diff --git a/src/main/java/com/yxt/yyth/biz/lpkcustomer/LpkCustomerMapper.java b/src/main/java/com/yxt/yyth/biz/lpkcustomer/LpkCustomerMapper.java index a3febe4..3b69583 100644 --- a/src/main/java/com/yxt/yyth/biz/lpkcustomer/LpkCustomerMapper.java +++ b/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 { IPage customerListPage(IPage page, @Param(Constants.WRAPPER) QueryWrapper qw); @Select("select * from lpk_customer where sid=#{sid}") LpkCustomerVo getCustomerInfo (@Param("sid")String sid); + @Select("select * from lpk_customer where wxMpOpenid=#{wxMpOpenid}") + List getCustomer(@Param("wxMpOpenid") String wxMpOpenid); } diff --git a/src/main/java/com/yxt/yyth/biz/lpkcustomer/LpkCustomerService.java b/src/main/java/com/yxt/yyth/biz/lpkcustomer/LpkCustomerService.java index c6d5f98..b643711 100644 --- a/src/main/java/com/yxt/yyth/biz/lpkcustomer/LpkCustomerService.java +++ b/src/main/java/com/yxt/yyth/biz/lpkcustomer/LpkCustomerService.java @@ -88,9 +88,10 @@ public class LpkCustomerService extends MybatisBaseService map=new HashMap<>(); // map.put("unionid",unionid); map.put("openid",openid); - LpkCustomer lpkCustomer= baseMapper.selectOne(new QueryWrapper().eq("wxMpOpenid",openid)); +// LpkCustomer lpkCustomer= baseMapper.selectOne(new QueryWrapper().eq("wxMpOpenid",openid)); + List 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