|
|
|
@ -4,6 +4,8 @@ import com.alibaba.fastjson.JSON; |
|
|
|
import com.alibaba.fastjson.JSONArray; |
|
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
|
import com.yxt.anrui.fin.api.kingdee.KingDeeResult; |
|
|
|
import com.yxt.anrui.fin.api.kingdee.auditKd.AuditKD; |
|
|
|
import com.yxt.anrui.fin.api.kingdee.submitkd.SubmitKD; |
|
|
|
import com.yxt.common.base.utils.StringUtils; |
|
|
|
import com.yxt.common.core.result.ResultBean; |
|
|
|
import org.apache.http.Header; |
|
|
|
@ -47,18 +49,17 @@ public class KingDeeSaveSKD { |
|
|
|
* 登录金蝶的账户信息 |
|
|
|
*/ |
|
|
|
private static String lcid = "2052"; |
|
|
|
private static String url="http://121.36.43.55/k3cloud/Kingdee.BOS.WebApi.ServicesStub."; |
|
|
|
// 数据保存接口地址
|
|
|
|
private static String Save_URL = "http://121.36.43.55/k3cloud/Kingdee.BOS.WebApi.ServicesStub." + |
|
|
|
"DynamicFormService.Save.common.kdsvc"; |
|
|
|
private static String Save_URL = url+"DynamicFormService.Save.common.kdsvc"; |
|
|
|
//数据提交接口的地址
|
|
|
|
private static String Submit_URL = "http://121.36.43.55/k3cloud/Kingdee.BOS.WebApi.ServicesStub." + |
|
|
|
"DynamicFormService.Submit"; |
|
|
|
private static String Submit_URL = url+"DynamicFormService.Submit.common.kdsvc"; |
|
|
|
//数据审核接口的地址
|
|
|
|
private static String Audit_URL = "http://121.36.43.55/k3cloud/Kingdee.BOS.WebApi.ServicesStub." + |
|
|
|
"DynamicFormService.Audit"; |
|
|
|
private static String Audit_URL = url+"DynamicFormService.Audit.common.kdsvc"; |
|
|
|
//数据分配接口的地址
|
|
|
|
private static String Allocate_URL = url+"DynamicFormService.Allocate.common.kdsvc"; |
|
|
|
//登录，校验用户的API接口地址
|
|
|
|
private static String Login_URL = "http://121.36.43.55/k3cloud/Kingdee.BOS.WebApi.ServicesStub." + |
|
|
|
"AuthService.ValidateUser.common.kdsvc"; |
|
|
|
private static String Login_URL = url+"AuthService.ValidateUser.common.kdsvc"; |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
@ -90,7 +91,6 @@ public class KingDeeSaveSKD { |
|
|
|
try { |
|
|
|
URI save_uri = new URI(Save_URL); |
|
|
|
HttpPost method = new HttpPost(save_uri); |
|
|
|
//采购入库单保存参数
|
|
|
|
log.info(jsonParam.getData()); |
|
|
|
/*String ss="{\"formId\":\"AR_receivable\",\"data\":\"{\\\"Creator\\\":\\\"\\\",\\\"NeedUpDateFields\\\":[],\\\"NeedReturnFields\\\":[],\\\"IsDeleteEntry\\\":\\\"True\\\",\\\"SubSystemId\\\":\\\"\\\",\\\"IsVerifyBaseDataField\\\":\\\"false\\\",\\\"IsEntryBatchFill\\\":\\\"True\\\",\\\"ValidateFlag\\\":\\\"True\\\",\\\"NumberSearch\\\":\\\"True\\\",\\\"InterationFlags\\\":\\\"\\\",\\\"Model\\\":{\\\"FID\\\":0,\\\"FBillTypeID\\\":{\\\"FNUMBER\\\":\\\"YSD01_SYS\\\"},\\\"FDATE\\\":\\\"2022-08-02 00:00:00\\\",\\\"FISINIT\\\":false,\\\"FENDDATE_H\\\":\\\"2022-08-02 00:00:00\\\",\\\"FCUSTOMERID\\\":{\\\"FNumber\\\":\\\" JXYXB\\\"},\\\"FCURRENCYID\\\":{\\\"FNumber\\\":\\\"PRE001\\\"},\\\"FISPRICEEXCLUDETAX\\\":true,\\\"FSETTLEORGID\\\":{\\\"FNumber\\\":\\\"101\\\"},\\\"FPAYORGID\\\":{\\\"FNumber\\\":\\\"101\\\"},\\\"FSALEORGID\\\":{\\\"FNumber\\\":\\\"101\\\"},\\\"FISTAX\\\":true,\\\"FCancelStatus\\\":\\\"A\\\",\\\"FBUSINESSTYPE\\\":\\\"BZ\\\",\\\"FSetAccountType\\\":\\\"1\\\",\\\"FISHookMatch\\\":false,\\\"FISINVOICEARLIER\\\":false,\\\"F_PMZC_Assistant2\\\":{\\\"FNumber\\\":\\\"01\\\"},\\\"FsubHeadSuppiler\\\":{\\\"FORDERID\\\":{\\\"FNumber\\\":\\\" JXYXB\\\"},\\\"FTRANSFERID\\\":{\\\"FNumber\\\":\\\" JXYXB\\\"},\\\"FChargeId\\\":{\\\"FNumber\\\":\\\" JXYXB\\\"}},\\\"FsubHeadFinc\\\":{\\\"FACCNTTIMEJUDGETIME\\\":\\\"2022-08-02 00:00:00\\\",\\\"FMAINBOOKSTDCURRID\\\":{\\\"FNumber\\\":\\\"PRE001\\\"},\\\"FEXCHANGETYPE\\\":{\\\"FNumber\\\":\\\"HLTX01_SYS\\\"},\\\"FExchangeRate\\\":1.0,\\\"FTaxAmountFor\\\":121.01,\\\"FNoTaxAmountFor\\\":12100.99},\\\"FEntityDetail\\\":[{\\\"FMATERIALID\\\":{\\\"FNumber\\\":\\\" JX091054\\\"},\\\"FMaterialDesc\\\":\\\"X牵引6*4-550超\\\",\\\"FPRICEUNITID\\\":{\\\"FNumber\\\":\\\"liang\\\"},\\\"FPriceQty\\\":1.0,\\\"FTaxPrice\\\":12222.0,\\\"FPrice\\\":12100.99,\\\"FEntryTaxRate\\\":1.0,\\\"FNoTaxAmountFor_D\\\":12100.99,\\\"FTAXAMOUNTFOR_D\\\":121.01,\\\"FALLAMOUNTFOR_D\\\":12222.0,\\\"FDeliveryControl\\\":false,\\\"FStockUnitId\\\":{\\\"FNumber\\\":\\\"liang\\\"},\\\"FStockQty\\\":1.0,\\\"FIsFree\\\":false,\\\"FStockBaseQty\\\":1.0,\\\"FSalUnitId\\\":{\\\"FNumber\\\":\\\"liang\\\"},\\\"FSalQty\\\":1.0,\\\"FSalBaseQty\\\":1.0,\\\"FPriceBaseDen\\\":1.0,\\\"FSalBaseNum\\\":1.0,\\\"FStockBaseNum\\\":1.0}],\\\"FEntityPlan\\\":[{\\\"FENDDATE\\\":\\\"2022-08-02 00:00:00\\\",\\\"FPAYRATE\\\":100.0,\\\"FPAYAMOUNTFOR\\\":12222.0}]}}\"}"; |
|
|
|
log.info("ss-:{}",ss);*/ |
|
|
|
@ -133,16 +133,21 @@ public class KingDeeSaveSKD { |
|
|
|
/** |
|
|
|
* 调用提交金蝶的数据接口 |
|
|
|
* @param jsonParam |
|
|
|
* @param httpclient |
|
|
|
* @return |
|
|
|
*/ |
|
|
|
public static ResultBean<List<KingDeeResult>> submitKingDeeBillData(FinKingDeeService.KingDeeParams jsonParam, HttpClient httpclient) { |
|
|
|
public static ResultBean<List<KingDeeResult>> submitKingDeeBillData(FinKingDeeService.KingDeeParams jsonParam) { |
|
|
|
// 定义httpClient的实例
|
|
|
|
HttpClient httpclient = new DefaultHttpClient(); |
|
|
|
/********** 用户登录Begin ************************/ |
|
|
|
ResultBean<List<KingDeeResult>> rb1 = loginKingDeeSystem(httpclient); |
|
|
|
if (!rb1.getSuccess()) return rb1; |
|
|
|
ResultBean<List<KingDeeResult> > rb= ResultBean.fireFail(); |
|
|
|
try { |
|
|
|
URI save_uri = new URI(Save_URL); |
|
|
|
URI save_uri = new URI(Submit_URL); |
|
|
|
HttpPost method = new HttpPost(save_uri); |
|
|
|
//采购入库单保存参数
|
|
|
|
log.info(jsonParam.getData()); |
|
|
|
//String ss= "{\"formId\":\"BD_MATERIAL\",\"data\":\"{\\\"CreateOrgId\\\":\\\"\\\",\\\"Numbers\\\":[],\\\"Ids\\\":\\\"6263811\\\"}\"}";
|
|
|
|
//StringEntity entity = new StringEntity(ss, "utf-8");
|
|
|
|
StringEntity entity = new StringEntity(jsonParam.getData(), "utf-8"); |
|
|
|
log.info(JSON.toJSONString(entity)); |
|
|
|
entity.setContentEncoding("UTF-8"); |
|
|
|
@ -162,7 +167,6 @@ public class KingDeeSaveSKD { |
|
|
|
return rb.setMsg("操作失败"); |
|
|
|
} |
|
|
|
log.info(str); |
|
|
|
// auditKingDeeBillData();
|
|
|
|
return createResultBean(str); |
|
|
|
} |
|
|
|
} catch (Exception e) { |
|
|
|
@ -173,16 +177,63 @@ public class KingDeeSaveSKD { |
|
|
|
/** |
|
|
|
* 调用审核金蝶的数据接口 |
|
|
|
* @param jsonParam |
|
|
|
* @param httpclient |
|
|
|
* @return |
|
|
|
*/ |
|
|
|
public static ResultBean<List<KingDeeResult>> auditKingDeeBillData(FinKingDeeService.KingDeeParams jsonParam, HttpClient httpclient) { |
|
|
|
public static ResultBean<List<KingDeeResult>> auditKingDeeBillData(FinKingDeeService.KingDeeParams jsonParam) { |
|
|
|
// 定义httpClient的实例
|
|
|
|
HttpClient httpclient = new DefaultHttpClient(); |
|
|
|
/********** 用户登录Begin ************************/ |
|
|
|
ResultBean<List<KingDeeResult>> rb1 = loginKingDeeSystem(httpclient); |
|
|
|
if (!rb1.getSuccess()) return rb1; |
|
|
|
ResultBean<List<KingDeeResult> > rb= ResultBean.fireFail(); |
|
|
|
try { |
|
|
|
URI save_uri = new URI(Save_URL); |
|
|
|
URI save_uri = new URI(Audit_URL); |
|
|
|
HttpPost method = new HttpPost(save_uri); |
|
|
|
//采购入库单保存参数
|
|
|
|
log.info(jsonParam.getData()); |
|
|
|
log.info("jsonParam:{}",jsonParam); |
|
|
|
StringEntity entity = new StringEntity(jsonParam.getData(), "utf-8"); |
|
|
|
log.info(JSON.toJSONString(entity)); |
|
|
|
entity.setContentEncoding("UTF-8"); |
|
|
|
entity.setContentType("application/json"); |
|
|
|
//把成功登录的Session信息传进去，获取连接信息
|
|
|
|
method.setHeader(sessionkey, sessionValue); |
|
|
|
method.setHeader(aspnetsessionkey, aspnetsessionValue); |
|
|
|
//方法参数
|
|
|
|
method.setEntity(entity); |
|
|
|
HttpResponse result = httpclient.execute(method); |
|
|
|
// 请求发送成功，并得到响应
|
|
|
|
if (result.getStatusLine().getStatusCode() == 200) { |
|
|
|
log.info("请求成功"); |
|
|
|
// 读取服务器返回过来的json字符串数据
|
|
|
|
String str = EntityUtils.toString(result.getEntity()); |
|
|
|
if(StringUtils.isBlank(str)){ |
|
|
|
return rb.setMsg("操作失败"); |
|
|
|
} |
|
|
|
log.info(str); |
|
|
|
return createResultBean(str); |
|
|
|
} |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
return rb; |
|
|
|
} |
|
|
|
/** |
|
|
|
* 分配金蝶返回的数据 |
|
|
|
* @param jsonParam |
|
|
|
* @return |
|
|
|
*/ |
|
|
|
public static ResultBean<List<KingDeeResult>> allocateKingDeeBillData(FinKingDeeService.KingDeeParams jsonParam) { |
|
|
|
// 定义httpClient的实例
|
|
|
|
HttpClient httpclient = new DefaultHttpClient(); |
|
|
|
/********** 用户登录Begin ************************/ |
|
|
|
ResultBean<List<KingDeeResult>> rb1 = loginKingDeeSystem(httpclient); |
|
|
|
if (!rb1.getSuccess()) return rb1; |
|
|
|
ResultBean<List<KingDeeResult> > rb= ResultBean.fireFail(); |
|
|
|
try { |
|
|
|
URI save_uri = new URI(Allocate_URL); |
|
|
|
HttpPost method = new HttpPost(save_uri); |
|
|
|
//采购入库单保存参数
|
|
|
|
log.info("jsonParam:{}",JSON.toJSON(jsonParam.getData())); |
|
|
|
StringEntity entity = new StringEntity(jsonParam.getData(), "utf-8"); |
|
|
|
log.info(JSON.toJSONString(entity)); |
|
|
|
entity.setContentEncoding("UTF-8"); |
|
|
|
|
