package service import ( "context" "fmt" "strconv" "strings" "time" "youngee_m_api/db" "youngee_m_api/model/common_model" "youngee_m_api/model/gorm_model" "youngee_m_api/model/http_model" "youngee_m_api/pack" "youngee_m_api/util" "github.com/caixw/lib.go/conv" "github.com/gin-gonic/gin" "github.com/sirupsen/logrus" ) var Project *project type project struct { } func (*project) GetFullProjectList(ctx context.Context, pageSize, pageNum int32, condition *common_model.ProjectCondition, projectType string) (*http_model.FullProjectListData, error) { fullProjects, total, err := db.GetFullProjectList(ctx, pageSize, pageNum, condition, projectType) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetFullProjectList error,err:%+v", err) return nil, err } fullProjectListData := new(http_model.FullProjectListData) fullProjectListData.FullProjectPreview = pack.MGormFullProjectToHttpFullProjectPreview(fullProjects) fullProjectListData.Total = conv.MustString(total, "") return fullProjectListData, nil } func (*project) GetProjectDetail(ctx context.Context, projectID int64) (*http_model.ShowProjectData, error) { project, err := db.GetProjectDetail(ctx, projectID) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetPorjectDetail error,err:%+v", err) return nil, err } enterprise, err := db.GetEnterpriseByEnterpriseID(ctx, project.EnterpriseID) // fmt.Println("%+v", enterprise.UserID) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetEnterpriseByEnterpriseID error,err:%+v", err) return nil, err } user, err := db.GetUserByID(ctx, enterprise.UserID) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetUserByID error,err:%+v", err) return nil, err } // fmt.Println("%+v", user.Phone) //var RecruitStrategys []http_model.ShowRecruitStrategy ProjectDetail := http_model.ShowProjectData{ ProjectID: conv.MustString(project.ProjectID, ""), ProjectName: conv.MustString(project.ProjectName, ""), ProjectStatus: conv.MustString(project.ProjectStatus, ""), ProjectType: conv.MustString(project.ProjectType, ""), ProjectPlatform: conv.MustString(project.ProjectPlatform, ""), ProjectForm: conv.MustString(project.ProjectForm, ""), TalentType: conv.MustString(project.TalentType, ""), RecruitDdl: util.GetTimePointer(project.RecruitDdl), ContentType: conv.MustString(project.ContentType, ""), ProjectDetail: conv.MustString(project.ProjectDetail, ""), ProductID: conv.MustString(project.ProductID, ""), EnterpriseID: conv.MustString(project.EnterpriseID, ""), Balance: conv.MustString(enterprise.Balance, ""), FailReason: conv.MustString(project.FailReason, ""), CreateAt: util.GetTimePointer(project.CreatedAt), UpdateAt: util.GetTimePointer(project.UpdatedAt), Phone: user.Phone, FinishAt: util.GetTimePointer(project.FinishAt), PassAt: util.GetTimePointer(project.PassAt), PayAt: util.GetTimePointer(project.PayAt), } Strategys, err := db.GetRecruitStrategys(ctx, projectID) fmt.Println("招募策略:", Strategys) if err != nil { logrus.WithContext(ctx).Error() return nil, err } for _, strategy := range Strategys { RecruitStrategy := http_model.ShowRecruitStrategy{ RecruitStrategyID: conv.MustString(strategy.RecruitStrategyID, ""), FeeForm: conv.MustString(strategy.FeeForm, ""), StrategyID: conv.MustString(strategy.StrategyID, ""), FollowersLow: conv.MustString(strategy.FollowersLow, ""), FollowersUp: conv.MustString(strategy.FollowersUp, ""), RecruitNumber: conv.MustString(strategy.RecruitNumber, ""), Offer: conv.MustString(strategy.Offer, ""), ServiceCharge: conv.MustString(strategy.ServiceCharge, ""), SelectedNumber: strategy.SelectedNumber, WaitingNumber: strategy.WaitingNumber, DeliveredNumber: strategy.DeliveredNumber, SignedNumber: strategy.SignedNumber, } ProjectDetail.RecruitStrategys = append(ProjectDetail.RecruitStrategys, RecruitStrategy) } Photos, err := db.GetProjectPhoto(ctx, projectID) if err != nil { logrus.WithContext(ctx).Error() return nil, err } for _, Photo := range Photos { ProjectPhoto := http_model.ShowProjectPhoto{ PhotoUrl: Photo.PhotoUrl, PhotoUid: Photo.PhotoUid, } ProjectDetail.ProjectPhotos = append(ProjectDetail.ProjectPhotos, ProjectPhoto) } return &ProjectDetail, nil } func (*project) ApproveProject(ctx *gin.Context, data http_model.ApproveProjectRequest) (error, string) { //fmt.Println("data.IsApprove:", data.IsApprove) err, message := db.ApproveProject(ctx, data.ProjectId, data.IsApprove) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err) return err, "" } return nil, message } func (*project) GetAllProject(ctx context.Context, pageSize, pageNum int32) (*http_model.GetAllProjectData, error) { allProjectPreviews, total, err := db.GetAllProject(ctx, pageSize, pageNum) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetAllProject error,err:%+v", err) return nil, err } allProjects := new(http_model.GetAllProjectData) allProjects.AllProjectPreview = pack.MGormAllProjectToHttpAllProjectPreview(allProjectPreviews) allProjects.Total = conv.MustString(total, "") return allProjects, nil } func (*project) GetProjectTaskList(ctx context.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TaskConditions) (*http_model.ProjectTaskListData, error) { projectTasks, total, err := db.GetProjectTaskList(ctx, projectID, pageSize, pageNum, conditions) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetProjectTaskList error,err:%+v", err) return nil, err } projectTaskListData := new(http_model.ProjectTaskListData) projectTaskListData.ProjectTaskPreview = pack.MGormProjectTaskToHttpProjectTaskPreview(projectTasks) projectTaskListData.Total = conv.MustString(total, "") return projectTaskListData, nil } func (*project) Create(ctx context.Context, newProject http_model.CreateProjectRequest, enterpriseID int64) (*http_model.CreateProjectData, error) { RecruitDdl, _ := time.ParseInLocation("2006-01-02 15:04:05", newProject.RecruitDdl, time.Local) // 查询关联商品信息 product, err := db.GetProductByID(ctx, newProject.ProductID) if err != nil { return nil, err } // 按照品牌名-商品名对项目进行命名 projectName := product.BrandName + "-" + product.ProductName //feeForm := fmt.Sprintf("[") feeFrom := []string{} for _, strategy := range newProject.RecruitStrategys { feeFrom = append(feeFrom, strconv.FormatInt(strategy.FeeForm, 10)) } var ECost float64 = 0 if newProject.ProjectType == int64(1) { for _, strategy := range newProject.RecruitStrategys { // 计算预估成本 var tmpCost float64 = 0 if strategy.FeeForm == 1 { tmpCost = strategy.ServiceCharge * float64(strategy.RecruitNumber) } else if strategy.FeeForm == 2 { tmpCost = strategy.Offer * float64(strategy.RecruitNumber) } ECost += tmpCost } } feeFroms := strings.Join(feeFrom, ",") projectInfo := gorm_model.ProjectInfo{ ProjectName: projectName, ProjectStatus: 1, ProjectType: newProject.ProjectType, TalentType: newProject.TalentType, ProjectPlatform: newProject.ProjectPlatform, ProjectForm: newProject.ProjectForm, RecruitDdl: &RecruitDdl, ProjectDetail: newProject.ProjectDetail, ContentType: newProject.ContentType, EnterpriseID: enterpriseID, ProductID: newProject.ProductID, FeeForm: feeFroms, EstimatedCost: ECost, IsRead: 0, } // db create ProjectInfo projectID, err := db.CreateProject(ctx, projectInfo) if err != nil { return nil, err } if len(newProject.ProjectPhotos) != 0 { // build []gorm_model.ProjectPhoto projectPhotos := []gorm_model.ProjectPhoto{} for _, photo := range newProject.ProjectPhotos { projectPhoto := gorm_model.ProjectPhoto{ PhotoUrl: photo.PhotoUrl, PhotoUid: photo.PhotoUid, ProjectID: *projectID, } projectPhotos = append(projectPhotos, projectPhoto) } // db create ProjectPhoto err = db.CreateProjectPhoto(ctx, projectPhotos) if err != nil { return nil, err } } // build recruitStrategys := []gorm_model.RecruitStrategy{} for _, strategy := range newProject.RecruitStrategys { // 查询对应定价策略 pricingStrategy, err := db.GetPricingStrategy(ctx, strategy.FollowersLow, strategy.FollowersUp, strategy.FeeForm, newProject.ProjectPlatform) if err != nil { return nil, err } // 根据定价策略计算达人所见报价 if strategy.FeeForm == 2 { strategy.TOffer = strategy.Offer * (1 - conv.MustFloat64(pricingStrategy.ServiceRate, 0)/1000) } recruitStrategy := gorm_model.RecruitStrategy{ FeeForm: strategy.FeeForm, StrategyID: strategy.StrategyID, FollowersLow: strategy.FollowersLow, FollowersUp: strategy.FollowersUp, RecruitNumber: strategy.RecruitNumber, Offer: strategy.Offer, TOffer: strategy.TOffer, ProjectID: *projectID, } recruitStrategys = append(recruitStrategys, recruitStrategy) } err = db.CreateRecruitStrategy(ctx, recruitStrategys) if err != nil { return nil, err } res := &http_model.CreateProjectData{ ProjectID: *projectID, } fmt.Printf("%+v", res) return res, nil } func (*project) Update(ctx context.Context, newProject http_model.UpdateProjectRequest, enterpriseID int64) (*http_model.UpdateProjectData, error) { //fmt.Println("newproject:", newProject) RecruitDdl, _ := time.ParseInLocation("2006-01-02 15:04:05", newProject.RecruitDdl, time.Local) oldProject, err3 := db.GetProjectDetail(ctx, conv.MustInt64(newProject.ProjectID, 0)) if err3 != nil { return nil, err3 } feeFrom := []string{} for _, strategy := range newProject.RecruitStrategys { //if strategy.StrategyID feeFrom = append(feeFrom, strconv.FormatInt(strategy.FeeForm, 10)) //feeForm += string(strategy.StrategyID) } var ECost float64 = 0 if newProject.ProjectType == int64(1) { for _, strategy := range newProject.RecruitStrategys { // 计算预估成本 var tmpCost float64 = 0 if strategy.FeeForm == 1 { tmpCost = strategy.ServiceCharge * float64(strategy.RecruitNumber) } else if strategy.FeeForm == 2 { tmpCost = strategy.Offer * float64(strategy.RecruitNumber) } ECost += tmpCost } } feeFroms := strings.Join(feeFrom, ",") project := gorm_model.ProjectInfo{ ProjectID: conv.MustInt64(newProject.ProjectID, 0), RecruitDdl: &RecruitDdl, TalentType: newProject.TalentType, ContentType: conv.MustInt64(newProject.ContentType, 0), ProjectDetail: newProject.ProjectDetail, ProjectForm: conv.MustInt64(newProject.ProjectForm, 0), EnterpriseID: enterpriseID, ProjectStatus: int64(newProject.ProjectStatus), FeeForm: feeFroms, EstimatedCost: ECost, } projectID, err := db.UpdateProject(ctx, project) if err != nil { return nil, err } // 删除该项目之前的所有图片 err = db.DeleteProjectPhotoByProjecttID(ctx, *projectID) if err != nil { return nil, err } fmt.Printf("照片:\t %+v", newProject.ProjectPhotos) if len(newProject.ProjectPhotos) != 0 { // 新增图片 projectPhotos := []gorm_model.ProjectPhoto{} for _, photo := range newProject.ProjectPhotos { projectPhoto := gorm_model.ProjectPhoto{ ProjectID: project.ProjectID, PhotoUrl: photo.PhotoUrl, PhotoUid: photo.PhotoUid, } projectPhotos = append(projectPhotos, projectPhoto) } err = db.CreateProjectPhoto(ctx, projectPhotos) if err != nil { return nil, err } } // 删除该项目之前的所有策略 err = db.DeleteRecruitStrategyByProjectID(ctx, *projectID) if err != nil { return nil, err } //fmt.Printf("策略:\t %+v", newProject.RecruitStrategys) if newProject.RecruitStrategys != nil { // 新增策略 RecruitStrategys := []gorm_model.RecruitStrategy{} for _, Strategy := range newProject.RecruitStrategys { // 查询对应定价策略 pricingStrategy, err := db.GetPricingStrategy(ctx, Strategy.FollowersLow, Strategy.FollowersUp, Strategy.FeeForm, oldProject.ProjectPlatform) if err != nil { return nil, err } // 根据定价策略计算达人所见报价 if Strategy.FeeForm == 2 { Strategy.TOffer = Strategy.Offer * (1 - conv.MustFloat64(pricingStrategy.ServiceRate, 0)/1000) } RecruitStrategy := gorm_model.RecruitStrategy{ FeeForm: conv.MustInt64(Strategy.FeeForm, 0), StrategyID: conv.MustInt64(Strategy.StrategyID, 0), FollowersLow: conv.MustInt64(Strategy.FollowersLow, 0), FollowersUp: conv.MustInt64(Strategy.FollowersUp, 0), RecruitNumber: conv.MustInt64(Strategy.RecruitNumber, 0), Offer: conv.MustFloat64(Strategy.Offer, 0), TOffer: conv.MustFloat64(Strategy.TOffer, 0), ProjectID: project.ProjectID, } fmt.Printf("Offer:\t %+v", Strategy.Offer) RecruitStrategys = append(RecruitStrategys, RecruitStrategy) } err = db.CreateRecruitStrategy(ctx, RecruitStrategys) if err != nil { return nil, err } } res := &http_model.UpdateProjectData{ ProjectID: *projectID, } return res, nil } func (*project) GetPorjectDetail(ctx context.Context, projectID int64) (*http_model.ShowProjectData, error) { project, err := db.GetProjectDetail(ctx, projectID) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetPorjectDetail error,err:%+v", err) return nil, err } enterprise, err := db.GetEnterpriseByEnterpriseID(ctx, project.EnterpriseID) // fmt.Println("%+v", enterprise.UserID) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetEnterpriseByEnterpriseID error,err:%+v", err) return nil, err } user, err := db.GetUserByID(ctx, enterprise.UserID) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetUserByID error,err:%+v", err) return nil, err } // fmt.Println("%+v", user.Phone) //var RecruitStrategys []http_model.ShowRecruitStrategy ProjectDetail := http_model.ShowProjectData{ ProjectID: conv.MustString(project.ProjectID, ""), ProjectName: conv.MustString(project.ProjectName, ""), ProjectStatus: conv.MustString(project.ProjectStatus, ""), ProjectType: conv.MustString(project.ProjectType, ""), ProjectPlatform: conv.MustString(project.ProjectPlatform, ""), ProjectForm: conv.MustString(project.ProjectForm, ""), TalentType: conv.MustString(project.TalentType, ""), RecruitDdl: util.GetTimePointer(project.RecruitDdl), ContentType: conv.MustString(project.ContentType, ""), ProjectDetail: conv.MustString(project.ProjectDetail, ""), ProductID: conv.MustString(project.ProductID, ""), EnterpriseID: conv.MustString(project.EnterpriseID, ""), Balance: conv.MustString(enterprise.Balance, ""), FailReason: conv.MustString(project.FailReason, ""), CreateAt: util.GetTimePointer(project.CreatedAt), UpdateAt: util.GetTimePointer(project.UpdatedAt), Phone: user.Phone, FinishAt: util.GetTimePointer(project.FinishAt), PassAt: util.GetTimePointer(project.PassAt), PayAt: util.GetTimePointer(project.PayAt), } Strategys, err := db.GetRecruitStrategys(ctx, projectID) fmt.Println("招募策略:", Strategys) if err != nil { logrus.WithContext(ctx).Error() return nil, err } for _, strategy := range Strategys { RecruitStrategy := http_model.ShowRecruitStrategy{ RecruitStrategyID: conv.MustString(strategy.RecruitStrategyID, ""), FeeForm: conv.MustString(strategy.FeeForm, ""), StrategyID: conv.MustString(strategy.StrategyID, ""), FollowersLow: conv.MustString(strategy.FollowersLow, ""), FollowersUp: conv.MustString(strategy.FollowersUp, ""), RecruitNumber: conv.MustString(strategy.RecruitNumber, ""), Offer: conv.MustString(strategy.Offer, ""), ServiceCharge: conv.MustString(strategy.ServiceCharge, ""), SelectedNumber: strategy.SelectedNumber, WaitingNumber: strategy.WaitingNumber, DeliveredNumber: strategy.DeliveredNumber, SignedNumber: strategy.SignedNumber, } ProjectDetail.RecruitStrategys = append(ProjectDetail.RecruitStrategys, RecruitStrategy) } Photos, err := db.GetProjectPhoto(ctx, projectID) if err != nil { logrus.WithContext(ctx).Error() return nil, err } for _, Photo := range Photos { ProjectPhoto := http_model.ShowProjectPhoto{ PhotoUrl: Photo.PhotoUrl, PhotoUid: Photo.PhotoUid, } ProjectDetail.ProjectPhotos = append(ProjectDetail.ProjectPhotos, ProjectPhoto) } return &ProjectDetail, nil } func (*project) GetTaskLogisticsList(ctx context.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskLogisticsListData, error) { TaskLogisticss, total, err := db.GetTaskLogisticsList(ctx, projectID, pageSize, pageNum, conditions) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetTaskLogisticsList error,err:%+v", err) return nil, err } TaskLogisticsListData := new(http_model.TaskLogisticsListData) TaskLogisticsListData.TaskLogisticsPreview = pack.MGormTaskLogisticsInfoListToHttpTaskLogisticsPreviewList(TaskLogisticss) TaskLogisticsListData.Total = conv.MustString(total, "") return TaskLogisticsListData, nil } func (*project) ChangeTaskStatus(ctx *gin.Context, data http_model.ProjectChangeTaskStatusRequest) interface{} { RecruitStrategyIDs, err := db.ChangeTaskStatus(ctx, data.TaskIds, data.TaskStatus) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err) return err } if data.TaskStatus == "2" { err = db.CalculateSelectedNumberByRecruitStrategyID(ctx, RecruitStrategyIDs, 1) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err) return err } } else { err = db.CalculateSelectedNumberByRecruitStrategyID(ctx, RecruitStrategyIDs, -1) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err) return err } } return nil } func (p *project) GetTaskScriptList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskScriptListData, error) { TaskScripts, total, err := db.GetTaskScriptList(ctx, projectID, pageSize, pageNum, conditions) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetTaskScriptList error,err:%+v", err) return nil, err } TaskScriptListData := new(http_model.TaskScriptListData) TaskScriptListData.TaskScriptPreview = pack.MGormTaskScriptInfoListToHttpTaskScriptPreviewList(TaskScripts) TaskScriptListData.Total = conv.MustString(total, "") return TaskScriptListData, nil } func (p *project) GetTaskSketchList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskSketchListData, error) { TaskSketchs, total, err := db.GetTaskSketchList(ctx, projectID, pageSize, pageNum, conditions) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetTaskSketchList error,err:%+v", err) return nil, err } TaskSketchListData := new(http_model.TaskSketchListData) TaskSketchListData.TaskSketchPreview = pack.MGormTaskSketchInfoListToHttpTaskSketchPreviewList(TaskSketchs) TaskSketchListData.Total = conv.MustString(total, "") return TaskSketchListData, nil } func (p *project) GetTaskLinkList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskLinkListData, error) { TaskLinks, total, err := db.GetTaskLinkList(ctx, projectID, pageSize, pageNum, conditions) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetTaskLinkList error,err:%+v", err) return nil, err } TaskLinkListData := new(http_model.TaskLinkListData) TaskLinkListData.TaskLinkPreview = pack.MGormTaskLinkInfoListToHttpTaskLinkPreviewList(TaskLinks) TaskLinkListData.Total = conv.MustString(total, "") return TaskLinkListData, nil } func (p *project) GetTaskDataList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskDataListData, error) { TaskDatas, total, err := db.GetTaskDataList(ctx, projectID, pageSize, pageNum, conditions) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetTaskDataList error,err:%+v", err) return nil, err } TaskDataListData := new(http_model.TaskDataListData) TaskDataListData.TaskDataPreview = pack.MGormTaskDataInfoListToHttpTaskDataPreviewList(TaskDatas) TaskDataListData.Total = conv.MustString(total, "") return TaskDataListData, nil } func (p *project) GetTaskFinishList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskFinishListData, error) { TaskFinishs, total, err := db.GetTaskFinishList(ctx, projectID, pageSize, pageNum, conditions) if err != nil { logrus.WithContext(ctx).Errorf("[project service] call GetTaskFinishList error,err:%+v", err) return nil, err } TaskFinishListData := new(http_model.TaskFinishListData) TaskFinishListData.TaskFinishPreview = pack.MGormTaskFinishInfoListToHttpTaskFinishPreviewList(TaskFinishs) TaskFinishListData.Total = conv.MustString(total, "") return TaskFinishListData, nil } func (p *project) GetServiceCharge(ctx *gin.Context, data http_model.GetServiceChargeRequest) (*http_model.ServiceChargeData, error) { pricingStrategy, err := db.GetPricingStrategy(ctx, data.FollowersLow, data.FollowersUp, data.FeeForm, data.Platform) if err != nil { return nil, err } serviceFee := http_model.ServiceChargeData{ ServiceCharge: pricingStrategy.ServiceCharge, } return &serviceFee, nil }