package com.nq.service.impl;


import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.nq.common.ServerResponse;
import com.nq.dao.FundsAppendMapper;
import com.nq.dao.FundsApplyMapper;
import com.nq.dao.FundsLeverMapper;
import com.nq.pojo.FundsAppend;
import com.nq.pojo.FundsApply;
import com.nq.pojo.FundsLever;
import com.nq.pojo.User;
import com.nq.service.IFundsAppendService;
import com.nq.service.IUserService;
import com.nq.utils.timeutil.DateTimeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

/**
 * 配资追加申请
 * @author lr
 * @date 2020/07/24
 */
@Service("IFundsAppendService")
public class FundsAppendServiceImpl implements IFundsAppendService {

    @Resource
    private FundsAppendMapper fundsAppendMapper;

    @Autowired
    IUserService iUserService;

    @Autowired
    FundsApplyMapper fundsApplyMapper;

    @Autowired
    FundsLeverMapper fundsLeverMapper;


    @Override
    public int insert(FundsAppend model) {
        int ret = 0;
        if (model == null) {
            return 0;
        }
        ret = fundsAppendMapper.insert(model);
        return ret;
    }

    @Override
    public int update(FundsAppend model) {
        int ret = fundsAppendMapper.update(model);
        return ret>0 ? ret: 0;
    }

    /**
     * 配资追加申请-保存
     */
    @Transactional
    public ServerResponse save(FundsAppend model, HttpServletRequest request) {
        int ret = 0;
        if(model.getApplyId() == null || model.getApplyId() == 0){
            return ServerResponse.createByErrorMsg("操作异常，请稍后再试");
        }
        FundsApply fundsApply = fundsApplyMapper.load(model.getApplyId());
        if(fundsApply == null){
            return ServerResponse.createByErrorMsg("子账户不存在，请稍后再试");
        }
        User user = this.iUserService.getCurrentRefreshUser(request);
//        if(user == null){
//            return ServerResponse.createBySuccessMsg("请登录后操作");
//        }
        //修改+审核
        if(model!=null && model.getId()>0){
            FundsAppend fundsAppend = fundsAppendMapper.load(model.getId());
            model.setAuditTime(DateTimeUtil.getCurrentDate());
            SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//设置日期格式
            // 追加类型：1、扩大配资，2、追加保证金，3、续期，4、终止操盘，5、提前盈利
            if(fundsAppend.getAppendType() == 1){

            } else if(fundsAppend.getAppendType() == 3){
                String endtime = df.format(fundsApply.getEndTime());
                Date endDate = DateTimeUtil.strToDate(endtime);
                endDate = DateTimeUtil.addDay(endDate, fundsAppend.getAppendCycle());
                model.setEndTime(endDate);
                model.setTradersCycle(fundsAppend.getTradersCycle() + fundsAppend.getAppendCycle());
                //修改子账户结束时间
                fundsApply.setEndTime(endDate);
                fundsApplyMapper.update(fundsApply);
                //修改用户余额，待完善

            } else if(fundsAppend.getAppendType() == 4){
                //修改子账户状态
                if(model.getStatus() == 1){
                    fundsApply.setStatus(4);
                    fundsApplyMapper.update(fundsApply);
                }
                //修改用户余额，待完善

            }
            ret = fundsAppendMapper.update(model);
        } else{// 提交申请
            model.setUserId(user.getId());
            model.setUserName(user.getRealName());
            model.setUserPhone(user.getPhone());
            model.setMargin(fundsApply.getMargin());
            model.setFundsAmount(fundsApply.getFundsAmount());
            model.setLever(fundsApply.getLever());
            model.setManageFee(fundsApply.getManageFee());
            model.setTotalTradingAmount(fundsApply.getTotalTradingAmount());
            model.setLineWarning(fundsApply.getLineWarning());
            model.setLineUnwind(fundsApply.getLineUnwind());
            model.setRatioWarning(fundsApply.getRatioWarning());
            model.setRatioUnwind(fundsApply.getRatioUnwind());
            model.setEndTime(fundsApply.getEndTime());

            // 追加类型：1、扩大配资，2、追加保证金，3、续期，4、终止操盘，5、提前盈利
            if(model.getAppendType() == 1){
                model.setTradersCycle(fundsApply.getTradersCycle());
                FundsLever fundsLever = fundsLeverMapper.getLeverRateInfo(1, fundsApply.getLever());
                BigDecimal appendServiceFee = model.getAppendMargin().multiply(fundsLever.getManageRate());
                model.setAppendServiceFee(appendServiceFee);
                model.setPayAmount(model.getAppendMargin());
            } else if(model.getAppendType() == 2) {
                model.setTradersCycle(fundsApply.getTradersCycle());
                model.setPayAmount(model.getAppendMargin());
            } else if(model.getAppendType() == 3){
                model.setTradersCycle(model.getAppendCycle());
                model.setPayAmount(model.getAppendServiceFee());
            } else if(model.getAppendType() == 4){
                int isAppendEnd = fundsAppendMapper.isAppendEnd(model.getApplyId());
                if(isAppendEnd>0){
                    return ServerResponse.createByErrorMsg("申请已提交，无需重复操作！");
                }
                model.setTradersCycle(model.getAppendCycle());
                model.setPayAmount(model.getAppendServiceFee());
            }
            ret = fundsAppendMapper.insert(model);
        }
        if(ret>0){
            return ServerResponse.createBySuccessMsg("操作成功");
        }
        return ServerResponse.createByErrorMsg("操作失败");
    }

    /*配资追加申请-查询列表*/
    @Override
    public ServerResponse<PageInfo> getList(int pageNum, int pageSize, String keyword, Integer status, Integer userId, Integer appendType, HttpServletRequest request){
        PageHelper.startPage(pageNum, pageSize);
        List<FundsAppend> listData = this.fundsAppendMapper.pageList(pageNum, pageSize, keyword, status, userId, appendType);
        PageInfo pageInfo = new PageInfo(listData);
        pageInfo.setList(listData);
        return ServerResponse.createBySuccess(pageInfo);
    }

    /*配资追加申请-查询详情*/
    @Override
    public ServerResponse getDetail(int id) {
        return ServerResponse.createBySuccess(this.fundsAppendMapper.load(id));
    }

}