From 6da808c02e3044c485f2180113287578a471a229 Mon Sep 17 00:00:00 2001 From: calyrex <2213354201@qq.com> Date: Fri, 17 Jan 2025 10:22:15 +0800 Subject: [PATCH] 80 files update --- .../action/K3_Check_CustomerInfo_Action.java | 90 ++++++++++++ .../action/K3_Check_SupplierInfo_Action.java | 93 ++++++++++++ .../action/K3_Get_CustomerInfo_Action.java | 137 ++++++++++++++++++ .../action/K3_Get_SupplierInfo_Action.java | 136 +++++++++++++++++ 4 files changed, 456 insertions(+) create mode 100644 secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Check_CustomerInfo_Action.java create mode 100644 secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Check_SupplierInfo_Action.java create mode 100644 secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Get_CustomerInfo_Action.java create mode 100644 secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Get_SupplierInfo_Action.java diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Check_CustomerInfo_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Check_CustomerInfo_Action.java new file mode 100644 index 0000000..d4dc86c --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Check_CustomerInfo_Action.java @@ -0,0 +1,90 @@ +package com.weaver.seconddev.interfaces.workflow.action; + +import cn.hutool.json.JSONArray; +import cn.hutool.json.JSONObject; +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface; +import com.weaver.seconddev.interfaces.k3.CallK3CustomerService; +import com.weaver.seconddev.interfaces.k3.CustomerServiceStub; +import com.weaver.verupgrade.soa.workflow.request.RequestInfo; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @Author: calyrex + * @CreateTime: 2025-01-17 + * @Description: K3_Check_CustomerInfo动作流调用 + */ +@org.springframework.stereotype.Service("workflow_action_K3_Check_CustomerInfo_Action") +@Slf4j +public class K3_Check_CustomerInfo_Action implements EsbServerlessRpcRemoteInterface { + + @Autowired + private RequestInfo requestInfoTemp; + @Override + public WeaResult> execute(Map params) { + log.info("K3_Check_CustomerInfo_Action execute start"); + log.info("K3_Check_CustomerInfo_Action execute params : " + params); + try { + String datacenterid = null2String(params.get("datacenterid")); //数据中心 + String custname= null2String(params.get("custname")); //客户名称 + String custnumber = null2String(params.get("custnumber")); //客户编号 + String code = "0"; + String message = ""; + String issuccess = ""; + String result = ""; + CustomerServiceStub.CustomerSearchReq req = new CustomerServiceStub.CustomerSearchReq(); + req.setUser("oa"); + req.setPwd("k3cloud_htgd"); + req.setFName(custname); + req.setFNumber(custnumber); + req.setDataCenterID(datacenterid); + CallK3CustomerService services = new CallK3CustomerService(); + CustomerServiceStub.CustomerSearchRes res = services.getCustMsg(req); + code = res.getCode(); + message = res.getMessage(); + issuccess = res.getIsSuccess(); + result = res.getResult(); + Map resultJson=new HashMap<>(); + resultJson.put("code",code); + resultJson.put("message",message); + resultJson.put("IsSuccess",issuccess); + resultJson.put("result",result); + List> customers = new ArrayList<>(); + if(!result.equals("0")) { + CustomerServiceStub.ArrayOfCustSample supsample = res.getCustSamples(); + CustomerServiceStub.CustSample[] arrs = supsample.getCustSample(); + if (arrs != null && arrs.length > 0) { + for (int i = 0; i < arrs.length; i++) { + Map item = new HashMap<>(); + item.put("custname", arrs[i].getFCustName()); + item.put("custnumber", arrs[i].getFCustNumber()); + customers.add(item); + } + } + } + resultJson.put("customers",customers); + return WeaResult.success(resultJson); + }catch (Exception e){ + log.error("K3_Check_CustomerInfo_Action execute error", e); + return WeaResult.fail(500, "执行异常", e); + } + } + + public static String null2String(String s){ + return s == null ? "" : s; + } + + public static String null2String(Object o){ + return o == null ? "" : o.toString(); + } + + public static String null2String(String s1,String s2){ + return s1 == null ? (s2 == null ? "" : s2) : s1; + } +} diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Check_SupplierInfo_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Check_SupplierInfo_Action.java new file mode 100644 index 0000000..289a3de --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Check_SupplierInfo_Action.java @@ -0,0 +1,93 @@ +package com.weaver.seconddev.interfaces.workflow.action; + +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface; +import com.weaver.seconddev.interfaces.k3.CallK3SupplierServices; +import com.weaver.seconddev.interfaces.k3.SupplierServiceStub; +import com.weaver.verupgrade.soa.workflow.request.RequestInfo; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @Author: calyrex + * @CreateTime: 2025-01-17 + * @Description: K3_Check_SupplierInfo动作流 + */ + +@org.springframework.stereotype.Service("workflow_action_K3_Check_SupplierInfo_Action") +@Slf4j +public class K3_Check_SupplierInfo_Action implements EsbServerlessRpcRemoteInterface { + + @Autowired + private RequestInfo requestInfoTemp; + @Override + public WeaResult> execute(Map params) { + log.info("K3_Check_SupplierInfo_Action execute start"); + log.info("K3_Check_SupplierInfo_Action execute params : " + params); + try { + String datacenterid = null2String(params.get("datacenterid")); //数据中心 + String supname= null2String(params.get("supname")); //供应商名称 + String supnumber = null2String(params.get("supnumber")); //供应商编号 + String code = "0"; + String message = ""; + String issuccess = ""; + String result = ""; + SupplierServiceStub.SupplierSearchReq req = new SupplierServiceStub.SupplierSearchReq(); + req.setUser("oa"); + req.setPwd("k3cloud_htgd"); + req.setFName(supname); + req.setFNumber(supnumber); + req.setDataCenterID(datacenterid); + CallK3SupplierServices services = new CallK3SupplierServices(); + SupplierServiceStub.SupplierSearchRes res = services.getSupMsg(req); + code = res.getCode(); + message = res.getMessage(); + issuccess = res.getIsSuccess(); + result = res.getResult(); + + + Map resultJson=new HashMap<>(); + resultJson.put("code",code); + resultJson.put("message",message); + resultJson.put("IsSuccess",issuccess); + resultJson.put("result",result); + + List> suppliers = new ArrayList<>(); + + if(!result.equals("0")) { + SupplierServiceStub.ArrayOfSupSample supsample = res.getSupSamples(); + SupplierServiceStub.SupSample[] arrs = supsample.getSupSample(); + if (arrs != null && arrs.length > 0) { + for (int i = 0; i < arrs.length; i++) { + Map item = new HashMap<>(); + item.put("supname", arrs[i].getFSupName()); + item.put("supnumber", arrs[i].getFSupNumber()); + suppliers.add(item); + } + } + } + resultJson.put("suppliers",suppliers); + return WeaResult.success(resultJson); + }catch (Exception e){ + log.error("K3_Check_SupplierInfo_Action execute error", e); + return WeaResult.fail(500, "执行异常", e); + } + } + + public static String null2String(String s){ + return s == null ? "" : s; + } + + public static String null2String(Object o){ + return o == null ? "" : o.toString(); + } + + public static String null2String(String s1,String s2){ + return s1 == null ? (s2 == null ? "" : s2) : s1; + } +} diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Get_CustomerInfo_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Get_CustomerInfo_Action.java new file mode 100644 index 0000000..f2c5f77 --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Get_CustomerInfo_Action.java @@ -0,0 +1,137 @@ +package com.weaver.seconddev.interfaces.workflow.action; + +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface; +import com.weaver.seconddev.interfaces.k3.CallK3CustomerService; +import com.weaver.seconddev.interfaces.k3.CustomerServiceStub; +import com.weaver.verupgrade.soa.workflow.request.RequestInfo; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @Author: calyrex + * @CreateTime: 2025-01-17 + * @Description: K3_Get_CustomerInfo动作流调用 + */ + +@org.springframework.stereotype.Service("workflow_action_K3_Get_CustomerInfo_Action") +@Slf4j +public class K3_Get_CustomerInfo_Action implements EsbServerlessRpcRemoteInterface { + + @Autowired + private RequestInfo requestInfoTemp; + @Override + public WeaResult> execute(Map params) { + log.info("K3_Get_CustomerInfo_Action execute start"); + log.info("K3_Get_CustomerInfo_Action execute params : " + params); + try { + String datacenterid = null2String(params.get("datacenterid")); //数据中心 + String custname= null2String(params.get("custname")); //供应商名称 + String custnumber = null2String(params.get("custnumber")); //供应商编号 + String code = "0"; + String message = ""; + String issuccess = ""; + String result = ""; + + CustomerServiceStub.CustomerSearchReq req = new CustomerServiceStub.CustomerSearchReq(); + req.setUser("oa"); + req.setPwd("k3cloud_htgd"); + req.setFName(custname); + req.setFNumber(custnumber); + req.setDataCenterID(datacenterid); + + CallK3CustomerService service = new CallK3CustomerService(); + CustomerServiceStub.CustomerReturn res = service.getCustomer(req); + Map resultJson=new HashMap<>(); + resultJson.put("code",code); + resultJson.put("message",message); + resultJson.put("IsSuccess",issuccess); + resultJson.put("result",result); + CustomerServiceStub.Customer customer = res.getCustomer(); + Map supJson = new HashMap<>(); + if(customer!=null){ + supJson.put("FCustName",customer.getFCustName());//客户名称 + supJson.put("FCustNumber",customer.getFCustNumber());//客户代码 + supJson.put("Fgroup",customer.getFGroup());//客户分组分组 + supJson.put("FGroupName",customer.getFGroupName());//客户分组名称 + supJson.put("FCustClassify",customer.getFCustClassify());//供应商类别 + supJson.put("FCustCLASSIFYNAME",customer.getFCustCLASSIFYNAME());//供应商类别名称 + supJson.put("FTAXREGISTERCODE",customer.getFTAXREGISTERCODE());//统一社会信用代码 + supJson.put("FTRADINGCURRID",customer.getFTRADINGCURRID());//结算币别 + supJson.put("FRECCONDITIONID",customer.getFRECCONDITIONID());//付款条件 + supJson.put("FTaxRateId",customer.getFTaxRate());//默认税率 + supJson.put("F_HTGD_RELATEDTYPE",customer.getF_HTGD_RELATEDTYPE());//关联方属性 + CustomerServiceStub.ArrayOfOrganization org = customer.getListOrgs(); + String orgcode = ""; + String orgname = ""; + if (org != null) { + CustomerServiceStub.Organization[] orgArr = org.getOrganization(); + + if(orgArr!=null){ + for(int m=0;m contactJson = new HashMap<>(); + if(contact!=null) { + contactJson.put("Fcontact", contact.getFCONTACT()); //联系人 + contactJson.put("FBizAddress", contact.getFBIZADDRESS());//通讯地址 + contactJson.put("FMobile", contact.getFMOBILE());//手机 + contactJson.put("Ftel", contact.getFTEL());//电话 + contactJson.put("FFax", contact.getFFAX());//传真 + contactJson.put("Femail", contact.getFEMAIL());//电子邮箱 + } + supJson.put("contact",contactJson); + CustomerServiceStub.ArrayOfCustBank bankinfo = customer.getBankList(); + if(bankinfo!=null) { + CustomerServiceStub.CustBank[] bankarr = bankinfo.getCustBank(); + List> bankJsonarr = new ArrayList<>(); + if(bankarr!=null && bankarr.length>0){ + for (int i=0; i item = new HashMap<>(); + item.put("FBankHolder",bankarr[i].getFBankHolder()); + item.put("FBankCode",bankarr[i].getFBankCode()); + item.put("FOPENBANKNAME",bankarr[i].getFOPENBANKNAME()); + item.put("FCNAPS",bankarr[i].getFCNAPS()); + bankJsonarr.add(item); + } + } + supJson.put("banklist",bankJsonarr); + }else{ + supJson.put("banklist",new ArrayList<>()); + } + } + resultJson.put("customer",supJson); + return WeaResult.success(resultJson); + }catch (Exception e){ + log.error("K3_Get_CustomerInfo_Action execute error : " + e.getMessage()); + return WeaResult.fail(500, "执行异常", e); + } + } + + public static String null2String(String s){ + return s == null ? "" : s; + } + + public static String null2String(Object o){ + return o == null ? "" : o.toString(); + } + + public static String null2String(String s1,String s2){ + return s1 == null ? (s2 == null ? "" : s2) : s1; + } +} diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Get_SupplierInfo_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Get_SupplierInfo_Action.java new file mode 100644 index 0000000..b4b1746 --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3_Get_SupplierInfo_Action.java @@ -0,0 +1,136 @@ +package com.weaver.seconddev.interfaces.workflow.action; + +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface; +import com.weaver.seconddev.interfaces.k3.CallK3SupplierServices; +import com.weaver.seconddev.interfaces.k3.SupplierServiceStub; +import com.weaver.verupgrade.soa.workflow.request.RequestInfo; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @Author: calyrex + * @CreateTime: 2025-01-17 + * @Description: K3_Get_SupplierInfo动作流调用 + */ + +@org.springframework.stereotype.Service("workflow_action_K3_Get_CustomerInfo_Action") +@Slf4j +public class K3_Get_SupplierInfo_Action implements EsbServerlessRpcRemoteInterface { + + @Autowired + private RequestInfo requestInfoTemp; + @Override + public WeaResult> execute(Map params) { + log.info("K3_Get_SupplierInfo_Action execute start"); + log.info("K3_Get_SupplierInfo_Action execute params : " + params); + try { + String datacenterid = null2String(params.get("datacenterid")); //数据中心 + String supname= null2String(params.get("supname")); //供应商名称 + String supnumber = null2String(params.get("supnumber")); //供应商编号 + String code = "0"; + String message = ""; + String issuccess = ""; + String result = ""; + SupplierServiceStub.SupplierSearchReq req = new SupplierServiceStub.SupplierSearchReq(); + req.setUser("oa"); + req.setPwd("k3cloud_htgd"); + req.setFName(supname); + req.setFNumber(supnumber); + req.setDataCenterID(datacenterid); + CallK3SupplierServices services = new CallK3SupplierServices(); + SupplierServiceStub.SupplierReturn res = services.getSupplier(req); + + Map resultJson=new HashMap<>(); + resultJson.put("code",code); + resultJson.put("message",message); + resultJson.put("IsSuccess",issuccess); + resultJson.put("result",result); + SupplierServiceStub.Supplier supplier = res.getSupplier(); + Map supJson = new HashMap<>(); + if(supplier!=null){ + supJson.put("FSupName",supplier.getFSupName());//供应商名称 + supJson.put("FSupNumber",supplier.getFSupNumber());//公共上代码 + supJson.put("Fgroup",supplier.getFGroup());//供应商分组 + supJson.put("FGroupName",supplier.getFGroupName());//供应商分组名称 + supJson.put("FSupplierClassify",supplier.getFSupplierClassify());//供应商类别 + supJson.put("FSUPPLYCLASSIFYNAME",supplier.getFSUPPLYCLASSIFYNAME());//供应商类别名称 + supJson.put("SOCIALCRECODE",supplier.getFSOCIALCRECODE());//统一社会信用代码 + supJson.put("FPayCurrencyId",supplier.getFPayCurrencyId());//结算币别 + supJson.put("FPayCondition",supplier.getFPayCondition());//付款条件 + supJson.put("FTaxRateId",supplier.getFTaxRateId());//默认税率 + supJson.put("F_HTGD_RELATEDTYPE",supplier.getF_HTGD_RELATEDTYPE());//关联方属性 + SupplierServiceStub.ArrayOfOrganization org = supplier.getListOrgs(); + String orgcode = ""; + String orgname = ""; + if(org!=null){ + SupplierServiceStub.Organization[] orgArr = org.getOrganization(); + if(orgArr!=null){ + for(int m=0;m contactJson = new HashMap<>(); + if(contact!=null) { + contactJson.put("Fcontact", contact.getFCONTACT()); //联系人 + contactJson.put("FBizAddress", contact.getFBIZADDRESS());//通讯地址 + contactJson.put("FMobile", contact.getFMOBILE());//手机 + contactJson.put("Ftel", contact.getFTEL());//电话 + contactJson.put("FFax", contact.getFFAX());//传真 + contactJson.put("Femail", contact.getFEMAIL());//电子邮箱 + } + supJson.put("contact",contactJson); + SupplierServiceStub.ArrayOfSupplierBank bankinfo = supplier.getBankList(); + + if(bankinfo!=null) { + SupplierServiceStub.SupplierBank[] bankarr = bankinfo.getSupplierBank(); + List> bankJsonarr = new ArrayList<>(); + if(bankarr!=null && bankarr.length>0){ + for (int i=0; i item = new HashMap<>(); + item.put("FBankHolder",bankarr[i].getFBankHolder()); + item.put("FBankCode",bankarr[i].getFBankCode()); + item.put("FOPENBANKNAME",bankarr[i].getFOPENBANKNAME()); + item.put("FCNAPS",bankarr[i].getFCNAPS()); + bankJsonarr.add(item); + } + } + supJson.put("banklist",bankJsonarr); + }else{ + supJson.put("banklist",new ArrayList<>()); + } + } + resultJson.put("supplier",supJson); + return WeaResult.success(resultJson); + }catch (Exception e){ + log.error("K3_Get_SupplierInfo_Action execute error : " , e); + return WeaResult.fail(500, "执行异常", e); + } + } + + public static String null2String(String s){ + return s == null ? "" : s; + } + + public static String null2String(Object o){ + return o == null ? "" : o.toString(); + } + + public static String null2String(String s1,String s2){ + return s1 == null ? (s2 == null ? "" : s2) : s1; + } +}