库卡哈尔滨CTU库项目
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
wangxinhui
2 天以前 6d3ea08855337c0cfcc60df2903d3431611c7097 
 ÏîÄ¿´úÂë/WCSServices/WIDESEAWCS_TaskInfoService/TaskService.cs


@@ -15,15 +15,19 @@


 *----------------------------------------------------------------*/


#endregion << ç‰ˆ æœ¬ æ³¨ é‡Š >>


using AutoMapper;


using Microsoft.AspNetCore.Mvc;


using Newtonsoft.Json;


using NPOI.SS.Formula.Functions;


using SqlSugar;


using System.Diagnostics.CodeAnalysis;


using System.DirectoryServices.Protocols;


using System.Linq;


using System.Net.Http.Headers;


using System.Security.Policy;


using System.Threading.Tasks;


using WIDESEA_DTO.Agv;


using WIDESEA_External.Model;


using WIDESEAWCS_BasicInfoService;


using WIDESEAWCS_Common;


using WIDESEAWCS_Common.APIEnum;


using WIDESEAWCS_Common.TaskEnum;


@@ -37,6 +41,7 @@


using WIDESEAWCS_DTO.Agv;


using WIDESEAWCS_DTO.TaskInfo;


using WIDESEAWCS_IBasicInfoRepository;


using WIDESEAWCS_IBasicInfoService;


using WIDESEAWCS_ITaskInfoRepository;


using WIDESEAWCS_ITaskInfoService;


using WIDESEAWCS_Model.Models;


