task_controller.go 31 KB

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