Python TCP服务端多线程接收RFID网络读卡器上传数据

本示例使用设备介绍:WIFI/TCP/UDP/HTTP协议RFID液显网络读卡器可二次开发语音播报POE-淘宝网 (taobao.com) 

#python通过缩进来表示代码块,不可以随意更改每行前面的空白,否则程序会运行错误!!!如果缩进不一致,就会报错: IndentationError
#!/usr/bin/env python
# -*- coding: utf-8 -*-
#python -m pdb xxx.py 调试程度 n命令单步执行,s命令单步执行 会进入函数内部  b xx ,c
#import pdb    pdb.set_trace() 设断点

import sys
import socketserver
import os
import socket
import time
import pdb

class Server(socketserver.BaseRequestHandler):
    def handle(self):
        print("conn is :", self.request)  # conn
        print("client_address is :", self.client_address)  # addr

        while True:
            if self.request:
                # 接收收消息
                data = self.request.recv(1024).strip()
                if not data:
                    print("no data break")
                    break
                    print("no data continue")
                    continue

                GetData = 'Received from %s:%s' % (self.client_address) + " :"
                for num in range(0, len(data)):
                    GetData = GetData + '%02X ' % (data[num])
                print(GetData)

                #解析接收到的数据
                if (data[0] == eval('0xC1') or data[0] == eval('0xCF')):  # 接收IC读卡器上传的读卡号数据、IC卡离开读卡器的信息
                    FunCode = '%02X' % (data[0])
                    DEvIp = '%d.%d.%d.%d' % (data[1], data[2], data[3], data[4])  # 设备IP
                    DevNo = '%05d' % (data[5] + data[6] * 256)  # 机号
                    FrameNo = '%d' % (data[7] + data[8] * 256)  # 数据包序号
                    Cardlen=data[9];    #卡号长度
                    Card16H=""          #16进制卡号
                    for num in range(10, 10+Cardlen):
                        Card16H = Card16H + '%02X' % (data[num])
                    Cardno = data[10]   #转10进制卡号
                    Cardno = Cardno + (data[11] * 256)
                    Cardno = Cardno + (data[12] * 65536)
                    Cardno = Cardno + (data[13] * 16777216)
                    CardnoStr = '%010d' % Cardno

                    SerialNum = ''  # 设备硬件序列号
                    for num in range(10+Cardlen, len(data)):
                        SerialNum = SerialNum + '%02X' % (data[num])
                    if (data[0] == eval('0xC1')):
                        print('数据解析:IC读卡器刷卡数据,设备IP:' + DEvIp + ',机号:' + DevNo + ",数据包号:" + FrameNo +",卡号长度:"+"%d" %(Cardlen)+ ",16进制卡号:" + Card16H + " 转10进制卡号:" + CardnoStr + ",硬件序列号:" + SerialNum+"\n")
                    else:
                        print('数据解析:IC卡离开读卡器,设备IP:' + DEvIp + ',机号:' + DevNo + ",数据包号:" + FrameNo +",卡号长度:"+"%d" %(Cardlen)+ ",16进制卡号:" + Card16H + " 转10进制卡号:" + CardnoStr + ",硬件序列号:" + SerialNum + "\n")

                    RespByte=GetResponseData(2)     #根据不同情况生成要回应指令码
                    self.request.sendall(RespByte)  #发送回应指令码
                    SendData = 'Send Data to %s:%s' % (self.client_address) + " :"
                    for num in range(0, len(RespByte)):
                        SendData = SendData + '%02X ' % (RespByte[num])
                    print(SendData+"\n")

                elif (data[0] == eval('0xD1') or data[0] == eval('0xDF')):   # 接收ID读卡器上传的读卡号数据、ID卡离开读卡器数据
                    FunCode = '%02X' % (data[0])
                    DEvIp = '%d.%d.%d.%d' % (data[1], data[2], data[3], data[4])  # 设备IP
                    DevNo = '%05d' % (data[5] + data[6] * 256)  # 机号
                    FrameNo = '%d' % (data[7] + data[8] * 256)  # 数据包序号
                    Card16H = '%02X%02X%02X%02X%02X' % (data[9],data[10], data[11], data[12], data[13])  # 16进制卡号
                    Cardno = data[9]       #转10进制卡事情
                    Cardno = Cardno + (data[10] * 256)
                    Cardno = Cardno + (data[11] * 65536)
                    Cardno = Cardno + (data[12] * 16777216)
                    CardnoStr = '%010d' % Cardno
                    SerialNum = ''  # 设备硬件序列号
                    for num in range(14, len(data)):
                        SerialNum = SerialNum + '%02X' % (data[num])

                    if (data[0] == eval('0xD1')):
                        print('数据解析:ID读卡器刷卡数据,设备IP:' + DEvIp + ',机号:' + DevNo + ",数据包号:" + FrameNo + ",16进制卡号:" + Card16H + " 转10进制卡号:" + CardnoStr + ",硬件序列号:" + SerialNum + "\n")
                    else:
                        print('数据解析:ID卡离开读卡器,设备IP:' + DEvIp + ',机号:' + DevNo + ",数据包号:" + FrameNo + ",16进制卡号:" + Card16H + " 转10进制卡号:" + CardnoStr + ",硬件序列号:" + SerialNum + "\n")

                    RespByte = GetResponseData(2)  # 根据不同情况生成要回应指令码
                    self.request.sendall(RespByte)  # 发送回应指令码
                    SendData = 'Send Data to %s:%s' % (self.client_address) + " :"
                    for num in range(0, len(RespByte)):
                        SendData = SendData + '%02X ' % (RespByte[num])
                    print(SendData + "\n")

                elif (data[0] == eval('0xF3')):  # 接收到设备的心跳数据包,设备心跳间隔可根据协议自行设置
                    FunCode = '%02X' % (data[0])
                    DEvIp = '%d.%d.%d.%d' % (data[1], data[2], data[3], data[4])  # 设备IP
                    DevNo = '%05d' % (data[5] + data[6] * 256)  # 机号
                    FrameNo = '%d' % (data[7] + data[8] * 256)  # 数据包序号
                    heartbeattype='%02X' % (data[9])
                    outleng='%d' % (data[10])
                    switchon='%02X' % (data[11])
                    inputinf='%02X' % (data[12])
                    rand='%02X%02X%02X%02X' % (data[13], data[14], data[15], data[16])
                    SerialNum = ''
                    for num in range(17, len(data)):
                        SerialNum = SerialNum + '%02X' % (data[num])
                    print('接收数据解析:设备心跳包,设备IP:' + DEvIp + ',机号:' + DevNo + ",数据包号:" + FrameNo + ",心跳类型:" + heartbeattype + ",长度:" + outleng+ ",继电器状态:" + switchon + ",输入接口状态:" + inputinf + ",随机校验码:" + rand  + ",硬件序列号:" + SerialNum + "\n")

def GetResponseData(respcode):      # 生成不同的回应数据
    sdata=bytearray()
    if (respcode==0):               # 生成蜂鸣响声的回应数据
        sdata.append(eval('0x96'))  # 蜂鸣响声的指令码
        sdata.append(eval('0x00'))  # 机号低
        sdata.append(eval('0x00'))  # 机号高,0000表示任意机号
        sdata.append(eval('0x01'))  # 蜂鸣响声代码,取值范围0-12

    elif(respcode==1):              # 生成显示文字+蜂鸣响声的 回应数据
        DispStr = "本次刷卡成功,感谢您的使用,再见!            "
        DispByte = bytes(DispStr, encoding='gbk')    # 将要显示的文字转bytes
        DispByte = DispByte[0:34]                    # 两行屏可以显示34个字符
        CommByte=bytes([eval('0x5A'), 0, 0, 2, 30])  # 5A是指令码+2字节机号+1字节蜂鸣代码+1字节显示时长
        sdata = CommByte + DispByte                  # 加入显示文字的ASC码

    elif (respcode == 2):           # 生成显示文字+蜂鸣响声的+继电器开关+TTS中文语音的 回应数据
        DispStr = "本次刷卡成功,感谢您的使用,再见!            "
        DispByte = bytes(DispStr, encoding='gbk')   # 将要显示的文字转bytes
        DispByte = DispByte[0:34]                   # 两行屏可以显示34个字符

        SpkStr = '[v1]欢迎您使用我们的网络读卡器,谢谢!'     # 要播报的TTS语音,[v10]表示音量,取值0-16,可放置字符串的任意地方,一次最多126个字节
        Spkb = bytes(SpkStr, encoding='gbk')            # 将要播报的TTS语音转bytes,
        Spkl = len(Spkb)  # TTS语音长度

        sufb = bytes([eval('0x55'), eval('0xaa'), eval('0x66'), eval('0x99')])      # 固定的抗干扰后缀
        comb = bytes([eval('0x5C'), 0, 0, 1, eval('0xF0'), 20, 0, 20, 0, 34,Spkl])  # 5C是指令码+2字节机号+1字节蜂鸣代码+1字节继电器代码+2字节继电器延时+1字节显示时长+1字节显示起始位+1字节显示长度+1语音长度
        sdata = comb + DispByte + Spkb + sufb

    elif (respcode == 3):  # 生成开启继电器开关的 回应数据
        sdata.append(eval('0x78'))  # 蜂鸣响声的指令码
        sdata.append(eval('0x00'))  # 机号低
        sdata.append(eval('0x00'))  # 机号高,0000表示任意机号
        sdata.append(eval('0xF0'))  # 继电器代码 F0表示全部继电器、F1表示1号继电器 、F2表示2号继电器......
        sdata.append(eval('0x2c'))  # 继电器开启延时低位
        sdata.append(eval('0x01'))  # 继电器开启延时高位,FFFF表示继电器一直开启
    return sdata


