1

czw

2025-06-25 5cb28a17ca74fc0fbb07e25af0c3554951e4c2d9

1

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/AuxAllWCS.json

@@ -9,5 +9,5 @@
  "DevelopVersion": "1.0.2.0",
  "Encode": "Ij/zvOgkqNT5SmHrFKCAVQ==",
  "CreationTime": "0001-01-01 00:00:00",
  "LastWriteTime": "2025-06-23 09:22:04"
  "LastWriteTime": "2025-06-25 10:43:43"
}

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Build/Project/AuxAllWCS.csproj

@@ -6,7 +6,7 @@
    <RootNamespace>GZ.Projects.AuxAllWCS</RootNamespace>
    <AssemblyName>AuxAllWCS</AssemblyName>
    <TargetFrameworkVersion>4.6.1</TargetFrameworkVersion>
    <ProjectGuid>{89297187-7C92-4DF5-A2EC-DEE82376770A}</ProjectGuid>
    <ProjectGuid>{8ec00415-f135-4f69-84fd-926694fa46f1}</ProjectGuid>
  </PropertyGroup>
  <PropertyGroup Condition="'$(Configuration)|$(Platform)' == 'Debug|AnyCPU'">
    <PlatformTarget>AnyCPU</PlatformTarget>
@@ -213,41 +213,6 @@
  </ItemGroup>
  <ItemGroup>
    <None Include="App.config" />
    <None Include="Static\config.json">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </None>
    <None Include="Static\js\app.829e775c.js.map">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </None>
    <None Include="Static\js\chunk-vendors.3e768dfe.js.map">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </None>
  </ItemGroup>
  <ItemGroup>
    <Content Include="Static\css\a.css">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </Content>
    <Content Include="Static\css\app.d545ec97.css">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </Content>
    <Content Include="Static\favicon.ico">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </Content>
    <Content Include="Static\index.html">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </Content>
    <Content Include="Static\js\a.js">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </Content>
    <Content Include="Static\js\app.829e775c.js">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </Content>
    <Content Include="Static\js\chunk-vendors.3e768dfe.js">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </Content>
    <Content Include="Static\W.html">
      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
    </Content>
  </ItemGroup>
  <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
</Project>

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Build/Project/´úÂë/ViewModel.cs

@@ -177,7 +177,7 @@
                                    {  //卸货进行清空，触发扫码
                                        var inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;
                                        string V = inde ? "R05" : "R06";
                                        Conn.默认Redis.SetValue(device.deviceName + "." + V, "true", device.deviceName + "Queue");
                                        Conn.默认Redis.SetValue(device.deviceName + "." + V, "true", device.deviceName + "Queue", false);

                                        TcpServer.TrayIps.Remove(device.deviceNo[inde ? 0 : 1]);
                                    }

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Build/Project/´úÂë/½çÃæʼþ.cs

@@ -52,7 +52,7 @@
            {
                HttpSvcHost = new System.Net.HttpListener();
                HttpSvcHost.AuthenticationSchemes = System.Net.AuthenticationSchemes.Anonymous;
                HttpSvcHost.Prefixes.Add("http://10.221.55.116:8808/");
                HttpSvcHost.Prefixes.Add("http://10.221.55.117:8808/");
                HttpSvcHost.Start();
                HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null);
            }
@@ -230,6 +230,24 @@
                        //    if (di.deviceType == 2 || di.deviceType == 1)
                        //    RunafterMac(di,true);
                        /// TODO  mes ä¸‹å‘。   æ”¹æˆæœºæ¢°è‡‚监控 -  ç›‘控空的还是满的 - è”动mes ä»»åŠ¡ã€‚

                        LogHelper.Info($"设备状态：维希尔1：维希尔抓臂1.State:{Device.维希尔抓臂1.State} ");
                        Device.维希尔抓臂1.ReadPLC("维希尔抓臂1.R50", out object value);
                        LogHelper.Info($"设备状态：维希尔1：维希尔抓臂1.R50:{value?.ToString()} ");

                        LogHelper.Info($"设备状态：维希尔2：维希尔抓臂2.State:{Device.维希尔抓臂2.State} ");
                        Device.维希尔抓臂2.ReadPLC("维希尔抓臂2.R50", out value);
                        LogHelper.Info($"设备状态：维希尔2：维希尔抓臂2.R50:{value?.ToString()} ");

                        LogHelper.Info($"设备状态：捷瞬1：Js捷顺1.State:{Device.Js捷顺1.State} ");
                        Device.Js捷顺1.ReadPLC("Js捷顺1.D1202", out value);
                        LogHelper.Info($"设备状态：捷瞬1 Js捷顺1.D1202:{value?.ToString()} ");

                        LogHelper.Info($"设备状态：捷瞬2：Js捷顺2.State:{Device.Js捷顺2.State} ");
                        Device.Js捷顺2.ReadPLC("Js捷顺2.D1202", out value);
                        LogHelper.Info($"设备状态：捷瞬2 Js捷顺2.D1202:{value?.ToString()} ");


                        #endregion [脚本][20250325085810885][业务逻辑.第三标段.自流转流程]
                    }
                    catch (Exception ex)
@@ -1050,7 +1068,7 @@
                System.Net.HttpListenerResponse response = context.Response;
                switch (request.LocalEndPoint.ToString())
                {
                    case "10.221.55.116:8808":
                    case "10.221.55.117:8808":
                        {
                            using (var reader = new System.IO.StreamReader(request.InputStream, System.Text.Encoding.UTF8))
                            {

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Build/Project/´úÂë/×Ô¶¨ÒåÀà.cs

@@ -563,7 +563,7 @@
        internal static bool CreateTask(string no, string from, string to, string taskType, int pri, List<string> cntrs, string workMode = "AGV", int cntrCount = 1, int startLayer = 1, int endLayer = 1)
        {

            LogHelper.Info($"输送线RGV空托任务 from:{from}>to {to}开始创建>");
            LogHelper.Info($"创建任务 from:{from}>to {to}开始创建>");
            var cntrInfo = string.Join(",", cntrs);
            ILocRepository locc = new LocRepository();
            var fromLoc = locc.FindEntity(x => x.S_LOC_CODE == from);
@@ -571,10 +571,14 @@

            var s = Settings.deviceInfos.Find(x => x.location.Contains(from)) != null;
            var e = Settings.deviceInfos.Find(x => x.location.Contains(to)) != null;
            string t = "F01";
            if (s && !e) t = "A002";
            if (!s && e) t = "A003";
            if (s && e) t = "A004";
            string t = "";
            if (workMode == "AGV")
            {
                t = "F01";
                if (s && !e) t = "A002";
                if (!s && e) t = "A003";
                if (s && e) t = "A004";
            }
            try
            {

@@ -613,7 +617,7 @@
                    locc.Update(endLoc);
                }

                LogHelper.Info($"输送线RGV空托任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功");
                LogHelper.Info($"创建任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功");
                return true;
            }
            catch (Exception ex)
@@ -693,7 +697,7 @@
                        S_DEPART_NAME = "",
                        S_START_LOC = model.startBit,
                        S_END_LOC = model.endBit,
                        S_TYPE = model.reqCode,
                        S_TYPE = model.taskType,
                        S_SRC_NO = "",//
                        N_PRIORITY = -88,
                        S_WORK_MODE = "agv",
@@ -768,13 +772,19 @@
            //if (VERXs.Any())
            foreach (var task in tasks)
            {
                LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ");
                var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC));
                LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} {(sx == null ? "非" : "是")}总装机器人任务");
                if (sx == null)
                {
                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务");
                    //直接生成对应任务。
                    var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS.Split(',').ToList());
                    var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>());

                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务 ç»“果：{res}");
                    if (res)
                    {
                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ä¿®æ”¹æ ‡è¯†");
                        //task.N_PRIORITY = 0;
                        taskservice.dbcontext.Set<TaskEntity>().Attach(task);
                        taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).CurrentValue = 0;
@@ -788,6 +798,8 @@
                    LocRepository locRepository = new LocRepository();
                    //生成跳跃任务。  -- æ‰˜ç›˜è´§ä½è¡¨ã€‚ 
                    var t1s = taskservice.FindList(x => x.S_SRC_NO == task.S_TASK_NO);

                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} æŸ¥æ‰¾æ˜¯å¦æœ‰å·²ç”Ÿæˆä»»åŠ¡ï¼š{t1s != null}");
                    if (t1s.Any())
                    {
                        var t1 = t1s.OrderBy(x => x.T_CREATE).LastOrDefault();
@@ -857,6 +869,7 @@
                    }
                    else
                    {
                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç­›é€‰ç”Ÿæˆç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚");
                        //生成第一段。
                        LocEntity endLoc = null;
                        var di = sx;
@@ -873,7 +886,10 @@
                            }
                            if (endLoc != null)
                            {
                                LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} åˆ›å»ºç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚");
                                var res = TaskProcess.CreateTask("", task.S_START_LOC, endLoc.S_LOC_CODE, task.S_TYPE + "满转", 8, task.S_CNTRS.Split(',').ToList());

                                LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} åˆ›å»ºç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚结果：{res}");
                                if (res)
                                {
                                    task.N_PRIORITY = 0; taskservice.Update(task);

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Devices/PlcConfig

@@ -249,7 +249,7 @@
          "DataType": "System.Boolean",
          "DataValue": "",
          "SetValue": "",
          "Address": "DB20.4..2",
          "Address": "DB20.4.2",
          "AddrType": "",
          "Length": 1,
          "Desc": "",
@@ -657,7 +657,7 @@
          "DataType": "System.Boolean",
          "DataValue": "",
          "SetValue": "",
          "Address": "DB20.4..2",
          "Address": "DB20.4.2",
          "AddrType": "",
          "Length": 1,
          "Desc": "",
@@ -6786,5 +6786,5 @@
    }
  ],
  "CreationTime": "2025-02-26 15:31:23",
  "LastWriteTime": "2025-06-23 08:50:40"
  "LastWriteTime": "2025-06-25 10:38:08"
}

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Devices/É豸ͨÐÅ.json

@@ -2,5 +2,5 @@
  "ProjectSn": "1",
  "DeviceList": [],
  "CreationTime": "2025-02-26 15:31:23",
  "LastWriteTime": "2025-06-23 08:51:04"
  "LastWriteTime": "2025-06-25 10:38:08"
}

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Net/Conn.json

@@ -191,10 +191,10 @@
      "Code": "cddc17eb-398d-4781-b24a-62baec9f680b",
      "Name": "he",
      "Desc": "",
      "IP": "10.221.55.116",
      "IP": "10.221.55.117",
      "Port": "8808",
      "EndPoint": "10.221.55.116:8808",
      "Url": "http://10.221.55.116:8808/",
      "EndPoint": "10.221.55.117:8808",
      "Url": "http://10.221.55.117:8808/",
      "Interface": [
        {
          "ID": "20250323130424925",
@@ -340,5 +340,5 @@
    }
  ],
  "CreationTime": "2025-02-26 15:31:23",
  "LastWriteTime": "2025-06-23 09:22:04"
  "LastWriteTime": "2025-06-25 10:43:43"
}

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/RunTime/Code/×Ô¶¨ÒåÀà.cs

@@ -535,65 +535,69 @@
#region    [自定义类][20250325152141671][TaskProcess]
    internal static bool CreateTask(string no, string from, string to, string taskType, int pri, List<string> cntrs, string workMode = "AGV", int cntrCount = 1, int startLayer = 1, int endLayer = 1)
{
	
            LogHelper.Info($"输送线RGV空托任务 from:{from}>to {to}开始创建>");
     var cntrInfo = string.Join(",", cntrs);
 ILocRepository locc = new LocRepository();
 var fromLoc = locc.FindEntity(x => x.S_LOC_CODE == from);
 var endLoc = locc.FindEntity(x => x.S_LOC_CODE == to);
 
            var s = Settings.deviceInfos.Find(x => x.location.Contains(from)) != null;
            var e = Settings.deviceInfos.Find(x => x.location.Contains(to)) != null;
            string t = "F01";
            if (s && !e) t = "A002";
            if (!s && e) t = "A003";
            if (s && e) t = "A004";
 try
 {

     TaskEntity wmsTask = new TaskEntity()
     {
         S_ID = Guid.NewGuid().ToString(),
        S_STATE = "编辑",
        T_CREATE = DateTime.Now,
        T_MODIFY = DateTime.Now,
    LogHelper.Info($"创建任务 from:{from}>to {to}开始创建>");
    var cntrInfo = string.Join(",", cntrs);
    ILocRepository locc = new LocRepository();
    var fromLoc = locc.FindEntity(x => x.S_LOC_CODE == from);
    var endLoc = locc.FindEntity(x => x.S_LOC_CODE == to);

         S_TASK_NO = GenerateTaskNo(),
         S_START_LAREA = fromLoc.S_AREA_CODE,
         S_END_LAREA = endLoc.S_AREA_CODE,
         S_DEPART_NAME = "",
         S_START_LOC = from,
         S_END_LOC = to,
         S_TYPE = taskType,
         S_SRC_NO = no,//
         N_PRIORITY = pri,
         S_WORK_MODE = workMode,
         S_B_STATE = "未执行",
         S_CNTRS = cntrInfo,
         N_START_LAYER = startLayer,
         N_END_LAYER = endLayer,
         N_CNTR_COUNT = cntrCount,
                    S_INDEX=t,
     };
     ITaskRepository taskserice = new TaskRepository();
     taskserice.Insert(wmsTask);
     
                if (workMode == "AGV")
                {
                    fromLoc.S_LOCK_STATE = "出库锁";
                    endLoc.S_LOCK_STATE = "入库锁";
                    locc.Update(fromLoc);
                    locc.Update(endLoc);
                }
                
                LogHelper.Info($"输送线RGV空托任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功");
                return true;
 }
 catch (Exception ex)
 {
     LogHelper.Error("CreateTask" + ex.Message, ex);
     return false;
 }
    var s = Settings.deviceInfos.Find(x => x.location.Contains(from)) != null;
    var e = Settings.deviceInfos.Find(x => x.location.Contains(to)) != null;
    string t = "";
    if (workMode == "AGV")
    {
        t = "F01";
        if (s && !e) t = "A002";
        if (!s && e) t = "A003";
        if (s && e) t = "A004";
    }
    try
    {

        TaskEntity wmsTask = new TaskEntity()
        {
            S_ID = Guid.NewGuid().ToString(),
            S_STATE = "编辑",
            T_CREATE = DateTime.Now,
            T_MODIFY = DateTime.Now,

            S_TASK_NO = GenerateTaskNo(),
            S_START_LAREA = fromLoc.S_AREA_CODE,
            S_END_LAREA = endLoc.S_AREA_CODE,
            S_DEPART_NAME = "",
            S_START_LOC = from,
            S_END_LOC = to,
            S_TYPE = taskType,
            S_SRC_NO = no,//
            N_PRIORITY = pri,
            S_WORK_MODE = workMode,
            S_B_STATE = "未执行",
            S_CNTRS = cntrInfo,
            N_START_LAYER = startLayer,
            N_END_LAYER = endLayer,
            N_CNTR_COUNT = cntrCount,
            S_INDEX = t,
        };
        ITaskRepository taskserice = new TaskRepository();
        taskserice.Insert(wmsTask);

        if (workMode == "AGV")
        {
            fromLoc.S_LOCK_STATE = "出库锁";
            endLoc.S_LOCK_STATE = "入库锁";
            locc.Update(fromLoc);
            locc.Update(endLoc);
        }

        LogHelper.Info($"创建任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功");
        return true;
    }
    catch (Exception ex)
    {
        LogHelper.Error("CreateTask" + ex.Message, ex);
        return false;
    }
}


@@ -666,7 +670,7 @@
                        S_DEPART_NAME = "",
                        S_START_LOC = model.startBit,
                        S_END_LOC = model.endBit,
                        S_TYPE = model.reqCode,
                        S_TYPE = model.taskType,
                        S_SRC_NO = "",//
                        N_PRIORITY = -88,
                        S_WORK_MODE = "agv",
