python串口编程-传感器数据采集模块和位移计

3266阅读　0评论2012-10-21　niexining
分类：Python/Ruby


点击(此处)折叠或打开

  1. #coding:utf-8
  2. import serial
  3. from datetime import datetime
  4. from pyExcelerator import *
  5. import time

  7. f_art = lambda x : [x[i]*256+x[i+1] for i in range(len(x))[3:len(x)-2:4]]
  8. f_kerui = lambda x : [x[i]*256+x[i+1] for i in range(len(x))[3:len(x)-2:2]]
  9. def f_jinma(x):
  10.    ws = [hex(i)[-2:] for i in x]
  11.    a = []
  12.    for i in range(13,len(ws)):
  13.       if ws[i][0]=='3': a.append(ws[i][1])
  14.       else: break
  15.    b = []
  16.    for j in range(i+1,len(ws)):
  17.       if ws[j]=='2d': b.append('-')
  18.       elif ws[j][0]=='3': b.append(ws[j][1])
  19.       else: break
  20.    return [int(''.join(a))/100.0,int(''.join(b))/100.0]
  21.       
  22.    
  23.    a = int(''.join(ws[13:17]),10)/100.0
  24.    if ws[18]=='d': b = - int(''.join(ws[19:23]),10)/100.0
  25.    else: b = int(''.join(ws[18:22]),10)/100.0
  26.    return [a,b]

  28. def crc16(x):
  29.     b = 0xA001
  30.     a = 0xFFFF
  31.     for byte in x:
  32.         a = a^byte
  33.         for i in range(8):
  34.             last = a%2
  35.             a = a>>1
  36.             if last ==1: a = a^b
  37.     aa = '0'*(6-len(hex(a)))+hex(a)[2:]
  38.     ll,hh = int(aa[:2],16),int(aa[2:],16)
  39.     #print hex(hh),hex(ll)
  40.     return [hh,ll]


  43. def art_sort(ser,address,times):
  44.     w = [address,0x03,0x00,0x80,0x00,0x06] #判断阿尔泰模块类型
  45.     s = ''.join([chr(i) for i in w+crc16(w)])
  46.     for i in range(times):
  47.         ser.write(s)
  48.         r = [ord(i) for i in ser.read(21)]
  49.         if r and r[0]==address and r[1]==0x03:
  50.             sort = "%s%s" %(hex(r[3])[2:], hex(r[4])[2:])
  51.             print u"地址%s, %s" %(address,sort)
  52.             return sort
  53.     sort = ''
  54.     print u"地址%s, %s" %(address,sort)
  55.     return sort

  57. def read_3058(ser,address,times):
  58.     for channel in range(8):
  59.         w = [address,0x10,0x01,channel,0x00,0x01,0x02,0x00,0x0c] #设置量程 4~20ma
  60.         s = ''.join([chr(i) for i in w+crc16(w)])
  61.         ser.write(s)
  62.         ser.read(8)
  63.             
  64.     w = [address,0x04,0x01,0x00,0x00,0x10] #读数据,8通道
  65.     s = ''.join([chr(i) for i in w+crc16(w)])
  66.     for i in range(times):
  67.         ser.write(s)
  68.         r = [ord(i) for i in ser.read(37)]
  69.         if r and r[0]==address and r[1]==0x04:
  70.             code = f_art(r)
  71.             print [float('%.1f' %(c/65536.0*16+4)) for c in code]
  72.             return [float('%.1f' %(c/65536.0*16+4)) for c in code]
  73.     print []
  74.     return []

  76. def read_3046(ser,address,times):
  77.     for channel in range(6):
  78.         w = [address,0x10,0x01,channel,0x00,0x01,0x02,0x00,0x20] #设置量程 -200~600.C
  79.         s = ''.join([chr(i) for i in w+crc16(w)])
  80.         ser.write(s)
  81.         ser.read(8)
  82.     w = [address,0x04,0x01,0x00,0x00,0x0c] #读数据,6通道
  83.     s = ''.join([chr(i) for i in w+crc16(w)])
  84.     for i in range(times):
  85.         ser.write(s)
  86.         r = [ord(i) for i in ser.read(29)]
  87.         if r and r[0]==address and r[1]==0x04:
  88.             code = f_art(r)
  89.             print [float('%.1f' %(c/65536.0*800-200)) for c in code]
  90.             return [float('%.1f' %(c/65536.0*800-200)) for c in code]
  91.     print []
  92.     return []

  94. def read_art_module(com,addresses):
  95.     ser=serial.Serial()
  96.     ser.baudrate=2400
  97.     ser.port=com-1
  98.     ser.timeout=30
  99.     ser.open()
  100.     print u"阿尔泰模块"
  101.     w="0x0f 0x0f 0x00 0x00 0x00 0x04 0x01 0x01 0x00 0x5a 0x20".split() #打开继电器
  102.     s = ''.join([chr(int(i,16)) for i in w])
  103.     ser.write(s)
  104.     print u'正在打开继电器...'
  105.     ser.read(8)
  106.     result = {}
  107.     for address in addresses:
  108.         sort = art_sort(ser,address,2)
  109.         if sort == '3058': data = read_3058(ser,address,2)
  110.         elif sort == '3046': data = read_3046(ser,address,2)
  111.         else: data = []
  112.         result[(sort,address,datetime.now())] = data
  113.     w="0f 0f 00 00 00 04 01 00 00 5b b0".split() #关闭继电器
  114.     s = ''.join([chr(int(i,16)) for i in w])
  115.     ser.write(s)
  116.     print u'正在关闭继电器...'
  117.     ser.read(8)
  118.     ser.close()
  119.     return result

  121. def kerui_sort(ser,address,times):
  122.     w = [address,0x17,0x00,0x00,0x00,0x07] #判断科瑞模块类型
  123.     s = ''.join([chr(i) for i in w+crc16(w)])
  124.     for i in range(times):
  125.         ser.write(s)
  126.         r = [ord(i) for i in ser.read(12)]
  127.         if r and r[0]==address and r[1]==0x17:
  128.             sort = '8511'
  129.             print u"地址%s, %s" %(address,sort)
  130.             return sort
  131.     sort = ''
  132.     print u"地址%s, %s" %(address,sort)
  133.     return sort
  134.     
  135. def read_8511(ser,address,times):
  136.     w = [address,0x04,0x00,0x00,0x00,0x06]
  137.     s = ''.join([chr(i) for i in w+crc16(w)])
  138.     for i in range(times):
  139.         ser.write(s)
  140.         r = [ord(i) for i in ser.read(17)]
  141.         if r and r[0]==address and r[1]==0x04:
  142.             code = f_kerui(r)
  143.             print [float('%.1f' %(c/100.0)) for c in code]
  144.             return [float('%.1f' %(c/100.0)) for c in code]
  145.     print []
  146.     return []
  147.     
  148. def read_kerui_module(com,addresses):
  149.     ser=serial.Serial()
  150.     ser.baudrate=2400
  151.     ser.port=com-1
  152.     ser.timeout=30
  153.     ser.open()
  154.     print u"科瑞模块"
  155.     w="0F 05 00 00 FF 00 8D 14".split() #打开继电器
  156.     s = ''.join([chr(int(i,16)) for i in w])
  157.     ser.write(s)
  158.     print u'正在打开继电器...'
  159.     ser.read(20)
  160.     result = {}
  161.     for address in addresses:
  162.         sort = kerui_sort(ser,address,2)
  163.         if sort == '8511': data = read_8511(ser,address,2)
  164.         else: data = []
  165.         result[(sort,address,datetime.now())] = data
  166.     w="0F 05 00 00 00 00 CC E4".split() #关闭继电器
  167.     s = ''.join([chr(int(i,16)) for i in w])
  168.     ser.write(s)
  169.     print u'正在关闭继电器...'
  170.     ser.read(20)
  171.     ser.close()
  172.     return result

  174. def read_j(ser,address,times):
  175.     w = [0x23]+[int('3'+i,16) for i in address]+[0x41,0xde,0x21]
  176.     s = ''.join([chr(i) for i in w])
  177.     for i in range(times):
  178.         ser.write(s)
  179.         r = [ord(i) for i in ser.read(27)]
  180.         if r and r[0]==0x24 and ''.join([hex(i)[-1] for i in r][4:12])==address:
  181.            data = f_jinma(r)
  182.            print data
  183.            return data
  184.     print []
  185.     return []

  187. def read_jinma(com,addresses):
  188.     ser=serial.Serial()
  189.     ser.baudrate=2400
  190.     ser.port=com-1
  191.     ser.timeout=30
  192.     ser.open()
  193.     print u"金马位移计"
  194.     if com in art_table.keys(): w = "0x0f 0x0f 0x00 0x00 0x00 0x04 0x01 0x01 0x00 0x5a 0x20".split()
  195.     elif com in kerui_table.keys(): w = "0F 05 00 00 FF 00 8D 14".split()
  196.     s = ''.join([chr(int(i,16)) for i in w])
  197.     ser.write(s)
  198.     print u'正在打开继电器...'
  199.     ser.read(20)
  200.     result = {}
  201.     for address in addresses:
  202.        print u"金马 %s" %(address)
  203.        data = read_j(ser,address,2)
  204.        result[(u'金马',address,datetime.now())] = data
  205.     if com in art_table.keys(): w = "0f 0f 00 00 00 04 01 00 00 5b b0".split()
  206.     elif com in kerui_table.keys(): w = "0F 05 00 00 00 00 CC E4".split()
  207.     s = ''.join([chr(int(i,16)) for i in w])
  208.     ser.write(s)
  209.     print u'正在关闭继电器...'
  210.     ser.read(20)
  211.     ser.close()
  212.     return result
  213.     

  215. art_table = {6:[23,37,48,50,51,52,59,60,61,68,69,70],
  216.              18:[39,47,83,84,85,86,87,89],
  217.              8:[17,26,36,59,60,61,65,66,67,68,69,70,71,72,73],
  218.              9:[20,29,33,74,75,76,77,78,79,81,82],
  219.              12:[18,37,38,74,75,76,77,78,79,83,84,85],
  220.              26:[28,45,59,60,61,86,87,88],
  221.              7:[17,19,34,68,69,70,71,72,73,74,75,76,77,78,79],
  222.              27:[32,35,38,71,72,73,83,84,85,86,87,88],
  223.              17:[22,29,44,77,78,79,80,81,82,83,84,85],
  224.              11:[20,30,62,63,64,74,75,76],
  225.              10:[18,21,39,41,53,54,55,56,57,58,71,72,73,80,81,82],
  226.              24:[19,30,44,62,63,64,81,82,83,84,85,89],
  227.              22:[16,42,49,50,51,52,53,54,55,88,90,91],
  228.              25:[16,46,50,51,52,56,57,58],
  229.              21:[22,23,35,46,56,57,58,65,66,67,68,69,70,80,81,82],
  230.              23:[24,32,40,56,57,58,62,63,64,86,87,88],
  231.              5:[25,26,40,56,57,58,65,66,67,68,69,70],
  232.              14:[33,36,59,60,61,86,87,89],
  233.              19:[21,34,43,45,50,51,52,53,54,55,71,72,73,74,75,76],
  234.              13:[25,27,31,59,60,61,62,63,64,77,78,79],
  235.          }

  237. kerui_table = {2:[4,5,6,7,8,9,29,30,31],
  238.                1:[4,5,6,7,8,9,19,28,31],
  239.                4:[5,6,7,8,9,16,17,18,24],
  240.                3:[4,5,6,7,8,9,16,17,18],
  241.                28:[7,8,9,16,19,20],
  242.                15:[4,5,6,20,21,23],
  243.                30:[17,18,19,20,21,22,23,24,30],
  244.                31:[19,20,21,22,23,24,25,26,27],
  245.                34:[21,22,23,24,26,27,28,29,30],
  246.                16:[20,21,25,26,27,28,29,30,31],
  247.                29:[16,17,18,25,26,27,28,29,30],
  248.                32:[16,17,18,23,25,26,28,29,31],
  249.                }

  251. jinma_table = {6:['00618648','00618658','00618666','00618394'],
  252.                18:['00618313','00618675'],
  253.                8:['00618678','00618661','00618341','00618335','00618393','00618340'],
  254.                9:['00618679','00618682','06118655','00618329'],
  255.                12:['00618662','00618328','00618656','00618694'],
  256.                26:['00618676','00618336'],
  257.                7:['00618322','00618659','00618680','00618321','00618654','00618657'],
  258.                27:['00618660','00618664','00618339','00618325'],
  259.                17:['00619162','00618646','00619157','00618690'],
  260.                11:['00619181','00619202'],
  261.                10:['00619171','00618650','00618337','00619166','00618651','00618645'],
  262.                24:['00618647','00618323','00619183','00619158'],
  263.                22:['00618338','00619180','00619156','00619175'],
  264.                25:['00618315','00619159'],
  265.                21:['00618312','00619190','00618686','00619163','00618331','00618334'],
  266.                23:['00619192','00619177','00618681','00619176'],
  267.                5:['00618683','00618684','00618389','00618667'],
  268.                14:['00618390','00618391'],
  269.                19:['00618663','00618669','00618672','00618333','00618670','00618327'],
  270.                13:['00618392','00618311','00618668','00618324'],
  271.                2:['00619155','00618653','00618652','00618330'],
  272.                1:['00619187','00619195','00618677','00619172'],
  273.                4:['00619194','00619199'],
  274.                3:['00619188','00619173'],
  275.                28:['00618649','00619198'],
  276.                15:['00619165','00619168'],
  277.                30:['00619191','00619196','00619197','00619200'],
  278.                31:['00619186','00619185','00619154','00619161'],
  279.                34:['00619164','00619179','00619167','00619184'],
  280.                16:['00619201','00619170','00619193','00619174'],
  281.                29:['00619178','00618692','00619160','00618693'],
  282.                32:['00619182','00619189','00619169','00618689'],
  283.                
  284.                }

  286. def write_result(result,w,sheet):
  287.     ws = w.add_sheet(sheet)
  288.     ks = result.keys()
  289.     ks.sort()
  290.     row = 0
  291.     for k in ks:
  292.        sort,address,datetime = k
  293.        ws.write(row,0,sort)
  294.        ws.write(row,1,address)
  295.        style = XFStyle()
  296.        style.num_format_str = 'M/D/YY h:mm'
  297.        ws.write(row,2,datetime,style)
  298.        col = 3
  299.        for d in result[k]:
  300.           ws.write(row,col,d)
  301.           col += 1
  302.        row += 1
  303.    

  305. if __name__=="__main__":
  306.     
  307.     art_ks = art_table.keys()
  308.     kerui_ks = kerui_table.keys()
  309.     k = input('port: ')
  310.     print u'默认位移计, 模块输入m'
  311.     t = raw_input(': ')
  312.     if t == 'm':
  313.        if k in art_ks: result = read_art_module(k,art_table[k])
  314.        elif k in kerui_ks: result = read_kerui_module(k,kerui_table[k])
  315.     else:
  316.        result = read_jinma(k,jinma_table[k])
  317.     w = Workbook()
  318.     write_result(result,w,u'串口%s' %(k))
  319.     w.save(u'单个串口%s.xls' %(time.time()))

上一篇：crc16 python程序
下一篇：python调用vba宏