if __name__ == "__main__":
    IpList = []
    if sys.platform == 'linux' or sys.platform == 'mac':  # linux、mac系统获取电脑所有网卡IP
        ips = [ip.split('/')[0] for ip in os.popen("ip addr | grep 'inet '|awk '{print $2}'").readlines()]
        for i in ips:
            IpList.append(i)
            print('%d   ' % (len(IpList)) + i)
    else:
        addrs = socket.getaddrinfo(socket.gethostname(), None)  # windows获取电脑所有网卡IP
        for item in addrs:
            if ':' not in item[4][0]:
                IpList.append(item[4][0])
                print('%d   ' % (len(IpList)) + item[4][0])

    Bindip = IpList[0]          # 如有多张网卡,可选择绑定不同的网卡
    address = ('', 39169)       # 未指定绑定网卡,可侦听本机所有网卡信息,读卡器出厂默认39169通讯端口

    with socketserver.ThreadingTCPServer(address, Server) as server:
        try:
            server.serve_forever()
        except Exception as e:
            print(e)
            pass
    pass

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/122511.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Git->git简介,git的常用命令,git命令的常用理论

git简介git的常用命令git命令的常用理论 1.git简介 Git是什么? Git是一个开源的分布式,用于敏捷高效地处理任何或小或大的项目 Git 是 Linus Torvalds 为了帮助管理 Linux 内核开发而开发的一个开放源码的版本控制软件。 Git 与常用的版本控制工具 CVSI…

2023-11 | 短视频批量下载/爬取某个用户的所有视频 | Python

这里以鞠婧祎的个人主页为demo https://www.douyin.com/user/MS4wLjABAAAACV5Em110SiusElwKlIpUd-MRSi8rBYyg0NfpPrqZmykHY8wLPQ8O4pv3wPL6A-oz 【2023-11-4 23:02:52 星期六】可能后面随着XX的调整, 方法不再适用, 请注意 找到接口 找到https://www.douyin.com/aweme/v1/web/…

蓝桥云课--1014 第 1 场算法双周赛

2-数树数【算法赛】&#xff08;找规律&#xff09; 一、题目要求 二、思路 由此可以推导出来&#xff0c;当s[i]L时&#xff0c;下一个编号当前编号*2-1&#xff1b;当s[i]R时&#xff0c;下一个编号当前编号*2&#xff1b; 三、代码 #include<bits/stdc.h> #define…

安卓三防手持终端 二维码扫描识别器 pda条码手持机

PDA条码手持机是一种快速的数据采集设备&#xff0c;具备多种数据采集功能并且可以进行二次开发&#xff0c;可以针对性的进行定制服务&#xff0c;满足各种业务需求。因其体积小&#xff0c;易操作、功能全、效率高深受物联网行业的青睐。 条码扫描是PDA重要的功能之一&#…

网络安全(黑客)小白自学

1.网络安全是什么 网络安全可以基于攻击和防御视角来分类&#xff0c;我们经常听到的 “红队”、“渗透测试” 等就是研究攻击技术&#xff0c;而“蓝队”、“安全运营”、“安全运维”则研究防御技术。 2.网络安全市场 一、是市场需求量高&#xff1b; 二、则是发展相对成熟…

C++|前言

c|前言 一、什么是C二、C发展史三、C的重要性3.1语言的使用广泛度3.2工作领域3.3校招领域 四、如何学习C4.1别人怎么学4.2自己怎么学 一、什么是C 在上回书已经学习了C语言&#xff0c;我们知道C语言是面向过程语言&#xff0c;C语言是结构化和模块化的语言&#xff0c;适合处理…

你觉得哪个软件写verilog体验最好?

最近在媒体上看到一个热点问题&#xff0c;浏览量高达680,003。“你觉得哪个软件写verilog体验最好&#xff1f;”这个问题可以说是IC设计师们最想知道的问题&#xff0c;也是大家工作交流中比较常见的。今天移知教育小编就来为大家分享一下&#xff0c;我对于这个问题的解答。…

登陆认证权限控制(2)—— 基于Spring security 安全框架的权限管理 注解式权限控制 RABC模型

前言 登陆认证&#xff0c;权限控制是一个系统必不可少的部分&#xff0c;一个开放访问的系统能否在上线后稳定持续运行其实很大程度上取决于登陆认证和权限控制措施是否到位&#xff0c;不然可能系统刚刚上线就会夭折。 Spring Security 是一个能够为基于 Spring 的企业应用…

