xh-erp.7in6.com/application/admin/controller/Procuremenarchive.php

<?php

namespace app\admin\controller;

use app\common\controller\Backend;
use app\common\library\ProcuremenStatus;
use app\common\library\ProcuremenTime;
use think\Db;

/**
 * 协助采购 — 历史存证档案查询（审批通过即可查；含操作记录详情）
 *
 * @icon fa fa-archive
 */
class Procuremenarchive extends Backend
{
    protected $searchFields = 'CCYDH,CYJMC,CGYMC,pick_company_name';

    public function _initialize()
    {
        parent::_initialize();
        $canArchiveAbandon = $this->canArchiveAbandon();
        $canDetails = $this->hasProcuremenSiblingPerm(['details']);
        $this->view->assign('canArchiveAbandon', $canArchiveAbandon);
        $this->assignconfig('procuremenAuth', [
            'details'        => $canDetails,
            'auditabandon'   => $canArchiveAbandon,
            'archiveabandon' => $canArchiveAbandon,
        ]);
    }

    /**
     * 历史存证「重新下发」权限：与审批列表统一为 auditabandon
     */
    protected function canArchiveAbandon(): bool
    {
        if ($this->hasProcuremenSiblingPerm(['auditabandon', 'auditAbandon'])) {
            return true;
        }

        return $this->hasProcuremenSiblingPerm(['archiveabandon', 'archiveAbandon']);
    }

    /**
     * @param string[] $actions
     */
    protected function hasProcuremenSiblingPerm(array $actions): bool
    {
        foreach ($actions as $action) {
            $action = strtolower(trim((string)$action));
            if ($action === '') {
                continue;
            }
            if (strpos($action, 'procuremen/') !== 0) {
                $action = 'procuremen/' . $action;
            }
            if ($this->auth->check($action)) {
                return true;
            }
        }
        $suffixes = [];
        foreach ($actions as $action) {
            $action = strtolower(trim((string)$action));
            $action = preg_replace('#^procuremen/#', '', $action);
            if ($action !== '') {
                $suffixes[$action] = true;
            }
        }
        if ($suffixes === []) {
            return false;
        }
        try {
            foreach ($this->auth->getRuleList() as $rule) {
                $rule = strtolower((string)$rule);
                if (strpos($rule, 'procuremen/') !== 0) {
                    continue;
                }
                foreach (array_keys($suffixes) as $suffix) {
                    if ($rule === 'procuremen/' . $suffix || strpos($rule, 'procuremen/' . $suffix . '/') === 0) {
                        return true;
                    }
                }
            }
        } catch (\Throwable $e) {
        }

        return false;
    }

    /**
     * 历史存证范围：审批通过（wflow=已审核）即可显示，不要求入库合格/已完结
     * （兼容旧数据仅有 status=已完结）
     */
    protected function applyPurchaseOrderArchiveWhere($query): void
    {
        $quoted = [];
        foreach (ProcuremenStatus::wflowApprovedValues() as $v) {
            $quoted[] = "'" . str_replace("'", "''", (string)$v) . "'";
        }
        $wflowSql = 'TRIM(CAST(`wflow_status` AS CHAR)) IN (' . implode(',', $quoted) . ')';
        $query->whereRaw('(' . $wflowSql . ' OR ' . ProcuremenStatus::sqlPoCompleted('status') . ')');
    }