@@ -59,6 +64,8 @@


        private readonly IRouterRepository _routerRepository;


        private readonly IApiInfoRepository _apiInfoRepository;


        private readonly ILocationInfoRepository _locationInfoRepository;


        private readonly ILocationInfoService _locationInfoService;


        private readonly ILocationStatusChangeRecordService _locationStatusChangeRecordService;




        private Dictionary<string, OrderByType> _taskOrderBy = new()


            {


@@ -76,7 +83,7 @@




        public List<int> TaskRelocationTypes => typeof(TaskTypeEnum).GetEnumIndexList().Where(x => x >= 900 && x < 1000).ToList();




        public TaskService(ITaskRepository BaseDal, IMapper mapper, ICacheService cacheService, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository, IApiInfoRepository apiInfoRepository,ILocationInfoRepository locationInfoRepository,IUnitOfWorkManage unitOfWorkManage) : base(BaseDal)


        public TaskService(ITaskRepository BaseDal, IMapper mapper, ICacheService cacheService, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository, IApiInfoRepository apiInfoRepository,ILocationInfoRepository locationInfoRepository,IUnitOfWorkManage unitOfWorkManage, ILocationInfoService locationInfoService,ILocationStatusChangeRecordService locationStatusChangeRecordService) : base(BaseDal)


        {


            _mapper = mapper;


            _cacheService = cacheService;


@@ -88,6 +95,8 @@


            _apiInfoRepository = apiInfoRepository;


            _locationInfoRepository = locationInfoRepository;


            _unitOfWorkManage = unitOfWorkManage;


            _locationInfoService = locationInfoService;


            _locationStatusChangeRecordService=locationStatusChangeRecordService;


        }


        static object lock_taskReceive = new object();


        /// <summary>


@@ -98,27 +107,38 @@


        public WebResponseContent ReceiveWMSTask([NotNull] WMSTaskDTO taskDTO)


        {


            WebResponseContent content = new WebResponseContent();


            string errorMsg = "";


            try


            {


                lock (lock_taskReceive)


                {


                    List<Dt_Task> tasks = new List<Dt_Task>();


                    List<Dt_LocationInfo> locationInfos = _locationInfoRepository.GetCanOut(taskDTO.Tasks.Select(x=>x.ContainerCode).ToList());


                    TasksItem? tasksItem = taskDTO.Tasks.FirstOrDefault(x => !locationInfos.Select(t => t.PalletCode).Contains(x.ContainerCode));


                    if (tasksItem != null) throw new Exception($"任务{tasksItem.TaskCode}料箱号{tasksItem.ContainerCode}不存在");


                    Dt_Task taskOld = BaseDal.QueryFirst(x=> taskDTO.Tasks.Select(x => x.TaskDescribe.ContainerCode).Contains(x.PalletCode));


                    if (taskOld != null) throw new Exception($"料箱{taskOld.PalletCode}"+(taskOld.TaskType == TaskTypeEnum.Inbound.ObjToInt() ? "入库任务已存在" : "出库任务已存在"));


                    List<Dt_LocationInfo> locationInfos = _locationInfoRepository.GetCanOut(taskDTO.Tasks.Select(x=>x.TaskDescribe.ContainerCode).ToList());


                    


                    Dt_LocationInfo? noOutLocation = locationInfos.FirstOrDefault(x=>x.LocationStatus != LocationStatusEnum.InStock.ObjToInt() || x.EnableStatus != EnableStatusEnum.Normal.ObjToInt());




                    if (noOutLocation != null) throw new Exception($"料箱{noOutLocation.PalletCode}货位{noOutLocation.LocationCode}状态不可出库");


                    List<Dt_StationManger> stationMangers = _stationMangerRepository.QueryData();


                    //下发任务组


                    string taskGroup= taskDTO.TaskGroupCode.IsNullOrEmpty() ? Guid.NewGuid().ToString().Replace("-","") : taskDTO.TaskGroupCode;


                    foreach (var item in taskDTO.Tasks)


                    foreach (var item in taskDTO.Tasks.OrderBy(x=>x.TaskDescribe.ToStationCode))


                    {


                        if (item.ToStationCode.IsNullOrEmpty()) throw new Exception($"任务{item.TaskCode}出库目标操作台不能为空");


                        if (item.TaskDescribe.ToStationCode.IsNullOrEmpty()) throw new Exception($"任务{item.TaskCode}出库目标操作台不能为空");


                        //获取操作台


                        Dt_StationManger? stationManger = stationMangers.FirstOrDefault(x => x.PickStationCode == item.ToStationCode);


                        if (stationManger == null) throw new Exception($"任务{item.TaskCode}出库目标操作台{item.ToStationCode}不存在");


                        Dt_StationManger? stationManger = stationMangers.FirstOrDefault(x => x.PickStationCode == item.TaskDescribe.ToStationCode);


                        if (stationManger == null) throw new Exception($"任务{item.TaskCode}出库目标操作台{item.TaskDescribe.ToStationCode}不存在");




                        Dt_LocationInfo? locationInfo = locationInfos.FirstOrDefault(x => x.PalletCode == item.TaskDescribe.ContainerCode);


                        if (locationInfo == null)


                        {


                            errorMsg += $"料箱{item.TaskDescribe.ContainerCode}不存在;";


                            continue;


                        };




                        Dt_Task task = _mapper.Map<Dt_Task>(item);


                        Dt_LocationInfo locationInfo = locationInfos.FirstOrDefault(x=>x.PalletCode==item.ContainerCode);


                        


                        task.SourceAddress = locationInfo.LocationCode;


                        task.CurrentAddress = locationInfo.LocationCode;


                        task.NextAddress = stationManger.PickStationCode;


@@ -126,7 +146,7 @@


                        task.GroupId = taskGroup;


                        task.TaskType = TaskTypeEnum.Outbound.ObjToInt();


                        task.Roadway = locationInfo.RoadwayNo;


                        task.DeviceCode = "AGV";


                        task.DeviceCode = stationManger.CraneCode;


                        task.TaskState = TaskStatusEnum.AGV_Execute.ObjToInt();


                        tasks.Add(task);


                    }


@@ -140,10 +160,9 @@


                    BaseDal.AddData(tasks);


                    _locationInfoRepository.UpdateData(locationInfos);


                    _unitOfWorkManage.CommitTran();




                    _taskExecuteDetailService.AddTaskExecuteDetail(tasks.Select(x => x.TaskNum).ToList(), "接收WMS任务");




                    content = tasks.Count > 0 ? content.OK("成功") : content.Error("失败");


                    _locationStatusChangeRecordService.AddLocationStatusChangeRecord(locationInfos, LocationStatusEnum.InStock, LocationStatusEnum.Lock, LocationChangeType.OutboundAssignLocation, tasks.Select(x => x.TaskNum).ToList());


                    content = tasks.Count > 0 ? content.OK("成功!"+(errorMsg.IsNullOrEmpty()? "": errorMsg)) : content.Error("失败");


                }


            }


            catch (Exception ex)


@@ -152,30 +171,159 @@


            }


            return content;


        }


       


        


        /// <summary>


        /// å®¹å™¨å…¥åº“创建任务


        /// </summary>


        /// <returns></returns>


        public WebResponseContent ContainerFlow(ContainerFlowDTO containerFlowDTO, string deviceCode, string stationCode)


        {


            WebResponseContent content = new WebResponseContent();


            try


            {


                List<Dt_LocationInfo> locationInfos = _locationInfoRepository.QueryData();


                Dt_LocationInfo? locationInfo = locationInfos.FirstOrDefault(x => x.PalletCode == containerFlowDTO.ContainerCode);


                if (locationInfo != null) throw new Exception($"库位料箱号{containerFlowDTO.ContainerCode}已存在");


                if (BaseDal.QueryFirst(x => x.PalletCode == containerFlowDTO.ContainerCode && x.TaskType == TaskTypeEnum.Inbound.ObjToInt() && x.TaskState == TaskStatusEnum.CL_Executing.ObjToInt() && x.DeviceCode== deviceCode) != null)


                {


                    return content.OK();


                }


                else if(BaseDal.QueryFirst(x => x.PalletCode == containerFlowDTO.ContainerCode) != null)


                {


                    throw new Exception($"料箱号{containerFlowDTO.ContainerCode}任务已存在");


                }


                Dt_LocationInfo? noInLocation = locationInfos.FirstOrDefault(x => x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && x.EnableStatus == EnableStatusEnum.Normal.ObjToInt());


                if (noInLocation == null) throw new Exception($"可用货位不足!");


                Dt_StationManger stationManger = _stationMangerRepository.QueryFirst(x => x.StationType == StationTypeEnum.StationType_OnlyInbound.ObjToInt() && x.StationDeviceCode == deviceCode);


                //创建任务


                Dt_Task task = new Dt_Task();


                task.PalletCode = containerFlowDTO.ContainerCode;


                task.SourceAddress = containerFlowDTO.SlotCode;


                task.CurrentAddress = containerFlowDTO.SlotCode;


                task.NextAddress = stationManger.StationCode;


                task.TargetAddress = "";


                task.WMSId = "";


                task.TaskType = TaskTypeEnum.Inbound.ObjToInt();


                task.Roadway = noInLocation.RoadwayNo;


                task.DeviceCode = stationManger.StationDeviceCode;


                task.TaskState = TaskStatusEnum.CL_Executing.ObjToInt();


                //添加任务


                BaseDal.AddData(task);


                _taskExecuteDetailService.AddTaskExecuteDetail(new List<int>() { task.TaskNum }, "创建入库任务");


                content.OK("成功");


            }


            catch (Exception ex)


            {


                content.Error($"错误信息:{ex.Message}");


            }


            return content;


        }


        /// <summary>


        /// æ’­ç§å¢™åˆå§‹åŒ–


        /// </summary>


        /// <returns></returns>


        public WebResponseContent InitLight()


        {


            WebResponseContent content = new WebResponseContent();


            try


            {


                EPLightContent lightContent = INITIALIZATION();


                if (lightContent.Result != "0") throw new Exception($"{lightContent.Msg}");


                content.OK();


            }


            catch (Exception ex)


            {


                content.Error(ex.Message);


            }


            return content;


        }


        /// <summary>


        /// ç»“束作业


        /// </summary>


        /// <returns></returns>


        public WebResponseContent EndLight()


        {


            WebResponseContent content = new WebResponseContent();


            try


            {


                EPLightContent lightContent = ENDWORK();


                if (lightContent.Result != "0") throw new Exception($"{lightContent.Msg}");


                content.OK();


            }


            catch (Exception ex)


            {


                content.Error(ex.Message);


            }


            return content;


        }


        /// <summary>


        /// æ’­ç§å¢™äº®ç¯


        /// </summary>


        /// <returns></returns>


        public WebResponseContent SendLight(TaskSendLight taskSendLight)


        {


            WebResponseContent content = new WebResponseContent();


            try


            {


                EPLightContent pLightContent = new EPLightContent();


            }


            catch (Exception ex)


            {


                content.Error(ex.Message);


            }


            return content;


        }


        static object lock_requestInTask = new object();


        /// <summary>


        /// ç”³è¯·å…¥åº“


        /// </summary>


        /// <returns></returns>


        public WebResponseContent RequestInTask(string stationCode,string barCode)


        {


            WebResponseContent content = new WebResponseContent();


            try


            {


                lock (lock_requestInTask)


                {


                    Dt_Task task = BaseDal.QueryFirst(x => x.PalletCode == barCode && x.TaskType==TaskTypeEnum.Inbound.ObjToInt() && x.NextAddress == stationCode && x.TaskState == TaskStatusEnum.CL_Executing.ObjToInt());


                    if (task == null) throw new Exception($"{barCode}料箱未找到任务!");


                    Dt_LocationInfo? locationInfo = _locationInfoService.AssignLocation();


                    if (locationInfo == null) throw new Exception($"可用货位不足!");


                    task.NextAddress = locationInfo.LocationCode;


                    task.TargetAddress = locationInfo.LocationCode;


                    task.CurrentAddress = stationCode;


                    task.DeviceCode = "AGV";


                    task.TaskState = TaskStatusEnum.AGV_Execute.ObjToInt();


                    locationInfo.LocationStatus = LocationStatusEnum.Lock.ObjToInt();


                    //更新任务和货位数据


                    _unitOfWorkManage.BeginTran();


                    BaseDal.UpdateData(task);


                    _locationInfoRepository.UpdateData(locationInfo);


                    _unitOfWorkManage.CommitTran();


                    _taskExecuteDetailService.AddTaskExecuteDetail(new List<int>() { task.TaskNum }, $"分配货位{locationInfo.LocationCode}");


                    _locationStatusChangeRecordService.AddLocationStatusChangeRecord(locationInfo, LocationStatusEnum.Free, LocationStatusEnum.Lock, LocationChangeType.InboundAssignLocation, task.TaskNum);


                    content.OK("成功");


                }


            }


            catch (Exception ex)


            {


                _unitOfWorkManage.RollbackTran();


                content.Error($"错误信息:{ex.Message}");


            }


            return content;


        }




        public static string Post(string serviceAddress, string requestJson = "", string contentType = "application/json", Dictionary<string, string>? headers = null)


        {


            string result = string.Empty;


            DateTime beginDate = DateTime.Now;


            try


            {


                using (HttpContent httpContent = new StringContent(requestJson))


                using (HttpContent httpContent = new StringContent(string.Empty))


                {


                    httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");




                    using HttpClient httpClient = new HttpClient();


                    httpClient.Timeout = new TimeSpan(0, 0, 30);


                    string LoginToken = AppSettings.Get("MESLoginToken");


                    headers = new Dictionary<string, string>


                    {


                        //正式


                        { "LoginToken", LoginToken }


                    };


                    if (headers != null)


                    {


                        foreach (var header in headers)


                            httpClient.DefaultRequestHeaders.Add(header.Key, header.Value);


                    }


                    HttpResponseMessage responseMessage = httpClient.PostAsync(serviceAddress, httpContent).Result;


                    result = responseMessage.Content.ReadAsStringAsync().Result;


                }


@@ -208,7 +356,7 @@


                task.ModifyDate = DateTime.Now;


                BaseDal.UpdateData(task);




                _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskNum, task.ExceptionMessage);


                _taskExecuteDetailService.AddTaskExecuteDetail(task, task.ExceptionMessage);




                content = WebResponseContent.Instance.OK();


            }


