service.py 130 KB

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