@@ -736,127 +740,139 @@
        {
            ///1.
            TaskRepository taskservice = new TaskRepository();
            var tasks = taskservice.FindList(x =>( x.S_B_STATE == "MES"|| x.S_B_STATE == "People") && x.N_PRIORITY == -88);
            var VERXs = Settings.deviceInfos?.FindAll(x => x.deviceType==2);
            //if (VERXs.Any())
                foreach (var task in tasks)
                {
                    var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC));
                    if (sx == null)
                    {
                        //直接生成对应任务。
                        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS.Split(',').ToList());
                        if (res)
                        {
                            //task.N_PRIORITY = 0;
                            taskservice.dbcontext.Set<TaskEntity>().Attach(task);
                            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).CurrentValue = 0;
                            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).IsModified = true;
                            taskservice.dbcontext.SaveChanges();
                        }
                    }
                    else
                    {
                        var sindex = sx.location.ToList().IndexOf(task.S_END_LOC);
                        LocRepository locRepository = new LocRepository();
                        //生成跳跃任务。  -- æ‰˜ç›˜è´§ä½è¡¨ã€‚ 
                        var t1s = taskservice.FindList(x => x.S_SRC_NO == task.S_TASK_NO);
                        if (t1s.Any())
                        {
                            var t1 = t1s.OrderBy(x => x.T_CREATE).LastOrDefault();
                            if (t1.S_END_LOC == task.S_END_LOC)
                            {
                                task.N_PRIORITY = 0;
                                task.S_B_STATE = "MES_完成";
                                taskservice.Update(task);
                                continue;
                            }
                            if (t1.S_B_STATE == "完成")
                            {
                                //1.终点是否有托盘。 ä¾æ®æ˜¯ç»ˆç‚¹çš„任务是 ä½œä¸ºç»ˆç‚¹ï¼Œè¿˜æ˜¯èµ·ç‚¹ã€‚
                                //var ec = taskservice.FindList(x => (x.S_START_LOC == task.S_START_LOC || x.S_END_LOC == task.S_END_LOC) /*&& DateTime.Now.Subtract(x.T_CREATE).TotalHours < 5*/).OrderByDescending(x => x.T_CREATE).FirstOrDefault();//($"select top 1 * from TN_TASK WHERE S_START_LOC='{task.S_END_LOC}' OR S_END_LOC='{task.S_END_LOC}' ORDER BY T_CREATE DESC");
                                //var ec = taskservice.FindList(x => x.S_START_LOC == task.S_START_LOC && x.S_END_LOC == task.S_START_LOC, new Common.Data.Pagination
        //                        {
        //                            page = 1,
        //                            sidx = "T_CREATE",
        //                            sord = "desc",
        //                            rows = 1
        //                        }).FirstOrDefault();
                                TaskEntity ec = null;
                                var dev = Conn.默认Redis.GetValue(sx.deviceName + "." + (sindex == 0 ? "D1224" : "D1225"));
                                if (dev?.Trim() == "1")
                                    ec = taskservice.FindList(x =>x.S_END_LOC == task.S_END_LOC&&x.S_B_STATE=="完成", new Common.Data.Pagination
                                    {
                                        page = 1,
                                        sidx = "T_CREATE",
                                        sord = "desc",
                                        rows = 1
                                    }).FirstOrDefault();
                                if (t1.S_START_LOC == task.S_START_LOC && ec != null)//!= task.S_END_LOC)
                                {
                                    //第二段。
                                    LocEntity endLoc = null;
                                    var di = sx;
                                    if (di != null)
                                    {
                                        foreach (var ssloc in di.deviceNo)
                                        {
                                            var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);
                                            if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == "无")
                                            {
                                                endLoc = endloc;
                                                break;
                                            }
                                        }
                                        if (endLoc != null)
                                        {
                                            var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_END_LOC, endLoc.S_LOC_CODE, task.S_TYPE + "下空", 7, ec.S_CNTRS.Split(',').ToList());
                                            if (res)
                                            {
                                                task.N_PRIORITY = 0; taskservice.Update(task);
                                            }
                                        }
                                    }
                                }
                                else
                                {
                                    var res = TaskProcess.CreateTask(task.S_TASK_NO, t1.S_END_LOC, task.S_END_LOC, task.S_TYPE + "补满", 6, task.S_CNTRS.Split(',').ToList());
                                    if (res)
                                    {
                                        task.N_PRIORITY = 0; taskservice.Update(task);
                                    }
                                }
                            }
                        }
                        else
                        {
                            //生成第一段。
                            LocEntity endLoc = null;
                            var di = sx;
                            if (di != null)
                            {
                                foreach (var ssloc in di.deviceNo)
                                {
                                    var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);
                                    if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == "无")
                                    {
                                        endLoc = endloc;
                                        break;
                                    }
                                }
                                if (endLoc != null)
                                {
                                    var res = TaskProcess.CreateTask("", task.S_START_LOC, endLoc.S_LOC_CODE, task.S_TYPE + "满转", 8, task.S_CNTRS.Split(',').ToList());
                                    if (res)
                                    {
                                        task.N_PRIORITY = 0; taskservice.Update(task);
                                    }
                                }
                            }
                        }
var tasks = taskservice.FindList(x => (x.S_B_STATE == "MES" || x.S_B_STATE == "People") && x.N_PRIORITY == -88);
var VERXs = Settings.deviceInfos?.FindAll(x => x.deviceType == 2);
//if (VERXs.Any())
foreach (var task in tasks)
{
    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ");
    var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC));
    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} {(sx == null ? "非" : "是")}总装机器人任务");
    if (sx == null)
    {
        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务");
        //直接生成对应任务。
        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>());

        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务 ç»“果：{res}");
        if (res)
        {
            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ä¿®æ”¹æ ‡è¯†");
            //task.N_PRIORITY = 0;
            taskservice.dbcontext.Set<TaskEntity>().Attach(task);
            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).CurrentValue = 0;
            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).IsModified = true;
            taskservice.dbcontext.SaveChanges();
        }
    }
    else
    {
        var sindex = sx.location.ToList().IndexOf(task.S_END_LOC);
        LocRepository locRepository = new LocRepository();
        //生成跳跃任务。  -- æ‰˜ç›˜è´§ä½è¡¨ã€‚ 
        var t1s = taskservice.FindList(x => x.S_SRC_NO == task.S_TASK_NO);

        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} æŸ¥æ‰¾æ˜¯å¦æœ‰å·²ç”Ÿæˆä»»åŠ¡ï¼š{t1s != null}");
        if (t1s.Any())
        {
            var t1 = t1s.OrderBy(x => x.T_CREATE).LastOrDefault();
            if (t1.S_END_LOC == task.S_END_LOC)
            {
                task.N_PRIORITY = 0;
                task.S_B_STATE = "MES_完成";
                taskservice.Update(task);
                continue;
            }
            if (t1.S_B_STATE == "完成")
            {
                //1.终点是否有托盘。 ä¾æ®æ˜¯ç»ˆç‚¹çš„任务是 ä½œä¸ºç»ˆç‚¹ï¼Œè¿˜æ˜¯èµ·ç‚¹ã€‚
                //var ec = taskservice.FindList(x => (x.S_START_LOC == task.S_START_LOC || x.S_END_LOC == task.S_END_LOC) /*&& DateTime.Now.Subtract(x.T_CREATE).TotalHours < 5*/).OrderByDescending(x => x.T_CREATE).FirstOrDefault();//($"select top 1 * from TN_TASK WHERE S_START_LOC='{task.S_END_LOC}' OR S_END_LOC='{task.S_END_LOC}' ORDER BY T_CREATE DESC");
                //var ec = taskservice.FindList(x => x.S_START_LOC == task.S_START_LOC && x.S_END_LOC == task.S_START_LOC, new Common.Data.Pagination
                //                        {
                //                            page = 1,
                //                            sidx = "T_CREATE",
                //                            sord = "desc",
                //                            rows = 1
                //                        }).FirstOrDefault();
                TaskEntity ec = null;
                var dev = Conn.默认Redis.GetValue(sx.deviceName + "." + (sindex == 0 ? "D1224" : "D1225"));
                if (dev?.Trim() == "1")
                    ec = taskservice.FindList(x => x.S_END_LOC == task.S_END_LOC && x.S_B_STATE == "完成", new Common.Data.Pagination
                    {
                        page = 1,
                        sidx = "T_CREATE",
                        sord = "desc",
                        rows = 1
                    }).FirstOrDefault();
                if (t1.S_START_LOC == task.S_START_LOC && ec != null)//!= task.S_END_LOC)
                {
                    //第二段。
                    LocEntity endLoc = null;
                    var di = sx;
                    if (di != null)
                    {
                        foreach (var ssloc in di.deviceNo)
                        {
                            var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);
                            if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == "无")
                            {
                                endLoc = endloc;
                                break;
                            }
                        }
                        if (endLoc != null)
                        {
                            var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_END_LOC, endLoc.S_LOC_CODE, task.S_TYPE + "下空", 7, ec.S_CNTRS.Split(',').ToList());
                            if (res)
                            {
                                task.N_PRIORITY = 0; taskservice.Update(task);
                            }
                        }
                    }
                }
                else
                {
                    var res = TaskProcess.CreateTask(task.S_TASK_NO, t1.S_END_LOC, task.S_END_LOC, task.S_TYPE + "补满", 6, task.S_CNTRS.Split(',').ToList());
                    if (res)
                    {
                        task.N_PRIORITY = 0; taskservice.Update(task);
                    }
                }
            }
        }
        else
        {
            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç­›é€‰ç”Ÿæˆç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚");
            //生成第一段。
            LocEntity endLoc = null;
            var di = sx;
            if (di != null)
            {
                foreach (var ssloc in di.deviceNo)
                {
                    var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);
                    if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == "无")
                    {
                        endLoc = endloc;
                        break;
                    }
                }
                if (endLoc != null)
                {
                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} åˆ›å»ºç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚");
                    var res = TaskProcess.CreateTask("", task.S_START_LOC, endLoc.S_LOC_CODE, task.S_TYPE + "满转", 8, task.S_CNTRS.Split(',').ToList());

                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} åˆ›å»ºç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚结果：{res}");
                    if (res)
                    {
                        task.N_PRIORITY = 0; taskservice.Update(task);
                    }
                }
            }
        }

    }
}
            //var VERX = Settings.deviceInfos?.FindAll(x => x.deviceName.Contains("捷瞬抓臂"));
            //if ()
            ///2  çœ‹ç¼“存区。 æ²¡æ»¡çš„。

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Scripts/Custom.json

