Merge remote-tracking branch 'remotes/origin/test'

yun-zuoyi
曾贞一 6 years ago
commit 18aff86ea0

@ -13,6 +13,7 @@ import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import javax.persistence.Transient;
/**
* @Description : ANDON_
@ -47,5 +48,13 @@ public class AndonAlarmCause extends BaseBean {
@ApiParam(value = "呼叫原因描述")
private String acName;
@Transient
@ApiParam(value = "工作中心")
private String workCenterCode;
@Transient
@ApiParam(value = "工作单元")
private String workCellCode;
}

@ -0,0 +1,50 @@
package cn.estsh.i3plus.pojo.andon.bean;
import cn.estsh.i3plus.pojo.base.annotation.AnnoOutputColumn;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import cn.estsh.i3plus.pojo.base.enumutil.AndonEnumUtil;
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 : ANDON_
* @Reference :
* @Author : crish.li
* @CreateDate : 2019-08-22 11:20
* @Modify:
**/
@Data
@Entity
@Table(name="ANDON_CELL_ALARM_CAUSE")
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Api("ANDON_工作单元呼叫原因配置")
public class AndonCellAlarmCause extends BaseBean {
@Column(name = "WORK_CENTER_CODE")
@ApiParam(value = "工作中心代码")
private String workCenterCode;
@Column(name = "WORK_CELL_CODE")
@ApiParam(value = "工作单元代码")
private String workCellCode;
@Column(name = "ALARM_CODE")
@ApiParam(value = "安灯类型")
private String alarmCode;
@Column(name = "AC_CODE")
@ApiParam(value = "呼叫原因代码")
private String acCode;
}

@ -0,0 +1,48 @@
package cn.estsh.i3plus.pojo.andon.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 : ANDON_
* @Reference :
* @Author : crish.li
* @CreateDate : 2019-08-22 11:20
* @Modify:
**/
@Data
@Entity
@Table(name="ANDON_CELL_EVENT_CAUSE")
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Api("ANDON_工作单元事件原因配置")
public class AndonCellEventCause extends BaseBean {
@Column(name = "WORK_CENTER_CODE")
@ApiParam(value = "工作中心代码")
private String workCenterCode;
@Column(name = "WORK_CELL_CODE")
@ApiParam(value = "工作单元代码")
private String workCellCode;
@Column(name = "ALARM_CODE")
@ApiParam(value = "安灯类型")
private String alarmCode;
@Column(name = "EC_CODE")
@ApiParam(value = "事件原因代码")
private String ecCode;
}

@ -0,0 +1,50 @@
package cn.estsh.i3plus.pojo.andon.bean;
import cn.estsh.i3plus.pojo.base.annotation.AnnoOutputColumn;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import cn.estsh.i3plus.pojo.base.enumutil.AndonEnumUtil;
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 : ANDON_
* @Reference :
* @Author : crish.li
* @CreateDate : 2019-08-22 11:20
* @Modify:
**/
@Data
@Entity
@Table(name="ANDON_CELL_EVENT_METHOD")
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Api("ANDON_工作单元处理方法配置")
public class AndonCellEventMethod extends BaseBean {
@Column(name = "WORK_CENTER_CODE")
@ApiParam(value = "工作中心代码")
private String workCenterCode;
@Column(name = "WORK_CELL_CODE")
@ApiParam(value = "工作单元代码")
private String workCellCode;
@Column(name = "ALARM_CODE")
@ApiParam(value = "安灯类型")
private String alarmCode;
@Column(name = "EM_CODE")
@ApiParam(value = "事件方法代码")
private String emCode;
}

@ -0,0 +1,48 @@
package cn.estsh.i3plus.pojo.andon.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 : ANDON_
* @Reference :
* @Author : crish.li
* @CreateDate : 2019-08-22 11:20
* @Modify:
**/
@Data
@Entity
@Table(name="ANDON_CELL_EVENT_PHENOMENON")
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Api("ANDON_工作单元事件现象")
public class AndonCellEventPhenomenon extends BaseBean {
@Column(name = "WORK_CENTER_CODE")
@ApiParam(value = "工作中心代码")
private String workCenterCode;
@Column(name = "WORK_CELL_CODE")
@ApiParam(value = "工作单元代码")
private String workCellCode;
@Column(name = "ALARM_CODE")
@ApiParam(value = "安灯类型")
private String alarmCode;
@Column(name = "EPM_CODE")
@ApiParam(value = "事件现象代码")
private String epmCode;
}

