package com.mes.common; import cn.hutool.core.date.DateTime; import cn.hutool.json.JSONObject; import com.github.yulichang.query.MPJLambdaQueryWrapper; import com.github.yulichang.wrapper.MPJLambdaWrapper; import com.mes.edgstoragecage.entity.EdgStorageCage; import com.mes.edgstoragecage.entity.EdgStorageCageDetails; import com.mes.edgstoragecage.mapper.EdgStorageCageDetailsMapper; import com.mes.edgstoragecage.service.EdgStorageCageDetailsService; import com.mes.edgstoragecage.service.EdgStorageCageService; import com.mes.glassinfo.entity.GlassInfo; import com.mes.glassinfo.service.GlassInfoService; import com.mes.taskcache.entity.TaskCache; import com.mes.taskcache.mapper.TaskCacheMapper; import com.mes.taskcache.service.TaskCacheService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; @Service @Slf4j public class PlcHomeEdg extends Thread { @Autowired TaskCacheService taskCacheService; @Autowired GlassInfoService glassInfoService; @Autowired EdgStorageCageService edgStorageCageService; @Autowired EdgStorageCageDetailsService edgStorageCageDetailsService; @Autowired private EdgStorageCageDetailsMapper edgStorageCageDetailsMapper; private Map mapParameter=new HashMap(); private Map mapValue=new HashMap(); private Map mapSettings=new HashMap(); private void initialize(){ mapParameter.put("A06_request_word","DB11.0"); mapParameter.put("A05_scanning_ID","DB11.2"); mapParameter.put("MES_confirmation_word","DB11.40"); mapParameter.put("A09_glass_status","DB11.70"); mapParameter.put("A10_glass_status","DB11.72"); mapParameter.put("A09_prohibit_film_production","DB11.74"); mapParameter.put("A10_prohibit_film_production","DB11.76"); mapSettings.put("territoryPoor",3); // mapValue.put("A06_request_word","1");//请求字 // mapValue.put("A05_scanning_ID","7");//请求ID // mapValue.put("MES_confirmation_word","0");//MES发送字 // mapValue.put("A09_glass_status","0");//A09玻璃状态 // mapValue.put("A10_glass_status","0");//A09玻璃状态 // mapValue.put("A09_prohibit_film_production","0");//A9禁止出片 // mapValue.put("A10_prohibit_film_production","0");//A10禁止出片 for (String key:mapParameter.keySet()){ String value=S7object.getinstance().plccontrol.readString(mapParameter.get(key)); mapValue.put(key,value); } } private void inTo(){ List glassInfos=glassInfoService.selectId(mapValue.get("A05_scanning_ID")); if(glassInfos.size()<1){ log.info("此玻璃编号不存在"); }else if(glassInfos.size()==1){ //添加进片任务 查找空格 log.info("正常"); List list=edgStorageCageService.selectCacheEmpty(); if(list.size()>1){ EdgStorageCageDetails edgStorageCageDetails=edgStorageCageDetailsMapper.selectOne(new MPJLambdaWrapper() .eq(EdgStorageCageDetails::getGlassId,glassInfos.get(0).getGlassId())); edgStorageCageDetails.setState(200); TaskCache taskCache=new TaskCache(); EdgStorageCage edgStorageCage=list.get(0); taskCache.setGlassId(glassInfos.get(0).getGlassId()); taskCache.setTaskStatus(0); taskCache.setStartCell(0); taskCache.setEndCell(edgStorageCage.getSlot()); taskCache.setTaskType(1); taskCache.setCreateTime(new DateTime()); edgStorageCageDetailsMapper.updateById(edgStorageCageDetails); taskCacheService.insertTaskCache(taskCache); }else{ log.info("不存在空格"); } }else{ log.info("此玻璃编号存在多个"); } } private void outTo(int line){ int endcell=0; EdgStorageCageDetails outEdgStorageCageDetails=new EdgStorageCageDetails(); TaskCache taskCacheA09=taskCacheService.selectLastOutCacheInfo(""); TaskCache taskCacheA10=taskCacheService.selectLastOutCacheInfo(""); //两线各自要出的玻璃 EdgStorageCageDetails glassInfo09=edgStorageCageDetailsService.selectConformGlass(taskCacheA09.getGlassId(),(int)mapSettings.get("territoryPoor")); EdgStorageCageDetails glassInfo10=edgStorageCageDetailsService.selectConformGlass(taskCacheA10.getGlassId(),(int)mapSettings.get("territoryPoor")); //决定线路 if(line==1){ endcell=9000; outEdgStorageCageDetails=glassInfo09; }else if(line==2){ endcell=1000; outEdgStorageCageDetails=glassInfo10; }else if(line==3){ endcell=9000;//默认走一号线 优化方向可根据 对比两线速度/两线当前任务情况做 outEdgStorageCageDetails=glassInfo09; } if(outEdgStorageCageDetails!=null&&endcell>0){ TaskCache taskCache=new TaskCache(); taskCache.setGlassId(outEdgStorageCageDetails.getGlassId()); taskCache.setTaskStatus(0); taskCache.setStartCell(outEdgStorageCageDetails.getSlot()); taskCache.setEndCell(endcell); taskCache.setTaskType(2); taskCache.setCreateTime(new DateTime()); taskCacheService.insertTaskCache(taskCache); } } @Override public void run() { boolean start=true; while (this != null&&start) { JSONObject jsonObject = new JSONObject(); try { Thread.sleep(1000); taskCacheService = WebSocketServer.applicationContext.getBean(TaskCacheService.class); glassInfoService = WebSocketServer.applicationContext.getBean(GlassInfoService.class); edgStorageCageService = WebSocketServer.applicationContext.getBean(EdgStorageCageService.class); edgStorageCageDetailsMapper = WebSocketServer.applicationContext.getBean(EdgStorageCageDetailsMapper.class); initialize();//初始化数据 log.info("当前参数值：{}",mapValue); if("0".equals(mapValue.get("A06_request_word"))){ //清除 //S7object.getinstance().plccontrol.WriteWord(mapParameter.get("MES_confirmation_word"),(short) 0); }else if("1".equals(mapValue.get("A06_request_word"))&& "0".equals(mapValue.get("MES_confirmation_word"))) { inTo(); }else if("2".equals(mapValue.get("A06_request_word"))&& "0".equals(mapValue.get("MES_confirmation_word"))&& ( "0".equals(mapValue.get("A09_glass_status"))|| "0".equals(mapValue.get("A10_glass_status")) ) ){ outTo(3); }else if("3".equals(mapValue.get("A06_request_word"))&& "0".equals(mapValue.get("MES_confirmation_word"))){ if("0".equals(mapValue.get("A09_glass_status"))||"0".equals(mapValue.get("A10_glass_status"))){ outTo(3); }else{ inTo(); } } // List address2=new ArrayList(); // address.add(""); // List list2= S7object.getinstance().plccontrol.readStrings(address); // PlcParameterObject plcmes=PLCAutoMes.PlcMesObject; // log.info("plcmes:{}",plcmes); // S7object.getinstance().plccontrol.WriteWord(plcmes.getPlcParameter("MESToGaStatus").getAddress(),(short) 1); // taskCacheMapper = WebSocketServer.applicationContext.getBean(TaskCacheMapper.class); // List list=taskCacheMapper.selectList(null); // log.info("数据{}",list); // 注入mapper // HomeService = WebSocketServer.applicationContext.getBean(HomeService.class); // QueueMapper = WebSocketServer.applicationContext.getBean(QueueMapper.class); // //读取DB105区文件 // PlcParameterObject plcmes=PLCAutoMes.PlcMesObject; // // String PlcRequest=plcmes.getPlcParameter("GaToMES").getValue();//请求 // String MesSend=plcmes.getPlcParameter("MESToGaStatus").getValue();//发送 // double width=Double.valueOf(plcmes.getPlcParameter("width").getValue());//宽 // double height=Double.valueOf(plcmes.getPlcParameter("Height").getValue());//高 //获取测量的长，宽 boolean istest = true; // String PlcRequest = "1"; // String MesSend = "0"; // double width = 516; // double height = 507; //System.out.println(111); // //查询当前订单任务 //List OrderTask = storageCageService.SelectOrderTask(); //jsonObject.append("OrderTask", OrderTask); } catch (InterruptedException e) { e.printStackTrace(); } // log.info("推数据"); // jsonObject.append("params", new short[] { 30, 40, }); ArrayList sendwServer = WebSocketServer.sessionMap.get("Home"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { webserver.sendMessage(jsonObject.toString()); if (webserver != null) { List messages = webserver.getMessages(); if (!messages.isEmpty()) { // // 将最后一个消息转换为整数类型的列表 webserver.clearMessages(); } } } } } } }