公有云数据同步到本地数据库(仅需要的数据字段)

需求:有独立的数据BI平台,需要的数据存储在公有云中没法做交互,还存在部分其他原因,所以需要将公有云中的销售合同及销售订单数据表同步到本地的数据库中。
界面:

部分代码:
private void button1_Click(object sender, EventArgs e)
{
int a = ClearTable("crm_contract");
LogTextBox.AppendText("销售合同表crm_contract清除:"+a.ToString() + "行;" + "\r\n");
progressBar1.Value = 0;
var clienter = new K3CloudApi();
string formId = "CRM_Contract";
string josnDat = "{" +
"\"FormId\": \"CRM_Contract\"," +
"\"FieldKeys\": \"FSalerId.FNAME,FBillNo,FDate,FName,F_ora_BasePropertyJFS,F_ora_TextZZYH,F_ora_Assistant.FDataValue,F_QETW_ASSISTANT_BU.Fdatavalue,FMaterialName,FMaterialModel,FUnitID.Fname,FQty,FAllAmount,FRecConditionId.FNAME,FSettleCurrId.FName,FDocumentStatus,FCancelStatus,FBDCUSTID.Fnumber,F_ora_Base1.Fname,FAllAmount_LC,FBILLALLAMOUNT_LC,F_ora_Remarks\"," +
"\"FilterString\": [{\"Left\":\"\",\"FieldName\":\"FDate\",\"Compare\":\"39\",\"Value\":\"2023-01-01 00:00:00\",\"Right\":\"\",\"Logic\":0},{\"Left\":\"\",\"FieldName\":\"FDate\",\"Compare\":\"16\",\"Value\":\"2024-12-31 00:00:00\",\"Right\":\"\",\"Logic\":0},{\"Left\":\"\",\"FieldName\":\"FDocumentStatus\",\"Compare\":\"105\",\"Value\":\"C\",\"Right\":\"\",\"Logic\":0},{\"Left\":\"\",\"FieldName\":\"FCancelStatus\",\"Compare\":\"105\",\"Value\":\"A\",\"Right\":\"\",\"Logic\":0},{\"Left\":\"\",\"FieldName\":\"FSalerId.FName\",\"Compare\":\"83\",\"Value\":\"***\",\"Right\":\"\",\"Logic\":0},{\"Left\":\"\",\"FieldName\":\"FSalerId.FName\",\"Compare\":\"83\",\"Value\":\"****\",\"Right\":\"\",\"Logic\":0}]," +
"\"OrderString\": \"\"," +
"\"TopRowCount\": 0," +
"\"StartRow\": 0," +
"\"Limit\": 5000," +
"\"SubSystemId\": \"\"}";
clienter.InitClient("*******", "******","*****","*****", 2052, "G", "https://********.ik3cloud.com/k3cloud/");
var s = clienter.BillQuery(josnDat);
JArray ja = (JArray)JsonConvert.DeserializeObject(s);
Console.WriteLine(ja[0].ToString());
Console.WriteLine(ja.Count);
// string connectionString = "server=192.168.100.******;database=erp;uid=root;password=*******;";
MySQLHelper mySQLHelper = new MySQLHelper(connectionString);
//DataTable dataTable = mySQLHelper.ExecuteQuery("SELECT * FROM crm_contract");
Dictionary<string, object> data = new Dictionary<string, object>();
LogTextBox.AppendText("数据开始写入数据库,数据总行数为:" + ja.Count.ToString() +";"+ "\r\n");
progressBar1.Maximum = ja.Count;
for (int i=0;i<ja.Count; i++)
{
data.Add("FBill
公有云数据同步到本地数据库(仅需要的数据字段)
声明:除非特别标注,否则均为本站原创文章,转载时请以链接形式注明文章出处。如若本站内容侵犯了原著者的合法权益,可联系本站删除。



