合并

yangle

2025-04-02 cee055eb7cdecf5d995cc65d379494e471bde9c8

 WarM/ÌõÂë´òÓ¡/Gy_BarCodeBill_automaticallyByPLC_New_Change.cs

@@ -1356,16 +1356,49 @@
        }
        #endregion

        //#region MQTT接收到信息后的回调方法
        //public void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
        //{
        //    try
        //    {
        //        string message = Encoding.UTF8.GetString(e.Message);
        //        List<MQTT_MainEntity_New> mQTT_MainEntity = getObjectByJson_Xs_OutDoorBillMain_New(message);
        //        for (int i = 0; i < mQTT_MainEntity[0].data.Count; i++)
        //        {
        //            if (mQTT_MainEntity[0].data[i].id == textBox_WorkPositionParams.Text && mQTT_MainEntity[0].data[i].value == 1)
        //            {
        //                produceQty += 1;
        //            }
        //        }
        //    }
        //    catch (Exception ex)
        //    {
        //        MessageBox.Show(ex.Message);

        //        string msg = "";
        //        if (disConnect(ref msg) == true)
        //        {
        //            MessageBox.Show(msg);
        //        }
        //        else
        //        {
        //            MessageBox.Show(msg);
        //        }
        //    }
        //}
        //#endregion


        #region MQTT接收到信息后的回调方法
        public void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
        {
            try
            {
                string message = Encoding.UTF8.GetString(e.Message);
                List<MQTT_MainEntity> mQTT_MainEntity = getObjectByJson_Xs_OutDoorBillMain(message);
                for(int i = 0; i < mQTT_MainEntity[0].values.Count; i++)
                List<MQTT_MainEntity_New> mQTT_MainEntity = getObjectByJson_Xs_OutDoorBillMain_New(message);
                for(int i = 0; i < mQTT_MainEntity[0].data.Count; i++)
                {
                    if (mQTT_MainEntity[0].values[i].id == textBox_WorkPositionParams.Text && mQTT_MainEntity[0].values[i].v == true)
                    if (mQTT_MainEntity[0].data[i].id == textBox_WorkPositionParams.Text && mQTT_MainEntity[0].data[i].value == 1)
                    {
                        produceQty += 1;
                    }
@@ -2627,6 +2660,15 @@
            return list;
        }
        #endregion

        #region json转为对象
        public List<MQTT_MainEntity_New> getObjectByJson_Xs_OutDoorBillMain_New(string jsonString)
        {
            jsonString = "[" + jsonString.ToString() + "]";
            List<MQTT_MainEntity_New> list = Newtonsoft.Json.JsonConvert.DeserializeObject<List<MQTT_MainEntity_New>>(jsonString);
            return list;
        }
        #endregion
        #endregion
    }

@@ -2644,4 +2686,21 @@
        public long t;                              //时间戳
    }
    #endregion

    #region MQTT发送数据模型1
    public class MQTT_MainEntity_New
    {
        public string id;
        public string name;
        public List<MQTT_SubEntity_New> data;
    }
    public class MQTT_SubEntity_New
    {
        public string id;                                   //工位
        public string name;                                 //结果
        public string updatetime;
        public string address;
        public long value;                              //时间戳
    }
    #endregion
}