add ethernet example

network-comm/nic/ethernet/example_network_eth_lan.py

@@ -0,0 +1,41 @@
+import dataCall
+import ethernet
+
+nic = None
+
+def netStatusCallback(args):
+    pdp = args[0]
+    datacallState = args[1]
+    if datacallState == 0:
+        print('modem network {} disconnected.'.format(pdp))
+    elif datacallState == 1:
+        print('modem network {} connected.'.format(pdp))
+        if nic != None:
+            lte=dataCall.getInfo(1, 0)
+            print(lte)
+            nic.set_default_NIC(lte[2][2])
+
+def eth_init():
+    lte=dataCall.getInfo(1, 0)
+    print('modem net config: {}'.format(lte))
+    workMode=1
+    global nic
+    print('eth init start')
+    nic = ethernet.W5500(b'\x12\x34\x56\x78\x9a\xbc','192.168.1.1','','',-1,-1,-1,-1, workMode)
+    if lte != -1 and lte[2][0] == 1:
+        print('eth set default nic {}'.format(lte[2][2]))
+        nic.set_default_NIC(lte[2][2])
+    nic.set_dns('8.8.8.8', '114.114.114.114')
+    print('eth net config: {}'.format(nic.ipconfig()))
+    nic.set_up()
+    print('eth startup success')
+
+dataCall.setCallback(netStatusCallback)
+eth_init()
+
+
+
+
+
+
+

network-comm/nic/ethernet/example_network_eth_wan.py

@@ -0,0 +1,31 @@
+import ethernet
+
+nic = None
+
+def eth_init():
+    print('eth init start')
+    nic = ethernet.W5500(b'\x12\x34\x56\x78\x9a\xbc','','','',-1,-1,-1,-1)
+    nic_info = nic.ipconfig()
+    print('nic net config before: {}'.format(nic_info))
+    # dhcp ip config
+    nic.dhcp()
+    # static ip config 
+    nic.set_addr('192.168.1.99', '255.255.255.0','192.168.1.1')
+    nic.set_dns('8.8.8.8', '114.114.114.114')
+    nic_info = nic.ipconfig()
+    print('nic net config after: {}'.format(nic_info))
+    nic.set_default_NIC(nic_info[1][1])
+    nic.set_up()
+    print('eth startup success')
+
+eth_init()
+
+# now, you can connect server by ethernet interface
+
+
+
+
+
+
+
+

network-comm/nic/wifi/WLAN.py

