71 lines
1.6 KiB
Go
71 lines
1.6 KiB
Go
package service
|
|
|
|
/*func InsertNoticesByRepo(repo *model.TRepo, n *notice.Notice) (rterr error) {
|
|
return InsertNoticesByRepoId(repo.Id, n)
|
|
}
|
|
func InsertNoticesByRepoOpenid(openid string, n *notice.Notice) (rterr error) {
|
|
db := comm.DBMain.GetDB()
|
|
repo := &model.TRepo{}
|
|
get, err := db.Where("openid =? ", openid).Where("deleted != 1").Get(repo)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if !get {
|
|
return nil
|
|
}
|
|
return InsertNoticesByRepoId(repo.Id, n)
|
|
}
|
|
func InsertNoticesByRepoId(id string, n *notice.Notice) (rterr error) {
|
|
db := comm.DBMain.GetDB()
|
|
turs := make([]*model.TUserRepo, 0)
|
|
err := db.Where("repo_id = ? ", id).Find(&turs)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
message, err := InsertTMessage(n)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
for _, tur := range turs {
|
|
_, err = InsertTUserMsg(message, strconv.FormatInt(tur.UserId, 10))
|
|
if err != nil {
|
|
core.Log.Errorf("InsertTUserMsg db err: %v", err)
|
|
continue
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
func InsertTUserMsg(m *model.TMessage, sender string) (*model.TUserMsg, error) {
|
|
db := comm.DBMain.GetDB()
|
|
tum := &model.TUserMsg{
|
|
Mid: m.Xid,
|
|
Uid: sender,
|
|
Created: time.Now(),
|
|
Status: 0,
|
|
Deleted: 0,
|
|
}
|
|
_, err := db.Insert(tum)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return tum, nil
|
|
}
|
|
func InsertTMessage(n *notice.Notice) (*model.TMessage, error) {
|
|
db := comm.DBMain.GetDB()
|
|
msg := &model.TMessage{
|
|
Xid: utils.NewXid(),
|
|
Uid: strconv.FormatInt(n.Receiver, 10),
|
|
Title: n.Title,
|
|
Content: n.Content,
|
|
Types: n.Types,
|
|
Created: time.Now(),
|
|
Infos: n.Infos,
|
|
Url: n.Url,
|
|
}
|
|
_, err := db.Insert(msg)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return msg, nil
|
|
}*/
|