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) {