From 3ada3a6e740b3c4b60a43d1a1a67dba072181dbd Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 09 Apr 2021 14:42:24 +0800
Subject: [PATCH] 20210409 获取未领取的奖品

---
 zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java |  173 +++++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 160 insertions(+), 13 deletions(-)

diff --git a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java
index f5854d3..8b2e985 100644
--- a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java
+++ b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java
@@ -7,21 +7,27 @@
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.matrix.component.redis.RedisUserLoginUtils;
 import com.matrix.core.pojo.AjaxResult;
+import com.matrix.core.tools.StringUtils;
 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.dao.ActivitySignWriteoffDao;
 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.activity.entity.ActivitySignWriteoff;
 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.api.vo.SignSuccessVo;
 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 io.swagger.annotations.ApiResponse;
+import io.swagger.annotations.ApiResponses;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
@@ -48,14 +54,21 @@
 	private ActivitySignReceiveRecordDao activitySignReceiveRecordDao;
 	
 	@Autowired
+	private ActivitySignWriteoffDao activitySignWriteoffDao;
+	
+	@Autowired
 	private ActivitySignRecordDao activitySignRecordDao;
 	
 	@ApiOperation(value = "获取签到基本信息", notes = "")
+	@ApiResponses({
+			@ApiResponse(code = 200, message = "ok", response = SignBasicInfoVo.class)
+	})
     @GetMapping(value = "/getSignBasicInfo")
     public AjaxResult getSignBasicInfo() {
 		//获取登录人信息
 		SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class);
 		Long companyId = loginUser.getCompanyId();
+		Long userId = loginUser.getId();
 		//获取签到活动的信息
         SignBasicInfoVo signBasicInfoVo = new SignBasicInfoVo();
         ShopActivities shopActivities = shopActivitiesDao.selectOneByCompanyIdAndActTypeAndActStatus(companyId,ShopActivities.ACTIVITIES_TYPE_SIGN,ShopActivities.ACTSTATUS_STATUS_ING);
@@ -71,6 +84,13 @@
 				.selectListByActIDAndCompanyId(actId,companyId,ActivitySignAwardSet.AWARDSTATE_WORK);
 		signBasicInfoVo.setActivitySignAwardSetVos(activitySignAwardSetVos);
 
+		//今日是否已经参与
+        ActivitySignRecord activitySignRecord = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,new Date());
+        if(ObjectUtil.isNotEmpty(activitySignRecord)) {
+        	signBasicInfoVo.setJoinState(SignBasicInfoVo.JOINSTATE_SIGN);
+        }else {
+        	signBasicInfoVo.setJoinState(SignBasicInfoVo.JOINSTATE_NOTSIGN);
+        }
         AjaxResult ajaxResult = AjaxResult.buildSuccessInstance("");
         ajaxResult.setData(signBasicInfoVo);
         return ajaxResult;
@@ -81,6 +101,9 @@
      *
      */
 	@ApiOperation(value = "点击签到", notes = "")
+	@ApiResponses({
+			@ApiResponse(code = 200, message = "ok", response = SignSuccessVo.class)
+	})
     @PostMapping(value = "/clickSign")
     @Transactional
     public AjaxResult clickSign(@RequestBody ClickSignDTO clickSignDTO) {
@@ -94,8 +117,10 @@
          * 今日是否已经参与
          * 新增签到记录表
          * 判断累计连续签到天数是否+1
+         * 是否已领取
          * 查询是否有签到奖品
          * 		日常奖励和自定义奖品
+         * 			生成核销记录
          */
         //活动是否存在
         ShopActivities shopActivities = shopActivitiesDao.selectById(actId);
@@ -108,25 +133,28 @@
         	return AjaxResult.buildFailInstance("活动未开始");
         }
         //今日是否已经参与
