From 14418bf90619163acb85da349a3f1bd7809014d7 Mon Sep 17 00:00:00 2001
From: zxx <Zxx@HanInfo>
Date: 星期一, 07 七月 2025 10:58:50 +0800
Subject: [PATCH] 1
---
HH.WCS.Mobox3/HH.WCS.Mobox3.XiaoMi/process/TaskProcess.cs | 1267 ++++++++++-----------------------------------------------
1 files changed, 231 insertions(+), 1,036 deletions(-)
diff --git a/HH.WCS.Mobox3/HH.WCS.Mobox3.XiaoMi/process/TaskProcess.cs b/HH.WCS.Mobox3/HH.WCS.Mobox3.XiaoMi/process/TaskProcess.cs
index 97b00c5..e06e524 100644
--- a/HH.WCS.Mobox3/HH.WCS.Mobox3.XiaoMi/process/TaskProcess.cs
+++ b/HH.WCS.Mobox3/HH.WCS.Mobox3.XiaoMi/process/TaskProcess.cs
@@ -27,6 +27,8 @@
using Newtonsoft.Json.Linq;
using S7.Net;
using System.Threading.Tasks;
+using HH.WCS.XiaoMi.LISTA.dispatch;
+using static HH.WCS.XiaoMi.LISTA.dispatch.RcsHelper;
namespace HH.WCS.XiaoMi.process
{
@@ -368,7 +370,61 @@
else { result = true; }
return result;
}
+ //灏忕背鎺ㄩ�浠诲姟
+ internal static bool SendXmTask(WCSTask mst)
+ {
+ var result = false;
+ var taskState = mst.N_B_STATE;
+ if (taskState == 0)
+ {
+ Console.WriteLine($"浠诲姟mst {JsonConvert.SerializeObject(mst)}");
+ LogHelper.Info($"浠诲姟mst {JsonConvert.SerializeObject(mst)}", "浠诲姟");
+ //var startLoc = LocationHelper.GetLoc(mst.S_START_LOC);
+ //var endLoc = LocationHelper.GetLoc(mst.S_END_LOC);
+ if (mst.S_START_LOC != null && mst.S_END_LOC != null)
+ {
+ string src = $"\"src\":\"{mst.S_START_LOC}\",";
+ string dst = $"\"dst\":\"{mst.S_END_LOC}\",";
+ string carrier_type_id = $"\"carrier_type_id\":\"1\"";
+ string parmeS = "{";
+ string parmeD = "}";
+ string parme = parmeS + src + dst + carrier_type_id + parmeD;
+
+ LogHelper.Info($"鎺ㄩ�浠诲姟鍙傛暟{parme}", "浠诲姟");
+ AntsTaskModel model = new AntsTaskModel();
+ model.order_name = mst.S_CODE;
+ model.priority = 1;
+ model.dead_line = DateTime.Now.ToString();
+ model.ts_name = mst.S_TYPE;
+ model.parameters = parme;
+ //model.parameters = new AntsParasModel {
+ // src = mst.S_START_LOC,
+ // dst = mst.S_END_LOC,
+ // carrier_type_id="-99"
+ //};
+ var res = RcsHelper.CreateAntsOrder(model);
+ if (res)
+ {
+ //鏇存柊浠诲姟鐘舵�
+ mst.N_B_STATE = 1;
+ //mst.S_EQ_TASK_CODE = res.ToString();
+ WCSHelper.UpdateStatus(mst);
+ WCSHelper.UpdateEQNo(mst);
+ ////鎺ㄩ�鎴愬姛锛屼慨鏀逛换鍔＄姸鎬�+ //TaskHelper.UpdateStatus(mst, "宸叉帹閫�);
+ ////鎺ㄩ�鎴愬姛锛屼慨鏀瑰浗鑷狪D
+ //TaskHelper.UpdateGzId(mst, res);
+ LogHelper.Info($"浠诲姟mst {mst.S_CODE}鎺ㄩ�鎴愬姛", "浠诲姟");
+ result = true;
+ }
+ }
+
+ }
+
+ else { result = true; }
+ return result;
+ }
/// <summary>
/// 鍒涘缓鎼繍浠诲姟
@@ -390,6 +446,24 @@
var res = WCSHelper.CreateTask(taskNo, start.Trim(), end.Trim(), taskType, priority, trayCodes, trayCarryCount, startLayer, endLayer);
+ if (res)
+ {
+ result = true;
+ //浠诲姟鍒涘缓鎴愬姛锛岃捣鐐硅揣浣嶅嚭搴撻攣瀹氾紝缁堢偣璐т綅鍏ュ簱閿佸畾
+ LocationHelper.LockLoc(start, 2);
+ LocationHelper.LockLoc(end, 1);
+ }
+ return result;
+ }
+ //灏忕背澶т欢
+ public static bool CreateTransportDj(string start, string end, string taskType, string cntrs,string orderName, int startLayer, int endLayer, int trayCarryCount = 1, int priority = 1)
+ {
+ var result = false;
+ var trayCodes = cntrs;
+ var taskNo = DateTime.Now.Ticks.ToString();
+
+
+ var res = WCSHelper.CreateTaskDj(taskNo, start.Trim(), end.Trim(), taskType, priority, trayCodes, orderName,trayCarryCount, startLayer, endLayer);
if (res)
{
result = true;
@@ -714,6 +788,7 @@
result = list.OrderBy(s => s.N_ROW).ThenBy(x => x.N_COL).FirstOrDefault();
}
+
}
}
@@ -875,897 +950,6 @@
return result;
}
- #region 宸ㄧ煶浠ｇ爜
- /// <summary>
- /// 甯歌閫佹缂撳瓨鍖鸿揣浣�abc涓変釜鍖�涓ゅ眰
- /// </summary>
- /// <param name="startloc">璧风偣璐т綅</param>
- /// <param name="area">搴撳尯</param>
- /// <returns></returns>
- public static Location InCgWorkTransport(string startloc, string area)
- {
- Location result = null;
- var db = new SqlHelper<object>().GetInstance();
- try
- {
- //A,B,C3涓揣鏋朵笂锛岃繖涓鏈変紭鍏堢骇浜�CX03,04浼樺厛閫佸埌A鍖鸿揣鏋讹紝CX01,CX02浼樺厛閫佸埌B,C璐ф灦
- var reservoirs = Settings.ReservoirAreas.Where(s => s.areaName == "閫佹缂撳瓨鍖�).FirstOrDefault();
-
- var alllist = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == reservoirs.areaCode).ToList();
- // 浠庨厤缃幏鍙栦紭鍏堢骇瑙勫垯
- var mapping = Settings.PriorityLocs.FirstOrDefault(m => m.Location == startloc);
- LogHelper.Info($"閰嶇疆鐨勪紭鍏堢骇瑙勫垯{JsonConvert.SerializeObject(mapping)}");
- if (mapping == null)
- {
- LogHelper.Info($"鏈壘鍒颁骇绾縶startloc}鐨勪紭鍏堢骇閰嶇疆");
- return null;
- }
- var primaryAreas = mapping.PrimaryArea.Split(',');
- var secondaryAreas = mapping.SecondaryArea.Split(',');
- LogHelper.Info($"浼樺厛锛歿JsonConvert.SerializeObject(primaryAreas)}娆￠�锛歿JsonConvert.SerializeObject(secondaryAreas)}");
- // 绛涢�鏈攣涓旀湁绌虹殑璐т綅
- var availablePrimaryLocations = FilterAvailableLocations(alllist, primaryAreas);
- //浼樺厛
- result = availablePrimaryLocations.OrderBy(l => l.N_COL).ThenBy(l => l.N_LAYER).FirstOrDefault();
-
- // 娆￠�
- if (result == null)
- {
- var availableSecondaryLocations = FilterAvailableLocations(alllist, secondaryAreas);
- result = availableSecondaryLocations.OrderBy(l => l.N_COL).ThenBy(l => l.N_LAYER).FirstOrDefault();
- }
-
- return result;
-
- }
- catch (Exception ex)
- {
- Console.WriteLine("InWorkTransport:" + ex.Message + ex.StackTrace);
- LogHelper.Error("InWorkTransport:" + ex.Message, ex);
- }
- return result;
- }
- //绛涢�鍙敤浣嶇疆
- private static List<Location> FilterAvailableLocations(List<Location> locations, string[] targetAreas)
- {
- return locations
- .Where(l => targetAreas.Any(area => l.S_CODE.Contains(area)))
- .Where(l => l.N_LOCK_STATE == 0 && l.C_ENABLE == "Y" && l.N_CURRENT_NUM < l.N_CAPACITY)
- .ToList();
- }
-
- /// <summary>
- /// 绱у噾鍨嬪叆搴撹揣浣� 绱ф�閫佹鍖�绌烘墭缂撳瓨涓��浜屽尯
- /// </summary>
- /// <param name="area">搴撳尯</param>
- /// <returns></returns>
- public static Location CompactWorkTransport(string area)
- {
- Location result = null;
- var db = new SqlHelper<object>().GetInstance();
- try
- {
- //鏌ヨ姣忔帓鏈�悗涓�垪鏈夋墭鐩樼殑璐т綅 鏍规嵁琛屽垎鍖�鍐嶆壘姣忎竴琛岀殑鏈�悗涓�垪鏈夎揣鐨勮揣浣�- var list = db.Queryable<Location>().
- Where(a => a.N_CURRENT_NUM > 0 && a.S_AREA_CODE.Trim() == area).PartitionBy(a => a.N_ROW)
- .OrderByDescending(a => a.N_COL).Take(1).ToList();
- if (list.Count > 0)
- {
- for (int i = 0; i < list.Count; i++)
- {
- LogHelper.Info($"鏈夋墭鐩樻帓鍙穥list[i].N_ROW}锛屽簱鍖簕area}");
-
- //鍏ヨ揣浣嶅悗涓�綅璐т綅
- result = db.Queryable<Location>().OrderBy(a => a.N_COL)
- .Where(a => a.S_AREA_CODE.Trim() == area && a.N_ROW == list[i].N_ROW
- && a.N_COL > list[i].N_COL).First();
- if (result != null && result.N_LOCK_STATE == 0 && result.C_ENABLE == "Y")
- {
- return result;
- }
- }
- }
- //娌℃壘鍒拌鏄庡簱鍖烘槸绌虹殑 鍏ラ噷闈�- else
- {
- result = db.Queryable<Location>().
- Where(a => a.S_AREA_CODE.Trim() == area && a.N_LOCK_STATE == 0 && a.C_ENABLE == "Y" && a.N_CURRENT_NUM == 0)
- .OrderBy(a => a.N_COL).OrderBy(a => a.N_ROW).First();
- }
- }
- catch (Exception ex)
- {
- Console.WriteLine("InWorkTransport:" + ex.Message + ex.StackTrace);
- LogHelper.Error("InWorkTransport:" + ex.Message, ex);
- }
- return result;
- }
-
-
-
- /// <summary>
- /// 鐗╂枡涓嬬嚎/閫佹缂撳瓨鍖�>甯歌閫佹鍖�- /// </summary>
- /// <param name="model.START_LOC">璧风偣璐т綅</param>
- /// <param name="model.END_AREA">缁堢偣璐у尯</param>
- /// <param name="model.S_ITEM_CODE">鐗╂枡锛堥�濉級</param>
- /// <returns></returns>
- internal static Results materialOffline(GetSubmitCheck model)
- {
- var result = new Results() { Code = "0", Message = "涓嬬嚎浠诲姟鐢熸垚鎴愬姛锛�, Data = null };
- var db = new SqlHelper<Location>().GetInstance();
- try
- {
- //鏍￠獙璧风偣璐т綅鏄惁瀛樺湪/閿佷綇
- var loc = db.Queryable<Location>().Where(a => a.S_CODE == model.START_LOC).First();
- if (loc == null || loc.N_LOCK_STATE != 0 || loc.C_ENABLE != "Y")
- {
- return new Results { Code = "1", Message = $"{model.START_LOC}搴撲綅宸茶閿佸畾!", Data = null };
- }
- //璁＄畻缁堢偣璐т綅
- if (string.IsNullOrEmpty(model.END_AREA))
- {
- return new Results { Code = "1", Message = "鍑哄簱鏈紶缁堢偣搴撳尯!", Data = null };
- }
- //濡傛灉鏄揣鎬ラ�妫�尯 绱у噾鍨�- var reservoirs = Settings.ReservoirAreas.Where(s => s.areaName == "绱ф�閫佹鍖�).FirstOrDefault();
- //濡傛灉鏄�妫�紦瀛樺尯
- var reservoirs2 = Settings.ReservoirAreas.Where(s => s.areaName == "閫佹缂撳瓨鍖�).FirstOrDefault();
- Location OutLoc = null;
- if (model.END_AREA.Equals(reservoirs.areaCode))
- {
- LogHelper.Info($"绱ф�閫佹鍖�=================");
- OutLoc = CompactWorkTransport(model.END_AREA);
- }
- else if (model.END_AREA.Equals(reservoirs2.areaCode))
- {
- LogHelper.Info($"閫佹缂撳瓨鍖�=================");
- OutLoc = InCgWorkTransport(model.START_LOC, model.END_AREA);
- }
- else
- {
- LogHelper.Info($"鍏朵粬==================");
- OutLoc = InWorkTransport(model.END_AREA);
- }
-
- //娌′紶鐗╂枡鐨勮瘽榛樿涓�釜
- string itemCode = null;
- string wlName = null;
- if (!string.IsNullOrEmpty(model.S_ITEM_CODE))
- {
- itemCode = model.S_ITEM_CODE;
- wlName = "甯冨嵎";
- //wlName = db.Queryable<TN_Material>().Where(b => b.S_ITEM_CODE == model.S_ITEM_CODE).First().S_ITEM_NAME;
- }
- //鍒涘缓鎵樼洏璐т綅缁戝畾鍏崇郴
- string trayCode = ContainerHelper.GenerateCntrNo();
- //缁戝畾璧风偣璐т綅(浜х嚎)鍜岀墿鏂� 涓嶄紶鐨勮瘽杩欓噷娌℃湁缁戠墿鏂欐墭鐩樿〃 鍙粦浜嗘墭鐩樿揣浣嶈〃
- ContainerHelper.BindLocCntrs(model.START_LOC, trayCode, itemCode, wlName);
-
- var reservoirs1 = Settings.ReservoirAreas.Where(s => s.areaName == "甯歌閫佹鍖�).FirstOrDefault();
- //鍒涘缓浠诲姟
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{model.START_LOC}缁堢偣:{OutLoc.S_CODE}", OutLoc.S_CODE == reservoirs1.areaCode ? "甯歌閫佹" : "鐗╂枡涓嬬嚎");
- var res = TaskProcess.CreateTransport(model.START_LOC, OutLoc.S_CODE, OutLoc.S_CODE == reservoirs1.areaCode ? "甯歌閫佹" : "鐗╂枡涓嬬嚎", trayCode, 1, 1);
-
- if (!res)
- {
- return new Results { Code = "1", Message = "涓嬬嚎浠诲姟鐢熸垚澶辫触!", Data = null };
-
- }
- return result;
- }
- catch (Exception ex)
- {
- Console.WriteLine("materialOffline:" + ex.Message + ex.StackTrace);
- LogHelper.Error("materialOffline:" + ex.Message, ex);
- throw;
- }
- }
- /// <summary>
- /// 鍛煎彨绌烘墭
- /// </summary>
- /// <param name="model.START_LOC">璧风偣绫诲瀷(鎷嗘墭鏈�</param>
- /// <param name="model.END_LOC">缁堢偣璐т綅(浜х嚎)</param>
- /// <returns></returns>
- internal static Results CallEmptyTray(GetSubmitCheck model)
- {
- var result = new Results() { Code = "0", Message = "鍛煎彨绌烘墭浠诲姟鐢熸垚鎴愬姛锛�, Data = null };
- var db = new SqlHelper<Location>().GetInstance();
- try
- {
- //蹇呭～鍙傛暟鏍￠獙
- if (string.IsNullOrEmpty(model.START_LOC))
- {
- return new Results { Code = "1", Message = "鍛煎彨绌烘墭鏈紶璧风偣搴撲綅!", Data = null };
- }
- if (string.IsNullOrEmpty(model.END_LOC))
- {
- return new Results { Code = "1", Message = "鍛煎彨绌烘墭鏈紶缁堢偣搴撲綅!", Data = null };
- }
- //鏍￠獙缁堢偣璐т綅鏄惁瀛樺湪/閿佸畾
- var loc = db.Queryable<Location>().Where(a => a.S_CODE == model.END_LOC).First();
- if (loc == null || loc.N_LOCK_STATE != 0 || loc.C_ENABLE != "Y")
- {
- return new Results { Code = "1", Message = $"{model.END_LOC}搴撲綅宸茶閿佸畾!", Data = null };
- }
- ////浠庨厤缃牴鎹媶鎵樻満绫诲瀷鎵惧埌鍑哄彛璐т綅
- //var reservoirs = Settings.linePlcInfos.Where(s => s.code == model.S_TYPE).FirstOrDefault();
- //string OutLocStr = reservoirs.outLoca;
-
- //濡傛灉缁堢偣鍜屼骇绾夸笅绾挎槸鍚屼竴涓揣浣�缁堢偣涔熶笉缁戞墭鐩�- string trayCode = ContainerHelper.GenerateCntrNo();
- //鍒涘缓浠诲姟
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{model.START_LOC}缁堢偣:{model.END_LOC}", "鍛煎彨绌烘墭");
- var res = TaskProcess.CreateTransport(model.START_LOC, model.END_LOC, "鍛煎彨绌烘墭", trayCode, 1, 1);
- if (!res)
- {
- return new Results { Code = "1", Message = "鍛煎彨绌烘墭浠诲姟鐢熸垚澶辫触!", Data = null };
-
- }
- return result;
- }
- catch (Exception ex)
- {
- Console.WriteLine("CallEmptyTray:" + ex.Message + ex.StackTrace);
- LogHelper.Error("CallEmptyTray:" + ex.Message, ex);
- throw;
- }
- }
- /// <summary>
- /// 閫佹 甯歌閫佹鍖�->绱ф�閫佹鍖�- /// </summary>
- /// <param name="model.START_LOC">璧风偣璐т綅锛堥�濉級</param>
- /// <param name="model.S_ITEM_CODE">鐗╂枡锛堥�濉級</param>
- /// <returns></returns>
- internal static Results submitCheck(GetSubmitCheck model)
- {
- var result = new Results() { Code = "0", Message = "閫佹浠诲姟鐢熸垚鎴愬姛锛�, Data = null };
- var db = new SqlHelper<Location>().GetInstance();
- try
- {
- string startloc = "";
- //鐗╂枡涓嶄负绌哄垯鏍规嵁鐗╂枡鎵捐捣鐐硅揣浣�- if (!string.IsNullOrEmpty(model.S_ITEM_CODE))
- {
- //鏍规嵁鐗╂枡鎵捐揣浣�- var cgreservoirs = Settings.ReservoirAreas.Where(s => s.areaName == "甯歌閫佹鍖�).FirstOrDefault();
- startloc = getLocByMaterial(model.S_ITEM_CODE, cgreservoirs.areaCode).S_CODE;
- if (startloc == null)
- {
- return new Results { Code = "1", Message = $"{model.S_ITEM_CODE}鏈壘鍒拌鐗╂枡!", Data = null };
- }
- }
- //濡傛灉浼犱簡璧风偣
- if (!string.IsNullOrEmpty(model.START_LOC))
- {
- var loc = db.Queryable<Location>().Where(a => a.S_CODE == model.START_LOC).First();
- if (loc == null || loc.N_LOCK_STATE != 0 || loc.C_ENABLE != "Y")
- {
- return new Results { Code = "1", Message = $"{model.START_LOC}搴撲綅宸茶閿佸畾!", Data = null };
- }
- startloc = loc.S_CODE;
- }
- //璁＄畻绱ф�閫佹鍖虹粓鐐硅揣浣�- var reservoirs = Settings.ReservoirAreas.Where(s => s.areaName == "绱ф�閫佹鍖�).FirstOrDefault();
- Location OutLoc = TaskProcess.CompactWorkTransport(reservoirs.areaCode);
- if (OutLoc == null)
- {
- return new Results { Code = "1", Message = $"缁堢偣搴撳尯绱ф�閫佹鍖烘湭鎵惧埌绌鸿揣浣�", Data = null };
- }
- //鍒涘缓閫佹浠诲姟
- var locCntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == model.START_LOC).First();
-
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startloc}缁堢偣:{OutLoc.S_CODE}", "閫佹");
- var res = TaskProcess.CreateTransport(startloc, OutLoc.S_CODE, "閫佹", locCntrRel.S_CNTR_CODE, 1, 1);
- if (!res)
- {
- return new Results { Code = "1", Message = "閫佹浠诲姟鐢熸垚澶辫触!", Data = null };
-
- }
- return result;
- }
- catch (Exception ex)
- {
- Console.WriteLine("submitCheck:" + ex.Message + ex.StackTrace);
- LogHelper.Error("submitCheck:" + ex.Message, ex);
- throw;
- }
- }
-
- /// <summary>
- /// 鏍规嵁鐗╂枡鎵捐揣浣� 鏍规嵁CntrItemDetail鏃堕棿 鍏堣繘鍏堝嚭 杩炶〃鏌ュ垽鏂揣浣嶆湁娌℃湁閿�- /// </summary>
- /// <param name="itemCode">鐗╂枡</param>
- /// <returns></returns>
- public static Location getLocByMaterial(string itemCode, string areaCode)
- {
- Location result = null;
- try
- {
- var db = new SqlHelper<object>().GetInstance();
- //涓よ〃鑱旀煡鏌ュ嚭鏈夎鐗╂枡鐨勮揣浣嶇紪鍙� 锛堢幇鍦烘病鏈夌墿鏂欒〃锛�- var locCntrs = db.Queryable<LocCntrRel>().LeftJoin<CntrItemDetail>((p, m) => p.S_CNTR_CODE == m.S_CNTR_CODE)
- .Where((p, m) => m.S_ITEM_CODE == itemCode)
- .OrderBy((p, m) => p.T_CREATE) //鎸夊垱寤烘椂闂撮『搴�- .Select((p, m) => p.S_LOC_CODE) // 閫夋嫨鎵樼洏鐗╂枡琛ㄧ殑鏁版嵁
- .ToList();
- LogHelper.Info($"鏈夌墿鏂檣itemCode}鐨勮揣浣嶇紪鍙穥JsonConvert.SerializeObject(locCntrs)}");
- //鎵惧父瑙勯�妫�尯鍐呭惈鏈夋煡鍑虹墿鏂欒揣浣嶇殑璐т綅
- var locList = db.Queryable<Location>()
- .Where(p => p.S_AREA_CODE == areaCode && p.N_LOCK_STATE == 0 && p.C_ENABLE == "Y")
- .Where(s => locCntrs.Contains(s.S_CODE.Trim()))
- .ToList();
-
- if (!locList.Any())
- {
- return null;
- }
- result = locList.FirstOrDefault();
- }
- catch (Exception ex)
- {
- Console.WriteLine("getLocByMaterial:" + ex.Message + ex.StackTrace);
- LogHelper.Error("getLocByMaterial:" + ex.Message, ex);
- }
- return result;
- }
-
- //瀛樻憚鍍忓ご璋冪敤鎺ュ彛绌烘弧鐘舵� 璐т綅锛岀┖婊＄姸鎬�- private static string monitorStatus = null;
- /// <summary>
- /// 鎽勫儚澶寸洃娴嬫帴鍙�
- /// </summary>
- /// <param name="models.PointCode">鐩戞祴璐т綅</param>
- /// <param name="models.PointStatus">鐩戞祴绌烘弧鐘舵�0绌洪棽1鍗犵敤3寮傚父</param>
- /// <returns></returns>
- internal static Results UpdateFullStatus(List<CameraMonitor> models)
- {
- var result = new Results() { Code = "0", Message = "鎿嶄綔鎴愬姛", Data = null };
- var db = new SqlHelper<object>().GetInstance();
- //鏍￠獙涓庡唴瀛樻槸鍚︿竴鑷�- if (monitorStatus != null)
- {
- try
- {
- //string杞垚list
- var jsonList = JsonConvert.DeserializeObject<List<CameraMonitor>>(monitorStatus);
- //鎵句袱涓狶ist鐨勪氦闆�- var intersection = jsonList.Where(j => models.Any(m =>
- m.PointCode == j.PointCode && m.PointStatus == j.PointStatus)).ToList();
- LogHelper.Info($"鎽勫儚澶翠笌涓婃璋冪敤涓�嚧鏁版嵁锛歿JsonConvert.SerializeObject(intersection)}");
- foreach (var model in intersection)
- {
- //鎵惧埌璇ョ偣浣嶇殑搴撳尯
- var loc = db.Queryable<Location>().Where(a => a.S_CODE == model.PointCode).First();
- //娌￠攣鍐嶇户缁蛋
- if (loc.N_LOCK_STATE == 0 && loc.C_ENABLE == "Y" && loc != null)
- {
- var reservoirs = Settings.ReservoirAreas.Where(s => s.areaName == "閫佹鍏ュ簱鍖�).FirstOrDefault();
- //濡傛灉鏄�妫�叆搴撳尯
- if (reservoirs.areaCode.Equals(loc.S_AREA_CODE))
- {
- var locCntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == model.PointCode).First();
- var container = new Container();
- if (locCntrRel == null)
- {
- //绗竴娆¤嚜宸辩粦瀹氫竴涓墭鐩�- string trayCode = ContainerHelper.GenerateCntrNo();
- ContainerHelper.BindLocCntrs(model.PointCode, trayCode, null, null);
- container = db.Queryable<Container>().Where(a => a.S_CODE == trayCode).First();
- container.C_FULL = "2";
- }
- else
- {
- //鏌ユ暟鎹簱绌烘弧鐘舵� 璺熺紦瀛樹笉涓�牱鍒欐洿鏂�- //鎵惧埌杩欎釜璐т綅鐨勫鍣�绌烘弧鐘舵�C_FULL鏀规垚2婊� 0 -- 绌�1 -- 鏈夎揣 2 -- 婊�- container = db.Queryable<Container>().Where(a => a.S_CODE == locCntrRel.S_CNTR_CODE).First();
- if (container.C_FULL != model.PointStatus.ToString())
- {
- container.C_FULL = "2";
- }
- }
- var res = db.Updateable(container).UpdateColumns(it => it.C_FULL).ExecuteCommand() > 0;
- if (res)
- {
- LogHelper.Info($"淇敼{model.PointCode}璐т綅绌烘弧鐘舵�鎴愬姛", "鎽勫儚澶寸洃娴�);
- }
- else
- {
- LogHelper.Info($"淇敼{model.PointCode}璐т綅绌烘弧鐘舵�澶辫触", "鎽勫儚澶寸洃娴�);
- }
- }
- else
- {
- //濡傛灉鏄┖鎵樼紦瀛樺尯 鍒ゆ柇鎷嗘墭鏈烘槸鍚︽湁绌轰綅 绌烘墭缂撳瓨鍖烘弧浜嗕笖鎷嗘墭鏈哄叆鍙ｆ湁绌哄垯鍒涘缓浠诲姟
- var reservoirs1 = Settings.ReservoirAreas.Where(s => s.areaName == "3min绌烘墭鍖�).FirstOrDefault();
- var reservoirs2 = Settings.ReservoirAreas.Where(s => s.areaName == "6min绌烘墭鍖�).FirstOrDefault();
- if (loc.S_AREA_CODE.Equals(reservoirs1.areaCode) || loc.S_AREA_CODE.Equals(reservoirs2.areaCode))//涓夊绌烘墭
- {
- ProcessEmptyTrayAreas(db, loc, reservoirs1.areaCode, reservoirs2.areaCode);
- }
- }
- }
- else
- {
- LogHelper.Info($"{model.PointCode}璐т綅浠诲姟宸茬粡鐢熸垚", "鎽勫儚澶寸洃娴�);
- }
-
- }
- }
- catch (Exception ex)
- {
- Console.WriteLine("UpdateFullStatus:" + ex.Message + ex.StackTrace);
- LogHelper.Error("UpdateFullStatus:" + ex.Message, ex);
- throw;
- }
- }
- //list杞瑂tring 瀛樺埌鍐呭瓨
- monitorStatus = JsonConvert.SerializeObject(models);
-
- return result;
- }
- //鎽勫儚澶寸洃娴嬬┖鎵樼紦瀛樺尯
- private static void ProcessEmptyTrayAreas(SqlSugar.ISqlSugarClient db, Location loc, string areaCode1, string areaCode2)
- {
- var plcDeviceTable = S7Helper.plcDeviceTables;
- if (plcDeviceTable != null)
- {
- string endLoc = null;
- bool request = false;
- if (loc.S_AREA_CODE.Equals(areaCode1))
- {
- request = plcDeviceTable.requestPut1;
- endLoc = Settings.linePlcInfos.Where(s => s.code == "鎷嗘墭鏈�").FirstOrDefault().inLoca;
- }
- else if (loc.S_AREA_CODE.Equals(areaCode2))//鍏绌烘墭
- {
- request = plcDeviceTable.requestPut2;
- endLoc = Settings.linePlcInfos.Where(s => s.code == "鎷嗘墭鏈�").FirstOrDefault().inLoca;
- }
- //鍒ゆ柇鏄惁鍏佽鏀炬
- if (request)
- {
- //鍒涘缓浠诲姟 浠庣┖鎵樼紦瀛樺尯鍒版媶鎵樻満
- var list = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == loc.S_AREA_CODE
- && a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.C_ENABLE == "Y").OrderByDescending(a => a.N_ROW)
- .OrderByDescending(a => a.N_COL).First();
- var startLoc = list.S_CODE;
-
- string trayCode = ContainerHelper.GenerateCntrNo();
-
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startLoc}缁堢偣:{endLoc}", "鎷嗘墭");
- var res = TaskProcess.CreateTransport(startLoc, endLoc, "鎷嗘墭", trayCode, 1, 1);
- if (res)
- {
- LogHelper.Info($"璧风偣:{startLoc}缁堢偣:{endLoc}浠诲姟鍒涘缓鎴愬姛", "鎷嗘墭");
- }
- else
- {
- LogHelper.Info($"璧风偣:{startLoc}缁堢偣:{endLoc}浠诲姟鍒涘缓澶辫触", "鎷嗘墭");
- }
- }
- }
- else
- {
- LogHelper.Info($"鏈鍙栧埌鎷嗘墭鏈轰俊鍙�, "鎷嗘墭");
-
- }
-
- }
- /// <summary>
- /// 鎶芥涓诲姩鍛煎彨 璧风偣锛氶�妫�紦瀛樺尯
- /// </summary>
- /// <param name="model.S_ITEM_CODE">鐗╂枡</param>
- /// <param name="model.END_LOC">缁堢偣璐т綅</param>
- /// <returns></returns>
- internal static Results activeCall(GetSubmitCheck model)
- {
- var result = new Results() { Code = "0", Message = "鎶芥涓诲姩鍛煎彨浠诲姟鐢熸垚鎴愬姛锛�, Data = null };
- var db = new SqlHelper<Location>().GetInstance();
- try
- {
- //鏍规嵁鐗╂枡鎵炬煇搴撳尯鐨勮揣浣�- var cgreservoirs = Settings.ReservoirAreas.Where(s => s.areaName == "閫佹缂撳瓨鍖�).FirstOrDefault();
- var startloc = getLocByMaterial(model.S_ITEM_CODE, cgreservoirs.areaCode);
- if (startloc == null)
- {
- return new Results { Code = "1", Message = $"鏈壘鍒板寘鍚墿鏂檣model.S_ITEM_CODE}鐨勮揣浣�, Data = null };
- }
- //缁堢偣
- var endloc = db.Queryable<Location>().Where(a => a.S_CODE == model.END_LOC).First();
- if (endloc == null || endloc.N_LOCK_STATE != 0 || endloc.C_ENABLE != "Y")
- {
- return new Results { Code = "1", Message = $"{model.END_LOC}搴撲綅宸茶閿佸畾!", Data = null };
- }
- //鍒涘缓浠诲姟
- var locCntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == startloc.S_CODE).First();
-
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startloc.S_CODE}缁堢偣:{endloc.S_CODE}", "鎶芥涓诲姩鍛煎彨");
- var res = TaskProcess.CreateTransport(startloc.S_CODE, endloc.S_CODE, "鎶芥涓诲姩鍛煎彨", locCntrRel.S_CNTR_CODE, 1, 1);
- if (!res)
- {
- return new Results { Code = "1", Message = "鎶芥涓诲姩鍛煎彨浠诲姟鐢熸垚澶辫触!", Data = null };
-
- }
- return result;
- }
- catch (Exception ex)
- {
- Console.WriteLine("submitCheck:" + ex.Message + ex.StackTrace);
- LogHelper.Error("submitCheck:" + ex.Message, ex);
- throw;
- }
- }
- /// <summary>
- /// 涓诲姩鐗╂枡缁戝畾
- /// </summary>
- /// <param name="model.S_ITEM_CODE">鐗╂枡缂栫爜(閫夊～)</param>
- /// <param name="model.BIND_LOC">缁戝畾璐т綅</param>
- /// <returns></returns>
- internal static Results bindMaterial(GetSubmitCheck model)
- {
- var result = new Results() { Code = "0", Message = "鐗╂枡缁戝畾鎴愬姛锛�, Data = null };
- var db = new SqlHelper<object>().GetInstance();
- try
- {
- var loc = db.Queryable<Location>().Where(a => a.S_CODE == model.BIND_LOC).First();
- if (loc == null || loc.N_LOCK_STATE != 0 || loc.C_ENABLE != "Y")
- {
- return new Results { Code = "1", Message = $"缁戝畾璐т綅涓嶅瓨鍦ㄦ垨宸茶閿�, Data = null };
-
- }
- string cntrStr = ContainerHelper.GenerateCntrNo();
- var locCntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == model.BIND_LOC).First();
- if (locCntrRel != null)
- {
- cntrStr = locCntrRel.S_CNTR_CODE;
- }
- var res = ContainerHelper.BindLocCntrs(model.BIND_LOC, cntrStr, model.S_ITEM_CODE, "甯冨嵎");
- if (!res)
- {
- return new Results { Code = "1", Message = $"鐗╂枡{model.S_ITEM_CODE}璐т綅{model.BIND_LOC}缁戝畾澶辫触", Data = null };
- }
- loc.N_CURRENT_NUM++;
- var res2 = db.Updateable(loc).UpdateColumns(it => it.N_CURRENT_NUM).ExecuteCommand() > 0;
- if (!res2)
- {
- return new Results { Code = "1", Message = $"璐т綅{model.BIND_LOC}褰撳墠鏁伴噺鑷澶辫触", Data = null };
- }
- return result;
- }
- catch (Exception ex)
- {
- Console.WriteLine("bindMaterial:" + ex.Message + ex.StackTrace);
- LogHelper.Error("bindMaterial:" + ex.Message, ex);
- throw;
- }
- }
- /// <summary>
- /// 鏁存帓鐗╂枡缁戝畾
- /// </summary>
- /// <param name="bondLoc">缁戝畾璐т綅</param>
- /// <returns></returns>
- internal static Results multBindMaterial(string bondLoc)
- {
- var result = new Results() { Code = "0", Message = "鏁存帓鐗╂枡缁戝畾鎴愬姛锛�, Data = null };
- var db = new SqlHelper<object>().GetInstance();
- try
- {
- var location = db.Queryable<Location>().Where(a => a.S_CODE == bondLoc).First();
- //鏌ュ嚭杩欎竴鎺掔殑璐т綅
- var loclist = db.Queryable<Location>()
- .Where(a => a.S_AREA_CODE == location.S_AREA_CODE && a.N_ROW == location.N_ROW).ToList();
- foreach (var loc in loclist)
- {
- //娌￠攣鐨勪笖娌¤揣鐨勬墠缁�- if (loc.N_LOCK_STATE == 0 && loc.N_CURRENT_NUM < loc.N_CAPACITY)
- {
-
-
- }
-
- }
- }
- catch (Exception ex)
- {
- Console.WriteLine("multBindMaterial:" + ex.Message + ex.StackTrace);
- LogHelper.Error("multBindMaterial:" + ex.Message, ex);
- throw;
- }
-
-
- return result;
- }
- /// <summary>
- /// 鎸夐挳鐩掕皟鐢ㄤ笅绾�- /// </summary>
- /// <param name="startLoc">璧风偣璐т綅</param>
- /// <param name="endArea">缁堢偣璐у尯</param>
- /// <returns></returns>
- internal static bool tcpOffline(string startLoc, string endArea)
- {
- var db = new SqlHelper<Location>().GetInstance();
-
- LogHelper.Info($"tcpOffline=====鍙傛暟:璧风偣璐т綅{startLoc}缁堢偣搴撳尯{endArea}");
- try
- {
- //鏍￠獙璧风偣璐т綅鏄惁瀛樺湪/閿佷綇
- var loc = db.Queryable<Location>().Where(a => a.S_CODE == startLoc).First();
- if (loc == null || loc.N_LOCK_STATE != 0 || loc.C_ENABLE != "Y")
- {
- LogHelper.Info("璧风偣璐т綅涓嶅瓨鍦ㄦ垨宸查攣" + startLoc);
- return false;
- }
- //璁＄畻缁堢偣璐т綅
- //if (string.IsNullOrEmpty(endArea))
- //{
- // return new Results { Code = "1", Message = "鍑哄簱鏈紶缁堢偣搴撳尯!", Data = null };
- //}
- //濡傛灉鏄揣鍑戝瀷
- var reservoirs = Settings.ReservoirAreas.Where(s => s.areaName == "绱ф�閫佹鍖�).FirstOrDefault();
- Location OutLoc = null;
- if (endArea.Equals(reservoirs.areaCode))
- {
- OutLoc = CompactWorkTransport(endArea);
- }
- else
- {
- OutLoc = InWorkTransport(endArea);
- }
- //鍒涘缓鎵樼洏璐т綅缁戝畾鍏崇郴
- string trayCode = ContainerHelper.GenerateCntrNo();
- //娌′紶鐗╂枡鐨勮瘽榛樿涓�釜
- string itemCode = null;
- string wlName = null;
- //if (!string.IsNullOrEmpty(model.S_ITEM_CODE))
- //{
- // itemCode = model.S_ITEM_CODE;
- // wlName = db.Queryable<TN_Material>().Where(b => b.S_ITEM_CODE == model.S_ITEM_CODE).First().S_ITEM_NAME;
- //}
- if (OutLoc == null)
- {
- LogHelper.Info($"缁堢偣璐т綅涓嶅瓨鍦�, "鎸夐挳鐩掍笅绾�);
- return false;
- }
- ContainerHelper.BindLocCntrs(OutLoc.S_CODE, trayCode, itemCode, wlName);
- //鍒涘缓浠诲姟
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startLoc}缁堢偣:{OutLoc.S_CODE}", "鎸夐挳鐩掍笅绾�);
- return TaskProcess.CreateTransport(startLoc, OutLoc.S_CODE, "鎸夐挳鐩掍笅绾�, trayCode, 1, 1);
-
- }
- catch (Exception ex)
- {
- Console.WriteLine("tcpOffline:" + ex.Message + ex.StackTrace);
- LogHelper.Error("tcpOffline:" + ex.Message, ex);
- throw;
- }
- }
- /// <summary>
- /// 鎸夐挳鐩掕皟鐢ㄧ┖鎵�- /// </summary>
- /// <param name="startLoc">璧风偣璐т綅</param>
- /// <param name="endLoc">缁堢偣璐т綅</param>
- /// <returns></returns>
- internal static bool tcpEmptyTray(string startLoc, string endLoc)
- {
- var db = new SqlHelper<Location>().GetInstance();
- try
- {
- //鏍￠獙缁堢偣璐т綅鏄惁閿�- var endloc = db.Queryable<Location>().Where(a => a.S_CODE == endLoc).First();
- if (endloc == null || endloc.N_LOCK_STATE != 0 || endloc.C_ENABLE != "Y")
- {
- LogHelper.Info("缁堢偣璐т綅宸查攣" + endLoc);
- return false;
- }
- //鍒涘缓鎵樼洏璐т綅缁戝畾鍏崇郴
- string trayCode = ContainerHelper.GenerateCntrNo();
- //鍒涘缓浠诲姟
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startLoc}缁堢偣:{endLoc}", "鎸夐挳鐩掕皟鐢ㄧ┖鎵�);
- return TaskProcess.CreateTransport(startLoc, endLoc, "鎸夐挳鐩掕皟鐢ㄧ┖鎵�, trayCode, 1, 1);
-
- }
- catch (Exception ex)
- {
- Console.WriteLine("materialOffline:" + ex.Message + ex.StackTrace);
- LogHelper.Error("materialOffline:" + ex.Message, ex);
- throw;
- }
- }
-
-
- /// <summary>
- /// 瀹夊叏浜や簰
- /// </summary>
- /// <param name="model.STATION_NAME">璇锋眰鐐逛綅</param>
- /// <param name="model.APPLY_CODE">璇锋眰鐮�/param>
- /// <returns></returns>
- internal static safeResult safetyInteraction(SafetyInteraction model)
- {
- //0鍏佽杩涘叆 1涓嶅厑璁歌繘鍏�- var result = new safeResult() { code = "1", msg = "success" };
- try
- {
- var reservoirs = Settings.SafeInteractions.Where(s => s.location == model.STATION_NAME).FirstOrDefault();//y0-0000 y1-0001 on-FF00 off-0000
- //var rgvSafeInteraction = DeviceProcess.rgvSafeInteraction;
- var plcDeviceTable = S7Helper.plcDeviceTables;
- if (plcDeviceTable != null)
- {
- //RGV
- if (reservoirs.type.Equals("RGV"))
- {
- LogHelper.Info($"RGV瀹夊叏浜や簰 璇锋眰鐐逛綅锛歿model.STATION_NAME}璇锋眰鐮侊細{model.APPLY_CODE}");
- //澶勭悊淇″彿
- var res = int.Parse(plcDeviceTable.RGVAllowUnload[reservoirs.code].ToString().Substring(1, 1));
- //鏍规嵁ip璇荤姸鎬�- LogHelper.Info($"RGV瀹夊叏浜や簰缂撳瓨淇″彿{res}锛寋JsonConvert.SerializeObject(plcDeviceTable.RGVAllowUnload)}");
- //鍗歌揣璇锋眰杩涘叆
- if (model.APPLY_CODE.Equals("5"))
- {
- //1鍏佽鍗歌揣
- if (res == 1)
- {
- LogHelper.Info($"RGV瀹夊叏浜や簰 鍏佽鍗歌揣");
- return new safeResult() { code = "0", msg = "success" };
- }
- }
- //鍗歌揣鍚庡凡绂诲紑
- else if (model.APPLY_CODE.Equals("8"))
- {
- //鍙戦�鍗歌揣瀹屾垚銆佸浣嶄俊鍙�- //鍗歌揣瀹屾垚淇″彿
- S7Helper.WriteInt(50, reservoirs.code * 2 - 2, (short)(reservoirs.code * 10 + 1));
-
- // 鍚姩鍚庡彴浠诲姟澶勭悊寤惰繜澶嶄綅
- Task.Run(async () =>
- {
- //10绉掑悗澶嶄綅
- await Task.Delay(10000);
- S7Helper.WriteInt(50, reservoirs.code * 2 - 2, (short)(reservoirs.code * 10));
- LogHelper.Info($"RGV瀹夊叏浜や簰 澶嶄綅瀹屾垚");
- });
- //10绉掑悗澶嶄綅
- //S7Helper.WriteInt(50, reservoirs.code * 2 - 2, (short)(reservoirs.code * 10));
- //safeAssistant(reservoirs.code, res);
- LogHelper.Info($"RGV瀹夊叏浜や簰 鍗歌揣瀹屾垚");
- return new safeResult() { code = "0", msg = "success" };
- }
-
-
- }
- //鎷嗘墭鏈�- else if (reservoirs.type.Equals("CTJ"))
- {
- LogHelper.Info($"鎷嗘墭鏈哄畨鍏ㄤ氦浜� 璇锋眰鐐逛綅锛歿model.STATION_NAME}璇锋眰鐮侊細{model.APPLY_CODE}");
- //鎵惧埌绾夸綋 鏍规嵁绾夸綋鎵惧唴瀛橀噷鐨勭姸鎬�- var reservoirs1 = Settings.ConveyorLinesInfos.Where(s => s.location == model.STATION_NAME).FirstOrDefault();
-
- LogHelper.Info($"鎷嗘墭鏈哄畨鍏ㄤ氦浜掑弬鏁皗JsonConvert.SerializeObject(plcDeviceTable)}");
- if (model.APPLY_CODE.Equals("1"))
- {
- //0-鑴辨満鐘舵�锛�-寰呮満鐘舵�锛�-杩愯涓� 寰呮満涓旀湁鎵樼洏涓旇姹傚彇妗嗘墠璧�- if ((reservoirs1.deviceNo == "1" && plcDeviceTable.requestTake1) ||
- (reservoirs1.deviceNo == "2" && plcDeviceTable.requestTake2))
- {
- LogHelper.Info($"鎷嗘墭鏈哄畨鍏ㄤ氦浜�鍏佽鍙栨");
- return new safeResult() { code = "0", msg = "success" };
- }
-
- }
- else if (model.APPLY_CODE.Equals("5"))
- {
- //0-鑴辨満鐘舵�锛�-寰呮満鐘舵�锛�-杩愯涓� 寰呮満涓旀棤鎵樼洏涓斿厑璁告斁妗嗘墠璧�- if ((reservoirs1.deviceNo == "1" && plcDeviceTable.requestPut1) ||
- (reservoirs1.deviceNo == "2" && plcDeviceTable.requestPut2))
- {
- LogHelper.Info($"鎷嗘墭鏈哄畨鍏ㄤ氦浜�鍏佽鏀炬");
- return new safeResult() { code = "0", msg = "success" };
- }
- }
- //鍙栬揣绂诲紑
- else if (model.APPLY_CODE.Equals("4"))
- {
- int offsetAddr = 8;
- if (reservoirs1.deviceNo == "1")
- {
- offsetAddr = 1;
- }
- else if (reservoirs1.deviceNo == "2")
- {
- offsetAddr = 3;
- }
- LogHelper.Info($"鎷嗘墭鏈哄畨鍏ㄤ氦浜掑啓鍏reservoirs1.deviceNo}锛寋offsetAddr}");
- S7Helper.WriteDouble(reservoirs1.deviceNo, 9, 182, offsetAddr, 1);
- LogHelper.Info($"鎷嗘墭鏈哄畨鍏ㄤ氦浜�鍙栨绂诲紑");
- return new safeResult() { code = "0", msg = "success" };
- }
- //鍗歌揣绂诲紑
- else if (model.APPLY_CODE.Equals("8"))
- {
- int offsetAddr = 8;//闅忎究缁欎竴涓�- if (reservoirs1.deviceNo == "1")
- {
- offsetAddr = 0;
- }
- else if (reservoirs1.deviceNo == "2")
- {
- offsetAddr = 2;
- }
- LogHelper.Info($"鎷嗘墭鏈哄畨鍏ㄤ氦浜掑啓鍏reservoirs1.deviceNo}锛寋offsetAddr}");
- S7Helper.WriteDouble(reservoirs1.deviceNo, 9, 182, offsetAddr, 1);
- LogHelper.Info($"鎷嗘墭鏈哄畨鍏ㄤ氦浜�鍙栨绂诲紑");
- return new safeResult() { code = "0", msg = "success" };
- }
-
- }
- }
- return result;
- }
- catch (Exception ex)
- {
- Console.WriteLine("safetyInteraction:" + ex.Message + ex.StackTrace);
- LogHelper.Error("safetyInteraction:" + ex.Message, ex);
- throw;
- }
- }
- //寰幆鍙戦�淇″彿
- private static void safeAssistant(int code, int res)
- {
- Thread.Sleep(10000);
- S7Helper.WriteInt(50, code * 2 - 2, (short)(code * 10));
- LogHelper.Info($"RGV瀹夊叏浜や簰 澶嶄綅瀹屾垚");
- ////2鍗歌揣瀹屾垚纭
- //if (res != 2)
- //{
- // //鍗歌揣瀹屾垚淇″彿
- // S7Helper.WriteInt(50, code * 2 - 2, (short)(code * 10 + 1));
- // Thread.Sleep(3000);
- // safeAssistant(code, res);
- //}
- //else
- //{
- // S7Helper.WriteInt(50, code * 2 - 2, (short)(code * 10));
- //}
-
- }
-
- /// <summary>
- /// 鎸夐挳鎺у埗鏈嶅姟寮�叧
- /// </summary>
- /// <param name="isusing.S_STATUS">鏈嶅姟鐘舵�</param>
- /// <param name="isusing.S_TYPE">鏈嶅姟绫诲瀷</param>
- /// <returns></returns>
- internal static Results switchButton(Isusing isusing)
- {
- var db = new SqlHelper<object>().GetInstance();
- var result = new Results() { Code = "1", Message = $"鏈嶅姟鐘舵�澶辫触锛�, Data = null };
- var isusinglist = db.Queryable<Isusing>().Where(a => a.S_TYPE == isusing.S_TYPE).First();
- isusinglist.S_STATUS = isusing.S_STATUS;
- var res = db.Updateable(isusinglist).UpdateColumns(it => it.S_STATUS).ExecuteCommand() > 0;
- if (res)
- {
- return new Results() { Code = "0", Message = $"鏈嶅姟鐘舵�淇敼鎴愬姛锛�, Data = null };
-
- }
- return result;
- }
- //tcp鍙戦�淇″彿 娴嬭瘯鐢�- internal static Results tcpSend(string str)
- {
- var reservoirs = Settings.SafeInteractions.Where(s => s.code == 1).FirstOrDefault();
- //娴嬭瘯鐢�- LogHelper.Info($"RGV瀹夊叏浜や簰鍙戦�淇″彿{reservoirs.ip},{str}");
- //鏃犵姸鎬佷俊鍙�- bool res = PlcHelper.SendHex(reservoirs.ip, str);
- if (res)
- {
- return new Results() { Code = "0", Message = $"鍙戦�鎴愬姛", Data = null };
- }
-
- return new Results() { Code = "1", Message = $"鍙戦�澶辫触", Data = null };
- }
-
- #endregion
/// <summary>
/// 澶т欢
@@ -1779,55 +963,76 @@
try
{
var startLoc = new Location();
- var endLoc = new Location();
+ string endLocStr = null;
string Message = null;
switch (model.ts_name)
{
case "p2p":
- startLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameter.src).First();
+ startLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameters.src).First();
if (startLoc == null || startLoc.N_LOCK_STATE != 0 || startLoc.C_ENABLE != "Y")
{
- Message = $"{model.parameter.src}搴撲綅宸茶閿佸畾!";
+ Message = $"{model.parameters.src}搴撲綅宸茶閿佸畾!";
}
-
- endLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameter.dst).First();
- if (startLoc == null || startLoc.N_LOCK_STATE != 0 || startLoc.C_ENABLE != "Y")
- {
- Message = $"{model.parameter.dst}搴撲綅宸茶閿佸畾!";
- }
-
+ endLocStr = model.parameters.dst;
+
break;
case "p2a":
- startLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameter.src).First();
+ startLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameters.src).First();
if (startLoc == null || startLoc.N_LOCK_STATE != 0 || startLoc.C_ENABLE != "Y")
{
- Message = $"{model.parameter.src}搴撲綅宸茶閿佸畾!";
+ Message = $"{model.parameters.src}搴撲綅宸茶閿佸畾!";
}
- endLoc = InWorkTransport(model.parameter.dst);
+ var endLoc = InWorkTransport(model.parameters.dst_area);
if (endLoc==null)
{
- Message = $"{model.parameter.dst}搴撳尯娌℃湁鍙叆璐т綅!";
+ //濡傛灉娌℃壘鍒板氨绛夌涓�潯
+ endLocStr = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == model.parameters.dst).OrderByDescending(a => a.N_ROW).ToList()[0].S_CODE;
+
}
break;
case "a2p":
- startLoc = OutWorkTransport(model.parameter.src);
+ startLoc = OutWorkTransport(model.parameters.src_area);
if (startLoc==null)
{
- Message = $"{model.parameter.dst}搴撳尯娌℃湁鍙嚭璐т綅!";
+ Message = $"{model.parameters.dst}搴撳尯娌℃湁鍙嚭璐т綅!";
}
- endLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameter.dst).First();
- if (startLoc == null || startLoc.N_LOCK_STATE != 0 || startLoc.C_ENABLE != "Y")
+ endLocStr = model.parameters.dst;
+ break;
+ case "a2a":
+ startLoc = OutWorkTransport(model.parameters.src_area);
+ if (startLoc == null)
{
- Message = $"{model.parameter.dst}搴撲綅宸茶閿佸畾!";
+ Message = $"{model.parameters.src}搴撳尯娌℃湁鍙嚭璐т綅!";
}
+ var endLoc1 = InWorkTransport(model.parameters.dst_area);
+ if (endLoc1 == null)
+ {
+ //濡傛灉娌℃壘鍒板氨绛夌涓�潯
+ endLocStr = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == model.parameters.dst).OrderByDescending(a => a.N_ROW).ToList()[0].S_CODE;
+
+ }
+ break;
+ case "p2u":
+ startLoc = OutWorkTransport(model.parameters.src);
+ if (startLoc == null)
+ {
+ Message = $"{model.parameters.src}搴撳尯娌℃湁鍙嚭璐т綅!";
+ }
+ endLocStr = "";
break;
}
+ LogHelper.Info($"bigMaterial 鎺ユ敹鍙傛暟{JsonConvert.SerializeObject(model) }");
+ //鍒涘缓鎵樼洏璐т綅缁戝畾鍏崇郴
+ string trayCode = ContainerHelper.GenerateCntrNo();
+ //缁戝畾璧风偣璐т綅(浜х嚎)鍜岀墿鏂�+ ContainerHelper.BindLocCntrsXm(startLoc.S_CODE, trayCode, model.parameters.sku, "", model.parameters.BatchNo, model.parameters.issueMode, model.parameters.num);
+
var locCntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == startLoc.S_CODE).First();
//鍒涘缓浠诲姟
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startLoc.S_CODE}缁堢偣:{endLoc.S_CODE}", model.ts_name);
- var res = TaskProcess.CreateTransport(startLoc.S_CODE, endLoc.S_CODE, model.ts_name, locCntrRel.S_CNTR_CODE, 1, 1);
+ LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startLoc.S_CODE}缁堢偣:{endLocStr}", model.ts_name);
+ var res = TaskProcess.CreateTransportDj(startLoc.S_CODE, endLocStr, model.ts_name, locCntrRel.S_CNTR_CODE, model.order_name, 1, 1);
if (!res)
{
return new TaskResponse
@@ -1870,136 +1075,126 @@
}
- //鑷姩 鎷嗗垎
- public static TaskResponse autoSmallMaterial(smallMaterial model) {
- var db = new SqlHelper<Location>().GetInstance();
+
+ //public static TaskResponse smallMaterial(smallMaterial model) {
+ // var db = new SqlHelper<Location>().GetInstance();
- string Message = null;
+ // string Message = null;
- //鎷嗗垎鎴愪袱鏉′换鍔★紝涓�潯鏄枡鏋跺埌鎸囧畾鐨勭紦瀛樺尯锛屼簩鏄枡鏋朵笂鐨勬墭鐩樺埌鎸囧畾鐨勫伐浣嶏紙灏忕背wcs浼狅級涓�澶�- var startFrame = db.Queryable<LocFrameRel>().Where(a => a.S_LOC_CODE == model.parameters[0].src).First();
+ // //鎷嗗垎鎴愪袱鏉′换鍔★紝涓�潯鏄枡鏋跺埌鎸囧畾鐨勭紦瀛樺尯锛屼簩鏄枡鏋朵笂鐨勬墭鐩樺埌鎸囧畾鐨勫伐浣嶏紙灏忕背wcs浼狅級涓�澶�+ // var startFrame = db.Queryable<LocFrameRel>().Where(a => a.S_LOC_CODE == model.taskList[0].parameters[0].src).First();
- var startLoc = db.Queryable<Location>().Where(a => a.S_CODE == startFrame.S_FRAME_CODE).First();
- if (startLoc == null || startLoc.N_LOCK_STATE != 0)
- {
- return new TaskResponse
- {
- header = new ResponseHead { code = 0, desc = $"{model.parameters[0].src}搴撲綅宸茶閿佸畾!" }
- };
- }
- var endReservoirs = Settings.ReservoirAreas.Where(s => s.areaName == model.routeType).FirstOrDefault();
- var endLoc = TaskProcess.InWorkTransport(endReservoirs.areaCode);
- if (endLoc != null)
- {
- //鍒涘缓鍒扮紦瀛樺尯浠诲姟
- var locCntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == startLoc.S_CODE).First();
- //鍒涘缓浠诲姟
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startLoc.S_CODE}缁堢偣:{endLoc.S_CODE}", model.ts_name);
- var res = TaskProcess.CreateTransportHj(startLoc.S_CODE, endLoc.S_CODE, model.ts_name, locCntrRel.S_FRAME_CODE, 1, 1);
- if (!res)
- {
- return new TaskResponse
- {
- header = new ResponseHead { code = 0, desc = "鑷姩涓婄嚎浠诲姟鍒涘缓澶辫触" }
- };
- }
- }
- //鏂欐灦涓婄殑鎵樼洏鍒版寚瀹氱殑宸ヤ綅
- foreach (var parameter in model.parameters)
- {
- var startLocHj = db.Queryable<Location>().Where(a => a.S_CODE == parameter.src).First();
- if (startLocHj == null || startLocHj.N_LOCK_STATE != 0)
- {
- Message = Message==null? $"{model.parameters[0].src}搴撲綅宸茶閿佸畾!": Message+ $"{model.parameters[0].src}搴撲綅宸茶閿佸畾!";
- }
- else
- {
- //璐ф灦涓婄殑璐у垽鏂竴涓嬭揣鏋舵湁娌℃湁閿�- var startFrameParent = db.Queryable<LocFrameRel>().Where(a => a.S_LOC_CODE == parameter.src).First();
- if (startFrameParent != null)
- {
- var startLocParent = db.Queryable<Location>().Where(a => a.S_CODE == startFrameParent.S_FRAME_CODE).First();
- if (startLocParent == null || startLocParent.N_LOCK_STATE != 0)
- {
- return new TaskResponse
- {
- header = new ResponseHead { code = 0, desc = $"{startFrameParent.S_FRAME_CODE}璐ф灦宸茶閿佸畾!" }
- };
- }
- }
- var endLocHj = db.Queryable<Location>().Where(a => a.S_CODE == parameter.dst).First();
- if (endLocHj == null || endLocHj.N_LOCK_STATE != 0 || endLocHj.C_ENABLE != "Y")
- {
- //搴旇缁曡矾
+ // var startLoc = db.Queryable<Location>().Where(a => a.S_CODE == startFrame.S_FRAME_CODE).First();
+ // if (startLoc == null || startLoc.N_LOCK_STATE != 0)
+ // {
+ // return new TaskResponse
+ // {
+ // header = new ResponseHead { code = 0, desc = $"{model.taskList[0].parameters[0].src}搴撲綅宸茶閿佸畾!" }
+ // };
+ // }
+ // var endLoc = TaskProcess.InWorkTransport(model.shippingRoute);
+ // if (endLoc != null)
+ // {
+ // //鍒涘缓鍒扮紦瀛樺尯浠诲姟
+ // var locCntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == startLoc.S_CODE).First();
+ // //鍒涘缓浠诲姟
+ // LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startLoc.S_CODE}缁堢偣:{endLoc.S_CODE}", model.ts_name);
+ // var res = TaskProcess.CreateTransportHj(startLoc.S_CODE, endLoc.S_CODE, model.ts_name, locCntrRel.S_FRAME_CODE, 1, 1);
+ // if (!res)
+ // {
+ // return new TaskResponse
+ // {
+ // header = new ResponseHead { code = 0, desc = "鑷姩涓婄嚎浠诲姟鍒涘缓澶辫触" }
+ // };
+ // }
+ // }
+ // //鏂欐灦涓婄殑鎵樼洏鍒版寚瀹氱殑宸ヤ綅
+ // foreach (var parameter in model.parameters)
+ // {
+ // var startLocHj = db.Queryable<Location>().Where(a => a.S_CODE == parameter.src).First();
+ // if (startLocHj == null || startLocHj.N_LOCK_STATE != 0)
+ // {
+ // Message = Message==null? $"{model.parameters[0].src}搴撲綅宸茶閿佸畾!": Message+ $"{model.parameters[0].src}搴撲綅宸茶閿佸畾!";
+ // }
+ // else
+ // {
+ // //璐ф灦涓婄殑璐у垽鏂竴涓嬭揣鏋舵湁娌℃湁閿�+ // var startFrameParent = db.Queryable<LocFrameRel>().Where(a => a.S_LOC_CODE == parameter.src).First();
+ // if (startFrameParent != null)
+ // {
+ // var startLocParent = db.Queryable<Location>().Where(a => a.S_CODE == startFrameParent.S_FRAME_CODE).First();
+ // if (startLocParent == null || startLocParent.N_LOCK_STATE != 0)
+ // {
+ // return new TaskResponse
+ // {
+ // header = new ResponseHead { code = 0, desc = $"{startFrameParent.S_FRAME_CODE}璐ф灦宸茶閿佸畾!" }
+ // };
+ // }
+ // }
+ // var endLocHj = db.Queryable<Location>().Where(a => a.S_CODE == parameter.dst).First();
+ // if (endLocHj == null || endLocHj.N_LOCK_STATE != 0 || endLocHj.C_ENABLE != "Y")
+ // {
+ // //搴旇缁曡矾
- Message = Message == null ? $"{parameter.dst}搴撲綅宸茶閿佸畾!" : Message + $"{parameter.dst}搴撲綅宸茶閿佸畾!";
- }
- else
- {
- //璐ф灦涓婄殑璐у垽鏂竴涓嬭揣鏋舵湁娌℃湁閿�- var endFrameParent = db.Queryable<LocFrameRel>().Where(a => a.S_LOC_CODE == parameter.dst).First();
- if (endFrameParent != null)
- {
- var endLocParent = db.Queryable<Location>().Where(a => a.S_CODE == endFrameParent.S_FRAME_CODE).First();
- if (endLocParent == null || endLocParent.N_LOCK_STATE != 0)
- {
- return new TaskResponse
- {
- header = new ResponseHead { code = 0, desc = $"{endFrameParent.S_FRAME_CODE}璐ф灦宸茶閿佸畾!" }
- };
- }
- }
- //鍒涘缓鍒扮紦瀛樺尯浠诲姟
- var locCntrRel1 = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == startLocHj.S_CODE).First();
- //鍒涘缓浠诲姟
- LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startLocHj.S_CODE}缁堢偣:{endLocHj.S_CODE}", model.ts_name);
- var res = TaskProcess.CreateTransport(startLocHj.S_CODE, endLocHj.S_CODE, model.ts_name, locCntrRel1.S_CNTR_CODE, 1, 1);
- if (!res)
- {
- return new TaskResponse
- {
- header = new ResponseHead { code = 0, desc = "鑷姩涓婄嚎浠诲姟2鍒涘缓澶辫触" }
- };
- }
+ // Message = Message == null ? $"{parameter.dst}搴撲綅宸茶閿佸畾!" : Message + $"{parameter.dst}搴撲綅宸茶閿佸畾!";
+ // }
+ // else
+ // {
+ // //璐ф灦涓婄殑璐у垽鏂竴涓嬭揣鏋舵湁娌℃湁閿�+ // var endFrameParent = db.Queryable<LocFrameRel>().Where(a => a.S_LOC_CODE == parameter.dst).First();
+ // if (endFrameParent != null)
+ // {
+ // var endLocParent = db.Queryable<Location>().Where(a => a.S_CODE == endFrameParent.S_FRAME_CODE).First();
+ // if (endLocParent == null || endLocParent.N_LOCK_STATE != 0)
+ // {
+ // return new TaskResponse
+ // {
+ // header = new ResponseHead { code = 0, desc = $"{endFrameParent.S_FRAME_CODE}璐ф灦宸茶閿佸畾!" }
+ // };
+ // }
+ // }
+ // //鍒涘缓鍒扮紦瀛樺尯浠诲姟
+ // var locCntrRel1 = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == startLocHj.S_CODE).First();
+ // //鍒涘缓浠诲姟
+ // LogHelper.Info($"鍒涘缓浠诲姟 璧风偣:{startLocHj.S_CODE}缁堢偣:{endLocHj.S_CODE}", model.ts_name);
+ // var res = TaskProcess.CreateTransport(startLocHj.S_CODE, endLocHj.S_CODE, model.ts_name, locCntrRel1.S_CNTR_CODE, 1, 1);
+ // if (!res)
+ // {
+ // return new TaskResponse
+ // {
+ // header = new ResponseHead { code = 0, desc = "鑷姩涓婄嚎浠诲姟2鍒涘缓澶辫触" }
+ // };
+ // }
- }
+ // }
- }
- }
- var result = new TaskResponse();
- if (Message != null)
- {
- result = new TaskResponse
- {
- header = new ResponseHead { code = 0, desc = Message }
- };
- }
- else
- {
- result = new TaskResponse
- {
- header = new ResponseHead { code = 200, desc = "SUCCESS" },
- body = new ResponseBody
- {
- msg = "success",
- app_name = "Guozi client",
- data = new List<ResponseData> { new ResponseData { in_order_id = model.taskID } },
- version = ""
- }
- };
- }
- return result;
- }
- //浜哄伐 涓嶆媶鍒�- public static void artificialSmallMaterial(smallMaterial model)
- {
- var db = new SqlHelper<Location>().GetInstance();
-
-
-
-
-
- }
+ // }
+ // }
+ // var result = new TaskResponse();
+ // if (Message != null)
+ // {
+ // result = new TaskResponse
+ // {
+ // header = new ResponseHead { code = 0, desc = Message }
+ // };
+ // }
+ // else
+ // {
+ // result = new TaskResponse
+ // {
+ // header = new ResponseHead { code = 200, desc = "SUCCESS" },
+ // body = new ResponseBody
+ // {
+ // msg = "success",
+ // app_name = "Guozi client",
+ // data = new List<ResponseData> { new ResponseData { in_order_id = model.taskID } },
+ // version = ""
+ // }
+ // };
+ // }
+ // return result;
+ //}
+
}
--
Gitblit v1.9.1