@ -2,6 +2,7 @@ package com.jianshui.invoice.service.impl.api;
import cn.hutool.core.bean.BeanUtil ;
import cn.hutool.core.codec.Base64 ;
import cn.hutool.core.util.StrUtil ;
import cn.hutool.json.JSONUtil ;
import com.alibaba.fastjson.JSONArray ;
import com.alibaba.fastjson.JSONObject ;
@ -9,6 +10,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.dxhy.order.protocol.invoke.DxhyInterfaceResponse ;
import com.google.gson.Gson ;
import com.jianshui.common.constant.Constants ;
import com.jianshui.common.constant.WebServiceConstant ;
import com.jianshui.common.core.domain.AjaxResult ;
import com.jianshui.common.core.domain.entity.Companyservice ;
import com.jianshui.common.enums.ErrorCode ;
@ -19,9 +21,10 @@ import com.jianshui.common.utils.DateUtils;
import com.jianshui.common.utils.StringUtils ;
import com.jianshui.common.utils.TimeUtil ;
import com.jianshui.common.utils.http.HttpHelper ;
import com.jianshui.common.utils.jcsk.ApiHttp ;
import com.jianshui.common.utils.uuid.IdUtils ;
import com.jianshui.framework.manager.AsyncManager ;
import com.jianshui.invoice.constant.elephant.ElephantConstants ;
import com.jianshui.invoice.constant.elephant.ElephantConstantsV6 ;
import com.jianshui.invoice.domain.* ;
import com.jianshui.invoice.domain.dto.* ;
import com.jianshui.invoice.domain.dto.adapter.response.RedInfoDTO ;
@ -43,6 +46,7 @@ import com.jianshui.queue.utils.RedisQueueUtil;
import com.jianshui.storage.domain.StorageUrlDTO ;
import com.jianshui.storage.factory.StorageFactory ;
import com.jianshui.storage.service.IStorageService ;
import com.jianshui.system.domain.InvoiceAllApiLog ;
import com.jianshui.system.mapper.CompanyserviceMapper ;
import com.jianshui.system.service.ISysConfigService ;
import lombok.extern.slf4j.Slf4j ;
@ -189,12 +193,12 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
// JSONObject result = JSONObject.parseObject("{\"zipCode\":\"0\",\"entCode\":\"91370102MA3UD2FG21\",\"dataExchangeId\":\"20220328140706911955546286280593\",\"encryptCode\":\"0\",\"returnStateInfo\":{\"returnCode\":\"0000\",\"returnMessage\":\"5aSE55CG5oiQ5YqfIQ==\"},\"content\":\"eyJERFFRUENIIjoiODgyOWNmNWUtNDAyYS00NWZkLWFiYmEtMzlkMjlhOWMzMjMzIiwiWlRETSI6IjAwOTk5OSIsIlpUWFgiOiLkvIHkuJrmnKrphY3nva7nqI7mjqforr7lpIcifQ==\"}");
// if (!CommonUtils.isDevMode()) {
// result = ElephantUtils.sendRequest(ElephantConstants.ADD_INVOICE, (JSONObject) JSONObject.toJSON(elephantInvoiceAddDTO));
// result = ElephantUtils.sendRequest(ElephantConstantsV6 .ADD_INVOICE, (JSONObject) JSONObject.toJSON(elephantInvoiceAddDTO));
// }
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstants.ADD_INVOICE, JSONUtil.parse(elephantInvoiceAddDTO));
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstantsV6 .ADD_INVOICE, JSONUtil.parse(elephantInvoiceAddDTO));
AjaxResult queryResult = null ;
try {
queryResult = ElephantUtils . sendRequestWithoutTokenV6New ( ElephantConstants . ADD_INVOICE_LOCALHOST , ElephantConstants . ADD_INVOICE_METHOD , JSONUtil . parse ( elephantInvoiceAddDTO ) , companyservice ) ;
queryResult = ElephantUtils . sendRequestWithoutTokenV6New ( ElephantConstantsV6 . ADD_INVOICE_LOCALHOST , ElephantConstantsV6 . ADD_INVOICE_METHOD , JSONUtil . parse ( elephantInvoiceAddDTO ) , companyservice ) ;
} catch ( UnsupportedEncodingException | NoSuchAlgorithmException | InvalidKeyException e ) {
log . error ( "【销项发票】【大象接口】【发票开具】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( elephantInvoiceAddDTO ) . toString ( ) , JSONObject . toJSONString ( companyservice ) ) ;
e . printStackTrace ( ) ;
@ -227,9 +231,9 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
queryBody . put ( "DDQQPCH" , billInfo . getSystemOrderno ( ) ) ;
queryBody . put ( "FPLXDM" , fplxdm ) ;
queryBody . put ( "SFFHSBSJ" , "0" ) ;
// queryResult = ElephantUtils.sendRequest(ElephantConstants.ADD_INVOICE_RESULT, JSONUtil.parse(queryBody));
// queryResult = ElephantUtils.sendRequest(ElephantConstantsV6 .ADD_INVOICE_RESULT, JSONUtil.parse(queryBody));
try {
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstants . ADD_INVOICE_RESULT_LOCALHOST , ElephantConstants . ADD_INVOICE_RESULT_METHOD , JSONUtil . parse ( queryBody ) , companyservice ) ;
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstantsV6 . ADD_INVOICE_RESULT_LOCALHOST , ElephantConstantsV6 . ADD_INVOICE_RESULT_METHOD , JSONUtil . parse ( queryBody ) , companyservice ) ;
} catch ( UnsupportedEncodingException | InvalidKeyException | NoSuchAlgorithmException e ) {
log . error ( "【销项发票】【大象接口】【发票开具】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( elephantInvoiceAddDTO ) . toString ( ) , JSONObject . toJSONString ( companyservice ) ) ;
e . printStackTrace ( ) ;
@ -350,11 +354,11 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
queryBody . put ( "BSWJ" , "0" ) ;
debugLog ( "断点4" , uuid , timestamp ) ;
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstants.QUERY_INVOICE, JSONUtil.parse(queryBody));
// queryResult = ElephantUtils.sendRequest(ElephantConstants.ADD_INVOICE_RESULT, JSONUtil.parse(queryBody));
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstantsV6 .QUERY_INVOICE, JSONUtil.parse(queryBody));
// queryResult = ElephantUtils.sendRequest(ElephantConstantsV6 .ADD_INVOICE_RESULT, JSONUtil.parse(queryBody));
AjaxResult queryResult = null ;
try {
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstants . QUERY_INVOICE_LOCALHOST , ElephantConstants . QUERY_INVOICE_METHOD , JSONUtil . parse ( queryBody ) , companyservice ) ;
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstantsV6 . QUERY_INVOICE_LOCALHOST , ElephantConstantsV6 . QUERY_INVOICE_METHOD , JSONUtil . parse ( queryBody ) , companyservice ) ;
} catch ( UnsupportedEncodingException | InvalidKeyException | NoSuchAlgorithmException e ) {
log . error ( "【销项发票】【大象接口】【发票开具】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( queryBody ) . toString ( ) , JSONObject . toJSONString ( companyservice ) ) ;
e . printStackTrace ( ) ;
@ -763,7 +767,7 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
}
DxhyInterfaceResponse dxhyInterfaceResponse = null ;
try {
dxhyInterfaceResponse = ElephantUtils . sendRequestWithoutTokenV6 ( ElephantConstants . REDINFO_FIND_LOCALHOST , ElephantConstants . REDINFO_FIND_METHOD , JSONUtil . parse ( findRedInfo ) , companyservice ) ;
dxhyInterfaceResponse = ElephantUtils . sendRequestWithoutTokenV6 ( ElephantConstantsV6 . REDINFO_FIND_LOCALHOST , ElephantConstantsV6 . REDINFO_FIND_METHOD , JSONUtil . parse ( findRedInfo ) , companyservice ) ;
} catch ( UnsupportedEncodingException | InvalidKeyException | NoSuchAlgorithmException e ) {
log . error ( "【销项发票】【大象接口】【红字信息表查询】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( findRedInfo ) . toString ( ) , JSONObject . toJSONString ( companyservice ) ) ;
e . printStackTrace ( ) ;
@ -806,6 +810,30 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
}
/ * *
* 生成动态二维码接口
* @param decryptResult
* @param companyservice
* @return
* /
@Override
public HXResponse generateDynamicCode ( JSONObject decryptResult , Companyservice companyservice ) {
DxhyInterfaceResponse dxhyInterfaceResponse = null ;
try {
dxhyInterfaceResponse = ElephantUtils . sendRequestWithoutTokenV6 ( ElephantConstantsV6 . GEN_DYNAMIC_CODE_LOCALHOST , ElephantConstantsV6 . GEN_DYNAMIC_CODE_METHOD , JSONUtil . parse ( decryptResult ) , companyservice ) ;
} catch ( UnsupportedEncodingException | InvalidKeyException | NoSuchAlgorithmException e ) {
log . error ( "【销项发票】【大象接口】【生成动态二维码】发票请求异常,请求报文{},销方信息{}" , decryptResult , JSONObject . toJSONString ( companyservice ) ) ;
e . printStackTrace ( ) ;
return new HXResponse ( "9999" , "系统异常!" ) ;
}
String data = dxhyInterfaceResponse . getData ( ) ;
String code = dxhyInterfaceResponse . getCode ( ) ;
return new HXResponse ( code , data ) ;
}
@ -914,10 +942,10 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
HZSQDSCZXXList . add ( HZSQDSCZXX ) ;
elephatRedInfoDTO . setHZSQDSCZXX ( HZSQDSCZXXList ) ;
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstants.REDINFO_UPLOAD, JSONUtil.parse(elephatRedInfoDTO));
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstantsV6 .REDINFO_UPLOAD, JSONUtil.parse(elephatRedInfoDTO));
AjaxResult queryResult = null ;
try {
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstants . REDINFO_UPLOAD_LOCALHOST , ElephantConstants . REDINFO_UPLOAD_METHOD , JSONUtil . parse ( elephatRedInfoDTO ) , companyservice ) ;
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstantsV6 . REDINFO_UPLOAD_LOCALHOST , ElephantConstantsV6 . REDINFO_UPLOAD_METHOD , JSONUtil . parse ( elephatRedInfoDTO ) , companyservice ) ;
} catch ( UnsupportedEncodingException | InvalidKeyException | NoSuchAlgorithmException e ) {
log . error ( "【销项发票】【大象接口】【红字信息表上传】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( elephatRedInfoDTO ) . toString ( ) , JSONObject . toJSONString ( companyservice ) ) ;
e . printStackTrace ( ) ;
@ -1100,11 +1128,11 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
for ( ; page < 11 ; page + + ) {
queryJson . put ( "YS" , page ) ; // 页数",
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstants.DEPRECATE_INVOICE, JSONUtil.parse(queryJson));
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstantsV6 .DEPRECATE_INVOICE, JSONUtil.parse(queryJson));
AjaxResult queryResult = null ;
try {
// System.out.println(JSONUtil.parse(queryJson));
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstants . REDINFO_DOWNLOAD_LOCALHOST , ElephantConstants . REDINFO_DOWNLOAD_METHOD , JSONUtil . parse ( queryJson ) , companyservice ) ;
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstantsV6 . REDINFO_DOWNLOAD_LOCALHOST , ElephantConstantsV6 . REDINFO_DOWNLOAD_METHOD , JSONUtil . parse ( queryJson ) , companyservice ) ;
} catch ( UnsupportedEncodingException | InvalidKeyException | NoSuchAlgorithmException e ) {
log . error ( "【销项发票】【大象接口】【红字信息表下载】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( queryJson ) . toString ( ) , JSONObject . toJSONString ( companyservice ) ) ;
break ;
@ -1332,10 +1360,10 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
queryBody . put ( "FPZH" , invoice . getFphm ( ) ) ;
queryBody . put ( "ZFLX" , "1" ) ;
queryBody . put ( "ZFPCH" , IdUtils . randomSystemOrderno ( ) ) ;
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstants.DEPRECATE_INVOICE, JSONUtil.parse(queryBody));
// AjaxResult queryResult = ElephantUtils.sendRequest(ElephantConstantsV6 .DEPRECATE_INVOICE, JSONUtil.parse(queryBody));
AjaxResult queryResult = null ;
try {
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstants . DEPRECATE_INVOICE_LOCALHOST , ElephantConstants . DEPRECATE_INVOICE_METHOD , JSONUtil . parse ( queryBody ) , companyservice ) ;
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstantsV6 . DEPRECATE_INVOICE_LOCALHOST , ElephantConstantsV6 . DEPRECATE_INVOICE_METHOD , JSONUtil . parse ( queryBody ) , companyservice ) ;
} catch ( UnsupportedEncodingException | InvalidKeyException | NoSuchAlgorithmException e ) {
log . error ( "【销项发票】【大象接口】【发票作废】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( queryBody ) . toString ( ) , JSONObject . toJSONString ( companyservice ) ) ;
e . printStackTrace ( ) ;
@ -1360,9 +1388,9 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
// queryBody.put("XHFSBH", companyservice.getSellertax()); // 销货方纳税人识别号
// queryBody.put("FPDM", invoice.getFpdm());
// queryBody.put("FPHM", invoice.getFphm());
// // queryResult = ElephantUtils.sendRequest(ElephantConstants.DEPRECATE_INVOICE_RESULT, JSONUtil.parse(queryBody));
// // queryResult = ElephantUtils.sendRequest(ElephantConstantsV6 .DEPRECATE_INVOICE_RESULT, JSONUtil.parse(queryBody));
// try {
// queryResult = ElephantUtils.sendRequestWithoutToken(ElephantConstants.DEPRECATE_INVOICE_RESULT_LOCALHOST, ElephantConstants.DEPRECATE_INVOICE_RESULT_METHOD, JSONUtil.parse(queryBody), companyservice);
// queryResult = ElephantUtils.sendRequestWithoutToken(ElephantConstantsV6 .DEPRECATE_INVOICE_RESULT_LOCALHOST, ElephantConstantsV6 .DEPRECATE_INVOICE_RESULT_METHOD, JSONUtil.parse(queryBody), companyservice);
// } catch (UnsupportedEncodingException | InvalidKeyException | NoSuchAlgorithmException e) {
// log.error("【销项发票】【大象接口】【发票开具】发票请求异常,请求报文{},销方信息{}", JSONUtil.parse(queryBody).toString(), JSONObject.toJSONString(companyservice));
// e.printStackTrace();
@ -1451,7 +1479,7 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
query . put ( "DYJMC" , queryPrinterDTO . getPrinterName ( ) ) ;
AjaxResult queryResult = null ;
try {
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstants . QUERY_PRINTER_LOCALHOST , ElephantConstants . QUERY_PRINTER , JSONUtil . parse ( query ) , companyservice ) ;
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstantsV6 . QUERY_PRINTER_LOCALHOST , ElephantConstantsV6 . QUERY_PRINTER , JSONUtil . parse ( query ) , companyservice ) ;
} catch ( UnsupportedEncodingException | NoSuchAlgorithmException | InvalidKeyException e ) {
log . error ( "【销项发票】【大象接口】【打印机查询】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( query ) . toString ( ) , JSONObject . toJSONString ( companyservice ) ) ;
e . printStackTrace ( ) ;
@ -1536,7 +1564,7 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
AjaxResult queryResult = null ;
try {
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstants . BATCH_PRINT_LOCALHOST , ElephantConstants . BATCH_PRINT , JSONUtil . parse ( query ) , companyservice ) ;
queryResult = ElephantUtils . sendRequestWithoutToken ( ElephantConstantsV6 . BATCH_PRINT_LOCALHOST , ElephantConstantsV6 . BATCH_PRINT , JSONUtil . parse ( query ) , companyservice ) ;
} catch ( UnsupportedEncodingException | NoSuchAlgorithmException | InvalidKeyException e ) {
log . error ( "【销项发票】【大象接口】【打印机查询】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( query ) . toString ( ) , JSONObject . toJSONString ( companyservice ) ) ;
e . printStackTrace ( ) ;
@ -1593,7 +1621,7 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
AjaxResult queryResult = null ;
System . out . println ( JSONUtil . parse ( signESealDTO ) . toString ( ) ) ;
try {
queryResult = ElephantUtils . sendRequest ( ElephantConstants . SIGN
queryResult = ElephantUtils . sendRequest ( ElephantConstantsV6 . SIGN
, JSONUtil . parse ( signESealDTO ) , companyservice , true ) ;
} catch ( Exception e ) {
log . error ( "【销项发票】【大象接口】【发票签章】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( signESealDTO ) . toString ( )
@ -1626,7 +1654,7 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
AjaxResult queryResult = null ;
try {
queryResult = ElephantUtils . sendRequest ( ElephantConstants . SIGN_CREATE
queryResult = ElephantUtils . sendRequest ( ElephantConstantsV6 . SIGN_CREATE
, JSONUtil . parse ( createESealDTO ) , companyservice , true ) ;
} catch ( Exception e ) {
log . error ( "【销项发票】【大象接口】【发票专用章图片生成】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( createESealDTO ) . toString ( )
@ -1661,7 +1689,7 @@ public class ElephantInvoiceApiV6ServiceImpl implements IInvoiceApiService {
AjaxResult queryResult = null ;
try {
queryResult = ElephantUtils . sendRequest ( ElephantConstants . SIGN_REGISTER
queryResult = ElephantUtils . sendRequest ( ElephantConstantsV6 . SIGN_REGISTER
, JSONUtil . parse ( createESealDTO ) , companyservice , true ) ;
} catch ( Exception e ) {
log . error ( "【销项发票】【大象接口】【发票专用章导入】发票请求异常,请求报文{},销方信息{}" , JSONUtil . parse ( createESealDTO ) . toString ( )