工单分页bug

xiangpei

2024-08-30 f7df98e8a755086952dfe5eec8cefa2b56efd91e

 ycl-server/src/main/java/com/ycl/task/WorkOrderImgTask.java

@@ -15,6 +15,7 @@
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;
@@ -41,13 +42,17 @@
            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;
        }
@@ -60,7 +65,7 @@
            return;
        }
        for (DeviceInfoVO deviceInfo : deviceList) {
//            executorService.submit(() -> {
            executorService.submit(() -> {
                // 国标设备的编码就是取视频流的设备编码，国标设备就一个。国标设备的每一个通道代表一个摄像头，也就是设备id是取流的通道id
                String frameImg = workOrderService.getFrameImgByDevice(gbDevices.get(0).getDeviceId(), deviceInfo.getDeviceId(), deviceInfo.getWorkOrderNo());
                if (StringUtils.hasText(frameImg)) {
@@ -70,8 +75,9 @@
                    img.setCreateTime(new Date());
                    workOrderCheckImgMapper.insert(img);
                }
//            });
            });
        }
        executorService.shutdown();
    }

}