22
schangxiang@126.com
2024-12-11 ce35b6cf3c6c35e485429c2a9d061e0fe2122151
CC/iWareCC_ASRS/ThreadService/04_BZ21£¨°áÔËÕû¶â»úÆ÷ÈË£©/1¡¢DataProcess_BZ21.cs
@@ -10,6 +10,7 @@
using iWareSql.WmsDBModel;
using Newtonsoft.Json.Linq;
using System;
using System.Collections;
using System.Collections.Generic;
using System.ComponentModel;
using System.Diagnostics.Contracts;
@@ -125,41 +126,62 @@
                                papercut.CreateTime = papercut.UpdateTime = DateTime.Now;
                                wmsDB.mes_push_papercut.Add(papercut);
                                AreaCodeEnum setAreaCode = AreaCodeEnum.合包裁切区;
                                UpiStatusEnum setUpiStatus = UpiStatusEnum.已合包;
                                var ngFlag = false;
                                var queryFlag = (int)UpiFlagEnum.NG;
                                var upilist = wmsDB.mes_batchOrderUPI_new.Where(x => x.PackageCode == upiObj.PackageCode).ToList();
                                var ngCount = upilist.Count(x => x.UpiFlag == queryFlag);
                                if (ngCount > 0)
                                {
                                    ngFlag = true;
                                    setUpiStatus = UpiStatusEnum.已下线;
                                    setAreaCode = AreaCodeEnum.下线区域;
                                }
                                else
                                {//不是NG
                                 //新增mes推送表
                                    var putpakegecodeid = Yitter.IdGenerator.YitIdHelper.NextId();
                                    var putpakegecode = new mes_push_packagecode()
                                    {
                                        Id = putpakegecodeid,
                                        PackageCode = upiObj.PackageCode,
                                        PushStatus = 0,
                                        PushNum = 0,
                                        ApiMessage = "",
                                        CreateTime = DateTime.Now,
                                        CreateUserName = SysGloble.WCSSystem,
                                        UpdateTime = DateTime.Now,
                                        UpdateUserName = SysGloble.WCSSystem
                                    };
                                    wmsDB.mes_push_packagecode.Add(putpakegecode);
                                    //新增表
                                    var mesinequeue = ClassHelper.RotationMapping<mes_package_linequeue, mes_batchOrderUPI_new>(upiObj);
                                    mesinequeue.Id = Yitter.IdGenerator.YitIdHelper.NextId();
                                    mesinequeue.CreateTime = mesinequeue.UpdateTime = DateTime.Now;
                                    wmsDB.mes_package_linequeue.Add(mesinequeue);
                                }
                                //更新表
                                var mesgather = wmsDB.mes_package_gather.Where(x => x.PackageCode == upiObj.PackageCode).FirstOrDefault();
                                if (mesgather != null)
                                {
                                    mesgather.AreaCode = (int)AreaCodeEnum.合包裁切区;
                                    mesgather.UpiStatus = (int)UpiStatusEnum.已合包;
                                    mesgather.AreaCode = (int)setAreaCode;
                                    mesgather.UpiStatus = (int)setUpiStatus;
                                }
                                //var upilist = wmsDB.mes_batchOrderUPI_new.Where(x => x.PackageCode == upiObj.PackageCode).ToList();
                                //var upilength = upilist.Max(x => x.Length);
                                //var upiwidth = upilist.Max(x => x.Width);
                                //cartonhigh = (short)upiObj.Info3;
                                //cartonwidth = (short)upiObj.Info2;
                                upiObj.UpiStatus = (int)UpiStatusEnum.已合包;
                                upiObj.AreaCode = (int)AreaCodeEnum.合包裁切区;
                                upiObj.UpiStatus = (int)setUpiStatus;
                                upiObj.AreaCode = (int)setAreaCode;
                                //记录任务
                                var _id = Yitter.IdGenerator.YitIdHelper.NextId();
                                var putpakegecodeid = Yitter.IdGenerator.YitIdHelper.NextId();
                                var plcTaskNo = BusinessHelper.CreatePlcTaskIdForSrmTask();
                                //新增表
                                var mesinequeue = ClassHelper.RotationMapping<mes_package_linequeue, mes_batchOrderUPI_new>(upiObj);
                                mesinequeue.Id = Yitter.IdGenerator.YitIdHelper.NextId();
                                //新增mes推送表
                                var putpakegecode = new mes_push_packagecode()
                                {
                                    Id = putpakegecodeid,
                                    PackageCode = upiObj.PackageCode,
                                    PushStatus = 0,
                                    PushNum = 0,
                                    ApiMessage = "",
                                    CreateTime = DateTime.Now,
                                    CreateUserName = SysGloble.WCSSystem,
                                    UpdateTime = DateTime.Now,
                                    UpdateUserName = SysGloble.WCSSystem
                                };
                                var plcTaskNo = BusinessHelper.CreatePlcTaskIdForSrmTask();
                                //新增任务表
                                var task = new wms_rbline_task()
                                {
@@ -205,9 +227,9 @@
                                printtwo.Id = Yitter.IdGenerator.YitIdHelper.NextId();
                                wmsDB.wms_record_print.Add(printtwo);
                                wmsDB.mes_package_linequeue.Add(mesinequeue);
                                wmsDB.wms_rbline_task.Add(task);
                                wmsDB.mes_push_packagecode.Add(putpakegecode);
                                //处理表  mes_order_gather
                                var errmsg = "";
@@ -218,24 +240,6 @@
                                    SystemWarningMsg._lbl_alert_DataProcess_BZ21 = errmsg;
                                    continue;
                                }
                                /*
                                using (StationServiceClient client = new StationServiceClient())
                                {
                                    var plcres = client.WriteSurroundTaskInfo((int)EDevice.Station, rgvLocation, short.Parse(task.TaskNo),
                                          (short)upilength, (short)upiwidth, cartonhigh, cartonwidth, 0, 0);
                                    if (!plcres.result)
                                    {
                                        SystemWarningMsg._lbl_alert_DataProcess_BZ12 = $"{rgvLocation.ToString()}-下发入库任务 å¤±è´¥,WriteInStoreTaskInfoAsync è¿”回:{plcres.resMsg}";
                                        continue;
                                    }
                                    else
                                    {
                                        Log4NetHelper.WriteInfoLog(logType, $"{rgvLocation.ToString()}-下发入库任务 æˆåŠŸ,WriteInStoreTaskInfoAsync,参数: ç«™ç‚¹{rgvLocation}");
                                    }
                                }
                                //*/
                                WmsRecordUpiProcessHandler.SaveWmsRecordUpiProcess(wmsDB, upiObj, "BZ21", "合包");