You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
43 lines
925 B
43 lines
925 B
package dao |
|
|
|
import ( |
|
"context" |
|
"time" |
|
|
|
"go-common/app/admin/main/workflow/model/param" |
|
"go-common/app/job/main/workflow/model" |
|
"go-common/library/ecode" |
|
"go-common/library/queue/databus/report" |
|
) |
|
|
|
// SendMessage . |
|
func (d *Dao) SendMessage(c context.Context, chs []*model.ChallRes, msg *param.MessageParam) (err error) { |
|
params := msg.Query() |
|
var res struct { |
|
Code int `json:"code"` |
|
} |
|
if err = d.httpSearch.Post(c, d.messageURL, "", params, &res); err != nil { |
|
return |
|
} |
|
if res.Code != 0 { |
|
err = ecode.Int(res.Code) |
|
return |
|
} |
|
for _, ch := range chs { |
|
report.Manager(&report.ManagerInfo{ |
|
UID: 2233, |
|
Uname: "", |
|
Business: 11, |
|
Type: 2, |
|
Oid: ch.OID, |
|
Ctime: time.Now(), |
|
Action: "notify_users_received", |
|
Content: map[string]interface{}{ |
|
"mid": ch.MID, |
|
"message": "zhoushuguang", |
|
}, |
|
Index: []interface{}{ch.ID, ch.GID, ch.MID}, |
|
}) |
|
} |
|
return |
|
}
|
|
|