138 lines
4.2 KiB
Go
138 lines
4.2 KiB
Go
package sqLite
|
|
|
|
import (
|
|
sqLiteServer "planA/service/sqLite"
|
|
_type "planA/type"
|
|
sqliteType "planA/type/sqLite"
|
|
"time"
|
|
)
|
|
|
|
// CreateTaskRecords 创建任务记录
|
|
// @param export 任务记录
|
|
// @return error 错误信息
|
|
func (s *SqlAdapter) CreateTaskRecords(records _type.TaskRecordsDTO) error {
|
|
return sqLiteServer.CreateTaskRecords(sqliteType.TaskRecords{
|
|
UserID: records.UserId,
|
|
ShopID: records.ShopId,
|
|
TaskID: records.TaskId,
|
|
ShopName: records.ShopName,
|
|
IsExport: records.IsExport,
|
|
TaskType: records.TaskType,
|
|
CreateAt: time.Time{},
|
|
})
|
|
}
|
|
|
|
// GetTaskRecordsList 获取任务记录列表
|
|
// @param params 查询参数
|
|
// @return []mysqlType.TaskExport 任务记录列表
|
|
// @return error 错误信息
|
|
func (s *SqlAdapter) GetTaskRecordsList(params _type.GetTaskRecordsListReq) ([]*_type.TaskRecordsDTO, int64, error) {
|
|
list, count, err := sqLiteServer.GetTaskRecordsList(sqliteType.GetTaskRecordsByUserIdParams{
|
|
UserID: params.UserId,
|
|
ShopName: params.ShopName,
|
|
TaskID: params.TaskId,
|
|
TaskType: params.TaskType,
|
|
Page: _type.Page{
|
|
PageNum: params.Page,
|
|
PageSize: params.Size,
|
|
},
|
|
})
|
|
listDTO := convertSqliteTaskRecordsToDTO(list)
|
|
return listDTO, count, err
|
|
}
|
|
|
|
// GetTaskRecordsByTaskId 根据任务ID获取任务记录
|
|
func (s *SqlAdapter) GetTaskRecordsByTaskId(taskId string) (*_type.TaskRecordsDTO, error) {
|
|
info, err := sqLiteServer.GetTaskRecordByTaskID(taskId)
|
|
infoDTO := _type.TaskRecordsDTO{
|
|
Id: info.ID,
|
|
UserId: info.UserID,
|
|
ShopId: info.ShopID,
|
|
TaskId: info.TaskID,
|
|
ShopName: info.ShopName,
|
|
IsExport: info.IsExport,
|
|
TaskType: info.TaskType,
|
|
CreateAt: time.Now(),
|
|
}
|
|
return &infoDTO, err
|
|
}
|
|
|
|
// UpdateTaskRecords 更新任务记录
|
|
// @param export 任务记录
|
|
// @return error 错误信息
|
|
func (s *SqlAdapter) UpdateTaskRecords(user _type.TaskRecordsDTO) error {
|
|
return sqLiteServer.UpdateTaskRecord(sqliteType.TaskRecords{
|
|
ID: user.Id,
|
|
UserID: user.UserId,
|
|
ShopID: user.ShopId,
|
|
TaskID: user.TaskId,
|
|
ShopName: user.ShopName,
|
|
IsExport: user.IsExport,
|
|
TaskType: user.TaskType,
|
|
})
|
|
}
|
|
|
|
// GetTaskRecordsOldList 获取任务记录旧数据列表
|
|
// @return *mysqlType.TaskExport 任务记录列表
|
|
// @return error 错误信息
|
|
func (s *SqlAdapter) GetTaskRecordsOldList() ([]*_type.TaskRecordsDTO, error) {
|
|
list, err := sqLiteServer.GetTaskRecordsOldList()
|
|
listDTO := convertSqliteTaskRecordsToDTO(list)
|
|
return listDTO, err
|
|
}
|
|
|
|
// DeleteTaskRecordsOldData 删除任务记录旧数据
|
|
// @return error 错误信息
|
|
func (s *SqlAdapter) DeleteTaskRecordsOldData() error {
|
|
return sqLiteServer.DeleteOldTaskRecords()
|
|
}
|
|
|
|
// DeleteTaskRecordsByTaskId 根据任务 ID删除任务记录
|
|
func (s *SqlAdapter) DeleteTaskRecordsByTaskId(taskId string) error {
|
|
return sqLiteServer.DeleteTaskRecordsByTaskID(taskId)
|
|
}
|
|
|
|
// GetTaskRecords24Hour 获取24小时内的任务记录
|
|
func (s *SqlAdapter) GetTaskRecords24Hour() ([]*_type.TaskRecordsDTO, error) {
|
|
list, err := sqLiteServer.GetTaskRecords24Hour()
|
|
listDTO := convertSqliteTaskRecordsToDTO(list)
|
|
return listDTO, err
|
|
}
|
|
|
|
// GetTaskByShopIdAndTaskType 根据 shopId和 taskType获取任务记录
|
|
// @param taskId 任务ID
|
|
// @param taskType 任务类型
|
|
// @return []*_type.TaskRecordsDTO 任务列表
|
|
// @return error 错误信息
|
|
func (s *SqlAdapter) GetTaskByShopIdAndTaskType(taskId string, taskType int64) ([]*_type.TaskRecordsDTO, error) {
|
|
list, err := sqLiteServer.GetTaskByShopIdAndTaskType(taskId, taskType)
|
|
listDTO := convertSqliteTaskRecordsToDTO(list)
|
|
return listDTO, err
|
|
}
|
|
|
|
// GetAllTask 获取所有的任务记录
|
|
// @return []*_type.TaskRecordsDTO 所有任务列表
|
|
// @return error 错误信息
|
|
func (s *SqlAdapter) GetAllTask() ([]*_type.TaskRecordsDTO, error) {
|
|
list, err := sqLiteServer.GetAllTask()
|
|
listDTO := convertSqliteTaskRecordsToDTO(list)
|
|
return listDTO, err
|
|
}
|
|
|
|
func convertSqliteTaskRecordsToDTO(records []sqliteType.TaskRecords) []*_type.TaskRecordsDTO {
|
|
dtos := make([]*_type.TaskRecordsDTO, len(records))
|
|
for i, r := range records {
|
|
dtos[i] = &_type.TaskRecordsDTO{
|
|
Id: r.ID,
|
|
UserId: r.UserID,
|
|
ShopId: r.UserID,
|
|
TaskId: r.TaskID,
|
|
ShopName: r.ShopName,
|
|
IsExport: r.IsExport,
|
|
TaskType: r.TaskType,
|
|
CreateAt: r.CreateAt,
|
|
}
|
|
}
|
|
return dtos
|
|
}
|