| | |
| | | } |
| | | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | private void reportTaskToUplink(){ |
| | | private void reportTaskToUplink() { |
| | | if (!uplinkProperties.getEnabled()) { return; } |
| | | List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>() |
| | | .eq(Task::getUplinkSts, TaskUplinkStateType.PENDING.toString()) |
| | | .in(Task::getUplinkSts, TaskUplinkStateType.PENDING.toString(), TaskUplinkStateType.FAILED.toString()) |
| | | .eq(Task::getTaskSts, TaskStsType.COMPLETE.val()) |
| | | .isNotNull(Task::getBusId) |
| | | ); |
| | | if (Cools.isEmpty(taskList)) { return; } |
| | | for (Task task : taskList) { |
| | |
| | | } |
| | | |
| | | @Scheduled(cron = "0/5 * * * * ? ") |
| | | private synchronized void releaseFuncSta(){ |
| | | private synchronized void releaseFuncSta() { |
| | | List<FuncSta> funcStaList = funcStaService.list(new LambdaQueryWrapper<FuncSta>().eq(FuncSta::getState, FuncStaStateType.OCCUPIED.toString())); |
| | | for (FuncSta funcSta : funcStaList) { |
| | | boolean beIdle = funcStaService.isCanBeIdle(funcSta); |