记得上下班打卡 | 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
bca590c0
Commit
bca590c0
authored
Sep 22, 2021
by
jiangxiulong
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
unid to openId
parent
17f7c342
Changes
8
Show whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
22 additions
and
22 deletions
+22
-22
db_sweetsugar_structure.sql
.../liquidnet-service-sweet/docu/db_sweetsugar_structure.sql
+1
-1
SweetCityVoteController.java
...net/service/sweet/controller/SweetCityVoteController.java
+3
-3
SweetCityVote.java
...ava/com/liquidnet/service/sweet/entity/SweetCityVote.java
+3
-3
SweetCityVoteParam.java
...com/liquidnet/service/sweet/param/SweetCityVoteParam.java
+3
-3
ISweetCityVoteService.java
...iquidnet/service/sweet/service/ISweetCityVoteService.java
+1
-1
SweetCityVoteServiceImpl.java
.../service/sweet/service/impl/SweetCityVoteServiceImpl.java
+6
-6
RedisDataUtils.java
...ava/com/liquidnet/service/sweet/utils/RedisDataUtils.java
+4
-4
sqlmap.properties
...uidnet-service-sweet/src/main/resources/sqlmap.properties
+1
-1
No files found.
liquidnet-bus-service/liquidnet-service-sweet/docu/db_sweetsugar_structure.sql
View file @
bca590c0
...
@@ -487,7 +487,7 @@ CREATE TABLE `sweet_city_vote`
...
@@ -487,7 +487,7 @@ CREATE TABLE `sweet_city_vote`
`mid`
bigint
unsigned
NOT
NULL
AUTO_INCREMENT
,
`mid`
bigint
unsigned
NOT
NULL
AUTO_INCREMENT
,
`vote_id`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'vote_id'
,
`vote_id`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'vote_id'
,
`phone`
varchar
(
11
)
NOT
NULL
DEFAULT
''
COMMENT
'手机号'
,
`phone`
varchar
(
11
)
NOT
NULL
DEFAULT
''
COMMENT
'手机号'
,
`
unionId`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'unio
nId'
,
`
openId`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'ope
nId'
,
`city_code`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'城市代码'
,
`city_code`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'城市代码'
,
`city_name`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'城市名称'
,
`city_name`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'城市名称'
,
`day_time`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'投票天'
,
`day_time`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'投票天'
,
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/SweetCityVoteController.java
View file @
bca590c0
...
@@ -35,13 +35,13 @@ public class SweetCityVoteController {
...
@@ -35,13 +35,13 @@ public class SweetCityVoteController {
@ApiOperation
(
"城市投票排名"
)
@ApiOperation
(
"城市投票排名"
)
@ApiImplicitParams
({
@ApiImplicitParams
({
@ApiImplicitParam
(
type
=
"query"
,
dataType
=
"String"
,
name
=
"phone"
,
value
=
"手机号"
,
required
=
true
),
@ApiImplicitParam
(
type
=
"query"
,
dataType
=
"String"
,
name
=
"phone"
,
value
=
"手机号"
,
required
=
true
),
@ApiImplicitParam
(
type
=
"query"
,
dataType
=
"String"
,
name
=
"
unionId"
,
value
=
"unio
nId"
,
required
=
true
)
@ApiImplicitParam
(
type
=
"query"
,
dataType
=
"String"
,
name
=
"
openId"
,
value
=
"ope
nId"
,
required
=
true
)
})
})
public
ResponseDto
<
List
<
SweetCItyVoteStatVo
>>
getList
(
public
ResponseDto
<
List
<
SweetCItyVoteStatVo
>>
getList
(
@RequestParam
String
phone
,
@RequestParam
String
phone
,
@RequestParam
String
unio
nId
@RequestParam
String
ope
nId
)
{
)
{
return
sweetCityVoteService
.
getList
(
phone
,
unio
nId
);
return
sweetCityVoteService
.
getList
(
phone
,
ope
nId
);
}
}
@PostMapping
(
"createVote"
)
@PostMapping
(
"createVote"
)
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/entity/SweetCityVote.java
View file @
bca590c0
...
@@ -36,10 +36,10 @@ public class SweetCityVote implements Serializable {
...
@@ -36,10 +36,10 @@ public class SweetCityVote implements Serializable {
private
String
phone
;
private
String
phone
;
/**
/**
*
unio
nId
*
ope
nId
*/
*/
@TableField
(
"
unio
nId"
)
@TableField
(
"
ope
nId"
)
private
String
unio
nId
;
private
String
ope
nId
;
/**
/**
* 城市代码
* 城市代码
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/param/SweetCityVoteParam.java
View file @
bca590c0
...
@@ -16,9 +16,9 @@ public class SweetCityVoteParam implements java.io.Serializable {
...
@@ -16,9 +16,9 @@ public class SweetCityVoteParam implements java.io.Serializable {
@NotBlank
(
message
=
"phone不能为空"
)
@NotBlank
(
message
=
"phone不能为空"
)
private
String
phone
;
private
String
phone
;
@ApiModelProperty
(
position
=
11
,
required
=
true
,
value
=
"
unionId"
,
example
=
"unio
nId"
)
@ApiModelProperty
(
position
=
11
,
required
=
true
,
value
=
"
openId"
,
example
=
"ope
nId"
)
@NotBlank
(
message
=
"
unio
nId不能为空"
)
@NotBlank
(
message
=
"
ope
nId不能为空"
)
private
String
unio
nId
;
private
String
ope
nId
;
@ApiModelProperty
(
position
=
12
,
required
=
true
,
value
=
"城市代码"
,
example
=
"10001"
)
@ApiModelProperty
(
position
=
12
,
required
=
true
,
value
=
"城市代码"
,
example
=
"10001"
)
@NotBlank
(
message
=
"cityCode不能为空"
)
@NotBlank
(
message
=
"cityCode不能为空"
)
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/ISweetCityVoteService.java
View file @
bca590c0
...
@@ -22,5 +22,5 @@ public interface ISweetCityVoteService extends IService<SweetCityVote> {
...
@@ -22,5 +22,5 @@ public interface ISweetCityVoteService extends IService<SweetCityVote> {
ResponseDto
setStatList
();
ResponseDto
setStatList
();
ResponseDto
<
List
<
SweetCItyVoteStatVo
>>
getList
(
String
phone
,
String
unio
nId
);
ResponseDto
<
List
<
SweetCItyVoteStatVo
>>
getList
(
String
phone
,
String
ope
nId
);
}
}
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetCityVoteServiceImpl.java
View file @
bca590c0
...
@@ -52,9 +52,9 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
...
@@ -52,9 +52,9 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
private
SweetCityVoteStatMapper
sweetCityVoteStatMapper
;
private
SweetCityVoteStatMapper
sweetCityVoteStatMapper
;
@Override
@Override
public
ResponseDto
<
List
<
SweetCItyVoteStatVo
>>
getList
(
String
phone
,
String
unio
nId
)
{
public
ResponseDto
<
List
<
SweetCItyVoteStatVo
>>
getList
(
String
phone
,
String
ope
nId
)
{
List
<
SweetCItyVoteStatVo
>
sweetCityVoteStatList
=
redisDataUtils
.
getSweetCityVoteStatList
();
List
<
SweetCItyVoteStatVo
>
sweetCityVoteStatList
=
redisDataUtils
.
getSweetCityVoteStatList
();
String
userVote
=
redisDataUtils
.
getUserVote
(
phone
,
unio
nId
);
String
userVote
=
redisDataUtils
.
getUserVote
(
phone
,
ope
nId
);
for
(
SweetCItyVoteStatVo
info
:
sweetCityVoteStatList
)
{
for
(
SweetCItyVoteStatVo
info
:
sweetCityVoteStatList
)
{
if
(
userVote
.
isEmpty
()
||
!
userVote
.
equals
(
info
.
getCityCode
()))
{
if
(
userVote
.
isEmpty
()
||
!
userVote
.
equals
(
info
.
getCityCode
()))
{
info
.
setIsVote
(
1
);
info
.
setIsVote
(
1
);
...
@@ -67,14 +67,14 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
...
@@ -67,14 +67,14 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
@Override
@Override
public
ResponseDto
createVote
(
SweetCityVoteParam
param
)
{
public
ResponseDto
createVote
(
SweetCityVoteParam
param
)
{
String
userVote
=
redisDataUtils
.
getUserVote
(
param
.
getPhone
(),
param
.
get
Unio
nId
());
String
userVote
=
redisDataUtils
.
getUserVote
(
param
.
getPhone
(),
param
.
get
Ope
nId
());
if
(!
userVote
.
isEmpty
())
{
if
(!
userVote
.
isEmpty
())
{
return
ResponseDto
.
failure
(
"已经投过票啦~"
);
return
ResponseDto
.
failure
(
"已经投过票啦~"
);
}
}
SweetCityVote
aNew
=
SweetCityVote
.
getNew
();
SweetCityVote
aNew
=
SweetCityVote
.
getNew
();
aNew
.
setVoteId
(
IDGenerator
.
nextSnowId
());
aNew
.
setVoteId
(
IDGenerator
.
nextSnowId
());
aNew
.
setPhone
(
param
.
getPhone
());
aNew
.
setPhone
(
param
.
getPhone
());
aNew
.
set
UnionId
(
param
.
getUnio
nId
());
aNew
.
set
OpenId
(
param
.
getOpe
nId
());
aNew
.
setCityCode
(
param
.
getCityCode
());
aNew
.
setCityCode
(
param
.
getCityCode
());
aNew
.
setCityName
(
param
.
getCityName
());
aNew
.
setCityName
(
param
.
getCityName
());
...
@@ -84,7 +84,7 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
...
@@ -84,7 +84,7 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
LinkedList
<
Object
[]>
sqlsDataB
=
CollectionUtil
.
linkedListObjectArr
();
LinkedList
<
Object
[]>
sqlsDataB
=
CollectionUtil
.
linkedListObjectArr
();
sqls
.
add
(
SqlMapping
.
get
(
"sweet_city_vote.insert"
));
sqls
.
add
(
SqlMapping
.
get
(
"sweet_city_vote.insert"
));
sqlsDataA
.
add
(
new
Object
[]{
sqlsDataA
.
add
(
new
Object
[]{
aNew
.
getVoteId
(),
aNew
.
getPhone
(),
aNew
.
get
Unio
nId
(),
aNew
.
getCityCode
(),
aNew
.
getCityName
(),
DateUtil
.
format
(
LocalDateTime
.
now
(),
DateUtil
.
Formatter
.
yyyyMMdd
)
aNew
.
getVoteId
(),
aNew
.
getPhone
(),
aNew
.
get
Ope
nId
(),
aNew
.
getCityCode
(),
aNew
.
getCityName
(),
DateUtil
.
format
(
LocalDateTime
.
now
(),
DateUtil
.
Formatter
.
yyyyMMdd
)
});
});
Integer
cityVoteNum
=
redisDataUtils
.
getSweetCityVote
(
aNew
.
getCityCode
());
Integer
cityVoteNum
=
redisDataUtils
.
getSweetCityVote
(
aNew
.
getCityCode
());
if
(
cityVoteNum
>
0
)
{
// 已有 incr
if
(
cityVoteNum
>
0
)
{
// 已有 incr
...
@@ -103,7 +103,7 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
...
@@ -103,7 +103,7 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
redisDataUtils
.
incrSweetCityVote
(
aNew
.
getCityCode
());
redisDataUtils
.
incrSweetCityVote
(
aNew
.
getCityCode
());
redisDataUtils
.
setUserVote
(
param
.
getPhone
(),
param
.
get
Unio
nId
(),
param
.
getCityCode
());
redisDataUtils
.
setUserVote
(
param
.
getPhone
(),
param
.
get
Ope
nId
(),
param
.
getCityCode
());
return
ResponseDto
.
success
();
return
ResponseDto
.
success
();
}
}
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/RedisDataUtils.java
View file @
bca590c0
...
@@ -504,12 +504,12 @@ public class RedisDataUtils {
...
@@ -504,12 +504,12 @@ public class RedisDataUtils {
return
(
Integer
)
obj
;
return
(
Integer
)
obj
;
}
}
}
}
public
void
setUserVote
(
String
phone
,
String
unio
nId
,
String
cityCode
)
{
public
void
setUserVote
(
String
phone
,
String
ope
nId
,
String
cityCode
)
{
String
redisKey
=
SweetConstant
.
REDIS_KEY_SWEET_CITY_VOTE_USER
.
concat
(
phone
).
concat
(
"-"
).
concat
(
unio
nId
);
String
redisKey
=
SweetConstant
.
REDIS_KEY_SWEET_CITY_VOTE_USER
.
concat
(
phone
).
concat
(
"-"
).
concat
(
ope
nId
);
redisUtil
.
set
(
redisKey
,
cityCode
);
redisUtil
.
set
(
redisKey
,
cityCode
);
}
}
public
String
getUserVote
(
String
phone
,
String
unio
nId
)
{
public
String
getUserVote
(
String
phone
,
String
ope
nId
)
{
String
redisKey
=
SweetConstant
.
REDIS_KEY_SWEET_CITY_VOTE_USER
.
concat
(
phone
).
concat
(
"-"
).
concat
(
unio
nId
);
String
redisKey
=
SweetConstant
.
REDIS_KEY_SWEET_CITY_VOTE_USER
.
concat
(
phone
).
concat
(
"-"
).
concat
(
ope
nId
);
Object
obj
=
redisUtil
.
get
(
redisKey
);
Object
obj
=
redisUtil
.
get
(
redisKey
);
if
(
null
==
obj
)
{
if
(
null
==
obj
)
{
return
""
;
return
""
;
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/resources/sqlmap.properties
View file @
bca590c0
...
@@ -70,6 +70,6 @@ sweet_remind.insert=INSERT INTO sweet_remind (remind_id,openId,unionId,performan
...
@@ -70,6 +70,6 @@ sweet_remind.insert=INSERT INTO sweet_remind (remind_id,openId,unionId,performan
# --------------------------小程序登录记录用户解密后信息--------------------------
# --------------------------小程序登录记录用户解密后信息--------------------------
sweet_applet_user.insert
=
INSERT INTO sweet_applet_user (user_id,openId,unionId,getPhoneNumber,getPurePhoneNumber,getCountryCode,type) VALUES (?,?,?,?,?,?,?)
sweet_applet_user.insert
=
INSERT INTO sweet_applet_user (user_id,openId,unionId,getPhoneNumber,getPurePhoneNumber,getCountryCode,type) VALUES (?,?,?,?,?,?,?)
# --------------------------用户投票记录--------------------------
# --------------------------用户投票记录--------------------------
sweet_city_vote.insert
=
INSERT INTO sweet_city_vote (vote_id,phone,
unio
nId,city_code,city_name,day_time) VALUES (?,?,?,?,?,?)
sweet_city_vote.insert
=
INSERT INTO sweet_city_vote (vote_id,phone,
ope
nId,city_code,city_name,day_time) VALUES (?,?,?,?,?,?)
sweet_city_vote_stat.insert
=
INSERT INTO sweet_city_vote_stat (stat_id,city_code,city_name,vote_num) VALUES (?,?,?,?)
sweet_city_vote_stat.insert
=
INSERT INTO sweet_city_vote_stat (stat_id,city_code,city_name,vote_num) VALUES (?,?,?,?)
sweet_city_vote_stat.update
=
UPDATE sweet_city_vote_stat SET vote_num = IFNULL(vote_num, 0) + 1, updated_at = ? WHERE city_code = ?
sweet_city_vote_stat.update
=
UPDATE sweet_city_vote_stat SET vote_num = IFNULL(vote_num, 0) + 1, updated_at = ? WHERE city_code = ?
\ No newline at end of file
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