yanh
/
auseft.Platform.DataSync
1
0
Fork 0
Koodi Ongelmat 0 Pull-pyynnöt 0 Julkaisut 0 Wiki Activity
数据同步
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
49 Commitit
2 Branchit
356MB
Haara: 晋江
Branchit Tagit
${ item.name }
Create branch ${ searchTerm }
from '晋江'
${ noResults }
auseft.Platform.DataSync/tcp_client/config_send.toml

182 lines
8.6KB
Raaka Pysyvä linkki Blame Historia 

  1. [server]

  2. #host = "10.180.4.88"

  3. host = "127.0.0.1"

  4. 

  5. port = 9090

  6. 

  7. [client]

  8. # 定时任务配置

  9. interval_seconds = 3600  # 每隔多少秒执行一次

  10. max_retries = 3

  11. read_timeout_secs = 10

  12. write_timeout_secs = 10

  13. retry_delay_secs = 2

  14. 

  15. [database]

  16. host = "10.180.4.100"

  17. port = 5432

  18. name = "Auseft_new_web"

  19. user = "postgres"

  20. password = "Auseft@2025qwer"

  21. 

  22. # 要同步的表配置

  23. 

  24. 

  25. [[tables]]

  26. name = "comm_bch_batch"

  27. 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"

  28. incremental = false 

  29. key_field = "UpdateTime"  

  30. 

  31. [[tables]]

  32. name = "hy_record"

  33. 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'  "

  34. incremental = false 

  35. key_field = "UpdateTime"  

  36. 

  37. 

  38. [[tables]]

  39. name = "hy_itemdetail"

  40. 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') "

  41. incremental = false

  42. key_field = "UpdateTime"

  43. 

  44. [[tables]]

  45. name = "hy_norm"

  46. 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')"

  47. incremental = false

  48. key_field = "UpdateTime"

  49. 

  50. 

  51. [[tables]]

  52. name = "hy_instrument"

  53. query = "SELECT * FROM \"hy_instrument\""

  54. incremental = false

  55. key_field = "UpdateTime"

  56. 

  57. [[tables]]

  58. name = "hy_information"

  59. query = "SELECT * FROM \"hy_information\""

  60. incremental = false

  61. key_field = "UpdateTime"

  62. 

  63. 

  64. 

  65. [[tables]]

  66. name = "hy_allot"

  67. query = "SELECT * FROM \"hy_allot\""

  68. incremental = false

  69. key_field = "UpdateTime"

  70. 

  71. [[tables]]

  72. name = "hy_cytask"

  73. query = "SELECT * FROM \"hy_cytask\""

  74. incremental = false

  75. key_field = "UpdateTime"

  76. 

  77. [[tables]]

  78. name = "hy_fullwatersample"

  79. 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"

  80. incremental = false

  81. key_field = "UpdateTime"

  82. 

  83. [[tables]]

  84. name = "hy_informationnorm"

  85. query = "SELECT * FROM \"hy_informationnorm\""

  86. incremental = false

  87. key_field = "UpdateTime"

  88. 

  89. 

  90. 

  91. 

  92. 

  93. 

  94. 

  95. [[tables]]

  96. name = "hy_laboratoryinstrument"

  97. query = "SELECT * FROM \"hy_laboratoryinstrument\""

  98. incremental = false

  99. key_field = "UpdateTime"

  100. 

  101. [[tables]]

  102. name = "hy_materialanalysis_type"

  103. query = "SELECT * FROM \"hy_materialanalysis_type\""

  104. incremental = false

  105. key_field = "UpdateTime"

  106. 

  107. [[tables]]

  108. name = "hy_materialdetail"

  109. query = "SELECT * FROM \"hy_materialdetail\""

  110. incremental = false

  111. key_field = "UpdateTime"

  112. 

  113. 

  114. 

  115. [[tables]]

  116. name = "hy_weight_input"

  117. query = "SELECT * FROM \"hy_weight_input\""

  118. incremental = false

  119. key_field = "UpdateTime"

  120. 

  121. 

  122. [[tables]]

  123. name = "hy_warmhumid"

  124. query = "select id,laboratoryid,temperature::text as temperature,humidity::text humidity,begintime,endtime, username from hy_warmhumid"

  125. incremental = false

  126. key_field = "UpdateTime"

  127. 

  128. 

  129. 

  130. 

  131. [[tables]]

  132. name = "erp_matl_material"

  133. 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"

  134. incremental = false

  135. key_field = "UpdateTime"

  136. 

  137. 

  138. [[tables]]

  139. name = "erp_co_supply"

  140. 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"

  141. incremental = false

  142. key_field = "UpdateTime"

  143. 

  144. [[tables]]

  145. name = "comm_bm_vehicleinfo"

  146. 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"

  147. incremental = false

  148. key_field = "UpdateTime"

  149. 

  150. 

  151. [[tables]]

  152. name = "erp_shipping_plan"

  153. 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"

  154. incremental = false

  155. key_field = "UpdateTime"

  156. 

  157. [[tables]]

  158. name = "erp_shipping_details"

  159. 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"

  160. incremental = false

  161. key_field = "UpdateTime"

  162. 

  163. 

  164. 

  165. [[tables]]

  166. name = "erp_total_shipping_plan"

  167. 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"

  168. incremental = false

  169. key_field = "UpdateTime"

  170. 

  171. 

  172. [[tables]]

  173. name = "wt_weight_info"

  174.  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'  "

  175. incremental = false

  176. key_field = "UpdateTime"

  177. 

  178. 

  179. 

  180.