优化代码

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

@@ -0,0 +1,101 @@
+package com.java110.job.adapt.hcIotNew;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.dto.owner.OwnerCarDto;
+import com.java110.dto.owner.OwnerDto;
+import com.java110.dto.system.Business;
+import com.java110.intf.user.IOwnerCarInnerServiceSMO;
+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.util.DateUtil;
+import com.java110.utils.util.ListUtil;
+import com.java110.utils.util.StringUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 同步车辆信息
+ */
+@Component(value = "sendCarDataToIotAdapt")
+public class SendCarDataToIotAdapt extends DatabusAdaptImpl {
+
+    @Autowired
+    private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl;
+
+    @Autowired
+    private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IOwnerDataToIot ownerDataToIotImpl;
+
+    @Autowired
+    private ISendIot sendIotImpl;
+
+    @Override
+    public void execute(Business business, List<Business> businesses) {
+
+        JSONObject data = business.getData();
+        String memberId = data.getString("memberId");
+        if (StringUtil.isEmpty(memberId)) {
+            throw new IllegalArgumentException("车辆不存在");
+        }
+
+        OwnerCarDto ownerCarDto = new OwnerCarDto();
+        ownerCarDto.setMemberId(memberId);
+        List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
+
+        if (ListUtil.isNull(ownerCarDtos)) {
+            throw new IllegalArgumentException("车辆不存在");
+        }
+
+        OwnerDto ownerDto = new OwnerDto();
+        ownerDto.setMemberId(ownerCarDtos.get(0).getOwnerId());
+        List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
+        if (ListUtil.isNull(ownerDtos)) {
+            throw new IllegalArgumentException("业主不存在");
+        }
+
+        /**
+         * {
+         * “communityId”:”12313”,
+         * “ownerId”:”123123”,
+         * “name”:”张三”,
+         * “link”:”18909711445”,
+         * “carMemberId”:”1231”,
+         * “carNum”:”青A88488”,
+         * “paId”:”1231”,
+         * “psId”:”1231”,
+         * “paNum”:”1231”,
+         * “startTime”:”2024-01-01 11:22:22”,
+         * “endTime”:”2024-12-01 11:22:22”,
+         * “leaseType”:”1231”,
+         * “carTypeCd”:”123123”
+         * }
+         */
+
+        OwnerCarDto tmpOwnerCarDto = ownerCarDtos.get(0);
+
+        JSONObject car = new JSONObject();
+        car.put("communityId", ownerDtos.get(0).getCommunityId());
+        car.put("ownerId", ownerDtos.get(0).getMemberId());
+        car.put("name", ownerDtos.get(0).getName());
+        car.put("link", ownerDtos.get(0).getLink());
+        car.put("carMemberId", tmpOwnerCarDto.getMemberId());
+        car.put("carId", tmpOwnerCarDto.getCarId());
+        car.put("carNum", tmpOwnerCarDto.getCarNum());
+        car.put("paId", tmpOwnerCarDto.getPaId());
+        car.put("psId", tmpOwnerCarDto.getPsId());
+        car.put("paNum", tmpOwnerCarDto.getAreaNum());
+        car.put("psNum", tmpOwnerCarDto.getNum());
+        car.put("carTypeCd", tmpOwnerCarDto.getCarTypeCd());
+        car.put("startTime", DateUtil.getFormatTimeStringA(tmpOwnerCarDto.getStartTime()));
+        car.put("endTime", DateUtil.getFormatTimeStringA(tmpOwnerCarDto.getEndTime()));
+        car.put("leaseType", tmpOwnerCarDto.getLeaseType());
+
+        sendIotImpl.post("/iot/api/car.addCarApi", car);
+    }
+}

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

@@ -0,0 +1,64 @@
+package com.java110.job.adapt.hcIotNew;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.dto.owner.OwnerCarDto;
+import com.java110.dto.owner.OwnerDto;
+import com.java110.dto.system.Business;
+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.util.DateUtil;
+import com.java110.utils.util.ListUtil;
+import com.java110.utils.util.StringUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 同步车辆信息
+ */
+@Component(value = "sendDeleteCarDataToIotAdapt")
+public class SendDeleteCarDataToIotAdapt extends DatabusAdaptImpl {
+
+    @Autowired
+    private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl;
+
+    @Autowired
+    private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IOwnerDataToIot ownerDataToIotImpl;
+
+    @Autowired
+    private ISendIot sendIotImpl;
+
+    @Override
+    public void execute(Business business, List<Business> businesses) {
+
+        JSONObject data = business.getData();
+        String memberId = data.getString("memberId");
+        if (StringUtil.isEmpty(memberId)) {
+            throw new IllegalArgumentException("车辆不存在");
+        }
+
+        OwnerCarDto ownerCarDto = new OwnerCarDto();
+        ownerCarDto.setMemberId(memberId);
+        ownerCarDto.setStatusCd("1");
+        List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
+
+        if (ListUtil.isNull(ownerCarDtos)) {
+            throw new IllegalArgumentException("车辆不存在");
+        }
+
+
+        OwnerCarDto tmpOwnerCarDto = ownerCarDtos.get(0);
+
+        JSONObject car = new JSONObject();
+        car.put("communityId", ownerCarDtos.get(0).getCommunityId());
+        car.put("carMemberId", tmpOwnerCarDto.getMemberId());
+
+        sendIotImpl.post("/iot/api/car.deleteCarApi", car);
+    }
+}

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

