yc/java-10561
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增审计内容10-廉政情况接口

Browse Source
This commit is contained in:
yuance
2025-12-12 15:22:07 +08:00
parent 4c022d3c21
commit da4b230bd7
5 changed files with 1080 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

431
src/main/java/com/gxwebsoft/ai/constants/AuditContent10PartyConductConstants.java Normal file
View File

@@ -0,0 +1,431 @@
package com.gxwebsoft.ai.constants;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import java.util.*;
/**
* 党风廉政建设责任制审计常量类
*/
public class AuditContent10PartyConductConstants {
// 大类定义
public static final String CATEGORY_TARGET_RESPONSIBILITY = "落实党风廉政建设责任制";
public static final String CATEGORY_INSPECTION_RECTIFICATION = "巡视整改工作";
public static final String CATEGORY_DISCIPLINE_REFORM = "深化纪律检查体制改革";
// 子类定义 - 落实党风廉政建设责任制
public static final String SUBCATEGORY_MAIN_RESPONSIBILITY = "落实主体责任和监督责任";
public static final String SUBCATEGORY_EIGHT_REGULATIONS = "落实中央八项规定精神工作";
public static final String SUBCATEGORY_ANTI_CORRUPTION = "开展查处发生在群众身边的\"四风\"和腐败问题专项工作";
public static final String SUBCATEGORY_DISCIPLINE_ENFORCEMENT = "严明纪律确保政令畅通";
// 子类定义 - 巡视整改工作
public static final String SUBCATEGORY_MONTHLY_REPORT = "严格执行月报告制度";
public static final String SUBCATEGORY_RECTIFICATION_TASK = "按时完成整改任务";
public static final String SUBCATEGORY_RECTIFICATION_ACCOUNTABILITY = "因巡视整改不给力被追究";
// 子类定义 - 深化纪律检查体制改革
public static final String SUBCATEGORY_THREE_TURNS = "聚焦主业主责，持续深化\"三转\"工作";
public static final String SUBCATEGORY_SYSTEM_CONSTRUCTION = "健全完善深化纪检体制改革的相关制度文件并抓好贯彻落实";
// 小类定义
public static final String DETAIL_LEADERSHIP_STRENGTHENING = "1 强化组织领导";
public static final String DETAIL_TASK_DEPLOYMENT = "2 及时部署工作任务";
public static final String DETAIL_PRESSURE_TRANSMISSION = "3 层层传到责任和压力";
public static final String DETAIL_CASE_DOUBLE_CHECK = "4 坚持\"一案双查\"";
public static final String DETAIL_WORK_REPORTING = "5 及时汇报工作情况";
public static final String DETAIL_INSPECTION_AND_SUPERVISION = "1 开展监督检查";
public static final String DETAIL_DATA_SUBMISSION = "2 报送数据和资料";
public static final String DETAIL_CASE_HANDLING = "3 查办违反中央八项规定精神案件";
public static final String DETAIL_EXPOSURE_NOTIFICATION = "4 通报曝光";
public static final String DETAIL_HOUSING_CLEARANCE = "5 清退干部职工多占住房";
public static final String DETAIL_PROBLEM_CLUE_HANDLING = "1 及时梳理处置问题线索";
public static final String DETAIL_CASE_INVESTIGATION = "2 查处一批案件";
public static final String DETAIL_TYPICAL_CASE_EXPOSURE = "3 通报曝光一批典型案件";
public static final String DETAIL_ATMOSPHERE_CREATION = "4 营造氛围";
public static final String DETAIL_PROBLEM_CONFESSION = "5 督促违纪人员主动交代问题";
public static final String DETAIL_SUMMARY_AND_MECHANISM = "6 进行总结并建立长效机制";
public static final String DETAIL_NORMALIZED_GOVERNANCE = "7 专项工作纳入常态化治理";
public static final String DETAIL_POLITICAL_DISCIPLINE = "1 严明政治纪律和组织纪律";
public static final String DETAIL_MAJOR_DECISION = "2 按时完成中央和自治区重大决策部署";
public static final String DETAIL_CASE_COMPLETION = "3 按时完成转办督办案件";
// 大类与子类映射关系
public static final Map<String, List<String>> CATEGORY_SUBCATEGORY_MAP = new HashMap<>();
static {
// 落实党风廉政建设责任制
CATEGORY_SUBCATEGORY_MAP.put(CATEGORY_TARGET_RESPONSIBILITY, Arrays.asList(
SUBCATEGORY_MAIN_RESPONSIBILITY,
SUBCATEGORY_EIGHT_REGULATIONS,
SUBCATEGORY_ANTI_CORRUPTION,
SUBCATEGORY_DISCIPLINE_ENFORCEMENT
));
// 巡视整改工作
CATEGORY_SUBCATEGORY_MAP.put(CATEGORY_INSPECTION_RECTIFICATION, Arrays.asList(
SUBCATEGORY_MONTHLY_REPORT,
SUBCATEGORY_RECTIFICATION_TASK,
SUBCATEGORY_RECTIFICATION_ACCOUNTABILITY
));
// 深化纪律检查体制改革
CATEGORY_SUBCATEGORY_MAP.put(CATEGORY_DISCIPLINE_REFORM, Arrays.asList(
SUBCATEGORY_THREE_TURNS,
SUBCATEGORY_SYSTEM_CONSTRUCTION
));
}
// 子类与小类映射关系
public static final Map<String, List<String>> SUBCATEGORY_DETAIL_MAP = new HashMap<>();
static {
// 落实主体责任和监督责任
SUBCATEGORY_DETAIL_MAP.put(SUBCATEGORY_MAIN_RESPONSIBILITY, Arrays.asList(
DETAIL_LEADERSHIP_STRENGTHENING,
DETAIL_TASK_DEPLOYMENT,
DETAIL_PRESSURE_TRANSMISSION,
DETAIL_CASE_DOUBLE_CHECK,
DETAIL_WORK_REPORTING
));
// 落实中央八项规定精神工作
SUBCATEGORY_DETAIL_MAP.put(SUBCATEGORY_EIGHT_REGULATIONS, Arrays.asList(
DETAIL_INSPECTION_AND_SUPERVISION,
DETAIL_DATA_SUBMISSION,
DETAIL_CASE_HANDLING,
DETAIL_EXPOSURE_NOTIFICATION,
DETAIL_HOUSING_CLEARANCE
));
// 开展查处发生在群众身边的"四风"和腐败问题专项工作
SUBCATEGORY_DETAIL_MAP.put(SUBCATEGORY_ANTI_CORRUPTION, Arrays.asList(
DETAIL_PROBLEM_CLUE_HANDLING,
DETAIL_CASE_INVESTIGATION,
DETAIL_TYPICAL_CASE_EXPOSURE,
DETAIL_ATMOSPHERE_CREATION,
DETAIL_PROBLEM_CONFESSION,
DETAIL_SUMMARY_AND_MECHANISM,
DETAIL_NORMALIZED_GOVERNANCE
));
// 严明纪律确保政令畅通
SUBCATEGORY_DETAIL_MAP.put(SUBCATEGORY_DISCIPLINE_ENFORCEMENT, Arrays.asList(
DETAIL_POLITICAL_DISCIPLINE,
DETAIL_MAJOR_DECISION,
DETAIL_CASE_COMPLETION
));
// 巡视整改工作的子类
SUBCATEGORY_DETAIL_MAP.put(SUBCATEGORY_MONTHLY_REPORT, Arrays.asList("1 严格执行月报告制度"));
SUBCATEGORY_DETAIL_MAP.put(SUBCATEGORY_RECTIFICATION_TASK, Arrays.asList("2 按时完成整改任务"));
SUBCATEGORY_DETAIL_MAP.put(SUBCATEGORY_RECTIFICATION_ACCOUNTABILITY, Arrays.asList("3 因巡视整改不给力被追究"));
// 深化纪律检查体制改革的子类
SUBCATEGORY_DETAIL_MAP.put(SUBCATEGORY_THREE_TURNS, Arrays.asList("1 聚焦主业主责，持续深化\"三转\"工作"));
SUBCATEGORY_DETAIL_MAP.put(SUBCATEGORY_SYSTEM_CONSTRUCTION, Arrays.asList("2 健全完善深化纪检体制改革的相关制度文件并抓好贯彻落实"));
}
// 固定顺序的示例数据列表（按审计内容10.txt中的顺序）
private static final List<JSONObject> FIXED_ORDER_EXAMPLE_DATA = new ArrayList<>();
static {
// 落实主体责任和监督责任
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "1 强化组织领导", "建立责任清单、明确党组、纪检责任");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "1 强化组织领导", "建立健全反腐败领导机制，人员调整后及时进行分工，并全年召开两次以上协调会");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "1 强化组织领导", "主要领导认真履行第一责任人责任，对党风廉政建设重要工作亲自部署、重大问题亲自过问、重点环节亲自协调、重要案件亲自督办5次以上");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "1 强化组织领导", "领导班子其他成员对职责范围内的党风廉政建设承担主要责任，与分管联系部门研究安排党风廉政建设工作4次以上");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "2 及时部署工作任务", "有党风廉政建设任务分工方案，党组专题研究部署党风廉政建设工作4次以上");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "3 层层传到责任和压力", "主要领导检查和调研党风廉政建设各一次以上,每年听取分管联系部门的党风廉政建设一次以上，且每年亲自上廉政党课不少于1次");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "3 层层传到责任和压力", "分管领导对分管联系部门党风廉政建设检查和调研各1次以上，每年听取分管联系部门的党风廉政建设情况汇报一次以上，到分管联系部门上廉政党课1次以上");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "3 层层传到责任和压力", "党组、纪检组注重抓早抓小，经常进行咬耳扯袖、红脸出汗，及时开展约谈、集体廉政谈话等工作3次以上");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "3 层层传到责任和压力", "开展述责评议工作");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "4 坚持\"一案双查\"", "对发生在本单位的较严重的违反政治纪律、组织纪律等问题进行\"一案双查\"");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "4 坚持\"一案双查\"", "出现\"四风\"和腐败等顶风违纪问题的");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "4 坚持\"一案双查\"", "出现区域性系统性违纪违法问题突出的");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "4 坚持\"一案双查\"", "出现上级交办的党风廉政建设事项不传达部署和落实的");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "4 坚持\"一案双查\"", "出现违纪行为隐瞒不报压案不查等问题而未进行责任追究被中央、自治区进行挂牌督办或直接问责、约谈等");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "5 及时汇报工作情况", "党组、纪检组向自治区党委、纪委汇报\"两个\"责任落实情况两次以上");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "5 及时汇报工作情况", "班子成员年底向自治区纪委报送个人落实\"两个责任\"情况报告");
addExampleData("落实党风廉政建设责任制", "落实主体责任和监督责任", "5 及时汇报工作情况", "按照自治区纪委部署开展其他工作，并按时报送总结报告的");
// 落实中央八项规定精神工作
addExampleData("落实党风廉政建设责任制", "落实中央八项规定精神工作", "1 开展监督检查", "部署开展监督检查3次以上");
addExampleData("落实党风廉政建设责任制", "落实中央八项规定精神工作", "2 报送数据和资料", "每月按时报送中央八项规定精神案件有关统计数据和有关资料");
addExampleData("落实党风廉政建设责任制", "落实中央八项规定精神工作", "2 报送数据和资料", "每月不按时报送或未按要求报送的");
addExampleData("落实党风廉政建设责任制", "落实中央八项规定精神工作", "3 查办违反中央八项规定精神案件", "及时查处监督检查中发现的问题和中央、自治区转办督办的问题线索");
addExampleData("落实党风廉政建设责任制", "落实中央八项规定精神工作", "3 查办违反中央八项规定精神案件", "出现违反中央八项规定精神问题被上级查处的，或查处但问责太轻，被上级责令重新查办");
addExampleData("落实党风廉政建设责任制", "落实中央八项规定精神工作", "4 通报曝光", "对受到党纪政纪处分的问题全部进行通报曝光的");
addExampleData("落实党风廉政建设责任制", "落实中央八项规定精神工作", "5 清退干部职工多占住房", "到年底还不能完成干部职工多占住房清退的");
addExampleData("落实党风廉政建设责任制", "落实中央八项规定精神工作", "5 清退干部职工多占住房", "信访反映清房工作不到位被查实的");
// 开展查处发生在群众身边的"四风"和腐败问题专项工作
addExampleData("落实党风廉政建设责任制", "开展查处发生在群众身边的\"四风\"和腐败问题专项工作", "1 及时梳理处置问题线索", "对收到或者上级交办问题线索进行转办督办或直接查办的");
addExampleData("落实党风廉政建设责任制", "开展查处发生在群众身边的\"四风\"和腐败问题专项工作", "2 查处一批案件", "因查处案件不力被自治区约谈或通报批评的");
addExampleData("落实党风廉政建设责任制", "开展查处发生在群众身边的\"四风\"和腐败问题专项工作", "3 通报曝光一批典型案件", "对查处的案件进行通报曝光");
addExampleData("落实党风廉政建设责任制", "开展查处发生在群众身边的\"四风\"和腐败问题专项工作", "4 营造氛围", "加大宣传力度，用典型案例进行警示教育");
addExampleData("落实党风廉政建设责任制", "开展查处发生在群众身边的\"四风\"和腐败问题专项工作", "5 督促违纪人员主动交代问题", "以文件形式或在网络、报纸、电视等媒介上发布公告，督促违纪人员主动交代问题并主动上缴违纪所得");
addExampleData("落实党风廉政建设责任制", "开展查处发生在群众身边的\"四风\"和腐败问题专项工作", "6 进行总结并建立长效机制", "没有在6月20日前进行总结");
addExampleData("落实党风廉政建设责任制", "开展查处发生在群众身边的\"四风\"和腐败问题专项工作", "6 进行总结并建立长效机制", "没有结合专项工作中发现存在的突出问题建立完善制度措施");
addExampleData("落实党风廉政建设责任制", "开展查处发生在群众身边的\"四风\"和腐败问题专项工作", "7 专项工作纳入常态化治理", "6月后，在全部二层单位开展专项工作");
// 严明纪律确保政令畅通
addExampleData("落实党风廉政建设责任制", "严明纪律确保政令畅通", "1 严明政治纪律和组织纪律", "有违反政治纪律等问题被中央、自治区查处的");
addExampleData("落实党风廉政建设责任制", "严明纪律确保政令畅通", "2 按时完成中央和自治区重大决策部署", "出现问题被中央、自治区问责的");
addExampleData("落实党风廉政建设责任制", "严明纪律确保政令畅通", "3 按时完成转办督办案件", "按时完成自治区纪委转办督办的党风政风类案件");
addExampleData("落实党风廉政建设责任制", "严明纪律确保政令畅通", "3 按时完成转办督办案件", "不按时完成或不完成的");
// 巡视整改工作
addExampleData("巡视整改工作", "严格执行月报告制度", "1 严格执行月报告制度", "严格执行月报告制度");
addExampleData("巡视整改工作", "按时完成整改任务", "2 按时完成整改任务", "按时完成整改任务");
addExampleData("巡视整改工作", "因巡视整改不给力被追究", "3 因巡视整改不给力被追究", "因巡视整改不给力被追究");
// 深化纪律检查体制改革
addExampleData("深化纪律检查体制改革", "聚焦主业主责，持续深化\"三转\"工作", "1 聚焦主业主责，持续深化\"三转\"工作", "纪检组长或纪工委书记不分管具体业务工作，专职抓执纪监督问责工作");
addExampleData("深化纪律检查体制改革", "聚焦主业主责，持续深化\"三转\"工作", "1 聚焦主业主责，持续深化\"三转\"工作", "检查发现有参与业务工作");
addExampleData("深化纪律检查体制改革", "健全完善深化纪检体制改革的相关制度文件并抓好贯彻落实", "2 健全完善深化纪检体制改革的相关制度文件并抓好贯彻落实", "年底前制定有1项以上配套制度文件");
}
private static void addExampleData(String category, String subCategory, String detailCategory, String content) {
JSONObject obj = new JSONObject();
obj.put("category", category);
obj.put("subCategory", subCategory);
obj.put("detailCategory", detailCategory);
obj.put("content", content);
obj.put("executionStatus", "");
obj.put("workPaperIndex", "[\"实际存在的完整文件名1\", \"实际存在的完整文件名2\", \"...\"]");
FIXED_ORDER_EXAMPLE_DATA.add(obj);
}
/**
* 获取所有固定顺序的示例数据
*/
public static List<JSONObject> getFixedOrderExampleData() {
return new ArrayList<>(FIXED_ORDER_EXAMPLE_DATA);
}
/**
* 获取指定子类的示例数据
*/
public static JSONArray getExampleDataBySubCategory(String subCategory) {
JSONArray result = new JSONArray();
for (JSONObject example : FIXED_ORDER_EXAMPLE_DATA) {
if (subCategory.equals(example.getString("subCategory"))) {
result.add(example);
}
}
return result;
}
/**
* 获取固定顺序的内容列表
*/
public static List<String> getFixedOrderContentList() {
List<String> contentList = new ArrayList<>();
for (JSONObject example : FIXED_ORDER_EXAMPLE_DATA) {
contentList.add(example.getString("content"));
}
return contentList;
}
/**
* 获取内容在固定顺序中的索引
*/
public static int getContentFixedOrderIndex(String content) {
List<String> fixedOrder = getFixedOrderContentList();
int index = fixedOrder.indexOf(content);
return index != -1 ? index : Integer.MAX_VALUE;
}
/**
* 获取所有子类列表（包括所有大类的子类）
*/
public static List<String> getAllSubCategories() {
List<String> allSubCategories = new ArrayList<>();
for (List<String> subCategories : CATEGORY_SUBCATEGORY_MAP.values()) {
allSubCategories.addAll(subCategories);
}
return allSubCategories;
}
// 大类顺序 - 用于排序
public static final List<String> CATEGORY_ORDER = Arrays.asList(
CATEGORY_TARGET_RESPONSIBILITY,
CATEGORY_INSPECTION_RECTIFICATION,
CATEGORY_DISCIPLINE_REFORM
);
// 大类描述
public static final Map<String, String> CATEGORY_DESCRIPTIONS = new HashMap<>();
static {
CATEGORY_DESCRIPTIONS.put(CATEGORY_TARGET_RESPONSIBILITY, "落实党风廉政建设主体责任和监督责任");
CATEGORY_DESCRIPTIONS.put(CATEGORY_INSPECTION_RECTIFICATION, "巡视反馈问题的整改落实情况");
CATEGORY_DESCRIPTIONS.put(CATEGORY_DISCIPLINE_REFORM, "深化纪律检查体制改革工作情况");
}
// 子类描述
public static final Map<String, String> SUBCATEGORY_DESCRIPTIONS = new HashMap<>();
static {
SUBCATEGORY_DESCRIPTIONS.put(SUBCATEGORY_MAIN_RESPONSIBILITY, "党委主体责任和纪委监督责任落实情况");
SUBCATEGORY_DESCRIPTIONS.put(SUBCATEGORY_EIGHT_REGULATIONS, "中央八项规定精神落实情况");
SUBCATEGORY_DESCRIPTIONS.put(SUBCATEGORY_ANTI_CORRUPTION, "查处群众身边腐败问题工作情况");
SUBCATEGORY_DESCRIPTIONS.put(SUBCATEGORY_DISCIPLINE_ENFORCEMENT, "纪律执行和政令畅通情况");
SUBCATEGORY_DESCRIPTIONS.put(SUBCATEGORY_MONTHLY_REPORT, "巡视整改月报告制度执行情况");
SUBCATEGORY_DESCRIPTIONS.put(SUBCATEGORY_RECTIFICATION_TASK, "巡视整改任务完成情况");
SUBCATEGORY_DESCRIPTIONS.put(SUBCATEGORY_RECTIFICATION_ACCOUNTABILITY, "巡视整改责任追究情况");
SUBCATEGORY_DESCRIPTIONS.put(SUBCATEGORY_THREE_TURNS, "纪检机构转职能、转方式、转作风工作情况");
SUBCATEGORY_DESCRIPTIONS.put(SUBCATEGORY_SYSTEM_CONSTRUCTION, "纪检体制改革制度建设情况");
}
// 执行状态选项
public static final String STATUS_IMPLEMENTED = "已落实";
public static final String STATUS_PARTIALLY_IMPLEMENTED = "部分落实";
public static final String STATUS_NOT_IMPLEMENTED = "未落实";
public static final String STATUS_NOT_APPLICABLE = "不适用";
// 关键词权重
public static final Map<String, Integer> KEYWORD_WEIGHTS = new HashMap<>();
static {
KEYWORD_WEIGHTS.put("党风廉政建设", 10);
KEYWORD_WEIGHTS.put("主体责任", 9);
KEYWORD_WEIGHTS.put("监督责任", 9);
KEYWORD_WEIGHTS.put("中央八项规定", 8);
KEYWORD_WEIGHTS.put("廉洁从业", 8);
KEYWORD_WEIGHTS.put("巡视整改", 7);
KEYWORD_WEIGHTS.put("纪律检查", 7);
KEYWORD_WEIGHTS.put("廉政谈话", 6);
KEYWORD_WEIGHTS.put("一案双查", 6);
KEYWORD_WEIGHTS.put("四风", 5);
KEYWORD_WEIGHTS.put("腐败", 5);
}
// 工作底稿关键词
public static final Map<String, String> WORK_PAPER_KEYWORDS = new HashMap<>();
static {
WORK_PAPER_KEYWORDS.put("会议纪要", "党委会议纪要、党风廉政建设专题会议纪要");
WORK_PAPER_KEYWORDS.put("责任清单", "党风廉政建设责任清单、主体责任清单");
WORK_PAPER_KEYWORDS.put("检查报告", "党风廉政建设检查报告、巡视整改报告");
WORK_PAPER_KEYWORDS.put("谈话记录", "廉政谈话记录、提醒谈话记录");
WORK_PAPER_KEYWORDS.put("制度文件", "党风廉政建设制度、廉洁从业规定");
WORK_PAPER_KEYWORDS.put("审批文件", "津补贴审批文件、车辆配备审批");
WORK_PAPER_KEYWORDS.put("举报材料", "信访举报材料、问题线索登记");
}
/**
* 对廉政情况数据进行排序（提供给ServiceImpl使用）
*/
public static void sortPartyConductData(JSONArray data) {
if (data == null || data.isEmpty()) {
return;
}
// 转换为List进行排序
List<JSONObject> dataList = new ArrayList<>();
for (int i = 0; i < data.size(); i++) {
dataList.add(data.getJSONObject(i));
}
// 排序：优先按固定顺序，其次按类别
dataList.sort(AuditContent10PartyConductConstants::compareJSONObject);
// 清空原数组并添加排序后的数据
data.clear();
data.addAll(dataList);
}
/**
* 比较两个JSON对象的排序
*/
public static int compareJSONObject(JSONObject o1, JSONObject o2) {
String content1 = o1.getString("content");
String content2 = o2.getString("content");
// 1. 按固定顺序排序
int index1 = getContentFixedOrderIndex(content1);
int index2 = getContentFixedOrderIndex(content2);
if (index1 != index2) {
return Integer.compare(index1, index2);
}
// 2. 如果都不在固定顺序中，按类别排序
return compareByCategory(o1, o2);
}
/**
* 按照大类、子类、小类排序
*/
public static int compareByCategory(JSONObject o1, JSONObject o2) {
// 清理子类字符串用于比较
String cleanSubCategory1 = cleanSubCategory(o1.getString("subCategory"));
String cleanSubCategory2 = cleanSubCategory(o2.getString("subCategory"));
// 1. 按大类排序
String category1 = o1.getString("category");
String category2 = o2.getString("category");
int categoryIndex1 = CATEGORY_ORDER.indexOf(category1);
int categoryIndex2 = CATEGORY_ORDER.indexOf(category2);
if (categoryIndex1 != categoryIndex2) {
return Integer.compare(categoryIndex1, categoryIndex2);
}
// 2. 按子类排序
String subCategory1 = o1.getString("subCategory");
String subCategory2 = o2.getString("subCategory");
List<String> subCategories = CATEGORY_SUBCATEGORY_MAP.get(category1);
if (subCategories != null) {
int subCategoryIndex1 = subCategories.indexOf(subCategory1);
int subCategoryIndex2 = subCategories.indexOf(subCategory2);
if (subCategoryIndex1 != subCategoryIndex2) {
return Integer.compare(subCategoryIndex1, subCategoryIndex2);
}
}
// 3. 按小类排序
String detailCategory1 = o1.getString("detailCategory");
String detailCategory2 = o2.getString("detailCategory");
List<String> detailCategories = SUBCATEGORY_DETAIL_MAP.get(subCategory1);
if (detailCategories != null) {
int detailCategoryIndex1 = detailCategories.indexOf(detailCategory1);
int detailCategoryIndex2 = detailCategories.indexOf(detailCategory2);
if (detailCategoryIndex1 != detailCategoryIndex2) {
return Integer.compare(detailCategoryIndex1, detailCategoryIndex2);
}
}
// 4. 如果小类也相同，按内容排序
String content1 = o1.getString("content");
String content2 = o2.getString("content");
return content1.compareTo(content2);
}
private static String cleanSubCategory(String subCategory) {
if (subCategory == null) return "";
if (subCategory.contains(" - ")) {
return subCategory.split(" - ")[0].trim();
}
return subCategory;
}
/**
* 获取指定子类的示例数据JSON字符串
*/
public static String getExampleDataJsonString(String subCategory) {
JSONArray exampleData = getExampleDataBySubCategory(subCategory);
if (exampleData == null || exampleData.isEmpty()) {
return "[]";
}
// 直接使用FastJSON的序列化，确保正确转义即可
return exampleData.toJSONString();
}
private AuditContent10PartyConductConstants() {
// 防止实例化
}
}

