From 855bb0c3ac7614017d26e90ff40ba68918820225 Mon Sep 17 00:00:00 2001
From: liquanyu <liquanyu@lymsh.com>
Date: Thu, 17 Oct 2019 14:47:30 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E9=87=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../platform/operate/web/facade/MeasureInfoFacade.java  | 17 ++++++++++++++---
 1 file changed, 14 insertions(+), 3 deletions(-)

diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/MeasureInfoFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/MeasureInfoFacade.java
index c9e7a1b..8930236 100644
--- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/MeasureInfoFacade.java
+++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/MeasureInfoFacade.java
@@ -35,9 +35,11 @@ import org.apache.commons.dbutils.QueryRunner;
 import org.apache.commons.dbutils.handlers.BeanListHandler;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
 
 import java.sql.Connection;
@@ -104,6 +106,10 @@ public class MeasureInfoFacade {
 
     private static Integer MAX_TODAY_COUNT = 10000;
 
+    @Autowired
+    @Qualifier("commonThreadPool")
+    private ThreadPoolTaskExecutor commonThreadPool;
+
     public BaseListResponse queryMeasureInfoList(String queryNo,
                                                  Integer valueType, String vcCardNo,
                                                  String recordTime, String age,
@@ -1232,9 +1238,14 @@ public class MeasureInfoFacade {
      * @param measureInfoRequest
      * @return
      */
-    public BaseResponse addToDataInfo(MeasureInfoRequest measureInfoRequest) {
-        MAX_TODAY_COUNT = 100;
-        return addMeasureDataInfo(measureInfoRequest);
+    public void addToDataInfo(final MeasureInfoRequest measureInfoRequest) {
+        commonThreadPool.execute(new Runnable() {
+            @Override
+            public void run() {
+                MAX_TODAY_COUNT = 100;
+                addMeasureDataInfo(measureInfoRequest);
+            }
+        });
     }
 
     public BaseResponse addBloodSugar(BloodSugar bloodSugar) {
-- 
1.8.3.1