远程数据采集系统设计,数据传输到上位机。通过3G无线传输,传到监控中心后,怎么把数据存储SQL数据库中

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了远程数据采集系统设计,数据传输到上位机。通过3G无线传输,传到监控中心后,怎么把数据存储SQL数据库中相关的知识,希望对你有一定的参考价值。

传感器采集到相关的数据信息(主要是对环境数据的采集,包括了湘江水质PH,浊度等空气的湿度,灰尘等信号),传送给主控芯片S3C2440AL通过AT指令控制3G模块 发送数据到3G网络,通过网关后数据传送到INTERNET上,然后数据中心接收到数据后处理并存储起来。问题:数据传输过来后,怎么做可以把数据存储到SQL2005数据库中去。我上位机是采用B/S结构,VS2010 ,C#做一个上位机。对数据进行报表显示,趋势图分析。
另外就是3G模块与我中控室怎么进行连接通讯,是否是通过什么桥梁
中控室这边要接收数据,保存。是要编个什么程序还是怎么处理的
希望高手为我解答疑问啊,越详细越好。谢谢,急需!

数据中心动态库说明

1、数据类型

typedef UINT  u32t;

typedef UCHAR  u8t;

typedef USHORT  u16t;

typedef ULONG u64t;

2、数据结构

1) 用以区分标识各台DTU的数据结构

typedef struct _modem_info_t_

u32t m_modemId;       //Modem模块的ID号

u8t m_phoneno[12]; //Modem的11位电话号码,必须以'\\0'字符结尾

u8t m_dynip[4]; //Modem的4位动态ip地址

u64t m_conn_time;  //Modem模块最后一次建立TCP连接的时间

u64t m_refresh_time; //Modem模块最后一次收发数据的时间

 ModemInfoStruct;

2) DTU数据包的数据结构

#define MAX_RECEIVE_BUF 1450

typedef struct _modem_data_t 

   u32t m_modemId;       // Modem模块的ID号

   u64t m_recv_time; //接收到数据包的时间

   u8t  m_data_buf[MAX_RECEIVE_BUF+1]; //存储接收到的数据

   u16t  m_data_len; //接收到的数据包长度

   u8t      m_data_type;            //接收到的数据包类型,

// 0x01:用户数据包 

// 0x02:对控制命令帧的回应

ModemDataStruct;

以上u64t类型的时间是基于GMT时间1970年1月1日0:00:000以来的秒数指示时间值,即当前时间距1970年1月1日0点0分0秒以秒为单位的数值。在大多数语言都提供转换函数。

3、API函数说明

1) BOOL DSStartService(u16t uiListenPort);

功能:启动服务器的数据服务

参数:u16ListenPort:服务的侦听端口

返回:成功返回TRUE,失败返回FALSE;

说明:启动服务器的数据服务。启动数据服务后,服务器侦听在指定端口。

如果失败了,可以调用DSGetLastError()函数查看错误原因。

2) BOOL DSStopService(void);

功能:停止服务器的数据服务

参数:无

返回:成功返回TRUE,失败返回FALSE;

说明:停止服务器的数据服务。所有的DTU都将下线。

 如果失败了,可以调用DSGetLastError()函数查看错误原因。

3) BOOL DSGetNextData(ModemDataStruct* pDataStruct, u16t waitseconds);

功能:读取下一条DTU送上来的信息

参数:pDataStruct: 存放DTU所送上来的信息和数据的结构,读函数执行成功后,返回的数据存放到该参数指向的结构中

 waitseconds:本函数读到数据后立即返回;如果没有数据到达,则等待最长waitseconds(时间单位:秒)的时间,直到有数据到达,取值范围从0~65535,如果取值为0表明本函数将立即返回。另外,当在另一个线程中执行成功了DSStopService()后,本函数将立即返回。

返回:成功返回TRUE,失败返回FALSE;

说明:如果失败了,可以调用DSGetLastError()函数查看错误原因。

4) BOOL DSSendData(u32t modemId, u16t len, u8t * buf);

功能:向指定ID号的的DTU发送数据

参数:modemId:DTU的ID号,用以标识一个DTU

 len:待发送的数据长度(字节数),数据长度必须小于或等于1450个字节

 buf:待发送的数据

返回:成功返回TRUE,失败返回FALSE;

说明:如果失败了,可以调用DSGetLastError()函数查看错误原因。

5) BOOL DSSendControl(u32t modemId, u16t len, u8t * buf);

功能:向指定ID号的的DTU发送控制命令

参数:modemId:DTU的ID号,用以标识一个DTU

 len:待发送的控制命令长度(字节数),数据长度必须小于或等于1000个字节

 buf:待发送的控制命令帧

返回:成功返回TRUE,失败返回FALSE

说明:如果失败了,可以调用DSGetLastError()函数查看错误原因。]

6) u32t DSGetModemCount(void);

功能:取得当前在线的所有的DTU的总数

参数:无

返回:得到在线的DTU的数量

7) BOOL DSGetModemByPosition(u32t pos, ModemInfoStruct *pModemInfo);

功能:取得指定位置的DTU的数据;

参数:pos:DTU列表中的位置信息,0代表第一个DTU位置;

pModemInfo:指向用以保存DTU信息的数据结构;

返回:成功返回TRUE,失败返回FALSE

说明:如果失败了,可以调用DSGetLastError()函数查看错误原因。

一般来说DSGetDtuCount()和DSGetDtuByPosition()函数配合使用,用以查看当前所有DTU的信息,如下例所示:

u32t uiDtuCount;

uiDtuCount = DSGetDtuCount();

DtuInfoStruct dtuInfo;

u32t i;

for (i = 0; i < uiDtuCount; i++)

DSGetDtuByPosition (i, &dtuInfo);

