Merge branch 'pre' into 'master'

修改 支付返回状态 已支付 并且 订单状态为待支付状态 才能走支付成功逻辑

See merge request !278

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/GoblinOrderServiceImpl.java

@@ -781,7 +781,7 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
 //                redisUtils.setGoblinOrder(orderVo.getOrderId(),orderVo);
             } else if ((orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_6.getValue() || orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_7.getValue()) && syncOrderParam.getStatus().equals(1)) {
                 log.error("订单号为 {} 的订单正在退款 或者已退款", syncOrderParam.getOrderCode());
-            } else if (syncOrderParam.getStatus().equals(1)) {
+            } else if (syncOrderParam.getStatus().equals(1) && orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_0.getValue()) {
                 log.error("订单号为 {} 的订单正常流程", syncOrderParam.getOrderCode());
                 storeOrder.setPaymentType(syncOrderParam.getPaymentType());
                 storeOrder.setPaymentId(syncOrderParam.getPaymentId());
@@ -795,14 +795,14 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
                 }
                 storeOrder.setStatus(GoblinStatusConst.Status.ORDER_STATUS_2.getValue());
                 storeOrder.setZhengzaiStatus(0);
-                if(orderVo.getDeviceFrom().equals("micropay") && GoblinStatusConst.MarketPreStatus.MARKET_PRE_ZHENGZAI.getValue().equals(orderVo.getMarketType())){
+                if (orderVo.getDeviceFrom().equals("micropay") && GoblinStatusConst.MarketPreStatus.MARKET_PRE_ZHENGZAI.getValue().equals(orderVo.getMarketType())) {
                     storeOrder.setStatus(GoblinStatusConst.Status.ORDER_STATUS_4.getValue());
                     storeOrder.setZhengzaiStatus(1);
                 }
                 storeOrder.setUpdatedAt(now);
                 sqls.add(SqlMapping.get("goblin_order.pay.order"));
                 sqlDataOrder.add(new Object[]{
-                        storeOrder.getPaymentType(), storeOrder.getPaymentId(), storeOrder.getPayCode(), storeOrder.getPayTime(), storeOrder.getWriteOffCode(), storeOrder.getZhengzaiStatus(),storeOrder.getStatus(), storeOrder.getUpdatedAt(),
+                        storeOrder.getPaymentType(), storeOrder.getPaymentId(), storeOrder.getPayCode(), storeOrder.getPayTime(), storeOrder.getWriteOffCode(), storeOrder.getZhengzaiStatus(), storeOrder.getStatus(), storeOrder.getUpdatedAt(),
                         orderId, now, now
                 });
                 sqls.add(SqlMapping.get("goblin_order.pay.sku"));
@@ -859,6 +859,11 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
                 //mysql
                 queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_ORDER_CREATE_PAY.getKey(),
                         SqlMapping.gets(sqls, sqlDataOrder, sqlDataSku));
+
+                //加分
+                if (orderUtils.noZhengzaiOrder(uid)) {
+                    orderUtils.integral(uid, priceActual, "购买商品", 1);
+                }
             }
             //发短信
 //            SmsEnum.ADTemplate adTemplate = null;
@@ -877,10 +882,6 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
 //                                .setTemplateParam("time", time1 + " " + time2).toJson()
 //                );
 //            }
-            //加分
-            if (orderUtils.noZhengzaiOrder(uid)) {
-                orderUtils.integral(uid, priceActual, "购买商品", 1);
-            }
         }
         return "success";
     }
@@ -1105,7 +1106,7 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
                     storeOrder.setUpdatedAt(now);
                     sqls.add(SqlMapping.get("goblin_order.pay.order"));
                     sqlDataOrder.add(new Object[]{
-                            storeOrder.getPaymentType(), storeOrder.getPaymentId(), storeOrder.getPayCode(), storeOrder.getPayTime(), storeOrder.getWriteOffCode(),storeOrder.getZhengzaiStatus(), storeOrder.getStatus(), storeOrder.getUpdatedAt(),
+                            storeOrder.getPaymentType(), storeOrder.getPaymentId(), storeOrder.getPayCode(), storeOrder.getPayTime(), storeOrder.getWriteOffCode(), storeOrder.getZhengzaiStatus(), storeOrder.getStatus(), storeOrder.getUpdatedAt(),
                             orderId, now, now
                     });
                     sqls.add(SqlMapping.get("goblin_order.pay.sku"));