diff --git a/src/main/java/cn/fw/freya/service/crawl/impl/Common.java b/src/main/java/cn/fw/freya/service/crawl/impl/Common.java index f9a80c7..28c510e 100644 --- a/src/main/java/cn/fw/freya/service/crawl/impl/Common.java +++ b/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);// 不存在, 则保存该账号 } }