@@ -250,7 +398,7 @@




                BaseDal.UpdateData(task);




                _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskNum, $"人工恢复挂起任务,恢复挂起时任务状态【{task.TaskState}】");


                _taskExecuteDetailService.AddTaskExecuteDetail(task, $"人工恢复挂起任务,恢复挂起时任务状态【{task.TaskState}】");




                content = WebResponseContent.Instance.OK();


            }


@@ -291,7 +439,7 @@




                BaseDal.UpdateData(task);




                _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskNum, $"人工将任务状态从【{oldState}】回滚到【{task.TaskState}】");


                _taskExecuteDetailService.AddTaskExecuteDetail(task, $"人工将任务状态从【{oldState}】回滚到【{task.TaskState}】");




                content = WebResponseContent.Instance.OK();


            }


@@ -339,7 +487,7 @@


                AgvTaskFlowDTO agvTaskFlowDTO = new AgvTaskFlowDTO()


                {


                    RequestId = Guid.NewGuid().ToString().Replace("-", ""),


                    ContainerCode = code


                    MissionCode = code


                };


                string request = JsonConvert.SerializeObject(agvTaskFlowDTO, settings);


                string response = HttpHelper.Post(url, request);


@@ -392,7 +540,7 @@


            try


            {


                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);


                if (task != null && task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)//出库任务逻辑


                if (task != null && task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)//出库任务完成逻辑


                {


                    Dt_LocationInfo locationInfo = _locationInfoRepository.QueryFirst(x=>x.PalletCode==task.PalletCode);


                    if (locationInfo.LocationStatus != LocationStatusEnum.Lock.ObjToInt())


@@ -402,32 +550,68 @@


                    task.TaskState = TaskStatusEnum.Finish.ObjToInt();


                    locationInfo.LocationStatus = LocationStatusEnum.Free.ObjToInt();


                    locationInfo.PalletCode = "";


                    //料箱出库完成上报给WMS


                    string? url = _apiInfoRepository.QueryFirst(x => x.ApiCode == APIEnum.WMSInOutBoundBack.ToString())?.ApiAddress;


                    if (string.IsNullOrEmpty(url))


                    {


                        _taskExecuteDetailService.AddTaskExecuteDetail(task, $"未找到WMS出库上报接口,请检查接口配置");


                        UpdateTaskExceptionMessage(taskNum, $"未找到WMS出库上报接口,请检查接口配置");


                        return content.Error($"{taskNum},未找到WMS出库上报接口,请检查接口配置");


                    }


                    ContainerInFinishDTO containerInFinishDTO = new ContainerInFinishDTO()


                    {


                        TaskCode = task.TaskNum.ToString(),


                        ContainerCode = task.PalletCode,


                        StationCode = task.TargetAddress,


                        LocationCode = task.SourceAddress,


                        CompleteType = 1


                    };


                    string request = JsonConvert.SerializeObject(containerInFinishDTO, settings);


                    //调用接口


                    string response = HttpHelper.Post(url, request);


                    WMSResponseContent wMSResponse = JsonConvert.DeserializeObject<WMSResponseContent>(response) ?? throw new Exception($"{taskNum},未接收到WMS出库上报返回值");


                    if (wMSResponse.Code != "0") throw new Exception($"出库任务{task.TaskNum}WMS出库上报错误,信息:{wMSResponse.Msg}");


                    _unitOfWorkManage.BeginTran();


                    _locationInfoRepository.UpdateData(locationInfo);


                    BaseDal.DeleteAndMoveIntoHty(task, App.User?.UserId == 0 ? OperateTypeEnum.自动完成 : OperateTypeEnum.人工完成);


                    _unitOfWorkManage.CommitTran();


                    _locationStatusChangeRecordService.AddLocationStatusChangeRecord(locationInfo, LocationStatusEnum.Lock, LocationStatusEnum.Free, LocationChangeType.OutboundCompleted, task.TaskNum);


                }


                else if(task != null && task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)//入库任务逻辑


                else if(task != null && task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)//入库任务完成逻辑


                {


                    string? url = _apiInfoRepository.QueryFirst(x => x.ApiCode == APIEnum.WMSInBoundBack.ToString())?.ApiAddress;


                    string? url = _apiInfoRepository.QueryFirst(x => x.ApiCode == APIEnum.WMSInOutBoundBack.ToString())?.ApiAddress;


                    if (string.IsNullOrEmpty(url))


                    {


                        _taskExecuteDetailService.AddTaskExecuteDetail(taskNum, $"未找到WMS入库上报接口,请检查接口配置");


                        _taskExecuteDetailService.AddTaskExecuteDetail(task, $"未找到WMS入库上报接口,请检查接口配置");


                        UpdateTaskExceptionMessage(taskNum, $"未找到WMS入库上报接口,请检查接口配置");


                        return content.Error($"{taskNum},未找到WMS入库上报接口,请检查接口配置");


                    }


                    ContainerInFinishDTO containerInFinishDTO = new ContainerInFinishDTO()


                    {


                        TaskCode= task.TaskNum.ToString(),


                        TaskCode = task.TaskNum.ToString(),


                        ContainerCode = task.PalletCode,


                        FromStationCode = task.SourceAddress,


                        ToLocationCode = task.TargetAddress


                        StationCode = task.SourceAddress,


                        LocationCode = task.TargetAddress,


                        CompleteType = 2


                    };


                    string request = JsonConvert.SerializeObject(containerInFinishDTO, settings);


                    //调用接口


                    string response = HttpHelper.Post(url, request);


                    WMSResponseContent wMSResponse = JsonConvert.DeserializeObject<WMSResponseContent>(response) ??throw new Exception($"{taskNum},未接收到WMS入库上报返回值");


                    if (wMSResponse.Code!="0") throw new Exception($"入库任务{task.TaskNum}WMS入库上报错误,信息:{wMSResponse.Msg}");


                    WMSResponseContent wMSResponse = JsonConvert.DeserializeObject<WMSResponseContent>(response) ?? throw new Exception($"{taskNum},未接收到WMS入库上报返回值");


                    if (wMSResponse.Code != "0") throw new Exception($"入库任务{task.TaskNum}WMS入库上报错误,信息:{wMSResponse.Msg}");


                    Dt_LocationInfo locationInfo = _locationInfoRepository.QueryFirst(x => x.LocationCode == task.TargetAddress);


                    if (locationInfo.LocationStatus != LocationStatusEnum.Lock.ObjToInt())


                    {


                        return content.Error($"{locationInfo.LocationCode}货位状态不正确");


                    }


                    task.TaskState = TaskStatusEnum.Finish.ObjToInt();


                    locationInfo.LocationStatus = LocationStatusEnum.InStock.ObjToInt();


                    locationInfo.PalletCode = task.PalletCode;


                    _unitOfWorkManage.BeginTran();


                    _locationInfoRepository.UpdateData(locationInfo);


                    BaseDal.DeleteAndMoveIntoHty(task, App.User?.UserId == 0 ? OperateTypeEnum.自动完成 : OperateTypeEnum.人工完成);


                    _unitOfWorkManage.CommitTran();


                    _locationStatusChangeRecordService.AddLocationStatusChangeRecord(locationInfo, LocationStatusEnum.Lock, LocationStatusEnum.InStock, LocationChangeType.InboundCompleted, task.TaskNum);


                }


                content.OK("任务完成");


            }


