mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-23 02:45:33 +08:00
462 lines
16 KiB
PHP
462 lines
16 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.
|
||
*/
|
||
/**
|
||
* Created by PhpStorm.
|
||
* User: yaokangming
|
||
* Date: 2019/4/23
|
||
* Time: 15:45
|
||
*/
|
||
class erpapi_shop_request_branch extends erpapi_shop_request_abstract {
|
||
|
||
/**
|
||
* feedbackDelivery
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
|
||
public function feedbackDelivery($sdf) {
|
||
$title = '待寻仓订单寻仓回写';
|
||
$results = array(array(
|
||
'order_sn' => $sdf['order_bn'],
|
||
'feedback_status' => 'SUCCESS',
|
||
'warehouse' => $sdf['warehouse']
|
||
));
|
||
$params = array('feed_back_results' => json_encode($results));
|
||
$rsp = $this->__caller->call(SHOP_BRANCH_FEEDBACK, $params, array(), $title, 10, $sdf['order_bn']);
|
||
return $rsp;
|
||
}
|
||
|
||
|
||
/**
|
||
* 创建Warehouse
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
public function createWarehouse($sdf){
|
||
$title = '创建单个区域仓';
|
||
|
||
$params = array(
|
||
|
||
'out_warehouse_id' => $sdf['out_warehouse_id'],
|
||
'name' => $sdf['name'],
|
||
'intro' => $sdf['name'],
|
||
);
|
||
|
||
$rsp = $this->__caller->call(SHOP_CREATE_WAREHOUSE, $params, array(), $title, 10, $sdf['name']);
|
||
|
||
$result = array();
|
||
$result['rsp'] = $rsp['rsp'];
|
||
$result['err_msg'] = $rsp['err_msg'];
|
||
$result['msg_id'] = $rsp['msg_id'];
|
||
$result['res'] = $rsp['res'];
|
||
$data = json_decode($rsp['data'],1);
|
||
$result['data'] = is_array($data) && is_array($data['results']) ? $data['results']['data'] : [];
|
||
|
||
return $result;
|
||
}
|
||
|
||
|
||
/**
|
||
* editWarehouse
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
public function editWarehouse($sdf){
|
||
$title = '编辑单个区域仓';
|
||
|
||
$params = array(
|
||
|
||
'out_warehouse_id' => $sdf['out_warehouse_id'],
|
||
'name' => $sdf['name'],
|
||
'info' => $sdf['name'],
|
||
);
|
||
|
||
$rs = $this->__caller->call(SHOP_EDIT_WAREHOUSE, $params, array(), $title, 10, $sdf['name']);
|
||
return $rs;
|
||
|
||
}
|
||
|
||
/**
|
||
* bindWarehouse
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
public function bindWarehouse($sdf){
|
||
|
||
$title = '绑定地址到区域仓';
|
||
$params = array(
|
||
|
||
'out_warehouse_id' => $sdf['out_warehouse_id'],
|
||
'addr_list' => $sdf['addr'],
|
||
|
||
);
|
||
|
||
$rsp = $this->__caller->call(SHOP_BIND_WAREHOUSE_ADDR, $params, array(), $title, 10, $sdf['out_warehouse_id']);
|
||
|
||
$result = array();
|
||
$result['rsp'] = $rsp['rsp'];
|
||
$result['err_msg'] = $rsp['err_msg'];
|
||
$result['msg_id'] = $rsp['msg_id'];
|
||
$result['res'] = $rsp['res'];
|
||
$data = json_decode($rsp['data'],1);
|
||
$result['data'] = is_array($data) && is_array($data['results']) ? $data['results']['data'] : [];
|
||
|
||
return $result;
|
||
|
||
}
|
||
|
||
/**
|
||
* unbindWarehouse
|
||
* @return mixed 返回值
|
||
*/
|
||
public function unbindWarehouse(){
|
||
$title = '地址与区域仓解绑';
|
||
$params = array(
|
||
|
||
'out_warehouse_id' => $sdf['out_warehouse_id'],
|
||
'addr' => $sdf['addr'],
|
||
);
|
||
|
||
$rs = $this->__caller->call(SHOP_UNBIND_WAREHOUSE_ADDR, $params, array(), $title, 10, $sdf['out_warehouse_id']);
|
||
return $rs;
|
||
}
|
||
|
||
/**
|
||
* 获取Province
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getProvince($sdf){
|
||
$title = '获取四级地址全量省份信息';
|
||
$primary_bn = date('Ymd');
|
||
|
||
$params = array(
|
||
|
||
);
|
||
$rsp = $this->__caller->call(SHOP_GET_ADDRESS_PROVINCE, $params, array(), $title, 10, $primary_bn);
|
||
$result = array();
|
||
$result['rsp'] = $rsp['rsp'];
|
||
$result['err_msg'] = $rsp['err_msg'];
|
||
$result['msg_id'] = $rsp['msg_id'];
|
||
$result['res'] = $rsp['res'];
|
||
$data = json_decode($rsp['data'],1);
|
||
$data = $this->_formatProvinceData($data);
|
||
$area = array();
|
||
foreach($data as $v){
|
||
$area[] = array(
|
||
'shop_type' => $this->__channelObj->channel['node_type'],
|
||
'outregion_id' => $v['province_id'],
|
||
'outregion_name'=> $v['province'],
|
||
'region_grade' => $sdf['region_grade'],
|
||
|
||
);
|
||
}
|
||
$result['data'] = $area;
|
||
return $result;
|
||
}
|
||
|
||
protected function _formatProvinceData($data) {
|
||
if (is_array($data) && is_array($data['results']) && is_array($data['results']['data'])) {
|
||
return $data['results']['data'];
|
||
}
|
||
return [];
|
||
}
|
||
|
||
protected $areaOutregionId = 'code';
|
||
protected $areaOutregionName = 'name';
|
||
protected $areaOutparentId = 'father_code';
|
||
protected function _formatAreasByProvince($data) {
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 获取AreasByProvince
|
||
* @param mixed $data 数据
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getAreasByProvince($data)
|
||
{
|
||
$title = '获取四级地址' . $data['outregion_name'] . '信息';
|
||
|
||
$params = array(
|
||
'province_id' => $data['outregion_id']
|
||
);
|
||
$rsp = $this->__caller->call(STORE_ADDRESS_GETBY_PROVINCE, $params, array(), $title, 10, $data['outregion_name']);
|
||
$result = array();
|
||
$result['rsp'] = $rsp['rsp'];
|
||
$result['err_msg'] = $rsp['err_msg'];
|
||
$result['msg_id'] = $rsp['msg_id'];
|
||
$result['res'] = $rsp['res'];
|
||
$data = json_decode($rsp['data'], 1);
|
||
$data = $this->_formatAreasByProvince($data);
|
||
$address = array();
|
||
foreach ($data as $key => $value) {
|
||
foreach ($value['sub_districts'] as $one => $oneValue) {
|
||
$address[] = array(
|
||
'shop_type' => $this->__channelObj->channel['node_type'],
|
||
'outregion_id' => $oneValue[$this->areaOutregionId],
|
||
'outregion_name' => $oneValue[$this->areaOutregionName],
|
||
'region_grade' => 2,
|
||
'outparent_id' => $oneValue[$this->areaOutparentId],
|
||
);
|
||
foreach ($oneValue['sub_districts'] as $two => $twoValue) {
|
||
$address[] = array(
|
||
'shop_type' => $this->__channelObj->channel['node_type'],
|
||
'outregion_id' => $twoValue[$this->areaOutregionId],
|
||
'outregion_name' => $twoValue[$this->areaOutregionName],
|
||
'region_grade' => 3,
|
||
'outparent_id' => $twoValue[$this->areaOutparentId],
|
||
);
|
||
|
||
if(empty($twoValue['sub_districts'])){
|
||
continue;
|
||
}
|
||
|
||
//镇或者街道
|
||
foreach ($twoValue['sub_districts'] as $threeKey => $threeVal) {
|
||
$address[] = array(
|
||
'shop_type' => $this->__channelObj->channel['node_type'],
|
||
'outparent_id' => $threeVal[$this->areaOutparentId], //父ID
|
||
'outregion_id' => $threeVal[$this->areaOutregionId], //镇或者街道ID
|
||
'outregion_name' => $threeVal[$this->areaOutregionName], //镇或者街道名称
|
||
'region_grade' => 4,
|
||
);
|
||
}
|
||
|
||
}
|
||
}
|
||
}
|
||
$result['data'] = $address;
|
||
return $result;
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取Stock
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getStock($sdf)
|
||
{
|
||
$title = '查询渠道库存['.$sdf['branch_bn'].']';
|
||
|
||
$params = array(
|
||
'out_warehouse_id' => $sdf['branch_bn'],
|
||
'sku_id' => $sdf['material_bn'],
|
||
);
|
||
|
||
$result = $this->__caller->call(SHOP_ITEM_STOCK_GET, $params, array(), $title, 10, $sdf['material_bn']);
|
||
|
||
if ($result['rsp'] == 'succ') {
|
||
$result['data'] = @json_decode($result['data'],true);
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 同步OMS仓库给到翱象系统
|
||
*
|
||
* @param array $params
|
||
* @return array
|
||
*/
|
||
public function createAoxiangWarehouse($branchList)
|
||
{
|
||
$title = '同步OMS仓库给到翱象系统';
|
||
|
||
$original_bn = $branchList[0]['shop_bn'];
|
||
$original_bn = ($original_bn ? $original_bn : date('Ymd', time()));
|
||
|
||
//warehouse
|
||
$warehouse_infos = array();
|
||
foreach ($branchList as $key => $branchInfo)
|
||
{
|
||
$status = ($branchInfo['disabled'] == 'true' ? '0' : '1');
|
||
|
||
//联系人信息
|
||
$contact_info = array (
|
||
'type' => 'mr', //联系人分组：mr=默认组、th=退货组、kf=客服组、rk=入库组、ck=出库组、kn=库内组
|
||
'name' => $branchInfo['uname'], //联系人名称
|
||
'mobile' => $branchInfo['mobile'], //联系人手机
|
||
'tel' => $branchInfo['phone'], //固定电话
|
||
'province' => $branchInfo['province'], //省份
|
||
'city' => $branchInfo['city'], //城市
|
||
'area' => $branchInfo['area'], //地区
|
||
'town' => $branchInfo['town'], //乡镇
|
||
'detail_address' => $branchInfo['address'], //详细地址
|
||
);
|
||
|
||
//仓库信息
|
||
$branchInfo = array (
|
||
'wms_warehouse_code' => $branchInfo['wms_channel_bn'], //WMS仓储编码
|
||
'wms_warehouse_name' => $branchInfo['wms_channel_name'], //WMS仓储名称
|
||
'erp_warehouse_code' => $branchInfo['branch_bn'], //OMS仓库编码
|
||
'erp_warehouse_name' => $branchInfo['branch_name'], //OMS仓库名称
|
||
'erp_warehouse_biz_code' => $branchInfo['branch_bn'], //商家编码
|
||
'province' => $branchInfo['province'], //省份
|
||
'city' => $branchInfo['city'], //城市
|
||
'area' => $branchInfo['area'], //地区
|
||
'town' => $branchInfo['town'], //乡镇
|
||
'detail_address' => $branchInfo['address'], //详细地址
|
||
'zip_code' => $branchInfo['zip'],
|
||
'status' => $status, //状态：0=停用,1=启用
|
||
'contact_infos' => $contact_info, //联系人信息(必填1个)
|
||
);
|
||
|
||
$warehouse_infos[] = $branchInfo;
|
||
}
|
||
|
||
//params
|
||
$requestParams = array(
|
||
//'request_id' => uniqid(),
|
||
//'request_time' => time(),
|
||
'warehouse_infos' => json_encode($warehouse_infos), //仓库数组,最多50条
|
||
);
|
||
|
||
//callback
|
||
$callback = array();
|
||
|
||
//request
|
||
$result = $this->__caller->call(SHOP_AOXIANG_WAREHOUSE_CREATE, $requestParams, $callback, $title, 10, $original_bn);
|
||
|
||
//format
|
||
if($result['rsp'] == 'succ'){
|
||
$dataList = $result['data'];
|
||
|
||
//unset
|
||
unset($result['data']);
|
||
|
||
//string
|
||
if(is_string($dataList)){
|
||
$dataList = json_decode($dataList, true);
|
||
}
|
||
|
||
$detailItems = $dataList['data']['detail']['detail_item'];
|
||
|
||
$resData = array();
|
||
foreach ((array)$detailItems as $key => $val)
|
||
{
|
||
$warehouse_code = $val['warehouse_code'];
|
||
|
||
//check
|
||
if($val['success'] == 1 || $val['success'] == 'true'){
|
||
$resData['succ'][$warehouse_code] = array('warehouse_code'=>$warehouse_code, 'seller_id'=>$val['seller_id']);
|
||
}else{
|
||
$resData['fail'][$warehouse_code] = array('warehouse_code'=>$warehouse_code, 'message'=>$val['message']);
|
||
}
|
||
}
|
||
|
||
$result['datalist'] = $resData;
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 删除翱象系统里OMS同步的仓库
|
||
*
|
||
* @param array $params
|
||
* @return array
|
||
*/
|
||
public function deleteAoxiangWarehouse($branchList)
|
||
{
|
||
$title = '删除翱象系统里OMS同步的仓库';
|
||
|
||
$original_bn = $branchList[0]['shop_bn'];
|
||
$original_bn = ($original_bn ? $original_bn : date('Ymd', time()));
|
||
|
||
//warehouse
|
||
$warehouse_infos = array();
|
||
foreach ($branchList as $key => $branchInfo)
|
||
{
|
||
//联系人信息
|
||
$contact_info = array (
|
||
'type' => 'mr', //联系人分组：mr=默认组、th=退货组、kf=客服组、rk=入库组、ck=出库组、kn=库内组
|
||
'name' => $branchInfo['uname'], //联系人名称
|
||
'mobile' => $branchInfo['mobile'], //联系人手机
|
||
'tel' => $branchInfo['phone'], //固定电话
|
||
'province' => $branchInfo['province'], //省份
|
||
'city' => $branchInfo['city'], //城市
|
||
'area' => $branchInfo['area'], //地区
|
||
'town' => $branchInfo['town'], //乡镇
|
||
'detail_address' => $branchInfo['address'], //详细地址
|
||
);
|
||
|
||
//仓库信息
|
||
$branchInfo = array (
|
||
'wms_warehouse_code' => $branchInfo['wms_channel_bn'], //WMS仓储编码
|
||
'wms_warehouse_name' => $branchInfo['wms_channel_name'], //WMS仓储名称
|
||
'erp_warehouse_code' => $branchInfo['branch_bn'], //OMS仓库编码
|
||
'erp_warehouse_name' => $branchInfo['branch_name'], //OMS仓库名称
|
||
'erp_warehouse_biz_code' => $branchInfo['branch_bn'], //商家编码
|
||
'province' => $branchInfo['province'], //省份
|
||
'city' => $branchInfo['city'], //城市
|
||
'area' => $branchInfo['area'], //地区
|
||
'town' => $branchInfo['town'], //乡镇
|
||
'detail_address' => $branchInfo['address'], //详细地址
|
||
'zip_code' => $branchInfo['zip'],
|
||
'status' => '0', //状态：0=停用,1=启用
|
||
'contact_infos' => $contact_info, //联系人信息(必填1个)
|
||
);
|
||
|
||
$warehouse_infos[] = $branchInfo;
|
||
}
|
||
|
||
//params
|
||
$requestParams = array(
|
||
'warehouse_infos' => json_encode($warehouse_infos), //仓库数组,最多50条
|
||
);
|
||
|
||
//callback
|
||
$callback = array();
|
||
|
||
//request
|
||
$result = $this->__caller->call(SHOP_AOXIANG_WAREHOUSE_CREATE, $requestParams, $callback, $title, 10, $original_bn);
|
||
|
||
//format
|
||
if($result['rsp'] == 'succ'){
|
||
$dataList = $result['data'];
|
||
|
||
//unset
|
||
unset($result['data']);
|
||
|
||
//string
|
||
if(is_string($dataList)){
|
||
$dataList = json_decode($dataList, true);
|
||
}
|
||
|
||
$detailItems = $dataList['data']['detail']['detail_item'];
|
||
|
||
$resData = array();
|
||
foreach ((array)$detailItems as $key => $val)
|
||
{
|
||
$warehouse_code = $val['warehouse_code'];
|
||
|
||
//check
|
||
if($val['success'] == 1 || $val['success'] == 'true'){
|
||
$resData['succ'][$warehouse_code] = array('warehouse_code'=>$warehouse_code, 'seller_id'=>$val['seller_id']);
|
||
}else{
|
||
$resData['fail'][$warehouse_code] = array('warehouse_code'=>$warehouse_code, 'message'=>$val['message']);
|
||
}
|
||
}
|
||
|
||
$result['datalist'] = $resData;
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
}
|