wms数据同步迁移至mes
qianhs
5 years ago
parent
11adb5ff09
commit
20f5bfc9eb
@ -0,0 +1,103 @@
|
||||
package cn.estsh.i3plus.pojo.mes.bean;
|
||||
|
||||
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 : amy
|
||||
* @CreateDate : 2018-11-07 14:21
|
||||
* @Modify:
|
||||
**/
|
||||
@Data
|
||||
@Entity
|
||||
@DynamicInsert
|
||||
@DynamicUpdate
|
||||
@EqualsAndHashCode(callSuper = true)
|
||||
@Table(name="BAS_VENDOR")
|
||||
@Api("供应商信息")
|
||||
public class BasVendor extends BaseBean{
|
||||
|
||||
private static final long serialVersionUID = 9214639813072592779L;
|
||||
@Column(name="VENDOR_NO")
|
||||
@ApiParam("供应商编号")
|
||||
private String vendorNo;
|
||||
|
||||
@Column(name="VENDOR_NAME")
|
||||
@ApiParam("供应商简称")
|
||||
private String vendorName;
|
||||
|
||||
@Column(name="VENDOR_DESC")
|
||||
@ApiParam("供应商全称")
|
||||
private String vendorDesc;
|
||||
|
||||
@Column(name="VENDOR_ADDR")
|
||||
@ApiParam("供应商地址")
|
||||
private String vendorAddr;
|
||||
|
||||
@Column(name="VENDOR_OWNER")
|
||||
@ApiParam("联系人")
|
||||
private String vendorOwner;
|
||||
|
||||
@Column(name="VENDOR_EMAIL")
|
||||
@ApiParam("邮箱")
|
||||
private String vendorEmail;
|
||||
|
||||
@Column(name = "IS_ASN")
|
||||
@ApiParam(value = "是否发ASN", example = "0")
|
||||
private Integer isAsn;
|
||||
|
||||
@Column(name = "USER_NAME")
|
||||
@ApiParam(value = "用户名")
|
||||
private String userName;
|
||||
|
||||
@Column(name = "PASSWORD")
|
||||
@ApiParam(value = "密码")
|
||||
private String password;
|
||||
|
||||
@Column(name = "VENDOR_CALL")
|
||||
@ApiParam("供应商电话")
|
||||
private String vendorCall;
|
||||
|
||||
@Column(name = "VENDOR_FAX")
|
||||
@ApiParam("传真")
|
||||
private String vendorFax;
|
||||
|
||||
@Column(name = "VENDOR_PHONE")
|
||||
@ApiParam("手机")
|
||||
private String vendorPhone;
|
||||
|
||||
@Column(name = "KILOBIT")
|
||||
@ApiParam("千位符号")
|
||||
private String kilobit;
|
||||
|
||||
@Column(name = "DECIMALS")
|
||||
@ApiParam("小数位符号")
|
||||
private String decimals;
|
||||
|
||||
//20-承运商
|
||||
@Column(name = "VENDOR_TYPE")
|
||||
private Integer vendorType;
|
||||
|
||||
@Column(name = "MAP_LOCATION")
|
||||
@ApiParam("经纬度")
|
||||
private String mapLocation;
|
||||
|
||||
public BasVendor() {
|
||||
}
|
||||
|
||||
public BasVendor(Long id, String userName) {
|
||||
this.id = id;
|
||||
this.userName = userName;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,66 @@
|
||||
package cn.estsh.i3plus.pojo.mes.bean;
|
||||
|
||||
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;
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* @Description :MES_JIT发运队列
|
||||
* @Reference :
|
||||
* @Author : qianhausheng
|
||||
* @CreateDate : 2020-03-06 10:16 上午
|
||||
* @Modify:
|
||||
**/
|
||||
@Data
|
||||
@Entity
|
||||
@DynamicInsert
|
||||
@DynamicUpdate
|
||||
@EqualsAndHashCode(callSuper = true)
|
||||
@Table(name = "MES_QUEUE_SHIPPING")
|
||||
@Api("MES_JIT发运队列")
|
||||
public class MesQueueShipping extends BaseBean implements Serializable {
|
||||
|
||||
private static final long serialVersionUID = 655875369308414110L;
|
||||
|
||||
@Column(name = "JIT_NO")
|
||||
@ApiParam("队列编号")
|
||||
private String jitNo;
|
||||
|
||||
@Column(name = "PROD_CFG_CODE")
|
||||
@ApiParam("配置代码")
|
||||
private String prodCfgCode;
|
||||
|
||||
@Column(name = "VIN_CODE")
|
||||
@ApiParam("vin")
|
||||
private String vinCode;
|
||||
|
||||
@Column(name = "CUST_FLAG_NO")
|
||||
@ApiParam("客户标识号")
|
||||
private String custFlagNo;
|
||||
|
||||
@Column(name = "SEQ")
|
||||
@ApiParam("排序号")
|
||||
private Double seq;
|
||||
|
||||
@Column(name = "STATUS")
|
||||
@ApiParam("状态")
|
||||
private Integer status;
|
||||
|
||||
@Column(name = "CUST_CODE")
|
||||
@ApiParam("客户代码")
|
||||
private String custCode;
|
||||
|
||||
@Column(name = "CUST_PLANT_CODE")
|
||||
@ApiParam("客户产线代码")
|
||||
private String custPlantCode;
|
||||
|
||||
}
|
||||
@ -0,0 +1,73 @@
|
||||
package cn.estsh.i3plus.pojo.mes.bean;
|
||||
|
||||
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;
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* @Description :MES_JIT发运队列明细
|
||||
* @Reference :
|
||||
* @Author : qianhausheng
|
||||
* @CreateDate : 2020-03-06 10:16 上午
|
||||
* @Modify:
|
||||
**/
|
||||
@Data
|
||||
@Entity
|
||||
@DynamicInsert
|
||||
@DynamicUpdate
|
||||
@EqualsAndHashCode(callSuper = true)
|
||||
@Table(name = "MES_QUEUE_SHIPPING_DETAIL")
|
||||
@Api("MES_JIT发运队列明细")
|
||||
public class MesQueueShippingDetail extends BaseBean implements Serializable {
|
||||
|
||||
private static final long serialVersionUID = 1442091799346314190L;
|
||||
|
||||
@Column(name = "JIT_NO")
|
||||
@ApiParam("队列编号")
|
||||
private String jitNo;
|
||||
|
||||
@Column(name = "PROD_CFG_CODE")
|
||||
@ApiParam("配置代码")
|
||||
private String prodCfgCode;
|
||||
|
||||
@Column(name = "PART_NO")
|
||||
@ApiParam("物料号")
|
||||
private String partNo;
|
||||
|
||||
@Column(name = "PART_NAME_RDD")
|
||||
@ApiParam("物料名称")
|
||||
private String partNameRdd;
|
||||
|
||||
@Column(name = "status")
|
||||
@ApiParam("状态")
|
||||
private Integer status;
|
||||
|
||||
@Column(name="SERIAL_NUMBER")
|
||||
@ApiParam("过程条码")
|
||||
private String serialNumber;
|
||||
|
||||
@Column(name = "QUEUE_GROUP_NO")
|
||||
@ApiParam("分组队列编号")
|
||||
private String queueGroupNo;
|
||||
|
||||
@Column(name = "GROUP_NO")
|
||||
@ApiParam("组内编号")
|
||||
private Integer groupNo;
|
||||
|
||||
@Column(name = "GROUP_SEQ")
|
||||
@ApiParam("分组序号")
|
||||
private String groupSeq;
|
||||
|
||||
@Column(name = "qty")
|
||||
@ApiParam("数量")
|
||||
private Double qty;
|
||||
}
|
||||
@ -0,0 +1,74 @@
|
||||
package cn.estsh.i3plus.pojo.mes.dbinterface;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
|
||||
public class MesInterfaceEnumUtil {
|
||||
|
||||
@JsonFormat(shape = JsonFormat.Shape.OBJECT)
|
||||
public enum DIRECTION_TYPE {
|
||||
SAP2WMS(10, "SAP2WMS", "SAP --> WMS"),
|
||||
WMS2SAP(20, "WMS2SAP", "WMS --> SAP"),
|
||||
MES2WMS(30, "MES2WMS", "MES --> WMS"),
|
||||
WMS2MES(40, "WMS2MES", "WMS --> MES");
|
||||
|
||||
private int value;
|
||||
private String name;
|
||||
private String description;
|
||||
|
||||
DIRECTION_TYPE() {
|
||||
}
|
||||
|
||||
DIRECTION_TYPE(int value, String name, String description) {
|
||||
this.value = value;
|
||||
this.name = name;
|
||||
this.description = description;
|
||||
}
|
||||
|
||||
public int getValue() {
|
||||
return value;
|
||||
}
|
||||
|
||||
public String getDescription() {
|
||||
return description;
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public static String valueOf(int val) {
|
||||
String tmp = null;
|
||||
for (int i = 0; i < values().length; i++) {
|
||||
if (values()[i].value == val) {
|
||||
tmp = values()[i].getName();
|
||||
}
|
||||
}
|
||||
return tmp;
|
||||
}
|
||||
|
||||
public static int nameOf(String val) {
|
||||
int tmp = -1;
|
||||
for (int i = 0; i < values().length; i++) {
|
||||
if (values()[i].name.equals(val)) {
|
||||
tmp = values()[i].value;
|
||||
}
|
||||
}
|
||||
return tmp;
|
||||
}
|
||||
|
||||
/**
|
||||
* -1 不在范围内
|
||||
* @param desc
|
||||
* @return
|
||||
*/
|
||||
public static int descOf(String desc) {
|
||||
int tmp = -1;
|
||||
for (int i = 0; i < values().length; i++) {
|
||||
if (values()[i].description.equals(desc)) {
|
||||
tmp = values()[i].value;
|
||||
}
|
||||
}
|
||||
return tmp;
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,26 @@
|
||||
package cn.estsh.i3plus.pojo.mes.dbinterface;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
/**
|
||||
* 回写接口库的值
|
||||
*/
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
public class UpdateSyncItem {
|
||||
|
||||
/**
|
||||
* 字段名
|
||||
*/
|
||||
public String columnName;
|
||||
|
||||
/**
|
||||
* 写入的值
|
||||
* 支持表达式
|
||||
* #sap_date, #sap_time, #guid
|
||||
*/
|
||||
public String updateValue;
|
||||
}
|
||||
@ -0,0 +1,38 @@
|
||||
package cn.estsh.i3plus.pojo.mes.repository;
|
||||
|
||||
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
|
||||
import cn.estsh.i3plus.pojo.mes.engine.script.EngineScriptPersistence;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description : 脚本引擎持久化类
|
||||
* @Reference :
|
||||
* @Author : Rock.Yu
|
||||
* @CreateDate : 2019-04-16 09:53
|
||||
* @Modify:
|
||||
**/
|
||||
public interface IEngineScriptPersistenceRepository extends BaseRepository<EngineScriptPersistence, Long> {
|
||||
/**
|
||||
* 按照工厂代码和脚本编号查询脚本实体对象
|
||||
* @param organizeCode 工厂代码
|
||||
* @param scriptNo 脚本编号
|
||||
* @return 脚本实体对象
|
||||
*/
|
||||
EngineScriptPersistence findByOrganizeCodeAndScriptNo(String organizeCode, String scriptNo);
|
||||
|
||||
/**
|
||||
* 按照脚本编号查询脚本实体对象
|
||||
* @param scriptNo 脚本编号
|
||||
* @return 脚本实体对象
|
||||
*/
|
||||
EngineScriptPersistence findByScriptNo(String scriptNo);
|
||||
|
||||
/**
|
||||
* 查找所有的脚本语言类型
|
||||
* @return 数据库中已经存在的脚本语言类型
|
||||
*/
|
||||
@Query("select t.languageType from EngineScriptPersistence t group by t.organizeCode, t.languageType")
|
||||
List findGroupByLanguageType();
|
||||
}
|
||||
@ -0,0 +1,16 @@
|
||||
package cn.estsh.i3plus.pojo.mes.repository;
|
||||
|
||||
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
|
||||
import cn.estsh.i3plus.pojo.mes.dbinterface.MesInterfaceDataMapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
/**
|
||||
* @Description :
|
||||
* @Reference :
|
||||
* @Author : jessica.chen
|
||||
* @CreateDate : 2019-06-28 15:17
|
||||
* @Modify:
|
||||
**/
|
||||
@Repository
|
||||
public interface MesInterfaceDataMapperRepository extends BaseRepository<MesInterfaceDataMapper,Long> {
|
||||
}
|
||||
@ -0,0 +1,14 @@
|
||||
package cn.estsh.i3plus.pojo.mes.repository;
|
||||
|
||||
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
|
||||
import cn.estsh.i3plus.pojo.mes.bean.MesQueueShippingDetail;
|
||||
|
||||
/**
|
||||
* @Description :发运队列明细
|
||||
* @Reference :
|
||||
* @Author : qianhuasheng
|
||||
* @CreateDate : 2020-03-06 10:56 上午
|
||||
* @Modify:
|
||||
**/
|
||||
public interface MesQueueShippingDetailRepository extends BaseRepository<MesQueueShippingDetail, Long> {
|
||||
}
|
||||
@ -0,0 +1,14 @@
|
||||
package cn.estsh.i3plus.pojo.mes.repository;
|
||||
|
||||
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
|
||||
import cn.estsh.i3plus.pojo.mes.bean.MesQueueShipping;
|
||||
|
||||
/**
|
||||
* @Description :
|
||||
* @Reference :
|
||||
* @Author : qianhuasheng
|
||||
* @CreateDate : 2020-03-06 10:56 上午
|
||||
* @Modify:
|
||||
**/
|
||||
public interface MesQueueShippingRepository extends BaseRepository<MesQueueShipping, Long> {
|
||||
}
|
||||
Loading…
Reference in New Issue