WindowsApplication3-LEEHSIEHJUI/WindowsApplication3/FrmTest.vb

Imports System.Data.Common
Imports System.Data.SqlClient
Imports System.Net
Imports System.Net.Http
Imports LrGetToken
Imports System.Text
Imports Newtonsoft.Json
Imports Newtonsoft.Json.Linq
Imports System.Web
Imports System.ServiceModel.Security
Imports System.Web.UI.WebControls.WebParts
Imports System.Web.UI.WebControls

Public Class FrmTest
    Dim strAppSecret As String = ""

    Dim strAccessToken As String = ""

    Dim uId As String = ""

    Dim dt_global As New DataTable()
    Dim dt_global2 As New DataTable()

    Dim cmd As New SqlCommand
    Dim da As New SqlDataAdapter
    Dim dt As New DataTable
    Dim conn As New SqlConnection
    Dim sql As String = ""



    Private Sub Form1_Load(sender As Object, e As EventArgs) Handles MyBase.Load

        Dim updated_time As DateTime

        updated_time = DateTime.Now ' 你可以把它设置为具体的时间，或者从 Excel 中获取
        Dim updated_time_str As String = updated_time.ToString("yyyy-MM-dd HH:mm:ss")

        conn.ConnectionString = connstring
        conn.Open()

        sql = "select top(1) token,updated_time from hf_00_token order by updated_time desc"
        cmd.CommandText = sql
        cmd.Connection = conn

        cmd.ExecuteNonQuery()

        Dim my_result As String

        ' 获取返回结果
        If cmd.ExecuteScalar Is Nothing Then

            GetToken()
            ' 更新数据库或者存储新的 token




            sql = "insert into hf_00_token (token,updated_time) values('" & gAppToken & "','" & updated_time_str & "')"
            cmd.CommandText = sql

            If cmd.ExecuteNonQuery() = 1 Then

                MsgBox("取得新Token")
            Else
                MsgBox("发生异常")
            End If
        Else
            ' 获取 updated_time 和 token
            Using reader As SqlDataReader = cmd.ExecuteReader()
                If reader.HasRows Then
                    reader.Read()
                    gAppToken = reader("token").ToString()
                    updated_time = Convert.ToDateTime(reader("updated_time"))

                End If
            End Using

            ' 如果没有返回 token，提示没有找到数据
            If gAppToken = "" Then
                MsgBox("No data found")
            Else
                ' 将 updated_time 加上 24 小时
                Dim token_expiry_time As DateTime = updated_time.AddHours(24)
                gTokenValidTime = token_expiry_time
                ' 对比 token 是否过期
                If token_expiry_time < DateTime.Now Then
                    ' 如果过期，则重新获取 token
                    MsgBox("Token 过期. 重新取得...")
                    ' 在这里添加获取新的 token 的代码，例如调用一个方法来获取新的 token
                    sql = "delete from hf_00_token"
                    cmd.CommandText = sql
                    cmd.ExecuteScalar()

                    GetToken()
                    ' 更新数据库或者存储新的 token
                    sql = "insert into hf_00_token (token,updated_time) values('" & gAppToken & "','" & Now.ToString("yyyy-MM-dd HH:mm:ss") & "')"
                    cmd.CommandText = sql

                    If cmd.ExecuteNonQuery() = 1 Then

                        MsgBox("Token更新完成")
                    Else
                        MsgBox("发生异常")
                    End If




                Else
                    ' 如果未过期，使用现有 token
                    MsgBox("Token有效期：" & vbCrLf & gTokenValidTime)
                End If
            End If
        End If


        Me.DataGridView1.ClipboardCopyMode = DataGridViewClipboardCopyMode.EnableAlwaysIncludeHeaderText

        Me.dgv_detail.ClipboardCopyMode = DataGridViewClipboardCopyMode.EnableAlwaysIncludeHeaderText
    End Sub
    Private Sub GetToken()

        Dim xx As String = ConvertTimestampToDate(1742491933000)

        Dim clsX As New LrGetToken.clsGetToken()



        strAppSecret = clsX.GetAppSecretB(gClientID, gClientSecret, gAppkey, gInstanceID)
        If strAppSecret = "" Then
            Exit Sub
        End If
        Dim jo As JObject = JsonConvert.DeserializeObject(strAppSecret)
        strAppSecret = jo("data")(0).Item("appSecret")
        gAppToken = clsX.GetToken(gClientID, gClientSecret, gAppkey, strAppSecret)
        jo = JsonConvert.DeserializeObject(gAppToken)
        gAppToken = jo("data").Item("app-token")
        strAccessToken = jo("data").Item("access_token")
        uId = jo("data").Item("uid")
        TextBox1.Text = gAppToken




        TextBox4.Text = New Random().Next(100000000, 999999999)
        TextBox3.Text = Int((DateTime.Now.ToLocalTime() - DateTime.Parse("1970-01-01").ToLocalTime()).TotalSeconds)

    End Sub
    Private Sub btnGetMtrl_Click(sender As Object, e As EventArgs) Handles btnGetMtrl.Click
        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim strJson As String = clsX.GetDatum(gClientID, gClientSecret, gAppkey, strAppSecret, gAppToken, "", "", "jdy/v2/bd/material", 1, 100)

        BindJsonToDataGridView(strJson)

    End Sub






    Private Sub btnGetDept_Click(sender As Object, e As EventArgs) Handles btnGetDept.Click '-----部门列表
        Dim clsX As New LrGetToken.LrGetMtrlDatum
        '  Dim strJson As String = clsX.GetDatum(clientID, clientSecret, appkey, strAppSecret, strAppToken, "", "", "jdy/v2/bd/department", 1, 100)

    End Sub

    Private Sub btnGetEmp_Click(sender As Object, e As EventArgs) Handles btnGetEmp.Click
        Dim clsX As New LrGetToken.LrGetMtrlDatum
        '  Dim strJson As String = clsX.GetDatum(clientID, clientSecret, appkey, strAppSecret, strAppToken, "", "", "jdy/v2/bd/emp", 1, 100)

    End Sub

    Private Sub btnGetUnits_Click(sender As Object, e As EventArgs) Handles btnGetUnits.Click '-
        Dim clsX As New LrGetToken.LrGetMtrlDatum
        '  Dim strJson As String = clsX.GetDatum(clientID, clientSecret, appkey, strAppSecret, strAppToken, "", "", "jdy/v2/bd/measure_unit", 1, 100)

    End Sub

    Private Sub btnGetLoc_Click(sender As Object, e As EventArgs) Handles btnGetLoc.Click
        Dim clsX As New LrGetToken.LrGetMtrlDatum
        '	Dim strJson As String = clsX.GetDatum(clientID, clientSecret, appkey, strAppSecret, strAppToken, "", "", "jdy/v2/bd/spaces", 1, 100)

    End Sub

    Private Sub btnSaveInStk_Click(sender As Object, e As EventArgs) Handles btnSaveInStk.Click
        Dim clsX As New LrGetToken.clsGetToken
        Dim strJson As String = clsX.SaveBill(gClientID, gClientSecret, gAppToken)
    End Sub

    'Private Sub btnGetMtrlDetail_Click(sender As Object, e As EventArgs) Handles btnGetMtrlDetail.Click  '-----物料详情



    '    Dim clsX As New LrGetToken.LrGetMtrlDatum
    '    Dim paramLst As New List(Of LrGetToken.LrParam)
    '    Dim param As New LrGetToken.LrParam()
    '    param.pKey = "id" : param.pValue = DataGridView1.Rows(DataGridView1.CurrentCell.RowIndex).Cells("id").Value
    '    paramLst.Add(param)
    '    Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/bd/material_detail")


    '    Dim token As JToken = JToken.Parse(strJson)


    '    Dim clsXX As New LrGetToken.NodeAdder

    '    clsXX.AddNode(token, TreeView1.Nodes)

    '    ' 显示 TreeView
    '    TreeView1.ExpandAll()
    '    TreeView1.Visible = True

    '    ' dgv_detail.DataSource = dt_global2


    'End Sub




    Public Class ImageData 'EmployeeBean
        Public Property PWidth As Integer
        Public Property PHeight As Integer
        Public Property BImagePath As String
        Public Property SavePath As String
        Public Property Data As String
    End Class




    Private Sub btnIcMoBill_Click(sender As Object, e As EventArgs) Handles btnIcMoBill.Click '-生产工单
        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        param = New LrGetToken.LrParam()
        param.pKey = "bill_close_state" : param.pValue = "C"
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "bill_status" : param.pValue = "C"
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "end_date" : param.pValue = "2024-08-16"
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "page_size" : param.pValue = "100"
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "start_date" : param.pValue = "2024-08-16"
        paramLst.Add(param)
        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gClientSecret, paramLst, "jdy/v2/pm/mo_taskbill")

    End Sub

    Private Sub btnGetMoLst_Click(sender As Object, e As EventArgs) Handles btnGetMoLst.Click '-----生产工单详情'-
        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        param = New LrGetToken.LrParam()
        param.pKey = "number" : param.pValue = "SCRW-20240820-00002"
        paramLst.Add(param)
        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gClientSecret, paramLst, "jdy/v2/pm/mo_taskbill_detail")

    End Sub

    Private Sub btnGetInStkLst_Click(sender As Object, e As EventArgs)   '-----入库单列表 OK的
        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        param = New LrGetToken.LrParam()
        param.pKey = "bill_status" : param.pValue = ""
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "end_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "page" : param.pValue = "1"
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "page_size" : param.pValue = "100"
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "start_date" : param.pValue = dtp_start.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)
        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/inv_product")

        Product_in_detail(strJson)

        DataGridView1.DataSource = dt_global


    End Sub

    Private Sub btnGetInStkDetail_Click(sender As Object, e As EventArgs)  '-----入库单明细 OK的
        'Dim clsX As New LrGetToken.LrGetMtrlDatum
        'Dim paramLst As New List(Of LrGetToken.LrParam)
        'Dim param As New LrGetToken.LrParam()
        ''param = New LrGetToken.LrParam()
        ''param.pKey = "id" : param.pValue = "2151573134136962048"
        ''paramLst.Add(param)

        'param = New LrGetToken.LrParam()
        'param.pKey = "start_date" : param.pValue = dtp_start.Value.ToString("yyyy-MM-dd")
        'paramLst.Add(param)

        'param = New LrGetToken.LrParam()
        'param.pKey = "end_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
        'paramLst.Add(param)

        'Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/inv_product_detail")

        'product_in_detail(strJson)




    End Sub

    Private Sub DataGridView1_SelectionChanged(sender As Object, e As EventArgs) Handles DataGridView1.SelectionChanged


    End Sub

    Private Sub DataGridView1_CellMouseUp(sender As Object, e As DataGridViewCellMouseEventArgs) Handles DataGridView1.CellMouseUp
    End Sub

    Private Sub Button1_Click(sender As Object, e As EventArgs) Handles Button1.Click '--------订单列表


        Dim sql As String = ""
        sql = "delete from hf_00_orders_main"

        cmd.CommandText = sql
        cmd.Connection = conn

        cmd.ExecuteNonQuery()



        sql = "delete from hf_00_orders_detail"
        cmd.CommandText = sql
        cmd.Connection = conn

        cmd.ExecuteNonQuery()

        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        'param = New LrGetToken.LrParam()
        'param.pKey = "bill_close_state" : param.pValue = "C"
        'paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "end_bill_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "page" : param.pValue = 1
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "page_size" : param.pValue = 100
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "start_bill_date" : param.pValue = dtp_start.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)

        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/sal_order")

        BindJsonToDataGridView(strJson)

    End Sub
    Private Sub BindJsonToDataGridView(jsonStr As String)

        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(jsonStr)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As Integer = jsonData("data")("total_page")

            dt_global = New DataTable()

            ' 尝试获取 "rows"（方法1）
            Dim rows1 As JArray = Nothing
            If jsonData("data") IsNot Nothing AndAlso jsonData("data")("rows") IsNot Nothing Then
                rows1 = jsonData("data")("rows")
            End If

            ' 尝试获取 "data"（方法2）
            Dim rows2 As JObject = Nothing
            If jsonData("data") IsNot Nothing Then
                rows2 = jsonData("data")
            End If

            ' 处理方法1: 解析 "rows" (JArray)
            If rows1 IsNot Nothing AndAlso rows1.Count > 0 Then
                ' 取第一条数据的字段作为列名
                For Each prop As JProperty In rows1(0)
                    dt_global.Columns.Add(prop.Name)
                Next

                ' 添加数据
                For Each item As JObject In rows1
                    Dim row As DataRow = dt_global.NewRow()
                    For Each prop As JProperty In item.Properties()
                        row(prop.Name) = prop.Value.ToString()
                    Next
                    dt_global.Rows.Add(row)
                Next
            ElseIf rows2 IsNot Nothing Then
                ' 处理方法2: 解析 "material_entity" (JArray)
                Dim materialArray As JArray = rows2("material_entity")

                If materialArray IsNot Nothing AndAlso materialArray.Count > 0 Then
                    ' 取第一条数据的字段作为列名
                    For Each prop As JProperty In materialArray(0)
                        dt_global.Columns.Add(prop.Name)
                    Next

                    ' 添加数据
                    For Each item As JObject In materialArray
                        Dim row As DataRow = dt_global.NewRow()
                        For Each prop As JProperty In item.Properties()
                            row(prop.Name) = prop.Value.ToString()
                        Next
                        dt_global.Rows.Add(row)
                    Next
                Else
                    MessageBox.Show("material_entity 为空，无法转换 DataTable")
                End If
            Else
                MessageBox.Show("JSON 数据为空，无法转换为 DataTable")
            End If

            ' 绑定 DataGridView
            DataGridView1.DataSource = dt_global







            ' 获取数据库连接
            Dim conn As New SqlConnection(connstring)
            conn.Open()
            Dim sql As String = ""



            Dim clsX As New LrGetToken.LrGetMtrlDatum
            ' 遍历每一页的 rows
            For page As Integer = 1 To totalPage
                ' 更新 "page" 和 "page_size"
                Dim paramLst As New List(Of LrGetToken.LrParam)

                Dim param As New LrGetToken.LrParam()
                'param.pKey = "bill_close_state"
                'param.pValue = "C"
                'paramLst.Add(param)


                param = New LrGetToken.LrParam()
                param.pKey = "page"
                param.pValue = page
                paramLst.Add(param)


                param = New LrGetToken.LrParam()
                param.pKey = "page_size"
                param.pValue = 100
                paramLst.Add(param)

                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/sal_order")
                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取当前页的 rows 数据
                Dim pageRows As JArray = pageData("data")("rows")

                If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                    ' 插入每页数据到数据库

                    Dim dt_order As New DataTable

                    dt_order.Columns.Add("id", GetType(String))
                    dt_order.Columns.Add("bill_no", GetType(String))
                    dt_order.Columns.Add("bill_date", GetType(DateTime))
                    dt_order.Columns.Add("customer_id", GetType(String))
                    dt_order.Columns.Add("customer_name", GetType(String))
                    dt_order.Columns.Add("customer_number", GetType(String))
                    dt_order.Columns.Add("bill_close_state", GetType(String))
                    dt_order.Columns.Add("io_status", GetType(String))
                    dt_order.Columns.Add("real_io_status", GetType(String))


                    For Each item As JObject In pageRows


                        dt_order.Rows.Add(item("id").ToString(), item("bill_no").ToString(), item("bill_date").ToString(), item("customer_id").ToString(), item("customer_name").ToString(), item("customer_number").ToString(), item("bill_close_state").ToString(), item("io_status").ToString(), item("real_io_status").ToString())

                    Next


                    ' 插入到数据库

                    Using connection As New SqlConnection(connstring)
                        connection.Open()

                        Using bulkCopy As New SqlBulkCopy(connection)
                            bulkCopy.DestinationTableName = "hf_00_orders_main"

                            ' 4. 映射字段
                            bulkCopy.ColumnMappings.Add("id", "id")
                            bulkCopy.ColumnMappings.Add("bill_no", "bill_no")
                            bulkCopy.ColumnMappings.Add("bill_date", "bill_date")
                            bulkCopy.ColumnMappings.Add("customer_id", "customer_id")
                            bulkCopy.ColumnMappings.Add("customer_name", "customer_name")
                            bulkCopy.ColumnMappings.Add("customer_number", "customer_number")
                            bulkCopy.ColumnMappings.Add("bill_close_state", "bill_close_state")
                            bulkCopy.ColumnMappings.Add("io_status", "io_status")
                            bulkCopy.ColumnMappings.Add("real_io_status", "real_io_status")

                            Try
                                ' 5. 执行批量插入
                                bulkCopy.WriteToServer(dt_order)
                                Console.WriteLine("数据批量插入成功！")
                            Catch ex As Exception
                                Console.WriteLine("插入数据失败：" & ex.Message)
                            End Try
                        End Using
                    End Using


                End If
            Next


            Dim sql_detail As String = "select * from hf_00_orders_main" '----------------------------每张订单

            Dim cmd1 As New SqlCommand(sql_detail, conn)

            Dim da As New SqlDataAdapter
            Dim dt As New DataTable
            da.SelectCommand = cmd1

            da.Fill(dt)


            For x As Integer = 0 To dt.Rows.Count - 1 '--------------------每张订单写入明细

                order_id = dt.Rows(x).Item("id")
                order_no = dt.Rows(x).Item("bill_no")

                Dim paramLst11 As New List(Of LrGetToken.LrParam)

                Dim param11 As New LrGetToken.LrParam()
                param11.pKey = "id"
                param11.pValue = dt.Rows(x).Item(0)
                paramLst11.Add(param11)

                Dim percents As String = ""
                Dim card As String = “”

                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst11, "jdy/v2/scm/sal_order_detail")


                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取 remark 字段
                Dim remark As String = pageData("data")("remark").ToString()

                ' 获取 material_entity 数组
                Dim materialEntities As JArray = pageData("data")("material_entity")



                ' 遍历所有行
                For Each materialEntity As JObject In materialEntities
                    ' 提取每一行的数据
                    Dim materialName As String = materialEntity("material_name").ToString()
                    Dim materialNumber As String = materialEntity("material_number").ToString()
                    Dim stockName As String = materialEntity("stock_name").ToString()
                    Dim price As Double = Convert.ToDouble(materialEntity("price"))
                    Dim qty As Integer = Convert.ToInt32(materialEntity("qty"))
                    Dim comment As String = materialEntity("comment").ToString()
                    Dim deliveryDate As String = materialEntity("delivery_date").ToString()
                    Dim customEntityName As String = percents



                    Dim card_no As String

                    If materialEntity("custom_entity_field") IsNot Nothing Then
                        ' 确保 "custom_entity_field" 是一个数组
                        If materialEntity("custom_entity_field").Type = JTokenType.Array Then
                            Dim customEntity As JArray = materialEntity("custom_entity_field")
                            ' 继续处理数组内容
                        ElseIf materialEntity("custom_entity_field").Type = JTokenType.Object Then
                            Dim customEntity As JObject = materialEntity("custom_entity_field")
                            ' 访问自定义字段  
                            If customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name") IsNot Nothing Then
                                Dim customFieldName As String = customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name").ToString()
                                percents = customFieldName '-------打尺
                            Else
                                Console.WriteLine("字段 '3t1q2jkjahvn2_name' 不存在。")
                            End If

                            If customEntity("custom_entity_field__1__4mrjiazczldljia6") IsNot Nothing Then
                                card_no = customEntity("custom_entity_field__1__4mrjiazczldljia6").ToString() '----卡号
                                '  card = card_no

                            Else
                                Console.WriteLine("字段 'custom_entity_field__1__4mrjiazczldljia6' 不存在。")
                            End If

                        End If
                    Else
                        Console.WriteLine("material 对象中没有 'custom_entity_field' 字段。")
                    End If











                    Dim card1 As String = card_no

                    Dim query As String = "
    INSERT INTO hf_00_orders_detail 
    (material_name, material_number, stock_name, price, qty, comment, delivery_date, custom_entity_name, remark,card,order_id,order_no)
    VALUES (@material_name, @material_number, @stock_name, @price, @qty, @comment, @delivery_date, @custom_entity_name, @remark,@card,@order_id,@order_no)"

                    Try
                        ' 创建数据库连接
                        Using connection As New SqlConnection(connstring)
                            connection.Open()

                            ' 创建 SQL 命令
                            Using cmd As New SqlCommand(query, connection)
                                ' 添加参数并传递变量值
                                cmd.Parameters.AddWithValue("@material_name", materialName)
                                cmd.Parameters.AddWithValue("@material_number", materialNumber)
                                cmd.Parameters.AddWithValue("@stock_name", stockName)
                                cmd.Parameters.AddWithValue("@price", price)
                                cmd.Parameters.AddWithValue("@qty", qty)
                                cmd.Parameters.AddWithValue("@comment", comment)
                                cmd.Parameters.AddWithValue("@delivery_date", deliveryDate)
                                cmd.Parameters.AddWithValue("@custom_entity_name", customEntityName)
                                cmd.Parameters.AddWithValue("@remark", remark)
                                cmd.Parameters.AddWithValue("@card", card1)
                                cmd.Parameters.AddWithValue("@order_id", order_id)
                                cmd.Parameters.AddWithValue("@order_no", order_no)

                                ' 执行插入操作
                                cmd.ExecuteNonQuery()
                            End Using
                        End Using

                        '  MessageBox.Show("数据已成功插入！", "成功", MessageBoxButtons.OK, MessageBoxIcon.Information)
                    Catch ex As Exception
                        MessageBox.Show("插入数据时出错：" & ex.Message, "错误", MessageBoxButtons.OK, MessageBoxIcon.Error)
                    End Try


                Next



                '' 获取当前页的 rows 数据
                'Dim pageRows As JArray = pageData("data")("rows")

                'If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                '    ' 插入每页数据到数据库
                '    For Each item As JObject In pageRows
                '        Dim id As String = item("id").ToString()
                '        Dim bill_no As String = item("bill_no").ToString()
                '        ' 获取其他字段
                '        ' ...

                '        ' 插入到数据库
                '        sql = "INSERT INTO hf_00_orders_main (id, bill_no) VALUES (@id, @bill_no)"
                '        Dim cmd11 As New SqlCommand(sql, conn)
                '        cmd11.Parameters.AddWithValue("@id", id)
                '        cmd11.Parameters.AddWithValue("@bill_no", bill_no)
                '        ' 添加其他参数
                '        cmd1.ExecuteNonQuery()
                '    Next
                'End If




            Next












            'Dim paramLst1 As New List(Of LrGetToken.LrParam)
            'Dim param1 As New LrGetToken.LrParam()
            'param1.pKey = "id"
            'param1.pValue = "C"
            'paramLst1.Add(param1)
            'Dim strJson_detail As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst1, "jdy/v2/scm/sal_order_detail")







            conn.Close()


        Catch ex As Exception
            MessageBox.Show("解析 JSON 失败：" & ex.Message)
        End Try


        MsgBox("")

    End Sub


    Private Sub db_in(jsonstr As String)


        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(jsonstr)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As Integer = jsonData("data")("total_page")

            dt_global = New DataTable()

            ' 尝试获取 "rows"（方法1）
            Dim rows1 As JArray = Nothing
            If jsonData("data") IsNot Nothing AndAlso jsonData("data")("rows") IsNot Nothing Then
                rows1 = jsonData("data")("rows")
            End If

            ' 尝试获取 "data"（方法2）
            Dim rows2 As JObject = Nothing
            If jsonData("data") IsNot Nothing Then
                rows2 = jsonData("data")
            End If

            ' 处理方法1: 解析 "rows" (JArray)
            If rows1 IsNot Nothing AndAlso rows1.Count > 0 Then
                ' 取第一条数据的字段作为列名
                For Each prop As JProperty In rows1(0)
                    dt_global.Columns.Add(prop.Name)
                Next

                ' 添加数据
                For Each item As JObject In rows1
                    Dim row As DataRow = dt_global.NewRow()
                    For Each prop As JProperty In item.Properties()
                        row(prop.Name) = prop.Value.ToString()
                    Next
                    dt_global.Rows.Add(row)
                Next
            ElseIf rows2 IsNot Nothing Then
                '' 处理方法2: 解析 "material_entity" (JArray)
                'Dim materialArray As JArray = rows2("material_entity")

                'If materialArray IsNot Nothing AndAlso materialArray.Count > 0 Then
                '    ' 取第一条数据的字段作为列名
                '    For Each prop As JProperty In materialArray(0)
                '        dt_global.Columns.Add(prop.Name)
                '    Next

                '    ' 添加数据
                '    For Each item As JObject In materialArray
                '        Dim row As DataRow = dt_global.NewRow()
                '        For Each prop As JProperty In item.Properties()
                '            row(prop.Name) = prop.Value.ToString()
                '        Next
                '        dt_global.Rows.Add(row)
                '    Next
                'Else
                '    MessageBox.Show("material_entity 为空，无法转换 DataTable")
                'End If
            Else
                MessageBox.Show("JSON 数据为空，无法转换为 DataTable")
            End If

            ' 绑定 DataGridView
            DataGridView1.DataSource = dt_global







            ' 获取数据库连接
            Dim conn As New SqlConnection(connstring)
            conn.Open()
            Dim sql As String = ""



            Dim clsX As New LrGetToken.LrGetMtrlDatum
            ' 遍历每一页的 rows
            For page As Integer = 1 To totalPage
                ' 更新 "page" 和 "page_size"
                Dim paramLst As New List(Of LrGetToken.LrParam)

                Dim param As New LrGetToken.LrParam()
                'param.pKey = "bill_close_state"
                'param.pValue = "C"
                'paramLst.Add(param)


                param = New LrGetToken.LrParam()
                param.pKey = "page"
                param.pValue = page
                paramLst.Add(param)


                param = New LrGetToken.LrParam()
                param.pKey = "page_size"
                param.pValue = 100
                paramLst.Add(param)

                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/inv_tfinc")
                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取当前页的 rows 数据
                Dim pageRows As JArray = pageData("data")("rows")

                If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                    ' 插入每页数据到数据库

                    Dim dt_order As New DataTable


                    dt_order.Columns.Add("bill_no", GetType(String))
                    dt_order.Columns.Add("bill_date", GetType(DateTime))
                    dt_order.Columns.Add("dept_name", GetType(String))
                    dt_order.Columns.Add("out_dept_name", GetType(String))
                    dt_order.Columns.Add("customer_number", GetType(String))
                    dt_order.Columns.Add("bill_status", GetType(String))


                    For Each item As JObject In pageRows


                        dt_order.Rows.Add(item("id").ToString(), item("bill_no").ToString(), item("bill_date").ToString(), item("customer_id").ToString(), item("customer_name").ToString(), item("customer_number").ToString(), item("bill_close_state").ToString(), item("io_status").ToString(), item("real_io_status").ToString())

                    Next


                    ' 插入到数据库

                    Using connection As New SqlConnection(connstring)
                        connection.Open()

                        Using bulkCopy As New SqlBulkCopy(connection)
                            bulkCopy.DestinationTableName = "hf_00_orders_main"

                            ' 4. 映射字段
                            bulkCopy.ColumnMappings.Add("id", "id")
                            bulkCopy.ColumnMappings.Add("bill_no", "bill_no")
                            bulkCopy.ColumnMappings.Add("bill_date", "bill_date")
                            bulkCopy.ColumnMappings.Add("customer_id", "customer_id")
                            bulkCopy.ColumnMappings.Add("customer_name", "customer_name")
                            bulkCopy.ColumnMappings.Add("customer_number", "customer_number")
                            bulkCopy.ColumnMappings.Add("bill_close_state", "bill_close_state")
                            bulkCopy.ColumnMappings.Add("io_status", "io_status")
                            bulkCopy.ColumnMappings.Add("real_io_status", "real_io_status")

                            Try
                                ' 5. 执行批量插入
                                bulkCopy.WriteToServer(dt_order)
                                Console.WriteLine("数据批量插入成功！")
                            Catch ex As Exception
                                Console.WriteLine("插入数据失败：" & ex.Message)
                            End Try
                        End Using
                    End Using


                End If
            Next


            Dim sql_detail As String = "select * from hf_00_orders_main" '----------------------------每张订单

            Dim cmd1 As New SqlCommand(sql_detail, conn)

            Dim da As New SqlDataAdapter
            Dim dt As New DataTable
            da.SelectCommand = cmd1

            da.Fill(dt)


            For x As Integer = 0 To dt.Rows.Count - 1 '--------------------每张订单写入明细

                order_id = dt.Rows(x).Item("id")
                order_no = dt.Rows(x).Item("bill_no")

                Dim paramLst11 As New List(Of LrGetToken.LrParam)

                Dim param11 As New LrGetToken.LrParam()
                param11.pKey = "id"
                param11.pValue = dt.Rows(x).Item(0)
                paramLst11.Add(param11)

                Dim percents As String = ""
                Dim card As String = “”

                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst11, "jdy/v2/scm/sal_order_detail")


                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取 remark 字段
                Dim remark As String = pageData("data")("remark").ToString()

                ' 获取 material_entity 数组
                Dim materialEntities As JArray = pageData("data")("material_entity")



                ' 遍历所有行
                For Each materialEntity As JObject In materialEntities
                    ' 提取每一行的数据
                    Dim materialName As String = materialEntity("material_name").ToString()
                    Dim materialNumber As String = materialEntity("material_number").ToString()
                    Dim stockName As String = materialEntity("stock_name").ToString()
                    Dim price As Double = Convert.ToDouble(materialEntity("price"))
                    Dim qty As Integer = Convert.ToInt32(materialEntity("qty"))
                    Dim comment As String = materialEntity("comment").ToString()
                    Dim deliveryDate As String = materialEntity("delivery_date").ToString()
                    Dim customEntityName As String = percents



                    Dim card_no As String

                    If materialEntity("custom_entity_field") IsNot Nothing Then
                        ' 确保 "custom_entity_field" 是一个数组
                        If materialEntity("custom_entity_field").Type = JTokenType.Array Then
                            Dim customEntity As JArray = materialEntity("custom_entity_field")
                            ' 继续处理数组内容
                        ElseIf materialEntity("custom_entity_field").Type = JTokenType.Object Then
                            Dim customEntity As JObject = materialEntity("custom_entity_field")
                            ' 访问自定义字段  
                            If customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name") IsNot Nothing Then
                                Dim customFieldName As String = customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name").ToString()
                                percents = customFieldName '-------打尺
                            Else
                                Console.WriteLine("字段 '3t1q2jkjahvn2_name' 不存在。")
                            End If

                            If customEntity("custom_entity_field__1__4mrjiazczldljia6") IsNot Nothing Then
                                card_no = customEntity("custom_entity_field__1__4mrjiazczldljia6").ToString() '----卡号
                                '  card = card_no

                            Else
                                Console.WriteLine("字段 'custom_entity_field__1__4mrjiazczldljia6' 不存在。")
                            End If

                        End If
                    Else
                        Console.WriteLine("material 对象中没有 'custom_entity_field' 字段。")
                    End If











                    Dim card1 As String = card_no

                    Dim query As String = "
    INSERT INTO hf_00_orders_detail 
    (material_name, material_number, stock_name, price, qty, comment, delivery_date, custom_entity_name, remark,card,order_id,order_no)
    VALUES (@material_name, @material_number, @stock_name, @price, @qty, @comment, @delivery_date, @custom_entity_name, @remark,@card,@order_id,@order_no)"

                    Try
                        ' 创建数据库连接
                        Using connection As New SqlConnection(connstring)
                            connection.Open()

                            ' 创建 SQL 命令
                            Using cmd As New SqlCommand(query, connection)
                                ' 添加参数并传递变量值
                                cmd.Parameters.AddWithValue("@material_name", materialName)
                                cmd.Parameters.AddWithValue("@material_number", materialNumber)
                                cmd.Parameters.AddWithValue("@stock_name", stockName)
                                cmd.Parameters.AddWithValue("@price", price)
                                cmd.Parameters.AddWithValue("@qty", qty)
                                cmd.Parameters.AddWithValue("@comment", comment)
                                cmd.Parameters.AddWithValue("@delivery_date", deliveryDate)
                                cmd.Parameters.AddWithValue("@custom_entity_name", customEntityName)
                                cmd.Parameters.AddWithValue("@remark", remark)
                                cmd.Parameters.AddWithValue("@card", card1)
                                cmd.Parameters.AddWithValue("@order_id", order_id)
                                cmd.Parameters.AddWithValue("@order_no", order_no)

                                ' 执行插入操作
                                cmd.ExecuteNonQuery()
                            End Using
                        End Using

                        '  MessageBox.Show("数据已成功插入！", "成功", MessageBoxButtons.OK, MessageBoxIcon.Information)
                    Catch ex As Exception
                        MessageBox.Show("插入数据时出错：" & ex.Message, "错误", MessageBoxButtons.OK, MessageBoxIcon.Error)
                    End Try


                Next



                '' 获取当前页的 rows 数据
                'Dim pageRows As JArray = pageData("data")("rows")

                'If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                '    ' 插入每页数据到数据库
                '    For Each item As JObject In pageRows
                '        Dim id As String = item("id").ToString()
                '        Dim bill_no As String = item("bill_no").ToString()
                '        ' 获取其他字段
                '        ' ...

                '        ' 插入到数据库
                '        sql = "INSERT INTO hf_00_orders_main (id, bill_no) VALUES (@id, @bill_no)"
                '        Dim cmd11 As New SqlCommand(sql, conn)
                '        cmd11.Parameters.AddWithValue("@id", id)
                '        cmd11.Parameters.AddWithValue("@bill_no", bill_no)
                '        ' 添加其他参数
                '        cmd1.ExecuteNonQuery()
                '    Next
                'End If




            Next












            'Dim paramLst1 As New List(Of LrGetToken.LrParam)
            'Dim param1 As New LrGetToken.LrParam()
            'param1.pKey = "id"
            'param1.pValue = "C"
            'paramLst1.Add(param1)
            'Dim strJson_detail As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst1, "jdy/v2/scm/sal_order_detail")







            conn.Close()


        Catch ex As Exception
            MessageBox.Show("解析 JSON 失败：" & ex.Message)
        End Try


        MsgBox("")

    End Sub


    Private Sub Product_in(jsonStr As String)

        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        '  Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(jsonStr)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As Integer = jsonData("data")("total_page")

            dt_global = New DataTable()

            ' 尝试获取 "rows"（方法1）
            Dim rows1 As JArray = Nothing
            If jsonData("data") IsNot Nothing AndAlso jsonData("data")("rows") IsNot Nothing Then
                rows1 = jsonData("data")("rows")
            End If

            ' 尝试获取 "data"（方法2）
            Dim rows2 As JObject = Nothing
            If jsonData("data") IsNot Nothing Then
                rows2 = jsonData("data")
            End If

            ' 处理方法1: 解析 "rows" (JArray)
            If rows1 IsNot Nothing AndAlso rows1.Count > 0 Then
                ' 取第一条数据的字段作为列名
                For Each prop As JProperty In rows1(0)
                    dt_global.Columns.Add(prop.Name)
                Next

                ' 添加数据
                For Each item As JObject In rows1
                    Dim row As DataRow = dt_global.NewRow()
                    For Each prop As JProperty In item.Properties()
                        row(prop.Name) = prop.Value.ToString()
                    Next
                    dt_global.Rows.Add(row)
                Next
            ElseIf rows2 IsNot Nothing Then

            Else
                MessageBox.Show("JSON 数据为空，无法转换为 DataTable")
            End If

            ' 绑定 DataGridView
            DataGridView1.DataSource = dt_global



            ' 获取数据库连接
            Dim conn As New SqlConnection(connstring)
            conn.Open()
            Dim sql As String = ""



            Dim clsX As New LrGetToken.LrGetMtrlDatum
            ' 遍历每一页的 rows
            For page As Integer = 1 To totalPage

                Dim paramLst As New List(Of LrGetToken.LrParam)

                Dim param As New LrGetToken.LrParam()
                'param.pKey = "bill_close_state"
                'param.pValue = "C"
                'paramLst.Add(param)


                param = New LrGetToken.LrParam()
                param.pKey = "end_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
                paramLst.Add(param)
                param = New LrGetToken.LrParam()
                param.pKey = "page" : param.pValue = page
                paramLst.Add(param)

                param = New LrGetToken.LrParam()
                param.pKey = "page_size" : param.pValue = 100
                paramLst.Add(param)
                param = New LrGetToken.LrParam()
                param.pKey = "start_date" : param.pValue = dtp_start.Value.ToString("yyyy-MM-dd")
                paramLst.Add(param)



                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/inv_product")
                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取当前页的 rows 数据
                Dim pageRows As JArray = pageData("data")("rows")

                If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                    ' 插入每页数据到数据库

                    Dim dt_order As New DataTable

                    dt_order.Columns.Add("id", GetType(String))
                    dt_order.Columns.Add("bill_no", GetType(String))
                    dt_order.Columns.Add("bill_date", GetType(Date))
                    dt_order.Columns.Add("remark", GetType(String))


                    For Each item As JObject In pageRows
                        ' 确保日期类型正确，防止Null错误
                        Dim billDate As DateTime = If(item("bill_date") IsNot Nothing, Convert.ToDateTime(item("bill_date")), DateTime.MinValue)

                        ' 处理可能为Null的字段，使用默认值或空字符串
                        dt_order.Rows.Add(
            If(item("id") IsNot Nothing, item("id").ToString(), ""),
            If(item("bill_no") IsNot Nothing, item("bill_no").ToString(), ""),
            billDate,
            If(item("remark") IsNot Nothing, item("remark").ToString(), "")
        )
                    Next




                    ' 插入到数据库
                    Using connection As New SqlConnection(connstring)
                        connection.Open()

                        Using bulkCopy As New SqlBulkCopy(connection)
                            bulkCopy.DestinationTableName = "hf_00_k3_product_in"

                            ' 4. 映射字段
                            bulkCopy.ColumnMappings.Add("id", "id")
                            bulkCopy.ColumnMappings.Add("bill_no", "bill_no")
                            bulkCopy.ColumnMappings.Add("bill_date", "bill_date")
                            bulkCopy.ColumnMappings.Add("remark", "remark")

                            Try
                                ' 5. 执行批量插入

                                DataGridView1.DataSource = dt_order

                                bulkCopy.WriteToServer(dt_order)
                                Console.WriteLine("数据批量插入成功！")
                            Catch ex As Exception
                                MsgBox("插入数据失败：" & ex.Message)
                            End Try
                        End Using
                    End Using


                End If
            Next


            Dim sql_detail As String = "select * from hf_00_k3_product_in" '----------------------------每张订单

            Dim cmd1 As New SqlCommand(sql_detail, conn)

            Dim da As New SqlDataAdapter
            Dim dt As New DataTable
            da.SelectCommand = cmd1

            da.Fill(dt)


            For x As Integer = 0 To dt.Rows.Count - 1 '--------------------每张订单写入明细

                order_id = dt.Rows(x).Item("id")
                order_no = dt.Rows(x).Item("bill_no")

                Dim paramLst11 As New List(Of LrGetToken.LrParam)

                Dim param11 As New LrGetToken.LrParam()
                param11.pKey = "id"
                param11.pValue = dt.Rows(x).Item(0)
                paramLst11.Add(param11)

                Dim percents As String = ""


                ' 调用 API 获取每页数据详请
                Dim strJson1 As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst11, "jdy/v2/scm/inv_product_detail")


                Dim pageData As JObject = JObject.Parse(strJson1)


                ' 获取 material_entity 数组
                Dim materialEntities As JArray = pageData("data")("material_entity")

                Dim mydata As JObject = pageData("data")

                Dim bill_date1 As String = mydata("bill_date").ToString()
                Dim bill_no1 As String = mydata("bill_no").ToString()
                Dim bill_type_name As String = mydata("bill_type_name").ToString()



                ' 遍历所有行
                For Each materialEntity As JObject In materialEntities
                    ' 提取每一行的数据

                    Dim materialName As String = materialEntity("material_name").ToString()
                    Dim materialNumber As String = materialEntity("material_number").ToString()
                    Dim stockName As String = materialEntity("stock_name").ToString()
                    Dim batch_no As String = materialEntity("batch_no").ToString()
                    Dim qty As Double = Convert.ToDecimal(materialEntity("qty"))
                    Dim aux_qty As Double = Convert.ToDecimal(materialEntity("aux_qty"))
                    Dim comment As String = materialEntity("comment").ToString()

                    Dim unit_id As String = materialEntity("unit_id").ToString()



                    Dim query As String = "
    INSERT INTO hf_00_k3_product_in_detail 
