mirror of
https://gitee.com/ShopeX/OMS
synced 2026-04-03 06:05:46 +08:00
61783b7d01
2. 【新增】手工创建订单折扣可输入正数 3. 【优化】盘点申请单确认 4. 【修复】采购退货单模拟出库失败问题 5. 【新增】订单金额客户实付与结算金额 6. 【优化】仓库发货统计报表物料名称显示 7. 【优化】自有仓储虚拟发货逻辑 8. 【修复】基础物料分类管理问题
2107 lines
80 KiB
PHP
2107 lines
80 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 ome_event_receive_delivery extends ome_event_response
|
||
{
|
||
|
||
/**
|
||
* 发货单对象
|
||
*/
|
||
private $__dlyObj = null;
|
||
|
||
/**
|
||
* 日志对象
|
||
*/
|
||
private $__operationLogObj = null;
|
||
|
||
/**
|
||
* 当前处理的发货单源数据
|
||
*/
|
||
private $__currDlyInfo = array();
|
||
|
||
/**
|
||
* 当前处理的发货单单号
|
||
*/
|
||
private $__currDlyBn = "";
|
||
|
||
/**
|
||
* 当前处理的发货单ID
|
||
*/
|
||
private $__currDlyId = "";
|
||
|
||
/**
|
||
* 当前发货单是否是合并发货单
|
||
*/
|
||
private $__isBind = false;
|
||
|
||
/**
|
||
* 当前发货单关联仓储是否管控库存
|
||
*/
|
||
private $__storeCtrl = true;
|
||
|
||
/**
|
||
* 合并发货单的子发货单ID数组
|
||
*/
|
||
private $__currDlyChilds = array();
|
||
|
||
/**
|
||
* 是否是第三方仓储回传，根据回传参数判断的
|
||
*/
|
||
private $__isThirdParty = false;
|
||
|
||
/**
|
||
* 当前传入的参数
|
||
*/
|
||
private $__inputParams = array();
|
||
|
||
/**
|
||
* 格式化后的参数
|
||
*/
|
||
private $__formatParams = false;
|
||
|
||
/**
|
||
* 加载库存的处理模式Lib类
|
||
*/
|
||
private $__storeManageLib = null;
|
||
|
||
/**
|
||
*
|
||
* 发货通知单处理总入口
|
||
* @param array $data
|
||
*/
|
||
public function update($data)
|
||
{
|
||
$msg_code = '';
|
||
|
||
//参数检查
|
||
if (!isset($data['status'])) {
|
||
return $this->send_error('必要参数缺失', $msg_code, $data);
|
||
}
|
||
|
||
$type = $data['status'];
|
||
unset($data['status']);
|
||
switch ($type) {
|
||
case 'delivery':
|
||
return $this->consign($data);
|
||
break;
|
||
case 'print':
|
||
return $this->setPrint($data);
|
||
break;
|
||
case 'check':
|
||
return $this->setCheck($data);
|
||
break;
|
||
case 'cancel':
|
||
return $this->rebackDly($data);
|
||
break;
|
||
case 'update':
|
||
return $this->updateDetail($data);
|
||
break;
|
||
case 'confirm':
|
||
return $this->confirm($data);
|
||
break;
|
||
case 'sign':
|
||
return $this->sign($data);
|
||
break;
|
||
case 'return_back':
|
||
return $this->returnBackDly($data); //追回物流包裹
|
||
break;
|
||
case 'exception':
|
||
return $this->abnormal($data); //异常EXCEPTION
|
||
break;
|
||
default:
|
||
return $this->send_succ('未知的发货单操作通知行为', $msg_code, $data);
|
||
break;
|
||
}
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 初始化核心所需的加载类
|
||
* @param void
|
||
*/
|
||
private function _instanceObj()
|
||
{
|
||
$this->__dlyObj = app::get('ome')->model('delivery');
|
||
$this->__operationLogObj = app::get('ome')->model('operation_log');
|
||
$this->__storeManageLib = kernel::single('ome_store_manage');
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 初始化发货单信息
|
||
* @param array $params 传入参数
|
||
* @param string $msg 错误信息
|
||
*/
|
||
private function _initDlyInfo($params, &$msg)
|
||
{
|
||
if (!isset($params['delivery_bn']) || empty($params['delivery_bn'])) {
|
||
$msg = '发货单通知单编号参数没有定义!';
|
||
return false;
|
||
}
|
||
|
||
$deliveryInfo = $this->__dlyObj->dump(array('delivery_bn' => $params['delivery_bn']), '*', array('delivery_items' => array('*'), 'delivery_order' => array('*')));
|
||
if (!isset($deliveryInfo['delivery_id'])) {
|
||
$msg = '发货单通知单编号不存在!';
|
||
return false;
|
||
}
|
||
$wdMdl = app::get('console')->model('wms_delivery');
|
||
$wdRow = $wdMdl->db_dump(['delivery_bn'=>$params['delivery_bn'], 'delivery_status'=>'1'], 'id');
|
||
if($wdRow) {
|
||
$wdRs = $wdMdl->update(['delivery_id'=>$deliveryInfo['delivery_id'], 'delivery_status'=>'2'], ['id'=>$wdRow['id'], 'delivery_status'=>'1']);
|
||
if(!is_bool($wdRs)) {
|
||
app::get('ome')->model('operation_log')->write_log('wms_delivery@console',$wdRow['id'], '匹配成功：'.$params['delivery_bn']);
|
||
}
|
||
}
|
||
//WMS仓储订单号(外部发货单号)
|
||
$params['original_delivery_bn'] = ($params['original_delivery_bn'] ? $params['original_delivery_bn'] : '0');
|
||
|
||
//接口传入参数
|
||
$this->__inputParams = $params;
|
||
|
||
//当前处理的发货单原始数据
|
||
$this->__currDlyInfo = $deliveryInfo;
|
||
|
||
//当前处理的发货单ID
|
||
$this->__currDlyId = $deliveryInfo['delivery_id'];
|
||
|
||
//当前处理的发货单单号
|
||
$this->__currDlyBn = $deliveryInfo['delivery_bn'];
|
||
|
||
// 重置格式化后的参数
|
||
$this->__formatParams = [];
|
||
|
||
//识别当前发货单是否是合并的
|
||
$this->__isBind = ($deliveryInfo['is_bind'] == 'true') ? true : false;
|
||
|
||
//如果是合并的，取出子发货单的id数组
|
||
if ($this->__isBind) {
|
||
$this->__currDlyChilds = $this->__dlyObj->getItemsByParentId($this->__currDlyId, 'array');
|
||
}
|
||
|
||
//检查仓储类型，如果是门店自提不管控库存的，不处理冻结释放和仓库库存扣减的逻辑
|
||
$this->__storeManageLib->loadBranch(array('branch_id' => $deliveryInfo['branch_id']));
|
||
$this->__isStoreBranch = $this->__storeManageLib->isStoreBranch();
|
||
$this->__storeCtrl = $this->__storeManageLib->isCtrlBranchStore(); //是否管控库存
|
||
|
||
unset($deliveryInfo);
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 执行发货的时候，检查发货单相关状态
|
||
* @param string $msg 错误信息
|
||
*/
|
||
private function _checkStatusWhenConsign(&$msg)
|
||
{
|
||
//判断是否发货单已取消如果已取消不更新
|
||
if (in_array($this->__currDlyInfo['status'], array('cancel', 'back', 'return_back'))) {
|
||
foreach ($this->__currDlyInfo['delivery_order'] as $dlyOrder) {
|
||
$this->__operationLogObj->write_log('order_modify@ome', $dlyOrder['order_id'], '第三方仓库回写:已发货状态,因发货单目前状态为已取消或打回,不更新');
|
||
}
|
||
|
||
$msg = '发货单状态为已取消不更新发货状态!';
|
||
return false;
|
||
}
|
||
|
||
//如果传入有物流公司和运单号，检查运单号是否被其他发货单占用
|
||
if (isset($this->__inputParams['logi_no'])) {
|
||
// 验证运单号是否存在
|
||
$dlyInfo = $this->__dlyObj->dump(array('logi_no'=>$this->__inputParams['logi_no'], 'delivery_id|noequal'=>$this->__currDlyInfo['delivery_id']), 'delivery_id,original_delivery_bn');
|
||
if($dlyInfo && $dlyInfo['original_delivery_bn'] == $this->__inputParams['original_delivery_bn'])
|
||
{
|
||
$msg = '运单号重复!';
|
||
return false;
|
||
}
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 格式化相应参数
|
||
* @param void
|
||
*/
|
||
private function _convertConsignSdf()
|
||
{
|
||
|
||
$order_fundObj = kernel::single('ome_func');
|
||
$this->__formatParams['delivery_time'] = isset($this->__inputParams['delivery_time']) ? $order_fundObj->date2time($this->__inputParams['delivery_time']) : time();
|
||
$this->__formatParams['weight'] = isset($this->__inputParams['weight']) ? floatval($this->__inputParams['weight']) : 0.00;
|
||
$this->__formatParams['delivery_cost_actual'] = isset($this->__inputParams['delivery_cost_actual']) ? $this->__inputParams['delivery_cost_actual'] : 0.00;
|
||
|
||
//第三方回写发货要更新物流相关信息
|
||
$dlyCorpObj = app::get('ome')->model('dly_corp');
|
||
if (isset($this->__inputParams['logi_id']) && isset($this->__inputParams['logi_no'])) {
|
||
$dlyInfo = $dlyCorpObj->dump(array('type' => $this->__inputParams['logi_id']), 'corp_id,name');
|
||
|
||
//物流公司是否发生变化，不变化已原来的为准
|
||
$erpdlyInfo = $dlyCorpObj->dump(array('corp_id' => $this->__currDlyInfo['logi_id'], 'type' => $this->__inputParams['logi_id']), 'corp_id,name');
|
||
if (!$erpdlyInfo) {
|
||
$this->__formatParams['logi_id'] = empty($dlyInfo['corp_id']) ? '' : $dlyInfo['corp_id'];
|
||
$this->__formatParams['logi_name'] = empty($dlyInfo['name']) ? '' : $dlyInfo['name'];
|
||
}
|
||
|
||
$this->__formatParams['logi_no'] = $this->__inputParams['logi_no'];
|
||
$this->__isThirdParty = true;
|
||
}
|
||
|
||
if(empty($this->__inputParams['logi_id']) && empty($this->__inputParams['logi_no'])) {
|
||
// 大件发货没有运单号使用发货单号作为运单号
|
||
$logiId = $this->__formatParams['logi_id'] ? : $this->__currDlyInfo['logi_id'];
|
||
$erpdlyInfo = $dlyCorpObj->db_dump(array('corp_id' => $logiId), 'corp_model');
|
||
if ($erpdlyInfo['corp_model'] == 'heavy') {
|
||
$this->__formatParams['logi_no'] = $this->__currDlyInfo['delivery_bn'];
|
||
$this->__isThirdParty = true;
|
||
}
|
||
}
|
||
|
||
if ($this->__inputParams['bill_logi_weight']) {
|
||
$this->__formatParams['bill_logi_weight'] = $this->__inputParams['bill_logi_weight'];
|
||
}
|
||
|
||
if ($this->__inputParams['out_serial']) {
|
||
$this->__formatParams['out_serial'] = $this->__inputParams['out_serial'];
|
||
}
|
||
|
||
if ($this->__inputParams['out_storagelife']) {
|
||
$this->__formatParams['out_storagelife'] = $this->__inputParams['out_storagelife'];
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 发货通知单发货事件处理
|
||
* @param array $data
|
||
*/
|
||
private function consign($data)
|
||
{
|
||
$msg_code = '';
|
||
|
||
//初始化类的对象
|
||
$this->_instanceObj();
|
||
|
||
//初始化当前处理发货单的数据
|
||
if (!$this->_initDlyInfo($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $data);
|
||
}
|
||
|
||
//该检查项单拉出来，如果是已发货的返回成功的响应标记，伊藤忠会出现成功发货还重复请求的问题
|
||
if ($this->__currDlyInfo['status'] == 'succ') {
|
||
return $this->send_succ('发货成功');
|
||
}
|
||
|
||
//检查当前发货单对应状态是否可以操作
|
||
if (!$this->_checkStatusWhenConsign($msg)) {
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
//组织参数
|
||
$this->_convertConsignSdf();
|
||
|
||
/*发货处理核心流程 Begin*/
|
||
//加入事务机制
|
||
$trans = kernel::database()->beginTransaction();
|
||
|
||
$this->_dealBatch();
|
||
|
||
$this->_dealSnList();
|
||
|
||
$this->_dealDeliveryPackage();
|
||
|
||
//具体发货处理
|
||
if (!$this->_consign($msg, $msg_code)) {
|
||
|
||
kernel::database()->rollBack();
|
||
|
||
return $this->send_error($msg, $msg_code, array('params' => json_encode($this->__inputParams), 'obj_bn' => $data['delivery_bn']));
|
||
}
|
||
|
||
//生成出入库明细及销售单
|
||
if (!$this->_consign_siso($msg)) {
|
||
|
||
kernel::database()->rollBack();
|
||
|
||
return $this->send_error($msg, $msg_code, array('params' => json_encode($this->__inputParams), 'obj_bn' => $data['delivery_bn']));
|
||
}
|
||
|
||
// 事务提交
|
||
kernel::database()->commit($trans);
|
||
/*发货处理核心流程 End*/
|
||
|
||
//发货后续处理
|
||
$this->_after_consign();
|
||
|
||
return $this->send_succ('发货成功');
|
||
}
|
||
|
||
private function _dealBatch() {
|
||
if($this->__inputParams['items']){
|
||
foreach ((array)$this->__inputParams['items'] as $item) {
|
||
if($item['batch']) {
|
||
$useLogModel = app::get('console')->model('useful_life_log');
|
||
$bnBmId = app::get('material')->model('basic_material')->db_dump(array('material_bn'=>$item['bn']), 'bm_id');
|
||
$useful = [];
|
||
foreach ($item['batch'] as $bv) {
|
||
|
||
if (!$bv['purchase_code']) {
|
||
continue;
|
||
}
|
||
|
||
$tmpUseful = [];
|
||
$tmpUseful['product_id'] = $bnBmId['bm_id'];
|
||
$tmpUseful['bn'] = $item['bn'];
|
||
$tmpUseful['original_bn'] = $this->__currDlyBn;
|
||
$tmpUseful['original_id'] = $this->__currDlyId;
|
||
$tmpUseful['sourcetb'] = 'delivery';
|
||
$tmpUseful['create_time'] = time();
|
||
$tmpUseful['stock_status'] = '0';
|
||
$tmpUseful['num'] = $bv['num'];
|
||
$tmpUseful['normal_defective'] = $bv['normal_defective'];
|
||
$bv['product_time'] && $tmpUseful['product_time'] = $bv['product_time'];
|
||
$bv['expire_time'] && $tmpUseful['expire_time'] = $bv['expire_time'];
|
||
$tmpUseful['purchase_code'] = $bv['purchase_code'];
|
||
$tmpUseful['produce_code'] = $bv['produce_code'];
|
||
$useful[] = $tmpUseful;
|
||
}
|
||
|
||
if ($useful) {
|
||
$useLogModel->db->exec(ome_func::get_insert_sql($useLogModel, $useful));
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
private function _dealSnList() {
|
||
foreach ((array)$this->__inputParams['items'] as $item) {
|
||
|
||
if (($item['imeiList'] && $item['imeiList']['extSnList']) || $item['sn_list']) {
|
||
|
||
$bnBm = app::get('material')->model('basic_material')->db_dump(array('material_bn'=>$item['bn']), 'bm_id,material_name');
|
||
$serialHistoryObj = app::get('ome')->model('product_serial_history');
|
||
$opInfo = kernel::single('ome_func')->getDesktopUser();
|
||
$historyData = [];
|
||
|
||
$_tmp = [
|
||
'branch_id' => $this->__currDlyInfo['branch_id'],
|
||
'bn' => $item['bn'],
|
||
'product_name' => $bnBm['material_name'],
|
||
'act_type' => '1',
|
||
'act_time' =>time(),
|
||
'act_owner' => $opInfo['op_id'],
|
||
'bill_type' => '1',
|
||
'bill_id' => $this->__currDlyId,
|
||
'bill_no' => $this->__currDlyBn,
|
||
];
|
||
}
|
||
|
||
if ($item['imeiList'] && $item['imeiList']['extSnList']) {
|
||
|
||
// 兼容sn vs imei 一对多的情况
|
||
$_tmp_sn_imei = [];
|
||
foreach ($item['imeiList']['extSnList'] as $_extSn) {
|
||
$_tmp_sn_imei[$_extSn['sn']][] = $_extSn['imei'];
|
||
}
|
||
|
||
foreach ($_tmp_sn_imei as $_sn => $_imei_arr) {
|
||
$tmp = $_tmp;
|
||
$tmp['serial_number'] = $_sn;
|
||
$tmp['imei_number'] = implode(',', $_imei_arr);
|
||
$historyData[] = $tmp;
|
||
}
|
||
$serialHistoryObj->db->exec(ome_func::get_insert_sql($serialHistoryObj, $historyData));
|
||
|
||
} elseif ($item['sn_list']) {
|
||
|
||
foreach($item['sn_list'] as $serial){
|
||
$tmp = $_tmp;
|
||
$tmp['serial_number'] = $serial;
|
||
$historyData[] = $tmp;
|
||
}
|
||
$serialHistoryObj->db->exec(ome_func::get_insert_sql($serialHistoryObj, $historyData));
|
||
}
|
||
}
|
||
}
|
||
|
||
private function _dealDeliveryPackage() {
|
||
$packageObj = app::get('ome')->model('delivery_package');
|
||
if($packageObj->db_dump(['delivery_id'=>$this->__currDlyId], 'package_id')) {
|
||
return;
|
||
}
|
||
if($this->__inputParams['package']) {
|
||
$package = $this->__inputParams['package'];
|
||
foreach($package as $k => $v) {
|
||
$package[$k]['delivery_id'] = $this->__currDlyId;
|
||
if(empty($v['create_time'])) {
|
||
$package[$k]['create_time'] = time();
|
||
}
|
||
if(empty($v['delivery_time'])) {
|
||
$package[$k]['delivery_time'] = time();
|
||
}
|
||
if(empty($v['logi_no'])) {
|
||
$v['logi_no'] = $this->__formatParams['logi_no'] ? : $this->__currDlyInfo['logi_no'];
|
||
}
|
||
}
|
||
} else {
|
||
if($this->__formatParams['logi_id']) {
|
||
$logi_id = $this->__formatParams['logi_id'];
|
||
} else {
|
||
$logi_id = $this->__currDlyInfo['logi_id'];
|
||
}
|
||
$logisticsCode = app::get('ome')->model('dly_corp')->db_dump(['corp_id'=>$logi_id], 'type')['type'];
|
||
$expressCode = $this->__formatParams['logi_no'] ? : $this->__currDlyInfo['logi_no'];
|
||
$package = [];
|
||
foreach($this->__currDlyInfo['delivery_items'] as $iv) {
|
||
$package[] = [
|
||
'delivery_id' => $this->__currDlyId,
|
||
'package_bn' => $this->__currDlyBn,
|
||
'logi_bn' => $logisticsCode,
|
||
'logi_no' => $expressCode,
|
||
'product_id' => $iv['product_id'],
|
||
'bn' => $iv['bn'],
|
||
'status' => 'delivery',
|
||
'number' => $iv['number'],
|
||
'create_time' => time(),
|
||
'delivery_time' => time(),
|
||
];
|
||
}
|
||
}
|
||
$packageObj->db->exec(ome_func::get_insert_sql($packageObj, $package));
|
||
}
|
||
|
||
/**
|
||
* 发货详细处理流程
|
||
*
|
||
* @param string $msg 错误信息
|
||
* @return void
|
||
**/
|
||
private function _consign(&$msg, &$msg_code)
|
||
{
|
||
//[拆单]配置
|
||
$orderSplitLib = kernel::single('ome_order_split');
|
||
$split_seting = $orderSplitLib->get_delivery_seting();
|
||
|
||
$orderObj = app::get('ome')->model('orders');
|
||
$basicMStockFreezeLib = kernel::single('material_basic_material_stock_freeze');
|
||
$delivery_sync = app::get('ome')->model('delivery_sync');
|
||
$reservationMdl = app::get('ome')->model('order_reservation');
|
||
|
||
$err_msg = '';
|
||
$opinfo = [];
|
||
|
||
//是否合并发货单
|
||
if ($this->__isBind) {
|
||
//主发货单更新信息，如果是第三方仓储的并且物流公司有变化，则赋值更新
|
||
if ($this->__isThirdParty == true) {
|
||
if ($this->__formatParams['logi_id']) {
|
||
$maindly['logi_id'] = $this->__formatParams['logi_id'];
|
||
}
|
||
if ($this->__formatParams['logi_name']) {
|
||
$maindly['logi_name'] = $this->__formatParams['logi_name'];
|
||
}
|
||
|
||
$maindly['logi_no'] = $this->__formatParams['logi_no'];
|
||
}
|
||
|
||
//子发货单相应处理
|
||
foreach ($this->__currDlyChilds as $item) {
|
||
$delivery = $this->__dlyObj->dump($item, 'delivery_id,type,is_cod,branch_id,shop_id', array('delivery_items' => array('*'), 'delivery_order' => array('*')));
|
||
|
||
$de = $delivery['delivery_order'];
|
||
$or = array_shift($de);
|
||
$ord_id = $or['order_id'];
|
||
|
||
//普通发货单才做库存处理、订单发货数量的更新
|
||
if (in_array($this->__currDlyInfo['type'], array('normal'))) {
|
||
//仓库库存处理
|
||
$params['params'] = array_merge($delivery, array('order_id' => $ord_id));
|
||
$params['node_type'] = 'consignDly';
|
||
$shop = app::get('ome')->model('shop')->db_dump(['shop_id'=>$delivery['shop_id']], 'delivery_mode');
|
||
if($shop['delivery_mode'] == 'jingxiao') {
|
||
$processResult = true;
|
||
} else {
|
||
$processResult = $this->__storeManageLib->processBranchStore($params, $err_msg);
|
||
}
|
||
if (!$processResult) {
|
||
$msg = $err_msg;
|
||
$msg_code = 'W30012';
|
||
return false;
|
||
}
|
||
|
||
//[行锁]先更新订单物流单号,防并发
|
||
//@todo：订单拆分多个发货单,同分同秒发货,导致订单是部分发货状态;
|
||
if ($this->__isThirdParty == true && $this->__formatParams['logi_no']) {
|
||
$updateSdf = array();
|
||
$updateSdf['logi_no'] = $this->__formatParams['logi_no'];
|
||
if($this->__formatParams['logi_id']){
|
||
$updateSdf['logi_id'] = $this->__formatParams['logi_id'];
|
||
}
|
||
|
||
$orderObj->update($updateSdf, array('order_id' => $ord_id));
|
||
}
|
||
|
||
//订单发货数量更新
|
||
$this->__dlyObj->consignOrderItem($delivery);
|
||
}
|
||
|
||
$childly['delivery_id'] = $delivery['delivery_id'];
|
||
$childly['process'] = 'true';
|
||
$childly['status'] = 'succ';
|
||
$childly['delivery_time'] = $this->__formatParams['delivery_time'];
|
||
$this->__dlyObj->save($childly); //更新子发货单发货状态为已发货
|
||
|
||
$item_num = $this->__dlyObj->countOrderSendNumber($ord_id);
|
||
if ($item_num == 0) {
|
||
//已发货
|
||
//订单全部发货，清除订单级预占流水
|
||
//检测仓库是否管控库存，如果是需要释放订单冻结
|
||
$isCtrlStore = kernel::single('ome_branch')->getBranchCtrlStore($this->__currDlyInfo['branch_id']);
|
||
if($isCtrlStore === false){
|
||
$orderObj->unfreez($ord_id,false);
|
||
}
|
||
if(isset($shop) && $shop['delivery_mode'] == 'jingxiao') {
|
||
$freeResult = $basicMStockFreezeLib->delOrderFreeze($ord_id);
|
||
if (!$freeResult) {
|
||
$msg = '删除流水冻结失败!';
|
||
$msg_code = 'W30012';
|
||
return false;
|
||
}
|
||
}
|
||
$orderInfo = $orderObj->db_dump(['order_id'=>$ord_id]);
|
||
// 检测京东订单是否有微信支付先用后付的单据
|
||
$use_before_payed = false;
|
||
if ($orderInfo['shop_type'] == '360buy') {
|
||
$labelCode = kernel::single('ome_bill_label')->getLabelFromOrder($orderInfo['order_id']);
|
||
$labelCode = array_column($labelCode, 'label_code');
|
||
$use_before_payed = kernel::single('ome_order')->canDeliveryFromBillLabel($labelCode);
|
||
}
|
||
|
||
if (($delivery['is_cod'] == 'false' && !$use_before_payed) || ($delivery['is_cod'] == 'false' && $use_before_payed && $orderInfo['pay_status'] == '1') || ($delivery['is_cod'] == 'true' && $orderInfo['pay_status'] == '1')) {
|
||
$orderdata['status'] = 'finish';
|
||
}
|
||
$orderdata['archive'] = 1; //订单归档
|
||
$orderdata['ship_status'] = '1';
|
||
$orderdata['delivery_time'] = time();
|
||
$affect_order = $orderObj->update($orderdata, array('order_id' => $ord_id)); //更新订单发货状态
|
||
} else {
|
||
//部分发货
|
||
$orderdata['ship_status'] = '2';
|
||
$orderdata['delivery_time'] = time();
|
||
$affect_order = $orderObj->update($orderdata, array('order_id' => $ord_id)); //更新订单发货状态
|
||
}
|
||
|
||
if (!is_numeric($affect_order) || $affect_order <= 0) {
|
||
$msg_code = 'W30012';
|
||
$msg = '订单状态更新失败!';
|
||
return false;
|
||
}
|
||
|
||
// 预约订单状态
|
||
$custom_reserved_status = ($orderdata['ship_status'] == '2' ? '6' : '5');
|
||
$reservationMdl->update(['ship_status'=>$orderdata['ship_status'], 'custom_reserved_status'=>$custom_reserved_status], array('order_id'=>$ord_id));
|
||
|
||
//标记当前门店履约订单已发货
|
||
if ($this->__isStoreBranch) {
|
||
kernel::single('ome_o2o_performance_orders')->updateProcessStatus($ord_id, 'consign');
|
||
}
|
||
|
||
//[拆单]新增_发货单状态回写记录
|
||
$dly_data = array();
|
||
$frst_info = $orderObj->dump(array('order_id' => $ord_id), 'shop_id, shop_type, order_bn');
|
||
|
||
if ($split_seting) {
|
||
$dly_data['order_id'] = $ord_id;
|
||
$dly_data['order_bn'] = $frst_info['order_bn'];
|
||
$dly_data['delivery_id'] = $this->__currDlyId;
|
||
$dly_data['delivery_bn'] = $this->__currDlyBn;
|
||
$dly_data['logi_no'] = isset($maindly['logi_no']) ? $maindly['logi_no'] : $this->__currDlyInfo['logi_no'];
|
||
$dly_data['logi_id'] = isset($maindly['logi_id']) ? $maindly['logi_id'] : $this->__currDlyInfo['logi_id'];
|
||
$dly_data['branch_id'] = $this->__currDlyInfo['branch_id'];
|
||
$dly_data['status'] = $childly['status']; //发货状态
|
||
$dly_data['shop_id'] = $this->__currDlyInfo['shop_id'];
|
||
$dly_data['delivery_time'] = $this->__formatParams['delivery_time'];
|
||
$dly_data['dateline'] = $this->__formatParams['delivery_time'];
|
||
$dly_data['split_model'] = intval($split_seting['split_model']); //拆单方式
|
||
$dly_data['split_type'] = intval($split_seting['split_type']); //回写方式
|
||
|
||
$delivery_sync->save($dly_data);
|
||
}
|
||
|
||
unset($delivery, $childly, $orderdata);
|
||
}
|
||
|
||
// 更新主发货单
|
||
$maindly['delivery_id'] = $this->__currDlyId;
|
||
$maindly['delivery_bn'] = $this->__currDlyBn;
|
||
$maindly['process'] = 'true';
|
||
$maindly['status'] = 'succ';
|
||
$maindly['weight'] = $this->__formatParams['weight'];
|
||
$maindly['delivery_time'] = $this->__formatParams['delivery_time'];
|
||
$maindly['delivery_cost_actual'] = $this->__formatParams['delivery_cost_actual'];
|
||
|
||
//打印状态
|
||
$maindly['expre_status'] = 'true';
|
||
$maindly['deliv_status'] = 'true';
|
||
$maindly['stock_status'] = 'true';
|
||
$maindly['print_status'] = 1;
|
||
$maindly['delivery_logi_number'] = 1;
|
||
//更新子运单号
|
||
if ($this->__formatParams['bill_logi_weight']) {
|
||
$this->_save_bill_logi_weight($this->__formatParams['bill_logi_weight'], $maindly);
|
||
$num = count($this->__formatParams['bill_logi_weight']);
|
||
$maindly['delivery_logi_number'] = $maindly['logi_number'] = $num + 1;
|
||
|
||
}
|
||
|
||
$affect_row = $this->__dlyObj->update($maindly, array('delivery_id' => $maindly['delivery_id'], 'process' => 'false'));
|
||
if (!is_numeric($affect_row) || $affect_row <= 0) {
|
||
$msg = '发货单发货状态更新失败!';
|
||
return false;
|
||
}
|
||
$this->__operationLogObj->write_log('delivery_process@ome', $this->__currDlyId, '发货单发货完成,（发货单号：' . $this->__currDlyBn . '）', '', $opinfo);
|
||
|
||
} else {
|
||
$de = $this->__currDlyInfo['delivery_order'];
|
||
$or = array_shift($de);
|
||
$ord_id = $or['order_id'];
|
||
|
||
$frst_info = $orderObj->dump(array('order_id' => $ord_id), 'shop_id, shop_type, order_bn');
|
||
|
||
//普通发货单才做库存处理、订单发货数量的更新
|
||
if (in_array($this->__currDlyInfo['type'], array('normal'))) {
|
||
//仓库库存处理
|
||
$params['params'] = array_merge($this->__currDlyInfo, array('order_id' => $ord_id));
|
||
$params['node_type'] = 'consignDly';
|
||
$shop = app::get('ome')->model('shop')->db_dump(['shop_id'=>$this->__currDlyInfo['shop_id']], 'delivery_mode');
|
||
if($shop['delivery_mode'] == 'jingxiao') {
|
||
$processResult = true;
|
||
} else {
|
||
$processResult = $this->__storeManageLib->processBranchStore($params, $err_msg);
|
||
}
|
||
if (!$processResult) {
|
||
$msg = $err_msg;
|
||
$msg_code = 'W30012';
|
||
return false;
|
||
}
|
||
|
||
//[行锁]先更新订单物流单号,防并发
|
||
//@todo：订单拆分多个发货单,同分同秒发货,导致订单是部分发货状态;
|
||
if ($this->__isThirdParty == true && $this->__formatParams['logi_no']) {
|
||
$updateSdf = array();
|
||
$updateSdf['logi_no'] = $this->__formatParams['logi_no'];
|
||
if($this->__formatParams['logi_id']){
|
||
$updateSdf['logi_id'] = $this->__formatParams['logi_id'];
|
||
}
|
||
|
||
$orderObj->update($updateSdf, array('order_id' => $ord_id));
|
||
}
|
||
|
||
//订单发货数量更新
|
||
$this->__dlyObj->consignOrderItem($this->__currDlyInfo);
|
||
}
|
||
|
||
//如果是第三方仓储的并且物流公司有变化，则赋值更新
|
||
if ($this->__isThirdParty == true) {
|
||
if ($this->__formatParams['logi_id']) {
|
||
$singledly['logi_id'] = $this->__formatParams['logi_id'];
|
||
$orderdata['logi_id'] = $this->__formatParams['logi_id'];
|
||
}
|
||
if ($this->__formatParams['logi_name']) {
|
||
$singledly['logi_name'] = $this->__formatParams['logi_name'];
|
||
}
|
||
|
||
$singledly['logi_no'] = $this->__formatParams['logi_no'];
|
||
$orderdata['logi_no'] = $this->__formatParams['logi_no'];
|
||
}
|
||
|
||
// 更新主发货单
|
||
$singledly['delivery_id'] = $this->__currDlyId;
|
||
$singledly['delivery_bn'] = $this->__currDlyBn;
|
||
$singledly['process'] = 'true';
|
||
$singledly['status'] = 'succ';
|
||
$singledly['weight'] = $this->__formatParams['weight'];
|
||
$singledly['delivery_time'] = $this->__formatParams['delivery_time'];
|
||
$singledly['delivery_cost_actual'] = $this->__formatParams['delivery_cost_actual'];
|
||
|
||
//打印状态
|
||
$singledly['expre_status'] = 'true';
|
||
$singledly['deliv_status'] = 'true';
|
||
$singledly['stock_status'] = 'true';
|
||
$singledly['stock_status'] = 1;
|
||
$singledly['delivery_logi_number'] = 1;
|
||
//更新子运单号
|
||
if ($this->__formatParams['bill_logi_weight']) {
|
||
$this->_save_bill_logi_weight($this->__formatParams['bill_logi_weight'], $singledly);
|
||
$num = count($this->__formatParams['bill_logi_weight']);
|
||
$singledly['delivery_logi_number'] = $singledly['logi_number'] = $num + 1;
|
||
|
||
}
|
||
|
||
$affect_row = $this->__dlyObj->update($singledly, array('delivery_id' => $singledly['delivery_id'], 'process' => 'false'));
|
||
if (!is_numeric($affect_row) || $affect_row <= 0) {
|
||
$msg = '发货单发货状态更新失败!';
|
||
return false;
|
||
}
|
||
$this->__operationLogObj->write_log('delivery_process@ome', $this->__currDlyId, '发货单发货完成,（发货单号：' . $this->__currDlyBn . '）', '', $opinfo);
|
||
|
||
$item_num = $this->__dlyObj->countOrderSendNumber($ord_id);
|
||
if ($item_num == 0) {
|
||
//已发货
|
||
//订单全部发货，清除订单级预占流水
|
||
//检测仓库是否管控库存，如果是需要释放订单冻结
|
||
$isCtrlStore = kernel::single('ome_branch')->getBranchCtrlStore($this->__currDlyInfo['branch_id']);
|
||
if($isCtrlStore === false){
|
||
$orderObj->unfreez($ord_id,false);
|
||
}
|
||
if(isset($shop) && $shop['delivery_mode'] == 'jingxiao') {
|
||
$freeResult = $basicMStockFreezeLib->delOrderFreeze($ord_id);
|
||
if (!$freeResult) {
|
||
$msg = '删除流水冻结失败!';
|
||
$msg_code = 'W30012';
|
||
return false;
|
||
}
|
||
}
|
||
$orderInfo = $orderObj->db_dump(['order_id'=>$ord_id]);
|
||
// 检测京东订单是否有微信支付先用后付的单据
|
||
$use_before_payed = false;
|
||
if ($orderInfo['shop_type'] == '360buy') {
|
||
$labelCode = kernel::single('ome_bill_label')->getLabelFromOrder($orderInfo['order_id']);
|
||
$labelCode = array_column($labelCode, 'label_code');
|
||
$use_before_payed = kernel::single('ome_order')->canDeliveryFromBillLabel($labelCode);
|
||
}
|
||
if (($this->__currDlyInfo['is_cod'] == 'false' && !$use_before_payed) || ($this->__currDlyInfo['is_cod'] == 'false' && $use_before_payed && $orderInfo['pay_status'] == '1') || ($this->__currDlyInfo['is_cod'] == 'true' && $orderInfo['pay_status'] == '1')) {
|
||
$orderdata['status'] = 'finish';
|
||
}
|
||
$orderdata['archive'] = 1; //订单归档
|
||
$orderdata['ship_status'] = '1';
|
||
$orderdata['delivery_time'] = time();
|
||
$affect_order = $orderObj->update($orderdata, array('order_id' => $ord_id)); //更新订单发货状态
|
||
} else {
|
||
//部分发货
|
||
$orderdata['ship_status'] = '2';
|
||
$orderdata['delivery_time'] = time();
|
||
$affect_order = $orderObj->update($orderdata, array('order_id' => $ord_id)); //更新订单发货状态
|
||
}
|
||
|
||
if (!is_numeric($affect_order) || $affect_order <= 0) {
|
||
$msg_code = 'W30012';
|
||
$msg = '订单状态更新失败!';
|
||
return false;
|
||
}
|
||
|
||
// 预约订单状态
|
||
$custom_reserved_status = ($orderdata['ship_status'] == '2' ? '6' : '5');
|
||
$reservationMdl->update(['ship_status'=>$orderdata['ship_status'], 'custom_reserved_status'=>$custom_reserved_status], array('order_id'=>$ord_id));
|
||
|
||
//标记当前门店履约订单已发货
|
||
if ($this->__isStoreBranch) {
|
||
kernel::single('ome_o2o_performance_orders')->updateProcessStatus($ord_id, 'consign');
|
||
}
|
||
|
||
//[拆单]新增_发货单状态回写记录
|
||
if ($split_seting) {
|
||
$dly_data = array();
|
||
$dly_data['order_id'] = $ord_id;
|
||
$dly_data['order_bn'] = $frst_info['order_bn'];
|
||
$dly_data['delivery_id'] = $this->__currDlyId;
|
||
$dly_data['delivery_bn'] = $this->__currDlyBn;
|
||
$dly_data['logi_no'] = isset($singledly['logi_no']) ? $singledly['logi_no'] : $this->__currDlyInfo['logi_no'];
|
||
$dly_data['logi_id'] = isset($singledly['logi_id']) ? $singledly['logi_id'] : $this->__currDlyInfo['logi_id'];
|
||
$dly_data['branch_id'] = $this->__currDlyInfo['branch_id'];
|
||
$dly_data['status'] = $singledly['status']; //发货状态
|
||
$dly_data['shop_id'] = $this->__currDlyInfo['shop_id'];
|
||
$dly_data['delivery_time'] = $this->__formatParams['delivery_time'];
|
||
$dly_data['dateline'] = $this->__formatParams['delivery_time'];
|
||
$dly_data['split_model'] = intval($split_seting['split_model']); //拆单方式
|
||
$dly_data['split_type'] = intval($split_seting['split_type']); //回写方式
|
||
|
||
$delivery_sync->save($dly_data);
|
||
}
|
||
}
|
||
|
||
|
||
// 包裹处理
|
||
if ($this->__inputParams['packages']) {
|
||
$packageMdl = app::get('ome')->model('delivery_package');
|
||
$corpMdl = app::get('ome')->model('dly_corp');
|
||
|
||
$logi_id = $singledly['logi_id'] ? $singledly['logi_id'] : $this->__currDlyInfo['logi_id'];
|
||
$corp = $corpMdl->db_dump($logi_id, 'type');
|
||
|
||
$packages = [];
|
||
foreach ($this->__inputParams['packages'] as $package) {
|
||
foreach ($package['items'] as $item) {
|
||
$packages[] = [
|
||
'delivery_id' => $this->__currDlyId,
|
||
'package_bn' => $package['package_bn'],
|
||
'logi_bn' => $corp['type'],
|
||
'logi_no' => $package['logi_no'],
|
||
'product_id' => $item['product_id'],
|
||
'bn' => $item['bn'],
|
||
'status' => 'delivery',
|
||
'shipping_status' => '8',
|
||
'number' => $item['number'],
|
||
'create_time' => time(),
|
||
'delivery_time' => $package['delivery_time']
|
||
];
|
||
}
|
||
}
|
||
|
||
if ($packages) $packageMdl->db->exec(ome_func::get_insert_sql($packageMdl, $packages));
|
||
}
|
||
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 发货完成后生成出入库明细及销售单
|
||
*
|
||
* @param string $msg 错误信息
|
||
* @return void
|
||
**/
|
||
private function _consign_siso(&$msg)
|
||
{
|
||
|
||
$soldIoLib = kernel::single('siso_receipt_iostock_sold');
|
||
// 门店订单不统计成本
|
||
if ($this->__isStoreBranch) {
|
||
$soldIoLib->set_io_cost(false);
|
||
}
|
||
|
||
$soldSalesLib = kernel::single('siso_receipt_sales_sold');
|
||
|
||
// if (!$this->__isStoreBranch) {
|
||
|
||
$iostock_data = [];
|
||
$save_iostock = $soldIoLib->create(array('delivery_id' => $this->__currDlyId), $iostock_data, $msg);
|
||
if ($save_iostock) {
|
||
$save_sales = $soldSalesLib->create(array('delivery_id' => $this->__currDlyId, 'iostock' => $iostock_data), $msg);
|
||
if (!$save_sales) {
|
||
$msg = '销售单生成失败!'.(is_array($msg) ? implode(',', $msg) : $msg);
|
||
return false;
|
||
}
|
||
} else {
|
||
$msg = '出入库明细生成失败!'.(is_array($msg) ? implode(',', $msg) : $msg);
|
||
return false;
|
||
}
|
||
|
||
// 发货销售单生成
|
||
$rs = kernel::single('ome_sales_delivery')->process($this->__currDlyId, $msg);
|
||
if (!$rs) {
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 发货以后的后续逻辑处理
|
||
*
|
||
* @return void
|
||
**/
|
||
private function _after_consign()
|
||
{
|
||
$wdMdl = app::get('console')->model('wms_delivery');
|
||
$wdRow = $wdMdl->db_dump(['delivery_id'=>$this->__currDlyId, 'delivery_status'=>'2'], 'id');
|
||
if($wdRow) {
|
||
$wdRs = $wdMdl->update(['delivery_status'=>'3'], ['id'=>$wdRow['id'], 'delivery_status'=>'2']);
|
||
if(!is_bool($wdRs)) {
|
||
app::get('ome')->model('operation_log')->write_log('wms_delivery@console',$wdRow['id'], '发货单完成');
|
||
}
|
||
}
|
||
|
||
//平台自发仓加判断不处理
|
||
if ($this->__currDlyInfo['bool_type'] & ome_delivery_bool_type::__PLATFORM_CODE) {
|
||
return array();
|
||
}
|
||
|
||
if($this->__currDlyInfo['delivery'] == 'SHIPED'){
|
||
return array();
|
||
}
|
||
|
||
//撤销发货单成功后更新退款未退货报表退货单据状态
|
||
kernel::single('ome_refund_noreturn')->deliveryRefundNoreturn($this->__currDlyId);
|
||
|
||
//唯一码出库处理
|
||
$this->_after_consign_serial();
|
||
|
||
//保质期批次出库处理
|
||
$this->_after_consign_storagelife();
|
||
|
||
//电子面单回传
|
||
$this->_after_consign_logisticsmanager();
|
||
|
||
//京东仓储扩展信息的保存
|
||
$this->_after_consign_extend();
|
||
|
||
//短信
|
||
$this->_after_consign_sms();
|
||
|
||
//绩效
|
||
$this->_after_consign_tgkpi();
|
||
|
||
$channel_type = kernel::single('logisticsmanager_service_waybill')->getChannelType($this->__currDlyInfo['logi_id']);
|
||
|
||
//华强宝 需判断 非银联 才发起 华强宝订阅
|
||
if (!in_array($channel_type, array('unionpay'))) {
|
||
$this->_after_consign_hqepay();
|
||
}
|
||
|
||
// 补寄发货处理
|
||
$this->_after_consign_reshipping();
|
||
|
||
//淘宝全链路
|
||
$this->_after_consign_tmc();
|
||
|
||
//状态回写
|
||
$this->_after_consign_shop();
|
||
|
||
//电子发票开蓝票处理
|
||
$this->_after_einvoice_create();
|
||
|
||
//换货订单回写
|
||
$this->_after_consign_change_order();
|
||
|
||
//订单全额退款包裹拦截
|
||
kernel::single('console_reship')->orderRefundToLJRK($this->__currDlyId);
|
||
|
||
// order_ids
|
||
$orderIds = array_column($this->__currDlyInfo['delivery_order'], 'order_id');
|
||
|
||
//更新经销商订单(检查是否安装dealer应用)
|
||
if($this->__currDlyInfo['betc_id'] && app::get('dealer')->is_installed()){
|
||
$jxOrderLib = kernel::single('dealer_platform_orders');
|
||
|
||
//update
|
||
$jxOrderLib->updateDlyOrders($orderIds);
|
||
}
|
||
|
||
// [更新]预约订单的发货状态
|
||
kernel::single('ome_order_reservation')->updateReservationByOrderIds($orderIds);
|
||
|
||
// 发货单发货完成后，service扩展触发其他服务
|
||
foreach(kernel::servicelist('ome.service.delivery.after.consign') as $service) {
|
||
if(method_exists($service,'after_consign')) {
|
||
$service->after_consign($this->__currDlyId);
|
||
}
|
||
}
|
||
|
||
// 订单发货完成后，service扩展触发其他服务
|
||
foreach(kernel::servicelist('ome.service.order.finish.after') as $service) {
|
||
if(method_exists($service, 'after_order_finish')) {
|
||
$service->after_order_finish($orderIds);
|
||
}
|
||
}
|
||
}
|
||
|
||
//自动开蓝票处理
|
||
private function _after_einvoice_create()
|
||
{
|
||
if (!empty($this->__currDlyInfo)) {
|
||
|
||
kernel::single('invoice_process')->after_consign_autoinvoice($this->__currDlyId);
|
||
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 唯一码出库处理
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_serial()
|
||
{
|
||
$msg = '';
|
||
if ($this->__formatParams['out_serial']) {
|
||
$params = array('delivery_id' => $this->__currDlyId, 'delivery_bn' => $this->__currDlyBn, 'branch_id' => $this->__currDlyInfo['branch_id'], 'out_serial' => $this->__formatParams['out_serial']);
|
||
kernel::single('ome_receipt_dlyitemsserial')->consign($params, $msg);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 保质期批次出库处理
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_storagelife()
|
||
{
|
||
$msg = '';
|
||
if ($this->__formatParams['out_storagelife']) {
|
||
$params = array('delivery_id' => $this->__currDlyId, 'delivery_bn' => $this->__currDlyBn, 'branch_id' => $this->__currDlyInfo['branch_id'], 'out_storagelife' => $this->__formatParams['out_storagelife']);
|
||
kernel::single('ome_receipt_dlyitemsstoragelife')->consign($params, $msg);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 电子面单回传
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_logisticsmanager()
|
||
{
|
||
//对EMS直联电子面单作处理（以及京东360buy）(京东先回写运单号）
|
||
$channel_type = $this->__dlyObj->getChannelType($this->__currDlyInfo['logi_id']);
|
||
if ($channel_type && in_array($channel_type, array('360buy', 'taobao', 'ems', 'wxshipin'))) {
|
||
kernel::single('ome_event_trigger_logistics_electron')->delivery($this->__currDlyId);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 京东仓储扩展信息的保存
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_extend()
|
||
{
|
||
//确认有没外部发货单号如果有更新，目前只针对坑爹的京东仓储
|
||
if ($this->__inputParams['out_delivery_bn']) {
|
||
$oDelivery_ext = app::get('console')->model('delivery_extension');
|
||
$delivery_ext = $oDelivery_ext->dump(array('delivery_bn' => $this->__currDlyBn), 'original_delivery_bn');
|
||
if (!$delivery_ext) {
|
||
$ext_data = array(
|
||
'delivery_bn' => $this->__currDlyBn,
|
||
'original_delivery_bn' => $this->__inputParams['out_delivery_bn'],
|
||
);
|
||
$oDelivery_ext->create($ext_data);
|
||
}
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 状态回写
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_shop()
|
||
{
|
||
//调用发货相关api，比如订单的发货状态，库存的回写，发货单的回写
|
||
$this->__dlyObj->call_delivery_api($this->__currDlyId, false);
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 短信
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_sms()
|
||
{
|
||
$sms_error_msg = '';
|
||
$error_msg = '';
|
||
|
||
if (defined('APP_TOKEN') && defined('APP_SOURCE')) {
|
||
/* 门店发货完成后,短信提醒用户收货 */
|
||
if ($this->__isStoreBranch) {
|
||
$event_type = ($this->__inputParams['dly_corp_type'] == 'o2o_pickup' ? 'o2opickup' : 'o2oship');
|
||
|
||
//门店自提单发送短信
|
||
$sendArr = array(
|
||
'event_type' => $event_type,
|
||
'ship_mobile' => $this->__inputParams['ship_mobile'],
|
||
'ship_name' => $this->__inputParams['ship_name'],
|
||
'pickup_bn' => $this->__inputParams['pickup_bn'], #提货单
|
||
'pickup_code' => $this->__inputParams['pickup_code'], #校验码
|
||
'store_name' => $this->__inputParams['store_name'], #门店名称
|
||
'store_addr' => $this->__inputParams['store_addr'], #门店地址
|
||
'store_contact_tel' => $this->__inputParams['store_contact_tel'], #门店联系方式
|
||
);
|
||
|
||
if ($event_type == 'o2opickup') {
|
||
$log_str = '请到(' . $this->__inputParams['store_name'] . ')门店自提,';
|
||
} else {
|
||
unset($sendArr['store_addr']); //不需要门店地址
|
||
$log_str = '请耐心等待门店(' . $this->__inputParams['store_name'] . ')为您配送,';
|
||
}
|
||
|
||
$sendSms = kernel::single('taoexlib_sms')->sendSms($sendArr, $sms_error_msg);
|
||
if (!$sendSms) {
|
||
$log_str = $log_str . "短信发送失败(" . $sms_error_msg . ");";
|
||
} else {
|
||
$log_str = $log_str . '短信发送成功;';
|
||
}
|
||
|
||
$this->__operationLogObj->write_log('delivery_process@ome', $this->__currDlyId, $log_str);
|
||
} else {
|
||
kernel::single('taoexlib_sms')->sendSms(array('event_type' => 'delivery', 'delivery_id' => $this->__currDlyId), $error_msg);
|
||
}
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 绩效
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_tgkpi()
|
||
{
|
||
if (!app::get('tgkpi')->is_installed()) {
|
||
return;
|
||
}
|
||
|
||
$sql = 'select delivery_id from sdb_tgkpi_pick WHERE delivery_id =' . $this->__currDlyId;
|
||
$row = $this->__dlyObj->db->selectrow($sql);
|
||
if ($row) {
|
||
$opInfo = kernel::single('ome_func')->getDesktopUser();
|
||
$sql = sprintf('UPDATE `sdb_tgkpi_pick` SET `pick_status`="deliveryed",`op_name`="%s" WHERE delivery_id="%s"', $opInfo['op_name'], $this->__currDlyId);
|
||
kernel::database()->exec($sql);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 华强宝
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_hqepay()
|
||
{
|
||
|
||
#订阅物流信息
|
||
kernel::single('ome_event_trigger_shop_hqepay')->hqepay_pub($this->__currDlyId);
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 补寄发货处理
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_reshipping()
|
||
{
|
||
// 补寄发货处理
|
||
$reshippingTrigger = kernel::single('ome_event_trigger_reshipping_delivery');
|
||
$reshippingTrigger->afterDelivery($this->__currDlyId);
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 淘宝全链路
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
private function _after_consign_tmc()
|
||
{
|
||
$this->__dlyObj->sendMessageProduce($this->__currDlyId, 'dispatch'); #淘宝全链路 已打包，已称重，已出库
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 发货打印的时候，检查相关状态
|
||
* @param string $msg 错误信息
|
||
*/
|
||
private function _checkStatusWhenPrint(&$msg)
|
||
{
|
||
|
||
// 发货单状态判断
|
||
if (in_array($this->__currDlyInfo['status'], array('succ', 'back', 'stop', 'cancel', 'failed', 'timeout', 'return_back'))) {
|
||
$msg = '发货单状态异常:' . $this->__currDlyInfo['status'] . '!';
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 打印发货单具体处理逻辑
|
||
*
|
||
* @param string $msg 错误信息
|
||
* @return void
|
||
**/
|
||
private function _printDly(&$msg)
|
||
{
|
||
//更新发货单打印状态
|
||
$stock_status = isset($this->__inputParams['stock_status']) ? $this->__inputParams['stock_status'] : 'true';
|
||
$deliv_status = isset($this->__inputParams['deliv_status']) ? $this->__inputParams['deliv_status'] : 'true';
|
||
$expre_status = isset($this->__inputParams['expre_status']) ? $this->__inputParams['expre_status'] : 'true';
|
||
$upData = array('print_status' => 1, 'stock_status' => $stock_status, 'deliv_status' => $deliv_status, 'expre_status' => $expre_status, 'status' => 'progress');
|
||
if($this->__inputParams['logi_no']) {
|
||
$upData['logi_no'] = $this->__inputParams['logi_no'];
|
||
}
|
||
$this->__dlyObj->update($upData, array('delivery_id' => $this->__currDlyId, 'status' => ['ready', 'progress']));
|
||
|
||
//更新订单打印状态
|
||
$this->__dlyObj->updateOrderPrintFinish($this->__currDlyId);
|
||
|
||
//淘宝全链路
|
||
if ($stock_status == 'true') {
|
||
// $flag[] = 5;
|
||
$flag[] = 'print_stock';
|
||
}
|
||
|
||
if ($deliv_status == 'true') {
|
||
// $flag[] = 6;
|
||
$flag[] = 'print_deliv';
|
||
}
|
||
|
||
if ($expre_status == 'true') {
|
||
// $flag[] = 7;
|
||
$flag[] = 'print_expre';
|
||
}
|
||
|
||
if (isset($flag)) {
|
||
$this->__dlyObj->sendMessageProduce($this->__currDlyId, $flag);
|
||
}
|
||
|
||
//请求前端发货单进行更新
|
||
if ($this->__currDlyInfo['status'] == 'ready') {
|
||
kernel::single('ome_event_trigger_shop_delivery')->delivery_process_update($this->__currDlyId);
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 更新接收发货单已打印
|
||
* @param array $data
|
||
*/
|
||
private function setPrint($data)
|
||
{
|
||
$msg_code = '';
|
||
|
||
//初始化类的对象
|
||
$this->_instanceObj();
|
||
|
||
//初始化当前处理发货单的数据
|
||
if (!$this->_initDlyInfo($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $data);
|
||
}
|
||
|
||
//检查当前发货单对应状态是否可以操作
|
||
if (!$this->_checkStatusWhenPrint($msg)) {
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
//加入事务机制
|
||
kernel::database()->beginTransaction();
|
||
|
||
//具体发货单打印的详细处理逻辑
|
||
if (!$this->_printDly($msg)) {
|
||
kernel::database()->rollBack();
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
// 事务提交
|
||
kernel::database()->commit();
|
||
$corpMdl = app::get('ome')->model('dly_corp');
|
||
$corp = $corpMdl->db_dump($this->__currDlyInfo['logi_id'], 'type');
|
||
|
||
//库内作业操作通知
|
||
$sdf = array (
|
||
'logi_no' => $this->__inputParams['logi_no'],
|
||
'type' => $corp['type'],
|
||
'delivery_bn' => $this->__currDlyInfo['delivery_bn'],
|
||
'status' => 'print',
|
||
'orderinfo' => app::get('ome')->model('orders')->db_dump(['order_id' => array_keys($this->__currDlyInfo['delivery_order'])]),
|
||
);
|
||
kernel::single('erpapi_router_request')->set('shop',$this->__currDlyInfo['shop_id'])->delivery_operationInWarehouse($sdf);
|
||
$rb = app::get('ome')->getConf('ome.delivery.back_node');
|
||
if($rb == 'print') {
|
||
kernel::single('ome_event_trigger_shop_delivery')->delivery_confirm_send($this->__currDlyInfo['delivery_id']);
|
||
}
|
||
return $this->send_succ();
|
||
}
|
||
|
||
/**
|
||
* 校验发货单具体处理逻辑
|
||
*
|
||
* @param string $msg 错误信息
|
||
* @return void
|
||
**/
|
||
private function _checkDly(&$msg)
|
||
{
|
||
|
||
$dlyItemObj = app::get('ome')->model('delivery_items');
|
||
|
||
if ($dlyItemObj->verifyItemsByDeliveryId($this->__currDlyId)) {
|
||
$filter['delivery_id'] = $this->__currDlyId;
|
||
$delivery['verify'] = 'true';
|
||
|
||
$affect_dly = $this->__dlyObj->update($delivery, $filter);
|
||
if (!is_numeric($affect_dly) || $affect_dly <= 0) {
|
||
$msg = '发货单校验更新失败!';
|
||
return false;
|
||
}
|
||
|
||
if ($this->__isBind) {
|
||
foreach ($this->__currDlyChilds as $i) {
|
||
$dlyItemObj->verifyItemsByDeliveryId($i);
|
||
}
|
||
}
|
||
|
||
#淘宝全链路 已捡货，已验货
|
||
$this->__dlyObj->sendMessageProduce($this->__currDlyId, 'picking');
|
||
} else {
|
||
$msg = '发货单校验更新失败!';
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 更新接收发货单已校验
|
||
* @param array $data
|
||
*/
|
||
private function setCheck($data)
|
||
{
|
||
$msg_code = '';
|
||
|
||
//初始化类的对象
|
||
$this->_instanceObj();
|
||
|
||
//初始化当前处理发货单的数据
|
||
if (!$this->_initDlyInfo($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $data);
|
||
}
|
||
|
||
//检查当前发货单对应状态是否可以操作
|
||
|
||
//加入事务机制
|
||
kernel::database()->beginTransaction();
|
||
|
||
//具体打回发货单的详细处理逻辑
|
||
if (!$this->_checkDly($msg)) {
|
||
kernel::database()->rollBack();
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
// 事务提交
|
||
kernel::database()->commit();
|
||
|
||
$rb = app::get('ome')->getConf('ome.delivery.back_node');
|
||
if($rb == 'check') {
|
||
kernel::single('ome_event_trigger_shop_delivery')->delivery_confirm_send($this->__currDlyInfo['delivery_id']);
|
||
}
|
||
return $this->send_succ();
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 更新发货单信息格式化相应参数
|
||
* @param void
|
||
*/
|
||
private function _convertUpdateSdf()
|
||
{
|
||
|
||
$validKeys = array('logi_id', 'logi_name', 'logi_no', 'delivery_cost_expect', 'delivery_cost_actual', 'weight', 'memo');
|
||
$arrKeys = array_keys($this->__inputParams);
|
||
foreach ($arrKeys as $arrKey) {
|
||
if (in_array($arrKey, $validKeys)) {
|
||
$this->__formatParams[$arrKey] = $this->__inputParams[$arrKey];
|
||
}
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 更新发货单详情具体处理逻辑
|
||
*
|
||
* @param string $msg 错误信息
|
||
* @return void
|
||
**/
|
||
private function _updateDly(&$msg)
|
||
{
|
||
|
||
//保存发货单变更信息
|
||
$affect_dly = $this->__dlyObj->updateDelivery($this->__formatParams, array('delivery_id' => $this->__currDlyId));
|
||
if (!is_numeric($affect_dly) || $affect_dly <= 0) {
|
||
$msg = '发货单校验更新失败!';
|
||
return false;
|
||
}
|
||
|
||
//根据动作类型记录相关日志
|
||
if ($this->__inputParams['action']) {
|
||
switch ($this->__inputParams['action']) {
|
||
case 'updateDetail':
|
||
$this->__operationLogObj->write_log('delivery_modify@ome', $this->__currDlyId, '修改发货单详情');
|
||
break;
|
||
case 'addLogiNo':
|
||
$this->__operationLogObj->write_log('delivery_logi_no@ome', $this->__currDlyId, '录入快递单号:' . $this->__formatParams['logi_no']);
|
||
break;
|
||
}
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 更新接收发货单信息变更
|
||
* @param array $data
|
||
*/
|
||
private function updateDetail($data)
|
||
{
|
||
$msg_code = '';
|
||
|
||
//初始化类的对象
|
||
$this->_instanceObj();
|
||
|
||
//初始化当前处理发货单的数据
|
||
if (!$this->_initDlyInfo($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $data);
|
||
}
|
||
|
||
//检查当前发货单对应状态是否可以操作
|
||
|
||
//组织参数
|
||
$this->_convertUpdateSdf();
|
||
|
||
//加入事务机制
|
||
kernel::database()->beginTransaction();
|
||
|
||
//具体更新发货单的详细处理逻辑
|
||
if (!$this->_updateDly($msg)) {
|
||
kernel::database()->rollBack();
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
// 事务提交
|
||
kernel::database()->commit();
|
||
|
||
return $this->send_succ();
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 打回发货的时候，检查相关状态
|
||
* @param string $msg 错误信息
|
||
*/
|
||
private function _checkStatusWhenReback(&$msg)
|
||
{
|
||
|
||
if ($this->__currDlyInfo['status'] == 'back') {
|
||
$msg = '该发货单已经被打回，无法继续操作!';
|
||
return false;
|
||
}
|
||
|
||
if ($this->__currDlyInfo['delivery_logi_number'] > 0) {
|
||
$msg = '该发货单已部分发货，无法继续操作!';
|
||
return false;
|
||
}
|
||
|
||
if ($this->__currDlyInfo['pause'] == 'true') {
|
||
$msg = '该发货单已暂停，无法继续操作!';
|
||
return false;
|
||
}
|
||
|
||
if ($this->__currDlyInfo['process'] == 'true') {
|
||
$msg = '该发货单已经发货，无法继续操作!';
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 打回发货单具体处理逻辑
|
||
*
|
||
* @param string $msg 错误信息
|
||
* @return void
|
||
**/
|
||
private function _rebackDly(&$msg)
|
||
{
|
||
$branchPrdObj = app::get('ome')->model('branch_product');
|
||
$orderObj = app::get('ome')->model('orders');
|
||
|
||
$err_msg = '';
|
||
$tmp['memo'] = $this->__isStoreBranch ? '门店拒绝：' . $this->__inputParams['memo'] : $this->__inputParams['memo'];
|
||
$tmp['status'] = 'back';
|
||
$tmp['logi_no'] = null;
|
||
$filter['delivery_id'] = $this->__currDlyId;
|
||
|
||
$affect_dly = $this->__dlyObj->update($tmp, $filter);
|
||
if (!is_numeric($affect_dly) || $affect_dly <= 0) {
|
||
$msg = '发货单状态更新失败!';
|
||
return false;
|
||
}
|
||
|
||
$log_prefix = ($tmp['memo'] ? $tmp['memo'] : '发货单打回');
|
||
$logi_info = $this->__currDlyInfo['logi_no'] ? ',物流单号' . $this->__currDlyInfo['logi_no'] : '';
|
||
$this->__operationLogObj->write_log('delivery_back@ome', $this->__currDlyId, $log_prefix . $logi_info);
|
||
|
||
//门店拒绝添加统计
|
||
if ($this->__isStoreBranch && app::get('o2o')->is_installed()) {
|
||
$reason_data = array(
|
||
'delivery_bn' => $this->__currDlyBn,
|
||
'delivery_id' => $this->__currDlyId,
|
||
'store_bn' => $this->__inputParams['store_bn'],
|
||
'store_name' => $this->__inputParams['store_name'],
|
||
'reason_id' => $this->__inputParams['reason_id'],
|
||
'memo' => $this->__inputParams['memo'],
|
||
'createtime' => time(),
|
||
);
|
||
$reasonAnalysisObj = app::get('o2o')->model('store_refuse_analysis');
|
||
$reasonAnalysisObj->save($reason_data);
|
||
}
|
||
|
||
//子发货单处理
|
||
if ($this->__isBind) {
|
||
foreach ($this->__currDlyChilds as $i) {
|
||
$tmpdly = array(
|
||
'status' => 'cancel',
|
||
'logi_id' => null,
|
||
'logi_name' => '',
|
||
'logi_no' => null,
|
||
);
|
||
|
||
$affect_dly = $this->__dlyObj->update($tmpdly, array('delivery_id' => $i));
|
||
if (!is_numeric($affect_dly) || $affect_dly <= 0) {
|
||
$msg = '发货单状态更新失败!';
|
||
return false;
|
||
}
|
||
|
||
$this->__operationLogObj->write_log('delivery_back@ome', $i, $log_prefix);
|
||
|
||
$delivery = $this->__dlyObj->dump($i, 'delivery_id,branch_id,shop_id', array('delivery_items' => array('*'), 'delivery_order' => array('*')));
|
||
|
||
$de = $delivery['delivery_order'];
|
||
$or = array_shift($de);
|
||
$ord_id = $or['order_id'];
|
||
|
||
//仓库库存处理
|
||
$params['params'] = array_merge($delivery, array('order_id' => $ord_id));
|
||
$params['node_type'] = 'cancelDly';
|
||
$processResult = $this->__storeManageLib->processBranchStore($params, $err_msg);
|
||
|
||
if (!$processResult) {
|
||
$msg = $err_msg;
|
||
return false;
|
||
}
|
||
kernel::single('ome_order_object_splitnum')->backDeliverySplitNum($i);
|
||
}
|
||
} else {
|
||
$de = $this->__currDlyInfo['delivery_order'];
|
||
$or = array_shift($de);
|
||
$ord_id = $or['order_id'];
|
||
|
||
//仓库库存处理
|
||
$params['params'] = array_merge($this->__currDlyInfo, array('order_id' => $ord_id));
|
||
$params['node_type'] = 'cancelDly';
|
||
$processResult = $this->__storeManageLib->processBranchStore($params, $err_msg);
|
||
if (!$processResult) {
|
||
$msg = $err_msg;
|
||
return false;
|
||
}
|
||
kernel::single('ome_order_object_splitnum')->backDeliverySplitNum($this->__currDlyId);
|
||
}
|
||
|
||
//单个发货单的对应订单号
|
||
$validOrderIdsForDelete = array(); // 收集pay_status != 5的订单ID，用于后续删除明细
|
||
foreach ($this->__currDlyInfo['delivery_order'] as $dly_order) {
|
||
$orderInfo = $orderObj->dump($dly_order['order_id'], 'order_id,order_bn,order_combine_idx,order_combine_hash,pay_status,ship_status,payed,process_status');
|
||
$pay_status = $orderInfo['pay_status'];
|
||
$memo = '';
|
||
if ($pay_status == '5' && $orderInfo['ship_status'] == '0') {
|
||
$memo .= '全额退款订单取消';
|
||
app::get('ome')->model('refund_apply')->check_iscancel($dly_order['order_id'], $memo, false);
|
||
} else {
|
||
$memo .= '更新订单状态(payed:'. $orderInfo['payed'] .',pay_status:'. $pay_status .',ship_status:'. $orderInfo['ship_status'] .')';
|
||
|
||
//发货单打回，更新订单状态
|
||
kernel::single('ome_order')->resumeOrdStatus($orderInfo);
|
||
|
||
// 收集pay_status != 5的订单ID
|
||
$validOrderIdsForDelete[] = $dly_order['order_id'];
|
||
}
|
||
|
||
$this->__operationLogObj->write_log('order_back@ome', $dly_order['order_id'], '发货单' . $this->__currDlyBn . $logi_info . '打回+' . '备注:' . $tmp['memo'] . $memo);
|
||
|
||
//标记当前门店履约订单已拒绝
|
||
if ($this->__isStoreBranch) {
|
||
kernel::single('ome_o2o_performance_orders')->updateProcessStatus($dly_order['order_id'], 'refuse');
|
||
}
|
||
}
|
||
|
||
// 处理发货单关联的订单明细：订单主结构pay_status != 5时，删除明细并扣除金额
|
||
if (!empty($validOrderIdsForDelete)) {
|
||
$deliveryItemsDetail = app::get('ome')->model('delivery_items_detail')->getList('order_obj_id',
|
||
array('delivery_id' => $this->__currDlyId, 'order_id' => $validOrderIdsForDelete));
|
||
|
||
if (!empty($deliveryItemsDetail)) {
|
||
$orderObjIds = array_unique(array_column($deliveryItemsDetail, 'order_obj_id'));
|
||
|
||
// 批量查询符合条件的order_objects（pay_status=5且delete=false）
|
||
$orderObjectsObj = app::get('ome')->model('order_objects');
|
||
$orderObjects = $orderObjectsObj->getList('obj_id',
|
||
array('obj_id' => $orderObjIds, 'order_id' => $validOrderIdsForDelete, 'pay_status' => '5', 'delete' => 'false'));
|
||
|
||
if (!empty($orderObjects)) {
|
||
$ordersObj = app::get('ome')->model('orders');
|
||
|
||
// 对每个符合条件的obj_id调用封装的方法
|
||
foreach ($orderObjects as $obj) {
|
||
$ordersObj->deleteRefundObject($obj['obj_id'], '发货单撤销');
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
$this->__dlyObj->updateOrderPrintFinish($this->__currDlyId, 1);
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 撤销发货单
|
||
* @param array $data
|
||
*/
|
||
private function rebackDly($data)
|
||
{
|
||
$msg_code = '';
|
||
|
||
//初始化类的对象
|
||
$this->_instanceObj();
|
||
|
||
//初始化当前处理发货单的数据
|
||
if (!$this->_initDlyInfo($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $data);
|
||
}
|
||
|
||
//检查当前发货单对应状态是否可以操作
|
||
if (!$this->_checkStatusWhenReback($msg)) {
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
//加入事务机制
|
||
$transaction = kernel::database()->beginTransaction();
|
||
|
||
|
||
//具体打回发货单的详细处理逻辑
|
||
if (!$this->_rebackDly($msg)) {
|
||
|
||
kernel::database()->rollBack();
|
||
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
// 事务提交
|
||
kernel::database()->commit($transaction);
|
||
// 发货单取消后的service扩展点
|
||
foreach(kernel::servicelist('ome.service.delivery.cancel.after') as $object) {
|
||
if(method_exists($object, 'cancel_delivery_after')) {
|
||
$object->cancel_delivery_after($this->__currDlyId);
|
||
}
|
||
}
|
||
return $this->send_succ();
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 确认接单的时候，检查相关状态
|
||
* @param string $msg 错误信息
|
||
*/
|
||
private function _checkStatusWhenConfirm(&$msg)
|
||
{
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 确认接单详细处理逻辑
|
||
* @param array $data
|
||
*/
|
||
public function _confirmDly($data)
|
||
{
|
||
$filter['delivery_id'] = $this->__currDlyId;
|
||
$filter['status'] = ['ready', 'progress'];
|
||
$delivery['status'] = 'progress';
|
||
|
||
//更新发货单为处理中状态，说明门店已接单
|
||
$affect_dly = $this->__dlyObj->update($delivery, $filter);
|
||
if (is_numeric($affect_dly) || $affect_dly > 0) {
|
||
//记录日志
|
||
$this->__operationLogObj->write_log('delivery_modify@ome', $this->__currDlyId, $this->__inputParams['memo']);
|
||
|
||
//标记当前门店履约订单已接单
|
||
if ($this->__isStoreBranch) {
|
||
$dly_order = $this->__currDlyInfo['delivery_order'];
|
||
$order_arr = array_shift($dly_order);
|
||
kernel::single('ome_o2o_performance_orders')->updateProcessStatus($order_arr['order_id'], 'accept');
|
||
}
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 确认接单
|
||
* @param array $data
|
||
*/
|
||
private function confirm($data)
|
||
{
|
||
$msg_code = '';
|
||
$msg = '';
|
||
|
||
//初始化类的对象
|
||
$this->_instanceObj();
|
||
|
||
//初始化当前处理发货单的数据
|
||
if (!$this->_initDlyInfo($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $data);
|
||
}
|
||
|
||
//检查当前发货单对应状态是否可以操作
|
||
if (!$this->_checkStatusWhenConfirm($msg)) {
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
//加入事务机制
|
||
kernel::database()->beginTransaction();
|
||
|
||
//具体确认接单的详细处理逻辑
|
||
if (!$this->_confirmDly($msg)) {
|
||
kernel::database()->rollBack();
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
// 事务提交
|
||
kernel::database()->commit();
|
||
|
||
return $this->send_succ();
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 发货单签收的时候，检查相关状态
|
||
* @param string $msg 错误信息
|
||
*/
|
||
private function _checkStatusWhenSign($data, &$msg=null)
|
||
{
|
||
//WMS仓储类型
|
||
$sql = "SELECT a.branch_id,b.channel_id,b.node_type FROM sdb_ome_branch AS a LEFT JOIN sdb_channel_channel AS b ON a.wms_id=b.channel_id ";
|
||
$sql .= " WHERE a.branch_id=". $this->__currDlyInfo['branch_id'] ." AND b.channel_type='wms'";
|
||
$row = $this->__dlyObj->db->selectrow($sql);
|
||
if($row){
|
||
$this->__currDlyInfo['wms_type'] = $row['node_type'];
|
||
}
|
||
|
||
//[WMS仓储类型]京东一件代发
|
||
if($this->__currDlyInfo['wms_type'] == 'yjdf'){
|
||
$packageObj = app::get('ome')->model('delivery_package');
|
||
|
||
$packageInfo = $packageObj->dump(array('delivery_id'=>$this->__currDlyId, 'package_bn'=>$data['oid']), 'package_id,package_bn');
|
||
if(empty($packageInfo)){
|
||
$msg = '没有找到包裹单号：'.$data['oid'];
|
||
return false;
|
||
}
|
||
|
||
$this->__currDlyInfo['package_bn'] = $packageInfo['package_bn'];
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 发货单签收详细处理逻辑
|
||
* @param array $data
|
||
*/
|
||
public function _signDly($data)
|
||
{
|
||
//$saveData = array('logi_status'=>3);
|
||
$saveData = array('logistics_status'=>'499','logi_status'=>3);
|
||
$error_msg = '';
|
||
|
||
|
||
//签收时间
|
||
$sign_time = ($data['sign_time'] ? strtotime($data['sign_time']) : time());
|
||
if($sign_time){
|
||
$saveData['sign_time'] = $sign_time;
|
||
}
|
||
|
||
//标记发货单已签收
|
||
$this->__dlyObj->update($saveData, array('delivery_id' => $this->__currDlyId));
|
||
|
||
//日志记录
|
||
$this->__inputParams['memo'] = ($this->__inputParams['memo'] ? $this->__inputParams['memo'] : '发货单已签收');
|
||
$this->__operationLogObj->write_log('delivery_modify@ome', $this->__currDlyId, $this->__inputParams['memo']);
|
||
|
||
//标记当前门店履约订单已核销签收
|
||
if ($this->__isStoreBranch) {
|
||
$dly_order = $this->__currDlyInfo['delivery_order'];
|
||
$order_arr = array_shift($dly_order);
|
||
kernel::single('ome_o2o_performance_orders')->updateProcessStatus($order_arr['order_id'], 'sign');
|
||
}
|
||
|
||
//自提、配送签收发送短消息
|
||
if (kernel::service('message_setting') && defined('APP_TOKEN') && defined('APP_SOURCE')) {
|
||
kernel::single('taoexlib_sms')->sendSms(array('event_type' => 'received', 'delivery_id' => $this->__currDlyId), $error_msg);
|
||
}
|
||
|
||
//只有已签收的货到付款单才自动支付
|
||
if ($this->__currDlyInfo['is_cod'] == 'true' && 'false' != app::get('ome')->getConf('ome.codorder.autopay')) {
|
||
kernel::single('ome_order')->codAutoPay($this->__currDlyId);
|
||
}
|
||
|
||
//订单签收收自动开蓝票埋点
|
||
$funcObj = kernel::single('invoice_func');
|
||
$orderDelivery = app::get('ome')->model('delivery_order')->getList('*', array('delivery_id' => $this->__currDlyId));
|
||
foreach ($orderDelivery as $od) {
|
||
$funcObj->do_einvoice_bill($od['order_id'], "2");
|
||
}
|
||
|
||
//[WMS仓储类型]京东一件代发
|
||
if($this->__currDlyInfo['wms_type'] == 'yjdf' && $this->__currDlyInfo['package_bn']){
|
||
$packageObj = app::get('ome')->model('delivery_package');
|
||
|
||
$saveData = array('shipping_status'=>'18');
|
||
|
||
//签收时间
|
||
if($sign_time){
|
||
$saveData['sign_time'] = $sign_time;
|
||
}
|
||
|
||
$packageObj->update($saveData, array('package_bn'=>$this->__currDlyInfo['package_bn']));
|
||
}
|
||
if($sign_time){
|
||
|
||
foreach($this->__currDlyInfo['delivery_order'] as $dly_order) {
|
||
$order_id = $dly_order['order_id'];
|
||
$orderObj = app::get('ome')->model('orders');
|
||
$orderInfo = $orderObj->dump($order_id, 'order_id,createway');
|
||
if(in_array($orderInfo['createway'], ['local'])) {
|
||
$orderObj->update(array('end_time' => $sign_time), array('order_id' => $order_id));
|
||
|
||
}
|
||
}
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 发货单签收
|
||
* @param array $data
|
||
*/
|
||
private function sign($data)
|
||
{
|
||
$msg_code = '';
|
||
|
||
//初始化类的对象
|
||
$this->_instanceObj();
|
||
|
||
//初始化当前处理发货单的数据
|
||
if (!$this->_initDlyInfo($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $data);
|
||
}
|
||
|
||
//检查当前发货单对应状态是否可以操作
|
||
if (!$this->_checkStatusWhenSign($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
//加入事务机制
|
||
kernel::database()->beginTransaction();
|
||
|
||
//具体发货单签收的详细处理逻辑
|
||
if (!$this->_signDly($data)) {
|
||
|
||
kernel::database()->rollBack();
|
||
|
||
return $this->send_error($msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
// 事务提交
|
||
kernel::database()->commit();
|
||
|
||
// 发货签收后触发服务
|
||
foreach(kernel::servicelist('ome.service.delivery.sign.after') as $service) {
|
||
if(method_exists($service,'after_sign')) {
|
||
$payload = [];
|
||
if (isset($data['sign_time'])) {
|
||
$payload['sign_time'] = $data['sign_time'];
|
||
}
|
||
|
||
$service->after_sign($this->__currDlyId, $payload);
|
||
}
|
||
}
|
||
|
||
|
||
return $this->send_succ();
|
||
}
|
||
|
||
private function _save_bill_logi_weight($bill_logi_weight, $delivery)
|
||
{
|
||
$dliBill = app::get('ome')->model('delivery_bill');
|
||
|
||
foreach ($bill_logi_weight as $k => $val) {
|
||
$bill = array();
|
||
$bill['status'] = '1';
|
||
$bill['logi_no'] = $k;
|
||
$bill['weight'] = $val;
|
||
$bill['delivery_id'] = $delivery['delivery_id'];
|
||
$bill['delivery_bn'] = $delivery['delivery_bn'];
|
||
$bill['create_time'] = $this->__formatParams['delivery_time'];
|
||
$bill['delivery_time'] = $this->__formatParams['delivery_time'];
|
||
|
||
$dliBill->db_save($bill);
|
||
|
||
}
|
||
return true;
|
||
|
||
}
|
||
|
||
/**
|
||
* 换货订单发货回写
|
||
*
|
||
*/
|
||
private function _after_consign_change_order()
|
||
{
|
||
|
||
foreach ($this->__currDlyInfo['delivery_order'] as $v_o) {
|
||
|
||
kernel::single('ome_service_aftersale')->exchange_consigngoods($v_o['order_id']);
|
||
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 追回物流包裹
|
||
*
|
||
* @param unknown $data
|
||
* @return multitype:string unknown |multitype:string NULL
|
||
*/
|
||
private function returnBackDly($data)
|
||
{
|
||
$msg_code = '';
|
||
|
||
//初始化类的对象
|
||
$this->_instanceObj();
|
||
|
||
//初始化当前处理发货单的数据
|
||
if (!$this->_initDlyInfo($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $data);
|
||
}
|
||
|
||
//检查当前发货单对应状态是否可以操作
|
||
if (in_array($this->__currDlyInfo['status'], array('succ', 'return_back')))
|
||
{
|
||
$error_msg = '该发货单不是已发货或打回状态，无法继续操作!';
|
||
$this->send_error($error_msg, $msg_code, $this->__inputParams);
|
||
}
|
||
|
||
//加入事务机制
|
||
kernel::database()->beginTransaction();
|
||
|
||
//更新发货单追回状态
|
||
$affect_row = $this->__dlyObj->update(array('status'=>'return_back'), array('delivery_id'=>$this->__currDlyId));
|
||
if (!is_numeric($affect_row) || $affect_row <= 0)
|
||
{
|
||
kernel::database()->rollBack();
|
||
$msg = '发货单发货状态更新失败!';
|
||
return false;
|
||
}
|
||
|
||
$this->__operationLogObj->write_log('delivery_process@ome', $this->__currDlyId, '发货单包裹追回成功');
|
||
|
||
//事务提交
|
||
kernel::database()->commit();
|
||
|
||
//[兼容]追回包裹成功,自动完成退货单
|
||
$order_ids = array();
|
||
foreach ($this->__currDlyInfo['delivery_order'] as $dlyOrder)
|
||
{
|
||
$order_id = $dlyOrder['order_id'];
|
||
|
||
$order_ids[$order_id] = $order_id;
|
||
}
|
||
|
||
$reshipObj = app::get('ome')->model('reship');
|
||
$reshipList = $reshipObj->getList('reship_id,reship_bn', array('order_id'=>$order_ids, 'is_check'=>array('0', '1')));
|
||
if($reshipList)
|
||
{
|
||
$queueObj = app::get('base')->model('queue');
|
||
|
||
foreach ($reshipList as $key => $val)
|
||
{
|
||
//放入queue队列中执行
|
||
$queueData = array(
|
||
'queue_title' => '退货单号：'. $val['reship_bn'] .'追回包裹成功,自动完成退货单',
|
||
'start_time' => time(),
|
||
'params' => array(
|
||
'sdfdata' => $val,
|
||
'app' => 'oms',
|
||
'mdl' => 'reship',
|
||
),
|
||
'worker'=>'ome_reship.autoCompleteReship',
|
||
);
|
||
$queueObj->save($queueData);
|
||
}
|
||
}
|
||
|
||
return $this->send_succ();
|
||
}
|
||
|
||
/**
|
||
* 仓库作业返回异常状态
|
||
* @param $data
|
||
* @return array|bool
|
||
* @author db
|
||
* @date 2024-01-19 3:30 下午
|
||
*/
|
||
private function abnormal($data)
|
||
{
|
||
$msg_code = '';
|
||
|
||
//初始化类的对象
|
||
$this->_instanceObj();
|
||
|
||
//初始化当前处理发货单的数据
|
||
if (!$this->_initDlyInfo($data, $msg)) {
|
||
return $this->send_error($msg, $msg_code, $data);
|
||
}
|
||
|
||
//更新仓库异常作业状态
|
||
$wms_msg = htmlspecialchars($data['operate_info'], ENT_QUOTES, 'UTF-8');
|
||
$affect_row = $this->__dlyObj->update(array('wms_status' => '5', 'wms_msg' => $wms_msg), array('delivery_id' => $this->__currDlyId));
|
||
if (!is_numeric($affect_row)) {
|
||
$msg = '发货单仓库作业状态更新失败!';
|
||
$this->__operationLogObj->write_log('delivery_process@ome', $this->__currDlyId, '发货单仓库作业返回异常状态');
|
||
}
|
||
|
||
return $this->send_succ();
|
||
}
|
||
}
|