📄 taskdata1.c
字号:
//上送数据
if(!send_flag[i])
{
num_ram = 0;
if((cur_hour*60+cur_minute)>RAM1_TaskDataFat[i].TimeSend[1])
{
//判断此时是否为上送时间点(2分钟内)
//调试用 if(((cur_hour*60+cur_minute-RAM1_TaskDataFat[i].TimeSend[1])%(RAM1_TaskDataFat[i].IntervalSend[1]))<=2)
{
//到RAM中寻找该时间点之前最近的数据采样点
temp = bcd_hex(TaskData[RAM1_TaskDataFat[i].AddStart+4])*60+bcd_hex(TaskData[RAM1_TaskDataFat[i].AddStart+5]);
if((cur_hour*60+cur_minute)>=(temp+RAM1_TaskDataFat[i].IntervalSample[1]))
{
while((cur_hour*60+cur_minute)>=(temp+RAM1_TaskDataFat[i].IntervalSample[1]))
{
temp = bcd_hex(TaskData[RAM1_TaskDataFat[i].AddStart+num_ram*RAM1_TaskDataFat[i].ByteNum_p+4])*60+
bcd_hex(TaskData[RAM1_TaskDataFat[i].AddStart+num_ram*RAM1_TaskDataFat[i].ByteNum_p+5]);
num_ram++;
}
}
//到此处num_ram的值为当前上送时间点之前最近的数据采样点的点号；
//SendInterval = (RAM1_TaskDataFat[i].FhzSend)*(RAM1_TaskDataFat[i].IntervalSample[1]);
if(RAM1_TaskDataFat[i].NumTotal>=num_ram)
{
num_flash = RAM1_TaskDataFat[i].NumTotal-num_ram;
add_start = RAM1_TaskDataFat[i].AddStartFlash+(RAM1_TaskDataFat[i].NumTotal-num_flash)*RAM1_TaskDataFat[i].ByteNum_p;
}
else //所有的上送数据都在SRAM1中；
{
num_flash = 0;
add_start = RAM1_TaskDataFat[i].AddStart+(num_ram-RAM1_TaskDataFat[i].NumTotal)*RAM1_TaskDataFat[i].ByteNum_p;
}
SendTaskData(i,num_ram,num_flash,add_start);
send_flag[i] = 1;
}
// else send_flag[i] = 0;
}
}
}
}
}
/*********************************************************************************************************
** 函数名称: task_ask_data
** 功能描述: 任务数据的召唤;
** 输 入: 无
** 输 出: 无
********************************************************************************************************/
void task_ask_data(void)
{
}
/*********************************************************************************************************
** 函数名称: SendTaskData
** 功能描述: 任务数据的上送;
** 输 入: no,任务分配表的表号；
** num_r,当日数据区的存放点数；
** num_f,FLASH1中的存放点数；
** add,FLASH1中开始点的首地址；
** 输 出: 无
** 说 明：同一点的数据不能拆分在连续两帧里进行发送。
********************************************************************************************************/
void SendTaskData(INT8U no,INT16U num_r,INT16U num_f,INT32U add)
{
INT8U buf[1024];
static INT8U iseq=0;//ISEQ 帧内序号（D15-D13），PSEQ 帧序号（D12-D6），
INT8U crc;
INT32U i,j,count=0;
INT32U lenth=0,lenth_d,len_frame=0; //发送长度计数；
INT32U SendInterval;
INT16S num,num1,numf_bufen;//num_bufen,一次上送帧中在FLASH1中的数据点数；
INT16U temp;
num = (INT16S)num_f;
num1 = (INT16S)num_r;
SendInterval = (RAM1_TaskDataFat[no].FhzSend)*(RAM1_TaskDataFat[no].IntervalSample[1]);
if(num_f>0)
{
// if(num)
while(num_f>count) //对FLASH中数据进行处理；num_f表示要从FLASH1中取出的点数；
{
for(i=0;i<1024;i++) buf[i] = 0;
buf[0] = RAM1_TaskDataFat[no].TaskNO; //任务号
buf[1] = *((volatile unsigned char *)add+(num_f-num)*(RAM1_TaskDataFat[no].ByteNum_p)); //年
buf[2] = *((volatile unsigned char *)add+(num_f-num)*(RAM1_TaskDataFat[no].ByteNum_p)+1);
buf[3] = *((volatile unsigned char *)add+(num_f-num)*(RAM1_TaskDataFat[no].ByteNum_p)+2);//月
buf[4] = *((volatile unsigned char *)add+(num_f-num)*(RAM1_TaskDataFat[no].ByteNum_p)+3);//日
buf[5] = *((volatile unsigned char *)add+(num_f-num)*(RAM1_TaskDataFat[no].ByteNum_p)+4);//时
buf[6] = *((volatile unsigned char *)add+(num_f-num)*(RAM1_TaskDataFat[no].ByteNum_p)+5);//分
buf[8] = MINU; //数据间隔单位;
buf[9] = SendInterval; //数据间隔数值；
lenth = 0;
while((lenth+RAM1_TaskDataFat[no].ByteNum_p-(count+num-num_f)*6/(RAM1_TaskDataFat[no].FhzSend))<1000) //RAM1_TaskDataFat[no].ByteNum_p
{
for(i=0;i<(RAM1_TaskDataFat[no].ByteNum_p)-6;i++)
{
buf[lenth+i+10-(count+num-num_f)*6/(RAM1_TaskDataFat[no].FhzSend)] =
*((volatile unsigned char *)add+(num_f-num)*(RAM1_TaskDataFat[no].ByteNum_p)+lenth+i+6);
}
lenth += RAM1_TaskDataFat[no].ByteNum_p;
count += RAM1_TaskDataFat[no].FhzSend;
if(count>=num_f) //当上送的点大于要从FLASH1中取出的点时，表示FLASH1中的数据点已发送完，
//接下来就要从SRAM1中读取数据
//假如count每次增加的上送频率大于1时，在SRAM1第一次取的有可能不是第一个点；
{
//lenth = 0;
//发送完所有点的数据后，直接退出函数；
numf_bufen = num; //在FLASH1中最后一次的上送点数的字节数不足发送缓冲区的空间时，在FLASH1中上送点数值
//count = RAM1_TaskDataFat[no].FhzSend-(count-num_f)-1;
count = count-num_f;
while(count<=num_r)
{
if(num_r>num1)
{
numf_bufen = 0;
for(i=0;i<1024;i++) buf[i] = 0;
buf[0] = RAM1_TaskDataFat[no].TaskNO; //任务号
buf[1] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)]; //年
buf[2] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+1];
buf[3] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+2];//月
buf[4] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+3];//日
buf[5] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+4];//时
buf[6] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+5];//分
buf[8] = MINU; //数据间隔单位;
buf[9] = SendInterval; //数据间隔数值；
}
while((lenth+RAM1_TaskDataFat[no].ByteNum_p-(count+numf_bufen+num1-num_r)*6/(RAM1_TaskDataFat[no].FhzSend))<1000)
{
for(i=0;i<(RAM1_TaskDataFat[no].ByteNum_p)-6;i++)
{
if(num_r==num1)
buf[lenth+i+10-(count+numf_bufen)*6/(RAM1_TaskDataFat[no].FhzSend)] =
TaskData[RAM1_TaskDataFat[no].AddStart+i+6];
else
buf[lenth+i+10-(count+num1-num_r)*6/(RAM1_TaskDataFat[no].FhzSend)] =
TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+i+lenth+6];
}
lenth += RAM1_TaskDataFat[no].ByteNum_p;
count += RAM1_TaskDataFat[no].FhzSend;
if(num_r<count) goto zhuzheng;
}
zhuzheng: if(num_r==num1) buf[7] = (count+numf_bufen)/(RAM1_TaskDataFat[no].FhzSend);//历史数据点数；
else buf[7] = (count+num1-num_r)/(RAM1_TaskDataFat[no].FhzSend);
// num_percent = buf[7];
for(i=0;i<64;i++)
{
if(!Send_Q[i].state)
{
for(j=0;j<1024;j++) Send_Q[i].buf[j] = 0;
Send_Q[i].flag = 1;
Send_Q[i].ch = 06; //调试时先用RS232通道；
//实际运行时，通过X8010[9]获得通信通道类型，从而确定每帧发送的最大长度；
Send_Q[i].count = 0;//已发送次数；
Send_Q[i].buf[0] = 0x68;
Send_Q[i].buf[1] = 0xaa; //终端逻辑地址-地市码（A1）；
Send_Q[i].buf[2] = 0xaa; //终端逻辑地址-区县码（A2）；
Send_Q[i].buf[3] = 0xaa; //终端逻辑地址-终端地址（A3）；
Send_Q[i].buf[4] = 0xaa; //终端逻辑地址-终端地址（A4）；
pseq++; //帧序号
if(pseq>=0x7f) pseq = 1;
if((RAM1_TaskDataFat[no].NumTotal)*(RAM1_TaskDataFat[no].ByteNum_p)<1000)
iseq = 0; //帧内序号
else iseq ++;
Send_Q[i].buf[5] = ((pseq&0x03)<<6)+0; //buf[5]和buf[6]表示主站地址和命令序号
Send_Q[i].buf[6] = ((iseq&0x07)<<5)+((pseq&0x7c)>>2);
Send_Q[i].buf[7] = 0x68;
Send_Q[i].buf[8] = 0x82;//控制码
if(num_r==num1) lenth_d = (count+numf_bufen)*(RAM1_TaskDataFat[no].ByteNum_p-6)/(RAM1_TaskDataFat[no].FhzSend)+10;
else lenth_d = (count+num1-num_r)*(RAM1_TaskDataFat[no].ByteNum_p-6)/(RAM1_TaskDataFat[no].FhzSend)+10;
Send_Q[i].buf[9] = (INT8U)lenth_d;//数据域长度
Send_Q[i].buf[10] = (INT8U)(lenth_d>>8);
for(j=0;j<lenth_d;j++)
{
Send_Q[i].buf[j+11] = buf[j];
}
len_frame = 13+lenth_d; //整个帧的长度，包括校验码和帧尾
for(j=0;j<(len_frame-2);j++)
{
crc += Send_Q[i].buf[j];
}
Send_Q[i].buf[len_frame-2] = crc;
Send_Q[i].buf[len_frame-1] = 0x68;
Send_Q[i].len = len_frame;
Send_Q[i].state = 1;
break;
}
}
if(num_r<count) return;
lenth = 0;
num1 = num_r-count;
}
}
}
buf[7] = (count+num-num_f)/(RAM1_TaskDataFat[no].FhzSend); //历史数据点数；
//num_percent = buf[7];
//组帧
for(i=0;i<64;i++)
{
if(!Send_Q[i].state)
{
for(j=0;j<1024;j++) Send_Q[i].buf[j] = 0;
Send_Q[i].flag = 1;
Send_Q[i].ch = 06; //调试时先用RS232通道；
//实际运行时，通过X8010[9]获得通信通道类型，从而确定每帧发送的最大长度；
Send_Q[i].count = 0;//已发送次数；
Send_Q[i].buf[0] = 0x68;
Send_Q[i].buf[1] = 0xaa; //终端逻辑地址-地市码（A1）；
Send_Q[i].buf[2] = 0xaa; //终端逻辑地址-区县码（A2）；
Send_Q[i].buf[3] = 0xaa; //终端逻辑地址-终端地址（A3）；
Send_Q[i].buf[4] = 0xaa; //终端逻辑地址-终端地址（A4）；
pseq++; //帧序号
if(pseq>=0x7f) pseq = 1;
if((RAM1_TaskDataFat[no].NumTotal)*(RAM1_TaskDataFat[no].ByteNum_p)<1000)
iseq = 0; //帧内序号
else iseq ++;
Send_Q[i].buf[5] = ((pseq&0x03)<<6)+0; //buf[5]和buf[6]表示主站地址和命令序号
Send_Q[i].buf[6] = ((iseq&0x07)<<5)+((pseq&0x7c)>>2);
Send_Q[i].buf[7] = 0x68;
Send_Q[i].buf[8] = 0x82;//控制码
lenth_d = (count+num-num_f)*(RAM1_TaskDataFat[no].ByteNum_p-6)/(RAM1_TaskDataFat[no].FhzSend)+10;
Send_Q[i].buf[9] = (INT8U)lenth_d;//数据域长度
Send_Q[i].buf[10] = (INT8U)(lenth_d>>8);
for(j=0;j<lenth_d;j++)
{
Send_Q[i].buf[j+11] = buf[j];
}
len_frame = 13+lenth_d; //整个帧的长度，包括校验码和帧尾
for(j=0;j<(len_frame-2);j++)
{
crc += Send_Q[i].buf[j];
}
Send_Q[i].buf[len_frame-2] = crc;
Send_Q[i].buf[len_frame-1] = 0x68;
Send_Q[i].len = len_frame;
Send_Q[i].state = 1;
break;
}
}
num = num_f-count;
// if(num==0) //此时表明FLASH1中最后一点数据也属于发送帧中的内容
}
}
else if(num_f==0) //第一次上送的数据点都在SRAM1中
{
//发送完所有点的数据后，直接退出函数；
//lenth = 0;
//发送完所有点的数据后，直接退出函数；
//numf_bufen = num; //在FLASH1中最后一次的上送点数的字节数不足发送缓冲区的空间时，在FLASH1中上送点数值
//count = RAM1_TaskDataFat[no].FhzSend-(count-num_f)-1;
//count = count-num_f-1;
lenth = 0;
count = 0;
while(count<=num_r)
{
if(num_r<=num1)
{
for(i=0;i<1024;i++) buf[i] = 0;
buf[0] = RAM1_TaskDataFat[no].TaskNO; //任务号
buf[1] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)]; //年
buf[2] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+1];
buf[3] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+2];//月
buf[4] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+3];//日
buf[5] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+4];//时
buf[6] = TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+5];//分
buf[8] = MINU; //数据间隔单位;
buf[9] = SendInterval; //数据间隔数值；
}
while((lenth+RAM1_TaskDataFat[no].ByteNum_p-(count+num1-num_r)*6/(RAM1_TaskDataFat[no].FhzSend))<1000)
{
for(i=0;i<(RAM1_TaskDataFat[no].ByteNum_p)-6;i++)
{
buf[lenth+i+10-(count+num1-num_r)*6/(RAM1_TaskDataFat[no].FhzSend)] =
TaskData[RAM1_TaskDataFat[no].AddStart+(num_r-num1)*(RAM1_TaskDataFat[no].ByteNum_p)+i+lenth+6];
}
lenth += RAM1_TaskDataFat[no].ByteNum_p;
count += RAM1_TaskDataFat[no].FhzSend;
if(num_r<count) goto zhuzheng1;
}
zhuzheng1: buf[7] = (count+num1-num_r)/(RAM1_TaskDataFat[no].FhzSend); //历史数据点数；
//num_percent = buf[7];
for(i=0;i<64;i++)
{
if(!Send_Q[i].state)
{
for(j=0;j<1024;j++) Send_Q[i].buf[j] = 0;
Send_Q[i].flag = 1;
Send_Q[i].ch = 06; //调试时先用RS232通道；
//实际运行时，通过X8010[9]获得通信通道类型，从而确定每帧发送的最大长度；
Send_Q[i].count = 0;//已发送次数；
Send_Q[i].buf[0] = 0x68;
Send_Q[i].buf[1] = 0xaa; //终端逻辑地址-地市码（A1）；
Send_Q[i].buf[2] = 0xaa; //终端逻辑地址-区县码（A2）；
Send_Q[i].buf[3] = 0xaa; //终端逻辑地址-终端地址（A3）；
Send_Q[i].buf[4] = 0xaa; //终端逻辑地址-终端地址（A4）；
pseq++; //帧序号
if(pseq>=0x7f) pseq = 1;
if((RAM1_TaskDataFat[no].NumTotal)*(RAM1_TaskDataFat[no].ByteNum_p)<1000)
iseq = 0; //帧内序号
else iseq ++;
Send_Q[i].buf[5] = ((pseq&0x03)<<6)+0; //buf[5]和buf[6]表示主站地址和命令序号
Send_Q[i].buf[6] = ((iseq&0x07)<<5)+((pseq&0x7c)>>2);
Send_Q[i].buf[7] = 0x68;
Send_Q[i].buf[8] = 0x82;//控制码
lenth_d = (count+num1-num_r)*(RAM1_TaskDataFat[no].ByteNum_p-6)/(RAM1_TaskDataFat[no].FhzSend)+10;
Send_Q[i].buf[9] = (INT8U)lenth_d;//数据域长度
Send_Q[i].buf[10] = (INT8U)(lenth_d>>8);
for(j=0;j<lenth_d;j++)
{
Send_Q[i].buf[j+11] = buf[j];
}
len_frame = 13+lenth_d; //整个帧的长度，包括校验码和帧尾
for(j=0;j<(len_frame-2);j++)
{
crc += Send_Q[i].buf[j];
}
Send_Q[i].buf[len_frame-2] = crc;
Send_Q[i].buf[len_frame-1] = 0x68;
Send_Q[i].len = len_frame;
Send_Q[i].state = 1;
break;
}
}
if(num_r<count) return;
num1 = num_r-count;
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -