|
@@ -82,8 +82,8 @@ func StartTask1() {
|
|
log.Println("自动回款创建回款记录成功", id, orderCode)
|
|
log.Println("自动回款创建回款记录成功", id, orderCode)
|
|
util.JysqlDB.Update("dataexport_order", map[string]interface{}{"order_code": orderCode}, updateData)
|
|
util.JysqlDB.Update("dataexport_order", map[string]interface{}{"order_code": orderCode}, updateData)
|
|
util.CbsDB.Update("transaction", map[string]interface{}{"id": id}, map[string]interface{}{"ISRELATION": 1, "return_id": fmt.Sprint(returnId)})
|
|
util.CbsDB.Update("transaction", map[string]interface{}{"id": id}, map[string]interface{}{"ISRELATION": 1, "return_id": fmt.Sprint(returnId)})
|
|
- //filterMap := qu.ObjToMap(o["filter"])
|
|
|
|
- if qu.IntAll(o["return_status"]) == 1 {
|
|
|
|
|
|
+ filterMap := qu.ObjToMap(o["filter"])
|
|
|
|
+ if qu.IntAll(o["return_status"]) == 1 && qu.IntAll((*filterMap)["isServiceOpen"]) == 0 {
|
|
err := order.OpenUserService(orderCode, o)
|
|
err := order.OpenUserService(orderCode, o)
|
|
if err != nil {
|
|
if err != nil {
|
|
log.Println("自动回款开通权益失败", id, orderCode)
|
|
log.Println("自动回款开通权益失败", id, orderCode)
|