| | |
|---|
| | | import cc.mrbird.febs.mall.vo.*; |
|---|
| | | import cc.mrbird.febs.pay.model.BrandWCPayRequestData; |
|---|
| | | import cc.mrbird.febs.pay.service.IXcxPayService; |
|---|
| | | import cc.mrbird.febs.rabbit.producter.AgentProducer; |
|---|
| | | import cn.hutool.core.bean.BeanUtil; |
|---|
| | | import cn.hutool.core.collection.CollUtil; |
|---|
| | | import cn.hutool.core.util.IdUtil; |
|---|
| | |
|---|
| | | private final SpringContextHolder springContextHolder; |
|---|
| | | private final MallAgentRecordMapper mallAgentRecordMapper; |
|---|
| | | private final IMallMoneyFlowService mallMoneyFlowService; |
|---|
| | | private final AgentProducer agentProducer; |
|---|
| | | |
|---|
| | | |
|---|
| | | @Value("${spring.profiles.active}") |
|---|
| | |
|---|
| | | 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.setLevel(AgentLevelEnum.ZERO_LEVEL.name()); |
|---|
| | | mallMember.setOpenId(openId); |
|---|
| | | mallMember.setSessionKey(sessionKey); |
|---|
| | | 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); |
|---|
| | | agentProducer.sendMemberSubMsg(openId); |
|---|
| | | } else { |
|---|
| | | mallMember.setSessionKey(sessionKey); |
|---|
| | | this.baseMapper.updateById(mallMember); |
|---|
