printapi/dibang.py at main · deepforest7/printapi · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
from flask import Flask, request
import flask
import json
import random
import serial
#form icecream import ic

app = Flask(__name__)

from wsgiref.simple_server import make_server

# 只接受get方法访问
@app.route("/dibang", methods=["GET"])
def check():
    # 默认返回内容
    return_dict = {'return_code': '500', 'return_info': '处理失败', 'result': False}
    # 判断入参是否为空
    com = flask.request.values.get('com')
    bsp = flask.request.values.get('bsp')

    if com and bsp:
        # 对参数进行操作,并将结果返回
        return_dict['result'] = getdata(com, bsp)

        return json.dumps(return_dict, ensure_ascii=False)
    else:
        return json.dumps(return_dict, ensure_ascii=False)


# 功能函数
def getdata(com, bsp):  # 发送函数
    try:

        '''    connect serial'''
        try:
            '''    connect serial'''
            x = serial.Serial(com, bsp,timeout=0.3)  # 这是我的串口，测试连接成功，没毛病
        except Exception as e:
            print(e)
            return_dict['return_info'] = '串口链接超时'
            return

        myinput = bytes([0x02,0x41,0x42,0x30,0x33,0x03])
        #print(myinput[2:5])
        x.write(myinput)

        data = x.read(14)
        datas =''.join(map(lambda x:('/x' if len(hex(x))>=4 else '/x0')+hex(x)[2:],data))#将数据转成十六进制的形式
        #datas =''.join(map(lambda x:('0x' if len(hex(x))>=4 else '0x0')+hex(x)[2:],data))#将数据转成十六进制的形式

        print(datas)
        #datas = '/x02/x41/x42/x2b/x30/x30/x30/x30/x30/x30/x30/x31/x38/x03'
        new_datas = datas.split("/x")#将字符串分割，拼接下标4和5部分的数据

        #拼接整数位
        nums = ''
        for num in new_datas[5:11]:
            ic(num)
            nums += str(bytes.fromhex(num), encoding='utf-8')


        ic(new_datas[12])
        nums = nums +'.' + str(bytes.fromhex(new_datas[11]), encoding='utf-8')
        ic(nums)
        nums = float(nums)
        ic(nums)
    except Exception as e:
        print(e)
    return nums
    # if nums :
   	#     return_dict['return_info'] = '处理成功'
    #     return_dict['return_code'] = '200'
    #     return nums


# 默认返回内容
return_dict = {'return_code': '500', 'return_info': '处理失败', 'r1': False, 'r2': False}


# 只接受get方法访问
@app.route("/dianziweilan", methods=["GET"])
def checkin():
    # 判断入参是否为空
    com = flask.request.values.get('com')
    bsp = flask.request.values.get('bsp')
    if com and bsp:
        # 对参数进行操作
        print(com, bsp)
        return_dict['return_code'] = '200'
        return_dict['return_info'] = '处理成功'
        return_dict['r1'], return_dict['r2'] = dianziweilan(com, bsp)
        return json.dumps(return_dict, ensure_ascii=False)

    else:
        return_dict['return_info'] = '参数为空'
        return json.dumps(return_dict, ensure_ascii=False)


# 获取电子围栏寄存器状态
def dianziweilan(com, bsp):
    r1 = False
    r2 = False

    try:
        try:
            '''    connect serial'''
            x = serial.Serial(com, bsp,timeout=0.3)  # 这是我的串口，测试连接成功，没毛病
        except Exception as e:
            print(e)
            return_dict['return_info'] = '串口链接超时'
        '''    connect dibang   握手'''
        myinput = bytes([0xFE, 0x02, 0x00, 0x00, 0x00, 0x04, 0x6D, 0xC6])
        x.write(myinput)

        '''    read from dianziweilan '''
        myout = x.read(6)  # 读取串口传过来的字节流，这里我根据文档只接收7个字节的数据

        if len(myout) < 6:
            return_dict['return_info'] = '串口未拿到返回值'

        datas = ''.join(map(lambda x: ('/x' if len(hex(x)) >= 4 else '/x0') + hex(x)[2:], myout))  # 将数据转成十六进制的形式

        new_datas = datas.split("/x")  # 将字符串分割，拼接下标4和5部分的数据

        '''     chuli '''
        status = new_datas[4]
        print(status)
        if status == '01':
            r1 = True
        if status == '03':
            r2 = True
            r1 = True
        if status == '02':
            r2 = True
    except Exception as e:
        print(e)

    # my_need = int(hex(int(need,16)),16)#将十六进制转化为十进制
    # my_need = my_need/10
    # print('weight',my_need)

    print(r1, r2)
    return r1, r2


if __name__ == "__main__":
    #server = make_server('', 5000, app)
    #server.serve_forever()
    app.run(host='0.0.0.0', port=5000, debug=True)