|
|
|
@@ -1439,13 +1439,6 @@ public class WxCouponServiceImpl implements WxCouponService { |
|
|
|
} |
|
|
|
|
|
|
|
private void spuStockSync(TenantEntity tenantEntity,Long couponId){ |
|
|
|
// new Thread(() -> { |
|
|
|
// //1秒之后同步poi |
|
|
|
// try { |
|
|
|
// Thread.currentThread().sleep(1000); |
|
|
|
// } catch (Exception e) { |
|
|
|
// logger.error("sleep error: " + e.getMessage()); |
|
|
|
// } |
|
|
|
|
|
|
|
FmInsideProductPushMsg productPush = new FmInsideProductPushMsg(); |
|
|
|
productPush.setDelayTimeLevel(3); |
|
|
|
@@ -1456,18 +1449,10 @@ public class WxCouponServiceImpl implements WxCouponService { |
|
|
|
logger.info(">>>>>>>>>>>send FmInsideProductPushMsg :"+productPush); |
|
|
|
mqBaseProducer.sendMessage(productPush, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); |
|
|
|
|
|
|
|
// }).start(); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
private void spuFreeAuditSync(TenantEntity tenantEntity,Long couponId){ |
|
|
|
// new Thread(() -> { |
|
|
|
// //1秒之后同步poi |
|
|
|
// try { |
|
|
|
// Thread.currentThread().sleep(1000); |
|
|
|
// } catch (Exception e) { |
|
|
|
// logger.error("sleep error: " + e.getMessage()); |
|
|
|
// } |
|
|
|
|
|
|
|
FmInsideProductPushMsg productPush = new FmInsideProductPushMsg(); |
|
|
|
productPush.setDelayTimeLevel(3); |
|
|
|
@@ -1478,8 +1463,6 @@ public class WxCouponServiceImpl implements WxCouponService { |
|
|
|
logger.info(">>>>>>>>>>>send FmInsideProductPushMsg :"+productPush); |
|
|
|
mqBaseProducer.sendMessage(productPush, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); |
|
|
|
|
|
|
|
// }).start(); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
|