删除mq消费者

ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/rabbitmq/TopicFXSSJConsumer.java

@@ -1,36 +0,0 @@
-package com.ssj.service.rabbitmq;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import com.alibaba.fastjson.JSONObject;
-import com.ssj.bean.sys.fx.domain.Device;
-import com.ssj.framework.core.rabbitmq.TopicRabbitConfig;
-import com.ssj.service.sys.fx.service.DeviceService;
-
-@Component
-public class TopicFXSSJConsumer {
-	
-	  private static Logger logger = LoggerFactory.getLogger(TopicFXSSJConsumer.class);
-		
-	  @Autowired
-	  private DeviceService deviceService;
-	  
-	  @RabbitListener(queues = {TopicRabbitConfig.topic_fx_ssj})
-	  @RabbitHandler
-	  public void handleMessage(Message message){
-	  	  try {
-			  Device device=JSONObject.parseObject(message.getBody(),Device.class);
-			  deviceService.matchDeviceByMQ(device);
-		  } catch (Exception e){
-	  	  	  logger.error("消费队列消费异常" + e);
-		  }
-	  }
-}
-
-

ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/rabbitmq/TopicRabbitHomeWorkPictureConsumer.java

@@ -1,54 +0,0 @@
-package com.ssj.service.rabbitmq;
-
-import com.alibaba.fastjson.JSONObject;
-import com.ssj.bean.sys.homework.domain.HomeworkPicture;
-import com.ssj.framework.core.rabbitmq.TopicRabbitConfig;
-import com.ssj.service.sys.homework.service.HomeworkPictureService;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-import org.springframework.transaction.PlatformTransactionManager;
-import org.springframework.transaction.TransactionDefinition;
-import org.springframework.transaction.TransactionStatus;
-import org.springframework.transaction.support.DefaultTransactionDefinition;
-
-
-@Component
-public class TopicRabbitHomeWorkPictureConsumer {
-	
-	  private static Logger logger = LoggerFactory.getLogger(TopicRabbitHomeWorkPictureConsumer.class);
-
-	@Autowired
-	private HomeworkPictureService homeworkPictureService;
-
-	@Autowired
-	private PlatformTransactionManager transactionManager;
-
-	  
-	  @RabbitListener(queues = {TopicRabbitConfig.topic_homework_picture_discern})
-	  @RabbitHandler
-	  public void handleMessage(Message message){
-	  	  try {
-			  DefaultTransactionDefinition def = new DefaultTransactionDefinition();
-			  ////新发起一个事务
-			  def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
-			  TransactionStatus status = transactionManager.getTransaction(def);
-			  logger.info("作业修改队列开始消费...");
-			  HomeworkPicture homeworkPicture = JSONObject.parseObject(message.getBody(), HomeworkPicture.class);
-			  logger.error("开始消费推送信息队列数据："+JSONObject.toJSONString(homeworkPicture));
-			  homeworkPictureService.delete(homeworkPicture);
-			  transactionManager.commit(status);
-			  homeworkPictureService.save(homeworkPicture);
-			  transactionManager.commit(status);
-
-		  } catch (Exception e){
-	  	  	  logger.error("消费队列消费异常" + e);
-		  }
-	  }
-}
-
-

ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/rabbitmq/TopicRabbitHomeworkConsumer.java

@@ -1,42 +0,0 @@
-package com.ssj.service.rabbitmq;
-
-import com.ssj.service.ai.model.HomeworkPicturePreDeal;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import com.alibaba.fastjson.JSONObject;
-import com.ssj.framework.core.rabbitmq.TopicRabbitConfig;
-import com.ssj.service.sys.picturepredeal.service.PicturePreDealService;
-
-@Component
-public class TopicRabbitHomeworkConsumer {
-	
-	  private static Logger logger = LoggerFactory.getLogger(TopicRabbitHomeworkConsumer.class);
-		
-	  @Autowired
-	  private PicturePreDealService picturePreDealService;
-	  
-	  private static Long num=0L;
-	  
-	  @RabbitListener(queues = {TopicRabbitConfig.topic_homework_discern})
-	  @RabbitHandler
-	  public void handleMessage(Message message){
-	  	  try {
-			  num = num + 1;
-			  logger.info("作业图片识别答案消息队列开始消费...");
-			  HomeworkPicturePreDeal homeworkPicturePreDeal = JSONObject.parseObject(message.getBody(), HomeworkPicturePreDeal.class);
-			  logger.error("开始消费推送信息队列数据："+JSONObject.toJSONString(homeworkPicturePreDeal));
-			  picturePreDealService.postRequest2AIV1(homeworkPicturePreDeal);
-			  logger.info("作业图片识别答案消息队列完成消费..." + num);
-		  } catch (Exception e){
-	  	  	  logger.error("消费队列消费异常" + e);
-		  }
-	  }
-}
-
-

ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/rabbitmq/TopicRabbitHomeworkFeedbackPushConsumer.java

