|
|
@ -96,11 +96,9 @@ public class DeviceTaskServiceImpl implements IDeviceTaskService {
|
|
|
|
new LinkedBlockingQueue<Runnable>());
|
|
|
|
new LinkedBlockingQueue<Runnable>());
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
dateSources.forEach(dateSource -> {
|
|
|
|
dateSources.forEach(dateSource -> {
|
|
|
|
if("ds_1000".equals(dateSource.get("poolName"))){//TODO生产去掉
|
|
|
|
logger.info("++++++++++++" + dateSource.get("poolName") + "++++点检开始++++++++++");
|
|
|
|
logger.info("++++++++++++" + dateSource.get("poolName") + "++++点检开始++++++++++");
|
|
|
|
Runnable run = () -> createSpotCheckPlanFunc(dateSource.get("poolName"));
|
|
|
|
Runnable run = () -> createSpotCheckPlanFunc(dateSource.get("poolName"));
|
|
|
|
executorService.execute(run);
|
|
|
|
executorService.execute(run);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
});
|
|
|
|
});
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
logger.error("service == dataClearTask == exception", e);
|
|
|
|
logger.error("service == dataClearTask == exception", e);
|
|
|
|