tcp也延时发送

modules/common/pom.xml

@@ -51,6 +51,7 @@
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
+            <version>1.18.30</version>
             <optional>true</optional>
         </dependency>
 

modules/filter/pom.xml

@@ -49,6 +49,7 @@
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
+            <version>1.18.30</version>
             <optional>true</optional>
         </dependency>
 

modules/pom.xml

@@ -37,6 +37,7 @@
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
+            <version>1.18.30</version>
             <optional>true</optional>
         </dependency>
     </dependencies>

pom.xml

@@ -34,6 +34,7 @@
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
+            <version>1.18.30</version>
             <optional>true</optional>
         </dependency>
         <dependency>

web/pom.xml

@@ -76,6 +76,7 @@
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
+            <version>1.18.30</version>
             <optional>true</optional>
         </dependency>
         <dependency>

web/src/main/java/com/zhehekeji/web/pojo/IndustrialCameraVO.java

@@ -25,7 +25,7 @@ public class IndustrialCameraVO implements Delayed {
 
     private long executeTime;
     public IndustrialCameraVO(){
-        this.executeTime = System.currentTimeMillis() + 2000;
+        this.executeTime = System.currentTimeMillis() + 3000;
     }
     /**
      * 获取延迟时间

web/src/main/java/com/zhehekeji/web/service/KuKouService.java

@@ -13,6 +13,7 @@ import com.zhehekeji.web.entity.KuKou;
 import com.zhehekeji.web.mapper.KukouMapper;
 import com.zhehekeji.web.pojo.IndustrialCameraVO;
 import com.zhehekeji.web.pojo.OrderSearch;
+import com.zhehekeji.web.service.ksec.CommandQueue;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.core.ParameterizedTypeReference;
 import org.springframework.http.HttpEntity;
@@ -29,7 +30,6 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
-import static com.zhehekeji.web.service.ksec.CommandQueue.addCommand;
 
 @Service
 @Slf4j
@@ -55,7 +55,7 @@ public class KuKouService   extends ServiceImpl<KukouMapper,KuKou> implements IS
     private ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(10); // 初始化一个包含2个线程的调度池; // 可以通过配置注入或使用 @Async 的 scheduler
 
     public void setHttp(IndustrialCameraVO scTransmission, Boolean flag) {
-        addCommand(scTransmission);
+        CommandQueue.addCommand(scTransmission);
     }
 
     private void sendWithRetry(IndustrialCameraVO scTransmission, Boolean flag, int retryCount) {

web/src/main/java/com/zhehekeji/web/service/ksec/CommandQueue.java

@@ -21,11 +21,14 @@ import java.time.LocalDateTime;
 import java.util.concurrent.*;
 
 import static com.zhehekeji.web.service.KuKouService.setTrayCode;
+import static java.lang.Thread.sleep;
 
 @Slf4j
 public class CommandQueue {
-//    增加queue
+//    增加queue,固定延时3s
     public static void addCommand(IndustrialCameraVO scTransmission) {
+
+        scTransmission.setExecuteTime(System.currentTimeMillis() + 3000);
         delayQueue.add(scTransmission);
     }
     private static ExecutorService exec = Executors.newFixedThreadPool(1);
@@ -37,6 +40,26 @@ public class CommandQueue {
         exec.execute(new Consumer(restTemplate,  configProperties));
     }
 
+    public static void main(String[] args) {
+        ConfigProperties configProperties = new ConfigProperties();
+        configProperties.setKsec(new ConfigProperties.KSEC());
+        configProperties.getKsec().setReportHttp("http://127.0.0.1:8000");
+        sentHttp(new RestTemplate(),new ConfigProperties());
+        System.out.println(System.currentTimeMillis());
+        IndustrialCameraVO industrialCameraVO = new IndustrialCameraVO();
+        industrialCameraVO.setTrayCode("1321351351651351");
+        IndustrialCameraVO industrialCameraVO2 = new IndustrialCameraVO();
+        industrialCameraVO.setTrayCode("1321351351651351");
+        delayQueue.add(industrialCameraVO);
+        delayQueue.add(industrialCameraVO2);
+        try {
+            sleep(10000);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+
+    }
+
     private static class Consumer implements Runnable {
         RestTemplate restTemplate ;
         ConfigProperties configProperties;
@@ -54,6 +77,7 @@ public class CommandQueue {
                     IndustrialCameraVO scTransmission = delayQueue.take();
                     if(scTransmission != null){
 
+                        System.out.println(System.currentTimeMillis());
                         try {
                             HttpHeaders headers = new HttpHeaders();
                             headers.set("Content-Type", "application/json");

web/src/main/java/com/zhehekeji/web/service/ksec/KsecDecoder.java

@@ -213,6 +213,11 @@ public class KsecDecoder extends DelimiterBasedFrameDecoder {
                     }else {
                         ksecInfo.getData().setAckStatus(0);
                     }
+                    try {
+                        Thread.sleep(2000);
+                    } catch (InterruptedException e) {
+                        log.error("sleep error",e);
+                    }
                     ctx.channel().writeAndFlush(ksecInfo);
                     log.info("盘点结束："+ksecInfo.getData().toString());
 
@@ -221,6 +226,11 @@ public class KsecDecoder extends DelimiterBasedFrameDecoder {
 
                     ksecInfo.getData().setCmdName("SC02");
                     ksecInfo.getData().setCheckRlt(flag?1:0);
+                    try {
+                        Thread.sleep(2000);
+                    } catch (InterruptedException e) {
+                        log.error("sleep error",e);
+                    }
                     ctx.channel().writeAndFlush(ksecInfo);
                 }
                 //找到该货位的最后一张照片与现在的照片比照