| | |
| | | package com.doumee.service.business.impl; |
| | | |
| | | import com.doumee.core.constants.ResponseStatus; |
| | | import com.doumee.core.exception.BusinessException; |
| | | import com.doumee.core.model.PageData; |
| | | import com.doumee.core.model.PageWrap; |
| | | import com.doumee.core.utils.DateUtil; |
| | | import com.doumee.core.utils.Utils; |
| | | import com.doumee.core.wx.WxMiniConfig; |
| | | import com.doumee.dao.business.WxBillMapper; |
| | | import com.doumee.dao.business.model.WxBill; |
| | | import com.doumee.service.business.WxBillService; |
| | |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.github.binarywang.wxpay.bean.request.WxPayDownloadBillRequest; |
| | | import com.github.binarywang.wxpay.bean.result.WxPayBillInfo; |
| | | import com.github.binarywang.wxpay.bean.result.WxPayBillResult; |
| | | import com.github.binarywang.wxpay.exception.WxPayException; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | /** |
| | |
| | | |
| | | @Autowired |
| | | private WxBillMapper wxBillMapper; |
| | | |
| | | @Override |
| | | public String create(WxBill wxBill) { |
| | | wxBillMapper.insert(wxBill); |
| | |
| | | QueryWrapper<WxBill> wrapper = new QueryWrapper<>(wxBill); |
| | | return wxBillMapper.selectCount(wrapper); |
| | | } |
| | | @Override |
| | | public void getWxBill() { |
| | | try { |
| | | // 获取交易账单数据 |
| | | WxPayDownloadBillRequest request = new WxPayDownloadBillRequest(); |
| | | String billDate = DateUtil.beforeDateToStr(1); |
| | | request.setBillDate(billDate); |
| | | request.setBillType("ALL"); |
| | | WxPayBillResult response = WxMiniConfig.wxPayService.downloadBill(request); |
| | | if(response !=null){ |
| | | List<WxPayBillInfo> detailList = response.getBillInfoList(); |
| | | }else{ |
| | | throw new BusinessException(ResponseStatus.SERVER_ERROR); |
| | | } |
| | | |
| | | } catch (WxPayException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | } |