From de19730a1a81d3355b42b6c3b7038c13aa8182f8 Mon Sep 17 00:00:00 2001
From: yechenhao <yechenhao>
Date: Wed, 27 May 2020 18:31:28 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E5=AE=A2=E6=88=B7=E5=AF=BC?=
 =?UTF-8?q?=E8=B4=AD=E5=85=B3=E7=B3=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../kiisoo/ic/job/behavior/BehaviorDTOMessageGroupConsumer.java | 2 --
 .../java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java    | 2 +-
 src/main/java/com/kiisoo/ic/job/count/CustomerCountJob.java     | 2 +-
 3 files changed, 2 insertions(+), 4 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 20426dc..a13a187 100644
--- a/src/main/java/com/kiisoo/ic/job/behavior/BehaviorDTOMessageGroupConsumer.java
+++ b/src/main/java/com/kiisoo/ic/job/behavior/BehaviorDTOMessageGroupConsumer.java
@@ -66,8 +66,6 @@ public class BehaviorDTOMessageGroupConsumer implements WorkHandler<BehaviorDTOM
             WxCusInfoReqDO wxCusInfoReqDO = new WxCusInfoReqDO();
             wxCusInfoReqDO.setAccess_token(wxCpService.getAccessToken());
             wxCusInfoReqDO.setUserid(cpUserId);
-            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
-            //todo 分开写便于同步历史数据 最大跨度30天 最久当天往前180天 上线时改为System.currentTimeMillis()
             wxCusInfoReqDO.setStart_time(statDate.getTime() / 1000);
             wxCusInfoReqDO.setEnd_time(statDate.getTime() / 1000);
             WxCusInfoRespDO wxCusInfoRespDO = getWxCusInfo(wxCusInfoReqDO);
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 4a78d47..12262c3 100644
--- a/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java
+++ b/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java
@@ -39,7 +39,7 @@ public class CustomerBehaviorJob {
     // 指定 ring buffer字节大小，必需为2的N次方(能将求模运算转为位运算提高效率 )，否则影响性能
     private static final int BUFFER_SIZE = 1024 * 1024;
     //固定线程数
-    private static final int THREAD_NUMBERS = 60;
+    private static final int THREAD_NUMBERS = 40;
 
 
     @Autowired
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 f58492b..c55af72 100644
--- a/src/main/java/com/kiisoo/ic/job/count/CustomerCountJob.java
+++ b/src/main/java/com/kiisoo/ic/job/count/CustomerCountJob.java
@@ -39,7 +39,7 @@ public class CustomerCountJob {
     // 指定 ring buffer字节大小，必需为2的N次方(能将求模运算转为位运算提高效率 )，否则影响性能
     private static final int BUFFER_SIZE = 1024 * 1024;
     //固定线程数
-    private static final int THREAD_NUMBERS = 60;
+    private static final int THREAD_NUMBERS = 50;
 
 
     @Autowired