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/job/JDGoodsUpdateJob.java | 160 ++++++++++++++++++++++++++--------------------------
1 files changed, 80 insertions(+), 80 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/JDGoodsUpdateJob.java b/fanli/src/main/java/com/yeshi/fanli/job/JDGoodsUpdateJob.java
index 7a52c51..c88f2df 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/JDGoodsUpdateJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/JDGoodsUpdateJob.java
@@ -1,80 +1,80 @@
-package com.yeshi.fanli.job;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Component;
-
-import com.xxl.job.core.biz.model.ReturnT;
-import com.xxl.job.core.handler.annotation.XxlJob;
-import com.yeshi.fanli.entity.goods.jd.NYouHuiGoods;
-import com.yeshi.fanli.log.LogHelper;
-import com.yeshi.fanli.service.inter.goods.jd.NYouHuiService;
-import com.yeshi.fanli.util.StringUtil;
-import org.yeshi.utils.TimeUtil;
-import com.yeshi.fanli.util.goods.jd.NYouHuiUtil;
-import com.yeshi.fanli.util.jd.JDUtil;
-
-/**
- * 浜笢鍟嗗搧鏇存柊
- *
- * @author Administrator
- *
- */
-@Component
-public class JDGoodsUpdateJob {
-
- @Resource
- private NYouHuiService nyouHuiService;
-
- /**
- * 鏇存柊鍐呬紭鎯犳渶杩戝嚑澶╃殑鍟嗗搧
- *
- * @param param
- * @return
- * @throws Exception
- */
- @XxlJob("nyhLatest2DayGoodsUpdateHandler")
- public ReturnT<String> updateNYHLatest2DayGoods(String param) throws Exception {
- long startTime = TimeUtil.convertToTimeTemp(
- TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd");
- List<String> list = NYouHuiUtil.getClasses();
- for (String name : list) {
- if (name.trim().equalsIgnoreCase("鏈垎绫�"))
- continue;
- try {
- List<NYouHuiGoods> goodsList = NYouHuiUtil.listByClassName(name,
- StringUtil.isNullOrEmpty(param) ? 1 : Integer.parseInt(param));
- for (NYouHuiGoods goods : goodsList) {
- try {
- if (TimeUtil.convertToTimeTemp(goods.getPublishTime(), "yyyy-MM-dd") >= startTime) {
- NYouHuiGoods old = nyouHuiService.selectByName(goods.getName());
- if (old == null
- || TimeUtil.convertToTimeTemp(old.getPublishTime(), "yyyy-MM-dd") < startTime) {
- NYouHuiGoods goodsDetail = NYouHuiUtil.getGoodsDetail(goods.getSourceUrl());
- List<Long> skuList = new ArrayList<>();
- for (String link : goodsDetail.getLinkList()) {
- String skuId = JDUtil.getJDGoodsIdByUJD(link);
- skuList.add(Long.parseLong(skuId));
- }
- goodsDetail.setSkuId(skuList.get(0));
- goodsDetail.setSkuList(skuList);
- goodsDetail.setClassName(name);
- nyouHuiService.addGoods(goodsDetail);
- Thread.sleep(2000 + (int) (Math.random() * 5) * 1000);
- }
- }
- } catch (Exception e) {
- LogHelper.errorDetailInfo(e, "浜笢-鍐呬紭鎯犲嚭閿�", goods.getSourceUrl());
- }
- }
- } catch (Exception e) {
- LogHelper.errorDetailInfo(e, "浜笢-鍐呬紭鎯犲嚭閿�", name);
- }
- }
- return ReturnT.SUCCESS;
- }
-
-}
+package com.yeshi.fanli.job;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Component;
+
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import com.yeshi.fanli.entity.goods.jd.NYouHuiGoods;
+import com.yeshi.fanli.log.LogHelper;
+import com.yeshi.fanli.service.inter.goods.jd.NYouHuiService;
+import com.yeshi.fanli.util.StringUtil;
+import org.yeshi.utils.TimeUtil;
+import com.yeshi.fanli.util.goods.jd.NYouHuiUtil;
+import com.yeshi.fanli.util.jd.JDUtil;
+
+/**
+ * 浜笢鍟嗗搧鏇存柊
+ *
+ * @author Administrator
+ *
+ */
+@Component
+public class JDGoodsUpdateJob {
+
+ @Resource
+ private NYouHuiService nyouHuiService;
+
+ /**
+ * 鏇存柊鍐呬紭鎯犳渶杩戝嚑澶╃殑鍟嗗搧
+ *
+ * @param param
+ * @return
+ * @throws Exception
+ */
+ @XxlJob("nyhLatest2DayGoodsUpdateHandler")
+ public ReturnT<String> updateNYHLatest2DayGoods(String param) throws Exception {
+ long startTime = TimeUtil.convertToTimeTemp(
+ TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd");
+ List<String> list = NYouHuiUtil.getClasses();
+ for (String name : list) {
+ if (name.trim().equalsIgnoreCase("鏈垎绫�"))
+ continue;
+ try {
+ List<NYouHuiGoods> goodsList = NYouHuiUtil.listByClassName(name,
+ StringUtil.isNullOrEmpty(param) ? 1 : Integer.parseInt(param));
+ for (NYouHuiGoods goods : goodsList) {
+ try {
+ if (TimeUtil.convertToTimeTemp(goods.getPublishTime(), "yyyy-MM-dd") >= startTime) {
+ NYouHuiGoods old = nyouHuiService.selectByName(goods.getName());
+ if (old == null
+ || TimeUtil.convertToTimeTemp(old.getPublishTime(), "yyyy-MM-dd") < startTime) {
+ NYouHuiGoods goodsDetail = NYouHuiUtil.getGoodsDetail(goods.getSourceUrl());
+ List<Long> skuList = new ArrayList<>();
+ for (String link : goodsDetail.getLinkList()) {
+ String skuId = JDUtil.getJDGoodsIdByUJD(link);
+ skuList.add(Long.parseLong(skuId));
+ }
+ goodsDetail.setSkuId(skuList.get(0));
+ goodsDetail.setSkuList(skuList);
+ goodsDetail.setClassName(name);
+ nyouHuiService.addGoods(goodsDetail);
+ Thread.sleep(2000 + (int) (Math.random() * 5) * 1000);
+ }
+ }
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e, "浜笢-鍐呬紭鎯犲嚭閿�", goods.getSourceUrl());
+ }
+ }
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e, "浜笢-鍐呬紭鎯犲嚭閿�", name);
+ }
+ }
+ return ReturnT.SUCCESS;
+ }
+
+}
--
Gitblit v1.8.0