调用物联网加入开关工嗯呢

service-job/src/main/java/com/java110/job/adapt/hcIotNew/SendAttendanceStaffDataToIotAdapt.java

@@ -65,6 +65,10 @@ public class SendAttendanceStaffDataToIotAdapt extends DatabusAdaptImpl {
 
     @Override
     public void execute(Business business, List<Business> businesses) {
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            return;
+        }
 
         JSONObject data = business.getData();
         String csId = data.getString("csId");

service-job/src/main/java/com/java110/job/adapt/hcIotNew/SendCarDataToIotAdapt.java

@@ -12,6 +12,7 @@ import com.java110.intf.user.IOwnerCarV1InnerServiceSMO;
 import com.java110.intf.user.IOwnerV1InnerServiceSMO;
 import com.java110.job.adapt.DatabusAdaptImpl;
 import com.java110.job.adapt.hcIotNew.http.ISendIot;
+import com.java110.utils.cache.MappingCache;
 import com.java110.utils.util.DateUtil;
 import com.java110.utils.util.ListUtil;
 import com.java110.utils.util.StringUtil;
@@ -44,6 +45,10 @@ public class SendCarDataToIotAdapt extends DatabusAdaptImpl {
 
     @Override
     public void execute(Business business, List<Business> businesses) {
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            return;
+        }
 
         JSONObject data = business.getData();
         String memberId = data.getString("memberId");

service-job/src/main/java/com/java110/job/adapt/hcIotNew/SendCommunityDataToIotAdapt.java

@@ -28,6 +28,7 @@ import com.java110.intf.user.IOwnerRoomRelV1InnerServiceSMO;
 import com.java110.intf.user.IOwnerV1InnerServiceSMO;
 import com.java110.job.adapt.DatabusAdaptImpl;
 import com.java110.job.adapt.hcIotNew.http.ISendIot;
+import com.java110.utils.cache.MappingCache;
 import com.java110.utils.exception.CmdException;
 import com.java110.utils.util.Assert;
 import com.java110.utils.util.ListUtil;
@@ -99,6 +100,11 @@ public class SendCommunityDataToIotAdapt extends DatabusAdaptImpl {
      */
     @Override
     public void execute(Business business, List<Business> businesses) {
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            return;
+        }
+
         JSONObject data = business.getData();
         String communityId = data.getString("communityId");
 

service-job/src/main/java/com/java110/job/adapt/hcIotNew/SendDeleteAttendanceStaffDataToIotAdapt.java

@@ -63,6 +63,10 @@ public class SendDeleteAttendanceStaffDataToIotAdapt extends DatabusAdaptImpl {
 
     @Override
     public void execute(Business business, List<Business> businesses) {
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            return;
+        }
 
         JSONObject data = business.getData();
         String csId = data.getString("csId");

service-job/src/main/java/com/java110/job/adapt/hcIotNew/SendDeleteCarDataToIotAdapt.java

@@ -11,6 +11,7 @@ import com.java110.intf.user.IOwnerCarInnerServiceSMO;
 import com.java110.intf.user.IOwnerV1InnerServiceSMO;
 import com.java110.job.adapt.DatabusAdaptImpl;
 import com.java110.job.adapt.hcIotNew.http.ISendIot;
+import com.java110.utils.cache.MappingCache;
 import com.java110.utils.util.DateUtil;
 import com.java110.utils.util.ListUtil;
 import com.java110.utils.util.StringUtil;
@@ -43,6 +44,10 @@ public class SendDeleteCarDataToIotAdapt extends DatabusAdaptImpl {
 
     @Override
     public void execute(Business business, List<Business> businesses) {
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            return;
+        }
 
         JSONObject data = business.getData();
         String memberId = data.getString("memberId");

service-job/src/main/java/com/java110/job/adapt/hcIotNew/SendDeleteOwnerDataToIotAdapt.java

@@ -9,6 +9,7 @@ import com.java110.intf.common.IMachineTranslateInnerServiceSMO;
 import com.java110.intf.user.IOwnerV1InnerServiceSMO;
 import com.java110.job.adapt.DatabusAdaptImpl;
 import com.java110.job.adapt.hcIotNew.http.ISendIot;
+import com.java110.utils.cache.MappingCache;
 import com.java110.utils.util.DateUtil;
 import com.java110.utils.util.ListUtil;
 import com.java110.utils.util.StringUtil;
@@ -37,6 +38,10 @@ public class SendDeleteOwnerDataToIotAdapt extends DatabusAdaptImpl {
     private ISendIot sendIotImpl;
     @Override
     public void execute(Business business, List<Business> businesses) {
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            return;
+        }
 
         JSONObject data = business.getData();
         String memberId = data.getString("memberId");

service-job/src/main/java/com/java110/job/adapt/hcIotNew/SendDeleteStaffDataToIotAdapt.java

@@ -17,6 +17,7 @@ import com.java110.intf.store.IStoreUserV1InnerServiceSMO;
 import com.java110.intf.user.IUserV1InnerServiceSMO;
 import com.java110.job.adapt.DatabusAdaptImpl;
 import com.java110.job.adapt.hcIotNew.http.ISendIot;
+import com.java110.utils.cache.MappingCache;
 import com.java110.utils.util.DateUtil;
 import com.java110.utils.util.ListUtil;
 import com.java110.utils.util.StringUtil;
@@ -56,6 +57,10 @@ public class SendDeleteStaffDataToIotAdapt extends DatabusAdaptImpl {
 
     @Override
     public void execute(Business business, List<Business> businesses) {
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            return;
+        }
 
         JSONObject data = business.getData();
         String userId = data.getString("userId");

service-job/src/main/java/com/java110/job/adapt/hcIotNew/SendOwnerDataToIotAdapt.java

@@ -5,6 +5,7 @@ import com.java110.dto.owner.OwnerDto;
 import com.java110.dto.system.Business;
 import com.java110.intf.user.IOwnerV1InnerServiceSMO;
 import com.java110.job.adapt.DatabusAdaptImpl;
+import com.java110.utils.cache.MappingCache;
 import com.java110.utils.util.ListUtil;
 import com.java110.utils.util.StringUtil;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -26,6 +27,10 @@ public class SendOwnerDataToIotAdapt extends DatabusAdaptImpl {
 
     @Override
     public void execute(Business business, List<Business> businesses) {
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            return;
+        }
 
         JSONObject data = business.getData();
         String memberId = data.getString("memberId");

service-job/src/main/java/com/java110/job/adapt/hcIotNew/SendStaffDataToIotAdapt.java

@@ -18,6 +18,8 @@ import com.java110.intf.store.IStoreUserV1InnerServiceSMO;
 import com.java110.intf.user.IUserV1InnerServiceSMO;
 import com.java110.job.adapt.DatabusAdaptImpl;
 import com.java110.job.adapt.hcIotNew.http.ISendIot;
+import com.java110.utils.cache.MappingCache;
+import com.java110.utils.exception.CmdException;
 import com.java110.utils.util.DateUtil;
 import com.java110.utils.util.ListUtil;
 import com.java110.utils.util.StringUtil;
@@ -59,6 +61,11 @@ public class SendStaffDataToIotAdapt extends DatabusAdaptImpl {
     @Override
     public void execute(Business business, List<Business> businesses) {
 
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            return;
+        }
+
         JSONObject data = business.getData();
         String userId = data.getString("userId");
         if (StringUtil.isEmpty(userId)) {

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

@@ -48,6 +48,11 @@ public class GetIotTokenCmd extends Cmd {
     public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
 
         Assert.hasKeyAndValue(reqJson, "targetUrl", "未包含targetUrl");
+
+        String iotSwitch = MappingCache.getValue("IOT", "IOT_SWITCH");
+        if (!"ON".equals(iotSwitch)) {
+            throw new CmdException("物联网系统未部署");
+        }
     }
 
     @Override
@@ -59,20 +64,20 @@ public class GetIotTokenCmd extends Cmd {
         userDto.setUserId(userId);
         List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
 
-        Assert.listOnlyOne(userDtos,"用户未登录");
+        Assert.listOnlyOne(userDtos, "用户未登录");
 
         StoreUserDto storeUserDto = new StoreUserDto();
         storeUserDto.setUserId(userId);
         List<StoreUserDto> storeUserDtos = storeUserV1InnerServiceSMOImpl.queryStoreUsers(storeUserDto);
 
-        Assert.listOnlyOne(storeUserDtos,"未包含商户");
+        Assert.listOnlyOne(storeUserDtos, "未包含商户");
 
 
         StoreDto storeDto = new StoreDto();
         storeDto.setStoreId(storeUserDtos.get(0).getStoreId());
         List<StoreDto> storeDtos = storeV1InnerServiceSMOImpl.queryStores(storeDto);
 
-        Assert.listOnlyOne(storeDtos,"商户不存在");
+        Assert.listOnlyOne(storeDtos, "商户不存在");
 
         JSONObject staff = new JSONObject();
         staff.put("tel", userDtos.get(0).getTel());
@@ -80,16 +85,16 @@ public class GetIotTokenCmd extends Cmd {
 
         ResultVo resultVo = sendIotImpl.post("/iot/api/sso.getSsoToken", staff);
 
-        if(resultVo.getCode() != ResultVo.CODE_OK){
+        if (resultVo.getCode() != ResultVo.CODE_OK) {
             throw new CmdException(resultVo.getMsg());
         }
 
         JSONObject paramOut = (JSONObject) resultVo.getData();
 
         String iotUrl = MappingCache.getValue(URL_DOMAIN, IotConstant.IOT_URL);
-        String targetUrl = iotUrl+reqJson.getString("targetUrl");
-        String url = iotUrl+"/sso.html?token="+paramOut.getString("token")+"&targetUrl="+targetUrl;
-        paramOut.put("url",url);
+        String targetUrl = iotUrl + reqJson.getString("targetUrl");
+        String url = iotUrl + "/sso.html?token=" + paramOut.getString("token") + "&targetUrl=" + targetUrl;
+        paramOut.put("url", url);
         context.setResponseEntity(ResultVo.createResponseEntity(paramOut));
 
     }