Merge branch 'dev' into test

yun-zuoyi
crish 6 years ago
commit 4a1ad40dfa

@ -48,7 +48,7 @@ public class AndonManageQueue extends BaseBean {
@Column(name = "ALARM_CODE")
@ApiParam(value = "安灯类型")
@AnnoOutputColumn(refClass = AndonEnumUtil.ALARM_TYPE.class,refForeignKey = "code",value = "description")
@AnnoOutputColumn(refClass = AndonEnumUtil.ALARM_TYPE.class,refForeignKey = "value",value = "description")
private String alarmCode;
@Column(name = "ACTION_CODE")

@ -60,7 +60,7 @@ public class XStreamFactory {
}
});
xStream.setMode(XStream.NO_REFERENCES);
// xStream.setMode(XStream.NO_REFERENCES);
xStream.autodetectAnnotations(true);
return xStream;

@ -10,19 +10,19 @@ import org.apache.commons.lang3.StringUtils;
* @CreateDate : 2019-08-13 9:34
* @Modify:
**/
public class SoftSwitchEnumUtil {
public class BlockSoftSwitchEnumUtil {
/**
*
*/
@JsonFormat(shape = JsonFormat.Shape.OBJECT)
public enum CASE_TYPE{
SOCKET(1,"SOCKET"),
RESTFUL(2,"RESTFUL"),
DATASOURCE(3,"数据源"),
WEBSERVICE(4,"WebService"),
MQ(5,"消息队列"),
WebSocket(6,"WebSocket");
SOCKET(10,"SOCKET"),
RESTFUL(20,"RESTFUL"),
DATASOURCE(30,"数据源"),
WEBSERVICE(40,"WebService"),
MQ(50,"消息队列"),
WebSocket(60,"WebSocket");
private int value;
private String description;
@ -57,7 +57,8 @@ public class SoftSwitchEnumUtil {
@JsonFormat(shape = JsonFormat.Shape.OBJECT)
public enum REQUEST_SOURCE{
ACTIVE(1,"主动请求"),
SCHEDULE(2,"定时调度");
SCHEDULE(2,"定时调度"),
RABBITMQ(3,"MQ 调用");
private int value;
private String description;
@ -234,7 +235,7 @@ public class SoftSwitchEnumUtil {
return tmp;
}
public static SoftSwitchEnumUtil.DATA_SOURCE_TYPE valueOf(int val) {
public static BlockSoftSwitchEnumUtil.DATA_SOURCE_TYPE valueOf(int val) {
String tmp = null;
for (int i = 0; i < values().length; i++) {
if (values()[i].value == val) {
@ -267,7 +268,7 @@ public class SoftSwitchEnumUtil {
return null;
}
public static SoftSwitchEnumUtil.DATA_SOURCE_TYPE getDataSourceURL(String databaseProductName){
public static BlockSoftSwitchEnumUtil.DATA_SOURCE_TYPE getDataSourceURL(String databaseProductName){
if(StringUtils.isNotBlank(databaseProductName)){
if(databaseProductName.indexOf(":mysql:") != -1){
return SOURCE_MARIA_DB;
@ -304,11 +305,11 @@ public class SoftSwitchEnumUtil {
*/
@JsonFormat(shape = JsonFormat.Shape.OBJECT)
public enum PARAM_VALUE_TYPE{
NUM(1,"数字"),
STRING(2,"字符串"),
BOOLEAN(3,"布尔"),
MAP(4,"字典"),
LIST(5,"列表");
NUM(10,"数字"),
STRING(20,"字符串"),
BOOLEAN(30,"布尔"),
MAP(40,"字典"),
LIST(50,"列表");
private int value;
private String description;
@ -378,8 +379,8 @@ public class SoftSwitchEnumUtil {
*/
@JsonFormat(shape = JsonFormat.Shape.OBJECT)
public enum SUIT_MODE{
ACTIVE(1,"主动"),
PASSIVE(2,"被动");
ACTIVE(1,"客户端"),
PASSIVE(2,"服务端");
private int value;
private String description;
@ -443,4 +444,76 @@ public class SoftSwitchEnumUtil {
}
}
/**
*
*/
@JsonFormat(shape = JsonFormat.Shape.OBJECT)
public enum DATABASE_OPERATE_TYPE{
READ(1,"读取"),
WRITE(2,"写入");
private int value;
private String description;
DATABASE_OPERATE_TYPE(int value, String description) {
this.value = value;
this.description = description;
}
public int getValue() {
return value;
}
public String getDescription() {
return description;
}
public static String valueOfDescription(int val) {
String tmp = null;
for (int i = 0; i < values().length; i++) {
if (values()[i].value == val) {
tmp = values()[i].description;
}
}
return tmp;
}
}
/**
*
*/
@JsonFormat(shape = JsonFormat.Shape.OBJECT)
public enum SUIT_SERVER_WEB_SERVICE{
ACTIVE(40001,"serverWebServiceHello","hello"),
SCHEDULE(40002,"serverWebServiceSendEmail","邮件测试");
private int value;
private String description;
private String clazzName;
SUIT_SERVER_WEB_SERVICE(int value, String clazzName,String description) {
this.value = value;
this.clazzName = clazzName;
this.description = description;
}
public int getValue() {
return value;
}
public String getDescription() {
return description;
}
public static String valueOfDescription(int val) {
String tmp = null;
for (int i = 0; i < values().length; i++) {
if (values()[i].value == val) {
tmp = values()[i].description;
}
}
return tmp;
}
}
}

@ -79,6 +79,10 @@ public class BfElement extends BaseBean {
@ApiParam(value = "是否删除")
private Integer isObjectDel;
@Column(name = "IS_OBJECT_EXPORT")
@ApiParam(value = "是否导出")
private Integer isObjectExport;
@Column(name="ELEMENT_SORT_ATTR_ID")
@ApiParam(value ="默认排序属性")
@JsonSerialize(using = ToStringSerializer.class)

@ -136,7 +136,7 @@ public class BfElementProperty extends BaseBean {
@AnnoOutputColumn(hidden = true)
private BfDataObjectProperty objectProperty;
public Object getFormValue() {
return propertyFormValue;
}
// public Object getFormValue() {
// return propertyFormValue == null ? propertyDefaultValue : propertyFormValue;
// }
}

@ -341,6 +341,8 @@ public final class FormHqlPack {
DdlPreparedPack.getNegativeNumEqualPack(bfMenu.getId(), "parentId", result);
DdlPreparedPack.getNumEqualPack(
CommonEnumUtil.IS_VAILD.VAILD.getValue(), "isValid", result);
DdlPreparedPack.getNumEqualPack(
CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue(), "isDeleted", result);
// 按顺序字段进行排序

@ -77,10 +77,6 @@ public class MesPcnTask extends BaseBean {
@ApiParam("任务周期描述")
private String taskCycleDescription;
@Column(name="TASK_STATUS")
@ApiParam("任务状态")
private Integer taskStatus;
@Column(name="TASK_PARAM")
@ApiParam("任务参数")
private String taskParam;
@ -89,7 +85,4 @@ public class MesPcnTask extends BaseBean {
return this.taskType == null ? 0 : this.taskType;
}
public int getTaskStatusVal() {
return this.taskStatus == null ? 0 : this.taskStatus;
}
}

@ -77,10 +77,6 @@ public class MesPcnTask extends BaseBean {
@ApiParam("任务周期描述")
private String taskCycleDescription;
@Column(name="TASK_STATUS")
@ApiParam("任务状态")
private Integer taskStatus;
@Column(name="TASK_PARAM")
@ApiParam("任务参数")
private String taskParam;
@ -89,7 +85,4 @@ public class MesPcnTask extends BaseBean {
return this.taskType == null ? 0 : this.taskType;
}
public int getTaskStatusVal() {
return this.taskStatus == null ? 0 : this.taskStatus;
}
}

@ -1161,9 +1161,6 @@ public class MesHqlPack {
DdlPackBean packBean = getAllBaseDataByNormalPro(mesPcnTask, organizeCode);
DdlPreparedPack.getStringLikerPack(mesPcnTask.getTaskCode(), "taskCode", packBean);
DdlPreparedPack.getStringLikerPack(mesPcnTask.getTaskName(), "taskName", packBean);
if (null != mesPcnTask.getTaskStatus()) {
DdlPreparedPack.getNumEqualPack(mesPcnTask.getTaskStatus(), "taskStatus", packBean);
}
packBean.setOrderByStr(mesPcnTask.orderBy());
return packBean;
}

@ -0,0 +1,32 @@
package cn.estsh.i3plus.pojo.model.softswitch;
import cn.estsh.i3plus.pojo.softswitch.bean.BsSocketSuitCase;
import cn.estsh.i3plus.pojo.softswitch.bean.BsSuitCase;
import cn.estsh.i3plus.pojo.softswitch.bean.BsSuitCaseDataSource;
import cn.estsh.i3plus.pojo.softswitch.bean.BsSuitCaseWebService;
import io.swagger.annotations.ApiParam;
import lombok.Data;
/**
* @Description : model
* @Reference :
* @Author : yunhao
* @CreateDate : 2019-09-04 15:30
* @Modify:
**/
@Data
public class BsSuitCaseModel {
@ApiParam(value = "适配器")
private BsSuitCase bsSuitCase;
@ApiParam(value = "数据源适配套件")
private BsSuitCaseDataSource bsDataSourceSuitCase;
@ApiParam(value = "socket适配套件")
private BsSocketSuitCase bsSocketSuitCase;
@ApiParam(value = "Web Service 适配套件")
private BsSuitCaseWebService webService;
}

@ -1,26 +1,26 @@
package cn.estsh.i3plus.pojo.model.softswitch;
import java.util.List;
import java.util.Map;
/**
* @Description :
* @Reference :
* @Author : alwaysfrin
* @CreateDate : 2019-04-29 11:11
* @Modify:
**/
public class DataSwitchModel {
private String stringVal;
private Long longVal;
private Double doubleVal;
private List<?> listVal;
private Map<String,?> mapVal;
private Object[] arrayVal;
}
//package cn.estsh.i3plus.pojo.model.softswitch;
//
//import java.util.List;
//import java.util.Map;
//
///**
// * @Description : 数据模型转换对象
// * @Reference :
// * @Author : alwaysfrin
// * @CreateDate : 2019-04-29 11:11
// * @Modify:
// **/
//public class DataSwitchModel {
//
// private String stringVal;
//
// private Long longVal;
//
// private Double doubleVal;
//
// private List<?> listVal;
//
// private Map<String,?> mapVal;
//
// private Object[] arrayVal;
//}

@ -1,50 +1,50 @@
package cn.estsh.i3plus.pojo.model.softswitch;
import cn.estsh.i3plus.pojo.base.annotation.XStreamCDATA;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
import com.thoughtworks.xstream.annotations.XStreamImplicit;
import lombok.Data;
import java.util.List;
import java.util.Map;
/**
* @Description :
* @Reference :
* @Author : wei.peng
* @CreateDate : 19-7-25 3:31
* @Modify:
**/
@Data
@XStreamAlias("auth")
public class PojoAuth{
@XStreamAsAttribute
private Long id;
@XStreamAsAttribute
private Integer authType;
@XStreamImplicit
private List<Prop> params;
private String authPath;
private String userName ="登录名称";
private String password ="登录名称";
private String languageCode ="登录名称";
// 认证令牌
private String token;
// // 认证令牌集合(复杂认证令牌)
// private List<Prop> tokenList;
// 原始认证数据
@XStreamCDATA
private String result;
public PojoAuth(Long id, Integer authType,String authPath, List<Prop> params) {
this.id = id;
this.authType = authType;
this.authPath = authPath;
this.params = params;
}
}
//package cn.estsh.i3plus.pojo.model.softswitch;
//
//import cn.estsh.i3plus.pojo.base.annotation.XStreamCDATA;
//import com.thoughtworks.xstream.annotations.XStreamAlias;
//import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
//import com.thoughtworks.xstream.annotations.XStreamImplicit;
//import lombok.Data;
//
//import java.util.List;
//import java.util.Map;
//
///**
// * @Description :
// * @Reference :
// * @Author : wei.peng
// * @CreateDate : 19-7-25 下午3:31
// * @Modify:
// **/
//@Data
//@XStreamAlias("auth")
//public class PojoAuth{
//
// @XStreamAsAttribute
// private Long id;
// @XStreamAsAttribute
// private Integer authType;
//
// @XStreamImplicit
// private List<Prop> params;
//
// private String authPath;
// private String userName ="登录名称";
// private String password ="登录名称";
// private String languageCode ="登录名称";
//
// // 认证令牌
// private String token;
//// // 认证令牌集合(复杂认证令牌)
//// private List<Prop> tokenList;
// // 原始认证数据
// @XStreamCDATA
// private String result;
//
// public PojoAuth(Long id, Integer authType,String authPath, List<Prop> params) {
// this.id = id;
// this.authType = authType;
// this.authPath = authPath;
// this.params = params;
// }
//}

@ -1,28 +1,28 @@
package cn.estsh.i3plus.pojo.model.softswitch;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
import lombok.Data;
/**
* @Description :
* @Reference :
* @Author : wei.peng
* @CreateDate : 19-7-25 5:18
* @Modify:
**/
@Data
@XStreamAlias("prop")
public class Prop {
@XStreamAsAttribute
private Long id;
private String paramName;
private String paramValue;
public Prop(Long id, String paramName, String paramValue) {
this.id = id;
this.paramName = paramName;
this.paramValue = paramValue;
}
}
//package cn.estsh.i3plus.pojo.model.softswitch;
//
//import com.thoughtworks.xstream.annotations.XStreamAlias;
//import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
//import lombok.Data;
//
///**
// * @Description :
// * @Reference :
// * @Author : wei.peng
// * @CreateDate : 19-7-25 下午5:18
// * @Modify:
// **/
//@Data
//@XStreamAlias("prop")
//public class Prop {
//
// @XStreamAsAttribute
// private Long id;
// private String paramName;
// private String paramValue;
//
// public Prop(Long id, String paramName, String paramValue) {
// this.id = id;
// this.paramName = paramName;
// this.paramValue = paramValue;
// }
//}

@ -1,33 +1,33 @@
package cn.estsh.i3plus.pojo.model.softswitch;
import cn.estsh.i3plus.pojo.base.annotation.XStreamCDATA;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
import lombok.Data;
/**
* @Description :
* @Reference :
* @Author : wei.peng
* @CreateDate : 19-7-25 3:31
* @Modify:
**/
@Data
@XStreamAlias("request")
public class Request{
@XStreamAsAttribute
private Long id;
@XStreamAsAttribute
private Integer requestType;
private String requestPath;
@XStreamCDATA
private String result;
public Request(Long id, Integer requestType,String requestPath) {
this.id = id;
this.requestType = requestType;
this.requestPath = requestPath;
}
}
//package cn.estsh.i3plus.pojo.model.softswitch;
//
//import cn.estsh.i3plus.pojo.base.annotation.XStreamCDATA;
//import com.thoughtworks.xstream.annotations.XStreamAlias;
//import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
//import lombok.Data;
//
///**
// * @Description :
// * @Reference :
// * @Author : wei.peng
// * @CreateDate : 19-7-25 下午3:31
// * @Modify:
// **/
//@Data
//@XStreamAlias("request")
//public class Request{
//
// @XStreamAsAttribute
// private Long id;
// @XStreamAsAttribute
// private Integer requestType;
// private String requestPath;
//
// @XStreamCDATA
// private String result;
//
// public Request(Long id, Integer requestType,String requestPath) {
// this.id = id;
// this.requestType = requestType;
// this.requestPath = requestPath;
// }
//}

@ -86,15 +86,19 @@ public class SuitCoreModel {
private String suitResultMessage;
/**
*
* @param requestSource
* @param sslKey
* @param bsSuitCase
*/
public SuitCoreModel(Integer requestSource, BsSslKey sslKey, BsSuitCase bsSuitCase){
this(requestSource,sslKey, bsSuitCase,null);
}
public SuitCoreModel(Integer requestSource,BsSslKey sslKey, BsSuitCase bsSuitCase,Object bsSuitCaseDetail) {
this.sslKey = sslKey;
this.bsSuitCase = bsSuitCase;
this.requestSource = requestSource;
this.bsSuitCaseDetail = bsSuitCaseDetail;
// 设置套件类型
this.caseType = bsSuitCase.getCaseTypeId();

@ -0,0 +1,35 @@
package cn.estsh.i3plus.pojo.model.softswitch;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import lombok.Data;
import java.util.List;
import java.util.Map;
/**
* @Description :
* @Reference :
* @Author : wei.peng
* @CreateDate : 19-9-5 7:30
* @Modify:
**/
@Data
@XStreamAlias("model")
public class SuitServerModel {
// 执行方法命令
private String action;
// 执行类型固定类型(SoftSwitchEnumUtil.CASE_TYPE)
private Integer caseType;
/* 认证使用 以后使用 */
private String token;
// 传输单对象
private Object obj;
// 传输集合
private List list;
// 传输键值对
private Map<String,Object> map;
// 传输 JSON 数据
private String json;
}

@ -61,7 +61,7 @@ public class BsDataSource extends BaseBean {
@Column(name = "DATA_SOURCE_STATUS")
@ApiParam(value = "数据源状态")
private String dataSourceStatus;
private Integer dataSourceStatus;
@Column(name = "DATA_SOURCE_DESCRIPTION")
@ApiParam(value = "数据源描述")

@ -49,9 +49,9 @@ public class BsSuitCase extends BaseBean {
@JsonSerialize(using = ToStringSerializer.class)
private Long suitTypeId;
@Column(name = "SUIT_TYPE_NAME")
@Column(name = "SUIT_TYPE_NAME_RDD")
@ApiParam(value = "适配类型名称")
private String suitTypeName;
private String suitTypeNameRdd;
@Column(name = "SUIT_CASE_CODE")
@ApiParam(value = "适配器代码")
@ -61,6 +61,10 @@ public class BsSuitCase extends BaseBean {
@ApiParam(value = "适配模式(枚举,主动,被动)")
private Integer suitModeId;
@Column(name = "SUIT_SERVER_ACTION_ID")
@ApiParam(value = "Server 适配命令")
private Integer suitServerActionId;
@Column(name = "SUIT_CASE_HOST")
@ApiParam(value = "适配主机")
private String suitCaseHost;
@ -107,7 +111,15 @@ public class BsSuitCase extends BaseBean {
private Integer suitCaseStatus;
@Transient
@ApiParam(value = "适配器套件明细")
private Object bsSuitCaseDetail;
@Transient
@ApiParam(value = "适配器参数")
List<BsSuitCaseParam> bsSuitCaseParamList;
private List<BsSuitCaseParam> bsSuitCaseParamList;
@Transient
@ApiParam(value = "参数转换")
private List<BsParamAdapter> bsParamAdapterList;
}

@ -12,6 +12,8 @@ import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import javax.persistence.Transient;
import java.util.List;
/**
* @Description :
@ -25,9 +27,9 @@ import javax.persistence.Table;
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Table(name = "BS_DATA_SOURCE_SUIT_CASE")
@Table(name = "BS_SUIT_CASE_DATA_SOURCE")
@Api(value = "数据库套件", description = "数据库套件")
public class BsDataSourceSuitCase extends BaseBean {
public class BsSuitCaseDataSource extends BaseBean {
@Column(name = "SUIT_CASE_ID")
@ApiParam(value = "套件id")
@ -46,5 +48,12 @@ public class BsDataSourceSuitCase extends BaseBean {
@ApiParam(value = "数据源名称")
private String dataSourceNameRdd;
@Transient
@ApiParam(value = "数据源")
private BsDataSource bsDataSource;
@Transient
@ApiParam(value = "数据库操作")
private List<BsSuitCaseDataSourceTable> bsDataSourceSuitCaseTableList;
}

@ -25,9 +25,9 @@ import javax.persistence.Table;
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Table(name = "BS_DATA_SOURCE_SUIT_CASE_TABLE")
@Table(name = "BS_SUIT_CASE_DATA_SOURCE_TABLE")
@Api(value = "数据库表操作", description = "数据库表操作")
public class BsDataSourceSuitCaseTable extends BaseBean {
public class BsSuitCaseDataSourceTable extends BaseBean {
@Column(name = "SUIT_CASE_ID")
@ApiParam(value = "套件id")
@ -42,6 +42,13 @@ public class BsDataSourceSuitCaseTable extends BaseBean {
@ApiParam(value = "操作类型")
private Integer operateTypeId;
public int getOperateTypeIdVal(){
if(operateTypeId == null){
return -1;
}
return operateTypeId.intValue();
}
@Column(name = "EXECUTE_SQL")
@ApiParam(value = "执行sql")
private String executeSql;
@ -52,7 +59,14 @@ public class BsDataSourceSuitCaseTable extends BaseBean {
@Column(name = "IS_RETURN")
@ApiParam(value = "是否有返回")
private String isReturn;
private Integer isReturn;
public int getIsReturnVal(){
if(isReturn == null){
return -1;
}
return isReturn.intValue();
}
}

@ -0,0 +1,46 @@
package cn.estsh.i3plus.pojo.softswitch.bean;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
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;
import lombok.EqualsAndHashCode;
import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
/**
* @Description : WebService
* @Reference :
* @Author : wei.peng
* @CreateDate : 2019/9/9 11:09
* @Modify:
**/
@Data
@Entity
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Table(name = "BS_SUIT_CASE_WEB_SERVICE")
@Api(value = "WebService", description = "WebService 适配套件")
public class BsSuitCaseWebService extends BaseBean {
@Column(name = "SUIT_CASE_ID")
@ApiParam(value = "套件id")
@JsonSerialize(using = ToStringSerializer.class)
private Long suitCaseId;
@Column(name = "SERVICE_TAG_NAME")
@ApiParam(value = "Service Tag Name(包名称)")
private String serviceTagName;
@Column(name = "SERVICE_FUNCTION_NAME")
@ApiParam(value = "Service Function Name(方法名称)")
private String serviceFunctionName;
}

@ -1,7 +1,7 @@
package cn.estsh.i3plus.pojo.softswitch.repository;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import cn.estsh.i3plus.pojo.softswitch.bean.BsDataSourceSuitCase;
import cn.estsh.i3plus.pojo.softswitch.bean.BsSuitCaseDataSource;
import org.springframework.stereotype.Repository;
/**
@ -12,7 +12,7 @@ import org.springframework.stereotype.Repository;
* @Modify:
*/
@Repository
public interface BsDataSourceSuitCaseRepository extends BaseRepository<BsDataSourceSuitCase,Long> {
public interface BsDataSourceSuitCaseRepository extends BaseRepository<BsSuitCaseDataSource,Long> {
}

@ -1,7 +1,7 @@
package cn.estsh.i3plus.pojo.softswitch.repository;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import cn.estsh.i3plus.pojo.softswitch.bean.BsDataSourceSuitCaseTable;
import cn.estsh.i3plus.pojo.softswitch.bean.BsSuitCaseDataSourceTable;
import org.springframework.stereotype.Repository;
/**
@ -12,7 +12,7 @@ import org.springframework.stereotype.Repository;
* @Modify:
*/
@Repository
public interface BsDataSourceSuitCaseTableRepository extends BaseRepository<BsDataSourceSuitCaseTable,Long> {
public interface BsDataSourceSuitCaseTableRepository extends BaseRepository<BsSuitCaseDataSourceTable,Long> {
}

@ -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.BsSuitCaseWebService;
/**
* @Description :
* @Reference :
* @Author : wei.peng
* @CreateDate : 2019/9/9 11:41
* @Modify:
**/
public interface BsSuitCaseWebServiceRepository extends BaseRepository<BsSuitCaseWebService,Long> {
}

@ -47,7 +47,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlBsSuitCaseParam(BsSuitCaseParam bsSuitCaseParam){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getStringLikerPack(bsSuitCaseParam.getParamName(),"paramName",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitCaseParam.getParamTypeId(), "paramTypeId", ddlPackBean);
@ -65,7 +65,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlCheckBsSuitCaseParamOnly(BsSuitCaseParam bsSuitCaseParam){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumNOEqualPack(bsSuitCaseParam.getId(),"id",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitCaseParam.getSuitCaseId(), "suitCaseId", ddlPackBean);
@ -80,12 +80,12 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlBsSuitCaseParam(BsSuitCase bsSuitCase){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getStringLikerPack(bsSuitCase.getSuitCaseName(),"suitCaseName",ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsSuitCase.getSuitCaseCode(),"suitCaseCode",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitCase.getSuitTypeId(), "suitTypeId", ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsSuitCase.getSuitTypeName(),"suitTypeName",ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsSuitCase.getSuitTypeNameRdd(),"suitTypeNameRdd",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitCase.getCaseTypeId(), "caseTypeId", ddlPackBean);
ddlPackBean.setOrderByStr(bsSuitCase.orderBy());
@ -99,7 +99,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlCheckBsSuitCaseOnly(BsSuitCase bsSuitCase){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumNOEqualPack(bsSuitCase.getId(),"id",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitCase.getSuitCaseCode(), "suitCaseCode", ddlPackBean);
@ -113,7 +113,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlBsParamAdapter(BsParamAdapter bsParamAdapter){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(bsParamAdapter.getSuitCaseId(),"suitCaseId",ddlPackBean);
DdlPreparedPack.getStringEqualPack(bsParamAdapter.getSuitCaseCode(),"suitCaseCode",ddlPackBean);
@ -131,7 +131,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlCheckBsParamAdapterOnly(BsParamAdapter bsParamAdapter){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(bsParamAdapter.getId(), "id", ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsParamAdapter.getSuitCaseId(), "suitCaseId", ddlPackBean);
@ -147,7 +147,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlBsSuitSchedule(BsSuitSchedule bsSuitSchedule){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getStringLikerPack(bsSuitSchedule.getScheduleName(),"scheduleName",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSuitSchedule.getSuitCaseId(),"suitCaseId",ddlPackBean);
@ -165,7 +165,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlCheckBsSuitScheduleOnly(BsSuitSchedule bsSuitSchedule){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(bsSuitSchedule.getId(),"id",ddlPackBean);
DdlPreparedPack.getStringEqualPack(bsSuitSchedule.getScheduleName(),"scheduleName",ddlPackBean);
@ -180,7 +180,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlBsSslKey(BsSslKey bsSslKey){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getStringEqualPack(bsSslKey.getKeyName(),"keyName",ddlPackBean);
DdlPreparedPack.getNumEqualPack(bsSslKey.getKeyTypeId(),"keyTypeId",ddlPackBean);
@ -196,7 +196,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlCheckBsSslKeyOnly(BsSslKey bsSslKey){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(bsSslKey.getId(),"id",ddlPackBean);
DdlPreparedPack.getStringEqualPack(bsSslKey.getKeyName(), "keyName", ddlPackBean);
@ -210,7 +210,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlBsSslKeyParam(BsSslKeyParam bsSslKeyParam){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(bsSslKeyParam.getSslKeyId(), "sslKeyId", ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsSslKeyParam.getParamName(), "paramName", ddlPackBean);
@ -226,7 +226,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlCheckBsSslKeyParamOnly(BsSslKeyParam bsSslKeyParam){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(bsSslKeyParam.getSslKeyId(), "sslKeyId", ddlPackBean);
DdlPreparedPack.getStringEqualPack(bsSslKeyParam.getParamName(), "paramName", ddlPackBean);
@ -240,7 +240,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlBsDataSource(BsDataSource bsDataSource){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getStringLikerPack(bsDataSource.getDataSourceName(), "dataSourceName", ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsDataSource.getDataSourceCode(), "dataSourceCode", ddlPackBean);
@ -258,7 +258,7 @@ public class SoftSwitchHqlPack {
* @return
*/
public static DdlPackBean packHqlCheckBsDataSourceOnly(BsDataSource bsDataSource){
DdlPackBean ddlPackBean = new DdlPackBean();
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(bsDataSource.getId(), "id", ddlPackBean);
DdlPreparedPack.getStringLikerPack(bsDataSource.getDataSourceCode(), "dataSourceCode", ddlPackBean);
@ -266,4 +266,14 @@ public class SoftSwitchHqlPack {
return ddlPackBean;
}
/**
* WebService
* @param webService
* @return
*/
public static DdlPackBean packHqlCheckWebService(BsSuitCaseWebService webService){
DdlPackBean result = DdlPackBean.getDdlPackBean();
return result;
}
}

@ -122,4 +122,74 @@ public class WmsASNMaster extends BaseBean {
@Transient
@ApiParam("手机")
private String vendorPhone;
@Transient
@ApiParam("物料代码")
private String partNo;
@Transient
@ApiParam("物料名称")
private String partNoNameRdd;
@Transient
@ApiParam("收货数量")
private Double sumRecQty;
@Transient
@ApiParam("需求数量")
private Double sumQty;
@Transient
@ApiParam("计划日期")
private String planDate;
@Transient
@ApiParam("计划日期开始")
private String planDateStart;
@Transient
@ApiParam("计划日期结束")
private String planDateEnd;
@Transient
@ApiParam("计划时间")
private String planTime;
@Transient
@ApiParam("差异数量")
private Double diffQty;
@Transient
@ApiParam("单据类型") // PO/ASN
private String orderType;
@Transient
@ApiParam("收货状态")
private String recStatus;
@Transient
@ApiParam("项目代码")
private String prodCfgTypeCode;
public WmsASNMaster(){}
public WmsASNMaster(String orderNo,Integer asnStatus,String vendorNo,String partNo,String partNoNameRdd,
Double sumQty,Double sumRecQty,String planDate,String planTime,Double diffQty,String orderType,
String recStatus){
this.orderNo = orderNo;
this.asnStatus = asnStatus;
this.vendorNo = vendorNo;
this.partNo = partNo;
this.partNoNameRdd = partNoNameRdd;
this.sumQty = sumQty;
this.sumRecQty = sumRecQty;
this.planDate = planDate;
this.planTime = planTime;
this.diffQty = diffQty;
this.orderType = orderType;
this.recStatus = recStatus;
}
}

@ -116,7 +116,7 @@ public class WmsCSFactTrans extends BaseBean {
public Double sumPartQty;
@Transient
@ApiParam("存储区编号")
@ApiParam("存储区编号")
public String[] zoneNos;
public WmsCSFactTrans(){}

@ -3,7 +3,6 @@ package cn.estsh.i3plus.pojo.wms.bean;
import cn.estsh.i3plus.pojo.base.annotation.AnnoOutputColumn;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import cn.estsh.i3plus.pojo.base.enumutil.WmsEnumUtil;
import com.alibaba.fastjson.annotation.JSONField;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiParam;
import lombok.Data;
@ -174,6 +173,10 @@ public class WmsMoveDetails extends BaseBean {
@ApiParam("创建时间")
private String createDateTime;
@Version
@Column(name = "LOCK_VERSION")
@ApiParam(value = "乐观锁", example = "1")
public Integer lockVersion;
/* @JSONField(name="fPartNo")
public String getfPartNo() {
return fPartNo;

@ -144,6 +144,11 @@ public class WmsMoveMaster extends BaseBean {
@ApiParam(value = "设备编号")
public String fixId;
@Version
@Column(name = "LOCK_VERSION")
@ApiParam(value = "乐观锁", example = "1")
public Integer lockVersion;
public WmsMoveMaster(){};
public WmsMoveMaster(String orderNo, Integer orderStatus, String transTypeCode, String errorMessage,

@ -183,7 +183,13 @@ public class WmsMoveSn extends BaseBean {
@ApiParam("交易类型名称")
private String transTypeName;
public WmsMoveSn(){}
@Version
@Column(name = "LOCK_VERSION")
@ApiParam(value = "乐观锁", example = "1")
public Integer lockVersion;
public WmsMoveSn() {
}
public WmsMoveSn(String partNo, Long finishedCounts, Long waitingCounts) {
this.partNo = partNo;
@ -207,6 +213,7 @@ public class WmsMoveSn extends BaseBean {
this.transTypeCode = transTypeCode;
this.refSrc = refSrc;
}
public WmsMoveSn(String partNo, String partNameRdd, Double destQty, String transTypeCode, String refSrc) {
this.partNo = partNo;
this.partNameRdd = partNameRdd;

@ -166,11 +166,12 @@ public class WmsPOMasterDetails extends BaseBean {
public WmsPOMasterDetails(){}
public WmsPOMasterDetails(String orderNo,String containerNo,String partNo,Integer item,String organizeCode){
public WmsPOMasterDetails(String orderNo,String containerNo,String partNo,Integer item,String organizeCode,String erpAreaNo){
this.orderNo = orderNo;
this.containerNo = containerNo;
this.partNo = partNo;
this.item = item;
this.organizeCode = organizeCode;
this.erpAreaNo = erpAreaNo;
}
}

@ -0,0 +1,52 @@
package cn.estsh.i3plus.pojo.wms.bean.iotio;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiParam;
import lombok.Data;
import lombok.EqualsAndHashCode;
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 : jessica.chen
* @CreateDate : 2019-09-09 11:14
* @Modify:
**/
@Data
@Entity
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Table(name="SWEB_PROCUREMENT_PLAN_ORDER")
@Api("开口合同主表")
public class SwebProcurementPlanOrder extends BaseBean {
private static final long serialVersionUID = -4332932784803175933L;
@Column(name = "ORDER_NO")
@ApiParam(value = "合同号")
private String orderNo;
@Column(name = "VENDOR_CODE")
@ApiParam(value = "物料名称")
private String vendorCode;
@Column(name = "VENDOR_NAME")
@ApiParam(value = "物料名称")
private String vendorName;
@Column(name = "PART_NO")
@ApiParam(value = "物料名称")
private String partNo;
@Column(name = "PART_NAME")
@ApiParam(value = "物料名称")
private String partName;
}

@ -0,0 +1,16 @@
package cn.estsh.i3plus.pojo.wms.repository;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import cn.estsh.i3plus.pojo.wms.bean.iotio.SwebProcurementPlanOrder;
import org.springframework.stereotype.Repository;
/**
* @Description :
* @Reference :
* @Author : jessica.chen
* @CreateDate : 2019-09-09 14:49
* @Modify:
**/
@Repository
public interface SwebProcurementPlanOrderRepository extends BaseRepository<SwebProcurementPlanOrder, Long> {
}
Loading…
Cancel
Save