mes-dc-server-api/application/api/controller/MonthlyGarments.php

<?php

namespace app\api\controller;


use app\common\controller\Api;
use Monolog\Handler\IFTTTHandler;
use Overtrue\Socialite\Providers\WeWorkProvider;
use think\Db;
use think\Request;
use function fast\e;

/**
 *
 * 生产单衣进度管理
 */
class MonthlyGarments extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

     /**
 * 样衣进度左侧数据
 */
    public function getDateTree()
    {
        if (!$this->request->isGet()) {
            $this->error('请求错误');
        }

        $results = \db('月度样衣进度')
            ->field([
                'DATE_FORMAT(Sys_rq, "%Y-%m")' => '年月',
                '客户编号',
                'COUNT(*) as total'
            ])
            ->whereNull('Mod_rq')
            ->group('年月, 客户编号')
            ->order('年月 DESC')
            ->select();

        $formattedData = [];

        foreach ($results as $row) {
            $yearMonth = $row['年月'];
            $customerCode = $row['客户编号'];
            $total = $row['total'];

            if (!isset($formattedData[$yearMonth])) {
                $formattedData[$yearMonth] = [];
            }

            $formattedData[$yearMonth][] = [
                '客户编号' => $customerCode,
                'total' => $total
            ];
        }

        krsort($formattedData);

        $this->success('成功', $formattedData);
    }

    /**
     * 样衣进度列表数据（支持分页）
     * @param string sys_rq 年月，如 2026-09
     * @param string customer 客户编号
     * @param string search 搜索
     * @param int page 页码，默认1
     * @param int pageSize|limit 每页条数，默认30
     */
    public function getMonthlyGarmentsList()
    {
        if (!$this->request->isGet()) {
            $this->error('请求错误');
        }

        $yearMonth = $this->request->param('sys_rq', '');
        $customerCode = $this->request->param('customer', '');
        $search = $this->request->param('search', '');
        $page = max(1, intval($this->request->param('page', 1)));
        $limit = intval($this->request->param('pageSize', 0));
        if ($limit <= 0) {
            $limit = intval($this->request->param('limit', 30));
        }
        $limit = max(1, min(200, $limit));
        $offset = ($page - 1) * $limit;

        // 不要 clone 查询对象：ThinkPHP 预处理绑定会被 count 吃掉，再 select 会报 2031
        $applyFilters = function ($query) use ($yearMonth, $customerCode, $search) {
            $query->whereNull('Mod_rq');

            if ($yearMonth) {
                $monthStart = $yearMonth . '-01 00:00:00';
                $monthEnd = date('Y-m-d H:i:s', strtotime($monthStart . ' +1 month'));
                $query->where('Sys_rq', '>=', $monthStart)
                    ->where('Sys_rq', '<', $monthEnd);
            }

            if ($customerCode === '__EMPTY__') {
                $query->where(function ($q) {
                    $q->whereNull('客户编号')->whereOr('客户编号', '');
                });
            } elseif ($customerCode) {
                $query->where('客户编号', $customerCode);
            }

            if ($search) {
                $query->where(function ($q) use ($search) {
                    $q->where('客户编号', 'like', "%{$search}%")
                      ->whereOr('款号', 'like', "%{$search}%")
                      ->whereOr('款式', 'like', "%{$search}%");
                });
            }

            return $query;
        };

        $total = (int)$applyFilters(\db('月度样衣进度'))->count();
        $results = $applyFilters(\db('月度样衣进度'))
            ->order('UniqId DESC')
            ->limit($offset, $limit)
            ->select();

        foreach ($results as &$row) {
            if (!empty($row['下单日期'])) {
                $row['下单日期'] = date('Y-m-d', strtotime($row['下单日期']));
            }
            if (!empty($row['计划交办日期'])) {
                $row['计划交办日期'] = date('Y-m-d', strtotime($row['计划交办日期']));
            }
        }
        unset($row);

        $this->success('成功', [
            'result' => $results,
            'total' => $total,
            'page' => $page,
            'pageSize' => $limit,
        ]);
    }

 /**
     * 样衣进度新增数据
 */
    public function saveMonthlyGarments()
    {
        if (!$this->request->isPost()) {
            $this->error('请求错误');
        }

        $data = $this->request->post();

        $customerCode = $data['客户编号'] ?? '';
        $styleNo = $data['款号'] ?? '';
        $style = $data['款式'] ?? '';
        $sampleType = $data['样办种类'] ?? '';
        $department = $data['做办部门'] ?? '';
        $quantity = isset($data['数量']) && $data['数量'] !== '' ? (int)$data['数量'] : 0;
        $orderDate = (!empty($data['下单日期'])) ? "'{$data['下单日期']}'" : 'NULL';
        $fabricProgress = $data['面料进度'] ?? '';
        $auxiliaryProgress = $data['辅料进度'] ?? '';
        $planDeliveryDate = (!empty($data['计划交办日期'])) ? "'{$data['计划交办日期']}'" : 'NULL';
        $actualDeliveryDate = (!empty($data['实际交办日期'])) ? "'{$data['实际交办日期']}'" : 'NULL';
        $remark = $data['备注'] ?? '';
        $sysId = $data['Sys_id'] ?? '';
        $sysRq = date('Y-m-d H:i:s');

        $sql = "INSERT INTO `月度样衣进度` (`客户编号`, `款号`, `款式`, `样办种类`, `做办部门`, `数量`, `下单日期`, `面料进度`, `辅料进度`, `计划交办日期`, `实际交办日期`, `备注`, `Sys_id`, `Sys_rq`, `Mod_rq`) VALUES ('{$customerCode}', '{$styleNo}', '{$style}', '{$sampleType}', '{$department}', {$quantity}, {$orderDate}, '{$fabricProgress}', '{$auxiliaryProgress}', {$planDeliveryDate}, {$actualDeliveryDate}, '{$remark}', '{$sysId}', '{$sysRq}', NULL)";
        
        $result = \db()->execute($sql);

        if ($result !== false) {
            $lastId = \db('月度样衣进度')->getLastInsID();
            $this->success('保存成功', ['id' => $lastId]);
        } else {
            $this->error('保存失败');
        }
    }
     /**
 * 样衣进度修改数据
 */
    public function updateMonthlyGarments()
    {
        if (!$this->request->isPost()) {
            $this->error('请求错误');
        }

        $data = $this->request->post();
        $uniqId = $data['UniqId'] ?? '';
        $nickName = $data['nickName'] ?? '';

        if (!$uniqId) {
            $this->error('UniqId不能为空');
        }

        $oldData = \db('月度样衣进度')->where('UniqId', $uniqId)->find();

        $customerCode = $data['客户编号'] ?? '';
        $styleNo = $data['款号'] ?? '';
        $style = $data['款式'] ?? '';
        $sampleType = $data['样办种类'] ?? '';
        $department = $data['做办部门'] ?? '';
        $quantity = isset($data['数量']) && $data['数量'] !== '' ? (int)$data['数量'] : 0;
        $orderDate = (!empty($data['下单日期'])) ? "'{$data['下单日期']}'" : 'NULL';
        $fabricProgress = $data['面料进度'] ?? '';
        $auxiliaryProgress = $data['辅料进度'] ?? '';
        $planDeliveryDate = (!empty($data['计划交办日期'])) ? "'{$data['计划交办日期']}'" : 'NULL';
        $actualDeliveryDate = (!empty($data['实际交办日期'])) ? "'{$data['实际交办日期']}'" : 'NULL';
        $remark = $data['备注'] ?? '';
        $sysRq = date('Y-m-d H:i:s');

        $sql = "UPDATE `月度样衣进度` SET `客户编号`='{$customerCode}', `款号`='{$styleNo}', `款式`='{$style}', `样办种类`='{$sampleType}', `做办部门`='{$department}', `数量`={$quantity}, `下单日期`={$orderDate}, `面料进度`='{$fabricProgress}', `辅料进度`='{$auxiliaryProgress}', `计划交办日期`={$planDeliveryDate}, `实际交办日期`={$actualDeliveryDate}, `备注`='{$remark}', `Sys_rq`='{$sysRq}' WHERE `UniqId`='{$uniqId}'";

        $result = \db()->query($sql);

        if ($result !== false) {
            $this->saveLogs($uniqId, $oldData, $data, $nickName);
            $this->success('修改成功');
        } else {
            $this->error('修改失败');
        }
    }

 

    public function deleteMonthlyGarments()
    {
        if (!$this->request->isPost()) {
            $this->error('请求错误');
        }

        $data = $this->request->post();
        $uniqId = $data['UniqId'] ?? '';
        $nickName = $data['nickName'] ?? '';

        if (!$uniqId) {
            $this->error('UniqId不能为空');
        }

        // 支持多个 UniqId（逗号分隔），逐条删除
        $idList = array_filter(array_map('trim', explode(',', $uniqId)));
        if (empty($idList)) {
            $this->error('UniqId不能为空');
        }

        $modRq = date('Y-m-d H:i:s');
        $successCount = 0;
        foreach ($idList as $id) {
            $safeId = addslashes($id);
            $sql = "UPDATE `月度样衣进度` SET `Mod_rq`='{$modRq}' WHERE `UniqId`='{$safeId}'";
            $result = \db()->query($sql);
            if ($result !== false) {
                $successCount++;
            }
        }

        if ($successCount > 0) {
            $this->success('删除成功');
        } else {
            $this->error('删除失败');
        }
    }

    /**
     * 样衣进度存储日志数据
     */
    private function saveLogs($uniqId, $oldData, $newData, $operator)
    {
        $fields = ['客户编号', '款号', '款式', '样办种类', '做办部门', '数量', '下单日期', '面料进度', '辅料进度', '计划交办日期', '实际交办日期', '备注'];
        $modifyTime = date('Y-m-d H:i:s');

        foreach ($fields as $field) {
            $oldValue = $oldData[$field] ?? '';
            $newValue = $newData[$field] ?? '';

            if ((string)$oldValue !== (string)$newValue) {
                $sql = "INSERT INTO `样衣进度日志` (`Uniqid`, `ModifyField`, `OriginalValue`, `Modified`, `修改人`, `修改日期`) VALUES ('{$uniqId}', '{$field}', '{$oldValue}', '{$newValue}', '{$operator}', '{$modifyTime}')";
                \db()->query($sql);
            }
        }
    }

    /**
     * 样衣进度日志数据
     */
    public function getLogs()
    {
        if (!$this->request->isGet()) {
            $this->error('请求错误');
        }

        $uniqId = $this->request->get('UniqId') ?? '';

        if (!$uniqId) {
            $this->error('UniqId不能为空');
        }

        $logs = \db('样衣进度日志')
            ->where('Uniqid', $uniqId)
            ->order('修改日期', 'desc')
            ->select();

        $this->success('获取成功', ['result' => $logs, 'total' => count($logs)]);
    }
}