wip:并发限制提交

internal/model/pool.go

@@ -16,7 +16,6 @@ type cChatGptPool struct {
 }
 
 func NewChatGptPool(pool int) *cChatGptPool {
-	fmt.Println("pool", pool)
 	c := &cChatGptPool{
 		GPTPool: make(chan bool, pool),
 	}
@@ -27,7 +26,6 @@ func NewChatGptPool(pool int) *cChatGptPool {
 }
 
 func (c *cChatGptPool) Get() error {
-	fmt.Println("tttt", g.Config().MustGet(gctx.New(), "chat.api.waitTimeout", 10).Int())
 	select {
 	case <-c.GPTPool:
 		return nil

internal/model/question.go

@@ -163,6 +163,7 @@ func (q *cQuestion) DetailQuestion(ctx context.Context, qRes *QuestionReq) (repl
 		}
 		cRes, err := ChatGpt.GPTDo(ctx, qRes)
 		if err != nil {
+			ChatGptPool.Add()
 			return "", nil, 0, err
 		}
 		return "", cRes, Answer_ChatGPT, nil