11
cjs
2025-06-30 84c2e090b4c3d380cbbc029291c162e4e86ec51d
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037
1038
1039
1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
1052
1053
1054
1055
1056
1057
1058
1059
1060
1061
1062
1063
1064
1065
1066
1067
1068
1069
1070
1071
1072
1073
1074
1075
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
1097
1098
1099
1100
1101
1102
1103
1104
1105
1106
1107
1108
1109
1110
1111
1112
1113
1114
1115
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
1140
1141
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
1180
1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
1197
1198
1199
1200
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
1211
1212
1213
1214
1215
1216
1217
1218
1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
1232
1233
1234
1235
1236
1237
1238
1239
1240
1241
1242
1243
1244
1245
1246
1247
1248
1249
1250
1251
1252
1253
1254
1255
1256
1257
1258
1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
1269
1270
1271
1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
1297
1298
1299
1300
1301
1302
1303
1304
1305
1306
1307
1308
1309
1310
1311
1312
1313
1314
1315
1316
1317
1318
1319
1320
1321
1322
1323
1324
1325
1326
1327
1328
1329
1330
1331
1332
1333
1334
1335
1336
1337
1338
1339
1340
1341
1342
1343
1344
1345
1346
1347
1348
1349
1350
1351
1352
1353
1354
1355
1356
1357
1358
1359
1360
1361
1362
1363
1364
1365
1366
1367
1368
1369
1370
1371
1372
1373
1374
1375
1376
1377
1378
1379
1380
1381
1382
1383
1384
1385
1386
1387
1388
1389
1390
1391
1392
1393
1394
1395
1396
1397
1398
1399
1400
1401
1402
1403
1404
1405
1406
1407
1408
1409
1410
1411
1412
1413
1414
1415
1416
1417
1418
1419
1420
1421
1422
1423
1424
1425
1426
1427
1428
1429
1430
1431
1432
1433
1434
1435
using Hanhe.iWCS.Business;
using Hanhe.iWCS.Common;
using Hanhe.iWCS.DeviceDriver;
using Hanhe.iWCS.MData;
using Hanhe.iWCS.Model;
using Hanhe.iWCS.Model.AMS;
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;
using MySql.Data.MySqlClient;
using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Configuration;
using System.Text;
using System.Web.UI.WebControls.WebParts;
using static Hanhe.iWCS.JingmenGEMTwoProtocol.EnentListen;
using static Hanhe.iWCS.JingmenGEMTwoProtocol.MESHelper;
using static Hanhe.iWCS.JingmenGEMTwoProtocol.PLCControl;
using static Hanhe.iWCS.JingmenGEMTwoProtocol.ProtocolAnalysis;
 
namespace Hanhe.iWCS.JingmenGEMTwoProtocol
{
    public class ProcessHelper
    {
        private static ICallTaskProcessing callTaskProcessing = new ICallTaskProcessing();
        private static WebApiHelper webApiHelper = new WebApiHelper();
 
        public static bool CheckStartFree(string bit) {
            var result = false;
            var tasks = MongoDBSingleton.Instance.Find<TN_I_TASK_MST>(Query.EQ("CN_S_START_BIT", bit), "TN_I_TASK_MST");
            if (tasks.Count == 0) {
                result = true;
            }
            else {
                for (int i = 0; i < tasks.Count; i++) {
                    if (!WorkFlowAction.ExistsTrackLogs(tasks[i].CN_S_TASK_NO, 1, 4)) {
                        break;
                    }
                }
            }
            return result;
        }
 
        public static bool PickUpStartFree(string bit)
        {
            var result = false;
            var tasks = MongoDBSingleton.Instance.Find<TN_I_TASK_MST>(Query.EQ("CN_S_START_BIT", bit), "TN_I_TASK_MST");
            if (tasks.Count == 0)
            {
                result = true;
            }
            else
            {
                result = true;
                for (int i = 0; i < tasks.Count; i++)
                {
                    if (!WorkFlowAction.ExistsTrackLogs(tasks[i].CN_S_TASK_NO, 1, 4))
                    {
                        result = false;
                        break;
                    }
                }
            }
            return result;
        }
 
        public static bool PickUpEndFree(string bit)
        {
            var result = false;
            var tasks = MongoDBSingleton.Instance.Find<TN_I_TASK_MST>(Query.EQ("CN_S_END_BIT", bit), "TN_I_TASK_MST");
            if (tasks.Count == 0)
            {
                result = true;
            }
            else
            {
                result = true;
                for (int i = 0; i < tasks.Count; i++)
                {
                    if (!WorkFlowAction.ExistsTrackLogs(tasks[i].CN_S_TASK_NO, 1, 6))
                    {
                        result = false;
                        break;
                    }
                }
            }
            return result;
        }
 
        internal static bool CheckEndFree(string bit) {
            var count = MongoDBSingleton.Instance.FindCount<TN_I_TASK_MST>(Query.EQ("CN_S_END_BIT", bit), "TN_I_TASK_MST");
            return count == 0;
        }
 
        internal static void recordInfo(string taskName,string errMsg)
        {
            var errInfo = MongoDBSingleton.Instance.FindOne<errInfoTable>(Query.EQ("taskName", taskName), "errInfoTable");
            if(errInfo != null)
            {
                MongoDBSingleton.Instance.Update<errInfoTable>(Query.EQ("_id", errInfo._id), Update.Set("errMsg", errMsg).Set("dateTime", DateTime.Now), UpdateFlags.None);
            }
            else
            {
                MongoDBSingleton.Instance.Insert<errInfoTable>(new errInfoTable 
                {
                    taskName = taskName,
                    errMsg = errMsg,
                    dateTime = DateTime.Now
                });
            }
        }
 
        internal static void deleteInfo(string taskName)
        {
            MongoDBSingleton.Instance.Remove<errInfoTable>(Query.EQ("taskName", taskName), RemoveFlags.None);
        }
 
 
 