-        ActivitySignRecord activitySignRecord = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,DateUtil.today());
+        ActivitySignRecord activitySignRecord = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,new Date());
         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 activitySignRecordOld = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,offsetDay);
         ActivitySignRecord activitySignRecordAdd = new ActivitySignRecord();
         activitySignRecordAdd.setCompanyId(companyId);
+        activitySignRecordAdd.setCreateBy(user.getName());
+        activitySignRecordAdd.setCreateTime(new Date());
+        activitySignRecordAdd.setUpdateBy(user.getName());
+        activitySignRecordAdd.setUpdateTime(new Date());
         activitySignRecordAdd.setActivityId(actId);
         activitySignRecordAdd.setSignTime(date);
         activitySignRecordAdd.setUserId(userId);
-        Integer cumulativeDay = activitySignRecordOld.getCumulativeDay();
         if(ObjectUtil.isEmpty(activitySignRecordOld)) {
         	//新增签到记录表,累计连续签到天数是1
         	activitySignRecordAdd.setCumulativeDay(1);
         }else {
+        	Integer cumulativeDay = activitySignRecordOld.getCumulativeDay();
         	//新增签到记录表,累计连续签到天数是否+1
         	activitySignRecordAdd.setCumulativeDay(cumulativeDay+1);
         }
@@ -135,6 +163,7 @@
 		 * 查询是否有签到奖品
         * 		日常奖励和自定义奖品
         */
+        SignSuccessVo signSuccessVo = new SignSuccessVo();
         //日常奖励,新增奖品领取记录
         QueryWrapper<ActivitySignAwardSet> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("award_rule",ActivitySignAwardSet.AWARDRULE_NORMAL);
@@ -149,27 +178,145 @@
         	activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE);
         	activitySignReceiveRecord.setActivityId(actId);
         	activitySignReceiveRecord.setCompanyId(companyId);
+        	activitySignReceiveRecord.setCreateBy(user.getName());
+        	activitySignReceiveRecord.setCreateTime(new Date());
+        	activitySignReceiveRecord.setUpdateBy(user.getName());
+        	activitySignReceiveRecord.setUpdateTime(new Date());
         	activitySignReceiveRecordDao.insert(activitySignReceiveRecord);
+        	
+        	signSuccessVo.setNormalAwardName(activitySignAwardSetNormal.getAwardName());
+        	signSuccessVo.setNormalAwardImg(activitySignAwardSetNormal.getIntroduceImg());
         }
+        //获取当前累计天数
+        int cumulativeDay = getCumulativeDay(actId, userId, date, 0);
         //自定义奖励
         QueryWrapper<ActivitySignAwardSet> queryWrapperCumulativeDay = new QueryWrapper<>();
         queryWrapperCumulativeDay.eq("award_rule",ActivitySignAwardSet.AWARDRULE_CUMULATIVEDAY);
