task_controller.go 33 KB

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