答题卡pdfmq

sexam/src/main/java/com/xhkjedu/sexam/listener/MessageConsumer.java

@@ -61,8 +61,8 @@ public class MessageConsumer {
      * @Date 2022/8/2 14:00
      **/
     @RabbitHandler
-    @RabbitListener(queues = "${rabbitmq.examImgToPdfHandleQueue}")
-    public void imgToPdfHandleQueue(Message message) {
+    @RabbitListener(queues = "${rabbitmq.examBaseToPdfHandleQueue}")
+    public void baseToPdfHandleQueue(Message message) {
         try {
             String msg = new String(message.getBody(), "UTF-8");
             System.out.println(LocalDateTime.now() + "答题卡图片合并接收消息内容：" + msg);

sexam/src/main/java/com/xhkjedu/sexam/listener/MessageSender.java

@@ -23,8 +23,8 @@ public class MessageSender {
 
     @Value("${rabbitmq.examImgMergeQueue}")
     private String examImgMergeQueue;
-    @Value("${rabbitmq.examImgToPdfQueue}")
-    private String examImgToPdfQueue;
+    @Value("${rabbitmq.examBaseToPdfQueue}")
+    private String examBaseToPdfQueue;
 
 
     /**
@@ -49,10 +49,12 @@ public class MessageSender {
      * @Author wn
      * @Date 2022/8/2 13:57
      **/
-    public void imgToPdf(Integer epid, List<String> imgs) {
+    public void base64ToPdf(Integer epid,Integer examid, List<String> imgs,String savefolder) {
         Map map = new HashMap();
         map.put("epid", epid);
+        map.put("examid", examid);
         map.put("imgs", imgs);
-        rabbitTemplate.convertAndSend(examImgToPdfQueue, JSON.toJSONString(map));
+        map.put("savefolder","");
+        rabbitTemplate.convertAndSend(examBaseToPdfQueue, JSON.toJSONString(map));
     }
 }

sexam/src/main/java/com/xhkjedu/sexam/mapper/paper/EPaperMapper.java

@@ -58,4 +58,7 @@ public interface EPaperMapper extends TkMapper<EPaper> {
 
     //保存答题卡pdf
     void updatePaperScantronpdf(@Param("paper") EPaper paper);
+
+    //获取试卷中答题卡文件
+    Map getPaperScantronfile(@Param("epid") Integer epid);
 }

sexam/src/main/java/com/xhkjedu/sexam/service/paper/EPaperQtypeService.java

@@ -8,16 +8,19 @@ import com.xhkjedu.sexam.mapper.paperstudent.EPaperStudentQuestionMapper;
 import com.xhkjedu.sexam.mapper.system.UserBasketMapper;
 import com.xhkjedu.sexam.model.paper.*;
 import com.xhkjedu.sexam.model.paperstudent.EPaperStudentQuestion;
+import com.xhkjedu.sexam.utils.ConvertUtil;
 import com.xhkjedu.sexam.utils.ExamUtil;
 import com.xhkjedu.sexam.vo.paper.*;
 import com.xhkjedu.utils.N_Utils;
 import com.xhkjedu.vo.ResultVo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
+import java.io.File;
 import java.util.*;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -48,6 +51,8 @@ public class EPaperQtypeService {
     private EPaperStudentQuestionMapper ePaperStudentQuestionMapper;
     @Resource
     private EPaperStudentMapper ePaperStudentMapper;
+    @Autowired
+    private ConvertUtil convertUtil;
 
 
     /**
@@ -621,8 +626,25 @@ public class EPaperQtypeService {
         ePaperQtypeMapper.updateBatchQuestionForScan(questions);
         if(paper.getPstate() == 1){
             eSubjectMapper.updateEsubjectStateByEpid(1,paper.getEpid());
+            //提交之后把答题卡base图片转成pdf
+//            chandleScantronFile(paper.getEpid());
+        }
+    }
 
-
+    //答题卡种图片处理
+    private void chandleScantronFile(Integer epid){
+        //获取试卷中答题卡文件，
+        Map map = ePaperMapper.getPaperScantronfile(epid);
+        if(map.get("scantronfile")!=null){
+            List<String> scantronfiles = JSON.parseArray(map.get("scantronfile").toString(),String.class);
+            if(N_Utils.isNotEmpty(scantronfiles)){
+                Integer examid = Integer.parseInt(map.get("examid").toString());
+                Integer schoolid = Integer.parseInt(map.get("schoolid").toString());
+                String cloudcode =  map.get("cloudcode").toString();
+                String path = cloudcode + File.separator + schoolid + File.separator + "exam" +
+                        File.separator;
+                convertUtil.baseToPdf(epid,examid,scantronfiles,path);
+            }
         }
     }
 }

sexam/src/main/java/com/xhkjedu/sexam/utils/ConvertUtil.java

@@ -28,4 +28,15 @@ public class ConvertUtil {
         messageSender.imgMerge(psqid, userAnswers, device);
     }
 
+    /**
+     * @Description  答题卡base64转pdf
+     * @Param [epid, examid, imgs, savefolder]
+     * @Return void
+     * @Author wn
+     * @Date 2022/8/2 17:20
+     **/
+    public void baseToPdf(Integer epid,Integer examid, List<String> imgs, String savefolder) {
+        messageSender.base64ToPdf(epid, examid,imgs, savefolder);
+    }
+
 }

sexam/src/main/resources/application.properties

@@ -54,8 +54,8 @@ redisdatatime=604800
 
 rabbitmq.examImgMergeQueue=xhkjedu.xhschool.examImgMergeQueue_dev
 rabbitmq.examImgMergeHandleQueue=xhkjedu.xhschool.examImgMergeHandleQueue_dev
-rabbitmq.examImgToPdfQueue=xhkjedu.xhschool.examImgToPdfQueue_dev
-rabbitmq.examImgToPdfHandleQueue=xhkjedu.xhschool.examImgToPdfHandleQueue_dev
+rabbitmq.examBaseToPdfQueue=xhkjedu.xhschool.examBaseToPdfQueue_dev
+rabbitmq.examBaseToPdfHandleQueue=xhkjedu.xhschool.examBaseToPdfHandleQueue_dev
 spring.rabbitmq.host=116.63.199.166
 spring.rabbitmq.port=5672
 spring.rabbitmq.username=xhkjedu

sexam/src/main/resources/mapper/paper/EPaperMapper.xml

@@ -117,4 +117,12 @@
         update e_paper set scantronpdf=#{paper.scantronpdf} where epid=#{paper.epid}
     </update>
 
+    <!--获取试卷中答题卡文件-->
+    <select id="getPaperScantronfile" resultType="java.util.Map">
+        select p.epid,p.examid,p.scantronfile,e.schoolid,
+        (select cloudcode from t_cloud limit 1) cloudcode
+        from e_paper p left join e_base e on p.examid=e.examid
+        where p.epid=#{epid}
+    </select>
+
 </mapper>