diff --git a/jsowell-admin/src/main/java/com/jsowell/service/MemberService.java b/jsowell-admin/src/main/java/com/jsowell/service/MemberService.java index cc0c93965..c80d27ded 100644 --- a/jsowell-admin/src/main/java/com/jsowell/service/MemberService.java +++ b/jsowell-admin/src/main/java/com/jsowell/service/MemberService.java @@ -33,7 +33,6 @@ import com.jsowell.pile.dto.*; import com.jsowell.pile.service.*; import com.jsowell.pile.transaction.dto.MemberTransactionDTO; import com.jsowell.pile.transaction.service.TransactionService; -import com.jsowell.pile.vo.base.StationInfoVO; import com.jsowell.pile.vo.uniapp.*; import com.jsowell.wxpay.service.WxAppletRemoteService; import org.apache.commons.collections4.CollectionUtils; @@ -121,7 +120,6 @@ public class MemberService { public String memberRegisterAndLogin(MemberRegisterAndLoginDTO dto) { // 校验短信验证码 两种情况不能通过校验,1-验证码错误;2-超时 验证码10分钟有效 checkVerificationCode(dto); - String merchantId = ""; return memberRegisterAndLogin(dto.getMobileNumber(), dto.getMerchantId(), dto.getOpenId()); } @@ -139,7 +137,7 @@ public class MemberService { // throw new BusinessException(ReturnCodeEnum.CODE_GET_MERCHANT_ID_BY_APP_ID_ERROR); // } // 查询手机号码是否注册过 - MemberBasicInfo memberBasicInfo = memberBasicInfoService.selectInfoByMobileNumberAndMerchantId(phoneNumber, merchantId); + MemberBasicInfo memberBasicInfo = memberBasicInfoService.selectInfoByMobileNumber(phoneNumber); if (Objects.isNull(memberBasicInfo)) { // 不存在则新增数据 String memberId = generateNewMemberId(); @@ -148,7 +146,7 @@ public class MemberService { memberBasicInfo.setMemberId(memberId); memberBasicInfo.setNickName("会员" + memberId); memberBasicInfo.setMobileNumber(phoneNumber); - memberBasicInfo.setMerchantId(Long.valueOf(merchantId)); + // memberBasicInfo.setMerchantId(Long.valueOf(merchantId)); memberBasicInfo.setOpenId(openId); // 首次新建会员,同时新建会员钱包 @@ -192,7 +190,7 @@ public class MemberService { throw new BusinessException(ReturnCodeEnum.CODE_GET_MOBILE_NUMBER_BY_CODE_ERROR); } // 通过appid获取运营商id - String merchantId = pileMerchantInfoService.getMerchantIdByAppId(dto.getAppId()); + // String merchantId = pileMerchantInfoService.getMerchantIdByAppId(dto.getAppId()); // if (Objects.isNull(merchantId)) { // throw new BusinessException(ReturnCodeEnum.CODE_GET_MERCHANT_ID_BY_APP_ID_ERROR); // } @@ -204,7 +202,7 @@ public class MemberService { log.error("getOpenIdByCode发生异常", e); } // 查询手机号码是否注册过 - return memberRegisterAndLogin(mobileNumber, merchantId, openId); + return memberRegisterAndLogin(mobileNumber, null, openId); } /** diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileMerchantInfoMapper.java b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileMerchantInfoMapper.java index 736c6d36b..c57aa7787 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileMerchantInfoMapper.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileMerchantInfoMapper.java @@ -27,7 +27,7 @@ public interface PileMerchantInfoMapper { * @param appId * @return */ - PileMerchantInfo selectPileMerchantInfoByAppId(String appId); + List selectPileMerchantInfoByAppId(String appId); /** * 查询充电桩运营商信息列表 diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/IMemberBasicInfoService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/IMemberBasicInfoService.java index 84c6de8f0..efdb63519 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/IMemberBasicInfoService.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/IMemberBasicInfoService.java @@ -73,7 +73,7 @@ public interface IMemberBasicInfoService { * @param merchantId 运营商id * @return 会员信息 */ - MemberBasicInfo selectInfoByMobileNumberAndMerchantId(String phone, String merchantId); + MemberBasicInfo selectInfoByMobileNumber(String phone, String merchantId); /** * 根据手机号查询会员信息 diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/IPileMerchantInfoService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/IPileMerchantInfoService.java index e28749b15..eb3fd294a 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/IPileMerchantInfoService.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/IPileMerchantInfoService.java @@ -64,6 +64,8 @@ public interface IPileMerchantInfoService { String getMerchantIdByAppId(String appId); + List getMerchantIdsByAppId(String appId); + MerchantInfoVO getMerchantInfo(String merchantId); /** diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/MemberBasicInfoServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/MemberBasicInfoServiceImpl.java index 057307ab4..63bed2157 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/MemberBasicInfoServiceImpl.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/MemberBasicInfoServiceImpl.java @@ -137,13 +137,14 @@ public class MemberBasicInfoServiceImpl implements IMemberBasicInfoService { * @param merchantId 运营商id * @return 会员信息 */ - public MemberBasicInfo selectInfoByMobileNumberAndMerchantId(String mobileNumber, String merchantId) { + @Override + public MemberBasicInfo selectInfoByMobileNumber(String mobileNumber, String merchantId) { return memberBasicInfoMapper.selectInfoByMobileNumberAndMerchantId(mobileNumber, merchantId); } @Override public MemberBasicInfo selectInfoByMobileNumber(String mobileNumber) { - return selectInfoByMobileNumberAndMerchantId(mobileNumber, null); + return selectInfoByMobileNumber(mobileNumber, null); } @Override diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileMerchantInfoServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileMerchantInfoServiceImpl.java index c371bbf0b..0feaaf721 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileMerchantInfoServiceImpl.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileMerchantInfoServiceImpl.java @@ -26,6 +26,7 @@ import org.springframework.transaction.annotation.Transactional; import java.util.List; import java.util.Objects; +import java.util.stream.Collectors; /** * 充电桩运营商信息Service业务层处理 @@ -248,9 +249,9 @@ public class PileMerchantInfoServiceImpl implements IPileMerchantInfoService { return null; } try { - PileMerchantInfo pileMerchantInfo = pileMerchantInfoMapper.selectPileMerchantInfoByAppId(appId); - if (pileMerchantInfo != null) { - return pileMerchantInfo.getId().toString(); + List pileMerchantInfos = pileMerchantInfoMapper.selectPileMerchantInfoByAppId(appId); + if (CollectionUtils.isNotEmpty(pileMerchantInfos)) { + return pileMerchantInfos.get(0).getId().toString(); } } catch (Exception e) { log.error("通过appid获取运营商id error", e); @@ -258,6 +259,23 @@ public class PileMerchantInfoServiceImpl implements IPileMerchantInfoService { return null; } + @Override + public List getMerchantIdsByAppId(String appId) { + if (StringUtils.isBlank(appId)) { + return null; + } + List resultList = Lists.newArrayList(); + try { + List pileMerchantInfos = pileMerchantInfoMapper.selectPileMerchantInfoByAppId(appId); + if (CollectionUtils.isNotEmpty(pileMerchantInfos)) { + resultList = pileMerchantInfos.stream().map(x -> String.valueOf(x.getId())).collect(Collectors.toList()); + } + } catch (Exception e) { + log.error("通过appid获取运营商ids error", e); + } + return resultList; + } + @Override public MerchantInfoVO getMerchantInfo(String merchantId) { PileMerchantInfo pileMerchantInfo = selectPileMerchantInfoById(Long.parseLong(merchantId));