最新

zhangchengsong

12 小时以前 f59f3b24814387573b5bca9a9b6c832a3720ee7e

 ÏîÄ¿´úÂë/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/WMSTaskService.cs

@@ -229,175 +229,134 @@
                return apiResponse.ErrorResponse($"WCS任务添加错误，原因：{ex.Message}");
            }
        }


        //设置光幕
        /// <summary>
        /// è®¾ç½®å…‰å¹•
        /// </summary>
        /// <param name="setCurtain"></param>
        /// <returns></returns>
        public ApiResponse setCurtain(SetCurtainRequest setCurtain)
        {
            if (setCurtain == null || setCurtain.Datas == null || setCurtain.Datas.Length == 0)
            {
                return new ApiResponse().ErrorResponse("请求参数或库口列表不能为空");
            }
            if (string.IsNullOrWhiteSpace(setCurtain.Operate))
            {
                return new ApiResponse().ErrorResponse("操作类型(Operate)不能为空");
            }

            WriteLog.Write_Log("设置光幕接口", "设置光幕接口信息", $"库口名称：【{string.Join(",", setCurtain.Datas)}】,申请状态：【{setCurtain.Operate}】");
            ApiResponse apiResponse = new ApiResponse();
            bool HandShakeboolOPEN = false;
            bool HandShakeboolCLOSE = false;
            bool allSuccess = true;
            var specialPorts = new[] { "G01", "G06", "G07" };

            try
            {
                Dictionary<string, int> portStatusDict = new Dictionary<string, int>();
                foreach (string DeStateName in setCurtain.Datas)
                foreach (string portName in setCurtain.Datas)
                {
                    string DeciceCodes = "1003";
                    if (DeStateName.StartsWith("C")) DeciceCodes = "1004";
                    if (string.IsNullOrWhiteSpace(portName)) { allSuccess = false; continue; }
                    string deviceCode = portName.StartsWith("C") ? "1004" : "1003";

                    IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == DeciceCodes);
                    if (device == null) return apiResponse.ErrorResponse("WCS未能获取到库口实例");
                        CommonConveyorLine? conveyorLine = Storage.Devices.FirstOrDefault(x => x.DeviceCode == deviceCode) as CommonConveyorLine;
                        if (conveyorLine == null) { allSuccess = false; continue; }

                    CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                        DeviceProDTO? handShakeDto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == portName && x.DeviceProParamName == "HandShake");
                        DeviceProDTO? requestDto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == portName && x.DeviceProParamName == "Request");
                        if (handShakeDto == null) { allSuccess = false; continue; }

                    DeviceProDTO? HandShake = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == DeStateName && x.DeviceProParamName == "HandShake");
                    if (HandShake == null) return apiResponse.ErrorResponse($"WCS未找到库口：{setCurtain.Datas},对应的协议");
                    DeviceProDTO? Request = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == DeStateName && x.DeviceProParamName == "Request");
                    if (HandShake == null) return apiResponse.ErrorResponse($"WCS未找到库口：{setCurtain.Datas},对应的协议");
                    
                    if (setCurtain.Operate.Equals("OPEN"))
                    {
                        //写入plc，agv退出中打开信号
                        HandShakeboolOPEN =  conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 0);

                        WriteLog.Write_Log("设置打开光幕接口", "设置打开光幕信息", $"库口名称：【{DeStateName}】，打开光幕信号地址：【{Request.DeviceProAddress}】，读取数据：【{conveyorLine.Communicator.Read<ushort>(Request.DeviceProAddress)}】\n" +
                        $"写入打开光幕信号是否成功返回值：【{HandShakeboolOPEN}】");

                        bool writeResult = false;
                        //StringComparison.OrdinalIgnoreCase是兼容大小写
                        if (setCurtain.Operate.Equals("OPEN", StringComparison.OrdinalIgnoreCase))
                        {
                            if (specialPorts.Contains(portName))
                                writeResult = conveyorLine.Communicator.Write<short>(requestDto.DeviceProAddress, 0);
                            else
                                writeResult = conveyorLine.Communicator.Write<short>(handShakeDto.DeviceProAddress, 0);
                        }
                        else if (setCurtain.Operate.Equals("CLOSE", StringComparison.OrdinalIgnoreCase))
                        {
                            if (specialPorts.Contains(portName))
                                writeResult = conveyorLine.Communicator.Write<short>(handShakeDto.DeviceProAddress, 1) && conveyorLine.Communicator.Write<short>(requestDto.DeviceProAddress, 1);
                            else
                                writeResult = conveyorLine.Communicator.Write<short>(handShakeDto.DeviceProAddress, 1);
                        }
                        if (!writeResult) allSuccess = false;
                    }
                    else
                    {
                        //写入plc，agv进入关闭光栅信号
                        HandShakeboolCLOSE = conveyorLine.Communicator.Write<short>(HandShake.DeviceProAddress, 1)&& conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 1);

                        WriteLog.Write_Log("设置关闭光幕接口", "设置关闭光幕接口信息", $"库口名称：【{DeStateName}】，关闭光幕信号地址：【{HandShake.DeviceProAddress}】，读取数据：【{conveyorLine.Communicator.Read<ushort>(HandShake.DeviceProAddress)}】" +
                            $"关闭光幕信号备用地址：【{Request.DeviceProAddress}】，读取数据：【{conveyorLine.Communicator.Read<ushort>(Request.DeviceProAddress)}】\n" +
                        $"写入关闭光幕信号是否成功返回值：【{HandShakeboolCLOSE}】");
                    }
                }
                 if ((HandShakeboolOPEN && setCurtain.Operate.Equals("OPEN") )|| (HandShakeboolCLOSE && setCurtain.Operate.Equals("CLOSE")))
                 {
                    return apiResponse.SuccessResponse();
                 }
                else
                {
                 return apiResponse.ErrorResponse("写入plc进入信号失败");
                }
                }
                return allSuccess ? apiResponse.SuccessResponse() : apiResponse.ErrorResponse("部分/全部库口写入PLC信号失败");
            }
            catch (Exception ex)
            {
                return apiResponse.ErrorResponse($"WCS任务添加错误，原因：{ex.Message}");
                WriteLog.Write_Log("设置光幕接口异常", "错误信息", ex.ToString());
                return apiResponse.ErrorResponse($"WCS设置光幕错误，原因：{ex.Message}");
            }
        }
        



        //agv进出状态反馈
       #endregion
        /// <summary>
        /// agv进出入反馈
        /// </summary>
        /// <param name="agvUpdateRequest"></param>
        /// <returns></returns>
        public ApiResponse getAGVStatus(AgvUpdateRequest agvUpdateRequest)
        {
            //获取WMS调取的参数
            WriteLog.Write_Log("agv进出状态反馈接口", "agv进出状态信息", "调取参数", setCurtain);
            if (agvUpdateRequest == null) return new ApiResponse().ErrorResponse("请求参数不能为空");
            if (string.IsNullOrWhiteSpace(agvUpdateRequest.warehousenumber)) return new ApiResponse().ErrorResponse("库口编号不能为空");

            WriteLog.Write_Log("agv进出状态反馈接口", "agv进出状态信息", $"库口名称：【{agvUpdateRequest.warehousenumber}】，申请状态：【{agvUpdateRequest.agvstatus}】");
            ApiResponse apiResponse = new ApiResponse();

            try
            {
                string DeciceCodes = "1003";
                if (agvUpdateRequest.warehousenumber.StartsWith("C")) DeciceCodes = "1004";
                string deviceCode = agvUpdateRequest.warehousenumber.StartsWith("C") ? "1004" : "1003";

                IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == DeciceCodes);
                if (device == null) return apiResponse.ErrorResponse("WCS未能获取到库口实例");
                CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                    CommonConveyorLine? conveyorLine = Storage.Devices.FirstOrDefault(x => x.DeviceCode == deviceCode) as CommonConveyorLine;
                    if (conveyorLine == null) return apiResponse.ErrorResponse("WCS未能获取到库口实例");

                //是否可进出
                DeviceProDTO? HandShake = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "HandShake");
                if (HandShake == null) return apiResponse.ErrorResponse($"WCS未找到库口：{agvUpdateRequest.warehousenumber},对应的协议");
                DeviceProDTO? Request = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "Request");
              
                    DeviceProDTO? handShake = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "HandShake");
                    if (handShake == null) return apiResponse.ErrorResponse($"WCS未找到库口：{agvUpdateRequest.warehousenumber},对应的协议");
                    DeviceProDTO? request = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "Request");

                    if (agvUpdateRequest.agvstatus == 1)
                    {
                        bool HandShakebool = conveyorLine.Communicator.Write<short>(HandShake.DeviceProAddress, 1);
                        if (HandShakebool)
                        {
                        if (Request != null)
                        {
                            conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 1);
                        }
                            //是否可进出    1允许取  2允许放
                            DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "PermitHandShake");
                            //是否有货
                            DeviceProDTO? StationNumProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "StationNum");
                            if (deviceProDTO == null || StationNumProDTO == null) return apiResponse.ErrorResponse($"WCS未找到库口：{agvUpdateRequest.warehousenumber},对应的协议");
                            int statusValue = 0;
                            int portStatus = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                            int StationStatus = conveyorLine.Communicator.Read<ushort>(StationNumProDTO.DeviceProAddress);
                        bool writeHandShake = conveyorLine.Communicator.Write<short>(handShake.DeviceProAddress, 1);
                        if (!writeHandShake) return apiResponse.ErrorResponse("写入plc进入信号失败");
                        if (request != null) conveyorLine.Communicator.Write<short>(request.DeviceProAddress, 1);

                            //有货，可进信号
                            statusValue = ((portStatus == 1 && StationStatus == 1) || (portStatus == 2 && StationStatus == 0)) ? 1 : (portStatus == 0) ? 0 : 0;
                            WriteLog.Write_Log("申请进入AGV反馈信号信息", "申请进入AGV反馈信号信息", $"库口编号：【{agvUpdateRequest.warehousenumber}】，是否允许进入地址：【{deviceProDTO.DeviceProAddress}】，读取数据：【{portStatus}】\n" +
                                $"是否有货地址：【{StationNumProDTO.DeviceProAddress}】，读取数据：【{StationStatus}】\n" +
                                $"是否可进入信号：【{statusValue}】");
                            if (agvUpdateRequest.warehousenumber == "G01" || agvUpdateRequest.warehousenumber == "G06" || agvUpdateRequest.warehousenumber == "G07")
                            {
                                if (statusValue == 1)
                                {
                                    return apiResponse.SuccessResponse();
                        var specialPorts = new[] { "G01", "G06", "G07" };
                        if (specialPorts.Contains(agvUpdateRequest.warehousenumber))
                        {
                            DeviceProDTO? permitHandShake = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "PermitHandShake");
                            DeviceProDTO? stationNum = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "StationNum");
                            if (permitHandShake == null || stationNum == null) return apiResponse.ErrorResponse($"WCS未找到库口：{agvUpdateRequest.warehousenumber},对应的协议");

                                }
                                else
                                {
                                    conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 0);
                                    return apiResponse.ErrorResponse("读取plc不可进入信息");
                                }
                            }
                            else
                            int portStatus = conveyorLine.Communicator.Read<ushort>(permitHandShake.DeviceProAddress);
                            int stationStatus = conveyorLine.Communicator.Read<ushort>(stationNum.DeviceProAddress);
                            bool canEnter = (portStatus == 1 && stationStatus == 1) || (portStatus == 2 && stationStatus == 0);
                            if (!canEnter)
                            {
                                return apiResponse.SuccessResponse();
                                if (request != null) conveyorLine.Communicator.Write<short>(request.DeviceProAddress, 0);
                                return apiResponse.ErrorResponse("读取plc不可进入信息");
                            }
                        }
                        else
                        {
                            return apiResponse.ErrorResponse("写入plc进入信号失败");
                        }
                        return apiResponse.SuccessResponse();
                    }
                    else if (agvUpdateRequest.agvstatus == 2)
                    {
                        //写入输送线信号
                        bool portStatus = conveyorLine.Communicator.Write<short>(HandShake.DeviceProAddress, 0);
                        if (portStatus)
                        {
                            if (Request != null)
                            {
                                conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 0);
                                WriteLog.Write_Log("申请离开AGV反馈信号信息", "申请离开AGV反馈信号信息", $"库口编号：【{agvUpdateRequest.warehousenumber}】，申请信号地址：【{HandShake.DeviceProAddress}】，读取数据：【{conveyorLine.Communicator.Read<ushort>(HandShake.DeviceProAddress)}】\n" +
                                    $"备用信号地址：【{Request.DeviceProAddress}】，读取数据：【{conveyorLine.Communicator.Read<ushort>(Request.DeviceProAddress)}】");

                            }
                            else
                            {
                                WriteLog.Write_Log("申请离开AGV反馈信号信息", "申请离开AGV反馈信号信息", $"库口编号：【{agvUpdateRequest.warehousenumber}】，申请信号地址：【{HandShake.DeviceProAddress}】，读取数据：【{conveyorLine.Communicator.Read<ushort>(HandShake.DeviceProAddress)}】\n" );
                            }
                            return apiResponse.SuccessResponse();
                        }
                        else
                        {
                            return apiResponse.ErrorResponse("写入plc清除信号失败");
                        }
                        bool clearHandShake = conveyorLine.Communicator.Write<short>(handShake.DeviceProAddress, 0);
                        if (!clearHandShake) return apiResponse.ErrorResponse("写入plc清除信号失败");
                        if (request != null) conveyorLine.Communicator.Write<short>(request.DeviceProAddress, 0);
                        return apiResponse.SuccessResponse();
                    }
                    else
                    {
                        return apiResponse.ErrorResponse($"agv对应的申请错误，字段：agvstatus，申请的值：{agvUpdateRequest.agvstatus}");
                    }

            }
            catch (Exception ex)
            {
                return apiResponse.ErrorResponse($"WCS任务添加错误，原因：{ex.Message}");
                return apiResponse.ErrorResponse($"WCS AGV状态错误，原因：{ex.Message}");
            }
        }
        #endregion



        #region è°ƒå–上游接口
        public CommandResult taskreturn(int taskId, string taskType, string invType, string psd)
