diff --git a/business/jxstore/cms/cms.go b/business/jxstore/cms/cms.go index 1e89a26cc..d76aeb0b4 100644 --- a/business/jxstore/cms/cms.go +++ b/business/jxstore/cms/cms.go @@ -4,6 +4,8 @@ import ( "strconv" "time" + "git.rosy.net.cn/jx-callback/business/jxutils/msg" + "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxutils" "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" @@ -17,6 +19,8 @@ import ( const ( qiniuTokenExpires = 300 // 七牛TOKEN有效时间,5分钟 + + SendMsgTypeOpenStoreRequest = "openStoreRequest" ) var ( @@ -26,6 +30,13 @@ var ( "enabled": true, "mtpsPrice": true, } + + receiveMsgUsersMap = map[string][]string{ + SendMsgTypeOpenStoreRequest: []string{ + "石峰", + "徐建华", + }, + } ) func InitServiceInfo(version string, buildTime time.Time, gitCommit string) { @@ -161,3 +172,16 @@ func UpdatePlace(ctx *jxcontext.Context, placeCode int, payload map[string]inter func GetCoordinateDistrictCode(ctx *jxcontext.Context, lng, lat float64) (code int, err error) { return api.AutonaviAPI.GetCoordinateDistrictCode(lng, lat), nil } + +func SendMsg2Somebody(ctx *jxcontext.Context, msgType, msgContent string) (err error) { + db := dao.GetDB() + for _, v := range receiveMsgUsersMap[msgType] { + user, err2 := dao.GetUserByID(db, "name", v) + if err2 == nil { + msg.SendUserMessage(user.GetID(), msgType, msgContent) + } else if err == nil { + err = err2 + } + } + return err +} diff --git a/controllers/cms.go b/controllers/cms.go index 02548e393..df0bb6f3e 100644 --- a/controllers/cms.go +++ b/controllers/cms.go @@ -200,3 +200,18 @@ func (c *CmsController) FakeNewOrder() { return retVal, "", err }) } + +// @Title 发送消息给相关人员 +// @Description 发送消息给相关人员 +// @Param token header string true "认证token" +// @Param msgType formData string true "消息类型" +// @Param msgContent formData string true "消息内容" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /SendMsg2Somebody [post] +func (c *CmsController) SendMsg2Somebody() { + c.callSendMsg2Somebody(func(params *tCmsSendMsg2SomebodyParams) (retVal interface{}, errCode string, err error) { + err = cms.SendMsg2Somebody(params.Ctx, params.MsgType, params.MsgContent) + return retVal, "", err + }) +} diff --git a/routers/commentsRouter_controllers.go b/routers/commentsRouter_controllers.go index 41fd2570d..0726ae8b4 100644 --- a/routers/commentsRouter_controllers.go +++ b/routers/commentsRouter_controllers.go @@ -340,6 +340,15 @@ func init() { Filters: nil, Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:CmsController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:CmsController"], + beego.ControllerComments{ + Method: "SendMsg2Somebody", + Router: `/SendMsg2Somebody`, + AllowHTTPMethods: []string{"post"}, + MethodParams: param.Make(), + Filters: nil, + Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:CmsController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:CmsController"], beego.ControllerComments{ Method: "SetConfig",