微信公众号接收文本消息后脚本处理

微信公众号菜单回复媒体消息 菜单执行脚本

o2server/x_base_core_project/src/main/java/com/x/base/core/project/config/MPweixin.java

@@ -30,6 +30,8 @@ public class MPweixin extends ConfigObject  {
     private String encodingAesKey="";
     @FieldDescribe("微信公众号测试菜单的门户地址")
     private String portalId = "";
+    @FieldDescribe("接收到文本消息默认执行的服务脚本id")
+    private String scriptId = "";
 
     @FieldDescribe("是否启用公众号模版消息")
     private Boolean messageEnable;
@@ -59,6 +61,7 @@ public class MPweixin extends ConfigObject  {
         this.token = "";
         this.encodingAesKey = "";
         this.portalId = "";
+        this.scriptId = "";
         this.messageEnable = false;
         this.tempMessageId = "";
         this.fieldList = new ArrayList<>();
@@ -188,6 +191,14 @@ public class MPweixin extends ConfigObject  {
         this.fieldList = fieldList;
     }
 
+    public String getScriptId() {
+        return scriptId;
+    }
+
+    public void setScriptId(String scriptId) {
+        this.scriptId = scriptId;
+    }
+
     /**
      * 微信使用code获取accessToken openid 等数据
      */

o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/mpweixin/ActionReceiveMsg.java

@@ -6,6 +6,13 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+import com.x.base.core.project.Application;
+import com.x.base.core.project.config.CenterServer;
+import com.x.base.core.project.config.Config;
+import com.x.base.core.project.connection.ActionResponse;
+import com.x.base.core.project.connection.CipherConnectionAction;
+import com.x.base.core.project.gson.GsonPropertyObject;
+import com.x.base.core.project.x_jpush_assemble_control;
 import org.apache.commons.lang3.StringUtils;
 import org.dom4j.Document;
 import org.dom4j.Element;
@@ -38,7 +45,7 @@ public class ActionReceiveMsg  extends BaseAction {
             Map<String, String> map = xmlToMap(inputStream);
             String msgType = map.get("MsgType");
 
-            if (WX_MSG_RECEIVE_TYPE_EVENT.equals(msgType)) { //
+            if (WX_MSG_RECEIVE_TYPE_EVENT.equals(msgType)) { // 事件出发
                 String event = map.get("Event");
                 String eventKey = map.get("EventKey");
                 logger.info("接收到事件消息： event: {} , eventKey: {}", event, eventKey);
@@ -49,9 +56,42 @@ public class ActionReceiveMsg  extends BaseAction {
                         String content = menu.getContent();
                         String toUser = map.get("FromUserName");
                         String fromUser = map.get("ToUserName");
-                        String xml = txtMessageBack(toUser, fromUser, content);
-                        logger.info("回复点击菜单消息： {}", xml);
-                        wo.setText(xml);
+                        // 特殊消息处理 默认是回复文字消息 如果是媒体消息 需要配置特殊的头 media:image: 后面跟微信素材的mediaId
+                        if (content.startsWith(WX_MSG_BACK_MEDIA_KEY_IMAGE)) {
+                            String mediaId = content.substring(WX_MSG_BACK_MEDIA_KEY_IMAGE.length());
+                            String xml = imageMessageBack(toUser, fromUser, mediaId);
+                            logger.info("回复点击菜单消息： {}", xml);
+                            wo.setText(xml);
+                        } else if (content.startsWith(WX_MSG_BACK_MEDIA_KEY_VOICE)) {
+                            String mediaId = content.substring(WX_MSG_BACK_MEDIA_KEY_VOICE.length());
+                            String xml = voiceMessageBack(toUser, fromUser, mediaId);
+                            logger.info("回复点击菜单消息： {}", xml);
+                            wo.setText(xml);
+                        } else if (content.startsWith(WX_MSG_BACK_MEDIA_KEY_VIDEO)) {
+                            // 视频消息需要多两个字段 title和description 用｜分割  如： mediaId|title|description
+                            String videoContent = content.substring(WX_MSG_BACK_MEDIA_KEY_VIDEO.length());
+                            String xml = null;
+                            try {
+                                String[] arr = videoContent.split("\\|");
+                                xml = videoMessageBack(toUser, fromUser, arr[0], arr[1], arr[2]);
+                            } catch (Exception e) {
+                                logger.error(e);
+                                xml = txtMessageBack(toUser, fromUser, content);
+                            }
+                            logger.info("回复点击菜单消息： {}", xml);
+                            wo.setText(xml);
+                        } else if (content.startsWith(WX_MSG_BACK_MEDIA_KEY_SCRIPT)) {
+                            String scriptId = content.substring(WX_MSG_BACK_MEDIA_KEY_SCRIPT.length());
+                            if (StringUtils.isNotBlank(scriptId)) {
+                                ExecuteServiceScriptThread runner1 = new ExecuteServiceScriptThread(toUser, "", scriptId);
+                                Thread thread1 = new Thread(runner1);
+                                thread1.start();
+                            }
+                        }  else {
+                            String xml = txtMessageBack(toUser, fromUser, content);
+                            logger.info("回复点击菜单消息： {}", xml);
+                            wo.setText(xml);
+                        }
                         actionResult.setData(wo);
                         return actionResult;
                     } else {
@@ -72,6 +112,17 @@ public class ActionReceiveMsg  extends BaseAction {
                         logger.info("没有查询到对应的 eventKey：{}", eventKey);
                     }
                 }
+            } else if (WX_MSG_RECEIVE_TYPE_TEXT.equalsIgnoreCase(msgType)) { // 接收到文本消息
+                String text = map.get("Content");
+                String toUser = map.get("FromUserName");
+                logger.info("接收到文本消息： text: {} ", text);
+                //TODO 目前支持异步执行服务脚本，这里必须马上返回 否则会超时，脚本里面可以调用微信客服消息进行回复. 脚本id暂时先保存到配置文件
+                String id = Config.mPweixin().getScriptId();
+                if (StringUtils.isNotBlank(id)) {
+                    ExecuteServiceScriptThread runner1 = new ExecuteServiceScriptThread(toUser, text, id);
+                    Thread thread1 = new Thread(runner1);
+                    thread1.start();
+                }
             } else {
                 logger.info("未处理消息类型, MsgType: {}", msgType);
             }
@@ -84,6 +135,7 @@ public class ActionReceiveMsg  extends BaseAction {
     }
 
 
+    // 回复文本消息
     private String txtMessageBack(String toUser, String from, String content) {
         long time = new Date().getTime();
         String xml = "<xml>" +
@@ -96,8 +148,52 @@ public class ActionReceiveMsg  extends BaseAction {
         return xml;
     }
 
+    // 回复图片消息
+    private String imageMessageBack(String toUser, String from, String mediaId) {
+        long time = new Date().getTime();
+        String xml = "<xml>" +
+                "<ToUserName><![CDATA[" + toUser + "]]></ToUserName>" +
+                "<FromUserName><![CDATA[" + from + "]]></FromUserName>" +
+                "<CreateTime>" + time + "</CreateTime>" +
+                "<MsgType><![CDATA[image]]></MsgType>" +
+                "<Image><MediaId><![CDATA["+mediaId+"]]></MediaId></Image>" +
+                "</xml>";
+        return xml;
+    }
 
+    // 回复音频消息
+    private String voiceMessageBack(String toUser, String from, String mediaId) {
+        long time = new Date().getTime();
+        String xml = "<xml>" +
+                "<ToUserName><![CDATA[" + toUser + "]]></ToUserName>" +
+                "<FromUserName><![CDATA[" + from + "]]></FromUserName>" +
+                "<CreateTime>" + time + "</CreateTime>" +
+                "<MsgType><![CDATA[voice]]></MsgType>" +
+                "<Voice><MediaId><![CDATA["+mediaId+"]]></MediaId></Voice>" +
+                "</xml>";
+        return xml;
+    }
 
+    //回复视频消息
+    private String videoMessageBack(String toUser, String from, String mediaId, String title, String description) {
+        long time = new Date().getTime();
+        String xml = "<xml>" +
+                "<ToUserName><![CDATA[" + toUser + "]]></ToUserName>" +
+                "<FromUserName><![CDATA[" + from + "]]></FromUserName>" +
+                "<CreateTime>" + time + "</CreateTime>" +
+                "<MsgType><![CDATA[video]]></MsgType>" +
+                "<Video>"+
+                "<MediaId><![CDATA["+mediaId+"]]></MediaId>" +
+                "<Title><![CDATA["+title+"]]></Title>" +
+                "<Description><![CDATA["+description+"]]></Description>"  +
+                "</Video>" +
+                "</xml>";
+        return xml;
+    }
+
+    private void asyncPostServiceScript(String text) {
+
+    }
 
 
     /**
@@ -128,4 +224,62 @@ public class ActionReceiveMsg  extends BaseAction {
 
     public static class Wo extends WoText {
     }
+
+
+    public static class ExecuteServiceScriptThread implements Runnable {
+        String toUser;
+        String text;
+        String scriptId;
+        ExecuteServiceScriptThread(String toUser, String text, String scriptId) {
+            this.toUser = toUser;
+            this.text = text;
+            this.scriptId = scriptId;
+        }
+        @Override
+        public void run() {
+            evalRemote();
+        }
+
+        private void evalRemote() {
+            try {
+                if (StringUtils.isNotBlank(scriptId)) {
+                    ScriptExecuteBody body = new ScriptExecuteBody();
+                    body.setKeyword(text);
+                    body.setOpenId(toUser);
+                    ActionResponse result = CipherConnectionAction.post(false,
+                            Config.url_x_program_center_jaxrs("invoke",scriptId, "execute"), body);
+                    logger.info("执行脚本结果： " + result.toJson());
+                } else {
+                    logger.warn("没有配置服务脚本id");
+                }
+            } catch (Exception e) {
+                logger.error(e);
+            }
+        }
+    }
+
+    /**
+     * 脚本执行传入对象
+     */
+    public static class ScriptExecuteBody extends GsonPropertyObject {
+        // 微信公众号 用户的 openId
+        private String openId;
+        private String keyword;
+
+        public String getOpenId() {
+            return openId;
+        }
+
+        public void setOpenId(String openId) {
+            this.openId = openId;
+        }
+
+        public String getKeyword() {
+            return keyword;
+        }
+
+        public void setKeyword(String keyword) {
+            this.keyword = keyword;
+        }
+    }
 }

o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/mpweixin/BaseAction.java

@@ -13,7 +13,8 @@ import java.util.List;
 
 abstract class BaseAction extends StandardJaxrsAction {
 
-    public static final String WX_MSG_RECEIVE_TYPE_EVENT = "event"; //消息类型 事件
+    public static final String WX_MSG_RECEIVE_TYPE_EVENT = "event"; //公众号接收到的消息类型 事件 主要是菜单点击和订阅取消订阅
+    public static final String WX_MSG_RECEIVE_TYPE_TEXT = "text"; //公众号接收到的消息类型 文本
 
 
 
@@ -24,6 +25,12 @@ abstract class BaseAction extends StandardJaxrsAction {
     public static final String WX_MSG_RECEIVE_EVENT_VIEW = "VIEW"; //点击菜单跳转链接时的事件推送
 
 
+    public static final String WX_MSG_BACK_MEDIA_KEY_IMAGE = "media:image:";
+    public static final String WX_MSG_BACK_MEDIA_KEY_VIDEO = "media:video:";
+    public static final String WX_MSG_BACK_MEDIA_KEY_VOICE = "media:voice:";
+    public static final String WX_MSG_BACK_MEDIA_KEY_SCRIPT = "o2oa:script:";
+
+
 
 
 

o2server/x_program_center/src/main/java/com/x/program/center/jaxrs/mpweixin/MPWeixinAction.java

@@ -77,7 +77,7 @@ public class MPWeixinAction extends StandardJaxrsAction {
 	@Path("media/add/forever")
 	@Consumes(MediaType.MULTIPART_FORM_DATA)
 	@Produces(HttpMediaType.APPLICATION_JSON_UTF_8)
-	public void androidPackStart(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request,
+	public void addMedia(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request,
 								 @JaxrsParameterDescribe("类型： image、voice、video 、thumb") @FormDataParam("type") String type,
 								 @JaxrsParameterDescribe("视频标题 video的类型必须传") @FormDataParam("videoTitle") String videoTitle,
 								 @JaxrsParameterDescribe("视频介绍 video的类型必须传") @FormDataParam("videoIntroduction") String videoIntroduction,