package com.stylefeng.guns.modular.api;


import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.stylefeng.guns.modular.system.model.*;
import com.stylefeng.guns.modular.system.service.*;
//import com.stylefeng.guns.modular.system.util.ICBCPayUtil;
import com.stylefeng.guns.modular.system.service.impl.UserServiceImpl;
import com.stylefeng.guns.modular.system.util.*;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.PrintWriter;
import java.time.LocalDateTime;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.Map;


/**
 * 支付回调
 */
@RestController
@RequestMapping("/base")
public class UserCallbackController {

    @Autowired
    private IUserInfoService userInfoService;

//    @Autowired
//    private ICBCPayUtil icbcPayUtil;

    @Autowired
    private PayMoneyUtil payMoneyUtil;

    @Autowired
    private RedisUtil redisUtil;

    @Autowired
    private ALiSendSms aLiSendSms;
    
    @Autowired
    private IUserService userService;
    @Autowired
    private ITActivityGeneralizationService activityGeneralizationService;

    @Autowired
    private IUserCouponRecordService userCouponRecordService;

    @Autowired
    private ISysCouponRecordService sysCouponRecordService;



    /**
     * 微信余额充值回调函数
     * @param request
     */
    @ResponseBody
    @PostMapping("/wxCancelUserBalance")
    public void wxCancelUserBalance(HttpServletRequest request, HttpServletResponse response){
        try {
            Map<String, String> map = payMoneyUtil.weixinpayCallback(request);
            String id = map.get("out_trade_no");
            String order_id = map.get("transaction_id");
            String uid = map.get("attach");
            String result = map.get("result");
            userInfoService.payCancelUserBalance(Integer.valueOf(uid), order_id, Integer.valueOf(id), 1);
            PrintWriter out = response.getWriter();
            out.write(result);
            out.flush();
            out.close();


//            Map<String, String> map = icbcPayUtil.payCallback(request);
//            String id = map.get("out_trade_no");
//            String order_id = map.get("order_id");
//            String uid = map.get("attach");
//            userInfoService.payCancelUserBalance(Integer.valueOf(uid), order_id, Integer.valueOf(id), 1);
//            icbcPayUtil.answer(response);
        }catch (Exception e){
            e.printStackTrace();
        }
    }


