|
@@ -16,9 +16,9 @@ import shop.alien.mapper.second.SecondTradeRecordMapper;
|
|
import shop.alien.store.config.BaseRedisService;
|
|
import shop.alien.store.config.BaseRedisService;
|
|
import shop.alien.store.config.WebSocketProcess;
|
|
import shop.alien.store.config.WebSocketProcess;
|
|
import shop.alien.store.service.*;
|
|
import shop.alien.store.service.*;
|
|
|
|
+import shop.alien.store.util.ali.AliApi;
|
|
import shop.alien.util.common.AlipayTradeRefund;
|
|
import shop.alien.util.common.AlipayTradeRefund;
|
|
import shop.alien.util.common.DateUtils;
|
|
import shop.alien.util.common.DateUtils;
|
|
-import shop.alien.store.util.ali.AliApi;
|
|
|
|
|
|
|
|
import java.math.BigDecimal;
|
|
import java.math.BigDecimal;
|
|
import java.math.RoundingMode;
|
|
import java.math.RoundingMode;
|
|
@@ -372,9 +372,9 @@ public class ScheduledTask {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 每五秒从redis中读取已读的消息id 并将数据库设为已读
|
|
|
|
|
|
+ * 每分钟从redis中读取已读的消息id 并将数据库设为已读
|
|
*/
|
|
*/
|
|
- @Scheduled(cron = "*/5 * * * * ?")
|
|
|
|
|
|
+ @Scheduled(cron = "0 * * * * ?")
|
|
public void readMessage() {
|
|
public void readMessage() {
|
|
try {
|
|
try {
|
|
if (CollectionUtil.isEmpty(baseRedisService.getList("readMessageIdKey"))) return;
|
|
if (CollectionUtil.isEmpty(baseRedisService.getList("readMessageIdKey"))) return;
|