perf:场地订阅
This commit is contained in:
@@ -17,6 +17,8 @@ import org.apache.commons.collections4.CollectionUtils;
|
|||||||
import org.apache.commons.collections4.MapUtils;
|
import org.apache.commons.collections4.MapUtils;
|
||||||
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.StringUtils;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
import org.springframework.web.bind.annotation.GetMapping;
|
||||||
|
import org.springframework.web.bind.annotation.RestController;
|
||||||
|
|
||||||
import java.time.LocalDate;
|
import java.time.LocalDate;
|
||||||
import java.util.Comparator;
|
import java.util.Comparator;
|
||||||
@@ -32,6 +34,7 @@ import java.util.stream.Collectors;
|
|||||||
*/
|
*/
|
||||||
@Component
|
@Component
|
||||||
@Slf4j
|
@Slf4j
|
||||||
|
@RestController
|
||||||
@RequiredArgsConstructor
|
@RequiredArgsConstructor
|
||||||
public class JtVenuePickTask {
|
public class JtVenuePickTask {
|
||||||
|
|
||||||
@@ -42,6 +45,7 @@ public class JtVenuePickTask {
|
|||||||
|
|
||||||
|
|
||||||
@XxzJob(name = "jtVenuePickTask")
|
@XxzJob(name = "jtVenuePickTask")
|
||||||
|
@GetMapping("jtVenuePickTask")
|
||||||
public void handler() {
|
public void handler() {
|
||||||
log.info("江体小程序场地捡漏,time:{}", System.currentTimeMillis());
|
log.info("江体小程序场地捡漏,time:{}", System.currentTimeMillis());
|
||||||
|
|
||||||
@@ -69,6 +73,7 @@ public class JtVenuePickTask {
|
|||||||
.filter(VenueInfoUtils::get8210VenueInfo)
|
.filter(VenueInfoUtils::get8210VenueInfo)
|
||||||
.filter(item -> StringUtils.equals(item.getContacts(), "0")).toList();
|
.filter(item -> StringUtils.equals(item.getContacts(), "0")).toList();
|
||||||
if (CollectionUtils.isEmpty(sitePositionLists)) {
|
if (CollectionUtils.isEmpty(sitePositionLists)) {
|
||||||
|
log.info("目前没有可以捡漏的场地");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
Map<String, List<VenueInfoDO>> map = sitePositionLists.stream().map(item -> {
|
Map<String, List<VenueInfoDO>> map = sitePositionLists.stream().map(item -> {
|
||||||
|
|||||||
Reference in New Issue
Block a user