(bill_date,bill_no,materialName, materialNumber, stockName, batch_no, qty, aux_qty, comment,bill_type_name,unit_id)
VALUES 
(@bill_date,@bill_no,@material_name, @material_number, @stock_name, @batch_no, @qty, @aux_qty, @comment,@bill_type_name,@unit_id);
"

                    Try
                        ' 创建数据库连接
                        Using connection As New SqlConnection(connstring)
                            connection.Open()

                            ' 创建 SQL 命令
                            Using cmd As New SqlCommand(query, connection)
                                ' 添加参数并传递变量值
                                cmd.Parameters.AddWithValue("@bill_date", bill_date1)
                                cmd.Parameters.AddWithValue("@bill_no", bill_no1)

                                cmd.Parameters.AddWithValue("@material_name", materialName)
                                cmd.Parameters.AddWithValue("@material_number", materialNumber)
                                cmd.Parameters.AddWithValue("@stock_name", stockName)
                                cmd.Parameters.AddWithValue("@batch_no", batch_no) ' Updated to match batch_no column
                                cmd.Parameters.AddWithValue("@qty", qty)
                                cmd.Parameters.AddWithValue("@aux_qty", aux_qty) ' Added aux_qty
                                cmd.Parameters.AddWithValue("@comment", comment)
                                cmd.Parameters.AddWithValue("@bill_type_name", bill_type_name)
                                cmd.Parameters.AddWithValue("@unit_id", unit_id)

                                ' 执行插入操作
                                cmd.ExecuteNonQuery()
                            End Using
                        End Using

                        '  MessageBox.Show("数据已成功插入！", "成功", MessageBoxButtons.OK, MessageBoxIcon.Information)
                    Catch ex As Exception
                        MessageBox.Show("插入数据时出错：" & ex.Message, "错误", MessageBoxButtons.OK, MessageBoxIcon.Error)
                    End Try


                Next



                '' 获取当前页的 rows 数据
                'Dim pageRows As JArray = pageData("data")("rows")

                'If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                '    ' 插入每页数据到数据库
                '    For Each item As JObject In pageRows
                '        Dim id As String = item("id").ToString()
                '        Dim bill_no As String = item("bill_no").ToString()
                '        ' 获取其他字段
                '        ' ...

                '        ' 插入到数据库
                '        sql = "INSERT INTO hf_00_orders_main (id, bill_no) VALUES (@id, @bill_no)"
                '        Dim cmd11 As New SqlCommand(sql, conn)
                '        cmd11.Parameters.AddWithValue("@id", id)
                '        cmd11.Parameters.AddWithValue("@bill_no", bill_no)
                '        ' 添加其他参数
                '        cmd1.ExecuteNonQuery()
                '    Next
                'End If




            Next












            'Dim paramLst1 As New List(Of LrGetToken.LrParam)
            'Dim param1 As New LrGetToken.LrParam()
            'param1.pKey = "id"
            'param1.pValue = "C"
            'paramLst1.Add(param1)
            'Dim strJson_detail As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst1, "jdy/v2/scm/sal_order_detail")







            conn.Close()


        Catch ex As Exception
            MessageBox.Show("解析 JSON 失败：" & ex.Message)
        End Try





        MsgBox("")

    End Sub

    Private Sub Product_in_detail(jsonStr As String)

        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(jsonStr)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As Integer = jsonData("data")("total_page")

            dt_global = New DataTable()

            ' 尝试获取 "rows"（方法1）
            Dim rows1 As JArray = Nothing
            If jsonData("data") IsNot Nothing AndAlso jsonData("data")("rows") IsNot Nothing Then
                rows1 = jsonData("data")("rows")
            End If

            ' 尝试获取 "data"（方法2）
            Dim rows2 As JObject = Nothing
            If jsonData("data") IsNot Nothing Then
                rows2 = jsonData("data")
            End If

            ' 处理方法1: 解析 "rows" (JArray)
            If rows1 IsNot Nothing AndAlso rows1.Count > 0 Then
                ' 取第一条数据的字段作为列名
                For Each prop As JProperty In rows1(0)
                    dt_global.Columns.Add(prop.Name)
                Next

                ' 添加数据
                For Each item As JObject In rows1
                    Dim row As DataRow = dt_global.NewRow()
                    For Each prop As JProperty In item.Properties()
                        row(prop.Name) = prop.Value.ToString()
                    Next
                    dt_global.Rows.Add(row)
                Next
            ElseIf rows2 IsNot Nothing Then

            Else
                MessageBox.Show("JSON 数据为空，无法转换为 DataTable")
            End If

            ' 绑定 DataGridView
            DataGridView1.DataSource = dt_global



            ' 获取数据库连接
            Dim conn As New SqlConnection(connstring)
            conn.Open()
            Dim sql As String = ""



            Dim clsX As New LrGetToken.LrGetMtrlDatum
            ' 遍历每一页的 rows
            For page As Integer = 1 To totalPage

                Dim paramLst As New List(Of LrGetToken.LrParam)

                Dim param As New LrGetToken.LrParam()
                'param.pKey = "bill_close_state"
                'param.pValue = "C"
                'paramLst.Add(param)


                param = New LrGetToken.LrParam()
                param.pKey = "end_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
                paramLst.Add(param)
                param = New LrGetToken.LrParam()
                param.pKey = "page" : param.pValue = page
                paramLst.Add(param)

                param = New LrGetToken.LrParam()
                param.pKey = "page_size" : param.pValue = 100
                paramLst.Add(param)
                param = New LrGetToken.LrParam()
                param.pKey = "start_date" : param.pValue = dtp_start.Value.ToString("yyyy-MM-dd")
                paramLst.Add(param)



                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/inv_product")
                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取当前页的 rows 数据
                Dim pageRows As JArray = pageData("data")("rows")

                If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                    ' 插入每页数据到数据库

                    Dim dt_order As New DataTable

                    dt_order.Columns.Add("id", GetType(String))
                    dt_order.Columns.Add("bill_no", GetType(String))
                    dt_order.Columns.Add("bill_date", GetType(DateTime))
                    dt_order.Columns.Add("remark", GetType(String))


                    For Each item As JObject In pageRows


                        dt_order.Rows.Add(item("id").ToString(), item("bill_no").ToString(), item("bill_date").ToString(), item("remark").ToString())

                    Next


                    ' 插入到数据库

                    Using connection As New SqlConnection(connstring)
                        connection.Open()

                        Using bulkCopy As New SqlBulkCopy(connection)
                            bulkCopy.DestinationTableName = "hf_00_k3_product_in"

                            ' 4. 映射字段
                            bulkCopy.ColumnMappings.Add("id", "id")
                            bulkCopy.ColumnMappings.Add("bill_no", "bill_no")
                            bulkCopy.ColumnMappings.Add("bill_date", "bill_date")
                            bulkCopy.ColumnMappings.Add("remark", "remark")


                            Try
                                ' 5. 执行批量插入
                                bulkCopy.WriteToServer(dt_order)
                                Console.WriteLine("数据批量插入成功！")
                            Catch ex As Exception
                                Console.WriteLine("插入数据失败：" & ex.Message)
                            End Try
                        End Using
                    End Using


                End If
            Next


            Dim sql_detail As String = "select * from hf_00_k3_product_in" '----------------------------每张订单

            Dim cmd1 As New SqlCommand(sql_detail, conn)

            Dim da As New SqlDataAdapter
            Dim dt As New DataTable
            da.SelectCommand = cmd1

            da.Fill(dt)


            For x As Integer = 0 To dt.Rows.Count - 1 '--------------------每张订单写入明细

                order_id = dt.Rows(x).Item("id")
                order_no = dt.Rows(x).Item("bill_no")

                Dim paramLst11 As New List(Of LrGetToken.LrParam)

                Dim param11 As New LrGetToken.LrParam()
                param11.pKey = "id"
                param11.pValue = dt.Rows(x).Item(0)
                paramLst11.Add(param11)

                Dim percents As String = ""
                Dim card As String = “”

                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst11, "jdy/v2/scm/sal_order_detail")


                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取 remark 字段
                Dim remark As String = pageData("data")("remark").ToString()

                ' 获取 material_entity 数组
                Dim materialEntities As JArray = pageData("data")("material_entity")

                For Each material As JObject In materialEntities

                    ' 确保 "custom_entity_field" 存在于 material 中
                    If material("custom_entity_field") IsNot Nothing Then
                        ' 确保 "custom_entity_field" 是一个数组
                        If material("custom_entity_field").Type = JTokenType.Array Then
                            Dim customEntity As JArray = material("custom_entity_field")
                            ' 继续处理数组内容
                        ElseIf material("custom_entity_field").Type = JTokenType.Object Then
                            Dim customEntity As JObject = material("custom_entity_field")
                            ' 访问自定义字段  
                            If customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name") IsNot Nothing Then
                                Dim customFieldName As String = customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name").ToString()
                                percents = customFieldName '-------打尺
                            Else
                                Console.WriteLine("字段 '3t1q2jkjahvn2_name' 不存在。")
                            End If

                            If customEntity("custom_entity_field__1__4mrjiazczldljia6") IsNot Nothing Then
                                Dim card_no As String = customEntity("custom_entity_field__1__4mrjiazczldljia6").ToString() '----卡号
                                card = card_no

                            Else
                                Console.WriteLine("字段 'custom_entity_field__1__4mrjiazczldljia6' 不存在。")
                            End If

                        End If
                    Else
                        Console.WriteLine("material 对象中没有 'custom_entity_field' 字段。")
                    End If
                Next



                ' 遍历所有行
                For Each materialEntity As JObject In materialEntities
                    ' 提取每一行的数据
                    Dim materialName As String = materialEntity("material_name").ToString()
                    Dim materialNumber As String = materialEntity("material_number").ToString()
                    Dim stockName As String = materialEntity("stock_name").ToString()
                    Dim price As Double = Convert.ToDouble(materialEntity("price"))
                    Dim qty As Integer = Convert.ToInt32(materialEntity("qty"))
                    Dim comment As String = materialEntity("comment").ToString()
                    Dim deliveryDate As String = materialEntity("delivery_date").ToString()
                    Dim customEntityName As String = percents


                    Dim query As String = "
    INSERT INTO hf_00_orders_detail 
    (material_name, material_number, stock_name, price, qty, comment, delivery_date, custom_entity_name, remark,card,order_id,order_no)
    VALUES (@material_name, @material_number, @stock_name, @price, @qty, @comment, @delivery_date, @custom_entity_name, @remark,@card,@order_id,@order_no)"

                    Try
                        ' 创建数据库连接
                        Using connection As New SqlConnection(connstring)
                            connection.Open()

                            ' 创建 SQL 命令
                            Using cmd As New SqlCommand(query, connection)
                                ' 添加参数并传递变量值
                                cmd.Parameters.AddWithValue("@material_name", materialName)
                                cmd.Parameters.AddWithValue("@material_number", materialNumber)
                                cmd.Parameters.AddWithValue("@stock_name", stockName)
                                cmd.Parameters.AddWithValue("@price", price)
                                cmd.Parameters.AddWithValue("@qty", qty)
                                cmd.Parameters.AddWithValue("@comment", comment)
                                cmd.Parameters.AddWithValue("@delivery_date", deliveryDate)
                                cmd.Parameters.AddWithValue("@custom_entity_name", customEntityName)
                                cmd.Parameters.AddWithValue("@remark", remark)
                                cmd.Parameters.AddWithValue("@card", card)
                                cmd.Parameters.AddWithValue("@order_id", order_id)
                                cmd.Parameters.AddWithValue("@order_no", order_no)

                                ' 执行插入操作
                                cmd.ExecuteNonQuery()
                            End Using
                        End Using

                        '  MessageBox.Show("数据已成功插入！", "成功", MessageBoxButtons.OK, MessageBoxIcon.Information)
                    Catch ex As Exception
                        MessageBox.Show("插入数据时出错：" & ex.Message, "错误", MessageBoxButtons.OK, MessageBoxIcon.Error)
                    End Try


                Next



                '' 获取当前页的 rows 数据
                'Dim pageRows As JArray = pageData("data")("rows")

                'If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                '    ' 插入每页数据到数据库
                '    For Each item As JObject In pageRows
                '        Dim id As String = item("id").ToString()
                '        Dim bill_no As String = item("bill_no").ToString()
                '        ' 获取其他字段
                '        ' ...

                '        ' 插入到数据库
                '        sql = "INSERT INTO hf_00_orders_main (id, bill_no) VALUES (@id, @bill_no)"
                '        Dim cmd11 As New SqlCommand(sql, conn)
                '        cmd11.Parameters.AddWithValue("@id", id)
                '        cmd11.Parameters.AddWithValue("@bill_no", bill_no)
                '        ' 添加其他参数
                '        cmd1.ExecuteNonQuery()
                '    Next
                'End If




            Next












            'Dim paramLst1 As New List(Of LrGetToken.LrParam)
            'Dim param1 As New LrGetToken.LrParam()
            'param1.pKey = "id"
            'param1.pValue = "C"
            'paramLst1.Add(param1)
            'Dim strJson_detail As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst1, "jdy/v2/scm/sal_order_detail")







            conn.Close()


        Catch ex As Exception
            MessageBox.Show("解析 JSON 失败：" & ex.Message)
        End Try





        MsgBox("")

    End Sub

    Private Sub Get_json_order_detail(jsonstr As String)



    End Sub

    Private Sub PopulateDataTableFromTreeView()
        Try
            ' 创建 DataTable
            Dim dt_global2 As New DataTable()

            ' 从 TreeView 获取节点名称
            Dim nodeNames As New List(Of String)()

            ' 递归遍历 TreeView 获取节点名称
            For Each node As TreeNode In TreeView1.Nodes
                PopulateNodeNames(node, nodeNames)
            Next

            ' 确保 DataTable 中有每个字段对应的列
            For Each nodeName As String In nodeNames
                If Not dt_global2.Columns.Contains(nodeName) Then
                    dt_global2.Columns.Add(nodeName)
                End If
            Next

            ' 遍历 TreeView 中的每个节点
            For Each node As TreeNode In TreeView1.Nodes
                ' 创建一个新行
                Dim row As DataRow = dt_global2.NewRow()

                ' 填充行数据
                FillRowWithNodeData(node, row)

                ' 添加该行到 DataTable
                dt_global2.Rows.Add(row)
            Next

            ' 绑定到 DataGridView
            dgv_detail.DataSource = dt_global2
        Catch ex As Exception
            MessageBox.Show("错误: " & ex.Message)
        End Try
    End Sub

    Private Sub PopulateNodeNames(node As TreeNode, ByRef nodeNames As List(Of String))
        ' 递归遍历节点并获取所有节点的名称
        If Not nodeNames.Contains(node.Text) Then
            nodeNames.Add(node.Text)
        End If

        For Each childNode As TreeNode In node.ChildNodes
            PopulateNodeNames(childNode, nodeNames)
        Next



    End Sub

    Private Sub FillRowWithNodeData(node As TreeNode, row As DataRow)
        ' 对节点没有子节点的，存储值
        If node.ChildNodes.Count = 0 Then
            ' 如果节点是最后一个值，将其用 "{...}" 包裹
            If node.Text.Contains("{") Then
                row(node.Text) = "{" & node.Text & "}"
            Else
                row(node.Text) = node.Text
            End If
        End If

        ' 对节点有子节点的，递归填充子节点数据
        For Each childNode As TreeNode In node.ChildNodes
            ' 递归填充子节点数据
            FillRowWithNodeData(childNode, row)
        Next
    End Sub





    Private Sub Button2_Click(sender As Object, e As EventArgs) Handles Button2.Click '---商品收发明细表





        'Dim sql As String = ""
        'sql = "delete from hf_00_k3_realtime_stock"

        'cmd.CommandText = sql
        'cmd.Connection = conn

        'cmd.ExecuteNonQuery()



        'sql = "delete from hf_00_orders_detail"
        'cmd.CommandText = sql
        'cmd.Connection = conn

        'cmd.ExecuteNonQuery()

        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        'param = New LrGetToken.LrParam()
        'param.pKey = "bill_close_state" : param.pValue = "C"
        'paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "end_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)


        param = New LrGetToken.LrParam()
        param.pKey = "filter_material_id" : param.pValue = "1863167288438514688"
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "filter_stock_id" : param.pValue = "1844877444239115264"
        paramLst.Add(param)


        param = New LrGetToken.LrParam()
        param.pKey = "page" : param.pValue = 1  '------page
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "page_size" : param.pValue = 100  '------page_size
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "start_date" : param.pValue = dtp_start.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)

        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/inv_detail")

        inv_io(strJson)

    End Sub


    Function ConvertTimestampToDate(timeStamp As Long) As String

        Dim dt As DateTime = New DateTime(1970, 1, 1, 0, 0, 0, 0, DateTimeKind.Utc)
        dt = dt.AddMilliseconds(timeStamp)
        Return dt.ToString("yyyy-MM-dd HH:mm:ss")
    End Function

    Private Sub txtappKey_TextChanged(sender As Object, e As EventArgs) Handles txtappKey.TextChanged

    End Sub

    Public Function GetSignature(request As APIRequest, nonce As String, timestamp As String) As String
        Dim querySign As String = GetQueryString(request, True)
        Dim my_sign As String = ""
        Dim sb As New StringBuilder()

        sb.Append(request.Method.ToString().ToUpper())
        sb.Append(ControlChars.NewLine)
        sb.Append(PathEncode(request.Path))
        sb.Append(ControlChars.NewLine)
        sb.Append(querySign)
        sb.Append(ControlChars.NewLine)
        sb.Append("x-api-nonce:" & nonce)
        sb.Append(ControlChars.NewLine)
        sb.Append("x-api-timestamp:" & timestamp)
        sb.Append(ControlChars.NewLine)

        ' my_sign = SHAHelper.HmacSHA256(_clientSecret, sb.ToString())

        ' Return SHAHelper.HmacSHA256(_clientSecret, sb.ToString())
    End Function
    Private Shared Function GetQueryString(request As APIRequest, Optional doubleEncode As Boolean = False) As String
        Dim querySign As String = String.Empty

        If request.Params IsNot Nothing AndAlso request.Params.Keys IsNot Nothing Then
            For Each key As String In request.Params.Keys
                If doubleEncode Then
                    querySign &= "&" & key.ToString() & "=" & HttpUtility.UrlEncode(HttpUtility.UrlEncode(request.Params(key))).Replace("+", "%20")
                Else
                    querySign &= "&" & key.ToString() & "=" & HttpUtility.UrlEncode(request.Params(key)).Replace("+", "%20")
                End If
            Next
            querySign = querySign.TrimStart("&"c)
        End If

        Return querySign
    End Function
    Private Shared Function PathEncode(path As String) As String
        path = HttpUtility.UrlEncode("/" & path.TrimStart("/"c)).Replace("%2f", "%2F").Replace("%2d", "%2D").Replace("(", "%28").Replace(")", "%29")
        Return path
    End Function

    Private Sub DataGridView1_LostFocus(sender As Object, e As EventArgs) Handles DataGridView1.LostFocus
        TreeView1.Visible = False
    End Sub

    Private Sub Button3_Click(sender As Object, e As EventArgs)  '-----订单明细
        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        param = New LrGetToken.LrParam()
        param.pKey = "id" : param.pValue = DataGridView1.CurrentRow.Cells("id").Value.ToString()
        paramLst.Add(param)
        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/sal_order_detail")



        Dim token As JToken = JToken.Parse(strJson)
        Dim clsXX As New LrGetToken.NodeAdder

        clsXX.AddNode(token, TreeView1.Nodes)

        ' 显示 TreeView
        TreeView1.ExpandAll()
        TreeView1.Visible = True

        '  PopulateDataTableFromTreeView()

        'BindJsonToDataGridView22(strJson)

    End Sub

    Private Sub Button5_Click(sender As Object, e As EventArgs) Handles Button5.Click  '---产品入库



        Dim sql As String = ""
        sql = "delete from hf_00_k3_product_in where bill_date BETWEEN '" & dtp_start.Value & "' and '" & dtp_end.Value & "'"

        cmd.CommandText = sql
        cmd.Connection = conn

        cmd.ExecuteNonQuery()



        sql = "delete hf_00_k3_product_in_detail where bill_date BETWEEN '" & dtp_start.Value & "' and '" & dtp_end.Value & "'"
        cmd.CommandText = sql
        cmd.Connection = conn

        cmd.ExecuteNonQuery()

        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        'param = New LrGetToken.LrParam()
        'param.pKey = "bill_close_state" : param.pValue = "C"
        'paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "end_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "page" : param.pValue = 1
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "page_size" : param.pValue = 100
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "start_date" : param.pValue = dtp_start.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)

        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/inv_product")

        Product_in(strJson)



    End Sub

    Private Sub Button6_Click(sender As Object, e As EventArgs) Handles Button6.Click
        '-------库存查询




        Dim sql As String = ""
        sql = "delete from hf_00_k3_realtime_stock"

        cmd.CommandText = sql
        cmd.Connection = conn

        cmd.ExecuteNonQuery()



        'sql = "delete from hf_00_orders_detail"
        'cmd.CommandText = sql
        'cmd.Connection = conn

        'cmd.ExecuteNonQuery()

        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        'param = New LrGetToken.LrParam()
        'param.pKey = "bill_close_state" : param.pValue = "C"
        'paramLst.Add(param)
        'param = New LrGetToken.LrParam()
        'param.pKey = "end_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
        'paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "page" : param.pValue = 1  '------page
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "page_size" : param.pValue = 1000  '------page_size
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "show_batch_no_kf_period" : param.pValue = "1"
        paramLst.Add(param)

        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/inv/inv_inventory_ims")

        query_stock(strJson)





    End Sub


    Private Sub query_stock(stringJson As String)

        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(stringJson)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As Integer = jsonData("data")("total_page")

            dt_global = New DataTable()

            ' 尝试获取 "rows"（方法1）
            Dim rows1 As JArray = Nothing
            If jsonData("data") IsNot Nothing AndAlso jsonData("data")("rows") IsNot Nothing Then
                rows1 = jsonData("data")("rows")
            End If

            ' 尝试获取 "data"（方法2）
            Dim rows2 As JObject = Nothing
            If jsonData("data") IsNot Nothing Then
                rows2 = jsonData("data")
            End If

            ' 处理方法1: 解析 "rows" (JArray)
            If rows1 IsNot Nothing AndAlso rows1.Count > 0 Then
                ' 取第一条数据的字段作为列名
                For Each prop As JProperty In rows1(0)
                    dt_global.Columns.Add(prop.Name)
                Next

                ' 添加数据
                For Each item As JObject In rows1
                    Dim row As DataRow = dt_global.NewRow()
                    For Each prop As JProperty In item.Properties()
                        row(prop.Name) = prop.Value.ToString()
                    Next
                    dt_global.Rows.Add(row)
                Next
            ElseIf rows2 IsNot Nothing Then

            Else
                MessageBox.Show("JSON 数据为空，无法转换为 DataTable")
            End If

            ' 绑定 DataGridView
            DataGridView1.DataSource = dt_global



            ' 获取数据库连接
            Dim conn As New SqlConnection(connstring)
            conn.Open()
            Dim sql As String = ""



            Dim clsX As New LrGetToken.LrGetMtrlDatum
            ' 遍历每一页的 rows
            For page As Integer = 1 To totalPage

                Dim paramLst As New List(Of LrGetToken.LrParam)

                Dim param As New LrGetToken.LrParam()
                'param.pKey = "bill_close_state"
                'param.pValue = "C"
                'paramLst.Add(param)



                param = New LrGetToken.LrParam()
                param.pKey = "page" : param.pValue = page
                paramLst.Add(param)

                param = New LrGetToken.LrParam()
                param.pKey = "page_size" : param.pValue = 1000
                paramLst.Add(param)

                param = New LrGetToken.LrParam()
                param.pKey = "show_batch_no_kf_period" : param.pValue = "1"
                paramLst.Add(param)




                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/inv/inv_inventory_ims")
                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取当前页的 rows 数据
                Dim pageRows As JArray = pageData("data")("rows")

                If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                    ' 插入每页数据到数据库

                    Dim dt_order As New DataTable

                    dt_order.Columns.Add("material_id", GetType(String))
                    dt_order.Columns.Add("material_number", GetType(String))
                    dt_order.Columns.Add("material_name", GetType(String))
                    dt_order.Columns.Add("stock_number", GetType(String))
                    dt_order.Columns.Add("stockid_name", GetType(String))
                    dt_order.Columns.Add("aux_unit_id", GetType(String))
                    dt_order.Columns.Add("qty", GetType(String))
                    dt_order.Columns.Add("batch_no", GetType(String))

                    For Each item As JObject In pageRows

                        dt_order.Rows.Add(item("material_id").ToString(), item("material_number").ToString(), item("material_name").ToString(), item("stock_number").ToString(), item("stockid_name").ToString(), item("aux_unit_id").ToString(), item("qty").ToString(), item("batch_no").ToString())

                    Next


                    ' 插入到数据库

                    Using connection As New SqlConnection(connstring)
                        connection.Open()

                        Using bulkCopy As New SqlBulkCopy(connection)
                            bulkCopy.DestinationTableName = "hf_00_k3_realtime_stock"

                            ' 4. 映射字段
                            bulkCopy.ColumnMappings.Add("material_id", "material_id")
                            bulkCopy.ColumnMappings.Add("material_number", "material_number")
                            bulkCopy.ColumnMappings.Add("material_name", "material_category_name")
                            bulkCopy.ColumnMappings.Add("stock_number", "stock_number")

                            bulkCopy.ColumnMappings.Add("stockid_name", "stockid_name")
                            bulkCopy.ColumnMappings.Add("aux_unit_id", "aux_unit_id")
                            bulkCopy.ColumnMappings.Add("qty", "qty")
                            bulkCopy.ColumnMappings.Add("batch_no", "batch_no")


                            Try
                                ' 5. 执行批量插入
                                bulkCopy.WriteToServer(dt_order)
                                MsgBox("数据批量插入成功！")
                            Catch ex As Exception
                                MsgBox("插入数据失败：" & ex.Message)
                            End Try
                        End Using
                    End Using


                End If
            Next


            Dim sql_detail As String = "select * from hf_00_k3_realtime_stock" '----------------------------每张订单

            Dim cmd1 As New SqlCommand(sql_detail, conn)

            Dim da As New SqlDataAdapter
            Dim dt As New DataTable
            da.SelectCommand = cmd1

            da.Fill(dt)


            For x As Integer = 0 To dt.Rows.Count - 1 '--------------------每张订单写入明细

                order_id = dt.Rows(x).Item("id")
                order_no = dt.Rows(x).Item("bill_no")

                Dim paramLst11 As New List(Of LrGetToken.LrParam)

                Dim param11 As New LrGetToken.LrParam()
                param11.pKey = "id"
                param11.pValue = dt.Rows(x).Item(0)
                paramLst11.Add(param11)

                Dim percents As String = ""
                Dim card As String = ""

                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst11, "jdy/v2/scm/sal_order_detail")


                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取 remark 字段
                Dim remark As String = pageData("data")("remark").ToString()

                ' 获取 material_entity 数组
                Dim materialEntities As JArray = pageData("data")("material_entity")

                For Each material As JObject In materialEntities

                    ' 确保 "custom_entity_field" 存在于 material 中
                    If material("custom_entity_field") IsNot Nothing Then
                        ' 确保 "custom_entity_field" 是一个数组
                        If material("custom_entity_field").Type = JTokenType.Array Then
                            Dim customEntity As JArray = material("custom_entity_field")
                            ' 继续处理数组内容
                        ElseIf material("custom_entity_field").Type = JTokenType.Object Then
                            Dim customEntity As JObject = material("custom_entity_field")
                            ' 访问自定义字段  
                            If customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name") IsNot Nothing Then
                                Dim customFieldName As String = customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name").ToString()
                                percents = customFieldName '-------打尺
                            Else
                                Console.WriteLine("字段 '3t1q2jkjahvn2_name' 不存在。")
                            End If

                            If customEntity("custom_entity_field__1__4mrjiazczldljia6") IsNot Nothing Then
                                Dim card_no As String = customEntity("custom_entity_field__1__4mrjiazczldljia6").ToString() '----卡号
                                card = card_no

                            Else
                                Console.WriteLine("字段 'custom_entity_field__1__4mrjiazczldljia6' 不存在。")
                            End If

                        End If
                    Else
                        Console.WriteLine("material 对象中没有 'custom_entity_field' 字段。")
                    End If
                Next



                ' 遍历所有行
                For Each materialEntity As JObject In materialEntities
                    ' 提取每一行的数据
                    Dim materialName As String = materialEntity("material_name").ToString()
                    Dim materialNumber As String = materialEntity("material_number").ToString()
                    Dim stockName As String = materialEntity("stock_name").ToString()
                    Dim price As Double = Convert.ToDouble(materialEntity("price"))
                    Dim qty As Integer = Convert.ToInt32(materialEntity("qty"))
                    Dim comment As String = materialEntity("comment").ToString()
                    Dim deliveryDate As String = materialEntity("delivery_date").ToString()
                    Dim customEntityName As String = percents


                    Dim query As String = "
    INSERT INTO hf_00_orders_detail 
    (material_name, material_number, stock_name, price, qty, comment, delivery_date, custom_entity_name, remark,card,order_id,order_no)
    VALUES (@material_name, @material_number, @stock_name, @price, @qty, @comment, @delivery_date, @custom_entity_name, @remark,@card,@order_id,@order_no)"

                    Try
                        ' 创建数据库连接
                        Using connection As New SqlConnection(connstring)
                            connection.Open()

                            ' 创建 SQL 命令
                            Using cmd As New SqlCommand(query, connection)
                                ' 添加参数并传递变量值
                                cmd.Parameters.AddWithValue("@material_name", materialName)
                                cmd.Parameters.AddWithValue("@material_number", materialNumber)
                                cmd.Parameters.AddWithValue("@stock_name", stockName)
                                cmd.Parameters.AddWithValue("@price", price)
                                cmd.Parameters.AddWithValue("@qty", qty)
                                cmd.Parameters.AddWithValue("@comment", comment)
                                cmd.Parameters.AddWithValue("@delivery_date", deliveryDate)
                                cmd.Parameters.AddWithValue("@custom_entity_name", customEntityName)
                                cmd.Parameters.AddWithValue("@remark", remark)
                                cmd.Parameters.AddWithValue("@card", card)
                                cmd.Parameters.AddWithValue("@order_id", order_id)
                                cmd.Parameters.AddWithValue("@order_no", order_no)

                                ' 执行插入操作
                                cmd.ExecuteNonQuery()
                            End Using
                        End Using

                        '  MessageBox.Show("数据已成功插入！", "成功", MessageBoxButtons.OK, MessageBoxIcon.Information)
                    Catch ex As Exception
                        MessageBox.Show("插入数据时出错：" & ex.Message, "错误", MessageBoxButtons.OK, MessageBoxIcon.Error)
                    End Try


                Next




            Next







            MsgBox("")


            conn.Close()


        Catch ex As Exception
            MessageBox.Show("解析 JSON 失败：" & ex.Message)
        End Try





        MsgBox("")


    End Sub

    Private Sub inv_io(stringJson As String)

        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(stringJson)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As Integer = jsonData("data")("total_page")

            dt_global = New DataTable()

            ' 尝试获取 "rows"（方法1）
            Dim rows1 As JArray = Nothing
            If jsonData("data") IsNot Nothing AndAlso jsonData("data")("rows") IsNot Nothing Then
                rows1 = jsonData("data")("rows")
            End If

            ' 尝试获取 "data"（方法2）
            Dim rows2 As JObject = Nothing
            If jsonData("data") IsNot Nothing Then
                rows2 = jsonData("data")
            End If

            ' 处理方法1: 解析 "rows" (JArray)
            If rows1 IsNot Nothing AndAlso rows1.Count > 0 Then
                ' 取第一条数据的字段作为列名
                For Each prop As JProperty In rows1(0)
                    dt_global.Columns.Add(prop.Name)
                Next

                ' 添加数据
                For Each item As JObject In rows1
                    Dim row As DataRow = dt_global.NewRow()
                    For Each prop As JProperty In item.Properties()
                        row(prop.Name) = prop.Value.ToString()
                    Next
                    dt_global.Rows.Add(row)
                Next
            ElseIf rows2 IsNot Nothing Then

            Else
                MessageBox.Show("JSON 数据为空，无法转换为 DataTable")
            End If

            ' 绑定 DataGridView
            DataGridView1.DataSource = dt_global



            ' 获取数据库连接
            Dim conn As New SqlConnection(connstring)
            conn.Open()
            Dim sql As String = ""



            Dim clsX As New LrGetToken.LrGetMtrlDatum
            ' 遍历每一页的 rows
            For page As Integer = 1 To totalPage

                Dim paramLst As New List(Of LrGetToken.LrParam)

                Dim param As New LrGetToken.LrParam()
                'param.pKey = "bill_close_state"
                'param.pValue = "C"
                'paramLst.Add(param)



                param = New LrGetToken.LrParam()
                param.pKey = "page" : param.pValue = page
                paramLst.Add(param)

                param = New LrGetToken.LrParam()
                param.pKey = "page_size" : param.pValue = 1000
                paramLst.Add(param)




                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/inv/inv_inventory_ims")
                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取当前页的 rows 数据
                Dim pageRows As JArray = pageData("data")("rows")

                If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                    ' 插入每页数据到数据库

                    Dim dt_order As New DataTable

                    dt_order.Columns.Add("material_id", GetType(String))
                    dt_order.Columns.Add("material_number", GetType(String))
                    dt_order.Columns.Add("material_name", GetType(String))
                    dt_order.Columns.Add("stock_number", GetType(String))
                    dt_order.Columns.Add("stockid_name", GetType(String))
                    dt_order.Columns.Add("aux_unit_id", GetType(String))
                    dt_order.Columns.Add("qty", GetType(String))
                    dt_order.Columns.Add("batch_no", GetType(String))

                    For Each item As JObject In pageRows

                        dt_order.Rows.Add(item("material_id").ToString(), item("material_number").ToString(), item("material_name").ToString(), item("stock_number").ToString(), item("stockid_name").ToString(), item("aux_unit_id").ToString(), item("qty").ToString(), item("batch_no").ToString())

                    Next


                    ' 插入到数据库

                    Using connection As New SqlConnection(connstring)
                        connection.Open()

                        Using bulkCopy As New SqlBulkCopy(connection)
                            bulkCopy.DestinationTableName = "hf_00_k3_realtime_stock"

                            ' 4. 映射字段
                            bulkCopy.ColumnMappings.Add("material_id", "material_id")
                            bulkCopy.ColumnMappings.Add("material_number", "material_number")
                            bulkCopy.ColumnMappings.Add("material_name", "material_category_name")
                            bulkCopy.ColumnMappings.Add("stock_number", "stock_number")

                            bulkCopy.ColumnMappings.Add("stockid_name", "stockid_name")
                            bulkCopy.ColumnMappings.Add("aux_unit_id", "aux_unit_id")
                            bulkCopy.ColumnMappings.Add("qty", "qty")
                            bulkCopy.ColumnMappings.Add("batch_no", "batch_no")


                            Try
                                ' 5. 执行批量插入
                                bulkCopy.WriteToServer(dt_order)
                                MsgBox("数据批量插入成功！")
                            Catch ex As Exception
                                MsgBox("插入数据失败：" & ex.Message)
                            End Try
                        End Using
                    End Using


                End If
            Next


            Dim sql_detail As String = "select * from hf_00_k3_realtime_stock" '----------------------------每张订单

            Dim cmd1 As New SqlCommand(sql_detail, conn)

            Dim da As New SqlDataAdapter
            Dim dt As New DataTable
            da.SelectCommand = cmd1

            da.Fill(dt)


            For x As Integer = 0 To dt.Rows.Count - 1 '--------------------每张订单写入明细

                order_id = dt.Rows(x).Item("id")
                order_no = dt.Rows(x).Item("bill_no")

                Dim paramLst11 As New List(Of LrGetToken.LrParam)

                Dim param11 As New LrGetToken.LrParam()
                param11.pKey = "id"
                param11.pValue = dt.Rows(x).Item(0)
                paramLst11.Add(param11)

                Dim percents As String = ""
                Dim card As String = “”

                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst11, "jdy/v2/scm/sal_order_detail")


                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取 remark 字段
                Dim remark As String = pageData("data")("remark").ToString()

                ' 获取 material_entity 数组
                Dim materialEntities As JArray = pageData("data")("material_entity")

                For Each material As JObject In materialEntities

                    ' 确保 "custom_entity_field" 存在于 material 中
                    If material("custom_entity_field") IsNot Nothing Then
                        ' 确保 "custom_entity_field" 是一个数组
                        If material("custom_entity_field").Type = JTokenType.Array Then
                            Dim customEntity As JArray = material("custom_entity_field")
                            ' 继续处理数组内容
                        ElseIf material("custom_entity_field").Type = JTokenType.Object Then
                            Dim customEntity As JObject = material("custom_entity_field")
                            ' 访问自定义字段  
                            If customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name") IsNot Nothing Then
                                Dim customFieldName As String = customEntity("custom_entity_field__4__3t1q2jkjiahvn2_name").ToString()
                                percents = customFieldName '-------打尺
                            Else
                                Console.WriteLine("字段 '3t1q2jkjahvn2_name' 不存在。")
                            End If

                            If customEntity("custom_entity_field__1__4mrjiazczldljia6") IsNot Nothing Then
                                Dim card_no As String = customEntity("custom_entity_field__1__4mrjiazczldljia6").ToString() '----卡号
                                card = card_no

                            Else
                                Console.WriteLine("字段 'custom_entity_field__1__4mrjiazczldljia6' 不存在。")
                            End If

                        End If
                    Else
                        Console.WriteLine("material 对象中没有 'custom_entity_field' 字段。")
                    End If
                Next



                ' 遍历所有行
                For Each materialEntity As JObject In materialEntities
                    ' 提取每一行的数据
                    Dim materialName As String = materialEntity("material_name").ToString()
                    Dim materialNumber As String = materialEntity("material_number").ToString()
                    Dim stockName As String = materialEntity("stock_name").ToString()
                    Dim price As Double = Convert.ToDouble(materialEntity("price"))
                    Dim qty As Integer = Convert.ToInt32(materialEntity("qty"))
                    Dim comment As String = materialEntity("comment").ToString()
                    Dim deliveryDate As String = materialEntity("delivery_date").ToString()
                    Dim customEntityName As String = percents


                    Dim query As String = "
    INSERT INTO hf_00_orders_detail 
    (material_name, material_number, stock_name, price, qty, comment, delivery_date, custom_entity_name, remark,card,order_id,order_no)
    VALUES (@material_name, @material_number, @stock_name, @price, @qty, @comment, @delivery_date, @custom_entity_name, @remark,@card,@order_id,@order_no)"

                    Try
                        ' 创建数据库连接
                        Using connection As New SqlConnection(connstring)
                            connection.Open()

                            ' 创建 SQL 命令
                            Using cmd As New SqlCommand(query, connection)
                                ' 添加参数并传递变量值
                                cmd.Parameters.AddWithValue("@material_name", materialName)
                                cmd.Parameters.AddWithValue("@material_number", materialNumber)
                                cmd.Parameters.AddWithValue("@stock_name", stockName)
                                cmd.Parameters.AddWithValue("@price", price)
                                cmd.Parameters.AddWithValue("@qty", qty)
                                cmd.Parameters.AddWithValue("@comment", comment)
                                cmd.Parameters.AddWithValue("@delivery_date", deliveryDate)
                                cmd.Parameters.AddWithValue("@custom_entity_name", customEntityName)
                                cmd.Parameters.AddWithValue("@remark", remark)
                                cmd.Parameters.AddWithValue("@card", card)
                                cmd.Parameters.AddWithValue("@order_id", order_id)
                                cmd.Parameters.AddWithValue("@order_no", order_no)

                                ' 执行插入操作
                                cmd.ExecuteNonQuery()
                            End Using
                        End Using

                        '  MessageBox.Show("数据已成功插入！", "成功", MessageBoxButtons.OK, MessageBoxIcon.Information)
                    Catch ex As Exception
                        MessageBox.Show("插入数据时出错：" & ex.Message, "错误", MessageBoxButtons.OK, MessageBoxIcon.Error)
                    End Try


                Next




            Next










            conn.Close()


        Catch ex As Exception
            MessageBox.Show("解析 JSON 失败：" & ex.Message)
        End Try





        MsgBox("")


    End Sub

    Private Sub Button7_Click(sender As Object, e As EventArgs) Handles Button7.Click


        '-------仓库列表




        Dim sql As String = ""
        sql = "delete from hf_00_k3_wh"

        cmd.CommandText = sql
        cmd.Connection = conn

        cmd.ExecuteNonQuery()



        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        'param = New LrGetToken.LrParam()
        'param.pKey = "bill_close_state" : param.pValue = "C"
        'paramLst.Add(param)






        param = New LrGetToken.LrParam()
        param.pKey = "page" : param.pValue = 1  '------page
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "page_size" : param.pValue = 100  '------page_size
        paramLst.Add(param)


        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/bd/store")

        update_warehouse(strJson)

    End Sub
    Private Sub update_warehouse(stringJson As String)

        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(stringJson)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As Integer = jsonData("data")("total_page")

            dt_global = New DataTable()

            ' 尝试获取 "rows"（方法1）
            Dim rows1 As JArray = Nothing
            If jsonData("data") IsNot Nothing AndAlso jsonData("data")("rows") IsNot Nothing Then
                rows1 = jsonData("data")("rows")
            End If

            ' 尝试获取 "data"（方法2）
            Dim rows2 As JObject = Nothing
            If jsonData("data") IsNot Nothing Then
                rows2 = jsonData("data")
            End If

            ' 处理方法1: 解析 "rows" (JArray)
            If rows1 IsNot Nothing AndAlso rows1.Count > 0 Then
                ' 取第一条数据的字段作为列名
                For Each prop As JProperty In rows1(0)
                    dt_global.Columns.Add(prop.Name)
                Next

                ' 添加数据
                For Each item As JObject In rows1
                    Dim row As DataRow = dt_global.NewRow()
                    For Each prop As JProperty In item.Properties()
                        row(prop.Name) = prop.Value.ToString()
                    Next
                    dt_global.Rows.Add(row)
                Next
            ElseIf rows2 IsNot Nothing Then

            Else
                MessageBox.Show("JSON 数据为空，无法转换为 DataTable")
            End If

            ' 绑定 DataGridView
            DataGridView1.DataSource = dt_global



            ' 获取数据库连接
            Dim conn As New SqlConnection(connstring)
            conn.Open()
            Dim sql As String = ""



            Dim clsX As New LrGetToken.LrGetMtrlDatum
            ' 遍历每一页的 rows
            For page As Integer = 1 To totalPage

                Dim paramLst As New List(Of LrGetToken.LrParam)

                Dim param As New LrGetToken.LrParam()
                'param.pKey = "bill_close_state"
                'param.pValue = "C"
                'paramLst.Add(param)



                param = New LrGetToken.LrParam()
                param.pKey = "page" : param.pValue = page
                paramLst.Add(param)

                param = New LrGetToken.LrParam()
                param.pKey = "page_size" : param.pValue = 1000
                paramLst.Add(param)




                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/bd/store")
                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取当前页的 rows 数据
                Dim pageRows As JArray = pageData("data")("rows")

                If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                    ' 插入每页数据到数据库

                    Dim dt_order As New DataTable



                    dt_order.Columns.Add("id", GetType(String))
                    dt_order.Columns.Add("number", GetType(String))
                    dt_order.Columns.Add("name", GetType(String))
                    dt_order.Columns.Add("group_name", GetType(String))
                    dt_order.Columns.Add("group_id", GetType(String))
                    dt_order.Columns.Add("group_number", GetType(String))
                    dt_order.Columns.Add("is_allow_freight", GetType(String))
                    dt_order.Columns.Add("is_allow_neg", GetType(String))
                    dt_order.Columns.Add("enable", GetType(String))

                    For Each item As JObject In pageRows

                        dt_order.Rows.Add(item("id").ToString(), item("number").ToString(), item("name").ToString(), item("group_name").ToString(), item("group_id").ToString(), item("group_number").ToString(), item("is_allow_freight").ToString(), item("is_allow_neg").ToString(), item("enable").ToString())




                    Next

                    ' 插入到数据库
                    Using connection As New SqlConnection(connstring)
                        connection.Open()

                        Using bulkCopy As New SqlBulkCopy(connection)




                            bulkCopy.DestinationTableName = "hf_00_k3_wh"
                            ' 4. 映射字段
                            bulkCopy.ColumnMappings.Add("id", "id")
                            bulkCopy.ColumnMappings.Add("number", "number")
                            bulkCopy.ColumnMappings.Add("name", "name")
                            bulkCopy.ColumnMappings.Add("group_name", "group_name")
                            bulkCopy.ColumnMappings.Add("group_id", "group_id")
                            bulkCopy.ColumnMappings.Add("group_number", "group_number")
                            bulkCopy.ColumnMappings.Add("is_allow_freight", "is_allow_freight")
                            bulkCopy.ColumnMappings.Add("is_allow_neg", "is_allow_neg")
                            bulkCopy.ColumnMappings.Add("enable", "enable")




                            Try
                                ' 5. 执行批量插入
                                bulkCopy.WriteToServer(dt_order)
                                MsgBox("数据批量插入成功！")
                            Catch ex As Exception
                                MsgBox("插入数据失败：" & ex.Message)
                            End Try
                        End Using
                    End Using


                End If
            Next


            conn.Close()


        Catch ex As Exception
            MessageBox.Show("解析 JSON 失败：" & ex.Message)
        End Try



        MsgBox("更新仓库完成")


    End Sub

    Private Sub update_material(stringJson As String)

        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(stringJson)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As Integer = jsonData("data")("total_page")

            dt_global = New DataTable()

            ' 尝试获取 "rows"（方法1）
            Dim rows1 As JArray = Nothing
            If jsonData("data") IsNot Nothing AndAlso jsonData("data")("rows") IsNot Nothing Then
                rows1 = jsonData("data")("rows")
            End If

            ' 尝试获取 "data"（方法2）
            Dim rows2 As JObject = Nothing
            If jsonData("data") IsNot Nothing Then
                rows2 = jsonData("data")
            End If

            ' 处理方法1: 解析 "rows" (JArray)
            If rows1 IsNot Nothing AndAlso rows1.Count > 0 Then
                ' 取第一条数据的字段作为列名
                For Each prop As JProperty In rows1(0)
                    dt_global.Columns.Add(prop.Name)
                Next

                ' 添加数据
                For Each item As JObject In rows1
                    Dim row As DataRow = dt_global.NewRow()
                    For Each prop As JProperty In item.Properties()
                        row(prop.Name) = prop.Value.ToString()
                    Next
                    dt_global.Rows.Add(row)
                Next
            ElseIf rows2 IsNot Nothing Then

            Else
                MessageBox.Show("JSON 数据为空，无法转换为 DataTable")
            End If

            ' 绑定 DataGridView
            DataGridView1.DataSource = dt_global



            ' 获取数据库连接
            Dim conn As New SqlConnection(connstring)
            conn.Open()
            Dim sql As String = ""



            Dim clsX As New LrGetToken.LrGetMtrlDatum
            ' 遍历每一页的 rows
            For page As Integer = 1 To totalPage

                Dim paramLst As New List(Of LrGetToken.LrParam)

                Dim param As New LrGetToken.LrParam()
                'param.pKey = "bill_close_state"
                'param.pValue = "C"
                'paramLst.Add(param)



                param = New LrGetToken.LrParam()
                param.pKey = "page" : param.pValue = page
                paramLst.Add(param)

                param = New LrGetToken.LrParam()
                param.pKey = "page_size" : param.pValue = 1000
                paramLst.Add(param)




                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/bd/material")
                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取当前页的 rows 数据
                Dim pageRows As JArray = pageData("data")("rows")

                If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                    ' 插入每页数据到数据库

                    Dim dt_order As New DataTable





                    dt_order.Columns.Add("parent_name", GetType(String))
                    dt_order.Columns.Add("number", GetType(String))
                    dt_order.Columns.Add("parent_number", GetType(String))
                    dt_order.Columns.Add("parent_id", GetType(String))
                    dt_order.Columns.Add("name", GetType(String))
                    dt_order.Columns.Add("id", GetType(String))
                    dt_order.Columns.Add("help_code", GetType(String))
                    dt_order.Columns.Add("stock_name", GetType(String))
                    dt_order.Columns.Add("stock_number", GetType(String))







                    For Each item As JObject In pageRows


                        dt_order.Rows.Add(item("parent_name").ToString(), item("number").ToString(), item("parent_number").ToString(), item("parent_id").ToString(), item("name").ToString(), item("id").ToString(), item("help_code").ToString(), item("stock_name").ToString(), item("stock_number").ToString())



                    Next

                    ' 插入到数据库
                    Using connection As New SqlConnection(connstring)
                        connection.Open()

                        Using bulkCopy As New SqlBulkCopy(connection)




                            bulkCopy.DestinationTableName = "hf_00_k3_ProductInfo"
                            ' 4. 映射字段
                            bulkCopy.ColumnMappings.Add("parent_name", "parent_name")
                            bulkCopy.ColumnMappings.Add("number", "number")
                            bulkCopy.ColumnMappings.Add("parent_number", "parent_number")
                            bulkCopy.ColumnMappings.Add("parent_id", "parent_id")
                            bulkCopy.ColumnMappings.Add("name", "name")
                            bulkCopy.ColumnMappings.Add("id", "id")
                            bulkCopy.ColumnMappings.Add("help_code", "help_code")
                            bulkCopy.ColumnMappings.Add("stock_name", "stock_name")
                            bulkCopy.ColumnMappings.Add("stock_number", "stock_number")









                            Try
                                ' 5. 执行批量插入
                                bulkCopy.WriteToServer(dt_order)
                                '  MsgBox("数据批量插入成功！")
                            Catch ex As Exception
                                MsgBox("插入数据失败：" & ex.Message)
                            End Try
                        End Using
                    End Using


                End If
            Next


            conn.Close()


        Catch ex As Exception
            MessageBox.Show("解析 JSON 失败：" & ex.Message)
        End Try



        MsgBox("更新物料完成")


    End Sub

    Private Sub Button8_Click(sender As Object, e As EventArgs) Handles Button8.Click '-商品列表



        '-------商品列表---ok




        Dim sql As String = ""
        sql = "delete from hf_00_k3_ProductInfo"

        cmd.CommandText = sql
        cmd.Connection = conn

        cmd.ExecuteNonQuery()



        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        'param = New LrGetToken.LrParam()
        'param.pKey = "bill_close_state" : param.pValue = "C"
        'paramLst.Add(param)





        param = New LrGetToken.LrParam()
        param.pKey = "page" : param.pValue = 1  '------page
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "page_size" : param.pValue = 100  '------page_size
        paramLst.Add(param)



        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/bd/material")

        update_material(strJson)


    End Sub

    Private Sub Button9_Click(sender As Object, e As EventArgs) Handles Button9.Click
        '----生产领料




        'Dim sql As String = ""
        'sql = "delete from hf_00_k3_realtime_stock"

        'cmd.CommandText = sql
        'cmd.Connection = conn

        'cmd.ExecuteNonQuery()



        'sql = "delete from hf_00_orders_detail"
        'cmd.CommandText = sql
        'cmd.Connection = conn

        'cmd.ExecuteNonQuery()

        Dim clsX As New LrGetToken.LrGetMtrlDatum
        'Dim paramLst As New List(Of LrGetToken.LrParam)
        'Dim param As New LrGetToken.LrParam()
        'param = New LrGetToken.LrParam()
        'param.pKey = "bill_close_state" : param.pValue = "C"
        'paramLst.Add(param)
        'param = New LrGetToken.LrParam()
        'param.pKey = "bill_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
        'paramLst.Add(param)


        sql = "select outdate,card from ht_retan_chem_out where card like '%19115%' and  outdate BETWEEN '" & dtp_start.Value & "' and '" & dtp_end.Value & "' group by outdate,card "
        cmd.CommandText = sql
        dt = New DataTable
        da.SelectCommand = cmd
        da.Fill(dt)


        For x As Integer = 0 To dt.Rows.Count - 1


            ' 定义一个空的 requestData 字典
            Dim requestData As New Dictionary(Of String, Object)
            requestData.Add("bill_date", "2025-05-31")
            requestData.Add("dept_id", "1859378504722898945")

            ' 创建一个空的 material_entity 列表
            Dim materialList As New List(Of Object)




            sql = "SELECT   TOP (200) HT_Retan_Chem_Out.outDate, HT_Retan_Chem_Out.Card, HT_Retan_Chem_Out.Weight,           HT_Retan_Chem_Out.chem_name, HT_Retan_Chem_Out.chem_code, HT_Retan_Chem_Out.chem_percent, HT_Retan_Chem_Out.Rcp_name, HT_Retan_Chem_Out.chem_weight, HT_Retan_Chem_Out.item, HT_Retan_Chem_Out.time, HT_Retan_Chem_Out.comment, hf_00_k3_ProductInfo.id FROM      HT_Retan_Chem_Out LEFT OUTER JOIN hf_00_k3_ProductInfo ON HT_Retan_Chem_Out.chem_code = hf_00_k3_ProductInfo.number where  (hf_00_k3_ProductInfo.id IS NOT NULL) and outdate='" & dt.Rows(x).Item("outdate") & "' and card='" & dt.Rows(x).Item("card") & "'"


            cmd.CommandText = sql
            da.SelectCommand = cmd
            Dim dt_detail As New DataTable

            da.Fill(dt_detail)



            For y As Integer = 0 To dt_detail.Rows.Count - 1

                ' 用循环生成并添加多笔资料

                Dim material = New With {
                .material_id = dt_detail.Rows(y).Item("id").ToString(), '  material_id
                .qty = dt_detail.Rows(y).Item("chem_weight"),
                .stock_id = "1854401706419382272",
                .comment = dt_detail.Rows(y).Item("card"),
                .unit_id = "7"
            }
                materialList.Add(material) ' 将每笔资料添加到列表
            Next

            ' 将 material_entity 列表添加到 requestData
            requestData.Add("material_entity", materialList)

            ' 将数据转换为 JSON 字符串
            Dim jsonContent As String = JsonConvert.SerializeObject(requestData)

            Dim strJson As String = clsX.GetDatumX1(gClientID, gClientSecret, gAppToken, "jdy/v2/scm/inv_pick", jsonContent)

            import_scll(strJson) '未完

        Next


        MsgBox("导入完成")



    End Sub

    Private Sub import_scll(stringjson As String)


        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(stringjson)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As String = jsonData("data")("id_number_map")
        Catch
        End Try



    End Sub


    ' 在 Form 中定义一个方法来更新控件
    Public Sub UpdateResponseText(response As String)
        ' 确保更新控件在 UI 线程中执行
        If TextBox5.InvokeRequired Then
            TextBox5.Invoke(New Action(Of String)(AddressOf UpdateResponseText), response)
        Else
            TextBox5.Text = response
        End If
    End Sub


    Private Sub Button10_Click(sender As Object, e As EventArgs) Handles Button10.Click

        '----调拨入库
        'Dim sql As String = ""
        'sql = "delete from hf_00_orders_main"

        'cmd.CommandText = sql
        'cmd.Connection = conn

        'cmd.ExecuteNonQuery()



        'sql = "delete from hf_00_orders_detail"
        'cmd.CommandText = sql
        'cmd.Connection = conn

        'cmd.ExecuteNonQuery()

        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()

        param = New LrGetToken.LrParam()
        param.pKey = "end_bill_date" : param.pValue = dtp_end.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "page" : param.pValue = 1
        paramLst.Add(param)

        param = New LrGetToken.LrParam()
        param.pKey = "page_size" : param.pValue = 100
        paramLst.Add(param)
        param = New LrGetToken.LrParam()
        param.pKey = "start_bill_date" : param.pValue = dtp_start.Value.ToString("yyyy-MM-dd")
        paramLst.Add(param)

        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/scm/inv_tfin") '---调拨入库

        BindJsonToDataGridView(strJson)



    End Sub

    Private Sub Button11_Click(sender As Object, e As EventArgs) Handles Button11.Click




        '-------部门列表




        'Dim sql As String = ""
        'sql = "delete from hf_00_k3_wh"

        'cmd.CommandText = sql
        'cmd.Connection = conn

        'cmd.ExecuteNonQuery()



        Dim clsX As New LrGetToken.LrGetMtrlDatum
        Dim paramLst As New List(Of LrGetToken.LrParam)
        Dim param As New LrGetToken.LrParam()
        'param = New LrGetToken.LrParam()
        'param.pKey = "bill_close_state" : param.pValue = "C"
        'paramLst.Add(param)






        'param = New LrGetToken.LrParam()
        'param.pKey = "page" : param.pValue = 1  '------page
        'paramLst.Add(param)

        'param = New LrGetToken.LrParam()
        'param.pKey = "page_size" : param.pValue = 100  '------page_size
        'paramLst.Add(param)


        Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/bd/department")

        update_dep(strJson)

    End Sub

    Private Sub update_dep(stringJson As String)

        Dim order_id As String = ""
        Dim order_no As String = ""
        'Dim card As String = ""
        Dim cust_id As String = ""
        Dim cust_name As String = ""
        Dim bill_date As String = ""
        Dim cust_number As String = ""
        Dim bill_close_state As String = ""
        Dim io_status As String = ""
        Dim real_io_status As String = ""



        Try
            ' 解析 JSON 数据
            Dim jsonData As JObject = JObject.Parse(stringJson)
            'Dim dt As New DataTable()
            ' 获取 total_page
            Dim totalPage As Integer = jsonData("data")("total_page")

            dt_global = New DataTable()

            ' 尝试获取 "rows"（方法1）
            Dim rows1 As JArray = Nothing
            If jsonData("data") IsNot Nothing AndAlso jsonData("data")("rows") IsNot Nothing Then
                rows1 = jsonData("data")("rows")
            End If

            ' 尝试获取 "data"（方法2）
            Dim rows2 As JObject = Nothing
            If jsonData("data") IsNot Nothing Then
                rows2 = jsonData("data")
            End If

            ' 处理方法1: 解析 "rows" (JArray)
            If rows1 IsNot Nothing AndAlso rows1.Count > 0 Then
                ' 取第一条数据的字段作为列名
                For Each prop As JProperty In rows1(0)
                    dt_global.Columns.Add(prop.Name)
                Next

                ' 添加数据
                For Each item As JObject In rows1
                    Dim row As DataRow = dt_global.NewRow()
                    For Each prop As JProperty In item.Properties()
                        row(prop.Name) = prop.Value.ToString()
                    Next
                    dt_global.Rows.Add(row)
                Next
            ElseIf rows2 IsNot Nothing Then

            Else
                MessageBox.Show("JSON 数据为空，无法转换为 DataTable")
            End If

            ' 绑定 DataGridView
            DataGridView1.DataSource = dt_global



            ' 获取数据库连接
            Dim conn As New SqlConnection(connstring)
            conn.Open()
            Dim sql As String = ""



            Dim clsX As New LrGetToken.LrGetMtrlDatum
            ' 遍历每一页的 rows
            For page As Integer = 1 To totalPage

                Dim paramLst As New List(Of LrGetToken.LrParam)

                Dim param As New LrGetToken.LrParam()
                'param.pKey = "bill_close_state"
                'param.pValue = "C"
                'paramLst.Add(param)



                param = New LrGetToken.LrParam()
                param.pKey = "page" : param.pValue = page
                paramLst.Add(param)

                param = New LrGetToken.LrParam()
                param.pKey = "page_size" : param.pValue = 1000
                paramLst.Add(param)




                ' 调用 API 获取每页数据详请
                Dim strJson As String = clsX.GetDatumX(gClientID, gClientSecret, gAppToken, paramLst, "jdy/v2/bd/department")
                Dim pageData As JObject = JObject.Parse(strJson)

                ' 获取当前页的 rows 数据
                Dim pageRows As JArray = pageData("data")("rows")

                If pageRows IsNot Nothing AndAlso pageRows.Count > 0 Then
                    ' 插入每页数据到数据库

                    Dim dt_order As New DataTable



                    dt_order.Columns.Add("id", GetType(String))
                    dt_order.Columns.Add("fullname", GetType(String))
                    dt_order.Columns.Add("number", GetType(String))
                    dt_order.Columns.Add("parent_id", GetType(String))
                    dt_order.Columns.Add("parent_name", GetType(String))
                    dt_order.Columns.Add("parent_number", GetType(String))


                    For Each item As JObject In pageRows

                        dt_order.Rows.Add(item("id").ToString(), item("fullname").ToString(), item("number").ToString(), item("parent_id").ToString(), item("parent_name").ToString(), item("parent_number").ToString())




                    Next

                    ' 插入到数据库
                    Using connection As New SqlConnection(connstring)
                        connection.Open()

                        Using bulkCopy As New SqlBulkCopy(connection)




                            bulkCopy.DestinationTableName = "hf_00_k3_dep"
                            ' 4. 映射字段
                            bulkCopy.ColumnMappings.Add("id", "id")
                            bulkCopy.ColumnMappings.Add("fullname", "fullname")
                            bulkCopy.ColumnMappings.Add("number", "number")
                            bulkCopy.ColumnMappings.Add("parent_id", "parent_id")
                            bulkCopy.ColumnMappings.Add("parent_name", "parent_name")
                            bulkCopy.ColumnMappings.Add("parent_number", "parent_number")



                            Try
                                ' 5. 执行批量插入
                                bulkCopy.WriteToServer(dt_order)
                                MsgBox("数据批量插入成功！")
                            Catch ex As Exception
                                MsgBox("插入数据失败：" & ex.Message)
                            End Try
                        End Using
                    End Using


                End If
            Next


            conn.Close()


        Catch ex As Exception
            MessageBox.Show("解析 JSON 失败：" & ex.Message)
        End Try



        MsgBox("更新仓库完成")


    End Sub

End Class