| | |
| | | import com.iplatform.recvideo.VideoLoadInfo; |
| | | import com.iplatform.recvideo.VideoLoader; |
| | | import com.iplatform.recvideo.service.VideoLoaderServiceImpl; |
| | | import com.walker.connector.support.DatabaseConnector; |
| | | import com.walker.infrastructure.utils.DateUtils; |
| | | import com.walker.infrastructure.utils.NumberGenerator; |
| | | |
| | |
| | | public class DefaultVideoLoader extends VideoLoader { |
| | | |
| | | private VideoLoaderServiceImpl videoLoaderService; |
| | | |
| | | private DatabaseConnector databaseConnector = null; |
| | | |
| | | public void setDatabaseConnector(DatabaseConnector databaseConnector) { |
| | | this.databaseConnector = databaseConnector; |
| | | } |
| | | |
| | | public void setVideoLoaderService(VideoLoaderServiceImpl videoLoaderService) { |
| | | this.videoLoaderService = videoLoaderService; |
| | |
| | | |
| | | @Override |
| | | protected long acquireInitBatchId() { |
| | | return 0; |
| | | return 20210101; |
| | | } |
| | | |
| | | @Override |
| | | protected List<VideoLoadInfo> acquireLoadVideoFromDatabase(long nextBatchId) { |
| | | this.databaseConnector.queryForList("", new Object[]{nextBatchId}); |
| | | return null; |
| | | } |
| | | |