积分排行接口 - points模块 - 代码恢复

esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/controller/EpdcAppPointsController.java

@@ -37,4 +37,17 @@ public class EpdcAppPointsController {
         List<EpdcAppPointsRecordResultDTO> list = pointsLogsService.listPointsRecord(formDto);
         return new Result<List<EpdcAppPointsRecordResultDTO>>().ok(list);
     }
+
+    /**
+     * @Description: 积分排行接口（0 周排行、1 月排行）
+     * @Param: [formDto]
+     * @return: com.elink.esua.epdc.commons.tools.utils.Result<java.util.List<com.elink.esua.epdc.dto.result.EpdcAppPointsRankingResultDTO>>
+     * @Author: zy
+     * @Date: 2020-04-30
+     */
+    @GetMapping("pointsRanking/list")
+    public Result<List<EpdcAppPointsRankingResultDTO>> listPointsRanking(@RequestBody EpdcAppPointsRankingFormDTO formDto) {
+        List<EpdcAppPointsRankingResultDTO> list = pointsLogsService.listPointsRanking(formDto);
+        return new Result<List<EpdcAppPointsRankingResultDTO>>().ok(list);
+    }
 }

esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/dao/PointsLogsDao.java

@@ -78,4 +78,16 @@ public interface PointsLogsDao extends BaseDao<PointsLogsEntity> {
      */
     List<EpdcAppPointsRecordResultDTO> selectListPointsRecord(EpdcAppPointsRecordFormDTO formDto);
 
+    /**
+     * 积分排行接口（0 周排行、1 月排行）
+     *
+     * @param formDto
+     *  param   pageIndex   必选  页码
+     *  param   pageSize    必选  页容量
+     *  param   rankingType 必选  排名方式：0-周，1-月
+     * @return: com.elink.esua.epdc.commons.tools.utils.Result<java.util.List < com.elink.esua.epdc.dto.result.EpdcAppPointsRankingResultDTO>>
+     * @Author: zy
+     * @Date: 2020-04-30
+     */
+    List<EpdcAppPointsRankingResultDTO> selectListPointsRanking(EpdcAppPointsRankingFormDTO formDto);
 }

esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/service/PointsLogsService.java

@@ -151,4 +151,17 @@ public interface PointsLogsService extends BaseService<PointsLogsEntity> {
      * @Date 2019/12/16 18:56
      **/
     Result confirmAdjustPoint(EpdcAdjustVolunteerPointsDTO formDto);
+
+    /**
+     * 积分排行接口（0 周排行、1 月排行）
+     *
+     * @param formDto
+     *  param   pageIndex   必选  页码
+     *  param   pageSize    必选  页容量
+     *  param   rankingType 必选  排名方式：0-周，1-月
+     * @return: com.elink.esua.epdc.commons.tools.utils.Result<java.util.List < com.elink.esua.epdc.dto.result.EpdcAppPointsRankingResultDTO>>
+     * @Author: zy
+     * @Date: 2020-04-30
+     */
+    List<EpdcAppPointsRankingResultDTO> listPointsRanking(EpdcAppPointsRankingFormDTO formDto);
 }

esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/service/impl/PointsLogsServiceImpl.java

@@ -224,4 +224,10 @@ public class PointsLogsServiceImpl extends BaseServiceImpl<PointsLogsDao, Points
         newsTask.insertUserInformation(informationFormDTO);
     }
 
+    @Override
+    public List<EpdcAppPointsRankingResultDTO> listPointsRanking(EpdcAppPointsRankingFormDTO formDto) {
+        int pageIndex = (formDto.getPageIndex() - NumConstant.ONE) * formDto.getPageSize();
+        formDto.setPageIndex(pageIndex);
+        return baseDao.selectListPointsRanking(formDto);
+    }
 }

esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/resources/mapper/PointsLogsDao.xml

@@ -78,4 +78,33 @@
         from epdc_points_logs where DEL_FLAG ='0' and USER_ID = #{userId}
         and BEHAVIOR_CODE = #{behaviorCode} order by  OPERATION_TIME desc limit 1
     </select>
+
+    <select id="selectListPointsRanking" resultType="com.elink.esua.epdc.dto.result.EpdcAppPointsRankingResultDTO">
+        SELECT
+        tab.USER_ID userId,
+        (
+        SELECT NICKNAME
+        FROM epdc_points_logs
+        WHERE tab.USER_ID = USER_ID
+        ORDER BY CREATED_TIME DESC
+        limit 0,1
+        ) nickName,
+        (tab.totalPointsAdd - tab.totalPointsDeducted) points
+        FROM(
+        SELECT
+        USER_ID,
+        SUM(case when OPERATION_TYPE = 0 then IFNULL(points,0) else 0 end) totalPointsDeducted,
+        SUM(case when OPERATION_TYPE = 1 then IFNULL(points,0) else 0 end) totalPointsAdd
+        FROM epdc_points_logs
+        WHERE DEL_FLAG = 0
+        <if test="rankingType != null and rankingType == 0">
+            AND YEARWEEK(date_format(OPERATION_TIME,'%Y-%m-%d')) = YEARWEEK(now())
+        </if>
+        <if test="rankingType != null and rankingType == 1">
+            AND DATE_FORMAT( OPERATION_TIME, '%Y%m' ) = DATE_FORMAT( CURDATE() , '%Y%m' )
+        </if>
+        GROUP BY USER_ID
+        ) tab ORDER BY (tab.totalPointsAdd - tab.totalPointsDeducted) DESC
+        LIMIT #{pageIndex}, #{pageSize}
+    </select>
 </mapper>