bsd-say/src/main/java/com/bsd/say/service/impl/WeixinService.java

package com.bsd.say.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.bsd.say.config.RedisProperies;
import com.bsd.say.entities.Record;
import com.bsd.say.mapper.RecordMapper;
import com.bsd.say.service.RedisService;
import com.bsd.say.util.AESWithJCEUtils;
import com.bsd.say.util.HttpRequestUtils;
import com.bsd.say.util.LogUtils;
import com.bsd.say.util.wechat.Sign;
import me.chanjar.weixin.open.api.impl.WxOpenInRedisConfigStorage;
import me.chanjar.weixin.open.api.impl.WxOpenMessageRouter;
import me.chanjar.weixin.open.api.impl.WxOpenServiceImpl;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import redis.clients.jedis.JedisPool;

import javax.annotation.Resource;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;

@Service
public class WeixinService extends WxOpenServiceImpl {


    @Value("${wechat.aesKey}")
    private String aesKey;
    @Value("${wechat.componentToken}")
    private String componentToken;
    @Value("${wechat.appId}")
    private String appId;
    @Value("${wechat.componentAppId}")
    private String componentAppId;
    @Value("${wechat.componentAppSecret}")
    private String componentAppSecret;
    @Value("${wechat.getComponentAccessTokenUrl}")
    private String getComponentAccessTokenUrl;
    @Value("${wechat.getAccessTokenUrl}")
    private String getAccessTokenUrl;
    @Value("${wechat.getUnionIdUrl}")
    private String getUnionIdUrl;
    @Value("${wechat.getWxUserInfoUrl}")
    private String getWxUserInfoUrl;
    @Value("${wechat.getTicketUrl}")
    private String getTicketUrl;
    @Resource
    private RedisTemplate redisTemplate;
    @Resource
    private RecordMapper recordMapper;
    private WxOpenMessageRouter wxOpenMessageRouter;

    @Resource
    private RedisService redisService;


    Logger logger = LogUtils.getBussinessLogger();

    /**
     * 刷新第三方accessToken
     */

