ECS / WCS_LiuzhouZhituo · Files

using HHWCS.Model;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using SystemLogHelper;

using LEDhelp;

namespace HHWCS.Bll
{

    public class Bll : IBll
    {   

        public static void Main(String[] args)
        {

            //string str = "";
            //for (int i = 1; i < 3; i++)
            //{

            //    for (int j = 1; j < 33; j++)

            //    {
            //        for (int k = 1; k < 6; k++)
            //        {

            //            str += String.Format("INSERT INTO `huaheng`.`location` (`code`, `warehouseId`, `warehouseCode`, `row`, `line`, `layer`, `grid`, `roadway`, `type`, `containerId`, `containerCode`, `zoneId`, `zoneCode`, `status`, `lastCycleCountDate`, `created`, `createdBy`, `lastUpdated`, `lastUpdatedBy`, `enable`, `deleted`, `userDef1`, `userDef2`, `userDef3`, `userDef4`, `userDef5`) VALUES ('{0}', '1', 'CS0001', '{1}', '{2}', '{3}', '0', '1', 'LK', NULL, NULL, NULL, NULL, 'empty', NULL, '2018-08-24 11:31:27', NULL, '2018-08-24 14:31:46', NULL, b'01', b'00', NULL, NULL, NULL, NULL, NULL);\r\n", "A" + i.ToString().PadLeft(2, '0') + j.ToString().PadLeft(2, '0') + k.ToString().ToString().PadLeft(2, '0'), i, j, k);

            //        }
            //    }
            //}
            //LogExecute.WriteInfoLog(str);
            //Console.WriteLine(str);
            //object a = false;
            //object b = "abc";
            //object c = 1;
            //object d = (byte)1;

            //object a =Convert.ToBoolean("True");
            //object b = Convert.ToInt32("1");
            //object c = Convert.ToByte("1");
            //object d = Convert.ToBoolean("0");

            //Console.WriteLine(a.GetType()+" - "+a);
            //Console.WriteLine(b.GetType() +" - "+b);
            //Console.WriteLine(c.GetType()+" - "+c);
            //Console.WriteLine(d.GetType()+ " - " + d);

            //Console.WriteLine(d);

            //byte a = 0b00010001;
            //Console.WriteLine(a);
            //LEDhelp.LEDHelper led = new LEDhelp.LEDHelper("192.168.10.110", 5005, 1);
            //led.SendLedInfo("dfadffgsdgsdfgs\\ndfgsdfgdfg16\\n开发机构涉及地方\\n管理会计师对方了国家\\n受到了房价太高迫而价格\\n破手机而苹果就是独立\\n开发背景来看笑话\\nVB哦时间的反馈给解释答复");

            //Bll bll = new Bll();
            //var a = bll.GetTaskDetailsByTaskId(150);
            //a.Data.ForEach(t => Console.WriteLine(t.ToString()));

            //Queue<string> q = new Queue<string>();

            //LEDHelper led = new LEDHelper("192.168.10.110", 5005, 1);

            //LEDHelper led2 = new LEDHelper("192.168.10.110", 5005, 1);
            //Task.Run(async () =>
            //{
            //    while (true)
            //    {
            //        await Task.Delay(3000);
            //        if (q.Count > 0)
            //        {
            //            led2.SendLedInfo(q.Dequeue()); 
            //        }
            //    }
            //});
            //String read = "";
            //while (read != "exit")
            //{
            //    read = Console.ReadLine();
            //    //led.SendLedInfo(read);
            //    q.Enqueue(read);
            //}

            Console.Read();
        }

        #region Login

        public async Task<BllResult> Login(string userName, string password)

        {
            return BllResultFactory.Sucess(null, "默认成功");
        }

        #endregion

        #region Task

