@ -298,10 +298,10 @@ public class ClueJpa {
clueDto . setNewestCallTime ( ( Date ) row . get ( "newestCallTime" ) ) ;
clueDto . setAmount ( ( String ) row . get ( "amount" ) ) ;
clueDto . setPlatform ( ( String ) row . get ( "platform" ) ) ;
clueDtoList . add ( clueDto ) ;
clueDto . setTurnoverAmount ( ( Double ) row . get ( "turnoverAmount" ) ) ;
clueDto . setCastInfo ( ( String ) row . get ( "castInfo" ) ) ;
clueDto . setClueType ( ( Integer ) row . get ( "clueType" ) ) ;
clueDtoList . add ( clueDto ) ;
}
return clueDtoList ;
}
@ -371,6 +371,9 @@ public class ClueJpa {
}
if ( pageable ! = null ) {
Integer memberStatus = clueQueryCriteria . getMemberStatus ( ) ;
if ( clueQueryCriteria . getUserId ( ) ! = null ) {
sql . append ( "AND tc.create_by = :userId " ) ;
}
if ( memberStatus ! = null & & memberStatus = = 0 ) {
sql . append ( "AND tcm.member_id is null " ) ;
}
@ -407,6 +410,9 @@ public class ClueJpa {
query . setParameter ( "taskId" , taskIds ) ;
}
if ( pageable ! = null ) {
if ( clueQueryCriteria . getUserId ( ) ! = null ) {
query . setParameter ( "userId" , clueQueryCriteria . getUserId ( ) ) ;
}
if ( origin ! = null ) {
query . setParameter ( "origin" , origin ) ;
}
@ -502,65 +508,68 @@ public class ClueJpa {
if ( CollUtil . isNotEmpty ( taskIds ) ) {
sql . append ( "AND cm.task_id IN (:taskId) " ) ;
Integer memberStatus = clueQueryCriteria . getMemberStatus ( ) ;
if ( memberStatus ! = null & & memberStatus = = 0 ) {
sql . append ( "AND cm.member_id is null " ) ;
}
if ( memberStatus ! = null & & memberStatus > 0 ) {
sql . append ( "AND cm.member_id is not null " ) ;
}
if ( StringUtils . isNotBlank ( name ) ) {
sql . append ( "and c.name like :name " ) ;
}
if ( origin ! = null ) {
sql . append ( "and c.origin = :origin " ) ;
}
if ( createTimeList ! = null & & createTimeList . size ( ) = = 2 ) {
sql . append ( "and c.create_time between :createTimeBegin and :createTimeEnd " ) ;
}
}
if ( clueQueryCriteria . getUserId ( ) ! = null ) {
sql . append ( "AND c.create_by = :userId " ) ;
}
Integer memberStatus = clueQueryCriteria . getMemberStatus ( ) ;
if ( memberStatus ! = null & & memberStatus = = 0 ) {
sql . append ( "AND cm.member_id is null " ) ;
}
if ( memberStatus ! = null & & memberStatus > 0 ) {
sql . append ( "AND cm.member_id is not null " ) ;
}
if ( StringUtils . isNotBlank ( name ) ) {
sql . append ( "and c.name like :name " ) ;
}
if ( origin ! = null ) {
sql . append ( "and c.origin = :origin " ) ;
}
if ( createTimeList ! = null & & createTimeList . size ( ) = = 2 ) {
sql . append ( "and c.create_time between :createTimeBegin and :createTimeEnd " ) ;
}
if ( userIdList ! = null & & userIdList . size ( ) > 0 ) {
sql . append ( "and cm.member_id in (:userIdList)" ) ;
}
if ( clueStage ! = null ) {
sql . append ( "AND cm.clue_stage = :clueStage " ) ;
}
if ( clueType ! = null ) {
sql . append ( "AND cm.clue_type = :clueType " ) ;
} else {
sql . append ( "AND cm.clue_type < :clueType " ) ;
}
if ( userIdList ! = null & & userIdList . size ( ) > 0 ) {
sql . append ( "and cm.member_id in (:userIdList)" ) ;
}
if ( clueStage ! = null ) {
sql . append ( "AND cm.clue_stage = :clueStage " ) ;
}
if ( clueType ! = null ) {
sql . append ( "AND cm.clue_type = :clueType " ) ;
}
Query query = entityManager . createNativeQuery ( sql . toString ( ) ) ;
if ( CollUtil . isNotEmpty ( taskIds ) ) {
query . setParameter ( "taskId" , taskIds ) ;
if ( origin ! = null ) {
query . setParameter ( "origin" , origin ) ;
}
if ( StringUtils . isNotBlank ( name ) ) {
query . setParameter ( "name" , "%" + name + "%" ) ;
}
if ( createTimeList ! = null & & createTimeList . size ( ) = = 2 ) {
String createTimeBegin = this . format . format ( createTimeList . get ( 0 ) ) ;
String createTimeEnd = this . format . format ( createTimeList . get ( 1 ) ) ;
query . setParameter ( "createTimeBegin" , createTimeBegin ) ;
query . setParameter ( "createTimeEnd" , createTimeEnd ) ;
}
if ( clueStage ! = null ) {
query . setParameter ( "clueStage" , clueStage ) ;
}
if ( userIdList ! = null & & userIdList . size ( ) > 0 ) {
query . setParameter ( "userIdList" , userIdList ) ;
}
if ( clueType ! = null ) {
query . setParameter ( "clueType" , clueType ) ;
} else {
query . setParameter ( "clueType" , DefaultNumberConstants . FOUR_NUMBER ) ;
}
}
if ( clueQueryCriteria . getUserId ( ) ! = null ) {
query . setParameter ( "userId" , clueQueryCriteria . getUserId ( ) ) ;
}
if ( origin ! = null ) {
query . setParameter ( "origin" , origin ) ;
}
if ( StringUtils . isNotBlank ( name ) ) {
query . setParameter ( "name" , "%" + name + "%" ) ;
}
if ( createTimeList ! = null & & createTimeList . size ( ) = = 2 ) {
String createTimeBegin = this . format . format ( createTimeList . get ( 0 ) ) ;
String createTimeEnd = this . format . format ( createTimeList . get ( 1 ) ) ;
query . setParameter ( "createTimeBegin" , createTimeBegin ) ;
query . setParameter ( "createTimeEnd" , createTimeEnd ) ;
}
if ( clueStage ! = null ) {
query . setParameter ( "clueStage" , clueStage ) ;
}
if ( userIdList ! = null & & userIdList . size ( ) > 0 ) {
query . setParameter ( "userIdList" , userIdList ) ;
}
if ( clueType ! = null ) {
query . setParameter ( "clueType" , clueType ) ;
}
query . unwrap ( NativeQuery . class ) . setResultTransformer ( Transformers . ALIAS_TO_ENTITY_MAP ) ;
List confirmReceipt = query . getResultList ( ) ;
Long count = 0 L ;
l ong count = 0 L ;
for ( Object obj : confirmReceipt ) {
Map row = ( Map ) obj ;
BigInteger countBig = ( BigInteger ) row . get ( "countNum" ) ;
@ -585,7 +594,7 @@ public class ClueJpa {
public Long getPoolCount ( PublicCluePoolQueryCriteria clueQueryCriteria ) {
StringBuilder sql = new StringBuilder ( "select count(*) as countNum from tb_public_clue_pool as p left join tb_clue_middle as cm on p.clue_id=cm.clue_id where 1=1 " ) ;
List confirmReceipt = getCluePoolListCondition ( clueQueryCriteria , sql , null ) ;
L ong count = 0 L ;
l ong count = 0 L ;
for ( Object obj : confirmReceipt ) {
Map row = ( Map ) obj ;
BigInteger countBig = ( BigInteger ) row . get ( "countNum" ) ;