秒返

consume/zhios_fast_return_order_refund.go

@@ -12,6 +12,7 @@ import (
 	"errors"
 	"fmt"
 	"github.com/streadway/amqp"
+	"time"
 )
 
 func ZhiosFastReturnOrderRefund(queue md.MqQueue) {
@@ -146,5 +147,22 @@ func handleZhiosFastReturnOrderRefund(msg []byte) error {
 		args1 = CommInfo(eg, mid, args1)
 		pay.CreditagreementOrderFinish(args1)
 	}
+	var flow = &model.FinUserFlow{
+		Type:         1,
+		Uid:          orderData.Uid,
+		Amount:       "",
+		PaymentType:  3,
+		BeforeAmount: "0",
+		AfterAmount:  "0",
+		OrdType:      "fast_return",
+		OrdId:        utils.AnyToString(orderData.OrdId),
+		OrdAction:    103,
+		OrdTitle:     "秒返订单退款扣除" + money + "元（请到支付宝查看）",
+		State:        2,
+		OtherId:      0,
+		OrdTime:      int(time.Now().Unix()),
+		CreateAt:     time.Now(),
+	}
+	eg.Insert(flow)
 	return nil
 }