package com.yami.trading.admin.controller.syspara;

import javax.servlet.http.HttpServletRequest;
import javax.validation.Valid;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.StrUtil;
import com.google.common.collect.Lists;
import com.yami.trading.admin.controller.finance.AdminFinanceOrderController;
import com.yami.trading.admin.util.BackupUtil;
import com.yami.trading.bean.model.Log;
import com.yami.trading.bean.syspara.dto.SysparasDto;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.domain.Result;
import com.yami.trading.common.exception.YamiShopBindException;
import com.yami.trading.common.query.QueryWrapperGenerator;
import com.yami.trading.common.util.Arith;
import com.yami.trading.common.util.DateUtils;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.system.LogService;
import com.yami.trading.sys.service.SysLogService;
import com.yami.trading.sys.service.SysUserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.bean.syspara.domain.Syspara;
import com.yami.trading.bean.syspara.dto.SysparaDTO;
import com.yami.trading.bean.syspara.mapstruct.SysparaWrapper;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.bean.syspara.query.SysparaQuery;
import org.springframework.web.servlet.ModelAndView;

import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * 配置参数Controller
 *
 * @author lucas
 * @version 2023-03-17
 */
@Api(tags = "配置参数")
@RestController
@CrossOrigin
@Slf4j
@RequestMapping(value = "normal/adminSysparaAction!")
public class SysparaController {
    @Autowired
    private SysparaService sysparaService;
    @Autowired
    private SysparaWrapper sysparaWrapper;
    @Autowired
    private SysUserService sysUserService;
    @Autowired
    protected SysLogService sysLogService;

    @Autowired
    LogService logService;

    /**
     * 配置参数列表数据
     */
    @ApiOperation(value = "获取 系统参数（ROOT) 列表")
    @GetMapping("list.action")
    public Result<IPage<Syspara>> list(@RequestParam(required = false) String notes, Page<Syspara> page) throws Exception {
        SysparaQuery sysparaQuery = new SysparaQuery();
        if (StringUtils.isNotEmpty(notes)) {
            sysparaQuery.setNotes(notes);
        }
        sysparaQuery.setNotStype(3L);
        QueryWrapper queryWrapper = QueryWrapperGenerator.buildQueryCondition(sysparaQuery, SysparaQuery.class);
        queryWrapper.orderByDesc("code");
        IPage<Syspara> result = sysparaService.page(page, queryWrapper);
        return Result.ok(result);
    }

    /**
     * 配置参数列表数据
     */
    @ApiOperation(value = "获取 系统参数（ADMIN) 列表")
    @GetMapping("listAdmin.action")
    public Result<IPage<Syspara>> listAdmin(@RequestParam(required = false) String notesPara, Page<Syspara> page) throws Exception {
        SysparaQuery sysparaQuery = new SysparaQuery();
        if (StringUtils.isNotEmpty(notesPara)) {
            sysparaQuery.setNotes(notesPara);
        }
        QueryWrapper queryWrapper = QueryWrapperGenerator.buildQueryCondition(sysparaQuery, SysparaQuery.class);
        queryWrapper.in("stype", 1L, 2L);
        queryWrapper.orderByDesc("code");
        IPage<Syspara> result = sysparaService.page(page, queryWrapper);
        return Result.ok(result);
    }

