mirror of
https://github.com/opensourcepos/opensourcepos.git
synced 2026-01-23 00:37:56 -05:00
269 lines
8.6 KiB
PHP
269 lines
8.6 KiB
PHP
<?php
|
|
class Receiving extends CI_Model
|
|
{
|
|
public function get_info($receiving_id)
|
|
{
|
|
$this->db->from('receivings');
|
|
$this->db->join('people', 'people.person_id = receivings.supplier_id', 'LEFT');
|
|
$this->db->where('receiving_id', $receiving_id);
|
|
|
|
return $this->db->get();
|
|
}
|
|
|
|
/*
|
|
Gets total of invoice rows
|
|
*/
|
|
public function get_invoice_count()
|
|
{
|
|
$this->db->from('receivings');
|
|
$this->db->where('invoice_number IS NOT NULL');
|
|
|
|
return $this->db->count_all_results();
|
|
}
|
|
|
|
public function get_receiving_by_invoice_number($invoice_number)
|
|
{
|
|
$this->db->from('receivings');
|
|
$this->db->where('invoice_number', $invoice_number);
|
|
|
|
return $this->db->get();
|
|
}
|
|
|
|
public function get_invoice_number_for_year($year = '', $start_from = 0)
|
|
{
|
|
$year = $year == '' ? date('Y') : $year;
|
|
$this->db->select('COUNT( 1 ) AS invoice_number_year');
|
|
$this->db->from('receivings');
|
|
$this->db->where('DATE_FORMAT(receiving_time, "%Y" ) = ', $year);
|
|
$this->db->where('invoice_number IS NOT NULL');
|
|
$result = $this->db->get()->row_array();
|
|
|
|
return ($start_from + $result['invoice_number_year'] + 1);
|
|
}
|
|
|
|
public function exists($receiving_id)
|
|
{
|
|
$this->db->from('receivings');
|
|
$this->db->where('receiving_id',$receiving_id);
|
|
|
|
return ($this->db->get()->num_rows() == 1);
|
|
}
|
|
|
|
public function update($receiving_data, $receiving_id)
|
|
{
|
|
$this->db->where('receiving_id', $receiving_id);
|
|
|
|
return $this->db->update('receivings', $receiving_data);
|
|
}
|
|
|
|
public function save($items, $supplier_id, $employee_id, $comment, $invoice_number, $payment_type, $receiving_id = FALSE)
|
|
{
|
|
if(count($items) == 0)
|
|
{
|
|
return -1;
|
|
}
|
|
|
|
$receivings_data = array(
|
|
'supplier_id' => $this->Supplier->exists($supplier_id) ? $supplier_id : null,
|
|
'employee_id' => $employee_id,
|
|
'payment_type' => $payment_type,
|
|
'comment' => $comment,
|
|
'invoice_number' => $invoice_number
|
|
);
|
|
|
|
//Run these queries as a transaction, we want to make sure we do all or nothing
|
|
$this->db->trans_start();
|
|
|
|
$this->db->insert('receivings', $receivings_data);
|
|
$receiving_id = $this->db->insert_id();
|
|
|
|
foreach($items as $line=>$item)
|
|
{
|
|
$cur_item_info = $this->Item->get_info($item['item_id']);
|
|
|
|
$receivings_items_data = array(
|
|
'receiving_id'=>$receiving_id,
|
|
'item_id'=>$item['item_id'],
|
|
'line'=>$item['line'],
|
|
'description'=>$item['description'],
|
|
'serialnumber'=>$item['serialnumber'],
|
|
'quantity_purchased'=>$item['quantity'],
|
|
'receiving_quantity'=>$item['receiving_quantity'],
|
|
'discount_percent'=>$item['discount'],
|
|
'item_cost_price' => $cur_item_info->cost_price,
|
|
'item_unit_price'=>$item['price'],
|
|
'item_location'=>$item['item_location']
|
|
);
|
|
|
|
$this->db->insert('receivings_items', $receivings_items_data);
|
|
|
|
$items_received = $item['receiving_quantity'] != 0 ? $item['quantity'] * $item['receiving_quantity'] : $item['quantity'];
|
|
|
|
// update cost price, if changed AND is set in config as wanted
|
|
if($cur_item_info->cost_price != $item['price'] AND $this->config->item('receiving_calculate_average_price') != FALSE)
|
|
{
|
|
$this->Item->change_cost_price($item['item_id'],
|
|
$items_received,
|
|
$item['price'],
|
|
$cur_item_info->cost_price);
|
|
}
|
|
|
|
//Update stock quantity
|
|
$item_quantity = $this->Item_quantity->get_item_quantity($item['item_id'], $item['item_location']);
|
|
$this->Item_quantity->save(array('quantity'=>$item_quantity->quantity + $items_received,
|
|
'item_id'=>$item['item_id'],
|
|
'location_id'=>$item['item_location']), $item['item_id'], $item['item_location']);
|
|
|
|
$recv_remarks ='RECV '.$receiving_id;
|
|
$inv_data = array(
|
|
'trans_date'=>date('Y-m-d H:i:s'),
|
|
'trans_items'=>$item['item_id'],
|
|
'trans_user'=>$employee_id,
|
|
'trans_location'=>$item['item_location'],
|
|
'trans_comment'=>$recv_remarks,
|
|
'trans_inventory'=>$items_received
|
|
);
|
|
|
|
$this->Inventory->insert($inv_data);
|
|
|
|
$supplier = $this->Supplier->get_info($supplier_id);
|
|
}
|
|
|
|
$this->db->trans_complete();
|
|
|
|
if($this->db->trans_status() === FALSE)
|
|
{
|
|
return -1;
|
|
}
|
|
|
|
return $receiving_id;
|
|
}
|
|
|
|
public function delete_list($receiving_ids, $employee_id, $update_inventory = TRUE)
|
|
{
|
|
$success = TRUE;
|
|
|
|
// start a transaction to assure data integrity
|
|
$this->db->trans_start();
|
|
|
|
foreach($receiving_ids as $receiving_id)
|
|
{
|
|
$success &= $this->delete($receiving_id, $employee_id, $update_inventory);
|
|
}
|
|
|
|
// execute transaction
|
|
$this->db->trans_complete();
|
|
|
|
$success &= $this->db->trans_status();
|
|
|
|
return $success;
|
|
}
|
|
|
|
public function delete($receiving_id, $employee_id, $update_inventory = TRUE)
|
|
{
|
|
// start a transaction to assure data integrity
|
|
$this->db->trans_start();
|
|
|
|
if($update_inventory)
|
|
{
|
|
// defect, not all item deletions will be undone??
|
|
// get array with all the items involved in the sale to update the inventory tracking
|
|
$items = $this->get_receiving_items($receiving_id)->result_array();
|
|
foreach($items as $item)
|
|
{
|
|
// create query to update inventory tracking
|
|
$inv_data = array(
|
|
'trans_date'=>date('Y-m-d H:i:s'),
|
|
'trans_items'=>$item['item_id'],
|
|
'trans_user'=>$employee_id,
|
|
'trans_comment'=>'Deleting receiving ' . $receiving_id,
|
|
'trans_location'=>$item['item_location'],
|
|
'trans_inventory'=>$item['quantity_purchased']*-1
|
|
);
|
|
// update inventory
|
|
$this->Inventory->insert($inv_data);
|
|
|
|
// update quantities
|
|
$this->Item_quantity->change_quantity($item['item_id'],
|
|
$item['item_location'],
|
|
$item['quantity_purchased']*-1);
|
|
}
|
|
}
|
|
|
|
// delete all items
|
|
$this->db->delete('receivings_items', array('receiving_id' => $receiving_id));
|
|
// delete sale itself
|
|
$this->db->delete('receivings', array('receiving_id' => $receiving_id));
|
|
|
|
// execute transaction
|
|
$this->db->trans_complete();
|
|
|
|
return $this->db->trans_status();
|
|
}
|
|
|
|
public function get_receiving_items($receiving_id)
|
|
{
|
|
$this->db->from('receivings_items');
|
|
$this->db->where('receiving_id', $receiving_id);
|
|
|
|
return $this->db->get();
|
|
}
|
|
|
|
public function get_supplier($receiving_id)
|
|
{
|
|
$this->db->from('receivings');
|
|
$this->db->where('receiving_id', $receiving_id);
|
|
|
|
return $this->Supplier->get_info($this->db->get()->row()->supplier_id);
|
|
}
|
|
|
|
public function invoice_number_exists($invoice_number, $receiving_id = '')
|
|
{
|
|
$this->db->from('receivings');
|
|
$this->db->where('invoice_number', $invoice_number);
|
|
if(!empty($receiving_id))
|
|
{
|
|
$this->db->where('receiving_id !=', $receiving_id);
|
|
}
|
|
$query = $this->db->get();
|
|
|
|
return ($query->num_rows() == 1);
|
|
}
|
|
|
|
/*
|
|
We create a temp table that allows us to do easy report/receiving queries
|
|
*/
|
|
public function create_receivings_items_temp_table()
|
|
{
|
|
$this->db->query("CREATE TEMPORARY TABLE IF NOT EXISTS " . $this->db->dbprefix('receivings_items_temp') . "
|
|
(SELECT
|
|
date(receiving_time) AS receiving_date,
|
|
" . $this->db->dbprefix('receivings_items') . " . receiving_id,
|
|
comment,
|
|
item_location,
|
|
invoice_number,
|
|
payment_type,
|
|
employee_id,
|
|
" . $this->db->dbprefix('items') . " . item_id,
|
|
" . $this->db->dbprefix('receivings') . " . supplier_id,
|
|
quantity_purchased,
|
|
" . $this->db->dbprefix('receivings_items') . " . receiving_quantity,
|
|
item_cost_price,
|
|
item_unit_price,
|
|
discount_percent,
|
|
(item_unit_price * quantity_purchased - item_unit_price * quantity_purchased * discount_percent / 100) AS subtotal,
|
|
" . $this->db->dbprefix('receivings_items') . " . line AS line,
|
|
serialnumber,
|
|
" . $this->db->dbprefix('receivings_items') . " . description AS description,
|
|
(item_unit_price * quantity_purchased - item_unit_price * quantity_purchased * discount_percent / 100) AS total,
|
|
(item_unit_price * quantity_purchased - item_unit_price * quantity_purchased * discount_percent / 100) - (item_cost_price * quantity_purchased) AS profit,
|
|
(item_cost_price * quantity_purchased) AS cost
|
|
FROM " . $this->db->dbprefix('receivings_items') . "
|
|
INNER JOIN " . $this->db->dbprefix('receivings') . " ON " . $this->db->dbprefix('receivings_items') . '.receiving_id=' . $this->db->dbprefix('receivings') . '.receiving_id' . "
|
|
INNER JOIN " . $this->db->dbprefix('items') . " ON " . $this->db->dbprefix('receivings_items') . '.item_id=' . $this->db->dbprefix('items') . '.item_id' . "
|
|
GROUP BY receiving_id, item_id, line)"
|
|
);
|
|
}
|
|
}
|
|
?>
|