配置调整

tcp_client/config.toml

@@ -24,95 +24,7 @@ password = "Auseft@2025qwer"
 
 [[tables]]
 name = "hy_record"
-query = "SELECT id, hy_code, type, hy_check, hy_approve, check_time, approve_time, approve_user, check_user, hy_time, hy_values, accept_time, accept_user, mt::text as mt, mad::text as mad, aad::text as aad, ad::text as ad, vad::text as vad, vd::text as vd, var::text as var, vdaf::text as vdaf, fcad::text as fcad, st_ar::text as st_ar, st_ad::text as st_ad, st_d::text as st_d, had::text as had, hd::text as hd, qb_ad::text as qb_ad, qgr_ad::text as qgr_ad, qgr_d::text as qgr_d, qnet_ar_mj_kg::text as qnet_ar_mj_kg, qnet_ar_j_cal::text as qnet_ar_j_cal, v::text as v, aar::text as aar, qnet_ar::text as qnet_ar, qnet_ar1::text as qnet_ar1, crc::text as crc, st_daf::text as st_daf, cad ::text as  cad, cd::text as cd, isauto, hy_type, isnormal FROM hy_record where  hy_approve=0 and accept_time  >= NOW() - INTERVAL '10 days'  "
+query = "SELECT id, hy_code, type, hy_check, hy_approve, check_time, approve_time, approve_user, check_user, hy_time, hy_values, accept_time, accept_user, mt::text as mt, mad::text as mad, aad::text as aad, ad::text as ad, vad::text as vad, vd::text as vd, var::text as var, vdaf::text as vdaf, fcad::text as fcad, st_ar::text as st_ar, st_ad::text as st_ad, st_d::text as st_d, had::text as had, hd::text as hd, qb_ad::text as qb_ad, qgr_ad::text as qgr_ad, qgr_d::text as qgr_d, qnet_ar_mj_kg::text as qnet_ar_mj_kg, qnet_ar_j_cal::text as qnet_ar_j_cal, v::text as v, aar::text as aar, qnet_ar::text as qnet_ar, qnet_ar1::text as qnet_ar1, crc::text as crc, st_daf::text as st_daf, cad ::text as  cad, cd::text as cd, isauto, hy_type, isnormal FROM hy_record where  hy_approve=0 and id=11026 "
 incremental = false 
 key_field = "UpdateTime"  
 
-
-[[tables]]
-name = "hy_itemdetail"
-query = "SELECT * FROM hy_itemdetail  where record_id in (select id from  hy_record  where hy_approve=0 and accept_time  >= NOW() - INTERVAL '10 days') "
-incremental = false
-key_field = "UpdateTime"
-
-[[tables]]
-name = "hy_norm"
-query = " select  id,norm_id,zbvalues::text as zbvalues,itemdetail_id,hy_user,checktime,\"explain\" from hy_norm  where itemdetail_id in (SELECT t1.id FROM hy_itemdetail t1 inner join hy_record t2 on t1.record_id=t2.id where t2.hy_approve=0 and t2.accept_time  >= NOW() - INTERVAL '10 days')"
-incremental = false
-key_field = "UpdateTime"
-
-
-[[tables]]
-name = "hy_instrument"
-query = "SELECT * FROM \"hy_instrument\""
-incremental = false
-key_field = "UpdateTime"
-
-[[tables]]
-name = "hy_information"
-query = "SELECT * FROM \"hy_information\""
-incremental = false
-key_field = "UpdateTime"
-
-
-
-[[tables]]
-name = "hy_allot"
-query = "SELECT * FROM \"hy_allot\""
-incremental = false
-key_field = "UpdateTime"
-
-[[tables]]
-name = "hy_cytask"
-query = "SELECT * FROM \"hy_cytask\""
-incremental = false
-key_field = "UpdateTime"
-
-[[tables]]
-name = "hy_fullwatersample"
-query = "select  id,qs_code,qs_tonnage::text as qs_tonnage,mt::text as mt,remark,onecode,towcode,fx_code,fx_onecode,fx_twocode from  hy_fullwatersample"
-incremental = false
-key_field = "UpdateTime"
-
-[[tables]]
-name = "hy_informationnorm"
-query = "SELECT * FROM \"hy_informationnorm\""
-incremental = false
-key_field = "UpdateTime"
-
-
-
-
-
-[[tables]]
-name = "hy_laboratoryinstrument"
-query = "SELECT * FROM \"hy_laboratoryinstrument\""
-incremental = false
-key_field = "UpdateTime"
-
-[[tables]]
-name = "hy_materialanalysis_type"
-query = "SELECT * FROM \"hy_materialanalysis_type\""
-incremental = false
-key_field = "UpdateTime"
-
-[[tables]]
-name = "hy_materialdetail"
-query = "SELECT * FROM \"hy_materialdetail\""
-incremental = false
-key_field = "UpdateTime"
-
-
-
-[[tables]]
-name = "hy_weight_input"
-query = "SELECT * FROM \"hy_weight_input\""
-incremental = false
-key_field = "UpdateTime"
-
-
-[[tables]]
-name = "hy_warmhumid"
-query = "select id,laboratoryid,temperature::text as temperature,humidity::text humidity,begintime,endtime, username from hy_warmhumid"
-incremental = false
-key_field = "UpdateTime"

