Sjzs_admin/application/api/controller/Index.php

<?php


namespace app\api\controller;

use app\admin\controller\Site;
use app\common\library\Common;
use app\common\controller\Api;
use app\common\library\WxPay;
use EasyWeChat\Factory;
use think\Db;
use think\facade\Validate;
use app\common\library\AliPay;
use function Qiniu\arraySort;
use app\common\model\SiteModel;
use app\common\model\KdModel;


/**
 * @title 首页
 * @controller Index
 */
class Index extends Api
{

    /**
     * @title 获取天气
     * @desc 获取天气
     * @url /api/Index/GetWeather
     * @method POST
     * @tag 基础
     */
    public function GetWeather(){
        $weather = Db::name('system_day')->where('date',date('Y-m-d'))->value('weather') ? : "晴转多云";
        $this->success('成功',['weather'=>$weather]);
    }


    /**
     * @title 当月截止昨日各乡镇总数量/中间大图数据
     * @desc 当月截止昨日各乡镇总数量/中间大图数据
     * @url /api/Index/townsData
     * @method POST
     * @tag 基础
     */
    public function townsData(){
        $start = date('Y-m-01'); //当月开始日期
        $end = date("Y-m-d",strtotime("-1 day"));  //昨天日期
        $list = Db::name('system_towns')
            ->where('is_del',1)
            ->field('id,name')
            ->select();
        $dm = '005,006,007,008,018,029,040,042,043,066,068,069,070,071,073,074,075,076,077,078,079,080,081,083,084,085,086,087,090,091,092,094,096,097,098,099,123,124,125,126,127';
        foreach ($list as &$v){
            if ($v['name']=='城关街道办'){
                $v['value'] = Db::name('system_values3')
                    ->whereBetween('date',[$start,$end])
                    ->whereIn('dm',$dm)
                    ->sum('value') ? : 0;
            }else{
                $site_ids = Db::name('system_site')->where('towns_id',$v['id'])->column('id');
                $v['value'] = Db::name('system_values')
                    ->whereIn('site_id',$site_ids)
                    ->where('name','总签收')
                    ->whereBetween('date',[$start,$end])
                    ->sum('value') ? : 0;
            }
        }
        $list = arraySort($list,'value',SORT_DESC);
        foreach ($list as &$v){
            if ($v['name']=='留古镇'){
                $v['value'] ='10';
            }
            if ($v['name']=='宫里镇'){
                $v['value'] = '5';
            }
            if ($v['name']=='流曲镇'){
                $v['value'] = '15';
            }
        }
        $this->success('成功',$list);
    }


    /**
     * @title 全县快递量
     * @desc 全县快递量
     * @url /api/Index/CountyExpress
     * @method POST
     * @tag 基础
     */
    public function CountyExpress(){
        $month = monthpast();
        $arr = array();
        $no_array = ['中通','申通','总签收'];
        foreach ($month as &$v){
            $array['date'] =$v;
            $value1 = Db::name('system_values')
                ->whereRaw("date_format(date,'%Y-%m')='".$v."'")
                ->whereNotIn('name',$no_array)
                ->sum('value') ? : 0;
            $value2 = Db::name('system_values2')
                ->whereRaw("date_format(date,'%Y-%m')='".$v."'")
                ->sum('value') ? : 0;
            $array['value'] = floatval(bcadd($value1,$value2));
            array_push($arr,$array);
        }
        $arr = arraySort($arr,'date',SORT_ASC);
        $this->success('成功',$arr);
    }

    /**
     * @title 全县快递量
     * @desc 全县快递量
     * @url /api/Index/CountyExpress
     * @method POST
     * @tag 基础
     */
    public function CountyExpress2(){
        $date = date('Y-m-d');
        $list = Db::name('system_values')->where('date','lt',$date)
            ->group('date')->limit(12)
            ->order('date asc')
            ->column('date');
        $arr = array();
        foreach ($list as &$v){
            $array['date'] =$v;
            $array['value']= Db::name('system_values')->where('date',$v)->where('name','总签收')->sum('value') ? : 0;
            array_push($arr,$array);
        }
        $this->success('成功',$arr);
    }


    /**
     * @title 截止昨日年度快递总量/昨日快递总量
     * @desc 截止昨日年度快递总量/昨日快递总量
     * @url /api/Index/YesterDayOrBeforeExpressTotal
     * @method POST
     * @tag 基础
     *
     * @param name:type type:int require:0 default:1 desc:1:截止昨日年度快递总量2:昨日快递总量
     */
    public function YesterDayOrBeforeExpressTotal(){
        $type = input('type',1);
        if ($type==1){
            $start = date('Y-01-01');   //当年开始日期
            $end = date("Y-m-d",strtotime("-1 day"));  //昨天日期
        }else{
            $start = date("Y-m-d",strtotime("-1 day"));  //昨天日期
            $end = date("Y-m-d",strtotime("-1 day"));  //昨天日期
        }
        $kd = Db::name('system_kd')->field('id,name')->select();
        foreach ($kd as &$v){
            if (in_array($v['name'],['中通','申通'])){
                $v['value'] = Db::name('system_values2')
                    ->whereBetween('date',[$start,$end])
                    ->where('name',$v['name'])
                    ->sum('value') ? : 0;
            }else{
                $value =  Db::name('system_values')
                    ->whereBetween('date',[$start,$end])
                    ->where('name',$v['name'])
                    ->sum('value') ? : 0;
                $value2 = Db::name('system_values2')
                    ->whereBetween('date',[$start,$end])
                    ->where('name',$v['name'])
                    ->sum('value') ? : 0;
                $v['value'] = floatval(bcadd($value,$value2));
            }
        }
        $total = array_sum(array_column($kd,'value'));
        $list = arraySort($kd,'value',SORT_DESC);
        $this->success('成功',['total'=>$total,'list'=>$list]);
    }