296
src/main/java/com/gxwebsoft/ai/controller/AuditContent10Controller.java Normal file
View File

@@ -0,0 +1,296 @@
package com.gxwebsoft.ai.controller;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.gxwebsoft.ai.dto.AuditContentRequest;
import com.gxwebsoft.ai.dto.export.PartyConductExportEntity;
import com.gxwebsoft.ai.entity.AiCloudDoc;
import com.gxwebsoft.ai.entity.AiCloudFile;
import com.gxwebsoft.ai.service.AiHistoryService;
import com.gxwebsoft.ai.utils.ExcelExportTool;
import com.gxwebsoft.common.core.web.ApiResult;
import com.gxwebsoft.common.core.web.BaseController;
import com.gxwebsoft.common.system.entity.User;
import com.gxwebsoft.pwl.entity.PwlProjectLibrary;
import com.gxwebsoft.pwl.service.PwlProjectLibraryService;
import com.gxwebsoft.ai.service.AiCloudDocService;
import com.gxwebsoft.ai.service.AiCloudFileService;
import com.gxwebsoft.ai.service.AuditContent10PartyConductService;
import com.gxwebsoft.ai.service.KnowledgeBaseService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import cn.hutool.core.util.StrUtil;
import cn.hutool.crypto.digest.DigestUtil;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
/**
* 审计内容10控制器 - 党风廉政建设责任制审计
*/
@Slf4j
@Tag(name = "审计内容10-廉政情况")
@RestController
@RequestMapping("/api/ai/auditContent10")
public class AuditContent10Controller extends BaseController {
@Autowired
private AuditContent10PartyConductService auditContent10PartyConductService;
@Autowired
private AiCloudDocService aiCloudDocService;
@Autowired
private AiCloudFileService aiCloudFileService;
@Autowired
private KnowledgeBaseService knowledgeBaseService;
@Autowired
private PwlProjectLibraryService pwlProjectLibraryService;
@Autowired
private AiHistoryService aiHistoryService;
// 历史记录有效期（分钟）
private static final int HISTORY_EXPIRE_MINUTES = 10;
/**
* 生成党风廉政建设责任制审计表数据
*/
@Operation(summary = "生成党风廉政建设责任制审计表")
@PostMapping("/generatePartyConductTable")
public ApiResult<?> generatePartyConductTable(@RequestBody AuditContentRequest request, HttpServletRequest servletRequest) {
return generateTableData(request, servletRequest.getRequestURI(),
(params) -> auditContent10PartyConductService.generatePartyConductTableData(
params.knowledgeBaseId, params.libraryKbIds, params.projectLibrary,
params.username, params.history, params.suggestion
));
}
/**
* 通用的表格数据生成方法
*/
private ApiResult<?> generateTableData(AuditContentRequest request, String interfaceName, Function<GenerateParams, JSONObject> generateFunction) {
final User loginUser = getLoginUser();
String requestHistory = request.getHistory();
request.setHistory("");
// 检查历史记录
String requestHash = generateRequestHash(request, interfaceName);
var history = aiHistoryService.getValidHistory(requestHash, interfaceName, HISTORY_EXPIRE_MINUTES);
if (history != null) {
log.info("返回历史数据，请求哈希: {}", requestHash);
return success(JSONObject.parseObject(history.getResponseData()));
}
request.setHistory(requestHistory);
String kbIdTmp = "";
String libraryKbIds = "";
try {
// 创建临时知识库（如果需要）
if (hasUploadedFiles(request)) {
kbIdTmp = createTempKnowledgeBase(request);
}
// 查询项目库信息
libraryKbIds = getLibraryKbIds(request.getLibraryIds());
// 生成数据
String knowledgeBaseId = getKnowledgeBaseId(kbIdTmp, request.getKbIds());
GenerateParams params = new GenerateParams(knowledgeBaseId, libraryKbIds, request.getProjectLibrary(), loginUser.getUsername(), request.getHistory(), request.getSuggestion());
JSONObject result = generateFunction.apply(params);
if(result.getBoolean("success")) {
// 保存到历史记录
saveToHistory(request, interfaceName, requestHash, result, loginUser);
}
return success(result);
} catch (Exception e) {
log.error("生成表格数据失败，接口: {}", interfaceName, e);
return fail("生成表格数据失败: " + e.getMessage());
} finally {
cleanupTempKnowledgeBase(kbIdTmp);
}
}
/**
* 生成请求哈希
*/
private String generateRequestHash(AuditContentRequest request, String interfaceName) {
String requestJson = JSONObject.toJSONString(request);
return DigestUtil.md5Hex(interfaceName + ":" + requestJson);
}
/**
* 保存到历史记录
*/
private void saveToHistory(AuditContentRequest request, String interfaceName, String requestHash, JSONObject result, User loginUser) {
try {
aiHistoryService.saveHistory(requestHash, interfaceName, JSONObject.toJSONString(request), result.toJSONString(), loginUser.getUserId(), loginUser.getUsername(), loginUser.getTenantId());
} catch (Exception e) {
log.warn("保存历史记录失败", e);
}
}
/**
* 检查是否有上传的文件
*/
private boolean hasUploadedFiles(AuditContentRequest request) {
return !request.getDocList().isEmpty() || !request.getFileList().isEmpty();
}
/**
* 获取知识库ID
*/
private String getKnowledgeBaseId(String tempKbId, String requestKbIds) {
return StrUtil.isNotBlank(tempKbId) ? tempKbId : requestKbIds;
}
/**
* 获取项目库KB IDs
*/
private String getLibraryKbIds(String libraryIds) {
if (StrUtil.isBlank(libraryIds)) {
return "";
}
List<String> idList = StrUtil.split(libraryIds, ',');
List<PwlProjectLibrary> ret = pwlProjectLibraryService.list(new LambdaQueryWrapper<PwlProjectLibrary>().in(PwlProjectLibrary::getId, idList));
return ret.stream().map(PwlProjectLibrary::getKbId).filter(StrUtil::isNotBlank).collect(Collectors.joining(","));
}
/**
* 创建临时知识库并提交文档
*/
private String createTempKnowledgeBase(AuditContentRequest request) {
String kbIdTmp = knowledgeBaseService.createKnowledgeBaseTemp();
// 收集文档ID
Set<Integer> docIds = request.getDocList().stream().flatMap(docId -> aiCloudDocService.getSelfAndChildren(docId).stream()).map(AiCloudDoc::getId).collect(Collectors.toSet());
// 查询相关文件
List<AiCloudFile> fileList = getRelatedFiles(docIds, request.getFileList());
// 提取文件ID并提交到知识库
Set<String> kbFileIds = fileList.stream().map(AiCloudFile::getFileId).collect(Collectors.toSet());
if (!kbFileIds.isEmpty()) {
knowledgeBaseService.submitDocuments(kbIdTmp, new ArrayList<>(kbFileIds));
}
return kbIdTmp;
}
/**
* 获取相关文件列表
*/
private List<AiCloudFile> getRelatedFiles(Set<Integer> docIds, List<Integer> fileList) {
LambdaQueryWrapper<AiCloudFile> queryWrapper = new LambdaQueryWrapper<AiCloudFile>()
.in(!docIds.isEmpty(), AiCloudFile::getDocId, docIds)
.or(!fileList.isEmpty())
.in(!fileList.isEmpty(), AiCloudFile::getId, fileList);
return aiCloudFileService.list(queryWrapper);
}
/**
* 清理临时知识库
*/
private void cleanupTempKnowledgeBase(String kbId) {
if (StrUtil.isNotBlank(kbId)) {
try {
knowledgeBaseService.deleteIndex(kbId);
} catch (Exception e) {
log.warn("删除临时知识库失败: {}", kbId, e);
}
}
}
/**
* 导出党风廉政建设责任制审计表到Excel
*/
@Operation(summary = "导出党风廉政建设责任制审计表到Excel")
@PostMapping("/exportPartyConductTable")
public void exportPartyConductTable(@RequestBody Map<String, Object> request, HttpServletResponse response) {
exportToExcel(request, response, "党风廉政建设责任制审计表",
this::convertToPartyConductEntityList, PartyConductExportEntity.class);
}
/**
* 通用的Excel导出方法
*/
private <T> void exportToExcel(Map<String, Object> request, HttpServletResponse response,
String sheetName, Function<List<Map<String, Object>>, List<T>> converter,
Class<T> entityClass) {
List<Map<String, Object>> dataList = (List<Map<String, Object>>) request.get("data");
String companyName = (String) request.get("companyName");
List<T> exportData = converter.apply(dataList);
String fileName = sheetName + "_" + (companyName != null ? companyName : "未知公司");
String title = companyName != null ? companyName + " - " + sheetName : sheetName;
ExcelExportTool.exportExcel(exportData, entityClass, fileName, sheetName, title, response);
}
/**
* 参数包装类
*/
private static class GenerateParams {
final String knowledgeBaseId;
final String libraryKbIds;
final String projectLibrary;
final String username;
final String history;
final String suggestion;
GenerateParams(String knowledgeBaseId, String libraryKbIds, String projectLibrary, String username, String history, String suggestion) {
this.knowledgeBaseId = knowledgeBaseId;
this.libraryKbIds = libraryKbIds;
this.projectLibrary = projectLibrary;
this.username = username;
this.history = history;
this.suggestion = suggestion;
}
}
// ========== 数据转换方法 ==========
private List<PartyConductExportEntity> convertToPartyConductEntityList(List<Map<String, Object>> originalData) {
return originalData.stream().map(this::convertToPartyConductEntity).collect(Collectors.toList());
}
private PartyConductExportEntity convertToPartyConductEntity(Map<String, Object> item) {
PartyConductExportEntity entity = new PartyConductExportEntity();
entity.setCategory(getStringValue(item, "category"));
entity.setSubCategory(getStringValue(item, "subCategory"));
entity.setDetailCategory(getStringValue(item, "detailCategory"));
entity.setContent(getStringValue(item, "content"));
entity.setExecutionStatus(getStringValue(item, "executionStatus"));
entity.setWorkPaperIndex(formatWorkPaperIndex(item.get("workPaperIndex")));
return entity;
}
private String getStringValue(Map<String, Object> map, String key) {
Object value = map.get(key);
return value != null ? value.toString() : "";
}
private String formatWorkPaperIndex(Object workPaperIndex) {
if (workPaperIndex == null) {
return "";
}
if (workPaperIndex instanceof List) {
List<?> list = (List<?>) workPaperIndex;
return String.join(", ", list.stream()
.map(Object::toString)
.collect(Collectors.toList()));
}
return workPaperIndex.toString();
}
}

