blame | history | patch | commit | commitdiff | ignore whitespace
xiaoyong931011
2023-07-17 ea2938522357f193ee82938129a8094c594f1fb1 
 src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java


@@ -1,32 +1,41 @@


package cc.mrbird.febs.mall.service.impl;




import cc.mrbird.febs.common.entity.FebsResponse;


import cc.mrbird.febs.common.enumerates.AgentLevelEnum;


import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum;


import cc.mrbird.febs.common.exception.FebsException;


import cc.mrbird.febs.common.utils.AppContants;


import cc.mrbird.febs.mall.entity.AgentInfo;


import cc.mrbird.febs.mall.entity.DataDictionaryCustom;


import cc.mrbird.febs.mall.entity.MallMember;


import cc.mrbird.febs.mall.entity.MallOrderInfo;


import cc.mrbird.febs.common.utils.HttpCurlUtil;


import cc.mrbird.febs.common.utils.ShareCodeUtil;


import cc.mrbird.febs.mall.entity.*;


import cc.mrbird.febs.mall.mapper.*;


import cc.mrbird.febs.mall.service.IAgentService;


import cc.mrbird.febs.mall.service.IApiMallMemberService;


import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;


import cc.mrbird.febs.mall.service.IMallAchieveService;


import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.util.ObjectUtil;


import cn.hutool.core.util.StrUtil;


import cn.hutool.crypto.SecureUtil;


import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import jdk.nashorn.internal.ir.IfNode;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.springframework.http.HttpHeaders;


import org.springframework.http.HttpStatus;


import org.springframework.http.MediaType;


import org.springframework.http.converter.StringHttpMessageConverter;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.client.RestTemplate;




import javax.annotation.Resource;


import java.io.IOException;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.nio.charset.Charset;


import java.util.*;




/**


 * @author wzy


@@ -39,6 +48,8 @@




    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;


    private final MallMemberMapper memberMapper;


    private final MallMemberWalletMapper mallMemberWalletMapper;


    private final RestTemplate restTemplate;




    @Override


    @Transactional(rollbackFor = Exception.class)


@@ -136,7 +147,6 @@


    /**


     * 团队业绩是否达标


     *


     * @param mallMember


     * @param agentInfo


     * @return


     */


