正在显示
4 个修改的文件
包含
78 行增加
和
0 行删除
pkg/infrastructure/dao/task_anomaly.go
0 → 100644
| 1 | +package dao | ||
| 2 | + | ||
| 3 | +import ( | ||
| 4 | + pgTransaction "github.com/linmadan/egglib-go/transaction/pg" | ||
| 5 | + "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain" | ||
| 6 | +) | ||
| 7 | + | ||
| 8 | +// 异常的任务记录 | ||
| 9 | +type TaskAnomalyDao struct { | ||
| 10 | + transactionContext *pgTransaction.TransactionContext | ||
| 11 | +} | ||
| 12 | + | ||
| 13 | +func NewTaskAnomalyDao(options map[string]interface{}) *TaskAnomalyDao { | ||
| 14 | + var transactionContext *pgTransaction.TransactionContext | ||
| 15 | + if value, ok := options["transactionContext"]; ok { | ||
| 16 | + transactionContext = value.(*pgTransaction.TransactionContext) | ||
| 17 | + } | ||
| 18 | + return &TaskAnomalyDao{ | ||
| 19 | + transactionContext: transactionContext, | ||
| 20 | + } | ||
| 21 | +} | ||
| 22 | + | ||
| 23 | +// 异常的任务记录, 获取我负责的任务 | ||
| 24 | +// userId 谁要查看数据 | ||
| 25 | +// companyId 公司id | ||
| 26 | +// dayTime 搜索条件日期 ,例:"2006-01-02" | ||
| 27 | +// pageSize 分页大小 | ||
| 28 | +// pageNumber 分页页码 | ||
| 29 | +func (d *TaskAnomalyDao) List1(userId int, companyId int, dayTime string, pageSize int, pageNumber int) (int, []*domain.Task, error) { | ||
| 30 | + | ||
| 31 | + // with t_task_ignore as ( | ||
| 32 | + // select task_ignore.id ,task_ignore.task_id | ||
| 33 | + // from task_ignore | ||
| 34 | + // where user_id = 0 | ||
| 35 | + // ) | ||
| 36 | + // select * | ||
| 37 | + // from task as task_anomaly | ||
| 38 | + // left join t_task_ignore on task_anomaly.id=t_task_ignore.task_id | ||
| 39 | + // where t_task_ignore.id isnull and task_anomaly.company_id =? | ||
| 40 | + // order by task_anomaly.id desc | ||
| 41 | + // limit 20 | ||
| 42 | + | ||
| 43 | + return 0, nil, nil | ||
| 44 | +} | ||
| 45 | + | ||
| 46 | +// 异常的任务记录,获取我的下级负责的任务 | ||
| 47 | +// userId 谁要查看数据 | ||
| 48 | +// companyId 公司id | ||
| 49 | +// dayTime 搜索条件日期 ,例:"2006-01-02" | ||
| 50 | +// pageSize 分页大小 | ||
| 51 | +// pageNumber 分页页码 | ||
| 52 | +func (d *TaskAnomalyDao) List2(userId int, companyId int, dayTime string, pageSize int, pageNumber int) error { | ||
| 53 | + | ||
| 54 | + return nil | ||
| 55 | +} | ||
| 56 | + | ||
| 57 | +// 异常的任务记录,我作为相关人的任务 | ||
| 58 | +// userId 谁要查看数据 | ||
| 59 | +// companyId 公司id | ||
| 60 | +// dayTime 搜索条件日期 ,例:"2006-01-02" | ||
| 61 | +// pageSize 分页大小 | ||
| 62 | +// pageNumber 分页页码 | ||
| 63 | +func (d *TaskAnomalyDao) List3(userId int, companyId int, dayTime string, pageSize int, pageNumber int) error { | ||
| 64 | + return nil | ||
| 65 | +} |
| @@ -57,6 +57,7 @@ func init() { | @@ -57,6 +57,7 @@ func init() { | ||
| 57 | &models.TaskIgnore{}, | 57 | &models.TaskIgnore{}, |
| 58 | &models.TaskRecord{}, | 58 | &models.TaskRecord{}, |
| 59 | &models.TaskLevel{}, | 59 | &models.TaskLevel{}, |
| 60 | + &models.TaskAnomaly{}, | ||
| 60 | } | 61 | } |
| 61 | for _, model := range tables { | 62 | for _, model := range tables { |
| 62 | err := DB.Model(model).CreateTable(&orm.CreateTableOptions{ | 63 | err := DB.Model(model).CreateTable(&orm.CreateTableOptions{ |
-
请 注册 或 登录 后发表评论