service.py 128 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053
  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_tjazfy(debh):
  777. id = "412"
  778. r_debh = debh.split("!")[0]
  779. if len(debh.split("!")) == 1:
  780. return json.dumps({
  781. "reverse": id,
  782. "rgde": [],
  783. "jxde": [],
  784. "clde": [],
  785. "actual_zhuanye": 10,
  786. "bz_selected": {"BZBH": {}},
  787. "bz_selected2": {"BZBH": {}}
  788. }, ensure_ascii=False)
  789. gclmc = debh.split("!")[1]
  790. return json.dumps({
  791. "reverse": id,
  792. "DEBH": {"111": r_debh},
  793. "GCLMC": {"111": gclmc},
  794. "DW": {"111": '项'},
  795. "rgde": [],
  796. "jxde": [],
  797. "clde": [],
  798. "actual_zhuanye": 10,
  799. "bz_selected": {"BZBH": {}},
  800. "bz_selected2": {"BZBH": {}}
  801. }, ensure_ascii=False)
  802. def read_singledexilie_xsazfy(debh):
  803. id = "None"
  804. if "-F1" in debh:
  805. id = "185"
  806. elif "-F2" in debh:
  807. id = "186"
  808. elif "-F3" in debh:
  809. id = "187"
  810. r_debh = debh.split("!")[0]
  811. if len(debh.split("!")) == 1:
  812. return json.dumps({
  813. "reverse": id,
  814. "rgde": [],
  815. "jxde": [],
  816. "clde": [],
  817. "actual_zhuanye": 60,
  818. "bz_selected": {"BZBH": {}},
  819. "bz_selected2": {"BZBH": {}}
  820. }, ensure_ascii=False)
  821. gclmc = debh.split("!")[1]
  822. return json.dumps({
  823. "reverse": id,
  824. "DEBH": {"111": r_debh},
  825. "GCLMC": {"111": gclmc},
  826. "DW": {"111": '项'},
  827. "rgde": [],
  828. "jxde": [],
  829. "clde": [],
  830. "actual_zhuanye": 60,
  831. "bz_selected": {"BZBH": {}},
  832. "bz_selected2": {"BZBH": {}}
  833. }, ensure_ascii=False)
  834. def read_singledexilie_azfy(debh):
  835. id = "None"
  836. if "-F1" in debh:
  837. id = "2076"
  838. elif "-F2" in debh:
  839. id = "2077"
  840. elif "-F3" in debh:
  841. id = "2078"
  842. elif "-F4" in debh:
  843. id = "2079"
  844. elif "-F5" in debh:
  845. if '4-F5' in debh:
  846. id = "2081"
  847. elif '5-F5' in debh:
  848. id = '2082'
  849. elif '7-F5' in debh:
  850. id = '2083'
  851. elif '9-F5' in debh:
  852. id = '2084'
  853. elif '10-F5' in debh:
  854. id = '2085'
  855. elif '11-F5' in debh:
  856. id = '2086'
  857. elif "-F6" in debh:
  858. id = "2087"
  859. r_debh = debh.split("!")[0]
  860. if len(debh.split("!")) == 1:
  861. return json.dumps({
  862. "reverse": id,
  863. "rgde": [],
  864. "jxde": [],
  865. "clde": [],
  866. "actual_zhuanye": 30,
  867. "bz_selected": {"BZBH": {}},
  868. "bz_selected2": {"BZBH": {}}
  869. }, ensure_ascii=False)
  870. gclmc = debh.split("!")[1]
  871. return json.dumps({
  872. "reverse": id,
  873. "DEBH": {"111": r_debh},
  874. "GCLMC": {"111": gclmc},
  875. "DW": {"111": '项'},
  876. "rgde": [],
  877. "jxde": [],
  878. "clde": [],
  879. "actual_zhuanye": 30,
  880. "bz_selected": {"BZBH": {}},
  881. "bz_selected2": {"BZBH": {}}
  882. }, ensure_ascii=False)
  883. def getDeXilie_xsazfy(value, id):
  884. if int(id) == 184:
  885. return "{\"Unnamed: 0\":{},\"id\":{},\"DEBH\":{},\"GCLMC\":{},\"GCLSJDJ\":{},\"DW\":{},\"DeId\":{}}"
  886. if int(id) == 185:
  887. data = {'DW': ['项', '项', '项'],
  888. 'DEBH': ['1-F1', '2-F1', '3-F1'],
  889. "GCLMC": [ "第一章" , "第二章", "第三章"],
  890. "GCLSJDJ": ["0", "0", "0"]}
  891. df = pd.DataFrame(data)
  892. return df.to_json(force_ascii=False)
  893. if int(id) == 186:
  894. data = {'DW': ['项', '项', '项'],
  895. 'DEBH': ['1-F2', '2-F2', '3-F2'],
  896. "GCLMC": [ "第一章" , "第二章", "第三章"],
  897. "GCLSJDJ": ["0", "0", "0"]}
  898. df = pd.DataFrame(data)
  899. return df.to_json(force_ascii=False)
  900. if int(id) == 187:
  901. data = {'DW': ['项', '项', '项'],
  902. 'DEBH': ['1-F3', '2-F3', '3-F3'],
  903. "GCLMC": [ "第一章" , "第二章", "第三章"],
  904. "GCLSJDJ": ["0", "0", "0"]}
  905. df = pd.DataFrame(data)
  906. return df.to_json(force_ascii=False)
  907. def getDeXilie_azfy(value, id):
  908. if int(id) == 2075 or int(id) == 2080:
  909. return "{\"Unnamed: 0\":{},\"id\":{},\"DEBH\":{},\"GCLMC\":{},\"GCLSJDJ\":{},\"DW\":{},\"DeId\":{}}"
  910. if int(id) == 2076:
  911. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项", "项", "项", "项", "项", "项", "项"],
  912. 'DEBH': ['2-F1', '2-F1', '3-F1', '3-F1', '4-F1',
  913. '5-F1', '6-F1', '7-F1', '8-F1', '9-F1', '10-F1', '11-F1', '11-F1', '11-F1', '11-F1', '11-F1'],
  914. "GCLMC": ["第二册第1-5章(定额2-1~2-390)", "第二册第6章(定额2-391~2-9999)", "第三册静置设备制作(定额3-1~3-615)",
  915. "第三册除静置设备制作以外(定额3-616~3-9999)", "第四册",
  916. "第五册", "第六册", "第七册", "第八册", "第九册", "第十册",
  917. "第十一册刷油工程(定额11-51~11-329)",
  918. "第十一册防腐蚀工程(定额11-330~11-1689)", "第十一册绝热工程(定额11-1690~11-2327)", "第十一册除锈工程(定额11-1~11-50)刷油工程", "第十一册除锈工程(定额11-1~11-50)防腐蚀工程"],
  919. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  920. df = pd.DataFrame(data)
  921. return df.to_json(force_ascii=False)
  922. if int(id) == 2077:
  923. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项','项','项',
  924. '项','项','项','项','项','项','项','项','项','项',
  925. '项','项','项',
  926. '项','项', "项",'项','项','项','项', "项",'项', "项"],
  927. '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',
  928. '4-F2', '5-F2', '5-F2', '5-F2','6-F2',
  929. '7-F2', '9-F2','9-F2','9-F2','9-F2', '10-F2','10-F2','10-F2','10-F2',
  930. '11-F2','11-F2','11-F2','11-F2', '11-F2','11-F2','11-F2' ],
  931. "GCLMC": ["第一册第1-6章(定额1-1~1-571)10-15m",
  932. "第一册第1-6章(定额1-1~1-571)15-20m",
  933. "第一册第1-6章(定额1-1~1-571)20-25m",
  934. "第一册第1-6章(定额1-1~1-571)25-30m",
  935. "第一册第1-6章(定额1-1~1-571)30-40m",
  936. "第一册第1-6章(定额1-1~1-571)40m以上",
  937. "第一册第8-14章(定额1-672~1-9999)10-15m",
  938. "第一册第8-14章(定额1-672~1-9999)15-20m",
  939. "第一册第8-14章(定额1-672~1-9999)20-25m",
  940. "第一册第8-14章(定额1-672~1-9999)25-30m",
  941. "第一册第8-14章(定额1-672~1-9999)30-40m",
  942. "第一册第8-14章(定额1-672~1-9999)40m以上",
  943. "第四册",
  944. "第五册5m以上到10m以内",
  945. "第五册10-20m",
  946. "第五册20m以上",
  947. "第六册", "第七册",
  948. "第九册5m以上到8m以内",
  949. "第九册8-12m",
  950. "第九册12-16m",
  951. "第九册16-20m",
  952. "第十册3.6-8m以内",
  953. "第十册8-12m以内",
  954. "第十册12-16m以内",
  955. "第十册16-20m",
  956. "第十一册6-20m",
  957. "第十一册20-30m",
  958. "第十一册30-40m",
  959. "第十一册40-50m",
  960. "第十一册50-60m",
  961. "第十一册60-70m",
  962. "第十一册80m以上",
  963. ],
  964. "GCLSJDJ": ["0", "0", '0', '0',"0", "0", "0", "0", "0", "0",
  965. "0", "0", '0', '0',"0", "0", "0", "0", "0", "0",
  966. "0","0", "0",
  967. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  968. df = pd.DataFrame(data)
  969. return df.to_json(force_ascii=False)
  970. if int(id) == 2078:
  971. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项", "项"],
  972. 'DEBH': ['1-F4', '1-F4', '2-F4', '3-F4', '4-F4',
  973. '5-F4', '6-F4', '7-F4', '8-F4', '9-F4', '11-F4'],
  974. "GCLMC": ["第一册第1-6章", "第一册第8-14章", "第二册",
  975. "第三册", "第四册",
  976. "第五册", "第六册", "第七册", "第八册", "第九册",
  977. "第十一册", ],
  978. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  979. df = pd.DataFrame(data)
  980. return df.to_json(force_ascii=False)
  981. if int(id) == 2079:
  982. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项", "项"],
  983. 'DEBH': ['1-F5', '1-F5', '2-F5', '3-F5', '4-F5',
  984. '5-F5', '6-F5', '7-F5', '8-F5', '9-F5', '11-F5'],
  985. "GCLMC": ["第一册第1-6章", "第一册第8-14章", "第二册",
  986. "第三册", "第四册",
  987. "第五册", "第六册", "第七册", "第八册", "第九册",
  988. "第十一册", ],
  989. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  990. df = pd.DataFrame(data)
  991. return df.to_json(force_ascii=False)
  992. if int(id) == 2081:
  993. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  994. "项", '项', '项', '项', '项', "项", "项", "项"],
  995. 'DEBH': ['4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3',
  996. '4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3','4-F3', '4-F3'],
  997. "GCLMC": ["9层或30m以内",
  998. "12层或40m以内",
  999. "15层或50m以内",
  1000. "18层或60m以内",
  1001. "21层或70m以内",
  1002. "24层或80m以内",
  1003. "27层或90m以内",
  1004. "30层或100m以内",
  1005. "33层或110m以内",
  1006. "36层或120m以内",
  1007. "40层或130m以内",
  1008. "42层或140m以内",
  1009. "45层或150m以内",
  1010. "48层或160m以内",
  1011. "51层或170m以内",
  1012. "54层或180m以内",
  1013. "57层或190m以内",
  1014. "60层或200m以内",
  1015. ],
  1016. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1017. "0", "0", "0", "0", "0", "0", "0", "0"]}
  1018. df = pd.DataFrame(data)
  1019. return df.to_json(force_ascii=False)
  1020. if int(id) == 2082:
  1021. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1022. "项", '项', '项', '项', '项', "项", "项", "项"],
  1023. 'DEBH': ['5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3',
  1024. '5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3','5-F3', '5-F3'],
  1025. "GCLMC": ["9层或30m以内",
  1026. "12层或40m以内",
  1027. "15层或50m以内",
  1028. "18层或60m以内",
  1029. "21层或70m以内",
  1030. "24层或80m以内",
  1031. "27层或90m以内",
  1032. "30层或100m以内",
  1033. "33层或110m以内",
  1034. "36层或120m以内",
  1035. "40层或130m以内",
  1036. "42层或140m以内",
  1037. "45层或150m以内",
  1038. "48层或160m以内",
  1039. "51层或170m以内",
  1040. "54层或180m以内",
  1041. "57层或190m以内",
  1042. "60层或200m以内",
  1043. ],
  1044. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1045. "0", "0", "0", "0", "0", "0", "0", "0"]}
  1046. df = pd.DataFrame(data)
  1047. return df.to_json(force_ascii=False)
  1048. if int(id) == 2083:
  1049. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1050. "项", '项', '项', '项', '项', "项", "项", "项"],
  1051. 'DEBH': ['7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3',
  1052. '7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3','7-F3', '7-F3'],
  1053. "GCLMC": ["9层或30m以内",
  1054. "12层或40m以内",
  1055. "15层或50m以内",
  1056. "18层或60m以内",
  1057. "21层或70m以内",
  1058. "24层或80m以内",
  1059. "27层或90m以内",
  1060. "30层或100m以内",
  1061. "33层或110m以内",
  1062. "36层或120m以内",
  1063. "40层或130m以内",
  1064. "42层或140m以内",
  1065. "45层或150m以内",
  1066. "48层或160m以内",
  1067. "51层或170m以内",
  1068. "54层或180m以内",
  1069. "57层或190m以内",
  1070. "60层或200m以内",
  1071. ],
  1072. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1073. "0", "0", "0", "0", "0", "0", "0", "0"]}
  1074. df = pd.DataFrame(data)
  1075. return df.to_json(force_ascii=False)
  1076. if int(id) == 2084:
  1077. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1078. "项", '项', '项', '项', '项', "项", "项", "项"],
  1079. 'DEBH': ['9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3',
  1080. '9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3','9-F3', '9-F3'],
  1081. "GCLMC": ["9层或30m以内",
  1082. "12层或40m以内",
  1083. "15层或50m以内",
  1084. "18层或60m以内",
  1085. "21层或70m以内",
  1086. "24层或80m以内",
  1087. "27层或90m以内",
  1088. "30层或100m以内",
  1089. "33层或110m以内",
  1090. "36层或120m以内",
  1091. "40层或130m以内",
  1092. "42层或140m以内",
  1093. "45层或150m以内",
  1094. "48层或160m以内",
  1095. "51层或170m以内",
  1096. "54层或180m以内",
  1097. "57层或190m以内",
  1098. "60层或200m以内",
  1099. ],
  1100. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1101. "0", "0", "0", "0", "0", "0", "0", "0"]}
  1102. df = pd.DataFrame(data)
  1103. return df.to_json(force_ascii=False)
  1104. if int(id) == 2085:
  1105. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1106. "项", '项', '项', '项', '项', "项", "项", "项"],
  1107. 'DEBH': ['10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3',
  1108. '10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3','10-F3', '10-F3'],
  1109. "GCLMC": ["9层或30m以内",
  1110. "12层或40m以内",
  1111. "15层或50m以内",
  1112. "18层或60m以内",
  1113. "21层或70m以内",
  1114. "24层或80m以内",
  1115. "27层或90m以内",
  1116. "30层或100m以内",
  1117. "33层或110m以内",
  1118. "36层或120m以内",
  1119. "40层或130m以内",
  1120. "42层或140m以内",
  1121. "45层或150m以内",
  1122. "48层或160m以内",
  1123. "51层或170m以内",
  1124. "54层或180m以内",
  1125. "57层或190m以内",
  1126. "60层或200m以内",
  1127. ],
  1128. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1129. "0", "0", "0", "0", "0", "0", "0", "0"]}
  1130. df = pd.DataFrame(data)
  1131. return df.to_json(force_ascii=False)
  1132. if int(id) == 2086:
  1133. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1134. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1135. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1136. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1137. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1138. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1139. '项', '项', '项', '项', '项', '项', '项', '项', "项", "项",
  1140. "项", '项'],
  1141. 'DEBH': ['11-F3', '11-F3',
  1142. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1143. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1144. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1145. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1146. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1147. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1148. '11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3','11-F3', '11-F3',
  1149. ],
  1150. "GCLMC": [
  1151. "(按通风空调工程)9层或30m以内",
  1152. "(按通风空调工程)12层或40m以内",
  1153. "(按通风空调工程)15层或50m以内",
  1154. "(按通风空调工程)18层或60m以内",
  1155. "(按通风空调工程)21层或70m以内",
  1156. "(按通风空调工程)24层或80m以内",
  1157. "(按通风空调工程)27层或90m以内",
  1158. "(按通风空调工程)30层或100m以内",
  1159. "(按通风空调工程)33层或110m以内",
  1160. "(按通风空调工程)36层或120m以内",
  1161. "(按通风空调工程)40层或130m以内",
  1162. "(按通风空调工程)42层或140m以内",
  1163. "(按通风空调工程)45层或150m以内",
  1164. "(按通风空调工程)48层或160m以内",
  1165. "(按通风空调工程)51层或170m以内",
  1166. "(按通风空调工程)54层或180m以内",
  1167. "(按通风空调工程)57层或190m以内",
  1168. "(按通风空调工程)60层或200m以内",
  1169. ############################
  1170. "(按消防工程)9层或30m以内",
  1171. "(按消防工程)12层或40m以内",
  1172. "(按消防工程)15层或50m以内",
  1173. "(按消防工程)18层或60m以内",
  1174. "(按消防工程)21层或70m以内",
  1175. "(按消防工程)24层或80m以内",
  1176. "(按消防工程)27层或90m以内",
  1177. "(按消防工程)30层或100m以内",
  1178. "(按消防工程)33层或110m以内",
  1179. "(按消防工程)36层或120m以内",
  1180. "(按消防工程)40层或130m以内",
  1181. "(按消防工程)42层或140m以内",
  1182. "(按消防工程)45层或150m以内",
  1183. "(按消防工程)48层或160m以内",
  1184. "(按消防工程)51层或170m以内",
  1185. "(按消防工程)54层或180m以内",
  1186. "(按消防工程)57层或190m以内",
  1187. "(按消防工程)60层或200m以内",
  1188. ############################
  1189. "(按给排水、采暖工程)9层或30m以内",
  1190. "(按给排水、采暖工程)12层或40m以内",
  1191. "(按给排水、采暖工程)15层或50m以内",
  1192. "(按给排水、采暖工程)18层或60m以内",
  1193. "(按给排水、采暖工程)21层或70m以内",
  1194. "(按给排水、采暖工程)24层或80m以内",
  1195. "(按给排水、采暖工程)27层或90m以内",
  1196. "(按给排水、采暖工程)30层或100m以内",
  1197. "(按给排水、采暖工程)33层或110m以内",
  1198. "(按给排水、采暖工程)36层或120m以内",
  1199. "(按给排水、采暖工程)40层或130m以内",
  1200. "(按给排水、采暖工程)42层或140m以内",
  1201. "(按给排水、采暖工程)45层或150m以内",
  1202. "(按给排水、采暖工程)48层或160m以内",
  1203. "(按给排水、采暖工程)51层或170m以内",
  1204. "(按给排水、采暖工程)54层或180m以内",
  1205. "(按给排水、采暖工程)57层或190m以内",
  1206. "(按给排水、采暖工程)60层或200m以内",
  1207. ############################
  1208. "(按电气工程)9层或30m以内",
  1209. "(按电气工程)12层或40m以内",
  1210. "(按电气工程)15层或50m以内",
  1211. "(按电气工程)18层或60m以内",
  1212. "(按电气工程)21层或70m以内",
  1213. "(按电气工程)24层或80m以内",
  1214. "(按电气工程)27层或90m以内",
  1215. "(按电气工程)30层或100m以内",
  1216. "(按电气工程)33层或110m以内",
  1217. "(按电气工程)36层或120m以内",
  1218. "(按电气工程)40层或130m以内",
  1219. "(按电气工程)42层或140m以内",
  1220. "(按电气工程)45层或150m以内",
  1221. "(按电气工程)48层或160m以内",
  1222. "(按电气工程)51层或170m以内",
  1223. "(按电气工程)54层或180m以内",
  1224. "(按电气工程)57层或190m以内",
  1225. "(按电气工程)60层或200m以内",
  1226. ],
  1227. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1228. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1229. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1230. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1231. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1232. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1233. "0", "0", "0", "0", "0", "0", "0", "0", "0", "0",
  1234. "0", "0" ]}
  1235. df = pd.DataFrame(data)
  1236. return df.to_json(force_ascii=False)
  1237. if int(id) == 2087:
  1238. data = {'DW': ['项', '项', '项', '项', '项', '项', '项', '项', "项"],
  1239. 'DEBH': ['1-F6', '3-F6', '4-F6', '7-F6', '8-F6',
  1240. '10-F6', '10-F6', '10-F6', '11-F6'],
  1241. "GCLMC": ["第一册 站内工艺系统",
  1242. "第三册 站内工艺系统", "第四册 站内工艺系统",
  1243. "第七册", "第八册 站内工艺系统",
  1244. "第十册供暖器具安装", "第十册空调水工程管道安装", "第十册空调水工程管道附件", "第十一册 站内工艺系统" ],
  1245. "GCLSJDJ": ["0", "0", "0", "0", "0", "0", "0", "0", "0"]}
  1246. df = pd.DataFrame(data)
  1247. return df.to_json(force_ascii=False)
  1248. def getDeXilie(value, id):
  1249. ##print(type(id))
  1250. if value == 10:
  1251. shu = pd.read_csv("de/tj/JD_DingEShu.csv")
  1252. elif value == 20:
  1253. shu = pd.read_csv("de/sz/JD_DingEShu.csv")
  1254. elif value == 30:
  1255. shu = pd.read_csv("de/az/JD_DingEShu.csv")
  1256. elif value == 40:
  1257. shu = pd.read_csv("de/yl/JD_DingEShu.csv")
  1258. elif value == 50:
  1259. shu = pd.read_csv("de/xstj/JD_DingEShu.csv")
  1260. else:
  1261. shu = pd.read_csv("de/xsaz/JD_DingEShu.csv")
  1262. hit = shu[shu["ID"]==int(id)]
  1263. ##print(hit)
  1264. if len(hit) == 0:
  1265. return []
  1266. hit0 = hit.iloc[0]
  1267. index = str(hit0['zjh'])
  1268. ##print("index=" + index)
  1269. if value == 10:
  1270. gj = pd.read_csv("de/tj/JD_DanWeiGJ.csv")
  1271. filtered = gj[gj["YSDELBH"]==int(index)]
  1272. elif value == 20:
  1273. gj = pd.read_csv("de/sz/JD_DanWeiGJ.csv")
  1274. filtered = gj[gj["YSDELBH"]==(index)]
  1275. elif value == 30:
  1276. gj = pd.read_csv("de/az/JD_DanWeiGJ.csv")
  1277. filtered = gj[gj["YSDELBH"]==(index)]
  1278. elif value == 40:
  1279. gj = pd.read_csv("de/yl/JD_DanWeiGJ.csv")
  1280. filtered = gj[gj["YSDELBH"]==int(index)]
  1281. elif value == 50:
  1282. gj = pd.read_csv("de/xstj/JD_DanWeiGJ.csv")
  1283. filtered = gj[gj["YSDELBH"]==int(index)]
  1284. else:
  1285. gj = pd.read_csv("de/xsaz/JD_DanWeiGJ.csv")
  1286. filtered = gj[gj["YSDELBH"]==int(index)]
  1287. 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)
  1288. return filtered.to_json(force_ascii=False)
  1289. def getPbxl(name, zhuanye):
  1290. if name == "0":
  1291. if zhuanye == 10:
  1292. gj = pd.read_csv("de/tj/JD_PeiBi.csv")
  1293. elif zhuanye == 20:
  1294. gj = pd.read_csv("de/tj/JD_PeiBi.csv")
  1295. elif zhuanye == 30:
  1296. gj = pd.read_csv("de/tj/JD_PeiBi.csv")
  1297. elif zhuanye == 40:
  1298. gj = pd.read_csv("de/yl/JD_PeiBi.csv")
  1299. elif zhuanye == 50:
  1300. gj = pd.read_csv("de/xstj/JD_PeiBi.csv")
  1301. elif zhuanye == 60:
  1302. gj = pd.read_csv("de/xsaz/JD_PeiBi.csv")
  1303. return gj.to_json(force_ascii=False)
  1304. shu = pd.read_csv("de/tj/JD_PeiBiFLB.csv")
  1305. hit = shu[shu["ID"]==int(name)]
  1306. ##print(hit)
  1307. if len(hit) == 0:
  1308. return []
  1309. hit0 = hit.iloc[0]
  1310. index = str(hit0['pblbh'])
  1311. index_list = index.split(";")
  1312. gj = pd.read_csv("de/tj/JD_PeiBi.csv")
  1313. filtered = gj[gj["PBBH"].str.startswith(tuple(index_list))]
  1314. return filtered.to_json(force_ascii=False)
  1315. def getJxxl(name, zhuanye):
  1316. if name == "0":
  1317. if zhuanye == 10:
  1318. gj = pd.read_csv("de/tj/JD_JiXieK.csv")
  1319. elif zhuanye == 20:
  1320. gj = pd.read_csv("de/tj/JD_JiXieK.csv")
  1321. elif zhuanye == 30:
  1322. gj = pd.read_csv("de/tj/JD_JiXieK.csv")
  1323. elif zhuanye == 40:
  1324. gj = pd.read_csv("de/yl/JD_JiXieK.csv")
  1325. elif zhuanye == 50:
  1326. gj = pd.read_csv("de/xstj/JD_JiXieK.csv")
  1327. elif zhuanye == 60:
  1328. gj = pd.read_csv("de/xsaz/JD_JiXieK.csv")
  1329. return gj.to_json(force_ascii=False)
  1330. shu = pd.read_csv("de/tj/JD_JiXieFLB.csv")
  1331. hit = shu[shu["ID"]==int(name)]
  1332. ##print(hit)
  1333. if len(hit) == 0:
  1334. return []
  1335. hit0 = hit.iloc[0]
  1336. index = str(hit0['jxlbh'])
  1337. index_list = index.split(";")
  1338. gj = pd.read_csv("de/tj/JD_JiXieK.csv")
  1339. filtered = gj[gj["jxbh"].str.startswith(tuple(index_list))]
  1340. return filtered.to_json(force_ascii=False)
  1341. def getClxl(name, zhuanye):
  1342. if name == "0":
  1343. if zhuanye == 10:
  1344. gj = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  1345. elif zhuanye == 20:
  1346. gj = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  1347. elif zhuanye == 30:
  1348. gj = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  1349. elif zhuanye == 40:
  1350. gj = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1351. elif zhuanye == 50:
  1352. gj = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1353. elif zhuanye == 60:
  1354. gj = pd.read_csv("de/xsaz/JD_CaiLiaoK.csv")
  1355. return gj.to_json(force_ascii=False)
  1356. if zhuanye == 10:
  1357. shu = pd.read_csv("de/tj/JD_CaiLiaoFLB.csv")
  1358. if zhuanye == 20:
  1359. shu = pd.read_csv("de/sz/JD_CaiLiaoFLB.csv")
  1360. if zhuanye == 30:
  1361. shu = pd.read_csv("de/az/JD_CaiLiaoFLB.csv")
  1362. if zhuanye == 40:
  1363. shu = pd.read_csv("de/yl/JD_CaiLiaoFLB.csv", dtype={'cllbh': str})
  1364. if zhuanye == 50:
  1365. shu = pd.read_csv("de/xstj/JD_CaiLiaoFLB.csv", dtype={'cllbh': str})
  1366. if zhuanye == 60:
  1367. shu = pd.read_csv("de/xsaz/JD_CaiLiaoFLB.csv", dtype={'cllbh': str})
  1368. hit = shu[shu["ID"]==int(name)]
  1369. ##print(hit)
  1370. if len(hit) == 0:
  1371. return []
  1372. hit0 = hit.iloc[0]
  1373. index = str(hit0['cllbh'])
  1374. index_list = index.split(";")
  1375. if zhuanye == 10:
  1376. gj = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  1377. if zhuanye == 20:
  1378. gj = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  1379. if zhuanye == 30:
  1380. gj = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  1381. if zhuanye == 40:
  1382. gj = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1383. if zhuanye == 50:
  1384. gj = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1385. if zhuanye == 60:
  1386. gj = pd.read_csv("de/xsaz/JD_CaiLiaoK.csv")
  1387. ##print(index_list)
  1388. ##print(gj)
  1389. filtered = gj[gj["CLBH"].str.startswith(tuple(index_list))]
  1390. return filtered.to_json(force_ascii=False)
  1391. def getSingleDeXilie(zhuanye, debh):
  1392. if zhuanye == 10:
  1393. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_tj(debh)
  1394. if A1:
  1395. return A1, A2, A3, A4, A5, A6, A7, 10
  1396. else:
  1397. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_sz(debh)
  1398. return A1, A2, A3, A4,A5, A6, A7, 20
  1399. elif zhuanye == 20:##shizheng
  1400. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_sz(debh)
  1401. if A1:
  1402. return A1, A2, A3, A4, A5, A6, A7, 20
  1403. else:
  1404. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_tj(debh)
  1405. if A1:
  1406. return A1, A2, A3, A4, A5, A6, A7, 10
  1407. else:
  1408. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_az(debh)
  1409. return A1, A2, A3, A4, A5, A6, A7, 30
  1410. elif zhuanye == 30:##anzhuang
  1411. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_az(debh)
  1412. return A1, A2, A3, A4, A5, A6, A7, 30
  1413. elif zhuanye == 40:##yuanlin
  1414. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_yl(debh)
  1415. return A1, A2, A3, A4, A5, A6, A7, 40
  1416. elif zhuanye == 50: ## xiushan tujian
  1417. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_xstj(debh)
  1418. if A1:
  1419. return A1, A2, A3, A4, A5, A6, A7, 50
  1420. else:
  1421. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_tj(debh)
  1422. return A1, A2, A3, A4,A5, A6, A7, 10
  1423. else:
  1424. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_xsaz(debh)
  1425. if A1:
  1426. return A1, A2, A3, A4, A5, A6, A7, 60
  1427. else:
  1428. A1, A2, A3, A4, A5, A6, A7 = getSingleDeXilie_az(debh)
  1429. return A1, A2, A3, A4,A5, A6, A7, 30
  1430. def getSingleDeXilie_xsaz(debh):
  1431. id = None
  1432. bz_selected = []
  1433. bz_selected2 = []
  1434. if "附注" in debh:
  1435. position = debh.find("附注")
  1436. debh = debh[:position]
  1437. if "*" in debh:
  1438. position = debh.find("*")
  1439. debh = debh[:position]
  1440. if debh.endswith("换"):
  1441. debh = debh[:-1]
  1442. if "[" in debh:
  1443. position = debh.find("[")
  1444. debh = debh[:position-1]
  1445. gj = pd.read_csv("de/xsaz/JD_DanWeiGJ.csv")
  1446. filtered = gj[gj["DEBH"]==debh]
  1447. ##print(filtered)
  1448. if len(filtered) > 0:
  1449. index = (filtered.iloc[0]["YSDELBH"])
  1450. shu = pd.read_csv("de/xsaz/JD_DingEShu.csv")
  1451. hit = shu[shu["zjh"]==index]
  1452. if len(hit) > 0:
  1453. id = hit.iloc[0]["ID"]
  1454. beizhu = str(filtered.iloc[0]["BZBH"])
  1455. if 'nan' in beizhu:
  1456. pass
  1457. else:
  1458. beizhus = beizhu.split(";")
  1459. ##print(beizhus)
  1460. bzfile = pd.read_csv("de/xsaz/JD_BeiZhuZK.csv")
  1461. bzfile2 = pd.read_csv("de/xsaz/JD_BeiZhuFK.csv", dtype=str)
  1462. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  1463. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  1464. else:
  1465. return None, None, None, None, None, None, None
  1466. ####rengong
  1467. rgde = []
  1468. rg = pd.read_csv("de/xsaz/JD_GuJiaRG.csv")
  1469. filtered1 = rg[rg["DEBH"]==debh]
  1470. for i in range(len(filtered1)):
  1471. rgde_ = {}
  1472. gr = filtered1.iloc[i]["RGR"]##gongri
  1473. gf = filtered1.iloc[i]["RGF"]##gongfei
  1474. rcjID = filtered1.iloc[i]["RcjID"]
  1475. detail = pd.read_csv("de/xsaz/JD_CaiLiaoK.csv")
  1476. filtered2 = detail[detail["RcjID"]==rcjID]
  1477. if len(filtered2) > 0:
  1478. CLBH = filtered2.iloc[0]["CLBH"]
  1479. CLMC = filtered2.iloc[0]["CLMC"]
  1480. JLDW = filtered2.iloc[0]["JLDW"]
  1481. YSJG = filtered2.iloc[0]["YSJG"]
  1482. rgde_["CLBH"] = CLBH
  1483. rgde_["CLMC"] = CLMC
  1484. rgde_["JLDW"] = JLDW
  1485. rgde_["YSJG"] = YSJG.item()
  1486. rgde_["gr"] = gr.item()
  1487. rgde_["gf"] = gf.item()
  1488. rgde.append(rgde_)
  1489. ##print(rgde)
  1490. ####jixie
  1491. jxde = []
  1492. jx = pd.read_csv("de/xsaz/JD_GuJiaJX.csv")
  1493. filtered1 = jx[jx["DEBH"]==debh]
  1494. for i in range(len(filtered1)):
  1495. jxde_ = {}
  1496. sl = filtered1.iloc[i]["SL"]##shuliang
  1497. hj = filtered1.iloc[i]["HJ"]##hejia
  1498. rcjID = filtered1.iloc[i]["RcjID"]
  1499. detail = pd.read_csv("de/xsaz/JD_JiXieK.csv")
  1500. filtered2 = detail[detail["RcjID"]==rcjID]
  1501. if len(filtered2) > 0:
  1502. jxbh = filtered2.iloc[0]["jxbh"]
  1503. jxmc = filtered2.iloc[0]["jxmc"]
  1504. DW = filtered2.iloc[0]["DW"]
  1505. tbdj = filtered2.iloc[0]["tbdj"]
  1506. jxde_["jxbh"] = jxbh
  1507. jxde_["jxmc"] = jxmc
  1508. jxde_["DW"] = DW
  1509. jxde_["tbdj"] = tbdj.item()
  1510. jxde_["sl"] = sl.item()
  1511. jxde_["hj"] = hj.item()
  1512. jxde.append(jxde_)
  1513. ####cailiao
  1514. clde = []
  1515. cl = pd.read_csv("de/xsaz/JD_GuJiaCL.csv")
  1516. filtered1 = cl[cl["DEBH"]==debh]
  1517. for i in range(len(filtered1)):
  1518. clde_ = {}
  1519. SL = filtered1.iloc[i]["SL"]##shuliang
  1520. HJ = filtered1.iloc[i]["HJ"]##hejia
  1521. rcjID = filtered1.iloc[i]["RcjID"]
  1522. detail = pd.read_csv("de/xsaz/JD_CaiLiaoK.csv")
  1523. filtered2 = detail[detail["RcjID"]==rcjID]
  1524. detail_ = pd.read_csv("de/xsaz/JD_PeiBi.csv")
  1525. filtered2_ = detail_[detail_["RcjID"]==rcjID]
  1526. if len(filtered2) > 0 and len(filtered2_) == 0:
  1527. CLBH = filtered2.iloc[0]["CLBH"]
  1528. CLMC = filtered2.iloc[0]["CLMC"]
  1529. JLDW = filtered2.iloc[0]["JLDW"]
  1530. YSJG = filtered2.iloc[0]["YSJG"]
  1531. clde_["CLBH"] = CLBH
  1532. clde_["CLMC"] = CLMC
  1533. clde_["JLDW"] = JLDW
  1534. clde_["YSJG"] = YSJG.item()
  1535. clde_["SL"] = SL.item()
  1536. clde_["HJ"] = HJ.item()
  1537. clde.append(clde_)
  1538. elif len(filtered2) == 0 and len(filtered2_) > 0:
  1539. CLBH = filtered2_.iloc[0]["PBBH"]
  1540. CLMC = filtered2_.iloc[0]["PBMC"]
  1541. JLDW = filtered2_.iloc[0]["DW"]
  1542. YSJG = filtered2_.iloc[0]["PBDJ"]
  1543. clde_["CLBH"] = CLBH.item()
  1544. clde_["CLMC"] = CLMC
  1545. clde_["JLDW"] = JLDW
  1546. clde_["YSJG"] = YSJG.item()
  1547. clde_["SL"] = SL.item()
  1548. clde_["HJ"] = HJ.item()
  1549. clde.append(clde_)
  1550. elif len(filtered2) > 0 and len(filtered2_) > 0:
  1551. YSJG = filtered2.iloc[0]["YSJG"]
  1552. YSJG_ = filtered2_.iloc[0]["PBDJ"]
  1553. if float(HJ) < 0.00001:
  1554. if float(YSJG) < 0.00001:
  1555. CLBH = filtered2.iloc[0]["CLBH"]
  1556. CLMC = filtered2.iloc[0]["CLMC"]
  1557. JLDW = filtered2.iloc[0]["JLDW"]
  1558. YSJG = filtered2.iloc[0]["YSJG"]
  1559. clde_["CLBH"] = CLBH
  1560. clde_["CLMC"] = CLMC
  1561. clde_["JLDW"] = JLDW
  1562. clde_["YSJG"] = YSJG.item()
  1563. clde_["SL"] = SL.item()
  1564. clde_["HJ"] = HJ.item()
  1565. clde.append(clde_)
  1566. elif float(YSJG_) < 0.00001:
  1567. CLBH = filtered2_.iloc[0]["PBBH"]
  1568. CLMC = filtered2_.iloc[0]["PBMC"]
  1569. JLDW = filtered2_.iloc[0]["DW"]
  1570. YSJG = filtered2_.iloc[0]["PBDJ"]
  1571. clde_["CLBH"] = CLBH.item()
  1572. clde_["CLMC"] = CLMC
  1573. clde_["JLDW"] = JLDW
  1574. clde_["YSJG"] = YSJG.item()
  1575. clde_["SL"] = SL.item()
  1576. clde_["HJ"] = HJ.item()
  1577. clde.append(clde_)
  1578. else:
  1579. ratio = float(YSJG) / (float(HJ) / float(SL))
  1580. ratio_ = float(YSJG_) / (float(HJ) / float(SL))
  1581. if abs(ratio - 1) < abs(ratio_ -1):
  1582. CLBH = filtered2.iloc[0]["CLBH"]
  1583. CLMC = filtered2.iloc[0]["CLMC"]
  1584. JLDW = filtered2.iloc[0]["JLDW"]
  1585. YSJG = filtered2.iloc[0]["YSJG"]
  1586. clde_["CLBH"] = CLBH
  1587. clde_["CLMC"] = CLMC
  1588. clde_["JLDW"] = JLDW
  1589. clde_["YSJG"] = YSJG.item()
  1590. clde_["SL"] = SL.item()
  1591. clde_["HJ"] = HJ.item()
  1592. clde.append(clde_)
  1593. else:
  1594. CLBH = filtered2_.iloc[0]["PBBH"]
  1595. CLMC = filtered2_.iloc[0]["PBMC"]
  1596. JLDW = filtered2_.iloc[0]["DW"]
  1597. YSJG = filtered2_.iloc[0]["PBDJ"]
  1598. clde_["CLBH"] = CLBH.item()
  1599. clde_["CLMC"] = CLMC
  1600. clde_["JLDW"] = JLDW
  1601. clde_["YSJG"] = YSJG.item()
  1602. clde_["SL"] = SL.item()
  1603. clde_["HJ"] = HJ.item()
  1604. clde.append(clde_)
  1605. 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)
  1606. 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
  1607. def getSingleDeXilie_xstj(debh):
  1608. id = None
  1609. bz_selected = []
  1610. bz_selected2 = []
  1611. additional = []
  1612. if "附注" in debh:
  1613. position = debh.find("附注")
  1614. debh = debh[:position]
  1615. if "*" in debh:
  1616. position = debh.find("*")
  1617. debh = debh[:position]
  1618. if debh.endswith("换"):
  1619. debh = debh[:-1]
  1620. if "[" in debh:
  1621. position = debh.find("[")
  1622. debh = debh[:position-1]
  1623. gj = pd.read_csv("de/xstj/JD_DanWeiGJ.csv")
  1624. filtered = gj[gj["DEBH"]==debh]
  1625. ##print(filtered)
  1626. if len(filtered) > 0:
  1627. index = (filtered.iloc[0]["YSDELBH"])
  1628. shu = pd.read_csv("de/xstj/JD_DingEShu.csv")
  1629. hit = shu[shu["zjh"]==index]
  1630. if len(hit) > 0:
  1631. id = hit.iloc[0]["ID"]
  1632. beizhu = str(filtered.iloc[0]["BZBH"])
  1633. if 'nan' in beizhu:
  1634. pass
  1635. else:
  1636. beizhus = beizhu.split(";")
  1637. ##print(beizhus)
  1638. bzfile = pd.read_csv("de/xstj/JD_BeiZhuZK.csv")
  1639. bzfile2 = pd.read_csv("de/xstj/JD_BeiZhuFK.csv", dtype=str)
  1640. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  1641. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  1642. bz_selected2 = bz_selected2.astype({'BH': str})
  1643. additional = bz_selected2['BH'].tolist()
  1644. 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']]
  1645. else:
  1646. return None, None, None, None, None, None, None
  1647. ####rengong
  1648. rgde = []
  1649. rg = pd.read_csv("de/xstj/JD_GuJiaRG.csv")
  1650. filtered1 = rg[rg["DEBH"]==debh]
  1651. for i in range(len(filtered1)):
  1652. rgde_ = {}
  1653. gr = filtered1.iloc[i]["RGR"]##gongri
  1654. gf = filtered1.iloc[i]["RGF"]##gongfei
  1655. rcjID = filtered1.iloc[i]["RcjID"]
  1656. detail = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1657. filtered2 = detail[detail["RcjID"]==rcjID]
  1658. if len(filtered2) > 0:
  1659. CLBH = filtered2.iloc[0]["CLBH"]
  1660. CLMC = filtered2.iloc[0]["CLMC"]
  1661. JLDW = filtered2.iloc[0]["JLDW"]
  1662. YSJG = filtered2.iloc[0]["YSJG"]
  1663. rgde_["CLBH"] = CLBH
  1664. rgde_["CLMC"] = CLMC
  1665. rgde_["JLDW"] = JLDW
  1666. rgde_["YSJG"] = YSJG.item()
  1667. rgde_["gr"] = gr.item()
  1668. rgde_["gf"] = gf.item()
  1669. if CLBH in additional:
  1670. additional.remove(CLBH)
  1671. rgde.append(rgde_)
  1672. detail = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1673. detail = detail[detail['RcjLb'].isin([1, '1'])]
  1674. added = detail[detail['CLBH'].isin(additional)]
  1675. for _, entry in added.iterrows():
  1676. rgde_ = {}
  1677. CLBH = entry["CLBH"]
  1678. CLMC = entry["CLMC"]
  1679. JLDW = entry["JLDW"]
  1680. YSJG = entry["YSJG"]
  1681. rgde_["CLBH"] = CLBH
  1682. rgde_["CLMC"] = CLMC
  1683. rgde_["JLDW"] = JLDW
  1684. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1685. rgde_["gr"] = 0
  1686. rgde_["gf"] = 0
  1687. rgde.append(rgde_)
  1688. ####jixie
  1689. jxde = []
  1690. jx = pd.read_csv("de/xstj/JD_GuJiaJX.csv")
  1691. filtered1 = jx[jx["DEBH"]==debh]
  1692. for i in range(len(filtered1)):
  1693. jxde_ = {}
  1694. sl = filtered1.iloc[i]["SL"]##shuliang
  1695. hj = filtered1.iloc[i]["HJ"]##hejia
  1696. rcjID = filtered1.iloc[i]["RcjID"]
  1697. detail = pd.read_csv("de/xstj/JD_JiXieK.csv")
  1698. filtered2 = detail[detail["RcjID"]==rcjID]
  1699. if len(filtered2) > 0:
  1700. jxbh = filtered2.iloc[0]["jxbh"]
  1701. jxmc = filtered2.iloc[0]["jxmc"]
  1702. DW = filtered2.iloc[0]["DW"]
  1703. tbdj = filtered2.iloc[0]["tbdj"]
  1704. jxde_["jxbh"] = jxbh
  1705. jxde_["jxmc"] = jxmc
  1706. jxde_["DW"] = DW
  1707. jxde_["tbdj"] = tbdj.item()
  1708. jxde_["sl"] = sl.item()
  1709. jxde_["hj"] = hj.item()
  1710. if jxbh in additional:
  1711. additional.remove(jxbh)
  1712. jxde.append(jxde_)
  1713. detail = pd.read_csv("de/xstj/JD_JiXieK.csv")
  1714. added = detail[detail['jxbh'].isin(additional)]
  1715. for _, entry in added.iterrows():
  1716. jxde_ = {}
  1717. jxbh = entry["jxbh"]
  1718. jxmc = entry["jxmc"]
  1719. DW = entry["DW"]
  1720. tbdj = entry["tbdj"]
  1721. jxde_["jxbh"] = jxbh
  1722. jxde_["jxmc"] = jxmc
  1723. jxde_["DW"] = DW
  1724. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  1725. jxde_["sl"] = 0
  1726. jxde_["hj"] = 0
  1727. jxde.append(jxde_)
  1728. ####cailiao
  1729. clde = []
  1730. cl = pd.read_csv("de/xstj/JD_GuJiaCL.csv")
  1731. filtered1 = cl[cl["DEBH"]==debh]
  1732. for i in range(len(filtered1)):
  1733. clde_ = {}
  1734. SL = filtered1.iloc[i]["SL"]##shuliang
  1735. HJ = filtered1.iloc[i]["HJ"]##hejia
  1736. rcjID = filtered1.iloc[i]["RcjID"]
  1737. detail = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1738. filtered2 = detail[detail["RcjID"]==rcjID]
  1739. detail_ = pd.read_csv("de/xstj/JD_PeiBi.csv")
  1740. filtered2_ = detail_[detail_["RcjID"]==rcjID]
  1741. if len(filtered2) > 0 and len(filtered2_) == 0:
  1742. CLBH = filtered2.iloc[0]["CLBH"]
  1743. CLMC = filtered2.iloc[0]["CLMC"]
  1744. JLDW = filtered2.iloc[0]["JLDW"]
  1745. YSJG = filtered2.iloc[0]["YSJG"]
  1746. clde_["CLBH"] = CLBH
  1747. clde_["CLMC"] = CLMC
  1748. clde_["JLDW"] = JLDW
  1749. clde_["YSJG"] = YSJG.item()
  1750. clde_["SL"] = SL.item()
  1751. clde_["HJ"] = HJ.item()
  1752. clde.append(clde_)
  1753. elif len(filtered2) == 0 and len(filtered2_) > 0:
  1754. CLBH = filtered2_.iloc[0]["PBBH"]
  1755. CLMC = filtered2_.iloc[0]["PBMC"]
  1756. JLDW = filtered2_.iloc[0]["DW"]
  1757. YSJG = filtered2_.iloc[0]["PBDJ"]
  1758. clde_["CLBH"] = CLBH.item()
  1759. clde_["CLMC"] = CLMC
  1760. clde_["JLDW"] = JLDW
  1761. clde_["YSJG"] = YSJG.item()
  1762. clde_["SL"] = SL.item()
  1763. clde_["HJ"] = HJ.item()
  1764. clde.append(clde_)
  1765. elif len(filtered2) > 0 and len(filtered2_) > 0:
  1766. YSJG = filtered2.iloc[0]["YSJG"]
  1767. YSJG_ = filtered2_.iloc[0]["PBDJ"]
  1768. if float(HJ) < 0.00001:
  1769. if float(YSJG) < 0.00001:
  1770. CLBH = filtered2.iloc[0]["CLBH"]
  1771. CLMC = filtered2.iloc[0]["CLMC"]
  1772. JLDW = filtered2.iloc[0]["JLDW"]
  1773. YSJG = filtered2.iloc[0]["YSJG"]
  1774. clde_["CLBH"] = CLBH
  1775. clde_["CLMC"] = CLMC
  1776. clde_["JLDW"] = JLDW
  1777. clde_["YSJG"] = YSJG.item()
  1778. clde_["SL"] = SL.item()
  1779. clde_["HJ"] = HJ.item()
  1780. clde.append(clde_)
  1781. elif float(YSJG_) < 0.00001:
  1782. CLBH = filtered2_.iloc[0]["PBBH"]
  1783. CLMC = filtered2_.iloc[0]["PBMC"]
  1784. JLDW = filtered2_.iloc[0]["DW"]
  1785. YSJG = filtered2_.iloc[0]["PBDJ"]
  1786. clde_["CLBH"] = CLBH.item()
  1787. clde_["CLMC"] = CLMC
  1788. clde_["JLDW"] = JLDW
  1789. clde_["YSJG"] = YSJG.item()
  1790. clde_["SL"] = SL.item()
  1791. clde_["HJ"] = HJ.item()
  1792. clde.append(clde_)
  1793. else:
  1794. ratio = float(YSJG) / (float(HJ) / float(SL))
  1795. ratio_ = float(YSJG_) / (float(HJ) / float(SL))
  1796. if abs(ratio - 1) < abs(ratio_ -1):
  1797. CLBH = filtered2.iloc[0]["CLBH"]
  1798. CLMC = filtered2.iloc[0]["CLMC"]
  1799. JLDW = filtered2.iloc[0]["JLDW"]
  1800. YSJG = filtered2.iloc[0]["YSJG"]
  1801. clde_["CLBH"] = CLBH
  1802. clde_["CLMC"] = CLMC
  1803. clde_["JLDW"] = JLDW
  1804. clde_["YSJG"] = YSJG.item()
  1805. clde_["SL"] = SL.item()
  1806. clde_["HJ"] = HJ.item()
  1807. clde.append(clde_)
  1808. else:
  1809. CLBH = filtered2_.iloc[0]["PBBH"]
  1810. CLMC = filtered2_.iloc[0]["PBMC"]
  1811. JLDW = filtered2_.iloc[0]["DW"]
  1812. YSJG = filtered2_.iloc[0]["PBDJ"]
  1813. clde_["CLBH"] = CLBH.item()
  1814. clde_["CLMC"] = CLMC
  1815. clde_["JLDW"] = JLDW
  1816. clde_["YSJG"] = YSJG.item()
  1817. clde_["SL"] = SL.item()
  1818. clde_["HJ"] = HJ.item()
  1819. clde.append(clde_)
  1820. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  1821. additional.remove(clde_['CLBH'])
  1822. detail = pd.read_csv("de/xstj/JD_CaiLiaoK.csv")
  1823. detail = detail[detail['RcjLb'].isin([2, '2'])]
  1824. added = detail[detail['CLBH'].isin(additional)]
  1825. added = added.drop_duplicates(subset=['CLBH'])
  1826. for _, entry in added.iterrows():
  1827. clde_ = {}
  1828. CLBH = entry["CLBH"]
  1829. CLMC = entry["CLMC"]
  1830. JLDW = entry["JLDW"]
  1831. YSJG = entry["YSJG"]
  1832. clde_["CLBH"] = CLBH
  1833. clde_["CLMC"] = CLMC
  1834. clde_["JLDW"] = JLDW
  1835. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1836. clde_["SL"] = 0
  1837. clde_["HJ"] = 0
  1838. clde.append(clde_)
  1839. detail = pd.read_csv("de/xstj/JD_PeiBi.csv")
  1840. added = detail[detail['PBBH'].isin(additional)]
  1841. for _, entry in added.iterrows():
  1842. clde_ = {}
  1843. CLBH = entry["PBBH"]
  1844. CLMC = entry["PBMC"]
  1845. JLDW = entry["DW"]
  1846. YSJG = entry["PBDJ"]
  1847. clde_["CLBH"] = CLBH
  1848. clde_["CLMC"] = CLMC
  1849. clde_["JLDW"] = JLDW
  1850. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1851. clde_["SL"] = 0
  1852. clde_["HJ"] = 0
  1853. clde.append(clde_)
  1854. 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)
  1855. 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
  1856. def getSingleDeXilie_yl(debh):
  1857. id = None
  1858. bz_selected = []
  1859. bz_selected2 = []
  1860. additional = []
  1861. if "附注" in debh:
  1862. position = debh.find("附注")
  1863. debh = debh[:position]
  1864. if "*" in debh:
  1865. position = debh.find("*")
  1866. debh = debh[:position]
  1867. if debh.endswith("换"):
  1868. debh = debh[:-1]
  1869. if "[" in debh:
  1870. position = debh.find("[")
  1871. debh = debh[:position-1]
  1872. gj = pd.read_csv("de/yl/JD_DanWeiGJ.csv")
  1873. filtered = gj[gj["DEBH"]==debh]
  1874. ##print(filtered)
  1875. if len(filtered) > 0:
  1876. index = (filtered.iloc[0]["YSDELBH"])
  1877. shu = pd.read_csv("de/yl/JD_DingEShu.csv")
  1878. hit = shu[shu["zjh"]==index]
  1879. if len(hit) > 0:
  1880. id = hit.iloc[0]["ID"]
  1881. beizhu = str(filtered.iloc[0]["BZBH"])
  1882. if 'nan' in beizhu:
  1883. pass
  1884. else:
  1885. beizhus = beizhu.split(";")
  1886. ##print(beizhus)
  1887. bzfile = pd.read_csv("de/yl/JD_BeiZhuZK.csv")
  1888. bzfile2 = pd.read_csv("de/yl/JD_BeiZhuFK.csv", dtype=str)
  1889. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  1890. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  1891. bz_selected2 = bz_selected2.astype({'BH': str})
  1892. additional = bz_selected2['BH'].tolist()
  1893. 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']]
  1894. else:
  1895. return None, None, None, None, None, None, None
  1896. ####rengong
  1897. rgde = []
  1898. rg = pd.read_csv("de/yl/JD_GuJiaRG.csv")
  1899. filtered1 = rg[rg["DEBH"]==debh]
  1900. for i in range(len(filtered1)):
  1901. rgde_ = {}
  1902. gr = filtered1.iloc[i]["RGR"]##gongri
  1903. gf = filtered1.iloc[i]["RGF"]##gongfei
  1904. rcjID = filtered1.iloc[i]["RcjID"]
  1905. detail = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1906. filtered2 = detail[detail["RcjID"]==rcjID]
  1907. if len(filtered2) > 0:
  1908. CLBH = filtered2.iloc[0]["CLBH"]
  1909. CLMC = filtered2.iloc[0]["CLMC"]
  1910. JLDW = filtered2.iloc[0]["JLDW"]
  1911. YSJG = filtered2.iloc[0]["YSJG"]
  1912. rgde_["CLBH"] = CLBH
  1913. rgde_["CLMC"] = CLMC
  1914. rgde_["JLDW"] = JLDW
  1915. rgde_["YSJG"] = YSJG.item()
  1916. rgde_["gr"] = gr.item()
  1917. rgde_["gf"] = gf.item()
  1918. if CLBH in additional:
  1919. additional.remove(CLBH)
  1920. rgde.append(rgde_)
  1921. detail = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1922. detail = detail[detail['RcjLb'].isin([1, '1'])]
  1923. added = detail[detail['CLBH'].isin(additional)]
  1924. for _, entry in added.iterrows():
  1925. rgde_ = {}
  1926. CLBH = entry["CLBH"]
  1927. CLMC = entry["CLMC"]
  1928. JLDW = entry["JLDW"]
  1929. YSJG = entry["YSJG"]
  1930. rgde_["CLBH"] = CLBH
  1931. rgde_["CLMC"] = CLMC
  1932. rgde_["JLDW"] = JLDW
  1933. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  1934. rgde_["gr"] = 0
  1935. rgde_["gf"] = 0
  1936. rgde.append(rgde_)
  1937. ####jixie
  1938. jxde = []
  1939. jx = pd.read_csv("de/yl/JD_GuJiaJX.csv")
  1940. filtered1 = jx[jx["DEBH"]==debh]
  1941. for i in range(len(filtered1)):
  1942. jxde_ = {}
  1943. sl = filtered1.iloc[i]["SL"]##shuliang
  1944. hj = filtered1.iloc[i]["HJ"]##hejia
  1945. rcjID = filtered1.iloc[i]["RcjID"]
  1946. detail = pd.read_csv("de/yl/JD_JiXieK.csv")
  1947. filtered2 = detail[detail["RcjID"]==rcjID]
  1948. if len(filtered2) > 0:
  1949. jxbh = filtered2.iloc[0]["jxbh"]
  1950. jxmc = filtered2.iloc[0]["jxmc"]
  1951. DW = filtered2.iloc[0]["DW"]
  1952. tbdj = filtered2.iloc[0]["tbdj"]
  1953. jxde_["jxbh"] = jxbh
  1954. jxde_["jxmc"] = jxmc
  1955. jxde_["DW"] = DW
  1956. jxde_["tbdj"] = tbdj.item()
  1957. jxde_["sl"] = sl.item()
  1958. jxde_["hj"] = hj.item()
  1959. if jxbh in additional:
  1960. additional.remove(jxbh)
  1961. jxde.append(jxde_)
  1962. detail = pd.read_csv("de/yl/JD_JiXieK.csv")
  1963. added = detail[detail['jxbh'].isin(additional)]
  1964. for _, entry in added.iterrows():
  1965. jxde_ = {}
  1966. jxbh = entry["jxbh"]
  1967. jxmc = entry["jxmc"]
  1968. DW = entry["DW"]
  1969. tbdj = entry["tbdj"]
  1970. jxde_["jxbh"] = jxbh
  1971. jxde_["jxmc"] = jxmc
  1972. jxde_["DW"] = DW
  1973. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  1974. jxde_["sl"] = 0
  1975. jxde_["hj"] = 0
  1976. jxde.append(jxde_)
  1977. ####cailiao
  1978. clde = []
  1979. cl = pd.read_csv("de/yl/JD_GuJiaCL.csv")
  1980. filtered1 = cl[cl["DEBH"]==debh]
  1981. for i in range(len(filtered1)):
  1982. clde_ = {}
  1983. SL = filtered1.iloc[i]["SL"]##shuliang
  1984. HJ = filtered1.iloc[i]["HJ"]##hejia
  1985. rcjID = filtered1.iloc[i]["RcjID"]
  1986. detail = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  1987. filtered2 = detail[detail["RcjID"]==rcjID]
  1988. if len(filtered2) > 0:
  1989. CLBH = filtered2.iloc[0]["CLBH"]
  1990. CLMC = filtered2.iloc[0]["CLMC"]
  1991. JLDW = filtered2.iloc[0]["JLDW"]
  1992. YSJG = filtered2.iloc[0]["YSJG"]
  1993. clde_["CLBH"] = CLBH
  1994. clde_["CLMC"] = CLMC
  1995. clde_["JLDW"] = JLDW
  1996. clde_["YSJG"] = YSJG.item()
  1997. clde_["SL"] = SL.item()
  1998. clde_["HJ"] = HJ.item()
  1999. clde.append(clde_)
  2000. else:
  2001. detail = pd.read_csv("de/yl/JD_PeiBi.csv")
  2002. filtered2 = detail[detail["RcjID"]==rcjID]
  2003. if len(filtered2) > 0:
  2004. CLBH = filtered2.iloc[0]["PBBH"]
  2005. CLMC = filtered2.iloc[0]["PBMC"]
  2006. JLDW = filtered2.iloc[0]["DW"]
  2007. YSJG = filtered2.iloc[0]["PBDJ"]
  2008. clde_["CLBH"] = CLBH.item()
  2009. clde_["CLMC"] = CLMC
  2010. clde_["JLDW"] = JLDW
  2011. clde_["YSJG"] = YSJG.item()
  2012. clde_["SL"] = SL.item()
  2013. clde_["HJ"] = HJ.item()
  2014. clde.append(clde_)
  2015. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  2016. additional.remove(clde_['CLBH'])
  2017. detail = pd.read_csv("de/yl/JD_CaiLiaoK.csv")
  2018. detail = detail[detail['RcjLb'].isin([2, '2'])]
  2019. added = detail[detail['CLBH'].isin(additional)]
  2020. for _, entry in added.iterrows():
  2021. clde_ = {}
  2022. CLBH = entry["CLBH"]
  2023. CLMC = entry["CLMC"]
  2024. JLDW = entry["JLDW"]
  2025. YSJG = entry["YSJG"]
  2026. clde_["CLBH"] = CLBH
  2027. clde_["CLMC"] = CLMC
  2028. clde_["JLDW"] = JLDW
  2029. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2030. clde_["SL"] = 0
  2031. clde_["HJ"] = 0
  2032. clde.append(clde_)
  2033. detail = pd.read_csv("de/yl/JD_PeiBi.csv")
  2034. added = detail[detail['PBBH'].isin(additional)]
  2035. for _, entry in added.iterrows():
  2036. clde_ = {}
  2037. CLBH = entry["PBBH"]
  2038. CLMC = entry["PBMC"]
  2039. JLDW = entry["DW"]
  2040. YSJG = entry["PBDJ"]
  2041. clde_["CLBH"] = CLBH
  2042. clde_["CLMC"] = CLMC
  2043. clde_["JLDW"] = JLDW
  2044. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2045. clde_["SL"] = 0
  2046. clde_["HJ"] = 0
  2047. clde.append(clde_)
  2048. 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)
  2049. 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
  2050. def getSingleDeXilie_az(debh):
  2051. id = None
  2052. bz_selected = []
  2053. bz_selected2 = []
  2054. additional = []
  2055. if "附注" in debh:
  2056. position = debh.find("附注")
  2057. debh = debh[:position]
  2058. if "*" in debh:
  2059. position = debh.find("*")
  2060. debh = debh[:position]
  2061. if debh.endswith("换"):
  2062. debh = debh[:-1]
  2063. if "[" in debh:
  2064. position = debh.find("[")
  2065. debh = debh[:position-1]
  2066. gj = pd.read_csv("de/az/JD_DanWeiGJ.csv")
  2067. filtered = gj[gj["DEBH"]==debh]
  2068. ##print(filtered)
  2069. if len(filtered) > 0:
  2070. index = (filtered.iloc[0]["YSDELBH"])
  2071. shu = pd.read_csv("de/az/JD_DingEShu.csv")
  2072. hit = shu[shu["zjh"]==index]
  2073. if len(hit) > 0:
  2074. id = hit.iloc[0]["ID"]
  2075. beizhu = str(filtered.iloc[0]["BZBH"])
  2076. if 'nan' in beizhu:
  2077. pass
  2078. else:
  2079. beizhus = beizhu.split(";")
  2080. ##print(beizhus)
  2081. bzfile = pd.read_csv("de/az/JD_BeiZhuZK.csv")
  2082. bzfile2 = pd.read_csv("de/az/JD_BeiZhuFK.csv", dtype=str)
  2083. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  2084. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  2085. bz_selected2 = bz_selected2.astype({'BH': str})
  2086. additional = bz_selected2['BH'].tolist()
  2087. 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']]
  2088. else:
  2089. return None, None, None, None, None, None, None
  2090. ####rengong
  2091. rgde = []
  2092. rg = pd.read_csv("de/az/JD_GuJiaRG.csv")
  2093. filtered1 = rg[rg["DEBH"]==debh]
  2094. for i in range(len(filtered1)):
  2095. rgde_ = {}
  2096. gr = filtered1.iloc[i]["RGR"]##gongri
  2097. gf = filtered1.iloc[i]["RGF"]##gongfei
  2098. rcjID = filtered1.iloc[i]["RcjID"]
  2099. detail = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  2100. filtered2 = detail[detail["RcjID"]==rcjID]
  2101. if len(filtered2) > 0:
  2102. CLBH = filtered2.iloc[0]["CLBH"]
  2103. CLMC = filtered2.iloc[0]["CLMC"]
  2104. JLDW = filtered2.iloc[0]["JLDW"]
  2105. YSJG = filtered2.iloc[0]["YSJG"]
  2106. rgde_["CLBH"] = str(CLBH.item()) if type(CLBH) == int64 else CLBH
  2107. rgde_["CLMC"] = CLMC
  2108. rgde_["JLDW"] = JLDW
  2109. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2110. rgde_["gr"] = gr.item() if type(gr) == float64 else gr
  2111. rgde_["gf"] = gf.item() if type(gf) == float64 else gf
  2112. if CLBH in additional:
  2113. additional.remove(CLBH)
  2114. rgde.append(rgde_)
  2115. detail = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  2116. detail = detail[detail['RcjLb'].isin([1, '1'])]
  2117. added = detail[detail['CLBH'].isin(additional)]
  2118. for _, entry in added.iterrows():
  2119. rgde_ = {}
  2120. CLBH = entry["CLBH"]
  2121. CLMC = entry["CLMC"]
  2122. JLDW = entry["JLDW"]
  2123. YSJG = entry["YSJG"]
  2124. rgde_["CLBH"] = CLBH
  2125. rgde_["CLMC"] = CLMC
  2126. rgde_["JLDW"] = JLDW
  2127. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2128. rgde_["gr"] = 0
  2129. rgde_["gf"] = 0
  2130. rgde.append(rgde_)
  2131. ####jixie
  2132. jxde = []
  2133. jx = pd.read_csv("de/az/JD_GuJiaJX.csv")
  2134. filtered1 = jx[jx["DEBH"]==debh]
  2135. for i in range(len(filtered1)):
  2136. jxde_ = {}
  2137. sl = filtered1.iloc[i]["SL"]##shuliang
  2138. hj = filtered1.iloc[i]["HJ"]##hejia
  2139. rcjID = filtered1.iloc[i]["RcjID"]
  2140. detail = pd.read_csv("de/az/JD_JiXieK.csv")
  2141. filtered2 = detail[detail["RcjID"]==rcjID]
  2142. if len(filtered2) > 0:
  2143. jxbh = filtered2.iloc[0]["jxbh"]
  2144. jxmc = filtered2.iloc[0]["jxmc"]
  2145. DW = filtered2.iloc[0]["DW"]
  2146. tbdj = filtered2.iloc[0]["tbdj"]
  2147. jxde_["jxbh"] = jxbh
  2148. jxde_["jxmc"] = jxmc
  2149. jxde_["DW"] = DW
  2150. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2151. jxde_["sl"] = sl.item() if type(sl) == float64 else sl
  2152. jxde_["hj"] = hj.item() if type(hj) == float64 else hj
  2153. if jxbh in additional:
  2154. additional.remove(jxbh)
  2155. jxde.append(jxde_)
  2156. detail = pd.read_csv("de/az/JD_JiXieK.csv")
  2157. added = detail[detail['jxbh'].isin(additional)]
  2158. for _, entry in added.iterrows():
  2159. jxde_ = {}
  2160. jxbh = entry["jxbh"]
  2161. jxmc = entry["jxmc"]
  2162. DW = entry["DW"]
  2163. tbdj = entry["tbdj"]
  2164. jxde_["jxbh"] = jxbh
  2165. jxde_["jxmc"] = jxmc
  2166. jxde_["DW"] = DW
  2167. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2168. jxde_["sl"] = 0
  2169. jxde_["hj"] = 0
  2170. jxde.append(jxde_)
  2171. ####cailiao
  2172. clde = []
  2173. cl = pd.read_csv("de/az/JD_GuJiaCL.csv")
  2174. filtered1 = cl[cl["DEBH"]==debh]
  2175. for i in range(len(filtered1)):
  2176. clde_ = {}
  2177. SL = filtered1.iloc[i]["SL"]##shuliang
  2178. HJ = filtered1.iloc[i]["HJ"]##hejia
  2179. rcjID = filtered1.iloc[i]["RcjID"]
  2180. detail = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  2181. filtered2 = detail[detail["RcjID"]==rcjID]
  2182. if len(filtered2) > 0:
  2183. CLBH = filtered2.iloc[0]["CLBH"]
  2184. CLMC = filtered2.iloc[0]["CLMC"]
  2185. JLDW = filtered2.iloc[0]["JLDW"]
  2186. YSJG = filtered2.iloc[0]["YSJG"]
  2187. clde_["CLBH"] = str(CLBH.item()) if type(CLBH) == int64 else CLBH
  2188. clde_["CLMC"] = CLMC
  2189. clde_["JLDW"] = JLDW
  2190. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2191. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2192. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2193. clde.append(clde_)
  2194. else:
  2195. detail = pd.read_csv("de/az/JD_PeiBi.csv")
  2196. filtered2 = detail[detail["RcjID"]==rcjID]
  2197. if len(filtered2) > 0:
  2198. CLBH = filtered2.iloc[0]["PBBH"]
  2199. CLMC = filtered2.iloc[0]["PBMC"]
  2200. JLDW = filtered2.iloc[0]["DW"]
  2201. YSJG = filtered2.iloc[0]["PBDJ"]
  2202. clde_["CLBH"] = str(CLBH.item()) if type(CLBH) == int64 else CLBH
  2203. clde_["CLMC"] = CLMC
  2204. clde_["JLDW"] = JLDW
  2205. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2206. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2207. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2208. clde.append(clde_)
  2209. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  2210. additional.remove(clde_['CLBH'])
  2211. detail = pd.read_csv("de/az/JD_CaiLiaoK.csv")
  2212. detail = detail[detail['RcjLb'].isin([2, '2'])]
  2213. added = detail[detail['CLBH'].isin(additional)]
  2214. added = added.drop_duplicates(subset=['CLBH'])
  2215. for _, entry in added.iterrows():
  2216. clde_ = {}
  2217. CLBH = entry["CLBH"]
  2218. CLMC = entry["CLMC"]
  2219. JLDW = entry["JLDW"]
  2220. YSJG = entry["YSJG"]
  2221. clde_["CLBH"] = CLBH
  2222. clde_["CLMC"] = CLMC
  2223. clde_["JLDW"] = JLDW
  2224. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2225. clde_["SL"] = 0
  2226. clde_["HJ"] = 0
  2227. clde.append(clde_)
  2228. detail = pd.read_csv("de/az/JD_PeiBi.csv")
  2229. added = detail[detail['PBBH'].isin(additional)]
  2230. for _, entry in added.iterrows():
  2231. clde_ = {}
  2232. CLBH = entry["PBBH"]
  2233. CLMC = entry["PBMC"]
  2234. JLDW = entry["DW"]
  2235. YSJG = entry["PBDJ"]
  2236. clde_["CLBH"] = CLBH
  2237. clde_["CLMC"] = CLMC
  2238. clde_["JLDW"] = JLDW
  2239. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2240. clde_["SL"] = 0
  2241. clde_["HJ"] = 0
  2242. clde.append(clde_)
  2243. 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)
  2244. ##print(filtered)
  2245. 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
  2246. def getSingleDeXilie_sz(debh):
  2247. id = None
  2248. bz_selected = []
  2249. bz_selected2 = []
  2250. additional = []
  2251. if "附注" in debh:
  2252. position = debh.find("附注")
  2253. debh = debh[:position]
  2254. if "*" in debh:
  2255. position = debh.find("*")
  2256. debh = debh[:position]
  2257. if debh.endswith("换"):
  2258. debh = debh[:-1]
  2259. if "[" in debh:
  2260. position = debh.find("[")
  2261. debh = debh[:position-1]
  2262. gj = pd.read_csv("de/sz/JD_DanWeiGJ.csv")
  2263. filtered = gj[gj["DEBH"]==debh]
  2264. ##print(filtered)
  2265. if len(filtered) > 0:
  2266. index = (filtered.iloc[0]["YSDELBH"])
  2267. shu = pd.read_csv("de/sz/JD_DingEShu.csv")
  2268. hit = shu[shu["zjh"]==index]
  2269. if len(hit) > 0:
  2270. id = hit.iloc[0]["ID"]
  2271. beizhu = str(filtered.iloc[0]["BZBH"])
  2272. if 'nan' in beizhu:
  2273. pass
  2274. else:
  2275. beizhus = beizhu.split(";")
  2276. ##print(beizhus)
  2277. bzfile = pd.read_csv("de/sz/JD_BeiZhuZK.csv")
  2278. bzfile2 = pd.read_csv("de/sz/JD_BeiZhuFK.csv", dtype=str)
  2279. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  2280. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  2281. bz_selected2 = bz_selected2.astype({'BH': str})
  2282. additional = bz_selected2['BH'].tolist()
  2283. 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']]
  2284. else:
  2285. return None, None, None, None, None, None, None
  2286. ####rengong
  2287. rgde = []
  2288. rg = pd.read_csv("de/sz/JD_GuJiaRG.csv")
  2289. filtered1 = rg[rg["DEBH"]==debh]
  2290. for i in range(len(filtered1)):
  2291. rgde_ = {}
  2292. gr = filtered1.iloc[i]["RGR"]##gongri
  2293. gf = filtered1.iloc[i]["RGF"]##gongfei
  2294. rcjID = filtered1.iloc[i]["RcjID"]
  2295. detail = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  2296. filtered2 = detail[detail["RcjID"]==rcjID]
  2297. if len(filtered2) > 0:
  2298. CLBH = filtered2.iloc[0]["CLBH"]
  2299. CLMC = filtered2.iloc[0]["CLMC"]
  2300. JLDW = filtered2.iloc[0]["JLDW"]
  2301. YSJG = filtered2.iloc[0]["YSJG"]
  2302. rgde_["CLBH"] = CLBH
  2303. rgde_["CLMC"] = CLMC
  2304. rgde_["JLDW"] = JLDW
  2305. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2306. rgde_["gr"] = gr.item() if type(gr) == float64 else gr
  2307. rgde_["gf"] = gf.item() if type(gf) == float64 else gf
  2308. if CLBH in additional:
  2309. additional.remove(CLBH)
  2310. rgde.append(rgde_)
  2311. detail = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  2312. detail = detail[detail['RcjLb'].isin([1, '1'])]
  2313. added = detail[detail['CLBH'].isin(additional)]
  2314. for _, entry in added.iterrows():
  2315. rgde_ = {}
  2316. CLBH = entry["CLBH"]
  2317. CLMC = entry["CLMC"]
  2318. JLDW = entry["JLDW"]
  2319. YSJG = entry["YSJG"]
  2320. rgde_["CLBH"] = CLBH
  2321. rgde_["CLMC"] = CLMC
  2322. rgde_["JLDW"] = JLDW
  2323. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2324. rgde_["gr"] = 0
  2325. rgde_["gf"] = 0
  2326. rgde.append(rgde_)
  2327. ####jixie
  2328. jxde = []
  2329. jx = pd.read_csv("de/sz/JD_GuJiaJX.csv")
  2330. filtered1 = jx[jx["DEBH"]==debh]
  2331. for i in range(len(filtered1)):
  2332. jxde_ = {}
  2333. sl = filtered1.iloc[i]["SL"]##shuliang
  2334. hj = filtered1.iloc[i]["HJ"]##hejia
  2335. rcjID = filtered1.iloc[i]["RcjID"]
  2336. detail = pd.read_csv("de/sz/JD_JiXieK.csv")
  2337. filtered2 = detail[detail["RcjID"]==rcjID]
  2338. if len(filtered2) > 0:
  2339. jxbh = filtered2.iloc[0]["jxbh"]
  2340. jxmc = filtered2.iloc[0]["jxmc"]
  2341. DW = filtered2.iloc[0]["DW"]
  2342. tbdj = filtered2.iloc[0]["tbdj"]
  2343. jxde_["jxbh"] = jxbh
  2344. jxde_["jxmc"] = jxmc
  2345. jxde_["DW"] = DW
  2346. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2347. jxde_["sl"] = sl.item() if type(sl) == float64 else sl
  2348. jxde_["hj"] = hj.item() if type(hj) == float64 else hj
  2349. if jxbh in additional:
  2350. additional.remove(jxbh)
  2351. jxde.append(jxde_)
  2352. detail = pd.read_csv("de/sz/JD_JiXieK.csv")
  2353. added = detail[detail['jxbh'].isin(additional)]
  2354. for _, entry in added.iterrows():
  2355. jxde_ = {}
  2356. jxbh = entry["jxbh"]
  2357. jxmc = entry["jxmc"]
  2358. DW = entry["DW"]
  2359. tbdj = entry["tbdj"]
  2360. jxde_["jxbh"] = jxbh
  2361. jxde_["jxmc"] = jxmc
  2362. jxde_["DW"] = DW
  2363. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2364. jxde_["sl"] = 0
  2365. jxde_["hj"] = 0
  2366. jxde.append(jxde_)
  2367. ####cailiao
  2368. clde = []
  2369. cl = pd.read_csv("de/sz/JD_GuJiaCL.csv")
  2370. filtered1 = cl[cl["DEBH"]==debh]
  2371. for i in range(len(filtered1)):
  2372. clde_ = {}
  2373. SL = filtered1.iloc[i]["SL"]##shuliang
  2374. HJ = filtered1.iloc[i]["HJ"]##hejia
  2375. rcjID = filtered1.iloc[i]["RcjID"]
  2376. detail = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  2377. filtered2 = detail[detail["RcjID"]==rcjID]
  2378. detail_ = pd.read_csv("de/sz/JD_PeiBi.csv")
  2379. filtered2_ = detail_[detail_["RcjID"]==rcjID]
  2380. if len(filtered2) > 0 and len(filtered2_) == 0:
  2381. CLBH = filtered2.iloc[0]["CLBH"]
  2382. CLMC = filtered2.iloc[0]["CLMC"]
  2383. JLDW = filtered2.iloc[0]["JLDW"]
  2384. YSJG = filtered2.iloc[0]["YSJG"]
  2385. clde_["CLBH"] = str(CLBH.item()) if type(CLBH) == int64 else CLBH
  2386. clde_["CLMC"] = CLMC
  2387. clde_["JLDW"] = JLDW
  2388. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2389. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2390. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2391. clde.append(clde_)
  2392. elif len(filtered2) == 0 and len(filtered2_) > 0:
  2393. CLBH = filtered2_.iloc[0]["PBBH"]
  2394. CLMC = filtered2_.iloc[0]["PBMC"]
  2395. JLDW = filtered2_.iloc[0]["DW"]
  2396. YSJG = filtered2_.iloc[0]["PBDJ"]
  2397. clde_["CLBH"] = str(CLBH.item()) if type(CLBH) == int64 else CLBH
  2398. clde_["CLMC"] = CLMC
  2399. clde_["JLDW"] = JLDW
  2400. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2401. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2402. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2403. clde.append(clde_)
  2404. elif len(filtered2) > 0 and len(filtered2_) > 0:
  2405. YSJG = filtered2.iloc[0]["YSJG"]
  2406. YSJG_ = filtered2_.iloc[0]["PBDJ"]
  2407. ##print(debh)
  2408. if float(HJ) < 0.00001:
  2409. if float(YSJG) < 0.00001:
  2410. CLBH = filtered2.iloc[0]["CLBH"]
  2411. CLMC = filtered2.iloc[0]["CLMC"]
  2412. JLDW = filtered2.iloc[0]["JLDW"]
  2413. YSJG = filtered2.iloc[0]["YSJG"]
  2414. clde_["CLBH"] = str(CLBH.item()) if type(CLBH) == int64 else CLBH
  2415. clde_["CLMC"] = CLMC
  2416. clde_["JLDW"] = JLDW
  2417. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2418. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2419. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2420. clde.append(clde_)
  2421. elif float(YSJG_) < 0.00001:
  2422. CLBH = filtered2_.iloc[0]["PBBH"]
  2423. CLMC = filtered2_.iloc[0]["PBMC"]
  2424. JLDW = filtered2_.iloc[0]["DW"]
  2425. YSJG = filtered2_.iloc[0]["PBDJ"]
  2426. clde_["CLBH"] = str(CLBH.item()) if type(CLBH) == int64 else CLBH
  2427. clde_["CLMC"] = CLMC
  2428. clde_["JLDW"] = JLDW
  2429. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2430. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2431. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2432. clde.append(clde_)
  2433. else:
  2434. ratio = float(YSJG) / (float(HJ) / float(SL))
  2435. ratio_ = float(YSJG_) / (float(HJ) / float(SL))
  2436. if abs(ratio - 1) < abs(ratio_ - 1):
  2437. CLBH = filtered2.iloc[0]["CLBH"]
  2438. CLMC = filtered2.iloc[0]["CLMC"]
  2439. JLDW = filtered2.iloc[0]["JLDW"]
  2440. YSJG = filtered2.iloc[0]["YSJG"]
  2441. clde_["CLBH"] = str(CLBH.item()) if type(CLBH) == int64 else CLBH
  2442. clde_["CLMC"] = CLMC
  2443. clde_["JLDW"] = JLDW
  2444. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2445. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2446. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2447. clde.append(clde_)
  2448. else:
  2449. CLBH = filtered2_.iloc[0]["PBBH"]
  2450. CLMC = filtered2_.iloc[0]["PBMC"]
  2451. JLDW = filtered2_.iloc[0]["DW"]
  2452. YSJG = filtered2_.iloc[0]["PBDJ"]
  2453. clde_["CLBH"] = str(CLBH.item()) if type(CLBH) == int64 else CLBH
  2454. clde_["CLMC"] = CLMC
  2455. clde_["JLDW"] = JLDW
  2456. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2457. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2458. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2459. clde.append(clde_)
  2460. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  2461. additional.remove(clde_['CLBH'])
  2462. detail = pd.read_csv("de/sz/JD_CaiLiaoK.csv")
  2463. detail = detail[detail['RcjLb'].isin([2, '2'])]
  2464. added = detail[detail['CLBH'].isin(additional)]
  2465. for _, entry in added.iterrows():
  2466. clde_ = {}
  2467. CLBH = entry["CLBH"]
  2468. CLMC = entry["CLMC"]
  2469. JLDW = entry["JLDW"]
  2470. YSJG = entry["YSJG"]
  2471. clde_["CLBH"] = CLBH
  2472. clde_["CLMC"] = CLMC
  2473. clde_["JLDW"] = JLDW
  2474. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2475. clde_["SL"] = 0
  2476. clde_["HJ"] = 0
  2477. clde.append(clde_)
  2478. detail = pd.read_csv("de/sz/JD_PeiBi.csv")
  2479. added = detail[detail['PBBH'].isin(additional)]
  2480. for _, entry in added.iterrows():
  2481. clde_ = {}
  2482. CLBH = entry["PBBH"]
  2483. CLMC = entry["PBMC"]
  2484. JLDW = entry["DW"]
  2485. YSJG = entry["PBDJ"]
  2486. clde_["CLBH"] = CLBH
  2487. clde_["CLMC"] = CLMC
  2488. clde_["JLDW"] = JLDW
  2489. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2490. clde_["SL"] = 0
  2491. clde_["HJ"] = 0
  2492. clde.append(clde_)
  2493. 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)
  2494. 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
  2495. def getSingleDeXilie_tj(debh):
  2496. id = None
  2497. bz_selected = []
  2498. bz_selected2 = []
  2499. additional = []
  2500. if "附注" in debh:
  2501. position = debh.find("附注")
  2502. debh = debh[:position]
  2503. if "*" in debh:
  2504. position = debh.find("*")
  2505. debh = debh[:position]
  2506. if debh.endswith("换"):
  2507. debh = debh[:-1]
  2508. if "[" in debh:
  2509. position = debh.find("[")
  2510. debh = debh[:position-1]
  2511. gj = pd.read_csv("de/tj/JD_DanWeiGJ.csv")
  2512. filtered = gj[gj["DEBH"]==debh]
  2513. ##print(filtered)
  2514. if len(filtered) > 0:
  2515. index = int(filtered.iloc[0]["YSDELBH"])
  2516. shu = pd.read_csv("de/tj/JD_DingEShu.csv")
  2517. hit = shu[shu["zjh"]==index]
  2518. if len(hit) > 0:
  2519. id = hit.iloc[0]["ID"]
  2520. beizhu = str(filtered.iloc[0]["BZBH"])
  2521. if 'nan' in beizhu:
  2522. pass
  2523. else:
  2524. beizhus = beizhu.split(";")
  2525. ##print(beizhus)
  2526. bzfile = pd.read_csv("de/tj/JD_BeiZhuZK.csv")
  2527. bzfile2 = pd.read_csv("de/tj/JD_BeiZhuFK.csv", dtype=str)
  2528. bz_selected = bzfile[bzfile["BZBH"].isin(beizhus)]
  2529. bz_selected2 = bzfile2[bzfile2["BZBH"].isin(beizhus)]
  2530. bz_selected2 = bz_selected2.astype({'BH': str})
  2531. additional = bz_selected2['BH'].tolist()
  2532. 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']]
  2533. else:
  2534. return None, None, None, None, None, None, None
  2535. ####rengong
  2536. rgde = []
  2537. rg = pd.read_csv("de/tj/JD_GuJiaRG.csv")
  2538. filtered1 = rg[rg["DEBH"]==debh]
  2539. for i in range(len(filtered1)):
  2540. rgde_ = {}
  2541. gr = filtered1.iloc[i]["RGR"]##gongri
  2542. gf = filtered1.iloc[i]["RGF"]##gongfei
  2543. rcjID = filtered1.iloc[i]["RcjID"]
  2544. detail = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  2545. filtered2 = detail[detail["RcjID"]==rcjID]
  2546. if 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. rgde_["CLBH"] = CLBH
  2552. rgde_["CLMC"] = CLMC
  2553. rgde_["JLDW"] = JLDW
  2554. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2555. rgde_["gr"] = gr.item() if type(gr) == float64 else gr
  2556. rgde_["gf"] = gf.item() if type(gf) == float64 else gf
  2557. if CLBH in additional:
  2558. additional.remove(CLBH)
  2559. rgde.append(rgde_)
  2560. detail = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  2561. detail = detail[detail['RcjLb'].isin([1, '1'])]
  2562. added = detail[detail['CLBH'].isin(additional)]
  2563. for _, entry in added.iterrows():
  2564. rgde_ = {}
  2565. CLBH = entry["CLBH"]
  2566. CLMC = entry["CLMC"]
  2567. JLDW = entry["JLDW"]
  2568. YSJG = entry["YSJG"]
  2569. rgde_["CLBH"] = CLBH
  2570. rgde_["CLMC"] = CLMC
  2571. rgde_["JLDW"] = JLDW
  2572. rgde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2573. rgde_["gr"] = 0
  2574. rgde_["gf"] = 0
  2575. rgde.append(rgde_)
  2576. ####jixie
  2577. jxde = []
  2578. jx = pd.read_csv("de/tj/JD_GuJiaJX.csv")
  2579. filtered1 = jx[jx["DEBH"]==debh]
  2580. for i in range(len(filtered1)):
  2581. jxde_ = {}
  2582. sl = filtered1.iloc[i]["SL"]##shuliang
  2583. hj = filtered1.iloc[i]["HJ"]##hejia
  2584. rcjID = filtered1.iloc[i]["RcjID"]
  2585. detail = pd.read_csv("de/tj/JD_JiXieK.csv")
  2586. filtered2 = detail[detail["RcjID"]==rcjID]
  2587. if len(filtered2) > 0:
  2588. jxbh = filtered2.iloc[0]["jxbh"]
  2589. jxmc = filtered2.iloc[0]["jxmc"]
  2590. DW = filtered2.iloc[0]["DW"]
  2591. tbdj = filtered2.iloc[0]["tbdj"]
  2592. jxde_["jxbh"] = jxbh
  2593. jxde_["jxmc"] = jxmc
  2594. jxde_["DW"] = DW
  2595. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2596. jxde_["sl"] = sl.item() if type(sl) == float64 else sl
  2597. jxde_["hj"] = hj.item() if type(hj) == float64 else hj
  2598. if jxbh in additional:
  2599. additional.remove(jxbh)
  2600. jxde.append(jxde_)
  2601. detail = pd.read_csv("de/tj/JD_JiXieK.csv")
  2602. added = detail[detail['jxbh'].isin(additional)]
  2603. for _, entry in added.iterrows():
  2604. jxde_ = {}
  2605. jxbh = entry["jxbh"]
  2606. jxmc = entry["jxmc"]
  2607. DW = entry["DW"]
  2608. tbdj = entry["tbdj"]
  2609. jxde_["jxbh"] = jxbh
  2610. jxde_["jxmc"] = jxmc
  2611. jxde_["DW"] = DW
  2612. jxde_["tbdj"] = tbdj.item() if type(tbdj) == float64 else tbdj
  2613. jxde_["sl"] = 0
  2614. jxde_["hj"] = 0
  2615. jxde.append(jxde_)
  2616. clde = []
  2617. cl = pd.read_csv("de/tj/JD_GuJiaCL.csv")
  2618. filtered1 = cl[cl["DEBH"]==debh]
  2619. for i in range(len(filtered1)):
  2620. clde_ = {}
  2621. SL = filtered1.iloc[i]["SL"]##shuliang
  2622. HJ = filtered1.iloc[i]["HJ"]##hejia
  2623. rcjID = filtered1.iloc[i]["RcjID"]
  2624. detail = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  2625. filtered2 = detail[detail["RcjID"]==rcjID]
  2626. detail_ = pd.read_csv("de/tj/JD_PeiBi.csv")
  2627. filtered2_ = detail_[detail_["RcjID"]==rcjID]
  2628. if len(filtered2) > 0 and len(filtered2_) == 0:
  2629. CLBH = filtered2.iloc[0]["CLBH"]
  2630. CLMC = filtered2.iloc[0]["CLMC"]
  2631. JLDW = filtered2.iloc[0]["JLDW"]
  2632. YSJG = filtered2.iloc[0]["YSJG"]
  2633. clde_["CLBH"] = CLBH
  2634. clde_["CLMC"] = CLMC
  2635. clde_["JLDW"] = JLDW
  2636. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2637. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2638. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2639. clde.append(clde_)
  2640. elif len(filtered2) == 0 and len(filtered2_) > 0:
  2641. CLBH = filtered2_.iloc[0]["PBBH"]
  2642. CLMC = filtered2_.iloc[0]["PBMC"]
  2643. JLDW = filtered2_.iloc[0]["DW"]
  2644. YSJG = filtered2_.iloc[0]["PBDJ"]
  2645. clde_["CLBH"] = CLBH
  2646. clde_["CLMC"] = CLMC
  2647. clde_["JLDW"] = JLDW
  2648. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2649. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2650. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2651. clde.append(clde_)
  2652. elif len(filtered2) > 0 and len(filtered2_) > 0:
  2653. YSJG = filtered2.iloc[0]["YSJG"]
  2654. YSJG_ = filtered2_.iloc[0]["PBDJ"]
  2655. if float(HJ) < 0.00001:
  2656. if float(YSJG) < 0.00001:
  2657. CLBH = filtered2.iloc[0]["CLBH"]
  2658. CLMC = filtered2.iloc[0]["CLMC"]
  2659. JLDW = filtered2.iloc[0]["JLDW"]
  2660. YSJG = filtered2.iloc[0]["YSJG"]
  2661. clde_["CLBH"] = CLBH
  2662. clde_["CLMC"] = CLMC
  2663. clde_["JLDW"] = JLDW
  2664. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2665. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2666. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2667. clde.append(clde_)
  2668. elif float(YSJG_) < 0.00001:
  2669. CLBH = filtered2_.iloc[0]["PBBH"]
  2670. CLMC = filtered2_.iloc[0]["PBMC"]
  2671. JLDW = filtered2_.iloc[0]["DW"]
  2672. YSJG = filtered2_.iloc[0]["PBDJ"]
  2673. clde_["CLBH"] = CLBH
  2674. clde_["CLMC"] = CLMC
  2675. clde_["JLDW"] = JLDW
  2676. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2677. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2678. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2679. clde.append(clde_)
  2680. else:
  2681. ratio = float(YSJG) / (float(HJ) / float(SL))
  2682. ratio_ = float(YSJG_) / (float(HJ) / float(SL))
  2683. if abs(ratio - 1) < abs(ratio_ - 1):
  2684. CLBH = filtered2.iloc[0]["CLBH"]
  2685. CLMC = filtered2.iloc[0]["CLMC"]
  2686. JLDW = filtered2.iloc[0]["JLDW"]
  2687. YSJG = filtered2.iloc[0]["YSJG"]
  2688. clde_["CLBH"] = CLBH
  2689. clde_["CLMC"] = CLMC
  2690. clde_["JLDW"] = JLDW
  2691. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2692. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2693. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2694. clde.append(clde_)
  2695. else:
  2696. CLBH = filtered2_.iloc[0]["PBBH"]
  2697. CLMC = filtered2_.iloc[0]["PBMC"]
  2698. JLDW = filtered2_.iloc[0]["DW"]
  2699. YSJG = filtered2_.iloc[0]["PBDJ"]
  2700. clde_["CLBH"] = CLBH
  2701. clde_["CLMC"] = CLMC
  2702. clde_["JLDW"] = JLDW
  2703. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2704. clde_["SL"] = SL.item() if type(SL) == float64 else SL
  2705. clde_["HJ"] = HJ.item() if type(HJ) == float64 else HJ
  2706. clde.append(clde_)
  2707. if 'CLBH' in clde_ and clde_['CLBH'] in additional:
  2708. additional.remove(clde_['CLBH'])
  2709. detail = pd.read_csv("de/tj/JD_CaiLiaoK.csv")
  2710. detail = detail[detail['RcjLb'].isin([2, '2'])]
  2711. added = detail[detail['CLBH'].isin(additional)]
  2712. added = added.drop_duplicates(subset=['CLBH'])
  2713. for _, entry in added.iterrows():
  2714. clde_ = {}
  2715. CLBH = entry["CLBH"]
  2716. CLMC = entry["CLMC"]
  2717. JLDW = entry["JLDW"]
  2718. YSJG = entry["YSJG"]
  2719. clde_["CLBH"] = CLBH
  2720. clde_["CLMC"] = CLMC
  2721. clde_["JLDW"] = JLDW
  2722. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2723. clde_["SL"] = 0
  2724. clde_["HJ"] = 0
  2725. clde.append(clde_)
  2726. detail = pd.read_csv("de/tj/JD_PeiBi.csv")
  2727. added = detail[detail['PBBH'].isin(additional)]
  2728. for _, entry in added.iterrows():
  2729. clde_ = {}
  2730. CLBH = entry["PBBH"]
  2731. CLMC = entry["PBMC"]
  2732. JLDW = entry["DW"]
  2733. YSJG = entry["PBDJ"]
  2734. clde_["CLBH"] = CLBH
  2735. clde_["CLMC"] = CLMC
  2736. clde_["JLDW"] = JLDW
  2737. clde_["YSJG"] = YSJG.item() if type(YSJG) == float64 else YSJG
  2738. clde_["SL"] = 0
  2739. clde_["HJ"] = 0
  2740. clde.append(clde_)
  2741. 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)
  2742. 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
  2743. def getDwgc(root, id, Zylb):
  2744. result = []
  2745. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  2746. item = None
  2747. for child in root:
  2748. if child.tag == "Dxgcxx":
  2749. for child1 in child:
  2750. Dwgcbh = child1.attrib["Dwgcbh"]
  2751. if Dwgcbh == id:
  2752. item = child1
  2753. break
  2754. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  2755. id = id + "Zylb" + Zylb
  2756. for child in item:
  2757. if child.tag == "Fywj":
  2758. result.append({"id": id + "bao jia hui zong", "label": "报价汇总表"})
  2759. elif child.tag == "Gfsj":
  2760. result.append({"id": id + "gui fei shui jin", "label": "规费税金"})
  2761. elif child.tag == "Qdxm":
  2762. result.append({"id": id + "qing dan xiang mu", "label": "清单项目"})
  2763. elif child.tag == "Csxm":
  2764. result.append({"id": id + "cuo shi xiang mu", "label": "措施项目"})
  2765. elif child.tag == "Qtxm":
  2766. result.append({"id": id +"qi ta xiang mu", "label": "其他项目"})
  2767. elif child.tag == "Zlje":
  2768. result.append({"id": id +"zan lie jin e", "label": "暂列金额"})
  2769. elif child.tag == "Clzg":
  2770. result.append({"id": id +"cai liao zan gu jia", "label": "材料暂估价"})
  2771. elif child.tag == "Zygczg":
  2772. result.append({"id": id + "zhuan ye gong cheng zan gu jia", "label": "专业工程暂估价"})
  2773. elif child.tag == "Jrg":
  2774. result.append({"id": id + "ji ri gong", "label": "计日工"})
  2775. elif child.tag == "Zcbfwf":
  2776. result.append({"id": id + "zong cheng bao fu wu fei", "label": "总承包服务费"})
  2777. elif child.tag == "Zjxmjdkzffj":
  2778. result.append({"id": id + "zong jia xiang mu jin du kuan zhi fu fen jie", "label": "总价项目进度款支付分解"})
  2779. elif child.tag == "Fbrgycl":
  2780. result.append({"id": id + "fa bao ren gong ying cai liao", "label": "发包人供应材料"})
  2781. elif child.tag == "Cbrgycl":
  2782. result.append({"id": id + "cheng bao ren gong ying cai liao", "label": "承包人供应材料"})
  2783. elif child.tag == "Rcjhz":
  2784. result.append({"id": id + "ren cai ji hui zong", "label": "人材机汇总"})
  2785. else:
  2786. print(child.tag)
  2787. print("WARNING####################################################################")
  2788. return result
  2789. def getDjcs(root, id):
  2790. result = []
  2791. #result.append(["ming cheng", "jin e", "zan gu jia", "anquan wenming fei", "guifei"])
  2792. item = None
  2793. for child in root:
  2794. if child.tag == "Dxgcxx":
  2795. for child1 in child:
  2796. Dwgcbh = child1.attrib["Dwgcbh"]
  2797. if Dwgcbh == id:
  2798. item = child1
  2799. break
  2800. ##result.append([child.attrib["Dxgcmc"], child.attrib["Je"], child.attrib["Zgj"], child.attrib["Aqwmf"], child.attrib["Gf"]])
  2801. Fywj = None
  2802. for child in item:
  2803. if child.tag == 'Csxm':
  2804. Fywj= child
  2805. break
  2806. Djcs_parent = None
  2807. for child in Fywj:
  2808. if child.tag == 'DjCs':
  2809. Djcs_parent = child
  2810. break
  2811. for child in Djcs_parent:
  2812. ##child is mx {
  2813. result.append({
  2814. "序号": child.attrib["Xh"], "清单编码": child.attrib["Bm"], "名称" : child.attrib["Mc"],
  2815. "项目特征" : child.attrib["Xmtz"],
  2816. "计算规则" : child.attrib["Jsgz"], "单位" : child.attrib["Dw"], "数量" : child.attrib["Sl"],
  2817. "综合单价" : child.attrib["Zhdj"], "合价" : child.attrib["Zhhj"], "人工费" : child.attrib["Rgf"],
  2818. "主材费" : child.attrib["Zcf"],
  2819. "设备费" : child.attrib["Sbf"], "辅材费" : child.attrib["Fcf"], "材料费" : child.attrib["Clf"],
  2820. "机械费" : child.attrib["Jxf"], "管理费" : child.attrib["Glf"], "利润" : child.attrib["Lr"],
  2821. "暂估价" : child.attrib["Zgj"], "综合人工工日" : child.attrib["Zgr"] })
  2822. __children = []
  2823. zj_parent = None
  2824. for grandchild in child:
  2825. if grandchild.tag == "Csxdezj":
  2826. zj_parent = grandchild
  2827. if zj_parent:
  2828. for entry in zj_parent:
  2829. key = str(uuid.uuid4())
  2830. entry.set("key", key)
  2831. __children.append({
  2832. "key": key,
  2833. "序号": None, "清单编码": entry.attrib["Debm"], "名称" : entry.attrib["Mc"],
  2834. "项目特征" : None,
  2835. "计算规则" : None, "单位" : entry.attrib["Dw"], "数量" : entry.attrib["DwQdSl"],
  2836. "综合单价" : entry.attrib["Dj"], "合价" : entry.attrib["Hj"], "人工费" : entry.attrib["Rgf"],
  2837. "主材费" : entry.attrib["Zcf"],
  2838. "设备费" : entry.attrib["Sbf"], "辅材费" : entry.attrib["Fcf"], "材料费" : entry.attrib["Clf"],
  2839. "机械费" : entry.attrib["Jxf"], "管理费" : entry.attrib["Glf"], "利润" : entry.attrib["Lr"],
  2840. "暂估价" : None, "综合人工工日" : None })
  2841. if len(__children) > 0:
  2842. result[-1]["__children"] = __children
  2843. return result