//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();
|
// }
|
// }
|
// }
|
//}
|
