package com.matrix.system.shopXcx.action;
|
|
|
import com.matrix.core.anotations.RemoveRequestToken;
|
import com.matrix.core.anotations.SaveRequestToken;
|
import com.matrix.core.constance.MatrixConstance;
|
import com.matrix.core.constance.SystemErrorCode;
|
import com.matrix.core.constance.SystemMessageCode;
|
import com.matrix.core.exception.GlobleException;
|
import com.matrix.core.pojo.AjaxResult;
|
import com.matrix.core.pojo.PaginationVO;
|
import com.matrix.core.tools.ModelUtils;
|
import com.matrix.core.tools.StringUtils;
|
import com.matrix.core.tools.WebUtil;
|
import com.matrix.system.common.bean.SysUsers;
|
import com.matrix.system.constance.Dictionary;
|
import com.matrix.system.shopXcx.bean.ShopCoupon;
|
import com.matrix.system.shopXcx.bean.ShopProduct;
|
import com.matrix.system.shopXcx.dao.ShopCouponDao;
|
import com.matrix.system.shopXcx.dao.ShopProductDao;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import org.springframework.web.servlet.ModelAndView;
|
|
import java.beans.Transient;
|
import java.util.*;
|
|
/**
|
* @author jyy
|
* @description 优惠券
|
* @date 2019-06-12 15:17
|
*/
|
@Controller
|
@RequestMapping(value = "admin/shopCoupon")
|
public class ShopCouponAction {
|
|
@Autowired
|
private ShopCouponDao shopCouponDao;
|
|
@Autowired
|
private ShopProductDao shopProductDao;
|
|
|
|
|
|
|
//记录编辑前的值Before_Edit_Value
|
public static final String BEV = "ShopCoupon_BEV";
|
|
|
/**
|
* 列表显示
|
*/
|
@RequestMapping(value = "/showList")
|
public @ResponseBody
|
AjaxResult showList(ShopCoupon shopCoupon, PaginationVO pageVo) {
|
|
pageVo.setSort("update_time");
|
pageVo.setOrder("desc");
|
SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
if (!user.getShopRole().equals(Dictionary.FLAG_YES_Y)) {
|
shopCoupon.setShopId(user.getShopId());
|
}
|
shopCoupon.setCompanyId(user.getCompanyId());
|
List<ShopCoupon> dataList = shopCouponDao.selectInPage(shopCoupon, pageVo);
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, dataList, shopCouponDao.selectTotalRecord(shopCoupon));
|
}
|
|
/**
|
* 新增
|
*/
|
@RemoveRequestToken
|
@RequestMapping(value = "/addShopCoupon")
|
@Transient
|
public @ResponseBody
|
AjaxResult addShopCoupon(ShopCoupon shopCoupon) {
|
//如果结束时间早于开始时间
|
if (shopCoupon.getBeginTime().after(shopCoupon.getEndTime())) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "结束时间不得早于开始时间！");
|
}
|
//如果抵消金额大于最低消费金额
|
if (shopCoupon.getOffsetAmount().compareTo(shopCoupon.getMinAmount()) == 1) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "抵消金额不能大于最低消费金额（满减）！");
|
}
|
SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
shopCoupon.setCreateBy(user.getSuName());
|
shopCoupon.setUpdateBy(user.getSuName());
|
shopCoupon.setQuantityReceive(0);
|
//设置为未开始状态
|
shopCoupon.setCouponStatus(1);
|
//如果是全部产品可以使用
|
if (shopCoupon.getIsAll() == 1) {
|
shopCoupon.setProductIds("");
|
shopCoupon.setAttrIds("");
|
}
|
// @TODO wzy增加
|
shopCoupon.setShopId(user.getShopId());
|
shopCoupon.setCompanyId(user.getCompanyId());
|
int i = shopCouponDao.insert(shopCoupon);
|
|
productLabeling(shopCoupon);
|
|
if (i > 0) {
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, SystemMessageCode.ADD_SUCCES, "优惠券");
|
} else {
|
throw new GlobleException(SystemErrorCode.DATA_ADD_FAIL);
|
}
|
}
|
|
|
/**
|
* 修改
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@RequestMapping(value = "/modifyShopCoupon")
|
public @ResponseBody
|
AjaxResult modifyShopCoupon(ShopCoupon newShopCoupon) {
|
//如果结束时间早于开始时间
|
if (newShopCoupon.getBeginTime().after(newShopCoupon.getEndTime())) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "结束时间不得早于开始时间！");
|
}
|
//如果抵消金额大于最低消费金额
|
if (newShopCoupon.getOffsetAmount().compareTo(newShopCoupon.getMinAmount()) == 1) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "抵消金额不能大于最低消费金额（满减）！");
|
}
|
//如果所有产品都优惠或没有选择产品
|
if (newShopCoupon.getIsAll() == 1 || newShopCoupon.getProductIds() == null) {
|
newShopCoupon.setProductIds("");
|
}
|
//如果所有产品都优惠或没有选择属性
|
if (newShopCoupon.getIsAll() == 1 || newShopCoupon.getAttrIds() == null) {
|
newShopCoupon.setAttrIds("");
|
}
|
ShopCoupon oldShopCoupon = WebUtil.getSessionAttribute(BEV);
|
int i = 0;
|
Map<String, Object> modifyMap = null;
|
try {
|
if (!ModelUtils.isModified(oldShopCoupon, newShopCoupon)) {
|
i = MatrixConstance.DML_SUCCESSS;
|
}
|
modifyMap = ModelUtils.comparePojo2Map(oldShopCoupon, newShopCoupon);
|
} catch (Exception e) {
|
throw new GlobleException(SystemErrorCode.DATA_UPDATE_FAIL, e, newShopCoupon);
|
}
|
if (modifyMap.size() > 0) {
|
modifyMap.put("id", oldShopCoupon.getId());
|
shopCouponDao.updateByMap(modifyMap);
|
}
|
i = MatrixConstance.DML_SUCCESSS;
|
WebUtil.removeSessionAttribute(BEV);
|
if (i > 0) {
|
shopCouponDao.updateCouponStatusById(newShopCoupon.getId());
|
if (newShopCoupon.getKind() == 2) {
|
// @TODO wzy增加
|
SysUsers users = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
newShopCoupon.setShopId(users.getShopId());
|
|
//更新产品标签
|
shopProductDao.removeProductCouponLable(newShopCoupon.getId());
|
productLabeling(newShopCoupon);
|
|
}
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, SystemMessageCode.UPDATE_SUCCES, "优惠券");
|
} else {
|
throw new GlobleException(SystemErrorCode.DATA_UPDATE_FAIL);
|
}
|
}
|
|
|
/**
|
* 进入修改界面
|
*/
|
@SaveRequestToken
|
@RequestMapping(value = "/editForm")
|
public ModelAndView editForm(Integer id) {
|
ShopCoupon shopCoupon = new ShopCoupon();
|
ModelAndView modelAndView = new ModelAndView("admin/shop/shopCoupon-form");
|
if (id != null) {
|
shopCoupon = shopCouponDao.selectById(id);
|
WebUtil.setSessionAttribute(BEV, shopCoupon);
|
}
|
modelAndView.addObject("obj", shopCoupon);
|
return modelAndView;
|
}
|
|
|
/**
|
* 删除
|
*/
|
@RequestMapping(value = "/del")
|
@Transactional(rollbackFor = Exception.class)
|
public @ResponseBody
|
AjaxResult del(String keys) {
|
List<String> ids = StringUtils.strToCollToString(keys, ",");
|
int i = shopCouponDao.deleteByIds(ids);
|
for (String couponId : ids) {
|
shopProductDao.removeProductCouponLable(Integer.valueOf(couponId));
|
}
|
if (i > 0) {
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, SystemMessageCode.DELETE_SUCCES, i);
|
} else {
|
throw new GlobleException(SystemErrorCode.DATA_DELETE_FAIL);
|
}
|
}
|
|
/**
|
* 批量启用
|
*/
|
@RequestMapping(value = "/startUsing")
|
@Transactional(rollbackFor = Exception.class)
|
public @ResponseBody
|
AjaxResult startUsing(String keys) {
|
List<String> ids = StringUtils.strToCollToString(keys, ",");
|
List<String> newIds = new ArrayList<>();
|
Date now = new Date();
|
//如果结束已经晚于当前时间则跳过不开启
|
for (String couponId : ids) {
|
Integer id = Integer.valueOf(couponId);
|
ShopCoupon shopCoupon = shopCouponDao.selectById(id);
|
if (shopCoupon.getEndTime().after(now)) {
|
newIds.add(couponId);
|
//更新产品标签
|
if (shopCoupon.getKind() == 2) {
|
//更新产品标签
|
productLabeling(shopCoupon);
|
}
|
}
|
}
|
int i = 0;
|
if (CollectionUtils.isNotEmpty(newIds)) {
|
i = shopCouponDao.updateStateByStateAndIds(newIds, 1);
|
}
|
if (i > 0) {
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, SystemMessageCode.UPDATE_SUCCES, i);
|
} else {
|
throw new GlobleException(SystemErrorCode.DATA_UPDATE_FAIL);
|
}
|
}
|
|
/**
|
* 批量停用
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@RequestMapping(value = "/blockUp")
|
public @ResponseBody
|
AjaxResult blockUp(String keys) {
|
List<String> ids = StringUtils.strToCollToString(keys, ",");
|
int i = shopCouponDao.updateStateByStateAndIds(ids, 2);
|
for (String couponId : ids) {
|
shopProductDao.removeProductCouponLable(Integer.valueOf(couponId));
|
}
|
if (i > 0) {
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, SystemMessageCode.UPDATE_SUCCES, i);
|
} else {
|
throw new GlobleException(SystemErrorCode.DATA_UPDATE_FAIL);
|
}
|
}
|
|
|
/**
|
* 给产品打上合适的标签
|
*
|
* @param shopCoupon
|
*/
|
private void productLabeling(ShopCoupon shopCoupon) {
|
SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
Date now = new Date();
|
Boolean needUpdate = false;
|
//优惠券处于可用状态
|
if (shopCoupon.getIsOpen() == 1 && shopCoupon.getBeginTime().before(now) &&
|
shopCoupon.getEndTime().after(now)) {
|
//查询优惠券适配的所有产品
|
List<ShopProduct> shopProductList = new ArrayList<>();
|
if (shopCoupon.getIsAll() == 1) {
|
ShopProduct productQuery = new ShopProduct();
|
productQuery.setDelFlag(2);
|
productQuery.setCompanyId(user.getCompanyId());
|
shopProductList = shopProductDao.selectByModel(productQuery);
|
} else {
|
if (StringUtils.isNotBlank(shopCoupon.getProductIds())) {
|
//根据产品id查询，合适的产品
|
shopProductList.addAll(shopProductDao.selectProductByIds(shopCoupon.getProductIds(), shopCoupon.getShopId()));
|
}
|
if (StringUtils.isNotBlank(shopCoupon.getAttrIds())) {
|
List<Integer> pIds = new ArrayList<>();
|
//根据属性id查询合适的属性
|
List<String> attrIds = StringUtils.strToColl(shopCoupon.getAttrIds(), ",");
|
for (String attrId : attrIds) {
|
List<ShopProduct> tempList = shopProductDao.selectProductByAttrid(attrId, shopCoupon.getShopId());
|
for (ShopProduct product : tempList) {
|
if (!pIds.contains(product.getId())) {
|
shopProductList.add(product);
|
}
|
}
|
}
|
}
|
}
|
//更新优惠券标签
|
if (CollectionUtils.isNotEmpty(shopProductList)) {
|
for (ShopProduct product : shopProductList) {
|
if (product.getCouponId() != null) {
|
ShopCoupon coupon = shopCouponDao.selectById(product.getCouponId());
|
//之前的活动存在，且正在进行中
|
if (coupon != null && coupon.getCouponStatus() == 2) {
|
//比较活动金额
|
if (coupon.getMinAmount().compareTo(shopCoupon.getMinAmount()) <= 0) {
|
//当前优惠活动力度大则更新
|
needUpdate = true;
|
}
|
} else {
|
needUpdate = true;
|
}
|
} else {
|
needUpdate = true;
|
}
|
if (needUpdate) {
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", product.getId());
|
map.put("couponId", shopCoupon.getId());
|
shopProductDao.updateByMap(map);
|
}
|
}
|
}
|
} else {
|
//清除标签
|
shopProductDao.removeProductCouponLable(shopCoupon.getId());
|
}
|
}
|
}
|
