task_controller.go 33 KB

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