jili2/application/api/controller/screen/Waste.php

<?php
namespace app\api\controller\screen;

use app\hander\HelpHander;
use app\api\controller\screen\Index;

use think\Db;

class Waste extends Index
{
    public function cateList(){
        $type = input('type',1);
        if($type == 1){
            $map[] = ['create_yyyy','=',date('Y')];
        }else{
            $map[] = ['create_yyyymm','=',date('Ym')];
        }
        $list = Db::name('waste_type')
            ->field('id,title')
            //->where('org_id',$this->orgId)
            ->where('del',0)
            ->where('enable',1)
            ->limit(5)
            ->select();
        foreach ($list as $k=>$v){
            $record = Db::name('waste_record')
                ->where('cateid',$v['id'])
                ->where('org_id',$this->orgId)
                ->where($map)
                ->where('del',0)
                ->sum('weight');
            $list[$k]['kg'] = round($record/1000,1);
        }
        HelpHander::success($list);
    }

    public function deviceList(){
        $device = Db::name('dep')
            ->alias('d')
            ->field('d.title,a.id')
            ->join('address a','a.dep_id=d.id')
            ->where('d.org_id',$this->orgId)
            ->where('d.del',0)
            ->where('d.enable',1)
            ->where('','exp',Db::raw("FIND_IN_SET(7,a.types)"))
            ->where('a.del',0)
            ->where('a.enable',1)
            ->group('d.title')
            ->select();

        $cate = Db::name('waste_type')
            ->field('id,title')
//            ->where('org_id',$this->orgId)
            ->where('del',0)
            ->where('enable',1)
            ->limit(5)
            ->select();

        foreach ($device as $k=>$v){
            $device[$k]['kg'] = Db::name('waste_record')
                ->where('org_id',$this->orgId)
                ->where('waste_device_id',$v['id'])
                ->where('del',0)
                ->where('create_yyyymmdd',date('Ymd'))
                ->sum('weight');
        }
        $newList = array_slice(list_sort_by($device,'kg','desc'),0,5);
        $lists = $cateTitle = [];
        foreach ($cate as $k=>$v){
            $cateTitle[] = $v['title'];
            $aa = [];
            $lists[$k]['title'] = $v['title'];
            foreach ($newList as $kk=>$vv){
                $record = Db::name('waste_record')
                    ->where('org_id',$this->orgId)
                    ->where('waste_device_id',$vv['id'])
                    ->where('cateid',$v['id'])
                    ->where('del',0)
                    ->where('create_yyyymmdd',date('Ymd'))
                    ->sum('weight');
                $aa[] = !empty($record)? round($record/1000,1):0;
            }
            $lists[$k]['list'] = $aa;
        }
        $title = array_column($newList,'title');
//        $cc = [];
//        foreach ($cateTitle as $k=>$v){
//            $cc[$k]['title'] = $v;
//            foreach ($lists as $kk=>$vv){
//                $cc[$k]['list'] = $vv;
//            }
//        }

        $data = [
            'title'=>$title,
            'title1'=>$cateTitle,
            'list'=>$lists,
        ];
        HelpHander::success($data);
    }

    public function userWorkWaste(){
        $record = Db::name('waste_record')
            ->where('org_id',$this->orgId)
            ->where('del',0)
            ->where('weight','>',0)
            ->where('create_yyyymmdd',date('Ymd'))
            ->group('user_id')
            ->column('user_id');

        $lists = [];
        foreach ($record as $k=>$v){
           $list1 =  Db::name('waste_record')
               ->where('org_id',$this->orgId)
               ->where('user_id',$v)
               ->where('del',0)
               ->where('create_yyyymmdd',date('Ymd'))
               ->sum('weight');

            $lists[$k]['title'] = Db::name('user')->where('id',$v)->value('real_name');
            $lists[$k]['kg'] = round($list1/1000,1);
        }
        $endData = array_slice(list_sort_by($lists,'kg','desc'),0,5);
        $data = [
            'title'=>array_column($endData,'title'),
            'lists'=>array_column($endData,'kg'),
        ];

        HelpHander::success($data);
    }

