mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-22 10:25:35 +08:00
500 lines
16 KiB
PHP
500 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.
|
||
*/
|
||
|
||
class organization_mdl_organization extends dbeav_model
|
||
{
|
||
|
||
// var $export_name = '企业组织架构';
|
||
public $org_status = array(
|
||
1 => "启用",
|
||
2 => "停用",
|
||
);
|
||
|
||
//企业组织管理页面显示状态
|
||
public function modifier_status($row)
|
||
{
|
||
return $this->org_status[$row];
|
||
}
|
||
|
||
public function modifier_org_type($row)
|
||
{
|
||
if ($row == 2) {
|
||
return '门店';
|
||
} else {
|
||
return '-';
|
||
}
|
||
}
|
||
|
||
//上级组织编码
|
||
public function modifier_parent_no($row)
|
||
{
|
||
if (!$row) {
|
||
return '-';
|
||
} else {
|
||
return $row;
|
||
}
|
||
}
|
||
|
||
//下级组织编码
|
||
public function modifier_child_nos($row)
|
||
{
|
||
if (!$row) {
|
||
return '-';
|
||
} else {
|
||
return $row;
|
||
}
|
||
}
|
||
|
||
//下级组织名称
|
||
public function modifier_child_names($row)
|
||
{
|
||
if (!$row) {
|
||
return '-';
|
||
} else {
|
||
return $row;
|
||
}
|
||
}
|
||
|
||
//导出
|
||
// public function exportName(&$data){
|
||
// $data['name'] = $this->export_name.date("Y-m-d H:i:s");
|
||
// }
|
||
|
||
//输出头标题和数据
|
||
// function fgetlist_csv( &$data,$filter,$offset,$exportType = 1 ){
|
||
// if( !$data['title']){
|
||
// $title = array();
|
||
// foreach($this->io_title('organization') as $k => $v ){
|
||
// $title[] = $this->charset->utf2local($v);
|
||
// }
|
||
// $data['title']['organization'] = '"'.implode('","',$title).'"';
|
||
// }
|
||
// if( !$list=$this->getlist('*',$filter,0,-1) )return false;
|
||
// foreach( $list as $aFilter ){
|
||
// $pRow = array();
|
||
// $detail['org_id'] = $this->charset->utf2local($aFilter['org_id']);
|
||
// $detail['org_name'] = $this->charset->utf2local($aFilter['org_name']);
|
||
// $detail['org_level_num'] = $this->charset->utf2local($aFilter['org_level_num']);
|
||
// $detail['higher_level_id'] = $this->charset->utf2local($aFilter['higher_level_id']);
|
||
// $detail['lower_level_ids'] = $this->charset->utf2local($aFilter['lower_level_ids']); //需要replace ,
|
||
// $detail['lower_level_names'] = $this->charset->utf2local($aFilter['lower_level_names']); //需要replace ,
|
||
// $detail['status'] = $this->charset->utf2local($this->org_status[$aFilter['status']]);
|
||
// foreach( $this->oSchema['csv']['organization'] as $k => $v ){
|
||
// $pRow[$k] = utils::apath( $detail,explode('/',$v) );
|
||
// }
|
||
// $data['contents']['organization'][] = implode(',',$pRow);
|
||
// }
|
||
// return false;
|
||
// }
|
||
|
||
// function export_csv($data,$exportType = 1 ){
|
||
// $output = array();
|
||
// $output[] = $data['title']['organization']."\n".implode("\n",(array)$data['contents']['organization']);
|
||
// echo implode("\n",$output);
|
||
// }
|
||
|
||
//头标题
|
||
// function io_title( $filter, $ioType='csv' ){
|
||
// switch( $filter ){
|
||
// case 'organization':
|
||
// $this->oSchema['csv'][$filter] = array(
|
||
// '*:组织ID' => 'org_id',
|
||
// '*:组织名称' => 'org_name',
|
||
// '*:组织层级' => 'org_level_num',
|
||
// '*:上级ID' => 'higher_level_id',
|
||
// '*:下级ID' => 'lower_level_ids',
|
||
// '*:下级ID名称' => 'lower_level_names',
|
||
// '*:状态' => 'status',
|
||
// );
|
||
// break;
|
||
// }
|
||
// $this->ioTitle[$ioType][$filter] = array_keys( $this->oSchema[$ioType][$filter] );
|
||
// return $this->ioTitle[$ioType][$filter];
|
||
// }
|
||
|
||
/**
|
||
* 导入门店模板的标题
|
||
*
|
||
* @param Null
|
||
* @return Array
|
||
*/
|
||
public function exportTemplate()
|
||
{
|
||
$tmpList = $this->io_title();
|
||
foreach ($tmpList as $v) {
|
||
$title[] = kernel::single('base_charset')->utf2local($v);
|
||
}
|
||
|
||
return $title;
|
||
}
|
||
|
||
/**
|
||
* 导入导出的标题
|
||
*
|
||
* @param $ioType 导入文件格式
|
||
* @return Array
|
||
*/
|
||
public function io_title($ioType = 'csv')
|
||
{
|
||
$this->oSchema['csv'] = array(
|
||
'*:组织编码' => 'org_no',
|
||
'*:组织名称' => 'org_name',
|
||
'*:所属上级(为空视为最高级)' => 'org_parent_name',
|
||
'*:状态' => 'status',
|
||
);
|
||
|
||
$this->ioTitle[$ioType] = array_keys($this->oSchema[$ioType]);
|
||
|
||
return $this->ioTitle[$ioType];
|
||
}
|
||
|
||
/**
|
||
* 准备导入的参数定义
|
||
*
|
||
* @param Null
|
||
* @return Null
|
||
*/
|
||
public function prepared_import_csv()
|
||
{
|
||
$this->ioObj->cacheTime = time();
|
||
}
|
||
|
||
/**
|
||
* 准备导入的数据主体内容部分检查和处理
|
||
*
|
||
* @param Array $data
|
||
* @param Boolean $mark
|
||
* @param String $tmpl
|
||
* @param String $msg
|
||
* @return Null
|
||
*/
|
||
public function prepared_import_csv_obj($data, $mark, $tmpl, &$msg = '')
|
||
{
|
||
return null;
|
||
}
|
||
|
||
/**
|
||
* 准备导入的数据明细内容部分检查和处理
|
||
*
|
||
* @param Array $row
|
||
* @param String $title
|
||
* @param String $tmpl
|
||
* @param Boolean $mark
|
||
* @param Boolean $newObjFlag
|
||
* @param array $msg
|
||
* @return Null
|
||
*/
|
||
public function prepared_import_csv_row($row, $title, &$tmpl, &$mark, &$newObjFlag, &$msg)
|
||
{
|
||
$organizationObj = app::get('organization')->model('organization');
|
||
$orgCheckLib = kernel::single('organization_organizations_check');
|
||
$error_msg = '';
|
||
|
||
if (empty($row)) {
|
||
return true;
|
||
}
|
||
|
||
$mark = false;
|
||
|
||
if (substr($row[0], 0, 1) == '*') {
|
||
$titleRs = array_flip($row);
|
||
$mark = 'title';
|
||
|
||
# [防止重复]记录组织编码
|
||
$this->org_no_list = array();
|
||
$this->org_name_list = array();
|
||
$this->basicm_nums = 1;
|
||
|
||
return $titleRs;
|
||
} else {
|
||
$re = base_kvstore::instance('organization')->fetch('organization-' . $this->ioObj->cacheTime, $fileData);
|
||
|
||
if (!$re) {
|
||
$fileData = array();
|
||
}
|
||
|
||
//判断导入的数量
|
||
if (isset($this->basicm_nums)) {
|
||
$this->basicm_nums++;
|
||
if ($this->basicm_nums > 5000) {
|
||
$msg['error'] = "导入的数量量过大，请减少到5000个以下！";
|
||
return false;
|
||
}
|
||
}
|
||
|
||
//导入数据检查
|
||
if (!$row[0]) {
|
||
$msg['error'] = "组织编码必须填写,组织名称：" . $row[1];
|
||
return false;
|
||
}
|
||
if (strlen($row[0]) > 15) {
|
||
$msg['error'] = "组织编码长度必须在15个字符以内,组织编码：" . $row[0];
|
||
return false;
|
||
}
|
||
|
||
if (!$row[1]) {
|
||
$msg['error'] = "组织名称必须填写,组织编码：" . $row[0];
|
||
return false;
|
||
}
|
||
|
||
if (!$row[3]) {
|
||
$msg['error'] = "状态必须填写,组织编码：" . $row[0];
|
||
return false;
|
||
}
|
||
|
||
//组织编码是否已经存在
|
||
$org_row = $orgCheckLib->check_org_no_exist($row[0], $error_msg);
|
||
if (!$org_row) {
|
||
$msg['error'] = $error_msg . ",组织编码：" . $row[0];
|
||
return false;
|
||
}
|
||
|
||
//组织名称是否已经存在
|
||
$org_row = $orgCheckLib->check_org_name_exist($row[1], $error_msg);
|
||
if (!$org_row) {
|
||
$msg['error'] = $error_msg . ",组织编码：" . $row[0];
|
||
return false;
|
||
}
|
||
$row[3] = trim($row[3]);
|
||
//状态值
|
||
if ($row[3] == "启用") {
|
||
$row[3] = 1;
|
||
} elseif ($row[3] == "停用") {
|
||
$row[3] = 2;
|
||
} else {
|
||
$msg['error'] = "组织状态填写错误：" . $row[0] . ",请填写启用、停用";
|
||
return false;
|
||
}
|
||
|
||
//所属上级(为空视为最高级)
|
||
$org_level_num = 1; //组织层级
|
||
$parent_id = 0;
|
||
$parent_no = '';
|
||
$org_parents_structure = ''; //组织架构结构
|
||
|
||
if (empty($row[2])) {
|
||
$row[4] = 1; #组织层级org_level_num
|
||
} else {
|
||
$tempData = explode('-', $row[2]);
|
||
foreach ($tempData as $key => $val) {
|
||
if (empty($val)) {
|
||
$msg['error'] = "所属上级填写错误,组织编码：" . $row[0];
|
||
return false;
|
||
}
|
||
|
||
#判断上下级是否关联
|
||
$org_filter = array('org_name' => $val, 'org_type' => 1);
|
||
if ($parent_id) {
|
||
$org_filter['parent_id'] = $parent_id;
|
||
}
|
||
|
||
#Check
|
||
$org_row = $organizationObj->dump($org_filter, 'org_id, org_no, org_name');
|
||
if (empty($org_row)) {
|
||
$msg['error'] = "所属组织[" . $val . "]与[" . $tempData[$key - 1] . "]没有关联,组织编码：" . $row[0];
|
||
return false;
|
||
}
|
||
|
||
$parent_id = $org_row['org_id'];
|
||
$parent_no = $org_row['org_no'];
|
||
|
||
$org_parents_structure .= ('/' . $org_row['org_name']);
|
||
|
||
$org_level_num++;
|
||
}
|
||
|
||
$org_parents_structure = substr($org_parents_structure, 1);
|
||
$org_parents_structure = 'mainOrganization:' . $org_parents_structure . ':' . $parent_id;
|
||
}
|
||
|
||
#扩展信息
|
||
$row[4] = $org_level_num;
|
||
$row[5] = $parent_id;
|
||
$row[6] = $parent_no;
|
||
$row[7] = $org_parents_structure;
|
||
|
||
#组织类型(默认为：1)
|
||
$row[8] = 1;
|
||
|
||
#时间
|
||
$dateline = time();
|
||
$row[9] = $dateline; //新建时间create_time
|
||
if ($row[3] == 1) {
|
||
$row[10] = $dateline; //最近启用时间recently_enabled_time
|
||
$row[11] = $dateline; //首次启用时间first_enable_time
|
||
$row[12] = 0; //最近停用时间recently_stopped_time
|
||
} else {
|
||
$row[10] = 0; //最近启用时间recently_enabled_time
|
||
$row[11] = 0; //首次启用时间first_enable_time
|
||
$row[12] = $dateline; //最近停用时间recently_stopped_time
|
||
}
|
||
|
||
#目前组织结构最大支持五层层级
|
||
$chk_org_level = $orgCheckLib->check_org_level($org_level_num, $error_msg);
|
||
if (!$chk_org_level) {
|
||
$msg['error'] = $error_msg . ",组织编码：" . $row[0];
|
||
return false;
|
||
}
|
||
|
||
# [防止重复]检查组织编码
|
||
if (in_array($row[0], $this->org_no_list)) {
|
||
$msg['error'] = 'Line ' . $this->basicm_nums . '：组织编码【' . $row[0] . '】重复！';
|
||
return false;
|
||
}
|
||
$this->org_no_list[] = $row[0];
|
||
|
||
# [防止重复]检查组织名称
|
||
if (in_array($row[1], $this->org_name_list)) {
|
||
$msg['error'] = 'Line ' . $this->basicm_nums . '：组织名称【' . $row[1] . '】重复！';
|
||
return false;
|
||
}
|
||
$this->org_name_list[] = $row[1];
|
||
|
||
$fileData['basicm']['contents'][] = $row;
|
||
base_kvstore::instance('organization')->store('organization-' . $this->ioObj->cacheTime, $fileData);
|
||
}
|
||
|
||
return null;
|
||
}
|
||
|
||
/**
|
||
* 完成导入
|
||
*
|
||
* @param Null
|
||
* @return Null
|
||
*/
|
||
public function finish_import_csv()
|
||
{
|
||
base_kvstore::instance('organization')->fetch('organization-' . $this->ioObj->cacheTime, $data);
|
||
base_kvstore::instance('organization')->store('organization-' . $this->ioObj->cacheTime, '');
|
||
|
||
$oQueue = app::get('base')->model('queue');
|
||
$aP = $data;
|
||
$pSdf = array();
|
||
|
||
$count = 0;
|
||
$limit = 50;
|
||
$page = 0;
|
||
$orderSdfs = array();
|
||
|
||
foreach ($aP['basicm']['contents'] as $k => $aPi) {
|
||
if ($count < $limit) {
|
||
$count++;
|
||
} else {
|
||
$count = 0;
|
||
$page++;
|
||
}
|
||
$pSdf[$page][] = $aPi;
|
||
}
|
||
|
||
foreach ($pSdf as $v) {
|
||
$queueData = array(
|
||
'queue_title' => '企业组织结构导入',
|
||
'start_time' => time(),
|
||
'params' => array(
|
||
'sdfdata' => $v,
|
||
'app' => 'organization',
|
||
'mdl' => 'organization',
|
||
),
|
||
'worker' => 'organization_organizations_to_import.run',
|
||
);
|
||
$oQueue->save($queueData);
|
||
}
|
||
$oQueue->flush();
|
||
|
||
//记录日志
|
||
$operationLogObj = app::get('ome')->model('operation_log');
|
||
$operationLogObj->write_log('organization_import@wms', 0, "批量导入企业组织结构,本次共导入" . count($aP['basicm']['contents']) . "条记录!");
|
||
|
||
return null;
|
||
}
|
||
|
||
public function get_first_parent($org_no)
|
||
{
|
||
$parent = array();
|
||
|
||
$orgMdl = app::get('organization')->model('organization');
|
||
|
||
// 注意：这里需要根据业务逻辑判断是否添加前缀
|
||
// 如果是查询经销商，需要添加BS_前缀
|
||
// 如果是查询门店或公司，不需要添加前缀
|
||
// 由于这个方法没有org_type参数，暂时保持原样，后续可能需要优化
|
||
$org = $orgMdl->db_dump(array('org_no' => $org_no), 'org_no,org_name,org_type,parent_id');
|
||
if (!$org['parent_id']) {
|
||
return $org;
|
||
}
|
||
|
||
$parent_id = $org['parent_id'];
|
||
|
||
do {
|
||
$parent = $orgMdl->db_dump(array('org_id' => $parent_id), 'org_no,org_name,org_type,parent_id');
|
||
|
||
if (!$parent['parent_id']) {
|
||
break;
|
||
}
|
||
|
||
$parent_id = $parent['parent_id'];
|
||
|
||
} while (true);
|
||
|
||
return $parent;
|
||
}
|
||
|
||
public function get_all_children($org_no)
|
||
{
|
||
$children = array();
|
||
|
||
$orgMdl = app::get('organization')->model('organization');
|
||
|
||
// 注意：这里需要根据业务逻辑判断是否添加前缀
|
||
// 如果是查询经销商，需要添加BS_前缀
|
||
// 如果是查询门店或公司，不需要添加前缀
|
||
// 由于这个方法没有org_type参数，暂时保持原样，后续可能需要优化
|
||
$org = $orgMdl->db_dump(array('org_no' => $org_no), 'org_id,org_no,org_name,org_type,parent_id,haschild');
|
||
if (!$org['haschild']) {
|
||
if ($org['org_type'] == '2') {
|
||
$children[] = $org;
|
||
}
|
||
|
||
return $children;
|
||
}
|
||
|
||
$parent_id = $org['org_id'];
|
||
do {
|
||
$org_list = $orgMdl->getList('org_id,org_no,org_name,org_type,parent_id,haschild', array('parent_id' => $parent_id));
|
||
if (!$org_list) {
|
||
break;
|
||
}
|
||
|
||
$parent_id = array(0);
|
||
foreach ($org_list as $key => $value) {
|
||
if (!$value['haschild']) {
|
||
if ($value['org_type'] == '2') {
|
||
$children[] = $value;
|
||
}
|
||
continue;
|
||
}
|
||
|
||
$parent_id[] = $value['org_id'];
|
||
}
|
||
|
||
} while (true);
|
||
|
||
return $children;
|
||
}
|
||
}
|