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/parkArea/EditParkingAreaToHcGovAdapt.java | 39 +++++++++++++++++++++++++++++++++++++--
1 files changed, 37 insertions(+), 2 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/adapt/hcGov/parkArea/EditParkingAreaToHcGovAdapt.java b/service-job/src/main/java/com/java110/job/adapt/hcGov/parkArea/EditParkingAreaToHcGovAdapt.java
index 47c1ffb..f7471ca 100644
--- a/service-job/src/main/java/com/java110/job/adapt/hcGov/parkArea/EditParkingAreaToHcGovAdapt.java
+++ b/service-job/src/main/java/com/java110/job/adapt/hcGov/parkArea/EditParkingAreaToHcGovAdapt.java
@@ -19,9 +19,12 @@
import com.alibaba.fastjson.JSONObject;
import com.java110.dto.community.CommunityAttrDto;
import com.java110.dto.community.CommunityDto;
+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.job.adapt.DatabusAdaptImpl;
import com.java110.job.adapt.hcGov.HcGovConstant;
@@ -29,6 +32,7 @@
import com.java110.po.parking.ParkingAreaPo;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -51,7 +55,8 @@
private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl;
@Autowired
private BaseHcGovSendAsyn baseHcGovSendAsynImpl;
-
+ @Autowired
+ private IParkingAreaInnerServiceSMO parkingAreaInnerServiceSMOImpl;
/**
* @param business 褰撳墠澶勭悊涓氬姟
@@ -103,14 +108,44 @@
parkingSpaceDto.setPaId(parkingAreaPo.getPaId());
int count = parkingSpaceInnerServiceSMOImpl.queryParkingSpacesCount(parkingSpaceDto);
+ //鏌ヨ 澶栭儴鍋滆溅
+ ParkingAreaDto parkingAreaDto = new ParkingAreaDto();
+ parkingAreaDto.setPaId(parkingAreaPo.getPaId());
+ parkingAreaDto.setCommunityId(parkingAreaPo.getCommunityId());
+ List<ParkingAreaDto> parkingAreaDtos = parkingAreaInnerServiceSMOImpl.queryParkingAreas(parkingAreaDto);
+ Assert.listOnlyOne(parkingAreaDtos, "鍋滆溅鍦轰笉瀛樺湪");
+
+ String extPaId = getExtPaId(parkingAreaDtos.get(0).getAttrs());
+
JSONObject body = new JSONObject();
body.put("num", parkingAreaPo.getNum());
body.put("parkingCount", count);
body.put("typeCd", parkingAreaPo.getTypeCd());
- body.put("extPaId", parkingAreaPo.getPaId());
+ //濡傛灉涓虹┖ 璧版坊鍔犳帴鍙�
+ if (StringUtil.isEmpty(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);
+ return;
+ }
+ body.put("extPaId", extPaId);
JSONObject kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, extCommunityId, HcGovConstant.EDIT_PARKING_AREA_ACTION, HcGovConstant.COMMUNITY_SECURE);
baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, communityId, parkingAreaPo.getPaId(), 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