修复bug

xiazhengtongxue

2026-02-09 e81c782b3e7a632ffb8e32be56fce931a8c89ae6

 ÏîÄ¿´úÂë/WCSServices/WIDESEAWCS_TaskInfoService/InvokeAGVService.cs

@@ -64,50 +64,53 @@

                string? ErrorBack = _apiInfoRepository.QueryFirst(x => x.ApiCode == APIEnum.WMSErrorBack.ToString())?.ApiAddress;
                if (string.IsNullOrEmpty(ErrorBack))
                    throw new Exception($"未找到WMS故障上报接口,请检查接口配置");

                // å¦‚果是故障上报(e2.ErrorType == 2)
                if (e2.ErrorType == 2)
                {
                    // æ£€æŸ¥æ˜¯å¦å·²å­˜åœ¨ç›¸åŒæœºå™¨äººçš„故障记录
                    if (existingErrors.Count == 0)
                    return;
                }else{
                    // å¦‚果是故障上报(e2.ErrorType == 2)
                    if (e2.ErrorType == 2)
                    {
                        _errorInfoRepository.AddData(e2);
                        // å‘送给WMS - æ•…障上报
                        TaskError taskError = new TaskError()
                        // æ£€æŸ¥æ˜¯å¦å·²å­˜åœ¨ç›¸åŒæœºå™¨äººçš„故障记录
                        if (existingErrors.Count == 0)
                        {
                            MsgID = e2.Id,
                            StationCode = e2.StationCode,
                            MsgCode = 1, // 1表示故障
                            Msg = e2.Message
                        };
                        string reqErrorBack = JsonConvert.SerializeObject(taskError, settings);
                        HttpHelper.Post(ErrorBack, reqErrorBack);
                    }
                    // å¦‚果已存在故障记录，则不重复添加
                }
                // å¦‚果是正常状态(e2.ErrorType == 0)且存在故障记录，则执行故障恢复
                else if (e2.ErrorType == 0 && existingErrors.Count > 0)
                {
                    // åˆ é™¤æ•…障记录
                    if (_errorInfoRepository.DeleteData(existingErrors))
                    {
                        // å‘送给WMS - æ•…障恢复
                        foreach (var error in existingErrors)
                        {
                            _errorInfoRepository.AddData(e2);
                            // å‘送给WMS - æ•…障上报
                            TaskError taskError = new TaskError()
                            {
                                MsgID = error.Id,
                                StationCode = error.StationCode,
                                MsgCode = 0, // 0表示恢复
                                Msg = "故障恢复"
                                MsgID = e2.Id,
                                StationCode = e2.StationCode,
                                MsgCode = 1, // 1表示故障
                                Msg = e2.Message
                            };
                            string reqErrorBack = JsonConvert.SerializeObject(taskError, settings);
                            HttpHelper.Post(ErrorBack, reqErrorBack);
                        }
                        // å¦‚果已存在故障记录，则不重复添加
                    }
                    // å¦‚果是正常状态(e2.ErrorType == 0)且存在故障记录，则执行故障恢复
                    else if (e2.ErrorType == 0 && existingErrors.Count > 0)
                    {
                        // åˆ é™¤æ•…障记录
                        if (_errorInfoRepository.DeleteData(existingErrors))
                        {
                            // å‘送给WMS - æ•…障恢复
                            foreach (var error in existingErrors)
                            {
                                TaskError taskError = new TaskError()
                                {
                                    MsgID = error.Id,
                                    StationCode = error.StationCode,
                                    MsgCode = 0, // 0表示恢复
                                    Msg = "故障恢复"
                                };
                                string reqErrorBack = JsonConvert.SerializeObject(taskError, settings);
                                HttpHelper.Post(ErrorBack, reqErrorBack);
                            }
                        }
                    }
                    return;
                }
                return;
  
            }
        }
        /// <summary>
@@ -178,7 +181,7 @@
                _errorInfoRepository.DeleteData(delErrorInfos);
                _errorInfoRepository.AddData(addErrorInfos);
                _unitOfWorkManage.CommitTran();
                List<Dt_ErrorInfo> newErrInfos = _errorInfoRepository.QueryData(x=>x.Id > errorId && x.ErrorType == 2);
                List<Dt_ErrorInfo> newErrInfos = _errorInfoRepository.QueryData(x=>x.Id > errorId && x.ErrorType == 1);
                if (delErrorInfos.Count>0)
                {
                    foreach (var item in delErrorInfos)