update

bigdata_django/zhijian/cbd_zhijian.py

@@ -1,5 +1,6 @@
 from asyncio import ensure_future, shield
 from concurrent.futures import process
+from platform import python_build
 from turtle import st
 from PyQt5 import QtCore, QtGui, QtWidgets
 import shutil
@@ -193,16 +194,16 @@ class Ui_MainWindow(object):
         self.startTimeLabel.setObjectName("startTimeLabel")
         self.startTimeEdit = QtWidgets.QDateTimeEdit(self.centralwidget)
         self.startTimeEdit.setGeometry(QtCore.QRect(310, 210, 151, 21))
-        self.startTimeEdit.setMaximumDateTime(QtCore.QDateTime(QtCore.QDate(2025, 12, 31), QtCore.QTime(23, 59, 59)))
-        self.startTimeEdit.setMinimumDateTime(QtCore.QDateTime(QtCore.QDate(2023, 1, 1), QtCore.QTime(12, 0, 0)))
+        self.startTimeEdit.setMaximumDateTime(QtCore.QDateTime(QtCore.QDate(2028, 12, 31), QtCore.QTime(23, 59, 59)))
+        self.startTimeEdit.setMinimumDateTime(QtCore.QDateTime(QtCore.QDate(2024, 1, 1), QtCore.QTime(12, 0, 0)))
         self.startTimeEdit.setObjectName("startTimeEdit")
         self.endTimeLabel = QtWidgets.QLabel(self.centralwidget)
         self.endTimeLabel.setGeometry(QtCore.QRect(180, 250, 121, 21))
         self.endTimeLabel.setObjectName("endTimeLabel")
         self.endTimeEdit = QtWidgets.QDateTimeEdit(self.centralwidget)
         self.endTimeEdit.setGeometry(QtCore.QRect(310, 250, 151, 21))
-        self.endTimeEdit.setMaximumDateTime(QtCore.QDateTime(QtCore.QDate(2025, 12, 31), QtCore.QTime(23, 59, 59)))
-        self.endTimeEdit.setMinimumDateTime(QtCore.QDateTime(QtCore.QDate(2023, 1, 1), QtCore.QTime(12, 0, 0)))
+        self.endTimeEdit.setMaximumDateTime(QtCore.QDateTime(QtCore.QDate(2028, 12, 31), QtCore.QTime(23, 59, 59)))
+        self.endTimeEdit.setMinimumDateTime(QtCore.QDateTime(QtCore.QDate(2024, 1, 1), QtCore.QTime(12, 0, 0)))
         self.endTimeEdit.setObjectName("endTimeEdit")
         self.platLabel = QtWidgets.QLabel(self.centralwidget)
         self.platLabel.setGeometry(QtCore.QRect(180, 290, 121, 21))
@@ -596,10 +597,14 @@ class CBDThread(QtCore.QThread):
             os.makedirs(local_dir) if not os.path.exists(local_dir) else None
             print(photo_addr, "----------img----------")
             # response = requests.get(f"https://bigdata-image.oss-cn-hangzhou.aliyuncs.com/Basics/cbd/{photo_addr}")
-            response = requests.get(f"http://8.136.98.49:8003/Basics/cbd/{photo_addr}")
+            if "ftp" in photo_addr:
+                response = requests.get(photo_addr)
+            else:
+                response = requests.get(f"http://8.136.98.49:8003/Basics/cbd/{photo_addr}")
             with open(os.path.join(local_dir, file_name), 'wb') as f:
                 f.write(response.content)
             result_score = self.predict(os.path.join(local_dir, file_name))
+            print(result_score)
             if result_score:
                 avg_score = sum(result_score)/len(result_score)
                 scores_time[str(addtime)] = avg_score

temp/datetime_year_month.py

@@ -0,0 +1,29 @@
+
+import paho.mqtt.client as mqtt
+
+User = "yfkj"
+Passwd = "yfkj"
+HOST = "121.43.122.145"
+PORT = 1883
+
+pub = [('/zhai/test/#', 0)]
+
+def on_message(client, userdata, msg):
+    """接收到消息的回调方法"""
+    print(msg.topic, msg.payload)
+
+def on_connect(client, userdata, flags, rc):
+    '''mqtt 连接成功后的回调'''
+    client.subscribe(pub)
+    msg = """大数据平台 MQTT 订阅:
+{}
+""".format('\n'.join([i[0] for i in pub]))
+    print(msg)
+    print('--------------')
+
+client = mqtt.Client()
+client.username_pw_set(User, Passwd)  # 必须设置，否则会返回「Connected with result code 4」
+client.on_connect = on_connect
+client.on_message = on_message
+client.connect(HOST, PORT, 30)
+client.loop_forever()

temp/send_data.py

@@ -49,6 +49,7 @@ def sim_info(iccid):
                 sign = (md5.hexdigest()).upper()
                 url = f"http://hywx.xjict.com:32040/api/v1/getChaxun?userId={userId}&cardno={iccid}&times={timestamp_now}&sign={sign}"
                 ret = requests.get(url,timeout=(10,30))
+                print(url)
                 print("第四个：", json.loads(ret.text))
                 status = 4
     except:
@@ -74,5 +75,5 @@ def sim_info(iccid):
         return [0, "查询无结果"]
 
 
-# for i in iccids_list:
-sim_info("898604F81623D0406531")
+# for i in iccids_list:  89860496162181190059  
+sim_info("89860496162181190059")

temp/xph_ele.py

@@ -0,0 +1,13 @@
+import pandas as pd 
+import json
+
+data = pd.read_excel("新普惠水肥.xlsx")
+data = data.fillna(0)
+# 将数据转换为字典
+data_str = data.applymap(lambda x: str(x) if isinstance(x, float) else x)
+dict_data = data_str.to_dict(orient='records')
+result = {}
+for i in dict_data:
+    result[str(i.get("index"))] = i
+with open("xph_ele.json", "w", encoding="utf-8") as k:
+    json.dump(result, k, ensure_ascii=False, indent=4)

tools/sim_info.py

@@ -49,7 +49,7 @@ def sim_updata(iccid):
         status = 0
         ret = 0
     day = 0
-    print(ret)
+    print(status, ret)
     if ret:
         try:
             result = json.loads(ret.text)
@@ -101,5 +101,5 @@ if __name__ == "__main__":
     # result = sim_info("89860480192280587662")
     
     # result = sim_updata("89860480192280587662")
-    result = sim_updata("89860492192090432038")
+    result = sim_updata("898604C32622D0173770")
     print(result)