[关闭]
@liruiyi962464 2025-04-17T08:18:50.000000Z 字数 10648 阅读 98

LTE-R网络无线质量采集终端部署文档

Linux服务器部署

for /L %i IN (1,1,254) DO ping -w 2 -n 1 172.0.0.%i

标题

一、设备链接

  1. ● 网口最右侧为wan口。其余4个为lan口。
  2. ● 默认接口ip:192.168.1.1。修改后：172.0.0.221。
  3. ● 网线一端连接lan口，另一侧连接到计算机，通过接口ip接入到终端

二、配置网络

  1. ● 添加路由网关的方式
  2. route add default gw 172.0.0.8
  4. ● 修改DNS
  5. vi /etc/resolv.conf
  6. nameserver 180.76.76.76
  7. nameserver 114.114.114.144
  9. ● 测试网络连接情况
  10. ping baidu.com

三、修改下载地址

  1. ● 地址文件的位置: vi /etc/opkg/distfeeds.conf
  2. ● 删除并修改文件内容，为官方下载地址
  3. src/gz openwrt_core http://archive.openwrt.org/releases/23.05.0/targets/ramips/mt7621/packages
  4. src/gz openwrt_base http://archive.openwrt.org/releases/23.05.0/packages/mipsel_24kc/base
  5. src/gz openwrt_luci http://archive.openwrt.org/releases/23.05.0/packages/mipsel_24kc/luci
  6. src/gz openwrt_packages http://archive.openwrt.org/releases/23.05.0/packages/mipsel_24kc/packages
  7. src/gz openwrt_routing http://archive.openwrt.org/releases/23.05.0/packages/mipsel_24kc/routing
  8. src/gz openwrt_telephony http://archive.openwrt.org/releases/23.05.0/packages/mipsel_24kc/telephony

