package com.dsh.guns.modular.system.controller.general;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.dsh.course.feignClient.activity.TUserClinet;
import com.dsh.course.feignClient.activity.UserCouponRecordClient;
import com.dsh.guns.config.UserExt;
import com.dsh.guns.core.base.controller.BaseController;
import com.dsh.guns.core.common.constant.factory.PageFactory;
import com.dsh.guns.core.log.LogObjectHolder;
import com.dsh.guns.core.util.SinataUtil;
import com.dsh.guns.modular.system.enums.ActivityTypeEnum;
import com.dsh.guns.modular.system.model.*;
import com.dsh.guns.modular.system.service.ISysCouponActivityService;
import com.dsh.guns.modular.system.service.ISysCouponRecordService;
import com.dsh.guns.modular.system.service.ITAuditRecordService;
import com.dsh.guns.modular.system.util.DateUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.*;

/**
 * 控制器
 *
 * @author fengshuonan
 * @Date 2020-06-17 09:14:59
 */
@Controller
@RequestMapping("/sysCouponActivity")
public class SysCouponActivityController extends BaseController {

    private String PREFIX = "/system/sysCouponActivity/";

    @Autowired
    private ISysCouponActivityService sysCouponActivityService;

    @Autowired
    private TUserClinet tUserClinet;

    @Autowired
    private ISysCouponRecordService couponRecordService;

    @Autowired
    UserCouponRecordClient userCouponRecordClient;
    @Autowired
    private ITAuditRecordService auditRecordService;

    /**
     * 跳转到首页
     */
    @RequestMapping("")
    public String index(Model model) {
        model.addAttribute("language",UserExt.getLanguage());
        model.addAttribute("companyId",UserExt.getUser().getObjectId());
        return PREFIX + "sysCouponActivity.html";
    }

    /**
     * 跳转到选择优惠券页面
     * @return
     */
    @RequestMapping("/sysCouponRecord")
    public String sysCouponRecord(Model model) {
        model.addAttribute("language",UserExt.getLanguage());

        return PREFIX + "sysCouponRecord.html";
    }

    /**
     * 跳转到选择用户页面
     * @return
     */
    @RequestMapping("user")
    public String user(Model model) {
        model.addAttribute("language",UserExt.getLanguage());
        return PREFIX + "tUser.html";
    }
    /**
     * 跳转到添加
     */
    @RequestMapping("/sysCouponActivity_add")
    public String sysCouponActivityAdd(Model model) {
        model.addAttribute("language",UserExt.getLanguage());
        return PREFIX + "sysCouponActivity_add.html";
    }

    /**
     * 跳转到修改
     */
    @RequestMapping("/sysCouponActivity_update/{sysCouponActivityId}")
    public String sysCouponActivityUpdate(@PathVariable Integer sysCouponActivityId, Model model) {
        SysCouponActivity sysCouponActivity = sysCouponActivityService.getById(sysCouponActivityId);
        model.addAttribute("item",sysCouponActivity);
        if(sysCouponActivity.getSendType()==2){
            model.addAttribute("sendUserInfoList",JSON.parseArray(sysCouponActivity.getSendUserId()));
        }else{
            model.addAttribute("sendUserInfoList",new ArrayList<>());
        }
        LogObjectHolder.me().set(sysCouponActivity);
        return PREFIX + "sysCouponActivity_edit.html";
    }

    /**
     * 获取列表
     */
    @RequestMapping(value = "/list")
    @ResponseBody
    public Object list(String createTime,Integer couponUseType,Integer status) {
        Date startTimes = null;
        Date endTimes = null;
        if (SinataUtil.isNotEmpty(createTime)){
            String[] timeArray = createTime.split(" - ");
            startTimes = DateUtil.getDate_str3(timeArray[0]+" 00:00:00");
            endTimes = DateUtil.getDate_str3(timeArray[1]+" 23:59:59");
        }
        Page<SysCouponActivity> page = new PageFactory<SysCouponActivity>().defaultPage();
        LambdaQueryWrapper<SysCouponActivity> wrapper = new LambdaQueryWrapper<>();
//        Wrapper wrapper = new QueryWrapper<SysCouponActivity>().lambda();
        if(SinataUtil.isNotEmpty(createTime)){
            wrapper.between(SysCouponActivity::getInsertTime,startTimes,endTimes);
        }
        if(SinataUtil.isNotEmpty(couponUseType)){wrapper.eq(SysCouponActivity::getCouponUseType,couponUseType);}
        if(SinataUtil.isNotEmpty(status)){wrapper.eq(SysCouponActivity::getStatus,status);}
//        ShiroUser user = ShiroKit.getUser();
//        if(user.getRoleType()!=1){
//            wrapper.eq(SysCouponActivity::getCompanyId,user.getObjectId());
//            wrapper.eq(SysCouponActivity::getCompanyType,user.getRoleType());
//        }
        wrapper.ne(SysCouponActivity::getStatus,4);
        wrapper.orderByDesc(SysCouponActivity::getId);
        return super.packForBT(sysCouponActivityService.getBaseMapper().selectPage(page,wrapper));
    }


    /**
     * 新增
     */
    @RequestMapping(value = "/add")
    @ResponseBody
    public Object add(SysCouponActivity sysCouponActivity,Integer activityId,Integer allNum) {
        SysCouponRecord sysCouponRecord = couponRecordService.getById(activityId);
        sysCouponActivity.setCouponType(sysCouponRecord.getCouponType());
        sysCouponActivity.setCouponUseType(sysCouponRecord.getCouponUseType());
        sysCouponActivity.setMoney(sysCouponRecord.getMoney());
        sysCouponActivity.setFullMoney(sysCouponRecord.getFullMoney());
        sysCouponActivity.setInsertTime(new Date());
        sysCouponActivity.setCouponId(activityId);
        sysCouponActivity.setCompanyId(UserExt.getUser().getObjectId());
        sysCouponActivity.setCompanyType(UserExt.getUser().getRoleType());
        sysCouponActivity.setAllNum(allNum);
        // 数量
        Integer number = sysCouponActivity.getNumber();

        sysCouponActivity.setStatus(sysCouponActivity.getCompanyType()==1?3:1);
        sysCouponActivityService.save(sysCouponActivity);
        if(true){
            //定时发送优惠券 Timed delivery of discount coupons.
            Timer timer = new Timer();
            timer.schedule(new timerTaskTest(sysCouponActivity.getId(),number,allNum),30*1000);//timer.schedule(执行的方法，延迟多久执行(ms))
        }
        return SUCCESS_TIP;
    }
    /**
     * 跳转到立即处理页面
     */
    @RequestMapping("/sysCouponActivity_immediately/{id}")
    public String sysCouponActivityImmediately(@PathVariable Integer id, Model model) {
        model.addAttribute("id",id);
        model.addAttribute("language",UserExt.getLanguage());
        return PREFIX + "sysCouponActivity_immediately.html";
    }
    /**
     * 立即处理操作
     */
    @RequestMapping(value = "/immediately")
    @Transactional(rollbackFor = Exception.class)
    @ResponseBody
    public Object immediately(@RequestParam Integer id,@RequestParam Integer state,@RequestParam String remark) {
        SysCouponActivity sysCouponActivity = sysCouponActivityService.getById(id);
        if (SinataUtil.isNotEmpty(sysCouponActivity)){
            sysCouponActivity.setStatus(state);
            sysCouponActivity.setRemark(remark);
            sysCouponActivityService.updateById(sysCouponActivity);

            // 添加审核记录
            TAuditRecord tAuditRecord = new TAuditRecord();
            tAuditRecord.setActivityId(id);
            tAuditRecord.setActivityName(sysCouponActivity.getName());
            if(state == 2){
                tAuditRecord.setAuditStatus(3);
            }
            if(state == 3){
                tAuditRecord.setAuditStatus(2);
            }
            tAuditRecord.setAuditTime(new Date());
            tAuditRecord.setAuditUserId(Objects.requireNonNull(UserExt.getUser()).getId());
            tAuditRecord.setRemark(remark);
            tAuditRecord.setActivityType(ActivityTypeEnum.SEND_ACTIVITY.getCode());
            auditRecordService.save(tAuditRecord);

            if(state==3){
                //定时发送优惠券 Timed delivery of discount coupons.
                Timer timer = new Timer();
                timer.schedule(new timerTaskTest(id),30*1000);//timer.schedule(执行的方法，延迟多久执行(ms))
            }
        }
        return SUCCESS_TIP;
    }
    class timerTaskTest extends TimerTask {
        private Integer id;

        private Integer number;

        private Integer allNum;

