diff --git a/model/model_test.go b/model/model_test.go index 8816567..9d5de3f 100644 --- a/model/model_test.go +++ b/model/model_test.go @@ -638,20 +638,35 @@ func SyncUserRentCard() { } for _, user := range users { - fmt.Println("user:", user.MemberLevel, user.MemberExpire, user.OpenMemberTime) - userRentCard := &UserRentCard{ - Uid: user.Uid, - MemberLevel: user.MemberLevel, - LevelRentCount: 1, - HaveRentCount: 0, - CanRentCount: 1, - Status: 0, - } - err = DBProd.Create(userRentCard).Error + var orderCards []OrderCard + qs := NewOrderCardQuerySet(DBProd).UidEq(user.Uid).CardStatusIn(1, 2, 3).PayStatusEq(2) + qs.All(&orderCards) + count, err := qs.Count() if err != nil { - logger.Error("err:", err) + fmt.Println("err:", err) + } + if count > 1 { + //if orderCards[0].CardStatus > 1 &&orderCards[1].CardStatus >1{ + // continue + //} + fmt.Println("订单 count: uid:", count, user.Uid, orderCards[0].CardStatus, orderCards[1].CardStatus) } } + //for _, user := range users { + // fmt.Println("user:", user.MemberLevel, user.MemberExpire, user.OpenMemberTime) + // userRentCard := &UserRentCard{ + // Uid: user.Uid, + // MemberLevel: user.MemberLevel, + // LevelRentCount: 1, + // HaveRentCount: 0, + // CanRentCount: 1, + // Status: 0, + // } + // err = DBProd.Create(userRentCard).Error + // if err != nil { + // logger.Error("err:", err) + // } + //} } func TestSyncUserOpenMemberTime(t *testing.T) { @@ -699,45 +714,141 @@ func SyncUserOrder() { return } fmt.Println("orders:", len(orders)) - for _, order := range orders { - //fmt.Println("order:", order.PayStatus, order.GameCardGoodsId) - //var gameCardGoods GameCardGoods - //err = NewGameCardGoodsQuerySet(DBProd).IDEq(uint32(order.GameCardGoodsId)).One(&gameCardGoods) - //if err != nil { - // logger.Error("err:", err) - // //continue - //} - orderCard := OrderCard{ - OrderId: order.ID, - Uid: uint32(order.Uid), - GameCardId: uint32(order.GameCardId), - GameCardGoodsId: uint32(order.GameCardGoodsId), - StoreId: uint32(order.StoreId), - CardStatus: uint32(order.CardStatus), - DeliveryTime: order.DeliveryTime, - ReceiptTime: order.ReceiptTime, - DeliveryType: order.DeliveryType, - SerialNumber: order.GameCardSerialNumber, - PayStatus: order.PayStatus, - RevertStoreId: order.RevertStoreId, - RevertTime: order.RevertTime, - RevertExpressCompany: order.RevertExpressCompany, - RevertExpressCompanyNo: order.RevertExpressCompanyNo, - RevertExpressNo: order.RevertExpressNo, - RevertExpressDuration: order.RevertExpressDuration, + //for _, order := range orders { + // //fmt.Println("order:", order.PayStatus, order.GameCardGoodsId) + // //var gameCardGoods GameCardGoods + // //err = NewGameCardGoodsQuerySet(DBProd).IDEq(uint32(order.GameCardGoodsId)).One(&gameCardGoods) + // //if err != nil { + // // logger.Error("err:", err) + // // //continue + // //} + // //orderCard := OrderCard{ + // // OrderId: order.ID, + // // Uid: uint32(order.Uid), + // // GameCardId: uint32(order.GameCardId), + // // GameCardGoodsId: uint32(order.GameCardGoodsId), + // // StoreId: uint32(order.StoreId), + // // CardStatus: uint32(order.CardStatus), + // // DeliveryTime: order.DeliveryTime, + // // ReceiptTime: order.ReceiptTime, + // // DeliveryType: order.DeliveryType, + // // SerialNumber: order.GameCardSerialNumber, + // // PayStatus: order.PayStatus, + // // RevertStoreId: order.RevertStoreId, + // // RevertTime: order.RevertTime, + // // RevertExpressCompany: order.RevertExpressCompany, + // // RevertExpressCompanyNo: order.RevertExpressCompanyNo, + // // RevertExpressNo: order.RevertExpressNo, + // // RevertExpressDuration: order.RevertExpressDuration, + // // + // // //Postage: order.Postage, + // // //ExpressCompany: order.ExpressCompany, + // // //ExpressCompanyNo: order.ExpressCompanyNo, + // // //ExpressNo: order.ExpressNo, + // // //GamePrice: 0, + // // //GameCoverImg: "", + // // //Order: nil, + // //} + // //fmt.Println("order:", order.ID, order.PayStatus, order.CardStatus, order.Uid, order.GameCardId) + // //err = DBProd.Create(&orderCard).Error + // //if err != nil { + // // logger.Error("err:", err) + // //} + //} +} - //Postage: order.Postage, - //ExpressCompany: order.ExpressCompany, - //ExpressCompanyNo: order.ExpressCompanyNo, - //ExpressNo: order.ExpressNo, - //GamePrice: 0, - //GameCoverImg: "", - //Order: nil, +func TestSyncUserRent(t *testing.T) { + SyncUserRent() +} + +func SyncUserRent() { + InitDBProd() + var users []User + err := NewUserQuerySet(DBProd).MemberLevelIn(2, 3).All(&users) + if err != nil { + logger.Error("err:", err) + } + //Order{} + for _, user := range users { + if user.Uid == 34021861 || user.Uid == 81309358 { + continue } - fmt.Println("order:", order.ID, order.PayStatus, order.CardStatus, order.Uid, order.GameCardId) - err = DBProd.Create(&orderCard).Error + count, err := NewUserRentCardQuerySet(DBProd).UidEq(user.Uid).CanRentCountEq(1).HaveRentCountEq(0).Count() if err != nil { - logger.Error("err:", err) + fmt.Println("err:", err) + } + if count > 0 { + orderCount, err := NewOrderCardQuerySet(DBProd).UidEq(user.Uid).CardStatusIn(1, 2, 3).PayStatusEq(2).Count() + if err != nil { + fmt.Println("err:", err) + } + if orderCount == 0 { + continue + } + fmt.Println("订单 count: uid:", orderCount, user.Uid) + + _, err = NewUserRentCardQuerySet(DBProd).UidEq(user.Uid).GetUpdater().SetCanRentCount(0). + SetHaveRentCount(1).UpdateNum() + if err != nil { + fmt.Println("err:", err) + } } } } + +func TestOrderCancelId(t *testing.T) { + //OrderCancelId() +} + +//func OrderCancelId() { +// ids := []uint32{8288, 8265} +// for _, id := range ids { +// //OrderCancel(id) +// controller.OrderCancelBy(id) +// } +// +//} + +//func OrderCancel(id uint32) { +// //InitDBProd() +// //DB = DBProd +// var order Order +// err := NewOrderQuerySet(DB).IDEq(id).One(&order) +// if err != nil { +// fmt.Println("err:", err) +// } +// +// outTradeNo, err := GetWxPayExpressFeeRefundRecord(order.ID) +// if err != nil { +// logger.Error("err:", err) +// return +// } +// +// orderSn := GetOrderSn() +// err = UserOpenMemberRecord{Uid: uint32(order.Uid), OpenNo: orderSn, OrderId: order.ID, OrderType: 2}.Insert() +// if err != nil { +// logger.Error(errors.New("WebPay err")) +// return +// } +// +// orderRefund := wxpay.OrderRefund{ +// OutTradeNo: outTradeNo, +// OutRefundNo: orderSn, +// NotifyUrl: "", +// Amount: wxpay.OrderRefundAmount{ +// Refund: order.PayPrice, +// Total: order.PayPrice, +// Currency: "CNY", +// }, +// } +// bytes, _ := json.Marshal(order) +// fmt.Println("订单取消:", string(bytes)) +// orderRefundJson, _ := json.Marshal(&orderRefund) +// fmt.Println("订单取消 orderRefundJson:", string(orderRefundJson)) +// //err = wxpay.WxPayOrderRefund(orderRefund) +// err = wxpay.TransactionOrderRefund(orderRefund) +// if err != nil { +// logger.Error("err:", err) +// return +// } +//}