task_controller.go 33 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154
  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) GetPublicDefaultTalentCount(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, _ := service.DefaultService{}.GetPublicDefaultTalentCount(param)
  509. returnSuccess(c, 20000, res)
  510. }
  511. // 违约管理——定向任务-违约达人列表
  512. func (t TaskController) GetTargetDefaultTalentList(c *gin.Context) {
  513. param := &vo.DefaultSearchParam{}
  514. err := c.BindJSON(param)
  515. if err != nil {
  516. logrus.Errorf("Request bind err:%+v\n", err)
  517. returnError(c, 40000, "Parameter Error: "+err.Error())
  518. return
  519. }
  520. res, err := service.DefaultService{}.GetTargetDefaultTalentList(param)
  521. if err != nil {
  522. logrus.Errorf("[GetTargetDefaultTalentList] call Show err:%+v\n", err)
  523. returnError(c, 40000, err.Error())
  524. return
  525. }
  526. returnSuccess(c, 20000, res)
  527. }
  528. // 违约管理——达人解约
  529. func (t TaskController) CancelTalent(c *gin.Context) {
  530. param := &vo.TalentCancelParam{}
  531. err := c.BindJSON(param)
  532. if err != nil || param.TaskId == "" {
  533. logrus.Errorf("Request bind err:%+v\n", err)
  534. returnError(c, 40000, "Parameter Error: "+err.Error())
  535. return
  536. }
  537. err = service.DefaultService{}.CancelTalent(param)
  538. if err != nil {
  539. logrus.Errorf("[CancelTalent] call Show err:%+v\n", err)
  540. returnError(c, 40000, err.Error())
  541. return
  542. }
  543. resultMap := make(map[string]string)
  544. resultMap["taskId"] = param.TaskId
  545. returnSuccess(c, 20000, resultMap)
  546. }
  547. // 违约管理——达人批量解约
  548. func (t TaskController) CancelTalentList(c *gin.Context) {
  549. param := &vo.TalentCancelParam{}
  550. err := c.BindJSON(param)
  551. if err != nil || param.TaskIds == nil {
  552. logrus.Errorf("Request bind err:%+v\n", err)
  553. returnError(c, 40000, "Parameter Error: "+err.Error())
  554. return
  555. }
  556. err = service.DefaultService{}.CancelTalentList(param)
  557. if err != nil {
  558. logrus.Errorf("[CancelTalentList] call Show err:%+v\n", err)
  559. returnError(c, 40000, err.Error())
  560. return
  561. }
  562. resultMap := make(map[string][]string)
  563. resultMap["taskIds"] = param.TaskIds
  564. returnSuccess(c, 20000, resultMap)
  565. }
  566. // 服务商合作-服务商列表
  567. func (o TaskController) GetSupplierInTargetTaskList(c *gin.Context) {
  568. param := &vo.SupplierSearchInTargetTaskParam{}
  569. err := c.BindJSON(param)
  570. if err != nil || "" == param.EnterpriseId {
  571. logrus.Errorf("Request bind err:%+v\n", err)
  572. returnError(c, 40000, "Parameter Error: "+err.Error())
  573. return
  574. }
  575. result, err1 := service.CooperationService{}.GetSupplierInTargetTaskList(param)
  576. if err1 != nil {
  577. logrus.Errorf("[GetSuplierList] call Show err:%+v\n", err)
  578. returnError(c, 40000, err.Error())
  579. return
  580. }
  581. returnSuccess(c, 20000, result)
  582. }
  583. // 服务商合作-服务商列表角标
  584. func (t TaskController) GetSupplierInTargetCount(c *gin.Context) {
  585. param := &vo.SupplierSearchInTargetTaskParam{}
  586. err := c.BindJSON(param)
  587. if err != nil || "" == param.EnterpriseId {
  588. logrus.Errorf("Request bind err:%+v\n", err)
  589. returnError(c, 40000, "Parameter Error: "+err.Error())
  590. return
  591. }
  592. res := service.CooperationService{}.GetSupplierInTargetCount(param)
  593. returnSuccess(c, 20000, res)
  594. }
  595. // 服务商合作-邀约合作
  596. func (o TaskController) InviteSupplier(c *gin.Context) {
  597. param := &vo.SupplierInviteInTargetTaskParam{}
  598. err := c.BindJSON(param)
  599. if err != nil {
  600. logrus.Errorf("Request bind err:%+v\n", err)
  601. returnError(c, 40000, "Parameter Error: "+err.Error())
  602. return
  603. }
  604. err1 := service.CooperationService{}.InviteSupplierInTargetTask(param)
  605. if err1 != nil {
  606. logrus.Errorf("[InviteSupplier] call Show err:%+v\n", err)
  607. returnError(c, 40000, err.Error())
  608. return
  609. }
  610. returnSuccess(c, 20000, nil)
  611. }
  612. // 门店类目
  613. func (t TaskController) GetStoreCategory(c *gin.Context) {
  614. res, err := service.StoreService{}.GetStoreCategory()
  615. if err != nil {
  616. logrus.Errorf("[GetStoreCategory] call Show err:%+v\n", err)
  617. returnError(c, 40000, err.Error())
  618. return
  619. }
  620. returnSuccess(c, 20000, res)
  621. }
  622. // 达人内容类型
  623. func (t TaskController) GetTalentCategory(c *gin.Context) {
  624. res, err := service.ProjectService{}.GetTalentCategory()
  625. if err != nil {
  626. logrus.Errorf("[GetTalentCategory] call Show err:%+v\n", err)
  627. returnError(c, 40000, err.Error())
  628. return
  629. }
  630. returnSuccess(c, 20000, res)
  631. }
  632. // 关联门店-已有门店展示
  633. func (t TaskController) GetAllStore(c *gin.Context) {
  634. search := vo.GetAllStoreParam{}
  635. err := c.BindJSON(&search)
  636. if err != nil || search.EnterpriseId == "" {
  637. logrus.Errorf("Request bind err:%+v\n", err)
  638. returnError(c, 40000, "Parameter Error: "+err.Error())
  639. return
  640. }
  641. var result vo.ResultVO
  642. result, err = service.StoreService{}.GetStoresByEnterpriseId(search)
  643. if err != nil {
  644. logrus.Errorf("[GetAllStore] call Show err:%+v\n", err)
  645. returnError(c, 40000, err.Error())
  646. return
  647. }
  648. returnSuccess(c, 20000, result)
  649. }
  650. // 关联门店-新建门店
  651. func (t TaskController) CreateStore(c *gin.Context) {
  652. param := &vo.StoreCreateParam{}
  653. err := c.BindJSON(param)
  654. if err != nil {
  655. logrus.Errorf("Request bind err:%+v\n", err)
  656. returnError(c, 40000, "Parameter Error: "+err.Error())
  657. return
  658. }
  659. storeId, err := service.StoreService{}.CreateStore(param)
  660. if err != nil {
  661. logrus.Errorf("[CreateStore] call Show err:%+v\n", err)
  662. returnError(c, 40000, err.Error())
  663. return
  664. }
  665. resultMap := make(map[string]int64)
  666. resultMap["storeId"] = storeId
  667. returnSuccess(c, 20000, resultMap)
  668. }
  669. // 门店团购列表
  670. func (t TaskController) GetAllTeamBuying(c *gin.Context) {
  671. search := vo.GetAllTeamBuyingParam{}
  672. err := c.BindJSON(&search)
  673. if err != nil || search.StoreId == 0 {
  674. logrus.Errorf("Request bind err:%+v\n", err)
  675. returnError(c, 40000, "Parameter Error: "+err.Error())
  676. return
  677. }
  678. var result vo.ResultVO
  679. result, err = service.TeamBuyingService{}.GetTeamBuyingsByStoreId(search)
  680. if err != nil {
  681. logrus.Errorf("[GetAllTeamBuying] call Show err:%+v\n", err)
  682. returnError(c, 40000, err.Error())
  683. return
  684. }
  685. returnSuccess(c, 20000, result)
  686. }
  687. // 新建团购
  688. func (t TaskController) CreateTeamBuying(c *gin.Context) {
  689. param := &vo.TeamBuyingCreateParam{}
  690. err := c.BindJSON(param)
  691. if err != nil {
  692. logrus.Errorf("Request bind err:%+v\n", err)
  693. returnError(c, 40000, "Parameter Error: "+err.Error())
  694. return
  695. }
  696. teamBuyingId, err := service.TeamBuyingService{}.CreateTeamBuying(param)
  697. if err != nil {
  698. logrus.Errorf("[CreateTeamBuying] call Show err:%+v\n", err)
  699. returnError(c, 40000, err.Error())
  700. return
  701. }
  702. resultMap := make(map[string]int64)
  703. resultMap["teamBuyingId"] = teamBuyingId
  704. returnSuccess(c, 20000, resultMap)
  705. }
  706. // 创建本地生活任务
  707. func (t TaskController) CreateLocalLife(c *gin.Context) {
  708. data := &vo.LocalCreateParam{}
  709. err := c.BindJSON(data)
  710. if err != nil {
  711. logrus.Errorf("Request bind err:%+v\n", err)
  712. returnError(c, 40000, "Parameter Error: "+err.Error())
  713. return
  714. }
  715. localId, err := service.LocalLifeService{}.CreateLocalLife(data)
  716. if err != nil {
  717. logrus.Errorf("[CreateLocalLife] call CreateLocalLife err:%+v\n", err)
  718. returnError(c, 40000, err.Error())
  719. return
  720. }
  721. resultMap := make(map[string]string)
  722. resultMap["localId"] = *localId
  723. returnSuccess(c, 20000, resultMap)
  724. }
  725. // 更新本地生活任务
  726. func (t TaskController) UpdateLocalLife(c *gin.Context) {
  727. data := &vo.LocalUpdateParam{}
  728. err := c.BindJSON(data)
  729. if err != nil {
  730. logrus.Errorf("Request bind err:%+v\n", err)
  731. returnError(c, 40000, "Parameter Error: "+err.Error())
  732. return
  733. }
  734. localId, err := service.LocalLifeService{}.UpdateLocal(data)
  735. if err != nil {
  736. logrus.Errorf("[UpdateLocalLife] call UpdateLocalLife err:%+v\n", err)
  737. returnError(c, 40000, err.Error())
  738. return
  739. }
  740. resultMap := make(map[string]string)
  741. resultMap["localId"] = *localId
  742. returnSuccess(c, 20000, resultMap)
  743. }
  744. // 更新定向本地生活任务
  745. func (t TaskController) UpdateLocalLifeTarget(c *gin.Context) {
  746. data := &vo.LocalUpdateParam{}
  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{}.UpdateLocalTarget(data)
  754. if err != nil {
  755. logrus.Errorf("[UpdateLocalLifeTarget] call UpdateLocalLifeTarget err:%+v\n", err)
  756. returnError(c, 40000, err.Error())
  757. return
  758. }
  759. resultMap := make(map[string]string)
  760. resultMap["localId"] = *localId
  761. returnSuccess(c, 20000, resultMap)
  762. }
  763. // 本地生活任务预览
  764. func (t TaskController) GetLocalLifeDetail(c *gin.Context) {
  765. param := &LocalLifeDetailParam{}
  766. err := c.BindJSON(param)
  767. if err != nil {
  768. logrus.Errorf("Request bind err:%+v\n", err)
  769. returnError(c, 40000, "Parameter Error: "+err.Error())
  770. return
  771. }
  772. res, err := service.LocalLifeService{}.GetLocalLifeDetail(param.LocalLifeId)
  773. if err != nil {
  774. logrus.Errorf("[GetLocalLifeDetail] call Show err:%+v\n", err)
  775. returnError(c, 40000, err.Error())
  776. return
  777. }
  778. returnSuccess(c, 20000, res)
  779. }
  780. // 本地生活复制任务
  781. func (t TaskController) CopyLocalLife(c *gin.Context) {
  782. data := &vo.LocalSearchParam{}
  783. err := c.BindJSON(data)
  784. if err != nil {
  785. logrus.Errorf("Request bind err:%+v\n", err)
  786. returnError(c, 40000, "Parameter Error: "+err.Error())
  787. return
  788. }
  789. localId, err := service.LocalLifeService{}.CopyLocalLife(data)
  790. if err != nil {
  791. if err.Error() == "任务不存在" {
  792. returnError(c, 30000, err.Error())
  793. return
  794. }
  795. logrus.Errorf("[CreateLocalLife] call CreateLocalLife err:%+v\n", err)
  796. returnError(c, 40000, err.Error())
  797. return
  798. }
  799. resultMap := make(map[string]string)
  800. resultMap["localId"] = *localId
  801. returnSuccess(c, 20000, resultMap)
  802. }
  803. // 本地生活提交审核
  804. func (t TaskController) LocalLifeToReview(c *gin.Context) {
  805. data := &vo.LocalUpdateParam{}
  806. err := c.BindJSON(data)
  807. if err != nil || data.LocalID == "" {
  808. logrus.Errorf("Request bind err:%+v\n", err)
  809. returnError(c, 40000, "Parameter Error: "+err.Error())
  810. return
  811. }
  812. localId, err := service.LocalLifeService{}.LocalLifeToReview(data)
  813. if err != nil {
  814. logrus.Errorf("[ProjectToReview] call ProjectToReview err:%+v\n", err)
  815. returnError(c, 40000, err.Error())
  816. return
  817. }
  818. resultMap := make(map[string]string)
  819. resultMap["localId"] = *localId
  820. returnSuccess(c, 20000, resultMap)
  821. }
  822. // 带货待发货、待签收、已签收统计
  823. func (t TaskController) LogisticsSelectionTalentCount(c *gin.Context) {
  824. param := &vo.LogisticsSelectionTalentParam{}
  825. err := c.BindJSON(param)
  826. if err != nil || "" == param.SelectionId {
  827. logrus.Errorf("Request bind err:%+v\n", err)
  828. returnError(c, 40000, "Parameter Error: "+err.Error())
  829. return
  830. }
  831. res := service.TaskInfoService{}.LogisticsSelectionTalentCount(param)
  832. returnSuccess(c, 20000, res)
  833. }
  834. // 种草达人物流列表
  835. func (t TaskController) LogisticsTalentList(c *gin.Context) {
  836. param := &vo.LogisticsTalentParam{}
  837. err := c.BindJSON(param)
  838. if err != nil || "" == param.ProjectId {
  839. logrus.Errorf("Request bind err:%+v\n", err)
  840. returnError(c, 40000, "Parameter Error: "+err.Error())
  841. return
  842. }
  843. res, err := service.TaskInfoService{}.LogisticsTalentList(param)
  844. if err != nil {
  845. logrus.Errorf("[LogisticsTalentList] call LogisticsTalentList err:%+v\n", err)
  846. returnError(c, 40000, err.Error())
  847. return
  848. }
  849. returnSuccess(c, 20000, res)
  850. }
  851. // 种草待发货、待签收、已签收统计
  852. func (t TaskController) LogisticsTalentCount(c *gin.Context) {
  853. param := &vo.LogisticsTalentParam{}
  854. err := c.BindJSON(param)
  855. if err != nil || "" == param.ProjectId {
  856. logrus.Errorf("Request bind err:%+v\n", err)
  857. returnError(c, 40000, "Parameter Error: "+err.Error())
  858. return
  859. }
  860. res := service.TaskInfoService{}.LogisticsTalentCount(param)
  861. returnSuccess(c, 20000, res)
  862. }
  863. // 本地生活列表
  864. func (t TaskController) LocalLifeTaskList(c *gin.Context) {
  865. param := &vo.LocalSearchParam{}
  866. err := c.BindJSON(param)
  867. if err != nil {
  868. logrus.Errorf("Request bind err:%+v\n", err)
  869. returnError(c, 40000, "Parameter Error: "+err.Error())
  870. return
  871. }
  872. res, err := service.LocalLifeService{}.GetLocalLifeTaskList(param)
  873. if err != nil {
  874. logrus.Errorf("[LocalLifeTaskList] call GetLocalLifeTaskList err:%+v\n", err)
  875. returnError(c, 40000, err.Error())
  876. return
  877. }
  878. returnSuccess(c, 20000, res)
  879. }
  880. // 删除本地生活任务
  881. func (t TaskController) LocalLifeDel(c *gin.Context) {
  882. param := &vo.LocalSearchParam{}
  883. err := c.BindJSON(param)
  884. if err != nil {
  885. logrus.Errorf("Request bind err:%+v\n", err)
  886. returnError(c, 40000, "Parameter Error: "+err.Error())
  887. return
  888. }
  889. localId, err := service.LocalLifeService{}.DeleteLocalLife(param.LocalId)
  890. if err != nil {
  891. logrus.Errorf("[DeleteLocalLife] call DeleteLocalLife err:%+v\n", err)
  892. returnError(c, 40000, err.Error())
  893. return
  894. }
  895. resultMap := make(map[string]string)
  896. resultMap["localId"] = *localId
  897. returnSuccess(c, 20000, resultMap)
  898. }
  899. // 结束本地生活任务
  900. func (t TaskController) LocalLifeClose(c *gin.Context) {
  901. param := &vo.LocalSearchParam{}
  902. err := c.BindJSON(param)
  903. if err != nil {
  904. logrus.Errorf("Request bind err:%+v\n", err)
  905. returnError(c, 40000, "Parameter Error: "+err.Error())
  906. return
  907. }
  908. localId, err := service.LocalLifeService{}.CloseLocalLife(param.LocalId)
  909. if err != nil {
  910. logrus.Errorf("[CloseLocalLife] call CloseLocalLife err:%+v\n", err)
  911. returnError(c, 40000, err.Error())
  912. return
  913. }
  914. resultMap := make(map[string]string)
  915. resultMap["localId"] = *localId
  916. returnSuccess(c, 20000, resultMap)
  917. }
  918. // 探店本地生活列表
  919. func (t TaskController) StoreExploreList(c *gin.Context) {
  920. param := &vo.LocalSearchParam{}
  921. err := c.BindJSON(param)
  922. if err != nil {
  923. logrus.Errorf("Request bind err:%+v\n", err)
  924. returnError(c, 40000, "Parameter Error: "+err.Error())
  925. return
  926. }
  927. res, err := service.LocalLifeService{}.GetStoreExploreList(param)
  928. if err != nil {
  929. logrus.Errorf("[StoreExploreList] call StoreExploreList err:%+v\n", err)
  930. returnError(c, 40000, err.Error())
  931. return
  932. }
  933. returnSuccess(c, 20000, res)
  934. }
  935. // 探店达人详情
  936. func (t TaskController) StoreExploreInfo(c *gin.Context) {
  937. param := &vo.StoreExploreParam{}
  938. err := c.BindJSON(param)
  939. if err != nil {
  940. logrus.Errorf("Request bind err:%+v\n", err)
  941. returnError(c, 40000, "Parameter Error: "+err.Error())
  942. return
  943. }
  944. res, err := service.LocalLifeService{}.GetStoreExploreInfo(param)
  945. if err != nil {
  946. logrus.Errorf("[StoreExploreInfo] call Show err:%+v\n", err)
  947. returnError(c, 40000, err.Error())
  948. return
  949. }
  950. returnSuccess(c, 20000, res)
  951. }
  952. // 探店达人列表角标
  953. func (t TaskController) StoreExploreInfoCount(c *gin.Context) {
  954. param := &vo.StoreExploreParam{}
  955. err := c.BindJSON(param)
  956. if err != nil || "" == param.LocalLifeId {
  957. logrus.Errorf("Request bind err:%+v\n", err)
  958. returnError(c, 40000, "Parameter Error: "+err.Error())
  959. return
  960. }
  961. res := service.LocalLifeService{}.StoreExploreInfoCount(param)
  962. returnSuccess(c, 20000, res)
  963. }
  964. // 探店终止合作
  965. func (t TaskController) StoreExploreOver(c *gin.Context) {
  966. param := &vo.LocalTalentOperateParam{}
  967. err := c.BindJSON(param)
  968. if err != nil || param.TaskId == "" {
  969. logrus.Errorf("Request bind err:%+v\n", err)
  970. returnError(c, 40000, "Parameter Error: "+err.Error())
  971. return
  972. }
  973. res, err := service.LocalLifeService{}.StoreExploreOver(param)
  974. if err != nil {
  975. logrus.Errorf("[StoreExploreOver] call Show err:%+v\n", err)
  976. returnError(c, 40000, err.Error())
  977. return
  978. }
  979. returnSuccess(c, 20000, res)
  980. }
  981. // 预约时间批量同意/驳回
  982. func (t TaskController) StoreExploreOperate(c *gin.Context) {
  983. param := &vo.LocalTalentOperateParam{}
  984. err := c.BindJSON(param)
  985. if err != nil || param.TaskIds == nil {
  986. logrus.Errorf("Request bind err:%+v\n", err)
  987. returnError(c, 40000, "Parameter Error: "+err.Error())
  988. return
  989. }
  990. err = service.LocalLifeService{}.StoreExploreOperate(param)
  991. if err != nil {
  992. logrus.Errorf("[StoreExploreOperate] call Show err:%+v\n", err)
  993. returnError(c, 40000, err.Error())
  994. return
  995. }
  996. returnSuccess(c, 20000, nil)
  997. }
  998. // 电商带货看数据-达人数据
  999. func (t TaskController) TalentDataDetail(c *gin.Context) {
  1000. param := &vo.SelectionShowDataParam{}
  1001. err := c.BindJSON(param)
  1002. if err != nil {
  1003. logrus.Errorf("Request bind err:%+v\n", err)
  1004. returnError(c, 40000, "Parameter Error: "+err.Error())
  1005. return
  1006. }
  1007. result, err := service.ViewDataService{}.SelectionTalentDataDetail(param)
  1008. if err != nil {
  1009. logrus.Errorf("[TalentDataDetail] call Show err:%+v\n", err)
  1010. returnError(c, 40000, err.Error())
  1011. return
  1012. }
  1013. resultMap := make(map[string]vo.ReSelectionTalentData)
  1014. resultMap["dataInfo"] = result
  1015. returnSuccess(c, 20000, resultMap)
  1016. }
  1017. // 电商带货看数据-领样数据
  1018. func (t TaskController) SampleDataDetail(c *gin.Context) {
  1019. param := &vo.SelectionShowDataParam{}
  1020. err := c.BindJSON(param)
  1021. if err != nil {
  1022. logrus.Errorf("Request bind err:%+v\n", err)
  1023. returnError(c, 40000, "Parameter Error: "+err.Error())
  1024. return
  1025. }
  1026. result, err := service.ViewDataService{}.SelectionSampleDataDetail(param)
  1027. if err != nil {
  1028. logrus.Errorf("[SampleDataDetail] call Show err:%+v\n", err)
  1029. returnError(c, 40000, err.Error())
  1030. return
  1031. }
  1032. resultMap := make(map[string]vo.ReSelectionSampleData)
  1033. resultMap["dataInfo"] = result
  1034. returnSuccess(c, 20000, resultMap)
  1035. }
  1036. // 电商带货看数据-带货数据
  1037. func (t TaskController) SelectionDataDetail(c *gin.Context) {
  1038. param := &vo.SelectionShowDataParam{}
  1039. err := c.BindJSON(param)
  1040. if err != nil {
  1041. logrus.Errorf("Request bind err:%+v\n", err)
  1042. returnError(c, 40000, "Parameter Error: "+err.Error())
  1043. return
  1044. }
  1045. result, err := service.ViewDataService{}.SelectionDataDetail(param)
  1046. if err != nil {
  1047. logrus.Errorf("[SelectionDataDetail] call Show err:%+v\n", err)
  1048. returnError(c, 40000, err.Error())
  1049. return
  1050. }
  1051. resultMap := make(map[string]vo.ReSelectionData)
  1052. resultMap["dataInfo"] = result
  1053. returnSuccess(c, 20000, resultMap)
  1054. }
  1055. // 电商带货执行中-悬赏兑现
  1056. func (t TaskController) SelectionRewardCash(c *gin.Context) {
  1057. param := &vo.SelectionRewardCashParam{}
  1058. err := c.BindJSON(param)
  1059. if err != nil {
  1060. logrus.Errorf("Request bind err:%+v\n", err)
  1061. returnError(c, 40000, "Parameter Error: "+err.Error())
  1062. return
  1063. }
  1064. result, err1 := service.TaskInfoService{}.SelectionRewardCashDetail(param)
  1065. if err1 != nil {
  1066. logrus.Errorf("[SelectionRewardCash] call Show err:%+v\n", err)
  1067. returnError(c, 40000, err1.Error())
  1068. return
  1069. }
  1070. returnSuccess(c, 20000, result)
  1071. }