diff --git a/web/src/main/java/com/zhehekeji/web/config/ConfigProperties.java b/web/src/main/java/com/zhehekeji/web/config/ConfigProperties.java index 9042e8e..c2ecca6 100644 --- a/web/src/main/java/com/zhehekeji/web/config/ConfigProperties.java +++ b/web/src/main/java/com/zhehekeji/web/config/ConfigProperties.java @@ -92,8 +92,8 @@ public class ConfigProperties { public static class KSEC{ private String ip; private Integer port; -// private Integer reconnectNum = 10; -// private long reconnectInterval = 10000; + private Integer reconnectNum = 10; + private long reconnectInterval = 10000; } @Data diff --git a/web/src/main/java/com/zhehekeji/web/mapper/OrderMapper.java b/web/src/main/java/com/zhehekeji/web/mapper/OrderMapper.java index 22f6cc8..1dfe1c5 100644 --- a/web/src/main/java/com/zhehekeji/web/mapper/OrderMapper.java +++ b/web/src/main/java/com/zhehekeji/web/mapper/OrderMapper.java @@ -11,7 +11,7 @@ import java.util.List; public interface OrderMapper extends BaseMapper { - @Select("select * from `order` where order_num = #{orderNum} limit 1") + @Select("select * from `order` where order_num = #{orderNum} order by start_time desc limit 1") Order getOneByOrderNum(String orderNum); List list(@Param("req")OrderSearch orderSearch); diff --git a/web/src/main/java/com/zhehekeji/web/service/ksec/KsecNettyClient.java b/web/src/main/java/com/zhehekeji/web/service/ksec/KsecNettyClient.java index 9d4ceeb..66b0f4f 100644 --- a/web/src/main/java/com/zhehekeji/web/service/ksec/KsecNettyClient.java +++ b/web/src/main/java/com/zhehekeji/web/service/ksec/KsecNettyClient.java @@ -66,7 +66,13 @@ public class KsecNettyClient { } catch (InterruptedException e) { e.printStackTrace(); } - while (num < RECONNECT_NUM && !isConnected) { + while (ksec.getReconnectNum() == -1 || num < ksec.getReconnectNum() && !isConnected) { + + try { + Thread.sleep(ksec.getReconnectInterval()); + } catch (InterruptedException e) { + e.printStackTrace(); + } try { createClient(ksec); } catch (Exception e) { diff --git a/web/src/main/java/com/zhehekeji/web/service/putian/PuTianNettyClient.java b/web/src/main/java/com/zhehekeji/web/service/putian/PuTianNettyClient.java index ca0a4e3..bf9ff5c 100644 --- a/web/src/main/java/com/zhehekeji/web/service/putian/PuTianNettyClient.java +++ b/web/src/main/java/com/zhehekeji/web/service/putian/PuTianNettyClient.java @@ -32,10 +32,6 @@ public class PuTianNettyClient { @Resource private EmptyCheckService emptyCheckService; - /** - * 重连最大次数 - */ - private static int RECONNECT_NUM = 10; private static Channel channel; @@ -71,8 +67,13 @@ public class PuTianNettyClient { } catch (InterruptedException e) { e.printStackTrace(); } -// while (ksec.getReconnectNum() == -1 || num < ksec.getReconnectNum() && !isConnected) { - while (num < RECONNECT_NUM && !isConnected) { + while (ksec.getReconnectNum() == -1 || num < ksec.getReconnectNum() && !isConnected) { + //while (num < RECONNECT_NUM && !isConnected) { + try { + Thread.sleep(ksec.getReconnectInterval()); + } catch (InterruptedException e) { + e.printStackTrace(); + } try { createClient(ksec); } catch (Exception e) {