加入重新同步 工鞥呢

java110-interface/src/main/java/com/java110/intf/job/IDataBusInnerServiceSMO.java

@@ -50,4 +50,13 @@ public interface IDataBusInnerServiceSMO {
      */
     @RequestMapping(value = "/restartMachine", method = RequestMethod.POST)
     ResultVo restartMachine(@RequestBody JSONObject reqJson);
+
+    /**
+     * <p>重启设备</p>
+     *
+     * @param reqJson 请求信息
+     * @return TaskDto 对象数据
+     */
+    @RequestMapping(value = "/resendIot", method = RequestMethod.POST)
+    ResultVo resendIot(@RequestBody JSONObject reqJson);
 }

service-common/src/main/java/com/java110/common/api/MachineApi.java

@@ -51,6 +51,21 @@ public class MachineApi {
     }
 
 
+    /**
+     * 重新送物联网系统
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /machine/resendIot
+     * @path /app/machine/resendIot
+     */
+    @RequestMapping(value = "/resendIot", method = RequestMethod.POST)
+    public ResponseEntity<String> resendIot(@RequestBody JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "machineTranslateId", "未包含同步ID");
+        Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区ID");
+        return machineOpenDoorBMOImpl.resendIot(reqJson);
+    }
+
     /**
      * 微信删除消息模板
      *

service-common/src/main/java/com/java110/common/bmo/machine/IMachineOpenDoorBMO.java

@@ -36,4 +36,12 @@ public interface IMachineOpenDoorBMO {
      * @return
      */
     ResponseEntity<String> restartMachine(JSONObject reqJson);
+
+    /**
+     * 开门接口类
+     *
+     * @param reqJson 请求报文信息
+     * @return
+     */
+    ResponseEntity<String> resendIot(JSONObject reqJson);
 }

service-common/src/main/java/com/java110/common/bmo/machine/impl/MachineOpenDoorBMOImpl.java

@@ -58,4 +58,10 @@ public class MachineOpenDoorBMOImpl implements IMachineOpenDoorBMO {
         ResultVo resultVo = dataBusInnerServiceSMOImpl.restartMachine(reqJson);
         return ResultVo.createResponseEntity(resultVo);
     }
+
+    @Override
+    public ResponseEntity<String> resendIot(JSONObject reqJson) {
+        ResultVo resultVo = dataBusInnerServiceSMOImpl.resendIot(reqJson);
+        return ResultVo.createResponseEntity(resultVo);
+    }
 }

service-job/src/main/java/com/java110/job/adapt/hcIot/ReSendIotAdapt.java

@@ -26,11 +26,15 @@ import org.springframework.stereotype.Component;
 /**
  * 重新同步
  *
+ * 当设备信息失败是可以重新送HC物联系统
+ *
+ * 物联网系统 代码地址 https://gitee.com/java110/MicroCommunityThings
+ *
  * 接口协议地址： https://gitee.com/java110/MicroCommunityThings/blob/master/back/docs/api.md
  *
  * @desc add by 吴学文 15:29
  */
-@Component(value = "openDoorAdapt")
+@Component(value = "reSendIotAdapt")
 public class ReSendIotAdapt extends DatabusAdaptImpl {
 
     @Autowired

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

@@ -56,6 +56,13 @@ public class DataBusInnerServiceSMOImpl extends BaseServiceSMO implements IDataB
 
     }
 
+    @Override
+    public ResultVo resendIot(@RequestBody JSONObject reqJson) {
+        IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_START_MACHINE_PROTOCOL, IDatabusAdapt.class);
+        return databusAdaptImpl.reSendToIot(reqJson);
+
+    }
+
     /**
      * 处理业务类
      *