瀏覽代碼

0611 job表插入记录

caizm 3 月之前
父節點
當前提交
73c108eaee

+ 21 - 0
src/main/java/com/miniframe/bisiness/es/ES0013Service.java

@@ -1,6 +1,7 @@
 package com.miniframe.bisiness.es;
 
 import java.io.File;
+import java.util.Date;
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 
@@ -9,10 +10,14 @@ import com.github.dockerjava.api.model.Frame;
 import com.miniframe.core.ExecProcessFlow;
 import com.miniframe.core.ext.UtilTools;
 import com.miniframe.generate.business.es.model.ES0013BaseModel;
+import com.miniframe.mappers.es.dao.EsMapper;
+import com.miniframe.model.es.EsProJob;
+import com.miniframe.model.es.dao.EsProJobMapper;
 import com.miniframe.tools.XIFileUtils;
 import com.miniframe.tools.docker.DockerExe;
 import es.service.LogService;
 import es.template.TemplateGenerator;
+import org.apache.commons.lang3.StringUtils;
 
 /**
  * 无锡发动机,“项目求解”逻辑处理(重新生成不覆盖)。
@@ -32,6 +37,22 @@ public class ES0013Service extends ES0013BaseModel implements ExecProcessFlow {
 		XIFileUtils.mkdir(XIFileUtils.getRootPathStr()+"/es/"+pid+"/Calculate");
 		XIFileUtils.mkdir(XIFileUtils.getRootPathStr()+"/es/"+pid+"/Calculate/Geometry");//几何路径
 		TemplateGenerator.createPipenetXml(pid);
+
+		EsProJobMapper epjDao = UtilTools.getBean(EsProJobMapper.class);
+		EsProJob esjob = new EsProJob();
+		esjob.setJobId(UtilTools.getUUid());
+		esjob.setPid(pid);
+		esjob.setStartTime(new Date());
+		esjob.setEndTime(new Date());
+		EsMapper esMapper = UtilTools.getBean(EsMapper.class);
+		Integer maxser =esMapper.getProJobSer(pid);
+		maxser=maxser==null?0:maxser;
+		esjob.setSer(maxser+1);
+		esjob.setUid(this.getA_eshead().getUserId());
+		esjob.setCreateTime(new Date());
+		esjob.setUpdateTime(new Date());
+		esjob.setRemark("");
+		epjDao.insert(esjob);
 		run(pid);
 	}
 	private void run(String pid) throws Exception {

+ 7 - 0
src/main/java/com/miniframe/mappers/es/dao/EsMapper.java

@@ -50,6 +50,13 @@ public interface EsMapper extends MiniserviceBaseDao {
     @Select("select max(ser) from es_pro_com where pid =#{pid} and id_code=#{idCode}")
     Integer getProComSer(String pid,String idCode);
 
+    /**
+     * 项目任务 获取最大编号
+     * @param pid
+     * @return
+     */
+    @Select("select max(ser) from es_pro_job where pid =#{pid}")
+    Integer getProJobSer(String pid);
 
     /**
      *  项目组件属性值数据