| | |
| | | SourceAddress = outTask.TargetAddress, |
| | | TargetAddress = cachePoint.PointCode, |
| | | SourceKey = outTask.TaskId, |
| | | //TaskNum = outTask.TaskNum, |
| | | TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)), |
| | | TaskStatus = AGVTaskStatusEnum.AGV_New.ObjToInt(), |
| | | TaskType = TaskTypeEnum.AGVCarry.ObjToInt(), |
| | |
| | | Dt_AreaRouter areaRouter = _basicService.AreaRouterService.Repository.QueryFirst(x => x.StartArea == startPoint); |
| | | if (areaRouter == null) |
| | | { |
| | | throw new Exception("æªæ¾å°è·¯ç±ä¿¡æ¯"); |
| | | throw new Exception("æªæ¾å°è·¯ç±ä¿¡æ¯!"); |
| | | } |
| | | Dt_AreaInfo areaInfo = _basicService.AreaInfoService.Repository.QueryFirst(x => x.AreaCode == areaRouter.NextArea); |
| | | if (areaInfo == null) |
| | | { |
| | | throw new Exception("æªæ¾å°ä¸ä¸åºåä¿¡æ¯"); |
| | | throw new Exception("æªæ¾å°ä¸ä¸åºåä¿¡æ¯!"); |
| | | } |
| | | |
| | | Dt_CachePoint? cachePoint = _basicService.CachePointService.AssignCachePoint(areaInfo.Id); |
| | | if (cachePoint == null) |
| | | { |
| | | throw new Exception("æªæ¾å°ç©ºé²ç¼åç¹"); |
| | | throw new Exception("æªæ¾å°ç©ºé²ç¼åç¹!"); |
| | | } |
| | | |
| | | return cachePoint; |
| | |
| | | Dt_AreaRouter areaRouter = _basicService.AreaRouterService.Repository.QueryFirst(x => x.NextArea == endPoint); |
| | | if (areaRouter == null) |
| | | { |
| | | throw new Exception("æªæ¾å°è·¯ç±ä¿¡æ¯"); |
| | | throw new Exception("æªæ¾å°è·¯ç±ä¿¡æ¯!"); |
| | | } |
| | | Dt_AreaInfo areaInfo = _basicService.AreaInfoService.Repository.QueryFirst(x => x.AreaCode == areaRouter.StartArea); |
| | | if (areaInfo == null) |
| | | { |
| | | throw new Exception("æªæ¾å°èµ·ç¹ç¼ååºåä¿¡æ¯"); |
| | | throw new Exception("æªæ¾å°èµ·ç¹ç¼ååºåä¿¡æ¯!"); |
| | | } |
| | | |
| | | Dt_CachePoint? cachePoint = _basicService.CachePointService.GetIbStockCachePoint(areaInfo.Id); |
| | | if (cachePoint == null) |
| | | { |
| | | throw new Exception("æªæ¾å°æè´§ç¼åç¹"); |
| | | throw new Exception("æªæ¾å°æè´§ç¼åç¹!"); |
| | | } |
| | | return cachePoint; |
| | | } |
| | |
| | | Dt_Task task = BaseDal.QueryFirst(x => x.TaskId == Convert.ToInt32(model.Task_id)); |
| | | if (task == null) |
| | | { |
| | | return new { code = 404, message = "æªæ¾å°è¯¥ä»»å¡" }; |
| | | return new { code = 404, message = "æªæ¾å°è¯¥ä»»å¡!" }; |
| | | } |
| | | |
| | | Dt_CachePoint startCachePoint = _basicService.CachePointService.Repository.QueryFirst(x => x.PointCode == task.SourceAddress); |
| | |
| | | _basicService.CachePointService.Repository.UpdateData(endCachePoint); |
| | | } |
| | | BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.èªå¨å®æ : OperateType.äººå·¥å®æ); |
| | | //BaseDal.DeleteData(task); |
| | | |
| | | return new { code = 200, message = "æå" }; |
| | | } |