7.28 日常开发 - 启用线程池

sp-service/level-one-server/src/main/java/com/pj/tb_goods_transit/MethodGoodsTransitService.java

@@ -45,7 +45,7 @@ public class MethodGoodsTransitService {
     /**
      * 给边民组组员发送短信通知
      */
-    public void sendSms(List<TbPeople> peopleIdList){
+    public int sendSms(List<TbPeople> peopleIdList){
 
         //获取当前电脑核心数
         int processors = Runtime.getRuntime().availableProcessors() / 2;
@@ -77,6 +77,7 @@ public class MethodGoodsTransitService {
         }
         //关闭多线程
         executorService.shutdown();
+        return count;
     }
 
 

sp-service/level-one-server/src/main/java/com/pj/tb_goods_transit/TbGoodsTransitService.java

@@ -269,7 +269,10 @@ public class TbGoodsTransitService extends ServiceImpl<TbGoodsTransitMapper, TbG
 							.eq(TbPeople::getDeleteStatus, DeleteStatus.DELETE_STATUS_ON.getCode()));
 
 			if(tbPeopleList.size() == 0)throw new RuntimeException("订单异常,原因是没有关联的边民!!!");
-			methodGoodsTransitService.sendSms(tbPeopleList);
+			int sendSms = methodGoodsTransitService.sendSms(tbPeopleList);
+			if(sendSms != tbPeopleList.size()){
+				//todo: 如果短信发送成功次数 与 边民数不一致处理
+			}
 
 		}