之前一直没有写这篇文章，是觉得企微的服务商应用相对简单。第二个原因是最近在弄钉钉的ISV上架，所以时间不是很充足。正题开始……

第一章 服务商入驻

1、使用管理员登录服务商管理后台

企业微信-服务商后台-登录地址https://open.work.weixin.qq.com/wwopen/login2、输入基本信息及认证

第二章 应用配置

1、登录后，直接创建创建网页应用，如下图。

 2、应用详情-使用配置-参照下面的教程。主页地址是固定的，只需要写入自己的appid和redirect_uri的地址就行。这里需要注意，可信域名必须配置一下，需要注意的是这个一级域名一旦使用的服务商应用，那么自建应用是无法在使用这个域名的，即便是不同的二级域名也不可以。这个还是比较坑，导致我们重新申请了一个一级域名来服务自建应用。

 3、可信域名配置，使用配置-点击【编辑】，然后点击【校验可信域名归属】，然后下载这个文件到nginx配置的域名文件夹下，只要通过步骤2的地址可以访问到就算验证通过。nginx的配置参照下面的这个文章。

nginx配置websocket或https的转发教程_renkai721的博客-CSDN博客_nginx websocket转发nginx配置http,https,ssl,websocket转发https://blog.csdn.net/renkai721/article/details/125991270

 4、数据回调的配置

第三章 应用开发

1、pom.xml中添加解析XML格式内容

 
		
		<dependency>
			<groupId>org.jdomgroupId>
			<artifactId>jdom2artifactId>
			<version>2.0.6version>
		dependency>
		<dependency>
			<groupId>commons-codecgroupId>
			<artifactId>commons-codecartifactId>
			<version>1.15version>
		dependency>

2、properties文件，不需要那么多，命名更具自己的喜好，这一看就是参照了gitee的binarywang/weixin-java-cp-demo，这个demo如果初学者可以看看，然后自己封装。

 3、核心解密controller.java

package cn.renkai721.controller;
 
import cn.renkai721.bean.*;
import cn.renkai721.configuration.QywxProperties;
import cn.renkai721.service.*;
import cn.renkai721.util.HttpUtil;
import cn.renkai721.util.MsgUtil;
import cn.renkai721.util.WxUtil;
import cn.renkai721.wechataes.WXBizMsgCrypt;
import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RBucket;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
 
import javax.annotation.Resource;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Map;
 
 
@EnableAsync
@RestController
@RequestMapping("/d3f")
@Slf4j
public class D3f2Controller {
    @Resource
    private RedissonClient redissonClient;
    @Autowired
    private RestTemplate restTemplate;
    @Autowired
    private D3fService d3fService;
 
 
    @GetMapping(produces = "text/plain;charset=utf-8")
    public void d3fGet(@RequestParam(name = "msg_signature", required = false) String signature,
                          @RequestParam(name = "timestamp", required = false) String timestamp,
                          @RequestParam(name = "nonce", required = false) String nonce,
                          @RequestParam(name = "echostr", required = false) String echostr,
                          HttpServletResponse response) throws Exception  {
        response.setContentType("text/html;charset=utf-8");
        response.setStatus(HttpServletResponse.SC_OK);
        WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(
                MsgUtil.val("wechat.cp.appConfigs[0].token"),
                MsgUtil.val("wechat.cp.appConfigs[0].aesKey"),
                MsgUtil.val("wechat.cp.corpId"));
        // 需要返回的明文
        String sEchoStr = "";
        try {
            sEchoStr = wxcpt.VerifyURL(signature, timestamp, nonce, echostr);
            log.info("resp sEchoStr={}",sEchoStr);
            response.getWriter().print(sEchoStr);
            return;
        } catch (Exception e) {
            // 验证URL失败，错误原因请查看异常
            e.printStackTrace();
        }
        response.getWriter().print("非法请求");
        return;
    }
 
