From 41388b3fc48589a26ba7e79fc60ffc0facd21be7 Mon Sep 17 00:00:00 2001
From: cjs <2216046164@qq.com>
Date: 星期五, 30 五月 2025 17:21:43 +0800
Subject: [PATCH] 11
---
HH.WCS.Mobox3.NongFuLinZhi/wms/WCSHelper.cs | 122 +++++++++++++++++++++++++++++++++++++++-
1 files changed, 119 insertions(+), 3 deletions(-)
diff --git a/HH.WCS.Mobox3.NongFuLinZhi/wms/WCSHelper.cs b/HH.WCS.Mobox3.NongFuLinZhi/wms/WCSHelper.cs
index 668cb09..6b83aef 100644
--- a/HH.WCS.Mobox3.NongFuLinZhi/wms/WCSHelper.cs
+++ b/HH.WCS.Mobox3.NongFuLinZhi/wms/WCSHelper.cs
@@ -1,4 +1,5 @@
锘縰sing HH.WCS.Mobox3.NFLZ.util;
+using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
@@ -13,11 +14,16 @@
var date = DateTime.Now.ToString("yyMMdd");
return $"TN{date}{id.ToString().PadLeft(4, '0')}";
}
- internal static bool UpdateStatus(WCSTask task, string status) {
+ internal static bool UpdateStatus(WCSTask task, string status, string S_AGV_NO = "") {
+ Console.WriteLine("寮�鍙栬揣");
var res = false;
var db = new SqlHelper<WCSTask>().GetInstance();
task.S_B_STATE = status;
- db.Updateable(task).UpdateColumns(it => new { it.S_B_STATE,it.N_B_STATE }).ExecuteCommand();
+ if (S_AGV_NO != "")
+ {
+ task.S_EQ_NO = S_AGV_NO;
+ }
+ db.Updateable(task).UpdateColumns(it => new { it.S_B_STATE,it.N_B_STATE,it.S_EQ_NO }).ExecuteCommand();
return res;
}
internal static bool UpdatePrioryty(WCSTask task,int Prioryty) {
@@ -117,7 +123,7 @@
}
internal static bool CheckActionRecordExist(string no, int code) {
var db = new SqlHelper<TaskAction>().GetInstance();
- return db.Queryable<TaskAction>().Count(a => a.S_TASK_CODE == no&& a.N_ACTION_CODE == code) > 0;
+ return db.Queryable<TaskAction>().Count(a => a.S_TASK_CODE == no && a.N_ACTION_CODE == code) > 0;
}
internal static void Begin(WCSTask task) {
var db = new SqlHelper<WCSTask>().GetInstance();
@@ -206,5 +212,115 @@
{
//var order1 = new SqlHelper<OI_SYS_MAXID>().CreateTable();
}
+
+ #region 鏋楄姖WCS涓氬姟澶勭悊
+ /// <summary>
+ /// 鏋楄姖-鏌ヨ宸ュ崟淇℃伅--鎵ц涓垨鑰呮殏鍋�+ /// </summary>
+ /// <param name="lineNo"></param>
+ /// <returns></returns>
+ public static LinZhiWorkOrder GetLinZhiWorkOrder(string lineNo)
+ {
+ var db = new SqlHelper<object>().GetInstance();
+ var order = db.Queryable<LinZhiWorkOrder>().Where(a => a.S_PLineNo == lineNo && a.S_WorkState == "鎵ц涓�).First();
+ //var order = new SqlHelper<LinJiangWorkOrder>().Get(a => a.S_PLineNo == lineNo && (a.S_WorkState == "鎵ц涓�), a => a.T_CREATE, true);
+ return order;
+ }
+
+ internal List<YiKuWorkOrder> GetLinJianglysisOrderWork(string orderType)
+ {
+ var order = new SqlHelper<YiKuWorkOrder>().GetList(a => a.S_ORDER_TYPE == orderType && a.S_WorkState == "鎵ц涓�);
+ return order;
+ }
+
+ internal static void CreateLinJiangMiddleTableTest()
+ {
+ var order4 = new SqlHelper<OI_SYS_MAXID>().CreateTable();//HTTP鎺ュ彛璋冪敤澶辫触閲嶅彂涓棿琛�+ }
+
+ /// <summary>
+ /// 鏋楄姖-鏌ヨ褰撳墠璁惧淇℃伅
+ /// </summary>
+ /// <param name="lineNo"></param>
+ /// <returns></returns>
+ public static LinZhiDeviceState GetLinJiangDeviceState(string deviceName)
+ {
+ var order = new SqlHelper<LinZhiDeviceState>().Get(a => a.DeviceName == deviceName, a => a.DeviceTime, true);
+ return order;
+ }
+
+ internal static bool UpdateLinJiangDeviceState(LinZhiDeviceState deviceInfo, string status, string dateTime, string extData = "")
+ {
+ var res = false;
+ var db = new SqlHelper<LinZhiDeviceState>().GetInstance();
+ deviceInfo.DeviceState = status;
+ deviceInfo.DeviceTime = dateTime;
+ db.Updateable(deviceInfo).UpdateColumns(it => new { it.DeviceState, it.DeviceTime }).ExecuteCommand();
+ return res;
+ }
+
+ /// <summary>
+ /// 鏋楄姖-鎻掑叆璁惧淇℃伅
+ /// </summary>
+ /// <param name="wmsTask"></param>
+ /// <returns></returns>
+ internal static bool LinJiangInsertDeviceState(LinZhiDeviceState deviceState)
+ {
+ var db = new SqlHelper<LinZhiDeviceState>().GetInstance();
+ return db.Insertable(deviceState).ExecuteCommand() > 0;
+ }
+
+ /// <summary>
+ /// 鏋楄姖-鏌ヨ鎵樼洏淇℃伅-涓嬬嚎鏃堕棿涔嬪墠鐨勬暟鎹�+ /// </summary>
+ /// <param name="lineNo"></param>
+ /// <returns></returns>
+ public static List<LinZhiTrayInfo> GetLinZhiTrayInfoList(string dateTime, string deviceName)
+ {
+ var db = new SqlHelper<object>().GetInstance();
+ var order = new SqlHelper<LinZhiTrayInfo>().GetList(a => Convert.ToDateTime(a.dateTime.Trim()) < Convert.ToDateTime(dateTime) && a.deviceName == deviceName);
+
+ var trayInfo = new SqlHelper<LinZhiTrayInfo>().GetInstance().Queryable<LinZhiTrayInfo>().ToList();
+ LogHelper.Info("瀵屼箰鎵樼洏琛ㄥ叏閮ㄦ暟鎹細" + JsonConvert.SerializeObject(trayInfo));
+
+ //if (order != null && order.Count > 0)
+ //{
+ // //鍒犻櫎褰撳墠浜х嚎涓嬬嚎鏃堕棿鍓�0鍒嗛挓鐨勬墭鐩樻暟鎹�+ // for (int i = order.Count - 1; i >= 0; i--)
+ // {
+
+ // }
+ //}
+ return order;
+ }
+
+ /// <summary>
+ /// 鏋楄姖-鏇存敼宸ュ崟淇℃伅锛氭墭瑙勩�鎵规鍙枫�鐗╂枡灞傛暟
+ /// </summary>
+ /// <param name="task"></param>
+ /// <param name="status"></param>
+ /// <returns></returns>
+ internal static bool UpdateWorkInfo(LinZhiWorkOrder task, string trayRule = "", string batchNo = "", string itemLayer = "")
+ {
+ var res = false;
+ var db = new SqlHelper<LinZhiWorkOrder>().GetInstance();
+ task.S_TrayRules = trayRule;
+ task.S_BatchNo = batchNo;
+ task.S_ItemLayer = itemLayer;
+ db.Updateable(task).UpdateColumns(it => new { it.S_TrayRules, it.S_BatchNo, it.S_ItemLayer }).ExecuteCommand();
+ return res;
+ }
+
+ /// <summary>
+ /// 鏋楄姖-鏌ヨ鎵樼洏淇℃伅-鍏ㄩ儴-涓轰簡瀵规瘮褰撳墠鏄惁涓烘甯镐笅绾�+ /// </summary>
+ /// <param name="lineNo"></param>
+ /// <returns></returns>
+ public static List<LinZhiTrayInfo> GetLinJiangTrayInfoAllList(string deviceName)
+ {
+ var order = new SqlHelper<LinZhiTrayInfo>().GetList(a => a.deviceName == deviceName);
+ return order;
+ }
+ #endregion
}
}
--
Gitblit v1.9.1