记得上下班打卡 | 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
f1bf9426
Commit
f1bf9426
authored
Nov 22, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修改脚本
parent
bf0c5082
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
20 additions
and
8 deletions
+20
-8
StoneScoreUser.java
...va/com/liquidnet/service/stone/entity/StoneScoreUser.java
+13
-1
DataImpl.java
...quidnet/service/platform/service/impl/kylin/DataImpl.java
+7
-7
No files found.
liquidnet-bus-do/liquidnet-service-stone-do/src/main/java/com/liquidnet/service/stone/entity/StoneScoreUser.java
View file @
f1bf9426
...
@@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.annotation.IdType;
...
@@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.annotation.IdType;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
java.time.LocalDateTime
;
import
java.time.LocalDateTime
;
import
java.io.Serializable
;
import
java.io.Serializable
;
import
com.liquidnet.service.stone.dto.StoneScoreListDto
;
import
lombok.Data
;
import
lombok.Data
;
import
lombok.EqualsAndHashCode
;
import
lombok.EqualsAndHashCode
;
...
@@ -17,7 +19,7 @@ import lombok.EqualsAndHashCode;
...
@@ -17,7 +19,7 @@ import lombok.EqualsAndHashCode;
*/
*/
@Data
@Data
@EqualsAndHashCode
(
callSuper
=
false
)
@EqualsAndHashCode
(
callSuper
=
false
)
public
class
StoneScoreUser
implements
Serializable
{
public
class
StoneScoreUser
implements
Serializable
,
Cloneable
{
private
static
final
long
serialVersionUID
=
1L
;
private
static
final
long
serialVersionUID
=
1L
;
...
@@ -46,4 +48,14 @@ public class StoneScoreUser implements Serializable {
...
@@ -46,4 +48,14 @@ public class StoneScoreUser implements Serializable {
private
String
comment
;
private
String
comment
;
private
static
final
StoneScoreUser
obj
=
new
StoneScoreUser
();
public
static
StoneScoreUser
getNew
()
{
try
{
return
(
StoneScoreUser
)
obj
.
clone
();
}
catch
(
CloneNotSupportedException
e
)
{
e
.
printStackTrace
();
}
return
new
StoneScoreUser
();
}
}
}
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java
View file @
f1bf9426
...
@@ -83,7 +83,7 @@ public class DataImpl {
...
@@ -83,7 +83,7 @@ public class DataImpl {
//创建 用户积分数据
//创建 用户积分数据
int
isExists
=
stoneScoreUserMapper
.
selectCount
(
Wrappers
.
lambdaQuery
(
StoneScoreUser
.
class
).
eq
(
StoneScoreUser:
:
getUid
,
uid
));
int
isExists
=
stoneScoreUserMapper
.
selectCount
(
Wrappers
.
lambdaQuery
(
StoneScoreUser
.
class
).
eq
(
StoneScoreUser:
:
getUid
,
uid
));
if
(
isExists
<=
0
)
{
if
(
isExists
<=
0
)
{
StoneScoreUser
data
=
new
StoneScoreUser
();
StoneScoreUser
data
=
StoneScoreUser
.
getNew
();
data
.
setStatus
(
1
);
data
.
setStatus
(
1
);
data
.
setScoreId
(
IDGenerator
.
nextTimeId2
());
data
.
setScoreId
(
IDGenerator
.
nextTimeId2
());
data
.
setUid
(
uid
);
data
.
setUid
(
uid
);
...
@@ -103,7 +103,7 @@ public class DataImpl {
...
@@ -103,7 +103,7 @@ public class DataImpl {
int
goodsPrice
=
(
int
)
JSONObject
.
parseObject
(
resultData
).
get
(
"cost"
);
int
goodsPrice
=
(
int
)
JSONObject
.
parseObject
(
resultData
).
get
(
"cost"
);
try
{
try
{
score
+=
(
goodsPrice
);
score
+=
(
goodsPrice
);
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
}
}
...
@@ -141,7 +141,7 @@ public class DataImpl {
...
@@ -141,7 +141,7 @@ public class DataImpl {
if
(
isLog
<=
0
)
{
if
(
isLog
<=
0
)
{
MultiValueMap
<
String
,
String
>
params
=
CollectionUtil
.
linkedMultiValueMapStringString
();
MultiValueMap
<
String
,
String
>
params
=
CollectionUtil
.
linkedMultiValueMapStringString
();
params
.
add
(
"uid"
,
uid
);
params
.
add
(
"uid"
,
uid
);
params
.
add
(
"score"
,
(
score
>=
12000
?
12000
:
score
)
+
""
);
params
.
add
(
"score"
,
(
score
>=
12000
?
12000
:
score
)
+
""
);
params
.
add
(
"content"
,
"历史积分"
);
params
.
add
(
"content"
,
"历史积分"
);
HttpUtil
.
post
(
stoneUrl
+
"/user/logs/in2111"
,
params
);
HttpUtil
.
post
(
stoneUrl
+
"/user/logs/in2111"
,
params
);
}
}
...
@@ -165,7 +165,7 @@ public class DataImpl {
...
@@ -165,7 +165,7 @@ public class DataImpl {
//创建 用户积分数据
//创建 用户积分数据
int
isExists
=
stoneScoreUserMapper
.
selectCount
(
Wrappers
.
lambdaQuery
(
StoneScoreUser
.
class
).
eq
(
StoneScoreUser:
:
getUid
,
uid
));
int
isExists
=
stoneScoreUserMapper
.
selectCount
(
Wrappers
.
lambdaQuery
(
StoneScoreUser
.
class
).
eq
(
StoneScoreUser:
:
getUid
,
uid
));
if
(
isExists
<=
0
)
{
if
(
isExists
<=
0
)
{
StoneScoreUser
data
=
new
StoneScoreUser
();
StoneScoreUser
data
=
StoneScoreUser
.
getNew
();
data
.
setStatus
(
1
);
data
.
setStatus
(
1
);
data
.
setScoreId
(
IDGenerator
.
nextTimeId2
());
data
.
setScoreId
(
IDGenerator
.
nextTimeId2
());
data
.
setUid
(
uid
);
data
.
setUid
(
uid
);
...
@@ -184,7 +184,7 @@ public class DataImpl {
...
@@ -184,7 +184,7 @@ public class DataImpl {
//获取商品每日任务积分
//获取商品每日任务积分
String
resultData
=
HttpUtil
.
get
(
"http://mall.zhengzai.tv/admin/sumUserCost?user_id="
+
uid
,
null
);
String
resultData
=
HttpUtil
.
get
(
"http://mall.zhengzai.tv/admin/sumUserCost?user_id="
+
uid
,
null
);
int
goodsPrice
=
(
int
)
JSONObject
.
parseObject
(
resultData
).
get
(
"cost"
);
int
goodsPrice
=
(
int
)
JSONObject
.
parseObject
(
resultData
).
get
(
"cost"
);
score
+=
goodsPrice
;
score
+=
goodsPrice
;
//获取 关注摩登天空服务号
//获取 关注摩登天空服务号
if
(
getUnionIdByPhone
(
mobile
)
!=
null
)
{
if
(
getUnionIdByPhone
(
mobile
)
!=
null
)
{
...
@@ -220,7 +220,7 @@ public class DataImpl {
...
@@ -220,7 +220,7 @@ public class DataImpl {
if
(
isLog
<=
0
)
{
if
(
isLog
<=
0
)
{
MultiValueMap
<
String
,
String
>
params
=
CollectionUtil
.
linkedMultiValueMapStringString
();
MultiValueMap
<
String
,
String
>
params
=
CollectionUtil
.
linkedMultiValueMapStringString
();
params
.
add
(
"uid"
,
uid
);
params
.
add
(
"uid"
,
uid
);
params
.
add
(
"score"
,
(
score
>=
12000
?
12000
:
score
)
+
""
);
params
.
add
(
"score"
,
(
score
>=
12000
?
12000
:
score
)
+
""
);
params
.
add
(
"content"
,
"历史积分"
);
params
.
add
(
"content"
,
"历史积分"
);
HttpUtil
.
post
(
stoneUrl
+
"/user/logs/in2111"
,
params
);
HttpUtil
.
post
(
stoneUrl
+
"/user/logs/in2111"
,
params
);
}
}
...
@@ -240,7 +240,7 @@ public class DataImpl {
...
@@ -240,7 +240,7 @@ public class DataImpl {
int
scoreUse
=
0
;
int
scoreUse
=
0
;
for
(
StoneScoreLogs
item
:
list
)
{
for
(
StoneScoreLogs
item
:
list
)
{
//初始化 mongo
//初始化 mongo
StoneScoreLogs
logs
=
new
StoneScoreLogs
();
StoneScoreLogs
logs
=
StoneScoreLogs
.
getNew
();
logs
.
setLogsId
(
item
.
getLogsId
());
logs
.
setLogsId
(
item
.
getLogsId
());
logs
.
setContent
(
item
.
getContent
());
logs
.
setContent
(
item
.
getContent
());
logs
.
setReason
(
item
.
getReason
());
logs
.
setReason
(
item
.
getReason
());
...
...
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