diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FICO_COC_CHECK.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FICO_COC_CHECK.java new file mode 100644 index 0000000..d53e442 --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FICO_COC_CHECK.java @@ -0,0 +1,151 @@ +// Decompiled by Jad v1.5.8g. Copyright 2001 Pavel Kouznetsov. +// Jad home page: http://www.kpdus.com/jad.html +// Decompiler options: packimports(3) +// Source File Name: ZOA_MM_PR_CREATE.java +package com.weaver.seconddev.interfaces.workflow.action; + +import java.util.HashMap; +import java.util.Map; +import com.sap.conn.jco.JCoDestination; +import com.sap.conn.jco.JCoFunction; +import com.sap.conn.jco.JCoTable; +import com.weaver.common.i18n.tool.util.I18nContextUtil; +import java.lang.*; +import java.util.*; +import com.weaver.verupgrade.workflow.request.RequestManager; +import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface; +import com.weaver.common.base.entity.result.WeaResult; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import com.weaver.verupgrade.soa.workflow.request.RequestInfo; +import com.weaver.verupgrade.conn.RecordSetTrans; +import com.weaver.verupgrade.general.BaseBean; +import com.weaver.verupgrade.interfaces.workflow.action.Action; + +// Referenced classes of package weaver.interfaces.workflow.action: +// SAPConn, Action +@org.springframework.stereotype.Service("workflow_action_ZOA_FICO_COC_CHECK") +public class ZOA_FICO_COC_CHECK implements Action, EsbServerlessRpcRemoteInterface { + + // 对应E9的请求信息对象 + @Autowired + private RequestInfo requestInfoTemp; + + public static final org.slf4j.Logger logger_6a128882 = LoggerFactory.getLogger(ZOA_FICO_COC_CHECK.class); + + private JCoDestination destination; + + public ZOA_FICO_COC_CHECK() { + new SAPConn(); + destination = SAPConn.getJCoDestination(); + } + + public WeaResult> execute(Map requestInfoMap) { + Map weaverResultMap = new HashMap<>(); + Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1))); + Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1))); + RequestInfo requestinfo = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp); + try { + return WeaResult.success(getResultMapForAction(weaverResultMap, "result", "1", requestinfo.getRequestManager())); + } catch (Exception e) { + e.printStackTrace(); + logger_6a128882.error("ZOA_FICO_COC_CHECK e: {}", e.getMessage()); + return WeaResult.success(getResultMapForAction(weaverResultMap, "result", WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestinfo.getRequestManager())), requestinfo.getRequestManager())); + } + } + + public Map Getexecute(String cbzxdm) { + Map map = new HashMap(); + BaseBean base = new BaseBean(); + map.put("estatus", "E"); + try { + RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); + recordsettrans.setAutoCommit(false); + JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_FICO_COC_CHECK"); + if (jcofunction == null) { + logger_6a128882.info(String.valueOf("ZOA_FICO_COC_CHECK not found in SAP.")); + map.put("emessage", "ZOA_FICO_COC_CHECK not found in SAP."); + } else { + // 成本中心编码 + jcofunction.getImportParameterList().setValue("I_KOSTL", cbzxdm); + logger_6a128882.info(String.valueOf("ZOA_FICO_COC_CHECK接收KOSTL:" + cbzxdm)); + try { + jcofunction.execute(destination); + String stat = jcofunction.getExportParameterList().getValue("E_ISTAT").toString(); + String msg = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); + map.put("estatus", stat); + map.put("emessage", msg); + if ("S".equals(stat)) { + JCoTable localJCoTable1 = jcofunction.getTableParameterList().getTable("E_OUT"); + if (localJCoTable1.getNumRows() > 0) { + localJCoTable1.setRow(1); + // 开始生效日期 + map.put("DATAB", localJCoTable1.getString("DATAB").trim()); + // 一般姓名 + map.put("KTEXT", localJCoTable1.getString("KTEXT").trim()); + // 说明 + map.put("LTEXT", localJCoTable1.getString("LTEXT").trim()); + // 负责人 + map.put("VERAK", localJCoTable1.getString("VERAK").trim()); + // 成本中心类型 + map.put("KOSAR", localJCoTable1.getString("KOSAR").trim()); + // 标准层次结构区域 + map.put("KHINR", localJCoTable1.getString("KHINR").trim()); + // 公司代码 + map.put("BUKRS", localJCoTable1.getString("BUKRS").trim()); + // 功能范围 + map.put("FKBER", localJCoTable1.getString("FKBER").trim()); + // 利润中心 + map.put("PRCTR", localJCoTable1.getString("PRCTR").trim()); + // 工厂 + map.put("ZZWERKS", localJCoTable1.getString("ZZWERKS").trim()); + // 控制范围 + map.put("KOKRS", localJCoTable1.getString("KOKRS").trim()); + // 货币码 + map.put("WAERS", localJCoTable1.getString("WAERS").trim()); + // 成本中心 + map.put("KOSTL", localJCoTable1.getString("KOSTL").trim()); + // 层次结构 + map.put("CCNAME", localJCoTable1.getString("CCNAME").trim()); + // 成本中心类型 + map.put("CBNAME", localJCoTable1.getString("CBNAME").trim()); + // 功能范围的名称 + map.put("GNNAME", localJCoTable1.getString("GNNAME").trim()); + // 利润中心描述 + map.put("LRNAME", localJCoTable1.getString("LRNAME").trim()); + // 工厂描述 + map.put("GCNAME", localJCoTable1.getString("GCNAME").trim()); + // 货币描述 + map.put("HBNAME", localJCoTable1.getString("HBNAME").trim()); + // 公司描述 + map.put("GSNAME", localJCoTable1.getString("GSNAME").trim()); + } + } + } catch (Exception e1) { + logger_6a128882.info(String.valueOf("error1:" + e1.getMessage())); + map.put("emessage", e1.getMessage()); + } + } + } catch (Exception e2) { + logger_6a128882.info(String.valueOf("error2:" + e2.getMessage())); + map.put("emessage", e2.getMessage()); + } + return map; + } + + Map getResultMapForAction(Map map, String key, Object value, RequestManager requestManager) { + if (key != null && !key.isEmpty()) { + map.put(key, value); + } + String msgContent = requestManager.getMessagecontent(); + if (msgContent != null && !msgContent.isEmpty()) { + map.put("msgContent", msgContent); + } + String msgId = requestManager.getMessageid(); + if (msgId != null && !msgId.isEmpty()) { + map.put("msgId", msgId); + } + return map; + } +} diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FI_VENDOR_MAINTAIN_ACTION.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FI_VENDOR_MAINTAIN_ACTION.java new file mode 100644 index 0000000..5e7de19 --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FI_VENDOR_MAINTAIN_ACTION.java @@ -0,0 +1,257 @@ +package com.weaver.seconddev.interfaces.workflow.action; + +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.seconddev.interfaces.scfoa.GetApproveResult; +import com.weaver.verupgrade.conn.CONN_TYPE; +import com.weaver.verupgrade.conn.RecordSet; +import com.weaver.verupgrade.soa.workflow.request.RequestInfo; +import org.apache.commons.lang.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; + +import java.util.HashMap; +import java.util.Map; + +/** + * @Author: calyrex + * @CreateTime: 2025-01-10 + * @Description: + */ + +@org.springframework.stereotype.Service("workflow_action_ZOA_FI_VENDOR_MAINTAIN_ACTION") +public class ZOA_FI_VENDOR_MAINTAIN_ACTION { + // 对应E9的请求信息对象 + @Autowired + private RequestInfo requestInfoTemp; + + @Autowired + private GetApproveResult mGetResult; + + private static final Logger logger_d39bef7 = LoggerFactory.getLogger(ZOA_FI_VENDOR_MAINTAIN_ACTION.class); + + public WeaResult> execute(Map requestInfoMap) { + logger_d39bef7.info("ZOA_FI_VENDOR_MAINTAIN_ACTION start"); + logger_d39bef7.info("requestInfoMap:{}", requestInfoMap); + try { + String edit_flag = null2String(requestInfoMap.get("edit_flag")); + String bukrs = null2String(requestInfoMap.get("bukrs"));//公司代码 + String lifnr = null2String(requestInfoMap.get("lifnr"));//供应商编号 + String ktokk = null2String(requestInfoMap.get("ktokk"));//账户组 + String anred = null2String(requestInfoMap.get("anred"));//称谓 + String name1 = null2String(requestInfoMap.get("name1"));//名称 + String sortl = null2String(requestInfoMap.get("sortl"));//简称-搜索项 + String telf1 = null2String(requestInfoMap.get("telf1"));//电话 + String smtp_addr = null2String(requestInfoMap.get("smtp_addr"));//邮件 + String telf2 = null2String(requestInfoMap.get("telf2"));//手机 + String telfx = null2String(requestInfoMap.get("telfx"));//传真 + String land1 = null2String(requestInfoMap.get("land1"));//国家 + String regio = null2String(requestInfoMap.get("regio"));//地区 + String spras = null2String(requestInfoMap.get("spras"));//语言 + String ort01 = null2String(requestInfoMap.get("ort01"));//城市 + String stras = null2String(requestInfoMap.get("stras"));//地址 + String pstlz = null2String(requestInfoMap.get("pstlz"));//邮政编号 + String bankl = null2String(requestInfoMap.get("bankl"));//开户行行号 + String banka = null2String(requestInfoMap.get("banka"));//开户行名称 + String banks = null2String(requestInfoMap.get("banks"));//开户行国家 + String koinh = null2String(requestInfoMap.get("koinh"));//开户行账号 + String stcd5 = null2String(requestInfoMap.get("stcd5"));//纳税登记证代码 + String akont = null2String(requestInfoMap.get("akont"));//统驭科目 + String zterm = null2String(requestInfoMap.get("zterm"));//付款条件 + String zuawa = null2String(requestInfoMap.get("zuawa"));//排序码 + String zwels = null2String(requestInfoMap.get("zwels"));//付款方式 + String frgrp = null2String(requestInfoMap.get("frgrp"));//批准组 + String zahls = null2String(requestInfoMap.get("zahls"));//付款冻结 + String reprf = null2String(requestInfoMap.get("reprf"));//检查双重发票 + String bumen = null2String(requestInfoMap.get("bumen"));//部门 + String gangwei = null2String(requestInfoMap.get("gangwei"));//岗位 + String name2 = ""; //部门 + String name3 = ""; //岗位 + + logger_d39bef7.info("ZOA_FI_VENDOR_MAINTAIN_CONTROLLER execute bumen : " + bumen); + logger_d39bef7.info("ZOA_FI_VENDOR_MAINTAIN_CONTROLLER execute gangwei : " + gangwei); + + if(StringUtils.isNotEmpty(bumen)){ + name2 = getDepartmentname(bumen); + } + if(StringUtils.isNotEmpty(gangwei)){ + name3 = getJobTitlesname(gangwei); + } + + String estatus = "E"; + String emessage = ""; + String[] prdetail = new String[41]; + prdetail[0] = edit_flag; //动作类型 + prdetail[1] = bukrs; //公司代码 + prdetail[2] = lifnr; //供应商编号 + prdetail[3] = ktokk; //账户组 + prdetail[4] = anred; //称谓 + prdetail[5] = name1; //名称 + prdetail[6] = sortl; //简称-搜索项 + prdetail[7] = telf1; //电话 + prdetail[8] = smtp_addr; //邮件 + prdetail[9] = telf2; //手机 + prdetail[10] = telfx; //传真 + prdetail[11] = land1; //国家 + prdetail[12] = regio; //地区 + prdetail[13] = spras; //语言 + prdetail[14] = ort01; //城市 + prdetail[15] = stras; //地址 + prdetail[16] = pstlz;//邮政编号 + prdetail[17] = bankl; //开户行行号 + prdetail[18] = banka;//开户行名称 + prdetail[19] = banks;//开户行国家 + prdetail[20] = koinh; //开户行账号 + prdetail[21] = stcd5;//纳税登记证代码 + + prdetail[22] = akont;//统驭科目 + prdetail[23] = zterm;//付款条件 + prdetail[24] = zuawa; //排序码 + prdetail[25] = zwels;//付款方式 + prdetail[26] = frgrp;//批准组 + + prdetail[29] = name2;//部门 + prdetail[30] = name3;//岗位 + prdetail[40] = ""; + + //付款冻结 + if(zahls.equals("X")){ + prdetail[27] = zahls; + }else{ + prdetail[27] = ""; + } + + //检查双重发票 + if(reprf.equals("X")){ + prdetail[28] = reprf; + }else{ + prdetail[28] = ""; + } + + ZOA_FI_VENDOR_MAINTAIN po=new ZOA_FI_VENDOR_MAINTAIN(); + String[][] fhz = po.Getexecute(prdetail); + if(fhz[0][0].equals("S")){ + estatus = fhz[0][0]; + } + emessage = fhz[0][1]; + Map result = new HashMap<>(); + result.put("estatus",estatus); + result.put("emessage",emessage); + result.put("lifnr",fhz[1][0]); + result.put("bukrs",fhz[1][1]); + result.put("ktokk",fhz[1][2]); + result.put("txt30",fhz[1][3]); + result.put("anred",fhz[1][4]); + result.put("name1",fhz[1][5]); + result.put("sortl",fhz[1][6]); + result.put("telf1",fhz[1][7]); + result.put("smtp_addr",fhz[1][8]); + result.put("telf2",fhz[1][9]); + result.put("telfx",fhz[1][10]); + result.put("land1",fhz[1][11]); + result.put("landx50",fhz[1][12]); + result.put("bland",fhz[1][13]); + result.put("bezei",fhz[1][14]); + result.put("spras",fhz[1][15]); + result.put("sptxt",fhz[1][16]); + result.put("ort01",fhz[1][17]); + result.put("stras",fhz[1][18]); + result.put("pstlz",fhz[1][19]); + result.put("bankl",fhz[1][20]); + result.put("banka",fhz[1][21]); + result.put("banks",fhz[1][22]); + result.put("landx",fhz[1][23]); + result.put("koinh",fhz[1][24]); + result.put("stcd5",fhz[1][25]); + result.put("akont",fhz[1][26]); + result.put("txt20",fhz[1][27]); + result.put("zterm",fhz[1][28]); + result.put("text1",fhz[1][29]); + result.put("zuawa",fhz[1][30]); + result.put("ttext",fhz[1][31]); + result.put("zwels",fhz[1][32]); + result.put("text2",fhz[1][33]); + result.put("frgrp",fhz[1][34]); + result.put("frgrt",fhz[1][35]); + result.put("zahls",fhz[1][36]); + result.put("reprf",fhz[1][37]); + result.put("name2",fhz[1][38]); + result.put("name3",fhz[1][39]); + return WeaResult.success(result); + }catch (Exception e){ + logger_d39bef7.error("ZOA_FI_VENDOR_MAINTAIN_ACTION error:{}", e); + return WeaResult.fail(500, "执行异常", e); + } + } + + /** + * 根据部门ID获取部门名称 + * + * @param deptid 部门ID，用于查询部门名称 + * @return 部门名称如果找到对应的部门则返回名称，否则返回空字符串 + */ + private String getDepartmentname(String deptid){ + // 构造SQL查询语句，根据部门ID查询部门名称 + String sql = "select name from eteams.dbo.department where id = " + deptid; + // 记录查询语句日志 + logger_d39bef7.info("getDepartmentname sql--" + sql); + // 创建RecordSet对象用于执行SQL查询 + RecordSet rs = new RecordSet(); + // 获取连接池名称 + String poolname_oj = CONN_TYPE.hrm.getType(); + // 执行SQL查询 + boolean b = rs.execute(sql, poolname_oj); + // 记录执行结果日志 + logger_d39bef7.info("getDepartmentname b--" + b); + // 如果查询到结果，则返回部门名称 + if (rs.next()) { + return rs.getString("name"); + } + // 如果没有查询到结果，则返回空字符串 + return ""; + } + + /** + * 根据职位ID获取职位名称 + * + * @param jobid 职位ID，用于查询特定职位的名称 + * @return 职位名称如果找到对应的职位名称，则返回该名称；否则返回空字符串 + */ + private String getJobTitlesname(String jobid){ + // 构造SQL查询语句，用于从数据库中获取指定职位ID的名称 + String sql = "select name from eteams.dbo.position where id = " + jobid; + + // 记录查询语句的日志信息 + logger_d39bef7.info("getJobTitlesname sql--" + sql); + + // 创建RecordSet对象用于执行数据库查询操作 + RecordSet rs = new RecordSet(); + + // 获取数据库连接池名称 + String poolname_oj = CONN_TYPE.hrm.getType(); + + // 执行数据库查询操作，并记录操作结果的日志信息 + boolean b = rs.execute(sql, poolname_oj); + logger_d39bef7.info("getJobTitlesname b--" + b); + + // 如果查询结果存在下一条记录，则返回该记录的名称字段 + if(rs.next()) { + return rs.getString("name"); + } + + // 如果没有查询到任何记录，则返回空字符串 + return ""; + } + + 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/controller/ZOA_FICO_ANLA_CHECK_CONTROLLER.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ZOA_FICO_ANLA_CHECK_CONTROLLER.java index bea46d7..b541afd 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ZOA_FICO_ANLA_CHECK_CONTROLLER.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ZOA_FICO_ANLA_CHECK_CONTROLLER.java @@ -1,11 +1,134 @@ package com.weaver.seconddev.interfaces.workflow.controller; +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.seconddev.interfaces.workflow.action.ZOA_FICO_ANLA_CHECK; +import lombok.extern.slf4j.Slf4j; +import org.dom4j.Document; +import org.dom4j.DocumentHelper; +import org.dom4j.Element; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Map; + /** * @Author: calyrex * @CreateTime: 2025-01-10 * @Description:ZOA_FICO_ANLA_CHECK的API调用 */ +@Slf4j +@RestController +@RequestMapping({"/papi/secondev/workflow/controller" }) public class ZOA_FICO_ANLA_CHECK_CONTROLLER { + @GetMapping("/ZOA_FICO_ANLA_CHECK") + public WeaResult run(@RequestParam Map params) { + log.info("ZOA_FI_CUSTOMER_MAINTAIN_CONTROLLER execute start"); + log.info("ZOA_FI_CUSTOMER_MAINTAIN_CONTROLLER execute params : " + params); + try { + String gdzcdm = null2String(params.get("gdzcdm")); //固定资产代码 + String gsdm = null2String(params.get("gsdm")); //公司 + String estatus = "E"; + String emessage = ""; + + ZOA_FICO_ANLA_CHECK po=new ZOA_FICO_ANLA_CHECK(); + Map map = po.Getexecute(gdzcdm , gsdm); + if(map != null && map.size() > 0){ + estatus = map.get("estatus"); + emessage = map.get("emessage"); + Document document = DocumentHelper.createDocument(); + Element xml = document.addElement("xml"); + Element status = xml.addElement("estatus"); + status.setText(estatus); + Element message = xml.addElement("emessage"); + message.setText(emessage); + Element TXT50_ = xml.addElement("TXT50");; + TXT50_.setText(""); + Element TXA50_ = xml.addElement("TXA50"); + TXA50_.setText(""); + Element ANLN1_ = xml.addElement("ANLN1"); + ANLN1_.setText(""); + Element ANLHTXT_ = xml.addElement("ANLHTXT"); + ANLHTXT_.setText(""); + Element SERNR_ = xml.addElement("SERNR"); + SERNR_.setText(""); + Element INVNR_ = xml.addElement("INVNR"); + INVNR_.setText(""); + Element KOSTL_ = xml.addElement("KOSTL"); + KOSTL_.setText(""); + Element KOSTLV_ = xml.addElement("KOSTLV"); + KOSTLV_.setText(""); + Element CAUFN_ = xml.addElement("CAUFN"); + CAUFN_.setText(""); + Element WERKS_ = xml.addElement("WERKS"); + WERKS_.setText(""); + Element RAUMN_ = xml.addElement("RAUMN"); + RAUMN_.setText(""); + Element BUKRS_ = xml.addElement("BUKRS"); + BUKRS_.setText(""); + Element KKTOGR_ = xml.addElement("KTOGR"); + KKTOGR_.setText(""); + Element MENGE_ = xml.addElement("MENGE"); + MENGE_.setText(""); + Element MEINS_ = xml.addElement("MEINS"); + MEINS_.setText(""); + Element AKTIV_ = xml.addElement("AKTIV"); + AKTIV_.setText(""); + Element ZUGDT_ = xml.addElement("ZUGDT"); + ZUGDT_.setText(""); + Element ZUJHR_ = xml.addElement("ZUJHR"); + ZUJHR_.setText(""); + Element ZUPER_ = xml.addElement("ZUPER"); + ZUPER_.setText(""); + Element DEAKT_ = xml.addElement("DEAKT"); + DEAKT_.setText(""); + Element ORD41_ = xml.addElement("ORD41"); + ORD41_.setText(""); + Element ORD42_ = xml.addElement("ORD42"); + ORD42_.setText(""); + Element NDJAR_ = xml.addElement("NDJAR"); + NDJAR_.setText(""); + Element NDPER_ = xml.addElement("NDPER"); + NDPER_.setText(""); + Element AFABG_ = xml.addElement("AFABG"); + AFABG_.setText(""); + Element NDABJ_ = xml.addElement("NDABJ"); + NDABJ_.setText(""); + Element NDABP_ = xml.addElement("NDABP"); + NDABP_.setText(""); + Element ANLKL_ = xml.addElement("ANLKL"); + ANLKL_.setText(""); + Element ANLN2_ = xml.addElement("ANLN2"); + ANLN2_.setText(""); + return WeaResult.success(document.asXML()); + }else { + estatus = map.get("estatus"); + emessage = map.get("emessage"); + Document document = DocumentHelper.createDocument(); + Element xml = document.addElement("xml"); + Element status = xml.addElement("estatus"); + status.setText(estatus); + Element message = xml.addElement("emessage"); + message.setText(emessage); + return WeaResult.success(document.asXML()); + } + }catch (Exception e){ + log.error("ZOA_FI_CUSTOMER_MAINTAIN_CONTROLLER execute error : " , e); + return WeaResult.fail(500, "执行异常", e.getMessage()); + } + } + + 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/controller/ZOA_FICO_COC_CHECK_CONTROLLER.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ZOA_FICO_COC_CHECK_CONTROLLER.java new file mode 100644 index 0000000..4f72b67 --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ZOA_FICO_COC_CHECK_CONTROLLER.java @@ -0,0 +1,114 @@ +package com.weaver.seconddev.interfaces.workflow.controller; + +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.seconddev.interfaces.workflow.action.ZOA_FICO_COC_CHECK; +import lombok.extern.slf4j.Slf4j; +import org.dom4j.Document; +import org.dom4j.DocumentHelper; +import org.dom4j.Element; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Map; + +/** + * @Author: calyrex + * @CreateTime: 2025-01-10 + * @Description:ZOA_FICO_COC_CHECK的API调用 + */ + +@Slf4j +@RestController +@RequestMapping({"/papi/secondev/workflow/controller" }) +public class ZOA_FICO_COC_CHECK_CONTROLLER { + @GetMapping("/ZOA_FICO_COC_CHECK") + public WeaResult run(@RequestParam Map params) { + log.info("ZOA_FICO_COC_CHECK_CONTROLLER execute start"); + log.info("ZOA_FICO_COC_CHECK_CONTROLLER execute params : " + params); + try { + String cbzxdm = null2String(params.get("cbzxdm")); //成本中心代码 + + String estatus = "E"; + String emessage = ""; + + ZOA_FICO_COC_CHECK po=new ZOA_FICO_COC_CHECK(); + Map map = po.Getexecute(cbzxdm); + if(map != null && map.size() > 0){ + estatus = map.get("estatus"); + emessage = map.get("emessage"); + Document document = DocumentHelper.createDocument(); + Element xml = document.addElement("xml"); + Element status = xml.addElement("estatus"); + status.setText(estatus); + Element message = xml.addElement("emessage"); + message.setText(emessage); + Element DATAB_ = xml.addElement("DATAB"); + DATAB_.setText(null2String(map.get("DATAB"))); + Element KTEXT_ = xml.addElement("KTEXT"); + KTEXT_.setText(null2String(map.get("KTEXT"))); + Element LTEXT_ = xml.addElement("LTEXT"); + LTEXT_.setText(null2String(map.get("LTEXT"))); + Element VERAK_ = xml.addElement("VERAK"); + VERAK_.setText(null2String(map.get("VERAK"))); + Element KOSAR_ = xml.addElement("KOSAR"); + KOSAR_.setText(null2String(map.get("KOSAR"))); + Element KHINR_ = xml.addElement("KHINR"); + KHINR_.setText(null2String(map.get("KHINR"))); + Element BUKRS_ = xml.addElement("BUKRS"); + BUKRS_.setText(null2String(map.get("BUKRS"))); + Element FKBER_ = xml.addElement("FKBER"); + FKBER_.setText(null2String(map.get("FKBER"))); + Element WAERS_ = xml.addElement("WAERS"); + WAERS_.setText(null2String(map.get("WAERS"))); + Element PRCTR_ = xml.addElement("PRCTR"); + PRCTR_.setText(null2String(map.get("PRCTR"))); + Element ZZWERKS_ = xml.addElement("ZZWERKS"); + ZZWERKS_.setText(null2String(map.get("ZZWERKS"))); + Element KOKRS_ = xml.addElement("KOKRS"); + KOKRS_.setText(null2String(map.get("KOKRS"))); + Element KOSTL_ = xml.addElement("KOSTL"); + KOSTL_.setText(null2String(map.get("KOSTL"))); + Element CCNAME_ = xml.addElement("CCNAME"); + CCNAME_.setText(null2String(map.get("CCNAME"))); + Element CBNAME_ = xml.addElement("CBNAME"); + CBNAME_.setText(null2String(map.get("CBNAME"))); + Element LRNAME_ = xml.addElement("LRNAME"); + LRNAME_.setText(null2String(map.get("LRNAME"))); + Element GCNAME_ = xml.addElement("GCNAME"); + GCNAME_.setText(null2String(map.get("GCNAME"))); + Element HBNAME_ = xml.addElement("HBNAME"); + HBNAME_.setText(null2String(map.get("HBNAME"))); + Element GSNAME_ = xml.addElement("GSNAME"); + GSNAME_.setText(null2String(map.get("GSNAME"))); + return WeaResult.success(document.asXML()); + }else { + estatus = map.get("estatus"); + emessage = map.get("emessage"); + Document document = DocumentHelper.createDocument(); + Element xml = document.addElement("xml"); + Element status = xml.addElement("estatus"); + status.setText(estatus); + Element message = xml.addElement("emessage"); + message.setText(emessage); + return WeaResult.success(document.asXML()); + } + }catch (Exception e){ + log.error("ZOA_FI_CUSTOMER_MAINTAIN_CONTROLLER execute error : " , e); + return WeaResult.fail(500, "执行异常", e.getMessage()); + } + } + + 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; + } +}