KuaishouPromoterServiceImpl.java 56 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265
  1. package com.ruixuan.isc.service.impl;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.google.common.collect.Lists;
  5. import com.monitorjbl.xlsx.StreamingReader;
  6. import com.ruixuan.common.core.domain.AjaxResult;
  7. import com.ruixuan.common.core.domain.entity.SysUser;
  8. import com.ruixuan.common.utils.Check;
  9. import com.ruixuan.common.utils.DateUtils;
  10. import com.ruixuan.common.utils.LoadFileUtil;
  11. import com.ruixuan.common.utils.PageUtils;
  12. import com.ruixuan.common.utils.RedisUtil;
  13. import com.ruixuan.common.utils.Result;
  14. import com.ruixuan.common.utils.file.FileUtil;
  15. import com.ruixuan.common.utils.http.HttpUtil;
  16. import com.ruixuan.data.utils.ExportExcelUtils;
  17. import com.ruixuan.isc.entity.FirstDeliveryValidMaterials;
  18. import com.ruixuan.isc.entity.JYKuaishouPromoter;
  19. import com.ruixuan.isc.entity.KuaishouItemCollectSamples;
  20. import com.ruixuan.isc.entity.KuaishouPromoter;
  21. import com.ruixuan.isc.mapper.FirstDeliveryValidMapper;
  22. import com.ruixuan.isc.mapper.KuaishouPromoterMapper;
  23. import com.ruixuan.isc.service.IKuaishouItemCollectSamplesService;
  24. import com.ruixuan.isc.service.IKuaishouPromoterService;
  25. import com.ruixuan.system.service.ISysDeptService;
  26. import com.ruixuan.system.service.ISysRoleService;
  27. import com.ruixuan.system.service.ISysUserService;
  28. import lombok.extern.slf4j.Slf4j;
  29. import org.apache.commons.io.IOUtils;
  30. import org.apache.poi.ss.usermodel.Row;
  31. import org.apache.poi.ss.usermodel.Sheet;
  32. import org.apache.poi.ss.usermodel.Workbook;
  33. import org.springframework.beans.factory.annotation.Autowired;
  34. import org.springframework.beans.factory.annotation.Value;
  35. import org.springframework.stereotype.Service;
  36. import org.springframework.web.multipart.MultipartFile;
  37. import java.io.File;
  38. import java.io.FileInputStream;
  39. import java.io.InputStream;
  40. import java.util.ArrayList;
  41. import java.util.Arrays;
  42. import java.util.Collections;
  43. import java.util.Date;
  44. import java.util.HashMap;
  45. import java.util.List;
  46. import java.util.Map;
  47. import java.util.UUID;
  48. import java.util.concurrent.ExecutorService;
  49. import java.util.concurrent.Executors;
  50. import java.util.regex.Pattern;
  51. /**
  52. * 快手达人 信息Service业务层处理
  53. *
  54. * @author ruoyi
  55. * @date 2023-02-03
  56. */
  57. @Slf4j
  58. @Service
  59. public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
  60. @Value("${promoter.start_ip_path}")
  61. private String startIpPath;
  62. @Value("${promoter.internal_ip_path}")
  63. private String internalIpPath;
  64. @Autowired
  65. private ISysUserService sysUserService;
  66. @Autowired
  67. private KuaishouPromoterMapper kuaishouPromoterMapper;
  68. @Autowired
  69. private FirstDeliveryValidMapper deliveryValidMapper;
  70. @Autowired
  71. private ISysDeptService deptService;
  72. @Autowired
  73. private ISysRoleService roleService;
  74. @Autowired
  75. private RedisUtil redisUtil;
  76. @Autowired
  77. private IKuaishouItemCollectSamplesService kuaishouItemCollectSamplesService;
  78. /**
  79. * 查询快手达人 信息列表
  80. *
  81. * @param kuaishouPromoter 快手达人 信息
  82. * @return 快手达人 信息
  83. */
  84. @Override
  85. public List<KuaishouPromoter> selectKuaishouPromoterList(Long userId, String promoterId, String promoterNickName, String mediaId, String parameter, String orderBy, Long bdUserId, Integer searchPhone) {
  86. String roleKey = sysUserService.getRoleKeyByUserId(userId);
  87. List<Long> userList = new ArrayList<>();
  88. //角色:供应链管理员、招商、招商经理可以看到所有的达人信息
  89. if (roleKey.contains("courtship") || "supplyChainAdmin".equals(roleKey) || "admin".equals(roleKey)) {
  90. if (!Check.isNull(bdUserId)) {
  91. userList.add(bdUserId);
  92. }
  93. } else if ("bdManager".equals(roleKey) || "z".equals(roleKey)) {
  94. // 渠道经理、社群经理 可以看到自己创建的以及自己部门人员的达人信息
  95. if (!Check.isNull(bdUserId)) {
  96. userList.add(bdUserId);
  97. } else {
  98. Long deptId = deptService.getDeptIdByUserId(userId);
  99. userList = deptService.getDeptUserListByDeptId(deptId);
  100. }
  101. } else if ("bd".equals(roleKey)) {
  102. // 渠道可以看到自己创建的达人信息
  103. userList = Arrays.asList(userId);
  104. } else if ("association".equals(roleKey)) {
  105. // 社群可以看到所有社群的达人信息
  106. userList = sysUserService.getUserIdByRoleKey(roleKey);
  107. } else {
  108. return Collections.emptyList();
  109. }
  110. if (Check.isNull(parameter)) {
  111. parameter = "create_time";
  112. } else {
  113. switch (parameter) {
  114. case "avg_video_sales":
  115. parameter = "avgVideoSalesOrder";
  116. break;
  117. case "video_sales":
  118. parameter = "videoSalesOrder";
  119. break;
  120. case "total_sale":
  121. parameter = "totalSaleOrder";
  122. break;
  123. }
  124. }
  125. if (Check.isNull(orderBy)) {
  126. orderBy = "desc";
  127. }
  128. PageUtils.startPage();
  129. List<KuaishouPromoter> list = kuaishouPromoterMapper.selectKuaishouPromoterList(userList, promoterId, promoterNickName, mediaId, parameter, orderBy, bdUserId, searchPhone);
  130. list.forEach(ent -> {
  131. JSONObject follow = kuaishouPromoterMapper.getFollowUpRecordsByUserId(ent.getPromoterId(), ent.getUserId());
  132. ent.setFollowUpRecord(Check.isNull(follow) ? "-" : follow.getString("txt"));
  133. List<JSONObject> promoterLabelList = kuaishouPromoterMapper.getPromoterLabel(ent.getPromoterId(), ent.getUserId());
  134. ent.setLabels(promoterLabelList);
  135. });
  136. return list;
  137. }
  138. @Override
  139. public List<JYKuaishouPromoter> selectKuaishouPromoterList3(Long userId, String promoterId, String promoterNickName, String mediaId, String type, String parameter, String orderBy) {
  140. String roleKey = sysUserService.getRoleKeyByUserId(userId);
  141. List<Long> userList = new ArrayList<>();
  142. //角色:管理员和骄阳管理员可以看到所有的达人信息
  143. Long expertMentorId = null;
  144. Long expertBusinessId = null;
  145. if ("admin".equals(roleKey) || "jy_admnin".equals(roleKey)) {
  146. userList = null;
  147. } else if ("jy_bd_manage".equals(roleKey) || "jy_scissors_manage".equals(roleKey) || "jy_out_operation_manager".equals(roleKey)) {
  148. // 骄阳渠道经理、骄阳剪手经理 可以看到自己创建的以及自己部门人员的达人信息
  149. Long deptId = deptService.getDeptIdByUserId(userId);
  150. userList = deptService.getDeptUserListByDeptId(deptId);
  151. } else if ("jy_bd".equals(roleKey) || "jy_scissors".equals(roleKey) || "jy_out_operation".equals(roleKey)) {
  152. // 骄阳渠道、骄阳-剪手 可以看到自己创建的达人信息
  153. userList = Arrays.asList(userId);
  154. } else if ("jy_expert_mentor".equals(roleKey) || "jy_expert_business".equals(roleKey)) {
  155. if ("jy_expert_mentor".equals(roleKey)) {
  156. expertMentorId = userId;
  157. }
  158. if ("jy_expert_business".equals(roleKey)) {
  159. expertBusinessId = userId;
  160. }
  161. } else {
  162. return Collections.emptyList();
  163. }
  164. if (Check.isNull(parameter)) {
  165. parameter = "create_time";
  166. } else {
  167. switch (parameter) {
  168. case "avg_video_sales":
  169. parameter = "avgVideoSalesOrder";
  170. break;
  171. case "video_sales":
  172. parameter = "videoSalesOrder";
  173. break;
  174. case "total_sale":
  175. parameter = "totalSaleOrder";
  176. break;
  177. }
  178. }
  179. if (Check.isNull(orderBy)) {
  180. orderBy = "desc";
  181. }
  182. PageUtils.startPage();
  183. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.selectKuaishouPromoterList3(userList, promoterId, promoterNickName, mediaId, type, parameter, orderBy, expertMentorId, expertBusinessId);
  184. list.forEach(ent -> {
  185. JSONObject follow = kuaishouPromoterMapper.getFollowUpRecordsByUserId(ent.getPromoterId(), ent.getUserId());
  186. ent.setFollowUpRecord(Check.isNull(follow) ? "-" : follow.getString("txt"));
  187. List<JSONObject> promoterLabelList = kuaishouPromoterMapper.getPromoterLabel(ent.getPromoterId(), ent.getUserId());
  188. ent.setLabels(promoterLabelList);
  189. });
  190. return list;
  191. }
  192. @Override
  193. public List<JSONObject> selectKuaishouPromoterList2(Long userId, String promoterId, String promoterNickName, String status, String parameter, String orderBy) {
  194. if (Check.isNull(parameter)) {
  195. parameter = "promoterId";
  196. } else if ("avgVideoSales".equals(parameter)) {
  197. parameter = "avgVideoSalesOrder";
  198. } else if ("videoSales".equals(parameter)) {
  199. parameter = "videoSalesOrder";
  200. }
  201. if (Check.isNull(orderBy)) {
  202. orderBy = "desc";
  203. }
  204. PageUtils.startPage();
  205. List<JSONObject> list = kuaishouPromoterMapper.selectAllPromoterList(userId, promoterId, promoterNickName, status, parameter, orderBy);
  206. return list;
  207. }
  208. /**
  209. * 查询快手达人 信息
  210. *
  211. * @param id 快手达人 信息主键
  212. * @return 快手达人 信息
  213. */
  214. @Override
  215. public JSONObject selectKuaishouPromoterById(Long id) {
  216. JSONObject data = new JSONObject();
  217. JSONObject result = null;
  218. try {
  219. KuaishouPromoter promoter = kuaishouPromoterMapper.selectKuaishouPromoterById(id);
  220. if (Check.isNotNull(promoter)) {
  221. Thread thread = new Thread() {
  222. @Override
  223. public void run() {
  224. try {
  225. editPromoter(promoter.getId(), promoter.getMediaId(), promoter.getPromoterId(), true);
  226. } catch (Exception e) {
  227. e.printStackTrace();
  228. }
  229. }
  230. };
  231. thread.start();
  232. Long startTime = System.currentTimeMillis();
  233. String content = HttpUtil.httpGetRequest(internalIpPath + "kuaiShou/promoter/getPromoterInfo?promoterId=" + promoter.getPromoterId());
  234. result = JSONObject.parseObject(content);
  235. data.put("promoterInfo", promoter);
  236. data.put("result", result);
  237. //跟进记录
  238. JSONObject followUpRecord = kuaishouPromoterMapper.getFollowUpRecordsByUserId(promoter.getPromoterId(), promoter.getUserId());
  239. data.put("followUpRecord", followUpRecord);
  240. Long followUpRecordId = null;
  241. if (Check.isNotNull(followUpRecord)) {
  242. followUpRecordId = followUpRecord.getLong("id");
  243. }
  244. List<JSONObject> followUpRecordList = kuaishouPromoterMapper.getFollowUpRecordListByPromoterId(promoter.getPromoterId(), followUpRecordId);
  245. data.put("historyFollowUpRecord", followUpRecordList);
  246. //标签
  247. List<JSONObject> promoterLabelList = kuaishouPromoterMapper.getPromoterLabel(promoter.getPromoterId(), promoter.getUserId());
  248. data.put("promoterLabelList", promoterLabelList);
  249. }
  250. } catch (Exception e) {
  251. e.printStackTrace();
  252. log.error("获取达人详情数据异常,{}", result);
  253. }
  254. return data;
  255. }
  256. /**
  257. * 新增快手达人 信息
  258. */
  259. @Override
  260. public JSONObject insertKuaishouPromoter(KuaishouPromoter promoter) {
  261. JSONObject result = new JSONObject();
  262. promoter.setPromoterId(promoter.getPromoterId().trim());
  263. KuaishouPromoter one = kuaishouPromoterMapper.getOneByIdAndPromoterId(promoter.getUserId(), promoter.getPromoterId());
  264. if (Check.isNotNull(one)) {
  265. result.put("code", 500);
  266. result.put("msg", "该数据已存在,请重新输入");
  267. return result;
  268. }
  269. // 如果 达人ID是字母 并且 媒体是快手,说明操作失误,媒体改为抖音
  270. if (!isNumeric(promoter.getPromoterId()) && "2".equals(promoter.getMediaId())) {
  271. promoter.setMediaId("1");
  272. }
  273. // if ("2".equals(promoter.getMediaId())) {
  274. // 快手、抖音 同一达人ID 不能绑定到多个渠道角色用户上
  275. String roleKey = sysUserService.getRoleKeyByUserId(promoter.getUserId());
  276. if (roleKey.contains("bd")) {
  277. List<JSONObject> keys = kuaishouPromoterMapper.getBoundPromoterRoleKey(promoter.getPromoterId());
  278. if (Check.isNotNull(keys)) {
  279. for (JSONObject key : keys) {
  280. String rKey = key.getString("role_key");
  281. if ("bd".equals(rKey) || "bdManager".equals(rKey) || "supplyChainAdmin".equals(rKey)) {
  282. result.put("code", 500);
  283. result.put("msg", "该达人已被其他渠道人员绑定,绑定人:" + key.getString("user_name"));
  284. return result;
  285. }
  286. }
  287. }
  288. }
  289. // }
  290. //查询 设置可绑定达人数
  291. Integer count = kuaishouPromoterMapper.getUserPromotersCount(promoter.getUserId(), promoter.getMediaId());
  292. if (Check.isNotNull(count)) {
  293. //查询 已绑定达人数
  294. Integer hCount = kuaishouPromoterMapper.getBoundCount(promoter.getUserId());
  295. if (Check.isNotNull(hCount) && hCount >= count) {
  296. result.put("code", 500);
  297. result.put("msg", "绑定达人数过多,暂无法绑定!");
  298. return result;
  299. }
  300. }
  301. SysUser sysUser = sysUserService.selectUserById(promoter.getUserId());
  302. if (Check.isNotNull(sysUser)) {
  303. promoter.setUserName(sysUser.getNickName());
  304. }
  305. kuaishouPromoterMapper.insertKuaishouPromoter(promoter);
  306. editPromoter(promoter.getId(), promoter.getMediaId(), promoter.getPromoterId(), true);
  307. result.put("code", 200);
  308. result.put("msg", "success");
  309. return result;
  310. }
  311. /**
  312. * 同步更新数据
  313. */
  314. private void editPromoter(Long id, String mediaId, String promoterId, boolean flag) {
  315. try {
  316. if (flag) {
  317. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  318. String key = DateUtils.getDate() + "_" + id + "_" + promoterId;
  319. String value = (String) redisUtil.get(key);
  320. if (Check.isNotNull(value) && "1".equals(value)) {
  321. return;
  322. }
  323. redisUtil.set(key, "1", 60 * 60 * 24);
  324. }
  325. /*更新达人数据*/
  326. Map<String, Object> param = new HashMap<>();
  327. param.put("promoterId", promoterId);
  328. param.put("mediaId", mediaId);
  329. Long startTime = System.currentTimeMillis();
  330. String content = "";
  331. if ("2".equals(mediaId)) {
  332. //睡眠: 随机数3的倍数 3、6、9 ...33s
  333. Thread.sleep(1000 * (int) (1 + Math.random() * 11) * 3);
  334. content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  335. } else {
  336. Thread.sleep(60000);
  337. content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  338. }
  339. JSONObject result = JSONObject.parseObject(content);
  340. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  341. log.info("--------------------RuiXuan达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
  342. String province = "";
  343. if (Check.isNotNull(result.getString("province"))) {
  344. province = result.getString("province").concat("-").concat(result.getString("city"));
  345. }
  346. KuaishouPromoter kuaishouPromoter = new KuaishouPromoter(
  347. id,
  348. result.getString("promoterNickName"),
  349. province,
  350. result.getString("promoterHeadImgUrl"),
  351. result.getString("fanNum"),
  352. result.getString("avgVideoSales"),
  353. result.getString("videoSales"),
  354. result.getString("totalSale"),
  355. promoterId
  356. );
  357. if ("1".equals(mediaId)) {
  358. String followerincr = result.getString("follower_incr");
  359. if (Check.isNotNull(followerincr) && !"-".equals(followerincr)) {
  360. kuaishouPromoter.setFollowerIncr(result.getLong("follower_incr"));
  361. } else {
  362. kuaishouPromoter.setFollowerIncr(0l);
  363. }
  364. kuaishouPromoter.setLiveCount30(result.getInteger("live_count_30"));
  365. kuaishouPromoter.setLiveAverageUser30(result.getString("live_average_user_30"));
  366. kuaishouPromoter.setAwemeDiggFollowerRation(result.getString("aweme_digg_follower_ration"));
  367. kuaishouPromoter.setAwemeAvgDiggCount30(result.getLong("aweme_avg_digg_count_30"));
  368. }
  369. kuaishouPromoterMapper.updateKuaishouPromoterByPromoterId(kuaishouPromoter);
  370. } else {
  371. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  372. }
  373. } catch (Exception e) {
  374. e.printStackTrace();
  375. log.error("更新达人信息异常", e);
  376. }
  377. }
  378. /**
  379. * 同步更新数据
  380. */
  381. private void editPromoter3(Long id, String mediaId, String promoterId, boolean flag) {
  382. try {
  383. if (flag) {
  384. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  385. String key = DateUtils.getDate() + "_" + promoterId + "_" + id;
  386. String value = (String) redisUtil.get(key);
  387. if (Check.isNotNull(value) && "1".equals(value)) {
  388. return;
  389. }
  390. redisUtil.set(key, "1", 60 * 60 * 24);
  391. }
  392. //睡眠: 随机数3的倍数 3、6、9 ...33s
  393. Thread.sleep(1000 * (int) (1 + Math.random() * 11) * 3);
  394. /*更新达人数据*/
  395. Map<String, Object> param = new HashMap<>();
  396. param.put("promoterId", promoterId);
  397. param.put("mediaId", mediaId);
  398. Long startTime = System.currentTimeMillis();
  399. String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  400. JSONObject result = JSONObject.parseObject(content);
  401. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  402. log.info("--------------------JY达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
  403. String province = "";
  404. if (Check.isNotNull(result.getString("province"))) {
  405. province = result.getString("province").concat("-").concat(result.getString("city"));
  406. }
  407. JYKuaishouPromoter kuaishouPromoter = new JYKuaishouPromoter(
  408. id,
  409. result.getString("promoterNickName"),
  410. province,
  411. result.getString("promoterHeadImgUrl"),
  412. result.getString("fanNum"),
  413. result.getString("avgVideoSales"),
  414. result.getString("videoSales"),
  415. result.getString("totalSale"),
  416. promoterId
  417. );
  418. kuaishouPromoterMapper.updateKuaishouPromoterByPromoterId3(kuaishouPromoter);
  419. } else {
  420. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  421. }
  422. } catch (Exception e) {
  423. e.printStackTrace();
  424. log.error("更新达人信息异常", e);
  425. }
  426. }
  427. /**
  428. * Miaogousi同步更新数据
  429. */
  430. private void editMiaogousiPromoter(Long id, String mediaId, String promoterId, boolean flag) {
  431. try {
  432. if (flag) {
  433. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  434. String key = DateUtils.getDate() + "mgs_" + promoterId + "_" + id;
  435. String value = (String) redisUtil.get(key);
  436. if (Check.isNotNull(value) && "1".equals(value)) {
  437. return;
  438. }
  439. redisUtil.set(key, "1", 60 * 60 * 24);
  440. }
  441. //睡眠: 随机数3的倍数 3、6、9 ...33s
  442. Thread.sleep(1000 * (int) (1 + Math.random() * 11) * 3);
  443. /*更新达人数据*/
  444. Map<String, Object> param = new HashMap<>();
  445. param.put("promoterId", promoterId);
  446. param.put("mediaId", mediaId);
  447. Long startTime = System.currentTimeMillis();
  448. String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  449. JSONObject result = JSONObject.parseObject(content);
  450. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  451. log.info("--------------------Miaogousi达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
  452. String province = "";
  453. if (Check.isNotNull(result.getString("province"))) {
  454. province = result.getString("province").concat("-").concat(result.getString("city"));
  455. }
  456. KuaishouPromoter kuaishouPromoter = new KuaishouPromoter(
  457. id,
  458. result.getString("promoterNickName"),
  459. province,
  460. result.getString("promoterHeadImgUrl"),
  461. result.getString("fanNum"),
  462. result.getString("avgVideoSales"),
  463. result.getString("videoSales"),
  464. result.getString("totalSale"),
  465. promoterId
  466. );
  467. kuaishouPromoterMapper.updateMiaogousiKuaishouPromoterByPromoterId(kuaishouPromoter);
  468. } else {
  469. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  470. }
  471. } catch (Exception e) {
  472. e.printStackTrace();
  473. log.error("更新达人信息异常", e);
  474. }
  475. }
  476. /**
  477. * Rocket同步更新数据
  478. */
  479. private void editRocketPromoter(Long id, String mediaId, String promoterId, boolean flag) {
  480. try {
  481. if (flag) {
  482. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  483. String key = DateUtils.getDate() + "rocket_" + promoterId + "_" + id;
  484. String value = (String) redisUtil.get(key);
  485. if (Check.isNotNull(value) && "1".equals(value)) {
  486. return;
  487. }
  488. redisUtil.set(key, "1", 60 * 60 * 24);
  489. }
  490. //睡眠: 随机数3的倍数 3、6、9 ...33s
  491. Thread.sleep(1000 * (int) (1 + Math.random() * 11) * 3);
  492. /*更新达人数据*/
  493. Map<String, Object> param = new HashMap<>();
  494. param.put("promoterId", promoterId);
  495. param.put("mediaId", mediaId);
  496. Long startTime = System.currentTimeMillis();
  497. String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  498. JSONObject result = JSONObject.parseObject(content);
  499. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  500. log.info("--------------------Rocket达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
  501. String province = "";
  502. if (Check.isNotNull(result.getString("province"))) {
  503. province = result.getString("province").concat("-").concat(result.getString("city"));
  504. }
  505. KuaishouPromoter kuaishouPromoter = new KuaishouPromoter(
  506. id,
  507. result.getString("promoterNickName"),
  508. province,
  509. result.getString("promoterHeadImgUrl"),
  510. result.getString("fanNum"),
  511. result.getString("avgVideoSales"),
  512. result.getString("videoSales"),
  513. result.getString("totalSale"),
  514. promoterId
  515. );
  516. kuaishouPromoterMapper.updateRocketKuaishouPromoterByPromoterId(kuaishouPromoter);
  517. } else {
  518. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  519. }
  520. } catch (Exception e) {
  521. e.printStackTrace();
  522. log.error("更新达人信息异常", e);
  523. }
  524. }
  525. /**
  526. * Yufu同步更新数据
  527. */
  528. private void editYufuPromoter(Long id, String mediaId, String promoterId, boolean flag) {
  529. try {
  530. if (flag) {
  531. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  532. String key = DateUtils.getDate() + "yufu_" + promoterId + "_" + id;
  533. String value = (String) redisUtil.get(key);
  534. if (Check.isNotNull(value) && "1".equals(value)) {
  535. return;
  536. }
  537. redisUtil.set(key, "1", 60 * 60 * 24);
  538. }
  539. //睡眠: 随机数3的倍数 3、6、9 ...33s
  540. Thread.sleep(1000 * (int) (1 + Math.random() * 11) * 3);
  541. /*更新达人数据*/
  542. Map<String, Object> param = new HashMap<>();
  543. param.put("promoterId", promoterId);
  544. param.put("mediaId", mediaId);
  545. Long startTime = System.currentTimeMillis();
  546. String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  547. JSONObject result = JSONObject.parseObject(content);
  548. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  549. log.info("--------------------Yufu达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
  550. String province = "";
  551. if (Check.isNotNull(result.getString("province"))) {
  552. province = result.getString("province").concat("-").concat(result.getString("city"));
  553. }
  554. KuaishouPromoter kuaishouPromoter = new KuaishouPromoter(
  555. id,
  556. result.getString("promoterNickName"),
  557. province,
  558. result.getString("promoterHeadImgUrl"),
  559. result.getString("fanNum"),
  560. result.getString("avgVideoSales"),
  561. result.getString("videoSales"),
  562. result.getString("totalSale"),
  563. promoterId
  564. );
  565. kuaishouPromoterMapper.updateYufuKuaishouPromoterByPromoterId(kuaishouPromoter);
  566. } else {
  567. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  568. }
  569. } catch (Exception e) {
  570. e.printStackTrace();
  571. log.error("更新达人信息异常", e);
  572. }
  573. }
  574. /**
  575. * Yuxiu同步更新数据
  576. */
  577. private void editYuxiuPromoter(Long id, String mediaId, String promoterId, boolean flag) {
  578. try {
  579. if (flag) {
  580. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  581. String key = DateUtils.getDate() + "yuxiu_" + promoterId + "_" + id;
  582. String value = (String) redisUtil.get(key);
  583. if (Check.isNotNull(value) && "1".equals(value)) {
  584. return;
  585. }
  586. redisUtil.set(key, "1", 60 * 60 * 24);
  587. }
  588. //睡眠: 随机数3的倍数 3、6、9 ...33s
  589. Thread.sleep(1000 * (int) (1 + Math.random() * 11) * 3);
  590. /*更新达人数据*/
  591. Map<String, Object> param = new HashMap<>();
  592. param.put("promoterId", promoterId);
  593. param.put("mediaId", mediaId);
  594. Long startTime = System.currentTimeMillis();
  595. String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  596. JSONObject result = JSONObject.parseObject(content);
  597. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  598. log.info("--------------------Yuxiu达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
  599. String province = "";
  600. if (Check.isNotNull(result.getString("province"))) {
  601. province = result.getString("province").concat("-").concat(result.getString("city"));
  602. }
  603. KuaishouPromoter kuaishouPromoter = new KuaishouPromoter(
  604. id,
  605. result.getString("promoterNickName"),
  606. province,
  607. result.getString("promoterHeadImgUrl"),
  608. result.getString("fanNum"),
  609. result.getString("avgVideoSales"),
  610. result.getString("videoSales"),
  611. result.getString("totalSale"),
  612. promoterId
  613. );
  614. kuaishouPromoterMapper.updateYuxiuKuaishouPromoterByPromoterId(kuaishouPromoter);
  615. } else {
  616. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  617. }
  618. } catch (Exception e) {
  619. e.printStackTrace();
  620. log.error("更新达人信息异常", e);
  621. }
  622. }
  623. /**
  624. * zhishui同步更新数据
  625. */
  626. private void editZhishuiPromoter(Long id, String mediaId, String promoterId, boolean flag) {
  627. try {
  628. if (flag) {
  629. /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
  630. String key = DateUtils.getDate() + "zhishui_" + promoterId + "_" + id;
  631. String value = (String) redisUtil.get(key);
  632. if (Check.isNotNull(value) && "1".equals(value)) {
  633. return;
  634. }
  635. redisUtil.set(key, "1", 60 * 60 * 24);
  636. }
  637. //睡眠: 随机数3的倍数 3、6、9 ...33s
  638. Thread.sleep(1000 * (int) (1 + Math.random() * 11) * 3);
  639. /*更新达人数据*/
  640. Map<String, Object> param = new HashMap<>();
  641. param.put("promoterId", promoterId);
  642. param.put("mediaId", mediaId);
  643. Long startTime = System.currentTimeMillis();
  644. String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
  645. JSONObject result = JSONObject.parseObject(content);
  646. if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
  647. log.info("--------------------Zhishui达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
  648. String province = "";
  649. if (Check.isNotNull(result.getString("province"))) {
  650. province = result.getString("province").concat("-").concat(result.getString("city"));
  651. }
  652. KuaishouPromoter kuaishouPromoter = new KuaishouPromoter(
  653. id,
  654. result.getString("promoterNickName"),
  655. province,
  656. result.getString("promoterHeadImgUrl"),
  657. result.getString("fanNum"),
  658. result.getString("avgVideoSales"),
  659. result.getString("videoSales"),
  660. result.getString("totalSale"),
  661. promoterId
  662. );
  663. kuaishouPromoterMapper.updateZhishuiKuaishouPromoterByPromoterId(kuaishouPromoter);
  664. } else {
  665. log.error("更新达人失败,达人ID:{} 【返回结果】:{}", promoterId, result);
  666. }
  667. } catch (Exception e) {
  668. e.printStackTrace();
  669. log.error("更新达人信息异常", e);
  670. }
  671. }
  672. @Override
  673. public JSONObject insertKuaishouPromoter3(JYKuaishouPromoter promoter) {
  674. JSONObject result = new JSONObject();
  675. promoter.setPromoterId(promoter.getPromoterId().trim());
  676. KuaishouPromoter one = kuaishouPromoterMapper.getOneByIdAndPromoterId3(null, promoter.getPromoterId());
  677. if (Check.isNotNull(one)) {
  678. result.put("code", 500);
  679. result.put("msg", "达人已被绑定,请重新选择 (绑定人:" + one.getUserName() + ")");
  680. return result;
  681. }
  682. SysUser sysUser = sysUserService.selectUserById(promoter.getUserId());
  683. if (Check.isNotNull(sysUser)) {
  684. promoter.setUserName(sysUser.getNickName());
  685. }
  686. if (!Check.isNull(promoter.getExpertBusinessId())) {
  687. SysUser businessUser = sysUserService.selectUserById(promoter.getExpertBusinessId());
  688. if (!Check.isNull(businessUser)) {
  689. promoter.setExpertBusinessName(businessUser.getNickName());
  690. }
  691. }
  692. if (!Check.isNull(promoter.getExpertMentorId())) {
  693. SysUser mentorUser = sysUserService.selectUserById(promoter.getExpertMentorId());
  694. if (!Check.isNull(mentorUser)) {
  695. promoter.setExpertMentorName(mentorUser.getNickName());
  696. }
  697. }
  698. kuaishouPromoterMapper.insertKuaishouPromoter3(promoter);
  699. if (promoter.getMediaId().equals("2")) {
  700. addAuth(Long.valueOf(promoter.getPromoterId()));
  701. }
  702. editPromoter3(promoter.getId(), promoter.getMediaId(), promoter.getPromoterId(), true);
  703. result.put("code", 200);
  704. result.put("msg", "success");
  705. return result;
  706. }
  707. @Override
  708. public JSONObject addAuth(Long promoterId) {
  709. String cookie = kuaishouPromoterMapper.getAuthCookie();
  710. Map<String, Object> param = new HashMap<>();
  711. param.put("userId", promoterId);
  712. param.put("appKey", "ks690458118961229051");
  713. param.put("type", 2);
  714. Map<String, String> headers = new HashMap<>();
  715. headers.put("Cookie", cookie);
  716. String url = "https://open.kwaixiaodian.com/rest/open/platform/oauth/add";
  717. String s = HttpUtil.httpPostRequest(url, param, headers);
  718. JSONObject jsonObject = JSONObject.parseObject(s);
  719. log.info("爬虫增加授权账户返回信息:{}", jsonObject);
  720. return jsonObject;
  721. }
  722. static ExecutorService editPromoterService = Executors.newFixedThreadPool(6);
  723. @Override
  724. public Result supplementInfo() {
  725. List<String> promoters = new ArrayList<>();
  726. List<KuaishouPromoter> list = kuaishouPromoterMapper.getFailInfo();
  727. if (!Check.isNull(list)) {
  728. list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
  729. try {
  730. editPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false);
  731. } catch (Exception e) {
  732. e.printStackTrace();
  733. }
  734. }));
  735. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId() + "[" + ("2".equals(kuaishouPromoter.getMediaId()) ? "快手" : "头条") + "]"));
  736. }
  737. promoters.add(supplementInfo3());
  738. promoters.add(miaogousiInfo());
  739. promoters.add(rocketInfo());
  740. promoters.add(yufuInfo());
  741. promoters.add(yuxiuInfo());
  742. promoters.add(zhishuiInfo());
  743. return Result.success("达人数据更新 -------------<睿选>共计:" + list.size() + "条", promoters);
  744. }
  745. //骄阳补全
  746. public String supplementInfo3() {
  747. List<String> promoters = new ArrayList<>();
  748. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getFailInfo3();
  749. if (!Check.isNull(list)) {
  750. list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
  751. try {
  752. editPromoter3(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false);
  753. } catch (Exception e) {
  754. e.printStackTrace();
  755. }
  756. }));
  757. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
  758. }
  759. return "-------------骄阳共计" + list.size() + "条,达人id: " + promoters.toString();
  760. }
  761. //miaogousi
  762. public String miaogousiInfo() {
  763. List<String> promoters = new ArrayList<>();
  764. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getMiaogousiInfoFailInfo();
  765. if (!Check.isNull(list)) {
  766. list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
  767. try {
  768. editMiaogousiPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false);
  769. } catch (Exception e) {
  770. e.printStackTrace();
  771. }
  772. }));
  773. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
  774. }
  775. return "-------------miaogousi共计" + list.size() + "条,达人id: " + promoters.toString();
  776. }
  777. //rocket
  778. public String rocketInfo() {
  779. List<String> promoters = new ArrayList<>();
  780. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getRocketFailInfo();
  781. if (!Check.isNull(list)) {
  782. list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
  783. try {
  784. editRocketPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false);
  785. } catch (Exception e) {
  786. e.printStackTrace();
  787. }
  788. }));
  789. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
  790. }
  791. return "-------------rocket共计" + list.size() + "条,达人id: " + promoters.toString();
  792. }
  793. //yufu
  794. public String yufuInfo() {
  795. List<String> promoters = new ArrayList<>();
  796. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getYufuFailInfo();
  797. if (!Check.isNull(list)) {
  798. list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
  799. try {
  800. editYufuPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false);
  801. } catch (Exception e) {
  802. e.printStackTrace();
  803. }
  804. }));
  805. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
  806. }
  807. return "-------------yufu共计" + list.size() + "条,达人id: " + promoters.toString();
  808. }
  809. //yuxiu
  810. public String yuxiuInfo() {
  811. List<String> promoters = new ArrayList<>();
  812. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getYuxiuFailInfo();
  813. if (!Check.isNull(list)) {
  814. list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
  815. try {
  816. editYuxiuPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false);
  817. } catch (Exception e) {
  818. e.printStackTrace();
  819. }
  820. }));
  821. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
  822. }
  823. return "-------------yuxiu共计" + list.size() + "条,达人id: " + promoters.toString();
  824. }
  825. //zhishui
  826. public String zhishuiInfo() {
  827. List<String> promoters = new ArrayList<>();
  828. List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getZhishuiFailInfo();
  829. if (!Check.isNull(list)) {
  830. list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
  831. try {
  832. editZhishuiPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false);
  833. } catch (Exception e) {
  834. e.printStackTrace();
  835. }
  836. }));
  837. list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
  838. }
  839. return "-------------zhishui共计" + list.size() + "条,达人id: " + promoters.toString();
  840. }
  841. @Override
  842. public int addFollowUpRecords(JSONObject result) {
  843. return kuaishouPromoterMapper.addFollowUpRecords(result);
  844. }
  845. @Override
  846. public void updateFollowUpRecords(JSONObject result) {
  847. kuaishouPromoterMapper.updateFollowUpRecords(result);
  848. }
  849. @Override
  850. public Result getGongHaiVideoSales(String promoterId) {
  851. Map<String, Object> param = new HashMap<>();
  852. param.put("promoterId", promoterId);
  853. String url = startIpPath + "promoterInfo/updatePromoter";
  854. String content = HttpUtil.httpPostRequest(url, param, null);
  855. if ("0".equals(content)) {
  856. return Result.success();
  857. } else {
  858. log.error("查询达人公海销售额失败,达人ID:{}\nurl:{}", promoterId, url);
  859. return Result.error("失败");
  860. }
  861. }
  862. @Override
  863. public KuaishouPromoter getOnlyPromoterInfoByUserId(String promoterId, Long userId) {
  864. return kuaishouPromoterMapper.getOnlyPromoterInfoByUserId(promoterId, userId);
  865. }
  866. @Override
  867. public JSONObject addPromotersCount(Long userId, Long promotersCount, String mediaId) {
  868. kuaishouPromoterMapper.addPromotersCount(userId, promotersCount, mediaId);
  869. JSONObject result = new JSONObject();
  870. result.put("code", 200);
  871. result.put("msg", "success");
  872. return result;
  873. }
  874. @Override
  875. public String getRuleName(Long ruleId) {
  876. return kuaishouPromoterMapper.getRuleName(ruleId);
  877. }
  878. @Override
  879. public int addRule(String promoterId, Long ruleId, String ruleName) {
  880. return kuaishouPromoterMapper.addRule(promoterId, ruleId, ruleName);
  881. }
  882. @Override
  883. public List<String> selectPromoterIdListByTime(List<Long> userList, Long startDate, Long endDate) {
  884. return kuaishouPromoterMapper.selectPromoterIdListByTime(userList, startDate, endDate);
  885. }
  886. @Override
  887. public Result updatePromoterLabel(JSONObject result) {
  888. String promoterId = result.getString("promoterId");
  889. Long userId = result.getLong("userId");
  890. kuaishouPromoterMapper.deletePromoterLabel(promoterId, userId);
  891. JSONArray ids = result.getJSONArray("ids");
  892. if (Check.isNotNull(ids)) {
  893. List<JSONObject> list = new ArrayList<>();
  894. for (int i = 0; i < ids.size(); i++) {
  895. JSONObject obj = new JSONObject();
  896. Long labelId = ids.getLong(i);
  897. obj.put("promoterId", promoterId);
  898. obj.put("labelId", labelId);
  899. obj.put("userId", userId);
  900. list.add(obj);
  901. }
  902. kuaishouPromoterMapper.insertPromoterLabels(list);
  903. }
  904. return Result.success();
  905. }
  906. /**
  907. * 修改快手达人 信息
  908. *
  909. * @param kuaishouPromoter 快手达人 信息
  910. * @return 结果
  911. */
  912. @Override
  913. public int updateKuaishouPromoter(KuaishouPromoter kuaishouPromoter) {
  914. return kuaishouPromoterMapper.updateKuaishouPromoter(kuaishouPromoter);
  915. }
  916. /**
  917. * 修改快手达人 信息
  918. *
  919. * @param kuaishouPromoter 快手达人 信息
  920. * @return 结果
  921. */
  922. @Override
  923. public int updateKuaishouPromoter3(JYKuaishouPromoter promoter) {
  924. if (!Check.isNull(promoter.getExpertBusinessId())) {
  925. SysUser businessUser = sysUserService.selectUserById(promoter.getExpertBusinessId());
  926. if (!Check.isNull(businessUser)) {
  927. promoter.setExpertBusinessName(businessUser.getNickName());
  928. }
  929. }
  930. if (!Check.isNull(promoter.getExpertMentorId())) {
  931. SysUser mentorUser = sysUserService.selectUserById(promoter.getExpertMentorId());
  932. if (!Check.isNull(mentorUser)) {
  933. promoter.setExpertMentorName(mentorUser.getNickName());
  934. }
  935. }
  936. return kuaishouPromoterMapper.updateKuaishouPromoter3(promoter);
  937. }
  938. /**
  939. * 删除快手达人 信息信息
  940. *
  941. * @param id 快手达人 信息主键 follow_up_records
  942. * @return 结果
  943. */
  944. @Override
  945. public Result deleteKuaishouPromoterById(Long id, Long userId) {
  946. KuaishouPromoter promoter = kuaishouPromoterMapper.selectKuaishouPromoterById(id);
  947. List<KuaishouItemCollectSamples> list = kuaishouItemCollectSamplesService.getListByPromoterId(promoter.getPromoterId(), userId);
  948. for (KuaishouItemCollectSamples item : list) {
  949. if (item.getCollectSampleStatus() != 2 && item.getCollectSampleStatus() != 7) {
  950. return Result.error("该达人还有未完成的领样申请,请在完成后进行解绑!");
  951. }
  952. }
  953. if (Check.isNotNull(promoter)) {
  954. JSONObject record = new JSONObject();
  955. record.put("promoterId", promoter.getPromoterId());
  956. record.put("userId", promoter.getUserId());
  957. record.put("operatorId", userId);
  958. List<JSONObject> roles = sysUserService.getUserRoleByUserId(userId);
  959. if (Check.isNotNull(roles)) {
  960. record.put("roleName", roles.get(0).getString("role_name"));
  961. record.put("roleKey", roles.get(0).getString("role_key"));
  962. }
  963. kuaishouPromoterMapper.insertKuaishouPromoterRecord(record);
  964. }
  965. kuaishouPromoterMapper.deleteKuaishouPromoterById(id);
  966. return Result.success();
  967. }
  968. /**
  969. * 删除快手达人 信息信息
  970. *
  971. * @param id 快手达人 信息主键 follow_up_records
  972. * @return 结果
  973. */
  974. @Override
  975. public Result deleteKuaishouPromoterById3(Long id, Long userId) {
  976. JYKuaishouPromoter promoter = kuaishouPromoterMapper.selectKuaishouPromoterById3(id);
  977. if (Check.isNotNull(promoter)) {
  978. JSONObject record = new JSONObject();
  979. record.put("promoterId", promoter.getPromoterId());
  980. record.put("userId", promoter.getUserId());
  981. record.put("operatorId", userId);
  982. List<JSONObject> roles = sysUserService.getUserRoleByUserId(userId);
  983. if (Check.isNotNull(roles)) {
  984. record.put("roleName", roles.get(0).getString("role_name") + " (解绑骄阳)");
  985. record.put("roleKey", roles.get(0).getString("role_key"));
  986. }
  987. kuaishouPromoterMapper.insertKuaishouPromoterRecord(record);
  988. }
  989. kuaishouPromoterMapper.deleteKuaishouPromoterById3(id);
  990. return Result.success();
  991. }
  992. @Override
  993. public JSONObject selectKuaishouRulePromoterById(Long promoterId) {
  994. return kuaishouPromoterMapper.selectKuaishouRulePromoterById(promoterId);
  995. }
  996. @Override
  997. public List<JSONObject> jyExpertMentorList() {
  998. return kuaishouPromoterMapper.jyExpertMentorList();
  999. }
  1000. @Override
  1001. public List<JSONObject> jyExpertBusiness() {
  1002. return kuaishouPromoterMapper.jyExpertBusiness();
  1003. }
  1004. @Value("${pcm.local-path}")
  1005. private String downloadPath;
  1006. @Override
  1007. public void importExcelMaterials(MultipartFile file) throws InterruptedException {
  1008. ExecutorService executorService = Executors.newFixedThreadPool(8);
  1009. long t1 = System.currentTimeMillis();
  1010. List<FirstDeliveryValidMaterials> dataList = null;
  1011. StringBuffer path = new StringBuffer();
  1012. try {
  1013. path.append(downloadPath).append(DateUtils.getNowDateStr()).append("/").append(UUID.randomUUID().toString()).append("/");
  1014. log.info("-------下载到服务器地址:{}", path.toString());
  1015. dataList = this.analysisBIGBIGFile(file, path.toString());
  1016. } catch (Exception e) {
  1017. e.printStackTrace();
  1018. throw new InterruptedException("解析excel失败");
  1019. } finally {
  1020. LoadFileUtil.delFile(path.toString());
  1021. }
  1022. if (!Check.isNull(dataList)) {
  1023. //根据当前年份和月份,删除旧数据
  1024. FirstDeliveryValidMaterials material = dataList.get(0);
  1025. deliveryValidMapper.delMaterials(material.getDeliveryYear(), material.getDeliveryMonth());
  1026. //插入 数据量大于5Q,分批插入
  1027. if (dataList.size() > 5000) {
  1028. List<List<FirstDeliveryValidMaterials>> splitList = Lists.newArrayList(Lists.partition(dataList, 5000));
  1029. splitList.forEach(materials -> executorService.submit(() -> {
  1030. deliveryValidMapper.replaceBatchMaterials(materials);
  1031. }));
  1032. } else {
  1033. deliveryValidMapper.replaceBatchMaterials(dataList);
  1034. }
  1035. }
  1036. executorService.shutdown();
  1037. while (true) {
  1038. if (executorService.isTerminated()) {
  1039. log.info("所有的子线程都结束了!");
  1040. //执行宇鹏提供的sql
  1041. deliveryValidMapper.replaceEtl();
  1042. break;
  1043. }
  1044. Thread.sleep(1000L);//休眠1秒钟
  1045. }
  1046. log.info("------共用时" + (System.currentTimeMillis() - t1) / 1000 + "秒");
  1047. }
  1048. @Override
  1049. public List<Long> getAllJyPromoterList() {
  1050. return kuaishouPromoterMapper.getAllJyPromoterList();
  1051. }
  1052. public List<FirstDeliveryValidMaterials> analysisBIGBIGFile(MultipartFile mfile, String path) throws Exception {
  1053. InputStream is = null;
  1054. String newFileUrl = FileUtil.approvalFile(mfile, path);
  1055. List<FirstDeliveryValidMaterials> dataList = null;
  1056. try {
  1057. File file = new File(newFileUrl);
  1058. is = new FileInputStream(file);
  1059. Workbook workbook = StreamingReader.builder()
  1060. .rowCacheSize(20000)
  1061. .bufferSize(4096)
  1062. .open(is);
  1063. ExportExcelUtils eeu = new ExportExcelUtils();
  1064. //最后一列(列数)
  1065. int lastCellNum = 0;
  1066. // list存储数据集
  1067. dataList = new ArrayList<>();
  1068. for (Sheet sheet : workbook) {
  1069. // sheet.getLastRowNum()获取最后一个非空行的行下标,比如总行数为n,则返回的为n-1
  1070. int sumPageNum = (sheet.getLastRowNum() + 1) / 20000 + 1; //计算分片数
  1071. for (int i = 1; i <= sumPageNum; i++) { //读取每片范围内的内容
  1072. int minRowNum = 20000 * (i - 1) + 1; //计算每片读取的行数范围
  1073. int maxRowNum = 20000 * i;
  1074. for (Row row : sheet) {
  1075. if (lastCellNum == 0) {
  1076. lastCellNum = row.getLastCellNum();
  1077. }
  1078. if (row != null) {
  1079. Map<String, Object> columnValueMap = new HashMap<>();
  1080. if (row.getRowNum() >= minRowNum && row.getRowNum() <= maxRowNum) {//控制每片读取的行
  1081. //每行数据对象,按照顺序从0到(lastCellNum-1)记录
  1082. JSONObject cellEntity = new JSONObject();
  1083. for (int k = 0; k < lastCellNum; k++) {
  1084. cellEntity.put(String.valueOf(k), eeu.getCellValue(row.getCell(k)));
  1085. }
  1086. FirstDeliveryValidMaterials material = new FirstDeliveryValidMaterials(cellEntity);
  1087. if ("走量".equals(material.getOperationLabel())) {
  1088. continue;
  1089. }
  1090. if (!Check.isNull(material.getStatDate())) {
  1091. material.setDeliveryYear(material.getStatDate().substring(0, 4));
  1092. }
  1093. dataList.add(material);
  1094. if (row.getRowNum() == maxRowNum) {//读取到每片最大行数限制,跳出,执行数据写入
  1095. break;
  1096. }
  1097. }
  1098. }
  1099. }
  1100. }
  1101. }
  1102. workbook.close();
  1103. } catch (Exception e) {
  1104. e.printStackTrace();
  1105. } finally {
  1106. IOUtils.closeQuietly(is);
  1107. }
  1108. return dataList;
  1109. }
  1110. @Override
  1111. public AjaxResult getPromoterInfo(String promoterId) {
  1112. AjaxResult ajaxResult = null;
  1113. try {
  1114. KuaishouPromoter promoter = kuaishouPromoterMapper.getOneByIdAndPromoterId(null, promoterId);
  1115. JSONObject data = new JSONObject();
  1116. if (Check.isNotNull(promoter)) {
  1117. Thread thread = new Thread() {
  1118. @Override
  1119. public void run() {
  1120. try {
  1121. editPromoter(promoter.getId(), promoter.getMediaId(), promoter.getPromoterId(), true);
  1122. } catch (Exception e) {
  1123. e.printStackTrace();
  1124. }
  1125. }
  1126. };
  1127. thread.start();
  1128. Long startTime = System.currentTimeMillis();
  1129. String content = HttpUtil.httpGetRequest(internalIpPath + "kuaiShou/promoter/getPromoterVideoInfo?promoterId=" + promoter.getPromoterId());
  1130. JSONObject result = JSONObject.parseObject(content);
  1131. log.info("获取达人视频销售数据,用时:{}s", (System.currentTimeMillis() - startTime) / 1000);
  1132. String start = DateUtils.getSubtractTime(new Date(), 31);
  1133. String end = DateUtils.getDate();
  1134. JSONObject info = kuaishouPromoterMapper.getNearlyMonthGmv(promoter.getPromoterId(), DateUtils.strDateToInt(start), DateUtils.strDateToInt(end));
  1135. if (Check.isNotNull(info)) {
  1136. data.put("orderAmount", info.getString("orderAmount"));
  1137. data.put("operationCompletionRate", info.getString("operationCompletionRate"));
  1138. }
  1139. if (Check.isNotNull(result)) {
  1140. data.put("avgVideoSales", result.getString("avgVideoSales"));
  1141. data.put("videoSales", result.getString("videoSales"));
  1142. }
  1143. data.put("promoterId", promoter.getPromoterId());
  1144. data.put("promoterUrl", promoter.getPromoterUrl());
  1145. }
  1146. ajaxResult = new AjaxResult(200, "查询成功", data);
  1147. } catch (Exception e) {
  1148. e.printStackTrace();
  1149. log.error("获取达人详情数据异常");
  1150. ajaxResult = new AjaxResult(500, "查询失败");
  1151. }
  1152. return ajaxResult;
  1153. }
  1154. @Override
  1155. public KuaishouPromoter getOnlyPromoterInfo(String promoterId) {
  1156. return kuaishouPromoterMapper.getOneByIdAndPromoterId(null, promoterId);
  1157. }
  1158. @Override
  1159. public List<String> selectPromoterIdList(List<Long> userList, String mediaId) {
  1160. return kuaishouPromoterMapper.selectPromoterIdList(userList, mediaId);
  1161. }
  1162. @Override
  1163. public JSONObject getgetMonthPromoterTotal(List<Long> userList, String start, String end, String mediaId) {
  1164. return kuaishouPromoterMapper.getgetMonthPromoterTotal(userList, start, end, mediaId);
  1165. }
  1166. /**
  1167. * 判断是否为数字
  1168. */
  1169. public static boolean isNumeric(String str) {
  1170. Pattern pattern = Pattern.compile("[0-9]*");
  1171. return pattern.matcher(str).matches();
  1172. }
  1173. }