    /**
     * 配置参数列表数据
     */
    @ApiOperation(value = "修改 系统参数admin 页面")
    @GetMapping("toUpdate.action")
    public Result<SysparasDto> toUpdate() throws Exception {
        List<Syspara> list = sysparaService.list();
        Map<String, String> map = list.stream()
                .filter(s -> s.getSvalue() != null)
                .collect(Collectors.toMap(Syspara::getCode, Syspara::getSvalue, (s1, s2) -> s2));
        SysparasDto sysparasDto = new SysparasDto();
        BeanUtil.fillBeanWithMap(map, sysparasDto, true);
        List<String> needMultipleProperties = Lists.newArrayList("",
                "", "withdraw_limit_turnover_percent", "futures_most_prfit_level"
        );//exchange_apply_order_buy_fee  exchange_apply_order_sell_fee
        for (String field : needMultipleProperties) {
            Object fieldValueObject = BeanUtil.getFieldValue(sysparasDto, field);
            System.out.println("field => " + field);
            System.out.println("fieldValueObject => " + fieldValueObject);
            if (fieldValueObject == null) {
                continue;
            }
            String fieldValue = fieldValueObject.toString();
            if (StrUtil.isBlank(fieldValue)) {
                continue;
            }
            BeanUtil.setFieldValue(sysparasDto, field, Arith.mul(fieldValue, "100"));
        }
        String withdraw_limit_time = sysparasDto.getWithdraw_limit_time();
        if (StringUtils.isNotBlank(withdraw_limit_time)) {
            String[] withdraw_time = withdraw_limit_time.split("-");
            sysparasDto.setWithdraw_limit_time_min(withdraw_time[0]);
            sysparasDto.setWithdraw_limit_time_max(withdraw_time[1]);
        }
        // 设置 usdt 的最低和最高限额
        if (sysparasDto.getWithdraw_limit_usdt() != null) {
            sysparasDto.setWithdraw_limit_dapp(sysparasDto.getWithdraw_limit_usdt());
        } else {
            sysparasDto.setWithdraw_limit_dapp(sysparasDto.getWithdraw_limit());
        }
        if (sysparasDto.getWithdraw_limit_max_usdt() != null) {
            sysparasDto.setWithdraw_limit_max(sysparasDto.getWithdraw_limit_max_usdt());
        } else {
            sysparasDto.setWithdraw_limit_max(sysparasDto.getWithdraw_limit_max());
        }
        return Result.ok(sysparasDto);
    }

    /**
     * 配置参数列表数据
     */
    @ApiOperation(value = "修改 系统参数admin ")
    @PostMapping("updateAdmin.action")
    public Result<String> updateAdmin(@Valid @RequestBody SysparasDto sysparasDto) throws Exception {
        verification(sysparasDto);
        verificationWithdraw(sysparasDto);
        verificationOthers(sysparasDto);
        sysUserService.checkSafeWord(sysparasDto.getLogin_safeword());
        List<String> needDivideProperties = Lists.newArrayList("",
                "", "withdraw_limit_turnover_percent", "futures_most_prfit_level"
        );
        //exchange_apply_order_buy_fee  exchange_apply_order_sell_fee
        for (String field : needDivideProperties) {
            Object fieldValueObject = BeanUtil.getFieldValue(sysparasDto, field);
            if (fieldValueObject == null) {
                continue;
            }
            String fieldValue = fieldValueObject.toString();
            if (StrUtil.isBlank(fieldValue)) {
                continue;
            }
            BeanUtil
                    .setFieldValue(sysparasDto, field, Arith.div(fieldValue, "100"));
        }
        String withdraw_limit_time_min = sysparasDto.getWithdraw_limit_time_min();
        String withdraw_limit_time_max = sysparasDto.getWithdraw_limit_time_max();
        if (!"".equals(withdraw_limit_time_min) && !"".equals(withdraw_limit_time_max)
                && isValidDate(withdraw_limit_time_min) && isValidDate(withdraw_limit_time_max)) {
            sysparasDto.setWithdraw_limit_time(withdraw_limit_time_min + "-" + withdraw_limit_time_max);
        } else {
            sysparasDto.setWithdraw_limit_time_min("");
            sysparasDto.setWithdraw_limit_time_max("");
        }
        sysparaService.updateSysparas(sysparasDto);
        //todo log
        return Result.ok("更新成功");
    }

