优化站点下新增设备接口，增加平台产品编码录入

service-iot/service-iot-api/src/main/java/com/usky/iot/RemoteIotTaskService.java

@@ -24,10 +24,6 @@ public interface RemoteIotTaskService {
     @GetMapping("/addDeviceInfo")
     void addDeviceInfo(@RequestParam("productCode") String productCode, @RequestParam(value = "deviceUuid") String deviceUuid, @RequestParam(value = "deviceId") String deviceId, @RequestParam(value = "deviceName") String deviceName, @RequestParam(value = "installAddress") String installAddress, @RequestParam(value = "serviceStatus") Integer serviceStatus);
 
-
-    @GetMapping("/addSubsystemDeviceInfo")
-    void addSubsystemDeviceInfo(@RequestParam(value = "deviceUuid") String deviceUuid, @RequestParam(value = "deviceId") String deviceId, @RequestParam(value = "tenantId") Integer tenantId);
-
     @GetMapping("/deleteDeviceInfo")
     void deleteDeviceInfo(@RequestParam(value = "deviceUuid") String deviceUuid);
 }

service-iot/service-iot-api/src/main/java/com/usky/iot/factory/RemoteIotTaskFactory.java

@@ -49,11 +49,6 @@ public class RemoteIotTaskFactory implements FallbackFactory<RemoteIotTaskServic
                 throw new FeignBadRequestException(500,"新增设备信息异常"+throwable.getMessage());
             }
 
