diff --git a/tcp_client/config - 副本.toml b/tcp_client/config - 副本.toml new file mode 100644 index 0000000..b520b50 --- /dev/null +++ b/tcp_client/config - 副本.toml @@ -0,0 +1,29 @@ +[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" +port = 5432 +name = "Auseft_RL_Web" +user = "postgres" +password = "Auseft@2025qwer" + +# 要同步的表配置 + + +[[tables]] +name = "erp_total_shipping_plan" +query = "SELECT id, order_number, start_time, end_time, finish, ship_name, voyage, total_quantity::text as total_quantity, deviation_quantity::text as deviation_quantity, supplier_code, supplier_name, material_code, material_name, shipping_station_code, shipping_station_name, departure_port, departure_time, port_destination, berthing_time, supplier_id, material_id,delete_flag FROM public.erp_total_shipping_plan" +incremental = false +key_field = "UpdateTime" diff --git a/tcp_client/config.toml b/tcp_client/config.toml index 0cc0708..b520b50 100644 --- a/tcp_client/config.toml +++ b/tcp_client/config.toml @@ -15,163 +15,15 @@ retry_delay_secs = 2 [database] host = "10.180.4.100" port = 5432 -name = "Auseft_new_web" +name = "Auseft_RL_Web" user = "postgres" password = "Auseft@2025qwer" # 要同步的表配置 -[[tables]] -name = "comm_bch_batch" -query = "SELECT id, tenant_id, supply_id, material_id, batch_record_id, sample_type, related_code, batching_start_time, batching_end_time, batching_start_ticket, batching_end_ticket, batching_quantity, batching_weight::text, batching_code, batching_code_creator, batching_code_creation_time, preparation_code, preparation_code_creator, preparation_code_creation_time, assay_code, assay_code_creator, assay_code_creation_time, creator_id, creation_time, last_modifier_id, last_modification_reason, last_modification_time, deleted, deleter_id, deletion_reason, deletion_time, source_type FROM comm_bch_batch" -incremental = false -key_field = "UpdateTime" - -[[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" - - - - -[[tables]] -name = "erp_matl_material" -query = "SELECT id, tenant_id, category_id, code, name, manufacturer, model, specification, color, unit, warehouse_id, expiration_date, expiration_date_unit, sort, extra_properties, description, status, enabled, enabler_id, enablement_time, creator_id, creation_time, last_modifier_id, last_modification_time, deleted, deleter_id, deletion_time FROM public.erp_matl_material" -incremental = false -key_field = "UpdateTime" - - -[[tables]] -name = "erp_co_supply" -query = "SELECT id, tenant_id, category_id, company_id, code, name, abbreviate, transport_type, departure_name, departure_address, departure_longitude::text as departure_longitude, departure_latitude::text as departure_latitude, destination_name, destination_address, destination_longitude::text as destination_longitude, destination_latitude::text as destination_latitude, sort, extra_properties, description, status, enabled, enabler_id, enablement_time, creator_id, creation_time, last_modifier_id, last_modification_time, deleted, deleter_id, deletion_time FROM public.erp_co_supply" -incremental = false -key_field = "UpdateTime" - -[[tables]] -name = "comm_bm_vehicleinfo" -query = "SELECT id, licenseplate, type, grosswt::text as grosswt, tarewt::text as tarewt, owner, dl, supervision, outage, insurancedate, insurancenum, lock, transcompany, createdby, creationtime, modifiedby, modifiedtime, reviewed, reviewedby, reviewedtime, remarks, phonenumber, electronicnumber, rfidmodifiedtime, rfidstop, rfidstopby, rfidstoptime, rfidgrantby, rfidgranttime, samplingpoints, drawbar, carriagelength::text as carriagelength , carriagewidth::text as carriagewidth, carriageheight::text as carriageheight, underbodyheight::text as underbodyheight, frontsampling, backsampling, rod1::text as rod1, rod2::text as rod2, rod3::text as rod3, rod4::text as rod4, rod5::text as rod5, rod6::text as rod6, supplier_id, supplier_name, material_id, material_name,group_type FROM public.comm_bm_vehicleinfo" -incremental = false -key_field = "UpdateTime" - - -[[tables]] -name = "erp_shipping_plan" -query = "SELECT id, cust_id, material_id, plan_type, plan_start_date, plan_end_date, plan_days, plan_quantity::text as plan_quantity, through_put::text as through_put, calorific_value::text as calorific_value, sulfur_content::text as sulfur_content, transport_vehicles, sample_code, batch_code, update_by, update_time, review, review_by, review_date, cancel, cancel_by, cancel_time, remarks, plan_number, order_number, warehouse_id, order_type, cust_name, material_name, plan_name, warehouse_name,hy_upload_status,zl_upload_status FROM public.erp_shipping_plan" -incremental = false -key_field = "UpdateTime" - -[[tables]] -name = "erp_shipping_details" -query = "SELECT id, plan_id, vehicle_id, vehicle_number, gross_weight::text as gross_weight, tare_weight::text as tare_weight, net_weight::text as net_weight, card_number, appointment_number, appointment_time, appointment_weight::text as appointment_weight, is_cancel, is_end, driver_phone, remarks, create_time, create_by, update_time, update_by FROM public.erp_shipping_details" -incremental = false -key_field = "UpdateTime" - - - [[tables]] name = "erp_total_shipping_plan" -query = "SELECT id, order_number, start_time, end_time, finish, ship_name, voyage, total_quantity::text as total_quantity, deviation_quantity::text as deviation_quantity, supplier_code, supplier_name, material_code, material_name, shipping_station_code, shipping_station_name, departure_port, departure_time, port_destination, berthing_time, supplier_id, material_id FROM public.erp_total_shipping_plan" +query = "SELECT id, order_number, start_time, end_time, finish, ship_name, voyage, total_quantity::text as total_quantity, deviation_quantity::text as deviation_quantity, supplier_code, supplier_name, material_code, material_name, shipping_station_code, shipping_station_name, departure_port, departure_time, port_destination, berthing_time, supplier_id, material_id,delete_flag FROM public.erp_total_shipping_plan" incremental = false key_field = "UpdateTime" - - -[[tables]] -name = "wt_weight_info" - query = "SELECT id, materiel_id, weigh_type, vehicle_id, bill_no, supply_id, vehicle_no, ship_type, issued_time, gw::text as gw, gw_scale_no, gw_time, gw_by, accept_by, accept_time, t::text as t, t_scale_no, t_time, deduction::text as deduction, nw::text as nw, aw::text as aw, flow_id, is_invoice, is_end, is_cancel, is_manual_data, is_inbound, is_outbound, is_settle_and_review, is_settle, tax_rate::text as tax_rate, itax_unit_price::text as itax_unit_price, iunit_price::text as iunit_price, is_special_batch, total::text as total, is_rejected, sample1_collection, sample2_collection, supply_id_name, sample_done, load_weight::text as load_weight, is_reviewed, deduction1::text as deduction1, deduction2::text as deduction2, material_name, is_accept_and_receive FROM public.wt_weight_info where issued_time >= NOW() - INTERVAL '2 days' " -incremental = false -key_field = "UpdateTime" - diff --git a/tcp_client/config_send.toml b/tcp_client/config_send.toml index 66d9d23..2cab6b7 100644 --- a/tcp_client/config_send.toml +++ b/tcp_client/config_send.toml @@ -164,7 +164,7 @@ key_field = "UpdateTime" [[tables]] name = "erp_total_shipping_plan" -query = "SELECT id, order_number, start_time, end_time, finish, ship_name, voyage, total_quantity::text as total_quantity, deviation_quantity::text as deviation_quantity, supplier_code, supplier_name, material_code, material_name, shipping_station_code, shipping_station_name, departure_port, departure_time, port_destination, berthing_time, supplier_id, material_id FROM public.erp_total_shipping_plan" +query = "SELECT id, order_number, start_time, end_time, finish, ship_name, voyage, total_quantity::text as total_quantity, deviation_quantity::text as deviation_quantity, supplier_code, supplier_name, material_code, material_name, shipping_station_code, shipping_station_name, departure_port, departure_time, port_destination, berthing_time, supplier_id, material_id,delete_flag FROM public.erp_total_shipping_plan" incremental = false key_field = "UpdateTime"