KuaishouItemCollectSamplesController.java 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541
  1. package com.ruixuan.isc.controller;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.google.gson.Gson;
  5. import com.kuaidi100.sdk.api.Subscribe;
  6. import com.kuaidi100.sdk.contant.ApiInfoConstant;
  7. import com.kuaidi100.sdk.core.IBaseClient;
  8. import com.kuaidi100.sdk.request.SubscribeParam;
  9. import com.kuaidi100.sdk.request.SubscribeParameters;
  10. import com.kuaidi100.sdk.request.SubscribeReq;
  11. import com.kuaidi100.sdk.response.SubscribeResp;
  12. import com.ruixuan.common.core.controller.BaseController;
  13. import com.ruixuan.common.core.domain.AjaxResult;
  14. import com.ruixuan.common.core.domain.entity.SysUser;
  15. import com.ruixuan.common.core.page.TableDataInfo;
  16. import com.ruixuan.common.utils.Check;
  17. import com.ruixuan.data.utils.ExportExcelUtils;
  18. import com.ruixuan.isc.entity.KuaishouItemCollectSampleExpress;
  19. import com.ruixuan.isc.entity.KuaishouItemCollectSampleLog;
  20. import com.ruixuan.isc.entity.KuaishouItemCollectSamples;
  21. import com.ruixuan.isc.enums.CompanyEnum;
  22. import com.ruixuan.isc.service.IKuaishouItemCollectSamplesService;
  23. import com.ruixuan.isc.service.IKuaishouItemListService;
  24. import com.ruixuan.system.service.ISysDeptService;
  25. import com.ruixuan.system.service.ISysRoleService;
  26. import com.ruixuan.system.service.ISysUserService;
  27. import io.swagger.annotations.Api;
  28. import io.swagger.annotations.ApiOperation;
  29. import io.swagger.annotations.ApiParam;
  30. import lombok.extern.slf4j.Slf4j;
  31. import org.apache.poi.xssf.usermodel.XSSFWorkbook;
  32. import org.springframework.beans.factory.annotation.Autowired;
  33. import org.springframework.web.bind.annotation.DeleteMapping;
  34. import org.springframework.web.bind.annotation.GetMapping;
  35. import org.springframework.web.bind.annotation.PostMapping;
  36. import org.springframework.web.bind.annotation.PutMapping;
  37. import org.springframework.web.bind.annotation.RequestBody;
  38. import org.springframework.web.bind.annotation.RequestMapping;
  39. import org.springframework.web.bind.annotation.RequestParam;
  40. import org.springframework.web.bind.annotation.ResponseBody;
  41. import org.springframework.web.bind.annotation.RestController;
  42. import javax.servlet.http.HttpServletRequest;
  43. import javax.servlet.http.HttpServletResponse;
  44. import java.io.IOException;
  45. import java.io.OutputStream;
  46. import java.io.UnsupportedEncodingException;
  47. import java.util.ArrayList;
  48. import java.util.Date;
  49. import java.util.HashMap;
  50. import java.util.List;
  51. import java.util.Map;
  52. /**
  53. * 【商品领样】Controller
  54. *
  55. * @author ruoyi
  56. * @date 2023-02-08
  57. */
  58. @Api(tags = "商品领样")
  59. @RestController
  60. @Slf4j
  61. @RequestMapping("/itemCollectSamples")
  62. public class KuaishouItemCollectSamplesController extends BaseController {
  63. @Autowired
  64. private IKuaishouItemCollectSamplesService kuaishouItemCollectSamplesService;
  65. @Autowired
  66. private ISysRoleService sysRoleService;
  67. @Autowired
  68. private ISysDeptService sysDeptService;
  69. @Autowired
  70. private ISysUserService sysUserService;
  71. @Autowired
  72. private IKuaishouItemListService itemListService;
  73. /**
  74. * 查询【请填写功能名称】列表
  75. */
  76. @GetMapping("/list")
  77. public TableDataInfo list(Long itemId, Long promoterId, Long userId, Integer collectSampleStatus, String itemTitle, String promoterNickName, String promoterPhone) {
  78. TableDataInfo tableDataInfo = new TableDataInfo();
  79. try {
  80. Map<String, Object> requestMap = new HashMap<>();
  81. if (!Check.isNull(userId)) {
  82. String roleId = sysRoleService.getRoleBYUserId(userId);
  83. if (roleId.equals("courtshipManager") || roleId.equals("bdManager") || roleId.equals("associationManager")) { // 经理层级查看部门下所有数据
  84. Long deptId = sysDeptService.getDeptIdByUserId(userId);
  85. List<Long> userIds = sysDeptService.getDeptUserListByDeptId(deptId);
  86. if (roleId.equals("bdManager") || roleId.equals("associationManager")) {
  87. requestMap.put("collectSampleIds", userIds);
  88. } else {
  89. requestMap.put("itemCreateIds", userIds);
  90. }
  91. } else if (roleId.equals("association") || roleId.equals("bd")) { // 社群和bd查看申请人为自己的领样信息
  92. requestMap.put("collectSampleId", userId);
  93. } else if (roleId.equals("courtship")) { // 招商查看创建人为自己的领样信息
  94. requestMap.put("itemCreateId", userId);
  95. }
  96. }
  97. if (!Check.isNull(itemId)) {
  98. requestMap.put("itemId", itemId);
  99. }
  100. if (!Check.isNull(promoterId)) {
  101. requestMap.put("promoterId", promoterId);
  102. }
  103. if (!Check.isNull(collectSampleStatus)) {
  104. requestMap.put("collectSampleStatus", collectSampleStatus);
  105. }
  106. if (!Check.isNull(itemTitle)) {
  107. requestMap.put("itemTitle", itemTitle);
  108. }
  109. if (!Check.isNull(promoterNickName)) {
  110. requestMap.put("promoterNickName", promoterNickName);
  111. }
  112. if (!Check.isNull(promoterPhone)) {
  113. requestMap.put("promoterPhone", promoterPhone);
  114. }
  115. startPage();
  116. List<KuaishouItemCollectSamples> list = kuaishouItemCollectSamplesService.selectKuaishouItemCollectSamplesList(requestMap);
  117. return getDataTable(list);
  118. } catch (Exception e) {
  119. e.printStackTrace();
  120. tableDataInfo.setCode(-1);
  121. tableDataInfo.setMsg(e.getMessage());
  122. }
  123. return tableDataInfo;
  124. }
  125. /**
  126. * 领样预览
  127. */
  128. @PostMapping("/preview")
  129. public JSONObject preview(@RequestBody JSONObject requestJson) {
  130. JSONObject returnJson = new JSONObject();
  131. try {
  132. Long userId = requestJson.getLong("userId");
  133. if (Check.isNull(userId)) {
  134. throw new Exception("请传入当前登录人ID");
  135. }
  136. SysUser sysUser = sysUserService.selectUserById(userId);
  137. if (Check.isNull(sysUser)) {
  138. throw new Exception("未获取到登录人信息");
  139. }
  140. JSONArray itemIds = requestJson.getJSONArray("itemIds");
  141. if (Check.isNull(itemIds)) {
  142. throw new Exception("请传入需要申请的商品列表");
  143. }
  144. JSONArray promoterIds = requestJson.getJSONArray("promoterIds");
  145. if (Check.isNull(promoterIds)) {
  146. throw new Exception("请传入需要申请的达人列表");
  147. }
  148. JSONObject previewJson = kuaishouItemCollectSamplesService.preview(userId, sysUser.getNickName(), itemIds, promoterIds);
  149. returnJson.put("code", 0);
  150. returnJson.put("message", "success");
  151. returnJson.put("preview", previewJson);
  152. } catch (Exception e) {
  153. e.printStackTrace();
  154. returnJson.put("code", -1);
  155. returnJson.put("message", e.getMessage());
  156. }
  157. return returnJson;
  158. }
  159. /**
  160. * 新增【请填写功能名称】
  161. */
  162. @PostMapping("/add")
  163. public JSONObject add(@RequestBody JSONObject requestJson) {
  164. JSONObject returnJson = new JSONObject();
  165. try {
  166. if (Check.isNull(requestJson)) {
  167. throw new Exception("入参不能为空");
  168. }
  169. JSONArray temCollectSamples = requestJson.getJSONArray("temCollectSamples");
  170. if (Check.isNull(temCollectSamples)) {
  171. throw new Exception("认领信息不能为空");
  172. }
  173. kuaishouItemCollectSamplesService.batchAdd(temCollectSamples);
  174. returnJson.put("code", 0);
  175. returnJson.put("message", "领样信息增加成功");
  176. } catch (Exception e) {
  177. e.printStackTrace();
  178. returnJson.put("code", -1);
  179. returnJson.put("message", e.getMessage());
  180. }
  181. return returnJson;
  182. }
  183. @GetMapping("/getCompany")
  184. public List<JSONObject> getCompany() {
  185. return CompanyEnum.companyList();
  186. }
  187. /**
  188. * 修改【请填写功能名称】
  189. */
  190. @PutMapping("/edit")
  191. public JSONObject edit(@RequestBody KuaishouItemCollectSamples kuaishouItemCollectSamples) {
  192. JSONObject returnJson = new JSONObject();
  193. try {
  194. Long id = kuaishouItemCollectSamples.getId();
  195. if (Check.isNull(id)) {
  196. throw new Exception("id不能为空");
  197. }
  198. KuaishouItemCollectSampleLog sampleLog = new KuaishouItemCollectSampleLog();
  199. sampleLog.setUserId(kuaishouItemCollectSamples.getUserId());
  200. sampleLog.setUserName(kuaishouItemCollectSamples.getUserName());
  201. sampleLog.setSampleId(id);
  202. Integer collectSampleStatus = kuaishouItemCollectSamples.getCollectSampleStatus();
  203. if (!Check.isNull(collectSampleStatus)) {
  204. sampleLog.setCollectSampleStatus(collectSampleStatus);
  205. if (collectSampleStatus == 2) {
  206. String collectSampleDesc = kuaishouItemCollectSamples.getCollectSampleDesc();
  207. if (Check.isNull(collectSampleDesc)) {
  208. kuaishouItemCollectSamples.setCollectSampleDesc("领样审核拒绝");
  209. kuaishouItemCollectSamplesService.cleanLogs(kuaishouItemCollectSamples.getId(), collectSampleStatus);
  210. }
  211. }
  212. if (collectSampleStatus == 3) {
  213. kuaishouItemCollectSamples.setCollectSampleDesc("待录入订单号");
  214. }
  215. if (collectSampleStatus == 5) { // 招商审核作业拒绝
  216. String collectSampleDesc = kuaishouItemCollectSamples.getCollectSampleDesc();
  217. if (Check.isNull(collectSampleDesc)) {
  218. kuaishouItemCollectSamples.setCollectSampleDesc("招商审核作业拒绝,请重新提交");
  219. }
  220. kuaishouItemCollectSamplesService.cleanLogs(kuaishouItemCollectSamples.getId(), collectSampleStatus);
  221. }
  222. if (collectSampleStatus == 7) { // 作业完成
  223. kuaishouItemCollectSamples.setCollectSampleDesc("作业已完成");
  224. }
  225. }
  226. String courierNumber = kuaishouItemCollectSamples.getCourierNumber();
  227. if (!Check.isNull(courierNumber)) {
  228. sampleLog.setCollectSampleStatus(4);
  229. kuaishouItemCollectSamples.setCollectSampleStatus(4);
  230. kuaishouItemCollectSamples.setCollectSampleDesc("商品已发货");
  231. // 调用快递接口
  232. kuaishouItemCollectSamplesService.subscribe(id, courierNumber, kuaishouItemCollectSamples.getCompanyCode());
  233. }
  234. String taskFileUrl = kuaishouItemCollectSamples.getTaskFileUrl();
  235. if (!Check.isNull(taskFileUrl)) { // 作业上传成功
  236. sampleLog.setCollectSampleStatus(6);
  237. kuaishouItemCollectSamples.setCollectSampleStatus(6);
  238. kuaishouItemCollectSamples.setCollectSampleDesc("作业上传成功,待招商审核");
  239. }
  240. int i = kuaishouItemCollectSamplesService.updateKuaishouItemCollectSamples(kuaishouItemCollectSamples);
  241. if (i > 0) {
  242. sampleLog.setCreateTime(new Date());
  243. sampleLog.setUpdateTime(new Date());
  244. kuaishouItemCollectSamplesService.insertLog(sampleLog);
  245. Long itemId = kuaishouItemCollectSamplesService.getItemIdById(id);
  246. if (!Check.isNull(itemId)) {
  247. JSONObject info = kuaishouItemCollectSamplesService.getCollectSampleInfo(itemId);
  248. itemListService.updateCount(itemId, info.getInteger("sampleCount"), info.getInteger("userCount"));
  249. }
  250. }
  251. returnJson.put("code", 0);
  252. returnJson.put("message", "修改成功");
  253. } catch (Exception e) {
  254. e.printStackTrace();
  255. returnJson.put("code", -1);
  256. returnJson.put("message", e.getMessage());
  257. }
  258. return returnJson;
  259. }
  260. @GetMapping("/detail")
  261. public JSONObject detail(Long id) {
  262. JSONObject returnJson = new JSONObject();
  263. try {
  264. if (Check.isNull(id)) {
  265. throw new Exception("id不能为空");
  266. }
  267. returnJson = kuaishouItemCollectSamplesService.getDetail(id);
  268. returnJson.put("code", 0);
  269. returnJson.put("message", "查询成功");
  270. } catch (Exception e) {
  271. e.printStackTrace();
  272. returnJson.put("code", -1);
  273. returnJson.put("message", e.getMessage());
  274. }
  275. return returnJson;
  276. }
  277. @GetMapping("/courierNumberInfo")
  278. public JSONObject courierNumberInfo(String courierNumber) {
  279. JSONObject returnJson = new JSONObject();
  280. try {
  281. if (Check.isNull(courierNumber)) {
  282. throw new Exception("快递单号不能为空");
  283. }
  284. JSONObject data = kuaishouItemCollectSamplesService.courierNumberInfo(courierNumber);
  285. returnJson.put("data", data);
  286. returnJson.put("code", 0);
  287. returnJson.put("message", "查询成功");
  288. } catch (Exception e) {
  289. e.printStackTrace();
  290. returnJson.put("code", -1);
  291. returnJson.put("message", e.getMessage());
  292. }
  293. return returnJson;
  294. }
  295. @PutMapping("/testSubscribe")
  296. public JSONObject testSubscribe(String phone, String courierNumber, String code) {
  297. JSONObject returnJson = new JSONObject();
  298. try {
  299. SubscribeParameters subscribeParameters = new SubscribeParameters();
  300. subscribeParameters.setCallbackurl("http://ruixuan.api.tjyourong.com.cn/itemCollectSamples/callback");
  301. subscribeParameters.setPhone(phone);
  302. SubscribeParam subscribeParam = new SubscribeParam();
  303. subscribeParam.setParameters(subscribeParameters);
  304. subscribeParam.setCompany(code);
  305. subscribeParam.setNumber(courierNumber);
  306. subscribeParam.setKey("BPEQUJxB9244");
  307. SubscribeReq subscribeReq = new SubscribeReq();
  308. subscribeReq.setSchema(ApiInfoConstant.SUBSCRIBE_SCHEMA);
  309. subscribeReq.setParam(new Gson().toJson(subscribeParam));
  310. IBaseClient subscribe = new Subscribe();
  311. JSONObject jsonObject = JSONObject.parseObject(subscribe.execute(subscribeReq).getBody());
  312. System.err.println(jsonObject);
  313. System.out.println(subscribe.execute(subscribeReq));
  314. returnJson.put("code", 0);
  315. returnJson.put("message", "调用成功");
  316. } catch (Exception e) {
  317. e.printStackTrace();
  318. returnJson.put("code", -1);
  319. returnJson.put("message", e.getMessage());
  320. }
  321. return returnJson;
  322. }
  323. @PostMapping("/callback")
  324. public SubscribeResp callback(HttpServletRequest request) {
  325. SubscribeResp subscribeResp = new SubscribeResp();
  326. try {
  327. String param = request.getParameter("param");
  328. log.info("快递回调信息:{}", param);
  329. JSONObject paramJson = JSONObject.parseObject(param);
  330. if (Check.isNull(paramJson)) {
  331. throw new Exception("回调信息为空");
  332. }
  333. JSONObject lastResult = paramJson.getJSONObject("lastResult");
  334. if (!Check.isNull(lastResult)) {
  335. String state = lastResult.getString("state");
  336. String nu = lastResult.getString("nu");
  337. String com = lastResult.getString("com");
  338. if ("3".equals(state)) {
  339. Integer status = kuaishouItemCollectSamplesService.getStatusByCourierNumbe(nu);
  340. if (!Check.isNull(status)) {
  341. if (status < 5) { // 防止快递重复回调
  342. KuaishouItemCollectSamples updateSample = new KuaishouItemCollectSamples();
  343. updateSample.setCourierNumber(nu);
  344. updateSample.setCollectSampleStatus(5);
  345. updateSample.setCollectSampleDesc("快递已签收,待上传作业");
  346. kuaishouItemCollectSamplesService.updateByNum(updateSample);
  347. }
  348. }
  349. }
  350. JSONArray data = lastResult.getJSONArray("data");
  351. KuaishouItemCollectSampleExpress express = new KuaishouItemCollectSampleExpress();
  352. express.setCourierNumber(nu);
  353. express.setCom(com);
  354. express.setState(state);
  355. if (!Check.isNull(data)) {
  356. express.setExpressData(data.toJSONString());
  357. }
  358. kuaishouItemCollectSamplesService.replaceExpress(express);
  359. }
  360. subscribeResp.setResult(Boolean.TRUE);
  361. subscribeResp.setReturnCode("200");
  362. subscribeResp.setMessage("回调成功");
  363. } catch (Exception e) {
  364. e.printStackTrace();
  365. subscribeResp.setResult(Boolean.FALSE);
  366. subscribeResp.setReturnCode("-1");
  367. subscribeResp.setMessage(e.getMessage());
  368. }
  369. return subscribeResp;
  370. }
  371. @GetMapping("/copyInfo")
  372. public JSONObject copyInfo(Long promoterId) {
  373. JSONObject returnJson = new JSONObject();
  374. try {
  375. if (Check.isNull(promoterId)) {
  376. throw new Exception("请传入达人ID");
  377. }
  378. JSONObject copyJson = kuaishouItemCollectSamplesService.getCopyInfo(promoterId);
  379. returnJson.put("code", 0);
  380. returnJson.put("message", "调用成功");
  381. returnJson.put("data", copyJson);
  382. } catch (Exception e) {
  383. e.printStackTrace();
  384. returnJson.put("code", -1);
  385. returnJson.put("message", e.getMessage());
  386. }
  387. return returnJson;
  388. }
  389. @DeleteMapping("/remove")
  390. public AjaxResult remove( Long id) {
  391. return toAjax(kuaishouItemCollectSamplesService.deleteKuaishouItemCollectSamplesById(id));
  392. }
  393. /**
  394. * 认领商品列表导出
  395. *
  396. * @return
  397. */
  398. @PostMapping("/exportCollectSamples")
  399. @ApiOperation(value = "认领商品列表")
  400. @ResponseBody
  401. public void exportCollectSamples(HttpServletRequest request, HttpServletResponse response, @RequestBody JSONObject requestJson) throws IOException {
  402. Map<String, Object> requestMap = new HashMap<>();
  403. if (!Check.isNull(requestJson.getJSONArray("ids"))) {
  404. requestMap.put("ids", requestJson.getJSONArray("ids"));
  405. }
  406. List<JSONObject> list = kuaishouItemCollectSamplesService.exportCollectSamples(requestMap);
  407. List<List<Object>> exportList = new ArrayList<>();
  408. if (!Check.isNull(list)) {
  409. for (int i = 0; i < list.size(); i++) {
  410. JSONObject date = list.get(i);
  411. List<Object> export = new ArrayList();
  412. export.add(date.getString("id"));
  413. export.add(date.getString("itemId"));
  414. export.add(date.getString("itemTitle"));
  415. export.add(date.getString("promoterId"));
  416. export.add(date.getString("promoterNickName"));
  417. export.add(date.getString("status"));
  418. JSONObject copyJson = kuaishouItemCollectSamplesService.getCopyInfo(date.getLong("promoterId"));
  419. export.add(copyJson.getString("fansNumber"));
  420. export.add(copyJson.getString("totalSale"));
  421. export.add(date.getString("sampleCount"));
  422. export.add(date.getString("sampleRequirement"));
  423. export.add(date.getString("consignee"));
  424. export.add(date.getString("promoterPhone"));
  425. export.add(date.getString("promoterAddress"));
  426. exportList.add(export);
  427. }
  428. }
  429. String[] headers = {"id", "商品ID", "商品名称", "达人ID", "达人昵称", "领样状态", "粉丝数", "销售额", "领样数量", "领样规则", "收件人", "收件人手机号码", "收件人地址"};
  430. OutputStream os = response.getOutputStream();
  431. ExportExcelUtils eeu = new ExportExcelUtils();
  432. XSSFWorkbook workbook = new XSSFWorkbook();
  433. eeu.exportExcel(workbook, 0, "领样列表", headers, exportList);
  434. this.setResponseHeader(response, "领样列表.xls");
  435. workbook.write(os);
  436. os.flush();
  437. os.close();
  438. }
  439. //发送响应流方法
  440. public void setResponseHeader(HttpServletResponse response, String fileName) {
  441. try {
  442. try {
  443. fileName = new String(fileName.getBytes(), "ISO8859-1");
  444. } catch (UnsupportedEncodingException e) {
  445. e.printStackTrace();
  446. }
  447. response.setContentType("application/octet-stream;charset=ISO8859-1");
  448. response.setHeader("Content-Disposition", "attachment;filename=" + fileName);
  449. response.addHeader("Pargam", "no-cache");
  450. response.addHeader("Cache-Control", "no-cache");
  451. } catch (Exception ex) {
  452. ex.printStackTrace();
  453. }
  454. }
  455. @GetMapping("/getPersonalInfo")
  456. @ApiOperation(value = "工作台——个人信息")
  457. public JSONObject getPersonalInfo(@ApiParam("创建人ID") @RequestParam(value = "userId", required = true) Long userId) {
  458. JSONObject returnJson = new JSONObject();
  459. try {
  460. if (Check.isNull(userId)) {
  461. throw new Exception("请传入人员ID");
  462. }
  463. return kuaishouItemCollectSamplesService.getPersonalInfo(userId);
  464. } catch (Exception e) {
  465. e.printStackTrace();
  466. returnJson.put("code", -1);
  467. returnJson.put("message", e.getMessage());
  468. }
  469. return returnJson;
  470. }
  471. @GetMapping("/getOrderData")
  472. @ApiOperation(value = "工作台——订单数据")
  473. public JSONObject getOrderData(@ApiParam("创建人ID") @RequestParam(value = "userId", required = true) Long userId,
  474. @ApiParam("日期") @RequestParam(value = "statDate", required = false) String statDate) {
  475. JSONObject returnJson = new JSONObject();
  476. try {
  477. if (Check.isNull(userId)) {
  478. throw new Exception("请传入人员ID");
  479. }
  480. return kuaishouItemCollectSamplesService.getOrderData(userId, statDate);
  481. } catch (Exception e) {
  482. e.printStackTrace();
  483. returnJson.put("code", -1);
  484. returnJson.put("message", e.getMessage());
  485. }
  486. return returnJson;
  487. }
  488. @GetMapping("/getDataAnalysis")
  489. @ApiOperation(value = "工作台——数据分析")
  490. public JSONObject getDataAnalysis(@ApiParam("创建人ID") @RequestParam(value = "userId", required = true) Long userId) {
  491. JSONObject returnJson = new JSONObject();
  492. try {
  493. if (Check.isNull(userId)) {
  494. throw new Exception("请传入人员ID");
  495. }
  496. return kuaishouItemCollectSamplesService.getDataAnalysis(userId);
  497. } catch (Exception e) {
  498. e.printStackTrace();
  499. returnJson.put("code", -1);
  500. returnJson.put("message", e.getMessage());
  501. }
  502. return returnJson;
  503. }
  504. }