package cc.mrbird.febs.mall.service.impl;
|
|
import cc.mrbird.febs.common.entity.FebsResponse;
|
import cc.mrbird.febs.common.entity.QueryRequest;
|
import cc.mrbird.febs.common.enumerates.OrderStatusEnum;
|
import cc.mrbird.febs.common.utils.LoginUserUtil;
|
import cc.mrbird.febs.common.utils.RedisUtils;
|
import cc.mrbird.febs.mall.dto.AdminMallInvoiceDto;
|
import cc.mrbird.febs.mall.dto.ApiMallInvoiceDto;
|
import cc.mrbird.febs.mall.entity.MallInvoice;
|
import cc.mrbird.febs.mall.entity.MallMember;
|
import cc.mrbird.febs.mall.entity.MallOrderInfo;
|
import cc.mrbird.febs.mall.entity.MallOrderItem;
|
import cc.mrbird.febs.mall.mapper.MallInvoiceMapper;
|
import cc.mrbird.febs.mall.mapper.MallOrderInfoMapper;
|
import cc.mrbird.febs.mall.mapper.MallOrderItemMapper;
|
import cc.mrbird.febs.mall.service.MallInvoiceService;
|
import cc.mrbird.febs.mall.vo.AdminMallOrderInfoVo;
|
import cc.mrbird.febs.mall.vo.ApiMallInvoiceVo;
|
import cc.mrbird.febs.pay.service.WxFaPiaoService;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.json.JSONObject;
|
import cn.hutool.json.JSONUtil;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.io.IOException;
|
import java.util.List;
|
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class MallInvoiceServiceImpl extends ServiceImpl<MallInvoiceMapper, MallInvoice> implements MallInvoiceService {
|
|
private final MallOrderInfoMapper mallOrderInfoMapper;
|
private final MallOrderItemMapper mallOrderItemMapper;
|
private final RedisUtils redisUtils;
|
private final WxFaPiaoService wxFaPiaoService;
|
@Override
|
public FebsResponse getInvoices(ApiMallInvoiceDto apiMallInvoiceDto) {
|
MallMember member = LoginUserUtil.getLoginUser();
|
apiMallInvoiceDto.setMemberId(member.getId());
|
IPage<ApiMallInvoiceVo> page = new Page<>(apiMallInvoiceDto.getPageNum(), apiMallInvoiceDto.getPageSize());
|
IPage<ApiMallInvoiceVo> apiMallInvoiceVoIPage = this.baseMapper.selectApiMallInvoiceVoInPage(page, apiMallInvoiceDto);
|
return new FebsResponse().success().data(apiMallInvoiceVoIPage);
|
}
|
|
@Override
|
public void mallInvoiceJob() {
|
/**
|
* 获取当前已经是已完成且未开过发票的订单
|
*/
|
List<MallOrderInfo> mallOrderInfos = mallOrderInfoMapper.selectOrderInfoByStatusAndIsInvoice(OrderStatusEnum.FINISH.getValue(), 0);
|
if(CollUtil.isEmpty(mallOrderInfos)){
|
return;
|
}
|
for(MallOrderInfo mallOrderInfo : mallOrderInfos){
|
/**
|
* 生成开票记录
|
*/
|
Long memberId = mallOrderInfo.getMemberId();
|
/**
|
* fapiao_apply_id
|
* 发票申请单号，唯一标识一次开票行为。微信支付场景下，为微信支付订单号；非微信支付场景下，为调用【获取抬头填写链接】接口时指定的发票申请单号
|
* 对应订单信息的pay_order_no支付订单号
|
*/
|
String payOrderNo = mallOrderInfo.getPayOrderNo();
|
List<MallInvoice> mallInvoices = this.baseMapper.selectByFapiaoApplyIdAndMemberId(payOrderNo, memberId);
|
if(CollUtil.isNotEmpty(mallInvoices)){
|
MallInvoice mallInvoice = mallInvoices.get(0);
|
mallInvoice.setStatus(mallOrderInfo.getStatus());
|
this.baseMapper.updateById(mallInvoice);
|
}else{
|
MallInvoice mallInvoice = new MallInvoice();
|
mallInvoice.setMemberId(memberId);
|
mallInvoice.setFapiaoApplyId(payOrderNo);
|
mallInvoice.setOrderNo(mallOrderInfo.getOrderNo());
|
mallInvoice.setOrderId(mallOrderInfo.getId());
|
mallInvoice.setStatus(mallOrderInfo.getStatus());
|
mallInvoice.setAmount(mallOrderInfo.getAmount());
|
List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(mallOrderInfo.getId());
|
mallInvoice.setGoodsImg(mallOrderItemList.get(0).getSkuImage());
|
mallInvoice.setState(0);
|
this.baseMapper.insert(mallInvoice);
|
}
|
|
/**
|
* 更新订单为已开票
|
*/
|
mallOrderInfo.setIsInvoice(1);
|
mallOrderInfoMapper.updateById(mallOrderInfo);
|
}
|
|
}
|
|
@Override
|
public IPage<MallInvoice> getInvoiceList(AdminMallInvoiceDto mallInvoiceDto, QueryRequest request) {
|
Page<MallInvoice> page = new Page<>(request.getPageNum(), request.getPageSize());
|
return this.baseMapper.getInvoiceListInPage(page, mallInvoiceDto);
|
}
|
|
@Override
|
public List<MallOrderItem> invoiceItemList() {
|
Long existToken = Long.parseLong(redisUtils.getString("ADMIN_INVOICE_ID"));
|
MallInvoice mallInvoice = this.baseMapper.selectById(existToken);
|
if(ObjectUtil.isEmpty(mallInvoice)){
|
return null;
|
}
|
return this.baseMapper.getInvoiceItemList(mallInvoice);
|
}
|
|
@Override
|
@Transactional
|
public FebsResponse addInvoiceUrl(MallInvoice mallInvoice) {
|
Long id = mallInvoice.getId();
|
MallInvoice mallInvoiceOld = this.baseMapper.selectById(id);
|
if(ObjectUtil.isEmpty(mallInvoiceOld)){
|
return new FebsResponse().fail().message("开票信息异常。");
|
}
|
Integer status = mallInvoiceOld.getStatus();
|
if(OrderStatusEnum.FINISH.getValue() != status){
|
return new FebsResponse().fail().message("订单还未完成，请勿开发票。");
|
}
|
mallInvoiceOld.setInvoiceUrl(mallInvoice.getInvoiceUrl());
|
mallInvoiceOld.setState(2);
|
this.baseMapper.updateById(mallInvoiceOld);
|
return new FebsResponse().success();
|
}
|
|
@Override
|
@Transactional
|
public FebsResponse updateInvoiceDetail(Long id) {
|
MallInvoice mallInvoice = this.baseMapper.selectById(id);
|
if(ObjectUtil.isEmpty(mallInvoice)){
|
return new FebsResponse().fail().message("开票信息异常。");
|
}
|
String fapiaoApplyId = mallInvoice.getFapiaoApplyId();
|
try {
|
String userInvoiceInfo = wxFaPiaoService.getUserInvoiceInfo(fapiaoApplyId);
|
JSONObject userInvoiceInfoJson = JSONUtil.parseObj(userInvoiceInfo);
|
mallInvoice.setType(userInvoiceInfoJson.getStr("type"));
|
mallInvoice.setName(userInvoiceInfoJson.getStr("name"));
|
mallInvoice.setTaxpayerId(userInvoiceInfoJson.getStr("taxpayer_id"));
|
mallInvoice.setAddress(userInvoiceInfoJson.getStr("address"));
|
mallInvoice.setTelephone(userInvoiceInfoJson.getStr("telephone"));
|
mallInvoice.setBankName(userInvoiceInfoJson.getStr("bank_name"));
|
mallInvoice.setBankAccount(userInvoiceInfoJson.getStr("bank_account"));
|
this.baseMapper.updateById(mallInvoice);
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return new FebsResponse().success();
|
}
|
|
@Override
|
@Transactional
|
public FebsResponse updateOrderDetail(Long id) {
|
MallInvoice mallInvoice = this.baseMapper.selectById(id);
|
|
if(ObjectUtil.isEmpty(mallInvoice.getFapiaoApplyId())){
|
return new FebsResponse().fail().message("订单的支付方式不是微信支付。");
|
}
|
String fapiaoApplyId = mallInvoice.getFapiaoApplyId();
|
MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectBypayOrderNo(fapiaoApplyId);
|
if(OrderStatusEnum.FINISH.getValue() != mallOrderInfo.getStatus()){
|
return new FebsResponse().fail().message("当前订单还未完成。");
|
}
|
/**
|
* fapiao_apply_id
|
* 发票申请单号，唯一标识一次开票行为。微信支付场景下，为微信支付订单号；非微信支付场景下，为调用【获取抬头填写链接】接口时指定的发票申请单号
|
* 对应订单信息的pay_order_no支付订单号
|
*/
|
mallInvoice.setStatus(mallOrderInfo.getStatus());
|
this.baseMapper.updateById(mallInvoice);
|
/**
|
* 更新订单为已开票
|
*/
|
mallOrderInfo.setIsInvoice(1);
|
mallOrderInfoMapper.updateById(mallOrderInfo);
|
return new FebsResponse().success();
|
}
|
}
|
