运单预警

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

@@ -3,7 +3,7 @@ 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.AliSmsMessageReq;
 import com.clx.message.req.message.ClinkMessageReq;
 import com.clx.order.vo.feign.FeignOrderInfoVO;
 import com.clx.performance.config.ClxMessageConfig;
@@ -280,18 +280,22 @@ public class VehicleWarnMqHandlerServiceImpl implements VehicleWarnMqHandlerServ
     @Override
     public void sendSms(List<String> mobileList, String warnName, String truckNo, String childNo) {
         //触发${warnName}预警；车牌号${truckNo}；运单${childNo}；请尽快核实情况
-        AliBatchSmsMessageReq req = new AliBatchSmsMessageReq();
+
+        AliSmsMessageReq req = new AliSmsMessageReq();
+        req.setTemplateCode(clxMessageConfig.getVehicleWarnTemplateCode());
         JSONObject jsonObject = new JSONObject();
         jsonObject.set("warnName", warnName);
         jsonObject.set("truckNo", truckNo);
         jsonObject.set("childNo", childNo);
-
-        req.setTemplateCode(clxMessageConfig.getVehicleWarnTemplateCode());
-        req.setChannelId(clxMessageConfig.getChannelId());
+        req.setChannelId(clxMessageConfig.getVehicleWarnChannelId());
         req.setAppId(clxMessageConfig.getAppId().toString());
-        req.setMobileList(mobileList);
         req.setContent(jsonObject.toString());
-        clxMessageOpenapiFeign.sendAliSmsBatch(req);
+        req.setExpire(300L);
+
+        for (String mobile : mobileList) {
+            req.setMobile(mobile);
+            clxMessageOpenapiFeign.sendAliSms(req);
+        }
 
     }