去除 订单 无效的打印

account_order/account_order_change.go

@@ -33,7 +33,7 @@ func allDataOrderSaleRecordForAccountOrderChange() {
 	}()
 	now := time.Now()
 	var total int64
-	JianyuDB.Debug().Model(&OrderSaleRecord{}).Where("state IN  ?", []string{"1", "-1"}).Where("autoUpdate < ?", endTime).Count(&total)
+	JianyuDB.Model(&OrderSaleRecord{}).Where("state IN  ?", []string{"1", "-1"}).Where("autoUpdate < ?", endTime).Count(&total)
 	log.Info("allDataOrderSaleRecordForAccountOrderChange", zap.Any("OrderSaleRecord 总数是", total))
 
 	rowsPerPage := 100                           // 每页的数量
@@ -41,7 +41,7 @@ func allDataOrderSaleRecordForAccountOrderChange() {
 
 	for page := 0; page < totalPages; page++ {
 		offset := page * rowsPerPage
-		rows, err := JianyuDB.Debug().Model(&OrderSaleRecord{}).Where("state IN  ?", []string{"1", "-1"}).Where("autoUpdate < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
+		rows, err := JianyuDB.Model(&OrderSaleRecord{}).Where("state IN  ?", []string{"1", "-1"}).Where("autoUpdate < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
 		defer func() {
 			err = rows.Close()
 			if err != nil {
@@ -331,7 +331,7 @@ func allDataRefundRecordForAccountOrderChange() {
 	}()
 	now := time.Now()
 	var total int64
-	AnalysisDB.Debug().Model(&RefundRecord{}).Where("refund_time < ?", endTime).Count(&total)
+	AnalysisDB.Model(&RefundRecord{}).Where("refund_time < ?", endTime).Count(&total)
 	log.Info("allDataRefundRecordForAccountOrderChange", zap.Any("RefundRecord 退款表 总数是", total))
 
 	rowsPerPage := 100                           // 每页的数量
@@ -339,7 +339,7 @@ func allDataRefundRecordForAccountOrderChange() {
 
 	for page := 0; page < totalPages; page++ {
 		offset := page * rowsPerPage
-		rows, err := AnalysisDB.Debug().Model(&RefundRecord{}).Where("refund_time < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
+		rows, err := AnalysisDB.Model(&RefundRecord{}).Where("refund_time < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
 		defer func() {
 			err = rows.Close()
 			if err != nil {
@@ -372,7 +372,7 @@ func allDataRefundRecordForAccountOrderChange() {
 					log.Info("allDataRefundRecordForAccountOrderChange", zap.Error(err))
 				}
 				//2.业绩变更表
-				err = JianyuDB.Debug().Where("ordercode = ? ", refund_record.OrderCode).Order("id desc").First(&order_sale_record).Error
+				err = JianyuDB.Where("ordercode = ? ", refund_record.OrderCode).Order("id desc").First(&order_sale_record).Error
 				if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
 					log.Info("allDataRefundRecordForAccountOrderChange", zap.Error(err))
 				}

account_order/account_return.go

@@ -27,14 +27,14 @@ func allDataReturnMoneyRecordForAccountReturn() {
 	}()
 	now := time.Now()
 	var total int64
-	AnalysisDB.Debug().Model(&ReturnMoneyRecord{}).Where("state = ?", 1).Where("autoUpdate < ?", endTime).Count(&total)
+	AnalysisDB.Model(&ReturnMoneyRecord{}).Where("state = ?", 1).Where("autoUpdate < ?", endTime).Count(&total)
 	log.Info("allDataReturnMoneyRecordForAccountReturn", zap.Any("RefundRecord 退款表 总数是", total))
 
 	rowsPerPage := 100                           // 每页的数量
 	totalPages := (int(total) / rowsPerPage) + 1 //总页数
 	for page := 0; page < totalPages; page++ {
 		offset := page * rowsPerPage
-		rows, err := AnalysisDB.Debug().Model(&ReturnMoneyRecord{}).Where("state = ?", 1).Where("autoUpdate < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
+		rows, err := AnalysisDB.Model(&ReturnMoneyRecord{}).Where("state = ?", 1).Where("autoUpdate < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
 		defer func() {
 			err = rows.Close()
 			if err != nil {
@@ -237,14 +237,14 @@ func allDataDataexportOrderForAccountReturn() {
 	}()
 	now := time.Now()
 	var total int64
-	AnalysisDB.Debug().Model(&DataexportOrder{}).Where("order_status =? AND is_backstage_order =? AND NOT (pay_way =? AND product_type =?)", 1, 0, "transferAccounts", "VIP订阅").Where("autoUpdate < ?", endTime).Count(&total)
+	AnalysisDB.Model(&DataexportOrder{}).Where("order_status =? AND is_backstage_order =? AND NOT (pay_way =? AND product_type =?)", 1, 0, "transferAccounts", "VIP订阅").Where("autoUpdate < ?", endTime).Count(&total)
 	log.Info("allDataDataexportOrderForAccountReturn", zap.Any("dataexport_order 订单表 ，order_status=1 and is_backstage_order=0 ，\n\t并排除pay_way=’transferAccounts’ and product_type=’VIP订阅’，总数是", total))
 
 	rowsPerPage := 100                           // 每页的数量
 	totalPages := (int(total) / rowsPerPage) + 1 //总页数
 	for page := 0; page < totalPages; page++ {
 		offset := page * rowsPerPage
-		rows, err := AnalysisDB.Debug().Model(&DataexportOrder{}).Where("order_status =? AND is_backstage_order =? AND NOT (pay_way =? AND product_type =?)", 1, 0, "transferAccounts", "VIP订阅").Where("autoUpdate < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
+		rows, err := AnalysisDB.Model(&DataexportOrder{}).Where("order_status =? AND is_backstage_order =? AND NOT (pay_way =? AND product_type =?)", 1, 0, "transferAccounts", "VIP订阅").Where("autoUpdate < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
 		defer func() {
 			err = rows.Close()
 			if err != nil {
@@ -270,7 +270,7 @@ func allDataDataexportOrderForAccountReturn() {
 					log.Info("allDataDataexportOrderForAccountReturn", zap.Error(err))
 				}
 				//2.回款表-return_money_record
-				err = AnalysisDB.Debug().Model(ReturnMoneyRecord{}).Where("order_code =? ", data_exOrder.OrderCode).First(&return_money_record).Error
+				err = AnalysisDB.Model(ReturnMoneyRecord{}).Where("order_code =? ", data_exOrder.OrderCode).First(&return_money_record).Error
 				if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
 					log.Info("allDataDataexportOrderForAccountReturn", zap.Error(err))
 				}

account_order/account_return_change.go

@@ -31,14 +31,14 @@ func allDataOrderSaleRecordForAccountReturnChange() {
 	}()
 	now := time.Now()
 	var total int64
-	JianyuDB.Debug().Model(&OrderSaleRecord{}).Where("autoUpdate < ?", endTime).Where("change_reason IN ? AND state IN ? ", []string{"业绩红冲", "销售撞单", "补录销售信息"}, []int{-1, 1}).Count(&total)
+	JianyuDB.Model(&OrderSaleRecord{}).Where("autoUpdate < ?", endTime).Where("change_reason IN ? AND state IN ? ", []string{"业绩红冲", "销售撞单", "补录销售信息"}, []int{-1, 1}).Count(&total)
 	log.Info("allDataOrderSaleRecordForAccountReturnChange", zap.Any("业绩变更表中取变更类型change_reason是：业绩红冲、销售撞单、补录销售信息，且state in (-1,1)，总数是", total))
 
 	rowsPerPage := 100                           //每页的数量
 	totalPages := (int(total) / rowsPerPage) + 1 //总页数
 	for page := 0; page < totalPages; page++ {
 		offset := page * rowsPerPage
-		rows, err := JianyuDB.Debug().Model(&OrderSaleRecord{}).Where("autoUpdate < ?", endTime).Where("change_reason IN ? AND state IN ? ", []string{"业绩红冲", "销售撞单", "补录销售信息"}, []int{-1, 1}).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
+		rows, err := JianyuDB.Model(&OrderSaleRecord{}).Where("autoUpdate < ?", endTime).Where("change_reason IN ? AND state IN ? ", []string{"业绩红冲", "销售撞单", "补录销售信息"}, []int{-1, 1}).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
 		defer func() {
 			err = rows.Close()
 			if err != nil {
@@ -59,12 +59,12 @@ func allDataOrderSaleRecordForAccountReturnChange() {
 			}
 			if order_sale_record.Ordercode != "" {
 				// 1.原来订单表- dataexport_order
-				err = AnalysisDB.Debug().Model(DataexportOrder{}).Where("order_code =? ", order_sale_record.Ordercode).First(&data_exOrder).Error
+				err = AnalysisDB.Model(DataexportOrder{}).Where("order_code =? ", order_sale_record.Ordercode).First(&data_exOrder).Error
 				if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
 					log.Info("allDataOrderSaleRecordForAccountReturnChange", zap.Error(err))
 				}
 				//2.回款表-return_money_record
-				err = AnalysisDB.Debug().Model(ReturnMoneyRecord{}).Where("order_code =? ", order_sale_record.Ordercode).First(&return_money_record).Error
+				err = AnalysisDB.Model(ReturnMoneyRecord{}).Where("order_code =? ", order_sale_record.Ordercode).First(&return_money_record).Error
 				if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
 					log.Info("allDataOrderSaleRecordForAccountReturnChange", zap.Error(err))
 				}
@@ -229,7 +229,7 @@ func allDataRefundRecordForAccountReturnChange() {
 	}()
 	now := time.Now()
 	var total int64
-	AnalysisDB.Debug().Model(&RefundRecord{}).Where("refund_time < ?", endTime).Count(&total)
+	AnalysisDB.Model(&RefundRecord{}).Where("refund_time < ?", endTime).Count(&total)
 	log.Info("allDataRefundRecordForAccountReturnChange", zap.Any("总数是", total))
 
 	rowsPerPage := 100                           //每页的数量
@@ -237,7 +237,7 @@ func allDataRefundRecordForAccountReturnChange() {
 
 	for page := 0; page < totalPages; page++ {
 		offset := page * rowsPerPage
-		rows, err := AnalysisDB.Debug().Model(&RefundRecord{}).Where("refund_time < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
+		rows, err := AnalysisDB.Model(&RefundRecord{}).Where("refund_time < ?", endTime).Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
 		defer func() {
 			err = rows.Close()
 			if err != nil {
@@ -256,17 +256,17 @@ func allDataRefundRecordForAccountReturnChange() {
 			err = AnalysisDB.ScanRows(rows, &refund_record)
 			if refund_record.OrderCode != "" {
 				// 1.原来订单表- dataexport_order
-				err = AnalysisDB.Debug().Model(DataexportOrder{}).Where("order_code =? ", refund_record.OrderCode).First(&data_exOrder).Error
+				err = AnalysisDB.Model(DataexportOrder{}).Where("order_code =? ", refund_record.OrderCode).First(&data_exOrder).Error
 				if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
 					log.Info("allDataRefundRecordForAccountReturnChange", zap.Error(err))
 				}
 				//2.回款表-return_money_record
-				err = AnalysisDB.Debug().Model(ReturnMoneyRecord{}).Where("order_code =? ", refund_record.OrderCode).First(&return_money_record).Error
+				err = AnalysisDB.Model(ReturnMoneyRecord{}).Where("order_code =? ", refund_record.OrderCode).First(&return_money_record).Error
 				if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
 					log.Info("allDataRefundRecordForAccountReturnChange;", zap.Error(err))
 				}
 				//3.业绩变更表-order_sale_record
-				err = JianyuDB.Debug().Model(OrderSaleRecord{}).Where("ordercode =? ", refund_record.OrderCode).Order("id desc").First(&order_sale_record).Error
+				err = JianyuDB.Model(OrderSaleRecord{}).Where("ordercode =? ", refund_record.OrderCode).Order("id desc").First(&order_sale_record).Error
 				if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
 					log.Info("allDataRefundRecordForAccountReturnChange;", zap.Error(err))
 				}

account_order/account_test.go

@@ -19,7 +19,7 @@ func TestOrder(T *testing.T) {
 	dsn := fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8mb4&parseTime=True&loc=Local", username, password, host, database)
 	// 连接到数据库
 	db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{
-		Logger: logger.Default.LogMode(logger.Error), //不打印日志
+		Logger: logger.Default.LogMode(logger.Silent), //不打印日志
 	})
 	if err != nil {
 		log.Info("dealAllDataAccountOrder, Rows Error", zap.Error(err))

account_order/main.go

@@ -134,7 +134,7 @@ func dealAllDataAccountOrder2() {
 	}()
 	now := time.Now()
 	var total int64
-	AnalysisDB.Debug().Model(&DataexportOrder{}).Where("autoUpdate < ?", endTime).Count(&total)
+	AnalysisDB.Model(&DataexportOrder{}).Where("autoUpdate < ?", endTime).Count(&total)
 	log.Info("dealAllDataAccountOrder", zap.Any("总数是", total))
 
 	rowsPerPage := 100                           // 每页的数量
@@ -155,7 +155,7 @@ func dealAllDataAccountOrder2() {
 			defer func() { <-sem }() // 在协程结束时从 channel 中取出，释放一个槽位
 
 			offset := page * rowsPerPage
-			rows, err := AnalysisDB.Debug().Model(&DataexportOrder{}).Where("autoUpdate < ?", endTime).
+			rows, err := AnalysisDB.Model(&DataexportOrder{}).Where("autoUpdate < ?", endTime).
 				Order("id desc").Offset(offset).Limit(rowsPerPage).Rows()
 			if err != nil {
 				log.Info("dealAllDataAccountOrder, Rows Error", zap.Error(err))