代码整理

yangys

2024-11-21 fe82f1f9a9be911d1420fe3b018ea85dd5fff1a3

 collect/src/main/java/com/qianwen/mdc/collect/job/DeviceStatusAggregateJob.java

@@ -29,15 +29,21 @@
    public ReturnT<String> workStationAggregateJobHandler(String param) throws Exception {
        XxlJobLogger.log("XXL-JOB, 定时计算工位的状态，产量等信息,开始发送.....", new Object[0]);
        
        
        Map<Long, WorkstationDTO> workstations = workstationCache.getWorkstations();
        if (ObjectUtil.isNotEmpty(workstations)) {
            Set<Long> workStationIds = workstations.keySet();
            for(Long workstationId :workStationIds) {
               deviceStateAggregateService.stateAggregate(workstationId);
        Map<String, WorkstationDTO> workstationsMap = workstationCache.getWorkstations();
        if (ObjectUtil.isNotEmpty(workstationsMap)) {
        	
            Set<String> workstationIds = workstationsMap.keySet();
            
            log.info("聚合状态工位总数:{}",workstationsMap.size());
        	
            
            for(String workstationId :workstationIds) {
               log.info("开始聚合工位{}的状态",workstationId);
               Long wid = Long.parseLong(workstationId);
               deviceStateAggregateService.stateAggregate(wid);
            }
        }
        
        log.info("聚合状态整体结束");
        XxlJobLogger.log("XXL-JOB, 定时计算工位的状态，产量等信息,发送结束", new Object[0]);
        return ReturnT.SUCCESS;
    }