@ -13,6 +13,7 @@ import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import javax.persistence.Transient;
/**
* @Description : ANDON_
@ -46,4 +47,12 @@ public class AndonEventCause extends BaseBean {
@Column(name = "ALARM_CODE")
@ApiParam(value = "安灯类型")
private String alarmCode;
@Transient
@ApiParam(value = "工作中心")
private String workCenterCode;
@Transient
@ApiParam(value = "工作单元")
private String workCellCode;
}

@ -13,6 +13,7 @@ import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import javax.persistence.Transient;
/**
* @Description : ANDON_
@ -46,4 +47,12 @@ public class AndonEventMethod extends BaseBean {
@Column(name = "ALARM_CODE")
@ApiParam(value = "安灯类型")
private String alarmCode;
@Transient
@ApiParam(value = "工作中心")
private String workCenterCode;
@Transient
@ApiParam(value = "工作单元")
private String workCellCode;
}

@ -13,6 +13,7 @@ import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import javax.persistence.Transient;
/**
* @Description : ANDON_
@ -42,4 +43,12 @@ public class AndonEventPhenoMenon extends BaseBean {
@Column(name = "ALARM_CODE")
@ApiParam(value = "安灯类型")
private String alarmCode;
@Transient
@ApiParam(value = "工作中心")
private String workCenterCode;
@Transient
@ApiParam(value = "工作单元")
private String workCellCode;
}

@ -0,0 +1,17 @@
package cn.estsh.i3plus.pojo.andon.repository;
import cn.estsh.i3plus.pojo.andon.bean.AndonAlarmCause;
import cn.estsh.i3plus.pojo.andon.bean.AndonCellAlarmCause;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import org.springframework.stereotype.Repository;
/**
* @Description : ANDON_
* @Reference :
* @Author : crish.li
* @CreateDate : 2019-08-22 11:07
* @Modify:
**/
@Repository
public interface IAndonCellAlarmCauseRepository extends BaseRepository<AndonCellAlarmCause, Long> {
}

@ -0,0 +1,16 @@
package cn.estsh.i3plus.pojo.andon.repository;
import cn.estsh.i3plus.pojo.andon.bean.AndonCellEventCause;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import org.springframework.stereotype.Repository;
/**
* @Description : ANDON_
* @Reference :
* @Author : crish.li
* @CreateDate : 2019-08-22 11:07
* @Modify:
**/
@Repository
public interface IAndonCellEventCauseRepository extends BaseRepository<AndonCellEventCause, Long> {
}

@ -0,0 +1,17 @@
package cn.estsh.i3plus.pojo.andon.repository;
import cn.estsh.i3plus.pojo.andon.bean.AndonCellAlarmCause;
import cn.estsh.i3plus.pojo.andon.bean.AndonCellEventMethod;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import org.springframework.stereotype.Repository;
/**
* @Description : ANDON_
* @Reference :
* @Author : crish.li
* @CreateDate : 2019-08-22 11:07
* @Modify:
**/
@Repository
public interface IAndonCellEventMethodRetository extends BaseRepository<AndonCellEventMethod, Long> {
}

@ -0,0 +1,17 @@
package cn.estsh.i3plus.pojo.andon.repository;
import cn.estsh.i3plus.pojo.andon.bean.AndonCellAlarmCause;
import cn.estsh.i3plus.pojo.andon.bean.AndonCellEventPhenomenon;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import org.springframework.stereotype.Repository;
/**
* @Description : ANDON_
* @Reference :
* @Author : crish.li
* @CreateDate : 2019-08-22 11:07
* @Modify:
**/
@Repository
public interface IAndonCellEventPhenomenonRepository extends BaseRepository<AndonCellEventPhenomenon, Long> {
}

@ -823,6 +823,7 @@ public class MesEnumUtil {
}
}
/**
*
*/

@ -83,4 +83,40 @@ public class MesPcnEnumUtil {
return tmp;
}
}
/**
* PCN
*/
@JsonFormat(shape = JsonFormat.Shape.OBJECT)
public enum PCN_CACHE {
PCH_EHCACHE(10, "PCN_EHCACHE");
private int value;
private String description;
PCN_CACHE(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;
}
}
}

