| | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | | import org.springframework.stereotype.Component; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.io.IOException; |
| | | |
| | |
| | | private TaskWrkReportService taskWrkReportService; |
| | | |
| | | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | public void execute() throws IOException { |
| | | @Scheduled(cron = "0/5 * * * * ? ") |
| | | public synchronized void execute() throws IOException { |
| | | for (TaskWrk taskWrk : taskWrkService.selectToBeHistoryData()) { |
| | | switch (taskWrk.getStatus()) { |
| | | case 4: |
| | |
| | | case 5: |
| | | break; |
| | | } |
| | | TaskWrkReport taskWrkReport = new TaskWrkReport(); |
| | | TaskWrkLog taskWrkLog = new TaskWrkLog(); |
| | | Synchro.Copy(taskWrk, taskWrkReport); |
| | | Synchro.Copy(taskWrk, taskWrkLog); |
| | | if (!taskWrkReportService.insert(taskWrkReport)) { |
| | | throw new CoolException("转移至上报表" + taskWrk); |
| | | } |
| | | if (!wrkLogService.insert(taskWrkLog)) { |
| | | throw new CoolException("转历史档失败" + taskWrk); |
| | | } |
| | | if (!taskWrkService.deleteById(taskWrk)) { |
| | | throw new CoolException("任务档删除失败" + taskWrk); |
| | | } |
| | | exe(taskWrk); |
| | | } |
| | | } |
| | | |
| | | @Transactional |
| | | public void exe(TaskWrk taskWrk) { |
| | | TaskWrkReport taskWrkReport = new TaskWrkReport(); |
| | | TaskWrkLog taskWrkLog = new TaskWrkLog(); |
| | | Synchro.Copy(taskWrk, taskWrkReport); |
| | | Synchro.Copy(taskWrk, taskWrkLog); |
| | | if (!wrkLogService.insert(taskWrkLog)) { |
| | | throw new CoolException("转历史档失败" + taskWrk); |
| | | } |
| | | if (!taskWrkService.deleteById(taskWrk)) { |
| | | throw new CoolException("任务档删除失败" + taskWrk); |
| | | } |
| | | if (!taskWrkReportService.insert(taskWrkReport)) { |
| | | throw new CoolException("转移至上报表" + taskWrk); |
| | | } |
| | | } |
| | | } |