四、下载插件

  1. ● opkg update  更新可以获取的软件包列表
  2. ● opkg upgrade 对已经安装的软件包升级
  3. ● 下载连接文件传输
  4. opkg install vsftpd openssh-sftp-server
  5. 加入开机自启——/etc/init.d/vsftpd enable
  6. 启动——/etc/init.d/vsftpd start
  7. ● opkg install minicom
  8. ● opkg install make
  9. ● opkg install python3
  10. ● opkg install python3-pip
  11. ● opkg install luci-i18n-base-zh-cn
  12. ● 安装linux后台运行插件nohup
  13.       opkg install nohup(将两个文件传送进去，需要手动下载 文件名如下：）
  14.       coreutils_9.3-1_mipsel_24kc.ipk 和 coreutils-nohup_9.3-1_mipsel_24kc.ipk
  15. ● pip3 install pyserial -i https://mirrors.aliyun.com/pypi/simple
  16. ● pip3 install flask -i https://mirrors.aliyun.com/pypi/simple
  17. ● pip3 install requests -i https://mirrors.aliyun.com/pypi/simple
  18. ● pip3 install ping3 -i https://mirrors.aliyun.com/pypi/simple
  20. ping3下载地址
  21. https://mirrors.aliyun.com/pypi/packages/e6/f4/4070daca3da5bbc3ef5e622d68f979e034e5bf678416817918e51a1b2907/ping3-4.0.8-py3-none-any.whl
  23. 汉化下载地址
  24. http://archive.openwrt.org/releases/23.05.0/packages/mipsel_24kc/luci/luci-i18n-base-zh-cn_git-24.101.63174-10fd9f2_all.ipk
  26. ● 文件存放地址
  27. python执行文件存放在 ./根目录下
  28. 自启动文件存放在./etc/init.d目录下
  30. 修改IP地址
  31. vi /etc/config/network
  32. /etc/init.d/network restart

五、设置自启动

  1. ln -s /etc/init.d/Start /etc/rc.d/S92Start
  2. chmod +x /etc/init.d/Start
  3. /etc/init.d/Start enable
  4. /etc/init.d/Start start
  1. root@OpenWrt:~# cat /etc/init.d/Start
  2. #!/bin/sh /etc/rc.common
  3. START=92
  4. STOP=15
  6. start(){
  7.    python3 start.py
  8. }
  10. stop(){
  11.    python3 start.py
  12. }
  14. restart(){
  15.    python3 start.py
  16. }
  18. enable(){
  19.    python3 start.py
  20. }
  22. disable(){
  23.    python3 start.py
  24. }
  26. root@OpenWrt:~# cat /etc/rc.d/S92Start
  27. #!/bin/sh /etc/rc.common
  28. START=92
  29. STOP=15
  31. start(){
  32.    python3 start.py
  33. }
  35. stop(){
  36.    python3 start.py
  37. }
  39. restart(){
  40.    python3 start.py
  41. }
  43. enable(){
  44.    python3 start.py
  45. }
  47. disable(){
  48.    python3 start.py
  49. }

六、接口说明

  1. ● 发送接口——at.py
  2. 传送IP地址，模组状态和卡状态———"http://"+ip_addr+":8091/jeecg-boot/system/deviceInfo/updateDeviceSIMStateAndMoudleState?ip="+data["ip"]+"&moudelState="+str(data["moudelState"])+"&simState="+str(data["simStat"])
  3. 传送信号值信息———"http://"+ip_addr+":8091/jeecg-boot/onlineStateDetection/deviceNetworkstatus/add"
  4. ● 接收接口——api.py
  5. 接收终端ping模组命令并执行操作——http://localhost:3562/ping
  6. 接收注册注销等命令并执行相关操作——http://localhost:3562/init

七、AT指令

  1. ● SIM卡开关机流程
  2. 开机初始化设置：
  3. AT
  4. AT+CIMI
  5. AT+CMEE=1
  6. ATE0
  7. AT+CGDCONT=1,"IP"
  8. 通电上电：
  9. AT+CFUN?
  10. AT+CFUN=1
  11. 轮询系统和网络信息
  12. AT+CSQ
  13. AT^SYSINFO
  14. AT+COPS=3,0
  15. AT+COPS?
  16. AT+COPS=3,2
  17. AT+COPS?
  18. 关机流程
  19. AT+CFUN=4
  20. AT+CFUN=0
  22. ● 搜网流程
  23. 测试当前可用的网络
  24. AT^SYSCONFIG?
  25. AT^SYSCONFIG=2,2,1,3
  26. AT+COPS=?
  27. 手动网络搜索
  28. AT^SYSCONFIG?
  29. AT+COPS=1,2,"46030",0
  30. AT+COPS=0
  32. ● 网络附着链接过程
  33. AT+CFUN=1
  34. AT+CGACT=1,1
  35. AT+ZGACT=1,1

八、代码文件

api.py

  1. from flask import Flask, jsonify, request,flash
  2. import at,requests,serial,time,os,ping3,threading
  4. app = Flask(__name__)
  6. app.secret_key = 'asdfghjkl'
  8. Dialer="/usr/local/bin/quectel-CM"
  9. tty_com="/dev/ttyUSB1"
  10. ip_addr = "172.0.0.10"
  12. @app.route('/ping/<ip>/<num>', methods=['POST', 'GET'])                                                           
  13. def ping(ip, num):                                                                                               
  14.     result = os.popen('ping -c '+num+' '+ip, 'r')                                                                 
  15.     out = result.read()                                                                                     
  16.     out = out.split('\n')
  17.     num = len(out)
  18.     # print(out)
  19.     if num == 1:
  20.         if out[0] == '':
  21.             print("error")
  22.             return "error"
  23.     else:                                                                                   
  24.         if out[1] == '':                                                                                        
  25.             print("error")                                                                                      
  26.             return "error"                                                                                      
  27.         else:                                                                                                   
  28.             print(out)                                                                                          
  29.             return out
  32. def send_AT(tty,cmd):
  34.     tty.write(cmd.encode())
  36.     data=ser.read(1)
  37.     time.sleep(0.1)
  38.     data = (data + ser.read(ser.inWaiting())).decode()
  40.     return data
  43. @app.route('/init', methods=['POST', 'GET'])
  44. def init():
  45.     global ser
  47.     ser = serial.Serial(tty_com, 115200,
  48.                             bytesize=serial.EIGHTBITS,
  49.                             parity=serial.PARITY_NONE,
  50.                             stopbits=serial.STOPBITS_ONE,
  51.                             timeout=3600)
  53.     state = request.args.get('state')
  54.     print(state)
  55.     if state.isdigit():
  56.         try:
  57.             os.system("kill $(pgrep -f 'python3 at.py')")
  58.             if state == '0':
  59.                 datas = send_AT(ser,"AT+CFUN=1\r\n")
  61.                 time.sleep(1)
  63.             elif state == '1':                                                                                                                                                                      
  64.                 datas = send_AT(ser,"AT+CFUN=0\r\n")
  65.                 datas = send_AT(ser,"AT+ZEMCI=0\r\n")                                                                                                                                              
  67.                 time.sleep(1)                                                                                                                                               
  69.             elif state == '2':                                                                                                                                                                                                                                                                                                                                     
  70.                 datas = send_AT(ser,"AT+CFUN=1\r\n")                                                                                                                                              
  72.                 time.sleep(1) 
  74.             elif state == '3':
  75.                 datas = send_AT(ser,"AT+CGATT=0\r\n")
  76.                 time.sleep(0.5)
  77.                 start_time = time.time()                                                                                                                                                                     
  78.                 datas = send_AT(ser,"AT+CGATT=1\r\n")
  79.                 datas = datas.split('\r\n')[0]
  81.                 if datas == 'ok':
  82.                     end_time = time.time()
  83.                     time_interval = end_time-start_time
  84.                     print(time_interval)
  86.                 time.sleep(1)                                                                                                                                               
  88.             elif state == '4':                                                                                             
  89.                 datas = send_AT(ser,"AT+CEREG=1\r\nAT+CGDCONT=1,\"IP\"\r\nAT+CGACT=1,1\r\nAT+ZGACT=1,1\r\n")                                                                      
  91.                 time.sleep(1)                                                                                                                                                                                 
  92.             else:
  93.                 time.sleep(0.2)
  94.             return state
  96.         except:
  97.             return 'error'
  99.         finally:
  100.             data = os.system("nohup python3 at.py >> /dev/null 2>&1 &")
  102. if __name__ == '__main__':
  103.     app.run(host='172.0.0.221', port=3652, debug=True)

at.py

  1. import os,sys,re,time,serial,subprocess,requests,json,socket
  3. Dialer="/usr/local/bin/quectel-CM"
  4. tty_com="/dev/ttyUSB1"
  6. ip_addr = "172.0.0.10"
  8. def send_AT(tty,cmd):
  10.     tty.write(cmd.encode())
  12.     data=ser.read(1)
  13.     time.sleep(0.1)
  14.     data = (data + ser.read(ser.inWaiting())).decode()
  16.     return data
  18. def cfun():
  19.     global ser
  20.     ser = serial.Serial(tty_com, 115200,
  21.                         bytesize=serial.EIGHTBITS,
  22.                         parity=serial.PARITY_NONE,
  23.                         stopbits=serial.STOPBITS_ONE,
  24.                         timeout=3600)
  26.     datas = send_AT(ser,"AT+CFUN=0\r\n")
  27.     datas = send_AT(ser,"AT+ZEMCI=0\r\n")
  28.     time.sleep(0.5)
  29.     # datas = send_AT(ser,"AT\r\nAT+CIMI\r\nAT+CMEE=1\r\nATE0\r\nAT+CGDCONT=1,\"IP\"\r\nAT+CFUN=?\r\nAT+CFUN=1\r\n")
  30.     # datas = send_AT(ser,"AT+CSQ\r\nAT^SYSINFO\r\nAT+COPS=3,0\r\nAT+COPS?\r\nAT+COPS=3,2\r\nAT+COPS?\r\n")
  31.     # datas = send_AT(ser,"AT^SYSCONFIG?\r\nAT+SYSCONFIG=2,2,1,3\r\nAT+COPS=?\r\n")
  32.     datas = send_AT(ser,"AT+CFUN=1\r\n&AT+CGACT=1,1\r\n&AT+ZGACT=1,1\r\n")
  33.     time.sleep(2)
  34.     datas = send_AT(ser,"AT+CGACT=1,1\r\n")
  35.     print("dadsqweqweqfas")
  36.     time.sleep(2)
  37.     datas = send_AT(ser,"AT+ZGACT=1,1\r\n")
  38.     time.sleep(2) 
  39.     datas = send_AT(ser,"AT+ZEMCI=1\r\n")
  41.     datas = send_AT(ser,"AT+CGPADDR=1\r\n")
  42.     ip = datas.split('\r\n')[0]
  44.     ser.close()
  46.     return 0
  48. def attach():                                                                     
  49.     global ser                                                                  
  50.     ser = serial.Serial(tty_com, 115200,                                        
  51.                         bytesize=serial.EIGHTBITS,                              
  52.                         parity=serial.PARITY_NONE,                              
  53.                         stopbits=serial.STOPBITS_ONE,                           
  54.                         timeout=3600)                                           
  56.     datas = send_AT(ser,"AT+ZGACT=1,1\r\n")                                       
  57.     time.sleep(1)                                               
  59.     ser.close()                                                                 
  61.     return 0
  64. def zemci():
  65.     parameter = {}
  66.     global ser                                                                  
  67.     ser = serial.Serial(tty_com, 115200,                                        
  68.                         bytesize=serial.EIGHTBITS,                              
  69.                         parity=serial.PARITY_NONE,                              
  70.                         stopbits=serial.STOPBITS_ONE,                           
  71.                         timeout=3600)
  73.     datas = send_AT(ser,"AT+ZEMCI=1\r\n")
  74.     time.sleep(1.2)
  75.     datas = send_AT(ser,"AT+ZEMCI=1\r\n")
  76.     zemci = datas.split('\r\n')[1]
  77.     # print(zemci)                                      
  80.     if zemci[5:10] != "ERROR" and zemci != "OK":
  81.         try:                                             
  82.             zemci = zemci.split(':')[1]                                                 
  83.             zemci = zemci.split(',')                                                                   
  84.             cellId = hex(int(zemci[0]))[2:]                                         
  85.             tac = zemci[2]                                                          
  86.             band = zemci[6]                                                         
  87.             rsrp = int(zemci[10])-140                                               
  88.             rsrq = int(zemci[11])*0.5-20                                            
  89.             pci = zemci[14][:4]                                                     
  90.             earfcn = int(zemci[14][4:],16)                                          
  91.             datas = send_AT(ser,"AT+ZEMCI=0\r\n")                                           
  92.             csq = zemci[10]
  93.         except:
  94.             print("error")
  96.         result = subprocess.check_output(['ifconfig'], shell=True)              
  97.         ifconfig_output = result.decode('utf-8')                                
  98.         ip = ifconfig_output[78:89]
  100.         parameter["ip"] = ip                                                        
  101.         parameter["cellId"] = cellId                                                
  102.         parameter["tac"] = tac                                                      
  103.         parameter["band1"] = band                                                   
  104.         parameter["rsrp"] = rsrp                                                    
  105.         parameter["rsrq"] = rsrq                                                    
  106.         parameter["pci"] = pci                                                      
  107.         parameter["earfcn"] = earfcn                                                
  108.         parameter["csq"] = csq                                                      
  109.         parameter['zemci'] = zemci
  111.         return parameter                                                                                
  112.     else:                                                                       
  113.         print("yizhuxiao")
  115.         return "yizhuxiao"
  118. def state():
  119.     parameter = {}                                                              
  120.     global ser                                                                  
  121.     ser = serial.Serial(tty_com, 115200,                                        
  122.                         bytesize=serial.EIGHTBITS,                              
  123.                         parity=serial.PARITY_NONE,                              
  124.                         stopbits=serial.STOPBITS_ONE,                           
  125.                         timeout=3600)
  127.     result = subprocess.check_output(['ifconfig'], shell=True)              
  128.     ifconfig_output = result.decode('utf-8')                                
  129.     ip = ifconfig_output[78:89]                                             
  131.     datas = send_AT(ser,"AT+CPIN?\r\n")                                     
  132.     card_status = datas.split('\r\n')[1]                                    
  134.     datas = send_AT(ser,"AT+CFUN?\r\n")                                     
  135.     fun = datas.split('\r\n')[1]                                            
  136.     # print(fun)
  137.     if fun == '+CFUN: 0':                                                   
  138.         moudelState = 0                                                     
  139.     else:                                                                   
  140.         moudelState = 1                                                     
  142.     if card_status == '+CME ERROR: 10':                                     
  143.         simState = 0                                                        
  144.     else:                                                                   
  145.         simState = 1
  147.     parameter["ip"] = ip
  148.     parameter['moudelState'] = moudelState                                  
  149.     parameter['simState'] = simState
  150.     return parameter
  152. def loop():
  153.     data = {}
  154.     global ser
  155.     ser = serial.Serial(tty_com, 115200,
  156.                             bytesize=serial.EIGHTBITS,
  157.                             parity=serial.PARITY_NONE,
  158.                             stopbits=serial.STOPBITS_ONE,
  159.                             timeout=3600)
  161.     datas = zemci()
  162.     print(datas)                                          
  163.     if datas != "yizhuxiao" and datas["ip"] == '172.0.0.221':              
  164.         data = {
  165.         "deviceIp":datas["ip"], 
  166.         "band1":datas["band1"],                      
  167.         "cellId":datas["cellId"],                  
  168.         "csq":datas["csq"],                        
  169.         "earfcn":datas["earfcn"],                  
  170.         "pci":datas["pci"],                        
  171.         "rsrp":datas["rsrp"],                      
  172.         "rsrq":datas["rsrq"],                                        
  173.         "tac":datas["tac"],          
  174.         }
  175.         print(data)
  176.         url = "http://"+ip_addr+":8091/jeecg-boot/onlineStateDetection/deviceNetworkstatus/add"
  177.         print("123")
  178.         response = requests.post(url,data=json.dumps(data),headers={"Content-Type":"application/json"})
  179.         print(response)
  180.     else:
  181.         print("error")
  182.     return data
  184. if __name__=="__main__":
  185.     num = 0
  186.     cfun()                                                            
  187.     while True:
  188.         try:
  189.             data = state()
  190.             # print(data) 
  191.         except Exception as e:
  192.             print('error')
  193.         result = os.system('ping -c 1 '+ip_addr+' >>/dev/null')
  194.         print(result)
  195.         attach()
  196.         if result:
  197.             time.sleep(10)
  198.             print('error1')
  199.         else:
  200.             try:
  201.                 if num == 0:
  202.                     num = 1
  203.                     loop()
  204.                     print(2)
  206.                     time.sleep(5)
  207.                     url = "http://"+ip_addr+":8091/jeecg-boot/system/deviceInfo/updateDeviceSIMStateAndMoudleState?ip="+data["ip"]+"&moudelState="+str(data["moudelState"])+"&simState="+str(data["simState"])
  208.                     response = requests.get(url)
  209.                 elif num == 1:
  210.                     num = 0
  211.                     loop()
  212.                     print(200)
  214.                     time.sleep(5)
  215.                     url = "http://"+ip_addr+":8091/jeecg-boot/system/deviceInfo/updateDeviceSIMStateAndMoudleState?ip="+data["ip"]+"&moudelState="+str(data["moudelState"])+"&simState="+str(data["simState"])         
  216.                     response = requests.get(url)
  217.             except:
  218.                 print("error2")

attach_api.py

  1. from flask import Flask, jsonify, request,flash
  2. import at,requests,serial,time,os,ping3,threading
  4. app = Flask(__name__)
  6. app.secret_key = 'asdfghjkl'
  8. Dialer="/usr/local/bin/quectel-CM"
  9. tty_com="/dev/ttyUSB1"
  10. ip_addr = "172.0.0.10"
  13. def send_AT(tty,cmd):
  15.     tty.write(cmd.encode())
  17.     data=ser.read(1)
  18.     time.sleep(0.1)
  19.     data = (data + ser.read(ser.inWaiting())).decode()
  21.     return data
  24. @app.route('/attach/<num>', methods=['POST', 'GET'])
  25. def attach(num):
  26.     global ser
  27.     ser = serial.Serial(tty_com, 115200,
  28.                             bytesize=serial.EIGHTBITS,
  29.                             parity=serial.PARITY_NONE,
  30.                             stopbits=serial.STOPBITS_ONE,
  31.                             timeout=3600)
  33.     result = []
  34.     if num.isnumeric():
  35.         while True:
  36.             try: 
  37.                 for i in range(int(num)):
  38.                     time_interval = 0
  39.                     datas = send_AT(ser,"AT+CGATT=0\r\n")
  40.                     print(datas)
  41.                     time.sleep(1)
  42.                     t = time.time()
  43.                     start_time = int(round(t * 1000))                                                                                                                                                                      
  44.                     datas = send_AT(ser,"AT+CGATT=1\r\n")
  46.                     datas = datas.split('\r\n')[1]
  48.                     if datas != 'ok':
  49.                         t = time.time()
  50.                         end_time = int(round(t * 1000))
  51.                         time_interval = end_time-start_time
  52.                         result.append(time_interval)
  53.                     else:
  54.                         result[i] = 'error'
  55.                     if len(result) == int(num):                    
  56.                         break                                                                                                                                              
  58.                 time.sleep(0.5)
  59.                 break
  60.             except:
  61.                 print("IndexError") 
  62.             # datas = send_AT(ser,"AT+CGATT?\r\n")                                                                                                                                           
  64.         return result
  65.     else:
  66.         return "error"
  69. if __name__ == '__main__':
  70.     app.run(host='172.0.0.221', port=3653, debug=True)

start.py

  1. import threading,time,os
  3. def at1():
  4.     os.system("python3 at.py")
  6. def api1():
  7.     os.system("python3 api.py")
  9. def attach_api():
  10.     os.system("python3 attach_api.py")
  13. if __name__=="__main__":
  14.     t1 = threading.Thread(target=at1)
  15.     t2 = threading.Thread(target=api1)
  16.     t3 = threading.Thread(target=attach_api)
  17.     t1.start()
  18.     t2.start()
  19.     t3.start()
添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注