package com.matrix.system.shopXcx.api.action;
|
|
import com.matrix.component.redis.RedisUserLoginUtils;
|
import com.matrix.core.exception.GlobleException;
|
import com.matrix.core.pojo.AjaxResult;
|
import com.matrix.core.pojo.PaginationVO;
|
import com.matrix.core.tools.LogUtil;
|
import com.matrix.system.common.interceptor.HostInterceptor;
|
import com.matrix.system.hive.bean.SysVipInfo;
|
import com.matrix.system.hive.plugin.util.CollectionUtils;
|
import com.matrix.system.shopXcx.api.vo.SalonVO;
|
import com.matrix.system.shopXcx.bean.ShopActivities;
|
import com.matrix.system.shopXcx.bean.ShopActivitiesSalonAttrRecord;
|
import com.matrix.system.shopXcx.bean.ShopActivitiesSalonDistribute;
|
import com.matrix.system.shopXcx.bean.ShopActivitiesSalonRecord;
|
import com.matrix.system.shopXcx.dao.ShopActivitiesDao;
|
import com.matrix.system.shopXcx.dao.ShopActivitiesSalonAttrRecordDao;
|
import com.matrix.system.shopXcx.dao.ShopActivitiesSalonAttributeDao;
|
import com.matrix.system.shopXcx.dao.ShopActivitiesSalonRecordDao;
|
import com.matrix.system.shopXcx.dto.CreateSalonDTO;
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author wzy
|
* @date 2020-04-21 11:09
|
**/
|
@RestController
|
@CrossOrigin(origins = "*")
|
@RequestMapping(value = "/wxapi/salon")
|
public class WxShopActivitiesSalonAction {
|
|
@Autowired
|
private ShopActivitiesDao shopActivitiesDao;
|
|
@Autowired
|
private ShopActivitiesSalonAttributeDao shopActivitiesSalonAttributeDao;
|
|
@Autowired
|
private RedisUserLoginUtils redisUserLoginUtils;
|
|
@Autowired
|
private ShopActivitiesSalonRecordDao shopActivitiesSalonRecordDao;
|
|
@Autowired
|
private ShopActivitiesSalonAttrRecordDao shopActivitiesSalonAttrRecordDao;
|
|
/**
|
* 前端分页查询沙龙活动
|
*
|
* @param salonVO
|
* @return
|
*/
|
@PostMapping(value = "/findSalonActivitiesInPage")
|
public AjaxResult findSalonActivitiesInPage(@RequestBody SalonVO salonVO) {
|
ShopActivities shopActivities = new ShopActivities();
|
shopActivities.setActType(ShopActivities.ACTIVITIES_TYPE_SALON);
|
shopActivities.setShopIds(salonVO.getShopId().toString());
|
shopActivities.setCompanyId(HostInterceptor.getCompanyId());
|
PaginationVO pageVo = new PaginationVO();
|
pageVo.setLimit(salonVO.getLimit());
|
pageVo.setOffset(salonVO.getOffset());
|
List<ShopActivities> list = shopActivitiesDao.selectInPage(shopActivities, pageVo);
|
|
AjaxResult ajaxResult = AjaxResult.buildSuccessInstance(list, shopActivitiesDao.selectTotalRecord(shopActivities));
|
return ajaxResult;
|
}
|
|
|
/**
|
* 获取沙龙活动详情
|
*
|
* @param id
|
* @return
|
*/
|
@GetMapping(value = "/findSalonInfoById/{id}")
|
public AjaxResult findSalonInfoById(@PathVariable("id") Long id) {
|
SysVipInfo user = redisUserLoginUtils.getLoginUser(SysVipInfo.class);
|
ShopActivities shopActivities = shopActivitiesDao.selectSalonActivityById(id);
|
ShopActivitiesSalonRecord salonRecord = shopActivitiesSalonRecordDao.selectSalonRecordByUserIdAndActId(user.getOpenId(), id);
|
AjaxResult ajaxResult = AjaxResult.buildSuccessInstance("获取成功");
|
if(shopActivities.getActEndTime().getTime() - System.currentTimeMillis() < 0 || shopActivities.getActStatus() == ShopActivities.ACTIVITIES_STATUS_CLOSE) {
|
ajaxResult.putInMap("status", 2);
|
} else {
|
ajaxResult.putInMap("status", 1);
|
}
|
ajaxResult.putInMap("activity", shopActivities);
|
ajaxResult.putInMap("userRecord", salonRecord);
|
return ajaxResult;
|
}
|
|
/**
|
* 加入沙龙活动
|
*
|
* @param salonDTO
|
* @return
|
*/
|
@PostMapping(value = "/joinSalonActivity")
|
@Transactional
|
public AjaxResult joinSalonActivity(@RequestBody CreateSalonDTO salonDTO) {
|
SysVipInfo user = redisUserLoginUtils.getLoginUser(SysVipInfo.class);
|
|
ShopActivities shopActivities = shopActivitiesDao.selectById(salonDTO.getActId());
|
if (shopActivities == null) {
|
return AjaxResult.buildFailInstance("活动不存在");
|
}
|
|
ShopActivitiesSalonRecord record = shopActivitiesSalonRecordDao.selectSalonRecordByUserIdAndActId(user.getOpenId(), salonDTO.getActId());
|
if (record != null) {
|
return AjaxResult.buildFailInstance("该用户已经参加过了");
|
}
|
|
if (shopActivities.getActMax() != null && shopActivities.getActMax() != 0) {
|
ShopActivitiesSalonRecord salonRecord = new ShopActivitiesSalonRecord();
|
salonRecord.setActId(salonDTO.getActId());
|
int count = shopActivitiesSalonRecordDao.selectTotalRecord(salonRecord);
|
if (count + 1 > shopActivities.getActMax()) {
|
return AjaxResult.buildFailInstance("活动参与人数已满");
|
}
|
}
|
|
ShopActivitiesSalonRecord salonRecord = new ShopActivitiesSalonRecord();
|
salonRecord.setActId(salonDTO.getActId());
|
salonRecord.setUserId(user.getId());
|
salonRecord.setCreateBy(user.getNickName());
|
salonRecord.setUpdateBy(user.getNickName());
|
salonRecord.setStatus(ShopActivitiesSalonRecord.JOIN_STATUS_ING);
|
salonRecord.setShopId(salonDTO.getShopId());
|
salonRecord.setCompanyId(shopActivities.getCompanyId());
|
shopActivitiesSalonRecordDao.insert(salonRecord);
|
|
List<ShopActivitiesSalonDistribute> list = shopActivitiesSalonAttributeDao.selectByActId(salonDTO.getActId());
|
if (CollectionUtils.isNotEmpty(list)) {
|
List<ShopActivitiesSalonAttrRecord> attrRecords = new ArrayList<>();
|
for (ShopActivitiesSalonDistribute salonDistribute : list) {
|
ShopActivitiesSalonAttrRecord attrRecord = new ShopActivitiesSalonAttrRecord();
|
attrRecord.setAsrId(salonRecord.getId());
|
Map<String, String> attrs = salonDTO.getAttrLists();
|
String attrValue = attrs.get(salonDistribute.getAttrName());
|
LogUtil.info("#{}#", attrValue);
|
if (StringUtils.isBlank(attrValue)) {
|
throw new GlobleException("有信息字段未填写");
|
} else {
|
attrRecord.setAttrName(salonDistribute.getAttrName());
|
attrRecord.setAttrValue(attrValue);
|
attrRecord.setCompanyId(shopActivities.getCompanyId());
|
attrRecords.add(attrRecord);
|
}
|
}
|
|
if (CollectionUtils.isNotEmpty(attrRecords)) {
|
shopActivitiesSalonAttrRecordDao.batchInsert(attrRecords);
|
} else {
|
throw new GlobleException("参数异常");
|
}
|
}
|
|
return AjaxResult.buildSuccessInstance("申请成功,等待审核");
|
}
|
|
|
/**
|
* 查询用户所有加入活动
|
*
|
* @return
|
*/
|
@RequestMapping(value = "/findSalonListByUser")
|
public AjaxResult findSalonListByUser(@RequestBody SalonVO salonVO) {
|
SysVipInfo user = redisUserLoginUtils.getLoginUser(SysVipInfo.class);
|
salonVO.setUserId(user.getOpenId());
|
List<ShopActivities> list = shopActivitiesDao.selectSalonActivityByUser(salonVO);
|
return AjaxResult.buildSuccessInstance(list);
|
}
|
}
|