31
src/main/java/com/gxwebsoft/ai/dto/export/PartyConductExportEntity.java Normal file
View File

@@ -0,0 +1,31 @@
package com.gxwebsoft.ai.dto.export;
import cn.afterturn.easypoi.excel.annotation.Excel;
import cn.afterturn.easypoi.excel.annotation.ExcelTarget;
import lombok.Data;
/**
* 党风廉政建设责任制审计表导出实体
*/
@Data
@ExcelTarget("PartyConductExportEntity")
public class PartyConductExportEntity {
@Excel(name = "大类", orderNum = "1", width = 20, isWrap = true)
private String category;
@Excel(name = "子类", orderNum = "2", width = 25, isWrap = true)
private String subCategory;
@Excel(name = "小类", orderNum = "3", width = 15, isWrap = true)
private String detailCategory;
@Excel(name = "内容", orderNum = "4", width = 40, isWrap = true)
private String content;
@Excel(name = "执行情况", orderNum = "5", width = 12)
private String executionStatus;
@Excel(name = "工作底稿索引", orderNum = "6", width = 30, isWrap = true)
private String workPaperIndex;
}

15
src/main/java/com/gxwebsoft/ai/service/AuditContent10PartyConductService.java Normal file
View File

@@ -0,0 +1,15 @@
package com.gxwebsoft.ai.service;
import com.alibaba.fastjson.JSONObject;
/**
* 审计内容10服务接口 - 党风廉政建设责任制审计
*/
public interface AuditContent10PartyConductService {
/**
* 生成党风廉政建设责任制审计表数据
*/
JSONObject generatePartyConductTableData(String kbIds, String libraryKbIds, String projectLibrary,
String userName, String history, String suggestion);
}

