task_controller.go 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155
  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/vo"
  7. )
  8. type TaskController struct{}
  9. type SelectionDetailParam struct {
  10. SelectionId string `json:"selection_id"`
  11. //EnterpriseId string `json:"enterprise_id"`
  12. //SubAccountId int `json:"sub_account_id"`
  13. }
  14. type ProjectDetailParam struct {
  15. ProjectId string `json:"project_id"`
  16. //EnterpriseId string `json:"enterprise_id"`
  17. //SubAccountId int `json:"sub_account_id"`
  18. }
  19. type LocalLifeDetailParam struct {
  20. LocalLifeId string `json:"local_id"`
  21. //EnterpriseId string `json:"enterprise_id"`
  22. //SubAccountId int `json:"sub_account_id"`
  23. }
  24. // 关联商品-已有商品展示
  25. func (t TaskController) GetAllProduct(c *gin.Context) {
  26. search := vo.GetAllProductParam{}
  27. err := c.BindJSON(&search)
  28. if err != nil {
  29. logrus.Errorf("Request bind err:%+v\n", err)
  30. returnError(c, 40000, "Parameter Error: "+err.Error())
  31. return
  32. }
  33. var result vo.ResultVO
  34. result, err = service.ProductService{}.GetTaskProductsByUserId(search)
  35. if err != nil {
  36. logrus.Errorf("[GetAllProduct] call GetAllProduct err:%+v\n", err)
  37. returnError(c, 40000, err.Error())
  38. return
  39. }
  40. returnSuccess(c, 20000, result)
  41. return
  42. }
  43. // 关联商品-新建商品
  44. func (t TaskController) CreateProduct(c *gin.Context) {
  45. data := &vo.ProductCreateParam{}
  46. err := c.BindJSON(data)
  47. if err != nil {
  48. logrus.Errorf("Request bind err:%+v\n", err)
  49. returnError(c, 40000, "Parameter Error: "+err.Error())
  50. return
  51. }
  52. productId, err := service.ProductService{}.CreateProduct(data)
  53. if err != nil {
  54. logrus.Errorf("[CreateProduct] call CreateProduct err:%+v\n", err)
  55. returnError(c, 40000, err.Error())
  56. return
  57. }
  58. resultMap := make(map[string]int64)
  59. resultMap["productId"] = productId
  60. returnSuccess(c, 20000, resultMap)
  61. }
  62. // 关联商品-完成关联创建带货任务
  63. func (t TaskController) CreateSelection(c *gin.Context) {
  64. data := &vo.SelectionInfoCreateParam{}
  65. err := c.BindJSON(data)
  66. if err != nil {
  67. logrus.Errorf("Request bind err:%+v\n", err)
  68. returnError(c, 40000, "Parameter Error: "+err.Error())
  69. return
  70. }
  71. selectionId, err := service.SelectionInfoService{}.CreateSelectionInfo(data)
  72. if err != nil {
  73. logrus.Errorf("[CreateSelection] call CreateSelection err:%+v\n", err)
  74. returnError(c, 40000, err.Error())
  75. return
  76. }
  77. resultMap := make(map[string]string)
  78. resultMap["selectionId"] = *selectionId
  79. returnSuccess(c, 20000, resultMap)
  80. }
  81. // 更新带货任务(样品奖励、补充信息)
  82. func (t TaskController) UpdateSelection(c *gin.Context) {
  83. data := &vo.SelectionInfoUpdateParam{}
  84. err := c.BindJSON(data)
  85. if err != nil {
  86. logrus.Errorf("Request bind err:%+v\n", err)
  87. returnError(c, 40000, "Parameter Error: "+err.Error())
  88. return
  89. }
  90. selectionId, err := service.SelectionInfoService{}.UpdateSelectionInfo(data)
  91. if err != nil {
  92. logrus.Errorf("[UpdateSelection] call UpdateSelection err:%+v\n", err)
  93. returnError(c, 40000, err.Error())
  94. return
  95. }
  96. resultMap := make(map[string]string)
  97. resultMap["selectionId"] = *selectionId
  98. returnSuccess(c, 20000, resultMap)
  99. }
  100. // 电商带货任务预览
  101. func (t TaskController) GetSelectionDetail(c *gin.Context) {
  102. data := &SelectionDetailParam{}
  103. err := c.BindJSON(data)
  104. if err != nil {
  105. logrus.Errorf("Request bind err:%+v\n", err)
  106. returnError(c, 40000, "Parameter Error: "+err.Error())
  107. return
  108. }
  109. res, err := service.SelectionInfoService{}.GetSelectionDetail(data.SelectionId)
  110. if err != nil {
  111. logrus.Errorf("[GetSelectionDetail] call Show err:%+v\n", err)
  112. returnError(c, 40000, err.Error())
  113. return
  114. }
  115. returnSuccess(c, 20000, res)
  116. }
  117. // 电商带货复制任务
  118. func (t TaskController) CopySelection(c *gin.Context) {
  119. data := &vo.SelectionSearchParam{}
  120. err := c.BindJSON(data)
  121. if err != nil {
  122. logrus.Errorf("Request bind err:%+v\n", err)
  123. returnError(c, 40000, "Parameter Error: "+err.Error())
  124. return
  125. }
  126. res, err := service.SelectionInfoService{}.CopySelection(data)
  127. if err != nil {
  128. if err.Error() == "任务不存在" {
  129. returnError(c, 30000, err.Error())
  130. return
  131. }
  132. logrus.Errorf("[CopySelection] call CopySelection err:%+v\n", err)
  133. returnError(c, 40000, err.Error())
  134. return
  135. }
  136. resultMap := make(map[string]string)
  137. resultMap["selectionId"] = *res
  138. returnSuccess(c, 20000, res)
  139. }
  140. // 电商带货提交审核
  141. func (t TaskController) SelectionToReview(c *gin.Context) {
  142. data := &vo.SelectionInfoUpdateParam{}
  143. err := c.BindJSON(data)
  144. if err != nil || data.SelectionID == "" {
  145. logrus.Errorf("Request bind err:%+v\n", err)
  146. returnError(c, 40000, "Parameter Error: "+err.Error())
  147. return
  148. }
  149. selectionId, err := service.SelectionInfoService{}.SelectionToReview(data)
  150. if err != nil {
  151. logrus.Errorf("[SelectionToReview] call SelectionToReview err:%+v\n", err)
  152. returnError(c, 40000, err.Error())
  153. return
  154. }
  155. resultMap := make(map[string]string)
  156. resultMap["selectionId"] = *selectionId
  157. returnSuccess(c, 20000, resultMap)
  158. }
  159. // 电商带货任务列表
  160. func (t TaskController) SelectionTaskList(c *gin.Context) {
  161. param := &vo.SelectionSearchParam{}
  162. err := c.BindJSON(param)
  163. if err != nil {
  164. logrus.Errorf("Request bind err:%+v\n", err)
  165. returnError(c, 40000, "Parameter Error: "+err.Error())
  166. return
  167. }
  168. res, err := service.SelectionInfoService{}.GetSelectionTaskList(param)
  169. if err != nil {
  170. logrus.Errorf("[SelectionTaskList] call Show err:%+v\n", err)
  171. returnError(c, 40000, err.Error())
  172. return
  173. }
  174. returnSuccess(c, 20000, res)
  175. }
  176. // 删除带货任务
  177. func (t TaskController) SelectionDel(c *gin.Context) {
  178. param := &vo.SelectionSearchParam{}
  179. err := c.BindJSON(param)
  180. if err != nil {
  181. logrus.Errorf("Request bind err:%+v\n", err)
  182. returnError(c, 40000, "Parameter Error: "+err.Error())
  183. return
  184. }
  185. selectionId, err := service.SelectionInfoService{}.DeleteSelection(param.SelectionId)
  186. if err != nil {
  187. logrus.Errorf("[SelectionDel] call Show err:%+v\n", err)
  188. returnError(c, 40000, err.Error())
  189. return
  190. }
  191. resultMap := make(map[string]string)
  192. resultMap["selectionId"] = *selectionId
  193. returnSuccess(c, 20000, resultMap)
  194. }
  195. // 结束带货任务
  196. func (t TaskController) SelectionClose(c *gin.Context) {
  197. param := &vo.SelectionSearchParam{}
  198. err := c.BindJSON(param)
  199. if err != nil {
  200. logrus.Errorf("Request bind err:%+v\n", err)
  201. returnError(c, 40000, "Parameter Error: "+err.Error())
  202. return
  203. }
  204. todo, err1 := service.SelectionInfoService{}.CloseSelection(param.SelectionId)
  205. if err1 != nil {
  206. logrus.Errorf("[CloseSelection] call CloseSelection err:%+v\n", err1)
  207. returnError(c, 40000, err1.Error())
  208. return
  209. }
  210. resultMap := make(map[string]string)
  211. resultMap["selectionId"] = param.SelectionId
  212. resultMap["todo"] = todo
  213. returnSuccess(c, 20000, resultMap)
  214. }
  215. // 电商带货选达人角标 未处理、同意合作、拒绝合作
  216. func (t TaskController) SelectionTalentCount(c *gin.Context) {
  217. param := &vo.SelectionSearchParam{}
  218. err := c.BindJSON(param)
  219. if err != nil {
  220. logrus.Errorf("Request bind err:%+v\n", err)
  221. returnError(c, 40000, "Parameter Error: "+err.Error())
  222. return
  223. }
  224. res := service.SelectionInfoService{}.SelectionTalentCount(param.SelectionId)
  225. returnSuccess(c, 20000, res)
  226. }
  227. // 创建种草任务
  228. func (t TaskController) CreateProject(c *gin.Context) {
  229. data := &vo.ProjectCreateParam{}
  230. err := c.BindJSON(data)
  231. if err != nil {
  232. logrus.Errorf("Request bind err:%+v\n", err)
  233. returnError(c, 40000, "Parameter Error: "+err.Error())
  234. return
  235. }
  236. projectId, err := service.ProjectService{}.CreateProject(data)
  237. if err != nil {
  238. logrus.Errorf("[CreateProject] call CreateProject err:%+v\n", err)
  239. returnError(c, 40000, err.Error())
  240. return
  241. }
  242. resultMap := make(map[string]string)
  243. resultMap["projectId"] = *projectId
  244. returnSuccess(c, 20000, resultMap)
  245. }
  246. // 更新种草任务
  247. func (t TaskController) UpdateProject(c *gin.Context) {
  248. data := &vo.ProjectUpdateParam{}
  249. err := c.BindJSON(data)
  250. if err != nil {
  251. logrus.Errorf("Request bind err:%+v\n", err)
  252. returnError(c, 40000, "Parameter Error: "+err.Error())
  253. return
  254. }
  255. projectId, err := service.ProjectService{}.UpdateProject(data)
  256. if err != nil {
  257. logrus.Errorf("[UpdateProject] call UpdateProject err:%+v\n", err)
  258. returnError(c, 40000, err.Error())
  259. return
  260. }
  261. resultMap := make(map[string]string)
  262. resultMap["projectId"] = *projectId
  263. returnSuccess(c, 20000, resultMap)
  264. }
  265. // 更新定向种草任务
  266. func (t TaskController) UpdateProjectTarget(c *gin.Context) {
  267. data := &vo.ProjectUpdateParam{}
  268. err := c.BindJSON(data)
  269. if err != nil {
  270. logrus.Errorf("Request bind err:%+v\n", err)
  271. returnError(c, 40000, "Parameter Error: "+err.Error())
  272. return
  273. }
  274. projectId, err := service.ProjectService{}.UpdateProjectTarget(data)
  275. if err != nil {
  276. logrus.Errorf("[UpdateProject] call UpdateProject err:%+v\n", err)
  277. returnError(c, 40000, err.Error())
  278. return
  279. }
  280. resultMap := make(map[string]string)
  281. resultMap["projectId"] = *projectId
  282. returnSuccess(c, 20000, resultMap)
  283. }
  284. // 种草任务预览
  285. func (t TaskController) GetProjectDetail(c *gin.Context) {
  286. data := &ProjectDetailParam{}
  287. err := c.BindJSON(data)
  288. if err != nil {
  289. logrus.Errorf("Request bind err:%+v\n", err)
  290. returnError(c, 40000, "Parameter Error: "+err.Error())
  291. return
  292. }
  293. res, err := service.ProjectService{}.GetProjectDetail(data.ProjectId)
  294. if err != nil {
  295. logrus.Errorf("[GetProjectDetail] call GetProjectDetail err:%+v\n", err)
  296. returnError(c, 40000, err.Error())
  297. return
  298. }
  299. returnSuccess(c, 20000, res)
  300. }
  301. // 种草复制任务
  302. func (t TaskController) CopyProject(c *gin.Context) {
  303. data := &vo.ProjectSearchParam{}
  304. err := c.BindJSON(data)
  305. if err != nil {
  306. logrus.Errorf("Request bind err:%+v\n", err)
  307. returnError(c, 40000, "Parameter Error: "+err.Error())
  308. return
  309. }
  310. projectId, err := service.ProjectService{}.CopyProject(data)
  311. if err != nil {
  312. if err.Error() == "任务不存在" {
  313. returnError(c, 30000, err.Error())
  314. return
  315. }
  316. logrus.Errorf("[CopyProject] call CopyProject err:%+v\n", err)
  317. returnError(c, 40000, err.Error())
  318. return
  319. }
  320. resultMap := make(map[string]string)
  321. resultMap["projectId"] = *projectId
  322. returnSuccess(c, 20000, resultMap)
  323. }
  324. // 种草提交审核
  325. func (t TaskController) ProjectToReview(c *gin.Context) {
  326. data := &vo.ProjectUpdateParam{}
  327. err := c.BindJSON(data)
  328. if err != nil || data.ProjectID == "" {
  329. logrus.Errorf("Request bind err:%+v\n", err)
  330. returnError(c, 40000, "Parameter Error: "+err.Error())
  331. return
  332. }
  333. projectId, err := service.ProjectService{}.ProjectToReview(data)
  334. if err != nil {
  335. logrus.Errorf("[ProjectToReview] call ProjectToReview err:%+v\n", err)
  336. returnError(c, 40000, err.Error())
  337. return
  338. }
  339. resultMap := make(map[string]string)
  340. resultMap["projectId"] = *projectId
  341. returnSuccess(c, 20000, resultMap)
  342. }
  343. // 种草任务列表
  344. func (t TaskController) ProjectTaskList(c *gin.Context) {
  345. param := &vo.ProjectSearchParam{}
  346. err := c.BindJSON(param)
  347. if err != nil {
  348. logrus.Errorf("Request bind err:%+v\n", err)
  349. returnError(c, 40000, "Parameter Error: "+err.Error())
  350. return
  351. }
  352. res, err := service.ProjectService{}.GetProjectTaskList(param)
  353. if err != nil {
  354. logrus.Errorf("[ProjectTaskList] call Show err:%+v\n", err)
  355. returnError(c, 40000, err.Error())
  356. return
  357. }
  358. returnSuccess(c, 20000, res)
  359. }
  360. // 删除种草任务
  361. func (t TaskController) ProjectDel(c *gin.Context) {
  362. param := &vo.ProjectSearchParam{}
  363. err := c.BindJSON(param)
  364. if err != nil {
  365. logrus.Errorf("Request bind err:%+v\n", err)
  366. returnError(c, 40000, "Parameter Error: "+err.Error())
  367. return
  368. }
  369. projectId, err := service.ProjectService{}.DeleteProject(param.ProjectId)
  370. if err != nil {
  371. logrus.Errorf("[ProjectDel] call Show err:%+v\n", err)
  372. returnError(c, 40000, err.Error())
  373. return
  374. }
  375. resultMap := make(map[string]string)
  376. resultMap["projectId"] = *projectId
  377. returnSuccess(c, 20000, resultMap)
  378. }
  379. // 结束种草任务
  380. func (t TaskController) ProjectClose(c *gin.Context) {
  381. param := &vo.ProjectSearchParam{}
  382. err := c.BindJSON(param)
  383. if err != nil {
  384. logrus.Errorf("Request bind err:%+v\n", err)
  385. returnError(c, 40000, "Parameter Error: "+err.Error())
  386. return
  387. }
  388. projectId, err := service.ProjectService{}.CloseProject(param.ProjectId)
  389. if err != nil {
  390. logrus.Errorf("[CloseProject] call CloseProject err:%+v\n", err)
  391. returnError(c, 40000, err.Error())
  392. return
  393. }
  394. resultMap := make(map[string]string)
  395. resultMap["projectId"] = *projectId
  396. returnSuccess(c, 20000, resultMap)
  397. }
  398. // 草稿箱——电商带货
  399. func (t TaskController) GetSelectionDraftList(c *gin.Context) {
  400. param := &vo.SelectionDraftParam{}
  401. err := c.BindJSON(param)
  402. if err != nil {
  403. logrus.Errorf("Request bind err:%+v\n", err)
  404. returnError(c, 40000, "Parameter Error: "+err.Error())
  405. return
  406. }
  407. res, err := service.SelectionInfoService{}.GetSelectionDraftList(param)
  408. if err != nil {
  409. logrus.Errorf("[SelectionTaskList] call Show err:%+v\n", err)
  410. returnError(c, 40000, err.Error())
  411. return
  412. }
  413. returnSuccess(c, 20000, res)
  414. }
  415. // 草稿箱——品牌种草
  416. func (t TaskController) GetProjectDraftList(c *gin.Context) {
  417. param := &vo.ProjectDraftParam{}
  418. err := c.BindJSON(param)
  419. if err != nil {
  420. logrus.Errorf("Request bind err:%+v\n", err)
  421. returnError(c, 40000, "Parameter Error: "+err.Error())
  422. return
  423. }
  424. res, err := service.ProjectService{}.GetProjectDraftList(param)
  425. if err != nil {
  426. logrus.Errorf("[ProjectTaskList] call Show err:%+v\n", err)
  427. returnError(c, 40000, err.Error())
  428. return
  429. }
  430. returnSuccess(c, 20000, res)
  431. }
  432. // 草稿箱——本地生活
  433. func (t TaskController) GetLocalLifeDraftList(c *gin.Context) {
  434. param := &vo.LocalDraftParam{}
  435. err := c.BindJSON(param)
  436. if err != nil {
  437. logrus.Errorf("Request bind err:%+v\n", err)
  438. returnError(c, 40000, "Parameter Error: "+err.Error())
  439. return
  440. }
  441. res, err := service.LocalLifeService{}.GetLocalLifeDraftList(param)
  442. if err != nil {
  443. logrus.Errorf("[LocalLifeTaskList] call Show err:%+v\n", err)
  444. returnError(c, 40000, err.Error())
  445. return
  446. }
  447. returnSuccess(c, 20000, res)
  448. }
  449. // 违约管理——违约公开任务列表
  450. func (t TaskController) GetPublicDefaultList(c *gin.Context) {
  451. param := &vo.DefaultSearchParam{}
  452. err := c.BindJSON(param)
  453. if err != nil {
  454. logrus.Errorf("Request bind err:%+v\n", err)
  455. returnError(c, 40000, "Parameter Error: "+err.Error())
  456. return
  457. }
  458. res, err := service.DefaultService{}.GetPublicDefaultList(param)
  459. if err != nil {
  460. logrus.Errorf("[GetPublicDefaultList] call Show err:%+v\n", err)
  461. returnError(c, 40000, err.Error())
  462. return
  463. }
  464. returnSuccess(c, 20000, res)
  465. }
  466. // 违约管理——违约定向任务列表
  467. func (t TaskController) GetTargetDefaultList(c *gin.Context) {
  468. param := &vo.DefaultSearchParam{}
  469. err := c.BindJSON(param)
  470. if err != nil {
  471. logrus.Errorf("Request bind err:%+v\n", err)
  472. returnError(c, 40000, "Parameter Error: "+err.Error())
  473. return
  474. }
  475. res, err := service.DefaultService{}.GetTargetDefaultList(param)
  476. if err != nil {
  477. logrus.Errorf("[GetTargetDefaultList] call Show err:%+v\n", err)
  478. returnError(c, 40000, err.Error())
  479. return
  480. }
  481. returnSuccess(c, 20000, res)
  482. }
  483. // 违约管理——公开任务-违约达人列表
  484. func (t TaskController) GetPublicDefaultTalentList(c *gin.Context) {
  485. param := &vo.DefaultSearchParam{}
  486. err := c.BindJSON(param)
  487. if err != nil {
  488. logrus.Errorf("Request bind err:%+v\n", err)
  489. returnError(c, 40000, "Parameter Error: "+err.Error())
  490. return
  491. }
  492. res, err := service.DefaultService{}.GetPublicDefaultTalentList(param)
  493. if err != nil {
  494. logrus.Errorf("[GetPublicDefaultTalentList] call Show err:%+v\n", err)
  495. returnError(c, 40000, err.Error())
  496. return
  497. }
  498. returnSuccess(c, 20000, res)
  499. }
  500. // 违约管理——公开任务-违约达人列表角标
  501. func (t TaskController) GetPublicDefaultTalentCount(c *gin.Context) {
  502. param := &vo.DefaultSearchParam{}
  503. err := c.BindJSON(param)
  504. if err != nil {
  505. logrus.Errorf("Request bind err:%+v\n", err)
  506. returnError(c, 40000, "Parameter Error: "+err.Error())
  507. return
  508. }
  509. res, _ := service.DefaultService{}.GetPublicDefaultTalentCount(param)
  510. returnSuccess(c, 20000, res)
  511. }
  512. // 违约管理——定向任务-违约达人列表
  513. func (t TaskController) GetTargetDefaultTalentList(c *gin.Context) {
  514. param := &vo.DefaultSearchParam{}
  515. err := c.BindJSON(param)
  516. if err != nil {
  517. logrus.Errorf("Request bind err:%+v\n", err)
  518. returnError(c, 40000, "Parameter Error: "+err.Error())
  519. return
  520. }
  521. res, err := service.DefaultService{}.GetTargetDefaultTalentList(param)
  522. if err != nil {
  523. logrus.Errorf("[GetTargetDefaultTalentList] call Show err:%+v\n", err)
  524. returnError(c, 40000, err.Error())
  525. return
  526. }
  527. returnSuccess(c, 20000, res)
  528. }
  529. // 违约管理——达人解约
  530. func (t TaskController) CancelTalent(c *gin.Context) {
  531. param := &vo.TalentCancelParam{}
  532. err := c.BindJSON(param)
  533. if err != nil || param.TaskId == "" {
  534. logrus.Errorf("Request bind err:%+v\n", err)
  535. returnError(c, 40000, "Parameter Error: "+err.Error())
  536. return
  537. }
  538. err = service.DefaultService{}.CancelTalent(param)
  539. if err != nil {
  540. logrus.Errorf("[CancelTalent] call Show err:%+v\n", err)
  541. returnError(c, 40000, err.Error())
  542. return
  543. }
  544. resultMap := make(map[string]string)
  545. resultMap["taskId"] = param.TaskId
  546. returnSuccess(c, 20000, resultMap)
  547. }
  548. // 违约管理——达人批量解约
  549. func (t TaskController) CancelTalentList(c *gin.Context) {
  550. param := &vo.TalentCancelParam{}
  551. err := c.BindJSON(param)
  552. if err != nil || param.TaskIds == nil {
  553. logrus.Errorf("Request bind err:%+v\n", err)
  554. returnError(c, 40000, "Parameter Error: "+err.Error())
  555. return
  556. }
  557. err = service.DefaultService{}.CancelTalentList(param)
  558. if err != nil {
  559. logrus.Errorf("[CancelTalentList] call Show err:%+v\n", err)
  560. returnError(c, 40000, err.Error())
  561. return
  562. }
  563. resultMap := make(map[string][]string)
  564. resultMap["taskIds"] = param.TaskIds
  565. returnSuccess(c, 20000, resultMap)
  566. }
  567. // 服务商合作-服务商列表
  568. func (o TaskController) GetSupplierInTargetTaskList(c *gin.Context) {
  569. param := &vo.SupplierSearchInTargetTaskParam{}
  570. err := c.BindJSON(param)
  571. if err != nil || "" == param.EnterpriseId {
  572. logrus.Errorf("Request bind err:%+v\n", err)
  573. returnError(c, 40000, "Parameter Error: "+err.Error())
  574. return
  575. }
  576. result, err1 := service.CooperationService{}.GetSupplierInTargetTaskList(param)
  577. if err1 != nil {
  578. logrus.Errorf("[GetSuplierList] call Show err:%+v\n", err)
  579. returnError(c, 40000, err.Error())
  580. return
  581. }
  582. returnSuccess(c, 20000, result)
  583. }
  584. // 服务商合作-服务商列表角标
  585. func (t TaskController) GetSupplierInTargetCount(c *gin.Context) {
  586. param := &vo.SupplierSearchInTargetTaskParam{}
  587. err := c.BindJSON(param)
  588. if err != nil || "" == param.EnterpriseId {
  589. logrus.Errorf("Request bind err:%+v\n", err)
  590. returnError(c, 40000, "Parameter Error: "+err.Error())
  591. return
  592. }
  593. res := service.CooperationService{}.GetSupplierInTargetCount(param)
  594. returnSuccess(c, 20000, res)
  595. }
  596. // 服务商合作-邀约合作
  597. func (o TaskController) InviteSupplier(c *gin.Context) {
  598. param := &vo.SupplierInviteInTargetTaskParam{}
  599. err := c.BindJSON(param)
  600. if err != nil {
  601. logrus.Errorf("Request bind err:%+v\n", err)
  602. returnError(c, 40000, "Parameter Error: "+err.Error())
  603. return
  604. }
  605. err1 := service.CooperationService{}.InviteSupplierInTargetTask(param)
  606. if err1 != nil {
  607. logrus.Errorf("[InviteSupplier] call Show err:%+v\n", err)
  608. returnError(c, 40000, err.Error())
  609. return
  610. }
  611. returnSuccess(c, 20000, nil)
  612. }
  613. // 门店类目
  614. func (t TaskController) GetStoreCategory(c *gin.Context) {
  615. res, err := service.StoreService{}.GetStoreCategory()
  616. if err != nil {
  617. logrus.Errorf("[GetStoreCategory] call Show err:%+v\n", err)
  618. returnError(c, 40000, err.Error())
  619. return
  620. }
  621. returnSuccess(c, 20000, res)
  622. }
  623. // 达人内容类型
  624. func (t TaskController) GetTalentCategory(c *gin.Context) {
  625. res, err := service.ProjectService{}.GetTalentCategory()
  626. if err != nil {
  627. logrus.Errorf("[GetTalentCategory] call Show err:%+v\n", err)
  628. returnError(c, 40000, err.Error())
  629. return
  630. }
  631. returnSuccess(c, 20000, res)
  632. }
  633. // 关联门店-已有门店展示
  634. func (t TaskController) GetAllStore(c *gin.Context) {
  635. search := vo.GetAllStoreParam{}
  636. err := c.BindJSON(&search)
  637. if err != nil || search.EnterpriseId == "" {
  638. logrus.Errorf("Request bind err:%+v\n", err)
  639. returnError(c, 40000, "Parameter Error: "+err.Error())
  640. return
  641. }
  642. var result vo.ResultVO
  643. result, err = service.StoreService{}.GetStoresByEnterpriseId(search)
  644. if err != nil {
  645. logrus.Errorf("[GetAllStore] call Show err:%+v\n", err)
  646. returnError(c, 40000, err.Error())
  647. return
  648. }
  649. returnSuccess(c, 20000, result)
  650. }
  651. // 关联门店-新建门店
  652. func (t TaskController) CreateStore(c *gin.Context) {
  653. param := &vo.StoreCreateParam{}
  654. err := c.BindJSON(param)
  655. if err != nil {
  656. logrus.Errorf("Request bind err:%+v\n", err)
  657. returnError(c, 40000, "Parameter Error: "+err.Error())
  658. return
  659. }
  660. storeId, err := service.StoreService{}.CreateStore(param)
  661. if err != nil {
  662. logrus.Errorf("[CreateStore] call Show err:%+v\n", err)
  663. returnError(c, 40000, err.Error())
  664. return
  665. }
  666. resultMap := make(map[string]int64)
  667. resultMap["storeId"] = storeId
  668. returnSuccess(c, 20000, resultMap)
  669. }
  670. // 门店团购列表
  671. func (t TaskController) GetAllTeamBuying(c *gin.Context) {
  672. search := vo.GetAllTeamBuyingParam{}
  673. err := c.BindJSON(&search)
  674. if err != nil || search.StoreId == 0 {
  675. logrus.Errorf("Request bind err:%+v\n", err)
  676. returnError(c, 40000, "Parameter Error: "+err.Error())
  677. return
  678. }
  679. var result vo.ResultVO
  680. result, err = service.TeamBuyingService{}.GetTeamBuyingsByStoreId(search)
  681. if err != nil {
  682. logrus.Errorf("[GetAllTeamBuying] call Show err:%+v\n", err)
  683. returnError(c, 40000, err.Error())
  684. return
  685. }
  686. returnSuccess(c, 20000, result)
  687. }
  688. // 新建团购
  689. func (t TaskController) CreateTeamBuying(c *gin.Context) {
  690. param := &vo.TeamBuyingCreateParam{}
  691. err := c.BindJSON(param)
  692. if err != nil {
  693. logrus.Errorf("Request bind err:%+v\n", err)
  694. returnError(c, 40000, "Parameter Error: "+err.Error())
  695. return
  696. }
  697. teamBuyingId, err := service.TeamBuyingService{}.CreateTeamBuying(param)
  698. if err != nil {
  699. logrus.Errorf("[CreateTeamBuying] call Show err:%+v\n", err)
  700. returnError(c, 40000, err.Error())
  701. return
  702. }
  703. resultMap := make(map[string]int64)
  704. resultMap["teamBuyingId"] = teamBuyingId
  705. returnSuccess(c, 20000, resultMap)
  706. }
  707. // 创建本地生活任务
  708. func (t TaskController) CreateLocalLife(c *gin.Context) {
  709. data := &vo.LocalCreateParam{}
  710. err := c.BindJSON(data)
  711. if err != nil {
  712. logrus.Errorf("Request bind err:%+v\n", err)
  713. returnError(c, 40000, "Parameter Error: "+err.Error())
  714. return
  715. }
  716. localId, err := service.LocalLifeService{}.CreateLocalLife(data)
  717. if err != nil {
  718. logrus.Errorf("[CreateLocalLife] call CreateLocalLife err:%+v\n", err)
  719. returnError(c, 40000, err.Error())
  720. return
  721. }
  722. resultMap := make(map[string]string)
  723. resultMap["localId"] = *localId
  724. returnSuccess(c, 20000, resultMap)
  725. }
  726. // 更新本地生活任务
  727. func (t TaskController) UpdateLocalLife(c *gin.Context) {
  728. data := &vo.LocalUpdateParam{}
  729. err := c.BindJSON(data)
  730. if err != nil {
  731. logrus.Errorf("Request bind err:%+v\n", err)
  732. returnError(c, 40000, "Parameter Error: "+err.Error())
  733. return
  734. }
  735. localId, err := service.LocalLifeService{}.UpdateLocal(data)
  736. if err != nil {
  737. logrus.Errorf("[UpdateLocalLife] call UpdateLocalLife err:%+v\n", err)
  738. returnError(c, 40000, err.Error())
  739. return
  740. }
  741. resultMap := make(map[string]string)
  742. resultMap["localId"] = *localId
  743. returnSuccess(c, 20000, resultMap)
  744. }
  745. // 更新定向本地生活任务
  746. func (t TaskController) UpdateLocalLifeTarget(c *gin.Context) {
  747. data := &vo.LocalUpdateParam{}
  748. err := c.BindJSON(data)
  749. if err != nil {
  750. logrus.Errorf("Request bind err:%+v\n", err)
  751. returnError(c, 40000, "Parameter Error: "+err.Error())
  752. return
  753. }
  754. localId, err := service.LocalLifeService{}.UpdateLocalTarget(data)
  755. if err != nil {
  756. logrus.Errorf("[UpdateLocalLifeTarget] call UpdateLocalLifeTarget err:%+v\n", err)
  757. returnError(c, 40000, err.Error())
  758. return
  759. }
  760. resultMap := make(map[string]string)
  761. resultMap["localId"] = *localId
  762. returnSuccess(c, 20000, resultMap)
  763. }
  764. // 本地生活任务预览
  765. func (t TaskController) GetLocalLifeDetail(c *gin.Context) {
  766. param := &LocalLifeDetailParam{}
  767. err := c.BindJSON(param)
  768. if err != nil {
  769. logrus.Errorf("Request bind err:%+v\n", err)
  770. returnError(c, 40000, "Parameter Error: "+err.Error())
  771. return
  772. }
  773. res, err := service.LocalLifeService{}.GetLocalLifeDetail(param.LocalLifeId)
  774. if err != nil {
  775. logrus.Errorf("[GetLocalLifeDetail] call Show err:%+v\n", err)
  776. returnError(c, 40000, err.Error())
  777. return
  778. }
  779. returnSuccess(c, 20000, res)
  780. }
  781. // 本地生活复制任务
  782. func (t TaskController) CopyLocalLife(c *gin.Context) {
  783. data := &vo.LocalSearchParam{}
  784. err := c.BindJSON(data)
  785. if err != nil {
  786. logrus.Errorf("Request bind err:%+v\n", err)
  787. returnError(c, 40000, "Parameter Error: "+err.Error())
  788. return
  789. }
  790. localId, err := service.LocalLifeService{}.CopyLocalLife(data)
  791. if err != nil {
  792. if err.Error() == "任务不存在" {
  793. returnError(c, 30000, err.Error())
  794. return
  795. }
  796. logrus.Errorf("[CreateLocalLife] call CreateLocalLife err:%+v\n", err)
  797. returnError(c, 40000, err.Error())
  798. return
  799. }
  800. resultMap := make(map[string]string)
  801. resultMap["localId"] = *localId
  802. returnSuccess(c, 20000, resultMap)
  803. }
  804. // 本地生活提交审核
  805. func (t TaskController) LocalLifeToReview(c *gin.Context) {
  806. data := &vo.LocalUpdateParam{}
  807. err := c.BindJSON(data)
  808. if err != nil || data.LocalID == "" {
  809. logrus.Errorf("Request bind err:%+v\n", err)
  810. returnError(c, 40000, "Parameter Error: "+err.Error())
  811. return
  812. }
  813. localId, err := service.LocalLifeService{}.LocalLifeToReview(data)
  814. if err != nil {
  815. logrus.Errorf("[ProjectToReview] call ProjectToReview err:%+v\n", err)
  816. returnError(c, 40000, err.Error())
  817. return
  818. }
  819. resultMap := make(map[string]string)
  820. resultMap["localId"] = *localId
  821. returnSuccess(c, 20000, resultMap)
  822. }
  823. // 带货待发货、待签收、已签收统计
  824. func (t TaskController) LogisticsSelectionTalentCount(c *gin.Context) {
  825. param := &vo.LogisticsSelectionTalentParam{}
  826. err := c.BindJSON(param)
  827. if err != nil || "" == param.SelectionId {
  828. logrus.Errorf("Request bind err:%+v\n", err)
  829. returnError(c, 40000, "Parameter Error: "+err.Error())
  830. return
  831. }
  832. res := service.TaskInfoService{}.LogisticsSelectionTalentCount(param)
  833. returnSuccess(c, 20000, res)
  834. }
  835. // 种草达人物流列表
  836. func (t TaskController) LogisticsTalentList(c *gin.Context) {
  837. param := &vo.LogisticsTalentParam{}
  838. err := c.BindJSON(param)
  839. if err != nil || "" == param.ProjectId {
  840. logrus.Errorf("Request bind err:%+v\n", err)
  841. returnError(c, 40000, "Parameter Error: "+err.Error())
  842. return
  843. }
  844. res, err := service.TaskInfoService{}.LogisticsTalentList(param)
  845. if err != nil {
  846. logrus.Errorf("[LogisticsTalentList] call LogisticsTalentList err:%+v\n", err)
  847. returnError(c, 40000, err.Error())
  848. return
  849. }
  850. returnSuccess(c, 20000, res)
  851. }
  852. // 种草待发货、待签收、已签收统计
  853. func (t TaskController) LogisticsTalentCount(c *gin.Context) {
  854. param := &vo.LogisticsTalentParam{}
  855. err := c.BindJSON(param)
  856. if err != nil || "" == param.ProjectId {
  857. logrus.Errorf("Request bind err:%+v\n", err)
  858. returnError(c, 40000, "Parameter Error: "+err.Error())
  859. return
  860. }
  861. res := service.TaskInfoService{}.LogisticsTalentCount(param)
  862. returnSuccess(c, 20000, res)
  863. }
  864. // 本地生活列表
  865. func (t TaskController) LocalLifeTaskList(c *gin.Context) {
  866. param := &vo.LocalSearchParam{}
  867. err := c.BindJSON(param)
  868. if err != nil {
  869. logrus.Errorf("Request bind err:%+v\n", err)
  870. returnError(c, 40000, "Parameter Error: "+err.Error())
  871. return
  872. }
  873. res, err := service.LocalLifeService{}.GetLocalLifeTaskList(param)
  874. if err != nil {
  875. logrus.Errorf("[LocalLifeTaskList] call GetLocalLifeTaskList err:%+v\n", err)
  876. returnError(c, 40000, err.Error())
  877. return
  878. }
  879. returnSuccess(c, 20000, res)
  880. }
  881. // 删除本地生活任务
  882. func (t TaskController) LocalLifeDel(c *gin.Context) {
  883. param := &vo.LocalSearchParam{}
  884. err := c.BindJSON(param)
  885. if err != nil {
  886. logrus.Errorf("Request bind err:%+v\n", err)
  887. returnError(c, 40000, "Parameter Error: "+err.Error())
  888. return
  889. }
  890. localId, err := service.LocalLifeService{}.DeleteLocalLife(param.LocalId)
  891. if err != nil {
  892. logrus.Errorf("[DeleteLocalLife] call DeleteLocalLife err:%+v\n", err)
  893. returnError(c, 40000, err.Error())
  894. return
  895. }
  896. resultMap := make(map[string]string)
  897. resultMap["localId"] = *localId
  898. returnSuccess(c, 20000, resultMap)
  899. }
  900. // 结束本地生活任务
  901. func (t TaskController) LocalLifeClose(c *gin.Context) {
  902. param := &vo.LocalSearchParam{}
  903. err := c.BindJSON(param)
  904. if err != nil {
  905. logrus.Errorf("Request bind err:%+v\n", err)
  906. returnError(c, 40000, "Parameter Error: "+err.Error())
  907. return
  908. }
  909. localId, err := service.LocalLifeService{}.CloseLocalLife(param.LocalId)
  910. if err != nil {
  911. logrus.Errorf("[CloseLocalLife] call CloseLocalLife err:%+v\n", err)
  912. returnError(c, 40000, err.Error())
  913. return
  914. }
  915. resultMap := make(map[string]string)
  916. resultMap["localId"] = *localId
  917. returnSuccess(c, 20000, resultMap)
  918. }
  919. // 探店本地生活列表
  920. func (t TaskController) StoreExploreList(c *gin.Context) {
  921. param := &vo.LocalSearchParam{}
  922. err := c.BindJSON(param)
  923. if err != nil {
  924. logrus.Errorf("Request bind err:%+v\n", err)
  925. returnError(c, 40000, "Parameter Error: "+err.Error())
  926. return
  927. }
  928. res, err := service.LocalLifeService{}.GetStoreExploreList(param)
  929. if err != nil {
  930. logrus.Errorf("[StoreExploreList] call StoreExploreList err:%+v\n", err)
  931. returnError(c, 40000, err.Error())
  932. return
  933. }
  934. returnSuccess(c, 20000, res)
  935. }
  936. // 探店达人详情
  937. func (t TaskController) StoreExploreInfo(c *gin.Context) {
  938. param := &vo.StoreExploreParam{}
  939. err := c.BindJSON(param)
  940. if err != nil {
  941. logrus.Errorf("Request bind err:%+v\n", err)
  942. returnError(c, 40000, "Parameter Error: "+err.Error())
  943. return
  944. }
  945. res, err := service.LocalLifeService{}.GetStoreExploreInfo(param)
  946. if err != nil {
  947. logrus.Errorf("[StoreExploreInfo] call Show err:%+v\n", err)
  948. returnError(c, 40000, err.Error())
  949. return
  950. }
  951. returnSuccess(c, 20000, res)
  952. }
  953. // 探店达人列表角标
  954. func (t TaskController) StoreExploreInfoCount(c *gin.Context) {
  955. param := &vo.StoreExploreParam{}
  956. err := c.BindJSON(param)
  957. if err != nil || "" == param.LocalLifeId {
  958. logrus.Errorf("Request bind err:%+v\n", err)
  959. returnError(c, 40000, "Parameter Error: "+err.Error())
  960. return
  961. }
  962. res := service.LocalLifeService{}.StoreExploreInfoCount(param)
  963. returnSuccess(c, 20000, res)
  964. }
  965. // 探店终止合作
  966. func (t TaskController) StoreExploreOver(c *gin.Context) {
  967. param := &vo.LocalTalentOperateParam{}
  968. err := c.BindJSON(param)
  969. if err != nil || param.TaskId == "" {
  970. logrus.Errorf("Request bind err:%+v\n", err)
  971. returnError(c, 40000, "Parameter Error: "+err.Error())
  972. return
  973. }
  974. res, err := service.LocalLifeService{}.StoreExploreOver(param)
  975. if err != nil {
  976. logrus.Errorf("[StoreExploreOver] call Show err:%+v\n", err)
  977. returnError(c, 40000, err.Error())
  978. return
  979. }
  980. returnSuccess(c, 20000, res)
  981. }
  982. // 预约时间批量同意/驳回
  983. func (t TaskController) StoreExploreOperate(c *gin.Context) {
  984. param := &vo.LocalTalentOperateParam{}
  985. err := c.BindJSON(param)
  986. if err != nil || param.TaskIds == nil {
  987. logrus.Errorf("Request bind err:%+v\n", err)
  988. returnError(c, 40000, "Parameter Error: "+err.Error())
  989. return
  990. }
  991. err = service.LocalLifeService{}.StoreExploreOperate(param)
  992. if err != nil {
  993. logrus.Errorf("[StoreExploreOperate] call Show err:%+v\n", err)
  994. returnError(c, 40000, err.Error())
  995. return
  996. }
  997. returnSuccess(c, 20000, nil)
  998. }
  999. // 电商带货看数据-达人数据
  1000. func (t TaskController) TalentDataDetail(c *gin.Context) {
  1001. param := &vo.SelectionShowDataParam{}
  1002. err := c.BindJSON(param)
  1003. if err != nil {
  1004. logrus.Errorf("Request bind err:%+v\n", err)
  1005. returnError(c, 40000, "Parameter Error: "+err.Error())
  1006. return
  1007. }
  1008. result, err := service.ViewDataService{}.SelectionTalentDataDetail(param)
  1009. if err != nil {
  1010. logrus.Errorf("[TalentDataDetail] call Show err:%+v\n", err)
  1011. returnError(c, 40000, err.Error())
  1012. return
  1013. }
  1014. resultMap := make(map[string]vo.ReSelectionTalentData)
  1015. resultMap["dataInfo"] = result
  1016. returnSuccess(c, 20000, resultMap)
  1017. }
  1018. // 电商带货看数据-领样数据
  1019. func (t TaskController) SampleDataDetail(c *gin.Context) {
  1020. param := &vo.SelectionShowDataParam{}
  1021. err := c.BindJSON(param)
  1022. if err != nil {
  1023. logrus.Errorf("Request bind err:%+v\n", err)
  1024. returnError(c, 40000, "Parameter Error: "+err.Error())
  1025. return
  1026. }
  1027. result, err := service.ViewDataService{}.SelectionSampleDataDetail(param)
  1028. if err != nil {
  1029. logrus.Errorf("[SampleDataDetail] call Show err:%+v\n", err)
  1030. returnError(c, 40000, err.Error())
  1031. return
  1032. }
  1033. resultMap := make(map[string]vo.ReSelectionSampleData)
  1034. resultMap["dataInfo"] = result
  1035. returnSuccess(c, 20000, resultMap)
  1036. }
  1037. // 电商带货看数据-带货数据
  1038. func (t TaskController) SelectionDataDetail(c *gin.Context) {
  1039. param := &vo.SelectionShowDataParam{}
  1040. err := c.BindJSON(param)
  1041. if err != nil {
  1042. logrus.Errorf("Request bind err:%+v\n", err)
  1043. returnError(c, 40000, "Parameter Error: "+err.Error())
  1044. return
  1045. }
  1046. result, err := service.ViewDataService{}.SelectionDataDetail(param)
  1047. if err != nil {
  1048. logrus.Errorf("[SelectionDataDetail] call Show err:%+v\n", err)
  1049. returnError(c, 40000, err.Error())
  1050. return
  1051. }
  1052. resultMap := make(map[string]vo.ReSelectionData)
  1053. resultMap["dataInfo"] = result
  1054. returnSuccess(c, 20000, resultMap)
  1055. }
  1056. // 电商带货执行中-悬赏兑现
  1057. func (t TaskController) SelectionRewardCash(c *gin.Context) {
  1058. param := &vo.SelectionRewardCashParam{}
  1059. err := c.BindJSON(param)
  1060. if err != nil {
  1061. logrus.Errorf("Request bind err:%+v\n", err)
  1062. returnError(c, 40000, "Parameter Error: "+err.Error())
  1063. return
  1064. }
  1065. result, err1 := service.TaskInfoService{}.SelectionRewardCashDetail(param)
  1066. if err1 != nil {
  1067. logrus.Errorf("[SelectionRewardCash] call Show err:%+v\n", err)
  1068. returnError(c, 40000, err1.Error())
  1069. return
  1070. }
  1071. returnSuccess(c, 20000, result)
  1072. }