Merge branch 'feature/1004545' into 'master'

feat:[1004545] 超级搜索

See merge request rays/pcloud-common-parent!193

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

@@ -197,4 +197,9 @@ public class MQQueueConstant {
 	 * 商品信息爬取功能
 	 */
 	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;
+}