package com.xzx.gc.order.controller;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.util.StrUtil;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.xzx.gc.common.Result;
|
import com.xzx.gc.common.annotations.PassToken;
|
import com.xzx.gc.common.constant.CommonEnum;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.constant.UserEnum;
|
import com.xzx.gc.common.dto.log.OperationAppLog;
|
import com.xzx.gc.common.exception.RestException;
|
import com.xzx.gc.common.request.BaseController;
|
import com.xzx.gc.common.utils.BusinessUtil;
|
import com.xzx.gc.common.utils.DateUtils;
|
import com.xzx.gc.entity.*;
|
import com.xzx.gc.model.IdDTO;
|
import com.xzx.gc.model.JsonResult;
|
import com.xzx.gc.model.admin.*;
|
import com.xzx.gc.model.order.QueryRuleManageDetailDTO;
|
import com.xzx.gc.model.order.RuleParamDto;
|
import com.xzx.gc.model.order.SettlePageDTO;
|
import com.xzx.gc.model.order.UpdateRoyaltyRuleDTO;
|
import com.xzx.gc.model.query.XzxUserRedpaperRuleQuery;
|
import com.xzx.gc.order.dto.RuleDto;
|
import com.xzx.gc.order.service.*;
|
import com.xzx.gc.util.DateUtil;
|
import com.xzx.gc.util.SessionUtil;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.math.BigDecimal;
|
import java.sql.Struct;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author :zz
|
*/
|
@RestController
|
@Api(tags = {"规则管理"})
|
@Validated
|
public class RuleController extends BaseController {
|
|
@Autowired
|
private RedPaperRuleService redPaperRuleService;
|
|
@Autowired
|
private RedPaperService redPaperService;
|
@Autowired
|
private RuleService ruleService;
|
|
@Autowired
|
SessionUtil sessionUtil;
|
@Autowired
|
CityPartnerService cityPartnerService;
|
|
@Autowired
|
RebateRuleService rebateRuleService;
|
|
@Autowired
|
UserShareService userShareService;
|
|
@Autowired
|
private AddressService addressService;
|
|
@Autowired
|
private PartnerGaodeService partnerGaodeService;
|
|
@Autowired
|
private WeightItemPriceService weightItemPriceService;
|
|
@Autowired
|
private BusinessUtil businessUtil;
|
|
|
|
|
@PostMapping("/rule/findShareRebate")
|
@ApiOperation(value = "查询分享返利的规则", notes = "extra:经纬度逗号拼接")
|
@PassToken
|
public Result<RuleDto> findShareRebate(HttpServletRequest request, @RequestBody RuleParamDto ruleParamDto) {
|
String userId = getUserId(request);
|
|
UserInfo userInfo = null;
|
String partnerId = null;
|
|
if (StrUtil.isBlank(userId)) {
|
if (StrUtil.isBlank(ruleParamDto.getExtra())) {
|
return Result.error(-3, "未发现分享返利规则");
|
}
|
AddressInfo byLon = addressService.getByLon(ruleParamDto.getExtra().split(",")[0], ruleParamDto.getExtra().split(",")[1]);
|
if (byLon != null) {
|
partnerId = partnerGaodeService.findPartnerIdByAddress(byLon);
|
}
|
} else {
|
partnerId = partnerGaodeService.findPartnerIdByUserId(userId, 0);
|
}
|
|
if (partnerId != null) {
|
RedPaperRule one = redPaperRuleService.getOne(UserEnum.分享分利规则.getValue(), partnerId);
|
if (one != null) {
|
RuleDto ruleDto = new RuleDto();
|
ruleDto.setScale(one.getShareRatio());
|
UserInfo userInfo1 = new UserInfo();
|
if (userInfo != null) {
|
userInfo1.setMobilePhone(businessUtil.changeMobile(userInfo.getMobilePhone()));
|
}
|
ruleDto.setUserinfo(userInfo1);
|
return Result.success(ruleDto);
|
}
|
}
|
|
|
return Result.error(-3, "未发现分享返利规则");
|
|
|
}
|
|
@PostMapping("/rule/findStepRebate")
|
@ApiOperation(value = "查询阶梯返利的规则")
|
public Result<RuleDto> findStepRebate(HttpServletRequest request, @RequestBody RuleParamDto ruleParamDto) {
|
String userId = getUserId(request);
|
String partnerId = partnerGaodeService.findPartnerIdByUserId(userId, ruleParamDto.getType());
|
RuleDto ruleDto = ruleService.findStepRebate(userId, false, partnerId);
|
return Result.success(ruleDto);
|
}
|
|
|
@PostMapping("/rule/findWeightRebate")
|
@ApiOperation(value = "查询重量返利的规则")
|
public Result<RuleDto> findWeightRebate(HttpServletRequest request, @RequestBody RuleParamDto ruleParamDto) {
|
RuleDto ruleDto = new RuleDto();
|
String partnerIdByUserId = partnerGaodeService.findPartnerIdByUserId(getUserId(request), ruleParamDto.getType());
|
RedPaperRule one = redPaperRuleService.getOne(UserEnum.重量返利规则.getValue(), partnerIdByUserId);
|
if (one != null) {
|
List<RebateRule> rebateRules = ruleService.getRebateRules(one);
|
ruleDto.setRebateRules(rebateRules);
|
String s = ruleService.changeProductType(one.getProductType());
|
ruleDto.setProductType(s);
|
}
|
return Result.success(ruleDto);
|
}
|
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/redRuleList.json")
|
@ApiOperation(value = "红包记录-红包规则", notes = "test: 仅0有正确返回")
|
public JsonResult<Map<String, Object>> redRuleList(@RequestBody XzxUserRedpaperRuleQuery condtion) {
|
CoreUser user = sessionUtil.getCurrentUser();
|
|
if (StrUtil.isBlank(condtion.getPartnerId())) {
|
CityPartner partner = cityPartnerService.queryById(user.getId());
|
if (null != partner) {
|
condtion.setPartnerId(partner.getId() + "");
|
}
|
}
|
|
Map<String, Object> map = redPaperRuleService.queryByCondition(condtion, condtion.getRuleType());
|
return JsonResult.success(map);
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/add.json")
|
@ApiOperation(value = "红包规则-添加红包规则", notes = "test: 仅0有正确返回")
|
public JsonResult add(@RequestBody XzxUserRedpaperRuleModel model, HttpServletRequest request) {
|
JsonResult jsonResult = redPaperService.addRedPaper(model);
|
if (jsonResult.getCode() == 0) {
|
//根据规则生成红包
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("添加红包规则-" + jsonResult.getData()).build();
|
mqUtil.sendApp(build);
|
}
|
|
return jsonResult;
|
}
|
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/edit.json")
|
@ApiOperation(value = "红包规则-修改红包规则", notes = "test: 仅0有正确返回")
|
public JsonResult<String> update(@RequestBody Map<String, Object> map, HttpServletRequest request) {
|
JsonResult jsonResult = redPaperService.updateRedPaper(map);
|
if (jsonResult.getCode() == 0) {
|
//根据规则生成红包
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("修改红包规则-" + jsonResult.getData()).build();
|
mqUtil.sendApp(build);
|
}
|
|
return jsonResult;
|
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/delete.json")
|
@ApiOperation(value = "红包记录-删除红包规则(分享分利规则)", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "id", value = "规则Id", required = false, dataType = "Integer")
|
})
|
public JsonResult delete(@RequestBody XzxUserRedpaperRuleModel model, HttpServletRequest request) {
|
//先退回再删除
|
CoreUser user = sessionUtil.getCurrentUser();
|
CityPartner partner = cityPartnerService.queryById(user.getId());
|
RedPaperRule rule = redPaperRuleService.queryById(model.getId());
|
if (rule.getRuleType().equals("1")) {
|
String msg = redPaperService.cancelRedPaper1(partner, rule.getRuleType());
|
if (null != msg) {
|
return JsonResult.failMessage(msg);
|
}
|
}
|
|
RedPaperRule ru = redPaperRuleService.queryById(model.getId());
|
//删除原有规则，重新创建规则生成红包
|
ru.setDelFlag((short) 1);
|
boolean success = redPaperRuleService.update(ru);
|
if (rule.getRuleType().equals("1")) {
|
redPaperService.deletePaperByRuleId(ru.getId());
|
|
} else if (rule.getRuleType().equals("3")) {
|
redPaperService.deleteJtRuleId(ru.getId());
|
}
|
if (success) {
|
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("删除红包规则-" + rule.getId()).build();
|
mqUtil.sendApp(build);
|
return new JsonResult().success();
|
} else {
|
return JsonResult.failMessage("删除失败");
|
}
|
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/isStart.json")
|
@ApiOperation(value = "红包记录-规则（是否启用 通用）", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "id", value = "规则Id", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "开关0：关闭，1：正常", required = false, dataType = "Integer")
|
|
})
|
public JsonResult isStart(@RequestBody XzxUserRedpaperRuleModel model, HttpServletRequest request) {
|
JsonResult<Object> objectJsonResult = redPaperService.openRule(model);
|
if (objectJsonResult.getCode() == 0) {
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("规则启用或关闭-" + model.getId()).build();
|
mqUtil.sendApp(build);
|
}
|
return objectJsonResult;
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/queryRebateList.do")
|
@ApiOperation(value = "阶梯返利(查询列表)", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = false, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = false, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "mobilePhone", value = "手机号(昵称)", required = false, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> queryRebateList(@RequestBody XzxPlatformCapitalInfoModel model) {
|
Map<String, Object> map = redPaperRuleService.queryRebateList(model);
|
return JsonResult.success(map);
|
}
|
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/queryShareInfoList.do")
|
@ApiOperation(value = "分享分利", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = false, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = false, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "name", value = "邀请人", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "mobilePhone", value = "邀请人手机号", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "registerName", value = "被邀请人", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "registerMobilePhone", value = "被邀请人手机号", required = false, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> queryShareInfoList(@RequestBody XzxUserShareInfoModel model) {
|
Map<String, Object> map = userShareService.queryShareInfoList(model);
|
return JsonResult.success(map);
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/queryShareOrderList.json")
|
@ApiOperation(value = "分享分利-下单详情", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = false, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = false, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "shareId", value = "邀请人ID", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "invitedUserId", value = "被邀请人ID", required = false, dataType = "String"),
|
})
|
public JsonResult<Map<String, Object>> queryShareOrderList(@RequestBody XzxPlatformCapitalInfoModel model) {
|
Map<String, Object> map = userShareService.queryShareOrderList(model);
|
return JsonResult.success(map);
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/addShareRule.json")
|
@ApiOperation(value = "分享分利-分享分利添加", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "有效开始时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "有效结束时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "开关0：关闭，1：正常", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "sharingProfitType", value = "分享分利规则文案（SHARE_RATIO对应第一个文案，COMMISSION_FOR_INVITEES：第二个，DESIGNATED_USER：第三个，多个用逗号分割）", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "shareRatio", value = "分享利益百分比", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "ruleName", value = "规则名称", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "applicableObject", value = "指定用户1：全部用户，2：指定用户", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "designatedWeight", value = "指定用户规则(回收累计重量)", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "issuanceRules", value = "发放规则（0：金额随机，1：金额固定）", required = false, dataType = "String")
|
})
|
public JsonResult addShareRule(@RequestBody XzxUserRedpaperRuleModel model, HttpServletRequest request) {
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
if (null != partnerIds && partnerIds.size() > 0) {
|
model.setPartnerId(partnerIds.get(0));
|
} else {
|
throw new RestException("非法操作");
|
}
|
|
redPaperService.checkRuleTime(model, UserEnum.分享分利规则.getValue());
|
|
|
RedPaperRule rule = getRedpaperRule(model);
|
rule.setPartnerId(partnerIds.get(0));
|
boolean success = redPaperRuleService.save(rule);
|
if (success) {
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("分享分利添加-" + rule.getId()).build();
|
mqUtil.sendApp(build);
|
return new JsonResult().success();
|
} else {
|
return JsonResult.failMessage("添加失败");
|
}
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/updateShareRule.json")
|
@ApiOperation(value = "分享分利-分享分利修改", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "有效开始时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "有效结束时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "开关0：关闭，1：正常", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "sharingProfitType", value = "分享分利规则文案（SHARE_RATIO对应第一个文案，COMMISSION_FOR_INVITEES：第二个，DESIGNATED_USER：第三个，多个用逗号分割）", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "shareRatio", value = "分享利益百分比", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "ruleName", value = "规则名称", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "applicableObject", value = "指定用户1：全部用户，2：指定用户", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "designatedWeight", value = "指定用户规则(回收累计重量)", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "id", value = "id", required = false, dataType = "String")
|
|
})
|
public JsonResult updateShareRule(@RequestBody XzxUserRedpaperRuleModel model, HttpServletRequest request) {
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
if (null != partnerIds) {
|
model.setPartnerId(partnerIds.get(0));
|
} else {
|
throw new RestException("非法操作");
|
}
|
|
redPaperService.checkRuleTime(model, UserEnum.分享分利规则.getValue());
|
|
RedPaperRule rule = new RedPaperRule();
|
rule = redPaperRuleService.queryById(model.getId());
|
if (rule != null) {
|
rule = getRedpaperRule(model);
|
rule.setId(model.getId());
|
} else {
|
return JsonResult.failMessage("修改失败");
|
}
|
boolean success = redPaperRuleService.update(rule);
|
if (success) {
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("分享分利或重量返利修改-" + rule.getId()).build();
|
mqUtil.sendApp(build);
|
return new JsonResult().success();
|
} else {
|
return JsonResult.failMessage("修改失败");
|
}
|
}
|
|
private RedPaperRule getRedpaperRule(XzxUserRedpaperRuleModel model) {
|
RedPaperRule rule = new RedPaperRule();
|
rule.setId(model.getId());
|
rule.setStartTime(model.getStartTime());
|
rule.setEndTime(model.getEndTime());
|
rule.setRuleName(model.getRuleName());
|
if (model.getId() != null) {
|
rule.setUpdateTime(cn.hutool.core.date.DateUtil.now());
|
} else {
|
rule.setCreateTime(cn.hutool.core.date.DateUtil.now());
|
}
|
rule.setDelFlag((short) 0);
|
if (null != model.getRuleType() && !"".equals(model.getRuleType())) {
|
rule.setRuleType(model.getRuleType());
|
} else {
|
rule.setRuleType("2");
|
}
|
|
rule.setSharingProfitType(model.getSharingProfitType());
|
rule.setShareRatio(model.getShareRatio());
|
rule.setStatus(model.getStatus());
|
rule.setRuleName(model.getRuleName());
|
rule.setApplicableObject(model.getApplicableObject());
|
rule.setDesignatedWeight(model.getDesignatedWeight());
|
rule.setIssuanceRules(model.getIssuanceRules());
|
return rule;
|
|
}
|
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/addWeightRule.json")
|
@ApiOperation(value = "重量返利规则-重量返利规则添加", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "weightRateList", value = "阶梯重量列表（用户返利，合伙人，回收员的返利用逗号隔开）", required = false, dataType = "List<XzxRebateRulePrice>"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "有效开始时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "有效结束时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "开关0：关闭，1：正常", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "productType", value = "适用物品类型（1：废纸，2：杂纸（多选用逗号隔开））", required = false, dataType = "String")
|
|
})
|
public JsonResult addWeightRule(@RequestBody XzxUserRebateRuleModel model, HttpServletRequest request) {
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
if (null != partnerIds && partnerIds.size() > 0) {
|
model.setPartnerId(partnerIds.get(0));
|
} else {
|
throw new RestException("非法操作");
|
}
|
|
|
// List<RedPaperRule> queryList = redPaperRuleService.queryWeightRuleList(model);
|
// if (queryList != null && queryList.size() > 0) {
|
// return JsonResult.failMessage("只能添加一个重量返利规则");
|
// }
|
//查看是否有开启的重量返利
|
// if (model.getStatus() == 1) {
|
// List<RedPaperRule> queryRebateList = redPaperRuleService.queryRebateRuleList(model);
|
// if (queryRebateList != null && queryRebateList.size() > 0) {
|
// return JsonResult.failMessage("阶梯返利规则和重量返利不能同时开启!");
|
// }
|
// }
|
|
XzxUserRedpaperRuleModel model1 = new XzxUserRedpaperRuleModel();
|
BeanUtil.copyProperties(model, model1);
|
redPaperService.checkRuleTime(model1, UserEnum.重量返利规则.getValue());
|
|
try {
|
redPaperService.checkRuleTime(model1, UserEnum.阶梯返利规则.getValue());
|
} catch (RestException e) {
|
return JsonResult.failMessage("阶梯返利规则和重量返利不能同时开启");
|
}
|
|
List<RebateRule> rulePriceList = model.getWeightRateList();
|
List<String> priceList = new ArrayList<>();
|
for (int i = 0; i < rulePriceList.size(); i++) {
|
priceList.add(rulePriceList.get(i).getWeight());
|
}
|
boolean bool = DateUtil.isSorted(priceList, priceList.size());
|
if (!bool) {
|
return JsonResult.failMessage("重量必须按顺序排列");
|
}
|
RedPaperRule rule = new RedPaperRule();
|
rule.setStartTime(model.getStartTime());
|
rule.setEndTime(model.getEndTime());
|
rule.setRuleName("按重量返利规则");
|
rule.setCreateTime(cn.hutool.core.date.DateUtil.now());
|
rule.setDelFlag((short) 0);
|
rule.setRuleType("5");
|
rule.setStatus(model.getStatus());
|
rule.setApplicableObject("1");
|
rule.setProductType(model.getProductType());
|
rule.setPartnerId(model.getPartnerId());
|
redPaperRuleService.save(rule);
|
if (rule.getId() != null) {
|
for (int i = 0; i < rulePriceList.size(); i++) {
|
RebateRule rulePrice = rulePriceList.get(i);
|
rulePrice.setCreateTime(cn.hutool.core.date.DateUtil.now());
|
rulePrice.setRuleId(Long.parseLong(rule.getId() + ""));
|
rulePrice.setSort(String.valueOf(i + 1));
|
rulePrice.setDelFlag((short) 0);
|
rebateRuleService.save(rulePrice);
|
}
|
}
|
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("重量返利规则添加-" + rule.getId()).build();
|
mqUtil.sendApp(build);
|
return new JsonResult().success();
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/addRebateRule.json")
|
@ApiOperation(value = "阶梯返利-阶梯返利添加", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "rulePriceList", value = "阶梯价格列表", required = false, dataType = "List<XzxRebateRulePrice>"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "有效开始时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "有效结束时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "开关0：关闭，1：正常", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "conversionPerUnit", value = "每台家电折算重量", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "conversionPerUnitFlag", value = "每台家电折算重量是否启用（0:不启用，1：启用）", required = false, dataType = "String")
|
|
})
|
public JsonResult addRebateRule(@RequestBody XzxUserRebateRuleModel model, HttpServletRequest request) {
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
if (null != partnerIds && partnerIds.size() > 0) {
|
model.setPartnerId(partnerIds.get(0));
|
} else {
|
throw new RestException("非法操作");
|
}
|
// List<RedPaperRule> queryList = redPaperRuleService.queryRebateRuleList(model);
|
// if (queryList != null && queryList.size() > 0) {
|
// return JsonResult.failMessage("只能添加一个阶梯规则!");
|
// }
|
|
|
//查看是否有开启的重量返利
|
// if (model.getStatus() == 1) {
|
// List<RedPaperRule> queryWeightList = redPaperRuleService.queryWeightRuleList(model);
|
// if (queryWeightList != null && queryWeightList.size() > 0) {
|
// return JsonResult.failMessage("阶梯返利规则和重量返利不能同时开启!");
|
// }
|
// }
|
|
XzxUserRedpaperRuleModel model1 = new XzxUserRedpaperRuleModel();
|
BeanUtil.copyProperties(model, model1);
|
redPaperService.checkRuleTime(model1, UserEnum.阶梯返利规则.getValue());
|
|
|
try {
|
redPaperService.checkRuleTime(model1, UserEnum.重量返利规则.getValue());
|
} catch (RestException e) {
|
return JsonResult.failMessage("阶梯返利规则和重量返利不能同时开启");
|
}
|
|
List<RebateRule> rulePriceList = model.getRulePriceList();
|
List<String> priceList = new ArrayList<>();
|
for (int i = 0; i < rulePriceList.size(); i++) {
|
priceList.add(rulePriceList.get(i).getRate());
|
}
|
boolean bool = DateUtil.isSorted(priceList, priceList.size());
|
if (!bool) {
|
return JsonResult.failMessage("阶梯价格必须按顺序排列");
|
}
|
RedPaperRule rule = new RedPaperRule();
|
rule.setConversionPerUnit(model.getConversionPerUnit());
|
rule.setStartTime(model.getStartTime());
|
rule.setEndTime(model.getEndTime());
|
rule.setRuleName("阶梯价格规则");
|
rule.setCreateTime(cn.hutool.core.date.DateUtil.now());
|
rule.setDelFlag((short) 0);
|
rule.setRuleType("3");
|
rule.setStatus(model.getStatus());
|
rule.setApplicableObject("1");
|
rule.setConversionPerUnitFlag(model.getConversionPerUnitFlag());
|
rule.setPartnerId(model.getPartnerId());
|
rule.setSharingProfitType("REBATE_ONE,REBATE_TWO,REBATE_THREE");
|
redPaperRuleService.save(rule);
|
if (rule.getId() != null) {
|
for (int i = 0; i < rulePriceList.size(); i++) {
|
RebateRule rulePrice = rulePriceList.get(i);
|
rulePrice.setCreateTime(cn.hutool.core.date.DateUtil.now());
|
rulePrice.setRuleId(Long.parseLong(rule.getId() + ""));
|
rulePrice.setSort(String.valueOf(i + 1));
|
rulePrice.setDelFlag((short) 0);
|
rebateRuleService.save(rulePrice);
|
}
|
}
|
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("阶梯返利添加-" + rule.getId()).build();
|
mqUtil.sendApp(build);
|
|
|
return new JsonResult().success();
|
}
|
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/updateRebateRule.json")
|
@ApiOperation(value = "阶梯返利-阶梯返利修改(重量规则修改)", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "ruleName", value = "规则名称", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "rulePriceList", value = "阶梯价格列表", required = false, dataType = "List<XzxRebateRulePrice>"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "有效开始时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "有效结束时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "开关0：关闭，1：正常", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "conversionPerUnit", value = "每台家电折算重量", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "conversionPerUnitFlag", value = "每台家电折算重量是否启用（0:不启用，1：启用）", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "id", value = "规则ID", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "ruleType", value = "规则类型", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "weightRateList", value = "重量规则", required = false, dataType = "String")
|
})
|
public JsonResult updateRebateRule(@RequestBody Map<String, Object> map, HttpServletRequest request) {
|
|
JsonResult jsonResult = redPaperService.updateRebateRule(map);
|
if (jsonResult.getCode() == 0) {
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("阶梯返利修改(重量规则修改)-" + jsonResult.getData()).build();
|
mqUtil.sendApp(build);
|
}
|
return jsonResult;
|
}
|
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/queryWeightOrderList.json")
|
@ApiOperation(value = "重量返利-下单详情", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = false, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = false, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "nickName", value = "用户昵称或手机号", required = false, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> queryWeightOrderList(@RequestBody WeightOrderModel model) {
|
Map<String, Object> map = userShareService.queryWeightOrderList(model);
|
return JsonResult.success(map);
|
}
|
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/addRoyaltyRule.json")
|
@ApiOperation(value = "添加(修改)提成规则", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "royaltyRuleList", value = "提成规则", required = false, dataType = "List<RebateWeightPriceModel>"),
|
@ApiImplicitParam(paramType = "query", name = "packageId", value = "打包员Id", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "ruleName", value = "规则名称", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "productType", value = "3：人工审核,4：自动审核", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "timing", value = "定时执行时间(比如星期一 2点 格式为 1,2)", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "ruleName", value = "规则名称", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "id", value = "规则主键", required = false, dataType = "String")
|
})
|
public JsonResult<Integer> addRoyaltyRule(@RequestBody XzxUserRebateRuleModel model, HttpServletRequest request) {
|
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
if (null != partnerIds && partnerIds.size() > 0) {
|
model.setPartnerId(partnerIds.get(0));
|
} else {
|
throw new RestException("非法操作");
|
}
|
|
|
//时间交叉判断
|
XzxUserRedpaperRuleModel model2 = new XzxUserRedpaperRuleModel();
|
BeanUtil.copyProperties(model, model2);
|
redPaperService.checkRuleTime(model2, UserEnum.提成规则.getValue());
|
|
|
if (StrUtil.isNotBlank(model.getPackageId())) {
|
|
|
JsonResult<Integer> stringJsonResult = weightItemPriceService.addRoyaltyRule(model);
|
if(stringJsonResult.getCode()==0) {
|
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("添加(修改)提成规则-" + stringJsonResult.getData()).build();
|
mqUtil.sendApp(build);
|
}
|
return stringJsonResult;
|
} else {
|
return JsonResult.failMessage("打包站不能为空！");
|
}
|
|
|
}
|
|
|
@PostMapping(Constants.ADMIN_VIEW_PREFIX + "/xzxUserRedpaperRule/queryPackageType.json")
|
@ResponseBody
|
@ApiOperation(value = "查询打包站纸类别", notes = "test: 仅0有正确返回")
|
public JsonResult<Map<String, Object>> queryPackageType(@RequestBody XzxCityPartnerModel model) {
|
String packageId = "";
|
if (null != model) {
|
packageId = model.getId();
|
}
|
|
Map<String, Object> map = userShareService.queryPackageType(packageId);
|
return JsonResult.success(map);
|
}
|
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/addCommissionRule.json")
|
@ApiOperation(value = "提佣规则添加", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "有效开始时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "有效结束时间", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "开关0：关闭，1：正常", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "shareRatio", value = "每笔订单回收流水百分比", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "ruleName", value = "规则名称", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "applicableObject", value = "指定用户1：全部合伙人", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "issuanceRules", value = "3:系统自动提佣", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "ruleType", value = "规则类型：1：红包规则，2：分享分利规则，3：阶梯返利，5重量返利,7:提成规则，8：提佣规则", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "partnerId", value = "合伙人ID", required = false, dataType = "String"),
|
})
|
public JsonResult addCommissionRule(@RequestBody XzxUserRedpaperRuleModel model, HttpServletRequest request) {
|
|
redPaperService.checkRuleTime(model, UserEnum.提佣规则.getValue());
|
|
BigDecimal shareRatio = new BigDecimal(model.getShareRatio());
|
BigDecimal aa = shareRatio.divide(new BigDecimal("100"));
|
model.setShareRatio(aa.toString());
|
RedPaperRule rule = getRedpaperRule(model);
|
rule.setPartnerId(model.getPartnerId());
|
boolean success = redPaperRuleService.save(rule);
|
if (success) {
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("提佣规则添加-" + rule.getId()).build();
|
mqUtil.sendApp(build);
|
return new JsonResult().success();
|
} else {
|
return JsonResult.failMessage("添加失败");
|
}
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/updateCommissionRule.json")
|
@ApiOperation(value = "提佣规则修改", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "id", value = "规则Id", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "有效开始时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "有效结束时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "开关0：关闭，1：正常", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "shareRatio", value = "每笔订单回收流水百分比", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "ruleName", value = "规则名称", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "applicableObject", value = "指定用户1：全部合伙人", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "issuanceRules", value = "3:系统自动提佣", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "ruleType", value = "规则类型：1：红包规则，2：分享分利规则，3：阶梯返利，5重量返利,7:提成规则，8：提佣规则", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "partnerId", value = "合伙人ID", required = false, dataType = "String"),
|
})
|
public JsonResult updateCommissionRule(@RequestBody XzxUserRedpaperRuleModel model, HttpServletRequest request) {
|
//List<RedPaperRule> queryList = redPaperRuleService.queryCommissioList();
|
// List<RedPaperRule> queryList = redPaperRuleService.queryCommListByTime(model.getStartTime(), model.getEndTime(), model.getId() + "");
|
// if (queryList != null && queryList.size() > 0) {
|
// return JsonResult.failMessage("该时间段内不允许修改提佣规则！");
|
// }
|
|
redPaperService.checkRuleTime(model, UserEnum.提佣规则.getValue());
|
|
BigDecimal shareRatio = new BigDecimal(model.getShareRatio());
|
BigDecimal aa = shareRatio.divide(new BigDecimal("100"));
|
model.setShareRatio(aa.toString());
|
RedPaperRule rule = getRedpaperRule(model);
|
rule.setPartnerId(model.getPartnerId());
|
boolean success = redPaperRuleService.update(rule);
|
if (success) {
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("提佣规则修改-" + rule.getId()).build();
|
mqUtil.sendApp(build);
|
return new JsonResult().success();
|
} else {
|
return JsonResult.failMessage("添加失败");
|
}
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/queryAccountList.json")
|
@ApiOperation(value = "提佣规则数据列表", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "条数", required = false, dataType = "Integer"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = false, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "partnerName", value = "城市合伙人姓名/手机号", required = false, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> queryAccountList(@RequestBody CommissionModel model) {
|
|
Map<String, Object> result = redPaperRuleService.queryAccountList(model);
|
return JsonResult.success(result);
|
}
|
|
@PostMapping( "/admin/front/xzxUserRedpaperRule/deleteCommissionRule.json")
|
@ApiOperation(value = "提佣规则删除", notes = "test: 仅0有正确返回")
|
public JsonResult deleteCommissionRule(@RequestBody XzxUserRedpaperRuleModel model, HttpServletRequest request) {
|
RedPaperRule ru = redPaperRuleService.queryById(model.getId());
|
//删除原有规则，重新创建规则生成红包
|
ru.setDelFlag((short) 1);
|
redPaperRuleService.update(ru);
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("提佣规则删除-" + model.getId()).build();
|
mqUtil.sendApp(build);
|
return new JsonResult().success();
|
}
|
|
}
|