@@ -413,7 +372,7 @@

                commandResult = HttpHelper.Post<CommandResult>(urlWMStaskreturn, taskInfo1, "任务状态回调");

                WriteLog.Write_Log("同步给上游反馈任务完成", "任务信息", $"任务号：{taskId}", $"调取参数：{taskInfo1.ToJsonString()},返回参数：{commandResult.ToJsonString()}");
                WriteLog.Write_Log("同步给上游反馈任务完成", "任务信息", $"任务号：【{taskId}】", $"调取参数：【{taskInfo1.ToJsonString()}】\n返回参数：{commandResult.ToJsonString()}】");
                return commandResult;
            }
            catch (Exception ex)
@@ -423,7 +382,7 @@
                string resujos = $"WCS接口错误，原因：{ex.Message}";
                commandResult.result = resujos.ToJsonString();

                WriteLog.Write_Log("同步给上游反馈任务完成", "任务信息", $"任务号：{taskId}", $"需要上传WMS信息内容：{commandResult.ToJsonString()},WCS接口错误，原因：{ex.Message}");
                WriteLog.Write_Log("同步给上游反馈任务完成", "任务信息", $"任务号：【{taskId}】", $"需要上传WMS信息内容：【{commandResult.ToJsonString()}】\nWCS接口错误，原因：{ex.Message}");
                return commandResult;
            }