查询排行榜列表

src/main/java/com/zh/project0512/controller/ScheduleController.java

@@ -65,9 +65,9 @@ public class ScheduleController {
         QueryWrapper<RankListDTO> queryWrapper = new QueryWrapper<>();
         queryWrapper.groupBy("u.id");
         queryWrapper.orderByDesc("value");
-        List<RankListVo> rankList = qywxDepartmentUserLinkMapper.getUserRankList(queryWrapper);
-        if (rankList != null && rankList.size()>0){
-            for (RankListVo rankListVo : rankList) {
+        List<RankListVo> rankUserList = qywxDepartmentUserLinkMapper.getUserRankList(queryWrapper);
+        if (rankUserList != null && rankUserList.size()>0){
+            for (RankListVo rankListVo : rankUserList) {
                 //查询是否有上一月记录，如果有就减去上一月传播值，没有则直接添加
                 QueryWrapper<Rank> queryWrapper2 = new QueryWrapper<>();
                 queryWrapper2.eq("linkId",rankListVo.getLinkId());
@@ -87,7 +87,29 @@ public class ScheduleController {
             }
         }
         //计算经销商排名进排名数据库
-
-
+        QueryWrapper<RankListDTO> queryWrapper3 = new QueryWrapper<>();
+        queryWrapper3.groupBy("qd.departmentId");
+        queryWrapper3.orderByDesc("value");
+        List<RankListVo> rankDepartmentList = qywxDepartmentUserLinkMapper.getDepartmentRankList(queryWrapper3);
+        if (rankDepartmentList != null && rankDepartmentList.size()>0){
+            for (RankListVo rankListVo : rankDepartmentList) {
+                //查询是否有上一月记录，如果有就减去上一月传播值，没有则直接添加
+                QueryWrapper<Rank> queryWrapper2 = new QueryWrapper<>();
+                queryWrapper2.eq("linkId",rankListVo.getLinkId());
+                queryWrapper2.eq("type",1);//1.经销商
+                queryWrapper2.orderByDesc("dateStart");
+                queryWrapper2.last("limit 1");
+                Rank rank = rankMapper.selectOne(queryWrapper2);
+                if (rank != null){
+                    rankListVo.setValue(rankListVo.getValue() - rank.getValue());
+                }
+                Rank rank2 = new Rank();
+                PropertyUtils.copyProperties(rankListVo,rank2);
+                rank2.setDateStart(timeStart);
+                rank2.setDateEnd(timeEnd);
+                rank2.setCreateDate(new Date());
+                rankMapper.insert(rank2);
+            }
+        }
     }
 }

src/main/java/com/zh/project0512/mapper/QywxDepartmentUserLinkMapper.java

@@ -1,6 +1,7 @@
 package com.zh.project0512.mapper;
 
 import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.zh.project0512.model.QywxDepartmentUserLink;
 import com.zh.project0512.model.dto.RankListDTO;
@@ -11,5 +12,7 @@ import java.util.List;
 
 public interface QywxDepartmentUserLinkMapper extends BaseMapper<QywxDepartmentUserLink> {
 
-    List<RankListVo> getUserRankList( @Param("ew") Wrapper<RankListDTO> queryWrapper);
+    List<RankListVo> getUserRankList(@Param("ew") Wrapper<RankListDTO> queryWrapper);
+
+    List<RankListVo> getDepartmentRankList(@Param("ew") QueryWrapper<RankListDTO> queryWrapper2);
 }

src/main/resources/mapper/QywxDepartmentUserLinkMapper.xml

@@ -8,4 +8,11 @@
         LEFT JOIN video as v ON u.id = v.userId
         ${ew.SqlSegment}
     </select>
+    <select id="getDepartmentRankList" resultType="com.zh.project0512.model.vo.RankListVo">
+        select qd.departmentId as linkId,qd.name as title,sum(r.value) as value
+        from qywxDepartment as qd
+        LEFT JOIN qywxDepartmentUserLink as qdul on qd.departmentId = qdul.departmentId
+        LEFT JOIN rank as r on r.linkId=qdul.openid
+        ${ew.SqlSegment}
+    </select>
 </mapper>