CC/iWareCC_ASRS/ThreadService/03_BZ12(»úÆ÷ÈËÂë°ü¹¤Î»)/DataProcess_BZ12.cs
@@ -92,6 +92,7 @@ continue; } upiObj.UpiStatus = (int)UpiStatusEnum.ç åä¸; upiObj.AreaCode = (int)AreaCodeEnum.ç ååºå; //æ¥å¤è¿å ææçæ°é var upiList = wmsDB.mes_batchOrderUPI_new.Where(x => x.PackageCode == upiObj.PackageCode).ToList(); //æ¥è¯¢æ¯å¦æ«æ¿å¹¶ä¸å¤æææ²¡ææ··æ¹ CC/iWareCC_ASRS/ThreadService/04_BZ21£¨°áÔËÕû¶â»úÆ÷ÈË£©/DataProcess_BZ21.cs
@@ -62,16 +62,13 @@ continue; } var upiCode = result.Replace("/r", ""); ; short cartonwidth = 0;//æ¯å¦æ«æ¿ short cartonhigh = 0;//æ¯å¦æè½¬ short placeX = 0; short placeY = 0; short placeZ = 0; short cartonwidth = 0;//纸箱宽 short cartonhigh = 0;//çº¸ç®±é« string place = "22"; using (WmsDBModel wmsDB = new WmsDBModel()) { //è¦æ¯æå·²ä¸åçä»»å¡ï¼å°±ä¸è¦æ§è¡ var isValidate = TaskHandler.ValidateIssueTaskForBZ21(wmsDB,result); var isValidate = TaskHandler.ValidateIssueTaskForBZ21(wmsDB, result); if (!isValidate) { SystemWarningMsg._lbl_alert_DataProcess_BZ21 = $"{rgvLocation.ToString()}-æâå·²ä¸åâçä»»å¡ï¼ä¸è½å¤ç,æ¤æ¬¡å¾ªç¯ç»æ"; @@ -83,28 +80,35 @@ SystemWarningMsg._lbl_alert_DataProcess_BZ21 = $"{rgvLocation.ToString()},æ ¹æ®UPI:{upiCode}æ²¡ææ¾å°å¯¹è±¡ "; continue; } var mesgather = wmsDB.mes_package_gather.Where(x => x.PackageCode == upiObj.PackageCode).FirstOrDefault(); if (mesgather != null) { mesgather.AreaCode = (int)AreaCodeEnum.åå è£ååº; mesgather.UpiStatus = (int)UpiStatusEnum.å·²åå ; } placeX = (short)upiObj.MachineXCenter; placeY = (short)upiObj.MachineYCenter; placeZ = (short)upiObj.MachineZCenter; cartonhigh = (short)upiObj.Info3; cartonwidth = (short)upiObj.Info2; upiObj.UpiStatus = (int)UpiStatusEnum.å·²åå ; upiObj.AreaCode = (int)AreaCodeEnum.åå è£ååº; //è®°å½ä»»å¡ 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(); var putpakegecode = new mes_push_packagecode() { Id = _id, PackageCode=upiObj.PackageCode, PushStatus=0, PushNum=0, ApiMessage="11", Id = putpakegecodeid, PackageCode = upiObj.PackageCode, PushStatus = 0, PushNum = 0, ApiMessage = "11", CreateTime = DateTime.Now, CreateUserName = "CC", UpdateTime = DateTime.Now, UpdateUserName = "CC", CreateOrgName="11" CreateOrgName = "11" }; var task = new wms_rbline_task() { @@ -129,14 +133,14 @@ UpdateUserName = "CC", PlaceCode = place }; wmsDB.mes_package_linequeue.Add(mesinequeue); wmsDB.wms_rbline_task.Add(task); // wmsDB.mes_push_packagecode.Add(putpakegecode); wmsDB.mes_push_packagecode.Add(putpakegecode); using (StationServiceClient client = new StationServiceClient()) { var res = client.WriteSurroundTaskInfo((int)EDevice.Station, rgvLocation, short.Parse(task.TaskNo), (short)upiObj.Length, (short)upiObj.Width,cartonhigh,cartonwidth,placeX,placeY); var res = client.WriteSurroundTaskInfo((int)EDevice.Station, rgvLocation, short.Parse(task.TaskNo), (short)upiObj.Length, (short)upiObj.Width, cartonhigh, cartonwidth, 0, 0); if (!res.result) { SystemWarningMsg._lbl_alert_DataProcess_BZ12 = $"{rgvLocation.ToString()}-ä¸åå ¥åºä»»å¡ 失败,WriteInStoreTaskInfoAsync è¿å:{res.resMsg}"; CC/iWareCC_ASRS/ThreadService/04_BZ21£¨°áÔËÕû¶â»úÆ÷ÈË£©/DataProcess_BZ21_FinishTask.cs
@@ -53,18 +53,30 @@ var task = wmsDB.wms_rbline_task.Where(x => x.TaskNo == obj.R_SurrouondTaskNo.ToString() && x.RbTaskType == (int)RbTaskTypeEnum.夹æ¿ä»»å¡ && x.TaskStatus == (int)TaskStatusEnum.å·²ä¸å).FirstOrDefault(); ).OrderByDescending(x=>x.Id).FirstOrDefault(); if (task == null) { SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = $"{rgvLocation.ToString()},æ ¹æ® R_InboundNumber:{obj.R_InboundNumber}æ²¡ææ¾å°å·²ä¸åçä»»å¡ "; continue; } else { if (task.TaskStatus == (int)TaskStatusEnum.已宿) { //ç»PLCæ¨éä»»å¡å®æç¡®è®¤ä¿¡å· using (StationServiceClient client = new StationServiceClient()) { var res = client.SetSurroundTaskFinishAck((int)EDevice.Station, true, rgvLocation); } continue; } } var upiobj = wmsDB.mes_batchOrderUPI_new.Where(x => x.PackageCode == task.PackageCode).ToList(); if (upiobj.Count > 0) { foreach (var item in upiobj) { item.UpiStatus = 4; item.UpiStatus = (int)UpiStatusEnum.å·²åå ; } } task.TaskStatus = (int)TaskStatusEnum.已宿; CC/iWareSql/DataAccess/TaskHandler.cs
@@ -43,7 +43,7 @@ public static bool ValidateIssueTaskForBZ12(WmsDBModel.WmsDBModel wmsDB,string str) { var isExist = wmsDB.wms_rbline_task.Where(x => x.TaskStatus == (int)TaskStatusEnum.å·²ä¸å && x.RbTaskType == (int)RbTaskTypeEnum.ç æ¿ä»»å¡).ToList(); && x.RbTaskType == (int)RbTaskTypeEnum.ç æ¿ä»»å¡ && x.UPI == str).ToList(); if (isExist?.Count() > 0) { return false; @@ -53,7 +53,7 @@ public static bool ValidateIssueTaskForBZ21(WmsDBModel.WmsDBModel wmsDB,string str) { var isExist = wmsDB.wms_rbline_task.Where(x => x.TaskStatus == (int)TaskStatusEnum.å·²ä¸å && x.RbTaskType == (int)RbTaskTypeEnum.夹æ¿ä»»å¡).ToList(); && x.RbTaskType == (int)RbTaskTypeEnum.夹æ¿ä»»å¡&&x.UPI==str).ToList(); if (isExist?.Count() > 0) { return false; LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Configuration/Database.json
@@ -9,7 +9,9 @@ //"ConfigId": "1300000000001", // é»è®¤åºæ è¯-ç¦æ¢ä¿®æ¹ "DbType": "SqlServer", // MySqlãSqlServerãSqliteãOracleãPostgreSQLãDmãKdbndpãOscarãMySqlConnectorãAccessãOpenGaussãQuestDBãHGãClickHouseãGBaseãOdbcãCustom // "ConnectionString": "Server=.;Database=iWare_RawMaterialWarehouse_Wms;User=sa;Password=123456;MultipleActiveResultSets=True;", // åºè¿æ¥å符串 "ConnectionString": "Server=172.17.1.111;Database=LA24030_LuLiPackageLine;User=sa;Password=admin@123;MultipleActiveResultSets=True;", // åºè¿æ¥å符串 // "ConnectionString": "Server=172.17.1.111;Database=LA24030_LuLiPackageLine;User=sa;Password=admin@123;MultipleActiveResultSets=True;", // åºè¿æ¥å符串 "ConnectionString": "Server=.;Database=LA24030_LuLiPackageLine;User=sa;Password=123abc.com;MultipleActiveResultSets=True;", // åºè¿æ¥å符串 //"SlaveConnectionConfigs": [ // 读åå离/ä¸»ä» // { // "HitRate": 10,