yujian
2019-09-09 0d9ac58dc11f54351e5e18dba8e950717d78019f
fanli/src/main/java/com/yeshi/fanli/service/impl/config/ConfigServiceImpl.java
@@ -7,6 +7,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;
@@ -19,6 +20,7 @@
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;
@@ -184,4 +186,56 @@
      return get("home_float_notify_img");
   }
   @Override
   public void save(Config config) {
      List<Config> list = configMapper.listByKey(config.getKey());
      if (list == null || list.size() == 0) {
         configMapper.insertSelective(config);
      }
   }
   @Cacheable(value = "config", key = "'getSearchDiscoveryKeys'")
   @Override
   public String getSearchDiscoveryKeys() {
      List<Config> list = configMapper.listByKey("search_discovery_keys");
      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 ;
      config.setValue(hotWords);
      config.setCreatetime(currentTime + "");
      configMapper.updateByPrimaryKeySelective(config);
   }
}