package com.doumee.api;
|
|
import com.doumee.dao.admin.request.CollectionMediaSyncRequest;
|
import com.doumee.service.business.CollectionMediaSyncService;
|
import com.doumee.service.business.CollectionStationService;
|
import com.doumee.service.business.third.model.ApiResponse;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.Calendar;
|
import java.util.Date;
|
|
@Api(tags = "海康采集站定时器接口")
|
@Slf4j
|
@RestController
|
@RequestMapping("/timer/collectionStation")
|
public class HkCollectionStationTimerController extends BaseController {
|
|
@Autowired
|
private CollectionStationService collectionStationService;
|
@Autowired
|
private CollectionMediaSyncService collectionMediaSyncService;
|
|
@ApiOperation("定时同步采集站在线状态")
|
@PostMapping("/syncStations")
|
public ApiResponse<String> syncStations() {
|
log.info("定时任务：同步采集站状态");
|
return ApiResponse.success(collectionStationService.syncAllStations());
|
}
|
|
@ApiOperation("定时同步采集站媒体索引并批量下载")
|
@PostMapping("/syncMediaAndDownload")
|
public ApiResponse<String> syncMediaAndDownload() {
|
log.info("定时任务：同步采集站媒体索引");
|
CollectionMediaSyncRequest request = new CollectionMediaSyncRequest();
|
Calendar cal = Calendar.getInstance();
|
request.setEndTime(cal.getTime());
|
cal.add(Calendar.HOUR_OF_DAY, -24);
|
request.setStartTime(cal.getTime());
|
String syncResult = collectionMediaSyncService.syncMediaList(request);
|
String downloadResult = collectionMediaSyncService.batchDownload(request);
|
return ApiResponse.success(syncResult + "；" + downloadResult);
|
}
|
}
|
