package com.qianwen.mdc.collect.controller; import java.time.LocalDate; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import com.google.common.collect.Sets; import com.qianwen.core.tool.utils.Func; import com.qianwen.mdc.collect.cache.TimeSliceCache; import com.qianwen.mdc.collect.dto.CacheBuildDTO; @RestController public class JobTestController { private final Logger log = LoggerFactory.getLogger(this.getClass()); @Autowired private TimeSliceCache timeSliceCache; @GetMapping("/timecache") public Object stateagg(Long workstationId) { LocalDate targetDate = LocalDate.now();//.plusDays(1L); CacheBuildDTO cacheBuildDTO = CacheBuildDTO.builder().tenantIds(Sets.newHashSet(new String[]{"000000"})).targetDate(targetDate).build(); if (Func.isNotEmpty(cacheBuildDTO)) { timeSliceCache.build(cacheBuildDTO); } else { log.error("[生产日历切片缓存构建失败...],构建时间{},构建租户:{}", targetDate, "000000"); } return "1"; } }