123

xx-summit/xx-summit-server/src/main/java/com/xxfc/platform/summit/biz/ActivityBmBiz.java

@@ -7,8 +7,10 @@ import com.github.wxiaoqi.security.common.constant.RestCode;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.xxfc.platform.summit.entity.ActivityBm;
+import com.xxfc.platform.summit.entity.User;
 import com.xxfc.platform.summit.mapper.ActivityBmMapper;;
 import com.xxfc.platform.summit.vo.MeepoActivityVo;
+import io.swagger.models.auth.In;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
@@ -17,6 +19,7 @@ import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 import tk.mybatis.mapper.entity.Example;
 
+import javax.servlet.http.HttpServletRequest;
 import java.util.List;
 
 /**
@@ -29,6 +32,9 @@ public class ActivityBmBiz extends BaseBiz<ActivityBmMapper, ActivityBm> {
     @Autowired
     private RedisTemplate summbitRedisTemplate;
 
+    @Autowired
+    private  UserBiz userBiz;
+
 
   //用户报名
     public  ObjectRestResponse userBm(ActivityBm activityBm,Integer meepoUserId)throws  Exception{
@@ -42,10 +48,7 @@ public class ActivityBmBiz extends BaseBiz<ActivityBmMapper, ActivityBm> {
         if (activityId==null||activityId==0){
             return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,"活动不存在");
         }
-        Example example =new Example(ActivityBm.class);
-        example.createCriteria().andEqualTo("meepoUserId",meepoUserId).andEqualTo("activityId",activityId).andEqualTo("isDel",0);
-        List<ActivityBm> list=mapper.selectByExample(example);
-        if (list.size()>0){
+        if (checkUserBm(meepoUserId,activityId)==null){
             log.info("----用户已报名---meepoUserId==="+meepoUserId);
             return ObjectRestResponse.createFailedResult(ResultCode.EXIST_CODE,"用户已报名");
         }
@@ -68,12 +71,69 @@ public class ActivityBmBiz extends BaseBiz<ActivityBmMapper, ActivityBm> {
         }
         ActivityBm bm =new ActivityBm();
         String json = summbitRedisTemplate.opsForValue().get(redisLockKey) == null ? "" : summbitRedisTemplate.opsForValue().get(redisLockKey).toString();
-        log.error("userBm接口，获取redis中的报名信息：" + json);
+        log.info("userBm接口，获取redis中的报名信息：" + json);
+        if (StringUtils.isBlank(json)){
+            return  null;
+        }
         JSONObject jsonObject= JSONObject.parseObject(json);
         BeanUtils.copyProperties(jsonObject,bm);
         return  bm;
     }
 
+    public  ActivityBm checkUserBm(Integer meepoUserId,Integer activityId ){
+        Example example =new Example(ActivityBm.class);
+        example.createCriteria().andEqualTo("meepoUserId",meepoUserId).andEqualTo("activityId",activityId).andEqualTo("isDel",0);
+        List<ActivityBm> list=mapper.selectByExample(example);
+        if (list.size()>0){
+            return  list.get(0);
+        }
+        return null;
+    }
+
+
+    public  JSONObject  userBmByKey(String key,Integer activityId, HttpServletRequest request)throws  Exception{
+        JSONObject jsonObject=new JSONObject();
+        jsonObject.put("isbm",0);
+        jsonObject.put("value","");
+        User user=userBiz.getSession(request);
+        //是否登录
+        log.info("-----userBmByKey---activityId==="+activityId);
+        if (user==null){
+            log.info("-----userBmByKey---用户未登录----");
+            ActivityBm activityBm= userInfo(key);
+            if (activityBm!=null){
+                log.info("-----userBmByKey---key已存在----");
+                jsonObject.put("value",activityBm);
+                // 获取到缓存的验证码后要先清空缓存对应键的值
+                summbitRedisTemplate.delete(key);
+            }
+        }else {
+            Integer userId=user.getId();
+            log.info("-----userBmByKey---用户登录--userId==="+userId);
+            ActivityBm activityBm= userInfo(key);
+            if (activityBm==null){
+                log.info("-----userBmByKey---key不存在判断用户是否报名----");
+                if (checkUserBm(userId,activityId)!=null){
+                    log.info("-----userBmByKey---key不存在用户已报名----");
+                    jsonObject.put("isbm",1);
+                }
+            }else {
+                log.info("-----userBmByKey---key已存在去报名----");
+                ObjectRestResponse restResponse=userBm(activityBm,userId);
+                if (restResponse.getStatus()==RestCode.SUCCESS.getStatus()){
+                    log.info("-----userBmByKey---key已存在去报名----报名成功");
+                    jsonObject.put("isbm",1);
+                    jsonObject.put("bmStatus",1);
+                }else {
+                    log.info("-----userBmByKey---key已存在去报名----报名失败");
+                    jsonObject.put("bmStatus",2);
+                }
+                summbitRedisTemplate.delete(key);
+            }
+        }
+        return  jsonObject;
+    }
+
 
 
 }

xx-summit/xx-summit-server/src/main/java/com/xxfc/platform/summit/biz/UserBiz.java

@@ -87,6 +87,7 @@ public class UserBiz extends BaseBiz<UserMapper, User> {
         }
         return userId;
     }
+
     public  void  authUser(String code,String key, HttpServletRequest request){
         if (StringUtils.isBlank(code)){
             log.info("----code为空---");