From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 16 十月 2024 14:28:37 +0800 Subject: [PATCH] 将CMQ替换为rabbitmq --- fanli/src/main/java/com/yeshi/fanli/controller/client/v1/RecommendController.java | 34 +++++++++++++++++----------------- 1 files changed, 17 insertions(+), 17 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/RecommendController.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/RecommendController.java index 4b33637..f75e073 100644 --- a/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/RecommendController.java +++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/RecommendController.java @@ -608,7 +608,7 @@ TaoBaoGoodsBrief simpleGoods = null; try { - simpleGoods = redisManager.getTaoBaoGoodsBrief(Long.parseLong(id)); + simpleGoods = redisManager.getTaoBaoGoodsBrief(id); } catch (NumberFormatException e2) { e2.printStackTrace(); } catch (TaobaoGoodsDownException e2) { @@ -642,7 +642,7 @@ app.setAppKey(clientTBPid.getAppKey()); app.setAppSecret(config.getAppSecret()); app.setPid(clientTBPid.getPid()); - tb = TaoKeApiUtil.searchGoodsDetail(Long.parseLong(id), app); + tb = TaoKeApiUtil.searchGoodsDetail(id, app); } catch (NumberFormatException e1) { e1.printStackTrace(); } catch (TaobaoGoodsDownException e1) { @@ -669,7 +669,7 @@ taoBaoGoodsBriefExtra.setAuctionUrl(tb.getAuctionUrl()); if (uid != null && !"".equals(uid.trim())) { CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid), - Long.parseLong(id), Constant.SOURCE_TYPE_TAOBAO); + id, Constant.SOURCE_TYPE_TAOBAO); data.put("collection", collectionGoods != null ? true : false); } @@ -803,7 +803,7 @@ app.setAppSecret(config.getAppSecret()); app.setPid(clientPid); try { - goods = TaoKeApiUtil.searchGoodsDetail(Long.parseLong(id), app); + goods = TaoKeApiUtil.searchGoodsDetail(id, app); if (goods != null) { ticket.put("clickUrl", goods.getAuctionUrl()); // 娴嬭瘯浣跨敤 @@ -822,7 +822,7 @@ } } else { try { - goods = redisManager.getTaoBaoGoodsBrief(Long.parseLong(id)); + goods = redisManager.getTaoBaoGoodsBrief(id); } catch (TaobaoGoodsDownException e) { try { monitorService.addClientAPIMonitor(MonitorFactory.createClientAPI(request, 0, 0, "鍟嗗搧涓嬫灦")); @@ -832,7 +832,7 @@ // 鍟嗗搧涓嬫灦 ThreadUtil.run(new Runnable() { public void run() { - taoBaoGoodsUpdateService.deleteTaoBaoGoods(Long.parseLong(id)); + taoBaoGoodsUpdateService.deleteTaoBaoGoods(id); } }); @@ -855,7 +855,7 @@ }); } } else if (task.equalsIgnoreCase("imgs")) {// 鑾峰彇鍥炬枃璇︽儏 - List<ImageInfo> imgs = redisManager.getTaoBaoGoodsDetailImgs(Long.parseLong(id), acceptData.getSystem()); + List<ImageInfo> imgs = redisManager.getTaoBaoGoodsDetailImgs(id, acceptData.getSystem()); if (imgs != null && imgs.size() > 0) { detailImgs.clear(); detailImgsSize.clear(); @@ -929,7 +929,7 @@ // 鍒ゆ柇鏀惰棌 if (!StringUtil.isNullOrEmpty(uid)) { CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid), - Long.parseLong(id), Constant.SOURCE_TYPE_TAOBAO); + id, Constant.SOURCE_TYPE_TAOBAO); data.put("collected", collectionGoods != null ? true : false); } else data.put("collected", false); @@ -1021,7 +1021,7 @@ * @param out */ @RequestMapping(value = "gettaobaolink") - public void getTaobaoLink(AcceptData acceptData, String uid, Long id, PrintWriter out) { + public void getTaobaoLink(AcceptData acceptData, String uid, String id, PrintWriter out) { ClientTBPid clientTBPid = null; // 鐢ㄦ埛宸茬粡鐧诲綍 if (!StringUtil.isNullOrEmpty(uid)) { @@ -1073,7 +1073,7 @@ // 鏍规嵁鍟嗗搧鑾峰彇鎺ㄨ崘 @RequestMapping(value = "getgoodsrecommend", method = RequestMethod.POST) - public void getGoodsRecommend(final AcceptData acceptData, long id, PrintWriter out) { + public void getGoodsRecommend(final AcceptData acceptData, String id, PrintWriter out) { BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(), acceptData.getPackages(), acceptData.getSystem()); if (system == null) { @@ -1273,7 +1273,7 @@ for (String auctionIdStr : idStr) { scanHistoryV2Service.deleteByAuctionIdAndDeviceOrUid( StringUtil.isNullOrEmpty(uid) ? null : Long.parseLong(uid), acceptData.getDevice(), - Long.parseLong(auctionIdStr)); + auctionIdStr); } } else { scanHistoryV2Service.deleteByDeviceOrUid(StringUtil.isNullOrEmpty(uid) ? null : Long.parseLong(uid), @@ -1323,7 +1323,7 @@ // } TaoBaoGoodsBrief goods = null; try { - goods = redisManager.getTaoBaoGoodsBrief(Long.parseLong(id)); + goods = redisManager.getTaoBaoGoodsBrief(id); } catch (NumberFormatException e) { e.printStackTrace(); } catch (TaobaoGoodsDownException e) { @@ -1807,7 +1807,7 @@ * @param out */ @RequestMapping(value = "getgoodsinfo", method = RequestMethod.POST) - public void getGoodsInfo(AcceptData acceptData, Long id, Long uid, String from, PrintWriter out) { + public void getGoodsInfo(AcceptData acceptData, String id, Long uid, String from, PrintWriter out) { if (id == null) { out.print(JsonUtil.loadFalseResult(1, "璇蜂笂浼爄d")); @@ -2316,7 +2316,7 @@ List<String> detailImgs = new ArrayList<>(); JSONArray detailImgsSize = new JSONArray(); - List<ImageInfo> imgs = redisManager.getTaoBaoGoodsDetailImgs(Long.parseLong(id), acceptData.getSystem()); + List<ImageInfo> imgs = redisManager.getTaoBaoGoodsDetailImgs(id, acceptData.getSystem()); if (imgs != null && imgs.size() > 0) { @@ -2354,7 +2354,7 @@ * @param out */ @RequestMapping(value = "getgoodsderivation", method = RequestMethod.POST) - public void getRecommendGoods(AcceptData acceptData, long id, PrintWriter out) { + public void getRecommendGoods(AcceptData acceptData, String id, PrintWriter out) { try { @@ -2374,7 +2374,7 @@ app.setPid(pidManager.getPidCache(acceptData.getSystem(), Constant.SOURCE_TYPE_TAOBAO, SystemPIDInfo.PidType.fanli)); app.setAdzoneId(app.getPid().split("_")[3]); - List<Long> ids = new ArrayList<>(); + List<String> ids = new ArrayList<>(); for (TaoBaoGoodsBrief goods : goodsList) ids.add(goods.getAuctionId()); @@ -2412,7 +2412,7 @@ } }); - List<TaoBaoGoodsBrief> listQuality = new ArrayList<TaoBaoGoodsBrief>(); + List<TaoBaoGoodsBrief> listQuality = new ArrayList<>(); // 鍙栧伓鏁颁釜鏁版嵁 if (listExtra.size() % 2 != 0) { -- Gitblit v1.8.0