diff --git a/servers/boe-server-all/src/main/java/com/xboe/school/study/api/StudyCourseESApi.java b/servers/boe-server-all/src/main/java/com/xboe/school/study/api/StudyCourseESApi.java index f03003a4..95f46cd7 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/school/study/api/StudyCourseESApi.java +++ b/servers/boe-server-all/src/main/java/com/xboe/school/study/api/StudyCourseESApi.java @@ -1,10 +1,13 @@ package com.xboe.school.study.api; import java.io.IOException; +import java.time.LocalDateTime; import java.time.ZoneOffset; +import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; @@ -42,7 +45,7 @@ public class StudyCourseESApi extends ApiBaseController{ return error("无ES的实现",""); } try { - PageList rs=search.search(page.getPageIndex(),page.getPageSize(), dto); + PageList rs=search.search(page.getStartRow(),page.getPageSize(), dto); return success(rs); }catch(Exception e) { log.error("查询报名学习ES失败",e); @@ -60,7 +63,7 @@ public class StudyCourseESApi extends ApiBaseController{ return success(true); }catch(Exception e) { log.error("创建索引失败",e); - return error("创建索引失败",e.getMessage(),false); + return error("创建索引失败:"+e.getMessage(),e.getMessage(),false); } } @@ -75,7 +78,25 @@ public class StudyCourseESApi extends ApiBaseController{ return success(true); }catch(Exception e) { log.error("删除索引失败",e); - return error("删除索引失败",e.getMessage(),false); + return error("删除索引失败:"+e.getMessage(),e.getMessage(),false); + } + } + + @PostMapping("/delete-by-esid") + public JsonResponse deleteByDocId(String esid){ + //前端一定要二次询问 + if(search==null) { + return error("无ES的实现","",false); + } + if(StringUtils.isBlank(esid)) { + return badRequest("未指定ESId"); + } + try { + search.removeByDocId(esid); + return success(true); + }catch(Exception e) { + log.error("删除ES学习课程错误",e); + return error("删除失败:"+e.getMessage(),e.getMessage(),false); } } @@ -88,6 +109,7 @@ public class StudyCourseESApi extends ApiBaseController{ if(search==null) { return error("无ES的实现","",false); } + LocalDateTime now=LocalDateTime.now(); //按分页初始化 int pageIndex=1; int pageSize=1000; @@ -106,7 +128,11 @@ public class StudyCourseESApi extends ApiBaseController{ dto.setCourseType(sc.getCourseType()); dto.setProgress(sc.getProgress()==null? 0:sc.getProgress().intValue()); dto.setSource(2);//固定值,新系统 - dto.setStartTime(sc.getStartTime().toEpochSecond(ZoneOffset.of("+8"))); + if(sc.getStartTime()!=null) { + dto.setStartTime(sc.getStartTime().toEpochSecond(ZoneOffset.of("+8"))); + }else { + dto.setStartTime(now.toEpochSecond(ZoneOffset.of("+8"))); + } dto.setStatus(sc.getStatus()); try { search.publishOrUpdate(dto, null); diff --git a/servers/boe-server-all/src/main/java/com/xboe/school/study/service/IStudyCourseService.java b/servers/boe-server-all/src/main/java/com/xboe/school/study/service/IStudyCourseService.java index 9a80d241..3a7f04e7 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/school/study/service/IStudyCourseService.java +++ b/servers/boe-server-all/src/main/java/com/xboe/school/study/service/IStudyCourseService.java @@ -36,6 +36,14 @@ public interface IStudyCourseService { */ StudyCourse findByCourseIdAndAid(String courseId,String aid); + /** + * 为ES初始化的处理 + * @param pageIndex + * @param pageSize + * @return + */ + PageList findByES(int pageIndex,int pageSize) throws Exception; + /** * 分页查询课程学习记录,用户的课程学习记录 * @param pageIndex diff --git a/servers/boe-server-all/src/main/java/com/xboe/school/study/service/impl/StudyCourseServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/school/study/service/impl/StudyCourseServiceImpl.java index 73ee8c17..74523231 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/school/study/service/impl/StudyCourseServiceImpl.java +++ b/servers/boe-server-all/src/main/java/com/xboe/school/study/service/impl/StudyCourseServiceImpl.java @@ -666,4 +666,28 @@ public class StudyCourseServiceImpl implements IStudyCourseService{ return sc; } + @Override + public PageList findByES(int pageIndex, int pageSize) throws Exception { + QueryBuilder query=QueryBuilder.from(StudyCourse.class.getSimpleName()+" sc,"+ Course.class.getSimpleName()+" c"); + query.addField("sc"); + query.addField("c.coverImg"); + query.setPageIndex(pageIndex); + query.setPageSize(pageSize); + query.addFilter(FieldFilters.eqField("sc.courseId","c.id")); + query.addFilter(FieldFilters.eq("c.enabled",true)); + query.addFilter(FieldFilters.eq("c.deleted",false)); + List rslist=new ArrayList(); + PageList list=studyCourseDao.findPageFields(query.builder()); + for(Object[] objs : list.getList()) { + StudyCourse sc=(StudyCourse)objs[0]; + sc.setCourseImage((String)objs[1]); + rslist.add(sc); + } + PageList rs=new PageList(); + rs.setCount(list.getCount()); + rs.setPageSize(pageSize); + rs.setList(rslist); + return rs; + } + }