<?php

namespace app\common\model;
use function PHPSTORM_META\map;
use think\Db;
use think\Exception;

class WasteRecord extends Base {
    public $table = 'waste_record';
    protected $validateName = 'WasteRecord';
    public $status = [
        '已收取',
        '已交接',
        '已转运',
        '医废异常',
        '未转运',
    ];

    public function updates($type=0){ //type=0克 type=1千克
        $data = request()->post();
        $data['org_id'] = cur_org_id();

        if($data['cateid'] < 1){
            $this->error ='类型不能为空';
            return false;
        }
//
//        if($data['waste_device_id'] < 1){
//            $this->error ='收取地点不能为空';
//            return false;
//        }
        if($data['user_id'] < 1){
            $this->error ='收取人不能为空';
            return false;
        }

        if($data['weight'] < 0.1){
            $this->error ='重量不能为空';
            return false;
        }
        if(!$data['create_time']){
            $this->error ='收取时间不能为空';
            return false;
        }
        if($type == 1){
            $data['weight'] = $data['weight']*1000;
        }
        $data['serial_number'] = get_unique_id();
        $data['create_yyyy'] = date('Y',strtotime($data['create_time']));
        $data['create_yyyymm'] = date('Ym',strtotime($data['create_time']));
        $data['create_yyyymmdd'] = date('Ymd',strtotime($data['create_time']));


        $id = $data['id'];
        unset($data['id']);

        $data['status'] = 1;
        $ret = $this->allowField(true)->save($data);
        $waste_record_id = $this->id;

        $sdata[] = [
            'status' => 0,
            'create_time' => $data['create_time'],
            'user_id' => $data['user_id'],
            'waste_record_id' => $waste_record_id,
        ];
        $sdata[] = [
            'status' => 1,
            'create_time' => $data['create_time'],
            'user_id' => $data['user_id'],
            'waste_record_id' => $waste_record_id,
        ];
        $res = Db::name('waste_record_user')->insertAll( $sdata);
        if(!$res){
            $this->error = '操作失败';
            return false;
        }

        if(!$ret){
            $this->error = '操作失败';
            return false;
        }



        return true;
    }


    /**
     * 医废记录详情
     *
     * @author wst
     * @date   2021/9/8 17:32
     * @return array
     */
    public function info($id,$orgId){
        $info = $this->getOne($id,$orgId);
        if($info){
            $info['real_name'] = Db::name('user')
            ->where('id',$info['user_id'])
            ->value('real_name');
            $info['waste_device'] = Db::name('address')
                ->where('id',$info['waste_device_id'])
                ->value('title');
            $info['cate'] = Db::name('waste_type')
                ->where('id',$info['cateid'])
                ->value('title');
            $info['weight'] =round($info['weight']/1000,2);
            $info['status'] =$this->status[$info['status']];

            $rlist = Db::name('waste_record_user')
                ->alias('waste_record_user')
                ->join('user user','user.id = waste_record_user.user_id')
                ->where('waste_record_user.waste_record_id',$info['id'])
                ->field('waste_record_user.*,user.real_name')
                ->order('status', 'asc')
                ->select();

            $info['rlist'] = $rlist?$rlist:array();
            $info = json_decode(json_encode($info),true);
        }
        return $info;
    }
    //转运
    public function finish($id,$user_id){
        $this->startTrans();
        try{
            $ret = $this
                ->where('id', $id)
                ->update(['status'=>2]);
            if(!$ret){
                throw new Exception('更新状态失败');
            }
            $ret2 = Db::name('waste_record_user')->insert(array(
                'waste_record_id' => $id,
                'user_id' => $user_id,
                'status' => 2,
                'create_time' => getTime()
            ));
            if(!$ret2){
                throw new exception('保存操作记录失败');
            }
            $this->commit();
            return true;
        }catch (exception $e){
            $this->rollback();
            $this->error=$e->getMessage();
            return false;
        }
    }
    public function getOne($id,$orgId=0){
        $info = $this
             ->where('id',$id)
             ->where('org_id',$orgId)
             ->whereOr('serial_number',$id)
            ->find()
            ->toArray();
        return $info;
    }

    /*----------------api----------------*/

