修改bug
This commit is contained in:
@@ -8,6 +8,7 @@ import com.njcn.dataProcess.param.FullRecallMessage;
|
||||
import com.njcn.message.message.RecallMessage;
|
||||
import com.njcn.system.timer.TimerTaskRunner;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.log4j.Log4j;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.time.LocalDate;
|
||||
@@ -22,6 +23,7 @@ import java.time.LocalDateTime;
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor
|
||||
|
||||
public class DataRecallHourTaskRunner implements TimerTaskRunner {
|
||||
|
||||
private final DataRecallFeignClient dataRecallFeignClient;
|
||||
@@ -34,7 +36,8 @@ public class DataRecallHourTaskRunner implements TimerTaskRunner {
|
||||
FullRecallMessage baseParam = new FullRecallMessage();
|
||||
baseParam.setReCallStartTime(LocalDateTime.now().withMinute(0).withSecond(0).withNano(0).minusHours(1));
|
||||
baseParam.setReCallEndTime(LocalDateTime.now().withMinute(0).withSecond(0).withNano(0));
|
||||
// dataRecallFeignClient.fullHourRecall(baseParam);
|
||||
|
||||
dataRecallFeignClient.fullHourRecall(baseParam);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user