更新快照查询为多线程处理

src/main/java/com/uas/platform/b2b/controller/SnapshotController.java

@@ -83,9 +83,9 @@ public class SnapshotController {
 		ThreadUtils.task(()-> {
 			List<Snapshot> snapshots = snapshotService.findByEnUU(enUU);
 			if (!CollectionUtils.isEmpty(snapshots)) {
-				for (Snapshot snapshot : snapshots) {
-					modelMap.put(snapshot.getCategory(), snapshot.getCount());
-				}
+				snapshots.stream()
+                        .filter(snapshot -> null != snapshot)
+                        .forEach(snapshot -> modelMap.put(snapshot.getCategory(), snapshot.getCount()));
 			}
 		}).run();
 		ContextUtils.getBean("snapshotController");

src/main/java/com/uas/platform/b2b/service/impl/SnapshotServiceImpl.java

@@ -1,5 +1,6 @@
 package com.uas.platform.b2b.service.impl;
 
+import com.uas.platform.b2b.core.util.ThreadUtils;
 import com.uas.platform.b2b.dao.CommonDao;
 import com.uas.platform.b2b.model.Snapshot;
 import com.uas.platform.b2b.model.util.SnapshotSqlUtil;
@@ -29,76 +30,109 @@ public class SnapshotServiceImpl implements SnapshotService {
     @Override
     public List<Snapshot> findByEnUU(Long enUU) {
         List<Snapshot> snapshots = new ArrayList<>();
-        // 获取待处理客户询价单
-        getInquiryTodo(snapshots, enUU);
-        // 获取全部客户询价单
-        getInquiryAll(snapshots, enUU);
-        // 获取待处理采购询价单
-        getPurchaseInquiryTodo(snapshots, enUU);
-        // 获取待回复采购订单
-        getPurchaseOrderTodo(snapshots, enUU);
-        // 获取全部采购订单
-        getPurchaseOrderAll(snapshots, enUU);
-        // 获取全部客户采购变更单
-        getSaleChangeAll(snapshots, enUU);
-        // 获取待处理客户采购变更单
-        getSaleChangeTodo(snapshots, enUU);
-        // 获取客户发货提醒（待发货）
-        getSaleOrderNoticeTodo(snapshots, enUU);
-        // 获取客户发货提醒（全部）
-        getSaleOrderNoticeAll(snapshots, enUU);
-        // 获取客户采购验收单（全部）
-        getSaleOrderAcceptAll(snapshots, enUU);
-        // 获取客户采购验退单（全部）
-        getSaleOrderReturnAll(snapshots, enUU);
-        // 获取待送样打样申请
-        getSampleTodo(snapshots, enUU);
-        // 获取全部打样申请
-        getSampleAll(snapshots, enUU);
-        // 获取全部送样认定单
-        getApprovalAll(snapshots, enUU);
-        // 获取全部发货单
-        getSaleSendAll(snapshots, enUU);
-        // 获取已收料发货单
-        getSaleSendDone(snapshots, enUU);
-        // 获取待回复客户委外单
-        getMakeOrderTodo(snapshots, enUU);
-        // 获取全部客户委外单
-        getMakeOrderAll(snapshots, enUU);
-        // 获取全部客户委外变更单
-        getMakeChangeAll(snapshots, enUU);
-        // 获取全部客户委外验收单
-        getMakeAcceptAll(snapshots, enUU);
-        // 获取全部客户委外验退单
-        getMakeReturnAll(snapshots, enUU);
-        // 获取全部委外单
-        getMakeOutAll(snapshots, enUU);
-        // 获取全部不良品入库单
-        getBadInAll(snapshots, enUU);
-        // 获取全部不良品出库单
-        getBadOutAll(snapshots, enUU);
-        // 获取全部MRB单
-        getMrbAll(snapshots, enUU);
-        // 获取全部应付发票
-        getApbillAll(snapshots, enUU);
-        // 获取全部应付对账单
-        getArCheckAll(snapshots, enUU);
-        // 获取待处理应付对账单
-        getArCheckTodo(snapshots, enUU);
-        // 获取待处理应收对账单
-        getApcheckTodo(snapshots, enUU);
-        // 获取购物车数量
-        getCart(snapshots, enUU);
-        // 获取待报价模具询价
-        getInquiryMouldTodo(snapshots, enUU);
-        // 获取待回复主动报价
-        getSaleQuotationTodo(snapshots, enUU);
-        // 获取待处理采购招标单
-        getTenderTodo(snapshots, enUU);
-        // 获取待处理招标单
-        getSaleTenderTodo(snapshots, enUU);
-        // 获取待评标招标单
-        getSaleTenderWaiting(snapshots, enUU);
+        ThreadUtils.task(() -> {
+            // 获取待处理客户询价单
+            getInquiryTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部客户询价单
+            getInquiryAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取待处理采购询价单
+            getPurchaseInquiryTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取待回复采购订单
+            getPurchaseOrderTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部采购订单
+            getPurchaseOrderAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部客户采购变更单
+            getSaleChangeAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取待处理客户采购变更单
+            getSaleChangeTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取客户发货提醒（待发货）
+            getSaleOrderNoticeTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取客户发货提醒（全部）
+            getSaleOrderNoticeAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取客户采购验收单（全部）
+            getSaleOrderAcceptAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取客户采购验退单（全部）
+            getSaleOrderReturnAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取待送样打样申请
+            getSampleTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部打样申请
+            getSampleAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部送样认定单
+            getApprovalAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部发货单
+            getSaleSendAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取已收料发货单
+            getSaleSendDone(snapshots, enUU);
+        }).task(() -> {
+            // 获取待回复客户委外单
+            getMakeOrderTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部客户委外单
+            getMakeOrderAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部客户委外变更单
+            getMakeChangeAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部客户委外验收单
+            getMakeAcceptAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部客户委外验退单
+            getMakeReturnAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部委外单
+            getMakeOutAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部不良品入库单
+            getBadInAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部不良品出库单
+            getBadOutAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部应付发票
+            getApbillAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部应付对账单
+            getArCheckAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取待处理应付对账单
+            getArCheckTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取待处理应收对账单
+            getApcheckTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取购物车数量
+            getCart(snapshots, enUU);
+        }).task(() -> {
+            // 获取待报价模具询价
+            getInquiryMouldTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取待回复主动报价
+            getSaleQuotationTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取待处理采购招标单
+            getTenderTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取待处理招标单
+            getSaleTenderTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取待评标招标单
+            getSaleTenderWaiting(snapshots, enUU);
+        }).run();
         return snapshots;
     }