bug: fix wechat test case

controllers/component.go

@@ -231,7 +231,7 @@ func (c *WechatController) WxReceive() {
 	if err != nil && err.Error() == RESPONSE_CUSTOM_MESSAGE {
 		// 微信测试用例会跑到这边
 		// 模拟粉丝发送消息, 并立即调用客户接口, 反馈固定的字串
-		go wechat.SendCustomText(receiveData["FromUserName"], wechat.GetAuthCode()+"_from_api")
+		go wechat.SendCustomText(receiveData["FromUserName"], string(replyMessage))
 
 		c.ResponseRaw(nil)
 	}
@@ -340,7 +340,6 @@ func (c *WechatController) getReplayMessage(receviceData map[string]string, wech
 	from := receviceData["ToUserName"]
 	openID := receviceData["FromUserName"]
 	appID := wechat.GetAppID()
-	fromWXOffice := openID == WX_OFFICE_TEST_USERNAME
 
 	// 暂时支持 文本以及订阅事件消息
 	switch msgType {
@@ -348,28 +347,25 @@ func (c *WechatController) getReplayMessage(receviceData map[string]string, wech
 		content := receviceData["Content"]
 
 		// 微信文本消息测试
-		if fromWXOffice {
-			// 普通文本测试, 返回 TESTCOMPONENT_MSG_TYPE_TEXT_callback
-			if content == "TESTCOMPONENT_MSG_TYPE_TEXT" {
-				replay = &model.TaAutoReply{
-					MessageType:      models.MESSAGE_TYPE_PARAGRAPH,
-					MessageParagraph: "TESTCOMPONENT_MSG_TYPE_TEXT_callback",
-					IsUse:            models.AUTOREPLY_IS_USE_ON,
-				}
-
-				// 发送 query_auth_code , 返回空, 并立即调用客服接口
-			} else if strings.Index(content, "QUERY_AUTH_CODE") > -1 {
-				replay = nil
-				return nil, errors.New(RESPONSE_CUSTOM_MESSAGE)
+		// 普通文本测试, 返回 TESTCOMPONENT_MSG_TYPE_TEXT_callback
+		if content == "TESTCOMPONENT_MSG_TYPE_TEXT" {
+			replay = &model.TaAutoReply{
+				MessageType:      models.MESSAGE_TYPE_PARAGRAPH,
+				MessageParagraph: "TESTCOMPONENT_MSG_TYPE_TEXT_callback",
+				IsUse:            models.AUTOREPLY_IS_USE_ON,
 			}
-			break
-		}
 
-		if replay, err = c.serv.GetAutoReplayByAppID(appID, content); err != nil {
-			utils.LogError("获取微信自动回复信息失败: " + err.Error())
-			return
-		}
+			// 发送 query_auth_code , 返回空, 并立即调用客服接口
+		} else if strings.Index(content, "QUERY_AUTH_CODE") > -1 {
+			rplTxt := strings.TrimSpace(strings.Split(content, ":")[1])
 
+			return []byte(rplTxt + "_from_api"), errors.New(RESPONSE_CUSTOM_MESSAGE)
+		} else {
+			if replay, err = c.serv.GetAutoReplayByAppID(appID, content); err != nil {
+				utils.LogError("获取微信自动回复信息失败: " + err.Error())
+				return
+			}
+		}
 		break
 	case "event":
 		beego.Info("_______________这里是event————————————————")