feat: 增加产品批量修改规则链

@@ -36,11 +36,14 @@ import org.thingsboard.server.common.data.EntityInfo;
 import org.thingsboard.server.common.data.StringUtils;
 import org.thingsboard.server.common.data.exception.ThingsboardException;
 import org.thingsboard.server.common.data.id.DeviceProfileId;
+import org.thingsboard.server.common.data.id.RuleChainId;
 import org.thingsboard.server.common.data.id.TenantId;
 import org.thingsboard.server.common.data.page.PageData;
 import org.thingsboard.server.common.data.page.PageLink;
+import org.thingsboard.server.common.data.yunteng.dto.BatchUpdateDeviceProfileDTO;
 import org.thingsboard.server.dao.resource.ImageService;
 import org.thingsboard.server.dao.timeseries.TimeseriesService;
+import org.thingsboard.server.dao.yunteng.service.TkDeviceProfileService;
 import org.thingsboard.server.queue.util.TbCoreComponent;
 import org.thingsboard.server.service.entitiy.device.profile.TbDeviceProfileService;
 import org.thingsboard.server.service.security.model.SecurityUser;
@@ -82,6 +85,7 @@ public class DeviceProfileController extends BaseController {
 
     @Autowired
     private TimeseriesService timeseriesService;
+    private final TkDeviceProfileService tkDeviceProfileService;
 
     @ApiOperation(value = "Get Device Profile (getDeviceProfileById)",
             notes = "Fetch the Device Profile object based on the provided Device Profile Id. " +
@@ -199,6 +203,25 @@ public class DeviceProfileController extends BaseController {
         return tbDeviceProfileService.save(deviceProfile, getCurrentUser());
     }
 
+    //thingskit
+    @ApiOperation(value = "批量更新产品的规则链")
+    @PreAuthorize("@check.checkPermissions({'TENANT_ADMIN'},{'api:yt:deviceProfile:batch:update:ruleChain'})")
+    @RequestMapping(value = "/batch/change/ruleChain", method = RequestMethod.POST)
+    @ResponseBody
+    public Boolean batchUpdateDeviceProfileRuleChainId(
+            @RequestBody BatchUpdateDeviceProfileDTO dto) throws Exception {
+        //校验
+        tkDeviceProfileService.checkDeviceProfilesCanChangeRuleChain(dto.getDeviceProfileIds(),getTenantId());
+        String ruleChainId = dto.getTargetRuleChainId();
+        for (String deviceProfileId :dto.getDeviceProfileIds()){
+            DeviceProfile deviceProfile = deviceProfileService.findDeviceProfileById(getTenantId(),new DeviceProfileId(UUID.fromString(deviceProfileId)));
+            deviceProfile.setDefaultRuleChainId(new RuleChainId(UUID.fromString(ruleChainId)));
+            checkEntity(deviceProfile.getId(), deviceProfile, Resource.DEVICE_PROFILE);
+            tbDeviceProfileService.save(deviceProfile, getCurrentUser());
+        }
+        return true;
+    }
+
     @ApiOperation(value = "Delete device profile (deleteDeviceProfile)",
             notes = "Deletes the device profile. Referencing non-existing device profile Id will cause an error. " +
                     "Can't delete the device profile if it is referenced by existing devices." + TENANT_AUTHORITY_PARAGRAPH,

+package org.thingsboard.server.common.data.yunteng.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class BatchUpdateDeviceProfileDTO {
+
+  @ApiModelProperty(value = "选中的产品ID列表")
+  private List<String> deviceProfileIds;
+
+  @ApiModelProperty(value = "目标规则链ID")
+  private String targetRuleChainId;
+}

@@ -231,7 +231,7 @@ public class TkDeviceProfileServiceImpl
                 if(null != datasource){
                     JsonNode usedDeviceProfileIds = datasource.get("convertProducts");
                     List<String> ids = new ArrayList<>();;
-                    if(usedDeviceProfileIds.isArray()){
+                    if(null != usedDeviceProfileIds && usedDeviceProfileIds.isArray()){
                         Iterator<JsonNode> iteratorNodes = usedDeviceProfileIds.iterator();
                         while (iteratorNodes.hasNext()){
                             ids.add(iteratorNodes.next().asText());