| | |
|---|
| | | 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)) { |
|---|
| | | Map<String, WorkstationDTO> workstationsMap = workstationCache.getWorkstations(); |
|---|
| | | if (ObjectUtil.isNotEmpty(workstationsMap)) { |
|---|
| | | |
|---|
| | | Set<Long> workStationIds = workstations.keySet(); |
|---|
| | | log.info("聚合状态工位总数:{}",workStationIds.size()); |
|---|
| | | for(Long workstationId :workStationIds) { |
|---|
| | | Set<String> workstationIds = workstationsMap.keySet(); |
|---|
| | | |
|---|
| | | log.info("聚合状态工位总数:{}",workstationsMap.size()); |
|---|
| | | |
|---|
| | | |
|---|
| | | for(String workstationId :workstationIds) { |
|---|
| | | log.info("开始聚合工位{}的状态",workstationId); |
|---|
| | | deviceStateAggregateService.stateAggregate(workstationId); |
|---|
| | | Long wid = Long.parseLong(workstationId); |
|---|
| | | deviceStateAggregateService.stateAggregate(wid); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | log.info("聚合状态整体结束"); |
|---|
