0301_APP/APP/network/downlink.c

#include "downlink.h"
#include "uplink.h"
#include "device.h"
#include "gateway.h"
#include "../network_mgr/net_proc.h"
#include "../../User/includes.h"
#include "../storage/AT24c128.h"
#include "../gateway_collect/gateway_collect.h"
#include "../dev_mgr/taxctrl/tax_ctrl.h"
#include "../globalDef.h"
#include "../storage/AT24C128Opt.h"
#include "../network_mgr/net_ctrl.h"
#include "../storage/AT24C128Opt.h"
#include "nettimer.h"

#include "me3616.h"

extern ME3616  air;

downlink_config_t downlink_config;
void downlink_init(void)
{
    int ret;
    int i;
    uint32_t flag = 0;
//    memset(&downlink_config.collect_conf,0,sizeof(downlink_config.collect_conf));
//    printf("downlink size %d\n",sizeof(downlink_config));
 //   printf("gateway_read size %d\n",sizeof(gateway_read));

    sprintf(g_upLinkTopic,"%s%04x/%010u",(char*)MQTT_UPLINK_TOPIC,GATEWAY_DEVICE_TYPE, g_firmwareMsg.gatewayMsg.hardwareMsg.gateway_sn);


  //  fram_read_config_msg();
   // if(downlink_config.config_flag == CONFIG_WRITE)
    {
        
        g_ledStatus.collNum =  g_ledStatus.led16.status;
        g_runData.timeSendStatus = 1;
        g_runData.bUpdate = 0;
        g_runData.bsendOilData = 0;
        downlink_config.config_flag =  1;
        g_ledStatus.led16.status = 0x8000;
        set_led_update_status(g_ledStatus.led16.status);
    }

}

int downlink_gateway_para(uint8_t *data, uint16_t len)
{
    int ret=-1;
    int i,j,k;
    downlinkSysCmd0x1011 *p_msg = NULL;
    uint16_t flag = 0x01;
    uint8_t *tempdata;
    tempdata = data+5;





    p_msg = (downlinkSysCmd0x1011 *)data;



    memset(&downlink_config,0,sizeof(downlink_config));


   // if(p_msg->gateway_id != g_firmwareMsg.gatewayMsg.hardwareMsg.gateway_sn)
   //     return ret;

    downlink_config.gateway_id = p_msg->gateway_id;
//    downlink_config.collect_num = p_msg->collect_num;
//    g_firmwareMsg.gatewayMsg.configmsg.coll_num = p_msg->collect_num;
   // g_firmwareMsg.gatewayMsg.hardwareMsg.gateway_sn = p_msg->gateway_id;
   // if(p_msg->collect_num > COLLECT_MAX_NUM) //采集器个数大于最大值，数据错误，直接返回
  //      return ret;


    downlink_config.config_flag = CONFIG_WRITE;
    fram_write_config_msg(flag);
    //fram_write_gateway_soft_msg();
    downlink_config.config_flag = flag;

    g_runData.timeSendStatus = 1;
    g_runData.bUpdate = 0;
    g_runData.bsendOilData = 0;
 //   AT24CXX_Write(CONFIG_ADDR,(uint8_t *)&downlink_config,sizeof(downlink_config));
    NVIC_SystemReset();//复位
	  return 0;
}
/*--------------------------------------------------------------
 *  解析网络下发的 系统类（0x01)的 0x1003指令 切换mqtt服务器
 * -------------------------------------------------------------*/
void downlink_analyze_system_cmd0x1003(uint8_t *data,uint16_t size)
{
    uint8_t len = 0;
    downlinkSysCmd0x1003 *msg = NULL;

    msg = (downlinkSysCmd0x1003*)data;

    if(msg->gateway_sn != downlink_config.gateway_id) return;
    //if(msg->targettype != GATEWAY_DEVICE_TYPE) return;

    memset(&(g_mqttRunDa.mqttMsg),0,sizeof(MqttIdPort));

    memcpy(g_mqttRunDa.mqttMsg.ip,msg->str,msg->iplen);
    len = msg->iplen;
    memcpy(g_mqttRunDa.mqttMsg.port,msg->str+len,msg->portlen);
    len += msg->portlen;
    memcpy(g_mqttRunDa.mqttMsg.admin,msg->str+len,msg->userlen);
    len += msg->userlen;
    memcpy(g_mqttRunDa.mqttMsg.password,msg->str+len,msg->pwdlen);

    g_mqttRunDa.mqttIdlen = msg->iplen;
    g_mqttRunDa.mqttPortlen = msg->portlen;
    g_mqttRunDa.mqttUserlen = msg->userlen;
    g_mqttRunDa.mqttPwdlen = msg->pwdlen;

    close_tcp_mqtt();
    g_mqttRunDa.bChangeMqtt = 1;
    air.State.MQTT_State= 0;
    //g_mqttRunDa.bChangeSuc = 0;
    g_mqttRunDa.connectNum = 0;
    g_runData.cregStatus = 0;


}

/*--------------------------------------------------------------
 *  刷新税控序列号0x1012
 * --------------------------------------------------------------*/
void downlink_analyze_system_cmd0x1012(uint8_t *data,uint16_t size)
{

}

/*--------------------------------------------------------------
 *  设备重新启动 0x1021
 * --------------------------------------------------------------*/
void downlink_analyze_system_cmd0x1021(uint8_t *data,uint16_t size)
{

    downlinkSysCmd0x1021 *p_msg = NULL;

    p_msg = (downlinkSysCmd0x1021*)data;


    switch(p_msg->targetType){
    case 0x0101: // 网关
        if(p_msg->sn != downlink_config.gateway_id) break;
        NVIC_SystemReset();//复位//设备重新启动
        break;
    case 0x0201: // 采集器
        break;
    case 0x0301: // 液位仪采集器
        if(p_msg->sn != downlink_config.gateway_id) break;
        NVIC_SystemReset();//复位//设备重新启动
        break;
    case 0x0401: // 显示器

        break;
    }
}
/*---------------------------------------------------------------
 *  液位仪的配置信息初始化
 * --------------------------------------------------------------*/
void downlink_oil_sys_cmd0x1031(uint8_t *data, uint16_t size)
{
    downlinkSysOilCmd0x1031 *pmsg = NULL;
  //  char sendbuff[32] = {0};
  //  uint16_t len = 0;
 //   downlinkDataOilCmd0x1021 *msg = (downlinkDataOilCmd0x1021*)sendbuff;

    pmsg = (downlinkSysOilCmd0x1031*)data;

    if((pmsg->gateway_sn!=downlink_config.gateway_id) && (pmsg->gateway_sn!=0xFFFFFFFF) ) return;
    g_oilReadMsg.paraLen = pmsg->paraLen;
    memset(g_oilReadMsg.param,0,sizeof(g_oilReadMsg.param));
    memcpy(g_oilReadMsg.param,pmsg->param,pmsg->paraLen);
    g_oilReadMsg.bInit = 0x5;
    fram_write_oil_msg();
    timeout_stop(&g_timeOut);
    g_runData.bsendOilData = READ_TIMER;
//    msg->gateway_sn = downlink_config.gateway_id;

//    len = sizeof(downlinkDataOilCmd0x1021);
//    tax_net_send(sendbuff,len,0x01,0x2031);
}

/*--------------------------------------------------------------
 *  解析网络下发的 系统类（0x01）的数据
 * --------------------------------------------------------------*/
void downlink_analyze_system_cmd(uint16_t type, uint8_t *data, uint16_t size)
{
    switch(type){
    case COLL_DN_SYS_CMD1011: //系统类 采集路由信息初始化下行
        downlink_gateway_para(data,size);
        break;
    case COLL_DN_SYS_CMD1012: // 系统类，刷新税控序列号
        downlink_analyze_system_cmd0x1012(data,size);
        break;
    case COLL_DN_SYS_CMD1021: // 系统类，系统重新启动
        downlink_analyze_system_cmd0x1021(data,size);
        break;
    case GATEWAY_DN_SYS_CMD1003: //配置mqtt服务器
        downlink_analyze_system_cmd0x1003(data,size);
        break;
    case COLL_DN_SYS_CMD1001: // 升级
        gateway_update_proc(data,size);
        break;
    case OILL_DN_SYS_CMD1031: // 系统类，油罐下行配置
        downlink_oil_sys_cmd0x1031(data,size);
        break;
    }
}
/*----------------------------------------------------------------------
 *  解析网络下发的  状态类的信息   固件信息下行指令 0x1001
 * ---------------------------------------------------------------------*/
void downlink_analyze_status_cmd0x1001(uint16_t type, uint8_t *data,uint16_t size)
{
    uint8_t index = 0;
    uint8_t sendBuff[160];
    uint8_t sendLen = 0;

    downlinkStatusCmd0x1001 *pMsg = NULL;

    pMsg = (downlinkStatusCmd0x1001*)data;

    if(pMsg->gateway_sn!=downlink_config.gateway_id) return;
    memset(sendBuff,0,sizeof(sendBuff));
    switch(pMsg->targetType){
    case 0x0101: // 网关
        uplink_tax_statusmcmd_0x2001(sendBuff,&sendLen,pMsg->targetType,0);
        tax_net_send(sendBuff,sendLen,FIRST_TYPE_STATUS,COLL_UP_STATUS_CMD2001);
        break;
    case 0x0201: // 采集器
        
        break;
    case 0x0301: // 液位仪采集器
        uplink_tax_statusmcmd_0x2001(sendBuff,&sendLen,pMsg->targetType,0);
        tax_net_send(sendBuff,sendLen,FIRST_TYPE_STATUS,COLL_UP_STATUS_CMD2001);
        break;
    case 0x0401: // 显示器

        break;
    }
}

/*--------------------------------------------------------------
 *  解析网络下发的状态类（0x02）的数据
 * --------------------------------------------------------------*/
void downlink_analyze_status_cmd(uint16_t type,uint8_t *data, uint16_t size)
{
    switch(type){
    case COLL_DN_STATUS_CMD1001: // 固件信息下行
        downlink_analyze_status_cmd0x1001(type,data,size);
        break;
    }
}
/*--------------------------------------------------------------------
 *  读取液位仪的数据
 * --------------------------------------------------------------------*/
void downlink_oil_data_cmd0x1021(uint8_t *data,uint16_t size)
{
    downlinkDataOilCmd0x1021 *pmsg = NULL;

    pmsg = (downlinkDataOilCmd0x1021*)data;

    if((pmsg->gateway_sn!=downlink_config.gateway_id) && (pmsg->gateway_sn!=0xFFFFFFFF)) return ;

	timeout_stop(&g_timeOut);
        g_runData.bsendOilData = READ_TIMER;
        g_runData.bread = 1;
}

/*--------------------------------------------------------------------
 * 数据类 0x03 类的信息
 * -------------------------------------------------------------------*/
void downlink_analyze_data_cmd(uint16_t type,uint8_t *data, uint16_t size)
{
    switch(type){
    case SECOND_TYPE_DATA_TAX : //报税口类

        break;
    case SECOND_TYPE_DATA_LED : // 显示屏

        break;
    case COLL_OIL_DATA_CMD1021 : // 液位仪
        downlink_oil_data_cmd0x1021(data,size);
        break;
    }
}


extern uint16_t crc16_get(uint8_t *data, uint8_t size);
int downlink_gateway_analyze(uint8_t *data, uint16_t len)
{
    int ret = 1;
    uint16_t crc,fcrc;
    uint8_t msg_type = 0;
    sverMsgHeader *p_msg = (sverMsgHeader *)data;

    if(p_msg->len > 128)
        return ret;

    crc = _crc16_get(data,p_msg->len+FRAME_HEADER_LEN-2);// len-2);
    fcrc = p_msg->info[p_msg->len-1];
    fcrc = (fcrc<<8)|p_msg->info[p_msg->len-2];

    if(p_msg->frame_header != 0xfefe){printf("rcv net data head error\r\n"); return 0;}
    if(crc != fcrc) {printf("rcv net data crc error\r\n"); return 0;}

    msg_type = p_msg->msgtypeFirst;
    printf("msg_type:%d\n",msg_type);
    switch(msg_type)
    {
        case FIRST_TYPE_SYST: //0x01
            downlink_analyze_system_cmd(p_msg->msgtypeSecd,(uint8_t*)p_msg->info,p_msg->len);
            break;
        case FIRST_TYPE_STATUS: // 0x02
            downlink_analyze_status_cmd(p_msg->msgtypeSecd,(uint8_t*)p_msg->info,p_msg->len);
            break;
        case FIRST_TYPE_DATA: // 0x03
            downlink_analyze_data_cmd(p_msg->msgtypeSecd,(uint8_t*)p_msg->info,p_msg->len);
            break;
        default:
            break;
    }
    return 0;
}