feats

src/main/java/com/yunzhi/marketing/borker/controller/BorkerController.java

@@ -59,6 +59,17 @@ public class BorkerController  extends BaseController {
         return ResponseBean.success(result);
     }
 
+    @RequestMapping(value="/wx/borker/rank",method= RequestMethod.GET)
+    @ApiOperation(value="小程序端经纪人榜单", notes = "小程序端经纪人榜单", httpMethod = "GET", response = ResponseBean.class)
+    public ResponseBean getWxBorkerRank(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                        @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                       @ApiParam(value = "榜单类型", allowableValues = "person,money") @RequestParam(value ="rankType") String rankType,
+                                        HttpServletRequest request) throws Exception {
+        IPage<BorkerSummery> page = new Page<>(pageNum, pageSize);
+        IPage<BorkerSummery> result = iTaPersonService.getWxBorkerRankPage(page, rankType);
+        return ResponseBean.success(result);
+    }
+
 
     @RequestMapping(value="/wx/bindBorker",method= RequestMethod.PUT)
     @ApiOperation(value="成为经纪人", notes = "成为经纪人", httpMethod = "PUT", response = ResponseBean.class)

src/main/java/com/yunzhi/marketing/borker/vo/BorkerSummery.java

@@ -41,4 +41,7 @@ public class BorkerSummery {
     @TableField(exist = false)
     @ApiModelProperty("经纪人数")
     Integer borkerNum;
+
+    @ApiModelProperty("总佣金")
+    private Integer totalCommission;
 }

src/main/java/com/yunzhi/marketing/mapper/TaPersonMapper.java

@@ -278,4 +278,6 @@ public interface TaPersonMapper extends BaseMapper<TaPerson> {
     IPage<BorkerSummery> getWxBorkerPage(IPage<BorkerSummery> page,
                                          @Param("personType") String personType,
                                          @Param("recommendAgent") String recommendAgent);
+
+    IPage<BorkerSummery> getWxBorkerRankPage(IPage<BorkerSummery> page, @Param("personType") String personBorker, @Param("recommendAgent") String rankType);
 }

src/main/java/com/yunzhi/marketing/service/ITaPersonService.java

@@ -136,4 +136,6 @@ public interface ITaPersonService extends IService<TaPerson> {
     IPage<BorkerVO> getBorkerPage(IPage<BorkerVO> page, String name, String phone, String recommendPersonName, String sortOrder, String sortField);
 
     IPage<BorkerSummery> getWxBorkerPage(IPage<BorkerSummery> page, String personId);
+
+    IPage<BorkerSummery> getWxBorkerRankPage(IPage<BorkerSummery> page, String rankType);
 }

src/main/java/com/yunzhi/marketing/service/impl/TaPersonServiceImpl.java

@@ -1356,4 +1356,9 @@ public class TaPersonServiceImpl extends ServiceImpl<TaPersonMapper, TaPerson> i
     public IPage<BorkerSummery> getWxBorkerPage(IPage<BorkerSummery> page, String personId) {
         return baseMapper.getWxBorkerPage(page, CommConstant.PERSON_BORKER, personId);
     }
+
+    @Override
+    public IPage<BorkerSummery> getWxBorkerRankPage(IPage<BorkerSummery> page, String rankType) {
+        return baseMapper.getWxBorkerRankPage(page, CommConstant.PERSON_BORKER, rankType);
+    }
 }

src/main/resources/mapper/TaPersonMapper.xml

@@ -732,6 +732,46 @@ FROM
         ORDER BY
             t.create_date DESC
     </select>
+    <select id="getWxBorkerRankPage" resultType="com.yunzhi.marketing.borker.vo.BorkerSummery">
+        SELECT
+            t.*,
+            s.customer_num,
+            m.borker_num
+        FROM
+            ta_person t
+                LEFT JOIN (
+                SELECT
+                    a.recommend_person,
+                    count( 1 ) AS customer_num
+                FROM
+                    xlk_channel_customer a
+                WHERE
+                    a.recommend_person_type = #{personType}
+                  AND a.`status` = 2
+                GROUP BY
+                    a.recommend_person
+            ) s ON s.recommend_person = t.person_id
+                LEFT JOIN (
+                SELECT
+                    a.recommend_agent,
+                    count( 1 ) AS borker_num
+                FROM
+                    ta_person a
+                WHERE
+                    a.person_type = #{personType}
+                  AND a.`status` > - 1
+            ) m ON m.recommend_agent = t.person_id
+        WHERE t.person_type = #{personType}
+          AND t.`status` &gt; -1
+        <if test="rankType == 'person'">
+            ORDER BY
+            m.borker_num DESC
+        </if>
+        <if test="rankType == 'money'">
+            ORDER BY
+            t.total_commission DESC
+        </if>
+    </select>
 
     <insert id="savePersonPosition" parameterType="com.yunzhi.marketing.entity.TaPersonPositon">
         insert into ta_person_position