|
@@ -135,9 +135,11 @@ var (
|
|
|
},
|
|
|
}
|
|
|
//TODO 回调开票成功
|
|
|
- for {
|
|
|
+ ok := false
|
|
|
+ for i := 0; i < 10; i++ {
|
|
|
if checkCallBackOk(goCtx, callBackParam) {
|
|
|
g.Log().Infof(goCtx, "开票任务-开票成功")
|
|
|
+ ok = true
|
|
|
break
|
|
|
}
|
|
|
time.Sleep(time.Second * 3)
|
|
@@ -151,6 +153,10 @@ var (
|
|
|
}
|
|
|
time.Sleep(time.Second * 3)
|
|
|
}
|
|
|
+
|
|
|
+ if !ok {
|
|
|
+ g.Log().Errorf(goCtx, "发票回调执行异常 %+v", callBackParam)
|
|
|
+ }
|
|
|
}()
|
|
|
r.Response.WriteJson(CommonRes{
|
|
|
Code: 200,
|
|
@@ -192,7 +198,8 @@ var (
|
|
|
}
|
|
|
|
|
|
//TODO 回调红冲成功
|
|
|
- for {
|
|
|
+ ok := false
|
|
|
+ for i := 0; i < 10; i++ {
|
|
|
if checkCallBackOk(goCtx, callBackParam) {
|
|
|
g.Log().Infof(goCtx, "红冲任务-红冲成功")
|
|
|
break
|
|
@@ -208,6 +215,10 @@ var (
|
|
|
}
|
|
|
time.Sleep(time.Second * 3)
|
|
|
}
|
|
|
+
|
|
|
+ if !ok {
|
|
|
+ g.Log().Errorf(goCtx, "发票回调执行异常 %+v", callBackParam)
|
|
|
+ }
|
|
|
}()
|
|
|
r.Response.WriteJson(CommonRes{
|
|
|
Code: 200,
|