project.go 25 KB

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