Merge remote-tracking branch 'origin/master'

zhoushihao

2024-05-24 d1ac4de7a592863f653433bef1707f121441a1ac

Merge remote-tracking branch 'origin/master'

 UI-Project/src/views/Returns/returns.vue

@@ -26,7 +26,7 @@
    //  number.value = '';
import request from "@/utils/request"
const ida = ref(null); 
import { ref, onMounted } from "vue";
import { ref, onMounted, onUnmounted } from "vue";
// import http from "@/http/index";
 
let ruleForm = ref({
@@ -69,25 +69,79 @@
    // ElMessage.error('获取表格数据失败，请重试');
  }
};
   request.get("/loadGlass/LoadGlass/list").then((res) => {
onMounted(async () => {  
  await fetchTableData();  
  
  // 设置定时器来定期刷新数据  
  const intervalId = setInterval(async () => {  
    await fetchTableData();  
  }, 1000); // 每1秒刷新一次  
  
  // 组件卸载时清除定时器  
  onUnmounted(() => {  
    clearInterval(intervalId);  
  });  
}); 
onMounted(async () => {  
  await fetchTableDataa();  
  
  // 设置定时器来定期刷新数据  
  const intervalId = setInterval(async () => {  
    await fetchTableDataa();  
  }, 1000); // 每1秒刷新一次  
  
  // 组件卸载时清除定时器  
  onUnmounted(() => {  
    clearInterval(intervalId);  
  });  
}); 
  //  request.get("/loadGlass/LoadGlass/list").then((res) => {
  //   if (res.code === 200) {
  //    console.log(res.data);
  //    tableDataa.value = res.data;
   
  //   if (tableDataa.value.length === 2) {
  //    if (tableDataa.value[0].patternWidth > 0) {
  //     flake.value = true;
  //    }
 
  //   if (tableDataa.value[1].patternWidth > 0) {
  //   flakea.value = true;
  //   }
  //   }
  //   } else {
  //   ElMessage.warning(res.msg);
  //   // router.push("/login");
  //   }
  //  });
   async function fetchTableDataa() {  
  try {  
    const res = await request.get("/loadGlass/LoadGlass/list");  
    if (res.code === 200) {
     console.log(res.data);
     tableDataa.value = res.data;
   
    if (tableDataa.value.length === 2) {
     if (tableDataa.value[0].patternWidth > 0) {
      // 根据数据更新 flake 和 flakea 的值  
      if (res.data.length >= 2) {  
        if (res.data[0].patternWidth > 0) {  
      flake.value = true;
        } else {  
          flake.value = false;  
     }
 
    if (tableDataa.value[1].patternWidth > 0) {
        if (res.data[1].patternWidth > 0) {  
    flakea.value = true;
        } else {  
          flakea.value = false;  
    }
    }
    } else {
    ElMessage.warning(res.msg);
    // router.push("/login");
    }
   });
  } catch (error) {  
    console.error('获取表格数据失败', error);  
    // 可以在这里添加额外的错误处理逻辑  
  }  
}  
// request.get("/loadGlass/LoadGlass/list").then((res) => {
//       window.localStorage.setItem('patternWidth', res.data.patternWidth)
//       window.localStorage.setItem('workstationId', res.data.workstationId)
@@ -468,6 +522,7 @@
  }
}
onMounted(fetchTableData);
onMounted(fetchTableDataa);
function getStatusText(state: number) {
  switch (state) {
    case 0:  

 hangzhoumesParent/common/servicebase/src/main/java/com/mes/device/PlcParameterObject.java

@@ -1,5 +1,8 @@
package com.mes.device;

import com.github.xingshuangs.iot.utils.IntegerUtil;
import com.github.xingshuangs.iot.utils.ShortUtil;

import java.lang.reflect.Array;
import java.nio.charset.StandardCharsets;
import java.util.*;
@@ -156,15 +159,14 @@
                    Array.setByte(valueList, i, plcValueArray[plcParameterInfo.getAddressIndex() + i]);
                }
                if (plcParameterInfo.getAddressLength() == 2) {
                    plcParameterInfo.setValue(String.valueOf(byte2short(valueList)));
                    plcParameterInfo.setValue(String.valueOf(ShortUtil.toUInt16(valueList)));
                } else if (plcParameterInfo.getAddressLength() == 4) {
                    plcParameterInfo.setValue(String.valueOf(byte2int(valueList)));
                    plcParameterInfo.setValue(String.valueOf(IntegerUtil.toUInt32(valueList)));
                }
                else if (plcParameterInfo.getAddressLength() >10) {
                    plcParameterInfo.setValue((byteToHexString(valueList)));
                } else {
                    String valuestr = new String(valueList);
                    plcParameterInfo.setValue(valuestr);
                    plcParameterInfo.setValue((byteToHexString(valueList)));
                }
            }
        }
