KuaishouPromoterServiceImpl.java 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857
  1. package com.ruixuan.isc.service.impl;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.ruixuan.common.core.domain.AjaxResult;
  5. import com.ruixuan.common.core.domain.entity.SysUser;
  6. import com.ruixuan.common.utils.Check;
  7. import com.ruixuan.common.utils.DateUtils;
  8. import com.ruixuan.common.utils.PageUtils;
  9. import com.ruixuan.common.utils.RedisUtil;
  10. import com.ruixuan.common.utils.Result;
  11. import com.ruixuan.common.utils.http.HttpUtil;
  12. import com.ruixuan.isc.entity.JYKuaishouPromoter;
  13. import com.ruixuan.isc.entity.KuaishouItemCollectSamples;
  14. import com.ruixuan.isc.entity.KuaishouPromoter;
  15. import com.ruixuan.isc.mapper.KuaishouPromoterMapper;
  16. import com.ruixuan.isc.service.IKuaishouItemCollectSamplesService;
  17. import com.ruixuan.isc.service.IKuaishouPromoterService;
  18. import com.ruixuan.system.service.ISysDeptService;
  19. import com.ruixuan.system.service.ISysRoleService;
  20. import com.ruixuan.system.service.ISysUserService;
  21. import lombok.extern.slf4j.Slf4j;
  22. import org.springframework.beans.factory.annotation.Autowired;
  23. import org.springframework.beans.factory.annotation.Value;
  24. import org.springframework.stereotype.Service;
  25. import java.util.ArrayList;
  26. import java.util.Arrays;
  27. import java.util.Collections;
  28. import java.util.Date;
  29. import java.util.HashMap;
  30. import java.util.List;
  31. import java.util.Map;
  32. import java.util.regex.Pattern;
  33. /**
  34. * 快手达人 信息Service业务层处理
  35. *
  36. * @author ruoyi
  37. * @date 2023-02-03
  38. */
  39. @Slf4j
  40. @Service
  41. public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
  42. @Value("${promoter.start_ip_path}")
  43. private String startIpPath;
  44. @Value("${promoter.internal_ip_path}")
  45. private String internalIpPath;
  46. @Autowired
  47. private ISysUserService sysUserService;
  48. @Autowired
  49. private KuaishouPromoterMapper kuaishouPromoterMapper;
  50. @Autowired
  51. private ISysDeptService deptService;
  52. @Autowired
  53. private ISysRoleService roleService;
  54. @Autowired
  55. private RedisUtil redisUtil;
  56. @Autowired
  57. private IKuaishouItemCollectSamplesService kuaishouItemCollectSamplesService;
  58. /**
  59. * 查询快手达人 信息列表
  60. *
  61. * @param kuaishouPromoter 快手达人 信息
  62. * @return 快手达人 信息
  63. */
  64. @Override
  65. public List<KuaishouPromoter> selectKuaishouPromoterList(Long userId, String promoterId, String promoterNickName, String mediaId, String parameter, String orderBy, Long bdUserId) {
  66. String roleKey = sysUserService.getRoleKeyByUserId(userId);
  67. List<Long> userList = new ArrayList<>();
  68. //角色:供应链管理员、招商、招商经理可以看到所有的达人信息
  69. if (roleKey.contains("courtship") || "supplyChainAdmin".equals(roleKey) || "admin".equals(roleKey)) {
  70. if (!Check.isNull(bdUserId)) {
  71. userList.add(bdUserId);
  72. }
  73. } else if ("bdManager".equals(roleKey) || "z".equals(roleKey)) {
  74. // 渠道经理、社群经理 可以看到自己创建的以及自己部门人员的达人信息
  75. if (!Check.isNull(bdUserId)) {
  76. userList.add(bdUserId);
  77. } else {
  78. Long deptId = deptService.getDeptIdByUserId(userId);
  79. userList = deptService.getDeptUserListByDeptId(deptId);
  80. }
  81. } else if ("bd".equals(roleKey)) {
  82. // 渠道可以看到自己创建的达人信息
  83. userList = Arrays.asList(userId);
  84. } else if ("association".equals(roleKey)) {
  85. // 社群可以看到所有社群的达人信息
  86. userList = sysUserService.getUserIdByRoleKey(roleKey);
  87. } else {
  88. return Collections.emptyList();
  89. }
  90. if (Check.isNull(parameter)) {
  91. parameter = "create_time";
  92. } else {
  93. switch (parameter) {
  94. case "avg_video_sales":
  95. parameter = "avgVideoSalesOrder";
  96. break;
  97. case "video_sales":
  98. parameter = "videoSalesOrder";
  99. break;
  100. case "total_sale":
  101. parameter = "totalSaleOrder";
  102. break;
  103. }
  104. }
  105. if (Check.isNull(orderBy)) {
  106. orderBy = "desc";
  107. }
  108. PageUtils.startPage();
  109. List<KuaishouPromoter> list = kuaishouPromoterMapper.selectKuaishouPromoterList(userList, promoterId, promoterNickName, mediaId, parameter, orderBy, bdUserId);
  110. list.forEach(ent -> {
  111. JSONObject follow = kuaishouPromoterMapper.getFollowUpRecordsByUserId(ent.getPromoterId(), ent.getUserId());
  112. ent.setFollowUpRecord(Check.isNull(follow) ? "-" : follow.getString("txt"));
  113. List<JSONObject> promoterLabelList = kuaishouPromoterMapper.getPromoterLabel(ent.getPromoterId(), ent.getUserId());
  114. ent.setLabels(promoterLabelList);
  115. });
  116. return list;
  117. }
  118. @Override
  119. public List<JYKuaishouPromoter> selectKuaishouPromoterList3(Long userId, String promoterId, String promoterNickName, String mediaId, String type, String parameter, String orderBy) {
  120. String roleKey = sysUserService.getRoleKeyByUserId(userId);
  121. List<Long> userList = new ArrayList<>();
  122. //角色:管理员和骄阳管理员可以看到所有的达人信息
  123. if ("admin".equals(roleKey) || "jy_admnin".equals(roleKey)) {
  124. userList = null;
  125. } else if ("jy_bd_manage".equals(roleKey) || "jy_scissors_manage".equals(roleKey) || "jy_out_operation_manager".equals(roleKey)) {
  126. // 骄阳渠道经理、骄阳剪手经理 可以看到自己创建的以及自己部门人员的达人信息
  127. Long deptId = deptService.getDeptIdByUserId(userId);
  128. userList = deptService.getDeptUserListByDeptId(deptId);
  129. } else if ("jy_bd".equals(roleKey) || "jy_scissors".equals(roleKey) || "jy_out_operation".equals(roleKey)) {
  130. // 骄阳渠道、骄阳-剪手 可以看到自己创建的达人信息
  131. userList = Arrays.asList(userId);
  132. } else {
  133. return Collections.emptyList();
  134. }
  135. if (Check.isNull(parameter)) {
  136. parameter = "create_time";
  137. } else {
  138. switch (parameter) {
  139. case "avg_video_sales":
  140. parameter = "avgVideoSalesOrder";
  141. break;
  142. case "video_sales":
  143. parameter = "videoSalesOrder";
  144. break;
  145. case "total_sale":
  146. parameter = "totalSaleOrder";
  147. break;
  148. }
  149. }
  150. if (Check.isNull(orderBy)) {
  151. orderBy = "desc";
  152. }
  153. PageUtils.startPage();
  154. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.selectKuaishouPromoterList3(userList, promoterId, promoterNickName, mediaId, type, parameter, orderBy);
  155. list.forEach(ent -> {
  156. JSONObject follow = kuaishouPromoterMapper.getFollowUpRecordsByUserId(ent.getPromoterId(), ent.getUserId());
  157. ent.setFollowUpRecord(Check.isNull(follow) ? "-" : follow.getString("txt"));
  158. List<JSONObject> promoterLabelList = kuaishouPromoterMapper.getPromoterLabel(ent.getPromoterId(), ent.getUserId());
  159. ent.setLabels(promoterLabelList);
  160. });
  161. return list;
  162. }
  163. @Override
  164. public List<JSONObject> selectKuaishouPromoterList2(Long userId, String promoterId, String promoterNickName, String status, String parameter, String orderBy) {
  165. if (Check.isNull(parameter)) {
  166. parameter = "promoterId";
  167. } else if ("avgVideoSales".equals(parameter)) {
  168. parameter = "avgVideoSalesOrder";
  169. } else if ("videoSales".equals(parameter)) {
  170. parameter = "videoSalesOrder";
  171. }
  172. if (Check.isNull(orderBy)) {
  173. orderBy = "desc";
  174. }
  175. PageUtils.startPage();
  176. List<JSONObject> list = kuaishouPromoterMapper.selectAllPromoterList(userId, promoterId, promoterNickName, status, parameter, orderBy);
  177. return list;
  178. }
  179. /**
  180. * 查询快手达人 信息
  181. *
  182. * @param id 快手达人 信息主键
  183. * @return 快手达人 信息
  184. */
  185. @Override
  186. public JSONObject selectKuaishouPromoterById(Long id) {
  187. JSONObject data = new JSONObject();
  188. JSONObject result = null;
  189. try {
  190. KuaishouPromoter promoter = kuaishouPromoterMapper.selectKuaishouPromoterById(id);
  191. if (Check.isNotNull(promoter)) {
  192. Thread thread = new Thread() {
  193. @Override
  194. public void run() {
  195. try {
  196. editPromoter(promoter.getId(), promoter.getMediaId(), promoter.getPromoterId(), true);
  197. } catch (Exception e) {
  198. e.printStackTrace();
  199. }
  200. }
  201. };
  202. thread.start();
  203. Long startTime = System.currentTimeMillis();
  204. String content = HttpUtil.httpGetRequest(internalIpPath + "kuaiShou/promoter/getPromoterInfo?promoterId=" + promoter.getPromoterId());
  205. result = JSONObject.parseObject(content);
  206. data.put("promoterInfo", promoter);
  207. data.put("result", result);
  208. //跟进记录
  209. JSONObject followUpRecord = kuaishouPromoterMapper.getFollowUpRecordsByUserId(promoter.getPromoterId(), promoter.getUserId());
  210. data.put("followUpRecord", followUpRecord);
  211. Long followUpRecordId = null;
  212. if (Check.isNotNull(followUpRecord)) {
  213. followUpRecordId = followUpRecord.getLong("id");
  214. }
  215. List<JSONObject> followUpRecordList = kuaishouPromoterMapper.getFollowUpRecordListByPromoterId(promoter.getPromoterId(), followUpRecordId);
  216. data.put("historyFollowUpRecord", followUpRecordList);
  217. //标签
  218. List<JSONObject> promoterLabelList = kuaishouPromoterMapper.getPromoterLabel(promoter.getPromoterId(), promoter.getUserId());
  219. data.put("promoterLabelList", promoterLabelList);
  220. }
  221. } catch (Exception e) {
  222. e.printStackTrace();
  223. log.error("获取达人详情数据异常,{}", result);
  224. }
  225. return data;
  226. }
  227. /**
  228. * 新增快手达人 信息
  229. *
  230. * @param 快手达人 信息
  231. */
  232. @Override
  233. public JSONObject insertKuaishouPromoter(KuaishouPromoter promoter) {
  234. JSONObject result = new JSONObject();
  235. promoter.setPromoterId(promoter.getPromoterId().trim());
  236. KuaishouPromoter one = kuaishouPromoterMapper.getOneByIdAndPromoterId(promoter.getUserId(), promoter.getPromoterId());
  237. if (Check.isNotNull(one)) {
  238. result.put("code", 500);
  239. result.put("msg", "该数据已存在,请重新输入");
  240. return result;
  241. }
  242. // 如果 达人ID是字母 并且 媒体是快手,说明操作失误,媒体改为抖音
  243. if (!isNumeric(promoter.getPromoterId()) && "2".equals(promoter.getMediaId())) {
  244. promoter.setMediaId("1");
  245. }
  246. // if ("2".equals(promoter.getMediaId())) {
  247. // 快手、抖音 同一达人ID 不能绑定到多个渠道角色用户上
  248. String roleKey = sysUserService.getRoleKeyByUserId(promoter.getUserId());
  249. if (roleKey.contains("bd")) {
  250. List<JSONObject> keys = kuaishouPromoterMapper.getBoundPromoterRoleKey(promoter.getPromoterId());
  251. if (Check.isNotNull(keys)) {
  252. for (JSONObject key : keys) {
  253. String rKey = key.getString("role_key");
  254. if ("bd".equals(rKey) || "bdManager".equals(rKey)) {
  255. result.put("code", 500);
  256. result.put("msg", "该达人已被其他渠道人员绑定,绑定人:" + key.getString("user_name"));
  257. return result;
  258. }
  259. }
  260. }
  261. }
  262. // }
  263. //查询 设置可绑定达人数
  264. Integer count = kuaishouPromoterMapper.getUserPromotersCount(promoter.getUserId(), promoter.getMediaId());
  265. if (Check.isNotNull(count)) {
  266. //查询 已绑定达人数
  267. Integer hCount = kuaishouPromoterMapper.getBoundCount(promoter.getUserId());
  268. if (Check.isNotNull(hCount) && hCount >= count) {
  269. result.put("code", 500);
  270. result.put("msg", "绑定达人数过多,暂无法绑定!");
  271. return result;
  272. }
  273. }
  274. SysUser sysUser = sysUserService.selectUserById(promoter.getUserId());
  275. if (Check.isNotNull(sysUser)) {
  276. promoter.setUserName(sysUser.getNickName());
  277. }
  278. kuaishouPromoterMapper.insertKuaishouPromoter(promoter);
  279. editPromoter(promoter.getId(), promoter.getMediaId(), promoter.getPromoterId(), true);
  280. result.put("code", 200);
  281. result.put("msg", "success");
  282. return result;
  283. }
  284. /**
  285. * 同步更新数据
  286. */
  287. private void editPromoter(Long id, String mediaId, String promoterId, boolean flag) {
  288. try {
  289. if (flag) {
  290. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  291. String key = DateUtils.getDate() + "_" + id + "_" + promoterId;
  292. String value = (String) redisUtil.get(key);
  293. if (Check.isNotNull(value) && "1".equals(value)) {
  294. return;
  295. }
  296. redisUtil.set(key, "1", 60 * 60 * 24);
  297. }
  298. /*更新达人数据*/
  299. Map<String, Object> param = new HashMap<>();
  300. param.put("promoterId", promoterId);
  301. param.put("mediaId", mediaId);
  302. Long startTime = System.currentTimeMillis();
  303. String content = "";
  304. if ("2".equals(mediaId)) {
  305. content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  306. Thread.sleep(3000);
  307. } else {
  308. content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  309. Thread.sleep(60000);
  310. }
  311. JSONObject result = JSONObject.parseObject(content);
  312. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  313. log.info("--------------------达人更新,【入参】:{},【返回结果】:{}", param, result.toJSONString());
  314. String province = "";
  315. if (Check.isNotNull(result.getString("province"))) {
  316. province = result.getString("province").concat("-").concat(result.getString("city"));
  317. }
  318. KuaishouPromoter kuaishouPromoter = new KuaishouPromoter(
  319. id,
  320. result.getString("promoterNickName"),
  321. province,
  322. result.getString("promoterHeadImgUrl"),
  323. result.getString("fanNum"),
  324. result.getString("avgVideoSales"),
  325. result.getString("videoSales"),
  326. result.getString("totalSale"),
  327. promoterId
  328. );
  329. if ("1".equals(mediaId)) {
  330. String followerincr = result.getString("follower_incr");
  331. if (Check.isNotNull(followerincr) && !"-".equals(followerincr)) {
  332. kuaishouPromoter.setFollowerIncr(result.getLong("follower_incr"));
  333. } else {
  334. kuaishouPromoter.setFollowerIncr(0l);
  335. }
  336. kuaishouPromoter.setLiveCount30(result.getInteger("live_count_30"));
  337. kuaishouPromoter.setLiveAverageUser30(result.getString("live_average_user_30"));
  338. kuaishouPromoter.setAwemeDiggFollowerRation(result.getString("aweme_digg_follower_ration"));
  339. kuaishouPromoter.setAwemeAvgDiggCount30(result.getLong("aweme_avg_digg_count_30"));
  340. }
  341. kuaishouPromoterMapper.updateKuaishouPromoterByPromoterId(kuaishouPromoter);
  342. } else {
  343. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  344. }
  345. } catch (Exception e) {
  346. e.printStackTrace();
  347. log.error("更新达人信息异常", e);
  348. }
  349. }
  350. /**
  351. * 同步更新数据
  352. */
  353. private void editPromoter3(Long id, String mediaId, String promoterId, boolean flag) {
  354. try {
  355. if (flag) {
  356. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  357. String key = DateUtils.getDate() + "_" + promoterId + "_" + id;
  358. String value = (String) redisUtil.get(key);
  359. if (Check.isNotNull(value) && "1".equals(value)) {
  360. return;
  361. }
  362. redisUtil.set(key, "1", 60 * 60 * 24);
  363. }
  364. /*更新达人数据*/
  365. Map<String, Object> param = new HashMap<>();
  366. param.put("promoterId", promoterId);
  367. param.put("mediaId", mediaId);
  368. Long startTime = System.currentTimeMillis();
  369. String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  370. Thread.sleep(3000);
  371. JSONObject result = JSONObject.parseObject(content);
  372. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  373. String province = "";
  374. if (Check.isNotNull(result.getString("province"))) {
  375. province = result.getString("province").concat("-").concat(result.getString("city"));
  376. }
  377. JYKuaishouPromoter kuaishouPromoter = new JYKuaishouPromoter(
  378. id,
  379. result.getString("promoterNickName"),
  380. province,
  381. result.getString("promoterHeadImgUrl"),
  382. result.getString("fanNum"),
  383. result.getString("avgVideoSales"),
  384. result.getString("videoSales"),
  385. result.getString("totalSale"),
  386. promoterId
  387. );
  388. kuaishouPromoterMapper.updateKuaishouPromoterByPromoterId3(kuaishouPromoter);
  389. } else {
  390. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  391. }
  392. } catch (Exception e) {
  393. e.printStackTrace();
  394. log.error("更新达人信息异常", e);
  395. }
  396. }
  397. /**
  398. * 同步更新数据
  399. */
  400. private void editMiaogousiPromoter(Long id, String mediaId, String promoterId, boolean flag) {
  401. try {
  402. if (flag) {
  403. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  404. String key = DateUtils.getDate() + "mgs_" + promoterId + "_" + id;
  405. String value = (String) redisUtil.get(key);
  406. if (Check.isNotNull(value) && "1".equals(value)) {
  407. return;
  408. }
  409. redisUtil.set(key, "1", 60 * 60 * 24);
  410. }
  411. /*更新达人数据*/
  412. Map<String, Object> param = new HashMap<>();
  413. param.put("promoterId", promoterId);
  414. param.put("mediaId", mediaId);
  415. Long startTime = System.currentTimeMillis();
  416. String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  417. Thread.sleep(3000);
  418. JSONObject result = JSONObject.parseObject(content);
  419. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  420. String province = "";
  421. if (Check.isNotNull(result.getString("province"))) {
  422. province = result.getString("province").concat("-").concat(result.getString("city"));
  423. }
  424. KuaishouPromoter kuaishouPromoter = new KuaishouPromoter(
  425. id,
  426. result.getString("promoterNickName"),
  427. province,
  428. result.getString("promoterHeadImgUrl"),
  429. result.getString("fanNum"),
  430. result.getString("avgVideoSales"),
  431. result.getString("videoSales"),
  432. result.getString("totalSale"),
  433. promoterId
  434. );
  435. kuaishouPromoterMapper.updateMiaogousiKuaishouPromoterByPromoterId(kuaishouPromoter);
  436. } else {
  437. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  438. }
  439. } catch (Exception e) {
  440. e.printStackTrace();
  441. log.error("更新达人信息异常", e);
  442. }
  443. }
  444. /**
  445. * 同步更新数据
  446. */
  447. private void editRocketPromoter(Long id, String mediaId, String promoterId, boolean flag) {
  448. try {
  449. if (flag) {
  450. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  451. String key = DateUtils.getDate() + "rocket_" + promoterId + "_" + id;
  452. String value = (String) redisUtil.get(key);
  453. if (Check.isNotNull(value) && "1".equals(value)) {
  454. return;
  455. }
  456. redisUtil.set(key, "1", 60 * 60 * 24);
  457. }
  458. /*更新达人数据*/
  459. Map<String, Object> param = new HashMap<>();
  460. param.put("promoterId", promoterId);
  461. param.put("mediaId", mediaId);
  462. Long startTime = System.currentTimeMillis();
  463. String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  464. Thread.sleep(3000);
  465. JSONObject result = JSONObject.parseObject(content);
  466. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  467. String province = "";
  468. if (Check.isNotNull(result.getString("province"))) {
  469. province = result.getString("province").concat("-").concat(result.getString("city"));
  470. }
  471. KuaishouPromoter kuaishouPromoter = new KuaishouPromoter(
  472. id,
  473. result.getString("promoterNickName"),
  474. province,
  475. result.getString("promoterHeadImgUrl"),
  476. result.getString("fanNum"),
  477. result.getString("avgVideoSales"),
  478. result.getString("videoSales"),
  479. result.getString("totalSale"),
  480. promoterId
  481. );
  482. kuaishouPromoterMapper.updateRocketKuaishouPromoterByPromoterId(kuaishouPromoter);
  483. } else {
  484. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  485. }
  486. } catch (Exception e) {
  487. e.printStackTrace();
  488. log.error("更新达人信息异常", e);
  489. }
  490. }
  491. @Override
  492. public JSONObject insertKuaishouPromoter3(JYKuaishouPromoter promoter) {
  493. JSONObject result = new JSONObject();
  494. promoter.setPromoterId(promoter.getPromoterId().trim());
  495. KuaishouPromoter one = kuaishouPromoterMapper.getOneByIdAndPromoterId3(null, promoter.getPromoterId());
  496. if (Check.isNotNull(one)) {
  497. result.put("code", 500);
  498. result.put("msg", "达人已被绑定,请重新选择 (绑定人:" + one.getUserName() + ")");
  499. return result;
  500. }
  501. SysUser sysUser = sysUserService.selectUserById(promoter.getUserId());
  502. if (Check.isNotNull(sysUser)) {
  503. promoter.setUserName(sysUser.getNickName());
  504. }
  505. kuaishouPromoterMapper.insertKuaishouPromoter3(promoter);
  506. editPromoter3(promoter.getId(), promoter.getMediaId(), promoter.getPromoterId(), true);
  507. result.put("code", 200);
  508. result.put("msg", "success");
  509. return result;
  510. }
  511. @Override
  512. public Result supplementInfo() {
  513. List<KuaishouPromoter> list = kuaishouPromoterMapper.getFailInfo();
  514. Thread thread = new Thread() {
  515. @Override
  516. public void run() {
  517. try {
  518. list.forEach(kuaishouPromoter -> editPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
  519. } catch (Exception e) {
  520. e.printStackTrace();
  521. }
  522. }
  523. };
  524. thread.start();
  525. List<String> promoters = new ArrayList<>();
  526. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId() + "【" + kuaishouPromoter.getMediaId() + "】"));
  527. promoters.add(supplementInfo3());
  528. promoters.add(miaogousiInfo());
  529. promoters.add(rocketInfo());
  530. return Result.success("共计" + list.size() + "条,数据补充中...", promoters);
  531. }
  532. //骄阳补全
  533. public String supplementInfo3() {
  534. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getFailInfo3();
  535. Thread thread = new Thread() {
  536. @Override
  537. public void run() {
  538. try {
  539. list.forEach(kuaishouPromoter -> editPromoter3(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
  540. } catch (Exception e) {
  541. e.printStackTrace();
  542. }
  543. }
  544. };
  545. thread.start();
  546. List<String> promoters = new ArrayList<>();
  547. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
  548. return "-------------骄阳共计" + list.size() + "条,达人IDS: " + promoters.toString();
  549. }
  550. //miaogousi
  551. public String miaogousiInfo() {
  552. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getMiaogousiInfoFailInfo();
  553. Thread thread = new Thread() {
  554. @Override
  555. public void run() {
  556. try {
  557. list.forEach(kuaishouPromoter -> editMiaogousiPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
  558. } catch (Exception e) {
  559. e.printStackTrace();
  560. }
  561. }
  562. };
  563. thread.start();
  564. List<String> promoters = new ArrayList<>();
  565. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
  566. return "-------------miaogousi共计" + list.size() + "条,达人IDS: " + promoters.toString();
  567. }
  568. //rocket
  569. public String rocketInfo() {
  570. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getRocketFailInfo();
  571. Thread thread = new Thread() {
  572. @Override
  573. public void run() {
  574. try {
  575. list.forEach(kuaishouPromoter -> editRocketPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
  576. } catch (Exception e) {
  577. e.printStackTrace();
  578. }
  579. }
  580. };
  581. thread.start();
  582. List<String> promoters = new ArrayList<>();
  583. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
  584. return "-------------rocket共计" + list.size() + "条,达人IDS: " + promoters.toString();
  585. }
  586. @Override
  587. public int addFollowUpRecords(JSONObject result) {
  588. return kuaishouPromoterMapper.addFollowUpRecords(result);
  589. }
  590. @Override
  591. public void updateFollowUpRecords(JSONObject result) {
  592. kuaishouPromoterMapper.updateFollowUpRecords(result);
  593. }
  594. @Override
  595. public Result getGongHaiVideoSales(String promoterId) {
  596. Map<String, Object> param = new HashMap<>();
  597. param.put("promoterId", promoterId);
  598. String url = startIpPath + "promoterInfo/updatePromoter";
  599. String content = HttpUtil.httpPostRequest(url, param, null);
  600. if ("0".equals(content)) {
  601. return Result.success();
  602. } else {
  603. log.error("查询达人公海销售额失败,达人ID:{}\nurl:{}", promoterId, url);
  604. return Result.error("失败");
  605. }
  606. }
  607. @Override
  608. public KuaishouPromoter getOnlyPromoterInfoByUserId(String promoterId, Long userId) {
  609. return kuaishouPromoterMapper.getOnlyPromoterInfoByUserId(promoterId, userId);
  610. }
  611. @Override
  612. public JSONObject addPromotersCount(Long userId, Long promotersCount, String mediaId) {
  613. kuaishouPromoterMapper.addPromotersCount(userId, promotersCount, mediaId);
  614. JSONObject result = new JSONObject();
  615. result.put("code", 200);
  616. result.put("msg", "success");
  617. return result;
  618. }
  619. @Override
  620. public String getRuleName(Long ruleId) {
  621. return kuaishouPromoterMapper.getRuleName(ruleId);
  622. }
  623. @Override
  624. public int addRule(String promoterId, Long ruleId, String ruleName) {
  625. return kuaishouPromoterMapper.addRule(promoterId, ruleId, ruleName);
  626. }
  627. @Override
  628. public List<String> selectPromoterIdListByTime(List<Long> userList, Long startDate, Long endDate) {
  629. return kuaishouPromoterMapper.selectPromoterIdListByTime(userList, startDate, endDate);
  630. }
  631. @Override
  632. public Result updatePromoterLabel(JSONObject result) {
  633. String promoterId = result.getString("promoterId");
  634. Long userId = result.getLong("userId");
  635. kuaishouPromoterMapper.deletePromoterLabel(promoterId, userId);
  636. JSONArray ids = result.getJSONArray("ids");
  637. if (Check.isNotNull(ids)) {
  638. List<JSONObject> list = new ArrayList<>();
  639. for (int i = 0; i < ids.size(); i++) {
  640. JSONObject obj = new JSONObject();
  641. Long labelId = ids.getLong(i);
  642. obj.put("promoterId", promoterId);
  643. obj.put("labelId", labelId);
  644. obj.put("userId", userId);
  645. list.add(obj);
  646. }
  647. kuaishouPromoterMapper.insertPromoterLabels(list);
  648. }
  649. return Result.success();
  650. }
  651. /**
  652. * 修改快手达人 信息
  653. *
  654. * @param kuaishouPromoter 快手达人 信息
  655. * @return 结果
  656. */
  657. @Override
  658. public int updateKuaishouPromoter(KuaishouPromoter kuaishouPromoter) {
  659. return kuaishouPromoterMapper.updateKuaishouPromoter(kuaishouPromoter);
  660. }
  661. /**
  662. * 修改快手达人 信息
  663. *
  664. * @param kuaishouPromoter 快手达人 信息
  665. * @return 结果
  666. */
  667. @Override
  668. public int updateKuaishouPromoter3(JYKuaishouPromoter kuaishouPromoter) {
  669. return kuaishouPromoterMapper.updateKuaishouPromoter3(kuaishouPromoter);
  670. }
  671. /**
  672. * 删除快手达人 信息信息
  673. *
  674. * @param id 快手达人 信息主键 follow_up_records
  675. * @return 结果
  676. */
  677. @Override
  678. public Result deleteKuaishouPromoterById(Long id, Long userId) {
  679. KuaishouPromoter promoter = kuaishouPromoterMapper.selectKuaishouPromoterById(id);
  680. List<KuaishouItemCollectSamples> list = kuaishouItemCollectSamplesService.getListByPromoterId(promoter.getPromoterId(), userId);
  681. for (KuaishouItemCollectSamples item : list) {
  682. if (item.getCollectSampleStatus() != 2 && item.getCollectSampleStatus() != 7) {
  683. return Result.error("该达人还有未完成的领样申请,请在完成后进行解绑!");
  684. }
  685. }
  686. if (Check.isNotNull(promoter)) {
  687. JSONObject record = new JSONObject();
  688. record.put("promoterId", promoter.getPromoterId());
  689. record.put("userId", promoter.getUserId());
  690. record.put("operatorId", userId);
  691. List<JSONObject> roles = sysUserService.getUserRoleByUserId(userId);
  692. if (Check.isNotNull(roles)) {
  693. record.put("roleName", roles.get(0).getString("role_name"));
  694. record.put("roleKey", roles.get(0).getString("role_key"));
  695. }
  696. kuaishouPromoterMapper.insertKuaishouPromoterRecord(record);
  697. }
  698. kuaishouPromoterMapper.deleteKuaishouPromoterById(id);
  699. return Result.success();
  700. }
  701. /**
  702. * 删除快手达人 信息信息
  703. *
  704. * @param id 快手达人 信息主键 follow_up_records
  705. * @return 结果
  706. */
  707. @Override
  708. public Result deleteKuaishouPromoterById3(Long id, Long userId) {
  709. JYKuaishouPromoter promoter = kuaishouPromoterMapper.selectKuaishouPromoterById3(id);
  710. if (Check.isNotNull(promoter)) {
  711. JSONObject record = new JSONObject();
  712. record.put("promoterId", promoter.getPromoterId());
  713. record.put("userId", promoter.getUserId());
  714. record.put("operatorId", userId);
  715. List<JSONObject> roles = sysUserService.getUserRoleByUserId(userId);
  716. if (Check.isNotNull(roles)) {
  717. record.put("roleName", roles.get(0).getString("role_name") + " (解绑骄阳)");
  718. record.put("roleKey", roles.get(0).getString("role_key"));
  719. }
  720. kuaishouPromoterMapper.insertKuaishouPromoterRecord(record);
  721. }
  722. kuaishouPromoterMapper.deleteKuaishouPromoterById3(id);
  723. return Result.success();
  724. }
  725. @Override
  726. public JSONObject selectKuaishouRulePromoterById(Long promoterId) {
  727. return kuaishouPromoterMapper.selectKuaishouRulePromoterById(promoterId);
  728. }
  729. @Override
  730. public AjaxResult getPromoterInfo(String promoterId) {
  731. AjaxResult ajaxResult = null;
  732. try {
  733. KuaishouPromoter promoter = kuaishouPromoterMapper.getOneByIdAndPromoterId(null, promoterId);
  734. JSONObject data = new JSONObject();
  735. if (Check.isNotNull(promoter)) {
  736. Thread thread = new Thread() {
  737. @Override
  738. public void run() {
  739. try {
  740. editPromoter(promoter.getId(), promoter.getMediaId(), promoter.getPromoterId(), true);
  741. } catch (Exception e) {
  742. e.printStackTrace();
  743. }
  744. }
  745. };
  746. thread.start();
  747. Long startTime = System.currentTimeMillis();
  748. String content = HttpUtil.httpGetRequest(internalIpPath + "kuaiShou/promoter/getPromoterVideoInfo?promoterId=" + promoter.getPromoterId());
  749. JSONObject result = JSONObject.parseObject(content);
  750. log.info("获取达人视频销售数据,用时:{}s", (System.currentTimeMillis() - startTime) / 1000);
  751. String start = DateUtils.getSubtractTime(new Date(), 31);
  752. String end = DateUtils.getDate();
  753. JSONObject info = kuaishouPromoterMapper.getNearlyMonthGmv(promoter.getPromoterId(), start, end);
  754. if (Check.isNotNull(info)) {
  755. data.put("orderAmount", info.getString("orderAmount"));
  756. data.put("operationCompletionRate", info.getString("operationCompletionRate"));
  757. }
  758. if (Check.isNotNull(result)) {
  759. data.put("avgVideoSales", result.getString("avgVideoSales"));
  760. data.put("videoSales", result.getString("videoSales"));
  761. }
  762. data.put("promoterId", promoter.getPromoterId());
  763. data.put("promoterUrl", promoter.getPromoterUrl());
  764. }
  765. ajaxResult = new AjaxResult(200, "查询成功", data);
  766. } catch (Exception e) {
  767. e.printStackTrace();
  768. log.error("获取达人详情数据异常");
  769. ajaxResult = new AjaxResult(500, "查询失败");
  770. }
  771. return ajaxResult;
  772. }
  773. @Override
  774. public KuaishouPromoter getOnlyPromoterInfo(String promoterId) {
  775. return kuaishouPromoterMapper.getOneByIdAndPromoterId(null, promoterId);
  776. }
  777. @Override
  778. public List<String> selectPromoterIdList(List<Long> userList, String mediaId) {
  779. return kuaishouPromoterMapper.selectPromoterIdList(userList, mediaId);
  780. }
  781. @Override
  782. public JSONObject getgetMonthPromoterTotal(List<Long> userList, String start, String end, String mediaId) {
  783. return kuaishouPromoterMapper.getgetMonthPromoterTotal(userList, start, end, mediaId);
  784. }
  785. /**
  786. * 判断是否为数字
  787. */
  788. public static boolean isNumeric(String str) {
  789. Pattern pattern = Pattern.compile("[0-9]*");
  790. return pattern.matcher(str).matches();
  791. }
  792. }