From db28fdce5ee36eeb9bbfdaa746351c341c766a3c Mon Sep 17 00:00:00 2001
From: yuqh <123456>
Date: Wed, 14 Aug 2024 10:57:58 +0800
Subject: [PATCH] 1
---
.../plugin/KunBFlowSubPluginInitializer.java | 130 ++++++++++++++++++
.../plugin/a8bill/util/NingBBankUtil.java | 4 +-
.../frame/plugin/a8bill/util/OaFlowUtil.java | 27 ++++
.../plugin/PayApplyPluginInitializer.java | 3 +-
.../spring/spring-buildpackage-plugin.xml | 1 +
5 files changed, 162 insertions(+), 3 deletions(-)
create mode 100644 buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/plugin/KunBFlowSubPluginInitializer.java
create mode 100644 buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/util/OaFlowUtil.java
diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/plugin/KunBFlowSubPluginInitializer.java b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/plugin/KunBFlowSubPluginInitializer.java
new file mode 100644
index 00000000..4704a03c
--- /dev/null
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/plugin/KunBFlowSubPluginInitializer.java
@@ -0,0 +1,130 @@
+package com.hzya.frame.plugin.a8bill.plugin;
+
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson2.JSON;
+import com.hzya.frame.base.PluginBaseEntity;
+import com.hzya.frame.plugin.a8bill.dao.IPayBillPluginInitializerDao;
+import com.hzya.frame.plugin.a8bill.entity.PayBillEntity;
+import com.hzya.frame.plugin.a8bill.util.NingBBankUtil;
+import com.hzya.frame.plugin.a8bill.util.OaFlowUtil;
+import com.hzya.frame.web.entity.JsonResultEntity;
+import org.apache.commons.collections.CollectionUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 堃博OA单据推送宁波银行
+ *
+ * @author makejava
+ * @since 2024年7月10日14:13:18
+ */
+public class KunBFlowSubPluginInitializer extends PluginBaseEntity{
+ Logger logger = LoggerFactory.getLogger(KunBFlowSubPluginInitializer.class);
+ @Autowired
+ private IPayBillPluginInitializerDao payBillDao;
+ @Override
+ public void initialize() {
+ logger.info(getPluginLabel() + "執行初始化方法initialize()");
+ }
+
+ @Override
+ public void destroy() {
+ logger.info(getPluginLabel() + "執行銷毀方法destroy()");
+ }
+
+ @Override
+ public String getPluginId() {
+ return "KunBFlowSubPluginInitializer";
+ }
+
+ @Override
+ public String getPluginName() {
+ return "KunBFlowSubPluginInitializer插件";
+ }
+
+ @Override
+ public String getPluginLabel() {
+ return "KunBFlowSubPluginInitializer";
+ }
+
+ @Override
+ public String getPluginType() {
+ return "1";
+ }
+ @Override
+ public JsonResultEntity executeBusiness(JSONObject requestJson) {
+ PayBillEntity oaBillEntity = new PayBillEntity();
+ String dataSourceCode = "KUNBOA";
+ oaBillEntity.setDataSourceCode(dataSourceCode);
+ StringBuffer stringBuffer = new StringBuffer();
+ stringBuffer.append("select * from v_hzya_pay where payState ='1'");
+ try {
+ List<HashMap<String, Object>> hashMaps = payBillDao.getOaBillData(stringBuffer.toString(),oaBillEntity);
+ if(CollectionUtils.isNotEmpty(hashMaps)){
+ for (HashMap<String, Object> hashMap : hashMaps) {
+ JSONObject main = new JSONObject();
+ for(String key:hashMap.keySet()) {
+ main.put(key, hashMap.get(key));
+ }
+ String affairId = main.getString("affair_id");
+ String memberId = main.getString("member_id");
+ String loginName = main.getString("loginName");
+ if(StrUtil.isNotEmpty(affairId)&& StrUtil.isNotEmpty(memberId)){
+ JSONObject tokenRes = new JSONObject();
+ tokenRes.put("loginName",loginName);
+ logger.info("获取token请求参数："+tokenRes.toString());
+ String tokenResult = OaFlowUtil.sendOAToEsb(tokenRes.toString(),"8000320000");
+ logger.info("获取token请求返回："+tokenResult);
+ //通过当前处理人获取token
+ Map res = new HashMap();
+ res.put("affairId", affairId);
+ res.put("memberid", memberId);//当前处理人ID
+ res.put("comment", "自动审批");//处理意见
+ res.put("attitude", "1");//态度：1同意，2不同意，0已阅
+ logger.info("流程处理请求参数："+JSON.toJSONString(res));
+ String result = OaFlowUtil.sendOAToEsb(JSON.toJSONString(res),"8000320001");
+ logger.info("流程处理请求返回："+result);
+ }
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return new JsonResultEntity("成功",true,new JsonResultEntity());
+ }
+
+ public String formatStatus(String status){
+
+ Map<String,String> statusMap = new HashMap<>();
+ statusMap.put("0","交易成功");
+ statusMap.put("-2","已删除");
+ statusMap.put("-3","审批打回交易关闭");
+ statusMap.put("2","交易失败");
+ statusMap.put("4","交易失败，资金下拨失败");
+ statusMap.put("5","联动支付失败，资金退回成功");
+ statusMap.put("6","联动支付失败，资金退回查证中、");
+ statusMap.put("96","联动支付失败，资金退回失败");
+ statusMap.put("112","请款失败");
+ statusMap.put("-1","驳回");
+ statusMap.put("1","交易待查证");
+ statusMap.put("3","待发送");
+ statusMap.put("95","审批通过");
+ statusMap.put("7","暂存");
+ statusMap.put("-4","经办撤回");
+ statusMap.put("111","请款查证中");
+ statusMap.put("113","请款成功，交易待发送");
+ statusMap.put("114","联动支付成功，智能支付交易待发送");
+ if(Long.valueOf(status)>=11 && Long.valueOf(status) <=94){
+ return "待审批";
+ }
+ return statusMap.get(status);
+ }
+}
diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/util/NingBBankUtil.java b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/util/NingBBankUtil.java
index a63026cf..98578442 100644
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/util/NingBBankUtil.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/util/NingBBankUtil.java
@@ -21,8 +21,8 @@ import java.util.List;
public class NingBBankUtil {
public static String sendOAToNbBankEsb(String parm,String apiCode){
- String baseUrl = "http://127.0.0.1:8901/kangarooDataCenterV3/entranceController/externalCallInterface";
-// String baseUrl = "http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterface";
+// String baseUrl = "http://127.0.0.1:8901/kangarooDataCenterV3/entranceController/externalCallInterface";
+ String baseUrl = "http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterface";
// System.out.println("推送参数"+parm);
String result = HttpRequest.post(baseUrl)
.header("appId", "800031")//头信息，多个头信息多次调用此方法即可
diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/util/OaFlowUtil.java b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/util/OaFlowUtil.java
new file mode 100644
index 00000000..280617f0
--- /dev/null
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/util/OaFlowUtil.java
@@ -0,0 +1,27 @@
+package com.hzya.frame.plugin.a8bill.util;
+
+import cn.hutool.http.HttpRequest;
+
+/**
+ * com.hzya.frame.u9c.util
+ *
+ * @author yqh
+ * @date 2023-10 -25 15:26
+ */
+
+public class OaFlowUtil {
+ public static String sendOAToEsb(String parm,String apiCode){
+// String baseUrl = "http://127.0.0.1:8901/kangarooDataCenterV3/entranceController/externalCallInterface";
+ String baseUrl = "http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterface";
+// System.out.println("推送参数"+parm);
+ String result = HttpRequest.post(baseUrl)
+ .header("appId", "800032")//头信息，多个头信息多次调用此方法即可
+ .header("apiCode", apiCode)//头信息，多个头信息多次调用此方法即可
+ .header("publicKey", "ZJYAWb7lhAUTYqekPkU+uHJv1/ObJxb7dT7sD8HPRDGAgyhCe7eDIk+3zDUT+v578prj")//头信息，多个头信息多次调用此方法即可
+ .header("secretKey", "fviZnLBsQUAGF8w8FSOdJi7XlIm/XAZclMxRagDLfTyJFlvnIBF3w66Hrpfzs8cYj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=")//头信息，多个头信息多次调用此方法即可
+ .body(parm)//表单内容
+ .timeout(20000)//超时，毫秒
+ .execute().body();
+ return result;
+ }
+}
diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayApplyPluginInitializer.java b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayApplyPluginInitializer.java
index 36baa131..588538a6 100644
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayApplyPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayApplyPluginInitializer.java
@@ -102,8 +102,9 @@ public class PayApplyPluginInitializer extends PluginBaseEntity {
requestJson.remove("jsonStr");
paymentEntity = JSONObject.parseObject(requestJson.toString(),PaymentEntity.class);
}
- if (null == paymentEntity)
+ if (null == paymentEntity) {
paymentEntity = new PaymentEntity();
+ }
//支付申请
paymentEntity.setOaId("8475071606892874568");
cbsPluginService.applyPay(paymentEntity);
diff --git a/buildpackage/src/main/resources/cfgHome/plugin/payBill/spring/spring-buildpackage-plugin.xml b/buildpackage/src/main/resources/cfgHome/plugin/payBill/spring/spring-buildpackage-plugin.xml
index 40709ed3..33dfdd47 100644
--- a/buildpackage/src/main/resources/cfgHome/plugin/payBill/spring/spring-buildpackage-plugin.xml
+++ b/buildpackage/src/main/resources/cfgHome/plugin/payBill/spring/spring-buildpackage-plugin.xml
@@ -5,4 +5,5 @@
<bean name="RecBillPluginInitializer" class="com.hzya.frame.plugin.a8bill.plugin.RecBillPluginInitializer" />
<bean name="KunBPayBillPluginInitializer" class="com.hzya.frame.plugin.a8bill.plugin.KunBPayBillPluginInitializer" />
<bean name="KunBNingBBankPluginInitializer" class="com.hzya.frame.plugin.a8bill.plugin.KunBNingBBankPluginInitializer" />
+<bean name="KunBFlowSubPluginInitializer" class="com.hzya.frame.plugin.a8bill.plugin.KunBFlowSubPluginInitializer" />
</beans>