优化代码

dengjunjie

2024-03-05 db6156a92cc59467bde608a00c76952ebc75e488

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
using Newtonsoft.Json;
using WIDESEA_Comm.LogInfo;
using WIDESEA_Common;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Entity.ToAGV;
using WIDESEA_WMS.Common;
using WIDESEA_WMS.Common.AGVTask;
using WIDESEA_WMS.IRepositories;
using WIDESEA_WMS.Repositories;
 
namespace WIDESEA_WMS
{
    public partial class ToAGVServer
    {
        /// <summary>
        /// 修改任务状态
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        public static AGVRespone UpdateTaskState(string json)
        {
            VOLContext context = new VOLContext();
            Idt_agvtaskRepository repository = new dt_agvtaskRepository(context);
            AGVRespone respone = new AGVRespone();
            UpdateTasteInfo tasteInfo = new();
            try
            {
                if (string.IsNullOrEmpty(json) || json == "null")
                    throw new Exception("未获取到请求参数数据");
                tasteInfo = JsonConvert.DeserializeObject<UpdateTasteInfo>(json);
                if (tasteInfo == null)
                    throw new Exception("请求参数格式不对！");
                if (string.IsNullOrEmpty(tasteInfo.TASK_NO))
                    throw new Exception("未获取到任务号!");
                var task = repository.FindFirst(x => x.agv_tasknum == tasteInfo.TASK_NO);
                if (task == null)
                    throw new Exception("未找到任务,任务ID：" + tasteInfo.TASK_NO);
                if (tasteInfo.TASK_State < 1 || tasteInfo.TASK_State > 4)
                    throw new Exception("未定义的任务状态:" + tasteInfo.TASK_State);
                var StateName = Enum.GetName(typeof(AGVTaskStateEnum), tasteInfo.TASK_State);
                if (task.agv_taskstate == StateName && task.agv_taskstate != AGVTaskStateEnum.Complete1.ToString())
                {
                    respone.success = 2;
                    respone.Message = tasteInfo.TASK_NO + "：重复调用，任务状态为：" + tasteInfo.TASK_State;
                    return respone;
                }
                #region 判断任务状态
                //List<string> list = new List<string>() { AGVTaskStateEnum.Executing.ToString(), AGVTaskStateEnum.Complete.ToString(), AGVTaskStateEnum.Executing1.ToString(), AGVTaskStateEnum.Complete1.ToString() };
                //var index = list.IndexOf(task.agv_taskstate) + 1;
                //if (tasteInfo.TASK_State < index)
                //    throw new Exception("任务状态更新异常！当前任务状态为：" + index + ";请求更新状态为：" + tasteInfo.TASK_State);
                #endregion
                if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Executing)
                    task.agv_executingBeginTime = DateTime.Now;
                else if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Complete)
                    task.agv_executingEndTime = DateTime.Now;
                else if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Executing1)
                    task.agv_completeBeginTime = DateTime.Now;
                task.agv_taskstate = StateName;
                var count = repository.Update(task, true);
                if (count < 1)
                    throw new Exception("任务状态更新失败！任务ID：" + tasteInfo.TASK_NO + "；任务状态：" + tasteInfo.TASK_State);
                if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Complete1)
                {
                    task.agv_finishedtime = DateTime.Now;
                    //HandleTask_Mes.UploadMESInfo(task);
                    HandleTask.Updateinventory(task);
                    HandleTask.AutoUpdateHCJState(task);
                    HandleTask.AddHtyTask(task);
                }
            }
            catch (Exception ex)
            {
                respone.success = 3;
                respone.Message = ex.Message;
            }
            finally
            {
                WriteWMSLog.LogAdd(tasteInfo.TASK_NO, respone.success == 1 ? "成功 " : "失败", "WMS", "AGV", json, JsonConvert.SerializeObject(respone), "AGV反馈任务状态", "UpdateTaskState", respone.Message);
            }
            return respone;
        }
    }
}