直接查询imsEweishopGoods表判断商品是否存在

src/main/java/zs/payment/messages/KafkaConsumer.java

@@ -128,7 +128,7 @@ public class KafkaConsumer {
         JSONObject jsonObject = JSONObject.parseObject(messsage);
         int productId = jsonObject.getIntValue("product_id");
 
-        // 更新商品状态为下架   update ims_ewei_shop_goods set  status = 0 where catch_source=yunxin and catch_id=productId
+        // 删除
         Boolean b = redisUtils.sismember(ProductSupplyRedis.SYNC_SUPPLY_ID, productId + "");
         if (b) {
             b = imsEweiShopGoodsService.deleteBySupplyId(String.valueOf(productId), "yunxin");