@@ -194,6 +196,25 @@
            }
        }*/
    }
    /**
     * 把写入值转化为byte[]
     * @param param 参数实例
     * @param data 写入值的字符类型
     */
    public byte[] setValueToBytes(PlcParameterInfo param, String data) {
        if (param.getAddressLength() == 2) {
            return ShortUtil.toByteArray(Integer.parseInt(data));

        } else if (param.getAddressLength() == 4) {

            return IntegerUtil.toByteArray(Long.parseLong(data));
        }
        else if (param.getAddressLength() >10) {
           return data.getBytes();
        } else {
            return data.getBytes();
        }
    }

    /**
     * short类型转byte[]
@@ -203,7 +224,7 @@
    public static byte[] short2byte(short s) {
        byte[] b = new byte[2];
        for (int i = 0; i < 2; i++) {
            int offset = 16 - (i + 1) * 8; //因为byte占4个字节，所以要计算偏移量
            int offset = 16 - (i + 1) * 8; //计算偏移量
            b[i] = (byte) ((s >> offset) & 0xff); //把16位分为2个8位进行分别存储
        }
        return b;
@@ -228,14 +249,22 @@
     *
     * @param b byte[]类型值
     */
    public static short byte2int(byte[] b) {
        short l = 0;
    public static int byte2int(byte[] b) {
        int l = 0;
        for (int i = 0; i < 4; i++) {
            l <<= 8; //<<=和我们的 +=是一样的，意思就是 l = l << 8
            l |= (b[3-i] & 0xff); //和上面也是一样的  l = l | (b[i]&0xff)
        }
        return l;
    }
    public static byte[] int2byte(int s){
        byte[] b = new byte[2];
        for(int i = 0; i < 4; i++){
            int offset = 16 - (i+1)*8; //因为byte占4个字节，所以要计算偏移量
            b[i] = (byte)((s >> offset)&0xff); //把32位分为4个8位进行分别存储
        }
        return b;
    }
    public static String byteToHexString(byte[] bytes) {
        String str = new String(bytes, StandardCharsets.UTF_8).trim();
        return str;

 hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/S7control.java

@@ -3,9 +3,6 @@
import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
import com.github.xingshuangs.iot.protocol.s7.service.MultiAddressWrite;
import com.github.xingshuangs.iot.protocol.s7.service.S7PLC;
import com.google.common.primitives.Bytes;

import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;

@@ -22,17 +19,25 @@
    /**
     * 关闭西门子s7通讯连接
     */
    public void CloseS7client() {
        if (s7PLC == null) {
    public void closeS7client() {
        if (s7PLC != null) {
            s7PLC.close();
        }
        s7PLC.checkConnected();
    }
    /**
     * 重启西门子s7通讯连接
     */
    public void reStartS7client() {
        if (s7PLC != null) {
            s7PLC.hotRestart();
        }
    }


    /**
     * s7通讯连接状态
     */
    public boolean CheckConnected() {
    public boolean checkConnected() {
        return s7PLC.checkConnected();
    }

@@ -42,11 +47,14 @@
     * @param address 地址
     * @param data    word的值
     */
    public void WriteWord(String address, short data) {
    public void writeWord(String address, int data) {
        if (s7PLC == null) {
            return;
        }
        s7PLC.writeInt16(address, data);
        else if(!s7PLC.checkConnected()) {
            s7PLC.hotRestart();
        }
        s7PLC.writeUInt16(address, data);
    }

    /**
@@ -55,15 +63,18 @@
     * @param address 地址
     * @param datas   word的值
     */
    public void WriteWord(String address, List<Short> datas) {
    public void writeWord(String address, List<Integer> datas) {
        if (s7PLC == null) {
            return;
        }
        else if(!s7PLC.checkConnected()) {
            s7PLC.hotRestart();
        }
        // s7PLC.write(address, data);
        List<String> addresslist = GetAddressList(address, datas.size(), 16);
        List<String> addresslist = getAddressList(address, datas.size(), 16);
        MultiAddressWrite addressWrite = new MultiAddressWrite();
        for (int i = 0; i < datas.size(); i++) {
            addressWrite.addInt16(addresslist.get(i), datas.get(i));
            addressWrite.addUInt16(addresslist.get(i), datas.get(i));
        }
        s7PLC.writeMultiData(addressWrite);
    }
@@ -82,9 +93,12 @@
     * @param address 地址
     * @param data    Bit的值
     */
    public void WriteBit(String address, Boolean data) {
    public void writeBit(String address, Boolean data) {
        if (s7PLC == null) {
            return;
        }
        else if(!s7PLC.checkConnected()) {
            s7PLC.hotRestart();
        }
        s7PLC.writeBoolean(address, data);
    }
@@ -95,9 +109,12 @@
     * @param address 地址
     * @param datas   bit的值
     */
    public void WriteBit(List<String> address, List<Boolean> datas) {
    public void writeBit(List<String> address, List<Boolean> datas) {
        if (s7PLC == null) {
            return;
        }
        else if(!s7PLC.checkConnected()) {
            s7PLC.hotRestart();
        }
        // s7PLC.write(address, data);

@@ -114,12 +131,15 @@
     * @param address 地址
     * @param datas   word的值
     */
    public void WriteBit(String address, List<Boolean> datas) {
    public void writeBit(String address, List<Boolean> datas) {
        if (s7PLC == null) {
            return;
        }
        else if(!s7PLC.checkConnected()) {
            s7PLC.hotRestart();
        }
        // s7PLC.write(address, data);
        List<String> addresslist = GetAddressList(address, datas.size(), 1);
        List<String> addresslist = getAddressList(address, datas.size(), 1);
        MultiAddressWrite addressWrite = new MultiAddressWrite();
        for (int i = 0; i < datas.size(); i++) {
            addressWrite.addBoolean(addresslist.get(i), datas.get(i));
@@ -133,9 +153,12 @@
     * @param address 地址
     * @param datas   byte的值
     */
    public void WriteByte(String address, byte[] datas) {
    public void writeByte(String address, byte[] datas) {
        if (s7PLC == null) {
            return;
        }
        else if(!s7PLC.checkConnected()) {
            s7PLC.hotRestart();
        }
        // s7PLC.write(address, data); 
        s7PLC.writeByte(address, datas);
@@ -147,31 +170,21 @@
     * @param address 地址
     * @return 结果
     */
    public List<Short> ReadWord(List<String> address) {
    public List<Integer> readWord(List<String> address) {
        if (s7PLC == null) {
            return null;
        }

        try {
            return s7PLC.readInt16(address);
            return s7PLC.readUInt16(address);
        } catch (Exception e) {
            s7PLC.hotRestart();
            System.out.println("读取 " + address + " 失败：" + e.getMessage());
            return null;
        }
    }


    private int getIndexFromAddress(String address) {

        // 可以解析出地址中的数字部分，并转换为整数
        return 0;
    }

    private String getAddressFromIndex(int index) {

        // 整数转换为地址格式的字符串
        return "";
    }

    /**
     * 按指定的地址 读取word结果集
@@ -180,15 +193,16 @@
     * @param count   连续读多少个word
     * @return 结果
     */
    public List<Short> ReadWord(String address, int count) {
    public List<Integer> readWord(String address, int count) {
        if (s7PLC == null) {
            return null;
        }

        List<String> addresslist = GetAddressList(address, count, 16);
        List<String> addresslist = getAddressList(address, count, 16);
        try {
            return s7PLC.readInt16(addresslist);
            return s7PLC.readUInt16(addresslist);
        } catch (Exception e) {
            s7PLC.hotRestart();
            System.out.println("读取 " + address + " 失败：" + e.getMessage());

            return null;
@@ -202,7 +216,7 @@
     * @param count   连续读多少个byte
     * @return 结果
     */
    public byte[] ReadByte(String address, int count) {
    public byte[] readByte(String address, int count) {
        if (s7PLC == null) {
            return null;
        }
@@ -212,6 +226,7 @@
            return s7PLC.readByte(address, count);
        } catch (Exception e) {
            // 处理异常
            s7PLC.hotRestart();
            System.out.println("读取 " + address + " 失败：" + e.getMessage());
            return null;
        }
@@ -224,14 +239,21 @@
     * @param addresslist 地址集
     * @return Boolean结果
     */
    public List<Boolean> ReadBits(List<String> addresslist) {
    public List<Boolean> readBits(List<String> addresslist) {
        if (s7PLC == null) {
            return null;
        }
        try {
        return s7PLC.readBoolean(addresslist);
        } catch (Exception e) {
            // 处理异常
            s7PLC.hotRestart();
            return null;
    }

    //读取不连续地址bit
    }

   /* //读取不连续地址bit
    public List<Boolean> readBits(List<String> addressList) {
        if (s7PLC == null || addressList.isEmpty()) {
            return null;
@@ -249,30 +271,10 @@
        }

        return values;
    }
    }*/


    //读取StringList
    public List<String> readStrings(List<String> addressList) {
        if (s7PLC == null) {
            return null;
        }
        List<String> result = new ArrayList<>();
        for (String address : addressList) {
            try {
                byte[] bytes = s7PLC.readByte(address, 14);
                if (bytes != null) {
                    String str = new String(bytes, StandardCharsets.UTF_8);
                    result.add(str);
                }
            } catch (Exception e) {
                System.out.println("读取 " + address + " 失败：" + e.getMessage());
                result.add(null);
            }
        }

        return result;
    }

    //读取字符串
    public String readString(String address) {
@@ -282,81 +284,13 @@
        try {
            return s7PLC.readString(address);
        } catch (Exception e) {
            s7PLC.hotRestart();
            System.out.println("读取 " + address + " 失败：" + e.getMessage());
            return null;
        }
    }


    //不连续地址写入Word
    public void WriteWord(List<String> address, List<Short> datas) {
        if (s7PLC == null) {
            return;
        }

        for (int i = 0; i < address.size(); i++) {
            String addr = address.get(i);
            short data = datas.get(i);

            if (addr.contains("-")) {
                outmesid(String.valueOf(data), addr); // 单独处理带破折号的地址
            } else {
                s7PLC.writeInt16(addr, data); // 将数据写入单个地址
            }
        }
    }


    //字符串写入
    public void outmesid(String data, String addr) {
//        System.out.println("outmesid: " + data);
        List<Byte> glassidlist = new ArrayList<>();
        String[] parts = addr.split("-");
        if (parts.length == 2) {
            addr = parts[0]; // 只保留 "-" 前面的部分
        }
        for (char iditem : data.toCharArray()) {
            glassidlist.add(Byte.valueOf(String.valueOf(iditem)));
        }
        byte[] bytes = Bytes.toArray(glassidlist);
        WriteByte(addr, bytes);
    }

    //读取不连续word
    public List<Short> readWords(List<String> addresses) {
        if (s7PLC == null) {
            return null;
        }
        List<Short> data = new ArrayList<>();

        for (String address : addresses) {
            try {
                // 单个地址
                Short value = s7PLC.readInt16(address);
                data.add(value);
            } catch (Exception e) {
                System.out.println("读取 " + address + " 失败：" + e.getMessage());

            }

        }
        return data;
    }

    //读取单个word
    public Short readWord(String address) {
        if (s7PLC == null) {
            return null;
        }
        try {
            // 单个地址
            return s7PLC.readInt16(address);
        } catch (Exception e) {
            System.out.println("读取 " + address + " 失败：" + e.getMessage());

        }
        return -1;
    }

    //读取时间
    public Long readtime(String address) {
@@ -366,6 +300,7 @@
        try {
            return s7PLC.readTime(address);
        } catch (Exception e) {
            s7PLC.hotRestart();
            System.out.println("读取 " + address + " 失败：" + e.getMessage());
            return null;
        }
@@ -373,17 +308,16 @@


    public void writetime(String address, long datas) {
        if (s7PLC == null)
        if (s7PLC == null) {
            return;


        s7PLC.writeTime(address, datas); // 将数据写入单个地址
        }
        else if(!s7PLC.checkConnected())
        {
            s7PLC.hotRestart();
    }


    private int extractAddressNumber(String address) {
        String numberStr = address.replaceAll("\\D+", ""); // 使用正则表达式提取数字部分
        return Integer.parseInt(numberStr);
        s7PLC.writeTime(address, datas); // 将数据写入单个地址
    }


@@ -394,13 +328,15 @@
     * @param count   长度
     * @return Boolean结果
     */
    public List<Boolean> ReadBits(String address, int count) {
        if (s7PLC == null)
    public List<Boolean> readBits(String address, int count) {
        if (s7PLC == null) {
            return null;
        List<String> addresslist = GetAddressList(address, count, 1);
        }
        List<String> addresslist = getAddressList(address, count, 1);
        try {
            return s7PLC.readBoolean(addresslist);
        } catch (Exception e) {
            s7PLC.hotRestart();
            System.out.println("读取 " + address + " 失败：" + e.getMessage());
            return null;
        }
@@ -410,7 +346,7 @@
    ;


    private List<String> GetAddressList(String address, int count, int addedbit) {
    private List<String> getAddressList(String address, int count, int addedbit) {
        List<String> addresslist = new ArrayList<String>();

        String[] stringdatas = address.trim().split("\\.");