mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-22 18:35:35 +08:00
498 lines
20 KiB
PHP
498 lines
20 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 console_receipt_allocate
|
||
{
|
||
|
||
/**
|
||
* 保存调拔单出库数据
|
||
* 并冻结对应商品库存
|
||
*
|
||
*/
|
||
public function to_savestore($adata, $appropriation_type, $memo, $op_name, &$msg)
|
||
{
|
||
$oAppropriation = app::get('taoguanallocate')->model("appropriation");
|
||
$oAppropriation_items = app::get('taoguanallocate')->model("appropriation_items");
|
||
$pStockObj = kernel::single('console_stock_products');
|
||
|
||
$basicMaterialObj = app::get('material')->model('basic_material');
|
||
|
||
$oBranch = app::get('ome')->model("branch_product");
|
||
$op_name = $op_name == '' ? '未知' : $op_name;
|
||
$appro_data = array(
|
||
'type' => $appropriation['type'],
|
||
'create_time' => time(),
|
||
'operator_name' => $op_name,
|
||
'memo' => $memo,
|
||
'corp_id' => $adata[0]['corp_id'] ? $adata[0]['corp_id'] : 0,
|
||
'from_branch_id' => $adata[0]['from_branch_id'],
|
||
'to_branch_id' => $adata[0]['to_branch_id'],
|
||
);
|
||
|
||
$extrabranch = [];
|
||
if ($appro_data['to_branch_id']) {
|
||
$extrabranch = app::get('ome')->model('branch')->db_dump([
|
||
'branch_id' => $appro_data['to_branch_id'],
|
||
'check_permission' => false,
|
||
], 'branch_bn');
|
||
|
||
$appro_data['extrabranch_bn'] = $extrabranch['branch_bn'];
|
||
}
|
||
|
||
//新增原单据号
|
||
if($adata[0]['original_bn']){
|
||
$appro_data['original_bn'] = $adata[0]['original_bn'];
|
||
}
|
||
|
||
if($adata[0]['bill_type']){
|
||
$appro_data['bill_type'] = $adata[0]['bill_type'];
|
||
}
|
||
if($adata[0]['business_bn']){
|
||
$appro_data['business_bn'] = $adata[0]['business_bn'];
|
||
}
|
||
if($adata[0]['to_physics_id']){
|
||
$appro_data['to_physics_id'] = $adata[0]['to_physics_id'];
|
||
}
|
||
$appro_data['appropriation_no'] = $this->gen_appropriation_no();
|
||
$oAppropriation->save($appro_data);
|
||
|
||
$appropriation_id = $appro_data['appropriation_id'];
|
||
|
||
$is_flag = false;
|
||
foreach ($adata as $k => $v) {
|
||
|
||
//过滤数量是0的记录
|
||
if(empty($v['num'])){
|
||
continue;
|
||
}
|
||
|
||
//基础物料信息
|
||
$product = $basicMaterialObj->dump(array('bm_id' => $v['product_id']), 'bm_id, material_bn, material_name');
|
||
|
||
$from_branch_id = $v['from_branch_id'];
|
||
$to_branch_id = $v['to_branch_id'];
|
||
$add_store_data = array(
|
||
'pos_id' => $to_pos_id, 'product_id' => $v['product_id'], 'num' => $v['num'], 'branch_id' => $to_branch_id,
|
||
);
|
||
|
||
$lower_store_data = array(
|
||
'pos_id' => $from_pos_id, 'product_id' => $v['product_id'], 'num' => $v['num'], 'branch_id' => $from_branch_id);
|
||
|
||
$items_data = array(
|
||
'appropriation_id' => $appropriation_id,
|
||
'bn' => $product['material_bn'],
|
||
'product_name' => $product['material_name'],
|
||
'product_id' => $v['product_id'],
|
||
'from_branch_id' => $from_branch_id == '' ? 0 : $from_branch_id,
|
||
'from_pos_id' => $from_pos_id == '' ? 0 : $from_pos_id,
|
||
'to_branch_id' => $to_branch_id == '' ? 0 : $to_branch_id,
|
||
'to_pos_id' => $to_pos_id == '' ? 0 : $to_pos_id,
|
||
'num' => $v['num'],
|
||
'to_branch_num' => $v['to_branch_num'],
|
||
'from_branch_num' => $v['from_branch_num'],
|
||
);
|
||
$oAppropriation_items->save($items_data);
|
||
|
||
//标识
|
||
$is_flag = true;
|
||
}
|
||
|
||
//没有调拔单,直接返回
|
||
if($is_flag === false){
|
||
return false;
|
||
}
|
||
|
||
if ($appropriation_type == 1) {
|
||
//直接调拨
|
||
$result = $this->do_iostock($appropriation_id, $msg);
|
||
return $result;
|
||
} elseif ($appropriation_type == 2) {
|
||
//出入库调拨
|
||
$result = $this->do_out_iostockorder($appropriation_id, $msg);
|
||
return $result;
|
||
} else {
|
||
return false;
|
||
}
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 调拔单出库
|
||
* @param appropriation_id
|
||
* @param $msg
|
||
*/
|
||
public function do_out_iostockorder($appropriation_id, &$msg)
|
||
{
|
||
$basicMaterialObj = app::get('material')->model('basic_material');
|
||
$basicMaterialExtObj = app::get('material')->model('basic_material_ext');
|
||
|
||
#判断是否开启固定成本，如果开启，price等于商品成本价
|
||
$cost = false;
|
||
if (app::get('tgstockcost')->is_installed()) {
|
||
$tgstockcost = app::get("ome")->getConf("tgstockcost.cost");
|
||
if ($tgstockcost == 2) {
|
||
$cost = true;
|
||
}
|
||
}
|
||
$iostock_instance = kernel::service('ome.iostock');
|
||
$appitemObj = app::get('taoguanallocate')->model('appropriation_items');
|
||
|
||
$products = array();
|
||
$db = kernel::database();
|
||
$sql = 'SELECT * FROM `sdb_taoguanallocate_appropriation` WHERE `appropriation_id`=\'' . $appropriation_id . '\'';
|
||
$app_detail = $db->selectrow($sql);
|
||
$app_items_detail = $appitemObj->getList('*', array('appropriation_id' => $appropriation_id), 0, -1);
|
||
$branch_id = 0;
|
||
$to_branch_id = 0;
|
||
if ($app_items_detail) {
|
||
$items_detail = array();
|
||
foreach ($app_items_detail as $k => $v) {
|
||
if (!$branch_id) {
|
||
$branch_id = $v['from_branch_id'];
|
||
}
|
||
//虚拟仓累计成本
|
||
$costSetting = kernel::single('tgstockcost_system_setting')->getCostSetting();
|
||
$branchCost = false;
|
||
if ($costSetting['branch_cost']['value'] == '2') {
|
||
$branchCost = true;
|
||
$entityBranchProduct = $res = kernel::single('ome_entity_branch_product')->getBranchCountCostPrice($branch_id,$v['product_id'] );
|
||
}
|
||
if (!$to_branch_id) {
|
||
$to_branch_id = $v['to_branch_id'];
|
||
}
|
||
|
||
if ($cost) {
|
||
#如果已经开启固定成本，则获取商品的成本价
|
||
$product = $basicMaterialExtObj->dump(array('bm_id' => $v['product_id']), 'bm_id, retail_price, cost, unit');
|
||
} else {
|
||
#如果没有开启，则不需要获取成本价
|
||
$product = $basicMaterialExtObj->dump(array('bm_id' => $v['product_id']), 'bm_id, retail_price, unit');
|
||
|
||
#调拨出库时，获取对应的单位成本
|
||
$unit_cost = $db->selectRow('select unit_cost from sdb_ome_branch_product where branch_id=' . $branch_id . ' and product_id=' . $v['product_id']);
|
||
$product['cost'] = $unit_cost['unit_cost'];
|
||
|
||
//使用虚拟仓累计成本
|
||
if ($branchCost) {
|
||
$entityUnitCost = $entityBranchProduct[$branch_id][$v['product_id']]['unit_cost'];
|
||
$product['unit'] = isset($entityUnitCost) ? $entityUnitCost : $product['cost'];
|
||
$product['cost'] = isset($entityUnitCost) ? $entityUnitCost : $product['cost'];
|
||
}
|
||
}
|
||
|
||
$products[$v['product_id']] = array(
|
||
'unit' => $product['unit'],
|
||
'name' => $v['product_name'],
|
||
'bn' => $v['bn'],
|
||
'nums' => $v['num'],
|
||
'price' => $product['cost'] ? $product['cost'] : 0,
|
||
|
||
);
|
||
|
||
if($v['package_code']){
|
||
|
||
$extendpro = array('package_code'=>$v['package_code']);
|
||
$extendpro = serialize($extendpro);
|
||
$products[$v['product_id']]['items_detail'][] = array(
|
||
'product_id'=>$v['product_id'],
|
||
'unit' => $product['unit'],
|
||
'name' => $v['product_name'],
|
||
'bn' => $v['bn'],
|
||
'nums' => $v['num'],
|
||
'price' => $product['cost'] ? $product['cost'] : 0,
|
||
'extendpro'=>$extendpro,
|
||
'original_id' => $v['item_id'],
|
||
);
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
$extrabranch = [];
|
||
if ($to_branch_id) {
|
||
$extrabranch = app::get('ome')->model('branch')->db_dump([
|
||
'branch_id' => $to_branch_id,
|
||
'check_permission' => false,
|
||
], 'branch_bn');
|
||
}
|
||
|
||
$data = array(
|
||
'iostockorder_name' => date('Ymd') . '出库单',
|
||
'supplier' => '',
|
||
'supplier_id' => 0,
|
||
'branch' => $branch_id,
|
||
'extrabranch_id' => $to_branch_id,
|
||
'extrabranch_bn' => $extrabranch['branch_bn'],
|
||
'type_id' => 40,
|
||
'iso_price' => 0,
|
||
'memo' => $app_detail['memo'],
|
||
'operator' => kernel::single('desktop_user')->get_name(),
|
||
'original_bn' => '',
|
||
'original_id' => $appropriation_id,
|
||
'products' => $products,
|
||
'appropriation_no' => $app_detail['appropriation_no'],
|
||
'business_bn' => $app_detail['business_bn'] ? $app_detail['business_bn'] : $app_detail['appropriation_no'],
|
||
'physics_id' => $app_detail['from_physics_id'],
|
||
'logi_no' => $app_detail['logi_no'],
|
||
);
|
||
|
||
if($app_detail['extra_ship_area']){
|
||
$data['extra_ship_area'] = $app_detail['extra_ship_area'];
|
||
}
|
||
if($app_detail['extra_ship_addr']){
|
||
$data['extra_ship_addr'] = $app_detail['extra_ship_addr'];
|
||
}
|
||
if($app_detail['extra_ship_mobile']){
|
||
$data['extra_ship_mobile'] = $app_detail['extra_ship_mobile'];
|
||
}
|
||
if($app_detail['extra_ship_name']){
|
||
$data['extra_ship_name'] = $app_detail['extra_ship_name'];
|
||
}
|
||
|
||
//加判断 是否已存在
|
||
if($app_detail['appropriation_no']){
|
||
$isoMdl = app::get('taoguaniostockorder')->model('iso');
|
||
$isos = $isoMdl->db_dump(array('type_id'=>$data['type_id'],'appropriation_no'=>$data['appropriation_no']),'iso_id');
|
||
if($isos){
|
||
return false;
|
||
}
|
||
}
|
||
if($app_detail['source_from'] == 'pos' && $app_detail['bill_type'] == 'returnnormal'){
|
||
//门店退仓自动完成
|
||
$data['confirm'] = 'Y';
|
||
}
|
||
if($app_detail['bill_type'] == 'transfer') {
|
||
$data['check'] = 'Y';
|
||
}
|
||
if($app_detail['bill_type']){
|
||
$data['bill_type'] = $app_detail['bill_type'];
|
||
}
|
||
if ($app_detail['corp_id']) {
|
||
$data['corp_id'] = $app_detail['corp_id'];
|
||
}
|
||
|
||
$iostockorder_instance = kernel::single('console_iostockorder');
|
||
return $iostockorder_instance->save_iostockorder($data, $msg);
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 生成调拨单出入库明细
|
||
* @param $appropriation_id
|
||
* @param
|
||
* @param $msg
|
||
*/
|
||
public function do_iostock($appropriation_id, &$msg)
|
||
{
|
||
$allow_commit = false;
|
||
kernel::database()->beginTransaction();
|
||
|
||
//存储出入库记录
|
||
$iostock_data = $this->get_iostock_data($appropriation_id);
|
||
$out = array(); //调出
|
||
$in = array(); //调入
|
||
$out = $in = $iostock_data;
|
||
foreach ($iostock_data['items'] as $item_id => $iostock) {
|
||
$iostock['nums'] = abs($iostock['nums']);
|
||
$out['branch_id'] = $iostock['from_branch_id'];
|
||
$in['branch_id'] = $iostock['to_branch_id'];
|
||
|
||
}
|
||
if (count($out['items']) > 0) {
|
||
$stockoutLib = kernel::single('siso_receipt_iostock_stockout');
|
||
$stockoutLib->_typeId = 40;
|
||
if ($stockoutLib->create($out, $data, $msg)) {
|
||
$allow_commit = true;
|
||
}
|
||
|
||
}
|
||
if (count($in['items']) > 0 && $allow_commit) {
|
||
|
||
$stockinLib = kernel::single('siso_receipt_iostock_stockin');
|
||
$stockinLib->_typeId = 4;
|
||
if ($stockinLib->create($in, $data, $msg)) {
|
||
$allow_commit = true;
|
||
}
|
||
|
||
}
|
||
|
||
if ($allow_commit == true) {
|
||
kernel::database()->commit();
|
||
return true;
|
||
} else {
|
||
|
||
kernel::database()->rollBack();
|
||
|
||
$msg['out_msg'] = $out_msg;
|
||
$msg['in_msg'] = $in_msg;
|
||
return false;
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* 组织出库数据
|
||
* @access public
|
||
* @param String $iso_id 出入库ID
|
||
* @return sdf 出库数据
|
||
*/
|
||
public function get_iostock_data($appropriation_id)
|
||
{
|
||
|
||
$appitemObj = app::get('taoguanallocate')->model('appropriation_items');
|
||
|
||
$db = kernel::database();
|
||
$sql = 'SELECT * FROM `sdb_taoguanallocate_appropriation` WHERE `appropriation_id`=\'' . $appropriation_id . '\'';
|
||
$app_detail = $db->selectrow($sql);
|
||
$iostock_data = array(
|
||
'original_id' => $appropriation_id,
|
||
'original_bn' => $app_detail['appropriation_no'],
|
||
);
|
||
$app_items_detail = $appitemObj->getList('*', array('appropriation_id' => $appropriation_id), 0, -1);
|
||
if ($app_items_detail) {
|
||
foreach ($app_items_detail as $k => $v) {
|
||
|
||
$bp_data = $db->selectrow('select unit_cost from sdb_ome_branch_product where branch_id = ' . $v['from_branch_id'] . ' and product_id = ' . $v['product_id']);
|
||
|
||
$iostock_data['items'][$v['item_id']] = array(
|
||
'from_branch_id' => $v['from_branch_id'],
|
||
'to_branch_id' => $v['to_branch_id'],
|
||
'original_bn' => '',
|
||
'original_id' => $appropriation_id,
|
||
'original_item_id' => $v['item_id'],
|
||
'supplier_id' => 0,
|
||
'bn' => $v['bn'],
|
||
'iostock_price' => $bp_data['unit_cost'] ? $bp_data['unit_cost'] : 0,
|
||
'nums' => abs($v['num']),
|
||
'oper' => $app_detail['operator_name'],
|
||
'create_time' => $app_detail['create_time'],
|
||
'operator' => kernel::single('desktop_user')->get_name(),
|
||
'memo' => $app_detail['memo'],
|
||
);
|
||
}
|
||
}
|
||
return $iostock_data;
|
||
}
|
||
|
||
#生成16位的调拨单号
|
||
private function gen_appropriation_no()
|
||
{
|
||
$i = rand(0, 9);
|
||
$appropriation_no = 'S' . date('YmdHis') . $i;
|
||
return $appropriation_no;
|
||
}
|
||
|
||
/**
|
||
* 调拔单创建
|
||
* @return
|
||
*/
|
||
public function create($data, $msg)
|
||
{
|
||
|
||
$approMdl = app::get('taoguanallocate')->model("appropriation");
|
||
$branchMdl = app::get('ome')->model('branch');
|
||
$approItemMdl = app::get('taoguanallocate')->model('appropriation_items');
|
||
$basicMaterialObj = app::get('material')->model('basic_material');
|
||
|
||
$appro_data = array(
|
||
'create_time' => time(),
|
||
'operator_name' => $data['op_name'],
|
||
'memo' => $data['memo'],
|
||
'corp_id' => 0,
|
||
'from_branch_id' => $data['from_branch_id'],
|
||
'to_branch_id' => $data['to_branch_id'],
|
||
'bill_type' => $data['bill_type'],
|
||
'from_physics_id'=> $data['from_physics_id'],
|
||
'to_physics_id' => $data['to_physics_id'],
|
||
'movement_code' => $data['movement_code'],
|
||
|
||
);
|
||
if($data['source_from']){
|
||
$appro_data['source_from'] = $data['source_from'];
|
||
}
|
||
|
||
if($data['logi_code']){
|
||
$appro_data['logi_code'] = $data['logi_code'];
|
||
}
|
||
|
||
if($data['logi_no']){
|
||
$appro_data['logi_no'] = $data['logi_no'];
|
||
}
|
||
if (!$appro_data['bill_type']) {
|
||
//电商-》门店 补货
|
||
$from_branch_id = $appro_data['from_branch_id'];
|
||
$to_branch_id = $appro_data['to_branch_id'];
|
||
|
||
$from_branch = $branchMdl->db_dump(array('branch_id' => $from_branch_id, 'check_permission' => 'false'), 'b_type');
|
||
$to_branch = $branchMdl->db_dump(array('branch_id' => $to_branch_id, 'check_permission' => 'false'), 'b_type');
|
||
if ($from_branch['b_type'] == 1 && $from_branch['b_type'] == 2) {
|
||
$appro_data['bill_type'] = 'replenishment';
|
||
}
|
||
}
|
||
|
||
$appro_data['appropriation_no'] = $data['appropriation_no'] ? $data['appropriation_no'] : $this->gen_appropriation_no();
|
||
$appro_data['process_status'] = isset($data['process_status']) ? $data['process_status'] : 0;
|
||
$appro_data['original_bn'] = isset($data['original_bn']) ? $data['original_bn'] : null;
|
||
$appro_data['original_id'] = isset($data['original_id']) ? $data['original_id'] : null;
|
||
$appro_data['extrabranch_bn'] = isset($data['extrabranch_bn']) ? $data['extrabranch_bn'] : '';
|
||
$appro_data['is_quickly'] = isset($data['is_quickly']) ? $data['is_quickly'] : 'false';
|
||
|
||
if($data['extra_ship_area']){
|
||
$appro_data['extra_ship_area'] = $data['extra_ship_area'];
|
||
}
|
||
if($data['extra_ship_addr']){
|
||
$appro_data['extra_ship_addr'] = $data['extra_ship_addr'];
|
||
}
|
||
if($data['extra_ship_mobile']){
|
||
$appro_data['extra_ship_mobile'] = $data['extra_ship_mobile'];
|
||
}
|
||
if($data['extra_ship_name']){
|
||
$appro_data['extra_ship_name'] = $data['extra_ship_name'];
|
||
}
|
||
$approMdl->save($appro_data);
|
||
$appropriation_id = $appro_data['appropriation_id'];
|
||
foreach ((array) $data['items'] as $k => $v) {
|
||
$items = $approItemMdl->dump(array('appropriation_id' => $appropriation_id, 'product_id' => $v['product_id']), 'item_id');
|
||
|
||
$items_data = array(
|
||
'appropriation_id' => $appropriation_id,
|
||
'bn' => $v['material_bn'],
|
||
'product_name' => $v['material_name'],
|
||
'product_id' => $v['product_id'],
|
||
'from_branch_id' => $v['from_branch_id'],
|
||
'from_pos_id' => 0,
|
||
'to_branch_id' => $v['to_branch_id'],
|
||
'to_pos_id' => 0,
|
||
'num' => $v['num'],
|
||
'to_branch_num' => $v['to_branch_num'],
|
||
'from_branch_num' => $v['from_branch_num'],
|
||
);
|
||
if($v['package_code']){
|
||
$items_data['package_code'] = $v['package_code'];
|
||
}
|
||
if ($items) {
|
||
$items_data['item_id'] = $items['item_id'];
|
||
}
|
||
$approItemMdl->save($items_data);
|
||
|
||
}
|
||
|
||
return $appro_data['appropriation_no'];
|
||
|
||
}
|
||
}
|