    public function recordInfo($serialNum,$orgId){
        $map[] = ['serial_number','=',$serialNum];
        $map[] = ['org_id','=',$orgId];
        $map[] = ['del','=',0];
        $info = $this->field('id,serial_number,org_id,waste_device_id,user_id,cateid,weight,status,create_time,reason,is_print,weight2')
           ->where($map)->find();

        $info = $info?$info->toArray():[];
        if(!$info){
            $this->error = '记录不存在';
            return false;
        }
        $org = Db::name('org')
            ->where('id',$info['org_id'])
            ->field('name')->find();

        $info['org_name'] = $org?$org['name']:'';
        $user = Db::name('user')
            ->where('id',$info['user_id'])
            ->field('real_name')->find();
        $info['real_name'] = $user?$user['real_name']:'';
        $wasteDevice = Db::name('address')
            ->where('id',$info['waste_device_id'])
            ->field('title')
            ->find();
        $info['title'] = $wasteDevice?$wasteDevice['title']:'';
        $info['cate_id'] = $info['cateid'];
        $info['cate_name'] =Db::name('waste_type')
        ->where('id',$info['cateid'])->value('title');
        unset($info['cateid']);


        $lists = Db::name('waste_record_user')
            ->alias('wru')
            ->where('wru.waste_record_id',$info['id'])
            ->join('user u','u.id = wru.user_id')
            ->field('u.real_name,wru.status,wru.create_time')
            ->order('wru.id asc')
           ->select();
        $data = [
            'type' => 1, // 1=医废记录详情 2=医废包详情
            'info' => $info,
            'status_list' => $lists?$lists:[]
        ];
        return $data;
    }


