From 146dbd5ed24c1fe63766aa45e0ce602caa39748e Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 25 八月 2022 17:53:10 +0800
Subject: [PATCH] 商品ID字符串化

---
 fanli/src/main/java/com/yeshi/fanli/service/manger/JobManager.java |   10 +++++++---
 1 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/manger/JobManager.java b/fanli/src/main/java/com/yeshi/fanli/service/manger/JobManager.java
index 611feb9..7a827c6 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/manger/JobManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/manger/JobManager.java
@@ -67,6 +67,7 @@
 
 @Component
 public class JobManager {
+
     @Resource
     private BoutiqueAutoRuleService boutiqueAutoRuleService;
 
@@ -577,12 +578,12 @@
                 public void run() {
                     super.run();
                     try {
-                        Map<String, Long> map = CMQManager.getInstance().consumeNeedUpdateTaoBaoGoodsIdMsg(16);
+                        Map<String, String> map = CMQManager.getInstance().consumeNeedUpdateTaoBaoGoodsIdMsg(16);
                         if (map != null) {
                             Iterator<String> its = map.keySet().iterator();
                             while (its.hasNext()) {
                                 String key = its.next();
-                                taoBaoGoodsUpdateService.updateByTaoKeGoodsDetail(Long.parseLong(key));
+                                taoBaoGoodsUpdateService.updateByTaoKeGoodsDetail(map.get(key));
                                 CMQManager.getInstance().deleteNeedUpdateTaoBaoGoodsIdMsg(key);
                             }
                         }
@@ -682,6 +683,7 @@
                         Iterator<String> its = map.keySet().iterator();
                         while (its.hasNext()) {
                             String key = its.next();
+                            LogHelper.test("鎷煎澶氳鍗曞鐞嗗紑濮嬶細" + key);
                             try {
                                 String orderId = map.get(key);
                                 if (!StringUtil.isNullOrEmpty(orderId)) {
@@ -691,7 +693,9 @@
                                             orderProcessService.processPDDOrder(order);
                                 }
                                 PDDOrderCMQManager.getInstance().deletePDDOrder(key);
+                                LogHelper.test("鎷煎澶氳鍗曞鐞嗘垚鍔燂細" + key);
                             } catch (Exception e) {
+                                LogHelper.test("鎷煎澶氳鍗曞鐞嗗け璐ワ細" + key);
                                 LogHelper.errorDetailInfo(e);
                             }
                         }
@@ -785,7 +789,7 @@
                 @Override
                 public void run() {
                     super.run();
-                    Map<String, Long> map = CMQManager.getInstance().consumeTBImpGoodsUpdateMsg(16);
+                    Map<String, String> map = CMQManager.getInstance().consumeTBImpGoodsUpdateMsg(16);
                     if (map != null) {
                         Iterator<String> its = map.keySet().iterator();
                         while (its.hasNext()) {

--
Gitblit v1.8.0