Merge remote-tracking branch 'origin/tzskwcs_3' into tzskwcs_3

Junjie

2024-06-12 8a8faba0f55512a2c18c4fe719a1bb0c4f6a86c9

Merge remote-tracking branch 'origin/tzskwcs_3' into tzskwcs_3

 src/main/java/com/zy/asrs/mapper/AgvBasDevpMapper.java

@@ -13,5 +13,5 @@
public interface AgvBasDevpMapper extends BaseMapper<AgvBasDevp> {

    @Update("update agv_bas_devp set barcode = #{barcode} where dev_no = #{devNo}")
    public void updateBarcode(@Param("devNo") String devNo, @Param("barcode") String barcode);
    int updateBarcode(@Param("devNo") String devNo, @Param("barcode") String barcode);
}

 src/main/java/com/zy/asrs/service/AgvBasDevpService.java

@@ -8,6 +8,6 @@

public interface AgvBasDevpService extends IService<AgvBasDevp> {

    void updateBarcode(String devNo, String barcode);
    int updateBarcode(String devNo, String barcode);

}

 src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java

@@ -10,7 +10,7 @@
public class AgvBasDevpServiceImpl extends ServiceImpl<AgvBasDevpMapper, AgvBasDevp> implements AgvBasDevpService {

    @Override
    public void updateBarcode(String devNo, String barcode) {
        this.baseMapper.updateBarcode(devNo,barcode);
    public int updateBarcode(String devNo, String barcode) {
        return this.baseMapper.updateBarcode(devNo,barcode);
    }
}

 src/main/java/com/zy/common/utils/NyHttpUtils.java

@@ -315,17 +315,15 @@

        // 读取服务器的响应
        StringBuffer sb = new StringBuffer();
        String response = null;
        char[] chars = new char[2048];//缓冲区
        do {
        while (true) {
            reader.read(chars);
            String trim = new String(chars).trim();
            String trim = new String(chars);
            sb.append(trim);
            if (sb.lastIndexOf("\r\n") != -1) {
            if (trim.lastIndexOf("\r\n") != -1) {
                break;
            }
        } while (response != null);
//            System.out.println("Received response from server: " + sb);
        }

        JSONObject result = JSON.parseObject(sb.toString());//得到响应结果集
        if (!result.get("msgType").equals("responseMsg")) {//不是响应内容

 src/main/java/com/zy/core/thread/BarcodeThread.java

@@ -56,7 +56,10 @@
            String devNo = slave.getId() == 13 ? "310-1" : slave.getId() == 15 ? "312-2" : slave.getId() == 17 ? "314-1" : slave.getId() == 19 ? "316-1" : null;
            if(!Cools.isEmpty(devNo)){
                barcode = barcode.substring(3,barcode.length());
                agvBasDevpService.updateBarcode(devNo,barcode);
                int updateBarcode = agvBasDevpService.updateBarcode(devNo, barcode);
                if (updateBarcode <= 0) {
                    News.info("{}号条码器，检索数据：{}，更新站点条码失败", slave.getId(), this.barcode);
                }
            }
            News.info("{}号条码器，更新成功", slave.getId());
            JSONObject jsonObject = new JSONObject();
@@ -77,7 +80,7 @@
            close();  //1.主动释放连接 //2.某些服务器对指定ip有链路数限制
            socket = new Socket();
            SocketAddress socketAddress = new InetSocketAddress(slave.getIp(), slave.getPort());
            socket.connect(socketAddress, 1000); //某些服务器ping延迟高时要增加,否则会报错connect timeout
            socket.connect(socketAddress, 10000); //某些服务器ping延迟高时要增加,否则会报错connect timeout
            dataOutputStream = new DataOutputStream(socket.getOutputStream());
            dataInputStream = new DataInputStream(socket.getInputStream());
//            log.info("条码扫描仪连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());

 src/main/resources/application.yml

@@ -396,7 +396,7 @@
    id: 11
    ip: 10.10.10.225
    port: 2002
  # 条码扫描仪
  # 条码扫描仪310
  barcode[11]:
    id: 12
    ip: 10.10.10.224
@@ -434,7 +434,7 @@
  # 条码扫描仪
  barcode[18]:
    id: 19
    ip: 10.10.10.171
    ip: 10.10.10.235
    port: 2002
  # 条码扫描仪
  barcode[19]: