x11_template_vue2/templates/ultra/v2_program_stream_single.py

import json
import sys
from pathlib import Path

PROJECT_ROOT = Path(__file__).resolve().parents[2]
sys.path.insert(0, str(PROJECT_ROOT))

from pre_data.common.client_tools import redis_client, write_hset


INDEX_KEY = "program-names:index"
STREAM_KEY = "program-names:stream"
KEY_PREFIX = "program-names"


def make_redis_key(type_id: str, zone_id: str) -> str:
    return f"{KEY_PREFIX}:{type_id}:{zone_id}"


def write_program_names(type_id: str, zone_id: str, program_map: dict[str, str], clear_before_write: bool = True):
    redis_key = make_redis_key(type_id, zone_id)
    index_value = f"{type_id}:{zone_id}"
    normalized = {str(k): str(v) for k, v in program_map.items()}

    if clear_before_write:
        redis_client.delete(redis_key)

    write_hset(redis_key, normalized)
    redis_client.sadd(INDEX_KEY, index_value)
    redis_client.xadd(
        STREAM_KEY,
        {
            "action": "upsert",
            "type_id": type_id,
            "zone_id": zone_id,
        },
    )

    print(f"[OK] key={redis_key}, fields={len(normalized)}")
    print(f"[OK] index={INDEX_KEY} add {index_value}")
    print(f"[OK] stream={STREAM_KEY} xadd upsert")


if __name__ == "__main__":
    #ultra_下筒1
    ultra_type_id_1 = "201c51890c31c308050100218008054150000000000000000000000000000040"
    ultra_zone_id_1 = "1"

    ultra_program_names_1 =  { 56 : "智慧", 15 :  "POP速洗", 19 : "摇篮柔洗", 17 :  "大件", 31 :  "四件套", 1 : "棉麻", 20 :  "婴童服", 58 : "浴巾", 6 :  "衬衣", 3 :  "羽绒", 10 :  "羊毛", 18 :  "校服", 52 :  "户外服", 40:  "超净洗", 60 :  "蒸汽除菌", 27 :  "漂+脱", 28 :  "单脱水", 13 :  "筒自洁"  }

    write_program_names(ultra_type_id_1, ultra_zone_id_1, ultra_program_names_1, clear_before_write=True)

    # #ultra_下筒3
    # ultra_type_id_3 = "201c51890c31c308050100218008054150000000000000000000000000000040"
    # ultra_zone_id_3 = "3"

    # ultra_program_names_3 = { 56 : "智慧", 15 : "59分钟速洗烘", 17 : "大件", 31 : "四件套", 1 : "棉麻", 20 : "婴童服", 58 : "浴巾", 6 : "衬衣", 3 : "羽绒", 10 : "羊毛", 40 : "超净洗烘", 27 : "漂净烘", 29 : "单烘干", 91 : "筒净烘" }


    # write_program_names(ultra_type_id_3, ultra_zone_id_3, ultra_program_names_3, clear_before_write=True)

    # #ultra_左筒43
    # ultra_type_id_41 = "201c51890c31c308050100218008054150000001000000000000000000010040"
    # ultra_zone_id_41 = "41"

    # ultra_program_names_41 = { 56 : "智慧", 15 : "POP速洗", 102 : "无痕Bra", 104 : "蕾丝Bra", 101 : "运动Bra", 105 : "内裤", 26 : "毛巾", 20 : "婴童服", 8 : "轻柔",  40 : "超净洗", 60 : "蒸汽除菌", 27 : "漂+脱", 28 : "单脱水", 13 : "筒自洁" }


    # write_program_names(ultra_type_id_41, ultra_zone_id_41, ultra_program_names_41, clear_before_write=True)