@@ -0,0 +1,58 @@
+package com.java110.job.adapt.hcIotNew;
+
+import com.alibaba.fastjson.JSONObject;
+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.job.adapt.hcIotNew.http.ISendIot;
+import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.ListUtil;
+import com.java110.utils.util.StringUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 同步业主信息
+ */
+@Component(value = "sendDeleteOwnerDataToIotAdapt")
+public class SendDeleteOwnerDataToIotAdapt extends DatabusAdaptImpl {
+
+    @Autowired
+    private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IOwnerDataToIot ownerDataToIotImpl;
+
+    @Autowired
+    private ISendIot sendIotImpl;
+    @Override
+    public void execute(Business business, List<Business> businesses) {
+
+        JSONObject data = business.getData();
+        String memberId = data.getString("memberId");
+        if (StringUtil.isEmpty(memberId)) {
+            throw new IllegalArgumentException("未包含业主信息");
+        }
+
+        OwnerDto ownerDto = new OwnerDto();
+        ownerDto.setMemberId(memberId);
+        ownerDto.setStatusCd("1");
+        List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
+
+        if (ListUtil.isNull(ownerDtos)) {
+            throw new IllegalArgumentException("业主不存在");
+        }
+
+        JSONObject car = new JSONObject();
+        car.put("communityId", ownerDtos.get(0).getCommunityId());
+        car.put("ownerId", ownerDtos.get(0).getOwnerId());
+        car.put("memberId", ownerDtos.get(0).getMemberId());
+
+
+        sendIotImpl.post("/iot/api/owner.deleteOwnerApi", car);
+
+    }
+}

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

@@ -0,0 +1,46 @@
+package com.java110.job.adapt.hcIotNew;
+
+import com.alibaba.fastjson.JSONObject;
+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.exception.CmdException;
+import com.java110.utils.util.ListUtil;
+import com.java110.utils.util.StringUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 同步业主信息
+ */
+@Component(value = "sendOwnerDataToIotAdapt")
+public class SendOwnerDataToIotAdapt extends DatabusAdaptImpl {
+
+    @Autowired
+    private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IOwnerDataToIot ownerDataToIotImpl;
+
+    @Override
+    public void execute(Business business, List<Business> businesses) {
+
+        JSONObject data = business.getData();
+        String memberId = data.getString("memberId");
+        if (StringUtil.isEmpty(memberId)) {
+            throw new IllegalArgumentException("未包含业主信息");
+        }
+
+        OwnerDto ownerDto = new OwnerDto();
+        ownerDto.setMemberId(memberId);
+        List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
+
+        if (ListUtil.isNull(ownerDtos)) {
+            throw new IllegalArgumentException("业主不存在");
+        }
+        ownerDataToIotImpl.sendOwnerData(ownerDtos.get(0));
+    }
+}

service-user/src/main/java/com/java110/user/dao/impl/OwnerCarServiceDaoImpl.java

@@ -89,9 +89,9 @@ public class OwnerCarServiceDaoImpl extends BaseServiceDao implements IOwnerCarS
     public List<Map> getOwnerCarInfo(Map info) throws DAOException {
         logger.debug("查询车辆管理信息 入参 info : {}", info);
 
-        List<Map> businessOwnerCarInfos = sqlSessionTemplate.selectList("ownerCarServiceDaoImpl.getOwnerCarInfo", info);
+        List<Map> infos = sqlSessionTemplate.selectList("ownerCarServiceDaoImpl.getOwnerCarInfo", info);
 
-        return businessOwnerCarInfos;
+        return infos;
     }
 
 

service-user/src/main/java/com/java110/user/dao/impl/OwnerV1ServiceDaoImpl.java

@@ -67,9 +67,9 @@ public class OwnerV1ServiceDaoImpl extends BaseServiceDao implements IOwnerV1Ser
     public List<Map> getOwnerInfo(Map info) throws DAOException {
         logger.debug("查询 getOwnerInfo 入参 info : {}",info);
 
-        List<Map> businessOwnerInfos = sqlSessionTemplate.selectList("ownerV1ServiceDaoImpl.getOwnerInfo",info);
+        List<Map> infos = sqlSessionTemplate.selectList("ownerV1ServiceDaoImpl.getOwnerInfo",info);
 
-        return businessOwnerInfos;
+        return infos;
     }