个人支付操作人查询

service/exportChargeService.go

@@ -294,10 +294,15 @@ func personCharge(data *resourcesCenter.ChargeReq) (resp *resourcesCenter.Charge
 			Source:        int(data.Source),
 		}
 		if detailed.EntUserId > 0 {
-			jyOrm.Table("entniche_user").Select("CONCAT(NAME,'（',phone,'）')").Where("id=?", detailed.EntUserId).Get(&detailed.Operator)
+			_, err = jyOrm.Table("entniche_user").Select("CONCAT(NAME,'（',phone,'）')").Where("id=?", detailed.EntUserId).Get(&detailed.Operator)
+		}
+		if err != nil {
+			_ = centerOrm.Rollback()
+			return &resourcesCenter.ChargeResp{Code: entity.ErrorCode, Message: "操作人查询失败"}
 		}
 		updateNum, err = centerOrm.Table(ConsumeRecord).Insert(&detailed)
 		if err != nil || updateNum <= 0 {
+			_ = centerOrm.Rollback()
 			return &resourcesCenter.ChargeResp{Code: entity.ErrorCode, Message: "账号使用明细保存失败"}
 		}
 		err = centerOrm.Commit()