[Hardware] Added userid to everything that has to do with hardware.

这个提交包含在:
Andreas 2021-09-20 15:03:35 +02:00
父节点 109683e041
当前提交 586bc969fa
共有 3 个文件被更改,包括 47 次插入25 次删除

查看文件

@ -22,7 +22,7 @@ $config['migration_enabled'] = TRUE;
|
*/
$config['migration_version'] = 75;
$config['migration_version'] = 77;
/*
|--------------------------------------------------------------------------

查看文件

@ -0,0 +1,20 @@
<?php
defined('BASEPATH') OR exit('No direct script access allowed');
class Migration_add_userid_to_hardware extends CI_Migration {
public function up()
{
$fields = array(
'user_id BIGINT(20) DEFAULT NULL',
);
$this->dbforge->add_column('cat', $fields);
}
public function down()
{
$this->dbforge->drop_column('cat', 'user_id');
}
}

查看文件

@ -9,10 +9,11 @@
}
function update($result) {
$this->db->where('radio', $result['radio']);
$this->db->where('radio', $result['radio']);
$this->db->where('user_id', $this->session->userdata('user_id'));
$query = $this->db->get('cat');
if ($query->num_rows() > 0)
{
if($result['radio'] == "SatPC32") {
@ -20,7 +21,7 @@
foreach ($query->result() as $row)
{
$radio_id = $row->id;
$data = array(
'sat_name' => $result['sat_name'],
'downlink_freq' => $result['downlink_freq'],
@ -30,14 +31,15 @@
);
$this->db->where('id', $radio_id);
$this->db->update('cat', $data);
$this->db->where('user_id', $this->session->userdata('user_id'));
$this->db->update('cat', $data);
}
} else {
// Update the record
foreach ($query->result() as $row)
{
$radio_id = $row->id;
$data = array(
'frequency' => $result['frequency'],
'mode' => $result['mode'],
@ -45,12 +47,13 @@
);
$this->db->where('id', $radio_id);
$this->db->update('cat', $data);
$this->db->where('user_id', $this->session->userdata('user_id'));
$this->db->update('cat', $data);
}
}
} else {
// Add a new record
if($result['radio'] == "SatPC32") {
$data = array(
'radio' => $result['radio'],
@ -61,6 +64,7 @@
'uplink_freq' => $result['uplink_freq'],
'downlink_mode' => $result['downlink_mode'],
'uplink_mode' => $result['uplink_mode'],
'user_id' => $this->session->userdata('user_id'),
);
} else {
$data = array(
@ -68,23 +72,25 @@
'frequency' => $result['frequency'],
'mode' => $result['mode'],
'timestamp' => $result['timestamp'],
'user_id' => $this->session->userdata('user_id'),
);
}
$this->db->insert('cat', $data);
$this->db->insert('cat', $data);
}
}
function status() {
//$this->db->where('radio', $result['radio']);
//$this->db->where('radio', $result['radio']);
$this->db->where('user_id', $this->session->userdata('user_id'));
$query = $this->db->get('cat');
return $query;
}
function recent_status() {
$this->db->where('user_id', $this->session->userdata('user_id'));
$this->db->where("timestamp > date_sub(now(), interval 15 minute)", NULL, FALSE);
$query = $this->db->get('cat');
@ -94,27 +100,23 @@
/* Return list of radios */
function radios() {
$this->db->select('id, radio');
$this->db->where('user_id', $this->session->userdata('user_id'));
$query = $this->db->get('cat');
return $query;
}
function radio_status($id) {
return $this->db->query('SELECT *, CONVERT_TZ(`timestamp`, @@session.time_zone, \'+00:00\' ) as newtime FROM `cat` WHERE id = '.$id.' ');
$sql = 'SELECT *, CONVERT_TZ(`timestamp`, @@session.time_zone, \'+00:00\' ) as newtime FROM `cat` WHERE id = ' . $id . ' and user_id =' . $this->session->userdata('user_id');
return $this->db->query($sql);
}
function delete($id) {
$this->db->where('id', $id);
$this->db->delete('cat');
$this->db->where('user_id', $this->session->userdata('user_id'));
$this->db->delete('cat');
return true;
}
}
?>