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

定时任务封装

Browse Source
yun-zuoyi
alwaysfrin 6 years ago
parent d62910737b
commit fd6552b4ac
2 changed files with 153 additions and 94 deletions
Show Stats Download Patch File Download Diff File

238
modules/i3plus-pojo-base/src/main/java/cn/estsh/i3plus/pojo/base/jpa/daoimpl/BaseRepositoryImpl.java
Unescape Escape View File

@ -261,10 +261,14 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override @Override
public List<T> listPager(Pager pager) { public List<T> listPager(Pager pager) {
return entityManager.createQuery("from " + persistentClass.getName()) if(pager.getTotalRows() > 0) {
.setFirstResult(pager.getStartRow()) return entityManager.createQuery("from " + persistentClass.getName())
.setMaxResults(pager.getPageSize()) .setFirstResult(pager.getStartRow())
.getResultList(); .setMaxResults(pager.getPageSize())
.getResultList();
}else{
return new ArrayList<T>();
}
} }
@Override @Override
@ -474,41 +478,49 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override @Override
public List<T> findByPropertyPage(String propertyName, Object value, String orderByStuff, Pager pager) { public List<T> findByPropertyPage(String propertyName, Object value, String orderByStuff, Pager pager) {
String queryString = "from " + persistentClass.getSimpleName() + " as model where model." + propertyName + "= :" + propertyName + " " + orderByStuff; if(pager.getTotalRows() > 0){
return entityManager.createQuery(queryString) String queryString = "from " + persistentClass.getSimpleName() + " as model where model." + propertyName + "= :" + propertyName + " " + orderByStuff;
.setParameter(propertyName, value) return entityManager.createQuery(queryString)
.getResultList(); .setParameter(propertyName, value)
.getResultList();
}else{
return new ArrayList<T>();
}
} }
@Override @Override
public List<T> findByPropertyPage(String[] propertyNames, Object[] values, String orderByStuff, Pager pager) { public List<T> findByPropertyPage(String[] propertyNames, Object[] values, String orderByStuff, Pager pager) {
if(propertyNames.length != values.length){ if(pager.getTotalRows() > 0){
throw new IllegalArgumentException("参数名的数量和参数值不匹配!propertyNames:" + propertyNames.length + ",values:" + values.length); if(propertyNames.length != values.length){
} throw new IllegalArgumentException("参数名的数量和参数值不匹配!propertyNames:" + propertyNames.length + ",values:" + values.length);
StringBuffer queryString = new StringBuffer(); }
queryString.append("from " + persistentClass.getSimpleName() + " as model "); StringBuffer queryString = new StringBuffer();
queryString.append("from " + persistentClass.getSimpleName() + " as model ");
int size = propertyNames.length; int size = propertyNames.length;
if (size > 0) { if (size > 0) {
queryString.append("where 1=1 "); queryString.append("where 1=1 ");
} }
for (int i = 0; i < size; i++) { for (int i = 0; i < size; i++) {
if(values[i] != null) { if(values[i] != null) {
queryString.append(" and model." + propertyNames[i] + "= :" + propertyNames[i]); queryString.append(" and model." + propertyNames[i] + "= :" + propertyNames[i]);
}
} }
}
if(orderByStuff != null && orderByStuff.length() > 0){ if(orderByStuff != null && orderByStuff.length() > 0){
queryString.append(orderByStuff); queryString.append(orderByStuff);
} }
Query queryObject = entityManager.createQuery(queryString.toString()); Query queryObject = entityManager.createQuery(queryString.toString());
for (int i = 0; i < size; i++) { for (int i = 0; i < size; i++) {
queryObject.setParameter(propertyNames[i], values[i]); queryObject.setParameter(propertyNames[i], values[i]);
} }
return queryObject.setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize()).getResultList(); return queryObject.setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize()).getResultList();
}else{
return new ArrayList<T>();
}
} }
@Override @Override
@ -594,47 +606,55 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override @Override
public List<T> findByHqlWherePage(String hqlWhere, Pager pager, String[] propertyNames, Object[] values, String orderByStuff) { public List<T> findByHqlWherePage(String hqlWhere, Pager pager, String[] propertyNames, Object[] values, String orderByStuff) {
if(propertyNames.length != values.length){ if(pager.getTotalRows() > 0){
throw new IllegalArgumentException("参数名的数量和参数值不匹配!propertyNames:" + propertyNames.length + ",values:" + values.length); if(propertyNames.length != values.length){
} throw new IllegalArgumentException("参数名的数量和参数值不匹配!propertyNames:" + propertyNames.length + ",values:" + values.length);
StringBuffer queryString = new StringBuffer(); }
queryString.append("from " + persistentClass.getSimpleName() + " as model where 1=1 "); StringBuffer queryString = new StringBuffer();
queryString.append("from " + persistentClass.getSimpleName() + " as model where 1=1 ");
if (hqlWhere != null && hqlWhere.length() > 0) { if (hqlWhere != null && hqlWhere.length() > 0) {
queryString.append(hqlWhere); queryString.append(hqlWhere);
} }
int size = propertyNames.length; int size = propertyNames.length;
for (int i = 0; i < size; i++) { for (int i = 0; i < size; i++) {
if(values[i] != null) { if(values[i] != null) {
queryString.append(" and model." + propertyNames[i] + "= :" + propertyNames[i]); queryString.append(" and model." + propertyNames[i] + "= :" + propertyNames[i]);
}
} }
} queryString.append(" " + orderByStuff);
queryString.append(" " + orderByStuff);
Query queryObject = entityManager.createQuery(queryString.toString()).setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize()); Query queryObject = entityManager.createQuery(queryString.toString()).setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize());
for (int i = 0; i < size; i++) { for (int i = 0; i < size; i++) {
if(values[i] != null) { if(values[i] != null) {
queryObject.setParameter(propertyNames[i], values[i]); queryObject.setParameter(propertyNames[i], values[i]);
}
} }
}
return queryObject.getResultList(); return queryObject.getResultList();
}else{
return new ArrayList<T>();
}
} }
@Override @Override
public List<T> findByHqlWherePage(String hqlWhere, Pager pager) { public List<T> findByHqlWherePage(String hqlWhere, Pager pager) {
StringBuffer queryString = new StringBuffer(); if(pager.getTotalRows() > 0) {
queryString.append("from " + persistentClass.getSimpleName() + " as model where 1=1 "); StringBuffer queryString = new StringBuffer();
queryString.append("from " + persistentClass.getSimpleName() + " as model where 1=1 ");
if (hqlWhere != null && hqlWhere.length() > 0) { if (hqlWhere != null && hqlWhere.length() > 0) {
queryString.append(hqlWhere); queryString.append(hqlWhere);
} }
return entityManager.createQuery(queryString.toString()) return entityManager.createQuery(queryString.toString())
.setFirstResult(pager.getStartRow()) .setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize()) .setMaxResults(pager.getPageSize())
.getResultList(); .getResultList();
}else{
return new ArrayList<T>();
}
} }
@Override @Override
@ -680,31 +700,39 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override @Override
public List<T> findByHqlPage(String hqlWhere, Pager pager) { public List<T> findByHqlPage(String hqlWhere, Pager pager) {
StringBuffer queryString = new StringBuffer(); if(pager.getTotalRows() > 0){
queryString.append("from " + persistentClass.getSimpleName() + " as model where 1=1 "); StringBuffer queryString = new StringBuffer();
queryString.append("from " + persistentClass.getSimpleName() + " as model where 1=1 ");
if (hqlWhere != null && hqlWhere.length() > 0) { if (hqlWhere != null && hqlWhere.length() > 0) {
queryString.append(hqlWhere); queryString.append(hqlWhere);
} }
return entityManager.createQuery(queryString.toString()) return entityManager.createQuery(queryString.toString())
.setFirstResult(pager.getStartRow()) .setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize()) .setMaxResults(pager.getPageSize())
.getResultList(); .getResultList();
}else{
return new ArrayList<T>();
}
} }
@Override @Override
public List<T> findByHqlPage(String hql, Pager pager, String[] paramName, Object[] paramValue) { public List<T> findByHqlPage(String hql, Pager pager, String[] paramName, Object[] paramValue) {
Query queryObject = entityManager.createQuery(hql); if(pager.getTotalRows() > 0) {
for(int i=0;i<paramName.length;i++){ Query queryObject = entityManager.createQuery(hql);
if(paramValue[i] != null) { for (int i = 0; i < paramName.length; i++) {
queryObject.setParameter(paramName[i], paramValue[i].toString()); if (paramValue[i] != null) {
queryObject.setParameter(paramName[i], paramValue[i].toString());
}
} }
}
return queryObject.setFirstResult(pager.getStartRow()) return queryObject.setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize()) .setMaxResults(pager.getPageSize())
.getResultList(); .getResultList();
}else{
return new ArrayList<T>();
}
} }
@Override @Override
@ -719,18 +747,26 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override @Override
public List findBySqlPage(String sql, Pager pager) { public List findBySqlPage(String sql, Pager pager) {
return entityManager.createNativeQuery(sql) if(pager.getTotalRows() > 0) {
return entityManager.createNativeQuery(sql)
.setFirstResult(pager.getStartRow()) .setFirstResult(pager.getStartRow())
.setMaxResults(pager.getPageSize()) .setMaxResults(pager.getPageSize())
.getResultList(); .getResultList();
}else{
return new ArrayList();
}
} }
@Override @Override
public List<?> findBySqlPage(String sql, Class entity, Pager pager) { public List<?> findBySqlPage(String sql, Class entity, Pager pager) {
return entityManager.createNativeQuery(sql,entity) if(pager.getTotalRows() > 0){
.setFirstResult(pager.getStartRow()) return entityManager.createNativeQuery(sql,entity)
.setMaxResults(pager.getPageSize()) .setFirstResult(pager.getStartRow())
.getResultList(); .setMaxResults(pager.getPageSize())
.getResultList();
}else{
return new ArrayList();
}
} }
@Override @Override
@ -793,17 +829,21 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override @Override
public List<T> findColumnsByHql(String hql, String hqlWhere, String orderByStuff, Pager pager) { public List<T> findColumnsByHql(String hql, String hqlWhere, String orderByStuff, Pager pager) {
StringBuffer queryString = new StringBuffer(); if(pager.getTotalRows() > 0) {
StringBuffer queryString = new StringBuffer();
queryString.append(hql + " as model where 1=1 "); queryString.append(hql + " as model where 1=1 ");
if (hqlWhere != null && hqlWhere.length() > 0) { if (hqlWhere != null && hqlWhere.length() > 0) {
queryString.append(hqlWhere); queryString.append(hqlWhere);
} }
queryString.append(" " + orderByStuff); queryString.append(" " + orderByStuff);
return entityManager.createQuery(queryString.toString()).setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize()).getResultList(); return entityManager.createQuery(queryString.toString()).setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize()).getResultList();
}else{
return new ArrayList<T>();
}
} }
@Override @Override
@ -825,19 +865,27 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override @Override
public List<Object[]> findByHqlPageObjects(String hql, Pager pager) { public List<Object[]> findByHqlPageObjects(String hql, Pager pager) {
return entityManager.createQuery(hql).setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize()).getResultList(); if(pager.getTotalRows() > 0){
return entityManager.createQuery(hql).setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize()).getResultList();
}else{
return new ArrayList<Object[]>();
}
} }
@Override @Override
public List<Object[]> findByHqlPageObjects(String hql, Pager pager, String[] paramName, Object[] paramValue) { public List<Object[]> findByHqlPageObjects(String hql, Pager pager, String[] paramName, Object[] paramValue) {
Query queryObject = entityManager.createQuery(hql); if(pager.getTotalRows() > 0) {
for(int i=0;i<paramName.length;i++){ Query queryObject = entityManager.createQuery(hql);
if(paramValue[i] != null) { for (int i = 0; i < paramName.length; i++) {
queryObject.setParameter(paramName[i], paramValue[i].toString()); if (paramValue[i] != null) {
queryObject.setParameter(paramName[i], paramValue[i].toString());
}
} }
}
return queryObject.setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize()).getResultList(); return queryObject.setFirstResult(pager.getStartRow()).setMaxResults(pager.getPageSize()).getResultList();
}else{
return new ArrayList<Object[]>();
}
} }
@Override @Override
@ -847,10 +895,14 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override @Override
public List<Object[]> findBySqlObjListByPager(String sql, Pager pager) { public List<Object[]> findBySqlObjListByPager(String sql, Pager pager) {
return entityManager.createNativeQuery(sql) if(pager.getTotalRows() > 0){
.setFirstResult(pager.getStartRow()) return entityManager.createNativeQuery(sql)
.setMaxResults(pager.getPageSize()) .setFirstResult(pager.getStartRow())
.getResultList(); .setMaxResults(pager.getPageSize())
.getResultList();
}else{
return new ArrayList<Object[]>();
}
} }
/** /**

9
modules/i3plus-pojo-platform/src/main/java/cn/estsh/i3plus/pojo/platform/bean/SysTool.java
Unescape Escape View File

@ -12,6 +12,7 @@ import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Column; import javax.persistence.Column;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.Index;
import javax.persistence.Table; import javax.persistence.Table;
/** /**
@ -26,7 +27,13 @@ import javax.persistence.Table;
@DynamicInsert @DynamicInsert
@DynamicUpdate @DynamicUpdate
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
@Table(name="SYS_TOOL") @Table(name="SYS_TOOL",indexes =
{
@Index(name="sys_tool_tool_type_idx",columnList = "tool_type_id"),
@Index(name="sys_tool_tool_status_idx",columnList = "TOOL_STATUS"),
@Index(name="sys_tool_tool_conn_type_idx",columnList = "TOOL_CONN_TYPE"),
@Index(name="sys_tool_tool_data_type_idx",columnList = "TOOL_DATA_TYPE")
})
@Api(value="硬件设备表",description = "硬件设备表") @Api(value="硬件设备表",description = "硬件设备表")
public class SysTool extends BaseBean { public class SysTool extends BaseBean {

Write Preview
Loading…
Cancel
Save