mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-22 18:35:35 +08:00
261 lines
10 KiB
PHP
261 lines
10 KiB
PHP
<?php
|
|
/**
|
|
* Copyright 2012-2026 ShopeX (https://www.shopex.cn)
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
class wms_eo{
|
|
/*
|
|
* 将采购单入库
|
|
* 采购单入库会分配货位，生成供应商商品采购价历史记录
|
|
* 更新库存
|
|
*/
|
|
|
|
function save_eo($data)
|
|
{
|
|
$basicMaterialLib = kernel::single('material_basic_material');
|
|
|
|
$oPo = app::get('purchase')->model("po");
|
|
$supplierObj = app::get('purchase')->model("supplier");
|
|
$oPo_items = app::get('purchase')->model("po_items");
|
|
|
|
$oEo = app::get('purchase')->model("eo");
|
|
$oEo_items = app::get('purchase')->model("eo_items");
|
|
$oCredit_sheet = app::get('purchase')->model("credit_sheet");
|
|
|
|
$oProduct_batch = app::get('purchase')->model("branch_product_batch");
|
|
$po_id = $data['po_id'];
|
|
$branch_id = $_POST['branch_id'] ? $_POST['branch_id'] : $data['branch_id'];
|
|
$Po = $oPo->dump($po_id,'*');
|
|
$supplier = $supplierObj->dump($Po['supplier_id'],'*');
|
|
$expire_bm_info = $data['expire_bm_info'];
|
|
|
|
$batchs = $this->processBatchs($branch_id,$expire_bm_info);
|
|
|
|
$amount=0;
|
|
//start入库
|
|
$history_data= array();
|
|
foreach($data['ids'] as $i){
|
|
$v = intval($data['entry_num'][$i]);
|
|
$k = $i;
|
|
$Po_items = $oPo_items->dump($k,'price,product_id,num,status,name,spec_info,bn');
|
|
|
|
$Products = $basicMaterialLib->getBasicMaterialExt($Po_items['product_id']);
|
|
|
|
$amount+=$v*$Po_items['price'];
|
|
$item_memo = $data['item_memo'][$k];
|
|
|
|
if($batchs[$Po_items['product_id']]){
|
|
$batch = array_values($batchs[$Po_items['product_id']]);
|
|
}
|
|
$eo_items[$Po_items['product_id']]=array(
|
|
'product_id' => $Po_items['product_id'],
|
|
'name' => $Po_items['name'],
|
|
'spec_info' => $Po_items['spec_info'],
|
|
'bn' => $Po_items['bn'],
|
|
'unit' => $Products['unit'],
|
|
'price' => $Po_items['price'],
|
|
'purchase_num' => $Po_items['num'],
|
|
'nums' => $v,
|
|
'is_new' => $data['is_new'][$k],
|
|
'memo' => $item_memo,
|
|
'batch'=>$batch,
|
|
);
|
|
|
|
//为供应商与商品建立关联
|
|
if($Po['supplier_id'] && $Products['bm_id']){
|
|
$supplier_goods = array(
|
|
'supplier_id' => $Po['supplier_id'],
|
|
'bm_id' => $Products['bm_id']
|
|
);
|
|
$su_goodsObj = app::get('purchase')->model('supplier_goods');
|
|
|
|
//关联关系不存在则插入
|
|
$supGoodsData = $su_goodsObj->getList('*', array('supplier_id'=>$Po['supplier_id'], 'bm_id'=>$Products['bm_id']), 0, 1);
|
|
if(empty($supGoodsData))
|
|
{
|
|
$su_goodsObj->save($supplier_goods);
|
|
}
|
|
}
|
|
|
|
$history_data[]=array('product_id'=>$Po_items['product_id'],'purchase_price'=>$Po_items['price'],'store'=>$v,'branch_id'=>$Po['branch_id']);
|
|
//更新采购单数量
|
|
$po_items_data[] = array(
|
|
'item_id'=>$k,
|
|
'in_num'=>$v,
|
|
'num'=>$v,
|
|
'status'=>$Po_items['status'],
|
|
'item_memo'=>addslashes($item_memo),
|
|
'product_id' => $Po_items['product_id']
|
|
);
|
|
}
|
|
|
|
//追加备注信息
|
|
$memo = array();
|
|
$op_name = kernel::single('desktop_user')->get_name();
|
|
$newmemo = htmlspecialchars($data['memo']);
|
|
$memo[] = array('op_name'=>$op_name, 'op_time'=>date('Y-m-d H:i',time()), 'op_content'=>$newmemo);
|
|
$memo = serialize($memo);
|
|
|
|
$iostock_instance = kernel::single('console_iostockorder');
|
|
$eo_data = array (
|
|
'iostockorder_name' => date('Ymd').'入库单',
|
|
'supplier' => $supplier['name'],
|
|
'supplier_id' => $Po['supplier_id'],
|
|
'branch' => $Po['branch_id'],
|
|
'bill_type'=>'po',
|
|
'type_id' => siso_receipt_iostock::PURCH_STORAGE,
|
|
'iso_price' => $Po['delivery_cost'],
|
|
'memo' => $newmemo,
|
|
'operator' => $data['operator'],
|
|
'products' => $eo_items,
|
|
'original_bn' => $Po['po_bn'],
|
|
'original_id' => $po_id,
|
|
'business_bn'=>$Po['po_bn'],
|
|
'confirm' => 'Y',
|
|
'po_type' => $Po['po_type'],
|
|
'arrival_no' => $data['arrival_no'],
|
|
);
|
|
if ( method_exists($iostock_instance, 'save_iostockorder') ){
|
|
$eo_data['eo_id'] = $iostock_instance->save_iostockorder($eo_data, $msg);
|
|
$eo_data['eo_bn'] = $iostock_instance->getIoStockOrderBn();
|
|
}
|
|
|
|
//日志备注
|
|
$log_msg = '对编号为（'.$Po['po_bn'].'）的采购单进行采购入库，生成一张入库单编号为:'.$eo_data['eo_bn'];
|
|
|
|
//更新采购单状态
|
|
foreach($po_items_data as $ke=>$va){
|
|
$oPo->db->exec('UPDATE sdb_purchase_po_items SET in_num=IFNULL(in_num,0)+'.$va['in_num'].' WHERE item_id='.$va['item_id']);
|
|
//更新对应状态
|
|
$new_Po_items = $oPo_items->dump($va['item_id'],'in_num,out_num,num');
|
|
$status = 1;
|
|
if($new_Po_items['num']>$new_Po_items['in_num']+$new_Po_items['out_num']){
|
|
$status = 2;
|
|
}else if($new_Po_items['num']==$new_Po_items['in_num']+$new_Po_items['out_num']){
|
|
$status=3;
|
|
}
|
|
if ($va['item_memo']) $update_memo = ",memo='".$va['item_memo']."'";
|
|
$oPo->db->exec(" UPDATE `sdb_purchase_po_items` SET `status`='".$status."'$update_memo WHERE item_id='".$va['item_id']."'");
|
|
}
|
|
$storeManageLib = kernel::single('ome_store_manage');
|
|
$storeManageLib->loadBranch(array('branch_id' => $branch_id));
|
|
$params = array();
|
|
$params['node_type'] = 'changeArriveStore';
|
|
$params['params'] = array(
|
|
'obj_id' => $po_id,
|
|
'branch_id' => $branch_id,
|
|
'obj_type' => 'purchase',
|
|
'operator' => '-'
|
|
);
|
|
$params['params']['items'] = $po_items_data;
|
|
$storeManageLib->processBranchStore($params, $err_msg);
|
|
//保存入库单
|
|
$eorder_data = array(
|
|
'eo_id' => $eo_data['eo_id'],
|
|
'supplier_id' => $eo_data['supplier_id'],
|
|
'eo_bn' => $eo_data['eo_bn'],
|
|
'po_id' => $po_id,
|
|
'amount' => $amount,
|
|
'entry_time' => time(),
|
|
'arrive_time' => $Po['arrive_time'],
|
|
'operator' => kernel::single('desktop_user')->get_name(),
|
|
'branch_id' => $branch_id,
|
|
'status' => $status,
|
|
|
|
);
|
|
$oEo->save($eorder_data);
|
|
$new_Po = $oPo->db->selectrow('SELECT SUM(num) as total_num,SUM(in_num) as total_in_num,SUM(out_num) AS total_out_num FROM sdb_purchase_po_items WHERE po_id='.$po_id);
|
|
if($new_Po['total_num']>$new_Po['total_in_num']+$new_Po['total_out_num']){
|
|
$po_data['eo_status'] =2;
|
|
}else{
|
|
$po_data['eo_status'] =3;
|
|
if ($Po['po_status']==1){
|
|
$po_data['po_status'] =4;
|
|
}
|
|
//取消在途
|
|
$storeManageLib = kernel::single('ome_store_manage');
|
|
$storeManageLib->loadBranch(array('branch_id' => $branch_id));
|
|
$params = array();
|
|
$params['node_type'] = 'deleteArriveStore';
|
|
$params['params'] = array(
|
|
'obj_id' => $po_id,
|
|
'branch_id' => $branch_id,
|
|
'obj_type' => 'purchase',
|
|
);
|
|
$storeManageLib->processBranchStore($params, $err_msg);
|
|
}
|
|
$po_data['po_id'] =$po_id;
|
|
$oPo->save($po_data);
|
|
|
|
|
|
|
|
//供应商商品采购价历史记录
|
|
foreach($history_data as $k2=>$v2){
|
|
|
|
$v2['supplier_id']=$eo_data['supplier_id'];
|
|
$v2['eo_id'] =$eo_data['eo_id'];
|
|
$v2['eo_bn'] =$eo_data['eo_bn'];
|
|
$v2['purchase_time']=time();
|
|
$v2['in_num'] = $v2['store'];
|
|
$oProduct_batch->save($v2);
|
|
}
|
|
//--采购入库日志记录
|
|
|
|
$log_msg .= '<br/>生成了供应商商品采购历史价格记录表';
|
|
$opObj = app::get('ome')->model('operation_log');
|
|
$opObj->write_log('purchase_storage@purchase', $po_id, $log_msg);
|
|
|
|
return $eo_data['eo_id'];
|
|
|
|
}
|
|
|
|
|
|
/**
|
|
* 处理Batchs
|
|
* @param mixed $branch_id ID
|
|
* @param mixed $expire_bm_info expire_bm_info
|
|
* @return mixed 返回值
|
|
*/
|
|
public function processBatchs($branch_id,$expire_bm_info){
|
|
$batchs = [];
|
|
|
|
$iostockLib = kernel::single('wms_event_trigger_otherinstorage');
|
|
foreach($expire_bm_info as $v){
|
|
|
|
$v= json_decode($v,true);
|
|
|
|
foreach($v as $vv){
|
|
$expire_bn = $vv['expire_bn'];
|
|
$storagelife = $iostockLib->getlifedetail($branch_id,$vv['bm_id'],$expire_bn);
|
|
$batchs[$vv['bm_id']][$vv['expire_bn']] = array(
|
|
|
|
'purchase_code' => $vv['expire_bn'],
|
|
|
|
'product_time' => strtotime($vv['production_date']),
|
|
'expire_time' => $storagelife['expiring_date'],
|
|
'normal_defective' => 'normal',
|
|
'num' => $vv['in_num'],
|
|
|
|
);
|
|
|
|
|
|
}
|
|
}
|
|
return $batchs;
|
|
|
|
|
|
}
|
|
}
|