后端代码改为大部分使用消息处理对象写入

wuyouming666

2023-12-14 54c7981d6f05ce0e3b59df3c4e23cd06a81a059b

后端代码改为大部分使用消息处理对象写入

 CanadaMes-ui/.env

@@ -1 +1 @@
VUE_APP_BASE_API=/api
VUE_APP_BASE_API=/api


 CanadaMes-ui/src/configuration/AutomaticParameterSetting.json

@@ -8,7 +8,9 @@
      "address": "DB100.0",
      "count": 3,
      "unit": "°",
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    },
    {
      "name": "A01行走低速角度",
@@ -17,7 +19,9 @@
      "address": "DB100.0",
      "unit": "°",
      "type": "0",
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    },
    {
      "name": "A01输送接片角度",
@@ -26,7 +30,9 @@
      "unit": "°",
      "address": "DB100.0",
      "type": "0",
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    },
    {
      "name": "A01笼子角度",
@@ -35,7 +41,9 @@
      "unit": "°",
      "address": "DB100.0",
      "type": "0",
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    }
  ],
  [
@@ -47,7 +55,9 @@
      "unit": "°",
      "address": "DB100.0",
      "count": 3,
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    },
    {
      "name": "A02行走低速角度",
@@ -56,7 +66,9 @@
      "unit": "°",
      "address": "DB100.0",
      "type": "0",
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    },
    {
      "name": "A02输送接片角度",
@@ -65,7 +77,9 @@
      "unit": "°",
      "address": "DB100.0",
      "type": "0",
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    },
    {
      "name": "A02笼子角度",
@@ -74,7 +88,9 @@
      "unit": "°",
      "address": "DB100.0",
      "type": "0",
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    }
  ],
  [
@@ -86,7 +102,9 @@
      "unit": "m/min",
      "address": "DB100.0",
      "count": 3,
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    }
  ],
  [
@@ -97,7 +115,9 @@
      "unit": "m/min",
      "address": "DB100.0",
      "type": "0",
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    }
  ],
  [
@@ -108,7 +128,9 @@
      "unit": "m/min",
      "address": "DB100.0",
      "type": "0",
      "value": ""
      "value": "",
      "min": 0,
      "max": 100
    }
  ],
  [
@@ -125,7 +147,9 @@
    "type": "0",
    "unit": "m/min",
    "count":3,
    "value":0
    "value":0,
    "min": 0,
    "max": 1000
  },
  {
    "name": "高速线速度",
@@ -133,7 +157,9 @@
    "sending": 0,
    "type": "0",
    "unit": "m/min",
    "value":0
    "value":0,
    "min": 0,
    "max": 100
  },
  {
    "name": "低速线速度",
@@ -141,7 +167,9 @@
    "sending": 0,
    "type": "0",
    "unit": "m/min",
    "value":0
    "value":0,
    "min": 0,
    "max": 100
  },
  {
    "name": "手动速度",
@@ -149,7 +177,9 @@
    "sending": 0,
    "type": "0",
    "unit": "m/min",
    "value":0
    "value":0,
    "min": 0,
    "max": 100
  }
  
 
@@ -169,7 +199,9 @@
  "type": "0",
  "unit": "m/min",
  "count":3,
  "value":0
  "value":0,
  "min": 0,
  "max": 100
},
{
  "name": "高速线速度",
@@ -177,7 +209,9 @@
  "sending": 0,
  "unit": "m/min",
  "type": "0",
  "value":0
  "value":0,
  "min": 0,
  "max": 100
},
{
  "name": "低速线速度",
@@ -185,7 +219,9 @@
  "sending": 0,
  "unit": "m/min",
  "type": "0",
  "value":0
  "value":0,
  "min": 0,
  "max": 100
},
{
  "name": "手动速度",
@@ -193,7 +229,9 @@
  "sending": 0,
  "unit": "m/min",
  "type": "0",
  "value":0
  "value":0,
  "min": 0,
  "max": 100
}


@@ -211,7 +249,9 @@
"type": "0",
"unit": "m/min",
"count":3,
"value":0
"value":0,
"min": 0,
"max": 100
},
{
"name": "高速线速度",
@@ -219,7 +259,9 @@
"sending": 0,
"type": "0",
"unit": "m/min",
"value":0
"value":0,
"min": 0,
"max": 100
},
{
"name": "低速线速度",
@@ -227,7 +269,9 @@
"sending": 0,
"type": "0",
"unit": "m/min",
"value":0
"value":0,
"min": 0,
"max": 100
},
{
"name": "手动速度",
@@ -235,7 +279,9 @@
"sending": 0,
"type": "0",
"unit": "m/min",
"value":0
"value":0,
"min": 0,
"max": 100
}


@@ -250,7 +296,9 @@
"unit": "mm/S",

"count":3,
"value":0
"value":0,
"min": 0,
"max": 100
}


@@ -264,7 +312,9 @@
"sending": 0,
"unit": "mm/S",
"type": "0",
"value":0
"value":0,
"min": 0,
"max": 100
}



 CanadaMes-ui/src/configuration/Positioning1.json

