物联网开发完成话机功能

service-job/src/main/java/com/java110/job/cmd/iot/GetOpenApiCmd.java

@@ -6,6 +6,7 @@ import com.java110.core.context.CmdContextUtils;
 import com.java110.core.context.ICmdDataFlowContext;
 import com.java110.core.event.cmd.Cmd;
 import com.java110.core.event.cmd.CmdEvent;
+import com.java110.dto.store.StoreDto;
 import com.java110.dto.user.UserDto;
 import com.java110.intf.store.IStoreUserV1InnerServiceSMO;
 import com.java110.intf.store.IStoreV1InnerServiceSMO;
@@ -51,9 +52,18 @@ public class GetOpenApiCmd extends Cmd {
         List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
 
         Assert.listOnlyOne(userDtos, "用户未登录");
+        String storeId = CmdContextUtils.getStoreId(context);
 
         reqJson.put("propertyUserId", userDtos.get(0).getUserId());
         reqJson.put("propertyUserTel", userDtos.get(0).getTel());
+        reqJson.put("propertyStoreId", storeId);
+
+        StoreDto storeDto = new StoreDto();
+        storeDto.setStoreId(storeId);
+        storeDto.setStoreTypeCd(StoreDto.STORE_TYPE_PROPERTY);
+        List<StoreDto> storeDtos = storeV1InnerServiceSMOImpl.queryStores(storeDto);
+
+        Assert.listOnlyOne(storeDtos,"不是物业公司");
 
     }
 

service-job/src/main/java/com/java110/job/cmd/iot/PostOpenApiCmd.java

@@ -6,6 +6,7 @@ import com.java110.core.context.CmdContextUtils;
 import com.java110.core.context.ICmdDataFlowContext;
 import com.java110.core.event.cmd.Cmd;
 import com.java110.core.event.cmd.CmdEvent;
+import com.java110.dto.store.StoreDto;
 import com.java110.dto.user.UserDto;
 import com.java110.intf.store.IStoreUserV1InnerServiceSMO;
 import com.java110.intf.store.IStoreV1InnerServiceSMO;
@@ -49,12 +50,20 @@ public class PostOpenApiCmd extends Cmd {
         UserDto userDto = new UserDto();
         userDto.setUserId(userId);
         List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
+        String storeId = CmdContextUtils.getStoreId(context);
 
         Assert.listOnlyOne(userDtos, "用户未登录");
 
         reqJson.put("propertyUserTel", userDtos.get(0).getTel());
         reqJson.put("propertyUserId", userDtos.get(0).getUserId());
+        reqJson.put("propertyStoreId", storeId);
 
+        StoreDto storeDto = new StoreDto();
+        storeDto.setStoreId(storeId);
+        storeDto.setStoreTypeCd(StoreDto.STORE_TYPE_PROPERTY);
+        List<StoreDto> storeDtos = storeV1InnerServiceSMOImpl.queryStores(storeDto);
+
+        Assert.listOnlyOne(storeDtos,"不是物业公司");
     }
 
     @Override