@@ -824,7 +824,7 @@ private void processGiftMoneyFlow(String wxid, String message, UserInteractionSt
|
|||||||
/**
|
/**
|
||||||
* 消毒柜部分的业务逻辑
|
* 消毒柜部分的业务逻辑
|
||||||
*/
|
*/
|
||||||
@Scheduled(fixedRate = 600000) // 每10分钟执行一次
|
@Scheduled(fixedRate = 60000) // 每分钟执行一次
|
||||||
public void cleanUpTimeoutStates() {
|
public void cleanUpTimeoutStates() {
|
||||||
LocalDateTime now = LocalDateTime.now();
|
LocalDateTime now = LocalDateTime.now();
|
||||||
redisTemplate.keys(INTERACTION_STATE_PREFIX + "*").forEach(key -> {
|
redisTemplate.keys(INTERACTION_STATE_PREFIX + "*").forEach(key -> {
|
||||||
@@ -1036,7 +1036,7 @@ private void handleUserInteraction(String fromWxid, String message) {
|
|||||||
// 6. 进入确认礼金步骤
|
// 6. 进入确认礼金步骤
|
||||||
state.setCurrentField("confirm");
|
state.setCurrentField("confirm");
|
||||||
try {
|
try {
|
||||||
Thread.sleep(10000);
|
Thread.sleep(5000);
|
||||||
} catch (InterruptedException ignored) {
|
} catch (InterruptedException ignored) {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user