package com.mes.plcTaskThread;
|
|
import com.mes.md.entity.Machine;
|
import com.mes.md.entity.Tasking;
|
import com.mes.md.mapper.MachineMapper;
|
import com.mes.md.service.TaskingService;
|
import com.mes.service.ModbusTcp;
|
import com.mes.service.PlcAgreement;
|
import com.mes.service.PlcParameter;
|
import com.mes.utils.HexUtil;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
@Slf4j
|
public class MachineDispensing extends Thread {
|
|
|
private MachineMapper machineMapper;
|
private TaskingService taskingService;
|
public static Long machineId = 16L;
|
public List<Map> sendRecords = new ArrayList<>();
|
public Machine thisMachine;
|
|
public MachineDispensing(Machine machine, MachineMapper machineMapper, TaskingService taskingService) {
|
this.thisMachine = machine;
|
this.machineMapper = machineMapper;
|
this.taskingService = taskingService;
|
}
|
|
public void plcStart() {
|
Machine machine = machineMapper.selectById(thisMachine.getId());
|
String fileName = machine.getFileName();
|
ModbusTcp modbusTcp1 = new ModbusTcp(machine.getIp(), machine.getPort(), fileName);
|
modbusTcp1.connect();
|
PlcAgreement plcAgreement = modbusTcp1.getPlcAgreement(fileName);
|
try {
|
if (!modbusTcp1.read(plcAgreement)) {
|
log.info("通讯读取新数据失败");
|
modbusTcp1.close();
|
return;
|
}
|
PlcParameter plcRequest = plcAgreement.getPlcParameter("plcRequest");//请求字
|
PlcParameter plcRequestID = plcAgreement.getPlcParameter("plcRequestID");//请求ID
|
PlcParameter mesSend = plcAgreement.getPlcParameter("mesSend");//发送字
|
PlcParameter mesSendID = plcAgreement.getPlcParameter("mesSendID");//发送ID
|
// PlcParameterInfo drawingMark =plcParameterObject.getPlcParameter("drawingGlue");//点胶图纸地址
|
PlcParameter JPZX = plcAgreement.getPlcParameter("JPZX");//类型
|
PlcParameter thickness = plcAgreement.getPlcParameter("thickness");//厚
|
PlcParameter side1 = plcAgreement.getPlcParameter("side1");//下边
|
PlcParameter side2 = plcAgreement.getPlcParameter("side2");//右边
|
PlcParameter side3 = plcAgreement.getPlcParameter("side3");//上边
|
PlcParameter side4 = plcAgreement.getPlcParameter("side4");//左边
|
PlcParameter R_angle1_1 = plcAgreement.getPlcParameter("R_angle1_1");//R角1-1
|
PlcParameter R_angle1_2 = plcAgreement.getPlcParameter("R_angle1_2");//R角1-2
|
PlcParameter R_angle2_1 = plcAgreement.getPlcParameter("R_angle2_1");//R角2-1
|
PlcParameter R_angle2_2 = plcAgreement.getPlcParameter("R_angle2_2");//R角2-2
|
PlcParameter R_angle3_1 = plcAgreement.getPlcParameter("R_angle3_1");//R角3-1
|
PlcParameter R_angle3_2 = plcAgreement.getPlcParameter("R_angle3_2");//R角3-2
|
PlcParameter R_angle4_1 = plcAgreement.getPlcParameter("R_angle4_1");//R角4-1
|
PlcParameter R_angle4_2 = plcAgreement.getPlcParameter("R_angle4_2");//R角4-2
|
|
PlcParameter plcReport = plcAgreement.getPlcParameter("plcReport");//汇报字
|
PlcParameter plcReportID = plcAgreement.getPlcParameter("plcReportID");//汇报ID
|
PlcParameter mesConfirm = plcAgreement.getPlcParameter("mesConfirm");//确认字
|
PlcParameter mesConfirmID = plcAgreement.getPlcParameter("mesConfirmID");//确认ID
|
PlcParameter machineStatusWord = plcAgreement.getPlcParameter("machineStatusWord");
|
if (machine.getIsLog() > 0) {
|
modbusTcp1.consoleLogInfo(plcAgreement);
|
}
|
|
if (0 == plcRequest.getValueInt() && 1 == mesSend.getValueInt()) {
|
log.info("1.发送字置零");
|
//发送字置0
|
String send = HexUtil.intTo2ByteHex(0);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesSend.getAddressStart() / 2));
|
log.info("发送字 清空成功；内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesSend.getAddressStart()));
|
modbusTcp1.close();
|
return;
|
}
|
if (0 == plcReport.getValueInt() && 0 != mesConfirm.getValueInt()) {
|
log.info("2.确认字置零");
|
//发送字置0
|
String send = HexUtil.intTo2ByteHex(0);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
|
log.info("任务完成 清空成功；内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
|
modbusTcp1.close();
|
return;
|
}
|
if (1 == plcReport.getValueInt() && 0 == mesConfirm.getValueInt()) {
|
int finishCount = taskingService.finishMachineTask(machine);
|
log.info("3、任务完成");
|
if (finishCount > 0) {//有任务
|
String send = HexUtil.intTo2ByteHex(1);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
|
log.info("任务完成 成功 内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
|
modbusTcp1.close();
|
return;
|
}
|
String send = HexUtil.intTo2ByteHex(1);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
|
log.info("任务完成 异常成功 内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
|
modbusTcp1.close();
|
return;
|
}
|
if (4 == plcReport.getValueInt() && 0 == mesConfirm.getValueInt()) {
|
int finishCount = taskingService.glassDownLineOne(machine);
|
if (finishCount > 0) {//有任务
|
log.info("4、人工拿走");
|
String send = HexUtil.intTo2ByteHex(4);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
|
log.info("人工拿走发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
|
modbusTcp1.close();
|
return;
|
}
|
String send = HexUtil.intTo2ByteHex(4);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
|
log.info("人工拿走异常 发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
|
modbusTcp1.close();
|
return;
|
}
|
if (2 == plcReport.getValueInt() && 0 == mesConfirm.getValueInt()) {
|
int finishCount = taskingService.loseMachineTask(machine);
|
if (finishCount > 0) {//有任务
|
log.info("2、重发");
|
String send = HexUtil.intTo2ByteHex(2);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
|
log.info("重发发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
|
modbusTcp1.close();
|
return;
|
} else {
|
log.info("2、异常重发");
|
String send = HexUtil.intTo2ByteHex(2);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
|
log.info("异常重发发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
|
modbusTcp1.close();
|
return;
|
}
|
}
|
|
if (3 == plcReport.getValueInt() && 0 == mesConfirm.getValueInt()) {
|
int finishCount = taskingService.finishMachineTask(machine);
|
if (finishCount > 0) {//有任务
|
log.info("3、设备上人工点破损");
|
String send = HexUtil.intTo2ByteHex(3);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
|
log.info("人工点破损发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
|
modbusTcp1.close();
|
return;
|
} else {
|
//是否自动清除破损
|
log.info("3、无效破损 （没有找到此ID的玻璃）");
|
String send = HexUtil.intTo2ByteHex(3);
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
|
log.info("发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
|
modbusTcp1.close();
|
//modbusTcp1.close();
|
return;
|
}
|
}
|
List<Tasking> taskingCount = taskingService.findMachineWorkStateTask(machine, "正在工作");
|
if ((1 == plcRequest.getValueInt() && 0 == mesSend.getValueInt())
|
&& "开工".equals(machine.getState())
|
&& taskingCount.size() < machine.getMaxTaskCount()) {
|
Tasking tasking = taskingService.startMachineTask(machine);
|
if (tasking != null) {
|
log.info("4、发送任务 任务数据：{}, 设备状态:{}, ", machine, tasking);
|
String send =
|
HexUtil.intTo2ByteHex(1) +
|
HexUtil.intTo2ByteHex(tasking.getTaskSequence().intValue())+
|
HexUtil.intTo2ByteHex(tasking.getJPZX()) +
|
HexUtil.intTo2ByteHex(tasking.getThickness().intValue()) +
|
HexUtil.intTo2ByteHex(tasking.getWidth().intValue()) + // side1 下边 = 宽度
|
HexUtil.intTo2ByteHex(tasking.getLength().intValue()) + // side2 右边 = 长度
|
HexUtil.intTo2ByteHex(tasking.getWidth().intValue()) + // side3 上边 = 宽度
|
HexUtil.intTo2ByteHex(tasking.getLength().intValue()) + // side4 左边 = 长度
|
HexUtil.intTo2ByteHex((int) ((tasking.getR_1_1() != null ? tasking.getR_1_1() : 0.0) * 10)) +
|
HexUtil.intTo2ByteHex((int) ((tasking.getR_1_2() != null ? tasking.getR_1_2() : 0.0) * 10)) +
|
HexUtil.intTo2ByteHex((int) ((tasking.getR_2_1() != null ? tasking.getR_2_1() : 0.0) * 10)) +
|
HexUtil.intTo2ByteHex((int) ((tasking.getR_2_2() != null ? tasking.getR_2_2() : 0.0) * 10)) +
|
HexUtil.intTo2ByteHex((int) ((tasking.getR_3_1() != null ? tasking.getR_3_1() : 0.0) * 10)) +
|
HexUtil.intTo2ByteHex((int) ((tasking.getR_3_2() != null ? tasking.getR_3_2() : 0.0) * 10)) +
|
HexUtil.intTo2ByteHex((int) ((tasking.getR_4_1() != null ? tasking.getR_4_1() : 0.0) * 10)) +
|
HexUtil.intTo2ByteHex((int) ((tasking.getR_4_2() != null ? tasking.getR_4_2() : 0.0) * 10)) ;
|
modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesSend.getAddressStart() / 2));
|
log.info("发送任务发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesSend.getAddressStart()));
|
modbusTcp1.close();
|
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String sendRecord = df.format(new Date()) + " " +
|
tasking.getGlassId() + "-" +
|
tasking.getLength() + "-" +
|
tasking.getWidth() + "-" +
|
tasking.getThickness() + "-" +
|
tasking.getR_1_1() + "-" +
|
tasking.getR_1_2() + "-" +
|
tasking.getR_2_1() + "-" +
|
tasking.getR_2_2() + "-" +
|
tasking.getR_3_1() + "-" +
|
tasking.getR_3_2() + "-" +
|
tasking.getR_4_1() + "-" +
|
tasking.getR_4_2() + "-" +
|
tasking.getJPZX();
|
if (sendRecords.size() > 7) {
|
sendRecords.remove(0);
|
}
|
Map sendContentMap = new HashMap();
|
sendContentMap.put("sendContent", sendRecord);
|
sendRecords.add(sendContentMap);
|
return;
|
}
|
}
|
//}
|
|
} catch (Exception e) {
|
log.info("交互逻辑错误");
|
}
|
|
modbusTcp1.close();
|
//log.info("无可执行的条件");
|
}
|
|
|
@Override
|
public void run() {
|
while (this != null) {
|
try {
|
Thread.sleep(1000);
|
plcStart();
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
