This commit is contained in:
li 2022-02-27 19:34:36 +08:00
parent 2b93e9046e
commit 6fa60b68e6

View File

@ -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
// }
//}