feats

pom.xml

@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>com.njyunzhi</groupId>
 	<artifactId>pet_identity</artifactId>
-	<version>0.0.7</version>
+	<version>0.0.8</version>
 	<name>pet_identity</name>
 	<description>Demo project for Spring Boot</description>
 

src/main/java/com/njyunzhi/pet_identity/common/DateUtils.java

@@ -57,4 +57,34 @@ public class DateUtils {
 
         return toString(LocalDateTime.now(ZoneId.of("Asia/Shanghai")), formater);
     }
+
+    public static int getDayNum(int year, int month) {
+        int days = 0;
+        if (month != 2) {
+            switch (month) {
+                case 1:
+                case 3:
+                case 5:
+                case 7:
+                case 8:
+                case 10:
+                case 12:
+                    days = 31;
+                    break;
+                case 4:
+                case 6:
+                case 9:
+                case 11:
+                    days = 30;
+
+            }
+        } else {
+            // 闰年
+            if (year % 4 == 0 && year % 100 != 0 || year % 400 == 0)
+                days = 29;
+            else
+                days = 28;
+        }
+        return days;
+    }
 }

src/main/java/com/njyunzhi/pet_identity/common/WxPayUtils.java

@@ -1,7 +1,11 @@
 package com.njyunzhi.pet_identity.common;
 
+import com.github.binarywang.wxpay.bean.request.WxPayApplyTradeBillV3Request;
+import com.github.binarywang.wxpay.bean.request.WxPayDownloadBillRequest;
 import com.github.binarywang.wxpay.bean.request.WxPayRefundV3Request;
 import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderV3Request;
+import com.github.binarywang.wxpay.bean.result.WxPayApplyBillV3Result;
+import com.github.binarywang.wxpay.bean.result.WxPayBillResult;
 import com.github.binarywang.wxpay.bean.result.WxPayRefundV3Result;
 import com.github.binarywang.wxpay.bean.result.WxPayUnifiedOrderV3Result;
 import com.github.binarywang.wxpay.bean.result.enums.TradeTypeEnum;
@@ -12,6 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
+import java.io.InputStream;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
 
@@ -65,4 +70,12 @@ public class WxPayUtils {
         return result;
     }
 
+    public InputStream download(String date) throws Exception {
+        WxPayService payService = wxUtils.getPayService();
+        WxPayApplyTradeBillV3Request request = new WxPayApplyTradeBillV3Request();
+        request.setBillDate(date);
+        request.setBillType("ALL");
+        WxPayApplyBillV3Result wxPayApplyBillV3Result = payService.applyTradeBill(request);
+        return payService.downloadV3(wxPayApplyBillV3Result.getDownloadUrl());
+    }
 }

src/main/java/com/njyunzhi/pet_identity/common/excelConverter/WxStringConverter.java

@@ -0,0 +1,25 @@
+package com.njyunzhi.pet_identity.common.excelConverter;
+
+import com.alibaba.excel.converters.Converter;
+import com.alibaba.excel.converters.ReadConverterContext;
+import com.alibaba.excel.enums.CellDataTypeEnum;
+
+public class WxStringConverter implements Converter<String> {
+    @Override
+    public Class supportJavaTypeKey() {
+        return String.class;
+    }
+
+    @Override
+    public CellDataTypeEnum supportExcelTypeKey() {
+        return CellDataTypeEnum.STRING;
+    }
+
+    @Override
+    public String convertToJavaData(ReadConverterContext<?> context) throws Exception {
+        String val = context.getReadCellData().getStringValue();
+        if (null == val) return null;
+        return val.replaceFirst("^`", "");
+    }
+
+}

src/main/java/com/njyunzhi/pet_identity/controller/TaAccountLogController.java