学习Opencv(蝴蝶书/C++)相关——2.用clang++或g++命令行编译程序

文章目录 1. c/cpp程序的执行1.1 cpp程序的编译过程1.2 预处理指令1.3 编译过程的细节2. macOS下使用Clang看cpp程序的编译过程2.1 示例2.1.1 第一步 预处理器-preprocessor2.1.2 第二步 编译器-compiler2.1.3 第三步 汇编器-assembler2.1.4 第四步 链接器-linker2.1.5 链接其他…

【机器学习基础】机器学习概述

目录 前言 一、机器学习概念 二、机器学习分类 三、机器学习术语 &#x1f308;嗨&#xff01;我是Filotimo__&#x1f308;。很高兴与大家相识&#xff0c;希望我的博客能对你有所帮助。 &#x1f4a1;本文由Filotimo__✍️原创&#xff0c;首发于CSDN&#x1f4da;。 &#x…

【论文阅读】PSDF Fusion:用于动态 3D 数据融合和场景重建的概率符号距离函数

【论文阅读】PSDF Fusion&#xff1a;用于动态 3D 数据融合和场景重建的概率符号距离函数 Abstract1 Introduction3 Overview3.1 Hybrid Data Structure3.2 3D Representations3.3 Pipeline 4 PSDF Fusion and Surface Reconstruction4.1 PSDF Fusion4.2 Inlier Ratio Evaluati…

MCU平台使用SPI-DirectC实现FPGA在线升级

本文介绍在MCU平台上使用SPI-DirectC实现FPGA的在线升级功能。 对于使用Microchip FPGA若想使用离线方式对FPGA进行Bitstream的烧写,就不得不使用官方提供的DirectC组件(开源,包含JTAG-DirectC和SPI-DirectC),本文是在MCU(32bit)上实现的,采用的是SPI-DirectC组件。 …

分布式数据库·Hive和MySQL的安装与配置

一、版本要求&#xff1a;Hadoop:hadoop-2.10.1、MySQL&#xff1a;mysql-8.0.35、 HIVE&#xff1a;apache-hive-3.1.2、MySQL驱动&#xff1a;mysql-connector-java-5.1.49 安装包网盘链接&#xff1a;阿里云盘分享 安装位置 Hive:master、MySQL:slave1 二、卸载已安装的…

实现第三方app开机自启

添加 <category android:name"android.intent.category.LAUNCHER_APP" />

【数据结构】单链表OJ题(一)

&#x1f525;博客主页&#xff1a; 小羊失眠啦. &#x1f3a5;系列专栏&#xff1a;《C语言》 《数据结构》 《Linux》《Cpolar》 ❤️感谢大家点赞&#x1f44d;收藏⭐评论✍️ 文章目录 前言一、移除链表元素二、寻找链表中间结点三、输出链表倒数第k个结点四、反转单链表五…

【Web】在前端中CSS的语法

CSS规则是由两个主要的部分构成&#xff1a;选择器、以及一条或多条声明。 选择器通常是需要改变的HTML元素。 每条声明由一个属性和一个值组成。 属性&#xff08;Property&#xff09;是需要设置的样式属性&#xff08;Style attribute&#xff09;。每一个属性有一个值。…

Vue3+vite+cesium环境搭建

引言 目前有不少vue3cesium的配置教学&#xff0c;存在以下两个问题&#xff1a; &#xff08;1&#xff09;vue3cli方式&#xff0c;随着项目的迭代&#xff0c;npm run serve 启动调试很慢&#xff1b; &#xff08;2&#xff09;vue3vite 确实能将调试启动提升不少的&…

万宾科技智能井盖监测仪器助力建设数字化城市

市政公共设施建设在近几年来发展迅速&#xff0c;市政设备的更新换代&#xff0c;资产管理等也成为其中的重要一项。在市政设施建设过程中&#xff0c;井盖也是不可忽视的&#xff0c;一方面&#xff0c;根据传统的管理井盖模式来讲&#xff0c;缺乏有效的远程监控管理方法和手…

zookeeper:启动原理

主类&#xff1a; QuorumPeerMain, 其中调用了main对象的initializeAndRun方法&#xff0c; 首先定义了QuorumPeerConfig对象&#xff0c;然后调用了parse方法&#xff0c;parse方法代码如下&#xff1a; 其中调用的parseProperties方法的代码如下&#xff1a; 可以看到&am…

Docker实战

一、Docker安装 以下均以CentOS 7为例 1、安装Docker yum install -y docker-ce docker-ce-cli containerd.io docker-buildx-plugin docker-compose-plugin 2、启动和校验 # 启动Docker systemctl start docker# 停止Docker systemctl stop docker# 重启 systemctl resta…