Update api/chatgpt/api.go

api/chatgpt/api.go

@@ -73,17 +73,20 @@ func CreateConversation(c *gin.Context) {
 		return
 	}
 
-	defer resp.Body.Close()
 	if resp.StatusCode != http.StatusOK {
 		responseMap := make(map[string]interface{})
 		json.NewDecoder(resp.Body).Decode(&responseMap)
 		c.AbortWithStatusJSON(resp.StatusCode, responseMap)
+		resp.Body.Close()
 		return
 	}
 	c.Set("oldpart", "")
 	Status, ConversationID, part := api.HandleConversationResponse(c, resp)
 	if Status {
+		resp.Body.Close()
 		ContinueConversation(c, ConversationID, request.ParentMessageID, request.Model, part)
+	} else {
+		resp.Body.Close()
 	}
 }
 
@@ -126,20 +129,23 @@ func ContinueConversation(c *gin.Context, conversationID string, parentMessageID
 		return
 	}
 
-	defer resp.Body.Close()
 	if resp.StatusCode != http.StatusOK {
-		logger.Info(fmt.Sprintf("ContinueConversationRequestStatusCode != http.StatusOK %d", resp.StatusCode))
+		logger.Info("ContinueConversationRequestStatusCode != http.StatusOK " + string(rune(resp.StatusCode)))
 		responseMap := make(map[string]interface{})
 		json.NewDecoder(resp.Body).Decode(&responseMap)
 		c.AbortWithStatusJSON(resp.StatusCode, responseMap)
+		resp.Body.Close()
 		return
 	}
 
 	c.Set("oldpart", oldpart)
 	Status, ConversationID, part := api.HandleConversationResponse(c, resp)
 	if Status {
+		resp.Body.Close()
 		logger.Info(fmt.Sprintf("part的值: %s", part))
 		ContinueConversation(c, ConversationID, request.ParentMessageID, request.Model, part)
+	} else {
+		resp.Body.Close()
 	}
 }