支持业主端登录 将 业主用户资料同步物联网，物联网免去再次登录的繁琐操作，主要是充电桩模块

service-job/src/main/java/com/java110/job/smo/impl/IotInnerServiceSMOImpl.java

@@ -1,14 +1,20 @@
 package com.java110.job.smo.impl;
 
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.java110.core.base.smo.BaseServiceSMO;
 import com.java110.core.log.LoggerFactory;
 import com.java110.dto.IotDataDto;
+import com.java110.dto.owner.OwnerAppUserDto;
 import com.java110.dto.user.UserDto;
 import com.java110.intf.job.IIotInnerServiceSMO;
+import com.java110.intf.user.IOwnerAppUserV1InnerServiceSMO;
 import com.java110.job.adapt.hcIotNew.http.ISendIot;
+import com.java110.po.owner.OwnerAppUserPo;
 import com.java110.utils.cache.MappingCache;
+import com.java110.utils.util.ListUtil;
+import com.java110.utils.util.StringUtil;
 import com.java110.vo.ResultVo;
 import org.slf4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -34,6 +40,9 @@ public class IotInnerServiceSMOImpl extends BaseServiceSMO implements IIotInnerS
     @Autowired
     private ISendIot sendIotImpl;
 
+    @Autowired
+    private IOwnerAppUserV1InnerServiceSMO ownerAppUserV1InnerServiceSMOImpl;
+
 
     @Override
     public ResultVo postIot(@RequestBody JSONObject paramIn) {
@@ -76,6 +85,42 @@ public class IotInnerServiceSMOImpl extends BaseServiceSMO implements IIotInnerS
         paramIn.put("userName", userDto.getName());
         paramIn.put("address", userDto.getAddress());
 
+        //todo 查询 房屋认证信息也同步到物联网
+
+        OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
+        ownerAppUserDto.setUserId(userDto.getUserId());
+        List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserV1InnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
+        JSONArray appUsers = new JSONArray();
+        JSONObject appUser = null;
+        if(!ListUtil.isNull(ownerAppUserDtos)){
+            for(OwnerAppUserDto tmpOwnerAppUserDto:ownerAppUserDtos){
+                if(StringUtil.isEmpty(tmpOwnerAppUserDto.getMemberId())){
+                    continue;
+                }
+                if(tmpOwnerAppUserDto.getMemberId().startsWith("-")){
+                    continue;
+                }
+
+                if(StringUtil.isEmpty(tmpOwnerAppUserDto.getRoomId())){
+                    continue;
+                }
+
+                if(StringUtil.isEmpty(tmpOwnerAppUserDto.getRoomName())){
+                    continue;
+                }
+
+                appUser = new JSONObject();
+                appUser.put("ownerId",tmpOwnerAppUserDto.getMemberId());
+                appUser.put("ownerName",tmpOwnerAppUserDto.getAppUserName());
+                appUser.put("roomId",tmpOwnerAppUserDto.getRoomId());
+                appUser.put("roomName",tmpOwnerAppUserDto.getRoomName());
+                appUser.put("communityId",tmpOwnerAppUserDto.getCommunityId());
+                appUser.put("communityName",tmpOwnerAppUserDto.getCommunityName());
+                appUsers.add(appUser);
+            }
+            paramIn.put("appUsers", appUsers);
+        }
+
         ResultVo resultVo = sendIotImpl.post("/iot/api/owner.transforOwnerUser", paramIn);
 
         return resultVo;