用户发送消息

business/jxutils/weixinmsg/weixinmsg.go

@@ -816,3 +816,104 @@ func NotifyAdjustOrder(order *model.GoodsOrder) (err error) {
 	storeID := jxutils.GetSaleStoreIDFromOrder(order)
 	return SendMsgToStore(storeID, WX_ADJUSTORDER_TEMPLATE_ID, globals.WxBackstageHost+fmt.Sprintf("%s%d", WX_TO_ORDER_PAGE_URL, storeID), WX_MINI_TO_ORDER_PAGE_URL, data)
 }
+
+func SendUserMessage(ctx *jxcontext.Context, title, content string, userIDs []string, isAsync, isContinueWhenError bool) (hint string, err error) {
+	db := dao.GetDB()
+	dao.Begin(db)
+	defer func() {
+		if r := recover(); r != nil {
+			dao.Rollback(db)
+			panic(r)
+		}
+	}()
+	msg := &model.Message{
+		Title:   title,
+		Content: content,
+		Type:    model.MessageTypeUser,
+	}
+	dao.WrapAddIDCULDEntity(msg, ctx.GetUserName())
+	if err = dao.CreateEntity(db, msg); err != nil {
+		dao.Rollback(db)
+		return "", err
+	}
+	msgStatusList := make([]*model.MessageStatus, len(userIDs))
+	for k, userID := range userIDs {
+		msgStatus := &model.MessageStatus{
+			MessageID: msg.ID,
+			UserID:    userID,
+			Status:    model.MessageStatusNew,
+		}
+		dao.WrapAddIDCULDEntity(msgStatus, ctx.GetUserName())
+		if err = dao.CreateEntity(db, msgStatus); err != nil {
+			dao.Rollback(db)
+			return "", err
+		}
+		msgStatusList[k] = msgStatus
+	}
+	dao.Commit(db)
+
+	rootTask := tasksch.NewParallelTask("SendUserMessage", nil, ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+		db := dao.GetDB()
+		msgStatus := batchItemList[0].(*model.MessageStatus)
+		if err = NotifyUserMessage(msgStatus.UserID, msg.Title, msg.Content); err == nil {
+			msgStatus.Status = model.MessageStatusSendAllSuccess
+		} else {
+			msgStatus.Status = model.MessageStatusSendAllFailed
+		}
+		dao.WrapUpdateULEntity(msgStatus, ctx.GetUserName())
+		_, err = dao.UpdateEntity(db, msgStatus)
+		return nil, err
+	}, msgStatusList)
+	tasksch.HandleTask(rootTask, nil, len(msgStatusList) > 5).Run()
+	if !isAsync {
+		_, err = rootTask.GetResult(0)
+	} else {
+		hint = rootTask.ID
+	}
+	return "", err
+}
+
+func NotifyUserMessage(userID string, title, content string) (err error) {
+	globals.SugarLogger.Debugf("NotifyUserMessage userID:%d, title:%s, content:%s", userID, title, content)
+	templateID := WX_NORMAL_STORE_MSG_TEMPLATE_ID
+	data := map[string]interface{}{
+		"first": map[string]interface{}{
+			"value": content,
+			"color": "#333333",
+		},
+		"keyword1": map[string]interface{}{
+			"value": title,
+			"color": "#2E408E",
+		},
+		"keyword2": map[string]interface{}{
+			"value": utils.GetCurTimeStr(),
+			"color": "#2E408E",
+		},
+		"remark": map[string]interface{}{
+			"value": "",
+		},
+	}
+	return SendMsgToUser(userID, templateID, data)
+}
+
+func SendMsgToUser(userID string, templateID string, data interface{}) (err error) {
+	globals.SugarLogger.Debugf("SendMsgToUser userID:%d, templateID:%s", userID, templateID)
+	authBinds, err := dao.GetUserBindAuthInfo(dao.GetDB(), userID, model.AuthBindTypeAuth, []string{"weixinmini"}, "", "", "wx4b5930c13f8b1170")
+	if err != nil {
+		return err
+	}
+	successCount := 0
+	globals.SugarLogger.Debugf("SendMsgToUser userID:%d, openID:%s, templateID:%s", userID, authBinds[0].AuthID, templateID)
+	if err2 := SmartMessageTemplateSend(authBinds[0].AuthID, templateID, "", "", data); err2 == nil {
+		successCount++
+	} else {
+		err = err2
+	}
+	if successCount > 0 {
+		err = nil // 只要成功一个都当成成功
+	}
+	if err != nil {
+		globals.SugarLogger.Debugf("SendMsgToUser all failed userID:%d, templateID:%s, error:%v", userID, templateID, err)
+	}
+	return err
+}

business/model/message.go

@@ -2,6 +2,7 @@ package model
 
 const (
 	MessageTypeStore = 1
+	MessageTypeUser  = 2
 )
 
 const (
@@ -36,10 +37,11 @@ func (*Message) TableIndex() [][]string {
 
 type MessageStatus struct {
 	ModelIDCULD
-	MessageID int  `orm:"column(message_id)" json:"messageID"`
-	StoreID   int  `orm:"column(store_id)" json:"storeID"`
-	Status    int8 `json:"status"`
-	ReadCount int  `json:"readCount"`
+	MessageID int    `orm:"column(message_id)" json:"messageID"`
+	StoreID   int    `orm:"column(store_id)" json:"storeID"`
+	Status    int8   `json:"status"`
+	ReadCount int    `json:"readCount"`
+	UserID    string `orm:"column(user_id)" json:"userID"`
 }
 
 func (*MessageStatus) TableIndex() [][]string {

controllers/cms_msg.go

@@ -37,6 +37,28 @@ func (c *MsgController) SendStoreMessage() {
 	})
 }
 
+// @Title 发送用户微信消息
+// @Description 发送用户微信消息
+// @Param	token				header		string	true	"认证token"
+// @Param	userIDs				formData	string	true	"用户 ID列表"
+// @Param	title				formData	string	true	"消息标题"
+// @Param	content				formData	string	true	"消息内容"
+// @Param	isAsync				formData	bool	false	"是否异步操作，缺省否"
+// @Param	isContinueWhenError	formData	bool	false	"单个失败是否继续，缺省false"
+// @Success 200 {object} controllers.CallResult
+// @Failure 200 {object} controllers.CallResult
+// @router /SendUserMessage [post]
+func (c *MsgController) SendUserMessage() {
+	c.callSendUserMessage(func(params *tMsgSendUserMessageParams) (retVal interface{}, errCode string, err error) {
+		var userIDs []string
+		if err = jxutils.Strings2Objs(params.UserIDs, &userIDs); err != nil {
+			return retVal, "", err
+		}
+		retVal, err = weixinmsg.SendUserMessage(params.Ctx, params.Title, params.Content, userIDs, params.IsAsync, params.IsContinueWhenError)
+		return retVal, "", err
+	})
+}
+
 // @Title 门店读微信消息
 // @Description 门店读微信消息（此API是自动调用的）
 // @Param	token			header		string	true	"认证token"

routers/commentsRouter_controllers.go

@@ -864,6 +864,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:MsgController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:MsgController"],
+        beego.ControllerComments{
+            Method: "SendUserMessage",
+            Router: `/SendUserMessage`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:NetSpiderController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:NetSpiderController"],
         beego.ControllerComments{
             Method: "GetAndStoreCitiesShops",