流量卡待缴费消息

device-api-service/src/main/java/com/xy/job/DeviceSimJob.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
+import com.xy.annotate.RestMappingController;
 import com.xy.collections.map.JHashMap;
 import com.xy.collections.map.JMap;
 import com.xy.device.EnumSimConfig;
@@ -17,6 +18,7 @@ import com.xy.utils.*;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.GetMapping;
 
 import java.util.Arrays;
 import java.util.List;
@@ -27,6 +29,7 @@ import java.util.List;
 @Slf4j
 @Component
 @AllArgsConstructor
+@RestMappingController("test")
 public class DeviceSimJob {
 
     private DeviceSimMapper deviceSimMapper;
@@ -101,6 +104,7 @@ public class DeviceSimJob {
      *
      * @return
      */
+    @GetMapping("test")
     @XxlJob("deviceSimWaitHandle")
     public ReturnT<String> deviceSimWaitHandle() {
         Long count = deviceSimMapper.selectCount(new LambdaQueryWrapper<DeviceSim>().eq(DeviceSim::getWaitHandle, true));
@@ -110,8 +114,9 @@ public class DeviceSimJob {
                         JMap<String, Object> map = new JHashMap<String, Object>()
                                 .set("thing1", "有需要缴费的流量卡")
                                 .set("thing5", "有需要缴费的流量卡");
-                        return Arrays.asList(new MsgUtils.MsgInfo("oIJ5O5gjQr8QStjPzVqaBCUIdPiI", map));
-                    });
+                        return Arrays.asList(new MsgUtils.MsgInfo("oIJ5O5jnmMXg0vRBM3WuASPHJGbE", map));
+                    })
+                    .builder();
         }
         return ReturnT.SUCCESS;
     }