Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
H
haoban-manage3.0
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
haoban3.0
haoban-manage3.0
Commits
bca0d49f
Commit
bca0d49f
authored
Dec 23, 2022
by
徐高华
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
活码查询
parent
adb5db1c
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
54 additions
and
35 deletions
+54
-35
GroupChatSearchQDTO.java
.../haoban/manage/api/dto/qdto/chat/GroupChatSearchQDTO.java
+10
-0
GroupChatServiceImpl.java
...anage/service/service/chat/impl/GroupChatServiceImpl.java
+6
-2
GroupChatHmController.java
...ban/manage/web/controller/chat/GroupChatHmController.java
+38
-33
No files found.
haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/dto/qdto/chat/GroupChatSearchQDTO.java
View file @
bca0d49f
...
@@ -24,6 +24,8 @@ public class GroupChatSearchQDTO extends PageQo implements Serializable {
...
@@ -24,6 +24,8 @@ public class GroupChatSearchQDTO extends PageQo implements Serializable {
private
String
staffId
;
private
String
staffId
;
private
int
gicFlag
=
1
;
private
int
gicFlag
=
1
;
private
Long
chatHmId
;
private
Long
chatHmId
;
// 查询活码关联是否包含下线的1是0否
private
int
includeOff
;
private
List
<
Long
>
groupChatIdList
;
private
List
<
Long
>
groupChatIdList
;
private
String
sortColumn
;
private
String
sortColumn
;
private
String
sortType
=
"desc"
;
private
String
sortType
=
"desc"
;
...
@@ -34,6 +36,14 @@ public class GroupChatSearchQDTO extends PageQo implements Serializable {
...
@@ -34,6 +36,14 @@ public class GroupChatSearchQDTO extends PageQo implements Serializable {
// 筛选激活或者开启联系我的群主
// 筛选激活或者开启联系我的群主
private
Integer
canUseFlag
;
private
Integer
canUseFlag
;
public
int
getIncludeOff
()
{
return
includeOff
;
}
public
void
setIncludeOff
(
int
includeOff
)
{
this
.
includeOff
=
includeOff
;
}
public
String
getDepartmentId
()
{
public
String
getDepartmentId
()
{
return
departmentId
;
return
departmentId
;
}
}
...
...
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatServiceImpl.java
View file @
bca0d49f
...
@@ -246,8 +246,12 @@ public class GroupChatServiceImpl implements GroupChatService {
...
@@ -246,8 +246,12 @@ public class GroupChatServiceImpl implements GroupChatService {
@Override
@Override
public
Page
<
GroupChatDTO
>
listPage
(
GroupChatSearchQDTO
qdto
,
BasePageInfo
basePageInfo
)
{
public
Page
<
GroupChatDTO
>
listPage
(
GroupChatSearchQDTO
qdto
,
BasePageInfo
basePageInfo
)
{
if
(
null
!=
qdto
.
getChatHmId
())
{
if
(
null
!=
qdto
.
getChatHmId
())
{
List
<
TabGroupChatHmRelation
>
list
=
this
.
groupChatHmRelationMapper
List
<
TabGroupChatHmRelation
>
list
=
null
;
.
listByChatHmIdIncludeOff
(
qdto
.
getChatHmId
());
if
(
qdto
.
getIncludeOff
()
==
1
)
{
list
=
this
.
groupChatHmRelationMapper
.
listByChatHmIdIncludeOff
(
qdto
.
getChatHmId
());
}
else
{
list
=
this
.
groupChatHmRelationMapper
.
listByChatHmId
(
qdto
.
getChatHmId
());
}
if
(
CollectionUtils
.
isEmpty
(
list
))
{
if
(
CollectionUtils
.
isEmpty
(
list
))
{
return
new
Page
<
GroupChatDTO
>();
return
new
Page
<
GroupChatDTO
>();
}
}
...
...
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/chat/GroupChatHmController.java
View file @
bca0d49f
...
@@ -74,7 +74,7 @@ import com.google.common.collect.Sets;
...
@@ -74,7 +74,7 @@ import com.google.common.collect.Sets;
public
class
GroupChatHmController
{
public
class
GroupChatHmController
{
private
static
Logger
logger
=
LogManager
.
getLogger
(
GroupChatHmController
.
class
);
private
static
Logger
logger
=
LogManager
.
getLogger
(
GroupChatHmController
.
class
);
@Autowired
@Autowired
private
GroupChatHmApiService
groupChatHmApiService
;
private
GroupChatHmApiService
groupChatHmApiService
;
@Autowired
@Autowired
...
@@ -131,7 +131,8 @@ public class GroupChatHmController {
...
@@ -131,7 +131,8 @@ public class GroupChatHmController {
if
(!
oldResp
.
isSuccess
())
{
if
(!
oldResp
.
isSuccess
())
{
return
RestResponse
.
failure
(
oldResp
.
getCode
(),
oldResp
.
getMessage
());
return
RestResponse
.
failure
(
oldResp
.
getCode
(),
oldResp
.
getMessage
());
}
}
List
<
Long
>
oldIdList
=
this
.
groupChatHmApiService
.
listHmGroupChatId
(
loginUser
.
getWxEnterpriseId
(),
dto
.
getChatHmId
()).
getResult
()
;
List
<
Long
>
oldIdList
=
this
.
groupChatHmApiService
.
listHmGroupChatId
(
loginUser
.
getWxEnterpriseId
(),
dto
.
getChatHmId
()).
getResult
();
GroupChatHmDTO
oldDTO
=
oldResp
.
getResult
();
GroupChatHmDTO
oldDTO
=
oldResp
.
getResult
();
dto
.
setWxEnterpriseId
(
loginUser
.
getWxEnterpriseId
());
dto
.
setWxEnterpriseId
(
loginUser
.
getWxEnterpriseId
());
dto
.
setEnterpriseId
(
loginUser
.
getEnterpriseId
());
dto
.
setEnterpriseId
(
loginUser
.
getEnterpriseId
());
...
@@ -140,7 +141,7 @@ public class GroupChatHmController {
...
@@ -140,7 +141,7 @@ public class GroupChatHmController {
dto
.
setWxConfigId
(
oldDTO
.
getWxConfigId
());
dto
.
setWxConfigId
(
oldDTO
.
getWxConfigId
());
ServiceResponse
<
GroupChatHmDTO
>
resp
=
this
.
groupChatHmApiService
.
save
(
dto
);
ServiceResponse
<
GroupChatHmDTO
>
resp
=
this
.
groupChatHmApiService
.
save
(
dto
);
if
(
resp
.
isSuccess
())
{
if
(
resp
.
isSuccess
())
{
String
logContent
=
this
.
getUpdateLog
(
oldDTO
,
dto
,
oldIdList
);
String
logContent
=
this
.
getUpdateLog
(
oldDTO
,
dto
,
oldIdList
);
if
(
StringUtils
.
isNotBlank
(
logContent
))
{
if
(
StringUtils
.
isNotBlank
(
logContent
))
{
GicLogRecordEvaluationContext
.
putAttribute
(
"logValue"
,
logContent
);
GicLogRecordEvaluationContext
.
putAttribute
(
"logValue"
,
logContent
);
GicLogRecordEvaluationContext
.
putOptTargetId
(
AuthWebRequestUtil
.
getLoginUser
().
getClerkId
());
GicLogRecordEvaluationContext
.
putOptTargetId
(
AuthWebRequestUtil
.
getLoginUser
().
getClerkId
());
...
@@ -153,7 +154,7 @@ public class GroupChatHmController {
...
@@ -153,7 +154,7 @@ public class GroupChatHmController {
return
RestResponse
.
failure
(
"1"
,
resp
.
getMessage
());
return
RestResponse
.
failure
(
"1"
,
resp
.
getMessage
());
}
}
private
String
getUpdateLog
(
GroupChatHmDTO
oldDTO
,
GroupChatHmDTO
newDTO
,
List
<
Long
>
oldIdList
)
{
private
String
getUpdateLog
(
GroupChatHmDTO
oldDTO
,
GroupChatHmDTO
newDTO
,
List
<
Long
>
oldIdList
)
{
String
wxEnterpriseId
=
newDTO
.
getWxEnterpriseId
();
String
wxEnterpriseId
=
newDTO
.
getWxEnterpriseId
();
String
enterpriseId
=
newDTO
.
getEnterpriseId
();
String
enterpriseId
=
newDTO
.
getEnterpriseId
();
StringBuilder
content
=
new
StringBuilder
();
StringBuilder
content
=
new
StringBuilder
();
...
@@ -165,32 +166,32 @@ public class GroupChatHmController {
...
@@ -165,32 +166,32 @@ public class GroupChatHmController {
if
(
null
!=
b
)
{
if
(
null
!=
b
)
{
content
.
append
(
b
);
content
.
append
(
b
);
}
}
String
o
=
null
;
String
o
=
null
;
List
<
Long
>
newIdList
=
newDTO
.
getChatIdList
()
;
List
<
Long
>
newIdList
=
newDTO
.
getChatIdList
();
Sets
.
SetView
<
Long
>
delView
=
Sets
.
difference
(
Sets
.
newHashSet
(
oldIdList
),
Sets
.
newHashSet
(
newIdList
));
Sets
.
SetView
<
Long
>
delView
=
Sets
.
difference
(
Sets
.
newHashSet
(
oldIdList
),
Sets
.
newHashSet
(
newIdList
));
List
<
Long
>
delIdList
=
delView
.
stream
().
collect
(
Collectors
.
toList
());
List
<
Long
>
delIdList
=
delView
.
stream
().
collect
(
Collectors
.
toList
());
logger
.
info
(
"删除的群={}"
,
delIdList
);
logger
.
info
(
"删除的群={}"
,
delIdList
);
if
(
CollectionUtils
.
isNotEmpty
(
delIdList
))
{
if
(
CollectionUtils
.
isNotEmpty
(
delIdList
))
{
String
chats
=
this
.
getGroupChatName
(
wxEnterpriseId
,
delIdList
)
;
String
chats
=
this
.
getGroupChatName
(
wxEnterpriseId
,
delIdList
);
if
(
StringUtils
.
isNotBlank
(
chats
))
{
if
(
StringUtils
.
isNotBlank
(
chats
))
{
o
=
"删除可加入群聊【"
+
chats
+
"】"
;
o
=
"删除可加入群聊【"
+
chats
+
"】"
;
content
.
append
(
o
);
content
.
append
(
o
);
}
}
}
}
String
p
=
null
;
String
p
=
null
;
Sets
.
SetView
<
Long
>
addView
=
Sets
.
difference
(
Sets
.
newHashSet
(
newIdList
),
Sets
.
newHashSet
(
oldIdList
));
Sets
.
SetView
<
Long
>
addView
=
Sets
.
difference
(
Sets
.
newHashSet
(
newIdList
),
Sets
.
newHashSet
(
oldIdList
));
List
<
Long
>
addIdList
=
addView
.
stream
().
collect
(
Collectors
.
toList
());
List
<
Long
>
addIdList
=
addView
.
stream
().
collect
(
Collectors
.
toList
());
logger
.
info
(
"增加的群={}"
,
addIdList
);
logger
.
info
(
"增加的群={}"
,
addIdList
);
if
(
CollectionUtils
.
isNotEmpty
(
addIdList
))
{
if
(
CollectionUtils
.
isNotEmpty
(
addIdList
))
{
String
chats
=
this
.
getGroupChatName
(
wxEnterpriseId
,
addIdList
)
;
String
chats
=
this
.
getGroupChatName
(
wxEnterpriseId
,
addIdList
);
if
(
StringUtils
.
isNotBlank
(
chats
))
{
if
(
StringUtils
.
isNotBlank
(
chats
))
{
p
=
"新增可加入群聊【"
+
chats
+
"】"
;
p
=
"新增可加入群聊【"
+
chats
+
"】"
;
content
.
append
(
p
);
content
.
append
(
p
);
}
}
}
}
String
c
=
null
;
String
c
=
null
;
if
(
oldDTO
.
getAutoCreateRoom
()
==
1
&&
newDTO
.
getAutoCreateRoom
()
==
0
)
{
if
(
oldDTO
.
getAutoCreateRoom
()
==
1
&&
newDTO
.
getAutoCreateRoom
()
==
0
)
{
c
=
"关闭自动建群功能"
;
c
=
"关闭自动建群功能"
;
...
@@ -214,7 +215,7 @@ public class GroupChatHmController {
...
@@ -214,7 +215,7 @@ public class GroupChatHmController {
content
.
append
(
f
);
content
.
append
(
f
);
}
}
}
}
if
(
org
.
apache
.
commons
.
lang3
.
StringUtils
.
isAllBlank
(
a
,
b
,
c
,
d
,
e
,
f
,
o
,
p
))
{
if
(
org
.
apache
.
commons
.
lang3
.
StringUtils
.
isAllBlank
(
a
,
b
,
c
,
d
,
e
,
f
,
o
,
p
))
{
return
null
;
return
null
;
}
}
StringBuilder
sb
=
new
StringBuilder
(
"编辑群活码"
).
append
(
"【"
).
append
(
oldDTO
.
getChatHmCode
()).
append
(
"-"
)
StringBuilder
sb
=
new
StringBuilder
(
"编辑群活码"
).
append
(
"【"
).
append
(
oldDTO
.
getChatHmCode
()).
append
(
"-"
)
...
@@ -222,21 +223,23 @@ public class GroupChatHmController {
...
@@ -222,21 +223,23 @@ public class GroupChatHmController {
return
sb
.
append
(
content
).
toString
();
return
sb
.
append
(
content
).
toString
();
}
}
private
String
getGroupChatName
(
String
wxEnterpriseId
,
List
<
Long
>
groupChatIdList
)
{
private
String
getGroupChatName
(
String
wxEnterpriseId
,
List
<
Long
>
groupChatIdList
)
{
ServiceResponse
<
List
<
GroupChatDTO
>>
resp
=
this
.
groupChatApiService
.
listChatByIdList
(
wxEnterpriseId
,
groupChatIdList
)
;
ServiceResponse
<
List
<
GroupChatDTO
>>
resp
=
this
.
groupChatApiService
.
listChatByIdList
(
wxEnterpriseId
,
List
<
GroupChatDTO
>
list
=
resp
.
getResult
()
;
groupChatIdList
);
String
names
=
list
.
stream
().
map
(
dto
->
joint
(
dto
.
getWxChatId
(),
"-"
,
dto
.
getName
())).
collect
(
Collectors
.
joining
(
","
))
;
List
<
GroupChatDTO
>
list
=
resp
.
getResult
();
return
names
;
String
names
=
list
.
stream
().
map
(
dto
->
joint
(
dto
.
getWxChatId
(),
"-"
,
dto
.
getName
()))
.
collect
(
Collectors
.
joining
(
","
));
return
names
;
}
}
private
String
joint
(
String
...
arr
)
{
private
String
joint
(
String
...
arr
)
{
StringBuilder
sb
=
new
StringBuilder
()
;
StringBuilder
sb
=
new
StringBuilder
();
for
(
String
s
:
arr
)
{
for
(
String
s
:
arr
)
{
sb
.
append
(
s
)
;
sb
.
append
(
s
);
}
}
return
sb
.
toString
()
;
return
sb
.
toString
();
}
}
public
String
comp
(
String
wxEnterpriseId
,
String
enterpriseId
,
String
title
,
String
oldValue
,
String
newValue
,
public
String
comp
(
String
wxEnterpriseId
,
String
enterpriseId
,
String
title
,
String
oldValue
,
String
newValue
,
int
type
)
{
int
type
)
{
StringBuilder
sb
=
new
StringBuilder
();
StringBuilder
sb
=
new
StringBuilder
();
...
@@ -255,7 +258,7 @@ public class GroupChatHmController {
...
@@ -255,7 +258,7 @@ public class GroupChatHmController {
@RequestMapping
(
"page"
)
@RequestMapping
(
"page"
)
public
RestResponse
<
Object
>
page
(
@RequestBody
ChatHmSearchQDTO
qdto
)
{
public
RestResponse
<
Object
>
page
(
@RequestBody
ChatHmSearchQDTO
qdto
)
{
BasePageInfo
basePageInfo
=
new
BasePageInfo
()
;
BasePageInfo
basePageInfo
=
new
BasePageInfo
();
basePageInfo
.
setPageNum
(
qdto
.
getPageNum
());
basePageInfo
.
setPageNum
(
qdto
.
getPageNum
());
basePageInfo
.
setPageSize
(
qdto
.
getPageSize
());
basePageInfo
.
setPageSize
(
qdto
.
getPageSize
());
WebLoginDTO
loginUser
=
AuthWebRequestUtil
.
getLoginUser
();
WebLoginDTO
loginUser
=
AuthWebRequestUtil
.
getLoginUser
();
...
@@ -366,7 +369,8 @@ public class GroupChatHmController {
...
@@ -366,7 +369,8 @@ public class GroupChatHmController {
* @throws
* @throws
*/
*/
@RequestMapping
(
"group-relation"
)
@RequestMapping
(
"group-relation"
)
public
RestResponse
<
Object
>
groupRelation
(
Long
chatHmId
,
BasePageInfo
basePageInfo
)
{
public
RestResponse
<
Object
>
groupRelation
(
Long
chatHmId
,
BasePageInfo
basePageInfo
,
@RequestParam
(
defaultValue
=
"0"
)
int
includeOff
)
{
if
(
null
==
chatHmId
)
{
if
(
null
==
chatHmId
)
{
return
RestResponse
.
failure
(
"1"
,
"群活码ID空"
);
return
RestResponse
.
failure
(
"1"
,
"群活码ID空"
);
}
}
...
@@ -376,6 +380,7 @@ public class GroupChatHmController {
...
@@ -376,6 +380,7 @@ public class GroupChatHmController {
qdto
.
setWxEnterpriseId
(
wxEnterpriseId
);
qdto
.
setWxEnterpriseId
(
wxEnterpriseId
);
qdto
.
setEnterpriseId
(
loginUser
.
getEnterpriseId
());
qdto
.
setEnterpriseId
(
loginUser
.
getEnterpriseId
());
qdto
.
setChatHmId
(
chatHmId
);
qdto
.
setChatHmId
(
chatHmId
);
qdto
.
setIncludeOff
(
includeOff
);
ServiceResponse
<
Page
<
GroupChatDTO
>>
page
=
this
.
groupChatApiService
.
listPage
(
qdto
,
basePageInfo
);
ServiceResponse
<
Page
<
GroupChatDTO
>>
page
=
this
.
groupChatApiService
.
listPage
(
qdto
,
basePageInfo
);
return
RestResponse
.
successResult
(
page
.
getResult
());
return
RestResponse
.
successResult
(
page
.
getResult
());
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment