外呼

performance-web/src/main/java/com/clx/performance/service/impl/vehiclewarn/VehicleWarnMqHandlerServiceImpl.java

 package com.clx.performance.service.impl.vehiclewarn;
 
 import cn.hutool.json.JSONObject;
+import com.alibaba.fastjson.JSON;
 import com.clx.message.feign.ClxMessageOpenapiFeign;
 import com.clx.message.req.batch.AliBatchSmsMessageReq;
 import com.clx.message.req.message.ClinkMessageReq;
@@ -127,9 +128,20 @@ public class VehicleWarnMqHandlerServiceImpl implements VehicleWarnMqHandlerServ
     public void truckWarnNotice(VehicleWarnTruckWarnNoticeMqParam mq) {
         VehicleWarnInfo vehicleWarnInfo = vehicleWarnInfoDao.findById(mq.getInfoId()).orElseThrow(ResultEnum.DATA_NOT_FIND);
 
+        List<String> mobileList = new ArrayList<>();
+
+        // 过滤需要通知的人员
         List<VehicleWarnUser> list = vehicleWarnUserDao.listAllEnable();
+        for (VehicleWarnUser item : list) {
+            List<Integer> warnTypeList = JSON.parseArray(item.getWarmTypeJson(),Integer.class);
+            if (warnTypeList.contains(vehicleWarnInfo.getWarnType())){
+                mobileList.add(item.getMobile());
+            }
+        }
+
+        if (mobileList.isEmpty()) {return;}
+        log.info("车辆预警通知, id:{}, mobileList:{}", vehicleWarnInfo.getId(), JSON.toJSONString(mobileList));
 
-        List<String> mobileList = new ArrayList<>();
         if (vehicleWarnInfo.getWarnLevel() == 2){   //2级短信
             sendSms(mobileList, vehicleWarnInfo.getWarnName(), vehicleWarnInfo.getTruckNo(), vehicleWarnInfo.getChildNo());
         }