    public void refreshComponentAccessToken() {
        RedisProperies redisProperies = new RedisProperies();
        JedisPool pool =
                new JedisPool(redisProperies, redisProperies.getHost(),
                        redisProperies.getPort(), redisProperies.getConnectionTimeout(),
                        redisProperies.getSoTimeout(), redisProperies.getPassword(),
                        redisProperies.getDatabase(), redisProperies.getClientName(),
                        redisProperies.isSsl(), redisProperies.getSslSocketFactory(),
                        redisProperies.getSslParameters(), redisProperies.getHostnameVerifier());
        try {
            WxOpenInRedisConfigStorage inRedisConfigStorage = new WxOpenInRedisConfigStorage(pool);
            inRedisConfigStorage.setComponentAppId(componentAppId);
            inRedisConfigStorage.setComponentAppSecret(componentAppSecret);
            inRedisConfigStorage.setComponentToken(componentToken);
            inRedisConfigStorage.setComponentAesKey(aesKey);
            setWxOpenConfigStorage(inRedisConfigStorage);
            wxOpenMessageRouter = new WxOpenMessageRouter(this);
            String ComponentVerifyTicket = inRedisConfigStorage.getComponentVerifyTicket();
            logger.info("ComponentVerifyTicket：" + ComponentVerifyTicket);
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("component_appid", componentAppId);
            jsonObject.put("component_appsecret", componentAppSecret);
            jsonObject.put("component_verify_ticket", ComponentVerifyTicket);
            String post = HttpRequestUtils.sendPost(getComponentAccessTokenUrl, jsonObject);
//            logger.debug("====================返回post结果：" + post);
            HashMap<String, String> hashMap = JSON.parseObject(post, HashMap.class);
            String componentAccessToken = hashMap.get("component_access_token");
            if (StringUtils.isNotEmpty(componentAccessToken)) {
                redisTemplate.opsForValue().set("component_access_token", componentAccessToken, 60 * 60 * 2, TimeUnit.SECONDS);
                String accessToken = redisTemplate.opsForValue().get("component_access_token").toString();
                System.out.println("accessToken" + accessToken);
//                logger.debug("====================令牌component_access_token】：【" + accessToken + "】====================");
            } else {
                throw new RuntimeException("微信开放平台，第三方平台获取【令牌】失败");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 获取accessToken
     *
     * @return
     */
    public JSONObject getAccessToken(String code) {
        String component_access_token = redisTemplate.opsForValue().get("component_access_token").toString();
        String param = appId + "&code=" + code + "&grant_type=authorization_code&component_appid=" + componentAppId
                + "&component_access_token=" + component_access_token;
        String url = getAccessTokenUrl + param;
        String result = HttpRequestUtils.sendGet(url);
        JSONObject resultJson = JSONObject.parseObject(result);
        return resultJson;
    }

    /**
     * 获取unionId
     *
     * @param code
     * @return
     */
    public String getUnionId(String code) {
        JSONObject jsonObject = getAccessToken(code);
        String accessToken = jsonObject.getString("access_token");
        String openid = jsonObject.getString("openid");
        String param = accessToken + "&openid=" + openid + "&lang=zh_CN";
        String url = getUnionIdUrl + param;
        String result = HttpRequestUtils.sendGet(url);
        JSONObject resultJson = JSONObject.parseObject(result);
        String unionId = resultJson.getString("unionid");
        return unionId;
    }

    /**
     * 通过openId获取用户信息(含是否订阅公众号)
     */
    public JSONObject getUserInfoByOpenId(String openId) {
        String result1 = HttpRequestUtils.sendGet("https://api.weq.me/wx/token.php?id=15969759463491&key=1234567890123456");
        JSONObject result2 = JSONObject.parseObject(result1);
        String result3 = result2.getString("access_token");
        String pubkey = "1234567890123456";
        String iv = "WJi7HTZQoh8eHjup";
        String decode = AESWithJCEUtils.aesDecode(result3, pubkey, iv);
        String resutl = HttpRequestUtils.sendGet("https://api.weixin.qq.com/cgi-bin/user/info?access_token=" + decode + "&openid=" + openId + "&lang=zh_CN");
        JSONObject jsonObject = JSONObject.parseObject(resutl);
        logger.info("userInfo:" + jsonObject.toString());
        return jsonObject;
    }

    /**
     * 通过accessToken刷新ticket
     */
    public String getTicket() {
        String access_token = fetchAccessToken();
        String getTicketNewUrl = getTicketUrl + access_token + "&type=jsapi";
        String ticketResult = HttpRequestUtils.sendGet(getTicketNewUrl);
        JSONObject ticketJson = JSONObject.parseObject(ticketResult);
        String jsapi_ticket = ticketJson.getString("ticket");
//        redisTemplate.opsForValue().set("jsapi_ticket",jsapi_ticket);
        return jsapi_ticket;
    }

    public Map<String, String> getSign(String url) {
        String jsapiTicket = getTicket();
        logger.info("jsapiTicket:" + jsapiTicket);
        Map<String, String> sign = Sign.sign(jsapiTicket, url);
        sign.put("appId", appId);
        logger.info("sign:" + sign);
        return sign;
    }

    /**
     * 插入记录的
     *
     * @param openId
     * @param subscribe
     */
    public void insertRecord(String openId, Integer subscribe) {
        logger.info("subscribe：" + subscribe);
        Record recordByOpenId = recordMapper.selectOne(Wrappers.<Record>lambdaQuery().eq(Record::getOpenId, openId)
                .and(queryWrapper1 -> queryWrapper1.eq(Record::getState, 1)));
        if (subscribe == 0) {
            //未关注公众号
            if (recordByOpenId == null) {
                logger.info("新粉丝第一次进入");
                Record record = new Record();
                record.setOpenId(openId);
                record.setFan("新粉丝");
                record.setCreateDateTime(new Date());
                recordMapper.insert(record);
            } else {
                logger.info("游客访问过，但未关注");
            }
        } else {
            //关注过公众号
            if (recordByOpenId == null) {
                logger.info("老粉丝第一次进入");
                Record record = new Record();
                record.setOpenId(openId);
                record.setFan("老粉丝");
                record.setCreateDateTime(new Date());
                recordMapper.insert(record);
            } else {
                logger.info("老粉丝访问过,已关注");
            }
        }
    }

    public JSONObject autoLogin(String openId) {

        String userInfo = "";
        if (redisService.exists(openId)) {

            userInfo = redisService.get(openId).toString();
            JSONObject jsonObject = JSONObject.parseObject(userInfo);
            Integer subscribe = jsonObject.getInteger("subscribe");
            insertRecord(openId, subscribe);
            return jsonObject;
        }

        String accessToken = fetchAccessToken();
        userInfo = HttpRequestUtils.sendGet("https://api.weixin.qq.com/cgi-bin/user/info?access_token=" + accessToken + "&openid=" + openId + "&lang=zh_CN");
        redisService.set(openId, userInfo.toString());
        JSONObject jsonObject = JSONObject.parseObject(userInfo);
        Integer subscribe = jsonObject.getInteger("subscribe");
        insertRecord(openId, subscribe);
        return jsonObject;
    }

    public String fetchAccessToken() {

        String access_token = "";
        //从cache中获取
        if (redisService.exists("access_token")) {
            access_token = redisService.get("access_token").toString();
            return access_token;
        }
        String accessTokenResult = HttpRequestUtils.sendGet("https://api.weq.me/wx/token.php?id=15969759463491&key=1234567890123456");
        JSONObject accessTokenObject = JSONObject.parseObject(accessTokenResult);
        String aesAccessToken = accessTokenObject.getString("access_token");
        Long expiresIn = accessTokenObject.getLongValue("expires_in");
        String pubkey = "1234567890123456";
        String iv = "WJi7HTZQoh8eHjup";
        String accessToken = AESWithJCEUtils.aesDecode(aesAccessToken, pubkey, iv);
        redisService.set("access_token", access_token, expiresIn - 1000);
        return accessToken;
    }


}