From f0d3683e8591f220112d69e92e97e5da8f81d457 Mon Sep 17 00:00:00 2001
From: 1098226878 <1098226878@qq.com>
Date: 星期三, 01 九月 2021 17:23:38 +0800
Subject: [PATCH] 楼栋回写
---
service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java | 32 ++++++++++++++++++++++++++++++--
1 files changed, 30 insertions(+), 2 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 13d6e41..9b20459 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
@@ -2,6 +2,7 @@
import com.alibaba.fastjson.JSONObject;
import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.reportData.ReportDataHeaderDto;
import com.java110.intf.common.IHcGovTranslateDetailInnerServiceSMO;
import com.java110.intf.common.IHcGovTranslateInnerServiceSMO;
import com.java110.job.adapt.hcGov.HcGovConstant;
@@ -38,7 +39,7 @@
}
- protected 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");
@@ -56,7 +57,7 @@
hcGovTranslatePo.setReqTime(heard.getString("reqTime"));
hcGovTranslatePo.setServiceCode(heard.getString("serviceCode"));
hcGovTranslatePo.setSign(heard.getString("sign"));
- hcGovTranslatePo.setState("1001");
+ hcGovTranslatePo.setState(ReportDataHeaderDto.RETUR_CODE);
hcGovTranslatePo.setUpdateTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
hcGovTranslatePo.setRemark("鐗╀笟绯荤粺鑷姩鎺ㄩ�佹ゼ鏍嬩俊鎭埌鏀垮姟绯荤粺");
int flag = hcGovTranslateInnerServiceSMOImpl.saveHcGovTranslate(hcGovTranslatePo);
@@ -74,6 +75,33 @@
}
}
+ public void updateHcGovLog(JSONObject paramIn) {
+ Assert.hasKeyAndValue(paramIn, "header", "璇锋眰鎶ユ枃涓湭鍖呭惈header");
+ Assert.hasKeyAndValue(paramIn, "body", "璇锋眰鎶ユ枃涓湭鍖呭惈body");
+ JSONObject heard = paramIn.getJSONObject("header");
+ JSONObject body = paramIn.getJSONObject("body");
+
+ 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_ERROR_CODE);
+ }
+
+ hcGovTranslatePo.setUpdateTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+ int flag = hcGovTranslateInnerServiceSMOImpl.updateHcGovTranslate(hcGovTranslatePo);
+ 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){
+ throw new IllegalArgumentException("鐗╀笟绯荤粺淇濆瓨妤兼爧鎺ㄩ�佹姤鏂囨槑缁嗘棩蹇楀け璐�");
+ }
+ }
+
public void sendKafka(String topic,JSONObject massage,String communityId,String objId,String secure) {
try {
KafkaFactory.sendKafkaMessage(topic,massage.toJSONString());
--
Gitblit v1.8.0