安全路径求解结果

dbscript/init/generate/03-functionInit.sql

@@ -102,3 +102,4 @@ INSERT INTO SYS_FUNCTION(FUNCTIONID, CLASSNAME, FUNCTIONNAME ,ENABLE)VALUES ('M0
 INSERT INTO SYS_FUNCTION(FUNCTIONID, CLASSNAME, FUNCTIONNAME ,ENABLE)VALUES ('M00002', '基础系统','平台对接预设路径',true);
 INSERT INTO SYS_FUNCTION(FUNCTIONID, CLASSNAME, FUNCTIONNAME ,ENABLE)VALUES ('M00003', '基础系统','平台对接求解状态',true);
 INSERT INTO SYS_FUNCTION(FUNCTIONID, CLASSNAME, FUNCTIONNAME ,ENABLE)VALUES ('M00004', '基础系统','平台对接求解结果',true);
+INSERT INTO SYS_FUNCTION(FUNCTIONID, CLASSNAME, FUNCTIONNAME ,ENABLE)VALUES ('M00005', '基础系统','平台对接安全路径求解结果',true);

generated/com/miniframe/generate/business/system/model/M00005BaseModel.java

@@ -0,0 +1,112 @@
+package com.miniframe.generate.business.system.model;
+
+import java.util.Map;
+import java.io.IOException;
+import java.util.LinkedHashMap;
+import com.miniframe.core.BaseMapModel;
+import com.miniframe.core.ext.UtilTools;
+import com.miniframe.core.ext.HttpMapFormater;
+import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
+import com.miniframe.generate.global.AppGlobalVariableSysconfig;
+
+import com.miniframe.generate.comm.system.A_SYSTEMHEAD;
+import com.miniframe.generate.comm.system.D_SYSTEMHEAD;
+import com.miniframe.generate.comm.system.A_M00005;
+import com.miniframe.generate.comm.system.D_M00005;
+
+/**
+ * 系统服务,“平台对接安全路径求解结果”模型类（不要维护，重新生成将覆盖）。
+ */
+@SuppressWarnings({ "rawtypes", "unchecked" })
+public class M00005BaseModel extends BaseMapModel {
+
+	private static final long serialVersionUID = -1326184831746814093L;
+
+	A_SYSTEMHEAD a_systemhead;//上行头
+	D_SYSTEMHEAD d_systemhead;//下行头
+	A_M00005 a_m00005;//上行体
+	D_M00005 d_m00005;//下行体
+
+	public M00005BaseModel(){
+		a_systemhead=new A_SYSTEMHEAD();
+		d_systemhead=new D_SYSTEMHEAD();
+		a_m00005=new A_M00005();
+		d_m00005=new D_M00005();
+	}
+
+	public void validater() throws Exception {
+		this.a_systemhead.validater();
+		this.a_m00005.validater();
+	}
+
+	public void setTransMap(Map map) throws Exception {
+		Map headMap = HttpMapFormater.format(map, A_SYSTEMHEAD.class);
+		this.a_systemhead = UtilTools.map2Obj(headMap, A_SYSTEMHEAD.class);
+		Map bodyMap = HttpMapFormater.format(map, A_M00005.class);
+		this.a_m00005 = UtilTools.map2Obj(bodyMap, A_M00005.class);
+	}
+
+	public Map getTransMap() throws Exception {
+		Map reMap = new LinkedHashMap();
+
+		if(UtilTools.isNullOrBlank((this.d_systemhead).getTransCode())){
+			(this.d_systemhead).setTransCode((this.a_systemhead).getTransCode());
+		}
+		if(UtilTools.isNullOrBlank((this.d_systemhead).getChannelNo())){
+			(this.d_systemhead).setChannelNo((this.a_systemhead).getChannelNo());
+		}
+		if(UtilTools.isNullOrBlank((this.d_systemhead).getUserId())){
+			(this.d_systemhead).setUserId((this.a_systemhead).getUserId());
+		}
+        if(UtilTools.isNullOrBlank((this.d_systemhead).getTransTime())){
+            (this.d_systemhead).setTransTime(DateTimeFormatter.ofPattern(AppGlobalVariableSysconfig.DATETIMEFORMAT).format(ZonedDateTime.now()));
+        }
+
+		reMap.putAll(UtilTools.obj2Map(this.d_systemhead));
+		reMap.putAll(UtilTools.obj2Map(this.d_m00005));
+
+		return reMap;
+	}
+
+	public A_SYSTEMHEAD getA_systemhead() {
+		return this.a_systemhead;
+	}
+
+	public void setA_systemhead(A_SYSTEMHEAD a_systemhead) {
+		this.a_systemhead=a_systemhead;
+	}
+
+	public D_SYSTEMHEAD getD_systemhead() {
+		return d_systemhead;
+	}
+
+	public void setD_systemhead(D_SYSTEMHEAD d_systemhead) {
+		this.d_systemhead=d_systemhead;
+	}
+
+	public A_M00005 getA_m00005() {
+		return a_m00005;
+	}
+
+	public void setA_m00005(A_M00005 a_m00005) {
+		this.a_m00005=a_m00005;
+	}
+
+	public D_M00005 getD_m00005() {
+		return this.d_m00005;
+	}
+
+	public void setD_m00005(D_M00005 d_m00005) {
+		this.d_m00005=d_m00005;
+	}
+
+	@Override
+	public String toString() {
+		try {
+			return UtilTools.obj2Json(this,true);
+		} catch (IOException e) {
+			return "";
+		}
+	}
+}

generated/com/miniframe/generate/comm/httpclientapater/M00005Client.java

@@ -0,0 +1,99 @@
+package com.miniframe.generate.comm.httpclientapater;
+
+import com.miniframe.spring.httpclient.MFHttpRespInfo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import com.miniframe.core.Transmitter;
+import com.miniframe.core.ext.UtilTools;
+import com.miniframe.generate.comm.system.D_M00005;
+import com.miniframe.generate.comm.system.D_SYSTEMHEAD;
+
+import com.miniframe.generate.business.system.model.M00005BaseModel;
+
+public class M00005Client {
+
+	private static final Logger logger = LoggerFactory.getLogger(M00005Client.class);
+	private MFHttpRespInfo respInfo;
+
+	public MFHttpRespInfo getRespInfo(){
+		return respInfo;
+	}
+
+	/**
+	 * 调用 [系统服务->平台对接安全路径求解结果((M00005)]的通讯接口
+	 * @param model 接口模型
+	 * @param extMap 扩展输入
+	 * @param url 请求地址
+	 * @return model 接口模型
+	 * @throws Exception
+	 */
+	@SuppressWarnings({ "rawtypes", "unchecked" })
+	public M00005BaseModel execute(M00005BaseModel model,final Map extMap,final String url) throws Exception {
+		this.executeToRespInfo(model,extMap,url);
+		return model;
+	}
+
+	@SuppressWarnings({ "rawtypes", "unchecked" })
+	public M00005BaseModel execute(M00005BaseModel model,final Map extMap) throws Exception {
+		this.executeToRespInfo(model,extMap,null);
+		return model;
+	}
+
+
+	@SuppressWarnings({ "rawtypes", "unchecked" })
+	public MFHttpRespInfo executeToRespInfo(M00005BaseModel model,final Map extMap,final String url) throws Exception {
+		if (logger.isDebugEnabled()) {
+			logger.debug("execute(M00005BaseModel) - start");
+		}
+
+		if(UtilTools.isNullOrBlank(model.getA_systemhead().getTransCode())){
+			model.getA_systemhead().setTransCode("M00005");
+		}
+
+		Map inMap = new LinkedHashMap();
+		inMap.putAll(UtilTools.obj2Map(model.getA_systemhead()));
+		inMap.putAll(UtilTools.obj2Map(model.getA_m00005()));
+		if(extMap!=null && extMap.size()>0){
+			inMap.putAll(extMap);
+		}
+
+		Transmitter httpclientApater = (Transmitter) UtilTools.getBean("httpclientApater");
+		MFHttpRespInfo respInfo;
+		if(UtilTools.isNotNullAndBlank(url)){
+			respInfo = httpclientApater.doPostDataToRespInfo(inMap,url);
+		}else{
+			respInfo = httpclientApater.doPostDataToRespInfo(inMap);
+		}
+
+		if(respInfo!=null) {
+			Map outMap=respInfo.getParamMap();
+			D_SYSTEMHEAD d_systemhead =  UtilTools.map2Obj(outMap, D_SYSTEMHEAD.class);
+			D_M00005 d_m00005 =  UtilTools.map2Obj(outMap, D_M00005.class);
+			model.setD_systemhead(d_systemhead);
+			model.setD_m00005(d_m00005);
+
+
+		}
+
+		if (logger.isDebugEnabled()) {
+			logger.debug("execute(M00005BaseModel) - end");
+		}
+
+        this.respInfo=respInfo;
+
+		return respInfo;
+	}
+
+
+
+	@SuppressWarnings({ "rawtypes", "unchecked" })
+	public M00005BaseModel execute(M00005BaseModel model) throws Exception {
+		return this.execute(model,null,null);
+	}
+
+
+}

generated/com/miniframe/generate/comm/system/A_M00005.java

@@ -5,47 +5,21 @@ package com.miniframe.generate.comm.system;
 import com.miniframe.core.BaseMapModel;
 import java.io.Serializable;
 /**
- * 功能权限修改
+ * 平台对接安全路径求解结果
  */
 public class A_M00005 extends BaseMapModel implements Serializable {
 	private static final long serialVersionUID = -1463838678425832212L;
-	String funcId;//功能ID
+	int aid;//事故ID
 	/**
-	 *功能ID
+	 *事故ID
 	 */
-	public void setFuncId(String funcId) {
-		this.funcId=funcId;
+	public void setAid(int aid) {
+		this.aid=aid;
 	}
 	/**
-	 *功能ID
+	 *事故ID
 	 */
-	public String getFuncId() {
-		return this.funcId;
-	}
-	String funcName;//功能名称
-	/**
-	 *功能名称
-	 */
-	public void setFuncName(String funcName) {
-		this.funcName=funcName;
-	}
-	/**
-	 *功能名称
-	 */
-	public String getFuncName() {
-		return this.funcName;
-	}
-	String funcDesc;//功能说明
-	/**
-	 *功能说明
-	 */
-	public void setFuncDesc(String funcDesc) {
-		this.funcDesc=funcDesc;
-	}
-	/**
-	 *功能说明
-	 */
-	public String getFuncDesc() {
-		return this.funcDesc;
+	public int getAid() {
+		return this.aid;
 	}
 }

generated/com/miniframe/generate/comm/system/D_M00005.java

@@ -4,9 +4,36 @@
 package com.miniframe.generate.comm.system;
 import com.miniframe.core.BaseMapModel;
 import java.io.Serializable;
+import java.util.*;
 /**
- * 功能权限修改
+ * 平台对接安全路径求解结果
  */
 public class D_M00005 extends BaseMapModel implements Serializable {
 	private static final long serialVersionUID = -1463838678425832212L;
+	int aid;//事故ID
+	/**
+	 *事故ID
+	 */
+	public void setAid(int aid) {
+		this.aid=aid;
+	}
+	/**
+	 *事故ID
+	 */
+	public int getAid() {
+		return this.aid;
+	}
+	List <D_M00005_LINES_RECODE> lines;//路径数据
+	/**
+	 *路径数据
+	 */
+	public void setLines(List <D_M00005_LINES_RECODE> lines) {
+		this.lines=lines;
+	}
+	/**
+	 *路径数据
+	 */
+	public List <D_M00005_LINES_RECODE> getLines() {
+		return this.lines;
+	}
 }

generated/com/miniframe/generate/comm/system/D_M00005_LINES_RECODE.java

@@ -0,0 +1,38 @@
+/**
+ * 系统服务
+ */
+package com.miniframe.generate.comm.system;
+import com.miniframe.core.BaseMapModel;
+import java.io.Serializable;
+/**
+ * 平台对接安全路径求解结果->路径数据
+ */
+public class D_M00005_LINES_RECODE extends BaseMapModel implements Serializable {
+	private static final long serialVersionUID = -1463838678425832212L;
+	String lname;//路径名称
+	/**
+	 *路径名称
+	 */
+	public void setLname(String lname) {
+		this.lname=lname;
+	}
+	/**
+	 *路径名称
+	 */
+	public String getLname() {
+		return this.lname;
+	}
+	String level;//安全等级
+	/**
+	 *安全等级
+	 */
+	public void setLevel(String level) {
+		this.level=level;
+	}
+	/**
+	 *安全等级
+	 */
+	public String getLevel() {
+		return this.level;
+	}
+}

generated/validateform/a_m00005Form.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE form-validation PUBLIC "-//Apache Software Foundation//DTD Commons Validator Rules Configuration 1.1//EN" "http://jakarta.apache.org/commons/dtds/validator_1_1.dtd">
+<!-- 平台对接安全路径求解结果Form配置文件系统生成请勿修改,否则重新生成将覆盖 -->
+<form-validation>
+<formset>
+<form name="a_m00005Form">
+<field property="aid" depends="required">
+    <arg0 key="a_m00005.aid"/>
+</field>
+</form>
+</formset>
+</form-validation>

generated/validateform/d_m00005Form.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE form-validation PUBLIC "-//Apache Software Foundation//DTD Commons Validator Rules Configuration 1.1//EN" "http://jakarta.apache.org/commons/dtds/validator_1_1.dtd">
+<!-- 平台对接安全路径求解结果Form配置文件系统生成请勿修改,否则重新生成将覆盖 -->
+<form-validation>
+<formset>
+<form name="d_m00005Form">
+<field property="aid" depends="required">
+    <arg0 key="d_m00005.aid"/>
+</field>
+</form>
+</formset>
+</form-validation>

generated/validateform/d_m00005_lines_recodeForm.xml

@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE form-validation PUBLIC "-//Apache Software Foundation//DTD Commons Validator Rules Configuration 1.1//EN" "http://jakarta.apache.org/commons/dtds/validator_1_1.dtd">
+<!-- 平台对接安全路径求解结果->路径数据Form配置文件系统生成请勿修改,否则重新生成将覆盖 -->
+<form-validation>
+<formset>
+<form name="d_m00005_lines_recodeForm">
+<field property="lname" depends="required">
+    <arg0 key="d_m00005_lines_recode.lname"/>
+</field>
+<field property="level" depends="required">
+    <arg0 key="d_m00005_lines_recode.level"/>
+</field>
+</form>
+</formset>
+</form-validation>

generated/validator/resources_a_m00005Form_validator.properties

@@ -0,0 +1,2 @@
+a_m00005.aid = \u4E8B\u6545ID
+a_m00005Form = true

generated/validator/resources_a_m00005Form_validator_zh_CN.properties

@@ -0,0 +1,2 @@
+a_m00005.aid = \u4E8B\u6545ID
+a_m00005Form = true

generated/validator/resources_d_m00005Form_validator.properties

@@ -0,0 +1,2 @@
+d_m00005.aid = \u4E8B\u6545ID
+d_m00005Form = true

generated/validator/resources_d_m00005Form_validator_zh_CN.properties

@@ -0,0 +1,2 @@
+d_m00005.aid = \u4E8B\u6545ID
+d_m00005Form = true

generated/validator/resources_d_m00005_lines_recodeForm_validator.properties

@@ -0,0 +1,3 @@
+d_m00005_lines_recode.lname = \u8DEF\u5F84\u540D\u79F0
+d_m00005_lines_recode.level = \u5B89\u5168\u7B49\u7EA7
+d_m00005_lines_recodeForm = true

generated/validator/resources_d_m00005_lines_recodeForm_validator_zh_CN.properties

@@ -0,0 +1,3 @@
+d_m00005_lines_recode.lname = \u8DEF\u5F84\u540D\u79F0
+d_m00005_lines_recode.level = \u5B89\u5168\u7B49\u7EA7
+d_m00005_lines_recodeForm = true

src/main/java/com/miniframe/bisiness/system/M00005Service.java

@@ -0,0 +1,70 @@
+package com.miniframe.bisiness.system;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import com.miniframe.core.ExecProcessFlow;
+import com.miniframe.core.ext.UtilTools;
+import com.miniframe.generate.business.system.model.M00005BaseModel;
+import com.miniframe.generate.comm.system.D_M00004_LINES_RECODE;
+import com.miniframe.generate.comm.system.D_M00005_LINES_RECODE;
+import com.miniframe.model.system.DMway;
+import com.miniframe.model.system.DMwaySQLBuilder;
+import com.miniframe.model.system.dao.DMwayMapper;
+
+/**
+ * 基础系统,“平台对接安全路径求解结果”逻辑处理（重新生成不覆盖）。
+ */
+public class M00005Service extends M00005BaseModel implements ExecProcessFlow {
+	
+	private static final long serialVersionUID = -7051358269847459502L;
+		
+	/**
+	 * 基础系统,“平台对接安全路径求解结果”业务核心处理
+ 	 */
+	public void transExecute() throws Exception {
+		Integer aid =this.getA_m00005().getAid();
+		DMwayMapper wdao = UtilTools.getBean(DMwayMapper.class);
+		DMwaySQLBuilder wsb =new DMwaySQLBuilder();
+		DMwaySQLBuilder.Criteria wsc =wsb.createCriteria();
+		wsc.andAidEqualTo(aid);
+		List<DMway> ways= wdao.selectByExample(wsb);
+		List<D_M00005_LINES_RECODE> lines =new ArrayList<>();
+		for (DMway w:ways) {
+			D_M00005_LINES_RECODE line = new D_M00005_LINES_RECODE();
+			line.setLname(w.getLname());
+			line.setLevel(w.getLevel());
+			lines.add(line);
+		}
+		this.getD_m00005().setAid(aid);
+		this.getD_m00005().setLines(lines);
+	}
+	
+	/**
+	 * 基础系统,“平台对接安全路径求解结果”业务前处理
+ 	 */
+	public void preTransFlow() throws Exception {
+		this.validater();
+	}
+	
+	/**
+	 * 基础系统,“平台对接安全路径求解结果”业务后处理
+ 	 */
+	public void afterTransFlow() throws Exception {
+	
+	}
+	
+	/**
+	 * 基础系统,“平台对接安全路径求解结果”逻辑入口处理方法
+ 	 */
+ 	@SuppressWarnings("rawtypes")
+	@Override
+	public Map execute(Map vars) throws Exception {
+		this.setTransMap(vars);
+		preTransFlow();// 执行业务开始的规则检查和校验
+		transExecute();// 执行核心业务段
+		afterTransFlow();// 执行核心逻辑完成后的收尾逻辑
+		return this.getTransMap();
+	}
+
+}

src/main/java/com/miniframe/solverjob/DockerExe.java

@@ -6,15 +6,15 @@ import com.github.dockerjava.api.command.CreateContainerResponse;
 import com.github.dockerjava.api.command.InspectContainerResponse;
 import com.github.dockerjava.api.command.LogContainerCmd;
 import com.github.dockerjava.api.command.RemoveContainerCmd;
-import com.github.dockerjava.api.model.*;
+import com.github.dockerjava.api.model.Frame;
+import com.github.dockerjava.api.model.HostConfig;
+import com.github.dockerjava.api.model.Mount;
+import com.github.dockerjava.api.model.MountType;
 import com.github.dockerjava.core.DefaultDockerClientConfig;
 import com.github.dockerjava.core.DockerClientBuilder;
 import com.github.dockerjava.core.DockerClientConfig;
-import com.github.dockerjava.core.command.RemoveContainerCmdImpl;
 import com.github.dockerjava.httpclient5.ApacheDockerHttpClient;
 import com.github.dockerjava.transport.DockerHttpClient;
-import com.miniframe.disaster.service.LogService;
-import jdk.nashorn.internal.ir.IdentNode;
 
 import java.util.ArrayList;
 import java.util.List;

src/test/java/com/miniframe/comm/httpclientapater/M00005Test.java

@@ -0,0 +1,44 @@
+package com.miniframe.comm.httpclientapater;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import com.miniframe.comm.httpclientapater.HttpclientapaterUtil;
+import com.miniframe.generate.comm.system.A_M00005;
+import com.miniframe.generate.comm.httpclientapater.M00005Client;
+import com.miniframe.generate.business.system.model.M00005BaseModel;
+
+public class M00005Test {
+
+	private static final Logger logger = LoggerFactory.getLogger(M00005Test.class);
+
+	/**
+	 * 平台对接安全路径求解结果，获取报文体
+	 * @return
+	 */
+	public static A_M00005 getA_m00005() {
+		A_M00005 a_m00005 = new A_M00005();
+
+		// ----------以下增加【平台对接安全路径求解结果】上行体赋值-------------
+
+
+
+		// ---------------------------------------------------
+		return a_m00005;
+	}
+	
+	/**
+	 * 运行客户端测试，平台对接安全路径求解结果
+	 * 
+	 * @param args
+	 * @throws Exception
+	 */
+	public static void main(String[] args) throws Exception {
+		M00005BaseModel model = new M00005BaseModel();
+		model.setA_systemhead(HttpclientapaterUtil.getA_systemhead("M00005"));
+		model.setA_m00005(M00005Test.getA_m00005());
+		M00005Client client = new M00005Client();
+		logger.error("客户端发送前总线：\r\n"+model);
+		model = client.execute(model);
+		logger.error("客户端发送后总线：\r\n"+model);
+	}
+}

系统设计/系统模块/SYSTEM(基础系统).csv

@@ -114,4 +114,5 @@
 400001,M00001,平台对接事故数据,service,,
 400002,M00002,平台对接预设路径,service,,
 400003,M00003,平台对接求解状态,service,,
-400003,M00004,平台对接求解结果 ,service,,
+400004,M00004,平台对接求解结果 ,service,,
+400005,M00005,平台对接安全路径求解结果 ,service,,

系统设计/通信设计/通讯报文/system(系统服务)/报文体/M00005_A(平台对接安全路径求解结果).csv

@@ -0,0 +1,2 @@
+序号,英文名称,中文名称,数据类型,默认值,格式化,非空/引用,最小(长度/值),最大(长度/值),验证规则,标准数据ID,XML样式,TAG标签,映射/子标签,CDATA
+1,aid,事故ID,int,,,是,,,,,,,,

系统设计/通信设计/通讯报文/system(系统服务)/报文体/M00005_D(平台对接安全路径求解结果).csv

@@ -0,0 +1,5 @@
+序号,英文名称,中文名称,数据类型,默认值,格式化,非空/引用,最小(长度/值),最大(长度/值),验证规则,标准数据ID,XML样式,TAG标签,映射/子标签,CDATA
+1,aid,事故ID,int,,,是,,,,,,,,
+2,lines,路径数据,list,,,,0,,,,,,,
+2.1,lname,路径名称,string,,,是,,,,,,,,
+2.2,level,安全等级,string,,,是,,,,,,,,