-        queryWrapperCumulativeDay.eq("cumulative_day",activitySignRecordAdd.getCumulativeDay());
+        queryWrapperCumulativeDay.eq("cumulative_day",cumulativeDay);
         queryWrapperCumulativeDay.eq("company_id",companyId);
         queryWrapperCumulativeDay.eq("activity_id",actId);
         ActivitySignAwardSet activitySignAwardSetCumulativeDay = activitySignAwardSetDao.selectOne(queryWrapperCumulativeDay);
         if(ObjectUtil.isNotEmpty(activitySignAwardSetCumulativeDay)) {
-        	//奖项类型(1:自定义产品2:积分3:优惠券4:店铺商品)
+        	//是否已领取
+        	Long id = activitySignAwardSetCumulativeDay.getId();
+        	QueryWrapper<ActivitySignReceiveRecord> queryWrapperActivitySignReceiveRecord = new QueryWrapper<>();
+        	queryWrapperActivitySignReceiveRecord.eq("award_id", id);
+        	queryWrapperActivitySignReceiveRecord.eq("company_id", companyId);
+        	queryWrapperActivitySignReceiveRecord.eq("activity_id", actId);
+        	queryWrapperActivitySignReceiveRecord.eq("user_id", userId);
+        	ActivitySignReceiveRecord activitySignReceiveRecordDone = activitySignReceiveRecordDao.selectOne(queryWrapperActivitySignReceiveRecord);
+        	if (ObjectUtil.isNotEmpty(activitySignReceiveRecordDone)) {
+        		String awardNameCumulativeDay = activitySignAwardSetCumulativeDay.getAwardName();
+        		AjaxResult ajaxResult = AjaxResult.buildSuccessInstance(awardNameCumulativeDay+"已经领取过了");
+                ajaxResult.setData(signSuccessVo);
+                return ajaxResult;
+            }
+        	//新增奖品领取记录
+        	ActivitySignReceiveRecord activitySignReceiveRecord = new ActivitySignReceiveRecord();
+        	activitySignReceiveRecord.setUserId(userId);
+        	activitySignReceiveRecord.setReceiveTime(date);
+        	activitySignReceiveRecord.setAwardId(activitySignAwardSetCumulativeDay.getId());
+        	activitySignReceiveRecord.setActivityId(actId);
+        	activitySignReceiveRecord.setCompanyId(companyId);
+        	activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE);
+        	activitySignReceiveRecord.setCreateBy(user.getName());
+        	activitySignReceiveRecord.setCreateTime(new Date());
+        	activitySignReceiveRecord.setUpdateBy(user.getName());
+        	activitySignReceiveRecord.setUpdateTime(new Date());
+        	/**
+        	 * 奖项类型(1:自定义产品2:积分3:优惠券4:店铺商品)
+        	 * 
+        	 * todo:4:店铺商品
+        	 */
+        	//1:自定义产品
         	if(ActivitySignAwardSet.AWARDTYPE_CUSTOMIZE == activitySignAwardSetCumulativeDay.getAwardType()) {
-        		
+            	activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_ING);
+            	String randomString = StringUtils.getRandomString(8);
+            	activitySignReceiveRecord.setWriteOffCode(randomString);
+            	
+            	/**
+            	 * 获取对应奖品的领取方式(兑奖方式(1:线下兑换2:物流配送3:客服兑换)
+            	 */
+            	signSuccessVo.setWriteOffCode(randomString);
+            	signSuccessVo.setAwardType(activitySignAwardSetCumulativeDay.getAwardType());
+            	signSuccessVo.setAwardName(activitySignAwardSetCumulativeDay.getAwardName());
+            	signSuccessVo.setAwardImg(activitySignAwardSetCumulativeDay.getIntroduceImg());
+            	signSuccessVo.setAwardWay(activitySignAwardSetCumulativeDay.getAwardWay());
+				signSuccessVo.setAwardState(activitySignAwardSetCumulativeDay.getAwardState());
+				//2:物流配送
+            	signSuccessVo.setOperationTip(activitySignAwardSetCumulativeDay.getOperationTip());
+            	//1:线下兑换
+            	if(ActivitySignAwardSet.AWARDWAY_ONE == activitySignAwardSetCumulativeDay.getAwardWay()) {
+            		signSuccessVo.setIntroduceTip(activitySignAwardSetCumulativeDay.getIntroduceTip());
+            		signSuccessVo.setPrizeAddress(activitySignAwardSetCumulativeDay.getPrizeAddress());
+            		signSuccessVo.setPrizeStartTime(activitySignAwardSetCumulativeDay.getPrizeStartTime());
+            		signSuccessVo.setPrizeEndTime(activitySignAwardSetCumulativeDay.getPrizeEndTime());
+            	}
+            	//3:客服兑换
+            	if(ActivitySignAwardSet.AWARDWAY_THREE == activitySignAwardSetCumulativeDay.getAwardWay()) {
+            		signSuccessVo.setWechatImg(activitySignAwardSetCumulativeDay.getWechatImg());
+            		signSuccessVo.setPrizeStartTime(activitySignAwardSetCumulativeDay.getPrizeStartTime());
+            		signSuccessVo.setPrizeEndTime(activitySignAwardSetCumulativeDay.getPrizeEndTime());
+            	}
         	}