@@ -1,105 +0,0 @@
-package com.ssj.service.rabbitmq;
-
-import com.alibaba.fastjson.JSONObject;
-import com.ssj.bean.sys.homework.domain.HomeworkPicture;
-import com.ssj.bean.sys.template.CommentTemplate;
-import com.ssj.framework.core.rabbitmq.TopicRabbitConfig;
-import com.ssj.framework.core.util.SystemResourceLocator;
-import com.ssj.service.ai.model.HomeworkFeedbackPushmqModel;
-import com.ssj.service.ai.model.HomeworkPicturePreDeal;
-import com.ssj.service.kmt.dto.CompositionCommentDto;
-import com.ssj.service.sys.homework.request.CorrectionRequest;
-import com.ssj.service.sys.homework.service.HomeworkPictureService;
-import com.ssj.service.sys.homework.service.HomeworkService;
-import com.ssj.service.sys.picturepredeal.service.PicturePreDealService;
-import com.ssj.service.sys.template.CommentTemplateMapperService;
-import com.ssj.service.weixin.library.service.IBookManagerService;
-import com.ssj.sys.util.xunfei.XunFeiTTSUtils;
-import org.apache.commons.collections.CollectionUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import java.util.List;
-import java.util.stream.Collectors;
-
-@Component
-public class TopicRabbitHomeworkFeedbackPushConsumer {
-	
-	  private static Logger logger = LoggerFactory.getLogger(TopicRabbitHomeworkFeedbackPushConsumer.class);
-		
-	  @Autowired
-	  private HomeworkPictureService homeworkPictureService;
-
-	  @Autowired
-      private HomeworkService homeworkService;
-
-	  @Autowired
-      private IBookManagerService bookManagerService;
-
-      @Autowired
-      private CommentTemplateMapperService commentTemplateMapperService;
-	  
-	  private static Long num=0L;
-	  
-	  @RabbitListener(queues = {TopicRabbitConfig.topic_homeworkfeedback_push})
-	  @RabbitHandler
-	  public void handleMessage(Message message){
-	  	  try {
-			  num = num + 1;
-			  logger.info("作业批改结果消息队列开始消费...");
-              HomeworkFeedbackPushmqModel model = JSONObject.parseObject(message.getBody(), HomeworkFeedbackPushmqModel.class);
-              logger.error("开始消费推送信息队列数据："+JSONObject.toJSONString(model));
-              //推送报告
-              try {
-                  Thread.sleep(3000);
-                  logger.error("作业批改结果推送报告处理任务开始---------------");
-                  CorrectionRequest request = model.getRequest();
-                  HomeworkPicture homeworkPicture = model.getHomeworkPicture();
-                  //待批改数累计减一
-                  bookManagerService.updateCorrectHomeworkNum(homeworkPicture.getVipId(), homeworkPicture.getTeacherId(), -1);
-
-                  if (CollectionUtils.isNotEmpty(request.getCompositionCommentList())) {
-                      List<String> selectedCompositionCommentIdList = request.getCompositionCommentList().stream()
-                              .map(CompositionCommentDto::getCompositionCommentId)
-                              .distinct()
-                              .collect(Collectors.toList());
-                      List<CommentTemplate> commentList = commentTemplateMapperService.findCompositionByIds(selectedCompositionCommentIdList);
-                      StringBuilder compositionComments = new StringBuilder();
-                      if (commentList != null) {
-                          for (int i = 0; i < commentList.size(); i++) {
-                              compositionComments.append(i + 1).append(" ").append(commentList.get(i).getComment());
-                          }
-                          if (!compositionComments.toString().equals(homeworkPicture.getCompositionComment())) {
-                              homeworkPicture.setCompositionComment(compositionComments.toString());
-                              try {
-                                  String videoPath = XunFeiTTSUtils.textToVoice(compositionComments.toString(), homeworkPicture.getVipId());
-                                  homeworkPicture.setCompositionCommentPath(videoPath);
-                              } catch (Exception e) {
-                                  logger.error("讯飞转语音异常", e);
-                              }
-                              homeworkPictureService.save(homeworkPicture);
-                          }
-                      }
-                  }
-                  homeworkService.findWrongQuestionAndSetRedis(homeworkPicture.getHomeworkId());
-                  homeworkService.findWrongHowDetailAndSetRedis(homeworkPicture.getHomeworkId());
-                  //批改后删除单科批改详情的缓存
-                  homeworkService.removeRedisCorrectDetailDto4(homeworkPicture.getVipId(), homeworkPicture.getSubject(), homeworkPicture.getCreateTime());
-                  homeworkPictureService.pushTodayFinishHomework(homeworkPicture, 2);
-                  logger.error("作业批改结果推送报告处理任务结束---------------");
-              }catch (Exception e){
-                  logger.error("异常", e);
-              }
-			  logger.info("作业批改结果消息队列完成消费..." + num);
-		  } catch (Exception e){
-	  	  	  logger.error("消费队列消费异常" + e);
-		  }
-	  }
-}
-
-

ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/rabbitmq/TopicRabbitSubmitHomeworkPictureConsumer.java

