qingdan/loadmongo3.py

import pymongo
import pandas
import json
from pymongo import MongoClient
client = MongoClient("mongodb://owner:Pheecian1@47.101.198.30:27017/dinge")
#client = MongoClient()
db = client["dinge"]
collection = db["de-collection"]
from subdir import service
##print(collection.find_one({"DEBH": "3-94"}))
def handle_cl(cl):
    result = {}
    result["CLBH"] = cl["CLBH"]
    result["CLMC"] = cl["CLMC"]
    result["JLDW"] = cl["JLDW"]
    result["YSJG"] = cl["YSJG"]
    result["SL"] = cl["SL"]
    result["HJ"] = cl["HJ"]
    return result
def handle_rg(rg):
    result = {}
    result["CLBH"] = rg["CLBH"]
    result["CLMC"] = rg["CLMC"]
    result["JLDW"] = rg["JLDW"]
    result["YSJG"] = rg["YSJG"]
    result["gr"] = rg["gr"]
    result["gf"] = rg["gf"]
    return result
def handle_jx(jx):
    result = {}
    result["jxbh"] = jx["jxbh"]
    result["jxmc"] = jx["jxmc"]
    result["DW"] = jx["DW"]
    result["tbdj"] = jx["tbdj"]
    result["sl"] = jx["sl"]
    result["hj"] = jx["hj"]
    return result
df = pandas.read_csv("de/tj/JD_DanWeiGJ.csv", dtype='str')
#for i in range(len(df)):
#    print(df.iloc[i]['DEBH'])
#    print(df.iloc[i]['GCLMC'])
    
#    newvalues = { "$set": { "GCLMC": df.iloc[i]['GCLMC']
                            
#                            } }

#    myquery = { "zhuanye": "土建",
      #      "DEBH": '16-334'
#                "DEBH": df.iloc[i]['DEBH']
#                }
#NT5-补1    南通补充定额 南通补充定额2014 气压焊 气压焊 钢筋工程
##4463,4464,NT8-补1,构件安装 蒸压轻质加气砼隔墙板(ALC板) 墙板厚度100mm,,0.0,984.39,0.75,425.0,,,,,,1410.14,1567.67,,,10m2,,,,,00000702,,,0B0068;0B0069;0B0070;0B0071;0B0072;0B0073;0B0074,,10,,,,,构件场内运输、就位堆放、切割、安装校正、固定、修整、1:3水泥砂浆座浆、勾缝、打胶、板面清扫。,,,0,,,,,8521
#4464,4465,NT8-补2,构件安装 蒸压轻质加气砼隔墙板(ALC板) 墙板厚度150mm,,0.0,1293.48,1.11,552.5,,,,,,1847.09,2051.92,,,10m2,,,,,00000702,,,0B0068;0B0069;0B0070;0B0071;0B0072;0B0073;0B0074,,10,,,,,构件场内运输、就位堆放、切割、安装校正、固定、修整、1:3水泥砂浆座浆、勾缝、打胶、板面清扫。,,,0,,,,,8522
#4465,4466,NT8-补3,构件安装 蒸压轻质加气砼隔墙板(ALC板) 墙板厚度200mm

#NT10-补20 南通补充定额 南通补充定额2020 干铺卷材 干铺卷材 屋面及防水工程
#NT16-补1 南通补充定额 南通补充定额2023 节能塑木附框 节能塑木附框制作安装 铝合金窗

#盐补4-1 城补充定额 盐城补充定额2018 2:1碎砖细砂垫层 电动夯实  基础垫层
#盐补4-2 盐城补充定额 盐城补充定额2018 2:1碎砖细砂垫层 压路机
#盐补4-3 盐城补充定额 盐城补充定额2018 1.5:1碎砖细砂垫层 电动夯实
#盐补4-4 盐城补充定额 盐城补充定额2018 1.5:1碎砖细砂垫层 压路机
#盐补4-5 盐城补充定额 盐城补充定额2018 1:1碎砖细砂垫层 电动夯实
#盐补4-6 盐城补充定额 盐城补充定额2018 1:1碎砖细砂垫层 压路机
#盐补4-7 盐城补充定额 盐城补充定额2018 1:1.5碎砖细砂垫层 电动夯实
#盐补4-8 盐城补充定额 盐城补充定额2018 1:1.5碎砖细砂垫层 压路机

#盐补10-1 盐城补充定额 盐城补充定额2018 屋面泡沫混凝土找坡  屋面防水
#盐补10-120 盐城补充定额 盐城补充定额2018 水泥基渗透结晶防水每增减0.5mm厚 平面立面及其它防水 涂刷油类

#盐补14-1 盐城补充定额 盐城补充定额2018 彩钢压型板墙 竖向排版 墙柱面工程
#盐补14-2 盐城补充定额 盐城补充定额2018 彩钢压型板墙 横向排版

#盐补15-1 盐城补充定额 盐城补充定额2018 不锈钢骨架制安 天棚工程 天棚龙骨
#盐补15-2 盐城补充定额 盐城补充定额2018 吊顶铝塑板安装在钢骨架上 天棚工程 铝塑板面层
#盐补15-3 盐城补充定额 盐城补充定额2018 吊顶铝格栅安装 方格铝格栅 100*100 天棚工程 天棚面层及饰面
#盐补15-5 盐城补充定额 盐城补充定额2018 石材块料面板 零星工程 水泥砂浆 天棚工程 天棚面层及饰面
#盐补15-6 盐城补充定额 盐城补充定额2018 铝合金微孔方板天棚面层 嵌入式 天棚工程 天棚面层及饰面

#淮补1-1 安补充定额 淮安补充定额2024 盘扣式钢管支撑架补充计价定额 盘扣式支撑架 模板工程       
#    collection.update_one(myquery, newvalues)
mapping=['15-38','15-39','15-40','15-41']
mapping2={}
for i in range(len(df)):
    if df.iloc[i]['DEBH'] in mapping:
        print(df.iloc[i]['DEBH'])
        print(df.iloc[i]['GCLMC'])
        newvalues = { "$set": { "GCLMC": df.iloc[i]['GCLMC']
                            
                            } }

        myquery = { "zhuanye": "土建",
      #      "DEBH": '16-334'
                "DEBH": df.iloc[i]['DEBH']
                }
                
        collection.update_one(myquery, newvalues)