@@ -161,4 +171,183 @@


    public void rankReturnMoney(Long orderId) {




    }




    @Override


    public void addMember(String memberOpenId) {


        MallMember mallMember = memberMapper.selectMemberByOpenId(memberOpenId);


        //根据OPENID，查询用户信息，如果存在，直接返回


        if (ObjectUtil.isNotEmpty(mallMember)) {


            mallMember.setSubStatus(MallMember.SUB_STATUS_ENABLE);


            memberMapper.updateById(mallMember);


            return;


        }


        mallMember = new MallMember();


        mallMember.setPassword(SecureUtil.md5("a123456"));


        mallMember.setName("微信用户");


        mallMember.setSubStatus(MallMember.SUB_STATUS_ENABLE);


        mallMember.setReferrerId(null);


        mallMember.setPhone(null);


        mallMember.setAccountStatus(MallMember.ACCOUNT_STATUS_ENABLE);


        mallMember.setAccountType(MallMember.ACCOUNT_TYPE_NORMAL);


        mallMember.setLevel(AgentLevelEnum.ZERO_LEVEL.name());


        mallMember.setSex("男");


        mallMember.setBindPhone(null);


        mallMember.setOpenId(memberOpenId);


        memberMapper.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 = memberMapper.selectInfoByInviteId(parentId);


            if (parentMember == null) {


                break;


            }


            parentId = parentMember.getReferrerId();


            if (StrUtil.isBlank(parentMember.getReferrerId())) {


                flag = true;


            }


        }


        if (StrUtil.isNotBlank(ids)) {


            mallMember.setReferrerIds(ids);


        }


        memberMapper.updateById(mallMember);


        //初始化钱包信息


        MallMemberWallet wallet = new MallMemberWallet();


        wallet.setBalance(BigDecimal.ZERO);


        wallet.setMemberId(mallMember.getId());


        mallMemberWalletMapper.insert(wallet);


        return;


    }




    @Override


    public void addMemberScan(String str) {




        String[] split = StrUtil.split(str, "-");


        String referrerId = split[0];


        String openId = split[1];


        MallMember mallMember = memberMapper.selectMemberByOpenId(openId);


        if (ObjectUtil.isNotEmpty(mallMember)) {


            return;


        }


        mallMember = new MallMember();


        mallMember.setPassword(SecureUtil.md5("a123456"));


        mallMember.setName("微信用户");


        mallMember.setSubStatus(MallMember.SUB_STATUS_DISABLED);


        mallMember.setReferrerId(referrerId);


        mallMember.setPhone(null);


        mallMember.setAccountStatus(MallMember.ACCOUNT_STATUS_ENABLE);


        mallMember.setAccountType(MallMember.ACCOUNT_TYPE_NORMAL);


        mallMember.setLevel(AgentLevelEnum.ZERO_LEVEL.name());


        mallMember.setSex("男");


        mallMember.setBindPhone(null);


        mallMember.setOpenId(openId);


        memberMapper.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 = memberMapper.selectInfoByInviteId(parentId);


            if (parentMember == null) {


                break;


            }


            parentId = parentMember.getReferrerId();


            if (StrUtil.isBlank(parentMember.getReferrerId())) {


                flag = true;


            }


        }


        if (StrUtil.isNotBlank(ids)) {


            mallMember.setReferrerIds(ids);


        }


        memberMapper.updateById(mallMember);


        //初始化钱包信息


        MallMemberWallet wallet = new MallMemberWallet();


        wallet.setBalance(BigDecimal.ZERO);


        wallet.setMemberId(mallMember.getId());


        mallMemberWalletMapper.insert(wallet);


        return;


    }




    @Override


    public void updateMemberInfo(String str) {


        String[] split = StrUtil.split(str, "|");


        String accessToken = split[0];


        String openId = split[1];


        MallMember mallMember = memberMapper.selectMemberByOpenId(openId);


        if (ObjectUtil.isNotEmpty(mallMember)) {


            return;


        }


        String requrl = "https://api.weixin.qq.com/sns/userinfo?access_token="+accessToken+"&openid="+openId+"&lang=zh_CN";


        // 创建一个StringHttpMessageConverter，并设置字符集为UTF-8


        StringHttpMessageConverter stringConverter = new StringHttpMessageConverter(Charset.forName("UTF-8"));


        stringConverter.setSupportedMediaTypes(Collections.singletonList(MediaType.TEXT_PLAIN));


        // 将StringHttpMessageConverter添加到RestTemplate的消息转换器列表中


        restTemplate.getMessageConverters().add(0, stringConverter);


        // 创建HttpHeaders对象，设置Accept头部的值为"text/plain;charset=UTF-8"


        HttpHeaders headers = new HttpHeaders();


        headers.setAccept(Collections.singletonList(MediaType.TEXT_PLAIN));


        headers.set(HttpHeaders.ACCEPT_CHARSET, "UTF-8");




        String responseStr = restTemplate.getForObject(requrl, String.class);


        net.sf.json.JSONObject json = net.sf.json.JSONObject.fromObject(responseStr);


        log.info("微信获取用户信息={}", json);




        if (json.containsKey("errcode")) {


            log.info("微信登录获取到异常信息errcode");


            return;


        }


        String nickname = json.getString("nickname");


        String headImgUrl = json.getString("headimgurl");


        mallMember.setName(nickname);


        mallMember.setAvatar(headImgUrl);


        memberMapper.updateById(mallMember);


    }




    public static void main(String[] args) {




        RestTemplate restTemplate = new RestTemplate();


        String accessToken = "70_6yOz-tXaDx6qMswGgmfl6j3LfgG-ur3JE-top_QvX5Oea9ryFxzEBwgVoW53IpMrzcS7mpPJf7tI3czT_kA2l5Y_Xu1WS7d7xDNbMs97ARk";


        String openId = "oXL7Y6LW5KGQTbmmP5W3JljjApSo";


        String requrl = "https://api.weixin.qq.com/sns/userinfo?access_token="+accessToken+"&openid="+openId+"&lang=zh_CN";


        // 创建一个StringHttpMessageConverter，并设置字符集为UTF-8


        StringHttpMessageConverter stringConverter = new StringHttpMessageConverter(Charset.forName("UTF-8"));


        stringConverter.setSupportedMediaTypes(Collections.singletonList(MediaType.TEXT_PLAIN));


        // 将StringHttpMessageConverter添加到RestTemplate的消息转换器列表中


        restTemplate.getMessageConverters().add(0, stringConverter);


        // 创建HttpHeaders对象，设置Accept头部的值为"text/plain;charset=UTF-8"


        HttpHeaders headers = new HttpHeaders();


        headers.setAccept(Collections.singletonList(MediaType.TEXT_PLAIN));


        headers.set(HttpHeaders.ACCEPT_CHARSET, "UTF-8");




        String responseStr = restTemplate.getForObject(requrl, String.class);


        net.sf.json.JSONObject json = net.sf.json.JSONObject.fromObject(responseStr);


        log.info("微信获取用户信息={}", json);


        String nickname = json.getString("nickname");


        String headImgUrl = json.getString("headimgurl");


        System.out.println(nickname);


        System.out.println(headImgUrl);


    }


}