| | |
| | | } |
| | | |
| | | public Task Execute(IJobExecutionContext context) |
| | | |
| | | { |
| | | try |
| | | { |
| | |
| | | }; |
| | | |
| | | // å¤çå®çå
¥åºè¯·æ± |
| | | ProcessRequests(conveyorLine, requests, "ä¸çº¿è¯·æ±å
¥åº"); |
| | | //ProcessRequests(conveyorLine, requests, "ä¸çº¿è¯·æ±å
¥åº"); |
| | | |
| | | // å¤ç空çåæµè¯·æ± |
| | | ProcessKpRequests(conveyorLine, requestsKP); |
| | |
| | | Dt_Task task = null; |
| | | if (isUpRequest) |
| | | { |
| | | task = CreateTask(fromAdd, "WaitBind", "æ£æç©æµçº¿002çä¸æè¯·æ±", "空æç", taskType); |
| | | List<Dt_Task> dt_Task = _taskRepository.QueryData(x => x.SourceAddress == fromAdd && x.TaskState == (int)TaskInStatusEnum.InPending); |
| | | if (dt_Task.Count < 0) { continue; } |
| | | var tasks = dt_Task.Where(x => x.SourceAddress == fromAdd).OrderBy(t => t.CreateDate).First(); |
| | | tasks.TaskState = (int)TaskInStatusEnum.InNew; |
| | | _taskService.UpdateData(tasks); |
| | | } |
| | | else if (isGMRequest && isGMState == 1) |
| | | { |
| | | task = CreateTask(fromAdd, "WaitBind", "æ£æç©æµçº¿002çä¸æè¯·æ±", "éè空æç", taskType); |
| | | } |
| | | //else if (isGMRequest && isGMState == 1) |
| | | //{ |
| | | // task = CreateTask(fromAdd, "WaitBind", "æ£æç©æµçº¿002çä¸æè¯·æ±", "éè空æç", taskType); |
| | | //} |
| | | |
| | | // æ·»å ä»»å¡å°ä»»å¡è¡¨ |
| | | if (task != null) |
| | | { |
| | | _taskRepository.AddData(task); |
| | | } |
| | | //// æ·»å ä»»å¡å°ä»»å¡è¡¨ |
| | | //if (task != null) |
| | | //{ |
| | | // _taskRepository.AddData(task); |
| | | //} |
| | | } |
| | | } |
| | | |