优化代码

service-community/src/main/java/com/java110/community/bmo/assets/impl/QueryAssetsOpenDoorBMOImpl.java

@@ -1,8 +1,11 @@
 package com.java110.community.bmo.assets.impl;
 
 import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import com.java110.community.bmo.assets.IQueryAssetsOpenDoorBMO;
+import com.java110.dto.IotDataDto;
 import com.java110.intf.common.IMachineRecordInnerServiceSMO;
+import com.java110.intf.job.IIotInnerServiceSMO;
 import com.java110.vo.ResultVo;
 import org.slf4j.Logger;
 import com.java110.core.log.LoggerFactory;
@@ -17,6 +20,9 @@ public class QueryAssetsOpenDoorBMOImpl implements IQueryAssetsOpenDoorBMO {
     @Autowired
     private IMachineRecordInnerServiceSMO machineRecordInnerServiceSMOImpl;
 
+    @Autowired
+    private IIotInnerServiceSMO iotInnerServiceSMOImpl;
+
 
     /**
      * @param communityId
@@ -31,9 +37,14 @@ public class QueryAssetsOpenDoorBMOImpl implements IQueryAssetsOpenDoorBMO {
      */
     @Override
     public ResponseEntity<String> query(String communityId) {
-        JSONArray data = machineRecordInnerServiceSMOImpl.getAssetsMachineRecords(communityId);
-
-        return ResultVo.createResponseEntity(data);
+        //JSONArray data = machineRecordInnerServiceSMOImpl.getAssetsMachineRecords(communityId);
+        JSONObject reqJson = new JSONObject();
+        reqJson.put("communityId",communityId);
+        IotDataDto iotDataDto = new IotDataDto();
+        iotDataDto.setIotApiCode("getAssetOpenDoorBmoImpl");
+        iotDataDto.setData(reqJson);
+        ResultVo resultVo = iotInnerServiceSMOImpl.postIotData(iotDataDto);
+        return ResultVo.createResponseEntity(resultVo);
     }
 
     @Override