新需求 H5活动的外部接口

src/main/java/com/huiju/estateagents/drainage/entity/TaDrainage.java

@@ -86,4 +86,14 @@ public class TaDrainage implements Serializable {
     @TableField(exist = false)
     private String appSecret;
 
+    /**
+     * 对应的H5的活动类型
+     */
+    private String activityType;
+
+    /**
+     * 对应的H5的活动id
+     */
+    private String activityId;
+
 }

src/main/java/com/huiju/estateagents/redpack/entity/TaMpPerson.java

@@ -45,7 +45,7 @@ public class TaMpPerson implements Serializable {
     /**
      * 性别
      */
-    private Boolean sex;
+    private Integer sex;
 
     /**
      * 省份

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

@@ -1,17 +1,19 @@
 package com.huiju.estateagents.third.controller;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.common.WxMpUtils;
+import com.huiju.estateagents.redpack.entity.TaMpPerson;
+import com.huiju.estateagents.third.entity.TaThirdPartyMiniappConfig;
+import com.huiju.estateagents.third.service.ITaThirdPartyMiniappConfigService;
 import lombok.AllArgsConstructor;
 import me.chanjar.weixin.common.error.WxErrorException;
 import me.chanjar.weixin.mp.api.WxMpService;
 import me.chanjar.weixin.mp.bean.result.WxMpOAuth2AccessToken;
 import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
 
@@ -24,31 +26,64 @@ import javax.servlet.http.HttpServletRequest;
 public class WxRedpackController {
     public WxMpUtils wxMpUtils;
 
+    @Autowired
+    public ITaThirdPartyMiniappConfigService iTaThirdPartyMiniappConfigService;
+
     /**
      * 换取openid接口并插入公众号人员表
-     * @param appid
+     * @param mpAppid
      * @param code
      * @param request
      * @return
      */
-    @GetMapping("/third/redirect/{appid}/greet")
-    public ResponseBean greetUser(@PathVariable String appid, @RequestParam String code, HttpServletRequest request) {
+    @GetMapping("/third/redirect/{mpAppid}/greet")
+    public ResponseBean greetUser(@PathVariable String mpAppid, @RequestParam String code, @RequestParam String personId, HttpServletRequest request) {
         WxMpService wxService = wxMpUtils.wxMpService();
-        if (!wxService.switchover(appid)) {
-            throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", appid));
+        if (!wxService.switchover(mpAppid)) {
+            throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", mpAppid));
         }
-        String openId = null;
+        TaMpPerson taMpPerson = new TaMpPerson();
         try {
             //换取openid
             WxMpOAuth2AccessToken accessToken = wxService.oauth2getAccessToken(code);
             WxMpUser user = wxService.oauth2getUserInfo(accessToken, null);
-            openId = user.getOpenId();
-            //插入公众号人员信息并插入表
 
+            //获取H5项目相关信息
+            String xAppid = request.getHeader("x-appid");
+             //获取小程序appid
+            String miniAppid = request.getHeader("appid");
+            //插入公众号人员信息并插入表
+            taMpPerson = iTaThirdPartyMiniappConfigService.newMpPerson(user, mpAppid, xAppid, miniAppid, personId);
         } catch (WxErrorException e) {
             e.printStackTrace();
         }
+        return ResponseBean.success(taMpPerson);
+    }
 
-        return ResponseBean.success(openId);
+    /**
+     * 我要参加 活动接口
+     * @param mpAppid
+     * @param mpPersonId
+     * @param request
+     * @return
+     */
+    @PostMapping("/third/activity/{mpAppid}/participate")
+    public ResponseBean participateActivity(@PathVariable String mpAppid, @RequestParam String mpPersonId, HttpServletRequest request) {
+        //获取H5项目相关信息
+        String xAppid = request.getHeader("x-appid");
+        QueryWrapper<TaThirdPartyMiniappConfig> taThirdPartyMiniappConfigQueryWrapper = new QueryWrapper<>();
+
+        taThirdPartyMiniappConfigQueryWrapper.eq("appid", xAppid);
+        TaThirdPartyMiniappConfig taThirdPartyMiniappConfig = iTaThirdPartyMiniappConfigService.getOne(taThirdPartyMiniappConfigQueryWrapper);
+        if (null == taThirdPartyMiniappConfig){
+            return ResponseBean.error("不存在的H5活动",ResponseBean.ERROR_UNAVAILABLE);
+        }
+        try {
+            ResponseBean res = iTaThirdPartyMiniappConfigService.participateActivity(mpAppid,mpPersonId,taThirdPartyMiniappConfig.getTargetId(),taThirdPartyMiniappConfig.getOrgId());
+            return res;
+        }catch (Exception e){
+            e.printStackTrace();
+            return ResponseBean.error("程序出错请联系运营人员",ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
     }
 }

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

@@ -1,7 +1,10 @@
 package com.huiju.estateagents.third.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.redpack.entity.TaMpPerson;
 import com.huiju.estateagents.third.entity.TaThirdPartyMiniappConfig;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
 
 /**
  * <p>
@@ -21,4 +24,22 @@ public interface ITaThirdPartyMiniappConfigService extends IService<TaThirdParty
 	 * @return
 	 */
 	String checkToken(String tokenHeader, String appidHeader, String nowHeader);
+
+	/**
+	 * 创建公众号人员并关联上小程序人员
+	 * @param user
+	 * @param xAppid
+	 * @param miniAppid
+	 * @param personId
+	 */
+	TaMpPerson newMpPerson(WxMpUser user, String mpAppid, String xAppid, String miniAppid, String personId);
+
+	/**
+	 * 参加活动生成参与记录等
+	 * @param mpAppid
+	 * @param mpPersonId
+	 * @param targetId
+	 * @param orgId
+	 */
+	ResponseBean participateActivity(String mpAppid, String mpPersonId, String targetId, Integer orgId);
 }

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

@@ -2,10 +2,23 @@ package com.huiju.estateagents.third.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.common.MD5Utils;
+import com.huiju.estateagents.drainage.entity.TaDrainage;
+import com.huiju.estateagents.drainage.mapper.TaDrainageMapper;
+import com.huiju.estateagents.redpack.entity.TaMpMiniapp;
+import com.huiju.estateagents.redpack.entity.TaMpPerson;
+import com.huiju.estateagents.redpack.entity.TaRedPacket;
+import com.huiju.estateagents.redpack.entity.TaRedPacketPerson;
+import com.huiju.estateagents.redpack.mapper.TaMpMiniappMapper;
+import com.huiju.estateagents.redpack.mapper.TaMpPersonMapper;
+import com.huiju.estateagents.redpack.mapper.TaRedPacketMapper;
+import com.huiju.estateagents.redpack.mapper.TaRedPacketPersonMapper;
 import com.huiju.estateagents.third.entity.TaThirdPartyMiniappConfig;
 import com.huiju.estateagents.third.mapper.TaThirdPartyMiniappConfigMapper;
 import com.huiju.estateagents.third.service.ITaThirdPartyMiniappConfigService;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -24,7 +37,22 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 	
 	@Autowired
 	private TaThirdPartyMiniappConfigMapper taThirdPartyMiniappConfigMapper;
-	
+
+	@Autowired
+	private TaMpPersonMapper taMpPersonMapper;
+
+	@Autowired
+	private TaMpMiniappMapper taMpMiniappMapper;
+
+	@Autowired
+	private TaDrainageMapper taDrainageMapper;
+
+	@Autowired
+	private TaRedPacketMapper taRedPacketMapper;
+
+	@Autowired
+	private TaRedPacketPersonMapper taRedPacketPersonMapper;
+
 	/**
 	 * 校验是否合法第三方接口调用
 	 *
@@ -58,4 +86,95 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 		
 		return "success";
 	}
+
+	/**
+	 * 创建公众号人员并关联上小程序人员
+	 *
+	 * @param user
+	 * @param xAppid
+	 * @param miniAppid
+	 * @param personId
+	 */
+	@Override
+	public TaMpPerson newMpPerson(WxMpUser user,String mpAppid, String xAppid, String miniAppid, String personId) {
+		//查询这个人员是否存在
+		TaMpPerson mpPerson = taMpPersonMapper.selectOne(new QueryWrapper<TaMpPerson>().eq("mp_openid", user.getOpenId()));
+		//不存在就新建
+		if (null == mpPerson){
+			//新增入公众号人员表
+			TaMpPerson taMpPerson = new TaMpPerson();
+			taMpPerson.setAppid(mpAppid);
+			taMpPerson.setCity(user.getCity());
+			taMpPerson.setCountry(user.getCountry());
+			taMpPerson.setCreateDate(LocalDateTime.now());
+			taMpPerson.setHeadimgurl(user.getHeadImgUrl());
+			taMpPerson.setMpOpenid(user.getOpenId());
+			taMpPerson.setMpPersonId(personId);
+			taMpPerson.setNickname(user.getNickname());
+			taMpPerson.setProvince(user.getProvince());
+			taMpPerson.setSex(user.getSex());
+			taMpPerson.setStatus(CommConstant.STATUS_NORMAL);
+			taMpPersonMapper.insert(taMpPerson);
+			mpPerson = taMpPerson;
+		}
+
+		//查看这个人是否绑定了小程序用户
+		TaMpMiniapp taMpMiniapp = taMpMiniappMapper.selectOne(new QueryWrapper<TaMpMiniapp>().eq("mp_person_id", mpPerson.getMpPersonId()).eq("miniapp_person_id", personId));
+		if (null == taMpMiniapp){
+			taMpMiniapp = new TaMpMiniapp();
+			taMpMiniapp.setMpPersonId(mpPerson.getMpPersonId());
+			taMpMiniapp.setMiniappPersonId(personId);
+			taMpMiniappMapper.insert(taMpMiniapp);
+		}
+
+		return mpPerson;
+	}
+
+	/**
+	 * 参加活动生成参与记录等
+	 *
+	 * @param mpAppid 公众号appid
+	 * @param mpPersonId 公众号人员id
+	 * @param drainageId H5活动id
+	 * @param orgId 小程序id
+	 */
+	@Override
+	public ResponseBean participateActivity(String mpAppid, String mpPersonId, String drainageId, Integer orgId) {
+		//第一步根据drainggeid查询出红包表对应的记录
+		TaDrainage taDrainage = taDrainageMapper.selectById(drainageId);
+		//第二步查询出这个H5对应的活动
+		TaRedPacket taRedPacket = taRedPacketMapper.selectById(taDrainage.getActivityId());
+		//判断这个活动的过期时间
+		if (LocalDateTime.now().isAfter(taRedPacket.getEndDate())){
+			return ResponseBean.error(taRedPacket.getActivityEndTip(),ResponseBean.ERROR_ILLEGAL_PARAMS);
+		}
+		if (LocalDateTime.now().isBefore(taRedPacket.getStartDate())){
+			return ResponseBean.error("此活动未开始",ResponseBean.ERROR_ILLEGAL_PARAMS);
+		}
+
+		//查看这个人绑定的小程序用户
+		TaMpMiniapp taMpMiniapp = taMpMiniappMapper.selectOne(new QueryWrapper<TaMpMiniapp>().eq("mp_person_id", mpPersonId));
+
+		//查看此人是否参加过活动如果参加过直接返回
+		QueryWrapper<TaRedPacketPerson> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("activity_id",taRedPacket.getActivityId());
+		queryWrapper.eq("org_id",orgId);
+		queryWrapper.eq("mp_person_id",mpPersonId);
+		queryWrapper.eq("miniapp_person_id",taMpMiniapp.getMiniappPersonId());
+		TaRedPacketPerson redPacketPerson = taRedPacketPersonMapper.selectOne(queryWrapper);
+		if (null != redPacketPerson){
+			return ResponseBean.success(redPacketPerson);
+		}
+
+		//参与活动
+		TaRedPacketPerson taRedPacketPerson = new TaRedPacketPerson();
+		taRedPacketPerson.setActivityId(taRedPacket.getActivityId());
+		taRedPacketPerson.setCreateDate(LocalDateTime.now());
+		taRedPacketPerson.setIsSignedUp(true);
+		taRedPacketPerson.setMiniappPersonId(taMpMiniapp.getMiniappPersonId());
+		taRedPacketPerson.setMpPersonId(mpPersonId);
+		taRedPacketPerson.setOrgId(orgId);
+		taRedPacketPersonMapper.insert(taRedPacketPerson);
+		return ResponseBean.success(taRedPacketPerson);
+	}
 }