-        	//获取对应奖品的领取方式(兑奖方式(1:线下兑换2:物流配送3:客服兑换)
-//        	if() {
-//
-//        	}
+        	//2:积分
+        	if(ActivitySignAwardSet.AWARDTYPE_SCORE == activitySignAwardSetCumulativeDay.getAwardType()) {
+            	signSuccessVo.setScoreCnt(activitySignAwardSetCumulativeDay.getScoreCnt());
+        	}
+        	//3:优惠券
+        	if(ActivitySignAwardSet.AWARDTYPE_COUPON == activitySignAwardSetCumulativeDay.getAwardType()) {
+        		signSuccessVo.setCouponName(activitySignAwardSetCumulativeDay.getCouponName());
+        	}
+        	activitySignReceiveRecordDao.insert(activitySignReceiveRecord);
+        	//生成核销记录
+        	if(ActivitySignAwardSet.AWARDTYPE_CUSTOMIZE == activitySignAwardSetCumulativeDay.getAwardType()) {
+	        	ActivitySignWriteoff activitySignWriteoff = new ActivitySignWriteoff();
+	        	//线下兑换和客服兑换
+	        	if(ActivitySignAwardSet.AWARDWAY_ONE == activitySignAwardSetCumulativeDay.getAwardWay()
+	        			|| ActivitySignAwardSet.AWARDWAY_THREE == activitySignAwardSetCumulativeDay.getAwardWay()) {
+	        		activitySignWriteoff.setWriteoffCode(activitySignReceiveRecord.getWriteOffCode());
+	        	}
+	        	activitySignWriteoff.setActId(actId);
+	        	activitySignWriteoff.setAwardId(activitySignAwardSetCumulativeDay.getId());
+	        	activitySignWriteoff.setWinTime(date);
+	        	if(ActivitySignAwardSet.AWARDWAY_TWO == activitySignAwardSetCumulativeDay.getAwardWay()) {
+	        		activitySignWriteoff.setState(ActivitySignWriteoff.STATE_TWO);
+	        	}else {
+	        		activitySignWriteoff.setState(ActivitySignWriteoff.STATE_ONE);
+	        	}
+	        	activitySignWriteoff.setUserId(userId);
+	        	activitySignWriteoff.setCompanyId(companyId);
+	        	activitySignWriteoff.setReceiveId(activitySignReceiveRecord.getId());
+	        	activitySignWriteoff.setCreateBy(user.getName());
+	        	activitySignWriteoff.setCreateTime(new Date());
+	        	activitySignWriteoff.setUpdateBy(user.getName());
+	        	activitySignWriteoff.setUpdateTime(new Date());
+	        	activitySignWriteoffDao.insert(activitySignWriteoff);
+        	}
         }
         
-        
-        return AjaxResult.buildSuccessInstance("申请成功,等待审核");
+        AjaxResult ajaxResult = AjaxResult.buildSuccessInstance("签到成功");
+        ajaxResult.setData(signSuccessVo);
+        return ajaxResult;
     }
+	/**
+     * 获取累计签到天数
+     * @param actId
+     * @param userId
+     * @param date
+     * @return
+     */
+    public int getCumulativeDay(long actId, long userId,Date date, int i) {
+        ActivitySignRecord activitySignRecordOld = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,date);
+        if(ObjectUtil.isEmpty(activitySignRecordOld)) {
+            return i;
+        }
+        i++;
+        DateTime offsetDay = DateUtil.offsetDay(date, -i);
+        return getCumulativeDay(actId,userId,offsetDay,i);
+    }
+    
+    
+    
+    
 }

--
Gitblit v1.9.1