删除有问题的TCP旧代码, 优化事务处理和ERP数据模型

kazelee

9 天以前 2ca90a404fa1ab94eb6374f50c6ddd47a2b7f0e6

 core/WCSCore.cs

@@ -58,13 +58,13 @@
            // AGV 任务 134562(7) 状态处理
            switch (model.state) {
                case 1: // 执行
                    WCSHelper.Begin(TN_Task, model.forklift_no); // 已推送的任务的状态改成执行
                    WCSHelper.SetTaskBegin(TN_Task, model.forklift_no); // 已推送的任务的状态改成执行
                    break;
                case 3: // 开始取货
                    WCSHelper.UpdateStatus(TN_Task, "开始取货"); // 任务状态改成开始取货
                    WCSHelper.UpdateTaskState(TN_Task, "开始取货"); // 任务状态改成开始取货
                    break;
                case 4: // 取货完成
                    WCSHelper.UpdateStatus(TN_Task, "取货完成"); // 任务状态改成取货完成
                    WCSHelper.UpdateTaskState(TN_Task, "取货完成"); // 任务状态改成取货完成
                    TaskProcess.OperateStatus(TN_Task, 4); // 起点容器货位解绑,解锁起点

                    if (TN_Task.S_TYPE == ETask.C成品胶出库.Name()) {
@@ -78,14 +78,14 @@

                    break;
                case 5: // 开始卸货
                    WCSHelper.UpdateStatus(TN_Task, "开始卸货"); // 任务状态改成开始卸货
                    WCSHelper.UpdateTaskState(TN_Task, "开始卸货"); // 任务状态改成开始卸货
                    break;
                case 6: // 卸货完成
                    WCSHelper.UpdateStatus(TN_Task, "卸货完成"); // 任务状态改成卸货完成
                    WCSHelper.UpdateTaskState(TN_Task, "卸货完成"); // 任务状态改成卸货完成
                    TaskProcess.OperateStatus(TN_Task, 6); // 终点容器货位绑定,解锁终点
                    break;
                case 2: // 完成
                    WCSHelper.End(TN_Task); // 任务状态改成结束
                    WCSHelper.SetTaskEnd(TN_Task); // 任务状态改成结束

                    //if (TN_Task.S_TYPE == TaskName.抽检_出库) {
                    //    var checkCompleteTask = Task.Run(() => {
@@ -100,7 +100,7 @@
                    break;
                case 7: // 异常
                    TaskProcess.OperateStatus(TN_Task, 7); // 异常处理
                    WCSHelper.Fail(TN_Task); // 任务状态改成错误
                    WCSHelper.SetTaskFail(TN_Task); // 任务状态改成错误
                    break;
            }

@@ -195,7 +195,7 @@
            try {
                ModbusHelper.Relink();

                var BZQ = Settings.GetTaskInfo(ETask.M满托下线入库).StartAreas;
                var BZQ = ETask.M满托下线入库.StartAreas();
                var loc = db.Queryable<TN_Location>()
                    .Where(l => BZQ.Contains(l.S_AREA_CODE) && l.S_AGV_SITE == model.station_name).First();

@@ -327,7 +327,7 @@
                    LogHelper.Info($"物料编码不存在!");
                }

                var model = new OtherModel.PickUpReturnErpInfo {
                var model = new ErpModel.PickUpReturnErpInfo {
                    jhdh = plan.JHDH, // 计划单号 (唯一标识) 
                    ckzt = plan.CKZT, // 出库状态 (需要返回) 
                    jhlb = plan.JHLB, // 计划类别
@@ -491,10 +491,10 @@
        public static (bool, string) CreateInboundTask(string startLocCode, string cntrCode) {
            var db = new SqlHelper<object>().GetInstance();

            var taskInfo = Settings.GetTaskInfo(ETask.M满托下线入库);
            var taskName = taskInfo.TaskName;
            var startAreas = taskInfo.StartAreas;
            var endAreas = taskInfo.EndAreas;
            var tInfo = ETask.M满托下线入库.Info();
            var taskName = tInfo.TaskName;
            var startAreas = tInfo.StartAreas;
            var endAreas = tInfo.EndAreas;
            const string cntrType = "托盘";

            try {
@@ -533,7 +533,7 @@
                }

                var cntId = locCntrRel.S_CNTR_CODE;
                var task = WCSHelper.BuildTaskWithLocLock(startLoc, endLoc, cntId, taskName);
                var task = WCSHelper.BuildTaskAndLockLoc(startLoc, endLoc, cntId, taskName);

                using (var tran = db.Ado.UseTran()) {
                    if (locCntrRelOld != null) {