@@ -0,0 +1,113 @@
+package com.njyunzhi.pet_identity.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.njyunzhi.pet_identity.common.BaseController;
+import com.njyunzhi.pet_identity.common.Constants;
+import com.njyunzhi.pet_identity.common.ResponseBean;
+import com.njyunzhi.pet_identity.common.StringUtils;
+import com.njyunzhi.pet_identity.entity.SysUser;
+import com.njyunzhi.pet_identity.entity.TaAccountLog;
+import com.njyunzhi.pet_identity.entity.TaAccountMonthly;
+import com.njyunzhi.pet_identity.service.ITaAccountLogService;
+import com.njyunzhi.pet_identity.service.ITaAccountMonthlyService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.LocalDateTime;
+
+@Api(tags = "账户流水")
+@RestController
+@RequestMapping("/admin")
+public class TaAccountLogController extends BaseController {
+
+    @Autowired
+    ITaAccountLogService iTaAccountLogService;
+
+    @Autowired
+    ITaAccountMonthlyService iTaAccountMonthlyService;
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/account-log",method= RequestMethod.GET)
+    @ApiOperation(value="账户流水", notes = "账户流水", httpMethod = "GET", response = ResponseBean.class)
+    public ResponseBean getDailyList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                    @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                    @ApiParam("日期") @RequestParam(value ="dailyId", required = false) String dailyId,
+                                     @ApiParam("月份") @RequestParam(value ="monthId", required = false) String monthId,
+                                    @ApiParam("订单号") @RequestParam(value ="orderNo", required = false) String orderNo) throws Exception{
+
+        IPage<TaAccountLog> pg = new Page<>(pageNum, pageSize);
+        QueryWrapper<TaAccountLog> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq(!StringUtils.isEmpty(dailyId), "daily_id", dailyId);
+        queryWrapper.like(!StringUtils.isEmpty(orderNo), "order_no", "%" + orderNo + "%");
+        queryWrapper.like(!StringUtils.isEmpty(monthId), "daily_id", monthId + "%");
+        queryWrapper.orderByDesc("daily_id");
+        queryWrapper.orderByDesc("create_date");
+
+        IPage<TaAccountLog> result = iTaAccountLogService.page(pg, queryWrapper);
+        return ResponseBean.success(result);
+    }
+
+    @RequestMapping(value="/account-log",method= RequestMethod.POST)
+    @ApiOperation(value="对账", notes = "对账", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean newReconciliation(@ApiParam("日期") @RequestParam(value ="dailyId") String dailyId) throws Exception {
+        iTaAccountLogService.reconciliation(dailyId);
+        return ResponseBean.success("ok");
+    }
+
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/account-log/month",method= RequestMethod.GET)
+    @ApiOperation(value="月度账户流水", notes = "月度账户流水", httpMethod = "GET", response = ResponseBean.class)
+    public ResponseBean getMonthList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                     @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                     @ApiParam("月份") @RequestParam(value ="monthId", required = false) String monthId) throws Exception{
+
+        IPage<TaAccountMonthly> pg = new Page<>(pageNum, pageSize);
+        QueryWrapper<TaAccountMonthly> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq(!StringUtils.isEmpty(monthId), "month_id", monthId);
+        queryWrapper.orderByDesc("month_id");
+        queryWrapper.orderByDesc("create_date");
+
+        IPage<TaAccountMonthly> result = iTaAccountMonthlyService.page(pg, queryWrapper);
+        return ResponseBean.success(result);
+    }
+
+    @RequestMapping(value="/account-log/month",method= RequestMethod.POST)
+    @ApiOperation(value="月度账单生成", notes = "月度账单生成", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean newReconciliationMonth(@ApiParam("月份") @RequestParam(value ="monthId") String monthId) throws Exception {
+        iTaAccountLogService.reconcileMonthly(monthId, true);
+        return ResponseBean.success("ok");
+    }
+
+    @RequestMapping(value="/account-log/month",method= RequestMethod.PUT)
+    @ApiOperation(value="月度账单对账", notes = "月度账单对账", httpMethod = "PUT", response = ResponseBean.class)
+    public ResponseBean monthlyUpdate(@ApiParam("月份") @RequestBody TaAccountMonthly taAccountMonthly) throws Exception {
+        TaAccountMonthly accountMonthly = iTaAccountMonthlyService.getById(taAccountMonthly.getMonthId());
+        if (null == accountMonthly) {
+            return ResponseBean.error("未找到对账月度信息");
+        }
+
+        accountMonthly.setStatus(taAccountMonthly.getStatus());
+        if (Constants.STATUS_NORMAL == taAccountMonthly.getStatus()) {
+            accountMonthly.setReconcileDate(LocalDateTime.now());
+        }
+
+        iTaAccountMonthlyService.updateById(accountMonthly);
+        return ResponseBean.success("ok");
+    }
+}

