错题本二期知识点浮生内容

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

+/**
+ *
+ */
+package com.pcloud.common.core.biz;
+
+import com.pcloud.common.core.dto.KnowledgeUseMQDTO;
+import com.pcloud.common.exceptions.BizException;
+
+/**
+ * @author：songx
+ * @date：2019/6/20,11:38
+ */
+public interface KnowledgeUseQueueBiz {
+    
+    /**
+     * 发送消息
+     *
+     * @param knowledgeUseMQDTO
+     */
+    void send(KnowledgeUseMQDTO knowledgeUseMQDTO) throws BizException;
+    
+}

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

@@ -17,7 +17,7 @@ public interface TranscodeQueueBiz {
 	/**
 	 * 发送消息
 	 * 
-	 * @param messageQueueDto
+	 * @param transcodeMQDTO
 	 */
 	void sendTranscodeQueue(TranscodeMQDTO transcodeMQDTO) throws BizException;
 

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

+/**
+ *
+ */
+package com.pcloud.common.core.biz.impl;
+
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import com.pcloud.common.core.aspect.ParamLog;
+import com.pcloud.common.core.biz.KnowledgeUseQueueBiz;
+import com.pcloud.common.core.constant.MQQueueConstant;
+import com.pcloud.common.core.dto.KnowledgeUseMQDTO;
+import com.pcloud.common.exceptions.BizException;
+
+/**
+ * @author：songx
+ * @date：2019/6/20,11:37
+ */
+@Component
+public class KnowledgeUseQueueBizImpl implements KnowledgeUseQueueBiz {
+    
+    @Autowired
+    private AmqpTemplate amqpTemplate;
+    
+    /**
+     * 知识点标签使用QUEUE
+     */
+    @Override
+    @ParamLog("知识点标签使用QUEUE")
+    public void send(KnowledgeUseMQDTO knowledgeUseMQDTO) throws BizException {
+        if (knowledgeUseMQDTO == null) {
+            throw BizException.PARAM_IS_NULL;
+        }
+        amqpTemplate.convertAndSend(MQQueueConstant.KNOWLEDGE_USE, knowledgeUseMQDTO);
+    }
+    
+}

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

@@ -11,6 +11,11 @@ package com.pcloud.common.core.constant;
 public class MQQueueConstant {
     
     /**
+     * 知识点标签使用
+     */
+    public static final String KNOWLEDGE_USE = "knowledgeUse";
+    
+    /**
 	 * 模板消息
 	 */
 	public static final String TEMPLATE = "templateQueue";

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

+/**
+ *
+ */
+package com.pcloud.common.core.dto;
+
+import java.io.Serializable;
+import java.util.List;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+/**
+ * @author：songx
+ * @date：2018年5月17日,下午4:27:26
+ */
+@Getter
+@Setter
+@ToString(callSuper = true)
+public class KnowledgeUseMQDTO implements Serializable {
+    
+    private static final long serialVersionUID = -6111501255761694004L;
+    
+    /**
+     * 知识点标签
+     */
+    private List<Long> knowledgeIds;
+    
+    public KnowledgeUseMQDTO() {
+    }
+    
+    public KnowledgeUseMQDTO(List<Long> knowledgeIds) {
+        this.knowledgeIds = knowledgeIds;
+    }
+}

pcloud-common/src/main/java/com/pcloud/common/exceptions/ParamCheck.java

@@ -91,6 +91,21 @@ public class ParamCheck {
     }
     
     /**
+     * check bety[] is null
+     *
+     * @param bts
+     * @param msg
+     * @throws BizException
+     * @author songx
+     * @date 2019年4月23日, 下午3:07:37
+     */
+    public static void isEmpty(byte[] bts, String msg) throws BizException {
+        if (bts == null || bts.length == 0) {
+            throw new BizException(BizException.PARAM_IS_NULL.getCode(), msg);
+        }
+    }
+    
+    /**
      * 校验分页参数校验分页参数
      *
      * @param basePageVO