    /**
     * @title 今日数据
     * @desc 今日数据
     * @url /api/Index/ThisDayData
     * @method POST
     * @tag 基础
     */
    public function ThisDayData(){
        $total = Db::name('system_day_fake')
            ->where('date',date('Y-m-d'))
            ->sum('value') ? : 0;
        $list = Db::name('system_day_fake')
            ->where('date',date('Y-m-d'))
            ->field('name,value')
            ->order('value desc')
            ->select();
        $this->success('成功',compact('total','list'));
    }


    /**
     * @title 查询页面数据
     * @desc 查询页面数据
     * @url /api/Index/SellDate2
     * @method POST
     * @tag 基础
     *
     * @param name:name type:string require:0 default: desc:站点名称
     * @param name:town_name type:string require:0 default: desc:乡镇名称
     * @param name:date type:string require:0 default: desc:日期
     * @param name:page type:int require:0 default:1 desc:
     * @param name:limit type:int require:0 default:10 desc:
     */
    public function SellDate2(){
        $name = input('name');  //站点名称
        $town_name = input('town_name'); //乡镇名称
        $date = input('date');   //日期
        $Nowpage = input('page',1);
        $limits = input("limit",10);
        $count = Db::name('system_site')->alias('a')
            ->leftJoin('system_towns b','a.towns_id=b.id')
            ->field('a.id,a.code,a.name,b.name as towns_name')
            ->where('a.is_del',1)
            ->when($name,function($query) use ($name){
                $query->whereLike('a.name','%'.$name.'%');
            })
            ->when($town_name,function($query) use ($town_name){
                $query->whereLike('b.name','%'.$town_name.'%');
            })
            ->count();
        $list = Db::name('system_site')->alias('a')
            ->leftJoin('system_towns b','a.towns_id=b.id')
            ->field('a.id,a.code,a.name,b.name as towns_name')
            ->where('a.is_del',1)
            ->when($name,function($query) use ($name){
                $query->whereLike('a.name','%'.$name.'%');
            })
            ->when($town_name,function($query) use ($town_name){
                $query->whereLike('b.name','%'.$town_name.'%');
            })
            ->order('a.id asc')
            ->page($Nowpage,$limits)
            ->select();
        $kd = Db::name('system_kd')->field('name')->select();
        $kd = array_merge([['name' => '总签收']],$kd);
        foreach ($list as &$v){
            foreach ($kd as &$a){
                $v[$a['name']] = Db::name('system_values')
                    ->where('site_id',$v['id'])
                    ->when($date,function($query) use ($date){
                        $query->where('date',$date);
                    })
                    ->where('name',$a['name'])
                    ->sum('value') ? : 0;
            }
        }
        $this->success('成功',['count'=>$count,'list'=>$list,'kd'=>$kd]);
    }


    /**
     * @title 查询页面数据
     * @desc 查询页面数据
     * @url /api/Index/SellDate
     * @method POST
     * @tag 基础
     *
     * @param name:name type:string require:0 default: desc:站点名称
     * @param name:town_name type:string require:0 default: desc:乡镇名称
     * @param name:date type:string require:0 default: desc:日期
     * @param name:page type:int require:0 default:1 desc:
     * @param name:limit type:int require:0 default:10 desc:
     */
    public function SellDate(){
        $name = input('name');  //站点名称
        $town_name = input('town_name'); //乡镇名称
        $date = input('date');   //日期
        $Nowpage = input('page',1);
        $limits = input("limit",10);
        $count =  SiteModel::alias('a')
            ->leftJoin('system_towns b','a.towns_id=b.id')
            ->when($name,function($query) use ($name){
                $query->whereLike('a.name','%'.$name.'%');
            })
            ->when($town_name,function($query) use ($town_name){
                $query->whereLike('b.name','%'.$town_name.'%');
            })
            ->where('a.is_del',1)
            ->where('b.is_del',1)
            ->count();
        $list = SiteModel::alias('a')
            ->leftJoin('system_towns b','a.towns_id=b.id')
            ->when($name,function($query) use ($name){
                $query->whereLike('a.name','%'.$name.'%');
            })
            ->when($town_name,function($query) use ($town_name){
                $query->whereLike('b.name','%'.$town_name.'%');
            })
            ->field('a.id,a.code,a.name,b.name as towns_name')
            ->with(['kd'=>function($query) use ($date){
                $query->when($date,function ($q) use ($date){
                    $q->where('date',$date);
                })
                    ->group('site_id,name')
                    ->order('id asc')
                    ->field('id,site_id,name,sum(value) as value');
            }])
            ->where('a.is_del',1)
            ->where('b.is_del',1)
            ->order('a.id asc')
            ->page($Nowpage,$limits)
            ->select();
        $kd = Db::name('system_kd')->field('name')->select();
        $kd = array_merge([['name' => '总签收']],$kd);
        foreach ($list as &$v) {
            $kdarray = array();
            foreach ($v['kd'] as &$a){
                $kdarray[$a['name']] = $a['value'];
            }
            foreach ($kd as $key=>$b){
                if (empty($kdarray)){
                    $v[$b['name']] = 0;
                }else{
                    $v[$b['name']] = isset($kdarray[$b['name']]) ? (int)$kdarray[$b['name']] : 0;
                }
            }
            unset($v['kd']);
        }
        $this->success('成功',['count'=>$count,'list'=>$list,'kd'=>$kd]);
    }

}