增加 刷新网络 接口

device-api-service/src/main/java/com/xy/service/SimInfoServiceImpl.java

@@ -26,7 +26,13 @@ public class SimInfoServiceImpl implements SimInfoService {
 
     @Override
     @ApiOperation("物联网卡信息")
-    public R<SimInfoDto.InfoVo> info(@RequestBody @Validated SimInfoDto.InfoDto dto) {
-        return FactoryUtils.getServiceRoute(SimInfoFactory.class, "111").info(dto);
+    public R<SimInfoDto.InfoVo> info(@RequestBody @Validated SimInfoDto.BaseDto dto) {
+        return FactoryUtils.getServiceRoute(SimInfoFactory.class, dto.getIsp()).info(dto);
+    }
+
+    @Override
+    @ApiOperation("刷新网络")
+    public R<String> refreshNet(SimInfoDto.RefreshNetDto dto) {
+        return FactoryUtils.getServiceRoute(SimInfoFactory.class,dto.getIsp()).refreshNet(dto);
     }
 }

device-api-service/src/main/java/com/xy/service/factory/sim/SimInfoFactory.java

@@ -12,5 +12,7 @@ import com.xy.utils.R;
  * @since 2024/8/20
  */
 public interface SimInfoFactory {
-    R<SimInfoDto.InfoVo> info(SimInfoDto.InfoDto dto);
+    R<SimInfoDto.InfoVo> info(SimInfoDto.BaseDto dto);
+
+    R<String> refreshNet(SimInfoDto.RefreshNetDto dto);
 }

device-api-service/src/main/java/com/xy/service/factory/sim/impl/CtWingFactoryImpl.java

@@ -41,7 +41,7 @@ public class CtWingFactoryImpl implements SimInfoFactory {
 
     @Override
     @SneakyThrows
-    public R<SimInfoDto.InfoVo> info(SimInfoDto.InfoDto dto) {
+    public R<SimInfoDto.InfoVo> info(SimInfoDto.BaseDto dto) {
         //三码查询
         CtWingVo.TelephonePlusVo telephonePlusVo = telephonePlus(dto.getIccid());
         if (!"0".equals(telephonePlusVo.getResultCode())) {
@@ -67,7 +67,27 @@ public class CtWingFactoryImpl implements SimInfoFactory {
             CtWingVo.NetStatusVo netStatusVo = CtWingUtils.queryNetStatus(accessNumberOrIccid);
         };
         queryCardMainStatus.run();
+        queryNetStatus.run();
         return R.ok(vo);
     }
 
+    @Override
+    @SneakyThrows
+    public R<String> refreshNet(SimInfoDto.RefreshNetDto dto) {
+        //三码查询
+        CtWingVo.TelephonePlusVo telephonePlusVo = telephonePlus(dto.getIccid());
+        if (!"0".equals(telephonePlusVo.getResultCode())) {
+            return R.fail("三码查询错误！");
+        }
+        String action = dto.getAction() ? "ADD":"DEL";
+        CtWingDto.SingleCutNetDto singleCutNetDto = new CtWingDto.SingleCutNetDto()
+                .setAccessNumber(telephonePlusVo.getAccessNumber())
+                .setAction(action);
+        CtWingVo.BaseVo baseVo = CtWingUtils.singleCutNet(singleCutNetDto);
+        if("0".equals(baseVo.getResultCode())){
+            return R.ok("处理成功！");
+        }else{
+            return R.fail(baseVo.getResultMsg());
+        }
+    }
 }

device-api/src/main/java/com/xy/dto/SimInfoDto.java

@@ -11,10 +11,13 @@ public class SimInfoDto {
 
     @Data
     @Accessors(chain = true)
-    public static class InfoDto {
+    public static class BaseDto {
         @NotNull(message = "iccid 不能为空")
         @ApiModelProperty(value = "iccid", required = true)
         private String iccid;
+
+        @ApiModelProperty(value = "运营商")
+        private String isp;
     }
 
     @Data
@@ -46,4 +49,14 @@ public class SimInfoDto {
 
         //上线掉线时间，流量套餐，使用情况
     }
+
+    @Data
+    @Accessors(chain = true)
+    public static class RefreshNetDto extends BaseDto{
+
+        @NotNull(message = "操作 不能为空")
+        @ApiModelProperty(value = "操作 true为联网，false为断网", required = true)
+        private Boolean action;
+    }
+
 }

device-api/src/main/java/com/xy/service/SimInfoService.java

@@ -18,6 +18,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 @RestMappingController("sim-info")
 public interface SimInfoService {
     @PostMapping("info")
-    R<SimInfoDto.InfoVo> info(@RequestBody @Validated SimInfoDto.InfoDto dto);
+    R<SimInfoDto.InfoVo> info(@RequestBody @Validated SimInfoDto.BaseDto dto);
 
+    @PostMapping("refreshNet")
+    R<String> refreshNet(@RequestBody @Validated SimInfoDto.RefreshNetDto dto);
 }