package com.hollywood.applet.controller;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.hollywood.applet.service.*;
import com.hollywood.common.model.TPerformerActivityUser;
import com.hollywood.common.model.TUser;
import com.hollywood.common.model.TVipPurchaseRecord;
import com.hollywood.common.utils.PayMoneyUtil;
import io.swagger.annotations.Api;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
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.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.PrintWriter;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.util.Date;
import java.util.List;
import java.util.Map;

@Slf4j
@RestController
@RequestMapping("/base")
public class CallBackController {

    @Autowired
    private   PayMoneyUtil payMoneyUtil;
    @Autowired
    private TScriptService scriptService;
    @Autowired
    private TShortPlayService shortPlayService;
    @Autowired
    private TPerformerActivityUserService performerActivityUserService;
    @Autowired
    private TVipPurchaseRecordService vipPurchaseRecordService;
    @Autowired
    private TUserService userService;

    @ResponseBody
    @PostMapping("/script/wxcallback")
    public void weChatScriptCallback(HttpServletRequest request, HttpServletResponse response) {
        try {
            Map<String, String> map = payMoneyUtil.weixinpayCallback(request);
            if (null != map) {
                String code = map.get("out_trade_no");
                String transaction_id = map.get("transaction_id");
                String result = map.get("result");
                scriptService.wxcallback(code, transaction_id);
                PrintWriter out = response.getWriter();
                out.write("success");
                out.flush();
                out.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @ResponseBody
    @PostMapping("/short/wxcallback")
    public void weChatShortCallback(HttpServletRequest request, HttpServletResponse response) {
        try {
            Map<String, String> map = payMoneyUtil.weixinpayCallback(request);
            if (null != map) {
                String code = map.get("out_trade_no");
                String transaction_id = map.get("transaction_id");
                String result = map.get("result");
                shortPlayService.wxcallback(code, transaction_id);
                PrintWriter out = response.getWriter();
                out.write(result);
                out.flush();
                out.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @ResponseBody
    @PostMapping("/performance/wxcallback")
    public void weChatPerformanceCallback(HttpServletRequest request, HttpServletResponse response) {
        try {
            Map<String, String> map = payMoneyUtil.weixinpayCallback(request);
            if (null != map) {
                String code = map.get("out_trade_no");
                String transaction_id = map.get("transaction_id");
                String result = map.get("result");
//                shortPlayService.wxcallback(code, transaction_id);

                TPerformerActivityUser one = performerActivityUserService.getOne(Wrappers.lambdaQuery(TPerformerActivityUser.class).eq(TPerformerActivityUser::getCode, code));
                if (one.getIsPay()==1){
                    one.setIsPay(2);
                    one.setOrderNum(transaction_id);
                }
                performerActivityUserService.updateById(one);
                PrintWriter out = response.getWriter();
                out.write("success");
                out.flush();
                out.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @ResponseBody
    @PostMapping("/vip/wxcallback")
    public void weChatVipCallback(HttpServletRequest request, HttpServletResponse response) {
        try {
            Map<String, String> map = payMoneyUtil.weixinpayCallback(request);
            if (null != map) {
                String code = map.get("out_trade_no");
                String transaction_id = map.get("transaction_id");
                String result = map.get("result");
                TVipPurchaseRecord one = vipPurchaseRecordService.getOne(Wrappers.lambdaQuery(TVipPurchaseRecord.class).eq(TVipPurchaseRecord::getCode, code));
                if (one.getIsPay()==1){
                    one.setIsPay(2);
                    one.setOrderNum(transaction_id);
                    TUser byId = userService.getById(one.getUserId());

                    LocalDateTime now = LocalDateTime.now();
                    LocalDateTime firstVipTime = byId.getFirstVipTime();
                    if (firstVipTime==null){
                        byId.setFirstVipTime(now);
                    }
                    Integer purchaseCount = one.getPurchaseCount();
                    LocalDateTime endTime = byId.getEndTime();
                    if (endTime==null||endTime.isBefore(now)){
                        byId.setEndTime(now.plusDays(purchaseCount* 31L));
                    }else {
                        byId.setEndTime(byId.getEndTime().plusDays(purchaseCount*31L));
                    }
                    userService.updateById(byId);
                }
                vipPurchaseRecordService.updateById(one);
                PrintWriter out = response.getWriter();
                out.write("success");
                out.flush();
                out.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @ResponseBody
    @PostMapping("/vip/aliPaymentCourseCallback")
    public void aliVipCallback(HttpServletRequest request, HttpServletResponse response) {
        try {
            Map<String, String> map = payMoneyUtil.alipayCallback(request);
            if (null != map) {
                String code = map.get("out_trade_no");
                String trade_no = map.get("trade_no");
                TVipPurchaseRecord one = vipPurchaseRecordService.getOne(Wrappers.lambdaQuery(TVipPurchaseRecord.class).eq(TVipPurchaseRecord::getCode, code));
                if (one.getIsPay()==1){
                    one.setIsPay(2);
                    one.setOrderNum(trade_no);
                    TUser byId = userService.getById(one.getUserId());
                    LocalDateTime now = LocalDateTime.now();
                    LocalDateTime firstVipTime = byId.getFirstVipTime();
                    if (firstVipTime==null){
                        byId.setFirstVipTime(now);
                    }
                    Integer purchaseCount = one.getPurchaseCount();
                    LocalDateTime endTime = byId.getEndTime();
                    if (endTime==null||endTime.isBefore(now)){
                        byId.setEndTime(now.plusDays(purchaseCount* 31L));
                    }else {
                        byId.setEndTime(byId.getEndTime().plusDays(purchaseCount*31L));
                    }
                    byId.setVipType(one.getVipType());
                    byId.setHasPay(byId.getHasPay()==null? BigDecimal.valueOf(one.getPayMoney()) :byId.getHasPay().add(BigDecimal.valueOf(one.getPayMoney())));
                    userService.updateById(byId);
                }
                vipPurchaseRecordService.updateById(one);
                PrintWriter out = response.getWriter();
                out.write("success");
                out.flush();
                out.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @ResponseBody
    @PostMapping("/performance/aliPaymentCourseCallback")
    public void aliPerformanceCallback(HttpServletRequest request, HttpServletResponse response) {
        try {
            Map<String, String> map = payMoneyUtil.alipayCallback(request);
            if (null != map) {
                String code = map.get("out_trade_no");
                String trade_no = map.get("trade_no");
                TPerformerActivityUser one = performerActivityUserService.getOne(Wrappers.lambdaQuery(TPerformerActivityUser.class).eq(TPerformerActivityUser::getCode, code));
                if (one.getIsPay()==1){
                    one.setIsPay(2);
                    one.setOrderNum(trade_no);
                }
                TUser byId = userService.getById(one.getUserId());
                byId.setHasPay(byId.getHasPay()==null? one.getMoney() :byId.getHasPay().add(one.getMoney()));
                userService.updateById(byId);

                performerActivityUserService.updateById(one);
                PrintWriter out = response.getWriter();
                out.write("success");
                out.flush();
                out.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @ResponseBody
    @PostMapping("/script/alicallback")
    public void aliScriptCallback(HttpServletRequest request, HttpServletResponse response){
        try {
            Map<String, String> map = payMoneyUtil.alipayCallback(request);
            if(null != map){
                String code = map.get("out_trade_no");
                String trade_no = map.get("trade_no");
                scriptService.alicallback(code,trade_no);
                PrintWriter out = response.getWriter();
                out.write("success");
                out.flush();
                out.close();
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    @ResponseBody
    @PostMapping("/short/alicallback")
    public void aliShortCallback(HttpServletRequest request, HttpServletResponse response){
        try {
            Map<String, String> map = payMoneyUtil.alipayCallback(request);
            if(null != map){
                String code = map.get("out_trade_no");
                String trade_no = map.get("trade_no");
                shortPlayService.alicallback(code,trade_no);
                PrintWriter out = response.getWriter();
                out.write("success");
                out.flush();
                out.close();
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}