project.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653
  1. package service
  2. import (
  3. "context"
  4. "fmt"
  5. "strconv"
  6. "strings"
  7. "youngee_m_api/db"
  8. "youngee_m_api/model/common_model"
  9. "youngee_m_api/model/gorm_model"
  10. "youngee_m_api/model/http_model"
  11. "youngee_m_api/pack"
  12. "youngee_m_api/util"
  13. "github.com/caixw/lib.go/conv"
  14. "github.com/gin-gonic/gin"
  15. "github.com/sirupsen/logrus"
  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. TOffer: strategy.TOffer,
  359. ProjectID: *projectID,
  360. }
  361. recruitStrategys = append(recruitStrategys, recruitStrategy)
  362. }
  363. err = db.CreateRecruitStrategy(ctx, recruitStrategys)
  364. if err != nil {
  365. return nil, err
  366. }
  367. res := &http_model.CreateProjectData{
  368. ProjectID: *projectID,
  369. }
  370. fmt.Printf("%+v", res)
  371. return res, nil
  372. }
  373. func (*project) Update(ctx context.Context, newProject http_model.UpdateProjectRequest, enterpriseID int64) (*http_model.UpdateProjectData, error) {
  374. //fmt.Println("newproject:", newProject)
  375. project := gorm_model.ProjectInfo{
  376. ProjectID: conv.MustInt64(newProject.ProjectID, 0),
  377. RecruitDdl: &newProject.RecruitDdl,
  378. TalentType: newProject.TalentType,
  379. ContentType: conv.MustInt64(newProject.ContentType, 0),
  380. ProjectDetail: newProject.ProjectDetail,
  381. ProjectForm: conv.MustInt64(newProject.ProjectForm, 0),
  382. EnterpriseID: enterpriseID,
  383. ProjectStatus: int64(newProject.ProjectStatus),
  384. }
  385. projectID, err := db.UpdateProject(ctx, project)
  386. if err != nil {
  387. return nil, err
  388. }
  389. // 删除该项目之前的所有图片
  390. err = db.DeleteProjectPhotoByProjecttID(ctx, *projectID)
  391. if err != nil {
  392. return nil, err
  393. }
  394. fmt.Printf("照片:\t %+v", newProject.ProjectPhotos)
  395. if len(newProject.ProjectPhotos) != 0 {
  396. // 新增图片
  397. projectPhotos := []gorm_model.ProjectPhoto{}
  398. for _, photo := range newProject.ProjectPhotos {
  399. projectPhoto := gorm_model.ProjectPhoto{
  400. ProjectID: project.ProjectID,
  401. PhotoUrl: photo.PhotoUrl,
  402. PhotoUid: photo.PhotoUid,
  403. }
  404. projectPhotos = append(projectPhotos, projectPhoto)
  405. }
  406. err = db.CreateProjectPhoto(ctx, projectPhotos)
  407. if err != nil {
  408. return nil, err
  409. }
  410. }
  411. // 删除该项目之前的所有策略
  412. err = db.DeleteRecruitStrategyByProjectID(ctx, *projectID)
  413. if err != nil {
  414. return nil, err
  415. }
  416. //fmt.Printf("策略:\t %+v", newProject.RecruitStrategys)
  417. if newProject.RecruitStrategys != nil {
  418. // 新增策略
  419. RecruitStrategys := []gorm_model.RecruitStrategy{}
  420. for _, Strategy := range newProject.RecruitStrategys {
  421. RecruitStrategy := gorm_model.RecruitStrategy{
  422. FeeForm: conv.MustInt64(Strategy.FeeForm, 0),
  423. StrategyID: conv.MustInt64(Strategy.StrategyID, 0),
  424. FollowersLow: conv.MustInt64(Strategy.FollowersLow, 0),
  425. FollowersUp: conv.MustInt64(Strategy.FollowersUp, 0),
  426. RecruitNumber: conv.MustInt64(Strategy.RecruitNumber, 0),
  427. Offer: conv.MustFloat64(Strategy.Offer, 0),
  428. TOffer: conv.MustFloat64(Strategy.TOffer, 0),
  429. ProjectID: project.ProjectID,
  430. }
  431. fmt.Printf("Offer:\t %+v", Strategy.Offer)
  432. RecruitStrategys = append(RecruitStrategys, RecruitStrategy)
  433. }
  434. err = db.CreateRecruitStrategy(ctx, RecruitStrategys)
  435. if err != nil {
  436. return nil, err
  437. }
  438. }
  439. res := &http_model.UpdateProjectData{
  440. ProjectID: *projectID,
  441. }
  442. return res, nil
  443. }
  444. //func (*project) GetFullProjectList(ctx context.Context, enterpriseID int64, pageSize, pageNum int32, condition *common_model.ProjectCondition) (*http_model.FullProjectListData, error) {
  445. // fullProjects, total, err := db.GetFullProjectList(ctx, enterpriseID, pageSize, pageNum, condition)
  446. // if err != nil {
  447. // logrus.WithContext(ctx).Errorf("[project service] call GetFullProjectList error,err:%+v", err)
  448. // return nil, err
  449. // }
  450. // fullProjectListData := new(http_model.FullProjectListData)
  451. // fullProjectListData.FullProjectPreview = pack.MGormFullProjectToHttpFullProjectPreview(fullProjects)
  452. // fullProjectListData.Total = conv.MustString(total)
  453. // return fullProjectListData, nil
  454. //}
  455. //
  456. //func (*project) GetProjectTaskList(ctx context.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TaskConditions) (*http_model.ProjectTaskListData, error) {
  457. // projectTasks, total, err := db.GetProjectTaskList(ctx, projectID, pageSize, pageNum, conditions)
  458. // if err != nil {
  459. // logrus.WithContext(ctx).Errorf("[project service] call GetProjectTaskList error,err:%+v", err)
  460. // return nil, err
  461. // }
  462. // projectTaskListData := new(http_model.ProjectTaskListData)
  463. // projectTaskListData.ProjectTaskPreview = pack.MGormProjectTaskToHttpProjectTaskPreview(projectTasks)
  464. // projectTaskListData.Total = conv.MustString(total)
  465. // return projectTaskListData, nil
  466. //}
  467. func (*project) GetPorjectDetail(ctx context.Context, projectID int64) (*http_model.ShowProjectData, error) {
  468. project, err := db.GetProjectDetail(ctx, projectID)
  469. if err != nil {
  470. logrus.WithContext(ctx).Errorf("[project service] call GetPorjectDetail error,err:%+v", err)
  471. return nil, err
  472. }
  473. enterprise, err := db.GetEnterpriseByEnterpriseID(ctx, project.EnterpriseID)
  474. // fmt.Println("%+v", enterprise.UserID)
  475. if err != nil {
  476. logrus.WithContext(ctx).Errorf("[project service] call GetEnterpriseByEnterpriseID error,err:%+v", err)
  477. return nil, err
  478. }
  479. user, err := db.GetUserByID(ctx, enterprise.UserID)
  480. if err != nil {
  481. logrus.WithContext(ctx).Errorf("[project service] call GetUserByID error,err:%+v", err)
  482. return nil, err
  483. }
  484. // fmt.Println("%+v", user.Phone)
  485. //var RecruitStrategys []http_model.ShowRecruitStrategy
  486. ProjectDetail := http_model.ShowProjectData{
  487. ProjectID: conv.MustString(project.ProjectID, ""),
  488. ProjectName: conv.MustString(project.ProjectName, ""),
  489. ProjectStatus: conv.MustString(project.ProjectStatus, ""),
  490. ProjectType: conv.MustString(project.ProjectType, ""),
  491. ProjectPlatform: conv.MustString(project.ProjectPlatform, ""),
  492. ProjectForm: conv.MustString(project.ProjectForm, ""),
  493. TalentType: conv.MustString(project.TalentType, ""),
  494. RecruitDdl: util.GetTimePointer(project.RecruitDdl),
  495. ContentType: conv.MustString(project.ContentType, ""),
  496. ProjectDetail: conv.MustString(project.ProjectDetail, ""),
  497. ProductID: conv.MustString(project.ProductID, ""),
  498. EnterpriseID: conv.MustString(project.EnterpriseID, ""),
  499. Balance: conv.MustString(enterprise.Balance, ""),
  500. FailReason: conv.MustString(project.FailReason, ""),
  501. CreateAt: util.GetTimePointer(project.CreatedAt),
  502. UpdateAt: util.GetTimePointer(project.UpdatedAt),
  503. Phone: user.Phone,
  504. FinishAt: util.GetTimePointer(project.FinishAt),
  505. PassAt: util.GetTimePointer(project.PassAt),
  506. PayAt: util.GetTimePointer(project.PayAt),
  507. }
  508. Strategys, err := db.GetRecruitStrategys(ctx, projectID)
  509. fmt.Println("招募策略:", Strategys)
  510. if err != nil {
  511. logrus.WithContext(ctx).Error()
  512. return nil, err
  513. }
  514. for _, strategy := range Strategys {
  515. RecruitStrategy := http_model.ShowRecruitStrategy{
  516. RecruitStrategyID: conv.MustString(strategy.RecruitStrategyID, ""),
  517. FeeForm: conv.MustString(strategy.FeeForm, ""),
  518. StrategyID: conv.MustString(strategy.StrategyID, ""),
  519. FollowersLow: conv.MustString(strategy.FollowersLow, ""),
  520. FollowersUp: conv.MustString(strategy.FollowersUp, ""),
  521. RecruitNumber: conv.MustString(strategy.RecruitNumber, ""),
  522. Offer: conv.MustString(strategy.Offer, ""),
  523. ServiceCharge: strategy.ServiceCharge,
  524. SelectedNumber: strategy.SelectedNumber,
  525. WaitingNumber: strategy.WaitingNumber,
  526. DeliveredNumber: strategy.DeliveredNumber,
  527. SignedNumber: strategy.SignedNumber,
  528. }
  529. ProjectDetail.RecruitStrategys = append(ProjectDetail.RecruitStrategys, RecruitStrategy)
  530. }
  531. Photos, err := db.GetProjectPhoto(ctx, projectID)
  532. if err != nil {
  533. logrus.WithContext(ctx).Error()
  534. return nil, err
  535. }
  536. for _, Photo := range Photos {
  537. ProjectPhoto := http_model.ShowProjectPhoto{
  538. PhotoUrl: Photo.PhotoUrl,
  539. PhotoUid: Photo.PhotoUid,
  540. }
  541. ProjectDetail.ProjectPhotos = append(ProjectDetail.ProjectPhotos, ProjectPhoto)
  542. }
  543. return &ProjectDetail, nil
  544. }
  545. func (*project) GetTaskLogisticsList(ctx context.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskLogisticsListData, error) {
  546. TaskLogisticss, total, err := db.GetTaskLogisticsList(ctx, projectID, pageSize, pageNum, conditions)
  547. if err != nil {
  548. logrus.WithContext(ctx).Errorf("[project service] call GetTaskLogisticsList error,err:%+v", err)
  549. return nil, err
  550. }
  551. TaskLogisticsListData := new(http_model.TaskLogisticsListData)
  552. TaskLogisticsListData.TaskLogisticsPreview = pack.MGormTaskLogisticsInfoListToHttpTaskLogisticsPreviewList(TaskLogisticss)
  553. TaskLogisticsListData.Total = conv.MustString(total, "")
  554. return TaskLogisticsListData, nil
  555. }
  556. func (*project) ChangeTaskStatus(ctx *gin.Context, data http_model.ProjectChangeTaskStatusRequest) interface{} {
  557. RecruitStrategyIDs, err := db.ChangeTaskStatus(ctx, data.TaskIds, data.TaskStatus)
  558. if err != nil {
  559. logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err)
  560. return err
  561. }
  562. if data.TaskStatus == "2" {
  563. err = db.CalculateSelectedNumberByRecruitStrategyID(ctx, RecruitStrategyIDs, 1)
  564. if err != nil {
  565. logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err)
  566. return err
  567. }
  568. } else {
  569. err = db.CalculateSelectedNumberByRecruitStrategyID(ctx, RecruitStrategyIDs, -1)
  570. if err != nil {
  571. logrus.WithContext(ctx).Errorf("[project service] call ChangeTaskStatus error,err:%+v", err)
  572. return err
  573. }
  574. }
  575. return nil
  576. }
  577. func (p *project) GetTaskScriptList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskScriptListData, error) {
  578. TaskScripts, total, err := db.GetTaskScriptList(ctx, projectID, pageSize, pageNum, conditions)
  579. if err != nil {
  580. logrus.WithContext(ctx).Errorf("[project service] call GetTaskScriptList error,err:%+v", err)
  581. return nil, err
  582. }
  583. TaskScriptListData := new(http_model.TaskScriptListData)
  584. TaskScriptListData.TaskScriptPreview = pack.MGormTaskScriptInfoListToHttpTaskScriptPreviewList(TaskScripts)
  585. TaskScriptListData.Total = conv.MustString(total, "")
  586. return TaskScriptListData, nil
  587. }
  588. func (p *project) GetTaskSketchList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskSketchListData, error) {
  589. TaskSketchs, total, err := db.GetTaskSketchList(ctx, projectID, pageSize, pageNum, conditions)
  590. if err != nil {
  591. logrus.WithContext(ctx).Errorf("[project service] call GetTaskSketchList error,err:%+v", err)
  592. return nil, err
  593. }
  594. TaskSketchListData := new(http_model.TaskSketchListData)
  595. TaskSketchListData.TaskSketchPreview = pack.MGormTaskSketchInfoListToHttpTaskSketchPreviewList(TaskSketchs)
  596. TaskSketchListData.Total = conv.MustString(total, "")
  597. return TaskSketchListData, nil
  598. }
  599. func (p *project) GetTaskLinkList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskLinkListData, error) {
  600. TaskLinks, total, err := db.GetTaskLinkList(ctx, projectID, pageSize, pageNum, conditions)
  601. if err != nil {
  602. logrus.WithContext(ctx).Errorf("[project service] call GetTaskLinkList error,err:%+v", err)
  603. return nil, err
  604. }
  605. TaskLinkListData := new(http_model.TaskLinkListData)
  606. TaskLinkListData.TaskLinkPreview = pack.MGormTaskLinkInfoListToHttpTaskLinkPreviewList(TaskLinks)
  607. TaskLinkListData.Total = conv.MustString(total, "")
  608. return TaskLinkListData, nil
  609. }
  610. func (p *project) GetTaskDataList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskDataListData, error) {
  611. TaskDatas, total, err := db.GetTaskDataList(ctx, projectID, pageSize, pageNum, conditions)
  612. if err != nil {
  613. logrus.WithContext(ctx).Errorf("[project service] call GetTaskDataList error,err:%+v", err)
  614. return nil, err
  615. }
  616. TaskDataListData := new(http_model.TaskDataListData)
  617. TaskDataListData.TaskDataPreview = pack.MGormTaskDataInfoListToHttpTaskDataPreviewList(TaskDatas)
  618. TaskDataListData.Total = conv.MustString(total, "")
  619. return TaskDataListData, nil
  620. }
  621. func (p *project) GetTaskFinishList(ctx *gin.Context, projectID string, pageSize, pageNum int64, conditions *common_model.TalentConditions) (*http_model.TaskFinishListData, error) {
  622. TaskFinishs, total, err := db.GetTaskFinishList(ctx, projectID, pageSize, pageNum, conditions)
  623. if err != nil {
  624. logrus.WithContext(ctx).Errorf("[project service] call GetTaskFinishList error,err:%+v", err)
  625. return nil, err
  626. }
  627. TaskFinishListData := new(http_model.TaskFinishListData)
  628. TaskFinishListData.TaskFinishPreview = pack.MGormTaskFinishInfoListToHttpTaskFinishPreviewList(TaskFinishs)
  629. TaskFinishListData.Total = conv.MustString(total, "")
  630. return TaskFinishListData, nil
  631. }