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.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.*;

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 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);
        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);

		//今日是否已经参与
        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;
    }
	
	/**
     * 点击签到
     *
     */
	@ApiOperation(value = "点击签到", notes = "")
	@ApiResponses({
			@ApiResponse(code = 200, message = "ok", response = SignSuccessVo.class)
	})
    @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,new Date());
        if (ObjectUtil.isNotEmpty(activitySignRecord)) {
            return AjaxResult.buildFailInstance("今日用户已经签到成功");
        }
        //前一天是否签到
        Date date = new Date();
        DateTime offsetDay = DateUtil.offsetDay(date, -1);
        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);
        if(ObjectUtil.isEmpty(activitySignRecordOld)) {
        	//新增签到记录表,累计连续签到天数是1
        	activitySignRecordAdd.setCumulativeDay(1);
        }else {
        	Integer cumulativeDay = activitySignRecordOld.getCumulativeDay();
        	//新增签到记录表,累计连续签到天数是否+1
        	activitySignRecordAdd.setCumulativeDay(cumulativeDay+1);
        }
        activitySignRecordDao.insert(activitySignRecordAdd);
		/**
		 * 查询是否有签到奖品
        * 		日常奖励和自定义奖品
        */
        SignSuccessVo signSuccessVo = new SignSuccessVo();
        //日常奖励,新增奖品领取记录
        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);
        	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",cumulativeDay);
        queryWrapperCumulativeDay.eq("company_id",companyId);
        queryWrapperCumulativeDay.eq("activity_id",actId);
        ActivitySignAwardSet activitySignAwardSetCumulativeDay = activitySignAwardSetDao.selectOne(queryWrapperCumulativeDay);
        if(ObjectUtil.isNotEmpty(activitySignAwardSetCumulativeDay)) {
        	//是否已领取
        	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());
            	}
        	}
        	//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);
        	}
        }
        
        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);
    }
    
    
    
    
}