义乌项目
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhoushihao
3 天以前 4e3b8155722b66e25df3c6fd42cc586b68dea391 
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java


@@ -1,31 +1,34 @@


package com.mes.job;




import cn.hutool.json.JSONObject;


import cn.smallbun.screw.core.util.CollectionUtils;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.kangaroohy.milo.model.ReadWriteEntity;


import com.kangaroohy.milo.service.MiloService;


import com.mes.bigstorage.entity.BigStorageCageDetails;


import com.mes.bigstorage.entity.dto.BigStorageSummaryDTO;


import com.mes.bigstorage.service.BigStorageCageDetailsService;


import com.mes.bigstorage.service.BigStorageCageService;


import com.mes.bigstoragecagetask.entity.BigStorageCageHistoryTask;


import com.mes.bigstoragecagetask.entity.BigStorageCageTask;


import com.mes.bigstoragecagetask.entity.BigStorageTaskVO;


import com.mes.bigstoragecagetask.service.BigStorageCageHistoryTaskService;


import com.mes.bigstoragecagetask.service.BigStorageCageTaskService;


import com.mes.glassinfo.entity.GlassInfo;


import com.mes.common.config.Const;


import com.mes.glassinfo.service.GlassInfoService;


import com.mes.largenscreen.entity.PieChartVO;


import com.mes.largenscreen.entity.RunTime;


import com.mes.temperingglass.entity.TemperingGlassInfo;


import com.mes.temperingglass.service.TemperingGlassInfoService;


import com.mes.tools.WebSocketServer;


import com.mes.utils.RedisUtil;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.scheduling.annotation.Scheduled;


import org.springframework.stereotype.Component;




import javax.annotation.Resource;


import java.io.BufferedReader;


import java.io.InputStreamReader;


import java.net.Socket;


import java.time.LocalDate;


import java.time.format.DateTimeFormatter;


import java.util.ArrayList;


import java.util.List;


import java.util.Map;


@@ -49,15 +52,11 @@


    private GlassInfoService glassInfoService;


    @Resource


    private BigStorageCageTaskService bigStorageCageTaskService;


    @Resource


    private BigStorageCageHistoryTaskService bigStorageCageHistoryTaskService;




    @Autowired(required = false)


    MiloService miloService;




    @Value("${mes.scan.ip}")


    private String scanIp;




    @Value("${mes.scan.port}")


    private Integer scanPort;




    private JSONObject jsonObject = new JSONObject();




