需求

src/main/java/com/huiju/estateagents/third/controller/WxRedpackController.java

@@ -123,12 +123,12 @@ public class WxRedpackController {
     /**
      * 帮他助力 接口
      * @param mpAppid
-     * @param mpPersonId
+     * @param personId
      * @param request
      * @return
      */
     @PostMapping("/third/activity/{mpAppid}/help")
-    public ResponseBean helpActivity(@PathVariable String mpAppid, @RequestParam String mpPersonId, @RequestParam String sponsorPersonId,@RequestParam String appid, HttpServletRequest request) {
+    public ResponseBean helpActivity(@PathVariable String mpAppid, @RequestParam String personId, @RequestParam String sponsorPersonId,@RequestParam String appid, HttpServletRequest request) {
         WxMpService wxService = getWxMpService();
         if (!wxService.switchover(mpAppid)) {
             throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", mpAppid));
@@ -142,11 +142,36 @@ public class WxRedpackController {
             return ResponseBean.error("不存在的H5活动",ResponseBean.ERROR_UNAVAILABLE);
         }
         try {
-            ResponseBean res = iTaThirdPartyMiniappConfigService.helpActivity(mpAppid, mpPersonId, sponsorPersonId, taThirdPartyMiniappConfig.getTargetId(),taThirdPartyMiniappConfig.getOrgId());
+            ResponseBean res = iTaThirdPartyMiniappConfigService.helpActivity(mpAppid, personId, sponsorPersonId, taThirdPartyMiniappConfig.getTargetId(),taThirdPartyMiniappConfig.getOrgId());
             return res;
         }catch (Exception e){
             e.printStackTrace();
             return ResponseBean.error("程序出错请联系运营人员",ResponseBean.ERROR_ILLEGAL_PARAMS);
         }
     }
+
+    /**
+     * 获取此活动的排行榜
+     * @param appid
+     * @param request
+     * @return
+     */
+    @GetMapping("/third/activity/ranking")
+    public ResponseBean getRanking(@RequestParam String appid, HttpServletRequest request) {
+        try {
+            //获取H5项目相关信息
+            QueryWrapper<TaThirdPartyMiniappConfig> taThirdPartyMiniappConfigQueryWrapper = new QueryWrapper<>();
+
+            taThirdPartyMiniappConfigQueryWrapper.eq("appid", appid);
+            TaThirdPartyMiniappConfig taThirdPartyMiniappConfig = iTaThirdPartyMiniappConfigService.getOne(taThirdPartyMiniappConfigQueryWrapper);
+            if (null == taThirdPartyMiniappConfig){
+                return ResponseBean.error("不存在的H5活动",ResponseBean.ERROR_UNAVAILABLE);
+            }
+            //获取活动的排行榜
+            return iTaThirdPartyMiniappConfigService.getRanking(taThirdPartyMiniappConfig.getTargetId(),taThirdPartyMiniappConfig.getOrgId());
+        } catch (Exception e) {
+//            e.printStackTrace();
+            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
 }

src/main/java/com/huiju/estateagents/third/service/ITaThirdPartyMiniappConfigService.java

@@ -54,4 +54,12 @@ public interface ITaThirdPartyMiniappConfigService extends IService<TaThirdParty
 	 * @return
 	 */
 	ResponseBean helpActivity(String mpAppid, String mpPersonId, String sponsorPersonId, String targetId, Integer orgId);
+
+	/**
+	 * 获取活动排行榜
+	 * @param targetId
+	 * @param orgId
+	 * @return
+	 */
+    ResponseBean getRanking(String targetId, Integer orgId);
 }

src/main/java/com/huiju/estateagents/third/service/impl/TaThirdPartyMiniappConfigServiceImpl.java

@@ -189,6 +189,16 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 		queryWrapper.eq("miniapp_person_id",taMpMiniapp.getMiniappPersonId());
 		TaRedPacketPerson mineRedPacketPerson = taRedPacketPersonMapper.selectOne(queryWrapper);
 		map.put("mineRedPacketPerson",mineRedPacketPerson);
+
+		//查看我的爆红助力列表
+		QueryWrapper<TaRedPacketHistory> historyQueryWrapper = new QueryWrapper<>();
+		historyQueryWrapper.eq("activity_id",taRedPacket.getActivityId());
+		historyQueryWrapper.eq("org_id",taRedPacket.getOrgId());
+		historyQueryWrapper.eq("target_mp_person",taMpMiniapp.getMpPersonId());
+		historyQueryWrapper.eq("target_miniapp_person",taMpMiniapp.getMiniappPersonId());
+		List<TaRedPacketHistory> taRedPacketHistories = taRedPacketHistoryMapper.selectList(historyQueryWrapper);
+		map.put("taRedPacketHistories",taRedPacketHistories);
+
 		//token
 		Map<Object, Object> tokenMap = new HashMap<>();
 		tokenMap.put("openId", accessToken.getOpenId());
@@ -264,14 +274,14 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 	 * 助力活动接口
 	 *
 	 * @param mpAppid 公众号appid
-	 * @param mpPersonId 公众号personId
+	 * @param personId 小程序personId
 	 * @param sponsorPersonId 公众号发起人id
 	 * @param drainageId H5活动id
 	 * @param orgId 小程序id
 	 * @return
 	 */
 	@Override
-	public ResponseBean helpActivity(String mpAppid, String mpPersonId, String sponsorPersonId, String drainageId, Integer orgId) {
+	public ResponseBean helpActivity(String mpAppid, String personId, String sponsorPersonId, String drainageId, Integer orgId) {
 		//第一步根据drainggeid查询出红包表对应的记录
 		TaDrainage taDrainage = taDrainageMapper.selectById(drainageId);
 		//第二步查询出这个H5对应的活动
@@ -285,23 +295,36 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 		}
 
 		//查看这个人绑定的小程序用户
-		TaMpMiniapp taMpMiniapp = taMpMiniappMapper.selectOne(new QueryWrapper<TaMpMiniapp>().eq("mp_person_id", mpPersonId));
+		TaMpMiniapp taMpMiniapp = taMpMiniappMapper.selectOne(new QueryWrapper<TaMpMiniapp>().eq("miniapp_person_id", personId));
 
 		//查询被助力者的绑定的小程序用户
-		TaMpMiniapp parentMpMiniapp = taMpMiniappMapper.selectOne(new QueryWrapper<TaMpMiniapp>().eq("mp_person_id", sponsorPersonId));
+		TaMpMiniapp parentMpMiniapp = taMpMiniappMapper.selectOne(new QueryWrapper<TaMpMiniapp>().eq("miniapp_person_id", sponsorPersonId));
 
 		//根据活动id查询这个活动的助力规则
 		TaRedPacketHelp taRedPacketHelp = taRedPacketHelpMapper.selectById(taDrainage.getActivityId());
 		
 		//助力
 		String result = saveRedPacketHistory(taMpMiniapp, parentMpMiniapp, taRedPacketHelp, orgId,mpAppid);
-		if (result.equals("success")){
-			ResponseBean.error(result,ResponseBean.ERROR_ILLEGAL_PARAMS);
+		if (!result.equals("success")){
+			return ResponseBean.error(result,ResponseBean.ERROR_ILLEGAL_PARAMS);
 		}
 
 		return ResponseBean.success(taRedPacketHelp.getSuccessTip());
 	}
 
+	/**
+	 * 获取活动排行榜
+	 *
+	 * @param targetId
+	 * @param orgId
+	 * @return
+	 */
+	@Override
+	public ResponseBean getRanking(String targetId, Integer orgId) {
+
+		return null;
+	}
+
 	private synchronized String saveRedPacketHistory(TaMpMiniapp taMpMiniapp, TaMpMiniapp parentMpMiniapp, TaRedPacketHelp taRedPacketHelp, Integer orgId, String mpAppid) {
 		//查看我是否助力过
 		QueryWrapper<TaRedPacketHistory> queryWrapper = new QueryWrapper();