@@ -0,0 +1,230 @@
+import usocket
+import log
+import utime
+import slip
+from machine import UART
+import _thread
+from queue import Queue
+
+# 设置日志输出级别
+log.basicConfig(level=log.INFO)
+ESP8266_log = log.getLogger("ESP8266")
+
+
+class ESP8266:
+    AP = 0  # SLIP_INNER
+    STA = 1 # SLIP_OUTER
+
+    def __init__(self, uart=UART.UART2, mode=STA, callback=None):
+        self.__uart = uart
+        self.__mode = mode
+        self.__message = ''
+        self.__err = 0
+        self.__callback = callback
+        self.__value = None
+        self.__wait_resp = 0
+        slip.destroy()
+
+        ret = slip.construct(self.__uart, self.__mode, 0)
+        if ret != 0:
+            #print('slip netif construct fail')
+            return None
+        #print('slip network card create success')
+        self.__queue = Queue(1)
+        self.__sock = self.__socket_init()
+        self.__threadid = _thread.start_new_thread(self.__Socket_Thread, ())
+        return None
+
+    def __socket_init(self):
+        # 创建一个socket实例
+        sock = usocket.socket(usocket.AF_INET, usocket.SOCK_DGRAM, usocket.TCP_CUSTOMIZE_PORT)
+        sock.setsockopt(usocket.SOL_SOCKET, usocket.SO_REUSEADDR, 1)
+        # 绑定IP
+        bind_addr = ('172.16.1.2', 5000)
+        sock.bind(bind_addr)
+        sock.settimeout(10)
+        return sock
+
+    def __socket_reinit(self):
+        return self.__socket_init()
+
+    # station模式
+    def station(self, user, password):
+        self.clear_remain()
+        __head = 'F3'
+        self.user = str(user)
+        self.password = str(password)
+        if self.__mode == self.STA:
+            self.__message = self.user + ',' + self.password
+        else:
+            #print('Not match station mode')
+            return -1
+        self.__Socket_UDP(__head, self.__message)
+        if self.__err == 1 or self.__value[2] != 'OK':
+            return -1
+        return 0
+
+    #ap 模式
+    def ap(self, user, password):
+        self.clear_remain()
+        __head = 'F2'
+        self.user = str(user)
+        self.password = str(password)
+
+        if self.__mode == self.AP:
+            self.__message = self.user + ',' + self.password
+        else:
+            #print('Not match ap mode')
+            return -1
+        self.__Socket_UDP(__head, self.__message)
+        if self.__err == 1 or self.__value[2] != 'OK':
+            return -1
+        return 0
+
+    # web配网模式
+    def web_config(self, user, password):
+        self.clear_remain()
+        __head = 'F0'
+        if user == '' and password == '':
+            self.__message = '0'
+        else:
+            self.user = str(user)
+            self.password = str(password)
+            self.__message = self.user + ',' + self.password
+        self.__Socket_UDP(__head, self.__message)
+        if self.__err == 1 or self.__value[2] != 'OK':
+            return -1
+        return 0
+
+    def clear_remain(self):
+        if self.__queue.empty() == False:
+            self.__queue.get()
+        self.__err = 0
+        self.__value = None
+
+    # 查询网卡状态
+    def status(self):
+        self.clear_remain()
+        self.__Socket_UDP('F1', '0')
+        if self.__err == 1:
+            return 0
+        return int(self.__value[2])
+
+	# 查询网卡版本信息
+    def version(self):
+        self.clear_remain()
+        self.__Socket_UDP('F5', '0')
+        if self.__err == 1:
+            return -1
+        return self.__value[2]
+
+	# ota升级
+    def ota(self, url):
+        self.clear_remain()
+        __head = 'F4'
+        self.__message = str(url)
+        self.__Socket_UDP(__head, self.__message)
+        if self.__err == 1 or self.__value[2] != 'OK':
+            return -1
+        return 0
+	# smartconfig配置
+    def smartconfig(self, mode):
+        self.clear_remain()
+        __head = 'F6'
+        self.__message = str(mode)
+        self.__Socket_UDP(__head, self.__message)
+        if self.__err == 1 or self.__value[2] != 'OK':
+            return -1
+        return 0
+
+    #添加路由信息
+    def router_add(self, ip='192.168.4.1', mask='255.255.255.0'):
+        self.ip = ip
+        self.mask = mask
+        return slip.router_add('192.168.4.1', '255.255.255.0')
+
+    # 获取slip的网络配置
+    def ipconfig(self):
+        return slip.ipconfig()
+
+	# 设置dns服务器
+    def set_dns(self, pri_dns='8.8.8.8', sec_dns='114.114.114.114'):
+        self.pri_dns = pri_dns
+        self.sec_dns = sec_dns
+        return slip.set_dns(self.pri_dns,self.sec_dns)
+
+	# 设置默认网卡
+    def set_default_NIC(self, ip_str):
+        self.ip_str = ip_str
+        return slip.set_default_netif(self.ip_str)
+
+    # 释放slip网卡
+    def stop(self):
+        slip.destroy()
+        return 0
+
+
+    # 封装tlv数据包
+    def __pack_tlv_format(self, head, content):
+        self.head = head
+        self.content = content
+        if len(self.content) == 0 or len(self.content) > 9999 or len(self.head) != 2:
+            #print('illegal tlv content')
+            return -1
+        len_str ='%04d' % len(self.content)
+        tlv_pack = self.head+len_str+self.content
+        return tlv_pack
+
+    # 解码tlv数据包
+    def __unpack_tlv_format(self, msg):
+        self.msg = str(msg)
+        tag = self.msg[0:2]
+        length = self.msg[2:6]
+        value = self.msg[6:]
+        len_str ='%04d' % len(value)
+        if len(value) == 0 or len(value) > 9999 or len(tag) != 2 or len_str != self.msg[2:6]:
+            #print('illegal tlv content')
+            return -1
+        unpack = (tag,length,value)
+        return unpack
+
+    # socket通信(UDP)模块
+    def __Socket_UDP(self, head, content):
+        self.head = head
+        self.content = content
+
+        # 消息处理
+        msg = self.__pack_tlv_format(self.head, self.content)
+
+        # 向服务端发送消息
+        server_addr = ('172.16.1.5',1000)
+        #print(msg)
+        self.__err = 0
+        self.__sock.sendto(msg,server_addr)
+        self.__wait_resp = 1
+        data = self.__queue.get()
+        self.__wait_resp = 0
+        return data
+
+    # socket通信(UDP)模块
+    def __Socket_Thread(self):
+        while True:
+            try:
+                data=self.__sock.recv(1024)
+            except Exception as recverr:
+                if "110" in str(recverr):
+                    self.__err = 1
+                    if self.__wait_resp == 1:
+                        self.__queue.put('0')
+                else:
+                    utime.sleep(1)
+                    self.__sock = self.__socket_reinit()
+            else :
+                value = self.__unpack_tlv_format(data.decode())
+                #print('mode: {0}, recv {1} bytes, Data: {2}'.format (value[0],len(data), value[2]))
+                if value[0] == 'FF':
+                    if self.__callback != None:
+                        self.__callback(value[2])
+                else:
+                    self.__value = value
+                    self.__queue.put('1')