package com.xzx.gc.order.controller;
|
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.NumberUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.xzx.gc.common.Result;
|
import com.xzx.gc.common.constant.CommonEnum;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.constant.OrderEnum;
|
import com.xzx.gc.common.constant.UserEnum;
|
import com.xzx.gc.common.dto.CommonDto;
|
import com.xzx.gc.common.dto.log.OperationAppLog;
|
import com.xzx.gc.common.request.BaseController;
|
import com.xzx.gc.common.utils.DateUtils;
|
import com.xzx.gc.common.utils.MqUtil;
|
import com.xzx.gc.entity.*;
|
import com.xzx.gc.model.JsonResult;
|
import com.xzx.gc.model.admin.XzxUserRedpaperInfoModel;
|
import com.xzx.gc.model.order.RedPaperDto;
|
import com.xzx.gc.order.mapper.ConfigMapper;
|
import com.xzx.gc.order.mapper.OrderDetailMapper;
|
import com.xzx.gc.order.mapper.OrderMapper;
|
import com.xzx.gc.order.service.*;
|
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 lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
import tk.mybatis.mapper.entity.Example;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.math.BigDecimal;
|
import java.util.*;
|
|
@Api(tags = "红包管理")
|
@RequestMapping
|
@RestController
|
@Slf4j
|
@Validated
|
public class RedPaperController extends BaseController {
|
|
@Autowired
|
SessionUtil sessionUtil;
|
|
|
@Autowired
|
private CityPartnerService cityPartnerService;
|
|
@Autowired
|
private RedPaperService redPaperService;
|
|
@Autowired
|
private RedPaperRuleService redPaperRuleService;
|
|
@Autowired
|
private OrderMapper orderMapper;
|
|
@Autowired
|
private OrderService orderService;
|
|
@Autowired
|
private ConfigMapper configMapper;
|
|
@Autowired
|
private OrderDetailMapper orderDetailMapper;
|
|
@Autowired
|
private OrderItemService orderItemService;
|
|
@Autowired
|
private OtherUserService otherUserService;
|
|
@Autowired
|
private UserService userService;
|
|
@Autowired
|
private PartnerGaodeService partnerGaodeService;
|
|
@Autowired
|
private SysEnvironmentalInfoService sysEnvironmentalInfoService;
|
|
@Autowired
|
private MqUtil mqUtil;
|
|
|
|
@ApiOperation( value = "查询当前用户是否有可领红包")
|
@PostMapping("/redpaper/find")
|
public Result<RedPaperDto> find(HttpServletRequest request) {
|
String partnerId = partnerGaodeService.findPartnerIdByUserId(getUserId(request), 0);
|
RedPaperRule one = redPaperRuleService.getOne(UserEnum.红包规则.getValue(),partnerId);
|
String userId=getUserId(request);
|
if(one==null){
|
return Result.error(-3,"当前时间段无红包活动");
|
}else{
|
UserInfo byId = userService.findById(userId);
|
if(byId!=null){
|
String mobilePhone = byId.getMobilePhone();
|
List<OtherUserInfo> byMobile = otherUserService.findByMobile(mobilePhone);
|
if(CollUtil.isNotEmpty(byMobile)) {
|
return Result.error(-3,"平台用户不参与活动");
|
}
|
}
|
String conversionPerUnit = one.getConversionPerUnit();
|
String sharingProfitType = one.getSharingProfitType();
|
String text="";
|
if(StrUtil.isNotBlank(sharingProfitType)){
|
ConfigInfo configInfo=new ConfigInfo();
|
configInfo.setConfigTypeCode("REDPAPER_TEXT");
|
ConfigInfo configInfo1 = configMapper.selectOne(configInfo);
|
if(configInfo1!=null){
|
text=configInfo1.getConfigValueName();
|
}
|
}
|
|
RedPaper redPaper = redPaperService.getOne(one.getId());
|
if(redPaper==null){
|
return Result.error(-3,"红包已被领完");
|
}
|
//查询用户是否已领取过红包
|
boolean b = redPaperService.checkIsReceive(userId, one.getId());
|
if(b) {
|
return Result.error(-3,"您已领取过红包");
|
}
|
|
RedPaperDto redPaperDto=new RedPaperDto();
|
redPaperDto.setText(text);
|
redPaperDto.setRuleId(one.getId());
|
redPaperDto.setIssuanceRules(one.getIssuanceRules());
|
redPaperDto.setRandomAmountAverage(one.getRandomAmountAverage());
|
String applicableObject = one.getApplicableObject();
|
if(UserEnum.全部用户.getValue().equals(applicableObject)){
|
redPaperDto.setDesignatedUser(1);
|
return Result.success(redPaperDto);
|
}else if(UserEnum.指定用户.getValue().equals(applicableObject)){
|
String designatedUser = one.getDesignatedUser();
|
if(UserEnum.首次下单用户.getValue().equals(designatedUser)){
|
int i=orderService.findByCreateTime(userId,Constants.ONLINE_REBATE_TIME,0);
|
int i2=orderService.findByCreateTime(userId,Constants.ONLINE_REBATE_TIME,1);
|
if(i==1&&i2==0){
|
redPaperDto.setDesignatedUser(2);
|
return Result.success(redPaperDto);
|
}
|
}else if(UserEnum.非首次下单用户.getValue().equals(designatedUser)){
|
//满足红包的下单重量
|
String designatedWeight = one.getDesignatedWeight();
|
Example example = new Example(OrderInfo.class);
|
Example.Criteria criteria = example.createCriteria();
|
criteria.andEqualTo("createUserId", userId);
|
List<String> list = new ArrayList<>();
|
list.add(OrderEnum.待入库.getValue());
|
list.add(OrderEnum.入库中.getValue());
|
list.add(OrderEnum.完成.getValue());
|
criteria.andIn("orderStatus", list);
|
//订单数必须大于1
|
List<OrderInfo> list1 = orderMapper.selectByExample(example);
|
List<OrderDetailInfo> list2 = new ArrayList<>();
|
if(CollUtil.isNotEmpty(list1)&&list1.size()>1){
|
|
for (OrderInfo orderInfo : list1) {
|
OrderDetailInfo orderDetailInfo = orderDetailMapper.selectByPrimaryKey(orderInfo.getOrderId());
|
if (orderDetailInfo != null) {
|
Date startTime = DateUtil.parse(one.getStartTime(), DateUtils.DATE_FORMAT_YMD);
|
Date endTime = DateUtil.parse(one.getEndTime(), DateUtils.DATE_FORMAT_YMD);
|
//订单完成时间要在规则有效时间之内
|
boolean in = DateUtil.isIn(DateUtil.parse(orderDetailInfo.getCompleteTime(), DateUtils.DATE_FORMAT_YMD), startTime, endTime);
|
if (in) {
|
//家电折算成30kg/每个
|
int amountNum = 0;
|
List<String> childItemTypeByType = sysEnvironmentalInfoService.findChildItemTypeByType(Constants.TIANXIN_CODE, Constants.HOUSE_HOLD_ITEM_TYPE);
|
if(CollUtil.isNotEmpty(childItemTypeByType)){
|
List<OrderItemInfo> houseHold = orderItemService.findByOrderIdAndTypes(orderInfo.getOrderId(), childItemTypeByType);
|
if (CollUtil.isNotEmpty(houseHold)) {
|
for (OrderItemInfo orderItemInfo : houseHold) {
|
String amount = orderItemInfo.getAmount();
|
if (StrUtil.isNotBlank(amount)) {
|
amountNum = amountNum + Convert.toInt(amount, 0);
|
}
|
}
|
}
|
if (StrUtil.isBlank(conversionPerUnit)) {
|
conversionPerUnit = "0";
|
}
|
BigDecimal i = NumberUtil.mul(Convert.toBigDecimal(amountNum), Convert.toBigDecimal(conversionPerUnit));
|
orderDetailInfo.setHouseHoldWeight(Convert.toStr(i));
|
}
|
list2.add(orderDetailInfo);
|
}
|
}
|
}
|
if(CollUtil.isNotEmpty(list2)){
|
Double sum = list2.stream().mapToDouble(x -> Convert.toDouble(x.getWeight(), Convert.toDouble(Constants.WEIGHT_INIT))).sum();
|
Double sumHouse = list2.stream().mapToDouble(x -> Convert.toDouble(x.getHouseHoldWeight(), Convert.toDouble(Constants.WEIGHT_INIT))).sum();
|
sum=NumberUtil.add(sum,sumHouse);
|
if(NumberUtil.compare(sum,Convert.toDouble(designatedWeight))>=0){
|
redPaperDto.setDesignatedUser(3);
|
return Result.success(redPaperDto);
|
}
|
}
|
|
}
|
}
|
}
|
}
|
return Result.error(-3,"无红包可领");
|
}
|
|
|
@ApiOperation( value = "领取红包",notes = "id为查询接口返回的id")
|
@PostMapping("/redpaper")
|
public Result<RedPaper> get(HttpServletRequest request, @RequestBody CommonDto commonDto) {
|
RedPaper redPaper=redPaperService.get(commonDto.getId(),getUserId(request));
|
|
String mobilePhone = userService.findOtherByUserId(getUserId(request),0);
|
OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("领取红包-"+redPaper.getId()).build();
|
mqUtil.sendApp(build);
|
|
return Result.success(redPaper);
|
}
|
|
|
@PostMapping(Constants.ADMIN_VIEW_PREFIX + "/xzxUserRedpaperInfo/redPaperList.do")
|
@ResponseBody
|
@ApiOperation(value="红包记录-红包列表", notes="test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType="query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "receiveFlag", value = "红包领取状态0：已领取 1未领取", required = true, dataType = "Integer")
|
})
|
public JsonResult<Map<String,Object>> redPaperList(@RequestBody XzxUserRedpaperInfoModel model)
|
{
|
Map<String,Object> map =redPaperService.redPaperList(model);
|
return JsonResult.success(map);
|
}
|
@PostMapping(Constants.ADMIN_VIEW_PREFIX + "/xzxUserRedpaperInfo/cancelRedPaper.do")
|
@ResponseBody
|
@ApiOperation(value="红包记录-红包退还", notes="test: 仅0有正确返回")
|
public JsonResult<Map<String,Object>> cancelRedPaper(HttpServletRequest request){
|
CoreUser user = sessionUtil.getCurrentUser();
|
CityPartner partner = cityPartnerService.queryById(user.getId());
|
String msg = redPaperService.cancelRedPaper(partner,"1");
|
if(null!=msg&&!"".equals(msg)){
|
return JsonResult.failMessage(msg);
|
}else{
|
|
Map<String,Object> map=new HashMap<>();
|
map.put("code",0);
|
map.put("msg","退还成功");
|
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("红包退还-"+partner.getId()).build();
|
mqUtil.sendApp(build);
|
|
return JsonResult.success(map);
|
}
|
}
|
}
|
