Salesforce与微信公众号集成实现输入关键字搜索文章

@RestResource(urlMapping=‘/WeChatRest/*‘)
global without sharing class WeChatRestController  
{
    @HttpGet
    global static void validateSignature() {
        //获取微信端传递的参数
        String signature = RestContext.request.params.get(‘signature‘); // 微信加密签名 
        String timestamp = RestContext.request.params.get(‘timestamp‘); // 微信请求URL时传过来的timestamp值
        String nonce = RestContext.request.params.get(‘nonce‘); // 随机数-->微信请求URL时传过来的nonce值
        String echostr = RestContext.request.params.get(‘echostr‘); // 随机字符串
        // 转换规则详情：https://developers.weixin.qq.com/doc/offiaccount/Basic_Information/Access_Overview.html
        //1. 字典排序
        String myToken = ‘zhangyq‘;
        List<String> paramList = new List<String>{myToken,timestamp,nonce};
        paramList.sort();
        String content = ‘‘;
        for(String param : paramList) {
            content += param;
        }
        // 2. sha1算法转换
        Blob hash = Crypto.generateDigest(‘SHA1‘, Blob.valueOf(content));  
        String hexString= EncodingUtil.convertToHex(hash);
        //3. 比对转换后的值是否和传递的echostr相同，相同证明认证通过
        Boolean isValid = hexString != null ? signature.equalsIgnoreCase(hexString) : false;
        
        if(isValid) {
            RestContext.response.addHeader(‘Content-Type‘, ‘text/plain‘);
            RestContext.response.responseBody = Blob.valueOf(echostr);
        }
    }
}

public with sharing class RequestMessage {
    public String toUserName;
    public String fromUserName;
    public String msgType;   
    public String content;

    public RequestMessage(String toUserName,String fromUserName,String msgType,String content) {
        this.toUserName = toUserName;
        this.fromUserName = fromUserName;
        this.msgType = msgType;
        this.content = content;
    }
}

public with sharing class ResponseMessage {
    public String title;
    public String url;

    public ResponseMessage(String title,String url) {
      this.title = title;
      this.url = url;
    }
}

@RestResource(urlMapping=‘/WeChatRest/*‘)
global without sharing class WeChatRestController  
{
    @HttpGet
    global static void validateSignature() {
        //获取微信端传递的参数
        String signature = RestContext.request.params.get(‘signature‘); // 微信加密签名 
        String timestamp = RestContext.request.params.get(‘timestamp‘); // 微信请求URL时传过来的timestamp值
        String nonce = RestContext.request.params.get(‘nonce‘); // 随机数-->微信请求URL时传过来的nonce值
        String echostr = RestContext.request.params.get(‘echostr‘); // 随机字符串
        // 转换规则详情：https://developers.weixin.qq.com/doc/offiaccount/Basic_Information/Access_Overview.html
        //1. 字典排序
        String myToken = ‘zhangyq‘;
        List<String> paramList = new List<String>{myToken,timestamp,nonce};
        paramList.sort();
        String content = ‘‘;
        for(String param : paramList) {
            content += param;
        }
        // 2. sha1算法转换
        Blob hash = Crypto.generateDigest(‘SHA1‘, Blob.valueOf(content));  
        String hexString= EncodingUtil.convertToHex(hash);
        //3. 比对转换后的值是否和传递的echostr相同，相同证明认证通过
        Boolean isValid = hexString != null ? signature.equalsIgnoreCase(hexString) : false;
        
        if(isValid) {
            RestContext.response.addHeader(‘Content-Type‘, ‘text/plain‘);
            RestContext.response.responseBody = Blob.valueOf(echostr);
        }
    }


    @HttpPost
  global static void doPost() {
    
        RestRequest req = RestContext.request;
        RestResponse res = RestContext.response;

        string strMsg = req.requestBody.toString();
        system.debug(‘*** message from wechat : ‘ + strMsg);
        XmlStreamReader reader = new XmlStreamReader(strMsg);
        String toUserName = ‘‘;
        String fromUserName = ‘‘;
        String msgType = ‘‘;
        String content = ‘‘;
        
        //解析微信传递过来的XML，将主要的内容的值取出来并进行操作
        while(reader.hasNext()) {
            if(reader.getLocalName() == ‘ToUserName‘) {
                reader.next();
                if(String.isNotBlank(reader.getText())) {
                    toUserName = reader.getText();
                }
            } else if(reader.getLocalName() == ‘FromUserName‘) {
                reader.next();
                if(String.isNotBlank(reader.getText())) {
                    fromUserName = reader.getText();
                }
            } else if(reader.getLocalName() == ‘MsgType‘) {
                reader.next();
                if(String.isNotBlank(reader.getText())) {
                    msgType = reader.getText();
                }
            } else if(reader.getLocalName() == ‘Content‘) {
                reader.next();
                if(String.isNotBlank(reader.getText())) {
                    content = reader.getText();
                }
            }
            
            reader.next();
        }

        //封装到request bean中用于获取传递过来的关键字的值
        RequestMessage receiveMsg = new RequestMessage(toUserName,fromUserName,msgType,content);
        //返回到微信的XML格式类型的字符串
        String resultXML;
        
        //根据输入类型进行处理，目前公众号只支持文本类型
        if(msgType.equals(‘text‘)){  
           resultXML = buildResponseXMLByContent(receiveMsg);
        } else {
            resultXML = buildResponseXML(receiveMsg,null);
        }
        RestContext.response.addHeader(‘Content-Type‘, ‘text/plain‘);  
        RestContext.response.responseBody = Blob.valueOf(resultXML);  
    }

    private static String buildResponseXMLByContent(RequestMessage message) {
        //用于作为XML拼装的返回结果
        String buildXMLString;
        
        //通过SOSL根据关键字进行搜索，最多返回5条
        String keyword = ‘\‘‘ + message.content + ‘\‘‘;
        String soslString = ‘FIND‘ + keyword + ‘IN ALL FIELDS ‘ 
                                + ‘ RETURNING ‘
                                + ‘ My_Blog__c(Title__c,Blog_URL__c,Picture_URL__c,Description__c) LIMIT 5‘;

        List<List<SObject>> soslResultList = search.query(soslString);
        //对搜索出来的结果集进行封装，然后加工处理XML作为微信返回内容
        List<ResponseMessage> responseMessageList = new List<ResponseMessage>();


        List<My_Blog__c> myBlogList = new List<My_Blog__c>();
        if(soslResultList.size() > 0) {
            myBlogList = (List<My_Blog__c>)soslResultList.get(0);
        }

        for(My_Blog__c myBlog : myBlogList) {
            ResponseMessage messageItem = new ResponseMessage(myBlog.Title__c,myBlog.Blog_URL__c);
            responseMessageList.add(messageItem);
        }
        buildXMLString = buildResponseXML(message, responseMessageList);
        System.debug(LoggingLevel.INFO, ‘*** buildXMLString: ‘ + buildXMLString);
        return buildXMLString;
    }

    private static String buildResponseXML(RequestMessage message,List<ResponseMessage> responseMessageList) {
        
        String newsTpl = ‘<item><Title><![CDATA[{0}]]></Title><Description><![CDATA[{1}]]></Description><PicUrl><![CDATA[{2}]]></PicUrl><Url><![CDATA[{3}]]></Url></item>‘;

        String currentDateTime = System.now().format(‘YYYY-MM-dd HH:mm:ss‘);

        //根据微信公众号规则拼装XML模板
        String responseMessageTemplate = ‘<xml><ToUserName><![CDATA[{0}]]></ToUserName><FromUserName><![CDATA[{1}]]></FromUserName><CreateTime>‘ + currentDateTime + ‘</CreateTime><MsgType><![CDATA[text]]></MsgType>‘ + ‘<Content><![CDATA[{2}]]></Content>‘ +‘</xml>‘;
        //XML模板中对应的Placeholder的值
        String[] arguments;
        //非文本输入提示
        if(!message.msgType.equalsIgnoreCase(‘text‘)) {
            arguments = new String[]{message.fromUserName, message.toUserName, ‘该公众号目前支支持文字输入‘};
        } else {
            //没有搜索出记录提示
            if(responseMessageList.isEmpty()) {
                arguments = new String[]{message.fromUserName, message.toUserName, ‘没有匹配的数据，请重新尝试其他的关键字‘};
            } else {
                String messageStringBuffer = ‘‘;
                for(ResponseMessage responseItem : responseMessageList) {
                    messageStringBuffer += ‘<a href="‘ + responseItem.url + ‘">‘ + responseItem.title + ‘"></a>\n‘;
                }
                messageStringBuffer = messageStringBuffer.removeEnd(‘\n‘);
                arguments = new String[]{message.fromUserName, message.toUserName, messageStringBuffer};
            }
        }     
        String results = String.format(responseMessageTemplate, arguments);
        return results;
    }
}