package com.stylefeng.guns.modular.system.service.impl;

import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.stylefeng.guns.modular.system.dao.WithdrawalMapper;
import com.stylefeng.guns.modular.system.model.Driver;
import com.stylefeng.guns.modular.system.model.UserInfo;
import com.stylefeng.guns.modular.system.model.Withdrawal;
import com.stylefeng.guns.modular.system.service.IUserInfoService;
import com.stylefeng.guns.modular.system.service.IWithdrawalService;
//import com.stylefeng.guns.modular.system.util.ICBCPayUtil;
import com.stylefeng.guns.modular.system.util.PayMoneyUtil;
import com.stylefeng.guns.modular.system.util.ResultUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.*;


@Service
@Transactional(isolation = Isolation.READ_UNCOMMITTED, propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
public class WithdrawalServiceImpl extends ServiceImpl<WithdrawalMapper, Withdrawal> implements IWithdrawalService {

    @Resource
    private WithdrawalMapper withdrawalMapper;

    @Autowired
    private IUserInfoService userInfoService;

//    @Autowired
//    private ICBCPayUtil icbcPayUtil;

    @Autowired
    private PayMoneyUtil payMoneyUtil;

    private Map<String, Timer> timerMap = new HashMap<>();




    /**
     * 提现操作
     * @param money
     * @param code
     * @param name
     * @param uid
     * @throws Exception
     */
    @Override
    public ResultUtil withdrawal(Double money, String code, String name, Integer uid) throws Exception {
        if(money.compareTo(0D) <= 0){
            return ResultUtil.error("提现金额必须大于0");
        }
        UserInfo userInfo = userInfoService.selectById(uid);
        if(null == userInfo.getBalance()){
            return ResultUtil.error("账户没有余额，不能提现");
        }
        if(userInfo.getBalance().compareTo(money) < 0){
            return ResultUtil.error("提现金额必须小于账户余额");
        }

        Withdrawal withdrawal = new Withdrawal();
        withdrawal.setBalance(userInfo.getBalance());
        withdrawal.setCode(code);
        withdrawal.setFlag(1);
        withdrawal.setInsertTime(new Date());
        withdrawal.setMoney(money);
        withdrawal.setName(name);
        withdrawal.setState(1);
        withdrawal.setUserId(uid);
        withdrawal.setUserType(1);

//        ResultUtil<String> transfer = icbcPayUtil.transfer(Double.valueOf(withdrawal.getMoney() * 100).longValue(), withdrawal.getCode(), withdrawal.getName());
//        if(transfer.getCode() != 200){
//            return transfer;
//        }
//        withdrawal.setSerialNo(transfer.getData());
        this.insert(withdrawal);

        double v = new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
        userInfo.setBalance(v);
        userInfoService.updateById(userInfo);
        return ResultUtil.success();
    }


    /**
     * 获取历史提交数
     * @param uid
     * @param pageNum
     * @param size
     * @return
     * @throws Exception
     */
    @Override
    public List<Map<String, Object>> queryWithdrawal(Integer uid, Integer pageNum, Integer size) throws Exception {
        pageNum = (pageNum - 1) * size;
        return withdrawalMapper.queryWithdrawal(uid, 1, pageNum, size);
    }


    /**
     * 提现审核处理
     * @param id
     * @param state
     * @return
     * @throws Exception
     */
    @Override
    public ResultUtil withdrawalAudit(Integer id, Integer state) throws Exception {
        Withdrawal withdrawal = this.selectById(id);
//        if(withdrawal.getState() == 2){
//            return ResultUtil.error("申请已审核通过，不能重复提交");
//        }
//        if(withdrawal.getState() == 3){
//            return ResultUtil.error("申请已审核拒绝，不能重复提交");
//        }
        if(state == 1){//审核通过
            TimerTask timerTask = new TimerTask() {
                @Override
                public void run() {
                    try {
                        Map<String, String> map = payMoneyUtil.wxPayBank("用户提现", withdrawal.getMoney().toString(), withdrawal.getId().toString(), withdrawal.getCode(), withdrawal.getName(), "");
                        if("SUCCESS".equals(map.get("return_code"))){
                            withdrawal.setSerialNo(map.get("payment_no"));
                            withdrawal.setState(2);
                            WithdrawalServiceImpl.this.updateById(withdrawal);
                            Timer timer = timerMap.get(withdrawal.getSerialNo());
                            timer.cancel();
                        }else{
                            UserInfo userInfo = userInfoService.selectById(withdrawal.getUserId());
                            userInfo.setBalance(new BigDecimal(userInfo.getBalance()).add(new BigDecimal(withdrawal.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
                            userInfoService.updateById(userInfo);
                            withdrawal.setState(3);
                            WithdrawalServiceImpl.this.updateById(withdrawal);

                            Timer timer = timerMap.get(withdrawal.getSerialNo());
                            timer.cancel();
                        }
                    }catch (Exception e){
                        e.printStackTrace();
                    }
                }
            };
            Timer timer = new Timer();
            timer.schedule(timerTask, 1000, 10000);//1秒钟后间隔10秒钟查询交易结果
            timerMap.put(withdrawal.getSerialNo(), timer);
        }
        if(state == 2){//审核拒绝
            withdrawal.setState(3);
            this.updateById(withdrawal);
        }
        return ResultUtil.success();
    }
}