加入字母车位同步功能

java110-db/src/main/resources/mapper/user/OwnerCarServiceDaoImplMapper.xml

@@ -368,4 +368,19 @@
 
     </select>
 
+    <select id="queryOwnerParkingSpaceCount" parameterType="Map" resultType="Map">
+        select count(DISTINCT t.ps_id) count
+        from owner_car t
+        where
+         t.ps_id != '-1'
+        <if test="statusCd !=null and statusCd != ''">
+            and t.status_cd= #{statusCd}
+        </if>
+        <if test="ownerId !=null and ownerId != ''">
+            and t.owner_id= #{ownerId}
+        </if>
+        <if test="communityId !=null and communityId != ''">
+            and t.community_id= #{communityId}
+        </if>
+    </select>
 </mapper>

java110-interface/src/main/java/com/java110/intf/user/IOwnerCarInnerServiceSMO.java

@@ -43,4 +43,15 @@ public interface IOwnerCarInnerServiceSMO {
 
     @RequestMapping(value = "/freshCarIds", method = RequestMethod.POST)
     List<ImportRoomFee> freshCarIds(@RequestBody List<ImportRoomFee> tmpImportCarFees);
+
+
+    /**
+     * <p>查询业主车位数</p>
+     *
+     *
+     * @param ownerCarDto 数据对象分享
+     * @return OwnerCarDto 对象数据
+     */
+    @RequestMapping(value = "/queryOwnerParkingSpaceCount", method = RequestMethod.POST)
+    long queryOwnerParkingSpaceCount(@RequestBody OwnerCarDto ownerCarDto);
 }

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

@@ -117,6 +117,11 @@ public class AddCarToIotAdapt extends DatabusAdaptImpl {
         List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
         Assert.listOnlyOne(ownerCarDtos, "未找到车位");
 
+        //查询业主车位数量 主要是做字母车位
+        ownerCarDto = new OwnerCarDto();
+        ownerCarDto.setCarNum(ownerCarPo.getCarNum());
+        ownerCarDto.setCommunityId(ownerCarPo.getCommunityId());
+        long parkingSpaceCount = ownerCarInnerServiceSMOImpl.queryOwnerParkingSpaceCount(ownerCarDto);
 
         JSONObject postParameters = new JSONObject();
 
@@ -128,6 +133,7 @@ public class AddCarToIotAdapt extends DatabusAdaptImpl {
         postParameters.put("personName", ownerCarDtos.get(0).getOwnerName());
         postParameters.put("personTel", ownerCarDtos.get(0).getLink());
         postParameters.put("extCarId", ownerCarDtos.get(0).getCarId());
+        postParameters.put("parkingNum", parkingSpaceCount);
         postParameters.put("extCommunityId", ownerCarDtos.get(0).getCommunityId());
         hcOwnerCarAsynImpl.addOwnerCar(postParameters);
     }

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

@@ -115,7 +115,10 @@ public class ModifyCarToIotAdapt extends DatabusAdaptImpl {
         List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
         Assert.listOnlyOne(ownerCarDtos, "未找到车位");
 
-
+        ownerCarDto = new OwnerCarDto();
+        ownerCarDto.setCarNum(ownerCarPo.getCarNum());
+        ownerCarDto.setCommunityId(ownerCarPo.getCommunityId());
+        long parkingSpaceCount = ownerCarInnerServiceSMOImpl.queryOwnerParkingSpaceCount(ownerCarDto);
         JSONObject postParameters = new JSONObject();
 
         postParameters.put("carNum", ownerCarDtos.get(0).getCarNum());
@@ -126,6 +129,7 @@ public class ModifyCarToIotAdapt extends DatabusAdaptImpl {
         postParameters.put("personTel", ownerCarDtos.get(0).getLink());
         postParameters.put("personId", ownerCarDtos.get(0).getOwnerId());
         postParameters.put("extCarId", ownerCarDtos.get(0).getCarId());
+        postParameters.put("parkingNum", parkingSpaceCount);
         postParameters.put("extCommunityId", ownerCarDtos.get(0).getCommunityId());
         hcOwnerCarAsynImpl.updateOwnerCar(postParameters);
     }

service-user/src/main/java/com/java110/user/dao/IOwnerCarServiceDao.java

@@ -72,4 +72,5 @@ public interface IOwnerCarServiceDao {
      */
     int queryOwnerCarsCount(Map info);
 
+    long queryOwnerParkingSpaceCount(Map beanCovertMap);
 }

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

@@ -130,5 +130,17 @@ public class OwnerCarServiceDaoImpl extends BaseServiceDao implements IOwnerCarS
         return Integer.parseInt(businessOwnerCarInfos.get(0).get("count").toString());
     }
 
+    @Override
+    public long queryOwnerParkingSpaceCount(Map info) {
+        logger.debug("查询车辆管理数据 入参 info : {}", info);
+
+        List<Map> businessOwnerCarInfos = sqlSessionTemplate.selectList("ownerCarServiceDaoImpl.queryOwnerParkingSpaceCount", info);
+        if (businessOwnerCarInfos.size() < 1) {
+            return 0;
+        }
+
+        return Integer.parseInt(businessOwnerCarInfos.get(0).get("count").toString());
+    }
+
 
 }

service-user/src/main/java/com/java110/user/smo/impl/OwnerCarInnerServiceSMOImpl.java

@@ -118,6 +118,11 @@ public class OwnerCarInnerServiceSMOImpl extends BaseServiceSMO implements IOwne
         return tmpImportCarFees;
     }
 
+    @Override
+    public long queryOwnerParkingSpaceCount(@RequestBody OwnerCarDto ownerCarDto) {
+        return ownerCarServiceDaoImpl.queryOwnerParkingSpaceCount(BeanConvertUtil.beanCovertMap(ownerCarDto));
+    }
+
     public IOwnerCarServiceDao getOwnerCarServiceDaoImpl() {
         return ownerCarServiceDaoImpl;
     }