Merge branch 'master' of http://git.ycjcjy.com/default/wechat-conf

controllers/autoreply/autoreply.go

@@ -39,11 +39,12 @@ func (c *AutoreplyController) GetAutoReplyById() {
 	c.ResponseJSON(autoreply)
 }
 func (c *AutoreplyController) SaveAutoreply() {
+	user := c.Context.Get("user").(*model.SysUser)
 	autoreply := model.TaAutoReply{}
 	if err := c.ParseForm(&autoreply); err != nil {
 		c.ResponseError(err)
 	}
-	newAuto, err := c.dao.SaveAutoReply(autoreply)
+	newAuto, err := c.dao.SaveAutoReply(autoreply, user.OrgId)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -57,3 +58,15 @@ func (c *AutoreplyController) DeleteAutoReply() {
 	}
 	c.ResponseJSON("删除成功")
 }
+
+func (c *AutoreplyController) ChangeIsUse() {
+	user := c.Context.Get("user").(*model.SysUser)
+	autoType := c.GetString(":autoType")
+	isUse := c.GetString(":isUse")
+	err := c.dao.DisableAutoreply(autoType, user.OrgId, isUse)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("修改成功")
+
+}

models/autoreply/autoreply.go

@@ -53,6 +53,7 @@ func (m *AutoreplyDAO) AddAutoReply(auto model.TaAutoReply) (*model.TaAutoReply,
 	auto.CreateDate = time.Now()
 	auto.Status = models.STATUS_NORMAL
 	auto.AutoReplyId = utils.GetGUID()
+	auto.IsUse = models.AUTOREPLY_IS_USE_ON
 	_, err := m.db.Insert(auto)
 	return &auto, err
 }
@@ -170,3 +171,16 @@ func (m *AutoreplyDAO) GetSubscribeByAppID(appid string) (*model.TaAutoReply, er
 	}
 	return nil, nil
 }
+
+func (m *AutoreplyDAO) DisableAutoreply(autoType, orgId, isUse string) error {
+	var auto = model.TaAutoReply{
+		AutoType: autoType,
+		OrgId:    orgId,
+		IsUse:    isUse,
+	}
+	var cols = []string{
+		"is_use",
+	}
+	_, err := m.db.Cols(cols...).Where("auto_type = ?", auto.AutoType).And("org_id = ?", auto.OrgId).Update(auto)
+	return err
+}

models/constant.go

@@ -54,3 +54,9 @@ const (
 	// 图文
 	MESSAGE_TYPE_CONTENT = "content"
 )
+
+// 是否启用自动回复
+const (
+	AUTOREPLY_IS_USE_ON  = "on"
+	AUTOREPLY_IS_USE_OFF = "off"
+)

models/model/ta_auto_reply.go

@@ -16,5 +16,6 @@ type TaAutoReply struct {
 	CreateDate       time.Time `xorm:"DATETIME"`
 	Status           int       `xorm:"SMALLINT(6)"`
 	OrgId            string    `xorm:"VARCHAR(64)"`
-	KeyWords         string    `xorm:"TEXT"`
+	Keywords         string    `xorm:"TEXT"`
+	IsUse            string    `xorm:"VARCHAR(32)"`
 }

routers/router.go

@@ -27,6 +27,9 @@ func RouteInit() {
 		// 登陆
 		beego.NSRouter("/user/login", &controllers.UserController{}, "post:Login"),
 		beego.NSNamespace("/admin",
+			beego.NSRouter("/user/pwd", &controllers.UserController{}, "put:UpdatePassword"),
+			beego.NSRouter("/user/sign", &controllers.UserController{}, "post:SignOut"),
+
 			// 菜单
 			beego.NSRouter("/menu", &menu.MenuController{}, "get:GetMenuList"),
 			// 自动回复
@@ -35,6 +38,7 @@ func RouteInit() {
 			beego.NSRouter("/autoreply", &autoreply.AutoreplyController{}, "post:SaveAutoreply"),
 			beego.NSRouter("/autoreply", &autoreply.AutoreplyController{}, "put:SaveAutoreply"),
 			beego.NSRouter("/autoreply/:autoreplyId", &autoreply.AutoreplyController{}, "delete:DeleteAutoReply"),
+			beego.NSRouter("/autoreply/isUse/:autoType/:isUse", &autoreply.AutoreplyController{}, "put:ChangeIsUse"),
 			// 图片资源
 			beego.NSRouter("/wechatimg", &wechatimg.WechatImgController{}, "get:GetWechatImgList"),
 			beego.NSRouter("/wechatimg/sync", &wechatimg.WechatImgController{}, "put:SyncWechatImg"),

service/autoreply/autoreply.go

@@ -3,6 +3,7 @@ package autoreply
 import (
 	"errors"
 	"strings"
+	"wechat-conf/models"
 	"wechat-conf/models/autoreply"
 	"wechat-conf/models/model"
 	"wechat-conf/service"
@@ -53,28 +54,32 @@ func (s *AutoreplyServ) GetAutoReplyById(autoReplyId string) (*model.TaAutoReply
 	return autoreply, nil
 }
 
-func (s *AutoreplyServ) SaveAutoReply(autoreply model.TaAutoReply) (*model.TaAutoReply, error) {
+func (s *AutoreplyServ) SaveAutoReply(autoreply model.TaAutoReply, orgId string) (*model.TaAutoReply, error) {
 	var newAutoreply *model.TaAutoReply
 	var err error
 	if autoreply.AutoReplyId == "" {
+		autoreply.OrgId = orgId
 		newAutoreply, err = s.dao.AddAutoReply(autoreply)
 	} else {
 		err = s.dao.DeleteKeywords(autoreply.AutoReplyId)
 		err = s.dao.UpdateAutoRelpy(autoreply)
 		newAutoreply = &autoreply
 	}
-	keywords := strings.Split(autoreply.KeyWords, ",")
-	for i := 0; i < len(keywords); i++ {
-		var keyword = model.TaAutoReplyKeywords{
-			AutoReplyId: newAutoreply.AutoReplyId,
-			Keywords:    keywords[i],
+	if autoreply.AutoType == models.AUTOREPLY_KEYWORDS {
+		keywords := strings.Split(autoreply.Keywords, ",")
+		for i := 0; i < len(keywords); i++ {
+			var keyword = model.TaAutoReplyKeywords{
+				AutoReplyId: newAutoreply.AutoReplyId,
+				Keywords:    keywords[i],
+			}
+			err = s.dao.AddKeyword(keyword)
+		}
+		if err != nil {
+			utils.LogError("保存自动回复失败: " + err.Error())
+			return nil, errors.New("保存自动回复失败")
 		}
-		err = s.dao.AddKeyword(keyword)
-	}
-	if err != nil {
-		utils.LogError("保存自动回复失败: " + err.Error())
-		return nil, errors.New("保存自动回复失败")
 	}
+
 	return newAutoreply, nil
 }
 
@@ -107,3 +112,12 @@ func (s *AutoreplyServ) GetSubscribeByAppID(appid string) (*model.TaAutoReply, e
 	}
 	return autoReplay, err
 }
+
+func (s *AutoreplyServ) DisableAutoreply(autoType, orgId, isUse string) error {
+	err := s.dao.DisableAutoreply(autoType, orgId, isUse)
+	if err != nil {
+		utils.LogError("修改状态失败: " + err.Error())
+		return errors.New("修改状态失败")
+	}
+	return nil
+}