1112PM by wangfei

conf/app.conf

@@ -14,4 +14,3 @@ allowOrigin = http://localhost:9528
 # GET, POST etc
 allowMethods = *
 
-

conf/wechat.conf

@@ -1,2 +1,3 @@
-appid = test
+[wechat]
+appid = appid
 aeskey = aeskey

controllers/component.go

@@ -3,11 +3,30 @@ package controllers
 import (
 	"encoding/base64"
 	"io/ioutil"
+	"net/http"
+	"wechat-conf/models"
+	"wechat-conf/models/model"
+	"wechat-conf/service/autoreply"
 	"wechat-conf/utils"
 
+	"github.com/kinisky564477/wechat/component"
+
 	"github.com/zjxpcyc/wechat/core"
 )
 
+// WechatController 用户
+type WechatController struct {
+	BaseController
+	serv *autoreply.AutoreplyServ
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *WechatController) Constructor() {
+	c.serv = autoreply.NewAutoreplyServ(c.Context)
+}
+
 const (
 	INFOTYPE_TICKET           = "component_verify_ticket"
 	INFOTYPE_AUTHORIZED       = "authorized"
@@ -16,7 +35,7 @@ const (
 )
 
 // ComponentPush 第三方平台推送
-func (c *BaseController) ComponentPush() {
+func (c *WechatController) ComponentPush() {
 	r := c.Ctx.Request
 	defer r.Body.Close()
 	con, _ := ioutil.ReadAll(r.Body)
@@ -70,5 +89,75 @@ func (c *BaseController) ComponentPush() {
 		// 取消授权
 		break
 	}
+}
+
+// WechatInfo 微信接入
+func (c *WechatController) WechatInfo() {
+	method := c.Ctx.Input.Method()
+	if method == http.MethodGet {
+		echostr := c.GetString("echostr")
+		c.ResponseRaw([]byte(echostr))
+	} else {
+		c.WxReceive()
+	}
+}
+
+// WxReceive 微信消息接收
+func (c *WechatController) WxReceive() {
+	appid := c.GetString(":appid")
+	wechat, err := utils.Component.GetWxClient(appid)
+	if err != nil {
+		utils.LogError("获取微信失败: " + err.Error())
+	}
+	val, err := wechat.TransformMessage(string(c.Ctx.Input.RequestBody))
+	if err != nil {
+		utils.LogError("读取微信服务发送内容失败: " + err.Error())
+		c.ResponseRaw([]byte(""))
+	}
 
+	var replay = new(model.TaAutoReply)
+	switch val["MsgType"] {
+	case "text":
+		content := val["Content"]
+		// 获取数据库存储返回类型
+		replay, err = c.serv.GetAutoReplayByAppID(appid, content)
+		break
+	case "event":
+		if val["Event"] == "subscribe" {
+			replay, err = c.serv.GetSubscribeByAppID(appid)
+		}
+		break
+	}
+	if err != nil {
+		utils.LogError("获取微信自动回复信息失败: " + err.Error())
+		c.ResponseRaw([]byte(""))
+	}
+
+	if replay == nil {
+		c.ResponseRaw([]byte(""))
+	}
+	openID := val["FromUserName"]
+	message, err := c.getReplayMessage(replay, openID, wechat)
+	if err != nil {
+		utils.LogError("转换回复信息失败: " + err.Error())
+		c.ResponseRaw([]byte(""))
+	}
+	c.ResponseRaw(message, false)
+	c.DestroyContext()
+	c.StopRun()
+}
+
+func (c *WechatController) getReplayMessage(replay *model.TaAutoReply, openid string, wx *component.WxClient) ([]byte, error) {
+	switch replay.MessageType {
+	case models.MESSAGE_TYPE_CONTENT:
+		msg, err := wx.ResponseMessageText(openid, replay.MessageParagraph)
+		return msg, err
+	case models.MESSAGE_TYPE_IMG:
+		msg, err := wx.ResponseMessageImage(openid, replay.MessageImg)
+		return msg, err
+		// case models.MESSAGE_TYPE_PARAGRAPH:
+		// 	msg, err := wx.ResponseMessageNews(openid, replay.MessageImg)
+		// 	return msg, err
+	}
+	return nil, nil
 }

models/autoreply/autoreply.go

@@ -32,7 +32,7 @@ FROM
 WHERE
 	org_id = '` + orgId + `'
 	AND auto_type = '` + autoType + `'
-	and status >`+ strconv.Itoa(models.STATUS_DEL)
+	and status >` + strconv.Itoa(models.STATUS_DEL)
 	sql += ` order by create_date desc limit ` + strconv.Itoa((page-1)*pagesize) + `, ` + strconv.Itoa(pagesize)
 	err := m.db.Sql(sql).Find(&autoreply)
 	return autoreply, err
@@ -105,3 +105,68 @@ WHERE
 	}
 	return nil, err
 }