307
src/main/java/com/gxwebsoft/ai/service/impl/AuditContent10PartyConductServiceImpl.java Normal file
View File

@@ -0,0 +1,307 @@
package com.gxwebsoft.ai.service.impl;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.gxwebsoft.ai.constants.AuditContent10PartyConductConstants;
import com.gxwebsoft.ai.service.AuditContent10PartyConductService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import cn.hutool.core.util.StrUtil;
import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
@Slf4j
@Service
public class AuditContent10PartyConductServiceImpl extends AbstractAuditContentService implements AuditContent10PartyConductService {
// 工作流配置
private static final String DIFY_WORKFLOW_TOKEN = "Bearer app-NpWFaPdBAl3LH7HqRXenlnVD";
@Override
public JSONObject generatePartyConductTableData(String kbIds, String libraryKbIds, String projectLibrary, String userName, String history, String suggestion) {
log.info("开始生成党风廉政建设责任制审计表数据 - 用户: {}, kbIds: {}, libraryIds: {}, projectLibrary: {}", userName, kbIds, libraryKbIds, projectLibrary);
long startTime = System.currentTimeMillis();
try {
// 获取所有子类（基于常量类中的映射关系）
List<String> allSubCategories = AuditContent10PartyConductConstants.getAllSubCategories();
log.info("共发现 {} 个子类需要处理", allSubCategories.size());
// 异步并行处理每个子类
Map<String, CompletableFuture<JSONArray>> futures = processCategoriesAsync(
allSubCategories,
subCategory -> generateSubCategoryDataAsync(subCategory, kbIds, libraryKbIds, projectLibrary, userName, history, suggestion)
);
// 等待所有异步任务完成
CompletableFuture.allOf(futures.values().toArray(new CompletableFuture[0])).join();
// 合并所有子类的结果
JSONArray allData = mergeCategoryResults(allSubCategories, futures);
// 对结果进行排序（直接调用常量类的排序方法）
AuditContent10PartyConductConstants.sortPartyConductData(allData);
log.info("党风廉政建设责任制审计表生成成功 - 记录数: {}, 处理时间: {}ms", allData.size(), (System.currentTimeMillis() - startTime));
return buildSuccessResponse(allData, startTime, "party_conduct_audit");
} catch (Exception e) {
log.error("生成党风廉政建设责任制审计表失败", e);
return buildErrorResponse("生成党风廉政建设责任制审计表失败: " + e.getMessage());
}
}
/**
* 异步生成单个子类的数据
*/
@Async
public CompletableFuture<JSONArray> generateSubCategoryDataAsync(String subCategory, String kbIds, String libraryKbIds, String projectLibrary, String userName, String history, String suggestion) {
return CompletableFuture.supplyAsync(() -> {
try {
log.info("开始生成子类 {} 的数据", subCategory);
// 1. 为当前子类召回相关知识
Map<String, List<String>> knowledgeSources = retrieveKnowledgeForSubCategory(
subCategory, kbIds, libraryKbIds, projectLibrary
);
// 2. 构建完整的知识上下文（包含固定内容和动态内容）
String knowledgeContext = buildCompleteKnowledgeContext(
subCategory, knowledgeSources, history, suggestion
);
// 3. 调用工作流生成数据
JSONObject requestBody = buildWorkflowRequest(knowledgeContext, userName);
JSONArray subCategoryData = callWorkflow(DIFY_WORKFLOW_URL, DIFY_WORKFLOW_TOKEN, requestBody, "廉政情况-" + subCategory);
log.info("子类 {} 数据生成完成，生成 {} 条记录", subCategory, subCategoryData.size());
return subCategoryData;
} catch (Exception e) {
log.error("生成子类 {} 数据失败", subCategory, e);
return new JSONArray();
}
});
}
/**
* 为单个子类检索相关知识
*/
private Map<String, List<String>> retrieveKnowledgeForSubCategory(String subCategory, String kbIds, String libraryKbIds, String projectLibrary) {
Map<String, List<String>> knowledgeSources = new HashMap<>();
knowledgeSources.put("enterprise", new ArrayList<>());
knowledgeSources.put("regulation", new ArrayList<>());
knowledgeSources.put("auditCase", new ArrayList<>());
// 构建当前子类的查询词
List<String> subCategoryQueries = buildSubCategoryQueries(subCategory);
// 企业单位库检索
if (StrUtil.isNotBlank(kbIds)) {
Arrays.stream(kbIds.split(","))
.map(String::trim)
.filter(StrUtil::isNotBlank)
.forEach(kbId -> knowledgeSources.get("enterprise")
.addAll(queryKnowledgeBase(kbId, subCategoryQueries, 100)));
}
// 公共法律法规库检索
if (StrUtil.isNotBlank(libraryKbIds)) {
Arrays.stream(libraryKbIds.split(","))
.map(String::trim)
.filter(StrUtil::isNotBlank)
.forEach(libId -> knowledgeSources.get("regulation")
.addAll(queryKnowledgeBase(libId, subCategoryQueries, 80)));
}
// 审计案例库检索
if (StrUtil.isNotBlank(projectLibrary)) {
knowledgeSources.get("auditCase").addAll(
queryKnowledgeBase(projectLibrary, subCategoryQueries, 60));
}
// 智能去重和排序
knowledgeSources.forEach((key, list) -> {
List<String> processed = list.stream()
.distinct()
.sorted(this::partyConductComparator)
.limit(getLimitBySourceType(key))
.collect(Collectors.toList());
knowledgeSources.put(key, processed);
});
log.debug("子类 {} 知识检索完成 - 企业: {}条, 法规: {}条, 案例: {}条",
subCategory,
knowledgeSources.get("enterprise").size(),
knowledgeSources.get("regulation").size(),
knowledgeSources.get("auditCase").size());
return knowledgeSources;
}
/**
* 构建子类特定的查询词
*/
private List<String> buildSubCategoryQueries(String subCategory) {
List<String> queries = new ArrayList<>();
// 基础查询词
queries.add(subCategory);
queries.add(subCategory + " 制度规定");
queries.add(subCategory + " 执行情况");
// 根据子类类型添加特定查询词
if (subCategory.equals(AuditContent10PartyConductConstants.SUBCATEGORY_MAIN_RESPONSIBILITY)) {
queries.add("主体责任 监督责任 责任清单");
queries.add("党风廉政建设责任制 党组责任 纪检责任");
} else if (subCategory.equals(AuditContent10PartyConductConstants.SUBCATEGORY_EIGHT_REGULATIONS)) {
queries.add("中央八项规定 监督检查 问题线索");
queries.add("八项规定精神 违规问题 通报曝光");
} else if (subCategory.equals(AuditContent10PartyConductConstants.SUBCATEGORY_ANTI_CORRUPTION)) {
queries.add("群众身边腐败 四风问题 案件查处");
queries.add("基层腐败 专项治理 长效机制");
} else if (subCategory.equals(AuditContent10PartyConductConstants.SUBCATEGORY_DISCIPLINE_ENFORCEMENT)) {
queries.add("政治纪律 组织纪律 政令畅通");
queries.add("纪律执行 重大决策 转办督办");
} else if (subCategory.equals(AuditContent10PartyConductConstants.SUBCATEGORY_MONTHLY_REPORT) ||
subCategory.equals(AuditContent10PartyConductConstants.SUBCATEGORY_RECTIFICATION_TASK) ||
subCategory.equals(AuditContent10PartyConductConstants.SUBCATEGORY_RECTIFICATION_ACCOUNTABILITY)) {
queries.add("巡视整改 整改报告 整改措施");
queries.add("巡视反馈 整改方案 整改完成");
} else if (subCategory.equals(AuditContent10PartyConductConstants.SUBCATEGORY_THREE_TURNS) ||
subCategory.equals(AuditContent10PartyConductConstants.SUBCATEGORY_SYSTEM_CONSTRUCTION)) {
queries.add("纪律检查体制改革 三转工作 纪检体制改革");
queries.add("纪检制度建设 监督执纪问责");
}
return queries;
}
/**
* 构建完整的知识上下文 - 包含完整的子类示例数据
*/
private String buildCompleteKnowledgeContext(String subCategory, Map<String, List<String>> knowledgeSources, String history, String suggestion) {
StringBuilder context = new StringBuilder();
// 1. 获取当前子类的大类
String category = findCategoryBySubCategory(subCategory);
String categoryDesc = AuditContent10PartyConductConstants.CATEGORY_DESCRIPTIONS.getOrDefault(category, "");
String subCategoryDesc = AuditContent10PartyConductConstants.SUBCATEGORY_DESCRIPTIONS.getOrDefault(subCategory, "");
// 2. 党风廉政建设责任制审计要求
context.append("## 党风廉政建设责任制审计要求\n");
context.append("请基于以下知识生成").append(category).append("-").append(subCategory).append("相关的党风廉政建设责任制审计表数据：\n\n");
context.append("1. 严格按照廉政情况表的结构生成数据：大类、子类、小类、内容、执行情况、工作底稿索引\n");
context.append("2. **执行情况字段必须填写：详细情况内容说明，基于知识库证据判断，不能留空**\n");
context.append("3. 工作底稿索引必须填写实际存在的完整文件名，确保能在文件夹中搜索到\n");
context.append("4. 内容字段必须填写具体、可核查的检查点描述\n\n");
// 3. 数据结构说明
context.append("## 数据结构说明\n");
context.append("当前大类：").append(category).append(" - ").append(categoryDesc).append("\n");
context.append("当前子类：").append(subCategory).append(" - ").append(subCategoryDesc).append("\n");
// 获取当前子类的小类列表
List<String> detailCategories = AuditContent10PartyConductConstants.SUBCATEGORY_DETAIL_MAP.getOrDefault(subCategory, Collections.emptyList());
if (!detailCategories.isEmpty()) {
context.append("\n可用的子类包括：\n");
for (String detailCategory : detailCategories) {
context.append("- ").append(detailCategory).append("\n");
}
}
context.append("\n可用的执行情况：详细情况内容说明\n\n");
// 4. 完整的示例数据
context.append("## 示例数据（参考结构）\n");
String exampleDataJson = AuditContent10PartyConductConstants.getExampleDataJsonString(subCategory);
context.append("以下是相关审计内容的").append(subCategory).append("的完整示例数据，请参考这些内容的结构生成：\n\n");
context.append(exampleDataJson).append("\n\n");
// 5. 历史内容
if (StrUtil.isNotBlank(history)) {
context.append("## 历史生成内容\n");
context.append("以下是之前生成的内容，请基于此进行优化：\n");
context.append(history).append("\n\n");
}
// 6. 用户建议
if (StrUtil.isNotBlank(suggestion)) {
context.append("## 用户优化建议\n");
context.append("请根据以下建议对生成内容进行调整：\n");
context.append(suggestion).append("\n\n");
}
// 7. 企业单位知识
if (!knowledgeSources.get("enterprise").isEmpty()) {
context.append("## 企业单位知识\n");
knowledgeSources.get("enterprise").forEach(knowledge ->
context.append(knowledge).append("\n"));
context.append("\n");
}
// 8. 法律法规知识
if (!knowledgeSources.get("regulation").isEmpty()) {
context.append("## 法律法规知识\n");
knowledgeSources.get("regulation").forEach(knowledge ->
context.append(knowledge).append("\n"));
context.append("\n");
}
// 9. 审计案例知识
if (!knowledgeSources.get("auditCase").isEmpty()) {
context.append("## 审计案例知识\n");
knowledgeSources.get("auditCase").forEach(knowledge ->
context.append(knowledge).append("\n"));
context.append("\n");
}
return context.toString();
}
/**
* 根据子类查找对应的大类
*/
private String findCategoryBySubCategory(String subCategory) {
for (Map.Entry<String, List<String>> entry : AuditContent10PartyConductConstants.CATEGORY_SUBCATEGORY_MAP.entrySet()) {
if (entry.getValue().contains(subCategory)) {
return entry.getKey();
}
}
return AuditContent10PartyConductConstants.CATEGORY_TARGET_RESPONSIBILITY; // 默认返回第一个大类
}
/**
* 廉政情况相关性比较器
*/
private int partyConductComparator(String reg1, String reg2) {
int score1 = calculatePartyConductRelevanceScore(reg1);
int score2 = calculatePartyConductRelevanceScore(reg2);
return Integer.compare(score2, score1);
}
/**
* 计算廉政情况相关性分数
*/
private int calculatePartyConductRelevanceScore(String content) {
return AuditContent10PartyConductConstants.KEYWORD_WEIGHTS.entrySet().stream()
.filter(entry -> content.contains(entry.getKey()))
.mapToInt(Map.Entry::getValue)
.sum();
}
private int getLimitBySourceType(String sourceType) {
switch (sourceType) {
case "enterprise": return 100;
case "regulation": return 80;
case "auditCase": return 60;
default: return 50;
}
}
}