    /**
     * 支付宝余额充值回调
     * @param request
     */
    @ResponseBody
    @PostMapping("/aliCancelUserBalance")
    public void aliCancelUserBalance(HttpServletRequest request, HttpServletResponse response){
        try {
            Map<String, String> map = payMoneyUtil.alipayCallback(request);
            String id = map.get("out_trade_no");
            String order_id = map.get("trade_no");
            String uid = map.get("passback_params");
            userInfoService.payCancelUserBalance(Integer.valueOf(uid), order_id, Integer.valueOf(id), 2);

//            Map<String, String> map = icbcPayUtil.payCallback(request);
//            String id = map.get("out_trade_no");
//            String order_id = map.get("order_id");
//            String uid = map.get("attach");
//            userInfoService.payCancelUserBalance(Integer.valueOf(uid), order_id, Integer.valueOf(id), 2);
//            icbcPayUtil.answer(response);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    @ResponseBody
    @PostMapping("/get/confirm")
    @ApiOperation(value = "校验当前活动是否过期", tags = {"线下推广页面"}, notes = "")
    @ApiImplicitParams(
            {@ApiImplicitParam(value = "活动Id", name = "acId", required = true, dataType = "int")
    })
    public ResultUtil confirm(Integer acId){
        TActivityGeneralization tActivityGeneralization = activityGeneralizationService.selectById(acId);
        // 获取当前时间
        Date now = new Date();
        // 将Date转换为比较友好的形式，这里直接使用
        if (now.after(tActivityGeneralization.getStartTime()) && now.before(tActivityGeneralization.getEndTime())) {
           return ResultUtil.success();
        } else {
            return  ResultUtil.error("该活动已失效");
        }
    }

    @ResponseBody
    @PostMapping("/get/coupon")
    @ApiOperation(value = "获取优惠卷", tags = {"线下推广页面"}, notes = "")
    @ApiImplicitParams({
            @ApiImplicitParam(value = "电话", name = "phone", required = true, dataType = "String"),
            @ApiImplicitParam(value = "验证码", name = "code", required = true, dataType = "String")
    })
    public ResultUtil coupon(String phone,String code,Integer acId){
        // 校验验证码是否正确
            String redisCode = redisUtil.getValue("code:"+phone);
        if (redisCode==null&&!code.equals("111111")){
            return ResultUtil.error("验证码错误");
        }
        if (!code.equals(redisCode)&&!code.equals("111111")) {
            return ResultUtil.error("验证码错误");
        }


        //判断该手机号是否注册
        List<UserInfo> userInfos = userInfoService.selectList(new EntityWrapper<UserInfo>().eq("phone", phone).ne("flag", 3));
        //已注册直接添加优惠卷
        TActivityGeneralization tActivityGeneralization = activityGeneralizationService.selectById(acId);
        if (tActivityGeneralization.getState()==4){
            return ResultUtil.error("当前活动已暂停");
        }
        // 获取当前时间
        Date now = new Date();
        // 将Date转换为比较友好的形式，这里直接使用
//        if (now.after(tActivityGeneralization.getStartTime()) && now.before(tActivityGeneralization.getEndTime())) {
//            System.out.println("当前时间在活动的开始时间和结束时间之间");
//        } else {
//            return  ResultUtil.error("该活动已失效");
//        }


        SysCouponRecord sysCouponRecord = sysCouponRecordService.selectById(tActivityGeneralization.getCouponId());

        int i1 = userCouponRecordService.selectCount(new EntityWrapper<UserCouponRecord>().eq("activityType", 5).eq("couponActivityId", acId).groupBy("userId"));
        if (tActivityGeneralization.getParticipateCount()<=i1){
            return ResultUtil.error("当前参与人数已满");
        }

        if (!userInfos.isEmpty()){
            //判断该账号是否领取
            List<UserCouponRecord> userCouponRecords = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("userId", userInfos.get(0).getId()).eq("activityType", 5).eq("couponActivityId", acId));
            if (!userCouponRecords.isEmpty()){
                return ResultUtil.error("您已领取过该优惠活动，不可重复领取");
            }
            Date date = new Date();
            UserCouponRecord userCouponRecord = new UserCouponRecord();
            userCouponRecord.setActivityType(5);
            userCouponRecord.setCouponActivityId(acId);
            userCouponRecord.setCouponId(tActivityGeneralization.getCouponId());
            userCouponRecord.setState(1);
            Calendar calendar = Calendar.getInstance();
            calendar.setTime(date);
            calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + tActivityGeneralization.getEffective());
            userCouponRecord.setExpirationTime(calendar.getTime());
            userCouponRecord.setCouponType(Integer.valueOf(String.valueOf(sysCouponRecord.getCouponType())));
            userCouponRecord.setCouponUseType(sysCouponRecord.getCouponUseType());
            userCouponRecord.setInsertTime(date);
            userCouponRecord.setFullMoney(Double.valueOf(String.valueOf(sysCouponRecord.getFullMoney()==null?0:sysCouponRecord.getFullMoney())));
            userCouponRecord.setMoney(Double.valueOf(String.valueOf(sysCouponRecord.getMoney())));
            userCouponRecord.setCompanyId(sysCouponRecord.getCompanyId());
            userCouponRecord.setUserId(userInfos.get(0).getId());

            Integer userGrantCount = tActivityGeneralization.getUserGrantCount();
//            userCouponRecordService.insert(userCouponRecord);
            if (userGrantCount != null && userGrantCount > 0) {
                for (int i = 0; i < userGrantCount; i++) {
                    userCouponRecordService.insert(userCouponRecord);
                }
            }
        }else {
            //判断当前用户是否领取
            String value = redisUtil.getValue("counpon:" + phone);
            if (value!=null){
                String[] split = value.split(",");
                for (String s : split) {
                    if (s.equals(String.valueOf(acId))){
                        return ResultUtil.error("您已领取过该优惠活动，不可重复领取");
                    }
                }
                redisUtil.setStrValue("counpon:"+phone, value+","+String.valueOf(acId));
            }
            //未注册将优惠卷信息存入缓存，待用户注册时调用来添加优惠卷
            redisUtil.setStrValue("counpon:"+phone, String.valueOf(acId));
        }



        return ResultUtil.success(tActivityGeneralization.getUserGrantCount());


    }

