feat:xiugai

service/exportChargeService.go

@@ -1,6 +1,7 @@
 package service
 
 import (
+	"log"
 	"strings"
 	"time"
 
@@ -99,6 +100,7 @@ func entCharge(data *resourcesCenter.ChargeReq) (resp *resourcesCenter.ChargeRes
 	} else {
 		return &resourcesCenter.ChargeResp{Code: entity.ErrorCode, Message: "未查询到企业数据流量"}
 	}
+	log.Println("-----1")
 	if data.DeductNum > 0 {
 		if entNums < data.DeductNum {
 			return &resourcesCenter.ChargeResp{
@@ -116,6 +118,8 @@ func entCharge(data *resourcesCenter.ChargeReq) (resp *resourcesCenter.ChargeRes
 				},
 			}
 		}
+		log.Println("-----2")
+
 		// 先更新mgo企业数据总量
 		query := map[string]interface{}{
 			"entid": data.EntId,
@@ -132,6 +136,8 @@ func entCharge(data *resourcesCenter.ChargeReq) (resp *resourcesCenter.ChargeRes
 		if !b {
 			return &resourcesCenter.ChargeResp{Code: entity.ErrorCode, Message: "企业余额操作失败"}
 		}
+		log.Println("-----3")
+
 		err = jyOrm.Begin()
 		//更新限额
 		if err != nil {
@@ -142,6 +148,8 @@ func entCharge(data *resourcesCenter.ChargeReq) (resp *resourcesCenter.ChargeRes
 			Incr("export_nums", data.ExportNum).
 			Incr("all_export_nums", data.ExportNum).
 			Update(&entity.PersonLimit{})
+		log.Println(updateNum, "-----4", err)
+
 		if err != nil {
 			_ = jyOrm.Rollback()
 			return &resourcesCenter.ChargeResp{Code: entity.ErrorCode, Message: "操作失败，" + err.Error()}
@@ -187,6 +195,8 @@ func entCharge(data *resourcesCenter.ChargeReq) (resp *resourcesCenter.ChargeRes
 				EntId:         data.EntId,
 			}
 			updateNum, err = souceOrm.Table(ConsumeRecord).Insert(&detailed)
+			log.Println(updateNum, "-----5", err)
+
 			if err != nil || updateNum <= 0 {
 				_ = jyOrm.Rollback()
 				return &resourcesCenter.ChargeResp{Code: entity.ErrorCode, Message: "账号使用明细保存失败"}