project.go 23 KB

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