package jnpf.base.service.impl;


import cn.hutool.core.collection.CollUtil;
import com.baomidou.dynamic.datasource.annotation.DSTransactional;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import jnpf.base.entity.EmailConfigEntity;
import jnpf.base.entity.SysConfigEntity;
import jnpf.base.mapper.SysconfigMapper;
import jnpf.base.model.systemconfig.UserFieldConfig;
import jnpf.base.service.SuperServiceImpl;
import jnpf.base.service.SysconfigService;
import jnpf.message.model.mail.MailAccount;
import jnpf.message.model.mail.Pop3Util;
import jnpf.message.model.mail.SmtpUtil;
import jnpf.model.BaseSystemInfo;
import jnpf.model.SocialsSysConfig;
import jnpf.util.CacheKeyUtil;
import jnpf.util.JsonUtil;
import jnpf.util.RedisUtil;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.UUID;
import java.util.stream.Collectors;

/**
 * 系统配置
 *
 * @author JNPF开发平台组
 * @version V3.1.0
 * @copyright 引迈信息技术有限公司
 * @date 2019年9月27日 上午9:18
 */
@Service
@RequiredArgsConstructor
public class SysconfigServiceImpl extends SuperServiceImpl<SysconfigMapper, SysConfigEntity> implements SysconfigService {

    private static final String USER_FIELD_CATEGORY = "UserFieldConfig";
    private static final String USER_FIELD_KEY = "permission.user.fields";
    private static final Set<String> FORM_FIELDS = Set.of("account", "realName", "jobNumber", "positionId", "gender", "email",
            "mobilePhone", "ranks", "sortCode", "enabledMark", "description", "headIcon", "nation", "nativePlace",
            "certificatesType", "entryDate", "certificatesNumber", "education", "birthday", "telePhone", "landline",
            "urgentContacts", "urgentTelePhone", "postalAddress", "roleId");
    private static final Set<String> LIST_FIELDS = Set.of("account", "realName", "jobNumber", "gender", "mobilePhone",
            "position", "creatorTime", "lastModifyTime", "sortCode", "enabledMark", "disableTime");
    private static final Set<String> CORE_FIELDS = Set.of("account", "realName");

    @Override
    public UserFieldConfig getUserFieldConfig() {
        SysConfigEntity entity = getOne(new QueryWrapper<SysConfigEntity>().lambda()
                .eq(SysConfigEntity::getCategory, USER_FIELD_CATEGORY).eq(SysConfigEntity::getFkey, USER_FIELD_KEY), false);
        return entity == null ? new UserFieldConfig() : UserFieldConfig.fromCompactString(entity.getValue());
    }

    @Override
    public void saveUserFieldConfig(UserFieldConfig config) {
        if (config == null) throw new IllegalArgumentException("用户字段配置不能为空");
        validateFormFields(config.getForm());
        if (config.getList() == null || !config.getList().keySet().equals(LIST_FIELDS)
                || config.getList().values().stream().anyMatch(rule -> rule == null || rule.isRequired())
                || config.getList().values().stream().noneMatch(UserFieldConfig.FieldRule::isVisible)) {
            throw new IllegalArgumentException("列表字段配置无效");
        }
        SysConfigEntity entity = getOne(new QueryWrapper<SysConfigEntity>().lambda()
                .eq(SysConfigEntity::getCategory, USER_FIELD_CATEGORY).eq(SysConfigEntity::getFkey, USER_FIELD_KEY), false);
        if (entity == null) {
            entity = new SysConfigEntity();
            entity.setId(UUID.randomUUID().toString().replace("-", ""));
            entity.setCategory(USER_FIELD_CATEGORY);
            entity.setFkey(USER_FIELD_KEY);
            entity.setFullName("用户管理字段配置");
        }
        entity.setValue(config.toCompactString());
        saveOrUpdate(entity);
    }

    private void validateFormFields(Map<String, UserFieldConfig.FieldRule> fields) {
        if (fields == null || !fields.keySet().equals(FORM_FIELDS)) {
            throw new IllegalArgumentException("表单字段配置无效");
        }
        for (Map.Entry<String, UserFieldConfig.FieldRule> entry : fields.entrySet()) {
            UserFieldConfig.FieldRule rule = entry.getValue();
            if (rule == null || (rule.isRequired() && !rule.isVisible())
                    || (CORE_FIELDS.contains(entry.getKey()) && (!rule.isVisible() || !rule.isRequired()))) {
                throw new IllegalArgumentException("字段配置无效: " + entry.getKey());
            }
        }
    }


    public static final String SYS_CONFIG ="SysConfig";
    public static final String MP_CONFIG ="MPConfig";
    public static final String QYH_CONFIG ="QYHConfig";

    private final RedisUtil redisUtil;

    private final CacheKeyUtil cacheKeyUtil;

    private final Pop3Util pop3Util;

    @Override
    public List<SysConfigEntity> getList(String type) {
        List<SysConfigEntity> list = new ArrayList<>();
        if ("WeChat".equals(type)) {
            QueryWrapper<SysConfigEntity> queryWrapper = new QueryWrapper<>();
            list = this.list(queryWrapper).stream().filter(t -> QYH_CONFIG.equals(t.getCategory()) || MP_CONFIG.equals(t.getCategory())).collect(Collectors.toList());
        }
        if (SYS_CONFIG.equals(type)) {
            QueryWrapper<SysConfigEntity> queryWrapper = new QueryWrapper<>();
            list = this.list(queryWrapper).stream().filter(t -> !QYH_CONFIG.equals(t.getCategory()) && !MP_CONFIG.equals(t.getCategory())
                    && !USER_FIELD_CATEGORY.equals(t.getCategory())).collect(Collectors.toList());
        }
        return list;
    }