        public BllResult<List<TaskDetailEntity>> GetTaskDetailsByTaskId(int taskId)
        {
            try
            {
                string sql = $"SELECT td.*,m.`name` materialName FROM task_detail td join material m on td.materialCode = m.`code` and td.warehouseId = m.warehouseId where td.taskId = {taskId}";
                var ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, sql);
                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                {
                    return BllResultFactory.Error<List<TaskDetailEntity>>(null, "没有数据");
                }
                var list = ds.Tables[0].AsEnumerable().Select(t => new TaskDetailEntity()
                {
                    Id = Convert.ToInt32(t["id"]),
                    TaskId = (int)t["taskId"],
                    WarehouseId = (int)t["warehouseId"],
                    WarehouseCode = t["warehouseCode"] is DBNull ? null : t["warehouseCode"].ToString(),
                    AllocationId = t["allocationId"] is DBNull ? -1 : Convert.ToInt32(t["allocationId"]),
                    MaterialCode = t["materialCode"] is DBNull ? null : t["materialCode"].ToString(),
                    ContainerCode = t["containerCode"] is DBNull ? null : t["containerCode"].ToString(),
                    SourceLocation = t["sourceLocation"] is DBNull ? null : t["sourceLocation"].ToString(),
                    DestinationLocation = t["destinationLocation"] is DBNull ? null : t["destinationLocation"].ToString(),
                    Qty = t["qty"] is DBNull ? 0 : Convert.ToInt32(t["qty"]),
                    Status = Convert.ToInt32(t["status"]),
                    Endtime = t["endTime"] is DBNull ? null : (DateTime?)(t["endTime"]),
                    LastUpdated = t["lastUpdated"] is DBNull ? null : (DateTime?)t["lastUpdated"],
                    LastUpdateBy = t["lastUpdatedBy"] is DBNull ? "" : t["lastUpdatedBy"].ToString(),
                    Deleted =Convert.ToBoolean(t["deleted"]),
                    MaterialName = t["materialName"] is DBNull ? null : t["materialName"].ToString()
                }).ToList();
                return BllResultFactory.Sucess<List<TaskDetailEntity>>(list, "成功");

            }
            catch (Exception ex)
            {
                return BllResultFactory.Error<List<TaskDetailEntity>>(null, "查询失败");
            }
        }

        /// <summary>

        /// 处理空出
        /// </summary>
        /// <param name="v"></param>
        /// <param name="task"></param>
        /// <returns></returns>
        public BllResult EmptyOutHandle(string v, string status, TaskEntity task)
        {
            try
            {

                string sql = $"UPDATE task set isEmptyOut ={v} ,lastStatus = {status},firstStatus={status}  where id = {task.Id}";

                int i = MySqlHelper.ExecuteNonQuery(AppCommon.ConnectionString, sql);
                if (i == 0)
                {
                    UpdateLocationStatus(task.DestinationLocation, AppCommon.WarehouseId, "empty", AppCommon.ConnectionString);
                    UpdateLocationStatus(task.SourceLocation, AppCommon.WarehouseId, "empty", AppCommon.ConnectionString);
                    return BllResultFactory.Error(null, "更新失败");
                }
                else
                {
                    return BllResultFactory.Sucess(null, "成功");
                }
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error(null, "空出处理失败：" + ex.ToString());
            }
        }

        /// <summary>

        /// 处理重入
        /// </summary>
        /// <param name="location"></param>
        /// <param name="task"></param>
        /// <returns></returns>

        public BllResult TaskDoubleInHandle(string flag, String location, int taskId)

        {
            try
            {

                string sql = $"update task set isDoubleIn = {flag},secondDestinationLocation = '{location}' WHERE id = {taskId}";

                int i = MySqlHelper.ExecuteNonQuery(AppCommon.ConnectionString, sql);
                if (i == 0)
                {
                    return BllResultFactory.Error(null, "更新失败");
                }
                else
                {

                    UpdateLocationStatus(location, AppCommon.WarehouseId, "lock", AppCommon.ConnectionString);

                    return BllResultFactory.Sucess(null, "更新成功");
                }
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error(null, "更新失败：" + ex.ToString());
            }
        }

        public BllResult<List<TaskEntity>> GetTasks(string status, string taskNo, string pallet, DateTime? beginTime, DateTime? endTime)

