copy from JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCTurn.java
copy to JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCManualReporting.java
| File was copied from JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCTurn.java |
| | |
|---|
| | | import cn.hutool.json.JSONObject; |
|---|
| | | import com.mes.common.S7object; |
|---|
| | | import com.mes.device.PlcParameterObject; |
|---|
| | | import com.mes.md.entity.Tasking; |
|---|
| | | import com.mes.md.entity.PrimitiveTask; |
|---|
| | | import com.mes.md.mapper.MachineMapper; |
|---|
| | | import com.mes.md.service.PrimitiveTaskService; |
|---|
| | | import com.mes.md.service.TaskingService; |
|---|
| | | import com.mes.tools.WebSocketServer; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | |
|---|
| | | |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Objects; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @author SNG-010 |
|---|
| | | */ |
|---|
| | | @Component |
|---|
| | | @Slf4j |
|---|
| | | public class PLCTurn { |
|---|
| | | public class PLCManualReporting { |
|---|
| | | |
|---|
| | | PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; |
|---|
| | | @Autowired |
|---|
| | | TaskingService taskingService; |
|---|
| | | //@Scheduled(fixedDelay = 500) |
|---|
| | | public void plcTurn() { |
|---|
| | | //清洗机速度 |
|---|
| | | String rinseSpeed = plcParameterObject.getPlcParameter("rinseSpeed").getValue(); |
|---|
| | | if(!Objects.equals(rinseSpeed, "")){ |
|---|
| | | //给翻片台发送磨边机速度 |
|---|
| | | S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("turnSpeed").getAddress(), Integer.parseInt(rinseSpeed)); |
|---|
| | | } |
|---|
| | | @Autowired |
|---|
| | | MachineMapper machineMapper; |
|---|
| | | @Autowired |
|---|
| | | PrimitiveTaskService primitiveTaskService; |
|---|
| | | |
|---|
| | | } |
|---|
| | | //@Scheduled(fixedDelay = 1000) |
|---|
| | | public void turnWeb() { |
|---|
| | | //获取报警状态 |
|---|
| | | String warning = plcParameterObject.getPlcParameter("turnWarning").getValue(); |
|---|
| | | //@Scheduled(fixedDelay = 500) |
|---|
| | | @Scheduled(fixedDelay = 1000) |
|---|
| | | public void manualReporting() { |
|---|
| | | |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | if (!Objects.equals(warning, "0")) { |
|---|
| | | //log.info("报警信息："+warning); |
|---|
| | | jsonObject.append("turnWarning", warning); |
|---|
| | | } |
|---|
| | | ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("turn"); |
|---|
| | | List<PrimitiveTask> taskingList = primitiveTaskService.selectPrimitiveTask(new PrimitiveTask()); |
|---|
| | | jsonObject.append("taskingList", taskingList); |
|---|
| | | ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("manualReporting"); |
|---|
| | | if (sendwServer != null) { |
|---|
| | | for (WebSocketServer webserver : sendwServer) { |
|---|
| | | if (webserver != null) { |
|---|
