商品ID字符串化

admin

2022-08-25 146dbd5ed24c1fe63766aa45e0ce602caa39748e

 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()) {