记得上下班打卡 | 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
553ab3b3
Commit
553ab3b3
authored
Sep 19, 2021
by
anjiabin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
提交chime社交相关
parent
d1484a46
Changes
4
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
23 additions
and
3 deletions
+23
-3
ChimeUserController.java
...quidnet/service/chime/controller/ChimeUserController.java
+4
-0
ChimeUserServiceImpl.java
...dnet/service/chime/service/impl/ChimeUserServiceImpl.java
+2
-2
DataUtils.java
...ain/java/com/liquidnet/service/chime/utils/DataUtils.java
+1
-1
TestDataUtils.java
.../java/com/liquidnet/service/chime/test/TestDataUtils.java
+16
-0
No files found.
liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/controller/ChimeUserController.java
View file @
553ab3b3
...
@@ -51,6 +51,10 @@ public class ChimeUserController {
...
@@ -51,6 +51,10 @@ public class ChimeUserController {
,
@RequestParam
@Validated
String
tags
,
@RequestParam
@Validated
String
tags
,
@RequestParam
@Validated
String
operateType
,
@RequestParam
@Validated
String
operateType
)
{
)
{
log
.
info
(
"ChimeUserController.register userId:{}"
,
userId
);
log
.
info
(
"ChimeUserController.register sex:{}"
,
sex
);
log
.
info
(
"ChimeUserController.register tags:{}"
,
tags
);
log
.
info
(
"ChimeUserController.register operateType:{}"
,
operateType
);
if
(
operateType
.
equalsIgnoreCase
(
"CREATE"
)){
if
(
operateType
.
equalsIgnoreCase
(
"CREATE"
)){
ChimeUserRegisterReqDto
reqDto
=
ChimeUserRegisterReqDto
.
getNew
();
ChimeUserRegisterReqDto
reqDto
=
ChimeUserRegisterReqDto
.
getNew
();
reqDto
.
setUserId
(
userId
);
reqDto
.
setUserId
(
userId
);
...
...
liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/service/impl/ChimeUserServiceImpl.java
View file @
553ab3b3
...
@@ -47,7 +47,7 @@ public class ChimeUserServiceImpl implements IChimeUserService {
...
@@ -47,7 +47,7 @@ public class ChimeUserServiceImpl implements IChimeUserService {
ChimeUserInfoDto
chimeUserInfoDto
=
ChimeUserInfoDto
.
getNew
();
ChimeUserInfoDto
chimeUserInfoDto
=
ChimeUserInfoDto
.
getNew
();
if
(
StringUtil
.
isNotNull
(
reqDto
)){
if
(
StringUtil
.
isNotNull
(
reqDto
)){
chimeUserInfoDto
.
setUserId
(
reqDto
.
getUserId
());
chimeUserInfoDto
.
setUserId
(
reqDto
.
getUserId
());
chimeUserInfoDto
.
setSex
(
reqDto
.
getSex
(
));
chimeUserInfoDto
.
setSex
(
chimeUserBiz
.
getSexDesc
(
reqDto
.
getSex
()
));
chimeUserInfoDto
.
setJoinPerformanceId
(
"-1"
);
chimeUserInfoDto
.
setJoinPerformanceId
(
"-1"
);
List
<
ChimeUserTagDto
>
userTagList
=
chimeUserBiz
.
buildUserTagDtoList
(
reqDto
.
getUserId
(),
reqDto
.
getTags
());
List
<
ChimeUserTagDto
>
userTagList
=
chimeUserBiz
.
buildUserTagDtoList
(
reqDto
.
getUserId
(),
reqDto
.
getTags
());
chimeUserInfoDto
.
setUserTags
(
userTagList
);
chimeUserInfoDto
.
setUserTags
(
userTagList
);
...
@@ -69,7 +69,7 @@ public class ChimeUserServiceImpl implements IChimeUserService {
...
@@ -69,7 +69,7 @@ public class ChimeUserServiceImpl implements IChimeUserService {
List
<
ChimeUserTagsMappingVo
>
userTagList
=
chimeUserBiz
.
buildUserTagVoList
(
reqDto
.
getUserId
(),
reqDto
.
getTags
());
List
<
ChimeUserTagsMappingVo
>
userTagList
=
chimeUserBiz
.
buildUserTagVoList
(
reqDto
.
getUserId
(),
reqDto
.
getTags
());
chimeUserInfoVo
.
setUserId
(
reqDto
.
getUserId
());
chimeUserInfoVo
.
setUserId
(
reqDto
.
getUserId
());
chimeUserInfoVo
.
setUserTagsVoList
(
userTagList
);
chimeUserInfoVo
.
setUserTagsVoList
(
userTagList
);
chimeUserInfoVo
.
setSex
(
reqDto
.
getSex
(
));
chimeUserInfoVo
.
setSex
(
chimeUserBiz
.
getSexDesc
(
reqDto
.
getSex
()
));
dataUtils
.
updateChimeUser
(
chimeUserInfoVo
);
dataUtils
.
updateChimeUser
(
chimeUserInfoVo
);
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
e
.
printStackTrace
();
...
...
liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/utils/DataUtils.java
View file @
553ab3b3
...
@@ -59,7 +59,7 @@ public class DataUtils {
...
@@ -59,7 +59,7 @@ public class DataUtils {
public
void
updateChimeUser
(
ChimeUserInfoVo
chimeUserInfoVo
)
{
public
void
updateChimeUser
(
ChimeUserInfoVo
chimeUserInfoVo
)
{
Query
query
=
Query
.
query
(
Criteria
.
where
(
"userId"
).
is
(
chimeUserInfoVo
.
getUserId
()));
Query
query
=
Query
.
query
(
Criteria
.
where
(
"userId"
).
is
(
chimeUserInfoVo
.
getUserId
()));
Update
update
=
Update
.
fromDocument
(
Document
.
parse
(
JsonUtils
.
toJson
(
chimeUserInfoVo
)));
Update
update
=
Update
.
fromDocument
(
Document
.
parse
(
JsonUtils
.
toJson
(
chimeUserInfoVo
)));
UpdateResult
result
=
mongoTemplate
.
updateFirst
(
query
,
update
,
ChimeUserInfoVo
.
class
.
getSimpleName
());
UpdateResult
result
=
mongoTemplate
.
updateFirst
(
query
,
update
,
ChimeUserInfoVo
.
class
,
ChimeUserInfoVo
.
class
.
getSimpleName
());
log
.
info
(
"updateChimeUser result:{}"
,
result
.
toString
());
log
.
info
(
"updateChimeUser result:{}"
,
result
.
toString
());
}
}
...
...
liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/test/java/com/liquidnet/service/chime/test/TestDataUtils.java
View file @
553ab3b3
...
@@ -6,8 +6,10 @@ import com.liquidnet.commons.lang.util.RandomUtil;
...
@@ -6,8 +6,10 @@ import com.liquidnet.commons.lang.util.RandomUtil;
import
com.liquidnet.service.chime.biz.ChimeUserBiz
;
import
com.liquidnet.service.chime.biz.ChimeUserBiz
;
import
com.liquidnet.service.chime.dto.ChimeUserInfoDto
;
import
com.liquidnet.service.chime.dto.ChimeUserInfoDto
;
import
com.liquidnet.service.chime.dto.ChimeUserListQueryReqDto
;
import
com.liquidnet.service.chime.dto.ChimeUserListQueryReqDto
;
import
com.liquidnet.service.chime.dto.ChimeUserUpdateReqDto
;
import
com.liquidnet.service.chime.dto.NewPageResult
;
import
com.liquidnet.service.chime.dto.NewPageResult
;
import
com.liquidnet.service.chime.service.IChimePerformanceService
;
import
com.liquidnet.service.chime.service.IChimePerformanceService
;
import
com.liquidnet.service.chime.service.IChimeUserService
;
import
com.liquidnet.service.chime.utils.DataUtils
;
import
com.liquidnet.service.chime.utils.DataUtils
;
import
com.liquidnet.service.chime.vo.mongo.ChimeUserInfoVo
;
import
com.liquidnet.service.chime.vo.mongo.ChimeUserInfoVo
;
import
com.liquidnet.service.chime.vo.mongo.ChimeUserTagsMappingVo
;
import
com.liquidnet.service.chime.vo.mongo.ChimeUserTagsMappingVo
;
...
@@ -47,11 +49,25 @@ public class TestDataUtils {
...
@@ -47,11 +49,25 @@ public class TestDataUtils {
@Autowired
@Autowired
private
IChimePerformanceService
chimePerformanceService
;
private
IChimePerformanceService
chimePerformanceService
;
@Autowired
private
IChimeUserService
chimeUserService
;
@Test
@Test
public
void
getPerformanceCount
(){
public
void
getPerformanceCount
(){
System
.
out
.
println
(
chimeUserBiz
.
getSexDesc
(
"{\"val\":\"MS01\",\"desc\":\"女3性\"}"
));
System
.
out
.
println
(
chimeUserBiz
.
getSexDesc
(
"{\"val\":\"MS01\",\"desc\":\"女3性\"}"
));
}
}
@Test
public
void
updateUserInfo
(){
String
sex
=
"\"{\"val\":\"MS01\",\"desc\":\"男性\"}\""
;
String
tags
=
"[ { \"val\": \"MMS0102\", \"desc\": \"B\" }, { \"val\": \"MMS0101\", \"desc\": \"A\" }, { \"val\": \"MMS0201\", \"desc\": \"C\" } ]"
;
ChimeUserUpdateReqDto
reqDto
=
ChimeUserUpdateReqDto
.
getNew
();
reqDto
.
setUserId
(
"TEST202109191447591475263969"
);
reqDto
.
setSex
(
sex
);
reqDto
.
setTags
(
tags
);
chimeUserService
.
updateUserInfo
(
reqDto
);
}
@Test
@Test
public
void
getUserImgList
(){
public
void
getUserImgList
(){
ExecutorService
executorService
=
Executors
.
newFixedThreadPool
(
100
);
ExecutorService
executorService
=
Executors
.
newFixedThreadPool
(
100
);
...
...
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