|
@@ -6,7 +6,9 @@ import cn.seecoder.fdroidrepository.DataObject.Enum.ResultCode;
|
|
|
import cn.seecoder.fdroidrepository.DataObject.PO.AppInfoPO;
|
|
import cn.seecoder.fdroidrepository.DataObject.PO.AppInfoPO;
|
|
|
import cn.seecoder.fdroidrepository.DataObject.PO.BuildTaskPO;
|
|
import cn.seecoder.fdroidrepository.DataObject.PO.BuildTaskPO;
|
|
|
import cn.seecoder.fdroidrepository.DataObject.VO.BuildTaskCreateVO;
|
|
import cn.seecoder.fdroidrepository.DataObject.VO.BuildTaskCreateVO;
|
|
|
|
|
+import cn.seecoder.fdroidrepository.DataObject.VO.BuildTaskVO;
|
|
|
import cn.seecoder.fdroidrepository.DataObject.VO.Response;
|
|
import cn.seecoder.fdroidrepository.DataObject.VO.Response;
|
|
|
|
|
+import cn.seecoder.fdroidrepository.DataObject.VO.search.BuildTaskSearchVO;
|
|
|
import cn.seecoder.fdroidrepository.Mapper.AppInfoMapper;
|
|
import cn.seecoder.fdroidrepository.Mapper.AppInfoMapper;
|
|
|
import cn.seecoder.fdroidrepository.Mapper.BuildTaskMapper;
|
|
import cn.seecoder.fdroidrepository.Mapper.BuildTaskMapper;
|
|
|
import cn.seecoder.fdroidrepository.Pipeline.*;
|
|
import cn.seecoder.fdroidrepository.Pipeline.*;
|
|
@@ -26,6 +28,7 @@ import java.util.List;
|
|
|
import java.util.concurrent.LinkedBlockingQueue;
|
|
import java.util.concurrent.LinkedBlockingQueue;
|
|
|
import java.util.concurrent.ThreadPoolExecutor;
|
|
import java.util.concurrent.ThreadPoolExecutor;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
@Service
|
|
@Service
|
|
|
public class BuildServiceImpl implements BuildService {
|
|
public class BuildServiceImpl implements BuildService {
|
|
@@ -137,18 +140,25 @@ public class BuildServiceImpl implements BuildService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public Response getBuildTaskPage(Integer appId, Integer pageNum) {
|
|
|
|
|
- if (appId == null || pageNum == null || pageNum < 1) {
|
|
|
|
|
|
|
+ public Response search(BuildTaskSearchVO buildTaskSearchVO) {
|
|
|
|
|
+ if (buildTaskSearchVO == null) {
|
|
|
return Response.buildFailure(ResultCode.ILLEGAL_ARGUMENT.getCode(), ResultCode.ILLEGAL_ARGUMENT.getMessage());
|
|
return Response.buildFailure(ResultCode.ILLEGAL_ARGUMENT.getCode(), ResultCode.ILLEGAL_ARGUMENT.getMessage());
|
|
|
}
|
|
}
|
|
|
- return Response.buildSuccess(buildTaskMapper.selectByAppIdPage(appId, pageNum));
|
|
|
|
|
|
|
+ if (buildTaskSearchVO.getPageNum() != null) {
|
|
|
|
|
+ if (buildTaskSearchVO.getPageNum() < 1) {
|
|
|
|
|
+ return Response.buildFailure(ResultCode.ILLEGAL_ARGUMENT.getCode(), ResultCode.ILLEGAL_ARGUMENT.getMessage());
|
|
|
|
|
+ }
|
|
|
|
|
+ buildTaskSearchVO.setStart((buildTaskSearchVO.getPageNum() - 1) * buildTaskSearchVO.getPageSize());
|
|
|
|
|
+ }
|
|
|
|
|
+ List<BuildTaskPO> result = buildTaskMapper.search(buildTaskSearchVO);
|
|
|
|
|
+ return Response.buildSuccess(result.stream().map(BuildTaskVO::new).collect(Collectors.toList()));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public Response getBuildTaskCount(Integer appId) {
|
|
|
|
|
- if (appId == null) {
|
|
|
|
|
|
|
+ public Response searchCount(BuildTaskSearchVO buildTaskSearchVO) {
|
|
|
|
|
+ if (buildTaskSearchVO == null) {
|
|
|
return Response.buildFailure(ResultCode.ILLEGAL_ARGUMENT.getCode(), ResultCode.ILLEGAL_ARGUMENT.getMessage());
|
|
return Response.buildFailure(ResultCode.ILLEGAL_ARGUMENT.getCode(), ResultCode.ILLEGAL_ARGUMENT.getMessage());
|
|
|
}
|
|
}
|
|
|
- return Response.buildSuccess(buildTaskMapper.getCount(appId));
|
|
|
|
|
|
|
+ return Response.buildSuccess(buildTaskMapper.searchCount(buildTaskSearchVO));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|