批量新增设备bug修改

cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java

@@ -93,7 +93,7 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
     private final AskDeviceDataFeignClient askDeviceDataFeignClient;
     private final RedisUtil redisUtil;
     private final CsSoftInfoMapper csSoftInfoMapper;
-
+    private final IMqttUserService mqttUserService;
     @Override
     public void refreshDeviceDataCache() {
         LambdaQueryWrapper<CsEquipmentDeliveryPO> queryWrapper = new LambdaQueryWrapper<>();
@@ -548,6 +548,16 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
                 }).collect (Collectors.toList ( ));
                 csEquipmentProcessPOService.saveBatch(collect1,500);
                 this.saveOrUpdateBatch (collect, 500);
+                collect.forEach(temp->{
+                    if (Objects.nonNull(temp)){
+                        //查询mqtt用户名和密码是否存在
+                        boolean result = mqttUserService.findMqttUser(temp.getNdid());
+                        if (result){
+                            //初始化装置mqtt连接信息(使用sha256加密)
+                            mqttUserService.insertMqttUser(temp.getNdid());
+                        }
+                    }
+                });
             }
             if (!CollectionUtils.isEmpty (falseCollect)) {
                 ExportParams exportExcel = new ExportParams ("批量导入模板（请严格按照模板标准填入数据）", "非法设备信息");