From b39d58280cdbd583f31ff1aa19e9ae07880c4359 Mon Sep 17 00:00:00 2001 From: fuzhongyun <15339891972@163.com> Date: Wed, 31 Dec 2025 10:17:46 +0800 Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=20=E5=A2=9E=E5=8A=A0=E6=88=91?= =?UTF-8?q?=E4=BB=AC=E7=9A=84=E5=95=86=E5=93=81=E7=BB=9F=E8=AE=A1=E5=B7=A5?= =?UTF-8?q?=E4=BD=9C=E6=B5=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/config/config.go | 2 + internal/domain/repo/repos.go | 12 +- .../tools/common/excel_generator/client.go | 76 +++++++++++ .../tools/common/image_converter/client.go | 58 +++++++++ internal/domain/tools/registry.go | 23 +++- .../recharge/statistics_ours_product.go | 121 +++++++++++++++++- internal/services/dtalk_bot_test.go | 2 +- .../recharge_statistics_ours_product.xlsx | Bin 0 -> 9787 bytes 8 files changed, 284 insertions(+), 10 deletions(-) create mode 100644 internal/domain/tools/common/excel_generator/client.go create mode 100644 internal/domain/tools/common/image_converter/client.go create mode 100755 tmpl/excel_temp/recharge_statistics_ours_product.xlsx diff --git a/internal/config/config.go b/internal/config/config.go index 7e94bfd..add63a1 100644 --- a/internal/config/config.go +++ b/internal/config/config.go @@ -209,6 +209,8 @@ type EinoToolsConfig struct { DaOfficialProductDecline ToolConfig `mapstructure:"daOfficialProductDecline"` // 我们的商品统计 RechargeStatisticsOursProduct ToolConfig `mapstructure:"rechargeStatisticsOursProduct"` + // Excel 转图片 + Excel2Pic ToolConfig `mapstructure:"excel2Pic"` } // LoggingConfig 日志配置 diff --git a/internal/domain/repo/repos.go b/internal/domain/repo/repos.go index 40ba3de..a3250ba 100644 --- a/internal/domain/repo/repos.go +++ b/internal/domain/repo/repos.go @@ -1,17 +1,21 @@ package repo import ( + "ai_scheduler/internal/config" "ai_scheduler/internal/data/impl" - "ai_scheduler/utils" + "ai_scheduler/internal/pkg/oss" ) // Repos 聚合所有 Repository type Repos struct { - Session SessionRepo + Session SessionRepo + OssClient *oss.Client } -func NewRepos(sessionImpl *impl.SessionImpl, rdb *utils.Rdb) *Repos { +func NewRepos(sessionImpl *impl.SessionImpl, cfg *config.Config) *Repos { + ossClient, _ := oss.NewClient(cfg.Oss) return &Repos{ - Session: NewSessionAdapter(sessionImpl), + Session: NewSessionAdapter(sessionImpl), + OssClient: ossClient, } } diff --git a/internal/domain/tools/common/excel_generator/client.go b/internal/domain/tools/common/excel_generator/client.go new file mode 100644 index 0000000..eae9451 --- /dev/null +++ b/internal/domain/tools/common/excel_generator/client.go @@ -0,0 +1,76 @@ +package excel_generator + +import ( + "fmt" + + "github.com/go-kratos/kratos/v2/log" + "github.com/xuri/excelize/v2" +) + +// Client Excel 生成器 +type Client struct{} + +func New() *Client { + return &Client{} +} + +// Call 根据模板和数据生成 Excel 字节流 +// templatePath: 模板文件路径 +// data: 二维字符串数组，不再使用反射 +// startRow: 数据填充起始行 (默认 2) +// styleRow: 样式参考行 (默认 2) +func (g *Client) Call(templatePath string, data [][]string, startRow int, styleRow int) ([]byte, error) { + if startRow <= 0 { + startRow = 2 + } + if styleRow <= 0 { + styleRow = 2 + } + + f, err := excelize.OpenFile(templatePath) + if err != nil { + return nil, err + } + defer f.Close() + + sheet := f.GetSheetName(0) + + // 获取样式和行高 + styleID, err := f.GetCellStyle(sheet, fmt.Sprintf("A%d", styleRow)) + if err != nil { + log.Errorf("获取样式失败: %v", err) + styleID = 0 + } + rowHeight, err := f.GetRowHeight(sheet, styleRow) + if err != nil { + log.Errorf("获取行高失败: %v", err) + rowHeight = 31 // 默认高度 + } + + row := startRow + for i, item := range data { + currentRow := row + i + + // 设置行高 + f.SetRowHeight(sheet, currentRow, rowHeight) + + // 填充数据 + for col, value := range item { + cell := fmt.Sprintf("%c%d", 'A'+col, currentRow) + f.SetCellValue(sheet, cell, value) + } + + // 设置样式 + if styleID != 0 { + endCol := 'A' + len(item) - 1 + f.SetCellStyle(sheet, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("%c%d", endCol, currentRow), styleID) + } + } + + buf, err := f.WriteToBuffer() + if err != nil { + return nil, err + } + + return buf.Bytes(), nil +} diff --git a/internal/domain/tools/common/image_converter/client.go b/internal/domain/tools/common/image_converter/client.go new file mode 100644 index 0000000..5eba199 --- /dev/null +++ b/internal/domain/tools/common/image_converter/client.go @@ -0,0 +1,58 @@ +package image_converter + +import ( + "ai_scheduler/internal/config" + "bytes" + "fmt" + "io" + "mime/multipart" + "net/http" +) + +// Client 图片转换器 +type Client struct { + cfg config.ToolConfig +} + +func New(cfg config.ToolConfig) *Client { + return &Client{ + cfg: cfg, + } +} + +// Call 将 Excel 文件转换为图片 +func (c *Client) Call(filename string, fileBytes []byte) ([]byte, error) { + body := &bytes.Buffer{} + writer := multipart.NewWriter(body) + + part, err := writer.CreateFormFile("file", filename) + if err != nil { + return nil, err + } + if _, err = io.Copy(part, bytes.NewReader(fileBytes)); err != nil { + return nil, err + } + + if err = writer.Close(); err != nil { + return nil, err + } + + req, err := http.NewRequest("POST", c.cfg.BaseURL, body) + if err != nil { + return nil, err + } + req.Header.Set("Content-Type", writer.FormDataContentType()) + + client := &http.Client{} + resp, err := client.Do(req) + if err != nil { + return nil, err + } + defer resp.Body.Close() + + if resp.StatusCode != http.StatusOK { + return nil, fmt.Errorf("excel2pic service returned status: %s", resp.Status) + } + + return io.ReadAll(resp.Body) +} diff --git a/internal/domain/tools/registry.go b/internal/domain/tools/registry.go index ad9439d..f6b2193 100644 --- a/internal/domain/tools/registry.go +++ b/internal/domain/tools/registry.go @@ -2,6 +2,8 @@ package tools import ( "ai_scheduler/internal/config" + "ai_scheduler/internal/domain/tools/common/excel_generator" + "ai_scheduler/internal/domain/tools/common/image_converter" "ai_scheduler/internal/domain/tools/hyt/goods_add" "ai_scheduler/internal/domain/tools/hyt/goods_brand_search" "ai_scheduler/internal/domain/tools/hyt/goods_category_add" @@ -10,13 +12,21 @@ import ( "ai_scheduler/internal/domain/tools/hyt/product_upload" "ai_scheduler/internal/domain/tools/hyt/supplier_search" "ai_scheduler/internal/domain/tools/hyt/warehouse_search" + "ai_scheduler/internal/domain/tools/recharge/statistics_ours_product" ) type Manager struct { - Hyt *HytTools + Hyt *HytTools + Recharge *RechargeTools + Common *CommonTools // Zltx *ZltxTools } +type CommonTools struct { + ExcelGenerator *excel_generator.Client + ImageConverter *image_converter.Client +} + type HytTools struct { ProductUpload *product_upload.Client SupplierSearch *supplier_search.Client @@ -28,6 +38,10 @@ type HytTools struct { GoodsBrandSearch *goods_brand_search.Client } +type RechargeTools struct { + StatisticsOursProduct *statistics_ours_product.Client +} + func NewManager(cfg *config.Config) *Manager { return &Manager{ Hyt: &HytTools{ @@ -40,5 +54,12 @@ func NewManager(cfg *config.Config) *Manager { GoodsCategorySearch: goods_category_search.New(cfg.EinoTools.HytGoodsCategorySearch), GoodsBrandSearch: goods_brand_search.New(cfg.EinoTools.HytGoodsBrandSearch), }, + Recharge: &RechargeTools{ + StatisticsOursProduct: statistics_ours_product.New(cfg.EinoTools.RechargeStatisticsOursProduct), + }, + Common: &CommonTools{ + ExcelGenerator: excel_generator.New(), + ImageConverter: image_converter.New(cfg.EinoTools.Excel2Pic), + }, } } diff --git a/internal/domain/workflow/recharge/statistics_ours_product.go b/internal/domain/workflow/recharge/statistics_ours_product.go index 0a7649d..91d5092 100644 --- a/internal/domain/workflow/recharge/statistics_ours_product.go +++ b/internal/domain/workflow/recharge/statistics_ours_product.go @@ -2,32 +2,145 @@ package recharge import ( "ai_scheduler/internal/config" + errorcode "ai_scheduler/internal/data/error" toolManager "ai_scheduler/internal/domain/tools" + "ai_scheduler/internal/domain/tools/recharge/statistics_ours_product" "ai_scheduler/internal/domain/workflow/runtime" "ai_scheduler/internal/entitys" + "ai_scheduler/internal/pkg/oss" "context" + "errors" + "fmt" + "path/filepath" + "time" + + "github.com/cloudwego/eino/compose" ) const WorkflowIDStatisticsOursProduct = "recharge.statisticsOursProduct" func init() { runtime.Register(WorkflowIDStatisticsOursProduct, func(d *runtime.Deps) (runtime.Workflow, error) { - return &statisticsOursProduct{cfg: d.Conf, toolManager: d.ToolManager}, nil + return &statisticsOursProduct{cfg: d.Conf, toolManager: d.ToolManager, ossClient: d.Repos.OssClient}, nil }) } type statisticsOursProduct struct { cfg *config.Config toolManager *toolManager.Manager + ossClient *oss.Client } type StatisticsOursProductWorkflowInput struct { - // 预留字段 + StartTime string `json:"start_time"` + EndTime string `json:"end_time"` +} + +type StatisticsOursProductWorkflowOutput struct { + ImgUrl string `json:"img_url"` } func (w *statisticsOursProduct) ID() string { return WorkflowIDStatisticsOursProduct } func (w *statisticsOursProduct) Invoke(ctx context.Context, rec *entitys.Recognize) (map[string]any, error) { - // 保持流程为空，仅返回 nil - return nil, nil + // 构建工作流 + runnable, err := w.buildWorkflow(ctx) + if err != nil { + return nil, err + } + + // 解析参数 (假设参数在 rec.Match.Parameters 中，或者根据实际情况解析) + // 这里简化处理，假设需要解析参数 + // 实际上这里应该根据 LLM 解析的结果来填充 Input + // 暂时假设 ParameterResult 是 JSON 字符串 + input := &StatisticsOursProductWorkflowInput{ + // 默认值，具体应从 rec 解析 + StartTime: time.Now().Format("2006010200"), + EndTime: time.Now().Format("2006010223"), + } + + // 工作流过程调用 + output, err := runnable.Invoke(ctx, input) + if err != nil { + fmt.Println("Invoke err:", err) + errStr := err.Error() + if u := errors.Unwrap(err); u != nil { + errStr = u.Error() + } + return nil, errorcode.WorkflowErr(errStr) + } + + return map[string]any{"img_url": output.ImgUrl}, nil +} + +func (w *statisticsOursProduct) buildWorkflow(ctx context.Context) (compose.Runnable[*StatisticsOursProductWorkflowInput, *StatisticsOursProductWorkflowOutput], error) { + c := compose.NewChain[*StatisticsOursProductWorkflowInput, *StatisticsOursProductWorkflowOutput]() + + // 1. 调用工具统计我们的商品 + c.AppendLambda(compose.InvokableLambda(w.callStatisticsTool)) + + // 2. 生成 Excel 并转图片上传 + c.AppendLambda(compose.InvokableLambda(w.generateExcelAndUpload)) + + return c.Compile(ctx) +} + +func (w *statisticsOursProduct) callStatisticsTool(ctx context.Context, input *StatisticsOursProductWorkflowInput) ([]statistics_ours_product.StatisticsOursProductItem, error) { + req := statistics_ours_product.StatisticsOursProductRequest{ + Page: 1, + Limit: 100, // 假设取前100条 + Serial: []string{input.StartTime, input.EndTime}, + } + + return w.toolManager.Recharge.StatisticsOursProduct.Call(ctx, req) +} + +func (w *statisticsOursProduct) generateExcelAndUpload(ctx context.Context, data []statistics_ours_product.StatisticsOursProductItem) (*StatisticsOursProductWorkflowOutput, error) { + // 2. 获取模板路径 (假设在项目根目录的 assets/templates 下) + cwd, _ := filepath.Abs(".") + templatePath := filepath.Join(cwd, "assets", "templates", "statistics_ours_product.xlsx") + fileName := fmt.Sprintf("statistics_ours_product_%d", time.Now().Unix()) + + // 3. 转换数据为 [][]string + excelData := w.convertDataToExcelFormat(data) + + // 4. 生成 Excel + excelBytes, err := w.toolManager.Common.ExcelGenerator.Call(templatePath, excelData, 2, 2) + if err != nil { + return nil, fmt.Errorf("生成 Excel 失败: %v", err) + } + + // 5. Excel 转图片 + picBytes, err := w.toolManager.Common.ImageConverter.Call(fileName+".xlsx", excelBytes) + if err != nil { + return nil, fmt.Errorf("Excel 转图片失败: %v", err) + } + + // 6. 上传 OSS + url, err := w.ossClient.UploadBytes(fileName+".png", picBytes) + if err != nil { + return nil, fmt.Errorf("上传 OSS 失败: %v", err) + } + + return &StatisticsOursProductWorkflowOutput{ImgUrl: url}, nil +} + +// convertDataToExcelFormat 将业务数据转换为 Excel 生成器需要的二维字符串数组 +func (w *statisticsOursProduct) convertDataToExcelFormat(data []statistics_ours_product.StatisticsOursProductItem) [][]string { + var result [][]string + for _, item := range data { + row := []string{ + item.OursProductName, + fmt.Sprintf("%d", item.OursProductId), + item.Count, + item.TotalPrice, + item.SuccessCount, + item.SuccessPrice, + item.FailCount, + item.FailPrice, + item.Profit, + } + result = append(result, row) + } + return result } diff --git a/internal/services/dtalk_bot_test.go b/internal/services/dtalk_bot_test.go index 2b8223f..6180016 100644 --- a/internal/services/dtalk_bot_test.go +++ b/internal/services/dtalk_bot_test.go @@ -60,7 +60,7 @@ func run() { // 初始化Redis数据库连接 rdb := utils.NewRdb(configConfig) // 初始化仓库层 - repos := repo.NewRepos(sessionImpl, rdb) + repos := repo.NewRepos(sessionImpl, configConfig) // 初始化包级别的Redis连接 pkgRdb := pkg.NewRdb(configConfig) diff --git a/tmpl/excel_temp/recharge_statistics_ours_product.xlsx b/tmpl/excel_temp/recharge_statistics_ours_product.xlsx new file mode 100755 index 0000000000000000000000000000000000000000..8d5b5a301642c7c87f355460c49b3ecf5a7d3d09 GIT binary patch literal 9787 zcma)i1z1#D*FW7cv~+h%O1E@}bcYO`LnugtNJ^JKEJ)rn!VRr%5u;!NDz-LSaD6{@%mRo1b;EJH&u4BcW`D^29sff2M~Uc zHSo-pvq3^Ya6&;q0RBm4?BKuxvb9NzZj*&($CkYGdjNd0=U}E#eM;{a!VjS!=@jUJK(c&Y1Q(WzOVDa5bR+>(C=Shr%e!rhaMzZ*+z5FAP8-e0FRfFnua?Khiy~O{SZZ0IkYDfXmBw{~a_bmy zH@>aztltM#uJQ{*&n@apANa2@59=sf2_oKb8wllY=)i3gIM2(L=eEr*bd8Vh&BLCp z-Cds?oU^d3GTrQyCUk5o??JQgK&$M-HTZR6ywh*b?IvjV(2$Pwflvx+6%=n*;C;&l zk(Vake7{z=qs8<6+U^AQcXS!z_Tq)X=mNp$V*C?bQ+p@#M|j`G7%Fv;VRtPn+@hf# zF^?9q=NznM?DtXA3|o0qI@DqyQ~SDozZiEbp1NM4Om+52brxq|-r>83+0rnTmEiEh zWXp=~w~;+-)XABlJ9$Icx7RHada*Lr$S2GgV4mf8yiI`2LU$}fg+CI&JjM+(z;b-Go4A_7|gpF8*bRVZ_hv1W*YA4hxWK{Fq~q^j#rUq-BSYszwE({)i+K z;cNEx5czi*&`nPrt#K~6-S|4wKIJ~?9BcY!%~@lcQe7z|HK=s5ce+|wp3E?DAPZ51 zM4#x;D!yJsSQw`wRClPp5;|`CaZ`wCy?q90U*~Q-W5%204UAYc6Y~N+r2k}0y6uF5nR{S;7epes17mD9=E+W~g z#<=ixKG;d6C1`aeIJ7_W_TGwNF$`LI=8(%z|I}9yhKME6hVSD*>w2D(>57%w+q}cv z6?|SN)cEVKlAie+y>UBrZcJj^DEsg5@c`B}TjHgHDY)DdvRsqhucy%ZYYv{UQm4SN zpim(MMk&nqwh;?E8f`M8ZPxZmeTq$6vWv)`8k#`A8hZ&p!G#ZE_RnI1#;)67pw|mO zo>#b~a#9HgXvb#BYHHcH;wyE*@Me+N?9Fsde?qeuiyWCR5Xh`6@}mns5Wlm=$&Lz| z?2+79r<3Z!>ZZSCP+HYqj}*Jt-riiDzL=9AEXgmkuhF|Zrlccdp-I;-dQNw`(=t0+ zsi1OcvkNpu-+8@zT{1rAP2z{zj1G~G%bB5ckM?Nb|L$d=!H|P&eyqvA6QKPhaJP2? zI$N2WyZq^k%yw{sEWm3g4+{bDOT}Q z9>`9;PJhQij_a0Mjr#K8F2Yv&9M4#mxL>OgA%dCBIJ{N*=?r}y@E(lRhIMaaxt8pmSA+jJkKB3-rAJw z^2(ZL&=nVi^R~()TcE`xc_5x9An6Vvs1QhRWZtPLzK0b8+acU|{YM z*+g=lDy^5B0$HAzx-+5rVqN}#!T63TRqGe!>`Z>Pw6TMS*8?%%yHq?M+BD_Bq}(BQ7kMQi-jor5%Yx~;$5d6IO?rMolu*1#&yMf z{nE++Ychf20q?ZGLfj2trg!6F!?k}h!XZ`85x<4MK7()dv6d;8oHA5?Q+i_Dh-XYH z0-+MvQR9d!e%AHbQPQTa71rGwdinEW?=%K1SNx{qH1}tkCeTC|dHK5@B`OlaTLnlv zGW4>dcPBk~Rf_cuk!?ontHO0x=>NB&KmMJ94c*1c+}8XL7Zh;w9pwsazRh6!eRM&8 zll>t6VZ8_1Ly?4B*e#SN!r_}shg3s7Zc{eZ*SliwUo>KCcE@B=!wE+~X8a99sMXJ@ zs3b)7qUsz)L~=FPRPU1mDdk?T2L6nl2C0jNoBm!!)13KQ0bt{^w>Nu|1HX#9uo z;qI%&Vk%TJ1ic8YywCv5Ri-u z&!@f}83_6iGfn_H?;FhR+_r5RlmE#Pz-&%J=a;S2_MZQEn)7zYvMX zeV=e7e1Dxkaw|fYl`F~G3_9Jbq-AZs-Ke!E^;&@^LbU;9P`!ZRIo5V~OTChU77lzy zay%2e-4nu#Ne8z`GDVEf-%98#@v4r-&EGv({NWg~eCUwB=E6iMwv*%AIj^H{Pxu(k z`Vxemma{g-;mCNXkCRZPV=aL1d}vXuFm`^J$-hj-n?aY|ZBQVSF3!qNjS2evodWv> z$UPE3Th?RNn`C5)zd$L9g<&s!W3~c#N$(CN#ri27?cxIcq+WhR`cx!_vy%tn>_)0?yGqM0UDemdR&j zE-$1U2>J4D$79HL2g1FaJWx4;TbiB`Q@G_XuP|R>*h<3vep?AD1nuO<*vy152 z1Zfv(Wm~bo5sGOK@T?CNDr8ZQ9}IQQHZaYKfs{k`H=+czUSwj#?@5s;!iTIyKV?s- zxU0x8oX7_SA!o3>FLuCwh^))C`WWMoJin9w(gDsLn?cN&O+uTJsN)R^Ni515)uaXN z7^0pj3N??%E39TSyvg(WszG-$?h@=<@@FBywbla1Eu%>62!VZ2e z(R$KC0GT$4tf!^H=yA>(O5{Lugo%G?^1dyuBR(R~3YSt`KhZ?o9FJy)^To7Zv4K`q zIWXN(AP<00_bh<19r|lXGT;#X`LPqdkARA;rdRcGZAq%$xz-@zYG9-5riOs8^K8*k z-rCaaTKkDPOVPP%wY21plbL}5EzZSMS{MXxzL>csl%L9b-#2@`c$+o@{wWEmFZ@Gw zkZcL~_6$^jL8yc?JqKd_gmsrOQe)QXWt)Orz-b+y~hjnPC6FE|fsnSNFI$+~iQ5=gKl-qkP zsG8J4b_MN5gdFpEr%5i`RWgS*)N}8g z+Q{PTT^CA~k`JXu53sFpmze`qtNpH0xopHD{ud80zn=_}`<%Nm!FyE=@aOR~2L7XP zwla1yH&b(QdTD3r{J76CA61a;5P^VQX<8u;no9{~W~S(KAqPPTwnl|3kR^pCg>ILf z=c9JTSRdq(1^VH_W-|ID@0npbA*)HiGPN|HEFe{<8@qV zj5jZEyT1N&|9Jksv$A}-#sVWLpY^!fW$m1GX16}HjLnDh?vdg7ZhbBS+_ztS2KZkJ zX~*B0L9ay<3^K5McmI0p=+9pmW_WtJB`h+hG!aBl3&62VZcB@p#R!0n%LU| ze{2)gRP0mO0IxHu9*nL9*`r1S>68O$tm2Z3WGh{~l8JczG%BJG!sRFKzuO?}TIOqXfezG=I^>7q7*K?>I72`0A@-(I zNKmhHe7kH;K2qJG1l4=>l&xaFsUocbv;#@4Avm=4Jk9m@SQW16axBR;!??VRbEsH^7A;7>#af=pD$S_xN7sgzv3O>&>1(nJKyxKw|YN$$LYwqS;#9e z7Qh-p9&o`hvFCOU-y^=jnEg0v0Z8Bat{HioH|AzmH6H@{-fs!a2U?h|H+h6y$2(gH zZM@p7L3*VvJ8&jLL8xQ0!e?NF?=X!nTZ@rKg?th@o6$8)bu2Z}sUW4s;~?ee%|U!! zY_{g(pydt}zMj*4RTFkSweuR9Azn69qO7N|K$@qn#jQ0hx`v=YNTyO}EK4m#m-F)n zEw&?Hxji2}w&gM##)RDmjEo`c1h%NueR#|x5}t-3k;4wp%X4acSp&PZDJNc^&x%^|9G7i^$#My zNaH_5bUqm6`k{wReq3(^*;ktLG{h?wDN7=YL8(6rtpu)iKI_>zAmJ+&4|3f>m6>^Vb@$5$IYazgUdmVqq$}$0f!vj zc%GU?viDTLSy!)%;|h(NL)7dACK=OZq6_&RVx7|QP%akzx$9l6nx6YmQ+?r2 zOoo08LF<}3y_e5*KM5R?XhS=D&k<{jU*#QnLQe!oE@cXkc*M^UQf9rOERK`aCrP}h zkg%R5aQUYGl&y(WN$P7E|C6NV#gD{agxg%>azx$t&O0*ql8E6Y1TW4iEI@?Co<{D1 z?)w*a1Ilsx7vJ4x!ek02%}46ZDfhN>(+*b6j8JYrPP)>Hw`h!KJ;%J>JSP!Qm&H`6 zKe!MHPZ{UQky~zbDRffvL~VL7PP#ig=bAHNU?BrSxW>jY(H48UDCJrzHxW2 z`F)UCu-!L&amBn7zax@J*DJ0+<0#k%U*(^05}Wy~LOOJ3r#xNQ%U6y#Y3Yey z06>%L3?*1v*~tjnXiPlmnC!t_xiE?_Z?#SX(6&~m@WL+KZpk=b<7qh3El0Q>(?_GZ zU2`@Ys16GuV&|vfHuy6U+qKdMyjxrb5g&`7}zV_ied^O^9l+Wka9^x1%r*~Syb9ZERT44Nmfmbb1Xqd_kxAVyXhM0-O<<+P!sDWE&v0&0 zSqRiHKfeXG8kTdP*CUyz$D>Zw-D?;v7fdB{NosMK&nbws`bb(&%kH^yboemaSzMKO z4Gk#1hfLlDy8Rk?N4?e9I`odKA!)S*mxtqaX3auiwd!^OWe*BCG=%a{UH9Wgc>ywn z93Aj4Q7u_1C%(8rqr@|NZJsIECFJxBD29ENX|_GP-`S$h_B$xgb{i-;OI%)&Y8JTF zc-44pqba~I^^;3ph0z&jqD^n;P(L6{PqxcgIIaXV$`od&FB$HdtTSyz16jN2icFqZUNq{f3>mB$j#!BgFKHAE z^vT64B#x16Oim~^O`lZQyiM>Rd!|ptA`WznZtwD{8P+@DWcPzXx~>C08+Luq+p-)P z^C^hii|8_G5wC(3u5>UPm1LV)-U8lU28xE%twy0ohzPBOyyQ|h-QIo7?hT7~RWIg) zqfeO*>QR1gk=E1alv|w;_lf-1FchOoUUh1s!bd?)qt9mqW@_t&mbTO&&kc0c8@Ws= zB?1+7YbwKx)f=^~D8q|Z@17HqGhmfSTRB!>KKOV&-F}h&hNp1sh3MXkvk4@>x6x0k z5mKnxC&>Jct3(6fpm{V9xi^z5sX1SSE2vCVYjX!aTSbk1lE=d%Z<1JuC5uv{)WJN% z&4gFW)~D`(s8WO@iTfdwj9WeikQ}^#S;h@bC-0BMjAyG1SwT<1iWgR~#dXRFgMfp? zRxgy9cs7h!ttrQjPt@+KgA`RKBuAYq0#k!s7>-lpCaXFwKFb&uE}sk?rLvWm;%I-p z&M|2PL#ZCvX9Gxw#fg!z1K@)%eI#_MVf49S-lS&6*o=f^)SL@l?=df?m35sulEfr= z8L4NU)5W|eV)=Zl_k#X&fIb!dGd*0MZxwY+HoL11h?sbl)F!zSM{nt=-^%ea)FP_l za$h=-u-Y81<}iUf2kqH~4w=W!qp{+1aO@{=_YGw1jLv9Y4gPu#dhCCWUd=m44wm)D za(P;KG`nR^dF<5rjG23e_*&ToqM<)Cgt~3N>C?l}E(`7fZH5hI2WDLO?R+@q;Bb9w zN66MO<+am$zF%vk89etq%GpvBEn4(m0Sn((TRl3uO_GuPI2F%>eYhI~ioMOoXtlOn z0)r|OYom1hY-ggf=ZLM{g{B7D%S%SSl_uj!+a3Q%#$v|(+Sb<59XAzp>r=B0-q&?L zG%L;*M?Dky!l;PK;mSfAG;g2z;rZMWB@W(`u#1+W=e7k$jhlTJ{ra4oXOb}Y{gvK; z05wKrrsykiS$}kyPOE$8%iFfCN<(3!>ksJ!x#U^`gD<)6Hr6XAScgf|n?Xlul^&jx z!C7Y@#!G>bxt4p+*GG#{G?~S9|+?hIuU>?ib&^DlZ>!$1~C3#Gfm!j>zzR zUs<{i_CcUOW}+3R;Cz@{j})n!JLnPM5xA6o2^8}NxM7lo2Ef|*Zkl0xGLwbrFa`D? z$b*nkFaeUba72U~yoh(W0MRiK0TR+E8ralfAs@CT!c6hiRmf}MHyca&7^hTa#%#Grrk)og zUX@=SQ0G=XAj6QITD=S=cd{*2JV-E$0GJa>irJ?E1nT4j!}bsR*AuiDh>@@wA%Q!V z8R>WHXhz;Q8>`pBM;UjgrbxQVejNS)JnOGORc+bQpdO^NYS@UGPsOVz&}qh^T<81N zAbE|zM9c!LuH1g;Vg?w^ER8Jd<0yZqAiY2i^hAl`QR~g|xC&;uDx^}lCH9c=u+=9$ zvXjTY_;pADSMuP|pdK5Ikhw=f(1vDUufpTd^D-KVG6+VM0iCbx$d`GDY$;YaI;fG_ zvw3s{G-C`^1SFp;*tL`u9+kDCloWFr@6lBtT?K3qy1XKS=2rNRyup|OHmB!+pYrUo zG_1IcNHyunonSQ~Ltr)E6wM+9B>vFXWAn&T@;HU*fd5Rv4wW(?!aEbV%%A5qo*C&+ zYG#o2)JI9CidKkkB*rO8tgOBLi<%k0%@ihpoQsGPiREiYG)coCYh7fd25?T@EHIeg zj@x~j!U>&I@u?6RMjFf@E1lFU&>|U%wp!VdOef|s`p6UKr=f>ap)%77Pu;A1J14@4 zSleV$HYzDkD7pL0VYlRCkc0E(x78JHMC0j@V7Fw_`{MBG3b+oOjvM zceP(RuU+wEvFcLa+$USMag9u+H0Zl5VZk|y?f@^CXL>ZMWzPiZOQmwPlj3VAsNpWg`RUm=q{hd7K|EF>Z#!Q72rOKW-B9l z5Z!Th4L|%i`TTpH1rB`jF?2Gw`7^)b#p~Ai0KT^j&aoi>O~dj?SsF7U+sOv#KJq&P zY&I*n<6z9Wuu|+Rn7#5%lz$kd!HUs7Xl@c!VVbOmk4(DWOj-6eYam=CGhok)X!LVc z@e{G{b!%2R_6EIJ^ph@Wnu7LFcW8%c*gZA*9^k(z@P3|!Dq7!Lb@XX4KYi@Wu^n|~ zkqmw=$^2)+rj-8NO?Jw5{ijmh86?UI0$ocCAzlq|j=X`5*Y@^Bd&4V&N!j8f9E=<4 z(P^$WQ8?lL-r2J)fOAPWxMw3yu0jJx?y|upr54Pnl6rxOYGDgs^;#U6l6v$MNyDf= z3|)&%Ol-BcMUUxL4M_6^P-pEuP(AJG+=%xO;xd$WI%O_)|9{5%{|(Mwn>nX_FpTwJ zI0?X4a0uro*<*t1uOP&K&{eSRU;_kR1}=#XHpi#MtIBTJ$dZ4V7W9qkjt^x<96IZ% zEq5SyB+DVRhp~rix*U@JvN*yU!YV%rU;cqX7O<^Q(R76E%~|fQL>5wA>xn>uBQIT1 zY;Rv<&ucZD(0d*&;dYYK%HCs1-^WYDg+rb-lE$5*;v8QXtCHe>_=v7bUM~EkWx9zy zPEOM+h%tF~+J__J`5K-p%)zaYbXE!JwU@onAyWBh+HDyuPbqr`PA-eP`O`+5o%_G& zt1=DD7;yvJ9bQukl$yjl2^9lTrjk*X$%%W(Pea#VP&{*wU_0IKnQHm{Kwfa7<7^2I z(V&8JB9HkHU2%Im7jruoLv;@ab7%d>Fiq+E0YxZw?4V1U=8ha)4mAhkaATuY^FpdM z=*f##&a?P*zvGK^dLt;&H{mHVd!%$Njj+9L;`K+?cFE#nvWppcBMvZ^~cwJJ?9ToTpQyN$<<|07U6* zAY!J@;|>T{nG_@_T7`llm%)bkT1lYg@PFSqumoIhjQzvN_qgK_^B;r>&? zpYgk263)So{V3t@Xx{(-vn#>>VErpy`@4nwnXvt((e0mXztXpVPWjIu^e+MH;Cct} zl>Z6af1C7Ub;Qs1xWd6dSNM_n?^=o9XZ~lk#3S#|Rjd48yuWHEl;vO_w+G;ABn$|6 LFdYfS