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,
        ]);
        if (session_status() === PHP_SESSION_ACTIVE) {
            @session_write_close();
        }
    }

    /**
     * 历史存证「重新下发」权限：与审批列表统一为 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
    {
        $query->where(function ($q) {
            $q->whereIn('wflow_status', ProcuremenStatus::wflowApprovedValues())
                ->whereOr('status', 'in', ProcuremenStatus::poCompletedValues());
        });
    }

    /**
     * 与 collapseArchiveRowsByOrder 一致：有订单号按 CCYDH 合并，空单号按 id
     */
    protected function archiveOrderGroupKeySql(): string
    {
        return "IF(TRIM(IFNULL(`CCYDH`,''))='', CONCAT('_id_', `id`), TRIM(`CCYDH`))";
    }

    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';
            $groupKeySql = $this->archiveOrderGroupKeySql();

            $total = 0;
            try {
                $countQuery = Db::table('purchase_order');
                $applyFilters($countQuery);
                $subSql = $countQuery->fieldRaw($groupKeySql . ' AS gk')->group($groupKeySql)->buildSql();
                $cntRows = Db::query('SELECT COUNT(*) AS c FROM ' . $subSql . ' _archive_g');
                $total = (int)($cntRows[0]['c'] ?? 0);
            } catch (\Throwable $e) {
                try {
                    $countQuery = Db::table('purchase_order');
                    $applyFilters($countQuery);
                    $total = (int)$countQuery->count('DISTINCT CCYDH');
                } catch (\Throwable $e2) {
                    $total = 0;
                }
            }

            if ($total <= 0) {
                return json(['total' => 0, 'rows' => []]);
            }

            $orderSql = 'MAX(`id`) ' . $orderDir;
            if ($sortField === 'CCYDH') {
                $orderSql = $groupKeySql . ' ' . $orderDir;
            } elseif (in_array($sortField, ['CYJMC', 'CGYMC', 'pick_company_name'], true)) {
                $orderSql = 'MAX(`' . $sortField . '`) ' . $orderDir;
            }

            $pageQuery = Db::table('purchase_order');
            $applyFilters($pageQuery);
            try {
                $groups = $pageQuery
                    ->fieldRaw($groupKeySql . ' AS gk, MAX(`id`) AS max_id')
                    ->group($groupKeySql)
                    ->orderRaw($orderSql)
                    ->limit($offset, $limit)
                    ->select();
            } catch (\Throwable $e) {
                $groups = [];
            }
            if (!is_array($groups) || $groups === []) {
                return json(['total' => $total, 'rows' => []]);
            }

            $ccydhs = [];
            $orphanIds = [];
            foreach ($groups as $g) {
                if (!is_array($g)) {
                    continue;
                }
                $gk = trim((string)($g['gk'] ?? ''));
                if ($gk === '') {
                    continue;
                }
                if (strpos($gk, '_id_') === 0) {
                    $oid = (int)substr($gk, 4);
                    if ($oid > 0) {
                        $orphanIds[$oid] = true;
                    }
                } else {
                    $ccydhs[$gk] = true;
                }
            }
            $ccydhList = array_keys($ccydhs);
            $orphanIdList = array_keys($orphanIds);
            if ($ccydhList === [] && $orphanIdList === []) {
                return json(['total' => $total, 'rows' => []]);
            }

            $detailQuery = Db::table('purchase_order');
            $applyFilters($detailQuery);
            $detailQuery->field('id,scydgy_id,CCYDH,CYJMC,CGYMC,pick_company_name,createtime,dStamp,pick_time');
            $detailQuery->where(function ($q) use ($ccydhList, $orphanIdList) {
                if ($ccydhList !== []) {
                    $quoted = [];
                    foreach ($ccydhList as $dh) {
                        $quoted[] = "'" . str_replace("'", "''", (string)$dh) . "'";
                    }
                    $q->whereRaw('TRIM(`CCYDH`) IN (' . implode(',', $quoted) . ')');
                }
                if ($orphanIdList !== []) {
                    if ($ccydhList !== []) {
                        $q->whereOr('id', 'in', $orphanIdList);
                    } else {
                        $q->where('id', 'in', $orphanIdList);
                    }
                }
            });
            $rows = $detailQuery->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);
                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);
            $pageRows = $this->reorderArchiveRowsByGroupKeys($merged, $groups);

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

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

    /**
     * @param array<int, array<string, mixed>> $merged
     * @param array<int, array<string, mixed>> $groups
     * @return array<int, array<string, mixed>>
     */
    protected function reorderArchiveRowsByGroupKeys(array $merged, array $groups): array
    {
        $pos = [];
        foreach ($groups as $i => $g) {
            if (!is_array($g)) {
                continue;
            }
            $gk = trim((string)($g['gk'] ?? ''));
            if ($gk !== '') {
                $pos[$gk] = $i;
            }
        }
        if ($pos === []) {
            return $merged;
        }
        usort($merged, function ($a, $b) use ($pos) {
            $ka = trim((string)($a['CCYDH'] ?? ''));
            if ($ka === '') {
                $ka = '_id_' . (int)($a['id'] ?? 0);
            }
            $kb = trim((string)($b['CCYDH'] ?? ''));
            if ($kb === '') {
                $kb = '_id_' . (int)($b['id'] ?? 0);
            }
            $ia = $pos[$ka] ?? 999999;
            $ib = $pos[$kb] ?? 999999;
            if ($ia === $ib) {
                return ((int)($b['id'] ?? 0)) <=> ((int)($a['id'] ?? 0));
            }

            return $ia <=> $ib;
        });

        return array_values($merged);
    }

    /**
     * 历史存证：同一订单号 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);
            } else {
                $merged['createtime'] = 0;
                $merged['createtime_text'] = '';
            }
            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;
    }
}