mxys_backend/src/main/java/com/sqx/modules/utils/SenInfoCheckUtil.java

package com.sqx.modules.utils;

import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Maps;
import com.sqx.common.constant.RedisKey;
import com.sqx.common.utils.RedisUtils;
import com.sqx.modules.common.entity.CommonInfo;
import com.sqx.modules.common.service.CommonInfoService;
import icu.xuyijie.secureapi.cipher.CipherAlgorithmEnum;
import icu.xuyijie.secureapi.cipher.CipherUtils;
import icu.xuyijie.secureapi.model.SecureApiPropertiesConfig;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import javax.imageio.ImageIO;
import javax.servlet.http.HttpServletResponse;
import java.awt.image.BufferedImage;
import java.io.InputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.URL;
import java.net.URLConnection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


@Component
@Slf4j
public class SenInfoCheckUtil {

    private static Logger logger = LoggerFactory.getLogger(SenInfoCheckUtil.class);

    // 这里使用静态，让 service 属于类
    private static CommonInfoService commonInfoService;

    private static RedisUtils redisUtils;

    private static boolean GET_MP_TOKEN_FROM_TEMP;
    private static SecureApiPropertiesConfig SECUREAPIPROPERTIESCONFIG;

    // 注入的时候，给类的 service 注入
    @Autowired
    public void setWxChatContentService(CommonInfoService commonInfoService, RedisUtils redisUtils, @Value("${mp.temp:false}") boolean isTemp, SecureApiPropertiesConfig secureApiPropertiesConfig) {
        SenInfoCheckUtil.commonInfoService = commonInfoService;
        SenInfoCheckUtil.redisUtils = redisUtils;
        SenInfoCheckUtil.GET_MP_TOKEN_FROM_TEMP = isTemp;
        SenInfoCheckUtil.SECUREAPIPROPERTIESCONFIG = secureApiPropertiesConfig;
    }


    /**
     * 获取Token  小程序
     * @return AccessToken
     */
    public static String getMpToken(){
        String token = (String) redisUtils.get(RedisKey.MP_TOKEN_CACHE_KEY);
        if (StrUtil.isBlank(token)) {
            if (!GET_MP_TOKEN_FROM_TEMP) {
                token = getMpAccessToken();
            } else {
                try {
                    token = doDecrypt(HttpUtil.get("https://mxys.chuanghai-tech.com/sqx_fast/app/wxPay/temp/token/1"));
                } catch (Exception e) {}
            }
            redisUtils.set(RedisKey.MP_TOKEN_CACHE_KEY, token, RedisUtils.HOUR_ONE_EXPIRE);
        }
        return token;
    }

    /**
     * 获取Token  小程序
     * @return AccessToken
     */
    public static String getRiderMpToken() {
        String token = (String) redisUtils.get(RedisKey.MP_OF_RIDER_TOKEN_CACHE_KEY);
        if (StrUtil.isBlank(token)) {
            if (!GET_MP_TOKEN_FROM_TEMP) {
                token = getRiderMpAccessToken();
            } else {
                try {
                    token = doDecrypt(HttpUtil.get("https://mxys.chuanghai-tech.com/sqx_fast/app/wxPay/temp/token/1"));
                } catch (Exception e) {}
            }

            redisUtils.set(RedisKey.MP_OF_RIDER_TOKEN_CACHE_KEY, token, RedisUtils.HOUR_ONE_EXPIRE);
        }
        return token;
    }

    public static String getShopMpToken() {
        String token = (String) redisUtils.get(RedisKey.MP_OF_SHOP_TOKEN_CACHE_KEY);
        if (StrUtil.isBlank(token)) {
            if (!GET_MP_TOKEN_FROM_TEMP) {
                token = getShopMpAccessToken();
            } else {
                try {
                    token = doDecrypt(HttpUtil.get("https://mxys.chuanghai-tech.com/sqx_fast/app/wxPay/temp/token/1"));
                } catch (Exception e) {}
            }

            redisUtils.set(RedisKey.MP_OF_SHOP_TOKEN_CACHE_KEY, token, RedisUtils.HOUR_ONE_EXPIRE);
        }
        return token;
    }

    private static String doDecrypt(String text) {
        CipherUtils cipherUtils = new CipherUtils(CipherAlgorithmEnum.AES_CBC_PKCS5);
        String key = SECUREAPIPROPERTIESCONFIG.getKey();
        String iv = SECUREAPIPROPERTIESCONFIG.getIv();
        return cipherUtils.decrypt(text, key, iv);
    }

