| | |
| | | import org.springframework.util.StringUtils; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Calendar; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.concurrent.ArrayBlockingQueue; |
| | |
| | | 24, |
| | | 5000, |
| | | TimeUnit.SECONDS, |
| | | new ArrayBlockingQueue<>(10), |
| | | new ArrayBlockingQueue<>(600), |
| | | new ThreadPoolExecutor.CallerRunsPolicy() |
| | | ); |
| | | |
| | | public void run() { |
| | | // 查出故障的设备 |
| | | List<DeviceInfoVO> deviceList = workOrderService.hasErrorWorkOrderList(); |
| | | // 查出最近一周的故障的设备 |
| | | Date now = new Date(); |
| | | Calendar ca = Calendar.getInstance(); |
| | | ca.setTime(now); |
| | | ca.add(Calendar.DATE, -6); |
| | | List<DeviceInfoVO> deviceList = workOrderService.hasErrorWorkOrderList(now, ca.getTime()); |
| | | if (CollectionUtils.isEmpty(deviceList)) { |
| | | return; |
| | | } |