package repository

import (
    "time"
    "xorm.io/xorm"
    "xps/pkg/system/datamodel"
)

type MsgToRepo struct {
    engine *xorm.Engine
}

func NewMsgToRepo(engine *xorm.Engine) *MsgCatRepo {
    return &MsgCatRepo{
        engine: engine,
    }
}

func (d *MsgToRepo) Create(data *datamodel.MsgTo) error {
    data.CreatedAt = time.Now()
    _, err := d.engine.Insert(data)
    return err
}

func (d *MsgToRepo) Update(data *datamodel.MsgTo) error {
    msgToId := data.MsgToId
    data.UpdatedAt = time.Now()
    _, err := d.engine.
        Where("msg_to_id = ?", msgToId).
        Update(data)
    return err
}

func (d *MsgToRepo) Delete(m map[string]interface{}) error {
    ocId := m["ocId"].(int64)
    msgToId := m["msgToId"].(int64)
    deletedBy := m["deletedBy"].(int64)

    data := &datamodel.MsgCat{}
    data.DeletedFlag = 1
    data.DeletedBy = deletedBy
    data.DeletedAt = time.Now()
    _, err := d.engine.
        Where("oc_id = ?", ocId).
        Where("msg_to_id = ?", msgToId).
        Update(data)
    return err
}