    public function index()
    {
        $this->relationSearch = false;
        $this->request->filter(['strip_tags', 'trim']);
        if ($this->request->isAjax()) {
            list($where, $sort, $order, $offset, $limit) = $this->buildparams();
            $limit = max(10, min(500, (int)$limit));
            $offset = max(0, (int)$offset);

            $applyFilters = function ($query) use ($where) {
                $this->applyPurchaseOrderArchiveWhere($query);
                if (!empty($where)) {
                    $query->where($where);
                }
            };

            $sortField = preg_match('/^[a-zA-Z0-9_]+$/', (string)$sort) ? $sort : 'complete_time';
            $orderDir = strtoupper((string)$order) === 'ASC' ? 'ASC' : 'DESC';
            // 完结/审批时间为计算字段，库表排序仅用真实列
            $dbSortAllow = ['id', 'CCYDH', 'CYJMC', 'CGYMC', 'pick_company_name', 'createtime', 'pick_time', 'dStamp'];
            $dbSortField = in_array($sortField, $dbSortAllow, true) ? $sortField : 'id';
            $listQuery = Db::table('purchase_order');
            $applyFilters($listQuery);
            $rows = $listQuery
                ->field('id,scydgy_id,CCYDH,CYJMC,CGYMC,pick_company_name,createtime,dStamp,pick_time')
                ->order($dbSortField, $orderDir)
                ->select();
            if (!is_array($rows)) {
                $rows = [];
            }

            $sidList = [];
            foreach ($rows as $r) {
                if (!is_array($r)) {
                    continue;
                }
                $sid = (int)($r['scydgy_id'] ?? 0);
                if ($sid !== 0) {
                    $sidList[$sid] = true;
                }
            }
            // 审批时间 = 审核确认供应商；完结时间 = 直接完结 / 质量评分（与详情「已完结」一致）
            $approveTsMap = ProcuremenTime::loadOperLogTimestampMap(
                array_keys($sidList),
                ['purchase_confirm']
            );
            $completeTsMap = ProcuremenTime::loadOperLogTimestampMap(
                array_keys($sidList),
                ['mark_complete', 'inbound_score']
            );
            $inboundMap = [];
            $inboundTimeMap = [];
            if ($sidList !== []) {
                try {
                    $inRows = Db::table('purchase_order_inbound_score')
                        ->where('scydgy_id', 'in', array_keys($sidList))
                        ->field('scydgy_id,result,updatetime,createtime')
                        ->select();
                } catch (\Throwable $e) {
                    $inRows = [];
                }
                if (is_array($inRows)) {
                    foreach ($inRows as $ir) {
                        if (!is_array($ir)) {
                            continue;
                        }
                        $isid = (int)($ir['scydgy_id'] ?? 0);
                        if ($isid === 0) {
                            continue;
                        }
                        $inboundMap[$isid] = trim((string)($ir['result'] ?? ''));
                        $its = ProcuremenTime::parseToTimestamp($ir['updatetime'] ?? $ir['createtime'] ?? null);
                        if ($its > 946684800) {
                            $inboundTimeMap[$isid] = $its;
                        }
                    }
                }
            }

            $out = [];
            foreach ($rows as $r) {
                if (!is_array($r)) {
                    continue;
                }
                $sid = (int)($r['scydgy_id'] ?? 0);
                $approve = ProcuremenTime::resolveCompletedDone($r, $approveTsMap);
                // 完结：操作日志优先；无日志时用入库评分表时间兜底
                $completeMap = $completeTsMap;
                if ($sid > 0 && empty($completeMap[$sid]) && isset($inboundTimeMap[$sid])) {
                    $completeMap[$sid] = $inboundTimeMap[$sid];
                }
                $complete = ProcuremenTime::resolveCompletedDone($r, $completeMap);
                // 未评分完结时勿用 pick_time 冒充完结：无完结日志则留空（审批时间仍单独展示）
                if ($sid > 0 && empty($completeTsMap[$sid]) && empty($inboundTimeMap[$sid])) {
                    $complete = ['ts' => 0, 'text' => ''];
                }
                $out[] = [
                    'id'                 => (int)($r['id'] ?? 0),
                    'scydgy_id'          => $sid,
                    'CCYDH'              => trim((string)($r['CCYDH'] ?? '')),
                    'CYJMC'              => trim((string)($r['CYJMC'] ?? '')),
                    'CGYMC'              => trim((string)($r['CGYMC'] ?? '')),
                    'pick_company_name'  => trim((string)($r['pick_company_name'] ?? '')),
                    'inbound_result'     => $inboundMap[$sid] ?? '',
                    'createtime'         => $approve['ts'],
                    'createtime_text'    => $approve['text'],
                    'complete_time'      => $complete['ts'],
                    'complete_time_text' => $complete['text'],
                ];
            }

            $merged = $this->collapseArchiveRowsByOrder($out);
            $nMerged = count($merged);
            if ($nMerged > 1) {
                if ($sortField === 'id') {
                    usort($merged, function ($a, $b) use ($orderDir) {
                        $cmp = ((int)($a['id'] ?? 0)) <=> ((int)($b['id'] ?? 0));
                        if ($cmp === 0) {
                            return strcmp((string)($a['CCYDH'] ?? ''), (string)($b['CCYDH'] ?? ''));
                        }

                        return $orderDir === 'ASC' ? $cmp : -$cmp;
                    });
                } elseif ($sortField === 'createtime') {
                    usort($merged, function ($a, $b) use ($orderDir) {
                        $ta = (int)($a['createtime'] ?? 0);
                        $tb = (int)($b['createtime'] ?? 0);
                        if ($ta === $tb) {
                            return ((int)($b['id'] ?? 0)) <=> ((int)($a['id'] ?? 0));
                        }

                        return $orderDir === 'ASC' ? ($ta <=> $tb) : ($tb <=> $ta);
                    });
                } else {
                    // 默认 / complete_time：按完结时间；无完结时间的排后面
                    usort($merged, function ($a, $b) use ($orderDir) {
                        $ta = (int)($a['complete_time'] ?? 0);
                        $tb = (int)($b['complete_time'] ?? 0);
                        if ($ta <= 0 && $tb <= 0) {
                            return ((int)($b['id'] ?? 0)) <=> ((int)($a['id'] ?? 0));
                        }
                        if ($ta <= 0) {
                            return 1;
                        }
                        if ($tb <= 0) {
                            return -1;
                        }
                        if ($ta === $tb) {
                            return ((int)($b['id'] ?? 0)) <=> ((int)($a['id'] ?? 0));
                        }

                        return $orderDir === 'ASC' ? ($ta <=> $tb) : ($tb <=> $ta);
                    });
                }
            }

            $pageRows = array_slice($merged, $offset, $limit);

            return json(['total' => $nMerged, 'rows' => $pageRows]);
        }

        return $this->view->fetch();
    }

