//#include "stdafx.h"
#include "sjframe.h"
#include "metertable.h"
#include "meterseltable.h"
#include "rptime.h"

extern void rp_recvack();
extern u8 * get_uart_send();
extern void sj_frame_data_ack(u8 * val,u16 * len,u8 * meter,u8 * data);
extern void controlkeyaddr(u8 *str1,u8 val);
extern void simul_plc_rx_addr(u8 *str1);
extern void metertable_add(const u8 * addr,const u8 type);
extern void metertable_write();
extern void ClearMeterInfo();
extern bool get_dl_task_state();
extern void dl_start();
extern void ClearMeterInfo_realdl( void );
extern void ctl_start(u8 flag);
extern afn04_F3_st comm_04F3_param;

extern void ctl_sel_start(u8 flag);
extern void dl_task_set_rp();
extern void mbus_master_tx_begin();

extern u8 smt_get_len();
extern u8 * smt_get_val();
extern void amt_task(u8 * val);
extern void concent_send_uart(u8 * val,u16 len);
extern void amt_frame_data(u8 * val,u16 * len,u8 * amtval,u8 amtlen);
extern u8 sj_get_recvser();


void control_key_ack(u8 key)
{
	u16 len = 0;
	u8 * q = get_uart_send();
	sj_frame_ack(q,&len,key);
	concent_send_uart(q,len);
}

void sj_data_ack(u8 * meter,u8 * data)
{
	u16 len = 0;
	u8 * q = get_uart_send();
	sj_frame_data_ack(q,&len,meter,data);
	concent_send_uart(q,len);
}



//////////////////////////////////////////////////
static bool is_ctl_flag = false;
static u16 is_ctl_count = 0;
u8 ctladdr[7];
u8 ctlflag = 0;
void sj_ctl_process()
{
	if(is_ctl_flag)
	{
		is_ctl_count++;

		if(is_ctl_count>6)
		{
			is_ctl_flag = false;
			is_ctl_count = 0;

			//
			printf("等待多个点开关阀时间到\r\n");

			ctl_sel_start(ctlflag);
		}
	}
}


