diff --git a/src/main/java/com/peanut/modules/common/entity/MyUserEntity.java b/src/main/java/com/peanut/modules/common/entity/MyUserEntity.java index 4cbc89df..7c02da6c 100644 --- a/src/main/java/com/peanut/modules/common/entity/MyUserEntity.java +++ b/src/main/java/com/peanut/modules/common/entity/MyUserEntity.java @@ -57,7 +57,7 @@ public class MyUserEntity implements Serializable { */ private String password; /** - * 0-普通 1-vip + * 0-普通 1-vip //0-普通 1超级vip 2医学vip 3国学vip */ private String vip; /** diff --git a/src/main/java/com/peanut/modules/medical/service/impl/CourseServiceImpl.java b/src/main/java/com/peanut/modules/medical/service/impl/CourseServiceImpl.java index c35a66da..ad197f99 100644 --- a/src/main/java/com/peanut/modules/medical/service/impl/CourseServiceImpl.java +++ b/src/main/java/com/peanut/modules/medical/service/impl/CourseServiceImpl.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.github.yulichang.wrapper.MPJLambdaWrapper; +import com.peanut.common.utils.ShiroUtils; import com.peanut.modules.common.dao.*; import com.peanut.modules.common.entity.*; import com.peanut.modules.common.to.ParamTo; @@ -117,21 +118,26 @@ public class CourseServiceImpl extends ServiceImpl impl @Override public List getCourseExpire(Map param) { - MPJLambdaWrapper wrapper = new MPJLambdaWrapper<>(); - wrapper.distinct(); - wrapper.leftJoin(CourseCatalogueEntity.class,CourseCatalogueEntity::getCourseId,CourseEntity::getId); - //关掉本次查询del_flg = 0的条件,查询过期课程 - wrapper.disableSubLogicDel().rightJoin(UserCourseBuyEntity.class,UserCourseBuyEntity::getCatalogueId,CourseCatalogueEntity::getId); - wrapper.rightJoin(CourseToMedicine.class,CourseToMedicine::getCourseId,CourseEntity::getId); - wrapper.eq(UserCourseBuyEntity::getUserId,param.get("userId")); - wrapper.eq(UserCourseBuyEntity::getDelFlag,-1); - wrapper.selectAll(CourseEntity.class); - wrapper.selectAs(CourseCatalogueEntity::getId,"catalogueId"); - wrapper.selectAs(CourseCatalogueEntity::getTitle,"catalogueTitle"); - wrapper.orderByAsc(CourseEntity::getSort); - wrapper.orderByAsc(CourseCatalogueEntity::getSort); - List courseEntities = this.getBaseMapper().selectMaps(wrapper); - return courseEntities; + String vip = ShiroUtils.getUser().getVip(); + if ("0".equals(vip)||"3".equals(vip)){ + MPJLambdaWrapper wrapper = new MPJLambdaWrapper<>(); + wrapper.distinct(); + wrapper.leftJoin(CourseCatalogueEntity.class,CourseCatalogueEntity::getCourseId,CourseEntity::getId); + //关掉本次查询del_flg = 0的条件,查询过期课程 + wrapper.disableSubLogicDel().rightJoin(UserCourseBuyEntity.class,UserCourseBuyEntity::getCatalogueId,CourseCatalogueEntity::getId); + wrapper.rightJoin(CourseToMedicine.class,CourseToMedicine::getCourseId,CourseEntity::getId); + wrapper.eq(UserCourseBuyEntity::getUserId,param.get("userId")); + wrapper.eq(UserCourseBuyEntity::getDelFlag,-1); + wrapper.selectAll(CourseEntity.class); + wrapper.selectAs(CourseCatalogueEntity::getId,"catalogueId"); + wrapper.selectAs(CourseCatalogueEntity::getTitle,"catalogueTitle"); + wrapper.orderByAsc(CourseEntity::getSort); + wrapper.orderByAsc(CourseCatalogueEntity::getSort); + List courseEntities = this.getBaseMapper().selectMaps(wrapper); + return courseEntities; + }else { + return null; + } } @@ -152,6 +158,8 @@ public class CourseServiceImpl extends ServiceImpl impl courseEntities = toMedicineDao.selectJoinList(CourseEntity.class, wrapper); if(courseEntities!=null&&courseEntities.size()>0){ for (CourseEntity co:courseEntities){ + int i = studyingDao.selectCount(new LambdaQueryWrapper().eq(UserCourseStudying::getCourseId,co.getId()).eq(UserCourseStudying::getUserId,user.getId())); + co.setIsStudying(i>0?1:0); List courseCatalogueEntities = courseCatalogueDao.selectList(new LambdaQueryWrapper().eq(CourseCatalogueEntity::getCourseId, co.getId()).orderByAsc(CourseCatalogueEntity::getSort)); co.setCourseCatalogueEntityList(courseCatalogueEntities); } @@ -170,6 +178,8 @@ public class CourseServiceImpl extends ServiceImpl impl courseEntities = courseBuyDao.selectJoinList(CourseEntity.class, wrapper); if(courseEntities!=null&&courseEntities.size()>0){ for (CourseEntity co:courseEntities){ + int i = studyingDao.selectCount(new LambdaQueryWrapper().eq(UserCourseStudying::getCourseId,co.getId()).eq(UserCourseStudying::getUserId,user.getId())); + co.setIsStudying(i>0?1:0); List courseCatalogueEntities = courseCatalogueDao.selectList( new MPJLambdaWrapper() .selectAll(CourseCatalogueEntity.class) diff --git a/src/main/java/com/peanut/modules/sociology/service/impl/CourseServiceImpl.java b/src/main/java/com/peanut/modules/sociology/service/impl/CourseServiceImpl.java index c3de651c..ac0440a7 100644 --- a/src/main/java/com/peanut/modules/sociology/service/impl/CourseServiceImpl.java +++ b/src/main/java/com/peanut/modules/sociology/service/impl/CourseServiceImpl.java @@ -24,8 +24,6 @@ public class CourseServiceImpl extends ServiceImpl impl @Autowired private MyUserService userService; @Autowired - private UserToCourseDao userToCourseDao; - @Autowired private CourseToSociologyDao courseToSociologyDao; @Autowired private CourseCatalogueDao courseCatalogueDao; @@ -293,21 +291,26 @@ public class CourseServiceImpl extends ServiceImpl impl @Override public List getCourseExpire(Map param) { - MPJLambdaWrapper wrapper = new MPJLambdaWrapper<>(); - wrapper.distinct(); - wrapper.leftJoin(CourseCatalogueEntity.class,CourseCatalogueEntity::getCourseId,CourseEntity::getId); - //关掉本次查询del_flg = 0的条件,查询过期课程 - wrapper.disableSubLogicDel().rightJoin(UserCourseBuyEntity.class,UserCourseBuyEntity::getCatalogueId,CourseCatalogueEntity::getId); - wrapper.rightJoin(CourseToSociologyEntity.class,CourseToSociologyEntity::getCourseId,CourseEntity::getId); - wrapper.eq(UserCourseBuyEntity::getUserId,param.get("userId")); - wrapper.eq(UserCourseBuyEntity::getDelFlag,-1); - wrapper.selectAll(CourseEntity.class); - wrapper.selectAs(CourseCatalogueEntity::getId,"catalogueId"); - wrapper.selectAs(CourseCatalogueEntity::getTitle,"catalogueTitle"); - wrapper.orderByAsc(CourseEntity::getSort); - wrapper.orderByAsc(CourseCatalogueEntity::getSort); - List courseEntities = this.getBaseMapper().selectMaps(wrapper); - return courseEntities; + String vip = ShiroUtils.getUser().getVip(); + if ("0".equals(vip)||"2".equals(vip)){ + MPJLambdaWrapper wrapper = new MPJLambdaWrapper<>(); + wrapper.distinct(); + wrapper.leftJoin(CourseCatalogueEntity.class,CourseCatalogueEntity::getCourseId,CourseEntity::getId); + //关掉本次查询del_flg = 0的条件,查询过期课程 + wrapper.disableSubLogicDel().rightJoin(UserCourseBuyEntity.class,UserCourseBuyEntity::getCatalogueId,CourseCatalogueEntity::getId); + wrapper.rightJoin(CourseToSociologyEntity.class,CourseToSociologyEntity::getCourseId,CourseEntity::getId); + wrapper.eq(UserCourseBuyEntity::getUserId,param.get("userId")); + wrapper.eq(UserCourseBuyEntity::getDelFlag,-1); + wrapper.selectAll(CourseEntity.class); + wrapper.selectAs(CourseCatalogueEntity::getId,"catalogueId"); + wrapper.selectAs(CourseCatalogueEntity::getTitle,"catalogueTitle"); + wrapper.orderByAsc(CourseEntity::getSort); + wrapper.orderByAsc(CourseCatalogueEntity::getSort); + List courseEntities = this.getBaseMapper().selectMaps(wrapper); + return courseEntities; + }else { + return null; + } } @@ -348,6 +351,8 @@ public class CourseServiceImpl extends ServiceImpl impl courseEntities = userCourseBuyDao.selectJoinList(CourseEntity.class, wrapper); if(courseEntities!=null&&courseEntities.size()>0){ for (CourseEntity co:courseEntities){ + int i = studyingDao.selectCount(new LambdaQueryWrapper().eq(UserCourseStudying::getCourseId,co.getId()).eq(UserCourseStudying::getUserId,user.getId())); + co.setIsStudying(i>0?1:0); List courseCatalogueEntities = courseCatalogueDao.selectList( new MPJLambdaWrapper() .selectAll(CourseCatalogueEntity.class)