Cleanups in ui_msgs.inc and inventory_db.inc
[fa-stable.git] / includes / db / inventory_db.inc
1 <?php
2 /**********************************************************************
3     Copyright (C) FrontAccounting, LLC.
4         Released under the terms of the GNU General Public License, GPL, 
5         as published by the Free Software Foundation, either version 3 
6         of the License, or (at your option) any later version.
7     This program is distributed in the hope that it will be useful,
8     but WITHOUT ANY WARRANTY; without even the implied warranty of
9     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  
10     See the License here <http://www.gnu.org/licenses/gpl-3.0.html>.
11 ***********************************************************************/
12 function get_qoh_on_date($stock_id, $location=null, $date_=null, $exclude=0)
13 {
14     if ($date_ == null)
15     {
16         $sql = "SELECT SUM(qty) FROM ".TB_PREF."stock_moves
17             WHERE stock_id=".db_escape($stock_id);
18         $date_ = Today();
19         $date = date2sql($date_);
20     }
21     else
22     {
23         $date = date2sql($date_);
24         $sql = "SELECT SUM(qty) FROM ".TB_PREF."stock_moves
25             WHERE stock_id=".db_escape($stock_id)."
26             AND tran_date <= '$date'"; 
27     }
28         
29     if ($location != null)
30         $sql .= " AND loc_code = ".db_escape($location);
31
32     $result = db_query($sql, "QOH calulcation failed");
33
34     $myrow = db_fetch_row($result);
35     if ($exclude > 0)
36     {
37         $sql = "SELECT SUM(qty) FROM ".TB_PREF."stock_moves
38             WHERE stock_id=".db_escape($stock_id)
39             ." AND type=".db_escape($exclude)
40             ." AND tran_date = '$date'";
41
42         $result = db_query($sql, "QOH calulcation failed");
43         $myrow2 = db_fetch_row($result);
44         if ($myrow2 !== false)
45             $myrow[0] -= $myrow2[0];
46     }
47
48     return $myrow[0];
49 }
50
51 //--------------------------------------------------------------------------------------
52
53 function get_item_edit_info($stock_id)
54 {
55         $sql = "SELECT material_cost + labour_cost + overhead_cost AS standard_cost, units, decimals
56                 FROM ".TB_PREF."stock_master,".TB_PREF."item_units
57                 WHERE stock_id=".db_escape($stock_id)
58                 ." AND ".TB_PREF."stock_master.units=".TB_PREF."item_units.abbr";
59         $result = db_query($sql, "The standard cost cannot be retrieved");
60
61         return db_fetch($result);
62 }
63
64 //--------------------------------------------------------------------------------------
65
66 function get_standard_cost($stock_id)
67 {
68         //Chaitanya : Compatibility with service items
69         $sql = "SELECT (material_cost + labour_cost + overhead_cost) AS std_cost
70                 FROM ".TB_PREF."stock_master s WHERE stock_id=".db_escape($stock_id);
71         $result = db_query($sql, "The standard cost cannot be retrieved");
72
73         $myrow = db_fetch_row($result);
74
75         return $myrow[0];
76 }
77
78 //--------------------------------------------------------------------------------------
79
80 function is_inventory_item($stock_id)
81 {
82         $sql = "SELECT stock_id FROM ".TB_PREF."stock_master
83                 WHERE stock_id=".db_escape($stock_id)." AND mb_flag <> 'D'";
84         $result = db_query($sql, "Cannot query is inventory item or not");
85
86         return db_num_rows($result) > 0;
87 }
88
89 //-------------------------------------------------------------------
90
91 function last_negative_stock_begin_date($stock_id, $to)
92 {
93         $to = date2sql($to);
94         $sql ="SET @q = 0";
95         db_query($sql);
96         $sql = "SET @flag = 0";
97         db_query($sql);
98         $sql = "SELECT SUM(qty), @q:= @q + qty, IF(@q < 0 AND @flag=0, @flag:=1,@flag:=0), IF(@q < 0 AND @flag=1, tran_date,'') AS begin_date 
99                 FROM ".TB_PREF."stock_moves
100                 WHERE stock_id=".db_escape($stock_id)." AND tran_date<='$to' 
101                 AND qty <> 0
102                 GROUP BY stock_id ORDER BY tran_date";
103
104         $result = db_query($sql, "The dstock moves could not be retrieved");
105         $row = db_fetch_row($result);
106         return $row[3];
107 }
108
109 //-------------------------------------------------------------------
110
111 function get_already_delivered($stock_id, $location, $trans_no)
112 {
113         $sql = "SELECT ".TB_PREF."stock_moves.qty
114                 FROM ".TB_PREF."stock_moves
115                 WHERE ".TB_PREF."stock_moves.stock_id = ".db_escape($stock_id)."
116                 AND ".TB_PREF."stock_moves.loc_code = ".db_escape($location)."
117                 AND type=".ST_CUSTDELIVERY." AND trans_no=".db_escape($trans_no);
118         $result = db_query($sql, "Could not get stock moves");
119         $row = db_fetch_row($result);
120         return $row[0];
121 }
122
123 function last_negative_stock_trans_id($stock_id, $to)
124 {
125         $sql = "SELECT * from ".TB_PREF."stock_moves
126                 WHERE stock_id=".db_escape($stock_id)." 
127                 AND qty <> 0 order by trans_id asc";
128         
129         $result = db_query($sql, "The query on stock moves failed.");
130         
131         $qty = 0;
132         $flag = 0;
133         $negative_trans_id = 1;
134         
135         while ($myrow = db_fetch($result))
136         {
137                 $qty += $myrow['qty'];
138                 if ($qty < 0 && $flag == 0)
139                 {
140                         $flag = 1;
141                         $negative_trans_id = $myrow['trans_id'];
142                 }
143                 if ($qty >= 0)
144                         $flag = 0;      
145         }
146                 
147         return $negative_trans_id;
148 }
149
150 //-------------------------------------------------------------------
151
152 function get_deliveries_between($stock_id, $from, $to)
153 {
154         $from = date2sql($from);
155         $to = date2sql($to);
156         $sql = "SELECT SUM(-qty), SUM(-qty*standard_cost) FROM ".TB_PREF."stock_moves
157                 WHERE type=".ST_CUSTDELIVERY." AND stock_id=".db_escape($stock_id)." AND
158                         tran_date>='$from' AND tran_date<='$to' GROUP BY stock_id";
159
160         $result = db_query($sql, "The deliveries could not be updated");
161         return db_fetch_row($result);
162 }
163
164 function get_deliveries_from_trans($stock_id, $from)
165 {
166         // -ve qty is delivery either by ST_CUSTDELIVERY or inventory adjustment
167         $sql = "SELECT SUM(-qty), SUM(-qty*standard_cost) FROM ".TB_PREF."stock_moves
168                 WHERE stock_id=".db_escape($stock_id)." AND qty < 0 AND
169                         trans_id>='$from' GROUP BY stock_id";
170         $result = db_query($sql, "The deliveries could not be updated");
171         $row = db_fetch_row($result);
172         
173         //return $row;
174         
175         // Get Std cost of previsous transaction before the cut-over delivery
176         // This is useful to get inventory valuation
177         //Chaitanya : Corrected
178         /*$sql = "SELECT max( `trans_id` )
179                         FROM ".TB_PREF."stock_moves
180                         WHERE stock_id = ".db_escape($stock_id)."
181                         AND trans_id<'$from'";
182         $result = db_query($sql, "The deliveries could not be updated");
183         $trans = db_fetch_row($result);
184         $prev_trans = $trans[0];*/
185         
186         $sql = "SELECT standard_cost FROM ".TB_PREF."stock_moves
187                 WHERE stock_id=".db_escape($stock_id)
188                         ." AND trans_id ='$from'";
189         $result = db_query($sql, "The deliveries could not be updated");
190         $cost = db_fetch_row($result);  
191         
192         // Adjusting QOH valuation 
193         $sql = "SELECT SUM(qty) FROM ".TB_PREF."stock_moves
194                 WHERE stock_id=".db_escape($stock_id)." AND
195                         trans_id<'$from' GROUP BY stock_id";
196         $result = db_query($sql, "The deliveries could not be updated");
197         $qoh = db_fetch_row($result);
198         
199         $qty = $row[0] - $qoh[0]; //Qoh is minus from delivered in -ve
200         $final_cost = $row[1] - $qoh[0]*$cost[0];
201         
202         return array($qty,$final_cost); 
203 }
204
205 function get_purchases_from_trans($stock_id, $from)
206 {
207         // Calculate All inward stock moves i.e. qty > 0
208         $sql = "SELECT SUM(qty), SUM(qty*standard_cost) FROM ".TB_PREF."stock_moves
209                 WHERE stock_id=".db_escape($stock_id)." AND qty > 0 AND 
210                         trans_id>'$from' GROUP BY stock_id";
211         $result = db_query($sql, "Could not get get_purchases_from_trans");
212         $row = db_fetch_row($result);
213         
214         return $row;
215 }
216
217 //-------------------------------------------------------------------
218 /* Original Code V0 Leave as is a while
219 function adjust_deliveries_v0($stock_id, $material_cost, $to)
220 {
221         if (!is_inventory_item($stock_id))
222                 return;
223         $from = last_negative_stock_begin_date($stock_id, $to);
224         if ($from == false || $from == "")
225                 return;
226         $from = sql2date($from);
227         $row = get_deliveries_between($stock_id, $from, $to);
228         if ($row == false)
229                 return; 
230         $old_cost = $row[1];
231         $new_cost = $row[0] * $material_cost;
232         $diff = $new_cost - $old_cost;
233         if ($diff != 0)
234         {
235                 $update_no = get_next_trans_no(ST_COSTUPDATE);
236                 if (!is_date_in_fiscalyear($to))
237                         $to = end_fiscalyear();
238            
239                 $stock_gl_code = get_stock_gl_code($stock_id);
240
241                 $memo_ = sprintf(_("Cost was %s changed to %s for item '%s'"),
242                         $old_cost, $new_cost, $stock_id);
243                 add_gl_trans_std_cost(ST_COSTUPDATE, $update_no, $to, $stock_gl_code["cogs_account"], 
244                         $stock_gl_code["dimension_id"], $stock_gl_code["dimension2_id"], $memo_, $diff);
245
246                 add_gl_trans_std_cost(ST_COSTUPDATE, $update_no, $to, $stock_gl_code["inventory_account"], 
247                         0, 0, $memo_, -$diff);
248                 add_audit_trail(ST_COSTUPDATE, $update_no, $to);
249         }
250 }
251 */
252 //New written function
253 function adjust_deliveries($stock_id, $material_cost, $to)
254 {
255         if (!is_inventory_item($stock_id))
256                 return;
257         
258         $from = last_negative_stock_trans_id($stock_id, $to);
259         if ($from == false || $from == "")
260                 return;
261
262         $row = get_deliveries_from_trans($stock_id, $from);
263                 
264         if ($row == false)
265                 return; 
266         $old_sales_cost = $row[1];
267         $new_sales_cost = $row[0] * $material_cost;
268         $sales_diff = $new_sales_cost - $old_sales_cost;
269         
270         $row = get_purchases_from_trans($stock_id, $from);
271         $purchase_diff = 0;
272         $old_purchase_cost = 0;
273         if ($row != false)
274         {
275                 $old_purchase_cost = $row[1];
276                 $new_purchase_cost = $row[0] * $material_cost;
277                 $purchase_diff = $new_purchase_cost - $old_purchase_cost;
278         }
279         
280         $diff =  $sales_diff - $purchase_diff;
281         
282         if ($diff != 0)
283         {
284                 $update_no = get_next_trans_no(ST_COSTUPDATE);
285                 if (!is_date_in_fiscalyear($to))
286                         $to = end_fiscalyear();
287            
288                 $stock_gl_code = get_stock_gl_code($stock_id);
289
290                 $dec = user_price_dec();
291                 $old_cost = -round2($old_sales_cost-$old_purchase_cost,$dec);
292                 $new_cost = -round2($new_sales_cost-$new_purchase_cost,$dec);
293                 
294                 $memo_ = _("Cost was ") . $old_cost. _(" changed to ") . $new_cost . _(" for item ")."'$stock_id'";
295                 add_gl_trans_std_cost(ST_COSTUPDATE, $update_no, $to, $stock_gl_code["cogs_account"], 
296                         $stock_gl_code["dimension_id"], $stock_gl_code["dimension2_id"], $memo_, $diff);           
297
298                 add_gl_trans_std_cost(ST_COSTUPDATE, $update_no, $to, $stock_gl_code["inventory_account"], 0, 0, $memo_, 
299                         -$diff);
300                 add_audit_trail(ST_COSTUPDATE, $update_no, $to);
301         }
302 }
303
304 function get_stock_gl_code($stock_id)
305 {
306         /*Gets the GL Codes relevant to the item account  */
307         //Chaitanya : Updated to also provide mb_flag
308         $sql = "SELECT mb_flag, inventory_account, cogs_account,
309                 adjustment_account, sales_account, assembly_account, dimension_id, dimension2_id FROM
310                 ".TB_PREF."stock_master WHERE stock_id = ".db_escape($stock_id);
311
312         $get = db_query($sql,"retreive stock gl code");
313         return db_fetch($get);
314 }
315
316 //-----------------------------------------------------------------------------------------
317 //Chaitanya : New Function handle negative stock effect
318 //Called in add_stock_move
319 function handle_negative_inventory($stock_id, $quantity, $standard_cost, $date_)
320 {
321         //Chaitanya : If negative adjustment result in negative or zero inventory 
322         //then difference should be adjusted
323         $qoh = get_qoh_on_date($stock_id);
324
325         if ($qoh + $quantity <= 0 && $qoh > 0) //Positive inventory turning zero/negative
326         {
327                 global $Refs;
328
329                 $id = get_next_trans_no(ST_JOURNAL);
330                 $ref = $Refs->get_next(ST_JOURNAL);
331                 $diff = get_standard_cost($stock_id) - $standard_cost;
332                 
333                 if ($diff !=0)
334                 {
335                         $stock_gl_code = get_stock_gl_code($stock_id);
336                         $memo = _("Zero/negative inventory handling");
337                         //Reverse the inventory effect if $qoh <=0
338                         add_gl_trans_std_cost(ST_JOURNAL, $id, $date_, 
339                                 $stock_gl_code["inventory_account"],
340                                 $stock_gl_code['dimension_id'], $stock_gl_code['dimension2_id'], $memo, 
341                                 -$qoh * $diff);
342                         //GL Posting to inventory adjustment account
343                         add_gl_trans_std_cost(ST_JOURNAL, $id, $date_, 
344                                 $stock_gl_code["adjustment_account"],
345                                 $stock_gl_code['dimension_id'], $stock_gl_code['dimension2_id'], $memo,
346                                 $qoh * $diff);
347                                 
348                         add_audit_trail(ST_JOURNAL, $id, $date_);
349                         add_comments(ST_JOURNAL, $id, $date_, $memo);
350                         $Refs->save(ST_JOURNAL, $id, $ref);     
351                 }
352         }
353 }
354
355 //--------------------------------------------------------------------------------------
356
357 // $date_ - display / non-sql date
358 // $std_cost - in HOME currency
359 // $show_or_hide - wil this move be visible in reports, etc
360 // $price - in $person_id's currency
361
362 function add_stock_move($type, $stock_id, $trans_no, $location,
363     $date_, $reference, $quantity, $std_cost, $person_id=0, $show_or_hide=1,
364     $price=0, $discount_percent=0, $error_msg="")
365 {
366         // Chaitanya : Removed following restriction considering WO issues
367         // Voiding issues and productions with Service items can not get the 
368         // Service items compatibility
369         // do not add a stock move if it's a non-inventory item
370         //if (!is_inventory_item($stock_id))
371                 //return null;
372
373         $date = date2sql($date_);
374
375         $sql = "INSERT INTO ".TB_PREF."stock_moves (stock_id, trans_no, type, loc_code,
376                 tran_date, person_id, reference, qty, standard_cost, visible, price,
377                 discount_percent) VALUES (".db_escape($stock_id)
378                 .", ".db_escape($trans_no).", ".db_escape($type)
379                 .",     ".db_escape($location).", '$date', "
380                 .db_escape($person_id).", ".db_escape($reference).", "
381                 .db_escape($quantity).", ".db_escape($std_cost).","
382                 .db_escape($show_or_hide).", "
383                 .db_escape($price).", ".db_escape($discount_percent).")";
384
385         if ($error_msg == "")
386                 $error_msg = "The stock movement record cannot be inserted";
387
388         db_query($sql, $error_msg);
389
390         return db_insert_id();
391 }
392
393 //Chaitanya : Added function
394 function update_stock_move($type, $trans_no, $stock_id, $cost)
395 {
396         $sql = "UPDATE ".TB_PREF."stock_moves SET standard_cost=".db_escape($cost)
397                         ." WHERE type=".db_escape($type)
398                         ."      AND trans_no=".db_escape($trans_no)
399                         ."      AND stock_id=".db_escape($stock_id);
400         db_query($sql, "The stock movement standard_cost cannot be updated");
401 }
402
403 function update_stock_move_pid($type, $type_no, $stock_id, $pid, $cost)
404 {
405         $sql = "UPDATE ".TB_PREF."stock_moves SET standard_cost=".db_escape($cost)
406                 ." WHERE type=".db_escape($type)
407                 ."      AND trans_no=".db_escape($type_no)
408                 ."      AND stock_id=".db_escape($stock_id)
409                 ."  AND person_id = ".db_escape($pid);
410         db_query($sql, "The stock movement standard_cost cannot be updated");
411 }
412
413 //--------------------------------------------------------------------------------------------------
414
415 function get_stock_moves($type, $type_no, $visible=false)
416 {
417         $sql = "SELECT ".TB_PREF."stock_moves.*, ".TB_PREF."stock_master.description, "
418                 .TB_PREF."stock_master.units,".TB_PREF."locations.location_name,"
419                 .TB_PREF."stock_master.material_cost + "
420                         .TB_PREF."stock_master.labour_cost + "
421                         .TB_PREF."stock_master.overhead_cost AS FixedStandardCost
422                 FROM ".TB_PREF."stock_moves,".TB_PREF."locations,".TB_PREF."stock_master
423                 WHERE ".TB_PREF."stock_moves.stock_id = ".TB_PREF."stock_master.stock_id
424                 AND ".TB_PREF."locations.loc_code=".TB_PREF."stock_moves.loc_code
425                 AND type=".db_escape($type)." AND trans_no=".db_escape($type_no)." ORDER BY trans_id";
426         if ($visible)
427                 $sql .= " AND ".TB_PREF."stock_moves.visible=1";
428
429         return db_query($sql, "Could not get stock moves");
430 }
431
432 //--------------------------------------------------------------------------------------------------
433
434 function void_stock_move($type, $type_no)
435 {
436     //Chaitanya : Reversing stock move rather than voiding as it is hazardous to lose stock movement trail with respect to costing
437     /*$sql = "UPDATE ".TB_PREF."stock_moves SET qty=0, price=0, discount_percent=0,
438         standard_cost=0 WHERE type=".db_escape($type)." AND trans_no=".db_escape($type_no);
439         
440     db_query($sql, "Could not void stock moves"); */
441     
442     $sql = "SELECT * from ".TB_PREF."stock_moves WHERE type=".db_escape($type)." AND trans_no=".db_escape($type_no);
443     $result = db_query($sql, "Could not void stock moves");
444     while ($row = db_fetch($result))
445     {
446                 //Skip cost averaging of service items
447                 if (is_inventory_item($row["stock_id"]))
448                 {        
449                         // The cost has to be adjusted.
450                         //Chaitanya : Transaction rates are stored either as price or standard_cost depending
451                         //on types
452                         $types = array(ST_SUPPCREDIT);
453                         if (in_array($type,$types))
454                                 $trans_rate = $row["price"];
455                         else
456                                 $trans_rate = $row["standard_cost"];
457
458                         update_average_material_cost(0, $row["stock_id"],
459                                 $trans_rate, -$row["qty"], sql2date($row["tran_date"]));
460                 }
461                 
462                 //Post stock move for service items also
463         add_stock_move($type, $row["stock_id"], $type_no, $row["loc_code"],
464                 sql2date($row["tran_date"]), $row["reference"], -$row["qty"]
465                         , $row["standard_cost"], $row["person_id"], $row["visible"],
466                 $row["price"], $row["discount_percent"]);
467     }
468 }
469
470 //--------------------------------------------------------------------------------------------------
471
472 function get_location_name($loc_code)
473 {
474         $sql = "SELECT location_name FROM ".TB_PREF."locations WHERE loc_code="
475                 .db_escape($loc_code);
476
477         $result = db_query($sql, "could not retreive the location name for $loc_code");
478
479         if (db_num_rows($result) == 1)
480         {
481                 $row = db_fetch_row($result);
482                 return $row[0];
483         }
484
485         display_db_error("could not retreive the location name for $loc_code", $sql, true);
486 }
487
488 //--------------------------------------------------------------------------------------------------
489
490
491 ?>