I3_YF_SEAT
/
i3plus-pojo
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

FTP多文件读取问题

Browse Source 
脚本解析功能初版
yun-zuoyi
汪云昊 5 years ago
parent 101a71970c
commit 18a09cc4b6
9 changed files with 158 additions and 3 deletions
Show Stats Download Patch File Download Diff File

2
modules/i3plus-pojo-model/src/main/java/cn/estsh/i3plus/pojo/model/softswitch/SuitClientModel.java
Unescape Escape View File

@ -105,6 +105,8 @@ public class SuitClientModel implements Serializable {
@XStreamCDATA
private Object suitResultMessage;
private boolean isNeedRetry = false;
public SuitClientModel() {
}

107
modules/i3plus-pojo-softswitch/src/main/java/cn/estsh/i3plus/pojo/softswitch/bean/BsBusiScript.java
Unescape Escape View File

@ -0,0 +1,107 @@
package cn.estsh.i3plus.pojo.softswitch.bean;
import cn.estsh.i3plus.pojo.base.annotation.AnnoOutputColumn;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import cn.estsh.i3plus.pojo.base.enumutil.BlockSoftSwitchEnumUtil;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.apache.commons.lang3.math.NumberUtils;
import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
/**
* @Description : 业务脚本
* @Reference :
* @Author : yunhao
* @CreateDate : 2020-07-28 14:35
* @Modify:
**/
@Data
@Entity
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Table(name = "BS_BUSI_SCRIPT")
@ApiModel(value = "业务脚本", description = "业务脚本")
public class BsBusiScript extends BaseBean {
private static final long serialVersionUID = 1419277265159912600L;
@Column(name = "SCRIPT_NAME")
@ApiModelProperty(value = "脚本名称")
private String scriptName;
@Column(name = "SCRIPT_CODE")
@ApiModelProperty(value = "脚本代码")
private String scriptCode;
@Column(name = "SCRIPT_TYPE")
@ApiModelProperty(value = "脚本类型")
@AnnoOutputColumn(refClass = BlockSoftSwitchEnumUtil.BS_SCRIPT_TYPE.class)
private Integer scriptType;
public String getScriptTypeTxt() {
return scriptType == null ? "无" : BlockSoftSwitchEnumUtil.BS_SCRIPT_TYPE.valueOfDescription(scriptType);
}
@Column(name = "SCRIPT_LANGUAGE")
@ApiModelProperty(value = "脚本语言")
@AnnoOutputColumn(refClass = BlockSoftSwitchEnumUtil.BS_SCRIPT_LANGUAGE.class)
private Integer scriptLanguage;
public String getScriptLanguageTxt() {
return scriptLanguage == null ? "无" : BlockSoftSwitchEnumUtil.BS_SCRIPT_LANGUAGE.valueOfDescription(scriptLanguage);
}
@Column(name = "SCRIPT_EXECUTE_METHOD")
@ApiModelProperty(value = "脚本执行方式")
@AnnoOutputColumn(refClass = BlockSoftSwitchEnumUtil.BS_SCRIPT_EXECUTE_METHOD.class)
private Integer scriptExecuteMethod;
public String getScriptExecuteMethodTxt() {
return scriptExecuteMethod == null ? "无" : BlockSoftSwitchEnumUtil.BS_SCRIPT_EXECUTE_METHOD.valueOfDescription(scriptExecuteMethod);
}
@Column(name = "SCRIPT_OBJ_NAME")
@ApiModelProperty(value = "脚本对象名称")
private String scriptObjName;
@Column(name = "SCRIPT_METHOD_NAME")
@ApiModelProperty(value = "脚本方法名称")
private String scriptMethodName;
@Column(name = "SCRIPT_CONTENT")
@ApiModelProperty(value = "脚本内容")
private String scriptContent;
@Column(name = "SCRIPT_DESC")
@ApiModelProperty(value = "脚本描述")
private String scriptDesc;
@Column(name = "REF_ID")
@ApiModelProperty(value = "关联id")
@JsonSerialize(using = ToStringSerializer.class)
private Long refId;
@Column(name = "SCRIPT_VERSION")
@ApiModelProperty(value = "脚本版本")
private Integer scriptVersion;
public int getScriptVersion(){
return scriptVersion == null ? NumberUtils.INTEGER_ONE : scriptVersion;
}
public BsBusiScript nextVersion() {
setScriptVersion(getScriptVersion() + 1);
return this;
}
}

4
modules/i3plus-pojo-softswitch/src/main/java/cn/estsh/i3plus/pojo/softswitch/bean/BsDataSource.java
Unescape Escape View File

@ -52,6 +52,10 @@ public class BsDataSource extends BaseBean {
@ApiParam(value = "数据源端口")
private Integer dataSourcePort;
@Column(name = "DATA_SOURCE_INSTANCE_NAME")
@ApiParam(value = "数据源实例名称")
private String dataSourceInstanceName;
@Column(name = "DATA_SOURCE_USER")
@ApiParam(value = "用户名")
private String dataSourceUser;

3
modules/i3plus-pojo-softswitch/src/main/java/cn/estsh/i3plus/pojo/softswitch/bean/BsLongData.java
Unescape Escape View File

@ -3,6 +3,8 @@ package cn.estsh.i3plus.pojo.softswitch.bean;
import cn.estsh.i3plus.pojo.base.annotation.AnnoOutputColumn;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import cn.estsh.i3plus.pojo.base.enumutil.BlockSoftSwitchEnumUtil;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiParam;
import lombok.Data;
@ -34,6 +36,7 @@ public class BsLongData extends BaseBean {
private static final long serialVersionUID = -329128754646765129L;
@Column(name = "REF_ID")
@ApiParam(value = "关联id")
@JsonSerialize(using = ToStringSerializer.class)
private Long refId;
@Column(name = "REF_DATA_TYPE")

7
modules/i3plus-pojo-softswitch/src/main/java/cn/estsh/i3plus/pojo/softswitch/bean/BsSuitCase.java
Unescape Escape View File

@ -1,5 +1,6 @@
package cn.estsh.i3plus.pojo.softswitch.bean;
import cn.estsh.i3plus.pojo.base.annotation.AnnoOutputColumn;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import cn.estsh.i3plus.pojo.base.enumutil.BlockSoftSwitchEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
@ -40,6 +41,7 @@ public class BsSuitCase extends BaseBean {
@Column(name = "CASE_TYPE_ID")
@ApiParam(value = "套件类型id(枚举)")
@AnnoOutputColumn(refClass = BlockSoftSwitchEnumUtil.CASE_TYPE.class)
private Integer caseTypeId;
public int getCaseTypeIdVal(){
@ -76,6 +78,7 @@ public class BsSuitCase extends BaseBean {
@Column(name = "SUIT_MODE_ID")
@ApiParam(value = "适配模式(枚举,主动，被动)")
@AnnoOutputColumn(refClass = BlockSoftSwitchEnumUtil.SUIT_MODE.class)
private Integer suitModeId;
@Column(name = "SUIT_ACTION_ID")
@ -230,6 +233,10 @@ public class BsSuitCase extends BaseBean {
@ApiParam(value = "适配器状态")
private Integer suitCaseStatus;
@Column(name = "BIND_BUSI_SCRIPT_CODE")
@ApiParam(value = "绑定业务脚本Code")
private String bindBusiScriptCode;
@Transient
@ApiParam(value = "适配器套件明细")
private Object bsSuitCaseDetail;

4
modules/i3plus-pojo-softswitch/src/main/java/cn/estsh/i3plus/pojo/softswitch/bean/BsSuitRecord.java
Unescape Escape View File

@ -133,6 +133,10 @@ public class BsSuitRecord extends BaseBean {
@ApiParam(value = "处理时间")
private String processTime;
@Column(name = "SCRIPT_RESULT")
@ApiParam(value = "脚本结果")
private String scriptResult;
@Transient
@ApiParam(value = "适配记录参数")
private List<BsSuitRecordParam> bsSuitRecordParamList;

5
modules/i3plus-pojo-softswitch/src/main/java/cn/estsh/i3plus/pojo/softswitch/bean/BsSuitRequestRecord.java
Unescape Escape View File

@ -11,6 +11,7 @@ import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.*;
import java.util.List;
/**
* @Description : 请求适配记录
@ -46,10 +47,12 @@ public class BsSuitRequestRecord extends BaseBean {
private Integer requestSource;
// 移动至记录数据表
@Lob
@Column(name = "REQUEST_ORGIN_PARAM")
@ApiParam(value = "请求原始参数")
private String requestOrginParam;
@Transient
@ApiParam(value = "id-查询条件")
private List<Long> searchIdList;
}

14
modules/i3plus-pojo-softswitch/src/main/java/cn/estsh/i3plus/pojo/softswitch/repository/BsBusiScriptRepository.java
Unescape Escape View File

@ -0,0 +1,14 @@
package cn.estsh.i3plus.pojo.softswitch.repository;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import cn.estsh.i3plus.pojo.softswitch.bean.BsBusiScript;
/**
* @Description : 业务脚本
* @Reference :
* @Author : yunhao
* @CreateDate : 2020-07-28 15:13
* @Modify:
**/
public interface BsBusiScriptRepository extends BaseRepository<BsBusiScript,Long> {
}

15
modules/i3plus-pojo-softswitch/src/main/java/cn/estsh/i3plus/pojo/softswitch/sqlpack/SoftSwitchHqlPack.java
Unescape Escape View File

@ -261,7 +261,7 @@ public class SoftSwitchHqlPack {
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(bsDataSource.getId(), "id", ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsDataSource.getDataSourceCode(), "dataSourceCode", ddlPackBean);
DdlPreparedPack.getStringEqualPack(bsDataSource.getDataSourceCode(), "dataSourceCode", ddlPackBean);
return ddlPackBean;
}
@ -323,6 +323,7 @@ public class SoftSwitchHqlPack {
DdlPreparedPack.getStringLikerPack(bsSuitRecord.getSuitCaseNameRdd(),"suitCaseNameRdd",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitRecord.getSuitTypeId(),"suitTypeId",ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsSuitRecord.getSuitCaseCode(),"suitCaseCode",ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsSuitRecord.getScriptResult(),"scriptResult",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitRecord.getProcessState(),"processState",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitRecord.getSuitCaseId(),"suitCaseId",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitRecord.getCaseTypeId(),"caseTypeId",ddlPackBean);
@ -367,6 +368,7 @@ public class SoftSwitchHqlPack {
public static DdlPackBean packHqlBsSuitRequestRecord(BsSuitRequestRecord bsSuitRequestRecord){
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(bsSuitRequestRecord);
DdlPreparedPack.getInPackList(bsSuitRequestRecord.getSearchIdList(),"id",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitRequestRecord.getSuitCaseId(),"suitCaseId",ddlPackBean);
DdlPreparedPack.timeBuilder(bsSuitRequestRecord.getCreateDatetime(), "createDatetime", ddlPackBean, false, true);
@ -416,7 +418,16 @@ public class SoftSwitchHqlPack {
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(bsLongData);
DdlPreparedPack.timeBuilder(bsLongData.getCreateDatetime(), "createDatetime", ddlPackBean, false, true);
DdlPreparedPack.getNumEqualPack(bsLongData.getRefDataType(),"refDataType",ddlPackBean);
DdlPreparedPack.getStringLikePack(bsLongData.getData(),"data",ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsLongData.getData(),"data",ddlPackBean);
return ddlPackBean;
}
public static DdlPackBean packHqlBsBusiScript(BsBusiScript bsBusiScript){
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(bsBusiScript);
DdlPreparedPack.getStringLikerPack(bsBusiScript.getScriptName(),"scriptName",ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsBusiScript.getScriptCode(),"scriptCode",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsBusiScript.getScriptType(),"scriptType",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsBusiScript.getRefId(),"refId",ddlPackBean);
return ddlPackBean;
}
}

Write Preview
Loading…
Cancel
Save