service.py 125 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965
  1. import xml.etree.ElementTree as ET
  2. from typing import Union
  3. from fastapi import FastAPI
  4. import os
  5. import json
  6. import uuid
  7. import re
  8. from fastapi.middleware.cors import CORSMiddleware
  9. from pydantic import BaseModel
  10. import pandas as pd
  11. from numpy import float64, int64
  12. def chaifen(result, zhuanye):
  13. clde = result['clde']
  14. if zhuanye == 10:
  15. pbf = pd.read_csv("de/tj/JD_PeiBiF.csv")
  16. clk = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  17. elif zhuanye == 20:
  18. pbf = pd.read_csv("de/sz/JD_PeiBiF.csv")
  19. clk = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  20. elif zhuanye == 30:
  21. pbf = pd.read_csv("de/az/JD_PeiBiF.csv")
  22. clk = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  23. elif zhuanye == 40:
  24. pbf = pd.read_csv("de/yl/JD_PeiBiF.csv")
  25. clk = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  26. elif zhuanye == 50:
  27. pbf = pd.read_csv("de/xstj/JD_PeiBiF.csv")
  28. clk = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  29. else:
  30. pbf = pd.read_csv("de/xsaz/JD_PeiBiF.csv")
  31. clk = pd.read_csv("de/xsaz/JD_CaiLiaoK.csv")
  32. for entry in clde:
  33. filtered = pbf[pbf["PBBH"]==entry['CLBH']]
  34. if len(filtered) > 0:
  35. entry["children"] = []
  36. ids = filtered['RcjID'].tolist()
  37. cls = clk[clk['RcjID'].isin(ids)]
  38. joined = pd.merge(filtered, cls, on='RcjID')
  39. for row in joined.itertuples():
  40. CLBH = row.CLBH
  41. CLMC = row.CLMC
  42. JLDW = row.JLDW
  43. YSJG = row.YSJG
  44. SL = float(row.SL) * float(entry['SL'])
  45. HJ = float(row.HJ) * float(entry['SL'])
  46. entry['children'].append({'CLBH': CLBH,
  47. 'CLMC': CLMC,
  48. 'JLDW': JLDW,
  49. 'YSJG': YSJG,
  50. 'SL': SL,
  51. 'HJ': HJ
  52. })
  53. ##print(result)
  54. return result
  55. def getQingdanTuijian(bh, bt, bm):
  56. result = []
  57. try:
  58. all = pd.read_csv("QingDanAllInOne.csv")
  59. bm_ = int(bm) // 1000
  60. hit = all[all["qdbh"] == str(bm_)]
  61. for i in range(len(hit)):
  62. result.append({'ID': hit.iloc[i]["index"].item(), '定额编号': hit.iloc[i]["debh"], '工程量名称': hit.iloc[i]["gclmc"], '工作内容': hit.iloc[i]["work"]})
  63. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  64. finally:
  65. return result
  66. def getQdmx(root, bh, bt):
  67. result = []
  68. #result = [["序号", "清单编码", "名称", "项目特征", "计算规则", "单位", "数量", "综合单价", "合价", "人工费", "主材费", "设备费", "辅材费", "材料费", "机械费", "管理费", "利润" , "暂估价", "综合人工工日", "备注" ]]
  69. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  70. item = None
  71. for child in root:
  72. if child.tag == "Dxgcxx":
  73. for child1 in child:
  74. Dwgcbh = child1.attrib["Dwgcbh"]
  75. if Dwgcbh == bh:
  76. item = child1
  77. break
  78. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  79. Fywj = None
  80. for child in item:
  81. if child.tag == 'Qdxm':
  82. Fywj= child
  83. break
  84. container = None
  85. for child in Fywj:
  86. ##child is mx
  87. if child.tag == "QdBt":
  88. if child.attrib["Mc"] == bt:
  89. count = 0
  90. for grandchild in child:
  91. count = count + 1
  92. if count > 0:
  93. container = child
  94. break
  95. if container == None:
  96. container = Fywj
  97. for child in container:
  98. #result = [["序号", "清单编码", "名称", "项目特征", "计算规则", "单位", "数量", "综合单价", "合价", "人工费", "主材费",
  99. # "设备费", "辅材费", "材料费", "机械费", "管理费", "利润" , "暂估价", "综合人工工日", "备注" ]]
  100. result.append({
  101. "操作" : "",
  102. "序号": child.attrib["Xh"], "清单编码" : child.attrib["Qdbm"], "名称" : child.attrib["Mc"],"项目特征" : child.attrib["Xmtz"],
  103. "计算规则" : child.attrib["Jsgz"],
  104. "单位" : child.attrib["Dw"],
  105. "数量": child.attrib["Sl"],
  106. "综合单价" : child.attrib["Zhdj"],
  107. "合价" : child.attrib["Zhhj"],
  108. "人工费": child.attrib["Rgf"],
  109. "主材费" : child.attrib["Zcf"],
  110. "设备费": child.attrib["Sbf"],
  111. "辅材费": child.attrib["Fcf"],
  112. "材料费" : child.attrib["Clf"],
  113. "机械费" : child.attrib["Jxf"],
  114. "管理费": child.attrib["Glf"],
  115. "利润": child.attrib["Lr"],
  116. "暂估价" : child.attrib["Zgj"],
  117. "综合人工工日" : child.attrib["Zgr"],
  118. "备注" : child.attrib["Bz"]}
  119. )
  120. for child_zj in child:
  121. if child_zj.tag == "Qdxdezj":
  122. for child_mx in child_zj:
  123. if child_mx.tag == "QdxdezjMx":
  124. key = str(uuid.uuid4())
  125. child_mx.set("key", key)
  126. ##print("set key")
  127. ##print(key)
  128. ##print(child_mx)
  129. parent = result[-1]
  130. if "__children" in parent:
  131. parent["__children"].append({
  132. "key": key,
  133. "操作" : "",
  134. "序号": None, "清单编码" : child_mx.attrib["Debm"], "名称" : child_mx.attrib["Mc"],"项目特征" : None,
  135. "计算规则" : None,
  136. "单位" : child_mx.attrib["Dw"],
  137. "数量": child_mx.attrib["DwQdSl"],
  138. "综合单价" : child_mx.attrib["Dj"],
  139. "合价" : child_mx.attrib["Hj"],
  140. "人工费": child_mx.attrib["Rgf"],
  141. "主材费" : child_mx.attrib["Zcf"],
  142. "设备费": child_mx.attrib["Sbf"],
  143. "辅材费": child_mx.attrib["Fcf"],
  144. "材料费" : child_mx.attrib["Clf"],
  145. "机械费" : child_mx.attrib["Jxf"],
  146. "管理费": child_mx.attrib["Glf"],
  147. "利润": child_mx.attrib["Lr"],
  148. "暂估价" : None,
  149. "综合人工工日" : None,
  150. "备注" : None}
  151. )
  152. else:
  153. parent["__children"] = [{
  154. "key": key,
  155. "操作" : "",
  156. "序号": None, "清单编码" : child_mx.attrib["Debm"], "名称" : child_mx.attrib["Mc"],"项目特征" : None,
  157. "计算规则" : None,
  158. "单位" : child_mx.attrib["Dw"],
  159. "数量": child_mx.attrib["DwQdSl"],
  160. "综合单价" : child_mx.attrib["Dj"],
  161. "合价" : child_mx.attrib["Hj"],
  162. "人工费": child_mx.attrib["Rgf"],
  163. "主材费" : child_mx.attrib["Zcf"],
  164. "设备费": child_mx.attrib["Sbf"],
  165. "辅材费": child_mx.attrib["Fcf"],
  166. "材料费" : child_mx.attrib["Clf"],
  167. "机械费" : child_mx.attrib["Jxf"],
  168. "管理费": child_mx.attrib["Glf"],
  169. "利润": child_mx.attrib["Lr"],
  170. "暂估价" : None,
  171. "综合人工工日" : None,
  172. "备注" : None}]
  173. return result
  174. def getQdmx_default(root, bh, bt):
  175. result = []
  176. #result = [["序号", "清单编码", "名称", "项目特征", "计算规则", "单位", "数量", "综合单价", "合价", "人工费", "主材费", "设备费", "辅材费", "材料费", "机械费", "管理费", "利润" , "暂估价", "综合人工工日", "备注" ]]
  177. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  178. item = None
  179. for child in root:
  180. if child.tag == "Dxgcxx":
  181. for child1 in child:
  182. Dwgcbh = child1.attrib["Dwgcbh"]
  183. if Dwgcbh == bh:
  184. item = child1
  185. break
  186. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  187. Fywj = None
  188. for child in item:
  189. if child.tag == 'Qdxm':
  190. Fywj= child
  191. break
  192. container = None
  193. for child in Fywj:
  194. ##child is mx
  195. if child.tag == "Qdmx":
  196. #result = [["序号", "清单编码", "名称", "项目特征", "计算规则", "单位", "数量", "综合单价", "合价", "人工费", "主材费",
  197. # "设备费", "辅材费", "材料费", "机械费", "管理费", "利润" , "暂估价", "综合人工工日", "备注" ]]
  198. result.append({
  199. "操作" : "",
  200. "序号": child.attrib["Xh"], "清单编码" : child.attrib["Qdbm"], "名称" : child.attrib["Mc"],"项目特征" : child.attrib["Xmtz"],
  201. "计算规则" : child.attrib["Jsgz"],
  202. "单位" : child.attrib["Dw"],
  203. "数量": child.attrib["Sl"],
  204. "综合单价" : child.attrib["Zhdj"],
  205. "合价" : child.attrib["Zhhj"],
  206. "人工费": child.attrib["Rgf"],
  207. "主材费" : child.attrib["Zcf"],
  208. "设备费": child.attrib["Sbf"],
  209. "辅材费": child.attrib["Fcf"],
  210. "材料费" : child.attrib["Clf"],
  211. "机械费" : child.attrib["Jxf"],
  212. "管理费": child.attrib["Glf"],
  213. "利润": child.attrib["Lr"],
  214. "暂估价" : child.attrib["Zgj"],
  215. "综合人工工日" : child.attrib["Zgr"],
  216. "备注" : child.attrib["Bz"]}
  217. )
  218. for child_zj in child:
  219. if child_zj.tag == "Qdxdezj":
  220. for child_mx in child_zj:
  221. if child_mx.tag == "QdxdezjMx":
  222. key = str(uuid.uuid4())
  223. child_mx.set("key", key)
  224. ##print("set key")
  225. ##print(key)
  226. ##print(child_mx)
  227. parent = result[-1]
  228. if "__children" in parent:
  229. parent["__children"].append({
  230. "key": key,
  231. "操作" : "",
  232. "序号": None, "清单编码" : child_mx.attrib["Debm"], "名称" : child_mx.attrib["Mc"],"项目特征" : None,
  233. "计算规则" : None,
  234. "单位" : child_mx.attrib["Dw"],
  235. "数量": child_mx.attrib["DwQdSl"],
  236. "综合单价" : child_mx.attrib["Dj"],
  237. "合价" : child_mx.attrib["Hj"],
  238. "人工费": child_mx.attrib["Rgf"],
  239. "主材费" : child_mx.attrib["Zcf"],
  240. "设备费": child_mx.attrib["Sbf"],
  241. "辅材费": child_mx.attrib["Fcf"],
  242. "材料费" : child_mx.attrib["Clf"],
  243. "机械费" : child_mx.attrib["Jxf"],
  244. "管理费": child_mx.attrib["Glf"],
  245. "利润": child_mx.attrib["Lr"],
  246. "暂估价" : None,
  247. "综合人工工日" : None,
  248. "备注" : None}
  249. )
  250. else:
  251. parent["__children"] = [{
  252. "key": key,
  253. "操作" : "",
  254. "序号": None, "清单编码" : child_mx.attrib["Debm"], "名称" : child_mx.attrib["Mc"],"项目特征" : None,
  255. "计算规则" : None,
  256. "单位" : child_mx.attrib["Dw"],
  257. "数量": child_mx.attrib["DwQdSl"],
  258. "综合单价" : child_mx.attrib["Dj"],
  259. "合价" : child_mx.attrib["Hj"],
  260. "人工费": child_mx.attrib["Rgf"],
  261. "主材费" : child_mx.attrib["Zcf"],
  262. "设备费": child_mx.attrib["Sbf"],
  263. "辅材费": child_mx.attrib["Fcf"],
  264. "材料费" : child_mx.attrib["Clf"],
  265. "机械费" : child_mx.attrib["Jxf"],
  266. "管理费": child_mx.attrib["Glf"],
  267. "利润": child_mx.attrib["Lr"],
  268. "暂估价" : None,
  269. "综合人工工日" : None,
  270. "备注" : None}]
  271. return result
  272. def getQdxm_addition(root, id):
  273. result = []
  274. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  275. item = None
  276. for child in root:
  277. if child.tag == "Dxgcxx":
  278. for child1 in child:
  279. Dwgcbh = child1.attrib["Dwgcbh"]
  280. if Dwgcbh == id:
  281. item = child1
  282. break
  283. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  284. Fywj = None
  285. for child in item:
  286. if child.tag == 'Qdxm':
  287. Fywj= child
  288. break
  289. for child in Fywj:
  290. ##child is mx
  291. if child.tag == "QdBt":
  292. count = 0
  293. for grandchild in child:
  294. count = count + 1
  295. if count > 0:
  296. result.append({'Bz': child.attrib["Bz"], 'Je': child.attrib['Je'], 'Mc': child.attrib['Mc'], 'Xh': child.attrib['Xh'], 'Zgj': child.attrib['Zgj']})
  297. return result
  298. def getQdxm(root, id):###qdxm下面既有qdmx,也有qdbt,qdbt可能为空
  299. result = []
  300. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  301. item = None
  302. for child in root:
  303. if child.tag == "Dxgcxx":
  304. for child1 in child:
  305. Dwgcbh = child1.attrib["Dwgcbh"]
  306. if Dwgcbh == id:
  307. item = child1
  308. break
  309. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  310. Fywj = None
  311. for child in item:
  312. if child.tag == 'Qdxm':
  313. Fywj= child
  314. break
  315. for child in Fywj:
  316. ##child is mx
  317. if child.tag == 'Qdmx':
  318. if 'Default' in result:
  319. pass
  320. else:
  321. result.append('Default')
  322. if child.tag == "QdBt":
  323. count = 0
  324. for grandchild in child:
  325. count = count + 1
  326. if count > 0:
  327. result.append(child.attrib["Mc"])
  328. return result
  329. def getZjcs(root, id):
  330. result = []
  331. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  332. item = None
  333. for child in root:
  334. if child.tag == "Dxgcxx":
  335. for child1 in child:
  336. Dwgcbh = child1.attrib["Dwgcbh"]
  337. if Dwgcbh == id:
  338. item = child1
  339. break
  340. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  341. Fywj = None
  342. for child in item:
  343. if child.tag == 'Csxm':
  344. Fywj= child
  345. break
  346. Zjcs_parent = None
  347. for child in Fywj:
  348. if child.tag == 'ZjCs':
  349. Zjcs_parent = child
  350. break
  351. for child in Zjcs_parent:
  352. ##child is mx {
  353. result.append({
  354. "序号" : child.attrib["Xh"], "清单编码": child.attrib["Bm"], "名称" : child.attrib["Mc"],
  355. "计算基数" : child.attrib["Js"],
  356. "计算基础" : child.attrib["Jsjc"], "费率" : child.attrib["Fl"],
  357. "金额" : child.attrib["Je"], "项目类别" : child.attrib["Xmlb"]})
  358. __children = []
  359. for grandchild in child:
  360. __children.append({
  361. "序号" : None, "清单编码": None, "名称" : grandchild.attrib["Mc"],
  362. "计算基数" : grandchild.attrib["Js"],
  363. "计算基础" : grandchild.attrib["Jsjc"], "费率" : grandchild.attrib["Fl"],
  364. "金额" : grandchild.attrib["Je"], "项目类别" : grandchild.attrib["Xmlb"]})
  365. if len(__children) > 0:
  366. result[-1]["__children"] = __children
  367. return result
  368. def getZcbfwf(root, id):
  369. result = []
  370. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  371. item = None
  372. for child in root:
  373. if child.tag == "Dxgcxx":
  374. for child1 in child:
  375. Dwgcbh = child1.attrib["Dwgcbh"]
  376. if Dwgcbh == id:
  377. item = child1
  378. break
  379. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  380. Fywj = None
  381. for child in item:
  382. if child.tag == 'Zcbfwf':
  383. Fywj= child
  384. break
  385. for child in Fywj:
  386. result.append(
  387. {'序号': child.attrib["Xh"],
  388. "名称" : child.attrib["Mc"], "项目价值" : child.attrib["Xmjz"], "服务内容" :child.attrib["Fwnr"], "计算基础" :child.attrib["Jsjc"],
  389. "费率" :child.attrib["Fl"], "金额" :child.attrib["Je"]}
  390. )
  391. return result
  392. def getRcjhz(root, id):
  393. result = [[ "ID", "编码", "名称", "规格型号", "单位", "数量", "单价", "合价", "产地",
  394. "供应厂商", "人材机类别", "主要材料标志", "主材标志", "设备标志", "甲供标志", "暂估价标志"]]
  395. for child in root:
  396. if child.tag == "Dxgcxx":
  397. for child1 in child:
  398. Dwgcbh = child1.attrib["Dwgcbh"]
  399. if Dwgcbh == id:
  400. item = child1
  401. break
  402. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  403. Fywj = None
  404. for child in item:
  405. if child.tag == 'Rcjhz':
  406. Fywj= child
  407. break
  408. for child in Fywj:
  409. result.append(
  410. [
  411. child.attrib["RcjId"], child.attrib["RcjBm"], child.attrib["Mc"], child.attrib["Ggxh"],
  412. child.attrib["Dw"], child.attrib["Sl"], child.attrib["Dj"], child.attrib["Hj"],
  413. child.attrib["Cd"], child.attrib["Gycs"], child.attrib["Rcjlb"],
  414. child.attrib["Zyclbz"], child.attrib["Zcbz"], child.attrib["Sbbz"], child.attrib["Jgbz"],
  415. child.attrib["Zgjbz"]]
  416. )
  417. return result
  418. def getFbrgycl(root, id):
  419. result = []
  420. for child in root:
  421. if child.tag == "Dxgcxx":
  422. for child1 in child:
  423. Dwgcbh = child1.attrib["Dwgcbh"]
  424. if Dwgcbh == id:
  425. item = child1
  426. break
  427. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  428. Fywj = None
  429. for child in item:
  430. if child.tag == 'Fbrgycl':
  431. Fywj= child
  432. break
  433. for child in Fywj:
  434. result.append(
  435. {'序号': child.attrib["Xh"],
  436. 'ID': child.attrib["RcjId"], '材料编号': child.attrib["Clbh"], '名称': child.attrib["Mc"], '规格型号': child.attrib["Ggxh"],
  437. '单位': child.attrib["Dw"], '数量': child.attrib["Sl"], '单价': child.attrib["Dj"], '合价': child.attrib["Hj"], '交货方式': child.attrib["Jhfs"],
  438. '送达地点': child.attrib["Sddd"], '备注': child.attrib["Bz"]}
  439. )
  440. return result
  441. def getJrg(root, id):
  442. result = []
  443. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  444. item = None
  445. for child in root:
  446. if child.tag == "Dxgcxx":
  447. for child1 in child:
  448. Dwgcbh = child1.attrib["Dwgcbh"]
  449. if Dwgcbh == id:
  450. item = child1
  451. break
  452. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  453. Fywj = None
  454. for child in item:
  455. if child.tag == 'Jrg':
  456. Fywj= child
  457. break
  458. for child in Fywj:
  459. result.append(
  460. {'序号': child.attrib["Xh"],
  461. '名称': child.attrib["Mc"], '金额': child.attrib["Je"], '类别': child.attrib["Lb"]}
  462. )
  463. return result
  464. def getZlje(root, id):
  465. result = []
  466. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  467. item = None
  468. for child in root:
  469. if child.tag == "Dxgcxx":
  470. for child1 in child:
  471. Dwgcbh = child1.attrib["Dwgcbh"]
  472. if Dwgcbh == id:
  473. item = child1
  474. break
  475. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  476. Fywj = None
  477. for child in item:
  478. if child.tag == 'Zlje':
  479. Fywj= child
  480. break
  481. for child in Fywj:
  482. result.append(
  483. {'序号': child.attrib["Xh"],
  484. '名称': child.attrib["Mc"], '单位': child.attrib["Dw"], '暂定金额': child.attrib["Zdje"], '备注': child.attrib["Bz"]}
  485. )
  486. return result
  487. def getZygczgj(root, id):
  488. result = []
  489. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  490. item = None
  491. for child in root:
  492. if child.tag == "Dxgcxx":
  493. for child1 in child:
  494. Dwgcbh = child1.attrib["Dwgcbh"]
  495. if Dwgcbh == id:
  496. item = child1
  497. break
  498. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  499. Fywj = None
  500. for child in item:
  501. if child.tag == 'Zygczg':
  502. Fywj= child
  503. break
  504. for child in Fywj:
  505. result.append(
  506. {'序号': child.attrib["Xh"],
  507. '名称': child.attrib["Mc"], '工程内容': child.attrib["Gcnr"], '金额': child.attrib["Je"], '备注': child.attrib["Bz"]}
  508. )
  509. return result
  510. def getQtxm(root, id):
  511. result = []
  512. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  513. item = None
  514. for child in root:
  515. if child.tag == "Dxgcxx":
  516. for child1 in child:
  517. Dwgcbh = child1.attrib["Dwgcbh"]
  518. if Dwgcbh == id:
  519. item = child1
  520. break
  521. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  522. Fywj = None
  523. for child in item:
  524. if child.tag == 'Qtxm':
  525. Fywj= child
  526. break
  527. for child in Fywj:
  528. ##child is mx
  529. xh = child.attrib["Xh"]
  530. if "." in xh:
  531. count = 0
  532. for entry in xh:
  533. if entry == ".":
  534. count = count + 1
  535. if count == 1:
  536. parent = result[-1]
  537. if "__children" in parent:
  538. children = parent["__children"]
  539. children.append(
  540. {"序号":xh, "名称": child.attrib["Mc"],
  541. "金额": child.attrib["Je"], "项目类别" : child.attrib["Xmlb"], "备注" : child.attrib["Bz"]}
  542. )
  543. else:
  544. parent["__children"] = [
  545. {"序号":xh, "名称": child.attrib["Mc"],
  546. "金额": child.attrib["Je"], "项目类别" : child.attrib["Xmlb"], "备注" : child.attrib["Bz"]}]
  547. else:
  548. result.append(
  549. {"序号":xh, "名称": child.attrib["Mc"],
  550. "金额": child.attrib["Je"], "项目类别" : child.attrib["Xmlb"], "备注" : child.attrib["Bz"]}
  551. )
  552. return result
  553. def getGfsj(root, id):
  554. result = []
  555. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  556. item = None
  557. for child in root:
  558. if child.tag == "Dxgcxx":
  559. for child1 in child:
  560. Dwgcbh = child1.attrib["Dwgcbh"]
  561. if Dwgcbh == id:
  562. item = child1
  563. break
  564. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  565. Fywj = None
  566. for child in item:
  567. if child.tag == 'Gfsj':
  568. Fywj= child
  569. break
  570. for child in Fywj:
  571. ##child is mx
  572. xh = child.attrib["Xh"]
  573. if "." in xh:
  574. count = 0
  575. for entry in xh:
  576. if entry == ".":
  577. count = count + 1
  578. if count == 1:
  579. parent = result[-1]
  580. if "__children" in parent:
  581. children = parent["__children"]
  582. children.append({"序号":xh, "名称": child.attrib["Mc"], "取费基数": child.attrib["Qfjs"], "计算基础": child.attrib["Jsjc"], "费率": child.attrib['Fl'], "金额": child.attrib["Je"], "类别" : child.attrib["Fyxlb"]})
  583. else:
  584. parent["__children"] = [{"序号":xh, "名称": child.attrib["Mc"], "取费基数": child.attrib["Qfjs"], "计算基础": child.attrib["Jsjc"], "费率": child.attrib['Fl'], "金额": child.attrib["Je"], "类别" : child.attrib["Fyxlb"]}]
  585. elif count == 2:
  586. parent = result[-1]
  587. if "__children" in parent:
  588. parent = parent["__children"][-1]
  589. ##print(parent)
  590. if "__children" in parent:
  591. children = parent["__children"]
  592. children.append({"序号":xh, "名称": child.attrib["Mc"], "取费基数": child.attrib["Qfjs"], "计算基础": child.attrib["Jsjc"], "费率": child.attrib['Fl'], "金额": child.attrib["Je"], "类别" : child.attrib["Fyxlb"]})
  593. else:
  594. parent["__children"] = [{"序号":xh, "名称": child.attrib["Mc"], "取费基数": child.attrib["Qfjs"], "计算基础": child.attrib["Jsjc"], "费率": child.attrib['Fl'], "金额": child.attrib["Je"], "类别" : child.attrib["Fyxlb"]}]
  595. else:
  596. ###["序号", "名称", "取费基数", "计算基础", "金额", "类别"]);
  597. result.append({"序号":xh, "名称": child.attrib["Mc"], "取费基数": child.attrib["Qfjs"], "计算基础": child.attrib["Jsjc"], "费率": child.attrib['Fl'], "金额": child.attrib["Je"], "类别" : child.attrib["Fyxlb"]})
  598. return result
  599. def getBjhz(root, id):
  600. ##print(root)
  601. ##print(id)
  602. result = []
  603. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  604. item = None
  605. for child in root:
  606. if child.tag == "Dxgcxx":
  607. for child1 in child:
  608. Dwgcbh = child1.attrib["Dwgcbh"]
  609. if Dwgcbh == id:
  610. item = child1
  611. break
  612. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  613. ##print(item)
  614. Fywj = None
  615. for child in item:
  616. if child.tag == 'Fywj':
  617. Fywj= child
  618. break
  619. for child in Fywj:
  620. ##child is mx
  621. xh = child.attrib["Xh"]
  622. if "." in xh:
  623. count = 0
  624. for entry in xh:
  625. if entry == ".":
  626. count = count + 1
  627. if count == 1:
  628. parent = result[-1]
  629. if "__children" in parent:
  630. children = parent["__children"]
  631. children.append({"序号":xh, "名称": child.attrib["Mc"], "金额": child.attrib["Je"], "暂估价" : child.attrib["Zgj"], "类别" : child.attrib["Fyxlb"]})
  632. else:
  633. parent["__children"] = [{"序号":xh, "名称": child.attrib["Mc"], "金额": child.attrib["Je"], "暂估价" : child.attrib["Zgj"], "类别" : child.attrib["Fyxlb"]}]
  634. elif count == 2:
  635. parent = result[-1]
  636. if "__children" in parent:
  637. parent = parent["__children"][-1]
  638. ##print(parent)
  639. if "__children" in parent:
  640. children = parent["__children"]
  641. children.append({"序号":xh, "名称": child.attrib["Mc"], "金额": child.attrib["Je"], "暂估价" : child.attrib["Zgj"], "类别" : child.attrib["Fyxlb"]})
  642. else:
  643. parent["__children"] = [{"序号":xh, "名称": child.attrib["Mc"], "金额": child.attrib["Je"], "暂估价" : child.attrib["Zgj"], "类别" : child.attrib["Fyxlb"]}]
  644. else:
  645. ###"序号", "名称", "金额", "暂估价", "类别"]
  646. result.append({"序号":xh, "名称": child.attrib["Mc"], "金额": child.attrib["Je"],
  647. "暂估价" : child.attrib["Zgj"], "类别" : child.attrib["Fyxlb"]})
  648. return result
  649. def processDes(dataframe, from_, end, level):
  650. result = []
  651. for i in range(from_, end):
  652. item = dataframe.iloc[i]
  653. fbcch = str(item['fbcch'])
  654. if fbcch == str(level):
  655. entry = {"id": str(item["ID"]),"key": str(item["ID"]), "value": str(item["ID"]), "label": str(item["zjbt"]), "title": str(item["zjbt"])}
  656. next = i + 1
  657. while next < end and str(dataframe.iloc[next]["fbcch"]) != str(level):
  658. next = next + 1
  659. entry["children"] = processDes(dataframe, i + 1, next, level + 1)
  660. result.append(entry)
  661. return result
  662. def processPbs(dataframe, from_, end, level):
  663. result = []
  664. for i in range(from_, end):
  665. item = dataframe.iloc[i]
  666. fbcch = str(item['fbcch'])
  667. if fbcch == str(level):
  668. entry = {"id": str(item["ID"]),"key": str(item["ID"]), "value": str(item["ID"]), "label": str(item["flmc"]),"title": str(item["flmc"]), "data": item["pblbh"]}
  669. next = i + 1
  670. while next < end and str(dataframe.iloc[next]["fbcch"]) != str(level):
  671. next = next + 1
  672. entry["children"] = processPbs(dataframe, i + 1, next, level + 1)
  673. result.append(entry)
  674. return result
  675. def processJxs(dataframe, from_, end, level):
  676. result = []
  677. for i in range(from_, end):
  678. item = dataframe.iloc[i]
  679. fbcch = str(item['fbcch'])
  680. if fbcch == str(level):
  681. entry = {"id": str(item["ID"]),"key": str(item["ID"]), "value": str(item["ID"]), "label": str(item["flmc"]),"title": str(item["flmc"]), "data": item["jxlbh"]}
  682. next = i + 1
  683. while next < end and str(dataframe.iloc[next]["fbcch"]) != str(level):
  684. next = next + 1
  685. entry["children"] = processJxs(dataframe, i + 1, next, level + 1)
  686. result.append(entry)
  687. return result
  688. def processCls(dataframe, from_, end, level):
  689. result = []
  690. for i in range(from_, end):
  691. item = dataframe.iloc[i]
  692. fbcch = str(item['fbcch'])
  693. if fbcch == str(level):
  694. entry = {"id": str(item["ID"]),"key": str(item["ID"]), "value": str(item["ID"]), "label": str(item["flmc"]),"title": str(item["flmc"]), "data": item["cllbh"].item() if type(item["cllbh"]) == int64 else item["cllbh"]}
  695. ##print(entry)
  696. next = i + 1
  697. while next < end and str(dataframe.iloc[next]["fbcch"]) != str(level):
  698. next = next + 1
  699. entry["children"] = processCls(dataframe, i + 1, next, level + 1)
  700. result.append(entry)
  701. return result
  702. def getCankao():
  703. tree = ET.parse('de/DeData_Fl.xml')
  704. root = tree.getroot()
  705. JSFF = None
  706. CsFl = None
  707. result = []
  708. for child in root:
  709. if child.tag == "JJFF":
  710. for grandchild in child:
  711. if grandchild.tag == 'JSFF':
  712. JSFF = grandchild
  713. for child in JSFF:
  714. if child.attrib['Markup'] == '1':
  715. for grandchild in child:
  716. if grandchild.tag == 'CsFl':
  717. CsFl = grandchild
  718. for child in CsFl:
  719. result.append({'工程类型': child.attrib['Gclx'], '名称': child.attrib['Mc'], '计算基础': child.attrib['Jsjc'],
  720. '参考费率': child.attrib['CkFl'], '地区': child.attrib['Dq'], '备注': child.attrib['Bz']})
  721. return result
  722. def getDes(value):
  723. if value == 10:
  724. shu = pd.read_csv("de/tj/JD_DingEShu.csv")
  725. elif value == 20:
  726. shu = pd.read_csv("de/sz/JD_DingEShu.csv")
  727. elif value == 30:
  728. shu = pd.read_csv("de/az/JD_DingEShu.csv")
  729. elif value == 40:
  730. shu = pd.read_csv("de/yl/JD_DingEShu.csv")
  731. elif value == 50:
  732. shu = pd.read_csv("de/xstj/JD_DingEShu.csv")
  733. else:
  734. shu = pd.read_csv("de/xsaz/JD_DingEShu.csv")
  735. length = len(shu)
  736. return processDes(shu, 1, length, 2)
  737. def getPbs(value):
  738. if value == 10:
  739. shu = pd.read_csv("de/tj/JD_PeiBiFLB.csv")
  740. elif value == 20:
  741. shu = pd.read_csv("de/tj/JD_PeiBiFLB.csv")
  742. elif value == 30:
  743. shu = pd.read_csv("de/tj/JD_PeiBiFLB.csv")
  744. else:
  745. return []
  746. length = len(shu)
  747. return processPbs(shu, 0, length, 1)
  748. def getJxs(value):
  749. if value == 10:
  750. shu = pd.read_csv("de/tj/JD_JiXieFLB.csv")
  751. elif value == 20:
  752. shu = pd.read_csv("de/tj/JD_JiXieFLB.csv")
  753. elif value == 30:
  754. shu = pd.read_csv("de/tj/JD_JiXieFLB.csv")
  755. else:
  756. return []
  757. length = len(shu)
  758. return processJxs(shu, 0, length, 1)
  759. def getCls(value):
  760. if value == 10:
  761. shu = pd.read_csv("de/tj/JD_CaiLiaoFLB.csv")
  762. elif value == 20:
  763. shu = pd.read_csv("de/sz/JD_CaiLiaoFLB.csv")
  764. elif value == 30:
  765. shu = pd.read_csv("de/az/JD_CaiLiaoFLB.csv")
  766. elif value == 40:
  767. shu = pd.read_csv("de/yl/JD_CaiLiaoFLB.csv")
  768. elif value == 50:
  769. shu = pd.read_csv("de/xstj/JD_CaiLiaoFLB.csv")
  770. elif value == 60:
  771. shu = pd.read_csv("de/xsaz/JD_CaiLiaoFLB.csv")
  772. else:
  773. return []
  774. length = len(shu)
  775. return processCls(shu, 0, length, 1)
  776. def read_singledexilie_azfy(debh):
  777. id = "None"
  778. if "-F1" in debh:
  779. id = "2076"
  780. elif "-F2" in debh:
  781. id = "2077"
  782. elif "-F3" in debh:
  783. id = "2078"
  784. elif "-F4" in debh:
  785. id = "2079"
  786. elif "-F5" in debh:
  787. if '4-F5' in debh:
  788. id = "2081"
  789. elif '5-F5' in debh:
  790. id = '2082'
  791. elif '7-F5' in debh:
  792. id = '2083'
  793. elif '9-F5' in debh:
  794. id = '2084'
  795. elif '10-F5' in debh:
  796. id = '2085'
  797. elif '11-F5' in debh:
  798. id = '2086'
  799. elif "-F6" in debh:
  800. id = "2087"
  801. r_debh = debh.split("!")[0]
  802. if len(debh.split("!")) == 1:
  803. return json.dumps({
  804. "reverse": id,
  805. "rgde": [],
  806. "jxde": [],
  807. "clde": [],
  808. "actual_zhuanye": 30,
  809. "bz_selected": {"BZBH": {}},
  810. "bz_selected2": {"BZBH": {}}
  811. }, ensure_ascii=False)
  812. gclmc = debh.split("!")[1]
  813. return json.dumps({
  814. "reverse": id,
  815. "DEBH": {"111": r_debh},
  816. "GCLMC": {"111": gclmc},
  817. "DW": {"111": '项'},
  818. "rgde": [],
  819. "jxde": [],
  820. "clde": [],
  821. "actual_zhuanye": 30,
  822. "bz_selected": {"BZBH": {}},
  823. "bz_selected2": {"BZBH": {}}
  824. }, ensure_ascii=False)
  825. def getDeXilie_azfy(value, id):
  826. if int(id) == 2075 or int(id) == 2080:
  827. return "{\"Unnamed: 0\":{},\"id\":{},\"DEBH\":{},\"GCLMC\":{},\"GCLSJDJ\":{},\"DW\":{},\"DeId\":{}}"
  828. if int(id) == 2076:
  829. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项", "项", "项", "项", "项", "项", "项"],
  830. 'DEBH': ['2-F1', '2-F1', '3-F1', '3-F1', '4-F1',
  831. '5-F1', '6-F1', '7-F1', '8-F1', '9-F1', '10-F1', '11-F1', '11-F1', '11-F1', '11-F1', '11-F1'],
  832. "GCLMC": ["第二册第1-5章(定额2-1~2-390)", "第二册第6章(定额2-391~2-9999)", "第三册静置设备制作(定额3-1~3-615)",
  833. "第三册除静置设备制作以外(定额3-616~3-9999)", "第四册",
  834. "第五册", "第六册", "第七册", "第八册", "第九册", "第十册",
  835. "第十一册刷油工程(定额11-51~11-329)",
  836. "第十一册防腐蚀工程(定额11-330~11-1689)", "第十一册绝热工程(定额11-1690~11-2327)", "第十一册除锈工程(定额11-1~11-50)刷油工程", "第十一册除锈工程(定额11-1~11-50)防腐蚀工程"],
  837. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  838. df = pd.DataFrame(data)
  839. return df.to_json(force_ascii=False)
  840. if int(id) == 2077:
  841. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项','项','项',
  842. '项','项','项','项','项','项','项','项','项','项',
  843. '项','项','项',
  844. '项','项', "项",'项','项','项','项', "项",'项', "项"],
  845. 'DEBH': ['1-F2', '1-F2','1-F2','1-F2','1-F2','1-F2','1-F2','1-F2','1-F2','1-F2','1-F2','1-F2',
  846. '4-F2', '5-F2', '5-F2', '5-F2','6-F2',
  847. '7-F2', '9-F2','9-F2','9-F2','9-F2', '10-F2','10-F2','10-F2','10-F2',
  848. '11-F2','11-F2','11-F2','11-F2', '11-F2','11-F2','11-F2' ],
  849. "GCLMC": ["第一册第1-6章(定额1-1~1-571)10-15m",
  850. "第一册第1-6章(定额1-1~1-571)15-20m",
  851. "第一册第1-6章(定额1-1~1-571)20-25m",
  852. "第一册第1-6章(定额1-1~1-571)25-30m",
  853. "第一册第1-6章(定额1-1~1-571)30-40m",
  854. "第一册第1-6章(定额1-1~1-571)40m以上",
  855. "第一册第8-14章(定额1-672~1-9999)10-15m",
  856. "第一册第8-14章(定额1-672~1-9999)15-20m",
  857. "第一册第8-14章(定额1-672~1-9999)20-25m",
  858. "第一册第8-14章(定额1-672~1-9999)25-30m",
  859. "第一册第8-14章(定额1-672~1-9999)30-40m",
  860. "第一册第8-14章(定额1-672~1-9999)40m以上",
  861. "第四册",
  862. "第五册5m以上到10m以内",
  863. "第五册10-20m",
  864. "第五册20m以上",
  865. "第六册", "第七册",
  866. "第九册5m以上到8m以内",
  867. "第九册8-12m",
  868. "第九册12-16m",
  869. "第九册16-20m",
  870. "第十册3.6-8m以内",
  871. "第十册8-12m以内",
  872. "第十册12-16m以内",
  873. "第十册16-20m",
  874. "第十一册6-20m",
  875. "第十一册20-30m",
  876. "第十一册30-40m",
  877. "第十一册40-50m",
  878. "第十一册50-60m",
  879. "第十一册60-70m",
  880. "第十一册80m以上",
  881. ],
  882. "GCLSJDJ": ["0", "0", '0', '0',"0", "0", "0", "0", "0", "0",
  883. "0", "0", '0', '0',"0", "0", "0", "0", "0", "0",
  884. "0","0", "0",
  885. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  886. df = pd.DataFrame(data)
  887. return df.to_json(force_ascii=False)
  888. if int(id) == 2078:
  889. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项", "项"],
  890. 'DEBH': ['1-F4', '1-F4', '2-F4', '3-F4', '4-F4',
  891. '5-F4', '6-F4', '7-F4', '8-F4', '9-F4', '11-F4'],
  892. "GCLMC": ["第一册第1-6章", "第一册第8-14章", "第二册",
  893. "第三册", "第四册",
  894. "第五册", "第六册", "第七册", "第八册", "第九册",
  895. "第十一册", ],
  896. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  897. df = pd.DataFrame(data)
  898. return df.to_json(force_ascii=False)
  899. if int(id) == 2079:
  900. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项", "项"],
  901. 'DEBH': ['1-F5', '1-F5', '2-F5', '3-F5', '4-F5',
  902. '5-F5', '6-F5', '7-F5', '8-F5', '9-F5', '11-F5'],
  903. "GCLMC": ["第一册第1-6章", "第一册第8-14章", "第二册",
  904. "第三册", "第四册",
  905. "第五册", "第六册", "第七册", "第八册", "第九册",
  906. "第十一册", ],
  907. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  908. df = pd.DataFrame(data)
  909. return df.to_json(force_ascii=False)
  910. if int(id) == 2081:
  911. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  912. "项", '项', '项', '项', '项', "项", "项", "项"],
  913. 'DEBH': ['4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3',
  914. '4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3'],
  915. "GCLMC": ["9层或30m以内",
  916. "12层或40m以内",
  917. "15层或50m以内",
  918. "18层或60m以内",
  919. "21层或70m以内",
  920. "24层或80m以内",
  921. "27层或90m以内",
  922. "30层或100m以内",
  923. "33层或110m以内",
  924. "36层或120m以内",
  925. "40层或130m以内",
  926. "42层或140m以内",
  927. "45层或150m以内",
  928. "48层或160m以内",
  929. "51层或170m以内",
  930. "54层或180m以内",
  931. "57层或190m以内",
  932. "60层或200m以内",
  933. ],
  934. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  935. "0", "0", "0", "0", "0", "0", "0", "0"]}
  936. df = pd.DataFrame(data)
  937. return df.to_json(force_ascii=False)
  938. if int(id) == 2082:
  939. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  940. "项", '项', '项', '项', '项', "项", "项", "项"],
  941. 'DEBH': ['5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3',
  942. '5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3'],
  943. "GCLMC": ["9层或30m以内",
  944. "12层或40m以内",
  945. "15层或50m以内",
  946. "18层或60m以内",
  947. "21层或70m以内",
  948. "24层或80m以内",
  949. "27层或90m以内",
  950. "30层或100m以内",
  951. "33层或110m以内",
  952. "36层或120m以内",
  953. "40层或130m以内",
  954. "42层或140m以内",
  955. "45层或150m以内",
  956. "48层或160m以内",
  957. "51层或170m以内",
  958. "54层或180m以内",
  959. "57层或190m以内",
  960. "60层或200m以内",
  961. ],
  962. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  963. "0", "0", "0", "0", "0", "0", "0", "0"]}
  964. df = pd.DataFrame(data)
  965. return df.to_json(force_ascii=False)
  966. if int(id) == 2083:
  967. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  968. "项", '项', '项', '项', '项', "项", "项", "项"],
  969. 'DEBH': ['7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3',
  970. '7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3'],
  971. "GCLMC": ["9层或30m以内",
  972. "12层或40m以内",
  973. "15层或50m以内",
  974. "18层或60m以内",
  975. "21层或70m以内",
  976. "24层或80m以内",
  977. "27层或90m以内",
  978. "30层或100m以内",
  979. "33层或110m以内",
  980. "36层或120m以内",
  981. "40层或130m以内",
  982. "42层或140m以内",
  983. "45层或150m以内",
  984. "48层或160m以内",
  985. "51层或170m以内",
  986. "54层或180m以内",
  987. "57层或190m以内",
  988. "60层或200m以内",
  989. ],
  990. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  991. "0", "0", "0", "0", "0", "0", "0", "0"]}
  992. df = pd.DataFrame(data)
  993. return df.to_json(force_ascii=False)
  994. if int(id) == 2084:
  995. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  996. "项", '项', '项', '项', '项', "项", "项", "项"],
  997. 'DEBH': ['9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3',
  998. '9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3'],
  999. "GCLMC": ["9层或30m以内",
  1000. "12层或40m以内",
  1001. "15层或50m以内",
  1002. "18层或60m以内",
  1003. "21层或70m以内",
  1004. "24层或80m以内",
  1005. "27层或90m以内",
  1006. "30层或100m以内",
  1007. "33层或110m以内",
  1008. "36层或120m以内",
  1009. "40层或130m以内",
  1010. "42层或140m以内",
  1011. "45层或150m以内",
  1012. "48层或160m以内",
  1013. "51层或170m以内",
  1014. "54层或180m以内",
  1015. "57层或190m以内",
  1016. "60层或200m以内",
  1017. ],
  1018. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1019. "0", "0", "0", "0", "0", "0", "0", "0"]}
  1020. df = pd.DataFrame(data)
  1021. return df.to_json(force_ascii=False)
  1022. if int(id) == 2085:
  1023. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1024. "项", '项', '项', '项', '项', "项", "项", "项"],
  1025. 'DEBH': ['10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3',
  1026. '10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3'],
  1027. "GCLMC": ["9层或30m以内",
  1028. "12层或40m以内",
  1029. "15层或50m以内",
  1030. "18层或60m以内",
  1031. "21层或70m以内",
  1032. "24层或80m以内",
  1033. "27层或90m以内",
  1034. "30层或100m以内",
  1035. "33层或110m以内",
  1036. "36层或120m以内",
  1037. "40层或130m以内",
  1038. "42层或140m以内",
  1039. "45层或150m以内",
  1040. "48层或160m以内",
  1041. "51层或170m以内",
  1042. "54层或180m以内",
  1043. "57层或190m以内",
  1044. "60层或200m以内",
  1045. ],
  1046. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1047. "0", "0", "0", "0", "0", "0", "0", "0"]}
  1048. df = pd.DataFrame(data)
  1049. return df.to_json(force_ascii=False)
  1050. if int(id) == 2086:
  1051. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1052. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1053. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1054. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1055. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1056. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1057. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1058. "项", '项'],
  1059. 'DEBH': ['11-F3', '11-F3',
  1060. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1061. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1062. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1063. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1064. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1065. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1066. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1067. ],
  1068. "GCLMC": [
  1069. "(按通风空调工程)9层或30m以内",
  1070. "(按通风空调工程)12层或40m以内",
  1071. "(按通风空调工程)15层或50m以内",
  1072. "(按通风空调工程)18层或60m以内",
  1073. "(按通风空调工程)21层或70m以内",
  1074. "(按通风空调工程)24层或80m以内",
  1075. "(按通风空调工程)27层或90m以内",
  1076. "(按通风空调工程)30层或100m以内",
  1077. "(按通风空调工程)33层或110m以内",
  1078. "(按通风空调工程)36层或120m以内",
  1079. "(按通风空调工程)40层或130m以内",
  1080. "(按通风空调工程)42层或140m以内",
  1081. "(按通风空调工程)45层或150m以内",
  1082. "(按通风空调工程)48层或160m以内",
  1083. "(按通风空调工程)51层或170m以内",
  1084. "(按通风空调工程)54层或180m以内",
  1085. "(按通风空调工程)57层或190m以内",
  1086. "(按通风空调工程)60层或200m以内",
  1087. ############################
  1088. "(按消防工程)9层或30m以内",
  1089. "(按消防工程)12层或40m以内",
  1090. "(按消防工程)15层或50m以内",
  1091. "(按消防工程)18层或60m以内",
  1092. "(按消防工程)21层或70m以内",
  1093. "(按消防工程)24层或80m以内",
  1094. "(按消防工程)27层或90m以内",
  1095. "(按消防工程)30层或100m以内",
  1096. "(按消防工程)33层或110m以内",
  1097. "(按消防工程)36层或120m以内",
  1098. "(按消防工程)40层或130m以内",
  1099. "(按消防工程)42层或140m以内",
  1100. "(按消防工程)45层或150m以内",
  1101. "(按消防工程)48层或160m以内",
  1102. "(按消防工程)51层或170m以内",
  1103. "(按消防工程)54层或180m以内",
  1104. "(按消防工程)57层或190m以内",
  1105. "(按消防工程)60层或200m以内",
  1106. ############################
  1107. "(按给排水、采暖工程)9层或30m以内",
  1108. "(按给排水、采暖工程)12层或40m以内",
  1109. "(按给排水、采暖工程)15层或50m以内",
  1110. "(按给排水、采暖工程)18层或60m以内",
  1111. "(按给排水、采暖工程)21层或70m以内",
  1112. "(按给排水、采暖工程)24层或80m以内",
  1113. "(按给排水、采暖工程)27层或90m以内",
  1114. "(按给排水、采暖工程)30层或100m以内",
  1115. "(按给排水、采暖工程)33层或110m以内",
  1116. "(按给排水、采暖工程)36层或120m以内",
  1117. "(按给排水、采暖工程)40层或130m以内",
  1118. "(按给排水、采暖工程)42层或140m以内",
  1119. "(按给排水、采暖工程)45层或150m以内",
  1120. "(按给排水、采暖工程)48层或160m以内",
  1121. "(按给排水、采暖工程)51层或170m以内",
  1122. "(按给排水、采暖工程)54层或180m以内",
  1123. "(按给排水、采暖工程)57层或190m以内",
  1124. "(按给排水、采暖工程)60层或200m以内",
  1125. ############################
  1126. "(按电气工程)9层或30m以内",
  1127. "(按电气工程)12层或40m以内",
  1128. "(按电气工程)15层或50m以内",
  1129. "(按电气工程)18层或60m以内",
  1130. "(按电气工程)21层或70m以内",
  1131. "(按电气工程)24层或80m以内",
  1132. "(按电气工程)27层或90m以内",
  1133. "(按电气工程)30层或100m以内",
  1134. "(按电气工程)33层或110m以内",
  1135. "(按电气工程)36层或120m以内",
  1136. "(按电气工程)40层或130m以内",
  1137. "(按电气工程)42层或140m以内",
  1138. "(按电气工程)45层或150m以内",
  1139. "(按电气工程)48层或160m以内",
  1140. "(按电气工程)51层或170m以内",
  1141. "(按电气工程)54层或180m以内",
  1142. "(按电气工程)57层或190m以内",
  1143. "(按电气工程)60层或200m以内",
  1144. ],
  1145. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1146. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1147. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1148. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1149. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1150. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1151. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1152. "0", "0" ]}
  1153. df = pd.DataFrame(data)
  1154. return df.to_json(force_ascii=False)
  1155. if int(id) == 2087:
  1156. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项"],
  1157. 'DEBH': ['1-F6', '3-F6', '4-F6', '7-F6', '8-F6',
  1158. '10-F6', '10-F6', '10-F6', '11-F6'],
  1159. "GCLMC": ["第一册 站内工艺系统",
  1160. "第三册 站内工艺系统", "第四册 站内工艺系统",
  1161. "第七册", "第八册 站内工艺系统",
  1162. "第十册供暖器具安装", "第十册空调水工程管道安装", "第十册空调水工程管道附件", "第十一册 站内工艺系统" ],
  1163. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  1164. df = pd.DataFrame(data)
  1165. return df.to_json(force_ascii=False)
  1166. def getDeXilie(value, id):
  1167. ##print(type(id))
  1168. if value == 10:
  1169. shu = pd.read_csv("de/tj/JD_DingEShu.csv")
  1170. elif value == 20:
  1171. shu = pd.read_csv("de/sz/JD_DingEShu.csv")
  1172. elif value == 30:
  1173. shu = pd.read_csv("de/az/JD_DingEShu.csv")
  1174. elif value == 40:
  1175. shu = pd.read_csv("de/yl/JD_DingEShu.csv")
  1176. elif value == 50:
  1177. shu = pd.read_csv("de/xstj/JD_DingEShu.csv")
  1178. else:
  1179. shu = pd.read_csv("de/xsaz/JD_DingEShu.csv")
  1180. hit = shu[shu["ID"]==int(id)]
  1181. ##print(hit)
  1182. if len(hit) == 0:
  1183. return []
  1184. hit0 = hit.iloc[0]
  1185. index = str(hit0['zjh'])
  1186. ##print("index=" + index)
  1187. if value == 10:
  1188. gj = pd.read_csv("de/tj/JD_DanWeiGJ.csv")
  1189. filtered = gj[gj["YSDELBH"]==int(index)]
  1190. elif value == 20:
  1191. gj = pd.read_csv("de/sz/JD_DanWeiGJ.csv")
  1192. filtered = gj[gj["YSDELBH"]==(index)]
  1193. elif value == 30:
  1194. gj = pd.read_csv("de/az/JD_DanWeiGJ.csv")
  1195. filtered = gj[gj["YSDELBH"]==(index)]
  1196. elif value == 40:
  1197. gj = pd.read_csv("de/yl/JD_DanWeiGJ.csv")
  1198. filtered = gj[gj["YSDELBH"]==int(index)]
  1199. elif value == 50:
  1200. gj = pd.read_csv("de/xstj/JD_DanWeiGJ.csv")
  1201. filtered = gj[gj["YSDELBH"]==int(index)]
  1202. else:
  1203. gj = pd.read_csv("de/xsaz/JD_DanWeiGJ.csv")
  1204. filtered = gj[gj["YSDELBH"]==int(index)]
  1205. filtered = filtered.drop(['BH1', 'BH2', "GCLCLF", "GCLCLF1", "GCLGG", "GCLGLF", "GCLJJ", "GCLJXF", "GCLLR", "GCLRGF", "GCLRGR", "GCPBHJ", "GLFFL", "LRFL", "PBBH", "PBBHM", "PBDJ", "PBSL", "THMC", "THSL", "dejb", "is_lock", "mcxz", "qfbz", "sptfl"], axis=1)
  1206. return filtered.to_json(force_ascii=False)
  1207. def getPbxl(name, zhuanye):
  1208. if name == "0":
  1209. if zhuanye == 10:
  1210. gj = pd.read_csv("de/tj/JD_PeiBi.csv")
  1211. elif zhuanye == 20:
  1212. gj = pd.read_csv("de/tj/JD_PeiBi.csv")
  1213. elif zhuanye == 30:
  1214. gj = pd.read_csv("de/tj/JD_PeiBi.csv")
  1215. elif zhuanye == 40:
  1216. gj = pd.read_csv("de/yl/JD_PeiBi.csv")
  1217. elif zhuanye == 50:
  1218. gj = pd.read_csv("de/xstj/JD_PeiBi.csv")
  1219. elif zhuanye == 60:
  1220. gj = pd.read_csv("de/xsaz/JD_PeiBi.csv")
  1221. return gj.to_json(force_ascii=False)
  1222. shu = pd.read_csv("de/tj/JD_PeiBiFLB.csv")
  1223. hit = shu[shu["ID"]==int(name)]
  1224. ##print(hit)
  1225. if len(hit) == 0:
  1226. return []
  1227. hit0 = hit.iloc[0]
  1228. index = str(hit0['pblbh'])
  1229. index_list = index.split(";")
  1230. gj = pd.read_csv("de/tj/JD_PeiBi.csv")
  1231. filtered = gj[gj["PBBH"].str.startswith(tuple(index_list))]
  1232. return filtered.to_json(force_ascii=False)
  1233. def getJxxl(name, zhuanye):
  1234. if name == "0":
  1235. if zhuanye == 10:
  1236. gj = pd.read_csv("de/tj/JD_JiXieK.csv")
  1237. elif zhuanye == 20:
  1238. gj = pd.read_csv("de/tj/JD_JiXieK.csv")
  1239. elif zhuanye == 30:
  1240. gj = pd.read_csv("de/tj/JD_JiXieK.csv")
  1241. elif zhuanye == 40:
  1242. gj = pd.read_csv("de/yl/JD_JiXieK.csv")
  1243. elif zhuanye == 50:
  1244. gj = pd.read_csv("de/xstj/JD_JiXieK.csv")
  1245. elif zhuanye == 60:
  1246. gj = pd.read_csv("de/xsaz/JD_JiXieK.csv")
  1247. return gj.to_json(force_ascii=False)
  1248. shu = pd.read_csv("de/tj/JD_JiXieFLB.csv")
  1249. hit = shu[shu["ID"]==int(name)]
  1250. ##print(hit)
  1251. if len(hit) == 0:
  1252. return []
  1253. hit0 = hit.iloc[0]
  1254. index = str(hit0['jxlbh'])
  1255. index_list = index.split(";")
  1256. gj = pd.read_csv("de/tj/JD_JiXieK.csv")
  1257. filtered = gj[gj["jxbh"].str.startswith(tuple(index_list))]
  1258. return filtered.to_json(force_ascii=False)
  1259. def getClxl(name, zhuanye):
  1260. if name == "0":
  1261. if zhuanye == 10:
  1262. gj = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  1263. elif zhuanye == 20:
  1264. gj = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  1265. elif zhuanye == 30:
  1266. gj = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  1267. elif zhuanye == 40:
  1268. gj = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1269. elif zhuanye == 50:
  1270. gj = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1271. elif zhuanye == 60:
  1272. gj = pd.read_csv("de/xsaz/JD_CaiLiaoK.csv")
  1273. return gj.to_json(force_ascii=False)
  1274. if zhuanye == 10:
  1275. shu = pd.read_csv("de/tj/JD_CaiLiaoFLB.csv")
  1276. if zhuanye == 20:
  1277. shu = pd.read_csv("de/sz/JD_CaiLiaoFLB.csv")
  1278. if zhuanye == 30:
  1279. shu = pd.read_csv("de/az/JD_CaiLiaoFLB.csv")
  1280. if zhuanye == 40:
  1281. shu = pd.read_csv("de/yl/JD_CaiLiaoFLB.csv", dtype={'cllbh': str})
  1282. if zhuanye == 50:
  1283. shu = pd.read_csv("de/xstj/JD_CaiLiaoFLB.csv", dtype={'cllbh': str})
  1284. if zhuanye == 60:
  1285. shu = pd.read_csv("de/xsaz/JD_CaiLiaoFLB.csv", dtype={'cllbh': str})
  1286. hit = shu[shu["ID"]==int(name)]
  1287. ##print(hit)
  1288. if len(hit) == 0:
  1289. return []
  1290. hit0 = hit.iloc[0]
  1291. index = str(hit0['cllbh'])
  1292. index_list = index.split(";")
  1293. if zhuanye == 10:
  1294. gj = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  1295. if zhuanye == 20:
  1296. gj = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  1297. if zhuanye == 30:
  1298. gj = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  1299. if zhuanye == 40:
  1300. gj = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1301. if zhuanye == 50:
  1302. gj = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1303. if zhuanye == 60:
  1304. gj = pd.read_csv("de/xsaz/JD_CaiLiaoK.csv")
  1305. ##print(index_list)
  1306. ##print(gj)
  1307. filtered = gj[gj["CLBH"].str.startswith(tuple(index_list))]
  1308. return filtered.to_json(force_ascii=False)
  1309. def getSingleDeXilie(zhuanye, debh):
  1310. if zhuanye == 10:
  1311. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_tj(debh)
  1312. if A1:
  1313. return A1, A2, A3, A4, A5, A6, A7, 10
  1314. else:
  1315. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_sz(debh)
  1316. return A1, A2, A3, A4,A5, A6, A7, 20
  1317. elif zhuanye == 20:##shizheng
  1318. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_sz(debh)
  1319. if A1:
  1320. return A1, A2, A3, A4, A5, A6, A7, 20
  1321. else:
  1322. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_tj(debh)
  1323. if A1:
  1324. return A1, A2, A3, A4, A5, A6, A7, 10
  1325. else:
  1326. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_az(debh)
  1327. return A1, A2, A3, A4, A5, A6, A7, 30
  1328. elif zhuanye == 30:##anzhuang
  1329. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_az(debh)
  1330. return A1, A2, A3, A4, A5, A6, A7, 30
  1331. elif zhuanye == 40:##yuanlin
  1332. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_yl(debh)
  1333. return A1, A2, A3, A4, A5, A6, A7, 40
  1334. elif zhuanye == 50: ## xiushan tujian
  1335. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_xstj(debh)
  1336. if A1:
  1337. return A1, A2, A3, A4, A5, A6, A7, 50
  1338. else:
  1339. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_tj(debh)
  1340. return A1, A2, A3, A4,A5, A6, A7, 10
  1341. else:
  1342. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_xsaz(debh)
  1343. if A1:
  1344. return A1, A2, A3, A4, A5, A6, A7, 60
  1345. else:
  1346. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_az(debh)
  1347. return A1, A2, A3, A4,A5, A6, A7, 30
  1348. def getSingleDeXilie_xsaz(debh):
  1349. id = None
  1350. bz_selected = []
  1351. bz_selected2 = []
  1352. if "附注" in debh:
  1353. position = debh.find("附注")
  1354. debh = debh[:position]
  1355. if "*" in debh:
  1356. position = debh.find("*")
  1357. debh = debh[:position]
  1358. if debh.endswith("换"):
  1359. debh = debh[:-1]
  1360. if "[" in debh:
  1361. position = debh.find("[")
  1362. debh = debh[:position-1]
  1363. gj = pd.read_csv("de/xsaz/JD_DanWeiGJ.csv")
  1364. filtered = gj[gj["DEBH"]==debh]
  1365. ##print(filtered)
  1366. if len(filtered) > 0:
  1367. index = (filtered.iloc[0]["YSDELBH"])
  1368. shu = pd.read_csv("de/xsaz/JD_DingEShu.csv")
  1369. hit = shu[shu["zjh"]==index]
  1370. if len(hit) > 0:
  1371. id = hit.iloc[0]["ID"]
  1372. beizhu = str(filtered.iloc[0]["BZBH"])
  1373. if 'nan' in beizhu:
  1374. pass
  1375. else:
  1376. beizhus = beizhu.split(";")
  1377. ##print(beizhus)
  1378. bzfile = pd.read_csv("de/xsaz/JD_BeiZhuZK.csv")
  1379. bzfile2 = pd.read_csv("de/xsaz/JD_BeiZhuFK.csv", dtype=str)
  1380. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  1381. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  1382. else:
  1383. return None, None, None, None, None, None, None
  1384. ####rengong
  1385. rgde = []
  1386. rg = pd.read_csv("de/xsaz/JD_GuJiaRG.csv")
  1387. filtered1 = rg[rg["DEBH"]==debh]
  1388. for i in range(len(filtered1)):
  1389. rgde_ = {}
  1390. gr = filtered1.iloc[i]["RGR"]##gongri
  1391. gf = filtered1.iloc[i]["RGF"]##gongfei
  1392. rcjID = filtered1.iloc[i]["RcjID"]
  1393. detail = pd.read_csv("de/xsaz/JD_CaiLiaoK.csv")
  1394. filtered2 = detail[detail["RcjID"]==rcjID]
  1395. if len(filtered2) > 0:
  1396. CLBH = filtered2.iloc[0]["CLBH"]
  1397. CLMC = filtered2.iloc[0]["CLMC"]
  1398. JLDW = filtered2.iloc[0]["JLDW"]
  1399. YSJG = filtered2.iloc[0]["YSJG"]
  1400. rgde_["CLBH"] = CLBH
  1401. rgde_["CLMC"] = CLMC
  1402. rgde_["JLDW"] = JLDW
  1403. rgde_["YSJG"] = YSJG.item()
  1404. rgde_["gr"] = gr.item()
  1405. rgde_["gf"] = gf.item()
  1406. rgde.append(rgde_)
  1407. ##print(rgde)
  1408. ####jixie
  1409. jxde = []
  1410. jx = pd.read_csv("de/xsaz/JD_GuJiaJX.csv")
  1411. filtered1 = jx[jx["DEBH"]==debh]
  1412. for i in range(len(filtered1)):
  1413. jxde_ = {}
  1414. sl = filtered1.iloc[i]["SL"]##shuliang
  1415. hj = filtered1.iloc[i]["HJ"]##hejia
  1416. rcjID = filtered1.iloc[i]["RcjID"]
  1417. detail = pd.read_csv("de/xsaz/JD_JiXieK.csv")
  1418. filtered2 = detail[detail["RcjID"]==rcjID]
  1419. if len(filtered2) > 0:
  1420. jxbh = filtered2.iloc[0]["jxbh"]
  1421. jxmc = filtered2.iloc[0]["jxmc"]
  1422. DW = filtered2.iloc[0]["DW"]
  1423. tbdj = filtered2.iloc[0]["tbdj"]
  1424. jxde_["jxbh"] = jxbh
  1425. jxde_["jxmc"] = jxmc
  1426. jxde_["DW"] = DW
  1427. jxde_["tbdj"] = tbdj.item()
  1428. jxde_["sl"] = sl.item()
  1429. jxde_["hj"] = hj.item()
  1430. jxde.append(jxde_)
  1431. ####cailiao
  1432. clde = []
  1433. cl = pd.read_csv("de/xsaz/JD_GuJiaCL.csv")
  1434. filtered1 = cl[cl["DEBH"]==debh]
  1435. for i in range(len(filtered1)):
  1436. clde_ = {}
  1437. SL = filtered1.iloc[i]["SL"]##shuliang
  1438. HJ = filtered1.iloc[i]["HJ"]##hejia
  1439. rcjID = filtered1.iloc[i]["RcjID"]
  1440. detail = pd.read_csv("de/xsaz/JD_CaiLiaoK.csv")
  1441. filtered2 = detail[detail["RcjID"]==rcjID]
  1442. detail_ = pd.read_csv("de/xsaz/JD_PeiBi.csv")
  1443. filtered2_ = detail_[detail_["RcjID"]==rcjID]
  1444. if len(filtered2) > 0 and len(filtered2_) == 0:
  1445. CLBH = filtered2.iloc[0]["CLBH"]
  1446. CLMC = filtered2.iloc[0]["CLMC"]
  1447. JLDW = filtered2.iloc[0]["JLDW"]
  1448. YSJG = filtered2.iloc[0]["YSJG"]
  1449. clde_["CLBH"] = CLBH
  1450. clde_["CLMC"] = CLMC
  1451. clde_["JLDW"] = JLDW
  1452. clde_["YSJG"] = YSJG.item()
  1453. clde_["SL"] = SL.item()
  1454. clde_["HJ"] = HJ.item()
  1455. clde.append(clde_)
  1456. elif len(filtered2) == 0 and len(filtered2_) > 0:
  1457. CLBH = filtered2_.iloc[0]["PBBH"]
  1458. CLMC = filtered2_.iloc[0]["PBMC"]
  1459. JLDW = filtered2_.iloc[0]["DW"]
  1460. YSJG = filtered2_.iloc[0]["PBDJ"]
  1461. clde_["CLBH"] = CLBH.item()
  1462. clde_["CLMC"] = CLMC
  1463. clde_["JLDW"] = JLDW
  1464. clde_["YSJG"] = YSJG.item()
  1465. clde_["SL"] = SL.item()
  1466. clde_["HJ"] = HJ.item()
  1467. clde.append(clde_)
  1468. elif len(filtered2) > 0 and len(filtered2_) > 0:
  1469. YSJG = filtered2.iloc[0]["YSJG"]
  1470. YSJG_ = filtered2_.iloc[0]["PBDJ"]
  1471. if float(HJ) < 0.00001:
  1472. if float(YSJG) < 0.00001:
  1473. CLBH = filtered2.iloc[0]["CLBH"]
  1474. CLMC = filtered2.iloc[0]["CLMC"]
  1475. JLDW = filtered2.iloc[0]["JLDW"]
  1476. YSJG = filtered2.iloc[0]["YSJG"]
  1477. clde_["CLBH"] = CLBH
  1478. clde_["CLMC"] = CLMC
  1479. clde_["JLDW"] = JLDW
  1480. clde_["YSJG"] = YSJG.item()
  1481. clde_["SL"] = SL.item()
  1482. clde_["HJ"] = HJ.item()
  1483. clde.append(clde_)
  1484. elif float(YSJG_) < 0.00001:
  1485. CLBH = filtered2_.iloc[0]["PBBH"]
  1486. CLMC = filtered2_.iloc[0]["PBMC"]
  1487. JLDW = filtered2_.iloc[0]["DW"]
  1488. YSJG = filtered2_.iloc[0]["PBDJ"]
  1489. clde_["CLBH"] = CLBH.item()
  1490. clde_["CLMC"] = CLMC
  1491. clde_["JLDW"] = JLDW
  1492. clde_["YSJG"] = YSJG.item()
  1493. clde_["SL"] = SL.item()
  1494. clde_["HJ"] = HJ.item()
  1495. clde.append(clde_)
  1496. else:
  1497. ratio = float(YSJG) / (float(HJ) / float(SL))
  1498. ratio_ = float(YSJG_) / (float(HJ) / float(SL))
  1499. if abs(ratio - 1) < abs(ratio_ -1):
  1500. CLBH = filtered2.iloc[0]["CLBH"]
  1501. CLMC = filtered2.iloc[0]["CLMC"]
  1502. JLDW = filtered2.iloc[0]["JLDW"]
  1503. YSJG = filtered2.iloc[0]["YSJG"]
  1504. clde_["CLBH"] = CLBH
  1505. clde_["CLMC"] = CLMC
  1506. clde_["JLDW"] = JLDW
  1507. clde_["YSJG"] = YSJG.item()
  1508. clde_["SL"] = SL.item()
  1509. clde_["HJ"] = HJ.item()
  1510. clde.append(clde_)
  1511. else:
  1512. CLBH = filtered2_.iloc[0]["PBBH"]
  1513. CLMC = filtered2_.iloc[0]["PBMC"]
  1514. JLDW = filtered2_.iloc[0]["DW"]
  1515. YSJG = filtered2_.iloc[0]["PBDJ"]
  1516. clde_["CLBH"] = CLBH.item()
  1517. clde_["CLMC"] = CLMC
  1518. clde_["JLDW"] = JLDW
  1519. clde_["YSJG"] = YSJG.item()
  1520. clde_["SL"] = SL.item()
  1521. clde_["HJ"] = HJ.item()
  1522. clde.append(clde_)
  1523. filtered = filtered.drop(['BH1', 'BH2', "GCLCLF", "GCLCLF1", "GCLGG", "GCLGLF", "GCLJJ", "GCLJXF", "GCLLR", "GCLRGF", "GCLRGR", "GCLSJDJ", "GCPBHJ", "GLFFL", "LRFL", "PBBH", "PBBHM", "PBDJ", "PBSL", "THMC", "THSL", "dejb", "is_lock", "mcxz", "qfbz", "sptfl"], axis=1)
  1524. return filtered.to_json(force_ascii=False), id, rgde, jxde, clde, bz_selected.to_json(force_ascii=False) if len(bz_selected) > 0 else None, bz_selected2.to_json(force_ascii=False) if len(bz_selected2) > 0 else None
  1525. def getSingleDeXilie_xstj(debh):
  1526. id = None
  1527. bz_selected = []
  1528. bz_selected2 = []
  1529. additional = []
  1530. if "附注" in debh:
  1531. position = debh.find("附注")
  1532. debh = debh[:position]
  1533. if "*" in debh:
  1534. position = debh.find("*")
  1535. debh = debh[:position]
  1536. if debh.endswith("换"):
  1537. debh = debh[:-1]
  1538. if "[" in debh:
  1539. position = debh.find("[")
  1540. debh = debh[:position-1]
  1541. gj = pd.read_csv("de/xstj/JD_DanWeiGJ.csv")
  1542. filtered = gj[gj["DEBH"]==debh]
  1543. ##print(filtered)
  1544. if len(filtered) > 0:
  1545. index = (filtered.iloc[0]["YSDELBH"])
  1546. shu = pd.read_csv("de/xstj/JD_DingEShu.csv")
  1547. hit = shu[shu["zjh"]==index]
  1548. if len(hit) > 0:
  1549. id = hit.iloc[0]["ID"]
  1550. beizhu = str(filtered.iloc[0]["BZBH"])
  1551. if 'nan' in beizhu:
  1552. pass
  1553. else:
  1554. beizhus = beizhu.split(";")
  1555. ##print(beizhus)
  1556. bzfile = pd.read_csv("de/xstj/JD_BeiZhuZK.csv")
  1557. bzfile2 = pd.read_csv("de/xstj/JD_BeiZhuFK.csv", dtype=str)
  1558. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  1559. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  1560. bz_selected2 = bz_selected2.astype({'BH': str})
  1561. additional = bz_selected2['BH'].tolist()
  1562. additional = [entry for entry in additional if not entry in ['000000', '000001', 'J00000', '100000', '800101', '015103', '066121', '066501', '066503', '070101', '070303', '070902', '071121', '241503', '8021', '80210']]
  1563. else:
  1564. return None, None, None, None, None, None, None
  1565. ####rengong
  1566. rgde = []
  1567. rg = pd.read_csv("de/xstj/JD_GuJiaRG.csv")
  1568. filtered1 = rg[rg["DEBH"]==debh]
  1569. for i in range(len(filtered1)):
  1570. rgde_ = {}
  1571. gr = filtered1.iloc[i]["RGR"]##gongri
  1572. gf = filtered1.iloc[i]["RGF"]##gongfei
  1573. rcjID = filtered1.iloc[i]["RcjID"]
  1574. detail = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1575. filtered2 = detail[detail["RcjID"]==rcjID]
  1576. if len(filtered2) > 0:
  1577. CLBH = filtered2.iloc[0]["CLBH"]
  1578. CLMC = filtered2.iloc[0]["CLMC"]
  1579. JLDW = filtered2.iloc[0]["JLDW"]
  1580. YSJG = filtered2.iloc[0]["YSJG"]
  1581. rgde_["CLBH"] = CLBH
  1582. rgde_["CLMC"] = CLMC
  1583. rgde_["JLDW"] = JLDW
  1584. rgde_["YSJG"] = YSJG.item()
  1585. rgde_["gr"] = gr.item()
  1586. rgde_["gf"] = gf.item()
  1587. if CLBH in additional:
  1588. additional.remove(CLBH)
  1589. rgde.append(rgde_)
  1590. detail = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1591. detail = detail[detail['RcjLb'].isin([1, '1'])]
  1592. added = detail[detail['CLBH'].isin(additional)]
  1593. for _, entry in added.iterrows():
  1594. rgde_ = {}
  1595. CLBH = entry["CLBH"]
  1596. CLMC = entry["CLMC"]
  1597. JLDW = entry["JLDW"]
  1598. YSJG = entry["YSJG"]
  1599. rgde_["CLBH"] = CLBH
  1600. rgde_["CLMC"] = CLMC
  1601. rgde_["JLDW"] = JLDW
  1602. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1603. rgde_["gr"] = 0
  1604. rgde_["gf"] = 0
  1605. rgde.append(rgde_)
  1606. ####jixie
  1607. jxde = []
  1608. jx = pd.read_csv("de/xstj/JD_GuJiaJX.csv")
  1609. filtered1 = jx[jx["DEBH"]==debh]
  1610. for i in range(len(filtered1)):
  1611. jxde_ = {}
  1612. sl = filtered1.iloc[i]["SL"]##shuliang
  1613. hj = filtered1.iloc[i]["HJ"]##hejia
  1614. rcjID = filtered1.iloc[i]["RcjID"]
  1615. detail = pd.read_csv("de/xstj/JD_JiXieK.csv")
  1616. filtered2 = detail[detail["RcjID"]==rcjID]
  1617. if len(filtered2) > 0:
  1618. jxbh = filtered2.iloc[0]["jxbh"]
  1619. jxmc = filtered2.iloc[0]["jxmc"]
  1620. DW = filtered2.iloc[0]["DW"]
  1621. tbdj = filtered2.iloc[0]["tbdj"]
  1622. jxde_["jxbh"] = jxbh
  1623. jxde_["jxmc"] = jxmc
  1624. jxde_["DW"] = DW
  1625. jxde_["tbdj"] = tbdj.item()
  1626. jxde_["sl"] = sl.item()
  1627. jxde_["hj"] = hj.item()
  1628. if jxbh in additional:
  1629. additional.remove(jxbh)
  1630. jxde.append(jxde_)
  1631. detail = pd.read_csv("de/xstj/JD_JiXieK.csv")
  1632. added = detail[detail['jxbh'].isin(additional)]
  1633. for _, entry in added.iterrows():
  1634. jxde_ = {}
  1635. jxbh = entry["jxbh"]
  1636. jxmc = entry["jxmc"]
  1637. DW = entry["DW"]
  1638. tbdj = entry["tbdj"]
  1639. jxde_["jxbh"] = jxbh
  1640. jxde_["jxmc"] = jxmc
  1641. jxde_["DW"] = DW
  1642. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  1643. jxde_["sl"] = 0
  1644. jxde_["hj"] = 0
  1645. jxde.append(jxde_)
  1646. ####cailiao
  1647. clde = []
  1648. cl = pd.read_csv("de/xstj/JD_GuJiaCL.csv")
  1649. filtered1 = cl[cl["DEBH"]==debh]
  1650. for i in range(len(filtered1)):
  1651. clde_ = {}
  1652. SL = filtered1.iloc[i]["SL"]##shuliang
  1653. HJ = filtered1.iloc[i]["HJ"]##hejia
  1654. rcjID = filtered1.iloc[i]["RcjID"]
  1655. detail = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1656. filtered2 = detail[detail["RcjID"]==rcjID]
  1657. detail_ = pd.read_csv("de/xstj/JD_PeiBi.csv")
  1658. filtered2_ = detail_[detail_["RcjID"]==rcjID]
  1659. if len(filtered2) > 0 and len(filtered2_) == 0:
  1660. CLBH = filtered2.iloc[0]["CLBH"]
  1661. CLMC = filtered2.iloc[0]["CLMC"]
  1662. JLDW = filtered2.iloc[0]["JLDW"]
  1663. YSJG = filtered2.iloc[0]["YSJG"]
  1664. clde_["CLBH"] = CLBH
  1665. clde_["CLMC"] = CLMC
  1666. clde_["JLDW"] = JLDW
  1667. clde_["YSJG"] = YSJG.item()
  1668. clde_["SL"] = SL.item()
  1669. clde_["HJ"] = HJ.item()
  1670. clde.append(clde_)
  1671. elif len(filtered2) == 0 and len(filtered2_) > 0:
  1672. CLBH = filtered2_.iloc[0]["PBBH"]
  1673. CLMC = filtered2_.iloc[0]["PBMC"]
  1674. JLDW = filtered2_.iloc[0]["DW"]
  1675. YSJG = filtered2_.iloc[0]["PBDJ"]
  1676. clde_["CLBH"] = CLBH.item()
  1677. clde_["CLMC"] = CLMC
  1678. clde_["JLDW"] = JLDW
  1679. clde_["YSJG"] = YSJG.item()
  1680. clde_["SL"] = SL.item()
  1681. clde_["HJ"] = HJ.item()
  1682. clde.append(clde_)
  1683. elif len(filtered2) > 0 and len(filtered2_) > 0:
  1684. YSJG = filtered2.iloc[0]["YSJG"]
  1685. YSJG_ = filtered2_.iloc[0]["PBDJ"]
  1686. if float(HJ) < 0.00001:
  1687. if float(YSJG) < 0.00001:
  1688. CLBH = filtered2.iloc[0]["CLBH"]
  1689. CLMC = filtered2.iloc[0]["CLMC"]
  1690. JLDW = filtered2.iloc[0]["JLDW"]
  1691. YSJG = filtered2.iloc[0]["YSJG"]
  1692. clde_["CLBH"] = CLBH
  1693. clde_["CLMC"] = CLMC
  1694. clde_["JLDW"] = JLDW
  1695. clde_["YSJG"] = YSJG.item()
  1696. clde_["SL"] = SL.item()
  1697. clde_["HJ"] = HJ.item()
  1698. clde.append(clde_)
  1699. elif float(YSJG_) < 0.00001:
  1700. CLBH = filtered2_.iloc[0]["PBBH"]
  1701. CLMC = filtered2_.iloc[0]["PBMC"]
  1702. JLDW = filtered2_.iloc[0]["DW"]
  1703. YSJG = filtered2_.iloc[0]["PBDJ"]
  1704. clde_["CLBH"] = CLBH.item()
  1705. clde_["CLMC"] = CLMC
  1706. clde_["JLDW"] = JLDW
  1707. clde_["YSJG"] = YSJG.item()
  1708. clde_["SL"] = SL.item()
  1709. clde_["HJ"] = HJ.item()
  1710. clde.append(clde_)
  1711. else:
  1712. ratio = float(YSJG) / (float(HJ) / float(SL))
  1713. ratio_ = float(YSJG_) / (float(HJ) / float(SL))
  1714. if abs(ratio - 1) < abs(ratio_ -1):
  1715. CLBH = filtered2.iloc[0]["CLBH"]
  1716. CLMC = filtered2.iloc[0]["CLMC"]
  1717. JLDW = filtered2.iloc[0]["JLDW"]
  1718. YSJG = filtered2.iloc[0]["YSJG"]
  1719. clde_["CLBH"] = CLBH
  1720. clde_["CLMC"] = CLMC
  1721. clde_["JLDW"] = JLDW
  1722. clde_["YSJG"] = YSJG.item()
  1723. clde_["SL"] = SL.item()
  1724. clde_["HJ"] = HJ.item()
  1725. clde.append(clde_)
  1726. else:
  1727. CLBH = filtered2_.iloc[0]["PBBH"]
  1728. CLMC = filtered2_.iloc[0]["PBMC"]
  1729. JLDW = filtered2_.iloc[0]["DW"]
  1730. YSJG = filtered2_.iloc[0]["PBDJ"]
  1731. clde_["CLBH"] = CLBH.item()
  1732. clde_["CLMC"] = CLMC
  1733. clde_["JLDW"] = JLDW
  1734. clde_["YSJG"] = YSJG.item()
  1735. clde_["SL"] = SL.item()
  1736. clde_["HJ"] = HJ.item()
  1737. clde.append(clde_)
  1738. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  1739. additional.remove(clde_['CLBH'])
  1740. detail = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1741. detail = detail[detail['RcjLb'].isin([2, '2'])]
  1742. added = detail[detail['CLBH'].isin(additional)]
  1743. added = added.drop_duplicates(subset=['CLBH'])
  1744. for _, entry in added.iterrows():
  1745. clde_ = {}
  1746. CLBH = entry["CLBH"]
  1747. CLMC = entry["CLMC"]
  1748. JLDW = entry["JLDW"]
  1749. YSJG = entry["YSJG"]
  1750. clde_["CLBH"] = CLBH
  1751. clde_["CLMC"] = CLMC
  1752. clde_["JLDW"] = JLDW
  1753. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1754. clde_["SL"] = 0
  1755. clde_["HJ"] = 0
  1756. clde.append(clde_)
  1757. detail = pd.read_csv("de/xstj/JD_PeiBi.csv")
  1758. added = detail[detail['PBBH'].isin(additional)]
  1759. for _, entry in added.iterrows():
  1760. clde_ = {}
  1761. CLBH = entry["PBBH"]
  1762. CLMC = entry["PBMC"]
  1763. JLDW = entry["DW"]
  1764. YSJG = entry["PBDJ"]
  1765. clde_["CLBH"] = CLBH
  1766. clde_["CLMC"] = CLMC
  1767. clde_["JLDW"] = JLDW
  1768. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1769. clde_["SL"] = 0
  1770. clde_["HJ"] = 0
  1771. clde.append(clde_)
  1772. filtered = filtered.drop(['BH1', 'BH2', "GCLCLF", "GCLCLF1", "GCLGG", "GCLGLF", "GCLJJ", "GCLJXF", "GCLLR", "GCLRGF", "GCLRGR", "GCLSJDJ", "GCPBHJ", "GLFFL", "LRFL", "PBBH", "PBBHM", "PBDJ", "PBSL", "THMC", "THSL", "dejb", "is_lock", "mcxz", "qfbz", "sptfl"], axis=1)
  1773. return filtered.to_json(force_ascii=False), id, rgde, jxde, clde, bz_selected.to_json(force_ascii=False) if len(bz_selected) > 0 else None, bz_selected2.to_json(force_ascii=False) if len(bz_selected2) > 0 else None
  1774. def getSingleDeXilie_yl(debh):
  1775. id = None
  1776. bz_selected = []
  1777. bz_selected2 = []
  1778. additional = []
  1779. if "附注" in debh:
  1780. position = debh.find("附注")
  1781. debh = debh[:position]
  1782. if "*" in debh:
  1783. position = debh.find("*")
  1784. debh = debh[:position]
  1785. if debh.endswith("换"):
  1786. debh = debh[:-1]
  1787. if "[" in debh:
  1788. position = debh.find("[")
  1789. debh = debh[:position-1]
  1790. gj = pd.read_csv("de/yl/JD_DanWeiGJ.csv")
  1791. filtered = gj[gj["DEBH"]==debh]
  1792. ##print(filtered)
  1793. if len(filtered) > 0:
  1794. index = (filtered.iloc[0]["YSDELBH"])
  1795. shu = pd.read_csv("de/yl/JD_DingEShu.csv")
  1796. hit = shu[shu["zjh"]==index]
  1797. if len(hit) > 0:
  1798. id = hit.iloc[0]["ID"]
  1799. beizhu = str(filtered.iloc[0]["BZBH"])
  1800. if 'nan' in beizhu:
  1801. pass
  1802. else:
  1803. beizhus = beizhu.split(";")
  1804. ##print(beizhus)
  1805. bzfile = pd.read_csv("de/yl/JD_BeiZhuZK.csv")
  1806. bzfile2 = pd.read_csv("de/yl/JD_BeiZhuFK.csv", dtype=str)
  1807. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  1808. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  1809. bz_selected2 = bz_selected2.astype({'BH': str})
  1810. additional = bz_selected2['BH'].tolist()
  1811. additional = [entry for entry in additional if not entry in ['000000', '000001', 'J00000', '100000', '800101', '015103', '066121', '066501', '066503', '070101', '070303', '070902', '071121', '241503', '8021', '80210']]
  1812. else:
  1813. return None, None, None, None, None, None, None
  1814. ####rengong
  1815. rgde = []
  1816. rg = pd.read_csv("de/yl/JD_GuJiaRG.csv")
  1817. filtered1 = rg[rg["DEBH"]==debh]
  1818. for i in range(len(filtered1)):
  1819. rgde_ = {}
  1820. gr = filtered1.iloc[i]["RGR"]##gongri
  1821. gf = filtered1.iloc[i]["RGF"]##gongfei
  1822. rcjID = filtered1.iloc[i]["RcjID"]
  1823. detail = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1824. filtered2 = detail[detail["RcjID"]==rcjID]
  1825. if len(filtered2) > 0:
  1826. CLBH = filtered2.iloc[0]["CLBH"]
  1827. CLMC = filtered2.iloc[0]["CLMC"]
  1828. JLDW = filtered2.iloc[0]["JLDW"]
  1829. YSJG = filtered2.iloc[0]["YSJG"]
  1830. rgde_["CLBH"] = CLBH
  1831. rgde_["CLMC"] = CLMC
  1832. rgde_["JLDW"] = JLDW
  1833. rgde_["YSJG"] = YSJG.item()
  1834. rgde_["gr"] = gr.item()
  1835. rgde_["gf"] = gf.item()
  1836. if CLBH in additional:
  1837. additional.remove(CLBH)
  1838. rgde.append(rgde_)
  1839. detail = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1840. detail = detail[detail['RcjLb'].isin([1, '1'])]
  1841. added = detail[detail['CLBH'].isin(additional)]
  1842. for _, entry in added.iterrows():
  1843. rgde_ = {}
  1844. CLBH = entry["CLBH"]
  1845. CLMC = entry["CLMC"]
  1846. JLDW = entry["JLDW"]
  1847. YSJG = entry["YSJG"]
  1848. rgde_["CLBH"] = CLBH
  1849. rgde_["CLMC"] = CLMC
  1850. rgde_["JLDW"] = JLDW
  1851. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1852. rgde_["gr"] = 0
  1853. rgde_["gf"] = 0
  1854. rgde.append(rgde_)
  1855. ####jixie
  1856. jxde = []
  1857. jx = pd.read_csv("de/yl/JD_GuJiaJX.csv")
  1858. filtered1 = jx[jx["DEBH"]==debh]
  1859. for i in range(len(filtered1)):
  1860. jxde_ = {}
  1861. sl = filtered1.iloc[i]["SL"]##shuliang
  1862. hj = filtered1.iloc[i]["HJ"]##hejia
  1863. rcjID = filtered1.iloc[i]["RcjID"]
  1864. detail = pd.read_csv("de/yl/JD_JiXieK.csv")
  1865. filtered2 = detail[detail["RcjID"]==rcjID]
  1866. if len(filtered2) > 0:
  1867. jxbh = filtered2.iloc[0]["jxbh"]
  1868. jxmc = filtered2.iloc[0]["jxmc"]
  1869. DW = filtered2.iloc[0]["DW"]
  1870. tbdj = filtered2.iloc[0]["tbdj"]
  1871. jxde_["jxbh"] = jxbh
  1872. jxde_["jxmc"] = jxmc
  1873. jxde_["DW"] = DW
  1874. jxde_["tbdj"] = tbdj.item()
  1875. jxde_["sl"] = sl.item()
  1876. jxde_["hj"] = hj.item()
  1877. if jxbh in additional:
  1878. additional.remove(jxbh)
  1879. jxde.append(jxde_)
  1880. detail = pd.read_csv("de/yl/JD_JiXieK.csv")
  1881. added = detail[detail['jxbh'].isin(additional)]
  1882. for _, entry in added.iterrows():
  1883. jxde_ = {}
  1884. jxbh = entry["jxbh"]
  1885. jxmc = entry["jxmc"]
  1886. DW = entry["DW"]
  1887. tbdj = entry["tbdj"]
  1888. jxde_["jxbh"] = jxbh
  1889. jxde_["jxmc"] = jxmc
  1890. jxde_["DW"] = DW
  1891. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  1892. jxde_["sl"] = 0
  1893. jxde_["hj"] = 0
  1894. jxde.append(jxde_)
  1895. ####cailiao
  1896. clde = []
  1897. cl = pd.read_csv("de/yl/JD_GuJiaCL.csv")
  1898. filtered1 = cl[cl["DEBH"]==debh]
  1899. for i in range(len(filtered1)):
  1900. clde_ = {}
  1901. SL = filtered1.iloc[i]["SL"]##shuliang
  1902. HJ = filtered1.iloc[i]["HJ"]##hejia
  1903. rcjID = filtered1.iloc[i]["RcjID"]
  1904. detail = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1905. filtered2 = detail[detail["RcjID"]==rcjID]
  1906. if len(filtered2) > 0:
  1907. CLBH = filtered2.iloc[0]["CLBH"]
  1908. CLMC = filtered2.iloc[0]["CLMC"]
  1909. JLDW = filtered2.iloc[0]["JLDW"]
  1910. YSJG = filtered2.iloc[0]["YSJG"]
  1911. clde_["CLBH"] = CLBH
  1912. clde_["CLMC"] = CLMC
  1913. clde_["JLDW"] = JLDW
  1914. clde_["YSJG"] = YSJG.item()
  1915. clde_["SL"] = SL.item()
  1916. clde_["HJ"] = HJ.item()
  1917. clde.append(clde_)
  1918. else:
  1919. detail = pd.read_csv("de/yl/JD_PeiBi.csv")
  1920. filtered2 = detail[detail["RcjID"]==rcjID]
  1921. if len(filtered2) > 0:
  1922. CLBH = filtered2.iloc[0]["PBBH"]
  1923. CLMC = filtered2.iloc[0]["PBMC"]
  1924. JLDW = filtered2.iloc[0]["DW"]
  1925. YSJG = filtered2.iloc[0]["PBDJ"]
  1926. clde_["CLBH"] = CLBH.item()
  1927. clde_["CLMC"] = CLMC
  1928. clde_["JLDW"] = JLDW
  1929. clde_["YSJG"] = YSJG.item()
  1930. clde_["SL"] = SL.item()
  1931. clde_["HJ"] = HJ.item()
  1932. clde.append(clde_)
  1933. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  1934. additional.remove(clde_['CLBH'])
  1935. detail = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1936. detail = detail[detail['RcjLb'].isin([2, '2'])]
  1937. added = detail[detail['CLBH'].isin(additional)]
  1938. for _, entry in added.iterrows():
  1939. clde_ = {}
  1940. CLBH = entry["CLBH"]
  1941. CLMC = entry["CLMC"]
  1942. JLDW = entry["JLDW"]
  1943. YSJG = entry["YSJG"]
  1944. clde_["CLBH"] = CLBH
  1945. clde_["CLMC"] = CLMC
  1946. clde_["JLDW"] = JLDW
  1947. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1948. clde_["SL"] = 0
  1949. clde_["HJ"] = 0
  1950. clde.append(clde_)
  1951. detail = pd.read_csv("de/yl/JD_PeiBi.csv")
  1952. added = detail[detail['PBBH'].isin(additional)]
  1953. for _, entry in added.iterrows():
  1954. clde_ = {}
  1955. CLBH = entry["PBBH"]
  1956. CLMC = entry["PBMC"]
  1957. JLDW = entry["DW"]
  1958. YSJG = entry["PBDJ"]
  1959. clde_["CLBH"] = CLBH
  1960. clde_["CLMC"] = CLMC
  1961. clde_["JLDW"] = JLDW
  1962. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1963. clde_["SL"] = 0
  1964. clde_["HJ"] = 0
  1965. clde.append(clde_)
  1966. filtered = filtered.drop(['BH1', 'BH2', "GCLCLF", "GCLCLF1", "GCLGG", "GCLGLF", "GCLJJ", "GCLJXF", "GCLLR", "GCLRGF", "GCLRGR", "GCLSJDJ", "GCPBHJ", "GLFFL", "LRFL", "PBBH", "PBBHM", "PBDJ", "PBSL", "THMC", "THSL", "dejb", "is_lock", "mcxz", "qfbz", "sptfl"], axis=1)
  1967. return filtered.to_json(force_ascii=False), id, rgde, jxde, clde, bz_selected.to_json(force_ascii=False) if len(bz_selected) > 0 else None, bz_selected2.to_json(force_ascii=False) if len(bz_selected2) > 0 else None
  1968. def getSingleDeXilie_az(debh):
  1969. id = None
  1970. bz_selected = []
  1971. bz_selected2 = []
  1972. additional = []
  1973. if "附注" in debh:
  1974. position = debh.find("附注")
  1975. debh = debh[:position]
  1976. if "*" in debh:
  1977. position = debh.find("*")
  1978. debh = debh[:position]
  1979. if debh.endswith("换"):
  1980. debh = debh[:-1]
  1981. if "[" in debh:
  1982. position = debh.find("[")
  1983. debh = debh[:position-1]
  1984. gj = pd.read_csv("de/az/JD_DanWeiGJ.csv")
  1985. filtered = gj[gj["DEBH"]==debh]
  1986. ##print(filtered)
  1987. if len(filtered) > 0:
  1988. index = (filtered.iloc[0]["YSDELBH"])
  1989. shu = pd.read_csv("de/az/JD_DingEShu.csv")
  1990. hit = shu[shu["zjh"]==index]
  1991. if len(hit) > 0:
  1992. id = hit.iloc[0]["ID"]
  1993. beizhu = str(filtered.iloc[0]["BZBH"])
  1994. if 'nan' in beizhu:
  1995. pass
  1996. else:
  1997. beizhus = beizhu.split(";")
  1998. ##print(beizhus)
  1999. bzfile = pd.read_csv("de/az/JD_BeiZhuZK.csv")
  2000. bzfile2 = pd.read_csv("de/az/JD_BeiZhuFK.csv", dtype=str)
  2001. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  2002. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  2003. bz_selected2 = bz_selected2.astype({'BH': str})
  2004. additional = bz_selected2['BH'].tolist()
  2005. additional = [entry for entry in additional if not entry in ['000000', '000001', 'J00000', '100000', '800101', '015103', '066121', '066501', '066503', '070101', '070303', '070902', '071121', '241503', '8021', '80210']]
  2006. else:
  2007. return None, None, None, None, None, None, None
  2008. ####rengong
  2009. rgde = []
  2010. rg = pd.read_csv("de/az/JD_GuJiaRG.csv")
  2011. filtered1 = rg[rg["DEBH"]==debh]
  2012. for i in range(len(filtered1)):
  2013. rgde_ = {}
  2014. gr = filtered1.iloc[i]["RGR"]##gongri
  2015. gf = filtered1.iloc[i]["RGF"]##gongfei
  2016. rcjID = filtered1.iloc[i]["RcjID"]
  2017. detail = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  2018. filtered2 = detail[detail["RcjID"]==rcjID]
  2019. if len(filtered2) > 0:
  2020. CLBH = filtered2.iloc[0]["CLBH"]
  2021. CLMC = filtered2.iloc[0]["CLMC"]
  2022. JLDW = filtered2.iloc[0]["JLDW"]
  2023. YSJG = filtered2.iloc[0]["YSJG"]
  2024. rgde_["CLBH"] = CLBH.item() if type(CLBH) == int64 else CLBH
  2025. rgde_["CLMC"] = CLMC
  2026. rgde_["JLDW"] = JLDW
  2027. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2028. rgde_["gr"] = gr.item() if type(gr) == float64 else gr
  2029. rgde_["gf"] = gf.item() if type(gf) == float64 else gf
  2030. if CLBH in additional:
  2031. additional.remove(CLBH)
  2032. rgde.append(rgde_)
  2033. detail = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  2034. detail = detail[detail['RcjLb'].isin([1, '1'])]
  2035. added = detail[detail['CLBH'].isin(additional)]
  2036. for _, entry in added.iterrows():
  2037. rgde_ = {}
  2038. CLBH = entry["CLBH"]
  2039. CLMC = entry["CLMC"]
  2040. JLDW = entry["JLDW"]
  2041. YSJG = entry["YSJG"]
  2042. rgde_["CLBH"] = CLBH
  2043. rgde_["CLMC"] = CLMC
  2044. rgde_["JLDW"] = JLDW
  2045. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2046. rgde_["gr"] = 0
  2047. rgde_["gf"] = 0
  2048. rgde.append(rgde_)
  2049. ####jixie
  2050. jxde = []
  2051. jx = pd.read_csv("de/az/JD_GuJiaJX.csv")
  2052. filtered1 = jx[jx["DEBH"]==debh]
  2053. for i in range(len(filtered1)):
  2054. jxde_ = {}
  2055. sl = filtered1.iloc[i]["SL"]##shuliang
  2056. hj = filtered1.iloc[i]["HJ"]##hejia
  2057. rcjID = filtered1.iloc[i]["RcjID"]
  2058. detail = pd.read_csv("de/az/JD_JiXieK.csv")
  2059. filtered2 = detail[detail["RcjID"]==rcjID]
  2060. if len(filtered2) > 0:
  2061. jxbh = filtered2.iloc[0]["jxbh"]
  2062. jxmc = filtered2.iloc[0]["jxmc"]
  2063. DW = filtered2.iloc[0]["DW"]
  2064. tbdj = filtered2.iloc[0]["tbdj"]
  2065. jxde_["jxbh"] = jxbh
  2066. jxde_["jxmc"] = jxmc
  2067. jxde_["DW"] = DW
  2068. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2069. jxde_["sl"] = sl.item() if type(sl) == float64 else sl
  2070. jxde_["hj"] = hj.item() if type(hj) == float64 else hj
  2071. if jxbh in additional:
  2072. additional.remove(jxbh)
  2073. jxde.append(jxde_)
  2074. detail = pd.read_csv("de/az/JD_JiXieK.csv")
  2075. added = detail[detail['jxbh'].isin(additional)]
  2076. for _, entry in added.iterrows():
  2077. jxde_ = {}
  2078. jxbh = entry["jxbh"]
  2079. jxmc = entry["jxmc"]
  2080. DW = entry["DW"]
  2081. tbdj = entry["tbdj"]
  2082. jxde_["jxbh"] = jxbh
  2083. jxde_["jxmc"] = jxmc
  2084. jxde_["DW"] = DW
  2085. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2086. jxde_["sl"] = 0
  2087. jxde_["hj"] = 0
  2088. jxde.append(jxde_)
  2089. ####cailiao
  2090. clde = []
  2091. cl = pd.read_csv("de/az/JD_GuJiaCL.csv")
  2092. filtered1 = cl[cl["DEBH"]==debh]
  2093. for i in range(len(filtered1)):
  2094. clde_ = {}
  2095. SL = filtered1.iloc[i]["SL"]##shuliang
  2096. HJ = filtered1.iloc[i]["HJ"]##hejia
  2097. rcjID = filtered1.iloc[i]["RcjID"]
  2098. detail = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  2099. filtered2 = detail[detail["RcjID"]==rcjID]
  2100. if len(filtered2) > 0:
  2101. CLBH = filtered2.iloc[0]["CLBH"]
  2102. CLMC = filtered2.iloc[0]["CLMC"]
  2103. JLDW = filtered2.iloc[0]["JLDW"]
  2104. YSJG = filtered2.iloc[0]["YSJG"]
  2105. clde_["CLBH"] = CLBH.item() if type(CLBH) == int64 else CLBH
  2106. clde_["CLMC"] = CLMC
  2107. clde_["JLDW"] = JLDW
  2108. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2109. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2110. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2111. clde.append(clde_)
  2112. else:
  2113. detail = pd.read_csv("de/az/JD_PeiBi.csv")
  2114. filtered2 = detail[detail["RcjID"]==rcjID]
  2115. if len(filtered2) > 0:
  2116. CLBH = filtered2.iloc[0]["PBBH"]
  2117. CLMC = filtered2.iloc[0]["PBMC"]
  2118. JLDW = filtered2.iloc[0]["DW"]
  2119. YSJG = filtered2.iloc[0]["PBDJ"]
  2120. clde_["CLBH"] = CLBH.item() if type(CLBH) == int64 else CLBH
  2121. clde_["CLMC"] = CLMC
  2122. clde_["JLDW"] = JLDW
  2123. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2124. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2125. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2126. clde.append(clde_)
  2127. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  2128. additional.remove(clde_['CLBH'])
  2129. detail = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  2130. detail = detail[detail['RcjLb'].isin([2, '2'])]
  2131. added = detail[detail['CLBH'].isin(additional)]
  2132. added = added.drop_duplicates(subset=['CLBH'])
  2133. for _, entry in added.iterrows():
  2134. clde_ = {}
  2135. CLBH = entry["CLBH"]
  2136. CLMC = entry["CLMC"]
  2137. JLDW = entry["JLDW"]
  2138. YSJG = entry["YSJG"]
  2139. clde_["CLBH"] = CLBH
  2140. clde_["CLMC"] = CLMC
  2141. clde_["JLDW"] = JLDW
  2142. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2143. clde_["SL"] = 0
  2144. clde_["HJ"] = 0
  2145. clde.append(clde_)
  2146. detail = pd.read_csv("de/az/JD_PeiBi.csv")
  2147. added = detail[detail['PBBH'].isin(additional)]
  2148. for _, entry in added.iterrows():
  2149. clde_ = {}
  2150. CLBH = entry["PBBH"]
  2151. CLMC = entry["PBMC"]
  2152. JLDW = entry["DW"]
  2153. YSJG = entry["PBDJ"]
  2154. clde_["CLBH"] = CLBH
  2155. clde_["CLMC"] = CLMC
  2156. clde_["JLDW"] = JLDW
  2157. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2158. clde_["SL"] = 0
  2159. clde_["HJ"] = 0
  2160. clde.append(clde_)
  2161. filtered = filtered.drop(['BH1', 'BH2', "GCLCLF", "GCLCLF1", "GCLGG", "GCLGLF", "GCLJJ", "GCLJXF", "GCLLR", "GCLRGF", "GCLRGR", "GCLSJDJ", "GCPBHJ", "GLFFL", "LRFL", "PBBH", "PBBHM", "PBDJ", "PBSL", "THMC", "THSL", "dejb", "is_lock", "mcxz", "qfbz", "sptfl"], axis=1)
  2162. ##print(filtered)
  2163. return filtered.to_json(force_ascii=False), id, rgde, jxde, clde, bz_selected.to_json(force_ascii=False) if len(bz_selected) > 0 else None, bz_selected2.to_json(force_ascii=False) if len(bz_selected2) > 0 else None
  2164. def getSingleDeXilie_sz(debh):
  2165. id = None
  2166. bz_selected = []
  2167. bz_selected2 = []
  2168. additional = []
  2169. if "附注" in debh:
  2170. position = debh.find("附注")
  2171. debh = debh[:position]
  2172. if "*" in debh:
  2173. position = debh.find("*")
  2174. debh = debh[:position]
  2175. if debh.endswith("换"):
  2176. debh = debh[:-1]
  2177. if "[" in debh:
  2178. position = debh.find("[")
  2179. debh = debh[:position-1]
  2180. gj = pd.read_csv("de/sz/JD_DanWeiGJ.csv")
  2181. filtered = gj[gj["DEBH"]==debh]
  2182. ##print(filtered)
  2183. if len(filtered) > 0:
  2184. index = (filtered.iloc[0]["YSDELBH"])
  2185. shu = pd.read_csv("de/sz/JD_DingEShu.csv")
  2186. hit = shu[shu["zjh"]==index]
  2187. if len(hit) > 0:
  2188. id = hit.iloc[0]["ID"]
  2189. beizhu = str(filtered.iloc[0]["BZBH"])
  2190. if 'nan' in beizhu:
  2191. pass
  2192. else:
  2193. beizhus = beizhu.split(";")
  2194. ##print(beizhus)
  2195. bzfile = pd.read_csv("de/sz/JD_BeiZhuZK.csv")
  2196. bzfile2 = pd.read_csv("de/sz/JD_BeiZhuFK.csv", dtype=str)
  2197. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  2198. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  2199. bz_selected2 = bz_selected2.astype({'BH': str})
  2200. additional = bz_selected2['BH'].tolist()
  2201. additional = [entry for entry in additional if not entry in ['000000', '000001', 'J00000', '100000', '800101', '015103', '066121', '066501', '066503', '070101', '070303', '070902', '071121', '241503', '8021', '80210']]
  2202. else:
  2203. return None, None, None, None, None, None, None
  2204. ####rengong
  2205. rgde = []
  2206. rg = pd.read_csv("de/sz/JD_GuJiaRG.csv")
  2207. filtered1 = rg[rg["DEBH"]==debh]
  2208. for i in range(len(filtered1)):
  2209. rgde_ = {}
  2210. gr = filtered1.iloc[i]["RGR"]##gongri
  2211. gf = filtered1.iloc[i]["RGF"]##gongfei
  2212. rcjID = filtered1.iloc[i]["RcjID"]
  2213. detail = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  2214. filtered2 = detail[detail["RcjID"]==rcjID]
  2215. if len(filtered2) > 0:
  2216. CLBH = filtered2.iloc[0]["CLBH"]
  2217. CLMC = filtered2.iloc[0]["CLMC"]
  2218. JLDW = filtered2.iloc[0]["JLDW"]
  2219. YSJG = filtered2.iloc[0]["YSJG"]
  2220. rgde_["CLBH"] = CLBH
  2221. rgde_["CLMC"] = CLMC
  2222. rgde_["JLDW"] = JLDW
  2223. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2224. rgde_["gr"] = gr.item() if type(gr) == float64 else gr
  2225. rgde_["gf"] = gf.item() if type(gf) == float64 else gf
  2226. if CLBH in additional:
  2227. additional.remove(CLBH)
  2228. rgde.append(rgde_)
  2229. detail = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  2230. detail = detail[detail['RcjLb'].isin([1, '1'])]
  2231. added = detail[detail['CLBH'].isin(additional)]
  2232. for _, entry in added.iterrows():
  2233. rgde_ = {}
  2234. CLBH = entry["CLBH"]
  2235. CLMC = entry["CLMC"]
  2236. JLDW = entry["JLDW"]
  2237. YSJG = entry["YSJG"]
  2238. rgde_["CLBH"] = CLBH
  2239. rgde_["CLMC"] = CLMC
  2240. rgde_["JLDW"] = JLDW
  2241. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2242. rgde_["gr"] = 0
  2243. rgde_["gf"] = 0
  2244. rgde.append(rgde_)
  2245. ####jixie
  2246. jxde = []
  2247. jx = pd.read_csv("de/sz/JD_GuJiaJX.csv")
  2248. filtered1 = jx[jx["DEBH"]==debh]
  2249. for i in range(len(filtered1)):
  2250. jxde_ = {}
  2251. sl = filtered1.iloc[i]["SL"]##shuliang
  2252. hj = filtered1.iloc[i]["HJ"]##hejia
  2253. rcjID = filtered1.iloc[i]["RcjID"]
  2254. detail = pd.read_csv("de/sz/JD_JiXieK.csv")
  2255. filtered2 = detail[detail["RcjID"]==rcjID]
  2256. if len(filtered2) > 0:
  2257. jxbh = filtered2.iloc[0]["jxbh"]
  2258. jxmc = filtered2.iloc[0]["jxmc"]
  2259. DW = filtered2.iloc[0]["DW"]
  2260. tbdj = filtered2.iloc[0]["tbdj"]
  2261. jxde_["jxbh"] = jxbh
  2262. jxde_["jxmc"] = jxmc
  2263. jxde_["DW"] = DW
  2264. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2265. jxde_["sl"] = sl.item() if type(sl) == float64 else sl
  2266. jxde_["hj"] = hj.item() if type(hj) == float64 else hj
  2267. if jxbh in additional:
  2268. additional.remove(jxbh)
  2269. jxde.append(jxde_)
  2270. detail = pd.read_csv("de/sz/JD_JiXieK.csv")
  2271. added = detail[detail['jxbh'].isin(additional)]
  2272. for _, entry in added.iterrows():
  2273. jxde_ = {}
  2274. jxbh = entry["jxbh"]
  2275. jxmc = entry["jxmc"]
  2276. DW = entry["DW"]
  2277. tbdj = entry["tbdj"]
  2278. jxde_["jxbh"] = jxbh
  2279. jxde_["jxmc"] = jxmc
  2280. jxde_["DW"] = DW
  2281. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2282. jxde_["sl"] = 0
  2283. jxde_["hj"] = 0
  2284. jxde.append(jxde_)
  2285. ####cailiao
  2286. clde = []
  2287. cl = pd.read_csv("de/sz/JD_GuJiaCL.csv")
  2288. filtered1 = cl[cl["DEBH"]==debh]
  2289. for i in range(len(filtered1)):
  2290. clde_ = {}
  2291. SL = filtered1.iloc[i]["SL"]##shuliang
  2292. HJ = filtered1.iloc[i]["HJ"]##hejia
  2293. rcjID = filtered1.iloc[i]["RcjID"]
  2294. detail = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  2295. filtered2 = detail[detail["RcjID"]==rcjID]
  2296. detail_ = pd.read_csv("de/sz/JD_PeiBi.csv")
  2297. filtered2_ = detail_[detail_["RcjID"]==rcjID]
  2298. if len(filtered2) > 0 and len(filtered2_) == 0:
  2299. CLBH = filtered2.iloc[0]["CLBH"]
  2300. CLMC = filtered2.iloc[0]["CLMC"]
  2301. JLDW = filtered2.iloc[0]["JLDW"]
  2302. YSJG = filtered2.iloc[0]["YSJG"]
  2303. clde_["CLBH"] = CLBH.item() if type(CLBH) == int64 else CLBH
  2304. clde_["CLMC"] = CLMC
  2305. clde_["JLDW"] = JLDW
  2306. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2307. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2308. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2309. clde.append(clde_)
  2310. elif len(filtered2) == 0 and len(filtered2_) > 0:
  2311. CLBH = filtered2_.iloc[0]["PBBH"]
  2312. CLMC = filtered2_.iloc[0]["PBMC"]
  2313. JLDW = filtered2_.iloc[0]["DW"]
  2314. YSJG = filtered2_.iloc[0]["PBDJ"]
  2315. clde_["CLBH"] = CLBH.item() if type(CLBH) == int64 else CLBH
  2316. clde_["CLMC"] = CLMC
  2317. clde_["JLDW"] = JLDW
  2318. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2319. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2320. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2321. clde.append(clde_)
  2322. elif len(filtered2) > 0 and len(filtered2_) > 0:
  2323. YSJG = filtered2.iloc[0]["YSJG"]
  2324. YSJG_ = filtered2_.iloc[0]["PBDJ"]
  2325. ##print(debh)
  2326. if float(HJ) < 0.00001:
  2327. if float(YSJG) < 0.00001:
  2328. CLBH = filtered2.iloc[0]["CLBH"]
  2329. CLMC = filtered2.iloc[0]["CLMC"]
  2330. JLDW = filtered2.iloc[0]["JLDW"]
  2331. YSJG = filtered2.iloc[0]["YSJG"]
  2332. clde_["CLBH"] = CLBH.item() if type(CLBH) == int64 else CLBH
  2333. clde_["CLMC"] = CLMC
  2334. clde_["JLDW"] = JLDW
  2335. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2336. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2337. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2338. clde.append(clde_)
  2339. elif float(YSJG_) < 0.00001:
  2340. CLBH = filtered2_.iloc[0]["PBBH"]
  2341. CLMC = filtered2_.iloc[0]["PBMC"]
  2342. JLDW = filtered2_.iloc[0]["DW"]
  2343. YSJG = filtered2_.iloc[0]["PBDJ"]
  2344. clde_["CLBH"] = CLBH.item() if type(CLBH) == int64 else CLBH
  2345. clde_["CLMC"] = CLMC
  2346. clde_["JLDW"] = JLDW
  2347. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2348. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2349. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2350. clde.append(clde_)
  2351. else:
  2352. ratio = float(YSJG) / (float(HJ) / float(SL))
  2353. ratio_ = float(YSJG_) / (float(HJ) / float(SL))
  2354. if abs(ratio - 1) < abs(ratio_ - 1):
  2355. CLBH = filtered2.iloc[0]["CLBH"]
  2356. CLMC = filtered2.iloc[0]["CLMC"]
  2357. JLDW = filtered2.iloc[0]["JLDW"]
  2358. YSJG = filtered2.iloc[0]["YSJG"]
  2359. clde_["CLBH"] = CLBH.item() if type(CLBH) == int64 else CLBH
  2360. clde_["CLMC"] = CLMC
  2361. clde_["JLDW"] = JLDW
  2362. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2363. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2364. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2365. clde.append(clde_)
  2366. else:
  2367. CLBH = filtered2_.iloc[0]["PBBH"]
  2368. CLMC = filtered2_.iloc[0]["PBMC"]
  2369. JLDW = filtered2_.iloc[0]["DW"]
  2370. YSJG = filtered2_.iloc[0]["PBDJ"]
  2371. clde_["CLBH"] = CLBH.item() if type(CLBH) == int64 else CLBH
  2372. clde_["CLMC"] = CLMC
  2373. clde_["JLDW"] = JLDW
  2374. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2375. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2376. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2377. clde.append(clde_)
  2378. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  2379. additional.remove(clde_['CLBH'])
  2380. detail = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  2381. detail = detail[detail['RcjLb'].isin([2, '2'])]
  2382. added = detail[detail['CLBH'].isin(additional)]
  2383. for _, entry in added.iterrows():
  2384. clde_ = {}
  2385. CLBH = entry["CLBH"]
  2386. CLMC = entry["CLMC"]
  2387. JLDW = entry["JLDW"]
  2388. YSJG = entry["YSJG"]
  2389. clde_["CLBH"] = CLBH
  2390. clde_["CLMC"] = CLMC
  2391. clde_["JLDW"] = JLDW
  2392. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2393. clde_["SL"] = 0
  2394. clde_["HJ"] = 0
  2395. clde.append(clde_)
  2396. detail = pd.read_csv("de/sz/JD_PeiBi.csv")
  2397. added = detail[detail['PBBH'].isin(additional)]
  2398. for _, entry in added.iterrows():
  2399. clde_ = {}
  2400. CLBH = entry["PBBH"]
  2401. CLMC = entry["PBMC"]
  2402. JLDW = entry["DW"]
  2403. YSJG = entry["PBDJ"]
  2404. clde_["CLBH"] = CLBH
  2405. clde_["CLMC"] = CLMC
  2406. clde_["JLDW"] = JLDW
  2407. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2408. clde_["SL"] = 0
  2409. clde_["HJ"] = 0
  2410. clde.append(clde_)
  2411. filtered = filtered.drop(['BH1', 'BH2', "GCLCLF", "GCLCLF1", "GCLGG", "GCLGLF", "GCLJJ", "GCLJXF", "GCLLR", "GCLRGF", "GCLRGR", "GCLSJDJ", "GCPBHJ", "GLFFL", "LRFL", "PBBH", "PBBHM", "PBDJ", "PBSL", "THMC", "THSL", "dejb", "is_lock", "mcxz", "qfbz", "sptfl"], axis=1)
  2412. return filtered.to_json(force_ascii=False), id, rgde, jxde, clde, bz_selected.to_json(force_ascii=False) if len(bz_selected) > 0 else None, bz_selected2.to_json(force_ascii=False) if len(bz_selected2) > 0 else None
  2413. def getSingleDeXilie_tj(debh):
  2414. id = None
  2415. bz_selected = []
  2416. bz_selected2 = []
  2417. additional = []
  2418. if "附注" in debh:
  2419. position = debh.find("附注")
  2420. debh = debh[:position]
  2421. if "*" in debh:
  2422. position = debh.find("*")
  2423. debh = debh[:position]
  2424. if debh.endswith("换"):
  2425. debh = debh[:-1]
  2426. if "[" in debh:
  2427. position = debh.find("[")
  2428. debh = debh[:position-1]
  2429. gj = pd.read_csv("de/tj/JD_DanWeiGJ.csv")
  2430. filtered = gj[gj["DEBH"]==debh]
  2431. ##print(filtered)
  2432. if len(filtered) > 0:
  2433. index = int(filtered.iloc[0]["YSDELBH"])
  2434. shu = pd.read_csv("de/tj/JD_DingEShu.csv")
  2435. hit = shu[shu["zjh"]==index]
  2436. if len(hit) > 0:
  2437. id = hit.iloc[0]["ID"]
  2438. beizhu = str(filtered.iloc[0]["BZBH"])
  2439. if 'nan' in beizhu:
  2440. pass
  2441. else:
  2442. beizhus = beizhu.split(";")
  2443. ##print(beizhus)
  2444. bzfile = pd.read_csv("de/tj/JD_BeiZhuZK.csv")
  2445. bzfile2 = pd.read_csv("de/tj/JD_BeiZhuFK.csv", dtype=str)
  2446. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  2447. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  2448. bz_selected2 = bz_selected2.astype({'BH': str})
  2449. additional = bz_selected2['BH'].tolist()
  2450. additional = [entry for entry in additional if not entry in ['000000', '000001', 'J00000', '100000', '800101', '015103', '066121', '066501', '066503', '070101', '070303', '070902', '071121', '241503', '8021', '80210']]
  2451. else:
  2452. return None, None, None, None, None, None, None
  2453. ####rengong
  2454. rgde = []
  2455. rg = pd.read_csv("de/tj/JD_GuJiaRG.csv")
  2456. filtered1 = rg[rg["DEBH"]==debh]
  2457. for i in range(len(filtered1)):
  2458. rgde_ = {}
  2459. gr = filtered1.iloc[i]["RGR"]##gongri
  2460. gf = filtered1.iloc[i]["RGF"]##gongfei
  2461. rcjID = filtered1.iloc[i]["RcjID"]
  2462. detail = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  2463. filtered2 = detail[detail["RcjID"]==rcjID]
  2464. if len(filtered2) > 0:
  2465. CLBH = filtered2.iloc[0]["CLBH"]
  2466. CLMC = filtered2.iloc[0]["CLMC"]
  2467. JLDW = filtered2.iloc[0]["JLDW"]
  2468. YSJG = filtered2.iloc[0]["YSJG"]
  2469. rgde_["CLBH"] = CLBH
  2470. rgde_["CLMC"] = CLMC
  2471. rgde_["JLDW"] = JLDW
  2472. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2473. rgde_["gr"] = gr.item() if type(gr) == float64 else gr
  2474. rgde_["gf"] = gf.item() if type(gf) == float64 else gf
  2475. if CLBH in additional:
  2476. additional.remove(CLBH)
  2477. rgde.append(rgde_)
  2478. detail = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  2479. detail = detail[detail['RcjLb'].isin([1, '1'])]
  2480. added = detail[detail['CLBH'].isin(additional)]
  2481. for _, entry in added.iterrows():
  2482. rgde_ = {}
  2483. CLBH = entry["CLBH"]
  2484. CLMC = entry["CLMC"]
  2485. JLDW = entry["JLDW"]
  2486. YSJG = entry["YSJG"]
  2487. rgde_["CLBH"] = CLBH
  2488. rgde_["CLMC"] = CLMC
  2489. rgde_["JLDW"] = JLDW
  2490. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2491. rgde_["gr"] = 0
  2492. rgde_["gf"] = 0
  2493. rgde.append(rgde_)
  2494. ####jixie
  2495. jxde = []
  2496. jx = pd.read_csv("de/tj/JD_GuJiaJX.csv")
  2497. filtered1 = jx[jx["DEBH"]==debh]
  2498. for i in range(len(filtered1)):
  2499. jxde_ = {}
  2500. sl = filtered1.iloc[i]["SL"]##shuliang
  2501. hj = filtered1.iloc[i]["HJ"]##hejia
  2502. rcjID = filtered1.iloc[i]["RcjID"]
  2503. detail = pd.read_csv("de/tj/JD_JiXieK.csv")
  2504. filtered2 = detail[detail["RcjID"]==rcjID]
  2505. if len(filtered2) > 0:
  2506. jxbh = filtered2.iloc[0]["jxbh"]
  2507. jxmc = filtered2.iloc[0]["jxmc"]
  2508. DW = filtered2.iloc[0]["DW"]
  2509. tbdj = filtered2.iloc[0]["tbdj"]
  2510. jxde_["jxbh"] = jxbh
  2511. jxde_["jxmc"] = jxmc
  2512. jxde_["DW"] = DW
  2513. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2514. jxde_["sl"] = sl.item() if type(sl) == float64 else sl
  2515. jxde_["hj"] = hj.item() if type(hj) == float64 else hj
  2516. if jxbh in additional:
  2517. additional.remove(jxbh)
  2518. jxde.append(jxde_)
  2519. detail = pd.read_csv("de/tj/JD_JiXieK.csv")
  2520. added = detail[detail['jxbh'].isin(additional)]
  2521. for _, entry in added.iterrows():
  2522. jxde_ = {}
  2523. jxbh = entry["jxbh"]
  2524. jxmc = entry["jxmc"]
  2525. DW = entry["DW"]
  2526. tbdj = entry["tbdj"]
  2527. jxde_["jxbh"] = jxbh
  2528. jxde_["jxmc"] = jxmc
  2529. jxde_["DW"] = DW
  2530. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2531. jxde_["sl"] = 0
  2532. jxde_["hj"] = 0
  2533. jxde.append(jxde_)
  2534. clde = []
  2535. cl = pd.read_csv("de/tj/JD_GuJiaCL.csv")
  2536. filtered1 = cl[cl["DEBH"]==debh]
  2537. for i in range(len(filtered1)):
  2538. clde_ = {}
  2539. SL = filtered1.iloc[i]["SL"]##shuliang
  2540. HJ = filtered1.iloc[i]["HJ"]##hejia
  2541. rcjID = filtered1.iloc[i]["RcjID"]
  2542. detail = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  2543. filtered2 = detail[detail["RcjID"]==rcjID]
  2544. detail_ = pd.read_csv("de/tj/JD_PeiBi.csv")
  2545. filtered2_ = detail_[detail_["RcjID"]==rcjID]
  2546. if len(filtered2) > 0 and len(filtered2_) == 0:
  2547. CLBH = filtered2.iloc[0]["CLBH"]
  2548. CLMC = filtered2.iloc[0]["CLMC"]
  2549. JLDW = filtered2.iloc[0]["JLDW"]
  2550. YSJG = filtered2.iloc[0]["YSJG"]
  2551. clde_["CLBH"] = CLBH
  2552. clde_["CLMC"] = CLMC
  2553. clde_["JLDW"] = JLDW
  2554. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2555. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2556. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2557. clde.append(clde_)
  2558. elif len(filtered2) == 0 and len(filtered2_) > 0:
  2559. CLBH = filtered2_.iloc[0]["PBBH"]
  2560. CLMC = filtered2_.iloc[0]["PBMC"]
  2561. JLDW = filtered2_.iloc[0]["DW"]
  2562. YSJG = filtered2_.iloc[0]["PBDJ"]
  2563. clde_["CLBH"] = CLBH
  2564. clde_["CLMC"] = CLMC
  2565. clde_["JLDW"] = JLDW
  2566. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2567. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2568. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2569. clde.append(clde_)
  2570. elif len(filtered2) > 0 and len(filtered2_) > 0:
  2571. YSJG = filtered2.iloc[0]["YSJG"]
  2572. YSJG_ = filtered2_.iloc[0]["PBDJ"]
  2573. if float(HJ) < 0.00001:
  2574. if float(YSJG) < 0.00001:
  2575. CLBH = filtered2.iloc[0]["CLBH"]
  2576. CLMC = filtered2.iloc[0]["CLMC"]
  2577. JLDW = filtered2.iloc[0]["JLDW"]
  2578. YSJG = filtered2.iloc[0]["YSJG"]
  2579. clde_["CLBH"] = CLBH
  2580. clde_["CLMC"] = CLMC
  2581. clde_["JLDW"] = JLDW
  2582. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2583. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2584. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2585. clde.append(clde_)
  2586. elif float(YSJG_) < 0.00001:
  2587. CLBH = filtered2_.iloc[0]["PBBH"]
  2588. CLMC = filtered2_.iloc[0]["PBMC"]
  2589. JLDW = filtered2_.iloc[0]["DW"]
  2590. YSJG = filtered2_.iloc[0]["PBDJ"]
  2591. clde_["CLBH"] = CLBH
  2592. clde_["CLMC"] = CLMC
  2593. clde_["JLDW"] = JLDW
  2594. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2595. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2596. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2597. clde.append(clde_)
  2598. else:
  2599. ratio = float(YSJG) / (float(HJ) / float(SL))
  2600. ratio_ = float(YSJG_) / (float(HJ) / float(SL))
  2601. if abs(ratio - 1) < abs(ratio_ - 1):
  2602. CLBH = filtered2.iloc[0]["CLBH"]
  2603. CLMC = filtered2.iloc[0]["CLMC"]
  2604. JLDW = filtered2.iloc[0]["JLDW"]
  2605. YSJG = filtered2.iloc[0]["YSJG"]
  2606. clde_["CLBH"] = CLBH
  2607. clde_["CLMC"] = CLMC
  2608. clde_["JLDW"] = JLDW
  2609. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2610. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2611. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2612. clde.append(clde_)
  2613. else:
  2614. CLBH = filtered2_.iloc[0]["PBBH"]
  2615. CLMC = filtered2_.iloc[0]["PBMC"]
  2616. JLDW = filtered2_.iloc[0]["DW"]
  2617. YSJG = filtered2_.iloc[0]["PBDJ"]
  2618. clde_["CLBH"] = CLBH
  2619. clde_["CLMC"] = CLMC
  2620. clde_["JLDW"] = JLDW
  2621. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2622. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2623. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2624. clde.append(clde_)
  2625. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  2626. additional.remove(clde_['CLBH'])
  2627. detail = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  2628. detail = detail[detail['RcjLb'].isin([2, '2'])]
  2629. added = detail[detail['CLBH'].isin(additional)]
  2630. added = added.drop_duplicates(subset=['CLBH'])
  2631. for _, entry in added.iterrows():
  2632. clde_ = {}
  2633. CLBH = entry["CLBH"]
  2634. CLMC = entry["CLMC"]
  2635. JLDW = entry["JLDW"]
  2636. YSJG = entry["YSJG"]
  2637. clde_["CLBH"] = CLBH
  2638. clde_["CLMC"] = CLMC
  2639. clde_["JLDW"] = JLDW
  2640. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2641. clde_["SL"] = 0
  2642. clde_["HJ"] = 0
  2643. clde.append(clde_)
  2644. detail = pd.read_csv("de/tj/JD_PeiBi.csv")
  2645. added = detail[detail['PBBH'].isin(additional)]
  2646. for _, entry in added.iterrows():
  2647. clde_ = {}
  2648. CLBH = entry["PBBH"]
  2649. CLMC = entry["PBMC"]
  2650. JLDW = entry["DW"]
  2651. YSJG = entry["PBDJ"]
  2652. clde_["CLBH"] = CLBH
  2653. clde_["CLMC"] = CLMC
  2654. clde_["JLDW"] = JLDW
  2655. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2656. clde_["SL"] = 0
  2657. clde_["HJ"] = 0
  2658. clde.append(clde_)
  2659. filtered = filtered.drop(['BH1', 'BH2', "GCLCLF", "GCLCLF1", "GCLGG", "GCLGLF", "GCLJJ", "GCLJXF", "GCLLR", "GCLRGF", "GCLRGR", "GCLSJDJ", "GCPBHJ", "GLFFL", "LRFL", "PBBH", "PBBHM", "PBDJ", "PBSL", "THMC", "THSL", "dejb", "is_lock", "mcxz", "qfbz", "sptfl"], axis=1)
  2660. return filtered.to_json(force_ascii=False), id, rgde, jxde, clde, bz_selected.to_json(force_ascii=False) if len(bz_selected) > 0 else None, bz_selected2.to_json(force_ascii=False) if len(bz_selected2) > 0 else None
  2661. def getDwgc(root, id, Zylb):
  2662. result = []
  2663. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  2664. item = None
  2665. for child in root:
  2666. if child.tag == "Dxgcxx":
  2667. for child1 in child:
  2668. Dwgcbh = child1.attrib["Dwgcbh"]
  2669. if Dwgcbh == id:
  2670. item = child1
  2671. break
  2672. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  2673. id = id + "Zylb" + Zylb
  2674. for child in item:
  2675. if child.tag == "Fywj":
  2676. result.append({"id": id + "bao jia hui zong", "label": "报价汇总表"})
  2677. elif child.tag == "Gfsj":
  2678. result.append({"id": id + "gui fei shui jin", "label": "规费税金"})
  2679. elif child.tag == "Qdxm":
  2680. result.append({"id": id + "qing dan xiang mu", "label": "清单项目"})
  2681. elif child.tag == "Csxm":
  2682. result.append({"id": id + "cuo shi xiang mu", "label": "措施项目"})
  2683. elif child.tag == "Qtxm":
  2684. result.append({"id": id +"qi ta xiang mu", "label": "其他项目"})
  2685. elif child.tag == "Zlje":
  2686. result.append({"id": id +"zan lie jin e", "label": "暂列金额"})
  2687. elif child.tag == "Clzg":
  2688. result.append({"id": id +"cai liao zan gu jia", "label": "材料暂估价"})
  2689. elif child.tag == "Zygczg":
  2690. result.append({"id": id + "zhuan ye gong cheng zan gu jia", "label": "专业工程暂估价"})
  2691. elif child.tag == "Jrg":
  2692. result.append({"id": id + "ji ri gong", "label": "计日工"})
  2693. elif child.tag == "Zcbfwf":
  2694. result.append({"id": id + "zong cheng bao fu wu fei", "label": "总承包服务费"})
  2695. elif child.tag == "Zjxmjdkzffj":
  2696. result.append({"id": id + "zong jia xiang mu jin du kuan zhi fu fen jie", "label": "总价项目进度款支付分解"})
  2697. elif child.tag == "Fbrgycl":
  2698. result.append({"id": id + "fa bao ren gong ying cai liao", "label": "发包人供应材料"})
  2699. elif child.tag == "Cbrgycl":
  2700. result.append({"id": id + "cheng bao ren gong ying cai liao", "label": "承包人供应材料"})
  2701. elif child.tag == "Rcjhz":
  2702. result.append({"id": id + "ren cai ji hui zong", "label": "人材机汇总"})
  2703. else:
  2704. print(child.tag)
  2705. print("WARNING####################################################################")
  2706. return result
  2707. def getDjcs(root, id):
  2708. result = []
  2709. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  2710. item = None
  2711. for child in root:
  2712. if child.tag == "Dxgcxx":
  2713. for child1 in child:
  2714. Dwgcbh = child1.attrib["Dwgcbh"]
  2715. if Dwgcbh == id:
  2716. item = child1
  2717. break
  2718. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  2719. Fywj = None
  2720. for child in item:
  2721. if child.tag == 'Csxm':
  2722. Fywj= child
  2723. break
  2724. Djcs_parent = None
  2725. for child in Fywj:
  2726. if child.tag == 'DjCs':
  2727. Djcs_parent = child
  2728. break
  2729. for child in Djcs_parent:
  2730. ##child is mx {
  2731. result.append({
  2732. "序号": child.attrib["Xh"], "清单编码": child.attrib["Bm"], "名称" : child.attrib["Mc"],
  2733. "项目特征" : child.attrib["Xmtz"],
  2734. "计算规则" : child.attrib["Jsgz"], "单位" : child.attrib["Dw"], "数量" : child.attrib["Sl"],
  2735. "综合单价" : child.attrib["Zhdj"], "合价" : child.attrib["Zhhj"], "人工费" : child.attrib["Rgf"],
  2736. "主材费" : child.attrib["Zcf"],
  2737. "设备费" : child.attrib["Sbf"], "辅材费" : child.attrib["Fcf"], "材料费" : child.attrib["Clf"],
  2738. "机械费" : child.attrib["Jxf"], "管理费" : child.attrib["Glf"], "利润" : child.attrib["Lr"],
  2739. "暂估价" : child.attrib["Zgj"], "综合人工工日" : child.attrib["Zgr"] })
  2740. __children = []
  2741. zj_parent = None
  2742. for grandchild in child:
  2743. if grandchild.tag == "Csxdezj":
  2744. zj_parent = grandchild
  2745. if zj_parent:
  2746. for entry in zj_parent:
  2747. key = str(uuid.uuid4())
  2748. entry.set("key", key)
  2749. __children.append({
  2750. "key": key,
  2751. "序号": None, "清单编码": entry.attrib["Debm"], "名称" : entry.attrib["Mc"],
  2752. "项目特征" : None,
  2753. "计算规则" : None, "单位" : entry.attrib["Dw"], "数量" : entry.attrib["DwQdSl"],
  2754. "综合单价" : entry.attrib["Dj"], "合价" : entry.attrib["Hj"], "人工费" : entry.attrib["Rgf"],
  2755. "主材费" : entry.attrib["Zcf"],
  2756. "设备费" : entry.attrib["Sbf"], "辅材费" : entry.attrib["Fcf"], "材料费" : entry.attrib["Clf"],
  2757. "机械费" : entry.attrib["Jxf"], "管理费" : entry.attrib["Glf"], "利润" : entry.attrib["Lr"],
  2758. "暂估价" : None, "综合人工工日" : None })
  2759. if len(__children) > 0:
  2760. result[-1]["__children"] = __children
  2761. return result