From 0f31c1e7c662881371c72cc45197d4739ca4861b Mon Sep 17 00:00:00 2001
From: yuance <182865460@qq.com>
Date: Wed, 17 Sep 2025 11:45:57 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E4=BC=81=E4=B8=9A=E4=BF=A1?=
=?UTF-8?q?=E6=81=AF=E3=80=81=E7=9F=A5=E8=AF=86=E5=BA=93=E3=80=81=E5=AE=A1?=
=?UTF-8?q?=E8=AE=A1=E6=8A=A5=E5=91=8A=E7=94=9F=E6=88=90=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
pom.xml | 12 +
.../ai/config/KnowledgeBaseConfig.java | 16 +
.../gxwebsoft/ai/config/TemplateConfig.java | 12 +
.../ai/constants/KnowledgeBaseConstants.java | 19 +
.../ai/controller/AuditReportController.java | 144 +++++++
.../controller/KnowledgeBaseController.java | 59 +++
.../gxwebsoft/ai/dto/AuditReportRequest.java | 42 ++
.../ai/dto/KnowledgeBaseRequest.java | 20 +
.../gxwebsoft/ai/enums/AuditReportEnum.java | 45 ++
.../factory/KnowledgeBaseClientFactory.java | 23 ++
.../ai/util/KnowledgeBaseCreate.java | 384 ++++++++++++++++++
.../ai/util/KnowledgeBaseManage.java | 145 +++++++
.../ai/util/KnowledgeBaseRetrieve.java | 110 +++++
.../ai/util/KnowledgeBaseUpdate.java | 384 ++++++++++++++++++
.../controller/EnterpriseController.java | 147 +++++++
.../enterprise/entity/Enterprise.java | 67 +++
.../enterprise/mapper/EnterpriseMapper.java | 13 +
.../mapper/xml/EnterpriseMapper.xml | 7 +
.../enterprise/service/EnterpriseService.java | 13 +
.../service/impl/EnterpriseServiceImpl.java | 17 +
src/main/resources/application-dev.yml | 13 +
src/main/resources/application-prod.yml | 13 +
.../templates/audit_report_template.docx | Bin 0 -> 815504 bytes
23 files changed, 1705 insertions(+)
create mode 100644 src/main/java/com/gxwebsoft/ai/config/KnowledgeBaseConfig.java
create mode 100644 src/main/java/com/gxwebsoft/ai/config/TemplateConfig.java
create mode 100644 src/main/java/com/gxwebsoft/ai/constants/KnowledgeBaseConstants.java
create mode 100644 src/main/java/com/gxwebsoft/ai/controller/AuditReportController.java
create mode 100644 src/main/java/com/gxwebsoft/ai/controller/KnowledgeBaseController.java
create mode 100644 src/main/java/com/gxwebsoft/ai/dto/AuditReportRequest.java
create mode 100644 src/main/java/com/gxwebsoft/ai/dto/KnowledgeBaseRequest.java
create mode 100644 src/main/java/com/gxwebsoft/ai/enums/AuditReportEnum.java
create mode 100644 src/main/java/com/gxwebsoft/ai/factory/KnowledgeBaseClientFactory.java
create mode 100644 src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseCreate.java
create mode 100644 src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseManage.java
create mode 100644 src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseRetrieve.java
create mode 100644 src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseUpdate.java
create mode 100644 src/main/java/com/gxwebsoft/enterprise/controller/EnterpriseController.java
create mode 100644 src/main/java/com/gxwebsoft/enterprise/entity/Enterprise.java
create mode 100644 src/main/java/com/gxwebsoft/enterprise/mapper/EnterpriseMapper.java
create mode 100644 src/main/java/com/gxwebsoft/enterprise/mapper/xml/EnterpriseMapper.xml
create mode 100644 src/main/java/com/gxwebsoft/enterprise/service/EnterpriseService.java
create mode 100644 src/main/java/com/gxwebsoft/enterprise/service/impl/EnterpriseServiceImpl.java
create mode 100644 src/main/resources/templates/audit_report_template.docx
diff --git a/pom.xml b/pom.xml
index ee63fc0..c64a5b4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -363,6 +363,11 @@
spring-boot-starter-websocket
+
+ com.aliyun
+ bailian20231229
+ 2.4.0
+
@@ -402,6 +407,13 @@
17
+
+ org.apache.maven.plugins
+ maven-surefire-plugin
+
+ true
+
+
diff --git a/src/main/java/com/gxwebsoft/ai/config/KnowledgeBaseConfig.java b/src/main/java/com/gxwebsoft/ai/config/KnowledgeBaseConfig.java
new file mode 100644
index 0000000..d34d1ae
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/config/KnowledgeBaseConfig.java
@@ -0,0 +1,16 @@
+package com.gxwebsoft.ai.config;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Data
+@Component
+@ConfigurationProperties(prefix = "aliyun.knowledge-base")
+public class KnowledgeBaseConfig {
+
+ private String accessKeyId;
+ private String accessKeySecret;
+ private String workspaceId;
+
+}
\ No newline at end of file
diff --git a/src/main/java/com/gxwebsoft/ai/config/TemplateConfig.java b/src/main/java/com/gxwebsoft/ai/config/TemplateConfig.java
new file mode 100644
index 0000000..354fc51
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/config/TemplateConfig.java
@@ -0,0 +1,12 @@
+package com.gxwebsoft.ai.config;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Data
+@Component
+@ConfigurationProperties(prefix = "ai.template")
+public class TemplateConfig {
+ private String wordTemplatePath;
+}
\ No newline at end of file
diff --git a/src/main/java/com/gxwebsoft/ai/constants/KnowledgeBaseConstants.java b/src/main/java/com/gxwebsoft/ai/constants/KnowledgeBaseConstants.java
new file mode 100644
index 0000000..340b215
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/constants/KnowledgeBaseConstants.java
@@ -0,0 +1,19 @@
+package com.gxwebsoft.ai.constants;
+
+public class KnowledgeBaseConstants {
+
+ public static final String[] KEY_WORDS = {
+ "",
+ "审计依据 法律法规 审计业务约定书 经济责任审计管理办法 中共中央办公厅 国务院办公厅 党政主要领导干部审计规定 国家法规 公司管理制度 年度工作目标 党政主要领导干部经济责任审计规定",
+ "审计目标 经济责任审计目标 资产负债损益真实性 合法性 效益性 经济指标完成情况 重大决策执行 遵守财经法规 国有资产保值增值 经济责任评价 任职期间履职评价 责任界定 业绩评价",
+ "审计对象 审计范围 被审计领导干部 [职务] [姓名] 任职期间 [开始日期]至[结束日期] 职务任期 重大问题追溯 重要事项延伸 审计时限 下属子公司 代管企业",
+ "被审计单位基本情况 单位概况 组织机构 人员结构 财务会计政策 合并口径财务数据 资产总额 负债总额 营业收入 利润 内部控制制度 子公司 代管企业 职能部门设置 合并财务报表",
+ "审计内容 审计重点 贯彻执行经济方针 重大决策执行 发展战略 年度目标完成 法人治理结构 内部控制 财务真实性 风险管控 党风廉政建设 以往审计整改 三重一大经济决策 资产管理 采购管理 债权债务",
+ "审计风险 证据不充分 评价不客观 内部控制失效 法律法规变化 风险应对策略 审计证据充分性 评价客观性 内部控制审查 法规政策跟踪 重要性水平",
+ "审计方法 穿行测试 趋势分析 比率分析 访谈法 数据分析 分析性程序 检查 监盘 观察 询问 函证 计算 重新执行",
+ "审计步骤 时间安排 准备阶段 实施阶段 报告阶段 归档阶段 审计人员安排 资料收集 实质性程序 审计报告编写 交换意见 审计归档 进点会 进度表",
+ "审计组织实施 审计组人员分工 职责分配 审计工作计划 前期调研 审前培训 实地审计 质量控制 内部培训 沟通协调 分级复核 集体讨论 重大事项汇报 里程碑事件清单 审计工作组 项目负责人 主审"
+ };
+
+
+}
\ No newline at end of file
diff --git a/src/main/java/com/gxwebsoft/ai/controller/AuditReportController.java b/src/main/java/com/gxwebsoft/ai/controller/AuditReportController.java
new file mode 100644
index 0000000..ec8a757
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/controller/AuditReportController.java
@@ -0,0 +1,144 @@
+package com.gxwebsoft.ai.controller;
+
+import java.io.FileOutputStream;
+import java.io.OutputStream;
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.servlet.http.HttpServletResponse;
+
+import org.apache.poi.openxml4j.util.ZipSecureFile;
+import org.apache.poi.xwpf.usermodel.XWPFDocument;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.alibaba.fastjson.JSONObject;
+import com.gxwebsoft.ai.config.TemplateConfig;
+import com.gxwebsoft.ai.dto.AuditReportRequest;
+import com.gxwebsoft.ai.dto.KnowledgeBaseRequest;
+import com.gxwebsoft.ai.enums.AuditReportEnum;
+import com.gxwebsoft.common.core.web.ApiResult;
+import com.gxwebsoft.common.core.web.BaseController;
+import com.gxwebsoft.common.system.entity.User;
+
+import cn.afterturn.easypoi.word.WordExportUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.http.HttpUtil;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+
+/**
+ * 审计报告控制器
+ * @author GIIT-YC
+ *
+ */
+@Tag(name = "审计报告")
+@RestController
+@RequestMapping("/api/ai/auditReport")
+public class AuditReportController extends BaseController {
+
+ @Autowired
+ private TemplateConfig templateConfig;
+
+ @Autowired
+ private KnowledgeBaseController knowledgeBaseController;
+
+ private String invok(String query, String knowledge, String history, String suggestion, String userName) {
+ // 构建请求体
+ JSONObject requestBody = new JSONObject();
+ JSONObject inputs = new JSONObject();
+ inputs.put("query", query);
+ inputs.put("knowledge", knowledge);
+ inputs.put("history", history);
+ inputs.put("suggestion", suggestion);
+
+ requestBody.put("inputs", inputs);
+ requestBody.put("response_mode", "blocking");
+ requestBody.put("user", userName);
+
+ // 发送 POST 请求
+ String result = HttpUtil.createPost("http://1.14.159.185:8180/v1/workflows/run")
+ .header("Authorization", "Bearer app-d7Ok9FECVZG2Ybw9wpg7tGu9")
+ .header("Content-Type", "application/json")
+ .body(requestBody.toString())
+ .timeout(600000)
+ .execute()
+ .body();
+ // 解析返回的JSON字符串
+ JSONObject jsonResponse = JSONObject.parseObject(result);
+ // 获取data字段
+ JSONObject data = jsonResponse.getJSONObject("data");
+ // 获取outputs字段
+ JSONObject outputs = data.getJSONObject("outputs");
+ // 获取outputs中的result字符串
+ String resultStr = outputs.getString("result");
+ return resultStr;
+ }
+
+ /**
+ * 生成审计报告-单一模块
+ */
+ @Operation(summary = "生成审计报告-单一模块")
+ @PostMapping("/generate")
+ public ApiResult generateAuditReport(@RequestBody AuditReportRequest req) {
+ final User loginUser = getLoginUser();
+
+ KnowledgeBaseRequest knowledgeBaseRequest = new KnowledgeBaseRequest();
+ knowledgeBaseRequest.setKbId(req.getKbId());
+ knowledgeBaseRequest.setFormCommit((req.getFormCommit() > 10) ? req.getFormCommit() / 10 : req.getFormCommit());
+ String knowledge = knowledgeBaseController.query(knowledgeBaseRequest).getData().toString();
+
+ String query = AuditReportEnum.getByCode(req.getFormCommit()).getDesc();
+ String ret = this.invok(query, knowledge, req.getHistory(), req.getSuggestion(), loginUser.getUsername());
+
+ return success(ret);
+ }
+
+ /**
+ * 生成并下载审计报告
+ */
+ @Operation(summary = "生成并下载审计报告")
+ @PostMapping("/download")
+ public void downloadAuditReport(@RequestBody AuditReportRequest req, HttpServletResponse response) {
+ // 保存原始的安全阈值
+ double originalMinInflateRatio = ZipSecureFile.getMinInflateRatio();
+
+ try {
+ // 降低Zip bomb检测的阈值，解决模板文件的安全检测问题
+ ZipSecureFile.setMinInflateRatio(0.001);
+
+ // 准备模板数据
+ Map map = new HashMap<>();
+ map.put(AuditReportEnum.AUDIT_TITLE.getCode().toString(), req.getFrom0());
+ map.put(AuditReportEnum.AUDIT_BASIS.getCode().toString(), req.getFrom1());
+ map.put(AuditReportEnum.AUDIT_OBJECTIVE.getCode().toString(), req.getFrom2());
+ map.put(AuditReportEnum.AUDIT_SCOPE.getCode().toString(), req.getFrom3());
+ map.put(AuditReportEnum.UNIT_OVERVIEW.getCode().toString(), req.getFrom41());
+ map.put(AuditReportEnum.ORG_AND_PERSONNEL.getCode().toString(), req.getFrom42());
+ map.put(AuditReportEnum.AUDIT_CONTENT_METHODS.getCode().toString(), req.getFrom5());
+
+ // 使用Easypoi的Word模板功能
+ XWPFDocument document = WordExportUtil.exportWord07(templateConfig.getWordTemplatePath(), map);
+
+ // 设置响应头
+ response.setContentType("application/vnd.openxmlformats-officedocument.wordprocessingml.document");
+ response.setHeader("Content-Disposition", "attachment; filename=audit_report.docx");
+
+ // 输出到响应流
+ OutputStream out = response.getOutputStream();
+ document.write(out);
+ out.flush();
+ out.close();
+
+ } catch (Exception e) {
+ throw new RuntimeException("生成审计报告失败", e);
+ } finally {
+ // 恢复原始的安全阈值
+ ZipSecureFile.setMinInflateRatio(originalMinInflateRatio);
+ }
+ }
+
+}
diff --git a/src/main/java/com/gxwebsoft/ai/controller/KnowledgeBaseController.java b/src/main/java/com/gxwebsoft/ai/controller/KnowledgeBaseController.java
new file mode 100644
index 0000000..ed819e4
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/controller/KnowledgeBaseController.java
@@ -0,0 +1,59 @@
+package com.gxwebsoft.ai.controller;
+
+import com.aliyun.bailian20231229.Client;
+import com.aliyun.bailian20231229.models.RetrieveResponse;
+import com.aliyun.bailian20231229.models.RetrieveResponseBody.RetrieveResponseBodyDataNodes;
+import com.gxwebsoft.ai.config.KnowledgeBaseConfig;
+import com.gxwebsoft.ai.constants.KnowledgeBaseConstants;
+import com.gxwebsoft.ai.factory.KnowledgeBaseClientFactory;
+import com.gxwebsoft.ai.util.KnowledgeBaseRetrieve;
+import com.gxwebsoft.ai.dto.KnowledgeBaseRequest;
+import com.gxwebsoft.common.core.web.ApiResult;
+import com.gxwebsoft.common.core.web.BaseController;
+import cn.hutool.core.util.StrUtil;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Arrays;
+import java.util.LinkedHashSet;
+import java.util.List;
+import java.util.Set;
+
+@Tag(name = "知识库")
+@RestController
+@RequestMapping("/api/ai/knowledgeBase")
+public class KnowledgeBaseController extends BaseController {
+
+ @Autowired
+ private KnowledgeBaseConfig config;
+
+ @Autowired
+ private KnowledgeBaseClientFactory clientFactory;
+
+ @Operation(summary = "查询知识库")
+ @GetMapping("/query")
+ public ApiResult query(KnowledgeBaseRequest req) {
+ Set ret = new LinkedHashSet<>();
+ String workspaceId = config.getWorkspaceId();
+ List keyWords = Arrays.asList(KnowledgeBaseConstants.KEY_WORDS);
+ String indexId = req.getKbId();
+ String query = StrUtil.isEmpty(req.getQuery()) ? keyWords.get(req.getFormCommit()) : req.getQuery();
+ Integer topK = req.getTopK() == null ? 10 : req.getTopK();
+
+ try {
+ Client client = clientFactory.createClient();
+ RetrieveResponse resp = KnowledgeBaseRetrieve.retrieveIndex(client, workspaceId, indexId, query);
+ for (RetrieveResponseBodyDataNodes node : resp.getBody().getData().getNodes()) {
+ ret.add(node.getText());
+ if (ret.size() >= topK) {
+ break;
+ }
+ }
+ } catch (Exception e) {
+ return fail("查询失败:" + e.getMessage());
+ }
+ return success(ret);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/gxwebsoft/ai/dto/AuditReportRequest.java b/src/main/java/com/gxwebsoft/ai/dto/AuditReportRequest.java
new file mode 100644
index 0000000..1fa78be
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/dto/AuditReportRequest.java
@@ -0,0 +1,42 @@
+package com.gxwebsoft.ai.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Data
+public class AuditReportRequest{
+
+ @Schema(description = "审计标题")
+ private String from0;
+
+ @Schema(description = "审计依据")
+ private String from1;
+
+ @Schema(description = "审计目标")
+ private String from2;
+
+ @Schema(description = "审计对象和范围")
+ private String from3;
+
+ @Schema(description = "被审计单位基本情况-单位概况")
+ private String from41;
+
+ @Schema(description = "被审计单位基本情况-机构和人员相关情况")
+ private String from42;
+
+ @Schema(description = "审计内容和重点及审计方法")
+ private String from5;
+
+ @Schema(description = "知识库ID")
+ private String kbId;
+
+ @Schema(description = "生成模块:AuditReportEnum.code")
+ private Integer formCommit;
+
+ @Schema(description = "历史内容")
+ private String history;
+
+ @Schema(description = "修改建议")
+ private String suggestion;
+
+}
diff --git a/src/main/java/com/gxwebsoft/ai/dto/KnowledgeBaseRequest.java b/src/main/java/com/gxwebsoft/ai/dto/KnowledgeBaseRequest.java
new file mode 100644
index 0000000..bee6ee3
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/dto/KnowledgeBaseRequest.java
@@ -0,0 +1,20 @@
+package com.gxwebsoft.ai.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Data
+public class KnowledgeBaseRequest {
+
+ @Schema(description = "知识库ID")
+ private String kbId;
+
+ @Schema(description = "召回内容")
+ private String query;
+
+ @Schema(description = "召回模块（1~9）")
+ private Integer formCommit;
+
+ @Schema(description = "返回TOP切片数量")
+ private Integer topK;
+}
diff --git a/src/main/java/com/gxwebsoft/ai/enums/AuditReportEnum.java b/src/main/java/com/gxwebsoft/ai/enums/AuditReportEnum.java
new file mode 100644
index 0000000..d66b145
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/enums/AuditReportEnum.java
@@ -0,0 +1,45 @@
+package com.gxwebsoft.ai.enums;
+
+public enum AuditReportEnum {
+
+ AUDIT_TITLE(0, "审计标题"),
+ AUDIT_BASIS(1, "审计依据"),
+ AUDIT_OBJECTIVE(2, "审计目标"),
+ AUDIT_SCOPE(3, "审计对象和范围"),
+ UNIT_OVERVIEW(41, "被审计单位基本情况-单位概况"),
+ ORG_AND_PERSONNEL(42, "被审计单位基本情况-机构和人员相关情况"),
+ AUDIT_CONTENT_METHODS(5, "审计内容和重点及审计方法");
+
+ private final Integer code;
+ private final String desc;
+
+ AuditReportEnum(Integer code, String desc) {
+ this.code = code;
+ this.desc = desc;
+ }
+
+ public Integer getCode() {
+ return code;
+ }
+
+ public String getDesc() {
+ return desc;
+ }
+
+ public static AuditReportEnum getByCode(Integer code) {
+ for (AuditReportEnum value : values()) {
+ if (value.code.equals(code)) {
+ return value;
+ }
+ }
+ return null;
+ }
+
+ /**
+ * 根据代码获取描述信息
+ */
+ public static String getDescByCode(Integer code) {
+ AuditReportEnum enumValue = getByCode(code);
+ return enumValue != null ? enumValue.getDesc() : null;
+ }
+}
diff --git a/src/main/java/com/gxwebsoft/ai/factory/KnowledgeBaseClientFactory.java b/src/main/java/com/gxwebsoft/ai/factory/KnowledgeBaseClientFactory.java
new file mode 100644
index 0000000..5c4beeb
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/factory/KnowledgeBaseClientFactory.java
@@ -0,0 +1,23 @@
+package com.gxwebsoft.ai.factory;
+
+import com.aliyun.bailian20231229.Client;
+import com.aliyun.teaopenapi.models.Config;
+import com.gxwebsoft.ai.config.KnowledgeBaseConfig;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class KnowledgeBaseClientFactory {
+
+ @Autowired
+ private KnowledgeBaseConfig config;
+
+ public Client createClient() throws Exception {
+ com.aliyun.teaopenapi.models.Config authConfig = new com.aliyun.teaopenapi.models.Config()
+ .setAccessKeyId(config.getAccessKeyId())
+ .setAccessKeySecret(config.getAccessKeySecret());
+ // 下方接入地址以公有云的公网接入地址为例，可按需更换接入地址。
+ authConfig.endpoint = "bailian.cn-beijing.aliyuncs.com";
+ return new com.aliyun.bailian20231229.Client(authConfig);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseCreate.java b/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseCreate.java
new file mode 100644
index 0000000..7ef388a
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseCreate.java
@@ -0,0 +1,384 @@
+package com.gxwebsoft.ai.util;
+
+import com.aliyun.bailian20231229.models.*;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.security.MessageDigest;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 创建知识库
+ * @author GIIT-YC
+ *
+ */
+public class KnowledgeBaseCreate {
+
+ String ALIBABA_CLOUD_ACCESS_KEY_ID = "LTAI5tD5YRKuxWz6Eg7qrM4P";
+ String ALIBABA_CLOUD_ACCESS_KEY_SECRET = "bO8TBDXflOwbtSKimPpG8XrJnyzgTk";
+ String WORKSPACE_ID = "llm-4pf5auwewoz34zqu";
+
+ /**
+ * 检查并提示设置必要的环境变量。
+ *
+ * @return true 如果所有必需的环境变量都已设置，否则 false
+ */
+ public static boolean checkEnvironmentVariables() {
+ Map requiredVars = new HashMap<>();
+ requiredVars.put("ALIBABA_CLOUD_ACCESS_KEY_ID", "阿里云访问密钥ID");
+ requiredVars.put("ALIBABA_CLOUD_ACCESS_KEY_SECRET", "阿里云访问密钥密码");
+ requiredVars.put("WORKSPACE_ID", "阿里云百炼业务空间ID");
+
+ List missingVars = new ArrayList<>();
+ for (Map.Entry entry : requiredVars.entrySet()) {
+ String value = System.getenv(entry.getKey());
+ if (value == null || value.isEmpty()) {
+ missingVars.add(entry.getKey());
+ System.out.println("错误：请设置 " + entry.getKey() + " 环境变量 (" + entry.getValue() + ")");
+ }
+ }
+
+ return missingVars.isEmpty();
+ }
+
+ /**
+ * 计算文档的MD5值。
+ *
+ * @param filePath 文档本地路径
+ * @return 文档的MD5值
+ * @throws Exception 如果计算过程中发生错误
+ */
+ public static String calculateMD5(String filePath) throws Exception {
+ MessageDigest md = MessageDigest.getInstance("MD5");
+ try (FileInputStream fis = new FileInputStream(filePath)) {
+ byte[] buffer = new byte[4096];
+ int bytesRead;
+ while ((bytesRead = fis.read(buffer)) != -1) {
+ md.update(buffer, 0, bytesRead);
+ }
+ }
+ StringBuilder sb = new StringBuilder();
+ for (byte b : md.digest()) {
+ sb.append(String.format("%02x", b & 0xff));
+ }
+ return sb.toString();
+ }
+
+ /**
+ * 获取文档大小（以字节为单位）。
+ *
+ * @param filePath 文档本地路径
+ * @return 文档大小（以字节为单位）
+ */
+ public static String getFileSize(String filePath) {
+ File file = new File(filePath);
+ long fileSize = file.length();
+ return String.valueOf(fileSize);
+ }
+
+ /**
+ * 初始化客户端（Client）。
+ *
+ * @return 配置好的客户端对象
+ */
+ public static com.aliyun.bailian20231229.Client createClient() throws Exception {
+ com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
+ .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
+ .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
+ // 下方接入地址以公有云的公网接入地址为例，可按需更换接入地址。
+ config.endpoint = "bailian.cn-beijing.aliyuncs.com";
+ return new com.aliyun.bailian20231229.Client(config);
+ }
+
+ /**
+ * 申请文档上传租约。
+ *
+ * @param client 客户端对象
+ * @param categoryId 类目ID
+ * @param fileName 文档名称
+ * @param fileMd5 文档的MD5值
+ * @param fileSize 文档大小（以字节为单位）
+ * @param workspaceId 业务空间ID
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static ApplyFileUploadLeaseResponse applyLease(com.aliyun.bailian20231229.Client client, String categoryId,
+ String fileName, String fileMd5, String fileSize, String workspaceId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.ApplyFileUploadLeaseRequest applyFileUploadLeaseRequest = new com.aliyun.bailian20231229.models.ApplyFileUploadLeaseRequest();
+ applyFileUploadLeaseRequest.setFileName(fileName);
+ applyFileUploadLeaseRequest.setMd5(fileMd5);
+ applyFileUploadLeaseRequest.setSizeInBytes(fileSize);
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ ApplyFileUploadLeaseResponse applyFileUploadLeaseResponse = null;
+ applyFileUploadLeaseResponse = client.applyFileUploadLeaseWithOptions(categoryId, workspaceId,
+ applyFileUploadLeaseRequest, headers, runtime);
+ return applyFileUploadLeaseResponse;
+ }
+
+ /**
+ * 上传文档到临时存储。
+ *
+ * @param preSignedUrl 上传租约中的 URL
+ * @param headers 上传请求的头部
+ * @param filePath 文档本地路径
+ * @throws Exception 如果上传过程中发生错误
+ */
+ public static void uploadFile(String preSignedUrl, Map headers, String filePath) throws Exception {
+ File file = new File(filePath);
+ if (!file.exists() || !file.isFile()) {
+ throw new IllegalArgumentException("文件不存在或不是普通文件: " + filePath);
+ }
+
+ try (FileInputStream fis = new FileInputStream(file)) {
+ URL url = new URL(preSignedUrl);
+ HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+ conn.setRequestMethod("PUT");
+ conn.setDoOutput(true);
+
+ // 设置上传请求头
+ conn.setRequestProperty("X-bailian-extra", headers.get("X-bailian-extra"));
+ conn.setRequestProperty("Content-Type", headers.get("Content-Type"));
+
+ // 分块读取并上传文档
+ byte[] buffer = new byte[4096];
+ int bytesRead;
+ while ((bytesRead = fis.read(buffer)) != -1) {
+ conn.getOutputStream().write(buffer, 0, bytesRead);
+ }
+
+ int responseCode = conn.getResponseCode();
+ if (responseCode != 200) {
+ throw new RuntimeException("上传失败: " + responseCode);
+ }
+ }
+ }
+
+ /**
+ * 将文档添加到类目中。
+ *
+ * @param client 客户端对象
+ * @param leaseId 租约ID
+ * @param parser 用于文档的解析器
+ * @param categoryId 类目ID
+ * @param workspaceId 业务空间ID
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static AddFileResponse addFile(com.aliyun.bailian20231229.Client client, String leaseId, String parser,
+ String categoryId, String workspaceId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.AddFileRequest addFileRequest = new com.aliyun.bailian20231229.models.AddFileRequest();
+ addFileRequest.setLeaseId(leaseId);
+ addFileRequest.setParser(parser);
+ addFileRequest.setCategoryId(categoryId);
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ return client.addFileWithOptions(workspaceId, addFileRequest, headers, runtime);
+ }
+
+ /**
+ * 查询文档的基本信息。
+ *
+ * @param client 客户端对象
+ * @param workspaceId 业务空间ID
+ * @param fileId 文档ID
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static DescribeFileResponse describeFile(com.aliyun.bailian20231229.Client client, String workspaceId,
+ String fileId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ return client.describeFileWithOptions(workspaceId, fileId, headers, runtime);
+ }
+
+ /**
+ * 在阿里云百炼服务中创建知识库（初始化）。
+ *
+ * @param client 客户端对象
+ * @param workspaceId 业务空间ID
+ * @param fileId 文档ID
+ * @param name 知识库名称
+ * @param structureType 知识库的数据类型
+ * @param sourceType 应用数据的数据类型，支持类目类型和文档类型
+ * @param sinkType 知识库的向量存储类型
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static CreateIndexResponse createIndex(com.aliyun.bailian20231229.Client client, String workspaceId,
+ String fileId, String name, String structureType, String sourceType, String sinkType) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.CreateIndexRequest createIndexRequest = new com.aliyun.bailian20231229.models.CreateIndexRequest();
+ createIndexRequest.setStructureType(structureType);
+ createIndexRequest.setName(name);
+ createIndexRequest.setSourceType(sourceType);
+ createIndexRequest.setSinkType(sinkType);
+ createIndexRequest.setDocumentIds(Collections.singletonList(fileId));
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ return client.createIndexWithOptions(workspaceId, createIndexRequest, headers, runtime);
+ }
+
+ /**
+ * 向阿里云百炼服务提交索引任务。
+ *
+ * @param client 客户端对象
+ * @param workspaceId 业务空间ID
+ * @param indexId 知识库ID
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static SubmitIndexJobResponse submitIndex(com.aliyun.bailian20231229.Client client, String workspaceId,
+ String indexId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.SubmitIndexJobRequest submitIndexJobRequest = new com.aliyun.bailian20231229.models.SubmitIndexJobRequest();
+ submitIndexJobRequest.setIndexId(indexId);
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ return client.submitIndexJobWithOptions(workspaceId, submitIndexJobRequest, headers, runtime);
+ }
+
+ /**
+ * 查询索引任务状态。
+ *
+ * @param client 客户端对象
+ * @param workspaceId 业务空间ID
+ * @param jobId 任务ID
+ * @param indexId 知识库ID
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static GetIndexJobStatusResponse getIndexJobStatus(com.aliyun.bailian20231229.Client client,
+ String workspaceId, String jobId, String indexId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.GetIndexJobStatusRequest getIndexJobStatusRequest = new com.aliyun.bailian20231229.models.GetIndexJobStatusRequest();
+ getIndexJobStatusRequest.setIndexId(indexId);
+ getIndexJobStatusRequest.setJobId(jobId);
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ GetIndexJobStatusResponse getIndexJobStatusResponse = null;
+ getIndexJobStatusResponse = client.getIndexJobStatusWithOptions(workspaceId, getIndexJobStatusRequest, headers,
+ runtime);
+ return getIndexJobStatusResponse;
+ }
+
+ /**
+ * 使用阿里云百炼服务创建知识库。
+ *
+ * @param filePath 文档本地路径
+ * @param workspaceId 业务空间ID
+ * @param name 知识库名称
+ * @return 如果成功，返回知识库ID；否则返回 null
+ */
+ public static String createKnowledgeBase(String filePath, String workspaceId, String name) {
+ // 设置默认值
+ String categoryId = "default";
+ String parser = "DASHSCOPE_DOCMIND";
+ String sourceType = "DATA_CENTER_FILE";
+ String structureType = "unstructured";
+ String sinkType = "DEFAULT";
+ try {
+ // 步骤1：初始化客户端（Client）
+ System.out.println("步骤1：初始化Client");
+ com.aliyun.bailian20231229.Client client = createClient();
+
+ // 步骤2：准备文档信息
+ System.out.println("步骤2：准备文档信息");
+ String fileName = new File(filePath).getName();
+ String fileMd5 = calculateMD5(filePath);
+ String fileSize = getFileSize(filePath);
+
+ // 步骤3：申请上传租约
+ System.out.println("步骤3：向阿里云百炼申请上传租约");
+ ApplyFileUploadLeaseResponse leaseResponse = applyLease(client, categoryId, fileName, fileMd5, fileSize,
+ workspaceId);
+ String leaseId = leaseResponse.getBody().getData().getFileUploadLeaseId();
+ String uploadUrl = leaseResponse.getBody().getData().getParam().getUrl();
+ Object uploadHeaders = leaseResponse.getBody().getData().getParam().getHeaders();
+
+ // 步骤4：上传文档
+ System.out.println("步骤4：上传文档到阿里云百炼");
+ // 请自行安装jackson-databind
+ // 将上一步的uploadHeaders转换为Map(Key-Value形式)
+ ObjectMapper mapper = new ObjectMapper();
+ Map uploadHeadersMap = (Map) mapper
+ .readValue(mapper.writeValueAsString(uploadHeaders), Map.class);
+ uploadFile(uploadUrl, uploadHeadersMap, filePath);
+
+ // 步骤5：将文档添加到服务器
+ System.out.println("步骤5：将文档添加到阿里云百炼服务器");
+ AddFileResponse addResponse = addFile(client, leaseId, parser, categoryId, workspaceId);
+ String fileId = addResponse.getBody().getData().getFileId();
+
+ // 步骤6：检查文档状态
+ System.out.println("步骤6：检查阿里云百炼中的文档状态");
+ while (true) {
+ DescribeFileResponse describeResponse = describeFile(client, workspaceId, fileId);
+ String status = describeResponse.getBody().getData().getStatus();
+ System.out.println("当前文档状态：" + status);
+
+ if (status.equals("INIT")) {
+ System.out.println("文档待解析，请稍候...");
+ } else if (status.equals("PARSING")) {
+ System.out.println("文档解析中，请稍候...");
+ } else if (status.equals("PARSE_SUCCESS")) {
+ System.out.println("文档解析完成！");
+ break;
+ } else {
+ System.out.println("未知的文档状态：" + status + "，请联系技术支持。");
+ return null;
+ }
+ TimeUnit.SECONDS.sleep(5);
+ }
+
+ // 步骤7：初始化知识库
+ System.out.println("步骤7：在阿里云百炼中创建知识库");
+ CreateIndexResponse indexResponse = createIndex(client, workspaceId, fileId, name, structureType,
+ sourceType, sinkType);
+ String indexId = indexResponse.getBody().getData().getId();
+
+ // 步骤8：提交索引任务
+ System.out.println("步骤8：向阿里云百炼提交索引任务");
+ SubmitIndexJobResponse submitResponse = submitIndex(client, workspaceId, indexId);
+ String jobId = submitResponse.getBody().getData().getId();
+
+ // 步骤9：获取索引任务状态
+ System.out.println("步骤9：获取阿里云百炼索引任务状态");
+ while (true) {
+ GetIndexJobStatusResponse getStatusResponse = getIndexJobStatus(client, workspaceId, jobId, indexId);
+ String status = getStatusResponse.getBody().getData().getStatus();
+ System.out.println("当前索引任务状态：" + status);
+
+ if (status.equals("COMPLETED")) {
+ break;
+ }
+ TimeUnit.SECONDS.sleep(5);
+ }
+
+ System.out.println("阿里云百炼知识库创建成功！");
+ return indexId;
+
+ } catch (Exception e) {
+ System.out.println("发生错误：" + e.getMessage());
+ e.printStackTrace();
+ return null;
+ }
+ }
+
+ /**
+ * 主函数。
+ */
+ public static void main(String[] args) {
+ Scanner scanner = new Scanner(System.in);
+ if (!checkEnvironmentVariables()) {
+ return;
+ }
+
+ System.out.print("请输入您需要上传文档的实际本地路径（以Linux为例：/xxx/xxx/阿里云百炼系列手机产品介绍.docx）：");
+ String filePath = scanner.nextLine();
+
+ System.out.print("请为您的知识库输入一个名称：");
+ String kbName = scanner.nextLine();
+
+ String workspaceId = System.getenv("WORKSPACE_ID");
+ String result = createKnowledgeBase(filePath, workspaceId, kbName);
+ if (result != null) {
+ System.out.println("知识库ID: " + result);
+ }
+ }
+}
diff --git a/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseManage.java b/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseManage.java
new file mode 100644
index 0000000..c669d52
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseManage.java
@@ -0,0 +1,145 @@
+package com.gxwebsoft.ai.util;
+
+import com.aliyun.bailian20231229.models.DeleteIndexResponse;
+import com.aliyun.bailian20231229.models.ListIndicesResponse;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.util.*;
+
+/**
+ * 管理知识库
+ * @author GIIT-YC
+ *
+ */
+public class KnowledgeBaseManage {
+
+ String ALIBABA_CLOUD_ACCESS_KEY_ID = "LTAI5tD5YRKuxWz6Eg7qrM4P";
+ String ALIBABA_CLOUD_ACCESS_KEY_SECRET = "bO8TBDXflOwbtSKimPpG8XrJnyzgTk";
+ String WORKSPACE_ID = "llm-4pf5auwewoz34zqu";
+
+ /**
+ * 检查并提示设置必要的环境变量。
+ *
+ * @return true 如果所有必需的环境变量都已设置，否则 false
+ */
+ public static boolean checkEnvironmentVariables() {
+ Map requiredVars = new HashMap<>();
+ requiredVars.put("ALIBABA_CLOUD_ACCESS_KEY_ID", "阿里云访问密钥ID");
+ requiredVars.put("ALIBABA_CLOUD_ACCESS_KEY_SECRET", "阿里云访问密钥密码");
+ requiredVars.put("WORKSPACE_ID", "阿里云百炼业务空间ID");
+
+ List missingVars = new ArrayList<>();
+ for (Map.Entry entry : requiredVars.entrySet()) {
+ String value = System.getenv(entry.getKey());
+ if (value == null || value.isEmpty()) {
+ missingVars.add(entry.getKey());
+ System.out.println("错误：请设置 " + entry.getKey() + " 环境变量 (" + entry.getValue() + ")");
+ }
+ }
+
+ return missingVars.isEmpty();
+ }
+
+ /**
+ * 创建并配置客户端（Client）
+ *
+ * @return 配置好的客户端（Client）
+ */
+ public static com.aliyun.bailian20231229.Client createClient() throws Exception {
+ com.aliyun.credentials.Client credential = new com.aliyun.credentials.Client();
+ com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
+ .setCredential(credential);
+ // 下方接入地址以公有云的公网接入地址为例，可按需更换接入地址。
+ config.endpoint = "bailian.cn-beijing.aliyuncs.com";
+ return new com.aliyun.bailian20231229.Client(config);
+ }
+
+ /**
+ * 获取指定业务空间下一个或多个知识库的详细信息
+ *
+ * @param client 客户端（Client）
+ * @param workspaceId 业务空间ID
+ * @return 阿里云百炼服务的响应
+ */
+ public static ListIndicesResponse listIndices(com.aliyun.bailian20231229.Client client, String workspaceId)
+ throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.ListIndicesRequest listIndicesRequest = new com.aliyun.bailian20231229.models.ListIndicesRequest();
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ return client.listIndicesWithOptions(workspaceId, listIndicesRequest, headers, runtime);
+ }
+
+ /**
+ * 永久性删除指定的知识库
+ *
+ * @param client 客户端（Client）
+ * @param workspaceId 业务空间ID
+ * @param indexId 知识库ID
+ * @return 阿里云百炼服务的响应
+ */
+ public static DeleteIndexResponse deleteIndex(com.aliyun.bailian20231229.Client client, String workspaceId,
+ String indexId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.DeleteIndexRequest deleteIndexRequest = new com.aliyun.bailian20231229.models.DeleteIndexRequest();
+ deleteIndexRequest.setIndexId(indexId);
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ return client.deleteIndexWithOptions(workspaceId, deleteIndexRequest, headers, runtime);
+ }
+
+ /**
+ * 主函数
+ */
+ public static void main(String[] args) {
+ if (!checkEnvironmentVariables()) {
+ System.out.println("环境变量校验未通过。");
+ return;
+ }
+
+ try {
+ Scanner scanner = new Scanner(System.in);
+ System.out.print("请选择要执行的操作：\n1. 查看知识库\n2. 删除知识库\n请输入选项（1或2）：");
+ String startOption = scanner.nextLine();
+ com.aliyun.bailian20231229.Client client = createClient();
+ if (startOption.equals("1")) {
+ // 查看知识库
+ System.out.println("\n执行查看知识库");
+ String workspaceId = System.getenv("WORKSPACE_ID");
+ ListIndicesResponse response = listIndices(client, workspaceId);
+ // 请自行安装jackson-databind。将响应转换为 JSON 字符串
+ ObjectMapper mapper = new ObjectMapper();
+ String result = mapper.writeValueAsString(response.getBody().getData());
+ System.out.println(result);
+ } else if (startOption.equals("2")) {
+ System.out.println("\n执行删除知识库");
+ String workspaceId = System.getenv("WORKSPACE_ID");
+ System.out.print("请输入知识库ID："); // 即 CreateIndex 接口返回的 Data.Id，您也可以在阿里云百炼控制台的知识库页面获取。
+ String indexId = scanner.nextLine();
+ // 删除前二次确认
+ boolean confirm = false;
+ while (!confirm) {
+ System.out.print("您确定要永久性删除该知识库 " + indexId + " 吗？(y/n): ");
+ String input = scanner.nextLine().trim().toLowerCase();
+ if (input.equals("y")) {
+ confirm = true;
+ } else if (input.equals("n")) {
+ System.out.println("已取消删除操作。");
+ return;
+ } else {
+ System.out.println("无效输入，请输入 y 或 n。");
+ }
+ }
+ DeleteIndexResponse resp = deleteIndex(client, workspaceId, indexId);
+ if (resp.getBody().getStatus().equals("200")) {
+ System.out.println("知识库" + indexId + "删除成功！");
+ } else {
+ ObjectMapper mapper = new ObjectMapper();
+ System.out.println("发生错误：" + mapper.writeValueAsString(resp.getBody()));
+ }
+ } else {
+ System.out.println("无效的选项，程序退出。");
+ }
+ } catch (Exception e) {
+ System.out.println("发生错误：" + e.getMessage());
+ }
+ }
+}
diff --git a/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseRetrieve.java b/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseRetrieve.java
new file mode 100644
index 0000000..a7b568e
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseRetrieve.java
@@ -0,0 +1,110 @@
+package com.gxwebsoft.ai.util;
+
+import com.aliyun.bailian20231229.models.RetrieveRequest;
+import com.aliyun.bailian20231229.models.RetrieveResponse;
+import com.aliyun.teautil.models.RuntimeOptions;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.util.*;
+
+/**
+ * 检索知识库
+ * @author GIIT-YC
+ *
+ */
+public class KnowledgeBaseRetrieve {
+
+ static String ALIBABA_CLOUD_ACCESS_KEY_ID = "LTAI5tD5YRKuxWz6Eg7qrM4P";
+ static String ALIBABA_CLOUD_ACCESS_KEY_SECRET = "bO8TBDXflOwbtSKimPpG8XrJnyzgTk";
+ static String WORKSPACE_ID = "llm-4pf5auwewoz34zqu";
+
+
+ /**
+ * 检查并提示设置必要的环境变量。
+ *
+ * @return true 如果所有必需的环境变量都已设置，否则 false
+ */
+ public static boolean checkEnvironmentVariables() {
+ Map requiredVars = new HashMap<>();
+ requiredVars.put("ALIBABA_CLOUD_ACCESS_KEY_ID", "阿里云访问密钥ID");
+ requiredVars.put("ALIBABA_CLOUD_ACCESS_KEY_SECRET", "阿里云访问密钥密码");
+ requiredVars.put("WORKSPACE_ID", "阿里云百炼业务空间ID");
+
+ List missingVars = new ArrayList<>();
+ for (Map.Entry entry : requiredVars.entrySet()) {
+ String value = System.getenv(entry.getKey());
+ if (value == null || value.isEmpty()) {
+ missingVars.add(entry.getKey());
+ System.out.println("错误：请设置 " + entry.getKey() + " 环境变量 (" + entry.getValue() + ")");
+ }
+ }
+
+ return missingVars.isEmpty();
+ }
+
+ /**
+ * 初始化客户端（Client）。
+ *
+ * @return 配置好的客户端对象
+ */
+ public static com.aliyun.bailian20231229.Client createClient() throws Exception {
+ com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
+ .setAccessKeyId(ALIBABA_CLOUD_ACCESS_KEY_ID)
+ .setAccessKeySecret(ALIBABA_CLOUD_ACCESS_KEY_SECRET);
+ // 下方接入地址以公有云的公网接入地址为例，可按需更换接入地址。
+ config.endpoint = "bailian.cn-beijing.aliyuncs.com";
+ return new com.aliyun.bailian20231229.Client(config);
+ }
+
+ /**
+ * 在指定的知识库中检索信息。
+ *
+ * @param client 客户端对象（bailian20231229Client）
+ * @param workspaceId 业务空间ID
+ * @param indexId 知识库ID
+ * @param query 检索查询语句
+ * @return 阿里云百炼服务的响应
+ */
+ public static RetrieveResponse retrieveIndex(com.aliyun.bailian20231229.Client client, String workspaceId,
+ String indexId, String query) throws Exception {
+ RetrieveRequest retrieveRequest = new RetrieveRequest();
+ retrieveRequest.setIndexId(indexId);
+ retrieveRequest.setQuery(query);
+ retrieveRequest.setDenseSimilarityTopK(null);
+ RuntimeOptions runtime = new RuntimeOptions();
+ return client.retrieveWithOptions(workspaceId, retrieveRequest, null, runtime);
+ }
+
+ /**
+ * 使用阿里云百炼服务检索知识库。
+ */
+ public static void main(String[] args) {
+// if (!checkEnvironmentVariables()) {
+// System.out.println("环境变量校验未通过。");
+// return;
+// }
+
+ try {
+ // 步骤1：初始化客户端（Client）
+ System.out.println("步骤1：创建Client");
+ com.aliyun.bailian20231229.Client client = createClient();
+
+ // 步骤2：检索知识库
+ System.out.println("步骤2：检索知识库");
+ Scanner scanner = new Scanner(System.in);
+ System.out.print("请输入知识库ID："); // 即 CreateIndex 接口返回的 Data.Id，您也可以在阿里云百炼控制台的知识库页面获取。
+ String indexId = scanner.nextLine();
+ System.out.print("请输入检索query：");
+ String query = scanner.nextLine();
+ String workspaceId = WORKSPACE_ID;
+ RetrieveResponse resp = retrieveIndex(client, workspaceId, indexId, query);
+
+ // 请自行安装jackson-databind。将响应体responsebody转换为 JSON 字符串
+ ObjectMapper mapper = new ObjectMapper();
+ String result = mapper.writeValueAsString(resp.getBody());
+ System.out.println(result);
+ } catch (Exception e) {
+ System.out.println("发生错误：" + e.getMessage());
+ }
+ }
+}
diff --git a/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseUpdate.java b/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseUpdate.java
new file mode 100644
index 0000000..518d3e6
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/ai/util/KnowledgeBaseUpdate.java
@@ -0,0 +1,384 @@
+package com.gxwebsoft.ai.util;
+
+import com.aliyun.bailian20231229.models.*;
+import com.aliyun.teautil.models.RuntimeOptions;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.nio.file.Paths;
+import java.security.MessageDigest;
+import java.util.*;
+
+/**
+ * 更新知识库
+ * @author GIIT-YC
+ *
+ */
+public class KnowledgeBaseUpdate {
+
+ String ALIBABA_CLOUD_ACCESS_KEY_ID = "LTAI5tD5YRKuxWz6Eg7qrM4P";
+ String ALIBABA_CLOUD_ACCESS_KEY_SECRET = "bO8TBDXflOwbtSKimPpG8XrJnyzgTk";
+ String WORKSPACE_ID = "llm-4pf5auwewoz34zqu";
+
+ /**
+ * 检查并提示设置必要的环境变量。
+ *
+ * @return true 如果所有必需的环境变量都已设置，否则 false
+ */
+ public static boolean checkEnvironmentVariables() {
+ Map requiredVars = new HashMap<>();
+ requiredVars.put("ALIBABA_CLOUD_ACCESS_KEY_ID", "阿里云访问密钥ID");
+ requiredVars.put("ALIBABA_CLOUD_ACCESS_KEY_SECRET", "阿里云访问密钥密码");
+ requiredVars.put("WORKSPACE_ID", "阿里云百炼业务空间ID");
+
+ List missingVars = new ArrayList<>();
+ for (Map.Entry entry : requiredVars.entrySet()) {
+ String value = System.getenv(entry.getKey());
+ if (value == null || value.isEmpty()) {
+ missingVars.add(entry.getKey());
+ System.out.println("错误：请设置 " + entry.getKey() + " 环境变量 (" + entry.getValue() + ")");
+ }
+ }
+
+ return missingVars.isEmpty();
+ }
+
+ /**
+ * 创建并配置客户端（Client）
+ *
+ * @return 配置好的客户端（Client）
+ */
+ public static com.aliyun.bailian20231229.Client createClient() throws Exception {
+ com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
+ .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
+ .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
+ // 下方接入地址以公有云的公网接入地址为例，可按需更换接入地址。
+ config.endpoint = "bailian.cn-beijing.aliyuncs.com";
+ return new com.aliyun.bailian20231229.Client(config);
+ }
+
+ /**
+ * 计算文档的MD5值
+ *
+ * @param filePath 文档本地路径
+ * @return 文档的MD5值
+ */
+ public static String calculateMD5(String filePath) throws Exception {
+ MessageDigest md = MessageDigest.getInstance("MD5");
+ try (FileInputStream fis = new FileInputStream(filePath)) {
+ byte[] buffer = new byte[4096];
+ int bytesRead;
+ while ((bytesRead = fis.read(buffer)) != -1) {
+ md.update(buffer, 0, bytesRead);
+ }
+ }
+ StringBuilder sb = new StringBuilder();
+ for (byte b : md.digest()) {
+ sb.append(String.format("%02x", b & 0xff));
+ }
+ return sb.toString();
+ }
+
+ /**
+ * 获取文档大小（以字节为单位）
+ *
+ * @param filePath 文档本地路径
+ * @return 文档大小（以字节为单位）
+ */
+ public static String getFileSize(String filePath) {
+ File file = new File(filePath);
+ long fileSize = file.length();
+ return String.valueOf(fileSize);
+ }
+
+ /**
+ * 申请文档上传租约。
+ *
+ * @param client 客户端对象
+ * @param categoryId 类目ID
+ * @param fileName 文档名称
+ * @param fileMd5 文档的MD5值
+ * @param fileSize 文档大小（以字节为单位）
+ * @param workspaceId 业务空间ID
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static ApplyFileUploadLeaseResponse applyLease(com.aliyun.bailian20231229.Client client, String categoryId,
+ String fileName, String fileMd5, String fileSize, String workspaceId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.ApplyFileUploadLeaseRequest applyFileUploadLeaseRequest = new com.aliyun.bailian20231229.models.ApplyFileUploadLeaseRequest();
+ applyFileUploadLeaseRequest.setFileName(fileName);
+ applyFileUploadLeaseRequest.setMd5(fileMd5);
+ applyFileUploadLeaseRequest.setSizeInBytes(fileSize);
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ ApplyFileUploadLeaseResponse applyFileUploadLeaseResponse = null;
+ applyFileUploadLeaseResponse = client.applyFileUploadLeaseWithOptions(categoryId, workspaceId,
+ applyFileUploadLeaseRequest, headers, runtime);
+ return applyFileUploadLeaseResponse;
+ }
+
+ /**
+ * 上传文档到临时存储。
+ *
+ * @param preSignedUrl 上传租约中的 URL
+ * @param headers 上传请求的头部
+ * @param filePath 文档本地路径
+ * @throws Exception 如果上传过程中发生错误
+ */
+ public static void uploadFile(String preSignedUrl, Map headers, String filePath) throws Exception {
+ File file = new File(filePath);
+ if (!file.exists() || !file.isFile()) {
+ throw new IllegalArgumentException("文件不存在或不是普通文件: " + filePath);
+ }
+
+ try (FileInputStream fis = new FileInputStream(file)) {
+ URL url = new URL(preSignedUrl);
+ HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+ conn.setRequestMethod("PUT");
+ conn.setDoOutput(true);
+
+ // 设置上传请求头
+ conn.setRequestProperty("X-bailian-extra", headers.get("X-bailian-extra"));
+ conn.setRequestProperty("Content-Type", headers.get("Content-Type"));
+
+ // 分块读取并上传文档
+ byte[] buffer = new byte[4096];
+ int bytesRead;
+ while ((bytesRead = fis.read(buffer)) != -1) {
+ conn.getOutputStream().write(buffer, 0, bytesRead);
+ }
+
+ int responseCode = conn.getResponseCode();
+ if (responseCode != 200) {
+ throw new RuntimeException("上传失败: " + responseCode);
+ }
+ }
+ }
+
+ /**
+ * 将文档添加到类目中。
+ *
+ * @param client 客户端对象
+ * @param leaseId 租约ID
+ * @param parser 用于文档的解析器
+ * @param categoryId 类目ID
+ * @param workspaceId 业务空间ID
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static AddFileResponse addFile(com.aliyun.bailian20231229.Client client, String leaseId, String parser,
+ String categoryId, String workspaceId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.AddFileRequest addFileRequest = new com.aliyun.bailian20231229.models.AddFileRequest();
+ addFileRequest.setLeaseId(leaseId);
+ addFileRequest.setParser(parser);
+ addFileRequest.setCategoryId(categoryId);
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ return client.addFileWithOptions(workspaceId, addFileRequest, headers, runtime);
+ }
+
+ /**
+ * 查询文档的基本信息。
+ *
+ * @param client 客户端对象
+ * @param workspaceId 业务空间ID
+ * @param fileId 文档ID
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static DescribeFileResponse describeFile(com.aliyun.bailian20231229.Client client, String workspaceId,
+ String fileId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ return client.describeFileWithOptions(workspaceId, fileId, headers, runtime);
+ }
+
+ /**
+ * 向一个非结构化知识库追加导入已解析的文档
+ *
+ * @param client 客户端（Client）
+ * @param workspaceId 业务空间ID
+ * @param indexId 知识库ID
+ * @param fileId 文档ID
+ * @param sourceType 数据类型
+ * @return 阿里云百炼服务的响应
+ */
+ public static SubmitIndexAddDocumentsJobResponse submitIndexAddDocumentsJob(
+ com.aliyun.bailian20231229.Client client, String workspaceId, String indexId, String fileId,
+ String sourceType) throws Exception {
+ Map headers = new HashMap<>();
+ SubmitIndexAddDocumentsJobRequest submitIndexAddDocumentsJobRequest = new SubmitIndexAddDocumentsJobRequest();
+ submitIndexAddDocumentsJobRequest.setIndexId(indexId);
+ submitIndexAddDocumentsJobRequest.setDocumentIds(Collections.singletonList(fileId));
+ submitIndexAddDocumentsJobRequest.setSourceType(sourceType);
+ RuntimeOptions runtime = new RuntimeOptions();
+ return client.submitIndexAddDocumentsJobWithOptions(workspaceId, submitIndexAddDocumentsJobRequest, headers,
+ runtime);
+ }
+
+ /**
+ * 查询索引任务状态。
+ *
+ * @param client 客户端对象
+ * @param workspaceId 业务空间ID
+ * @param jobId 任务ID
+ * @param indexId 知识库ID
+ * @return 阿里云百炼服务的响应对象
+ */
+ public static GetIndexJobStatusResponse getIndexJobStatus(com.aliyun.bailian20231229.Client client,
+ String workspaceId, String jobId, String indexId) throws Exception {
+ Map headers = new HashMap<>();
+ com.aliyun.bailian20231229.models.GetIndexJobStatusRequest getIndexJobStatusRequest = new com.aliyun.bailian20231229.models.GetIndexJobStatusRequest();
+ getIndexJobStatusRequest.setIndexId(indexId);
+ getIndexJobStatusRequest.setJobId(jobId);
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ GetIndexJobStatusResponse getIndexJobStatusResponse = null;
+ getIndexJobStatusResponse = client.getIndexJobStatusWithOptions(workspaceId, getIndexJobStatusRequest, headers,
+ runtime);
+ return getIndexJobStatusResponse;
+ }
+
+ /**
+ * 从指定的非结构化知识库中永久删除一个或多个文档
+ *
+ * @param client 客户端（Client）
+ * @param workspaceId 业务空间ID
+ * @param indexId 知识库ID
+ * @param fileId 文档ID
+ * @return 阿里云百炼服务的响应
+ */
+ public static DeleteIndexDocumentResponse deleteIndexDocument(com.aliyun.bailian20231229.Client client,
+ String workspaceId, String indexId, String fileId) throws Exception {
+ Map headers = new HashMap<>();
+ DeleteIndexDocumentRequest deleteIndexDocumentRequest = new DeleteIndexDocumentRequest();
+ deleteIndexDocumentRequest.setIndexId(indexId);
+ deleteIndexDocumentRequest.setDocumentIds(Collections.singletonList(fileId));
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+ return client.deleteIndexDocumentWithOptions(workspaceId, deleteIndexDocumentRequest, headers, runtime);
+ }
+
+ /**
+ * 使用阿里云百炼服务更新知识库
+ *
+ * @param filePath 文档（更新后的）的实际本地路径
+ * @param workspaceId 业务空间ID
+ * @param indexId 需要更新的知识库ID
+ * @param oldFileId 需要更新的文档的FileID
+ * @return 如果成功，返回知识库ID；否则返回 null
+ */
+ public static String updateKnowledgeBase(String filePath, String workspaceId, String indexId, String oldFileId) {
+ // 设置默认值
+ String categoryId = "default";
+ String parser = "DASHSCOPE_DOCMIND";
+ String sourceType = "DATA_CENTER_FILE";
+ try {
+ // 步骤1：初始化客户端（Client）
+ System.out.println("步骤1：创建Client");
+ com.aliyun.bailian20231229.Client client = createClient();
+
+ // 步骤2：准备文档信息（更新后的文档）
+ System.out.println("步骤2：准备文档信息");
+ String fileName = Paths.get(filePath).getFileName().toString();
+ String fileMd5 = calculateMD5(filePath);
+ String fileSize = getFileSize(filePath);
+
+ // 步骤3：申请上传租约
+ System.out.println("步骤3：向阿里云百炼申请上传租约");
+ ApplyFileUploadLeaseResponse leaseResponse = applyLease(client, categoryId, fileName, fileMd5, fileSize,
+ workspaceId);
+ String leaseId = leaseResponse.getBody().getData().getFileUploadLeaseId();
+ String uploadUrl = leaseResponse.getBody().getData().getParam().getUrl();
+ Object uploadHeaders = leaseResponse.getBody().getData().getParam().getHeaders();
+
+ // 步骤4：上传文档到临时存储
+ System.out.println("步骤4：上传文档到临时存储");
+ // 请自行安装jackson-databind
+ // 将上一步的uploadHeaders转换为Map(Key-Value形式)
+ ObjectMapper mapper = new ObjectMapper();
+ Map uploadHeadersMap = (Map) mapper
+ .readValue(mapper.writeValueAsString(uploadHeaders), Map.class);
+ uploadFile(uploadUrl, uploadHeadersMap, filePath);
+
+ // 步骤5：添加文档到类目中
+ System.out.println("步骤5：添加文档到类目中");
+ AddFileResponse addResponse = addFile(client, leaseId, parser, categoryId, workspaceId);
+ String fileId = addResponse.getBody().getData().getFileId();
+
+ // 步骤6：检查更新后的文档状态
+ System.out.println("步骤6：检查阿里云百炼中的文档状态");
+ while (true) {
+ DescribeFileResponse describeResponse = describeFile(client, workspaceId, fileId);
+ String status = describeResponse.getBody().getData().getStatus();
+ System.out.println("当前文档状态：" + status);
+ if ("INIT".equals(status)) {
+ System.out.println("文档待解析，请稍候...");
+ } else if ("PARSING".equals(status)) {
+ System.out.println("文档解析中，请稍候...");
+ } else if ("PARSE_SUCCESS".equals(status)) {
+ System.out.println("文档解析完成！");
+ break;
+ } else {
+ System.out.println("未知的文档状态：" + status + "，请联系技术支持。");
+ return null;
+ }
+ Thread.sleep(5000);
+ }
+
+ // 步骤7：提交追加文档任务
+ System.out.println("步骤7：提交追加文档任务");
+ SubmitIndexAddDocumentsJobResponse indexAddResponse = submitIndexAddDocumentsJob(client, workspaceId,
+ indexId, fileId, sourceType);
+ String jobId = indexAddResponse.getBody().getData().getId();
+
+ // 步骤8：等待追加任务完成
+ System.out.println("步骤8：等待追加任务完成");
+ while (true) {
+ GetIndexJobStatusResponse jobStatusResponse = getIndexJobStatus(client, workspaceId, jobId, indexId);
+ String status = jobStatusResponse.getBody().getData().getStatus();
+ System.out.println("当前索引任务状态：" + status);
+ if ("COMPLETED".equals(status)) {
+ break;
+ }
+ Thread.sleep(5000);
+ }
+
+ // 步骤9：删除旧文档
+ System.out.println("步骤9：删除旧文档");
+ deleteIndexDocument(client, workspaceId, indexId, oldFileId);
+
+ System.out.println("阿里云百炼知识库更新成功！");
+ return indexId;
+ } catch (Exception e) {
+ System.out.println("发生错误：" + e.getMessage());
+ return null;
+ }
+ }
+
+ /**
+ * 主函数。
+ */
+ public static void main(String[] args) {
+ if (!checkEnvironmentVariables()) {
+ System.out.println("环境变量校验未通过。");
+ return;
+ }
+
+ Scanner scanner = new Scanner(System.in);
+ System.out.print("请输入您需要上传文档（更新后的）的实际本地路径（以Linux为例：/xxx/xxx/阿里云百炼系列手机产品介绍.docx）：");
+ String filePath = scanner.nextLine();
+
+ System.out.print("请输入需要更新的知识库ID："); // 即 CreateIndex 接口返回的 Data.Id，您也可以在阿里云百炼控制台的知识库页面获取。
+ String indexId = scanner.nextLine(); // 即 AddFile 接口返回的 FileId。您也可以在阿里云百炼控制台的应用数据页面，单击文件名称旁的 ID 图标获取。
+
+ System.out.print("请输入需要更新的文档的 FileID：");
+ String oldFileId = scanner.nextLine();
+
+ String workspaceId = System.getenv("WORKSPACE_ID");
+ String result = updateKnowledgeBase(filePath, workspaceId, indexId, oldFileId);
+ if (result != null) {
+ System.out.println("知识库更新成功，返回知识库ID: " + result);
+ } else {
+ System.out.println("知识库更新失败。");
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/gxwebsoft/enterprise/controller/EnterpriseController.java b/src/main/java/com/gxwebsoft/enterprise/controller/EnterpriseController.java
new file mode 100644
index 0000000..819568a
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/enterprise/controller/EnterpriseController.java
@@ -0,0 +1,147 @@
+package com.gxwebsoft.enterprise.controller;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.gxwebsoft.common.core.web.BaseController;
+import com.gxwebsoft.common.core.web.ApiResult;
+import com.gxwebsoft.common.core.web.PageResult;
+import com.gxwebsoft.common.core.annotation.OperationLog;
+import com.gxwebsoft.common.system.entity.User;
+import com.gxwebsoft.enterprise.entity.Enterprise;
+import com.gxwebsoft.enterprise.service.EnterpriseService;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import io.swagger.v3.oas.annotations.Operation;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ *
+ * @author GIIT-YC
+ *
+ */
+@Tag(name = "企业信息管理")
+@RestController
+@RequestMapping("/api/enterprise/enterprise")
+public class EnterpriseController extends BaseController {
+
+ @Resource
+ private EnterpriseService enterpriseService;
+
+// @PreAuthorize("hasAuthority('enterprise:enterprise:list')")
+ @Operation(summary = "分页查询企业信息")
+ @GetMapping("/page")
+ public ApiResult> page(Enterprise enterprise) {
+ LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>();
+ wrapper.like(StrUtil.isNotBlank(enterprise.getName()), Enterprise::getName, enterprise.getName());
+ wrapper.like(StrUtil.isNotBlank(enterprise.getCreditCode()), Enterprise::getCreditCode, enterprise.getCreditCode());
+ wrapper.orderByAsc(Enterprise::getName);
+
+ final Page page = new Page<>(enterprise.getPage(), enterprise.getLimit());
+ final IPage p = enterpriseService.page(page, wrapper);
+
+ return success(new PageResult(p.getRecords(), p.getTotal()));
+ }
+
+// @PreAuthorize("hasAuthority('enterprise:enterprise:list')")
+ @Operation(summary = "查询全部企业信息")
+ @GetMapping("/list")
+ public ApiResult> list(Enterprise enterprise) {
+ LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>();
+ wrapper.like(StrUtil.isNotBlank(enterprise.getName()), Enterprise::getName, enterprise.getName());
+ wrapper.like(StrUtil.isNotBlank(enterprise.getCreditCode()), Enterprise::getCreditCode, enterprise.getCreditCode());
+ return success(enterpriseService.list(wrapper));
+ }
+
+// @PreAuthorize("hasAuthority('enterprise:enterprise:list')")
+ @Operation(summary = "根据id查询企业信息")
+ @GetMapping("/{id}")
+ public ApiResult get(@PathVariable("id") Integer id) {
+ return success(enterpriseService.getById(id));
+ }
+
+// @PreAuthorize("hasAuthority('enterprise:enterprise:list')")
+ @Operation(summary = "根据CreditCode查询企业信息")
+ @GetMapping("/creditCode/{creditCode}")
+ public ApiResult getByCreditCode(@PathVariable("creditCode") String creditCode) {
+ Enterprise enterprise = enterpriseService.getOne(new LambdaQueryWrapper().eq(Enterprise::getCreditCode, creditCode));
+ return success(enterprise);
+ }
+
+// @PreAuthorize("hasAuthority('enterprise:enterprise:save')")
+ @OperationLog
+ @Operation(summary = "添加企业信息")
+ @PostMapping()
+ public ApiResult save(@RequestBody Enterprise enterprise) {
+ // 记录当前登录用户id
+ User loginUser = getLoginUser();
+ if (loginUser != null) {
+ enterprise.setUserId(loginUser.getUserId());
+ final Enterprise one = enterpriseService.getOne(new LambdaQueryWrapper().eq(Enterprise::getCreditCode, enterprise.getCreditCode()));
+ if (!ObjectUtil.isEmpty(one)) {
+ return fail("企业统一信用代码已存在");
+ }
+ if (enterpriseService.save(enterprise)) {
+ //TODO 查询知识库(kb_name=enterprise.getCreditCode)
+
+ //TODO 新建知识库
+ String kbId = "pggi9mpair";
+
+ //绑定知识库
+ enterprise.setKbId(kbId);
+ enterpriseService.updateById(enterprise);
+ return success("添加成功");
+ }
+ }
+ return fail("添加失败");
+ }
+
+// @PreAuthorize("hasAuthority('enterprise:enterprise:update')")
+ @OperationLog
+ @Operation(summary = "修改企业信息")
+ @PutMapping()
+ public ApiResult update(@RequestBody Enterprise enterprise) {
+ if(StrUtil.isEmpty(enterprise.getKbId())) {
+ //TODO 查询知识库
+
+ //TODO 新建知识库
+ String kbId = "pggi9mpair";
+
+ //绑定知识库
+ enterprise.setKbId(kbId);
+ }
+ if (enterpriseService.updateById(enterprise)) {
+ return success("修改成功");
+ }
+ return fail("修改失败");
+ }
+
+// @PreAuthorize("hasAuthority('enterprise:enterprise:remove')")
+ @OperationLog
+ @Operation(summary = "删除企业信息")
+ @DeleteMapping("/{id}")
+ public ApiResult remove(@PathVariable("id") Integer id) {
+ if (enterpriseService.removeById(id)) {
+ return success("删除成功");
+ }
+ return fail("删除失败");
+ }
+
+// @PreAuthorize("hasAuthority('enterprise:enterprise:remove')")
+ @OperationLog
+ @Operation(summary = "批量删除企业信息")
+ @DeleteMapping("/batch")
+ public ApiResult removeBatch(@RequestBody List ids) {
+ if (enterpriseService.removeByIds(ids)) {
+ return success("删除成功");
+ }
+ return fail("删除失败");
+ }
+
+}
diff --git a/src/main/java/com/gxwebsoft/enterprise/entity/Enterprise.java b/src/main/java/com/gxwebsoft/enterprise/entity/Enterprise.java
new file mode 100644
index 0000000..9e99efd
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/enterprise/entity/Enterprise.java
@@ -0,0 +1,67 @@
+package com.gxwebsoft.enterprise.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.gxwebsoft.common.core.web.BaseParam;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 企业信息
+ * @author GIIT-YC
+ */
+@Data
+@TableName("enterprise")
+@EqualsAndHashCode(callSuper = false)
+@Schema(name = "Enterprise对象", description = "企业信息表")
+public class Enterprise extends BaseParam implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ @Schema(description = "ID")
+ @TableId(value = "id", type = IdType.AUTO)
+ private Integer id;
+
+ @Schema(description = "企业名称")
+ private String name;
+
+ @Schema(description = "统一代码")
+ private String creditCode;
+
+ @Schema(description = "企业性质（国企、行政事业单位、民间非营利组织）")
+ private String enterpriseType;
+
+ @Schema(description = "所属行业（使用插件）")
+ private String industry;
+
+ @Schema(description = "知识库ID")
+ private String kbId;
+
+ @Schema(description = "客户ID")
+ private Integer userId;
+
+ @Schema(description = "租户ID")
+ private Integer tenantId;
+
+ @Schema(description = "创建时间")
+ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ private LocalDateTime createTime;
+
+ @Schema(description = "修改时间")
+ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ private LocalDateTime updateTime;
+
+ @Schema(description = "状态, 0正常, 1冻结")
+ private Integer status;
+
+ @Schema(description = "是否删除, 0否, 1是")
+ @TableLogic
+ private Integer deleted;
+}
\ No newline at end of file
diff --git a/src/main/java/com/gxwebsoft/enterprise/mapper/EnterpriseMapper.java b/src/main/java/com/gxwebsoft/enterprise/mapper/EnterpriseMapper.java
new file mode 100644
index 0000000..33ca945
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/enterprise/mapper/EnterpriseMapper.java
@@ -0,0 +1,13 @@
+package com.gxwebsoft.enterprise.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.gxwebsoft.enterprise.entity.Enterprise;
+
+/**
+ *
+ * @author GIIT-YC
+ *
+ */
+public interface EnterpriseMapper extends BaseMapper {
+
+}
diff --git a/src/main/java/com/gxwebsoft/enterprise/mapper/xml/EnterpriseMapper.xml b/src/main/java/com/gxwebsoft/enterprise/mapper/xml/EnterpriseMapper.xml
new file mode 100644
index 0000000..b543162
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/enterprise/mapper/xml/EnterpriseMapper.xml
@@ -0,0 +1,7 @@
+
+
+
+
+
+
+
diff --git a/src/main/java/com/gxwebsoft/enterprise/service/EnterpriseService.java b/src/main/java/com/gxwebsoft/enterprise/service/EnterpriseService.java
new file mode 100644
index 0000000..daf3ff8
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/enterprise/service/EnterpriseService.java
@@ -0,0 +1,13 @@
+package com.gxwebsoft.enterprise.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.gxwebsoft.enterprise.entity.Enterprise;
+
+/**
+ *
+ * @author GIIT-YC
+ *
+ */
+public interface EnterpriseService extends IService {
+
+}
diff --git a/src/main/java/com/gxwebsoft/enterprise/service/impl/EnterpriseServiceImpl.java b/src/main/java/com/gxwebsoft/enterprise/service/impl/EnterpriseServiceImpl.java
new file mode 100644
index 0000000..a6eedda
--- /dev/null
+++ b/src/main/java/com/gxwebsoft/enterprise/service/impl/EnterpriseServiceImpl.java
@@ -0,0 +1,17 @@
+package com.gxwebsoft.enterprise.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.gxwebsoft.enterprise.entity.Enterprise;
+import com.gxwebsoft.enterprise.mapper.EnterpriseMapper;
+import com.gxwebsoft.enterprise.service.EnterpriseService;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * @author GIIT-YC
+ *
+ */
+@Service
+public class EnterpriseServiceImpl extends ServiceImpl implements EnterpriseService {
+
+}
diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index d0f9922..057cb94 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -63,3 +63,16 @@ certificate:
private-key-file: "apiclient_key.pem"
apiclient-cert-file: "apiclient_cert.pem"
wechatpay-cert-file: "wechatpay_cert.pem"
+
+aliyun:
+ knowledge-base:
+ access-key-id: LTAI5tD5YRKuxWz6Eg7qrM4P
+ access-key-secret: bO8TBDXflOwbtSKimPpG8XrJnyzgTk
+ workspace-id: llm-4pf5auwewoz34zqu
+
+ai:
+ template:
+ # Word 模板路径
+ word-template-path: classpath:templates/audit_report_template.docx
+ # 或者使用绝对路径
+ # word-template-path: D:\\公司经济责任审计方案模板.docx
\ No newline at end of file
diff --git a/src/main/resources/application-prod.yml b/src/main/resources/application-prod.yml
index fbff897..c27504d 100644
--- a/src/main/resources/application-prod.yml
+++ b/src/main/resources/application-prod.yml
@@ -69,3 +69,16 @@ payment:
key-prefix: "Payment:1"
# 缓存过期时间（小时）
expire-hours: 24
+
+aliyun:
+ knowledge-base:
+ access-key-id: LTAI5tD5YRKuxWz6Eg7qrM4P
+ access-key-secret: bO8TBDXflOwbtSKimPpG8XrJnyzgTk
+ workspace-id: llm-4pf5auwewoz34zqu
+
+ai:
+ template:
+ # Word 模板路径
+ word-template-path: classpath:templates/audit_report_template.docx
+ # 或者使用绝对路径
+ # word-template-path: D:\\公司经济责任审计方案模板.docx
\ No newline at end of file
diff --git a/src/main/resources/templates/audit_report_template.docx b/src/main/resources/templates/audit_report_template.docx
new file mode 100644
index 0000000000000000000000000000000000000000..0608b9de32d499ccadadca9887fc50e0a2233d0d
GIT binary patch
literal 815504
zcmeEt^OLW!v*y^gZQHhW#>N@j_8HqY&e*nX+xC3M-t)axyR}=j|G~ZQ52;Eed6RVa
zQ=NV~QIZ7(Lj!^Uf&u~pA_k(hLPqZf1_B!SS49Pa0?`q*w{tPIb1_i$bTD<+WAL!G
zAu0p|p~?pW`Pct{zW>G&=t`AWJY+%&y_Nb58`D^7a}csvP9D5*(v8O`?(TRlZoW&q
zqMq~bJuHqvl94X>BU?Pgdi&u)fo<;gWh{RW#%y^@;><_L2ouo^O*z(;@;V$ff86u3o$V>CmL|VFA8is|z4HD$)e$O;=!S
ze?;it2Wy1Ln)MT=UxA3)WqfQSzlW(e8=mE0$x@U1W7vcy1^hW)&dGslu&NydaI&Q?
zd5rSPp~6{$k6_xdM%@C$M6_VD3f|6!8!n8twdgQXH%3U);xAx>UpbD^e!#bQwk|c6
zp`*Ez91t2&M+$zFd9?n#n1)`aEsH#&s1&C4XEx~6i*(}q6Nc$hK0fEM>yoZ@o{91Z
z;`~LO_Cit?)ffcDX6VT(IF}rV34DCowr~x*22Ma30a~L$B;gx8xV1p59fB0Lx}EpL
zE5glrBm(1NM;TOj%jXf|`%b#51{nhV99N`+ix#d+A^0Q2Q<2|IU=Sg3!Y>w9kV7g>*ey8rHwolP`PR+QZ+`2V`E=S~>{IZc!T$V!0xA7JsLxRI
z1ONWlvi}d%u>VkR;ACp!%*gPc@_*3&-x%Wm*Vd~NVOwA9
zO#b&5uqew%U>0IxdCSiZRV2ewa~J`u=jk}B=t@>M{xa<-n}bc@d_Y+SwucQx@JW5
zC4zrgL1)kOZ6?HTR8d_{WH*goc7pVZ)?&XY{LsD1JE;)M7ubdA7CKEbv_)t-wpbQw
zJgO3S|IVC-ssbf00ZPEBon!a-(qy4E7LQ~_=(%%B%1qhBcN$q5L72r!2%lLC$ew=U
zwtZxXX#J@=WqqjrlN6`b3;O?q3rvGl-;o~>P+TQA5b{46x!XJaX8dh$;%fWPQ~t+A
zUin@s;;yIOzR+&}0E^?C?-V(sXuNG_3XlrUaxY+?mwoKC=RwEY*`bERox99hkfAbR
znJ|%c1;K+2R3;e`@fq9nEqqevY^WV8zG0eGcUMf9;!540xdd312kX^zTixnef2}y*
ze$D;>76)TX2{(D{U)NiG_sJJq#H`L+
z0UP@WS66rbv-Zt}r#t=CV90BF+m~FIVeQ)pg#La({z%v6CRg{t2a)L(XiH!+~x5mjhYv)F!!S4K4mwyNeU4{ubUiwzo++PSd
zM*TcK&lH7Tm7NtozMf;BbMpdA2aA#{?QTE!LHL8zAwt4tR-Av`?Rc*(Z>;RwESJ0Z
z`kp#gJuNYm|-*NqPx8!;8ba+3uFw;6qP7mVL-D!1VT3-fu
zUR_*$_k1M;A|Nu#!25mbQvwdPQ11>05x#mTI=wadsMyBdQ>VQKDSqXw>wo{|vrJo)Vr+SnB?Z*MHVf4z;J-<}b)*xp!v_q1;!
z;S|31kszI+=}|-u8RF~FL*x=qw>-#aZW6sdh%WN_JZ>L@Ju%kTjK)3fjC~*zdZ!4QJlE3&jcfWC?*}z2f%y2PWJj{;WNt
z_Qrk|`FhL+5^5825|iz`v0??jbZYyL^v3N$u4=?(noRqHVguU5+{aMecK0=eL!S54
zYM%*pzhK~IR_uFv4js5e?T9a!8A3J**aUCRn7;rU|m{uB_LVYfgb$65caO>
zJiWd1hC&mR)eB4cA
zrxe)5b_Nm6_ZunH%i-T%i?~U3i>LLx5Zdt=ZeamT3a1jP102uKxK-?|Z*HJnS~>F^
zCtm_*ZW^VUT=JINx=~A2{9&H%dv+Xc$zDX)em$hz_^&dy>At62$h%zUa%kot?p5Jj@7@Zo!4p5OwqiFo7xD?z^my;*AMBWQX2*nSh-~`d5E=Qfq|RL
z#?Z633Rx}PYp6K3v1qBsmX-`8tB%#zv(YO0hrdkRC#p;YfRz{7uQke*v)1l7{@mYrZ~`RV8K49w6|R8wV!Gok<-
zbJ@nj7f&O^#5Kw!BzzQFCxct)_1+-?u3zFwdrRK{#6@zQ)S3tpo_n?38ZF_CUEf{c
zpO-Vi&#jgD`KMxif}cY{yq~u`46vDV7l`aaQWaVU%m-x8AFJ_B(C@N6fc^~l7m91{
z=rP|f655h`2(wE4#kNW>;Pvsx2k6gV#|VGd#_(OPeQ?g*uSr(1L%1|miz$l_xjo73
z1C9EFoWSr2PSKrJQ#@y;Nrwo`nS)hnKn0d&T%IyH7MEeU7EALK)6WSvjC0<*aDMqN
zf8Lio;b{{!B~HlD`GCPdzLMExzHAzob?Mw6g6iW
zUKm1f%j%MMVu<)rs4erp9lr>)^W&S+-m|pl!h4j^RnGcrPpgQz*he>3Ug{xF&fC`@
zdm<%IDyhN->7loiK^9xwLdW_|EN~wt=o7B^y^knQ_s|mxEBJud?BeP&{CH2ABvGWn
z?Rmvjz)({s22y(Wf_IV<4UxWAjxIQU`tUJu!y`B@5v@}UF5C)N&@y=oDpogyKm^1~
zFoLu^Lsn5HCo_(**HKebRhPnv6T`#rmsM>?t5a`-v3?;(Plg`4d}w0YLU=`>u4{U$
zQCyUrI30{>lQ1c=Uxx$_Y0J>rd@?gc*&ZG9q=A9R_Ce8(7;P5Qt_w_j{7_qJ;KUZNs>EkD^FGVxf$ho<3x!Yy
zBY|Ibk`z{k1Dr;BoZe80DYmzvp6u1)4%Ha01_*Mbqk}-q
zxa`!+&ku~{L9gmuvSb|5V_7q9WPg>6#CY#Q_3&e;xwa%
zx4k9dLk+U&tF*eYnSN#EJ?`XoBdEURgwTUlE)EgRak>vLXa010VapaZZD*0*R
z#U6r>^B^ap&md$Xef8>I&|6q3o&Ebgla6`JVFiW7#mH6X+3ER9(zzO}yZmF{(3}@X
zH)6M>iJPqmL1sTCBf%cO1M*0hk}Ad_6I??Y?c&?SLbSF(VpP^0n+-dgNWVjeq~5R-
zNPeHp$AS^?&3s;i@pPFZZ;){Rb;aah+m>CO+d%VxH7LG#6{R<)Qh2~Q-CrNFWy$9*C^#*Ra{wo{Y)?a_oZH;LARW~>ZJur1hl)>>z
z#p?P@(MRs?KHFaE)b)$!6P;Q0Xp`Ry3z4dQPaqQ;>Wj7a*>CC{=c})}N!i&0gfXyv
ztN(1zla&r#az4N<6Gjo-?!B-;o*YM#)BzPY!|Y98y{wrlZ>tT+()1>y0i%^=>=Ktq
z9b^xHOfcO%ixZ%L_{>J|
z_4Q&6MtnRV=DZTyK$xevC_0;t)*ALgpAkmZF7UXexQOMhmv7ZvH_hOPnYOL76z+>8
zCAabKrIX#C5{v{9Pvx8K-?J;r(nwx(d^F1MUgjBExfP*K2g#f8*R!b}UT+;>XJt$KZ-N
zn(|$L_(hanZHqSC0`5ztE3$p65pJl~
z`EYTVuh2a`Ld<(s1J~C>&8XO+<>`9kUZSroO5rTK-qfC6HMi-%&
zdO)}-l_xVJ>Js#QJ^?tJJ7$x;R9_z{8n9QMx9i0|V$|a!J9RI&O<;b+1xJ64JW?XK
zh(wdZU(z@CxmYSs!X}61+qum6>SnY%^mSd-SB6web$?H80!>^j;8xfI9sWuEopE{`
zx;cU&>0t|RA_T(09bo8CisZ@WNM<_;fs)emG_l3Uu*+b09c@I`rij{7k$(RXo=_aj
z&HbSuz$KwSfzHm9wP8GNelf2z)UE=tAB2_2dBjF%2Fyp$zwfv#-lvP4M~eovWVIH5
zhAduHXfs#0!I<4)i@&J_RH+4&)(oN_$9d(>E4r^u&|K8?nEmlsi(kV2kXpZ^HiLfr
z=JyPT&RWxYGPz853JF%biVWwZTK|Q}>*fHBIxaGYfd^HGwe(rvQZ3|%{h)J{;d}|~
zckJ4$=_Z?ZoHL$fr&Eey-(VY|)8mv8=ExV>?Aki)XVdv$K4CFHYv;tiefL6(uD@%u
zTfkZUj9);>)NMCUg7{}Be^3E!gSqwrT1C{a_M+fop25@wR@9I?S~G!v=?EpuV+^Ew
zUIL{_Ehcdt2t{6@BdNBrZ|`;lI&P|(bnvBg{Ue2I==L)0(8)X{C$hT(Gix84V}Plb6iK}$T{<(@
z=~u+_;Ob}{_hGiMPnUi>vLN|RqnMl$Q!e8pm7zIGXJHmvvO*6@G8BL24nyoce2@7z
zzDBt=Ve%*q5+L<0$|tTXU5Q|!R@JdmTlyg|6z1r9WK}yA<^9OFT9+xvL4w$(6zso(
z12`W14QYIhFx!*4BDn{m+igh>Ov0@B#iNC>wg$BVbN3zo7y^%xa)9tJ@zNW1RnX`haNRX2sf!aWSOAKLBr3XM-f^Cqo0p44eWXSt`ptu{}ib@3OGDJrGk@l|NLfPTNd3sNJL{>JnO
z8Zzj6PL0$)7}MArMFYBfb-;4&8Jey7;wZgsmZf&BzJ-~nM6#(`sjuP$w?kRH5RXy#
zg60Ktq($YF%avU9KKN0D;Z?)}f6rQ*ME@8P2zFG0la
zOZt*%3+XDdxn;QHt+htdYqvw#j%TAz{G}K4;{kDrnE~Br)ZAf!@Wln07%eHPrF(aI
zaq;P{u-fFLZpRb1b&%H9_T%z6^JjB7^ANTw=lcWS-~Jn0weUWdpy_9+G(-N*q^!E=
z&>-tAYPs|S+Ahp(zOucn6Z(TGboumbf_9uuX%wu=h2SIr;J)s@dL
z95VB=_Y(7!K1a_Vp2NKbXZJg%#}Qu9m#OWMvHn^8^A-OS9B0XO{&Kmv^rT@Avx`y}
z17Cldzp9%q^7{hx>GW|ZQ(=MHECmhikHwht2Ed#|v~YUyoW;82NlV4LImOLD1`phF4o_dl0h-d;#-r%_z5CXNt$uzen!>K9_9i%~
zzQ5QVPwh5`_VRD;JUm<-21^X+8^L$5QN6fB68%*C#&)&%{byJO$sudek?JtG+EH(f
zE~MXUff+jB*fse`=px^j>SOkzBg;D20;77hmo8&{f-de?Vl_;xYD5<=d451t$OV#{
z%$T?%HDo6wp+SX{vF%$pLxm_VybXZ!XAaFJ%!yagAR^sPcmtcP(@0x_RYLxt!x|#}
zA^8SU+Ey4AzJ$6-A#|(_*(z9xOP(H{$Sc5o3Xa#_p&P3z2(Vvr9$^Q&8;NW>t*Vc3|KTZ>@u;#5+y|XN;^O{2
z_%+wWbwp8gwN!|fr*R&+`V|a1F5M%rwl)L3#Bls3hld?!5R|}u&89yx0j>A&g<@qec0ra60t
zo))aA`LHd#}9mGUDd3msnMx)BR)2BlfWuF(WwdipQx10McM6Xx+g^A1Dk
zZFV0vn-H_hB;m8ZtB393{=Y|m*jO-++8A%1e-*`PI1
z7q^;$Kps2#m(Vam$(mFF;+#y4)*W|{Us#TH&v60Tea$JH$*F2vohWrH9D`We=xOYl
zwXdBgm3Z4_uM&9{zD&EC!~XMYknp_e;4nR6iO22xjMUOU`Lnu_NTy@cP=zaNoN-dg
zA%o{6T`Nt9XYEQsIrH+>SUfgu$0`2S{HMX3c^PWcrFwMk9y3T)f$g1RWNT{ZCnNca7={x^C&J64&5z4K;%!&
z&tlleUfu^jB~!v4AY5RkQ)66AP2r7AbP0br#x2h6#O;5_BaizJeN*MPBKn?;`24lL
znE!&3&NBVi$IdpzpU{rC-G78js1Lvx_hHfrN27ug8K`I_#~R_ty0~JCJOk{msYzo~?aqBH*v6aDPcPv`qjW087ZS)04bOMCcbM#U1Go{jW%bEuT&Q>>Bkb
ztXjVA9{b!uefqTIpsr(OHj(kdf(BQV%tkEieeUR49RpE-pj6A)fX1c|a-O&&bFIHd
zb%r+V7vVuSo8PtD{Cx4Yfo?o!YExxUR*hLfJudF0^9ro$QkP%WOL5ERLD=gr*nwLF
z9=#r=y(amYT8US7{QHby{Zi(F5uUhH==$3$-aF+7>S0jM6m7ZmQ80V5@ea0JLkHx
zG=Vng5qJOu!|!#{)LqCui0k}h7QhY_lku?@ieDlObxE6qHgLh)S4`Ah9I0l&r7F7lwD}*?E3E6&fGG-GofH^az@#Xvu55^M
zOZR{yuKh3X#fuwSCe4xsm<^;)l4BQktJwt^H{A^H5~B|r!F0?k53Fx+R6LvsM#Q6p
zu59nh^~<-ni6}7QE`XEBn`s`LsnuAu+YJ_<>?Eq`92DTp`VJ``;kFLomJ&mLu5|(_
z>}(SS(TdKxK`x=ouxf83v6<*WOQzgpb?4v)e!ujJ$CaHWgp=nS@#?`PD^d+DYp3VT
z@2um%nigwrae#=SWfny~w?Yb>@b^VpXl(?pN-6Ishm}{8mkS`zj5g^^Blch*aK`T{%Z?;(4}1
zd)5A9Xfl+@FEO0LZFG^Y9h}p|Sz%F0i!1?fhemr{^cYuDnPvK^w%AHKr^JKPFNN%*
zP^EE_njAx{2WZH<0fG;7&#D$kiKPf^gWyh*CeH$ym;ltfaLF1do5a~QlnA`T%vR7n
zO}2xRXQde+SozM((iZ7ph^i2ni#dSRZiafc2>AzgEQP4ka|({%RV_y5vALG0K;wY0
zYLvROE1ZCYIJMr(XicHsOMD=kM%w7uEho}LzXFk{XXtZQ88(Vlen7hlhQwuEisp26
z!ROrzhbX@qrcX@_wRF|%M)W2pnMgVOhY+(o;BEk_KI&e*xB*rfBM=@v3+IN@z3rbq
zx93)8_iY-%;_L%U}u$Eg7kOWpKu$KIrSffzIQOl?wgFuL@v7D+br
zEnBsC$BslL8h36}^(xsNY2fM*ALgkg7zN&43IVez1TDol5G7!Yk0AtV%MgVrBI#E=
z(J3Iu>wf%mC>oIN^qDFMd9#=Ix~>Ho)rocmG6U%)W;pz^LBGp`YmeQ@QyGl!oZu^=
zgsL=|-ANj-`%zgYz%)T@t&WErMwar
zh#WumVVkN6oSJYt>Oz41$DqG8CF~%jU-&MZIy2UGG?8;l3RLz$BFnt(ws`hV`=nKowsRZn-G1M%ZIw^{dj`qlv+5$`!
zNuXlQ+pIkBPJB7LWI6@BCP!0}83@j$X?@V;OXG^NWk^V&)jm=s``&c%ZczR42_7Eg
zWA1dwTu$nLsTQjh;1>j;RAJb@9KaAWH)$E2TvFeN#2OTZBu)+#iLCAMHoB|3hTf3>
zIEkT&?*!xU#Dq5+Of(j)nHI)_;Y;>&BGZvf4TvIway7Uo#Y*2WE_xw?#%qO!;3j!G
zCU~rMLlao#Hv7yWGblHAkz9?^5s*A?H;dln!R4E`2oybZpS-OcTCz-LxoyJ<-5rBP
ztkBwRSNl!{{_Bs(Xh4na>>^l<>NIshsmK
z{MGz-XmUpPM7WIZXy92>`iRw}iHh4(v5-&CHp*i>aNo2<&`DNM(@Z1RR=ncmCQ)%dV02ET8s`}uW93Sj!dXu7hv)HTxvsjtb>46)!r%4z2
z>?sl$KKYz#V}I_IA|1k)E5-FYxEX#W%|zH&T*oir^i2S{lcg5C2nBCS2-B?c>Ap0F
zwC;eW^N;@85rc=3SStGanj4;InsBbEQ3+m3Z}Z`l(b9CtlEw__M|FM5MYMI$Kq)h
zvU*M;FXLvSjI7vTRfD&#Be~}d*d|xcn;2(F&8ng=^VSw3q=pk5rC!#}+VH{@5M;_r
z<_z0c)%aTK0eRRUwBDFLgbV!_HRux?77djs2WiyU5EyDLXAoP_Cks0zV<*M76N<>U
ziB)#O5*@1IiFl(9noluZGZ^_j*
zo?qF^J>H)Z3*GfBEX^H4>sG{WfAI18Oh{mAK9h5YGgUj?uum5SnFg#q56R`IQk7dP
z0@E`4>r+jPQ>PjP(E_$e`cUm=2ODFBwAOv4Ls<$U*0b0^exEubZ3D;Yz;WB(lp=Cu
z`m7{-n>rw&?tKi>sZq4|@obq}#-o{{(N3L3Qmnx%s~+k9f=U6K*0uVR*!+&xCo-;>
zSC+zD*VzIzI}k9jA!6!~O+T$cG3hXjWd4UW{;Zx&(Ra2X7@vca%KmyFjAy<^Mr)sX
z5VQ%xQAh%~*M
zr=AL2(UM=a_L`LuoVQrM*T^5dc&=R5$X~iikD^sl@D$|ggvWFg2Fe4@&)!P_>ygBwKlB)JCjug%CKOgQbW!oFVaZz5z}AKVX(J6{M1t9%
zvMAa!RYnqx#G28*wjB~d0Tb$RHrlatDMP5D5Xz9YERmA^lJU!Y{)~^Em>A-@!5;|0
z5l^|bKate%UA3F69
zS$owZfr;`nQoqJC;7!}tEOsm)k@*(gj4Rbaa`Zum5T2W5bhqouDC)!Cg1u&)w!YFCDwm4fCmSWX>3QXE`bK+@n+#vXkIu*t^
zP#A2Pq$ki
zhB0ESrW{^}#J0pcSWkvLo6(^)np*NN
zS{ppf(79<%x%h<%qGnf^ZnGf`PqRQc>uHF5I
zumLx|Wr#)DU}|wk1%xTAr$MlsqYo>OA!iW?K5PlK9CJlodENx<3@|3@3Uy@2>5F&H
z9%!rrm19?&)|>-_X%8^P{)y5K$om!ve&A()qrl>NdvBU39rzP{P!CI;vf1ZVqgD>K
z9=dS1^Z|4Fnz5wAk#UNqD5*o;eL(v$c;xRrxvBb{#O
z=Zz#~ub2ioy~}e$&3bxgOqnQMpHQQjmd%uyKG0l1V5(P!T1>u{6hH6maMBzA@}Rg`
zM9s`}5epoB`!i8yVDr;k>aAEkE|JK8XC0jtCF;omjiHRVh%KBpZYW94~O(@8mR^RQ71<+==6o6*0WMjkLK8vm&-OBhAweVAzL?+4L;n~hkl^xO03UQ
zocM;;0==MdCB6?TwTr`=9f_JBNUMlzEVG~*zHRlk9k-%BYg8E!-G9uzjeubcj%RyU
zW(%~24*3`ZnEmM%nz0yQymN>RhV*mnC*MoZkrBT*s7Rd8MlUD~6D)|XdM0xc$df<5d
z52j4~JZP}6*Y)c1nyzu+8>QX5XM+a{2MO;XeBDA~rdu=u2Trv`g4iWlA+-&g~
zS96iGOaG?pEMs(ZRcU}i-Xg6#*IFy!DOiaIjP!3wdDcNq2vuHF&lZHtB1SWu~GFf;UH}>0f#{ef3A&
ze|J2B7}!^pVAlDC-EE-_*QN>((C_iz{XAdKqj+NsK;-d~v0)R#hL
zU^qCt7ZPLk&;HD(lHKp9I2H-x%??|a)gP$^Mgij0edXtg=`a^Mjcg>vbyf}Q9o@6tJC4Kigrl=ANi@w-M6PjpdXa6yIcd^llR1dU5_!E_A)Q65EBGgeUC4vVq
zZ&!(;xIzqwL>o2nnbj8AQ=3Q;3(qpL2vnQoJjL%temFS$aV;N*Lp^TqSm;idlXc9W
zyro(NpHxjb6Ji80;~^nd6Cot^%THnN#HQt>`Hbi)R-Thv@srf4mnzYi%vMI?Fu&?>{JDMomeO*_RnZXIm{wKo#q);7-y
zyV$Eq2q`A#8v&5;Y!@=Pmf>O0GBTNOw6QX3C1#c`zMQfvsBonAPkt7|YJb@w-|5{L
z&S47YHv#WLd`8KHrYLcx#9})R#W2Hv^vjoTzv`Pf|MKbb`+}IQC(U#K@TANv+t*LJ*0M%5rk7
z0$2s|--ZP4B^oEX*8NUvEddmEJWA+nsnDrFR(Oq|DYCEBV>JpJ{>t!#bT+25E{E+|
z5m$q6tI!JIY5?MA&YuLy<{B^xqdn`qn9A&4IWAOkl#dqh2PG2gUF3)P2v
zvW~YVbAHRz7z|Zf^aU&K9SNgn`nyOOss}vJfZmw#;52240Q&1(13pjXT*Iz=r-c(d
zW-e4PH%Suk{te4VUv#?|B?(4fm7bO5{?%{za0BdIDDy*O
zOZ2Cn%3)M~pHN+4?-{9!+id*xh8HkZ#^+ph^Y^G-Aa`(o@+9y6kV(-IxXJ@5J!N8a
zeTo!W*eh2!byw|q)IIdFnsL*Ht8Xb%($?ZiBn5urX>e{a%XC;mvSehlShob8
zxkTuF!W!Qb
z{N;lbyDpzOr9*^M&pwp+f$GMOAGTbh*aereA=bz`KHc@+;a{n~<>)a@Rd7cv1B>I2
zx1b*J>0@JvIn;ZF@1DH)&4+{5$7GwNQ_a^`+K`jL4*yVupipn|44fO1VzbA2HyW|{
z*rubnFZegUR14bvUhnydTweHc<0*e3UBDYZ9-T_ieu*}da27-r>1YoF19SO%s;@U5
z4|F1rA|e$41{LRmLLhAcazdUXXnIu9AUNIY@Umg8(QflVWdk~5Q_j0~>~&S4-P^pX
z{n5IzA$<(d0%N99w|;O*`L+Z`SGVYAn?KrxX;s$BcAfrWS<#9XXgez1)74C34c7UF
zwvqHJD}G(Pk&!;BJ$gJ&)k(p7y
z^t~7?HKlM|sQl`Z5~4ahRc)xnY?q_p^sr7jIZrFWPGE
z*pdpkaXDK&gTWH6_)@DlBc9QxV{}7skAT-UzT5v0Z50s`LejWg#mSl
zXWI5Q?J|noCYI*0-~(EQXqIWoB|+*p35PF#q0nR^dwdjI5{(*WD(W;P%SBFXhXDEd1XbkS(OABPN&dOMeoa$Ix9BF2Bh)KWY2
zPC@+z?c;55Z|$F)ibiLrEi#KUz|G8BJ`4wlqmbs
zK0NQjFX&GCPE||^b{{^HnkSLD7l?O^?72Z8yxVIc+_jN<
z$ZQCOtt**i5A{
zMu!N|WmsFd^hE_{^8O({ycYL`^(iLJnBejO7L=w5V69y@CeQ
zkH)1Db_Zlu6AzJ>2ZAJ@!uYRmWh^c#0wBF0>_4&mT;z)~1aoWy&dB$C=>@~3cQMk&
zxg>~$pCjz)^ARz*n?5#iio(d6UeG@)pJ=o#Qb%bJ*;^F7#(a1;?zh}iFZvCbe6&_b
z=I)_;ceCElS^I$gL+%J%xzHh}8LAKnI#4U=!$g=+sje=$liB2GRB3i_bD%JI-&ra}
zX!jz1`m^r1zG!K7=q~D$GLPKly}Hg(D2g@E7)Xnn9~A{6!8M(5;4*?R3qs%L9S$iG
zD|E6*ixU2rbK_lq)l_Hu6q&xqgzyCL7F
zl9Y8+Nj7AVcHS~q;&;W50C8CxH^2UI5(?;xERHk8f(OBgGk3;yP@z(Zc6Bh@5rRS%
zMJ-o*W%}s9`HB1>8Yh4*s)Ong%5p)uEcd`B#9VXMp*>Qy83|w+{pu&uf#w85R!_%1
z6Nm=+u*}W=+dmCy+@E-wBIuL2d1L*XmjrMb%u!J@=Ii3}@41)D_X1$MS5nN7v!9G`
z42e83Lua?uTTobMuvs|IRSz!t@SGsOaWq`(3p`|WJ#Z&n(=<-l@BoNp@Lc{14Dy-l
zCK!L0kCrRV3l4;PA70ZS-LX}e>hY0nw6&D^;hg;FzN(V}hJ4U5
zS`Esz0**V30bZIqj;wurpcJ0W+c{9iL&@KgV4YGT^`amiae4%qPlc57vdL8=)d(}c
z&@UeegxD0R6tPrX=&37kNp3xdt~;%Y@1j*uL;gto4l>yRN!M3(8sx(6K#7w8*Eh?U
zv~=BA*ts%K6T&Q_0*7H4*yDf%unejMktgfrvKtmdjj4YvFrBTvHu-QnN+o0k!
z%DmuHIY+=Hggb}7*<{Z8e8;vlmmi{GiK{VEL@z_G^LZBS(>H**KDc{5|CaxRnaFnv
z*E89x-LQ)3T-mK;Y-ddXtA;Uf>qq>X8_;ckwqQEbuUj#j;e9m&$83y`GF1
zrCJg0>uJGx=1Rw_#d`hv=c3%GAt>|Z%-S*nH@N0=`a5Ipej$dG``mvMsSG>S(<9
zwTk6wKe(SFGGje{!JI^8Y4`W5dCd5@9%ijOo%1d)6;~WLLx=VKW4>HG{{d=TPtEqh
z(Xxnp$|=4_Y+?@u4!*b{{hq4%v&E08R93GH<23J!`1ANSi`g;i>DwBn(&F
zAAt!@{5^KWwhZy#YE+&cBFr3_-WsZL(|`S0F?dQs*A7LiE?CiYe_ui$ArbX1@RCci
zcL0m8N;dF%x2NQWa^x!oo3SD>nKbj3afs{Sb|{qkn~1+nOzQh(yLoY3Ep2YCv^wK}
z7^^11vyXQI;eY7g9`ts>Dvc-Gzf|`ZD|*`q$3Wr0L-5P~g3VV@+STa1b^YE>@8&#{
zBbeuK4@>_8Bz&H`d;P@r*@OAGxVD8Q(g
zQMTv}G|%VmPN^0H?WA((i+3>?-O+;px6z8l6|!@J`w{Q*{K`)kVzh2bgM
zkmWk3K1)v>&lX4#GGv&u#|irr97v9%ZNAQE9kuy2Fp;h_W94jA&QN?oIfAU9?Zfy>3DL7&-1Asav)CVWK`M1VSA+)7Eiqg6)e>V(>hM*!!uAz
zcWuxs*(1IWR
z1%Hmt-njvA6HA!R$IOb8+b|6-?c2}cUji<0*YKw?GTFYg*SB&TwBBUjr`*8`@!_DL
zBbjf{a@qli~7Ga_W
z!pDX?^)#Cqh5=v&%5R^cLi^@pxL>-66Vh=^sPU+*bF^}_R*hERrAITRsK9Fnjh)Vp=#fC0l)x8-ZqhCz-cC409Wc
ztXA&f3^2T3^wWx}i%$BRJuzyJ!lW4-HjbG9(CLBBrg&W(ISg#@3P;`vWpI9+(3pIgLzXfL*JxrI^oG}2R$U(hp9at3&4xYA3@
z(!x0D9TCr$Jf(sOVs|M&KzO
z&4f&4&?Gq_#T&PB1UHN7^d72QbTwnLs#=Xo7ErFYeMJ4ZlG*mU&8M`!>ex4kePGOG
zZx13Pvv1inwlsw;V13o>d#2o+YMhRbG&k|4yiiDsp>{_@zgeu{$W|FM{l^BBz&;-7
zbA~?!O*CruZCz`%c51gva-YOVe>H*k305RcIml)*?iv*CXEoPoN_?@!J;qgDV>Y=B
zx=NmN#PhoZFTN1_Z4Ci#p$!o$RKT0`5MkJ&~K+-`Hns;jK6@c@^~#QE)50x(%bHSCjSaL
zpO+@%u8-JLPsp*1c;^v$uq|a_X%UO7qmr8#E39OCCDxI~hYyGLtz=cn*pneog6E_4H9O*IUW!is~PgS{%S7Z^8?agGf~%O)>Oa3?$XKl%0hK$2-`
zS7&YkdY8SLAi&8TL2MFIO;&pein9l^*_{lQR%4ZF2_$FcaR)q=e{v@c-6$cvx-$wB
z;=w4n9Dr!0CwFw<{j*
zk|-S`iMZ{2_^J7Fd>MX9kYV?Iq}bTb?oH)qQ6caL(*M|S_L{bq#~aiS|uux|5;l@SNSZ1E!t6$caiaODb{NiVG9LenYI
z4GswFq8-X6kyOJnlRUA9OL}#Z&ZbsCH169IrKFz*TnimRn@gX#DxcZLi
zbSlx*MlKl6A#1?L1kIGyz^Uu;K<9_NnblE)k0zb_y(xf(MxWOP27(+Pm7i8HoG|}MV&&9tA
z@jq?(J-BvCfWa2qgUhNlg#<3``Vn!O-94Jy{u;8fLEMxRx_q&v=EN&O0>j@4GL_$Z
zS{AY`Y-2K2*Z?vW`1u%_s=e4>=@6+T_pSN$wOA)HqJKB~p=$g15VocX;~yr(XhJf0
z_F%p6iLXiaV2ZYwIY#)xIBo_6ePh;z>NP&kH@=zcCHw(>WON;Q#)b!no%P>w%>&9fc&iREmYE0E+lY4<29@W9aOZ-3|3O8NtII$B67M|BeO_BWsWU%7^bS;$n;s+Dhb|rz6c%I36n9UCQc%aO^b);>
zehsUFPWwhM9v^*>s84~2y7Za#W$ydrti22A&IpDXmt&w0xL)IWt#XlK0EV`Ccvfj17E0rt{?mP%f|gXIWN!BIniY031GGqq+vgF14=LxE*0>ct@Q
zK7`IvqPnI;#fuG6UL;Gk;wa_i5lh1bW-}uY1@huQ7;}WF@WpZn!I5=A6Ahku
z#3#EdMvYORAm<(txR9Dg~+1`ck;cx^x9ozst>7xpcPkovHWH*0|!}HQ1N4C
z+U;uw|1J^{4{F@x5t^NFkkvNJ2@$&%*bHenrrT=C$!AD9YBph+eOup~~P;Rvh_fzmAk
zKO%X-a1%@Jp$G)Wi-@%!prFJUDy*<4MlgW=o_n2Zzn?>%s~+~#|yZw$h?
zJx6xmC<~$VjOSLNkur`sx3QLcpMn{WT1%iEXvQIMfez<<1r)M8ke-wYhWJd#aaauw
zPvbqvx5y+!+`po52ur|yonIjn3Dm$kC3X@-mh<~?ZsP^ug>pIRM0jWqWO7qa?ETN!
z_W|IB`RILL^ONiLmzQwDXCrJ5qnWRmAPXc=dWk|sFj`p*3vAK0jIgHS&b`YXJtos6
z25-vaI`-~%Nqw~ZtI_NMuSfr`Y^Z&S|H=JDP?EiOp?ez+Xwwlm{5HJAIg0h2DZ
zf&s3xtk6>KXn?>nyR(K?r?Wi>hX)4cr+P8#l~$C;Sr+i=)zT|O6ugCppq-9cvDgg*
zZvhSAkWf@qSyAE_o3z8JQ57NX%BfM=9a`ue<$NgR%x;9Pc&D3&Dp($;K)XoX89l*$}SUuo(~5
zAht8Bxy>{sdw;OgAIaz3#vIwrK3KH($HA)F-L}VjbE(J24g)trzUaggH?!(3)McQy
zkk{Q0Q~5b@_1Jg8{6J067XzD-Rq6|s)FFt1mWcBNR6e6tsc
z_0qQ)cOiv+*g~$mNSdj}%ml|1$5Rz}IyK*vu6z~@m4&pQj*Y1EYiIb*3W`2POZ{Vg
zcwi|4@Ox-|BR_!42nlqFH5fG}9zOvI?1rsj)(4%jX8@#wqap|qM<+9mi##DCut`yh
zi}A*7yUmTLI=u&E95Csng_6!?L+DoHQggg+tFXvUz;=?q%q&Ot%R|3b_
zD45W!d^)R?j@{vcnJJL6HTxE{An>(&eC{^2CTKG^AYdKW-khEU6IlFK<3uZ+SU)
z*k=#@7NkdqM2QTdP4Y|Jmxu4GWCdg5X;l{ms~faM=Z1VMzA
zr+2_&Dvfgj4xUci-_RYv1~I?6GefylpKss=*NL6)xQV)sq|eU>^=6?66iJMoNKPf~h1Je99cT1oS}d4WCD%M&m?)mBw9{
z;Gv*8y$29YnT3Mfy|lac{5+u`MT=XyqVP}lDYmbhD)pdfg1(-OtbE{~E
zHRqmKC<`O(Oj1P?G79hfw_B60!|z>#dSso{8cKlCI8|G%-QufxZ3P*
z%x%3T&ZC{)CTa}zB{so9WtJZp2Q9d?YHz{<928Jq8X%$!wLV^K;;-4A=df%L7z|54
z>G|D0{J>P>%o`}RL6_&?LL1`{5DgrH{krXmClJL<1ECF0((~G0J_zRf;MmaMBqPB=
zhOA@~9xf
zJ{bt#;8lVrWT#qq=PaZPg{FqyknO>wG8)G3W9!y{ik_e~lHJ?O^^9Qc#vqx5xLXj<
zr+1Xi^cTtfCBKmxc>d*&?J95R+%Z8KealTOBOe~#3nerhBMelon5M?U^E5Dri$44%
z*40Za>F5I?4|;Fe9f)+4a6vHfq5Ki}@mT~ll;j+mfiMc)2fq>x1IZ3FT*3;tm!0Rd
zXfMu=G$-Ob6QL|7rD!r2f|*GEPiX7;U%{l^
z*mqKM&f~BCMn7+&;Gg3asdH}AdQ_NC!S<&}gE4zMU{N~EynqTdDTszLl9!jV5omz}
z1+n}{6!Z3rlP?N`p~+OxAefr8MD>TYRaLQ=Q;Ez1Sjy0ov65l-*DL
zBucKw9qh~t_x(}Gz6wNRN~#DF$Tj9Q42}|?Xb|1oQjKXsaI{Ea!j^L=Owo!)O;r=Q
z!n_goE~*k{FnR%#AfW*C-T08bI_V5fqaMs=mYmT=T>l5Hgvq-|2RK@HCU;pk8SiXZ
zH^*6fXYbSSXy95QdCE~))OGD*Ya4QHRqKm0ZDr5QfPHuH%vpHnYb!FvId5p4g3OXV
zF_s(nKm+aI4xnogPFbm%l}JWw-Z+yhtNK({LF)~TAu3jBP%?WN_v0|rEi{-6)y+0m
z+&yOVp>2m%k?fg6XE5b1Wx_2b>w44><5G3j68nYTWeKH6*CjP>R;S+BFDI+F6BH8@
zOHTlfe*lW9$2H5SZpHNE2cTJ|A_`TeP+sT*kfMquSv4nb-hj#A(Vd6we}*jQ3IKny
zJ9n?M=@C)TJ%MkN)$Qmd>`O4!Yq{2aysS7X^4MCL2Z^-~&Ij+-s%cqbQoDi?Rw5(Q(Hg
zSL9cEm4Cp$aI+nEI@-HhyIb2I{>dM1va|icAHHjDZ~OVdLp+@9^Pl(cceQl?yP|7`
zp_0cK+~|G9^Aw%+?45SF3lsX^+6&tyQC0M^-^fbIgQnJpXKMwg
z>S%55{<*V-oQ-_C)8P+`e5(3v4}bY{Yct$4d?AnGw3p@Wf(JCg_3_=5Kik5l&d&Bn
zKeaU7>+&9X@mc8CqCwnkYwbw3wza_(;B%z&PRoP4Ao)b|81#`6sQl2?%|78n{lAhC
z6$DeVzK^Lw?0ZGf6W>QoMgLwG61pNNh8PoL{|}BP>gwk%5UQrOct@-EhDD|9Q9fvG
z?riUBzu$eUx&6WI_WSo+n_IkxNgkyrFv+5d9`Qg2g@uXAGX6tyf=trp&!ZrbmxGe2friAaO$8_p+D1|W}r$!
zEU83=>dcdJ1L|tblM_r(OVy*ITwNT$zHd>tV#!!6QEM}}o^DZ#CzXUwedC6`MO{h6
zEwj3$`ue^_Raau7X4KkYJ>eGXqQS@U4?>I!rY@`1#mXDuK?n)cv}6_T?`A&;*)&8`
zHmjq}HpGLl1Vc?E`GZg_S{XO3!=8X1wk%nn5-V~G?@yvsbl+`bf7l4_wiT(krn@+5vi*ONZIAx&ooSfR
zk&0EuzV|D;QL@8-P&pyHd@s@>d&lhZ16`!`f4blLYYVHY4L`QG|Ce`NL5UW`>o4t(
zZ~+&g1>Xuk#^`cu;CF8W-Q{8XpRA^bVAbNczvDNya#nQTf9!0%2OobVf5|!URumOi
z7K^u<0#m=mTSZ(JE#9ii%)~3+s+-4b)#c;PD=HczXcS-0U=me)3YCGd_!N?;9Jg84
z=w^Hp-UI0Fj2x#`f-ZuVj3#2rNnw9H2|n27ria~s?PzO-)fm`{OZtG8pq}wwyJ@n~
zli~cSrHQCeHaZU=&G@hPjmadurDNo+*=p}3r|6|9bP>hZ)&d7~{U5qai0aUr
zv76i5+R2RF^mBJRo~NzlJ`A{`WACo@m@BH7*joP0ll5Q1(Er8~=8U;-_!@
z6hMK3i*P{I6i})v8Img2I-I}(b%}s-hWj9C`OC}f!DuD0A{Ih~!>XpR5(G(!O3_+}
zZaAzibDmm#9wBZ^1&9LcI>HfEQ$&e|o{Yw7UR!}9>M|#))M~^|f2;&i)a2)gs;Muf
zikd0ZJc!2;b(wS2?p7p!_@n|vK~yKg5mj46#iKFRh{L%#qOL2V)>b0+SaJEcaEPK2
z(FliBZQ~Pq+z{0$k561@vv1=?cIS2e)uJ=M043e%x=;lGgSCYS$5(CLDm|tcf&$m!
z_`25k!deKGSb{2*EDoz0!b&rAQwu(J6&mF
z!jxn_U0r7nYkbN+e3|PRaaT8;^wcrXDt+rxJZ>3^Q62f4zxAutrqt@kmdQ|+XMVpD
zoeI>T2-m5#b+Jv|ur#gK?Hf3{E)iXbsN4oE_jww*2L9kNoyWe|U^G*drFhIbX?*}s
zf&(}opH5R5C6V*#t{VHAtZ1qw)_PU-QR}_-M=^q!&UPqlags8C>(LQEfWkgks4cF6
zexPsO8xecrp~ns!WXu9-y+^Lw%fQz{8P5ff@%$>t^?GMvzI`d;mYRu@!VNXBbjtBwmTXUJV-_+A(EWI~1O
z)SuLzPd+%otM=ld8J1!hQgtkUuGCHzT27z3fSK43Oe0xk7?ca`$wJG?Nf#isk{E~H
zH(;1w_nDXzEiOPlh<~AIM$Jn=pCTXdoKIC*MEMlg$}4OD^%VHI!e9=o5mcnN*tS!G
zImZes{6Q&&i}7>s3pXyi_EDDjT-dTm8cR;s8ykf2YoMLh+*_Z|>
zG&Nb}QzSQCXFs{CPb&Z==bV%uTs0~+$*=@HUR{UXi$Y~%%KzuLx#c70)rNieE&pO5
z|7zQP{>@%n$-i2>o!x&8tvA+Icx9z}3c5rsJzC*-JZ=+zOYu0JR*PU0KWB>wu|?jK>s?@sy{
zFqgS4ie#D5#lZMMym1rVl`Y8E_qr)4HBK&x=FOu&tYrkZejZ
zQQ`(_cmcj97?XtxAjUbfwTBpih9MX_pT@$=?=^uKXTjDJ&XlBVBn&aman@)!vv-ej
z%SXAbMR#u;Nw%D0Tc3dyDXzt9-e!>_@X8S=38Kzfvvo7mMPpJlnyk-!500}caK>q{
zbrgOyB_$re@$^KV>v$%y^-OqjGTQ}&RWwbG$(LDh?o2YUMp7;iL4uoU#Ef`#{Wa+gXbOA$oZxoVIzqI}WIS&0q)#7QH**SCDwwo69j^9x
zRFi_JiyH55d$vqBG#)t}uCAiCnqdkFzHV~1U^g@<^LtNn=?_Jqd{kd_zl**9kT=h1
zf$*xYGA^eZv1mf$l%=y}zM=IMClS_-1z`!%gh)*@j>sE~$kQTmCjydF4r>oc#nQ}}
z8RdTV*+SjWfXwbZ=LE&NL8Yu{Q9-)#(ddg4`G&-BZu!U_eQ7VP+G{JvAh}e?G%=A#
zSXFk-=BoettA5H?;Plvf3S6l1Xe=J(w7s*%yP=^e38Ku&v~?4_(1fI+nlX;b8;(j&
zy{(^_GG?eolFyW!dRs)j3S#@C%V
zgwFwCJ3Ys_p7jT2JsK57NrvliuIB|I)vjNzr!4A%BuRn+z<5M-+Yv7E}tJW2gt|v@gv@TCq)aAr~
zoUU0qmmfsfNV5CN<`6eHeKCJd|Ff%RGl+-!VB>=!I{GOadm?-O&2vWrt?TicoDuL
zl+icujfg$*&|~NPxa-=YOG${Du3jEIIX|wh_;Ds}hAm2lWS$cFgga?Y
z5XsqdwKrdrQe4;L9Fb>B^%W!X+$)?)1rX!xx!OZaNvKvbPU%t{VmElw<6OJ?ira{)
zbaLCE2uJ13K&4j&amt=K$Zaq}-tFAhqCK?Wt}nO~{hX0kN3d1(s9?o8MfRq{RuUwc
z^Y`k;#ElsV(~R?0G-pe8L!+`nNOHDc`N36VQdBL$G8E4CJ6ok|D>&i1R{cF2Ng%4gTagFkoMj*%rnO(x<}t=r{x{I&ZZZ7tr7(J!LR?wBB>6>qTR
zetV|}lBWAa?AhnG)`u-XYW2VT<>xlCq2<@6W+sNM5ATtm?zeV!b^kzqkNwot*#*5}
z=n?+rKYXVt?5gcQcf*N(_@&JolytcQefR&fcXdsPBAMHnL%gid;tz#pg{+J=Ns;>MCC*RBhN(H5{
zXi+o55GX3MvWn+&Q=LSj&f1pKy4>X`HsdM@d|yt&e~0Qy{fIP1sOQrA%a^jO{I_W(JC67>kkzIvd0%wo$dJ@g1(WkA-$ucU=Te&m1
zF8!7rv=4JmB6D6&UK)R;5F_>!+ML8|h4XTXbYh<^q2hZo5-NvstClFDNQVC#E^~@>Ges(e5`hfxV={xrf4hV`1}+!H9)$iG8)g8!
zCHAe-s8vc>Yjf6bM`&{tHUgq2Kw{%^&f9~1mauXYmBKENZ+et`#X{uHLf+YULx#b|
z>~5n|?F1*M@!Mrc$0{9>hHUV7d>q9O{9uf(N+H!~y4K+lGv;1#p`WzUtfImy_aLv$EnEGpv?`-kKleA
z{5ZD?TX-G8&ktO9TelOs@V0Lwcu{Xo{mNTK7l{q8Yma^{aSK5LNx3TZ*s(hn%(oi*
z&0)u424&jG@}%sZgSdk+BV6|rYSEtw~kg8+8{5r8ouJ>ZPfhM
zOr=@jbJmGF4DPJo183cojIhyF;XW=(x=EBsZ76^4tasAhH;qsvDspF?Gqzb_
z&x}32#hvxW?eE-j7ov*%*w>wN@;04dqe<{iV$yy;j50Im!@RvcijuR$YiB+>p86eU
zPatuaCdv~7-}UUt3G+!vSm$1Qmzvs=sG73$*!PU$+`j{_T`~fJNTgZ7h;`x)hO&fv?VS@PqArU@K=6D0G#4cgMU=>GD1Yv?chc}zf>JPOKz%*VSkBl6
zhCiKn<6e8?_IFEOC8}$N$}`$Hd7GxPgD(y)IQ7Me`;IoZ+59@=HFwIp)smK#U@-LP
zi_ZB>?H`8*2fvF9L5~cz&xU$`_{YoMp_lG$Jsj%ejbZd@+ldt}FuTbkhzvY^a1Y?m
z*swJpp3`Pu1
z0m?
zC7@DYsf3bH;Eoj_f6Cc-9^KVL6?uB=fu@PNR41?zja>h1W
z*jwN8u?_NaFT8`~RTWcF!qEsPFDLIc!1eOQV-H#{Yi%f6?gn>|v2sMv!(xbM&U3~#
zPrfa_=WcN0_II2~5*8FqjKBltO5_n%a_LT
zMQ_6*;GTL18LLM$!;C1rG971ZlR2+HMk~c_?x{C!f7j-`Xv&JlOUiKaUQ6D^QFq5h
z?w5Dz43{X%p^(AXe{dq-kSFf1|1Bz}A{$N18?sK^G4Pr4dtlA$k`mIRe7y;mBaP)q
zpbgE>{qGJkR@FjcBr5UAHeVV0h-%rOQVJgqH}KD!JO#I$O>5NW-g_s5<+3a&LXc0!
zab?|v+8?&;^)y@hjpB>WyD1?1+!-nr?fj{=vr{R=*kbTXv1kvc$$RGEquF$&@H;uk
zgad3Bx3ad$A#*759%6=XZ
zxhoN?XkpQmLVWE2H?kT_5TgyFh(|;^8N&=ndL$(BCG?!JP28gVx}9Ig^M`ounCB%l
zZhyzqnGs!czM!)6=JHW3!)+WoznK>KVJUQ-&ebvDw`TVbiDPca`O7(L$4omAA0=&Jao_3
zS04K3{o+1f9F9HvzTYc0=!dU|dVjh6>z$XAm16q5oVxJqebM1wwe!%Yt;)%=wKxjz
zld~wF!c(&i;B^H^N1Oy-)x3^G`3og-7_efu}Vhxr`yw_cuzIW&+KqhTbI}DqUT@O~@B}82i$kJ6oz>eLq5c`}V
z0#NYs4&GV!;tB1Kq2ySlFj6V}j(4}5-#1Y?hCa-nm(wT?@I>!lRSFa5<;51DCMbG1
z6b<>kA5Dj$CK}XG@Uj)!rYm*5-%}TPc+6_rv(j9-cdLmd325
z0*W8le~jYnujl2ZN^#8Iepe|ER|<>Fmt~ttqtzmSmKwt3G^?DY+f}{A*%O>S#_P$(
z*70RzYPu8+N`l|nB^;Ue5SdaB5r71oX!Y36?-Kl=<(wC*uA(iy#w)96dWuLwt2Anr
z5*O5PX%xkCL_EUW^2{5nv|1^|SchmfjdtHxj@LkhE*)B>d9*!;Q*Q`d*&DZ?u{g>f
zTe~SB#fMjH6E<4N+>7mDS4tP>t=!qAk&yT7>h{?ZOpky1fZ|*1(lGB$2}PO^7qfDD
zhL;Y})(KkPcMGL^6amywA75{cN0OoG0WIQpOp^2H9`Z;gJbFtJ1t9K5=`QBiqH)>NYRKkvuI+IK^<6gk!TF$grv^;v9*-94_6`AqgW(laW=-#UYXh_
zX`GoR9aaic_QrqQ9@qe=qH#uY&O#1lvgmZd9-gxfN`%_X)bWmuU9>eW2y!qQP;|d%
z)VN`N54oW9;13BLD^&{PczlalI|NbeAetU^B`s4HAmnM}-nDAdS7kEk1kH@2F;|;D->TW}XoZ
zQYmhF33y&kde5h1Ofg+U&a5dKSGf?wkAc(E#3g2V(az^xO2*^F<3`gvfZ--Ru(s&<
zh%_ORf$NAkk!9X+p$%uSQd5vNFFy|yPtg2ZHzn~b7gmp;=3U}@oq#s0D=g2E@p7eb;
zI8>eW>;3L!AI$nyrH@~t$i3>|&o7~)Z~nKx2CFYCqn=c;L|(vYx3ZtH0VMh
z=IcGUQOEH$R4%eoeANigFiyRO=*Mc&T936Ng$%_MRMGERFkCfur)qR9G8PP=fxucQ
zf<*-J+?lnTWr2iRP6nVXoke@D(qsM^I}?;At^dekd+?Dd#&iO&C5R}t4oWU6lVjuv
zN{m5ix&0Bmy5%h7(c~vc=cbpd6kZd}jK^bmdCywiviHWUU9dnar71Q)gI`aQp|X`N
zD87YL5DT%l-`RU5Zzz#Eku*q2Zw(F}%oBT)?W9O<$8{wsW2llJshphQR18+#c$`-<
zRBJs?%mi`?JU)&y>+F`(%jX7HWJNQ>Dost}YJ{tiFRVtS9u&_JI#{_0
z{Be~~15IW?6wJrT`xelvM3jIS^u6piS0LS~Kq_Y|I6Yj0j91!K3cE1VvzcW$VhDne
zUuFiUx16Oh5aGWTaeNz`|M4YaYJ+Y`$MM9@d3ljEBzBB9s9h6iw*ktBysyqkk)hgq4b%|?(_^o!xg3sdgYwy)Ax+48I@ED?K1_+d
zg$xvw->|n|(KBDwf}3bRW0gjog+ul<>Z2;o5>H98is3_7DR^J;~HYgX~HRD23o~!v^j~_Ao9Y*f}PLV`CLfq3(0Ms2o|jW>!nHn8L_yU8iiEIah9%|U25vZtT0zkz_&DpOnv2UcJW==%
z@+GbyowcmbW>QJUa#0xQK>1gF$l7Vdh#*o8tt9NJPv~@k_}=!>LG4>&o8ZYjD0cEy
z0%kdDO=_DAUchpfJ-_QFFPYT@_com-MhlvrxiqH>v&G|E-nn6Pd~{(_iaugUEH52F
zKgUN`(;bKuV8$U41vOKOxa@Y`?SxrzEv7hx0>Pjp`@PPA%Y=KUStJ6d%P9!0Y8Fk<
z!{KnXzyL?lBSq0A_*~U2Ow?UcC`{U2QY#QPeLL;d4wd5x;(Agqwq&2qp!flCYU!Dq
zIJ@hHZs+%ja)JIcd(O%l^KOY~MES)F!+5iYrr$fuG5h^63uTh4R|+w_yH(d>#LF*c
zp#QTtgg%KlFC97aXBQOZa?VYDyAlH>{eauL0Df=_1XA^o(ebrFoIv+L49lR^>0|&-
zC(vHmMH)>8YXL~QEEr)u^l)Py97wGI=_-O;`RcXMXWfr=sYy`=GLMMuT}a5avNO&C
zd{rq<5b4f>aS(>1;?^q*-4t~eOQ-21H0|*%Io~R+!f6+!BRLhU*O3=hov@Zi~|AQ-HX=O_%F-c5GCQ2a)Oh2+Y8gExH#~v%ev=Nwy{#tceq8|j
zPAq^RctxArtb7S1x6ojgz4yu5Y;6uhkD6M@?-&7}G4D>ez>>?&QEPgPp$2B0i7mN!
z>Q=u=X4!Ej42h8l*5dw{JI_vCZg8Pf+m*tiy`RHzkgi~svW!(a3lB5zi6Zg9LFm!m
zYO}`fl1pz|QDVP2wFY)$?yz7?!Aj23{GR+GewOO#XYb`EfRZb{E+C
zXIQ0kQ8iRksH;s1F*|YSt_omFQm>B6yOM#CZ~Gk@J7{sKfEm>#QSp1jN-pOg7;)7e
z20JH_CLFUiW(Y+qr6XL3qsjS(ICHDpkQcX)C;b;d(ffp5mmGIXR~drVuyoav{%?AJ
z8T=XQx3I6id;WiYPwQU}4!)@U07|efw!a;OQk4`*z3!*_m*!yq&p!-!zONpjrwk1K
zHPkx*wm$pxPxeW4AB*>6
z48jAx^aYbDw73|#Wzk?q8<*kwVsfS`T`m!}YfEdjKVT3aOujS_B@|NEAe55I4}?Y{
zLNpldc->Ww(0htdHg(emLaBWB0ii-bFa(B0j!=%!s|aPqWtttt+bZ~FC+GnsC~G0VgE}01-7olH?#Erkx(GQ<$y&D5
zD69yoW+b81BwKb05m>jjBAt<{)}N~sChXHwb`aJttwNC@SgcC3PSNCif1K9t!(<(Pf8WW73O1^{Fa(mf(rUTigt
zFbpe(Gg&4gZMsnSQq;m*ET6_M>WgDprEqlo5z4}4#!>tTr((65;!uL5xQQn>uB)#4
z`9_E=$RSM$wKI338We9|&Ir+^kQfky_bOJ%jS!!?=q}Llq?F&G5h6y+fGErNDi4EW
z?{-Fr(IYY&#OP7)&;-#~JE2Dm1=mU#$uUFWsvv}1Y+9Agogi@y1-FzM
zDiw+00=v0_ZE@ht2yJxWka7ea9CeM#*7KL7v#|Nrb*TW`}y6#grfe*m=|
z+lix1r8G|1O1n~3ka%|ONn&tqYdmS%eX4*iX-lCz?5*XZB2_{HDjpE@2Kh0YNzy0&
z!p_ZsH0dsFQ5R7C;LJH^F6Vsbo0;R-G0MlDos(MoO}xD#jnuQ%d=Pt|DxA2_>;)(%
z0hP`noA}lJ&i?K0>QZ~<3D>lj
zxA22y+<4S^*2KGS@b=wyV~v{*Z#~1mE|Pa={Wj4Y{<-+!;4W|AwR>FIo1yi7qxFw*k*<-h^_-++bcF(s
z<|B}k+&O{yY~J@OK{A^I0t8?(p_n4-^VKlNEz2y32nKu|8Y)*=plsKCL@oSbfkk|g
zy61-VLKq+z`phxgy5^jC1F0!3>XAdvF{dBK%_8Vlk9lsln<)vz57)8#?%T!9w
z=p{M-E%EY#fv0AmDy#Y>MZToUr{J8XtC=ry7Rs7hR4nUEoD-G{&JDjm>Cd!3h`nm4
zRza7KyE9LVeH_`27gR`J-wOyibVH^CsW4UZi2}^o4mt*4B9%QDqn}9cLe+)@q_oV&
z_teC3RTBw1|5T*Z!BlYF@KhWHUDJx=dD)~PU4VXGpex1nxS7us&jkA5&2|C$|9sK?
zw~O>*>m2-!8*f^Bdmj$g1JU@?=(Kp6sq$oBH;}3m&%(3mX?Uwwt%+%0TB=`?~p`
zmz6t*lTUMkZ@Y85dX{dt;9cD;2Npb%^s7`BMP9E`sWOz5sfc5Qt&i8zN|0%$WWsNn
z-#)H`eMlWy_@pR+IRl6w>@dWQNIwuO2XC&R-FY}LQ;bIV2U6_D
z(aIZf!aaJ^g2
zFUn&fcNQ~oB(nSnn