#!/usr/bin/env python3 """ 统一搜索服务（端口8000） / → 中项网 (/root/cceup.db) /znlh → 中能联合 (/home/ccbuild/znlh.db) /zc → 中策大数据 (/home/ccbuild/zc.db) """ import http.server, sqlite3, urllib.parse, re, os CCEUP_DB = '/root/cceup.db' ZNLH_DB = '/home/ccbuild/znlh.db' ZC_DB = '/home/ccbuild/zc.db' def esc(s): if s is None: return '' return str(s).replace('&','&').replace('<','<').replace('>','>').replace('"','"') # ══════════════════════════════════════════════ # ZC 数据库 # ══════════════════════════════════════════════ def zc_search(q, page=1, per=20): db = sqlite3.connect(ZC_DB); db.row_factory = sqlite3.Row conds, params = [], [] if q: t = '%'+q+'%' conds.append('(project_id LIKE ? OR project_name LIKE ? OR industry LIKE ? OR province LIKE ? OR city LIKE ?)') params = [t]*5 wh = 'WHERE '+' AND '.join(conds) if conds else '' total = db.execute('SELECT COUNT(*) FROM zc_projects '+wh, params).fetchone()[0] rows = [dict(r) for r in db.execute('SELECT * FROM zc_projects '+wh+' ORDER BY publish_date DESC, project_id LIMIT ? OFFSET ?', params+[per,(page-1)*per])] db.close() return total, rows def zc_detail(pid): db = sqlite3.connect(ZC_DB); db.row_factory = sqlite3.Row r = db.execute('SELECT * FROM zc_projects WHERE project_id=?',(pid,)).fetchone() if not r: db.close(); return None p = dict(r) p['contacts'] = [dict(r) for r in db.execute('SELECT * FROM zc_contacts WHERE project_id=? ORDER BY id',(pid,))] db.close() return p # ══════════════════════════════════════════════ # ZNLH 数据库 # ══════════════════════════════════════════════ def znlh_search(q, page=1, per=20): db = sqlite3.connect(ZNLH_DB); db.row_factory = sqlite3.Row conds, params = [], [] if q: t = '%'+q+'%' conds.append('(project_id LIKE ? OR project_name LIKE ? OR owner_company LIKE ? OR industry LIKE ? OR province LIKE ? OR city LIKE ?)') params = [t]*6 wh = 'WHERE '+' AND '.join(conds) if conds else '' total = db.execute('SELECT COUNT(*) FROM znlh_projects '+wh, params).fetchone()[0] rows = [dict(r) for r in db.execute('SELECT * FROM znlh_projects '+wh+' ORDER BY publish_date DESC, project_id LIMIT ? OFFSET ?', params+[per,(page-1)*per])] db.close() return total, rows def znlh_detail(pid): db = sqlite3.connect(ZNLH_DB); db.row_factory = sqlite3.Row r = db.execute('SELECT * FROM znlh_projects WHERE project_id=?',(pid,)).fetchone() if not r: db.close(); return None p = dict(r) p['contacts'] = [dict(r) for r in db.execute('SELECT * FROM znlh_contacts WHERE project_id=? ORDER BY id',(pid,))] db.close() return p # ══════════════════════════════════════════════ # CCEUP 数据库 # ══════════════════════════════════════════════ def cceup_search(q, page=1, per=20): if not os.path.exists(CCEUP_DB): return 0, [] db = sqlite3.connect(CCEUP_DB); db.row_factory = sqlite3.Row conds, params = [], [] if q: t = '%'+q+'%' conds.append('(project_id LIKE ? OR project_name LIKE ? OR owner_company LIKE ? OR industry LIKE ? OR province LIKE ? OR city LIKE ?)') params = [t]*6 wh = 'WHERE '+' AND '.join(conds) if conds else '' total = db.execute('SELECT COUNT(*) FROM cceup_projects '+wh, params).fetchone()[0] rows = [dict(r) for r in db.execute('SELECT * FROM cceup_projects '+wh+' ORDER BY publish_date DESC, project_id LIMIT ? OFFSET ?', params+[per,(page-1)*per])] db.close() return total, rows def cceup_detail(pid): if not os.path.exists(CCEUP_DB): return None db = sqlite3.connect(CCEUP_DB); db.row_factory = sqlite3.Row r = db.execute('SELECT * FROM cceup_projects WHERE project_id=?',(pid,)).fetchone() if not r: db.close(); return None p = dict(r) p['contacts'] = [dict(r) for r in db.execute('SELECT * FROM cceup_contacts WHERE project_id=? ORDER BY id',(pid,))] db.close() return p # ══════════════════════════════════════════════ # HTML 渲染 # ══════════════════════════════════════════════ HEAD = ''' {title}
''' NAV = '''
中项网 中能联合 中策大数据
''' TAIL = '
' def nav_html(active): return NAV.format(c1='act' if active=='cceup' else '', c2='act' if active=='znlh' else '', c3='act' if active=='zc' else '') def render_list(db, title, active, q, page, total, rows, fields): tp = max(1,(total+19)//20) qp = '&q='+urllib.parse.quote(q) if q else '' prefix = '/'+db h = HEAD.format(title=title) h += '

'+title+'

'+nav_html(active) h += '
' h += '
共 '+str(total)+' 个项目'+('，搜索"'+esc(q)+'"' if q else '')+'
' for r in rows: pid = esc(r.get('project_id','')) name = esc(r.get('project_name','') or r.get('owner_company','') or '') h += '
'+name+'
' h += '#'+pid+'' for f in fields: v = r.get(f[0],'') if v: h += ''+esc(v)+'' if r.get('province'): h += ''+esc(r['province'])+('/'+esc(r['city']) if r.get('city') else '')+'' if r.get('total_investment') or r.get('budget'): h += ''+esc(r.get('total_investment','') or r.get('budget',''))+'' if r.get('publish_date'): h += ''+esc(r['publish_date'])+'' h += '
' if tp>1: h += '
' for p in range(1, min(tp+1,21)): h += ''+str(p)+'' h += '
' return h+TAIL def render_fields(h, p, field_list): for lbl, key in field_list: v = p.get(key,'') if v and v!='一一' and v!='——': h += '
'+lbl+'：'+esc(v)+'
' return h def render_contacts(h, contacts): if contacts: h += '

项目联系人

' for c in contacts: h += '
'+esc(c.get('company','') or c.get('owner_company',''))+'
' if c.get('contact_name'): h += '姓名：'+esc(c['contact_name'])+'' if c.get('department'): h += '部门：'+esc(c['department'])+'' if c.get('position'): h += '职务：'+esc(c['position'])+'' if c.get('phone'): h += '手机：'+esc(c['phone'])+'' if c.get('address'): h += '地址：'+esc(c['address'])+'' if c.get('remarks') and c['remarks'] not in ('一一','——',''): h += '备注：'+esc(c['remarks'])+'' h += '
' h += '
' return h # ══════════════════════════════════════════════ # Route handlers # ══════════════════════════════════════════════ def handle_zc(path, params): q = params.get('q',[''])[0].strip() page = int(params.get('page',['1'])[0]) if path.startswith('/project/'): pid = path[9:] p = zc_detail(pid) if not p: return 404, '

404

' h = HEAD.format(title='中策大数据 - '+esc(p.get('project_name',''))) h += nav_html('zc') + '← 返回列表' h += '

'+esc(p.get('project_name',''))+'

' h = render_fields(h, p, [ ('项目编号','project_id'),('版本类型','version_type'),('发布时间','publish_date'), ('项目阶段','phase'),('建设周期','construction_period'),('总投资额','total_investment'), ('工程类型','project_type'),('甲方性质','owner_nature'),('所属行业','industry'), ('项目规模','scale'),('省份','province'),('城市','city'),('详细地址','detail_address'), ('建筑面积','building_area'),('占地面积','land_area'),('建筑层数','floors'), ('外资参与','foreign_investment'),('装修','decoration'),('钢结构','steel_structure'), ('外墙材料','exterior_wall'),('车库停车位','parking'),('电梯','elevator'), ('空调','air_conditioning'),('新风系统','fresh_air'),('供暖方式','heating'), ('装配式建筑','prefab'),('被动房','passive_house'), ]) h += '
' if p.get('construction_content'): h += '

建设内容

'+esc(p['construction_content'])+'
' if p.get('equipment_list'): h += '

设备清单

'+esc(p['equipment_list'])+'
' if p.get('schedule_overview'): h += '

工期概述

'+esc(p['schedule_overview'])+'
' h = render_contacts(h, p.get('contacts',[])) return 200, h+TAIL else: total, rows = zc_search(q, page) h = render_list('zc', '中策大数据', 'zc', q, page, total, rows, [('phase','b1'),('scale','b2'),('project_type','b3')]) return 200, h def handle_znlh(path, params): q = params.get('q',[''])[0].strip() page = int(params.get('page',['1'])[0]) if path.startswith('/project/'): pid = path[9:] p = znlh_detail(pid) if not p: return 404, '

404

' h = HEAD.format(title='中能联合 - '+esc(p.get('project_name',''))) h += nav_html('znlh') + '← 返回列表' h += '

'+esc(p.get('project_name',''))+'

' h = render_fields(h, p, [ ('项目编号','project_id'),('当前阶段','phase'),('总投资','budget'), ('所属行业','industry'),('区域','region'),('省份','province'),('城市','city'), ('工程类型','nature'),('占地面积','area'),('采购情况','purchase_status'), ('竣工日期','completion_date'),('权重','weight'),('业主类型','owner_type'), ('发布日期','publish_date'),('资金情况','funding_status'),('更新时间','update_date'), ]) h += '
' # Enterprise info ent = [('企业名称','owner_company'),('注册地址','registered_address'),('注册资金','registered_capital'), ('企业负责人','company_contact'),('主营业务','business_scope')] has_ent = any(p.get(k) for _,k in ent) if has_ent: h += '

业主信息

' for lbl,k in ent: v = p.get(k,'') if v: h += '
'+lbl+'：'+esc(v)+'
' h += '
' # Detail 1-5 for lbl,k in [('1.建设背景','background'),('2.建设内容','construction_content'), ('3.工艺路线','process_route'),('4.建设地点','construction_location'),('5.社会效益','social_benefits')]: v = p.get(k,'') if v: h += '

'+lbl+'

'+esc(v)+'
' # Equipment eq = [('工艺设备','equipment_list'),('配套设施设备','supporting_equipment'),('客户所需设备','client_needed_equipment')] has_eq = any(p.get(k) for _,k in eq) if has_eq: h += '

设备清单

' for lbl,k in eq: v = p.get(k,'') if v: h += '

'+lbl+'：
'+esc(v)+'

' h += '
' if p.get('project_progress'): h += '

项目进展

'+esc(p['project_progress'])+'
' if p.get('detail'): h += '

特殊说明

'+esc(p['detail'])+'
' h = render_contacts(h, p.get('contacts',[])) return 200, h+TAIL else: total, rows = znlh_search(q, page) h = render_list('znlh', '中能联合', 'znlh', q, page, total, rows, [('phase','b1'),('weight','b2'),('nature','b3')]) return 200, h def handle_cceup(path, params): q = params.get('q',[''])[0].strip() page = int(params.get('page',['1'])[0]) if path.startswith('/project/'): pid = path[9:] p = cceup_detail(pid) if not p: return 404, '

404

' h = HEAD.format(title='中项网 - '+esc(p.get('project_name','') or p.get('owner_company',''))) h += nav_html('cceup') + '← 返回列表' h += '

'+esc(p.get('project_name','') or p.get('owner_company',''))+'

' h = render_fields(h, p, [ ('项目编号','project_id'),('项目阶段','phase'),('投资金额','budget'), ('所属行业','industry'),('省份','province'),('城市','city'), ('工程类型','nature'),('业主类型','owner_type'),('发布时间','publish_date'), ]) h += '
' if p.get('overview'): h += '

项目概况

'+esc(p['overview'])+'
' if p.get('progress'): h += '

项目进展

'+esc(p['progress'])+'
' if p.get('detail'): h += '

项目详情

'+esc(p['detail'])+'
' h = render_contacts(h, p.get('contacts',[])) return 200, h+TAIL else: total, rows = cceup_search(q, page) h = render_list('', '中项网', 'cceup', q, page, total, rows, [('phase','b1'),('nature','b3')]) return 200, h # ══════════════════════════════════════════════ # HTTP Server # ══════════════════════════════════════════════ class UnifiedHandler(http.server.BaseHTTPRequestHandler): def do_GET(self): p = urllib.parse.urlparse(self.path) params = urllib.parse.parse_qs(p.query) path = p.path.rstrip('/') or '/' try: if path.startswith('/zc'): sub = path[3:] or '/' code, body = handle_zc(sub, params) elif path.startswith('/znlh'): sub = path[5:] or '/' code, body = handle_znlh(sub, params) elif path.startswith('/project/'): # backward compat: /project/XXX -> CCEUP code, body = handle_cceup(path, params) else: code, body = handle_cceup(path, params) b = body.encode() self.send_response(code) self.send_header('Content-Type','text/html; charset=utf-8') self.send_header('Content-Length',str(len(b))) self.end_headers() self.wfile.write(b) except Exception as e: import traceback err = '
'+esc(traceback.format_exc())+'
' b = err.encode() self.send_response(500) self.send_header('Content-Type','text/html; charset=utf-8') self.send_header('Content-Length',str(len(b))) self.end_headers() self.wfile.write(b) def log_message(self,*a): pass if __name__ == '__main__': print('Unified search on :8000 [/ /zc/ /znlh/]') http.server.HTTPServer(('0.0.0.0',8000),UnifiedHandler).serve_forever()