+
+// GetAutoReplayByAppID 获取微信对应的自动回复信息
+func (m *AutoreplyDAO) GetAutoReplayByAppID(appid, val string) (*model.TaAutoReply, error) {
+	var reply []model.TaAutoReply
+	// 先查询精确查询
+	sql := `SELECT
+						a.*
+					FROM
+						ta_auto_reply a
+					INNER JOIN sys_org b ON a.org_id = b.org_id
+					INNER JOIN sys_wechat_conf c ON b.wechat_id = c.conf_id
+					INNER JOIN ta_auto_reply_keywords d ON a.auto_reply_id = d.auto_reply_id
+					WHERE
+						c.appid = ?
+					AND a.status > ?
+					AND b.status > ?
+					AND a.auto_type = ?
+					AND a.pair_type = ?
+					AND d.keywords = ? order by a.create_date desc`
+	err := m.db.Sql(sql, appid, models.STATUS_DEL, models.STATUS_DEL, models.AUTOREPLY_KEYWORDS, models.PAIR_TYPE_ACU, val).Find(&reply)
+	if err != nil {
+		return nil, err
+	}
+	if len(reply) > 0 {
+		return &reply[0], nil
+	}
+	// 模糊查询
+	sql = `SELECT
+						a.*
+					FROM
+						ta_auto_reply a
+					INNER JOIN sys_org b ON a.org_id = b.org_id
+					INNER JOIN sys_wechat_conf c ON b.wechat_id = c.conf_id
+					INNER JOIN ta_auto_reply_keywords d ON a.auto_reply_id = d.auto_reply_id
+					WHERE
+						c.appid = ?
+					AND a.status > ?
+					AND b.status > ?
+					AND a.auto_type = ?
+					AND a.pair_type = ?
+					AND ? like CONCAT('%', d.keywords, '%') order by a.create_date desc`
+	err = m.db.Sql(sql, appid, models.STATUS_DEL, models.STATUS_DEL, models.AUTOREPLY_KEYWORDS, models.PAIR_TYPE_BLUR, val).Find(&reply)
+	if err != nil {
+		return nil, err
+	}
+	if len(reply) > 0 {
+		return &reply[0], nil
+	}
+	return nil, nil
+}
+
+// GetSubscribeByAppID 获取微信关注自动回复
+func (m *AutoreplyDAO) GetSubscribeByAppID(appid string) (*model.TaAutoReply, error) {
+	var replys []model.TaAutoReply
+	sql := `select a.* from ta_auto_reply a inner join sys_org b on a.org_id=b.org_id
+	inner join sys_wechat_conf c on b.wechat_id = c.conf_id where c.appid=? and a.auto_type=? and a.status>? and b.status>? order by a.create_date desc`
+	err := m.db.Sql(sql, appid, models.AUTOREPLY_SUBSCRIBE, models.STATUS_DEL, models.STATUS_DEL).Find(&replys)
+	if err != nil {
+		return nil, err
+	}
+	if len(replys) > 0 {
+		return &replys[0], nil
+	}
+	return nil, nil
+}

service/autoreply/autoreply.go

@@ -87,3 +87,23 @@ func (s *AutoreplyServ) DeleteAutoReply(autoreplyId string) error {
 	}
 	return nil
 }
+
+// GetAutoReplayByAppID 获取自动回复消息
+func (s *AutoreplyServ) GetAutoReplayByAppID(appid, val string) (*model.TaAutoReply, error) {
+	autoReplay, err := s.dao.GetAutoReplayByAppID(appid, val)
+	if err != nil {
+		utils.LogError("获取自动回复消息失败: " + err.Error())
+		return nil, errors.New("获取自动回复消息失败")
+	}
+	return autoReplay, err
+}
+
+// GetSubscribeByAppID 获取关注回复消息
+func (s *AutoreplyServ) GetSubscribeByAppID(appid string) (*model.TaAutoReply, error) {
+	autoReplay, err := s.dao.GetSubscribeByAppID(appid)
+	if err != nil {
+		utils.LogError("获取关注回复消息失败: " + err.Error())
+		return nil, errors.New("获取关注回复消息失败")
+	}
+	return autoReplay, err
+}

utils/wechat.go

@@ -2,6 +2,7 @@ package utils
 
 import (
 	"github.com/astaxie/beego/config"
+	"github.com/astaxie/beego/logs"
 	"github.com/kinisky564477/wechat/component"
 )
 
@@ -11,10 +12,16 @@ var Component *component.ComponentClient
 // ComponentInit 第三方初始化
 func ComponentInit() {
 	// 初始化第三方
-	var cert map[string]string
-	wechat, _ := config.NewConfig("ini", appRoot+"/conf/db.conf")
-	cert["component_appid"] = wechat.String("appid")
-	cert["aeskey"] = wechat.String("aeskey")
+
+	// 读取配置文件
+	conf, err := config.NewConfig("ini", GetAppRoot()+"/conf/wechat.conf")
+	if err != nil {
+		logs.Error("读取微信配置文件失败")
+	}
+	var cert = map[string]string{
+		"component_appid": conf.String("wechat::appid"),
+		"aeskey":          conf.String("wechat::aeskey"),
+	}
 	Component = component.NewComponentClient(cert)
 }