关键代码

  1. Parallel.For(0,dtGatewayRst.Rows.Count, (i, loopState) =>
  3. lock (dtGatewayRst.Rows.SyncRoot)
  4. {
  5.     var dr = dtGatewayRst.Rows[i];
  6.     dr.BeginEdit();
  7.     dr["gatewayisOnline"] = nIsOnline;
  8.     dr["gatewaystatus"] = nStatus;
  9.     dr["gatewaysignalLevel"] = nSignalLevel;
  10.     dr["gatewaypowerVolt"] = nPowerVoltage;
  11.     dr["gatewaybatteryLevel"] = nBatteryLevel;
  12.     dr["gatewayAutoOrManual"] = nAutoOrManual;
  14.     dr.EndEdit();
  15. }

代码详情

  1. Parallel.For(0,dtGatewayRst.Rows.Count, (i, loopState) =>
  2. {
  3.     try
  4.     {
  5.         int gatewayid = int.Parse(dtGatewayRst.Rows[i]["gatewayID"].ToString());
  6.         string powerVoltage = RedisHelper.Get("gatway:id:" + gatewayid, "powerVoltage");
  7.         string signalLevel = RedisHelper.Get("gatway:id:" + gatewayid, "signalLevel");
  8.         string autoOrManual = RedisHelper.Get("gatway:id:" + gatewayid, "autoOrManual");
  9.         string isOnline = RedisHelper.Get("gatway:id:" + gatewayid, "isOnline");
  10.         string status = RedisHelper.Get("gatway:id:" + gatewayid, "status");
  11.         string batteryLevel = RedisHelper.Get("gatway:id:" + gatewayid, "batteryLevel");
  13.         int nSignalLevel = 0;
  14.         if (signalLevel != null && int.TryParse(signalLevel, out nSignalLevel))
  15.         {
  16.             if (nSignalLevel > 21)
  17.             {
  18.                 nSignalLevel = 4;
  19.             }
  20.             else if (nSignalLevel <= 21 && nSignalLevel > 18)
  21.             {
  22.                 nSignalLevel = 3;
  23.             }
  24.             else if (nSignalLevel <= 18 && nSignalLevel > 14)
  25.             {
  26.                 nSignalLevel = 2;
  27.             }
  28.             else if (nSignalLevel <= 14 && nSignalLevel > 9)
  29.             {
  30.                 nSignalLevel = 1;
  31.             }
  32.             else
  33.             {
  34.                 nSignalLevel = 0;
  35.             }
  36.         }
  38.         int nIsOnline = 0;
  39.         if (isOnline != null && int.TryParse(isOnline, out nIsOnline))
  40.         {
  41.         }
  43.         sbyte nStatus = 0;
  44.         if (status != null && sbyte.TryParse(status, out nStatus))
  45.         {
  46.         }
  48.         int nPowerVoltage = 0;
  49.         if (powerVoltage != null && int.TryParse(powerVoltage, out nPowerVoltage))
  50.         {
  51.         }
  53.         int nBatteryLevel = 0;
  54.         if (batteryLevel != null && int.TryParse(batteryLevel, out nBatteryLevel))
  55.         {
  56.         }
  58.         int nAutoOrManual = 0;
  59.         if (autoOrManual != null && int.TryParse(autoOrManual, out nAutoOrManual))
  60.         {
  61.         }
  62.         lock (dtGatewayRst.Rows.SyncRoot)
  63.         {
  64.             var dr = dtGatewayRst.Rows[i];
  65.             dr.BeginEdit();
  66.             dr["gatewayisOnline"] = nIsOnline;
  67.             dr["gatewaystatus"] = nStatus;
  68.             dr["gatewaysignalLevel"] = nSignalLevel;
  69.             dr["gatewaypowerVolt"] = nPowerVoltage;
  70.             dr["gatewaybatteryLevel"] = nBatteryLevel;
  71.             dr["gatewayAutoOrManual"] = nAutoOrManual;
  73.             dr.EndEdit();
  74.         }
  75.     }
  76.     catch (Exception ex)
  77.     {
  78.         aIoTFramework.SysLog.Error(this.GetType().ToString(), ex.Message);
  79.     }
  81. });