//对dtuInfo进行操作

8) void DSGetLastError(char *str, int nMaxBufSize);

功能:获得先前API执行时发生的错误;

参数:str:用来存放错误信息的缓冲区;

 nMaxStrSize:缓冲区的最大长度,如果错误信息的大小超过了这个值,则此函数将把错误信息的尾部截除。

返回:无

9) BOOL DSDisconnect(u32t modemId);

功能:断开指定ID号的DTU连接

参数:modemId: DTU的ID号,用以标识一个DTU

返回:成功返回TRUE,失败返回FALSE

说明:如果失败了,可以调用DSGetLastError()函数查看错误原因。

4、函数的具体使用

3) 导入动态库

调用WINDOWS API函数LoadLibrary装载动态库,如下:

HMODULE DllMudule;              //指向动态库的句柄

BOOL (*DSStartService)(u16t);  //定义一个指向函数的地址的指针

hDllModule = LoadLibrary(“gprsdll.dll”);

If (hDllModule != NULL)     //判断调用是否成功

       //从动态库中取函数地址

       DSStartService = GetProcAddress(hDllModule,”DSStartService”);

       if (DSStartService != NULL)    //判断是否取到该函数地址

        

            if ((*DSStartService)( 5001) != FALSE)  

                  MessageBox(“启动成功”);

             Else

                  MessageBox(“启动失败”);

        

在程序开始时需要调用动态库,程序运行完毕后,要释放动态库,调用windows API函数FreeLibrary可释放动态库:

    FreeLibrary(hDllModule);   //TRUE-success  FALSE-failed

程序中LoadLibrary次数必须和FreeLibrary相同,每调用一次LoadLibrary,相应的应该调用一次FreeLibrary,保证每次调用后都会释放。

4) 启动服务

首先从动态库中取到该函数地址,取到地址后,就可以执行该函数,如下:

BOOL (*DSStartService)(u16t);   //定义一个指向函数的地址的指针

DSStartService = (BOOL(*)(u16t))GetProcAddress(hDllModule, “DSStartService”);

if (DSStartService != NULL)

    (*DSStartService)( 5001);

5) 停止服务

BOOL (*DSStopService)(void);

DSStopService = (BOOL (*)(void))GetProcAddress(hDllModule, “DSStopService”);

If (DSStopService != NULL) 

(*DSStopService)();

6) 读数据

BOOL DSGetNextData(ModemDataStruct*, u16t);

DSGetNextData = 

(BOOL(*)(ModemDataStruct*, u16t))GetProcAddress(hDllModule, “DSGetNextData”);

if (DSGetNextData != Null)

if ((*DSGetNextData)(&dtudata, 100) == 0)   //dtudata为DtuDataStruct型结构

//如果没有数据最长等待100秒

        //处理结构dtudata中的数据

 

7) 发送数据

BOOL DSSendData (u32t, u16t, u8t *);

DSSendData = (BOOL(*)(u32t, u16t, u8t*))GetProcAddress(hDllModule, “DSSendData”);

if (DSSendData != NULL)

    (*DSSendData)(nID, len, buf);

8) 用户列表

底层服务维护一张用户列表,记录当前在线用户的信息,DSC如果想知道底层用户列表,需要调用提供的API函数:DSGetModemCount、DSGetModemByPosition

for (u32t i = 0; i < (*DSGetModemCount)(); i++)

      (*DSGetModemByPosition)(i, &dtuinfo);

      //1、处理记录用户信息记录dtuinfo中的信息;

9) 错误信息

可以通过调用DSGetLastError()函数来获得上次调用API函数失败后的具体的错误信息。

char szErrorMsg[256];

DSGetLastError(szErrorMsg, 255);

这个是厦门才茂DTU动态库文件,如果需要咨询更详细,可以直接联系厦门才茂技术,或者直接到他们网站咨询

参考技术A 数据传到上位机应该是以数据包的格式,编程把数据包解析,存入数据库,上位机软件从数据库调用数据 参考技术B 一般这样功能都是这样实现的:
现场会有什么传感器啊仪表什么的,把接口(串口等等)连接到DTU(GPRS模块)上,DTU会把数据送至网络上,然后上位机都会使用一款组态软件,开发工程,完成自己需要的功能,比如数据实时显示,报表啊,曲线啊或者控制现场的设备等功能,然后组态软件可以通过设置把数据存入到access或者sql中。。。就ok了!
明白?追问

这个过程我知道,就是问题这个组态软件现在是自己编。例如用WINCC\RSVIEW/CITECT等我们也搞过,现在就是要自己编上位机软件,采用C#语言,基于ASP.NET,采用VS2010平台。问题现在是在VS2010中编个程序与网络连接,然后对数据进行分解每隔一段时间采集一组数据存储于数据库中呢,还是通过数据库直接和网络连接进行存储。存储的过程和操作大体是什么的啊。寻求解答,谢谢!

参考技术C 前辈您的问题解决了吗?可以让我考一份吗? 参考技术D 楼主 。不知道你什么时候能看到这个消息 。也不知道过了这么久的时间,你的这个程序完成的怎么样了。现在 我也在做这个。也是有很多的问题。不知道可不可以请教你。可以的话。给我发个邮件可以吗 。因为Q号。别人都加不了。179003712@qq.com.谢谢

以上是关于远程数据采集系统设计,数据传输到上位机。通过3G无线传输,传到监控中心后,怎么把数据存储SQL数据库中的主要内容,如果未能解决你的问题,请参考以下文章

家居环境监測系统设计(PC上位机版)(手机APP版待定)

环境监测系统的软件设计!

c#上位机开发

基于OPC技术的上位机与PLC之间的通信

我的自动化设备上位机软件开发设计

我的自动化设备上位机软件开发设计