    private void verification(SysparasDto sysparasDto) {
        if (StringUtils.isEmpty(sysparasDto.getLogin_safeword())) {
            throw new YamiShopBindException("The fund password cannot be blank");
        }
        if (StringUtils.isEmpty(sysparasDto.getSuper_google_auth_code())) {
            throw new YamiShopBindException("谷歌验证码不能为空");
        }
    }

    private void verificationWithdraw(SysparasDto sysparasDto) {
        if (StringUtils.isBlank(sysparasDto.getWithdraw_limit_num())) {
            throw new YamiShopBindException("withdraw_limit_num不能为空");
        }
        if (StringUtils.isBlank(sysparasDto.getWithdraw_limit())) {
            throw new YamiShopBindException("withdraw_limit不能为空");
        }
        if (StringUtils.isBlank(sysparasDto.getWithdraw_limit_turnover_percent())) {
            throw new YamiShopBindException("withdraw_limit_turnover_percent不能为空");
        }
        if (StringUtils.isBlank(sysparasDto.getWithdraw_limit_max())) {
            throw new YamiShopBindException("withdraw_limit_max不能为空");
        }
        if (StringUtils.isBlank(sysparasDto.getWithdraw_limit_dapp())) {
            throw new YamiShopBindException("withdraw_limit_dapp不能为空");
        }
        double withdraw_limit_num = Double.valueOf(sysparasDto.getWithdraw_limit_num());
        double withdraw_limit = Double.valueOf(sysparasDto.getWithdraw_limit());
        double withdraw_limit_turnover_percent = Double.valueOf(sysparasDto.getWithdraw_limit_turnover_percent());
        String withdraw_limit_time_min = sysparasDto.getWithdraw_limit_time_min();
        String withdraw_limit_time_max = sysparasDto.getWithdraw_limit_time_max();
        double withdraw_limit_max = Double.valueOf(sysparasDto.getWithdraw_limit_max());
        double withdraw_limit_dapp = Double.valueOf(sysparasDto.getWithdraw_limit_dapp());
        if (withdraw_limit_num < 0) {
            throw new YamiShopBindException("每日可提现次数不得小于0");
        }
        if (withdraw_limit < 0) {
            throw new YamiShopBindException("提现最低金额不得小于0");
        }
        if (withdraw_limit_turnover_percent < 0) {
            throw new YamiShopBindException("提现限制流水按百分币不得小于0");
        }
        if (StringUtils.isEmpty(withdraw_limit_time_min)) {
            throw new YamiShopBindException("最早提现时间不能为空");
        }
        if (StringUtils.isEmpty(withdraw_limit_time_max)) {
            throw new YamiShopBindException("最晚提现时间不能为空");
        }
        if (withdraw_limit_dapp < 0) {
            throw new YamiShopBindException("最低提现额度不得小于0");
        }
        if (withdraw_limit_max < withdraw_limit_dapp) {
            throw new YamiShopBindException("usdt提现最高限额小于最低限额");
        }
        // 设置usdt提现最低和最高限额
        sysparasDto.setWithdraw_limit_usdt(sysparasDto.getWithdraw_limit_dapp());
        sysparasDto.setWithdraw_limit_max_usdt(sysparasDto.getWithdraw_limit_max());
        sysparasDto.setWithdraw_limit_max(null);
        sysparasDto.setWithdraw_limit_dapp(null);
        sysparasDto.setWithdraw_limit(null);
    }