        {

            try

            {

                String sql = "select * from task where 1=1 ";
                if (!String.IsNullOrEmpty(status))
                {

                    sql += " and lastStatus = '" + status + "'";

                }
                if (!String.IsNullOrEmpty(taskNo))
                {
                    sql += " and id = " + taskNo;
                }
                if (!String.IsNullOrEmpty(pallet))
                {
                    sql += " and containerCode = '" + pallet + "'";
                }
                if (beginTime != null)
                {
                    sql += " and created>='" + beginTime.ToString() + "'";
                }
                if (endTime != null)
                {
                    sql += " and created<='" + endTime.ToString() + "'";
                }

                sql += " ORDER BY lastUpdated ";

                DataSet ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, sql);
                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                {
                    return BllResultFactory.Error<List<TaskEntity>>(null, "未找到数据");
                }
                return BllResultFactory.Sucess<List<TaskEntity>>(ds.Tables[0].AsEnumerable().Select(x => new TaskEntity
                {
                    Id = (int)x["id"],
                    WarehouseId = Convert.ToInt32(x["warehouseId"]),
                    WarehouseCode = x["warehouseCode"]?.ToString(),
                    CompanyId = x["companyId"] is DBNull ? null : (int?)x["companyId"],
                    Priority = Convert.ToInt32(x["priority"]),
                    Type = Convert.ToInt32(x["type"]),
                    Station = x["station"] is DBNull ? null : (int?)x["station"],
                    ContainerId = x["containerId"] is DBNull ? null : (int?)x["containerId"],
                    ContainerCode = x["containerCode"]?.ToString(),
                    SourceLocation = x["sourceLocation"]?.ToString(),
                    DestinationLocation = x["destinationLocation"]?.ToString(),

                    FirstStatus = Convert.ToInt32(x["firstStatus"]),
                    LastStatus = Convert.ToInt32(x["lastStatus"]),

                    Created = x["created"] is DBNull ? null : (DateTime?)x["created"],
                    CreatedBy = x["createdBy"]?.ToString(),
                    BeginTime = x["beginTime"] is DBNull ? null : (DateTime?)x["beginTime"],
                    EndTime = x["endTime"] is DBNull ? null : (DateTime?)x["endTime"],
                    LastUpdated = x["lastUpdated"] is DBNull ? null : (DateTime?)x["lastUpdated"],

                    IsDoubleIn = Convert.ToInt32(x["isDoubleIn"]),

                    SecondDestinationLocation = x["secondDestinationLocation"] is DBNull ? null : x["secondDestinationLocation"].ToString()

                }).OrderByDescending(t => t.Created).ToList(), "成功");

            }

            catch (Exception ex)

