var newMSG = msg.payload;

timestamp = newMSG.rx.gwrx[0].time.split(' ');
 date = { payload: timestamp[0]};
 time = { payload: timestamp[1]};
pulse_base64 = {payload: newMSG.rx.userdata.payload};
 device_no = {payload: newMSG.rx.moteeui};
 port = {payload: newMSG.rx.userdata.port};
 rssi = {payload: newMSG.rx.gwrx[0].rssi};

msg.topic = "INSERT INTO `electro_count` (`date`, `time`, `start_t`, `end_t`, `flow`, `pulse`, `device_no`, `rssi`, `port`) VALUES ("+date+","+time+","+"1"+","+"2"+","+"3"+","+pulse_base64+","+device_no+","+rssi+","+port+")";
return msg ;