package repositories import ( "fmt" "time" "xorm.io/xorm" "xps/datamodel" "xps/viewmodel" ) type WfActivityActionInsRepo struct { engine *xorm.Engine } func NewWfActivityActionInsRepo(engine *xorm.Engine) *WfActivityActionInsRepo { return &WfActivityActionInsRepo{ engine: engine, } } func (d *WfActivityActionInsRepo) GetPage(m map[string]interface{}) (*viewmodel.PageResult, error){ limit := m["limit"].(int) page := m["page"].(int) sqlSelect := ` SELECT A.wf_def_id, A.wf_ins_id, A.activity_def_id, A.activity_ins_id, B.activity_ins_title, B.activity_ins_from, B.activity_ins_to, B.activity_code, A.action_ins_id, A.action_id, A.action_title, A.action_remark, A.action_code, A.form_code, A.action_result, A.target_activity_ins_id, A.action_time, A.group_id, A.group_name, A.position_id, A.position_name, A.account_id, A.account_name ` sqlFrom := ` FROM wf_activity_action_ins AS A LEFT JOIN wf_activity_ins AS B ON (A.oc_id = B.oc_id AND A.wf_ins_id = B.wf_ins_id )` sqlWhere := ` WHERE A.deleted_flag = 0 ` if ocId, ok := m["ocId"]; ok { sqlWhere += fmt.Sprintf(" AND A.oc_id = %d ", ocId) } if wfInsId, ok := m["wfInsId"]; ok { sqlWhere += fmt.Sprintf(" AND A.wf_ins_id = %d ", wfInsId) } if activityInsId, ok := m["activityInsId"]; ok { sqlWhere += fmt.Sprintf(" AND A.activity_ins_id = %d ", activityInsId) } if actionInsId, ok := m["actionInsId"]; ok { sqlWhere += fmt.Sprintf(" AND A.action_ins_id = %d ", actionInsId) } if keywords, ok := m["keywords"]; ok { sqlWhere += ` AND A.action_title like ` + "'%" + fmt.Sprintf("%s", keywords) + "%'" } sqlCount := `SELECT COUNT(*) ` total, err := d.engine.SQL(sqlCount + sqlFrom + sqlWhere).Count(new(viewmodel.WfActivityActionInsInfo)) if err != nil { return nil, err } sqlOrderBy := " ORDER BY A.wf_def_id, A.activity_def_id, A.action_id ASC " pageStart := (limit - 1) * limit sqlLimit := fmt.Sprintf(" LIMIT %d OFFSET %d ", limit, pageStart) datalist := make([]viewmodel.WfActivityActionInsInfo, 0) err = d.engine.SQL(sqlSelect + sqlFrom + sqlWhere + sqlOrderBy + sqlLimit).Find(&datalist) if err != nil { return nil, err } pageResult := &viewmodel.PageResult{} pageResult.Data = datalist pageResult.Total = total pageResult.PageSize = limit pageResult.Page = page return pageResult, nil } func (d *WfActivityActionInsRepo) GetList(m map[string]interface{}) ([]viewmodel.WfActivityActionInsInfo, error) { sqlSelect := ` SELECT A.wf_def_id, A.wf_ins_id, A.activity_def_id, A.activity_ins_id, B.activity_ins_title, B.activity_ins_from, B.activity_ins_to, B.activity_code, A.action_ins_id, A.action_id, A.action_title, A.action_remark, A.action_code, A.form_code, A.action_result, A.target_activity_ins_id, A.action_time, A.group_id, A.group_name, A.position_id, A.position_name, A.account_id, A.account_name ` sqlFrom := ` FROM wf_activity_action_ins AS A LEFT JOIN wf_activity_ins AS B ON (A.oc_id = B.oc_id AND A.wf_ins_id = B.wf_ins_id ) ` sqlWhere := ` WHERE A.deleted_flag = 0 ` if ocId, ok := m["ocId"]; ok { sqlWhere += fmt.Sprintf(" AND A.oc_id = %d ", ocId) } if wfInsId, ok := m["wfInsId"]; ok { sqlWhere += fmt.Sprintf(" AND A.wf_ins_id = %d ", wfInsId) } if activityInsId, ok := m["activityInsId"]; ok { sqlWhere += fmt.Sprintf(" AND A.activity_ins_id = %d ", activityInsId) } if actionInsId, ok := m["actionInsId"]; ok { sqlWhere += fmt.Sprintf(" AND A.action_ins_id = %d ", actionInsId) } if keywords, ok := m["keywords"]; ok { sqlWhere += ` AND A.action_title like ` + "'%" + fmt.Sprintf("%s", keywords) + "%'" } sqlOrderBy := " ORDER BY A.wf_def_id, A.activity_def_id, A.action_id ASC " datalist := make([]viewmodel.WfActivityActionInsInfo, 0) err := d.engine.SQL(sqlSelect + sqlFrom + sqlWhere + sqlOrderBy).Find(&datalist) if err != nil { return nil, err } else { return datalist, nil } } func (d *WfActivityActionInsRepo) GetById(ocId, wfInsId, activityInsId, actionInsId int64) (*viewmodel.WfActivityActionInsInfo, error) { sqlSelect := ` SELECT A.wf_def_id, A.wf_ins_id, A.activity_def_id, A.activity_ins_id, B.activity_ins_title, B.activity_ins_from, B.activity_ins_to, B.activity_code, A.action_ins_id, A.action_id, A.action_title, A.action_remark, A.action_code, A.form_code, A.action_result, A.target_activity_ins_id, A.action_time, A.group_id, A.group_name, A.position_id, A.position_name, A.account_id, A.account_name ` sqlFrom := ` FROM wf_activity_action_ins AS A LEFT JOIN wf_activity_ins AS B ON (A.oc_id = B.oc_id AND A.wf_ins_id = B.wf_ins_id )` sqlWhere := ` WHERE A.deleted_flag = 0 ` sqlWhere += fmt.Sprintf(" AND A.oc_id = %d ", ocId) sqlWhere += fmt.Sprintf(" AND A.wf_ins_id = %d ", wfInsId) sqlWhere += fmt.Sprintf(" AND A.activity_ins_id = %d ", activityInsId) sqlWhere += fmt.Sprintf(" AND A.action_ins_id = %d ", actionInsId) data := &viewmodel.WfActivityActionInsInfo{} has, err := d.engine.SQL(sqlSelect + sqlFrom + sqlWhere).Get(data) if !has || err != nil { return nil, err } else { return data, nil } } func (d *WfActivityActionInsRepo) Create(data *datamodel.WfActivityActionIns) error { _, err := d.engine.Insert(data) return err } func (d *WfActivityActionInsRepo) Update(data *datamodel.WfActivityActionIns) error { ocId := data.OcId wfInsId := data.WfInsId activityInsId := data.ActivityInsId actionInsId := data.ActionInsId data.UpdatedAt = time.Now() _, err := d.engine. Where("oc_id = ?", ocId). Where("wf_ins_id = ?", wfInsId). Where("activity_ins_id = ?", activityInsId). Where("action_ins_id = ?", actionInsId). Update(data) return err } func (d *WfActivityActionInsRepo) Delete(m map[string]interface{}) error { ocId := m["ocId"].(int64) wfInsId := m["wfInsId"].(int64) activityInsId := m["activityInsId"].(int64) actionInsId := m["actionInsId"].(int64) deletedBy := m["deletedBy"].(int64) data := &datamodel.WfActivityActionIns{} data.DeletedFlag = 1 data.DeletedBy = deletedBy data.DeletedAt = time.Now() _, err := d.engine. Where("oc_id = ?", ocId). Where("wf_ins_id = ?", wfInsId). Where("activity_ins_id = ?", activityInsId). Where("action_ins_id = ?", actionInsId). Update(data) return err }