From f4a0f2acc63d7785eab108419a4e16f5f688cb95 Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期六, 18 一月 2020 12:06:27 +0800 Subject: [PATCH] 用户注册信息 --- fanli/src/main/java/com/yeshi/fanli/service/impl/config/ConfigServiceImpl.java | 102 +++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 90 insertions(+), 12 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/config/ConfigServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/config/ConfigServiceImpl.java index f748388..b9d37cc 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/config/ConfigServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/config/ConfigServiceImpl.java @@ -1,5 +1,6 @@ package com.yeshi.fanli.service.impl.config; +import java.util.ArrayList; import java.util.Date; import java.util.List; @@ -7,6 +8,7 @@ import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.Cacheable; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.yeshi.utils.entity.ProxyIP; @@ -15,10 +17,12 @@ import com.yeshi.fanli.dao.mybatis.ConfigMapper; import com.yeshi.fanli.entity.common.Config; import com.yeshi.fanli.entity.config.AppHomeFloatImg; +import com.yeshi.fanli.entity.system.ConfigKeyEnum; import com.yeshi.fanli.entity.xcx.XCXSettingConfig; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.StringUtil; +import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil; import net.sf.json.JSONArray; @@ -61,7 +65,24 @@ @Cacheable(value = "config", key = "#p0+'Str'") public String get(String key) { - List<Config> list = configMapper.listByKey(key); + List<Config> list = configMapper.listByKey(key, null, null); + if (list.size() == 0) { + return null; + } + String value = list.get(0).getValue(); + return value; + } + + @Cacheable(value = "config", key = "'getByVersion'+'-'+#key+'-'+#platform+'-'+#version ") + public String getByVersion(String key, String platform, int version) { + Integer minAndroidVersion = null; + Integer minIosVersion = null; + if ("android".equalsIgnoreCase(platform)) { + minAndroidVersion = version; + } else + minIosVersion = version; + + List<Config> list = configMapper.listByKey(key, minAndroidVersion, minIosVersion); if (list.size() == 0) { return null; } @@ -71,7 +92,7 @@ @Cacheable(value = "config", key = "#p0") public Config getConfig(String key) { - List<Config> list = configMapper.listByKey(key); + List<Config> list = configMapper.listByKey(key, null, null); if (list.size() == 0) { return null; } @@ -83,7 +104,7 @@ if (version == null) return false; - String value = get("xcx_setting"); + String value = get(ConfigKeyEnum.xcxSetting.getKey()); if (StringUtil.isNullOrEmpty(value)) return false; JSONArray array = JSONArray.fromObject(value); @@ -101,7 +122,7 @@ @Override public XCXSettingConfig getXCXInfoByGhId(String ghId) { - String value = get("xcx_setting"); + String value = get(ConfigKeyEnum.xcxSetting.getKey()); JSONArray array = JSONArray.fromObject(value); for (int i = 0; i < array.size(); i++) { XCXSettingConfig config = new Gson().fromJson(array.optJSONObject(i).toString(), XCXSettingConfig.class); @@ -114,7 +135,7 @@ @Override public String getH5Host() { - String value = get("h5_url"); + String value = get(ConfigKeyEnum.h5Url.getKey()); String[] sts = value.split(","); value = sts[(int) (sts.length * Math.random())]; return value.trim(); @@ -123,7 +144,7 @@ @Cacheable(value = "config", key = "'iosOnLining'+#version") @Override public boolean iosOnLining(int version) { - String value = get("ios_onling_version"); + String value = get(ConfigKeyEnum.iosOnlingVersion.getKey()); if (StringUtil.isNullOrEmpty(value)) return false; return version >= Integer.parseInt(value); @@ -132,7 +153,7 @@ @Cacheable(value = "config", key = "'isConvertTaoBaoLinkInServer'") @Override public boolean isConvertTaoBaoLinkInServer() { - String value = get("convert_taobao_link_in_server"); + String value = get(ConfigKeyEnum.convertTaoBaoLinkInServer.getKey()); if (StringUtil.isNullOrEmpty(value)) return false; if ("1".equalsIgnoreCase(value.trim())) @@ -144,7 +165,7 @@ @Cacheable(value = "config", key = "'getAppHomeFloatImg'") @Override public AppHomeFloatImg getAppHomeFloatImg() { - String value = get("app_float_img"); + String value = get(ConfigKeyEnum.appFloatImg.getKey()); if (!StringUtil.isNullOrEmpty(value)) { Gson gson = new Gson(); AppHomeFloatImg appHomeFloatImg = gson.fromJson(value, AppHomeFloatImg.class); @@ -158,7 +179,7 @@ @Cacheable(value = "config", key = "'getHomeWEEXUrl'") @Override public String getHomeWEEXUrl() { - String value = get("home_weex_url"); + String value = get(ConfigKeyEnum.homeWeexUrl.getKey()); return value; } @@ -169,7 +190,7 @@ @Override public ProxyIP getTaoBaoProxyIP() { - String value = get("taobao_proxy_ip"); + String value = get(ConfigKeyEnum.taobaoProxyIP.getKey()); try { String[] sts = value.split(":"); return new ProxyIP(sts[0], Integer.parseInt(sts[1])); @@ -180,8 +201,65 @@ @Override public String getAppHomeFloatNotifyImg() { - - return get("home_float_notify_img"); + return get(ConfigKeyEnum.homeFloatNotifyImg.getKey()); } + @Override + public void save(Config config) { + List<Config> list = configMapper.listByKey(config.getKey(), null, null); + if (list == null || list.size() == 0) { + configMapper.insertSelective(config); + } + } + + @Cacheable(value = "config", key = "'getSearchDiscoveryKeys'") + @Override + public String getSearchDiscoveryKeys() { + List<Config> list = configMapper.listByKey(ConfigKeyEnum.searchDiscoveryKeys.getKey(), null, null); + if (list == null || list.size() == 0) + return null; + + Config config = list.get(0); + if (config == null) + return null; + + // 鏇存柊 + updateSearchDiscoveryKeys(config); + + String value = config.getValue(); + return value; + } + + /** + * 鏇存柊鎼滅储鍙戠幇璇� + * + * @param config + */ + @Async + private void updateSearchDiscoveryKeys(Config config) { + long currentTime = java.lang.System.currentTimeMillis(); + + String createtime = config.getCreatetime(); + if (!StringUtil.isNullOrEmpty(createtime)) { + long diff = currentTime - Long.parseLong(createtime); + if (diff < 1000 * 60 * 60) + return; // 瓒呰繃涓�涓皬鏃舵洿鏂� + } + + String hotWords = DaTaoKeApiUtil.getHotWords(); + if (StringUtil.isNullOrEmpty(hotWords)) + return; + JSONArray array = JSONArray.fromObject(hotWords); + String reg = "^([\u4E00-\uFA29]|[\uE7C7-\uE7F3]|[a-zA-Z0-9_-]){1,20}$"; + List<String> list = new ArrayList<>(); + for (int i = 0; i < array.size(); i++) { + String key = array.optString(i); + if (key.matches(reg)) { + list.add(key); + } + } + config.setValue(new Gson().toJson(list)); + config.setCreatetime(currentTime + ""); + configMapper.updateByPrimaryKeySelective(config); + } } -- Gitblit v1.8.0