project.go 23 KB

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