1:chan Callback 改为 chan *Callback

xluohome · Feb 23, 2017 · 9734bbe · 9734bbe
1 parent bc23d2c
commit 9734bbe
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/callback.go b/callback.go
@@ -16,7 +16,7 @@ type Callback struct {
 }
 
 var (
-	callback = make(chan Callback)
+	callback = make(chan *Callback)
 )
 
 func RunCallbackTask() {
@@ -37,14 +37,14 @@ func AddCallbackTask(sms *SMS, flag string) {
 	data.Set("service", sms.serviceName)
 	data.Set("uxtime", fmt.Sprintf("%d", sms.NowTime.Unix()))
 	data.Set("flag", flag)
-	callback <- Callback{sms.Config.Callback, data, 0}
+	callback <- &Callback{sms.Config.Callback, data, 0}
 }
 
-func (c Callback) Do(cbs <-chan Callback) {
+func (c *Callback) Do(cbs <-chan *Callback) {
 
 	for cb := range cbs {
 
-		go func() {
+		go func(cb *Callback) {
 			//延时 2,4,6,8,16,32,64,128 ... 秒
 			<-time.After(time.Duration(1<<cb.callnums) * time.Second)
 
@@ -70,7 +70,7 @@ func (c Callback) Do(cbs <-chan Callback) {
 
 			callback <- cb
 
-		}()
+		}(cb)
 
 	}
 }
diff --git a/f_hywx.go b/f_hywx.go
@@ -44,7 +44,7 @@ func (h *Hywx) Send(sms *SMS) error {
 	}
 
 	if h.Code != 2 {
-		log.Error("%v", h)
+		log.Errorf("%v", h)
 		return fmt.Errorf("%s", h.Msg)
 	}