管乐迷新需求一大堆

mec-biz/src/main/java/com/ym/mec/biz/dal/dao/CloudTeacherOrderDao.java

@@ -105,4 +105,7 @@ public interface CloudTeacherOrderDao extends BaseDAO<Long, CloudTeacherOrder> {
     List<Mapper> findUserNameByOrderId(@Param("platformOrderId")Integer platformOrderId);
 
     void batchInsert(@Param("bean") CloudTeacherOrder cloudTeacherOrder, @Param("userIds") List<Integer> userIds);
+
+    //获取待激活学员数
+    List<Map<Integer, Integer>> getWaitActivateMap(@Param("organIds") List<Integer> organIds);
 }

mec-biz/src/main/java/com/ym/mec/biz/dal/dao/StudentDao.java

@@ -213,9 +213,10 @@ public interface StudentDao extends com.ym.mec.common.dal.BaseDAO<Integer, Stude
     
     List<IndexCloudStudyListDto> getCloudStudyStudentOverViewList(@Param("organIds") List<Integer> organIds);
 
-    List<IndexCloudStudyListDto> getCloudStudyStudentOverViewList1(@Param("organIds") List<Integer> organIds);
+    List<IndexCloudStudySumDto> getCloudStudyStudentOverViewList1(@Param("organIds") List<Integer> organIds);
     
     List<Mapper> getOrganActiveCloudStudyStudentNum(@Param("organIds") List<Integer> organIds, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
+    List<Map<Integer,Integer>> getOrganActiveCloudStudyStudentNum1(@Param("organIds") List<Integer> organIds, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
     
     List<Mapper> getOrganCloudTeacherStudentNum(@Param("organIds") List<Integer> organIds);
 
@@ -347,4 +348,7 @@ public interface StudentDao extends com.ym.mec.common.dal.BaseDAO<Integer, Stude
 
     //统计训练时长
     List<CloudTeacherSumDto> cloudTeacherSum(@Param("queryInfo") StudentCourseConsumerQueryInfo queryInfo);
+
+    //统计重复购买人数
+    List<Map<Integer,Integer>> getAgainBuyNum(@Param("organIds") List<Integer> organIds);
 }

mec-biz/src/main/java/com/ym/mec/biz/dal/dao/StudentStatisticsDao.java

@@ -80,8 +80,14 @@ public interface StudentStatisticsDao extends BaseDAO<Integer, StudentStatistics
     List<StudentCourseConsumerSumDto> queryCourseConsumerSum(@Param("queryInfo") StudentCourseConsumerQueryInfo queryInfo);
 
     //获取实际课耗学员详情列表
-    List<StudentCourseConsumerDetailDto> queryCourseConsumerDetail(@Param("queryInfo") StudentCourseConsumerQueryInfo queryInfo);
+    List<StudentCourseConsumerDetailDto> queryCourseConsumerDetail(Map<String, Object> params);
+
+    //获取实际课耗学员详情列表
+    int countCourseConsumerDetail(Map<String, Object> params);
+
+    //获取预计课耗学员详情列表
+    List<StudentCourseConsumerDetailDto> queryPreCourseConsumerDetail(Map<String, Object> params);
 
     //获取预计课耗学员详情列表
-    List<StudentCourseConsumerDetailDto> queryPreCourseConsumerDetail(@Param("queryInfo") StudentCourseConsumerQueryInfo queryInfo);
+    int countPreCourseConsumerDetail(Map<String, Object> params);
 }

mec-biz/src/main/java/com/ym/mec/biz/dal/dto/CloudStudyStudentDataDto.java

