package org.sxkj.resource.cacel;

import org.apache.logging.log4j.util.Strings;
import org.springblade.core.cache.utils.CacheUtil;
import org.springblade.core.tool.utils.SpringUtil;
import org.sxkj.resource.entity.Oss;
import org.sxkj.resource.service.IOssService;
import static org.springblade.core.cache.constant.CacheConstant.*;

/**
 * 业务字典缓存工具类
 *
 * @author Chill
 */
public class OssCache {

	private static final String OSS_MIN_DEV_SN = "oss:dev:sn:";
	public static final String OSS_CODE = "oss:code:";

	private static IOssService ossService;

	private static IOssService getOssService() {
		if (ossService == null) {
			ossService = SpringUtil.getBean(IOssService.class);
		}
		return ossService;
	}

	/**
	 * 根据机场编号获取oss信息
	 *
	 * @param sn 机场编号
	 * @return DictBiz
	 */
	public static Oss getOssBySn(String sn) {
		// 如果sn 为空，直接查询默认的
		if (Strings.isBlank(sn)){
			return getDefaultOss();
		}
		Oss oss = CacheUtil.get(RESOURCE_CACHE, OSS_MIN_DEV_SN, sn, Oss.class);
		// 从数据库查
		if (oss == null) {
			Oss ossInfo = getOssService().getOssInfoByDevSn(sn);
			if (null==ossInfo){
				// 如果为空则查询默认的连接方式
				return getDefaultOss();
			}
			CacheUtil.put(RESOURCE_CACHE, OSS_MIN_DEV_SN, sn, ossInfo);
			return ossInfo;
		}
		// 返回
		return oss;
	}

	/**
	 * 获取默认的 oss 信息
	 * @return Oss
	 */
	public static Oss getDefaultOss() {
		String key = "000000";
		Oss oss = CacheUtil.get(RESOURCE_CACHE, OSS_CODE, key, () -> getOssService().getDefaultOss(key));
		return oss;
	}

}