package com.mes.job;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.github.xingshuangs.iot.protocol.modbus.service.ModbusTcp;
|
import com.github.xingshuangs.iot.protocol.s7.serializer.S7Serializer;
|
import com.kangaroohy.milo.model.ReadWriteEntity;
|
import com.kangaroohy.milo.service.MiloService;
|
import com.mes.common.config.Const;
|
import com.mes.pp.entity.OptimizeHeatDetail;
|
import com.mes.pp.entity.OptimizeHeatLayout;
|
import com.mes.pp.service.OptimizeHeatDetailService;
|
import com.mes.pp.service.OptimizeHeatLayoutService;
|
import com.mes.s7.entity.S7DataGHOne;
|
import com.mes.temperingglass.entity.TemperingGlassInfo;
|
import com.mes.temperingglass.service.TemperingGlassInfoService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
import java.util.Optional;
|
|
|
@Component
|
@Slf4j
|
public class OpcNGTemperingTask {
|
|
@Autowired(required = false)
|
MiloService miloService;
|
|
@Autowired
|
private TemperingGlassInfoService temperingAgoService;
|
|
@Autowired
|
private OptimizeHeatLayoutService optimizeHeatLayoutService;
|
|
@Autowired
|
private OptimizeHeatDetailService optimizeHeatDetailService;
|
|
@Autowired
|
@Qualifier("s7SerializerGHOne")
|
private S7Serializer s7SerializerGHOne;
|
|
@Autowired
|
ModbusTcp tempModbusTcp;
|
|
private Integer offset = 40001;
|
|
/**
|
* 摆片台请求进片逻辑处理
|
* fixedRate : 上一个调用开始后再次调用的延时（不用等待上一次调用完成）
|
* fixedDelay : 上一个调用结束后再次调用的延时
|
*/
|
@Scheduled(fixedDelay = 1000)
|
public void requestTemperingTask() throws Exception {
|
S7DataGHOne s7DataGHOne = s7SerializerGHOne.read(S7DataGHOne.class);
|
log.info("读取到的GH1S7.GH1S7数据：{}", s7DataGHOne);
|
Integer request = (int) s7DataGHOne.getRequestInTempering();
|
Integer id = (int) s7DataGHOne.getRequestTemperingId();
|
if (request == 0) {
|
s7SerializerGHOne.write(
|
S7DataGHOne.builder().responseInTempering(0).build()
|
);
|
} else {
|
if (id == 0) {
|
log.info("炉号不能为0");
|
return;
|
}
|
String placedNumber = s7DataGHOne.getPlacedNumber().toString();//已摆片数量
|
List<TemperingGlassInfo> glassList = temperingAgoService.selectGlassInfoById(id);
|
if (Integer.parseInt(placedNumber) == glassList.size()) {
|
s7SerializerGHOne.write(
|
S7DataGHOne.builder().responseInTempering(1).build()
|
);
|
} else {
|
s7SerializerGHOne.write(
|
S7DataGHOne.builder().responseInTempering(2).build()
|
);
|
}
|
}
|
}
|
|
/**
|
* 钢化上片台下发参数逻辑处理
|
* fixedRate : 上一个调用开始后再次调用的延时（不用等待上一次调用完成）
|
* fixedDelay : 上一个调用结束后再次调用的延时
|
*/
|
@Scheduled(fixedDelay = 1000)
|
public void loadTemperingTask() throws Exception {
|
S7DataGHOne s7DataGHOne = s7SerializerGHOne.read(S7DataGHOne.class);
|
log.info("读取到的GH1S7.GH1S7数据：{}", s7DataGHOne);
|
Integer loadTemperingId = s7DataGHOne.getLoadTemperingId();//进片完成 炉号ID
|
getNewTemperingID(loadTemperingId);//进片完成 下发参数
|
}
|
|
/**
|
* 更新钢化小片表内的玻璃状态
|
* fixedRate : 上一个调用开始后再次调用的延时（不用等待上一次调用完成）
|
* fixedDelay : 上一个调用结束后再次调用的延时
|
*/
|
@Scheduled(fixedDelay = 5000)
|
public void updateTemperingTask() throws Exception {
|
int furanchiIdEntity = tempModbusTcp.readUInt16(40461 - offset);
|
if (StringUtils.isNotBlank(furanchiIdEntity + "")) {
|
int temperingid = furanchiIdEntity;
|
temperingAgoService.update(new LambdaUpdateWrapper<TemperingGlassInfo>().set(TemperingGlassInfo::getState, Const.TEMPERING_START)
|
.in(TemperingGlassInfo::getState, Const.TEMPERING_OUT, Const.TEMPERING_DROP).eq(TemperingGlassInfo::getTemperingLayoutId, temperingid));
|
}
|
|
|
}
|
|
//获取到炉号id执行参数下发任务
|
private void getNewTemperingID(Integer temperingid) throws Exception {
|
int autoStatus = tempModbusTcp.readUInt16(40451 - offset);
|
if (1 != autoStatus) {
|
log.info("当前为非联机状态，结束钢化下发参数任务");
|
return;
|
}
|
int QandA = tempModbusTcp.readUInt16(40422 - offset);
|
int RecipeStatus = tempModbusTcp.readUInt16(40456 - offset);
|
if (1 == QandA && 2 == RecipeStatus) {
|
log.info("版面信息已经下发，并且已经匹配参数，结束钢化下发参数任务");
|
return;
|
}
|
List<TemperingGlassInfo> glassList = temperingAgoService.selectGlassInfoById(temperingid);
|
if (glassList != null && glassList.size() > 0) {
|
int glasstype = GetGlassType(glassList.get(0).getFilmsId());//膜系
|
int process = 0;//钢化类型
|
int thiness = (int) glassList.get(0).getThickness();//厚度
|
String engineerId = glassList.get(0).getEngineerId();
|
Integer temperingLayoutId = glassList.get(0).getTemperingLayoutId();
|
OptimizeHeatLayout heatLayoutinfo = optimizeHeatLayoutService.selectHeatLayoutInfo(engineerId, temperingLayoutId);
|
int loadingRate = (int) (heatLayoutinfo.getLayoutRate() * 100); //装载率
|
loadingRate = loadingRate > 10000 ? 10000 : loadingRate;
|
List<OptimizeHeatDetail> heatDetailGlassInfoList = optimizeHeatDetailService.selectHeatDetailGlassInfo(engineerId, temperingLayoutId);
|
|
Optional<Double> maxProductOpt = heatDetailGlassInfoList.stream()
|
.map(ohd -> ohd.getWidth() * ohd.getHeight())
|
.max(Double::compareTo);
|
double totalarea = heatDetailGlassInfoList.stream().mapToDouble(ohd -> ohd.getWidth() * ohd.getHeight()).sum();
|
|
int shape = 0; //最大片占总面积的比例
|
if (maxProductOpt.isPresent()) {
|
shape = (int) (maxProductOpt.get() / totalarea * 100);
|
}
|
shape = shape > 10000 ? 10000 : shape;
|
int workmode = 0; //工位数
|
int furmode = 0; //双室/联室
|
tempModbusTcp.writeUInt16(40408 - offset, temperingid);
|
tempModbusTcp.writeUInt16(40409 - offset, glasstype);
|
tempModbusTcp.writeUInt16(40411 - offset, process);
|
tempModbusTcp.writeUInt16(40412 - offset, thiness);
|
tempModbusTcp.writeUInt16(40413 - offset, loadingRate);
|
tempModbusTcp.writeUInt16(40414 - offset, shape);
|
tempModbusTcp.writeUInt16(40415 - offset, workmode);
|
tempModbusTcp.writeUInt16(40416 - offset, furmode);
|
|
log.info("炉号" + temperingid + "版面信息尝试下发");
|
}
|
}
|
|
|
//根据膜系返回玻璃类型
|
private int GetGlassType(String glasstype) {
|
int result = 0;
|
String str = glasstype.toLowerCase();
|
if (str.contains("白玻")) {
|
result = 0;
|
}
|
if (str.contains("超白")) {
|
result = 4;
|
}
|
if (str.contains("lowe") || str.contains("low-e")) {
|
result = 1;
|
}
|
if (str.contains("双银")) {
|
result = 2;
|
}
|
if (str.contains("三银")) {
|
result = 3;
|
}
|
if (str.contains("热反射")) {
|
result = 5;
|
}
|
return result;
|
}
|
|
private ReadWriteEntity generateReadWriteEntity(String identifier, Object value) {
|
return ReadWriteEntity.builder()
|
.identifier(identifier)
|
//Kep中是Long类型，即：Int32，Java中的int类型
|
.value(value)
|
.build();
|
}
|
}
|
