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 d4ed730..e81a2d6 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 @@ -6,12 +6,18 @@ 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.logging.LogFactory; import kd.bos.servicehelper.BusinessDataServiceHelper; +import shkd.fi.fi.sap.*; +import javax.xml.rpc.ServiceException; import java.math.BigDecimal; +import java.net.MalformedURLException; +import java.net.URL; +import java.rmi.RemoteException; import java.text.SimpleDateFormat; +import java.util.ArrayList; import java.util.Date; +import java.util.List; /** * 凭证--SAP @@ -25,8 +31,15 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { Integer integer = 0; for (DynamicObject dataEntity : e.getDataEntities()) { + + //结构：ZFIS_YS_HEAD 库存-财务系统PI接口表头结构 (1-6) + DT_DOCUMENT_IF_SRCDATAIS_HEADER header = new DT_DOCUMENT_IF_SRCDATAIS_HEADER(); + //结构：ZFIS_YS_ITEM 库存-财务系统PI接口行项目结构 + ArrayList items = new ArrayList<>(); + DynamicObject gl_voucher = BusinessDataServiceHelper.loadSingle(dataEntity.getPkValue(), "gl_voucher"); try { + //1.公司代码(BUKRS)--核算组织(org) DynamicObject org = gl_voucher.getDynamicObject("org"); String shkd_sap_number = ""; @@ -36,80 +49,44 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { shkd_sap_number = bos_org.getString("shkd_sap_number"); } } - //2.公司代码(CRDATE)--当前时间 + //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 = "T"; + 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; - - - //8.库存行项目号(ITEMID)--凭证分录行号，从1开始 - String seq = ""; - for (DynamicObject entry : entries) { - seq = entry.getString("seq"); - } - //9.数据处理状态 （I未处理V校验失败F过账失败S过账成功（写死"I未处理"））(ZSTATUS)--固定值I String zstatus = "I"; - - //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); - } - //13.抬头文本(BKTXT)----凭证分录第一行摘要(如超长需截位，保留前25个字)(edescription) + String bktxt = ""; //14.货币码(WAERS)----币别基础资料的货币代码(currency) - String edescription = ""; String waers = ""; - if (entries.size() > 0) { - edescription = entries.get(0).getString("edescription"); - if (edescription.length() > 25) { - edescription = edescription.substring(0,25);//摘要 - } - //币别 - DynamicObject currency = entries.get(0).getDynamicObject("currency"); - if (null != currency) { - waers = currency.getString("number"); - } - } - //16.凭证类型 SAP凭证类型（默认值：具体值待定）(BLART)--固定值SA String blart = "SA"; - //17.总账科目(HKONT)----取会计科目上SAP科目编码，测试时，可传9999999999(account) //18.记账代码y(BSCHL)----借贷方向，40=借方，50=贷方(entrydc) //19.凭证货币金额(WRBTR)----原币金额(oriamount) @@ -117,6 +94,40 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { //20.项目文本(SGTXT)----凭证行摘要(edescription) //21.成本中心(KOSTL)----金蝶核算维度：成本中心SAP编码() for (DynamicObject entry : entries) { + DT_DOCUMENT_IF_SRCDATAIT_ITEMITEM items1 = new DT_DOCUMENT_IF_SRCDATAIT_ITEMITEM(); + + //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 = ""; @@ -142,10 +153,73 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { if (sgtxt.length() > 25) { sgtxt = sgtxt.substring(0,25); } - //todo 核算维度--未调试(待维护数据) - Object assgrp = entry.get("assgrp"); + + //todo + DynamicObject assgrp = entry.getDynamicObject("assgrp"); + if (null != assgrp) { + DynamicObject bd_accountview = BusinessDataServiceHelper.loadSingle(assgrp.getPkValue(), "bd_asstacttype"); + String number = bd_accountview.getString("number"); + switch (number){ + case "0001": + //客户 + System.out.println("客户"); + + break; + case "0005": + //供应商 + break; + default: + break; + } + } + + 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(""); + items1.setPRCTR(""); + items1.setGSBER(""); + items1.setKUNNR(""); + items1.setLIFNR(""); + items1.setAUFNR(""); + items1.setVALUT(""); + items1.setXREF1(""); + items1.setXREF2(""); + items1.setXREF3(""); + items1.setVBUND(""); + items1.setZZCUSTOMER(""); + items1.setZZVENDOR(""); + items1.setZZFIELD1(""); + items1.setZZFIELD2(""); + items1.setZZFIELD3(""); + items1.setZZFIELD4(""); + items1.setZZFIELD5(""); + items1.setZZFIELD6(""); + items1.setHBKID(""); + items1.setHKTID(""); + items1.setXNEGP(""); + items1.setKIDNO(""); + + + items.add(items1); + + } - System.out.println(docid); }catch (Exception exc){ OperateErrorInfo operateErrorInfo = new OperateErrorInfo(); operateErrorInfo.setMessage(exc.getMessage()); @@ -153,7 +227,66 @@ public class SynchronizaSapOPPlugin extends AbstractOperationServicePlugIn { operateErrorInfo.setPkValue(dataEntity.getPkValue()); this.operationResult.addErrorInfo(operateErrorInfo); } + + //调接口 + //todo 核算维度--未调试(待维护数据) ,记录条数(ZRTOALL)待确认 + try { + test (header, items); + } catch (MalformedURLException | ServiceException | RemoteException ex) { + throw new RuntimeException(ex); + } } System.out.println(integer); } + + static String userName = "PIEXTIFUSER"; + static String password = "Welcome8"; + public static void test (DT_DOCUMENT_IF_SRCDATAIS_HEADER header, List itemss) throws MalformedURLException, ServiceException, RemoteException { + + // URL url = new URL("http://172.17.8.62:50000/dir/wsdl?p=ic/29ea716b5b95384591a91eb5d10c5715"); + //必须用调用具体方法的地址 + URL url = new URL("http://sappodev.cns.cosco.cos:50000/XISOAPAdapter/MessageServlet?senderParty=&senderService=ZBS&receiverParty=&receiverService=&interface=SI_DOCUMENT_IF&interfaceNamespace=urn:coscoshipping:shhy:2020"); + + SI_DOCUMENT_IFService service = new SI_DOCUMENT_IFServiceLocator(); + SI_DOCUMENT_IFBindingStub stub = new SI_DOCUMENT_IFBindingStub(url, service); + + stub.setUsername(userName); + stub.setPassword(password); + stub.setTimeout(8000); +// org.apache.axis.client.Call createCall = stub.createCall(); +// createCall.setUsername(userName); +// createCall.setPassword(password); +// createCall.setTimeout(8000); + + DT_DOCUMENT_IF_SRC srcData = setData(header,itemss); + DT_DOCUMENT_IF_RET result = null; + +// SI_DOCUMENT_IF document_IF = new SI_DOCUMENT_IFProxy(); +// result = document_IF.SI_DOCUMENT_IF(srcData); + + result = stub.SI_DOCUMENT_IF(srcData); + +// SI_DOCUMENT_IFServiceLocator locator = new SI_DOCUMENT_IFServiceLocator(); +// SI_DOCUMENT_IF http_Port = locator.getHTTP_Port(); +// result = http_Port.SI_DOCUMENT_IF(srcData); + System.out.println(result); + DT_DOCUMENT_IF_RETDATA returnData = result.getDATA(); + DT_DOCUMENT_IF_RETDATAOT_RETNITEM[] ot_RETN = returnData.getOT_RETN(); + + } + + public static DT_DOCUMENT_IF_SRC setData(DT_DOCUMENT_IF_SRCDATAIS_HEADER header, List itemss){ + 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 + DT_DOCUMENT_IF_SRCDATAIT_ITEMITEM[] items = itemss.toArray(new DT_DOCUMENT_IF_SRCDATAIT_ITEMITEM[itemss.size()] ); + data.setIT_ITEM(items); + + srcData.setDATA(data); + return srcData; + } }