package com.mes.job;
|
|
import cn.smallbun.screw.core.util.CollectionUtils;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.mes.common.S7object;
|
import com.mes.common.config.Const;
|
import com.mes.device.PlcParameterObject;
|
import com.mes.temperingglass.entity.TemperingGlassInfo;
|
import com.mes.temperingglass.service.TemperingGlassInfoService;
|
import com.mes.temperingrecord.entity.TemperingRecord;
|
import com.mes.temperingrecord.service.TemperingRecordService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Author : zhoush
|
* @Date: 2024/7/17 12:47
|
* @Description:
|
*/
|
@Component
|
@Slf4j
|
public class TemperingTask {
|
|
@Autowired
|
private TemperingRecordService temporalRecordService;
|
|
@Autowired
|
private TemperingGlassInfoService temporaryGlassInfoService;
|
private static final String ALONE_STATE = "0";
|
|
|
@Scheduled(fixedDelay = 1000)
|
public void temperingGlassBefore() {
|
Date startDate = new Date();
|
log.info("本次任务开始执行时间：{}", startDate);
|
PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
|
String state = plcParameterObject.getPlcParameter("state").getValue();
|
// 当前连线状态为
|
if (ALONE_STATE.equals(state)) {
|
log.info("当前钢化炉连线模式为：{},不执行该任务", state);
|
return;
|
}
|
//将确认字置为0
|
S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("confirmationWord").getAddress(), 0);
|
|
//todo:获取钢化版图中状态为2的（进炉完成的玻璃信息） 且不存在钢化记录表内的
|
List<Object> temperRecordIdListObj = temporalRecordService.listObjs(new QueryWrapper<TemperingRecord>().select("distinct tempering_layout_id"));
|
|
List<String> temperRecordIdList = temperRecordIdListObj.stream().map(String::valueOf).collect(Collectors.toList());
|
List<TemperingGlassInfo> list = temporaryGlassInfoService.list(new LambdaQueryWrapper<TemperingGlassInfo>()
|
.eq(TemperingGlassInfo::getState, Const.TEMPERING_START).notIn(TemperingGlassInfo::getTemperingLayoutId, temperRecordIdList));
|
if (CollectionUtils.isEmpty(list)) {
|
log.info("当前系统没有需要钢化的玻璃信息");
|
return;
|
}
|
List<Integer> temperingLayoutIdList = list.stream().map(TemperingGlassInfo::getTemperingLayoutId).distinct().collect(Collectors.toList());
|
if (CollectionUtils.isNotEmpty(temperRecordIdList)) {
|
temperingLayoutIdList.removeAll(temperRecordIdList);
|
}
|
if (CollectionUtils.isEmpty(temperingLayoutIdList)) {
|
log.info("当前玻璃有正在钢化的任务");
|
}
|
// 获取钢化下片表状态为2的玻璃信息
|
|
//完成任务将确认字置为1
|
S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("confirmationWord").getAddress(), 1);
|
}
|
|
@Scheduled(fixedDelay = 1000)
|
public void temperingGlassAfter() {
|
|
}
|
}
|