tcp_client/config_return.toml

@@ -0,0 +1,118 @@
+[server]
+#host = "10.180.4.88"
+host = "127.0.0.1"
+
+port = 9090
+
+[client]
+# 定时任务配置
+interval_seconds = 3600  # 每隔多少秒执行一次
+max_retries = 3
+read_timeout_secs = 10
+write_timeout_secs = 10
+retry_delay_secs = 2
+
+[database]
+host = "10.180.4.100"
+#host = "192.168.0.100"
+port = 5432
+name = "Auseft_RL_WEB_3"
+user = "postgres"
+password = "Auseft@2025qwer"
+
+# 要同步的表配置
+
+[[tables]]
+name = "hy_record"
+query = "SELECT id, hy_code, type, hy_check, hy_approve, check_time, approve_time, approve_user, check_user, hy_time, hy_values, accept_time, accept_user, mt::text as mt, mad::text as mad, aad::text as aad, ad::text as ad, vad::text as vad, vd::text as vd, var::text as var, vdaf::text as vdaf, fcad::text as fcad, st_ar::text as st_ar, st_ad::text as st_ad, st_d::text as st_d, had::text as had, hd::text as hd, qb_ad::text as qb_ad, qgr_ad::text as qgr_ad, qgr_d::text as qgr_d, qnet_ar_mj_kg::text as qnet_ar_mj_kg, qnet_ar_j_cal::text as qnet_ar_j_cal, v::text as v, aar::text as aar, qnet_ar::text as qnet_ar, qnet_ar1::text as qnet_ar1, crc::text as crc, st_daf::text as st_daf, cad ::text as  cad, cd::text as cd, isauto, hy_type, isnormal FROM hy_record where  hy_approve=0 and accept_time  >= NOW() - INTERVAL '10 days'  "
+incremental = false 
+key_field = "UpdateTime"  
+
+
+[[tables]]
+name = "hy_itemdetail"
+query = "SELECT * FROM hy_itemdetail  where record_id in (select id from  hy_record  where hy_approve=0 and accept_time  >= NOW() - INTERVAL '10 days') "
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_norm"
+query = " select  id,norm_id,zbvalues::text as zbvalues,itemdetail_id,hy_user,checktime,\"explain\" from hy_norm  where itemdetail_id in (SELECT t1.id FROM hy_itemdetail t1 inner join hy_record t2 on t1.record_id=t2.id where t2.hy_approve=0 and t2.accept_time  >= NOW() - INTERVAL '10 days')"
+incremental = false
+key_field = "UpdateTime"
+
+
+[[tables]]
+name = "hy_instrument"
+query = "SELECT * FROM \"hy_instrument\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_information"
+query = "SELECT * FROM \"hy_information\""
+incremental = false
+key_field = "UpdateTime"
+
+
+
+[[tables]]
+name = "hy_allot"
+query = "SELECT * FROM \"hy_allot\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_cytask"
+query = "SELECT * FROM \"hy_cytask\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_fullwatersample"
+query = "select  id,qs_code,qs_tonnage::text as qs_tonnage,mt::text as mt,remark,onecode,towcode,fx_code,fx_onecode,fx_twocode from  hy_fullwatersample"
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_informationnorm"
+query = "SELECT * FROM \"hy_informationnorm\""
+incremental = false
+key_field = "UpdateTime"
+
+
+
+
+
+[[tables]]
+name = "hy_laboratoryinstrument"
+query = "SELECT * FROM \"hy_laboratoryinstrument\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_materialanalysis_type"
+query = "SELECT * FROM \"hy_materialanalysis_type\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_materialdetail"
+query = "SELECT * FROM \"hy_materialdetail\""
+incremental = false
+key_field = "UpdateTime"
+
+
+
+[[tables]]
+name = "hy_weight_input"
+query = "SELECT * FROM \"hy_weight_input\""
+incremental = false
+key_field = "UpdateTime"
+
+
+[[tables]]
+name = "hy_warmhumid"
+query = "select id,laboratoryid,temperature::text as temperature,humidity::text humidity,begintime,endtime, username from hy_warmhumid"
+incremental = false
+key_field = "UpdateTime"

