package com.qianwen.mdc.service;
|
|
import java.text.DateFormat;
|
import java.text.SimpleDateFormat;
|
import java.util.List;
|
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.qianwen.mdc.domain.Machine;
|
import com.qianwen.mdc.domain.MachineAccount;
|
import com.qianwen.mdc.domain.MachineStatus;
|
import com.qianwen.mdc.domain.MachineStatusHistory;
|
import com.qianwen.mdc.domain.MachineUtilization;
|
import com.qianwen.mdc.domain.Section;
|
import com.qianwen.mdc.domain.workshop.Workshop;
|
import com.qianwen.mdc.mapper.MachineAccountMapper;
|
import com.qianwen.mdc.mapper.MachineMapper;
|
import com.qianwen.mdc.mapper.MachineStatusHistoryMapper;
|
import com.qianwen.mdc.mapper.MachineStatusMapper;
|
import com.qianwen.mdc.mapper.MdcUtilizationMapper;
|
import com.qianwen.mdc.mapper.SectionMapper;
|
import com.qianwen.mdc.mapper.WorkshopMapper;
|
import com.qianwen.mdc.utils.TimestampUtil;
|
|
|
/**
|
* 数据归档服务,将 machine_status 数据导入machine_status_history表,并加入最新的machine_status数据
|
*/
|
@Component
|
@Async
|
public class MdcDataArchiveService {
|
|
@Autowired
|
private MachineMapper machineMapper;
|
@Autowired
|
private WorkshopMapper workshopMapper;
|
@Autowired
|
private SectionMapper sectionMapper;
|
@Autowired
|
private MachineStatusMapper machineStatusMapper;
|
@Autowired
|
private MachineStatusHistoryMapper machineStatusHistoryMapper;
|
|
@Autowired
|
private MachineAccountMapper machineAccountMapper;
|
@Autowired
|
private MdcUtilizationMapper mdcUtilizationMapper;
|
|
|
|
@Scheduled(cron = "0 10 8 * * ?")
|
public void dataArchive() {
|
int dayStart = (int) TimestampUtil.getShiftDayStartTimestamp();
|
/*
|
Example statusExample = new Example(MdcMachineStatus.class);
|
statusExample.createCriteria().andLessThan("time", dayStart);
|
List<MdcMachineStatus> mdcMachineStatusList = mdcMachineStatusMapper.selectByExample(statusExample);
|
*/
|
LambdaQueryWrapper<MachineStatus> wrapper = Wrappers.lambdaQuery();
|
wrapper.lt(MachineStatus::getTime, dayStart);
|
|
List<MachineStatus> machineStatusList = machineStatusMapper.selectList(wrapper);
|
|
for (MachineStatus status : machineStatusList) {
|
MachineStatusHistory statusHistory = new MachineStatusHistory();
|
BeanUtils.copyProperties(status, statusHistory);
|
statusHistory.setId(null);
|
|
machineStatusHistoryMapper.insert(statusHistory);
|
machineStatusMapper.deleteById(status.getId());
|
|
MachineUtilization mdcUtilization = new MachineUtilization();
|
mdcUtilization.setId(null);
|
/*
|
Example accountExample = new Example(MdcMachineAccount.class);
|
accountExample.setOrderByClause("id desc");
|
accountExample.createCriteria().andEqualTo("machineId", status.getMachineId());
|
RowBounds rowBounds = new RowBounds(0, 1);
|
List<MdcMachineAccount> list = mdcMachineAccountMapper.selectByExampleAndRowBounds(accountExample, rowBounds);
|
*/
|
QueryWrapper<MachineAccount> wrapperAcc = Wrappers.query();
|
wrapperAcc.eq("machine_id", status.getMachineId());
|
wrapperAcc.orderByDesc("id");
|
|
//List<MdcMachineAccount> list = mdcMachineAccountMapper.selectList(wrapperAcc);
|
List<MachineAccount> list = machineAccountMapper.lastByMachineId(status.getMachineId());
|
if (list.isEmpty()) {
|
continue;
|
}
|
MachineAccount account = list.get(0);
|
|
//统计利用率数据并入库
|
mdcUtilization.setUid(account.getUuid());
|
mdcUtilization.setName(account.getCategory());
|
//mdcUtilization.setModel(account.getModel());
|
//TODO 设备类型??如果是，就是mdcUtilization.setModel(account.getType());
|
//mdcUtilization.setCategory(account.getType());
|
mdcUtilization.setModel(account.getType());
|
mdcUtilization.setCategory(account.getCategory());
|
|
|
mdcUtilization.setCncSystem(account.getCncSystem());
|
|
Machine machine = machineMapper.selectById(status.getMachineId());
|
Workshop workshop = workshopMapper.selectById(machine.getWorkshopId());
|
Section section = sectionMapper.selectById(machine.getSectionId());
|
if(workshop != null) {
|
mdcUtilization.setWorkshop(workshop.getName());
|
}
|
|
if(section != null) {
|
mdcUtilization.setSection(section.getName());
|
}
|
mdcUtilization.setShift(machine.getShiftType());
|
|
DateFormat df = new SimpleDateFormat("yyyyMMdd");
|
mdcUtilization.setCdate(df.format((long) status.getTime() * 1000));
|
|
//mdcUtilization.setCutTime(Integer.valueOf(status.getVar2()));
|
mdcUtilization.setCutTime(status.getCycleTime());
|
//mdcUtilization.setBootTime(Integer.valueOf(status.getVar3()));
|
mdcUtilization.setBootTime(status.getMachineOnTime());
|
|
String downTime = status.getVar8();
|
if ("".equals(downTime)) {
|
mdcUtilization.setDownTime(0);
|
} else {
|
mdcUtilization.setDownTime(Integer.valueOf(status.getVar8()));
|
}
|
mdcUtilization.setThreeShiftTime(3600 * 21);
|
mdcUtilization.setTwoShiftTime((int) (3600 * 15.5));
|
mdcUtilization.setFactory(2);
|
|
mdcUtilizationMapper.insert(mdcUtilization);
|
}
|
|
}
|
|
}
|
