修改积分控制

credit/src/config.json

@@ -69,5 +69,7 @@
         "pwd": "qy123456",
         "fromuser": "企明星",
 		"touser":"renzheng@topnet.net.cn,zhanghongbo@topnet.net.cn"
-    }
+    },
+	"saveLogDuration":1,
+	"checkGiveDuration":30,
 }

credit/src/main.go

@@ -59,7 +59,7 @@ func quartz() {
 	go func() {
 		for {
 			select {
-			case <-timingwheel.TW.After(5 * time.Second):
+			case <-timingwheel.TW.After(time.Duration(util.IntAllDef(SysConfig["saveLogDuration"], 5)) * time.Minute):
 				creditlog.SaveLog()
 			}
 		}
@@ -69,4 +69,33 @@ func quartz() {
 
 	//每天一次检查剑鱼积分
 
+	//定时任务转赠积分24后无人接收即退回，本月不做了
+	/**
+	go func() {
+		for {
+			select {
+			case <-timingwheel.TW.After(time.Duration(util.IntAllDef(SysConfig["checkGiveDuration"], 30)) * time.Second):
+				util.Try(func() {
+					session := mongodb.GetMgoConn()
+					defer mongodb.DestoryMongoConn(session)
+					query := session.DB("qfw").C(creditlog.TB).Find(&map[string]interface{}{
+						"s_code": "B1",
+						"l_date": map[string]interface{}{
+							"$lt": time.Now().Unix() - 24*3600,
+						},
+						"i_givestatus": 0,
+					}).Iter()
+					for tmp := new(map[string]interface{}); query.Next(tmp); {
+						//进行退回操作
+
+						tmp = new(map[string]interface{})
+					}
+				}, func(e interface{}) {
+					log.Println("定时任务转赠无人接收收回报错", e)
+				})
+			}
+		}
+	}()
+	**/
+
 }

credit/src/qfw/timewheel/timingwheel.go

@@ -5,7 +5,7 @@ import (
 	"time"
 )
 
-var TW *TimingWheel = NewTimingWheel(1*time.Second, 600)
+var TW *TimingWheel = NewTimingWheel(1*time.Minute, 300)
 
 type TimingWheel struct {
 	sync.Mutex