up

src/main/java/com/bsd/say/controller/UsersController.java

@@ -76,4 +76,19 @@ public class UsersController extends BaseController<UsersService, Users>{
         return ajaxResult;
     }
 
+    @RequestMapping(value = "/get-info")
+    @ResponseBody
+    public AjaxResult getUserInfoByOpenId(@RequestBody AjaxRequest ajaxRequest){
+        AjaxResult ajaxResult = new AjaxResult();
+        try {
+            ajaxResult = usersService.getUserInfoByOpenId(ajaxRequest);
+        } catch (Exception e) {
+            e.printStackTrace();
+            String errMsg = e.getMessage() != null ? e.getMessage() : "操作失败";
+            ajaxResult.setRetcode(AjaxResult.FAILED);
+            ajaxResult.setRetmsg(errMsg);
+        }
+        return ajaxResult;
+    }
+
 }

src/main/java/com/bsd/say/service/UsersService.java

@@ -7,4 +7,5 @@ import com.bsd.say.entities.Users;
 public interface UsersService extends BaseService<Users>{
     AjaxResult sendNote(AjaxRequest ajaxRequest);
     AjaxResult isSubscribe(AjaxRequest ajaxRequest);
+    AjaxResult getUserInfoByOpenId(AjaxRequest ajaxRequest);
 }

src/main/java/com/bsd/say/service/impl/UsersServiceImpl.java

@@ -1,13 +1,17 @@
 package com.bsd.say.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.bsd.say.beans.AjaxRequest;
 import com.bsd.say.beans.AjaxResult;
+import com.bsd.say.entities.Record;
 import com.bsd.say.entities.Users;
+import com.bsd.say.mapper.RecordMapper;
 import com.bsd.say.mapper.UsersMapper;
 import com.bsd.say.service.UsersService;
 import com.bsd.say.util.HttpRequestUtils;
 import com.bsd.say.util.MD5Utils;
+import com.sun.org.apache.bcel.internal.generic.NEW;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -38,6 +42,8 @@ public class UsersServiceImpl extends BaseServiceImpl<UsersMapper,Users> impleme
     protected UsersMapper usersMapper;
     @Autowired
     private WeixinService weixinService;
+    @Resource
+    private RecordMapper recordMapper;
 
     @Override
     public UsersMapper getBaseMapper() {
@@ -119,4 +125,38 @@ public class UsersServiceImpl extends BaseServiceImpl<UsersMapper,Users> impleme
         }
     }
 
+    /**
+     * 通过openId获取record中的name 和 phone
+     * @param ajaxRequest
+     * @return
+     */
+    @Override
+    public AjaxResult getUserInfoByOpenId(AjaxRequest ajaxRequest) {
+        AjaxResult ajaxResult = new AjaxResult();
+        JSONObject data = ajaxRequest.getData();
+        if (data == null){
+            ajaxResult.setRetcode(AjaxResult.FAILED);
+            ajaxResult.setRetmsg("data missing");
+            return ajaxResult;
+        }else {
+            String openId = data.getString("openId");
+            if (StringUtils.isBlank(openId)){
+                ajaxResult.setRetcode(AjaxResult.FAILED);
+                ajaxResult.setRetmsg("openId missing");
+                return ajaxResult;
+            }else {
+                JSONObject userInfo = new JSONObject();
+                Record record = recordMapper.selectOne(Wrappers.<Record>lambdaQuery().eq(Record::getOpenId,openId)
+                        .and(queryWrapper1 -> queryWrapper1.eq(Record::getState,1)));
+                if (record != null){
+                    userInfo.put("name",record.getName());
+                    userInfo.put("phone",record.getPhone());
+                }
+                ajaxResult.setData(userInfo);
+                ajaxResult.setRetcode(AjaxResult.SUCCESS);
+            }
+        }
+        return ajaxResult;
+    }
+
 }

src/main/resources/application.yml

@@ -42,7 +42,7 @@ server:
 
 award:
   rule: 5
-  amount: 2
+  amount: 10
 
 wechat:
   aesKey: r4cbRuIfbbnTIgJoQE33vJACJuoioZ5pRAhumITsP8O