src/main/java/com/njyunzhi/pet_identity/entity/TaAccountLog.java

@@ -0,0 +1,49 @@
+package com.njyunzhi.pet_identity.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="TaAccountLog对象", description="账户流水")
+public class TaAccountLog implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "流水ID")
+    @TableId(value = "serial_no", type = IdType.AUTO)
+    private Integer serialNo;
+
+    @ApiModelProperty(value = "日期ID")
+    private String dailyId;
+
+    @ApiModelProperty(value = "订单ID")
+    private String orderId;
+
+    @ApiModelProperty(value = "订单号")
+    private String orderNo;
+
+    @ApiModelProperty(value = "总金额;单位分")
+    private Integer charges;
+
+    @ApiModelProperty(value = "手续费;单位分")
+    private Integer poundage;
+
+    @ApiModelProperty(value = "支付类型;1收入,-1支出")
+    private Integer chargeType;
+
+    @ApiModelProperty(value = "状态;0未对账,1对账")
+    private Integer status;
+
+    @ApiModelProperty(value = "创建日期")
+    private LocalDateTime createDate;
+}

src/main/java/com/njyunzhi/pet_identity/entity/TaAccountMonthly.java

@@ -0,0 +1,37 @@
+package com.njyunzhi.pet_identity.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="TaAccountMonthly对象", description="账户月结")
+public class TaAccountMonthly implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "月度ID")
+    @TableId(value = "month_id", type = IdType.INPUT)
+    private String monthId;
+
+    @ApiModelProperty(value = "总金额;单位分")
+    private Integer totalCharge;
+
+    @ApiModelProperty(value = "状态;0未对账,1对账")
+    private Integer status;
+
+    @ApiModelProperty(value = "创建日期")
+    private LocalDateTime createDate;
+
+    @ApiModelProperty(value = "对账日期")
+    private LocalDateTime reconcileDate;
+}

src/main/java/com/njyunzhi/pet_identity/entity/TaWxBillList.java

