shequ/application/api/controller/Demo.php

<?php

namespace app\api\controller;

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

/**
 * 示例接口
 */
class Demo extends Api
{

    //如果$noNeedLogin为空表示所有接口都需要登录才能请求
    //如果$noNeedRight为空表示所有接口都需要验证权限才能请求
    //如果接口已经设置无需登录,那也就无需鉴权了
    //
    // 无需登录的接口,*表示全部
    protected $noNeedLogin = ['*'];
    // 无需鉴权的接口,*表示全部
    protected $noNeedRight = ['*'];

    /**
     * 测试方法
     *
     * @ApiTitle    (测试名称)
     * @ApiSummary  (测试描述信息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/demo/test/id/{id}/name/{name})
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="id", type="integer", required=true, description="会员ID")
     * @ApiParams   (name="name", type="string", required=true, description="用户名")
     * @ApiParams   (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturnParams   (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据返回")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function test()
    {
        $a = '我要反馈一';
        $b = mb_substr($a,0,12) . ((mb_strlen($a) > 12) ? '...' : '');
        echo $b;
    }

    /**
     * 无需登录的接口
     *
     */
    public function test1()
    {
        error_reporting(E_ALL);
        /*$rs0 = Db::query('SHOW TABLE STATUS');
        dump($rs0);*/

        $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);

//        $this->success('返回成功', ['action' => 'test1']);
    }

    public function test111(){
        //定义变量
        $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'));
            $bjl = bcdiv(array_sum(array_column($shequ_list, 'bjl')),8,8);

        }

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

        //分割线

        $jkdars = 0;//健康档案人数
        $whcss = 0;//文化场所数
        $smxykcs = 0;//市民学院课程数
        $sqhds = 0;//社区活动数
        $hdbms = 0;//活动报名数
        $hdmyd = 0;//活动满意度


    }

    /**
     * 需要登录的接口
     *
     */
    public function test2()
    {
        $data = [
            'key1' => 'value1',
            'key2' => 'value2',
            'key3' => 'value3',
            'key4' => 'value4',
            'key5' => 'value5',
        ];
        $this->success('返回成功', $data);
    }

    public function send_minimsg(){
        $config = config('wxMiniProgram');
        $wechat = new Wechat($config['appid'],$config['secret']);

        //活动开始
        $template_id = $config['mini_msgid_order'];
        $data = [
            'thing4' => ['value' => '活动名称'],
            'thing6' => ['value' => '活动地址'],
            'date5'  => ['value' => '2025-06-27 14:00'],
            'thing7' => ['value' => '明天开始，不要迟到哦'],
        ];

        $rs = $wechat->send($template_id,'odWcF7sjejGL7d-0DuCmbmbcH1yA',$data);
        dump($rs);

        //意见反馈
        $template_id = $config['mini_msgid_feedback'];
        $data = [
            'thing4' => ['value' => '动画视频功能'],
            'thing5' => ['value' => '无法上传'],
            'thing6' => ['value' => '已经处理完毕了'],
        ];

        $rs = $wechat->send($template_id,'odWcF7sjejGL7d-0DuCmbmbcH1yA',$data);
        dump($rs);


    }



    /**
     * 需要登录且需要验证有相应组的权限
     *
     */
    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);
    }


}