From 89323d325073e9e27c9b9109cd53d2288c42003d Mon Sep 17 00:00:00 2001
From: renzhiyuan <465386466@qq.com>
Date: Fri, 9 Jan 2026 11:00:39 +0800
Subject: [PATCH 01/13] =?UTF-8?q?fix:=20=E5=A2=9E=E5=8A=A0=E7=A9=BA?=
 =?UTF-8?q?=E5=80=BC=E6=A3=80=E6=9F=A5=E5=92=8C=E4=BC=98=E5=8C=96=E8=AE=A2?=
 =?UTF-8?q?=E5=8D=95=E6=9F=A5=E8=AF=A2=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/pkg/rec_extra/ext.go            |  3 +++
 internal/tools/zltx/excute_test.go       | 21 ++++++++++++++---
 internal/tools/zltx/zltx_order_detail.go | 29 ++++++++++++++++++++----
 3 files changed, 46 insertions(+), 7 deletions(-)

diff --git a/internal/pkg/rec_extra/ext.go b/internal/pkg/rec_extra/ext.go
index b8b3c86..ac842de 100644
--- a/internal/pkg/rec_extra/ext.go
+++ b/internal/pkg/rec_extra/ext.go
@@ -17,6 +17,9 @@ func SetTaskRecExt(requireData *entitys.RequireData, rec *entitys.Recognize) {
 }
 
 func GetTaskRecExt(rec *entitys.Recognize) (ext entitys.TaskExt, err error) {
+	if rec == nil {
+		return
+	}
 	err = json.Unmarshal(rec.Ext, &ext)
 	return ext, err
 }
diff --git a/internal/tools/zltx/excute_test.go b/internal/tools/zltx/excute_test.go
index 3f8460d..0c5cd78 100644
--- a/internal/tools/zltx/excute_test.go
+++ b/internal/tools/zltx/excute_test.go
@@ -4,16 +4,31 @@ import (
 	config2 "ai_scheduler/internal/config"
 	"ai_scheduler/internal/entitys"
 	"context"
+	"strings"
 	"testing"
 )
 
 func Test_task(t *testing.T) {
-	c := NewZltxOrderDetailTool(config2.ToolConfig{}, nil)
+	c := NewZltxOrderDetailTool(config2.ToolConfig{
+		BaseURL: "https://revcl.1688sup.com/api/admin/direct/ai/%s",
+		AddURL:  "https://revcl.1688sup.com/api/admin/direct/log/%s/%s",
+	}, nil)
+	ch := make(chan entitys.Response, 10000)
 	err :=
 		c.Execute(context.Background(), &entitys.Recognize{
 			Match: &entitys.Match{
-				Parameters: `{"order_number": 859393216068067329}`,
+				Parameters: `{"order_number": 864086822064234497}`,
 			},
+			Ext:         []byte(`{"auth":"eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJ1c2VyQ2VudGVyIiwiZXhwIjoxNzY3OTM0MTg1LCJuYmYiOjE3Njc5MjMzODUsImp0aSI6IjE3OSIsIlBob25lIjoiMTUwMDA0NTAxNTUiLCJVc2VyTmFtZSI6IjE1MDAwNDUwMTU1IiwiUmVhbE5hbWUiOiLliJjlvanlhpsiLCJBY2NvdW50VHlwZSI6MSwiR3JvdXBDb2RlcyI6IlZDTF9BRE1JTixWQ0xfU1lTVEVNLENSTV9BRE1JTixMU1hERFNfQURNSU4sTFNYRERTX1NZU1RFTSxNQVJLRVRJTkdTQUFTX1NVUEVSQURNSU4sU1RBVElTVElDQUxTWVNURU1fQURNSU4sUEhZU0lDQUxHT09EU19BRE1JTixNQVJLRVRJTkdTWVNURU1fU1VQRVIsUkVQT1JUQ0VOVEVSX0FETUlOLE1PTklUT1JfTUFESU4sWkxUWF9BRE1JTixaTFRYX09QRVJBVEUiLCJEaW5nVXNlcklkIjoiMTcxMTkzNTg3NTAzMjk5MzUifQ.d9z0S1Ia-PFAxhGstT055Amt8PI09bUHxG0_lba4UwvSomiTNCD-5DFdMkbZHwiDTlhVdBjcd1mDYFRRZXWMPoSnanubMBnRnuvTi8csch5nz1L9oWNo-HFyBE3lMw9-UJ5j84gz228_kcBsvRATT1Ixs9bnuaN9CDNz20c524llDt10C3cc8wLGMin4jWEMF4RNrf2oBZOFAahRYSJNeBmutIwRSIP1pMIAaUy_IkMCyOwK8JzgMnHJGLwIH_nxR9XZXlAN0FmrmtWVkRA2YUKvoDX5a5BCYmDVNqUbi_ZNuRPJH87Ia7_-UoyJu8Yq79jX0Qgsm6qJ4rX2nauneg"}`),
+			UserContent: &entitys.RecognizeUserContent{Text: "订单查询：864086822064234497\n"},
 		})
-	t.Log(err)
+	if err != nil {
+		t.Log(err)
+	}
+	var res strings.Builder
+	for v := range ch {
+		res.WriteString(v.Content)
+	}
+	t.Log(res)
+
 }