    /**
     * 历史存证：同一订单号 CCYDH 合并为一行（与审批/确认列表一致）
     *
     * @param array<int, array<string, mixed>> $rows
     * @return array<int, array<string, mixed>>
     */
    protected function collapseArchiveRowsByOrder(array $rows): array
    {
        if ($rows === []) {
            return [];
        }
        $groups = [];
        foreach ($rows as $row) {
            if (!is_array($row)) {
                continue;
            }
            $dh = trim((string)($row['CCYDH'] ?? ''));
            $key = $dh !== '' ? $dh : ('_id_' . (int)($row['id'] ?? 0));
            if (!isset($groups[$key])) {
                $groups[$key] = [];
            }
            $groups[$key][] = $row;
        }
        $out = [];
        foreach ($groups as $groupRows) {
            if ($groupRows === []) {
                continue;
            }
            usort($groupRows, function ($a, $b) {
                return ((int)($a['id'] ?? 0)) <=> ((int)($b['id'] ?? 0));
            });
            $head = $groupRows[0];
            $gymcList = [];
            $supplierList = [];
            $inboundList = [];
            foreach ($groupRows as $r) {
                $g = trim((string)($r['CGYMC'] ?? ''));
                if ($g !== '' && !in_array($g, $gymcList, true)) {
                    $gymcList[] = $g;
                }
                $sn = trim((string)($r['pick_company_name'] ?? ''));
                if ($sn !== '' && !in_array($sn, $supplierList, true)) {
                    $supplierList[] = $sn;
                }
                $ir = trim((string)($r['inbound_result'] ?? ''));
                if ($ir !== '' && !in_array($ir, $inboundList, true)) {
                    $inboundList[] = $ir;
                }
            }
            $merged = $head;
            if (count($groupRows) > 1) {
                $merged['CGYMC'] = implode('、', $gymcList);
            }
            $merged['pick_company_name'] = implode('、', $supplierList);
            $merged['inbound_result'] = $inboundList !== [] ? implode('、', $inboundList) : '';
            $merged['process_count'] = count($groupRows);
            $latestApproveTs = 0;
            $latestApproveText = '';
            $latestCompleteTs = 0;
            $latestCompleteText = '';
            foreach ($groupRows as $r) {
                $ts = (int)($r['createtime'] ?? 0);
                if ($ts <= 0 && !empty($r['createtime_text'])) {
                    $ts = (int)strtotime((string)$r['createtime_text']);
                }
                if ($ts > $latestApproveTs) {
                    $latestApproveTs = $ts;
                    $latestApproveText = trim((string)($r['createtime_text'] ?? ''));
                }
                $cts = (int)($r['complete_time'] ?? 0);
                if ($cts <= 0 && !empty($r['complete_time_text'])) {
                    $cts = (int)strtotime((string)$r['complete_time_text']);
                }
                if ($cts > $latestCompleteTs) {
                    $latestCompleteTs = $cts;
                    $latestCompleteText = trim((string)($r['complete_time_text'] ?? ''));
                }
            }
            if ($latestApproveTs > 0) {
                $merged['createtime'] = $latestApproveTs;
                if ($latestApproveText === '') {
                    $latestApproveText = date('Y-m-d H:i:s', $latestApproveTs);
                }
                $merged['createtime_text'] = ProcuremenTime::formatDisplayDateTime($latestApproveText);
            }
            if ($latestCompleteTs > 0) {
                $merged['complete_time'] = $latestCompleteTs;
                if ($latestCompleteText === '') {
                    $latestCompleteText = date('Y-m-d H:i:s', $latestCompleteTs);
                }
                $merged['complete_time_text'] = ProcuremenTime::formatDisplayDateTime($latestCompleteText);
            } else {
                $merged['complete_time'] = 0;
                $merged['complete_time_text'] = '';
            }
            $maxId = (int)($head['id'] ?? 0);
            foreach ($groupRows as $r) {
                $maxId = max($maxId, (int)($r['id'] ?? 0));
            }
            $merged['id'] = $maxId;
            $out[] = $merged;
        }

        return $out;
    }
}