task_controller.go 33 KB

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