42 lines
1.2 KiB
Python
42 lines
1.2 KiB
Python
from lib.all import *
|
|
|
|
col_zone_moment = MongoDB(
|
|
host="mongodb://root:Wishpal2024@dds-bp1da1ddd62bede41.mongodb.rds.aliyuncs.com:3717,dds-bp1da1ddd62bede42.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-77304659",
|
|
port=3717,
|
|
db="zone_moment",
|
|
collection="zone_moment"
|
|
)
|
|
|
|
col_zone_moment_price = MongoDB(
|
|
host="mongodb://root:Wishpal2024@dds-bp1da1ddd62bede41.mongodb.rds.aliyuncs.com:3717,dds-bp1da1ddd62bede42.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-77304659",
|
|
port=3717,
|
|
db="vas",
|
|
collection="zone_moment_price"
|
|
)
|
|
|
|
lis = col_zone_moment.find(
|
|
{"c_type": 1}, projection={"_id": 1, "price": 1}
|
|
)
|
|
|
|
for m in lis:
|
|
mmid = safe_get_int(m, "_id")
|
|
price = safe_get_int(m, "price")
|
|
|
|
vas_moment = col_zone_moment_price.find_one({"_id": mmid})
|
|
vas_price = safe_get_int(vas_moment, "price")
|
|
|
|
if price != vas_price:
|
|
q = {
|
|
"_id": mmid,
|
|
}
|
|
up = {
|
|
"$set": {
|
|
"price": price
|
|
}
|
|
}
|
|
ret = col_zone_moment_price.update_one(q, up)
|
|
print(mmid, price, vas_price, ret.modified_count)
|
|
|
|
col_zone_moment.close()
|
|
col_zone_moment_price.close()
|