package jnpf.integrate.job;

import cn.hutool.core.util.ObjectUtil;
import jnpf.base.UserInfo;
import jnpf.integrate.model.nodeJson.IntegrateModel;
import jnpf.util.JsonUtil;
import jnpf.util.RedisUtil;
import jnpf.util.StringUtil;
import lombok.extern.slf4j.Slf4j;


/**
 * @author JNPF开发平台组
 * @version V3.3.0 flowable
 * @copyright 引迈信息技术有限公司
 * @date 2022/6/15 17:37
 */
@Slf4j
public class IntegrateJobUtil {
    /**
     * 缓存key
     */
    public static final String WORKTIMEOUT_REDIS_KEY = "idgenerator_IntegrateList";

    /**
     * 缓存key
     */
    public static final String IDGENERATOR_REDIS_KEY = "idgenerator_IntegrateModel";

    /**
     * 缓存key
     */
    public static final String IDGENERATORID_REDIS_KEY = "idgenerator_id";

    public static IntegrateModel getModel(IntegrateModel model, RedisUtil redisUtil) {
        String id = model.getId();
        String hashValues = redisUtil.getHashValues(IDGENERATOR_REDIS_KEY, id);
        IntegrateModel integrateModel = StringUtil.isNotEmpty(hashValues) ? JsonUtil.getJsonToBean(hashValues, IntegrateModel.class) : null;
        return integrateModel;
    }

    public static void insertModel(IntegrateModel model, RedisUtil redisUtil) {
        String integrateId = model.getId();
        redisUtil.insertHash(IDGENERATOR_REDIS_KEY, integrateId, JsonUtil.getObjectToString(model));
        insertTenant(model, redisUtil);
    }

    public static void removeModel(IntegrateModel model, RedisUtil redisUtil) {
        redisUtil.removeHash(IDGENERATOR_REDIS_KEY, model.getId());
    }

    public static void insertTenant(IntegrateModel model, RedisUtil redisUtil) {
        String tenantId = StringUtil.isNotEmpty(model.getUserInfo().getTenantId()) ? model.getUserInfo().getTenantId() : "jnpf";
        UserInfo userInfo = model.getUserInfo();
        redisUtil.insertHash(WORKTIMEOUT_REDIS_KEY, tenantId, JsonUtil.getObjectToString(userInfo));
    }

    public static void removeTenant(String tenantId, RedisUtil redisUtil) {
        tenantId = StringUtil.isNotEmpty(tenantId) ? tenantId : "jnpf";
        redisUtil.removeHash(WORKTIMEOUT_REDIS_KEY, tenantId);
    }

    public static boolean getIntegrate(IntegrateModel model, RedisUtil redisUtil){
        String value = redisUtil.getHashValues(IDGENERATORID_REDIS_KEY, model.getId());
        return ObjectUtil.isNotEmpty(value);
    }

    public static void insertIntegrate(IntegrateModel model, RedisUtil redisUtil){
        redisUtil.insertHash(IDGENERATORID_REDIS_KEY, model.getId(), model.getId());
    }

    public static void removeIntegrate(IntegrateModel model, RedisUtil redisUtil){
        redisUtil.removeHash(IDGENERATORID_REDIS_KEY, model.getId());
    }

}