project.go 22 KB

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