Commit 1f89f36b authored by Luhan Wang's avatar Luhan Wang

update work logics

parent ce5cad7f
# OpenCPS <img src="README.assets/openxglogo.png" alt="OpenXG" style="zoom: 100;" />
## 无中心式物联网系统
### 新版本更新历史
##### 2019-4-12
1. 新增节点状态信息实时上报的功能
##### 2019-4-14
1. 构建矩阵解析程序
##### 2019-4-15
1. 重新设计完成新版的数据库
2. 基于矩阵解析程序构建完整任务处理逻辑程序
3. 完成任务自动循环处理的功能模块
4. 全部输入参数改为从数据库中调用
5. 新建DataCach数据库的控制函数
下一步计划:
1. 设计循环检测传感器数据并发送模块
2. 接收其他模块传递的数据并保存在dataCach数据库中
3. 构建基本控制器模块
4. 构建基于web控制的sanic脚本
##### 2019-4-16
1. 完成昨日计划1
2. 完成昨日计划3
##### 2019-4-21
1. 成功构建新版本的docker镜像,由于使用numpy需要安装额外的安装包
2. 完成在Docker上的测试功能
3. 实现基本的控制流程
下一步计划:
1. 将传感器数据传入云端数据库
2. 写一个好用的控制器脚本
3. 添加一个通过设备id查找相关配置信息的功能函数
4. 优化各个agent数据库内容显示
# 1. Generals
OpenXG is a series of 5G/6G-oriented open source projects developed by Open Source Radio Access Network Community. Currently, the community has developed the project from five aspects, including:
* Core network projects, 3GPP R15/R16 specification compliant network functions have been developed, including AMF, SMF, NRF, UPF, AUSF, UDM, AUSF, NWDAF, etc. Message level stateless mechanism is introduced in to the core network to make it better adapted to the cloud environment.
* Open hardware reference design, the reference design of heterogeneous computing hardware, white-box radio frontend, and open source UE hardware are also opened to the community.
* Radio access network projects, currently CU, DU and UE protocol software are developed, which is mainly compliant with 3GPP R15/R16 specifications. The software is developed by a modular-design, and which is flexible to customize to different vertical scenarios.
* AI-enabled management projects, three kinds of projects are developed under this category, including the AIEngine, which is aimed to provide the core AI capability for the management, the network measurement, and computing network for cloud-edge-end collaborative.
* Uses cases and applications in verticals, some key use cases when applying OpenXG to vertical scenarios are also developed as a reference for the community.
##### 2019-5-9
1. 构建命令行控制终端,模拟出物联网操作系统的样子
2. 添加外部直接控制传感器模块的任务模式
### 迭代历史
##### 2019-3-21
1. 完成智能体单元模块 # OpenCPS
## 无中心式物联网系统
##### 2019-3-22
1. 添加任务循环监听处理模块
2. 更改一些智能体单元模块bug
##### 2019-3-23
1. 完成控制器基本通信模块
##### 2019-3-25
1. 在docker上测试代码(存在bug未修复)
2. 已知问题:dht11的数据类型比较奇怪,需要进行额外处理,需要相应修改workProcess代码
##### 2019-3-26
1. 完成在Docker上的第一版代码测试(已修复BUG)
2. 搭建了一套完整的本地测试系统(包括dht102和switch104)
3. 搭建同时执行多条任务代码
## 版本说明
该版本由master版本迭代,在稳定运行基础上,添加如下新功能:
1. 添加故障检测功能
2. 添加在线设备检测功能
3. 优化控制接口,暂定`create`,`addtask`,`start`,`stop`,`delete`,`test`功能
注:multi-task多任务分支版本未完全开发完成,该版本为multi-task版本的拓展版本。 ## 主要功能说明
## 上一版本说明 本系统主要用于支撑面向垂直行业的开源无线网络示范应用,可支撑物联网设备、任务、资源等管理,本项目应用在了可视化智慧工厂、智能物流园区、网联智能驾驶等场景中。
智能体虚拟化模块主要有两大功能 智能体虚拟化模块主要有两大功能
1. 监听控制器的配置请求 1. 监听控制器的配置请求
2. 监听其他传感器的控制请求 2. 监听其他传感器的控制请求
### 目前智能体支持的控制命令 ### 目前智能体支持的控制命令
|控制命令|说明|范例| |控制命令|说明|范例|
|--------|----|----| |--------|----|----|
......
...@@ -38,3 +38,5 @@ while True: ...@@ -38,3 +38,5 @@ while True:
run_commands = run_commands + c_list[i] + ' ' run_commands = run_commands + c_list[i] + ' '
print(subprocess.getoutput(run_commands)) print(subprocess.getoutput(run_commands))
##
...@@ -2,8 +2,7 @@ ...@@ -2,8 +2,7 @@
*********************************************************** ***********************************************************
* 控制矩阵数据库的相关函数 * * 控制矩阵数据库的相关函数 *
* 1. resulovetable * * 1. resulovetable *
* author: joliu<joliu@s-an.org> * * author: joliu<joliu@s-an.org> * *
* date: 2018-4-14 *
*********************************************************** ***********************************************************
''' '''
...@@ -230,3 +229,5 @@ if __name__ == '__main__': ...@@ -230,3 +229,5 @@ if __name__ == '__main__':
(id, inputTask, inputTypeList, status, deviceList, ctime) = getTaskFromDB()[0] (id, inputTask, inputTypeList, status, deviceList, ctime) = getTaskFromDB()[0]
#print(inputTask) #print(inputTask)
print(getValueByNodeID(6)) print(getValueByNodeID(6))
###
...@@ -5,8 +5,7 @@ ...@@ -5,8 +5,7 @@
* 1. 输入任务流矩阵 * * 1. 输入任务流矩阵 *
* 1. 解析任务工作流 * * 1. 解析任务工作流 *
* * * *
* author: joliu<joliu@s-an.org> * * author: joliu<joliu@s-an.org> * *
* date: 2018-4-13 *
************************************************* *************************************************
''' '''
import json import json
...@@ -136,7 +135,7 @@ def runTask(): ...@@ -136,7 +135,7 @@ def runTask():
return (1, resolveMatrix(inputTask, inputTypeList, outputNode[0])) return (1, resolveMatrix(inputTask, inputTypeList, outputNode[0]))
###
if __name__ == "__main__": if __name__ == "__main__":
inputData = [0,0,0,0,0,1,0,1] inputData = [0,0,0,0,0,1,0,1]
print(runTask()) print(runTask())
......
...@@ -56,3 +56,5 @@ if __name__ == '__main__': ...@@ -56,3 +56,5 @@ if __name__ == '__main__':
ctime = getCircleTime() ctime = getCircleTime()
time.sleep(ctime) time.sleep(ctime)
###
\ No newline at end of file
...@@ -10,3 +10,4 @@ s.connect(("192.168.12.19", port)) ...@@ -10,3 +10,4 @@ s.connect(("192.168.12.19", port))
s.sendall(message.encode()) s.sendall(message.encode())
response = s.recv(1024).decode() response = s.recv(1024).decode()
print(response) print(response)
#####
\ No newline at end of file
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment