package com.java110.core.factory;
|
|
import com.java110.dto.communitySetting.CommunitySettingDto;
|
import com.java110.intf.community.ICommunitySettingInnerServiceSMO;
|
import com.java110.utils.cache.BaseCache;
|
import com.java110.utils.factory.ApplicationContextFactory;
|
import com.java110.utils.util.SerializeUtil;
|
import com.java110.utils.util.StringUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.NoSuchBeanDefinitionException;
|
import redis.clients.jedis.Jedis;
|
|
import java.util.List;
|
|
public class CommunitySettingFactory extends BaseCache {
|
|
//日志
|
private static Logger logger = LoggerFactory.getLogger(CommunitySettingFactory.class);
|
|
public static final String KEY_FEE_SCALE = "SCALE";
|
public static final int DEFAULE_FEE_SCALE = 2;
|
|
|
/**
|
* 查询设置值
|
*
|
* @param communityId
|
* @param key
|
* @return
|
*/
|
public static String getValue(String communityId, String key) {
|
Jedis redis = null;
|
CommunitySettingDto communitySettingDto = null;
|
try {
|
redis = getJedis();
|
Object object = SerializeUtil.unserialize(redis.get((communityId + "_" + key + "_community_setting").getBytes()));
|
if (object == null) {//这里存在并发问题，但是 等于查询了多次 然后多次写缓存，作者认为 这种应该比加全局锁效率高些
|
communitySettingDto = getCommunitySettingFromDb(communityId, key, redis);
|
} else {
|
communitySettingDto = (CommunitySettingDto) object;
|
}
|
} finally {
|
if (redis != null) {
|
redis.close();
|
}
|
}
|
|
if (communitySettingDto == null) {
|
return null;
|
}
|
|
return communitySettingDto.getSettingValue();
|
}
|
|
/**
|
* 查询设置值
|
*
|
* @param communityId
|
* @param key
|
* @return
|
*/
|
public static String getRemark(String communityId, String key) {
|
Jedis redis = null;
|
CommunitySettingDto communitySettingDto = null;
|
try {
|
redis = getJedis();
|
Object object = SerializeUtil.unserialize(redis.get((communityId + "_" + key + "_community_setting").getBytes()));
|
if (object == null) {//这里存在并发问题，但是 等于查询了多次 然后多次写缓存，作者认为 这种应该比加全局锁效率高些
|
communitySettingDto = getCommunitySettingFromDb(communityId, key, redis);
|
} else {
|
communitySettingDto = (CommunitySettingDto) object;
|
}
|
} finally {
|
if (redis != null) {
|
redis.close();
|
}
|
}
|
|
if (communitySettingDto == null) {
|
return null;
|
}
|
|
return communitySettingDto.getRemark();
|
}
|
|
public static CommunitySettingDto getCommunitySettingFromDb(String communityId, String key) {
|
Jedis redis = null;
|
try {
|
redis = getJedis();
|
return getCommunitySettingFromDb(communityId, key, redis);
|
} finally {
|
if (redis != null) {
|
redis.close();
|
}
|
}
|
}
|
|
private static CommunitySettingDto getCommunitySettingFromDb(String communityId, String key, Jedis redis) {
|
ICommunitySettingInnerServiceSMO communitySettingInnerServiceSMOImpl = null;
|
try {
|
communitySettingInnerServiceSMOImpl = ApplicationContextFactory.getBean(ICommunitySettingInnerServiceSMO.class.getName(), ICommunitySettingInnerServiceSMO.class);
|
} catch (NoSuchBeanDefinitionException e) {
|
communitySettingInnerServiceSMOImpl = ApplicationContextFactory.getBean("communitySettingInnerServiceSMOImpl", ICommunitySettingInnerServiceSMO.class);
|
}
|
CommunitySettingDto communitySettingDto = new CommunitySettingDto();
|
communitySettingDto.setCommunityId(communityId);
|
communitySettingDto.setSettingKey(key);
|
List<CommunitySettingDto> communitySettingDtos = communitySettingInnerServiceSMOImpl.queryCommunitySettings(communitySettingDto);
|
if (communitySettingDtos == null || communitySettingDtos.size() < 1) {
|
return null;
|
}
|
|
redis.set((communityId + "_" + key + "_community_setting").getBytes(), SerializeUtil.serialize(communitySettingDtos.get(0)));
|
return communitySettingDtos.get(0);
|
}
|
|
/**
|
* 手工保存数据
|
*
|
* @param communitySettingDto
|
*/
|
public static void saveCommunitySetting(CommunitySettingDto communitySettingDto) {
|
Jedis redis = null;
|
try {
|
redis = getJedis();
|
redis.set((communitySettingDto.getCommunityId() + "_" + communitySettingDto.getSettingKey() + "_community_setting").getBytes(), SerializeUtil.serialize(communitySettingDto));
|
} finally {
|
if (redis != null) {
|
redis.close();
|
}
|
}
|
}
|
|
/**
|
* 查询设置值
|
*
|
* @param communityId
|
* @param key
|
* @return
|
*/
|
public static CommunitySettingDto getCommunitySetting(String communityId, String key) {
|
Jedis redis = null;
|
CommunitySettingDto communitySettingDto = null;
|
try {
|
redis = getJedis();
|
Object object = SerializeUtil.unserialize(redis.get((communityId + "_" + key + "_community_setting").getBytes()));
|
if (object == null) { //这里存在并发问题，但是 等于查询了多次 然后多次写缓存，作者认为 这种应该比加全局锁效率高些
|
communitySettingDto = getCommunitySettingFromDb(communityId, key, redis);
|
} else {
|
communitySettingDto = (CommunitySettingDto) object;
|
}
|
} finally {
|
if (redis != null) {
|
redis.close();
|
}
|
}
|
|
if (communitySettingDto == null) {
|
return null;
|
}
|
|
return communitySettingDto;
|
}
|
|
/**
|
* 查询小数点 位数
|
*
|
* @param communityId
|
* @return
|
*/
|
public static int getFeeScale(String communityId) {
|
String scale = getValue(communityId, KEY_FEE_SCALE);
|
if (StringUtil.isEmpty(scale)) {
|
//防止每次都需要 查询数据库 增加 压力，这里像缓存中写入默认值
|
CommunitySettingDto communitySettingDto = new CommunitySettingDto();
|
communitySettingDto.setCommunityId(communityId);
|
communitySettingDto.setSettingKey(KEY_FEE_SCALE);
|
communitySettingDto.setSettingName("小数点位数");
|
communitySettingDto.setCsId("-1");
|
communitySettingDto.setSettingValue(DEFAULE_FEE_SCALE + "");
|
communitySettingDto.setSettingType(CommunitySettingDto.SETTING_TYPE_FEE);
|
communitySettingDto.setRemark("费用计算小数点位数,0至4整数");
|
saveCommunitySetting(communitySettingDto);
|
return DEFAULE_FEE_SCALE;
|
}
|
|
if (!StringUtil.isInteger(scale)) {
|
return DEFAULE_FEE_SCALE;
|
}
|
|
int scaleInt = Integer.parseInt(scale);
|
if (scaleInt > 4 || scaleInt < 0) {
|
return DEFAULE_FEE_SCALE;
|
}
|
return scaleInt;
|
}
|
}
|