@@ -67,19 +66,26 @@


        carPostion.add(0.5);


        jsonObject.append("carPostion", carPostion);


        //界面展示笼子信息


        jsonObject.append("bigStorageCageInfos", bigStorageCageService.querybigStorageCageDetail());


        jsonObject.append("bigStorageCageInfos", bigStorageCageDetailsService.querybigStorageCageDetail());




        try{


        try {


            //进片任务数据


            List<BigStorageCageTask> inTaskList = new ArrayList();


            List<BigStorageTaskVO> inTaskList = new ArrayList();


            ReadWriteEntity fromOpcUa = miloService.readFromOpcUa("DLP1A.DLP1A.FROM1");


            for (int i = 1; i <= 6; i++) {


                ReadWriteEntity requestWord = miloService.readFromOpcUa("DLP1A.DLP1A.DI" + i);


                ReadWriteEntity targetSlotWord = miloService.readFromOpcUa("DLP1A.DLP1A.TO" + i);


                ReadWriteEntity stateWord = miloService.readFromOpcUa("DLP1A.DLP1A.STATE" + i);


                if (null != requestWord.getValue()) {


                    BigStorageCageTask task = new BigStorageCageTask();


                    BigStorageTaskVO task = new BigStorageTaskVO();


                    task.setGlassId(requestWord.getValue() + "");


                    int isExistCount = bigStorageCageDetailsService.count(new LambdaQueryWrapper<BigStorageCageDetails>().in(BigStorageCageDetails::getGlassId, task.getGlassId())


                            .in(BigStorageCageDetails::getState, Const.GLASS_STATE_IN_ALL));


                    if (isExistCount > 0) {


                        task.setIsSame(1);


                    } else {


                        task.setIsSame(0);


                    }


                    task.setStartSlot(Integer.parseInt(fromOpcUa.getValue() + ""));


                    task.setTargetSlot(Integer.parseInt(targetSlotWord.getValue() + ""));


                    task.setTaskState(Integer.parseInt(stateWord.getValue() + ""));


@@ -88,7 +94,10 @@


                }


            }


            jsonObject.append("bigStorageCageDetailsFeedTask", inTaskList);




        } catch (Exception e) {


            //todo:不做任务处理


        }


        try {


            //进片联机


            ReadWriteEntity inkageEntity = miloService.readFromOpcUa("DLP1A.DLP1A.mesControl");


            jsonObject.append("inkageEntity", inkageEntity.getValue());


@@ -104,14 +113,14 @@


            //出片请求


            ReadWriteEntity outRequestEntity = miloService.readFromOpcUa("DLP1B.DLP1B.RequestMes");


            jsonObject.append("outRequestEntity", outRequestEntity.getValue());


        }catch(Exception e){






            //出片任务数据


            List<BigStorageCageTask> outTaskList = bigStorageCageTaskService.queryTaskMessage("big_storage_cage_out_one_task");


            jsonObject.append("bigStorageCageDetailsOutTask", outTaskList);


        } catch (Exception e) {


            //todo:不做任务处理


        }




        //出片任务数据


        List<BigStorageCageTask> outTaskList = bigStorageCageTaskService.queryTaskMessage("big_storage_cage_out_one_task");


        jsonObject.append("bigStorageCageDetailsOutTask", outTaskList);






        //钢化开关


        boolean temperingSwitch = false;


@@ -135,6 +144,9 @@


        List<Map<String, Object>> bigStorageCageUsage = bigStorageCageService.selectBigStorageCageUsage();


        jsonObject.append("bigStorageCageUsage", bigStorageCageUsage);




        //大理片汇总信息


        List<BigStorageSummaryDTO> bigStorageSummary = bigStorageCageService.selectBigStorageSummary();


        jsonObject.append("bigStorageSummary", bigStorageSummary);




        //打印开关


        boolean autoPrint = false;


@@ -178,7 +190,7 @@


            //查询使用数据源1查询数据


            queryDataSource1();


            //查询使用数据源2查询数据


            queryDataSource2();


//            queryDataSource2();




            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("slicecage");


            if (sendwServer != null) {


@@ -199,4 +211,31 @@


            e.printStackTrace();


        }


    }




    @Scheduled(fixedDelay = 1000)


    public void largenScreen() {


        JSONObject jsonObject = new JSONObject();


        //理片笼使用情况


        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("largenScreen");


        if (sendwServer != null) {


            List<Map<String, Object>> bigStorageCageUsage = bigStorageCageService.selectBigStorageCageUsage();


            jsonObject.append("bigStorageCageUsage", bigStorageCageUsage);


            List<PieChartVO> pieChartVOS = bigStorageCageService.queryPieChart();


            jsonObject.append("pieChartVOS", pieChartVOS);


            List<RunTime> tempRunTimes = bigStorageCageHistoryTaskService.queryRunTimes(LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));


            jsonObject.append("tempRunTimes", tempRunTimes);


            for (WebSocketServer webserver : sendwServer) {


                if (webserver != null) {


                    webserver.sendMessage(jsonObject.toString());


                    List<String> messages = webserver.getMessages();


                    if (!messages.isEmpty()) {


                        // // 将最后一个消息转换为整数类型的列表


                        webserver.clearMessages();


                    }


                } else {


                    log.info("largenScreen is closed");


                }


            }


        }


    }


}