package com.dsh.guns.modular.system.controller.general;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.dsh.course.feignClient.activity.*;
|
import com.dsh.course.feignClient.activity.model.*;
|
import com.dsh.guns.config.UserExt;
|
import com.dsh.guns.core.base.controller.BaseController;
|
import com.dsh.guns.core.common.constant.factory.PageFactory;
|
import com.dsh.guns.core.log.LogObjectHolder;
|
import com.dsh.guns.core.util.SinataUtil;
|
import com.dsh.guns.modular.system.enums.ActivityTypeEnum;
|
import com.dsh.guns.modular.system.model.*;
|
import com.dsh.guns.modular.system.service.ISysCouponRecordService;
|
import com.dsh.guns.modular.system.service.ISysRedPacketRecordService;
|
import com.dsh.guns.modular.system.service.ITAuditRecordService;
|
import com.dsh.guns.modular.system.util.DateUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.ui.Model;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* 控制器
|
*
|
* @author fengshuonan
|
* @Date 2020-06-19 14:32:29
|
*/
|
@Controller
|
@RequestMapping("/userActivity")
|
public class UserActivityController extends BaseController {
|
|
private String PREFIX = "/system/userActivity/";
|
|
@Autowired
|
private UserActivityClient userActivityClient;
|
|
@Autowired
|
private UserActivityBalanceClient userActivityBalanceClient;
|
|
@Autowired
|
private UserActivityDiscount1Client userActivityDiscount1Client;
|
|
@Autowired
|
private UserActivityInviteClient userActivityInviteClient;
|
|
@Autowired
|
private UserActivityRedenvelpoeClient userActivityRedenvelpoeClient;
|
|
@Autowired
|
private UserActivityRegisteredClient userActivityRegisteredClient;
|
|
|
@Autowired
|
private ISysCouponRecordService sysCouponRecordService;
|
|
@Autowired
|
private ISysRedPacketRecordService sysRedPacketRecordService;
|
|
@Autowired
|
private UserCouponRecordClient userCouponRecordService;
|
@Autowired
|
private ITAuditRecordService auditRecordService;
|
|
|
/**
|
* 跳转领取统计
|
*
|
* @return
|
*/
|
@RequestMapping("/receiveRecord")
|
public String receiveRecord(Model model, Integer activityId) {
|
model.addAttribute("activityId", activityId);
|
UserActivity userActivity = userActivityClient.queryUserActivityById(activityId);
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
model.addAttribute("startTime", sdf.format(userActivity.getStartTime()));
|
model.addAttribute("endTime", sdf.format(userActivity.getEndTime()));
|
UserActivityRegistered userActivityRegistered = userActivityRegisteredClient.queryUserActivityRegisteredByActivityId(activityId);
|
UserActivityInvite userActivityInvite = userActivityInviteClient.queryUserActivityInviteByActivityId(activityId);
|
UserActivityDiscount1 userActivityDiscount1 = userActivityDiscount1Client.queryUserActivityDiscount1ByActivityId(activityId);
|
UserActivityRedenvelope userActivityRedenvelope = userActivityRedenvelpoeClient.queryUserActivityRedenvelopeByActivityId(activityId);
|
if (SinataUtil.isNotEmpty(userActivityRegistered)) {
|
model.addAttribute("userActivityRegisteredId", userActivityRegistered.getId());
|
} else {
|
model.addAttribute("userActivityRegisteredId", 0);
|
}
|
if (SinataUtil.isNotEmpty(userActivityInvite)) {
|
model.addAttribute("userActivityInviteId", userActivityInvite.getId());
|
} else {
|
model.addAttribute("userActivityInviteId", 0);
|
}
|
if (SinataUtil.isNotEmpty(userActivityDiscount1)) {
|
model.addAttribute("userActivityDiscount1Id", userActivityDiscount1.getId());
|
} else {
|
model.addAttribute("userActivityDiscount1Id", 0);
|
}
|
if (SinataUtil.isNotEmpty(userActivityRedenvelope)) {
|
model.addAttribute("userActivityRedenvelopeId", userActivityRedenvelope.getId());
|
} else {
|
model.addAttribute("userActivityRedenvelopeId", 0);
|
}
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "receiveRecord.html";
|
}
|
|
@RequestMapping(value = "/receiveRecordDetail")
|
@ResponseBody
|
public Object receiveRecordDetail(String createTime, Integer activityId) {
|
String startTimes = null;
|
String endTimes = null;
|
if (SinataUtil.isNotEmpty(createTime)) {
|
String[] timeArray = createTime.split(" - ");
|
startTimes = timeArray[0];
|
endTimes = timeArray[1];
|
} else {
|
UserActivity userActivity = userActivityClient.queryUserActivityById(activityId);
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
startTimes = sdf.format(userActivity.getStartTime());
|
endTimes = sdf.format(userActivity.getEndTime());
|
}
|
Map<String, Object> map = new HashMap<>();
|
Double totalMOney = 0d;
|
UserActivityRegistered userActivityRegistered = userActivityRegisteredClient.queryUserActivityRegisteredByActivityId(activityId);
|
UserActivityInvite userActivityInvite = userActivityInviteClient.queryUserActivityInviteByActivityId(activityId);
|
UserActivityDiscount1 userActivityDiscount1 = userActivityDiscount1Client.queryUserActivityDiscount1ByActivityId(activityId);
|
UserActivityRedenvelope userActivityRedenvelope = userActivityRedenvelpoeClient.queryUserActivityRedenvelopeByActivityId(activityId);
|
if (SinataUtil.isNotEmpty(userActivityRegistered)) {
|
Map<String, Object> resultMap = userCouponRecordService.getCouponStatic(new GetCouponStaticReq(startTimes, endTimes, userActivityRegistered.getId(), 2));
|
totalMOney += Double.parseDouble(resultMap.get("money").toString());
|
map.put("userActivityRegisteredMoney", resultMap.get("money"));
|
map.put("userActivityRegisteredNumber", resultMap.get("number"));
|
map.put("userActivityRegisteredUseMoney", resultMap.get("useMoney"));
|
} else {
|
map.put("userActivityRegisteredMoney", 0);
|
map.put("userActivityRegisteredNumber", 0);
|
map.put("userActivityRegisteredUseMoney", 0);
|
}
|
if (SinataUtil.isNotEmpty(userActivityInvite)) {
|
Map<String, Object> resultMap = userCouponRecordService.getCouponStatic(new GetCouponStaticReq(startTimes, endTimes, userActivityInvite.getId(), 3));
|
totalMOney += Double.parseDouble(resultMap.get("money").toString());
|
map.put("userActivityInviteMoney", resultMap.get("money"));
|
map.put("userActivityInviteNumber", resultMap.get("number"));
|
map.put("userActivityInviteUseMoney", resultMap.get("useMoney"));
|
} else {
|
map.put("userActivityInviteMoney", 0);
|
map.put("userActivityInviteNumber", 0);
|
map.put("userActivityInviteUseMoney", 0);
|
}
|
if (SinataUtil.isNotEmpty(userActivityDiscount1)) {
|
Map<String, Object> resultMap = userCouponRecordService.getDiscountStatic(new GetDiscountStaticReq(startTimes, endTimes, userActivityDiscount1.getId()));
|
if(resultMap!=null){
|
map.put("userActivityDiscount1Money", resultMap.get("money"));
|
map.put("userActivityDiscount1Number", resultMap.get("number"));
|
}else {
|
map.put("userActivityDiscount1Money", 0);
|
map.put("userActivityDiscount1Number", 0);
|
}
|
|
} else {
|
map.put("userActivityDiscount1Money", 0);
|
map.put("userActivityDiscount1Number", 0);
|
}
|
if (SinataUtil.isNotEmpty(userActivityRedenvelope)) {
|
Map<String, Object> resultMap = userCouponRecordService.getRedStatic(new GetDiscountStaticReq(startTimes, endTimes, userActivityRedenvelope.getId()));
|
totalMOney += Double.parseDouble(resultMap.get("money").toString());
|
map.put("userActivityRedenvelopeMoney", resultMap.get("money"));
|
map.put("userActivityRedenvelopeNumber", resultMap.get("number"));
|
map.put("userActivityRedenvelopeUseMoney", resultMap.get("useMoney"));
|
} else {
|
map.put("userActivityRedenvelopeMoney", 0);
|
map.put("userActivityRedenvelopeNumber", 0);
|
map.put("userActivityRedenvelopeUseMoney", 0);
|
}
|
Map<String, Object> resultMap = userCouponRecordService.getRegStatic(new GetDiscountStaticReq(startTimes, endTimes, activityId));
|
|
totalMOney += Double.parseDouble(resultMap.get("money").toString());
|
map.put("totalMOney", totalMOney);
|
return map;
|
}
|
|
/**
|
* 跳转到首页
|
*/
|
@RequestMapping("")
|
public String index(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
model.addAttribute("id",UserExt.getUser().getObjectId());
|
return PREFIX + "userActivity.html";
|
}
|
|
/**
|
* 跳转添加注册送优惠券页面
|
*
|
* @return
|
*/
|
@RequestMapping("addRegist")
|
public String addRegist(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "addRegist.html";
|
}
|
|
/**
|
* 跳转红包选择页面
|
*
|
* @return
|
*/
|
@RequestMapping("/sysRedPacketRecord")
|
public String sysRedPacketRecord() {
|
return PREFIX + "sysRedPacketRecord.html";
|
}
|
|
/**
|
* 跳转到选择优惠券页面
|
*
|
* @return
|
*/
|
@RequestMapping("/sysCouponRecord")
|
public String sysCouponRecord(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "sysCouponRecord.html";
|
}
|
|
@RequestMapping("/sysCouponRecord1")
|
public String sysCouponRecord1(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "sysCouponRecord1.html";
|
}
|
|
@RequestMapping("/sysCouponRecord2")
|
public String sysCouponRecord2(Model model, Integer type) {
|
model.addAttribute("type", type);
|
model.addAttribute("language", UserExt.getLanguage());
|
return PREFIX + "sysCouponRecord2.html";
|
}
|
|
/**
|
* 跳转到添加
|
*/
|
@RequestMapping("/userActivity_add")
|
public String userActivityAdd(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "userActivity_add.html";
|
}
|
|
/**
|
* 跳转到修改
|
*/
|
@RequestMapping("/userActivity_update/{userActivityId}")
|
public String userActivityUpdate(@PathVariable Integer userActivityId, Model model) {
|
UserActivity userActivity = userActivityClient.queryUserActivityById(userActivityId);
|
model.addAttribute("item", userActivity);
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
model.addAttribute("startTime", sdf.format(userActivity.getStartTime()));
|
model.addAttribute("endTime", sdf.format(userActivity.getEndTime()));
|
UserActivityRegistered userActivityRegistered = userActivityRegisteredClient.queryUserActivityRegisteredByActivityId(userActivity.getId());
|
|
model.addAttribute("item1", userActivityRegistered);
|
if (userActivityRegistered != null) {
|
model.addAttribute("item1Coupon", sysCouponRecordService.getById(userActivityRegistered.getCouponId()));
|
}
|
UserActivityInvite userActivityInvite = userActivityInviteClient.queryUserActivityInviteByActivityId(userActivity.getId());
|
|
model.addAttribute("item2", userActivityInvite);
|
if (userActivityInvite != null) {
|
model.addAttribute("item2Coupon", sysCouponRecordService.getById(userActivityInvite.getCouponId()));
|
}
|
List<UserActivityBalance> balanceInfoList = userActivityBalanceClient.queryUserActivityBalanceList(userActivity.getId());
|
model.addAttribute("balanceInfoList", balanceInfoList);
|
model.addAttribute("item4", userActivityDiscount1Client.queryUserActivityDiscount1ByActivityId(userActivity.getId()));
|
|
UserActivityRedenvelope userActivityRedenvelope = userActivityRedenvelpoeClient.queryUserActivityRedenvelopeByActivityId(userActivity.getId());
|
model.addAttribute("item5", userActivityRedenvelope);
|
if (userActivityRedenvelope != null) {
|
model.addAttribute("item5Red", sysRedPacketRecordService.getById(userActivityRedenvelope.getRedEnvelopeId()));
|
}
|
LogObjectHolder.me().set(userActivity);
|
return PREFIX + "userActivity_edit.html";
|
}
|
|
/**
|
* 获取列表
|
*/
|
@RequestMapping(value = "/blanceList")
|
@ResponseBody
|
public Object blanceList(String createTime, Integer activityId) {
|
String beginTime = null;
|
String endTime = null;
|
if (SinataUtil.isNotEmpty(createTime)) {
|
String[] timeArray = createTime.split(" - ");
|
beginTime = timeArray[0];
|
endTime = timeArray[1];
|
}
|
Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
|
page.setRecords(userCouponRecordService.getBlanceList(new GetBlanceListReq(page, beginTime, endTime, activityId)));
|
return super.packForBT(page);
|
}
|
|
/**
|
* 获取列表
|
*/
|
@RequestMapping(value = "/list")
|
@ResponseBody
|
public Object list(String createTime, String name, Integer status, Integer offset, Integer limit) {
|
Date startTimes = null;
|
Date endTimes = null;
|
if (SinataUtil.isNotEmpty(createTime)) {
|
String[] timeArray = createTime.split(" - ");
|
startTimes = DateUtil.getDate_str3(timeArray[0] + " 00:00:00");
|
endTimes = DateUtil.getDate_str3(timeArray[1] + " 23:59:59");
|
}
|
Integer uid = UserExt.getUser().getId();
|
return userActivityClient.queryUserActivityList(new QueryUserActivityListReq(uid, startTimes, endTimes, name, status, offset, limit));
|
}
|
|
/**
|
* @param name 活动时间
|
* @param startTime 时间区间
|
* @param registCouponId 注册活动-优惠券id
|
* @param registEnable 注册活动-是否启动(1=不启动，2=启动)
|
* @param registNumber 注册活动-优惠券数量
|
* @param registEffective 注册活动-优惠券有效期
|
* @param inviteCouponId 邀请活动-优惠券id
|
* @param inviteEnable 邀请活动-是否启动(1=不启动，2=启动)
|
* @param inviteNumber 邀请活动-优惠券数量
|
* @param inviteEffective 邀请活动-优惠券有效期
|
* @param balanceEnable 充值活动-是否启动(1=不启动，2=启动)
|
* @param balanceInfo 充值活动-详情
|
* @param discountEnable 折扣活动-是否启动(1=不启动，2=启动)
|
* @param discountSpecial 折扣活动-专车
|
* @param discountTaxi 折扣活动-出租车
|
* @param discountLogistics 折扣活动-小件物流
|
* @param redenvelopeId -红包活动-红包id
|
* @param redenvelopeEnable 红包活动-是否启动(1=不启动，2=启动)
|
* @return
|
*/
|
@RequestMapping(value = "/add")
|
@ResponseBody
|
public Object add(String name, String startTime, Integer registCouponId,
|
Integer registEnable, Integer registNumber, Integer registEffective,
|
Integer inviteCouponId, Integer inviteEnable, Integer inviteNumber, Integer inviteEffective,
|
Integer balanceEnable, String balanceInfo,
|
Integer discountEnable, Double discountSpecial, Double discountTaxi, Double discountLogistics,
|
Integer redenvelopeId, Integer redenvelopeEnable, Double registerPrice, Double invitationPrice, Double redPrice) {
|
if(registEnable==1 && inviteEnable==1 && balanceEnable==1 && discountEnable==1){
|
return "504";
|
}
|
userActivityClient.insertOrUpdate(new UserActivityInsertOrUpdateReq(null, name, startTime, registCouponId,
|
registEnable, registNumber, registEffective,
|
inviteCouponId, inviteEnable, inviteNumber, inviteEffective,
|
balanceEnable, balanceInfo,
|
discountEnable, discountSpecial, discountTaxi, discountLogistics,
|
redenvelopeId, redenvelopeEnable, registerPrice, invitationPrice, redPrice, UserExt.getUser().getObjectId(), UserExt.getUser().getRoleType()));
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* 删除
|
*/
|
@RequestMapping(value = "/delete")
|
@ResponseBody
|
public Object delete(@RequestParam Integer userActivityId) {
|
userActivityClient.deleteUserActivityById(userActivityId);
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* @param name 活动时间
|
* @param startTime 时间区间
|
* @param registCouponId 注册活动-优惠券id
|
* @param registEnable 注册活动-是否启动(1=不启动，2=启动)
|
* @param registNumber 注册活动-优惠券数量
|
* @param registEffective 注册活动-优惠券有效期
|
* @param inviteCouponId 邀请活动-优惠券id
|
* @param inviteEnable 邀请活动-是否启动(1=不启动，2=启动)
|
* @param inviteNumber 邀请活动-优惠券数量
|
* @param inviteEffective 邀请活动-优惠券有效期
|
* @param balanceEnable 充值活动-是否启动(1=不启动，2=启动)
|
* @param balanceInfo 充值活动-详情
|
* @param discountEnable 折扣活动-是否启动(1=不启动，2=启动)
|
* @param discountSpecial 折扣活动-专车
|
* @param discountTaxi 折扣活动-出租车
|
* @param discountLogistics 折扣活动-小件物流
|
* @param redenvelopeId -红包活动-红包id
|
* @param redenvelopeEnable 红包活动-是否启动(1=不启动，2=启动)
|
* @return
|
*/
|
@RequestMapping(value = "/update")
|
@ResponseBody
|
public Object update(Integer id, String name, String startTime, Integer registCouponId,
|
Integer registEnable, Integer registNumber, Integer registEffective,
|
Integer inviteCouponId, Integer inviteEnable, Integer inviteNumber, Integer inviteEffective,
|
Integer balanceEnable, String balanceInfo,
|
Integer discountEnable, Double discountSpecial, Double discountTaxi, Double discountLogistics,
|
Integer redenvelopeId, Integer redenvelopeEnable, Double registerPrice, Double invitationPrice, Double redPrice) {
|
userActivityClient.insertOrUpdate(new UserActivityInsertOrUpdateReq(id, name, startTime, registCouponId,
|
registEnable, registNumber, registEffective,
|
inviteCouponId, inviteEnable, inviteNumber, inviteEffective,
|
balanceEnable, balanceInfo,
|
discountEnable, discountSpecial, discountTaxi, discountLogistics,
|
redenvelopeId, redenvelopeEnable, registerPrice, invitationPrice, redPrice, 11, 33));
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* 修改状态
|
*
|
* @param driverActivity
|
* @return
|
*/
|
@RequestMapping(value = "/updateStatus")
|
@ResponseBody
|
public Object updateStatus(UserActivity driverActivity) {
|
userActivityClient.updateStatus(driverActivity);
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* 详情
|
*/
|
@RequestMapping(value = "/userActivity_detail/{userActivityId}")
|
public Object detail(@PathVariable("userActivityId") Integer userActivityId, Model model) {
|
UserActivity userActivity = userActivityClient.queryUserActivityById(userActivityId);
|
model.addAttribute("item", userActivity);
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
model.addAttribute("startTime", sdf.format(userActivity.getStartTime()));
|
model.addAttribute("endTime", sdf.format(userActivity.getEndTime()));
|
UserActivityRegistered userActivityRegistered = userActivityRegisteredClient.queryUserActivityRegisteredByActivityId(userActivity.getId());
|
|
model.addAttribute("item1", userActivityRegistered);
|
if (userActivityRegistered != null) {
|
model.addAttribute("item1Coupon", sysCouponRecordService.getById(userActivityRegistered.getCouponId()));
|
}
|
UserActivityInvite userActivityInvite = userActivityInviteClient.queryUserActivityInviteByActivityId(userActivity.getId());
|
model.addAttribute("item2", userActivityInvite);
|
if (userActivityInvite != null) {
|
model.addAttribute("item2Coupon", sysCouponRecordService.getById(userActivityInvite.getCouponId()));
|
}
|
List<UserActivityBalance> balanceInfoList = userActivityBalanceClient.queryUserActivityBalanceList(userActivity.getId());
|
model.addAttribute("balanceInfoList", balanceInfoList==null?new ArrayList<UserActivityBalance>():balanceInfoList);
|
model.addAttribute("item4", userActivityDiscount1Client.queryUserActivityDiscount1ByActivityId(userActivity.getId()));
|
|
UserActivityRedenvelope userActivityRedenvelope = userActivityRedenvelpoeClient.queryUserActivityRedenvelopeByActivityId(userActivity.getId());
|
|
model.addAttribute("item5", userActivityRedenvelope);
|
if (userActivityRedenvelope != null) {
|
model.addAttribute("item5Red", sysRedPacketRecordService.getById(userActivityRedenvelope.getRedEnvelopeId()));
|
}
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "userActivity_detail.html";
|
}
|
|
/**
|
* 跳转到立即处理页面
|
*/
|
@RequestMapping("/userActivity_immediately/{id}")
|
public String userActivityImmediately(@PathVariable Integer id, Model model) {
|
model.addAttribute("id", id);
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "userActivity_immediately.html";
|
}
|
|
/**
|
* 立即处理操作
|
*/
|
@RequestMapping(value = "/immediately")
|
@Transactional(rollbackFor = Exception.class)
|
@ResponseBody
|
public Object immediately(@RequestParam Integer id, @RequestParam Integer state, @RequestParam String remark) {
|
UserActivity userActivity = userActivityClient.queryUserActivityById(id);
|
if (SinataUtil.isNotEmpty(userActivity)) {
|
userActivity.setStatus(state);
|
userActivity.setRemark(remark);
|
userActivityClient.updateStatus(userActivity);
|
|
// 添加审核记录
|
TAuditRecord tAuditRecord = new TAuditRecord();
|
tAuditRecord.setActivityId(id);
|
tAuditRecord.setActivityName(userActivity.getName());
|
if(state == 2){
|
tAuditRecord.setAuditStatus(3);
|
}
|
if(state == 3){
|
tAuditRecord.setAuditStatus(2);
|
}
|
tAuditRecord.setAuditTime(new Date());
|
tAuditRecord.setAuditUserId(Objects.requireNonNull(UserExt.getUser()).getId());
|
tAuditRecord.setRemark(remark);
|
tAuditRecord.setActivityType(ActivityTypeEnum.USER_ACTIVITY.getCode());
|
auditRecordService.save(tAuditRecord);
|
|
}
|
return SUCCESS_TIP;
|
}
|
}
|
