渲染文件保存

src/main/java/com/miniframe/service/mq/CaeMQ.java

@@ -2,13 +2,21 @@ package com.miniframe.service.mq;
 
 import com.miniframe.aftercure.ActionMsg;
 import com.miniframe.core.ext.UtilTools;
-import com.miniframe.spring.mq.*;
+import com.miniframe.generate.appcode.Processing;
+import com.miniframe.model.system.AdiSolverConfigImg;
+import com.miniframe.model.system.dao.AdiSolverConfigImgMapper;
+import com.miniframe.spring.mq.IMFMqOp;
+import com.miniframe.spring.mq.MFMqConfig;
+import com.miniframe.spring.mq.MFMqInfo;
+import com.miniframe.spring.mq.MFMqListenerInfo;
+import com.miniframe.tools.XIDateTimeUtils;
 import com.miniframe.tools.XiJsonUtil;
 import com.miniframe.websocket.WebsocketEndPoint;
 import com.rabbitmq.client.Channel;
 import org.springframework.amqp.core.AcknowledgeMode;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.stereotype.Component;
+import tk.mybatis.mapper.util.StringUtil;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -97,7 +105,19 @@ public class CaeMQ extends CaeViewMFMqDynamic {
             try {
                 ActionMsg msg= XiJsonUtil.jsonToPojo(data, ActionMsg.class);
                 WebsocketEndPoint point =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
+                if(!StringUtil.isEmpty(msg.getImg())){
+                    AdiSolverConfigImgMapper configImgMapper= UtilTools.getBean(AdiSolverConfigImgMapper.class);
+                    AdiSolverConfigImg img =new AdiSolverConfigImg();
+                    img.setId(UtilTools.getUUid());
+                    img.setPid(msg.getProId());
+                    img.setSolverConfigId(msg.getSolverConfigid());
+                    img.setCreateTime(XIDateTimeUtils.getNowDate());
+                    img.setStep(msg.getStep());
+                    img.setType(Processing.pre.getIndex());
+                    configImgMapper.insert(img);
+                }
                 point.sendMessageToUser(msg.getProId(),data);
+
             }catch (Exception e){
                 e.printStackTrace();
             }