    @Override
    public BaseSystemInfo getWeChatInfo() {
        Map<String, String> objModel = new HashMap<>(16);
        List<SysConfigEntity> list = this.getList("WeChat");
        for (SysConfigEntity entity : list) {
            objModel.put(entity.getFkey(), entity.getValue());
        }
        return JsonUtil.getJsonToBean(objModel, BaseSystemInfo.class);
    }

    @Override
    public BaseSystemInfo getSysInfo() {
        String cacheKey = cacheKeyUtil.getSystemInfo();
        if (redisUtil.exists(cacheKey)) {
            String json = String.valueOf(redisUtil.getString(cacheKey));
            return JsonUtil.getJsonToBean(json, BaseSystemInfo.class);
        }
        Map<String, String> objModel = new HashMap<>(16);
        List<SysConfigEntity> list = this.getList(SYS_CONFIG);
        for (SysConfigEntity entity : list) {
            objModel.put(entity.getFkey(), entity.getValue());
        }
        BaseSystemInfo baseSystemInfo = JsonUtil.getJsonToBean(objModel, BaseSystemInfo.class);
        redisUtil.insert(cacheKey, JsonUtil.getObjectToString(baseSystemInfo));
        return baseSystemInfo;
    }

    @Override
    @DSTransactional
    public void save(List<SysConfigEntity> entitys) {
        String cacheKey = cacheKeyUtil.getSystemInfo();
        redisUtil.remove(cacheKey);
        this.baseMapper.deleteFig();
        for (SysConfigEntity entity : entitys) {
            entity.setCategory(SYS_CONFIG);
            this.baseMapper.insert(entity);
        }
    }

    @Override
    @DSTransactional
    public boolean saveMp(List<SysConfigEntity> entitys) {
        String cacheKey = cacheKeyUtil.getWechatConfig();
        int flag = 0;
        redisUtil.remove(cacheKey);
        this.baseMapper.deleteMpFig();
        for (SysConfigEntity entity : entitys) {
            entity.setCategory(MP_CONFIG);
            if (this.baseMapper.insert(entity) > 0) {
                flag++;
            }
        }
        return entitys.size() == flag;
    }

    @Override
    @DSTransactional
    public void saveQyh(List<SysConfigEntity> entitys) {
        String cacheKey = cacheKeyUtil.getWechatConfig();
        redisUtil.remove(cacheKey);
        this.baseMapper.deleteQyhFig();
        for (SysConfigEntity entity : entitys) {
            entity.setCategory(QYH_CONFIG);
            this.baseMapper.insert(entity);
        }
    }

    @Override
    public String checkLogin(EmailConfigEntity configEntity) {
        MailAccount mailAccount = new MailAccount();
        mailAccount.setAccount(configEntity.getAccount());
        mailAccount.setPassword(configEntity.getPassword());
        mailAccount.setPop3Host(configEntity.getPop3Host());
        mailAccount.setPop3Port(configEntity.getPop3Port());
        mailAccount.setSmtpHost(configEntity.getSmtpHost());
        mailAccount.setSmtpPort(configEntity.getSmtpPort());
        mailAccount.setSsl("1".equals(String.valueOf(configEntity.getEmailSsl())));
        if (mailAccount.getSmtpHost() != null) {
            return SmtpUtil.checkConnected(mailAccount);
        }
        if (mailAccount.getPop3Host() != null) {
            return pop3Util.checkConnected(mailAccount);
        }
        return "false";
    }

    @Override
    public String getValueByKey(String keyStr) {
        QueryWrapper<SysConfigEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(SysConfigEntity::getFkey, keyStr);
        List<SysConfigEntity> list = list(queryWrapper);
        if (CollUtil.isNotEmpty(list)) {
            return list.get(0).getValue();
        }
        return null;
    }

    @Override
    public SocialsSysConfig getSocialsConfig() {
        String cacheKey = cacheKeyUtil.getSocialsConfig();
        if (redisUtil.exists(cacheKey)) {
            String json = String.valueOf(redisUtil.getString(cacheKey));
            return JsonUtil.getJsonToBean(json, SocialsSysConfig.class);
        }
        Map<String, String> objModel = new HashMap<>();
        QueryWrapper<SysConfigEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(SysConfigEntity::getCategory, "SocialsConfig");
        List<SysConfigEntity> configList = this.list(queryWrapper);
        for (SysConfigEntity entity : configList) {
            objModel.put(entity.getFkey(), entity.getValue());
        }
        SocialsSysConfig config = JsonUtil.getJsonToBean(objModel, SocialsSysConfig.class);
        redisUtil.insert(cacheKey, JsonUtil.getObjectToString(config));
        return config;
    }

    @Override
    public void saveSocials(List<SysConfigEntity> entitys) {
        String cacheKey = cacheKeyUtil.getSocialsConfig();
        redisUtil.remove(cacheKey);
        QueryWrapper<SysConfigEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(SysConfigEntity::getCategory, "SocialsConfig");
        this.remove(queryWrapper);
        for (SysConfigEntity entity : entitys) {
            this.baseMapper.insert(entity);
        }
    }
}