-            @Override
-            public void addSubsystemDeviceInfo(String deviceUuid, String deviceId, Integer tenantId) {
-                throw new FeignBadRequestException(500,"新增子系统设备信息异常"+throwable.getMessage());
-            }
-
             @Override
             public void deleteDeviceInfo(String deviceUuid) {
                 throw new FeignBadRequestException(500,"删除设备信息异常"+throwable.getMessage());

service-iot/service-iot-biz/src/main/java/com/usky/iot/controller/api/ServiceIotTaskApi.java

@@ -61,20 +61,6 @@ public class ServiceIotTaskApi implements RemoteIotTaskService {
         dmpDeviceInfoService.add(dmpDeviceInfo);
     }
 
-    @Override
-    public void addSubsystemDeviceInfo(String deviceUuid, String deviceId, Integer tenantId){
-        DmpDeviceInfo dmpDeviceInfo = new DmpDeviceInfo();
-        dmpDeviceInfo.setProductCode("");
-        dmpDeviceInfo.setDeviceUuid(deviceUuid);
-        dmpDeviceInfo.setDeviceId(deviceId);
-        dmpDeviceInfo.setDeviceName("");
-        dmpDeviceInfo.setInstallAddress("");
-        dmpDeviceInfo.setServiceStatus(1);
-        dmpDeviceInfo.setTenantId(tenantId);
-
-        dmpDeviceInfoService.add(dmpDeviceInfo);
-    }
-
     @Override
     public void deleteDeviceInfo(String deviceUuid){
         LambdaQueryWrapper<DmpDeviceInfo> deviceQueryWrapper = Wrappers.lambdaQuery();

service-iot/service-iot-biz/src/main/java/com/usky/iot/controller/web/DmpDeviceInfoController.java

@@ -53,17 +53,6 @@ public class DmpDeviceInfoController {
         return ApiResult.success();
     }
 
-    /**
-     * 物联中心绑定子系统同步过来的设备
-     * @param dmpDeviceInfo
-     * @return
-     */
-    @PutMapping
-    public ApiResult<Void> bindSubsystemDevice(@RequestBody DmpDeviceInfo dmpDeviceInfo) {
-        dmpDeviceInfoService.bindSubsystemDevice(dmpDeviceInfo);
-        return ApiResult.success();
-    }
-
     /**
      * 更新设备列表状态
      * @param queryVO

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/DmpDeviceInfoService.java

@@ -29,8 +29,6 @@ public interface DmpDeviceInfoService extends CrudService<DmpDeviceInfo> {
 
     void update(DmpDeviceInfo dmpDeviceInfo);
 
-    void bindSubsystemDevice(DmpDeviceInfo dmpDeviceInfo);
-
     boolean checkNameUnique(DmpDeviceInfo dmpDeviceInfo);
 
     boolean checkNameUnique1(DmpDeviceInfo dmpDeviceInfo,Integer tenantId);

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/impl/DmpDeviceInfoServiceImpl.java

@@ -541,10 +541,6 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
             throw new BusinessException("新增设备信息'" + dmpDeviceInfo.getDeviceId() + "'失败，设备信息已存在");
         }
         List<DmpProductInfo> list = baseMapper.getProductInfo(dmpDeviceInfo.getProductCode());
-        int count = 0;
-        if(dmpDeviceInfo.getTenantId() != null){
-            count = baseMapper.sysTenantCount(dmpDeviceInfo.getTenantId());
-        }
         if (CollectionUtils.isNotEmpty(list)) {
             dmpDeviceInfo.setDeviceType(list.get(0).getDeviceType());
             dmpDeviceInfo.setProductId(list.get(0).getId());
@@ -570,24 +566,8 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
             dmpDeviceStatus.setProductCode(dmpDeviceInfo.getProductCode());
             dmpDeviceStatus.setDeviceUuid(dmpDeviceInfo.getDeviceUuid());
             dmpDeviceStatusService.save(dmpDeviceStatus);
-        } else if(count > 0){  //子系统同步到平台
-            dmpDeviceInfo.setDeviceType(Integer.valueOf(""));
-            dmpDeviceInfo.setProductId(Integer.valueOf(""));
-            dmpDeviceInfo.setCreatedBy(SecurityUtils.getUsername());
-            dmpDeviceInfo.setCreatedTime(LocalDateTime.now());
-            dmpDeviceInfo.setServiceStatus(1);
-            this.save(dmpDeviceInfo);
-
-            DmpDeviceStatus dmpDeviceStatus = new DmpDeviceStatus();
-            dmpDeviceStatus.setDeviceId(dmpDeviceInfo.getDeviceId());
-            dmpDeviceStatus.setProductId(Integer.valueOf(""));
-            dmpDeviceStatus.setDeviceStatus(2);
-            dmpDeviceStatus.setLastOfflineTime(LocalDateTime.now());
-            dmpDeviceStatus.setProductCode("");
-            dmpDeviceStatus.setDeviceUuid(dmpDeviceInfo.getDeviceUuid());
-            dmpDeviceStatusService.save(dmpDeviceStatus);
         } else {
-            throw new BusinessException("新增设备信息'" + dmpDeviceInfo.getDeviceId() + "'失败，无对应产品信息或租户Id");
+            throw new BusinessException("新增设备信息'" + dmpDeviceInfo.getDeviceId() + "'失败，无对应产品信息");
         }
     }
 
@@ -602,22 +582,6 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
 
     }
 
-    @Override
-    public void bindSubsystemDevice(DmpDeviceInfo dmpDeviceInfo) {
-        dmpDeviceInfo.setUpdatedBy(SecurityUtils.getUsername());
-        dmpDeviceInfo.setUpdatedTime(LocalDateTime.now());
-        if (checkNameUnique(dmpDeviceInfo)) {
-            throw new BusinessException("修改设备信息'" + dmpDeviceInfo.getDeviceId() + "'失败，设备信息已存在");
-        }
-        this.updateById(dmpDeviceInfo);
-
-        LambdaUpdateWrapper<DmpDeviceStatus> updateWrapper = Wrappers.lambdaUpdate();
-        updateWrapper.set(DmpDeviceStatus::getProductId,dmpDeviceInfo.getProductId())
-                .set(DmpDeviceStatus::getProductCode,dmpDeviceInfo.getProductCode())
-                .eq(DmpDeviceStatus::getDeviceUuid, dmpDeviceInfo.getDeviceUuid());
-
-    }
-
     @Override
     public boolean checkNameUnique(DmpDeviceInfo dmpDeviceInfo) {
         Integer id = null == dmpDeviceInfo.getId() ? -1 : dmpDeviceInfo.getId();

service-vpp/service-vpp-biz/src/main/java/com/usky/vpp/service/impl/VppDeviceServiceImpl.java

@@ -93,7 +93,7 @@ public class VppDeviceServiceImpl implements VppDeviceService {
         VppAuditHelper.fillCreate(device);
         deviceMapper.insert(device);
 
-        remoteIotTaskService.addSubsystemDeviceInfo(device.getDeviceUuid(),device.getDeviceCode(),device.getTenantId());
+        remoteIotTaskService.addDeviceInfo(request.getProductCode(),device.getDeviceUuid(),device.getDeviceCode(),device.getDeviceName(),"",2);
         return device;
     }
 

service-vpp/service-vpp-biz/src/main/java/com/usky/vpp/service/vo/DeviceRequest.java

@@ -22,4 +22,6 @@ public class DeviceRequest {
     private String firmwareVersion;
     private String gatewayId;
     private String remark;
+
+    private String productCode;
 }