|
@@ -13,6 +13,66 @@ import (
|
|
"youngee_b_api/model/http_model"
|
|
"youngee_b_api/model/http_model"
|
|
)
|
|
)
|
|
|
|
|
|
|
|
+func GetRecruittime(ctx context.Context, request http_model.GetRecruitTimeRequest) (*http_model.GetRecruitTimeResponse, error) {
|
|
|
|
+ db := GetReadDB(ctx)
|
|
|
|
+ var info gorm_model.ProjectInfo
|
|
|
|
+ err := db.Model(&gorm_model.ProjectInfo{}).Where("project_id = ?", request.ProjectId).Find(&info).Error
|
|
|
|
+ var result http_model.GetRecruitTimeResponse
|
|
|
|
+ if err != nil {
|
|
|
|
+ return &result, err
|
|
|
|
+ }
|
|
|
|
+ result.RecruitTime = info.RecruitDdl.Format("2006-01-02 15:04:05")
|
|
|
|
+ return &result, nil
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+func GetTalentstatusCount(db *gorm.DB, request http_model.GetTalentstatusNumRequest, status int) (int64, error) {
|
|
|
|
+ query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_status = ?", request.ProjectId, status)
|
|
|
|
+
|
|
|
|
+ // 计算总数
|
|
|
|
+ var total int64
|
|
|
|
+ if err := query.Count(&total).Error; err != nil {
|
|
|
|
+ return 0, err
|
|
|
|
+ }
|
|
|
|
+ return total, nil
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+func GetTalentstatusNum(db *gorm.DB, request http_model.GetTalentstatusCountRequest, status int) (int64, error) {
|
|
|
|
+ query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, status)
|
|
|
|
+ var total int64
|
|
|
|
+ if err := query.Count(&total).Error; err != nil {
|
|
|
|
+ return 0, err
|
|
|
|
+ }
|
|
|
|
+ return total, nil
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+func GetTalentstatusCountNum(ctx context.Context, request http_model.GetTalentstatusCountRequest) (*http_model.GetTalentstatusCountResponse, error) {
|
|
|
|
+ db := GetReadDB(ctx)
|
|
|
|
+ var unoperatenum, agreetalentnum, refusetalentnum int64
|
|
|
|
+ unoperatenum, _ = GetTalentstatusNum(db, request, request.TaskStage)
|
|
|
|
+ agreetalentnum, _ = GetTalentstatusNum(db, request, request.TaskStage+1)
|
|
|
|
+ refusetalentnum, _ = GetTalentstatusNum(db, request, request.TaskStage+2)
|
|
|
|
+ count := &http_model.GetTalentstatusCountResponse{
|
|
|
|
+ UnoperateTalentnum: unoperatenum,
|
|
|
|
+ AgreeTalentnum: agreetalentnum,
|
|
|
|
+ RefuseTalentnum: refusetalentnum,
|
|
|
|
+ }
|
|
|
|
+ return count, nil
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+func GetTalentstatusNumCount(ctx context.Context, request http_model.GetTalentstatusNumRequest) (*http_model.GetTalentStatusNumResponse, error) {
|
|
|
|
+ db := GetReadDB(ctx)
|
|
|
|
+ var unoperatenum, agreetalentnum, refusetalentnum int64
|
|
|
|
+ unoperatenum, _ = GetTalentstatusCount(db, request, 1)
|
|
|
|
+ agreetalentnum, _ = GetTalentstatusCount(db, request, 2)
|
|
|
|
+ refusetalentnum, _ = GetTalentstatusCount(db, request, 3)
|
|
|
|
+ count := &http_model.GetTalentStatusNumResponse{
|
|
|
|
+ UnoperateTalentnum: unoperatenum,
|
|
|
|
+ AgreeTalentnum: agreetalentnum,
|
|
|
|
+ RefuseTalentnum: refusetalentnum,
|
|
|
|
+ }
|
|
|
|
+ return count, nil
|
|
|
|
+}
|
|
|
|
+
|
|
func GetProjecttaskList(ctx context.Context, request http_model.GetTaskListRequest) (*http_model.GetTaskListData, error) {
|
|
func GetProjecttaskList(ctx context.Context, request http_model.GetTaskListRequest) (*http_model.GetTaskListData, error) {
|
|
db := GetReadDB(ctx)
|
|
db := GetReadDB(ctx)
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
@@ -48,6 +108,42 @@ func GetProjecttaskList(ctx context.Context, request http_model.GetTaskListReque
|
|
}
|
|
}
|
|
offset := (pageNum - 1) * pageSize
|
|
offset := (pageNum - 1) * pageSize
|
|
|
|
|
|
|
|
+ // 处理多字段排序逻辑
|
|
|
|
+ if len(request.SortField) > 0 && len(request.SortOrder) > 0 && len(request.SortField) == len(request.SortOrder) {
|
|
|
|
+ for i := 0; i < len(request.SortField); i++ {
|
|
|
|
+ field := request.SortField[i]
|
|
|
|
+ order := request.SortOrder[i]
|
|
|
|
+ switch field {
|
|
|
|
+ case "fansnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("fans_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("fans_num desc")
|
|
|
|
+ }
|
|
|
|
+ case "voteavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("vote_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("vote_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "commentavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("commit_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("commit_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "collectnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("view_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("view_num desc")
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ // Default sorting if no valid sort parameters
|
|
|
|
+ query = query.Order("task_status asc").Order("task_stage asc")
|
|
|
|
+ }
|
|
// 执行分页查询
|
|
// 执行分页查询
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
return nil, err
|
|
return nil, err
|
|
@@ -65,24 +161,28 @@ func GetProjecttaskList(ctx context.Context, request http_model.GetTaskListReque
|
|
Time = task.CompleteDate
|
|
Time = task.CompleteDate
|
|
}
|
|
}
|
|
boperator := getBOperator(db, task.BOperator, task.BOperatorType)
|
|
boperator := getBOperator(db, task.BOperator, task.BOperatorType)
|
|
- nickname, headurl := getTalentinfo(db, task.TalentID)
|
|
|
|
|
|
+ nickname, headurl, gender, fansnum, voteavg := getTalentinfo(db, task.OpenId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterPriseId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterPriseId)
|
|
|
|
+ s_type, s_name := stype(db, task.SupplierId, task.SupplierStatus)
|
|
response := &http_model.TaskInfo{
|
|
response := &http_model.TaskInfo{
|
|
TaskId: task.TaskID,
|
|
TaskId: task.TaskID,
|
|
ProjectId: task.ProjectID,
|
|
ProjectId: task.ProjectID,
|
|
TalentId: task.TalentID,
|
|
TalentId: task.TalentID,
|
|
- FansNum: task.FansNum,
|
|
|
|
|
|
+ FansNum: fansnum,
|
|
DraftFee: task.DraftFee,
|
|
DraftFee: task.DraftFee,
|
|
- Voteavg: task.VoteAvg,
|
|
|
|
|
|
+ Voteavg: voteavg,
|
|
FeeFrom: task.FeeForm,
|
|
FeeFrom: task.FeeForm,
|
|
TaskStage: task.TaskStage,
|
|
TaskStage: task.TaskStage,
|
|
- Commentavg: task.CommitAvg,
|
|
|
|
|
|
+ Commentavg: 0, //暂时获取不到
|
|
|
|
+ CollectNum: 0,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
- SType: stype(db, task.SupplierId, task.SupplierStatus),
|
|
|
|
|
|
+ SType: s_type,
|
|
|
|
+ SName: s_name,
|
|
Boperator: boperator,
|
|
Boperator: boperator,
|
|
- CreateAt: Time,
|
|
|
|
|
|
+ CreateAt: Time.Format("2006-01-02 15:04:05"),
|
|
NickName: nickname,
|
|
NickName: nickname,
|
|
|
|
+ Gender: gender,
|
|
HeadUrl: headurl,
|
|
HeadUrl: headurl,
|
|
ISCoop: Iscoop,
|
|
ISCoop: Iscoop,
|
|
Sprojectid: task.SprojectId,
|
|
Sprojectid: task.SprojectId,
|
|
@@ -121,12 +221,13 @@ func getBOperator(db *gorm.DB, bOperatorID string, bOperatorType int) string {
|
|
return ""
|
|
return ""
|
|
}
|
|
}
|
|
|
|
|
|
-func getTalentinfo(db *gorm.DB, talentID string) (string, string) {
|
|
|
|
|
|
+func getTalentinfo(db *gorm.DB, OpenId string) (string, string, string, int, int) {
|
|
var talentinfo gorm_model.PlatformKuaishouUserInfo
|
|
var talentinfo gorm_model.PlatformKuaishouUserInfo
|
|
- if err := db.Where(gorm_model.PlatformKuaishouUserInfo{TalentId: talentID}).First(&talentinfo).Error; err != nil {
|
|
|
|
- return "", ""
|
|
|
|
|
|
+ if err := db.Where(gorm_model.PlatformKuaishouUserInfo{OpenId: OpenId}).First(&talentinfo).Error; err != nil {
|
|
|
|
+ return "", "", "", 0, 0
|
|
}
|
|
}
|
|
- return talentinfo.NickName, talentinfo.HeadUri
|
|
|
|
|
|
+ fan, _ := conv.Int(talentinfo.Fan)
|
|
|
|
+ return talentinfo.NickName, talentinfo.HeadUri, talentinfo.Gender, fan, talentinfo.LikeNum
|
|
}
|
|
}
|
|
|
|
|
|
func getIscoop(db *gorm.DB, talentid string, enterpriseid string) int {
|
|
func getIscoop(db *gorm.DB, talentid string, enterpriseid string) int {
|
|
@@ -144,24 +245,22 @@ func determineFrom(supplierID, supplierStatus int) int {
|
|
return 1
|
|
return 1
|
|
}
|
|
}
|
|
|
|
|
|
-func stype(db *gorm.DB, supplierID, supplierStatus int) int {
|
|
|
|
|
|
+func stype(db *gorm.DB, supplierID, supplierStatus int) (int, string) {
|
|
if supplierID != 0 && supplierStatus == 2 {
|
|
if supplierID != 0 && supplierStatus == 2 {
|
|
var supplierinfo gorm_model.Supplier
|
|
var supplierinfo gorm_model.Supplier
|
|
err := db.Model(gorm_model.Supplier{}).Where("supplier_id = ?", supplierID).First(&supplierinfo).Error
|
|
err := db.Model(gorm_model.Supplier{}).Where("supplier_id = ?", supplierID).First(&supplierinfo).Error
|
|
if err != nil {
|
|
if err != nil {
|
|
- return 0
|
|
|
|
|
|
+ return 0, "公海"
|
|
}
|
|
}
|
|
- return supplierinfo.SupplierType
|
|
|
|
|
|
+ return supplierinfo.SupplierType, supplierinfo.SupplierName
|
|
}
|
|
}
|
|
- return 0
|
|
|
|
|
|
+ return 0, "公海"
|
|
}
|
|
}
|
|
func PassProTaskCoop(ctx context.Context, projectId string, taskIds []string, operatorid string, operatetype int, Isspecial int, req http_model.PassproTaskCoopRequest) (bool, error) {
|
|
func PassProTaskCoop(ctx context.Context, projectId string, taskIds []string, operatorid string, operatetype int, Isspecial int, req http_model.PassproTaskCoopRequest) (bool, error) {
|
|
db := GetReadDB(ctx)
|
|
db := GetReadDB(ctx)
|
|
var count int64
|
|
var count int64
|
|
- fmt.Println("task_ids: ", taskIds)
|
|
|
|
err := db.Model(gorm_model.YoungeeTaskInfo{}).Where("task_id IN ? AND task_stage = 1", taskIds).Count(&count).Error
|
|
err := db.Model(gorm_model.YoungeeTaskInfo{}).Where("task_id IN ? AND task_stage = 1", taskIds).Count(&count).Error
|
|
|
|
|
|
- fmt.Println("count: ", count)
|
|
|
|
if err != nil {
|
|
if err != nil {
|
|
return false, err
|
|
return false, err
|
|
}
|
|
}
|
|
@@ -380,6 +479,11 @@ func GetPreSketchList(ctx context.Context, request http_model.PreSketchListReque
|
|
db := GetReadDB(ctx)
|
|
db := GetReadDB(ctx)
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.ScriptStatus)
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.ScriptStatus)
|
|
|
|
+
|
|
|
|
+ if request.Others != "" {
|
|
|
|
+ query = query.Where("talent_name LIKE ? OR s_operate_name LIKE ?", "%"+request.Others+"%", "%"+request.Others+"%")
|
|
|
|
+ }
|
|
|
|
+
|
|
// 计算总数
|
|
// 计算总数
|
|
var total int64
|
|
var total int64
|
|
if err := query.Count(&total).Error; err != nil {
|
|
if err := query.Count(&total).Error; err != nil {
|
|
@@ -397,35 +501,75 @@ func GetPreSketchList(ctx context.Context, request http_model.PreSketchListReque
|
|
}
|
|
}
|
|
offset := (pageNum - 1) * pageSize
|
|
offset := (pageNum - 1) * pageSize
|
|
// 执行分页查询
|
|
// 执行分页查询
|
|
|
|
+ // 处理多字段排序逻辑
|
|
|
|
+ if len(request.SortField) > 0 && len(request.SortOrder) > 0 && len(request.SortField) == len(request.SortOrder) {
|
|
|
|
+ for i := 0; i < len(request.SortField); i++ {
|
|
|
|
+ field := request.SortField[i]
|
|
|
|
+ order := request.SortOrder[i]
|
|
|
|
+ switch field {
|
|
|
|
+ case "fansnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("fans_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("fans_num desc")
|
|
|
|
+ }
|
|
|
|
+ case "voteavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("vote_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("vote_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "commentavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("commit_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("commit_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "collectnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("view_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("view_num desc")
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ // Default sorting if no valid sort parameters
|
|
|
|
+ query = query.Order("task_status asc").Order("task_stage asc")
|
|
|
|
+ }
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
return nil, err
|
|
return nil, err
|
|
}
|
|
}
|
|
taskInfoPointers := make([]*http_model.TasksketchInfo, 0, len(projecrtaskinfo))
|
|
taskInfoPointers := make([]*http_model.TasksketchInfo, 0, len(projecrtaskinfo))
|
|
|
|
|
|
for _, task := range projecrtaskinfo {
|
|
for _, task := range projecrtaskinfo {
|
|
- nickname, headurl := getTalentinfo(db, task.TalentID)
|
|
|
|
|
|
+ nickname, headurl, gender, fansnum, voteavg := getTalentinfo(db, task.OpenId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
|
|
+ s_type, s_name := stype(db, task.SupplierId, task.SupplierStatus)
|
|
taskinfo := &http_model.TaskInfo{
|
|
taskinfo := &http_model.TaskInfo{
|
|
TaskId: task.TaskID,
|
|
TaskId: task.TaskID,
|
|
ProjectId: task.ProjectID,
|
|
ProjectId: task.ProjectID,
|
|
TalentId: task.TalentID,
|
|
TalentId: task.TalentID,
|
|
- FansNum: task.FansNum,
|
|
|
|
|
|
+ FansNum: fansnum,
|
|
DraftFee: task.DraftFee,
|
|
DraftFee: task.DraftFee,
|
|
- Voteavg: task.VoteAvg,
|
|
|
|
|
|
+ Voteavg: voteavg,
|
|
FeeFrom: task.FeeForm,
|
|
FeeFrom: task.FeeForm,
|
|
TaskStage: task.TaskStage,
|
|
TaskStage: task.TaskStage,
|
|
- Commentavg: task.CommitAvg,
|
|
|
|
|
|
+ Commentavg: 0,
|
|
|
|
+ CollectNum: 0,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
- SType: stype(db, task.SupplierId, task.SupplierStatus),
|
|
|
|
|
|
+ SType: s_type,
|
|
|
|
+ SName: s_name,
|
|
NickName: nickname,
|
|
NickName: nickname,
|
|
|
|
+ Gender: gender,
|
|
HeadUrl: headurl,
|
|
HeadUrl: headurl,
|
|
ISCoop: Iscoop,
|
|
ISCoop: Iscoop,
|
|
City: task.City,
|
|
City: task.City,
|
|
}
|
|
}
|
|
response := &http_model.TasksketchInfo{
|
|
response := &http_model.TasksketchInfo{
|
|
Task: taskinfo,
|
|
Task: taskinfo,
|
|
- DDl: task.CurBreakAt,
|
|
|
|
|
|
+ DDl: task.CurBreakAt.Format("2006-01-02 15:04:05"),
|
|
}
|
|
}
|
|
taskInfoPointers = append(taskInfoPointers, response)
|
|
taskInfoPointers = append(taskInfoPointers, response)
|
|
|
|
|
|
@@ -440,6 +584,11 @@ func GetSketchList(ctx context.Context, request http_model.TasksketchlistRequest
|
|
db := GetReadDB(ctx)
|
|
db := GetReadDB(ctx)
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.ScriptStatus)
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.ScriptStatus)
|
|
|
|
+
|
|
|
|
+ if request.Others != "" {
|
|
|
|
+ query = query.Where("talent_name LIKE ? OR s_operate_name LIKE ?", "%"+request.Others+"%", "%"+request.Others+"%")
|
|
|
|
+ }
|
|
|
|
+
|
|
// 计算总数
|
|
// 计算总数
|
|
var total int64
|
|
var total int64
|
|
if err := query.Count(&total).Error; err != nil {
|
|
if err := query.Count(&total).Error; err != nil {
|
|
@@ -457,26 +606,66 @@ func GetSketchList(ctx context.Context, request http_model.TasksketchlistRequest
|
|
}
|
|
}
|
|
offset := (pageNum - 1) * pageSize
|
|
offset := (pageNum - 1) * pageSize
|
|
// 执行分页查询
|
|
// 执行分页查询
|
|
|
|
+ // 处理多字段排序逻辑
|
|
|
|
+ if len(request.SortField) > 0 && len(request.SortOrder) > 0 && len(request.SortField) == len(request.SortOrder) {
|
|
|
|
+ for i := 0; i < len(request.SortField); i++ {
|
|
|
|
+ field := request.SortField[i]
|
|
|
|
+ order := request.SortOrder[i]
|
|
|
|
+ switch field {
|
|
|
|
+ case "fansnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("fans_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("fans_num desc")
|
|
|
|
+ }
|
|
|
|
+ case "voteavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("vote_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("vote_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "commentavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("commit_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("commit_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "collectnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("view_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("view_num desc")
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ // Default sorting if no valid sort parameters
|
|
|
|
+ query = query.Order("task_status asc").Order("task_stage asc")
|
|
|
|
+ }
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
return nil, err
|
|
return nil, err
|
|
}
|
|
}
|
|
taskInfoPointers := make([]*http_model.Tasksketchinfo, 0, len(projecrtaskinfo))
|
|
taskInfoPointers := make([]*http_model.Tasksketchinfo, 0, len(projecrtaskinfo))
|
|
for _, task := range projecrtaskinfo {
|
|
for _, task := range projecrtaskinfo {
|
|
- nickname, headurl := getTalentinfo(db, task.TalentID)
|
|
|
|
|
|
+ nickname, headurl, gender, fansnum, voteavg := getTalentinfo(db, task.OpenId)
|
|
|
|
+ s_type, s_name := stype(db, task.SupplierId, task.SupplierStatus)
|
|
taskinfo := &http_model.TaskInfo{
|
|
taskinfo := &http_model.TaskInfo{
|
|
TaskId: task.TaskID,
|
|
TaskId: task.TaskID,
|
|
ProjectId: task.ProjectID,
|
|
ProjectId: task.ProjectID,
|
|
TalentId: task.TalentID,
|
|
TalentId: task.TalentID,
|
|
- FansNum: task.FansNum,
|
|
|
|
|
|
+ FansNum: fansnum,
|
|
DraftFee: task.DraftFee,
|
|
DraftFee: task.DraftFee,
|
|
- Voteavg: task.VoteAvg,
|
|
|
|
|
|
+ Voteavg: voteavg,
|
|
FeeFrom: task.FeeForm,
|
|
FeeFrom: task.FeeForm,
|
|
TaskStage: task.TaskStage,
|
|
TaskStage: task.TaskStage,
|
|
- Commentavg: task.CommitAvg,
|
|
|
|
|
|
+ Commentavg: 0,
|
|
|
|
+ CollectNum: 0,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
- SType: stype(db, task.SupplierId, task.SupplierStatus),
|
|
|
|
|
|
+ SType: s_type,
|
|
|
|
+ SName: s_name,
|
|
NickName: nickname,
|
|
NickName: nickname,
|
|
|
|
+ Gender: gender,
|
|
HeadUrl: headurl,
|
|
HeadUrl: headurl,
|
|
City: task.City,
|
|
City: task.City,
|
|
}
|
|
}
|
|
@@ -489,8 +678,8 @@ func GetSketchList(ctx context.Context, request http_model.TasksketchlistRequest
|
|
response := &http_model.Tasksketchinfo{
|
|
response := &http_model.Tasksketchinfo{
|
|
Task: taskinfo,
|
|
Task: taskinfo,
|
|
SketchId: sketchinfo.SketchID,
|
|
SketchId: sketchinfo.SketchID,
|
|
- SubmitAt: sketchinfo.SubmitAt,
|
|
|
|
- AgreeAt: sketchinfo.AgreeAt,
|
|
|
|
|
|
+ SubmitAt: sketchinfo.SubmitAt.Format("2006-01-02 15:04:05"),
|
|
|
|
+ AgreeAt: sketchinfo.AgreeAt.Format("2006-01-02 15:04:05"),
|
|
Operator: boperator,
|
|
Operator: boperator,
|
|
}
|
|
}
|
|
taskInfoPointers = append(taskInfoPointers, response)
|
|
taskInfoPointers = append(taskInfoPointers, response)
|
|
@@ -506,6 +695,11 @@ func GetPreLinkList(ctx context.Context, request http_model.PreLinkListRequest)
|
|
db := GetReadDB(ctx)
|
|
db := GetReadDB(ctx)
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.LinkStatus)
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.LinkStatus)
|
|
|
|
+
|
|
|
|
+ if request.Others != "" {
|
|
|
|
+ query = query.Where("talent_name LIKE ? OR s_operate_name LIKE ?", "%"+request.Others+"%", "%"+request.Others+"%")
|
|
|
|
+ }
|
|
|
|
+
|
|
// 计算总数
|
|
// 计算总数
|
|
var total int64
|
|
var total int64
|
|
if err := query.Count(&total).Error; err != nil {
|
|
if err := query.Count(&total).Error; err != nil {
|
|
@@ -523,34 +717,74 @@ func GetPreLinkList(ctx context.Context, request http_model.PreLinkListRequest)
|
|
}
|
|
}
|
|
offset := (pageNum - 1) * pageSize
|
|
offset := (pageNum - 1) * pageSize
|
|
// 执行分页查询
|
|
// 执行分页查询
|
|
|
|
+ // 处理多字段排序逻辑
|
|
|
|
+ if len(request.SortField) > 0 && len(request.SortOrder) > 0 && len(request.SortField) == len(request.SortOrder) {
|
|
|
|
+ for i := 0; i < len(request.SortField); i++ {
|
|
|
|
+ field := request.SortField[i]
|
|
|
|
+ order := request.SortOrder[i]
|
|
|
|
+ switch field {
|
|
|
|
+ case "fansnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("fans_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("fans_num desc")
|
|
|
|
+ }
|
|
|
|
+ case "voteavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("vote_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("vote_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "commentavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("commit_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("commit_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "collectnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("view_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("view_num desc")
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ // Default sorting if no valid sort parameters
|
|
|
|
+ query = query.Order("task_status asc").Order("task_stage asc")
|
|
|
|
+ }
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
return nil, err
|
|
return nil, err
|
|
}
|
|
}
|
|
taskInfoPointers := make([]*http_model.Tasklinkinfo, 0, len(projecrtaskinfo))
|
|
taskInfoPointers := make([]*http_model.Tasklinkinfo, 0, len(projecrtaskinfo))
|
|
for _, task := range projecrtaskinfo {
|
|
for _, task := range projecrtaskinfo {
|
|
- nickname, headurl := getTalentinfo(db, task.TalentID)
|
|
|
|
|
|
+ nickname, headurl, gender, fansnum, voteavg := getTalentinfo(db, task.OpenId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
|
|
+ s_type, s_name := stype(db, task.SupplierId, task.SupplierStatus)
|
|
taskinfo := &http_model.TaskInfo{
|
|
taskinfo := &http_model.TaskInfo{
|
|
TaskId: task.TaskID,
|
|
TaskId: task.TaskID,
|
|
ProjectId: task.ProjectID,
|
|
ProjectId: task.ProjectID,
|
|
TalentId: task.TalentID,
|
|
TalentId: task.TalentID,
|
|
- FansNum: task.FansNum,
|
|
|
|
|
|
+ FansNum: fansnum,
|
|
DraftFee: task.DraftFee,
|
|
DraftFee: task.DraftFee,
|
|
- Voteavg: task.VoteAvg,
|
|
|
|
|
|
+ Voteavg: voteavg,
|
|
FeeFrom: task.FeeForm,
|
|
FeeFrom: task.FeeForm,
|
|
TaskStage: task.TaskStage,
|
|
TaskStage: task.TaskStage,
|
|
- Commentavg: task.CommitAvg,
|
|
|
|
|
|
+ Commentavg: 0,
|
|
|
|
+ CollectNum: 0,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
- SType: stype(db, task.SupplierId, task.SupplierStatus),
|
|
|
|
|
|
+ SType: s_type,
|
|
|
|
+ SName: s_name,
|
|
NickName: nickname,
|
|
NickName: nickname,
|
|
|
|
+ Gender: gender,
|
|
HeadUrl: headurl,
|
|
HeadUrl: headurl,
|
|
ISCoop: Iscoop,
|
|
ISCoop: Iscoop,
|
|
City: task.City,
|
|
City: task.City,
|
|
}
|
|
}
|
|
response := &http_model.Tasklinkinfo{
|
|
response := &http_model.Tasklinkinfo{
|
|
Task: taskinfo,
|
|
Task: taskinfo,
|
|
- DDl: task.CurBreakAt,
|
|
|
|
|
|
+ DDl: task.CurBreakAt.Format("2006-01-02 15:04:05"),
|
|
}
|
|
}
|
|
taskInfoPointers = append(taskInfoPointers, response)
|
|
taskInfoPointers = append(taskInfoPointers, response)
|
|
|
|
|
|
@@ -565,6 +799,11 @@ func GetLinkList(ctx context.Context, request http_model.TaskLinklistRequest) (*
|
|
db := GetReadDB(ctx)
|
|
db := GetReadDB(ctx)
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.LinkStatus)
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.LinkStatus)
|
|
|
|
+
|
|
|
|
+ if request.Others != "" {
|
|
|
|
+ query = query.Where("talent_name LIKE ? OR s_operate_name LIKE ?", "%"+request.Others+"%", "%"+request.Others+"%")
|
|
|
|
+ }
|
|
|
|
+
|
|
// 计算总数
|
|
// 计算总数
|
|
var total int64
|
|
var total int64
|
|
if err := query.Count(&total).Error; err != nil {
|
|
if err := query.Count(&total).Error; err != nil {
|
|
@@ -582,27 +821,67 @@ func GetLinkList(ctx context.Context, request http_model.TaskLinklistRequest) (*
|
|
}
|
|
}
|
|
offset := (pageNum - 1) * pageSize
|
|
offset := (pageNum - 1) * pageSize
|
|
// 执行分页查询
|
|
// 执行分页查询
|
|
|
|
+ // 处理多字段排序逻辑
|
|
|
|
+ if len(request.SortField) > 0 && len(request.SortOrder) > 0 && len(request.SortField) == len(request.SortOrder) {
|
|
|
|
+ for i := 0; i < len(request.SortField); i++ {
|
|
|
|
+ field := request.SortField[i]
|
|
|
|
+ order := request.SortOrder[i]
|
|
|
|
+ switch field {
|
|
|
|
+ case "fansnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("fans_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("fans_num desc")
|
|
|
|
+ }
|
|
|
|
+ case "voteavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("vote_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("vote_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "commentavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("commit_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("commit_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "collectnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("view_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("view_num desc")
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ // Default sorting if no valid sort parameters
|
|
|
|
+ query = query.Order("task_status asc").Order("task_stage asc")
|
|
|
|
+ }
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
return nil, err
|
|
return nil, err
|
|
}
|
|
}
|
|
taskInfoPointers := make([]*http_model.TaskLinkinfo, 0, len(projecrtaskinfo))
|
|
taskInfoPointers := make([]*http_model.TaskLinkinfo, 0, len(projecrtaskinfo))
|
|
for _, task := range projecrtaskinfo {
|
|
for _, task := range projecrtaskinfo {
|
|
- nickname, headurl := getTalentinfo(db, task.TalentID)
|
|
|
|
|
|
+ nickname, headurl, gender, fansnum, voteavg := getTalentinfo(db, task.OpenId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
|
|
+ s_type, s_name := stype(db, task.SupplierId, task.SupplierStatus)
|
|
taskinfo := &http_model.TaskInfo{
|
|
taskinfo := &http_model.TaskInfo{
|
|
TaskId: task.TaskID,
|
|
TaskId: task.TaskID,
|
|
ProjectId: task.ProjectID,
|
|
ProjectId: task.ProjectID,
|
|
TalentId: task.TalentID,
|
|
TalentId: task.TalentID,
|
|
- FansNum: task.FansNum,
|
|
|
|
|
|
+ FansNum: fansnum,
|
|
DraftFee: task.DraftFee,
|
|
DraftFee: task.DraftFee,
|
|
- Voteavg: task.VoteAvg,
|
|
|
|
|
|
+ Voteavg: voteavg,
|
|
FeeFrom: task.FeeForm,
|
|
FeeFrom: task.FeeForm,
|
|
TaskStage: task.TaskStage,
|
|
TaskStage: task.TaskStage,
|
|
- Commentavg: task.CommitAvg,
|
|
|
|
|
|
+ Commentavg: 0,
|
|
|
|
+ CollectNum: 0,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
- SType: stype(db, task.SupplierId, task.SupplierStatus),
|
|
|
|
|
|
+ SType: s_type,
|
|
|
|
+ SName: s_name,
|
|
NickName: nickname,
|
|
NickName: nickname,
|
|
|
|
+ Gender: gender,
|
|
HeadUrl: headurl,
|
|
HeadUrl: headurl,
|
|
ISCoop: Iscoop,
|
|
ISCoop: Iscoop,
|
|
City: task.City,
|
|
City: task.City,
|
|
@@ -616,8 +895,8 @@ func GetLinkList(ctx context.Context, request http_model.TaskLinklistRequest) (*
|
|
response := &http_model.TaskLinkinfo{
|
|
response := &http_model.TaskLinkinfo{
|
|
Task: taskinfo,
|
|
Task: taskinfo,
|
|
LinkId: linkinfo.LinkID,
|
|
LinkId: linkinfo.LinkID,
|
|
- SubmitAt: linkinfo.SubmitAt,
|
|
|
|
- AgreeAt: linkinfo.AgreeAt,
|
|
|
|
|
|
+ SubmitAt: linkinfo.SubmitAt.Format("2006-01-02 15:04:05"),
|
|
|
|
+ AgreeAt: linkinfo.AgreeAt.Format("2006-01-02 15:04:05"),
|
|
LinkUrl: linkinfo.LinkUrl,
|
|
LinkUrl: linkinfo.LinkUrl,
|
|
PhotoUrl: linkinfo.PhotoUrl,
|
|
PhotoUrl: linkinfo.PhotoUrl,
|
|
Operator: boperator,
|
|
Operator: boperator,
|
|
@@ -635,6 +914,9 @@ func GetPreDataList(ctx context.Context, request http_model.PreDataListRequest)
|
|
db := GetReadDB(ctx)
|
|
db := GetReadDB(ctx)
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.DataStatus)
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.DataStatus)
|
|
|
|
+ if request.Others != "" {
|
|
|
|
+ query = query.Where("talent_name LIKE ? OR s_operate_name LIKE ?", "%"+request.Others+"%", "%"+request.Others+"%")
|
|
|
|
+ }
|
|
// 计算总数
|
|
// 计算总数
|
|
var total int64
|
|
var total int64
|
|
if err := query.Count(&total).Error; err != nil {
|
|
if err := query.Count(&total).Error; err != nil {
|
|
@@ -652,34 +934,74 @@ func GetPreDataList(ctx context.Context, request http_model.PreDataListRequest)
|
|
}
|
|
}
|
|
offset := (pageNum - 1) * pageSize
|
|
offset := (pageNum - 1) * pageSize
|
|
// 执行分页查询
|
|
// 执行分页查询
|
|
|
|
+ // 处理多字段排序逻辑
|
|
|
|
+ if len(request.SortField) > 0 && len(request.SortOrder) > 0 && len(request.SortField) == len(request.SortOrder) {
|
|
|
|
+ for i := 0; i < len(request.SortField); i++ {
|
|
|
|
+ field := request.SortField[i]
|
|
|
|
+ order := request.SortOrder[i]
|
|
|
|
+ switch field {
|
|
|
|
+ case "fansnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("fans_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("fans_num desc")
|
|
|
|
+ }
|
|
|
|
+ case "voteavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("vote_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("vote_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "commentavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("commit_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("commit_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "collectnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("view_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("view_num desc")
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ // Default sorting if no valid sort parameters
|
|
|
|
+ query = query.Order("task_status asc").Order("task_stage asc")
|
|
|
|
+ }
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
return nil, err
|
|
return nil, err
|
|
}
|
|
}
|
|
taskInfoPointers := make([]*http_model.Taskdatainfo, 0, len(projecrtaskinfo))
|
|
taskInfoPointers := make([]*http_model.Taskdatainfo, 0, len(projecrtaskinfo))
|
|
for _, task := range projecrtaskinfo {
|
|
for _, task := range projecrtaskinfo {
|
|
- nickname, headurl := getTalentinfo(db, task.TalentID)
|
|
|
|
|
|
+ nickname, headurl, gender, fansnum, voteavg := getTalentinfo(db, task.OpenId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
|
|
+ s_type, s_name := stype(db, task.SupplierId, task.SupplierStatus)
|
|
taskinfo := &http_model.TaskInfo{
|
|
taskinfo := &http_model.TaskInfo{
|
|
TaskId: task.TaskID,
|
|
TaskId: task.TaskID,
|
|
ProjectId: task.ProjectID,
|
|
ProjectId: task.ProjectID,
|
|
TalentId: task.TalentID,
|
|
TalentId: task.TalentID,
|
|
- FansNum: task.FansNum,
|
|
|
|
|
|
+ FansNum: fansnum,
|
|
DraftFee: task.DraftFee,
|
|
DraftFee: task.DraftFee,
|
|
- Voteavg: task.VoteAvg,
|
|
|
|
|
|
+ Voteavg: voteavg,
|
|
FeeFrom: task.FeeForm,
|
|
FeeFrom: task.FeeForm,
|
|
TaskStage: task.TaskStage,
|
|
TaskStage: task.TaskStage,
|
|
- Commentavg: task.CommitAvg,
|
|
|
|
|
|
+ Commentavg: 0,
|
|
|
|
+ CollectNum: 0,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
- SType: stype(db, task.SupplierId, task.SupplierStatus),
|
|
|
|
|
|
+ SType: s_type,
|
|
|
|
+ SName: s_name,
|
|
NickName: nickname,
|
|
NickName: nickname,
|
|
|
|
+ Gender: gender,
|
|
HeadUrl: headurl,
|
|
HeadUrl: headurl,
|
|
ISCoop: Iscoop,
|
|
ISCoop: Iscoop,
|
|
City: task.City,
|
|
City: task.City,
|
|
}
|
|
}
|
|
response := &http_model.Taskdatainfo{
|
|
response := &http_model.Taskdatainfo{
|
|
Task: taskinfo,
|
|
Task: taskinfo,
|
|
- DDl: task.CurBreakAt,
|
|
|
|
|
|
+ DDl: task.CurBreakAt.Format("2006-01-02 15:04:05"),
|
|
}
|
|
}
|
|
taskInfoPointers = append(taskInfoPointers, response)
|
|
taskInfoPointers = append(taskInfoPointers, response)
|
|
|
|
|
|
@@ -694,6 +1016,9 @@ func GetDataList(ctx context.Context, request http_model.TaskDatalistRequest) (*
|
|
db := GetReadDB(ctx)
|
|
db := GetReadDB(ctx)
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
var projecrtaskinfo []gorm_model.YoungeeTaskInfo
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.DataStatus)
|
|
query := db.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND task_stage = ?", request.ProjectId, request.DataStatus)
|
|
|
|
+ if request.Others != "" {
|
|
|
|
+ query = query.Where("talent_name LIKE ? OR s_operate_name LIKE ?", "%"+request.Others+"%", "%"+request.Others+"%")
|
|
|
|
+ }
|
|
// 计算总数
|
|
// 计算总数
|
|
var total int64
|
|
var total int64
|
|
if err := query.Count(&total).Error; err != nil {
|
|
if err := query.Count(&total).Error; err != nil {
|
|
@@ -711,27 +1036,67 @@ func GetDataList(ctx context.Context, request http_model.TaskDatalistRequest) (*
|
|
}
|
|
}
|
|
offset := (pageNum - 1) * pageSize
|
|
offset := (pageNum - 1) * pageSize
|
|
// 执行分页查询
|
|
// 执行分页查询
|
|
|
|
+ // 处理多字段排序逻辑
|
|
|
|
+ if len(request.SortField) > 0 && len(request.SortOrder) > 0 && len(request.SortField) == len(request.SortOrder) {
|
|
|
|
+ for i := 0; i < len(request.SortField); i++ {
|
|
|
|
+ field := request.SortField[i]
|
|
|
|
+ order := request.SortOrder[i]
|
|
|
|
+ switch field {
|
|
|
|
+ case "fansnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("fans_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("fans_num desc")
|
|
|
|
+ }
|
|
|
|
+ case "voteavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("vote_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("vote_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "commentavg":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("commit_avg asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("commit_avg desc")
|
|
|
|
+ }
|
|
|
|
+ case "collectnum":
|
|
|
|
+ if order == "asc" {
|
|
|
|
+ query = query.Order("view_num asc")
|
|
|
|
+ } else {
|
|
|
|
+ query = query.Order("view_num desc")
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ // Default sorting if no valid sort parameters
|
|
|
|
+ query = query.Order("task_status asc").Order("task_stage asc")
|
|
|
|
+ }
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
if err := query.Offset(offset).Limit(pageSize).Find(&projecrtaskinfo).Error; err != nil {
|
|
return nil, err
|
|
return nil, err
|
|
}
|
|
}
|
|
taskInfoPointers := make([]*http_model.TaskDatainfo, 0, len(projecrtaskinfo))
|
|
taskInfoPointers := make([]*http_model.TaskDatainfo, 0, len(projecrtaskinfo))
|
|
for _, task := range projecrtaskinfo {
|
|
for _, task := range projecrtaskinfo {
|
|
- nickname, headurl := getTalentinfo(db, task.TalentID)
|
|
|
|
|
|
+ nickname, headurl, gender, fansnum, voteavg := getTalentinfo(db, task.OpenId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
Iscoop := getIscoop(db, task.TalentID, request.EnterpriseId)
|
|
|
|
+ s_type, s_name := stype(db, task.SupplierId, task.SupplierStatus)
|
|
taskinfo := &http_model.TaskInfo{
|
|
taskinfo := &http_model.TaskInfo{
|
|
TaskId: task.TaskID,
|
|
TaskId: task.TaskID,
|
|
ProjectId: task.ProjectID,
|
|
ProjectId: task.ProjectID,
|
|
TalentId: task.TalentID,
|
|
TalentId: task.TalentID,
|
|
- FansNum: task.FansNum,
|
|
|
|
|
|
+ FansNum: fansnum,
|
|
DraftFee: task.DraftFee,
|
|
DraftFee: task.DraftFee,
|
|
- Voteavg: task.VoteAvg,
|
|
|
|
|
|
+ Voteavg: voteavg,
|
|
FeeFrom: task.FeeForm,
|
|
FeeFrom: task.FeeForm,
|
|
TaskStage: task.TaskStage,
|
|
TaskStage: task.TaskStage,
|
|
- Commentavg: task.CommitAvg,
|
|
|
|
|
|
+ Commentavg: 0,
|
|
|
|
+ CollectNum: 0,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
CurrentDefaultType: task.CurDefaultType,
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
From: determineFrom(task.SupplierId, task.SupplierStatus),
|
|
- SType: stype(db, task.SupplierId, task.SupplierStatus),
|
|
|
|
|
|
+ SType: s_type,
|
|
|
|
+ SName: s_name,
|
|
NickName: nickname,
|
|
NickName: nickname,
|
|
|
|
+ Gender: gender,
|
|
HeadUrl: headurl,
|
|
HeadUrl: headurl,
|
|
ISCoop: Iscoop,
|
|
ISCoop: Iscoop,
|
|
City: task.City,
|
|
City: task.City,
|
|
@@ -745,8 +1110,8 @@ func GetDataList(ctx context.Context, request http_model.TaskDatalistRequest) (*
|
|
response := &http_model.TaskDatainfo{
|
|
response := &http_model.TaskDatainfo{
|
|
Task: taskinfo,
|
|
Task: taskinfo,
|
|
DataId: datainfo.DataID,
|
|
DataId: datainfo.DataID,
|
|
- SubmitAt: datainfo.SubmitAt,
|
|
|
|
- AgreeAt: datainfo.AgreeAt,
|
|
|
|
|
|
+ SubmitAt: datainfo.SubmitAt.Format("2006-01-02 15:04:05"),
|
|
|
|
+ AgreeAt: datainfo.AgreeAt.Format("2006-01-02 15:04:05"),
|
|
PhotoUrl: datainfo.PhotoUrl,
|
|
PhotoUrl: datainfo.PhotoUrl,
|
|
PlayNumber: datainfo.PlayNumber,
|
|
PlayNumber: datainfo.PlayNumber,
|
|
LikeNumber: datainfo.LikeNumber,
|
|
LikeNumber: datainfo.LikeNumber,
|