task_controller.go 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821
  1. package controller
  2. import (
  3. "github.com/gin-gonic/gin"
  4. "github.com/sirupsen/logrus"
  5. "youngee_b_api/app/service"
  6. "youngee_b_api/app/service/review_service"
  7. "youngee_b_api/app/vo"
  8. )
  9. type TaskController struct{}
  10. type SelectionDetailParam struct {
  11. SelectionId string `json:"selection_id"`
  12. //EnterpriseId string `json:"enterprise_id"`
  13. //SubAccountId int `json:"sub_account_id"`
  14. }
  15. type ProjectDetailParam struct {
  16. ProjectId string `json:"project_id"`
  17. //EnterpriseId string `json:"enterprise_id"`
  18. //SubAccountId int `json:"sub_account_id"`
  19. }
  20. type LocalLifeDetailParam struct {
  21. LocalLifeId string `json:"local_id"`
  22. //EnterpriseId string `json:"enterprise_id"`
  23. //SubAccountId int `json:"sub_account_id"`
  24. }
  25. // 关联商品-已有商品展示
  26. func (t TaskController) GetAllProduct(c *gin.Context) {
  27. search := vo.GetAllProductParam{}
  28. err := c.BindJSON(&search)
  29. if err != nil {
  30. logrus.Errorf("Request bind err:%+v\n", err)
  31. returnError(c, 40000, "参数错误")
  32. return
  33. }
  34. var result vo.ResultVO
  35. result, err = service.ProductService{}.GetTaskProductsByUserId(search)
  36. if err != nil {
  37. logrus.Errorf("[GetAllProduct] call GetAllProduct err:%+v\n", err)
  38. returnError(c, 40000, err.Error())
  39. return
  40. }
  41. returnSuccess(c, 20000, result)
  42. return
  43. }
  44. // 关联商品-新建商品
  45. func (t TaskController) CreateProduct(c *gin.Context) {
  46. data := &vo.ProductCreateParam{}
  47. err := c.BindJSON(data)
  48. if err != nil {
  49. logrus.Errorf("Request bind err:%+v\n", err)
  50. returnError(c, 40000, "参数错误")
  51. return
  52. }
  53. productId, err := service.ProductService{}.CreateProduct(data)
  54. if err != nil {
  55. logrus.Errorf("[CreateProduct] call CreateProduct err:%+v\n", err)
  56. returnError(c, 40000, err.Error())
  57. return
  58. }
  59. resultMap := make(map[string]int64)
  60. resultMap["productId"] = productId
  61. returnSuccess(c, 20000, resultMap)
  62. }
  63. // 关联商品-完成关联创建带货任务
  64. func (t TaskController) CreateSelection(c *gin.Context) {
  65. data := &vo.SelectionInfoCreateParam{}
  66. err := c.BindJSON(data)
  67. if err != nil {
  68. logrus.Errorf("Request bind err:%+v\n", err)
  69. returnError(c, 40000, "参数错误")
  70. return
  71. }
  72. selectionId, err := service.SelectionInfoService{}.CreateSelectionInfo(data)
  73. if err != nil {
  74. logrus.Errorf("[CreateSelection] call CreateSelection err:%+v\n", err)
  75. returnError(c, 40000, "error")
  76. return
  77. }
  78. resultMap := make(map[string]string)
  79. resultMap["selectionId"] = *selectionId
  80. returnSuccess(c, 20000, resultMap)
  81. }
  82. // 更新带货任务(样品奖励、补充信息)
  83. func (t TaskController) UpdateSelection(c *gin.Context) {
  84. data := &vo.SelectionInfoUpdateParam{}
  85. err := c.BindJSON(data)
  86. if err != nil {
  87. logrus.Errorf("Request bind err:%+v\n", err)
  88. returnError(c, 40000, "参数错误")
  89. return
  90. }
  91. selectionId, err := service.SelectionInfoService{}.UpdateSelectionInfo(data)
  92. if err != nil {
  93. logrus.Errorf("[UpdateSelection] call UpdateSelection err:%+v\n", err)
  94. returnError(c, 40000, "error")
  95. return
  96. }
  97. resultMap := make(map[string]string)
  98. resultMap["selectionId"] = *selectionId
  99. returnSuccess(c, 20000, resultMap)
  100. }
  101. // 电商带货任务预览
  102. func (t TaskController) GetSelectionDetail(c *gin.Context) {
  103. data := &SelectionDetailParam{}
  104. err := c.BindJSON(data)
  105. if err != nil {
  106. logrus.Errorf("Request bind err:%+v\n", err)
  107. returnError(c, 40000, "参数错误")
  108. return
  109. }
  110. res, err := service.SelectionInfoService{}.GetSelectionDetail(data.SelectionId)
  111. if err != nil {
  112. logrus.Errorf("[GetSelectionDetail] call Show err:%+v\n", err)
  113. returnError(c, 40000, "error")
  114. return
  115. }
  116. returnSuccess(c, 20000, res)
  117. }
  118. // 电商带货提交审核
  119. func (t TaskController) SelectionToReview(c *gin.Context) {
  120. data := &vo.SelectionInfoUpdateParam{}
  121. err := c.BindJSON(data)
  122. if err != nil || data.SelectionID == "" {
  123. logrus.Errorf("Request bind err:%+v\n", err)
  124. returnError(c, 40000, "参数错误")
  125. return
  126. }
  127. selectionId, err := service.SelectionInfoService{}.SelectionToReview(data)
  128. if err != nil {
  129. logrus.Errorf("[SelectionToReview] call SelectionToReview err:%+v\n", err)
  130. returnError(c, 40000, "error")
  131. return
  132. }
  133. resultMap := make(map[string]string)
  134. resultMap["selectionId"] = *selectionId
  135. returnSuccess(c, 20000, resultMap)
  136. }
  137. // 电商带货任务列表
  138. func (t TaskController) SelectionTaskList(c *gin.Context) {
  139. param := &vo.SelectionSearchParam{}
  140. err := c.BindJSON(param)
  141. if err != nil {
  142. logrus.Errorf("Request bind err:%+v\n", err)
  143. returnError(c, 40000, "参数错误")
  144. return
  145. }
  146. res, err := service.SelectionInfoService{}.GetSelectionTaskList(param)
  147. if err != nil {
  148. logrus.Errorf("[SelectionTaskList] call Show err:%+v\n", err)
  149. returnError(c, 40000, "error")
  150. return
  151. }
  152. returnSuccess(c, 20000, res)
  153. }
  154. // 删除带货任务
  155. func (t TaskController) SelectionDel(c *gin.Context) {
  156. param := &vo.SelectionSearchParam{}
  157. err := c.BindJSON(param)
  158. if err != nil {
  159. logrus.Errorf("Request bind err:%+v\n", err)
  160. returnError(c, 40000, "参数错误")
  161. return
  162. }
  163. selectionId, err := service.SelectionInfoService{}.DeleteSelection(param.SelectionId)
  164. if err != nil {
  165. logrus.Errorf("[SelectionDel] call Show err:%+v\n", err)
  166. returnError(c, 40000, "error")
  167. return
  168. }
  169. resultMap := make(map[string]string)
  170. resultMap["selectionId"] = *selectionId
  171. returnSuccess(c, 20000, resultMap)
  172. }
  173. // 电商带货任务审核
  174. func (t TaskController) CheckSelectionInfo(c *gin.Context) {
  175. //data := &vo.ContentCheckParam{}
  176. //err := c.BindJSON(data)
  177. //if err != nil {
  178. // logrus.Errorf("Request bind err:%+v\n", err)
  179. // returnError(c, 40000, "error")
  180. // return
  181. //}
  182. //res, err := service.ContentService{}.CheckContent(data)
  183. //if err != nil {
  184. // logrus.Errorf("[CheckSelectionInfo] call Show err:%+v\n", err)
  185. // returnError(c, 40000, "error")
  186. // return
  187. //}
  188. //
  189. //returnSuccess(c, 20000, *res)
  190. data := &vo.ContentCheckParam{}
  191. err := c.BindJSON(data)
  192. if err != nil {
  193. logrus.Errorf("Request bind err:%+v\n", err)
  194. returnError(c, 40000, "参数错误")
  195. return
  196. }
  197. sdk := review_service.Config(data.AK, data.SK, data.ProjectId)
  198. res1, err1 := sdk.CheckContent(data.Text)
  199. res2, err2 := sdk.CheckImage(data.Image)
  200. res3, err3 := sdk.CheckDocument(data.Document, data.Format)
  201. res4, err4 := sdk.CheckVideo(data.Video)
  202. res5, err5 := sdk.CheckCredentials(data.Credentials)
  203. if err1 != nil {
  204. logrus.Errorf("[CheckSelectionInfo] call Show err:%+v\n", err)
  205. returnError(c, 40000, res1)
  206. return
  207. }
  208. if err2 != nil {
  209. logrus.Errorf("[CheckSelectionInfo] call Show err:%+v\n", err)
  210. returnError(c, 40000, res2)
  211. return
  212. }
  213. if err3 != nil {
  214. logrus.Errorf("[CheckSelectionInfo] call Show err:%+v\n", err)
  215. returnError(c, 40000, res3)
  216. return
  217. }
  218. if err4 != nil {
  219. logrus.Errorf("[CheckSelectionInfo] call Show err:%+v\n", err)
  220. returnError(c, 40000, res4)
  221. return
  222. }
  223. if err5 != nil {
  224. logrus.Errorf("[CheckSelectionInfo] call Show err:%+v\n", err)
  225. returnError(c, 40000, res5)
  226. return
  227. }
  228. returnSuccess(c, 20000, res3)
  229. }
  230. // 创建种草任务
  231. func (t TaskController) CreateProject(c *gin.Context) {
  232. data := &vo.ProjectCreateParam{}
  233. err := c.BindJSON(data)
  234. if err != nil {
  235. logrus.Errorf("Request bind err:%+v\n", err)
  236. returnError(c, 40000, "参数错误")
  237. return
  238. }
  239. projectId, err := service.ProjectService{}.CreateProject(data)
  240. if err != nil {
  241. logrus.Errorf("[CreateProject] call CreateProject err:%+v\n", err)
  242. returnError(c, 40000, err.Error())
  243. return
  244. }
  245. resultMap := make(map[string]string)
  246. resultMap["projectId"] = *projectId
  247. returnSuccess(c, 20000, resultMap)
  248. }
  249. // 更新种草任务
  250. func (t TaskController) UpdateProject(c *gin.Context) {
  251. data := &vo.ProjectUpdateParam{}
  252. err := c.BindJSON(data)
  253. if err != nil {
  254. logrus.Errorf("Request bind err:%+v\n", err)
  255. returnError(c, 40000, "参数错误")
  256. return
  257. }
  258. projectId, err := service.ProjectService{}.UpdateProject(data)
  259. if err != nil {
  260. logrus.Errorf("[UpdateProject] call UpdateProject err:%+v\n", err)
  261. returnError(c, 40000, err.Error())
  262. return
  263. }
  264. resultMap := make(map[string]string)
  265. resultMap["projectId"] = *projectId
  266. returnSuccess(c, 20000, resultMap)
  267. }
  268. // 更新定向种草任务
  269. func (t TaskController) UpdateProjectTarget(c *gin.Context) {
  270. data := &vo.ProjectUpdateParam{}
  271. err := c.BindJSON(data)
  272. if err != nil {
  273. logrus.Errorf("Request bind err:%+v\n", err)
  274. returnError(c, 40000, "参数错误")
  275. return
  276. }
  277. projectId, err := service.ProjectService{}.UpdateProjectTarget(data)
  278. if err != nil {
  279. logrus.Errorf("[UpdateProject] call UpdateProject err:%+v\n", err)
  280. returnError(c, 40000, err.Error())
  281. return
  282. }
  283. resultMap := make(map[string]string)
  284. resultMap["projectId"] = *projectId
  285. returnSuccess(c, 20000, resultMap)
  286. }
  287. // 种草任务预览
  288. func (t TaskController) GetProjectDetail(c *gin.Context) {
  289. data := &ProjectDetailParam{}
  290. err := c.BindJSON(data)
  291. if err != nil {
  292. logrus.Errorf("Request bind err:%+v\n", err)
  293. returnError(c, 40000, "参数错误")
  294. return
  295. }
  296. res, err := service.ProjectService{}.GetProjectDetail(data.ProjectId)
  297. if err != nil {
  298. logrus.Errorf("[GetProjectDetail] call Show err:%+v\n", err)
  299. returnError(c, 40000, err.Error())
  300. return
  301. }
  302. returnSuccess(c, 20000, res)
  303. }
  304. // 种草提交审核
  305. func (t TaskController) ProjectToReview(c *gin.Context) {
  306. data := &vo.ProjectUpdateParam{}
  307. err := c.BindJSON(data)
  308. if err != nil || data.ProjectID == "" {
  309. logrus.Errorf("Request bind err:%+v\n", err)
  310. returnError(c, 40000, "参数错误")
  311. return
  312. }
  313. projectId, err := service.ProjectService{}.ProjectToReview(data)
  314. if err != nil {
  315. logrus.Errorf("[ProjectToReview] call ProjectToReview err:%+v\n", err)
  316. returnError(c, 40000, "error")
  317. return
  318. }
  319. resultMap := make(map[string]string)
  320. resultMap["projectId"] = *projectId
  321. returnSuccess(c, 20000, resultMap)
  322. }
  323. // 种草任务列表
  324. func (t TaskController) ProjectTaskList(c *gin.Context) {
  325. param := &vo.ProjectSearchParam{}
  326. err := c.BindJSON(param)
  327. if err != nil {
  328. logrus.Errorf("Request bind err:%+v\n", err)
  329. returnError(c, 40000, "参数错误")
  330. return
  331. }
  332. res, err := service.ProjectService{}.GetProjectTaskList(param)
  333. if err != nil {
  334. logrus.Errorf("[ProjectTaskList] call Show err:%+v\n", err)
  335. returnError(c, 40000, "error")
  336. return
  337. }
  338. returnSuccess(c, 20000, res)
  339. }
  340. // 删除种草任务
  341. func (t TaskController) ProjectDel(c *gin.Context) {
  342. param := &vo.ProjectSearchParam{}
  343. err := c.BindJSON(param)
  344. if err != nil {
  345. logrus.Errorf("Request bind err:%+v\n", err)
  346. returnError(c, 40000, "参数错误")
  347. return
  348. }
  349. projectId, err := service.ProjectService{}.DeleteProject(param.ProjectId)
  350. if err != nil {
  351. logrus.Errorf("[ProjectDel] call Show err:%+v\n", err)
  352. returnError(c, 40000, "error")
  353. return
  354. }
  355. resultMap := make(map[string]string)
  356. resultMap["projectId"] = *projectId
  357. returnSuccess(c, 20000, resultMap)
  358. }
  359. // 草稿箱——电商带货
  360. func (t TaskController) GetSelectionDraftList(c *gin.Context) {
  361. param := &vo.SelectionDraftParam{}
  362. err := c.BindJSON(param)
  363. if err != nil {
  364. logrus.Errorf("Request bind err:%+v\n", err)
  365. returnError(c, 40000, "参数错误")
  366. return
  367. }
  368. res, err := service.SelectionInfoService{}.GetSelectionDraftList(param)
  369. if err != nil {
  370. logrus.Errorf("[SelectionTaskList] call Show err:%+v\n", err)
  371. returnError(c, 40000, "error")
  372. return
  373. }
  374. returnSuccess(c, 20000, res)
  375. }
  376. // 草稿箱——品牌种草
  377. func (t TaskController) GetProjectDraftList(c *gin.Context) {
  378. param := &vo.ProjectDraftParam{}
  379. err := c.BindJSON(param)
  380. if err != nil {
  381. logrus.Errorf("Request bind err:%+v\n", err)
  382. returnError(c, 40000, "参数错误")
  383. return
  384. }
  385. res, err := service.ProjectService{}.GetProjectDraftList(param)
  386. if err != nil {
  387. logrus.Errorf("[SelectionTaskList] call Show err:%+v\n", err)
  388. returnError(c, 40000, "error")
  389. return
  390. }
  391. returnSuccess(c, 20000, res)
  392. }
  393. // 违约管理——违约公开任务列表
  394. func (t TaskController) GetPublicDefaultList(c *gin.Context) {
  395. param := &vo.DefaultSearchParam{}
  396. err := c.BindJSON(param)
  397. if err != nil {
  398. logrus.Errorf("Request bind err:%+v\n", err)
  399. returnError(c, 40000, "参数错误")
  400. return
  401. }
  402. res, err := service.DefaultService{}.GetPublicDefaultList(param)
  403. if err != nil {
  404. logrus.Errorf("[GetPublicDefaultList] call Show err:%+v\n", err)
  405. returnError(c, 40000, "error")
  406. return
  407. }
  408. returnSuccess(c, 20000, res)
  409. }
  410. // 违约管理——违约定向任务列表
  411. func (t TaskController) GetTargetDefaultList(c *gin.Context) {
  412. param := &vo.DefaultSearchParam{}
  413. err := c.BindJSON(param)
  414. if err != nil {
  415. logrus.Errorf("Request bind err:%+v\n", err)
  416. returnError(c, 40000, "参数错误")
  417. return
  418. }
  419. res, err := service.DefaultService{}.GetTargetDefaultList(param)
  420. if err != nil {
  421. logrus.Errorf("[GetTargetDefaultList] call Show err:%+v\n", err)
  422. returnError(c, 40000, "error")
  423. return
  424. }
  425. returnSuccess(c, 20000, res)
  426. }
  427. // 违约管理——公开任务-违约达人列表
  428. func (t TaskController) GetPublicDefaultTalentList(c *gin.Context) {
  429. param := &vo.DefaultSearchParam{}
  430. err := c.BindJSON(param)
  431. if err != nil {
  432. logrus.Errorf("Request bind err:%+v\n", err)
  433. returnError(c, 40000, "参数错误")
  434. return
  435. }
  436. res, err := service.DefaultService{}.GetPublicDefaultTalentList(param)
  437. if err != nil {
  438. logrus.Errorf("[GetPublicDefaultTalentList] call Show err:%+v\n", err)
  439. returnError(c, 40000, "error")
  440. return
  441. }
  442. returnSuccess(c, 20000, res)
  443. }
  444. // 违约管理——定向任务-违约达人列表
  445. func (t TaskController) GetTargetDefaultTalentList(c *gin.Context) {
  446. param := &vo.DefaultSearchParam{}
  447. err := c.BindJSON(param)
  448. if err != nil {
  449. logrus.Errorf("Request bind err:%+v\n", err)
  450. returnError(c, 40000, "参数错误")
  451. return
  452. }
  453. res, err := service.DefaultService{}.GetTargetDefaultTalentList(param)
  454. if err != nil {
  455. logrus.Errorf("[GetTargetDefaultTalentList] call Show err:%+v\n", err)
  456. returnError(c, 40000, "error")
  457. return
  458. }
  459. returnSuccess(c, 20000, res)
  460. }
  461. // 违约管理——达人解约
  462. func (t TaskController) CancelTalent(c *gin.Context) {
  463. param := &vo.TalentCancelParam{}
  464. err := c.BindJSON(param)
  465. if err != nil {
  466. logrus.Errorf("Request bind err:%+v\n", err)
  467. returnError(c, 40000, "参数错误")
  468. return
  469. }
  470. err = service.DefaultService{}.CancelTalent(param)
  471. if err != nil {
  472. logrus.Errorf("[CancelTalent] call Show err:%+v\n", err)
  473. returnError(c, 40000, "error")
  474. return
  475. }
  476. resultMap := make(map[string]string)
  477. resultMap["taskId"] = param.TaskId
  478. returnSuccess(c, 20000, resultMap)
  479. }
  480. // 违约管理——达人批量解约
  481. func (t TaskController) CancelTalentList(c *gin.Context) {
  482. param := &vo.TalentCancelParam{}
  483. err := c.BindJSON(param)
  484. if err != nil {
  485. logrus.Errorf("Request bind err:%+v\n", err)
  486. returnError(c, 40000, "参数错误")
  487. return
  488. }
  489. err = service.DefaultService{}.CancelTalentList(param)
  490. if err != nil {
  491. logrus.Errorf("[CancelTalentList] call Show err:%+v\n", err)
  492. returnError(c, 40000, "error")
  493. return
  494. }
  495. resultMap := make(map[string][]string)
  496. resultMap["taskIds"] = param.TaskIds
  497. returnSuccess(c, 20000, resultMap)
  498. }
  499. // 服务商合作-服务商列表
  500. func (o TaskController) GetSupplierInTargetTaskList(c *gin.Context) {
  501. param := &vo.SupplierSearchInTargetTaskParam{}
  502. err := c.BindJSON(param)
  503. if err != nil || "" == param.EnterpriseId {
  504. logrus.Errorf("Request bind err:%+v\n", err)
  505. returnError(c, 40000, "参数错误")
  506. return
  507. }
  508. result, err1 := service.CooperationService{}.GetSupplierInTargetTaskList(param)
  509. if err1 != nil {
  510. logrus.Errorf("[GetSuplierList] call Show err:%+v\n", err)
  511. returnError(c, 40000, err.Error())
  512. return
  513. }
  514. returnSuccess(c, 20000, result)
  515. }
  516. // 服务商合作-邀约合作
  517. func (o TaskController) InviteSupplier(c *gin.Context) {
  518. param := &vo.SupplierInviteInTargetTaskParam{}
  519. err := c.BindJSON(param)
  520. if err != nil {
  521. logrus.Errorf("Request bind err:%+v\n", err)
  522. returnError(c, 40000, "参数错误")
  523. return
  524. }
  525. err1 := service.CooperationService{}.InviteSupplierInTargetTask(param)
  526. if err1 != nil {
  527. logrus.Errorf("[InviteSupplier] call Show err:%+v\n", err)
  528. returnError(c, 40000, err.Error())
  529. return
  530. }
  531. returnSuccess(c, 20000, nil)
  532. }
  533. // 门店类目
  534. func (t TaskController) GetStoreCategory(c *gin.Context) {
  535. res, err := service.StoreService{}.GetStoreCategory()
  536. if err != nil {
  537. logrus.Errorf("[GetStoreCategory] call Show err:%+v\n", err)
  538. returnError(c, 40000, "error")
  539. return
  540. }
  541. returnSuccess(c, 20000, res)
  542. }
  543. // 关联门店-已有门店展示
  544. func (t TaskController) GetAllStore(c *gin.Context) {
  545. search := vo.GetAllStoreParam{}
  546. err := c.BindJSON(&search)
  547. if err != nil || search.EnterpriseId == "" {
  548. logrus.Errorf("Request bind err:%+v\n", err)
  549. returnError(c, 40000, "参数错误")
  550. return
  551. }
  552. var result vo.ResultVO
  553. result, err = service.StoreService{}.GetStoresByEnterpriseId(search)
  554. if err != nil {
  555. logrus.Errorf("[GetAllStore] call Show err:%+v\n", err)
  556. returnError(c, 40000, err.Error())
  557. return
  558. }
  559. returnSuccess(c, 20000, result)
  560. }
  561. // 关联门店-新建门店
  562. func (t TaskController) CreateStore(c *gin.Context) {
  563. param := &vo.StoreCreateParam{}
  564. err := c.BindJSON(param)
  565. if err != nil {
  566. logrus.Errorf("Request bind err:%+v\n", err)
  567. returnError(c, 40000, "参数错误")
  568. return
  569. }
  570. storeId, err := service.StoreService{}.CreateStore(param)
  571. if err != nil {
  572. logrus.Errorf("[CreateStore] call Show err:%+v\n", err)
  573. returnError(c, 40000, err.Error())
  574. return
  575. }
  576. resultMap := make(map[string]int64)
  577. resultMap["storeId"] = storeId
  578. returnSuccess(c, 20000, resultMap)
  579. }
  580. // 门店团购列表
  581. func (t TaskController) GetAllTeamBuying(c *gin.Context) {
  582. search := vo.GetAllTeamBuyingParam{}
  583. err := c.BindJSON(&search)
  584. if err != nil || search.StoreId == 0 {
  585. logrus.Errorf("Request bind err:%+v\n", err)
  586. returnError(c, 40000, "参数错误")
  587. return
  588. }
  589. var result vo.ResultVO
  590. result, err = service.TeamBuyingService{}.GetTeamBuyingsByStoreId(search)
  591. if err != nil {
  592. logrus.Errorf("[GetAllTeamBuying] call Show err:%+v\n", err)
  593. returnError(c, 40000, err.Error())
  594. return
  595. }
  596. returnSuccess(c, 20000, result)
  597. }
  598. // 新建团购
  599. func (t TaskController) CreateTeamBuying(c *gin.Context) {
  600. param := &vo.TeamBuyingCreateParam{}
  601. err := c.BindJSON(param)
  602. if err != nil {
  603. logrus.Errorf("Request bind err:%+v\n", err)
  604. returnError(c, 40000, "参数错误")
  605. return
  606. }
  607. teamBuyingId, err := service.TeamBuyingService{}.CreateTeamBuying(param)
  608. if err != nil {
  609. logrus.Errorf("[CreateTeamBuying] call Show err:%+v\n", err)
  610. returnError(c, 40000, err.Error())
  611. return
  612. }
  613. resultMap := make(map[string]int64)
  614. resultMap["teamBuyingId"] = teamBuyingId
  615. returnSuccess(c, 20000, resultMap)
  616. }
  617. // 创建本地生活任务
  618. func (t TaskController) CreateLocalLife(c *gin.Context) {
  619. data := &vo.LocalCreateParam{}
  620. err := c.BindJSON(data)
  621. if err != nil {
  622. logrus.Errorf("Request bind err:%+v\n", err)
  623. returnError(c, 40000, "参数错误")
  624. return
  625. }
  626. localId, err := service.LocalLifeService{}.CreateLocalLife(data)
  627. if err != nil {
  628. logrus.Errorf("[CreateLocalLife] call CreateLocalLife err:%+v\n", err)
  629. returnError(c, 40000, err.Error())
  630. return
  631. }
  632. resultMap := make(map[string]string)
  633. resultMap["localId"] = *localId
  634. returnSuccess(c, 20000, resultMap)
  635. }
  636. // 更新本地生活任务
  637. func (t TaskController) UpdateLocalLife(c *gin.Context) {
  638. data := &vo.LocalUpdateParam{}
  639. err := c.BindJSON(data)
  640. if err != nil {
  641. logrus.Errorf("Request bind err:%+v\n", err)
  642. returnError(c, 40000, "参数错误")
  643. return
  644. }
  645. localId, err := service.LocalLifeService{}.UpdateLocal(data)
  646. if err != nil {
  647. logrus.Errorf("[UpdateLocalLife] call UpdateLocalLife err:%+v\n", err)
  648. returnError(c, 40000, err.Error())
  649. return
  650. }
  651. resultMap := make(map[string]string)
  652. resultMap["localId"] = *localId
  653. returnSuccess(c, 20000, resultMap)
  654. }
  655. // 更新定向本地生活任务
  656. func (t TaskController) UpdateLocalLifeTarget(c *gin.Context) {
  657. data := &vo.LocalUpdateParam{}
  658. err := c.BindJSON(data)
  659. if err != nil {
  660. logrus.Errorf("Request bind err:%+v\n", err)
  661. returnError(c, 40000, "参数错误")
  662. return
  663. }
  664. localId, err := service.LocalLifeService{}.UpdateLocalTarget(data)
  665. if err != nil {
  666. logrus.Errorf("[UpdateLocalLifeTarget] call UpdateLocalLifeTarget err:%+v\n", err)
  667. returnError(c, 40000, err.Error())
  668. return
  669. }
  670. resultMap := make(map[string]string)
  671. resultMap["localId"] = *localId
  672. returnSuccess(c, 20000, resultMap)
  673. }
  674. // 本地生活任务预览
  675. func (t TaskController) GetLocalLifeDetail(c *gin.Context) {
  676. param := &LocalLifeDetailParam{}
  677. err := c.BindJSON(param)
  678. if err != nil {
  679. logrus.Errorf("Request bind err:%+v\n", err)
  680. returnError(c, 40000, "参数错误")
  681. return
  682. }
  683. res, err := service.LocalLifeService{}.GetLocalLifeDetail(param.LocalLifeId)
  684. if err != nil {
  685. logrus.Errorf("[GetLocalLifeDetail] call Show err:%+v\n", err)
  686. returnError(c, 40000, err.Error())
  687. return
  688. }
  689. returnSuccess(c, 20000, res)
  690. }
  691. // 本地生活提交审核
  692. func (t TaskController) LocalLifeToReview(c *gin.Context) {
  693. data := &vo.LocalUpdateParam{}
  694. err := c.BindJSON(data)
  695. if err != nil || data.LocalID == "" {
  696. logrus.Errorf("Request bind err:%+v\n", err)
  697. returnError(c, 40000, "参数错误")
  698. return
  699. }
  700. localId, err := service.LocalLifeService{}.LocalLifeToReview(data)
  701. if err != nil {
  702. logrus.Errorf("[ProjectToReview] call ProjectToReview err:%+v\n", err)
  703. returnError(c, 40000, err.Error())
  704. return
  705. }
  706. resultMap := make(map[string]string)
  707. resultMap["localId"] = *localId
  708. returnSuccess(c, 20000, resultMap)
  709. }
  710. // 达人物流列表
  711. func (t TaskController) LogisticsTalentList(c *gin.Context) {
  712. param := &vo.LogisticsTalentParam{}
  713. err := c.BindJSON(param)
  714. if err != nil || "" == param.ProjectId {
  715. logrus.Errorf("Request bind err:%+v\n", err)
  716. returnError(c, 40000, "参数错误")
  717. return
  718. }
  719. res, err := service.TaskInfoService{}.LogisticsTalentList(param)
  720. if err != nil {
  721. logrus.Errorf("[LogisticsTalentList] call Show err:%+v\n", err)
  722. returnError(c, 40000, err.Error())
  723. return
  724. }
  725. returnSuccess(c, 20000, res)
  726. }
  727. // 种草任务列表
  728. func (t TaskController) LocalLifeTaskList(c *gin.Context) {
  729. param := &vo.LocalSearchParam{}
  730. err := c.BindJSON(param)
  731. if err != nil {
  732. logrus.Errorf("Request bind err:%+v\n", err)
  733. returnError(c, 40000, "参数错误")
  734. return
  735. }
  736. res, err := service.LocalLifeService{}.GetLocalLifeTaskList(param)
  737. if err != nil {
  738. logrus.Errorf("[LocalLifeTaskList] call Show err:%+v\n", err)
  739. returnError(c, 40000, err.Error())
  740. return
  741. }
  742. returnSuccess(c, 20000, res)
  743. }
  744. // 删除种草任务
  745. func (t TaskController) LocalLifeDel(c *gin.Context) {
  746. param := &vo.LocalSearchParam{}
  747. err := c.BindJSON(param)
  748. if err != nil {
  749. logrus.Errorf("Request bind err:%+v\n", err)
  750. returnError(c, 40000, "参数错误")
  751. return
  752. }
  753. localId, err := service.LocalLifeService{}.DeleteLocalLife(param.LocalId)
  754. if err != nil {
  755. logrus.Errorf("[LocalLifeDel] call Show err:%+v\n", err)
  756. returnError(c, 40000, err.Error())
  757. return
  758. }
  759. resultMap := make(map[string]string)
  760. resultMap["localId"] = *localId
  761. returnSuccess(c, 20000, resultMap)
  762. }