From 8f7a257aa945ceb588396c731565ef1826eb640c Mon Sep 17 00:00:00 2001 From: wsy182 <2392948297@qq.com> Date: Tue, 17 Mar 2026 16:06:09 +0800 Subject: [PATCH] =?UTF-8?q?config:=20=E6=9B=B4=E6=96=B0=E6=9C=8D=E5=8A=A1?= =?UTF-8?q?=E5=99=A8IP=E9=85=8D=E7=BD=AE=E5=B9=B6=E4=BC=98=E5=8C=96WITS?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=8F=91=E9=80=81=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 将server-ip从192.168.1.41更改为192.168.1.5 - 移除WitsData模型中的actod_label字段 - 修改wits_sender.py中的actcod值为随机生成(1-34范围内) - 更新WITS数据包构建逻辑以使用动态actcod值 - 优化代码格式和错误消息显示 - 移除不必要的空行和导入语句 --- app/wits_sender.py | 11 ++++++----- config.yaml | 2 +- model/wits.py | 1 - 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/app/wits_sender.py b/app/wits_sender.py index 491c2b9..87d10ad 100644 --- a/app/wits_sender.py +++ b/app/wits_sender.py @@ -8,7 +8,6 @@ from pathlib import Path from config import build_wits_sender_dependencies from model import REQUIRED_TRANSMISSION_CHANNELS, WITS_CHANNEL_MAPPING, WitsData - logger = logging.getLogger(__name__) BEGIN_MARK = "&&\r\n" END_MARK = "!!\r\n" @@ -44,6 +43,7 @@ def build_random_wits_data(device_code): weight_on_bit = rand_float(6.0, 12.0) bit_depth = rand_float(199.8, 200.3) block_position = rand_float(5.8, 6.3) + actcod = rand_int(1, 34) return WitsData( ts=ts_ms, wellid=device_code or "???1", @@ -53,8 +53,7 @@ def build_random_wits_data(device_code): actual_date=time.strftime("%y%m%d"), actual_time=time.strftime("%H%M%S"), actual_ts=ts_ms, - actcod=37, - actod_label="AUTO", + actcod=actcod, deptbitm=bit_depth, deptbitv=bit_depth - 1.45, deptmeas=bit_depth, @@ -149,7 +148,8 @@ def validate_packet(packet): def build_wits_packet(data): - lines = [f"{channel}{format_wits_value(getattr(data, field_name), kind)}" for channel, field_name, kind in WITS_CHANNEL_MAPPING] + lines = [f"{channel}{format_wits_value(getattr(data, field_name), kind)}" for channel, field_name, kind in + WITS_CHANNEL_MAPPING] packet = BEGIN_MARK + "\r\n".join(lines) + "\r\n" + END_MARK + RECORD_TERMINATOR validate_packet(packet) return packet @@ -193,7 +193,8 @@ def run_wits_sender(args, deps): interval = args.interval or 2.0 if not host or not port: - raise ValueError("WITS target host/port is empty. Configure wits.host/wits.port or tms.server-ip/tms.server-port") + raise ValueError( + "WITS target host/port is empty. Configure wits.host/wits.port or tms.server-ip/tms.server-port") logger.info( "WITS sender config host=%s port=%s timeout=%ss source_file=%s interval=%ss count=%s", diff --git a/config.yaml b/config.yaml index bd2b082..d46351b 100644 --- a/config.yaml +++ b/config.yaml @@ -15,7 +15,7 @@ tms: equipment-sn: GJ-304-0088 timeout: 10 keepalive: 20 - server-ip: 192.168.1.41 + server-ip: 192.168.1.5 server-port: 9929 tdengine: diff --git a/model/wits.py b/model/wits.py index 482e7b7..0e02214 100644 --- a/model/wits.py +++ b/model/wits.py @@ -47,7 +47,6 @@ class WitsData: actual_time: int actual_ts: int actcod: int - actod_label: str deptbitm: float deptbitv: float deptmeas: float