@@ -5,7 +5,9 @@
    "sending": 0,
    "type": "0",
    "unit": "mm",
    "value":"0"
    "value":"0",
    "min": 0,
     "max": 100
    
  }],
    [{

 CanadaMes-ui/src/views/Electrical/AutomaticParameterSetting.vue

@@ -60,9 +60,16 @@
          <div v-for="(item, itemIndex) in dataGroup" :key="itemIndex" class="item-container">
            <div class="item-row">
              <span class="name" style="width:250px;">{{ item.name }}</span>
              <el-input v-if="item.type === '0'" v-model="item.value" class="input-box"
                @keyup.enter.native="submitDataToBackend"></el-input>
                <span v-if="item.unit" :name="item.unit" >{{ item.unit }}</span>
              <el-input v-if="item.type === '0'"
            v-model="item.value"
            class="input-box"
            :oninput="`value=value.replace(/^0|[^0-9]/g,'');if(value<`+item.min+`){value=`+item.value+`}else if(value>`+item.max+`){value=`+item.value+`}`"
            @keyup.enter.native="submitDataToBackend">
  </el-input>

                <span v-if="item.unit" :name="item.unit"  >{{ item.unit }}</span>



            </div>
          </div>
@@ -108,6 +115,11 @@
    updateButtonValue (dataGroup, itemIndex) {
      this.$set(dataGroup[itemIndex].button, 'value', 1); // 点击按钮后将值改为1
    },
    checkInputValue() {
      if (this.item.value < this.item.min || this.item.value > this.item.max) {
        this.item.value = ''; // 清空输入框的值
      }
    },
    submitDataToBackend () {
      const inputData = this.jsonData.map(dataGroup => {
        return dataGroup.map(item => {

 CanadaMes-ui/src/views/Electrical/ManualJog.vue

@@ -50,12 +50,12 @@
    </el-breadcrumb>

    <el-row :gutter="40" >
      <el-col :span="16" v-for="(dataGroup, groupIndex) in jsonData" :key="groupIndex">
      <el-col :span="26" v-for="(dataGroup, groupIndex) in jsonData" :key="groupIndex">
        <el-card class="json-block" style="width:100%;">

          <div class="button-row" style="display: flex; justify-content: flex-start;flex-wrap:wrap;">
            <div v-for="(item, itemIndex) in dataGroup" :key="itemIndex" style="margin: 10px;">
              <el-button v-if="item.button" :name="item.button.name"
              <el-button v-if="item.button" :name="item.button.name" style='width:200px;'
 :class="{ 'dow': false, 'op': item.button.value === 1 }" class="action-button"
 @click="updateButtonValue(dataGroup, itemIndex); submitDataToBackend();">{{
 item.button.name

 CanadaMes-ui/src/views/Electrical/ManualonePosition.vue

@@ -378,11 +378,11 @@


      }



      if (currentButtonName === '回零' || currentButtonName === 'Zero') {

      if (currentButtonName === '回零' || currentButtonName === 'Home') {



        const data2 = [];

        const resetButtonValues = this.jsonData.map(item => {

          const buttonItem = item.find(subItem => subItem.button && ['回零', 'Zero'].includes(subItem.button.name));

          const buttonItem = item.find(subItem => subItem.button && ['回零', 'Home'].includes(subItem.button.name));



          return buttonItem ? buttonItem.button.value : null;

        }).filter(value => value !== null);


 CanadaMes-ui/src/views/Electrical/ManualonePosition2.vue

@@ -269,11 +269,11 @@


      }



      if (currentButtonName === '回零' || currentButtonName === 'Zero') {

      if (currentButtonName === '回零' || currentButtonName === 'Home') {



        const data2 = [];

        const resetButtonValues = this.jsonData.map(item => {

          const buttonItem = item.find(subItem => subItem.button && ['回零', 'Zero'].includes(subItem.button.name));

          const buttonItem = item.find(subItem => subItem.button && ['回零', 'Home'].includes(subItem.button.name));



          return buttonItem ? buttonItem.button.value : null;

        }).filter(value => value !== null);


 CanadaMes-ui/src/views/Electrical/Parameter2.vue

@@ -358,7 +358,7 @@

          const parms = obj.params;

          console.log(obj);
         // console.log(obj);

          // const handleMouseMove = throttle(function(event) {
          // const inputBox = document.querySelectorAll('.id');

 CanadaMes-ui/src/views/Electrical/ServoManualone.vue

@@ -213,84 +213,36 @@

},
submitDataToBackend(currentButtonName) {
  const data = [];
  let jsonObject;

//A01半自动启动提交
  if (currentButtonName === 'A01半自动启动' ||currentButtonName === 'A01 Semi-Auto Start') {
    const data = [];


  const values = [this.jsonData[0][10].button.value]

  data.push(values);
 

data.unshift([], [],[],[], [],[],[], []);


const jsonObject = { data };

// 提交数据到后端
const jsonString = JSON.stringify(jsonObject);
console.log('所有Type为0的value:', jsonString);
socket?.send(jsonString);

  }
  //A02半自动启动 提交

  if (currentButtonName === 'A02半自动启动' ||currentButtonName === 'A02 Semi-Auto Start') {
    const data2 = [];

    const values2 = [this.jsonData[1][8].button.value]

  data2.push(values2);

  data2.unshift([],[], [],[],[], [],[],[], []);





const jsonObject = { data:data2 };

// 提交数据到后端
const jsonString = JSON.stringify(jsonObject);
console.log('所有Type为0的value:', jsonString);
socket?.send(jsonString);

  if (currentButtonName === 'A01半自动启动' || currentButtonName === 'A01 Semi-Auto Start') {
    const values = [this.jsonData[0][10].button.value];
    data.push(values);
    data.unshift([], [],[],[], [],[],[], []);
    jsonObject = { data };
  }

  //复位提交
  if (currentButtonName === 'A02半自动启动' || currentButtonName === 'A02 Semi-Auto Start') {
    const values2 = [this.jsonData[1][8].button.value];
    data.push(values2);
    data.unshift([],[], [],[],[], [],[],[], []);
    jsonObject = { data };
  }

  if (currentButtonName === '复位' || currentButtonName === 'Reset') {
  const data2 = [];
  const resetButtonValues = this.jsonData.map(item => {
    const buttonItem = item.find(subItem => subItem.button && ['复位', 'Reset'].includes(subItem.button.name));
    const resetButtonValues = this.jsonData
      .map(item => item.find(subItem => subItem.button && ['复位', 'Reset'].includes(subItem.button.name)))
      .filter(value => value !== null)
      .map(item => item.button.value);

    
    return buttonItem ? buttonItem.button.value : null;
  }).filter(value => value !== null);
    data.push(resetButtonValues.flat());
    data.unshift([], []);
    data.push([], [], [], [], []);
    jsonObject = { data };
  }

  // 将得到的值添加到 data 数组中
  data2.push(resetButtonValues.flat());

  // 在 data2 数组前面添加两个空数组
  data2.unshift([], []);
  data2.push([], [], [], [], []);

  // 创建 jsonObject2 对象，并添加 data2 属性
  const jsonObject2 = { data: data2 };

  // 提交数据到后端
  const jsonString2 = JSON.stringify(jsonObject2);
  console.log('所有Type为0的value:', jsonString2);
  socket?.send(jsonString2);
  // setTimeout(()=>
  //   window.location.reload(),2000
  // )
 
}
////回零提交
if (currentButtonName === '回零' || currentButtonName === 'Home') {
  if (currentButtonName === '回零' || currentButtonName === 'Home') {
  const data3 = [];
  const resetButtonValues3 = this.jsonData.map(item => {
    const buttonItem3 = item.find(subItem => subItem.button && ['回零', 'Home'].includes(subItem.button.name));
@@ -306,22 +258,10 @@
  data3.push([], [], [], []);

  // 创建 jsonObject3 对象，并添加 data3 属性
  const jsonObject3 = { data: data3 };
   jsonObject = { data: data3 };

  // 提交数据到后端
  const jsonString3 = JSON.stringify(jsonObject3);
  console.log('回零:', jsonString3);
  socket?.send(jsonString3);
  // setTimeout(()=>
  //   window.location.reload(),2000
  // )

}




//A01半自动提交

  if (currentButtonName === 'A01半自动' || currentButtonName === 'A01 Semi-Auto' ) {
    const elements = document.getElementsByClassName('special-class');
    const data = [];
@@ -379,12 +319,9 @@



const jsonObject = { data };
 jsonObject = { data };

// 提交数据到后端
const jsonString = JSON.stringify(jsonObject);
console.log('所有Type为0的value:', jsonString);
socket?.send(jsonString);

  }

@@ -449,20 +386,18 @@
    data.unshift([],[],[],[],[],[],[]);


const jsonObject = { data };
 jsonObject = { data };

// 提交数据到后端
const jsonString = JSON.stringify(jsonObject);
console.log('所有Type为0的value:', jsonString);
socket?.send(jsonString);

  }

 
}

  
const jsonString = JSON.stringify(jsonObject);
  console.log('所有Type为0的value:', jsonString);
  socket?.send(jsonString);

},


    initWebSocket () {
 
@@ -493,7 +428,7 @@
  }

  let obj = JSON.parse(msg.data);
   console.log(obj)
  // console.log(obj)
const weihuiling=obj.weihuiling;
  const jsonData2 = this.jsonData;


 CanadaMes-ui/src/views/login/index.vue

@@ -83,7 +83,7 @@
          // 设置token
          setToken(res.data.Authorization);
          this.$router.push('/layout')
          this.$message.success('登录成功');
          this.$message.success(this.$t('loginSuccess'));
        });
      })
    },

 springboot-vue3/src/main/java/com/example/springboot/component/MessageHandler.java

@@ -66,7 +66,7 @@
        }

    }



    //写入Word

    //不连续地址 写入Word

    public void WriteWordToPLC(JSONArray messageArray, List<String> addresses, int index) {

        try {

            if (messageArray.getJSONArray(index).size() > 0) {

@@ -95,6 +95,26 @@
        }

    }







    public void WriteWordsToPLC(JSONArray jsonArray,  String address,int index) {

        if (jsonArray.getJSONArray(index).size() > 0) {

            Object value = jsonArray.getJSONArray(index).get(0);

            if (value != null && !value.toString().equals("null")) {

                try {

                    String cleanedValue = value.toString().replaceAll("[^0-9-]", "");

                    short sValue = Short.parseShort(cleanedValue.trim());

                    S7control.getinstance().WriteWord(address, Arrays.asList(sValue));

                    System.out.println("messageValue：" + Arrays.asList(sValue) + " written to PLC at address " + address);

                } catch (NumberFormatException e) {

                    // 如果无法解析为 short 类型，则忽略该部分

                    System.err.println("Could not parse value: " + value);

                }

            }

        }

    }





    //写入String

    public void writeStringToPLC(JSONArray messageArray, String addresses, int index) {

        try {


 springboot-vue3/src/main/java/com/example/springboot/component/PLCAutomaticParameterSetting.java

@@ -10,53 +10,9 @@
import java.util.List;

public class PLCAutomaticParameterSetting extends Thread {
  String name = "";
  Integer count = 0;

  public static String readFileToString(String filePath) throws IOException {
    File file = new File(filePath);
    return FileUtils.readFileToString(file, "UTF-8");
  }

  public void readValue() {
    String str = "";
    BufferedReader bufferedReader = null;
    FileInputStream fileInputStream;
    try {
      // 从文件中读取字节数据存入 fileInputStream
      fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json");
      // 读取 fileInputStream 中字节并将其解码为字符
      InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "utf-8");
      // 提高读取效率，在 BufferedReader 内包装 InputStreamReader
      bufferedReader = new BufferedReader(inputStreamReader);
      String line = null;
      // 将 bufferedReader 内容一行一行赋值给str
      while ((line = bufferedReader.readLine()) != null) {
        str += line;
      }

      // 将str字符串格式转为json
      JSONObject jsonObject = new JSONObject(str);

      // 获取json中的值
      JSONArray address = jsonObject.getJSONArray("address");
      for (int i = 0; i < address.size(); i++) {
        JSONObject ress = (JSONObject) address.get(i);

        this.name = ress.getStr("name");
        this.count = ress.getInt("count");

      }

    } catch (FileNotFoundException e) {
      e.printStackTrace();
    } catch (UnsupportedEncodingException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }

  // 创建一个自定义的 S7 控制器消息处理器对象
  MessageHandler customS7Control = new MessageHandler();
  @Override
  public void run() {
    while (this != null) {
@@ -66,9 +22,7 @@
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      // this.readValue();
      // String PlcAddress = this.name;
      // Integer Plccount = this.count;


      // System.out.println(stt);
      List<Short> arraylist = S7control.getinstance().ReadWord("DB100.120", 8);
@@ -161,55 +115,15 @@
              }
              System.out.println(messageArray);
              // 写入第一个地址
              if (messageArray.getJSONArray(2).size() > 0) {
                Object value = messageArray.getJSONArray(2).get(0);
                if (value != null && !value.toString().equals("null")) {
                  try {
                    String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                    short sValue = Short.parseShort(cleanedValue.trim());
                    S7control.getinstance().WriteWord(addressList2, Arrays.asList(sValue));
                    System.out
                            .println("messageValue：" + Arrays.asList(sValue) + " written to PLC at address " + addressList2);
                  } catch (NumberFormatException e) {
                    // 如果无法解析为 short 类型，则忽略该部分
                    System.err.println("Could not parse value: " + value);
                  }
                }
              }
              customS7Control.WriteWordsToPLC(messageArray, addressList2,2);

              // 写入第二个地址
              if (messageArray.getJSONArray(3).size() > 0) {
                Object value = messageArray.getJSONArray(3).get(0);
                if (value != null && !value.toString().equals("null")) {
                  try {
                    String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                    short sValue = Short.parseShort(cleanedValue.trim());
                    S7control.getinstance().WriteWord(addressList3, Arrays.asList(sValue));
                    System.out
                            .println("messageValue：" + Arrays.asList(sValue) + " written to PLC at address " + addressList3);
                  } catch (NumberFormatException e) {
                    // 如果无法解析为 short 类型，则忽略该部分
                    System.err.println("Could not parse value: " + value);
                  }
                }
              }
              customS7Control.WriteWordsToPLC(messageArray, addressList3,3);


              // 写入第三个地址
              if (messageArray.getJSONArray(4).size() > 0) {
                Object value = messageArray.getJSONArray(4).get(0);
                if (value != null && !value.toString().equals("null")) {
                  try {
                    String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                    short sValue = Short.parseShort(cleanedValue.trim());
                    S7control.getinstance().WriteWord(addressList4, Arrays.asList(sValue));
                    System.out
                            .println("messageValue：" + Arrays.asList(sValue) + " written to PLC at address " + addressList4);
                  } catch (NumberFormatException e) {
                    // 如果无法解析为 short 类型，则忽略该部分
                    System.err.println("Could not parse value: " + value);
                  }
                }
              }
              customS7Control.WriteWordsToPLC(messageArray, addressList4,4);


              // 写入第四个地址
              if (!mergedList.isEmpty()) {
@@ -259,38 +173,11 @@
                }

                // 写入第伍个地址
                if (messageArray.getJSONArray(8).size() > 0) {
                  Object value = messageArray.getJSONArray(8).get(0);
                  if (value != null && !value.toString().equals("null")) {
                    try {
                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                      short sValue = Short.parseShort(cleanedValue.trim());
                      S7control.getinstance().WriteWord(addressList22, Arrays.asList(sValue));
                      System.out
                              .println("messageValue：" + Arrays.asList(sValue) + " written to PLC at address " + addressList2);
                    } catch (NumberFormatException e) {
                      // 如果无法解析为 short 类型，则忽略该部分
                      System.err.println("Could not parse value: " + value);
                    }
                  }
                }
                customS7Control.WriteWordsToPLC(messageArray, addressList22,8);


                // 写入第六个地址
                if (messageArray.getJSONArray(9).size() > 0) {
                  Object value = messageArray.getJSONArray(9).get(0);
                  if (value != null && !value.toString().equals("null")) {
                    try {
                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                      short sValue = Short.parseShort(cleanedValue.trim());
                      S7control.getinstance().WriteWord(addressList33, Arrays.asList(sValue));
                      System.out
                              .println("messageValue：" + Arrays.asList(sValue) + " written to PLC at address " + addressList3);
                    } catch (NumberFormatException e) {
                      // 如果无法解析为 short 类型，则忽略该部分
                      System.err.println("Could not parse value: " + value);
                    }
                  }
                }
                customS7Control.WriteWordsToPLC(messageArray, addressList33,9);

                // 写入第七个地址
                if (!mergedList2.isEmpty()) {

 springboot-vue3/src/main/java/com/example/springboot/component/PLCManualJog.java

@@ -12,63 +12,58 @@
public class PLCManualJog extends Thread {





  // 用于存储应用程序的配置信息

  private Configuration config;

    // 用于存储应用程序的配置信息

    private Configuration config;



  // 创建一个自定义的 S7 控制器消息处理器对象

  MessageHandler customS7Control = new MessageHandler();

    // 创建一个自定义的 S7 控制器消息处理器对象

    MessageHandler customS7Control = new MessageHandler();





  public PLCManualJog() throws IOException {

    config = new Configuration("config.properties");

  }

    public PLCManualJog() throws IOException {

        config = new Configuration("config.properties");

    }





    @Override

    public void run() {

        while (this != null) {

            try {

                Thread.sleep(500);



            } catch (InterruptedException e) {

                e.printStackTrace();

            }

            // this.readValue();

            // String PlcAddress = this.name;

            // Integer Plccount = this.count;



            // System.out.println(stt);





  @Override

  public void run() {

    while (this != null) {

      try {

        Thread.sleep(500);



      } catch (InterruptedException e) {

        e.printStackTrace();

      }

      // this.readValue();

      // String PlcAddress = this.name;

      // Integer Plccount = this.count;



      // System.out.println(stt);

            List<String> addressList21 = Arrays.asList(config.getProperty("PLCManualJog.button").split(","));





      List<String> addressList21 = Arrays.asList(config.getProperty("PLCManualJog.button").split(","));

            List<Boolean> arraylist = S7control.getinstance().readBits(addressList21);



            // Boolean[] values1 = { false, true, true, true, false, false, true, false,

            // false, true, true, true, false, false,

            // true, false };

            // List<Boolean> arraylist = new ArrayList<>(Arrays.asList(values1));

            // Boolean[] values2 = { false, true, true, true, false, false, true, false };

            // List<Boolean> arraylist2 = new ArrayList<>(Arrays.asList(values2));

            // Boolean[] values3 = { false, false };

            // List<Boolean> arraylist3 = new ArrayList<>(Arrays.asList(values3));





            JSONObject jsonObject = new JSONObject();



            short[] params = new short[arraylist.size()];

            for (int i = 0; i < arraylist.size(); i++) {

                boolean value = arraylist.get(i);

                params[i] = value ? (short) 1 : (short) 0;

            }



      List<Boolean> arraylist = S7control.getinstance().readBits(addressList21);



      // Boolean[] values1 = { false, true, true, true, false, false, true, false,

      // false, true, true, true, false, false,

      // true, false };

      // List<Boolean> arraylist = new ArrayList<>(Arrays.asList(values1));

      // Boolean[] values2 = { false, true, true, true, false, false, true, false };

      // List<Boolean> arraylist2 = new ArrayList<>(Arrays.asList(values2));

      // Boolean[] values3 = { false, false };

      // List<Boolean> arraylist3 = new ArrayList<>(Arrays.asList(values3));







      JSONObject jsonObject = new JSONObject();



      short[] params = new short[arraylist.size()];

      for (int i = 0; i < arraylist.size(); i++) {

        boolean value = arraylist.get(i);

        params[i] = value ? (short) 1 : (short) 0;

      }



      jsonObject.append("params", params);

            jsonObject.append("params", params);



//      System.out.println("messageValue：" + arraylist +"messageValue2：" + arraylist2 );

//      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ManualJog");

@@ -76,62 +71,61 @@
//        sendwServer.sendMessage(jsonObject.toString());

//      }



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

      if (sendwServer != null) {

        for (WebSocketServer webserver : sendwServer) {

          webserver.sendMessage(jsonObject.toString());

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

            if (sendwServer != null) {

                for (WebSocketServer webserver : sendwServer) {

                    webserver.sendMessage(jsonObject.toString());



//      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("ManualJog");



          if (webserver != null) {

                    if (webserver != null) {





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

                        if (!messages.isEmpty()) {

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

                            String lastMessage = messages.get(messages.size() - 1);

                            // System.out.println("messages：" + messages);

                            String[] parts = lastMessage.split(",");

                            List<Integer> messageValues = new ArrayList<>();

                            for (String part : parts) {

                                try {

                                    // 使用正则表达式清除非数字字符

                                    String cleanedPart = part.replaceAll("[^0-9-]", "");

                                    Integer value = Integer.parseInt(cleanedPart.trim());

                                    messageValues.add(value);

                                } catch (NumberFormatException e) {

                                    // 如果无法解析为整数类型，则忽略该部分

                                    // e.printStackTrace();

                                }



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

            if (!messages.isEmpty()) {

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

              String lastMessage = messages.get(messages.size() - 1);

              // System.out.println("messages：" + messages);

              String[] parts = lastMessage.split(",");

              List<Integer> messageValues = new ArrayList<>();

              for (String part : parts) {

                try {

                  // 使用正则表达式清除非数字字符

                  String cleanedPart = part.replaceAll("[^0-9-]", "");

                  Integer value = Integer.parseInt(cleanedPart.trim());

                  messageValues.add(value);

                } catch (NumberFormatException e) {

                  // 如果无法解析为整数类型，则忽略该部分

                  // e.printStackTrace();

                            }

                            // 将消息值转换为布尔列表

                            List<Boolean> messageBooleans = new ArrayList<>();

                            for (Integer value : messageValues) {

                                messageBooleans.add(value == 1 ? true : false);

                            }

                            // System.out.println(messageBooleans);

                            List<Boolean> bolList = new ArrayList<>();





                            for (int i = 0; i < 26 && i < messageBooleans.size(); i++) {

                                bolList.add(messageBooleans.get(i));

                            }





                            if (!bolList.isEmpty()) {

                                S7control.getinstance().WriteBit(addressList21, bolList);

                                System.out.println("messageValue：" + bolList + " written to PLC at address " + addressList21);

                            }



                            webserver.clearMessages();

                        }

                    }

                }



              }

              // 将消息值转换为布尔列表

              List<Boolean> messageBooleans = new ArrayList<>();

              for (Integer value : messageValues) {

                messageBooleans.add(value == 1 ? true : false);

              }

              // System.out.println(messageBooleans);

              List<Boolean> bolList = new ArrayList<>();





              for (int i = 0; i < 26 && i < messageBooleans.size(); i++) {

                bolList.add(messageBooleans.get(i));

              }





              if (!bolList.isEmpty()) {

                S7control.getinstance().WriteBit(addressList21, bolList);

                System.out.println("messageValue：" + bolList + " written to PLC at address " + addressList21);

              }



              webserver.clearMessages();

            }

          }



        }



      }



    }

  }

}


 springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition.java

@@ -10,417 +10,267 @@
import java.util.List;

public class PlcManualonePosition extends Thread {
  private Configuration config;
    private Configuration config;

  public PlcManualonePosition() throws IOException {
    config = new Configuration("config.properties");
  }



  // 创建一个自定义的 S7 控制器消息处理器对象
  MessageHandler customS7Control = new MessageHandler();




  public static class PLCBooleanConverter {

    public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) {
      // 计算所有列表中元素的总数
      int totalSize = 0;
      for (List<Boolean> list : lists) {
        totalSize += list.size();
      }

      // 创建一个足够大的数组来存放所有的二进制值
      short[] binaryShortArray = new short[totalSize];

      // 当前数组填充位置指针
      int currentIndex = 0;

      // 遍历所有的列表
      for (List<Boolean> list : lists) {
        // 将每个布尔值转换为 0 或 1 并填入数组
        for (Boolean value : list) {
          binaryShortArray[currentIndex++] = (short) (value ? 1 : 0);
        }
      }

      return binaryShortArray;
    public PlcManualonePosition() throws IOException {
        config = new Configuration("config.properties");
    }
  }


    // 创建一个自定义的 S7 控制器消息处理器对象
    MessageHandler customS7Control = new MessageHandler();


  @Override
  public void run() {
    while (this != null) {
      try {
        Thread.sleep(500);
    public static class PLCBooleanConverter {

      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      // this.readValue();
      // String PlcAddress = this.name;
      // Integer Plccount = this.count;
        public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) {
            // 计算所有列表中元素的总数
            int totalSize = 0;
            for (List<Boolean> list : lists) {
                totalSize += list.size();
            }

      List<String> addresses = new ArrayList<>();
      addresses.add("DB100.108");
      addresses.add("DB100.20");
      addresses.add("DB103.32");
      List<Short> arraylist = S7control.getinstance().readWords(addresses);
      // System.out.println(arraylist);
            // 创建一个足够大的数组来存放所有的二进制值
            short[] binaryShortArray = new short[totalSize];

      List<String> addresses2 = new ArrayList<>();
      addresses2.add("DB100.110");
      addresses2.add("DB100.176");
      addresses2.add("DB103.34");
      List<Short> arraylist2 = S7control.getinstance().readWords(addresses2);
            // 当前数组填充位置指针
            int currentIndex = 0;

      List<String> addresses3 = new ArrayList<>();
      addresses3.add("DB100.112");
      addresses3.add("DB100.24");
      addresses3.add("DB103.36");
      List<Short> arraylist3 = S7control.getinstance().readWords(addresses3);
            // 遍历所有的列表
            for (List<Boolean> list : lists) {
                // 将每个布尔值转换为 0 或 1 并填入数组
                for (Boolean value : list) {
                    binaryShortArray[currentIndex++] = (short) (value ? 1 : 0);
                }
            }

      List<String> addresses4 = new ArrayList<>();
      addresses4.add("DB100.114");
      addresses4.add("DB100.178");
      addresses4.add("DB103.40");
      List<Short> arraylist4 = S7control.getinstance().readWords(addresses4);
            return binaryShortArray;
        }
    }

      List<Short> arraylist5 = S7control.getinstance().ReadWord("DB106.0", 1);
      List<Short> arraylist6 = S7control.getinstance().ReadWord("DB106.12", 1);
      List<Short> arraylist7 = S7control.getinstance().ReadWord("DB106.40", 1);
      List<Short> arraylist8 = S7control.getinstance().ReadWord("DB106.50", 1);
      List<String> addresses9 = new ArrayList<>();
      addresses9.add("DB104.1.2");
      addresses9.add("DB104.1.3");
      addresses9.add("DB104.1.6");
      addresses9.add("DB104.1.7");
      List<Boolean> arraylist9 = S7control.getinstance().readBits(addresses9);

      List<String> addresses10 = new ArrayList<>();
      addresses10.add("DB104.9.4");
      addresses10.add("DB104.9.5");
      addresses10.add("DB104.9.4");
      addresses10.add("DB104.9.5");
      List<Boolean> arraylist10 = S7control.getinstance().readBits(addresses10);
    @Override
    public void run() {
        while (this != null) {
            try {
                Thread.sleep(500);

      //A01启动地址
      List<String> A01start = Arrays.asList(config.getProperty("mlp.A01start"));
      //A02启动地址
      List<String> A02start = Arrays.asList(config.getProperty("mlp.A02start"));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            // this.readValue();
            // String PlcAddress = this.name;
            // Integer Plccount = this.count;

      List<String> B01start = Arrays.asList(config.getProperty("mlp.B01start"));
            List<String> addresses = new ArrayList<>();
            addresses.add("DB100.108");
            addresses.add("DB100.20");
            addresses.add("DB103.32");
            List<Short> arraylist = S7control.getinstance().readWords(addresses);
            // System.out.println(arraylist);

      List<String> B02start = Arrays.asList(config.getProperty("mlp.B02start"));
            List<String> addresses2 = new ArrayList<>();
            addresses2.add("DB100.110");
            addresses2.add("DB100.176");
            addresses2.add("DB103.34");
            List<Short> arraylist2 = S7control.getinstance().readWords(addresses2);

      List<Boolean> A01readstart = S7control.getinstance().readBits(A01start);
      List<Boolean> A02readstart = S7control.getinstance().readBits(A02start);
      List<Boolean> B01readstart = S7control.getinstance().readBits(B01start);
      List<Boolean> B02readstart = S7control.getinstance().readBits(B02start);
            List<String> addresses3 = new ArrayList<>();
            addresses3.add("DB100.112");
            addresses3.add("DB100.24");
            addresses3.add("DB103.36");
            List<Short> arraylist3 = S7control.getinstance().readWords(addresses3);

      short[] combinedBinaryShortArray = PLCBooleanConverter.convertListsToBinaryShortArray(
              A01readstart,  A02readstart,B01readstart, B02readstart
      );
            List<String> addresses4 = new ArrayList<>();
            addresses4.add("DB100.114");
            addresses4.add("DB100.178");
            addresses4.add("DB103.40");
            List<Short> arraylist4 = S7control.getinstance().readWords(addresses4);

      // Short[] values1 = { 1, 2, 3 };
      // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));
      // Short[] values2 = { 1, 2, 3 };
      // List<Short> arraylist2 = new ArrayList<>(Arrays.asList(values2));
      // Short[] values3 = { 1, 2, 3 };
      // List<Short> arraylist3 = new ArrayList<>(Arrays.asList(values3));
      // Short[] values4 = { 1, 2, 3 };
      // List<Short> arraylist4 = new ArrayList<>(Arrays.asList(values4));
      // Short[] values5 = { 5 };
      // List<Short> arraylist5 = new ArrayList<>(Arrays.asList(values5));
      // Short[] values6 = { 6 };
      // List<Short> arraylist6 = new ArrayList<>(Arrays.asList(values6));
      // Short[] values7 = { 7 };
      // List<Short> arraylist7 = new ArrayList<>(Arrays.asList(values7));
      // Short[] values8 = { 8 };
      // List<Short> arraylist8 = new ArrayList<>(Arrays.asList(values8));
      // Boolean[] values9 = { false, false, true, true };
      // List<Boolean> arraylist9 = new ArrayList<>(Arrays.asList(values9));
      short[] params2 = new short[arraylist9.size()];
      for (int i = 0; i < arraylist9.size(); i++) {
        boolean value = arraylist9.get(i);
        params2[i] = value ? (short) 1 : (short) 0;
      }
            List<Short> arraylist5 = S7control.getinstance().ReadWord("DB106.0", 1);
            List<Short> arraylist6 = S7control.getinstance().ReadWord("DB106.12", 1);
            List<Short> arraylist7 = S7control.getinstance().ReadWord("DB106.40", 1);
            List<Short> arraylist8 = S7control.getinstance().ReadWord("DB106.50", 1);
            List<String> addresses9 = new ArrayList<>();
            addresses9.add("DB104.1.2");
            addresses9.add("DB104.1.3");
            addresses9.add("DB104.1.6");
            addresses9.add("DB104.1.7");
            List<Boolean> arraylist9 = S7control.getinstance().readBits(addresses9);

      // Boolean[] values10 = { false, false, true, true };
      // List<Boolean> arraylist10 = new ArrayList<>(Arrays.asList(values10));
      short[] params3 = new short[arraylist10.size()];
      for (int i = 0; i < arraylist10.size(); i++) {
        boolean value = arraylist10.get(i);
        params3[i] = value ? (short) 1 : (short) 0;
      }
      // List<Short> arraylist9 = S7control.getinstance().readWords(addresses9);
      arraylist5.addAll(arraylist6);
      arraylist5.addAll(arraylist7);
      arraylist5.addAll(arraylist8);
            List<String> addresses10 = new ArrayList<>();
            addresses10.add("DB104.9.4");
            addresses10.add("DB104.9.5");
            addresses10.add("DB104.9.4");
            addresses10.add("DB104.9.5");
            List<Boolean> arraylist10 = S7control.getinstance().readBits(addresses10);

      JSONObject jsonObject = new JSONObject();
      // System.out.println(arraylist6);
      jsonObject.append("zuhe1", arraylist);
      jsonObject.append("zuhe2", arraylist2);
      jsonObject.append("zuhe3", arraylist3);
      jsonObject.append("zuhe4", arraylist4);
      jsonObject.append("shishi1", arraylist5);
      jsonObject.append("guzhang", params2);
      jsonObject.append("weihuiling", params3);
      jsonObject.append("qidong", combinedBinaryShortArray);
            //A01启动地址
            List<String> A01start = Arrays.asList(config.getProperty("mlp.A01start"));
            //A02启动地址
            List<String> A02start = Arrays.asList(config.getProperty("mlp.A02start"));

            List<String> B01start = Arrays.asList(config.getProperty("mlp.B01start"));

            List<String> B02start = Arrays.asList(config.getProperty("mlp.B02start"));

            List<Boolean> A01readstart = S7control.getinstance().readBits(A01start);
            List<Boolean> A02readstart = S7control.getinstance().readBits(A02start);
            List<Boolean> B01readstart = S7control.getinstance().readBits(B01start);
            List<Boolean> B02readstart = S7control.getinstance().readBits(B02start);

            short[] combinedBinaryShortArray = PLCBooleanConverter.convertListsToBinaryShortArray(
                    A01readstart, A02readstart, B01readstart, B02readstart
            );

            // Short[] values1 = { 1, 2, 3 };
            // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));
            // Short[] values2 = { 1, 2, 3 };
            // List<Short> arraylist2 = new ArrayList<>(Arrays.asList(values2));
            // Short[] values3 = { 1, 2, 3 };
            // List<Short> arraylist3 = new ArrayList<>(Arrays.asList(values3));
            // Short[] values4 = { 1, 2, 3 };
            // List<Short> arraylist4 = new ArrayList<>(Arrays.asList(values4));
            // Short[] values5 = { 5 };
            // List<Short> arraylist5 = new ArrayList<>(Arrays.asList(values5));
            // Short[] values6 = { 6 };
            // List<Short> arraylist6 = new ArrayList<>(Arrays.asList(values6));
            // Short[] values7 = { 7 };
            // List<Short> arraylist7 = new ArrayList<>(Arrays.asList(values7));
            // Short[] values8 = { 8 };
            // List<Short> arraylist8 = new ArrayList<>(Arrays.asList(values8));
            // Boolean[] values9 = { false, false, true, true };
            // List<Boolean> arraylist9 = new ArrayList<>(Arrays.asList(values9));
            short[] params2 = new short[arraylist9.size()];
            for (int i = 0; i < arraylist9.size(); i++) {
                boolean value = arraylist9.get(i);
                params2[i] = value ? (short) 1 : (short) 0;
            }

            // Boolean[] values10 = { false, false, true, true };
            // List<Boolean> arraylist10 = new ArrayList<>(Arrays.asList(values10));
            short[] params3 = new short[arraylist10.size()];
            for (int i = 0; i < arraylist10.size(); i++) {
                boolean value = arraylist10.get(i);
                params3[i] = value ? (short) 1 : (short) 0;
            }
            // List<Short> arraylist9 = S7control.getinstance().readWords(addresses9);
            arraylist5.addAll(arraylist6);
            arraylist5.addAll(arraylist7);
            arraylist5.addAll(arraylist8);

            JSONObject jsonObject = new JSONObject();
            // System.out.println(arraylist6);
            jsonObject.append("zuhe1", arraylist);
            jsonObject.append("zuhe2", arraylist2);
            jsonObject.append("zuhe3", arraylist3);
            jsonObject.append("zuhe4", arraylist4);
            jsonObject.append("shishi1", arraylist5);
            jsonObject.append("guzhang", params2);
            jsonObject.append("weihuiling", params3);
            jsonObject.append("qidong", combinedBinaryShortArray);

//      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ManualonePosition");
//      if (sendwServer != null) {
//        sendwServer.sendMessage(jsonObject.toString());
//      }

      ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("ManualonePosition");
      if (sendwServer != null) {
        for (WebSocketServer webserver : sendwServer) {
          webserver.sendMessage(jsonObject.toString());
            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("ManualonePosition");
            if (sendwServer != null) {
                for (WebSocketServer webserver : sendwServer) {
                    webserver.sendMessage(jsonObject.toString());

//      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("ManualonePosition");
      if (webserver != null) {
        List<String> messages = webserver.getMessages();
        List<String> waddresses1 = new ArrayList<>();
        waddresses1.add("DB100.108");
        waddresses1.add("DB100.20");
        waddresses1.add("DB103.32");
                    if (webserver != null) {
                        List<String> messages = webserver.getMessages();
                        List<String> waddresses1 = new ArrayList<>();
                        waddresses1.add("DB100.108");
                        waddresses1.add("DB100.20");
                        waddresses1.add("DB103.32");

        List<String> waddresses2 = new ArrayList<>();
        waddresses2.add("DB100.110");
        waddresses2.add("DB100.176");
        waddresses2.add("DB103.34");
                        List<String> waddresses2 = new ArrayList<>();
                        waddresses2.add("DB100.110");
                        waddresses2.add("DB100.176");
                        waddresses2.add("DB103.34");

        List<String> waddresses3 = new ArrayList<>();
        waddresses3.add("DB100.112");
        waddresses3.add("DB100.24");
        waddresses3.add("DB103.36");
                        List<String> waddresses3 = new ArrayList<>();
                        waddresses3.add("DB100.112");
                        waddresses3.add("DB100.24");
                        waddresses3.add("DB103.36");

        List<String> waddresses4 = new ArrayList<>();
        waddresses4.add("DB100.114");
        waddresses4.add("DB100.178");
        waddresses4.add("DB103.40");
                        List<String> waddresses4 = new ArrayList<>();
                        waddresses4.add("DB100.114");
                        waddresses4.add("DB100.178");
                        waddresses4.add("DB103.40");

        // 故障地址
        List<String> waddresses5 = new ArrayList<>();
        // waddresses5.add("DB103.244");
        // waddresses5.add("DB103.250");
        waddresses5.add("DB103.252");
        waddresses5.add("DB103.254");
                        // 故障地址
                        List<String> waddresses5 = new ArrayList<>();
                        // waddresses5.add("DB103.244");
                        // waddresses5.add("DB103.250");
                        waddresses5.add("DB103.252");
                        waddresses5.add("DB103.254");

        // 复位地址
        List<String> waddresses6 = new ArrayList<>();
        waddresses6.add("DB101.4.0");
        waddresses6.add("DB101.4.3");
        waddresses6.add("DB101.4.4");
        waddresses6.add("DB101.4.6");
                        // 复位地址
                        List<String> waddresses6 = new ArrayList<>();
                        waddresses6.add("DB101.4.0");
                        waddresses6.add("DB101.4.3");
                        waddresses6.add("DB101.4.4");
                        waddresses6.add("DB101.4.6");

        // 回零地址
        List<String> waddresses7 = new ArrayList<>();
                        // 回零地址
                        List<String> waddresses7 = new ArrayList<>();

        waddresses7.add("DB101.4.5");
        waddresses7.add("DB101.4.7");
                        waddresses7.add("DB101.4.5");
                        waddresses7.add("DB101.4.7");


        // System.out.println(messages.isEmpty());
        if (!messages.isEmpty()) {
          // 将最后一个消息转换为 short 类型的列表
          String lastMessage = messages.get(messages.size() - 1);
          // System.out.println("lastMessage：" + lastMessage);
          JSONArray messageArray = new JSONArray(lastMessage);
          // 写入A01
          if (messageArray.getJSONArray(0).size() > 0) {
            JSONArray jsonArray = messageArray.getJSONArray(0);
            List<Short> sValue = new ArrayList<>();
            for (int i = 0; i < jsonArray.size(); i++) {
              Object value = jsonArray.get(i);
              if (value != null && !value.toString().equals("null")) {
                try {
                  String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                  short val = Short.parseShort(cleanedValue.trim());
                  sValue.add(val);
                  System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");
                } catch (NumberFormatException e) {
                  // 如果无法解析为 short 类型，则忽略该部分
                  System.err.println("Could not parse value: " + value);
                        // System.out.println(messages.isEmpty());
                        if (!messages.isEmpty()) {
                            // 将最后一个消息转换为 short 类型的列表
                            String lastMessage = messages.get(messages.size() - 1);
                            // System.out.println("lastMessage：" + lastMessage);
                            JSONArray messageArray = new JSONArray(lastMessage);
                            // 写入A01
                            customS7Control.WriteWordToPLC(messageArray, waddresses1, 0);


                            // 写入A02
                            customS7Control.WriteWordToPLC(messageArray, waddresses2, 1);


                            // 写入B01
                            customS7Control.WriteWordToPLC(messageArray, waddresses3, 2);

                            // 写入B02
                            customS7Control.WriteWordToPLC(messageArray, waddresses4, 3);


                            // 写入故障地址

                            customS7Control.writeBitToPLC(messageArray, waddresses5, 4);


                            // 写入复位地址
                            customS7Control.writeBitToPLC(messageArray, waddresses6, 5);

                            // 写入回零地址

                            customS7Control.writeBitToPLC(messageArray, waddresses7, 6);
                            //A01启动
                            customS7Control.writeBitToPLC(messageArray, A01start, 7);
                            //A02启动
                            customS7Control.writeBitToPLC(messageArray, A02start, 8);
                            //B01启动
                            customS7Control.writeBitToPLC(messageArray, B01start, 9);
                            //B02启动
                            customS7Control.writeBitToPLC(messageArray, B02start, 10);

                            // 清空消息列表
                            webserver.clearMessages();
                        }
                    }
                }
              }
            }
            if (!sValue.isEmpty()) {
              S7control.getinstance().WriteWord(waddresses1, sValue);


              System.out.println("Values " + sValue + " written to PLC at address " + waddresses1);
            }
          }

          // 写入A02

          if (messageArray.getJSONArray(1).size() > 0) {
            JSONArray jsonArray = messageArray.getJSONArray(1);
            List<Short> sValue2 = new ArrayList<>();
            for (int i = 0; i < jsonArray.size(); i++) {
              Object value = jsonArray.get(i);
              if (value != null && !value.toString().equals("null")) {
                try {
                  String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                  short val = Short.parseShort(cleanedValue.trim());
                  sValue2.add(val);
                  System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");
                } catch (NumberFormatException e) {
                  // 如果无法解析为 short 类型，则忽略该部分
                  System.err.println("Could not parse value: " + value);
                }
              }
            }
            if (!sValue2.isEmpty()) {
              S7control.getinstance().WriteWord(waddresses2, sValue2);



              System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses2);
            }
          }

          // 写入B01
          if (messageArray.getJSONArray(2).size() > 0) {
            JSONArray jsonArray = messageArray.getJSONArray(2);
            List<Short> sValue2 = new ArrayList<>();
            for (int i = 0; i < jsonArray.size(); i++) {
              Object value = jsonArray.get(i);
              if (value != null && !value.toString().equals("null")) {
                try {
                  String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                  short val = Short.parseShort(cleanedValue.trim());
                  sValue2.add(val);
                  System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");
                } catch (NumberFormatException e) {
                  // 如果无法解析为 short 类型，则忽略该部分
                  System.err.println("Could not parse value: " + value);
                }
              }
            }
            if (!sValue2.isEmpty()) {
              S7control.getinstance().WriteWord(waddresses3, sValue2);

              System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses3);
            }
          }

          // 写入B02
          if (messageArray.getJSONArray(3).size() > 0) {
            JSONArray jsonArray = messageArray.getJSONArray(3);
            List<Short> sValue2 = new ArrayList<>();
            for (int i = 0; i < jsonArray.size(); i++) {
              Object value = jsonArray.get(i);
              if (value != null && !value.toString().equals("null")) {
                try {
                  String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                  short val = Short.parseShort(cleanedValue.trim());
                  sValue2.add(val);
                  System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");
                } catch (NumberFormatException e) {
                  // 如果无法解析为 short 类型，则忽略该部分
                  System.err.println("Could not parse value: " + value);
                }
              }
            }
            if (!sValue2.isEmpty()) {
              S7control.getinstance().WriteWord(waddresses4, sValue2);

              System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses4);
            }
          }

          // 写入故障地址
          if (messageArray.getJSONArray(4).size() > 0) {
            JSONArray jsonArray = messageArray.getJSONArray(4);
            List<Short> sValue2 = new ArrayList<>();
            for (int i = 0; i < jsonArray.size(); i++) {
              Object value = jsonArray.get(i);
              if (value != null && !value.toString().equals("null")) {
                try {
                  String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                  short val = Short.parseShort(cleanedValue.trim());
                  sValue2.add(val);
                  System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");
                } catch (NumberFormatException e) {
                  // 如果无法解析为 short 类型，则忽略该部分
                  System.err.println("Could not parse value: " + value);
                }
              }
            }
            if (!sValue2.isEmpty()) {
              S7control.getinstance().WriteWord(waddresses5, sValue2);
              System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses5);
            }
          }

          // 写入复位地址
          if (messageArray.getJSONArray(5).size() > 0) {
            JSONArray jsonArray3 = messageArray.getJSONArray(5);
            List<Boolean> sValue3 = new ArrayList<>();
            for (int i = 0; i < jsonArray3.size(); i++) {
              Object value = jsonArray3.get(i);
              if (value != null && !value.toString().equals("null")) {
                try {
                  String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                  boolean val = "1".equals(cleanedValue.trim());
                  sValue3.add(val);
                  System.out.println("messageValue: " + Arrays.asList(val) + " added to the list");
                } catch (NumberFormatException e) {
                  // 如果无法解析为 boolean 类型，则忽略该部分
                  System.err.println("Could not parse value: " + value);
                }
              }
            }
            if (!sValue3.isEmpty()) {
              S7control.getinstance().WriteBit(waddresses6, sValue3);
              System.out.println("Values " + sValue3 + " written to PLC at address " + waddresses6);
            }
          }

          // 写入回零地址
          if (messageArray.getJSONArray(6).size() > 0) {
            JSONArray jsonArray3 = messageArray.getJSONArray(6);
            List<Boolean> sValue3 = new ArrayList<>();
            for (int i = 0; i < jsonArray3.size(); i++) {
              Object value = jsonArray3.get(i);
              if (value != null && !value.toString().equals("null")) {
                try {
                  String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                  boolean val = "1".equals(cleanedValue.trim());
                  sValue3.add(val);
                  System.out.println("messageValue: " + Arrays.asList(val) + " added to the list");
                } catch (NumberFormatException e) {
                  // 如果无法解析为 boolean 类型，则忽略该部分
                  System.err.println("Could not parse value: " + value);
                }
              }
            }
            if (!sValue3.isEmpty()) {
              S7control.getinstance().WriteBit(waddresses7, sValue3);
              System.out.println("Values " + sValue3 + " written to PLC at address " + waddresses7);
            }
          }

          customS7Control.writeBitToPLC( messageArray, A01start,7);
          customS7Control.writeBitToPLC( messageArray, A02start,8);
          customS7Control.writeBitToPLC( messageArray,B01start,9);
          customS7Control.writeBitToPLC( messageArray, B02start,10);

          // 清空消息列表
          webserver.clearMessages();
        }
      }}
      }
    }
  }
}

 springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition2.java

@@ -10,307 +10,200 @@
import java.util.List;



public class PlcManualonePosition2 extends Thread {

  private Configuration config;

    private Configuration config;



  public PlcManualonePosition2() throws IOException {

    config = new Configuration("config.properties");

  }





  MessageHandler customS7Control = new MessageHandler();

  public static class PLCBooleanConverter {



    public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) {

      // 计算所有列表中元素的总数

      int totalSize = 0;

      for (List<Boolean> list : lists) {

        totalSize += list.size();

      }



      // 创建一个足够大的数组来存放所有的二进制值

      short[] binaryShortArray = new short[totalSize];



      // 当前数组填充位置指针

      int currentIndex = 0;



      // 遍历所有的列表

      for (List<Boolean> list : lists) {

        // 将每个布尔值转换为 0 或 1 并填入数组

        for (Boolean value : list) {

          binaryShortArray[currentIndex++] = (short) (value ? 1 : 0);

        }

      }



      return binaryShortArray;

    public PlcManualonePosition2() throws IOException {

        config = new Configuration("config.properties");

    }

  }





    MessageHandler customS7Control = new MessageHandler();



    public static class PLCBooleanConverter {



        public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) {

            // 计算所有列表中元素的总数

            int totalSize = 0;

            for (List<Boolean> list : lists) {

                totalSize += list.size();

            }



            // 创建一个足够大的数组来存放所有的二进制值

            short[] binaryShortArray = new short[totalSize];



            // 当前数组填充位置指针

            int currentIndex = 0;



            // 遍历所有的列表

            for (List<Boolean> list : lists) {

                // 将每个布尔值转换为 0 或 1 并填入数组

                for (Boolean value : list) {

                    binaryShortArray[currentIndex++] = (short) (value ? 1 : 0);

                }

            }



            return binaryShortArray;

        }

    }





  @Override

  public void run() {

    while (this != null) {

      try {

        Thread.sleep(500);

    @Override

    public void run() {

        while (this != null) {

            try {

                Thread.sleep(500);



      } catch (InterruptedException e) {

        e.printStackTrace();

      }

      // this.readValue();

      // String PlcAddress = this.name;

      // Integer Plccount = this.count;

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

            // this.readValue();

            // String PlcAddress = this.name;

            // Integer Plccount = this.count;



      List<String> addresses = new ArrayList<>();

      addresses.add("DB100.116");

      addresses.add("DB100.16");

            List<String> addresses = new ArrayList<>();

            addresses.add("DB100.116");

            addresses.add("DB100.16");



      addresses.add("DB103.20");

      List<Short> arraylist = S7control.getinstance().readWords(addresses);

      // System.out.println(arraylist);

            addresses.add("DB103.20");

            List<Short> arraylist = S7control.getinstance().readWords(addresses);

            // System.out.println(arraylist);



      List<String> addresses2 = new ArrayList<>();

      addresses2.add("DB100.118");

      addresses2.add("DB100.192");

            List<String> addresses2 = new ArrayList<>();

            addresses2.add("DB100.118");

            addresses2.add("DB100.192");



      addresses2.add("DB103.22");

      List<Short> arraylist2 = S7control.getinstance().readWords(addresses2);

            addresses2.add("DB103.22");

            List<Short> arraylist2 = S7control.getinstance().readWords(addresses2);



      List<String> addresses9 = new ArrayList<>();

            List<String> addresses9 = new ArrayList<>();



      addresses9.add("DB104.1.2");

      addresses9.add("DB104.1.3");

      List<Boolean> arraylist9 = S7control.getinstance().readBits(addresses9);

      short[] params2 = new short[arraylist9.size()];

      for (int i = 0; i < arraylist9.size(); i++) {

        boolean value = arraylist9.get(i);

        params2[i] = value ? (short) 1 : (short) 0;

      }

            addresses9.add("DB104.1.2");

            addresses9.add("DB104.1.3");

            List<Boolean> arraylist9 = S7control.getinstance().readBits(addresses9);

            short[] params2 = new short[arraylist9.size()];

            for (int i = 0; i < arraylist9.size(); i++) {

                boolean value = arraylist9.get(i);

                params2[i] = value ? (short) 1 : (short) 0;

            }



      // Short[] values1 = { 1, 2, 3 };

      // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));

      // Short[] values2 = { 1, 2, 3 };

      // List<Short> arraylist2 = new ArrayList<>(Arrays.asList(values2));

      // Boolean[] values9 = { false, true };

      // List<Boolean> arraylist9 = new ArrayList<>(Arrays.asList(values9));

      // short[] params2 = new short[arraylist9.size()];

      // for (int i = 0; i < arraylist9.size(); i++) {

      // boolean value = arraylist9.get(i);

      // params2[i] = value ? (short) 1 : (short) 0;

      // }

            // Short[] values1 = { 1, 2, 3 };

            // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));

            // Short[] values2 = { 1, 2, 3 };

            // List<Short> arraylist2 = new ArrayList<>(Arrays.asList(values2));

            // Boolean[] values9 = { false, true };

            // List<Boolean> arraylist9 = new ArrayList<>(Arrays.asList(values9));

            // short[] params2 = new short[arraylist9.size()];

            // for (int i = 0; i < arraylist9.size(); i++) {

            // boolean value = arraylist9.get(i);

            // params2[i] = value ? (short) 1 : (short) 0;

            // }



      // Boolean[] values10 = { false, true };

      List<String> addresses10 = new ArrayList<>();

            // Boolean[] values10 = { false, true };

            List<String> addresses10 = new ArrayList<>();



      addresses10.add("DB104.9.0");

      addresses10.add("DB104.9.1");

      List<Boolean> arraylist10 = S7control.getinstance().readBits(addresses10);

      short[] params3 = new short[arraylist10.size()];

      for (int i = 0; i < arraylist10.size(); i++) {

        boolean value = arraylist10.get(i);

        params3[i] = value ? (short) 1 : (short) 0;

      }

            addresses10.add("DB104.9.0");

            addresses10.add("DB104.9.1");

            List<Boolean> arraylist10 = S7control.getinstance().readBits(addresses10);

            short[] params3 = new short[arraylist10.size()];

            for (int i = 0; i < arraylist10.size(); i++) {

                boolean value = arraylist10.get(i);

                params3[i] = value ? (short) 1 : (short) 0;

            }







      //A01启动地址

      List<String> A01start = Arrays.asList(config.getProperty("mlp2.A01start"));

      //A02启动地址

      List<String> A02start = Arrays.asList(config.getProperty("mlp2.A02start"));

            //A01启动地址

            List<String> A01start = Arrays.asList(config.getProperty("mlp2.A01start"));

            //A02启动地址

            List<String> A02start = Arrays.asList(config.getProperty("mlp2.A02start"));







      List<Boolean> A01readstart = S7control.getinstance().readBits(A01start);

      List<Boolean> A02readstart = S7control.getinstance().readBits(A02start);

            List<Boolean> A01readstart = S7control.getinstance().readBits(A01start);

            List<Boolean> A02readstart = S7control.getinstance().readBits(A02start);





      short[] combinedBinaryShortArray = PLCBooleanConverter.convertListsToBinaryShortArray(

              A01readstart,  A02readstart

      );

            short[] combinedBinaryShortArray = PLCBooleanConverter.convertListsToBinaryShortArray(

                    A01readstart, A02readstart

            );



      JSONObject jsonObject = new JSONObject();

            JSONObject jsonObject = new JSONObject();



      jsonObject.append("zuhe1", arraylist);

      jsonObject.append("zuhe2", arraylist2);

      jsonObject.append("guzhang", params2);

      jsonObject.append("weihuiling", params3);

      jsonObject.append("qidong", combinedBinaryShortArray);

      // System.out.println(jsonObject);

            jsonObject.append("zuhe1", arraylist);

            jsonObject.append("zuhe2", arraylist2);

            jsonObject.append("guzhang", params2);

            jsonObject.append("weihuiling", params3);

            jsonObject.append("qidong", combinedBinaryShortArray);

            // System.out.println(jsonObject);

//      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ManualonePosition2");

//      if (sendwServer != null) {

//        sendwServer.sendMessage(jsonObject.toString());

//      }

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

      if (sendwServer != null) {

        for (WebSocketServer webserver : sendwServer) {

          webserver.sendMessage(jsonObject.toString());

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

            if (sendwServer != null) {

                for (WebSocketServer webserver : sendwServer) {

                    webserver.sendMessage(jsonObject.toString());



//      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("ManualonePosition2");

          if (webserver != null) {

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

            List<String> waddresses1 = new ArrayList<>();

            waddresses1.add("DB100.116");

            waddresses1.add("DB100.16");

                    if (webserver != null) {

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

                        List<String> waddresses1 = new ArrayList<>();

                        waddresses1.add("DB100.116");

                        waddresses1.add("DB100.16");





            List<String> waddresses2 = new ArrayList<>();

            waddresses2.add("DB100.118");

            waddresses2.add("DB100.192");

                        List<String> waddresses2 = new ArrayList<>();

                        waddresses2.add("DB100.118");

                        waddresses2.add("DB100.192");





            // 故障地址

            List<String> waddresses3 = new ArrayList<>();

            waddresses3.add("DB103.242");

            waddresses3.add("DB103.248");

                        // 故障地址

                        List<String> waddresses3 = new ArrayList<>();

                        waddresses3.add("DB103.242");

                        waddresses3.add("DB103.248");



            // 复位地址

            List<String> waddresses4 = new ArrayList<>();

            waddresses4.add("DB101.3.6");

            waddresses4.add("DB101.4.1");

                        // 复位地址

                        List<String> waddresses4 = new ArrayList<>();

                        waddresses4.add("DB101.3.6");

                        waddresses4.add("DB101.4.1");



            // 回零地址

            List<String> waddresses5 = new ArrayList<>();

            waddresses5.add("DB101.3.7");

            waddresses5.add("DB101.4.2");

                        // 回零地址

                        List<String> waddresses5 = new ArrayList<>();

                        waddresses5.add("DB101.3.7");

                        waddresses5.add("DB101.4.2");



            if (!messages.isEmpty()) {

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

              String lastMessage = messages.get(messages.size() - 1);

              // System.out.println("lastMessage：" + lastMessage);

              JSONArray messageArray = new JSONArray(lastMessage);

                        if (!messages.isEmpty()) {

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

                            String lastMessage = messages.get(messages.size() - 1);

                            // System.out.println("lastMessage：" + lastMessage);

                            JSONArray messageArray = new JSONArray(lastMessage);



              // A01下发

              if (messageArray.getJSONArray(0).size() > 0) {

                JSONArray jsonArray = messageArray.getJSONArray(0);

                List<Short> sValue = new ArrayList<>();

                for (int i = 0; i < jsonArray.size(); i++) {

                  Object value = jsonArray.get(i);

                  if (value != null && !value.toString().equals("null")) {

                    try {

                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");

                      short val = Short.parseShort(cleanedValue.trim());

                      sValue.add(val);

                      System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");

                    } catch (NumberFormatException e) {

                      // 如果无法解析为 short 类型，则忽略该部分

                      System.err.println("Could not parse value: " + value);

                            // A01下发

                            customS7Control.WriteWordToPLC(messageArray, waddresses1, 0);





                            // A02下发

                            customS7Control.WriteWordToPLC(messageArray, waddresses2, 1);





                            // 写入故障地址

                            customS7Control.WriteWordToPLC(messageArray, waddresses3, 2);





                            // 写入复位地址

                            customS7Control.writeBitToPLC(messageArray, waddresses4, 3);





                            // 写入回零地址

                            customS7Control.writeBitToPLC(messageArray, waddresses5, 4);



                            customS7Control.writeBitToPLC(messageArray, A01start, 5);

                            customS7Control.writeBitToPLC(messageArray, A02start, 6);



                            // 清空消息列表

                            webserver.clearMessages();

                        }

                    }

                  }

                }

                if (!sValue.isEmpty()) {

                  S7control.getinstance().WriteWord(waddresses1, sValue);



                  System.out.println("Values " + sValue + " written to PLC at address " + waddresses1);

                }

              }



              // A02下发

              if (messageArray.getJSONArray(1).size() > 0) {

                JSONArray jsonArray = messageArray.getJSONArray(1);

                List<Short> sValue2 = new ArrayList<>();

                for (int i = 0; i < jsonArray.size(); i++) {

                  Object value = jsonArray.get(i);

                  if (value != null && !value.toString().equals("null")) {

                    try {

                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");

                      short val = Short.parseShort(cleanedValue.trim());

                      sValue2.add(val);

                      System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");

                    } catch (NumberFormatException e) {

                      // 如果无法解析为 short 类型，则忽略该部分

                      System.err.println("Could not parse value: " + value);

                    }

                  }

                }

                if (!sValue2.isEmpty()) {

                  S7control.getinstance().WriteWord(waddresses2, sValue2);



                  System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses2);

                }

              }



              // 写入故障地址

              if (messageArray.getJSONArray(2).size() > 0) {

                JSONArray jsonArray = messageArray.getJSONArray(2);

                List<Short> sValue2 = new ArrayList<>();

                for (int i = 0; i < jsonArray.size(); i++) {

                  Object value = jsonArray.get(i);

                  if (value != null && !value.toString().equals("null")) {

                    try {

                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");

                      short val = Short.parseShort(cleanedValue.trim());

                      sValue2.add(val);

                      System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");

                    } catch (NumberFormatException e) {

                      // 如果无法解析为 short 类型，则忽略该部分

                      System.err.println("Could not parse value: " + value);

                    }

                  }

                }

                if (!sValue2.isEmpty()) {

                  S7control.getinstance().WriteWord(waddresses3, sValue2);

                  System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses3);

                }

              }



              // 写入复位地址

              if (messageArray.getJSONArray(3).size() > 0) {

                JSONArray jsonArray3 = messageArray.getJSONArray(3);

                List<Boolean> sValue3 = new ArrayList<>();

                for (int i = 0; i < jsonArray3.size(); i++) {

                  Object value = jsonArray3.get(i);

                  if (value != null && !value.toString().equals("null")) {

                    try {

                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");

                      boolean val = "1".equals(cleanedValue.trim());

                      sValue3.add(val);

                      System.out.println("messageValue: " + Arrays.asList(val) + " added to the list");

                    } catch (NumberFormatException e) {

                      // 如果无法解析为 boolean 类型，则忽略该部分

                      System.err.println("Could not parse value: " + value);

                    }

                  }

                }

                if (!sValue3.isEmpty()) {

                  S7control.getinstance().WriteBit(waddresses4, sValue3);

                  System.out.println("Values " + sValue3 + " written to PLC at address " + waddresses4);

                }

              }



              // 写入回零地址

              if (messageArray.getJSONArray(4).size() > 0) {

                JSONArray jsonArray3 = messageArray.getJSONArray(4);

                List<Boolean> sValue3 = new ArrayList<>();

                for (int i = 0; i < jsonArray3.size(); i++) {

                  Object value = jsonArray3.get(i);

                  if (value != null && !value.toString().equals("null")) {

                    try {

                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");

                      boolean val = "1".equals(cleanedValue.trim());

                      sValue3.add(val);

                      System.out.println("messageValue: " + Arrays.asList(val) + " added to the list");

                    } catch (NumberFormatException e) {

                      // 如果无法解析为 boolean 类型，则忽略该部分

                      System.err.println("Could not parse value: " + value);

                    }

                  }

                }

                if (!sValue3.isEmpty()) {

                  S7control.getinstance().WriteBit(waddresses5, sValue3);

                  System.out.println("Values " + sValue3 + " written to PLC at address " + waddresses5);

                }

              }





              customS7Control.writeBitToPLC( messageArray, A01start,5);

              customS7Control.writeBitToPLC( messageArray, A02start,6);



              // 清空消息列表

              webserver.clearMessages();

            }

          }

        }

      }

    }

  }

}


 springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter1.java

@@ -10,202 +10,130 @@
import java.util.List;

public class PlcParameter1 extends Thread {
  String name = "";
  Integer count = 0;

  public static String readFileToString(String filePath) throws IOException {
    File file = new File(filePath);
    return FileUtils.readFileToString(file, "UTF-8");
  }
    MessageHandler customS7Control = new MessageHandler();

  public void readValue() {
    String str = "";
    BufferedReader bufferedReader = null;
    FileInputStream fileInputStream;
    try {
      // 从文件中读取字节数据存入 fileInputStream
      fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json");
      // 读取 fileInputStream 中字节并将其解码为字符
      InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "utf-8");
      // 提高读取效率，在 BufferedReader 内包装 InputStreamReader
      bufferedReader = new BufferedReader(inputStreamReader);
      String line = null;
      // 将 bufferedReader 内容一行一行赋值给str
      while ((line = bufferedReader.readLine()) != null) {
        str += line;
      }
    @Override
    public void run() {
        while (this != null) {
            try {
                Thread.sleep(1000);

      // 将str字符串格式转为json
      JSONObject jsonObject = new JSONObject(str);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

      // 获取json中的值
      JSONArray address = jsonObject.getJSONArray("address");
      for (int i = 0; i < address.size(); i++) {
        JSONObject ress = (JSONObject) address.get(i);

        this.name = ress.getStr("name");
        this.count = ress.getInt("count");

      }

    } catch (FileNotFoundException e) {
      e.printStackTrace();
    } catch (UnsupportedEncodingException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }

  @Override
  public void run() {
    while (this != null) {
      try {
        Thread.sleep(1000);

      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      // this.readValue();
      // String PlcAddress = this.name;
      // Integer Plccount = this.count;

      // System.out.println(stt);
      List<String> addresses = new ArrayList<>();
      addresses.add("DB100.0");
      addresses.add("DB100.2");
      addresses.add("DB100.4");
      addresses.add("DB100.6");
      addresses.add("DB100.26");
      addresses.add("DB100.28");
      addresses.add("DB100.30");
      addresses.add("DB100.32");
      addresses.add("DB100.34");
      addresses.add("DB100.36");
      addresses.add("DB100.38");
      addresses.add("DB100.40");
      List<Short> arraylist = S7control.getinstance().readWords(addresses);
            // System.out.println(stt);
            List<String> addresses = new ArrayList<>();
            addresses.add("DB100.0");
            addresses.add("DB100.2");
            addresses.add("DB100.4");
            addresses.add("DB100.6");
            addresses.add("DB100.26");
            addresses.add("DB100.28");
            addresses.add("DB100.30");
            addresses.add("DB100.32");
            addresses.add("DB100.34");
            addresses.add("DB100.36");
            addresses.add("DB100.38");
            addresses.add("DB100.40");
            List<Short> arraylist = S7control.getinstance().readWords(addresses);
//翻转
    List<Short> fanzhuan1 = S7control.getinstance().ReadWord("DB100.8", 1);
    List<Short> xiaoche1 = S7control.getinstance().ReadWord("DB100.12", 1);
      // Short[] values1 = { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12 };
      // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));
      // Short[] fanzhuan = { 4 };
      // List<Short> fanzhuan1 = new ArrayList<>(Arrays.asList(fanzhuan));
      // Short[] xiaoche = {5};
      // List<Short> xiaoche1 = new ArrayList<>(Arrays.asList(xiaoche));
            List<Short> fanzhuan1 = S7control.getinstance().ReadWord("DB100.8", 1);
            List<Short> xiaoche1 = S7control.getinstance().ReadWord("DB100.12", 1);
            // Short[] values1 = { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12 };
            // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));
            // Short[] fanzhuan = { 4 };
            // List<Short> fanzhuan1 = new ArrayList<>(Arrays.asList(fanzhuan));
            // Short[] xiaoche = {5};
            // List<Short> xiaoche1 = new ArrayList<>(Arrays.asList(xiaoche));

      JSONObject jsonObject = new JSONObject();
      // new short[]{1,1, 1, 1, 1, 1, 2, 33, 2,3, 4, 5}
      // new short[]{0,0, 0, 0, 0, 0, 0, 0, 0, 0}
            JSONObject jsonObject = new JSONObject();
            // new short[]{1,1, 1, 1, 1, 1, 2, 33, 2,3, 4, 5}
            // new short[]{0,0, 0, 0, 0, 0, 0, 0, 0, 0}

      jsonObject.append("params", arraylist);
     jsonObject.append("fanzhuan", fanzhuan1);
     jsonObject.append("xiaoche", xiaoche1);
            jsonObject.append("params", arraylist);
            jsonObject.append("fanzhuan", fanzhuan1);
            jsonObject.append("xiaoche", xiaoche1);

//      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter1");
//      if (sendwServer != null) {
//        sendwServer.sendMessage(jsonObject.toString());
//      }

      ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Parameter1");
      if (sendwServer != null) {
        for (WebSocketServer webserver : sendwServer) {
          webserver.sendMessage(jsonObject.toString());
            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Parameter1");
            if (sendwServer != null) {
                for (WebSocketServer webserver : sendwServer) {
                    webserver.sendMessage(jsonObject.toString());


          if (webserver != null) {
            List<String> messages = webserver.getMessages();
            List<String> waddresses1 = new ArrayList<>();
            waddresses1.add("DB100.0");
            waddresses1.add("DB100.2");
            waddresses1.add("DB100.4");
            waddresses1.add("DB100.6");
            waddresses1.add("DB100.26");
            waddresses1.add("DB100.28");
            waddresses1.add("DB100.30");
            waddresses1.add("DB100.32");
            waddresses1.add("DB100.34");
            waddresses1.add("DB100.36");
            waddresses1.add("DB100.38");
            waddresses1.add("DB100.40");
                    if (webserver != null) {
                        List<String> messages = webserver.getMessages();
                        List<String> waddresses1 = new ArrayList<>();
                        waddresses1.add("DB100.0");
                        waddresses1.add("DB100.2");
                        waddresses1.add("DB100.4");
                        waddresses1.add("DB100.6");
                        waddresses1.add("DB100.26");
                        waddresses1.add("DB100.28");
                        waddresses1.add("DB100.30");
                        waddresses1.add("DB100.32");
                        waddresses1.add("DB100.34");
                        waddresses1.add("DB100.36");
                        waddresses1.add("DB100.38");
                        waddresses1.add("DB100.40");

            String addressList2 = "DB100.8";
            String addressList3 = "DB100.12";
                        String addressList2 = "DB100.8";
                        String addressList3 = "DB100.12";

            if (!messages.isEmpty()) {
              // 将最后一个消息转换为 short 类型的列表
              String lastMessage = messages.get(messages.size() - 1);
              // System.out.println("lastMessage：" + lastMessage);
              JSONArray messageArray = new JSONArray(lastMessage);
                        if (!messages.isEmpty()) {
                            // 将最后一个消息转换为 short 类型的列表
                            String lastMessage = messages.get(messages.size() - 1);
                            // System.out.println("lastMessage：" + lastMessage);
                            JSONArray messageArray = new JSONArray(lastMessage);

              // 整合第 1 到 3 个数组并去掉 null 元素
              List<Short> mergedList = new ArrayList<>();
              for (int i = 0; i < 3; i++) {
                JSONArray sublist = messageArray.getJSONArray(i);
                for (int j = 0; j < sublist.size(); j++) {
                  Object value = sublist.get(j);
                  if (value != null && !value.toString().equals("null")) {
                    try {
                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                      short sValue = Short.parseShort(cleanedValue.trim());
                      mergedList.add(sValue);
                    } catch (NumberFormatException e) {
                      // 如果无法解析为 short 类型，则忽略该部分
                      System.err.println("Could not parse value: " + value);
                            // 整合第 1 到 3 个数组并去掉 null 元素
                            List<Short> mergedList = new ArrayList<>();
                            for (int i = 0; i < 3; i++) {
                                JSONArray sublist = messageArray.getJSONArray(i);
                                for (int j = 0; j < sublist.size(); j++) {
                                    Object value = sublist.get(j);
                                    if (value != null && !value.toString().equals("null")) {
                                        try {
                                            String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                                            short sValue = Short.parseShort(cleanedValue.trim());
                                            mergedList.add(sValue);
                                        } catch (NumberFormatException e) {
                                            // 如果无法解析为 short 类型，则忽略该部分
                                            System.err.println("Could not parse value: " + value);
                                        }
                                    }
                                }
                            }

                            // 写入第一个地址
                            customS7Control.WriteWordsToPLC(messageArray, addressList2, 3);


                            // 写入第二个地址
                            customS7Control.WriteWordsToPLC(messageArray, addressList3, 4);


                            // 写入第三个地址
                            if (!mergedList.isEmpty()) {
                                S7control.getinstance().WriteWord(waddresses1, mergedList);
                                System.out.println("messageValue：" + mergedList + " written to PLC at address " + waddresses1);
                            }

                            // 清空消息列表
                            webserver.clearMessages();
                        }
                    }
                  }
                }
              }

              // 写入第一个地址
              if (messageArray.getJSONArray(3).size() > 0) {
                Object value = messageArray.getJSONArray(3).get(0);
                if (value != null && !value.toString().equals("null")) {
                  try {
                    String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                    short sValue = Short.parseShort(cleanedValue.trim());
                    S7control.getinstance().WriteWord(addressList2, Arrays.asList(sValue));
                    System.out
                            .println("messageValue：" + Arrays.asList(sValue) + " written to PLC at address " + addressList2);
                  } catch (NumberFormatException e) {
                    // 如果无法解析为 short 类型，则忽略该部分
                    System.err.println("Could not parse value: " + value);
                  }
                }
              }

              // 写入第二个地址
              if (messageArray.getJSONArray(4).size() > 0) {
                Object value = messageArray.getJSONArray(4).get(0);
                if (value != null && !value.toString().equals("null")) {
                  try {
                    String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                    short sValue = Short.parseShort(cleanedValue.trim());
                    S7control.getinstance().WriteWord(addressList3, Arrays.asList(sValue));
                    System.out
                            .println("messageValue：" + Arrays.asList(sValue) + " written to PLC at address " + addressList3);
                  } catch (NumberFormatException e) {
                    // 如果无法解析为 short 类型，则忽略该部分
                    System.err.println("Could not parse value: " + value);
                  }
                }
              }

              // 写入第三个地址
              if (!mergedList.isEmpty()) {
                S7control.getinstance().WriteWord(waddresses1, mergedList);
                System.out.println("messageValue：" + mergedList + " written to PLC at address " + waddresses1);
              }

              // 清空消息列表
              webserver.clearMessages();
            }
          }

        }

      }

    }
  }
}

 springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter2.java

@@ -12,144 +12,99 @@


public class PlcParameter2 extends Thread {
  String name = "";
  Integer count = 0;

  public static String readFileToString(String filePath) throws IOException {
    File file = new File(filePath);
    return FileUtils.readFileToString(file, "UTF-8");
  }

  public void readValue() {
    String str = "";
    BufferedReader bufferedReader = null;
    FileInputStream fileInputStream;
    try {
      // 从文件中读取字节数据存入 fileInputStream
      fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json");
      // 读取 fileInputStream 中字节并将其解码为字符
      InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "utf-8");
      // 提高读取效率，在 BufferedReader 内包装 InputStreamReader
      bufferedReader = new BufferedReader(inputStreamReader);
      String line = null;
      // 将 bufferedReader 内容一行一行赋值给str
      while ((line = bufferedReader.readLine()) != null) {
        str += line;
      }

      // 将str字符串格式转为json
      JSONObject jsonObject = new JSONObject(str);

      // 获取json中的值
      JSONArray address = jsonObject.getJSONArray("Positioning1");
      for (int i = 0; i < address.size(); i++) {
        JSONObject ress = (JSONObject) address.get(i);

        this.name = ress.getStr("name");
        this.count = ress.getInt("count");

      }

    } catch (FileNotFoundException e) {
      e.printStackTrace();
    } catch (UnsupportedEncodingException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }

  @Override
  public void run() {
    while (this != null) {
      try {
        Thread.sleep(1000);

      } catch (InterruptedException e) {
        e.printStackTrace();
      }

     //  手动状态地址
      List<String> addressList1 = new ArrayList<>();

      addressList1.add("DB103.44");//D01
      addressList1.add("DB103.58");//D02
      addressList1.add("DB103.72");//D03
      addressList1.add("DB103.86");//D04
      addressList1.add("DB103.100");//D05
      addressList1.add("DB103.114");//D06
      addressList1.add("DB103.128");//A01
      addressList1.add("DB103.142");//A01 2
      addressList1.add("DB103.156");//A02
      addressList1.add("DB103.184");//B01
      addressList1.add("DB103.212");//B02


      List<String> paramlist = S7control.getinstance().readStrings(addressList1);
    // 创建一个自定义的 S7 控制器消息处理器对象
    MessageHandler customS7Control = new MessageHandler();


   //清除ID地址
      List<String> addresses = new ArrayList<>();
      addresses.add("DB103.0");
      addresses.add("DB103.2");
      addresses.add("DB103.12");
      addresses.add("DB103.14");
      addresses.add("DB103.16");
      addresses.add("DB103.18");
      addresses.add("DB103.8");
      addresses.add("DB103.10");
      addresses.add("DB103.4");
      addresses.add("DB103.6");
      List<Short> data = S7control.getinstance().readWords(addresses);
    @Override
    public void run() {
        while (this != null) {
            try {
                Thread.sleep(1000);

            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            //  id
            List<String> addressList1 = new ArrayList<>();

            addressList1.add("DB103.44");//D01
            addressList1.add("DB103.58");//D02
            addressList1.add("DB103.72");//D03
            addressList1.add("DB103.86");//D04
            addressList1.add("DB103.100");//D05
            addressList1.add("DB103.114");//D06
            addressList1.add("DB103.128");//A01
            addressList1.add("DB103.142");//A01 2
            addressList1.add("DB103.156");//A02
            addressList1.add("DB103.184");//B01
            addressList1.add("DB103.212");//B02


      //id
      List<String> addressList0 = new ArrayList<>();

      addressList0.add("DB101.9.2");
      addressList0.add("DB101.9.3");
      addressList0.add("DB101.9.4");
      addressList0.add("DB101.9.5");
      addressList0.add("DB101.9.6");
      addressList0.add("DB101.9.7");

      addressList0.add("DB101.10.0");
      addressList0.add("DB101.10.1");
      addressList0.add("DB101.10.2");
      addressList0.add("DB101.10.3");

     // 扫码枪
      List<Boolean> data2 = S7control.getinstance().readBits(addressList0);
      List<String> addressList3 = new ArrayList<>();
      addressList3.add("DB103.256");
      addressList3.add("DB103.270");
            List<String> paramlist = S7control.getinstance().readStrings(addressList1);


            //手动状态
            List<String> addresses = new ArrayList<>();
            addresses.add("DB103.0");
            addresses.add("DB103.2");
            addresses.add("DB103.12");
            addresses.add("DB103.14");
            addresses.add("DB103.16");
            addresses.add("DB103.18");
            addresses.add("DB103.8");
            addresses.add("DB103.10");
            addresses.add("DB103.4");
            addresses.add("DB103.6");
            List<Short> data = S7control.getinstance().readWords(addresses);


      List<String> niuanaddressList3 = new ArrayList<>();
            //清除id
            List<String> addressList0 = new ArrayList<>();

      niuanaddressList3.add("DB101.10.4");
      List<Boolean> anniuread = S7control.getinstance().readBits(niuanaddressList3);
            addressList0.add("DB101.9.2");
            addressList0.add("DB101.9.3");
            addressList0.add("DB101.9.4");
            addressList0.add("DB101.9.5");
            addressList0.add("DB101.9.6");
            addressList0.add("DB101.9.7");

            addressList0.add("DB101.10.0");
            addressList0.add("DB101.10.1");
            addressList0.add("DB101.10.2");
            addressList0.add("DB101.10.3");

            // 扫码枪
            List<Boolean> data2 = S7control.getinstance().readBits(addressList0);
            List<String> addressList3 = new ArrayList<>();
            addressList3.add("DB103.256");
            addressList3.add("DB103.270");


            List<String> niuanaddressList3 = new ArrayList<>();

      List<String> data3 = S7control.getinstance().readStrings(addressList3);
            niuanaddressList3.add("DB101.10.4");
            List<Boolean> anniuread = S7control.getinstance().readBits(niuanaddressList3);


            List<String> data3 = S7control.getinstance().readStrings(addressList3);
// A01 A02 B01 B02
      List<String> addresses4 = new ArrayList<>();
      addresses4.add("DB103.32");
      addresses4.add("DB103.34");
      addresses4.add("DB103.36");
      addresses4.add("DB103.40");
            List<String> addresses4 = new ArrayList<>();
            addresses4.add("DB103.32");
            addresses4.add("DB103.34");
            addresses4.add("DB103.36");
            addresses4.add("DB103.40");

    List<Short> data4 = S7control.getinstance().readWords(addresses4);
            List<Short> data4 = S7control.getinstance().readWords(addresses4);

//      List<Long> TIME2 = Collections.singletonList(S7control.getinstance().readtime("DB100.194"));
//      System.out.println("addressList：" + TIME2);


      //

            //


//
@@ -166,25 +121,25 @@
//      List<Short> data4 = new ArrayList<>(Arrays.asList(values4));
//
//
      JSONObject jsonObject = new JSONObject();
      short[] params = new short[data2.size()];
      for (int i = 0; i < data2.size(); i++) {
        boolean value = data2.get(i);
        params[i] = value ? (short) 1 : (short) 0;
      }
            JSONObject jsonObject = new JSONObject();
            short[] params = new short[data2.size()];
            for (int i = 0; i < data2.size(); i++) {
                boolean value = data2.get(i);
                params[i] = value ? (short) 1 : (short) 0;
            }
//
      short[] anniuparams = new short[anniuread.size()];
      for (int i = 0; i < anniuread.size(); i++) {
        boolean value = anniuread.get(i);
        anniuparams[i] = value ? (short) 1 : (short) 0;
      }
            short[] anniuparams = new short[anniuread.size()];
            for (int i = 0; i < anniuread.size(); i++) {
                boolean value = anniuread.get(i);
                anniuparams[i] = value ? (short) 1 : (short) 0;
            }

      jsonObject.append("params", params);
      jsonObject.append("params", paramlist);
      jsonObject.append("params", data);
      jsonObject.append("params", data3);
      jsonObject.append("params", data4);
     jsonObject.append("jiting", anniuparams);
            jsonObject.append("params", params);
            jsonObject.append("params", paramlist);
            jsonObject.append("params", data);
            jsonObject.append("params", data3);
            jsonObject.append("params", data4);
            jsonObject.append("jiting", anniuparams);


//      WebSocketServer sendwServer = WebSocketServer.getWebSocketServer("Parameter2");
@@ -194,92 +149,49 @@
//        sendwServer.sendMessage(jsonObject.toString());
//      }

      ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Parameter2");
 if (sendwServer != null) {
     for (WebSocketServer webserver : sendwServer) {
            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Parameter2");
            if (sendwServer != null) {
                for (WebSocketServer webserver : sendwServer) {

         webserver.sendMessage(jsonObject.toString());
                    webserver.sendMessage(jsonObject.toString());


         if (webserver != null) {
                    if (webserver != null) {


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

             addressList.add("DB101.9.2");
             addressList.add("DB101.9.3");
             addressList.add("DB101.9.4");
             addressList.add("DB101.9.5");
             addressList.add("DB101.9.6");
             addressList.add("DB101.9.7");
             addressList.add("DB101.10.0");
             addressList.add("DB101.10.1");
             addressList.add("DB101.10.2");
             addressList.add("DB101.10.3");
                        addressList.add("DB101.9.2");
                        addressList.add("DB101.9.3");
                        addressList.add("DB101.9.4");
                        addressList.add("DB101.9.5");
                        addressList.add("DB101.9.6");
                        addressList.add("DB101.9.7");
                        addressList.add("DB101.10.0");
                        addressList.add("DB101.10.1");
                        addressList.add("DB101.10.2");
                        addressList.add("DB101.10.3");


             if (!messages.isEmpty()) {
                 // 将最后一个消息转换为整数类型的列表
                 String lastMessage = messages.get(messages.size() - 1);
                        if (!messages.isEmpty()) {
                            // 将最后一个消息转换为整数类型的列表
                            String lastMessage = messages.get(messages.size() - 1);
//        System.out.println("lastMessage：" + lastMessage);
                 JSONArray messageArray = new JSONArray(lastMessage);

                 if (messageArray.getJSONArray(0).size() > 0) {
                     JSONArray jsonArray3 = messageArray.getJSONArray(0);
                     List<Boolean> sValue3 = new ArrayList<>();
                     for (int i = 0; i < jsonArray3.size(); i++) {
                         Object value = jsonArray3.get(i);
                         if (value != null && !value.toString().equals("null")) {
                             try {
                                 String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                                 boolean val = "1".equals(cleanedValue.trim());
                                 sValue3.add(val);
                                 System.out.println("messageValue: " + Arrays.asList(val) + " added to the list");
                             } catch (NumberFormatException e) {
                                 // 如果无法解析为 boolean 类型，则忽略该部分
                                 System.err.println("Could not parse value: " + value);
                             }
                         }
                     }
                     if (!sValue3.isEmpty()) {
           S7control.getinstance().WriteBit(addressList, sValue3);
                         System.out.println("Values " + sValue3 + " written to PLC at address " + addressList);
                     }
                 }
                 // 将布尔列表写入 PLC
                 if (messageArray.getJSONArray(1).size() > 0) {
                     JSONArray jsonArray3 = messageArray.getJSONArray(1);
                     List<Boolean> sValue3 = new ArrayList<>();
                     for (int i = 0; i < jsonArray3.size(); i++) {
                         Object value = jsonArray3.get(i);
                         if (value != null && !value.toString().equals("null")) {
                             try {
                                 String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                                 boolean val = "1".equals(cleanedValue.trim());
                                 sValue3.add(val);
                                 System.out.println("messageValue: " + Arrays.asList(val) + " added to the list");
                             } catch (NumberFormatException e) {
                                 // 如果无法解析为 boolean 类型，则忽略该部分
                                 System.err.println("Could not parse value: " + value);
                             }
                         }
                     }
                     if (!sValue3.isEmpty()) {
             S7control.getinstance().WriteBit(niuanaddressList3, sValue3);

                         System.out.println("Values " + sValue3 + " written to PLC at address " + sValue3);
                     }
                 }
                            JSONArray messageArray = new JSONArray(lastMessage);
                            //清除ID
                            customS7Control.writeBitToPLC(messageArray, addressList, 0);
                            //急停
                            customS7Control.writeBitToPLC(messageArray, niuanaddressList3, 1);


                 // 清空消息列表
                 webserver.clearMessages();
             }
         }
     }
 }
      }
                            // 清空消息列表
                            webserver.clearMessages();
                        }
                    }
                }
            }
        }
    }
  }
}


 springboot-vue3/src/main/java/com/example/springboot/component/PlcPositioning1.java

@@ -17,53 +17,7 @@
import org.apache.commons.io.FileUtils;



public class PlcPositioning1 extends Thread {

    String name = "";

    Integer count = 0;



    public static String readFileToString(String filePath) throws IOException {

        File file = new File(filePath);

        return FileUtils.readFileToString(file, "UTF-8");

    }



    public void readValue() {

        String str = "";

        BufferedReader bufferedReader = null;

        FileInputStream fileInputStream;

        try {

            // 从文件中读取字节数据存入 fileInputStream

            fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json");

            // 读取 fileInputStream 中字节并将其解码为字符

            InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "utf-8");

            // 提高读取效率，在 BufferedReader 内包装 InputStreamReader

            bufferedReader = new BufferedReader(inputStreamReader);

            String line = null;

            // 将 bufferedReader 内容一行一行赋值给str

            while ((line = bufferedReader.readLine()) != null) {

                str += line;

            }



            // 将str字符串格式转为json

            JSONObject jsonObject = new JSONObject(str);



            // 获取json中的值

            JSONArray address = jsonObject.getJSONArray("Positioning1");

            for (int i = 0; i < address.size(); i++) {

                JSONObject ress = (JSONObject) address.get(i);



                this.name = ress.getStr("name");

                this.count = ress.getInt("count");

                System.out.println("messageValues：" + this.name);

                System.out.println("messageValues：" + this.count);

            }



        } catch (FileNotFoundException e) {

            e.printStackTrace();

        } catch (UnsupportedEncodingException e) {

            e.printStackTrace();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }



    @Override

    public void run() {

@@ -74,13 +28,11 @@
            } catch (InterruptedException e) {

                e.printStackTrace();

            }

//        this.readValue();

//            String PlcAddress = this.name;

//            Integer Plccount = this.count;





            // System.out.println(stt);

            //存片格  出片格读取

  List<Short> arraylist = S7control.getinstance().ReadWord("DB100.42", 33);

            List<Short> arraylist = S7control.getinstance().ReadWord("DB100.42", 33);

//            System.out.println(arraylist);

//            Short[] 存片 = { 1 };

//            List<Short> 存片1 = new ArrayList<>(Arrays.asList(存片));


 springboot-vue3/src/main/java/com/example/springboot/component/PlcPositioning2.java

@@ -10,53 +10,7 @@
import java.util.List;



public class PlcPositioning2 extends Thread {

    String name = "";

    Integer count = 0;



    public static String readFileToString(String filePath) throws IOException {

        File file = new File(filePath);

        return FileUtils.readFileToString(file, "UTF-8");

    }



    public void readValue() {

        String str = "";

        BufferedReader bufferedReader = null;

        FileInputStream fileInputStream;

        try {

            // 从文件中读取字节数据存入 fileInputStream

            fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json");

            // 读取 fileInputStream 中字节并将其解码为字符

            InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "utf-8");

            // 提高读取效率，在 BufferedReader 内包装 InputStreamReader

            bufferedReader = new BufferedReader(inputStreamReader);

            String line = null;

            // 将 bufferedReader 内容一行一行赋值给str

            while ((line = bufferedReader.readLine()) != null) {

                str += line;

            }



            // 将str字符串格式转为json

            JSONObject jsonObject = new JSONObject(str);



            // 获取json中的值

            JSONArray address = jsonObject.getJSONArray("Positioning2");

            for (int i = 0; i < address.size(); i++) {

                JSONObject ress = (JSONObject) address.get(i);



                this.name = ress.getStr("name");

                this.count = ress.getInt("count");

                System.out.println("messageValues：" + this.name);

                System.out.println("messageValues：" + this.count);

            }



        } catch (FileNotFoundException e) {

            e.printStackTrace();

        } catch (UnsupportedEncodingException e) {

            e.printStackTrace();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }



    @Override

    public void run() {


 springboot-vue3/src/main/java/com/example/springboot/component/PlcServoManualone.java

@@ -13,171 +13,167 @@
public class PlcServoManualone extends Thread {


  // 用于存储应用程序的配置信息
  private Configuration config;
    // 用于存储应用程序的配置信息
    private Configuration config;

  // 创建一个自定义的 S7 控制器消息处理器对象
  MessageHandler customS7Control = new MessageHandler();
    // 创建一个自定义的 S7 控制器消息处理器对象
    MessageHandler customS7Control = new MessageHandler();


  public PlcServoManualone() throws IOException {
    config = new Configuration("config.properties");
  }
    public PlcServoManualone() throws IOException {
        config = new Configuration("config.properties");
    }

//将布尔列表转换为二进制的 short 数组
  public static class PLCBooleanConverter {
    //将布尔列表转换为二进制的 short 数组
    public static class PLCBooleanConverter {

    public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) {
      // 计算所有列表中元素的总数
      int totalSize = 0;
      for (List<Boolean> list : lists) {
        totalSize += list.size();
      }
        public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) {
            // 计算所有列表中元素的总数
            int totalSize = 0;
            for (List<Boolean> list : lists) {
                totalSize += list.size();
            }

      // 创建一个足够大的数组来存放所有的二进制值
      short[] binaryShortArray = new short[totalSize];
            // 创建一个足够大的数组来存放所有的二进制值
            short[] binaryShortArray = new short[totalSize];

      // 当前数组填充位置指针
      int currentIndex = 0;
            // 当前数组填充位置指针
            int currentIndex = 0;

      // 遍历所有的列表
      for (List<Boolean> list : lists) {
        // 将每个布尔值转换为 0 或 1 并填入数组
        for (Boolean value : list) {
          binaryShortArray[currentIndex++] = (short) (value ? 1 : 0);
            // 遍历所有的列表
            for (List<Boolean> list : lists) {
                // 将每个布尔值转换为 0 或 1 并填入数组
                for (Boolean value : list) {
                    binaryShortArray[currentIndex++] = (short) (value ? 1 : 0);
                }
            }

            return binaryShortArray;
        }
      }

      return binaryShortArray;
    }
  }

//读取id
  public StringBuilder queGlassid(String address,int count) {
    StringBuilder writedstrIdOut = new StringBuilder();
    byte[] writedglassidbytesOut = S7control.getinstance().ReadByte(address, count);
    if (writedglassidbytesOut != null) {
      // 获取玻璃id
      for (byte iditem : writedglassidbytesOut) {
        writedstrIdOut.append((char) iditem);
      }
    //读取id
    public StringBuilder queGlassid(String address, int count) {
        StringBuilder writedstrIdOut = new StringBuilder();
        byte[] writedglassidbytesOut = S7control.getinstance().ReadByte(address, count);
        if (writedglassidbytesOut != null) {
            // 获取玻璃id
            for (byte iditem : writedglassidbytesOut) {
                writedstrIdOut.append((char) iditem);
            }
        }
        return writedstrIdOut;
    }
    return writedstrIdOut;
  }


  @Override
  public void run() {
    while (this != null) {
      try {
        Thread.sleep(1000);
    @Override
    public void run() {
        while (this != null) {
            try {
                Thread.sleep(1000);

      } catch (InterruptedException e) {
        e.printStackTrace();
      }

            } catch (InterruptedException e) {
                e.printStackTrace();
            }


//A01组合中地址表集合
      List<String> addresses = Arrays.asList(config.getProperty("A01.addresses").split(","));
      //System.out.println(addresses);
            List<String> addresses = Arrays.asList(config.getProperty("A01.addresses").split(","));
            //System.out.println(addresses);

      List<Short> arraylist = S7control.getinstance().readWords(addresses);
            List<Short> arraylist = S7control.getinstance().readWords(addresses);

//A02组合中地址表集合
      List<String> addresses2 = Arrays.asList(config.getProperty("A02.addresses").split(","));
      List<Short> arraylist2 = S7control.getinstance().readWords(addresses2);
            List<String> addresses2 = Arrays.asList(config.getProperty("A02.addresses").split(","));
            List<Short> arraylist2 = S7control.getinstance().readWords(addresses2);

      //A01翻转地址
      List<String> addresses3 = Arrays.asList(config.getProperty("A01.flipAddress"));
      List<Short> arraylist3 = S7control.getinstance().readWords(addresses3);
            //A01翻转地址
            List<String> addresses3 = Arrays.asList(config.getProperty("A01.flipAddress"));
            List<Short> arraylist3 = S7control.getinstance().readWords(addresses3);

      //A02翻转地址
      List<String> addresses4 = Arrays.asList(config.getProperty("A02.flipAddress"));
            //A02翻转地址
            List<String> addresses4 = Arrays.asList(config.getProperty("A02.flipAddress"));

      List<Short> arraylist4 = S7control.getinstance().readWords(addresses4);
     //B01组合中地址
      String b01Address = config.getProperty("B01.address");
      List<Short> arraylist5 = S7control.getinstance().ReadWord(b01Address, 2);
      //B02组合地址
      String b02Address = config.getProperty("B02.address");
      List<Short> arraylist6 = S7control.getinstance().ReadWord(b02Address, 2);
            List<Short> arraylist4 = S7control.getinstance().readWords(addresses4);
            //B01组合中地址
            String b01Address = config.getProperty("B01.address");
            List<Short> arraylist5 = S7control.getinstance().ReadWord(b01Address, 2);
            //B02组合地址
            String b02Address = config.getProperty("B02.address");
            List<Short> arraylist6 = S7control.getinstance().ReadWord(b02Address, 2);
//      System.out.println(b02Address);
     // 所有故障按钮地址
      List<String> addresses7 = Arrays.asList(config.getProperty("faultButtonAddresses").split(","));
      List<Boolean> arraylist7 = S7control.getinstance().readBits(addresses7);
            // 所有故障按钮地址
            List<String> addresses7 = Arrays.asList(config.getProperty("faultButtonAddresses").split(","));
            List<Boolean> arraylist7 = S7control.getinstance().readBits(addresses7);

      //A01启动地址
      List<String> A01start = Arrays.asList(config.getProperty("A01start"));
      //A02启动地址
      List<String> A02start = Arrays.asList(config.getProperty("A02start"));
            //A01启动地址
            List<String> A01start = Arrays.asList(config.getProperty("A01start"));
            //A02启动地址
            List<String> A02start = Arrays.asList(config.getProperty("A02start"));
//A01半自动地址
      List<String> A01Bstart = Arrays.asList(config.getProperty("A01Bstart"));
      //A02半自动地址
      List<String> A02Bstart = Arrays.asList(config.getProperty("A02Bstart"));
      //
      List<String> abortresumeTasks = Arrays.asList(config.getProperty("abortresumeTasks"));
      //回零按钮地址
      List<String> waddresses4 = Arrays.asList(config.getProperty("HomedButtonAddresses").split(","));
      // 所有复位按钮地址
      List<String> Reset = Arrays.asList(config.getProperty("resetButtonAddresses").split(","));
            List<String> A01Bstart = Arrays.asList(config.getProperty("A01Bstart"));
            //A02半自动地址
            List<String> A02Bstart = Arrays.asList(config.getProperty("A02Bstart"));
            //
            List<String> abortresumeTasks = Arrays.asList(config.getProperty("abortresumeTasks"));
            //回零按钮地址
            List<String> waddresses4 = Arrays.asList(config.getProperty("HomedButtonAddresses").split(","));
            // 所有复位按钮地址
            List<String> Reset = Arrays.asList(config.getProperty("resetButtonAddresses").split(","));
//      System.out.println(Reset);
      // 所有未回零按钮地址
      List<String> addresses8 = Arrays.asList(config.getProperty("notHomedButtonAddresses").split(","));
      // 进片id地址
      String inputGlassIdAddress = config.getProperty("inputGlassIdAddress");
      String outputGlassIdAddress = config.getProperty("outputGlassIdAddress");
      StringBuilder queueid1 = queGlassid(inputGlassIdAddress, 14);
      // 存片id地址
      StringBuilder queueid2 = queGlassid(outputGlassIdAddress, 14);
            // 所有未回零按钮地址
            List<String> addresses8 = Arrays.asList(config.getProperty("notHomedButtonAddresses").split(","));
            // 进片id地址
            String inputGlassIdAddress = config.getProperty("inputGlassIdAddress");
            String outputGlassIdAddress = config.getProperty("outputGlassIdAddress");
            StringBuilder queueid1 = queGlassid(inputGlassIdAddress, 14);
            // 存片id地址
            StringBuilder queueid2 = queGlassid(outputGlassIdAddress, 14);
//A01 A02启动   半自动启动
      List<Boolean> A01readstart = S7control.getinstance().readBits(A01start);
      List<Boolean> A02readstart = S7control.getinstance().readBits(A02start);
      List<Boolean> A01readBstart = S7control.getinstance().readBits(A01Bstart);
      List<Boolean> A02readsBtart = S7control.getinstance().readBits(A02Bstart);
            List<Boolean> A01readstart = S7control.getinstance().readBits(A01start);
            List<Boolean> A02readstart = S7control.getinstance().readBits(A02start);
            List<Boolean> A01readBstart = S7control.getinstance().readBits(A01Bstart);
            List<Boolean> A02readsBtart = S7control.getinstance().readBits(A02Bstart);

      List<Boolean> resumeTasks = S7control.getinstance().readBits(abortresumeTasks);
            List<Boolean> resumeTasks = S7control.getinstance().readBits(abortresumeTasks);

      short[] combinedBinaryShortArray = PLCBooleanConverter.convertListsToBinaryShortArray(
              A01readBstart, A01readstart,   A02readsBtart,A02readstart
      );
            short[] combinedBinaryShortArray = PLCBooleanConverter.convertListsToBinaryShortArray(
                    A01readBstart, A01readstart, A02readsBtart, A02readstart
            );

//      System.out.println(A01readBstart);

// 所有故障按钮转换为1和0
      short[] params2 = new short[arraylist7.size()];
      for (int i = 0; i < arraylist7.size(); i++) {
        boolean value = arraylist7.get(i);
        params2[i] = value ? (short) 1 : (short) 0;
      }
            short[] params2 = new short[arraylist7.size()];
            for (int i = 0; i < arraylist7.size(); i++) {
                boolean value = arraylist7.get(i);
                params2[i] = value ? (short) 1 : (short) 0;
            }

//急停中止按钮
      short[] resumeTask = new short[resumeTasks.size()];
      for (int i = 0; i < resumeTasks.size(); i++) {
        boolean value = resumeTasks.get(i);
        resumeTask[i] = value ? (short) 1 : (short) 0;
      }
            short[] resumeTask = new short[resumeTasks.size()];
            for (int i = 0; i < resumeTasks.size(); i++) {
                boolean value = resumeTasks.get(i);
                resumeTask[i] = value ? (short) 1 : (short) 0;
            }

      List<Boolean> Reset1 = S7control.getinstance().readBits(Reset);
    //  System.out.println(Reset1);
            List<Boolean> Reset1 = S7control.getinstance().readBits(Reset);
            //  System.out.println(Reset1);
// 所有故障按钮转换为1和0
      short[] rReset = new short[Reset1.size()];
      for (int i = 0; i < Reset1.size(); i++) {
        boolean value = Reset1.get(i);
        rReset[i] = value ? (short) 1 : (short) 0;
      }
            short[] rReset = new short[Reset1.size()];
            for (int i = 0; i < Reset1.size(); i++) {
                boolean value = Reset1.get(i);
                rReset[i] = value ? (short) 1 : (short) 0;
            }


//所有未回零按钮转换为1和0
      List<Boolean> arraylist8 = S7control.getinstance().readBits(addresses8);
      short[] params = new short[arraylist8.size()];
      for (int i = 0; i < arraylist8.size(); i++) {
        boolean value = arraylist8.get(i);
        params[i] = value ? (short) 1 : (short) 0;
      }



            List<Boolean> arraylist8 = S7control.getinstance().readBits(addresses8);
            short[] params = new short[arraylist8.size()];
            for (int i = 0; i < arraylist8.size(); i++) {
                boolean value = arraylist8.get(i);
                params[i] = value ? (short) 1 : (short) 0;
            }


//      Short[] values1 = { 1, 2, 3, 4, 5, 6, 7};
@@ -214,22 +210,21 @@
//        params[i] = value ? (short) 1 : (short) 0;
//      }

      JSONObject jsonObject = new JSONObject();
            JSONObject jsonObject = new JSONObject();

      jsonObject.append("zuhe1", arraylist);
      jsonObject.append("zuhe2", arraylist2);
      jsonObject.append("zuhe3", arraylist3);
      jsonObject.append("zuhe4", arraylist4);
      jsonObject.append("zuhe5", arraylist5);
      jsonObject.append("zuhe6", arraylist6);
      jsonObject.append("guzhang", params2);
   jsonObject.append("weihuiling", params);
      jsonObject.append("jinpianid", queueid1);
      jsonObject.append("qupianid", queueid2);
      jsonObject.append("fuwei", rReset);
      jsonObject.append("qidong", combinedBinaryShortArray);
      jsonObject.append("resumeTasks", resumeTask);

            jsonObject.append("zuhe1", arraylist);
            jsonObject.append("zuhe2", arraylist2);
            jsonObject.append("zuhe3", arraylist3);
            jsonObject.append("zuhe4", arraylist4);
            jsonObject.append("zuhe5", arraylist5);
            jsonObject.append("zuhe6", arraylist6);
            jsonObject.append("guzhang", params2);
            jsonObject.append("weihuiling", params);
            jsonObject.append("jinpianid", queueid1);
            jsonObject.append("qupianid", queueid2);
            jsonObject.append("fuwei", rReset);
            jsonObject.append("qidong", combinedBinaryShortArray);
            jsonObject.append("resumeTasks", resumeTask);


//      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ServoManualone");
@@ -237,63 +232,59 @@
//        sendwServer.sendMessage(jsonObject.toString());
//      }

      ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("ServoManualone");
      if (sendwServer != null) {
        for (WebSocketServer webserver : sendwServer) {
          webserver.sendMessage(jsonObject.toString());
            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("ServoManualone");
            if (sendwServer != null) {
                for (WebSocketServer webserver : sendwServer) {
                    webserver.sendMessage(jsonObject.toString());


          if (webserver != null) {
            List<String> messages = webserver.getMessages();
                    if (webserver != null) {
                        List<String> messages = webserver.getMessages();


            if (!messages.isEmpty()) {
              // 将最后一个消息转换为 short 类型的列表
              String lastMessage = messages.get(messages.size() - 1);
                        if (!messages.isEmpty()) {
                            // 将最后一个消息转换为 short 类型的列表
                            String lastMessage = messages.get(messages.size() - 1);
//        System.out.println("lastMessage：" + lastMessage);
              JSONArray messageArray = new JSONArray(lastMessage);
                            JSONArray messageArray = new JSONArray(lastMessage);


              // 写入AO1组合
              customS7Control.WriteWordToPLC(messageArray, addresses,0);

              //A01半自动启动
              customS7Control.writeBitToPLC( messageArray, A01start,8);
                            // 写入AO1组合
                            customS7Control.WriteWordToPLC(messageArray, addresses, 0);


              // 写入AO2组合
              customS7Control.WriteWordToPLC(messageArray, addresses2,1);
              //A02半自动启动
                            // 写入AO2组合
                            customS7Control.WriteWordToPLC(messageArray, addresses2, 1);

              customS7Control.writeBitToPLC( messageArray, A02start,9);

                            // 复位按钮写入
                            customS7Control.writeBitToPLC(messageArray, Reset, 2);

                            //回零按钮写入
                            customS7Control.writeBitToPLC(messageArray, waddresses4, 3);

                            // 进片ID写入
                            customS7Control.writeStringToPLC(messageArray, inputGlassIdAddress, 4);
                            //取片ID写入
                            customS7Control.writeStringToPLC(messageArray, outputGlassIdAddress, 5);

                            //A01半自动
                            customS7Control.writeBitToPLC(messageArray, A01Bstart, 6);
                            //A02半自动
                            customS7Control.writeBitToPLC(messageArray, A02Bstart, 7);
                          //A01半自动启动
                          customS7Control.writeBitToPLC(messageArray, A01start, 8);
                          //A02半自动启动
                          customS7Control.writeBitToPLC(messageArray, A02start, 9);



              // 复位按钮写入
              customS7Control.writeBitToPLC( messageArray, Reset,2);

              //回零按钮写入
              customS7Control.writeBitToPLC( messageArray, waddresses4,3);

              // 进片ID写入
              customS7Control.writeStringToPLC(  messageArray,inputGlassIdAddress,4);
              //取片ID写入
              customS7Control.writeStringToPLC(  messageArray,outputGlassIdAddress,5);

              //A01半自动
              customS7Control.writeBitToPLC( messageArray, A01Bstart,6);

            //A02半自动
              customS7Control.writeBitToPLC( messageArray, A02Bstart,7);



              // 清空消息列表
              webserver.clearMessages();
                          // 清空消息列表
                            webserver.clearMessages();
                        }
                    }
                }
            }
          }
        }
      }
    }
  }
}

 springboot-vue3/src/main/java/com/example/springboot/component/Plcalarm.java

@@ -106,7 +106,9 @@
          for (WebSocketServer webserver : sendwServer) {
            webserver.sendMessage(jsonObject.toString());

          }

        }
            // 将获取的布尔类型转换为整数类型
            List<Integer> Intlist = new ArrayList<>();
            for (Boolean value : plclist) {
@@ -128,7 +130,7 @@
              // 查询对应报警信息结束时间为null的条数
              short result = alarmMapper.selectnullti(array1[i]);
              // 读取到PLC的值为1并且对应报警信息结束时间为null的条数的条数为0
              // System.out.println(result);
    //System.out.println(result);
              if (shuzu1[i] == 1 && result == 0) {
                // 填加一条报警信息,有开始时间
                alarmMapper.Insertalarm(array1[i]);
@@ -141,5 +143,4 @@
        }
      }
    }
  }
}


 springboot-vue3/src/main/resources/config.properties

@@ -53,7 +53,6 @@






#PLCManualJog--------------------------







@@ -62,19 +61,15 @@
#id

Parameter2.id=DB103.44,DB103.58,DB103.72,DB103.86,DB103.100,DB103.114,DB103.128,DB103.142,DB103.156,DB103.184,DB103.212



#清除id

#state

Parameter2.state=DB103.0,DB103.2,DB103.12,DB103.14,DB103.16,DB103.18,DB103.8,DB103.10,DB103.4,DB103.6







#手动状态

#清除id

Parameter2.cleanid=DB101.9.2,DB101.9.3,DB101.9.4,DB101.9.5,DB101.9.6,DB101.9.7,DB101.10.0,DB101.10.1,DB101.10.2,DB101.10.3

#扫码枪

Parameter2.scanner=DB103.256,DB103.270



#急停

Parameter2.stop=DB101.10.4



#当前格子

Parameter2.Currentcell=DB103.32,DB103.34,DB103.36,DB103.40