|
|
@@ -220,7 +220,7 @@ func entCharge(data *resourcesCenter.ChargeReq) (resp *resourcesCenter.ChargeRes
|
|
|
|
|
|
func personCharge(data *resourcesCenter.ChargeReq) (resp *resourcesCenter.ChargeResp) {
|
|
|
now := time.Now().Format("2006-01-02")
|
|
|
- jyOrm := entity.Engine.NewSession()
|
|
|
+ jyOrm := entity.JyEngine.NewSession()
|
|
|
centerOrm := entity.Engine.NewSession()
|
|
|
var personNums int64
|
|
|
_, err := centerOrm.Table("account_resources").Select("sum(number) as number").
|
|
|
@@ -302,7 +302,7 @@ func personCharge(data *resourcesCenter.ChargeReq) (resp *resourcesCenter.Charge
|
|
|
}
|
|
|
err = centerOrm.Commit()
|
|
|
if err != nil {
|
|
|
- _ = jyOrm.Rollback()
|
|
|
+ _ = centerOrm.Rollback()
|
|
|
return &resourcesCenter.ChargeResp{Code: entity.ErrorCode, Message: "事务提交失败"}
|
|
|
}
|
|
|
}
|
