package cc.mrbird.febs.mall.service.impl; import cc.mrbird.febs.common.entity.FebsResponse; import cc.mrbird.febs.common.enumerates.DataDictionaryEnum; import cc.mrbird.febs.common.enumerates.FlowTypeEnum; import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum; import cc.mrbird.febs.common.enumerates.ScoreFlowTypeEnum; import cc.mrbird.febs.common.exception.FebsException; import cc.mrbird.febs.common.properties.XcxProperties; import cc.mrbird.febs.common.utils.*; import cc.mrbird.febs.mall.conversion.MallMemberConversion; import cc.mrbird.febs.mall.conversion.MallShopApplyConversion; import cc.mrbird.febs.mall.conversion.MallStoreConversion; import cc.mrbird.febs.mall.dto.*; import cc.mrbird.febs.mall.entity.*; import cc.mrbird.febs.mall.mapper.*; import cc.mrbird.febs.mall.service.*; import cc.mrbird.febs.mall.vo.*; import cc.mrbird.febs.pay.model.BrandWCPayRequestData; import cc.mrbird.febs.pay.service.IXcxPayService; import cc.mrbird.febs.pay.util.MD5; import cc.mrbird.febs.vip.VipSettingUnAliveSettingBo; import cc.mrbird.febs.vip.entity.MallVipConfig; import cc.mrbird.febs.vip.mapper.MallVipConfigMapper; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUnit; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.crypto.SecureUtil; import cn.hutool.crypto.asymmetric.KeyType; import cn.hutool.crypto.asymmetric.RSA; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; import org.springframework.http.HttpStatus; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.io.IOException; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; /** * @author wzy * @date 2021-09-16 **/ @Slf4j @Service @RequiredArgsConstructor public class ApiMallMemberServiceImpl extends ServiceImpl implements IApiMallMemberService { private final MallMemberWalletMapper mallMemberWalletMapper; private final ICommonService commonService; private final RedisUtils redisUtils; private final MallOrderInfoMapper mallOrderInfoMapper; private final MallShoppingCartMapper mallShoppingCartMapper; private final MallMoneyFlowMapper mallMoneyFlowMapper; private final IApiMallMemberWalletService walletService; private final MallMemberPaymentMapper mallMemberPaymentMapper; private final DataDictionaryCustomMapper dataDictionaryCustomMapper; private final MallShopApplyMapper mallShopApplyMapper; private final MallRegisterAppealMapper mallRegisterAppealMapper; private final MallTeamLeaderMapper mallTeamLeaderMapper; private final SpringContextHolder springContextHolder; private final MallAgentRecordMapper mallAgentRecordMapper; private final IMallMoneyFlowService mallMoneyFlowService; private final IMallMemberCollectionService mallMemberCollectionService; private final IMallMemberFootprintService mallMemberFootprintService; private final SalemanCouponMapper salemanCouponMapper; private final CouponGoodsMapper couponGoodsMapper; private final MallGoodsCouponMapper mallGoodsCouponMapper; private final MallMemberCouponMapper mallMemberCouponMapper; private final MallGoodsMapper mallGoodsMapper; private final MallVipConfigMapper mallVipConfigMapper; private final MallStoreMapper mallStoreMapper; private final MallStoreItemMapper mallStoreItemMapper; private final MallStoreMemberMapper mallStoreMemberMapper; private final MallDoctorMapper mallDoctorMapper; @Value("${spring.profiles.active}") private String active; @Transactional(rollbackFor = Exception.class) @Override public FebsResponse register(RegisterDto registerDto) { MallMember mallMember = this.baseMapper.selectInfoByAccount(registerDto.getAccount()); if (mallMember != null) { throw new FebsException("该账号已被占用"); } List mallMembers = this.baseMapper.selectMemberByName(registerDto.getName()); if (CollUtil.isNotEmpty(mallMembers)) { MallRegisterAppeal registerAppeal = mallRegisterAppealMapper.selectByPhoneAndName(registerDto.getName(), registerDto.getAccount()); if (registerAppeal == null || registerAppeal.getStatus() != 1) { return new FebsResponse().code(HttpStatus.ACCEPTED).message("用户名已存在"); } } String account = registerDto.getAccount(); if (!"admin".equals(registerDto.getRegistType())) { String code = registerDto.getCode(); boolean flags = commonService.verifyCode(account, code); if (!flags) { throw new FebsException("验证码错误"); } } mallMember = new MallMember(); mallMember.setPassword(SecureUtil.md5(registerDto.getPassword())); // 判断账号类型 if (AppContants.ACCOUNT_TYPE_MOBILE.equals(registerDto.getType())) { mallMember.setPhone(registerDto.getAccount()); } else { mallMember.setEmail(registerDto.getAccount()); } Integer count = this.baseMapper.selectCount(null); if (count != null && count != 0) { MallMember inviteMember = this.baseMapper.selectInfoByInviteId(registerDto.getInviteId()); if (inviteMember == null) { throw new FebsException("邀请码不存在"); } mallMember.setReferrerId(registerDto.getInviteId()); } mallMember.setName(registerDto.getName()); mallMember.setAccountStatus(MallMember.ACCOUNT_STATUS_ENABLE); mallMember.setAccountType(MallMember.ACCOUNT_TYPE_NORMAL); mallMember.setSex("男"); mallMember.setBindPhone(registerDto.getAccount()); this.baseMapper.insert(mallMember); String inviteId = ShareCodeUtil.toSerialCode(mallMember.getId()); mallMember.setInviteId(inviteId); //推荐人和推荐人链 boolean flag = false; String parentId = mallMember.getReferrerId(); if (StrUtil.isBlank(parentId)) { flag = true; } String ids = ""; while (!flag) { if (StrUtil.isBlank(ids)) { ids += parentId; } else { ids += ("," + parentId); } MallMember parentMember = this.baseMapper.selectInfoByInviteId(parentId); if (parentMember == null) { break; } parentId = parentMember.getReferrerId(); if (StrUtil.isBlank(parentMember.getReferrerId())) { flag = true; } } if (StrUtil.isNotBlank(ids)) { mallMember.setReferrerIds(ids); } this.baseMapper.updateById(mallMember); MallMemberWallet wallet = new MallMemberWallet(); wallet.setBalance(BigDecimal.ZERO); wallet.setMemberId(mallMember.getId()); mallMemberWalletMapper.insert(wallet); return new FebsResponse().success().message("注册成功"); } @Override public FebsResponse toLogin(LoginDto loginDto) { String md5Pwd = SecureUtil.md5(loginDto.getPassword()); MallMember mallMember = this.baseMapper.selectInfoByAccountAndPwd(loginDto.getAccount(), md5Pwd); if (mallMember == null) { throw new FebsException("用户不存在或账号密码错误"); } if (MallMember.ACCOUNT_STATUS_DISABLED.equals(mallMember.getAccountStatus())) { throw new FebsException("该账号存在异常, 暂限制登录"); } String redisKey = AppContants.APP_LOGIN_PREFIX + mallMember.getId(); String existToken = redisUtils.getString(redisKey); if (StrUtil.isNotBlank(existToken)) { Object o = redisUtils.get(existToken); if (ObjectUtil.isNotEmpty(o)) { redisUtils.del(existToken); } } String token = IdUtil.simpleUUID(); redisUtils.set(token, JSONObject.toJSONString(mallMember), 360000); redisUtils.set(redisKey, token, 360000); Map authInfo = new HashMap<>(); authInfo.put("token", token); authInfo.put("rasToken", generateAsaToken(token)); return new FebsResponse().success().data(authInfo); } public String generateAsaToken(String token) { RSA rsa = new RSA(null, AppContants.PUBLIC_KEY); // return rsa.encryptBase64(token + "_" + System.currentTimeMillis(), KeyType.PublicKey); //去掉时间戳 return rsa.encryptBase64(token, KeyType.PublicKey); } @Override public FebsResponse forgetPwd(ForgetPwdDto forgetPwdDto) { MallMember mallMember = this.baseMapper.selectInfoByAccount(forgetPwdDto.getAccount()); if (mallMember == null) { throw new FebsException("账号不存在"); } boolean b = commonService.verifyCode(forgetPwdDto.getAccount(), forgetPwdDto.getCode()); if (!b) { throw new FebsException("验证码错误"); } String pwd = SecureUtil.md5(forgetPwdDto.getPassword()); mallMember.setPassword(pwd); this.baseMapper.updateById(mallMember); return new FebsResponse().success().message("重置成功"); } @Override public FebsResponse logout() { Long id = LoginUserUtil.getLoginUser().getId(); String redisKey = AppContants.XCX_LOGIN_PREFIX + id; String existToken = redisUtils.getString(redisKey); if (StrUtil.isNotBlank(existToken)) { Object o = redisUtils.get(existToken); if (ObjectUtil.isNotEmpty(o)) { redisUtils.del(existToken); } } redisUtils.del(AppContants.XCX_LOGIN_PREFIX + id); redisUtils.del(AppContants.XCX_LOGIN_PHONE_PREFIX + id); return new FebsResponse().success().message("退出登录"); } @Override public FebsResponse findMemberInfo() { Long id = LoginUserUtil.getLoginUser().getId(); MallMember mallMember = this.baseMapper.selectById(id); MallMemberVo mallMemberVo = MallMemberConversion.INSTANCE.entityToVo(mallMember); if(StrUtil.isNotEmpty(mallMember.getReferrerId())){ MallMember referMember = this.baseMapper.selectInfoByInviteId(mallMember.getReferrerId()); if (referMember != null) { mallMemberVo.setReferrerName(referMember.getName()); } } if (StrUtil.isNotBlank(mallMember.getTradePassword())) { mallMemberVo.setHasTradePwd(1); } MallMemberPayment payment = mallMemberPaymentMapper.selectByMemberId(id); if (payment != null) { mallMemberVo.setHasPayment(1); } MemberCollectionListDto memberCollectionListDto = new MemberCollectionListDto(); memberCollectionListDto.setPageNow(1); memberCollectionListDto.setPageSize(10); List collectionList = mallMemberCollectionService.findMemberCollectionList(memberCollectionListDto); mallMemberVo.setCollectionCnt(CollUtil.isNotEmpty(collectionList) ? collectionList.size() : 0); MemberFootprintListDto memberFootprintListDto = new MemberFootprintListDto(); memberFootprintListDto.setPageNow(1); memberFootprintListDto.setPageSize(10); List footprintList = mallMemberFootprintService.findMemberFootprintList(memberFootprintListDto); mallMemberVo.setFootprintCnt(CollUtil.isNotEmpty(footprintList) ? footprintList.size() : 0); List mallMembers = this.baseMapper.selectByRefererId(mallMember.getInviteId()); mallMemberVo.setChildCnt(CollUtil.isNotEmpty(mallMembers) ? mallMembers.size() : 0); MallMemberWallet wallet = mallMemberWalletMapper.selectWalletByMemberId(mallMemberVo.getId()); MallVipConfig mallVipConfig = mallVipConfigMapper.selectVipConfigByCode(mallMember.getLevel()); mallMemberVo.setVipInfo(mallVipConfig); mallMemberVo.setBalance(wallet.getBalance()); // mallMemberVo.setScore(wallet.getScore()); mallMemberVo.setPrizeScore(wallet.getPrizeScore()); // mallMemberVo.setTotalCost(mallOrderInfoMapper.selectTotalAmount(id)); return new FebsResponse().success().data(mallMemberVo); } @Override public FebsResponse findMemberMarkCnt() { Long id = LoginUserUtil.getLoginUser().getId(); List> maps = mallOrderInfoMapper.selectMemberOrderStatusCnt(id); Map orderCnt = new HashMap<>(); if (CollUtil.isNotEmpty(maps)) { for (Map map : maps) { orderCnt.put(map.get("status"), map.get("cnt")); } } List carts = mallShoppingCartMapper.selectCartGoodsList(id, 1); Map result = new HashMap<>(); result.put("order", orderCnt); result.put("carts", carts.size()); return new FebsResponse().success().data(result); } @Override public FebsResponse setTradePwd(ForgetPwdDto forgetPwdDto) { MallMember memberId = LoginUserUtil.getLoginUser(); MallMember mallMember = this.baseMapper.selectById(memberId); if (mallMember == null) { throw new FebsException("账号不存在"); } boolean b = commonService.verifyCode(forgetPwdDto.getAccount(), forgetPwdDto.getCode()); if (!b) { throw new FebsException("验证码错误"); } mallMember.setTradePassword(SecureUtil.md5(forgetPwdDto.getPassword())); this.baseMapper.updateById(mallMember); return new FebsResponse().success().message("设置成功"); } @Override public FebsResponse modifyMemberInfo(ModifyMemberInfoDto modifyMemberInfoDto) { MallMember member = LoginUserUtil.getLoginUser(); MallMember mallMember = this.baseMapper.selectById(member.getId()); if (StrUtil.isNotBlank(modifyMemberInfoDto.getName())) { mallMember.setName(modifyMemberInfoDto.getName()); } if (StrUtil.isNotBlank(modifyMemberInfoDto.getPhoto())) { mallMember.setAvatar(modifyMemberInfoDto.getPhoto()); } this.baseMapper.updateById(mallMember); return new FebsResponse().success().message("修改成功"); } @Override public FebsResponse teamList(TeamListDto teamListDto) { Long memberId = null; if (teamListDto.getId() == null) { memberId = LoginUserUtil.getLoginUser().getId(); } else { memberId = teamListDto.getId(); } MallMember mallMember = this.baseMapper.selectById(memberId); List list = this.baseMapper.selectTeamListByInviteId(mallMember.getInviteId()); MyTeamVo myTeamVo = new MyTeamVo(); myTeamVo.setTeam(list); myTeamVo.setMyAchieve(this.mallOrderInfoMapper.selectAmountOrTeamAmount(mallMember.getInviteId(), 1)); myTeamVo.setMyTeamAchieve(this.mallOrderInfoMapper.selectAmountOrTeamAmount(mallMember.getInviteId(), 2)); myTeamVo.setMyTeamCnt(this.baseMapper.selectAllChildAgentListByInviteId(mallMember.getInviteId()).size()); return new FebsResponse().success().data(myTeamVo); } @Override public MyTeamVo teamListForMine(TeamListDto teamListDto) { return null; } @Override public FebsResponse moneyFlows(MoneyFlowDto moneyFlowDto) { IPage page = new Page<>(moneyFlowDto.getPageNum(), moneyFlowDto.getPageSize()); Long id = LoginUserUtil.getLoginUser().getId(); moneyFlowDto.setMemberId(id); IPage pages = mallMoneyFlowMapper.selectApiMoneyFlowInPage(page, moneyFlowDto); if (moneyFlowDto.getFlowType() == 3) { pages.getRecords().forEach(item -> { item.setDescription(ScoreFlowTypeEnum.getDescByValue(item.getType())); }); } return new FebsResponse().success().data(pages); } @Override public void addMoneyFlow(Long memberId, BigDecimal amount, Integer type, String orderNo, String description, String remark, Long rtMemberId, Integer status, Integer flowType) { MallMoneyFlow flow = new MallMoneyFlow(); flow.setMemberId(memberId); flow.setAmount(amount); flow.setType(type); flow.setOrderNo(orderNo); flow.setDescription(description); flow.setRemark(remark); flow.setRtMemberId(rtMemberId); flow.setStatus(status); flow.setFlowType(flowType); mallMoneyFlowMapper.insert(flow); } @Override @Transactional(rollbackFor = Exception.class) public void transfer(TransferDto transferDto) { MallMember mallMember = this.baseMapper.selectInfoByAccount(transferDto.getAccount()); if (mallMember == null) { throw new FebsException("用户不存在"); } Long memberId = LoginUserUtil.getLoginUser().getId(); MallMember loginMember = this.baseMapper.selectById(memberId); if (loginMember.getPhone().equals(transferDto.getAccount()) || loginMember.getInviteId().equals(transferDto.getAccount())) { throw new FebsException("不能给自己转账"); } if (StrUtil.isBlank(loginMember.getTradePassword())) { throw new FebsException("未设置支付密码"); } if (!loginMember.getTradePassword().equals(SecureUtil.md5(transferDto.getTradePwd()))) { throw new FebsException("支付密码错误"); } walletService.reduceBalance(transferDto.getAmount(), memberId); String orderNo = MallUtils.getOrderNum("T"); this.addMoneyFlow(memberId, transferDto.getAmount().negate(), MoneyFlowTypeEnum.TRANSFER.getValue(), orderNo, null, null, mallMember.getId(), null, FlowTypeEnum.BALANCE.getValue()); walletService.addBalance(transferDto.getAmount(), mallMember.getId()); this.addMoneyFlow(mallMember.getId(), transferDto.getAmount(), MoneyFlowTypeEnum.TRANSFER.getValue(), orderNo, null, null, memberId, null, FlowTypeEnum.BALANCE.getValue()); } @Override public void setPayment(MallMemberPayment mallMemberPayment) { MallMember member = LoginUserUtil.getLoginUser(); MallMemberPayment exist = mallMemberPaymentMapper.selectByMemberId(member.getId()); if (exist == null) { mallMemberPayment.setMemberId(member.getId()); mallMemberPaymentMapper.insert(mallMemberPayment); } else { mallMemberPayment.setId(exist.getId()); mallMemberPaymentMapper.updateById(mallMemberPayment); } } @Override public MallMemberPayment findMemberPayment() { MallMember member = LoginUserUtil.getLoginUser(); return mallMemberPaymentMapper.selectByMemberId(member.getId()); } @Override public void bindPhone(AccountAndCodeDto accountAndCodeDto) { boolean b = commonService.verifyCode(accountAndCodeDto.getAccount(), accountAndCodeDto.getCode()); if (!b) { throw new FebsException("验证码错误"); } Long id = LoginUserUtil.getLoginUser().getId(); MallMember member = this.baseMapper.selectById(id); member.setPhone(accountAndCodeDto.getAccount()); this.baseMapper.updateById(member); } @Override public BigDecimal canMoney() { Long memberId = LoginUserUtil.getLoginUser().getId(); MallMemberWallet wallet = mallMemberWalletMapper.selectWalletByMemberId(memberId); return wallet.getBalance().setScale(2,BigDecimal.ROUND_DOWN); } @Override public List findRankList(RankListDto rankListDto) { IPage page = new Page<>(rankListDto.getPageNum(), rankListDto.getPageSize()); MallMember member = new MallMember(); member.setQuery("2"); member.setCreatedTime(new Date()); IPage list = this.baseMapper.selectRankListInPage(page, member); return list.getRecords(); } @Override public MallMember findMemberInfoByAccount(String phone) { return this.baseMapper.selectInfoByAccount(phone); } @Override public MyCommissionVo myCommission() { Long id = LoginUserUtil.getLoginUser().getId(); MallMember mallMember = this.baseMapper.selectById(id); MyCommissionVo commissionVo = MallMemberConversion.INSTANCE.entityToCommissionVo(mallMember); MallMember referMember = this.baseMapper.selectInfoByInviteId(mallMember.getReferrerId()); if (referMember != null) { commissionVo.setReferrerName(referMember.getName()); commissionVo.setAvatar(referMember.getAvatar()); } DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.AGENT_LEVEL, mallMember.getLevel()); if (dic != null) { commissionVo.setLevelName(dic.getDescription()); } MallMemberWallet wallet = mallMemberWalletMapper.selectWalletByMemberId(id); commissionVo.setCommission(wallet.getCommission()); commissionVo.setToday(mallMoneyFlowMapper.selectCommissionIncome(1, new Date(), id)); commissionVo.setMonth(mallMoneyFlowMapper.selectCommissionIncome(2, new Date(), id)); commissionVo.setTotal(mallMoneyFlowMapper.selectCommissionIncome(null, null, id)); commissionVo.setWaitCommission(BigDecimal.ZERO); return commissionVo; } @Override public void shopApply(ShopApplyDto shopApplyDto) { MallMember member = LoginUserUtil.getLoginUser(); MallShopApply hasApply = mallShopApplyMapper.selectNewestApplyByMemberId(member.getId()); if (hasApply != null) { if (!hasApply.getStatus().equals(MallShopApply.APPLY_DISAGREE)) { throw new FebsException("请勿重复提交申请"); } } MallShopApply mallShopApply = new MallShopApply(); BeanUtil.copyProperties(shopApplyDto, mallShopApply); mallShopApply.setStatus(MallShopApply.APPLY_ING); mallShopApply.setMemberId(member.getId()); mallShopApplyMapper.insert(mallShopApply); } @Override public MallShopApply findNewestApply() { MallMember member = LoginUserUtil.getLoginUser(); return mallShopApplyMapper.selectNewestApplyByMemberId(member.getId()); } @Override public void addRegisterAppeal(RegisterAppealDto registerAppeal) { MallRegisterAppeal isExist = mallRegisterAppealMapper.selectByPhoneAndName(registerAppeal.getName(), registerAppeal.getPhone()); if (isExist != null) { throw new FebsException("申诉已存在"); } isExist = new MallRegisterAppeal(); isExist.setName(registerAppeal.getName()); isExist.setPhone(registerAppeal.getPhone()); isExist.setStatus(2); mallRegisterAppealMapper.insert(isExist); } @Override public CashOutSettingVo cashOutSetting() { CashOutSettingVo cashOutSettingVo = new CashOutSettingVo(); DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.CASHOUT_SETTING.getType(), DataDictionaryEnum.CASHOUT_SETTING.getCode()); if (dic != null) { cashOutSettingVo = JSONObject.parseObject(dic.getValue(), CashOutSettingVo.class); } return cashOutSettingVo; } @Override public List findShopListVo(ShopListDto shopListDto) { Page page = new Page<>(shopListDto.getPageNow(), shopListDto.getPageSize()); MallShopApply shopApply = new MallShopApply(); shopApply.setStatus(MallShopApply.APPLY_AGREE); IPage pageResult = mallShopApplyMapper.selectShopApplyInPage(shopApply, page); List list = pageResult.getRecords(); if (CollUtil.isEmpty(list)) { list = new ArrayList<>(); } return MallShopApplyConversion.INSTANCE.entitiesToVOs(list); } private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class); @Override public FebsResponse xcxLogin(ApiXcxLoginDto apiXcxLoginDto) throws IOException { log.info("登录请求参数：{}", JSONObject.toJSONString(apiXcxLoginDto)); FebsResponse febsResponse = new FebsResponse(); String code = apiXcxLoginDto.getCode(); log.info("code:" + code); if (StrUtil.isNotBlank(code)) { String requrl = getXcxLoginUrl(code); String reslutData = HttpCurlUtil.sendGetHttp(requrl, null); net.sf.json.JSONObject json = net.sf.json.JSONObject.fromObject(reslutData); log.info("微信登录获取到登录信息={}", json); if (json.containsKey("errcode")) { log.info("微信登录获取到异常信息errcode"); return febsResponse.fail().message("自动登录失败"); } String openId = json.getString("openid"); String sessionKey = json.getString("session_key"); log.info("openId={},sessionKey={}", openId, sessionKey); // 查询用户是否存在 MallMember mallMember = null; synchronized (this) { mallMember = this.baseMapper.selectMemberByOpenId(openId); if (ObjectUtil.isEmpty(mallMember)) { // 新增用户 mallMember = new MallMember(); mallMember.setAccountStatus(MallMember.ACCOUNT_STATUS_ENABLE); mallMember.setAccountType(MallMember.ACCOUNT_TYPE_NORMAL); mallMember.setOpenId(openId); mallMember.setSessionKey(sessionKey); if (StrUtil.isNotBlank(apiXcxLoginDto.getInviteId())) { MallMember member = this.baseMapper.selectInfoByInviteId(apiXcxLoginDto.getInviteId()); if (member != null) { mallMember.setReferrerId(member.getInviteId()); //推荐人和推荐人链 boolean flag = false; String parentId = mallMember.getReferrerId(); if (StrUtil.isBlank(parentId)) { flag = true; } String ids = ""; while (!flag) { if (StrUtil.isBlank(ids)) { ids += parentId; } else { ids += ("," + parentId); } MallMember parentMember = this.baseMapper.selectInfoByInviteId(parentId); if (parentMember == null) { break; } parentId = parentMember.getReferrerId(); if (StrUtil.isBlank(parentMember.getReferrerId())) { flag = true; } } if (StrUtil.isNotBlank(ids)) { mallMember.setReferrerIds(ids); } } } this.baseMapper.insert(mallMember); mallMember = this.baseMapper.selectMemberByOpenId(openId); String inviteId = ShareCodeUtil.toSerialCode(mallMember.getId()); mallMember.setInviteId(inviteId); this.baseMapper.updateById(mallMember); MallMemberWallet wallet = new MallMemberWallet(); wallet.setBalance(BigDecimal.ZERO); wallet.setMemberId(mallMember.getId()); mallMemberWalletMapper.insert(wallet); } else { mallMember.setSessionKey(sessionKey); this.baseMapper.updateById(mallMember); } } // 存放redis String redisKey = AppContants.XCX_LOGIN_PREFIX + mallMember.getId(); String existToken = redisUtils.getString(redisKey); if (StrUtil.isNotBlank(existToken)) { Object o = redisUtils.get(existToken); if (ObjectUtil.isNotEmpty(o)) { redisUtils.del(existToken); } } String token = IdUtil.simpleUUID(); redisUtils.set(token, JSONObject.toJSONString(mallMember), -1); redisUtils.set(redisKey, token, -1); Map authInfo = new HashMap<>(); authInfo.put("token", token); authInfo.put("appid", xcxProperties.getXcxAppid()); authInfo.put("member", mallMember); authInfo.put("rasToken", generateAsaToken(token)); febsResponse.success().data(authInfo); } else { return febsResponse.fail().message("自动登录失败"); } return febsResponse; } @Override public FebsResponse xcxSaveInfo(ApiXcxSaveInfoDto apiXcxSaveInfoDto) { log.info("name={},phone={},avatar={},sex={}", apiXcxSaveInfoDto.getNickName(),apiXcxSaveInfoDto.getPhone(),apiXcxSaveInfoDto.getAvatarUrl(),apiXcxSaveInfoDto.getGender()); Long memberId = LoginUserUtil.getLoginUser().getId(); MallMember mallMember = this.baseMapper.selectById(memberId); String nickName = apiXcxSaveInfoDto.getNickName(); if(StrUtil.isNotEmpty(nickName)){ mallMember.setName(nickName); } String phone = apiXcxSaveInfoDto.getPhone(); if(StrUtil.isNotEmpty(phone)){ mallMember.setPhone(phone); } String avatarUrl = apiXcxSaveInfoDto.getAvatarUrl(); if(StrUtil.isNotEmpty(avatarUrl)){ mallMember.setAvatar(avatarUrl); } if (StrUtil.isNotBlank(apiXcxSaveInfoDto.getRealName())) { mallMember.setRealName(apiXcxSaveInfoDto.getRealName()); } if (apiXcxSaveInfoDto.getBirthday() != null) { mallMember.setBirthday(apiXcxSaveInfoDto.getBirthday()); } List configs = mallVipConfigMapper.selectVipConfigList(); if (StrUtil.isBlank(mallMember.getLevel()) && CollUtil.isNotEmpty(configs)) { MallVipConfig mallVipConfig = configs.get(0); mallMember.setLevel(mallVipConfig.getCode()); } mallMember.setSex(1 == apiXcxSaveInfoDto.getGender() ? "女" : "男"); this.baseMapper.updateById(mallMember); return new FebsResponse().success(); } @Override public FebsResponse xcxPhoneLogin(ApiXcxPhoneLoginDto apiXcxPhoneLoginDto) { String phone = apiXcxPhoneLoginDto.getPhone(); boolean flag = commonService.verifyCode(phone, apiXcxPhoneLoginDto.getCode()); if (flag) { // 查询用户是否存在 MallMember mallMember = null; synchronized (this) { mallMember = this.baseMapper.selectInfoByAccount(apiXcxPhoneLoginDto.getPhone()); if (ObjectUtil.isEmpty(mallMember)) { // 新增用户 mallMember = new MallMember(); mallMember.setPhone(phone); mallMember.setAccountStatus(MallMember.ACCOUNT_STATUS_ENABLE); mallMember.setAccountType(MallMember.ACCOUNT_TYPE_NORMAL); this.baseMapper.insert(mallMember); String inviteId = ShareCodeUtil.toSerialCode(mallMember.getId()); mallMember.setInviteId(inviteId); this.baseMapper.updateById(mallMember); MallMemberWallet wallet = new MallMemberWallet(); wallet.setBalance(BigDecimal.ZERO); wallet.setMemberId(mallMember.getId()); mallMemberWalletMapper.insert(wallet); } } // 存放redis String redisKey = AppContants.XCX_LOGIN_PHONE_PREFIX + mallMember.getId(); String existToken = redisUtils.getString(redisKey); if (StrUtil.isNotBlank(existToken)) { Object o = redisUtils.get(existToken); if (ObjectUtil.isNotEmpty(o)) { redisUtils.del(existToken); } } String token = IdUtil.simpleUUID(); redisUtils.set(token, JSONObject.toJSONString(mallMember), 360000); redisUtils.set(redisKey, token, 360000); Map authInfo = new HashMap<>(); authInfo.put("token", token); authInfo.put("member", mallMember); authInfo.put("rasToken", generateAsaToken(token)); return new FebsResponse().success().data(authInfo); } return new FebsResponse().fail().message("验证码错误"); } @Override public FebsResponse xcxOpen(ApiXcxOpenDto apiXcxOpenDto) { DataDictionaryCustom rangeSwitch = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.RANGE_SWITCH.getType(), DataDictionaryEnum.RANGE_SWITCH.getCode()); if(StrUtil.isNotBlank(rangeSwitch.getValue()) && "1".equals(rangeSwitch.getValue())){ if(ObjectUtil.isNull(apiXcxOpenDto.getLongitude()) || ObjectUtil.isNull(apiXcxOpenDto.getLatitude())){ return new FebsResponse().fail().message("请授权位置信息"); } Double longitude = apiXcxOpenDto.getLongitude(); Double latitude = apiXcxOpenDto.getLatitude(); DataDictionaryCustom rangeSize = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.RANGE_SIZE.getType(), DataDictionaryEnum.RANGE_SIZE.getCode()); if(ObjectUtil.isEmpty(rangeSize)){ return new FebsResponse().success().data(2); } if(StrUtil.isBlank(rangeSize.getValue())){ return new FebsResponse().success().data(2); } //方位大小，换成单位：米 Integer value = Integer.parseInt(rangeSize.getValue()) * 1000; //根据经纬度获取周围团长的距离 MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByLonAndLat(longitude, latitude); if(ObjectUtil.isEmpty(mallTeamLeader)){ return new FebsResponse().success().data(2); } Double distance = mallTeamLeader.getDistance(); if(value <= distance){ return new FebsResponse().success().data(2); } } return new FebsResponse().success().data(1); } private final IXcxPayService iXcxPayService; @Override @Transactional(rollbackFor = Exception.class) public FebsResponse rechargeWallet(ApiRechargeWalletDto apiRechargeWalletDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); BigDecimal amount = apiRechargeWalletDto.getAmount(); if(BigDecimal.ZERO.compareTo(amount)>0){ return new FebsResponse().fail().message("请输入正确的充值金额"); } Integer type = apiRechargeWalletDto.getType(); if(2 == type){ //成为合伙人的充值金额 MallAgentRecord mallAgentRecord = mallAgentRecordMapper.selectById(apiRechargeWalletDto.getAgentApplyId()); BigDecimal agentPrice = mallAgentRecord.getAmount(); // DataDictionaryCustom agentPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.PRICE_AMOUNT.getType(), // DataDictionaryEnum.PRICE_AMOUNT.getCode()); // String agentPrice = agentPriceDic.getValue(); // BigDecimal price = new BigDecimal(agentPrice); if(agentPrice.compareTo(amount) != 0){ return new FebsResponse().fail().message("成为合伙人的金额为"+agentPrice); } } String rechargeNo = "CZ_"+MallUtils.getOrderNum(); apiRechargeWalletDto.setRechargeNo(rechargeNo); apiRechargeWalletDto.setMemberId(memberId); BrandWCPayRequestData brandWCPayRequestData = null; try { brandWCPayRequestData = iXcxPayService.startRechargeWallet(apiRechargeWalletDto); } catch (Exception e) { throw new FebsException("支付失败"); } mallMoneyFlowService.addMoneyFlow( memberId, amount, MoneyFlowTypeEnum.RECHARGE.getValue(), rechargeNo, FlowTypeEnum.BALANCE.getValue(), "余额充值",1); String wxResultStr = JSONUtil.toJsonStr(brandWCPayRequestData); String payResultStr = brandWCPayRequestData.getPrepay_id(); Map map = new HashMap<>(); map.put("orderInfo", payResultStr); map.put("wxResultStr", wxResultStr); return new FebsResponse().success().data(map).message("充值即将到账"); } @Override public void updateMemberAgent(Long memberId,String levelCode) { mallAgentRecordMapper.updateStateByMemberId(memberId); MallAgentRecord mallAgentRecord = mallAgentRecordMapper.selectById(memberId); //更新用户表中的LEVEL MallMember mallMember = this.baseMapper.selectById(mallAgentRecord.getMemberId()); mallMember.setLevel(levelCode); this.baseMapper.updateById(mallMember); } @Override public FebsResponse agentDetail() { DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.AGENT_DETAILS.getType(), DataDictionaryEnum.AGENT_DETAILS.getCode()); Map map = new HashMap<>(); if(ObjectUtil.isNotEmpty(dataDictionaryCustom)){ map.put("agentDetail", dataDictionaryCustom.getValue()); } return new FebsResponse().success().data(map); } @Override public FebsResponse activityInfo() { DataDictionaryCustom activityBulletinDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.ACTIVITY_BULLETIN.getType(), DataDictionaryEnum.ACTIVITY_BULLETIN.getCode()); DataDictionaryCustom giveAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.GIVE_AMOUNT.getType(), DataDictionaryEnum.GIVE_AMOUNT.getCode()); DataDictionaryCustom giveStateDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.GIVE_STATE.getType(), DataDictionaryEnum.GIVE_STATE.getCode()); Map map = new HashMap<>(); if(ObjectUtil.isNotEmpty(activityBulletinDic)){ map.put("activityBulletin", ObjectUtil.isEmpty(activityBulletinDic.getValue()) ? "暂无活动" : activityBulletinDic.getValue()); } if(ObjectUtil.isNotEmpty(giveAmountDic)){ map.put("giveAmount", ObjectUtil.isEmpty(giveAmountDic.getValue()) ? 0 : giveAmountDic.getValue()); } map.put("giveState",giveStateDic.getValue()); return new FebsResponse().success().data(map); } @Override public FebsResponse agentApplyInfo() { Long memberId = LoginUserUtil.getLoginUser().getId(); ApiMallAgentRecordVo apiMallAgentRecordVo = mallAgentRecordMapper.selectApiMallAgentRecordVoByMemberIdAndState(memberId,MallAgentRecord.APPLY_ING); return new FebsResponse().success().data(apiMallAgentRecordVo); } @Override public FebsResponse getCoupon(GetCouponDto getCouponDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); String couponUUID = IdUtil.simpleUUID(); // String couponUUID = getCouponDto.getCouponUUID(); // QueryWrapper objectQueryWrapper = new QueryWrapper<>(); // objectQueryWrapper.eq("coupon_uuid",couponUUID); // List mallMemberCouponDone = mallMemberCouponMapper.selectList(objectQueryWrapper); // if(CollUtil.isNotEmpty(mallMemberCouponDone)){ // return new FebsResponse().success(); // } //通过邀请人信息，获取能领取的优惠卷信息 MallMember mallMember = this.baseMapper.selectInfoByInviteId(getCouponDto.getInviteId()); if(ObjectUtil.isNotEmpty(mallMember)){ SalemanCoupon salemanCoupon = salemanCouponMapper.selectByMemberId(mallMember.getId()); if(ObjectUtil.isNotEmpty(salemanCoupon)){ Long couponId = salemanCoupon.getCouponId(); Long goodsId = getCouponDto.getGoodsId(); MallGoods mallGoods = mallGoodsMapper.selectById(goodsId); //验证商品存不存在，且上没上架 if(ObjectUtil.isNotEmpty(mallGoods) && MallGoods.ISSALE_STATUS_ENABLE == mallGoods.getIsSale()){ // List mallMemberCoupons = mallMemberCouponMapper.selectListByMemberIdAndGoodsIdAndCouponId(memberId, goodsId, couponId,mallMember.getInviteId()); // List mallMemberCoupons = mallMemberCouponMapper.selectListByMemberIdAndGoodsIdAndCouponIdWithOutInviteId(memberId, goodsId, couponId); List mallMemberCoupons = mallMemberCouponMapper.selectListByMemberIdAndGoodsIdAndCouponIdWithOutInviteId(memberId, goodsId); if(CollUtil.isEmpty(mallMemberCoupons)){ //商品优惠卷如果绑定了，那么当前登陆者获取一张卷 List couponGoodsList = couponGoodsMapper.selectByGoodIdAndCouponId(goodsId,couponId); MallGoodsCoupon mallGoodsCoupon = mallGoodsCouponMapper.selectById(couponId); if(CollUtil.isNotEmpty(couponGoodsList)){ MallMemberCoupon mallMemberCoupon = new MallMemberCoupon(); mallMemberCoupon.setCouponId(couponId); mallMemberCoupon.setCouponName(mallGoodsCoupon.getName()); mallMemberCoupon.setMemberId(memberId); mallMemberCoupon.setGoodsId(goodsId); mallMemberCoupon.setCouponUuid(couponUUID); mallMemberCoupon.setInviteId(mallMember.getInviteId()); mallMemberCoupon.setState(1); mallMemberCoupon.setExpireTime(DateUtil.offsetDay(DateUtil.date(),mallGoodsCoupon.getExpireDay())); mallMemberCouponMapper.insert(mallMemberCoupon); } } } } } return new FebsResponse().success(); } @Override public FebsResponse scanCoupon(GetCouponDto getCouponDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); String couponUUID = IdUtil.simpleUUID(); //通过邀请人信息，获取能领取的优惠卷信息 MallMember mallMember = this.baseMapper.selectInfoByInviteId(getCouponDto.getInviteId()); if(ObjectUtil.isNotEmpty(mallMember)){ SalemanCoupon salemanCoupon = salemanCouponMapper.selectByMemberId(mallMember.getId()); if(ObjectUtil.isNotEmpty(salemanCoupon)){ Long couponId = salemanCoupon.getCouponId(); List mallMemberCoupons = mallMemberCouponMapper.selectListByMemberIdCouponIdWithOutInviteId(memberId, couponId); if(CollUtil.isEmpty(mallMemberCoupons)){ //商品优惠卷如果绑定了，那么当前登陆者获取一张卷 MallGoodsCoupon mallGoodsCoupon = mallGoodsCouponMapper.selectById(couponId); MallMemberCoupon mallMemberCoupon = new MallMemberCoupon(); mallMemberCoupon.setCouponId(couponId); mallMemberCoupon.setCouponName(mallGoodsCoupon.getName()); mallMemberCoupon.setMemberId(memberId); mallMemberCoupon.setCouponUuid(couponUUID); mallMemberCoupon.setInviteId(mallMember.getInviteId()); mallMemberCoupon.setState(1); mallMemberCoupon.setExpireTime(DateUtil.offsetDay(DateUtil.date(),mallGoodsCoupon.getExpireDay())); mallMemberCouponMapper.insert(mallMemberCoupon); } } } return new FebsResponse().success(); } @Override public FebsResponse memberCoupon(MallMemberCouponDto mallMemberCouponDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); IPage page = new Page<>(mallMemberCouponDto.getPageNum(), mallMemberCouponDto.getPageSize()); mallMemberCouponDto.setMemberId(memberId); mallMemberCouponDto.setExpireTime(DateUtil.date()); IPage pages = mallMemberCouponMapper.selectListInPage(page, mallMemberCouponDto); return new FebsResponse().success().data(pages); } @Override public FebsResponse memberPayCoupon(MallMemberCouponDto mallMemberCouponDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); mallMemberCouponDto.setMemberId(memberId); mallMemberCouponDto.setExpireTime(DateUtil.date()); // List couponIds = couponGoodsMapper.selectByGoodId(mallMemberCouponDto.getGoodsId()); List goodsIdList = mallMemberCouponDto.getGoodsIdList(); List couponIds = couponGoodsMapper.selectByGoodIdList(goodsIdList); List mallMemberCouponVos = new ArrayList<>(); if(CollUtil.isNotEmpty(couponIds)){ mallMemberCouponVos = mallMemberCouponMapper.selectListCreateInPage(mallMemberCouponDto,couponIds); } return new FebsResponse().success().data(mallMemberCouponVos); } @Override public FebsResponse couponDetails(Long id) { Long memberId = LoginUserUtil.getLoginUser().getId(); MallMemberCoupon mallMemberCoupon = mallMemberCouponMapper.selectById(id); MallMemberCouponVo mallMemberCouponVo = new MallMemberCouponVo(); mallMemberCouponVo.setCouponName(mallMemberCoupon.getCouponName()); MallGoodsCoupon mallGoodsCoupon = mallGoodsCouponMapper.selectById(mallMemberCoupon.getCouponId()); mallMemberCouponVo.setCostAmount(mallGoodsCoupon.getCostAmount()); mallMemberCouponVo.setRealAmount(mallGoodsCoupon.getRealAmount()); mallMemberCouponVo.setType(mallGoodsCoupon.getType()); return new FebsResponse().success().data(mallMemberCouponVo); } @Override public FebsResponse setInvite(ApiSetInviteDto apiSetInviteDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); MallMember mallMember = this.baseMapper.selectById(memberId); if(ObjectUtil.isNotEmpty(mallMember.getReferrerId())){ throw new FebsException("已绑定"); } String inviteId = apiSetInviteDto.getInviteId(); if(inviteId.equals(mallMember.getInviteId())){ return new FebsResponse().success(); } MallMember member = this.baseMapper.selectInfoByInviteId(inviteId); if (member != null) { if (StrUtil.isNotBlank(member.getReferrerIds()) && member.getReferrerIds().contains(mallMember.getInviteId())) { log.info("下级不能邀请上级"); return new FebsResponse().success(); } mallMember.setReferrerId(member.getInviteId()); //推荐人和推荐人链 boolean flag = false; String parentId = mallMember.getReferrerId(); if (StrUtil.isBlank(parentId)) { flag = true; } String ids = ""; while (!flag) { if (StrUtil.isBlank(ids)) { ids += parentId; } else { ids += ("," + parentId); } MallMember parentMember = this.baseMapper.selectInfoByInviteId(parentId); if (parentMember == null) { break; } parentId = parentMember.getReferrerId(); if (StrUtil.isBlank(parentMember.getReferrerId())) { flag = true; } } if (StrUtil.isNotBlank(ids)) { mallMember.setReferrerIds(ids); } this.baseMapper.updateById(mallMember); } return new FebsResponse().success(); } private String getXcxLoginUrl(String code) { String wechatLoginUrl =xcxProperties.getWecharLoginUrl(); return String.format(wechatLoginUrl, xcxProperties.getXcxAppid(), xcxProperties.getXcxSecret(), code); } @Override public Map loginEvent() { MallMember loginUser = LoginUserUtil.getLoginUser(); MallMember member = this.baseMapper.selectById(loginUser.getId()); MallMember mallMember = new MallMember(); mallMember.setId(member.getId()); mallMember.setLastLoginTime(new Date()); this.baseMapper.updateById(mallMember); DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.UNALIVE_COUPON.getType(), DataDictionaryEnum.UNALIVE_COUPON.getCode()); if (dic == null || StrUtil.isBlank(dic.getValue())) { return new HashMap<>(); } Date today = new Date(); Date lastLoginTime = member.getLastLoginTime(); if (lastLoginTime == null) { lastLoginTime = new Date(); } long days = DateUtil.between(DateUtil.endOfDay(lastLoginTime), DateUtil.endOfDay(today), DateUnit.DAY); List list = JSONObject.parseArray(dic.getValue(), VipSettingUnAliveSettingBo.class); List couponIds = list.stream().filter(item -> { return item.getDay() <= days && item.getCouponId() != null; }).map(VipSettingUnAliveSettingBo::getCouponId).collect(Collectors.toList()); if (CollUtil.isEmpty(couponIds)) { return new HashMap<>(); } LambdaQueryWrapper query = new LambdaQueryWrapper<>(); query.in(MallGoodsCoupon::getId, couponIds) .eq(MallGoodsCoupon::getState, 2); List coupons = mallGoodsCouponMapper.selectList(query); LambdaQueryWrapper memberCouponQuery = new LambdaQueryWrapper<>(); memberCouponQuery.in(MallMemberCoupon::getCouponId, couponIds) .eq(MallMemberCoupon::getMemberId, member.getId()) .eq(MallMemberCoupon::getFromType, 3) .ge(MallMemberCoupon::getCreatedTime, DateUtil.beginOfDay(new Date())) .le(MallMemberCoupon::getCreatedTime, DateUtil.endOfDay(new Date())); List mallMemberCoupons = mallMemberCouponMapper.selectList(memberCouponQuery); if (CollUtil.isNotEmpty(mallMemberCoupons)) { Map map = mallMemberCoupons.stream().collect(Collectors.toMap(MallMemberCoupon::getCouponId, MallMemberCoupon -> MallMemberCoupon)); coupons = coupons.stream().filter(item -> { return map.get(item.getId()) == null; }).collect(Collectors.toList()); } if (CollUtil.isEmpty(coupons)) { return new HashMap<>(); } coupons.forEach(item -> { MallMemberCoupon memberCoupon = new MallMemberCoupon(); memberCoupon.setCouponId(item.getId()); memberCoupon.setCouponName(item.getName()); memberCoupon.setInviteId(member.getInviteId()); memberCoupon.setCouponUuid(IdUtil.simpleUUID()); memberCoupon.setState(1); memberCoupon.setFromType(3); memberCoupon.setExpireTime(DateUtil.offsetDay(DateUtil.date(), item.getExpireDay())); memberCoupon.setMemberId(member.getId()); mallMemberCouponMapper.insert(memberCoupon); }); Map result = new HashMap<>(); result.put("coupon", coupons); return result; } @Override public FebsResponse storeList(MallStoreDto mallStoreDto) { QueryWrapper mallStoreQueryWrapper = new QueryWrapper<>(); if(StrUtil.isNotEmpty(mallStoreDto.getName())){ mallStoreQueryWrapper.like("name",mallStoreDto.getName()); } List mallStores = mallStoreMapper.selectList(mallStoreQueryWrapper); List mallStoreVos = MallStoreConversion.INSTANCE.entitysToVos(mallStores); return new FebsResponse().success().data(mallStoreVos); } @Override public FebsResponse storeItemList(MallStoreItemDto mallStoreItemDto) { // QueryWrapper mallStoreQueryWrapper = new QueryWrapper<>(); // mallStoreQueryWrapper.like("store_id",mallStoreItemDto.getStoreId()); // List mallStores = mallStoreItemMapper.selectList(mallStoreQueryWrapper); List mallStores = mallStoreItemMapper.selectList( new LambdaQueryWrapper() .eq(MallStoreItem::getStoreId, mallStoreItemDto.getStoreId()) ); return new FebsResponse().success().data(mallStores); } @Override public FebsResponse bindStoreMember(BindStoreMemberDto bindStoreMemberDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); Long storeItemId = bindStoreMemberDto.getStoreItemId(); // QueryWrapper objectQueryWrapper = new QueryWrapper<>(); // objectQueryWrapper.eq("member_id",memberId); // List mallStoreMembers = mallStoreMemberMapper.selectList(objectQueryWrapper); List mallStoreMembers = mallStoreMemberMapper.selectList( new LambdaQueryWrapper() .eq(MallStoreMember::getMemberId, memberId) .eq(MallStoreMember::getStoreItemId, bindStoreMemberDto.getStoreItemId()) ); if(CollUtil.isNotEmpty(mallStoreMembers)){ return new FebsResponse().fail().message("您已经绑定过了"); } MallMember mallMember = this.baseMapper.selectById(memberId); Integer sex = "女".equals(mallMember.getSex()) ? 3 : 2; MallStoreItem mallStoreItem = mallStoreItemMapper.selectById(storeItemId); HashMap objectObjectHashMap = new HashMap<>(); String shopAccount = mallStoreItem.getAccount(); String shopPwd = mallStoreItem.getPassword(); String name = bindStoreMemberDto.getName(); String address = bindStoreMemberDto.getAddress(); Integer age = bindStoreMemberDto.getAge(); String phoneNumber = bindStoreMemberDto.getPhone(); objectObjectHashMap.put("shopAccount",shopAccount); objectObjectHashMap.put("shopPwd",shopPwd); objectObjectHashMap.put("name",name); objectObjectHashMap.put("address",address); objectObjectHashMap.put("age",age.toString()); objectObjectHashMap.put("phoneNumber",phoneNumber); objectObjectHashMap.put("sex",sex.toString()); //sign= MD5(address+age+name+phoneNumber+shopAccount+shopPwd) StringBuffer stringBuffer = new StringBuffer(); stringBuffer.append(address); stringBuffer.append(age); stringBuffer.append(name); stringBuffer.append(phoneNumber); stringBuffer.append(sex); stringBuffer.append(shopAccount); stringBuffer.append(shopPwd); String sign = MD5.MD5Encode(stringBuffer.toString()); objectObjectHashMap.put("sign",sign); String url = "https://data.muchun.co/api/bindCustomer"; log.info("请求参数"+objectObjectHashMap); String result = HttpCurlUtil.sendPost(url, objectObjectHashMap); log.info("绑定用户"+result); Integer retCode = JSONUtil.parseObj(result).getInt("retCode"); String message = JSONUtil.parseObj(result).getStr("message"); if(0 != retCode || !"绑定成功".equals(message)){ return new FebsResponse().fail().message(message); } Long bindId = JSONUtil.parseObj(result).getJSONObject("data").getLong("userId"); List mallStoreMembers1 = mallStoreMemberMapper.selectList( new LambdaQueryWrapper() .eq(MallStoreMember::getMemberId, memberId) .eq(MallStoreMember::getStoreItemId, mallStoreItem.getId()) .eq(MallStoreMember::getBindId, bindId) ); if(CollUtil.isEmpty(mallStoreMembers1)){ MallStoreMember mallStoreMember = new MallStoreMember(); mallStoreMember.setMemberId(memberId); mallStoreMember.setBindId(bindId); mallStoreMember.setStoreId(mallStoreItem.getStoreId()); mallStoreMember.setStoreItemId(mallStoreItem.getId()); mallStoreMember.setAccount(shopAccount); mallStoreMember.setPassword(shopPwd); mallStoreMember.setName(name); mallStoreMember.setAddress(address); mallStoreMember.setAge(age); mallStoreMember.setPhone(phoneNumber); mallStoreMemberMapper.insert(mallStoreMember); } return new FebsResponse().success().message("绑定成功"); } @Override public FebsResponse bindList() { Long memberId = LoginUserUtil.getLoginUser().getId(); QueryWrapper objectQueryWrapper = new QueryWrapper<>(); objectQueryWrapper.eq("member_id",memberId); List mallStoreMembers = mallStoreMemberMapper.selectList(objectQueryWrapper); ArrayList mallStoreMemberVos = new ArrayList<>(); for(MallStoreMember mallStoreMember : mallStoreMembers){ MallStoreMemberVo mallStoreMemberVo = new MallStoreMemberVo(); Long storeId = mallStoreMember.getStoreId(); Long storeItemId = mallStoreMember.getStoreItemId(); MallStore mallStore = mallStoreMapper.selectById(storeId); MallStoreItem mallStoreItem = mallStoreItemMapper.selectById(storeItemId); mallStoreMemberVo.setId(mallStoreMember.getId()); mallStoreMemberVo.setBindInfo(mallStore.getName()+"-"+mallStoreItem.getCode()); mallStoreMemberVos.add(mallStoreMemberVo); } return new FebsResponse().success().data(mallStoreMemberVos); } @Override public FebsResponse bindResult(BindResultDto bindResultDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); MallStoreMember mallStoreMember = mallStoreMemberMapper.selectById(bindResultDto.getBindId()); Long userld = mallStoreMember.getBindId(); String shopAccount = mallStoreMember.getAccount(); String shopPwd = mallStoreMember.getPassword(); HashMap objectObjectHashMap = new HashMap<>(); objectObjectHashMap.put("shopAccount",shopAccount); objectObjectHashMap.put("shopPwd",shopPwd); objectObjectHashMap.put("userId",userld.toString()); //sign= MD5(shopAccount+shopPwd+userId) StringBuffer stringBuffer = new StringBuffer(); stringBuffer.append(shopAccount); stringBuffer.append(shopPwd); stringBuffer.append(userld); String sign = MD5.MD5Encode(stringBuffer.toString()); objectObjectHashMap.put("sign",sign); String url = "https://data.muchun.co/api/getCustomerCheckRecords"; String result = HttpCurlUtil.sendPost(url, objectObjectHashMap); Integer retCode = JSONUtil.parseObj(result).getInt("retCode"); String message = JSONUtil.parseObj(result).getStr("message"); if(0 != retCode){ return new FebsResponse().fail().message(message); } JSONArray data = JSONUtil.parseObj(result).getJSONArray("data"); return new FebsResponse().success().data(data); } /** * 绑定医生接口的实现方法 * * @param dto 包含绑定医生所需信息的数据传输对象 * @return 返回操作结果的响应对象 * @throws FebsException 如果绑定操作失败，抛出此异常 */ @Override public FebsResponse bindDoctor(ApiDoctorBindDto dto) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); // 从DTO中提取邀请ID和门店会员ID String inviteId = dto.getInviteId(); Long storeMemberId = dto.getStoreMemberId(); // 根据门店会员ID查询门店会员信息 MallStoreMember mallStoreMember = mallStoreMemberMapper.selectById(storeMemberId); // 如果门店会员信息为空，抛出异常 if(null == mallStoreMember){ throw new FebsException("当前检测记录无法绑定！"); } // 如果门店会员的会员ID与当前登录用户ID不匹配，抛出异常 if(mallStoreMember.getMemberId() != memberId){ throw new FebsException("当前检测记录无法绑定！"); } // 根据邀请ID查询会员信息 MallMember mallMember = this.baseMapper.selectInfoByInviteId(inviteId); // 如果会员的医生状态不是1，抛出异常 if(1 != mallMember.getDoctorState()){ throw new FebsException("无法绑定！"); } // 查询与当前门店会员ID关联的医生列表 List mallDoctors = mallDoctorMapper.selectList(new LambdaQueryWrapper().eq(MallDoctor::getStoreMemberId, mallStoreMember.getId())); // 如果医生列表为空，创建新的医生对象并设置相关信息，然后插入数据库 if(CollUtil.isEmpty(mallDoctors)){ MallDoctor mallDoctor = new MallDoctor(); mallDoctor.setMemberId(mallMember.getId()); mallDoctor.setStoreMemberId(mallStoreMember.getId()); mallDoctor.setBindMemberId(mallStoreMember.getMemberId()); mallDoctor.setBindPhone(mallStoreMember.getPhone()); mallDoctor.setBindName(mallStoreMember.getName()); mallDoctor.setBindInfo(mallStoreMember.getAccount()); mallDoctor.setBindAge(mallStoreMember.getAge()); mallDoctorMapper.insert(mallDoctor); } // 返回操作成功的响应 return new FebsResponse().success().message("操作成功"); } /** * 获取医生列表接口的实现 * 根据登录用户信息和查询条件，返回相应的医生列表 * * @param dto 包含查询条件的数据传输对象 * @return 返回包含医生列表的响应对象 */ @Override public FebsResponse doctorList(ApiDoctorListDto dto) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); // 初始化用于存储医生信息的集合 ArrayList apiDoctorListVos = new ArrayList<>(); // 创建查询条件包装器 LambdaQueryWrapper objectQueryWrapper = new LambdaQueryWrapper<>(); // 根据传入的手机号进行模糊查询 if(StrUtil.isNotEmpty(dto.getPhone())){ objectQueryWrapper.like(MallDoctor::getBindPhone,dto.getPhone()); } // 根据会员ID进行精确查询 objectQueryWrapper.eq(MallDoctor::getMemberId,memberId); // 按创建时间降序排序 objectQueryWrapper.orderByDesc(MallDoctor::getCreatedTime); // 执行查询，获取医生列表 List mallDoctors = mallDoctorMapper.selectList(objectQueryWrapper); // 如果查询结果不为空，则遍历查询结果，封装医生信息 if(CollUtil.isNotEmpty(mallDoctors)){ for(MallDoctor mallDoctor : mallDoctors){ ApiDoctorListVo apiDoctorListVo = new ApiDoctorListVo(); apiDoctorListVo.setId(mallDoctor.getId()); apiDoctorListVo.setStoreMemberId(mallDoctor.getStoreMemberId()); apiDoctorListVo.setName(mallDoctor.getBindName()); apiDoctorListVo.setPhone(mallDoctor.getBindPhone()); apiDoctorListVo.setBindAge(mallDoctor.getBindAge()); apiDoctorListVo.setBindInfo(mallDoctor.getBindInfo()); apiDoctorListVo.setCreatedTime(mallDoctor.getCreatedTime()); // 将封装好的医生信息添加到集合中 apiDoctorListVos.add(apiDoctorListVo); } } // 返回包含医生列表的响应对象 return new FebsResponse().success().data(apiDoctorListVos); } @Override public FebsResponse authList() { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); // 初始化用于存储医生信息的集合 ArrayList apiDoctorListVos = new ArrayList<>(); // 创建查询条件包装器 LambdaQueryWrapper objectQueryWrapper = new LambdaQueryWrapper<>(); // 根据会员ID进行精确查询 objectQueryWrapper.eq(MallDoctor::getBindMemberId,memberId); // 按创建时间降序排序 objectQueryWrapper.orderByDesc(MallDoctor::getCreatedTime); // 执行查询，获取医生列表 List mallDoctors = mallDoctorMapper.selectList(objectQueryWrapper); // 如果查询结果不为空，则遍历查询结果，封装医生信息 if(CollUtil.isNotEmpty(mallDoctors)){ for(MallDoctor mallDoctor : mallDoctors){ ApiDoctorListVo apiDoctorListVo = new ApiDoctorListVo(); apiDoctorListVo.setId(mallDoctor.getId()); apiDoctorListVo.setStoreMemberId(mallDoctor.getStoreMemberId()); apiDoctorListVo.setName(mallDoctor.getBindName()); apiDoctorListVo.setPhone(mallDoctor.getBindPhone()); apiDoctorListVo.setBindAge(mallDoctor.getBindAge()); apiDoctorListVo.setBindInfo(mallDoctor.getBindInfo()); apiDoctorListVo.setCreatedTime(mallDoctor.getCreatedTime()); // 将封装好的医生信息添加到集合中 apiDoctorListVos.add(apiDoctorListVo); } } // 返回包含医生列表的响应对象 return new FebsResponse().success().data(apiDoctorListVos); } @Override public FebsResponse authDel(ApiDoctorAuthDeleteDto dto) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); MallDoctor mallDoctor = mallDoctorMapper.selectById(dto.getId()); if(memberId != mallDoctor.getBindMemberId()){ throw new FebsException("当前授权无法删除！"); } mallDoctorMapper.deleteById(dto.getId()); return new FebsResponse().success().message("操作成功"); } public static void main(String[] args) { Long userld = 16425L; String shopAccount = "爱和美医疗"; String shopPwd = "blnka2005"; HashMap objectObjectHashMap = new HashMap<>(); objectObjectHashMap.put("shopAccount",shopAccount); objectObjectHashMap.put("shopPwd",shopPwd); objectObjectHashMap.put("userId",userld.toString()); //sign= MD5(shopAccount+shopPwd+userId) StringBuffer stringBuffer = new StringBuffer(); stringBuffer.append(shopAccount); stringBuffer.append(shopPwd); stringBuffer.append(userld); String sign = MD5.MD5Encode(stringBuffer.toString()); objectObjectHashMap.put("sign",sign); System.out.println(sign); System.out.println(objectObjectHashMap); String url = "https://data.muchun.co/api/getCustomerCheckRecords"; String result = HttpCurlUtil.sendPost(url, objectObjectHashMap); Integer retCode = JSONUtil.parseObj(result).getInt("retCode"); String message = JSONUtil.parseObj(result).getStr("message"); if(0 != retCode){ System.out.println(message); } JSONArray data = JSONUtil.parseObj(result).getJSONArray("data"); System.out.println(data); } }