@ -25,7 +25,7 @@ import java.util.*;
* @Modify:
**/
public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRepository<T, ID>
implements BaseRepository<T, ID> {
implements BaseRepository<T, ID> {
public static final Logger LOGGER = LoggerFactory.getLogger(BaseRepositoryImpl.class);
/**
@ -391,8 +391,8 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
}
return query.setFirstResult(offset)
.setMaxResults(pageSize)
.getResultList();
.setMaxResults(pageSize)
.getResultList();
}
@Override
@ -607,8 +607,8 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
if(pager.getTotalRows() > 0){
String queryString = "from " + persistentClass.getSimpleName() + " as model where model." + propertyName + "= :" + propertyName + " " + orderByStuff;
return entityManager.createQuery(queryString)
.setParameter(propertyName, value)
.getResultList();
.setParameter(propertyName, value)
.getResultList();
}else{
return new ArrayList<T>();
}
@ -671,7 +671,7 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override
public List<T> findByHqlWhere(DdlPackBean packBean) {
Query query = entityManager.createQuery("from " + persistentClass.getSimpleName()
+ " as model where 1=1 " + packBean.getPackedHql());
+ " as model where 1=1 " + packBean.getPackedHql());
for (String key : packBean.getHqlPreparedMap().keySet()) {
query.setParameter("m_" + key,packBean.getHqlPreparedMap().get(key));
@ -958,9 +958,9 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
public List<?> findBySqlPage(String sql, Class entity, Pager pager) {
if(pager.getTotalRows() > 0){
return entityManager.createNativeQuery(sql,entity)
.setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize())
.getResultList();
.setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize())
.getResultList();
}else{
return new ArrayList();
}
@ -975,8 +975,8 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
public int findBySqlCount(String sql) {
try{
Long count = (Long) entityManager
.createNativeQuery("select count(*) from ( " + sql + " ) as usertable",Long.class)
.getSingleResult();
.createNativeQuery("select count(*) from ( " + sql + " ) as usertable",Long.class)
.getSingleResult();
return count == null ? 0 : count.intValue();
}catch(NoResultException e){
return 0;
@ -1081,9 +1081,9 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
queryString.append(" " + orderByStuff);
return entityManager.createQuery(queryString.toString())
.setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize())
.getResultList();
.setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize())
.getResultList();
}else{
return new ArrayList<T>();
}
@ -1140,9 +1140,9 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
public List<Object[]> findBySqlObjListByPager(String sql, Pager pager) {
if(pager.getTotalRows() > 0){
return entityManager.createNativeQuery(sql)
.setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize())
.getResultList();
.setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize())
.getResultList();
}else{
return new ArrayList<Object[]>();
}

@ -0,0 +1,58 @@
package cn.estsh.i3plus.pojo.mes.pcn.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;
/**
* @Author: Wynne.Lu
* @CreateDate: 2019/8/22 5:59 PM
* @Description:
**/
@Data
@Entity
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Table(name = "MES_NUMBER_RULE")
@Api("条码生成规则")
public class MesNumberRule extends BaseBean {
@Column(name = "RULE_CODE")
@ApiParam("规则代码")
private String ruleCode;
@Column(name = "RULE_DESC")
@ApiParam("规则描述")
private String ruleDesc;
@Column(name = "PREFIX")
@ApiParam("前缀")
private Integer prefix;
@Column(name = "NUMBER_RULE")
@ApiParam("编码规则")
private String numberRule;
@Column(name = "SERIALNO_LENGTH")
@ApiParam("序号长度")
private Integer serialnoLength;
@Column(name = "SERIALNO_INCREMENT")
@ApiParam("增量")
private Integer serialnoIncrement;
@Column(name = "IS_CYCLE")
@ApiParam("最大值后循环")
private Integer isCycle;
}

@ -0,0 +1,41 @@
package cn.estsh.i3plus.pojo.mes.pcn.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;
/**
* @Author: Wynne.Lu
* @CreateDate: 2019/8/23 9:14 AM
* @Description:
**/
@Data
@Entity
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Table(name = "MES_NUMBER_SERIALNO")
@Api("编码序号")
public class MesNumberSerialno extends BaseBean {
@Column(name = "CURRENT_NUMBER_PREFIX")
@ApiParam("当前编号前缀")
private String currentNumberPrefix;
@Column(name = "CURRENT_SERIALNO")
@ApiParam("当前序号")
private Integer currentSerialno;
@Column(name = "CURRENT_NUMBER")
@ApiParam("当前编号")
private String currentNumber;
}

@ -0,0 +1,58 @@
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;
/**
* @Author: Wynne.Lu
* @CreateDate: 2019/8/22 5:59 PM
* @Description:
**/
@Data
@Entity
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Table(name = "MES_NUMBER_RULE")
@Api("条码生成规则")
public class MesNumberRule extends BaseBean {
@Column(name = "RULE_CODE")
@ApiParam("规则代码")
private String ruleCode;
@Column(name = "RULE_DESC")
@ApiParam("规则描述")
private String ruleDesc;
@Column(name = "PREFIX")
@ApiParam("前缀")
private String prefix;
@Column(name = "NUMBER_RULE")
@ApiParam("编码规则")
private String numberRule;
@Column(name = "SERIALNO_LENGTH")
@ApiParam("序号长度")
private Integer serialnoLength;
@Column(name = "SERIALNO_INCREMENT")
@ApiParam("增量")
private Integer serialnoIncrement;
@Column(name = "IS_CYCLE")
@ApiParam("最大值后循环")
private Integer isCycle;
}

@ -0,0 +1,41 @@
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;
/**
* @Author: Wynne.Lu
* @CreateDate: 2019/8/23 9:14 AM
* @Description:
**/
@Data
@Entity
@DynamicInsert
@DynamicUpdate
@EqualsAndHashCode(callSuper = true)
@Table(name = "MES_NUMBER_SERIALNO")
@Api("编码序号")
public class MesNumberSerialno extends BaseBean {
@Column(name = "CURRENT_NUMBER_PREFIX")
@ApiParam("当前编号前缀")
private String currentNumberPrefix;
@Column(name = "CURRENT_SERIALNO")
@ApiParam("当前序号")
private Integer currentSerialno;
@Column(name = "CURRENT_NUMBER")
@ApiParam("当前编号")
private String currentNumber;
}

@ -0,0 +1,17 @@
package cn.estsh.i3plus.pojo.mes.repository;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import cn.estsh.i3plus.pojo.mes.bean.MesNumberRule;
import cn.estsh.i3plus.pojo.mes.bean.MesPart;
import org.springframework.stereotype.Repository;
/**
* @Description :
* @Reference :
* @Author : wangjie
* @CreateDate : 2019-08-23
* @Modify:
**/
@Repository
public interface MesNumberRuleRepository extends BaseRepository<MesNumberRule, Long> {
}

@ -1077,4 +1077,30 @@ public class MesHqlPack {
}
return packBean;
}
/**
* Mes
* @param numberRule
* @param organizeCode
* @return
*/
public static DdlPackBean getMesNumberRule(MesNumberRule numberRule, String organizeCode) {
DdlPackBean packBean = getAllBaseDataByNormalPro(numberRule, organizeCode);
if (StringUtils.isNotEmpty(numberRule.getRuleCode())) {
DdlPreparedPack.getStringLikerPack(numberRule.getRuleCode(), "ruleCode", packBean);
}
if (StringUtils.isNotEmpty(numberRule.getNumberRule())) {
DdlPreparedPack.getStringLikerPack(numberRule.getNumberRule(), "numberRule", packBean);
}
if (StringUtils.isNotEmpty(numberRule.getPrefix())) {
DdlPreparedPack.getNumEqualPack(numberRule.getPrefix(), "prefix", packBean);
}
if (null != numberRule.getIsCycle()) {
DdlPreparedPack.getNumEqualPack(numberRule.getIsCycle(), "isCycle", packBean);
}
packBean.setOrderByStr(numberRule.orderBy());
return packBean;
}
}