@@ -120,8 +120,8 @@
      "Type": "MethodCode",
      "Level": "Item",
      "Statement": "public void OperateHKTaskStatus(System.Object param1)",
      "EditCode": "HaiKangOrderInfo model = (HaiKangOrderInfo)param1;\r\n            if (string.IsNullOrEmpty(model.taskCode))\r\n                return;\r\n            // æŸ¥è¯¢ä»»åŠ¡ï¼šæ ¹æ®ä»»åŠ¡å·\r\n            //var wcsTask = WCSHelper.GetTask(model.taskCode);\r\n            ITaskRepository MainMissionService = new TaskRepository();\r\n            var wcsTask = MainMissionService.FindEntity(x => model.taskCode == x.S_TASK_NO);\r\n            if (wcsTask != null)\r\n            {\r\n                if (!string.IsNullOrWhiteSpace(model.method))\r\n                {\r\n                    ILocRepository locrep = new LocRepository();\r\n                    var startloc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                    var endLoc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_END_LOC);\r\n\r\n                    List<string> cntrs = wcsTask.S_CNTRS.Split(',').ToList();\r\n                    bool bobe = false;\r\n                    switch (model.method)\r\n                    {\r\n                        case \"start\":\r\n                            LogHelper.Info($\"海康车任务状态变更为执行，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            if (wcsTask.S_B_STATE.Trim() == \"已推送\")\r\n                            {\r\n                                wcsTask.S_B_STATE = \"执行中\";\r\n                                wcsTask.T_START_TIME = DateTime.Now;\r\n                                MainMissionService.Update(wcsTask);\r\n                                bobe = true;\r\n                            }\r\n                            break;\r\n                        case \"outbin\":\r\n                            LogHelper.Info($\"海康车任务状态变更为取货完成，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"取货完成\";\r\n\r\n                            startloc.N_CURRENT_NUM = 0;\r\n                            startloc.S_LOCK_STATE = \"无\";\r\n                            startloc.T_MODIFY = DateTime.Now;\r\n                            //ILocContainerRepository locContainerRepository = new LocContainerRepository();\r\n                            ////var cnr = locContainerRepository.FindList(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                            //locContainerRepository.Delete(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                            MainMissionService.Update(wcsTask);\r\n                            locrep.Update(startloc);\r\n\r\n                            bobe = true;\r\n                            var device = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_START_LOC));\r\n                            if (device != null)\r\n                            {\r\n                                if (device.deviceType == 1)\r\n                                {\r\n                                    if (device.deviceName.Contains(\"维希尔抓臂\"))\r\n                                    {  //卸货进行清空，触发扫码\r\n                                       var inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;\r\n                                       string V = inde ? \"R05\" : \"R06\";\r\n                                       Conn.默认Redis.SetValue(device.deviceName + \".\" + V, \"true\", device.deviceName + \"Queue\");\r\n                                       \r\n                                       TcpServer.TrayIps.Remove(device.deviceNo[inde ? 0 : 1]);\r\n                                    }\r\n                                }\r\n                                else if(device.deviceType == 2){\r\n\t\t\t\t\t\t\t\t\tvar inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;\r\n\t\t\t\t\t\t\t\t\t string V = inde? \"D1224\" : \"D1225\";\r\n\t\t\t\t\t\t\t\t\t Conn.默认Redis.SetValue(device.deviceName + \".\" + V, \"0\", device.deviceName + \"Queue\");\r\n                                }\r\n                            }\r\n                            //LocationHelper.UnLockLoc(wcsTask.S_START_LOC);\r\n                            break;\r\n                        case \"end\":\r\n                            LogHelper.Info($\"海康车任务状态变更为完成，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"完成\";\r\n                            wcsTask.T_END_TIME = DateTime.Now;\r\n\r\n                            bobe = true;\r\n                            //ILocContainerRepository locContainerRepository2 = new LocContainerRepository();\r\n                            //List<LocContainerEntity> llls = new List<LocContainerEntity>();\r\n                            //foreach (var c in cntrs)\r\n                            //{\r\n                            //    var action = new LocContainerEntity()\r\n                            //    {\r\n                            //        S_ID = Guid.NewGuid().ToString(),\r\n                            //        S_STATE = \"编辑\",\r\n                            //        T_CREATE = DateTime.Now,\r\n                            //        T_MODIFY = DateTime.Now,\r\n\r\n                            //        S_LOC_CODE = endLoc.S_LOC_CODE,\r\n                            //        S_CNTR_CODE = c,\r\n                            //        S_TYPE = \"\",\r\n                            //    };\r\n                            //    llls.Add(action);\r\n                            //}\r\n\r\n                            endLoc.S_LOCK_STATE = \"无\";\r\n                            endLoc.N_CURRENT_NUM = 1;\r\n                            endLoc.T_MODIFY = DateTime.Now;\r\n                            MainMissionService.Update(wcsTask);\r\n                            if(Settings.deviceInfos.Find(x=>x.deviceType==2 && (/*x.location.Contains(wcsTask.S_END_LOC)||*/x.deviceNo.Contains(wcsTask.S_END_LOC)))!=null)\r\n                                locrep.Update(endLoc);\r\n                            //locContainerRepository2.Insert(llls);\r\n\r\n                            var device2 = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_END_LOC));\r\n                            if (device2 != null)\r\n                            {\r\n                                if (device2.deviceType == 1)\r\n                                {\r\n                                    if (device2.deviceName.Contains(\"维希尔抓臂\"))\r\n                                    {\r\n                                        //string V = device2.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0 ? \"R10\" : \"R11\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"true\", device2.deviceName + \"Queue\");\r\n                                        //卸货再写托盘取走。 ç„¶åŽè§¦å‘扫码进行校验。 \r\n                                        var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;\r\n                                        //string V = inde ? \"R05\" : \"R06\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"true\", device2.deviceName + \"Queue\");\r\n                                        string V2 = inde ? \"R10_LAST\" : \"R11_LAST\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V2, \"true\", device2.deviceName + \"Queue\");\r\n                                        \r\n                                        GZ.Modular.Redis.RedisHelper.Add(device2.deviceName + \".\" + V2, \"true\", out string msg1);\r\n                                        TcpServer.TrayIps.Remove(device2.deviceNo[inde ? 0 : 1]);\r\n                                    }\r\n                                }\r\n                                else if (device2.deviceType == 2)\r\n                                    if (device2.deviceName.Contains(\"Js捷顺\"))\r\n                                    {\r\n                                        var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;\r\n                                        string V = inde? \"D1224\" : \"D1225\";\r\n                                        Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"1\", device2.deviceName + \"Queue\");\r\n\r\n                                        var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/202\", JsonConvert.SerializeObject(new\r\n                                        {\r\n                                            sceneType = 3,\r\n                                            cntrCode = cntrs.FirstOrDefault()\r\n                                        }));\r\n                                        //if (device2.deviceName.Contains(\"1\"))\r\n                                        //{\r\n                                        //    if (inde) tag.Js1.D1224 = 1;\r\n                                        //    else tag.Js1.D1225 = 1;\r\n                                        //}else\r\n                                        //{\r\n                                        //    if (inde) tag.Js2.D1224 = 1;\r\n                                        //    else tag.Js2.D1225 = 1;\r\n                                        //}\r\n                                    }\r\n                            }\r\n\r\n                            //LocationMethod.JudgeLocation(wcsTask);\r\n                            break;\r\n                        case \"cancel\":\r\n                            LogHelper.Info($\"海康车任务状态变更为取消，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"取消\";\r\n                            //startloc.S_LOCK_STATE = \"无\";\r\n                            //endLoc.S_LOCK_STATE = \"无\";\r\n                            MainMissionService.Update(wcsTask);\r\n                            TaskActRepository taskActRepository = new TaskActRepository();\r\n                            var tare = taskActRepository.FindList(x => x.S_TASK_NO == wcsTask.S_TASK_NO);\r\n                            if (tare.Any())\r\n                            {\r\n                                if(tare.Find(x=>x.S_ACTION_CODE==\"outbin\")==null)\r\n                                {\r\n                                    startloc.S_LOCK_STATE = \"无\";\r\n                                    endLoc.S_LOCK_STATE = \"无\";\r\n                                    locrep.Update(startloc);\r\n                                    locrep.Update(endLoc);\r\n                                }else if (tare.Find(x => x.S_ACTION_CODE == \"end\") == null)\r\n                                {\r\n                                    endLoc.S_LOCK_STATE = \"无\";\r\n                                    locrep.Update(endLoc);\r\n                                }\r\n                            }\r\n\r\n                            //locrep.Update(startloc);\r\n                            //locrep.Update(endLoc);\r\n                            //TaskProcess.OperateStatus(wcsTask, 7);\r\n                            //WCSHelper.Fail(wcsTask);\r\n                            break;\r\n                        case \"apply\":\r\n                            // åˆ¤æ–­è¯¥ä»»åŠ¡çš„接驳位是否有其他入库或出库任务，如果有，则在等位等待，如果没有，则入\r\n                            TaskisOk(wcsTask);\r\n                            break;\r\n                    }\r\n\r\n                    if (!string.IsNullOrEmpty(wcsTask.S_SRC_NO))\r\n                    {\r\n                        var mestask = MainMissionService.FindEntity(x => x.S_TASK_NO == wcsTask.S_SRC_NO);\r\n                        if (mestask!=null&&bobe)\r\n                        {\r\n                            if ( model.method != \"end\")\r\n                            {\r\n                            \tif (mestask.S_START_LOC == wcsTask.S_START_LOC&&mestask.S_B_STATE == \"MES\")\r\n\t                                Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n\t                                {\r\n\t                                    reqCode = wcsTask.S_SRC_NO,\r\n\t                                    model.method\r\n\t                                }));\r\n                            }\r\n                            else\r\n                            {\r\n                                if (mestask.S_END_LOC != wcsTask.S_END_LOC)\r\n                                {\r\n                                    LogHelper.Info($\"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸€é˜¶æ®µå®Œæˆï¼Œé‡ç½®è¿›è¡ŒäºŒé˜¶æ®µã€‚\");\r\n                                    mestask.N_PRIORITY = -88;\r\n                                    MainMissionService.Update(mestask);\r\n                                }\r\n                                else if(mestask.S_B_STATE == \"MES\")\r\n                                {\r\n                                    var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n                                    {\r\n                                        reqCode = wcsTask.S_SRC_NO,\r\n                                        model.method\r\n                                    }));\r\n                                }\r\n                            }\r\n\r\n                        }else if(mestask!=null && model.method== \"cancel\")\r\n                        {\r\n                        \t if(mestask.S_B_STATE == \"MES\")\r\n\t                           Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n\t                            {\r\n\t                                reqCode = wcsTask.S_SRC_NO,\r\n\t                                model.method\r\n\t                            })); \r\n                            LogHelper.Info($\"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸€é˜¶æ®µå–消，重置点，线程处理。\");\r\n                            mestask.N_PRIORITY = -1;\r\n                            mestask.S_B_STATE = \"MES_取消\";\r\n                            MainMissionService.Update(mestask);\r\n                        }\r\n                    }\r\n                    TaskProcess.AddActionRecord(model.taskCode, model.method, model.eqpCode, model.data,wcsTask.S_START_LOC,wcsTask.S_END_LOC);\r\n                    //调用第三方接口（如果有）TaskProcess.ReportStatus\r\n                }\r\n                else\r\n                {\r\n                    // æš‚时设定为0\r\n                    wcsTask.S_B_STATE = \"上报状态空\";\r\n                    //安全请求等\r\n                    //TaskProcess.OperateReq(model.taskCode, wcsTask.N_B_STATE, model.eqpCode, model.data);\r\n                }\r\n            }\r\n            else\r\n            {\r\n                LogHelper.Info($\"当前任务号任务不存在{model.taskCode}\", \"agv杭叉交互日志\");\r\n            }",
      "Code": "public void OperateHKTaskStatus(System.Object param1)\r\n{HaiKangOrderInfo model = (HaiKangOrderInfo)param1;\r\n            if (string.IsNullOrEmpty(model.taskCode))\r\n                return;\r\n            // æŸ¥è¯¢ä»»åŠ¡ï¼šæ ¹æ®ä»»åŠ¡å·\r\n            //var wcsTask = WCSHelper.GetTask(model.taskCode);\r\n            ITaskRepository MainMissionService = new TaskRepository();\r\n            var wcsTask = MainMissionService.FindEntity(x => model.taskCode == x.S_TASK_NO);\r\n            if (wcsTask != null)\r\n            {\r\n                if (!string.IsNullOrWhiteSpace(model.method))\r\n                {\r\n                    ILocRepository locrep = new LocRepository();\r\n                    var startloc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                    var endLoc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_END_LOC);\r\n\r\n                    List<string> cntrs = wcsTask.S_CNTRS.Split(',').ToList();\r\n                    bool bobe = false;\r\n                    switch (model.method)\r\n                    {\r\n                        case \"start\":\r\n                            LogHelper.Info($\"海康车任务状态变更为执行，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            if (wcsTask.S_B_STATE.Trim() == \"已推送\")\r\n                            {\r\n                                wcsTask.S_B_STATE = \"执行中\";\r\n                                wcsTask.T_START_TIME = DateTime.Now;\r\n                                MainMissionService.Update(wcsTask);\r\n                                bobe = true;\r\n                            }\r\n                            break;\r\n                        case \"outbin\":\r\n                            LogHelper.Info($\"海康车任务状态变更为取货完成，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"取货完成\";\r\n\r\n                            startloc.N_CURRENT_NUM = 0;\r\n                            startloc.S_LOCK_STATE = \"无\";\r\n                            startloc.T_MODIFY = DateTime.Now;\r\n                            //ILocContainerRepository locContainerRepository = new LocContainerRepository();\r\n                            ////var cnr = locContainerRepository.FindList(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                            //locContainerRepository.Delete(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                            MainMissionService.Update(wcsTask);\r\n                            locrep.Update(startloc);\r\n\r\n                            bobe = true;\r\n                            var device = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_START_LOC));\r\n                            if (device != null)\r\n                            {\r\n                                if (device.deviceType == 1)\r\n                                {\r\n                                    if (device.deviceName.Contains(\"维希尔抓臂\"))\r\n                                    {  //卸货进行清空，触发扫码\r\n                                       var inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;\r\n                                       string V = inde ? \"R05\" : \"R06\";\r\n                                       Conn.默认Redis.SetValue(device.deviceName + \".\" + V, \"true\", device.deviceName + \"Queue\");\r\n                                       \r\n                                       TcpServer.TrayIps.Remove(device.deviceNo[inde ? 0 : 1]);\r\n                                    }\r\n                                }\r\n                                else if(device.deviceType == 2){\r\n\t\t\t\t\t\t\t\t\tvar inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;\r\n\t\t\t\t\t\t\t\t\t string V = inde? \"D1224\" : \"D1225\";\r\n\t\t\t\t\t\t\t\t\t Conn.默认Redis.SetValue(device.deviceName + \".\" + V, \"0\", device.deviceName + \"Queue\");\r\n                                }\r\n                            }\r\n                            //LocationHelper.UnLockLoc(wcsTask.S_START_LOC);\r\n                            break;\r\n                        case \"end\":\r\n                            LogHelper.Info($\"海康车任务状态变更为完成，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"完成\";\r\n                            wcsTask.T_END_TIME = DateTime.Now;\r\n\r\n                            bobe = true;\r\n                            //ILocContainerRepository locContainerRepository2 = new LocContainerRepository();\r\n                            //List<LocContainerEntity> llls = new List<LocContainerEntity>();\r\n                            //foreach (var c in cntrs)\r\n                            //{\r\n                            //    var action = new LocContainerEntity()\r\n                            //    {\r\n                            //        S_ID = Guid.NewGuid().ToString(),\r\n                            //        S_STATE = \"编辑\",\r\n                            //        T_CREATE = DateTime.Now,\r\n                            //        T_MODIFY = DateTime.Now,\r\n\r\n                            //        S_LOC_CODE = endLoc.S_LOC_CODE,\r\n                            //        S_CNTR_CODE = c,\r\n                            //        S_TYPE = \"\",\r\n                            //    };\r\n                            //    llls.Add(action);\r\n                            //}\r\n\r\n                            endLoc.S_LOCK_STATE = \"无\";\r\n                            endLoc.N_CURRENT_NUM = 1;\r\n                            endLoc.T_MODIFY = DateTime.Now;\r\n                            MainMissionService.Update(wcsTask);\r\n                            if(Settings.deviceInfos.Find(x=>x.deviceType==2 && (/*x.location.Contains(wcsTask.S_END_LOC)||*/x.deviceNo.Contains(wcsTask.S_END_LOC)))!=null)\r\n                                locrep.Update(endLoc);\r\n                            //locContainerRepository2.Insert(llls);\r\n\r\n                            var device2 = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_END_LOC));\r\n                            if (device2 != null)\r\n                            {\r\n                                if (device2.deviceType == 1)\r\n                                {\r\n                                    if (device2.deviceName.Contains(\"维希尔抓臂\"))\r\n                                    {\r\n                                        //string V = device2.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0 ? \"R10\" : \"R11\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"true\", device2.deviceName + \"Queue\");\r\n                                        //卸货再写托盘取走。 ç„¶åŽè§¦å‘扫码进行校验。 \r\n                                        var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;\r\n                                        //string V = inde ? \"R05\" : \"R06\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"true\", device2.deviceName + \"Queue\");\r\n                                        string V2 = inde ? \"R10_LAST\" : \"R11_LAST\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V2, \"true\", device2.deviceName + \"Queue\");\r\n                                        \r\n                                        GZ.Modular.Redis.RedisHelper.Add(device2.deviceName + \".\" + V2, \"true\", out string msg1);\r\n                                        TcpServer.TrayIps.Remove(device2.deviceNo[inde ? 0 : 1]);\r\n                                    }\r\n                                }\r\n                                else if (device2.deviceType == 2)\r\n                                    if (device2.deviceName.Contains(\"Js捷顺\"))\r\n                                    {\r\n                                        var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;\r\n                                        string V = inde? \"D1224\" : \"D1225\";\r\n                                        Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"1\", device2.deviceName + \"Queue\");\r\n\r\n                                        var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/202\", JsonConvert.SerializeObject(new\r\n                                        {\r\n                                            sceneType = 3,\r\n                                            cntrCode = cntrs.FirstOrDefault()\r\n                                        }));\r\n                                        //if (device2.deviceName.Contains(\"1\"))\r\n                                        //{\r\n                                        //    if (inde) tag.Js1.D1224 = 1;\r\n                                        //    else tag.Js1.D1225 = 1;\r\n                                        //}else\r\n                                        //{\r\n                                        //    if (inde) tag.Js2.D1224 = 1;\r\n                                        //    else tag.Js2.D1225 = 1;\r\n                                        //}\r\n                                    }\r\n                            }\r\n\r\n                            //LocationMethod.JudgeLocation(wcsTask);\r\n                            break;\r\n                        case \"cancel\":\r\n                            LogHelper.Info($\"海康车任务状态变更为取消，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"取消\";\r\n                            //startloc.S_LOCK_STATE = \"无\";\r\n                            //endLoc.S_LOCK_STATE = \"无\";\r\n                            MainMissionService.Update(wcsTask);\r\n                            TaskActRepository taskActRepository = new TaskActRepository();\r\n                            var tare = taskActRepository.FindList(x => x.S_TASK_NO == wcsTask.S_TASK_NO);\r\n                            if (tare.Any())\r\n                            {\r\n                                if(tare.Find(x=>x.S_ACTION_CODE==\"outbin\")==null)\r\n                                {\r\n                                    startloc.S_LOCK_STATE = \"无\";\r\n                                    endLoc.S_LOCK_STATE = \"无\";\r\n                                    locrep.Update(startloc);\r\n                                    locrep.Update(endLoc);\r\n                                }else if (tare.Find(x => x.S_ACTION_CODE == \"end\") == null)\r\n                                {\r\n                                    endLoc.S_LOCK_STATE = \"无\";\r\n                                    locrep.Update(endLoc);\r\n                                }\r\n                            }\r\n\r\n                            //locrep.Update(startloc);\r\n                            //locrep.Update(endLoc);\r\n                            //TaskProcess.OperateStatus(wcsTask, 7);\r\n                            //WCSHelper.Fail(wcsTask);\r\n                            break;\r\n                        case \"apply\":\r\n                            // åˆ¤æ–­è¯¥ä»»åŠ¡çš„接驳位是否有其他入库或出库任务，如果有，则在等位等待，如果没有，则入\r\n                            TaskisOk(wcsTask);\r\n                            break;\r\n                    }\r\n\r\n                    if (!string.IsNullOrEmpty(wcsTask.S_SRC_NO))\r\n                    {\r\n                        var mestask = MainMissionService.FindEntity(x => x.S_TASK_NO == wcsTask.S_SRC_NO);\r\n                        if (mestask!=null&&bobe)\r\n                        {\r\n                            if ( model.method != \"end\")\r\n                            {\r\n                            \tif (mestask.S_START_LOC == wcsTask.S_START_LOC&&mestask.S_B_STATE == \"MES\")\r\n\t                                Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n\t                                {\r\n\t                                    reqCode = wcsTask.S_SRC_NO,\r\n\t                                    model.method\r\n\t                                }));\r\n                            }\r\n                            else\r\n                            {\r\n                                if (mestask.S_END_LOC != wcsTask.S_END_LOC)\r\n                                {\r\n                                    LogHelper.Info($\"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸€é˜¶æ®µå®Œæˆï¼Œé‡ç½®è¿›è¡ŒäºŒé˜¶æ®µã€‚\");\r\n                                    mestask.N_PRIORITY = -88;\r\n                                    MainMissionService.Update(mestask);\r\n                                }\r\n                                else if(mestask.S_B_STATE == \"MES\")\r\n                                {\r\n                                    var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n                                    {\r\n                                        reqCode = wcsTask.S_SRC_NO,\r\n                                        model.method\r\n                                    }));\r\n                                }\r\n                            }\r\n\r\n                        }else if(mestask!=null && model.method== \"cancel\")\r\n                        {\r\n                        \t if(mestask.S_B_STATE == \"MES\")\r\n\t                           Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n\t                            {\r\n\t                                reqCode = wcsTask.S_SRC_NO,\r\n\t                                model.method\r\n\t                            })); \r\n                            LogHelper.Info($\"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸€é˜¶æ®µå–消，重置点，线程处理。\");\r\n                            mestask.N_PRIORITY = -1;\r\n                            mestask.S_B_STATE = \"MES_取消\";\r\n                            MainMissionService.Update(mestask);\r\n                        }\r\n                    }\r\n                    TaskProcess.AddActionRecord(model.taskCode, model.method, model.eqpCode, model.data,wcsTask.S_START_LOC,wcsTask.S_END_LOC);\r\n                    //调用第三方接口（如果有）TaskProcess.ReportStatus\r\n                }\r\n                else\r\n                {\r\n                    // æš‚时设定为0\r\n                    wcsTask.S_B_STATE = \"上报状态空\";\r\n                    //安全请求等\r\n                    //TaskProcess.OperateReq(model.taskCode, wcsTask.N_B_STATE, model.eqpCode, model.data);\r\n                }\r\n            }\r\n            else\r\n            {\r\n                LogHelper.Info($\"当前任务号任务不存在{model.taskCode}\", \"agv杭叉交互日志\");\r\n            }\r\n}",
      "EditCode": "HaiKangOrderInfo model = (HaiKangOrderInfo)param1;\r\n            if (string.IsNullOrEmpty(model.taskCode))\r\n                return;\r\n            // æŸ¥è¯¢ä»»åŠ¡ï¼šæ ¹æ®ä»»åŠ¡å·\r\n            //var wcsTask = WCSHelper.GetTask(model.taskCode);\r\n            ITaskRepository MainMissionService = new TaskRepository();\r\n            var wcsTask = MainMissionService.FindEntity(x => model.taskCode == x.S_TASK_NO);\r\n            if (wcsTask != null)\r\n            {\r\n                if (!string.IsNullOrWhiteSpace(model.method))\r\n                {\r\n                    ILocRepository locrep = new LocRepository();\r\n                    var startloc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                    var endLoc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_END_LOC);\r\n\r\n                    List<string> cntrs = wcsTask.S_CNTRS.Split(',').ToList();\r\n                    bool bobe = false;\r\n                    switch (model.method)\r\n                    {\r\n                        case \"start\":\r\n                            LogHelper.Info($\"海康车任务状态变更为执行，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            if (wcsTask.S_B_STATE.Trim() == \"已推送\")\r\n                            {\r\n                                wcsTask.S_B_STATE = \"执行中\";\r\n                                wcsTask.T_START_TIME = DateTime.Now;\r\n                                MainMissionService.Update(wcsTask);\r\n                                bobe = true;\r\n                            }\r\n                            break;\r\n                        case \"outbin\":\r\n                            LogHelper.Info($\"海康车任务状态变更为取货完成，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"取货完成\";\r\n\r\n                            startloc.N_CURRENT_NUM = 0;\r\n                            startloc.S_LOCK_STATE = \"无\";\r\n                            startloc.T_MODIFY = DateTime.Now;\r\n                            //ILocContainerRepository locContainerRepository = new LocContainerRepository();\r\n                            ////var cnr = locContainerRepository.FindList(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                            //locContainerRepository.Delete(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                            MainMissionService.Update(wcsTask);\r\n                            locrep.Update(startloc);\r\n\r\n                            bobe = true;\r\n                            var device = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_START_LOC));\r\n                            if (device != null)\r\n                            {\r\n                                if (device.deviceType == 1)\r\n                                {\r\n                                    if (device.deviceName.Contains(\"维希尔抓臂\"))\r\n                                    {  //卸货进行清空，触发扫码\r\n                                       var inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;\r\n                                       string V = inde ? \"R05\" : \"R06\";\r\n                                        Conn.默认Redis.SetValue(device.deviceName + \".\" + V, \"true\", device.deviceName + \"Queue\",false);\r\n                                       \r\n                                       TcpServer.TrayIps.Remove(device.deviceNo[inde ? 0 : 1]);\r\n                                    }\r\n                                }\r\n                                else if(device.deviceType == 2){\r\n\t\t\t\t\t\t\t\t\tvar inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;\r\n\t\t\t\t\t\t\t\t\t string V = inde? \"D1224\" : \"D1225\";\r\n\t\t\t\t\t\t\t\t\t Conn.默认Redis.SetValue(device.deviceName + \".\" + V, \"0\", device.deviceName + \"Queue\");\r\n                                }\r\n                            }\r\n                            //LocationHelper.UnLockLoc(wcsTask.S_START_LOC);\r\n                            break;\r\n                        case \"end\":\r\n                            LogHelper.Info($\"海康车任务状态变更为完成，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"完成\";\r\n                            wcsTask.T_END_TIME = DateTime.Now;\r\n\r\n                            bobe = true;\r\n                            //ILocContainerRepository locContainerRepository2 = new LocContainerRepository();\r\n                            //List<LocContainerEntity> llls = new List<LocContainerEntity>();\r\n                            //foreach (var c in cntrs)\r\n                            //{\r\n                            //    var action = new LocContainerEntity()\r\n                            //    {\r\n                            //        S_ID = Guid.NewGuid().ToString(),\r\n                            //        S_STATE = \"编辑\",\r\n                            //        T_CREATE = DateTime.Now,\r\n                            //        T_MODIFY = DateTime.Now,\r\n\r\n                            //        S_LOC_CODE = endLoc.S_LOC_CODE,\r\n                            //        S_CNTR_CODE = c,\r\n                            //        S_TYPE = \"\",\r\n                            //    };\r\n                            //    llls.Add(action);\r\n                            //}\r\n\r\n                            endLoc.S_LOCK_STATE = \"无\";\r\n                            endLoc.N_CURRENT_NUM = 1;\r\n                            endLoc.T_MODIFY = DateTime.Now;\r\n                            MainMissionService.Update(wcsTask);\r\n                            if(Settings.deviceInfos.Find(x=>x.deviceType==2 && (/*x.location.Contains(wcsTask.S_END_LOC)||*/x.deviceNo.Contains(wcsTask.S_END_LOC)))!=null)\r\n                                locrep.Update(endLoc);\r\n                            //locContainerRepository2.Insert(llls);\r\n\r\n                            var device2 = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_END_LOC));\r\n                            if (device2 != null)\r\n                            {\r\n                                if (device2.deviceType == 1)\r\n                                {\r\n                                    if (device2.deviceName.Contains(\"维希尔抓臂\"))\r\n                                    {\r\n                                        //string V = device2.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0 ? \"R10\" : \"R11\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"true\", device2.deviceName + \"Queue\");\r\n                                        //卸货再写托盘取走。 ç„¶åŽè§¦å‘扫码进行校验。 \r\n                                        var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;\r\n                                        //string V = inde ? \"R05\" : \"R06\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"true\", device2.deviceName + \"Queue\");\r\n                                        string V2 = inde ? \"R10_LAST\" : \"R11_LAST\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V2, \"true\", device2.deviceName + \"Queue\");\r\n                                        \r\n                                        GZ.Modular.Redis.RedisHelper.Add(device2.deviceName + \".\" + V2, \"true\", out string msg1);\r\n                                        TcpServer.TrayIps.Remove(device2.deviceNo[inde ? 0 : 1]);\r\n                                    }\r\n                                }\r\n                                else if (device2.deviceType == 2)\r\n                                    if (device2.deviceName.Contains(\"Js捷顺\"))\r\n                                    {\r\n                                        var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;\r\n                                        string V = inde? \"D1224\" : \"D1225\";\r\n                                        Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"1\", device2.deviceName + \"Queue\");\r\n\r\n                                        var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/202\", JsonConvert.SerializeObject(new\r\n                                        {\r\n                                            sceneType = 3,\r\n                                            cntrCode = cntrs.FirstOrDefault()\r\n                                        }));\r\n                                        //if (device2.deviceName.Contains(\"1\"))\r\n                                        //{\r\n                                        //    if (inde) tag.Js1.D1224 = 1;\r\n                                        //    else tag.Js1.D1225 = 1;\r\n                                        //}else\r\n                                        //{\r\n                                        //    if (inde) tag.Js2.D1224 = 1;\r\n                                        //    else tag.Js2.D1225 = 1;\r\n                                        //}\r\n                                    }\r\n                            }\r\n\r\n                            //LocationMethod.JudgeLocation(wcsTask);\r\n                            break;\r\n                        case \"cancel\":\r\n                            LogHelper.Info($\"海康车任务状态变更为取消，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"取消\";\r\n                            //startloc.S_LOCK_STATE = \"无\";\r\n                            //endLoc.S_LOCK_STATE = \"无\";\r\n                            MainMissionService.Update(wcsTask);\r\n                            TaskActRepository taskActRepository = new TaskActRepository();\r\n                            var tare = taskActRepository.FindList(x => x.S_TASK_NO == wcsTask.S_TASK_NO);\r\n                            if (tare.Any())\r\n                            {\r\n                                if(tare.Find(x=>x.S_ACTION_CODE==\"outbin\")==null)\r\n                                {\r\n                                    startloc.S_LOCK_STATE = \"无\";\r\n                                    endLoc.S_LOCK_STATE = \"无\";\r\n                                    locrep.Update(startloc);\r\n                                    locrep.Update(endLoc);\r\n                                }else if (tare.Find(x => x.S_ACTION_CODE == \"end\") == null)\r\n                                {\r\n                                    endLoc.S_LOCK_STATE = \"无\";\r\n                                    locrep.Update(endLoc);\r\n                                }\r\n                            }\r\n\r\n                            //locrep.Update(startloc);\r\n                            //locrep.Update(endLoc);\r\n                            //TaskProcess.OperateStatus(wcsTask, 7);\r\n                            //WCSHelper.Fail(wcsTask);\r\n                            break;\r\n                        case \"apply\":\r\n                            // åˆ¤æ–­è¯¥ä»»åŠ¡çš„接驳位是否有其他入库或出库任务，如果有，则在等位等待，如果没有，则入\r\n                            TaskisOk(wcsTask);\r\n                            break;\r\n                    }\r\n\r\n                    if (!string.IsNullOrEmpty(wcsTask.S_SRC_NO))\r\n                    {\r\n                        var mestask = MainMissionService.FindEntity(x => x.S_TASK_NO == wcsTask.S_SRC_NO);\r\n                        if (mestask!=null&&bobe)\r\n                        {\r\n                            if ( model.method != \"end\")\r\n                            {\r\n                            \tif (mestask.S_START_LOC == wcsTask.S_START_LOC&&mestask.S_B_STATE == \"MES\")\r\n\t                                Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n\t                                {\r\n\t                                    reqCode = wcsTask.S_SRC_NO,\r\n\t                                    model.method\r\n\t                                }));\r\n                            }\r\n                            else\r\n                            {\r\n                                if (mestask.S_END_LOC != wcsTask.S_END_LOC)\r\n                                {\r\n                                    LogHelper.Info($\"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸€é˜¶æ®µå®Œæˆï¼Œé‡ç½®è¿›è¡ŒäºŒé˜¶æ®µã€‚\");\r\n                                    mestask.N_PRIORITY = -88;\r\n                                    MainMissionService.Update(mestask);\r\n                                }\r\n                                else if(mestask.S_B_STATE == \"MES\")\r\n                                {\r\n                                    var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n                                    {\r\n                                        reqCode = wcsTask.S_SRC_NO,\r\n                                        model.method\r\n                                    }));\r\n                                }\r\n                            }\r\n\r\n                        }else if(mestask!=null && model.method== \"cancel\")\r\n                        {\r\n                        \t if(mestask.S_B_STATE == \"MES\")\r\n\t                           Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n\t                            {\r\n\t                                reqCode = wcsTask.S_SRC_NO,\r\n\t                                model.method\r\n\t                            })); \r\n                            LogHelper.Info($\"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸€é˜¶æ®µå–消，重置点，线程处理。\");\r\n                            mestask.N_PRIORITY = -1;\r\n                            mestask.S_B_STATE = \"MES_取消\";\r\n                            MainMissionService.Update(mestask);\r\n                        }\r\n                    }\r\n                    TaskProcess.AddActionRecord(model.taskCode, model.method, model.eqpCode, model.data,wcsTask.S_START_LOC,wcsTask.S_END_LOC);\r\n                    //调用第三方接口（如果有）TaskProcess.ReportStatus\r\n                }\r\n                else\r\n                {\r\n                    // æš‚时设定为0\r\n                    wcsTask.S_B_STATE = \"上报状态空\";\r\n                    //安全请求等\r\n                    //TaskProcess.OperateReq(model.taskCode, wcsTask.N_B_STATE, model.eqpCode, model.data);\r\n                }\r\n            }\r\n            else\r\n            {\r\n                LogHelper.Info($\"当前任务号任务不存在{model.taskCode}\", \"agv杭叉交互日志\");\r\n            }",
      "Code": "public void OperateHKTaskStatus(System.Object param1)\r\n{HaiKangOrderInfo model = (HaiKangOrderInfo)param1;\r\n            if (string.IsNullOrEmpty(model.taskCode))\r\n                return;\r\n            // æŸ¥è¯¢ä»»åŠ¡ï¼šæ ¹æ®ä»»åŠ¡å·\r\n            //var wcsTask = WCSHelper.GetTask(model.taskCode);\r\n            ITaskRepository MainMissionService = new TaskRepository();\r\n            var wcsTask = MainMissionService.FindEntity(x => model.taskCode == x.S_TASK_NO);\r\n            if (wcsTask != null)\r\n            {\r\n                if (!string.IsNullOrWhiteSpace(model.method))\r\n                {\r\n                    ILocRepository locrep = new LocRepository();\r\n                    var startloc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                    var endLoc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_END_LOC);\r\n\r\n                    List<string> cntrs = wcsTask.S_CNTRS.Split(',').ToList();\r\n                    bool bobe = false;\r\n                    switch (model.method)\r\n                    {\r\n                        case \"start\":\r\n                            LogHelper.Info($\"海康车任务状态变更为执行，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            if (wcsTask.S_B_STATE.Trim() == \"已推送\")\r\n                            {\r\n                                wcsTask.S_B_STATE = \"执行中\";\r\n                                wcsTask.T_START_TIME = DateTime.Now;\r\n                                MainMissionService.Update(wcsTask);\r\n                                bobe = true;\r\n                            }\r\n                            break;\r\n                        case \"outbin\":\r\n                            LogHelper.Info($\"海康车任务状态变更为取货完成，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"取货完成\";\r\n\r\n                            startloc.N_CURRENT_NUM = 0;\r\n                            startloc.S_LOCK_STATE = \"无\";\r\n                            startloc.T_MODIFY = DateTime.Now;\r\n                            //ILocContainerRepository locContainerRepository = new LocContainerRepository();\r\n                            ////var cnr = locContainerRepository.FindList(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                            //locContainerRepository.Delete(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);\r\n                            MainMissionService.Update(wcsTask);\r\n                            locrep.Update(startloc);\r\n\r\n                            bobe = true;\r\n                            var device = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_START_LOC));\r\n                            if (device != null)\r\n                            {\r\n                                if (device.deviceType == 1)\r\n                                {\r\n                                    if (device.deviceName.Contains(\"维希尔抓臂\"))\r\n                                    {  //卸货进行清空，触发扫码\r\n                                       var inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;\r\n                                       string V = inde ? \"R05\" : \"R06\";\r\n                                        Conn.默认Redis.SetValue(device.deviceName + \".\" + V, \"true\", device.deviceName + \"Queue\",false);\r\n                                       \r\n                                       TcpServer.TrayIps.Remove(device.deviceNo[inde ? 0 : 1]);\r\n                                    }\r\n                                }\r\n                                else if(device.deviceType == 2){\r\n\t\t\t\t\t\t\t\t\tvar inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;\r\n\t\t\t\t\t\t\t\t\t string V = inde? \"D1224\" : \"D1225\";\r\n\t\t\t\t\t\t\t\t\t Conn.默认Redis.SetValue(device.deviceName + \".\" + V, \"0\", device.deviceName + \"Queue\");\r\n                                }\r\n                            }\r\n                            //LocationHelper.UnLockLoc(wcsTask.S_START_LOC);\r\n                            break;\r\n                        case \"end\":\r\n                            LogHelper.Info($\"海康车任务状态变更为完成，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"完成\";\r\n                            wcsTask.T_END_TIME = DateTime.Now;\r\n\r\n                            bobe = true;\r\n                            //ILocContainerRepository locContainerRepository2 = new LocContainerRepository();\r\n                            //List<LocContainerEntity> llls = new List<LocContainerEntity>();\r\n                            //foreach (var c in cntrs)\r\n                            //{\r\n                            //    var action = new LocContainerEntity()\r\n                            //    {\r\n                            //        S_ID = Guid.NewGuid().ToString(),\r\n                            //        S_STATE = \"编辑\",\r\n                            //        T_CREATE = DateTime.Now,\r\n                            //        T_MODIFY = DateTime.Now,\r\n\r\n                            //        S_LOC_CODE = endLoc.S_LOC_CODE,\r\n                            //        S_CNTR_CODE = c,\r\n                            //        S_TYPE = \"\",\r\n                            //    };\r\n                            //    llls.Add(action);\r\n                            //}\r\n\r\n                            endLoc.S_LOCK_STATE = \"无\";\r\n                            endLoc.N_CURRENT_NUM = 1;\r\n                            endLoc.T_MODIFY = DateTime.Now;\r\n                            MainMissionService.Update(wcsTask);\r\n                            if(Settings.deviceInfos.Find(x=>x.deviceType==2 && (/*x.location.Contains(wcsTask.S_END_LOC)||*/x.deviceNo.Contains(wcsTask.S_END_LOC)))!=null)\r\n                                locrep.Update(endLoc);\r\n                            //locContainerRepository2.Insert(llls);\r\n\r\n                            var device2 = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_END_LOC));\r\n                            if (device2 != null)\r\n                            {\r\n                                if (device2.deviceType == 1)\r\n                                {\r\n                                    if (device2.deviceName.Contains(\"维希尔抓臂\"))\r\n                                    {\r\n                                        //string V = device2.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0 ? \"R10\" : \"R11\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"true\", device2.deviceName + \"Queue\");\r\n                                        //卸货再写托盘取走。 ç„¶åŽè§¦å‘扫码进行校验。 \r\n                                        var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;\r\n                                        //string V = inde ? \"R05\" : \"R06\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"true\", device2.deviceName + \"Queue\");\r\n                                        string V2 = inde ? \"R10_LAST\" : \"R11_LAST\";\r\n                                        //Conn.默认Redis.SetValue(device2.deviceName + \".\" + V2, \"true\", device2.deviceName + \"Queue\");\r\n                                        \r\n                                        GZ.Modular.Redis.RedisHelper.Add(device2.deviceName + \".\" + V2, \"true\", out string msg1);\r\n                                        TcpServer.TrayIps.Remove(device2.deviceNo[inde ? 0 : 1]);\r\n                                    }\r\n                                }\r\n                                else if (device2.deviceType == 2)\r\n                                    if (device2.deviceName.Contains(\"Js捷顺\"))\r\n                                    {\r\n                                        var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;\r\n                                        string V = inde? \"D1224\" : \"D1225\";\r\n                                        Conn.默认Redis.SetValue(device2.deviceName + \".\" + V, \"1\", device2.deviceName + \"Queue\");\r\n\r\n                                        var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/202\", JsonConvert.SerializeObject(new\r\n                                        {\r\n                                            sceneType = 3,\r\n                                            cntrCode = cntrs.FirstOrDefault()\r\n                                        }));\r\n                                        //if (device2.deviceName.Contains(\"1\"))\r\n                                        //{\r\n                                        //    if (inde) tag.Js1.D1224 = 1;\r\n                                        //    else tag.Js1.D1225 = 1;\r\n                                        //}else\r\n                                        //{\r\n                                        //    if (inde) tag.Js2.D1224 = 1;\r\n                                        //    else tag.Js2.D1225 = 1;\r\n                                        //}\r\n                                    }\r\n                            }\r\n\r\n                            //LocationMethod.JudgeLocation(wcsTask);\r\n                            break;\r\n                        case \"cancel\":\r\n                            LogHelper.Info($\"海康车任务状态变更为取消，任务号为：{model.taskCode}\", \"agv杭叉交互日志\");\r\n                            wcsTask.S_B_STATE = \"取消\";\r\n                            //startloc.S_LOCK_STATE = \"无\";\r\n                            //endLoc.S_LOCK_STATE = \"无\";\r\n                            MainMissionService.Update(wcsTask);\r\n                            TaskActRepository taskActRepository = new TaskActRepository();\r\n                            var tare = taskActRepository.FindList(x => x.S_TASK_NO == wcsTask.S_TASK_NO);\r\n                            if (tare.Any())\r\n                            {\r\n                                if(tare.Find(x=>x.S_ACTION_CODE==\"outbin\")==null)\r\n                                {\r\n                                    startloc.S_LOCK_STATE = \"无\";\r\n                                    endLoc.S_LOCK_STATE = \"无\";\r\n                                    locrep.Update(startloc);\r\n                                    locrep.Update(endLoc);\r\n                                }else if (tare.Find(x => x.S_ACTION_CODE == \"end\") == null)\r\n                                {\r\n                                    endLoc.S_LOCK_STATE = \"无\";\r\n                                    locrep.Update(endLoc);\r\n                                }\r\n                            }\r\n\r\n                            //locrep.Update(startloc);\r\n                            //locrep.Update(endLoc);\r\n                            //TaskProcess.OperateStatus(wcsTask, 7);\r\n                            //WCSHelper.Fail(wcsTask);\r\n                            break;\r\n                        case \"apply\":\r\n                            // åˆ¤æ–­è¯¥ä»»åŠ¡çš„接驳位是否有其他入库或出库任务，如果有，则在等位等待，如果没有，则入\r\n                            TaskisOk(wcsTask);\r\n                            break;\r\n                    }\r\n\r\n                    if (!string.IsNullOrEmpty(wcsTask.S_SRC_NO))\r\n                    {\r\n                        var mestask = MainMissionService.FindEntity(x => x.S_TASK_NO == wcsTask.S_SRC_NO);\r\n                        if (mestask!=null&&bobe)\r\n                        {\r\n                            if ( model.method != \"end\")\r\n                            {\r\n                            \tif (mestask.S_START_LOC == wcsTask.S_START_LOC&&mestask.S_B_STATE == \"MES\")\r\n\t                                Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n\t                                {\r\n\t                                    reqCode = wcsTask.S_SRC_NO,\r\n\t                                    model.method\r\n\t                                }));\r\n                            }\r\n                            else\r\n                            {\r\n                                if (mestask.S_END_LOC != wcsTask.S_END_LOC)\r\n                                {\r\n                                    LogHelper.Info($\"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸€é˜¶æ®µå®Œæˆï¼Œé‡ç½®è¿›è¡ŒäºŒé˜¶æ®µã€‚\");\r\n                                    mestask.N_PRIORITY = -88;\r\n                                    MainMissionService.Update(mestask);\r\n                                }\r\n                                else if(mestask.S_B_STATE == \"MES\")\r\n                                {\r\n                                    var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n                                    {\r\n                                        reqCode = wcsTask.S_SRC_NO,\r\n                                        model.method\r\n                                    }));\r\n                                }\r\n                            }\r\n\r\n                        }else if(mestask!=null && model.method== \"cancel\")\r\n                        {\r\n                        \t if(mestask.S_B_STATE == \"MES\")\r\n\t                           Settings.apiHelper.Post(Settings.WMSbaseUrl + \"mom-basic/dataTransmission/json/service/201\", JsonConvert.SerializeObject(new\r\n\t                            {\r\n\t                                reqCode = wcsTask.S_SRC_NO,\r\n\t                                model.method\r\n\t                            })); \r\n                            LogHelper.Info($\"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸€é˜¶æ®µå–消，重置点，线程处理。\");\r\n                            mestask.N_PRIORITY = -1;\r\n                            mestask.S_B_STATE = \"MES_取消\";\r\n                            MainMissionService.Update(mestask);\r\n                        }\r\n                    }\r\n                    TaskProcess.AddActionRecord(model.taskCode, model.method, model.eqpCode, model.data,wcsTask.S_START_LOC,wcsTask.S_END_LOC);\r\n                    //调用第三方接口（如果有）TaskProcess.ReportStatus\r\n                }\r\n                else\r\n                {\r\n                    // æš‚时设定为0\r\n                    wcsTask.S_B_STATE = \"上报状态空\";\r\n                    //安全请求等\r\n                    //TaskProcess.OperateReq(model.taskCode, wcsTask.N_B_STATE, model.eqpCode, model.data);\r\n                }\r\n            }\r\n            else\r\n            {\r\n                LogHelper.Info($\"当前任务号任务不存在{model.taskCode}\", \"agv杭叉交互日志\");\r\n            }\r\n}",
      "CusMethod": {
        "Name": "OperateHKTaskStatus",
        "Params": [
@@ -593,8 +593,8 @@
      "Type": "ClassCode",
      "Level": "Item",
      "Statement": "public class TaskProcess",
      "EditCode": "internal static bool CreateTask(string no, string from, string to, string taskType, int pri, List<string> cntrs, string workMode = \"AGV\", int cntrCount = 1, int startLayer = 1, int endLayer = 1)\r\n{\r\n\t\r\n            LogHelper.Info($\"输送线RGV空托任务 from:{from}>to {to}开始创建>\");\r\n     var cntrInfo = string.Join(\",\", cntrs);\r\n ILocRepository locc = new LocRepository();\r\n var fromLoc = locc.FindEntity(x => x.S_LOC_CODE == from);\r\n var endLoc = locc.FindEntity(x => x.S_LOC_CODE == to);\r\n \r\n            var s = Settings.deviceInfos.Find(x => x.location.Contains(from)) != null;\r\n            var e = Settings.deviceInfos.Find(x => x.location.Contains(to)) != null;\r\n            string t = \"F01\";\r\n            if (s && !e) t = \"A002\";\r\n            if (!s && e) t = \"A003\";\r\n            if (s && e) t = \"A004\";\r\n try\r\n {\r\n\r\n     TaskEntity wmsTask = new TaskEntity()\r\n     {\r\n     \tS_ID = Guid.NewGuid().ToString(),\r\n\t\tS_STATE = \"编辑\",\r\n\t\tT_CREATE = DateTime.Now,\r\n\t\tT_MODIFY = DateTime.Now,\r\n\r\n         S_TASK_NO = GenerateTaskNo(),\r\n         S_START_LAREA = fromLoc.S_AREA_CODE,\r\n         S_END_LAREA = endLoc.S_AREA_CODE,\r\n         S_DEPART_NAME = \"\",\r\n         S_START_LOC = from,\r\n         S_END_LOC = to,\r\n         S_TYPE = taskType,\r\n         S_SRC_NO = no,//\r\n         N_PRIORITY = pri,\r\n         S_WORK_MODE = workMode,\r\n         S_B_STATE = \"未执行\",\r\n         S_CNTRS = cntrInfo,\r\n         N_START_LAYER = startLayer,\r\n         N_END_LAYER = endLayer,\r\n         N_CNTR_COUNT = cntrCount,\r\n                    S_INDEX=t,\r\n     };\r\n     ITaskRepository taskserice = new TaskRepository();\r\n     taskserice.Insert(wmsTask);\r\n     \r\n                if (workMode == \"AGV\")\r\n                {\r\n                    fromLoc.S_LOCK_STATE = \"出库锁\";\r\n                    endLoc.S_LOCK_STATE = \"入库锁\";\r\n                    locc.Update(fromLoc);\r\n                    locc.Update(endLoc);\r\n                }\r\n                \r\n                LogHelper.Info($\"输送线RGV空托任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功\");\r\n                return true;\r\n }\r\n catch (Exception ex)\r\n {\r\n     LogHelper.Error(\"CreateTask\" + ex.Message, ex);\r\n     return false;\r\n }\r\n}\r\n\r\n\r\n     internal static void AddActionRecord(string no, string state, string forkliftNo, string extData,string strloc,string endloc)\r\n        {\r\n            var action = new TaskActEntity()\r\n            {\r\n                S_ID = Guid.NewGuid().ToString(),\r\n                S_STATE = \"编辑\",\r\n                T_CREATE = DateTime.Now,\r\n                T_MODIFY = DateTime.Now,\r\n                S_START_LOC= strloc,\r\n                S_END_LOC= endloc,\r\n                S_ACTION_CODE = state,\r\n                S_TASK_NO = no,\r\n                S_EQ_NO = forkliftNo,\r\n                S_EQ_TYPE = \"agv\",\r\n                S_DATA = extData,\r\n                N_CREATEMETHOD = 0\r\n            };\r\n            TaskActRepository taskserice = new TaskActRepository();\r\n            taskserice.Insert(action);\r\n        }\r\n\r\n        public static System.String GenerateTaskNo()\r\n        {\r\n            var id = SYSHelper.GetSerialNumber(\"任务号\", \"TN\", \"1\");\r\n            var date = DateTime.Now.ToString(\"yyMMdd\");\r\n            return $\"TN{date}{id.ToString().PadLeft(4, '0')}\";\r\n        }",
      "Code": "public class TaskProcess\r\n{internal static bool CreateTask(string no, string from, string to, string taskType, int pri, List<string> cntrs, string workMode = \"AGV\", int cntrCount = 1, int startLayer = 1, int endLayer = 1)\r\n{\r\n\t\r\n            LogHelper.Info($\"输送线RGV空托任务 from:{from}>to {to}开始创建>\");\r\n     var cntrInfo = string.Join(\",\", cntrs);\r\n ILocRepository locc = new LocRepository();\r\n var fromLoc = locc.FindEntity(x => x.S_LOC_CODE == from);\r\n var endLoc = locc.FindEntity(x => x.S_LOC_CODE == to);\r\n \r\n            var s = Settings.deviceInfos.Find(x => x.location.Contains(from)) != null;\r\n            var e = Settings.deviceInfos.Find(x => x.location.Contains(to)) != null;\r\n            string t = \"F01\";\r\n            if (s && !e) t = \"A002\";\r\n            if (!s && e) t = \"A003\";\r\n            if (s && e) t = \"A004\";\r\n try\r\n {\r\n\r\n     TaskEntity wmsTask = new TaskEntity()\r\n     {\r\n     \tS_ID = Guid.NewGuid().ToString(),\r\n\t\tS_STATE = \"编辑\",\r\n\t\tT_CREATE = DateTime.Now,\r\n\t\tT_MODIFY = DateTime.Now,\r\n\r\n         S_TASK_NO = GenerateTaskNo(),\r\n         S_START_LAREA = fromLoc.S_AREA_CODE,\r\n         S_END_LAREA = endLoc.S_AREA_CODE,\r\n         S_DEPART_NAME = \"\",\r\n         S_START_LOC = from,\r\n         S_END_LOC = to,\r\n         S_TYPE = taskType,\r\n         S_SRC_NO = no,//\r\n         N_PRIORITY = pri,\r\n         S_WORK_MODE = workMode,\r\n         S_B_STATE = \"未执行\",\r\n         S_CNTRS = cntrInfo,\r\n         N_START_LAYER = startLayer,\r\n         N_END_LAYER = endLayer,\r\n         N_CNTR_COUNT = cntrCount,\r\n                    S_INDEX=t,\r\n     };\r\n     ITaskRepository taskserice = new TaskRepository();\r\n     taskserice.Insert(wmsTask);\r\n     \r\n                if (workMode == \"AGV\")\r\n                {\r\n                    fromLoc.S_LOCK_STATE = \"出库锁\";\r\n                    endLoc.S_LOCK_STATE = \"入库锁\";\r\n                    locc.Update(fromLoc);\r\n                    locc.Update(endLoc);\r\n                }\r\n                \r\n                LogHelper.Info($\"输送线RGV空托任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功\");\r\n                return true;\r\n }\r\n catch (Exception ex)\r\n {\r\n     LogHelper.Error(\"CreateTask\" + ex.Message, ex);\r\n     return false;\r\n }\r\n}\r\n\r\n\r\n     internal static void AddActionRecord(string no, string state, string forkliftNo, string extData,string strloc,string endloc)\r\n        {\r\n            var action = new TaskActEntity()\r\n            {\r\n                S_ID = Guid.NewGuid().ToString(),\r\n                S_STATE = \"编辑\",\r\n                T_CREATE = DateTime.Now,\r\n                T_MODIFY = DateTime.Now,\r\n                S_START_LOC= strloc,\r\n                S_END_LOC= endloc,\r\n                S_ACTION_CODE = state,\r\n                S_TASK_NO = no,\r\n                S_EQ_NO = forkliftNo,\r\n                S_EQ_TYPE = \"agv\",\r\n                S_DATA = extData,\r\n                N_CREATEMETHOD = 0\r\n            };\r\n            TaskActRepository taskserice = new TaskActRepository();\r\n            taskserice.Insert(action);\r\n        }\r\n\r\n        public static System.String GenerateTaskNo()\r\n        {\r\n            var id = SYSHelper.GetSerialNumber(\"任务号\", \"TN\", \"1\");\r\n            var date = DateTime.Now.ToString(\"yyMMdd\");\r\n            return $\"TN{date}{id.ToString().PadLeft(4, '0')}\";\r\n        }\r\n}",
      "EditCode": "internal static bool CreateTask(string no, string from, string to, string taskType, int pri, List<string> cntrs, string workMode = \"AGV\", int cntrCount = 1, int startLayer = 1, int endLayer = 1)\r\n{\r\n\r\n    LogHelper.Info($\"创建任务 from:{from}>to {to}开始创建>\");\r\n    var cntrInfo = string.Join(\",\", cntrs);\r\n    ILocRepository locc = new LocRepository();\r\n    var fromLoc = locc.FindEntity(x => x.S_LOC_CODE == from);\r\n    var endLoc = locc.FindEntity(x => x.S_LOC_CODE == to);\r\n\r\n    var s = Settings.deviceInfos.Find(x => x.location.Contains(from)) != null;\r\n    var e = Settings.deviceInfos.Find(x => x.location.Contains(to)) != null;\r\n    string t = \"\";\r\n    if (workMode == \"AGV\")\r\n    {\r\n        t = \"F01\";\r\n        if (s && !e) t = \"A002\";\r\n        if (!s && e) t = \"A003\";\r\n        if (s && e) t = \"A004\";\r\n    }\r\n    try\r\n    {\r\n\r\n        TaskEntity wmsTask = new TaskEntity()\r\n        {\r\n            S_ID = Guid.NewGuid().ToString(),\r\n            S_STATE = \"编辑\",\r\n            T_CREATE = DateTime.Now,\r\n            T_MODIFY = DateTime.Now,\r\n\r\n            S_TASK_NO = GenerateTaskNo(),\r\n            S_START_LAREA = fromLoc.S_AREA_CODE,\r\n            S_END_LAREA = endLoc.S_AREA_CODE,\r\n            S_DEPART_NAME = \"\",\r\n            S_START_LOC = from,\r\n            S_END_LOC = to,\r\n            S_TYPE = taskType,\r\n            S_SRC_NO = no,//\r\n            N_PRIORITY = pri,\r\n            S_WORK_MODE = workMode,\r\n            S_B_STATE = \"未执行\",\r\n            S_CNTRS = cntrInfo,\r\n            N_START_LAYER = startLayer,\r\n            N_END_LAYER = endLayer,\r\n            N_CNTR_COUNT = cntrCount,\r\n            S_INDEX = t,\r\n        };\r\n        ITaskRepository taskserice = new TaskRepository();\r\n        taskserice.Insert(wmsTask);\r\n\r\n        if (workMode == \"AGV\")\r\n        {\r\n            fromLoc.S_LOCK_STATE = \"出库锁\";\r\n            endLoc.S_LOCK_STATE = \"入库锁\";\r\n            locc.Update(fromLoc);\r\n            locc.Update(endLoc);\r\n        }\r\n\r\n        LogHelper.Info($\"创建任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功\");\r\n        return true;\r\n    }\r\n    catch (Exception ex)\r\n    {\r\n        LogHelper.Error(\"CreateTask\" + ex.Message, ex);\r\n        return false;\r\n    }\r\n}\r\n\r\n\r\n     internal static void AddActionRecord(string no, string state, string forkliftNo, string extData,string strloc,string endloc)\r\n        {\r\n            var action = new TaskActEntity()\r\n            {\r\n                S_ID = Guid.NewGuid().ToString(),\r\n                S_STATE = \"编辑\",\r\n                T_CREATE = DateTime.Now,\r\n                T_MODIFY = DateTime.Now,\r\n                S_START_LOC= strloc,\r\n                S_END_LOC= endloc,\r\n                S_ACTION_CODE = state,\r\n                S_TASK_NO = no,\r\n                S_EQ_NO = forkliftNo,\r\n                S_EQ_TYPE = \"agv\",\r\n                S_DATA = extData,\r\n                N_CREATEMETHOD = 0\r\n            };\r\n            TaskActRepository taskserice = new TaskActRepository();\r\n            taskserice.Insert(action);\r\n        }\r\n\r\n        public static System.String GenerateTaskNo()\r\n        {\r\n            var id = SYSHelper.GetSerialNumber(\"任务号\", \"TN\", \"1\");\r\n            var date = DateTime.Now.ToString(\"yyMMdd\");\r\n            return $\"TN{date}{id.ToString().PadLeft(4, '0')}\";\r\n        }",
      "Code": "public class TaskProcess\r\n{internal static bool CreateTask(string no, string from, string to, string taskType, int pri, List<string> cntrs, string workMode = \"AGV\", int cntrCount = 1, int startLayer = 1, int endLayer = 1)\r\n{\r\n\r\n    LogHelper.Info($\"创建任务 from:{from}>to {to}开始创建>\");\r\n    var cntrInfo = string.Join(\",\", cntrs);\r\n    ILocRepository locc = new LocRepository();\r\n    var fromLoc = locc.FindEntity(x => x.S_LOC_CODE == from);\r\n    var endLoc = locc.FindEntity(x => x.S_LOC_CODE == to);\r\n\r\n    var s = Settings.deviceInfos.Find(x => x.location.Contains(from)) != null;\r\n    var e = Settings.deviceInfos.Find(x => x.location.Contains(to)) != null;\r\n    string t = \"\";\r\n    if (workMode == \"AGV\")\r\n    {\r\n        t = \"F01\";\r\n        if (s && !e) t = \"A002\";\r\n        if (!s && e) t = \"A003\";\r\n        if (s && e) t = \"A004\";\r\n    }\r\n    try\r\n    {\r\n\r\n        TaskEntity wmsTask = new TaskEntity()\r\n        {\r\n            S_ID = Guid.NewGuid().ToString(),\r\n            S_STATE = \"编辑\",\r\n            T_CREATE = DateTime.Now,\r\n            T_MODIFY = DateTime.Now,\r\n\r\n            S_TASK_NO = GenerateTaskNo(),\r\n            S_START_LAREA = fromLoc.S_AREA_CODE,\r\n            S_END_LAREA = endLoc.S_AREA_CODE,\r\n            S_DEPART_NAME = \"\",\r\n            S_START_LOC = from,\r\n            S_END_LOC = to,\r\n            S_TYPE = taskType,\r\n            S_SRC_NO = no,//\r\n            N_PRIORITY = pri,\r\n            S_WORK_MODE = workMode,\r\n            S_B_STATE = \"未执行\",\r\n            S_CNTRS = cntrInfo,\r\n            N_START_LAYER = startLayer,\r\n            N_END_LAYER = endLayer,\r\n            N_CNTR_COUNT = cntrCount,\r\n            S_INDEX = t,\r\n        };\r\n        ITaskRepository taskserice = new TaskRepository();\r\n        taskserice.Insert(wmsTask);\r\n\r\n        if (workMode == \"AGV\")\r\n        {\r\n            fromLoc.S_LOCK_STATE = \"出库锁\";\r\n            endLoc.S_LOCK_STATE = \"入库锁\";\r\n            locc.Update(fromLoc);\r\n            locc.Update(endLoc);\r\n        }\r\n\r\n        LogHelper.Info($\"创建任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功\");\r\n        return true;\r\n    }\r\n    catch (Exception ex)\r\n    {\r\n        LogHelper.Error(\"CreateTask\" + ex.Message, ex);\r\n        return false;\r\n    }\r\n}\r\n\r\n\r\n     internal static void AddActionRecord(string no, string state, string forkliftNo, string extData,string strloc,string endloc)\r\n        {\r\n            var action = new TaskActEntity()\r\n            {\r\n                S_ID = Guid.NewGuid().ToString(),\r\n                S_STATE = \"编辑\",\r\n                T_CREATE = DateTime.Now,\r\n                T_MODIFY = DateTime.Now,\r\n                S_START_LOC= strloc,\r\n                S_END_LOC= endloc,\r\n                S_ACTION_CODE = state,\r\n                S_TASK_NO = no,\r\n                S_EQ_NO = forkliftNo,\r\n                S_EQ_TYPE = \"agv\",\r\n                S_DATA = extData,\r\n                N_CREATEMETHOD = 0\r\n            };\r\n            TaskActRepository taskserice = new TaskActRepository();\r\n            taskserice.Insert(action);\r\n        }\r\n\r\n        public static System.String GenerateTaskNo()\r\n        {\r\n            var id = SYSHelper.GetSerialNumber(\"任务号\", \"TN\", \"1\");\r\n            var date = DateTime.Now.ToString(\"yyMMdd\");\r\n            return $\"TN{date}{id.ToString().PadLeft(4, '0')}\";\r\n        }\r\n}",
      "CusMethod": {
        "Name": "",
        "Params": [],
@@ -635,8 +635,8 @@
      "Type": "ClassCode",
      "Level": "Item",
      "Statement": "public class ToWMSMES",
      "EditCode": "//2 wms  mes \r\n\r\n\r\n        public class CreateTask\r\n        {\r\n            public string taskType { get; set; }\r\n            public string startBit { get; set; }\r\n            public string endBit { get; set; }\r\n            public string reqCode { get; set; }\r\n            public string cntrCode { get; set; }\r\n\r\n            internal static ReturnMsg CreatemesTask(CreateTask model)\r\n            {\r\n                ITaskRepository taskservice = new TaskRepository();\r\n                var task = taskservice.FindEntity(x => x.S_TASK_NO == model.reqCode);\r\n                if (task == null)\r\n                {\r\n                    //var i = TaskProcess.CreateTask(\"\", model.startBit, model.endBit, string.IsNullOrEmpty(model.taskType) ? \"Mes下发\" : model.taskType, 5, new List<string> { model.cntrCode });\r\n                    TaskEntity wmsTask = new TaskEntity()\r\n                    {\r\n                        S_ID = Guid.NewGuid().ToString(),\r\n                        S_STATE = \"编辑\",\r\n                        T_CREATE = DateTime.Now,\r\n                        T_MODIFY = DateTime.Now,\r\n\r\n                        S_TASK_NO = model.reqCode,\r\n                        S_START_LAREA = \"\",\r\n                        S_END_LAREA = \"\",\r\n                        S_DEPART_NAME = \"\",\r\n                        S_START_LOC = model.startBit,\r\n                        S_END_LOC = model.endBit,\r\n                        S_TYPE = model.reqCode,\r\n                        S_SRC_NO = \"\",//\r\n                        N_PRIORITY = -88,\r\n                        S_WORK_MODE = \"agv\",\r\n                        S_B_STATE = \"MES\",\r\n                        S_CNTRS = model.cntrCode,\r\n                        N_START_LAYER = 1,\r\n                        N_END_LAYER = 1,\r\n                        N_CNTR_COUNT = 1\r\n                    };\r\n                    ITaskRepository taskserice = new TaskRepository();\r\n                    var i = taskserice.Insert(wmsTask) > 0;\r\n                    return new ReturnMsg { resultCode = (i ? 0 : -1), resultMsg = i ? \"\" : \"任务生成失败。\" };\r\n                }\r\n                else\r\n                {\r\n                    return new ReturnMsg { resultCode = -1, resultMsg = \"任务重复下发。\" };\r\n                }\r\n            }\r\n        \r\n        public class ReturnMsg\r\n        {\r\n            public int resultCode { get; set; }\r\n            public string resultMsg { get; set; }\r\n        }\r\n        \r\n        \r\n            internal static ReturnMsg CreatePointTask(CreateTask model)\r\n            {\r\n                ITaskRepository taskservice = new TaskRepository();\r\n                var task = taskservice.FindEntity(x => x.S_TASK_NO == model.reqCode);\r\n                if (task == null)\r\n                {\r\n                    //var i = TaskProcess.CreateTask(\"\", model.startBit, model.endBit, string.IsNullOrEmpty(model.taskType) ? \"Mes下发\" : model.taskType, 5, new List<string> { model.cntrCode });\r\n                    TaskEntity wmsTask = new TaskEntity()\r\n                    {\r\n                        S_ID = Guid.NewGuid().ToString(),\r\n                        S_STATE = \"编辑\",\r\n                        T_CREATE = DateTime.Now,\r\n                        T_MODIFY = DateTime.Now,\r\n                        S_TASK_NO = model.reqCode,\r\n                        S_START_LAREA = \"\",\r\n                        S_END_LAREA = \"\",\r\n                        S_DEPART_NAME = \"\",\r\n                        S_START_LOC = model.startBit,\r\n                        S_END_LOC = model.endBit,\r\n                        S_TYPE = model.reqCode,\r\n                        S_SRC_NO = \"\",//\r\n                        N_PRIORITY = -88,\r\n                        S_WORK_MODE = \"agv\",\r\n                        S_B_STATE = \"People\",\r\n                        S_CNTRS = model.cntrCode,\r\n                        N_START_LAYER = 1,\r\n                        N_END_LAYER = 1,\r\n                        N_CNTR_COUNT = 1\r\n                    };\r\n                    ITaskRepository taskserice = new TaskRepository();\r\n                    var i = taskserice.Insert(wmsTask) > 0;\r\n                    return new ReturnMsg { resultCode = (i ? 0 : -1), resultMsg = i ? \"\" : \"任务生成失败。\" };\r\n                }\r\n                else\r\n                {\r\n                    return new ReturnMsg { resultCode = -1, resultMsg = \"任务重复下发。\" };\r\n                }\r\n            }\r\n        }\r\n        public static void ResMesTask()\r\n        {\r\n            ///1.\r\n            TaskRepository taskservice = new TaskRepository();\r\n            var tasks = taskservice.FindList(x =>( x.S_B_STATE == \"MES\"|| x.S_B_STATE == \"People\") && x.N_PRIORITY == -88);\r\n            var VERXs = Settings.deviceInfos?.FindAll(x => x.deviceType==2);\r\n            //if (VERXs.Any())\r\n                foreach (var task in tasks)\r\n                {\r\n                    var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC));\r\n                    if (sx == null)\r\n                    {\r\n                        //直接生成对应任务。\r\n                        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS.Split(',').ToList());\r\n                        if (res)\r\n                        {\r\n                            //task.N_PRIORITY = 0;\r\n                            taskservice.dbcontext.Set<TaskEntity>().Attach(task);\r\n                            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).CurrentValue = 0;\r\n                            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).IsModified = true;\r\n                            taskservice.dbcontext.SaveChanges();\r\n                        }\r\n                    }\r\n                    else\r\n                    {\r\n                    \tvar sindex = sx.location.ToList().IndexOf(task.S_END_LOC);\r\n                        LocRepository locRepository = new LocRepository();\r\n                        //生成跳跃任务。  -- æ‰˜ç›˜è´§ä½è¡¨ã€‚ \r\n                        var t1s = taskservice.FindList(x => x.S_SRC_NO == task.S_TASK_NO);\r\n                        if (t1s.Any())\r\n                        {\r\n                            var t1 = t1s.OrderBy(x => x.T_CREATE).LastOrDefault();\r\n                            if (t1.S_END_LOC == task.S_END_LOC)\r\n                            {\r\n                                task.N_PRIORITY = 0;\r\n                                task.S_B_STATE = \"MES_完成\";\r\n                                taskservice.Update(task);\r\n                                continue;\r\n                            }\r\n                            if (t1.S_B_STATE == \"完成\")\r\n                            {\r\n                                //1.终点是否有托盘。 ä¾æ®æ˜¯ç»ˆç‚¹çš„任务是 ä½œä¸ºç»ˆç‚¹ï¼Œè¿˜æ˜¯èµ·ç‚¹ã€‚\r\n                                //var ec = taskservice.FindList(x => (x.S_START_LOC == task.S_START_LOC || x.S_END_LOC == task.S_END_LOC) /*&& DateTime.Now.Subtract(x.T_CREATE).TotalHours < 5*/).OrderByDescending(x => x.T_CREATE).FirstOrDefault();//($\"select top 1 * from TN_TASK WHERE S_START_LOC='{task.S_END_LOC}' OR S_END_LOC='{task.S_END_LOC}' ORDER BY T_CREATE DESC\");\r\n\t\t\t\t\t\t\t\t//var ec = taskservice.FindList(x => x.S_START_LOC == task.S_START_LOC && x.S_END_LOC == task.S_START_LOC, new Common.Data.Pagination\r\n        //                        {\r\n        //                            page = 1,\r\n        //                            sidx = \"T_CREATE\",\r\n        //                            sord = \"desc\",\r\n        //                            rows = 1\r\n        //                        }).FirstOrDefault();\r\n\t\t\t\t\t\t        TaskEntity ec = null;\r\n\t\t\t\t\t\t\t\tvar dev = Conn.默认Redis.GetValue(sx.deviceName + \".\" + (sindex == 0 ? \"D1224\" : \"D1225\"));\r\n\t\t\t\t\t\t\t\tif (dev?.Trim() == \"1\")\r\n\t\t\t\t\t\t\t\t    ec = taskservice.FindList(x =>x.S_END_LOC == task.S_END_LOC&&x.S_B_STATE==\"完成\", new Common.Data.Pagination\r\n\t\t\t\t\t\t\t\t    {\r\n\t\t\t\t\t\t\t\t        page = 1,\r\n\t\t\t\t\t\t\t\t        sidx = \"T_CREATE\",\r\n\t\t\t\t\t\t\t\t        sord = \"desc\",\r\n\t\t\t\t\t\t\t\t        rows = 1\r\n\t\t\t\t\t\t\t\t    }).FirstOrDefault();\r\n\t\t\t\t\t\t\t\tif (t1.S_START_LOC == task.S_START_LOC && ec != null)//!= task.S_END_LOC)\r\n                                {\r\n                                    //第二段。\r\n                                    LocEntity endLoc = null;\r\n                                    var di = sx;\r\n                                    if (di != null)\r\n                                    {\r\n                                        foreach (var ssloc in di.deviceNo)\r\n                                        {\r\n                                            var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);\r\n                                            if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == \"无\")\r\n                                            {\r\n                                                endLoc = endloc;\r\n                                                break;\r\n                                            }\r\n                                        }\r\n                                        if (endLoc != null)\r\n                                        {\r\n                                            var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_END_LOC, endLoc.S_LOC_CODE, task.S_TYPE + \"下空\", 7, ec.S_CNTRS.Split(',').ToList());\r\n                                            if (res)\r\n                                            {\r\n                                                task.N_PRIORITY = 0; taskservice.Update(task);\r\n                                            }\r\n                                        }\r\n                                    }\r\n                                }\r\n                                else\r\n                                {\r\n                                    var res = TaskProcess.CreateTask(task.S_TASK_NO, t1.S_END_LOC, task.S_END_LOC, task.S_TYPE + \"补满\", 6, task.S_CNTRS.Split(',').ToList());\r\n                                    if (res)\r\n                                    {\r\n                                        task.N_PRIORITY = 0; taskservice.Update(task);\r\n                                    }\r\n                                }\r\n                            }\r\n                        }\r\n                        else\r\n                        {\r\n                            //生成第一段。\r\n                            LocEntity endLoc = null;\r\n                            var di = sx;\r\n                            if (di != null)\r\n                            {\r\n                                foreach (var ssloc in di.deviceNo)\r\n                                {\r\n                                    var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);\r\n                                    if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == \"无\")\r\n                                    {\r\n                                        endLoc = endloc;\r\n                                        break;\r\n                                    }\r\n                                }\r\n                                if (endLoc != null)\r\n                                {\r\n                                    var res = TaskProcess.CreateTask(\"\", task.S_START_LOC, endLoc.S_LOC_CODE, task.S_TYPE + \"满转\", 8, task.S_CNTRS.Split(',').ToList());\r\n                                    if (res)\r\n                                    {\r\n                                        task.N_PRIORITY = 0; taskservice.Update(task);\r\n                                    }\r\n                                }\r\n                            }\r\n                        }\r\n\r\n                    }\r\n                }\r\n            //var VERX = Settings.deviceInfos?.FindAll(x => x.deviceName.Contains(\"捷瞬抓臂\"));\r\n            //if ()\r\n            ///2  çœ‹ç¼“存区。 æ²¡æ»¡çš„。\r\n\r\n\r\n        }\r\n        \r\n        ",
      "Code": "public class ToWMSMES\r\n{//2 wms  mes \r\n\r\n\r\n        public class CreateTask\r\n        {\r\n            public string taskType { get; set; }\r\n            public string startBit { get; set; }\r\n            public string endBit { get; set; }\r\n            public string reqCode { get; set; }\r\n            public string cntrCode { get; set; }\r\n\r\n            internal static ReturnMsg CreatemesTask(CreateTask model)\r\n            {\r\n                ITaskRepository taskservice = new TaskRepository();\r\n                var task = taskservice.FindEntity(x => x.S_TASK_NO == model.reqCode);\r\n                if (task == null)\r\n                {\r\n                    //var i = TaskProcess.CreateTask(\"\", model.startBit, model.endBit, string.IsNullOrEmpty(model.taskType) ? \"Mes下发\" : model.taskType, 5, new List<string> { model.cntrCode });\r\n                    TaskEntity wmsTask = new TaskEntity()\r\n                    {\r\n                        S_ID = Guid.NewGuid().ToString(),\r\n                        S_STATE = \"编辑\",\r\n                        T_CREATE = DateTime.Now,\r\n                        T_MODIFY = DateTime.Now,\r\n\r\n                        S_TASK_NO = model.reqCode,\r\n                        S_START_LAREA = \"\",\r\n                        S_END_LAREA = \"\",\r\n                        S_DEPART_NAME = \"\",\r\n                        S_START_LOC = model.startBit,\r\n                        S_END_LOC = model.endBit,\r\n                        S_TYPE = model.reqCode,\r\n                        S_SRC_NO = \"\",//\r\n                        N_PRIORITY = -88,\r\n                        S_WORK_MODE = \"agv\",\r\n                        S_B_STATE = \"MES\",\r\n                        S_CNTRS = model.cntrCode,\r\n                        N_START_LAYER = 1,\r\n                        N_END_LAYER = 1,\r\n                        N_CNTR_COUNT = 1\r\n                    };\r\n                    ITaskRepository taskserice = new TaskRepository();\r\n                    var i = taskserice.Insert(wmsTask) > 0;\r\n                    return new ReturnMsg { resultCode = (i ? 0 : -1), resultMsg = i ? \"\" : \"任务生成失败。\" };\r\n                }\r\n                else\r\n                {\r\n                    return new ReturnMsg { resultCode = -1, resultMsg = \"任务重复下发。\" };\r\n                }\r\n            }\r\n        \r\n        public class ReturnMsg\r\n        {\r\n            public int resultCode { get; set; }\r\n            public string resultMsg { get; set; }\r\n        }\r\n        \r\n        \r\n            internal static ReturnMsg CreatePointTask(CreateTask model)\r\n            {\r\n                ITaskRepository taskservice = new TaskRepository();\r\n                var task = taskservice.FindEntity(x => x.S_TASK_NO == model.reqCode);\r\n                if (task == null)\r\n                {\r\n                    //var i = TaskProcess.CreateTask(\"\", model.startBit, model.endBit, string.IsNullOrEmpty(model.taskType) ? \"Mes下发\" : model.taskType, 5, new List<string> { model.cntrCode });\r\n                    TaskEntity wmsTask = new TaskEntity()\r\n                    {\r\n                        S_ID = Guid.NewGuid().ToString(),\r\n                        S_STATE = \"编辑\",\r\n                        T_CREATE = DateTime.Now,\r\n                        T_MODIFY = DateTime.Now,\r\n                        S_TASK_NO = model.reqCode,\r\n                        S_START_LAREA = \"\",\r\n                        S_END_LAREA = \"\",\r\n                        S_DEPART_NAME = \"\",\r\n                        S_START_LOC = model.startBit,\r\n                        S_END_LOC = model.endBit,\r\n                        S_TYPE = model.reqCode,\r\n                        S_SRC_NO = \"\",//\r\n                        N_PRIORITY = -88,\r\n                        S_WORK_MODE = \"agv\",\r\n                        S_B_STATE = \"People\",\r\n                        S_CNTRS = model.cntrCode,\r\n                        N_START_LAYER = 1,\r\n                        N_END_LAYER = 1,\r\n                        N_CNTR_COUNT = 1\r\n                    };\r\n                    ITaskRepository taskserice = new TaskRepository();\r\n                    var i = taskserice.Insert(wmsTask) > 0;\r\n                    return new ReturnMsg { resultCode = (i ? 0 : -1), resultMsg = i ? \"\" : \"任务生成失败。\" };\r\n                }\r\n                else\r\n                {\r\n                    return new ReturnMsg { resultCode = -1, resultMsg = \"任务重复下发。\" };\r\n                }\r\n            }\r\n        }\r\n        public static void ResMesTask()\r\n        {\r\n            ///1.\r\n            TaskRepository taskservice = new TaskRepository();\r\n            var tasks = taskservice.FindList(x =>( x.S_B_STATE == \"MES\"|| x.S_B_STATE == \"People\") && x.N_PRIORITY == -88);\r\n            var VERXs = Settings.deviceInfos?.FindAll(x => x.deviceType==2);\r\n            //if (VERXs.Any())\r\n                foreach (var task in tasks)\r\n                {\r\n                    var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC));\r\n                    if (sx == null)\r\n                    {\r\n                        //直接生成对应任务。\r\n                        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS.Split(',').ToList());\r\n                        if (res)\r\n                        {\r\n                            //task.N_PRIORITY = 0;\r\n                            taskservice.dbcontext.Set<TaskEntity>().Attach(task);\r\n                            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).CurrentValue = 0;\r\n                            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).IsModified = true;\r\n                            taskservice.dbcontext.SaveChanges();\r\n                        }\r\n                    }\r\n                    else\r\n                    {\r\n                    \tvar sindex = sx.location.ToList().IndexOf(task.S_END_LOC);\r\n                        LocRepository locRepository = new LocRepository();\r\n                        //生成跳跃任务。  -- æ‰˜ç›˜è´§ä½è¡¨ã€‚ \r\n                        var t1s = taskservice.FindList(x => x.S_SRC_NO == task.S_TASK_NO);\r\n                        if (t1s.Any())\r\n                        {\r\n                            var t1 = t1s.OrderBy(x => x.T_CREATE).LastOrDefault();\r\n                            if (t1.S_END_LOC == task.S_END_LOC)\r\n                            {\r\n                                task.N_PRIORITY = 0;\r\n                                task.S_B_STATE = \"MES_完成\";\r\n                                taskservice.Update(task);\r\n                                continue;\r\n                            }\r\n                            if (t1.S_B_STATE == \"完成\")\r\n                            {\r\n                                //1.终点是否有托盘。 ä¾æ®æ˜¯ç»ˆç‚¹çš„任务是 ä½œä¸ºç»ˆç‚¹ï¼Œè¿˜æ˜¯èµ·ç‚¹ã€‚\r\n                                //var ec = taskservice.FindList(x => (x.S_START_LOC == task.S_START_LOC || x.S_END_LOC == task.S_END_LOC) /*&& DateTime.Now.Subtract(x.T_CREATE).TotalHours < 5*/).OrderByDescending(x => x.T_CREATE).FirstOrDefault();//($\"select top 1 * from TN_TASK WHERE S_START_LOC='{task.S_END_LOC}' OR S_END_LOC='{task.S_END_LOC}' ORDER BY T_CREATE DESC\");\r\n\t\t\t\t\t\t\t\t//var ec = taskservice.FindList(x => x.S_START_LOC == task.S_START_LOC && x.S_END_LOC == task.S_START_LOC, new Common.Data.Pagination\r\n        //                        {\r\n        //                            page = 1,\r\n        //                            sidx = \"T_CREATE\",\r\n        //                            sord = \"desc\",\r\n        //                            rows = 1\r\n        //                        }).FirstOrDefault();\r\n\t\t\t\t\t\t        TaskEntity ec = null;\r\n\t\t\t\t\t\t\t\tvar dev = Conn.默认Redis.GetValue(sx.deviceName + \".\" + (sindex == 0 ? \"D1224\" : \"D1225\"));\r\n\t\t\t\t\t\t\t\tif (dev?.Trim() == \"1\")\r\n\t\t\t\t\t\t\t\t    ec = taskservice.FindList(x =>x.S_END_LOC == task.S_END_LOC&&x.S_B_STATE==\"完成\", new Common.Data.Pagination\r\n\t\t\t\t\t\t\t\t    {\r\n\t\t\t\t\t\t\t\t        page = 1,\r\n\t\t\t\t\t\t\t\t        sidx = \"T_CREATE\",\r\n\t\t\t\t\t\t\t\t        sord = \"desc\",\r\n\t\t\t\t\t\t\t\t        rows = 1\r\n\t\t\t\t\t\t\t\t    }).FirstOrDefault();\r\n\t\t\t\t\t\t\t\tif (t1.S_START_LOC == task.S_START_LOC && ec != null)//!= task.S_END_LOC)\r\n                                {\r\n                                    //第二段。\r\n                                    LocEntity endLoc = null;\r\n                                    var di = sx;\r\n                                    if (di != null)\r\n                                    {\r\n                                        foreach (var ssloc in di.deviceNo)\r\n                                        {\r\n                                            var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);\r\n                                            if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == \"无\")\r\n                                            {\r\n                                                endLoc = endloc;\r\n                                                break;\r\n                                            }\r\n                                        }\r\n                                        if (endLoc != null)\r\n                                        {\r\n                                            var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_END_LOC, endLoc.S_LOC_CODE, task.S_TYPE + \"下空\", 7, ec.S_CNTRS.Split(',').ToList());\r\n                                            if (res)\r\n                                            {\r\n                                                task.N_PRIORITY = 0; taskservice.Update(task);\r\n                                            }\r\n                                        }\r\n                                    }\r\n                                }\r\n                                else\r\n                                {\r\n                                    var res = TaskProcess.CreateTask(task.S_TASK_NO, t1.S_END_LOC, task.S_END_LOC, task.S_TYPE + \"补满\", 6, task.S_CNTRS.Split(',').ToList());\r\n                                    if (res)\r\n                                    {\r\n                                        task.N_PRIORITY = 0; taskservice.Update(task);\r\n                                    }\r\n                                }\r\n                            }\r\n                        }\r\n                        else\r\n                        {\r\n                            //生成第一段。\r\n                            LocEntity endLoc = null;\r\n                            var di = sx;\r\n                            if (di != null)\r\n                            {\r\n                                foreach (var ssloc in di.deviceNo)\r\n                                {\r\n                                    var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);\r\n                                    if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == \"无\")\r\n                                    {\r\n                                        endLoc = endloc;\r\n                                        break;\r\n                                    }\r\n                                }\r\n                                if (endLoc != null)\r\n                                {\r\n                                    var res = TaskProcess.CreateTask(\"\", task.S_START_LOC, endLoc.S_LOC_CODE, task.S_TYPE + \"满转\", 8, task.S_CNTRS.Split(',').ToList());\r\n                                    if (res)\r\n                                    {\r\n                                        task.N_PRIORITY = 0; taskservice.Update(task);\r\n                                    }\r\n                                }\r\n                            }\r\n                        }\r\n\r\n                    }\r\n                }\r\n            //var VERX = Settings.deviceInfos?.FindAll(x => x.deviceName.Contains(\"捷瞬抓臂\"));\r\n            //if ()\r\n            ///2  çœ‹ç¼“存区。 æ²¡æ»¡çš„。\r\n\r\n\r\n        }\r\n        \r\n        \r\n}",
      "EditCode": "//2 wms  mes \r\n\r\n\r\n        public class CreateTask\r\n        {\r\n            public string taskType { get; set; }\r\n            public string startBit { get; set; }\r\n            public string endBit { get; set; }\r\n            public string reqCode { get; set; }\r\n            public string cntrCode { get; set; }\r\n\r\n            internal static ReturnMsg CreatemesTask(CreateTask model)\r\n            {\r\n                ITaskRepository taskservice = new TaskRepository();\r\n                var task = taskservice.FindEntity(x => x.S_TASK_NO == model.reqCode);\r\n                if (task == null)\r\n                {\r\n                    //var i = TaskProcess.CreateTask(\"\", model.startBit, model.endBit, string.IsNullOrEmpty(model.taskType) ? \"Mes下发\" : model.taskType, 5, new List<string> { model.cntrCode });\r\n                    TaskEntity wmsTask = new TaskEntity()\r\n                    {\r\n                        S_ID = Guid.NewGuid().ToString(),\r\n                        S_STATE = \"编辑\",\r\n                        T_CREATE = DateTime.Now,\r\n                        T_MODIFY = DateTime.Now,\r\n\r\n                        S_TASK_NO = model.reqCode,\r\n                        S_START_LAREA = \"\",\r\n                        S_END_LAREA = \"\",\r\n                        S_DEPART_NAME = \"\",\r\n                        S_START_LOC = model.startBit,\r\n                        S_END_LOC = model.endBit,\r\n                        S_TYPE = model.taskType,\r\n                        S_SRC_NO = \"\",//\r\n                        N_PRIORITY = -88,\r\n                        S_WORK_MODE = \"agv\",\r\n                        S_B_STATE = \"MES\",\r\n                        S_CNTRS = model.cntrCode,\r\n                        N_START_LAYER = 1,\r\n                        N_END_LAYER = 1,\r\n                        N_CNTR_COUNT = 1\r\n                    };\r\n                    ITaskRepository taskserice = new TaskRepository();\r\n                    var i = taskserice.Insert(wmsTask) > 0;\r\n                    return new ReturnMsg { resultCode = (i ? 0 : -1), resultMsg = i ? \"\" : \"任务生成失败。\" };\r\n                }\r\n                else\r\n                {\r\n                    return new ReturnMsg { resultCode = -1, resultMsg = \"任务重复下发。\" };\r\n                }\r\n            }\r\n        \r\n        public class ReturnMsg\r\n        {\r\n            public int resultCode { get; set; }\r\n            public string resultMsg { get; set; }\r\n        }\r\n        \r\n        \r\n            internal static ReturnMsg CreatePointTask(CreateTask model)\r\n            {\r\n                ITaskRepository taskservice = new TaskRepository();\r\n                var task = taskservice.FindEntity(x => x.S_TASK_NO == model.reqCode);\r\n                if (task == null)\r\n                {\r\n                    //var i = TaskProcess.CreateTask(\"\", model.startBit, model.endBit, string.IsNullOrEmpty(model.taskType) ? \"Mes下发\" : model.taskType, 5, new List<string> { model.cntrCode });\r\n                    TaskEntity wmsTask = new TaskEntity()\r\n                    {\r\n                        S_ID = Guid.NewGuid().ToString(),\r\n                        S_STATE = \"编辑\",\r\n                        T_CREATE = DateTime.Now,\r\n                        T_MODIFY = DateTime.Now,\r\n                        S_TASK_NO = model.reqCode,\r\n                        S_START_LAREA = \"\",\r\n                        S_END_LAREA = \"\",\r\n                        S_DEPART_NAME = \"\",\r\n                        S_START_LOC = model.startBit,\r\n                        S_END_LOC = model.endBit,\r\n                        S_TYPE = model.reqCode,\r\n                        S_SRC_NO = \"\",//\r\n                        N_PRIORITY = -88,\r\n                        S_WORK_MODE = \"agv\",\r\n                        S_B_STATE = \"People\",\r\n                        S_CNTRS = model.cntrCode,\r\n                        N_START_LAYER = 1,\r\n                        N_END_LAYER = 1,\r\n                        N_CNTR_COUNT = 1\r\n                    };\r\n                    ITaskRepository taskserice = new TaskRepository();\r\n                    var i = taskserice.Insert(wmsTask) > 0;\r\n                    return new ReturnMsg { resultCode = (i ? 0 : -1), resultMsg = i ? \"\" : \"任务生成失败。\" };\r\n                }\r\n                else\r\n                {\r\n                    return new ReturnMsg { resultCode = -1, resultMsg = \"任务重复下发。\" };\r\n                }\r\n            }\r\n        }\r\n        public static void ResMesTask()\r\n        {\r\n            ///1.\r\n            TaskRepository taskservice = new TaskRepository();\r\nvar tasks = taskservice.FindList(x => (x.S_B_STATE == \"MES\" || x.S_B_STATE == \"People\") && x.N_PRIORITY == -88);\r\nvar VERXs = Settings.deviceInfos?.FindAll(x => x.deviceType == 2);\r\n//if (VERXs.Any())\r\nforeach (var task in tasks)\r\n{\r\n    LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} \");\r\n    var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC));\r\n    LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} {(sx == null ? \"非\" : \"是\")}总装机器人任务\");\r\n    if (sx == null)\r\n    {\r\n        LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务\");\r\n        //直接生成对应任务。\r\n        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>());\r\n\r\n        LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务 ç»“果：{res}\");\r\n        if (res)\r\n        {\r\n            LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} ä¿®æ”¹æ ‡è¯†\");\r\n            //task.N_PRIORITY = 0;\r\n            taskservice.dbcontext.Set<TaskEntity>().Attach(task);\r\n            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).CurrentValue = 0;\r\n            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).IsModified = true;\r\n            taskservice.dbcontext.SaveChanges();\r\n        }\r\n    }\r\n    else\r\n    {\r\n        var sindex = sx.location.ToList().IndexOf(task.S_END_LOC);\r\n        LocRepository locRepository = new LocRepository();\r\n        //生成跳跃任务。  -- æ‰˜ç›˜è´§ä½è¡¨ã€‚ \r\n        var t1s = taskservice.FindList(x => x.S_SRC_NO == task.S_TASK_NO);\r\n\r\n        LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} æŸ¥æ‰¾æ˜¯å¦æœ‰å·²ç”Ÿæˆä»»åŠ¡ï¼š{t1s != null}\");\r\n        if (t1s.Any())\r\n        {\r\n            var t1 = t1s.OrderBy(x => x.T_CREATE).LastOrDefault();\r\n            if (t1.S_END_LOC == task.S_END_LOC)\r\n            {\r\n                task.N_PRIORITY = 0;\r\n                task.S_B_STATE = \"MES_完成\";\r\n                taskservice.Update(task);\r\n                continue;\r\n            }\r\n            if (t1.S_B_STATE == \"完成\")\r\n            {\r\n                //1.终点是否有托盘。 ä¾æ®æ˜¯ç»ˆç‚¹çš„任务是 ä½œä¸ºç»ˆç‚¹ï¼Œè¿˜æ˜¯èµ·ç‚¹ã€‚\r\n                //var ec = taskservice.FindList(x => (x.S_START_LOC == task.S_START_LOC || x.S_END_LOC == task.S_END_LOC) /*&& DateTime.Now.Subtract(x.T_CREATE).TotalHours < 5*/).OrderByDescending(x => x.T_CREATE).FirstOrDefault();//($\"select top 1 * from TN_TASK WHERE S_START_LOC='{task.S_END_LOC}' OR S_END_LOC='{task.S_END_LOC}' ORDER BY T_CREATE DESC\");\r\n                //var ec = taskservice.FindList(x => x.S_START_LOC == task.S_START_LOC && x.S_END_LOC == task.S_START_LOC, new Common.Data.Pagination\r\n                //                        {\r\n                //                            page = 1,\r\n                //                            sidx = \"T_CREATE\",\r\n                //                            sord = \"desc\",\r\n                //                            rows = 1\r\n                //                        }).FirstOrDefault();\r\n                TaskEntity ec = null;\r\n                var dev = Conn.默认Redis.GetValue(sx.deviceName + \".\" + (sindex == 0 ? \"D1224\" : \"D1225\"));\r\n                if (dev?.Trim() == \"1\")\r\n                    ec = taskservice.FindList(x => x.S_END_LOC == task.S_END_LOC && x.S_B_STATE == \"完成\", new Common.Data.Pagination\r\n                    {\r\n                        page = 1,\r\n                        sidx = \"T_CREATE\",\r\n                        sord = \"desc\",\r\n                        rows = 1\r\n                    }).FirstOrDefault();\r\n                if (t1.S_START_LOC == task.S_START_LOC && ec != null)//!= task.S_END_LOC)\r\n                {\r\n                    //第二段。\r\n                    LocEntity endLoc = null;\r\n                    var di = sx;\r\n                    if (di != null)\r\n                    {\r\n                        foreach (var ssloc in di.deviceNo)\r\n                        {\r\n                            var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);\r\n                            if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == \"无\")\r\n                            {\r\n                                endLoc = endloc;\r\n                                break;\r\n                            }\r\n                        }\r\n                        if (endLoc != null)\r\n                        {\r\n                            var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_END_LOC, endLoc.S_LOC_CODE, task.S_TYPE + \"下空\", 7, ec.S_CNTRS.Split(',').ToList());\r\n                            if (res)\r\n                            {\r\n                                task.N_PRIORITY = 0; taskservice.Update(task);\r\n                            }\r\n                        }\r\n                    }\r\n                }\r\n                else\r\n                {\r\n                    var res = TaskProcess.CreateTask(task.S_TASK_NO, t1.S_END_LOC, task.S_END_LOC, task.S_TYPE + \"补满\", 6, task.S_CNTRS.Split(',').ToList());\r\n                    if (res)\r\n                    {\r\n                        task.N_PRIORITY = 0; taskservice.Update(task);\r\n                    }\r\n                }\r\n            }\r\n        }\r\n        else\r\n        {\r\n            LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} ç­›é€‰ç”Ÿæˆç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚\");\r\n            //生成第一段。\r\n            LocEntity endLoc = null;\r\n            var di = sx;\r\n            if (di != null)\r\n            {\r\n                foreach (var ssloc in di.deviceNo)\r\n                {\r\n                    var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);\r\n                    if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == \"无\")\r\n                    {\r\n                        endLoc = endloc;\r\n                        break;\r\n                    }\r\n                }\r\n                if (endLoc != null)\r\n                {\r\n                    LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} åˆ›å»ºç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚\");\r\n                    var res = TaskProcess.CreateTask(\"\", task.S_START_LOC, endLoc.S_LOC_CODE, task.S_TYPE + \"满转\", 8, task.S_CNTRS.Split(',').ToList());\r\n\r\n                    LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} åˆ›å»ºç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚结果：{res}\");\r\n                    if (res)\r\n                    {\r\n                        task.N_PRIORITY = 0; taskservice.Update(task);\r\n                    }\r\n                }\r\n            }\r\n        }\r\n\r\n    }\r\n}\r\n            //var VERX = Settings.deviceInfos?.FindAll(x => x.deviceName.Contains(\"捷瞬抓臂\"));\r\n            //if ()\r\n            ///2  çœ‹ç¼“存区。 æ²¡æ»¡çš„。\r\n\r\n\r\n        }\r\n        \r\n        ",
      "Code": "public class ToWMSMES\r\n{//2 wms  mes \r\n\r\n\r\n        public class CreateTask\r\n        {\r\n            public string taskType { get; set; }\r\n            public string startBit { get; set; }\r\n            public string endBit { get; set; }\r\n            public string reqCode { get; set; }\r\n            public string cntrCode { get; set; }\r\n\r\n            internal static ReturnMsg CreatemesTask(CreateTask model)\r\n            {\r\n                ITaskRepository taskservice = new TaskRepository();\r\n                var task = taskservice.FindEntity(x => x.S_TASK_NO == model.reqCode);\r\n                if (task == null)\r\n                {\r\n                    //var i = TaskProcess.CreateTask(\"\", model.startBit, model.endBit, string.IsNullOrEmpty(model.taskType) ? \"Mes下发\" : model.taskType, 5, new List<string> { model.cntrCode });\r\n                    TaskEntity wmsTask = new TaskEntity()\r\n                    {\r\n                        S_ID = Guid.NewGuid().ToString(),\r\n                        S_STATE = \"编辑\",\r\n                        T_CREATE = DateTime.Now,\r\n                        T_MODIFY = DateTime.Now,\r\n\r\n                        S_TASK_NO = model.reqCode,\r\n                        S_START_LAREA = \"\",\r\n                        S_END_LAREA = \"\",\r\n                        S_DEPART_NAME = \"\",\r\n                        S_START_LOC = model.startBit,\r\n                        S_END_LOC = model.endBit,\r\n                        S_TYPE = model.taskType,\r\n                        S_SRC_NO = \"\",//\r\n                        N_PRIORITY = -88,\r\n                        S_WORK_MODE = \"agv\",\r\n                        S_B_STATE = \"MES\",\r\n                        S_CNTRS = model.cntrCode,\r\n                        N_START_LAYER = 1,\r\n                        N_END_LAYER = 1,\r\n                        N_CNTR_COUNT = 1\r\n                    };\r\n                    ITaskRepository taskserice = new TaskRepository();\r\n                    var i = taskserice.Insert(wmsTask) > 0;\r\n                    return new ReturnMsg { resultCode = (i ? 0 : -1), resultMsg = i ? \"\" : \"任务生成失败。\" };\r\n                }\r\n                else\r\n                {\r\n                    return new ReturnMsg { resultCode = -1, resultMsg = \"任务重复下发。\" };\r\n                }\r\n            }\r\n        \r\n        public class ReturnMsg\r\n        {\r\n            public int resultCode { get; set; }\r\n            public string resultMsg { get; set; }\r\n        }\r\n        \r\n        \r\n            internal static ReturnMsg CreatePointTask(CreateTask model)\r\n            {\r\n                ITaskRepository taskservice = new TaskRepository();\r\n                var task = taskservice.FindEntity(x => x.S_TASK_NO == model.reqCode);\r\n                if (task == null)\r\n                {\r\n                    //var i = TaskProcess.CreateTask(\"\", model.startBit, model.endBit, string.IsNullOrEmpty(model.taskType) ? \"Mes下发\" : model.taskType, 5, new List<string> { model.cntrCode });\r\n                    TaskEntity wmsTask = new TaskEntity()\r\n                    {\r\n                        S_ID = Guid.NewGuid().ToString(),\r\n                        S_STATE = \"编辑\",\r\n                        T_CREATE = DateTime.Now,\r\n                        T_MODIFY = DateTime.Now,\r\n                        S_TASK_NO = model.reqCode,\r\n                        S_START_LAREA = \"\",\r\n                        S_END_LAREA = \"\",\r\n                        S_DEPART_NAME = \"\",\r\n                        S_START_LOC = model.startBit,\r\n                        S_END_LOC = model.endBit,\r\n                        S_TYPE = model.reqCode,\r\n                        S_SRC_NO = \"\",//\r\n                        N_PRIORITY = -88,\r\n                        S_WORK_MODE = \"agv\",\r\n                        S_B_STATE = \"People\",\r\n                        S_CNTRS = model.cntrCode,\r\n                        N_START_LAYER = 1,\r\n                        N_END_LAYER = 1,\r\n                        N_CNTR_COUNT = 1\r\n                    };\r\n                    ITaskRepository taskserice = new TaskRepository();\r\n                    var i = taskserice.Insert(wmsTask) > 0;\r\n                    return new ReturnMsg { resultCode = (i ? 0 : -1), resultMsg = i ? \"\" : \"任务生成失败。\" };\r\n                }\r\n                else\r\n                {\r\n                    return new ReturnMsg { resultCode = -1, resultMsg = \"任务重复下发。\" };\r\n                }\r\n            }\r\n        }\r\n        public static void ResMesTask()\r\n        {\r\n            ///1.\r\n            TaskRepository taskservice = new TaskRepository();\r\nvar tasks = taskservice.FindList(x => (x.S_B_STATE == \"MES\" || x.S_B_STATE == \"People\") && x.N_PRIORITY == -88);\r\nvar VERXs = Settings.deviceInfos?.FindAll(x => x.deviceType == 2);\r\n//if (VERXs.Any())\r\nforeach (var task in tasks)\r\n{\r\n    LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} \");\r\n    var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC));\r\n    LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} {(sx == null ? \"非\" : \"是\")}总装机器人任务\");\r\n    if (sx == null)\r\n    {\r\n        LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务\");\r\n        //直接生成对应任务。\r\n        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>());\r\n\r\n        LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务 ç»“果：{res}\");\r\n        if (res)\r\n        {\r\n            LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} ä¿®æ”¹æ ‡è¯†\");\r\n            //task.N_PRIORITY = 0;\r\n            taskservice.dbcontext.Set<TaskEntity>().Attach(task);\r\n            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).CurrentValue = 0;\r\n            taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).IsModified = true;\r\n            taskservice.dbcontext.SaveChanges();\r\n        }\r\n    }\r\n    else\r\n    {\r\n        var sindex = sx.location.ToList().IndexOf(task.S_END_LOC);\r\n        LocRepository locRepository = new LocRepository();\r\n        //生成跳跃任务。  -- æ‰˜ç›˜è´§ä½è¡¨ã€‚ \r\n        var t1s = taskservice.FindList(x => x.S_SRC_NO == task.S_TASK_NO);\r\n\r\n        LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} æŸ¥æ‰¾æ˜¯å¦æœ‰å·²ç”Ÿæˆä»»åŠ¡ï¼š{t1s != null}\");\r\n        if (t1s.Any())\r\n        {\r\n            var t1 = t1s.OrderBy(x => x.T_CREATE).LastOrDefault();\r\n            if (t1.S_END_LOC == task.S_END_LOC)\r\n            {\r\n                task.N_PRIORITY = 0;\r\n                task.S_B_STATE = \"MES_完成\";\r\n                taskservice.Update(task);\r\n                continue;\r\n            }\r\n            if (t1.S_B_STATE == \"完成\")\r\n            {\r\n                //1.终点是否有托盘。 ä¾æ®æ˜¯ç»ˆç‚¹çš„任务是 ä½œä¸ºç»ˆç‚¹ï¼Œè¿˜æ˜¯èµ·ç‚¹ã€‚\r\n                //var ec = taskservice.FindList(x => (x.S_START_LOC == task.S_START_LOC || x.S_END_LOC == task.S_END_LOC) /*&& DateTime.Now.Subtract(x.T_CREATE).TotalHours < 5*/).OrderByDescending(x => x.T_CREATE).FirstOrDefault();//($\"select top 1 * from TN_TASK WHERE S_START_LOC='{task.S_END_LOC}' OR S_END_LOC='{task.S_END_LOC}' ORDER BY T_CREATE DESC\");\r\n                //var ec = taskservice.FindList(x => x.S_START_LOC == task.S_START_LOC && x.S_END_LOC == task.S_START_LOC, new Common.Data.Pagination\r\n                //                        {\r\n                //                            page = 1,\r\n                //                            sidx = \"T_CREATE\",\r\n                //                            sord = \"desc\",\r\n                //                            rows = 1\r\n                //                        }).FirstOrDefault();\r\n                TaskEntity ec = null;\r\n                var dev = Conn.默认Redis.GetValue(sx.deviceName + \".\" + (sindex == 0 ? \"D1224\" : \"D1225\"));\r\n                if (dev?.Trim() == \"1\")\r\n                    ec = taskservice.FindList(x => x.S_END_LOC == task.S_END_LOC && x.S_B_STATE == \"完成\", new Common.Data.Pagination\r\n                    {\r\n                        page = 1,\r\n                        sidx = \"T_CREATE\",\r\n                        sord = \"desc\",\r\n                        rows = 1\r\n                    }).FirstOrDefault();\r\n                if (t1.S_START_LOC == task.S_START_LOC && ec != null)//!= task.S_END_LOC)\r\n                {\r\n                    //第二段。\r\n                    LocEntity endLoc = null;\r\n                    var di = sx;\r\n                    if (di != null)\r\n                    {\r\n                        foreach (var ssloc in di.deviceNo)\r\n                        {\r\n                            var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);\r\n                            if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == \"无\")\r\n                            {\r\n                                endLoc = endloc;\r\n                                break;\r\n                            }\r\n                        }\r\n                        if (endLoc != null)\r\n                        {\r\n                            var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_END_LOC, endLoc.S_LOC_CODE, task.S_TYPE + \"下空\", 7, ec.S_CNTRS.Split(',').ToList());\r\n                            if (res)\r\n                            {\r\n                                task.N_PRIORITY = 0; taskservice.Update(task);\r\n                            }\r\n                        }\r\n                    }\r\n                }\r\n                else\r\n                {\r\n                    var res = TaskProcess.CreateTask(task.S_TASK_NO, t1.S_END_LOC, task.S_END_LOC, task.S_TYPE + \"补满\", 6, task.S_CNTRS.Split(',').ToList());\r\n                    if (res)\r\n                    {\r\n                        task.N_PRIORITY = 0; taskservice.Update(task);\r\n                    }\r\n                }\r\n            }\r\n        }\r\n        else\r\n        {\r\n            LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} ç­›é€‰ç”Ÿæˆç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚\");\r\n            //生成第一段。\r\n            LocEntity endLoc = null;\r\n            var di = sx;\r\n            if (di != null)\r\n            {\r\n                foreach (var ssloc in di.deviceNo)\r\n                {\r\n                    var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);\r\n                    if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == \"无\")\r\n                    {\r\n                        endLoc = endloc;\r\n                        break;\r\n                    }\r\n                }\r\n                if (endLoc != null)\r\n                {\r\n                    LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} åˆ›å»ºç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚\");\r\n                    var res = TaskProcess.CreateTask(\"\", task.S_START_LOC, endLoc.S_LOC_CODE, task.S_TYPE + \"满转\", 8, task.S_CNTRS.Split(',').ToList());\r\n\r\n                    LogHelper.Info($\"解释MES任务 ->{task.S_TASK_NO} åˆ›å»ºç¬¬ä¸€æ®µ ä»»åŠ¡ã€‚结果：{res}\");\r\n                    if (res)\r\n                    {\r\n                        task.N_PRIORITY = 0; taskservice.Update(task);\r\n                    }\r\n                }\r\n            }\r\n        }\r\n\r\n    }\r\n}\r\n            //var VERX = Settings.deviceInfos?.FindAll(x => x.deviceName.Contains(\"捷瞬抓臂\"));\r\n            //if ()\r\n            ///2  çœ‹ç¼“存区。 æ²¡æ»¡çš„。\r\n\r\n\r\n        }\r\n        \r\n        \r\n}",
      "CusMethod": {
        "Name": "",
        "Params": [],
@@ -692,6 +692,6 @@
    }
  ],
  "CreationTime": "2025-02-26 15:31:23",
  "LastWriteTime": "2025-06-23 09:18:50",
  "LastWriteTime": "2025-06-25 10:42:44",
  "HasSaved": true
}

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Scripts/Script.json

@@ -178,8 +178,8 @@
              "ID": "20250325085810885",
              "Name": "自流转流程",
              "Desc": "",
              "Content": "//foreach(var di in Settings.deviceInfos)\r\n//\tif (di.deviceType == 2 || di.deviceType == 1)\r\n//\tRunafterMac(di,true);\r\n\t/// TODO  mes ä¸‹å‘。   æ”¹æˆæœºæ¢°è‡‚监控 -  ç›‘控空的还是满的 - è”动mes ä»»åŠ¡ã€‚",
              "ContentCopy": "//foreach(var di in Settings.deviceInfos)\r\n//\tif (di.deviceType == 2 || di.deviceType == 1)\r\n//\tRunafterMac(di,true);\r\n\t/// TODO  mes ä¸‹å‘。   æ”¹æˆæœºæ¢°è‡‚监控 -  ç›‘控空的还是满的 - è”动mes ä»»åŠ¡ã€‚",
              "Content": "//foreach(var di in Settings.deviceInfos)\r\n//\tif (di.deviceType == 2 || di.deviceType == 1)\r\n//\tRunafterMac(di,true);\r\n\t/// TODO  mes ä¸‹å‘。   æ”¹æˆæœºæ¢°è‡‚监控 -  ç›‘控空的还是满的 - è”动mes ä»»åŠ¡ã€‚\r\n\t\r\n                        LogHelper.Info($\"设备状态：维希尔1：维希尔抓臂1.State:{Device.维希尔抓臂1.State} \");\r\n                        Device.维希尔抓臂1.ReadPLC(\"维希尔抓臂1.R50\", out object value);\r\n                        LogHelper.Info($\"设备状态：维希尔1：维希尔抓臂1.R50:{value?.ToString()} \");\r\n\r\n                        LogHelper.Info($\"设备状态：维希尔2：维希尔抓臂2.State:{Device.维希尔抓臂2.State} \");\r\n                        Device.维希尔抓臂2.ReadPLC(\"维希尔抓臂2.R50\", out value);\r\n                        LogHelper.Info($\"设备状态：维希尔2：维希尔抓臂2.R50:{value?.ToString()} \");\r\n\r\n                        LogHelper.Info($\"设备状态：捷瞬1：Js捷顺1.State:{Device.Js捷顺1.State} \");\r\n                        Device.Js捷顺1.ReadPLC(\"Js捷顺1.D1202\", out value);\r\n                        LogHelper.Info($\"设备状态：捷瞬1 Js捷顺1.D1202:{value?.ToString()} \");\r\n\r\n                        LogHelper.Info($\"设备状态：捷瞬2：Js捷顺2.State:{Device.Js捷顺2.State} \");\r\n                        Device.Js捷顺2.ReadPLC(\"Js捷顺2.D1202\", out value);\r\n                        LogHelper.Info($\"设备状态：捷瞬2 Js捷顺2.D1202:{value?.ToString()} \");\r\n\r\n",
              "ContentCopy": "//foreach(var di in Settings.deviceInfos)\r\n//\tif (di.deviceType == 2 || di.deviceType == 1)\r\n//\tRunafterMac(di,true);\r\n\t/// TODO  mes ä¸‹å‘。   æ”¹æˆæœºæ¢°è‡‚监控 -  ç›‘控空的还是满的 - è”动mes ä»»åŠ¡ã€‚\r\n\t\r\n                        LogHelper.Info($\"设备状态：维希尔1：维希尔抓臂1.State:{Device.维希尔抓臂1.State} \");\r\n                        Device.维希尔抓臂1.ReadPLC(\"维希尔抓臂1.R50\", out object value);\r\n                        LogHelper.Info($\"设备状态：维希尔1：维希尔抓臂1.R50:{value?.ToString()} \");\r\n\r\n                        LogHelper.Info($\"设备状态：维希尔2：维希尔抓臂2.State:{Device.维希尔抓臂2.State} \");\r\n                        Device.维希尔抓臂2.ReadPLC(\"维希尔抓臂2.R50\", out value);\r\n                        LogHelper.Info($\"设备状态：维希尔2：维希尔抓臂2.R50:{value?.ToString()} \");\r\n\r\n                        LogHelper.Info($\"设备状态：捷瞬1：Js捷顺1.State:{Device.Js捷顺1.State} \");\r\n                        Device.Js捷顺1.ReadPLC(\"Js捷顺1.D1202\", out value);\r\n                        LogHelper.Info($\"设备状态：捷瞬1 Js捷顺1.D1202:{value?.ToString()} \");\r\n\r\n                        LogHelper.Info($\"设备状态：捷瞬2：Js捷顺2.State:{Device.Js捷顺2.State} \");\r\n                        Device.Js捷顺2.ReadPLC(\"Js捷顺2.D1202\", out value);\r\n                        LogHelper.Info($\"设备状态：捷瞬2 Js捷顺2.D1202:{value?.ToString()} \");\r\n\r\n",
              "ParentID": "20250325083047245",
              "Children": [],
              "Type": "Program",
@@ -1410,6 +1410,6 @@
    }
  ],
  "CreationTime": "2025-02-26 15:31:20",
  "LastWriteTime": "2025-06-23 08:38:47",
  "LastWriteTime": "2025-06-25 10:42:44",
  "HasSaved": true
}