    @PostMapping(produces = "application/xml; charset=UTF-8")
    public void d3fPost(@RequestParam("msg_signature") String signature,
                     @RequestParam("timestamp") String timestamp,
                     @RequestParam("nonce") String nonce,
                     HttpServletResponse response,
                     HttpServletRequest request) throws Exception {
        String success = "success";
        String type = request.getParameter("type");
        String corpid = request.getParameter("corpid");
        log.info("接收d3f post请求：[signature=[{}], timestamp=[{}], nonce=[{}], type=[{}], corpid=[{}] ]",
                signature, timestamp, nonce, type, corpid);
        try{
            response.setContentType("text/html;charset=utf-8");
            response.setStatus(HttpServletResponse.SC_OK);
            String id = "";
            // 访问应用和企业回调传不同的ID
            if("data".equals(type)){
                // 企微后台设置【数据回调URL】的链接为https://wx.naturobot.com/qywx/d3f?type=data&corpid=$CORPID$
                id = corpid;
            } else {
                id = MsgUtil.val("suite_id");
            }
            WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(MsgUtil.val(
                    "wechat.cp.appConfigs[0].token"),
                    MsgUtil.val("wechat.cp.appConfigs[0].aesKey"),
                    id);
            // 密文，对应POST请求的数据
            String postData = "";
            // 获取加密的请求消息：使用输入流获得加密请求消息postData
            ServletInputStream in = request.getInputStream();
            BufferedReader reader = new BufferedReader(new InputStreamReader(in));
            // 作为输出字符串的临时串，用于判断是否读取完毕
            String tempStr = "";
            while(null != (tempStr=reader.readLine())){
                postData += tempStr;
            }
            String suiteXml = wxcpt.DecryptMsg(signature, timestamp, nonce, postData);
            Map suiteMap = WxUtil.transferXmlToMap(suiteXml);
            log.info("\n req map={}", suiteMap);
            if("suite_ticket".equals(suiteMap.get("InfoType"))){
                // https://developer.work.weixin.qq.com/document/10975#%E8%8E%B7%E5%8F%96%E7%AC%AC%E4%B8%89%E6%96%B9%E5%BA%94%E7%94%A8%E5%87%AD%E8%AF%81
                // 主动推送SuiteTicket直接写入
                // 每十分钟更新一次
                //suite_ticket实际有效期为30分钟，
                String suite_ticket_value = (String) suiteMap.get("SuiteTicket");
                String SuiteId = (String) suiteMap.get("SuiteId");
                log.info("suite_ticket={},SuiteId={}",suite_ticket_value,SuiteId);
                RBucket idBucket = redissonClient.getBucket(QywxProperties.suite_ticket_key);
                idBucket.set(suite_ticket_value);
                // 调用企业微信接口
                d3fService.get_suite_access_token();
 
            }else if("create_auth".equals(suiteMap.get("InfoType"))){
                String authCode = (String) suiteMap.get("AuthCode");
                // SuiteId代表一个企业，相当于suite_id
                String SuiteId = (String) suiteMap.get("SuiteId");
                log.info("第三方应用测试上线，AuthCode={},SuiteId={}",authCode,SuiteId);
                RBucket idBucket = redissonClient.getBucket(QywxProperties.authCode_key+"_"+SuiteId);
                idBucket.set(authCode);
                // 获取企业永久授权码
                idBucket = redissonClient.getBucket(QywxProperties.suite_access_token_key);
                String suite_access_token = idBucket.get();
                String url1 = "https://qyapi.weixin.qq.com/cgi-bin/service/get_permanent_code?suite_access_token="+suite_access_token;
                PermanentReqBean permanentReqBean = new PermanentReqBean();
                permanentReqBean.setAuth_code(authCode);
                ResponseEntity postForEntity1 = restTemplate.postForEntity(url1, permanentReqBean, PermanentRespBean.class);
                log.info("get_permanent_code={}",postForEntity1.getBody());
                if(postForEntity1.getBody().getExpires_in() != null){
                    String authCorpId = postForEntity1.getBody().getAuth_corp_info().getCorpid();
                    log.info("永久授权码中获取的第三方应用的authCorpId={}",authCorpId);
                    String userIdD3f = postForEntity1.getBody().getAuth_user_info().getUserid();
                    // 直接取第一个
                    String agentId = postForEntity1.getBody().getAuth_info().getAgent().get(0).getAgentid();
                    String permanent_code_access_token = postForEntity1.getBody().getAccess_token();
                    String permanent_code = postForEntity1.getBody().getPermanent_code();
                    log.info("permanent_code={}",permanent_code);
                    String open_userid = postForEntity1.getBody().getAuth_user_info().getOpen_userid();
                    // 可以设置企业的许可自动激活状态
// 这里面的东西需要保存下来，不然后面使用的时候没有了就完蛋了
// 这里面的东西需要保存下来，不然后面使用的时候没有了就完蛋了
// 这里面的东西需要保存下来，不然后面使用的时候没有了就完蛋了
                }else{
                    log.error("get_permanent_code api is error");
                }
            }else if("cancel_auth".equals(suiteMap.get("InfoType"))){
                String AuthCorpId = (String) suiteMap.get("AuthCorpId");
                log.info("取消订阅cancel_auth AuthCorpId={}",AuthCorpId);
            }
 
            if("unlicensed_notify".equals(suiteMap.get("Event"))){
                // 该用户帐号未授权
                String AgentID = (String) suiteMap.get("AgentID");
                String ToUserName = (String) suiteMap.get("ToUserName");
                String FromUserName = (String) suiteMap.get("FromUserName");
                log.info("用户帐号没有开通授权，需要授权");
            }else if("change_app_admin".equals(suiteMap.get("Event"))){
                String AgentID = (String) suiteMap.get("AgentID");
                // ToUserName=corpId
                String ToUserName = (String) suiteMap.get("ToUserName");
                log.info("第三方应用change_app_admin，ToUserName={},AgentID={}",ToUserName,AgentID);
            }else if("subscribe".equals(suiteMap.get("Event"))){
                log.info("新用户关注，user={}",suiteMap);
                // 回复感谢关注
                String ToUserName = (String) suiteMap.get("ToUserName");
                String FromUserName = (String) suiteMap.get("FromUserName");
                String AgentID = (String) suiteMap.get("AgentID");
                // 获取临时授权码
                RBucket idBucket = redissonClient.getBucket(QywxProperties.suite_access_token_key);
                String suite_access_token = idBucket.get();
                String url1 = "https://qyapi.weixin.qq.com/cgi-bin/service/get_pre_auth_code?suite_access_token=" + suite_access_token;
                String postData1 = HttpUtil.sendGet(url1);
                log.info("get_pre_auth_code={}", postData1);
                String subscribe_pre_auth_code = JSON.parseObject(postData1).getString("pre_auth_code");
                String expires_in = JSON.parseObject(postData1).getString("expires_in");
                if(!StringUtils.isEmpty(expires_in)){
                    // 设置授权配置
                    url1 = "https://qyapi.weixin.qq.com/cgi-bin/service/set_session_info?suite_access_token=" + suite_access_token;
                    SessionInfoReqBean sessionInfoReqBean = new SessionInfoReqBean();
                    sessionInfoReqBean.setPre_auth_code(subscribe_pre_auth_code);
                    SessionInfoBean sessionInfoBean = new SessionInfoBean();
                    sessionInfoBean.setAppid(new Integer[0]);
                    sessionInfoBean.setAuth_type(Integer.parseInt(MsgUtil.val("authType")));
                    sessionInfoReqBean.setSession_info(sessionInfoBean);
                    log.info("sessionInfoReqBean={}", JSON.toJSONString(sessionInfoReqBean));
                    ResponseEntity postForEntity = restTemplate.postForEntity(url1, sessionInfoReqBean, SessionInfoRespBean.class);
                    log.info("设置授权配置={}", postForEntity.getBody());
                }else{
                    log.error("get_pre_auth_code api is error");
                }
                // 发送XML消息给用户
                String Title = "谢谢安装该应用";
                String Description = "我们的应用很好用，如果有问题请拨打电话021-12345";
                String Url = MsgUtil.val("poster.freeUrl");
                String PicUrl = "https://wx.naturobot.com/qywx/image/bg1.png";
                log.info("Title={},Description={},Url={},PicUrl={},",Title,Description,Url,PicUrl);
                String xmlOutMsg = wxcpt.getXmlNewsMessage(FromUserName,ToUserName,Title,Description,Url,PicUrl);
                success = wxcpt.EncryptMsg(xmlOutMsg, timestamp, nonce);
            }else if("enter_agent".equals(suiteMap.get("Event"))){
                // 用户打开应用的事件
            }
 
            if("text".equals(suiteMap.get("MsgType"))){
                // 用户发送了文本消息给应用
                String ToUserName = (String) suiteMap.get("ToUserName");
                String FromUserName = (String) suiteMap.get("FromUserName");
                String AgentID = (String) suiteMap.get("AgentID");
                String xmlOutMsg = wxcpt.getXmlTextMessage(FromUserName,ToUserName,"暂未开启聊天功能。");
                success = wxcpt.EncryptMsg(xmlOutMsg, timestamp, nonce);
            }
 
        } catch (Exception e) {
            e.printStackTrace();
        }
        response.getWriter().print(success);
        return;
    }
 
 
 
}

4、解密工具WXBizMsgCrypt.java

/**
 * 对企业微信发送给企业后台的消息加解密示例代码.
 * 
 * @copyright Copyright (c) 1998-2014 Tencent Inc.
 */
 
// ------------------------------------------------------------------------
 
/**
 * 针对org.apache.commons.codec.binary.Base64，
 * 需要导入架包commons-codec-1.9（或commons-codec-1.8等其他版本）
 * 官方下载地址：http://commons.apache.org/proper/commons-codec/download_codec.cgi
 */
package cn.renkai721.wechataes;
 
import org.apache.commons.codec.binary.Base64;
 
import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;
import java.nio.charset.Charset;
import java.util.Arrays;
import java.util.Random;
 
/**
 * 提供接收和推送给企业微信消息的加解密接口(UTF8编码的字符串).
 * 
 * 	
第三方回复加密消息给企业微信