|
|
@@ -1,28 +1,18 @@
|
|
|
package com.uas.eis.service.Impl;
|
|
|
|
|
|
-import com.alibaba.fastjson.JSON;
|
|
|
-import com.alibaba.fastjson.JSONArray;
|
|
|
-import com.alibaba.fastjson.TypeReference;
|
|
|
-import com.uas.eis.config.DonlimConfig;
|
|
|
import com.uas.eis.core.config.SpObserver;
|
|
|
import com.uas.eis.core.support.TokenProperties;
|
|
|
import com.uas.eis.dao.*;
|
|
|
-import com.uas.eis.dto.*;
|
|
|
-import com.uas.eis.service.CommonService;
|
|
|
import com.uas.eis.service.ERPService;
|
|
|
-import com.uas.eis.service.NuoNuoSDKService;
|
|
|
import com.uas.eis.utils.*;
|
|
|
-import nuonuo.open.sdk.NNOpenSDK;
|
|
|
-import org.apache.commons.lang.StringUtils;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.http.HttpStatus;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import java.text.SimpleDateFormat;
|
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
|
-import java.util.stream.Stream;
|
|
|
|
|
|
/**
|
|
|
* @author koul
|
|
|
@@ -37,733 +27,230 @@ public class ERPServiceImpl implements ERPService {
|
|
|
@Autowired
|
|
|
private BaseDao baseDao;
|
|
|
|
|
|
- @Autowired
|
|
|
- private DonlimConfig donlimConfig;
|
|
|
- @Autowired
|
|
|
- private CommonService commonService;
|
|
|
- @Autowired
|
|
|
- private NuoNuoSDKService nuoNuoSDKService;
|
|
|
-
|
|
|
- @Override
|
|
|
- public Map<String, Object> pushInvoiceOrder(String master, int id) {
|
|
|
- Map<String, Object> map = new HashMap<String, Object>();
|
|
|
- Object[] obs = baseDao.getFieldsDataByCondition("YITOA_DATACENTER.dock_invoice_config", new String[]{"appKey", "appSecret", "token", "taxnum"}, "username='" + master + "'");
|
|
|
- String url = donlimConfig.getRoute();
|
|
|
- System.out.println(url);
|
|
|
- String appKey = donlimConfig.getAppKey();
|
|
|
- String appSecret = donlimConfig.getAppSecret();
|
|
|
- String token = donlimConfig.getToken();
|
|
|
- String taxnum = donlimConfig.getTaxnum();
|
|
|
- if (donlimConfig.isProd()) {
|
|
|
- appKey = obs[0].toString();
|
|
|
- appSecret = obs[1].toString();
|
|
|
- token = obs[2].toString();// 访问令牌
|
|
|
- taxnum = obs[3].toString();// 授权企业税号
|
|
|
- }
|
|
|
- logger.info("pushInvoiceOrder begin: master {} ,id {} ", master, id);
|
|
|
- SpObserver.putSp(master);
|
|
|
- SqlRowList rs_main = baseDao.queryForRowSet("select * from invoiceOrder left join customer on io_cucode=cu_code " +
|
|
|
- " left join YITOA_DATACENTER.custinvoicemsg on ci_cucode = cu_code " +
|
|
|
- " where io_id=" + id);
|
|
|
- if (rs_main.next()) {
|
|
|
- //String autoInvoiceFlag= baseDao.isDBSetting("InvoiceOrder", "autoInvoice")?"true":"false";
|
|
|
- //数据组装
|
|
|
- InvoiceOrderDTO invoiceOrderDTO = new InvoiceOrderDTO();
|
|
|
- invoiceOrderDTO.setOrderType(rs_main.getGeneralString("IO_ORDERTYPE"));
|
|
|
- invoiceOrderDTO.setAutoInvoiceFlag(rs_main.getGeneralString("io_autoinvoice"));//自动开票
|
|
|
- invoiceOrderDTO.setRepeatCall("0");
|
|
|
-
|
|
|
- OrderDTO orderDTO = new OrderDTO();
|
|
|
- orderDTO.setOriginalOrderNo(rs_main.getGeneralString("io_code"));
|
|
|
- orderDTO.setAddDate(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(rs_main.getDate("io_date")));
|
|
|
- orderDTO.setInvoiceLine(rs_main.getGeneralString("io_invoiceline"));
|
|
|
- orderDTO.setSpecificFactor("0");
|
|
|
- orderDTO.setSaleTaxNum(donlimConfig.getTaxnum());//
|
|
|
- orderDTO.setBuyerName(rs_main.getGeneralString("cu_name"));//客户名称
|
|
|
- orderDTO.setTaxNum(rs_main.getGeneralString("ci_taxnum").trim());//购方税号
|
|
|
- orderDTO.setAccount(rs_main.getGeneralString("ci_account"));
|
|
|
- orderDTO.setAddress(rs_main.getGeneralString("ci_address"));
|
|
|
- orderDTO.setTelephone(rs_main.getGeneralString("ci_telephone"));
|
|
|
- orderDTO.setRemark(rs_main.getGeneralString("io_remark"));
|
|
|
- orderDTO.setPayee(rs_main.getGeneralString("IO_PAYEE"));
|
|
|
- orderDTO.setChecker(rs_main.getGeneralString("IO_CHECKER"));
|
|
|
- orderDTO.setPhone(rs_main.getGeneralString("ci_jf_phone"));
|
|
|
- orderDTO.setEmail(rs_main.getGeneralString("ci_jf_email"));
|
|
|
- //原销售订单编号relateSaleOrderNo
|
|
|
- orderDTO.setRelateSaleOrderNo(rs_main.getGeneralString("io_RelateSaleOrderNo"));
|
|
|
- //原发票号码yfphm
|
|
|
- orderDTO.setYfphm(rs_main.getGeneralString("io_Yfphm"));
|
|
|
- invoiceOrderDTO.setOrderInfo(orderDTO);
|
|
|
-
|
|
|
- SqlRowList rs_det = baseDao.queryForRowSet("select * from invoiceOrderdet_view where id_ioid=" + id + " order by id_detno");
|
|
|
- List<OrderDetDTO> dets = new ArrayList<>();//商品列表
|
|
|
- while (rs_det.next()) {
|
|
|
- OrderDetDTO orderDetDTO = new OrderDetDTO();
|
|
|
- orderDetDTO.setRowNo(rs_det.getGeneralString("id_id"));//唯一值
|
|
|
- orderDetDTO.setGoodsName(rs_det.getGeneralString("pr_detail"));
|
|
|
- orderDetDTO.setSpec(rs_det.getGeneralString("pr_spec"));
|
|
|
- orderDetDTO.setUnit(rs_det.getGeneralString("pr_unit"));
|
|
|
- orderDetDTO.setNum(rs_det.getGeneralString("id_qty"));
|
|
|
- //orderDetDTO.setPrice(rs_det.getGeneralString("id_price"));//平台算法问题 传单价会有差异，校验可能不通过，所有传金额和数量，不传单价
|
|
|
- orderDetDTO.setTaxRate(rs_det.getGeneralString("taxrate"));//0.13
|
|
|
- orderDetDTO.setTaxAmount(rs_det.getGeneralString("id_amount"));
|
|
|
- orderDetDTO.setHsbz(rs_det.getGeneralString("hsbz"));
|
|
|
- orderDetDTO.setSpbm(rs_det.getGeneralString("spbm"));
|
|
|
- orderDetDTO.setZke(rs_det.getGeneralString("ZKE"));
|
|
|
- dets.add(orderDetDTO);
|
|
|
- }
|
|
|
- invoiceOrderDTO.setOrderOriginalDetails(dets);
|
|
|
- invoiceOrderDTO.setInvoiceGoodsTransports(new ArrayList<>());
|
|
|
- System.out.println(JSONArray.toJSONString(invoiceOrderDTO));
|
|
|
- //调用对接
|
|
|
- NNOpenSDK sdk = NNOpenSDK.getIntance();
|
|
|
- String method = "nuonuo.OpeMplatform.saveOrder"; // API方法名
|
|
|
- String content = sdk.convertToUtf8(JSONArray.toJSONString(invoiceOrderDTO));
|
|
|
- String senid = UUID.randomUUID().toString().replace("-", ""); // 唯一标识，32位随机码，无需修改，保持默认即可
|
|
|
- String result = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content);
|
|
|
- logger.info("pushInvoiceOrder resultString {}, token {}", result, token);
|
|
|
- Map<Object, Object> res = JSONUtil.toMap(result);
|
|
|
- System.out.println(result);
|
|
|
- Object status = res.get("status");
|
|
|
- Object message = res.get("message");
|
|
|
- if (status != null && "0000".equals(status.toString())) {//调用成功
|
|
|
- baseDao.execute("update invoiceOrder set io_dockstatus='对接成功',IO_INVOICESTATUS=0 where io_id=" + id);
|
|
|
- commonService.logSRecord("开票订单对接", id);
|
|
|
- } else if (status != null && "9999".equals(status.toString()) && message != null && message.toString().contains("已存在原始订单")) {
|
|
|
- baseDao.execute("update invoiceOrder set io_dockstatus='对接成功',IO_INVOICESTATUS=0 where io_id=" + id);
|
|
|
- commonService.logFRecord("开票订单对接", "(" + status + ")" + message, id);
|
|
|
- } else {
|
|
|
- baseDao.execute("update invoiceOrder set io_dockstatus='对接失败' where io_id=" + id);
|
|
|
- commonService.logFRecord("开票订单对接", "(" + status + ")" + message, id);
|
|
|
- }
|
|
|
- logger.info("pushInvoiceOrder master {} ,id {} status {} message {}", master, id, status, message);
|
|
|
- map.put("success", true);
|
|
|
- map.put("status", status);
|
|
|
- map.put("message", message);
|
|
|
- return map;
|
|
|
- } else {//数据无效
|
|
|
- logger.info("pushInvoiceOrder err {对接源信息无效} ,master {} , id {} status {} message {}", master, id);
|
|
|
- map.put("success", false);
|
|
|
- map.put("message", "对接源信息无效");
|
|
|
- return map;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Map<String, Object> invoiceOrderSubmitKp(String master, int id) {
|
|
|
- Object[] obs = baseDao.getFieldsDataByCondition("YITOA_DATACENTER.dock_invoice_config", new String[]{"appKey", "appSecret", "token", "taxnum"}, "username='" + master + "'");
|
|
|
- String url = donlimConfig.getRoute();
|
|
|
- System.out.println(url);
|
|
|
- String appKey = donlimConfig.getAppKey();
|
|
|
- String appSecret = donlimConfig.getAppSecret();
|
|
|
- String token = donlimConfig.getToken();
|
|
|
- String taxnum = donlimConfig.getTaxnum();
|
|
|
- if (donlimConfig.isProd()) {
|
|
|
- appKey = obs[0].toString();
|
|
|
- appSecret = obs[1].toString();
|
|
|
- token = obs[2].toString();// 访问令牌
|
|
|
- taxnum = obs[3].toString();// 授权企业税号
|
|
|
- }
|
|
|
- SpObserver.putSp(master);
|
|
|
- SqlRowList rs_main = baseDao.queryForRowSet("select * from invoiceOrder left join customer on io_cucode=cu_code where io_id=" + id);
|
|
|
- if (rs_main.next()) {
|
|
|
- NNOpenSDK sdk = NNOpenSDK.getIntance();
|
|
|
- String method = "nuonuo.OpeMplatform.submitKp"; // API方法名
|
|
|
- String code = rs_main.getGeneralString("io_code");
|
|
|
- Map<String, String> reqParam = new HashMap<>();
|
|
|
- reqParam.put("orderNo", code);
|
|
|
- String content = JSONArray.toJSONString(reqParam);
|
|
|
- String senid = UUID.randomUUID().toString().replace("-", ""); // 唯一标识，32位随机码，无需修改，保持默认即可
|
|
|
- String result = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content);
|
|
|
- System.out.println(result);
|
|
|
- } else {//数据无效
|
|
|
- logger.info("findOrderState err {对接源信息无效} ,master {} , id {} status {} message {}", master, id);
|
|
|
- }
|
|
|
-
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Map<String, Object> findOrderState(String master, int id) {
|
|
|
- Map<String, Object> map = new HashMap<String, Object>();
|
|
|
- Object[] obs = baseDao.getFieldsDataByCondition("YITOA_DATACENTER.dock_invoice_config", new String[]{"appKey", "appSecret", "token", "taxnum"}, "username='" + master + "'");
|
|
|
- if (obs == null) {
|
|
|
- return null;//对接信息为配置
|
|
|
- }
|
|
|
- String url = donlimConfig.getRoute();
|
|
|
- String appKey = donlimConfig.getAppKey();
|
|
|
- String appSecret = donlimConfig.getAppSecret();
|
|
|
- String token = donlimConfig.getToken();
|
|
|
- String taxnum = donlimConfig.getTaxnum();
|
|
|
- if (donlimConfig.isProd()) {
|
|
|
- appKey = obs[0].toString();
|
|
|
- appSecret = obs[1].toString();
|
|
|
- token = obs[2].toString();// 访问令牌
|
|
|
- taxnum = obs[3].toString();// 授权企业税号
|
|
|
- }
|
|
|
- SpObserver.putSp(master);
|
|
|
- SqlRowList rs_main = baseDao.queryForRowSet("select * from invoiceOrder left join customer on io_cucode=cu_code where io_id=" + id);
|
|
|
- if (rs_main.next()) {
|
|
|
- String code = rs_main.getGeneralString("io_code");
|
|
|
- NNOpenSDK sdk = NNOpenSDK.getIntance();
|
|
|
- String method = "nuonuo.OpeMplatform.findOrderState"; // API方法名
|
|
|
- Map<String, String> reqParam = new HashMap<>();
|
|
|
- reqParam.put("originalOrderNo", code);
|
|
|
- reqParam.put("saleTaxNum", taxnum);
|
|
|
- String content = JSONArray.toJSONString(reqParam);
|
|
|
- String senid = UUID.randomUUID().toString().replace("-", ""); // 唯一标识，32位随机码，无需修改，保持默认即可
|
|
|
- String result = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content);
|
|
|
- System.out.println(result);
|
|
|
- FindOrderStateResp resp = JSON.parseObject(result, new TypeReference<FindOrderStateResp>() {
|
|
|
- });
|
|
|
- System.out.println(resp.getCode());
|
|
|
- System.out.println(resp.getMessage());
|
|
|
- if ("该订单不存在".equals(resp.getMessage())) {
|
|
|
- baseDao.execute("update invoiceOrder set IO_INVOICESTATUS = '-1' where io_id = '" + id + "'");
|
|
|
- } else {
|
|
|
- baseDao.execute("update invoiceOrder set IO_INVOICESTATUS = '" + resp.getData().getInvoiceStatus() + "'"
|
|
|
- + ",io_errorMsg='" + StringUtil.nvl(resp.getData().getErrorMsg(), "") + "'"
|
|
|
- + " where io_id = '" + id + "'");
|
|
|
- }
|
|
|
-
|
|
|
- map.put("success", true);
|
|
|
- map.put("result", result);
|
|
|
- return map;
|
|
|
- } else {//数据无效
|
|
|
- logger.info("findOrderState err {对接源信息无效} ,master {} , id {} status {} message {}", master, id);
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Map<String, Object> cancelInvoiceOrder(String master, int id) {
|
|
|
- Map<String, Object> map = new HashMap<String, Object>();
|
|
|
- Object[] obs = baseDao.getFieldsDataByCondition("YITOA_DATACENTER.dock_invoice_config", new String[]{"appKey", "appSecret", "token", "taxnum"}, "username='" + master + "'");
|
|
|
- if (obs == null) {
|
|
|
- return null;//对接信息为配置
|
|
|
- }
|
|
|
- String url = donlimConfig.getRoute();
|
|
|
- System.out.println(url);
|
|
|
- String appKey = donlimConfig.getAppKey();
|
|
|
- String appSecret = donlimConfig.getAppSecret();
|
|
|
- String token = donlimConfig.getToken();
|
|
|
- String taxnum = donlimConfig.getTaxnum();
|
|
|
- if (donlimConfig.isProd()) {
|
|
|
- System.out.println("prod");
|
|
|
- appKey = obs[0].toString();
|
|
|
- appSecret = obs[1].toString();
|
|
|
- token = obs[2].toString();// 访问令牌
|
|
|
- taxnum = obs[3].toString();// 授权企业税号
|
|
|
- } else {
|
|
|
- System.out.println("dev");
|
|
|
- }
|
|
|
- SpObserver.putSp(master);
|
|
|
- SqlRowList rs_main = baseDao.queryForRowSet("select * from invoiceOrder left join customer on io_cucode=cu_code where io_id=" + id);
|
|
|
- if (rs_main.next()) {
|
|
|
- String code = rs_main.getGeneralString("io_code");
|
|
|
- Map<String, String> reqParam = new HashMap<>();
|
|
|
- reqParam.put("originalOrderNo", code);
|
|
|
- reqParam.put("saleTaxNum", taxnum);
|
|
|
-
|
|
|
- String content = JSONArray.toJSONString(reqParam);
|
|
|
- NNOpenSDK sdk = NNOpenSDK.getIntance();
|
|
|
- String method = "nuonuo.OpeMplatform.deleteOrder"; // API方法名
|
|
|
- String senid = UUID.randomUUID().toString().replace("-", ""); // 唯一标识，32位随机码，无需修改，保持默认即可
|
|
|
- String result = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content);
|
|
|
- Map<Object, Object> res = JSONUtil.toMap(result);
|
|
|
- System.out.println(result);
|
|
|
- Object status = res.get("status");
|
|
|
- Object message = res.get("message");
|
|
|
- if (status != null && "0000".equals(status.toString())) {//调用成功
|
|
|
- baseDao.execute("update invoiceOrder set io_dockstatus='' where io_id=" + id);
|
|
|
- baseDao.execute("insert into invoicedockLog(id_,code_,date_,result_,err_,keyvalue_)values(invoicedockLog_seq.nextval,'开票订单删除',sysdate,'SUCCEED',''," + id + ") ");
|
|
|
- map.put("success", true);
|
|
|
- map.put("message", message);
|
|
|
- } else {
|
|
|
- baseDao.execute("update invoiceOrder set io_dockstatus='取消失败' where io_id=" + id);
|
|
|
- baseDao.execute("insert into invoicedockLog(id_,code_,date_,result_,err_,keyvalue_)values(invoicedockLog_seq.nextval,'开票订单删除',sysdate,'FAILED','(" + status + ")" + message + "'," + id + ") ");
|
|
|
- map.put("success", false);
|
|
|
- map.put("message", "(" + status + ")" + message);
|
|
|
- }
|
|
|
- logger.info("cancelInvoiceOrder master {} ,id {} status {} message {}", master, id, status, message);
|
|
|
- return map;
|
|
|
- } else {//数据无效
|
|
|
- logger.info("cancelInvoiceOrder err {对接源信息无效} ,master {} , id {} status {} message {}", master, id);
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Map<String, Object> getElecInvoicesById(String master, Integer id) {
|
|
|
- Map<String, Object> map = new HashMap<String, Object>();
|
|
|
- Object[] obs = baseDao.getFieldsDataByCondition("YITOA_DATACENTER.dock_invoice_config", new String[]{"appKey", "appSecret", "token", "taxnum"}, "username='" + master + "'");
|
|
|
- if (obs == null) {
|
|
|
- return null;//对接信息为配置
|
|
|
- }
|
|
|
-// System.out.println(url);
|
|
|
- String appKey = donlimConfig.getAppKey();
|
|
|
- String appSecret = donlimConfig.getAppSecret();
|
|
|
- String token = donlimConfig.getToken();
|
|
|
- String taxnum = donlimConfig.getTaxnum();
|
|
|
- logger.info("ElecI-getElecInvoicesById：master {} isProd {}", SpObserver.getSp(), donlimConfig.isProd());
|
|
|
- if (donlimConfig.isProd()) {
|
|
|
- appKey = obs[0].toString();
|
|
|
- appSecret = obs[1].toString();
|
|
|
- token = obs[2].toString();// 访问令牌
|
|
|
- taxnum = obs[3].toString();// 授权企业税号
|
|
|
- }
|
|
|
- Map<String, Object> m = new HashMap<>();
|
|
|
- m.put("appKey", appKey);
|
|
|
- m.put("appSecret", appSecret);
|
|
|
- m.put("token", token);
|
|
|
- m.put("taxnum", taxnum);
|
|
|
- SpObserver.putSp(master);
|
|
|
- SqlRowList ioList = baseDao.queryForRowSet("select io_id,io_code,io_ordertype from " + master + ".invoiceOrder left join " + master + ".customer on io_cucode=cu_code " +
|
|
|
- " where io_id = " + id);
|
|
|
- while (ioList.next()) {
|
|
|
- m.put("io_id", ioList.getGeneralInt("io_id"));
|
|
|
- m.put("io_code", ioList.getGeneralString("io_code"));
|
|
|
- m.put("io_ordertype", ioList.getGeneralInt("io_ordertype"));
|
|
|
- map = getElecInvoices(m);
|
|
|
- }
|
|
|
- return map;
|
|
|
- }
|
|
|
-
|
|
|
@Override
|
|
|
- public Map<String, Object> getElecInvoices(Map<String, Object> m) {
|
|
|
- if (Integer.valueOf(m.get("io_ordertype").toString()).equals(2)) {
|
|
|
- return getRedReturnElecInvoices(m);
|
|
|
- }
|
|
|
- String taxnum = m.get("taxnum").toString();
|
|
|
- int ioid = Integer.valueOf(m.get("io_id").toString());
|
|
|
- String ioCode = m.get("io_code").toString();
|
|
|
- Map<String, Object> res = new HashMap<String, Object>();
|
|
|
- String errCode = "-999";
|
|
|
- String errMsg = "";
|
|
|
- try {
|
|
|
- //调用对接
|
|
|
- FindOrderRelationInvoiceReq foriReq = new FindOrderRelationInvoiceReq();
|
|
|
- foriReq.setOriginalOrderNo(ioCode);//订单编号
|
|
|
- foriReq.setSaleTaxNum(taxnum);//销方税号
|
|
|
- foriReq.setNeedInvoiceSourceDetail("1");//是否需要发票所来源的订单明细，1-是, 0-否(不填默认 0) 当为0时，将不回传orderDetailCallBackVOS。先默认不需要明细
|
|
|
- FindOrderRelationInvoiceResp resp = nuoNuoSDKService.findOrderRelationInvoice(foriReq, m);
|
|
|
- errCode = resp.getStatus();
|
|
|
- errMsg = resp.getMessage();
|
|
|
- logger.info("ElecI-DownLoad-master: {} ,id {} status {} message {}", SpObserver.getSp(), ioid, errCode, errMsg);
|
|
|
- if ("0000".equals(errCode)) {//调用成功
|
|
|
- //记录发票明细
|
|
|
- baseDao.execute(getElecInvoicesSqls(ioid, resp.getData()));
|
|
|
- //红字
|
|
|
- commonService.logSRecord("订单关联发票对接", ioid);
|
|
|
- } else if (!"8958".equals(errCode)) {// {"status":"8958","message":"该订单对应的开票单不存在","data":null} 没有开票单的不记录对接失败日志
|
|
|
- if (errMsg.length() > 3980) {
|
|
|
- errMsg = errMsg.substring(0, 3980);
|
|
|
- }
|
|
|
- baseDao.execute("update invoiceOrder set io_errorMsg='订单关联发票查询失败: " + errMsg + "' where io_id=" + ioid);
|
|
|
- commonService.logFRecord("订单关联发票对接", "(" + errCode + ")" + errMsg, ioid);
|
|
|
- }
|
|
|
- } catch (Exception e) {
|
|
|
- e.printStackTrace();
|
|
|
- errMsg = "发票获取异常";
|
|
|
- if (StringUtil.hasText(e.getMessage())) {
|
|
|
- errMsg = e.getMessage();
|
|
|
- } else if (e.getCause() != null && StringUtil.hasText(e.getCause().getMessage())) {
|
|
|
- errMsg = e.getCause().getMessage();
|
|
|
- }
|
|
|
- logger.info("ElecI-DownLoad-master: {} ,id {} message {}", SpObserver.getSp(), ioid, errMsg);
|
|
|
- commonService.logFRecord("订单关联发票对接", errMsg.replaceAll("'", "''"), ioid);
|
|
|
- }
|
|
|
- //获取红字发票PDF地址
|
|
|
- List<String> serialNosAll = baseDao.queryForList("select ei_redsid from ElecInvoice " +
|
|
|
- "where ei_ioid = " + ioid + " and EI_RELATIVEREFNO is not null and ei_redpdfurl is null and nvl(EI_BILLSTATUS,' ') in (' ','01','04')", String.class);
|
|
|
- if (!CollectionUtil.isEmpty(serialNosAll)) {
|
|
|
- queryRedPdfUrl(serialNosAll, m);
|
|
|
- }
|
|
|
- if (StringUtil.hasText(errMsg) && !"调用成功".equals(errMsg)) {
|
|
|
- res.put("success", false);
|
|
|
- res.put("errCode", errCode);
|
|
|
- res.put("errMsg", errMsg);
|
|
|
- } else {
|
|
|
- res.put("success", true);
|
|
|
- }
|
|
|
- return res;
|
|
|
- }
|
|
|
-
|
|
|
- private List<String> getElecInvoicesSqls(int ioid, List<FindOrderRelationInvoiceDTO> data) {
|
|
|
- List<String> sqls = new ArrayList<String>();
|
|
|
- boolean syncToBillOut = baseDao.isDBSetting("BillOut", "syncToBillOut");
|
|
|
- for (int i = 0; i < data.size(); i++) {
|
|
|
- FindOrderRelationInvoiceDTO friDto = data.get(i);
|
|
|
- sqls.addAll(friDto.toMergeSql(ioid, (i + 1)));
|
|
|
- }
|
|
|
- sqls.add(" update invoiceOrder set io_refno = (" +
|
|
|
- " select (min(ei_refno)||(case when max(ei_refno) <> min(ei_refno) then '-'||max(ei_refno) else '' end)) " +
|
|
|
- " from ELECINVOICE " +
|
|
|
- " where ei_ioid = io_id and EI_INVOICETYPE = 1 " +
|
|
|
- " and ( nvl(ei_rushredstate,0) <> 1 or (nvl(ei_rushredstate,0) = 1 and exists (Select 1 from invoiceOrder redio where redio.io_ordertype=2 and redio.io_yfphm = ei_refno)) ) " +
|
|
|
- " ) " +
|
|
|
- " where io_id = " + ioid);
|
|
|
- //更新开票记录
|
|
|
- if (syncToBillOut) {
|
|
|
- sqls.add("update BillOut set bi_refno = (select max(io_refno) from invoiceOrder where io_id = " + ioid + " and io_biid = bi_id) where bi_id in (select io_biid from invoiceOrder where io_id = " + ioid + " and io_refno is not null)");
|
|
|
- }
|
|
|
-// System.out.println("sqls：");
|
|
|
-// System.out.println(sqls.toString());
|
|
|
- return sqls;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Map<String, Object> rushRed(String master, int id) {
|
|
|
- Map<String, Object> map = new HashMap<String, Object>();
|
|
|
- Object[] obs = baseDao.getFieldsDataByCondition("YITOA_DATACENTER.dock_invoice_config", new String[]{"appKey", "appSecret", "token", "taxnum"}, "username='" + master + "'");
|
|
|
- String url = donlimConfig.getRoute();
|
|
|
- String appKey = donlimConfig.getAppKey();
|
|
|
- String appSecret = donlimConfig.getAppSecret();
|
|
|
- String token = donlimConfig.getToken();
|
|
|
- String taxnum = donlimConfig.getTaxnum();
|
|
|
- if (donlimConfig.isProd()) {
|
|
|
- appKey = obs[0].toString();
|
|
|
- appSecret = obs[1].toString();
|
|
|
- token = obs[2].toString();// 访问令牌
|
|
|
- taxnum = obs[3].toString();// 授权企业税号
|
|
|
- }
|
|
|
- Map<String, Object> m = new HashMap<>();
|
|
|
- m.put("appKey", appKey);
|
|
|
- m.put("appSecret", appSecret);
|
|
|
- m.put("token", token);
|
|
|
- m.put("taxnum", taxnum);
|
|
|
- logger.info("rushRed begin: master {} ,id {} ", master, id);
|
|
|
+ public Map<String, Object> createSticker(String master, Integer id) {
|
|
|
+ Map<String,Object> retMap = new HashMap<>();
|
|
|
+ retMap.put("success",true);
|
|
|
+ logger.info("createSticker-Begin:master {} id {}",master,id);
|
|
|
SpObserver.putSp(master);
|
|
|
- StringBuffer errmsg = new StringBuffer();
|
|
|
- StringBuffer remindmsg = new StringBuffer();
|
|
|
- SqlRowList rs_main = baseDao.queryForRowSet("select * from invoiceOrder left join customer on io_cucode=cu_code left join elecinvoice on io_id=ei_ioid where io_id=" + id + " and nvl(ei_redapplyid,' ')=' ' and nvl(EI_INVOICESTATE,0)=1 and nvl(EI_INVOICETYPE,0)=1 ");
|
|
|
- if (rs_main.hasNext()) {
|
|
|
- int scount = 0;
|
|
|
- while (rs_main.next()) {
|
|
|
- RedInvoiceReq redInvoiceReq = new RedInvoiceReq();
|
|
|
- redInvoiceReq.setBlueInvoiceLine(rs_main.getGeneralString("io_invoiceline"));//蓝票发票种类
|
|
|
- redInvoiceReq.setApplySource("0");//申请方（录入方）身份： 0 销方 1 购方
|
|
|
- redInvoiceReq.setSellerTaxNo(donlimConfig.getTaxnum());//销方税号
|
|
|
- redInvoiceReq.setBuyerName(rs_main.getGeneralString("cu_name"));//购方名称
|
|
|
- redInvoiceReq.setBuyerTaxNo(rs_main.getGeneralString("ei_taxno"));
|
|
|
- redInvoiceReq.setRedReason(rs_main.getGeneralString("io_redreason"));
|
|
|
- //redInvoiceReq.setAutoInvoice("1");//测试是否能自动红冲目前参数无效
|
|
|
- redInvoiceReq.setBlueElecInvoiceNumber(rs_main.getGeneralString("ei_allelectronicinvoicenumber"));
|
|
|
- NNOpenSDK sdk = NNOpenSDK.getIntance();
|
|
|
- String content = sdk.convertToUtf8(JSONArray.toJSONString(redInvoiceReq));
|
|
|
- String method = "nuonuo.OpeMplatform.saveInvoiceRedConfirm"; // API方法名
|
|
|
- String senid = UUID.randomUUID().toString().replace("-", ""); // 唯一标识，32位随机码，无需修改，保持默认即可
|
|
|
- String resp = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content);
|
|
|
- Map<Object, Object> res = JSONUtil.toMap(resp);
|
|
|
- Object code = res.get("code");
|
|
|
- Object describe = res.get("describe");
|
|
|
- Object result = res.get("result");
|
|
|
- logger.info("rushRed master {} ,id {} code {} describe {} applycode {}", master, id, code, describe, result);
|
|
|
- if (code != null && "E0000".equals(code.toString())) {//调用成功
|
|
|
- baseDao.execute("update elecinvoice set ei_redapplyid='" + result.toString() + "' where ei_id=" + rs_main.getGeneralInt("ei_id"));
|
|
|
- scount++;
|
|
|
- commonService.logSRecord("红字确认单申请(" + rs_main.getGeneralString("ei_refno") + ")", id);
|
|
|
- } else {
|
|
|
- //E9755 describe 该发票存在进行中的红字确认单，暂时不能冲红
|
|
|
- commonService.logFRecord("红字确认单申请(" + rs_main.getGeneralInt("ei_id") + ")", "(" + code + ")" + describe, id);
|
|
|
- errmsg.append("(" + code + ")" + describe).append("</br>");
|
|
|
- }
|
|
|
- }
|
|
|
- //没有自动开红票 但是可以拿状态
|
|
|
- if (scount > 0) {
|
|
|
- m.put("io_id", id);
|
|
|
- m.put("ei_id", 0);
|
|
|
- //获取红字确认状态等信息，若自动开票成功，则同时获取红票信息
|
|
|
- Map<String, Object> mm = queryInvoiceRedConfirm(m);
|
|
|
- if ("false".equals(mm.get("success")) && StringUtil.hasText(mm.get("errMsg"))) {
|
|
|
- remindmsg.append(mm.get("errMsg"));
|
|
|
- }
|
|
|
- }
|
|
|
- } else {//数据无效
|
|
|
- logger.info("rushRed err {对接源信息无效} ,master {} , id {} status {} message {}", master, id);
|
|
|
- errmsg.append("对接源信息无效");
|
|
|
- return map;
|
|
|
+ SqlRowList docLoist = baseDao.queryForRowSet("select CD_CPN matnr,min(CD_DC) ztcnno,pr_capacity zzxsmount,pr_zxbzs zbzsmount,sum(CD_QTY) zmount " +
|
|
|
+ "from CatlDocDetail left join product on pr_code = CD_PRCODE " +
|
|
|
+ "where cd_caid = ? and CD_PANID is null group by CD_CPN,pr_capacity,pr_zxbzs order by min(cd_detno)",id);
|
|
|
+ if(!docLoist.hasNext()){
|
|
|
+ System.out.println("no docLoist!");
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message","没有需要对接的明细.");
|
|
|
+ logger.info("createSticker-F:master {} id {} no docLoist!",master,id);
|
|
|
}
|
|
|
- if (errmsg.length() > 0) {
|
|
|
- map.put("success", false);
|
|
|
- if (remindmsg.length() > 0) {
|
|
|
- errmsg.append(remindmsg.toString());
|
|
|
- }
|
|
|
- map.put("message", errmsg.toString());
|
|
|
- } else {
|
|
|
- map.put("success", true);
|
|
|
- if (remindmsg.length() > 0) {
|
|
|
- map.put("message", remindmsg.toString());
|
|
|
- }
|
|
|
+ Object[] obs = baseDao.getFieldsDataByCondition("YITOA_DATACENTER.dock_catl_config A "
|
|
|
+ , new String[]{"URL_","deipaaskeyauth","appKey", "appSecret","VENDCODE"}
|
|
|
+ , "username='"+master+"' and A.ENVTYPE = (SELECT B.ENVTYPE FROM YITOA_DATACENTER.DOCK_CATL_EVCONFIG B WHERE A.username = B.username )");
|
|
|
+ String url = String.valueOf(obs[0]);
|
|
|
+ String deipaaskeyauth = String.valueOf(obs[1]);
|
|
|
+ String vendcode = String.valueOf(obs[4]);
|
|
|
+ Map<String,String> map = new HashMap<>();
|
|
|
+ map.put("url",url);
|
|
|
+ map.put("deipaaskeyauth",deipaaskeyauth);
|
|
|
+ map.put("appKey",String.valueOf(obs[2]));
|
|
|
+ map.put("appSecret",String.valueOf(obs[3]));
|
|
|
+ Map<String,Object> tokenMap = getToken(map);
|
|
|
+ if(!(boolean)tokenMap.get("success")){
|
|
|
+ return tokenMap;
|
|
|
}
|
|
|
- return map;
|
|
|
- }
|
|
|
-
|
|
|
- /*
|
|
|
- 条件：蓝票、有确认单号、待确认或者无需确认的情况下 持续获取红票相关信息
|
|
|
- 按照红冲确认单查询对应状态
|
|
|
- 可以查到信息： 确认单状态、开票状态、冲红原因、
|
|
|
- 若已开票，则自动获取红票 发票号：
|
|
|
- 冲红原因： 1销货退回 2开票有误 3服务中止 4销售折让
|
|
|
- */
|
|
|
- @Override
|
|
|
- public Map<String, Object> queryInvoiceRedConfirm(Map<String, Object> m) {
|
|
|
- int ioid = Integer.valueOf(m.get("io_id").toString());
|
|
|
- int eiid = Integer.valueOf(m.get("ei_id").toString());
|
|
|
- Map<String, Object> res = new HashMap<String, Object>();
|
|
|
- StringBuffer errmsg = new StringBuffer();
|
|
|
- SqlRowList bluePiao = baseDao.queryForRowSet("select ei_id,ei_redapplyid,ei_billStatus,ei_billNo,ei_billUuid,ei_taxExcludedAmount,ei_taxAmount,ei_redReason,io_ordertype " +
|
|
|
- "from elecinvoice left join invoiceOrder on ei_ioid = io_id " +
|
|
|
- "where ei_ioid = '" + ioid + "' " + (eiid > 0 ? "and ei_id = " + eiid : "")
|
|
|
- + " and EI_INVOICETYPE = '1' and ei_redapplyid is not null and EI_RELATIVEREFNO is null and nvl(ei_billStatus,' ') in (' ','01','02','03','15') " +
|
|
|
- "order by ei_Detno");
|
|
|
- if (bluePiao.hasNext()) {
|
|
|
- boolean isRushRedBill = false;
|
|
|
- while (bluePiao.next()) {
|
|
|
- String redApplyId = bluePiao.getGeneralString("ei_redapplyid");
|
|
|
- eiid = bluePiao.getGeneralInt("ei_id");
|
|
|
- m.put("ei_id", eiid);
|
|
|
- QueryInvoiceRedConfirmReq qircReq = new QueryInvoiceRedConfirmReq();
|
|
|
- qircReq.setIdentity("0");
|
|
|
- qircReq.setBillId(redApplyId);
|
|
|
- String rCode = "-999";
|
|
|
- String describe = "";
|
|
|
- String logCode = "发票红字确认状态查询";
|
|
|
- try {
|
|
|
- QueryInvoiceRedConfirmResp qircResp = nuoNuoSDKService.queryInvoiceRedConfirm(qircReq, m);
|
|
|
- rCode = qircResp.getCode();
|
|
|
- describe = qircResp.getDescribe();
|
|
|
- logger.info("ElecI-queryInvoiceRedConfirmByCode：master {} ,redApplyid {} rCode {} describe {} total {}", SpObserver.getSp(), redApplyId, rCode, describe, qircResp.getResult().getTotal());
|
|
|
- if ("E0000".equals(rCode)) {//调用成功 记录发票明细 1135624457459470336
|
|
|
- List<String> sqls = new ArrayList<>();
|
|
|
- List<QueryInvoiceRedConfirmDTO> qircList = qircResp.getResult().getList();
|
|
|
- for (int i = 0; i < qircList.size(); i++) {
|
|
|
- QueryInvoiceRedConfirmDTO qircfDTO = qircList.get(i);
|
|
|
- //先获取红票状态 不一致才更新
|
|
|
- sqls.add("update elecinvoice set " +
|
|
|
- "ei_billStatus='" + qircfDTO.getBillStatus() + "' " +
|
|
|
- ",ei_billNo='" + StringUtil.nvl(qircfDTO.getBillNo(), "") + "' " + //990000008655037292
|
|
|
- ",ei_billUuid='" + StringUtil.nvl(qircfDTO.getBillUuid(), "") + "' " +
|
|
|
- ",ei_redsid='" + StringUtil.nvl(qircfDTO.getInvoiceSerialNum(), "") + "' " +
|
|
|
- ",ei_redorderno='" + StringUtil.nvl(qircfDTO.getOrderNo(), "") + "' " +
|
|
|
- ",ei_taxExcludedAmount='" + StringUtil.nvl(qircfDTO.getTaxExcludedAmount(), "0") + "' " +
|
|
|
- ",ei_taxAmount='" + StringUtil.nvl(qircfDTO.getTaxAmount(), "0") + "' " +
|
|
|
- ",ei_redReason='" + StringUtil.nvl(qircfDTO.getRedReason(), "") + "' " +
|
|
|
- ",ei_openStatus='" + StringUtil.nvl(qircfDTO.getOpenStatus(), "0") + "' " +
|
|
|
- " where ei_id = " + eiid);
|
|
|
- //针对自动开票场景：若开票，则记录红票数据，调用查询接口批量更新
|
|
|
- if ("1".equals(qircfDTO.getOpenStatus())) { //已开具红字发票标记： 1：已开具 0：未开具 //orderNo 20230731182154174492
|
|
|
- isRushRedBill = true;
|
|
|
- // serialNos 流水号 -- EI_SID -- invoiceSerialNum ; orderNos 开票单号 --- EI_ORDERNO -- ORDERNO
|
|
|
+ String action="/SNC/outer_SNC_createSticker?sap-client=810&interfacename=ZIRFC_TP2SNC_CREATESTICKER";
|
|
|
+ String deipaasjwt = "Bearer "+tokenMap.get("token");
|
|
|
+ map.put("deipaasjwt",deipaasjwt);
|
|
|
+ StringBuffer errMsg = new StringBuffer();
|
|
|
+ for (Map<String,Object> docMap: docLoist.getResultList()) {
|
|
|
+ try {
|
|
|
+ String matnr = String.valueOf(docMap.get("matnr"));
|
|
|
+ Map<String,Object> paraMap=new HashMap<>();
|
|
|
+ paraMap.put("matnr",matnr);//物料号:客户料号
|
|
|
+ paraMap.put("ztcnno",docMap.get("ztcnno"));//制造日期: 取最小DC
|
|
|
+ paraMap.put("zzstz",matnr);//供应商批次: 用型号作为虚拟批次
|
|
|
+// paraMap.put("zeiar",docMap.get("zeiar"));//版本
|
|
|
+// paraMap.put("zwidth",docMap.get("zwidth"));//宽度
|
|
|
+ paraMap.put("zmount",docMap.get("zmount"));//本次生产总数量
|
|
|
+// paraMap.put("zzbsmount",docMap.get("zzbsmount"));//栈板容量
|
|
|
+ paraMap.put("zzxsmount",docMap.get("zzxsmount"));//纸箱容量
|
|
|
+ paraMap.put("zbzsmount",docMap.get("zbzsmount"));//包装袋容量
|
|
|
+// paraMap.put("zremark",docMap.get("zremark"));//备注
|
|
|
+ paraMap.put("partner",vendcode);//供应商编码 固定值
|
|
|
+ HttpUtil.Response response = HttpUtil.doPost(url+action, JacksonUtil.toJson(paraMap), deipaaskeyauth,deipaasjwt);
|
|
|
+ if (response.getStatusCode() == HttpStatus.OK.value()){
|
|
|
+ String res = response.getResponseText();
|
|
|
+ if(res!=null && !"".equals(res)){
|
|
|
+// System.out.println("res："+res);
|
|
|
+ Map<String,Object> resData = JacksonUtil.fromJson(res);
|
|
|
+ if("S".equals(String.valueOf(resData.get("e_type")))){
|
|
|
+ List<Map<String,Object>> outdata = (List) resData.get("outdata");
|
|
|
+// List<Map<String,Object>> outdata = JacksonUtil.fromJsonArray(resData.get("outdata").toString());
|
|
|
+ System.out.println("outdata.size:"+outdata.size());
|
|
|
+ List<Map<String,Object>> idList = outdata.stream().filter(od->{
|
|
|
+ return "1 ".equals(od.get("levels"));
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ //更新条码ID、箱ID
|
|
|
+ List<String> sqls = new ArrayList<>();
|
|
|
+ SqlRowList updateList = baseDao.queryForRowSet("select cd_id,cd_lotno,cd_dc,nvl(cd_ed,to_char(to_date(cd_dc,'yyyymmdd')+365,'yyyymmdd')) cd_ed from CatlDocDetail where cd_caid = ? and CD_CPN = ? and CD_PANID is null order by cd_detno",id,matnr);
|
|
|
+ List<Map<String,Object>> updateStickerList = new ArrayList<>();
|
|
|
+ if(idList.size() == updateList.getResultList().size()){
|
|
|
+ for (int i = 0; i < updateList.getResultList().size(); i++) {
|
|
|
+ Map<String,Object> updateMap = updateList.getResultList().get(i);
|
|
|
+ Map<String,Object> idMap = idList.get(i);
|
|
|
+ sqls.add("update CatlDocDetail set CD_PANID='"+idMap.get("zalt_id")+"',CD_BOXID='"+idMap.get("zalt_id_upper")+"' where cd_id = "+updateMap.get("cd_id"));
|
|
|
+ Map<String,Object> updateStickerMap = new HashMap<>();
|
|
|
+ updateStickerMap.put("matnr",matnr);//物料号
|
|
|
+ updateStickerMap.put("zalt_id",idMap.get("zalt_id"));//贴纸ID
|
|
|
+ updateStickerMap.put("prtbatchid",updateMap.get("cd_lotno"));//供应商批次
|
|
|
+ updateStickerMap.put("manufacturing_date",updateMap.get("cd_dc"));//生产日期
|
|
|
+ updateStickerMap.put("atlyx",updateMap.get("cd_ed"));//有效日期
|
|
|
+ updateStickerList.add(updateStickerMap);
|
|
|
+ }
|
|
|
+ if(sqls.size()>0){
|
|
|
+ baseDao.execute(sqls);
|
|
|
+ //第二个接口 更新供应商批次
|
|
|
+ Map<String,Object> updateStickerMap = updateStickerByList(master, id,map,updateStickerList);
|
|
|
+ if(!(boolean) updateStickerMap.get("success")){
|
|
|
+ errMsg.append("更新供应商批次失败:客户料号:"+matnr).append(updateStickerMap.get("message")).append("</br>");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ errMsg.append("条码创建数与实际不一致，型号:"+matnr).append("创建数:"+idList.size()+",待更新数量:"+updateList.getResultList().size()).append("</br>");
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ if(StringUtil.hasText(resData.get("e_message"))){
|
|
|
+ errMsg.append("客户料号:"+matnr).append(resData.get("e_message")).append("</br>");
|
|
|
+ }else {
|
|
|
+ errMsg.append("客户料号:"+matnr).append("创建条码失败").append("</br>");
|
|
|
}
|
|
|
}
|
|
|
- baseDao.execute(sqls);
|
|
|
- describe = "";
|
|
|
- } else {
|
|
|
- if (describe.length() > 3980) {
|
|
|
- describe = describe.substring(0, 3980);
|
|
|
- }
|
|
|
- errmsg.append(describe).append("</br>");
|
|
|
- baseDao.execute("update elecinvoice set EI_EXCEPTIONMESSAGE='" + logCode + ": " + describe + "' where ei_id = " + eiid + " ");
|
|
|
- commonService.logFRecord(logCode, describe, eiid);
|
|
|
+ }else{
|
|
|
+ logger.info("getToken-F:No ResponseText");
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", "No ResponseText");
|
|
|
}
|
|
|
- } catch (Exception e) {
|
|
|
- e.printStackTrace();
|
|
|
- describe = "未知异常";
|
|
|
- if (StringUtil.hasText(e.getMessage())) {
|
|
|
- describe = e.getMessage();
|
|
|
- } else if (e.getCause() != null && StringUtil.hasText(e.getCause().getMessage())) {
|
|
|
- describe = e.getCause().getMessage();
|
|
|
- }
|
|
|
- commonService.logFRecord(logCode, "发票红冲状态查询:" + describe.replaceAll("'", "''"), eiid);
|
|
|
- }
|
|
|
- if (StringUtil.hasText(describe)) {
|
|
|
- errmsg.append(describe);
|
|
|
- }
|
|
|
- }
|
|
|
- if (isRushRedBill) {
|
|
|
- Map<String, Object> elM = new HashMap<>();
|
|
|
- elM.put("appKey", m.get("appKey"));
|
|
|
- elM.put("appSecret", m.get("appSecret"));
|
|
|
- elM.put("token", m.get("token"));
|
|
|
- elM.put("taxnum", m.get("taxnum"));
|
|
|
- elM.put("io_id", ioid);
|
|
|
- elM.put("io_code", m.get("io_code"));
|
|
|
- elM.put("io_ordertype", bluePiao.getGeneralInt("io_ordertype"));
|
|
|
- Map<String, Object> r = getElecInvoices(elM);
|
|
|
- if (StringUtil.hasText(r.get("errMsg"))) {
|
|
|
- baseDao.execute("update elecinvoice set EI_EXCEPTIONMESSAGE='" + r.get("errCode") + ": " + r.get("errMsg") + "' where EI_INVOICETYPE = '1' and ei_redapplyid is not null and EI_RELATIVEREFNO is null and ei_ioid = " + ioid);
|
|
|
+ }else {
|
|
|
+ logger.info("createSticker-F:StatusCode {} ResponseText {}",response.getStatusCode(),response.getResponseText());
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", response.getStatusCode()+":"+response.getResponseText());
|
|
|
}
|
|
|
+ }catch (Exception e){
|
|
|
+ e.printStackTrace();
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message","创建条码异常。");
|
|
|
}
|
|
|
}
|
|
|
- if (errmsg.length() > 0) {
|
|
|
- res.put("success", false);
|
|
|
- res.put("errMsg", errmsg.toString());
|
|
|
- } else {
|
|
|
- res.put("success", true);
|
|
|
+ if(errMsg.length()>0){
|
|
|
+ System.out.println("errMsg:"+errMsg.toString());
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message","对接失败:</br>"+errMsg.toString());
|
|
|
+ }else {
|
|
|
+ baseDao.execute("update CatlDoc set CA_DOCSTATE=1 where ca_id = "+id);
|
|
|
}
|
|
|
- return res;
|
|
|
+ logger.info("createSticker-End:master {} id {} retMap {}",master,id,retMap.toString());
|
|
|
+ return retMap;
|
|
|
}
|
|
|
|
|
|
- //根据红票流水号 获取红票号及其他信息
|
|
|
- public Map<String, Object> queryRedPdfUrl(List<String> serialNosAll, Map<String, Object> m) {
|
|
|
- Map<String, Object> res = new HashMap<>();
|
|
|
- String describe = "";
|
|
|
+ @Override
|
|
|
+ public Map<String, Object> getToken(Map<String, String> map) {
|
|
|
+ Map<String, Object> retMap = new HashMap<>();
|
|
|
+ retMap.put("success",true);
|
|
|
+ String url = map.get("url");
|
|
|
+ String deipaaskeyauth = map.get("deipaaskeyauth");
|
|
|
+ String appKey = map.get("appKey");
|
|
|
+ String appSecret = map.get("appSecret");
|
|
|
+ logger.info("getToken-begin: url {} ,deipaaskeyauth {},appKey {},appSecret {} ", url,deipaaskeyauth,appKey,appSecret);
|
|
|
+ String action="/ipaas/ipaas_getJwtToken";
|
|
|
+ Map<String,Object> paraMap=new HashMap<>();
|
|
|
+ paraMap.put("appKey",appKey);
|
|
|
+ paraMap.put("appSecret",appSecret);
|
|
|
+ paraMap.put("time",60);
|
|
|
try {
|
|
|
- logger.info("ElecI-queryRedPdfUrl：master {} ,serialNosAll {}", SpObserver.getSp(), serialNosAll.toString());
|
|
|
- List<String> rSql = new ArrayList<String>();
|
|
|
- if (serialNosAll.size() > 0) {
|
|
|
- Stream.iterate(0, n -> n + 1)
|
|
|
- .limit((int) Math.ceil((double) serialNosAll.size() / 50)).forEach(page -> {
|
|
|
- List<String> serialNos = serialNosAll.stream().skip(page * 50).limit(50).collect(Collectors.toList());
|
|
|
- QueryInvoiceResultReq qirReq = new QueryInvoiceResultReq();
|
|
|
- qirReq.setIsOfferInvoiceDetail("0");
|
|
|
- qirReq.setSerialNos(serialNos);
|
|
|
- QueryInvoiceResultResp qirResp = nuoNuoSDKService.queryInvoiceResult(qirReq, m);
|
|
|
- List<QueryInvoiceResultDTO> list = qirResp.getResult();
|
|
|
- if (!CollectionUtil.isEmpty(list)) {
|
|
|
- for (int i = 0; i < list.size(); i++) {
|
|
|
- String sql = list.get(i).updatePdfUrlSql();
|
|
|
- if (!"".equals(sql)) {
|
|
|
- rSql.add(sql);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- });
|
|
|
+ HttpUtil.Response response =HttpUtil.doPost(url+action, JacksonUtil.toJson(paraMap), deipaaskeyauth,"");
|
|
|
+ if (response.getStatusCode() == HttpStatus.OK.value()){
|
|
|
+ String res = response.getResponseText();
|
|
|
+ if(res!=null && !"".equals(res)){
|
|
|
+ Map<String,Object> resMap = JacksonUtil.fromJson(res);
|
|
|
+ logger.info("getToken-S: {} ", String.valueOf(resMap.get("accessToken")));
|
|
|
+ retMap.put("token", String.valueOf(resMap.get("accessToken")));
|
|
|
+ }else{
|
|
|
+ logger.info("getToken-F:No ResponseText");
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", "No ResponseText");
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ logger.info("getToken-F:StatusCode {} ResponseText {}",response.getStatusCode(),response.getResponseText());
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", response.getStatusCode()+":"+response.getResponseText());
|
|
|
}
|
|
|
-// System.out.println("rSql:" + rSql.toString());
|
|
|
- baseDao.execute(rSql);
|
|
|
- } catch (Exception e) {
|
|
|
+ }catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
- describe = "未知异常";
|
|
|
- if (StringUtil.hasText(e.getMessage())) {
|
|
|
- describe = e.getMessage();
|
|
|
- } else if (e.getCause() != null && StringUtil.hasText(e.getCause().getMessage())) {
|
|
|
- describe = e.getCause().getMessage();
|
|
|
- }
|
|
|
- commonService.logFRecord("查询红票详情", describe.replaceAll("'", "''"), 0);
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", "对接异常");
|
|
|
}
|
|
|
- return res;
|
|
|
+ return retMap;
|
|
|
}
|
|
|
|
|
|
- //退货单 订单开票 根据来源蓝票获取红票信息：写入退货的发票明细、更新来源蓝票对应红票信息、及退货开票记录中
|
|
|
@Override
|
|
|
- public Map<String, Object> getRedReturnElecInvoices(Map<String, Object> m) {
|
|
|
- String taxnum = m.get("taxnum").toString();
|
|
|
- int ioid = Integer.valueOf(m.get("io_id").toString());
|
|
|
- String ioCode = m.get("io_code").toString();
|
|
|
- Map<String, Object> res = new HashMap<String, Object>();
|
|
|
- String errCode = "-999";
|
|
|
- String errMsg = "";
|
|
|
- SqlRowList ioReturn = baseDao.queryForRowSet("select io_id,io_code,io_relatesaleorderno,io_yfphm,io_biid,io_bicode from invoiceOrder " +
|
|
|
- " where IO_INVOICESTATUS = 2 and io_ordertype = 2 and io_id = " + ioid);
|
|
|
- if (!ioReturn.next()) {
|
|
|
- errMsg = "退货订单:" + ioCode + "(" + ioid + ")不存在";
|
|
|
- logger.info("RedReturnElecI-DownLoad-master: {} ,id {} status {} message {}", SpObserver.getSp(), ioid, errMsg);
|
|
|
- commonService.logFRecord("退货订单关联发票对接", errMsg, ioid);
|
|
|
- }
|
|
|
- String relatesaleorderno = ioReturn.getGeneralString("io_relatesaleorderno");//关联蓝票订单号
|
|
|
- String oldInvoiceNumber = ioReturn.getGeneralString("io_yfphm");//原蓝票发票号码
|
|
|
- Integer biid = ioReturn.getGeneralInt("io_biid");
|
|
|
- String bicode = ioReturn.getGeneralString("io_bicode");
|
|
|
- SqlRowList ioBlue = baseDao.queryForRowSet("select ei_id,ei_ioid from ElecInvoice " +
|
|
|
- "where EI_IOCODE ='" + relatesaleorderno + "' and EI_ALLELECTRONICINVOICENUMBER ='" + oldInvoiceNumber + "'");
|
|
|
- if (!ioBlue.next()) {
|
|
|
- errMsg = "原订单:" + relatesaleorderno + "不存在";
|
|
|
- logger.info("RedReturnElecI-DownLoad-master: {} ,id {} status {} message {}", SpObserver.getSp(), ioid, errMsg);
|
|
|
- commonService.logFRecord("退货订单关联发票对接", errMsg, ioid);
|
|
|
- }
|
|
|
- Integer eiBlue = ioBlue.getGeneralInt("ei_id");
|
|
|
+ public Map<String, Object> updateStickerByList(String master, Integer id,Map<String, String> map,List<Map<String,Object>> updateLists) {
|
|
|
+ Map<String, Object> retMap = new HashMap<>();
|
|
|
+ retMap.put("success",true);
|
|
|
+ String url = map.get("url");
|
|
|
+ String deipaaskeyauth = map.get("deipaaskeyauth");
|
|
|
+ String appKey = map.get("appKey");
|
|
|
+ String appSecret = map.get("appSecret");
|
|
|
+ String deipaasjwt = map.get("deipaasjwt");
|
|
|
+ logger.info("updateSticker-begin: url {} ,deipaaskeyauth {},appKey {},appSecret {},deipaasjwt {} ", url,deipaaskeyauth,appKey,appSecret,deipaasjwt);
|
|
|
+ String action="/SNC/outer_SNC_updateGyspc?sap-client=810&interfacename=ZIRFC_TP2SNC_UPDATEGYSPC";
|
|
|
+ Map<String,Object> paraMap=new HashMap<>();
|
|
|
+ paraMap.put("inputdata",updateLists);
|
|
|
+ StringBuffer errMsg = new StringBuffer();
|
|
|
try {
|
|
|
- Map<String, Object> mBlue = new HashMap<>();
|
|
|
- mBlue.put("taxnum", taxnum);
|
|
|
- mBlue.put("appKey", m.get("appKey"));
|
|
|
- mBlue.put("appSecret", m.get("appSecret"));
|
|
|
- mBlue.put("token", m.get("token"));
|
|
|
- FindOrderRelationInvoiceReq foriReqBlue = new FindOrderRelationInvoiceReq();
|
|
|
- foriReqBlue.setOriginalOrderNo(relatesaleorderno);//订单编号
|
|
|
- foriReqBlue.setSaleTaxNum(taxnum);//销方税号
|
|
|
- foriReqBlue.setNeedInvoiceSourceDetail("1");//是否需要发票所来源的订单明细，1-是, 0-否(不填默认 0) 当为0时，将不回传orderDetailCallBackVOS。先默认不需要明细
|
|
|
- FindOrderRelationInvoiceResp resp = nuoNuoSDKService.findOrderRelationInvoice(foriReqBlue, mBlue);
|
|
|
- errCode = resp.getStatus();
|
|
|
- errMsg = resp.getMessage();
|
|
|
- logger.info("RedReturnElecI-DownLoad-master: {} ,id {} status {} message {}", SpObserver.getSp(), ioid, errCode, errMsg);
|
|
|
- errCode = resp.getStatus();
|
|
|
- errMsg = resp.getMessage();
|
|
|
- logger.info("RedReturnElecI-DownLoad-master: {} ,id {} status {} message {}", SpObserver.getSp(), ioid, errCode, errMsg);
|
|
|
- if ("0000".equals(errCode)) {//调用成功
|
|
|
- List<String> sqls = new ArrayList<>();
|
|
|
- List<FindOrderRelationInvoiceDTO> data = resp.getData();
|
|
|
- for (int i = 0; i < data.size(); i++) {
|
|
|
- FindOrderRelationInvoiceDTO friDto = data.get(i);
|
|
|
- if (friDto.getAllElectronicInvoiceNumber().equals(oldInvoiceNumber)) {
|
|
|
- List<RelateRedInvoiceDTO> relateRedInvoiceList = friDto.getRelateRedInvoiceList();
|
|
|
- for (int j = 0; j < relateRedInvoiceList.size(); j++) {
|
|
|
- RelateRedInvoiceDTO relateRedInvoiceDTO = relateRedInvoiceList.get(j);
|
|
|
- if (StringUtil.hasText(relateRedInvoiceDTO.getAllElectronicInvoiceNumber())) {
|
|
|
- sqls.add("delete ElecInvoice where ei_ioid = " + ioid);
|
|
|
- sqls.add("insert into ElecInvoice (EI_ID, EI_DETNO, EI_IOID, EI_IOCODE, EI_BIID, EI_BICODE " +
|
|
|
- " , EI_SID, EI_ORDERNO, EI_CREATETIME, EI_INVOICETYPE, EI_INVOICELINE, EI_SPECIFICFACTOR, EI_INVOICESTATE, EI_EXCEPTIONMESSAGE, EI_INVOICECODE, EI_INVOICENUMBER, EI_ALLELECTRONICINVOICENUMBER, EI_OLDINVOICECODE, EI_OLDINVOICENUMBER, EI_OLDALLELECTRONICINVOICENU" +
|
|
|
- " , EI_INVOICETIME, EI_INVALIDTIME" +
|
|
|
- " , EI_PDFURL, EI_PDFATTACH, EI_OFDURL, EI_IMAGEURL, EI_CALCEXCLUDINGTAXAMOUNT, EI_CALCTAXAMOUNT, EI_CALEORDERAMOUNT, EI_SELLERTAXNO, EI_SELLERNAME, EI_TAXNO, EI_BUYERNAME, EI_REMARK, EI_CLERKER, EI_PAYEE, EI_CHECKER, EI_BFIELD1, EI_BFIELD2, EI_BFIELD3, EI_INDATE, EI_UPDATEDATE, EI_REFNO" +
|
|
|
- " ,EI_BILLSTATUS,ei_rushredstate,ei_redsid,ei_relativerefno,ei_taxamount,ei_taxexcludedamount) " +
|
|
|
- "SELECT ElecInvoice_Seq.nextval,1," + ioid + ",'" + ioCode + "'," + biid + ",'" + bicode + "' " +
|
|
|
- " , EI_SID, EI_ORDERNO, EI_CREATETIME, EI_INVOICETYPE, EI_INVOICELINE, EI_SPECIFICFACTOR, EI_INVOICESTATE, EI_EXCEPTIONMESSAGE, EI_INVOICECODE, EI_INVOICENUMBER, EI_ALLELECTRONICINVOICENUMBER, EI_OLDINVOICECODE, EI_OLDINVOICENUMBER, EI_OLDALLELECTRONICINVOICENU" +
|
|
|
- " , (to_date('1970-01-0100:00:00','yyyy-mm-dd hh24:mi:ss') + "+relateRedInvoiceDTO.getInvoiceTime()+"/1000/24/60/60) EI_INVOICETIME, EI_INVALIDTIME" +
|
|
|
- " , EI_PDFURL, EI_PDFATTACH, EI_OFDURL, EI_IMAGEURL, EI_CALCEXCLUDINGTAXAMOUNT, EI_CALCTAXAMOUNT, EI_CALEORDERAMOUNT, EI_SELLERTAXNO, EI_SELLERNAME, EI_TAXNO, EI_BUYERNAME, EI_REMARK, EI_CLERKER, EI_PAYEE, EI_CHECKER, EI_BFIELD1, EI_BFIELD2, EI_BFIELD3, EI_INDATE, EI_UPDATEDATE, EI_REFNO" +
|
|
|
- " ,'01' EI_BILLSTATUS,"+friDto.getRushRedState()+" ei_rushredstate,'"+relateRedInvoiceDTO.getSid()+"' ei_redsid,'"+relateRedInvoiceDTO.getAllElectronicInvoiceNumber()+"' ei_relativerefno,"+relateRedInvoiceDTO.getTaxAmount()+" ei_taxamount,"+relateRedInvoiceDTO.getExcludingTaxAmount()+" ei_taxexcludedamount " +
|
|
|
- "FROM ElecInvoice b WHERE EI_ID = " + eiBlue);
|
|
|
- sqls.add("update ElecInvoice set EI_BILLSTATUS='01'" +
|
|
|
- ",ei_rushredstate=" + friDto.getRushRedState() + "" +
|
|
|
- ",ei_redsid='" + relateRedInvoiceDTO.getSid() + "' " +
|
|
|
- ",ei_relativerefno='" + relateRedInvoiceDTO.getAllElectronicInvoiceNumber() + "' " +
|
|
|
- ",ei_taxamount=" + relateRedInvoiceDTO.getTaxAmount() +
|
|
|
- ",ei_taxexcludedamount=" + relateRedInvoiceDTO.getExcludingTaxAmount() +
|
|
|
- ",ei_redpdfurl=null,ei_redpdfattach=null " +
|
|
|
- " where EI_ID = '" + eiBlue + "'");
|
|
|
- sqls.add("update InvoiceOrder set io_refno='" + relateRedInvoiceDTO.getAllElectronicInvoiceNumber() + "' where io_id=" + ioid);
|
|
|
- sqls.add("update billout set bi_refno='" + relateRedInvoiceDTO.getAllElectronicInvoiceNumber() + "' where bi_code='" + bicode + "'");
|
|
|
+ HttpUtil.Response response =HttpUtil.doPost(url+action, JacksonUtil.toJson(paraMap), deipaaskeyauth,deipaasjwt);
|
|
|
+ if (response.getStatusCode() == HttpStatus.OK.value()){
|
|
|
+ String res = response.getResponseText();
|
|
|
+ if(res!=null && !"".equals(res)){
|
|
|
+ Map<String,Object> resMap = JacksonUtil.fromJson(res);
|
|
|
+ if(StringUtil.hasText(resMap.get("OUTPUTDATA"))){
|
|
|
+ if(StringUtil.hasText(String.valueOf(resMap.get("OUTPUTDATA")))){
|
|
|
+ List<Map<String,Object>> outputdataList = (List) resMap.get("OUTPUTDATA");
|
|
|
+ for (Map<String,Object> outputdataMap:outputdataList) {
|
|
|
+ if(!"S".equals(outputdataMap.get("e_msgtype"))){
|
|
|
+ errMsg.append("条码:").append(outputdataMap.get("zalt_id")).append(",原因:").append(outputdataMap.get("e_msg")).append("</br>");
|
|
|
+ baseDao.execute("update CatlDocDetail set cd_errmsg='"+outputdataMap.get("e_msg")+"' where cd_caid = "+id+" and cd_panid = '"+outputdataMap.get("zalt_id")+"'");
|
|
|
+ }
|
|
|
}
|
|
|
+ }else {
|
|
|
+ logger.info("updateSticker-F:No ResponseText");
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", "No outPutData");
|
|
|
}
|
|
|
+ }else {
|
|
|
+ logger.info("updateSticker-F:No ResponseText");
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", "No ResponseText");
|
|
|
}
|
|
|
+ }else{
|
|
|
+ logger.info("updateSticker-F:No ResponseText");
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", "No ResponseText");
|
|
|
}
|
|
|
- //记录发票明细
|
|
|
-// System.out.println(sqls.toString());
|
|
|
- baseDao.execute(sqls);
|
|
|
- //红字
|
|
|
- commonService.logSRecord("退货订单关联发票对接", ioid);
|
|
|
- } else {// {"status":"8958","message":"该订单对应的开票单不存在","data":null} 没有开票单的不记录对接失败日志
|
|
|
- if (errMsg.length() > 3850) {
|
|
|
- errMsg = errMsg.substring(0, 3850);
|
|
|
- }
|
|
|
- baseDao.execute("update invoiceOrder set io_errorMsg='订单关联发票查询失败: " + errMsg + "' where io_id=" + ioid);
|
|
|
- commonService.logFRecord("退货订单关联发票对接", "蓝发票信息获取：(" + errCode + ")" + errMsg, ioid);
|
|
|
+ }else {
|
|
|
+ logger.info("updateSticker-F:StatusCode {} ResponseText {}",response.getStatusCode(),response.getResponseText());
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", response.getStatusCode()+":"+response.getResponseText());
|
|
|
}
|
|
|
- } catch (Exception e) {
|
|
|
+ }catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
- errMsg = "发票获取异常";
|
|
|
- if (StringUtil.hasText(e.getMessage())) {
|
|
|
- errMsg = e.getMessage();
|
|
|
- } else if (e.getCause() != null && StringUtil.hasText(e.getCause().getMessage())) {
|
|
|
- errMsg = e.getCause().getMessage();
|
|
|
- }
|
|
|
- logger.info("RedReturnElecI-DownLoad-master: {} ,id {} message {}", SpObserver.getSp(), ioid, errMsg);
|
|
|
- commonService.logFRecord("退货订单关联发票对接", errMsg.replaceAll("'", "''"), ioid);
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message", "对接异常");
|
|
|
}
|
|
|
- //获取红字发票PDF地址
|
|
|
- List<String> serialNosAll = baseDao.queryForList("select ei_redsid from ElecInvoice " +
|
|
|
- "where ei_id = " + eiBlue + " and EI_RELATIVEREFNO is not null and ei_redpdfurl is null and nvl(EI_BILLSTATUS,' ') in (' ','01','04')", String.class);
|
|
|
- if (!CollectionUtil.isEmpty(serialNosAll)) {
|
|
|
- queryRedPdfUrl(serialNosAll, m);
|
|
|
+ if(errMsg.length()>0){
|
|
|
+ retMap.put("success",false);
|
|
|
+ retMap.put("message",errMsg.toString());
|
|
|
}
|
|
|
- if (StringUtil.hasText(errMsg) && !"调用成功".equals(errMsg)) {
|
|
|
- res.put("success", false);
|
|
|
- res.put("errCode", errCode);
|
|
|
- res.put("errMsg", errMsg);
|
|
|
- } else {
|
|
|
- res.put("success", true);
|
|
|
- }
|
|
|
- return res;
|
|
|
+ return retMap;
|
|
|
}
|
|
|
|
|
|
+
|
|
|
}
|
