TaskResponse_Dal.cs 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636
  1. using NX_CommonClassLibrary;
  2. using NX_DbClassLibrary;
  3. using NX_LogClassLibrary;
  4. using NX_ModelClassLibrary.BaseModel;
  5. using NX_ModelClassLibrary.CrnModel;
  6. using NX_ModelClassLibrary.CustomEnum;
  7. using NX_ModelClassLibrary.TranModel;
  8. using NX_ModelClassLibrary.WcsDispatch;
  9. using NX_ModelClassLibrary.WmsTask;
  10. using NX_WcsDal.CommonBusiness;
  11. using System;
  12. using System.Collections.Generic;
  13. using System.Data;
  14. using System.Linq;
  15. using System.Text;
  16. using System.Threading.Tasks;
  17. namespace NX_WcsDal.WcsDispatch
  18. {
  19. public class TaskResponse_Dal
  20. {
  21. #region 单例模式
  22. /// <summary>
  23. /// 单例模式对象
  24. /// </summary>
  25. private static TaskResponse_Dal _instance = null;
  26. private static readonly object lockObj = new object();
  27. /// <summary>
  28. /// 单例模式方法
  29. /// </summary>
  30. public static TaskResponse_Dal Instance
  31. {
  32. get
  33. {
  34. if (_instance == null)
  35. {
  36. lock (lockObj)
  37. {
  38. if (_instance == null)
  39. {
  40. _instance = new TaskResponse_Dal();
  41. }
  42. }
  43. }
  44. return _instance;
  45. }
  46. }
  47. #endregion
  48. public WcsTranCmdMd GetFinishedWcsTranCmdOfPalletCode(string trayCode, string palletCode, string eLocNo)
  49. {
  50. try
  51. {
  52. string sqlQueryCrnUnFinishedCmd = $@"
  53. SELECT
  54. TOP 1
  55. A.TRAN_CMD_ID,
  56. A.NEWID,
  57. A.TASK_NO,
  58. A.CMD_NO,
  59. A.TRAY_CODE,
  60. A.PALLET_CODE,
  61. A.TRAY_STATUS,
  62. A.TRAN_DEV_NO,
  63. A.SLOC_NO,
  64. A.SPLC_NO,
  65. A.ELOC_NO,
  66. A.EPLC_NO,
  67. A.CMD_TYPE,
  68. A.ACTIVE_TYPE,
  69. A.CMD_PRIORITY,
  70. A.CMD_STATUS,
  71. A.CMD_LOG,
  72. A.ERR_FLAG,
  73. A.ERR_LOG,
  74. A.CREATE_BY,
  75. B.USER_CODE CreateCode,
  76. B.USER_NAME CreateName,
  77. A.CREATE_TIME,
  78. A.EXECUTE_TIME,
  79. A.FINISH_TIME,
  80. A.UPDATE_BY,
  81. C.USER_CODE UpdateCode,
  82. C.USER_NAME UpdateName,
  83. A.UPDATE_TIME,
  84. A.DATA_VERSION,
  85. A.REMARKS1,
  86. A.REMARKS2,
  87. A.REMARKS3,
  88. A.REMARKS4,
  89. A.REMARKS5
  90. FROM
  91. WCS_TRAN_CMD A
  92. LEFT JOIN SYS_USER B ON A.CREATE_BY = B.USER_ID
  93. LEFT JOIN SYS_USER C ON A.UPDATE_BY = C.USER_ID
  94. WHERE A.TRAY_CODE = '{trayCode}' AND A.PALLET_CODE = '{palletCode}' AND A.CMD_STATUS = '{(int)TranCmdStatusEnum.完成}' AND A.ELOC_NO = '{eLocNo}'
  95. ";
  96. DataTable dt = LeadDbHelperSQLServer.Query(sqlQueryCrnUnFinishedCmd).Tables[0];
  97. if (dt != null && dt.Rows.Count > 0)
  98. {
  99. DataRow item = dt.Rows[0];
  100. WcsTranCmdMd tmpMd = ColumnToClassPropertyHelper.ColumnToClassProperty<WcsTranCmdMd>(dt.Columns, item);
  101. return tmpMd;
  102. }
  103. else
  104. {
  105. return null;
  106. }
  107. }
  108. catch (Exception ex)
  109. {
  110. LogHelper.WriteLog($"根据托盘号获取未完成的堆垛机指令数据发生异常!【{ex.Message}】", LogTypeEnum.Err);
  111. return null;
  112. }
  113. }
  114. public WcsCrnCmdMd GetFinishedWcsCrnCmdOfPalletCode(string palletCode,string trayCode)
  115. {
  116. try
  117. {
  118. string sqlQueryCrnUnFinishedCmd = $@"
  119. SELECT
  120. TOP 1
  121. A.CRN_CMD_ID,
  122. A.NEWID,
  123. A.TASK_NO,
  124. A.CMD_NO,
  125. A.TRAY_CODE,
  126. A.PALLET_CODE,
  127. A.TRAY_STATUS,
  128. A.CRN_DEV_NO,
  129. A.CRN_FORK_DEV_NO,
  130. A.SBIN_NO,
  131. A.SBIN_ROW,
  132. A.SBIN_COL,
  133. A.SBIN_LAYER,
  134. A.S_EXTENSION_GROUP,
  135. A.S_EXTENSION_IDX,
  136. A.EBIN_NO,
  137. A.EBIN_ROW,
  138. A.EBIN_COL,
  139. A.EBIN_LAYER,
  140. A.E_EXTENSION_GROUP,
  141. A.E_EXTENSION_IDX,
  142. A.CMD_TYPE,
  143. A.ACTIVE_TYPE,
  144. A.CMD_PRIORITY,
  145. A.CMD_STATUS,
  146. A.CMD_LOG,
  147. A.ERR_FLAG,
  148. A.ERR_LOG,
  149. A.CREATE_BY,
  150. B.USER_CODE CreateCode,
  151. B.USER_NAME CreateName,
  152. A.CREATE_TIME,
  153. A.EXECUTE_TIME,
  154. A.FINISH_TIME,
  155. A.UPDATE_BY,
  156. C.USER_CODE UpdateCode,
  157. C.USER_NAME UpdateName,
  158. A.UPDATE_TIME,
  159. A.DATA_VERSION,
  160. A.REMARKS1,
  161. A.REMARKS2,
  162. A.REMARKS3,
  163. A.REMARKS4,
  164. A.REMARKS5
  165. FROM
  166. WCS_CRN_CMD A
  167. LEFT JOIN SYS_USER B ON A.CREATE_BY = B.USER_ID
  168. LEFT JOIN SYS_USER C ON A.UPDATE_BY = C.USER_ID
  169. WHERE A.TRAY_CODE = '{trayCode}' AND A.PALLET_CODE = '{palletCode}' AND A.CMD_STATUS = '{(int)CrnCmdStatusEnum.完成}'
  170. ";
  171. DataTable dt = LeadDbHelperSQLServer.Query(sqlQueryCrnUnFinishedCmd).Tables[0];
  172. if (dt != null && dt.Rows.Count > 0)
  173. {
  174. DataRow item = dt.Rows[0];
  175. WcsCrnCmdMd retMd = ColumnToClassPropertyHelper.ColumnToClassProperty<WcsCrnCmdMd>(dt.Columns, item);
  176. return retMd;
  177. }
  178. else
  179. {
  180. return null;
  181. }
  182. }
  183. catch (Exception ex)
  184. {
  185. LogHelper.WriteLog($"根据托盘号获取完成的堆垛机指令数据发生异常!【{ex.Message}】", LogTypeEnum.Err);
  186. return null;
  187. }
  188. }
  189. public void UpdateWmsTaskElocNo(WmsTskTaskMd taskMd)
  190. {
  191. try
  192. {
  193. string sql = $@"update WMS_TSK_TASK set ELOC_CODE = '{taskMd.ElocCode}' where TASK_ID = '{taskMd.TaskId}'";
  194. LeadDbHelperSQLServer.ExecuteSql(sql) ;
  195. }
  196. catch (Exception ex)
  197. {
  198. LogHelper.WriteLog($"更新WMS大任务的终点数据时发生异常!【{ex.Message}】", LogTypeEnum.Err);
  199. }
  200. }
  201. public WmsTskTaskMd GetUnfinishWmsTaskOfTaskNo(string taskNo)
  202. {
  203. try
  204. {
  205. string sqlGetUnfinishWmsTask = $@"
  206. SELECT
  207. TOP 1
  208. A.TASK_ID,
  209. A.NEWID,
  210. A.WAREHOUSE_CODE,
  211. A.WAREHOUSE_NAME,
  212. A.TASK_NO,
  213. A.TRAY_CODE,
  214. A.PALLET_CODE,
  215. A.TRAY_LOADED_TYPE,
  216. A.SLOC_CODE,
  217. A.ELOC_CODE,
  218. A.CLOC_CODE,
  219. A.TASK_TYPE,
  220. A.TASK_MSG,
  221. A.ERR_FLAG,
  222. A.TASK_PRIORITY,
  223. A.TASK_STATUS,
  224. A.SBIN_CODE,
  225. A.EBIN_CODE,
  226. A.CMD_NO,
  227. A.ROUTE_CODE,
  228. A.CREATE_BY,
  229. B.USER_CODE CreateCode,
  230. B.USER_NAME CreateName,
  231. A.CREATE_TIME,
  232. A.UPDATE_BY,
  233. C.USER_CODE UpdateCode,
  234. C.USER_NAME UpdateName,
  235. A.UPDATE_TIME,
  236. A.DATA_VERSION,
  237. A.REMARKS1,
  238. A.REMARKS2,
  239. A.REMARKS3,
  240. A.REMARKS4,
  241. A.REMARKS5
  242. FROM
  243. WMS_TSK_TASK A
  244. LEFT JOIN SYS_USER B ON A.CREATE_BY = B.USER_ID
  245. LEFT JOIN SYS_USER C ON A.UPDATE_BY = C.USER_ID
  246. WHERE
  247. A.TASK_NO = '{taskNo}'
  248. AND A.TASK_STATUS < '{(int)WmsTaskStatusEnum.任务完成}'
  249. ";
  250. DataTable dtGetUnfinishWmsTask = LeadDbHelperSQLServer.Query(sqlGetUnfinishWmsTask).Tables[0];
  251. if (dtGetUnfinishWmsTask != null && dtGetUnfinishWmsTask.Rows.Count > 0)
  252. {
  253. DataRow item = dtGetUnfinishWmsTask.Rows[0];
  254. WmsTskTaskMd retMd = ColumnToClassPropertyHelper.ColumnToClassProperty<WmsTskTaskMd>(dtGetUnfinishWmsTask.Columns, item);
  255. return retMd;
  256. }
  257. else
  258. {
  259. return null;
  260. }
  261. }
  262. catch (Exception ex)
  263. {
  264. LogHelper.WriteLog($"根据托盘号获取WMS未完成的大任务数据发生异常!【{ex.Message}】", LogTypeEnum.Err);
  265. return null;
  266. }
  267. }
  268. public BasBinMd GetBinMdOfCodeAndType(string binCode, BasBinTypeEnum basBinType)
  269. {
  270. try
  271. {
  272. string sqlGetBinMdOfCodeAndType = $@"
  273. SELECT
  274. TOP 1 A.*, B.USER_CODE CreateCode,
  275. B.USER_NAME CreateName,
  276. C.USER_CODE UpdateCode,
  277. C.USER_NAME UpdateName
  278. FROM
  279. BAS_BIN A
  280. LEFT JOIN SYS_USER B ON A.CREATE_BY = B.USER_ID
  281. LEFT JOIN SYS_USER C ON A.UPDATE_BY = C.USER_ID
  282. WHERE
  283. A.USED_FLAG = 1
  284. AND A.DEL_FLAG = 0
  285. AND A.BIN_CODE = '{binCode}'
  286. AND A.BIN_TYPE = '{(int)basBinType}'
  287. ";
  288. DataTable dt = LeadDbHelperSQLServer.Query(sqlGetBinMdOfCodeAndType).Tables[0];
  289. if (dt != null && dt.Rows.Count > 0)
  290. {
  291. DataRow item = dt.Rows[0];
  292. BasBinMd retMd = ColumnToClassPropertyHelper.ColumnToClassProperty<BasBinMd>(dt.Columns, item);
  293. return retMd;
  294. }
  295. else
  296. {
  297. return null;
  298. }
  299. }
  300. catch (Exception ex)
  301. {
  302. LogHelper.WriteLog($"获取库位类型:【{basBinType}】库位号:【{binCode}】的详细库位信息发生异常!【{ex.Message}】", LogTypeEnum.Err);
  303. return null;
  304. }
  305. }
  306. public BasBinMd GetBinMdOfCode(string binCode)
  307. {
  308. try
  309. {
  310. string sqlGetBinMdOfCodeAndType = $@"
  311. SELECT
  312. TOP 1 A.*, B.USER_CODE CreateCode,
  313. B.USER_NAME CreateName,
  314. C.USER_CODE UpdateCode,
  315. C.USER_NAME UpdateName
  316. FROM
  317. BAS_BIN A
  318. LEFT JOIN SYS_USER B ON A.CREATE_BY = B.USER_ID
  319. LEFT JOIN SYS_USER C ON A.UPDATE_BY = C.USER_ID
  320. WHERE
  321. A.USED_FLAG = 1
  322. AND A.DEL_FLAG = 0
  323. AND A.BIN_CODE = '{binCode}'
  324. ";
  325. DataTable dt = LeadDbHelperSQLServer.Query(sqlGetBinMdOfCodeAndType).Tables[0];
  326. if (dt != null && dt.Rows.Count > 0)
  327. {
  328. DataRow item = dt.Rows[0];
  329. BasBinMd retMd = ColumnToClassPropertyHelper.ColumnToClassProperty<BasBinMd>(dt.Columns, item);
  330. return retMd;
  331. }
  332. else
  333. {
  334. return null;
  335. }
  336. }
  337. catch (Exception ex)
  338. {
  339. LogHelper.WriteLog($"获取库位号:【{binCode}】的详细库位信息发生异常!【{ex.Message}】", LogTypeEnum.Err);
  340. return null;
  341. }
  342. }
  343. public BasNextLocRouteMd GetRouteMsg(BasWcsLocMd sLocNo, BasWcsLocMd eLocNo)
  344. {
  345. try
  346. {
  347. string sqlGetRoute = $@"SELECT * FROM dbo.FN_GetAllNextRoute('{sLocNo.LocCode}','{eLocNo.LocCode}')";
  348. DataTable dt = LeadDbHelperSQLServer.Query(sqlGetRoute).Tables[0];
  349. if (dt != null && dt.Rows.Count > 0)
  350. {
  351. DataRow item = dt.Rows[0];
  352. BasNextLocRouteMd nextLocRouteMd = ColumnToClassPropertyHelper.ColumnToClassProperty<BasNextLocRouteMd>(dt.Columns, item);
  353. return nextLocRouteMd;
  354. }
  355. else
  356. {
  357. return null;
  358. }
  359. }
  360. catch (Exception ex)
  361. {
  362. LogHelper.WriteLog($"获取起点站台:【{sLocNo.LocCode}】到终点站台:【{eLocNo.LocCode}】的路径信息发生异常!【{ex.Message}】", LogTypeEnum.Err);
  363. return null;
  364. }
  365. }
  366. public int InsertCrnCmdAndUpdateWmsTask(WmsTskTaskMd wmsTskTaskMd, BasBinMd emptyBin, BasBinMd inBinMd, BasNextLocRouteMd locRouteMd)
  367. {
  368. try
  369. {
  370. string cmdNo = BasCommon_Dal.Instance.GetSysSequence("Cmd_No");
  371. string sqlInsertCrnCmd = $@"
  372. INSERT INTO [dbo].[WCS_CRN_CMD] (
  373. [TASK_NO],
  374. [CMD_NO],
  375. [TRAY_CODE],
  376. [PALLET_CODE],
  377. [TRAY_STATUS],
  378. [CRN_DEV_NO],
  379. [CRN_FORK_DEV_NO],
  380. [SBIN_NO],
  381. [SBIN_ROW],
  382. [SBIN_COL],
  383. [SBIN_LAYER],
  384. [S_EXTENSION_GROUP],
  385. [S_EXTENSION_IDX],
  386. [EBIN_NO],
  387. [EBIN_ROW],
  388. [EBIN_COL],
  389. [EBIN_LAYER],
  390. [E_EXTENSION_GROUP],
  391. [E_EXTENSION_IDX],
  392. [CMD_TYPE],
  393. [ACTIVE_TYPE],
  394. [CMD_PRIORITY],
  395. [CMD_STATUS],
  396. [CMD_LOG],
  397. [ERR_FLAG],
  398. [ERR_LOG],
  399. [CREATE_BY],
  400. [CREATE_TIME],
  401. [UPDATE_BY],
  402. [UPDATE_TIME],
  403. [DATA_VERSION],
  404. [REMARKS1],
  405. [REMARKS2],
  406. [REMARKS3],
  407. [REMARKS4],
  408. [REMARKS5]
  409. )
  410. VALUES
  411. (
  412. '{wmsTskTaskMd.TaskNo}',
  413. '{cmdNo}',
  414. '{wmsTskTaskMd.TrayCode}',
  415. '{wmsTskTaskMd.PalletCode}',
  416. '{(int)wmsTskTaskMd.TrayLoadedType}',
  417. '{locRouteMd.DevNo}',
  418. '{locRouteMd.DevNo}',
  419. '{inBinMd.BinCode}',
  420. '{inBinMd.BinRow}',
  421. '{inBinMd.BinColumn}',
  422. '{inBinMd.BinLayer}',
  423. '{inBinMd.EXTENSION_GROUP}',
  424. '{inBinMd.EXTENSION_IDX}',
  425. '{emptyBin.BinCode}',
  426. '{emptyBin.BinRow}',
  427. '{emptyBin.BinColumn}',
  428. '{emptyBin.BinLayer}',
  429. '{emptyBin.EXTENSION_GROUP}',
  430. '{emptyBin.EXTENSION_IDX}',
  431. '{CrnCmdTypeEnum.IN}',
  432. '{(int)CrnActiveTypeEnum.取放货}',
  433. 100,
  434. '{(int)CrnCmdStatusEnum.初始创建}',
  435. NULL,
  436. '{(int)WcsCmdErrFlagEnum.正常}',
  437. NULL,
  438. '{wmsTskTaskMd.UpdateBy}',
  439. getdate(),
  440. '{wmsTskTaskMd.UpdateBy}',
  441. getdate(),
  442. 0,
  443. NULL,
  444. NULL,
  445. NULL,
  446. NULL,
  447. NULL
  448. );
  449. ";
  450. string sqlUpdateWmsTask = $@"
  451. UPDATE WMS_TSK_TASK
  452. SET CLOC_CODE = '{locRouteMd.SlocNo}',
  453. SBIN_CODE = '{inBinMd.BinCode}',
  454. EBIN_CODE = '{emptyBin.BinCode}',
  455. CMD_NO = '{cmdNo}',
  456. ROUTE_CODE = '{locRouteMd.SectionNo}',
  457. TASK_STATUS = '{(int)WmsTaskStatusEnum.指令执行中}',
  458. UPDATE_TIME = GETDATE()
  459. WHERE
  460. TASK_ID = '{wmsTskTaskMd.TaskId}'
  461. ";
  462. List<string> sqlLst = new List<string>
  463. {
  464. sqlUpdateWmsTask,
  465. sqlInsertCrnCmd
  466. };
  467. int row = LeadDbHelperSQLServer.ExecuteSqlTran(sqlLst);
  468. return row;
  469. }
  470. catch (Exception ex)
  471. {
  472. LogHelper.WriteLog($"修改WMS大任务状态、新增堆垛机指令数据发生异常!【{ex.Message}】", LogTypeEnum.Err);
  473. return 0;
  474. }
  475. }
  476. public void UpdateMoveWmsTaskAndBalance(WmsTskTaskMd wmsTskTaskMd)
  477. {
  478. try
  479. {
  480. string sqlUodateWmsTaskToTargetLoc = $@"
  481. UPDATE WMS_TSK_TASK
  482. SET
  483. TASK_STATUS = '{(int)WmsTaskStatusEnum.任务完成}',
  484. UPDATE_TIME = GETDATE()
  485. WHERE
  486. TASK_ID = '{wmsTskTaskMd.TaskId}'
  487. ";
  488. string sqlUpdateSbinBalacne = $@"
  489. UPDATE WMS_STK_BALANCE
  490. SET BALANCE_STATUS = '99',
  491. UPDATE_TIME = GETDATE(),
  492. DATA_VERSION = DATA_VERSION + 1
  493. WHERE
  494. TRAY_CODE = '{wmsTskTaskMd.TrayCode}'
  495. AND BALANCE_STATUS = 66
  496. AND BIN_CODE = '{wmsTskTaskMd.SbinCode}'
  497. ";
  498. string sqlUpdateEbinBalacne = $@"
  499. UPDATE WMS_STK_BALANCE
  500. SET BALANCE_STATUS = '55',
  501. UPDATE_TIME = GETDATE(),
  502. DATA_VERSION = DATA_VERSION + 1
  503. WHERE
  504. TRAY_CODE = '{wmsTskTaskMd.TrayCode}'
  505. AND BALANCE_STATUS = 66
  506. AND BIN_CODE = '{wmsTskTaskMd.EbinCode}'
  507. ";
  508. List<string> sqlList = new List<string>();
  509. sqlList.Add(sqlUodateWmsTaskToTargetLoc);
  510. sqlList.Add(sqlUpdateSbinBalacne);
  511. sqlList.Add(sqlUpdateEbinBalacne);
  512. LeadDbHelperSQLServer.ExecuteSqlTran(sqlList);
  513. }
  514. catch (Exception ex)
  515. {
  516. LogHelper.WriteLog($"更新WMS内伸货位移库大任务完成状态时发生异常!【{ex.Message}】", LogTypeEnum.Err);
  517. }
  518. }
  519. public int UpdateWmsTaskToTargetLoc(WmsTskTaskMd wmsTskTaskMd)
  520. {
  521. try
  522. {
  523. string sqlUodateWmsTaskToTargetLoc = $@"
  524. UPDATE WMS_TSK_TASK
  525. SET
  526. TASK_STATUS = '{(int)WmsTaskStatusEnum.托盘到目标}',
  527. UPDATE_TIME = GETDATE()
  528. WHERE
  529. TASK_ID = '{wmsTskTaskMd.TaskId}'
  530. ";
  531. int row = LeadDbHelperSQLServer.ExecuteSql(sqlUodateWmsTaskToTargetLoc);
  532. return row;
  533. }
  534. catch (Exception ex)
  535. {
  536. LogHelper.WriteLog($"修改WMS大任务状态为托盘到目标时发生异常!【{ex.Message}】", LogTypeEnum.Err);
  537. return 0;
  538. }
  539. }
  540. public int InsertTranCmdAndUpdateWmsTask(WmsTskTaskMd wmsTskTaskMd, BasWcsLocMd sLocNo, BasWcsLocMd eLocNo, BasNextLocRouteMd locRouteMd)
  541. {
  542. try
  543. {
  544. string cmdNo = BasCommon_Dal.Instance.GetSysSequence("Cmd_No");
  545. string sqlInsertTranCmd = $@"
  546. INSERT INTO [dbo].[WCS_TRAN_CMD] (
  547. [TASK_NO],
  548. [CMD_NO],
  549. [TRAY_CODE],
  550. [PALLET_CODE],
  551. [TRAY_STATUS],
  552. [TRAN_DEV_NO],
  553. [SLOC_NO],
  554. [SPLC_NO],
  555. [ELOC_NO],
  556. [EPLC_NO],
  557. [CMD_TYPE],
  558. [ACTIVE_TYPE],
  559. [CMD_PRIORITY],
  560. [CMD_STATUS],
  561. [CMD_LOG],
  562. [ERR_FLAG],
  563. [ERR_LOG],
  564. [CREATE_BY],
  565. [CREATE_TIME],
  566. [UPDATE_BY],
  567. [UPDATE_TIME],
  568. [DATA_VERSION],
  569. [REMARKS1],
  570. [REMARKS2],
  571. [REMARKS3],
  572. [REMARKS4],
  573. [REMARKS5]
  574. )
  575. VALUES
  576. (
  577. '{wmsTskTaskMd.TaskNo}',
  578. '{cmdNo}',
  579. '{wmsTskTaskMd.TrayCode}',
  580. '{wmsTskTaskMd.PalletCode}',
  581. '{(int)wmsTskTaskMd.TrayLoadedType}',
  582. '{locRouteMd.DevNo}',
  583. '{sLocNo.LocCode}',
  584. '{sLocNo.LocCode}',
  585. '{eLocNo.LocCode}',
  586. '{eLocNo.LocCode}',
  587. '{(int)TranCmdTypeEnum.TRANSFER}',
  588. '{(int)TranActiveTypeEnum.直行}',
  589. 100,
  590. '{(int)TranCmdStatusEnum.初始创建}',
  591. NULL,
  592. '{(int)WcsCmdErrFlagEnum.正常}',
  593. NULL,
  594. '{wmsTskTaskMd.UpdateBy}',
  595. getdate(),
  596. {wmsTskTaskMd.UpdateBy},
  597. getdate(),
  598. 0,
  599. NULL,
  600. NULL,
  601. NULL,
  602. NULL,
  603. NULL
  604. );
  605. ";
  606. string sqlUpdateWmsTask = $@"
  607. UPDATE WMS_TSK_TASK
  608. SET CLOC_CODE = '{locRouteMd.SlocNo}',
  609. CMD_NO = '{cmdNo}',
  610. ROUTE_CODE = '{locRouteMd.SectionNo}',
  611. TASK_STATUS = '{(int)WmsTaskStatusEnum.指令执行中}',
  612. UPDATE_TIME = GETDATE()
  613. WHERE
  614. TASK_ID = '{wmsTskTaskMd.TaskId}'
  615. ";
  616. List<string> sqlLst = new List<string>
  617. {
  618. sqlUpdateWmsTask,
  619. sqlInsertTranCmd
  620. };
  621. int row = LeadDbHelperSQLServer.ExecuteSqlTran(sqlLst);
  622. return row;
  623. }
  624. catch (Exception ex)
  625. {
  626. LogHelper.WriteLog($"修改WMS大任务状态、新增输送线指令数据发生异常!【{ex.Message}】", LogTypeEnum.Err);
  627. return 0;
  628. }
  629. }
  630. }
  631. }