TimedUpload/QuartzJobs/DABusinessDataJob.cs

@@ -177,7 +177,6 @@ namespace TimedUpload.QuartzJobs
                     try
                     {
                         DataRow dr = dt.Rows[i];
-                        userMeterReadId = Convert.ToString(dr["UsedWater_ID"]);
 
                         string meterCode = Convert.ToString(dr["CM_ID"]);
                         string getDateTime = Convert.ToDateTime(dr["ThisMeterDt"]).ToString("yyyy-MM-dd HH:mm:ss");
@@ -199,6 +198,7 @@ namespace TimedUpload.QuartzJobs
                             IBasicProperties property = properties[key];
                             channel.BasicPublish("zone.userMeterHis", "", property, Encoding.UTF8.GetBytes(message.ToString())); //生产消息
                         }
+                        userMeterReadId = Convert.ToString(dr["UsedWater_ID"]);
                     }
                     catch (Exception ex)
                     {