记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
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
董敬伟
liquidnet-bus-v1
Commits
f1dbd27a
Commit
f1dbd27a
authored
Nov 30, 2021
by
jiangxiulong
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
这里没有token 不能写在这里
parent
14655818
Changes
2
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
0 additions
and
48 deletions
+0
-48
AdminUpushController.java
...atform/controller/basicServices/AdminUpushController.java
+0
-7
AdminUpushServiceImpl.java
...platform/service/basicServices/AdminUpushServiceImpl.java
+0
-41
No files found.
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/basicServices/AdminUpushController.java
View file @
f1dbd27a
...
@@ -48,11 +48,4 @@ public class AdminUpushController {
...
@@ -48,11 +48,4 @@ public class AdminUpushController {
return
ResponseDto
.
success
(
result
);
return
ResponseDto
.
success
(
result
);
}
}
@GetMapping
(
"unread"
)
@ApiOperation
(
"用户未读数量"
)
public
ResponseDto
<
Integer
>
unread
(
HttpServletRequest
request
)
{
Integer
num
=
adminUpushServiceImpl
.
unread
(
request
);
return
ResponseDto
.
success
(
num
);
}
}
}
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/basicServices/AdminUpushServiceImpl.java
View file @
f1dbd27a
...
@@ -38,7 +38,6 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp
...
@@ -38,7 +38,6 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp
RedisDataSourceUtil
redisDataSourceUtil
;
RedisDataSourceUtil
redisDataSourceUtil
;
public
PageInfo
<
AdminUpushVo
>
lists
(
HttpServletRequest
request
,
Integer
page
,
Integer
size
)
{
public
PageInfo
<
AdminUpushVo
>
lists
(
HttpServletRequest
request
,
Integer
page
,
Integer
size
)
{
String
uid
=
CurrentUtil
.
getCurrentUid
();
String
source
=
request
.
getHeader
(
"source"
);
String
source
=
request
.
getHeader
(
"source"
);
PageInfo
<
AdminUpushVo
>
voPageInfo
=
null
;
PageInfo
<
AdminUpushVo
>
voPageInfo
=
null
;
Object
adminUpushVo
=
null
;
Object
adminUpushVo
=
null
;
...
@@ -53,12 +52,7 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp
...
@@ -53,12 +52,7 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp
voPageInfo
=
PageInfo
.
of
(
new
LinkedList
<>());
voPageInfo
=
PageInfo
.
of
(
new
LinkedList
<>());
}
else
{
}
else
{
LinkedList
<
AdminUpushVo
>
pushList
=
(
LinkedList
<
AdminUpushVo
>)
adminUpushVo
;
LinkedList
<
AdminUpushVo
>
pushList
=
(
LinkedList
<
AdminUpushVo
>)
adminUpushVo
;
Integer
num
=
0
;
for
(
AdminUpushVo
info
:
pushList
)
{
for
(
AdminUpushVo
info
:
pushList
)
{
if
(
num
==
0
)
{
redisDataSourceUtil
.
getRedisKylinUtil
().
set
(
KylinRedisConst
.
ADMIN_UPUSH_LIST_READ_UID
.
concat
(
uid
),
info
.
getUpushId
());
}
num
++;
if
(!
info
.
getImg
().
isEmpty
())
{
if
(!
info
.
getImg
().
isEmpty
())
{
String
img
=
imgUrl
+
info
.
getImg
();
String
img
=
imgUrl
+
info
.
getImg
();
info
.
setImg
(
img
);
info
.
setImg
(
img
);
...
@@ -70,39 +64,4 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp
...
@@ -70,39 +64,4 @@ public class AdminUpushServiceImpl extends ServiceImpl<AdminUpushMapper, AdminUp
return
voPageInfo
;
return
voPageInfo
;
}
}
public
Integer
unread
(
HttpServletRequest
request
)
{
String
uid
=
CurrentUtil
.
getCurrentUid
();
Object
obj
=
redisDataSourceUtil
.
getRedisKylinUtil
().
get
(
KylinRedisConst
.
ADMIN_UPUSH_LIST_READ_UID
.
concat
(
uid
));
String
source
=
request
.
getHeader
(
"source"
);
Object
adminUpushVo
=
null
;
if
(
null
!=
source
)
{
if
(
source
.
equals
(
"IOS"
))
{
adminUpushVo
=
redisDataSourceUtil
.
getRedisKylinUtil
().
get
(
KylinRedisConst
.
ADMIN_UPUSH_LIST_IOS
);
}
else
if
(
source
.
equals
(
"Android"
))
{
adminUpushVo
=
redisDataSourceUtil
.
getRedisKylinUtil
().
get
(
KylinRedisConst
.
ADMIN_UPUSH_LIST_ANDROID
);
}
}
if
(
null
==
adminUpushVo
||
null
==
source
)
{
return
0
;
}
LinkedList
<
AdminUpushVo
>
pushList
=
(
LinkedList
<
AdminUpushVo
>)
adminUpushVo
;
if
(
null
==
obj
)
{
return
pushList
.
size
();
}
Integer
num
=
0
;
String
pushId
=
(
String
)
obj
;
for
(
AdminUpushVo
info
:
pushList
)
{
if
(
info
.
getUpushId
().
equals
(
pushId
))
{
break
;
}
else
{
num
++;
}
}
return
num
;
}
}
}
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