tcp_client/config_send.toml

@@ -0,0 +1,118 @@
+[server]
+#host = "10.180.4.88"
+host = "127.0.0.1"
+
+port = 9090
+
+[client]
+# 定时任务配置
+interval_seconds = 3600  # 每隔多少秒执行一次
+max_retries = 3
+read_timeout_secs = 10
+write_timeout_secs = 10
+retry_delay_secs = 2
+
+[database]
+host = "10.180.4.100"
+#host = "192.168.0.100"
+port = 5432
+name = "Auseft_RL_Web"
+user = "postgres"
+password = "Auseft@2025qwer"
+
+# 要同步的表配置
+
+[[tables]]
+name = "hy_record"
+query = "SELECT id, hy_code, type, hy_check, hy_approve, check_time, approve_time, approve_user, check_user, hy_time, hy_values, accept_time, accept_user, mt::text as mt, mad::text as mad, aad::text as aad, ad::text as ad, vad::text as vad, vd::text as vd, var::text as var, vdaf::text as vdaf, fcad::text as fcad, st_ar::text as st_ar, st_ad::text as st_ad, st_d::text as st_d, had::text as had, hd::text as hd, qb_ad::text as qb_ad, qgr_ad::text as qgr_ad, qgr_d::text as qgr_d, qnet_ar_mj_kg::text as qnet_ar_mj_kg, qnet_ar_j_cal::text as qnet_ar_j_cal, v::text as v, aar::text as aar, qnet_ar::text as qnet_ar, qnet_ar1::text as qnet_ar1, crc::text as crc, st_daf::text as st_daf, cad ::text as  cad, cd::text as cd, isauto, hy_type, isnormal FROM hy_record where  hy_approve=0 and accept_time  >= NOW() - INTERVAL '10 days'  "
+incremental = false 
+key_field = "UpdateTime"  
+
+
+[[tables]]
+name = "hy_itemdetail"
+query = "SELECT * FROM hy_itemdetail  where record_id in (select id from  hy_record  where hy_approve=0 and accept_time  >= NOW() - INTERVAL '10 days') "
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_norm"
+query = " select  id,norm_id,zbvalues::text as zbvalues,itemdetail_id,hy_user,checktime,\"explain\" from hy_norm  where itemdetail_id in (SELECT t1.id FROM hy_itemdetail t1 inner join hy_record t2 on t1.record_id=t2.id where t2.hy_approve=0 and t2.accept_time  >= NOW() - INTERVAL '10 days')"
+incremental = false
+key_field = "UpdateTime"
+
+
+[[tables]]
+name = "hy_instrument"
+query = "SELECT * FROM \"hy_instrument\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_information"
+query = "SELECT * FROM \"hy_information\""
+incremental = false
+key_field = "UpdateTime"
+
+
+
+[[tables]]
+name = "hy_allot"
+query = "SELECT * FROM \"hy_allot\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_cytask"
+query = "SELECT * FROM \"hy_cytask\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_fullwatersample"
+query = "select  id,qs_code,qs_tonnage::text as qs_tonnage,mt::text as mt,remark,onecode,towcode,fx_code,fx_onecode,fx_twocode from  hy_fullwatersample"
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_informationnorm"
+query = "SELECT * FROM \"hy_informationnorm\""
+incremental = false
+key_field = "UpdateTime"
+
+
+
+
+
+[[tables]]
+name = "hy_laboratoryinstrument"
+query = "SELECT * FROM \"hy_laboratoryinstrument\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_materialanalysis_type"
+query = "SELECT * FROM \"hy_materialanalysis_type\""
+incremental = false
+key_field = "UpdateTime"
+
+[[tables]]
+name = "hy_materialdetail"
+query = "SELECT * FROM \"hy_materialdetail\""
+incremental = false
+key_field = "UpdateTime"
+
+
+
+[[tables]]
+name = "hy_weight_input"
+query = "SELECT * FROM \"hy_weight_input\""
+incremental = false
+key_field = "UpdateTime"
+
+
+[[tables]]
+name = "hy_warmhumid"
+query = "select id,laboratoryid,temperature::text as temperature,humidity::text humidity,begintime,endtime, username from hy_warmhumid"
+incremental = false
+key_field = "UpdateTime"