@@ -438,5 +622,88 @@


            }


            return content;


        }




        /// <summary>


        /// äºŒæœŸæ’­ç§å¢™ä¸‹å‘


        /// </summary>


        /// <param name="taskNum"></param>


        /// <returns></returns>


        public EPLightContent PickOrderInfoRequest(List<EPLightSendDTO> lightSendDTOs)


        {


            EPLightContent content = new EPLightContent();


            try


            {


                string? url = _apiInfoRepository.QueryFirst(x => x.ApiCode == APIEnum.PickOrderInfoRequest.ToString())?.ApiAddress;


                if (string.IsNullOrEmpty(url))


                {


                    return content.Error($"未找到播种墙下发接口,请检查接口配置");


                }


                string request = JsonConvert.SerializeObject(lightSendDTOs, settings);


                //调用接口


                string response = HttpHelper.Post(url, request);


                EPLightContent lightContent = JsonConvert.DeserializeObject<EPLightContent>(response) ?? throw new Exception($"未接收到播种墙下发上报返回值");


                if (lightContent.Result != "0") throw new Exception($"播种墙下发错误,信息:{lightContent.Msg}");


                content.OK("成功");


            }


            catch (Exception ex)


            {


                content.Error(ex.Message);


            }


            return content;


        }


        /// <summary>


        /// äºŒæœŸæ’­ç§å¢™åˆå§‹åŒ–


        /// </summary>


        /// <param name="taskNum"></param>


        /// <returns></returns>


        public EPLightContent INITIALIZATION()


        {


            EPLightContent content = new EPLightContent();


            try


            {


                string? url = _apiInfoRepository.QueryFirst(x => x.ApiCode == APIEnum.INITIALIZATION.ToString())?.ApiAddress;


                if (string.IsNullOrEmpty(url))


                {


                    return content.Error($"未找到播种墙初始化接口,请检查接口配置");


                }


                //调用接口


                string response = Post(url);


                EPLightContent lightContent = JsonConvert.DeserializeObject<EPLightContent>(response) ?? throw new Exception($"未接收到播种墙初始化上报返回值");


                if (lightContent.Result != "0") throw new Exception($"播种墙初始化错误,信息:{lightContent.Msg}");


                content.OK("成功");


            }


            catch (Exception ex)


            {


                content.Error(ex.Message);


            }


            return content;


        }


        /// <summary>


        /// äºŒæœŸæ’­ç§å¢™ç»“束作业


        /// </summary>


        /// <param name="taskNum"></param>


        /// <returns></returns>


        public EPLightContent ENDWORK()


        {


            EPLightContent content = new EPLightContent();


            try


            {


                string? url = _apiInfoRepository.QueryFirst(x => x.ApiCode == APIEnum.ENDWORK.ToString())?.ApiAddress;


                if (string.IsNullOrEmpty(url))


                {


                    return content.Error($"未找到播种墙结束作业接口,请检查接口配置");


                }


                //调用接口


                string response = Post(url);


                EPLightContent lightContent = JsonConvert.DeserializeObject<EPLightContent>(response) ?? throw new Exception($"未接收到播种墙结束作业上报返回值");


                if (lightContent.Result != "0") throw new Exception($"播种墙结束作业错误,信息:{lightContent.Msg}");


                content.OK("成功");


            }


            catch (Exception ex)


            {


                content.Error(ex.Message);


            }


            return content;


        }


    }


}