@@ -47,6 +47,39 @@ public class CloudStudyStudentDataDto {
     @ApiModelProperty("云教练新增人数")
     private int newCloudStudyStudentNum;
 
+    @ApiModelProperty("重复购买云教练的用户")
+    private int againBuyNum;
+
+    //重复购买率
+    private double againBuyRate;
+
+    //购买率
+    private double buyRate;
+
+    public double getAgainBuyRate() {
+        return againBuyRate;
+    }
+
+    public void setAgainBuyRate(double againBuyRate) {
+        this.againBuyRate = againBuyRate;
+    }
+
+    public double getBuyRate() {
+        return buyRate;
+    }
+
+    public void setBuyRate(double buyRate) {
+        this.buyRate = buyRate;
+    }
+
+    public int getAgainBuyNum() {
+        return againBuyNum;
+    }
+
+    public void setAgainBuyNum(int againBuyNum) {
+        this.againBuyNum = againBuyNum;
+    }
+
     public Integer getOrganId() {
         return organId;
     }

mec-biz/src/main/java/com/ym/mec/biz/dal/dto/IndexCloudStudySumDto.java

@@ -5,21 +5,36 @@ public class IndexCloudStudySumDto {
 	private Integer organId;
 	
 	private String organName;
-	
+
+	//在读学员数
 	private int totalStudentNum;
-	
-	private int effectiveStudentNum;
-	
+
+	//会员总数
 	private int vipStudentNum;
-	
+
+	//会员人数占比
 	private double vipStudentRate;
-	
+
+	//生效中的学员数
 	private int effectiveVipStudentNum;
-	
+
+	//待激活学员数
 	private int waitActivateVipStudentNum;
-	
+
+	//活跃人数
 	private int activeStudentNum;
 
+	//重复购买人数
+	private int againBuyNum;
+
+	public int getAgainBuyNum() {
+		return againBuyNum;
+	}
+
+	public void setAgainBuyNum(int againBuyNum) {
+		this.againBuyNum = againBuyNum;
+	}
+
 	public Integer getOrganId() {
 		return organId;
 	}
@@ -44,14 +59,6 @@ public class IndexCloudStudySumDto {
 		this.totalStudentNum = totalStudentNum;
 	}
 
-	public int getEffectiveStudentNum() {
-		return effectiveStudentNum;
-	}
-
-	public void setEffectiveStudentNum(int effectiveStudentNum) {
-		this.effectiveStudentNum = effectiveStudentNum;
-	}
-
 	public int getVipStudentNum() {
 		return vipStudentNum;
 	}

mec-biz/src/main/java/com/ym/mec/biz/dal/page/StudentCourseConsumerQueryInfo.java

@@ -1,8 +1,9 @@
 package com.ym.mec.biz.dal.page;
 
+import com.ym.mec.common.page.QueryInfo;
 import io.swagger.annotations.ApiModelProperty;
 
-public class StudentCourseConsumerQueryInfo{
+public class StudentCourseConsumerQueryInfo extends QueryInfo {
 
     @ApiModelProperty(value = "分部")
     private String organId;

mec-biz/src/main/java/com/ym/mec/biz/service/StudentCourseConsumerService.java

@@ -4,22 +4,22 @@ import com.ym.mec.biz.dal.dto.StudentCourseConsumerDetailDto;
 import com.ym.mec.biz.dal.dto.StudentCourseConsumerDto;
 import com.ym.mec.biz.dal.dto.StudentCourseConsumerSumDto;
 import com.ym.mec.biz.dal.page.StudentCourseConsumerQueryInfo;
+import com.ym.mec.common.page.PageInfo;
 
 import java.util.List;
 
 public interface StudentCourseConsumerService{
-
     //实际课耗列表
     List<StudentCourseConsumerDto> queryCourseConsumer(StudentCourseConsumerQueryInfo queryInfo);
 
     //实际课耗学员详情列表
-    List<StudentCourseConsumerDetailDto> queryCourseConsumerDetail(StudentCourseConsumerQueryInfo queryInfo);
+    PageInfo<StudentCourseConsumerDetailDto> queryCourseConsumerDetail(StudentCourseConsumerQueryInfo queryInfo);
 
     //预计课耗列表
     List<StudentCourseConsumerDto> queryPreCourseConsumer(StudentCourseConsumerQueryInfo queryInfo);
 
     //预计课耗学员详情列表
-    List<StudentCourseConsumerDetailDto> queryPreCourseConsumerDetail(StudentCourseConsumerQueryInfo queryInfo);
+    PageInfo<StudentCourseConsumerDetailDto> queryPreCourseConsumerDetail(StudentCourseConsumerQueryInfo queryInfo);
 
     //课耗统计
     List<StudentCourseConsumerSumDto> queryCourseConsumerSum(StudentCourseConsumerQueryInfo queryInfo);

mec-biz/src/main/java/com/ym/mec/biz/service/StudentService.java

@@ -195,5 +195,5 @@ public interface StudentService extends BaseService<Integer, Student> {
     //统计训练时长
     List<CloudTeacherSumDto> cloudTeacherSum(StudentCourseConsumerQueryInfo queryInfo);
 
-    List<IndexCloudStudyListDto> getCloudStudyStudentOverViewList1(String organIds);
+    List<IndexCloudStudySumDto> getCloudStudyStudentOverViewList1(List<Integer> organIdsList);
 }

mec-biz/src/main/java/com/ym/mec/biz/service/impl/ExportServiceImpl.java

@@ -184,6 +184,8 @@ public class ExportServiceImpl implements ExportService {
     @Autowired
     private StudentCourseConsumerService studentCourseConsumerService;
     @Autowired
+    private StudentStatisticsDao studentStatisticsDao;
+    @Autowired
     private StudentTeacherMapperDao studentTeacherMapperDao;
 
     private static final ExecutorService exportExecutorService = Executors.newFixedThreadPool(10);
@@ -1511,10 +1513,13 @@ public class ExportServiceImpl implements ExportService {
         StudentCourseConsumerQueryInfo queryInfo = JSONObject.parseObject(JSONObject.toJSONString(info), StudentCourseConsumerQueryInfo.class);
         SysUser user = sysUserService.getUser();
         queryInfo.setOrganId(organizationService.getEmployeeOrgan(user.getId(), queryInfo.getOrganId(), user.getIsSuperAdmin()));
-        List<StudentCourseConsumerDetailDto> dtos = studentCourseConsumerService.queryCourseConsumerDetail(queryInfo);
-        checkRows(dtos);
+        Map<String, Object> params = new HashMap<String, Object>();
+        queryInfo.setRows(65535);
+        MapUtil.populateMap(params, queryInfo);
+        int count = studentStatisticsDao.countCourseConsumerDetail(params);
+        checkRows(count);
         ManagerDownload managerDownload = saveManagerDownload(ExportTypeEnum.EXPORT_COURSE_CONSUMER_DETAIL,user.getId());
-        return this.asyncExport(() -> this.initExportInfo(dtos, managerDownload,ExportEnum.EXPORT_COURSE_CONSUMER_DETAIL),
+        return this.asyncExport(() -> this.initExportInfo(studentStatisticsDao.queryCourseConsumerDetail(params), managerDownload,ExportEnum.EXPORT_COURSE_CONSUMER_DETAIL),
                 managerDownload.getName());
     }
     private HttpResponseResult exportPreCourseConsumer(Map<String, Object> info){
@@ -1531,10 +1536,13 @@ public class ExportServiceImpl implements ExportService {
         StudentCourseConsumerQueryInfo queryInfo = JSONObject.parseObject(JSONObject.toJSONString(info), StudentCourseConsumerQueryInfo.class);
         SysUser user = sysUserService.getUser();
         queryInfo.setOrganId(organizationService.getEmployeeOrgan(user.getId(), queryInfo.getOrganId(), user.getIsSuperAdmin()));
-        List<StudentCourseConsumerDetailDto> dtos = studentCourseConsumerService.queryPreCourseConsumerDetail(queryInfo);
-        checkRows(dtos);
+        Map<String, Object> params = new HashMap<String, Object>();
+        queryInfo.setRows(65535);
+        MapUtil.populateMap(params, queryInfo);
+        int count = studentStatisticsDao.countPreCourseConsumerDetail(params);
+        checkRows(count);
         ManagerDownload managerDownload = saveManagerDownload(ExportTypeEnum.EXPORT_PRE_COURSE_CONSUMER_DETAIL,user.getId());
-        return this.asyncExport(() -> this.initExportInfo(dtos, managerDownload,ExportEnum.EXPORT_PRE_COURSE_CONSUMER_DETAIL),
+        return this.asyncExport(() -> this.initExportInfo(studentStatisticsDao.queryPreCourseConsumerDetail(params), managerDownload,ExportEnum.EXPORT_PRE_COURSE_CONSUMER_DETAIL),
                 managerDownload.getName());
     }
     private HttpResponseResult exportCourseConsumerSum(Map<String, Object> info){

mec-biz/src/main/java/com/ym/mec/biz/service/impl/StudentCourseConsumerServiceImpl.java

@@ -7,14 +7,15 @@ import com.ym.mec.biz.dal.dto.StudentCourseConsumerSumDto;
 import com.ym.mec.biz.dal.page.StudentCourseConsumerQueryInfo;
 import com.ym.mec.biz.service.StudentCourseConsumerService;
 import com.ym.mec.common.constant.CommonConstants;
+import com.ym.mec.common.page.PageInfo;
+import com.ym.mec.util.collection.MapUtil;
 import com.ym.mec.util.date.DateUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.math.BigDecimal;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
 
 @Service
 public class StudentCourseConsumerServiceImpl implements StudentCourseConsumerService {
@@ -29,8 +30,23 @@ public class StudentCourseConsumerServiceImpl implements StudentCourseConsumerSe
     }
 
     @Override
-    public List<StudentCourseConsumerDetailDto> queryCourseConsumerDetail(StudentCourseConsumerQueryInfo queryInfo) {
-        return studentStatisticsDao.queryCourseConsumerDetail(queryInfo);
+    public PageInfo<StudentCourseConsumerDetailDto> queryCourseConsumerDetail(StudentCourseConsumerQueryInfo queryInfo) {
+        PageInfo<StudentCourseConsumerDetailDto> pageInfo = new PageInfo<>(queryInfo.getPage(), queryInfo.getRows());
+        Map<String, Object> params = new HashMap<String, Object>();
+        MapUtil.populateMap(params, queryInfo);
+
+        List<StudentCourseConsumerDetailDto> dataList = null;
+        int count = studentStatisticsDao.countCourseConsumerDetail(params);
+        if (count > 0) {
+            pageInfo.setTotal(count);
+            params.put("offset", pageInfo.getOffset());
+            dataList = studentStatisticsDao.queryCourseConsumerDetail(params);
+        }
+        if (count == 0) {
+            dataList = new ArrayList<>();
+        }
+        pageInfo.setRows(dataList);
+        return pageInfo;
     }
 
     @Override
@@ -39,8 +55,23 @@ public class StudentCourseConsumerServiceImpl implements StudentCourseConsumerSe
     }
 
     @Override
-    public List<StudentCourseConsumerDetailDto> queryPreCourseConsumerDetail(StudentCourseConsumerQueryInfo queryInfo) {
-        return studentStatisticsDao.queryPreCourseConsumerDetail(queryInfo);
+    public PageInfo<StudentCourseConsumerDetailDto> queryPreCourseConsumerDetail(StudentCourseConsumerQueryInfo queryInfo) {
+        PageInfo<StudentCourseConsumerDetailDto> pageInfo = new PageInfo<>(queryInfo.getPage(), queryInfo.getRows());
+        Map<String, Object> params = new HashMap<String, Object>();
+        MapUtil.populateMap(params, queryInfo);
+
+        List<StudentCourseConsumerDetailDto> dataList = null;
+        int count = studentStatisticsDao.countPreCourseConsumerDetail(params);
+        if (count > 0) {
+            pageInfo.setTotal(count);
+            params.put("offset", pageInfo.getOffset());
+            dataList = studentStatisticsDao.queryPreCourseConsumerDetail(params);
+        }
+        if (count == 0) {
+            dataList = new ArrayList<>();
+        }
+        pageInfo.setRows(dataList);
+        return pageInfo;
     }
 
     @Override

mec-biz/src/main/java/com/ym/mec/biz/service/impl/StudentServiceImpl.java

@@ -964,33 +964,8 @@ public class StudentServiceImpl extends BaseServiceImpl<Integer, Student> implem
     @Override
     public CloudStudyStudentDataDto getCloudStudyStudentOverView(List<Integer> organIds) {
         CloudStudyStudentDataDto result = new CloudStudyStudentDataDto();
-        
-        /*IndexCloudStudyListDto dto = studentDao.getOrgansCloudTeacherStudent(organIds);
-        result.setTotalStudentNum(dto.getTotalStudentNum());
-        result.setEffectiveVipStudentNum(dto.getEffectiveVipStudentNum());
-        result.setWaitActivateVipStudentNum(dto.getWaitActivateVipStudentNum());
-        
-        result.setVipStudentNum(cloudTeacherDao.getOrgansTotalVipStudentNum(organIds));*/
-//        result.seteVipStudentNum(studentDao.getOrgansTotalEVipStudentNum(organIds));
-        result.setCloudStudyUseStudentNum(studentDao.getOrgansTotalCloudStudyStudentNum(organIds));
+//        result.setCloudStudyUseStudentNum(studentDao.getOrgansTotalCloudStudyStudentNum(organIds));
         result.setCloudStudyTodayUseStudentNum(studentDao.getOrgansTodayTotalCloudStudyStudentNum(organIds));
-        
-        Calendar cal = Calendar.getInstance();    
-        cal.setTime(new Date());    
-        //cal.add(Calendar.WEEK_OF_YEAR, -1);// 一周    
-        cal.set(Calendar.DAY_OF_WEEK, Calendar.SUNDAY);
-        Date endTime = cal.getTime();
-        
-        cal.setTime(new Date());    
-        cal.add(Calendar.WEEK_OF_YEAR, -4);// 一周    
-        cal.set(Calendar.DAY_OF_WEEK, Calendar.MONDAY);
-        Date startTime = cal.getTime();
-        
-        //result.setCloudStudyLivelyStudentNum(studentDao.getOrganTotalCloudStudyLivelyStudentNum(organIds, startTime, endTime));
-        //result.setNewCloudStudyStudentNum(sysMusicCompareRecordDao.getOrgansTotalNewCloudStudyNum(organIds));
-//        if(result.getVipStudentNum()>0&&result.getTotalStudentNum()>0){
-//            result.setVipStudentDuty(new BigDecimal(result.getVipStudentNum()).divide(new BigDecimal(result.getTotalStudentNum()), 4, BigDecimal.ROUND_DOWN).multiply(new BigDecimal(100)).floatValue());
-//        }
         return result;
     }
 
@@ -1338,9 +1313,35 @@ public class StudentServiceImpl extends BaseServiceImpl<Integer, Student> implem
     }
 
     @Override
-    public List<IndexCloudStudyListDto> getCloudStudyStudentOverViewList1(String organIds) {
-//        List<IndexCloudStudyListDto> list = studentDao.getCloudStudyStudentOverViewList(organIds);
-        return null;
+    public List<IndexCloudStudySumDto> getCloudStudyStudentOverViewList1(List<Integer> organIdsList) {
+        List<IndexCloudStudySumDto> list = studentDao.getCloudStudyStudentOverViewList1(organIdsList);
+        //获取待激活学员数
+        Map<Integer,Integer> waitMap = MapUtil.convertIntegerMap(cloudTeacherOrderDao.getWaitActivateMap(organIdsList));
+        //获取活跃学员数
+        Calendar cal = Calendar.getInstance();
+        cal.setTime(new Date());
+        //cal.add(Calendar.WEEK_OF_YEAR, -1);// 一周
+        cal.set(Calendar.DAY_OF_WEEK, Calendar.SUNDAY);
+        Date endTime = cal.getTime();
+
+        cal.setTime(new Date());
+        cal.add(Calendar.WEEK_OF_YEAR, -4);// 一周
+        cal.set(Calendar.DAY_OF_WEEK, Calendar.MONDAY);
+        Date startTime = cal.getTime();
+
+        Map<Integer,Integer> activeMap = MapUtil.convertIntegerMap(studentDao.getOrganActiveCloudStudyStudentNum1(organIdsList, startTime, endTime));
+        //获取重复购买人数
+        Map<Integer,Integer> againBuyMap = MapUtil.convertIntegerMap(studentDao.getAgainBuyNum(organIdsList));
+        for (IndexCloudStudySumDto dto : list) {
+            dto.setWaitActivateVipStudentNum(waitMap.get(dto.getOrganId()));
+            dto.setAgainBuyNum(againBuyMap.get(dto.getOrganId()));
+            dto.setActiveStudentNum(activeMap.get(dto.getOrganId()));
+            dto.setTotalStudentNum(dto.getWaitActivateVipStudentNum() + dto.getVipStudentNum());
+//            double studentNum = (double)dto.getVipStudentNum();
+//            dto.setVipStudentRate(studentNum / dto.getTotalStudentNum());
+//            dto.setAgainBuyRate(dto.getAgainBuyNum() / studentNum);
+        }
+        return list;
     }
 
     @Transactional(rollbackFor = Exception.class)

mec-biz/src/main/resources/config/mybatis/CloudTeacherOrderMapper.xml

@@ -486,4 +486,16 @@
     <select id="queryByUserIdAndStatus" resultMap="CloudTeacherOrder">
         select cto.* from cloud_teacher_order cto where cto.student_id_ = #{userId} and cto.status_ = #{status}
     </select>
+    <select id="getWaitActivateMap" resultType="java.util.Map">
+        select cto.organ_id_,COUNT(DISTINCT cto.student_id_) from cloud_teacher_order cto
+        left join student s ON s.user_id_ = cto.student_id_
+        where cto.status_ = 1 AND (s.membership_end_time_ &lt; NOW() OR s.membership_end_time_ IS NULL)
+        <if test="organIds != null and organIds.size > 0">
+            AND cto.organ_id_ IN
+            <foreach collection="organIds" item="organId" open="(" close=")" separator=",">
+                #{organId}
+            </foreach>
+        </if>
+        group by cto.organ_id_
+    </select>
 </mapper>

mec-biz/src/main/resources/config/mybatis/StudentMapper.xml

@@ -633,11 +633,11 @@
         SELECT
         COUNT(DISTINCT smcr.user_id_)
         FROM sys_music_compare_record smcr
-        LEFT JOIN sys_user su ON smcr.user_id_=su.id_
-        LEFT JOIN student stu ON smcr.user_id_=stu.user_id_
-        WHERE su.del_flag_=0 AND stu.user_id_ IS NOT NULL
+        LEFT JOIN student_registration sr ON smcr.user_id_ = sr.user_id_
+        LEFT JOIN music_group mg ON mg.id_ = sr.music_group_id_
+        WHERE sr.music_group_status_ = 'NORMAL' AND mg.status_ = 'PROGRESS'
         AND smcr.create_time_ > date_sub(curdate(),INTERVAL 0 day)
-            AND su.organ_id_ IN
+            AND mg.organ_id_ IN
             <foreach collection="organIds" item="organId" open="(" close=")" separator=",">
                 #{organId}
             </foreach>
@@ -698,6 +698,23 @@
         </foreach>
 		GROUP BY u.`organ_id_` 
     </select>
+    <select id="getOrganActiveCloudStudyStudentNum1" resultType="java.util.Map">
+        SELECT mg.`organ_id_` 'key',count(a.user_id_) 'value' FROM
+        (
+        SELECT wd.`user_id_` FROM `sys_music_compare_week_data` wd
+        WHERE wd.`train_time_` >= 3600 AND wd.`monday_` BETWEEN date(#{startTime}) and date(#{endTime})  GROUP BY `user_id_` HAVING count(*) >= 3
+        ) a
+        LEFT JOIN student_registration sr ON a.user_id_ = sr.user_id_
+        LEFT JOIN music_group mg ON mg.id_ = sr.music_group_id_
+        WHERE sr.music_group_status_ = 'NORMAL' AND mg.status_ = 'PROGRESS'
+        <if test="organIds != null and organIds.size > 0">
+            AND mg.organ_id_ IN
+            <foreach collection="organIds" item="organId" open="(" close=")" separator=",">
+                #{organId}
+            </foreach>
+        </if>
+        GROUP BY mg.`organ_id_`
+    </select>
 
     <select id="getCloudStudyStudentOverViewList" resultType="com.ym.mec.biz.dal.dto.IndexCloudStudyListDto">
         SELECT o.`name_` organName,o.`id_` organId,count(s.`user_id_`) totalStudentNum,
@@ -714,6 +731,21 @@
         </foreach>
 		GROUP BY u.`organ_id_` 
     </select>
+    <select id="getCloudStudyStudentOverViewList1" resultType="com.ym.mec.biz.dal.dto.IndexCloudStudySumDto">
+        select mg.organ_id_ organId,COUNT(DISTINCT sr.user_id_) totalStudentNum,
+               COUNT(DISTINCT CASE WHEN s.membership_end_time_ >= NOW() THEN sr.user_id_ END) effectiveStudentNum
+        from student_registration sr
+        left join music_group mg ON mg.id_ = sr.music_group_id_
+        left join student s ON s.user_id_ = sr.user_id_
+        where sr.music_group_status_ = 'NORMAL' AND mg.status_ = 'PROGRESS'
+        <if test="organIds != null and organIds.size > 0">
+            AND mg.organ_id_ IN
+            <foreach collection="organIds" item="organId" open="(" close=")" separator=",">
+                #{organId}
+            </foreach>
+        </if>
+        group by mg.organ_id_;
+    </select>
 
     <select id="getOrganCloudStudyLivelyStudentNum" resultType="map">
         SELECT
@@ -1193,6 +1225,21 @@
         </if>
         group by mg.organ_id_
     </select>
+    <select id="getAgainBuyNum" resultType="java.util.Map">
+        select mg.organ_id_ 'key',COUNT(DISTINCT sr.user_id_) 'value' from student_registration sr
+        left join music_group mg ON mg.id_ = sr.music_group_id_
+        left join student s ON s.user_id_ = sr.user_id_
+        where s.membership_end_time_ >= NOW() AND sr.user_id_ IN
+        (select cto.student_id_ from cloud_teacher_order cto where cto.amount_ > 0 AND cto.status_ IN (1,2) group by cto.student_id_ HAVING COUNT(id_) > 1)
+          AND sr.music_group_status_ = 'NORMAL' AND mg.status_ = 'PROGRESS'
+        <if test="organIds!=null and organIds.size() > 0">
+            AND mg.organ_id_ IN
+            <foreach collection="organIds" item="organId" open="(" close=")" separator=",">
+                #{organId}
+            </foreach>
+        </if>
+        group by mg.organ_id_
+    </select>
     <sql id="queryStudentBasicInfoSql">
         <where>
             AND su.lock_flag_ = 0 AND su.del_flag_ = 0

mec-biz/src/main/resources/config/mybatis/StudentStatisticsMapper.xml

@@ -602,7 +602,7 @@
 		from student_statistics ss
 		left join (select COUNT(cssp.id_) course_sum_,cssp.user_id_,COUNT(distinct cssp.course_schedule_id_) course_num_ from course_schedule cs
 		left join course_schedule_student_payment cssp ON cssp.course_schedule_id_ = cs.id_
-		where DATE_FORMAT(cs.class_date_,'%Y-%m-%d') BETWEEN #{queryInfo.startDate} AND #{queryInfo.endDate} AND cs.status_ = 'OVER' AND cs.type_ = 'VIP'
+		where DATE_FORMAT(cs.class_date_,'%Y-%m-%d') BETWEEN #{startDate} AND #{queryInfo.endDate} AND cs.status_ = 'OVER' AND cs.type_ = 'VIP'
 		<include refid="com.ym.mec.biz.dal.dao.CourseScheduleDao.courseIgnore"/>
 		group by cssp.user_id_) cs ON cs.user_id_ = ss.user_id_
 		left join sys_user su ON su.id_ = ss.user_id_
@@ -628,17 +628,26 @@
 		from student_statistics ss
 		left join (select cssp.user_id_,COUNT(distinct cssp.course_schedule_id_) consumerNum from course_schedule cs
 		left join course_schedule_student_payment cssp ON cssp.course_schedule_id_ = cs.id_
-		where DATE_FORMAT(cs.class_date_,'%Y-%m') = #{queryInfo.month} AND cs.status_ = 'OVER' AND cs.type_ = 'VIP'
+		where DATE_FORMAT(cs.class_date_,'%Y-%m') = #{month} AND cs.status_ = 'OVER' AND cs.type_ = 'VIP'
 		<include refid="com.ym.mec.biz.dal.dao.CourseScheduleDao.courseIgnore"/>
 		group by cssp.user_id_) cs ON cs.user_id_ = ss.user_id_
 		left join sys_user su ON su.id_ = ss.user_id_
 		left join organization o ON o.id_ = su.organ_id_
 		where ss.group_type_ = 'VIP' AND (ss.no_schedule_num_ > 0 OR ss.sub_course_num_) AND ss.lately_year_course_consumer_ > 0
-		<if test="queryInfo.organId != null and queryInfo.organId != ''">
+		<if test="organId != null and organId != ''">
 			AND FIND_IN_SET(su.organ_id_,#{queryInfo.organId})
 		</if>
 		group by ss.user_id_ order by su.organ_id_;
 	</select>
+	<select id="countCourseConsumerDetail" resultType="java.lang.Integer">
+		select COUNT(DISTINCT ss.user_id_)
+		from student_statistics ss
+		left join sys_user su ON su.id_ = ss.user_id_
+		where ss.group_type_ = 'VIP' AND (ss.no_schedule_num_ > 0 OR ss.sub_course_num_) AND ss.lately_year_course_consumer_ > 0
+		<if test="organId != null and organId != ''">
+			AND FIND_IN_SET(su.organ_id_,#{organId})
+		</if>
+	</select>
 	<select id="queryPreCourseConsumerDetail" resultMap="StudentCourseConsumerDetailDto">
 		select o.name_ organName,su.username_,ss.user_id_,su.phone_,
 		CASE WHEN ss.no_schedule_num_ + CASE WHEN cs.course_num_ IS NULL THEN 0 ELSE cs.course_num_ END > 3
@@ -648,15 +657,24 @@
 		left join (
 		select cssp.user_id_,COUNT(distinct cssp.course_schedule_id_) course_num_ from course_schedule cs
 		left join course_schedule_student_payment cssp ON cssp.course_schedule_id_ = cs.id_
-		where DATE_FORMAT(cs.class_date_,'%Y-%m') BETWEEN #{queryInfo.startDate} AND #{queryInfo.endDate} AND cs.type_ = 'VIP'
+		where DATE_FORMAT(cs.class_date_,'%Y-%m') BETWEEN #{startDate} AND #{endDate} AND cs.type_ = 'VIP'
 		<include refid="com.ym.mec.biz.dal.dao.CourseScheduleDao.courseIgnore"/>
 		group by cssp.user_id_) cs ON ss.user_id_ = cs.user_id_
 		left join sys_user su ON su.id_ = ss.user_id_
 		left join organization o ON o.id_ = su.organ_id_
 		where ss.group_type_ = 'VIP' AND (ss.no_schedule_num_ > 0 OR ss.sub_course_num_) AND ss.lately_year_course_consumer_ > 0
-		<if test="queryInfo.organId != null and queryInfo.organId != ''">
-			AND FIND_IN_SET(su.organ_id_,#{queryInfo.organId})
+		<if test="organId != null and organId != ''">
+			AND FIND_IN_SET(su.organ_id_,#{organId})
 		</if>
 		ORDER BY su.organ_id_
 	</select>
+	<select id="countPreCourseConsumerDetail" resultType="java.lang.Integer">
+		select COUNT(DISTINCT ss.user_id_)
+		from student_statistics ss
+		left join sys_user su ON su.id_ = ss.user_id_
+		where ss.group_type_ = 'VIP' AND (ss.no_schedule_num_ > 0 OR ss.sub_course_num_) AND ss.lately_year_course_consumer_ > 0
+		<if test="organId != null and organId != ''">
+			AND FIND_IN_SET(su.organ_id_,#{organId})
+		</if>
+	</select>
 </mapper>

mec-web/src/main/java/com/ym/mec/web/controller/StudentCourseConsumerController.java

@@ -8,6 +8,7 @@ import com.ym.mec.biz.service.OrganizationService;
 import com.ym.mec.biz.service.StudentCourseConsumerService;
 import com.ym.mec.common.controller.BaseController;
 import com.ym.mec.common.entity.HttpResponseResult;
+import com.ym.mec.common.page.PageInfo;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -40,7 +41,7 @@ public class StudentCourseConsumerController extends BaseController {
     @ApiOperation(value = "实际课耗学员详情列表")
     @PostMapping("/queryCourseConsumerDetail")
     @PreAuthorize("@pcs.hasPermissions('studentCourseConsumer/queryCourseConsumerDetail')")
-    public HttpResponseResult<List<StudentCourseConsumerDetailDto>> queryCourseConsumerDetail(@RequestBody StudentCourseConsumerQueryInfo queryInfo){
+    public HttpResponseResult<PageInfo<StudentCourseConsumerDetailDto>> queryCourseConsumerDetail(@RequestBody StudentCourseConsumerQueryInfo queryInfo){
         queryInfo.setOrganId(organizationService.getEmployeeOrgan(queryInfo.getOrganId()));
         return succeed(studentCourseConsumerService.queryCourseConsumerDetail(queryInfo));
     }
@@ -56,7 +57,7 @@ public class StudentCourseConsumerController extends BaseController {
     @ApiOperation(value = "预计课耗学员详情列表")
     @PostMapping("/queryPreCourseConsumerDetail")
     @PreAuthorize("@pcs.hasPermissions('studentCourseConsumer/queryPreCourseConsumerDetail')")
-    public HttpResponseResult<List<StudentCourseConsumerDetailDto>> queryPreCourseConsumerDetail(@RequestBody StudentCourseConsumerQueryInfo queryInfo){
+    public HttpResponseResult<PageInfo<StudentCourseConsumerDetailDto>> queryPreCourseConsumerDetail(@RequestBody StudentCourseConsumerQueryInfo queryInfo){
         queryInfo.setOrganId(organizationService.getEmployeeOrgan(queryInfo.getOrganId()));
         return succeed(studentCourseConsumerService.queryPreCourseConsumerDetail(queryInfo));
     }

mec-web/src/main/java/com/ym/mec/web/controller/StudentManageController.java

@@ -333,8 +333,8 @@ public class StudentManageController extends BaseController {
     }
 
     @ApiOperation(value = "云教练学员数据预览")
-    @GetMapping("/getCloudStudyStudentOverView")
-    public HttpResponseResult<Object> getCloudStudyStudentOverView(String organIds) throws Exception {
+    @GetMapping("/getCloudStudyStudentOverView1")
+    public HttpResponseResult<Object> getCloudStudyStudentOverView1(String organIds) throws Exception {
         List<Integer> organIdsList;
         if(StringUtils.isNotBlank(organIds)){
             organIdsList = Arrays.stream(organIds.split(",")).map(id->Integer.valueOf(id)).collect(Collectors.toList());
@@ -385,10 +385,32 @@ public class StudentManageController extends BaseController {
     }
 
     @ApiOperation(value = "云教练学员数据预览")
-    @GetMapping("/getCloudStudyStudentOverView1")
-    public HttpResponseResult<Object> getCloudStudyStudentOverView1(String organIds) throws Exception {
+    @GetMapping("/getCloudStudyStudentOverView")
+    public HttpResponseResult<Map<String,Object>> getCloudStudyStudentOverView(String organIds) throws Exception {
         organIds = organizationService.getEmployeeOrgan(organIds);
-        List<IndexCloudStudyListDto> list = studentService.getCloudStudyStudentOverViewList1(organIds);
+        List<Integer> organIdsList = null;
+        if(StringUtils.isNotBlank(organIds)){
+            organIdsList = Arrays.stream(organIds.split(",")).map(id->Integer.valueOf(id)).collect(Collectors.toList());
+            List<Integer> ingnoreOrganIdList = Arrays.asList(36,39,41,42,43,44,45,46,47,48,49,50,52,54,56);
+            organIdsList.removeAll(ingnoreOrganIdList);
+        }
+        List<IndexCloudStudySumDto> list = studentService.getCloudStudyStudentOverViewList1(organIdsList);
+        list = list.stream().sorted(Comparator.comparing(IndexCloudStudySumDto::getVipStudentRate).reversed()).collect(Collectors.toList());
+
+        Map<String,Object> result = new HashMap<String, Object>(2);
+        result.put("list",list);
+        CloudStudyStudentDataDto cloudStudyStudentDataDto = studentService.getCloudStudyStudentOverView(organIdsList);
+
+        cloudStudyStudentDataDto.setCloudStudyLivelyStudentNum(list.stream().collect(Collectors.summingInt(IndexCloudStudySumDto :: getActiveStudentNum)));
+        cloudStudyStudentDataDto.setTotalStudentNum(list.stream().collect(Collectors.summingInt(IndexCloudStudySumDto :: getTotalStudentNum)));
+        cloudStudyStudentDataDto.setEffectiveVipStudentNum(list.stream().collect(Collectors.summingInt(IndexCloudStudySumDto :: getEffectiveVipStudentNum)));
+        cloudStudyStudentDataDto.setWaitActivateVipStudentNum(list.stream().collect(Collectors.summingInt(IndexCloudStudySumDto :: getWaitActivateVipStudentNum)));
+        cloudStudyStudentDataDto.setVipStudentNum(list.stream().collect(Collectors.summingInt(IndexCloudStudySumDto :: getVipStudentNum)));
+        double studentNum = (double)cloudStudyStudentDataDto.getVipStudentNum();
+        cloudStudyStudentDataDto.setBuyRate(studentNum / cloudStudyStudentDataDto.getTotalStudentNum());
+        cloudStudyStudentDataDto.setAgainBuyRate(cloudStudyStudentDataDto.getAgainBuyNum() / studentNum);
+        result.put("overView",cloudStudyStudentDataDto);
+        return succeed(result);
     }
 
     @ApiOperation(value = "云教练学员数据预览列表")