U
|
ù#;e³- ã @ s¾ d dl mZ d dlmZmZmZmZmZmZm Z d dl
|
m Z G dd dej Z G dd dej ZG dd d ej ZG d
|
d d ej ZG d d d ej ZG dd dej ZG dd dej ZdS )é )Údb_conn)ÚColumnÚIntegerÚStringÚDATETIMEÚDOUBLEÚBOOLEANÚTEXT)Ú DateUtilsc @ sp e Zd ZdZdZeeddddZeedddZ eed d
|
dZ
|
eed d dZ ee d dZ eed ddZdS )Ú LoginInfou ç»å½ä¿¡æ¯è¡¨Zdu_js_t_login_infoTõ ä¸»é®©Ú primary_keyÚ autoincrementÚdocé2 u ç»å½è´¦å·©r éÿ u ç»å½å¯ç iô Zcookiesu cookieæ¶é´æ³u åºåN)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú __tablename__r r Úidr Z user_nameÚpasswordÚcookier Zcookie_timestampÚregion© r r ú;e:\PycharmProject\fugitive_dust_new\src\db\models\tables.pyr s r c @ s e Zd ZdZdZeeddddZeedddZ ee
|
d dZ eedd
|
dZ eed d dZ ee
|
d dZee
|
ddZeeddZeeddZeeddZeeddZeeddZeeddZee
|
ddZee
|
ddZeeddZeeddZeeddZeeddZdS )ÚRequestTaskSettingu ç¬åä»»å¡é
ç½®åæ°è¡¨Z du_js_t_request_task_settingTr r r u ç¨æ·å称r u é
ç½®æ´æ°æ¶é´u åºå¿é
|
u çæ¬å·u æ°æ®ç¬åå¼å§æ¶é´u æ°æ®ç¬åç»ææ¶é´u6 å¨ç¬åä»»å¡å¼å§ç»ææ¶é´å
ï¼ç¬åçé¢çuK ä¸æ¬¡æ°æ®ç¬åä»»å¡ä¸ï¼ææ»æ¶é¿å段æ§è¡çæ¯æ®µæ¶é´é¿åº¦uE ä¸æ¬¡æ°æ®ç¬åä»»å¡ä¸ï¼å段æ§è¡æ¶çæ¯æ®µçé´éæ¶é´u' ç¬åä»»å¡å¼å¸¸æ¶å次å°è¯é´éu' ç¬å失败æ¶å次å°è¯çæ»æ¬¡æ°u cookieåå¨æææ¶é¿Ú u* å次ç»é失败éæ°å°è¯çå¾
æ¶é´u ç»é失败è¿ç»å°è¯æ¬¡æ°u0 æ´ä¸ªç¬åä»»å¡éæ°å¼å§å°è¯çå¾
æ¶é´us ç¨åºé¦æ¬¡æ§è¡, ç«ç¹æ°æ®ææ°æ¶å»è¡¨ä¸ºç©ºæ¶, æ°æ®è·åå¼å§æ¶é´ç¸å¯¹å½æ¥å¾åå移ç天æ°N) r r r r r r r r r Úuserr Ú update_timer ÚversionZrequest_start_timeZrequest_end_timeZrequest_interval_secondsZrequest_range_hourZ request_range_interval_secondsZrequest_fail_wait_secondsZrequest_retry_timesZ request_cookie_valid_durationZstatics_daily_timeZstatics_monthly_timeZlogin_fail_wait_secondsZlogin_retry_timesZtask_retry_wait_secondsZfirst_request_offset_daysr r r r r s* r c @ s e Zd ZdZdZeeddddZeedddZ ee
|
d dZ ee
|
d
|
dZ ee d dZeed d dZeed dZeed ddZddddZedddZdS )Ú DustDataInfou çæµæ°æ®è¡¨Zja_t_dust_site_data_infoTr r r õ ç«ç¹ç¼å·r u æ¬å°çæµå¼u åªå£°çæµå¼u çæµæ¶é´r u çæµè´¨éu ç¶ææ è¯N©Úreturnc C s^ | d¡| _| d¡| _| d¡| _t | d¡¡| _| d¡| _| d¡| _| d¡| _ dS ) uÿ
|
Args:
|
json_obj: {
|
"longitude": "121.32",
|
"latitude": "30.840834",
|
"Address": "西æ°æ³¾é»æ±¶æ³¾",
|
"DustValue": 0.207,
|
"Grade": 1,
|
"GroupID": 16,
|
"GroupName": "éå±±åº",
|
"LST": "2023-10-16 12:00:00",
|
"LST1": "1697457600",
|
"Name": "大信.ä¸ä¿¡æµ·ç´åä¸æ 人æºæ»é¨åºå°é¡¹ç®ââ1å·ç¹",
|
"MNCode": "SHXH0JS0100306",
|
"NoiseValue": 59.4,
|
"ProjectID": 45879,
|
"Quality": "好",
|
"SName": "ä¸æµ·å°æ
§",
|
"TypeName": "建çå·¥å°",
|
"flag": "N"
|
}
|
ÚMNCodeZ DustValueZ
|
NoiseValueZLSTZQualityZGradeÚflagN)
|
ÚgetÚmn_codeÚ
|
dust_valueÚ noise_valuer
|
Ú str_to_timeÚlstÚqualityÚgrader* ©ÚselfZjson_objr r r Ú__init__: s zDustDataInfo.__init__c C s t dd | }t|S )Nc S s t | S )N)r% )Úxr r r Ú<lambda>Z ó z*DustDataInfo.json_to_cls.<locals>.<lambda>)ÚmapÚlist)Z json_listÚmr r r Ú json_to_clsY s zDustDataInfo.json_to_cls)r r r r r r r r r r, r r- r. r r0 r1 r2 r* r5 r: r< r r r r r% , s r% c @ s> e Zd ZdZdZeeddddZeeddZ ee
|
d dZ d
|
S ) ÚSiteLatestTimeu ç«ç¹æ°æ®ææ°æ¶å»è¡¨Zdu_js_t_site_latest_timer Tr& )r r u ææ°æ¶é´r u7 ç«ç¹ç¶æ, 0代表ä¸çº¿;1代表åè¿;2代表ä¸çº¿N) r r r r r r r r, r Z latest_timer Z device_statusr r r r r= ^ s
|
r= c @ sò e Zd ZdZdZeeddddZeedddZ eed d
|
dZ
|
eed d dZ eedd dZ ee d dZeed d dZeedd dZee d dZeedd dZeed d dZeedd dZeed d dZeed d dZeedd dZeedd dZeedd dZeedd dZeedd dZeedd dZ eedd dZ eedd dZ eedd dZ eedd dZ eedd dZ!ee d dZ"eed d dZ#eed dZ$ee d dZ%ee d dZ&ee'd dZ(eedd dZ)eedd dZ*ee d dZ+eedd dZ,eed d dZ-eedd dZ.eedd dZ/ee d dZ0eedd dZ1ee d dZ2eedd dZ3eedd dZ4eedd dZ5eed d dZ6eed d dZ7eedd dZ8ddddZ9dd Z:dS )Ú DustSiteInfou ç«ç¹åºæ¬ä¿¡æ¯è¡¨Zja_t_dust_site_infoTu 项ç®ç¼å·r r u 设å¤ç¼å·r r u å®è£
å°åu ç«ç¹å称r! r é éd Nr' c C s | |¡ dS )uJ
|
Args:
|
json_obj: {
|
"Active": 1,
|
"Address": "ä¸æµ·å¸éå±±åºäºæéå¨æ
æè¡æ°7ç»1056å·",
|
"Code": "HMHB00087",
|
"DustValue": 0.065,
|
"DutyCompany": "ä¸æµ·æ³æ»ç¯ä¿ç§ææéå
¬å¸",
|
"DutyCompanyID": 25,
|
"GroupID": 16,
|
"GroupName": "éå±±åº",
|
"ID": 41024,
|
"IsOnline": 1,
|
"Name": "ä¸æµ·éé建ææéå
¬å¸",
|
"IsTrouble": 0,
|
"LST": "2023-10-27 08:15:00",
|
"RingName": "å¤ç¯å¤",
|
"MNCode": "HMHB0JS0300084",
|
"TypeName": "ç 头",
|
"TypeID": 3,
|
"NoiseValue": "68.9",
|
"RingID": 4
|
}
|
N)Úupdater3 r r r r5 s zDustSiteInfo.__init__c C s | d¡| _| d¡| _| d¡| _| d¡| _| d¡| _| d¡| _| d¡| _| d¡| _| d ¡| _ | d
|
¡| _
|
| d ¡| _ | d ¡| _ | d ¡| _ | d¡| _| d¡| _| d¡| _| d¡| _d| _| d¡| _| d¡| _| d¡| _| d¡| _| d¡| _| d¡| _d S )NÚIDr) ZAddressÚNameZCodeZ BeginDateZ DutyCompanyZ DutyCompanyIDZEndDateZEngineeringStageZGroupIDZ GroupNameZIsOnlineZ IsTroubleZKIndexZLinkmanZPhoneu ä¸æµ·å¸ZRingIDZRingNameZTypeIDZTypeNameZActiveZ
|
TroubleNum)r+ r r, ÚaddressÚnameÚcodeÚ
|
begin_dateÚ duty_companyÚduty_company_idÚend_dateÚengineering_stageÚgroup_idÚ
|
group_nameÚ is_onlineÚ
|
is_troubleÚkindexÚlinkmanÚphoneÚprovinceÚring_idÚ ring_nameÚtype_idÚtypenameÚactiveÚ trouble_numr3 r r r rA ¸ s0 zDustSiteInfo.update);r r r r r r r r r r, rD rE rF r rG rH rI rJ rK rL rM rN rO Zjhpt_update_timerP ZlatituderQ Z longituderR rS rT rU rV rW Z stop_timerX rY Z insert_timeZstage_begin_dater ZtspZ union_type_idZ wall_heightZ ywsj_dateZ
|
build_areaZconstruction_unitZ control_levelZ
|
developersZdo_timeZ has_monitorZ data_timeZengineering_stage_codeZequipment_codeZ
|
floor_areaZ jhpt_deleteZ noise_regionZ responsibler5 rA r r r r r> h sf r> c @ sb e Zd ZdZdZeeddddZeeddZ eeddZ
|
ee ddZ ee ddZ dd d
|
d ZdS ) Ú RequestTasku ç¬åæ°æ®ä»»å¡è¡¨Zdu_js_t_request_taskTõ ä»»å¡ç¼å·r r! r Nr' c C s || _ || _d| _d| _d S )NTF)r Ú
|
start_timeÚrunning_statusÚsuccess)r4 r r\ r r r r5 ô s zRequestTask.__init__)r r r r r r r r r r\ Úend_timer r] r^ r5 r r r r rZ é s rZ c @ sX e Zd ZdZdZeeddddZeeddZee ddZ
|
ee d ddZ ee ddZd
|
S ) ÚRequestTaskLogu ç¬åæ°æ®ä»»å¡æ¥å¿è¡¨Zdu_js_t_request_task_logTu æ¥å¿ç¼å·r r[ r r! r? N)r r r r r r r r Z
|
request_idr Z create_timer Zlog_typer Úlogr r r r r` û s r` N)Ú
|
db.db_connr Ú
|
sqlalchemyr r r r r r r Zutils.date_utilsr
|
ÚBaser r r% r= r> rZ r` r r r r Ú<module> s $ 2
|
|