    private void verificationOthers(SysparasDto sysparasDto) {
        Double recharge_limit_min = Double.valueOf(sysparasDto.getRecharge_limit_min());
        Double recharge_limit_max = Double.valueOf(sysparasDto.getRecharge_limit_max());
        Double exchange_apply_order_buy_fee = Double.valueOf(sysparasDto.getExchange_apply_order_buy_fee());
        Double exchange_apply_order_sell_fee = Double.valueOf(sysparasDto.getExchange_apply_order_sell_fee());
        Double futures_most_prfit_level = Double.valueOf(sysparasDto.getFutures_most_prfit_level());
        if (recharge_limit_min < 0) {
            throw new YamiShopBindException("充值最低金额不得小于0");
        }
        if (recharge_limit_max < 0 || recharge_limit_max < recharge_limit_min) {
            throw new YamiShopBindException("充值最高金额不得小于0或小于充值最低金额");
        }
        if (exchange_apply_order_buy_fee < 0) {
            throw new YamiShopBindException("币币交易买入手续费不得小于0");
        }
        if (exchange_apply_order_sell_fee < 0) {
            throw new YamiShopBindException("币币交易卖出手续费不得小于0");
        }
        if (futures_most_prfit_level < 0) {
            throw new YamiShopBindException("交割合约赢率不得小于0");
        }
    }

    /**
     * 保存配置参数
     */
    @ApiOperation(value = "修改 系统参数（ROOT）/ 系统参数（ADMIN）")
    @PostMapping("update.action")
    public Result<String> update(@Valid @RequestBody SysparaDTO sysparaDTO) {
        Syspara syspara = this.sysparaService.find(sysparaDTO.getCode());
        if (syspara != null) {
            String notes = syspara.getNotes();
            String code = syspara.getCode();
            String oldValue = syspara.getSvalue();
            syspara.setSvalue(sysparaDTO.getValue());
            this.sysparaService.saveOrUpdate(syspara);

            // 操作日志
            Log log = new Log();
            log.setCategory(Constants.LOG_CATEGORY_OPERATION);
            log.setCreateTime(new Date());
            log.setOperator(SecurityUtils.getSysUser().getUsername());
//            log.setUsername(party.getUserName());
//            log.setOperator(operator_name);
//            log.setUserId(partyId);
            log.setLog("修改系统参数,模块:"+notes+"["+code+"]"+",修改之前:"+oldValue+",修改之后:"+sysparaDTO.getValue());
            logService.save(log);

            return Result.ok("修改成功");
        } else {
            throw new YamiShopBindException("参数不存在");
        }
    }

    /**
     * 根据Id获取配置参数数据
     */
    @ApiOperation(value = "根据Id获取配置参数数据")
    @GetMapping("queryById")
    public Result<SysparaDTO> queryById(String id) {
        return Result.ok(sysparaWrapper.toDTO(sysparaService.getById(id)));
    }

    /**
     * 保存配置参数
     */
    @ApiOperation(value = "保存配置参数")
    @PostMapping("save")
    public Result<String> save(@Valid @RequestBody SysparaDTO sysparaDTO) {
        //新增或编辑表单保存
        sysparaService.saveOrUpdate(sysparaWrapper.toEntity(sysparaDTO));
        return Result.ok("保存配置参数成功");
    }

    public class JobDelayThread implements Runnable {
        public void run() {
           BackupUtil.backup(sysLogService, sysparaService);
            log.info("local 备份");
        }
    }



    /**
     * 备份数据
     */
    @PostMapping("backupDB")
    public Result backup(HttpServletRequest request) {
        if (!"root".equals(SecurityUtils.getSysUser().getUsername())) {
            throw new YamiShopBindException("权限不足");
        }
        JobDelayThread thread = new JobDelayThread();
        Thread t = new Thread(thread);
        t.start();
        return Result.succeed();
    }

    /**
     * 删除配置参数
     */
    @ApiOperation(value = "删除配置参数")
    @DeleteMapping("delete")
    public Result<String> delete(String ids) {
        String idArray[] = ids.split(",");
        sysparaService.removeByIds(Lists.newArrayList(idArray));
        return Result.ok("删除配置参数成功");
    }

    public static boolean isValidDate(String str) {
        boolean convertSuccess = true;
        SimpleDateFormat format = new SimpleDateFormat("HH:mm:ss");
        try {
            format.setLenient(false);
            format.parse(str);
        } catch (ParseException e) {
            convertSuccess = false;
        }
        return convertSuccess;
    }
}