手动取消、异常上报和数据库维护脚本

xiazhengtongxue

2026-01-23 f65bfbd6e84fdffc71353acfe7c9ccca5b117c45

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

@@ -51,12 +51,80 @@
            return content;
        }
        /// <summary>
        /// AGV查询调用及WMS故障上报
        /// </summary>
        public void AgvSearchStatus1(Dt_ErrorInfo e2)
        {
            if (e2 != null)
            {
                // æŸ¥è¯¢æ˜¯å¦æœ‰é”™è¯¯æ²¡æœ‰å°±æ·»åŠ ï¼Œæœ‰å°±å–消
                List<Dt_ErrorInfo> existingErrors = _errorInfoRepository.QueryData(x =>
                    x.RobotCode == e2.RobotCode &&
                    x.ErrorType == 2); // åªæŸ¥è¯¢æ•…障类型为2的记录

                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)
                    {
                        _errorInfoRepository.AddData(e2);
                        // å‘送给WMS - æ•…障上报
                        TaskError taskError = new TaskError()
                        {
                            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;
            }
        }
        /// <summary>
        /// AGV状态查询调用及WMS故障上报
        /// </summary>
        public void AgvSearchStatus()
        public void AgvSearchStatus() // 1原来和2更新任务
        {
            try
            {
                // æŸ¥è¯¢æ˜¯å¦æœ‰ä»»åŠ¡
                List<Dt_Task> tasks = BaseDal.QueryData();
                // å¦‚果没有任务，直接返回
                if (tasks == null || tasks.Count == 0)
                {
                    return;
                }
      
                AgvSearchStatusDTO agvSearchStatusDTO = new AgvSearchStatusDTO();
                string? apiAddress = _apiInfoRepository.QueryFirst(x => x.ApiCode == APIEnum.AgvSearchStatus.ToString())?.ApiAddress;
                if (string.IsNullOrEmpty(apiAddress)) throw new Exception($"未找到AGV状态查询接口,请检查接口配置");
@@ -67,12 +135,12 @@
                AgvStatusContent agvContent = response.DeserializeObject<AgvStatusContent>() ?? throw new Exception("AGV状态查询未返回结果");

                //获取所有故障信息
                List <Dt_ErrorInfo> errorInfos = _errorInfoRepository.QueryData();
                List <Dt_ErrorInfo> errorInfos = _errorInfoRepository.QueryData(x => x.ErrorType == 1);
                int errorId = errorInfos.Count > 0 ? errorInfos.Max(x => x.Id) : 0;
                List<Dt_ErrorInfo> delErrorInfos = new List<Dt_ErrorInfo>();
                List<Dt_ErrorInfo> addErrorInfos = new List<Dt_ErrorInfo>();
                //获取任务信息
                List<Dt_Task> tasks = BaseDal.QueryData();
                //List<Dt_Task> tasks = BaseDal.QueryData();
                if (agvContent.Success)
                {
                    foreach (var item in agvContent.Data.Where(x => errorInfos.Select(x => x.RobotCode).Contains(x.RobotId) && x.Status != 7))
@@ -90,7 +158,8 @@
                            Dt_ErrorInfo errorInfo = new Dt_ErrorInfo()
                            {
                                RobotCode = item.RobotId,
                                Message = "故障"
                                Message = "故障",
                                ErrorType = 1,
                            };
                            if (task.TaskType==TaskTypeEnum.Inbound.ObjToInt())
                            {
@@ -109,7 +178,7 @@
                _errorInfoRepository.DeleteData(delErrorInfos);
                _errorInfoRepository.AddData(addErrorInfos);
                _unitOfWorkManage.CommitTran();
                List<Dt_ErrorInfo> newErrInfos = _errorInfoRepository.QueryData(x=>x.Id > errorId);
                List<Dt_ErrorInfo> newErrInfos = _errorInfoRepository.QueryData(x=>x.Id > errorId && x.ErrorType == 2);
                if (delErrorInfos.Count>0)
                {
                    foreach (var item in delErrorInfos)
@@ -123,6 +192,7 @@
                        };
                        string reqErrorBack = JsonConvert.SerializeObject(taskError, settings);
                        HttpHelper.Post(apiErrorBack, reqErrorBack);

                    }
                }
                if (newErrInfos.Count>0)