tool/application/admin/controller/Picking.php

<?php

namespace app\admin\controller;

use app\common\controller\Backend;
use think\Db;
use Think\Exception;
/**
 * 领料单
 *
 * @icon fa fa-circle-o
 */
class Picking extends Backend
{

    /**
     * Picking模型对象
     * @var \app\admin\model\Picking
     */
    protected $model = null;
    protected $searchFields = 'order,picking,matter';

    public function _initialize()
    {
        parent::_initialize();
        $this->model = new \app\admin\model\Picking;

    }

    /**
     * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
     * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
     * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
     */
    public function order(){
        $data = $this->request->request();
        if ($this->request->isAjax()) {
            $params['pagesize'] = is_null($data['limit']) ? 10 : $data['limit'];//初始查询位置
            if ($data['limit'] == 0){
                $params['page'] = 1;
            }else{
                $params['page'] = $data['offset'] / 10 + 1;
            }
            $search = array();
            if (!empty($data['filter'])){
                $search = json_decode($data['filter'],true);
            }
//            print_r($search);die;
            /**
             * year(Gy0_sj1)=1900 表明尚未排单
             * year(Gy0_sj1)>1900 表明在排单中,
             * Pd_wg为真,表明工序结束
             * */
            if (!empty($search)){
                $gdbh = isset($search['Gd_gdbh'])?$search['Gd_gdbh']:'';
                $jtbh = isset($search['Gy0_sbbh'])?'%'.$search['Gy0_sbbh'].'%':'%JY%';
                if ($gdbh){
                    $sql = "SELECT DISTINCT(a.Gd_gdbh),a.Gd_cpmc,a.gd_statu,b.Gy0_sbbh,b.Gy0_sj1,b.Gy0_sj2,b.PD_WG FROM `工单_基本资料` a
                         LEFT JOIN `工单_工艺资料` b ON a.Gd_gdbh = b.Gy0_gdbh
                         WHERE (a.gd_statu = '2-生产中' OR a.gd_statu='3-计划中') AND a.Gd_cpmc !='' AND a.行号 = 1
                         AND b.Gy0_sbbh LIKE '{$jtbh}' AND YEAR(b.Gy0_sj1) > 1900 AND YEAR(b.Gy0_sj1)<2099 AND YEAR(b.PD_WG) = 1900 
                         AND a.Gd_gdbh = {$gdbh} 
                         ORDER BY b.Gy0_sbbh ASC ,b.Gy0_sj1 ASC ";
                }else{
                    $sql = "SELECT DISTINCT(a.Gd_gdbh),a.Gd_cpmc,a.gd_statu,b.Gy0_sbbh,b.Gy0_sj1,b.Gy0_sj2,b.PD_WG FROM `工单_基本资料` a
                         LEFT JOIN `工单_工艺资料` b ON a.Gd_gdbh = b.Gy0_gdbh
                         WHERE (a.gd_statu = '2-生产中' OR a.gd_statu='3-计划中') AND a.Gd_cpmc !='' AND a.行号 = 1
                         AND b.Gy0_sbbh LIKE '%{$jtbh}%' AND YEAR(b.Gy0_sj1) > 1900 AND YEAR(b.Gy0_sj1)<2099 AND YEAR(b.PD_WG) = 1900 
                         ORDER BY b.Gy0_sbbh ASC ,b.Gy0_sj1 ASC ";
                }
                $res = Db::connect('db2')
                    ->query($sql);
            }else{
                $res =  Db::connect('db2')
                    ->query("SELECT DISTINCT(a.Gd_gdbh),a.Gd_cpmc,a.gd_statu,b.Gy0_sbbh,b.Gy0_sj1,b.Gy0_sj2,b.PD_WG FROM `工单_基本资料` a
                         LEFT JOIN `工单_工艺资料` b ON a.Gd_gdbh = b.Gy0_gdbh
                         WHERE (a.gd_statu = '2-生产中' OR a.gd_statu='3-计划中') AND a.Gd_cpmc !='' AND a.行号 = 1
                         AND b.Gy0_sbbh LIKE '%JY%' AND YEAR(b.Gy0_sj1) > 1900 AND YEAR(b.Gy0_sj1)<2099 AND YEAR(b.PD_WG) = 1900
                         ORDER BY b.Gy0_sbbh ASC ,b.Gy0_sj1 ASC ");
            }
            foreach ($res as $key=>$val){
                $id = $val['Gd_gdbh'];
                $res[$key]['id'] = $id;
            }
            $total = count($res);
//            $res = array_slice($res,$data['offset'],$data['limit']);//分页
            $result = array("total" => $total, "rows" => $res);
            return json($result);
        }
        return $this->view->fetch();
    }
    /**
     * 查看
     */
    public function index()
    {
        //设置过滤方法
        $this->request->filter(['strip_tags']);
        if ($this->request->isAjax()) {
            //如果发送的来源是Selectpage，则转发到Selectpage
            if ($this->request->request('keyField')) {
                return $this->selectpage();
            }
            list($where, $sort, $order, $offset, $limit) = $this->buildparams();
            $total = $this->model
                ->where($where)
                ->order($sort, $order)
                ->count();

            $list = $this->model
                ->where($where)
                ->order($sort, $order)
                ->limit($offset, $limit)
                ->select();
//            dump($list);die;
            $list = collection($list)->toArray();
            $result = array("total" => $total, "rows" => $list);

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

    /**
     * 领料单界面数据
     */
    public function picking(){
        $result = $this->validatePicking(input('temp'));
        if (!$result['valid']) {
            $this->dialogError($result['msg']);
        }
        return $this->view->fetch('add', $result['data']);
    }

    /**
     * 生成领料单前校验（Ajax）
     */
    public function checkPicking()
    {
        $result = $this->validatePicking(input('temp'));
        if ($result['valid']) {
            $this->success('可以生成领料单');
        }
        $this->error($result['msg']);
    }

    /**
     * 校验选中工单是否具备领料配方数据
     */
    protected function validatePicking($data)
    {
        $gdbh = array_filter(explode(',', $data));
        if (empty($gdbh)) {
            return ['valid' => false, 'msg' => '请先选择要生成领料单的工单'];
        }

        $list = [];
        foreach ($gdbh as $key => $value) {
            $sql = "SELECT GD_gdbh AS gdbh,成品名称 as name,Gd_cpdh AS cpdh,计划投料 AS num FROM `工单_基本资料` WHERE Gd_gdbh = ? AND `行号`= 1";
            $res = Db::connect('db2')->query($sql, [$value]);
            if (empty($res[0])) {
                return ['valid' => false, 'msg' => '查不到工单【' . $value . '】，请确认工单是否存在'];
            }
            $list[$key] = $res[0];
        }

        $consumeList = [];
        $formulaList = [];
        $total = [];
        foreach ($list as $k => $val) {
            $formulaList = [];
            $box = $this->isBigOrSmall(trim($val['name']));
            if ($box == -1) {
                return ['valid' => false, 'msg' => '工单【' . $val['gdbh'] . '】产品【' . trim($val['name']) . '】无法识别大小盒类型，请联系开发人员'];
            }
            $productNumber = trim($val['cpdh']);
            if ($productNumber === '') {
                return ['valid' => false, 'msg' => '工单【' . $val['gdbh'] . '】产品编码为空，无法生成领料单'];
            }

            $where = [];
            $where[] = ['exp', Db::raw("FIND_IN_SET(:pn, product_number)")];
            $bind = ['pn' => $productNumber];

            $consume = Db::name('formula_consume')
                ->bind($bind)
                ->where($where)
                ->where('number', 'neq', '')
                ->where('box', $box)
                ->field('ink,number,code')
                ->select();

            $formmula = Db::name('formula_detail')->bind($bind)->where($where)->field('color,ink,ink_number,number,total,code')->select();

            if (empty($consume)) {
                return ['valid' => false, 'msg' => '工单【' . $val['gdbh'] . '】产品编码【' . $productNumber . '】未配置原墨消耗配方，请联系开发人员维护后再生成领料单'];
            }

            $num = count($consume);
            for ($i = 0; $i < $num; $i++) {
                $weight = round(trim($consume[$i]['number']) * $val['num'] / 10000, 3);
                $consume[$i]['number'] = $weight;

                if (empty($consume[$i]['code'])) {
                    foreach ($formmula as $j => $v) {
                        if ($v['color'] == $consume[$i]['ink']) {
                            $formulaList['ink'] = $v['ink'];
                            $formulaList['number'] = round($weight / $v['number'] * $v['total'] / 1000, 3);
                            $formulaList['code'] = $v['code'];
                            array_push($consume, $formulaList);
                        }
                    }
                    unset($consume[$i]);
                }
            }
            $consume = array_values($consume);

            foreach ($consume as &$item) {
                $total[] = $item;
            }
            $consumeList[$k]['gdbh'] = $val['gdbh'];
            $consumeList[$k]['cpdh'] = $val['cpdh'];
            $consumeList[$k]['name'] = trim($val['name']);
            $consumeList[$k]['num'] = $val['num'];
            $consumeList[$k]['inkData'] = $this->sumWeight($consume, 'code', 'number');
            $consumeList[$k]['total'] = count($consumeList[$k]['inkData']);
        }

        $bach = date('Ymd') . rand(100, 1000);
        $totalList = $this->sumWeight($total, 'code', 'number');
        return [
            'valid' => true,
            'msg' => 'ok',
            'data' => compact('consumeList', 'totalList', 'bach'),
        ];
    }
    /**
     * 新增领料单数据保存
    */
    public function doAdd()
    {
        if ($this->request->isPost()) {
            $headData = $this->request->post("headData/a");
            $footData = $this->request->post("footData/a");
            if ($headData && $footData) {
                $headData = $this->preExcludeFields($headData);
                //处理每个工单领料的数据
                $headList = [];
                foreach ($headData as $key =>$value){
                    if (count($value) == 5){
                        $headList[$key] = $value;
                        unset($headData[$key]);
                    }
                }
                $headRes = [];//定义插入数据库的数组
                $bach = $footData[0][0];//获取单据编号用于详细数据
                $order = [];
                foreach ($headList as $k=>$v){
                    $headData = array_values($headData);
                    $number = $v[4];
                    $order[$k] = $v[0];
                    foreach ($headData as $i=>$j){
                        if ($i < $number){
                            $res = [];
                            $res['picking'] = $bach;
                            $res['order'] = $v[0];
                            $res['product_name'] = $v[1];
                            $res['number'] = $v[2];
                            $res['matter'] = $j[1];
                            $res['matter_code'] = $j[0];
                            $res['weight'] = $j[2];
                            $res['create'] = date('Y-m-d H:i:s');
                            array_push($headRes,$res);
                            unset($headData[$i]);
                        }
                    }
                }
                //处理领料单统计数据
                $orderNumber = implode(',',$order);
                $footRes = [];//定义插入数据库的数组
                foreach ($footData as $key1=>$value1){
                    if ($key1 > 0){
                        $result = [];
                        $result['picking'] = $bach;
                        $result['order'] = $orderNumber;
                        $result['matter'] = $value1[1];
                        $result['code'] = $value1[0];
                        $result['weight'] = $value1[2];
                        $result['create'] = date('Y-m-d H:i:s');
                        array_push($footRes,$result);
                    }
                }
                $result = false;
                Db::startTrans();
                try {
                    $resOne = Db::name('picking')->insertAll($footRes);
                    $resTwo = Db::name('picking_detail')->insertAll($headRes);
                    Db::commit();
                    if ($resOne && $resTwo){
                        $result = true;
                    }
                } catch (ValidateException $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                } catch (PDOException $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                } catch (Exception $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                }
                if ($result !== false) {
//                    $this->success('保存成功','picking/index');
                    return array('code'=>1,'msg'=>'保存成功');
                } else {
                    $this->error(__('No rows were inserted'));
                }
            }
            $this->error(__('Parameter %s can not be empty', ''));
        }
//        return $this->view->fetch();
    }


    /**
     * 判断是大盒还是小盒
     * 条盒：条盒、条包装纸
     * 小盒：小盒、盒包装纸、烟盒、商标
     */
    public function isBigOrSmall($name){
        $result = -1;
        if (!empty($name)){
            $boxName = ['条盒','条包装纸'];
            $smallName = ['小盒','盒包装纸','烟盒','商标'];
            $smallCover = ['小盒上盖'];
            $lining = ['内衬纸'];
            $sticker = ['内贴'];
            $vegetable = ['硫酸纸'];
            foreach ($boxName as $key=>$value){
                $res = strpos($name,$value);
                if ($res !== false){
                    $result = 1;
                }
            }
            foreach ($smallName as $k=>$val){
                $res = strpos($name,$val);
                if ($res !== false){
                    $result = 2;
                }
            }
            foreach ($smallCover as $i=>$item){
                $res = strpos($name,$item);
                if ($res !== false){
                    $result = 3;
                }
            }
            foreach ($lining as $j=>$vol){
                $res = strpos($name,$vol);
                if ($res !== false){
                    $result = 4;
                }
            }
            foreach ($sticker as $p=>$v){
                $res = strpos($name,$v);
                if ($res !== false){
                    $result = 5;
                }
            }
            foreach ($vegetable as $o=>$vo){
                $res = strpos($name,$vo);
                if ($res !== false){
                    $result = 6;
                }
            }
            return $result;
        }
        return $result;
    }

    /**
     * 计算原墨数量，值去重&相加
    */
    function sumWeight($arr,$str1,$str2) {
        $item = array();
        foreach ($arr as $k => $v) {
            if (!isset($item[$v[$str1]])) {
                $item[$v[$str1]] = $v;
            } else {
                $item[$v[$str1]][$str2] += $v[$str2];
            }
        }
        return array_values($item);

    }
}