@@ -0,0 +1,133 @@
+package com.njyunzhi.pet_identity.entity;
+
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.njyunzhi.pet_identity.common.excelConverter.WxStringConverter;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@ApiModel(value="TaWxBillList对象", description="微信账单")
+@ExcelIgnoreUnannotated
+public class TaWxBillList {
+
+    @ApiModelProperty(value = "交易时间")
+    @ExcelProperty(index = 0, converter = WxStringConverter.class)
+    private String tradeTime;
+
+    @ApiModelProperty(value = "公众账号ID")
+    @ExcelProperty(index = 1, converter = WxStringConverter.class)
+    private String appId;
+
+    @ApiModelProperty(value = "商户号")
+    @ExcelProperty(index = 2, converter = WxStringConverter.class)
+    private String mchId;
+
+    @ApiModelProperty(value = "特约商户号")
+    @ExcelProperty(index = 3, converter = WxStringConverter.class)
+    private String subMchId;
+
+    @ApiModelProperty(value = "设备号")
+    @ExcelProperty(index = 4, converter = WxStringConverter.class)
+    private String deviceInfo;
+
+    @ApiModelProperty(value = "微信订单号")
+    @TableId(value = "transaction_id", type = IdType.INPUT)
+    @ExcelProperty(index = 5, converter = WxStringConverter.class)
+    private String transactionId;
+
+    @ApiModelProperty(value = "商户订单号")
+    @ExcelProperty(index = 6, converter = WxStringConverter.class)
+    private String outTradeNo;
+
+    @ApiModelProperty(value = "用户标识")
+    @ExcelProperty(index = 7, converter = WxStringConverter.class)
+    private String openId;
+
+    @ApiModelProperty(value = "交易类型")
+    @ExcelProperty(index = 8, converter = WxStringConverter.class)
+    private String tradeType;
+
+    @ApiModelProperty(value = "交易状态")
+    @ExcelProperty(index = 9, converter = WxStringConverter.class)
+    private String tradeState;
+
+    @ApiModelProperty(value = "付款银行")
+    @ExcelProperty(index = 10, converter = WxStringConverter.class)
+    private String bankType;
+
+    @ApiModelProperty(value = "货币种类")
+    @ExcelProperty(index = 11, converter = WxStringConverter.class)
+    private String feeType;
+
+    @ApiModelProperty(value = "应结订单金额")
+    @ExcelProperty(index = 12, converter = WxStringConverter.class)
+    private String totalFee;
+
+    @ApiModelProperty(value = "代金券金额")
+    @ExcelProperty(index = 13, converter = WxStringConverter.class)
+    private String couponFee;
+
+    @ApiModelProperty(value = "微信退款单号")
+    @ExcelProperty(index = 14, converter = WxStringConverter.class)
+    private String refundId;
+
+    @ApiModelProperty(value = "商户退款单号")
+    @ExcelProperty(index = 15, converter = WxStringConverter.class)
+    private String outRefundNo;
+
+    @ApiModelProperty(value = "退款金额")
+    @ExcelProperty(index = 16, converter = WxStringConverter.class)
+    private String settlementRefundFee;
+
+    @ApiModelProperty(value = "充值券退款金额")
+    @ExcelProperty(index = 17, converter = WxStringConverter.class)
+    private String couponRefundFee;
+
+    @ApiModelProperty(value = "退款类型")
+    @ExcelProperty(index = 18, converter = WxStringConverter.class)
+    private String refundChannel;
+
+    @ApiModelProperty(value = "退款状态")
+    @ExcelProperty(index = 19, converter = WxStringConverter.class)
+    private String refundState;
+
+    @ApiModelProperty(value = "商品名称")
+    @ExcelProperty(index = 20, converter = WxStringConverter.class)
+    private String body;
+
+    @ApiModelProperty(value = "商户数据包")
+    @ExcelProperty(index = 21, converter = WxStringConverter.class)
+    private String attach;
+
+    @ApiModelProperty(value = "手续费")
+    @ExcelProperty(index = 22, converter = WxStringConverter.class)
+    private String poundage;
+
+    @ApiModelProperty(value = "费率")
+    @ExcelProperty(index = 23, converter = WxStringConverter.class)
+    private String poundageRate;
+
+    @ApiModelProperty(value = "订单金额")
+    @ExcelProperty(index = 24, converter = WxStringConverter.class)
+    private String totalAmount;
+
+    @ApiModelProperty(value = "申请退款金额")
+    @ExcelProperty(index = 25, converter = WxStringConverter.class)
+    private String appliedRefundAmount;
+
+    @ApiModelProperty(value = "费率备注")
+    @ExcelProperty(index = 26, converter = WxStringConverter.class)
+    private String feeRemark;
+
+//    @ExcelProperty(index = 27)
+//    private String refundTime;
+//
+//    @ExcelProperty(index = 28)
+//    private String refundSuccessTime;
+}

src/main/java/com/njyunzhi/pet_identity/job/Reconciliation.java

