修复问题

This commit is contained in:
ChenYi 2025-04-29 10:12:09 +08:00
parent cc8465ec77
commit d97e38439a

View File

@ -2,7 +2,6 @@
using JiShe.CollectBus.Common;
using JiShe.CollectBus.Common.Consts;
using JiShe.CollectBus.Common.DeviceBalanceControl;
using JiShe.CollectBus.Common.Encrypt;
using JiShe.CollectBus.Common.Enums;
using JiShe.CollectBus.Common.Extensions;
using JiShe.CollectBus.Common.Helpers;
@ -16,6 +15,7 @@ using JiShe.CollectBus.IotSystems.Watermeter;
using JiShe.CollectBus.Kafka.Internal;
using JiShe.CollectBus.Kafka.Producer;
using JiShe.CollectBus.Protocol.Interfaces;
using JiShe.CollectBus.Protocol.Models;
using Microsoft.AspNetCore.Authorization;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
@ -23,7 +23,6 @@ using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using JiShe.CollectBus.Protocol.Models;
namespace JiShe.CollectBus.ScheduledMeterReading
@ -284,7 +283,8 @@ namespace JiShe.CollectBus.ScheduledMeterReading
itemCode: itemCode,
subItemCode: subItemCode,
pendingCopyReadTime: currentTime,
creationTime: currentTime);
creationTime: currentTime,
packetType: TelemetryPacketTypeEnum.AmmeterAutoValveControl);
taskList.Add(meterReadingRecords);
}
if (taskList == null || taskList.Count <= 0)