Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Sign in
Toggle navigation
T
tanpu-community
Project
Project
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
Packages
Packages
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
探普后端
tanpu-community
Commits
ea5dda15
Commit
ea5dda15
authored
Dec 10, 2021
by
刘基明
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'bugfix_1208' into 'dev'
Bugfix 1208 See merge request
!28
parents
394274fc
98b30d73
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
9 additions
and
13 deletions
+9
-13
ConJobManager.java
.../main/java/com/tanpu/community/manager/ConJobManager.java
+0
-4
ThemeManager.java
...c/main/java/com/tanpu/community/manager/ThemeManager.java
+9
-9
No files found.
community-service/src/main/java/com/tanpu/community/manager/ConJobManager.java
View file @
ea5dda15
package
com
.
tanpu
.
community
.
manager
;
import
com.tanpu.community.service.*
;
import
com.tanpu.community.util.TimeUtils
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.scheduling.annotation.Scheduled
;
import
org.springframework.stereotype.Service
;
import
java.time.LocalDateTime
;
@Slf4j
@Service
@Configuration
...
...
@@ -45,7 +42,6 @@ public class ConJobManager {
*/
@Scheduled
(
cron
=
"10 0/2 * * * ?"
)
public
void
themeRank
()
{
log
.
info
(
"圈子定时统计开始执行,"
+
TimeUtils
.
format
(
LocalDateTime
.
now
()));
rankService
.
rankThemes
();
rankService
.
rankTopics
();
}
...
...
community-service/src/main/java/com/tanpu/community/manager/ThemeManager.java
View file @
ea5dda15
...
...
@@ -583,13 +583,13 @@ public class ThemeManager {
private
void
buildThemeCountInfo
(
ThemeQo
themeQo
)
{
String
themeId
=
themeQo
.
getThemeId
();
// 点赞,收藏,转发
Integer
likeCount
=
redisCache
.
getObject
(
StringUtils
.
joinWith
(
"_"
,
THEME_LIKE_COUNT
,
themeId
),
60
,
Integer
likeCount
=
redisCache
.
getObject
(
StringUtils
.
joinWith
(
"_"
,
THEME_LIKE_COUNT
,
themeId
),
60
*
60
*
24
,
()
->
collectionService
.
getCountByTypeAndId
(
themeId
,
CollectionTypeEnum
.
LIKE_THEME
),
Integer
.
class
);
Integer
commentCount
=
redisCache
.
getObject
(
StringUtils
.
joinWith
(
"_"
,
THEME_COMMENT_COUNT
,
themeId
),
60
,
Integer
commentCount
=
redisCache
.
getObject
(
StringUtils
.
joinWith
(
"_"
,
THEME_COMMENT_COUNT
,
themeId
),
60
*
60
*
24
,
()
->
commentService
.
getCommentCountByThemeId
(
themeId
),
Integer
.
class
);
Integer
forwardCount
=
redisCache
.
getObject
(
StringUtils
.
joinWith
(
"_"
,
THEME_FORWARD_COUNT
,
themeId
),
60
,
Integer
forwardCount
=
redisCache
.
getObject
(
StringUtils
.
joinWith
(
"_"
,
THEME_FORWARD_COUNT
,
themeId
),
60
*
60
*
24
,
()
->
themeService
.
getForwardCountById
(
themeId
),
Integer
.
class
);
themeQo
.
setCommentCount
(
commentCount
);
...
...
@@ -605,10 +605,10 @@ public class ThemeManager {
Map
<
String
,
Integer
>
commentCountMap
=
commentService
.
getCountMapByThemeIds
(
themeIds
);
Map
<
String
,
Integer
>
forwardCountMap
=
themeService
.
getForwardCountMap
(
themeIds
);
themeQos
.
stream
().
forEach
(
o
->
{
o
.
setCommentCount
(
commentCountMap
.
getOrDefault
(
o
.
getThemeId
(),
0
));
o
.
setLikeCount
(
likeCountMap
.
getOrDefault
(
o
.
getThemeId
(),
0
));
o
.
setForwardCount
(
forwardCountMap
.
getOrDefault
(
o
.
getThemeId
(),
0
));
themeQos
.
stream
().
forEach
(
o
->
{
o
.
setCommentCount
(
commentCountMap
.
getOrDefault
(
o
.
getThemeId
(),
0
));
o
.
setLikeCount
(
likeCountMap
.
getOrDefault
(
o
.
getThemeId
(),
0
));
o
.
setForwardCount
(
forwardCountMap
.
getOrDefault
(
o
.
getThemeId
(),
0
));
});
}
...
...
@@ -855,13 +855,13 @@ public class ThemeManager {
while
(
content
.
length
()
>
5000
)
{
b
=
TencentcloudUtils
.
textModeration
(
content
.
substring
(
0
,
5000
));
if
(
StringUtils
.
isNotBlank
(
b
))
{
throw
new
BizException
(
ErrorCodeConstant
.
CONTENT_ILLEGAL
.
getCode
(),
"疑似违规词汇:"
+
b
);
throw
new
BizException
(
ErrorCodeConstant
.
CONTENT_ILLEGAL
.
getCode
(),
"疑似违规词汇:"
+
b
);
}
content
=
content
.
substring
(
5000
);
}
b
=
TencentcloudUtils
.
textModeration
(
content
);
if
(
StringUtils
.
isNotBlank
(
b
))
{
throw
new
BizException
(
ErrorCodeConstant
.
CONTENT_ILLEGAL
.
getCode
(),
"疑似违规词汇:"
+
b
);
throw
new
BizException
(
ErrorCodeConstant
.
CONTENT_ILLEGAL
.
getCode
(),
"疑似违规词汇:"
+
b
);
}
...
...
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