proFrom = [
'self'=>'产品库',
'tcd'=>'TCD',
'etk'=>'EPC',
];
$this->proFromSelect = ':;self:产品库;tcd:TCD;etk:EPC';
}
public function getDataList($params, $rules = [])
{
$filters = $params['filters'];
$page = $params['page'];
$pagesize = $params['rows'];
$sidx = empty($params['sidx'])? 'wdlist_id': $params['sidx'];
$sord = empty($params['sord']) || empty($params['sidx'])? 'desc': $params['sord'];
$orderby = $params['orderby'];
$table = 'work_data_list(wdl)';
$join = [
"[>]supplier(sup)" => ["wdl.wdlist_sup_id" => "sup_id"],
"[>]adm_user(au)" => ["wdl.wdlist_from_opuser" => "au_id"],
"[>]adm_user(au2)" => ["wdl.wdlist_opuser" => "au_id"],
];
$where = $this->filter2medoo($filters,function(&$field,&$op,&$data){
});
if(!empty($params['keys'])) $where['wdlist_id'] = explode(',', $params['keys']);
if(!empty($params['wdlist_id'])) $where['wdlist_id'] = explode(',', $params['wdlist_id']);
if(!empty($params['wdlist_seq'])) $where['wdlist_seq'] = explode(',', $params['wdlist_seq']);
//无分配权限的，展示分配给自己的数据
if(!\p::isAdmin() && !\p::has('A200','check1') ){
$user = new user();
$arids = $user->getMyPowerRole('A200', ['check2']);
$where['wdi_ar_id'] = $arids? $arids: -1;
$join["[><]work_data_item(wdi)"] = ["wdl.wdlist_id" => "wdi_wdlist_id"];
}
$where['GROUP'] = 'wdlist_id';
$where = $this->listWhere($where,$page,$pagesize,$sidx,$sord,$orderby);
if($page>0 && $pagesize>0){
$fields = '*';
$pages = $this->paging($table,$join,$fields,$where,$page,$pagesize);
$where["LIMIT"] = [$pages['limit'],$pagesize];
}
$fields = ['sup_name', 'sup_code', 'au.au_name(au_name_from)', 'au2.au_name', 'wdl.*'];
$arr = $this->db->select($table,$join,$fields,$where);
if($arr){
$collocation = new collocation();
$collArr = $collocation->getCollItems('work');
$wdlIds = array_column($arr, 'wdlist_id');
//清洗
$rows = $this->db->select('work_data_item', ['wdi_wdlist_id', 'item_count'=>raw('count(*)'), 'clean_count'=>raw('(sum(case when wdi_clean = 1 then 1 else 0 end))'), 'clean_has_count'=>raw('(sum(case when wdi_clean_has = 1 then 1 else 0 end))'), 'dstatusok_count'=>raw('(sum(case when wdi_dstatus > 0 then 1 else 0 end))')], ['wdi_wdlist_id'=>$wdlIds, 'GROUP'=>'wdi_wdlist_id']);
$tj1 = array_column($rows, null, 'wdi_wdlist_id');
//存在的零件库
$sql = sprintf("SELECT wdi_wdlist_id, count(distinct wdi_id) poe_has_count FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN oe_numidx ON wdif_pf_id=on_pf_id AND wdif_search=on_formart
JOIN oe_item ON on_oe_id=oe_id
WHERE (wdi_cat_id = 0 OR wdi_cat_id = oe_cate_id) AND wdi_wdlist_id IN (%s) GROUP BY wdi_wdlist_id", implode(',', $wdlIds));
$rows = $this->db->query($sql)->fetchAll();
if(!empty($rows)) $tj2 = array_column($rows, null, 'wdi_wdlist_id');
//存在的供应商
$sql = sprintf("SELECT wdi_wdlist_id, count(distinct wdi_id) sup_has_count FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN oe_numidx ON wdif_pf_id=on_pf_id AND wdif_search=on_formart
JOIN supplier_pro ON spr_oe_id=on_oe_id
WHERE (wdi_cat_id = 0 OR wdi_cat_id = spr_cat_id) AND wdi_wdlist_id IN (%s) group by wdi_wdlist_id", implode(',', $wdlIds));
$rows = $this->db->query($sql)->fetchAll();
if(!empty($rows)) $tj3 = array_column($rows, null, 'wdi_wdlist_id');
//存在的商品库
$sql = sprintf("SELECT wdi_wdlist_id, count(distinct wdi_id) pro_has_count FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN pro_numidx ON wdif_pf_id=pn_pf_id AND wdif_search=pn_formart
JOIN pro ON p_id=pn_p_id and p_pb_id = 1
WHERE (wdi_cat_id = 0 OR wdi_cat_id = p_cate) AND wdi_wdlist_id IN (%s) group by wdi_wdlist_id", implode(',', $wdlIds));
$rows = $this->db->query($sql)->fetchAll();
if(!empty($rows)) $tj4 = array_column($rows, null, 'wdi_wdlist_id');
$roleArr = $this->db->select('work_data_item',['[><]adm_role'=>['wdi_ar_id'=>'ar_id']],['wdi_wdlist_id','ar_name'=>raw('GROUP_CONCAT(DISTINCT ar_name)')],['wdi_wdlist_id'=>$wdlIds,'GROUP'=>'wdi_wdlist_id']);
$roleArr = array_column($roleArr,null,'wdi_wdlist_id');
foreach($arr as &$v){
if($tj1[$v['wdlist_id']]) $v = array_merge($v, $tj1[$v['wdlist_id']]);
if($tj2[$v['wdlist_id']]) $v = array_merge($v, $tj2[$v['wdlist_id']]);
if($tj3[$v['wdlist_id']]) $v = array_merge($v, $tj3[$v['wdlist_id']]);
if($tj4[$v['wdlist_id']]) $v = array_merge($v, $tj4[$v['wdlist_id']]);
$v['captions']['wdlist_from_opuser'] = $v['au_name_from'];
$v['captions']['wdlist_opuser'] = $v['au_name'];
$v['captions']['wdlist_type'] = !empty($collArr[$v['wdlist_type']])? $collArr[$v['wdlist_type']]: '';
$v['ar_name'] = $roleArr[$v['wdlist_id']]['ar_name']??'';
}
unset($v);
}
$data = [
'page'=> $page,
'total'=> $pages['total'],
'records' => $pages['records'],
'rows' => $arr
];
return $data;
}
public function formatWordDataCols($wdlist_id)
{
$row = $this->db->get('work_data_list', '*', ['wdlist_id'=>$wdlist_id]);
$row['cols'] = json_decode($row['wdlist_cols'], true);
return $row;
}
//数据工单的明细
public function getDataItemList($params, $rules = [])
{
$filters = $params['filters'];
$page = $params['page'];
$pagesize = $params['rows'];
if(empty($params['sidx'])){
$sidx = 'wdi_id';
$sord = 'desc';
}else{
$sidx = $params['sidx'];
$sord = $params['sord'];
}
$orderby = $params['orderby'];
$refiled = [
'cat_name'=>'cat.'.cateName(),
'pcat_name'=>'pcat.'.cateName()
];
$this->set('refiled', $refiled);
$sidx = strtr($sidx, $refiled);
$table = 'work_data_item(wdi)';
$join = [
"[><]work_data_list(wdl)" => ["wdi.wdi_wdlist_id" => "wdlist_id"],
"[>]pro_cate(cat)" => ["wdi.wdi_cat_id" => "id"],
"[>]pro_cate(pcat)" => ["cat.parent_id" => "id"],
"[>]adm_role(ar)" => ["wdi.wdi_ar_id" => "ar_id"],
"[>]adm_user(au)" => ["wdi.wdi_opuser" => "au_id"],
"[>]adm_user(au2)" => ["wdi.wdi_from_opuser" => "au_id"],
];
$this->set('pnumwhere', []);
$where = $this->filter2medoo($filters,function(&$field,&$op,&$data){
$field = strtr( $field, $this->get('refiled'));
if($field == 'chkok'){
$op = 'RAW_'.$field;
if($data == 1){
$data = raw(" wdi_chkpro_id!=0");
}else{
$data = raw(" wdi_chkpro_id=0");
}
}else if($field == 'wdi_chkpro_from'){
if($data == 'oth'){
$op = 'RAW_'.$field;
$data = raw(" wdi_chkpro_from not in ('', 'selft')");
}
}else if($field == 'chknums'){
if($op == 'eq'){
$where = "wdif_search = '".formatNum($data)."'";
}else if($op == 'bw'){
$where = "wdif_search like '%".formatNum($data)."%'";
}else{
$where = "wdif_search like '".formatNum($data)."%'";
}
$op = 'RAW_'.$field;
$data = raw(" wdi_id in (select wdif_wdi_id from work_data_item_format where wdif_type='Number' and ".$where.")");
}else if($field == 'chk_poes'){
$op = 'RAW_'.$field;
if($data == '-1'){
$data = raw(" wdi_id not in (SELECT distinct wdif_wdi_id FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN oe_numidx ON wdif_pf_id=on_pf_id AND wdif_search=on_formart
JOIN oe_item ON on_oe_id=oe_id
WHERE (wdi_cat_id = 0 OR wdi_cat_id = oe_cate_id)
)");
}else{
$data = raw(" wdi_id in (SELECT distinct wdif_wdi_id FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN oe_numidx ON wdif_pf_id=on_pf_id AND wdif_search=on_formart
JOIN oe_item ON on_oe_id=oe_id
WHERE (wdi_cat_id = 0 OR wdi_cat_id = oe_cate_id)
)");
}
}else if($field == 'chk_pcs'){
$op = 'RAW_'.$field;
if($data == '-1'){
$data = raw(" wdi_id not in (
SELECT distinct wdif_wdi_id FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN pro_numidx ON wdif_pf_id=pn_pf_id AND wdif_search=pn_formart
JOIN pro ON p_id=pn_p_id and p_pb_id = 1
WHERE (wdi_cat_id = 0 OR wdi_cat_id = p_cate)
)");
}else{
$data = raw(" wdi_id in (
SELECT distinct wdif_wdi_id FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN pro_numidx ON wdif_pf_id=pn_pf_id AND wdif_search=pn_formart
JOIN pro ON p_id=pn_p_id and p_pb_id = 1
WHERE (wdi_cat_id = 0 OR wdi_cat_id = p_cate)
)");
}
}else if($field == 'chk_sups'){
$op = 'RAW_'.$field;
if($data == '-1'){
$data = raw(" wdi_id not in (
SELECT DISTINCT wdif_wdi_id FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN oe_numidx ON wdif_pf_id=on_pf_id AND wdif_search=on_formart
JOIN supplier_pro ON spr_oe_id=on_oe_id
WHERE wdif_type='Number' AND (wdi_cat_id = 0 OR wdi_cat_id = spr_cat_id)
)");
}else{
$data = raw(" wdi_id in (SELECT DISTINCT wdif_wdi_id FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN oe_numidx ON wdif_pf_id=on_pf_id AND wdif_search=on_formart
JOIN supplier_pro ON spr_oe_id=on_oe_id WHERE wdif_type='Number' AND (wdi_cat_id = 0 OR wdi_cat_id = spr_cat_id))");
}
}else if($field == 'cleandes_tcd'){
$op = 'RAW_'.$field;
if($data == '-1'){
$data = raw("JSON_CONTAINS_PATH(wdi_clean_result, 'one', '$.data.tcd') != 1");
}else{
$data = raw("JSON_CONTAINS_PATH(wdi_clean_result, 'one', '$.data.tcd') = 1");
}
}else if($field == 'cleandes_etk'){
$op = 'RAW_'.$field;
if($data == '-1'){
$data = raw("JSON_CONTAINS_PATH(wdi_clean_result, 'one', '$.data.etk') != 1");
}else{
$data = raw("JSON_CONTAINS_PATH(wdi_clean_result, 'one', '$.data.etk') = 1");
}
}else if($field == 'ar_name'){
$field = 'RAW #ar_name';
$data = raw(sprintf(" wdi_wdlist_id IN (select distinct wdi_wdlist_id from work_data_item join adm_role on wdi_ar_id=ar_id where ar_name like '%%%s%%')",$data));
}else if($field == 'cat.'.cateName()){
if($data == 'Y'){
$op = 'RAW_'.$field;
$data = raw(" wdi_cat_id > 0");
}else if($data == 'N'){
$op = 'RAW_'.$field;
$data = raw(" wdi_cat_id = 0");
}
}
});
foreach($rules as $filed=>$val){
if(empty($val)) continue;
switch($filed){
case 'p_cate': $where['wdi_cat_id'] = explode(',', $rules['p_cate']); break;
case 'numbers':
$tnums = [];
foreach($val as $tk=>$tv){
$tnums = array_merge($tnums, reSearchNum($tv));
}
$tnums = array_unique($tnums);
$where['wdif_search'.($rules['numlike']? '[~]': '')] = $tnums;
$join['[><]work_data_item_format(wdif)'] = ['wdi.wdi_id'=>'wdif_wdi_id'];
break;
}
}
if($params['wdlist_id']) $where['wdlist_id'] = $params['wdlist_id'];
if(!empty($params['keys'])) $where['wdi_id'] = explode(',', $params['keys']);
//无分配权限的，展示分配给自己的数据
if(!\p::isAdmin() && !\p::has('A200','check1') ){
$user = new user();
$arids = $user->getMyPowerRole('A200', ['check2']);
$where['wdi_ar_id'] = $arids? $arids: -1;
}
$cates = \p::cates('A200');
if(!\p::isAdmin() && $cates){
$where['AND #rule_cate']['wdi_cat_id'] = explode(',',$cates);
}
$where = $this->listWhere($where,$page,$pagesize,$sidx,$sord,$orderby);
if($page>0 && $pagesize>0){
$fields = '*';
$pages = $this->paging($table,$join,$fields,$where,$page,$pagesize);
$where["LIMIT"] = [$pages['limit'],$pagesize];
}
$fields = ['cat.id(cat_id)', 'pcat.'.cateName().'(pcat_name)', 'cat.'.cateName().'(cat_name)', 'wdl.wdlist_id', 'wdl.wdlist_seq', 'wdi.*','ar_name', 'au.au_name', 'au2.au_name(au_name_from)'];
$arr = $this->db->select($table,$join,$fields,$where);
$wdlCols = $this->formatWordDataCols($wdlist_id);
if(!empty($arr)){
$wdiIds = array_column($arr, 'wdi_id');
$join = [
"[>]pro_factory(fac)" => ["wdif_pf_id" =>"pf_id"]
];
//$rows = $this->db->select('work_data_item_format', $join, ['wdif_wdi_id', 'wdif_id', 'pf_name', 'wdif_val', 'wdif_search'], ['wdif_type'=>'Number', 'wdif_wdi_id'=>$wdiIds, 'ORDER'=>['pf_name', 'wdif_search']]);
$rows = $this->db->select('work_data_item_format', $join, '*', ['wdif_type'=>'Number', 'wdif_wdi_id'=>$wdiIds]);
$nums = [];
$tnums = [];
foreach($rows as $rv){
$nums[$rv['wdif_wdi_id']][] = ['wdif_id'=>$rv['wdif_id'], 'factory'=>$rv['pf_name'], 'number'=>$rv['wdif_val'], 'format'=>$rv['wdif_search'], 'ok'=>1, 'pf_id'=>$rv['pf_id'], 'wdif_isborrow'=>$rv['wdif_isborrow']];
$tnums[] = $rv['wdif_search'];
}
//EDC
$wdzyArr = [];
if($tnums){
$resource = new resource();
$rows = $resource->getResourcesByNum(array_unique($tnums));
//每个号码每个工厂只取一条
foreach($rows as $row){
$row['num_format'] = formatNum($row['rnumber']);
if(empty($wdzyArr[$row['num_format']][$row['resourceFactoryId']]))
$wdzyArr[$row['num_format']][$row['resourceFactoryId']] = $row;
}
}
//存在的零件库
$poes = [];
$wdipoes = [];
$sql = sprintf("SELECT wdif_id, wdif_wdi_id, oe_id, pf_name, oe_oe FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN oe_numidx ON wdif_pf_id=on_pf_id AND wdif_search=on_formart
JOIN oe_item ON on_oe_id=oe_id
JOIN pro_factory on pf_id = oe_pf_id
WHERE (wdi_cat_id = 0 OR wdi_cat_id = oe_cate_id) AND wdif_wdi_id IN (%s)", implode(',', $wdiIds));
$rows = $this->db->query($sql)->fetchAll();
if(!empty($rows)){
foreach($rows as $rv){
$poes[$rv['wdif_wdi_id']][$rv['oe_id']] = $rv;
$wdipoes[$rv['wdif_id']] = $rv;
}
}
//存在的供应商
$sups = [];
$wdisups = [];
$supnameField = \p::has('C500','view')? 'sup_name': 'sup_code as sup_name';
$supnameField2 = \p::has('C500','view')? 'sup_name': 'sup_code';
$sql = sprintf("SELECT wdif_id, wdif_wdi_id,sup_id, %s,spr_id FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN oe_numidx ON wdif_pf_id=on_pf_id AND wdif_search=on_formart
JOIN supplier_pro ON spr_oe_id=on_oe_id
JOIN supplier ON spr_sup_id=sup_id
LEFT JOIN object ON sup_level=o_id WHERE wdif_type='Number' AND (wdi_cat_id = 0 OR wdi_cat_id = spr_cat_id) AND wdif_wdi_id IN (%s) group by wdif_id, sup_id ORDER BY o_sort,%s", $supnameField, implode(',', $wdiIds), $supnameField2);
$rows = $this->db->query($sql)->fetchAll();
if(!empty($rows)){
foreach($rows as $rv){
$sups[$rv['wdif_wdi_id']][$rv['sup_id']] = $rv;
$wdisups[$rv['wdif_id']][] = $rv;
}
}
//存在的商品库
$pcs = [];
$wdipcs = [];
$sql = sprintf("SELECT wdif_id, wdif_wdi_id, p_id, p_innum p_innum FROM work_data_item_format
JOIN work_data_item ON wdi_id = wdif_wdi_id
JOIN pro_numidx ON wdif_pf_id=pn_pf_id AND wdif_search=pn_formart
JOIN pro ON p_id=pn_p_id and p_pb_id = 1
WHERE (wdi_cat_id = 0 OR wdi_cat_id = p_cate) AND wdif_wdi_id IN (%s) group by wdif_id, p_id order by p_innum", implode(',', $wdiIds));
$rows = $this->db->query($sql)->fetchAll();
if(!empty($rows)){
foreach($rows as $rv){
$pcs[$rv['wdif_wdi_id']][$rv['p_id']] = $rv;
$wdipcs[$rv['wdif_id']][$rv['p_id']] = $rv;
}
}
foreach($arr as &$v){
$v['nums'] = $nums[$v['wdi_id']]? $nums[$v['wdi_id']]: [];
$v['poes'] = $poes[$v['wdi_id']]? $poes[$v['wdi_id']]: [];
$v['sups'] = $sups[$v['wdi_id']]? array_values($sups[$v['wdi_id']]): [];
$v['pcs'] = $pcs[$v['wdi_id']]? array_values($pcs[$v['wdi_id']]): [];
//文档资源
$v['wdzy'] = [];
foreach($v['nums'] as $nv){
$numf = $nv['format'];
if(empty($wdzyArr[$numf])) continue;
foreach($wdzyArr[$numf] as $fac=>$row){
if(!$v['wdzy'][$fac]){
$v['wdzy'][$fac] = [
'fac_resource_facid'=>$row['resourceFactoryName'],
'fac_name'=>$row['resourceFactoryName'],
'pro_name'=>$row['partName'],
'pro_number'=>$row['number'],
'from_time'=>date('Y-m-d', strtotime($row['resourceProvideTime'])),
];
}
}
}
$v['wdzy'] = array_values($v['wdzy']);
if(empty($v['wdi_chkpro_id'])) $v['wdi_chkpro_id'] = '';
$v['chkok'] = $v['wdi_chkpro_from'] && $v['wdi_chkpro_id'] ? $v['wdi_chkpro_from'].'@'.$v['wdi_chkpro_id']: '';
$cleanArr = empty($v['wdi_clean_result']) ? []: json_decode($v['wdi_clean_result'], true);
$chkproArr = empty($v['wdi_chkpro_clean_result']) ? []: json_decode($v['wdi_chkpro_clean_result'], true);
//哪些号码是异常的
if($cleanArr['errnum'] && $v['nums']){
foreach($v['nums'] as $tk=>$tv){
foreach($cleanArr['errnum'] as $tvv){
if($tvv['format'] == formatNum($tv['number'])){
$v['nums'][$tk]['err'] = 1;
}
}
}
}
//号码检测
$combtn = count($v['nums']) > 1? '比较': '';
$v['chknums'] = '';
$wdi_chkpro_info = empty($v['wdi_chkpro_info']) ? []: json_decode($v['wdi_chkpro_info'], true);
$v['img'] = $wdi_chkpro_info['pro_img']? $wdi_chkpro_info['pro_img']: '';
$v['chkok_para'] = '';
if(!empty($chkproArr['para'])){
foreach($chkproArr['para'] as $tv){
$v['chkok_para'] .= ''.($tv['cn_name']? $tv['cn_name']: $tv['name']).' : '.$tv['val'].$tv['unit'].'
';
}
}
$v['chk_poes'] = '';
if(!empty($v['poes'])){
$v['chk_poes'] .= '';
}
$v['chk_sups'] = '';
if(!empty($v['sups'])){
$v['chk_sups'] .= '';
foreach($v['sups'] as $tpk=>$tpv){
$v['chk_sups'] .= '- '.$tpv['sup_name'].'
';
}
$v['chk_sups'] .= '
';
}
//检测产品库
$v['chk_pcs'] = '';
$v['chkpro_url'] = '';
if(!empty($v['pcs'])){
$v['chk_pcs'] .= '';
foreach($v['pcs'] as $tpk=>$tpv){
$tpv['pro_url'] = \mvc::$cfg['sitePath'].'/pro/detail?tab=base&p_id='.$tpv['p_id'];
$v['chk_pcs'] .= '- '.$tpv['p_innum'].'
';
}
$v['chk_pcs'] .= '
';
}
$chkok_org = $chkproArr['pro']['art_show'] == 'org'? ' [人工]': '';
//数据清洗
$v['cleandes_tcd'] = '';
$v['captions']['wdi_chkpro_from'] = $this->proFrom[$v['wdi_chkpro_from']]? $this->proFrom[$v['wdi_chkpro_from']] : ($v['wdi_chkpro_from']? $this->proFrom['oth']: '');
if(!empty($cleanArr['data'])){
foreach(['tcd', 'etk'] as $type){
if(empty($cleanArr['data'][$type])) continue;
$tdata = $cleanArr['data'][$type];
$v['cleandes_'.$type] = '';
if($tdata['from'] == 'tcd'){//tcd源
$v['cleandes_'.$type] .= '
';
}else{//其他数据源
$v['cleandes_'.$type] .= '
';
$comnums = [];
foreach($tdata['pros'] as $tpk=>$tpv){
$valkey = $tdata['from'].'@'.$tpv['pro_id'];
$prochk = $v['chkok'] == $valkey? ' checked': '';
if($v['chkok'] == $valkey){
$v['chkpro_url'] = $tpv['pro_url'];
$v['captions']['chkok'] = '';
$prochk .= ' haschkok="1"';
}
$isnew = '';
if($tdata['from'] == 'etk'){
$tpv['pro_name'] = trim($tpv['grp1_name']).'
'.$tpv['grp2_name'].'
'.$tpv['pro_name'];
if($tpv['isnew'] == -1) $isnew = '【旧】';
}
$v['cleandes_'.$type] .= ''.$tpv['pro_name'].'
: '.$tpv['num'][0]['display'].''.$isnew;
$comnums[] = 'OE:'.$tpv['num'][0]['display'];
if($tdata['from'] == 'etk' && !empty($tpv['renum'])){
$v['cleandes_'.$type] .= '替换号
';
foreach($tpv['renum'] as $tpk=>$tpv){
$v['cleandes_'.$type] .= '
'.$tpv.($tpk === 0? '【新】': '').'
';
$comnums[] = 'OE:'.$tpv;
}
$v['cleandes_'.$type] .= '
';
$comnums = array_unique($comnums);
if(count($comnums) > 1) $v['cleandes_'.$type] .= '
比较';
}
$v['cleandes_'.$type] .= '
'.($tv['factory']? $tv['factory'].': ' : '').$tv['number'].'
';
}
$v['captions']['wai_oe_id'] = $v['oe_id']? ''.$v['pf_name'].': '.$v['oe_oe'].'': '';
$v['poe_img_big'] = $v['filepath']? $v['filepath'].'/'.$v['filebasename'].'big.'.$v['fileextname']: '';
$v['poe_img_small'] = $v['filepath']? $v['filepath'].'/'.$v['filebasename'].'small.'.$v['fileextname']: '';
$v['captions']['ref_price'] = '';
if(!empty($v['ref_price'])){
foreach($v['ref_price'] as $type=>$tpvs){
$v['captions']['ref_price'] .= '';
foreach($tpvs as $tpv){
$btns = '';
if($v['was_status'] != 1)
$btns = '';
if($tpv['from_type'] == 'pro_api'){
$tpv['pro_url'] = \mvc::$cfg['sitePath'].'/pro/detail?p_id='.$tpv['p_id'];
$v['captions']['ref_price'] .= '-
'.$btns.'【'.$tpv['from_name'].'】
最小起订量: '.$tpv['wai_minbuy'].''.$tpv['wai_price_name'].'('.$tpv['was_money_type'].'): '.$tpv['wai_price'].'
';
}else if($tpv['from_type'] == 'old_ask'){
$tpv['pro_url'] = \mvc::$cfg['sitePath'].'/work/askItemList?keys='.$tpv['wai_id'];
$v['captions']['ref_price'] .= '-
'.$btns.'【'.$tpv['from_name'].'】'.date('Y-m-d', strtotime($tpv['from_time'])).'
供应商: '.$tpv['sup_name'].'
成本价: '.$tpv['wai_cost_price'].'销售价('.$tpv['was_money_type'].'): '.$tpv['wai_price'].'
';
}else if($tpv['from_type'] == 'sup_pro'){
$tpv['pro_url'] = \mvc::$cfg['sitePath'].'/element/listView?elename=supplier_pro&rules=spr_id:'.$tpv['spr_id'];
$v['captions']['ref_price'] .= '-
'.$btns.'【'.$tpv['from_name'].'】'.date('Y-m-d', strtotime($tpv['from_time'])).'
含税价: '.$tpv['wai_cost_price'].'指导价: '.$tpv['wai_price'].'
';
}else if($tpv['from_type'] == 'resource'){
$tpv['pro_url'] = "javascript:qg.page.open('EDC', '".\mvc::$cfg['sitePath']."/pro/sourceSearch?nums=".$tpv['nums']."&type=num')";
$v['captions']['ref_price'] .= '-
【'.$tpv['from_name'].'】'.date('Y-m-d', strtotime($tpv['from_time'])).'
';
if($tpv['pro_name']) $v['captions']['ref_price'] .= '名称: '.$tpv['pro_name'].'
';
if($tpv['pro_price']) $v['captions']['ref_price'] .= '价格: '.$tpv['pro_price'].'
';
$v['captions']['ref_price'] .= ' ';
}
}
$v['captions']['ref_price'] .= '
';
}
}
$v['captions']['wai_sup_id'] = $v['sup_name'];
$v['captions']['wai_pb_id'] = $v['pb_name'];
$v['captions']['u_level'] = !empty($collArr[$v['u_level']])? $collArr[$v['u_level']]: '';
$v['captions']['wai_opuser'] = $v['au_name'];
$v['captions']['wai_cost_opuser'] = $v['au_cost_name'];
$v['captions']['wai_price_opuser'] = $v['au_price_name'];
$v['wai_data'] = empty($v['wai_data']) ? []: json_decode($v['wai_data'], true);
foreach($v['wai_data'] as $kk=>$vv){
$v['col_'.$kk] = $vv;
}
unset($v['wai_data']);
}
}
$data = [
'page'=> $page,
'total'=> $pages['total'],
'records' => $pages['records'],
'rows' => $arr
];
return $data;
}
//获取询单项有哪些参考价格 $type = autoPrice时只处理能用于自动填充价格的
public function getAskItemRefPrice($waiIdArr, $type = '')
{
$arr = [];
$join = [
"[><]work_ask(was)" => ["wai.wai_was_id" => "was_id"],
"[>]company(com)" => ["was.was_com_id" => "com_id"]
];
$rows = $this->db->select('work_ask_item(wai)', $join, '*', ['wai_id'=>$waiIdArr]);
if(empty($rows)) return $arr;
$waiArr = [];//明细项角度
$wasArr = [];//询单角度
foreach($rows as $row){
$row['wai_refprice_cache'] = $row['wai_refprice_cache']? json_decode($row['wai_refprice_cache'], true): [];
$waiArr[$row['wai_id']] = $row;
$wasArr[$row['was_id']][] = $row;
}
//事业部对应的商品
foreach($wasArr as $items){
//询单明细零件ID=>集团ID=>事业部
$sql = sprintf("SELECT wai_id, p.p_id, p.p_innum, pb_id, pb_%s pb_name, wai_count FROM pro p
JOIN pro_brand ON pb_id = p.p_pb_id
JOIN pro p1 ON p.p_lnk_p_id = p1.p_id
JOIN work_ask_item ON p1.p_oe_id = wai_oe_id
JOIN pro_link_company ON p.p_id = plc_p_id and plc_com_id = %d
WHERE wai_id IN (%s) GROUP BY wai_id, p.p_id ORDER BY pb_cn_name, p.p_innum_format", LG_NAME, $items[0]['was_com_id'], implode(',', array_column($items, 'wai_id')));
$rows = $this->db->query($sql)->fetchAll();
if($rows){
$link = []; $allnums = [];
foreach($rows as $row){
$link[$row['wai_id']][] = $row;
$allnums[] = $row['p_innum'];
}
$allnums = array_unique($allnums);
$freyApi = new \model\freyApi();
$numPrices = [];
foreach(array_chunk($allnums, 500) as $nums){
$post = [
'company_sap_no'=>$items[0]['com_code'],
'partner_sap_no'=>$items[0]['was_u_code'],
'frey_nos'=>implode(',', $nums)
];
//物料编码对应的价格
$post = json_encode($post, JSON_UNESCAPED_UNICODE);
$fres = $freyApi->httpCurl('/Pic.Pic/GetCompanyProductPrices', 'POST', $post, ["Content-Type:application/json"]);
if(isset($fres['data']['price_list']) && $fres['data']['price_list']){
foreach($fres['data']['price_list'] as $v){
if(empty($v['price'])) continue;
$numPrices[$v['frey_no']][] = $v;
}
}
}
//汇总到明细
foreach($link as $wai_id=>$ivs){
foreach($ivs as $iv){
if(empty($numPrices[$iv['p_innum']])) continue;
$row = $iv;
$priceInfo = $numPrices[$iv['p_innum']][0];
$row['from_type'] = 'pro_api';
$row['from_name'] = '商品接口';
$row['was_money_type'] = 'CNY';
$row['was_money_rate'] = 1;
$row['wai_minbuy'] = $priceInfo['min_quantity'];
$row['wai_price'] = $priceInfo['price'];
$row['wai_price_name'] = $priceInfo['price_name'];
$arr[$wai_id]['pro_api'][] = $row;
}
}
}
}
//历史询单
$sql = sprintf("SELECT *
FROM (
SELECT
sorted.*,
@row_number := IF(@prev_id = sorted.my_wai_id, @row_number + 1, 1) AS rn,
@prev_id := sorted.my_wai_id
FROM (
SELECT myin.wain_wai_id my_wai_id, 'old_ask' from_type, '询单' from_name, oa.was_id, oa.was_u_code, oi.wai_id, sup_id, sup_name, sup_code, wai_count, wai_cost_price, wai_cost_opuser, wai_cost_time, oa.was_money_type, oa.was_money_rate, wai_price, oa.was_create_time from_time,wai_pb_id pb_id, wai_hasshui, wai_tuishui, wai_haspack, wai_delivery, wai_minbuy
FROM work_ask_item_num oin
JOIN work_ask_item_num myin ON oin.wain_format = myin.wain_format AND oin.wain_wai_id != myin.wain_wai_id AND (oin.wain_pf_name = myin.wain_pf_name OR myin.wain_pf_name = '' AND oin.wain_pf_name != '')
JOIN work_ask mya ON myin.wain_was_id = mya.was_id
JOIN work_ask_item oi ON oi.wai_id = oin.wain_wai_id
LEFT JOIN supplier ON sup_id = oi.wai_sup_id
JOIN work_ask oa ON oa.was_id = oin.wain_was_id
WHERE myin.wain_wai_id IN (%s) AND wai_status = 1 ORDER BY myin.wain_wai_id, FIND_IN_SET(oa.was_u_code, mya.was_u_code) DESC, wai_id DESC
) AS sorted,
(SELECT @row_number := 0, @prev_id := NULL) AS vars
) AS ranked
WHERE ranked.rn = 1
ORDER BY ranked.my_wai_id", implode(',', array_keys($waiArr)));
$rows = $this->db->query($sql)->fetchAll();
if($rows){
foreach($rows as $row){
$arr[$row['my_wai_id']]['old_ask'][] = $row;
}
}
//零件供应商
$oeids = array_unique(array_column($waiArr, 'wai_oe_id'));
$supnameField = \p::has('C500','view')? 'sup_name': 'sup_code sup_name';
$sql = sprintf("SELECT spr_oe_id oe_id,'sup_pro' from_type, '零件供应商' from_name, sup_id, %s, sup_code, spr_id, oa.%s price_area, spr_price wai_cost_price, 'CNY' was_money_type, 1 was_money_rate, spr_price4 wai_price, spr_update_time from_time, spr_delivery wai_delivery, spr_minbuy wai_minbuy
FROM `supplier_pro` JOIN `supplier` ON sup_id = spr_sup_id
LEFT JOIN object oa ON o_id = spr_area
WHERE spr_oe_id in (%s)", $supnameField, LG_NAME, implode(',', $oeids));
$rows = $this->db->query($sql)->fetchAll();
if($rows){
$poePrice = [];
foreach($rows as $row){
$poePrice[$row['oe_id']][] = $row;
}
foreach($waiArr as $wai){
if($poePrice[$wai['wai_oe_id']]) $arr[$wai['wai_id']]['sup_pro'] = $poePrice[$wai['wai_oe_id']];
}
}
if($type != 'autoPrice'){
//无价格的找资源库
$nullIds = [];
$resource = new resource();
foreach($waiArr as $wai_id=>$wai){
if(empty($arr[$wai_id])){
$nullIds[] = $wai_id;
}
}
if($nullIds){
$nums = $this->db->select('work_ask_item_num', ['wain_wai_id', 'wain_number', 'wain_format'], ['wain_wai_id'=>$nullIds]);
if($nums){
$waiNums = [];
foreach($nums as $row){
$waiNums[$row['wain_wai_id']][$row['wain_format']] = $row['wain_number'];
}
$rows = $resource->getResourcesByNum(array_column($nums, 'wain_format'));
$mergeArr = [];//每个号码每个工厂只取一条
foreach($rows as $row){
$row['num_format'] = formatNum($row['rnumber']);
if(empty($mergeArr[$row['num_format']][$row['resourceFactoryId']]))
$mergeArr[$row['num_format']][$row['resourceFactoryId']] = $row;
}
foreach($waiNums as $wai_id=>$nvs){
$match = [];
foreach($nvs as $numf=>$nv){
if(empty($mergeArr[$numf])) continue;
foreach($mergeArr[$numf] as $fac=>$row){
if(!$match[$fac]){
$match[$fac] = [
'from_type'=>'resource',
'from_name'=>'EDC',
'fac_resource_facid'=>$row['resourceFactoryName'],
'fac_name'=>$row['resourceFactoryName'],
'pro_name'=>$row['partName'],
'pro_price'=>$row['price'],
'nums'=>implode(',', $nvs),
'from_time'=>date('Y-m-d', strtotime($row['resourceProvideTime'])),
];
}
}
}
if($match) $arr[$wai_id]['resource'] = array_values($match);
}
}
}
}
return $arr;
}
//批量改价
function changeAnyAskPrice($wai_ids, $req)
{
$waiArr = $this->db->select('work_ask_item(wai)', ["[><]work_ask(was)" => ["wai.wai_was_id" => "was_id"]], '*', ['wai_id'=>$wai_ids]);
$this->db->Begin();
foreach($waiArr as $wai){
$setArr = [];
foreach(['wai_cost_price', 'wai_price'] as $field){
if($req[$field]['opeval']){
$opv = $req[$field];
if($opv['byprice'] == 'new'){
$setArr[$field] = $opv['opeval'];
}else{
if($opv['byprice'] == 'wai_cost_price'){
//销售价使用成本价，两价是否同时改
$setArr[$field] = $setArr['wai_cost_price']? $setArr['wai_cost_price']: $wai['wai_cost_price'];
}else{
$setArr[$field] = $wai[$field];
}
if($opv['ope'] == '*'){
$setArr[$field] *= $opv['opeval'];
}else if($opv['ope'] == '+'){
$setArr[$field] += $opv['opeval'];
}else if($opv['ope'] == '-'){
$setArr[$field] -= $opv['opeval'];
}
}
}
}
foreach(['wai_pb_id', 'wai_sup_id', 'wai_delivery', 'wai_minbuy'] as $field){
if($req[$field]) $setArr[$field] = $req[$field];
}
if($setArr) $this->setCell('work_ask_item', $wai['wai_id'], $setArr);
}
$this->db->End();
return [];
}
//宜配号码比较['wdi_id'=>xxx]
public function compareNumByYiparts($params){
$arr = [];
if(!empty($params['wdi_id'])){
$join = [
"[>]pro_factory(fac)" => ["wdif_pf_id" =>"pf_id"]
];
$numsTemp = $this->db->select('work_data_item_format', $join, ['pf_name(factory)', 'wdif_val(number)'], ['wdif_type'=>'Number', 'wdif_wdi_id'=>$params['wdi_id']]);
//去重
$nums = [];
foreach ($numsTemp as $val)
{
$unikey = $val['factory'].formatNum($val['number']);
$nums[$unikey] = $val;
}
$nums = array_values($nums);
$apiPost = [
'number'=>json_encode($nums, JSON_UNESCAPED_UNICODE)
];
}else if($params['type']){
$nums = [];
foreach(explode(',', $params['nums']) as $v){
$tt = explode(':', $v);
$unikey = $tt[0].formatNum($tt[1]);
$nums[$unikey] = ['factory'=>$tt[0], 'number'=>$tt[1]];
}
$nums = array_values($nums);
if(!empty($params['artids']) || !empty($nums)){
$apiPost = [
'artids'=>$params['artids'],
'number'=>json_encode($nums, JSON_UNESCAPED_UNICODE)
];
}
}
if($apiPost){
$ypApi = new ypApi();
$res = $ypApi->Get('tcd/compareNum', [], $apiPost);
$arr = $res['status']? $res['data']: [];
}
return $arr;
}
//宜配号码检测['oe_id'=>xxx]
public function chkNumByYiparts($params){
$arr = [];
if(!empty($params['oe_id'])){
$join = [
"[><]pro_cate(cate)" => ["oi.oe_cate_id" =>"id"]
];
$oeInfo = $this->db->get('oe_item(oi)', $join, ['cat_tcdfacmain'], ['oe_id'=>$params['oe_id']]);
$join = [
"[>]pro_factory(fac)" => ["on_pf_id" =>"pf_id"]
];
$numsTemp = $this->db->select('oe_numidx', $join, ['pf_name(factory)', 'on_number(number)'], ['on_oe_id'=>$params['oe_id'], 'ORDER'=>['pf_name', 'on_number']]);
$nums = [];
foreach ($numsTemp as $val) {
$unikey = $val['factory'].formatNum($val['number']);
$nums[$unikey] = $val;
}
$nums = array_values($nums);
$apiPost = [
'number'=>json_encode($nums, JSON_UNESCAPED_UNICODE),
'mainfac'=>$oeInfo['cat_tcdfacmain']
];
$ypApi = new ypApi();
$res = $ypApi->Get('tcd/chkNumBase', [], $apiPost);
$arr = $res['status']? $res['data']: [];
}
return $arr;
}
public function checkAskItem($idArr,$setArr)
{
if(!empty($idArr))
{
$tempArr = $this->db->select('work_ask_item', '*', ['wai_id'=>$idArr]);
if(empty($tempArr)) exitJson('记录不存在');
$opuser = getOpuser();
$datetime = getNowTime();
$set = [
'ckuser1'=>$opuser,
'cktime1'=>$datetime,
'ck1'=>$setArr['ck1'],
'ckremark1'=>$setArr['ckremark1'],
];
$this->db->update('work_ask_item', $set, ['wai_id'=>$idArr]);
//审核通过->供应商产品目录
if($setArr['ck1']==1 && $idArr)
{
$askItem = $this->db->select('work_ask_item','*',['wai_id'=>$idArr]);
$emptySup = [];
foreach ($askItem as $item) {
if(!$item['wai_sup_id']){
$emptySup[] = $item['wai_oe'];
}
}
if(!empty($emptySup)) exitJson("OE号：".implode(',',$emptySup).'所属记录未填写供应商');
$wdiIds = array_column($askItem,'wai_wdi_id');
//存在的号码
$join = [
"[>]pro_factory(fac)" => ["wdif_pf_id" =>"pf_id"]
];
$rows = $this->db->select('work_data_item_format', $join, ['wdif_wdi_id', 'wdif_id', 'pf_id', 'wdif_val'], ['wdif_type'=>'Number', 'wdif_wdi_id'=>$wdiIds]);
$nums = [];
foreach($rows as $rv){
$nums[$rv['wdif_wdi_id']][] = ['wdif_id'=>$rv['wdif_id'], 'pf_id'=>$rv['pf_id'], 'number'=>$rv['wdif_val']];
}
if(!$nums) return [];
$anyAdd = [];
foreach ($askItem as $key => $val)
{
$dataArr = [
'spr_sup_id' => $val['wai_sup_id'],
'spr_brand' => $val['wai_brand'],
'spr_material' => $val['wai_material'],
'spr_price' => $val['wai_price'],
'spr_minbuy' => $val['wai_minbuy'],
'spr_delivery' => $val['wai_delivery'],
'spr_price_btime' => $val['wai_price_btime'],
'spr_price_etime' => $val['wai_price_etime'],
'spr_purin_time' => $val['wai_purin_time'],
'spr_price_status' => $val['wai_price_status'],
'spr_has' => $val['wai_has'],
'spr_hasample' => $val['wai_hasample'],
'spr_from' => $val['wai_form'],
'spr_remark' => $val['wai_remark'],
'spr_opuser' => getOpuser(),
'spr_update_time'=>getNowTime()
];
foreach ($nums[$val['wai_wdi_id']] as $nval)
{
// $dataArr['spr_number'] = $nval['number'];
// $dataArr['spr_format'] = formatNum($nval['number']);
// $dataArr['spr_pf_id'] = $nval['pf_id'];
$exists = $this->db->get('supplier_pro','spr_id',['spr_sup_id'=>$dataArr['spr_sup_id'],'spr_pf_id'=>$nval['pf_id'],'spr_format'=>formatNum($nval['number'])]);
if($exists){
$this->db->update('supplier_pro',$dataArr,['spr_id'=>$exists]);
}else{
$dataArr['spr_number'] = $nval['number'];
$dataArr['spr_format'] = formatNum($nval['number']);
$dataArr['spr_pf_id'] = $nval['pf_id'];
$dataArr['spr_create_time'] = getNowTime();
$anyAdd[] = $dataArr;
}
}
}
if($anyAdd) $this->db->insert('supplier_pro',$anyAdd);
}
}
return [];
}
function saveAskSup($dataArr)
{
$this->db->Begin();
foreach($dataArr as $row){
$spr_ids = explode(',', $row['value']);
$setArr = [];
if($spr_ids[0]){
$info = $this->db->get('supplier_pro', '*', ['spr_id'=>$spr_ids[0]]);
if($info){
$setArr['wai_sup_id'] = $info['spr_sup_id'];
$setArr['wai_material'] = $info['spr_material'];
$setArr['wai_has'] = $info['spr_has'];
$setArr['wai_minbuy'] = $info['spr_minbuy'];
$setArr['wai_delivery'] = $info['spr_delivery'];
$setArr['wai_price_btime'] = $info['spr_price_btime'];
$setArr['wai_price_etime'] = $info['spr_price_etime'];
$setArr['wai_purin_time'] = $info['spr_purin_time'];
$setArr['wai_purin_level'] = '主供应商';
$setArr['wai_from'] = $info['spr_from'];
}
}
if($spr_ids[1]){
$info = $this->db->get('supplier_pro', '*', ['spr_id'=>$spr_ids[1]]);
if($info){
$setArr['wai_bsup_id'] = $info['spr_sup_id'];
$setArr['wai_bhas'] = $info['spr_has'];
$setArr['wai_bdelivery'] = $info['spr_delivery'];
$setArr['wai_bprice_btime'] = $info['spr_price_btime'];
$setArr['wai_bprice_etime'] = $info['spr_price_etime'];
$setArr['wai_bpurin_time'] = $info['spr_purin_time'];
$setArr['wai_bpurin_level'] = '潜在供应商';
$setArr['wai_bfrom'] = $info['spr_from'];
}
}
if($setArr){
$setArr['wai_opuser'] = getOpuser();
$setArr['wai_update_time'] = getNowTime();
$this->db->update('work_ask_item', $setArr, ['wai_id'=>$row['kid']]);
}
}
$this->db->End();
return [];
}
//基本统计
function getBaseTj()
{
$arr = ['ask'=>[], 'oe'=>[]];
$user = new user();
$arr['ask']['role'] = $user->getPowerRole('A300');
//询源单
$sql = "SELECT COUNT(*) total, SUM(CASE WHEN was_status = 1 THEN 1 ELSE 0 END) ok_count, SUM(CASE WHEN was_status != 1 THEN 1 ELSE 0 END) wait_count FROM work_ask";
$row = $this->db->query($sql)->fetch();
$arr['ask'] = array_merge($arr['ask'], $row);
$sql = "SELECT wai_ar_id ar_id, COUNT(*) total, SUM(CASE WHEN was_status = 1 THEN 1 ELSE 0 END) ok_count, SUM(CASE WHEN was_status != 1 THEN 1 ELSE 0 END) wait_count FROM (
SELECT *
FROM work_ask JOIN work_ask_item ON was_id = wai_was_id GROUP BY was_id,wai_ar_id
) t GROUP BY wai_ar_id";
$rows = $this->db->query($sql)->fetchAll();
if(!empty($rows)){
foreach($rows as $v){
$arr['ask']['role'.$v['ar_id']] = $v;
}
}
//询源单明细
$sql = "SELECT COUNT(*) total, SUM(CASE WHEN ck1 = 1 THEN 1 ELSE 0 END) ok_count, SUM(CASE WHEN ck1 != 1 THEN 1 ELSE 0 END) wait_count FROM work_ask_item";
$arr['ask_item'] = $this->db->query($sql)->fetch();
$sql = "SELECT wai_ar_id ar_id, COUNT(*) total, SUM(CASE WHEN ck1 = 1 THEN 1 ELSE 0 END) ok_count, SUM(CASE WHEN ck1 != 1 THEN 1 ELSE 0 END) wait_count FROM work_ask_item GROUP BY wai_ar_id";
$rows = $this->db->query($sql)->fetchAll();
if(!empty($rows)){
foreach($rows as $v){
$arr['ask_item']['role'.$v['ar_id']] = $v;
}
}
return $arr;
}
/**
* @param [type] $req
* @param [type] $rules
* @method 导出解决方案
* @author zhengweihua
* @copyright 2024-12-13
*/
public function exportSolution($req, $rules)
{
$data = $this->getAskItemList($req, $rules);
if(!$data['rows']) return exitJson(-1,'没有数据');
$header = [
[
['title'=>'序号','scell'=>'A1','ecell'=>'A2','isMerge'=>true,'width'=>'8'],
['title'=>'物料编码','scell'=>'B1','ecell'=>'B2','isMerge'=>true,'width'=>'14'],
['title'=>'OE号','scell'=>'C1','ecell'=>'C2','isMerge'=>true,'width'=>'14'],
['title'=>'替换号','scell'=>'D1','ecell'=>'D2','isMerge'=>true,'width'=>'40'],
['title'=>'搜索号','scell'=>'E1','ecell'=>'E2','isMerge'=>true,'width'=>'14'],
['title'=>'图片','scell'=>'F1','ecell'=>'F2','isMerge'=>true,'width'=>'14'],
['title'=>'产品名称','scell'=>'G1','ecell'=>'G2','isMerge'=>true,'width'=>'20'],
['title'=>'产小类型','scell'=>'H1','ecell'=>'H2','isMerge'=>true,'width'=>'20'],
['title'=>'小类','scell'=>'I1','ecell'=>'I2','isMerge'=>true],
['title'=>'项目负责人','scell'=>'J1','ecell'=>'J2','isMerge'=>true,'width'=>'14'],
['title'=>'属性','scell'=>'K1','ecell'=>'K2','isMerge'=>true],
['title'=>'车型/发动机','scell'=>'L1','ecell'=>'L2','isMerge'=>true,'width'=>'16'],
['title'=>'所属项目','scell'=>'M1','ecell'=>'M2','isMerge'=>true],
['title'=>'品牌','scell'=>'N1','ecell'=>'N2','isMerge'=>true],
['title'=>'事业部','scell'=>'O1','ecell'=>'O2','isMerge'=>true,'width'=>'30'],
['title'=>'合作供应商','scell'=>'P1','ecell'=>'AA1','color'=>'FF80FFFF','isMerge'=>true],
['title'=>'潜在供应商','scell'=>'AB1','ecell'=>'AL1','color'=>'FFFACD91','isMerge'=>true],
],
[
'','','','','','','','','','','','','','','',
['title'=>'供应商编码','color'=>'FF80FFFF','width'=>'20'],['title'=>'供应商名称','color'=>'FF80FFFF','width'=>'25'],['title'=>'含税单价','color'=>'FF80FFFF'],['title'=>'是否备货','color'=>'FF80FFFF'],
['title'=>'交期','color'=>'FF80FFFF'],['title'=>'起订量','color'=>'FF80FFFF'],['title'=>'工厂报价时间','color'=>'FF80FFFF','width'=>'30'],['title'=>'价格失效时间','color'=>'FF80FFFF','width'=>'30'],
['title'=>'采购入库时间','color'=>'FF80FFFF','width'=>'30'],['title'=>'采购优先级','color'=>'FF80FFFF','width'=>'25'],['title'=>'采购类型','color'=>'FF80FFFF'],['title'=>'数据类型','color'=>'FF80FFFF'],
['title'=>'供应商编码','color'=>'FFFACD91','width'=>'20'],['title'=>'供应商名称','color'=>'FFFACD91','width'=>'25'],['title'=>'含税单价','color'=>'FFFACD91'],['title'=>'是否验厂','color'=>'FFFACD91'],
['title'=>'初步评级','color'=>'FFFACD91'],['title'=>'是否备货','color'=>'FFFACD91'],['title'=>'交期','color'=>'FFFACD91'],['title'=>'工厂报价时间','color'=>'FFFACD91','width'=>'30'],['title'=>'价格失效时间','color'=>'FFFACD91','width'=>'30'],
['title'=>'采购优先级','color'=>'FFFACD91','width'=>'25'],['title'=>'数据类型','color'=>'FFFACD91']
]
];
$fields = ['wai_id','p_innum','wai_oe','nums','','','wai_item_name','wai_item_type','cat_name','wai_manager','wai_material',
['name'=>['wai_model','wai_engine'],'separator'=>'/'],'wai_project','pb_name','user_area',['name'=>'sup_code','color'=>'FF80FFFF'],['name'=>'sup_name','color'=>'FF80FFFF'],
['name'=>'wai_price','color'=>'FF80FFFF'],['name'=>'wai_has','color'=>'FF80FFFF'],['name'=>'wai_delivery','color'=>'FF80FFFF'],['name'=>'wai_minbuy','color'=>'FF80FFFF'],
['name'=>'wai_price_btime','color'=>'FF80FFFF'],['name'=>'wai_price_etime','color'=>'FF80FFFF'],['name'=>'wai_purin_time','color'=>'FF80FFFF'],['name'=>'wai_purin_level','color'=>'FF80FFFF'],
['name'=>'wai_purin_type','color'=>'FF80FFFF'],['name'=>'wai_from','color'=>'FF80FFFF'],
['name'=>'sup_code2','color'=>'FFFACD91'],['name'=>'sup_name2','color'=>'FFFACD91'],['name'=>'wai_bprice','color'=>'FFFACD91'],['name'=>'wai_bchkfac','color'=>'FFFACD91'],['name'=>'wai_bchklevel','color'=>'FFFACD91'],['name'=>'wai_has','color'=>'FFFACD91'],['name'=>'wai_bdelivery','color'=>'FFFACD91'],
['name'=>'wai_bprice_btime','color'=>'FFFACD91'],['name'=>'wai_bprice_etime','color'=>'FFFACD91'],['name'=>'wai_bpurin_level','color'=>'FFFACD91'],['name'=>'wai_bfrom','color'=>'FFFACD91'],
];
// 创建一个新的 Spreadsheet 对象
$spreadsheet = new \PhpOffice\PhpSpreadsheet\Spreadsheet();
$sheet = $spreadsheet->getActiveSheet();
// 设置标题
$row = 1;
foreach ($header as $val) {
$col = 'A';
foreach ($val as $vv) {
if(!$vv){
$col++;
continue;
}
if(is_array($vv)){
if($vv['isMerge']){
$sheet->mergeCells(sprintf("%s:%s",$vv['scell'],$vv['ecell'])); // 合并单元格
}
if(!empty($vv['width']))
$sheet->getColumnDimension($col)->setWidth($vv['width']);
$sheet->setCellValue($vv['scell']??$col.$row, $vv['title']);
$cell = $vv['isMerge']?sprintf("%s:%s",$vv['scell'],$vv['ecell']):$col.$row;
$style = $sheet->getStyle($cell);
if($vv['color']){
$style->getFill()->setFillType(\PhpOffice\PhpSpreadsheet\Style\Fill::FILL_SOLID)->getStartColor()->setARGB($vv['color']);
$styleArray = [
'borders' => [
'allBorders' => [
'borderStyle' => \PhpOffice\PhpSpreadsheet\Style\Border::BORDER_THIN,
'color' => ['argb' => 'FF000000'], // 黑色边框
],
],
];
$style->applyFromArray($styleArray);
}
}else{
$sheet->setCellValue($col.$row, $vv);
$style = $sheet->getStyle($col.$row);
}
$style->getAlignment()->setHorizontal('center');
$style->getAlignment()->setVertical('center');
$col++;
}
$row++;
}
foreach ($data['rows'] as $val)
{
$col = 'A';
foreach ($fields as $field) {
if(!is_array($field)){
$val[$field] = $val['captions'][$field]?:$val[$field];
if($field=='nums'){
$val['nums'] =$val['nums']? implode(',',explode("\r\n",$val['nums'])):'';
}
$sheet->setCellValue($col.$row, $val[$field]);
$style = $sheet->getStyle($col.$row);
}else{
$fieldsVal = '';
$nameArr = [];
if(is_array($field['name'])){
foreach ($field['name'] as $name) {
if($val[$name]) $nameArr[] = $val['captions'][$name]?:$val[$name];
}
$fieldsVal = $nameArr ? implode($field['separator']?:',',$nameArr):'';
}else{
$fieldsVal = $val['captions'][$field['name']]?:$val[$field['name']];
}
if(!$fieldsVal||in_Array($fieldsVal,['0','0000-00-00'])) $fieldsVal = '';
$sheet->setCellValue($col.$row, $fieldsVal);
$style = $sheet->getStyle($col.$row);
if($field['color']){
$style->getFill()->setFillType(\PhpOffice\PhpSpreadsheet\Style\Fill::FILL_SOLID)->getStartColor()->setARGB($field['color']);
$styleArray = [
'borders' => [
'allBorders' => [
'borderStyle' => \PhpOffice\PhpSpreadsheet\Style\Border::BORDER_THIN,
'color' => ['argb' => 'FF000000'], // 黑色边框
],
],
];
$style->applyFromArray($styleArray);
}
}
if($field=='nums'){
$style->getAlignment()->setWrapText(true);
}
$style->getAlignment()->setHorizontal('center');
$style->getAlignment()->setVertical('center');
$col++;
}
$row++;
}
$dateTime = getNowTime();
$filename = sprintf('解决方案%s',$dateTime).'.xlsx';
$objWriter = \PhpOffice\PhpSpreadsheet\IOFactory::createWriter($spreadsheet, 'Xlsx');
ob_clean();
header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
header('Content-Disposition: attachment;filename="'.$filename.'"');
header('Cache-Control: max-age=0');
$objWriter->save("php://output");
}
public function chkDataToOth($req)
{
$data = [
'role'=>[],
'user'=>[]
];
//角色
$arr = $this->db->select('power_role_link(pw)',['[><]adm_role(ro)'=>['pw.prl_ar_id'=>'ar_id']],'*',['prl_power_code'=>$req['pwcode']]);
if($arr){
//判断是否有check2权限
foreach ($arr as $key => $val) {
if(!\p::checkXor($val['prl_value'],['check2'])){
unset($arr[$key]);
}
}
}
$data['role'] = array_values($arr);
//用户
$where = [
'au_id[!]' => ['frey.admin','admin','admin888']
];
$data['user'] = $this->db->select('adm_user',['au_id','au_name'],$where);
return $data;
}
public function workPoesTask($params)
{
$data = ['wdi_ar_id'=>$params['ar_id'],'wdi_from_opuser'=>$params['from_opuser'],'wdi_from_time'=>getNowTime()];
$this->db->update('work_data_item',$data,['wdi_id'=>explode(',',$params['ids'])]);
return [];
}
//保存询单
public function saveAskDetail($was_id, $dataArr)
{
$this->db->Begin();
foreach($dataArr['wai'] as $wai_id=>$v){
$set = [];
foreach($v as $kk=>$vv){
if(stripos($kk, 'wai_') === 0){
if(in_array($kk, ['wai_spr_id', 'wai_oe_id'])) $vv = (int) $vv;
$set[$kk] = $vv;
}
}
if($set){
if($set['wai_spr_id']){
$oe_id = $this->db->get('supplier_pro', 'spr_oe_id', ['spr_id'=>$set['wai_spr_id']]);
if($oe_id) $set['wai_oe_id'] = $oe_id;
}
$set['wai_opuser'] = getOpuser();
$set['wai_update_time'] = getNowTime();
$this->db->update('work_ask_item', $set,['wai_was_id'=>$was_id, 'wai_id'=>$wai_id]);
}
}
$set = [];
foreach($dataArr as $kk=>$vv){
if(stripos($kk, 'was_') === 0){
if(in_array($kk, ['was_money_rate'])) $vv = (float) $vv;
$set[$kk] = $vv;
}
}
if($set){
$set['was_opuser'] = getOpuser();
$set['was_update_time'] = getNowTime();
$this->db->update('work_ask', $set,['was_id'=>$was_id]);
}
$this->db->End();
return [];
}
//转数据单
public function numToWorkOrder($req)
{
$wdlInfo = [];
$factory = new factory();
$wdiNumArr = [];
foreach($req['nums'] as $tnums){
if(empty($tnums)) continue;
$nums = [];
foreach($tnums as $tnum){
$tarr = unserialize(base64_decode($tnum));
foreach($tarr as $tv){
$pfid = empty($tv['factory']) || $tv['factory'] == 'OE'? 1: $factory->getFacId($tv['factory'], 'add');
$format = formatNum($tv['number']);
if($format){
$nums[$pfid.$format] = [
'wdif_type'=>'Number',
'wdif_val'=>$tv['number'],
'wdif_search'=>$format,
'wdif_pf_id'=>$pfid? $pfid: 1
];
}
}
}
if($nums) $wdiNumArr[] = $nums;
}
if(empty($wdiNumArr)) exitJson('号码必填');
if($req['wdlist_id']){
$wdlArr = $this->db->get('work_data_list', ['wdlist_id', 'wdlist_seq'], ['wdlist_id'=>$req['wdlist_id']]);
$wdlist_seq = $wdlArr['wdlist_seq'];
$wdlist_id = $req['wdlist_id'];
}
$work = new work();
$opuser = getOpuser();
$datetime = getNowTime();
$this->db->Begin();
$check = new check();
if(empty($wdlist_id)){
$exists = $check->checkExist('wdlist_title', ['wdlist_title'=>$req['wdlist_title']]);
if($exists) exitJson('标题已存在');
$wdl = [
'wdlist_seq'=>$work->getWorkSeqNext(),
'wdlist_from_opuser'=>$req['wdlist_from_opuser']? $req['wdlist_from_opuser'] : '',
'wdlist_title'=>$req['wdlist_title'],
'wdlist_remark'=>$req['wdlist_remark']? $req['wdlist_remark'] : '',
'wdlist_opuser'=>$opuser,
'wdlist_create_time'=>$datetime,
'wdlist_update_time'=>$datetime
];
$wdlist_seq = $wdl['wdlist_seq'];
$this->db->insert('work_data_list', $wdl);
$wdlist_id = $this->db->id();
}
$noCatids = [];
foreach($wdiNumArr as $nums){
$toFormat = ['Number'=>[]];
foreach($nums as $dv){
$uniwhere = [
'wdi_wdlist_id'=>$wdlist_id,
'wdif_type'=>'Number',
'wdif_search'=>$dv['wdif_search'],
'wdif_pf_id'=>$dv['wdif_pf_id']
];
$chk = $this->db->get('work_data_item_format(wdif)', ["[><]work_data_item(wdi)"=>["wdif.wdif_wdi_id" =>"wdi_id"]], ['wdif_id'], $uniwhere);
if(!empty($chk)) continue;
$toFormat['Number'][] = $dv;
}
if(empty($toFormat['Number'])) continue;
$wdli = [
'wdi_wdlist_id'=>$wdlist_id,
'wdi_data'=>'{}',
'wdi_opuser'=>$opuser,
'wdi_create_time'=>$datetime,
'wdi_update_time'=>$datetime
];
$this->db->insert('work_data_item', $wdli);
$wdi_id = $this->db->id();
$noCatids[] = $wdi_id;
//格式化数据
foreach($toFormat as $type=>$vals){
//数组本身去重
$vals = array_map('unserialize', array_unique(array_map('serialize', $vals)));
foreach($vals as $vk=>$wdif){
$vals[$vk]['wdif_wdi_id'] = $wdi_id;
}
$this->db->insert('work_data_item_format', $vals);
}
}
if($noCatids) $this->autoCleanCat(['ids'=>$noCatids]);
$this->db->End();
$wdlInfo = ['wdlist_id'=>$wdlist_id, 'wdlist_seq'=>$wdlist_seq];
return $wdlInfo;
}
/**
* 询源明细自动转数据单
* @return string
*/
public function askItemToWorkOrder($wai_ids)
{
$where = [
'wai_id'=>$wai_ids,
'RAW_NOT'=>raw(" wai_id not in (SELECT distinct wdi_from_id FROM work_data_item where wdi_from=1123)")
];
$items = $this->db->select('work_ask_item', ['wai_id', 'wai_was_id', 'wai_cat_id'], $where);
if($items){
$linkArr = [];
foreach($items as $v){
$linkArr[$v['wai_was_id']][] = $v;
}
$nums = [];
$factory = new factory();
$rows = $this->db->select('work_ask_item_num', ['wain_wai_id', 'wain_pf_name(factory)', 'wain_number(number)', 'wain_format'], ['wain_wai_id'=>array_column($items, 'wai_id')]);
foreach($rows as $tv){
$pfid = empty($tv['factory']) || $tv['factory'] == 'OE'? 1: $factory->getFacId($tv['factory'], 'add');
$format = $tv['wain_format'];
if($format){
$nums[$tv['wain_wai_id']][] = [
'wdif_type'=>'Number',
'wdif_val'=>$tv['number'],
'wdif_search'=>$format,
'wdif_pf_id'=>$pfid? $pfid: 1
];
}
}
$opuser = getOpuser();
$datetime = getNowTime();
$this->db->Begin();
$noCatids = [];
foreach($linkArr as $wasid=>$wais){
$wdlist_id = $this->db->get('work_data_list', 'wdlist_id', ['wdlist_from'=>1123, 'wdlist_from_id'=>$wasid]);
if(!$wdlist_id){
$wdl = [
'wdlist_seq'=>$this->getWorkSeqNext(),
'wdlist_from_opuser'=>'',
'wdlist_title'=>'询单ID:'.$wasid,
'wdlist_remark'=>'',
'wdlist_from'=>1123,
'wdlist_from_id'=>$wasid,
'wdlist_opuser'=>$opuser,
'wdlist_create_time'=>$datetime,
'wdlist_update_time'=>$datetime
];
$wdlist_seq = $wdl['wdlist_seq'];
$this->db->insert('work_data_list', $wdl);
$wdlist_id = $this->db->id();
}
foreach($wais as $wai){
$toFormat = ['Number'=>$nums[$wai['wai_id']]];
$wdli = [
'wdi_wdlist_id'=>$wdlist_id,
'wdi_cat_id'=>$wai['wai_cat_id'],
'wdi_data'=>'{}',
'wdi_from'=>1123,
'wdi_from_id'=>$wai['wai_id'],
'wdi_opuser'=>$opuser,
'wdi_create_time'=>$datetime,
'wdi_update_time'=>$datetime
];
if($wai['wai_cat_id']) $wdli['wdi_cat_id'] = $wai['wai_cat_id'];
$this->db->insert('work_data_item', $wdli);
$wdi_id = $this->db->id();
if(!$wai['wai_cat_id']) $noCatids[] = $wdi_id;
//格式化数据
foreach($toFormat as $type=>$vals){
//数组本身去重
$vals = array_map('unserialize', array_unique(array_map('serialize', $vals)));
foreach($vals as $vk=>$wdif){
$vals[$vk]['wdif_wdi_id'] = $wdi_id;
}
$this->db->insert('work_data_item_format', $vals);
}
}
}
if($noCatids) $this->autoCleanCat(['ids'=>$noCatids]);
$this->db->End();
}
return [];
}
public function dataItemExport($fields,$data)
{
function processBatchData($data,$fields,&$drawImgRanges, &$wrapTextRanges, &$brow){
foreach ($data as $v) {
$row = [];
$col = 0;
$bcol = 'A';
// 写入主数据
foreach ($fields as $fk => $fv) {
if($fk=='wdi_dstatus'){
$v['wdi_dstatus'] = $v['wdi_dstatus'] == 1 ? 'Y' : 'N';
}
if($fk=='wdi_clean'){
$v['wdi_clean'] = $v['wdi_clean'] == 1 ? 'Y' : 'N';
}
//零件库检测
if($fk=='chk_poes')
{
$v['chk_poes'] = [];
if(!empty($v['poes'])){
foreach($v['poes'] as $tpk=>$tpv){
$v['chk_poes'][] = $tpv['pf_name'].': '.$tpv['oe_oe'];
}
}
}
//供应商检测
if($fk=='chk_sups')
{
$v['chk_sups'] = [];
if(!empty($v['sups'])){
foreach($v['sups'] as $tpk=>$tpv){
$v['chk_sups'][] = $tpv['sup_name'];
}
}
}
//商品库检测
if($fk=='chk_pcs'){
$v['chk_pcs'] = [];
if(!empty($v['pcs'])){
foreach($v['pcs'] as $tpk=>$tpv){
$v['chk_pcs'][] = $tpv['p_innum'];
}
}
}
if($fk=='chknums'){
$v['chknums'] = [];
foreach($v['nums'] as $tk=>$tv){
$v['chknums'][] = ($tv['factory']? $tv['factory'].': ' : '').$tv['number'].($tv['err']? ' [异常]': '');
}
}
if($fk=='chkok'){
$v['chkok'] = strip_tags(str_replace($v['chkok_para'],'',$v['captions']['chkok']));
$v['captions']['chkok'] = [];
if($v['chkok']){
$v['captions']['chkok'][] = trim($v['chkok'],' ');
}
$chkproArr = empty($v['wdi_chkpro_clean_result']) ? []: json_decode($v['wdi_chkpro_clean_result'], true);
if(!empty($chkproArr['para'])){
foreach($chkproArr['para'] as $tv){
$v['captions']['chkok'][] = ($tv['cn_name']? $tv['cn_name']: $tv['name']).' : '.$tv['val'].$tv['unit'];
}
}
}
$val = isset($v['captions'][$fk]) ?$v['captions'][$fk]: (isset($v[$fk]) ? $v[$fk]: '');
$val = is_array($val) ? implode("\n", $val) : $val;
$row[$col] = $val;
// 如果值中包含 \n，记录单元格范围
if (stripos($val, "\n") !== false) {
$wrapTextRanges[] = $bcol . $brow;
}
if($fk=='img' && $val){
$imgPath = tempnam(sys_get_temp_dir(), 'excel_img_'.md5($val));
// 检查文件是否存在且可访问
$headers = @get_headers($val);
if($headers && strpos($headers[0], '200') !== false) {
$contents = file_get_contents($val);
if($imgPath && file_exists($imgPath) && $contents){
file_put_contents($imgPath,$contents);
$drawImgRanges[$bcol . $brow] = $imgPath;
}
$row[$col] = '';
}
}
$bcol++;
$col++;
}
$brow++; // 更新行号
yield $row; // 使用 yield 返回当前行
}
}
// 创建一个新的 Spreadsheet 对象
$spreadsheet = new \PhpOffice\PhpSpreadsheet\Spreadsheet();
$sheet = $spreadsheet->getActiveSheet();
// 设置标题
$row = 1;
$col = 'A';
$defaultColumnWidth = 20;
foreach ($fields as $vv) {
if(!$vv){
$col++;
continue;
}
// 设置列宽（如果未单独指定宽度，则使用默认宽度）
if (is_array($vv) && !empty($vv['width'])) {
$sheet->getColumnDimension($col)->setWidth($vv['width']);
} else {
$sheet->getColumnDimension($col)->setWidth($defaultColumnWidth);
}
if(is_array($vv)){
if($vv['isMerge']){
$sheet->mergeCells(sprintf("%s:%s",$vv['scell'],$vv['ecell'])); // 合并单元格
}
$sheet->setCellValue($vv['scell']??$col.$row, $vv['title']);
$cell = $vv['isMerge']?sprintf("%s:%s",$vv['scell'],$vv['ecell']):$col.$row;
$style = $sheet->getStyle($cell);
if($vv['color']){
$style->getFill()->setFillType(\PhpOffice\PhpSpreadsheet\Style\Fill::FILL_SOLID)->getStartColor()->setARGB($vv['color']);
$styleArray = [
'borders' => [
'allBorders' => [
'borderStyle' => \PhpOffice\PhpSpreadsheet\Style\Border::BORDER_THIN,
'color' => ['argb' => 'FF000000'], // 黑色边框
],
],
];
$style->applyFromArray($styleArray);
}
}else{
$sheet->setCellValue($col.$row, $vv);
$style = $sheet->getStyle($col.$row);
}
$style->getAlignment()->setHorizontal('center');
$style->getAlignment()->setVertical('center');
$col++;
}
$row++;
$batchSize = 1000; // 每次处理 1000 条数据
$totalRows = count($data);
for ($i = 0; $i < $totalRows; $i += $batchSize) {
$batchData = array_slice($data, $i, $batchSize); // 获取当前批次数据
$data = [];
$wrapTextRanges = [];
$startRow = $row; // 记录当前批次的起始行号
$drawImgRanges = [];
// 使用生成器逐行处理数据
foreach (processBatchData($batchData,$fields,$drawImgRanges, $wrapTextRanges, $row) as $item) {
$data[] = $item;
}
// 批量写入数据到表格
if (!empty($data)) {
$sheet->fromArray($data, null, 'A' . $startRow);
}
// 批量设置换行样式
if (!empty($wrapTextRanges)) {
foreach ($wrapTextRanges as $cell) {
$sheet->getStyle($cell)->getAlignment()->setWrapText(true);
}
}
//批量插入图片
if(!empty($drawImgRanges)){
foreach ($drawImgRanges as $cell => $img) {
// 插入图片
$drawing = new \PhpOffice\PhpSpreadsheet\Worksheet\Drawing();
$drawing->setPath($img); // 图片路径
$drawing->setHeight(50); // 设置图片高度
$drawing->setCoordinates($cell); // 设置图片插入的单元格
$drawing->setWorksheet($sheet);
// 设置图片所在行的高度
$rowIndex = preg_replace('/[^0-9]/', '', $cell); // 提取行号
$sheet->getRowDimension($rowIndex)->setRowHeight(40); // 设置行高为 80，可根据需求调整
}
}
}
// 输出文件
ob_clean();
if (empty($filename)) {
$filename = sprintf('%d.xlsx', time());
}
header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
header('Content-Disposition: attachment;filename="' . $filename . '"');
header('Cache-Control: max-age=0');
$writer = new \PhpOffice\PhpSpreadsheet\Writer\Xlsx($spreadsheet);
$writer->save('php://output');
// 释放内存
$spreadsheet->disconnectWorksheets();
unset($spreadsheet);
}
//tcd汽车品牌
function tcdMfaList($req)
{
$ypApi = new ypApi();
$req['lang'] = LG;
$hotids = [];
$ckv = new \model\ckv();
$hids = $ckv->getKV('hot_brands');
if($hids){
$hotids = $this->db->select('m_make', 'mk_ypmfa_id', ['mk_id'=>$hids]);
if(!$hotids) $hotids = [];
}
$res = $ypApi->Get('tcd/tcdMfaList', $req);
$arr = $res['data'];
foreach($arr as $k=>$v){
$arr[$k]['ishot'] = in_array($v['mfa_id'], $hotids)? 1: 0;
}
return $arr;
}
//tcd某些汽车生产商的竞品和分类
function tcdSupGaByMfa($req)
{
$ypApi = new ypApi();
$req['lang'] = LG;
$res = $ypApi->Get('tcd/tcdSupGaByMfa', [], $req);
$arr = $res['data'];
return $arr;
}
//tcd产品统计
function tcdGaSupTj($req)
{
$ypApi = new ypApi();
$req['lang'] = LG;
$res = $ypApi->Get('tcd/tcdGaSupTj', [], $req);
$arr = $res['data'];
return $arr;
}
//tcd产品统计
function tcdGaSupArtList($req)
{
$ypApi = new ypApi();
$req['lang'] = LG;
$res = $ypApi->Get('tcd/tcdGaSupArtList', [], $req);
$arr = $res['data'];
$supname = $req['supname'];
$factory = new factory();
$pfid = $factory->getFacId($supname);
$ganame = $req['ganame'];
$cate = new cate();
$catIds = [];
$tid = $cate->eqname($ganame);
if(!empty($tid)){
$catIds = [$tid];
}else{
$tids = $cate->eqnameByTcd($ganame);
$catIds = $tids;
}
$tnums = [];
$numToPoe = [];
foreach($arr as $k=>$v){
$tnums[] = $v['art_format'];
if($k % 1000 == 999 || $k+1 == count($arr)){
$join = [
'[><]oe_item(woe)'=>['woi.on_oe_id'=>'oe_id'],
"[><]pro_factory(pf)" => ["woe.oe_pf_id" => "pf_id"],
"[<]pro_factory(pf2)" => ["woi.on_pf_id" => "pf_id"],
];
$where = ['on_pf_id'=>$pfid, 'on_formart'=>$tnums, 'GROUP'=>['oe_id'], 'ORDER'=>['oe_id'=>'DESC']];
if($catIds) $where['oe_cate_id'] = $catIds;
$rows = $this->db->select('oe_numidx(woi)', $join, ['oe_id', 'pf.pf_name', 'oe_oe', 'on_formart'], $where);
foreach($rows as $vv){
$numToPoe[$vv['on_formart']][] = $vv;
}
$tnums = [];
}
}
foreach($arr as $k=>$v){
$v['poe'] = $numToPoe[$v['art_format']]? $numToPoe[$v['art_format']]: [];
$arr[$k] = $v;
}
return $arr;
}
}