From a7d2e4dff2f31a281d04be83a64f0e265f21ba8a Mon Sep 17 00:00:00 2001
From: xjs <1294405880@qq.com>
Date: Mon, 10 Jan 2022 17:27:49 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=90=8E=E7=AB=AF=E5=AE=9E=E7=8E=B0?=
 =?UTF-8?q?=E8=B0=83=E7=94=A8=E5=A4=A9=E8=A1=8C=E6=95=B0=E6=8D=AE=E5=85=A8?=
 =?UTF-8?q?=E7=BD=91=E7=83=AD=E6=90=9C=E6=8E=A5=E5=8F=A3=202=E3=80=81?=
 =?UTF-8?q?=E5=89=8D=E7=AB=AF=E4=B8=BB=E9=A1=B5=E6=AF=8F=E6=97=A5=E4=B8=80?=
 =?UTF-8?q?=E5=8F=A5=E6=A8=A1=E5=9D=97=E5=9B=BE=E7=89=87=E6=98=BE=E7=A4=BA?=
 =?UTF-8?q?=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ruoyi-ui/src/views/index.vue                  |  6 +-
 .../main/java/com/xjs/consts/ApiConst.java    |  4 ++
 .../api/tianxing/TianXingQWRSFeignClient.java | 29 +++++++++
 .../factory/TianXingQWRSFeignFactory.java     | 28 +++++++++
 .../controller/CopyWritingController.java     |  5 ++
 .../controller/ApiTopSearchController.java    | 20 ++++++
 .../domain/ApiTopsearchAllnetwork.java        | 51 ++++++++++++++++
 .../topsearch/factory/TopserachFactory.java   | 19 ++++++
 .../TianXingTopsearchAllnetworkFactory.java   | 61 +++++++++++++++++++
 .../mapper/ApiTopsearchAllnetworkMapper.java  | 13 ++++
 .../ApiTopsearchAllnetworkService.java        | 12 ++++
 .../ApiTopsearchAllnetworkServiceImpl.java    | 15 +++++
 12 files changed, 262 insertions(+), 1 deletion(-)
 create mode 100644 xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/client/api/tianxing/TianXingQWRSFeignClient.java
 create mode 100644 xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/client/factory/TianXingQWRSFeignFactory.java
 create mode 100644 xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/controller/ApiTopSearchController.java
 create mode 100644 xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/domain/ApiTopsearchAllnetwork.java
 create mode 100644 xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/factory/TopserachFactory.java
 create mode 100644 xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/factory/impl/TianXingTopsearchAllnetworkFactory.java
 create mode 100644 xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/mapper/ApiTopsearchAllnetworkMapper.java
 create mode 100644 xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/service/ApiTopsearchAllnetworkService.java
 create mode 100644 xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/service/impl/ApiTopsearchAllnetworkServiceImpl.java

diff --git a/ruoyi-ui/src/views/index.vue b/ruoyi-ui/src/views/index.vue
index a5d6c75f..7f6848cc 100644
--- a/ruoyi-ui/src/views/index.vue
+++ b/ruoyi-ui/src/views/index.vue
@@ -7,7 +7,11 @@
           <!--每日一句-->
           <div class="box-card">
             <div class="aWordImage">
-              <img :src=apiAWord.imgurl class="aWordImage">
+              <el-image
+                class="aWordImage"
+                :src=apiAWord.imgurl
+                :preview-src-list=[apiAWord.imgurl]>
+              </el-image>
             </div>
             <div class="aWordAudio">
               <audio :src=apiAWord.tts controls="controls">
