package com.matrix.system.shopXcx.api.action;
|
|
import cn.hutool.core.date.DateTime;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.matrix.component.redis.RedisUserLoginUtils;
|
import com.matrix.core.pojo.AjaxResult;
|
import com.matrix.system.activity.dao.ActivitySignAwardSetDao;
|
import com.matrix.system.activity.dao.ActivitySignReceiveRecordDao;
|
import com.matrix.system.activity.dao.ActivitySignRecordDao;
|
import com.matrix.system.activity.entity.ActivitySignAwardSet;
|
import com.matrix.system.activity.entity.ActivitySignReceiveRecord;
|
import com.matrix.system.activity.entity.ActivitySignRecord;
|
import com.matrix.system.hive.bean.SysVipInfo;
|
import com.matrix.system.shopXcx.api.dto.ClickSignDTO;
|
import com.matrix.system.shopXcx.api.vo.ActivitySignAwardSetVo;
|
import com.matrix.system.shopXcx.api.vo.SignBasicInfoJsonVo;
|
import com.matrix.system.shopXcx.api.vo.SignBasicInfoVo;
|
import com.matrix.system.shopXcx.bean.ShopActivities;
|
import com.matrix.system.shopXcx.dao.ShopActivitiesDao;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
|
@Api(tags = "签到活动接口类")
|
@RestController
|
@RequestMapping(value = "/wxapi/sign")
|
public class WxShopActivitiesSignAction {
|
|
@Autowired
|
private ShopActivitiesDao shopActivitiesDao;
|
|
@Autowired
|
private RedisUserLoginUtils redisUserLoginUtils;
|
|
@Autowired
|
private ActivitySignAwardSetDao activitySignAwardSetDao;
|
|
@Autowired
|
private ActivitySignReceiveRecordDao activitySignReceiveRecordDao;
|
|
@Autowired
|
private ActivitySignRecordDao activitySignRecordDao;
|
|
@ApiOperation(value = "获取签到基本信息", notes = "")
|
@GetMapping(value = "/getSignBasicInfo")
|
public AjaxResult getSignBasicInfo() {
|
//获取登录人信息
|
SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class);
|
Long companyId = loginUser.getCompanyId();
|
//获取签到活动的信息
|
SignBasicInfoVo signBasicInfoVo = new SignBasicInfoVo();
|
ShopActivities shopActivities = shopActivitiesDao.selectOneByCompanyIdAndActTypeAndActStatus(companyId,ShopActivities.ACTIVITIES_TYPE_SIGN,ShopActivities.ACTSTATUS_STATUS_ING);
|
Long actId = shopActivities.getId();
|
signBasicInfoVo.setActName(shopActivities.getActName());
|
signBasicInfoVo.setActCode(shopActivities.getActCode());
|
signBasicInfoVo.setId(shopActivities.getId());
|
String actContent = shopActivities.getActContent();
|
SignBasicInfoJsonVo signBasicInfoJsonVo = JSON.parseObject(actContent, SignBasicInfoJsonVo.class);
|
signBasicInfoVo.setSignBasicInfoJsonVo(signBasicInfoJsonVo);
|
|
List<ActivitySignAwardSetVo> activitySignAwardSetVos = activitySignAwardSetDao
|
.selectListByActIDAndCompanyId(actId,companyId,ActivitySignAwardSet.AWARDSTATE_WORK);
|
signBasicInfoVo.setActivitySignAwardSetVos(activitySignAwardSetVos);
|
|
AjaxResult ajaxResult = AjaxResult.buildSuccessInstance("");
|
ajaxResult.setData(signBasicInfoVo);
|
return ajaxResult;
|
}
|
|
/**
|
* 点击签到
|
*
|
*/
|
@ApiOperation(value = "点击签到", notes = "")
|
@PostMapping(value = "/clickSign")
|
@Transactional
|
public AjaxResult clickSign(@RequestBody ClickSignDTO clickSignDTO) {
|
SysVipInfo user = redisUserLoginUtils.getLoginUser(SysVipInfo.class);
|
long actId = clickSignDTO.getActId();
|
Long userId = user.getId();
|
Long companyId = user.getCompanyId();
|
/**
|
* 活动是否存在
|
* 活动是否已经开始
|
* 今日是否已经参与
|
* 新增签到记录表
|
* 判断累计连续签到天数是否+1
|
* 查询是否有签到奖品
|
* 日常奖励和自定义奖品
|
*/
|
//活动是否存在
|
ShopActivities shopActivities = shopActivitiesDao.selectById(actId);
|
if (ObjectUtil.isEmpty(shopActivities)) {
|
return AjaxResult.buildFailInstance("活动不存在");
|
}
|
//活动是否已经开始
|
Integer actStatus = shopActivities.getActStatus();
|
if(ShopActivities.ACTSTATUS_STATUS_ING != actStatus) {
|
return AjaxResult.buildFailInstance("活动未开始");
|
}
|
//今日是否已经参与
|
ActivitySignRecord activitySignRecord = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,DateUtil.today());
|
if (ObjectUtil.isNotEmpty(activitySignRecord)) {
|
return AjaxResult.buildFailInstance("今日用户已经签到成功");
|
}
|
//前一天是否签到
|
Date date = new Date();
|
DateTime offsetDay = DateUtil.offsetDay(date, -1);
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
ActivitySignRecord activitySignRecordOld = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,sdf.format(offsetDay.getTime()));
|
ActivitySignRecord activitySignRecordAdd = new ActivitySignRecord();
|
activitySignRecordAdd.setCompanyId(companyId);
|
activitySignRecordAdd.setActivityId(actId);
|
activitySignRecordAdd.setSignTime(date);
|
activitySignRecordAdd.setUserId(userId);
|
Integer cumulativeDay = activitySignRecordOld.getCumulativeDay();
|
if(ObjectUtil.isEmpty(activitySignRecordOld)) {
|
//新增签到记录表,累计连续签到天数是1
|
activitySignRecordAdd.setCumulativeDay(1);
|
}else {
|
//新增签到记录表,累计连续签到天数是否+1
|
activitySignRecordAdd.setCumulativeDay(cumulativeDay+1);
|
}
|
activitySignRecordDao.insert(activitySignRecordAdd);
|
/**
|
* 查询是否有签到奖品
|
* 日常奖励和自定义奖品
|
*/
|
//日常奖励,新增奖品领取记录
|
QueryWrapper<ActivitySignAwardSet> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("award_rule",ActivitySignAwardSet.AWARDRULE_NORMAL);
|
queryWrapper.eq("company_id",companyId);
|
queryWrapper.eq("activity_id",actId);
|
ActivitySignAwardSet activitySignAwardSetNormal = activitySignAwardSetDao.selectOne(queryWrapper);
|
if(ObjectUtil.isNotEmpty(activitySignAwardSetNormal)) {
|
ActivitySignReceiveRecord activitySignReceiveRecord = new ActivitySignReceiveRecord();
|
activitySignReceiveRecord.setUserId(userId);
|
activitySignReceiveRecord.setReceiveTime(date);
|
activitySignReceiveRecord.setAwardId(activitySignAwardSetNormal.getId());
|
activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE);
|
activitySignReceiveRecord.setActivityId(actId);
|
activitySignReceiveRecord.setCompanyId(companyId);
|
activitySignReceiveRecordDao.insert(activitySignReceiveRecord);
|
}
|
//自定义奖励
|
QueryWrapper<ActivitySignAwardSet> queryWrapperCumulativeDay = new QueryWrapper<>();
|
queryWrapperCumulativeDay.eq("award_rule",ActivitySignAwardSet.AWARDRULE_CUMULATIVEDAY);
|
queryWrapperCumulativeDay.eq("cumulative_day",activitySignRecordAdd.getCumulativeDay());
|
queryWrapperCumulativeDay.eq("company_id",companyId);
|
queryWrapperCumulativeDay.eq("activity_id",actId);
|
ActivitySignAwardSet activitySignAwardSetCumulativeDay = activitySignAwardSetDao.selectOne(queryWrapperCumulativeDay);
|
if(ObjectUtil.isNotEmpty(activitySignAwardSetCumulativeDay)) {
|
//奖项类型（1：自定义产品2：积分3：优惠券4：店铺商品）
|
if(ActivitySignAwardSet.AWARDTYPE_CUSTOMIZE == activitySignAwardSetCumulativeDay.getAwardType()) {
|
|
}
|
//获取对应奖品的领取方式（兑奖方式（1：线下兑换2：物流配送3：客服兑换）
|
// if() {
|
//
|
// }
|
}
|
|
|
return AjaxResult.buildSuccessInstance("申请成功,等待审核");
|
}
|
}
|