tcp_server/target/.rustc_info.json

@@ -1 +1 @@
-{"rustc_fingerprint":12877487731689626790,"outputs":{"17747080675513052775":{"success":true,"status":"","code":0,"stdout":"rustc 1.85.0 (4d91de4e4 2025-02-17)\nbinary: rustc\ncommit-hash: 4d91de4e48198da2e33413efdcd9cd2cc0c46688\ncommit-date: 2025-02-17\nhost: x86_64-pc-windows-msvc\nrelease: 1.85.0\nLLVM version: 19.1.7\n","stderr":""},"13331785392996375709":{"success":true,"status":"","code":0,"stdout":"___.exe\nlib___.rlib\n___.dll\n___.dll\n___.lib\n___.dll\nC:\\Users\\qq101\\.rustup\\toolchains\\stable-x86_64-pc-windows-msvc\npacked\n___\ndebug_assertions\npanic=\"unwind\"\nproc_macro\ntarget_abi=\"\"\ntarget_arch=\"x86_64\"\ntarget_endian=\"little\"\ntarget_env=\"msvc\"\ntarget_family=\"windows\"\ntarget_feature=\"cmpxchg16b\"\ntarget_feature=\"fxsr\"\ntarget_feature=\"sse\"\ntarget_feature=\"sse2\"\ntarget_feature=\"sse3\"\ntarget_has_atomic=\"128\"\ntarget_has_atomic=\"16\"\ntarget_has_atomic=\"32\"\ntarget_has_atomic=\"64\"\ntarget_has_atomic=\"8\"\ntarget_has_atomic=\"ptr\"\ntarget_os=\"windows\"\ntarget_pointer_width=\"64\"\ntarget_vendor=\"pc\"\nwindows\n","stderr":""}},"successes":{}}
+{"rustc_fingerprint":12877487731689626790,"outputs":{"13331785392996375709":{"success":true,"status":"","code":0,"stdout":"___.exe\nlib___.rlib\n___.dll\n___.dll\n___.lib\n___.dll\nC:\\Users\\qq101\\.rustup\\toolchains\\stable-x86_64-pc-windows-msvc\npacked\n___\ndebug_assertions\npanic=\"unwind\"\nproc_macro\ntarget_abi=\"\"\ntarget_arch=\"x86_64\"\ntarget_endian=\"little\"\ntarget_env=\"msvc\"\ntarget_family=\"windows\"\ntarget_feature=\"cmpxchg16b\"\ntarget_feature=\"fxsr\"\ntarget_feature=\"sse\"\ntarget_feature=\"sse2\"\ntarget_feature=\"sse3\"\ntarget_has_atomic=\"128\"\ntarget_has_atomic=\"16\"\ntarget_has_atomic=\"32\"\ntarget_has_atomic=\"64\"\ntarget_has_atomic=\"8\"\ntarget_has_atomic=\"ptr\"\ntarget_os=\"windows\"\ntarget_pointer_width=\"64\"\ntarget_vendor=\"pc\"\nwindows\n","stderr":""},"17747080675513052775":{"success":true,"status":"","code":0,"stdout":"rustc 1.85.0 (4d91de4e4 2025-02-17)\nbinary: rustc\ncommit-hash: 4d91de4e48198da2e33413efdcd9cd2cc0c46688\ncommit-date: 2025-02-17\nhost: x86_64-pc-windows-msvc\nrelease: 1.85.0\nLLVM version: 19.1.7\n","stderr":""}},"successes":{}}