diff --git a/xjs-business/xjs-business-common/src/main/java/com/xjs/consts/ApiConst.java b/xjs-business/xjs-business-common/src/main/java/com/xjs/consts/ApiConst.java
index 73141492..54a1c126 100644
--- a/xjs-business/xjs-business-common/src/main/java/com/xjs/consts/ApiConst.java
+++ b/xjs-business/xjs-business-common/src/main/java/com/xjs/consts/ApiConst.java
@@ -31,6 +31,8 @@ public class ApiConst {
 
     public static final String TIANXING_A_WORD= "天行-每日一句";
 
+    public static final String TIANXING_TOPSEARCHALLNETWORK= "天行-全网热搜榜";
+
 
 
 
@@ -60,6 +62,8 @@ public class ApiConst {
 
     public static final String TIANXING_A_WORD_URL= "http://api.tianapi.com/everyday/index";
 
+    public static final String TIANXING_TOPSEARCHALLNETWORK_URL= "http://api.tianapi.com/networkhot/index";
+
 
 
 
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/client/api/tianxing/TianXingQWRSFeignClient.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/client/api/tianxing/TianXingQWRSFeignClient.java
new file mode 100644
index 00000000..32fa1c60
--- /dev/null
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/client/api/tianxing/TianXingQWRSFeignClient.java
@@ -0,0 +1,29 @@
+package com.xjs.common.client.api.tianxing;
+
+import com.alibaba.fastjson.JSONObject;
+import com.xjs.common.aop.ApiLog;
+import com.xjs.common.client.factory.TianXingQWRSFeignFactory;
+import com.xjs.copywriting.domain.RequestBody;
+import feign.Param;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.cloud.openfeign.SpringQueryMap;
+import org.springframework.web.bind.annotation.GetMapping;
+
+import static com.xjs.consts.ApiConst.*;
+
+/**
+ * 天行数据全网热搜feign远程调用api
+ * @author xiejs
+ * @since 2022-01-10
+ */
+@FunctionalInterface
+@FeignClient(name = "tianXingQWRS",url = TIANXING_TOPSEARCHALLNETWORK_URL,fallbackFactory = TianXingQWRSFeignFactory.class)
+public interface TianXingQWRSFeignClient {
+
+    @GetMapping
+    @ApiLog(name = TIANXING_TOPSEARCHALLNETWORK_URL,
+            url = TIANXING_PYQ_URL,
+            method = "Get")
+    JSONObject topSearchApi(@Param("key") String key);
+
+}
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/client/factory/TianXingQWRSFeignFactory.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/client/factory/TianXingQWRSFeignFactory.java
new file mode 100644
index 00000000..622f679e
--- /dev/null
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/client/factory/TianXingQWRSFeignFactory.java
@@ -0,0 +1,28 @@
+package com.xjs.common.client.factory;
+
+import com.alibaba.fastjson.JSONObject;
+import com.ruoyi.common.core.domain.R;
+import com.xjs.common.client.api.tianxing.TianXingQWRSFeignClient;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.cloud.openfeign.FallbackFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author xiejs
+ * @since 2022-01-10
+ */
+@Component
+@Log4j2
+public class TianXingQWRSFeignFactory implements FallbackFactory<TianXingQWRSFeignClient> {
+
+    @Override
+    public TianXingQWRSFeignClient create(Throwable cause) {
+        log.error("api模块天行全网热搜榜服务调用失败:{},执行降级处理", cause.getMessage());
+        return requestBody -> {
+            JSONObject jsonObject = new JSONObject();
+            //构建一个异常json给下层接口处理
+            jsonObject.put("error", R.FAIL);
+            return jsonObject;
+        };
+    }
+}
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/copywriting/controller/CopyWritingController.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/copywriting/controller/CopyWritingController.java
index 59b5ae3f..c90305f1 100644
--- a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/copywriting/controller/CopyWritingController.java
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/copywriting/controller/CopyWritingController.java
@@ -94,6 +94,11 @@ public class CopyWritingController extends BaseController {
         factories.add(rollMMYJCopyWritingFactory);
         factories.add(rollMMYJCopyWritingFactory);
         factories.add(rollMMYJCopyWritingFactory);
+        factories.add(rollMMYJCopyWritingFactory);
+        factories.add(rollMMYJCopyWritingFactory);
+        factories.add(rollMMYJCopyWritingFactory);
+        factories.add(rollMMYJCopyWritingFactory);
+        factories.add(rollMMYJCopyWritingFactory);
         //--------add----------------------------;-
         //随机调用集合中的接口
         return RandomUtil.randomEle(factories);
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/controller/ApiTopSearchController.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/controller/ApiTopSearchController.java
new file mode 100644
index 00000000..e6f0adb1
--- /dev/null
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/controller/ApiTopSearchController.java
@@ -0,0 +1,20 @@
+package com.xjs.topsearch.controller;
+
+import io.swagger.annotations.Api;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author xiejs
+ * @since 2022-01-10
+ */
+@RestController
+@RequestMapping("topsearch")
+@Api(tags = "业务模块-热搜管理")
+@Log4j2
+public class ApiTopSearchController {
+
+
+
+}
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/domain/ApiTopsearchAllnetwork.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/domain/ApiTopsearchAllnetwork.java
new file mode 100644
index 00000000..553f0394
--- /dev/null
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/domain/ApiTopsearchAllnetwork.java
@@ -0,0 +1,51 @@
+package com.xjs.topsearch.domain;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.ruoyi.common.core.annotation.Excel;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 全网热搜api实体
+ * @author xiejs
+ * @since 2022-01-10
+ */
+@Data
+@TableName("api_topsearch_allnetwork")
+public class ApiTopsearchAllnetwork {
+    private static final long serialVersionUID = 1L;
+
+    /** 主键 */
+    private Long id;
+
+    /** 热搜话题 */
+    @Excel(name = "热搜话题")
+    private String title;
+
+    /** 话题简介 */
+    @Excel(name = "话题简介")
+    private String digest;
+
+    /** 热搜榜指数 */
+    @Excel(name = "热搜榜指数")
+    private Long hotnum;
+
+    @Excel(name = "创建时间",dateFormat = "yyyy-MM-dd HH:mm:ss")
+    @TableField(fill = FieldFill.INSERT)
+    private Date createTime;
+
+
+
+
+
+
+
+
+
+
+
+
+}
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/factory/TopserachFactory.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/factory/TopserachFactory.java
new file mode 100644
index 00000000..c1dc2d52
--- /dev/null
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/factory/TopserachFactory.java
@@ -0,0 +1,19 @@
+package com.xjs.topsearch.factory;
+
+import java.util.List;
+
+/**
+ * 热搜api工厂 默认使用tianxing接口
+ * @author xiejs
+ * @since 2022-01-10
+ */
+public interface TopserachFactory<T> {
+
+    /**
+     * 热搜api工厂方法
+     * @return Object
+     */
+    List<T> topSearchApi();
+
+
+}
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/factory/impl/TianXingTopsearchAllnetworkFactory.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/factory/impl/TianXingTopsearchAllnetworkFactory.java
new file mode 100644
index 00000000..b65236d8
--- /dev/null
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/factory/impl/TianXingTopsearchAllnetworkFactory.java
@@ -0,0 +1,61 @@
+package com.xjs.topsearch.factory.impl;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.ruoyi.common.core.constant.HttpStatus;
+import com.xjs.common.client.api.tianxing.TianXingQWRSFeignClient;
+import com.xjs.config.TianXingProperties;
+import com.xjs.exception.ApiException;
+import com.xjs.topsearch.domain.ApiTopsearchAllnetwork;
+import com.xjs.topsearch.factory.TopserachFactory;
+import com.xjs.topsearch.service.ApiTopsearchAllnetworkService;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 天行全网热搜工厂实现
+ *
+ * @author xiejs
+ * @since 2022-01-10
+ */
+@Component
+@Log4j2
+public class TianXingTopsearchAllnetworkFactory implements TopserachFactory<ApiTopsearchAllnetwork> {
+
+    @Autowired
+    private TianXingProperties tianXingProperties;
+    @Autowired
+    private TianXingQWRSFeignClient tianXingQWRSFeignClient;
+    @Autowired
+    private ApiTopsearchAllnetworkService apiTopsearchAllnetworkService;
+
+
+    @Override
+    public List<ApiTopsearchAllnetwork> topSearchApi() {
+
+        JSONObject jsonObject = tianXingQWRSFeignClient.topSearchApi(tianXingProperties.getKey());
+        if (!jsonObject.containsKey("error")) {
+            if (jsonObject.getInteger("code") == HttpStatus.SUCCESS) {
+                JSONArray newslist = jsonObject.getJSONArray("newslist");
+                List<ApiTopsearchAllnetwork> collect = newslist.stream().map(arrayJson -> {
+                    ApiTopsearchAllnetwork apiTopsearchAllnetwork = new ApiTopsearchAllnetwork();
+                    JSONObject json = (JSONObject) arrayJson;
+                    apiTopsearchAllnetwork.setDigest(json.getString("digest"));
+                    apiTopsearchAllnetwork.setHotnum(json.getLong("hotnum"));
+                    apiTopsearchAllnetwork.setTitle(json.getString("title"));
+                    return apiTopsearchAllnetwork;
+                }).collect(Collectors.toList());
+                log.info("全网热搜批量插入成功了嘛---" + apiTopsearchAllnetworkService.saveBatch(collect));
+                return collect;
+            } else {
+                throw new ApiException("天行全网热搜服务调用成功，但返回异常");
+            }
+        } else {
+            throw new ApiException("天行全网热搜服务调用失败，被降级！！");
+        }
+    }
+}
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/mapper/ApiTopsearchAllnetworkMapper.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/mapper/ApiTopsearchAllnetworkMapper.java
new file mode 100644
index 00000000..065f27fe
--- /dev/null
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/mapper/ApiTopsearchAllnetworkMapper.java
@@ -0,0 +1,13 @@
+package com.xjs.topsearch.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.xjs.topsearch.domain.ApiTopsearchAllnetwork;
+
+/**
+ * @author xiejs
+ * @since 2022-01-10
+ */
+public interface ApiTopsearchAllnetworkMapper extends BaseMapper<ApiTopsearchAllnetwork> {
+
+
+}
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/service/ApiTopsearchAllnetworkService.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/service/ApiTopsearchAllnetworkService.java
new file mode 100644
index 00000000..df2563de
--- /dev/null
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/service/ApiTopsearchAllnetworkService.java
@@ -0,0 +1,12 @@
+package com.xjs.topsearch.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.xjs.topsearch.domain.ApiTopsearchAllnetwork;
+
+/**
+ * 全网热搜service
+ * @author xiejs
+ * @since 2022-01-10
+ */
+public interface ApiTopsearchAllnetworkService extends IService<ApiTopsearchAllnetwork> {
+}
diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/service/impl/ApiTopsearchAllnetworkServiceImpl.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/service/impl/ApiTopsearchAllnetworkServiceImpl.java
new file mode 100644
index 00000000..76443e47
--- /dev/null
+++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/topsearch/service/impl/ApiTopsearchAllnetworkServiceImpl.java
@@ -0,0 +1,15 @@
+package com.xjs.topsearch.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xjs.topsearch.domain.ApiTopsearchAllnetwork;
+import com.xjs.topsearch.mapper.ApiTopsearchAllnetworkMapper;
+import com.xjs.topsearch.service.ApiTopsearchAllnetworkService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author xiejs
+ * @since 2022-01-10
+ */
+@Service
+public class ApiTopsearchAllnetworkServiceImpl extends ServiceImpl<ApiTopsearchAllnetworkMapper, ApiTopsearchAllnetwork> implements ApiTopsearchAllnetworkService {
+}