ソースを参照

修改数据库maxActive配置,消息接口请求返回信息不再打印日志。

dongbw 7 年 前
コミット
ab2420a37e

+ 1 - 1
src/main/java/com/uas/ps/inquiry/controller/DeadlineTask.java

@@ -162,7 +162,7 @@ public class DeadlineTask {
                 try {
                     log.info("发送消息实体" + JSON.toJSONString(models));
                     String res = HttpUtil.doPost(PS_MESSAGE_URL + "/messages", FlexJsonUtils.toJsonDeep(models));
-                    log.info("消息请求发送日志" + res);
+                    log.info("消息请求发送");
                 } catch (Exception e) {
                     e.printStackTrace();
                 }

+ 10 - 10
src/main/java/com/uas/ps/inquiry/service/impl/InquiryServiceImpl.java

@@ -165,15 +165,15 @@ public class InquiryServiceImpl implements InquiryService {
             info.setOffset(info.getPageSize() * (info.getPageNumber() - 1));
         }
         info.setSort(sort);
-        if (null != filter.getUserUU()) {
-            info.filter("userUU", filter.getUserUU());
-            info.expression(PredicateUtils.isNull("inquiry.enUU"));
-        } else if (null != filter.getEnUU()) {
-            info.filter("inquiry.enUU", filter.getEnUU());
-        } else {
-            throw new IllegalAccessError("非法访问");
-        }
         if (null != filter) {
+            if (null != filter.getUserUU()) {
+                info.filter("userUU", filter.getUserUU());
+                info.expression(PredicateUtils.isNull("inquiry.enUU"));
+            } else if (null != filter.getEnUU()) {
+                info.filter("inquiry.enUU", filter.getEnUU());
+            } else {
+                throw new IllegalAccessError("非法访问");
+            }
             if (StringUtils.hasText(filter.getKeyword())) {
                 SimpleExpression cmpCode = new SimpleExpression("cmpCode", filter.getKeyword(), CriterionExpression.Operator.LIKE);
                 SimpleExpression brand = new SimpleExpression("inbrand", filter.getKeyword(), CriterionExpression.Operator.LIKE);
@@ -923,7 +923,7 @@ public class InquiryServiceImpl implements InquiryService {
                         if (models.size() >= 500) {
                             long start = System.currentTimeMillis();
                             String res = HttpUtil.doPost(PS_MESSAGE_URL + "/messages", FlexJsonUtils.toJsonDeep(models));
-                            log.info("消息中心生成消息接口返回日志" + res);
+                            log.info("消息中心生成消息");
                             log.info("发送消息" + models.size() + ",耗时:" + (System.currentTimeMillis() - start));
                             models = new ArrayList<>();
                         }
@@ -931,7 +931,7 @@ public class InquiryServiceImpl implements InquiryService {
                     if (!CollectionUtils.isEmpty(models)) {
                         long start = System.currentTimeMillis();
                         String res = HttpUtil.doPost(PS_MESSAGE_URL + "/messages", FlexJsonUtils.toJsonDeep(models));
-                        log.info("消息中心生成消息接口返回日志" + res);
+                        log.info("消息中心生成消息");
                         log.info("发送消息" + models.size() + ",耗时:" + (System.currentTimeMillis() - start));
                     }
                     log.info("发送消息全部完成");

+ 21 - 9
src/main/java/com/uas/ps/inquiry/service/impl/PublicInquiryServiceImpl.java

@@ -17,7 +17,6 @@ import com.uas.ps.inquiry.page.SearchFilter;
 import com.uas.ps.inquiry.page.criteria.*;
 import com.uas.ps.inquiry.page.exception.IllegalOperatorException;
 import com.uas.ps.inquiry.service.PublicInquiryService;
-import com.uas.ps.inquiry.support.InquiryBufferedLogger;
 import com.uas.ps.inquiry.util.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -34,7 +33,10 @@ import org.springframework.ui.ModelMap;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
 
-import javax.persistence.criteria.*;
+import javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Predicate;
+import javax.persistence.criteria.Root;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
@@ -528,7 +530,7 @@ public class PublicInquiryServiceImpl implements PublicInquiryService {
                     long start = System.currentTimeMillis();
                     log.info("发送消息实体" + JSON.toJSONString(models));
                     String res = HttpUtil.doPost(PS_MESSAGE_URL + "/messages", FlexJsonUtils.toJsonDeep(models));
-                    log.info("消息请求发送日志" + res);
+                    log.info("消息请求发送");
                     log.info("/messages , 条数: " + models.size() + ",耗时:" + (System.currentTimeMillis() - start));
                 } catch (Exception e) {
                     e.printStackTrace();
@@ -1135,6 +1137,22 @@ public class PublicInquiryServiceImpl implements PublicInquiryService {
         }
         info.setSort(sort);
         if (null != filter) {
+            if (filter.getFromDate() != null) {
+                info.expression(PredicateUtils.gte("offerTime", new Date(filter.getFromDate()), false));
+            }
+            if (filter.getEndDate() != null) {
+                info.expression(PredicateUtils.lte("offerTime", new Date(filter.getEndDate()), false));
+            }
+            // 此处的 fromDelivery 作为发布时间过滤
+            if (filter.getFromDelivery() != null) {
+                info.expression(PredicateUtils.gte("date", new Date(filter.getFromDelivery()), false));
+            }
+            if (filter.getEndDelivery() != null) {
+                info.expression(PredicateUtils.lte("date", new Date(filter.getEndDelivery()), false));
+            }
+            if (filter.getUserUU() != null) {
+                info.expression(PredicateUtils.gte("vendUserUU", filter.getUserUU(), false));
+            }
             if (StringUtils.hasText(filter.getKeyword())) {
                 SimpleExpression cmpCode = new SimpleExpression("cmpCode", filter.getKeyword(), CriterionExpression.Operator.LIKE, true);
                 SimpleExpression brand = new SimpleExpression("inbrand", filter.getKeyword(), CriterionExpression.Operator.LIKE, true);
@@ -1146,12 +1164,6 @@ public class PublicInquiryServiceImpl implements PublicInquiryService {
                 LogicalExpression logical = new LogicalExpression(simpleExpressions, CriterionExpression.Operator.OR);
                 info.expression(logical);
             }
-            if (filter.getFromDate() != null) {
-                info.expression(PredicateUtils.gte("offerTime", new Date(filter.getFromDate()), false));
-            }
-            if (filter.getEndDate() != null) {
-                info.expression(PredicateUtils.lte("offerTime", new Date(filter.getEndDate()), false));
-            }
         }
         Page<PublicInquiryItemInfo> itemInfoPage = itemInfoDao.findAll(new Specification<PublicInquiryItemInfo>() {
             @Override

+ 1 - 1
src/main/resources/config/application-dev.properties

@@ -4,7 +4,7 @@ datasource.password=select111***
 datasource.driverClassName=com.mysql.jdbc.Driver
 datasource.initialSize=1
 datasource.minIdle=30
-datasource.maxActive=100
+datasource.maxActive=500
 datasource.maxWait=5000
 datasource.timeBetweenEvictionRunsMillis=60000
 datasource.minEvictableIdleTimeMillis=300000