From 80978cf48901a33505250f13101d098e141ff845 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E9=B9=8F?= <845871400@qq.com> Date: Sat, 3 Aug 2024 11:21:23 +0800 Subject: [PATCH] dzpzk code --- .../fi/common/dzpzk/token/DzpzTokenBean.java | 54 ++ .../java/shkd/fi/fi/oa/OAInvoiceImpl.java | 11 + .../shkd/fi/fi/opplugin/DzpzkOPPlugin.java | 531 ++++++++++++++++++ .../fi/opplugin/SynchronizaSapOPPlugin.java | 51 +- .../DT_DOCUMENT_IF_SRCDATAIS_HEADER.java | 76 +-- .../DT_DOCUMENT_IF_SRCDATAIT_ITEM.java | 68 +-- .../java/shkd/fi/fi/util/CharsetUtils.java | 17 + .../main/java/shkd/fi/fi/util/FileUtils.java | 38 ++ .../main/java/shkd/fi/fi/util/HttpUtils.java | 12 +- .../main/java/shkd/fi/fi/util/XmlUtils.java | 5 +- 10 files changed, 743 insertions(+), 120 deletions(-) create mode 100644 fi/shkd-fi-fi/src/main/java/shkd/fi/fi/common/dzpzk/token/DzpzTokenBean.java create mode 100644 fi/shkd-fi-fi/src/main/java/shkd/fi/fi/oa/OAInvoiceImpl.java create mode 100644 fi/shkd-fi-fi/src/main/java/shkd/fi/fi/opplugin/DzpzkOPPlugin.java create mode 100644 fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/CharsetUtils.java create mode 100644 fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/FileUtils.java diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/common/dzpzk/token/DzpzTokenBean.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/common/dzpzk/token/DzpzTokenBean.java new file mode 100644 index 0000000..faf5463 --- /dev/null +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/common/dzpzk/token/DzpzTokenBean.java @@ -0,0 +1,54 @@ +/** + * Copyright 2024 bejson.com + */ +package shkd.fi.fi.common.dzpzk.token; + +/** + * Auto-generated: 2024-08-01 17:31:18 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +public class DzpzTokenBean { + + private String access_token; + private String token_type; + private String refresh_token; + private int expires_in; + private String scope; + public void setAccess_token(String access_token) { + this.access_token = access_token; + } + public String getAccess_token() { + return access_token; + } + + public void setToken_type(String token_type) { + this.token_type = token_type; + } + public String getToken_type() { + return token_type; + } + + public void setRefresh_token(String refresh_token) { + this.refresh_token = refresh_token; + } + public String getRefresh_token() { + return refresh_token; + } + + public void setExpires_in(int expires_in) { + this.expires_in = expires_in; + } + public int getExpires_in() { + return expires_in; + } + + public void setScope(String scope) { + this.scope = scope; + } + public String getScope() { + return scope; + } + +} \ No newline at end of file diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/oa/OAInvoiceImpl.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/oa/OAInvoiceImpl.java new file mode 100644 index 0000000..e2648d9 --- /dev/null +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/oa/OAInvoiceImpl.java @@ -0,0 +1,11 @@ +package shkd.fi.fi.oa; +import org.codehaus.xfire.client.*; +public class OAInvoiceImpl { + + public static void sendOA (){ + +// org.codehaus.xfire.client.Client client = new Client(new URL("http://127.0.0.1:8080/XFire_demo/services/XFireServer?wsdl")); +// Object[] results11 = client.invoke("sayHello", new Object[]{"Jadyer22"}); +// System.out.println(results11[0]); + } +} diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/opplugin/DzpzkOPPlugin.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/opplugin/DzpzkOPPlugin.java new file mode 100644 index 0000000..068f1b4 --- /dev/null +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/opplugin/DzpzkOPPlugin.java @@ -0,0 +1,531 @@ +package shkd.fi.fi.opplugin; + +import com.alibaba.druid.support.logging.Log; +import com.alibaba.druid.support.logging.LogFactory; +import com.sap.db.jdbc.packet.ErrorLevel; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.entity.DynamicObjectCollection; +import kd.bos.entity.operate.result.OperateErrorInfo; +import kd.bos.entity.plugin.AbstractOperationServicePlugIn; +import kd.bos.entity.plugin.args.AfterOperationArgs; +import kd.bos.orm.query.QCP; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.QueryServiceHelper; +import kd.bos.servicehelper.operation.SaveServiceHelper; +import kd.bos.util.StringUtils; +import shkd.fi.fi.common.AppflgConstant; +import shkd.fi.fi.sap.requst.docuentif.*; +import shkd.fi.fi.sap.result.docuentif.Item; +import shkd.fi.fi.sap.result.docuentif.MTDocumentIFRet; +import shkd.fi.fi.util.HttpUtils; +import shkd.fi.fi.util.LogBillUtils; +import shkd.fi.fi.util.XmlUtils; + +import javax.xml.bind.JAXBException; +import java.io.UnsupportedEncodingException; +import java.math.BigDecimal; +import java.text.SimpleDateFormat; +import java.util.*; + +/** + * 凭证-->电子凭证库 + * 元:shkd_gl_voucher_ext + */ +public class DzpzkOPPlugin extends AbstractOperationServicePlugIn { + private static final Log log = LogFactory.getLog(DzpzkOPPlugin.class); + @Override + public void afterExecuteOperationTransaction(AfterOperationArgs e) { + super.afterExecuteOperationTransaction(e); + String operationKey = e.getOperationKey(); + switch (operationKey){ + case "shkd_synchronizasap": + synSap(e); + break; + default: + break; + } + + } + public void synSap(AfterOperationArgs e){ + //1.校验，不满足条件的凭证，移除，不传输 + DynamicObjectCollection voucherColl = new DynamicObjectCollection(); + StringBuffer errStr = new StringBuffer(); + DynamicObject[] dataEntities = e.getDataEntities(); + + for (DynamicObject glvoucher : dataEntities) { + DynamicObject voucher = BusinessDataServiceHelper.loadSingle(glvoucher.getPkValue(), "gl_voucher"); + String voucherNo = voucher.getString("billno");//凭证号 + //1.1.校验公司是否已映射SAP编码 + DynamicObject org = voucher.getDynamicObject("org"); + String org_shkd_sap_number = org.getString("shkd_sap_number"); + if (StringUtils.isEmpty(org_shkd_sap_number)) { + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("业务单元 ").append(org.getString("number")).append(" ").append(org.getString("name")); + errStr.append(" 未维护SAP组织编码映射，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + } + //1.2.校验会计科目是否已映射SAP科目编码 + //1.3.核算维度校验：成本中心是否已映射SAP编码 + //1.4.核算维度校验：供应商是否已映射SAP编码 + //1.5.核算维度校验：客户是否已映射SAP编码 + DynamicObjectCollection entries = voucher.getDynamicObjectCollection("entries"); + boolean entryIsCheckPass = false;//分录是否校验通过 + for (int i = 0; i < entries.size(); i++) { + DynamicObject entry = entries.get(i); + //总账科目 + DynamicObject account = entry.getDynamicObject("account"); + String account_shkd_sap_number = account.getString("shkd_sap_number"); + if (StringUtils.isEmpty(account_shkd_sap_number)) { + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("会计科目：").append(account.getString("number")).append(" ").append(account.getString("name")); + errStr.append(" 未维护SAP编码映射，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + } + boolean shkd_sap_supplier_in = account.getBoolean("shkd_sap_supplier_in");//供应商是否必须 +// boolean shkd_sap_kostl_in = account.getBoolean("shkd_sap_kostl_in");//成本中心是否必须 + String shkd_sap_blart = account.getString("shkd_sap_blart");//SAP凭证类型 + String shkd_sap_bschl_j = account.getString("shkd_sap_bschl_j");//SAP记账代码(借) + String shkd_sap_bschl_d = account.getString("shkd_sap_bschl_d");//SAP记账代码(贷) + String shkd_sap_sup_num = account.getString("shkd_sap_sup_num");//SAP默认供应商编码 + if(StringUtils.isEmpty(shkd_sap_blart)){ + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("会计科目：").append(account.getString("number")).append(" ").append(account.getString("name")); + errStr.append(" 未维护SAP凭证类型映射，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + } + if(StringUtils.isEmpty(shkd_sap_bschl_j)){ + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("会计科目：").append(account.getString("number")).append(" ").append(account.getString("name")); + errStr.append(" 未维护SAP记账代码(借)映射，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + } + if(StringUtils.isEmpty(shkd_sap_bschl_d)){ + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("会计科目：").append(account.getString("number")).append(" ").append(account.getString("name")); + errStr.append(" 未维护SAP记账代码(贷)映射，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + } + + + String shkd_sap_sup_number = "";//核算维度 供应商编码 + String shkd_sap_cus_number = "";//核算维度 客户编码 + String shkd_sap_dep_number = "";//核算维度 部门编码 + DynamicObject assgrp = entry.getDynamicObject("assgrp"); + if (null != assgrp) { + + + QFilter filter = new QFilter("hg.id", QCP.equals,assgrp.getPkValue()); + DynamicObjectCollection gl_assist_bd = QueryServiceHelper.query("gl_assist_bd", "hg.id,asstype,assval", new QFilter[]{filter}); + Map map = new HashMap(); + for (int j = 0; j < gl_assist_bd.size(); j++) { + DynamicObject gl_assist_bdObject = gl_assist_bd.get(j); + Long hgId = gl_assist_bdObject.getLong("hg.id"); + Long assval = gl_assist_bdObject.getLong("assval");//维度值 + String asstype = gl_assist_bdObject.getString("asstype"); + switch (asstype) { + case "f0001": + //客户 + DynamicObject customer = QueryServiceHelper.queryOne("bd_customer", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); + shkd_sap_cus_number = customer.getString("shkd_sap_number"); + if(StringUtils.isEmpty(shkd_sap_cus_number)){ + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("客户：").append(customer.getString("number")).append(" ").append(customer.getString("name")); + errStr.append(" 未维护SAP编码映射，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + }else { + entryIsCheckPass=true; + } + break; + case "f000005": + //供应商 + DynamicObject supplier = QueryServiceHelper.queryOne("bd_supplier", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); + shkd_sap_sup_number = supplier.getString("shkd_sap_number"); + if(StringUtils.isEmpty(shkd_sap_sup_number)){ + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("供应商：").append(supplier.getString("number")).append(" ").append(supplier.getString("name")); + errStr.append(" 未维护SAP编码映射，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + }else { + entryIsCheckPass=true; + } + break; + case "f000009": + //部门 + DynamicObject adminOrg = QueryServiceHelper.queryOne("bos_adminorg", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); + shkd_sap_dep_number = adminOrg.getString("shkd_sap_number"); + if(StringUtils.isEmpty(shkd_sap_dep_number)){ + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("部门：").append(adminOrg.getString("number")).append(" ").append(adminOrg.getString("name")); + errStr.append(" 未维护SAP编码映射，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + }else { + entryIsCheckPass=true; + } + break; + default: + break; + } + } + + } + //如果 科目上 SAP供应商核算维度必须传，并且当前金蝶科目没核算维度为供应商，且科目上维护的SAP默认供应商编码为空，则校验不通过 + if(shkd_sap_supplier_in&&StringUtils.isEmpty(shkd_sap_sup_number)&&StringUtils.isEmpty(account.getString("shkd_sap_sup_num"))){ + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("会计科目：").append(account.getString("number")).append(" ").append(account.getString("name")); + errStr.append(" SAP系统要求供应商必须，当前凭证上科目无供应商核算维度或科目映射未维护SAP默认供应商编码，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + } + entryIsCheckPass=true; + + } + if(entryIsCheckPass){ + voucherColl.add(voucher); + }else { + break; + } + } + //数据校验不通过，则不进行同步 + if(StringUtils.isNotEmpty(errStr.toString())){ + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + return; + } + Integer integer = 0; + //2.组装转换参数 + for (DynamicObject dataEntity : voucherColl) { + + //结构：ZFIS_YS_HEAD 库存-财务系统PI接口表头结构 (1-6) + DT_DOCUMENT_IF_SRCDATAIS_HEADER header = new DT_DOCUMENT_IF_SRCDATAIS_HEADER(); + //结构：ZFIS_YS_ITEM 库存-财务系统PI接口行项目结构 + DT_DOCUMENT_IF_SRCDATAIT_ITEMITEM items = new DT_DOCUMENT_IF_SRCDATAIT_ITEMITEM(); + +// DynamicObject gl_voucher = BusinessDataServiceHelper.loadSingle(dataEntity.getPkValue(), "gl_voucher","id,billno,org,creator.name,entries.*"); + DynamicObject gl_voucher = dataEntity; + + //1.公司代码(BUKRS)--核算组织(org) + DynamicObject org = gl_voucher.getDynamicObject("org"); + String shkd_sap_number = org.getString("shkd_sap_number"); + + //2.创建日期(CRDATE)--当前时间 + Date date = new Date(); + SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMddHHmmss"); + String crdate = simpleDateFormat.format(date); + //3.创建人(CRNAME)--创建人名称(creator) + DynamicObject creator = gl_voucher.getDynamicObject("creator"); + String crname = ""; + if (null != creator) { + crname = creator.getString("name"); + } + //4.记录条数(ZRTOALL)--所传数据的凭证分录总条数 + DynamicObjectCollection entries = gl_voucher.getDynamicObjectCollection("entries"); + integer += entries.size(); + //5.数据包唯一标识号(PACKGID)--格式：JDN+时间戳 + String packgid = "JDN" + date.getTime(); + //6.数据状态（T：测试运行，P：正式运行）(ZFLAG)--固定传T + String zflag = "P"; + header.setBUKRS(shkd_sap_number); + header.setCRDATE(crdate); + header.setCRNAME(crname); + header.setZRTOALL(integer.toString()); + header.setPACKGID(packgid); + header.setZFLAG(zflag); + + + //7.库存凭证号(DOCID)--凭证号_凭证ID + Long id = gl_voucher.getLong("id"); + String billno = gl_voucher.getString("billno"); + String docid = id + "_" + billno; + //9.数据处理状态 （I未处理V校验失败F过账失败S过账成功（写死"I未处理"））(ZSTATUS)--固定值I + String zstatus = "I"; + //13.抬头文本(BKTXT)----凭证分录第一行摘要(如超长需截位，保留前25个字)(edescription) + String bktxt = ""; + //14.货币码(WAERS)----币别基础资料的货币代码(currency) + String waers = ""; + //16.凭证类型 SAP凭证类型（默认值：具体值待定）(BLART)--固定值SA + String blart = "SA"; + //17.总账科目(HKONT)----取会计科目上SAP科目编码，测试时，可传9999999999(account) + //18.记账代码y(BSCHL)----借贷方向，40=借方，50=贷方(entrydc) + //19.凭证货币金额(WRBTR)----原币金额(oriamount) + //19.按本位币计的金额(DMBTR)----原币金额(oriamount) + //20.项目文本(SGTXT)----凭证行摘要(edescription) + //21.成本中心(KOSTL)----金蝶核算维度：成本中心SAP编码() + List itemsList = new ArrayList<>(); + for (DynamicObject entry : entries) { + DT_DOCUMENT_IF_SRCDATAIT_ITEM items1 = new DT_DOCUMENT_IF_SRCDATAIT_ITEM(); + + //8.库存行项目号(ITEMID)--凭证分录行号，从1开始 + String seq = ""; + seq = entry.getString("seq"); + + //10.公司代码----同1重复 + //11.凭证中的过账日期(BUDAT)--记账日期(bookeddate)20181031 + //12.凭证中的凭证日期(BLDAT)--记账日期 + //15.凭证中的凭证日期(WWERT)--记账日期 + Date bookeddate = gl_voucher.getDate("bookeddate"); + String budat = ""; + String bldat = ""; + String wwert = ""; + if (null != bookeddate) { + SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); + budat = simpleDateFormat.format(bookeddate); + budat = budat.substring(0, 8); + bldat = simpleDateFormat.format(bookeddate); + bldat = bldat.substring(0, 8); + wwert = simpleDateFormat.format(bookeddate); + wwert = wwert.substring(0, 8); + } + + bktxt = entries.get(0).getString("edescription"); + if (bktxt.length() > 25) { + bktxt = bktxt.substring(0, 25);//摘要 + } + //币别 + DynamicObject currency = entries.get(0).getDynamicObject("currency"); + if (null != currency) { + waers = currency.getString("number"); + } + + //总账科目 + DynamicObject account = entry.getDynamicObject("account"); + String hkont = account.getString("shkd_sap_number"); + blart =account.getString("shkd_sap_blart");//SAP 科目-凭证类型 + //记账代码 + String bschl = ""; + //凭证货币金额 + BigDecimal oriamount = BigDecimal.ZERO; + if ("1".equals(entry.getString("entrydc"))) { + bschl = account.getString("shkd_sap_bschl_j"); + oriamount = entry.getBigDecimal("debitori"); + } else if ("-1".equals(entry.getString("entrydc"))) { + bschl = account.getString("shkd_sap_bschl_d");; + oriamount = entry.getBigDecimal("creditori"); + } + String wrbtr = oriamount.toString(); + String dmbtr = oriamount.toString(); + //项目文本 + String sgtxt = entry.getString("edescription"); + if (sgtxt.length() > 25) { + sgtxt = sgtxt.substring(0, 25); + } + + //todo + DynamicObject assgrp = entry.getDynamicObject("assgrp"); + String KUNNR="";//客户 + String LIFNR="";//供应商 + String KOSTL="";//成本中心 部门 + if (null != assgrp) { + QFilter filter = new QFilter("hg.id", QCP.equals,assgrp.getPkValue()); + DynamicObjectCollection gl_assist_bd = QueryServiceHelper.query("gl_assist_bd", "hg.id,asstype,assval", new QFilter[]{filter}); + for (int j = 0; j < gl_assist_bd.size(); j++) { + DynamicObject gl_assist_bdObject = gl_assist_bd.get(j); + Long hgId = gl_assist_bdObject.getLong("hg.id"); + Long assval = gl_assist_bdObject.getLong("assval");//维度值 + String asstype = gl_assist_bdObject.getString("asstype"); + switch (asstype) { + case "f0001": + //客户 + DynamicObject dynamicObject = QueryServiceHelper.queryOne("bd_customer", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); + KUNNR = dynamicObject.getString("shkd_sap_number"); + + break; + case "f000005": + //供应商 + dynamicObject = QueryServiceHelper.queryOne("bd_supplier", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); + LIFNR = dynamicObject.getString("shkd_sap_number"); + + break; + case "f000009": + //部门 + dynamicObject = QueryServiceHelper.queryOne("bos_adminorg", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); + KOSTL = dynamicObject.getString("shkd_sap_number"); + + break; + default: + break; + } + } + + } + //如果科目上维护了SAP默认供应商编码，则以科目维护的为准 + String shkd_sap_sup_num = account.getString("shkd_sap_sup_num"); + if(StringUtils.isNotEmpty(shkd_sap_sup_num)){ + LIFNR = shkd_sap_sup_num; + } + + items1.setDOCID(docid); + items1.setITEMNO(seq); + items1.setZSTATUS(zstatus); + items1.setBUKRS(shkd_sap_number); + items1.setBUDAT(budat); + + items1.setBLDAT(budat); + items1.setBKTXT(bktxt); + items1.setWAERS(waers); + items1.setWWERT(budat); + items1.setBLART(blart); + items1.setHKONT(hkont); + items1.setBSCHL(bschl); + items1.setUMSKZ(""); + items1.setWRBTR(wrbtr); + items1.setDMBTR(dmbtr); + items1.setZUONR(""); + items1.setSGTXT(sgtxt); + items1.setKOSTL(KOSTL); + items1.setPRCTR(""); + items1.setGSBER(""); + items1.setKUNNR(KUNNR); + items1.setLIFNR(LIFNR); + items1.setAUFNR(""); + items1.setVALUT(""); + items1.setXREF1(""); + items1.setXREF2(""); + items1.setXREF3(""); + items1.setVBUND(""); + items1.setZZCUSTOMER(KUNNR); + items1.setZZVENDOR(LIFNR); + items1.setZZFIELD1(""); + items1.setZZFIELD2(""); + items1.setZZFIELD3(""); + items1.setZZFIELD4(""); + items1.setZZFIELD5(""); + items1.setZZFIELD6(""); + items1.setHBKID(""); + items1.setHKTID(""); + items1.setXNEGP(""); + items1.setKIDNO(""); + + itemsList.add(items1); + } + items.setItems(itemsList); + + //3.调用SAP接口 + try { + DT_DOCUMENT_IF_SRC dt_document_if_src = setData(header, items); + String xml = XmlUtils.getXml(dt_document_if_src).replaceAll("DT_DOCUMENT_IF_SRC", "urn:MT_DOCUMENT_IF_SRC"); + Map headerMap = new HashMap(); + String spa_user_pass = System.getProperty(AppflgConstant.SAP_USER_PASS); + byte[] token = Base64.getEncoder().encode(spa_user_pass.getBytes()); + String tokenStr = new String(token); + String sap_syn_voucher_url = System.getProperty(AppflgConstant.SAP_SYN_VOUCHER_URL); + + String responseStr=""; + Map result = HttpUtils.sendPostToSAP(sap_syn_voucher_url,tokenStr, xml); + if(null!=result){ + String status = String.valueOf(result.get(HttpUtils.STATUS)); + responseStr = String.valueOf(result.get(HttpUtils.RESPONSE_STRING)); + log.info(status); + log.info(responseStr); + //4.处理接口返回结果：解析记录结果到凭证上， + if(status.equals("200")){//成功 + MTDocumentIFRet mtDocumentIFRet = XmlUtils.xmlToObject(MTDocumentIFRet.class, responseStr, XmlUtils.START_SUB_STR, XmlUtils.END_SUB_STR); + if(null!=mtDocumentIFRet&&null!=mtDocumentIFRet.getData() + &&null!=mtDocumentIFRet.getData().getOtRETN() + &&null!=mtDocumentIFRet.getData().getOtRETN().getItem()){ + Item item = mtDocumentIFRet.getData().getOtRETN().getItem(); + String zstatus1 = item.getZstatus(); + if("S".equals(zstatus1.toUpperCase())){//成功 + //成功提示 + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(true); + this.operationResult.setMessage("同步成功"); + + }else {//失败 + //失败提示 + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("同步失败:"+item.getPromsg()); + } + //更新凭证上接口返回字段 + updateVoucher(gl_voucher,item); + } + }else{//失败 + //更新凭证上接口返回字段 + updateVoucher(gl_voucher,responseStr); + } + //5.记录到接口日志表 + LogBillUtils.SaveLogBill(sap_syn_voucher_url,responseStr,AppflgConstant.SAP_SYN_VOUCHER_URL_NNAME,xml); + } + } catch (JAXBException ex) { + OperateErrorInfo operateErrorInfo = new OperateErrorInfo(); +// operateErrorInfo.setMessage(exc.getMessage()); + operateErrorInfo.setErrorLevel(ErrorLevel.Error.name()); + operateErrorInfo.setPkValue(dataEntity.getPkValue()); + this.operationResult.addErrorInfo(operateErrorInfo); + throw new RuntimeException(ex); + } catch (UnsupportedEncodingException ex) { + throw new RuntimeException(ex); + } + + + } + System.out.println(integer); + } + + public static void updateVoucher (DynamicObject voucher,Item item) { + String zstatus = item.getZstatus(); + String packgid = item.getPackgid(); + String docid = item.getDocid(); + String promsg = item.getPromsg(); + String bukrs = item.getBukrs(); + String gjahr = item.getGjahr(); + String monat = item.getMonat(); + String belnr = item.getBelnr(); + String wbdate = item.getWbdate(); + voucher.set("shkd_zstatus","S".equals(zstatus)?"1":"0"); + voucher.set("shkd_packgid",packgid); + voucher.set("shkd_docid",docid); + voucher.set("shkd_promsg",promsg); + voucher.set("shkd_bukrs",bukrs); + voucher.set("shkd_gjahr",gjahr); + voucher.set("shkd_monat",monat); + voucher.set("shkd_belnr",belnr); + voucher.set("shkd_wbdate",wbdate); + SaveServiceHelper.save(new DynamicObject[]{voucher}); + } + public static void updateVoucher (DynamicObject voucher,String resultStr) { + voucher.set("zstatus","0"); + voucher.set("promsg",resultStr); + SaveServiceHelper.save(new DynamicObject[]{voucher}); + } + + public static DT_DOCUMENT_IF_SRC setData(DT_DOCUMENT_IF_SRCDATAIS_HEADER header, DT_DOCUMENT_IF_SRCDATAIT_ITEMITEM items){ + DT_DOCUMENT_IF_SRC srcData = new DT_DOCUMENT_IF_SRC(); + DT_DOCUMENT_IF_SRCDATA data = new DT_DOCUMENT_IF_SRCDATA(); + // build header + data.setIS_HEADER(header); + //build items1 + data.setIT_ITEM(items); + + srcData.setDATA(data); + return srcData; + } +} diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/opplugin/SynchronizaSapOPPlugin.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/opplugin/SynchronizaSapOPPlugin.java index 3203bc1..7a77582 100644 --- a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/opplugin/SynchronizaSapOPPlugin.java +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/opplugin/SynchronizaSapOPPlugin.java @@ -92,7 +92,7 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); break; } -// boolean shkd_sap_supplier_in = account.getBoolean("shkd_sap_supplier_in");//供应商是否必须 + boolean shkd_sap_supplier_in = account.getBoolean("shkd_sap_supplier_in");//供应商是否必须 // boolean shkd_sap_kostl_in = account.getBoolean("shkd_sap_kostl_in");//成本中心是否必须 String shkd_sap_blart = account.getString("shkd_sap_blart");//SAP凭证类型 String shkd_sap_bschl_j = account.getString("shkd_sap_bschl_j");//SAP记账代码(借) @@ -127,6 +127,9 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { } + String shkd_sap_sup_number = "";//核算维度 供应商编码 + String shkd_sap_cus_number = "";//核算维度 客户编码 + String shkd_sap_dep_number = "";//核算维度 部门编码 DynamicObject assgrp = entry.getDynamicObject("assgrp"); if (null != assgrp) { @@ -142,11 +145,11 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { switch (asstype) { case "f0001": //客户 - DynamicObject dynamicObject = QueryServiceHelper.queryOne("bd_customer", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); - String shkd_sap_number = dynamicObject.getString("shkd_sap_number"); - if(StringUtils.isEmpty(shkd_sap_number)){ + DynamicObject customer = QueryServiceHelper.queryOne("bd_customer", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); + shkd_sap_cus_number = customer.getString("shkd_sap_number"); + if(StringUtils.isEmpty(shkd_sap_cus_number)){ errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); - errStr.append("客户：").append(dynamicObject.getString("number")).append(" ").append(dynamicObject.getString("name")); + errStr.append("客户：").append(customer.getString("number")).append(" ").append(customer.getString("name")); errStr.append(" 未维护SAP编码映射，请先维护;").append("\r"); this.operationResult.setShowMessage(true); this.operationResult.setSuccess(false); @@ -158,11 +161,11 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { break; case "f000005": //供应商 - dynamicObject = QueryServiceHelper.queryOne("bd_supplier", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); - shkd_sap_number = dynamicObject.getString("shkd_sap_number"); - if(StringUtils.isEmpty(shkd_sap_number)){ + DynamicObject supplier = QueryServiceHelper.queryOne("bd_supplier", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); + shkd_sap_sup_number = supplier.getString("shkd_sap_number"); + if(StringUtils.isEmpty(shkd_sap_sup_number)){ errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); - errStr.append("供应商：").append(dynamicObject.getString("number")).append(" ").append(dynamicObject.getString("name")); + errStr.append("供应商：").append(supplier.getString("number")).append(" ").append(supplier.getString("name")); errStr.append(" 未维护SAP编码映射，请先维护;").append("\r"); this.operationResult.setShowMessage(true); this.operationResult.setSuccess(false); @@ -174,11 +177,11 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { break; case "f000009": //部门 - dynamicObject = QueryServiceHelper.queryOne("bos_adminorg", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); - shkd_sap_number = dynamicObject.getString("shkd_sap_number"); - if(StringUtils.isEmpty(shkd_sap_number)){ + DynamicObject adminOrg = QueryServiceHelper.queryOne("bos_adminorg", "id,name,number,shkd_sap_number", new QFilter[]{new QFilter("id", QCP.equals, assval)}); + shkd_sap_dep_number = adminOrg.getString("shkd_sap_number"); + if(StringUtils.isEmpty(shkd_sap_dep_number)){ errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); - errStr.append("部门：").append(dynamicObject.getString("number")).append(" ").append(dynamicObject.getString("name")); + errStr.append("部门：").append(adminOrg.getString("number")).append(" ").append(adminOrg.getString("name")); errStr.append(" 未维护SAP编码映射，请先维护;").append("\r"); this.operationResult.setShowMessage(true); this.operationResult.setSuccess(false); @@ -194,6 +197,16 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { } } + //如果 科目上 SAP供应商核算维度必须传，并且当前金蝶科目没核算维度为供应商，且科目上维护的SAP默认供应商编码为空，则校验不通过 + if(shkd_sap_supplier_in&&StringUtils.isEmpty(shkd_sap_sup_number)&&StringUtils.isEmpty(account.getString("shkd_sap_sup_num"))){ + errStr.append("凭证号：").append(voucherNo).append("不满足同步条件，原因："); + errStr.append("会计科目：").append(account.getString("number")).append(" ").append(account.getString("name")); + errStr.append(" SAP系统要求供应商必须，当前凭证上科目无供应商核算维度或科目映射未维护SAP默认供应商编码，请先维护;").append("\r"); + this.operationResult.setShowMessage(true); + this.operationResult.setSuccess(false); + this.operationResult.setMessage("数据校验不通过:"+errStr.toString()); + break; + } entryIsCheckPass=true; } @@ -242,7 +255,7 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { //5.数据包唯一标识号(PACKGID)--格式：JDN+时间戳 String packgid = "JDN" + date.getTime(); //6.数据状态（T：测试运行，P：正式运行）(ZFLAG)--固定传T - String zflag = "T"; + String zflag = "P"; header.setBUKRS(shkd_sap_number); header.setCRDATE(crdate); header.setCRNAME(crname); @@ -308,15 +321,16 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { //总账科目 DynamicObject account = entry.getDynamicObject("account"); String hkont = account.getString("shkd_sap_number"); + blart =account.getString("shkd_sap_blart");//SAP 科目-凭证类型 //记账代码 String bschl = ""; //凭证货币金额 BigDecimal oriamount = BigDecimal.ZERO; if ("1".equals(entry.getString("entrydc"))) { - bschl = "40"; + bschl = account.getString("shkd_sap_bschl_j"); oriamount = entry.getBigDecimal("debitori"); } else if ("-1".equals(entry.getString("entrydc"))) { - bschl = "50"; + bschl = account.getString("shkd_sap_bschl_d");; oriamount = entry.getBigDecimal("creditori"); } String wrbtr = oriamount.toString(); @@ -365,6 +379,11 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { } } + //如果科目上维护了SAP默认供应商编码，则以科目维护的为准 + String shkd_sap_sup_num = account.getString("shkd_sap_sup_num"); + if(StringUtils.isNotEmpty(shkd_sap_sup_num)){ + LIFNR = shkd_sap_sup_num; + } items1.setDOCID(docid); items1.setITEMNO(seq); diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/sap/requst/docuentif/DT_DOCUMENT_IF_SRCDATAIS_HEADER.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/sap/requst/docuentif/DT_DOCUMENT_IF_SRCDATAIS_HEADER.java index 6177e42..b2e53f9 100644 --- a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/sap/requst/docuentif/DT_DOCUMENT_IF_SRCDATAIS_HEADER.java +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/sap/requst/docuentif/DT_DOCUMENT_IF_SRCDATAIS_HEADER.java @@ -7,6 +7,8 @@ package shkd.fi.fi.sap.requst.docuentif; +import shkd.fi.fi.util.CharsetUtils; + public class DT_DOCUMENT_IF_SRCDATAIS_HEADER implements java.io.Serializable { private String BUKRS; @@ -45,7 +47,7 @@ public class DT_DOCUMENT_IF_SRCDATAIS_HEADER implements java.io.Serializable { * @return BUKRS */ public String getBUKRS() { - return BUKRS; + return CharsetUtils.getUtf8Str(BUKRS); } @@ -65,7 +67,7 @@ public class DT_DOCUMENT_IF_SRCDATAIS_HEADER implements java.io.Serializable { * @return CRDATE */ public String getCRDATE() { - return CRDATE; + return CharsetUtils.getUtf8Str(CRDATE); } @@ -85,7 +87,7 @@ public class DT_DOCUMENT_IF_SRCDATAIS_HEADER implements java.io.Serializable { * @return CRNAME */ public String getCRNAME() { - return CRNAME; + return CharsetUtils.getUtf8Str(CRNAME); } @@ -105,7 +107,7 @@ public class DT_DOCUMENT_IF_SRCDATAIS_HEADER implements java.io.Serializable { * @return ZRTOALL */ public String getZRTOALL() { - return ZRTOALL; + return CharsetUtils.getUtf8Str(ZRTOALL); } @@ -125,7 +127,7 @@ public class DT_DOCUMENT_IF_SRCDATAIS_HEADER implements java.io.Serializable { * @return PACKGID */ public String getPACKGID() { - return PACKGID; + return CharsetUtils.getUtf8Str(PACKGID); } @@ -145,7 +147,7 @@ public class DT_DOCUMENT_IF_SRCDATAIS_HEADER implements java.io.Serializable { * @return ZFLAG */ public String getZFLAG() { - return ZFLAG; + return CharsetUtils.getUtf8Str(ZFLAG); } @@ -158,68 +160,6 @@ public class DT_DOCUMENT_IF_SRCDATAIS_HEADER implements java.io.Serializable { this.ZFLAG = ZFLAG; } - private Object __equalsCalc = null; - public synchronized boolean equals(Object obj) { - if (!(obj instanceof DT_DOCUMENT_IF_SRCDATAIS_HEADER)) return false; - DT_DOCUMENT_IF_SRCDATAIS_HEADER other = (DT_DOCUMENT_IF_SRCDATAIS_HEADER) obj; - if (obj == null) return false; - if (this == obj) return true; - if (__equalsCalc != null) { - return (__equalsCalc == obj); - } - __equalsCalc = obj; - boolean _equals; - _equals = true && - ((this.BUKRS==null && other.getBUKRS()==null) || - (this.BUKRS!=null && - this.BUKRS.equals(other.getBUKRS()))) && - ((this.CRDATE==null && other.getCRDATE()==null) || - (this.CRDATE!=null && - this.CRDATE.equals(other.getCRDATE()))) && - ((this.CRNAME==null && other.getCRNAME()==null) || - (this.CRNAME!=null && - this.CRNAME.equals(other.getCRNAME()))) && - ((this.ZRTOALL==null && other.getZRTOALL()==null) || - (this.ZRTOALL!=null && - this.ZRTOALL.equals(other.getZRTOALL()))) && - ((this.PACKGID==null && other.getPACKGID()==null) || - (this.PACKGID!=null && - this.PACKGID.equals(other.getPACKGID()))) && - ((this.ZFLAG==null && other.getZFLAG()==null) || - (this.ZFLAG!=null && - this.ZFLAG.equals(other.getZFLAG()))); - __equalsCalc = null; - return _equals; - } - - private boolean __hashCodeCalc = false; - public synchronized int hashCode() { - if (__hashCodeCalc) { - return 0; - } - __hashCodeCalc = true; - int _hashCode = 1; - if (getBUKRS() != null) { - _hashCode += getBUKRS().hashCode(); - } - if (getCRDATE() != null) { - _hashCode += getCRDATE().hashCode(); - } - if (getCRNAME() != null) { - _hashCode += getCRNAME().hashCode(); - } - if (getZRTOALL() != null) { - _hashCode += getZRTOALL().hashCode(); - } - if (getPACKGID() != null) { - _hashCode += getPACKGID().hashCode(); - } - if (getZFLAG() != null) { - _hashCode += getZFLAG().hashCode(); - } - __hashCodeCalc = false; - return _hashCode; - } } diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/sap/requst/docuentif/DT_DOCUMENT_IF_SRCDATAIT_ITEM.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/sap/requst/docuentif/DT_DOCUMENT_IF_SRCDATAIT_ITEM.java index 670c0e6..0ddc3fc 100644 --- a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/sap/requst/docuentif/DT_DOCUMENT_IF_SRCDATAIT_ITEM.java +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/sap/requst/docuentif/DT_DOCUMENT_IF_SRCDATAIT_ITEM.java @@ -7,6 +7,8 @@ package shkd.fi.fi.sap.requst.docuentif; +import shkd.fi.fi.util.CharsetUtils; + import javax.xml.bind.annotation.XmlAccessType; import javax.xml.bind.annotation.XmlAccessorType; import javax.xml.bind.annotation.XmlElement; @@ -189,7 +191,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return DOCID */ public String getDOCID() { - return DOCID; + return CharsetUtils.getUtf8Str(DOCID); } @@ -209,7 +211,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return ITEMNO */ public String getITEMNO() { - return ITEMNO; + return CharsetUtils.getUtf8Str(ITEMNO); } @@ -229,7 +231,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return ZSTATUS */ public String getZSTATUS() { - return ZSTATUS; + return CharsetUtils.getUtf8Str(ZSTATUS); } @@ -249,7 +251,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return BUKRS */ public String getBUKRS() { - return BUKRS; + return CharsetUtils.getUtf8Str(BUKRS); } @@ -269,7 +271,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return BUDAT */ public String getBUDAT() { - return BUDAT; + return CharsetUtils.getUtf8Str(BUDAT); } @@ -289,7 +291,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return BLDAT */ public String getBLDAT() { - return BLDAT; + return CharsetUtils.getUtf8Str(BLDAT); } @@ -309,7 +311,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return BKTXT */ public String getBKTXT() { - return BKTXT; + return CharsetUtils.getUtf8Str(BKTXT); } @@ -329,7 +331,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return WAERS */ public String getWAERS() { - return WAERS; + return CharsetUtils.getUtf8Str(WAERS); } @@ -349,7 +351,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return WWERT */ public String getWWERT() { - return WWERT; + return CharsetUtils.getUtf8Str(WWERT); } @@ -369,7 +371,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return BLART */ public String getBLART() { - return BLART; + return CharsetUtils.getUtf8Str(BLART); } @@ -389,7 +391,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return HKONT */ public String getHKONT() { - return HKONT; + return CharsetUtils.getUtf8Str(HKONT); } @@ -409,7 +411,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return BSCHL */ public String getBSCHL() { - return BSCHL; + return CharsetUtils.getUtf8Str(BSCHL); } @@ -429,7 +431,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return UMSKZ */ public String getUMSKZ() { - return UMSKZ; + return CharsetUtils.getUtf8Str(UMSKZ); } @@ -449,7 +451,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return WRBTR */ public String getWRBTR() { - return WRBTR; + return CharsetUtils.getUtf8Str(WRBTR); } @@ -469,7 +471,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return DMBTR */ public String getDMBTR() { - return DMBTR; + return CharsetUtils.getUtf8Str(DMBTR); } @@ -489,7 +491,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return ZUONR */ public String getZUONR() { - return ZUONR; + return CharsetUtils.getUtf8Str(ZUONR); } @@ -509,7 +511,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return SGTXT */ public String getSGTXT() { - return SGTXT; + return CharsetUtils.getUtf8Str(SGTXT); } @@ -529,7 +531,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return KOSTL */ public String getKOSTL() { - return KOSTL; + return CharsetUtils.getUtf8Str(KOSTL); } @@ -549,7 +551,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return PRCTR */ public String getPRCTR() { - return PRCTR; + return CharsetUtils.getUtf8Str(PRCTR); } @@ -569,7 +571,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return GSBER */ public String getGSBER() { - return GSBER; + return CharsetUtils.getUtf8Str(GSBER); } @@ -589,7 +591,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return KUNNR */ public String getKUNNR() { - return KUNNR; + return CharsetUtils.getUtf8Str(KUNNR); } @@ -609,7 +611,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return LIFNR */ public String getLIFNR() { - return LIFNR; + return CharsetUtils.getUtf8Str(LIFNR); } @@ -629,7 +631,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return AUFNR */ public String getAUFNR() { - return AUFNR; + return CharsetUtils.getUtf8Str(AUFNR); } @@ -649,7 +651,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return VALUT */ public String getVALUT() { - return VALUT; + return CharsetUtils.getUtf8Str(VALUT); } @@ -669,7 +671,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return XREF1 */ public String getXREF1() { - return XREF1; + return CharsetUtils.getUtf8Str(XREF1); } @@ -689,7 +691,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return XREF2 */ public String getXREF2() { - return XREF2; + return CharsetUtils.getUtf8Str(XREF2); } @@ -709,7 +711,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return XREF3 */ public String getXREF3() { - return XREF3; + return CharsetUtils.getUtf8Str(XREF3); } @@ -729,7 +731,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return VBUND */ public String getVBUND() { - return VBUND; + return CharsetUtils.getUtf8Str(VBUND); } @@ -749,7 +751,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return ZZCUSTOMER */ public String getZZCUSTOMER() { - return ZZCUSTOMER; + return CharsetUtils.getUtf8Str(ZZCUSTOMER); } @@ -769,7 +771,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return ZZVENDOR */ public String getZZVENDOR() { - return ZZVENDOR; + return CharsetUtils.getUtf8Str(ZZVENDOR); } @@ -789,7 +791,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return ZZFIELD1 */ public String getZZFIELD1() { - return ZZFIELD1; + return CharsetUtils.getUtf8Str(ZZFIELD1); } @@ -809,7 +811,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return ZZFIELD2 */ public String getZZFIELD2() { - return ZZFIELD2; + return CharsetUtils.getUtf8Str(ZZFIELD2); } @@ -829,7 +831,7 @@ public class DT_DOCUMENT_IF_SRCDATAIT_ITEM implements java.io.Serializable { * @return ZZFIELD3 */ public String getZZFIELD3() { - return ZZFIELD3; + return CharsetUtils.getUtf8Str(ZZFIELD3); } diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/CharsetUtils.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/CharsetUtils.java new file mode 100644 index 0000000..72ef997 --- /dev/null +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/CharsetUtils.java @@ -0,0 +1,17 @@ +package shkd.fi.fi.util; + +import java.io.UnsupportedEncodingException; + +public class CharsetUtils { + + public static String getUtf8Str(String str){ + try { + byte[] bytes = str.getBytes("UTF-8"); + String strUft8 = new String(bytes,"UTF-8"); + return strUft8; + } catch (UnsupportedEncodingException e) { +// throw new RuntimeException(e); + return str; + } + } +} diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/FileUtils.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/FileUtils.java new file mode 100644 index 0000000..fcda6e9 --- /dev/null +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/FileUtils.java @@ -0,0 +1,38 @@ +package shkd.fi.fi.util; +import java.io.FileInputStream; +import java.io.IOException; +import java.util.ArrayList; +import java.util.List; + +public class FileUtils { + + /** + * 根据文件路径，获取文件16进制内容 + * @param filePath 文件路径 + * @return 16进制字符串 + */ + public static String fileToHex(String filePath){ + String hexString =""; + try { + FileInputStream fis = new FileInputStream(filePath); + List hexValues = new ArrayList<>(); + + int b; + while ((b = fis.read()) != -1) { + hexValues.add(b); + } + + StringBuilder hexBuilder = new StringBuilder(); + for (int value : hexValues) { + hexBuilder.append(String.format("%02x", value)); + } + hexString = hexBuilder.toString(); +// System.out.println(hexString); + fis.close(); +// return hexString; + } catch (IOException e) { + e.printStackTrace(); + } + return hexString; + } +} diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/HttpUtils.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/HttpUtils.java index 33ceaad..da9c2d6 100644 --- a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/HttpUtils.java +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/HttpUtils.java @@ -1,7 +1,9 @@ package shkd.fi.fi.util; +import oadd.org.apache.calcite.avatica.org.apache.http.entity.StringEntity; import oadd.org.apache.commons.httpclient.HttpClient; import oadd.org.apache.commons.httpclient.methods.PostMethod; +import oadd.org.apache.commons.httpclient.methods.StringRequestEntity; import java.io.BufferedReader; import java.io.InputStream; @@ -31,10 +33,16 @@ public class HttpUtils { try{ //设置请求头部类型 myPost.setRequestHeader("Content-Type","application/xml"); - myPost.setRequestHeader("charset","utf-8"); + myPost.setRequestHeader("charset","UTF-8"); myPost.setRequestHeader("Authorization", "Basic "+token); //设置请求体，即xml文本内容，一种是直接获取xml内容字符串，一种是读取xml文件以流的形式 - myPost.setRequestBody(xmlString); + byte[] utf8Bytes = xmlString.getBytes("UTF-8"); + String utf8Str = new String(utf8Bytes, "UTF-8"); +// myPost.setRequestBody(utf8Str); +// String content, String contentType, String charset + StringRequestEntity requestEntity = new StringRequestEntity(utf8Str, "application/xml","UTF-8"); + myPost.setRequestEntity(requestEntity); + int status = client.executeMethod(myPost); resultMap.put(STATUS,status); InputStream inputStream = myPost.getResponseBodyAsStream(); diff --git a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/XmlUtils.java b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/XmlUtils.java index 0a22605..e87fa0a 100644 --- a/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/XmlUtils.java +++ b/fi/shkd-fi-fi/src/main/java/shkd/fi/fi/util/XmlUtils.java @@ -47,7 +47,10 @@ public class XmlUtils { xml.append(xmlContent); xml.append(""); xml.append(""); - return xml.toString(); + String xmlStr = xml.toString(); + byte[] utf8Bytes = xmlStr.getBytes("UTF-8"); + String utf8Str = new String(utf8Bytes, "UTF-8"); + return utf8Str; } public static DT_DOCUMENT_IF_SRC setData(){