        public timerTaskTest(Integer id) {
            this.id = id;
        }
        public timerTaskTest(Integer id,Integer number,Integer allNum) {
            this.id = id;
            this.number = number;
            this.allNum = allNum;
        }
        @Override
        public void run() {
            SysCouponActivity sysCouponActivity = sysCouponActivityService.getById(id);

            SysCouponRecord sysCouponRecord = couponRecordService.getBaseMapper().selectById(sysCouponActivity.getCouponId());

            UserCouponRecord userCouponRecord = new UserCouponRecord();
            if(sysCouponActivity.getCouponType()==3){
                userCouponRecord.setType(2);
                userCouponRecord.setTotalAmount(sysCouponRecord.getMoney().doubleValue());
                userCouponRecord.setResidualAmount(sysCouponRecord.getMoney().doubleValue());
            }
            userCouponRecord.setMoney(sysCouponActivity.getMoney());
            userCouponRecord.setFullMoney(sysCouponActivity.getFullMoney());
            Date nowDay = new Date();
            userCouponRecord.setInsertTime(nowDay);
            userCouponRecord.setCouponId(sysCouponRecord.getId());
            userCouponRecord.setExpirationTime(new Date(nowDay.getTime()+sysCouponActivity.getEffective()*24*3600*1000L));
            userCouponRecord.setCompanyId(sysCouponActivity.getCompanyId());
            userCouponRecord.setState(1);
            userCouponRecord.setCouponType(sysCouponActivity.getCouponType());
            userCouponRecord.setCouponUseType(sysCouponActivity.getCouponUseType());
            userCouponRecord.setCouponActivityId(sysCouponActivity.getId());
            userCouponRecord.setActivityType(1);
            //判断发送类型1=全部用户，2=选择用户 1:all user 2:select user
            if(sysCouponActivity.getSendType()==1){
                Integer companyId =null;
//                if(sysCouponActivity.getCompanyType()!=1){
                    companyId = sysCouponActivity.getCompanyId();
//                }
//                List<TUser> list = userService.selectList(wrapper);

                List<TUser> list = tUserClinet.queryUserListByCompanyId(companyId);
                for(TUser user:list){
                    userCouponRecord.setUserId(user.getId());
                    for (int i=0;i<sysCouponActivity.getNumber();i++){
                        if(allNum<number){
                            break;
                        }
                        userCouponRecordClient.addUserCouponRecord(userCouponRecord);
                        allNum=allNum-number;
                    }
                }
                sysCouponActivity.setSendUserNum(list.size());
                sysCouponActivity.updateById();
            }else{
               JSONArray  userId = JSON.parseArray(sysCouponActivity.getSendUserId());
                for(int j=0;j<userId.size();j++){
                    userCouponRecord.setUserId(userId.getJSONObject(j).getInteger("userId"));
                    for (int i=0;i<sysCouponActivity.getNumber();i++){
                        if(allNum<number){
                            break;
                        }
                        userCouponRecordClient.addUserCouponRecord(userCouponRecord);
                        allNum=allNum-number;
                    }
                }
                sysCouponActivity.setSendUserNum(userId.size());
                sysCouponActivity.updateById();

            }

        }
    }
    /**
     * 删除
     */
    @RequestMapping(value = "/delete")
    @ResponseBody
    public Object delete(@RequestParam Integer sysCouponActivityId) {
        SysCouponActivity sysCouponActivity = new SysCouponActivity();
        sysCouponActivity.setId(sysCouponActivityId);
        sysCouponActivity.setStatus(4);
        sysCouponActivityService.updateById(sysCouponActivity);
        return SUCCESS_TIP;
    }

    /**
     * 修改
     */
    @RequestMapping(value = "/update")
    @ResponseBody
    public Object update(SysCouponActivity sysCouponActivity,Integer activityId) {
        SysCouponRecord sysCouponRecord = couponRecordService.getById(activityId);
        sysCouponActivity.setCouponType(sysCouponRecord.getCouponType());
        sysCouponActivity.setCouponUseType(sysCouponRecord.getCouponUseType());
        sysCouponActivity.setMoney(sysCouponRecord.getMoney());
        sysCouponActivity.setFullMoney(sysCouponRecord.getFullMoney());
        sysCouponActivity.setInsertTime(new Date());
        sysCouponActivity.setCouponId(activityId);
        sysCouponActivity.setCompanyId(11);
        sysCouponActivity.setCompanyType(33);
        sysCouponActivity.setStatus(sysCouponActivity.getCompanyType()==1?3:1);
        sysCouponActivityService.updateById(sysCouponActivity);
        return SUCCESS_TIP;
    }

    /**
     * 详情
     */
    @RequestMapping(value = "/detail/{sysCouponActivityId}")
    @ResponseBody
    public Object detail(@PathVariable("sysCouponActivityId") Integer sysCouponActivityId) {
        return sysCouponActivityService.getById(sysCouponActivityId);
    }
}