diff --git a/cloud-mart-common/src/main/java/com/muyu/domain/ConnectorUser.java b/cloud-mart-common/src/main/java/com/muyu/domain/ConnectorUser.java index 8073f8c..ee2c692 100644 --- a/cloud-mart-common/src/main/java/com/muyu/domain/ConnectorUser.java +++ b/cloud-mart-common/src/main/java/com/muyu/domain/ConnectorUser.java @@ -31,6 +31,10 @@ public class ConnectorUser { * 购买次数 */ private Integer connectorFrequency; + /** + * 测试次数 + */ + private Integer textNumber; /** * 接口名称 */ 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 deleted file mode 100644 index 14a8317..0000000 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java +++ /dev/null @@ -1,92 +0,0 @@ -package com.muyu.cloud.mart.controller; - -import com.alibaba.fastjson.JSON; - -import com.muyu.cloud.mart.config.IPLocation; -import com.muyu.cloud.mart.service.MarketService; -import com.muyu.common.core.domain.Result; -import com.muyu.common.core.web.controller.BaseController; -import com.muyu.common.core.web.page.TableDataInfo; -import com.muyu.domain.Birthday; -import com.muyu.domain.Market; -import com.muyu.domain.Postcode; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.data.redis.core.RedisTemplate; -import org.springframework.web.bind.annotation.*; - -import java.util.ArrayList; -import java.util.List; -import java.util.Map; - -/** - * @Author：chaiyapeng - * @Package：com.muyu.cloud.etl.controller - * @Project：cloud-mart - * @name：MarketController - * @Date：2024/8/21 21:53 - */ -@RestController -@RequestMapping("/list") -public class MarketController extends BaseController { - - @Autowired - private MarketService marketService; - @Autowired - private RedisTemplateredisTemplate; - -// @RequiresPermissions("mart:info:list") - - /** - * 两千万条数据查询 - * @return - */ - @GetMapping("/findMarketList") - public Result> findMarketList(){ - List list = marketService.findMarketList(); - return getDataTable(list); - } - - /** - * 手机号查询归属地 - */ - @GetMapping("/getPhonePlace") - public Result getPhonePlace(@RequestParam(name = "tel") String tel){ - return marketService.getPhonePlace(tel); - } - /** - * IP查询归属地 - */ - @GetMapping("/getIpPlace") - public Result getIpPlace(@RequestParam(name = "ip") String ip){ - return marketService.getIpPlace(ip); - } - /** - * 新闻头条 - */ - @GetMapping("/getHeadlines") - public Result getHeadlines(){ - return marketService.getHeadlines(); - } - /** - * 气象预警 - */ - @GetMapping("/getWeather") - public Result getWeather(){ - return marketService.getWeather(); - } - /** - * 生辰助手 - */ - @PostMapping("/getBirthday") - public Result getBirthday(@RequestBody Birthday birthday){ - return marketService.getBirthday(birthday); - } - /** - * 邮编查询 - */ - @PostMapping("/getPostcode") - public Result getPostcode(@RequestBody Postcode postcode){ - return marketService.getPostcode(postcode); - } - -} 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 deleted file mode 100644 index 9146906..0000000 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java +++ /dev/null @@ -1,32 +0,0 @@ -package com.muyu.cloud.mart.service; - -import com.baomidou.mybatisplus.extension.service.IService; -import com.muyu.common.core.domain.Result; -import com.muyu.domain.Birthday; -import com.muyu.domain.Market; -import com.muyu.domain.Postcode; - -import java.util.List; - -/** - * @Author：chaiyapeng - * @Package：com.muyu.cloud.etl.service - * @Project：cloud-mart - * @name：MarketService - * @Date：2024/8/21 21:54 - */ -public interface MarketService extends IService { - List findMarketList(); - - Result getPhonePlace(String tel); - - Result getIpPlace(String ip); - - Result getHeadlines(); - - Result getWeather(); - - Result getBirthday(Birthday birthday); - - Result getPostcode(Postcode postcode); -} 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 deleted file mode 100644 index 89769e0..0000000 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java +++ /dev/null @@ -1,118 +0,0 @@ -package com.muyu.cloud.mart.service.impl; - -import com.alibaba.fastjson.JSON; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; - -import com.muyu.cloud.mart.utils.*; -import com.muyu.cloud.mart.mapper.MarketMapper; -import com.muyu.cloud.mart.service.MarketService; -import com.muyu.common.core.domain.Result; -import com.muyu.domain.Birthday; -import com.muyu.domain.Market; -import com.muyu.domain.PhonePlace; -import com.muyu.domain.Postcode; -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.URL; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; - -import static com.muyu.cloud.mart.config.IPLocation.params; -import static com.muyu.common.core.utils.PageUtils.startPage; - -/** - * @Author：chaiyapeng - * @Package：com.muyu.cloud.etl.service.impl - * @Project：cloud-mart - * @name：MarketServiceImpl - * @Date：2024/8/21 21:54 - */ -@Service -@Log4j2 -public class MarketServiceImpl extends ServiceImpl implements MarketService { - - @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(); - - /** - * 手机号查询归属地 - * @param tel - */ - @Override - public Result getPhonePlace(String tel) { - PhonePlace phonePlace = MobileLocation.queryMobileLocation(tel); - return Result.success(phonePlace); - } - - /** - * IP查询归属地 - * @param ip - * @return - */ - @Override - public Result getIpPlace(String ip) { - StringBuffer stringBuffer = IPLocation.queryIPLocation(ip); - return Result.success(stringBuffer); - } - /** - * 新闻头条 - * @return - */ - @Override - public Result getHeadlines() { - StringBuffer stringBuffer = Headlines.queryHeadlines(); - return Result.success(stringBuffer); - } - /** - * 气象预警 - */ - @Override - public Result getWeather() { - StringBuffer stringBuffer = Weather.queryWeather(); - return Result.success(stringBuffer); - } - /** - * 生辰助手 - */ - @Override - public Result getBirthday(Birthday birthday) { - StringBuffer stringBuffer = BirthdayHelper.queryBirthday(birthday); - return Result.success(stringBuffer); - } - /** - * 邮编查询 - */ - @Override - public Result getPostcode(Postcode postcode) { - StringBuffer stringBuffer = PostcodeInquire.queryPostcode(postcode); - return Result.success(stringBuffer); - } -} diff --git a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/BirthdayHelper.java b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/BirthdayHelper.java deleted file mode 100644 index f8aaacd..0000000 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/BirthdayHelper.java +++ /dev/null @@ -1,67 +0,0 @@ -package com.muyu.cloud.mart.utils; - -import com.muyu.domain.Birthday; - -import java.nio.charset.StandardCharsets; -import java.util.HashMap; -import java.io.BufferedReader; -import java.io.InputStreamReader; -import java.net.URL; -import java.net.URLEncoder; -import java.util.Map; -import java.util.stream.Collectors; - -/** - * @Author：chaiyapeng - * @Package：com.muyu.cloud.mart.utils - * @Project：cloud-mart - * @name：BirthdayHelper - * @Date：2024/8/24 19:36 - * 生辰助手 - */ -public class BirthdayHelper { - - public static StringBuffer queryBirthday(Birthday birthday){ - String apiKey = "9bbfc46233d4931c39207b090ed4b27c"; - String apiUrl = "http://apis.juhe.cn/birthEight/query"; - HashMap map = new HashMap<>(); - - map.put("key", apiKey); - map.put("year", birthday.getYear()); - birthday.setYear(map.put("year", birthday.getYear())); - map.put("month", birthday.getMonth()); - birthday.setMonth(map.put("month", birthday.getMonth())); - map.put("day", birthday.getDay()); - birthday.setDay(map.put("day", birthday.getDay())); - map.put("hour", birthday.getHour()); - birthday.setHour(map.put("hour", birthday.getHour())); - 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 response; - } catch (Exception e) { - throw new RuntimeException(e); - } - } - - - public static String params(Map map) { - return map.entrySet().stream() - .map(entry -> { - try { - return entry.getKey() + "=" + URLEncoder.encode(entry.getValue(), StandardCharsets.UTF_8.toString()); - } catch (Exception e) { - e.printStackTrace(); - return entry.getKey() + "=" + entry.getValue(); - } - }) - .collect(Collectors.joining("&")); - } -} diff --git a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/Headlines.java b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/Headlines.java deleted file mode 100644 index 51379b7..0000000 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/Headlines.java +++ /dev/null @@ -1,47 +0,0 @@ -package com.muyu.cloud.mart.utils; - -import com.muyu.common.core.domain.Result; - -import java.io.BufferedReader; -import java.io.InputStreamReader; -import java.net.URL; -import java.util.HashMap; - -import static com.muyu.cloud.mart.config.IPLocation.params; - -/** - * @Author：chaiyapeng - * @Package：com.muyu.cloud.mart.utils - * @Project：cloud-mart - * @name：Headlines - * @Date：2024/8/24 18:39 - * 新闻头条 - */ -public class Headlines { - - public static StringBuffer queryHeadlines(){ - 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 response; - } catch (Exception e) { - throw new RuntimeException(e); - } - } -} diff --git a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/IPLocation.java b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/IPLocation.java deleted file mode 100644 index 2cbfe4e..0000000 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/IPLocation.java +++ /dev/null @@ -1,56 +0,0 @@ -package com.muyu.cloud.mart.utils; - -import java.io.BufferedReader; -import java.io.InputStreamReader; -import java.net.URL; -import java.net.URLEncoder; -import java.nio.charset.StandardCharsets; -import java.util.HashMap; -import java.util.Map; -import java.util.stream.Collectors; - -/** - * @Author：chaiyapeng - * @Package：com.muyu.cloud.mart.utils - * @Project：cloud-mart - * @name：IPLocation - * @Date：2024/8/23 20:54 - * IP查询归属地 - */ -public class IPLocation { - public static StringBuffer queryIPLocation(String ip){ - String apiKey = "e84b7d13a9fb87b4ebcc9813e4518955"; - String apiUrl = "http://apis.juhe.cn/ip/ipNewV3"; - HashMap map = new HashMap<>(); - map.put("key", apiKey); - map.put("ip", ip); - try { - URL url = new URL(String.format(apiUrl + "?" + params(map))); - BufferedReader in = new BufferedReader(new InputStreamReader((url.openConnection()).getInputStream())); - String inputLine; - StringBuffer stringBuffer = new StringBuffer(); - while ((inputLine = in.readLine()) != null){ - stringBuffer.append(inputLine); - } - in.close(); - System.out.println(stringBuffer); - return stringBuffer; - } catch (Exception e) { - throw new RuntimeException(e); - } - } - - - public static String params(Map map) { - return map.entrySet().stream() - .map(entry -> { - try { - return entry.getKey() + "=" + URLEncoder.encode(entry.getValue(), StandardCharsets.UTF_8.toString()); - } catch (Exception e) { - e.printStackTrace(); - return entry.getKey() + "=" + entry.getValue(); - } - }) - .collect(Collectors.joining("&")); - } -} diff --git a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/MobileLocation.java b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/MobileLocation.java deleted file mode 100644 index 166a87a..0000000 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/MobileLocation.java +++ /dev/null @@ -1,154 +0,0 @@ -package com.muyu.cloud.mart.utils; - - - - - -import com.muyu.domain.PhonePlace; -import net.sf.json.JSONObject; - -import java.io.*; -import java.net.HttpURLConnection; -import java.net.URL; -import java.net.URLEncoder; -import java.nio.charset.StandardCharsets; -import java.util.HashMap; -import java.util.Map; - -/** - * 手机号查询归属地接口 - */ -public class MobileLocation { - // 手机归属地查询接口地址 -// http://apis.juhe.cn/mobile/get http://127.0.0.1:8369/query?mobile - public static String API_URL = "http://apis.juhe.cn/mobile/get"; - // 接口请求Key - public static String API_KEY = "8e5493da8edee8e42831574b9a2c3492"; - - - /** - * 根据手机号码/手机号码前7位查询号码归属地 - * @param tel - */ - public static PhonePlace queryMobileLocation(String tel) - { - Map params = new HashMap<>();//组合参数 - params.put("phone", tel); - params.put("key", API_KEY); - String queryParams = urlencode(params); - PhonePlace phonePlace = new PhonePlace(); - - String response = doGet(API_URL, queryParams); - try { - JSONObject jsonObject = JSONObject.fromObject(response); - int error_code = jsonObject.getInt("error_code"); - if (error_code == 0) { - System.out.println("调用接口成功"); - - JSONObject result = jsonObject.getJSONObject("result"); - - phonePlace.setProvince(result.getString("province")); - phonePlace.setCity(result.getString("city")); - phonePlace.setAreacode(result.getString("areacode")); - phonePlace.setZip(result.getString("zip")); - phonePlace.setCompany(result.getString("company")); - - System.out.printf("省份：%s%n", result.getString("province")); - System.out.printf("城市：%s%n", result.getString("city")); - System.out.printf("区号：%s%n", result.getString("areacode")); - System.out.printf("邮编：%s%n", result.getString("zip")); - System.out.printf("运营商：%s%n", result.getString("company")); - - } else { - System.out.println("调用接口失败：" + jsonObject.getString("reason")); - } - } catch (Exception e) { - e.printStackTrace(); - } - return phonePlace; - } - - /** - * get方式的http请求 - * - * @param httpUrl 请求地址 - * @return 返回结果 - */ - public static String doGet(String httpUrl, String queryParams) { - HttpURLConnection connection = null; - InputStream inputStream = null; - BufferedReader bufferedReader = null; - String result = null;// 返回结果字符串 - try { - // 创建远程url连接对象 - URL url = new URL(new StringBuffer(httpUrl).append("?").append(queryParams).toString()); - // 通过远程url连接对象打开一个连接，强转成httpURLConnection类 - connection = (HttpURLConnection) url.openConnection(); - // 设置连接方式：get - connection.setRequestMethod("GET"); - // 设置连接主机服务器的超时时间：15000毫秒 - connection.setConnectTimeout(5000); - // 设置读取远程返回的数据时间：60000毫秒 - connection.setReadTimeout(6000); - // 发送请求 - connection.connect(); - // 通过connection连接，获取输入流 - if (connection.getResponseCode() == 200) { - inputStream = connection.getInputStream(); - // 封装输入流，并指定字符集 - bufferedReader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8)); - // 存放数据 - StringBuilder sbf = new StringBuilder(); - String temp; - while ((temp = bufferedReader.readLine()) != null) { - sbf.append(temp); - sbf.append(System.getProperty("line.separator")); - } - result = sbf.toString(); - } - } catch (IOException e) { - e.printStackTrace(); - } finally { - // 关闭资源 - if (null != bufferedReader) { - try { - bufferedReader.close(); - } catch (IOException e) { - e.printStackTrace(); - } - } - if (null != inputStream) { - try { - inputStream.close(); - } catch (IOException e) { - e.printStackTrace(); - } - } - if (connection != null) { - connection.disconnect();// 关闭远程连接 - } - } - return result; - } - - /** - * 将map型转为请求参数型 - * - * @param data - * @return - */ - public static String urlencode(Map data) { - StringBuilder sb = new StringBuilder(); - for (Map.Entry i : data.entrySet()) { - try { - sb.append(i.getKey()).append("=").append(URLEncoder.encode(i.getValue() + "", "UTF-8")).append("&"); - } catch (UnsupportedEncodingException e) { - e.printStackTrace(); - } - } - String result = sb.toString(); - result = result.substring(0, result.lastIndexOf("&")); - return result; - } -} - diff --git a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/PostcodeInquire.java b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/PostcodeInquire.java deleted file mode 100644 index 9518e09..0000000 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/PostcodeInquire.java +++ /dev/null @@ -1,62 +0,0 @@ -package com.muyu.cloud.mart.utils; - -import com.muyu.domain.Postcode; - -import java.io.BufferedReader; -import java.io.InputStreamReader; -import java.net.MalformedURLException; -import java.net.URL; -import java.net.URLEncoder; -import java.nio.charset.StandardCharsets; -import java.util.HashMap; -import java.util.Map; -import java.util.stream.Collectors; -/** - * @Author：chaiyapeng - * @Package：com.muyu.cloud.mart.utils - * @Project：cloud-mart - * @name：Postcode - * @Date：2024/8/24 20:50 - */ -public class PostcodeInquire { - - public static StringBuffer queryPostcode(Postcode postcode){ - String apiKey = "0cabcd31c150369d8afb2c8b7e41a2c0"; - String apiUrl = "http://v.juhe.cn/postcode/query"; - - HashMap map = new HashMap<>(); - map.put("key", apiKey); - map.put("postcode", postcode.getPostcode());//邮编，如：215001 - postcode.setPostcode(map.put("postcode", postcode.getPostcode())); - map.put("page", String.valueOf(postcode.getPage()));//页数，默认1 - map.put("pagesize", "");//每页返回，默认:20,最大不超过50 - map.put("dtype", "json");//返回数据的格式,xml或json，默认json - 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 response; - } catch (Exception e) { - throw new RuntimeException(e); - } - } - - public static String params(Map map) { - return map.entrySet().stream() - .map(entry -> { - try { - return entry.getKey() + "=" + URLEncoder.encode(entry.getValue(), StandardCharsets.UTF_8.toString()); - } catch (Exception e) { - e.printStackTrace(); - return entry.getKey() + "=" + entry.getValue(); - } - }) - .collect(Collectors.joining("&")); - } -} diff --git a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/Weather.java b/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/Weather.java deleted file mode 100644 index 4efd595..0000000 --- a/cloud-mart-server/src/main/java/com/muyu/cloud/mart/utils/Weather.java +++ /dev/null @@ -1,56 +0,0 @@ -package com.muyu.cloud.mart.utils; - -import java.io.BufferedReader; -import java.io.IOException; -import java.io.InputStreamReader; -import java.net.URL; -import java.net.URLEncoder; -import java.nio.charset.StandardCharsets; -import java.util.HashMap; -import java.util.Map; -import java.util.stream.Collectors; - -/** - * @Author：chaiyapeng - * @Package：com.muyu.cloud.mart.utils - * @Project：cloud-mart - * @name：Weather - * @Date：2024/8/24 18:51 - * 气象预警 - */ -public class Weather { - public static StringBuffer queryWeather() { - String apiKey = "80e78ee9adaded8b1f42ec9cbdf69ac9"; - String apiUrl = "https://apis.juhe.cn/fapig/alarm/citys"; - - HashMap map = new HashMap<>(); - map.put("key", apiKey); - 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 response; - } catch (Exception e) { - throw new RuntimeException(e); - } - - } - public static String params(Map map) { - return map.entrySet().stream() - .map(entry -> { - try { - return entry.getKey() + "=" + URLEncoder.encode(entry.getValue(), StandardCharsets.UTF_8.toString()); - } catch (Exception e) { - e.printStackTrace(); - return entry.getKey() + "=" + entry.getValue(); - } - }) - .collect(Collectors.joining("&")); - } -} diff --git a/cloud-mart-server/src/main/resources/mapper/MarketMappers.xml b/cloud-mart-server/src/main/resources/mapper/MarketMappers.xml deleted file mode 100644 index cdcd325..0000000 --- a/cloud-mart-server/src/main/resources/mapper/MarketMappers.xml +++ /dev/null @@ -1,9 +0,0 @@ - - - - - - -