From 11d4160682766a6af113f8a8cc2685a6f40a8e3a Mon Sep 17 00:00:00 2001
From: LegnaYet <1023868505@qq.com>
Date: Tue, 19 May 2020 16:36:52 +0800
Subject: [PATCH] =?UTF-8?q?=E9=97=A8=E5=BA=97=E5=8F=B7=E7=AE=A1=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../behavior/BehaviorDTOMessageGroupConsumer.java    |  6 ------
 .../kiisoo/ic/job/behavior/CustomerBehaviorJob.java  |  1 +
 .../ic/job/count/CountDTOMessageGroupConsumer.java   |  6 ------
 .../com/kiisoo/ic/job/count/CustomerCountJob.java    |  1 +
 .../ic/job/detail/DetailDTOMessageGroupConsumer.java |  5 -----
 .../java/com/kiisoo/ic/system/entity/SysTaskDO.java  | 12 ++++++++++++
 6 files changed, 14 insertions(+), 17 deletions(-)

diff --git a/src/main/java/com/kiisoo/ic/job/behavior/BehaviorDTOMessageGroupConsumer.java b/src/main/java/com/kiisoo/ic/job/behavior/BehaviorDTOMessageGroupConsumer.java
index 656ffb0..4c96f38 100644
--- a/src/main/java/com/kiisoo/ic/job/behavior/BehaviorDTOMessageGroupConsumer.java
+++ b/src/main/java/com/kiisoo/ic/job/behavior/BehaviorDTOMessageGroupConsumer.java
@@ -36,8 +36,6 @@ public class BehaviorDTOMessageGroupConsumer implements WorkHandler<BehaviorDTOM
      */
     @Override
     public void onEvent(BehaviorDTOMessage behaviorDtoMessage) throws Exception {
-        long s = System.currentTimeMillis();
-
         behaviorDtoMessage.setId(UUID.randomUUID().toString());
         String cpUserId = behaviorDtoMessage.getCpUserId();
         Date statDate = behaviorDtoMessage.getStatDate();
@@ -125,10 +123,6 @@ public class BehaviorDTOMessageGroupConsumer implements WorkHandler<BehaviorDTOM
         } catch (Exception e) {
             log.error("请求企业微信api获取客户统计数据或日期转换出错！", e);
         }
-
-        System.out.println(Thread.currentThread().getName() + "消费者消费了消息：" + behaviorDtoMessage.getIndex() + "|" + behaviorDtoMessage.getCpUserId());
-        s = s - System.currentTimeMillis();
-        System.out.println(Thread.currentThread().getName() + "结束时间：" + s + " | " + behaviorDtoMessage.getIndex());
     }
 
 
diff --git a/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java b/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java
index d2d59ef..9fc283e 100644
--- a/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java
+++ b/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java
@@ -91,6 +91,7 @@ public class CustomerBehaviorJob {
         if (sysTaskDO !=null){
             sysTaskDO.setStatus(TASK_STATUS_FINISHED);
             sysTaskDOMapper.updateById(sysTaskDO);
+            System.out.println(sysTaskDO);
         }
     }
 }
diff --git a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java b/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java
index fe9ff47..a882130 100644
--- a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java
+++ b/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java
@@ -28,8 +28,6 @@ public class CountDTOMessageGroupConsumer implements WorkHandler<CountDTOMessage
      */
     @Override
     public void onEvent(CountDTOMessage countDtoMessage) throws Exception {
-        long s = System.currentTimeMillis();
-
         countDtoMessage.setId(UUID.randomUUID().toString());
         String cpUserId = countDtoMessage.getCpUserId();
         PrivilageCpUserDOMapper privilageCpUserDOMapper = countDtoMessage.getPrivilageCpUserDOMapper();
@@ -64,9 +62,5 @@ public class CountDTOMessageGroupConsumer implements WorkHandler<CountDTOMessage
                 privilageCpUserDOMapper.insertCpUserCustomerRelation(customerStr,cpUserId,privilageCpUserDO.getId());
             }
         }
-
-        System.out.println(Thread.currentThread().getName() + "消费者消费了消息：" + countDtoMessage.getIndex() + "|" + countDtoMessage.getCpUserId());
-        s = s - System.currentTimeMillis();
-        System.out.println(Thread.currentThread().getName() + "结束时间：" + s + " | " + countDtoMessage.getIndex());
     }
 }
diff --git a/src/main/java/com/kiisoo/ic/job/count/CustomerCountJob.java b/src/main/java/com/kiisoo/ic/job/count/CustomerCountJob.java
index 7f5b7af..a0f1699 100644
--- a/src/main/java/com/kiisoo/ic/job/count/CustomerCountJob.java
+++ b/src/main/java/com/kiisoo/ic/job/count/CustomerCountJob.java
@@ -97,6 +97,7 @@ public class CustomerCountJob {
         if (sysTaskDO!=null){
             sysTaskDO.setStatus(TASK_STATUS_FINISHED);
             sysTaskDOMapper.updateById(sysTaskDO);
+            System.out.println(sysTaskDO);
         }
     }
 }
diff --git a/src/main/java/com/kiisoo/ic/job/detail/DetailDTOMessageGroupConsumer.java b/src/main/java/com/kiisoo/ic/job/detail/DetailDTOMessageGroupConsumer.java
index 20bbe61..ee1f4d8 100644
--- a/src/main/java/com/kiisoo/ic/job/detail/DetailDTOMessageGroupConsumer.java
+++ b/src/main/java/com/kiisoo/ic/job/detail/DetailDTOMessageGroupConsumer.java
@@ -30,8 +30,6 @@ public class DetailDTOMessageGroupConsumer implements WorkHandler<DetailDTOMessa
      */
     @Override
     public void onEvent(DetailDTOMessage detailDtoMessage) throws Exception {
-        long s = System.currentTimeMillis();
-
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         detailDtoMessage.setId(UUID.randomUUID().toString());
         String cpUserId = detailDtoMessage.getCpUserId();
@@ -108,8 +106,5 @@ public class DetailDTOMessageGroupConsumer implements WorkHandler<DetailDTOMessa
 
             customerService.turnBack(turnBackDTO);
         }
-        System.out.println(Thread.currentThread().getName() + "消费者消费了消息：" + detailDtoMessage.getIndex() + "|" + detailDtoMessage.getCpUserId());
-        s = s - System.currentTimeMillis();
-        System.out.println(Thread.currentThread().getName() + "结束时间：" + s + " | " + detailDtoMessage.getIndex());
     }
 }
diff --git a/src/main/java/com/kiisoo/ic/system/entity/SysTaskDO.java b/src/main/java/com/kiisoo/ic/system/entity/SysTaskDO.java
index 711d2eb..a4ba661 100644
--- a/src/main/java/com/kiisoo/ic/system/entity/SysTaskDO.java
+++ b/src/main/java/com/kiisoo/ic/system/entity/SysTaskDO.java
@@ -59,4 +59,16 @@ public class SysTaskDO implements Serializable {
         this.type = type;
         this.createTime = createTime;
     }
+
+    @Override
+    public String toString() {
+        return "SysTaskDO{" +
+                "id=" + id +
+                ", taskName='" + taskName + '\'' +
+                ", status=" + status +
+                ", type=" + type +
+                ", createTime=" + createTime +
+                ", updateTime=" + updateTime +
+                '}';
+    }
 }
\ No newline at end of file