@ -3,10 +3,15 @@ package cn.estsh.i3plus.pojo.base.jpa.daoimpl;
import cn.estsh.i3plus.pojo.base.bean.DdlPackBean ;
import cn.estsh.i3plus.pojo.base.common.Pager ;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil ;
import cn.estsh.i3plus.pojo.base.enumutil.WmsEnumUtil ;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository ;
import cn.estsh.i3plus.pojo.base.codemaker.SnowflakeIdMaker ;
import cn.estsh.i3plus.pojo.base.util.BeanMapUtils ;
import cn.estsh.i3plus.pojo.base.util.StringCastUtils ;
import org.apache.commons.lang3.StringUtils ;
import org.hibernate.NonUniqueResultException ;
import org.hibernate.SQLQuery ;
import org.hibernate.transform.Transformers ;
import org.slf4j.Logger ;
import org.slf4j.LoggerFactory ;
import org.springframework.data.jpa.repository.support.SimpleJpaRepository ;
@ -37,7 +42,7 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
private Class < T > persistentClass ;
private SnowflakeIdMaker snowflakeIdMaker ;
public BaseRepositoryImpl ( Class < T > clz , EntityManager em , SnowflakeIdMaker snowflakeIdMaker ) {
public BaseRepositoryImpl ( Class < T > clz , EntityManager em , SnowflakeIdMaker snowflakeIdMaker ) {
super ( clz , em ) ;
this . entityManager = em ;
this . persistentClass = clz ;
@ -83,7 +88,7 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override
public T insert ( T item ) {
return insert ( item , true ) ;
return insert ( item , true ) ;
}
@Override
@ -94,7 +99,7 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override
public < S extends T > S save ( S entity ) {
//复写save方法， ，
return ( S ) innerSave ( entity , true ) ;
return ( S ) innerSave ( entity , true ) ;
}
@Override
@ -136,100 +141,101 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
}
@Override
public void deleteById ( ID id ) {
public void deleteById ( ID id ) {
deleteByProperty ( "id" , id ) ;
}
@Override
public int deleteByProperty ( String propName , Object propValue ) {
return deleteByProperties ( new String [ ] { propName } , new Object [ ] { propValue } ) ;
return deleteByProperties ( new String [ ] { propName } , new Object [ ] { propValue } ) ;
}
@Override
public int deleteByProperties ( String [ ] propName , Object [ ] propValue ) {
if ( ( propName ! = null ) & & ( propName . length > 0 ) & & ( propValue ! = null ) & & ( propValue . length > 0 ) & & ( propValue . length = = propName . length ) ) {
StringBuffer sb = new StringBuffer ( "delete from " + persistentClass . getName ( ) + " model where 1=1 " ) ;
appendQL ( sb , propName , propValue ) ;
appendQL ( sb , propName , propValue ) ;
Query query = entityManager . createQuery ( sb . toString ( ) ) ;
setParameter ( query , propName , propValue ) ;
setParameter ( query , propName , propValue ) ;
return query . executeUpdate ( ) ;
} else {
} else {
throw new IllegalArgumentException ( "删除错误!propName:" + propName + ",propValue:" + propValue ) ;
}
}
@Override
public int deleteByIds ( ID [ ] ids ) {
return deleteByPropertyIn ( "id" , ids ) ;
return deleteByPropertyIn ( "id" , ids ) ;
}
@Override
public int deleteByPropertyIn ( String propName , Object [ ] propValues ) {
if ( ( propName ! = null & & propName . length ( ) > 0 ) & & ( propValues ! = null & & propValues . length > 0 ) ) {
String hql = "delete from " + persistentClass . getName ( ) + " model where model." + propName + " in(:" + propName + ") " ;
String hql = "delete from " + persistentClass . getName ( ) + " model where model." + propName + " in(:" + propName + ") " ;
Query query = entityManager . createQuery ( hql ) ;
query . setParameter ( propName , Arrays . asList ( propValues ) ) ;
return query . executeUpdate ( ) ;
} else {
throw new IllegalArgumentException ( "删除出错：" + propName + ":" + propValues ) ;
} else {
throw new IllegalArgumentException ( "删除出错：" + propName + ":" + propValues ) ;
}
}
@Override
public int updateByProperties ( String conditionName , Object conditionValue , String propertyName , Object propertyValue ) {
return updateByProperties ( new String [ ] { conditionName } , new Object [ ] { conditionValue } , new String [ ] { propertyName } , new Object [ ] { propertyValue } ) ;
return updateByProperties ( new String [ ] { conditionName } , new Object [ ] { conditionValue } , new String [ ] { propertyName } , new Object [ ] { propertyValue } ) ;
}
@Override
public int updateByProperties ( String conditionName , Object conditionValue , String [ ] propertyName , Object [ ] propertyValue ) {
return updateByProperties ( new String [ ] { conditionName } , new Object [ ] { conditionValue } , propertyName , propertyValue ) ;
return updateByProperties ( new String [ ] { conditionName } , new Object [ ] { conditionValue } , propertyName , propertyValue ) ;
}
@Override
public int updateByProperties ( String [ ] conditionName , Object [ ] conditionValue , String propertyName , Object propertyValue ) {
return updateByProperties ( conditionName , conditionValue , new String [ ] { propertyName } , new Object [ ] { propertyValue } ) ;
return updateByProperties ( conditionName , conditionValue , new String [ ] { propertyName } , new Object [ ] { propertyValue } ) ;
}
@Override
public int updateByProperties ( String [ ] conditionName , Object [ ] conditionValue , String [ ] propertyName , Object [ ] propertyValue ) {
return updateByPropertiesMain ( conditionName , conditionValue , propertyName , propertyValue , true ) ;
return updateByPropertiesMain ( conditionName , conditionValue , propertyName , propertyValue , true ) ;
}
@Override
public int updateByPropertiesWithVal ( String conditionName , Object conditionValue , String propertyName , Object propertyValue ) {
return updateByPropertiesWithVal ( new String [ ] { conditionName } , new Object [ ] { conditionValue } , new String [ ] { propertyName } , new Object [ ] { propertyValue } ) ;
return updateByPropertiesWithVal ( new String [ ] { conditionName } , new Object [ ] { conditionValue } , new String [ ] { propertyName } , new Object [ ] { propertyValue } ) ;
}
@Override
public int updateByPropertiesWithVal ( String conditionName , Object conditionValue , String [ ] propertyName , Object [ ] propertyValue ) {
return updateByPropertiesWithVal ( new String [ ] { conditionName } , new Object [ ] { conditionValue } , propertyName , propertyValue ) ;
return updateByPropertiesWithVal ( new String [ ] { conditionName } , new Object [ ] { conditionValue } , propertyName , propertyValue ) ;
}
@Override
public int updateByPropertiesWithVal ( String [ ] conditionName , Object [ ] conditionValue , String propertyName , Object propertyValue ) {
return updateByPropertiesWithVal ( conditionName , conditionValue , new String [ ] { propertyName } , new Object [ ] { propertyValue } ) ;
return updateByPropertiesWithVal ( conditionName , conditionValue , new String [ ] { propertyName } , new Object [ ] { propertyValue } ) ;
}
@Override
public int updateByPropertiesWithVal ( String [ ] conditionName , Object [ ] conditionValue , String [ ] propertyName , Object [ ] propertyValue ) {
return updateByPropertiesMain ( conditionName , conditionValue , propertyName , propertyValue , false ) ;
return updateByPropertiesMain ( conditionName , conditionValue , propertyName , propertyValue , false ) ;
}
/ * *
* 更 新 参 数 汇 总 方 法
* @param conditionName 条 件 属 性 名
*
* @param conditionName 条 件 属 性 名
* @param conditionValue 条 件 属 性 值
* @param propertyName 更 新 属 性 名
* @param propertyValue 更 新 属 性 值
* @param valWithSimple 是 否 简 单 赋 值
* true 为 正 常 eg ： price = : price
* false 为 自 身 添 加 eg ： price = price + : price
* @param propertyName 更 新 属 性 名
* @param propertyValue 更 新 属 性 值
* @param valWithSimple 是 否 简 单 赋 值
* true 为 正 常 eg ： price = : price
* false 为 自 身 添 加 eg ： price = price + : price
* @return
* /
private int updateByPropertiesMain ( String [ ] conditionName , Object [ ] conditionValue ,
String [ ] propertyName , Object [ ] propertyValue , boolean valWithSimple ) {
String [ ] propertyName , Object [ ] propertyValue , boolean valWithSimple ) {
if ( ( propertyName ! = null ) & & ( propertyName . length > 0 ) & & ( propertyValue ! = null )
& & ( propertyValue . length > 0 ) & & ( propertyName . length = = propertyValue . length )
& & ( conditionValue ! = null ) & & ( conditionValue . length > 0 ) ) {
@ -237,9 +243,9 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
sb . append ( "update " + persistentClass . getName ( ) + " model set " ) ;
for ( int i = 0 ; i < propertyName . length ; i + + ) {
if ( valWithSimple ) {
if ( valWithSimple ) {
sb . append ( propertyName [ i ] + " = :p_" + propertyName [ i ] + "," ) ;
} else {
} else {
sb . append ( propertyName [ i ] + " = " + propertyName [ i ] + " + :p_" + propertyName [ i ] + "," ) ;
}
}
@ -261,36 +267,36 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
}
@Override
public int updateByProperties ( String propertyName , Object propertyValue , DdlPackBean packBean ) {
return updateByProperties ( new String [ ] { propertyName } , new Object [ ] { propertyValue } , packBean ) ;
public int updateByProperties ( String propertyName , Object propertyValue , DdlPackBean packBean ) {
return updateByProperties ( new String [ ] { propertyName } , new Object [ ] { propertyValue } , packBean ) ;
}
@Override
public int updateByProperties ( String [ ] propertyName , Object [ ] propertyValue , DdlPackBean packBean ) {
return updateByPropertiesDdlPack ( propertyName , propertyValue , packBean , true ) ;
public int updateByProperties ( String [ ] propertyName , Object [ ] propertyValue , DdlPackBean packBean ) {
return updateByPropertiesDdlPack ( propertyName , propertyValue , packBean , true ) ;
}
@Override
public int updateByPropertiesWithVal ( String propertyName , Object propertyValue , DdlPackBean packBean ) {
return updateByPropertiesWithVal ( new String [ ] { propertyName } , new Object [ ] { propertyValue } , packBean ) ;
public int updateByPropertiesWithVal ( String propertyName , Object propertyValue , DdlPackBean packBean ) {
return updateByPropertiesWithVal ( new String [ ] { propertyName } , new Object [ ] { propertyValue } , packBean ) ;
}
@Override
public int updateByPropertiesWithVal ( String [ ] propertyName , Object [ ] propertyValue , DdlPackBean packBean ) {
return updateByPropertiesDdlPack ( propertyName , propertyValue , packBean , false ) ;
public int updateByPropertiesWithVal ( String [ ] propertyName , Object [ ] propertyValue , DdlPackBean packBean ) {
return updateByPropertiesDdlPack ( propertyName , propertyValue , packBean , false ) ;
}
private int updateByPropertiesDdlPack ( String [ ] propertyName , Object [ ] propertyValue ,
DdlPackBean packBean , boolean valWithSimple ) {
DdlPackBean packBean , boolean valWithSimple ) {
if ( ( propertyName ! = null ) & & ( propertyName . length > 0 ) & & ( propertyValue ! = null )
& & ( propertyValue . length > 0 ) & & ( propertyName . length = = propertyValue . length ) ) {
StringBuffer sb = new StringBuffer ( ) ;
sb . append ( "update " + persistentClass . getName ( ) + " model set " ) ;
for ( int i = 0 ; i < propertyName . length ; i + + ) {
if ( valWithSimple ) {
if ( valWithSimple ) {
sb . append ( propertyName [ i ] + " = :p_" + propertyName [ i ] + "," ) ;
} else {
} else {
sb . append ( propertyName [ i ] + " = " + propertyName [ i ] + " + :p_" + propertyName [ i ] + "," ) ;
}
}
@ -304,7 +310,7 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
}
//查询条件
for ( String key : packBean . getHqlPreparedMap ( ) . keySet ( ) ) {
query . setParameter ( "m_" + key , packBean . getHqlPreparedMap ( ) . get ( key ) ) ;
query . setParameter ( "m_" + key , packBean . getHqlPreparedMap ( ) . get ( key ) ) ;
}
return query . executeUpdate ( ) ;
@ -345,9 +351,9 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override
public T getById ( long id ) {
try {
return entityManager . find ( persistentClass , id ) ;
} catch ( Exception e ) {
try {
return entityManager . find ( persistentClass , id ) ;
} catch ( Exception e ) {
return null ;
}
}
@ -361,12 +367,12 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override
public List < T > listPager ( Pager pager ) {
if ( pager . getTotalRows ( ) > 0 ) {
if ( pager . getTotalRows ( ) > 0 ) {
return entityManager . createQuery ( "from " + persistentClass . getName ( ) )
. setFirstResult ( pager . getStartRow ( ) )
. setMaxResults ( pager . getPageSize ( ) )
. getResultList ( ) ;
} else {
} else {
return new ArrayList < T > ( ) ;
}
}
@ -379,16 +385,16 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
@Override
public List < T > findByPage ( DdlPackBean packBean , int offset , int pageSize ) {
Query query = null ;
String ddl = "from " + persistentClass . getName ( ) + " where 1=1 " + packBean . getPackedHql ( ) ;
String ddl = "from " + persistentClass . getName ( ) + " where 1=1 " + packBean . getPackedHql ( ) ;
if ( packBean . isHql ( ) ) {
if ( packBean . isHql ( ) ) {
query = entityManager . createQuery ( ddl ) ;
} else {
} else {
query = entityManager . createNativeQuery ( ddl ) ;
}
for ( String key : packBean . getHqlPreparedMap ( ) . keySet ( ) ) {
query . setParameter ( "m_" + key , packBean . getHqlPreparedMap ( ) . get ( key ) ) ;
query . setParameter ( "m_" + key , packBean . getHqlPreparedMap ( ) . get ( key ) ) ;
}
return query . setFirstResult ( offset )
@ -412,6 +418,37 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
}
@Override
public List < Map < String , Object > > findByWasProperty ( String [ ] propertyNames , Object [ ] values ) {
if ( propertyNames . length ! = values . length ) {
throw new IllegalArgumentException ( "参数名的数量和参数值不匹配!propertyNames:" + propertyNames . length + ",values:" + values . length ) ;
}
StringBuffer queryString = new StringBuffer ( ) ;
queryString . append ( " SELECT \n" +
" a.sn_status AS snStatus,\n" +
" a.wh_no AS whNo,\n" +
" a.locate_no AS locateNo,\n" +
" a.part_no AS partNo,\n" +
" a.part_name_rdd AS partNameRdd,\n" +
" a.lot_no AS lotNo,\n" +
" CAST(IFNULL(SUM(a.qty), 0) AS DOUBLE) AS qty \n" +
"FROM\n" +
" `wms_stock_sn` a " ) ;
int size = propertyNames . length ;
if ( size > 0 ) {
queryString . append ( "where 1=1 and a.sn_status in ('" + WmsEnumUtil . STOCK_SN_STATUS . PRE_INSTOCK . getValue ( ) + "', '" + WmsEnumUtil . STOCK_SN_STATUS . INSTOCKED . getValue ( ) + "','" + WmsEnumUtil . STOCK_SN_STATUS . PICKED . getValue ( ) + "','" + WmsEnumUtil . STOCK_SN_STATUS . QUALITY_CONTROL . getValue ( ) + "') " ) ;
}
for ( int i = 0 ; i < size ; i + + ) {
if ( values [ i ] ! = null ) {
queryString . append ( " and a." + StringCastUtils . upperCharToUnderLine ( propertyNames [ i ] ) + "= " + values [ i ] ) ;
}
}
queryString . append ( " group by a.lot_no,a.date_code" ) ;
return entityManager . createNativeQuery ( queryString . toString ( ) ) . unwrap ( SQLQuery . class ) . setResultTransformer (
Transformers . ALIAS_TO_ENTITY_MAP ) . getResultList ( ) ;
}
@Override
public List < T > findByProperty ( String [ ] propertyNames , Object [ ] values ) {
if ( propertyNames . length ! = values . length ) {
throw new IllegalArgumentException ( "参数名的数量和参数值不匹配!propertyNames:" + propertyNames . length + ",values:" + values . length ) ;
@ -1529,4 +1566,6 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
}
return num ;
}
}
