springboot-vue3/src/main/java/com/example/springboot/component/Plchome.java
@@ -1,29 +1,26 @@
package com.example.springboot.component;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.example.springboot.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import com.example.springboot.entity.Glass;
import com.example.springboot.entity.Out_slice;
import com.example.springboot.entity.Queue;
import com.example.springboot.entity.StorageCage;
import com.example.springboot.entity.alarmmg;
import com.example.springboot.entity.north_frame_buffer1_frames;
import com.example.springboot.entity.north_glass_buffer1;
import com.example.springboot.entity.device.PlcParameterObject;
import com.example.springboot.mapper.HomeMapper;
import com.example.springboot.mapper.SpianMapper;
@Slf4j
public class Plchome extends Thread {
    @Autowired
@@ -37,19 +34,28 @@
    public static Boolean isAllowQueue = true;
    public static Boolean isAllowReordering = true;
    // 出片队列警告
    public static Boolean isQueueWarning = true;
    public static Boolean isQueueWarning = false;
    // 铝框id
    public static String FrameNo = "";
    // 是否需要手动确认玻璃
    public static Boolean isConfirm = false;
    public static Boolean isConfirm = true;
    // 待确认的出片队列
    public static List<north_glass_buffer1> AluminumFrame;
    // 待确认的铝框信息
    public static north_frame_buffer1_frames AluminumFrameInfo=new north_frame_buffer1_frames();
    // private Configuration config;
    private StorageCageService storageCageService;
    public static Boolean FeedState = false;
    public static StringBuilder feedglassid;
    public static Boolean dbconnected = false;
    public static Boolean plc1 = true;
    public static Boolean plc2 = false;
    // public Plchome() throws IOException {
    // config = new Configuration("config.properties");
@@ -59,8 +65,12 @@
    // b.put()
    @Override
    public void run() {
        while (this != null) {
            Short zhi = 0;
            JSONObject jsonObject = new JSONObject();
            jsonObject.append("feedglassid", feedglassid);
            try {
                Thread.sleep(1000);
                // 注入mapper
@@ -72,6 +82,41 @@
                        .getBean(North_Glass_Buffer1Service.class);
                storageCageService = WebSocketServer.applicationContext.getBean(StorageCageService.class);
                dbserve = WebSocketServer.applicationContext.getBean(JdbcConnections.class);
                // boolean dbconnected = false;
                try {
                    dbserve.getConn();
                    dbconnected = true;
                } catch (Exception e) {
                    e.printStackTrace();
                    dbconnected = false;
                    log.info("dbconnected:" + dbconnected);
                }
                jsonObject.append("dbconnected", dbconnected);
                // // 获取当前扫码枪玻璃id
                // String CurrrentGlassId = "X22595911002GV";
                // if (CurrrentGlassId.toString() != "" && CurrrentGlassId.toString() != null) {
                // north_glass_buffer1 form6 =
                // dbserve.SelectGlassByGlassIdOrderIdFrameIdouts(CurrrentGlassId, "",
                // "");
                // if (form6.getbarcode() != null) {
                // jsonObject.append("form6", form6);
                // double width = 0;
                // double height = 0;
                // if (form6.getglassheightmm() < form6.getglasslengthmm()) {
                // height = form6.getglassheightmm();
                // width = form6.getglasslengthmm();
                // } else {
                // height = form6.getglasslengthmm();
                // width = form6.getglassheightmm();
                // }
                // if (height < 380 || width < 380 || height > 1810 || width > 2760) {
                // zhi = 600;
                // } else {
                // zhi = spianService.selectAlls(form6);
                // }
                // }
                // }
                // 笼子使用情况
                List<StorageCage> tableData = homeMapper.selectAll();
@@ -125,39 +170,72 @@
                // String E01id = new String( S7controlLK.getinstance().ReadByte("DB17.0",16));
                // String J01id = new String( S7controlLK.getinstance().ReadByte("DB17.22",14));
                try {
                    // 铝框线交互
                    // if (S7controlLK.getinstance().CheckConnected() == true) {
                    // E02玻璃id
                    // log.info("frame1"+S7controlLK.getinstance().CheckConnected());
                    String E02id="";
                    // try {
                    //     E02id= S7controlLK.getinstance().readStrings("DB17.40");
                    //     plc2=true;
                    // } catch (Exception e) {
                    //     // TODO: handle exception
                    //     plc2=false;
                    //     e.printStackTrace();
                    // }
                    // jsonObject.append("Plc2", plc2);
                    // // log.info("铝框线读取2"+S7controlLK.getinstance().CheckConnected());
                    // // log.info("E02id"+E02id);
                    // outSliceServive.FrameStateUpdate(E02id);
                    // if (CurrentFrame != null) {
                    //     S7controlLK.getinstance().writeStrings(CurrentFrame.getBarCode(), "DB17.0");
                    // }
                    // String J01id = S7controlLK.getinstance().readStrings("DB17.22");
                    // List<Short> liststate = S7controlLK.getinstance().ReadWord("DB17.20", 1);
                    // Short framerequest = liststate.get(0);
                    // // log.info("liststate:" + liststate);
                    // if (framerequest == 1) {
                    //     // 铝框id
                    //     String position;
                    //     try {
                    //         position = dbserve.SelectPositionByFrameBarcode(J01id);
                    //     } catch (SQLException e) {
                    //         // TODO Auto-generated catch block
                    //         position = "0";
                    //         e.printStackTrace();
                    //     }
                    //     Short send;
                    //     if (position.equals("1")) {
                    //         send = 1;
                    //     } else {
                    //         send = 2;
                    //     }
                    //     if (J01id != null) {
                    //         int barcodeState = spianMapper.SelectOverState(J01id);// 获取该铝框的状态
                    //         if (barcodeState == 0) {// 当该铝框所有的玻璃都是完成状态时删除在出片队列的数据
                    //             spianMapper.DeleteQueue(J01id);
                    //             // log.info("deleteoutslice:" + J01id);
                    //         }
                    //     }
                    //     S7controlLK.getinstance().WriteWord("DB17.38", (short) send);
                    // }
                    String E01id = S7controlLK.getinstance().readStrings("DB17.0");
                    // log.info("frameno:" + E01id);
                    List<Short> liststates = S7controlLK.getinstance().ReadWord("DB17.38", 1);
                    // log.info("frameflip:" + liststates);
                    // }else{
                    // log.info("Plc2"+S7controlLK.getinstance().CheckConnected());
                    // jsonObject.append("Plc2", false);
                    // }
                } catch (Exception e) {
                    e.printStackTrace();
                }
                if (S7control.getinstance().CheckConnected() == true) {
                    // 铝框线交互
                    if (S7controlLK.getinstance().CheckConnected() == true) {
                        if (CurrentFrame != null) {
                            S7controlLK.getinstance().writeStrings(CurrentFrame.getBarCode(), "DB17.0");
                        }
                        String E01id = S7controlLK.getinstance().readStrings("DB17.0");
                        String J01id = S7controlLK.getinstance().readStrings("DB17.22");
                        List<Short> liststates = S7controlLK.getinstance().ReadWord("DB17.38", 1);
                        List<Short> liststate = S7controlLK.getinstance().ReadWord("DB17.20", 1);
                        Short framerequest = liststate.get(0);
                        if (framerequest == 1) {
                            // 铝框id
                            String position;
                            try {
                                position = dbserve.SelectPositionByFrameBarcode(J01id);
                            } catch (SQLException e) {
                                // TODO Auto-generated catch block
                                position = "0";
                                e.printStackTrace();
                            }
                            Short send;
                            if (position.equals("0")) {
                                send = 0;
                            } else {
                                send = 1;
                            }
                            S7controlLK.getinstance().WriteWord("DB17.38", (short) send);
                        }
                    }
                    // 获取当前扫码方式
                    List<Boolean> Scanningmethods = S7control.getinstance().ReadBits("DB101.11.4", 1);
@@ -168,6 +246,28 @@
                    }
                    // 获取当前扫码枪玻璃id
                    String CurrrentGlassId = spianService.queGlassid("DB103.256", 14).toString();
                    if (CurrrentGlassId.toString() != "" && CurrrentGlassId.toString() != null) {
                        north_glass_buffer1 form6 = dbserve.SelectGlassByGlassIdOrderIdFrameIdouts(CurrrentGlassId, "",
                                "");
                        if (form6.getbarcode() != null) {
                            jsonObject.append("form6", form6);
                            double width = 0;
                            double height = 0;
                            if (form6.getglassheightmm() < form6.getglasslengthmm()) {
                                height = form6.getglassheightmm();
                                width = form6.getglasslengthmm();
                            } else {
                                height = form6.getglasslengthmm();
                                width = form6.getglassheightmm();
                            }
                            if (height < 380 || width < 380 || height > 1810 || width > 2760) {
                                zhi = 600;
                            } else {
                                zhi = spianService.selectAlls(form6);
                            }
                        }
                    }
                    jsonObject.append("CurrrentGlassId", CurrrentGlassId);
                    // 获取D01-D06,A01,A02,B01,B02状态
@@ -216,7 +316,7 @@
                    // }
                    // // 获取铝框idDB106.DBW64,添加到出片队列
                    // String frameno="X21763329601FB";
                    String frameno = spianService.queGlassid("DB103.270", 14).toString();
                    String frameno = spianService.queGlassid("DB103.270", 11).toString();
                    if (!frameno.equals(Plchome.FrameNo)) {
                        Plchome.FrameNo = frameno;
                        try {
@@ -233,15 +333,14 @@
                                north_Glass_Buffer1Service.AddOutSliceS(Plchome.FrameNo);
                            } else {
                                Plchome.AluminumFrame = north_glass_buffer1s;
                                Plchome.AluminumFrameInfo=dbserve.SelectFrameBarcode(Plchome.FrameNo);
                            }
                        } catch (SQLException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                    if (AluminumFrame != null) {
                        jsonObject.append("AluminumFrame", AluminumFrame);
                    }
                    // 复位倒计时
                    // 地址104.9.6
@@ -271,57 +370,57 @@
                    boolean D01ResponseState = D01respnse.contains((short) 1);
                    // jsonObject.append("D01RequestState", D01RequestState);
                    // 自动进片
                    isConfirm = true;
                    if (isConfirm == true && form3.getglassId() != null && form3.getglassId() != "") {
                        if ((form3.getglassheight() < 380 || form3.getglasswidth() < 390
                                || form3.getglassheight() > 1810
                                || form3.getglasswidth() > 2760)
                                || (form3.getglassheight() < 390 || form3.getglasswidth() < 380
                                        || form3.getglassheight() > 2760 || form3.getglasswidth() > 1810)) {
                            FeedState = true;
                            jsonObject.append("FeedState", FeedState);
                            FeedState = false;
                        double width = 0;
                        double height = 0;
                        if (form3.getglassheight() < form3.getglasswidth()) {
                            height = form3.getglassheight();
                            width = form3.getglasswidth();
                        } else {
                            height = form3.getglasswidth();
                            width = form3.getglassheight();
                        }
                        if (height < 380 || width < 380 || height > 1810 || width > 2760) {
                            zhi = 600;
                        } else {
                            if (D01RequestState == true && D01ResponseState != true) {
                                storageCageService.InsertQueueGlassId((short) 1, form3);
                                zhi = storageCageService.InsertQueueGlassIds((short) 1, form3);
                            }
                        }
                    }
                    plc1=true;
                } else {
                    plc1=false;
                    log.info("Plc1" + S7controlLK.getinstance().CheckConnected());
                }
            } catch (InterruptedException e) {
                if (AluminumFrame != null) {
                    jsonObject.append("AluminumFrame", AluminumFrame);
                }
                if (AluminumFrameInfo.getbarcode() != null) {
                    jsonObject.append("AluminumFrameInfo", AluminumFrameInfo);
                }
                jsonObject.append("zhi", zhi);
                jsonObject.append("Plc1", plc1);
                // jsonObject.append("params", new short[] { 30, 40, });
                ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Home");
                if (sendwServer != null) {
                    for (WebSocketServer webserver : sendwServer) {
                        if (webserver != null && webserver.session.isOpen()) {
                            webserver.sendMessage(jsonObject.toString());
                            List<String> messages = webserver.getMessages();
                            if (!messages.isEmpty()) {
                                // // 将最后一个消息转换为整数类型的列表
                                webserver.clearMessages();
                            }
                        } else {
                            log.info("Home is closed");
                        }
                    }
                }
            } catch (InterruptedException | SQLException e) {
                e.printStackTrace();
            }
            boolean dbconnected = false;
            try {
                dbserve.getConn();
                dbconnected = true;
            } catch (Exception e) {
                // TODO: handle exception
                dbconnected = false;
            }
            jsonObject.append("dbconnected", dbconnected);
            // jsonObject.append("params", new short[] { 30, 40, });
            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Home");
            if (sendwServer != null) {
                for (WebSocketServer webserver : sendwServer) {
                    webserver.sendMessage(jsonObject.toString());
                    if (webserver != null) {
                        List<String> messages = webserver.getMessages();
                        if (!messages.isEmpty()) {
                            // // 将最后一个消息转换为整数类型的列表
                            webserver.clearMessages();
                        }
                    }
                }
            }
        }
    }
}