1/9

src/main/java/com/yxt/yyth/biz/lpkcustomer/LpkCustomerMapper.java

@@ -10,6 +10,8 @@ import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
 
+import java.util.List;
+
 /**
  * @author wangpengfei
  * @date 2023/11/21 15:03
@@ -20,4 +22,6 @@ public interface LpkCustomerMapper extends BaseMapper<LpkCustomer> {
     IPage<LpkCustomerVo> customerListPage(IPage<LpkCustomer> page, @Param(Constants.WRAPPER) QueryWrapper<LpkCustomer> qw);
     @Select("select * from lpk_customer where sid=#{sid}")
     LpkCustomerVo getCustomerInfo (@Param("sid")String sid);
+    @Select("select * from lpk_customer where wxMpOpenid=#{wxMpOpenid}")
+    List<LpkCustomer> getCustomer(@Param("wxMpOpenid") String wxMpOpenid);
 }

src/main/java/com/yxt/yyth/biz/lpkcustomer/LpkCustomerService.java

@@ -88,9 +88,10 @@ public class LpkCustomerService extends MybatisBaseService<LpkCustomerMapper, Lp
         Map<String,String> map=new HashMap<>();
 //        map.put("unionid",unionid);
         map.put("openid",openid);
-        LpkCustomer lpkCustomer= baseMapper.selectOne(new QueryWrapper<LpkCustomer>().eq("wxMpOpenid",openid));
+//        LpkCustomer lpkCustomer= baseMapper.selectOne(new QueryWrapper<LpkCustomer>().eq("wxMpOpenid",openid));
+        List<LpkCustomer> lpkCustomer= baseMapper.getCustomer(openid);
         //查询用户是否存在
-        if(null==lpkCustomer){
+        if(null==lpkCustomer.get(0)){
             //新增用户
             LpkCustomer newCustomer=new LpkCustomer();
             newCustomer.setWxMpOpenid(openid);
@@ -98,15 +99,18 @@ public class LpkCustomerService extends MybatisBaseService<LpkCustomerMapper, Lp
             newCustomer.setCreateTime(new Date());
             baseMapper.insert(newCustomer);
 //            return rb.setData(newCustomer).setCode("110");
+            StpUtil.login(newCustomer.getId());
+            SaTokenInfo tokenInfo = StpUtil.getTokenInfo();
+            newCustomer.setToken(tokenInfo.getTokenValue());
             return rb.success().setData(newCustomer);
         }
 //        //判断是否绑定手机号
 //        if(StringUtils.isBlank(lpkCustomer.getMobile())){
 //            return rb.setData(lpkCustomer).setCode("110");
 //        }
-        StpUtil.login(lpkCustomer.getId());
+        StpUtil.login(lpkCustomer.get(0).getId());
         SaTokenInfo tokenInfo = StpUtil.getTokenInfo();
-        lpkCustomer.setToken(tokenInfo.getTokenValue());
+        lpkCustomer.get(0).setToken(tokenInfo.getTokenValue());
         return rb.success().setData(lpkCustomer);
     }
     public ResultBean wxBindMobile(WxBindMobileDto wxBindMobileDto) {