2022年7月22日18:32:18 写入账号时候加强逻辑判断

王明元
1 parent 13ffb669
Showing 1 changed file with 28 additions and 10 deletions
src/main/java/cn/fw/freya/service/crawl/impl/Common.java
@@ -11,6 +11,7 @@ import cn.fw.freya.model.data.ResponseReceived;
 import cn.fw.freya.model.data.pool.LivePool;
 import cn.fw.freya.model.data.pool.VideoPool;
 import cn.fw.freya.model.dto.rpc.ReportAccountDto;
+import cn.fw.freya.utils.DateUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import lombok.RequiredArgsConstructor;
@@ -37,6 +38,9 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import java.io.IOException;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
 import java.util.*;
 import java.util.logging.Level;
 import java.util.stream.Collectors;
@@ -329,16 +333,30 @@ public class Common {
         Account account = accountDao.findByAccountNoAndType(accountNo, type);
         if (Objects.nonNull(account))
             return;
-        accountDao.save(Account.builder()
-                .cookiesStatus(true)
-                .accountNo(accountNo)
-                .type(type)
-                .fansCnt(null)
-                .accountName(null)
-                .reportDate(null)
-                .done(false)
-                .build()
-        );// 不存在, 则保存该账号
+        Date now = new Date();
+        Date date = DateUtil.localDateTime2Date(LocalDateTime.of(LocalDate.now(), LocalTime.of(12, 30, 0)));
+        Account waitSaveAccount;
+        if (now.compareTo(date) >= 0)// 当前时间>=12:30
+            waitSaveAccount = Account.builder()
+                    .cookiesStatus(true)
+                    .accountNo(accountNo)
+                    .type(type)
+                    .fansCnt(null)
+                    .accountName(null)
+                    .reportDate(null)
+                    .done(false)
+                    .build();
+        else
+            waitSaveAccount = Account.builder()
+                    .cookiesStatus(true)
+                    .accountNo(accountNo)
+                    .type(type)
+                    .fansCnt(0)
+                    .accountName(null)
+                    .reportDate(now)
+                    .done(true)
+                    .build();
+        accountDao.save(waitSaveAccount);// 不存在, 则保存该账号
     }
 }