        /// <summary>
        /// 发送任务——已增加起点终点层数,特殊AGV站点推送
        /// </summary>
        /// <param name="mst"></param>
        internal static void SendTask(TN_I_TASK_MST mst)
        {
            if(mst.CN_S_STATUS=="未执行" || mst.CN_S_STATUS == "待推送")
            {
                mst = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", mst.CN_S_TASK_NO), "TN_I_TASK_MST");
                if (mst.CN_S_BUSS_TYPE == "辅材回库")
                {
                    var CBTableList = MongoDBSingleton.Instance.FindAll<ConnectingBits>("ConnectingBits");
                    foreach (var a in CBTableList)
                    {
                        if (string.IsNullOrEmpty(a.trayCode))
                        {
                            string cntrType = mst.transportInfo[0].trayCode;
                            MongoDBSingleton.Instance.Update<ConnectingBits>(Query.EQ("Bit", a.Bit), Update.Set("trayCode", cntrType).Set("END_LOC", mst.CN_S_END_BIT), UpdateFlags.None);
                
                            MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", mst.CN_S_TASK_NO), Update.Set("CN_S_END_BIT", a.Bit), UpdateFlags.None);
                
                            new SqlHelper<object>().ExecuteSql($"update dbo.tn_am_task_mst set CN_S_END_BIT='{a.Bit}',CN_S_END_AGVBIT = '{StockInstance.Instance.GetAGVCodeForBitCode(a.Bit)}' where CN_S_TASK_NO = '{mst.CN_S_TASK_NO}'");
                        }
                    }
                }
 
                StringBuilder sbMsg = new StringBuilder();
                var start = StockInstance.Instance.GetLocationInfoTwo(mst.CN_S_START_BIT);
                var end = StockInstance.Instance.GetLocationInfoTwo(mst.CN_S_END_BIT);
                #region 接驳平台任务站点
                var conn = Settings.GetConnectingbitsList().Where(a => a.enable == 1).ToList();
                if (conn.Count == 2)
                {
                    //两个接驳平台
                    if (mst.CN_S_START_BIT == conn[0].locCode || mst.CN_S_START_BIT == conn[1].locCode)
                    {
                        start.CN_N_AGV_LOCATION = Settings.GetConnectingbitsList().Where(a => a.locCode == mst.CN_S_START_BIT).First().agvSite[1];
                    }
                    if (mst.CN_S_END_BIT == conn[0].locCode || mst.CN_S_END_BIT == conn[1].locCode)
                    {
                        end.CN_N_AGV_LOCATION = Settings.GetConnectingbitsList().Where(a => a.locCode == mst.CN_S_END_BIT).First().agvSite[0];
                    }
                }
                if (conn.Count == 1)
                {
                    //一个接驳平台
                    if (mst.CN_S_START_BIT == conn[0].locCode)
                    {
                        start.CN_N_AGV_LOCATION = Settings.GetConnectingbitsList().Where(a => a.locCode == mst.CN_S_START_BIT).First().agvSite[1];
                    }
                    if (mst.CN_S_END_BIT == conn[0].locCode)
                    {
                        end.CN_N_AGV_LOCATION = Settings.GetConnectingbitsList().Where(a => a.locCode == mst.CN_S_END_BIT).First().agvSite[0];
                    }
                }
                #endregion
 
                string FRow = string.IsNullOrEmpty(start.CN_S_FLOOR) ? "1" : start.CN_S_FLOOR;
                string TRow = string.IsNullOrEmpty(end.CN_S_FLOOR) ? "1" : end.CN_S_FLOOR;
                int location = -1;
                CMMLog.Info($"任务推送:货位编码:起点信息:{JsonConvert.SerializeObject(start)},终点信息:{JsonConvert.SerializeObject(end)};任务信息:{JsonConvert.SerializeObject(mst)}");
 
                
                if (mst.CN_S_BUSS_TYPE == "3楼复称入缓存架")
                {
                    CMMLog.Info($"任务推送特殊任务处理-3楼复称入缓存架:任务号:{mst.CN_S_TASK_NO},准备获取 sendBit 配置数据。备注:此任务类型仅获取起点。");
                    var plc = Settings.GetSendBit().Where(a => a.taskType == mst.CN_S_BUSS_TYPE && a.bit == mst.CN_S_START_BIT).FirstOrDefault();
                    if (plc != null)
                    {
                        start.CN_N_AGV_LOCATION = plc.agv;
                        FRow = string.IsNullOrEmpty(plc.floor) ? "1" : plc.floor;
                        CMMLog.Info($"任务推送特殊任务处理-3楼复称入缓存架-成功:获取数据成功,获取后的点位:{start.CN_N_AGV_LOCATION},FRow 参数:{FRow}");
                    }
                    else CMMLog.Info($"任务推送特殊任务处理-3楼复称入缓存架-失败:未获取到 settings 配置文件中的相关数据,请根据日志提供的相关数据对比 sendBit 配置数据。");
                }
                if (mst.CN_S_BUSS_TYPE == "包装线补空")
                {
                    CMMLog.Info($"任务推送特殊任务处理-包装线补空:任务号:{mst.CN_S_TASK_NO},准备获取 AGVLocationList 配置数据。备注:此任务类型仅获取起点。");
                    var agvLoc = Settings.GetDDSiteList().Where(a => a.ddLoc == mst.CN_S_START_BIT).FirstOrDefault();
                    if(agvLoc != null)
                    {
                        var emp = MongoDBSingleton.Instance.FindOne<BZEmptyPoint>(Query.EQ("Bit", mst.CN_S_START_BIT), "BZEmptyPoint");
                        if(emp != null)
                        {
                            location = agvLoc.Site[emp.Quantity - 1];
                        }
                    }
                }
                if (mst.CN_S_BUSS_TYPE == "缓存架入立库")
                {
                    TRow = "1";
                }
                if (mst.CN_S_BUSS_TYPE == "3楼成品出库")
                {
                    FRow = "1";
                }
 
                var startLoc = MongoDBSingleton.Instance.FindOne<MongoTN_AB_STOCK_LOCATION>(Query.EQ("CN_S_LOCATION_CODE", mst.CN_S_START_BIT), "MongoTN_AB_STOCK_LOCATION");
                var endLoc = MongoDBSingleton.Instance.FindOne<MongoTN_AB_STOCK_LOCATION>(Query.EQ("CN_S_LOCATION_CODE", mst.CN_S_END_BIT), "MongoTN_AB_STOCK_LOCATION");
                if(startLoc != null && endLoc != null)
                {
                    if(startLoc.CN_S_AREA_CODE == "CKHJ" || endLoc.CN_S_AREA_CODE == "CKHJ")
                    {
                        TRow = "1";
                    }
                }
 
                try
                {
                    start.CN_N_AGV_LOCATION = location == -1 ? start.CN_N_AGV_LOCATION : location;
                    var req = $"<Req><Order  TS='1'  Pri='{mst.CN_N_PRIORITY}' From='{start.CN_N_AGV_LOCATION}' To='{end.CN_N_AGV_LOCATION}'  No='{mst.CN_S_TASK_NO}_1' Ext1='1' Ext2='CALLADDAGV'  Ext3='' FRow='{FRow}' TRow='{TRow}'/></Req>";
                    CMMLog.Info($"任务推送:下发 Hosttoagv 数据:{req}.");
                    HardwareAccessObject AGVHao = HardwareAccessHelper.Instance.GetEquipmentsHAO("1");
                    if (AGVHao != null)
                    {
                        object[] args = new object[1];
                        args[0] = req;
                        object xmlData = AGVHao._WebServiceInstance.Invoke("AddNewOrder", args);
                        string errMsg = string.Empty;
                        int errCode = -1;
                        if (xmlData != null)
                        {
                            errCode = Hanhe.iWCS.AGVWebService.AGVHelper.Instance.AGVXmlResult((string)xmlData, out errMsg);
                        }
                        var msg = "WCS To AGV send task; errcode=" + errCode + "!data=" + sbMsg.ToString() + ";url=" + AGVHao.WebUrl;
                        CMMLog.Info($"任务推送:接收 Hosttoagv 数据:{msg}.");
                        if (errCode == Constants.WCS_AGV_ERRCode || errCode == 99999)
                        {
                            MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("_id", mst._id), Update.Set("CN_S_STATUS", "未执行"), UpdateFlags.None);
                            AMSHelper.TaskTrackLogMessage(mst.CN_S_TASK_NO, "1", "1027", "AGV任务拦截推送失败", errCode.ToString());
                            //Console.WriteLine(mst.CN_S_TASK_NO + ", \"1\", \"1027\", \"AGV任务拦截推送失败\"," + errCode.ToString());
                            CMMLog.Info(mst.CN_S_TASK_NO + ", \"1\", \"1027\", \"AGV任务拦截推送失败\"," + errCode.ToString());
                        }
                        else
                        {
                            if (errCode == 0 || errCode == 50009)
                            {
                                MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("_id", mst._id), Update.Set("CN_S_STATUS", "已推送"), UpdateFlags.None);
                            }
                            AMSHelper.TaskTrackLogMessage(mst.CN_S_TASK_NO, "1", "1027", "AGV任务下达成功");
                            //Console.WriteLine(mst.CN_S_TASK_NO + "\"1\", \"1027\", \"AGV任务下达成功\"");
                            CMMLog.Info(mst.CN_S_TASK_NO + "\"1\", \"1027\", \"AGV任务下达成功\"");
                        }
                    }
                    else
                    {
                        //Console.WriteLine("WCS To AGV send task fail; ts1 not set in ams work center");
                        CMMLog.Info("WCS To AGV send task fail; ts1 not set in ams work center");
                    }
                }
                catch (Exception ex)
                {
                    MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("_id", mst._id), Update.Set("CN_S_STATUS", "未执行"), UpdateFlags.None);
                    CMMLog.Error("WCS To AGV send task fail;param=" + mst.CN_S_TASK_NO + ";err=" + ex.Message);
                    AMSHelper.TaskTrackLogMessage(mst.CN_S_TASK_NO, "1", "1027", "AGV任务拦截推送失败");
                }
            }
        }
 
        #region   3楼设备任务
 
        /// <summary>
        /// 终点安全对接:1013安全请求进入;6安全请求退出
        /// </summary>
        /// <param name="mst"></param>
        /// <param name="code"></param>
        internal static void EndPickUpDoorSafe(TN_I_TASK_MST mst, int code)
        {
            //3楼包装补空:包装机补空托流程——3楼包装机安全门交互
            var plc = Settings.GetPlcInfo().Where(a => a.location == mst.CN_S_END_BIT).FirstOrDefault();
            //if (plc != null || mst.CN_S_BUSS_TYPE == "3楼复称入缓存架")
            CMMLog.Info($"{mst.CN_S_END_BIT}");
            CMMLog.Info($"{plc}");
            if (plc != null || mst.CN_S_BUSS_TYPE == "3楼打包下线")
            {
                CMMLog.Info($"进入{mst.CN_S_BUSS_TYPE}流程{code}的处理");
                if (code == 1013)
                {
                    //卸货申请,先判断设备是否允许进料,如果是直接改参数,并通知设备
                    if (mst.CN_S_BUSS_TYPE == "3楼包装取料" || mst.CN_S_BUSS_TYPE == "地面货位取料") PLCControl.SecondWeightSafe(plc.ip, mst.CN_S_TASK_NO, plc.port);
                    //if (mst.CN_S_BUSS_TYPE == "3楼复称入缓存架") PLCControl.SecondWeightInCache1013(mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "3楼缓存架入叠托") PLCControl.CacheStackingMouth1013(plc.deviceType, mst.CN_S_TASK_NO, mst.CN_S_END_BIT);
                    if (mst.CN_S_BUSS_TYPE == "3楼拆盘补空") PLCControl.DiscRemoverReqUnload(plc.deviceType, mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "包装线补空") PLCControl.PackingLine(plc.ip, mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "3楼打包下线" || mst.CN_S_BUSS_TYPE == "PDA打包下线") PLCControl.outWare(mst.CN_S_TASK_NO, true);
                    if (mst.CN_S_BUSS_TYPE == "3楼成品出库") PLCControl.productOutWare(mst.CN_S_END_BIT, mst.CN_S_TASK_NO, true);
                    if (mst.CN_S_BUSS_TYPE == "烘干机空托上线" || mst.CN_S_BUSS_TYPE == "剪切机满托上线") PLCControl.DGMachineTwo(plc, mst.CN_S_TASK_NO, true);
                }
                if (code == 6)
                {
                    //卸货完成申请,判断设备那边进料完成,改参数通知agv离开
                    if (mst.CN_S_BUSS_TYPE == "3楼包装取料" || mst.CN_S_BUSS_TYPE == "地面货位取料") PLCControl.CheckUpUnloadComplete(plc.ip, mst.CN_S_TASK_NO, mst.CN_S_START_BIT, plc.port);
                    //if (mst.CN_S_BUSS_TYPE == "3楼包装取料") PLCControl.SecondWeightSafeComplete(plc.ip, mst.CN_S_TASK_NO);
                    //if (mst.CN_S_BUSS_TYPE == "3楼复称入缓存架") PLCControl.SecondWeightInCache6(plc.ip, mst.CN_S_TASK_NO);
 
                    if (mst.CN_S_BUSS_TYPE == "3楼缓存架入叠托") PLCControl.writeStackingMouth6(mst.CN_S_END_BIT, mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "3楼拆盘补空") PLCControl.DiscRemoverUnloadComplete(plc.deviceType, mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "3楼打包下线" || mst.CN_S_BUSS_TYPE == "PDA打包下线") PLCControl.outWare(mst.CN_S_TASK_NO, false);
                    if (mst.CN_S_BUSS_TYPE == "包装线补空") PLCControl.PackingLineComplete(plc.ip);
                    if (mst.CN_S_BUSS_TYPE == "3楼成品出库") PLCControl.productOutWare(mst.CN_S_END_BIT, mst.CN_S_TASK_NO, false);
                    if (mst.CN_S_BUSS_TYPE == "烘干机空托上线" || mst.CN_S_BUSS_TYPE == "剪切机满托上线") PLCControl.DGMachineTwo(plc, mst.CN_S_TASK_NO, true);
                }
            }
            else CMMLog.Info($"PlcInfo中未找到该点位,点位:{mst.CN_S_END_BIT}");
        }
 
        /// <summary>
        /// 滚筒车终点到位信号:4     取货完成:1213
        /// </summary>
        /// <param name="mst"></param>
        /// <param name="code"></param>
        internal static void DiscRemoverEmptySupport(TN_I_TASK_MST mst, int code)
        {
            var plc = Settings.GetPlcInfo().Where(a => a.location == mst.CN_S_END_BIT).FirstOrDefault();
            if (plc != null)
            {
                if (code == 4)
                {
                    //卸货申请,先判断设备是否允许进料,如果是直接改参数,并通知设备
                    if (mst.CN_S_BUSS_TYPE == "3楼包装取料") PLCControl.CheckUpReqUnload(plc, mst);
                }
                if (code == 1213)
                {
                    //卸货完成申请,判断设备那边进料完成,改参数通知agv离开
                    //if (mst.CN_S_BUSS_TYPE == "3楼包装取料") PLCControl.CheckUpUnloadComplete(plc.ip, mst.CN_S_TASK_NO,mst.CN_S_START_BIT,plc.port);
                }
            }
            else CMMLog.Info($"设备未配置:{mst.CN_S_END_BIT}");
        }
 
        /// <summary>
        /// 起点安全对接:1012安全请求进入;4安全请求退出
        /// </summary>
        /// <param name="mst"></param>
        /// <param name="code"></param>
        internal static void StartPickUpDoorSafe(TN_I_TASK_MST mst, int code)
        {
            //3楼包装补空:包装机补空托流程——3楼包装机安全门交互
            var plc = Settings.GetPlcInfo().Where(a => a.location == mst.CN_S_START_BIT).FirstOrDefault();
            if (plc != null)
            {
                CMMLog.Info($"进入任务{mst.CN_S_BUSS_TYPE}的流程{code}");
                if (code == 1012)
                {
                    //卸货申请,先判断设备是否允许进料,如果是直接改参数,并通知设备
                    if (mst.CN_S_BUSS_TYPE == "3楼包装取料" || mst.CN_S_BUSS_TYPE == "PDA打包下线") PLCControl.PickUpFullDoorUnload(plc.ip, mst.CN_S_TASK_NO);//进入3楼包装取料流程1012,ip:{plc.ip},task:{mst.CN_S_TASK_NO}
                    if (mst.CN_S_BUSS_TYPE == "3楼复称入缓存架" || mst.CN_S_BUSS_TYPE == "3楼复称入缓存架NG") PLCControl.SecondWeightInCache1012(plc.ip, mst.CN_S_TASK_NO);//二期:直接改参数
                    if (mst.CN_S_BUSS_TYPE == "3楼缓存架入叠托") TSHelper.GoToAGV(mst.CN_S_TASK_NO, 10, 1);
                    if (mst.CN_S_BUSS_TYPE == "3楼叠盘下线") PLCControl.StackingReqUnload(plc.deviceType, mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "3楼打包下线") PLCControl.PackingLineUnload1012(plc.ip, mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "烘干机满托下线" || mst.CN_S_BUSS_TYPE == "剪切机空托下线" || mst.CN_S_BUSS_TYPE == "包装机满托下线") PLCControl.DGMachine(plc,mst.CN_S_TASK_NO,true);
                }
                if (code == 4)
                {
                    //卸货完成申请,判断设备那边进料完成,改参数通知agv离开
                    if (mst.CN_S_BUSS_TYPE == "3楼包装取料" || mst.CN_S_BUSS_TYPE == "PDA打包下线") PLCControl.PickUpFullDoorComplete(plc.ip, mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "3楼复称入缓存架" || mst.CN_S_BUSS_TYPE == "3楼复称入缓存架NG") PLCControl.SecondWeightInCache4(plc.deviceType, mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "3楼叠盘下线") PLCControl.StackingComplete(plc.deviceType, mst.CN_S_TASK_NO);
                    if (mst.CN_S_BUSS_TYPE == "3楼打包下线") PLCControl.PackingLineComplete4(plc.ip, mst.CN_S_SOURCE_NO);
                    if (mst.CN_S_BUSS_TYPE != "3楼包装取料") WMSHelper.ExecuteState(mst.CN_S_SOURCE_NO, 4);
                    if (mst.CN_S_BUSS_TYPE == "3楼缓存架入叠托NG") PLCControl.CacheStackingMouth6(plc);
                    if (mst.CN_S_BUSS_TYPE == "辅材入库") PLCControl.fcrk(plc);
                    if (mst.CN_S_BUSS_TYPE == "烘干机满托下线" || mst.CN_S_BUSS_TYPE == "剪切机空托下线" || mst.CN_S_BUSS_TYPE == "包装机满托下线") PLCControl.DGMachine(plc, mst.CN_S_TASK_NO, false);
 
                }
            }
            else CMMLog.Info($"点位{mst.CN_S_START_BIT}未配置");
        }
 
        /// <summary>
        /// 滚筒车起点到位信号:1112     取货完成:1212
        /// </summary>
        /// <param name="mst"></param>
        /// <param name="code"></param>
        internal static void PickupAndUnload(TN_I_TASK_MST mst,int code)
        {
            //3楼包装补空:包装机补空托流程——空托输送线交互(取空托,取空托完成)
            //3楼包装取料:3楼包装机取料去复称平台流程——进入包装机安全门后取料
            var plc = Settings.GetPlcInfo().Where(a => a.location == mst.CN_S_START_BIT).FirstOrDefault();
            if (plc != null)
            {
                if (code == 1112)
                {
                    //三楼包装机进安全门内对接
                    if (mst.CN_S_BUSS_TYPE == "3楼包装取料") PLCControl.PickUpFullUnload(plc.ip, mst.CN_S_TASK_NO, plc.port);
                }
                if (code == 1212)
                {
                    //三楼包装机安全门内对接   二期没有滚筒车,因此无需向 包装机 写入 滚筒停止指令
                    //if (mst.CN_S_BUSS_TYPE == "3楼包装取料") PLCControl.PickUpFullComplete(plc.ip, mst.CN_S_TASK_NO);
                }
            }
        }
 
        #endregion
 
        #region   任务处理——拦截任务-电梯任务-取消任务
 
        /// <summary>
        /// 拦截WMS发送的任务,因为WCS需要对任务类型进行分类处理
        /// </summary>
        /// <param name="mst"></param>
        /// <returns></returns>
        internal static bool Intercept(TN_I_TASK_MST mst)
        {
            bool result = false;// false:直接推送 true:拦截不推送
            try
            {
                //对WMS下发的任务进行拦截,因为AMS需要对任务类型进行区分处理(调试通过后,可以考虑封装为方法)
 
                CMMLog.Info($"任务拦截处理:执行开始!任务号:{mst.CN_S_TASK_NO}");
                if (mst.CN_S_BUSS_TYPE == "电梯卸货" || mst.CN_S_BUSS_TYPE == "电梯取货") return result;//不拦截,直接推送
                                                                                                //满托入库任务:需要拦截创建 电梯一段任务,然后更改任务状态为执行中,不进行推送
                if (mst.CN_S_BUSS_TYPE == "满托入库" && !mst.Ext1.Contains("满托入库"))
                {
                    //插入电梯任务中间表 ElevatorTask ,修改 mst表任务来源号 后面 加_1 表示电梯一段任务
                    //满托入库 任务 ,目前只需要直接送入库区中,取消一楼拆盘机交互代码 2023.10.10
                    var task = MongoDBSingleton.Instance.FindOne<ElevatorTask>(Query.EQ("wmsTaskNo", mst.CN_S_TASK_NO), "ElevatorTask");
                    if (task == null)
                    {
                        MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("_id", mst._id), Update.Set("Ext1", mst.Ext1 + "满托入库").Set("CN_S_STATUS", "执行中"), UpdateFlags.None);
                        MongoDBSingleton.Instance.Insert<ElevatorTask>(new ElevatorTask { taskNo = mst.CN_S_TASK_NO, wmsTaskNo = mst.CN_S_TASK_NO, startBit = mst.CN_S_START_BIT, endBit = "", endBit02 = "", wmsEndBit = mst.CN_S_END_BIT, startFloor = 3, endFloor = 1, sendFlag = 0, create = DateTime.Now.ToString(), wmsSourceNo = mst.CN_S_SOURCE_NO, timeStramp = mst.CN_S_BATCH_NO });
                    }
                    return result = true;
                }
                if (mst.CN_S_BUSS_TYPE == "3楼缓存架入叠托")
                {
                    //寻找所有正在执行中的  3楼缓存架入叠托  任务
                    //var taskInfoList = MongoDBSingleton.Instance.Find<TN_I_TASK_MST>(Query.And(Query.EQ("CN_S_BUSS_TYPE", "3楼缓存架入叠托"), Query.NotIn("CN_S_STATUS", new List<MongoDB.Bson.BsonValue>() { "未执行", "待推送" })), "TN_I_TASK_MST");
                    //if (taskInfoList.Count > 0)
                    //{
                    //    //找到了有正在执行中的任务,通过是否卸货完成判断是否可推送任务
                    //    try
                    //    {
                    //        for (int i = taskInfoList.Count - 1; i >= 0; i--)
                    //        {
                    //            //查询所有的已推送的任务,判断是否卸货完成,卸货完成从列表中掉
                    //            var taskNo = taskInfoList[i].CN_S_TASK_NO;
                    //            var trackInfo = MongoDBSingleton.Instance.FindOne<TN_I_TASK_DTL_ACTION_TrackLog>(Query.And(Query.EQ("CN_S_TASK_NO", taskNo), Query.EQ("CN_S_ACTION_CODE", 6)), "TN_I_TASK_DTL_ACTION_TrackLog");
                    //            if (trackInfo != null) taskInfoList.Remove(taskInfoList[i]);
                    //        }
                    //
                    //        if(taskInfoList.Count > 0) 
                    //        {
                    //            int a = 0;
                    //            int b = 0;
                    //            foreach (var c in taskInfoList)
                    //            {
                    //                //查询所有未推送的任务
                    //                if (c.CN_S_START_BIT.Substring(0,1) == mst.CN_S_START_BIT.Substring(0, 1)) a = a + 1;
                    //                else b = b + 1;
                    //            }
                    //            if (a > b) return true;
                    //        }
                    //
                    //        //判断是否还有没有取货完成的任务,若还有,不推送
                    //        if (taskInfoList.Count > 0)
                    //        {
                    //            return true;
                    //        }
                    //    }
                    //    catch (Exception ex)
                    //    {
                    //        Console.WriteLine("3楼缓存架入叠托:" + ex.Message);
                    //    }
                    //}
                }
                if (mst.CN_S_BUSS_TYPE == "3楼成品出库" || mst.CN_S_BUSS_TYPE == "辅材出库")
                {
                    //3楼成品出库任务拦截
                    if (!OutWareTask(mst))
                    {
                        CMMLog.Info($"{mst.CN_S_BUSS_TYPE}流程,任务更改为true");
                        result = true;
                    }
                }
                if (mst.CN_S_BUSS_TYPE == "辅材入库")
                {
                    if (!FCInTask(mst))
                    {
                        result = true;
                    }
                }
                var bussTypeInfo = Settings.GetHouWeiCodeo().Where(a => a.location == mst.Ext1).FirstOrDefault();
                if (bussTypeInfo != null)
                {
                    if (bussTypeInfo.task != "5" && bussTypeInfo.task != "15")
                        MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("_id", mst._id), Update.Set("CN_S_BUSS_TYPE", bussTypeInfo.taskType).Set("Ext1", mst.Ext1 + bussTypeInfo.taskType), "TN_I_TASK_MST", UpdateFlags.None);
                    else
                    {
                        var wmsinfo = MongoDBSingleton.Instance.FindOne<WMSInfo>(Query.EQ("trayCode", mst.CN_S_BATCH_NO), "WMSInfo");
                        if (wmsinfo == null)
                        {
                            MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("_id", mst._id), Update.Set("CN_S_BUSS_TYPE", bussTypeInfo.taskType).Set("Ext1", mst.Ext1 + bussTypeInfo.taskType), "TN_I_TASK_MST", UpdateFlags.None);
                            if(mst.CN_S_BUSS_TYPE == "缓存架人叠托" && mst.CN_S_BATCH_NO.Substring(0,3) == "SWT")
                            {
                                MongoDBSingleton.Instance.Insert<WMSInfo>(new WMSInfo
                                {
                                    trayCode = mst.CN_S_BATCH_NO,
                                    TaskNo = mst.CN_S_TASK_NO,
                                    dateTime = DateTime.Now
                                });
                            }
                            else
                            {
                                var transInfo = mst.transportInfo.First();
                                List<string> list = new List<string>(transInfo.itemWeight.Split(','));
                                List<string> date = new List<string>(transInfo.itemFeatures.Split(','));
                                MongoDBSingleton.Instance.Insert<WMSInfo>(new WMSInfo
                                {
                                    trayCode = mst.CN_S_BATCH_NO,
                                    itemCode = transInfo.itemCode,
                                    itemPCode = transInfo.itemPCode,
                                    location = transInfo.itemName,
                                    productWeight = list[0],
                                    trayCodeWeight = list[1],
                                    oneTrayWeight = list[2],
                                    palletLayers = list[3],
                                    addState = int.Parse(date[0]),
                                    packageCode = transInfo.trayCode,
                                    TaskNo = mst.CN_S_TASK_NO,
                                    dateTime = DateTime.Now
                                });
                            }
                            
                        }
                        else
                        {
                            //Console.WriteLine("任务拦截处理:WMSINFO中间表目前正在有缓存架入叠托的任务在执行!");
                            CMMLog.Info("任务拦截处理:WMSINFO中间表目前正在有缓存架入叠托的任务在执行!");
                        }
                    }
                    result = true;
                }
                MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("_id", mst._id), Update.Set("CN_S_STATUS", "未执行"), "TN_I_TASK_MST", UpdateFlags.None);
                CMMLog.Info("任务拦截处理:执行完毕!");
            }
            catch(Exception ex)
            {
                Console.WriteLine($"taskNo:{mst.CN_S_TASK_NO},Intercept ex:{ex}");
            }
            CMMLog.Info($"RESULT:{result}");
            return result;
        }
 
        /// <summary>
        /// 辅材入库流程
        /// </summary>
        /// <param name="mst"></param>
        /// <returns></returns>
        private static bool FCInTask(TN_I_TASK_MST mst)
        {
            //1、判断辅材入库终点是否有任务
            //2、判断输送线模式和中间表模式都是入库模式
            bool action = true;
            var plc = Settings.GetPlcInfo().Where(a => a.deviceType == "18" && a.enable == 1).ToList();
            if (plc.Count > 0)
            {
                foreach(var a in plc)
                {
                    if(CheckStartFree(a.location) && CheckEndFree(a.location))
                    {
                        var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
                        {
                            dataNum = 1,
                            addr = a.readAddr + 3,
                            host = a.ip,
                            port = a.port
                        });
                        if (result != null && result.errCode == 0)
                        {
                            CMMLog.Debug($"辅材入库流程:读取滚筒机{a.ip}通道号为:{a.readAddr + 3}的值为:{result.result[0]}");
                            if (result.result[0] == 1)
                            {
                                action = false;
                                CMMLog.Debug($"辅材入库流程:输送线为 出库模式,输送线点位:{a.location}");
                                break;
                            }
                            else
                            {
                                //读取中间表模式
                                var modelInfo = MongoDBSingleton.Instance.FindOne<ModeList>("ModeList");
                                if(modelInfo != null)
                                {
                                    if(modelInfo.Mode == "出库模式")
                                    {
                                        action = false;
                                        CMMLog.Debug($"辅材入库流程:中间表 ModeList为 出库模式");
                                        break;
                                    }
                                }
                                else
                                {
                                    action = false;
                                    CMMLog.Debug("辅材入库流程:中间表 ModeList 为空");
                                    break;
                                }
                            }
                        }
                    }
                    else
                    {
                        action = false;
                        CMMLog.Debug($"辅材入库流程:当前点位有任务,点位:{a.location}");
                        break;
                    }
                };
 
                if (action)
                {
                    //入库模式核验正确 判断货物是否到位
                    var startPlc = plc.Where(a => a.location == mst.CN_S_START_BIT).First();
                    if(startPlc != null)
                    {
                        var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
                        {
                            dataNum = 1,
                            addr = startPlc.readAddr + 1,
                            host = startPlc.ip,
                            port = startPlc.port
                        });
 
                        if (result != null && result.errCode == 0)
                        {
                            CMMLog.Debug($"辅材入库流程:读取滚筒机{startPlc.ip}通道号为:{startPlc.readAddr + 3}的值为:{result.result[0]}");
                            if (result.result[0] == 2)
                            {
                                int[] num = new int[2] { 2, 1 };
                                var wirteal = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
                                {
                                    addr = startPlc.writeAddr + 1,
                                    host = startPlc.ip,
                                    data = num,
                                    port = startPlc.port
                                });
 
                                return true;
                            }
                        }
                    }
                }
                else
                {
                    return false;
                }
            }
 
            return false;
        }
 
 
        public class ModeList
        {
            public ObjectId id { get; set; }
            /// <summary>
            /// 模式
            /// </summary>
            public string Mode { get; set; }
        }
 
        internal static bool OutWareTask(TN_I_TASK_MST mst)
        {
            bool result = false;
            CMMLog.Info($"OutWareTask {mst.CN_S_BUSS_TYPE}任务流程处理开始 ,result:{result}");
            //3楼成品出库流程
            //成品出口输送线上有两个输送口 每条输送口可以生成两条任务,任务推送了之后给输送线数量加一,两条输送口轮流推送任务
 
            //判断输送线模式和中间表模式都是出库模式
 
            try
            {
                string endMachLoc = "";
                string endLoc = "";
                //1、判断上料平台是否空闲,若空闲更改终点到上料平台
                var plc = Settings.GetPlcInfo().Where(a => a.deviceType == "18" && a.enable == 1).ToList();
                if (plc.Count > 0)
                {
                    #region 判断输送线模式 变更注释
 
                    //foreach(var a in plc)
                    //{
                    //    bool action = false;
                    //    var modeResult = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
                    //    {
                    //        dataNum = 1,
                    //        addr = a.readAddr + 3,
                    //        host = a.ip,
                    //        port = a.port
                    //    });
                    //    if (modeResult != null && modeResult.errCode == 0)
                    //    {
                    //        CMMLog.Debug($"OutWareTask:读取滚筒机{a.ip}通道号为:{a.readAddr + 3}的值为:{modeResult.result[0]}");
                    //        if (modeResult.result[0] == 2)
                    //        {
                    //            CMMLog.Debug($"OutWareTask:输送线为 入库模式,输送线点位:{a.location}");
                    //            break;
                    //        }
                    //        else
                    //        {
                    //            //读取中间表模式
                    //            var modelInfo = MongoDBSingleton.Instance.FindOne<ModeList>("ModeList");
                    //            if (modelInfo != null)
                    //            {
                    //                if (modelInfo.Mode == "入库模式")
                    //                {
                    //                    CMMLog.Debug($"OutWareTask:中间表 ModeList为 入库模式");
                    //                }
                    //                else
                    //                {
                    //                    action = true;
                    //                }
                    //            }
                    //            else
                    //            {
                    //                CMMLog.Debug("OutWareTask:中间表 ModeList 为空");
                    //            }
                    //        }
                    //    }
                    //    if (!action)
                    //    {
                    //        return false;
                    //    }
                    //};
 
                    #endregion
 
 
                    string ssx01 = plc[0].location;
                    string ssx02 = plc[1].location;
                    //CMMLog.Info($"查询输送线当前点位:{a.location}");
                    var slptInfo1 = MongoDBSingleton.Instance.FindOne<SLPTLoc>(Query.EQ("locCode", ssx01), "SLPTLoc");
                    if (slptInfo1 == null)
                    {
                        endMachLoc = ssx01;
                        slptInfo1 = new SLPTLoc
                        {
                            locCode = ssx01,
                            taskNum = 1
                        };
                        MongoDBSingleton.Instance.Insert(slptInfo1);
                    }
                    else
                    {
                        var slptInfo2 = MongoDBSingleton.Instance.FindOne<SLPTLoc>(Query.EQ("locCode", ssx02), "SLPTLoc");
                        if (slptInfo2 == null)
                        {
                            endMachLoc = ssx02;
                            slptInfo2 = new SLPTLoc
                            {
                                locCode = ssx02,
                                taskNum = 1
                            };
                            MongoDBSingleton.Instance.Insert(slptInfo2);
                        }
                        else
                        {
                            var loc = slptInfo1.taskNum <= slptInfo2.taskNum ? slptInfo1 : slptInfo2;
                            CMMLog.Info("OutWareTask :" + JsonConvert.SerializeObject(loc));
                            if (loc.taskNum < 2)
                            {
                                endMachLoc = loc.locCode;
                                int num = loc.taskNum + 1;
                                MongoDBSingleton.Instance.Update<SLPTLoc>(Query.EQ("locCode", endMachLoc), Update.Set("taskNum", num), UpdateFlags.None);
                            }
                        }
                    }
 
                    if (!string.IsNullOrEmpty(endMachLoc))
                    {
                        CMMLog.Info($"OutWareTask 55555");
                        //改任务的终点
                        MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", mst.CN_S_TASK_NO), Update.Set("CN_S_END_BIT", endMachLoc), UpdateFlags.None);
 
                        new SqlHelper<object>().ExecuteSql($"update dbo.tn_am_task_mst set CN_S_END_BIT='{endMachLoc}',CN_S_END_AGVBIT = '{StockInstance.Instance.GetAGVCodeForBitCode(endMachLoc)}' where CN_S_TASK_NO = '{mst.CN_S_TASK_NO}'");
 
                        var plcTwo = Settings.GetPlcInfo().Where(a => a.location == endMachLoc && a.enable == 1).First();
                        //int[] num = new int[1] { 1 };
                        //var wirte = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
                        //{
                        //    addr = plcTwo.writeAddr + 1,
                        //    host = plcTwo.ip,
                        //    data = num,
                        //    port = plcTwo.port
                        //});
 
                        result = true;
                    }
                    else CMMLog.Info("OutWareTask 输送线不可用");
                }
                else
                {
                    CMMLog.Info("上料平台设备未配置");
                }
            }
            catch(Exception ex)
            {
 
                CMMLog.Info($"OutWareTask err:"+ex.Message);
            }
            
            CMMLog.Info($"OutWareTask result:{result}");
            return result;
        }
 
        public class endBitModel
        {
            public string CN_S_TASK_NO { get; set; }
            public string CN_S_END_BIT { get; set; }
        }
 
        /// <summary>
        /// 3楼成品出库任务中间表
        /// </summary>
        public class SLPTLoc
        {
            public ObjectId _id { get; set; }
            public string locCode { get; set; }
            public int taskNum { get; set; }
            public int count { get; set; } = 0;
        }
 
        public class location
        {
            public ObjectId _id { get; set; }
            public string S_LOC_CODE { get; set; }
            //public string S_ITEM_CODE { get; set; }
            //public string S_BATCH_NO { get; set; }
            public string S_LOC_STATE { get; set; } = "无";
            public int N_CURRENT_NUM { get; set; }
            public string S_TRAY_CODE { get; set; }
        }
 
        /// <summary>
        /// 线程读取电梯任务中间表,推送一条电梯任务        待确认:这里推送应该根据任务号后缀“_2”判断是否为第二段任务,首先推送第二段任务,其次,推送最早的第一段任务
        /// </summary>
        internal static void CheckElevatorTask()
        {
            CMMLog.Info("电梯任务线程:执行开始!");
            //读取mongo ElevatorTask 表任务,先判断有没有 已经推送的,如果没有
            var tsTask = MongoDBSingleton.Instance.FindOne<ElevatorTask>(Query.EQ("sendFlag", 1), "ElevatorTask");
            if (tsTask == null)
            {
                //取一条任务
                CMMLog.Info("电梯任务线程:取一条任务");
                var taskInfo = MongoDBSingleton.Instance.FindOne<ElevatorTask>(Query.EQ("sendFlag", 0), "ElevatorTask");
                if(taskInfo != null)
                {
                    CMMLog.Info("电梯任务线程:创建一条从当前起点前往当前楼层等待点的任务");
                    //创建一条从当前起点前往当前楼层等待点的任务,等收到小车在等待点发送的信号之后,
                    //判断两部电梯哪个可以使用,在创建一段二段电梯任务,回归原始流程
                    string location = Settings.GetPlcInfo().Where(a => a.deviceType == "4").FirstOrDefault().location;
                    //如果当前 电梯任务 的 起点是 打包线-打包下线口,则是 满托入库 任务流程
                    if (taskInfo.startBit == location)
                    {
                        CMMLog.Info($"电梯任务线程:满托入库等待点{Settings.Wait02}");
                        //满托入库
                        AMSHelper.CreateTask(taskInfo.wmsTaskNo + "_1", taskInfo.startBit, Settings.Wait02, "电梯卸货", 10 ,taskInfo.timeStramp);
                    }
                    else
                    {
                        CMMLog.Info($"电梯任务线程:空托出库等待点{Settings.Wait01}");
                        //空托出库
                        AMSHelper.CreateTask(taskInfo.wmsTaskNo + "_1", taskInfo.startBit, Settings.Wait01, "电梯卸货", 10, taskInfo.timeStramp);
                    }
                    //根据 taskNo 查询任务,推送,修改ams任务的终点是 电梯任务的起点 sendTask
                    MongoDBSingleton.Instance.Update<ElevatorTask>(Query.EQ("taskNo", taskInfo.taskNo), Update.Set("sendFlag", 1).Set("taskNo", taskInfo.wmsTaskNo + "_1"), UpdateFlags.None);
                    //AMSHelper.CreateTask(taskInfo.wmsTaskNo + "_1", taskInfo.startBit, taskInfo.endBit, "电梯卸货", 10);
                    //MongoDBSingleton.Instance.Update<ElevatorTask>(Query.EQ("taskNo", taskInfo.taskNo), Update.Set("sendFlag", 1).Set("taskNo",taskInfo.wmsTaskNo+"_1"), UpdateFlags.None);
                }
                else CMMLog.Info("电梯任务线程:当前电梯中间表无任务!");
            } 
            else CMMLog.Info("当前电梯中间表有任务正在执行中!");
            CMMLog.Info("电梯任务线程:执行结束!");
        }
 
        /// <summary>
        /// 电梯开门关门服务
        /// </summary>
        /// <param name="mst"></param>
        /// <param name="v">true 开门请求  false关门请求</param>
        /// <exception cref="NotImplementedException"></exception>
        internal static void OperateDoor(TN_I_TASK_MST mst, int code)
        {
            //目前仅存在 入库任务(三楼至一楼) 2023.10.10 更新
            //1012-4(二段任务起点)    1013-6(一段任务终点)
            //根据任务类型或者起点终点判断        这里判断小车是去卸货还是取货
            var query = Query.EQ("taskNo",mst.CN_S_SOURCE_NO);
            //任务号查询  ElevatorTask
            ElevatorTask task = MongoDBSingleton.Instance.FindOne<ElevatorTask>(query, "ElevatorTask");
            string PlcBit04 = Settings.GetPlcInfo().Where(a => a.deviceType == "4").FirstOrDefault().location;//打包线下线口
            string PlcBit07 = Settings.GetPlcInfo().Where(a => a.deviceType == "7").FirstOrDefault().location;//一楼拆盘机点位
            if (code == 1312 || code == 6)
            {
                //卸货-请求开门   卸货完成    给plc发消息,卸货任务 让plc startFloor 开门,取货任务 让plc endFloor开门
                //入库任务一段任务终点货梯进入
                if (code == 1312 && task.startBit == PlcBit04 && task.wmsEndBit == PlcBit07) PLCControl.RuKuOne1013(mst, task.startFloor);
                else
                {
                    if (task.startBit == PlcBit04 && task.wmsEndBit == PlcBit07)
                    {
                        //入库任务一段任务终点货梯退出
                        //如果是 卸货任务 关门
                        //给电梯plc发信号,让他从startfloor 到endfloor 
                        if (PLCControl.RuKuOne6(mst, task.endFloor)) 
                        {
                            //关门同时生成一条对应楼层的取货任务(二段任务)
                            AMSHelper.SetStatus(mst.CN_S_TASK_NO, 1, "2", "0", true);
                            AMSHelper.CreateTask(task.wmsTaskNo + "_2", Settings.Wait01, task.wmsEndBit, "电梯取货", 10, mst.CN_S_BATCH_NO);
                            //查询更新电梯任务中间表的任务号为二段任务
                            MongoDBSingleton.Instance.Update<ElevatorTask>(Query.EQ("taskNo", mst.CN_S_SOURCE_NO), Update.Set("taskNo", task.wmsTaskNo + "_2"), UpdateFlags.None);
                        }
                    }
                }
            }
            else if(code == 1012 || code == 4)
            {
                //取货-请求开门   取货完成    4_6    小车离开货梯,一段任务完成,结束一段任务,开始推送二段任务
                if (code == 1012 && task.startBit == PlcBit04 && task.wmsEndBit == PlcBit07) PLCControl.RuKuOne1012(mst, task.endFloor);//入库任务二段任务起点货梯请求开门
                else if (task.startBit == PlcBit04 && task.wmsEndBit == PlcBit07) PLCControl.RuKuOne4(mst, task.endFloor);//入库任务二段任务起点货梯请求关门
            }
        }
        /// <summary>
        /// 取消任务处理
        /// </summary>
        /// <param name="mst"></param>
        public static void TaskCancel(TN_I_TASK_MST mst)
        {
            CMMLog.Info($"进入取消任务流程!任务类型:{mst.CN_S_BUSS_TYPE}");
            if (mst.CN_S_BUSS_TYPE == "3楼包装取料")
            {
                CMMLog.Info($"任务类型:{mst.CN_S_BUSS_TYPE},任务操作:查询<MachineInfo>表中已当前起点为包装机号的数据machineNo,不为空,删除!任务号:{mst.CN_S_TASK_NO},任务起点:{mst.CN_S_START_BIT},任务终点:{mst.CN_S_END_BIT}");
                var tray = MongoDBSingleton.Instance.FindOne<MachineInfo>(Query.EQ("machineNo", mst.CN_S_START_BIT), "MachineInfo");
                if(tray != null)
                {
                    MongoDBSingleton.Instance.Remove<MachineInfo>(Query.EQ("machineNo", mst.CN_S_START_BIT), RemoveFlags.Single);
                    if (ERPService.ERPSwitch01 == "0") MongoDBSingleton.Instance.Remove<MachineInfoTwo>(Query.EQ("machineNo", mst.CN_S_START_BIT), "MachineInfoTwo", RemoveFlags.Single);
                }
            }
            if (mst.CN_S_BUSS_TYPE == "3楼缓存架入叠托")
            {
                var plc = Settings.GetPlcInfo().Where(a => a.deviceType == "3").FirstOrDefault();
                if (plc != null)
                {
                    var machine = MongoDBSingleton.Instance.FindOne<WMSInfo>(Query.EQ("trayCode", mst.CN_S_BATCH_NO), "WMSInfo");
                    if (machine != null)
                    {
                        #region   写多个MODBUS数据
                        int[] num = DiePan(machine);
 
                        CMMLog.Info($"send num:");
                        CMMLog.Info(JsonConvert.SerializeObject(num));
                        var wirteall01 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
                        {
                            addr = plc.writeAddr + 10,
                            host = plc.ip,
                            port = plc.port,
                            data = num
                        });
                        #endregion
                        MongoDBSingleton.Instance.Remove<WMSInfo>(Query.EQ("trayCode", mst.CN_S_BATCH_NO), RemoveFlags.Single);
                    }
                }
            }
            if (mst.CN_S_BUSS_TYPE == "电梯卸货" || mst.CN_S_BUSS_TYPE == "电梯取货" || mst.CN_S_BUSS_TYPE == "满托入库")
            {
                CMMLog.Info($"任务类型:{mst.CN_S_BUSS_TYPE},任务操作:查询<ElevatorTask>表中以当前任务号或来源号为任务号taskNo表字段的数据,不为空,删除!");
                CMMLog.Info($"如果是子任务删除,还需设置主任务,也就是当前任务对应的daintiness中间表中wmsSourceNo字段所对应的任务");
                var query = Query.Or(Query.EQ("taskNo", mst.CN_S_TASK_NO), Query.EQ("taskNo", mst.CN_S_SOURCE_NO));
                var cancel = MongoDBSingleton.Instance.FindOne<ElevatorTask>(query, "ElevatorTask");
                if (cancel != null)
                {
                    CMMLog.Info($"查询主表中以电梯任务当前任务中间表中wmsSource为来源号的任务");
                    var master = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_SOURCE_NO", cancel.wmsSourceNo), "TN_I_TASK_MST");
                    if (master != null)
                    {
                        callTaskProcessing.CancelTask(master.CN_S_TASK_NO, "1");
                        AMSHelper.SetStatus(master.CN_S_TASK_NO, 1, "7", "0", true);
                        WMSHelper.ExecuteState(master.CN_S_TASK_NO,7);
                        callTaskProcessing.DeleteTask(master.CN_S_TASK_NO);
                    }
                    MongoDBSingleton.Instance.Remove<ElevatorTask>(query, RemoveFlags.Single);
                }
            }
            MongoDBSingleton.Instance.Remove<Mongo_AGV_TASK_STATE>(Query.EQ("TaskNo", mst.CN_S_TASK_NO), RemoveFlags.None);
            CMMLog.Info($"取消任务流程结束!");
        }
        /// <summary>
        /// 强制完成任务处理
        /// </summary>
        /// <param name="mst"></param>
        /// <param name="action"></param>
        public static void ForceComplete(TN_I_TASK_MST mst, TN_I_TASK_DTL_ACTION action)
        {
            CMMLog.Info($"强制完成任务处理:收到2信号之后特殊任务类型处理:任务号:{mst.CN_S_TASK_NO},任务类型:{mst.CN_S_BUSS_TYPE}");
            if (mst.CN_S_BUSS_TYPE == "电梯取货" || mst.CN_S_BUSS_TYPE == "电梯卸货" || mst.CN_S_BUSS_TYPE == "满托入库" || mst.CN_S_BUSS_TYPE == "空托出库")
            {
                var ele = MongoDBSingleton.Instance.FindOne<ElevatorTask>(Query.EQ("taskNo", mst.CN_S_SOURCE_NO), "ElevatorTask");
                if (ele != null)
                {
                    AMSHelper.SetStatus(ele.wmsTaskNo, 1, "2", action.CN_S_DEVICE_CODE, true);
                    WMSHelper.ExecuteState(ele.wmsSourceNo, 2);
                    MongoDBSingleton.Instance.Remove<ElevatorTask>(Query.EQ("taskNo", mst.CN_S_SOURCE_NO), RemoveFlags.Single);
                    MongoDBSingleton.Instance.Remove<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", ele.wmsTaskNo), RemoveFlags.Single);
                }
            }
            if(mst.CN_S_BUSS_TYPE == "3楼包装取料")
            {
                MongoDBSingleton.Instance.Remove<MachineInfo>(Query.EQ("trayCode", mst.CN_S_BATCH_NO), RemoveFlags.Single);
                if (ERPService.ERPSwitch01 == "0") MongoDBSingleton.Instance.Remove<MachineInfoTwo>(Query.EQ("trayCode", mst.CN_S_BATCH_NO), "MachineInfoTwo", RemoveFlags.Single);
            }
        }
        /// <summary>
        /// 电梯取消删除任务
        /// </summary>
        /// <param name="mst"></param>
        /// <param name="action"></param>
        public static void ForceCancel(TN_I_TASK_MST mst, TN_I_TASK_DTL_ACTION action)
        {
            CMMLog.Info($"取消任务处理:收到2信号之后特殊任务类型处理:任务号:{mst.CN_S_TASK_NO},任务类型:{mst.CN_S_BUSS_TYPE}");
            if (mst.CN_S_BUSS_TYPE == "电梯取货" || mst.CN_S_BUSS_TYPE == "电梯卸货" || mst.CN_S_BUSS_TYPE == "满托入库" || mst.CN_S_BUSS_TYPE == "空托出库")
            {
                var ele = MongoDBSingleton.Instance.FindOne<ElevatorTask>(Query.EQ("taskNo", mst.CN_S_SOURCE_NO), "ElevatorTask");
                if (ele != null)
                {
                    AMSHelper.SetStatus(ele.wmsTaskNo, 1, "7", "0", true);
                    WMSHelper.ExecuteState(ele.wmsSourceNo, 7);
                    MongoDBSingleton.Instance.Remove<ElevatorTask>(Query.EQ("taskNo", mst.CN_S_SOURCE_NO), RemoveFlags.Single);
                    MongoDBSingleton.Instance.Remove<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", ele.wmsTaskNo), RemoveFlags.Single);
                }
            }
            if (mst.CN_S_BUSS_TYPE == "3楼包装取料")
            {
                MongoDBSingleton.Instance.Remove<MachineInfo>(Query.EQ("trayCode", mst.CN_S_BATCH_NO), RemoveFlags.Single);
                if (ERPService.ERPSwitch01 == "0") MongoDBSingleton.Instance.Remove<MachineInfoTwo>(Query.EQ("trayCode", mst.CN_S_BATCH_NO), "MachineInfoTwo", RemoveFlags.Single);
            }
        }
        #endregion
 
        #region   充电任务
        public static string battery = Settings.BatteryTime;
        internal static void AGVBatteryTime()
        {
            CMMLog.Info("进入充电任务流程判断:执行开始!");
            var now = DateTime.Today;
            string date = now.Year.ToString() + "-" + now.Month.ToString() + "-" + now.Day.ToString() + " " + battery;
            DateTime dt = Convert.ToDateTime(date);
            //十分钟以内判断当前充电桩是否有小车在充电,没有则推送当前充电桩电量最低的一辆小车去充电,并写入充电桩状态
            CMMLog.Info("进入充电任务流程:获取配置文件时间,并判断当前时间减去配置文件时间是否在20分钟以内!");
            if (DateTime.Now.Subtract(dt).TotalMinutes <= 20 && DateTime.Now.Subtract(dt).TotalMinutes > 0)
            {
                //先判断中间表是否有当前充电桩的状态,有则不操作,反之进入小车电量查询
                CMMLog.Info("进入充电任务流程:当前时间满足生成充电任务基本要求,开始判断ChargingPile配置项中当前充电桩状态是否开启");//ChargingPile
                var list = Settings.GetChargingPile().Where(a => a.enable == "1").ToList();
                if (list.Count > 0)
                {
                    //CMMLog.Info("04");
                    list.ForEach(a => {
                        //CMMLog.Info("05");
                        var margin = MongoDBSingleton.Instance.FindOne<MarginAGV>(Query.EQ("marginGroup", int.Parse(a.charginGroup)), "MarginAGV");
                        int agvBattery = 1000, agvNo = 0, marginGroup = 0;
                        if (margin == null)
                        {
                            CMMLog.Info($"进入充电任务流程:判断当前充电桩分组{a.charginGroup}能否在ChargingPile配置项中查找到且enable为开启状态!");
                            var list2 = Settings.GetChargingPile().Where(b => b.charginGroup == a.charginGroup && b.enable == "1").ToList();
                            list2.ForEach(b =>
                            {
                                CMMLog.Info($"进入充电任务流程:判断当前车号能否在<HangChaAGV>小车车身状态表中查询到数据,车号agvNo:{b.agvNo}");
                                var battery = MongoDBSingleton.Instance.FindOne<HangChaAGV>(Query.EQ("agvNo", b.agvNo), "HangChaAGV");
                                if(battery != null)
                                {
                                    if (int.Parse(battery.agvBattery) < agvBattery)
                                    {
                                        //CMMLog.Info($"进入充电任务流程:06 ");
                                        agvBattery = int.Parse(battery.agvBattery);
                                        agvNo = int.Parse(b.agvNo);
                                        marginGroup = int.Parse(b.charginGroup);
                                    }
                                }
                                else CMMLog.Info($"进入充电任务流程:error:当前车号在HangChaAgv中间表中查询不到数据!车号:{b.agvNo},所属充电桩:{b.charginGroup}");
                            });
                            //推送小车前往指定充电桩,并插入中间表状态
                            var agv = MongoDBSingleton.Instance.FindOne<MarginAGV>(Query.And(Query.EQ("agvNo", agvNo),Query.EQ("marginGroup", marginGroup)), "MarginAGV");
                            if(agv == null && agvNo != 0)
                            {
                                TSHelper.SendChargeTask(agvNo.ToString(), true);
                                //增加时间
                                MongoDBSingleton.Instance.Insert<MarginAGV>(new MarginAGV { agvNo = agvNo, marginGroup = marginGroup ,dateTime = DateTime.Now});
                            }
                        }
                    });
                }
            }
            else
            {
                CMMLog.Info("进入充电任务流程:超过十分钟,删除中间表");
                //超过十分钟,删除中间表
                MongoDBSingleton.Instance.ReomveAll<MarginAGV>();
            }
            CMMLog.Info("进入充电任务流程判断:执行结束!");
        }
 
        internal static void AGVBatteryTimeTwo()
        {
            var cpsInfo = MongoDBSingleton.Instance.FindAll<TN_B_CHARGE_PLAN_SET>("TN_B_CHARGE_PLAN_SET");
            if (cpsInfo.Count > 0)
            {
                foreach (var a in cpsInfo)
                {
                    int agvNo = int.Parse(a.CN_S_NAME);
                    if(agvNo != 0)
                    {
                        //判断中间表 MarginAGV 是否有该AGV的数据
                        var maInfo = MongoDBSingleton.Instance.FindOne<MarginAGV>(Query.EQ("agvNo", int.Parse(a.CN_S_NAME)), "MarginAGV");
                        if (maInfo == null)
                        {
                            if (DateTime.Parse(a.CN_DT_START).AddMinutes(10) > DateTime.Now)
                            {
                                //当前时间在指定充电时间的10分钟之内
                                var pileInfo = Settings.GetChargingPile().Where(b => b.agvNo == a.CN_S_NAME && b.enable == "1").FirstOrDefault();
                                if(pileInfo != null)
                                {
                                    int marginGroup = int.Parse(pileInfo.charginGroup);
                                    TSHelper.SendChargeTask(a.CN_S_NAME, true);
                                    //增加时间
                                    MongoDBSingleton.Instance.Insert<MarginAGV>(new MarginAGV { agvNo = agvNo, marginGroup = marginGroup, dateTime = DateTime.Now });
                                }
                                else
                                {
                                    CMMLog.Info($"充电任务,未配置当前车号,车号:{a.CN_S_NAME}");
                                }
                            }
                        }
                        else
                        {
                            if (maInfo.dateTime.AddMinutes(10) < DateTime.Now)
                            {
                                MongoDBSingleton.Instance.Remove<MarginAGV>(Query.EQ("id", maInfo.id), RemoveFlags.None);
                            }
                        }
                    }
                    else
                    {
                        CMMLog.Info("充电任务流程异常,当前车号为0");
                    }
                }
            }
        }
        #endregion
 
        /// <summary>
        /// 获取杭叉AGV<HangChaAGV>表里小车电量,并将其写入MODBUS中
        /// </summary>
        public static int[] GetBatteryHang() 
        {
            int[] num = new int[5];
            var bits = Settings.GetChargingAgvNo();
            CMMLog.Info($"获取小车车号信息:{JsonConvert.SerializeObject(bits)}");//6723
            for (int i = 0; i < num.Length; i++)
            {
                var battery = MongoDBSingleton.Instance.FindOne<HangChaAGV>(Query.EQ("agvNo", bits[i]), "HangChaAGV");
                num[i] = battery == null ? 0 : int.Parse(battery.agvBattery);
            }
            CMMLog.Info($"获取小车电量:{JsonConvert.SerializeObject(num)}");
            return num;
        }
 
        /// <summary>
        /// 电梯任务中间表,通过线程创建的跨楼层任务都会被拦截放入此表中
        /// </summary>
        public class ElevatorTask
        {
            public ObjectId _id { get; set; }
            public string taskNo { get; set; }
            public string wmsTaskNo { get; set; }
            /// <summary>
            /// WMS来源号
            /// </summary>
            public string wmsSourceNo { get; set; }
            /// <summary>
            /// 二段电梯任务终点 读配置文件
            /// </summary>
            public string wmsEndBit { get; set; }
            /// <summary>
            /// 一段任务电梯要到达的楼层
            /// </summary>
            public int startFloor { get; set; }
            /// <summary>
            /// 一段电梯任务起点 读配置文件
            /// </summary> 
            public string startBit { get; set; }
            /// <summary>
            /// 二段任务电梯要到达的楼层
            /// </summary>
            public int endFloor { get; set; }
            /// <summary>
            /// 一段电梯任务终点/二段电梯任务起点 读配置文件
            /// </summary>
            public string endBit { get; set; }
            /// <summary>
            /// 二段电梯任务起点
            /// </summary>
            public string endBit02 { get; set; }
            /// <summary>
            /// 任务发送状态  0:表示任务未启动   1:表示任务执行中
            /// </summary>
            public int sendFlag { get; set; }
            public string occupy { get; set; } = "";
            /// <summary>
            /// 时间戳--满托下线时存在数据,存入ext1字段中
            /// </summary>
            public string timeStramp { get; set; }
            /// <summary>
            /// 任务创建时间
            /// </summary>
            public string create { get; set; }
        }
 
        /// <summary>
        /// WMS叠盘机任务中存储信息
        /// </summary>
        public class WMSInfo
        {
            public ObjectId _id { get; set; }
            /// <summary>
            /// 产品型号 11 60
            /// </summary>
            public string itemCode { get; set; }
            /// <summary>
            /// 批次号  30 30
            /// </summary>
            public string itemPCode { get; set; }
            /// <summary>
            /// 设备通道数据3——托盘码          
            /// </summary>
            public string trayCode { get; set; }
            /// <summary>
            /// 设备通道数据1——包装机号        
            /// </summary>
            public string location { get; set; }
            /// <summary>
            /// 设备通道数据2——产品需求重量:32位整数
            /// </summary>
            public string productWeight { get; set; }
            /// <summary>
            /// 设备通道数据2——托盘重量:32位整数
            /// </summary>
            public string trayCodeWeight { get; set; }
            /// <summary>
            /// 设备通道数据2——单托实际重量:32位整数
            /// </summary>
            public string oneTrayWeight { get; set; }
            /// <summary>
            /// 是否叠底托(1-不叠底托,2-叠底托)
            /// </summary>
            public string palletLayers { get; set; }
            /// <summary>
            /// 设备通道数据1——是否需要叠包:1:叠包,2:不叠包
            /// </summary>
            public int addState { get; set; }
            /// <summary>
            /// 设备通道数据1——袋号(001,002,003…999)
            /// </summary>
            public string packageCode { get; set; }
            public DateTime dateTime { get; set; }
            public string TaskNo { get; set; }
        }
        /// <summary>
        /// 充电任务中间表
        /// </summary>
        public class MarginAGV
        {
            public ObjectId id { get; set; }
            public int agvNo { get; set; }
            public int marginGroup { get; set; }
            public DateTime dateTime { get; set; }
        }
 
        /// <summary>
        /// 报错信息记录表
        /// </summary>
        public class errInfoTable
        {
            public ObjectId _id { get; set; }
            public string taskName { get; set; }
            public string errMsg { get; set; }
            public DateTime dateTime { get; set; }
        }
        /// <summary>
        /// 去除字符串中NULL字符串
        /// </summary>
        internal static string RemoveNull(string str)
        {
            CMMLog.Info($"remove:{str}");
            string result = "";
            string empty = null;
            for(int i = 0; i <= str.Length-1; i++)
            {
                if(str.Substring(i,1) != empty && str.Substring(i, 1) != "" && str.Substring(i, 1) != " " && str.Substring(i,1) != "\0")
                {
                    //CMMLog.Debug($"str.substring:{i},{str.Substring(i, 1)}");
                    result = result + str.Substring(i, 1);
                }
            }
            return result;
        }
 
        /// <summary>
        /// 获取时间戳
        /// </summary>
        /// <param name="DataBitType">数据位数:值:32|64  含义:32位|64位</param>
        /// <param name="TimeType">获取时间类型:值:1|2   含义:1-秒级   2-毫秒级</param>
        /// <param name="TimeUtcType">获取时间Utc类型:值:1|2   含义:1-本地时间   2-Utc时间</param>
        /// <returns></returns>
        public static string GetTimeStamp(int DataBitType, int TimeType, int TimeUtcType)
        {
            string timeStamp = "";
 
            //时间戳打印
            DateTime dateTime = TimeUtcType == 1 ? DateTime.Now : DateTime.UtcNow;//本地时间|Utc时间获取
            TimeSpan ts = dateTime - new DateTime(1970, 1, 1, 0, 0, 0, 0);//时间戳获取
            double tsTime = TimeType == 1 ? ts.TotalSeconds : ts.TotalMilliseconds;//秒级|毫秒级时间获取
 
            string TimeTypeInfo = TimeType == 1 ? "秒级" : "毫秒级";
            string TimeUtcTypeInfo = TimeUtcType == 1 ? "本地时间" : "Utc时间";
            timeStamp = DataBitType == 32 ? Convert.ToInt32(tsTime).ToString() : Convert.ToInt64(tsTime).ToString();
 
            //Console.WriteLine($"时间戳打印:{DataBitType}位,{TimeTypeInfo},{TimeUtcTypeInfo},时间戳:{timeStamp}");
 
            return timeStamp;
        }
 
        public static int GetWeekOfMonth(DateTime daytime)
        {
            int dayInMonth = daytime.Day;
            //本月第一天
            DateTime firstDay = daytime.AddDays(1 - daytime.Day);
            //本月第一天是周几
            int weekday = (int)firstDay.DayOfWeek == 0 ? 7 : (int)firstDay.DayOfWeek;
            //本月第一周有几天
            int firstWeekEndDay = 7 - (weekday - 1);
            //当前日期和第一周之差
            int diffday = dayInMonth - firstWeekEndDay;
 
            diffday = diffday > 0 ? diffday : 1;
            //当前是第几周,如果整除7就减一天 
            int WeekNumInMonth = ((diffday % 7) == 0 ? (diffday / 7 - 1) : (diffday / 7)) + 1 + (dayInMonth > firstWeekEndDay ? 1 : 0);
 
            return WeekNumInMonth;
        }
 
        internal static bool UpdateTaskState(string taskNo, int state)
        {
            var result = false;
            try
            {
                string taskState = state == 3 ? "开始取货" : state == 4 ? "取货完成" : state == 5 ? "开始卸货" : state == 6 ? "卸货完成" : state == 2 ? "完成" : "";
                CMMLog.Info($"SQLServer 更新任务状态:任务号:{taskNo},更改状态:{taskState}");
                if (!string.IsNullOrEmpty(taskState)) result = new SqlHelper<SQL_TN_I_TASK_MST>().ExecuteSql($"update dbo.tn_am_task_mst set CN_S_STATUS='{taskState}' where CN_S_TASK_NO='{taskNo}'");
            }
            catch (Exception ex)
            {
                CMMLog.Error($"SQLServer 更新任务状态异常:{ex.Message}");
            }
 
            return result;
        }
 
 
 
        /// <summary>
        /// SQL-AMS任务主表
        /// </summary>
        [SugarTable("dbo.tn_am_task_mst")]
        public class SQL_TN_I_TASK_MST
        {
            public string CN_S_BATCH_NO { get; set; }
            public int CN_S_ORDER_NO { get; set; }
            public string CN_S_TASK_NO { get; set; }
            public string CN_S_SOURCE_SYS { get; set; }
            public string CN_S_SOURCE_NO { get; set; }
            public string CN_S_PROCESS_CODE { get; set; }
            public string CN_S_TASK_TYPE { get; set; }
            public string CN_S_START_AREA { get; set; }
            public string CN_S_START_AREA_NAME { get; set; }
            public string CN_S_START_BIT { get; set; }
            public int CN_N_START_AGVBIT { get; set; }
            public string CN_S_END_AREA { get; set; }
            public string CN_S_END_AREA_NAME { get; set; }
            public string CN_S_END_BIT { get; set; }
            public int CN_N_END_AGVBIT { get; set; }
            public string CN_S_STATUS { get; set; }
            public string CN_S_BEF_STATUS { get; set; }
            public string CN_S_BEFORE_NO { get; set; }
            public string CN_S_AFTER_NO { get; set; }
            public string CN_T_START_WORKING { get; set; }
            public string CN_T_END_WORKING { get; set; }
            public int CN_N_PRIORITY { get; set; }
            public int CN_N_CUR_STEP { get; set; }
            public string CN_S_CREATOR { get; set; }
            public string CN_S_CREATOR_NAME { get; set; }
            public string CN_T_CREATE { get; set; }
            public string CN_S_MENDER { get; set; }
            public string CN_S_MODIFY_NAME { get; set; }
            public string CN_T_MODIFY { get; set; }
            public string CN_S_TASK_MODEL { get; set; }
            public string CN_S_EXT1 { get; set; }
            public string CN_S_EXT2 { get; set; }
            public string CN_S_EXT3 { get; set; }
            public string CN_N_AGV_NO { get; set; }
            public string CN_S_TRANSPORT_INFO { get; set; }
        }
    }
}