diff --git a/internal/tools/zltx/zltx_order_detail.go b/internal/tools/zltx/zltx_order_detail.go
index 47574a3..8ad1001 100644
--- a/internal/tools/zltx/zltx_order_detail.go
+++ b/internal/tools/zltx/zltx_order_detail.go
@@ -84,8 +84,8 @@ type ZltxOrderDetailData struct {
 
 // Execute 执行直连天下订单详情查询
 func (w *ZltxOrderDetailTool) Execute(ctx context.Context, rec *entitys.Recognize) error {
-	var req ZltxOrderDetailRequest
-	if err := json.Unmarshal([]byte(rec.Match.Parameters), &req); err != nil {
+	var req = &ZltxOrderDetailRequest{}
+	if err := req.UnmarshalJSON([]byte(rec.Match.Parameters)); err != nil {
 		return fmt.Errorf("invalid zltxOrderDetail request: %w", err)
 	}
 	if req.OrderNumber == "" {
@@ -96,6 +96,22 @@ func (w *ZltxOrderDetailTool) Execute(ctx context.Context, rec *entitys.Recogniz
 	return w.getZltxOrderDetail(rec, req.OrderNumber)
 }
 
+func (r *ZltxOrderDetailRequest) UnmarshalJSON(data []byte) error {
+	var tmp struct {
+		OrderNumber json.Number `json:"order_number"` // 使用 json.Number 保留原始格式
+	}
+	if err := json.Unmarshal(data, &tmp); err != nil {
+		return err
+	}
+	// 根据需要转换为 int64 或 string
+	if num, err := tmp.OrderNumber.Int64(); err == nil {
+		r.OrderNumber = num
+	} else {
+		r.OrderNumber = tmp.OrderNumber.String()
+	}
+	return nil
+}
+
 // getMockZltxOrderDetail 获取模拟直连天下订单详情数据
 func (w *ZltxOrderDetailTool) getZltxOrderDetail(rec *entitys.Recognize, number interface{}) (err error) {
 	log.Infof("订单编号：%v,类型：%v")
@@ -170,8 +186,13 @@ func (w *ZltxOrderDetailTool) getZltxOrderDetail(rec *entitys.Recognize, number
 
 		err = w.llm.ChatStream(context.TODO(), rec.Ch, []api.Message{
 			{
-				Role:    "system",
-				Content: "你是一个订单日志助手。用户可能会提供订单日志，你需要分析订单日志，失败订单->分析失败原因，成功订单->找出整个日志的 Base64 编码的 JSON 数据的内容进行转换并反馈给我",
+				Role: "system",
+				Content: "你是一个订单日志助手。用户可能会提供订单日志，你需要按以下规则处理：\n" +
+					"1. **先输出结论**：用<conclusion></conclusion>标签包裹关键结论（如失败原因或Base64解码内容）；\n" +
+					"2. **再输出分析过程**：详细解释如何得出结论；\n" +
+					"3. **订单类型处理**：\n" +
+					"   - 失败订单：分析失败原因（如支付超时、库存不足等）；\n" +
+					"   - 成功订单：提取日志中的Base64编码JSON数据，解码后转换为用户可读的格式（如表格或JSON）。",
 			},
 			{
 				Role:    "assistant",

From b4dddb06357e342836ffba58a564ce246d06f07e Mon Sep 17 00:00:00 2001
From: renzhiyuan <465386466@qq.com>
Date: Fri, 9 Jan 2026 16:52:05 +0800
Subject: [PATCH 02/13] =?UTF-8?q?fix:=20=E6=9B=B4=E6=96=B0=E7=BB=8F?=
 =?UTF-8?q?=E9=94=80=E5=95=86=E9=BB=91=E5=90=8D=E5=8D=95=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/tools/bbxt/bbxt_test.go         | 10 +++++-----
 internal/tools/zltx/zltx_order_detail.go |  2 +-
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/internal/tools/bbxt/bbxt_test.go b/internal/tools/bbxt/bbxt_test.go
index e119c02..ee7f5da 100644
--- a/internal/tools/bbxt/bbxt_test.go
+++ b/internal/tools/bbxt/bbxt_test.go
@@ -23,7 +23,7 @@ func Test_StatisOursProductLossSumApiTotal(t *testing.T) {
 	if err != nil {
 		panic(err)
 	}
-	o, err := NewBbxtTools()
+	o, err := NewBbxtTools(nil)
 	if err != nil {
 		panic(err)
 	}
@@ -34,7 +34,7 @@ func Test_StatisOursProductLossSumApiTotal(t *testing.T) {
 }
 
 func Test_StatisOursProductLossSum(t *testing.T) {
-	o, err := NewBbxtTools()
+	o, err := NewBbxtTools(nil)
 	if err != nil {
 		panic(err)
 	}
@@ -45,7 +45,7 @@ func Test_StatisOursProductLossSum(t *testing.T) {
 }
 
 func Test_GetProfitRankingSum(t *testing.T) {
-	o, err := NewBbxtTools()
+	o, err := NewBbxtTools(nil)
 	if err != nil {
 		panic(err)
 	}
@@ -56,7 +56,7 @@ func Test_GetProfitRankingSum(t *testing.T) {
 }
 
 func Test_GetStatisOfficialProductSumDecline(t *testing.T) {
-	o, err := NewBbxtTools()
+	o, err := NewBbxtTools(nil)
 	if err != nil {
 		panic(err)
 	}
@@ -69,7 +69,7 @@ func Test_GetStatisOfficialProductSumDecline(t *testing.T) {
 }
 
 func Test_GetStatisOfficialProductSum(t *testing.T) {
-	o, err := NewBbxtTools()
+	o, err := NewBbxtTools(nil)
 	if err != nil {
 		panic(err)
 	}
diff --git a/internal/tools/zltx/zltx_order_detail.go b/internal/tools/zltx/zltx_order_detail.go
index 8ad1001..6e33e63 100644
--- a/internal/tools/zltx/zltx_order_detail.go
+++ b/internal/tools/zltx/zltx_order_detail.go
@@ -189,7 +189,7 @@ func (w *ZltxOrderDetailTool) getZltxOrderDetail(rec *entitys.Recognize, number
 				Role: "system",
 				Content: "你是一个订单日志助手。用户可能会提供订单日志，你需要按以下规则处理：\n" +
 					"1. **先输出结论**：用<conclusion></conclusion>标签包裹关键结论（如失败原因或Base64解码内容）；\n" +
-					"2. **再输出分析过程**：详细解释如何得出结论；\n" +
+					"2. **再输出分析过程**：详细解释如何得出结论；分析过程直接输出分析内容，不需要标明是分析过程\n" +
 					"3. **订单类型处理**：\n" +
 					"   - 失败订单：分析失败原因（如支付超时、库存不足等）；\n" +
 					"   - 成功订单：提取日志中的Base64编码JSON数据，解码后转换为用户可读的格式（如表格或JSON）。",

From 44155c058d97263c683642076411112684579c4e Mon Sep 17 00:00:00 2001
From: fuzhongyun <15339891972@163.com>
Date: Fri, 9 Jan 2026 18:01:46 +0800
Subject: [PATCH 03/13] =?UTF-8?q?fix:=20=E5=A2=9E=E5=8A=A0=E4=B8=80?=
 =?UTF-8?q?=E4=B8=AA=E5=85=BC=E5=AE=B9=E7=9A=84=20TaskIndex=20=E5=AD=97?=
 =?UTF-8?q?=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/entitys/chat_history.go | 30 +++++++++++++++++++++++++++---
 1 file changed, 27 insertions(+), 3 deletions(-)

diff --git a/internal/entitys/chat_history.go b/internal/entitys/chat_history.go
index b50148e..50bbb0b 100644
--- a/internal/entitys/chat_history.go
+++ b/internal/entitys/chat_history.go
@@ -33,9 +33,10 @@ type ChatHisQueryResponse struct {
 	Files     string   `gorm:"column:files;not null" json:"files"`
 	Useful    int32    `gorm:"column:useful;not null;comment:0不评价,1有用，其他为无用" json:"useful"` // 0不评价,1有用，其他为无用
 	CreateAt  string   `gorm:"column:create_at;default:CURRENT_TIMESTAMP" json:"create_at"`
-	TaskID    int32    `gorm:"column:task_id;not null" json:"task_id"`     // 任务ID
-	TaskName  string   `gorm:"column:task_name;not null" json:"task_name"` // 任务名称
-	Contents  []string `gorm:"column:contents" json:"contents"`            // 前端回传数据
+	TaskID    int32    `gorm:"column:task_id;not null" json:"task_id"`       // 任务ID
+	TaskName  string   `gorm:"column:task_name;not null" json:"task_name"`   // 任务名称
+	Contents  []string `gorm:"column:contents" json:"contents"`              // 前端回传数据
+	TaskIndex string   `gorm:"column:task_index;not null" json:"task_index"` // 任务索引
 }
 
 func (c *ChatHisQueryResponse) FromModel(chat model.AiChatHi, task model.AiTask) {
@@ -49,6 +50,7 @@ func (c *ChatHisQueryResponse) FromModel(chat model.AiChatHi, task model.AiTask)
 	c.TaskID = chat.TaskID
 	c.TaskName = task.Name
 	c.Contents = make([]string, 0)
+	c.TaskIndex = c.parseTaskIndex(task.Index, chat.Ans)
 
 	// 解析Content
 	if "" != chat.Content {
@@ -60,6 +62,28 @@ func (c *ChatHisQueryResponse) FromModel(chat model.AiChatHi, task model.AiTask)
 	}
 }
 
+func (c *ChatHisQueryResponse) parseTaskIndex(taskIndex string, ans string) string {
+	if taskIndex != "" {
+		return taskIndex
+	}
+
+	if ans == "" {
+		return ""
+	}
+	var resp []Response
+	err := json.Unmarshal([]byte(ans), &resp)
+	if err != nil {
+		log.Println("解析Ans失败 error: ", err)
+		return ""
+	}
+
+	if 0 < len(resp) {
+		return resp[0].Index
+	}
+
+	return ""
+}
+
 type UpdateContentRequest struct {
 	HisID   int64  `json:"his_id" validate:"required"`
 	Content string `json:"content" validate:"required"`

From 03652cb588eed711d4290eb8b0b7be9c82665722 Mon Sep 17 00:00:00 2001
From: fuzhongyun <15339891972@163.com>
Date: Fri, 9 Jan 2026 18:31:51 +0800
Subject: [PATCH 04/13] =?UTF-8?q?fix:=20session=20title=20=E8=A1=A5?=
 =?UTF-8?q?=E5=85=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/biz/do/ctx.go | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/internal/biz/do/ctx.go b/internal/biz/do/ctx.go
index 6058b38..8d5cf74 100644
--- a/internal/biz/do/ctx.go
+++ b/internal/biz/do/ctx.go
@@ -32,16 +32,18 @@ type Do struct {
 }
 
 func NewDo(
+	sessionImpl *impl.SessionImpl,
 	sysImpl *impl.SysImpl,
 	taskImpl *impl.TaskImpl,
 	hisImpl *impl.ChatHisImpl,
 	conf *config.Config,
 ) *Do {
 	return &Do{
-		conf:     conf,
-		sysImpl:  sysImpl,
-		hisImpl:  hisImpl,
-		taskImpl: taskImpl,
+		conf:        conf,
+		sessionImpl: sessionImpl,
+		sysImpl:     sysImpl,
+		hisImpl:     hisImpl,
+		taskImpl:    taskImpl,
 	}
 }
 
@@ -275,6 +277,15 @@ func (d *Do) startMessageHandler(
 				}
 				d.hisImpl.AddWithData(AiRes)
 				hisLog.HisId = AiRes.HisID
+
+				// 查询当前session
+				cond := builder.NewCond().And(builder.Eq{"session_id": requireData.Session})
+				sessionMap, _ := d.sessionImpl.GetOneBySearch(&cond)
+				requireData.SessionInfo.Title = sessionMap["title"].(string)
+				// 当前 session title为空 ，更新为用户输入
+				if requireData.SessionInfo.Title == "" {
+					d.sessionImpl.UpdateByCond(&cond, &model.AiSession{Title: requireData.Req.Text})
+				}
 			}
 
 			_ = entitys.MsgSend(client, entitys.Response{

From 6c987b15db6c5e7f731a37eda4bb6cf60eece7c1 Mon Sep 17 00:00:00 2001
From: renzhiyuan <465386466@qq.com>
Date: Tue, 13 Jan 2026 17:13:44 +0800
Subject: [PATCH 05/13] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E8=B4=9F?=
 =?UTF-8?q?=E5=88=A9=E6=B6=A6=E5=88=86=E6=9E=90=E6=8A=A5=E8=A1=A8=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 config/config.yaml                            |   1 +
 config/config_test.yaml                       |  14 +-
 internal/biz/ding_talk_bot.go                 |  98 ++++++++---
 internal/biz/group_config.go                  |  87 ++++++++--
 internal/config/config.go                     |   6 +
 internal/data/impl/provider_set.go            |   1 +
 internal/data/impl/report_dayily_cache.go     |  17 ++
 .../data/model/ai_report_daily_cache.gen.go   |  20 +++
 internal/pkg/lsxd/login.go                    |  29 ++--
 internal/pkg/util/map.go                      |  31 +++-
 internal/tools/bbxt/api.go                    | 123 ++++++++++++-
 internal/tools/bbxt/bbxt.go                   | 161 ++++++++++++-----
 internal/tools/bbxt/bbxt_test.go              |  85 ++++++++-
 internal/tools/bbxt/entitys.go                |  15 +-
 internal/tools/bbxt/excel.go                  | 164 +++++++++++++++++-
 tmpl/excel_temp/kshj_total_ana.xlsx           | Bin 0 -> 10304 bytes
 16 files changed, 730 insertions(+), 122 deletions(-)
 create mode 100644 internal/data/impl/report_dayily_cache.go
 create mode 100644 internal/data/model/ai_report_daily_cache.gen.go
 create mode 100644 tmpl/excel_temp/kshj_total_ana.xlsx

diff --git a/config/config.yaml b/config/config.yaml
index 37b65aa..3b4fab8 100644
--- a/config/config.yaml
+++ b/config/config.yaml
@@ -27,6 +27,7 @@ lsxd:
   login_url: "https://api.user.1688sup.com/v1/login/phone"
   phone: "ORlviZN7N06W2+WKLe76xg=="
   password: "V5Uh8C4bamEM6UQZh4TCeQ=="
+  code: "456789"
   check_token_url: "https://api.user.1688sup.com/v1/user/welcome"
 
   
diff --git a/config/config_test.yaml b/config/config_test.yaml
index c993b35..4aab8b8 100644
--- a/config/config_test.yaml
+++ b/config/config_test.yaml
@@ -26,10 +26,14 @@ coze:
 
 lsxd:
   # 统一登录
-  login_url: "https://api.user.1688sup.com/v1/login/phone"
-  phone: "ORlviZN7N06W2+WKLe76xg=="
-  password: "V5Uh8C4bamEM6UQZh4TCeQ=="
-  check_token_url: "https://api.user.1688sup.com/v1/user/welcome"
+  login_url: "http://api.test.user.1688sup.com/v1/login/phone"
+  phone: "OFJ8UpqOlI7+w3Qklf36ZA=="
+  password: "tEbFegH/DRRh6LutFb7o3g=="
+  code: "123456"
+  check_token_url: "http://api.test.user.1688sup.com/v1/user/welcome"
+
+zltx:
+  req_url: "https://gateway.dev.cdlsxd.cn/zltx_api"
 
 sys:
   session_len: 6
@@ -41,7 +45,7 @@ redis:
   host: 47.97.27.195:6379
   type: node
   pass: lansexiongdi@666
-  key: report-api-test
+  key: ai_scheduler-test
   pollSize: 5 #连接池大小，不配置，或配置为0表示不启用连接池
   minIdleConns: 2 #最小空闲连接数
   maxIdleTime: 30 #每个连接最大空闲时间，如果超过了这个时间会被关闭
diff --git a/internal/biz/ding_talk_bot.go b/internal/biz/ding_talk_bot.go
index 1ad715c..fe8c6e0 100644
--- a/internal/biz/ding_talk_bot.go
+++ b/internal/biz/ding_talk_bot.go
@@ -29,21 +29,22 @@ import (
 
 // AiRouterBiz 智能路由服务
 type DingTalkBotBiz struct {
-	do                 *do.Do
-	handle             *do.Handle
-	botConfigImpl      *impl.BotConfigImpl
-	replier            *chatbot.ChatbotReplier
-	log                log.Logger
-	dingTalkUser       *dingtalk.User
-	botGroupImpl       *impl.BotGroupImpl
-	botGroupConfigImpl *impl.BotGroupConfigImpl
-	botGroupQywxImpl   *impl.BotGroupQywxImpl
-	toolManager        *tools.Manager
-	chatHis            *impl.BotChatHisImpl
-	conf               *config.Config
-	cardSend           *dingtalk.SendCardClient
-	qywxGroupHandle    *qywx.Group
-	groupConfigBiz     *GroupConfigBiz
+	do                   *do.Do
+	handle               *do.Handle
+	botConfigImpl        *impl.BotConfigImpl
+	replier              *chatbot.ChatbotReplier
+	log                  log.Logger
+	dingTalkUser         *dingtalk.User
+	botGroupImpl         *impl.BotGroupImpl
+	botGroupConfigImpl   *impl.BotGroupConfigImpl
+	botGroupQywxImpl     *impl.BotGroupQywxImpl
+	toolManager          *tools.Manager
+	chatHis              *impl.BotChatHisImpl
+	conf                 *config.Config
+	cardSend             *dingtalk.SendCardClient
+	qywxGroupHandle      *qywx.Group
+	groupConfigBiz       *GroupConfigBiz
+	reportDailyCacheImpl *impl.ReportDailyCacheImpl
 }
 
 // NewDingTalkBotBiz
@@ -54,23 +55,25 @@ func NewDingTalkBotBiz(
 	botGroupImpl *impl.BotGroupImpl,
 	dingTalkUser *dingtalk.User,
 	chatHis *impl.BotChatHisImpl,
+	reportDailyCacheImpl *impl.ReportDailyCacheImpl,
 	toolManager *tools.Manager,
 	conf *config.Config,
 	cardSend *dingtalk.SendCardClient,
 	groupConfigBiz *GroupConfigBiz,
 ) *DingTalkBotBiz {
 	return &DingTalkBotBiz{
-		do:             do,
-		handle:         handle,
-		botConfigImpl:  botConfigImpl,
-		replier:        chatbot.NewChatbotReplier(),
-		dingTalkUser:   dingTalkUser,
-		groupConfigBiz: groupConfigBiz,
-		botGroupImpl:   botGroupImpl,
-		toolManager:    toolManager,
-		chatHis:        chatHis,
-		conf:           conf,
-		cardSend:       cardSend,
+		do:                   do,
+		handle:               handle,
+		botConfigImpl:        botConfigImpl,
+		replier:              chatbot.NewChatbotReplier(),
+		dingTalkUser:         dingTalkUser,
+		groupConfigBiz:       groupConfigBiz,
+		botGroupImpl:         botGroupImpl,
+		toolManager:          toolManager,
+		chatHis:              chatHis,
+		conf:                 conf,
+		cardSend:             cardSend,
+		reportDailyCacheImpl: reportDailyCacheImpl,
 	}
 }
 
@@ -197,6 +200,49 @@ func (d *DingTalkBotBiz) Macro(ctx context.Context, requireData *entitys.Require
 		return
 	}
 
+	if strings.Contains(content, "[负利润分析]获取") {
+		var (
+			data  model.AiReportDailyCache
+			value map[int32]*bbxt.ResellerLossSumProductRelation
+		)
+		cond := builder.NewCond()
+		cond = cond.And(builder.Eq{"`index`": bbxt.IndexLossSumDetail})
+		cond = cond.And(builder.Eq{"`key`": time.Now().Format(time.DateOnly)})
+		err = d.reportDailyCacheImpl.GetOneBySearchToStrut(&cond, &data)
+		if err != nil {
+			entitys.ResText(requireData.Ch, "", "获取失败")
+			return
+		}
+		err = json.Unmarshal([]byte(data.Value), &value)
+		if err != nil {
+			entitys.ResText(requireData.Ch, "", "获取失败,格式解析错误")
+			return
+		}
+
+		return
+	}
+
+	if strings.Contains(content, "[负利润分析]更新") {
+		// 提取冒号后的内容
+		if len(groupConfig.ProductName) == 0 {
+			entitys.ResText(requireData.Ch, "", "暂未设置")
+		} else {
+			entitys.ResText(requireData.Ch, "", groupConfig.ProductName)
+			isFinish = true
+		}
+		return
+	}
+
+	if strings.Contains(content, "[负利润分析]同步") {
+		// 提取冒号后的内容
+		if len(groupConfig.ProductName) == 0 {
+			entitys.ResText(requireData.Ch, "", "暂未设置")
+		} else {
+			entitys.ResText(requireData.Ch, "", groupConfig.ProductName)
+			isFinish = true
+		}
+		return
+	}
 	return
 }
 
diff --git a/internal/biz/group_config.go b/internal/biz/group_config.go
index b8ccb92..21605fc 100644
--- a/internal/biz/group_config.go
+++ b/internal/biz/group_config.go
@@ -9,11 +9,15 @@ import (
 	"ai_scheduler/internal/domain/workflow/recharge"
 	"ai_scheduler/internal/domain/workflow/runtime"
 	"ai_scheduler/internal/entitys"
+	"ai_scheduler/internal/pkg"
 	"ai_scheduler/internal/pkg/l_request"
+	"ai_scheduler/internal/pkg/lsxd"
 	"ai_scheduler/internal/pkg/utils_oss"
 	"ai_scheduler/internal/tools"
 	"ai_scheduler/internal/tools/bbxt"
+	"ai_scheduler/utils"
 	"context"
+	"database/sql"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -30,12 +34,14 @@ import (
 
 // AiRouterBiz 智能路由服务
 type GroupConfigBiz struct {
-	botGroupConfigImpl *impl.BotGroupConfigImpl
-	ossClient          *utils_oss.Client
-	workflowManager    *runtime.Registry
-	botTools           []model.AiBotTool
-	toolManager        *tools.Manager
-	conf               *config.Config
+	botGroupConfigImpl   *impl.BotGroupConfigImpl
+	reportDailyCacheImpl *impl.ReportDailyCacheImpl
+	ossClient            *utils_oss.Client
+	workflowManager      *runtime.Registry
+	botTools             []model.AiBotTool
+	toolManager          *tools.Manager
+	conf                 *config.Config
+	rdb                  *utils.Rdb
 }
 
 // NewDingTalkBotBiz
@@ -45,13 +51,17 @@ func NewGroupConfigBiz(
 	botGroupConfigImpl *impl.BotGroupConfigImpl,
 	workflowManager *runtime.Registry,
 	conf *config.Config,
+	reportDailyCacheImpl *impl.ReportDailyCacheImpl,
+	rdb *utils.Rdb,
 ) *GroupConfigBiz {
 	return &GroupConfigBiz{
-		botTools:           tools.BootTools,
-		ossClient:          ossClient,
-		botGroupConfigImpl: botGroupConfigImpl,
-		workflowManager:    workflowManager,
-		conf:               conf,
+		botTools:             tools.BootTools,
+		ossClient:            ossClient,
+		botGroupConfigImpl:   botGroupConfigImpl,
+		workflowManager:      workflowManager,
+		conf:                 conf,
+		reportDailyCacheImpl: reportDailyCacheImpl,
+		rdb:                  rdb,
 	}
 }
 
@@ -72,12 +82,12 @@ func (g *GroupConfigBiz) GetReportLists(ctx context.Context, groupConfig *model.
 		product = strings.Split(groupConfig.ProductName, ",")
 	}
 
-	reportList, err := bbxt.NewBbxtTools(g.conf)
+	reportList, err := bbxt.NewBbxtTools(g.conf, lsxd.NewLogin(g.conf, g.rdb))
 	if err != nil {
 		return
 	}
 
-	reports, err = reportList.DailyReport(time.Now(), bbxt.DownWardValue, product, bbxt.SumFilter, g.ossClient)
+	reports, err = reportList.DailyReport(ctx, time.Now(), bbxt.DownWardValue, product, bbxt.SumFilter, g.ossClient, g.GetReportCache)
 	if err != nil {
 		return
 	}
@@ -145,7 +155,8 @@ func (g *GroupConfigBiz) handleReport(ctx context.Context, rec *entitys.Recogniz
 			}
 		}
 	}
-	rep, err := bbxt.NewBbxtTools(g.conf)
+
+	rep, err := bbxt.NewBbxtTools(g.conf, lsxd.NewLogin(g.conf, g.rdb))
 	uploader := bbxt.NewUploader(g.ossClient, g.conf)
 	if err != nil {
 		return err
@@ -153,7 +164,7 @@ func (g *GroupConfigBiz) handleReport(ctx context.Context, rec *entitys.Recogniz
 	var reports []*bbxt.ReportRes
 	switch rec.Match.Index {
 	case "report_loss_analysis":
-		repo, _err := rep.StatisOursProductLossSum(t)
+		repo, _err := rep.StatisOursProductLossSum(ctx, t, g.GetReportCache)
 		if _err != nil {
 			return _err
 		}
@@ -174,7 +185,7 @@ func (g *GroupConfigBiz) handleReport(ctx context.Context, rec *entitys.Recogniz
 		reports = append(reports, repo)
 	case "report_daily":
 		product := strings.Split(groupConfig.ProductName, ",")
-		repo, _err := rep.DailyReport(t, bbxt.DownWardValue, product, bbxt.SumFilter, nil)
+		repo, _err := rep.DailyReport(ctx, t, bbxt.DownWardValue, product, bbxt.SumFilter, nil, g.GetReportCache)
 		if _err != nil {
 			return _err
 		}
@@ -404,3 +415,47 @@ func (g *GroupConfigBiz) otherTask(ctx context.Context, rec *entitys.Recognize)
 	entitys.ResText(rec.Ch, "", rec.Match.Reasoning)
 	return
 }
+
+func (g *GroupConfigBiz) GetReportCache(ctx context.Context, day time.Time, totalDetail []*bbxt.ResellerLoss, bbxtObj *bbxt.BbxtTools) error {
+	var ResellerProductRelation map[int32]*bbxt.ResellerLossSumProductRelation
+
+	dayDate := day.Format(time.DateOnly)
+	cond := builder.NewCond()
+	cond = cond.And(builder.Eq{"index": bbxt.IndexLossSumDetail})
+	cond = cond.And(builder.Eq{"key": dayDate})
+	var cache model.AiReportDailyCache
+	err := g.reportDailyCacheImpl.GetOneBySearchToStrut(&cond, &cache)
+	if err != nil {
+		if errors.Is(sql.ErrNoRows, err) {
+			ResellerProductRelation, err = bbxtObj.GetResellerLossMannagerAndLossReasonFromApi(ctx, totalDetail)
+			if err != nil {
+				return err
+			}
+			cache = model.AiReportDailyCache{
+				Key:   dayDate,
+				Index: bbxt.IndexLossSumDetail,
+				Value: pkg.JsonStringIgonErr(ResellerProductRelation),
+			}
+			_, err = g.reportDailyCacheImpl.Add(&cache)
+		}
+	} else {
+		err = json.Unmarshal([]byte(cache.Value), &ResellerProductRelation)
+	}
+	if err != nil {
+		return err
+	}
+	for _, v := range totalDetail {
+		if _, ex := ResellerProductRelation[v.ResellerId]; !ex {
+			continue
+		}
+		v.Manager = ResellerProductRelation[v.ResellerId].AfterSaleName
+		for _, vv := range v.ProductLoss {
+			if _, ex := ResellerProductRelation[v.ResellerId].Products[vv.ProductId]; !ex {
+				continue
+			}
+			vv.LossReason = ResellerProductRelation[v.ResellerId].Products[vv.ProductId].LossReason
+		}
+	}
+
+	return nil
+}
diff --git a/internal/config/config.go b/internal/config/config.go
index 6756040..b4f05d9 100644
--- a/internal/config/config.go
+++ b/internal/config/config.go
@@ -27,6 +27,11 @@ type Config struct {
 	LLM              LLM              `mapstructure:"llm"`
 	Dingtalk         DingtalkConfig   `mapstructure:"dingtalk"`
 	Qywx             QywxConfig       `mapstructure:"qywx"`
+	ZLTX             ZLTX             `mapstructure:"zltx"`
+}
+
+type ZLTX struct {
+	ReqUrl string `mapstructure:"req_url"`
 }
 
 type SysPrompt struct {
@@ -136,6 +141,7 @@ type LSXDConfig struct {
 	LoginURL      string `mapstructure:"login_url"`
 	Phone         string `mapstructure:"phone"`
 	Password      string `mapstructure:"password"`
+	Code          string `mapstructure:"code"`
 	CheckTokenURL string `mapstructure:"check_token_url"`
 }
 
diff --git a/internal/data/impl/provider_set.go b/internal/data/impl/provider_set.go
index 916b017..c200234 100644
--- a/internal/data/impl/provider_set.go
+++ b/internal/data/impl/provider_set.go
@@ -17,4 +17,5 @@ var ProviderImpl = wire.NewSet(
 	NewBotGroupImpl,
 	NewBotGroupConfigImpl,
 	NewBotGroupQywxImpl,
+	NewReportDailyCacheImpl,
 )
diff --git a/internal/data/impl/report_dayily_cache.go b/internal/data/impl/report_dayily_cache.go
new file mode 100644
index 0000000..479d888
--- /dev/null
+++ b/internal/data/impl/report_dayily_cache.go
@@ -0,0 +1,17 @@
+package impl
+
+import (
+	"ai_scheduler/internal/data/model"
+	"ai_scheduler/tmpl/dataTemp"
+	"ai_scheduler/utils"
+)
+
+type ReportDailyCacheImpl struct {
+	dataTemp.DataTemp
+}
+
+func NewReportDailyCacheImpl(db *utils.Db) *ReportDailyCacheImpl {
+	return &ReportDailyCacheImpl{
+		DataTemp: *dataTemp.NewDataTemp(db, new(model.AiReportDailyCache)),
+	}
+}
diff --git a/internal/data/model/ai_report_daily_cache.gen.go b/internal/data/model/ai_report_daily_cache.gen.go
new file mode 100644
index 0000000..0fa1f57
--- /dev/null
+++ b/internal/data/model/ai_report_daily_cache.gen.go
@@ -0,0 +1,20 @@
+// Code generated by gorm.io/gen. DO NOT EDIT.
+// Code generated by gorm.io/gen. DO NOT EDIT.
+// Code generated by gorm.io/gen. DO NOT EDIT.
+
+package model
+
+const TableNameAiReportDailyCache = "ai_report_daily_cache"
+
+// AiReportDailyCache mapped from table <ai_report_daily_cache>
+type AiReportDailyCache struct {
+	ID    int32  `gorm:"column:id;primaryKey;autoIncrement:true" json:"id"`
+	Key   string `gorm:"column:key;not null;default:1;comment:索引方式，可以是任意类型" json:"key"` // 索引方式，可以是任意类型
+	Value string `gorm:"column:value;comment:类型下所需路由以及参数" json:"value"`                 // 类型下所需路由以及参数
+	Index string `gorm:"column:index;not null;comment:类型" json:"index"`                 // 类型
+}
+
+// TableName AiReportDailyCache's table name
+func (*AiReportDailyCache) TableName() string {
+	return TableNameAiReportDailyCache
+}
diff --git a/internal/pkg/lsxd/login.go b/internal/pkg/lsxd/login.go
index 5ea6801..13b7f1c 100644
--- a/internal/pkg/lsxd/login.go
+++ b/internal/pkg/lsxd/login.go
@@ -95,30 +95,18 @@ func (l *Login) checkTokenValid(ctx context.Context, token string) bool {
 
 // 调用登录接口获取token
 func (l *Login) login(ctx context.Context) (string, error) {
-	// 1.获取配置
-	loginURL := l.config.LSXD.LoginURL
-	phone := l.config.LSXD.Phone
-	password := l.config.LSXD.Password
-
-	// 2.调用登录接口获取token
-	if loginURL == "" {
-		return "", errors.New("login url is empty")
-	}
-	if phone == "" || password == "" {
-		return "", errors.New("phone or password is empty")
-	}
 
 	reqBody := map[string]any{
-		"phone":    phone,
-		"password": password,
-		"code":     "456789",
+		"phone":    l.config.LSXD.Phone,
+		"password": l.config.LSXD.Password,
+		"code":     l.config.LSXD.Code,
 	}
 	bodyBytes, err := json.Marshal(reqBody)
 	if err != nil {
 		return "", err
 	}
 
-	status, respBody, err := l.doRequestWithBody(ctx, http.MethodPost, loginURL, "", "application/json", bodyBytes)
+	status, respBody, err := l.doRequestWithBody(ctx, http.MethodPost, l.config.LSXD.LoginURL, "", "application/json", bodyBytes)
 	if err != nil {
 		return "", err
 	}
@@ -158,7 +146,7 @@ func (l *Login) login(ctx context.Context) (string, error) {
 }
 
 func (l *Login) getCachedToken(ctx context.Context) (string, error) {
-	token, err := l.redisCli.Get(ctx, constants.CACHE_KEY_LSXD_TOKEN).Result()
+	token, err := l.redisCli.Get(ctx, l.getCacheKey()).Result()
 	if err == nil {
 		return token, nil
 	}
@@ -168,11 +156,16 @@ func (l *Login) getCachedToken(ctx context.Context) (string, error) {
 	return "", err
 }
 
+func (l *Login) getCacheKey() string {
+	return l.config.Redis.Key + constants.CACHE_KEY_LSXD_TOKEN + l.config.LSXD.Phone // 1.获取配置
+
+}
+
 func (l *Login) cacheToken(ctx context.Context, token string) error {
 	if token == "" {
 		return errors.New("token is empty")
 	}
-	return l.redisCli.Set(ctx, constants.CACHE_KEY_LSXD_TOKEN, token, constants.EXPIRE_LSXD_TOKEN).Err()
+	return l.redisCli.Set(ctx, l.getCacheKey(), token, constants.EXPIRE_LSXD_TOKEN).Err()
 }
 
 func (l *Login) doRequest(ctx context.Context, method string, url string, authorization string, body []byte) (int, error) {
diff --git a/internal/pkg/util/map.go b/internal/pkg/util/map.go
index 5ca80c8..8bc5e1d 100644
--- a/internal/pkg/util/map.go
+++ b/internal/pkg/util/map.go
@@ -1,6 +1,10 @@
 package util
 
-import "encoding/json"
+import (
+	"encoding/json"
+	"reflect"
+	"strings"
+)
 
 // StructToMap 将结构体转换为 map[string]any
 func StructToMap(v any) (map[string]any, error) {
@@ -12,3 +16,28 @@ func StructToMap(v any) (map[string]any, error) {
 	err = json.Unmarshal(b, &m)
 	return m, err
 }
+
+func StructToMapWithReflect(obj interface{}) map[string]interface{} {
+	val := reflect.ValueOf(obj)
+	if val.Kind() == reflect.Ptr {
+		val = val.Elem()
+	}
+	if val.Kind() != reflect.Struct {
+		return nil
+	}
+
+	data := make(map[string]interface{})
+	for i := 0; i < val.NumField(); i++ {
+		valueField := val.Field(i)
+		typeField := val.Type().Field(i)
+		jsonTag := typeField.Tag.Get("json")
+		if idx := strings.Index(jsonTag, ","); idx != -1 {
+			jsonTag = jsonTag[:idx]
+		}
+		if !typeField.IsExported() {
+			continue
+		}
+		data[jsonTag] = valueField.Interface()
+	}
+	return data
+}
diff --git a/internal/tools/bbxt/api.go b/internal/tools/bbxt/api.go
index a7b057b..4dd645b 100644
--- a/internal/tools/bbxt/api.go
+++ b/internal/tools/bbxt/api.go
@@ -3,6 +3,8 @@ package bbxt
 import (
 	"ai_scheduler/internal/pkg"
 	"ai_scheduler/internal/pkg/l_request"
+	"ai_scheduler/internal/pkg/util"
+
 	"encoding/json"
 	"fmt"
 	"net/http"
@@ -29,12 +31,23 @@ type StatisOursProductLossSumResponse struct {
 }
 
 const Base = "https://reportapi.1688sup.com/api"
+const AuthUrl = "http://test.analysis.com/api"
 
 // StatisOursProductLossSumApi 负利润分析
 func StatisOursProductLossSumApi(param *StatisOursProductLossSumReq) (*StatisOursProductLossSumRes, error) {
 	url := "/dataanalytics/statisOursProductLossSum"
 	var res StatisOursProductLossSumRes
-	if err := request(url, param, &res); err != nil {
+	if err := request(url, param, &res, ""); err != nil {
+		return nil, err
+	}
+	return &res, nil
+}
+
+// StatisOursProductLossSumApi 负利润分析
+func StatisOursProductLossSumApiWithAuth(param *StatisOursProductLossSumReq, token string) (*StatisOursProductLossSumRes, error) {
+	url := "/dataanalytics/statisOursProductLossSum"
+	var res StatisOursProductLossSumRes
+	if err := request(url, param, &res, token); err != nil {
 		return nil, err
 	}
 	return &res, nil
@@ -73,7 +86,7 @@ type ProfitRankingSumResponse struct {
 func GetProfitRankingSumApi(param *GetProfitRankingSumRequest) (*GetProfitRankingSumResponse, error) {
 	url := "/dataanalytics/profitRankingSum"
 	var res GetProfitRankingSumResponse
-	if err := request(url, param, &res); err != nil {
+	if err := request(url, param, &res, ""); err != nil {
 		return nil, err
 	}
 	return &res, nil
@@ -106,7 +119,7 @@ type GetStatisOfficialProductSum struct {
 func GetStatisOfficialProductSumApi(param *GetStatisOfficialProductSumRequest) (*GetStatisOfficialProductSumResponse, error) {
 	url := "/dataanalytics/statisOfficialProduct"
 	var res GetStatisOfficialProductSumResponse
-	if err := request(url, param, &res); err != nil {
+	if err := request(url, param, &res, ""); err != nil {
 		return nil, err
 	}
 	return &res, nil
@@ -133,7 +146,7 @@ type GetStatisOfficialProductSumDecline struct {
 func GetStatisOfficialProductSumDeclineApi(param *GetStatisOfficialProductSumRequest) (*GetStatisOfficialProductSumDeclineResponse, error) {
 	url := "/dataanalytics/statisOfficialProductDecline"
 	var res GetStatisOfficialProductSumDeclineResponse
-	if err := request(url, param, &res); err != nil {
+	if err := request(url, param, &res, ""); err != nil {
 		return nil, err
 	}
 	return &res, nil
@@ -162,23 +175,119 @@ type StatisFilterOfficialProductResponse struct {
 func GetStatisFilterOfficialProductApi(param *GetStatisFilterOfficialProductRequest) (*GetStatisFilterOfficialProductResponse, error) {
 	url := "/dataanalytics/statisFilterOfficialProduct"
 	var res GetStatisFilterOfficialProductResponse
-	if err := request(url, param, &res); err != nil {
+	if err := request(url, param, &res, ""); err != nil {
 		return nil, err
 	}
 	return &res, nil
 }
 
-func request(url string, reqData interface{}, resData interface{}) error {
+//type GetManagerAndDefaultLossReasonRequest struct {
+//	ResellerId int32 ` json:"reseller_id"`
+//	GoodsIds   int32 ` json:"reseller_id"`
+//}
 
+type GetManagerAndDefaultLossReasonRequest struct {
+	Param map[int32]map[string][]int32 ` json:"param"`
+}
+
+type GetManagerAndDefaultLossReasonResponse struct {
+	Res []*GetManagerAndDefaultLossReasonResponseList `json:"res,omitempty"`
+}
+
+type GetManagerAndDefaultLossReasonResponseList struct {
+	ResellerInfo *GetManagerAndDefaultLossReasonResponse_ResellerInfo  `json:"GetManagerAndDefaultLossReasonResponse_ResellerInfo,omitempty"`
+	ProductList  []*GetManagerAndDefaultLossReasonResponse_ProductList `json:"GetManagerAndDefaultLossReasonResponse_ProductList,omitempty"`
+}
+
+type GetManagerAndDefaultLossReasonResponse_ResellerInfo struct {
+	ResellerId    int32  `json:"reseller_id,omitempty"`
+	AfterSaleName string `json:"after_sale_name,omitempty"`
+}
+
+type GetManagerAndDefaultLossReasonResponse_ProductList struct {
+	ProductId  int32  `json:"product_id,omitempty"`
+	LossReason string `json:"loss_reason,omitempty"`
+}
+
+// GetStatisFilterOfficialProductApi 官方商品列表
+func GetManagerAndDefaultLossReasonApi(param *GetManagerAndDefaultLossReasonRequest, token string, reqUrl string) ([]*GetManagerAndDefaultLossReasonResponseList, error) {
+	return []*GetManagerAndDefaultLossReasonResponseList{
+		{
+			ResellerInfo: &GetManagerAndDefaultLossReasonResponse_ResellerInfo{
+				ResellerId:    25009,
+				AfterSaleName: "张三",
+			},
+			ProductList: []*GetManagerAndDefaultLossReasonResponse_ProductList{
+				{
+					ProductId:  129,
+					LossReason: "小米钱包h5-QQ音乐绿钻季卡原因",
+				},
+				{
+					ProductId:  2218,
+					LossReason: "小米钱包h5-百度网盘新vip会员月卡原因",
+				},
+				{
+					ProductId:  3226,
+					LossReason: "小米钱包h5-腾讯视频月卡-小米钱包2024原因",
+				},
+				{
+					ProductId:  3364,
+					LossReason: "小米钱包h5-腾讯视频月卡-0元直充原因",
+				},
+			},
+		},
+	}, nil
+
+	reqParam, err := util.StructToMap(param)
+	if err != nil {
+		return nil, err
+	}
+
+	req := &l_request.Request{
+		Url:    reqUrl + "/admin/reseller/resellerAuthProduct/getManagerAndDefaultLossReason",
+		Method: http.MethodPost,
+		Json:   reqParam,
+		Headers: map[string]string{
+			"Authorization": fmt.Sprintf("Bearer %s", token),
+		},
+	}
+	res, err := req.Send()
+	if err != nil {
+		return nil, err
+	}
+	if res.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("request failed, status code: %d,resion: %s", res.StatusCode, res.Reason)
+	}
+	var code resCode
+	if err = json.Unmarshal(res.Content, &code); err != nil {
+		return nil, fmt.Errorf("返回结构异常：%s", string(res.Content))
+	}
+	var resData []*GetManagerAndDefaultLossReasonResponseList
+	if err = json.Unmarshal(code.Data, &resData); err != nil {
+		return nil, fmt.Errorf("返回数据异常：%s", string(res.Content))
+	}
+	return resData, nil
+}
+
+func request(url string, reqData interface{}, resData interface{}, token string) error {
+	requestSchema := Base
+	if len(token) > 0 {
+		requestSchema = AuthUrl
+	}
 	reqParam, err := pkg.StructToURLValues(reqData)
 	if err != nil {
 		return err
 	}
 
 	req := &l_request.Request{
-		Url:    FormatPHPURL(Base+url, reqParam),
+		Url:    FormatPHPURL(requestSchema+url, reqParam),
 		Method: http.MethodGet,
 	}
+	if len(token) > 0 {
+		req.Headers = map[string]string{
+			"Authorization": fmt.Sprintf("Bearer %s", token),
+		}
+	}
 	res, err := req.Send()
 	if err != nil {
 		return err
diff --git a/internal/tools/bbxt/bbxt.go b/internal/tools/bbxt/bbxt.go
index 304be24..926f973 100644
--- a/internal/tools/bbxt/bbxt.go
+++ b/internal/tools/bbxt/bbxt.go
@@ -3,8 +3,10 @@ package bbxt
 import (
 	"ai_scheduler/internal/config"
 	pkginner "ai_scheduler/internal/pkg"
+	"ai_scheduler/internal/pkg/lsxd"
 	"ai_scheduler/internal/pkg/utils_oss"
 	"ai_scheduler/pkg"
+	"context"
 	"fmt"
 	"math/rand"
 	"slices"
@@ -18,18 +20,17 @@ const (
 	GreenStyle = "${color: 008000;horizontal:center;vertical:center;borderColor:#000000}"
 )
 
+const (
+	IndexLossSumDetail = "lossSumDetail"
+)
+
+type LossSumInitFunc func(ctx context.Context, day time.Time, totalDetail []*ResellerLoss, selfObj *BbxtTools) error
+
 var (
 	DownWardValue int32 = 1000
 	SumFilter     int32 = -150
 )
 
-var resellerBlackList = []string{
-	"悦跑",
-	"电商-独立",
-	"蓝星严选连续包月",
-	"通钱-2025年12月",
-}
-
 var resellerBlackListProduct = []string{
 	"悦跑",
 	"电商-独立",
@@ -43,9 +44,10 @@ type BbxtTools struct {
 	excelTempDir string
 	ossClient    *utils_oss.Client
 	config       *config.Config
+	login        *lsxd.Login
 }
 
-func NewBbxtTools(config *config.Config) (*BbxtTools, error) {
+func NewBbxtTools(config *config.Config, login *lsxd.Login) (*BbxtTools, error) {
 	cache, err := pkg.GetCacheDir()
 	if err != nil {
 		return nil, err
@@ -59,12 +61,21 @@ func NewBbxtTools(config *config.Config) (*BbxtTools, error) {
 		cacheDir:     cache,
 		excelTempDir: fmt.Sprintf("%s/excel_temp", tempDir),
 		config:       config,
+		login:        login,
 	}, nil
 }
 
-func (b *BbxtTools) DailyReport(now time.Time, downWardValue int32, productName []string, sumFilter int32, ossClient *utils_oss.Client) (reports []*ReportRes, err error) {
+func (b *BbxtTools) DailyReport(
+	ctx context.Context,
+	now time.Time,
+	downWardValue int32,
+	productName []string,
+	sumFilter int32,
+	ossClient *utils_oss.Client,
+	initFunc LossSumInitFunc,
+) (reports []*ReportRes, err error) {
 	reports = make([]*ReportRes, 0, 4)
-	productLossReport, err := b.StatisOursProductLossSum(now)
+	productLossReport, err := b.StatisOursProductLossSum(ctx, now, initFunc)
 	if err != nil {
 		return
 	}
@@ -94,7 +105,7 @@ func (b *BbxtTools) DailyReport(now time.Time, downWardValue int32, productName
 }
 
 // StatisOursProductLossSum 负利润分析
-func (b *BbxtTools) StatisOursProductLossSum(now time.Time) (report []*ReportRes, err error) {
+func (b *BbxtTools) StatisOursProductLossSum(ctx context.Context, now time.Time, initFunc LossSumInitFunc) (report []*ReportRes, err error) {
 	ct := []string{
 		time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, now.Location()).Format("2006-01-02 15:04:05"),
 		adjustedTime(now), //adjustedTime(time.Date(now.Year(), now.Month(), now.Day(), 23, 59, 59, 0, now.Location())),
@@ -110,6 +121,7 @@ func (b *BbxtTools) StatisOursProductLossSum(now time.Time) (report []*ReportRes
 		resellerMap = make(map[int32]*ResellerLoss)
 		total       [][]string
 		gt          []*ResellerLoss
+		totalDetail []*ResellerLoss
 	)
 
 	for _, info := range data.List {
@@ -119,8 +131,8 @@ func (b *BbxtTools) StatisOursProductLossSum(now time.Time) (report []*ReportRes
 			resellerMap[info.ResellerId] = &ResellerLoss{
 				ResellerId:   info.ResellerId,
 				ResellerName: info.ResellerName,
-				Total:        0,                           // 初始化为0，后续累加
-				ProductLoss:  make(map[int32]ProductLoss), // 初始化map
+				Total:        0,                            // 初始化为0，后续累加
+				ProductLoss:  make(map[int32]*ProductLoss), // 初始化map
 			}
 		}
 
@@ -133,7 +145,7 @@ func (b *BbxtTools) StatisOursProductLossSum(now time.Time) (report []*ReportRes
 		// 检查产品是否已存在
 		if _, ok := reseller.ProductLoss[info.OursProductId]; !ok {
 			// 创建新的产品亏损记录
-			reseller.ProductLoss[info.OursProductId] = ProductLoss{
+			reseller.ProductLoss[info.OursProductId] = &ProductLoss{
 				ProductId:   info.OursProductId,
 				ProductName: info.OursProductName,
 				Loss:        info.Loss, // 初始化为当前产品的亏损
@@ -155,7 +167,8 @@ func (b *BbxtTools) StatisOursProductLossSum(now time.Time) (report []*ReportRes
 		return resellers[i].Total < resellers[j].Total
 	})
 	var (
-		totalSum    float64
+		totalSum float64
+
 		totalSum500 float64
 	)
 	// 构建分组
@@ -166,46 +179,116 @@ func (b *BbxtTools) StatisOursProductLossSum(now time.Time) (report []*ReportRes
 				fmt.Sprintf("%.2f", v.Total),
 			})
 			totalSum += v.Total
+			totalDetail = append(totalDetail, v)
 		}
 		if v.Total <= -500 && !slices.Contains(resellerBlackListProduct, v.ResellerName) {
 			gt = append(gt, v)
 			totalSum500 += v.Total
 		}
 	}
-	report = make([]*ReportRes, 2)
+	report = make([]*ReportRes, 3)
 	timeCh := now.Format("1月2日15点")
 	//总量生成excel
-	if len(total) > 0 {
-		filePath := b.cacheDir + "/kshj_total" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
-		err = b.SimpleFillExcelWithTitle(b.excelTempDir+"/"+"kshj_total.xlsx", filePath, total, "")
-		report[0] = &ReportRes{
-			ReportName: "负利润分析(合计表)",
-			Title:      "截至" + timeCh + "利润累计亏损" + fmt.Sprintf("%.2f", totalSum),
-			Path:       filePath,
-			Data:       total,
-		}
-	}
+	//if len(total) > 0 {
+	//	filePath := b.cacheDir + "/kshj_total" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
+	//	err = b.SimpleFillExcelWithTitle(b.excelTempDir+"/"+"kshj_total.xlsx", filePath, total, "")
+	//	if err != nil {
+	//		return
+	//	}
+	//	report[0] = &ReportRes{
+	//		ReportName: "分销商负利润统计",
+	//		Title:      "截至" + timeCh + "利润累计亏损" + fmt.Sprintf("%.2f", totalSum),
+	//		Path:       filePath,
+	//		Data:       total,
+	//	}
+	//}
 
-	if err != nil {
-		return
-	}
-	if len(gt) > 0 {
-		filePath := b.cacheDir + "/kshj_gt" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
-		title := "截至" + timeCh + "亏损500以上的分销商和产品"
-		err = b.resellerDetailFillExcelV2(b.excelTempDir+"/"+"kshj_gt.xlsx", filePath, gt, title)
-		report[1] = &ReportRes{
-			ReportName: "负利润分析(亏损500以上)",
-			Title:      "截至" + timeCh + "亏损500以上利润累计亏损" + fmt.Sprintf("%.2f", totalSum500),
+	//if len(gt) > 0 {
+	//	filePath := b.cacheDir + "/kshj_gt" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
+	//	title := "截至" + timeCh + "亏损500以上的分销商和产品"
+	//	err = b.resellerDetailFillExcelV2(b.excelTempDir+"/"+"kshj_gt.xlsx", filePath, gt, title)
+	//	if err != nil {
+	//		return
+	//	}
+	//	report[1] = &ReportRes{
+	//		ReportName: "负利润分析(亏损500以上)",
+	//		Title:      "截至" + timeCh + "亏损500以上利润累计亏损" + fmt.Sprintf("%.2f", totalSum500),
+	//		Path:       filePath,
+	//		Data:       total,
+	//	}
+	//}
+
+	if len(totalDetail) > 0 {
+		err = initFunc(ctx, now, totalDetail, b)
+		if err != nil {
+			return
+		}
+		filePath := b.cacheDir + "/kshj_total_ana" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
+		title := "截至" + timeCh + "亏损100以上的分销商&产品负利润原因"
+		err = b.resellerDetailFillExcelAna(b.excelTempDir+"/"+"kshj_total_ana.xlsx", filePath, totalDetail, title)
+		if err != nil {
+			return
+		}
+		report[2] = &ReportRes{
+			ReportName: "负利润分析(亏损100以上)",
+			Title:      "截至" + timeCh + "亏损100以上利润原因",
 			Path:       filePath,
 			Data:       total,
 		}
 	}
-	if err != nil {
-		return
-	}
 	return report, nil
 }
 
+func (b *BbxtTools) GetResellerLossMannagerAndLossReasonFromApi(ctx context.Context, resellerLoss []*ResellerLoss) (map[int32]*ResellerLossSumProductRelation, error) {
+	var (
+		resellerMap     = make(map[int32]map[string][]int32)
+		resellerLossMap = make(map[int32]*ResellerLoss, len(resellerLoss))
+		relationMap     = make(map[int32]*ResellerLossSumProductRelation)
+	)
+
+	for _, v := range resellerLoss {
+		var productSlice = make([]int32, 0, len(v.ProductLoss))
+		for _, vv := range v.ProductLoss {
+			productSlice = append(productSlice, vv.ProductId)
+		}
+		if _, ex := resellerMap[v.ResellerId]; !ex {
+			resellerMap[v.ResellerId] = make(map[string][]int32, 1)
+		}
+		resellerMap[v.ResellerId]["values"] = productSlice
+		resellerLossMap[v.ResellerId] = v
+		relationMap[v.ResellerId] = &ResellerLossSumProductRelation{
+			ResellerName: v.ResellerName,
+			Products:     make(map[int32]*LossReason, len(v.ProductLoss)),
+		}
+		for _, product := range v.ProductLoss {
+			relationMap[v.ResellerId].Products[product.ProductId] = &LossReason{
+				ProductName: product.ProductName,
+				LossReason:  "未填写", // 初始化为未填写
+			}
+		}
+	}
+	res, err := GetManagerAndDefaultLossReasonApi(&GetManagerAndDefaultLossReasonRequest{
+		Param: resellerMap,
+	}, b.login.GetToken(ctx), b.config.ZLTX.ReqUrl)
+	if err != nil {
+		return nil, err
+	}
+	for _, v := range res {
+		if v == nil {
+			continue
+		}
+		if _, ok := resellerLossMap[v.ResellerInfo.ResellerId]; !ok {
+			continue
+		}
+		relationMap[v.ResellerInfo.ResellerId].AfterSaleName = v.ResellerInfo.AfterSaleName
+
+		for _, vv := range v.ProductList {
+			relationMap[v.ResellerInfo.ResellerId].Products[vv.ProductId].LossReason = vv.LossReason
+		}
+	}
+	return relationMap, nil
+}
+
 // GetProfitRankingSum 利润同比分销商排行榜
 func (b *BbxtTools) GetProfitRankingSum(now time.Time) (report *ReportRes, err error) {
 
diff --git a/internal/tools/bbxt/bbxt_test.go b/internal/tools/bbxt/bbxt_test.go
index ee7f5da..1ea8f43 100644
--- a/internal/tools/bbxt/bbxt_test.go
+++ b/internal/tools/bbxt/bbxt_test.go
@@ -2,10 +2,19 @@ package bbxt
 
 import (
 	"ai_scheduler/internal/config"
+	"ai_scheduler/internal/data/impl"
+	"ai_scheduler/internal/data/model"
+	"ai_scheduler/internal/pkg"
+	"ai_scheduler/internal/pkg/lsxd"
 	"ai_scheduler/internal/pkg/utils_oss"
+	"ai_scheduler/utils"
+	"context"
+	"encoding/json"
 	"strings"
 	"testing"
 	"time"
+
+	"xorm.io/builder"
 )
 
 func Test_StatisOursProductLossSumApiTotal(t *testing.T) {
@@ -23,29 +32,30 @@ func Test_StatisOursProductLossSumApiTotal(t *testing.T) {
 	if err != nil {
 		panic(err)
 	}
-	o, err := NewBbxtTools(nil)
+	o, err := NewBbxtTools(nil, nil)
 	if err != nil {
 		panic(err)
 	}
-	reports, err := o.DailyReport(time.Now(), DownWardValue, []string{"官方-爱奇艺-星钻季卡", "官方-爱奇艺-星钻半年卡", "官方--腾讯-年卡", "官方--爱奇艺-月卡"}, SumFilter, ossClient)
+	reports, err := o.DailyReport(context.Background(), time.Now(), DownWardValue, []string{"官方-爱奇艺-星钻季卡", "官方-爱奇艺-星钻半年卡", "官方--腾讯-年卡", "官方--爱奇艺-月卡"}, SumFilter, ossClient, GetReportCache)
 
 	t.Log(reports, err)
 
 }
 
 func Test_StatisOursProductLossSum(t *testing.T) {
-	o, err := NewBbxtTools(nil)
+	run()
+	o, err := NewBbxtTools(configConfig, lsxd.NewLogin(configConfig, utils.NewRdb(configConfig)))
 	if err != nil {
 		panic(err)
 	}
-	report, err := o.StatisOursProductLossSum(time.Now())
+	report, err := o.StatisOursProductLossSum(context.Background(), time.Now(), GetReportCache)
 
 	t.Log(report, err)
 
 }
 
 func Test_GetProfitRankingSum(t *testing.T) {
-	o, err := NewBbxtTools(nil)
+	o, err := NewBbxtTools(nil, nil)
 	if err != nil {
 		panic(err)
 	}
@@ -56,7 +66,7 @@ func Test_GetProfitRankingSum(t *testing.T) {
 }
 
 func Test_GetStatisOfficialProductSumDecline(t *testing.T) {
-	o, err := NewBbxtTools(nil)
+	o, err := NewBbxtTools(nil, nil)
 	if err != nil {
 		panic(err)
 	}
@@ -69,7 +79,9 @@ func Test_GetStatisOfficialProductSumDecline(t *testing.T) {
 }
 
 func Test_GetStatisOfficialProductSum(t *testing.T) {
-	o, err := NewBbxtTools(nil)
+
+	configs := configConfig
+	o, err := NewBbxtTools(nil, lsxd.NewLogin(configs, utils.NewRdb(configConfig)))
 	if err != nil {
 		panic(err)
 	}
@@ -79,3 +91,62 @@ func Test_GetStatisOfficialProductSum(t *testing.T) {
 	t.Log(report, err)
 
 }
+
+var (
+	reportDailyCacheImpl *impl.ReportDailyCacheImpl
+	configConfig         *config.Config
+)
+
+func run() {
+	configConfig, _ = config.LoadConfigWithTest()
+	// 初始化数据库连接
+	db, _ := utils.NewGormDb(configConfig)
+	reportDailyCacheImpl = impl.NewReportDailyCacheImpl(db)
+}
+
+func GetReportCache(ctx context.Context, day time.Time, totalDetail []*ResellerLoss, bbxtObj *BbxtTools) error {
+	run()
+
+	var ResellerProductRelation map[int32]*ResellerLossSumProductRelation
+	dayDate := day.Format(time.DateOnly)
+	cond := builder.NewCond()
+	cond = cond.And(builder.Eq{"`index`": IndexLossSumDetail})
+	cond = cond.And(builder.Eq{"`key`": dayDate})
+	var cache model.AiReportDailyCache
+
+	err := reportDailyCacheImpl.GetOneBySearchToStrut(&cond, &cache)
+	if err != nil {
+		return err
+	}
+	if cache.Value == "" {
+		ResellerProductRelation, err = bbxtObj.GetResellerLossMannagerAndLossReasonFromApi(ctx, totalDetail)
+		if err != nil {
+			return err
+		}
+		cache = model.AiReportDailyCache{
+			Key:   dayDate,
+			Index: IndexLossSumDetail,
+			Value: pkg.JsonStringIgonErr(ResellerProductRelation),
+		}
+		_, err = reportDailyCacheImpl.Add(&cache)
+		if err != nil {
+			return err
+		}
+	}
+	err = json.Unmarshal([]byte(cache.Value), &ResellerProductRelation)
+
+	for _, v := range totalDetail {
+		if _, ex := ResellerProductRelation[v.ResellerId]; !ex {
+			continue
+		}
+		v.Manager = ResellerProductRelation[v.ResellerId].AfterSaleName
+		for _, vv := range v.ProductLoss {
+			if _, ex := ResellerProductRelation[v.ResellerId].Products[vv.ProductId]; !ex {
+				continue
+			}
+			vv.LossReason = ResellerProductRelation[v.ResellerId].Products[vv.ProductId].LossReason
+		}
+	}
+
+	return nil
+}
diff --git a/internal/tools/bbxt/entitys.go b/internal/tools/bbxt/entitys.go
index 7729d68..904f541 100644
--- a/internal/tools/bbxt/entitys.go
+++ b/internal/tools/bbxt/entitys.go
@@ -4,13 +4,15 @@ type ResellerLoss struct {
 	ResellerId   int32
 	ResellerName string
 	Total        float64
-	ProductLoss  map[int32]ProductLoss
+	ProductLoss  map[int32]*ProductLoss
+	Manager      string
 }
 
 type ProductLoss struct {
 	ProductId   int32
 	ProductName string
 	Loss        float64
+	LossReason  string
 }
 
 type ReportRes struct {
@@ -37,3 +39,14 @@ type ProductSumReseller struct {
 	HistoryTwoNum  int32 //上周成功数量
 	HistoryTwoDiff int32 //同比上周当前增减量
 }
+
+type ResellerLossSumProductRelation struct {
+	AfterSaleName string `json:"after_sale_name"`
+	ResellerName  string `json:"reseller_name"`
+	Products      map[int32]*LossReason
+}
+
+type LossReason struct {
+	ProductName string
+	LossReason  string
+}
diff --git a/internal/tools/bbxt/excel.go b/internal/tools/bbxt/excel.go
index 1744f76..91915dc 100644
--- a/internal/tools/bbxt/excel.go
+++ b/internal/tools/bbxt/excel.go
@@ -242,7 +242,7 @@ func (b *BbxtTools) resellerDetailFillExcelV2(templatePath, outputPath string, d
 
 	for _, reseller := range dataSlice {
 		// 排序 ProductLoss
-		var products []ProductLoss
+		var products []*ProductLoss
 		for _, p := range reseller.ProductLoss {
 			products = append(products, p)
 		}
@@ -311,4 +311,164 @@ func (b *BbxtTools) resellerDetailFillExcelV2(templatePath, outputPath string, d
 	return f.SaveAs(outputPath)
 }
 
-// OfficialProductSumDeclineExcel
+func (b *BbxtTools) resellerDetailFillExcelAna(templatePath, outputPath string, dataSlice []*ResellerLoss, title string) error {
+	// 1. 读取模板
+	f, err := excelize.OpenFile(templatePath)
+	if err != nil {
+		return err
+	}
+	defer f.Close()
+
+	sheet := f.GetSheetName(0)
+	if len(title) > 0 {
+		// 写入标题
+		f.SetCellValue(sheet, "A1", title)
+	}
+	// ---------------- 样式获取 ----------------
+	// 模板第2行：数据行样式
+	tplRowData := 3
+	styleA3, err := f.GetCellStyle(sheet, fmt.Sprintf("A%d", tplRowData))
+	if err != nil {
+		styleA3 = 0
+	}
+	// B2和C2通常样式一致，这里取B2作为明细列样式
+	styleB3, err := f.GetCellStyle(sheet, fmt.Sprintf("B%d", tplRowData))
+	if err != nil {
+		styleB3 = 0
+	}
+	styleC3, err := f.GetCellStyle(sheet, fmt.Sprintf("C%d", tplRowData))
+	if err != nil {
+		styleC3 = 0
+	}
+
+	styleD3, err := f.GetCellStyle(sheet, fmt.Sprintf("D%d", tplRowData))
+	if err != nil {
+		styleC3 = 0
+	}
+
+	styleE3, err := f.GetCellStyle(sheet, fmt.Sprintf("E%d", tplRowData))
+	if err != nil {
+		styleC3 = 0
+	}
+
+	rowHeightData, err := f.GetRowHeight(sheet, tplRowData)
+	if err != nil {
+		rowHeightData = 20
+	}
+
+	// 模板第4行：合计行样式
+	tplRowTotal := 5
+	styleTotalA, err := f.GetCellStyle(sheet, fmt.Sprintf("A%d", tplRowTotal))
+	if err != nil {
+		styleTotalA = 0
+	}
+	styleTotalB, err := f.GetCellStyle(sheet, fmt.Sprintf("B%d", tplRowTotal))
+	if err != nil {
+		styleTotalB = 0
+	}
+	styleTotalC, err := f.GetCellStyle(sheet, fmt.Sprintf("C%d", tplRowTotal))
+	if err != nil {
+		styleTotalC = 0
+	}
+	styleTotalD, err := f.GetCellStyle(sheet, fmt.Sprintf("D%d", tplRowTotal))
+	if err != nil {
+		styleTotalC = 0
+	}
+	styleTotalE, err := f.GetCellStyle(sheet, fmt.Sprintf("E%d", tplRowTotal))
+	if err != nil {
+		styleTotalC = 0
+	}
+	rowHeightTotal, err := f.GetRowHeight(sheet, tplRowTotal)
+	if err != nil {
+		rowHeightTotal = 30
+	}
+	// ----------------------------------------
+
+	currentRow := 3
+	totalLoss := 0.0
+
+	for _, reseller := range dataSlice {
+		// 排序 ProductLoss
+		var products []*ProductLoss
+		for _, p := range reseller.ProductLoss {
+			products = append(products, p)
+		}
+		sort.Slice(products, func(i, j int) bool {
+			return products[i].Loss < products[j].Loss
+		})
+
+		startRow := currentRow
+
+		// 填充该经销商的所有产品
+		for _, p := range products {
+			// 设置行高
+			f.SetRowHeight(sheet, currentRow, rowHeightData)
+
+			// 设置值
+			f.SetCellValue(sheet, fmt.Sprintf("A%d", currentRow), reseller.ResellerName)
+			f.SetCellValue(sheet, fmt.Sprintf("B%d", currentRow), p.ProductName)
+			f.SetCellValue(sheet, fmt.Sprintf("C%d", currentRow), p.Loss)
+			f.SetCellValue(sheet, fmt.Sprintf("D%d", currentRow), reseller.Manager)
+			f.SetCellValue(sheet, fmt.Sprintf("E%d", currentRow), p.LossReason)
+			// 设置样式
+			if styleA3 != 0 {
+				f.SetCellStyle(sheet, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("A%d", currentRow), styleA3)
+			}
+			if styleB3 != 0 {
+				f.SetCellStyle(sheet, fmt.Sprintf("B%d", currentRow), fmt.Sprintf("B%d", currentRow), styleB3)
+			}
+			if styleC3 != 0 {
+				f.SetCellStyle(sheet, fmt.Sprintf("C%d", currentRow), fmt.Sprintf("C%d", currentRow), styleC3)
+			}
+			if styleD3 != 0 {
+				f.SetCellStyle(sheet, fmt.Sprintf("D%d", currentRow), fmt.Sprintf("D%d", currentRow), styleD3)
+			}
+			if styleE3 != 0 {
+				f.SetCellStyle(sheet, fmt.Sprintf("E%d", currentRow), fmt.Sprintf("E%d", currentRow), styleE3)
+			}
+
+			totalLoss += p.Loss
+			currentRow++
+		}
+
+		endRow := currentRow - 1
+		// 合并单元格 (如果多于1行)
+		if endRow > startRow {
+			f.MergeCell(sheet, fmt.Sprintf("A%d", startRow), fmt.Sprintf("A%d", endRow))
+			f.MergeCell(sheet, fmt.Sprintf("D%d", startRow), fmt.Sprintf("D%d", endRow))
+		}
+	}
+
+	// ---------------- 填充合计行 ----------------
+	// 四舍五入保留四位小数
+	totalLoss, _ = decimal.NewFromFloat(totalLoss).Round(4).Float64()
+	// 设置行高
+	f.SetRowHeight(sheet, currentRow, rowHeightTotal)
+
+	f.SetCellValue(sheet, fmt.Sprintf("A%d", currentRow), "合计")
+	// B列留空，C列填充总亏损
+	f.SetCellValue(sheet, fmt.Sprintf("C%d", currentRow), totalLoss)
+
+	// 设置合计行样式
+	if styleTotalA != 0 {
+		f.SetCellStyle(sheet, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("A%d", currentRow), styleTotalA)
+	}
+	if styleTotalB != 0 {
+		f.SetCellStyle(sheet, fmt.Sprintf("B%d", currentRow), fmt.Sprintf("B%d", currentRow), styleTotalB)
+	}
+	if styleTotalC != 0 {
+		f.SetCellStyle(sheet, fmt.Sprintf("C%d", currentRow), fmt.Sprintf("C%d", currentRow), styleTotalC)
+	}
+	if styleTotalD != 0 {
+		f.SetCellStyle(sheet, fmt.Sprintf("D%d", currentRow), fmt.Sprintf("D%d", currentRow), styleTotalD)
+	}
+	if styleTotalE != 0 {
+		f.SetCellStyle(sheet, fmt.Sprintf("E%d", currentRow), fmt.Sprintf("E%d", currentRow), styleTotalE)
+	}
+
+	// 取消合并合计行的A、B列
+	// f.MergeCell(sheet, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("B%d", currentRow))
+
+	// 6. 保存
+	return f.SaveAs(outputPath)
+}
diff --git a/tmpl/excel_temp/kshj_total_ana.xlsx b/tmpl/excel_temp/kshj_total_ana.xlsx
new file mode 100644
index 0000000000000000000000000000000000000000..d2774f36304f5afde22664eb808ace7d75651753
GIT binary patch
literal 10304
zcma)iWk4KT5-#pCxVyW%yIXJx?(P!YCAbF<!QF#HfZ%SyJ-E9BcyP13xyjzQ@0}mh
zGu<Vpzv@$Sy6RJu0R@8rdL5zi8-lOLe-G%FFUEF8ijH>nP7I1KVyG`Cp#BnT;h3*v
z1O@_P1pxvA{9Vkz-k#pw#yT_Zi!>+`s@P4yGoZ$fg^u_QGgUws52Th09*f;Vrz~>(
z&iFkYy))4*r0u1h$`3del=0$5M>oCW@9h^**>-7Zb!&kQ<b??i;?S5TGB#>lZ5mn8
z(Uj1Xa#U7UgoWBr&h*ze?(5~CG1wsCXyjYYQM;y*;PoNmAr5tN&eR7u;SQHHrlry}
zoYngUz=76jCZTZbPz6DbTkWtGmKpW8tCN!@(F{8DpXotheGYZXlX~3q8>!K^F4p%p
zpMq=Gc?3Y`m)}Yr1+LMJYAKrYLEp3M^5<`9LF{5XEl5}9f0<kQIyru@0Diggcz1Sm
zMNhv@d%stn(!HyA0Lruns&oj^63~Mb^|mX&7rV<tRWimGNFk(?PoztZ^F13-L8eIi
z(?;W-I>*DE?HTy*=n9zWoGZMbYx{yO(%;cFvU4<fh1WY?PobL-_3NtK4+QuVx^eEe
zl8avj<`ZOOGbV1u*KA497l0Oy7G)O8T_<j#c9sZsmSP#Mn<LsgxmD9aCW3OHB8&2w
z7eU&}QqFM2Mx97JRB<TBfpN7GQ!tv$Q;X<$=bM2K&>AUYBaL#Y#z!AQ3=Vq`Sly)T
zQweP?OPdfSTE4<#5O~3Il5JsIo$5G_IY36H$Av{pQi&U1Sd`)uf``DcVxBO{Q9hl$
zt6F&E8mB=iRC^i^lJ9F&Za@v>Y`&3?>TR$|U_USl`hnU}j-UNdQq8<v0hYs@5&#Xm
z^sS*aNek<H>ybQH7UeQJ&G8RvTCY!nD|pf$%ZmJT;||I5joHV}>=gWN-iBZZiWA}C
zG-o7!JA5)|6E%^Z)Rdj#B(aKT<~9pzbwe86ZmH`I=7+e;cE>}(o+=|L2r}6VatBHD
zKE5D$;{*CT`cZnHgT-FZ4|+i#<u~+QoSf}!Uh%JwACT{61PGo;{t(&n+#r)$RFNv7
zjSk}U%ejmo?z5mHb4BF|hB-TFOsvrnTIx-kNax53S0D4<IlL<hj)(5V2SG@YWfQhV
zIjyQ#0=KU#Hc@tyJ_o~Xgebi{CvL}^>69R8bfp#E2Rn?!N(NXqY<idTr6;pbl~h+o
zc}Hs(EvPZ-QnO#_U`qnhgxD=Uy>q+m@kg<1;^+`#kH9;+H1)<Tv&Hu9M3i5|nIK)u
zhkIWGr?iWVjYcod=|&=u)?)4t7?4sD!}10nwWlTTjB~M*=%8j#uICuCb)Phqt<?-?
zW<~T;nef|~&xMkau8mNct{ms}?eT%@7&LO9z5NvHi{9McQSHQz!g5F2Y}(yN-~$%i
z^R=f|=1S7<$C{pXK&_mToAth>5#pZh{;iZ47?qEmRp1E$Pz)@0rouhME9(E8ctBrJ
zcenm4<@~b%!cPG=J4Y)ga}yKiKhqO~;AkuFi<KQHARx^DlKo4C={1f?Y6G^5jDR+b
zT>+?8iPDt0D%_srKy-8eoP!U^=ILRiC8Rd_zN<u36Iub}O&S}gBb({LB$dZm@0XeY
z^prG4sEz!Nk{@a!llw3qf1KGny~ibT_^_UlL@MqZF6ed;L!idCsjwj$=Ir+om5EzQ
zla5azkK&E~dQC)Pm6LvJCvx(S-S7yM42weI8{yS#5AXsqW;mHAbOcw<@kCNuK8(D?
zke~!ynQ;dBI%K*<r)%=|$W3fRn=5Bha?`$Z@PxSbfPxHY*I3&@m@!EliKbKZHqQ6X
zqL;!oFvHoSGw=X)z*5$>%G1nxLqJ&T`LxT?Y?A#{jnagaBI8ZiQdY3BSOA&$K~hC0
z$<1tOq%gYb9-ce`Q!`?6i++T@h=`BUoA;wFBxg@N15(sd5N!dtGoYTmS*WKhsa|3g
zz!AuW@w)xVTON_|Kx-Q@{9<k0NLhTJ9#*n$avrwhc(AzEoajH(KFhIqL`;CxH`tXu
ziSC|}3dwHC$90b~7n0ox)00AmV#-YmQ4RT{`D6x^;7iE+XGi&TW8NRrg59W46myAN
z)yW%df{iV3%6Z?QWfz_Kn{A@VFWo(lePHE3wf4$Y9|IQ01MuQxho6Wu5Nv%g-kmPB
z)u`kw#cQOBMN8^~I_{7P9HE^q@7fQ59HN@$P~G)Zl{*6C2PsRb?>MJd?5`8Dh9jN^
zSEOJ3NQ8y$+6&m*2GUf+A${aq076(G3{=x*9A_5~^6qhs47(3Aj!eBoYGE?8MAGHp
zHwU2U-S#el;%)?5F5a3ZtE-zC0csHpS0t>pgG!c0hTCAKz{2OV+@Ne9z<2`vVgk{s
ztHN~c6+>^pAnoxonm?D=u=kEfkzv*?Gz9PJcS)_un{``a^>?{$j$(pHHo+4%Hb^mm
z^j~@s12r~dj}NPF3whdL%kH>p$e{F;AH)PyrLuFiROA<872Ll6*5I(a#KaOZLQ4rH
zu<uWok(ennPVi;9VRlqPn9R{UCi&*w3c{gOoowB5Ee>NejTfmNlfdK~PA;xarS`0-
zrD3Pq*s@6x(=k%7w#x(PCn3Nttlr22s8P*ZKf>CZoT#eHL%qZ+f&csRecd;_EMI4H
z6C0C1_6<Sz4{*2OKtSy;tMWCs{zvRD;lI}8k>*GY4jXC*$(cap_R2BoNT2JBb^YDG
zu-l?)Lc{)qR7NDun7c7g%LshE1SzSgkWOr)gP>r(+Qyrwv|wV&H_zZ%M*}_bxVh*-
zIhOJ)S*xBt1RXa&;%L+fNLe|*>Hw12yC%O<!r5~hlf=touOIo`blGA;g-;^o(teGy
zj}~)xd49a9$l=4<1cM~Zj^LYyGNP(&%fw>}G9aa|fh#<<8FmjKZ9N|t4g170o<5%G
zh&tnnEIP?3sRUwql6Bej7(9vq{<Rp@QeV<T!J>zzbD}Pf|9z9W5`G5p0+i5ASmxCk
zC>8`NG&BLWL7wmW=u;A2T?(vHlhADZ!M+}S3T$M72_Ho^T!a)&l4ZWD;_f#f>TeF2
z?+Ry&(e7D+;6v96s=rP&X;;>zam|8!kcc@RwQX8*IZb|&v0`@{8VM{qTx09stt?wV
zm@#eH*kJ2lE48|nQKGR_!+pdyKCNf-D%7%2<w4L5G?bp)!{&|{te0n#z=&n~6sqgq
zro4||=X8q<ZcSN~Uw~Pw@-93%=ONN<y;N9<R0_M_Bc#t9s?LT;8X^Ns!WdbG4RWEo
z|K2tv#Lz}k4kL_+;)8V%fhiP>LGjhh#fdJTFLvv@r>!6BwHKiRSpx5zpH3k^4I%N0
z?)9L1-HjCbdR-}<K1@~W@joraV6Z=>oCrMK6^{K7q|D71V`z6jKd7Z(X#cVG*^a<-
z4H6gL+C7_81B~NT)BZi#S~^0c6&L>Lw}jokFivDjh-Lg4JS?7094ArlMsn9cw@{Ji
zQ{c*xW1fa<L;i#wmWwM+2fx0^3G&SqARTolO{C+o$#7ps{#u960Pd@iW#Qt4g;CnT
z3MnsYZ6?=Y-j9??<^jsIpjT0HOxNyiF#w8+KI8rm`bJnwBtj@ic9QqTYXA!>XG!G#
zp(QiIyoK<Qv&@`<qOk*ZewR2!K-jy;6Qlj0Gwd{}#9NhXCE+7K0wS!3$itDl@m`mp
zAXx=Q6Ctyp;M0Mnt+mRe%Y$+L9~J@y7d>K*QU&~(5@Ad@^QKd3k@3T!M{%qT)dXQw
zim2ceviEC!!{vZ01P{TzUguS!IjNg#aeEx@LYv8W!u_F0Pe%`Ume7tiE<BR57C2{@
zLOlx7<%QM}xRV7}65h2QZQf9tk#{J^zH_;Y=E+(5MG;qI`)@;izJ2We+%95Q^4+(c
zfkB(e*`gkcb<w8nPX34I3Dd_qiXBt}=(b1ns{6=h#-gB0AruVAYT6J9)!v-tFLIpJ
z#^l7`SdoN!!Eh0~qe`YBxn*pl`?lRROVmG^Gx_t!cLlv`4(BhXS4kcYclxAjlp7B$
z0~@GM0_eQ{h?IOFjxP@xwh_n7lv4Frm8~~b=pF)_O`lk5kNO<bm~UPkZ=bfXS7>1m
z;f6{rY``e0NrKz$4~L%sw?R5>3O)g?V+2RW;o*(aZmiSKj$A#^ToA8`hfK_bNGXNA
zUNI0S1t-U*x<bAABtO9kR%-4;$Eh=Y*rCWlrm)<qWb2<ok9g)D89HfNz?R#nuX~}^
zZ7P_q%gYT5;oNISlw(OnJ%bu5A=-J?feoBF4XdNBO5<_G5RPk4eu9j3W0?3QsXIA3
z*c_ci<ZY^<hzSPy9;?P|K&h^JU8Pl)18)HUs*x**rVI3YSQ_9MQR38*%9mHkM$NPS
z^mAE;&XxKw&U$dG%eE@7pVM5)Nx{a-+(y@#34O`cn|evHJx60*T?(}8nal_v&O%`m
zGmrqKL_hz7evEDFp}_Q%42{5WEf^bY?gL#Vs}OjcZ+%C?gE);h@!}IENv2as;PHLd
z#vwBAmItjWQnh)uhpTpJX^QFgQqhLi4Vjj^T!%`;!VIoHmosO8Ep)m^igVrwvDt5e
z(w@l>5YLpi@;6$wPLw3kyMnkTs)ICS3^U1TwnF8ZEI3ZH*{l=Ve}S*GT4*@xlP0x<
zt*3E#IIsbpQ_L%wYeH?ax)=rDQqzPL+5CE~P%HLauKx_)332mrsBV4GMLeGoPcZQM
z8SM8>IRD%wjLFL;oato~{`%Va@<-uhZs2HQtnBP)VQc2}x_h&U8<Fo4L=C<nZx>;q
zc`FDjY9y<TPR{SoF9=G)`cc^!;u8-mFbr5QRD>`XMiC_w<`1FH&wH}#bht!J1&ysc
zEjt-YI$ZANJwc$Uoz3B>YZuajew4-`E~rYK$D<8qpirsilx1IK!O-l%n4n6AWSDzJ
z*K~u>0A!@?R1uu0!66}SrntoN*TX>{k@(4piK8iU(0i4j!jVuO<Ll_L)1v(V%n4zq
zD?osF$yJ4}ay_A>>WV>8li5wu#hdDo?`A1Seop6H9yV`EyH`$%k_<TV(LCLIBSzSy
zY9wqtWA&26atAkJJhM8#6(pgSo1zP{iHyZq6z?wGEJe=XyW`13ZSUC*Pnkc>mXEsa
zStQJA+it6@G!AT{HjgTQf!`A|TG*=*w$)OYieWvvIXq*d`*u51*QhAcN9P%<-Jd#h
zzf@z?Hty;gkHf95H)Va-(fDEFgncre&Esi`?mVS*_4lw`s-lQ}e+df`7!VNRuZ^{#
zot@QdM52_H?9v$lKG}88`geRxvE#v%ioxXONogh0wa%VtxSRp1RdGj=vQtkF)=+x|
zawrOY-cQH1CoM(}o)yxU@Og#-p>udVn7|5Ry|+v~*{%cTA#sz5W_75z!awj(+oM)G
zv{{AQ@q^sO#QjPE7+T+)gjKWz#bz|7J4dAGjm7GvzQ+}5fsCjC=aj~~M>~m74{{!(
zZaapB^gAVYN#_;9G#-nRCaR?Glm^U{s1G3=iK&l3AZ!+>Z6=~rxn#-EqvFyzs&%zr
z08KRe<R$H0>KLlL$^V8m6&vhs_-3LLXU&LI!Ntokp9`KmI#kNJ{<~CK&wZ`gcoD}^
zL6HG3$_VU`Gm@blyHn%=-Zj!(^|&b@Yv(~N=10MVt8v{znES(^nN^{csqto;N7!Am
zlPUj}_jUt}x2E*ar4%uamf;$=u0EFiETZ&hq)bxSvzWQ;ucM@=;!{0x;>sNM;tpOc
zcz3178@~4HZdL+!^V;4G5qC3tKA_ae(jP@D`ihGrIT|}$J2T@Nu#5PmYPBYEmD9CZ
zn{w0{PyA#Ke03OCE39c!_MefmM=VnqV>1pRkx%eBT1EtqyWibhkzq;e+HTA^a{4wc
z({~)sW<SvM3&4|^ZksmU4<tO<Mf(8%{zTZW`I@G}0|5bB0|C7p{#vNc9@Zv*t<dGS
zRxvp0SWnSCzL;DAh)`y{n`b5sEjX@iJa6)$#7GHA1>+btmywKOc<>8b#F9WPpise!
zVE{$cN?O6E{<MmKs0H#zmg?Gv@QzN;QJqmwUNidnw~MtS(q}I}d`BOd57ZGL8k~om
z`;u9fD5+9t$Odp-Gqc#17Ad`-LzHZj^Qyn$UoSMUuyRO;ZZ|rcTpZ|W6L^L;czCa}
z@<D6B_2J}ukKvRLoHw@EAuMbTjrQYqrMGV)EZ{FSd!D;*r5&xL0^qGR%T@Nzb8O&c
z_(SW3I1m$r79aPFRgSp>l@@EclWjag6V;`#oxka>;&9ux7zLI<R^U5^3}GJl&$wh(
zPu<Xi(#-GOlviL)DHab^cnlG*Ovt1kbPsf5x*HWA$cC(lOTEXJdP@K1d8$Yy)jmO2
z2x+;L*iQEL{yJYKDSgsv>%Py#>t=+5Jo-j!{`n(SyOT2Yz(>kq^~{|El*f}Hi6?M$
z6wl!NUfp{{M=GUEb>i4}P0VHlo}CUIj%3S{Hd(&1n)_|Bo`*L2W*ZNvCR>Ef=?C6s
z{Q+gOgo9fH+xNG0duodz*154zE_jO$WQgMkN(BlbNB(<-srZlEUuz**XM7g%M99ye
zOR+t~Yb9eH^?~&VMCMc0pI3>Bg)I_864Z#mWETc@PVyyXOv{kj`HkEvYn7M-e0gu2
zwK<RD2E%ISger3!dlI!q?hHl`DmxRM>@&{x@OZz(iEu*W>iGMH#0`B>3AHXVhO!Rm
z+|J;FMjD}FjF4F3?k2p>EOgPyNDE?t^s}VblwPqm%ZIEqi0#lJcDj#escbO6;Ix=_
zdGAb40dGJ?2^i&arYb7KR{f+zF=`^VJzpajZy`iZ0aE(D8~WTt!`hC`6+QI?48%gt
zA&XuvJiD6ppvPrqzAD}jlhrTj0$w|Uu?<}8qG>xo#o%gTgATUKr2;Lwzvv<u+=eOY
zqnyRO>vWPI_MmS~6T&j~m~$vZYjVH=PAG}F5yD4E@tO=-N*3jlrXvw>?8+wS-e{Yv
zFmzA4g&O!lbX5x#wup53(=P1mVNjH2ZkGk-q_{4RB$-$-=_IxHMXhj}<;fKcQpuK`
ztB%GtGyN~0_4_U2R&HE1Kv+@V2NsrRF`~M2R6cr```gF#NM?ya&{3!0G*@sWy{ny{
zt}m(ax?_v2R8N2R7MzXxeTe1K6Lpx~wB<-zZfRQ0E-_(j2PunH{!9qgfSy!p+>fLn
zj|nsrzk>US?#Qi5(qYLb>8>RW`%H|Wrs@qwk~<n`miUf%#wp;!uir)(`)Veee<@1I
z0i{N3S^Q-MYe2v#)dCT-c^t3r=*v<*>Tn;GaY?UlLz8W~HzId@Mg3<5A3ihD=A`JI
zFV?Hu@5U@oxVjtQQye9co{*(eFN5wzqT)XzUL>sNIC*YxeNl;#MRr(Xp%M&K^dGKk
z&ziRkxbN?jZFsLjq|B+B2tmxUM|_D2BUa1&WRDhYB_9FTvO!!^_Fj1_I8bpDY}&M7
zqzblnqz0;xE|<<BhG8UE@UlVrNwSog0R%}*Jnvt^QP_HfUosUi18nrK%LWLk6+g9e
zReOFR&TUpF=_b$;DP^ro)4K7_Qg=0nRHp-5F{};r5DB9^4+bD@!4c(hBI3*stLfq(
ziSgqg3CZIieJx#>b0V)&qwF#QNc8|zFANS@EH+$C<DqCr@&>G|#FJ5nnBX)x1$Q3h
zKQM^cIdBCJoy@a44NMKgr`eAaAEq^UXR<E)%*CVyV{10Mj7wM*>nGu8nu#P^#mS_~
zL(@N!=lIq(tu&Okt#{&f?c+^dmC<WHOa*IC<%3@d`9_zEt4o-iB`ti4^EUVMqF(L*
zMVnh@x0$VZC|5+h-c37jH~sdh^qN|Kg{D**L+dS+>c_=cyfQ=1B>Kk|fc(s^Wf$y6
z>cKL`!<1Of$6H@F=H1i^p_Gi8R$<dO^UKK07?YUdRrIO7MS?*ak!WH1&~zopUc+c+
zu#{D?3I>h40e6Y01{>1kGleug<pKIYDR2<>2@rv*C9=|baVfwIO{%)Ij%aW8(RIWo
zLy(H0FzF*O5>#jz*`=IlPN{Wj4n@y3BeXH#BvR?%>jPx+(2VnEEP^dPbW4-&VP>{+
z2+z^B_Ga#=U*07MWAe;RfY3D)%)d~|lsxM1Nhvw20Bae@`w7<W7Kqq-p5d|OYK*I@
zDuF{fFcifXMFe(Ys7R><#v(W7Xyr<SHsHPmqa(Tnzaop~)X@W?YjPF-I7k#JQxQU6
zmaG%?mXeN%{=N2vKHYomD}5dG&&NVq@um`IGQ^X|jX+v2zrP?c*e(aw2OYoy&NgQG
zidt3PYu~JeVZ2=Vb-AwWRTHW5RsQGM(1V%eedesJ8;XMoUcN}k5xF8z(e5uV`5QYq
zWC!wbN`8*y$=o^^mYf&y?jcb1sfUlZpxf$6P|N)@UL<7jjk&(uI{DrW-nVzKAui()
z0U1_sjzw_ydaOynAH-C#TCqT4Kp~8ub4w!6c{_tmJj@yLi(7Rrb2l!WrQ7dwF%sSS
z^NTqBd$CV)zjJ>_wWRBTXUaqEhNrU39DwiS5Cu)?Gdhn@zRj*3G;`ELwp{1R{vdqw
zJzg9KcAQu6{rxSOw~~=C@lLaKVu3<7zJL$pz@aQHj_cBGIj9B%7D=P;&ez(9DZR(@
zt;f}1V?`Gd=I7W9dpQHbom+vJLIq!ZWI!h)*OTU3CoqQROWdI0CnRVhcqVa?&k%)s
z*PjLzge?>;iKUwtowFv@5hs9D0PxGrn4j)WmJ=Yy%sRYL2Z=J(3O@RtPG+c1DF|@!
z-=A--PYm6xa%B}#EK7+iaA=GSWjsFEQQWM+gU4s#k@!hr3AILN|8TiqX{i-hO7}j!
ziH*Lj2W0xHjARtlBA#S=UG~KW$lnqoe|(4`@P!*3u@%_PpRm9b*GAds#-IR>_qt3_
zCD4#Cm<A!1#0H#UDg_z9hULzpd{FutALIZVMrc78-WS?I<ioGgH%1_PBEGBW?%v5*
zK&d6@cv33~69a{*j2egg`2G7tcUVwgkaWua7!CWw?e*bUOu>z>K%1x8^*RO;T@0)$
zCMCf+lNLAiP(T^X#Y@@k#`LoQ;@1hHH=@Kn)0Y#qlzfQLm?X&VM)!M4iCGeX)S}%3
zM|!R9_oT$@)j2TLjE@_&o4zZ+kqX(oymz~Sn|i)o`mknw`i#Y0vSn)RL`nH7?7V9F
zb3*zh$s-|sh>@^RbJMl+r>P|{Ok|7{gDGnehe;&>jd0!Yx$y}M2+U`{W)EwMcfr*k
zN-KgIWiDZiK-G(uiXzrA`=nJ){ct!TguTdLF0V6bqZzVK&_u$=ER_J7!gUR--M1`-
zw_vJ}lgd=_YwelKfNK9bJKQyC1Dq~e$;i&@XiyvACzq>E%)SPJYbmF}4buw3basH_
zC`b>IPTpgktB#3-U;Bil+T;W<>LyV~A?A4Xa0`h;CR))+1618f(+R@@_?O@LG(c^*
z#;f1ipnkcRnRb(W7LOZ(0RCvP%A^0_oD(HNV2p3W?)y%oPJwb^GsUq-siLQgWyDzV
zx{DGj@O{-CGpB3n_T`+z*Dn)ob7f-6cScG}<fl!KW=ifk_VIh@)#koFK4Mh+-3j3a
zsTAK8+eB&of1GY1%2P~OxG{}1ON}Dn#k%(bQOHz1FnS2Q^;$G=)cUg0vemOb%ENA+
z+1|u37#yICZ`=!(+3NS`HfS#<j1hm;U3FK%8F=@R;llqu67V#5OUlG!ur^*p!}L9Z
zIJHPY_Cm+R#T<NV)fph3Z-(C!-&5R4Yn;`CPum)BN2A6J@J_q8<odve;vR>c+a=&u
zpD;*<R-%U{u`}?w@C<o?ZT$GUpX1H0_?@{d-n}wk?P}KCO4ROm@$k2LPI9-gVprR0
zDTn@{@;b5iX)Z%&l%-L~E!WDWN|v<Dm=X#Ge8jwa5J_w16uU8<5<0Ww=+^VknsTf2
z6&y2aO$B>env2Wxbapc|BaZo#lWtbxU&m+m7spfd#g7+GlMv?mP9_2qSC`zZ6Qm(Y
zejH=qok>b}AnKJfEuV1Ni4Rz0vr#qebhh%#%eC}N6+a~NTx&)1VReSugV>mV;|=e$
z?VFtPQGN4{8fd!dxM{XO(s-QyEp=4oH13DhI#cJlAt9XvAwnf?Ty<v5F_6+(oOf;W
zmdOVp)ylJ4Gw(b~XWk6nA150gQjVCG*C(ORx##HTVOw$(&?5$E<gI~KCvHh)4dbkG
zsdwR*(;9rE$ZU)*p1@CkYc_{6X(Ex4V?0Tu8+0PTlsBGAaW{@ZS&$cqDHZhTI?F<%
zV7X=CIQ5znSt3-PIoxNwf#Q^|gt2ej0Ox~J+^CUCL>!gqBvIh1KM%0Rl+3+ku0*>E
z^<knD7FnDK^F?P1cL)O84{4Nd0nFxZEgw$~u`Qc4=WUbgOEhT?>W}a!<FyufctUiQ
zXv#kWFK#VrSV2a(HlHY{I&0o^#DUX%Lbb86?p7~Z%2`4fTs=6P7l&TfA){EGNFB;y
z=Okqn#+O(<Uik4pYWEN?uW)*fCf0v;)I2#|Tc2O9t-jP_VE-dS|0-D?KPKJ72<SZt
zI00<8%ekQ;%{wy?AIcef`=!c0kCUUsYaX??2`SM|H$%pJxZ6%&^)hb3StitFDu`|k
za8U{nwCi_mS331_*H{jaENhzq^-!_z0&CenH+%>R+~!SOpeK!c>-A=wIh2Pg!D3=h
zMNu%DhfS=IOTdUEkiE@T(RT1$yf+(PQI7ZP3U!!g3xoq_aO<6&UCF`d8sCRcB4aEx
zTPksxF4nPVk%3;H<~jgZVh|8qV~#HTLnm(1p=IT!bns$2!Kum-OW$=m9B4oE>BtjA
zkmZcr2~JJzbbX1N(5@Sj<PIXsJ$NQ%?(5k~_TXpJlXN_%D|P#S_Cfv$&VK88$HNyG
zn_u9>emTCBw|<Jfwlx1;P5BqPa+WWx=HQ#)6`|qw<jmwZ(p%QjM2oY0ezCpD;dIa=
zmwlfr?TH)+^Kk6I>>%21MkE)P$2h|nWTzo3bEu^OyK+@+C#YVmm2L`zVfCNiLE)px
zN>-KH*)`a4nvbURU&V>Kp5=8i^_fu(aN@F|5#^3$vgau|B^M_sr3W6rqN`Mp4>@g?
zWoU<%*X9j0A<IPZe1f;oz;TN_yc3qiAS$_G(GMCXUWlOiC7Yg^q<`q_rnHwQbG+SY
zaPjRM+M#dy>{ea&J|w*5hRKfnrB-k=X>hAVc>P4@;hP%7TyD{f=ZAeW9luu=iq5p0
z%wB3u@Gt$M*Itpfh@GvoiLJAqiif?4)7#g2Q+eW$JO~qN$V&yVJ5QTM+1?=1K!4q&
zm~;bl`nr?#GC3>Y^g4@5A4JGMGF^)M=&s}WM;n|tja3Ah==91=nckHKu>8CH<uX%(
zgp~6vwA3KwE_X;aZP1#D(|b!sO~}rG61>?mDJow3=o(;}s&io65n1m#;t9r4cYq_k
zX{ViM8xMV(%-Wj|TJY?+ykAskWvR2&FFiL&1BBFgZP6Rb(!v3e$;5HW?auptZ)~B_
zRJYmYcKtYv1J6DMxo*34HXKLghHD8ip)<9?$gnq_JK}l^%7>J6s7B9SP8BB$V#CTH
zsf;(22`2fI5|P6TWIY?p5Ue}i(tm2WH{1Y8_?*Imh@GstEqgm?Z!HRTl|`H>c_`Zl
z5TdjOif5b2x;`$#ecyH!Hw*E!EQro0B=218w`14g1f;nQb~@B|S9o(VTGd@gbu|cc
zG`hA!C%oWYvbS>89@o%8+j{Zk!ifFHOQ#+f1of{n>`(U3pOJY94iGR9;mhZH;(v_O
zPXqtl%YV%{KgTPP=#t=9{`uYMpBd;?=ciLl!hh@hwPOC4v)9(-&++Q)b^MLs^t-=5
zDNe7#KmAesUF~0lr#~V3lfv^$JNV_1{*Tjt6MFts|C59AOC9uu*6>UHKa7<Bb<?kO
zil5{4rafLtw=e1De<}Qqk|5FF^3$Ia{WFoh`uT~H+27UvE3N%$=g)foFFRo`WRHKU
z{{Ly=&qCxc3rxsAE&Qh}`Tu|KoG%2D7w7+OW&i$!{MpR@<x%hNYQI|Be@^+&YWgn&
z1TT?#@%wk!{@0{m`7l4nYlPE&M))^&%<nV*lOOY{`!j02|E2qjEu$y{{?}qfdLgAj
LzQ~b~zUuuSzRB}O

literal 0
HcmV?d00001


From b5312e73f0d6aaac987ab331371cf8426af0ba56 Mon Sep 17 00:00:00 2001
From: renzhiyuan <465386466@qq.com>
Date: Tue, 13 Jan 2026 17:23:26 +0800
Subject: [PATCH 06/13] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E8=B4=9F?=
 =?UTF-8?q?=E5=88=A9=E6=B6=A6=E5=88=86=E6=9E=90=E6=8A=A5=E8=A1=A8=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/biz/chat_history.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/internal/biz/chat_history.go b/internal/biz/chat_history.go
index c3912a4..f8e18b8 100644
--- a/internal/biz/chat_history.go
+++ b/internal/biz/chat_history.go
@@ -8,6 +8,7 @@ import (
 	"ai_scheduler/internal/pkg/util"
 	"context"
 	"encoding/json"
+
 	"xorm.io/builder"
 )
 
@@ -127,5 +128,5 @@ func (c *ChatHistoryBiz) UpdateContent(ctx context.Context, chat *entitys.Update
 func (s *ChatHistoryBiz) Update(ctx context.Context, chat *entitys.UseFulRequest) error {
 	cond := builder.NewCond()
 	cond = cond.And(builder.Eq{"his_id": chat.HisId})
-	return s.chatHiRepo.UpdateByCond(&cond, &model.AiChatHi{HisID: chat.HisId, Useful: chat.Useful})
+	return s.chatHiRepo.UpdateByCond(&cond, &model.AiChatHi{Useful: chat.Useful})
 }

From c13c601475e50568396ef238ac8bb6acb53565e9 Mon Sep 17 00:00:00 2001
From: fuzhongyun <15339891972@163.com>
Date: Tue, 13 Jan 2026 17:27:23 +0800
Subject: [PATCH 07/13] =?UTF-8?q?fix:=201.=20=E5=AF=B9=E8=AF=9D=E5=8E=86?=
 =?UTF-8?q?=E5=8F=B2=E5=A2=9E=E5=8A=A0taskid=202.=20=E5=A2=9E=E5=8A=A0Orde?=
 =?UTF-8?q?rByAsc=E6=96=B9=E6=B3=95=203.=E5=8E=86=E5=8F=B2=E5=AF=B9?=
 =?UTF-8?q?=E8=AF=9D=E6=AD=A3=E5=BA=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/biz/chat_history.go        |  3 ++-
 internal/biz/do/ctx.go              | 40 ++++++++++++++++++++++++++++-
 internal/data/impl/base.go          |  8 ++++++
 internal/services/dtalk_bot_test.go |  2 +-
 4 files changed, 50 insertions(+), 3 deletions(-)

diff --git a/internal/biz/chat_history.go b/internal/biz/chat_history.go
index f8e18b8..488bead 100644
--- a/internal/biz/chat_history.go
+++ b/internal/biz/chat_history.go
@@ -31,7 +31,8 @@ func (s *ChatHistoryBiz) List(ctx context.Context, query *entitys.ChatHistQuery)
 	con := []impl.CondFunc{
 		s.chatHiRepo.WithSessionId(query.SessionID),
 		s.chatHiRepo.PaginateScope(query.Page, query.PageSize),
-		s.chatHiRepo.OrderByDesc("his_id"),
+		// s.chatHiRepo.OrderByDesc("his_id"),
+		s.chatHiRepo.OrderByAsc("his_id"),
 	}
 	if query.HisID > 0 {
 		con = append(con, s.chatHiRepo.WithHisId(query.HisID))
diff --git a/internal/biz/do/ctx.go b/internal/biz/do/ctx.go
index 8d5cf74..18babd3 100644
--- a/internal/biz/do/ctx.go
+++ b/internal/biz/do/ctx.go
@@ -267,13 +267,15 @@ func (d *Do) startMessageHandler(
 			if len(chat) > 0 {
 				// 合并所有回答-转json字符串
 				ans, _ := json.Marshal(chat)
+				// 通过 chat 获取 task_id
+				taskId := d.getTaskIdByChat(chat)
 
 				AiRes := &model.AiChatHi{
 					SessionID: requireData.Session,
 					Ques:      requireData.Req.Text,
 					Ans:       string(ans),
 					Files:     requireData.Req.Img,
-					TaskID:    requireData.Task.TaskID,
+					TaskID:    taskId,
 				}
 				d.hisImpl.AddWithData(AiRes)
 				hisLog.HisId = AiRes.HisID
@@ -410,3 +412,39 @@ func (d *Do) LoadUserPermission(client *gateway.Client, requireData *entitys.Req
 
 	return respBody.Codes, nil
 }
+
+// getTaskIdByChat 从 chat 中获取 task_id
+func (d *Do) getTaskIdByChat(chat []entitys.Response) (taskId int32) {
+	if len(chat) == 0 {
+		return
+	}
+
+	var irregularTaskToolIndexMap = map[string]string{
+		"zltxProduct":                     "product_diagnosis",
+		"zltxOrderDetail":                 "order_diagnosis",
+		"knowledgeBase":                   "knowledge_qa",
+		"zltxOrderStatistics":             "account_statistics",
+		"normalChat":                      "chat",
+		"zltxOrderAfterSaleSupplier":      "after_sale_supplier",
+		"zltxOrderAfterSaleReseller":      "after_sale_reseller",
+		"zltxOrderAfterSaleResellerBatch": "after_sale_reseller_batch",
+		"zltxLossRiskSearch":              "loss_order_direct",
+	}
+
+	taskIndex := chat[0].Index
+
+	if _, ok := irregularTaskToolIndexMap[taskIndex]; ok {
+		taskIndex = irregularTaskToolIndexMap[taskIndex]
+	}
+
+	// 通过 taskIndex 获取 taskId
+	cond := builder.NewCond().And(builder.Eq{"`index`": taskIndex})
+	taskMap, _ := d.taskImpl.GetOneBySearch(&cond)
+	if taskMap == nil {
+		return
+	}
+
+	taskId = taskMap["task_id"].(int32)
+
+	return
+}
diff --git a/internal/data/impl/base.go b/internal/data/impl/base.go
index b7abf1a..8eb0b7d 100644
--- a/internal/data/impl/base.go
+++ b/internal/data/impl/base.go
@@ -50,6 +50,7 @@ type BaseRepository[P PO] interface {
 	Count(conditions ...CondFunc) (count int64, err error)                             // 查询条数
 	PaginateScope(page, pageSize int) CondFunc                                         // 分页
 	OrderByDesc(field string) CondFunc                                                 // 倒序排序
+	OrderByAsc(field string) CondFunc                                                  // 正序排序
 	WithId(id interface{}) CondFunc                                                    // 查询id
 	WithStatus(status int) CondFunc                                                    // 查询status
 	GetDb() *gorm.DB                                                                   // 获取数据库连接
@@ -193,6 +194,13 @@ func (this *BaseModel[P]) OrderByDesc(field string) CondFunc {
 	}
 }
 
+// 正序排序条件生成器
+func (this *BaseModel[P]) OrderByAsc(field string) CondFunc {
+	return func(db *gorm.DB) *gorm.DB {
+		return db.Order(fmt.Sprintf("%s ASC", field))
+	}
+}
+
 // ID查询条件生成器
 func (this *BaseModel[P]) WithId(id interface{}) CondFunc {
 	return func(db *gorm.DB) *gorm.DB {
diff --git a/internal/services/dtalk_bot_test.go b/internal/services/dtalk_bot_test.go
index 5def7e6..cd4c245 100644
--- a/internal/services/dtalk_bot_test.go
+++ b/internal/services/dtalk_bot_test.go
@@ -63,7 +63,7 @@ func run() {
 	botGroupImpl := impl.NewBotGroupImpl(db)
 	botUserImpl := impl.NewBotUserImpl(db)
 	// 初始化Do业务对象
-	doDo := do.NewDo(sysImpl, taskImpl, chatHisImpl, configConfig)
+	doDo := do.NewDo(sessionImpl, sysImpl, taskImpl, chatHisImpl, configConfig)
 	// 初始化Ollama客户端
 	client, _, _ := utils_ollama.NewClient(configConfig)
 	// 初始化vLLM客户端

From e538f49beaeef9aeb2ca7ee85077a2ddaed57fc1 Mon Sep 17 00:00:00 2001
From: fuzhongyun <15339891972@163.com>
Date: Tue, 13 Jan 2026 17:42:23 +0800
Subject: [PATCH 08/13] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=20taskindex=20?=
 =?UTF-8?q?=E9=94=99=E4=B9=B1=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/biz/do/ctx.go           | 18 ++++--------------
 internal/data/constants/task.go  | 13 +++++++++++++
 internal/entitys/chat_history.go | 26 +++++++++-----------------
 3 files changed, 26 insertions(+), 31 deletions(-)

diff --git a/internal/biz/do/ctx.go b/internal/biz/do/ctx.go
index 18babd3..9527177 100644
--- a/internal/biz/do/ctx.go
+++ b/internal/biz/do/ctx.go
@@ -2,6 +2,7 @@ package do
 
 import (
 	"ai_scheduler/internal/config"
+	"ai_scheduler/internal/data/constants"
 	errors "ai_scheduler/internal/data/error"
 	"ai_scheduler/internal/data/impl"
 	"ai_scheduler/internal/data/model"
@@ -419,22 +420,11 @@ func (d *Do) getTaskIdByChat(chat []entitys.Response) (taskId int32) {
 		return
 	}
 
-	var irregularTaskToolIndexMap = map[string]string{
-		"zltxProduct":                     "product_diagnosis",
-		"zltxOrderDetail":                 "order_diagnosis",
-		"knowledgeBase":                   "knowledge_qa",
-		"zltxOrderStatistics":             "account_statistics",
-		"normalChat":                      "chat",
-		"zltxOrderAfterSaleSupplier":      "after_sale_supplier",
-		"zltxOrderAfterSaleReseller":      "after_sale_reseller",
-		"zltxOrderAfterSaleResellerBatch": "after_sale_reseller_batch",
-		"zltxLossRiskSearch":              "loss_order_direct",
-	}
-
+	// 解析 taskIndex
 	taskIndex := chat[0].Index
 
-	if _, ok := irregularTaskToolIndexMap[taskIndex]; ok {
-		taskIndex = irregularTaskToolIndexMap[taskIndex]
+	if _, ok := constants.IrregularTaskToolIndexMap[taskIndex]; ok {
+		taskIndex = constants.IrregularTaskToolIndexMap[taskIndex]
 	}
 
 	// 通过 taskIndex 获取 taskId
diff --git a/internal/data/constants/task.go b/internal/data/constants/task.go
index 8ba18a9..935d10d 100644
--- a/internal/data/constants/task.go
+++ b/internal/data/constants/task.go
@@ -9,3 +9,16 @@ const (
 	Enable  = 1
 	Disable = 2
 )
+
+// IrregularTaskToolIndexMap 不规则任务工具索引映射
+var IrregularTaskToolIndexMap = map[string]string{
+	"zltxProduct":                     "product_diagnosis",
+	"zltxOrderDetail":                 "order_diagnosis",
+	"knowledgeBase":                   "knowledge_qa",
+	"zltxOrderStatistics":             "account_statistics",
+	"normalChat":                      "chat",
+	"zltxOrderAfterSaleSupplier":      "after_sale_supplier",
+	"zltxOrderAfterSaleReseller":      "after_sale_reseller",
+	"zltxOrderAfterSaleResellerBatch": "after_sale_reseller_batch",
+	"zltxLossRiskSearch":              "loss_order_direct",
+}
diff --git a/internal/entitys/chat_history.go b/internal/entitys/chat_history.go
index 50bbb0b..084adfe 100644
--- a/internal/entitys/chat_history.go
+++ b/internal/entitys/chat_history.go
@@ -50,7 +50,7 @@ func (c *ChatHisQueryResponse) FromModel(chat model.AiChatHi, task model.AiTask)
 	c.TaskID = chat.TaskID
 	c.TaskName = task.Name
 	c.Contents = make([]string, 0)
-	c.TaskIndex = c.parseTaskIndex(task.Index, chat.Ans)
+	c.TaskIndex = c.parseTaskIndex(task.Index)
 
 	// 解析Content
 	if "" != chat.Content {
@@ -62,26 +62,18 @@ func (c *ChatHisQueryResponse) FromModel(chat model.AiChatHi, task model.AiTask)
 	}
 }
 
-func (c *ChatHisQueryResponse) parseTaskIndex(taskIndex string, ans string) string {
-	if taskIndex != "" {
-		return taskIndex
+func (c *ChatHisQueryResponse) parseTaskIndex(taskIndex string) string {
+	// 反转 IrregularTaskToolIndexMap
+	reverseMap := make(map[string]string)
+	for k, v := range constants.IrregularTaskToolIndexMap {
+		reverseMap[v] = k
 	}
 
-	if ans == "" {
-		return ""
-	}
-	var resp []Response
-	err := json.Unmarshal([]byte(ans), &resp)
-	if err != nil {
-		log.Println("解析Ans失败 error: ", err)
-		return ""
+	if _, ok := reverseMap[taskIndex]; !ok {
+		return reverseMap[taskIndex]
 	}
 
-	if 0 < len(resp) {
-		return resp[0].Index
-	}
-
-	return ""
+	return taskIndex
 }
 
 type UpdateContentRequest struct {

From 289ac1de7a81c7ec3f0863a65a26b9ffad30da36 Mon Sep 17 00:00:00 2001
From: fuzhongyun <15339891972@163.com>
Date: Tue, 13 Jan 2026 17:50:28 +0800
Subject: [PATCH 09/13] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=20taskindex=20?=
 =?UTF-8?q?=E9=94=99=E4=B9=B1=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/biz/do/ctx.go           | 2 +-
 internal/entitys/chat_history.go | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/biz/do/ctx.go b/internal/biz/do/ctx.go
index 9527177..a80858a 100644
--- a/internal/biz/do/ctx.go
+++ b/internal/biz/do/ctx.go
@@ -430,7 +430,7 @@ func (d *Do) getTaskIdByChat(chat []entitys.Response) (taskId int32) {
 	// 通过 taskIndex 获取 taskId
 	cond := builder.NewCond().And(builder.Eq{"`index`": taskIndex})
 	taskMap, _ := d.taskImpl.GetOneBySearch(&cond)
-	if taskMap == nil {
+	if taskMap == nil || taskMap["task_id"] == nil {
 		return
 	}
 
diff --git a/internal/entitys/chat_history.go b/internal/entitys/chat_history.go
index 084adfe..f4aa8de 100644
--- a/internal/entitys/chat_history.go
+++ b/internal/entitys/chat_history.go
@@ -69,7 +69,7 @@ func (c *ChatHisQueryResponse) parseTaskIndex(taskIndex string) string {
 		reverseMap[v] = k
 	}
 
-	if _, ok := reverseMap[taskIndex]; !ok {
+	if _, ok := reverseMap[taskIndex]; ok {
 		return reverseMap[taskIndex]
 	}
 

From c91e7bc95bdb2d25ed5da6ed8dea0294095e6ed4 Mon Sep 17 00:00:00 2001
From: renzhiyuan <465386466@qq.com>
Date: Tue, 13 Jan 2026 18:10:21 +0800
Subject: [PATCH 10/13] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E8=B4=9F?=
 =?UTF-8?q?=E5=88=A9=E6=B6=A6=E5=88=86=E6=9E=90=E6=8A=A5=E8=A1=A8=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/biz/session.go          | 52 +++++++++++++++++++++-----------
 internal/server/router/router.go |  2 +-
 internal/services/session.go     | 17 +++++++++++
 3 files changed, 52 insertions(+), 19 deletions(-)

diff --git a/internal/biz/session.go b/internal/biz/session.go
index a42e9c0..d8b45d8 100644
--- a/internal/biz/session.go
+++ b/internal/biz/session.go
@@ -35,41 +35,31 @@ func NewSessionBiz(conf *config.Config, sessionImpl *impl.SessionImpl, sysImpl *
 func (s *SessionBiz) SessionInit(ctx context.Context, req *entitys.SessionInitRequest) (result *entitys.SessionInitResponse, err error) {
 
 	// 获取系统配置
-	sysConfig, has, err := s.sysRepo.FindOne(s.sysRepo.WithSysId(req.SysId))
+	sysConfig, err := s.GetSysConfig(req.SysId)
 	if err != nil {
 		return
-	} else if !has {
-		err = errorcode.SysNotFound
-		return
 	}
-
 	result = &entitys.SessionInitResponse{
 		Chat: make([]entitys.ChatHistory, 0),
 	}
 
-	// 获取 当天的session
+	// 获取 当天的最新session
 	t := time.Now().Truncate(24 * time.Hour)
 	session, has, err := s.sessionRepo.FindOne(
 		s.sessionRepo.WithUserId(req.UserId), // 条件：用户ID
 		s.sessionRepo.WithStartTime(t),       // 条件：会话开始时间
-		s.sysRepo.WithSysId(sysConfig.SysID), // 条件：系统ID
+		s.sysRepo.WithSysId(sysConfig.SysID),
+		s.sessionRepo.OrderByDesc("create_at"), // 条件：系统ID
 	)
 	if err != nil {
 		return
-	} else if !has {
+	}
+	if !has {
 		// 不存在，创建一个
-		session = model.AiSession{
-			SysID:      sysConfig.SysID,
-			SessionID:  utils.UUID(),
-			UserID:     req.UserId,
-			UserName:   req.UserName,
-			DingUserId: req.DingUserId,
-		}
-		err = s.sessionRepo.Create(&session)
+		session, err = s.CreateNew(sysConfig.SysID, req)
 		if err != nil {
-			return
+			return nil, err
 		}
-
 		chat := entitys.ChatHistory{
 			SessionID: session.SessionID,
 			Role:      constants.RoleSystem,
@@ -122,6 +112,32 @@ func (s *SessionBiz) SessionInit(ctx context.Context, req *entitys.SessionInitRe
 	return
 }
 
+func (s *SessionBiz) GetSysConfig(sysId string) (model.AiSy, error) {
+	sysConfig, has, err := s.sysRepo.FindOne(s.sysRepo.WithSysId(sysId))
+	if err != nil {
+		return sysConfig, err
+	} else if !has {
+		err = errorcode.SysNotFound
+		return sysConfig, err
+	}
+	return sysConfig, nil
+}
+
+func (s *SessionBiz) CreateNew(sysID int32, req *entitys.SessionInitRequest) (model.AiSession, error) {
+	session := model.AiSession{
+		SysID:      sysID,
+		SessionID:  utils.UUID(),
+		UserID:     req.UserId,
+		UserName:   req.UserName,
+		DingUserId: req.DingUserId,
+	}
+	err := s.sessionRepo.Create(&session)
+	if err != nil {
+		return session, err
+	}
+	return session, nil
+}
+
 // SessionList 会话列表
 func (s *SessionBiz) SessionList(ctx context.Context, req *entitys.SessionListRequest) (list []model.AiSession, err error) {
 
diff --git a/internal/server/router/router.go b/internal/server/router/router.go
index 6285222..fec3d88 100644
--- a/internal/server/router/router.go
+++ b/internal/server/router/router.go
@@ -56,7 +56,7 @@ func SetupRoutes(app *fiber.App, ChatService *services.ChatService, sessionServi
 		c.Response().SetBody([]byte("1"))
 		return nil
 	})
-
+	r.Post("/session/new", sessionService.NewSession)
 	r.Post("/session/init", sessionService.SessionInit) // 会话初始化,不存在则创建,存在则返回会话ID和默认条数会话历史
 	r.Post("/session/list", sessionService.SessionList)
 
diff --git a/internal/services/session.go b/internal/services/session.go
index 6820fe5..d058d17 100644
--- a/internal/services/session.go
+++ b/internal/services/session.go
@@ -35,6 +35,23 @@ func (s *SessionService) SessionInit(c *fiber.Ctx) error {
 	return c.JSON(result)
 }
 
+// NewSession 新会话
+func (s *SessionService) NewSession(c *fiber.Ctx) error {
+	req := &entitys.SessionInitRequest{}
+	if err := c.BodyParser(req); err != nil {
+		return err
+	}
+
+	sysConfig, err := s.sessionBiz.GetSysConfig(req.SysId)
+
+	if err != nil {
+		return err
+	}
+	session, err := s.sessionBiz.CreateNew(sysConfig.SysID, req)
+
+	return c.JSON(session)
+}
+
 // SessionList 获取会话列表
 func (s *SessionService) SessionList(c *fiber.Ctx) error {
 	req := &entitys.SessionListRequest{}

From c7e1bad7ef9da670d349dcaef29f65ab70a5ff03 Mon Sep 17 00:00:00 2001
From: renzhiyuan <465386466@qq.com>
Date: Tue, 13 Jan 2026 18:28:31 +0800
Subject: [PATCH 11/13] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E8=B4=9F?=
 =?UTF-8?q?=E5=88=A9=E6=B6=A6=E5=88=86=E6=9E=90=E6=8A=A5=E8=A1=A8=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/biz/session.go    |  2 +-
 internal/data/impl/base.go | 49 +++++++++++++++++++++++++++-----------
 2 files changed, 36 insertions(+), 15 deletions(-)

diff --git a/internal/biz/session.go b/internal/biz/session.go
index d8b45d8..2d3f419 100644
--- a/internal/biz/session.go
+++ b/internal/biz/session.go
@@ -45,7 +45,7 @@ func (s *SessionBiz) SessionInit(ctx context.Context, req *entitys.SessionInitRe
 
 	// 获取 当天的最新session
 	t := time.Now().Truncate(24 * time.Hour)
-	session, has, err := s.sessionRepo.FindOne(
+	session, has, err := s.sessionRepo.Take(
 		s.sessionRepo.WithUserId(req.UserId), // 条件：用户ID
 		s.sessionRepo.WithStartTime(t),       // 条件：会话开始时间
 		s.sysRepo.WithSysId(sysConfig.SysID),
diff --git a/internal/data/impl/base.go b/internal/data/impl/base.go
index 8eb0b7d..501f710 100644
--- a/internal/data/impl/base.go
+++ b/internal/data/impl/base.go
@@ -43,20 +43,21 @@ type BaseRepository[P PO] interface {
 	FindAll(conditions ...CondFunc) ([]P, error)                                       // 查询所有
 	Paginate(page, pageSize int, conditions ...CondFunc) (*PaginationResult[P], error) // 分页查询
 	FindOne(conditions ...CondFunc) (P, bool, error)                                   // 查询单条记录，若未找到则返回 has=false, err=nil
-	Create(m *P) error                                                                 // 创建
-	BatchCreate(m *[]P) (err error)                                                    // 批量创建
-	Update(m *P, conditions ...CondFunc) (err error)                                   // 更新
-	Delete(conditions ...CondFunc) (err error)                                         // 删除
-	Count(conditions ...CondFunc) (count int64, err error)                             // 查询条数
-	PaginateScope(page, pageSize int) CondFunc                                         // 分页
-	OrderByDesc(field string) CondFunc                                                 // 倒序排序
-	OrderByAsc(field string) CondFunc                                                  // 正序排序
-	WithId(id interface{}) CondFunc                                                    // 查询id
-	WithStatus(status int) CondFunc                                                    // 查询status
-	GetDb() *gorm.DB                                                                   // 获取数据库连接
-	WithLimit(limit int) CondFunc                                                      // 限制返回条数
-	In(field string, values interface{}) CondFunc                                      // 查询字段是否在列表中
-	Select(fields ...string) CondFunc                                                  // 选择字段
+	Take(conditions ...CondFunc) (P, bool, error)
+	Create(m *P) error                                     // 创建
+	BatchCreate(m *[]P) (err error)                        // 批量创建
+	Update(m *P, conditions ...CondFunc) (err error)       // 更新
+	Delete(conditions ...CondFunc) (err error)             // 删除
+	Count(conditions ...CondFunc) (count int64, err error) // 查询条数
+	PaginateScope(page, pageSize int) CondFunc             // 分页
+	OrderByDesc(field string) CondFunc                     // 倒序排序
+	OrderByAsc(field string) CondFunc                      // 正序排序
+	WithId(id interface{}) CondFunc                        // 查询id
+	WithStatus(status int) CondFunc                        // 查询status
+	GetDb() *gorm.DB                                       // 获取数据库连接
+	WithLimit(limit int) CondFunc                          // 限制返回条数
+	In(field string, values interface{}) CondFunc          // 查询字段是否在列表中
+	Select(fields ...string) CondFunc                      // 选择字段
 }
 
 // PaginationResult 分页查询结果
@@ -128,6 +129,26 @@ func (this *BaseModel[P]) FindOne(conditions ...CondFunc) (P, bool, error) {
 	return result, true, err
 }
 
+func (this *BaseModel[P]) Take(conditions ...CondFunc) (P, bool, error) {
+	var (
+		result P
+	)
+
+	err := this.Db.Model(new(P)).
+		Scopes(conditions...).
+		Take(&result).
+		Error
+
+	if errors.Is(err, gorm.ErrRecordNotFound) {
+		return result, false, nil // 未找到记录
+	}
+	if err != nil {
+		return result, false, fmt.Errorf("查询单条记录失败: %w", err)
+	}
+
+	return result, true, err
+}
+
 // 创建
 func (this *BaseModel[P]) Create(m *P) error {
 	err := this.Db.Create(m).Error

From dd40bc250f58e8466155c1a636f46e34c0d7a732 Mon Sep 17 00:00:00 2001
From: renzhiyuan <465386466@qq.com>
Date: Wed, 14 Jan 2026 10:31:04 +0800
Subject: [PATCH 12/13] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E8=B4=9F?=
 =?UTF-8?q?=E5=88=A9=E6=B6=A6=E5=88=86=E6=9E=90=E6=8A=A5=E8=A1=A8=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/tools/bbxt/bbxt.go | 80 ++++++++++++++++++-------------------
 1 file changed, 40 insertions(+), 40 deletions(-)

diff --git a/internal/tools/bbxt/bbxt.go b/internal/tools/bbxt/bbxt.go
index 926f973..56b87d3 100644
--- a/internal/tools/bbxt/bbxt.go
+++ b/internal/tools/bbxt/bbxt.go
@@ -189,53 +189,53 @@ func (b *BbxtTools) StatisOursProductLossSum(ctx context.Context, now time.Time,
 	report = make([]*ReportRes, 3)
 	timeCh := now.Format("1月2日15点")
 	//总量生成excel
-	//if len(total) > 0 {
-	//	filePath := b.cacheDir + "/kshj_total" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
-	//	err = b.SimpleFillExcelWithTitle(b.excelTempDir+"/"+"kshj_total.xlsx", filePath, total, "")
-	//	if err != nil {
-	//		return
-	//	}
-	//	report[0] = &ReportRes{
-	//		ReportName: "分销商负利润统计",
-	//		Title:      "截至" + timeCh + "利润累计亏损" + fmt.Sprintf("%.2f", totalSum),
-	//		Path:       filePath,
-	//		Data:       total,
-	//	}
-	//}
-
-	//if len(gt) > 0 {
-	//	filePath := b.cacheDir + "/kshj_gt" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
-	//	title := "截至" + timeCh + "亏损500以上的分销商和产品"
-	//	err = b.resellerDetailFillExcelV2(b.excelTempDir+"/"+"kshj_gt.xlsx", filePath, gt, title)
-	//	if err != nil {
-	//		return
-	//	}
-	//	report[1] = &ReportRes{
-	//		ReportName: "负利润分析(亏损500以上)",
-	//		Title:      "截至" + timeCh + "亏损500以上利润累计亏损" + fmt.Sprintf("%.2f", totalSum500),
-	//		Path:       filePath,
-	//		Data:       total,
-	//	}
-	//}
-
-	if len(totalDetail) > 0 {
-		err = initFunc(ctx, now, totalDetail, b)
+	if len(total) > 0 {
+		filePath := b.cacheDir + "/kshj_total" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
+		err = b.SimpleFillExcelWithTitle(b.excelTempDir+"/"+"kshj_total.xlsx", filePath, total, "")
 		if err != nil {
 			return
 		}
-		filePath := b.cacheDir + "/kshj_total_ana" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
-		title := "截至" + timeCh + "亏损100以上的分销商&产品负利润原因"
-		err = b.resellerDetailFillExcelAna(b.excelTempDir+"/"+"kshj_total_ana.xlsx", filePath, totalDetail, title)
-		if err != nil {
-			return
-		}
-		report[2] = &ReportRes{
-			ReportName: "负利润分析(亏损100以上)",
-			Title:      "截至" + timeCh + "亏损100以上利润原因",
+		report[0] = &ReportRes{
+			ReportName: "分销商负利润统计",
+			Title:      "截至" + timeCh + "利润累计亏损" + fmt.Sprintf("%.2f", totalSum),
 			Path:       filePath,
 			Data:       total,
 		}
 	}
+
+	if len(gt) > 0 {
+		filePath := b.cacheDir + "/kshj_gt" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
+		title := "截至" + timeCh + "亏损500以上的分销商和产品"
+		err = b.resellerDetailFillExcelV2(b.excelTempDir+"/"+"kshj_gt.xlsx", filePath, gt, title)
+		if err != nil {
+			return
+		}
+		report[1] = &ReportRes{
+			ReportName: "负利润分析(亏损500以上)",
+			Title:      "截至" + timeCh + "亏损500以上利润累计亏损" + fmt.Sprintf("%.2f", totalSum500),
+			Path:       filePath,
+			Data:       total,
+		}
+	}
+
+	//if len(totalDetail) > 0 {
+	//	err = initFunc(ctx, now, totalDetail, b)
+	//	if err != nil {
+	//		return
+	//	}
+	//	filePath := b.cacheDir + "/kshj_total_ana" + fmt.Sprintf("%d%d", time.Now().Unix(), rand.Intn(1000)) + ".xlsx"
+	//	title := "截至" + timeCh + "亏损100以上的分销商&产品负利润原因"
+	//	err = b.resellerDetailFillExcelAna(b.excelTempDir+"/"+"kshj_total_ana.xlsx", filePath, totalDetail, title)
+	//	if err != nil {
+	//		return
+	//	}
+	//	report[2] = &ReportRes{
+	//		ReportName: "负利润分析(亏损100以上)",
+	//		Title:      "截至" + timeCh + "亏损100以上利润原因",
+	//		Path:       filePath,
+	//		Data:       total,
+	//	}
+	//}
 	return report, nil
 }
 

From 94c4a8fae82277c4601847a20b1959fb08b6c4ec Mon Sep 17 00:00:00 2001
From: fuzhongyun <15339891972@163.com>
Date: Wed, 14 Jan 2026 10:34:12 +0800
Subject: [PATCH 13/13] =?UTF-8?q?fix:=20=E5=B8=B8=E9=87=8F=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/data/constants/task.go | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/internal/data/constants/task.go b/internal/data/constants/task.go
index 935d10d..ce6a650 100644
--- a/internal/data/constants/task.go
+++ b/internal/data/constants/task.go
@@ -17,8 +17,7 @@ var IrregularTaskToolIndexMap = map[string]string{
 	"knowledgeBase":                   "knowledge_qa",
 	"zltxOrderStatistics":             "account_statistics",
 	"normalChat":                      "chat",
-	"zltxOrderAfterSaleSupplier":      "after_sale_supplier",
-	"zltxOrderAfterSaleReseller":      "after_sale_reseller",
-	"zltxOrderAfterSaleResellerBatch": "after_sale_reseller_batch",
-	"zltxLossRiskSearch":              "loss_order_direct",
+	"zltxOrderAfterSaleSupplier":      "after_sales_supplier",
+	"zltxOrderAfterSaleReseller":      "after_sales_reseller",
+	"zltxOrderAfterSaleResellerBatch": "after_sales_reseller_batch",
 }