    public function queryIsPrint($id){
        $ret=$this
            ->where('id',$id)
            ->field('is_print')
            ->find()->toArray();
        return  $ret;
    }
    public function wasteRecordList($orgId,$status,$createTime,$page,$size){
        $offset= ($page - 1) * $size;
        $starttime=$createTime.' 00:00:00';
        $endtime=$createTime.' 23:59:59';
        $where[] = ['create_time','between',[$starttime,$endtime]];
        $list=$this
            ->field('waste_device_id,cateid,create_time,is_print,serial_number,id,weight')
            ->where([
                'org_id'=>$orgId,
                'status'=>$status,
                'del'=>0,
            ])
            ->where($where)
            ->order('id desc')
            ->limit($offset,$size)
             ->select()->toArray();
        $ret['list']=$list;
        foreach ($list as $k=>$v){
            $title=Db::name('address')
                ->where([
                    'id'=>$v['waste_device_id'],
                    'del'=>0,
                    'enable'=>1,
                ])->value('title');
            $ret['list'][$k]['title']= $title;
            $cate = Db::name('waste_type')
                ->where('id',$v['cateid'])
                ->value('title');
            $ret['list'][$k]['cate_title']= $cate;
        }
        return $ret;
    }
    public function unTransportList($orgId,$createTime){
        $where = [];
        if($createTime){
            $starttime=$createTime.' 00:00:00';
            $endtime=$createTime.' 23:59:59';
            $where[] = ['create_time','between',[$starttime,$endtime]];
          }

        $list=$this
            ->field('waste_device_id,cateid,create_time,is_print,serial_number,id,weight')
            ->where('org_id',$orgId)
            ->where('del',0)
            ->where($where)
            ->where('status','in',[0,1])
            ->order('id','desc')
            ->select()
            ->toArray();
        $ret['list']=$list;
        foreach ($list as $k=>$v){
            $title=Db::name('address')
                ->where([
                    'id'=>$v['waste_device_id'],
                    'del'=>0,
                    'enable'=>1,
                ])->value('title');
            $ret['list'][$k]['title']= $title;
            $cate =Db::name('waste_type')
                ->where('id',$v['cateid'])
                ->value('title');;
            $ret['list'][$k]['cate_title']= $cate;
        }

        return $ret;
    }
    public function saveRecord($data){
        $curtime = getTime();
        $data['serial_number'] = get_unique_id();
        $data['create_time'] = $curtime;
        $data['create_yyyy'] = date('Y');
        $data['create_yyyymm'] = date('Ym');
        $data['create_yyyymmdd'] = date('Ymd');

        $this->startTrans();
        try{
            $waste_record_id = $this->insertGetId($data);
            if (!$waste_record_id) {
                throw new Exception('保存记录失败');
            }
            $sdata = [
                'status' => 0,
                'create_time' => $curtime,
                'user_id' => $data['user_id'],
                'waste_record_id' => $waste_record_id,
            ];
            $res = Db::name('waste_record_user')->insert( $sdata);
            if (!$res) {
                throw new Exception('保存操作记录失败');
            }

            $this->commit();
            return $waste_record_id;
        }catch (Exception $e){
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }
    public function saveStatus($data){
        $info = $this->
        where('serial_number',$data['serialNumber'])
           ->find();
        if(!$info){
            $this->error = '记录不存在';
            return false;
        }

        $curTime = date('Y-m-d H:i:s');
        $this->startTrans();
        try{
            $rdata = [
                'weight2' => isset($data['weight2'])?$data['weight2']:0,
                'status' => $data['status'],
                'reason' => isset($data['reason'])?$data['reason']:'',
                'package_id' => 0 // 有任何变化，都删除与包的关系
            ];
            $ret = $this
                ->where('id',$info['id'])
                ->update( $rdata);
            if (!$ret) {
               \exception('操作失败1');
            }

            $sdata = [
                'status' => $data['status'],
                'create_time' => $curTime,
                'user_id' => $data['userId'],
                'waste_record_id' => $info['id'],
            ];
            $res = Db::name('waste_record_user')
                ->insert($sdata);
            if (!$res) {
               \exception('操作失败');
            }
            // 如果在保内，检查包内是否还有可以记录，没有则删除包记录
            if($info['package_id'] > 0){
                $count = $this
                    ->where('package_id',$info['package_id'])
                    ->where('id','<>',$info['id'])
                    ->count();
                if($count == 0){
                    $res = Db::name('waste_package')->
                        where('id',$info['package_id'])
                        ->update(['del' => 1]);
                    if (!$res) {
                        \exception('操作失败');
                    }
                }
            }
            $this->commit();
        }catch (Exception $e){
            $this->error = '操作失败'.$e->getMessage();
            $this->rollback();
            return false;
        }
        return true;
    }
    public function lists($orgId,$depId,$date,$page,$size,$userId){
        $offset= ($page - 1) * $size;

        $map[]= ['wr.org_id','=',$orgId];
        $map[]= ['wr.sign','=',0];
        $map[]= ['wr.del','=',0];
        $map1[]= ['wr.user_id','=',$userId];

        if($depId){
            $map1[]= ['wd.dep_id','=',$depId];

        }
        if($date){
            $date = date('Ymd',strtotime($date));
            $map[]= ['wr.create_yyyymmdd','=',$date];

        }
        $list =  $this
            ->alias('wr')
            ->join('address wd','wd.id = wr.waste_device_id')
            ->where(function ($query) use ($map1) {
                $query->whereOr($map1);
            })->where($map)->field('wr.waste_device_id,wr.cateid,wr.create_time,wr.is_print,wr.serial_number,wr.id,wr.weight,wr.sign')
            ->order('wr.id','desc')
            ->limit($offset,$size)->select();
        $list = $list?$list->toArray():[];

        foreach ($list as $k=>$v){
            $title=Db::name('address')
                ->where('id',$v['waste_device_id'])
                ->value('title');
            $list[$k]['waste_device_name'] = $title;
            $cate = Db::name('waste_type')->
             where('id',$v['cateid'])->value('title');
            $list[$k]['cate_title']= $cate?$cate:'';
        }

        $ret['list']=$list?$list:[];
        return $ret;
    }

    public function savePackage($post){
        $curTime =getTime();
        $data = [
            'org_id' => $post['org_id'],
            'user_id' => $post['user_id'],
            'ids' => $post['ids'],
            'create_time' => $curTime,
        ];
        // 检查是否符合要求
        $count = Db::name('waste_record')
            ->where('del',0)
            ->where('status',0)
            ->where('package_id',0)
            ->where('user_id',$data['user_id'])
            ->where('id','in',$data['ids'])
            ->count();
        if($count != count($data['ids'])){
            $this->error = '有不符合要求的医废记录';
            return false;
        }

        $this->startTrans();
        try{
            $pData = [
                'org_id' => $post['org_id'],
                'user_id' => $post['user_id'],
                'record' => implode(',',$post['ids']),
                'create_time' => $curTime,
                'sn' => get_unique_id2()
            ];
            $id= Db::name('waste_package')
                ->insertGetId($pData);
            if (!$id) {
                exception('操作失败');
            }
            $sData = [
                'package_id' => $id,
            ];
            $res = $this->where('id','in',$data['ids'])
                ->update( $sData);
            if (!$res) {
                exception('操作失败');
            }
            $this->commit();
        }catch (Exception $e){
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
        return $id;
    }

    public function packInfo($serialNum,$orgId){
        $map[] = ['sn','=',$serialNum];
        $map[] = ['org_id','=',$orgId];
        $map[] = ['del','=',0];
        $info = Db::name('waste_package')
            ->where($map)
            ->field('id,sn,org_id,user_id,status,create_time,jj_time,zy_time,jj_user_id,zy_user_id')
            ->find();
        if(!$info){
            $this->error = '记录不存在';
            return false;
        }
        $org = Db::name('org')
            ->where('id',$info['org_id'])
            ->field('name')->find();

        $info['org_name'] = $org?$org['name']:'';
        $user = Db::name('user')
            ->where('id',$info['user_id'])
            ->field('real_name')->find();
        $info['real_name'] = $user?$user['real_name']:'';
        $info['jj_time'] = $info['jj_time']?$info['jj_time']:'';
        $info['zy_time'] = $info['zy_time']?$info['zy_time']:'';
        if($info['jj_user_id'] > 0){
            $user =  Db::name('user')
                ->where('id',$info['jj_user_id'])
                ->field('real_name')->find();
            $info['jj_real_name'] = $user?$user['real_name']:'';
        }

        if($info['zy_user_id'] > 0){
            $user = Db::name('user')
                ->where('id',$info['zy_user_id'])
                ->field('real_name')->find();
            $info['zy_real_name'] = $user?$user['real_name']:'';
        }
        $weight =$this
            ->where('package_id',$info['id'])
            ->sum('weight');
//        $info['weight'] = $weight?round($weight/1000,2):0;
        $info['weight'] = $weight;

        $count = $this->where('package_id',$info['id'])
          ->count();
        $info['count'] = $count?$count:0;

        $record = Db::name('waste_record')
            ->alias('wr')
            ->where('wr.del',0)
            ->where('wr.package_id',$info['id'])
            ->field('wr.waste_device_id,wr.cateid,wr.create_time,wr.is_print,wr.serial_number,wr.id,wr.weight,wr.sign')
            ->order('wr.id desc')
            ->select();

        foreach ($record as $k=>$v){
            $title=Db::name('address')
                ->field('title')
                ->where('id',$v['waste_device_id'])
                ->find();
            $record[$k]['title'] = $title?$title['title']:'';
            $record[$k]['cate_name'] =Db::name('waste_type')
                ->where('id',$v['cateid'])->value('title');
//            $record[$k]['weight'] = $v['weight']?round($v['weight']/1000,2):0;
            $record[$k]['weight'] = $v['weight']?$v['weight']:0;

        }
        $data = [
            'type' => 2,
            'pinfo' => $info,
            'record' => $record?$record:[]
        ];
        return $data;
    }

    public function packagesLists($orgId,$page,$size,$userId){
        $offset= ($page - 1) * $size;
        $map[] = ['org_id','=',$orgId];
        $map[] = ['user_id','=',$userId];
        $map[] = ['del','=',0];
        $list = Db::name('waste_package')
            ->field('id,sn,org_id,user_id,status,create_time')
            ->order('id desc')
            ->where($map)
            ->limit($offset,$size)
            ->select();

        foreach ($list as $k=>$v){
            $user = Db::name('user')
                ->where('id',$v['user_id'])
                ->field('real_name')
                ->find();
            $list[$k]['real_name'] = $user?$user['real_name']:'';

            $weight = $this->where('package_id',$v['id'])
                ->sum('weight');
            $list[$k]['weight'] = $weight?$weight:0;

            $count = $this->where('package_id',$v['id'])
                ->count();
            $list[$k]['count'] = $count?$count:0;
        }

        return $list?$list:[];
    }

    public function delpackage($orgId,$userId,$id,$recordId){
        $info = $this
            ->where('del',0)
            ->where('org_id',$orgId)
            ->where('package_id',$id)
            ->where('id',$recordId)
            ->find();
        if(!$info){
            $this->error = '记录不存在';
            return false;
        }

        $this->startTrans();
        try{

            $res = $this->where('id',$recordId)
                ->update(['package_id' => 0]);
            if (!$res) {
                exception('操作失败');
            }

            // 如果在保内，检查包内是否还有可以记录，没有则删除包记录
            if($info['package_id'] > 0){
                $count = $this
                    ->where('package_id',$id)
                    ->where('id','<>',$recordId)
                    ->count();
                if($count == 0){
                    $res = Db::name('waste_package')
                        ->where('id',$id)
                        ->update(['del' => 1]);
                    if (!$res) {
                        exception('操作失败');
                    }
                }
            }
            $this->commit();
            return true;
        }catch (Exception $e){
            $this->error = '操作失败'.$e->getmessage();
            $this->rollback();
            return false;
        }
    }

    // 交接
    public function jjpackage($orgId,$userId,$id){
        $info = Db::name('waste_package')
            ->where('del',0)
            ->where('org_id',$orgId)
            ->where('id',$id)
            ->find();
        if(!$info){
            $this->error = '记录不存在';
            return false;
        }
        if($info['status'] != 0){
            $this->error = '无权限操作';
            return false;
        }

        $lists = $this
            ->where('package_id',$id)
            ->where('del',0)
            ->select();
        $lists = $lists?$lists->toArray():[];
        if(count($lists) == 0){
            $this->error = '无可操作的医废记录';
            return false;
        }
        $ids = [];
        foreach ($lists as $k=>$v){
            $ids[] = $v['id'];
        }

        $this->startTrans();
        try{
            $rData = [
                'jj_time' => getTime(),
                'status' => 1,
                'jj_user_id' => $userId,
                'jj_record' => implode(',',$ids)
            ];
            $ret = Db::name('waste_package')
                ->where('id',$id)
                ->update($rData);
            if (!$ret) {
               exception('操作失败1');
            }

            foreach ($lists as $k=>$v){
                $rrData = [
                    'weight2' => 0,
                    'status' => 1,
                    'reason' => '',
                ];
                $ret = $this
                    ->where('id',$v['id'])
                    ->update($rrData);
                if (!$ret) {
                    exception('操作失败');
                }
                $sData = [
                    'status' => 1,
                    'create_time' => getTime(),
                    'user_id' => $userId,
                    'waste_record_id' => $v['id'],
                ];
                $res = Db::name('waste_record_user')
                    ->insert($sData);
                if (!$res) {
                   exception('操作失败');
                }
            }
            $this->commit();
            return true;
        }catch (Exception $e){
            $this->error = '操作失败'.$e->getmessage();
            $this->rollback();
            return false;
        }
    }
    // 转运
    public function zypackage($orgId,$userId,$id){
        $info = Db::name('waste_package')
            ->where('del',0)
            ->where('org_id',$orgId)
            ->where('id',$id)
            ->find();
        if(!$info){
            $this->error = '记录不存在';
            return false;
        }
        if($info['status'] != 1){
            $this->error = '无权限操作';
            return false;
        }
        $lists = $this
            ->where('package_id',$id)
            ->where('del',0)
            ->select();
        $lists = $lists?$lists->toArray():[];
        if(count($lists) == 0){
            $this->error = '无可操作的医废记录';
            return false;
        }
        $ids = [];
        foreach ($lists as $k=>$v){
            $ids[] = $v['id'];
        }

        $this->startTrans();
        try{
            $rData = [
                'zy_time' => date('Y-m-d H:i:s'),
                'status' => 2,
                'zy_user_id' => $userId,
                'zy_record' => implode(',',$ids)
            ];
            $ret = Db::name('waste_package')
                ->where('id',$id)
                ->update($rData);
            if (!$ret) {
                throw new exception('操作失败');
            }

            foreach ($lists as $k=>$v){
                $rrdata = [
                    'weight2' => 0,
                    'status' => 2,
                    'reason' => '',
                ];
                $ret = $this
                    ->where('id',$v['id'])
                    ->update($rrdata);
                if (!$ret) {
                    exception('操作失败');
                }
                $sdata = [
                    'status' => 2,
                    'create_time' => getTime(),
                    'user_id' => $userId,
                    'waste_record_id' => $v['id'],
                ];
                $res = Db::name('waste_record_user')
                    ->insert($sdata);
                if (!$res) {
                    exception('操作失败');
                }
            }
            $this->commit();
            return true;
        }catch (Exception $e){
            $this->error = '操作失败'.$e->getmessage();
            $this->rollback();
            return false;
        }
    }

    public function yflist($orgId,$userId){

        $map[] = ['wr.org_id','=',$orgId];
        $map[] = ['wr.user_id','=',$userId];
        $map[] = ['wr.package_id','=',0];
        $map[] = ['wr.del','=',0];
        $map[] = ['wr.status','=',0];
        $list=$this->alias('wr')
             ->where($map)
            ->field('wr.waste_device_id,wr.cateid,wr.create_time,wr.is_print,wr.serial_number,wr.id,wr.weight,wr.sign')
            ->order('wr.id desc')
            ->select();
        $list = $list?$list->toArray():[];
        foreach ($list as $k=>$v){
            $title=Db::name('address')
                ->field('title')
                ->where('id',$v['waste_device_id'])
                ->find();
            $list[$k]['title'] = $title?$title['title']:'';
            $list[$k]['cate_name'] =Db::name('waste_type')
                ->where('id',$v['cateid'])->value('title');
        }
        return $list?$list:[];
    }


}