package com.qianwen.mdc.collect.job;
|
|
import com.qianwen.mdc.collect.cache.WorkstationCache;
|
import com.qianwen.mdc.collect.dto.WorkstationDTO;
|
import com.qianwen.mdc.collect.service.DeviceStateAggregateService;
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.xxl.job.core.log.XxlJobLogger;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import java.util.Map;
|
import java.util.Set;
|
|
import javax.annotation.Resource;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
public class DeviceStatusAggregateJob {
|
private static final Logger log = LoggerFactory.getLogger(DeviceStatusAggregateJob.class);
|
@Resource
|
private DeviceStateAggregateService deviceStateAggregateService;
|
@Autowired
|
private WorkstationCache workstationCache;
|
@XxlJob("workStationAggregateJobHandler")
|
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();
|
log.info("聚合状态工位总数:{}",workStationIds.size());
|
for(Long workstationId :workStationIds) {
|
log.info("开始聚合工位{}的状态",workstationId);
|
deviceStateAggregateService.stateAggregate(workstationId);
|
}
|
}
|
log.info("聚合状态整体结束");
|
XxlJobLogger.log("XXL-JOB, 定时计算工位的状态，产量等信息,发送结束", new Object[0]);
|
return ReturnT.SUCCESS;
|
}
|
}
|
