cxc/yshopb2c
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

提现失败佣金判断

Browse Source
This commit is contained in:
taozi
2022-02-26 16:00:31 +08:00
parent a03bdd91d6
commit c0eee46be9
2 changed files with 27 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
yshop-mall/src/main/java/co/yixiang/modules/activity/service/impl/YxUserExtractServiceImpl.java
View File

@ -31,10 +31,7 @@ import co.yixiang.modules.activity.service.mapper.YxUserExtractMapper;
import co.yixiang.modules.user.domain.YxUser; import co.yixiang.modules.user.domain.YxUser;
import co.yixiang.modules.user.service.YxUserBillService; import co.yixiang.modules.user.service.YxUserBillService;
import co.yixiang.modules.user.service.YxUserService; import co.yixiang.modules.user.service.YxUserService;
import co.yixiang.modules.user.service.dto.WechatUserDto;
import co.yixiang.modules.user.service.dto.YxWechatUserDto;
import co.yixiang.utils.FileUtil; import co.yixiang.utils.FileUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import org.springframework.context.ApplicationEventPublisher; import org.springframework.context.ApplicationEventPublisher;
@ -219,19 +216,23 @@ public class YxUserExtractServiceImpl extends BaseServiceImpl<YxUserExtractMappe
if(StrUtil.isEmpty(resources.getFailMsg())){ if(StrUtil.isEmpty(resources.getFailMsg())){
throw new BadRequestException("请填写失败原因"); throw new BadRequestException("请填写失败原因");
} }
String mark = "提现失败,退回佣金"+resources.getExtractPrice()+"元"; //防止无限添加佣金
YxUser yxUser = userService.getById(resources.getUid()); if (ObjectUtil.isNull(userExtract.getFailTime())) {
String mark = "提现失败,退回佣金"+resources.getExtractPrice()+"元";
YxUser yxUser = userService.getById(resources.getUid());
double balance = NumberUtil.add(yxUser.getBrokeragePrice(),resources.getExtractPrice()).doubleValue(); double balance = NumberUtil.add(yxUser.getBrokeragePrice(),resources.getExtractPrice()).doubleValue();
//插入流水 //插入流水
billService.income(resources.getUid(),"提现失败", BillDetailEnum.CATEGORY_1.getValue(), billService.income(resources.getUid(),"提现失败", BillDetailEnum.CATEGORY_1.getValue(),
BillDetailEnum.TYPE_4.getValue(),resources.getExtractPrice().doubleValue(),balance, BillDetailEnum.TYPE_4.getValue(),resources.getExtractPrice().doubleValue(),balance,
mark,resources.getId().toString()); mark,resources.getId().toString());
//返回提现金额 //返回提现金额
userService.incBrokeragePrice(resources.getExtractPrice(),resources.getUid()); userService.incBrokeragePrice(resources.getExtractPrice(),resources.getUid());
resources.setFailTime(new Date());
}
resources.setFailTime(new Date());
}else{ }else{
//模板消息支付成功发布事件 //模板消息支付成功发布事件
TemplateBean templateBean = TemplateBean.builder() TemplateBean templateBean = TemplateBean.builder()

22
yshop-weixin/src/main/java/co/yixiang/modules/mp/listener/TemplateListener.java
View File

@ -143,15 +143,19 @@ public class TemplateListener implements SmartApplicationListener {
} }
} }
if (!success) { if (!success) {
String mark = "提现失败,退回佣金" + resources.getExtractPrice() + "元"; //防止无限添加佣金
double balance = NumberUtil.add(user.getBrokeragePrice(), resources.getExtractPrice()).doubleValue(); if (ObjectUtil.isNull(resources.getFailTime())) {
//插入流水 String mark = "提现失败,退回佣金" + resources.getExtractPrice() + "元";
billService.income(resources.getUid(), "提现失败", BillDetailEnum.CATEGORY_1.getValue(), double balance = NumberUtil.add(user.getBrokeragePrice(), resources.getExtractPrice()).doubleValue();
BillDetailEnum.TYPE_4.getValue(), resources.getExtractPrice().doubleValue(), balance, //插入流水
mark, resources.getId().toString()); billService.income(resources.getUid(), "提现失败", BillDetailEnum.CATEGORY_1.getValue(),
//返回提现金额 BillDetailEnum.TYPE_4.getValue(), resources.getExtractPrice().doubleValue(), balance,
userService.incBrokeragePrice(resources.getExtractPrice(), resources.getUid()); mark, resources.getId().toString());
resources.setFailTime(new Date()); //返回提现金额
userService.incBrokeragePrice(resources.getExtractPrice(), resources.getUid());
resources.setFailMsg("提现失败");
resources.setFailTime(new Date());
}
yxUserExtractService.updateById(resources); yxUserExtractService.updateById(resources);
} }