project.go 26 KB

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