@@ -1,53 +0,0 @@
-package com.ssj.service.rabbitmq;
-
-import com.alibaba.fastjson.JSONObject;
-import com.ssj.bean.sys.homework.domain.HomeworkPicture;
-import com.ssj.framework.core.rabbitmq.TopicRabbitConfig;
-import com.ssj.service.sys.homework.service.HomeworkPictureService;
-import com.ssj.service.sys.homework.service.HomeworkService;
-import org.apache.commons.lang3.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-/**
- * 用于提交匹配作业
- *
- * @Author: chchen
- * @Description
- * @Date Create in 14:59 2019/11/5
- * @Modified By
- */
-@Component
-public class TopicRabbitSubmitHomeworkPictureConsumer {
-    private static Logger logger = LoggerFactory.getLogger(TopicRabbitSubmitHomeworkPictureConsumer.class);
-    @Autowired
-    private HomeworkPictureService homeworkPictureService;
-    @Autowired
-    private HomeworkService homeworkService;
-
-    @RabbitListener(queues = {TopicRabbitConfig.topic_submit_homework_picture_discern})
-    @RabbitHandler
-    public void handleMessage(Message message){
-        try{
-            HomeworkPicture homeworkPicture = JSONObject.parseObject(message.getBody(), HomeworkPicture.class);
-
-            boolean flag = homeworkService.isCorrected(homeworkPicture.getHomeworkId()) == 1 ? true : false;
-            //推送小塾
-            if (StringUtils.isNotBlank(homeworkPicture.getDerver())){
-                homeworkPictureService.singleSujectPushConche(homeworkPicture, flag, homeworkPicture.getCreateTime());
-            }
-            if (flag){
-                homeworkPictureService.singleSujectPushPad(homeworkPicture, homeworkPicture.getCreateTime());
-            }
-            homeworkService.findWrongQuestionAndSetRedis(homeworkPicture.getHomeworkId());
-            homeworkService.findWrongHowDetailAndSetRedis(homeworkPicture.getHomeworkId());
-        } catch (Exception e){
-            logger.error("提交作业消费队列消费异常" + e);
-        }
-    }
-}

ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/rabbitmq/TopicTabbitProblemSimilarConsumer.java

@@ -1,45 +0,0 @@
-package com.ssj.service.rabbitmq;
-
-import com.alibaba.fastjson.JSONObject;
-import com.ssj.framework.core.rabbitmq.TopicRabbitConfig;
-import com.ssj.service.ai.model.ProblemPicturePreDeal;
-import com.ssj.service.sys.picturepredeal.service.ProblemSimilarPreDealService;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-/**
- * @Author: chchen
- * @Description
- * @Date Create in 15:20 2019/10/23
- * @Modified By
- */
-@Component
-public class TopicTabbitProblemSimilarConsumer {
-
-    private static Logger logger = LoggerFactory.getLogger(TopicRabbitHomeworkConsumer.class);
-
-    @Autowired
-    private ProblemSimilarPreDealService problemSimilarPreDealService;
-
-    private static Long num=0L;
-
-    @RabbitListener(queues = {TopicRabbitConfig.topic_problem_similar_query})
-    @RabbitHandler
-    public void handleMessage(Message message){
-        try {
-            num = num + 1;
-            logger.debug("难题识别答案消息队列开始消费...");
-            ProblemPicturePreDeal problemPicturePreDeal = JSONObject.parseObject(message.getBody(), ProblemPicturePreDeal.class);
-            logger.debug("开始消费推送信息队列数据："+JSONObject.toJSONString(problemPicturePreDeal));
-            problemSimilarPreDealService.postRequest2AI(problemPicturePreDeal);
-            logger.debug("作业图片识别答案消息队列完成消费..." + num);
-        } catch (Exception e){
-            logger.error("消费队列消费异常" + e);
-        }
-    }
-}