@ -7,6 +7,8 @@ import cn.estsh.i3plus.pojo.base.tool.HqlPack;
import cn.estsh.i3plus.pojo.platform.bean.*;
import org.apache.commons.lang3.StringUtils;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
@ -859,6 +861,22 @@ public class CoreHqlPack {
return result.toString();
}
public static DdlPackBean packBeanSysLabelTemplate(SysLabelTemplate sysLabelTemplate) {
DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(sysLabelTemplate);
// hql拼接
DdlPreparedPack.getStringEqualPack(sysLabelTemplate.getTemplateName(),"templateName",ddlPackBean);
DdlPreparedPack.getStringEqualPack(sysLabelTemplate.getTemplateCode(),"templateCode",ddlPackBean);
DdlPreparedPack.getStringEqualPack(sysLabelTemplate.getOrganizeCode(),"organizeCode",ddlPackBean);
DdlPreparedPack.timeBuilder(sysLabelTemplate.getModifyDateTimeStart(), sysLabelTemplate.getModifyDateTimeEnd(), "modifyDatetime", ddlPackBean, true);
// 添加默认排序
HqlPack.getOrderDefault(sysLabelTemplate);
return ddlPackBean;
}
/**
*
* @param sysLabelTemplateParam

@ -0,0 +1,34 @@
package cn.estsh.i3plus.pojo.wms.bean.iotio;
import lombok.Data;
import java.io.Serializable;
/**
* @Description : IOT
* @Reference :
* @Author : Rock.Yu
* @CreateDate : 2019-08-21 18:04
* @Modify:
**/
@Data
public class SysIotConfig implements Serializable {
private static final long serialVersionUID = 2228817197928571545L;
private Integer ruid;
private String fsbUrl;
private String fsbType;
private String requesterSystem;
private String topicName;
private String publishCode;
private String interfaceCode;
private String tableName;
private String columnName;
private String seq;
private String guid;
private String groupColumn;
private String uniqueColumn;
private String orderColumn;
private String organizeCode;
}
Loading…
Cancel
Save