From 4414e39a60a6f3d24e4217dfd2e2ab048621c66a Mon Sep 17 00:00:00 2001
From: 1098226878 <1098226878@qq.com>
Date: 星期三, 01 九月 2021 17:38:50 +0800
Subject: [PATCH] 完善修改楼栋接口
---
service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java | 36 ++++++++++++++++++++----------------
1 files changed, 20 insertions(+), 16 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java b/service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java
index 9b20459..590b6bd 100644
--- a/service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java
+++ b/service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java
@@ -9,6 +9,7 @@
import com.java110.job.adapt.hcGov.asyn.BaseHcGovSendAsyn;
import com.java110.po.hcGovTranslate.HcGovTranslatePo;
import com.java110.po.hcGovTranslateDetail.HcGovTranslateDetailPo;
+import com.java110.utils.cache.MappingCache;
import com.java110.utils.kafka.KafkaFactory;
import com.java110.utils.util.Assert;
import com.java110.utils.util.DateUtil;
@@ -16,6 +17,7 @@
import org.springframework.stereotype.Service;
import java.util.UUID;
+
@Service
public class BaseHcGovSendAsynImpl implements BaseHcGovSendAsyn {
@@ -25,21 +27,21 @@
private IHcGovTranslateDetailInnerServiceSMO hcGovTranslateDetailInnerServiceSMOImpl;
- public JSONObject createHeadersOrBody(JSONObject body,String extCommunityId,String serviceCode,String secure) {
+ public JSONObject createHeadersOrBody(JSONObject body, String extCommunityId, String serviceCode, String secure) {
JSONObject heard = new JSONObject();
heard.put("serviceCode", serviceCode);
- heard.put("extCommunityId",extCommunityId);
+ heard.put("extCommunityId", extCommunityId);
heard.put("tranId", UUID.randomUUID().toString());
heard.put("reqTime", DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_DEFAULT));
- HcGovConstant.generatorProducerSign(heard,body,secure);
+ HcGovConstant.generatorProducerSign(heard, body, secure);
JSONObject kafkaData = new JSONObject();
- kafkaData.put("header",heard);
- kafkaData.put("body",body);
+ kafkaData.put("header", heard);
+ kafkaData.put("body", body);
return kafkaData;
}
- public void saveHcGovLog(JSONObject paramIn,String communityId,String topic,String objId,String secure) {
+ public void saveHcGovLog(JSONObject paramIn, String communityId, String topic, String objId, String secure) {
Assert.hasKeyAndValue(paramIn, "header", "璇锋眰鎶ユ枃涓湭鍖呭惈header");
Assert.hasKeyAndValue(paramIn, "body", "璇锋眰鎶ユ枃涓湭鍖呭惈body");
JSONObject heard = paramIn.getJSONObject("header");
@@ -61,7 +63,7 @@
hcGovTranslatePo.setUpdateTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
hcGovTranslatePo.setRemark("鐗╀笟绯荤粺鑷姩鎺ㄩ�佹ゼ鏍嬩俊鎭埌鏀垮姟绯荤粺");
int flag = hcGovTranslateInnerServiceSMOImpl.saveHcGovTranslate(hcGovTranslatePo);
- if(flag < 1){
+ if (flag < 1) {
throw new IllegalArgumentException("鐗╀笟绯荤粺淇濆瓨妤兼爧鎺ㄩ�佹姤鏂囨棩蹇楀け璐�");
}
HcGovTranslateDetailPo hcGovTranslateDetailPo = new HcGovTranslateDetailPo();
@@ -70,12 +72,12 @@
hcGovTranslateDetailPo.setCommunityId(communityId);
hcGovTranslateDetailPo.setReqBody(paramIn.toJSONString());
flag = hcGovTranslateDetailInnerServiceSMOImpl.saveHcGovTranslateDetail(hcGovTranslateDetailPo);
- if(flag < 1){
+ if (flag < 1) {
throw new IllegalArgumentException("鐗╀笟绯荤粺淇濆瓨妤兼爧鎺ㄩ�佹姤鏂囨槑缁嗘棩蹇楀け璐�");
}
}
- public void updateHcGovLog(JSONObject paramIn) {
+ public void updateHcGovLog(JSONObject paramIn) {
Assert.hasKeyAndValue(paramIn, "header", "璇锋眰鎶ユ枃涓湭鍖呭惈header");
Assert.hasKeyAndValue(paramIn, "body", "璇锋眰鎶ユ枃涓湭鍖呭惈body");
JSONObject heard = paramIn.getJSONObject("header");
@@ -83,29 +85,31 @@
HcGovTranslatePo hcGovTranslatePo = new HcGovTranslatePo();
hcGovTranslatePo.setTranId(heard.getString("tranId"));
- hcGovTranslatePo.setState(ReportDataHeaderDto.RETUR_SUCCESS_CODE);
- if(!Integer.toString(ReportDataHeaderDto.CODE_SUCCESS).equals(heard.getString("code"))){
+ hcGovTranslatePo.setState(ReportDataHeaderDto.RETUR_SUCCESS_CODE);
+ if (!Integer.toString(ReportDataHeaderDto.CODE_SUCCESS).equals(heard.getString("code"))) {
hcGovTranslatePo.setState(ReportDataHeaderDto.RETUR_ERROR_CODE);
}
hcGovTranslatePo.setUpdateTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
int flag = hcGovTranslateInnerServiceSMOImpl.updateHcGovTranslate(hcGovTranslatePo);
- if(flag < 1){
+ if (flag < 1) {
throw new IllegalArgumentException("鏇存柊鐗╀笟绯荤粺淇濆瓨妤兼爧鏃ュ織澶辫触");
}
HcGovTranslateDetailPo hcGovTranslateDetailPo = new HcGovTranslateDetailPo();
hcGovTranslateDetailPo.setTranId(hcGovTranslatePo.getTranId());
hcGovTranslateDetailPo.setResBody(paramIn.toJSONString());
flag = hcGovTranslateDetailInnerServiceSMOImpl.updateHcGovTranslateDetail(hcGovTranslateDetailPo);
- if(flag < 1){
+ if (flag < 1) {
throw new IllegalArgumentException("鐗╀笟绯荤粺淇濆瓨妤兼爧鎺ㄩ�佹姤鏂囨槑缁嗘棩蹇楀け璐�");
}
}
- public void sendKafka(String topic,JSONObject massage,String communityId,String objId,String secure) {
+ public void sendKafka(String topic, JSONObject massage, String communityId, String objId, String secure) {
try {
- KafkaFactory.sendKafkaMessage(topic,massage.toJSONString());
- saveHcGovLog(massage,communityId,topic,objId,secure);
+ if ("TRUE".equals(MappingCache.getValue(HcGovConstant.GOV_DOMAIN, HcGovConstant.GOV_SWITCH))) {
+ KafkaFactory.sendKafkaMessage(topic, massage.toJSONString());
+ saveHcGovLog(massage, communityId, topic, objId, secure);
+ }
} catch (Exception e) {
e.printStackTrace();
}
--
Gitblit v1.8.0