project.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520
  1. package service
  2. import (
  3. "context"
  4. "fmt"
  5. "strconv"
  6. "strings"
  7. "youngee_b_api/db"
  8. "youngee_b_api/model/common_model"
  9. "youngee_b_api/model/gorm_model"
  10. "youngee_b_api/model/http_model"
  11. "youngee_b_api/pack"
  12. "youngee_b_api/util"
  13. "github.com/gin-gonic/gin"
  14. "github.com/issue9/conv"
  15. "github.com/sirupsen/logrus"
  16. )
  17. var Project *project
  18. type project struct {
  19. }
  20. func (*project) Create(ctx context.Context, newProject http_model.CreateProjectRequest, enterpriseID int64) (*http_model.CreateProjectData, error) {
  21. // build gorm_model.ProjectInfo
  22. // 查询关联商品信息
  23. product, err := db.GetProductByID(ctx, newProject.ProductID)
  24. if err != nil {
  25. return nil, err
  26. }
  27. AutoTaskID, err := db.GetLastAutoTaskID()
  28. if err != nil {
  29. return nil, err
  30. }
  31. AutoDefaultID, err := db.GetLastAutoDefaultID()
  32. if err != nil {
  33. return nil, err
  34. }
  35. // 按照品牌名-商品名对项目进行命名
  36. projectName := product.BrandName + "-" + product.ProductName
  37. //feeForm := fmt.Sprintf("[")
  38. feeFrom := []string{}
  39. for _, strategy := range newProject.RecruitStrategys {
  40. feeFrom = append(feeFrom, strconv.FormatInt(strategy.FeeForm, 10))
  41. }
  42. var ECost float64 = 0
  43. if newProject.ProjectType == int64(1) {
  44. for _, strategy := range newProject.RecruitStrategys {
  45. // 计算预估成本
  46. var tmpCost float64 = 0
  47. if strategy.FeeForm == 1 {
  48. tmpCost = strategy.ServiceCharge * float64(strategy.RecruitNumber)
  49. } else if strategy.FeeForm == 2 {
  50. tmpCost = strategy.Offer * float64(strategy.RecruitNumber)
  51. }
  52. ECost += tmpCost
  53. }
  54. }
  55. feeFroms := strings.Join(feeFrom, ",")
  56. fmt.Printf("创建项目new %+v", newProject)
  57. projectInfo := gorm_model.ProjectInfo{}
  58. if newProject.ProjectType == int64(1) {
  59. projectInfo = gorm_model.ProjectInfo{
  60. ProjectName: projectName,
  61. ProjectStatus: 1,
  62. ProjectType: newProject.ProjectType,
  63. TalentType: newProject.TalentType,
  64. ProjectPlatform: newProject.ProjectPlatform,
  65. ProjectForm: newProject.ProjectForm,
  66. RecruitDdl: &newProject.RecruitDdl,
  67. ProjectDetail: newProject.ProjectDetail,
  68. ContentType: newProject.ContentType,
  69. EnterpriseID: enterpriseID,
  70. ProductID: newProject.ProductID,
  71. FeeForm: feeFroms,
  72. AutoTaskID: conv.MustInt64(AutoTaskID),
  73. AutoDefaultID: conv.MustInt64(AutoDefaultID),
  74. EstimatedCost: ECost,
  75. }
  76. } else {
  77. projectInfo = gorm_model.ProjectInfo{
  78. ProjectName: projectName,
  79. ProjectStatus: 1,
  80. ProjectType: newProject.ProjectType,
  81. TalentType: "[]",
  82. ProjectPlatform: newProject.ProjectPlatform,
  83. ProjectForm: newProject.ProjectForm,
  84. ProjectDetail: newProject.ProjectDetail,
  85. ContentType: newProject.ContentType,
  86. EnterpriseID: enterpriseID,
  87. ProductID: newProject.ProductID,
  88. FeeForm: feeFroms,
  89. AutoTaskID: conv.MustInt64(AutoTaskID),
  90. AutoDefaultID: conv.MustInt64(AutoDefaultID),
  91. EstimatedCost: ECost,
  92. }
  93. }
  94. // db create ProjectInfo
  95. projectID, err := db.CreateProject(ctx, projectInfo)
  96. if err != nil {
  97. return nil, err
  98. }
  99. if len(newProject.ProjectPhotos) != 0 {
  100. // build []gorm_model.ProjectPhoto
  101. projectPhotos := []gorm_model.ProjectPhoto{}
  102. for _, photo := range newProject.ProjectPhotos {
  103. projectPhoto := gorm_model.ProjectPhoto{
  104. PhotoUrl: photo.PhotoUrl,
  105. PhotoUid: photo.PhotoUid,
  106. ProjectID: *projectID,
  107. }
  108. projectPhotos = append(projectPhotos, projectPhoto)
  109. }
  110. // db create ProjectPhoto
  111. err = db.CreateProjectPhoto(ctx, projectPhotos)
  112. if err != nil {
  113. return nil, err
  114. }
  115. }
  116. // build
  117. if newProject.ProjectType == int64(1) {
  118. recruitStrategys := []gorm_model.RecruitStrategy{}
  119. for _, strategy := range newProject.RecruitStrategys {
  120. // 查询对应定价策略
  121. pricingStrategy, err := db.GetPricingStrategy(ctx, strategy.FollowersLow, strategy.FollowersUp, strategy.FeeForm, newProject.ProjectPlatform)
  122. if err != nil {
  123. return nil, err
  124. }
  125. // 根据定价策略计算达人所见报价
  126. if strategy.FeeForm == 2 {
  127. strategy.TOffer = strategy.Offer * (1 - conv.MustFloat64(pricingStrategy.ServiceRate)/1000)
  128. }
  129. recruitStrategy := gorm_model.RecruitStrategy{
  130. FeeForm: strategy.FeeForm,
  131. StrategyID: strategy.StrategyID,
  132. FollowersLow: strategy.FollowersLow,
  133. FollowersUp: strategy.FollowersUp,
  134. RecruitNumber: strategy.RecruitNumber,
  135. ServiceCharge: strategy.ServiceCharge,
  136. Offer: strategy.Offer,
  137. TOffer: strategy.TOffer,
  138. ProjectID: *projectID,
  139. }
  140. recruitStrategys = append(recruitStrategys, recruitStrategy)
  141. }
  142. err = db.CreateRecruitStrategy(ctx, recruitStrategys)
  143. if err != nil {
  144. return nil, err
  145. }
  146. }
  147. res := &http_model.CreateProjectData{
  148. ProjectID: *projectID,
  149. }
  150. fmt.Printf("%+v", res)
  151. return res, nil
  152. }
  153. func (*project) Update(ctx context.Context, newProject http_model.UpdateProjectRequest, enterpriseID int64) (*http_model.UpdateProjectData, error) {
  154. fmt.Println("newproject:", newProject)
  155. oldProject, err3 := db.GetProjectDetail(ctx, conv.MustInt64(newProject.ProjectID))
  156. if err3 != nil {
  157. return nil, err3
  158. }
  159. feeFrom := []string{}
  160. for _, strategy := range newProject.RecruitStrategys {
  161. //if strategy.StrategyID
  162. feeFrom = append(feeFrom, strconv.FormatInt(strategy.FeeForm, 10))
  163. //feeForm += string(strategy.StrategyID)
  164. }
  165. var ECost float64 = 0
  166. if newProject.ProjectType == int64(1) {
  167. for _, strategy := range newProject.RecruitStrategys {
  168. // 计算预估成本
  169. var tmpCost float64 = 0
  170. if strategy.FeeForm == 1 {
  171. tmpCost = strategy.ServiceCharge * float64(strategy.RecruitNumber)
  172. } else if strategy.FeeForm == 2 {
  173. tmpCost = strategy.Offer * float64(strategy.RecruitNumber)
  174. }
  175. ECost += tmpCost
  176. }
  177. }
  178. feeFroms := strings.Join(feeFrom, ",")
  179. project := gorm_model.ProjectInfo{
  180. ProjectID: conv.MustInt64(newProject.ProjectID),
  181. RecruitDdl: &newProject.RecruitDdl,
  182. TalentType: newProject.TalentType,
  183. ContentType: conv.MustInt64(newProject.ContentType),
  184. ProjectDetail: newProject.ProjectDetail,
  185. ProjectForm: conv.MustInt64(newProject.ProjectForm),
  186. EnterpriseID: enterpriseID,
  187. ProjectStatus: conv.MustInt64(newProject.ProjectStatus),
  188. FeeForm: feeFroms,
  189. EstimatedCost: ECost,
  190. }
  191. projectID, err := db.UpdateProject(ctx, project)
  192. if err != nil {
  193. return nil, err
  194. }
  195. // 删除该项目之前的所有图片
  196. err = db.DeleteProjectPhotoByProjecttID(ctx, *projectID)
  197. if err != nil {
  198. return nil, err
  199. }
  200. fmt.Printf("照片:\t %+v", newProject.ProjectPhotos)
  201. if len(newProject.ProjectPhotos) != 0 {
  202. // 新增图片
  203. projectPhotos := []gorm_model.ProjectPhoto{}
  204. for _, photo := range newProject.ProjectPhotos {
  205. projectPhoto := gorm_model.ProjectPhoto{
  206. ProjectID: project.ProjectID,
  207. PhotoUrl: photo.PhotoUrl,
  208. PhotoUid: photo.PhotoUid,
  209. }
  210. projectPhotos = append(projectPhotos, projectPhoto)
  211. }
  212. err = db.CreateProjectPhoto(ctx, projectPhotos)
  213. if err != nil {
  214. return nil, err
  215. }
  216. }
  217. // 删除该项目之前的所有策略
  218. err = db.DeleteRecruitStrategyByProjectID(ctx, *projectID)
  219. if err != nil {
  220. return nil, err
  221. }
  222. //fmt.Printf("策略:\t %+v", newProject.RecruitStrategys)
  223. if newProject.RecruitStrategys != nil {
  224. // 新增策略
  225. RecruitStrategys := []gorm_model.RecruitStrategy{}
  226. for _, Strategy := range newProject.RecruitStrategys {
  227. // 查询对应定价策略
  228. pricingStrategy, err := db.GetPricingStrategy(ctx, Strategy.FollowersLow, Strategy.FollowersUp, Strategy.FeeForm, oldProject.ProjectPlatform)
  229. if err != nil {
  230. return nil, err
  231. }
  232. // 根据定价策略计算达人所见报价
  233. if Strategy.FeeForm == 2 {
  234. Strategy.TOffer = Strategy.Offer * (1 - conv.MustFloat64(pricingStrategy.ServiceRate)/1000)
  235. }
  236. RecruitStrategy := gorm_model.RecruitStrategy{
  237. FeeForm: conv.MustInt64(Strategy.FeeForm),
  238. StrategyID: conv.MustInt64(Strategy.StrategyID),
  239. FollowersLow: conv.MustInt64(Strategy.FollowersLow),
  240. FollowersUp: conv.MustInt64(Strategy.FollowersUp),
  241. RecruitNumber: conv.MustInt64(Strategy.RecruitNumber),
  242. ServiceCharge: Strategy.ServiceCharge,
  243. Offer: Strategy.Offer,
  244. TOffer: Strategy.TOffer,
  245. ProjectID: project.ProjectID,
  246. }
  247. fmt.Printf("Offer:\t %+v", Strategy.Offer)
  248. RecruitStrategys = append(RecruitStrategys, RecruitStrategy)
  249. }
  250. err = db.CreateRecruitStrategy(ctx, RecruitStrategys)
  251. if err != nil {
  252. return nil, err
  253. }
  254. }
  255. res := &http_model.UpdateProjectData{
  256. ProjectID: *projectID,
  257. }
  258. return res, nil
  259. }
  260. func (*project) Delete(ctx context.Context, projectID int64) (*http_model.DeleteProjectData, error) {
  261. // 删除该项目之前的所有图片
  262. err := db.DeleteProjectPhotoByProjecttID(ctx, projectID)
  263. if err != nil {
  264. return nil, err
  265. }
  266. // 删除该项目之前的所有策略
  267. err = db.DeleteRecruitStrategyByProjectID(ctx, projectID)
  268. if err != nil {
  269. return nil, err
  270. }
  271. //删除项目
  272. NewProjectID, err1 := db.DeleteProject(ctx, projectID)
  273. if err1 != nil {
  274. return nil, err1
  275. }
  276. res := &http_model.DeleteProjectData{
  277. ProjectID: *NewProjectID,
  278. }
  279. return res, nil
  280. }
  281. func (*project) GetFullProjectList(ctx context.Context, enterpriseID int64, pageSize, pageNum int32, condition *common_model.ProjectCondition) (*http_model.FullProjectListData, error) {
  282. fullProjects, total, err := db.GetFullProjectList(ctx, enterpriseID, pageSize, pageNum, condition)
  283. if err != nil {
  284. logrus.WithContext(ctx).Errorf("[project service] call GetFullProjectList error,err:%+v", err)
  285. return nil, err
  286. }
  287. fullProjectListData := new(http_model.FullProjectListData)
  288. fullProjectListData.FullProjectPreview = pack.MGormFullProjectToHttpFullProjectPreview(fullProjects)
  289. fullProjectListData.Total = conv.MustString(total)
  290. return fullProjectListData, nil
  291. }
  292. func (*project) GetProjectDraftList(ctx context.Context, enterpriseID int64, pageSize, pageNum int32, condition *common_model.ProjectCondition) (*http_model.ProjectDraftListData, error) {
  293. ProjectDrafts, total, err := db.GetProjectDraftList(ctx, enterpriseID, pageSize, pageNum, condition)
  294. if err != nil {
  295. logrus.WithContext(ctx).Errorf("[project service] call GetProjectDraftList error,err:%+v", err)
  296. return nil, err
  297. }
  298. ProjectDraftListData := new(http_model.ProjectDraftListData)
  299. ProjectDraftListData.ProjectDraftPreview = pack.MGormProjectDraftToHttpProjectDraftPreview(ProjectDrafts)
  300. ProjectDraftListData.Total = conv.MustString(total)
  301. return ProjectDraftListData, nil
  302. }
  303. func (*project) GetProjectTaskList(ctx context.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TaskConditions) (*http_model.ProjectTaskListData, error) {
  304. projectTasks, total, err := db.GetProjectTaskList(ctx, projectID, pageSize, pageNum, conditions)
  305. if err != nil {
  306. logrus.WithContext(ctx).Errorf("[project service] call GetProjectTaskList error,err:%+v", err)
  307. return nil, err
  308. }
  309. projectTaskListData := new(http_model.ProjectTaskListData)
  310. projectTaskListData.ProjectTaskPreview = pack.MGormProjectTaskToHttpProjectTaskPreview(projectTasks)
  311. projectTaskListData.Total = conv.MustString(total)
  312. return projectTaskListData, nil
  313. }
  314. func (*project) GetPorjectDetail(ctx context.Context, projectID int64) (*http_model.ShowProjectData, error) {
  315. project, err := db.GetProjectDetail(ctx, projectID)
  316. if err != nil {
  317. logrus.WithContext(ctx).Errorf("[project service] call GetPorjectDetail error,err:%+v", err)
  318. return nil, err
  319. }
  320. enterprise, err := db.GetEnterpriseByEnterpriseID(ctx, project.EnterpriseID)
  321. // fmt.Println("%+v", enterprise.UserID)
  322. if err != nil {
  323. logrus.WithContext(ctx).Errorf("[project service] call GetEnterpriseByEnterpriseID error,err:%+v", err)
  324. return nil, err
  325. }
  326. user, err := db.GetUserByID(ctx, enterprise.UserID)
  327. if err != nil {
  328. logrus.WithContext(ctx).Errorf("[project service] call GetUserByID error,err:%+v", err)
  329. return nil, err
  330. }
  331. // fmt.Println("%+v", user.Phone)
  332. //var RecruitStrategys []http_model.ShowRecruitStrategy
  333. ProjectDetail := http_model.ShowProjectData{
  334. ProjectID: conv.MustString(project.ProjectID),
  335. ProjectName: conv.MustString(project.ProjectName),
  336. ProjectStatus: conv.MustString(project.ProjectStatus),
  337. ProjectType: conv.MustString(project.ProjectType),
  338. ProjectPlatform: conv.MustString(project.ProjectPlatform),
  339. ProjectForm: conv.MustString(project.ProjectForm),
  340. TalentType: conv.MustString(project.TalentType),
  341. RecruitDdl: util.GetTimePoionter(project.RecruitDdl),
  342. ContentType: conv.MustString(project.ContentType),
  343. ProjectDetail: conv.MustString(project.ProjectDetail),
  344. ProductID: conv.MustString(project.ProductID),
  345. EnterpriseID: conv.MustString(project.EnterpriseID),
  346. Balance: conv.MustString(enterprise.Balance),
  347. EstimatedCost: conv.MustString(project.EstimatedCost),
  348. FailReason: conv.MustString(project.FailReason),
  349. CreateAt: util.GetTimePoionter(project.CreatedAt),
  350. UpdateAt: util.GetTimePoionter(project.UpdatedAt),
  351. Phone: user.Phone,
  352. FinishAt: util.GetTimePoionter(project.FinishAt),
  353. PassAt: util.GetTimePoionter(project.PassAt),
  354. PayAt: util.GetTimePoionter(project.PayAt),
  355. }
  356. Strategys, err := db.GetRecruitStrategys(ctx, projectID)
  357. fmt.Println("招募策略:", Strategys)
  358. if err != nil {
  359. logrus.WithContext(ctx).Error()
  360. return nil, err
  361. }
  362. for _, strategy := range Strategys {
  363. RecruitStrategy := http_model.ShowRecruitStrategy{
  364. RecruitStrategyID: conv.MustString(strategy.RecruitStrategyID),
  365. FeeForm: conv.MustString(strategy.FeeForm),
  366. StrategyID: conv.MustString(strategy.StrategyID),
  367. FollowersLow: conv.MustString(strategy.FollowersLow),
  368. FollowersUp: conv.MustString(strategy.FollowersUp),
  369. RecruitNumber: conv.MustString(strategy.RecruitNumber),
  370. Offer: conv.MustString(strategy.Offer),
  371. ServiceCharge: conv.MustString(strategy.ServiceCharge),
  372. SelectedNumber: strategy.SelectedNumber,
  373. WaitingNumber: strategy.WaitingNumber,
  374. DeliveredNumber: strategy.DeliveredNumber,
  375. SignedNumber: strategy.SignedNumber,
  376. }
  377. ProjectDetail.RecruitStrategys = append(ProjectDetail.RecruitStrategys, RecruitStrategy)
  378. }
  379. Photos, err := db.GetProjectPhoto(ctx, projectID)
  380. if err != nil {
  381. logrus.WithContext(ctx).Error()
  382. return nil, err
  383. }
  384. for _, Photo := range Photos {
  385. ProjectPhoto := http_model.ShowProjectPhoto{
  386. PhotoUrl: Photo.PhotoUrl,
  387. PhotoUid: Photo.PhotoUid,
  388. }
  389. ProjectDetail.ProjectPhotos = append(ProjectDetail.ProjectPhotos, ProjectPhoto)
  390. }
  391. return &ProjectDetail, nil
  392. }
  393. func (*project) GetTaskLogisticsList(ctx context.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskLogisticsListData, error) {
  394. TaskLogisticss, total, err := db.GetTaskLogisticsList(ctx, projectID, pageSize, pageNum, conditions)
  395. if err != nil {
  396. logrus.WithContext(ctx).Errorf("[project service] call GetTaskLogisticsList error,err:%+v", err)
  397. return nil, err
  398. }
  399. TaskLogisticsListData := new(http_model.TaskLogisticsListData)
  400. TaskLogisticsListData.TaskLogisticsPreview = pack.MGormTaskLogisticsInfoListToHttpTaskLogisticsPreviewList(TaskLogisticss)
  401. TaskLogisticsListData.Total = conv.MustString(total)
  402. return TaskLogisticsListData, nil
  403. }
  404. func (*project) ChangeTaskStatus(ctx *gin.Context, data http_model.ProjectChangeTaskStatusRequest) interface{} {
  405. RecruitStrategyIDs, err := db.ChangeTaskStatus(ctx, data.TaskIds, data.TaskStatus)
  406. if err != nil {
  407. logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err)
  408. return err
  409. }
  410. if data.TaskStatus == "2" {
  411. err = db.CalculateSelectedNumberByRecruitStrategyID(ctx, RecruitStrategyIDs, 1)
  412. if err != nil {
  413. logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err)
  414. return err
  415. }
  416. } else {
  417. err = db.CalculateSelectedNumberByRecruitStrategyID(ctx, RecruitStrategyIDs, -1)
  418. if err != nil {
  419. logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err)
  420. return err
  421. }
  422. }
  423. return nil
  424. }
  425. func (*project) ChangeSpecialTaskStatus(ctx *gin.Context, data http_model.ProjectChangeTaskStatusRequest) interface{} {
  426. err := db.ChangeSpecialTaskStatus(ctx, data.TaskIds, data.TaskStatus, data.TaskStage)
  427. if err != nil {
  428. logrus.WithContext(ctx).Errorf("[project service] call ChangeSpecialTaskStatus error,err:%+v", err)
  429. return err
  430. }
  431. return nil
  432. }
  433. func (p *project) GetTaskScriptList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskScriptListData, error) {
  434. TaskScripts, total, err := db.GetTaskScriptList(ctx, projectID, pageSize, pageNum, conditions)
  435. if err != nil {
  436. logrus.WithContext(ctx).Errorf("[project service] call GetTaskScriptList error,err:%+v", err)
  437. return nil, err
  438. }
  439. TaskScriptListData := new(http_model.TaskScriptListData)
  440. TaskScriptListData.TaskScriptPreview = pack.MGormTaskScriptInfoListToHttpTaskScriptPreviewList(TaskScripts)
  441. TaskScriptListData.Total = conv.MustString(total)
  442. return TaskScriptListData, nil
  443. }
  444. func (p *project) GetTaskSketchList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskSketchListData, error) {
  445. TaskSketchs, total, err := db.GetTaskSketchList(ctx, projectID, pageSize, pageNum, conditions)
  446. if err != nil {
  447. logrus.WithContext(ctx).Errorf("[project service] call GetTaskSketchList error,err:%+v", err)
  448. return nil, err
  449. }
  450. TaskSketchListData := new(http_model.TaskSketchListData)
  451. TaskSketchListData.TaskSketchPreview = pack.MGormTaskSketchInfoListToHttpTaskSketchPreviewList(TaskSketchs)
  452. TaskSketchListData.Total = conv.MustString(total)
  453. return TaskSketchListData, nil
  454. }
  455. func (p *project) GetTaskLinkList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskLinkListData, error) {
  456. TaskLinks, total, err := db.GetTaskLinkList(ctx, projectID, pageSize, pageNum, conditions)
  457. if err != nil {
  458. logrus.WithContext(ctx).Errorf("[project service] call GetTaskLinkList error,err:%+v", err)
  459. return nil, err
  460. }
  461. TaskLinkListData := new(http_model.TaskLinkListData)
  462. TaskLinkListData.TaskLinkPreview = pack.MGormTaskLinkInfoListToHttpTaskLinkPreviewList(TaskLinks)
  463. TaskLinkListData.Total = conv.MustString(total)
  464. return TaskLinkListData, nil
  465. }
  466. func (p *project) GetTaskDataList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskDataListData, error) {
  467. TaskDatas, total, err := db.GetTaskDataList(ctx, projectID, pageSize, pageNum, conditions)
  468. if err != nil {
  469. logrus.WithContext(ctx).Errorf("[project service] call GetTaskDataList error,err:%+v", err)
  470. return nil, err
  471. }
  472. TaskDataListData := new(http_model.TaskDataListData)
  473. TaskDataListData.TaskDataPreview = pack.MGormTaskDataInfoListToHttpTaskDataPreviewList(TaskDatas)
  474. TaskDataListData.Total = conv.MustString(total)
  475. return TaskDataListData, nil
  476. }
  477. func (p *project) GetTaskFinishList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskFinishListData, error) {
  478. TaskFinishs, total, err := db.GetTaskFinishList(ctx, pageSize, pageNum, conditions)
  479. if err != nil {
  480. logrus.WithContext(ctx).Errorf("[project service] call GetTaskFinishList error,err:%+v", err)
  481. return nil, err
  482. }
  483. TaskFinishListData := new(http_model.TaskFinishListData)
  484. TaskFinishListData.TaskFinishPreview = pack.MGormTaskFinishInfoListToHttpTaskFinishPreviewList(TaskFinishs)
  485. TaskFinishListData.Total = conv.MustString(total)
  486. return TaskFinishListData, nil
  487. }
  488. func (p *project) GetServiceCharge(ctx *gin.Context, data http_model.GetServiceChargeRequest) (*http_model.ServiceChargeData, error) {
  489. pricingStrategy, err := db.GetPricingStrategy(ctx, data.FollowersLow, data.FollowersUp, data.FeeForm, data.Platform)
  490. if err != nil {
  491. return nil, err
  492. }
  493. serviceFee := http_model.ServiceChargeData{
  494. ServiceCharge: pricingStrategy.ServiceCharge,
  495. }
  496. return &serviceFee, nil
  497. }