feat:[1004545] 超级搜索

pcloud-common-core/src/main/java/com/pcloud/common/core/biz/UpdateSuperSearchQueueBiz.java

+package com.pcloud.common.core.biz;
+
+import com.pcloud.common.core.dto.UpdateSuperSearchMQDTO;
+import com.pcloud.common.exceptions.BizException;
+
+public interface UpdateSuperSearchQueueBiz {
+
+    void sendMessageQueue(UpdateSuperSearchMQDTO superSearchMQDTO) throws BizException;
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/biz/impl/UpdateSuperSearchQueueBizImpl.java

+package com.pcloud.common.core.biz.impl;
+
+import com.pcloud.common.core.aspect.ParamLog;
+import com.pcloud.common.core.biz.UpdateSuperSearchQueueBiz;
+import com.pcloud.common.core.constant.MQTopicProducer;
+import com.pcloud.common.core.dto.UpdateSuperSearchMQDTO;
+import com.pcloud.common.exceptions.BizException;
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class UpdateSuperSearchQueueBizImpl implements UpdateSuperSearchQueueBiz {
+
+    @Autowired
+    private AmqpTemplate amqpTemplate;
+
+    @Override
+    @ParamLog("超级搜索更新queue")
+    public void sendMessageQueue(UpdateSuperSearchMQDTO superSearchMQDTO) throws BizException {
+        amqpTemplate.convertAndSend(MQTopicProducer.EXCHAGE, MQTopicProducer.UPDATE_SUPER_SEARCH, superSearchMQDTO);
+    }
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/ChildType.java

+package com.pcloud.common.core.constant;
+
+public enum ChildType {
+
+    NO(0),
+    //公众号码
+    ACCOUNT_QRCODE(1),
+    //rays码
+    RAYS_QRCODE(2),
+    //资源
+    MEDIA(3),
+    //文章
+    ARTICLE(4),
+    //素材
+    EXTERNAL(5),
+    //折扣
+    DISCOUNT(6),
+    //赠品促销
+    ACTIVITE(7),
+    //优惠券
+    COUPON(8);
+
+    public Integer code;
+
+    ChildType(Integer code) {
+        this.code = code;
+    }
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/MQQueueConstant.java

-/**
- *
- */
-package com.pcloud.common.core.constant;
-
-/**
- *
- * @author：songx
- * @date：2018年8月16日,下午9:54:51
- */
-public class MQQueueConstant {
-
-    /**
-     * 知识点标签使用
-     */
-    public static final String KNOWLEDGE_USE = "knowledgeUse";
-
-    /**
-	 * 模板消息
-	 */
-	public static final String TEMPLATE = "templateQueue";
-
-	/**
-	 * 小程序模板消息
-	 */
-	public static final String APPLET_TEMPLATE = "appletTemplateQueue";
-
-	/**
-	 * 音频配音(MP3)
-	 */
-	public static final String DUBBING = "dubbingQueue";
-
-	/**
-	 * 文件转码(PDF、OFFICE)
-	 */
-	public static final String TRANSCODE = "transcodeQueue";
-
-	/**
-	 * 文件转码(音视频)
-	 */
-	public static final String CONVERT = "convertQueue";
-
-	/**
-	 * 文件转码结束(音视频)->内容中心
-	 */
-	public static final String CONVERT_TO_CONTENT = "convert2ContentQueue";
-
-	/**
-	 * 文件转码结束(音视频)->教育表格
-	 */
-	public static final String CONVERT_TO_EFAPP = "convert2EfAppQueue";
-
-	/**
-	 * 文件转码结束(音视频)->圈子应用
-	 */
-	public static final String CONVERT_TO_GROUPAPP = "convert2GroupAppQueue";
-
-	/**
-	 * 文件转码结束(音视频)->直播应用
-	 */
-	public static final String CONVERT_TO_LIVEAPP = "convert2LiveAppQueue";
-
-	/**
-	 * 文件转码结束(音视频)->报名应用
-	 */
-	public static final String CONVERT_TO_MATCHAPP = "convert2MatchAppQueue";
-
-	/**
-	 * 文件转码结束(音视频)->题库文件溢出
-	 */
-	public static final String CONVERT_TO_PRETEST_FILEMEMORY = "convert2PretestFilememoryQueue";
-
-	/**
-	 * 文件转码结束(音视频)->小游戏
-	 */
-	public static final String CONVERT_TO_RAYSTASK = "convert2RaystaskQueue";
-
-	/**
-	 * 文件转码结束(音视频)->资源中心
-	 */
-	public static final String CONVERT_TO_RESOURCE = "convert2ResourceQueue";
-
-	/**
-	 * 文件转码结束(音视频)->测试应用
-	 */
-	public static final String CONVERT_TO_TESTAPP = "convert2TestAppQueue";
-
-	/**
-	 * 文件转码结束(音视频)->视频课
-	 */
-	public static final String CONVERT_TO_VIDEOLESSON = "convert2VideoLessonQueue";
-
-	/**
-	 * 文件转码结束(音视频)->投票应用
-	 */
-	public static final String CONVERT_TO_VOTEAPP = "convert2VoteAppQueue";
-
-	/**
-	 * 文件转码结束(音视频)->音频课/纯听
-	 */
-	public static final String CONVERT_TO_AUDIOLESSON = "convert2AudioLessonQueue";
-
-	/**
-	 * 文件转码结束(音视频)->音频课/纯听
-	 */
-	public static final String CONVERT_TO_AUDIOMAGIC = "convert2AudioMagicQueue";
-	/**
-	 * 文件转码结束(音视频)->场景化应用
-	 */
-	public static final String CONVERT_TO_SCENARIZEDAPP = "convert2ScenarizedAppQueue";
-	/**
-	 * 文件转码结束(音视频)->BOOK
-	 */
-	public static final String CONVERT_TO_BOOK = "convert2BookQueue";
-
-	/**
-	 * 数据埋点
-	 */
-	public static final String FRONT_EVENT = "frontEventQueue";
-
-	/**
-	 * 对外API
-	 */
-	public static final String EXAPI = "exapiQueue";
-
-	/**
-	 * 基金监控
-	 */
-	public static final String FUND = "fundQueue";
-
-	/**
-	 * 用户漏斗
-	 */
-	public static final String FUNNEL_FLOW = "funnelFlowQueue";
-
-	/**
-	 * 标签使用量
-	 */
-	public static final String LABEL_USED = "labelUsedQueue";
-
-	/**
-	 * 日志
-	 */
-	public static final String LOG = "logQueue";
-
-	/**
-	 * 动态监控
-	 */
-	public static final String MERCHANT_DYNAMIC = "merchantDynamicQueue";
-
-	/**
-	 * 系统消息
-	 */
-	public static final String MESSAGE = "messageQueue";
-
-	/**
-	 * 促销任务
-	 */
-	public static final String PROMOTION_TASK = "promotionTaskQueue";
-
-	/**
-	 * 促销终止
-	 */
-	public static final String PROMOTION_TERMINATE = "promotionTerminateQueue";
-
-	/**
-	 * 用户行为
-	 */
-	public static final String USER_ACTION = "userActionQueue";
-
-	/**
-	 * 周任务
-	 */
-	public static final String WEEK_TASK = "weekTaskQueue";
-
-	/**
-	 * 死信队列名称(勿改)
-	 */
-	public static final String DEAD = "rays.dlq";
-
-	/**
-	 * 待办事项数量统计
-	 */
-	public static final String BACKLOG = "backlogQueue";
-
-	/**
-	 * 红榜做书任务
-	 */
-	public static final String BOOKTASK = "booktaskQueue";
-
-	/**
-	 * 红榜做书任务（2021版）
-	 */
-	public static final String RAYS_TASK = "raysTaskQueue";
-
-	/**
-	 * 商品信息爬取功能
-	 */
-	public static final String PRODUCT_CRAWLER = "productCrawlerQueue";
-}
+/**
+ *
+ */
+package com.pcloud.common.core.constant;
+
+/**
+ *
+ * @author：songx
+ * @date：2018年8月16日,下午9:54:51
+ */
+public class MQQueueConstant {
+
+    /**
+     * 知识点标签使用
+     */
+    public static final String KNOWLEDGE_USE = "knowledgeUse";
+
+    /**
+	 * 模板消息
+	 */
+	public static final String TEMPLATE = "templateQueue";
+
+	/**
+	 * 小程序模板消息
+	 */
+	public static final String APPLET_TEMPLATE = "appletTemplateQueue";
+
+	/**
+	 * 音频配音(MP3)
+	 */
+	public static final String DUBBING = "dubbingQueue";
+
+	/**
+	 * 文件转码(PDF、OFFICE)
+	 */
+	public static final String TRANSCODE = "transcodeQueue";
+
+	/**
+	 * 文件转码(音视频)
+	 */
+	public static final String CONVERT = "convertQueue";
+
+	/**
+	 * 文件转码结束(音视频)->内容中心
+	 */
+	public static final String CONVERT_TO_CONTENT = "convert2ContentQueue";
+
+	/**
+	 * 文件转码结束(音视频)->教育表格
+	 */
+	public static final String CONVERT_TO_EFAPP = "convert2EfAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->圈子应用
+	 */
+	public static final String CONVERT_TO_GROUPAPP = "convert2GroupAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->直播应用
+	 */
+	public static final String CONVERT_TO_LIVEAPP = "convert2LiveAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->报名应用
+	 */
+	public static final String CONVERT_TO_MATCHAPP = "convert2MatchAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->题库文件溢出
+	 */
+	public static final String CONVERT_TO_PRETEST_FILEMEMORY = "convert2PretestFilememoryQueue";
+
+	/**
+	 * 文件转码结束(音视频)->小游戏
+	 */
+	public static final String CONVERT_TO_RAYSTASK = "convert2RaystaskQueue";
+
+	/**
+	 * 文件转码结束(音视频)->资源中心
+	 */
+	public static final String CONVERT_TO_RESOURCE = "convert2ResourceQueue";
+
+	/**
+	 * 文件转码结束(音视频)->测试应用
+	 */
+	public static final String CONVERT_TO_TESTAPP = "convert2TestAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->视频课
+	 */
+	public static final String CONVERT_TO_VIDEOLESSON = "convert2VideoLessonQueue";
+
+	/**
+	 * 文件转码结束(音视频)->投票应用
+	 */
+	public static final String CONVERT_TO_VOTEAPP = "convert2VoteAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->音频课/纯听
+	 */
+	public static final String CONVERT_TO_AUDIOLESSON = "convert2AudioLessonQueue";
+
+	/**
+	 * 文件转码结束(音视频)->音频课/纯听
+	 */
+	public static final String CONVERT_TO_AUDIOMAGIC = "convert2AudioMagicQueue";
+	/**
+	 * 文件转码结束(音视频)->场景化应用
+	 */
+	public static final String CONVERT_TO_SCENARIZEDAPP = "convert2ScenarizedAppQueue";
+	/**
+	 * 文件转码结束(音视频)->BOOK
+	 */
+	public static final String CONVERT_TO_BOOK = "convert2BookQueue";
+
+	/**
+	 * 数据埋点
+	 */
+	public static final String FRONT_EVENT = "frontEventQueue";
+
+	/**
+	 * 对外API
+	 */
+	public static final String EXAPI = "exapiQueue";
+
+	/**
+	 * 基金监控
+	 */
+	public static final String FUND = "fundQueue";
+
+	/**
+	 * 用户漏斗
+	 */
+	public static final String FUNNEL_FLOW = "funnelFlowQueue";
+
+	/**
+	 * 标签使用量
+	 */
+	public static final String LABEL_USED = "labelUsedQueue";
+
+	/**
+	 * 日志
+	 */
+	public static final String LOG = "logQueue";
+
+	/**
+	 * 动态监控
+	 */
+	public static final String MERCHANT_DYNAMIC = "merchantDynamicQueue";
+
+	/**
+	 * 系统消息
+	 */
+	public static final String MESSAGE = "messageQueue";
+
+	/**
+	 * 促销任务
+	 */
+	public static final String PROMOTION_TASK = "promotionTaskQueue";
+
+	/**
+	 * 促销终止
+	 */
+	public static final String PROMOTION_TERMINATE = "promotionTerminateQueue";
+
+	/**
+	 * 用户行为
+	 */
+	public static final String USER_ACTION = "userActionQueue";
+
+	/**
+	 * 周任务
+	 */
+	public static final String WEEK_TASK = "weekTaskQueue";
+
+	/**
+	 * 死信队列名称(勿改)
+	 */
+	public static final String DEAD = "rays.dlq";
+
+	/**
+	 * 待办事项数量统计
+	 */
+	public static final String BACKLOG = "backlogQueue";
+
+	/**
+	 * 红榜做书任务
+	 */
+	public static final String BOOKTASK = "booktaskQueue";
+
+	/**
+	 * 红榜做书任务（2021版）
+	 */
+	public static final String RAYS_TASK = "raysTaskQueue";
+
+	/**
+	 * 商品信息爬取功能
+	 */
+	public static final String PRODUCT_CRAWLER = "productCrawlerQueue";
+
+	/**
+	 * 超级搜索更新数据
+	 */
+	public static final String UPDATE_SUPER_SEARCH = "updateSuperSearch";
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/MQTopicProducer.java

@@ -447,6 +447,11 @@ public class MQTopicProducer {
 	public static final String FOREIGN_READ_PAY = "topic.foreignReadPay";
 
 	/**
+	 * 超级搜索
+	 */
+	public static final String UPDATE_SUPER_SEARCH = "topic.updateSuperSearch";
+
+	/**
 	 * 应用复制
 	 */
 	public static final String DUPLICATE_APP = "topic.duplicateApp";

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/UpdateSuperSearchCode.java

+package com.pcloud.common.core.constant;
+
+public enum UpdateSuperSearchCode {
+    BOOK_CREATE(1,"创建图书"),
+    BOOK_DELETE(2,"删除图书"),
+    BOOK_UPDATE(3,"更新图书"),
+    ACCOUNT_QRCODE_CREATE(4,"创建公众号二维码"),
+    ACCOUNT_QRCODE_DELETE(5,"删除公众号二维码"),
+    ACCOUNT_QRCODE_UPDATE(6,"更新公众号二维码"),
+    GROUP_QRCODE_CREATE(7,"创建社群二维码"),
+    GROUP_QRCODE_DELETE(8,"删除社群二维码"),
+    GROUP_QRCODE_UPDATE(9,"更新社群二维码"),
+    APP_CREATE(10,"创建应用"),
+    APP_DELETE(11,"删除应用"),
+    APP_UPDATE(12,"更新应用"),
+    MATERIAL_CREATE(13,"创建素材"),
+    MATERIAL_DELETE(14,"删除素材"),
+    MATERIAL_UPDATE(15,"更新素材"),
+    DISCOUNT_CREATE(16,"创建折扣工具"),
+    DISCOUNT_DELETE(17,"删除折扣工具"),
+    DISCOUNT_UPDATE(18,"更新折扣工具"),
+    ACTIVITY_CREATE(19,"创建赠品促销工具"),
+    ACTIVITY_DELETE(20,"删除赠品促销工具"),
+    ACTIVITY_UPDATE(21,"更新赠品促销工具"),
+    COUPON_CREATE(22,"创建优惠券工具"),
+    COUPON_DELETE(23,"删除优惠券工具"),
+    COUPON_UPDATE(24,"更新优惠券工具");
+
+    public Integer code;
+
+    public String desc;
+
+    UpdateSuperSearchCode(Integer code, String desc) {
+        this.code = code;
+        this.desc = desc;
+    }
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/dto/UpdateSuperSearchMQDTO.java

+package com.pcloud.common.core.dto;
+
+import com.pcloud.common.core.constant.UpdateSuperSearchCode;
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class UpdateSuperSearchMQDTO {
+    //更新类型
+    private UpdateSuperSearchCode superSearchCode;
+    //子类型
+    private Integer childTypeCode;
+    //es主键id
+    private String id;
+
+    //es资源id
+    private Long resourceId;
+
+    //es资源名称
+    private String resourceName;
+}