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


@@ -5,6 +5,7 @@


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.common.utils.HttpCurlUtil;


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


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


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


@@ -16,20 +17,25 @@


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


@@ -43,6 +49,7 @@


    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;


    private final MallMemberMapper memberMapper;


    private final MallMemberWalletMapper mallMemberWalletMapper;


    private final RestTemplate restTemplate;




    @Override


    @Transactional(rollbackFor = Exception.class)


@@ -185,6 +192,7 @@


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


        mallMember.setSex("男");


        mallMember.setBindPhone(null);


        mallMember.setOpenId(memberOpenId);


        memberMapper.insert(mallMember);


        //生成邀请码


        String inviteId = ShareCodeUtil.toSerialCode(mallMember.getId());


@@ -244,6 +252,7 @@


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


        mallMember.setSex("男");


        mallMember.setBindPhone(null);


        mallMember.setOpenId(openId);


        memberMapper.insert(mallMember);


        //生成邀请码


        String inviteId = ShareCodeUtil.toSerialCode(mallMember.getId());


@@ -281,4 +290,64 @@


        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);


    }


}