修改积分商品下单

liquidnet-bus-service/liquidnet-service-stone/liquidnet-service-stone-impl/src/main/java/com/liquidnet/service/stone/service/impl/StoneScoreOrderServiceImpl.java

@@ -123,16 +123,23 @@ public class StoneScoreOrderServiceImpl implements IStoneScoreOrderService {
                 order.getPaymentId(), order.getTimePay(), order.getPayCountdownMinute(), order.getStatus(), 1, order.getCreatedAt(),
                 mCouponId
         });
-        //mysql 发送券
-        LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
-        sqls.add(SqlMapping.get("stone_candy_mgt_coupon.add_for_member"));
-        sqlsDataB.add(new Object[]{
-                mCouponId, data.getTargetId(), number, order.getUserMobile(), order.getCreatedAt(), "SCORE_BUY_COUPON", order.getCreatedAt()
-        });
-        // 执行sql
-        String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB);
-        queueUtils.sendMsgByRedis(MQConst.StoneQueue.STONE_ORDER_COUPON.getKey(),
-                sqlData);
+        if (data.getType().equals("1")) {//券类型
+            //mysql 发送券
+            LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
+            sqls.add(SqlMapping.get("stone_candy_mgt_coupon.add_for_member"));
+            sqlsDataB.add(new Object[]{
+                    mCouponId, data.getTargetId(), number, order.getUserMobile(), order.getCreatedAt(), "SCORE_BUY_COUPON", order.getCreatedAt()
+            });
+            // 执行sql
+            String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB);
+            queueUtils.sendMsgByRedis(MQConst.StoneQueue.STONE_ORDER_COUPON.getKey(),
+                    sqlData);
+        } else {//非券类型
+            // 执行sql
+            String sqlData = SqlMapping.gets(sqls, sqlsDataA);
+            queueUtils.sendMsgByRedis(MQConst.StoneQueue.STONE_ORDER_COUPON.getKey(),
+                    sqlData);
+        }
 
         return ResponseDto.success("下单成功");
     }