|
|
@@ -18,10 +18,12 @@ import com.cyksj.model.request.DistributeApplyMoneyReq;
|
|
|
import com.cyksj.model.request.UserDistributeReq;
|
|
|
import com.cyksj.model.views.DistributeMoneyApplyView;
|
|
|
import com.cyksj.model.views.MoneyApplyView;
|
|
|
+import com.cyksj.model.views.UserDistributeView;
|
|
|
import com.cyksj.model.views.UserDistributeViews;
|
|
|
import com.cyksj.service.distribute.DistributeService;
|
|
|
import com.ejlchina.searcher.BeanSearcher;
|
|
|
import com.ejlchina.searcher.SearchResult;
|
|
|
+import com.ejlchina.searcher.param.Operator;
|
|
|
import com.ejlchina.searcher.util.MapUtils;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
@@ -87,6 +89,17 @@ public class DistributeController {
|
|
|
return GatewayResponse.SUCCESS.newBuilder().toResult("编辑成功");
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 固定推广者详情
|
|
|
+ */
|
|
|
+ @GetMapping("/get/detail/{id}")
|
|
|
+ public Result<List<UserDistributeView>> getDetailById(@PathVariable Long id) {
|
|
|
+ return GatewayResponse.SUCCESS.newBuilder().toResult(beanSearcher.searchAll(UserDistributeView.class, MapUtils.builder()
|
|
|
+ .field(UserDistributeView::getDistribute_id, id).op(Operator.Equal)
|
|
|
+ .orderBy(UserDistributeView::getGoodsId).asc()
|
|
|
+ .build()));
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 固定推广者列表
|
|
|
*/
|
|
|
@@ -94,10 +107,10 @@ public class DistributeController {
|
|
|
public SearchResult<UserDistributeViews> distributeList(HttpServletRequest request) {
|
|
|
SearchResult<UserDistributeViews> search = beanSearcher.search(UserDistributeViews.class, MapUtils.flatBuilder(request.getParameterMap()).build());
|
|
|
DistributePointsExchangeMoney pointsMoneyRate = distributePointsExchangeMoneyMapper.selectOne(null);
|
|
|
- Optional.ofNullable(search.getDataList()).ifPresent(list->list.forEach(view->{
|
|
|
+ Optional.ofNullable(search.getDataList()).ifPresent(list -> list.forEach(view -> {
|
|
|
Integer num = view.getPoints() / pointsMoneyRate.getPoints();
|
|
|
view.setAvailableMoney(pointsMoneyRate.getMoney().multiply(new BigDecimal(num)));
|
|
|
- List<DistributeMoneyApply> moneyApplies = distributeMoneyApplyMapper.selectList(Wrappers.lambdaQuery(DistributeMoneyApply.class).eq(DistributeMoneyApply::getVerifyStatus, DistributeMoneyApply.Status.Success).eq(DistributeMoneyApply::getUserId, view.getUserId()).select(DistributeMoneyApply::getMoney));
|
|
|
+ List<DistributeMoneyApply> moneyApplies = distributeMoneyApplyMapper.selectList(Wrappers.lambdaQuery(DistributeMoneyApply.class).eq(DistributeMoneyApply::getVerifyStatus, DistributeMoneyApply.Status.success).eq(DistributeMoneyApply::getUserId, view.getUserId()).select(DistributeMoneyApply::getMoney));
|
|
|
Optional<BigDecimal> money = moneyApplies.stream().map(apply -> apply.getMoney()).reduce(BigDecimal::add);
|
|
|
view.setGotMoney(money.isPresent() ? money.get() : BigDecimal.ZERO);
|
|
|
Integer orders = userDistributeMapper.count(view.getUserId());
|
|
|
@@ -111,7 +124,7 @@ public class DistributeController {
|
|
|
*/
|
|
|
@GetMapping("/get/plat")
|
|
|
public Result<List<GoodsDon>> getGoodsDistributeRate() {
|
|
|
- return GatewayResponse.SUCCESS.newBuilder().toResult(goodsDonMapper.selectList(Wrappers.lambdaQuery(GoodsDon.class).eq(GoodsDon::getType, 1).select(GoodsDon::getId, GoodsDon::getTitle, GoodsDon::getRate)));
|
|
|
+ return GatewayResponse.SUCCESS.newBuilder().toResult(goodsDonMapper.selectList(Wrappers.lambdaQuery(GoodsDon.class).eq(GoodsDon::getType, 1).orderByAsc(GoodsDon::getId).select(GoodsDon::getId, GoodsDon::getTitle, GoodsDon::getRate)));
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
@@ -120,7 +133,7 @@ public class DistributeController {
|
|
|
@PutMapping("/put/goods/rate")
|
|
|
public Result<String> editGoodsDistributeRate(@RequestBody UserDistributeReq userDistributeReq) {
|
|
|
for (UserPlatDistributeRate rate : userDistributeReq.getRates()) {
|
|
|
- if (rate.getRate() <0 || rate.getRate() > 100) {
|
|
|
+ if (rate.getRate() < 0 || rate.getRate() > 100) {
|
|
|
throw new BusinessRuntimeException("比例错误");
|
|
|
}
|
|
|
GoodsDon goodsDon = goodsDonMapper.selectById(rate.getGoodsId());
|
|
|
@@ -141,7 +154,7 @@ public class DistributeController {
|
|
|
MoneyApplyView moneyApplyView = new MoneyApplyView();
|
|
|
SearchResult<DistributeMoneyApplyView> search = beanSearcher.search(DistributeMoneyApplyView.class, MapUtils.flatBuilder(request.getParameterMap()).build());
|
|
|
moneyApplyView.setDetails(search.getDataList());
|
|
|
- List<DistributeMoneyApply> distributeMoneyApplies = distributeMoneyApplyMapper.selectList(Wrappers.lambdaQuery(DistributeMoneyApply.class).eq(DistributeMoneyApply::getVerifyStatus, DistributeMoneyApply.Status.Success).select(DistributeMoneyApply::getMoney));
|
|
|
+ List<DistributeMoneyApply> distributeMoneyApplies = distributeMoneyApplyMapper.selectList(Wrappers.lambdaQuery(DistributeMoneyApply.class).eq(DistributeMoneyApply::getVerifyStatus, DistributeMoneyApply.Status.success).select(DistributeMoneyApply::getMoney));
|
|
|
Optional<BigDecimal> reduce = distributeMoneyApplies.stream().map(DistributeMoneyApply::getMoney).reduce(BigDecimal::add);
|
|
|
moneyApplyView.setGotMoney(reduce.isPresent() ? reduce.get() : BigDecimal.ZERO);
|
|
|
return GatewayResponse.SUCCESS.newBuilder().toResult(moneyApplyView);
|
|
|
@@ -153,18 +166,18 @@ public class DistributeController {
|
|
|
@PutMapping("/verify/applyMoney")
|
|
|
public Result<String> verifyApplyMoney(@RequestBody @NotNull DistributeApplyMoneyReq distributeApplyMoneyReq) {
|
|
|
DistributeMoneyApply.Status status = DistributeMoneyApply.Status.checkStatus(distributeApplyMoneyReq.getVerifyStatus());
|
|
|
- if (status == null) {
|
|
|
+ if (status == null || status == DistributeMoneyApply.Status.verifying) {
|
|
|
throw BusinessRuntimeException.getInstance("审核状态错误");
|
|
|
}
|
|
|
DistributeMoneyApply distributeMoneyApply = distributeMoneyApplyMapper.selectById(distributeApplyMoneyReq.getId());
|
|
|
if (distributeMoneyApply == null) {
|
|
|
throw BusinessRuntimeException.getInstance("提现记录不存在");
|
|
|
}
|
|
|
- if (distributeMoneyApply.getVerifyStatus() != DistributeMoneyApply.Status.Verifying) {
|
|
|
+ if (distributeMoneyApply.getVerifyStatus() != DistributeMoneyApply.Status.verifying) {
|
|
|
throw BusinessRuntimeException.getInstance("该提现记录已处理,无法再进行审核");
|
|
|
}
|
|
|
distributeMoneyApply.setVerifyStatus(status);
|
|
|
- if (DistributeMoneyApply.Status.Fail.name().equals(distributeApplyMoneyReq.getVerifyStatus()) && StrUtil.isEmpty(distributeApplyMoneyReq.getReason())) {
|
|
|
+ if (DistributeMoneyApply.Status.fail.name().equals(distributeApplyMoneyReq.getVerifyStatus()) && StrUtil.isEmpty(distributeApplyMoneyReq.getReason())) {
|
|
|
throw BusinessRuntimeException.getInstance("拒绝原因为空");
|
|
|
}
|
|
|
distributeMoneyApplyMapper.updateById(distributeMoneyApply);
|