shequ/application/api/controller/Jiashicang.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use app\common\library\RsaUtil;
use think\Db;

/**
 * 驾驶舱数据
 */
class Jiashicang extends Api
{
    // 无需登录的接口,*表示全部
    protected $noNeedLogin = ['*'];
    // 无需鉴权的接口,*表示全部
    protected $noNeedRight = ['*'];

    /**
     * 政法委
     * 链接数据库
     */
    public function test1()
    {
        $rs1 = Db::connect('database_jsc')->query('SHOW TABLE STATUS');
        dump($rs1);

        $rs2 = Db::connect('database_jsc')->query('SELECT DATABASE()');
        dump($rs2);
    }

    /**
     * 政法委
     * 链接表
     */
    public function test11()
    {
        $fields = Db::connect('database_jsc')->query('SHOW FULL COLUMNS FROM dp_wccn');
        dump($fields);
        $list = Db::connect('database_jsc')->name('dp_wccn')->limit(1,10)->select();
        dump($list);

        /*$fields = Db::connect('database_jsc')->query('SHOW FULL COLUMNS FROM sys_dept');
        dump($fields);
        $list = Db::connect('database_jsc')->name('sys_dept')->limit(1,10)->select();
        dump($list);*/
    }

    //政法委
    //查询关键数据
    public function zfw_data(){
        //定义变量
        $jzrs = 0; //居住人数
        $fwts = 0; //房屋套数
        $wgypzs = 0; //网格员配置数
        $zxyjdy = 0; //最小应急单元
        $wgsj = 0; //网格事件数
        $bjl = 0; //办结率

        //获取数据并过滤
        $shequ_list = Db::connect('database_jsc')->name('dp_wccn')->select();
        //dump($shequ_list);

        if(!empty($shequ_list)){

            //为空的都改为0
            foreach($shequ_list as $k => $v){
                foreach($v as $k1 => $v1){
                    if(empty($v1)){
                        $v1 = 0;
                    }
                    $v[$k1] = $v1;
                }
                $shequ_list[$k] = $v;
            }

            $jzrs = array_sum(array_column($shequ_list, 'jzrs'));
            $fwts = array_sum(array_column($shequ_list, 'fwts'));
            $wgypzs = array_sum(array_column($shequ_list, 'wgypzs'));
            $zxyjdy = array_sum(array_column($shequ_list, 'zxyjdy'));
            $wgsj = array_sum(array_column($shequ_list, 'wgsj'));
            $bjs = array_sum(array_column($shequ_list, 'bjs'));

            //$bjl = bcdiv(array_sum(array_column($shequ_list, 'bjl')),count($shequ_list),8); // 办结率总和 / 社区数量
            $bjl = bcdiv($bjs,$wgsj,8);// 总办结数 / 总网格事件数

        }

        //已经校验过的数据,最终推出
        dump((string)$jzrs);
        dump((string)$fwts);
        dump((string)$wgypzs);
        dump((string)$zxyjdy);
        dump((string)$wgsj);
        dump((string)$bjl);

        //分割线

    }

    //社区小程序 推送数据
    public function shequ_data(){
        $sqhds = Db::name('unishop_product')->whereNull('deletetime')->where('switch',1)->count();//社区活动数
        $hdbms = Db::name('unishop_order')->whereNull('deletetime')->where('have_paid','gt',0)->where('status',1)->count();//活动报名数

        $gonghang_data = Db::name('dp_gonghang')->where('id',1)->find();
        $jkdars  = $gonghang_data['jkdars'];//健康档案人数
        $whcss   = $gonghang_data['whcss'];//文化场所数
        $smxykcs = $gonghang_data['smxykcs'];//市民学院课程数
        $hdmyd   = $gonghang_data['hdmyd'];//活动满意度
        $ddgz_djd   = $gonghang_data['ddgz_djd'];//订单跟踪（待接单）
        $ddgz_fwz   = $gonghang_data['ddgz_fwz'];//订单跟踪（服务中）
        $ddgz_wcpj  = $gonghang_data['ddgz_wcpj'];//订单跟踪（完成评价）

        dump($jkdars);
        dump($whcss);
        dump($smxykcs);
        dump($hdmyd);
        dump($ddgz_djd);
        dump($ddgz_fwz);
        dump($ddgz_wcpj);

        dump((string)$sqhds);
        dump((string)$hdbms);
    }

    /**
     * 需要登录且需要验证有相应组的权限
     */
    public function test3()
    {
        $this->send_score(1, 1);
    }

    public function send_score($score, $grade_id)
    {
        $url = 'http://apip-gateway-nrouter-saas-gn-C.month.sdc.cs.icbc:8081/api/mybank/farm/farmplatf/updateVillagerIntegral/V1';

        $biz_content = [
            'fSeqNo' => createUniqueNo('fseq', $grade_id),
            'corpCode' => 'xingfulishequ',
            'mobilePhone' => $this->auth->mobile,
            'integralValue' => $score,
            'integralType' => '',
            /* 'remark1'      => '',
             'remark2'      => '',
             'remark3'      => '',
             'remark4'      => '',
             'remark5'      => '',
             'remark6'      => '',
             'remark7'      => '',*/
        ];

        $public_key = APP_PATH.'/common/certs/icbc/public_key.pem';
        $private_key = APP_PATH.'/common/certs/icbc/private_key.pem';
        $rsautil =  new RsaUtil($public_key,$private_key);

        $sign = $rsautil->publicEncrypt(json_encode($biz_content));
dump($sign);

        $data = [
            'app_id' => '10000000000004096993',
            'msg_id' => createUniqueNo('msg', $grade_id),
            'format' => 'json',
            'charset' => 'UTF-8',
//            'encrypt_type'=> 'AES',
            'sign_type' => 'RSA',
            'sign' => $sign,
            'timestamp' => date('Y-m-d H:i:s'),
//            'ca'          => '',
            'biz_content' => $biz_content,
        ];

        $rs = curl_post($url, json_encode($data, JSON_UNESCAPED_UNICODE));
        dump($rs);
    }


}