    public function wasteRecord(){
        $list = Db::name('waste_record')
            ->where('del',0)
            ->where('org_id',$this->orgId)
            ->where('create_yyyymmdd',date('Ymd'))
            ->limit(20)
            ->select();
        foreach ($list as $k=>$v){
            $list[$k]['user_name'] = Db::name('user')
                ->where('id',$v['user_id'])
                ->value('real_name');
            $list[$k]['device_name'] = Db::name('address')
                ->where('id',$v['waste_device_id'])
                ->value('title');
            $list[$k]['cate_name'] = Db::name('waste_type')
                ->where('id',$v['cateid'])
                ->value('title');
            $list[$k]['kg'] = $v['weight'] ? round($v['weight']/1000,2):0;
            if($v['status'] == 0){
                $list[$k]['status'] = '已收取';
            }elseif ($v['status'] == 1){
                $list[$k]['status'] = '已交接';
            }elseif ($v['status'] == 2){
                $list[$k]['status'] = '已转运';
            }else{
                $list[$k]['status'] = '医废异常';
            }
            $list[$k]['create_time'] = date('m-d H:i',strtotime($v['create_time']));
        }
        $data = [];
        foreach ($list as $k=>$v){
            $data[$k][] = $v['device_name'];
            $data[$k][] = $v['user_name'];
            $data[$k][] = $v['create_time'];
            $data[$k][] = $v['cate_name'];
            $data[$k][] = $v['kg'];
            $data[$k][] = $v['status'];
        }
        HelpHander::success($data);
    }

    public function monthCateRecord(){
        $month = input('month','');
        if($month !=''){
            if($month > 0 && $month < 10){
                $date = date('Y').'0'.$month;
            }elseif ($month >=10){
                $date = date('Y').$month;
            }
        }else{
            $date =  date('Ym');
        }

//        $em =  cal_days_in_month(CAL_GREGORIAN,$month,date('Y'));

        $em = date('t',strtotime($date));

        $sDay = strtotime($date.'01');

        $arr = [];
        for ($i = 0;$i<$em;$i++){
            $arr[$i]['date'] = date('m-d',$sDay+$i*86400);
            $arr[$i]['ymd'] = date('Ymd',$sDay+$i*86400);
        }

        $cate = Db::name('waste_type')
            ->field('id,title')
            ->where('org_id','in',[0,$this->orgId])
            ->where('del',0)
            ->where('enable',1)
            ->select();

        $lists = $cateTitle = [];
        foreach ($cate as $k=>$v){
            $cateTitle[] = $v['title'];
            $lists[$k]['title'] = $v['title'];
            $aa = [];
            foreach ($arr as $kk=>$vv){
                $record = Db::name('waste_record')
                    ->where('org_id',$this->orgId)
                    ->where('cateid',$v['id'])
                    ->where('del',0)
                    ->where('create_yyyymmdd',$vv['ymd'])
                    ->sum('weight');
                $aa[$kk] = $record>0? round($record/1000,1):0;
            }
            $lists[$k]['list'] = $aa;
        }
//        $cc = [];
//        foreach ($cateTitle as $k=>$v){
//            $cc[$k]['title'] = $v;
//            foreach ($lists as $kk=>$vv){
//                $cc[$k]['list'] = $vv['weight'];
//            }
//        }

        $data = [
            'date' =>array_column($arr,'date'),
            'cate' =>$cateTitle,
            'list'=>$lists
        ];
        HelpHander::success($data);
    }