            {

                return BllResultFactory.Error<List<TaskEntity>>(null, "获取任务出现异常：" + ex.ToString());
            }

        }

        public virtual BllResult SendTaskToWCS(int id)

        {
            try
            {

                var tasks = GetTasks(null, id.ToString(), null, null, null);

                if (!tasks.Success)
                {
                    return BllResultFactory.Error(null, "未找到任务");
                }
                var task = tasks.Data[0];

                if (task.LastStatus != 0)

                {
                    return BllResultFactory.Error(null, "任务状态不允许下发");
                }

                string sql = "update task set lastStatus = 10,firstStatus=10 where id = " + id;

                int i = MySqlHelper.ExecuteNonQuery(AppCommon.ConnectionString, sql);
                if (i > 0)
                {
                    return BllResultFactory.Sucess(null, "成功");
                }
                else
                {
                    return BllResultFactory.Error(null, "更新失败");
                }
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error(null, "更新出现异常：" + ex.ToString());
            }
        }

        /// <summary>
        /// 创建任务
        /// </summary>
        /// <param name="palletCode"></param>
        /// <param name="station"></param>
        /// <param name="sourceLocation"></param>
        /// <param name="destinationLocation"></param>
        /// <param name="status"></param>
        /// <param name="type"></param>
        /// <param name="priority"></param>
        /// <returns>注意，任务实体没有返回</returns>

        public BllResult<TaskEntity> CreatTask(string palletCode, int station, string sourceLocation, string destinationLocation, int status, int type, int priority)

        {
            MySqlConnection mySqlConnection = new MySqlConnection(AppCommon.ConnectionString);
            MySqlTransaction tran = null;
            try
            {
                //检查参数

                if (!String.IsNullOrEmpty(palletCode))

                {
                    //校验托盘，查看托盘是否存在任务未完成

                    int result = Convert.ToInt32(MySqlHelper.ExecuteScalar(AppCommon.ConnectionString, "SELECT count(*) from task where containerCode = @pallet and `lastStatus`<40 and warehouseId= @warehouseId", new MySqlParameter("@pallet", palletCode), new MySqlParameter("@warehouseId", AppCommon.WarehouseId)));

                    if (result > 0)
                    {
                        return BllResultFactory.Error<TaskEntity>(null, "托盘已存在任务");
                    }
                }
                if (type == 100 || type == 500 || type == 800)
                {
                    if (String.IsNullOrEmpty(destinationLocation))
                    {
                        return BllResultFactory.Error<TaskEntity>(null, "对于整盘入库、空盘入库和移库目标库位不能为空");
                    }

                    else if (String.IsNullOrEmpty(palletCode))
                    {
                        return BllResultFactory.Error<TaskEntity>(null, "对于整盘入库、空盘入库和移库托盘号不能为空");
                    }

                    else
                    {

                        var temp = CheckLocationForCreateTaskIn(destinationLocation, AppCommon.WarehouseId);

                        if (!temp.Success)
                        {
                            return temp;
                        }
                    }
                }

                if (type == 200 || type == 300 || type == 400 || type==900 || type == 600 || type == 700 || type == 800)

                {
                    if (String.IsNullOrEmpty(sourceLocation))
                    {

                        return BllResultFactory.Error<TaskEntity>(null, "对于补充入库、整盘出库、分拣出库、空盘出库、出库查看、盘点和移库源库位不能为空");

                    }
                    else
                    {
                        //校验库位

                        var temp = GetAllLocations(null, null, null, null, null, null, sourceLocation);

                        if (!temp.Success)
                        {

                            return BllResultFactory.Error<TaskEntity>(null, "未找到" + sourceLocation);

                        }
                        var location = temp.Data[0];
                        if (location.Status != "empty")
                        {

                            return BllResultFactory.Error<TaskEntity>(null, sourceLocation + "非空闲");

                        }
                        if (string.IsNullOrEmpty(location.ContainerCode))
                        {

                            return BllResultFactory.Error<TaskEntity>(null, sourceLocation + "没有托盘");

                        }
                        if (string.IsNullOrEmpty(palletCode))
                        {
                            palletCode = location.ContainerCode;
                        }
                        else
                        {
                            if (palletCode != location.ContainerCode)
                            {

                                return BllResultFactory.Error<TaskEntity>(null, sourceLocation + "库位托盘为" + location.ContainerCode + "与录入的" + palletCode + "不一致");

                            }

                        }

                    }
                }
                mySqlConnection.Open();
                tran = mySqlConnection.BeginTransaction();

                string sql = "insert into task(containerCode,station,sourceLocation,destinationLocation,lastStatus,firstStatus,type,priority,warehouseId,warehouseCode,created,createdBy) " +
                    " VALUES(@pallet, @station, @sourceLocation, @destinationLocation, @lastStatus,@firstStatus, @type, @priority, @warehouseId,@warehouseCode, NOW(),@createdBy)";

                List<MySqlParameter> mySqlParameters = new List<MySqlParameter>();
                mySqlParameters.Add(new MySqlParameter("@pallet", palletCode));
                mySqlParameters.Add(new MySqlParameter("@station", station));
                mySqlParameters.Add(new MySqlParameter("@sourceLocation", sourceLocation));
                mySqlParameters.Add(new MySqlParameter("@destinationLocation", destinationLocation));

                mySqlParameters.Add(new MySqlParameter("@lastStatus", status));
                mySqlParameters.Add(new MySqlParameter("@firstStatus", status));

                mySqlParameters.Add(new MySqlParameter("@type", type));
                mySqlParameters.Add(new MySqlParameter("@priority", priority));
                mySqlParameters.Add(new MySqlParameter("@warehouseId", AppCommon.WarehouseId));
                mySqlParameters.Add(new MySqlParameter("@createdBy", AppCommon.User.UserName));
                mySqlParameters.Add(new MySqlParameter("@warehouseCode", AppCommon.WarehouseCode));
                int i = MySqlHelper.ExecuteNonQuery(mySqlConnection, sql, mySqlParameters.ToArray());
                if (i == 1)
                {
                    if (type == 100 || type == 500 || type == 800)
                    {

                        var temp = UpdateLocationStatus(destinationLocation, AppCommon.WarehouseId, "lock", mySqlConnection);

                        if (!temp.Success)
                        {
                            tran.Rollback();
                            return BllResultFactory.Sucess<TaskEntity>(null, "创建任务失败，更新货位状态失败");
                        }
                    }

                    if (type == 200 || type == 300 || type == 400 || type == 900 || type == 600 || type == 700 || type == 800)

                    {

                        var temp = UpdateLocationStatus(sourceLocation, AppCommon.WarehouseId, "lock", mySqlConnection);

                        if (!temp.Success)
                        {
                            tran.Rollback();
                            return BllResultFactory.Sucess<TaskEntity>(null, "创建任务失败，更新货位状态失败");
                        }
                    }
                    //更新货位状态为预定
                    tran.Commit();
                    return BllResultFactory.Sucess<TaskEntity>(null, "成功");
                }
                else
                {
                    tran.Rollback();
                    return BllResultFactory.Error<TaskEntity>(null, "插入任务失败");
                }
            }
            catch (Exception ex)
            {
                tran?.Rollback();
                return BllResultFactory.Error<TaskEntity>(null, "出现异常:" + ex.ToString());
            }
            finally
            {
                mySqlConnection.Close();
                mySqlConnection.Dispose();
            }
        }

        public BllResult<TaskEntity> CheckLocationForCreateTaskIn(String code, int warehouseId)

        {
            //校验库位
            var ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, "SELECT * from location where `code` = @code and warehouseId = @warehouseId", new MySqlParameter("@code", code), new MySqlParameter("@warehouseId", AppCommon.WarehouseId));
            if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
            {
                return BllResultFactory.Error<TaskEntity>(null, "没有找到库位");
            }
            var dr = ds.Tables[0].AsEnumerable().FirstOrDefault();

            if (dr["status"].ToString() != "empty")

            {
                return BllResultFactory.Error<TaskEntity>(null, "目标库位非空闲");
            }
            if (!String.IsNullOrEmpty(dr["containerCode"].ToString()))
            {
                return BllResultFactory.Error<TaskEntity>(null, "目标库位已有货，请不要重入");
            }
            return BllResultFactory.Sucess<TaskEntity>(null, "OK");
        }

        public BllResult SetTaskStatus(int taskId, int status)

        {
            try
            {

                string sql = "update task set lastStatus =" + status + ",firstStatus=" + status + " where id =" + taskId;

                int i = MySqlHelper.ExecuteNonQuery(AppCommon.ConnectionString, sql);
                if (i > 0)
                {
                    return BllResultFactory.Sucess(null, "更新成功");
                }
                else
                {
                    return BllResultFactory.Error(null, "更新失败");
                }
            }
            catch (Exception ex)
            {

                return BllResultFactory.Error(null, "更新出现异常:" + ex.ToString());

            }

        }

        /// <summary>
        /// 更新货位状态
        /// </summary>
        /// <param name="locationCode"></param>
        /// <param name="warehouseId"></param>
        /// <param name="newStatus"></param>
        /// <returns></returns>

        public BllResult<int> UpdateLocationStatus(String locationCode, int warehouseId, String newStatus, MySqlConnection mySqlConnection)

        {
            string sql = "update location set `status` = @status where code = @code;";
            List<MySqlParameter> mySqlParameters = new List<MySqlParameter>();
            mySqlParameters.Add(new MySqlParameter("@status", newStatus));
            mySqlParameters.Add(new MySqlParameter("@code", locationCode));
            //mySqlParameters.Add(new MySqlParameter("@warehouseId", warehouseId));
            int i = MySqlHelper.ExecuteNonQuery(mySqlConnection, sql, mySqlParameters.ToArray());
            if (i != 1)
            {
                return BllResultFactory.Error<int>(0, "失败");
            }
            else
            {
                return BllResultFactory.Sucess<int>(0, "成功");
            }

        }

        /// <summary>
        /// 更新货位状态
        /// </summary>
        /// <param name="locationCode"></param>
        /// <param name="warehouseId"></param>
        /// <param name="newStatus"></param>
        /// <returns></returns>

        public BllResult<int> UpdateLocationStatus(String locationCode, int warehouseId, String newStatus, String mySqlConnection)

        {
            string sql = "update location set `status` = @status where code = @code;";
            List<MySqlParameter> mySqlParameters = new List<MySqlParameter>();
            mySqlParameters.Add(new MySqlParameter("@status", newStatus));
            mySqlParameters.Add(new MySqlParameter("@code", locationCode));
            //mySqlParameters.Add(new MySqlParameter("@warehouseId", warehouseId));
            int i = MySqlHelper.ExecuteNonQuery(mySqlConnection, sql, mySqlParameters.ToArray());
            if (i != 1)
            {
                return BllResultFactory.Error<int>(0, "失败");
            }
            else
            {
                return BllResultFactory.Sucess<int>(0, "成功");
            }

        }

        /// <summary>
        /// 完成任务
        /// todo:事物管理
        /// </summary>
        /// <param name="task"></param>

        public virtual BllResult CompleteTask(string taskId)

        {
            try
            {

                var tasks = GetTasks(null, taskId, null, null, null);

                if (!tasks.Success)
                {
                    return BllResultFactory.Error(null, "未找到任务");
                }
                var task = tasks.Data[0];

                if (task.LastStatus == 40)

                {
                    return BllResultFactory.Error(null, "任务已完成请不要重复完成");
                }

                //入库任务将托盘更新到货位上、更新任务状态、更新货位状态
                //整入、空入
                if (task.Type == 100 || task.Type == 500)
                {
                    //更新货位状态为空闲

                    var location = GetAllLocations(null, null, null, null, null, null, task.DestinationLocation).Data[0];
                    var temp = UpdateLocationStatus(location.Code, task.WarehouseId, "empty", AppCommon.ConnectionString);

                    if (task.IsDoubleIn == 1)
                    {
                        //

                        UpdateLocationStatus(task.SecondDestinationLocation, task.WarehouseId, "empty", AppCommon.ConnectionString);
                        SetLocationPallet(task.SecondDestinationLocation, task.ContainerCode);

                    }
                    else
                    {
                        //更新托盘到货位上

                        SetLocationPallet(location.Code, task.ContainerCode);

                    }

                    //更新任务状态

                    SetTaskStatus(task.Id, 40);

                }
                //补入、分拣、盘点

                if (task.Type == 200 || task.Type == 400 || task.Type == 900 || task.Type == 700)

                {
                    //更新货位状态为空闲

                    var location = GetAllLocations(null, null, null, null, null, null, task.SourceLocation).Data[0];
                    var temp = UpdateLocationStatus(location.Code, task.WarehouseId, "empty", AppCommon.ConnectionString);

                    if (task.IsDoubleIn == 1)
                    {

                        UpdateLocationStatus(task.SecondDestinationLocation, task.WarehouseId, "empty", AppCommon.ConnectionString);
                        SetLocationPallet(task.SecondDestinationLocation, task.ContainerCode);

                        //清除原来货位上的托盘

                        SetLocationPallet(location.Code, "");

                    }
                    else
                    {
                        //更新托盘到货位上

                        SetLocationPallet(location.Code, task.ContainerCode);

                    }

                    //更新任务状态

                    SetTaskStatus(task.Id, 40);

                }
                if (task.Type == 300 || task.Type == 600)
                {
                    //整出、空出
                    //更新货位状态为空闲

                    var location = GetAllLocations(null, null, null, null, null, null, task.SourceLocation).Data[0];
                    var temp = UpdateLocationStatus(location.Code, task.WarehouseId, "empty", AppCommon.ConnectionString);

                    //清理货位上托盘

                    SetLocationPallet(location.Code, "");

                    //更新任务状态

                    SetTaskStatus(task.Id, 40);

                }
                if (task.Type == 800)
                {
                    //更新货位状态为空闲

                    var location = GetAllLocations(null, null, null, null, null, null, task.SourceLocation).Data[0];
                    var location2 = GetAllLocations(null, null, null, null, null, null, task.DestinationLocation).Data[0];
                    var temp = UpdateLocationStatus(location.Code, task.WarehouseId, "empty", AppCommon.ConnectionString);
                    var temp2 = UpdateLocationStatus(location2.Code, task.WarehouseId, "empty", AppCommon.ConnectionString);

                    //清理货位上托盘

                    SetLocationPallet(location.Code, "");

                    if (task.IsDoubleIn == 1)
                    {

                        UpdateLocationStatus(task.SecondDestinationLocation, task.WarehouseId, "empty", AppCommon.ConnectionString);
                        SetLocationPallet(task.SecondDestinationLocation, task.ContainerCode);

                    }
                    else
                    {
                        //新增目标货位上的托盘

                        SetLocationPallet(location2.Code, task.ContainerCode);

                    }

                    //更新任务状态

                    SetTaskStatus(task.Id, 40);

                }
                return BllResultFactory.Sucess(null, "完成任务成功");
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error(null, "完成任务发生异常：" + ex.ToString());
            }

        }

        /// <summary>
        /// 删除任务，只有生成未执行的任务可以删除
        /// </summary>
        /// <param name="taskId"></param>
        /// <returns></returns>

        public BllResult DeleteTask(int taskId)

        {
            try
            {

                var tasks = GetTasks(null, taskId.ToString(), null, null, null);

                if (!tasks.Success)
                {
                    return BllResultFactory.Error(null, "未找到任务");
                }
                var task = tasks.Data[0];

                if (task.LastStatus != 0)

                {
                    return BllResultFactory.Error(null, "任务状态不允许删除");
                }
                string sql = "DELETE from task where id = " + taskId;
                int i = MySqlHelper.ExecuteNonQuery(AppCommon.ConnectionString, sql);
                if (i > 0)
                {
                    return BllResultFactory.Sucess(null, "删除成功");
                }
                else
                {
                    return BllResultFactory.Error(null, "删除失败");
                }
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error(null, "删除任务出现异常：" + ex.ToString());
            }

        }

        /// <summary>
        /// 根据托盘号获取一条未完成的任务
        /// </summary>
        /// <param name="palletCode"></param>
        /// <returns></returns>

        public BllResult<TaskEntity> GetTaskUncompleteByPalletCode(string palletCode)

        {
            try
            {

                string sql = "SELECT * from task where `lastStatus`<40 and containerCode = '" + palletCode + "'";

                var ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, sql);

                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)

                {
                    return BllResultFactory.Error<TaskEntity>(null, "未找到数据");
                }
                return BllResultFactory.Sucess<TaskEntity>(ds.Tables[0].AsEnumerable().Select(x => new TaskEntity
                {
                    Id = (int)x["id"],
                    WarehouseId = Convert.ToInt32(x["warehouseId"]),
                    WarehouseCode = x["warehouseCode"]?.ToString(),
                    CompanyId = x["companyId"] is DBNull ? null : (int?)x["companyId"],
                    Priority = Convert.ToInt32(x["priority"]),
                    Type = Convert.ToInt32(x["type"]),
                    Station = x["station"] is DBNull ? null : (int?)x["station"],
                    ContainerId = x["containerId"] is DBNull ? null : (int?)x["containerId"],
                    ContainerCode = x["containerCode"]?.ToString(),
                    SourceLocation = x["sourceLocation"]?.ToString(),
                    DestinationLocation = x["destinationLocation"]?.ToString(),

                    LastStatus = Convert.ToInt32(x["lastStatus"]),

                    Created = x["created"] is DBNull ? null : (DateTime?)x["created"],
                    CreatedBy = x["createdBy"]?.ToString(),
                    BeginTime = x["beginTime"] is DBNull ? null : (DateTime?)x["beginTime"],
                    EndTime = x["endTime"] is DBNull ? null : (DateTime?)x["endTime"],
                    LastUpdated = x["lastUpdated"] is DBNull ? null : (DateTime?)x["lastUpdated"],
                }).OrderByDescending(t => t.Created).ToList()[0], "成功");
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error<TaskEntity>(null, "获取数据出现异常：" + ex.ToString());
            }
        }

        /// <summary>
        /// todo:根据空托盘创建一条空托盘入库任务,暂时不实现
        /// </summary>
        /// <param name="palletCode"></param>
        /// <returns></returns>