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

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.admin.model.MoneylogListModel;
import com.yami.trading.admin.model.channelBlockchain.ChannelBlockchainAddModel;
import com.yami.trading.admin.model.channelBlockchain.ChannelBlockchainDeleteModel;
import com.yami.trading.admin.model.channelBlockchain.ChannelBlockchainListModel;
import com.yami.trading.admin.model.channelBlockchain.ChannelBlockchainUpdateModel;
import com.yami.trading.bean.model.ChannelBlockchain;
import com.yami.trading.bean.model.Log;
import com.yami.trading.bean.user.dto.MoneyLogDto;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.domain.Result;
import com.yami.trading.common.exception.BusinessException;
import com.yami.trading.common.util.DateUtil;
import com.yami.trading.common.util.IPHelper;
import com.yami.trading.common.util.IpUtil;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.ChannelBlockchainService;
import com.yami.trading.service.system.LogService;
import com.yami.trading.sys.model.SysUser;
import com.yami.trading.sys.service.SysUserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.http.HttpServletRequest;
import javax.validation.Valid;
import java.util.Date;
import java.util.List;

@RestController
@CrossOrigin
@RequestMapping("channelBlockchain")
@Api(tags = "区块链充值地址维护")
public class ChannelBlockchainController {
    @Autowired
    ChannelBlockchainService channelBlockchainService;
    @Autowired
    SysUserService sysUserService;
    @Autowired
    LogService logService;

    @ApiOperation(value = "列表")
    @PostMapping("list")
    public Result<Page<ChannelBlockchain>> list(@RequestBody @Valid ChannelBlockchainListModel model) {
        Page<ChannelBlockchain> page = new Page(model.getCurrent(), model.getSize());
        LambdaQueryWrapper<ChannelBlockchain> lambdaQueryWrapper = Wrappers.<ChannelBlockchain>query().lambda();
        if (!StringUtils.isNullOrEmpty(model.getBlockchainName())) {
            lambdaQueryWrapper.like(ChannelBlockchain::getBlockchainName, model.getBlockchainName());
        }
        if (!StringUtils.isNullOrEmpty(model.getCoin())) {
            lambdaQueryWrapper.like(ChannelBlockchain::getCoin, model.getCoin());
        }
        channelBlockchainService.page(page, lambdaQueryWrapper);
        return Result.ok(page);
    }

    /**
     * 新增 区块链充值地址
     * <p>
     * blockchain_name 链名称
     * coin 币种 BTC USDT ETH
     * address 充值地址
     * img 充值地址二维码
     */
    @PostMapping("add")
    @ApiOperation("新增 区块链充值地址")
    public Result add(@RequestBody @Valid ChannelBlockchainAddModel model) {
        String blockchain_name = model.getBlockchainName();
        String coin = model.getCoin();
        String address = model.getAddress();
        String img = "1";
        String error = this.verif(model.getBlockchainName(), model.getCoin(), address, img);
        if (!StringUtils.isNullOrEmpty(error)) {
            throw new BusinessException(error);
        }
        ChannelBlockchain channelBlockchain = new ChannelBlockchain();
        channelBlockchain.setBlockchain_name(blockchain_name);
        channelBlockchain.setCoin(coin);
        channelBlockchain.setAddress(address);
        channelBlockchain.setImg("");
        sysUserService.checkSuperGoogleAuthCode(model.getSuperGoogleAuthCode());
        sysUserService.checkSafeWord(model.getSafeword());
        SysUser sysUser = sysUserService.getById(SecurityUtils.getSysUser().getUserId());
        this.channelBlockchainService.save(channelBlockchain);
        String log = "新增地址，名称[" + channelBlockchain.getBlockchain_name() + "]，地址[" + channelBlockchain.getAddress() + "]" + "币种["
                + channelBlockchain.getCoin() + "]，图片[" + channelBlockchain.getImg() + "]，" + "ip[" + IPHelper.getIpAddr() + "]";
        saveLog(sysUser, sysUser.getUsername(), log);
//        sendCodeToSysUsers(sec, userName, "新增区块链地址地址", "用户[" + userName + "],新增区块链地址地址");
        return Result.succeed();
    }

