diff --git a/b/product/add_user_inquiry.dspy b/b/product/add_user_inquiry.dspy index 88e0670..e09b03f 100644 --- a/b/product/add_user_inquiry.dspy +++ b/b/product/add_user_inquiry.dspy @@ -20,7 +20,11 @@ async def add_user_inquiry(ns={}): 'name': ns.get('name'), 'phone': ns.get('phone'), 'company': ns.get('company'), - 'email': ns.get('email') + 'enterprise_type': ns.get('enterprise_type'), + 'region': ns.get('region'), + 'consult_direction': ns.get('consult_direction'), + 'email': ns.get('email'), + 'source': ns.get('source') } await sor.C('product_inquiry', ns_c) return { diff --git a/b/product/search_user_inquiry.dspy b/b/product/search_user_inquiry.dspy index 906e50e..8eedc2d 100644 --- a/b/product/search_user_inquiry.dspy +++ b/b/product/search_user_inquiry.dspy @@ -10,8 +10,72 @@ async def search_user_inquiry(ns={}): db = DBPools() async with db.sqlorContext('kboss') as sor: - search_sql = """select * from product_inquiry where domain_name = '%s' and del_flg = '0' order by update_time desc;""" % domain_name + where_conditions = ["domain_name = '%s'" % domain_name, "del_flg = '0'"] + if ns.get('name'): + where_conditions.append("name like '%%%%%s%%%%'" % ns.get('name')) + if ns.get('phone'): + where_conditions.append("phone like '%%%%%s%%%%'" % ns.get('phone')) + if ns.get('email'): + where_conditions.append("email like '%%%%%s%%%%'" % ns.get('email')) + if ns.get('source'): + if ns.get('source') == '未知': + where_conditions.append("(source is null or source = '')") + else: + where_conditions.append("source = '%s'" % ns.get('source')) + if ns.get('feedback'): + where_conditions.append("feedback = '%s'" % ns.get('feedback')) + where_clause = ' and '.join(where_conditions) + + # 分页参数 + page = int(ns.get('page', 1)) + page_size = int(ns.get('page_size', 20)) + offset = (page - 1) * page_size + + # 统计查询（基于全部符合条件的数据） + count_sql = """select count(*) as cnt from product_inquiry where %s""" % where_clause + total_count = (await sor.sqlExe(count_sql, {}))[0]['cnt'] + + source_sql = """select source, count(*) as cnt from product_inquiry where %s group by source""" % where_clause + source_result = await sor.sqlExe(source_sql, {}) + source_stats = {} + for row in source_result: + src = row.get('source') or '未知' + source_stats[src] = row.get('cnt') + + pending_sql = """select count(*) as cnt from product_inquiry where %s and feedback = '0'""" % where_clause + pending_count = (await sor.sqlExe(pending_sql, {}))[0]['cnt'] + + source_list_sql = """select distinct source from product_inquiry where %s""" % where_clause + source_list = [row['source'] for row in (await sor.sqlExe(source_list_sql, {}))] + has_empty_source = any(s is None or s == '' for s in source_list) + source_list = [s for s in source_list if s] # 过滤空值 + if has_empty_source: + source_list.append('未知') + + # 分页查询 + search_sql = """select * from product_inquiry where %s order by update_time desc limit %d offset %d;""" % (where_clause, page_size, offset) result = await sor.sqlExe(search_sql, {}) + dict_sql = """select dict_type, dict_key, dict_value from product_inquiry_dict where status = 1 order by dict_type asc, sort_order asc;""" + dict_result = await sor.sqlExe(dict_sql, {}) + dict_mapping = {} + for dict_item in dict_result: + dict_type = dict_item.get('dict_type') + dict_mapping.setdefault(dict_type, {})[str(dict_item.get('dict_key'))] = dict_item.get('dict_value') + + value_mapping = { + 'custom_type': {'0': '个人', '1': '企业'}, + 'enterprise_type': dict_mapping.get('enterprise_type', {}), + 'region': dict_mapping.get('region', {}), + 'feedback': {'0': '待回复', '1': '沟通中', '2': '已关闭', '3': '号码错误'} + } + for data_dic in result: + for key, mapping in value_mapping.items(): + if key in data_dic: + data_dic['%s_name' % key] = mapping.get(str(data_dic.get(key)), data_dic.get(key)) + direction_mapping = dict_mapping.get('direction', {}) + direction_keys = str(data_dic.get('consult_direction')).split(',') if data_dic.get('consult_direction') else [] + data_dic['consult_direction_name'] = '，'.join([direction_mapping.get(direction_key.strip(), direction_key.strip()) for direction_key in direction_keys if direction_key.strip()]) + if ns.get('to_excel') == '1': # 创建映射字段 导出execl # 结果转换成 中文名称:值 的字典列表 @@ -21,14 +85,13 @@ async def search_user_inquiry(ns={}): 'phone': '联系人电话', 'email': '邮箱', 'company': '公司名称', + 'enterprise_type': '企业类型', + 'region': '所在区域', + 'consult_direction': '咨询方向', 'content': '咨询内容', 'feedback': '反馈状态', } # 新增值映射字典，集中管理各字段的数值转换规则 - value_mapping = { - 'custom_type': {'0': '个人', '1': '企业'}, - 'feedback': {'0': '未反馈', '1': '已反馈'} # 根据表结构补充反馈状态映射 - } # 转换字典键为中文 for data_dic in result: # 拆分后：显式循环结构（便于后续处理） @@ -40,7 +103,11 @@ async def search_user_inquiry(ns={}): continue value = data_dic[key] chinese_key = field_mapping[key] - if key in value_mapping: + if key == 'consult_direction': + direction_mapping = dict_mapping.get('direction', {}) + direction_keys = str(value).split(',') if value else [] + new_data_dic[chinese_key] = '，'.join([direction_mapping.get(direction_key.strip(), direction_key.strip()) for direction_key in direction_keys if direction_key.strip()]) + elif key in value_mapping: mapped_value = value_mapping[key].get(str(value), value) # 若未找到对应映射，保留原始值 new_data_dic[chinese_key] = mapped_value else: @@ -51,7 +118,14 @@ async def search_user_inquiry(ns={}): return { 'status': True, 'msg': 'search success', - 'data': result + 'data': result, + 'total_count': total_count, + 'source_stats': source_stats, + 'pending_count': pending_count, + 'source_list': source_list, + 'page': page, + 'page_size': page_size, + 'feedback_list': [{'id': 0, 'name': '待回复'},{'id': 1, 'name': '沟通中'},{'id': 2, 'name': '已关闭'},{'id': 3, 'name': '号码错误'}] } ret = await search_user_inquiry(params_kw) diff --git a/b/product/search_user_inquiry_dict.dspy b/b/product/search_user_inquiry_dict.dspy new file mode 100644 index 0000000..610e410 --- /dev/null +++ b/b/product/search_user_inquiry_dict.dspy @@ -0,0 +1,16 @@ +async def search_user_inquiry_dict(ns={}): + db = DBPools() + async with db.sqlorContext('kboss') as sor: + where_sql = "where status = 1" + if ns.get('dict_type'): + where_sql += " and dict_type = '%s'" % ns.get('dict_type') + search_sql = """select id, dict_type, dict_key, dict_value, sort_order from product_inquiry_dict %s order by dict_type asc, sort_order asc;""" % where_sql + result = await sor.sqlExe(search_sql, {}) + return { + 'status': True, + 'msg': 'search success', + 'data': result + } + +ret = await search_user_inquiry_dict(params_kw) +return ret diff --git a/b/user_inquiry.txt b/b/user_inquiry.txt new file mode 100644 index 0000000..a594ec0 --- /dev/null +++ b/b/user_inquiry.txt @@ -0,0 +1,43 @@ +CREATE TABLE `product_inquiry` ( + `id` varchar(32) NOT NULL COMMENT '唯一标识符', + `domain_name` varchar(64) NOT NULL COMMENT '所属域名', + `publish_type` varchar(1) DEFAULT NULL COMMENT '发布商品1/ 发布需求2', + `relate_id` varchar(32) DEFAULT NULL COMMENT '发布商品1/ 发布需求2', + `content` varchar(1024) DEFAULT NULL COMMENT '咨询需求内容', + `custom_type` tinyint(1) DEFAULT NULL COMMENT '客户类型（0-个人/1-企业）', + `name` varchar(50) DEFAULT NULL COMMENT '联系人姓名', + `phone` varchar(20) DEFAULT NULL COMMENT '联系电话', + `company` varchar(100) DEFAULT NULL COMMENT '企业客户公司名称', + `enterprise_type` tinyint(1) DEFAULT NULL COMMENT '企业类型（1-大型/2-中小企业/3-OPC个人/4-高校科研机构/5-政府/6-其他）', + `region` tinyint(1) DEFAULT NULL COMMENT '所在区域（0-大陆/1-港澳台）', + `consult_direction` varchar(20) DEFAULT NULL COMMENT '咨询方向（多选用逗号分隔：1,2,3）', + `email` varchar(50) DEFAULT NULL COMMENT '电子邮箱', + `feedback` varchar(1) DEFAULT '0' COMMENT '反馈状态', + `del_flg` varchar(1) DEFAULT '0' COMMENT '删除标志（0-正常/1-已删除）', + `update_time` timestamp NOT NULL DEFAULT current_timestamp() ON UPDATE current_timestamp() COMMENT '更新时间', + `create_at` timestamp NULL DEFAULT current_timestamp() COMMENT '创建时间', + PRIMARY KEY (`id`) USING BTREE +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3 COLLATE=utf8mb3_general_ci ROW_FORMAT=DYNAMIC COMMENT='产品咨询表'; + +CREATE TABLE `product_inquiry_dict` ( + `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键ID', + `dict_type` varchar(30) NOT NULL COMMENT '字典类型（标识属于哪一组选项）', + `dict_key` tinyint(4) NOT NULL COMMENT '字典键值（对应数据库实际存储的数字）', + `dict_value` varchar(50) NOT NULL COMMENT '字典显示名称（前端下拉框展示的文字）', + `sort_order` int(11) DEFAULT 0 COMMENT '排序序号（数字越小越靠前）', + `status` tinyint(1) DEFAULT 1 COMMENT '状态（0-禁用/1-启用）', + `create_time` timestamp NOT NULL DEFAULT current_timestamp() COMMENT '创建时间', + PRIMARY KEY (`id`) +) ENGINE=InnoDB AUTO_INCREMENT=12 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci COMMENT='咨询表字典配置表（运营可维护）'; +product_inquiry_dict表相关数据: +1 enterprise_type 1 大型企业 1 1 2026-07-07 16:32:45 +2 enterprise_type 2 中小企业 2 1 2026-07-07 16:32:45 +3 enterprise_type 3 OPC个人 3 1 2026-07-07 16:32:45 +4 enterprise_type 4 高校科研机构 4 1 2026-07-07 16:32:45 +5 enterprise_type 5 政府 5 1 2026-07-07 16:32:45 +6 enterprise_type 6 其他 6 1 2026-07-07 16:32:45 +7 region 0 大陆 1 1 2026-07-07 16:34:02 +8 region 1 港澳台 2 1 2026-07-07 16:34:02 +9 direction 1 AI Infra 基础设施（云/网/算） 1 1 2026-07-07 16:34:02 +10 direction 2 AI Agent 智能体（产品开发） 2 1 2026-07-07 16:34:02 +11 direction 3 AI Builder 炼智师（能力提升培训） 3 1 2026-07-07 16:34:02 \ No newline at end of file