diff --git a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java index c5d5bf9..3b151b1 100644 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java +++ b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java @@ -40,20 +40,7 @@ public class MarketController extends BaseController { */ @GetMapping("findMarketList") public Result> findMarketList(){ - if (redisTemplate.hasKey("list")){ - List list = redisTemplate.opsForList().range("list", 0, -1); - ArrayList markets = new ArrayList<>(); - for (String s : list) { - markets.add(JSON.parseObject(s, Market.class)); - } - return getDataTable(markets); - } - - startPage(); List list = marketService.findMarketList(); - for (Market market1 : list) { - redisTemplate.opsForList().rightPush("list", JSON.toJSONString(market1)); - } return getDataTable(list); } @@ -71,5 +58,12 @@ public class MarketController extends BaseController { public Result getIpPlace(@RequestParam(name = "ip") String ip){ return marketService.getIpPlace(ip); } + /** + * 新闻头条 + */ + @GetMapping("getHeadlines") + public Result getHeadlines(){ + return marketService.getHeadlines(); + } } diff --git a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java index 1022d3e..70510a0 100644 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java +++ b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java @@ -19,4 +19,6 @@ public interface MarketService extends IService { void getPhonePlace(String tel); Result getIpPlace(String ip); + + Result getHeadlines(); } diff --git a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java index 4538fe7..64ed344 100644 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java +++ b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java @@ -1,6 +1,7 @@ package com.muyu.cloud.mart.service.impl; import cn.hutool.log.Log; +import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.muyu.cloud.mart.config.JuheDemo; @@ -12,17 +13,20 @@ import com.muyu.common.core.utils.StringUtils; import com.muyu.domain.Market; import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import java.io.BufferedReader; import java.io.InputStreamReader; import java.net.MalformedURLException; import java.net.URL; +import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Locale; import static com.muyu.cloud.mart.config.IPLocation.params; +import static com.muyu.common.core.utils.PageUtils.startPage; /** * @Author:chaiyapeng @@ -37,10 +41,25 @@ public class MarketServiceImpl extends ServiceImpl impleme @Autowired private MarketMapper marketMapper; + @Autowired + private RedisTemplateredisTemplate; @Override public List findMarketList() { + if (redisTemplate.hasKey("list")){ + List list = redisTemplate.opsForList().range("list", 0, -1); + ArrayList markets = new ArrayList<>(); + for (String s : list) { + markets.add(JSON.parseObject(s, Market.class)); + } + return markets; + } + startPage(); +// List list = marketService.findMarketList(); List list = marketMapper.selectList(null); + for (Market market1 : list) { + redisTemplate.opsForList().rightPush("list", JSON.toJSONString(market1)); + } return list; } // public static final PhoneNumberOfflineGeocoder GEOCODER = PhoneNumberOfflineGeocoder.getInstance(); @@ -81,4 +100,34 @@ public class MarketServiceImpl extends ServiceImpl impleme throw new RuntimeException(e); } } + /** + * 新闻头条 + * @return + */ + @Override + public Result getHeadlines() { + String apiKey = "cdbb93769c75054e6beda4c1dc0b6a0b"; + String apiUrl = "http://v.juhe.cn/toutiao/index"; + + HashMap map = new HashMap<>(); + map.put("key", apiKey); + map.put("type", "top"); + map.put("page", "20"); + map.put("page_size", ""); + map.put("is_filter", ""); + try { + URL url = new URL(String.format(apiUrl + "?" + params(map))); + BufferedReader in = new BufferedReader(new InputStreamReader((url.openConnection()).getInputStream())); + String inputLine; + StringBuffer response = new StringBuffer(); + while ((inputLine = in.readLine()) != null) { + response.append(inputLine); + } + in.close(); + System.out.println(response); + return Result.success(response); + } catch (Exception e) { + throw new RuntimeException(e); + } + } }