    public function weekCateRecord(){
        $date = date('Y-m-d'); // 获取当前日期
        $startOfWeek = strtotime('last Monday', strtotime($date));
        $endOfWeek = strtotime('next Sunday', $startOfWeek);

        $arr = [];
        for ($i = 0; $i < 7; $i++) {
            $currentDay = strtotime("+$i day", $startOfWeek);
            $arr[$i]['date'] = date('m-d', $currentDay);
            $arr[$i]['ymd'] = date('Ymd', $currentDay);
        }

        $cate = Db::name('waste_type')
            ->field('id,title')
            ->where('org_id','in',[0,$this->orgId])
            ->where('del',0)
            ->where('enable',1)
            ->select();

        $lists = $cateTitle = [];
        foreach ($cate as $k=>$v){
            $cateTitle[] = $v['title'];
            $lists[$k]['title'] = $v['title'];
            $aa = [];
            $record = Db::name('waste_record')
                ->where('org_id',$this->orgId)
                ->where('cateid',$v['id'])
                ->where('del',0)
                ->where('create_yyyymmdd', '>=', date('Ymd', $startOfWeek))
                ->where('create_yyyymmdd', '<=', date('Ymd', $endOfWeek))
                ->sum('weight');
            $aa = $record>0? round($record/1000,1):0;
            $lists[$k]['list'] = $aa;
        }

        $data = [
            'date' =>array_column($arr,'date'),
            'title' =>array_column($lists,'title'),
            'cate' =>$cateTitle,
            'list'=>array_column($lists,'list')
        ];

        HelpHander::success($data);
    }
    // 医废收取量统计 当天及30天内平均收取重量
    public function depRecord(){
        //先取30内的科室
        $curDay = date('Ymd');
        $start = date('Ymd',strtotime(date('Y-m-d')) - 29*24*60*60);
        $lists = Db::name('waste_record')
            ->alias('wr')
            ->join('address a','a.id = wr.waste_device_id')
            ->join('dep d','d.id = a.dep_id')
            ->where('wr.org_id',$this->orgId)
            ->where('wr.del',0)
            ->where('wr.create_yyyymmdd','<=',$curDay)
            ->where('wr.create_yyyymmdd','>=',$start)
            ->field('d.id,d.title')
            ->group('d.id')
            ->distinct(true)
            ->select();
        $titles = [];
        $y1 = [];
        $y2 = [];
        foreach ($lists as $k=>$v){
            $titles[] = $v['title'];
            $count1 = Db::name('waste_record')
                ->where('org_id',$this->orgId)
                ->where('del',0)
                ->where('create_yyyymmdd','=',$curDay)
                ->sum('weight');
            $y1[] = round($count1/1000,1);

            $count2 = Db::name('waste_record')
                ->where('org_id',$this->orgId)
                ->where('del',0)
                ->where('create_yyyymmdd','<=',$curDay)
                ->where('create_yyyymmdd','>=',$start)
                ->sum('weight');
            $y2[] = round(($count2/1000)/30,1);
        }
        HelpHander::success(['titles' => $titles,'y1' => $y1,'y2' => $y2]);
    }

    public function depRecordList(){

        $dep = Db::name('dep')
            ->alias('d')
            ->field('d.title,a.id')
            ->join('address a','a.dep_id=d.id')
            ->where('d.org_id',$this->orgId)
            ->where('d.del',0)
            ->where('d.enable',1)
            ->where('','exp',Db::raw("FIND_IN_SET(7,a.types)"))
            ->where('a.del',0)
            ->where('a.enable',1)
            ->group('d.title')
            ->limit(5)
            ->select();

        $x = $y1 = $y2 = [];
        foreach ($dep as $k=>$v){
            $x[] = $v['title'];
            $record =  Db::name('waste_record')
                ->where('waste_device_id',$v['id'])
                ->where('create_yyyymmdd',date('Ymd'))
                ->where('del',0)
                ->sum('weight');
            $y1[] = round($record/1000,1);

            $record2 =  Db::name('waste_record')
                ->where('waste_device_id',$v['id'])
                ->where('create_yyyymmdd','>',date("Ymd",mktime(0,0,0,date("m")-1,date("d"),date("Y"))))
                ->where('create_yyyymmdd','<=',date('Ymd'))
                ->where('del',0)
                ->sum('weight');

            $y2[] = round($record2/1000/30,1);
        }

        HelpHander::success(['x'=>$x,'y1'=>$y1,'y2'=>$y2]);
    }

}