    public void saveLog(SysUser secUser, String operator, String context) {
        Log log = new Log();
        log.setCategory(Constants.LOG_CATEGORY_OPERATION);
        log.setOperator(operator);
        log.setUsername(secUser.getUsername());
        log.setUserId(secUser.getUserId().toString());
        log.setLog(context);
        log.setCreateTime(new Date());
        logService.save(log);
    }

    /**
     * 修改 区块链充值地址
     * <p>
     * blockchain_name 链名称
     * coin 币种 BTC USDT ETH
     * address 充值地址
     * img 充值地址二维码
     */
    @ApiOperation("修改 区块链充值地址")
    @PostMapping("update")
    public Result update(@RequestBody @Valid ChannelBlockchainUpdateModel model) {
        String id = model.getId();
        String blockchain_name = model.getBlockchainName();
        String coin = model.getCoin();
        String address = model.getAddress();
        ChannelBlockchain channelBlockchain = this.channelBlockchainService.getById(id);
        ChannelBlockchain old = new ChannelBlockchain();
        BeanUtils.copyProperties(channelBlockchain, old);
        String error = this.verif(blockchain_name, coin, address, null);
        if (!StringUtils.isNullOrEmpty(error)) {
            throw new BusinessException(error);
        }
        channelBlockchain.setBlockchain_name(blockchain_name);
        channelBlockchain.setCoin(coin);
//        if (!address.equals(channelBlockchain.getAddress())) {
//            channelBlockchain.setAddress(address);
//            img = this.qRProducerService.generate(address);
//            channelBlockchain.setImg(img);
//        }
        sysUserService.checkSuperGoogleAuthCode(model.getSuperGoogleAuthCode());
        sysUserService.checkSafeWord(model.getSafeword());
        channelBlockchainService.updateById(channelBlockchain);
        String log = "区块链充值地址修改。原名称[" + old.getBlockchain_name() + "]，原地址[" + old.getAddress() + "]" + "原币种["
                + old.getCoin() + "]，原图片[" + old.getImg() + "]。" + "修改后，新名称[" + channelBlockchain.getBlockchain_name() + "]，新地址["
                + channelBlockchain.getAddress() + "]" + "新币种[" + channelBlockchain.getCoin() + "]，" + "ip["
                + IPHelper.getIpAddr() + "]]";
        SysUser sysUser = sysUserService.getById(SecurityUtils.getSysUser().getUserId());
        saveLog(sysUser, sysUser.getUsername(), log);
//        sendCodeToSysUsers(sec, userName, "区块链充值地址修改", "用户[" + userName + "],区块链充值地址修改");
        return Result.succeed();
    }

    /**
     * 删除 区块链充值地址
     */
    @PostMapping("delete")
    @ApiOperation(" 删除 区块链充值地址")
    public Result toDelete(@RequestBody @Valid ChannelBlockchainDeleteModel request) {
      ChannelBlockchain entity=    channelBlockchainService.getById(request.getId());

        channelBlockchainService.removeById(entity.getUuid());

        String log = "删除地址，名称[" + entity.getBlockchain_name() + "]，地址[" + entity.getAddress() + "]" + "币种["
                + entity.getCoin() + "]，" + "ip[" + IPHelper.getIpAddr() + "]";
        SysUser sysUser = sysUserService.getById(SecurityUtils.getSysUser().getUserId());
        saveLog(sysUser, sysUser.getUsername(), log);
//        sendCodeToSysUsers(sec, userName, "区块链充值地址删除", "用户[" + userName + "],区块链充值地址删除");
        return Result.succeed();
    }

    private String verif(String blockchain_name, String coin, String address, String img) {
        if (StringUtils.isEmptyString(blockchain_name))
            return "请输入链名称";
        if (StringUtils.isEmptyString(coin))
            return "请输入币种";
        if (StringUtils.isEmptyString(address))
            return "请输入地址";
        return null;
    }
}