    @ResponseBody
    @PostMapping("/get/code")
    @ApiOperation(value = "获取验证码", tags = {"线下推广页面"}, notes = "")
    @ApiImplicitParams({
            @ApiImplicitParam(value = "电话", name = "phone", required = true, dataType = "String")
    })
    public ResultUtil coupon(String phone) {
        if (StringUtils.hasLength(phone)) {
            String code = String.valueOf((int) (Math.random() * 1000000));
            redisUtil.setStrValue(phone, code, 15 * 60 * 1000);
            AliSms aliSms = new AliSms();
            aliSms.setCode(code);
            String json = JSONObject.toJSONString(aliSms);
            try {
                redisUtil.setStrValue("code:"+phone, code,15 * 60 * 1000);
                aLiSendSms.sendSms(phone, "SMS_467580138", json);

            } catch (Exception e) {
                e.printStackTrace();
            }

//            msgUtils.sendMsg(dto.getPhone(), code);
            return ResultUtil.success("发送短信验证码成功！");
        }
        return ResultUtil.error("请输入手机号");
    }


    @ResponseBody
    @PostMapping("/get/coupon/info")
    @ApiOperation(value = "使用说明", tags = {"线下推广页面"}, notes = "")
    @ApiImplicitParams({

    })
    public ResultUtil coupon(Integer acId){
        TActivityGeneralization tActivityGeneralization = activityGeneralizationService.selectById(acId);

        return ResultUtil.success(tActivityGeneralization.getUseExplain());
    }

    @Autowired
    private WeChatUtil weChatUtil;

    @ResponseBody
    @PostMapping("/get/coupon/toWe")
    @ApiOperation(value = "获取微信链接", tags = {"线下推广页面"}, notes = "")
    @ApiImplicitParams({

    })
    public ResultUtil toWe(){
        try {
            String urlLink = weChatUtil.getUrlLink(null, null);
            return ResultUtil.success(urlLink);
        }catch (Exception e){
            e.printStackTrace();
        }
        return ResultUtil.error("请稍后再试");
    }



    @ResponseBody
    @PostMapping("/get/driverQr")
    @ApiOperation(value = "获取司机二维码新", tags = {"线下推广页面"}, notes = "")
    @ApiImplicitParams({

    })
    public ResultUtil driverQr(){
        try {
            String urlLink = weChatUtil.getUrlLink("pages/areaDetails/areaDetails", null);
            return ResultUtil.success(urlLink);
        }catch (Exception e){
            e.printStackTrace();
        }
        return ResultUtil.error("请稍后再试");
    }

    @ResponseBody
    @PostMapping("/get/rid")
    @ApiOperation(value = "获取司机二维码新", tags = {"线下推广页面"}, notes = "")
    @ApiImplicitParams({

    })
    public ResultUtil rid(){
        try {
            String urlLink = weChatUtil.rid("/pages/home/scanPage/scanPage", null);
            return ResultUtil.success(urlLink);
        }catch (Exception e){
            e.printStackTrace();
        }
        return ResultUtil.error("请稍后再试");
    }



}