package com.nova.sankuai.service.impl;

import cn.hutool.json.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nova.sankuai.domain.api.aliyunIP.AliyunUtil;
import com.nova.sankuai.domain.dto.AddAppAudit;
import com.nova.sankuai.domain.dto.UpdateAppAudit;
import com.nova.sankuai.domain.entity.AppAudit;
import com.nova.sankuai.domain.vo.AppAuditVo;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.mapper.AppAuditMapper;
import com.nova.sankuai.infra.utils.IpUtil;
import com.nova.sankuai.infra.utils.PageRequest;
import com.nova.sankuai.infra.utils.PageUtil;
import com.nova.sankuai.infra.utils.RsaSecretUtils;
import com.nova.sankuai.service.IAppAuditService;
import lombok.AllArgsConstructor;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.Random;

/**
 * <p>
 * description
 * </p>
 *
 * @author denglb 2021/11/18
 */
@Service
@AllArgsConstructor
public class AppAuditServiceImpl extends ServiceImpl<AppAuditMapper, AppAudit> implements IAppAuditService {

    private final AliyunUtil aliyunUtil;

    private final AppAuditMapper appAuditMapper;

    private final PageUtil pageUtil;

    @Override
    public JSONObject audit(AppAudit audit, HttpServletRequest request) {
        JSONObject result = new JSONObject(true);
        result.putOnce("code", 200);
        result.putOnce("msg", "成功");
        String content = null;
        AppAudit one = this.getOne(new LambdaQueryWrapper<AppAudit>()
                .eq(AppAudit::getCompany, audit.getCompany())
                .eq(AppAudit::getPlatform, audit.getPlatform())
                .eq(AppAudit::getSource, audit.getSource())
                .eq(AppAudit::getVersion, audit.getVersion()));
        if (one == null) {
            result.putOnce("data", "true");
        } else {
            if (one.getType() != null && 0 == one.getType()) {
                result.putOnce("data", "false");
                content = one.getContent0();
            } else if (one.getType() != null && 1 == one.getType()) {
                result.putOnce("data", "true");
                content = one.getContent1();
            }
        }
        if (content == null) {
            content = "https://skfq.biaohekeji.com?appId=08d4ced2-d7d0-4509-b197-317f99c7f08f";
        }
        result.putOnce("content", content);
        result.putOnce("timestamp", System.currentTimeMillis());
        result.putOnce("chat", getRandomStr());
        result.putOnce("xcodesss", getRandomStr());
        result.putOnce("guidang", getRandomStr());
        result.putOnce("demoww", getRandomStr());
        result.putOnce("sahre", getRandomStr());
        if (one.getType() != null && 0 == one.getType() && StringUtils.isNotEmpty(one.getPublicKey())) {
            try {
                com.alibaba.fastjson.JSONObject jsonObject = new com.alibaba.fastjson.JSONObject();
                if (StringUtils.isNotEmpty(one.getOcrId())) {
                    jsonObject.put("id", one.getOcrId());
                }
                if (StringUtils.isNotEmpty(one.getOcrSecret())) {
                    jsonObject.put("secret", one.getOcrSecret());
                }
                if (StringUtils.isNotEmpty(one.getOcrLicense())) {
                    jsonObject.put("license", one.getOcrLicense());
                }
                if (jsonObject != null && !jsonObject.isEmpty()) {
                    byte[] bytes = RsaSecretUtils.publicEncrypt(jsonObject.toJSONString().getBytes(), one.getPublicKey());
                    String ocrinfo = RsaSecretUtils.byte2Base64(bytes);
                    result.putOnce("ocrinfo", ocrinfo);
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        String ip = IpUtil.getIpAddr(request);
        if (aliyunUtil.checkCounty(ip)) {
            result.replace("data", "true");
        }
//        if ("true".equals(result.get("data"))) {
//            result.replace("content", null);
//        }
        return result;
    }

    @Override
    public void addAppVersion(AddAppAudit addAppAudit) {
        String company = addAppAudit.getCompany().toLowerCase();
        String platform = addAppAudit.getPlatform().toLowerCase();
        String source = addAppAudit.getSource().toLowerCase();
        String version = addAppAudit.getVersion();
        addAppAudit.setCompany(company);
        addAppAudit.setPlatform(platform);
        addAppAudit.setSource(source);
        //判断是否已存在
        checkIsExistence(company, platform, source, version);
        AppAudit appAuditsave = new AppAudit();
        BeanUtils.copyProperties(addAppAudit, appAuditsave);
        if (appAuditsave.getType() == null) {
            appAuditsave.setType(1);
        }
        if (0 == appAuditsave.getType()) {
            appAuditsave.setContent0(addAppAudit.getContent());
        } else {
            appAuditsave.setContent1(addAppAudit.getContent());
        }
        boolean save = save(appAuditsave);
        if (!save) {
            throw new CommonException("新增失败");
        }
    }

    @Override
    public void updateAppVersion(UpdateAppAudit updateAppAudit) {
        AppAudit appAudit = getById(updateAppAudit.getId());
        if (appAudit == null) {
            throw new CommonException("未查询到App免审");
        }
        String company = updateAppAudit.getCompany().toLowerCase();
        String platform = updateAppAudit.getPlatform().toLowerCase();
        String source = updateAppAudit.getSource().toLowerCase();
        String version = updateAppAudit.getVersion();
        //判断是否已存在
        checkOtherIsExistence(updateAppAudit.getId(), company, platform, source, version);
        LambdaUpdateWrapper<AppAudit> lambdaUpdate = Wrappers.lambdaUpdate();
        lambdaUpdate.set(AppAudit::getType, updateAppAudit.getType());
        if (updateAppAudit.getType() == null) {
            lambdaUpdate.set(AppAudit::getType, 1);
        }
        if (0 == updateAppAudit.getType()) {
            lambdaUpdate.set(AppAudit::getContent0, updateAppAudit.getContent());
        } else {
            lambdaUpdate.set(AppAudit::getContent1, updateAppAudit.getContent());
        }
        lambdaUpdate.set(AppAudit::getVersion, updateAppAudit.getVersion());
        lambdaUpdate.set(AppAudit::getSource, source);
        lambdaUpdate.set(AppAudit::getPlatform, platform);
        lambdaUpdate.set(AppAudit::getCompany, company);
        lambdaUpdate.set(AppAudit::getNotes, updateAppAudit.getNotes());
        lambdaUpdate.eq(AppAudit::getId, updateAppAudit.getId());
        boolean update = update(lambdaUpdate);
        if (!update) {
            throw new CommonException("修改失败");
        }
    }

    @Override
    public void deleteAppVersion(Long id) {
        boolean removeById = removeById(id);
        if (!removeById) {
            throw new CommonException("删除失败");
        }
    }

    @Override
    public IPage<AppAuditVo> queryAppVersion(PageRequest pageRequest,String company, String content) {
        Page page = pageUtil.getPage(pageRequest);
        IPage<AppAuditVo> appAuditVoIPage = appAuditMapper.pageAppAudit(page, company, content);
        return appAuditVoIPage;
    }

    public static String getRandomStr() {
        String base = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
        Random random = new Random();
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < 10; i++) {
            int number = random.nextInt(base.length());
            sb.append(base.charAt(number));
        }
        return sb.toString();
    }

    public void checkIsExistence(String company, String platform, String source, String version) {
        AppAudit appAudit = getOne(new LambdaQueryWrapper<AppAudit>().eq(AppAudit::getCompany, company)
                .eq(AppAudit::getPlatform, platform).eq(AppAudit::getSource, source)
                .eq(AppAudit::getVersion, version));
        if (appAudit != null) {
            throw new CommonException("该配置已存在");
        }
    }

    public void checkOtherIsExistence(Long id, String company, String platform, String source, String version) {
        List<AppAudit> list = list(new LambdaQueryWrapper<AppAudit>().eq(AppAudit::getCompany, company)
                .eq(AppAudit::getPlatform, platform).eq(AppAudit::getSource, source)
                .eq(AppAudit::getVersion, version).ne(AppAudit::getId, id));
        if (list.size() > 0) {
            throw new CommonException("该配置已存在");
        }
    }
}