feature: 重汽批量开票回推

master
dongxiaoke 1 year ago
parent 369ca3e10c
commit e798d9c6c4
  1. 2
      jianshui-common/src/main/java/com/jianshui/common/utils/encrypt/JianshuiInvoiceDecryptUtil.java
  2. 13
      jianshui-invoice/src/main/java/com/jianshui/invoice/task/QueryInvoiceTask.java

@ -20,7 +20,7 @@ import java.security.MessageDigest;
* 功能描述
* 加密常用类
*/
public class AisinoInvoiceDecryptUtil {
public class JianshuiInvoiceDecryptUtil {
private static final String ALGORITHM = "AES/GCM/NoPadding";
private static final int KEY_SIZE = 128; // 密钥长度为128位

@ -99,15 +99,16 @@ public class QueryInvoiceTask extends TimerTask {
QueryWrapper<InvoiceBack> invoiceBackQueryWrapper = new QueryWrapper<>();
invoiceBackQueryWrapper.eq("system_orderno", invoice.getOutTradeOrderno());
InvoiceBack invoiceBackVali = invoiceBackMapper.selectOne(invoiceBackQueryWrapper);
InvoiceBack invoiceBackVali = this.invoiceBackMapper.selectOne(invoiceBackQueryWrapper);
log.info("【重汽批量开票】查询回调表信息:{}",JSONUtil.toJsonStr(invoiceBackVali));
if (BeanUtil.isEmpty(invoiceBackVali)) {
invoiceBackVali = new InvoiceBack();
invoiceBackVali.setSystemOrderno(invoice.getOutTradeOrderno());
invoiceBackVali.setCreateTime(new Date());
invoiceBackVali.setId(IdUtils.randomUUID());
invoiceBackVali.setIdentity(companyservice.getIdentity());
invoiceBackVali.setIdentity(this.companyservice.getIdentity());
invoiceBackVali.setBackUrl("");
invoiceBackVali.setStatus("0");
invoiceBackVali.setCreateTime(new Date());
@ -116,17 +117,17 @@ public class QueryInvoiceTask extends TimerTask {
invoiceBackVali.setResultCode(kpStatus);
invoiceBackVali.setResultMsg(kpMsg);
invoiceBackVali.setUpdateTime(new Date());
invoiceBackMapper.insertInvoiceBack(invoiceBackVali);
this.invoiceBackMapper.insertInvoiceBack(invoiceBackVali);
} else {
invoiceBackVali.setResultCode(kpStatus);
invoiceBackVali.setResultMsg(kpMsg);
invoiceBackVali.setStatus("0");
invoiceBackVali.setUpdateTime(new Date());
invoiceBackMapper.updateInvoiceBack(invoiceBackVali);
this.invoiceBackMapper.updateInvoiceBack(invoiceBackVali);
}
log.info("【重汽批量开票】发票回调队列开始回调,组装参数:回调参数={},identity={},invoiceId={}", invoiceBackVali.toString(),companyservice.getIdentity(),invoice.getId());
invoiceApiService.callBackAisino(invoiceBackVali, "", companyservice.getIdentity(), invoice.getId());
log.info("【重汽批量开票】发票回调队列开始回调,组装参数:回调参数={},identity={},invoiceId={}", invoiceBackVali.toString(),this.companyservice.getIdentity(),invoice.getId());
this.invoiceApiService.callBackAisino(invoiceBackVali, "", this.companyservice.getIdentity(), invoice.getId());
log.info("【重汽批量开票】 发票批量开具回调队列处理完成: InvoiceId={}",invoice.getId());
} catch (Exception e) {
log.info("【重汽批量开票】发票回调队列失败!invoiceId={},捕捉异常{}", invoice.getId(),e.toString());

Loading…
Cancel
Save