package com.fzzy.push.gd2020.v2;
|
|
import com.fzzy.api.data.AuthToken;
|
import com.fzzy.api.entity.Api1310;
|
import com.fzzy.api.entity.ApiConfs;
|
import com.fzzy.push.gd2020.GDResult;
|
import com.fzzy.push.gd2020.GDUtils;
|
import com.fzzy.push.gd2020.InvokeResult;
|
import com.fzzy.push.gd2020.JaxbUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.cxf.endpoint.Client;
|
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
|
|
import javax.xml.namespace.QName;
|
|
/**
|
* @Desc: 质检数据接口
|
* @author: Andy
|
* @update-time: 2022/10/30
|
*/
|
@Slf4j
|
public class ZlglInventoryWebservice {
|
|
public static ZlglInventoryWebservice newInstance() {
|
return new ZlglInventoryWebservice();
|
}
|
|
|
public String xml_Webservice = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"zlgl_quality_check\"><kddm desc=\"库点代码\" type=\"varchar\" length=\"32\" requir=\"必填\">{kddm}</kddm><kddm desc=\"质检报告单编码\" type=\"varchar\" length=\"14\" requir=\"必填\">{kddm}</kddm><hwbm desc=\"货位编码\" type=\"varchar\" length=\"33\" requir=\"必填\">{hwbm}</hwbm><varieties desc=\"粮食品种\" type=\"varchar\" length=\"32\" requir=\"必填\">{varieties}</varieties><level desc=\"粮食等级\" type=\"varchar\" length=\"32\" requir=\"必填\">{level}</level><rkrq desc=\"入库日期\" type=\"varchar\" length=\"10\" requir=\"必填\">{rkrq}</rkrq><jylbbm desc=\"检验类别编码\" type=\"varchar\" length=\"2\" requir=\"必填\">{jylbbm}</jylbbm><jydw desc=\"检验单位\" type=\"varchar\" length=\"64\" requir=\"必填\">{jydw}</jydw><jyyj desc=\"检验依据\" type=\"varchar\" length=\"1\" requir=\"必填\">{jyyj}</jyyj><zblb desc=\"指标类别\" type=\"varchar\" length=\"8\" requir=\"必填\">{zblb}</zblb><jyxm desc=\"检验项目\" type=\"varchar\" length=\"1000\" requir=\"必填\">{jyxm}</jyxm><jyxmz desc=\"检验项目值\" type=\"varchar\" length=\"1000\" requir=\"必填\">{jyxmz}</jyxmz><zlzbjgpd desc=\"质量指标结果判定\" type=\"varchar\" length=\"128\" requir=\"必填\">{zlzbjgpd}</zlzbjgpd><shrxm desc=\"审核人姓名\" type=\"varchar\" length=\"64\" requir=\"必填\">{shrxm}</shrxm><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{zhgxsj}</zhgxsj><qysj desc=\"扦样时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{qysj}</qysj><qyqy desc=\"扦样区域\" type=\"varchar\" length=\"64\" requir=\"必填\">{qyqy}</qyqy><qyrxm desc=\"扦样人姓名\" type=\"varchar\" length=\"32\" requir=\"必填\">{qyrxm}</qyrxm><ypsl desc=\"样品数量\" type=\"decimal\" length=\"20\" requir=\"必填\">{ypsl}</ypsl><dbsl desc=\"代表数量\" type=\"decimal\" length=\"20\" requir=\"必填\">{dbsl}</dbsl><ypdj desc=\"样品等级\" type=\"varchar\" length=\"2\" requir=\"必填\">{ypdj}</ypdj><sfzcccnx desc=\"是否正常存储年限\" type=\"varchar\" length=\"1\" requir=\"必填\">{sfzcccnx}</sfzcccnx><crklx desc=\"出入库类型\" type=\"varchar\" length=\"1\" requir=\"必填\">{crklx}</crklx><pch desc=\"出入库批次号\" type=\"varchar\" length=\"32\" requir=\"必填\">{pch}</pch><bz desc=\"备注\" type=\"varchar\" length=\"200\" requir=\"可选\">{bz}</bz><jdrxm desc=\"监督人姓名\" type=\"varchar\" length=\"32\" requir=\"可选\">{jdrxm}</jdrxm><ypbh desc=\"样品编号\" type=\"varchar\" length=\"64\" requir=\"可选\">{ypbh}</ypbh><qydbh desc=\"扦样单编号\" type=\"varchar\" length=\"64\" requir=\"可选\">{qydbh}</qydbh><qfrq desc=\"签发日期\" type=\"varchar\" length=\"10\" requir=\"可选\">{qfrq}</qfrq><bgcjsj desc=\"报告出具时间\" type=\"varchar\" length=\"19\" requir=\"可选\">{bgcjsj}</bgcjsj><jyr desc=\"检验人\" type=\"varchar\" length=\"128\" requir=\"可选\">{jyr}</jyr><jysj desc=\"检验时间\" type=\"varchar\" length=\"19\" requir=\"可选\">{jysj}</jysj></row></root>";
|
|
|
public InvokeResult Webservice(AuthToken authToken, ApiConfs conf, Api1310 data) {
|
InvokeResult invokeResult = new InvokeResult();
|
|
ClassLoader cl = Thread.currentThread().getContextClassLoader();
|
|
String url = conf.getApiUrl() + "/zlglInventoryWebservice?wsdl"; //填写调用库存质量数据接口服务
|
String method = "zlglInventorySaveRecordBase"; //填写库存质量数据方法名
|
String nameSpace = "http://service.sljt.com"; //填写调用省平台命名空间
|
Thread.currentThread().setContextClassLoader(cl);
|
JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
|
Client client = dcf.createClient(url);
|
QName name = new QName(nameSpace, method);
|
Object[] objects;
|
|
try {
|
|
String xmlStr = zlglInventoryWebserviceXml(data);// 获取接口的输入报文，根据需要填写相应的报文
|
|
log.debug("------xmlStr--{}", xmlStr);
|
|
|
objects = client.invoke(name, new Object[]{authToken.getToken(), xmlStr});
|
|
log.debug("-----------返回信息---{}", objects[0].toString());
|
|
invokeResult = JaxbUtil.converyToJavaBean(objects[0].toString(), InvokeResult.class);
|
|
} catch (Exception e) {
|
log.error("----执行异常----{}", e);
|
invokeResult.setCode(GDResult.CODE_500.getCode());
|
invokeResult.setData("后端服务执行异常：+" + e.getMessage());
|
return invokeResult;
|
}
|
|
return invokeResult;
|
}
|
|
|
/**
|
* 报文获取--替换数据
|
*
|
* @param data
|
* @return
|
*/
|
public String zlglInventoryWebserviceXml(Api1310 data) {
|
String xmlStr = xml_Webservice;
|
xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码
|
xmlStr = xmlStr.replace("{hwbm}", GDUtils.formatStr(data.getHwdm()));//货位编码
|
xmlStr = xmlStr.replace("{zjbgdbh}", GDUtils.formatStr(data.getZbjgpd()));//质检报告单编码
|
xmlStr = xmlStr.replace("{varieties}", GDUtils.formatStr(data.getLspzdm()));//粮食品种
|
xmlStr = xmlStr.replace("{level}", GDUtils.formatStr(data.getLsdjdm()));//粮食等级
|
xmlStr = xmlStr.replace("{rkrq}", GDUtils.formatDate(data.getRkrq(), "yyyy-MM-dd"));//入库日期
|
xmlStr = xmlStr.replace("{jysj}", GDUtils.formatDate(data.getJysj(), "yyyy-MM-dd HH:mm:ss"));//检验时间
|
xmlStr = xmlStr.replace("{qfrq}", GDUtils.formatDate(data.getQfrq(), "yyyy-MM-dd"));//签发时间
|
xmlStr = xmlStr.replace("{bgcjsj}", GDUtils.formatDate(data.getBgcjsj(), "yyyy-MM-dd HH:mm:ss"));//报告出具时间
|
xmlStr = xmlStr.replace("{jylbbm}", GDUtils.formatStr(data.getJylb()));//检验类别编码 01：入仓验收 02：出仓检验
|
xmlStr = xmlStr.replace("{jyr}", GDUtils.formatStr(data.getJyr()));//检验人
|
xmlStr = xmlStr.replace("{jyyj}", GDUtils.formatStr(data.getJyyj()));//检验依据
|
xmlStr = xmlStr.replace("{zblb}", GDUtils.formatStr(data.getZblb()));//指标类别
|
xmlStr = xmlStr.replace("{jyxm}", GDUtils.formatStr(data.getJyxm()));//检验项目
|
xmlStr = xmlStr.replace("{jyxmz}", GDUtils.formatStr(data.getJyxmz()));//检验项目值
|
xmlStr = xmlStr.replace("{qyqy}", GDUtils.formatStr(data.getQyqy()));//扦样区域
|
xmlStr = xmlStr.replace("{qyrxm}", GDUtils.formatStr(data.getQyrxm()));//扦样人姓名
|
xmlStr = xmlStr.replace("{ypbh}", GDUtils.formatStr(data.getYpbh()));//样品编号
|
xmlStr = xmlStr.replace("{ypdj}", GDUtils.formatStr(data.getYpdj()));//样品等级
|
xmlStr = xmlStr.replace("{ypsl}", GDUtils.formatNum(data.getYpsl()));//样品数量
|
xmlStr = xmlStr.replace("{ybsl}", GDUtils.formatNum(data.getDbsl()));//代表数量
|
xmlStr = xmlStr.replace("{sfzcccnx}", GDUtils.formatStr(data.getSfzcccnx()));//是否正常存储年限
|
xmlStr = xmlStr.replace("{bz}", GDUtils.formatStr(data.getBz()));//备注
|
|
String ywdh = "";
|
//出入库类型 0：入库1：出库2：在库 9：其他
|
if ("01".equals(data.getJylb())) {
|
xmlStr = xmlStr.replace("{crklx}", GDUtils.formatStr("0"));
|
|
// 出库业务单号-- 由 12 位数字组成，第 1-2 位为业务编码 （14 代表粮食入库），第3-8 位依次为年份的后两位、2 位月份、2 位日期，后四位为顺序码。例如：141605041234
|
ywdh = "14" + data.getBizId().substring(2);
|
|
}
|
if ("02".equals(data.getJylb())) {
|
xmlStr = xmlStr.replace("{crklx}", GDUtils.formatStr("1"));
|
|
// 出库业务单号-- 由 12 位数字组成，第 1-2 位为业务编码 （15 代表粮食出库），第3-8 位依次为年份的后两位、2 位月份、2 位日期，后四位为顺序码。例如：141605041234
|
ywdh = "15" + data.getBizId().substring(2);
|
|
}
|
xmlStr = xmlStr.replace("{pch}", GDUtils.formatStr(ywdh));//出入库批次号
|
|
xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志
|
xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间
|
return xmlStr;
|
}
|
}
|
