feat(mall): 实现发送金蝶数据功能

吕琪
1 parent 99adb175
Showing 21 changed files with 1237 additions and 4 deletions
cashier-mall/src/main/java/com/diligrp/cashier/mall/MallConfiguration.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/MallConstants.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/api/TaxAgentApi.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/client/CardInfoHttpClient.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizPaymentDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/MallBizRefundDao.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/tax/ReceiptItem.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/tax/ReceivableItem.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/tax/RefundItem.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/tax/TaxMessage.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/tax/TradeTaxMessageBO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/TaxAgentNotifyService.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/TaxAgentService.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/impl/TaxAgentNotifyServiceImpl.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/biz/impl/TaxAgentServiceImpl.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/sourcechannel/AbstractSourceChannel.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/type/TaxAgentActionEnum.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/type/TaxAgentDocumentTypeEnum.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/type/TaxMessageType.java
cashier-mall/src/main/resources/com/diligrp/cashier/dao/mapper/MallBizPaymentDao.xml
@@ -38,6 +38,26 @@ public class MallConfiguration {
     }
     @Bean
+    public Queue taxQueue() {
+        return new Queue(MallConstants.TAX_REPORT_DELAY_QUEUE, true, false, false);
+    }
+    @Bean
+    public CustomExchange taxCustomExchange() {
+        Map<String, Object> args = new HashMap<>();
+        args.put("x-delayed-type", "direct");
+        return new CustomExchange(MallConstants.TAX_REPORT_DELAY_EXCHANGE, MallConstants.EXCHANGE_TYPE, true, false, args);
+    }
+
+    @Bean
+    public Binding taxBinding(Queue taxQueue, CustomExchange taxCustomExchange) {
+        return BindingBuilder.bind(taxQueue)
+                .to(taxCustomExchange)
+                .with(MallConstants.TAX_REPORT_DELAY_KEY)
+                .noargs();
+    }
+
+
+    @Bean
     public CustomExchange customExchange() {
         Map<String, Object> args = new HashMap<>();
         args.put("x-delayed-type", "direct");
@@ -24,4 +24,13 @@ public interface MallConstants {
     // 延时1分钟
     Integer WAIT_DELAY_MILLIS = 60_000;
+
+    // 财务报表延时队列
+    String TAX_REPORT_DELAY_QUEUE = "cashier.tax.delayQueue";
+
+    // 财务报表延时交换机
+    String TAX_REPORT_DELAY_EXCHANGE = "cashier.tax.delayExchange";
+
+    // 财务报表延时路由KEY
+    String TAX_REPORT_DELAY_KEY = "cashier.tax.delayKey";
 }
+package com.diligrp.cashier.mall.api;
+
+import com.diligrp.cashier.mall.service.biz.TaxAgentService;
+import jakarta.annotation.Resource;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * @author lvqi
+ */
+@RestController
+@RequestMapping("/tax")
+public class TaxAgentApi {
+
+    @Resource
+    private TaxAgentService taxAgentService;
+
+    @GetMapping("/order/init")
+    public void initOrder() {
+        taxAgentService.initOrder();
+    }
+
+    @GetMapping("/refund/init")
+    public void initRefund() {
+        taxAgentService.initRefund();
+    }
+
+    @GetMapping("/sync_order")
+    public void syncOrder(@RequestParam("paymentIds") List<Long> paymentIds,
+                          @RequestParam("startTime") String startTime, @RequestParam("endTime") String endTime) {
+        taxAgentService.syncOrder(paymentIds, startTime, endTime);
+    }
+
+    @GetMapping("/sync_refund")
+    public void syncRefund(@RequestParam("paymentIds") List<Long> paymentIds,
+                           @RequestParam("startTime") String startTime, @RequestParam("endTime") String endTime) {
+        taxAgentService.syncRefund(paymentIds, startTime, endTime);
+    }
+
+
+}
+package com.diligrp.cashier.mall.client;
+
+import com.diligrp.cashier.mall.util.HttpClientUtils;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author lvqi
+ */
+
+public class CardInfoHttpClient {
+
+    public static Object getCardPayInfo(String urlPrefix, List<Long> accountIds) {
+        Map<String, Object> params = new HashMap<>();
+        params.put("accountIds", accountIds);
+        Map<String, Object> map = HttpClientUtils.postJson(
+                urlPrefix + "/cashier/query/accountListWithOutAuth",
+                params,
+                null,
+                new TypeReference<>() {
+                },
+                ""
+        );
+        if (map != null && map.get("code").equals("200")) {
+            return map.get("data");
+        }
+        return null;
+
+    }
+
+    public static Map<String, Object> getCardCustomerInfo(String urlPrefix, Long marketId, Long id) {
+        Map<String, Object> params = new HashMap<>();
+        params.put("marketId", marketId);
+        params.put("id", id);
+        Map<String, Object> map = HttpClientUtils.postJson(urlPrefix + "/cashier/query/customerInfo", params, null, new TypeReference<>() {
+        }, "");
+        if (map != null && map.get("code").equals("200")) {
+            return JsonUtils.fromJsonString(JsonUtils.toJsonString(map.get("data")), new TypeReference<>() {
+            });
+        }
+        return null;
+    }
+
+}
@@ -4,6 +4,8 @@ import com.diligrp.cashier.mall.model.MallBizPayment;
 import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
 import org.apache.ibatis.annotations.Param;
+import java.util.List;
+
 /**
  * MallBizPaymentDao
  *
@@ -25,4 +27,8 @@ public interface MallBizPaymentDao extends MybatisMapperSupport {
     MallBizPayment getByPayTradeId(@Param("tradeId") String tradeId);
     MallBizPayment findByOrderIdAndTradeId(@Param("orderId") String orderId, @Param("tradeId") String tradeId);
+
+    List<MallBizPayment> initOrder();
+
+    List<MallBizPayment> selectByTimes(@Param("startTime") String startTime, @Param("endTime") String endTime);
 }
@@ -5,6 +5,8 @@ import com.diligrp.cashier.mall.model.MallBizRefund;
 import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
 import org.apache.ibatis.annotations.Param;
+import java.util.List;
+
 public interface MallBizRefundDao extends MybatisMapperSupport {
     int deleteByPrimaryKey(Long id);
@@ -23,4 +25,7 @@ public interface MallBizRefundDao extends MybatisMapperSupport {
     MallBizRefund getByRefundTradeId(@Param("refundTradeId") String refundTradeId);
     long sumRefundFee(@Param("bizOrderId") Long bizOrderId);
+
+    List<MallBizRefund> initRefund();
+    List<MallBizRefund> selectByTimes(@Param("startTime") String startTime, @Param("endTime") String endTime);
 }
+package com.diligrp.cashier.mall.domain.tax;
+
+/**
+ * 收款单
+ *
+ * @author lvqi
+ */
+
+public class ReceiptItem {
+
+    /**
+     * 费用编码(FCOSTID)
+     */
+    private String chargeItem;
+    /**
+     * 结算方法(FSETTLETYPEID)
+     */
+    private String settleMethod;
+    /**
+     * 应收金额(FRECTOTALAMOUNTFOR)
+     */
+    private String amountReceivable;
+    /**
+     * 收款用途(FPURPOSEID)
+     */
+    private String receiveUsedFor;
+    /**
+     * 银行卡号(FACCOUNTID)
+     */
+
+    private String bankCardNumber;
+    /**
+     * 费用部门(FCOSTDEPARTMENTID)
+     */
+    private String chargeItemDept;
+
+    public String getChargeItem() {
+        return chargeItem;
+    }
+
+    public void setChargeItem(String chargeItem) {
+        this.chargeItem = chargeItem;
+    }
+
+    public String getSettleMethod() {
+        return settleMethod;
+    }
+
+    public void setSettleMethod(String settleMethod) {
+        this.settleMethod = settleMethod;
+    }
+
+    public String getAmountReceivable() {
+        return amountReceivable;
+    }
+
+    public void setAmountReceivable(String amountReceivable) {
+        this.amountReceivable = amountReceivable;
+    }
+
+    public String getReceiveUsedFor() {
+        return receiveUsedFor;
+    }
+
+    public void setReceiveUsedFor(String receiveUsedFor) {
+        this.receiveUsedFor = receiveUsedFor;
+    }
+
+    public String getBankCardNumber() {
+        return bankCardNumber;
+    }
+
+    public void setBankCardNumber(String bankCardNumber) {
+        this.bankCardNumber = bankCardNumber;
+    }
+
+    public String getChargeItemDept() {
+        return chargeItemDept;
+    }
+
+    public void setChargeItemDept(String chargeItemDept) {
+        this.chargeItemDept = chargeItemDept;
+    }
+
+    public static ReceiptItem of(String chargeItem, String settleMethod, String amountReceivable, String bankCardNumber) {
+        ReceiptItem receiptItem = new ReceiptItem();
+        receiptItem.setChargeItem(chargeItem);
+        receiptItem.setSettleMethod(settleMethod);
+        receiptItem.setAmountReceivable(amountReceivable);
+        receiptItem.setBankCardNumber(bankCardNumber);
+        return receiptItem;
+    }
+}
+package com.diligrp.cashier.mall.domain.tax;
+
+/**
+ * 应收单
+ *
+ * @author lvqi
+ */
+public class ReceivableItem {
+
+    /**
+     * 费用编码(FCOSTID) 1
+     */
+    private String chargeItem;
+    /**
+     * 卡号(FASSETID) 园区卡支付
+     */
+    private String cardNumber;
+    /**
+     * 报价数量(FPriceQty ) 1
+     */
+    private String quotedQuantity;
+    /**
+     * 含税单价(FTaxPrice)
+     */
+    private String unitPriceIncludingTax;
+    /**
+     * 价格(FPrice) 1
+     */
+    private String price;
+    /**
+     * 不含税金额(FNoTaxAmountFor_D) 1
+     */
+    private String amountExcludingTax;
+    /**
+     * 费用部门(FCOSTDEPARTMENTID)
+     */
+    private String chargeItemDept;
+
+    public String getChargeItem() {
+        return chargeItem;
+    }
+
+    public void setChargeItem(String chargeItem) {
+        this.chargeItem = chargeItem;
+    }
+
+    public String getCardNumber() {
+        return cardNumber;
+    }
+
+    public void setCardNumber(String cardNumber) {
+        this.cardNumber = cardNumber;
+    }
+
+    public String getQuotedQuantity() {
+        return quotedQuantity;
+    }
+
+    public void setQuotedQuantity(String quotedQuantity) {
+        this.quotedQuantity = quotedQuantity;
+    }
+
+    public String getUnitPriceIncludingTax() {
+        return unitPriceIncludingTax;
+    }
+
+    public void setUnitPriceIncludingTax(String unitPriceIncludingTax) {
+        this.unitPriceIncludingTax = unitPriceIncludingTax;
+    }
+
+    public String getPrice() {
+        return price;
+    }
+
+    public void setPrice(String price) {
+        this.price = price;
+    }
+
+    public String getAmountExcludingTax() {
+        return amountExcludingTax;
+    }
+
+    public void setAmountExcludingTax(String amountExcludingTax) {
+        this.amountExcludingTax = amountExcludingTax;
+    }
+
+    public String getChargeItemDept() {
+        return chargeItemDept;
+    }
+
+    public void setChargeItemDept(String chargeItemDept) {
+        this.chargeItemDept = chargeItemDept;
+    }
+
+
+    public static ReceivableItem of(String chargeItem, String cardNumber, String quotedQuantity, String price,String chargeItemDept) {
+        ReceivableItem receivableItem = new ReceivableItem();
+        receivableItem.setChargeItem(chargeItem);
+        receivableItem.setCardNumber(cardNumber);
+        receivableItem.setQuotedQuantity(quotedQuantity);
+        receivableItem.setUnitPriceIncludingTax(price);
+        //receivableItem.setAmountExcludingTax(price);
+        receivableItem.setPrice(price);
+        receivableItem.setChargeItemDept(chargeItemDept);
+        return receivableItem;
+    }
+}
+package com.diligrp.cashier.mall.domain.tax;
+
+/**
+ * 退款单
+ *
+ * @author lvqi
+ */
+
+public class RefundItem {
+    /**
+     * 费用编码(FCOSTID)
+     */
+    private String chargeItem;
+    /**
+     * 结算方法(FSETTLETYPEID)
+     */
+    private String settleMethod;
+    /**
+     * 应退金额(FREFUNDAMOUNTFOR)
+     */
+    private String amountRefundable;
+    /**
+     * 备注(FNOTE)
+     */
+    private String remark;
+    /**
+     * 原收款用途(FPURPOSEID)
+     */
+    private String receiveUsedFor;
+    /**
+     * 银行卡号(FACCOUNTID)
+     */
+    private String bankCardNumber;
+    /**
+     * 费用部门(FCOSTDEPARTMENTID)
+     */
+    private String chargeItemDept;
+
+    public String getChargeItem() {
+        return chargeItem;
+    }
+
+    public void setChargeItem(String chargeItem) {
+        this.chargeItem = chargeItem;
+    }
+
+    public String getSettleMethod() {
+        return settleMethod;
+    }
+
+    public void setSettleMethod(String settleMethod) {
+        this.settleMethod = settleMethod;
+    }
+
+    public String getAmountRefundable() {
+        return amountRefundable;
+    }
+
+    public void setAmountRefundable(String amountRefundable) {
+        this.amountRefundable = amountRefundable;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    public String getReceiveUsedFor() {
+        return receiveUsedFor;
+    }
+
+    public void setReceiveUsedFor(String receiveUsedFor) {
+        this.receiveUsedFor = receiveUsedFor;
+    }
+
+    public String getBankCardNumber() {
+        return bankCardNumber;
+    }
+
+    public void setBankCardNumber(String bankCardNumber) {
+        this.bankCardNumber = bankCardNumber;
+    }
+
+    public String getChargeItemDept() {
+        return chargeItemDept;
+    }
+
+    public void setChargeItemDept(String chargeItemDept) {
+        this.chargeItemDept = chargeItemDept;
+    }
+
+    public static RefundItem of(String chargeItem, String settleMethod, String amountRefundable, String remark, String bankCardNumber) {
+        RefundItem refundItem = new RefundItem();
+        refundItem.setChargeItem(chargeItem);
+        refundItem.setSettleMethod(settleMethod);
+        refundItem.setAmountRefundable(amountRefundable);
+        refundItem.setRemark(remark);
+        refundItem.setBankCardNumber(bankCardNumber);
+        return refundItem;
+    }
+}
+package com.diligrp.cashier.mall.domain.tax;
+
+/**
+ * @author lvqi
+ */
+public class TaxMessage implements java.io.Serializable {
+    private Long paymentId;
+
+    private Integer type;
+
+    public Long getPaymentId() {
+        return paymentId;
+    }
+
+    public void setPaymentId(Long paymentId) {
+        this.paymentId = paymentId;
+    }
+
+    public Integer getType() {
+        return type;
+    }
+
+    public void setType(Integer type) {
+        this.type = type;
+    }
+}
+package com.diligrp.cashier.mall.domain.tax;
+
+import java.util.Map;
+
+/**
+ * @author lvqi
+ */
+public class TradeTaxMessageBO {
+    private String systemDataId;
+    /**
+     * 分组
+     */
+    private String group;
+    /**
+     * 实体
+     */
+    private String entity;
+    /**
+     * 租户账套编码
+     */
+    private String pipelineCode;
+
+    private String businessCode;
+
+    private String documentType;
+    /**
+     * 消息信息
+     */
+    private Map<String, Object> msgBody;
+
+
+    public String getSystemDataId() {
+        return systemDataId;
+    }
+
+    public void setSystemDataId(String systemDataId) {
+        this.systemDataId = systemDataId;
+    }
+
+    public String getGroup() {
+        return group;
+    }
+
+    public void setGroup(String group) {
+        this.group = group;
+    }
+
+    public String getEntity() {
+        return entity;
+    }
+
+    public void setEntity(String entity) {
+        this.entity = entity;
+    }
+
+    public String getPipelineCode() {
+        return pipelineCode;
+    }
+
+    public void setPipelineCode(String pipelineCode) {
+        this.pipelineCode = pipelineCode;
+    }
+
+    public String getBusinessCode() {
+        return businessCode;
+    }
+
+    public void setBusinessCode(String businessCode) {
+        this.businessCode = businessCode;
+    }
+
+    public String getDocumentType() {
+        return documentType;
+    }
+
+    public void setDocumentType(String documentType) {
+        this.documentType = documentType;
+    }
+
+    public Map<String, Object> getMsgBody() {
+        return msgBody;
+    }
+
+    public void setMsgBody(Map<String, Object> msgBody) {
+        this.msgBody = msgBody;
+    }
+
+    public static TradeTaxMessageBO of(String systemDataId, String group, String entity, String pipelineCode,
+                                       String businessCode, String documentType, Map<String, Object> msgBody) {
+        TradeTaxMessageBO tradeTaxMessageBO = new TradeTaxMessageBO();
+        tradeTaxMessageBO.setSystemDataId(systemDataId);
+        tradeTaxMessageBO.setGroup(group);
+        tradeTaxMessageBO.setEntity(entity);
+        tradeTaxMessageBO.setPipelineCode(pipelineCode);
+        tradeTaxMessageBO.setBusinessCode(businessCode);
+        tradeTaxMessageBO.setDocumentType(documentType);
+        tradeTaxMessageBO.setMsgBody(msgBody);
+        return tradeTaxMessageBO;
+    }
+}
+package com.diligrp.cashier.mall.service.biz;
+
+import com.diligrp.cashier.mall.domain.tax.TaxMessage;
+
+/**
+ * @author lvqi
+ */
+
+public interface TaxAgentNotifyService {
+    void sendTaxAgentNotify(TaxMessage taxMessage);
+}
+package com.diligrp.cashier.mall.service.biz;
+
+import java.util.List;
+
+/**
+ * @author lvqi
+ */
+public interface TaxAgentService {
+    void initOrder();
+
+    void initRefund();
+
+    void syncOrder(List<Long> paymentIds, String startTime, String endTime);
+
+    void syncRefund(List<Long> paymentIds, String startTime, String endTime);
+}
+package com.diligrp.cashier.mall.service.biz.impl;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.diligrp.cashier.mall.MallConstants;
+import com.diligrp.cashier.mall.client.CardInfoHttpClient;
+import com.diligrp.cashier.mall.dao.MallBizOrderDao;
+import com.diligrp.cashier.mall.dao.MallBizPaymentDao;
+import com.diligrp.cashier.mall.dao.MallBizRefundDao;
+import com.diligrp.cashier.mall.domain.tax.*;
+import com.diligrp.cashier.mall.model.MallBizOrder;
+import com.diligrp.cashier.mall.model.MallBizPayment;
+import com.diligrp.cashier.mall.model.MallBizRefund;
+import com.diligrp.cashier.mall.service.biz.TaxAgentNotifyService;
+import com.diligrp.cashier.mall.type.OrderChannel;
+import com.diligrp.cashier.mall.type.TaxAgentActionEnum;
+import com.diligrp.cashier.mall.type.TaxAgentDocumentTypeEnum;
+import com.diligrp.cashier.mall.type.TaxMessageType;
+import com.diligrp.cashier.mall.util.HttpClientUtils;
+import com.diligrp.cashier.pipeline.type.ChannelType;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import jakarta.annotation.Resource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 税务代理通知服务实现类
+ *
+ * @author lvqi
+ */
+@Service
+public class TaxAgentNotifyServiceImpl implements TaxAgentNotifyService {
+    private static final Logger log = LoggerFactory.getLogger(TaxAgentNotifyServiceImpl.class);
+
+    private static final String CASHIER = "MALL";
+    // 黑字
+    private static final String BLACK = "1";
+    // 红字
+    private static final String RED = "-1";
+
+    private static final String PAYMENT_BUSINESS_CODE = "order_pay";
+    private static final String REFUND_BUSINESS_CODE = "order_refund";
+    private static final String CARD_NUMBER = "cardNumber";
+    private static final String AREA = "area";
+    private static final String ORG = "org";
+    private static final String SALE_DEPT = "saleDept";
+    private static final String CUSTOMER_CODE = "customerCode";
+
+    private static final String RECEIVABLE_ITEM = "receivableItem";
+    private static final String REFUND_ITEM = "refundItem";
+    public static final String RECEIPT_ITEM = "receiptItem";
+
+    @Resource
+    private MallBizPaymentDao mallBizPaymentDao;
+    @Resource
+    private MallBizOrderDao mallBizOrderDao;
+    @Resource
+    private MallBizRefundDao mallBizRefundDao;
+
+    // 中瑞
+    @Value("${rt_mart.entity}")
+    private String rtMartEntity;
+    // 地利
+    @Value("${sam.entity}")
+    private String samEntity;
+
+    // 中瑞园区系统
+    @Value("${rt_mart.card_url}")
+    private String rtMartCardUrl;
+    // 地利园区系统
+    @Value("${sam.card_url}")
+    private String samCardUrl;
+
+    // 中瑞
+    @Value("${rt_mart.pipeline.code}")
+    private String rtMartPipelineCode;
+    // 地利
+    @Value("${sam.pipeline.code}")
+    private String samPipelineCode;
+
+    @Value("${tax.agent.uri}")
+    private String taxSyncUrl;
+
+    @RabbitListener(queues = MallConstants.TAX_REPORT_DELAY_QUEUE)
+    public void receive(Message message) {
+        byte[] packet = message.getBody();
+        try {
+            String body = new String(packet, StandardCharsets.UTF_8);
+            TaxMessage task = JsonUtils.fromJsonString(body, TaxMessage.class);
+            log.info("Consume async delay task message:{}", task.getPaymentId());
+            sendTaxAgentNotify(task);
+        } catch (Exception e) {
+            log.error("Consume async delay task message exception", e);
+        }
+    }
+
+
+    @Override
+    public void sendTaxAgentNotify(TaxMessage taxMessage) {
+        if (ObjectUtil.isEmpty(taxMessage)) {
+            return;
+        }
+        Map<String, Object> infoMap = new HashMap<>();
+        TaxAgentPrepareInfo taxAgentPrepareInfo = preparePaymentInfo(taxMessage, infoMap);
+        if (taxAgentPrepareInfo == null) {
+            return;
+        }
+
+        String entity = getEntity(taxAgentPrepareInfo.channel);
+        String urlPrefix = getUrlPrefix(taxAgentPrepareInfo.channel);
+        String sellerCustomerCode = taxAgentPrepareInfo.sellerCustomerCode;
+        String pipelineCode = getPipelineCode(taxAgentPrepareInfo.channel);
+
+
+        if (taxAgentPrepareInfo.isCardPay) {
+            prepareCardPayInfo(urlPrefix, taxAgentPrepareInfo, infoMap);
+        } else {
+            prepareCustomerInfo(urlPrefix, taxAgentPrepareInfo.firmId, taxAgentPrepareInfo.userCode(), infoMap);
+        }
+        // 买家应收单
+        sendBuyerReceivableMessage(taxAgentPrepareInfo, entity, pipelineCode, infoMap);
+
+        // 处理在线支付相关单据
+        if (!taxAgentPrepareInfo.isCardPay) {
+            // 买家
+            if (ObjectUtil.equal(taxAgentPrepareInfo.type, TaxMessageType.ORDER_PAY.getCode())) {
+                // 收款单
+                sendReceiptMessage(taxAgentPrepareInfo, entity, pipelineCode, infoMap);
+            } else if (ObjectUtil.equal(taxAgentPrepareInfo.type, TaxMessageType.ORDER_REFUND.getCode())) {
+                // 退款单
+                sendRefundMessage(taxAgentPrepareInfo, entity, pipelineCode, infoMap);
+            }
+        }
+        // 卖家应收单
+        sendSellerReceivableMessage(sellerCustomerCode, taxAgentPrepareInfo, entity, pipelineCode, infoMap);
+    }
+
+    private void prepareCardPayInfo(String urlPrefix, TaxAgentPrepareInfo taxAgentPrepareInfo, Map<String, Object> infoMap) {
+        Object cardPayInfo = CardInfoHttpClient.getCardPayInfo(urlPrefix, Collections.singletonList(taxAgentPrepareInfo.accountId));
+        if (cardPayInfo != null && cardPayInfo.getClass().isArray()) {
+            Object[] cardPayInfoArray = (Object[]) cardPayInfo;
+            if (cardPayInfoArray.length > 0 && cardPayInfoArray[0] instanceof Map<?, ?> rawMap) {
+                @SuppressWarnings("unchecked")
+                Map<String, Object> cardPayInfoMap = (Map<String, Object>) rawMap;
+                infoMap.put(CARD_NUMBER, taxAgentPrepareInfo.cardNo);
+                infoMap.put(AREA, cardPayInfoMap.get(AREA));
+                infoMap.put(CUSTOMER_CODE, cardPayInfoMap.get(CUSTOMER_CODE));
+            } else {
+                log.error("cardPayInfo error: {}", cardPayInfo);
+                throw new IllegalArgumentException("Invalid cardPayInfo structure");
+            }
+        }
+    }
+
+    private void prepareCustomerInfo(String urlPrefix, Long firmId, String userCode, Map<String, Object> infoMap) {
+        Map<String, Object> cardCustomerInfo = CardInfoHttpClient.getCardCustomerInfo(urlPrefix, firmId, Long.valueOf(userCode));
+        if (cardCustomerInfo != null && !cardCustomerInfo.isEmpty()) {
+            infoMap.put(CUSTOMER_CODE, cardCustomerInfo.get("code"));
+        } else {
+            log.error("cardCustomerInfo error: {}", cardCustomerInfo);
+            throw new IllegalArgumentException("Invalid cardCustomerInfo structure");
+        }
+    }
+
+    private TaxAgentPrepareInfo preparePaymentInfo(TaxMessage taxMessage, Map<String, Object> infoMap) {
+        Long paymentId = taxMessage.getPaymentId();
+        Integer type = taxMessage.getType();
+
+        // 订单支付
+        if (ObjectUtil.equal(type, TaxMessageType.ORDER_PAY.getCode())) {
+            return preparePaymentInfoForPayment(paymentId, infoMap);
+            // 订单退款
+        } else if (ObjectUtil.equal(type, TaxMessageType.ORDER_REFUND.getCode())) {
+            return preparePaymentInfoForRefund(paymentId, infoMap);
+        }
+        return null;
+    }
+
+    private TaxAgentPrepareInfo preparePaymentInfoForPayment(Long paymentId, Map<String, Object> infoMap) {
+        MallBizPayment payment = mallBizPaymentDao.selectByPrimaryKey(paymentId);
+
+        if (payment == null) {
+            return null;
+        }
+        MallBizOrder order = mallBizOrderDao.selectByPrimaryKey(Long.valueOf(payment.getBizOrderId()));
+
+        if (order == null) {
+            return null;
+        }
+        Map<String, Object> paymentMap = JsonUtils.convertValue(payment, new TypeReference<>() {
+        });
+        infoMap.putAll(paymentMap);
+        Map<String, Object> orderMap = JsonUtils.convertValue(order, new TypeReference<>() {
+        });
+        infoMap.putAll(orderMap);
+        String sellerCustomerCode = order.getShopCode() + "_" + order.getSource();
+
+        return new TaxAgentPrepareInfo(
+                PAYMENT_BUSINESS_CODE,
+                BLACK,
+                TaxAgentActionEnum.OUT_AMOUNT.getCode(),
+                payment.getPayTradeNo(),
+                payment.getPayFee(),
+                payment.getChannelId(),
+                order.getChannel(),
+                order.getUserCode(),
+                order.getFirmId(),
+                payment.getAccountId(),
+                payment.getCardNo(),
+                TaxMessageType.ORDER_PAY.getCode(),
+                ObjectUtil.equal(payment.getChannelId(), ChannelType.DILIPAY.getCode()),
+                sellerCustomerCode
+        );
+    }
+
+    private TaxAgentPrepareInfo preparePaymentInfoForRefund(Long paymentId, Map<String, Object> infoMap) {
+        MallBizRefund refund = mallBizRefundDao.selectByPrimaryKey(paymentId);
+        if (refund == null) {
+            return null;
+        }
+
+        MallBizPayment payment = mallBizPaymentDao.selectByPrimaryKey(refund.getBizPaymentId());
+
+        if (payment == null) {
+            return null;
+        }
+
+        MallBizOrder order = mallBizOrderDao.selectByPrimaryKey(Long.valueOf(payment.getBizOrderId()));
+        if (order == null) {
+            return null;
+        }
+        // 获取退款时间
+        Map<String, Object> refundMap = JsonUtils.convertValue(refund, new TypeReference<>() {
+        });
+        infoMap.putAll(refundMap);
+        // 获取支付方式
+        Map<String, Object> paymentMap = JsonUtils.convertValue(payment, new TypeReference<>() {
+        });
+        infoMap.putAll(paymentMap);
+        // 获取用户
+        Map<String, Object> orderMap = JsonUtils.convertValue(order, new TypeReference<>() {
+        });
+        infoMap.putAll(orderMap);
+        String sellerCustomerCode = order.getShopCode() + "_" + order.getSource();
+
+        return new TaxAgentPrepareInfo(
+                REFUND_BUSINESS_CODE,
+                RED,
+                TaxAgentActionEnum.IN_AMOUNT.getCode(),
+                refund.getRefundTradeNo(),
+                refund.getRefundFee(),
+                payment.getChannelId(),
+                order.getChannel(),
+                order.getUserCode(),
+                order.getFirmId(),
+                payment.getAccountId(),
+                payment.getCardNo(),
+                TaxMessageType.ORDER_REFUND.getCode(),
+                ObjectUtil.equal(payment.getChannelId(), ChannelType.DILIPAY.getCode()),
+                sellerCustomerCode
+        );
+    }
+
+    private String getEntity(String channel) {
+        return ObjectUtil.equal(channel, OrderChannel.RT_MART.code) ? rtMartEntity : samEntity;
+    }
+
+    private String getUrlPrefix(String channel) {
+        return ObjectUtil.equal(channel, OrderChannel.RT_MART.code) ? rtMartCardUrl : samCardUrl;
+    }
+
+
+    private String getPipelineCode(String channel) {
+        return ObjectUtil.equal(channel, OrderChannel.RT_MART.code) ? rtMartPipelineCode : samPipelineCode;
+    }
+
+
+    private void sendBuyerReceivableMessage(TaxAgentPrepareInfo taxAgentPrepareInfo, String entity,
+                                            String pipelineCode, Map<String, Object> infoMap) {
+        // 费用项
+        String chargeItem = taxAgentPrepareInfo.payType + "-" + taxAgentPrepareInfo.action;
+        String chargeItemDept;
+
+        if (taxAgentPrepareInfo.isCardPay) {
+            infoMap.put(ORG, taxAgentPrepareInfo.payType + "-B" + "-" + infoMap.get(AREA));
+            chargeItemDept = taxAgentPrepareInfo.payType + "-" + infoMap.get(AREA);
+            infoMap.put(SALE_DEPT, chargeItemDept);
+        } else {
+            infoMap.put(ORG, taxAgentPrepareInfo.payType + "-B");
+            chargeItemDept = String.valueOf(taxAgentPrepareInfo.payType);
+            infoMap.put(SALE_DEPT, chargeItemDept);
+        }
+        // 客户
+        String customerCode = infoMap.get(CUSTOMER_CODE).toString();
+        sendReceivableMessage(customerCode, infoMap, chargeItem, taxAgentPrepareInfo.amount,
+                taxAgentPrepareInfo.systemDataId, entity, pipelineCode,
+                taxAgentPrepareInfo.businessCode, taxAgentPrepareInfo.quotedQuantity, chargeItemDept);
+    }
+
+    private void sendSellerReceivableMessage(String sellerCustomerCode, TaxAgentPrepareInfo taxAgentPrepareInfo, String entity,
+                                             String pipelineCode, Map<String, Object> infoMap) {
+        String chargeItem = taxAgentPrepareInfo.payType + "-" + taxAgentPrepareInfo.action;
+        infoMap.put(ORG, taxAgentPrepareInfo.payType + "-S");
+        String chargeItemDept = String.valueOf(taxAgentPrepareInfo.payType);
+        infoMap.put(SALE_DEPT, chargeItemDept);
+
+        sendReceivableMessage(sellerCustomerCode, infoMap, chargeItem, taxAgentPrepareInfo.amount,
+                taxAgentPrepareInfo.systemDataId, entity, pipelineCode,
+                taxAgentPrepareInfo.businessCode, taxAgentPrepareInfo.quotedQuantity, chargeItemDept);
+    }
+
+    private void sendReceivableMessage(String customerCode, Map<String, Object> map, String chargeItem,
+                                       Long amount, String systemDataId, String entity,
+                                       String pipelineCode, String businessCode,
+                                       String quotedQuantity, String chargeItemDept) {
+        String documentType = TaxAgentDocumentTypeEnum.AR_RECEIVABLE.documentType();
+        BigDecimal amountYuan = convertToYuan(amount);
+
+        ArrayList<ReceivableItem> items = new ArrayList<>();
+        items.add(ReceivableItem.of(chargeItem, ObjectUtil.isNotEmpty(map.get(CARD_NUMBER)) ? map.get(CARD_NUMBER).toString() : "",
+                quotedQuantity, String.valueOf(amountYuan), chargeItemDept));
+        map.put(RECEIVABLE_ITEM, items);
+        map.put(CUSTOMER_CODE, customerCode);
+
+        TradeTaxMessageBO tradeTaxMessageBO = TradeTaxMessageBO.of(systemDataId, CASHIER, entity, pipelineCode,
+                businessCode, documentType, map);
+
+        HttpClientUtils.postJson(taxSyncUrl, tradeTaxMessageBO, null, "");
+    }
+
+    private void sendReceiptMessage(TaxAgentPrepareInfo taxAgentPrepareInfo, String entity,
+                                    String pipelineCode, Map<String, Object> map) {
+        String documentType = TaxAgentDocumentTypeEnum.AR_RECEIVEBILL.documentType();
+        BigDecimal amountYuan = convertToYuan(taxAgentPrepareInfo.amount);
+
+        ArrayList<ReceiptItem> items = new ArrayList<>();
+        String chargeItem = taxAgentPrepareInfo.payType + "-" + taxAgentPrepareInfo.action;
+        items.add(ReceiptItem.of(chargeItem, String.valueOf(taxAgentPrepareInfo.payType),
+                String.valueOf(amountYuan), taxAgentPrepareInfo.cardNo));
+        map.put(RECEIPT_ITEM, items);
+
+        TradeTaxMessageBO tradeTaxMessageBO = TradeTaxMessageBO.of(taxAgentPrepareInfo.systemDataId, CASHIER, entity, pipelineCode,
+                taxAgentPrepareInfo.businessCode, documentType, map);
+
+        HttpClientUtils.postJson(taxSyncUrl, tradeTaxMessageBO, null, "");
+    }
+
+    private void sendRefundMessage(TaxAgentPrepareInfo taxAgentPrepareInfo, String entity,
+                                   String pipelineCode, Map<String, Object> map) {
+        String documentType = TaxAgentDocumentTypeEnum.AR_REFUNDBILL.documentType();
+        BigDecimal amountYuan = convertToYuan(taxAgentPrepareInfo.amount);
+
+        ArrayList<RefundItem> items = new ArrayList<>();
+        String chargeItem = taxAgentPrepareInfo.payType + "-" + taxAgentPrepareInfo.action;
+        items.add(RefundItem.of(chargeItem, String.valueOf(taxAgentPrepareInfo.payType),
+                String.valueOf(amountYuan), "退款", taxAgentPrepareInfo.cardNo));
+        map.put(REFUND_ITEM, items);
+
+        TradeTaxMessageBO tradeTaxMessageBO = TradeTaxMessageBO.of(taxAgentPrepareInfo.systemDataId, CASHIER, entity, pipelineCode,
+                taxAgentPrepareInfo.businessCode, documentType, map);
+        HttpClientUtils.postJson(taxSyncUrl, tradeTaxMessageBO, null, "");
+    }
+
+    private BigDecimal convertToYuan(Long amount) {
+        return new BigDecimal(amount).divide(new BigDecimal(100), 2, RoundingMode.HALF_UP);
+    }
+
+    private record TaxAgentPrepareInfo(
+            String businessCode,
+            String quotedQuantity,
+            Integer action,
+            String systemDataId,
+            Long amount,
+            Integer payType,
+            String channel,
+            String userCode,
+            Long firmId,
+            Long accountId,
+            String cardNo,
+            Integer type,
+            boolean isCardPay,
+            String sellerCustomerCode
+    ) {
+    }
+}
+package com.diligrp.cashier.mall.service.biz.impl;
+
+import com.diligrp.cashier.mall.dao.MallBizPaymentDao;
+import com.diligrp.cashier.mall.dao.MallBizRefundDao;
+import com.diligrp.cashier.mall.domain.tax.TaxMessage;
+import com.diligrp.cashier.mall.model.MallBizPayment;
+import com.diligrp.cashier.mall.model.MallBizRefund;
+import com.diligrp.cashier.mall.service.biz.TaxAgentNotifyService;
+import com.diligrp.cashier.mall.service.biz.TaxAgentService;
+import com.diligrp.cashier.mall.type.TaxMessageType;
+import jakarta.annotation.Resource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @author lvqi
+ */
+@Service
+public class TaxAgentServiceImpl implements TaxAgentService {
+    @Resource
+    private MallBizPaymentDao mallBizPaymentDao;
+    @Resource
+    private MallBizRefundDao mallBizRefundDao;
+    @Resource
+    private TaxAgentNotifyService taxAgentNotifyService;
+    private static final Logger log = LoggerFactory.getLogger(TaxAgentServiceImpl.class);
+
+    @Override
+    public void initOrder() {
+        for (MallBizPayment mallBizPayment : mallBizPaymentDao.initOrder()) {
+            TaxMessage taxMessage = new TaxMessage();
+            taxMessage.setPaymentId(mallBizPayment.getId());
+            taxMessage.setType(TaxMessageType.ORDER_PAY.getCode());
+            try {
+                taxAgentNotifyService.sendTaxAgentNotify(taxMessage);
+            } catch (Exception e) {
+                log.error("订单{}发送税务代理消息失败", taxMessage.getPaymentId(), e);
+            }
+
+        }
+    }
+
+    @Override
+    public void initRefund() {
+        for (MallBizRefund mallBizRefund : mallBizRefundDao.initRefund()) {
+            TaxMessage taxMessage = new TaxMessage();
+            taxMessage.setPaymentId(mallBizRefund.getId());
+            taxMessage.setType(TaxMessageType.ORDER_REFUND.getCode());
+            try {
+                taxAgentNotifyService.sendTaxAgentNotify(taxMessage);
+            } catch (Exception e) {
+                log.error("退款{}发送税务代理消息失败", taxMessage.getPaymentId(), e);
+            }
+        }
+    }
+
+    @Override
+    public void syncOrder(List<Long> paymentIds, String startTime, String endTime) {
+        if (paymentIds != null && !paymentIds.isEmpty()) {
+            for (Long paymentId : paymentIds) {
+                TaxMessage taxMessage = new TaxMessage();
+                taxMessage.setPaymentId(paymentId);
+                taxMessage.setType(TaxMessageType.ORDER_PAY.getCode());
+                try {
+                    taxAgentNotifyService.sendTaxAgentNotify(taxMessage);
+                } catch (Exception e) {
+                    log.error("订单{}发送税务代理消息失败", taxMessage.getPaymentId(), e);
+                }
+            }
+        } else {
+            for (MallBizPayment mallBizPayment : mallBizPaymentDao.selectByTimes(startTime, endTime)) {
+                TaxMessage taxMessage = new TaxMessage();
+                taxMessage.setPaymentId(mallBizPayment.getId());
+                taxMessage.setType(TaxMessageType.ORDER_PAY.getCode());
+                try {
+                    taxAgentNotifyService.sendTaxAgentNotify(taxMessage);
+                } catch (Exception e) {
+                    log.error("订单{}发送税务代理消息失败", taxMessage.getPaymentId(), e);
+                }
+
+            }
+        }
+
+    }
+
+    @Override
+    public void syncRefund(List<Long> paymentIds, String startTime, String endTime) {
+        if (paymentIds != null && !paymentIds.isEmpty()) {
+            for (Long paymentId : paymentIds) {
+                TaxMessage taxMessage = new TaxMessage();
+                taxMessage.setPaymentId(paymentId);
+                taxMessage.setType(TaxMessageType.ORDER_REFUND.getCode());
+                try {
+                    taxAgentNotifyService.sendTaxAgentNotify(taxMessage);
+                } catch (Exception e) {
+                    log.error("退款{}发送税务代理消息失败", taxMessage.getPaymentId(), e);
+                }
+            }
+        } else {
+            for (MallBizRefund mallBizRefund : mallBizRefundDao.selectByTimes(startTime, endTime)) {
+                TaxMessage taxMessage = new TaxMessage();
+                taxMessage.setPaymentId(mallBizRefund.getId());
+                taxMessage.setType(TaxMessageType.ORDER_REFUND.getCode());
+                try {
+                    taxAgentNotifyService.sendTaxAgentNotify(taxMessage);
+                } catch (Exception e) {
+                    log.error("退款{}发送税务代理消息失败", taxMessage.getPaymentId(), e);
+                }
+
+            }
+        }
+    }
+}
@@ -5,6 +5,7 @@ import com.diligrp.cashier.mall.MallConstants;
 import com.diligrp.cashier.mall.dao.MallBizOrderDao;
 import com.diligrp.cashier.mall.domain.rtmall.co.AuthLoginCO;
 import com.diligrp.cashier.mall.domain.rtmall.vo.UserInfoVO;
+import com.diligrp.cashier.mall.domain.tax.TaxMessage;
 import com.diligrp.cashier.mall.exception.RtMartMallException;
 import com.diligrp.cashier.mall.model.MallBizOrder;
 import com.diligrp.cashier.mall.model.MallBizPayment;
@@ -15,6 +16,7 @@ import com.diligrp.cashier.mall.service.biz.MallBizPaymentService;
 import com.diligrp.cashier.mall.service.biz.MallBizRefundService;
 import com.diligrp.cashier.mall.type.OrderState;
 import com.diligrp.cashier.mall.type.RtMarkErrorCode;
+import com.diligrp.cashier.mall.type.TaxMessageType;
 import com.diligrp.cashier.pipeline.type.PaymentState;
 import com.diligrp.cashier.shared.spi.domain.PaymentResultBO;
 import com.diligrp.cashier.shared.spi.domain.RefundResultBO;
@@ -30,13 +32,10 @@ import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.transaction.annotation.Transactional;
 import java.nio.charset.StandardCharsets;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 import java.util.concurrent.TimeUnit;
 /**
- * @ClassName AbstractChannel.java
  * @author dengwei
  * @version 1.0.0
  * @Description AbstractChannel
@@ -109,6 +108,13 @@ public abstract class AbstractSourceChannel {
         // notify other channel
         payCallBack(event, mallBizPayment);
+        TaxMessage taxMessage = new TaxMessage();
+        taxMessage.setPaymentId(mallBizPayment.getId());
+        taxMessage.setType(TaxMessageType.ORDER_PAY.getCode());
+        Message msg = MessageBuilder.withBody(JsonUtils.toJsonString(taxMessage).getBytes(StandardCharsets.UTF_8))
+                .setHeader("x-delay", MallConstants.WAIT_DELAY_MILLIS)
+                .build();
+        rabbitTemplate.convertAndSend(MallConstants.TAX_REPORT_DELAY_EXCHANGE, MallConstants.TAX_REPORT_DELAY_KEY, msg);
     }
     /**
@@ -137,6 +143,13 @@ public abstract class AbstractSourceChannel {
         // notify other channel
         refundCallBack(event, mallBizRefund);
+        TaxMessage taxMessage = new TaxMessage();
+        taxMessage.setPaymentId(mallBizRefund.getId());
+        taxMessage.setType(TaxMessageType.ORDER_REFUND.getCode());
+        Message msg = MessageBuilder.withBody(JsonUtils.toJsonString(taxMessage).getBytes(StandardCharsets.UTF_8))
+                .setHeader("x-delay", MallConstants.WAIT_DELAY_MILLIS)
+                .build();
+        rabbitTemplate.convertAndSend(MallConstants.TAX_REPORT_DELAY_EXCHANGE, MallConstants.TAX_REPORT_DELAY_KEY, msg);
     }
     /**
+package com.diligrp.cashier.mall.type;
+
+/**
+ * @author lvqi
+ */
+public enum TaxAgentActionEnum {
+
+    IN_AMOUNT(1, "订单金额(入)"),
+    OUT_AMOUNT(2, "订单金额(出)");
+
+    private final Integer code;
+
+    private final String name;
+
+    TaxAgentActionEnum(Integer code, String name) {
+        this.code = code;
+        this.name = name;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public String getName() {
+        return name;
+    }
+}
+package com.diligrp.cashier.mall.type;
+
+/**
+ * @author lvqi
+ */
+public enum TaxAgentDocumentTypeEnum {
+
+    /**
+     * 应收
+     */
+    AR_RECEIVABLE("AR_receivable"),
+    /**
+     * 收款
+     */
+    AR_RECEIVEBILL("AR_RECEIVEBILL"),
+    /**
+     * 退款
+     */
+    AR_REFUNDBILL("AR_REFUNDBILL");
+
+    private final String documentType;
+
+    public String documentType() {
+        return documentType;
+    }
+
+    TaxAgentDocumentTypeEnum(String documentType) {
+        this.documentType = documentType;
+    }
+}
+package com.diligrp.cashier.mall.type;
+
+/**
+ * @author lvqi
+ */
+
+public enum TaxMessageType {
+    ORDER_PAY(1, "订单支付"),
+    ORDER_REFUND(2, "订单退款");
+
+    private final Integer code;
+
+    private final String name;
+
+    TaxMessageType(Integer code, String name) {
+        this.code = code;
+        this.name = name;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public String getName() {
+        return name;
+    }
+}
@@ -318,5 +318,22 @@
         where order_id = #{orderId,jdbcType=VARCHAR}
         and trade_id = #{tradeId,jdbcType=VARCHAR}
     </select>
+    <select id="initOrder" resultType="com.diligrp.cashier.mall.model.MallBizPayment">
+        select
+        <include refid="Base_Column_List"/>
+        from mall_biz_payment where pay_state=4
+    </select>
+    <select id="selectByTimes" resultType="com.diligrp.cashier.mall.model.MallBizPayment">
+        select
+        <include refid="Base_Column_List"/>
+        from mall_biz_payment
+        where pay_state=4
+        <if test="startTime != null and startTime != ''">
+            and pay_time &gt;= #{startTime}
+        </if>
+        <if test="endTime != null and endTime != ''">
+            and pay_time &lt;= #{endTime}
+        </if>
+    </select>
 </mapper>
@@ -349,4 +349,20 @@
         where biz_order_id = #{bizOrderId}
         and refund_state = 4
     </select>
+  <select id="initRefund" resultType="com.diligrp.cashier.mall.model.MallBizRefund">
+    select
+    <include refid="Base_Column_List"/>
+    from mall_biz_refund where refund_state=4
+  </select>
+  <select id="selectByTimes" resultType="com.diligrp.cashier.mall.model.MallBizRefund">
+    select
+    <include refid="Base_Column_List"/>
+    from mall_biz_refund where refund_state=4
+    <if test="startTime != null and startTime != ''">
+      and refund_time &gt;= #{startTime}
+    </if>
+    <if test="endTime != null and endTime != ''">
+      and refund_time &lt;= #{endTime}
+    </if>
+  </select>
 </mapper>