GOROOT=/usr/local/go #gosetup
GOPATH=/Users/laurent/go #gosetup
/usr/local/go/bin/go test -c -o /private/var/folders/xs/rz1dk04s1m1gv98fyc9h9b0m0000gn/T/___TestSyncJDChatGroup_in_code_haxii_com_thor_sif_service code.haxii.com/thor/sif/service #gosetup
/usr/local/go/bin/go tool test2json -t /private/var/folders/xs/rz1dk04s1m1gv98fyc9h9b0m0000gn/T/___TestSyncJDChatGroup_in_code_haxii_com_thor_sif_service -test.v -test.paniconexit0 -test.run ^\QTestSyncJDChatGroup\E$
=== RUN   TestSyncJDChatGroup
--- FAIL: TestSyncJDChatGroup (0.00s)
panic: runtime error: invalid memory address or nil pointer dereference [recovered]
	panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x10 pc=0x4728e43]

goroutine 21 [running]:
testing.tRunner.func1.2(0x49b9920, 0x526c7e0)
	/usr/local/go/src/testing/testing.go:1144 +0x332
testing.tRunner.func1(0xc000082f00)
	/usr/local/go/src/testing/testing.go:1147 +0x4b6
panic(0x49b9920, 0x526c7e0)
	/usr/local/go/src/runtime/panic.go:965 +0x1b9
code.haxii.com/thor/cookie.(*Cache).Query(0x0, 0x4acd9a4, 0x7, 0x4ace4a5, 0x8, 0x0, 0x4124c80, 0x503dea0)
	/Users/laurent/go/pkg/mod/code.haxii.com/thor/cookie@v0.1.0/cache.go:56 +0x43
code.haxii.com/thor/cookie.(*Cache).Get(...)
	/Users/laurent/go/pkg/mod/code.haxii.com/thor/cookie@v0.1.0/cache.go:41
code.haxii.com/thor/sif/service.SyncJDChatGroup(0xc000484cf0, 0x1, 0x1, 0x1445ed5421144, 0xc0165331d8)
	/Users/laurent/Downloads/thor/sif/service/jd_chat_group.go:24 +0x12a
code.haxii.com/thor/sif/service.TestSyncJDChatGroup(0xc000082f00)
	/Users/laurent/Downloads/thor/sif/service/jd_chat_goup_test.go:10 +0x65
testing.tRunner(0xc000082f00, 0x4b0c100)
	/usr/local/go/src/testing/testing.go:1194 +0xef
created by testing.(*T).Run
	/usr/local/go/src/testing/testing.go:1239 +0x2b3


Process finished with exit code 1

package service

import (
	"fmt"
	"io"
	"testing"
)

func a() error {
	var err error
	defer func() {
		if err != nil {
			fmt.Println("defer1", err)
		} else {
			fmt.Println("ok")
		}
	}()

	err = io.ErrNoProgress

	defer func() {
		err = io.ErrShortWrite
		if err != nil {
			fmt.Println("defer2", err)
		} else {
			fmt.Println("ok")
		}
	}()
	err = io.ErrClosedPipe

	fmt.Println("err", err)
	return err
}
func TestDefer(t *testing.T) {
	fmt.Println(a())
}

db.Table("go_service_info").Select("go_service_info.serviceId as service_id, go_service_info.serviceName as service_name, go_system_info.systemId as system_id, go_system_info.systemName as system_name").Joins("left join go_system_info on go_service_info.systemId = go_system_info.systemId where go_service_info.serviceId <> ? and go_system_info.systemId = ?", "xxx", "xxx").Scan(&results)

type handler struct {
	logger       log.Logger
	who          string
	jdAPI        *JDAPI
	uploadClient *CookieUploadClient

	uploadRateLimitMu  sync.RWMutex    // 读写锁
	uploadRateLimitMap map[string]uploadRateLimit
}
//……//
func (h *handler) rateLimit(next http.Handler) http.Handler {
	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		cookie := r.Header.Get("Cookie")
		if len(cookie) > 0 {
			h.uploadRateLimitMu.RLock()
			rateLimit := h.uploadRateLimitMap[cookie]
			h.uploadRateLimitMu.RUnlock()
			if time.Now().Sub(rateLimit.LastUploadTime) < cookieUploadRateLimitDuration {
				if _, err := fmt.Fprintf(w, autoRefreshHTML, "same cookie upload rate limit"); err != nil {
					h.logger.Error(h.who, err, "fail to respond %s", r.RemoteAddr)
				}
				return
			}
		}
		next.ServeHTTP(w, r)
		if len(cookie) > 0 {
			h.uploadRateLimitMu.Lock()     // 更改前把数据锁住，只能这这次操作更改
			h.uploadRateLimitMap[cookie] = uploadRateLimit{LastUploadTime: time.Now()}
			h.uploadRateLimitMu.Unlock()	// 更改后把数据解锁
		}
	})
}
//……//

type shopInfo struct {
   logger       log.Logger
   cookieClient *client.JDCookieClient

   cachedMallID sync.Map
}
//……//
func (s *shopInfo) getMallID(cookie *client.JDCookie) (string, error) {
	_mallID, exists := s.cachedMallID.Load(cookie.ShopID)
	if exists {
		return _mallID.(string), nil
	}
	mallID, err := s.queryMallID(cookie)
	if err != nil {
		return "", err
	}
	_mallID, _ = s.cachedMallID.LoadOrStore(cookie.ShopID, mallID)
	return _mallID.(string), nil
}
//……//

Methods:
  Load(key interface{}) (value interface{}, ok bool)
  Store(key interface{}, value interface{})
  LoadOrStore(key interface{}, value interface{}) (actual interface{}, loaded bool)
  LoadAndDelete(key interface{}) (value interface{}, loaded bool)
  Delete(key interface{})
  Range(f func(key interface{}, value interface{}) bool)
  missLocked()
  dirtyLocked()

// model
type SzWaiterResp struct {
	Content struct {
		Data      [][]json.RawMessage `json:"data"`
		MetaIndex map[string]int      `json:"metaIndex"`
	} `json:"content"`
	Message string `json:"message"`
	Status  string `json:"status"`
}
// 对query结果进行处理
waiterResp := &SzWaiterResp{}
	if err = jsoniter.Unmarshal(resp, waiterResp); err != nil {
		return nil, err
	}
	if waiterResp.Message != "success" {
		return nil, err
	}
	indexKey := make(map[int]string, 0)
	for key, val := range waiterResp.Content.MetaIndex {
		indexKey[val] = key
	}
	result = make([]map[string]json.RawMessage, 0)
	for _, jsonArr := range waiterResp.Content.Data {
		part := make(map[string]json.RawMessage, 0)
		for index, ele := range jsonArr {
			part[indexKey[index]] = ele
		}
		shopID, _ := jsoniter.Marshal(cookie.ShopID)
		date, _ := jsoniter.Marshal(FormatTimeStamp(timestamp))
		updateTimestamp, _ := jsoniter.Marshal(FormatTimeStamp(time.Now()))
		part["shopID"] = shopID
		part["timestamp"] = date
		part["updateTimestamp"] = updateTimestamp
		result = append(result, part)
	}