From 196e55ee26196179fa63e8c8ed07b7ab8e71a2e6 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 19 九月 2021 11:25:59 +0800
Subject: [PATCH] 同步 车辆完成
---
service-job/src/main/java/com/java110/job/adapt/hcGov/car/AddCarToHcGovAdapt.java | 88 +++++++++++++++++++++++++++++++++++++------
1 files changed, 75 insertions(+), 13 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/adapt/hcGov/car/AddCarToHcGovAdapt.java b/service-job/src/main/java/com/java110/job/adapt/hcGov/car/AddCarToHcGovAdapt.java
index 77fffd0..822f395 100644
--- a/service-job/src/main/java/com/java110/job/adapt/hcGov/car/AddCarToHcGovAdapt.java
+++ b/service-job/src/main/java/com/java110/job/adapt/hcGov/car/AddCarToHcGovAdapt.java
@@ -19,15 +19,23 @@
import com.alibaba.fastjson.JSONObject;
import com.java110.dto.community.CommunityAttrDto;
import com.java110.dto.community.CommunityDto;
+import com.java110.dto.owner.OwnerCarDto;
+import com.java110.dto.parking.ParkingAreaDto;
+import com.java110.dto.parking.ParkingSpaceDto;
+import com.java110.dto.parkingAreaAttr.ParkingAreaAttrDto;
import com.java110.entity.order.Business;
import com.java110.intf.community.ICommunityInnerServiceSMO;
import com.java110.intf.community.IParkingAreaInnerServiceSMO;
+import com.java110.intf.community.IParkingSpaceInnerServiceSMO;
+import com.java110.intf.user.IOwnerCarInnerServiceSMO;
import com.java110.job.adapt.DatabusAdaptImpl;
import com.java110.job.adapt.hcGov.HcGovConstant;
import com.java110.job.adapt.hcGov.asyn.BaseHcGovSendAsyn;
-import com.java110.po.parking.ParkingAreaPo;
+import com.java110.po.car.OwnerCarPo;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -47,9 +55,15 @@
private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
@Autowired
- private IParkingAreaInnerServiceSMO parkingAreaInnerServiceSMOImpl;
+ private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl;
@Autowired
private BaseHcGovSendAsyn baseHcGovSendAsynImpl;
+
+ @Autowired
+ private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl;
+
+ @Autowired
+ private IParkingAreaInnerServiceSMO parkingAreaInnerServiceSMOImpl;
/**
@@ -59,8 +73,8 @@
@Override
public void execute(Business business, List<Business> businesses) {
JSONObject data = business.getData();
- if (data.containsKey(ParkingAreaPo.class.getSimpleName())) {
- Object bObj = data.get(ParkingAreaPo.class.getSimpleName());
+ if (data.containsKey(OwnerCarPo.class.getSimpleName())) {
+ Object bObj = data.get(OwnerCarPo.class.getSimpleName());
JSONArray businessOwnerCars = null;
if (bObj instanceof JSONObject) {
businessOwnerCars = new JSONArray();
@@ -73,17 +87,17 @@
//JSONObject businessOwnerCar = data.getJSONObject("businessOwnerCar");
for (int bOwnerCarIndex = 0; bOwnerCarIndex < businessOwnerCars.size(); bOwnerCarIndex++) {
JSONObject businessOwnerCar = businessOwnerCars.getJSONObject(bOwnerCarIndex);
- doAddParkingArea(business, businessOwnerCar);
+ doAddOwnerCar(business, businessOwnerCar);
}
}
}
- private void doAddParkingArea(Business business, JSONObject businessFloor) {
+ private void doAddOwnerCar(Business business, JSONObject businessFloor) {
- ParkingAreaPo parkingAreaPo = BeanConvertUtil.covertBean(businessFloor, ParkingAreaPo.class);
+ OwnerCarPo ownerCarPo = BeanConvertUtil.covertBean(businessFloor, OwnerCarPo.class);
CommunityDto communityDto = new CommunityDto();
- communityDto.setCommunityId(parkingAreaPo.getCommunityId());
+ communityDto.setCommunityId(ownerCarPo.getCommunityId());
List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto);
Assert.listNotNull(communityDtos, "鏈寘鍚皬鍖轰俊鎭�");
CommunityDto tmpCommunityDto = communityDtos.get(0);
@@ -94,14 +108,62 @@
extCommunityId = communityAttrDto.getValue();
}
}
+ //鏌ヨ杞﹁締
+ OwnerCarDto ownerCarDto = new OwnerCarDto();
+ ownerCarDto.setCommunityId(ownerCarPo.getCommunityId());
+ ownerCarDto.setCarId(ownerCarPo.getCarId());
+ List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
+
+ Assert.listOnlyOne(ownerCarDtos, "杞﹁締涓嶅瓨鍦�");
+
+ //鏌ヨ澶栭儴鍋滆溅鍦�
+ ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();
+ parkingSpaceDto.setPsId(ownerCarDtos.get(0).getPsId());
+ List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
+ Assert.listOnlyOne(parkingSpaceDtos, "杞︿綅涓嶅瓨鍦�");
+
+ //鏌ヨ 澶栭儴鍋滆溅
+ ParkingAreaDto parkingAreaDto = new ParkingAreaDto();
+ parkingAreaDto.setPaId(parkingSpaceDtos.get(0).getPaId());
+ parkingAreaDto.setCommunityId(parkingSpaceDtos.get(0).getCommunityId());
+ List<ParkingAreaDto> parkingAreaDtos = parkingAreaInnerServiceSMOImpl.queryParkingAreas(parkingAreaDto);
+ Assert.listOnlyOne(parkingAreaDtos, "鍋滆溅鍦轰笉瀛樺湪");
+
+ String extPaId = getExtPaId(parkingAreaDtos.get(0).getAttrs());
+
+ if (StringUtil.isEmpty(extPaId)) {
+ return;
+ }
+
+
JSONObject body = new JSONObject();
- body.put("num", parkingAreaPo.getNum());
- body.put("parkingCount", "0");
- body.put("typeCd", parkingAreaPo.getTypeCd());
+ body.put("carNum", ownerCarDtos.get(0).getCarNum());
+ body.put("carBrand", ownerCarDtos.get(0).getCarBrand());
+ body.put("carType", ownerCarDtos.get(0).getCarType());
+ body.put("carColor", ownerCarDtos.get(0).getCarColor());
+ body.put("startTime", DateUtil.getFormatTimeString(ownerCarDtos.get(0).getStartTime(), DateUtil.DATE_FORMATE_STRING_A));
+ body.put("endTime", DateUtil.getFormatTimeString(ownerCarDtos.get(0).getEndTime(), DateUtil.DATE_FORMATE_STRING_A));
+ body.put("personName", ownerCarDtos.get(0).getOwnerName());
+ body.put("personTel", ownerCarDtos.get(0).getLink());
+ body.put("extPaId", extPaId);
- JSONObject kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, extCommunityId, HcGovConstant.ADD_PARKING_AREA_ACTION, HcGovConstant.COMMUNITY_SECURE);
- baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, communityId, parkingAreaPo.getPaId(), HcGovConstant.COMMUNITY_SECURE);
+ JSONObject kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, extCommunityId, HcGovConstant.ADD_CAR_ACTION, HcGovConstant.COMMUNITY_SECURE);
+ baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, communityId, ownerCarPo.getCarId(), HcGovConstant.COMMUNITY_SECURE);
+ }
+
+ private String getExtPaId(List<ParkingAreaAttrDto> attrs) {
+
+ if (attrs == null || attrs.size() < 1) {
+ return "";
+ }
+
+ for (ParkingAreaAttrDto parkingAreaAttrDto : attrs) {
+ if (parkingAreaAttrDto.getSpecCd().equals(HcGovConstant.EXT_COMMUNITY_ID)) {
+ return parkingAreaAttrDto.getValue();
+ }
+ }
+ return "";
}
}
--
Gitblit v1.8.0