package repositories

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

type MsgCcRepo struct {
    engine *xorm.Engine
}

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


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

func (d *MsgCcRepo) Update(data *datamodel.MsgCc) error {
    msgCcId := data.MsgCcId
    data.UpdatedAt = time.Now()
    _, err := d.engine.
        Where("msg_cc_id = ?", msgCcId).
        Update(data)
    return err
}

func (d *MsgCcRepo) Delete(m map[string]interface{}) error {
    ocId      := m["ocId"].(int64)
    msgCcId  := m["msgCcId"].(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_cc_id = ?", msgCcId).
        Update(data)
    return err
}