bool sj_frame_recv(u8 * val,u16 vallen)
{
	u8 * p = val;
	//0  1  2  3  4  5  6  7  8  9  10 11 12 13 14 
	//68 71 00 71 00 68 40 12 34 56 78 00 93 71 00 00 01 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 59 16

	u8 fn = p[12];
	u8 * q = get_uart_send();
	u16 len = 0;

	sj_set_recvser(p[13]);

	switch(fn)
	{
	default:
		break;
	case 0x93:			//1.集中器初始化
		{
			metertable_init();
			metertable_write();

			sj_frame_ack(q,&len,0x93);
			concent_send_uart(q,len);
			return true;
		}
		break;
	case 0x8C:			//2.上报时间
		{
			//0  1  2  3  4  5  6  7  8  9  10 11 12 13 14 15 16 17 18 19 20
			//68 8D 00 8D 00 68 40 07 55 00 08 00 8C 72 00 00 01 00 81 05 04 02 25 10 19 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 7D 16

			//
			rptime_set(&p[18]);
			rptime_write();
			sj_frame_ack(q,&len,0x8C);
			concent_send_uart(q,len);
			return true;
		}
		break;
	case 0x81:			//3.关阀
		{
			//0  1   2  3  4  5  6  7  8  9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26
			//68 99 00 99 00 68 40 12 34 56 78 00 81 71 00 00 01 00 00 00 00 96 25 10 08 19 00 00 00 00 00 00 00 AA 00 00 00 00 00 00 00 00 00 00 DD 16

			control_key_ack(0x81);

			ctlflag = METER_CLOSE;

			is_ctl_flag = true;

			is_ctl_count = 0;

			meterseltable_add(&p[21],METER_CLOSE);
			return true;
		}
		break;
	case 0x82:			//4.开阀
		{

			control_key_ack(0x82);

			ctlflag = METER_OPEN;

			is_ctl_flag = true;

			is_ctl_count = 0;

			meterseltable_add(&p[21],METER_OPEN);

			return true;
		}
		break;
	case 0x84:			//5.单个抄表
		{
			//0  1  2  3  4  5  6  7  8  9  10 11 12 13 14 15 16 17 18 19 20 21                 
			//68 55 00 55 00 68 40 12 34 56 78 00 84 71 00 00 01 00 00 01 00 59 02 81 90 11 11 D9 16                        
			//sj_frame_ack(q,&len,0x82);
			//concent_send_uart(q,len);

			//清除数据

			ClearMeterInfo_realdl();

			//因为涉及到延长30秒，特地加这个。
			mbus_master_tx_begin();

			simul_plc_rx_addr(&p[21]);
			return true;
		}
		break;
	case 0x9D:			//6.集抄
		{
			//0  1  2  3  4  5  6  7  8  9  10 11 12 13 14 15 16 17 18 19 20 21                 
			//68 31 00 31 00 68 40 12 34 56 78 00 9D 71 00 00 01 00 63 16	

			// 5秒后启动定时上报
			sj_frame_ack(q,&len,0x9D);
			concent_send_uart(q,len);

			//不仅抄表还需要上报
			dl_task_set_rp();

			dl_start();

			return true;
		}

	case 0x51:			//7.批量关阀
		{
			//0  1  2  3  4  5  6  7  8  9  10 11 12 13 14 15 16 17 18 19 20 21                 
			//68 31 00 31 00 68 40 12 34 56 78 00 51 73 00 00 01 00 19 16

			// 批量关阀
			sj_frame_ack(q,&len,0x51);
			concent_send_uart(q,len);
			ctl_start(METER_CLOSE);
			return true;
		}

		break;

	case 0x52:			//8.批量开阀
		{
			//0  1  2  3  4  5  6  7  8  9  10 11 12 13 14 15 16 17 18 19 20 21                 
			//68 31 00 31 00 68 40 12 34 56 78 00 52 74 00 00 01 00 1B 16

			// 批量开阀
			sj_frame_ack(q,&len,0x52);
			concent_send_uart(q,len);
			ctl_start(METER_OPEN);
			return true;
		}

		break;
	case 0x85:			//9.下发档案
		{
			//0  1  2  3  4  5  6  7  8  9  10 11 12 13 14 15 16 17 18 19 20 21                 
			//               68 40 12 34 56 78 00 85 71 00 00 01 00 02 00 
			//01 00 48 20 10 08 19 00 00 01 
			//02 00 96 25 10 08 19 00 00 01 
			//00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 D7 16
			// 批量开阀
			sj_frame_ack(q,&len,0x85);
			//
			u8 num = p[18];
			u8 * pp = &p[20];

			for(u8 i = 0;i<num;i++)
			{
				metertable_add(&pp[2],0);
				pp = pp + 10;
			}

			metertable_write();

			concent_send_uart(q,len);
			return true;
		}

		break;
	case 0x96:			//10.上报回应
		{
			rp_recvack();
			return true;
		}
		break;
	case 0x88:			//10.修改ip
		{
			//0  1  2  3  4  5  6  7  8  9  10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 
			//68 55 01 55 01 68 40 07 55 00 08 00 88 73 00 00 01 00 00 78 4C E5 35 DC 20 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 43 4D 4E 45 54 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 F1 16


			//comm_04F3_param.primary.ip1 = ip1[0];
			//comm_04F3_param.primary.ip2 = ip1[1];
			//comm_04F3_param.primary.ip3 = ip1[2];
			//comm_04F3_param.primary.ip4 = ip1[3];
			//comm_04F3_param.primary.port = port1;


			comm_04F3_param.reserve.ip1 = p[19];
			comm_04F3_param.reserve.ip2 = p[20];
			comm_04F3_param.reserve.ip3 = p[21];
			comm_04F3_param.reserve.ip4 = p[22];
			comm_04F3_param.reserve.port = (p[24]<<8)|p[23];


			ipport_write();

			ipport_init();


			sj_frame_ack(q,&len,0x88);
			concent_send_uart(q,len);

			//rp_recvack();
			return true;
		}
		break;

	case 0x9E:			//11.透明传输
		{
			//0  1  2  3  4  5  6  7  8  9  10 11 12 13 14 15 16 17 18 19 20 21                 
			//68 31 00 31 00 68 40 12 34 56 78 00 9E 74 00 00 01 00 1B 16
                  
                        amt_task(p);
                        amt_frame_data(q,&len, smt_get_val(),smt_get_len());
			concent_send_uart(q,len);
			return true;
		}
		break;
	}
	return false;
}