    public static void getImg(String relation,String goodsId,String type, String page,HttpServletResponse response){
        String mpToken = getMpToken();
        //获取二维码数据
        String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token="+mpToken;
        Map<String,Object> map = Maps.newHashMap();
        map.put("scene",relation+"&"+goodsId+"&"+type);
        String value = commonInfoService.findOne(105).getValue();
        if("是".equals(value)){
            map.put("page",page);
        }
        map.put("width", 280);
        String jsonString = JSON.toJSONString(map);
        InputStream inputStream = sendPostBackStream(url, jsonString);
        //生成二维码图片
        response.setContentType("image/png");
        try{
            BufferedImage bi = ImageIO.read(inputStream);
            ImageIO.write(bi, "JPG", response.getOutputStream());
            inputStream.close();
        }catch (Exception e){
            e.printStackTrace();
        }
    }


    /**
     * 获取二维码图片
     */
    public static void getPoster(String invitationCode, HttpServletResponse response){
        String mpToken = getMpToken();
        //获取二维码数据
        String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token="+mpToken;
        Map<String,Object> map = Maps.newHashMap();
        map.put("scene",invitationCode);
        map.put("width", 280);
        String jsonString = JSON.toJSONString(map);
        InputStream inputStream = sendPostBackStream(url, jsonString);
        //生成二维码图片
        response.setContentType("image/png");
        try{
            BufferedImage bi = ImageIO.read(inputStream);
            ImageIO.write(bi, "JPG", response.getOutputStream());
            inputStream.close();
        }catch (Exception e){
            logger.error(e.getMessage());
        }
    }

    /**
     * 获取二维码图片
     */
    public static void getShopQr(String shopId, HttpServletResponse response){
        String mpToken = getMpToken();
        //获取二维码数据
        String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token="+mpToken;
        Map<String,Object> map = Maps.newHashMap();
        map.put("scene",shopId);
        CommonInfo one = commonInfoService.findOne(261);
        if("是".equals(one.getValue())){
            map.put("page","pages/index/index");
        }

        map.put("width", 280);
        String jsonString = JSON.toJSONString(map);
        InputStream inputStream = sendPostBackStream(url, jsonString);
        //生成二维码图片
        response.setContentType("image/png");
        try{
            BufferedImage bi = ImageIO.read(inputStream);
            ImageIO.write(bi, "JPG", response.getOutputStream());
            inputStream.close();
        }catch (Exception e){
            logger.error(e.getMessage());
        }
    }

    /*public static void getShopQr(String shopId, HttpServletResponse response){
        String mpToken = getMpToken();
        //获取二维码数据
        String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token="+mpToken;
        Map<String,Object> map = Maps.newHashMap();
        CommonInfo one = commonInfoService.findOne(261);
      //  if("是".equals(one.getValue())){
            map.put("page","/pages/index/index?shopId="+shopId);
       // }
    //    map.put("scene",shopId);
        map.put("width", 280);
        String jsonString = JSON.toJSONString(map);
        InputStream inputStream = sendPostBackStream(url, jsonString);
        //生成二维码图片
        response.setContentType("image/png");
        try{
            BufferedImage bi = ImageIO.read(inputStream);
            ImageIO.write(bi, "JPG", response.getOutputStream());
            inputStream.close();
        }catch (Exception e){
            logger.error(e.getMessage());
        }
    }*/

    private static InputStream sendPostBackStream(String url, String param) {
        PrintWriter out = null;
        try {
            URL realUrl = new URL(url);
            // 打开和URL之间的连接
            URLConnection conn = realUrl.openConnection();
            // 设置通用的请求属性
            conn.setRequestProperty("accept", "*/*");
            conn.setRequestProperty("connection", "Keep-Alive");
            conn.setRequestProperty("user-agent",
                    "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            conn.setDoOutput(true);
            conn.setDoInput(true);
            //解决乱码问题
            OutputStreamWriter outWriter =new OutputStreamWriter(conn.getOutputStream(), "utf-8");
            out =new PrintWriter(outWriter);
            // 发送请求参数
            if(StringUtils.isNotBlank(param)) {
                out.print(param);
            }
            // flush输出流的缓冲
            out.flush();
            return conn.getInputStream();
        } catch (Exception e) {
            logger.error("发送 POST 请求出现异常！"+e);
        } finally{
            IOUtils.closeQuietly(out);
        }
        return null;
    }


    /**
     * 获取access_token
     * 每个两个小时自动刷新AcessTocken
     */
   // @Scheduled(cron = "0 0 */2 * * ?")
    public static String getMpAccessToken(){
        String appid = commonInfoService.findOne(45).getValue();
        String secret = commonInfoService.findOne(46).getValue();
        String jsonResult = HttpClientUtil.doPost("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appid + "&secret=" + secret);
        JSONObject parseObject = JSON.parseObject(jsonResult);
        logger.info("=========accessTokenOut========="+parseObject.toJSONString());

        String errcode = parseObject.getString("errcode");
        String accessToken = parseObject.getString("access_token");
        String expiresIn = parseObject.getString("expires_in");
        return accessToken;
    }

    public static String getRiderMpAccessToken(){
        String appid = commonInfoService.findOne(248).getValue();
        String secret = commonInfoService.findOne(249).getValue();
        String jsonResult = HttpClientUtil.doPost("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appid + "&secret=" + secret);
        JSONObject parseObject = JSON.parseObject(jsonResult);
        logger.info("=========accessTokenOut========="+parseObject.toJSONString());

        String errcode = parseObject.getString("errcode");
        String accessToken = parseObject.getString("access_token");
        String expiresIn = parseObject.getString("expires_in");
        return accessToken;
    }


    public static String getShopMpAccessToken(){
        String appid = commonInfoService.findOne(305).getValue();
        String secret = commonInfoService.findOne(306).getValue();
        String jsonResult = HttpClientUtil.doPost("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appid + "&secret=" + secret);
        JSONObject parseObject = JSON.parseObject(jsonResult);
        logger.info("=========accessTokenOut========="+parseObject.toJSONString());

        String errcode = parseObject.getString("errcode");
        String accessToken = parseObject.getString("access_token");
        String expiresIn = parseObject.getString("expires_in");
        return accessToken;
    }

    /**
     * 小程序消息推送
     * @param wxId  用户openId
     * @param templateId  模板id
     * @param msgList  消息内容集合
     * @param type   类型
     */
    public static void sendMsg(String wxId, String templateId, List<String> msgList, Integer type){
        String mpToken = getMpToken();
        RestTemplate restTemplate = new RestTemplate();
        String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" +mpToken;
        //拼接推送的模版
        WxMssVo wxMssVo = new WxMssVo();
        wxMssVo.setTouser(wxId);//用户的openid（要发送给那个用户，通常这里应该动态传进来的）
        wxMssVo.setTemplate_id(templateId);//订阅消息模板id
//        wxMssVo.setPage("pages/index/index");
        wxMssVo.setData(getParam(type,msgList));
        ResponseEntity<String> responseEntity =
                restTemplate.postForEntity(url, wxMssVo, String.class);
        String body = responseEntity.getBody();
        //System.err.println(body);
        log.info("小程序消息通知返回值");
        log.info("小程序消息通知返回值："+ body);
    }


    public static void sendRiderMsg(String wxId, String templateId, List<String> msgList, Integer type) {
        String mpToken = getRiderMpToken();
        RestTemplate restTemplate = new RestTemplate();
        String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" +mpToken;
        //拼接推送的模版
        WxMssVo wxMssVo = new WxMssVo();
        wxMssVo.setTouser(wxId);//用户的openid（要发送给那个用户，通常这里应该动态传进来的）
        wxMssVo.setTemplate_id(templateId);//订阅消息模板id
//        wxMssVo.setPage("pages/index/index");
        wxMssVo.setData(getParam(type,msgList));
        ResponseEntity<String> responseEntity =
                restTemplate.postForEntity(url, wxMssVo, String.class);
        String body = responseEntity.getBody();
        //System.err.println(body);
        log.info("小程序消息通知返回值");
        log.info("小程序消息通知返回值："+ body);
    }

    public static void sendShopMsg(String wxId, String templateId, List<String> msgList, Integer type) {
        String mpToken = getShopMpToken();
        RestTemplate restTemplate = new RestTemplate();
        String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" +mpToken;
        //拼接推送的模版
        WxMssVo wxMssVo = new WxMssVo();
        wxMssVo.setTouser(wxId);//用户的openid（要发送给那个用户，通常这里应该动态传进来的）
        wxMssVo.setTemplate_id(templateId);//订阅消息模板id
//        wxMssVo.setPage("pages/index/index");
        wxMssVo.setData(getParam(type,msgList));
        ResponseEntity<String> responseEntity =
                restTemplate.postForEntity(url, wxMssVo, String.class);
        String body = responseEntity.getBody();
        //System.err.println(body);
        log.info("小程序消息通知返回值");
        log.info("小程序消息通知返回值："+ body);
    }

    /**
     * 订阅消息模板
     * @param type  类型  1 用户端订单状态通知 2骑手端订单完成通知 3 用户端订单取消通知
     *              4 骑手端接单成功通知 5 6 骑手端订单完成 7骑手端新订单通知 8商家端新订单通知 9商家端订单变更通知
     *              10 账户余额充值成功通知
     * @param msgList 对应值
     * @return
     */
    public static Map<String, TemplateParam> getParam(Integer type, List<String> msgList){
        if(type==1){
            Map<String, TemplateParam> paras = new HashMap<>();
            //订单状态
            paras.put("phrase3",new TemplateParam( msgList.get(0)));
            //订单号
            paras.put("character_string1",new TemplateParam( msgList.get(1)));
            //服务门店
            paras.put("thing17",new TemplateParam( msgList.get(2)));
            //订单时间
            paras.put("time12",new TemplateParam( msgList.get(3)));
            return paras;
        }else if(type==2) {
            Map<String, TemplateParam> paras = new HashMap<>();
            //订单标题
            paras.put("thing1", new TemplateParam(msgList.get(0)));
            //下单时间
            paras.put("time7", new TemplateParam(msgList.get(1)));
            //订单状态
            paras.put("phrase2", new TemplateParam(msgList.get(2)));
            //完成时间
            paras.put("time3", new TemplateParam(msgList.get(3)));
            return paras;
        }else if(type==3) {
            Map<String, TemplateParam> paras = new HashMap<>();
            //订单号
            paras.put("character_string1", new TemplateParam(msgList.get(0)));
            //取消原因
            paras.put("thing2", new TemplateParam(msgList.get(1)));
            //退款金额
            paras.put("amount14", new TemplateParam(msgList.get(2)));
            //取消时间
            paras.put("time5", new TemplateParam(msgList.get(3)));
            return paras;
        }else if(type==4) {
            Map<String, TemplateParam> paras = new HashMap<>();
            //服务项目
            paras.put("thing9", new TemplateParam(msgList.get(0)));
            //接单人员
            paras.put("thing6", new TemplateParam(msgList.get(1)));
            //接单时间
            paras.put("time7", new TemplateParam(msgList.get(2)));
            //备注
            paras.put("thing4", new TemplateParam(msgList.get(3)));
            return paras;
        }else if(type==5) {
            Map<String, TemplateParam> paras = new HashMap<>(3);
            //订单名称
            paras.put("character_string1", new TemplateParam(msgList.get(0)));
            //下单时间
            paras.put("phrase3", new TemplateParam(msgList.get(1)));
            //订单状态
            paras.put("thing8", new TemplateParam(msgList.get(2)));
            //完成时间
            paras.put("time11", new TemplateParam(msgList.get(3)));
            return paras;
        }else if(type==6) {
            Map<String, TemplateParam> paras = new HashMap<>(3);
            //订单名称
            paras.put("thing1", new TemplateParam(msgList.get(0)));
            //下单时间
            paras.put("amount13", new TemplateParam(msgList.get(1)));
            //订单状态
            paras.put("thing11", new TemplateParam(msgList.get(2)));
            //完成时间
            paras.put("date4", new TemplateParam(msgList.get(3)));
            return paras;
        }else if(type==7) {
            Map<String, TemplateParam> paras = new HashMap<>(3);
            paras.put("character_string12", new TemplateParam(msgList.get(0)));
            paras.put("amount13", new TemplateParam(msgList.get(1)));
            paras.put("date4", new TemplateParam(msgList.get(2)));
            paras.put("thing5", new TemplateParam(msgList.get(3)));
            return paras;
        }else if(type==8) {
            Map<String, TemplateParam> paras = new HashMap<>(3);
            paras.put("number5", new TemplateParam(msgList.get(0)));
            paras.put("amount3", new TemplateParam(msgList.get(1)));
            paras.put("thing6", new TemplateParam(msgList.get(2)));
            return paras;
        }else if(type==9){
            Map<String, TemplateParam> paras = new HashMap<>(3);
            paras.put("character_string2", new TemplateParam(msgList.get(0)));
            paras.put("phrase5", new TemplateParam(msgList.get(1)));
            paras.put("time3", new TemplateParam(msgList.get(2)));
            return paras;
        } else if (type == 10) {
            Map<String, TemplateParam> paras = new HashMap<>(3);
            paras.put("thing1", new TemplateParam(msgList.get(0)));
            paras.put("amount2", new TemplateParam(msgList.get(1)));
            paras.put("time3", new TemplateParam(msgList.get(2)));
            return paras;
        }
        return null;
    }







}