package com.stylefeng.guns.modular.system.controller.general;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.mapper.Wrapper;
|
import com.baomidou.mybatisplus.plugins.Page;
|
import com.stylefeng.guns.core.base.controller.BaseController;
|
import com.stylefeng.guns.core.common.constant.factory.PageFactory;
|
import com.stylefeng.guns.core.log.LogObjectHolder;
|
import com.stylefeng.guns.core.shiro.ShiroKit;
|
import com.stylefeng.guns.core.util.SinataUtil;
|
import com.stylefeng.guns.core.util.ToolUtil;
|
import com.stylefeng.guns.modular.system.model.*;
|
import com.stylefeng.guns.modular.system.response.MerchantActivityVo;
|
import com.stylefeng.guns.modular.system.service.*;
|
import io.swagger.models.auth.In;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.ui.Model;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
import static com.stylefeng.guns.modular.system.service.impl.MerchantActivityServiceImpl.getOrderTypeName;
|
|
|
@Controller
|
@RequestMapping("/merchantActivity")
|
public class MerchantActivityController extends BaseController {
|
|
private String PREFIX = "/system/merchantActivity/";
|
|
@Autowired
|
private IMerchantCouponService merchantCouponService;
|
|
@Autowired
|
private IMerchantActivityService merchantActivityService;
|
|
|
@Autowired
|
private IUserMerchantCouponService userMerchantCouponService;
|
|
@Autowired
|
private ITMerchantService merchantService;
|
|
@Autowired
|
private IMerchantActivitySlaveService merchantActivitySlaveService;
|
|
@Autowired
|
private IUserService userService;
|
|
@RequestMapping("/index")
|
public String index() {
|
return PREFIX + "merchantActivity.html";
|
}
|
|
/**
|
* @param startTime
|
* @param endTime
|
* @param type 券类型（1=优惠券。2=商品券）
|
* @param merchantName 商家名称
|
* @param status 状态 0未开始 1开始 2结束
|
* @return
|
*/
|
@RequestMapping("/list")
|
@ResponseBody
|
public Object list(String startTime, String endTime, Integer type, String merchantName, Integer status) {
|
Integer companyId = ShiroKit.getUser().getObjectId();
|
|
Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
|
List<Map<String, Object>> list = merchantActivityService.list(startTime, endTime, type, merchantName, status, companyId, page);
|
page.setRecords(list);
|
return super.packForBT(page);
|
}
|
|
|
@RequestMapping("merchantActivity_add")
|
public String merchantActivityAdd(Model model) {
|
|
/*查询商家列表*/
|
List<Map<String, Object>> list = merchantCouponService.getMerchantList();
|
model.addAttribute("item", list);
|
|
return PREFIX + "merchantActivity_add.html";
|
}
|
|
|
/**
|
* 跳转选择商家卷
|
*
|
* @return
|
*/
|
@RequestMapping("/choiceCoupon")
|
public String choiceCoupon(String ids, String merchantIds, Integer type, Model model) {
|
|
model.addAttribute("item", ids);
|
model.addAttribute("merchantIds", merchantIds);
|
model.addAttribute("type", type);
|
|
return PREFIX + "merchantCoupon.html";
|
}
|
|
|
@RequestMapping("/getCouponList")
|
@ResponseBody
|
public Object getCouponList(String ids, String merchantIds, Integer type, String startTime, String endTime, String merchantName, String name) {
|
|
String[] split = ids.split(",");
|
List<Integer> couponIds = new ArrayList<>();
|
for (String id : split) {
|
couponIds.add(Integer.valueOf(id));
|
}
|
String[] split1 = merchantIds.split(",");
|
List<String> asList = Arrays.asList(split1);
|
|
Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
|
List<Map<String, Object>> list = merchantCouponService.getCouponList(asList, type, startTime, endTime, merchantName, name, page);
|
list.forEach(one -> {
|
if (couponIds.contains(Integer.valueOf(one.get("id").toString()))) {
|
one.put("selectItem", Boolean.TRUE);
|
}
|
});
|
page.setRecords(list);
|
return super.packForBT(page);
|
}
|
|
|
/**
|
* 添加优惠券活动
|
*
|
* @param activity
|
* @return
|
*/
|
@RequestMapping("/add")
|
@ResponseBody
|
public Object add(@RequestBody MerchantActivity activity) {
|
|
Integer userId = ShiroKit.getUser().getId();
|
User user = userService.selectById(userId);
|
if (ToolUtil.isNotEmpty(user)) {
|
if (user.getRoleType().equals(2)) {
|
activity.setAuditStatus(1);
|
}
|
if (user.getRoleType().equals(1)) {
|
activity.setAuditStatus(2);
|
}
|
}
|
activity.setCompanyType(user.getRoleType());
|
activity.setCompanyId(user.getObjectId());
|
activity.setStatus(0);
|
activity.setState(1);
|
activity.setActivityType(1);
|
activity.setCreateTime(new Date());
|
|
List<MerchantActivitySlave> activitySlaveList = activity.getMerchantActivitySlaveList();
|
Map<Integer, List<MerchantActivitySlave>> listMap = activitySlaveList.stream().collect(Collectors.groupingBy(b -> b.getMerchantId()));
|
|
for (Integer key : listMap.keySet()) {
|
|
MerchantActivity merchantActivity = new MerchantActivity();
|
|
BeanUtils.copyProperties(activity, merchantActivity);
|
merchantActivity.setMerchantId(key);
|
|
merchantActivityService.insert(merchantActivity);
|
|
List<MerchantActivitySlave> merchantActivitySlaves = listMap.get(key);
|
for (MerchantActivitySlave activitySlave : merchantActivitySlaves) {
|
activitySlave.setMerchantActivityId(merchantActivity.getId());
|
activitySlave.setLaveNumber(activitySlave.getTotalNumber());
|
|
merchantActivitySlaveService.insert(activitySlave);
|
}
|
}
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* 跳转到修改详情
|
*/
|
@RequestMapping("/merchant_activity_update")
|
public String merchantActivityUpdate(Integer id, Model model) {
|
|
MerchantActivity activity = merchantActivityService.selectById(id);
|
|
String orderType = activity.getOrderType();
|
|
String[] split = orderType.split(",");
|
List<String> asList = Arrays.asList(split);
|
|
MerchantActivityVo vo = new MerchantActivityVo();
|
BeanUtils.copyProperties(activity, vo);
|
vo.setAsList(asList);
|
vo.setOrderTypeName(getOrderTypeName(activity.getOrderType()));
|
|
/*券信息*/
|
List<Map<String, Object>> mapList = merchantActivitySlaveService.getActivitySlaveList(vo.getId());
|
|
/*查询商家列表*/
|
List<Map<String, Object>> list = merchantCouponService.getMerchantList();
|
model.addAttribute("merchantList", list);
|
model.addAttribute("item", vo);
|
model.addAttribute("mapList", mapList);
|
model.addAttribute("asList", asList);
|
|
LogObjectHolder.me().set(activity);
|
return PREFIX + "merchantActivity_edit.html";
|
}
|
|
/**
|
* 开始/结束活动
|
*
|
* @param ids
|
* @param state
|
* @return
|
*/
|
@RequestMapping("/renewState")
|
@ResponseBody
|
public Object renewState(String ids, Integer state) {
|
List<Integer> activityIds = new ArrayList<>();
|
if (SinataUtil.isNotEmpty(ids)) {
|
String[] split = ids.split(",");
|
for (String id : split) {
|
activityIds.add(Integer.valueOf(id));
|
}
|
}
|
if (CollectionUtils.isEmpty(activityIds)) {
|
activityIds.add(0);
|
}
|
Wrapper<MerchantActivity> wrapper = new EntityWrapper<>();
|
wrapper.in("id", activityIds);
|
List<MerchantActivity> activityList = merchantActivityService.selectList(wrapper);
|
if (CollectionUtils.isNotEmpty(activityList)) {
|
activityList.forEach(one -> {
|
one.setStatus(state);
|
merchantActivityService.updateById(one);
|
});
|
}
|
return SUCCESS_TIP;
|
}
|
|
|
/**
|
* 删除数据
|
*
|
* @param ids
|
* @return
|
*/
|
@RequestMapping("/activityDelete")
|
@ResponseBody
|
public Object activityDelete(String ids) {
|
List<Integer> activityIds = new ArrayList<>();
|
if (SinataUtil.isNotEmpty(ids)) {
|
String[] split = ids.split(",");
|
for (String id : split) {
|
activityIds.add(Integer.valueOf(id));
|
}
|
}
|
if (CollectionUtils.isEmpty(activityIds)) {
|
activityIds.add(0);
|
}
|
Wrapper<MerchantActivity> wrapper = new EntityWrapper<>();
|
wrapper.in("id", activityIds);
|
List<MerchantActivity> activityList = merchantActivityService.selectList(wrapper);
|
if (CollectionUtils.isNotEmpty(activityList)) {
|
activityList.forEach(one -> {
|
one.setState(3); //删除数据
|
one.setStatus(2);//结束活动
|
merchantActivityService.updateById(one);
|
});
|
}
|
return SUCCESS_TIP;
|
}
|
|
|
/**
|
* 跳转领取记录页面
|
*
|
* @return
|
*/
|
@RequestMapping("/receiveIndex")
|
public String receiveIndex(Integer merchantActivityId, Model model) {
|
|
model.addAttribute("item", merchantActivityId);
|
|
return PREFIX + "receivingRecord.html";
|
}
|
|
/**
|
* 领取记录
|
*
|
* @return
|
*/
|
@RequestMapping("/getReceiveList")
|
@ResponseBody
|
public Object getReceiveList(Integer merchantActivityId, String userName, String phone, String startTime, String endTime, Integer status) {
|
|
Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
|
|
List<Map<String, Object>> list = merchantActivityService.getReceiveList(merchantActivityId, userName, phone, startTime, endTime, status, page);
|
page.setRecords(list);
|
return super.packForBT(page);
|
}
|
|
|
@ResponseBody
|
@RequestMapping("/receiveDelete")
|
public Object receiveDelete(String ids) {
|
List<Integer> activityIds = new ArrayList<>();
|
if (SinataUtil.isNotEmpty(ids)) {
|
String[] split = ids.split(",");
|
for (String id : split) {
|
activityIds.add(Integer.valueOf(id));
|
}
|
}
|
if (CollectionUtils.isEmpty(activityIds)) {
|
activityIds.add(0);
|
}
|
Wrapper<UserMerchantCoupon> wrapper = new EntityWrapper<>();
|
wrapper.in("id", activityIds);
|
List<UserMerchantCoupon> merchantCoupons = userMerchantCouponService.selectList(wrapper);
|
if (CollectionUtils.isNotEmpty(merchantCoupons)) {
|
merchantCoupons.forEach(one -> {
|
one.setState(3);
|
userMerchantCouponService.updateById(one);
|
});
|
}
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* 跳转审核列表
|
*
|
* @return
|
*/
|
@RequestMapping("/activityExamineIndex")
|
public String activityExamineIndex() {
|
return PREFIX + "merchantActivityExamine.html";
|
}
|
|
|
/***
|
* 商家活动审核列表
|
* @param startTime
|
* @param endTime
|
* @param type
|
* @param auditStatus
|
* @return
|
*/
|
@RequestMapping("/activityExamineList")
|
@ResponseBody
|
public Object activityExamineList(String startTime, String endTime, Integer type, Integer auditStatus) {
|
|
Integer companyId = null;
|
if (ShiroKit.getUser().getRoleType().equals(1)) {
|
companyId = ShiroKit.getUser().getObjectId();
|
}
|
|
Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
|
List<Map<String, Object>> list = merchantActivityService.activityExamineList(startTime, endTime, type, auditStatus, companyId, page);
|
page.setRecords(list);
|
return super.packForBT(page);
|
}
|
|
|
@RequestMapping("/activityExamine")
|
public Object activityExamine(Integer id, Model model) {
|
|
MerchantActivity activity = merchantActivityService.selectById(id);
|
|
String orderType = activity.getOrderType();
|
|
String[] split = orderType.split(",");
|
List<String> asList = Arrays.asList(split);
|
|
MerchantActivityVo vo = new MerchantActivityVo();
|
BeanUtils.copyProperties(activity, vo);
|
vo.setAsList(asList);
|
vo.setOrderTypeName(getOrderTypeName(activity.getOrderType()));
|
|
/*券信息*/
|
List<Map<String, Object>> mapList = merchantActivitySlaveService.getActivitySlaveList(vo.getId());
|
|
/*查询商家列表*/
|
List<Map<String, Object>> list = merchantCouponService.getMerchantList();
|
model.addAttribute("merchantList", list);
|
model.addAttribute("item", vo);
|
model.addAttribute("mapList", mapList);
|
model.addAttribute("asList", asList);
|
|
LogObjectHolder.me().set(activity);
|
|
return PREFIX + "ActivityExamine.html";
|
}
|
|
|
@RequestMapping("/examine")
|
@ResponseBody
|
public Object examine(Integer id, Integer state, String auditNote) {
|
|
MerchantActivity activity = merchantActivityService.selectById(id);
|
|
Integer userId = ShiroKit.getUser().getId();
|
User user = userService.selectById(userId);
|
|
if (ToolUtil.isNotEmpty(activity)) {
|
activity.setAuditStatus(state);
|
activity.setAuditNote(auditNote);
|
activity.setAuditUserId(user.getObjectId());
|
activity.setAuditTime(new Date());
|
|
merchantActivityService.updateById(activity);
|
}
|
return SUCCESS_TIP;
|
}
|
}
|