@@ -0,0 +1,47 @@
+package com.njyunzhi.pet_identity.job;
+
+import com.njyunzhi.pet_identity.common.DateUtils;
+import com.njyunzhi.pet_identity.common.WxPayUtils;
+import com.njyunzhi.pet_identity.service.ITaAccountLogService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+
+import java.time.LocalDateTime;
+
+/**
+ * 对账
+ */
+@Configuration
+@EnableScheduling
+public class Reconciliation {
+    @Autowired
+    ITaAccountLogService iTaAccountLogService;
+
+    /**
+     * 微信对账, 官方建议在每天的 10 点之后
+     */
+    @Scheduled(cron = "0 0 11 * * ?")
+    public void daily() {
+        try {
+            String yestoday = DateUtils.toString(LocalDateTime.now().minusDays(1), "yyyy-MM-dd");
+            iTaAccountLogService.reconciliation(yestoday);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 月度对账, 每月2号14点
+     */
+    @Scheduled(cron = "0 0 14 2 * ?")
+    public void monthly() {
+        try {
+            String lastMonth = DateUtils.toString(LocalDateTime.now().minusMonths(1), "yyyy-MM");
+            iTaAccountLogService.reconcileMonthly(lastMonth, false);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}

src/main/java/com/njyunzhi/pet_identity/mapper/TaAccountLogMapper.java

@@ -0,0 +1,24 @@
+package com.njyunzhi.pet_identity.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njyunzhi.pet_identity.entity.TaAccountLog;
+import com.njyunzhi.pet_identity.entity.TaAccountMonthly;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+/**
+ * <p>
+ * 账户流水 Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-05-24
+ */
+@Mapper
+public interface TaAccountLogMapper extends BaseMapper<TaAccountLog> {
+
+    int countNumMonth(@Param("monthStr") String monthStr);
+
+    int accTotalCharge(@Param("monthStr") String monthStr);
+}

src/main/java/com/njyunzhi/pet_identity/mapper/TaAccountMonthlyMapper.java

@@ -0,0 +1,17 @@
+package com.njyunzhi.pet_identity.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njyunzhi.pet_identity.entity.TaAccountMonthly;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 账户月结 Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-05-24
+ */
+@Mapper
+public interface TaAccountMonthlyMapper  extends BaseMapper<TaAccountMonthly> {
+}

src/main/java/com/njyunzhi/pet_identity/mapper/TaWxBillListMapper.java

@@ -0,0 +1,17 @@
+package com.njyunzhi.pet_identity.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njyunzhi.pet_identity.entity.TaWxBillList;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 微信账单 Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-05-24
+ */
+@Mapper
+public interface TaWxBillListMapper extends BaseMapper<TaWxBillList> {
+}

src/main/java/com/njyunzhi/pet_identity/service/ITaAccountLogService.java

@@ -0,0 +1,9 @@
+package com.njyunzhi.pet_identity.service;
+
+import com.njyunzhi.pet_identity.entity.TaAccountLog;
+
+public interface ITaAccountLogService extends IBaseService<TaAccountLog> {
+    void reconciliation(String dayStr) throws Exception;
+
+    void reconcileMonthly(String monthStr, boolean force) throws Exception;
+}

src/main/java/com/njyunzhi/pet_identity/service/ITaAccountMonthlyService.java

@@ -0,0 +1,14 @@
+package com.njyunzhi.pet_identity.service;
+
+import com.njyunzhi.pet_identity.entity.TaAccountMonthly;
+
+/**
+ * <p>
+ * 账户月结 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-05-24
+ */
+public interface ITaAccountMonthlyService extends IBaseService<TaAccountMonthly> {
+}

src/main/java/com/njyunzhi/pet_identity/service/impl/TaAccountLogServiceImpl.java

@@ -0,0 +1,158 @@
+package com.njyunzhi.pet_identity.service.impl;
+
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.excel.read.listener.PageReadListener;
+import com.alibaba.excel.support.ExcelTypeEnum;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.github.binarywang.wxpay.bean.result.WxPayBillInfo;
+import com.github.binarywang.wxpay.bean.result.WxPayBillResult;
+import com.njyunzhi.pet_identity.common.Constants;
+import com.njyunzhi.pet_identity.common.DateUtils;
+import com.njyunzhi.pet_identity.common.WxPayUtils;
+import com.njyunzhi.pet_identity.entity.TaAccountLog;
+import com.njyunzhi.pet_identity.entity.TaAccountMonthly;
+import com.njyunzhi.pet_identity.entity.TaWxBillList;
+import com.njyunzhi.pet_identity.mapper.TaAccountLogMapper;
+import com.njyunzhi.pet_identity.mapper.TaAccountMonthlyMapper;
+import com.njyunzhi.pet_identity.mapper.TaWxBillListMapper;
+import com.njyunzhi.pet_identity.service.ITaAccountLogService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.io.InputStream;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 账户流水 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-05-24
+ */
+@Service
+public class TaAccountLogServiceImpl extends BaseServiceImpl<TaAccountLogMapper, TaAccountLog> implements ITaAccountLogService {
+
+    @Autowired
+    TaWxBillListMapper taWxBillListMapper;
+
+    @Autowired
+    TaAccountMonthlyMapper taAccountMonthlyMapper;
+
+    @Autowired
+    WxPayUtils wxPayUtils;
+
+    @Value("${weixin.pay.appId}")
+    String payAppId;
+
+    @Override
+    public void reconciliation(String dayStr) throws Exception {
+        InputStream inputStream = wxPayUtils.download(dayStr);
+
+        // 先删除原始数据
+        deleteLogByDailyId(dayStr);
+
+        EasyExcel.read(inputStream, TaWxBillList.class, new PageReadListener<TaWxBillList>(dataList -> {
+            if (null != dataList) {
+                int len = 0;
+                for (TaWxBillList billInfo : dataList) {
+                    // 只记录当前 APPID 的
+                    String appid = billInfo.getAppId();
+                    if (!payAppId.equals(appid)) continue;
+                    // 如果读到汇总区, 则代表读完了
+                    if ("应结订单总金额".equals(appid)) break;
+
+                    // 先删除原始数据
+                    taWxBillListMapper.deleteById(billInfo.getTransactionId());
+                    // 再插入
+                    taWxBillListMapper.insert(billInfo);
+
+                    TaAccountLog taAccountLog = new TaAccountLog();
+                    taAccountLog.setDailyId(dayStr);
+                    taAccountLog.setOrderNo(billInfo.getOutTradeNo());
+
+                    // 交易类型
+                    int chargeType = "REFUND".equals(billInfo.getTradeState()) ? -1 : 1;
+                    taAccountLog.setChargeType(chargeType);
+                    // 订单费用
+                    int charges = (int) (getDouble(billInfo.getTotalAmount()) * 100);
+                    // 手续费 , 微信手续费有正负, 所以不需要依据交易类型特殊处理
+                    int poundage = (int) (getDouble(billInfo.getPoundage()) * 100);
+                    // 退款金额
+                    int appliedRefundAmount = (int) (getDouble(billInfo.getAppliedRefundAmount()) * 100);
+                    // 如果是退款
+                    if (chargeType == -1) {
+                        charges = -appliedRefundAmount;
+                    }
+                    taAccountLog.setCharges(charges);
+                    taAccountLog.setPoundage(poundage);
+                    //
+                    taAccountLog.setCreateDate(DateUtils.from(billInfo.getTradeTime(), "yyyy-MM-dd HH:mm:ss"));
+
+                    save(taAccountLog);
+
+                    // 记录处理条数
+                    len++;
+                }
+
+                if (len == 0) {
+                    // 如果当月没有明细, 插入一条 0 记录
+                    TaAccountLog taAccountLog = new TaAccountLog();
+                    taAccountLog.setDailyId(dayStr);
+                    taAccountLog.setChargeType(1);
+                    taAccountLog.setCharges(0);
+                    taAccountLog.setPoundage(0);
+                    save(taAccountLog);
+                }
+            }
+        })).excelType(ExcelTypeEnum.CSV).sheet().headRowNumber(1).doRead();
+    }
+
+    @Override
+    public void reconcileMonthly(String monthStr, boolean force) throws Exception {
+        if (!force) {
+            if (!checkBillNum(monthStr)) {
+                throw new Exception("对账明细不全");
+            }
+        }
+
+        // 先删除原来的
+        TaAccountMonthly origin = taAccountMonthlyMapper.selectById(monthStr);
+        if (null != origin) {
+            if (Constants.STATUS_NORMAL == origin.getStatus()) {
+                throw new Exception(monthStr + " 已经核对过账目");
+            }
+
+            taAccountMonthlyMapper.deleteById(monthStr);
+        }
+
+        int totalCharge = baseMapper.accTotalCharge(monthStr);
+        TaAccountMonthly accountMonthly = new TaAccountMonthly();
+        accountMonthly.setMonthId(monthStr);
+        accountMonthly.setTotalCharge(totalCharge);
+        accountMonthly.setStatus(Constants.STATUS_READY);
+        accountMonthly.setCreateDate(LocalDateTime.now());
+        taAccountMonthlyMapper.insert(accountMonthly);
+    }
+
+    private boolean checkBillNum(String monthStr) {
+        String[] parts = monthStr.split("-");
+        int days = DateUtils.getDayNum(Integer.parseInt(parts[0]), Integer.parseInt(parts[1]));
+        int cnt = baseMapper.countNumMonth(monthStr);
+
+        return days == cnt;
+    }
+
+    private double getDouble(String item) {
+        if (null == item) return 0.0;
+
+        return Double.parseDouble(item);
+    }
+
+    private boolean deleteLogByDailyId(String date) {
+        QueryWrapper<TaAccountLog> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("daily_id", date);
+        return remove(queryWrapper);
+    }
+}

src/main/java/com/njyunzhi/pet_identity/service/impl/TaAccountMonthlyServiceImpl.java

@@ -0,0 +1,19 @@
+package com.njyunzhi.pet_identity.service.impl;
+
+
+import com.njyunzhi.pet_identity.entity.TaAccountMonthly;
+import com.njyunzhi.pet_identity.mapper.TaAccountMonthlyMapper;
+import com.njyunzhi.pet_identity.service.ITaAccountMonthlyService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 账户月结 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-05-24
+ */
+@Service
+public class TaAccountMonthlyServiceImpl extends BaseServiceImpl<TaAccountMonthlyMapper, TaAccountMonthly> implements ITaAccountMonthlyService {
+}

src/main/resources/mapper/TaAccountLogMapper.xml

@@ -0,0 +1,29 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njyunzhi.pet_identity.mapper.TaAccountLogMapper">
+
+    <select id="countNumMonth" resultType="java.lang.Integer">
+        SELECT
+            count( 1 )
+        FROM
+            (
+                SELECT
+                    t.daily_id,
+                    max( t.charges )
+                FROM
+                    ta_account_log t
+                WHERE
+                    t.daily_id LIKE CONCAT( #{monthStr}, '%' )
+                GROUP BY
+                    t.daily_id
+            ) s
+    </select>
+    <select id="accTotalCharge" resultType="java.lang.Integer">
+        SELECT
+            SUM( t.charges - t.poundage )
+        FROM
+            ta_account_log t
+        WHERE
+            t.daily_id LIKE CONCAT( #{monthStr}, '%' )
+    </select>
+</mapper>

src/main/resources/mapper/TaAccountMonthlyMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njyunzhi.pet_identity.mapper.TaAccountMonthlyMapper">
+
+</mapper>

src/main/resources/mapper/TaWxBillListMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njyunzhi.pet_identity.mapper.TaWxBillListMapper">
+
+</mapper>