记得上下班打卡 | 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
1f490023
Commit
1f490023
authored
Mar 25, 2022
by
zhengfuxin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
开发定时
parent
66f3d2d0
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
47 additions
and
1 deletion
+47
-1
RedisUtil.java
...java/com.liquidnet.common.cache/redis/util/RedisUtil.java
+1
-1
FeignPlatformSmileTaskClient.java
...ice/feign/platform/task/FeignPlatformSmileTaskClient.java
+24
-0
SweetTaskHandler.java
...idnet/service/executor/main/handler/SweetTaskHandler.java
+22
-0
No files found.
liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisUtil.java
View file @
1f490023
...
@@ -34,7 +34,7 @@ public final class RedisUtil extends AbstractRedisUtil{
...
@@ -34,7 +34,7 @@ public final class RedisUtil extends AbstractRedisUtil{
public
static
void
main
(
String
[]
args
)
{
public
static
void
main
(
String
[]
args
)
{
String
[]
keys
=
{
String
[]
keys
=
{
"smile:user:validate"
,
"smile:user:validate
王维110105198310241133
"
,
};
};
for
(
String
key
:
keys
)
{
for
(
String
key
:
keys
)
{
long
value
=
key
.
hashCode
();
long
value
=
key
.
hashCode
();
...
...
liquidnet-bus-feign/liquidnet-api-feign-platform/src/main/java/com/liquidnet/service/feign/platform/task/FeignPlatformSmileTaskClient.java
0 → 100644
View file @
1f490023
package
com
.
liquidnet
.
service
.
feign
.
platform
.
task
;
import
com.liquidnet.service.base.ResponseDto
;
import
feign.hystrix.FallbackFactory
;
import
org.springframework.cloud.openfeign.FeignClient
;
import
org.springframework.stereotype.Component
;
import
org.springframework.web.bind.annotation.PostMapping
;
@Component
@FeignClient
(
name
=
"liquidnet-service-platform"
,
contextId
=
"FeignPlatformGoblinTaskClient"
,
path
=
"platform"
,
url
=
"${liquidnet.service.platform.url}"
,
fallback
=
FallbackFactory
.
Default
.
class
)
public
interface
FeignPlatformSmileTaskClient
{
@PostMapping
(
"sell/sellData"
)
public
ResponseDto
<
Boolean
>
sellData
();
@PostMapping
(
"sell/commissionData"
)
public
ResponseDto
<
Boolean
>
commissionData
();
}
liquidnet-bus-service/liquidnet-service-executor-all/liquidnet-service-executor-main/src/main/java/com/liquidnet/service/executor/main/handler/SweetTaskHandler.java
View file @
1f490023
package
com
.
liquidnet
.
service
.
executor
.
main
.
handler
;
package
com
.
liquidnet
.
service
.
executor
.
main
.
handler
;
import
com.liquidnet.service.feign.platform.task.FeignPlatformSmileTaskClient
;
import
com.liquidnet.service.feign.sweet.task.FeignSweetTaskClient
;
import
com.liquidnet.service.feign.sweet.task.FeignSweetTaskClient
;
import
com.xxl.job.core.context.XxlJobHelper
;
import
com.xxl.job.core.context.XxlJobHelper
;
import
com.xxl.job.core.handler.annotation.XxlJob
;
import
com.xxl.job.core.handler.annotation.XxlJob
;
...
@@ -19,6 +20,8 @@ public class SweetTaskHandler {
...
@@ -19,6 +20,8 @@ public class SweetTaskHandler {
@Autowired
@Autowired
private
FeignSweetTaskClient
feignSweetTaskClient
;
private
FeignSweetTaskClient
feignSweetTaskClient
;
private
FeignPlatformSmileTaskClient
feignPlatformSmileTaskClient
;
@XxlJob
(
value
=
"sev-sweet:drawLuckAdd"
)
@XxlJob
(
value
=
"sev-sweet:drawLuckAdd"
)
public
void
drawLuckAdd
()
{
public
void
drawLuckAdd
()
{
try
{
try
{
...
@@ -44,4 +47,23 @@ public class SweetTaskHandler {
...
@@ -44,4 +47,23 @@ public class SweetTaskHandler {
XxlJobHelper
.
handleFail
();
XxlJobHelper
.
handleFail
();
}
}
}
}
@XxlJob
(
value
=
"sev-smile:sellData"
)
public
void
sellDataHandler
()
{
try
{
XxlJobHelper
.
handleSuccess
(
"结果:"
+
feignPlatformSmileTaskClient
.
sellData
().
toJson
());
}
catch
(
Exception
e
)
{
XxlJobHelper
.
log
(
e
);
XxlJobHelper
.
handleFail
();
}
}
@XxlJob
(
value
=
"sev-smile:commissionData"
)
public
void
sellcommissionDataHandler
()
{
try
{
XxlJobHelper
.
handleSuccess
(
"结果:"
+
feignPlatformSmileTaskClient
.
commissionData
().
toJson
());
}
catch
(
Exception
e
)
{
XxlJobHelper
.
log
(
e
);
XxlJobHelper
.
handleFail
();
}
}
}
}
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