package com.lxzn.modules.master.job;
|
|
import com.lxzn.modules.assembly2.entity.TcOpstate;
|
import com.lxzn.modules.assembly2.service.ITcOpstateService;
|
import com.lxzn.modules.master.entity.Assembly2TcOpstate;
|
import com.lxzn.modules.master.service.IAssembly2TcOpstateService;
|
import com.lxzn.modules.master.service.IEquipmentLogService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.List;
|
import java.util.Map;
|
|
@Slf4j
|
@Component
|
public class EquipmentLogCollectJob {
|
@Autowired
|
private IAssembly2TcOpstateService assembly2TcOpstateService;
|
@Autowired
|
private ITcOpstateService tcOpstateService;
|
@Autowired
|
private IEquipmentLogService equipmentLogService;
|
|
@Scheduled(initialDelay = 10000, fixedDelay = 15000)
|
public void equipmentLogCollect() {
|
log.info("------------2#装配线采集设备状态开始------------");
|
long startTime = System.currentTimeMillis();
|
try {
|
//上次采集数据
|
Map<String, Assembly2TcOpstate> oldStateMap = assembly2TcOpstateService.listStateMap();
|
//本次读取
|
List<TcOpstate> nevStateList = tcOpstateService.list();
|
if (CollectionUtils.isEmpty(nevStateList)) {
|
return;
|
}
|
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
}
|
long endTime = System.currentTimeMillis();
|
long duration = (endTime - startTime) / 1000;
|
log.info("------------2#装配线采集设备状态结束：消耗时长：{}S------------", duration);
|
}
|
}
|
