测试

performance-web/src/main/java/com/clx/performance/controller/temp/TempController.java

 package com.clx.performance.controller.temp;
 
-import com.clx.open.sdk.callback.message.OrderChildSyncMessage;
+import com.clx.message.feign.ClxMessageOpenapiFeign;
+import com.clx.message.req.batch.ClinkBatchMessageReq;
+import com.clx.performance.config.ClxMessageConfig;
 import com.clx.performance.extranal.transport.TransportService;
 import com.clx.performance.feign.TransportFeignService;
 import com.clx.performance.listener.OrderChildDtsListener;
@@ -14,6 +16,10 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
 
 /**
  * @Author: aiqingguo
@@ -37,18 +43,42 @@ public class TempController {
 
     @Autowired
     private OrderChildDtsListener orderChildDtsListener;
+    @Autowired
+    private ClxMessageConfig clxMessageConfig;
+    @Autowired
+    private ClxMessageOpenapiFeign clxMessageOpenapiFeign;
 
 
     @ApiOperation(value = "test", notes = "<br>By:艾庆国")
-    @RequestMapping(value = "/test", method = RequestMethod.GET)
-    public Result test() {
+    @RequestMapping(value = "/test", method = RequestMethod.POST)
+    public Result test(List<String> mobileList, String warnName, String truckNo, String childNo) {
+        //触发{指定预警名称}预警；车牌号{车牌号}；运单{运单号}；请尽快核实情况
+        ClinkBatchMessageReq req = new ClinkBatchMessageReq();
+
+        StringBuilder sb = new StringBuilder();
+        sb.append("触发");
+        sb.append(warnName);
+        sb.append("预警；车牌号");
+        sb.append(truckNo);
+        sb.append("；运单");
+        sb.append(childNo);
+        sb.append("；请尽快核实情况");
+
+        String content = sb.toString();
+        Map<String, String> params = new HashMap<>();
+        for (String mobile : mobileList) {
+            params.put(mobile, content);
+        }
+
+        req.setChannelId(clxMessageConfig.getChannelId());
+        req.setAppId(clxMessageConfig.getAppId().toString());
+        req.setParams(params);
+        clxMessageOpenapiFeign.sendClinkBatch(req);
 
-        OrderChildSyncMessage message = new OrderChildSyncMessage();
-        message.setId(1);
-        orderChildDtsListener.thirdpartySync(message);
         return Result.ok();
     }
 
+
 //    @ApiOperation(value = "更新网运标识", notes = "<br>By:艾庆国")
 //    @RequestMapping(value = "/updateInvoiceType", method = RequestMethod.POST)
 //    public Result<Void> updateInvoiceType(String childNo, Integer invoiceType) {