kly_api/prjcenter/prjKLY/base/AboutWorker.php

<?php
defined('ONLY_ONLY_ONLY') or exit('Access Denied');
/*****************劳方以自身劳动获取收益的人相关******************/

function bizWorker_verifyToken()
{
    $subSystem = intval(SUBSYS_LABOUR_MINA);

    $GPC = input_param_handle(false);
    $ajaxdata = input_getPostObj();
    $phone = isset($ajaxdata["phone"]) ? $ajaxdata["phone"] : $GPC["phone"];

    //这里是测试
    // $phone="18602638946";
    // $subSystem=1;

    if (empty($phone)) {
        throw new GeneralException("", "没有传递必要的phone参数");
    }

    $baseUser = pdo_fetch("select * from base_user where subsystem=:subsystem and `mobile`=:mobile limit 1;", array(
        ":subsystem" => intval($subSystem),
        ":mobile" => trim($phone),
    ));

    if (empty($baseUser)) {
        throw new GeneralException("", "没有定位到此phone的登录用户记录！");
    }

    $bizWorker = pdo_fetch("select wk.*,bu.id as buid,bu.mobile,bu.subsystem
        from biz_worker wk
        left join base_user bu on bu.id=wk.base_userid
        where wk.base_userid=:base_userid limit 1;", array(":base_userid" => $baseUser["id"]));
    if (empty($bizWorker)) {
        throw new GeneralException("", "没有定位到此phone的业务用户记录！");
    }

    base_verifyForendToken($baseUser); //前端会话TOKEN校验
    return array("baseUser" => $baseUser, "bizWorker" => $bizWorker);
}

function bizbase_workerIdCardCheck($ajaxdata, $GPC)
{
    $trueName = isset($ajaxdata["trueName"]) ? $ajaxdata["trueName"] : $GPC["trueName"];
    $idCard = isset($ajaxdata["idCard"]) ? $ajaxdata["idCard"] : $GPC["idCard"];
    if (empty($bizTrader)) {
        throw new GeneralException("", "没有以商家身份登录，请核查！");
    }

    require_once WEB_PHY_ROOT . "/base/wxsrv.php";
    txcloud_idcardCheck($trueName, $idCard);
    $sqlParam = array();
    $sqlParam[":nowtime"] = time();
    $sqlParam[":traderId"] = intval($bizTrader["id"]);
    $sqlParam[":lawer_name"] = $trueName;
    $sqlParam[":lawer_idcard"] = $idCard;
    $sqlParam[":linker_gender"] = ((intval(mb_substr($idCard, 17, 1)) % 2) <= 0 ? 1 : 0);
    $sqlParam[":linker_birthday"] = strtotime(mb_substr($idCard, 6, 4) . "-" . mb_substr($idCard, 10, 2) . "-" . mb_substr($idCard, 12, 2));
    $sqlParam[":remark"] = "[" . date("Y-m-d H:i:s", time()) . "] 实名认证 \n";
    $sqlTemp = "";
    $sqlTemp .= " update biz_trader set updatetime=:nowtime ";
    $sqlTemp .= " ,lawer_name=:lawer_name,lawer_idcard=:lawer_idcard ";
    $sqlTemp .= " ,linker_gender=:linker_gender,linker_birthday=:linker_birthday ";
    $sqlTemp .= " ,remark=concat(:remark,ifnull(remark,'')) ";
    $sqlTemp .= " where id =:traderId;";
    $backdata = pdo_query3($sqlTemp, $sqlParam);
    return $backdata;
}
function bizbase_workerAccountInfo($bizWorker)
{
    $sqlTemp = "";
    $sqlTemp .= " select type,sum(ifnull(money,0)) as total ";
    $sqlTemp .= " from biz_worker_account ";
    $sqlTemp .= " where deleted=0 and `status`=1 and biz_workerid=" . intval($bizWorker["id"]);
    $sqlTemp .= " group by type";
    $totalList = pdo_fetchall($sqlTemp, array());
    $income = 0.0;
    $outgoing = 0.0;
    foreach ($totalList as $item) {
        switch (intval($item["type"])) {
            case 0: //收入
                $income = round(floatval($item["total"]), 2);
                break;
            case 1: //支出
                $outgoing = round(floatval($item["total"]), 2);
                break;
        }
    }
    $frozenIn = 0.0; //解冻总额
    $frozenOut = 0.0; //冻结总额
    $frozenBalance = 0.0; //冻结余额，即当前实际冻结的金额
    //支出统计
    $sqlTemp = "";
    $sqlTemp .= " select biz_catalog,sum(ifnull(money,0)) as total ";
    $sqlTemp .= " from biz_worker_account ";
    $sqlTemp .= " where deleted=0 and `status`=1 and biz_workerid=" . intval($bizWorker["id"]) . " and type=1 ";
    $sqlTemp .= " group by biz_catalog ";
    $outlist = pdo_fetchall($sqlTemp, array());
    $withdrawout = 0.0;
    $activityout = 0.0;
    foreach ($outlist as $item) {
        switch (intval($item["biz_catalog"])) {
            case 0: //提现支出
                $withdrawout = round(floatval($item["total"]), 2);
                break;
            //case 1: //押金付给商户
            case 10: //活动支出
                $activityout = round(floatval($item["total"]), 2);
                break;
            case 2: //冻结总额
                $frozenOut = round(floatval($item["total"]), 2);
                break;
        }
    }
    $sqlTemp = "";
    $sqlTemp .= " select biz_catalog,sum(ifnull(money,0)) as total ";
    $sqlTemp .= " from biz_worker_account ";
    $sqlTemp .= " where deleted=0 and `status`=1 and biz_workerid=" . intval($bizWorker["id"]) . " and type=0 ";
    $sqlTemp .= " group by biz_catalog ";
    $inlist = pdo_fetchall($sqlTemp, array());
    $salaryin = 0.0;
    $commissionin = 0.0;
    $activityin = 0.0;
    $wxchargein = 0.0;
    foreach ($inlist as $item) {
        switch (intval($item["biz_catalog"])) {
            case 0: //工资收入
                $salaryin = round(floatval($item["total"]), 2);
                break;
            case 1: //佣金收入
                $commissionin = round(floatval($item["total"]), 2);
                break;
            case 2: //营销活动支付
                $activityin = round(floatval($item["total"]), 2);
                break;
            case 3: //微信充值
                $wxchargein = round(floatval($item["total"]), 2);
                break;
            case 5: //解冻报名押金 超时自动解冻
                $frozenIn = bcadd($frozenIn, round(floatval($item["total"]), 2), 2);
                break;
            case 7: //解冻报名押金
                $frozenIn = bcadd($frozenIn, round(floatval($item["total"]), 2), 2);
                //$frozenIn = round(floatval($item["total"]), 2);
                break;
                /*case 7: //解冻报名押金
        $frozenIn = round(floatval($item["total"]), 2);
        break;*/
        }
    }
    $frozenBalance = round($frozenOut - $frozenIn, 2); //冻结余额，即当前实际冻结的金额
    //$frozenSql = "select ifnull(sum(ifnull(money,0)),0) as sum from biz_worker_account where biz_id in (select id from biz_todowork as btw where btw.biz_workerid=:workerid and btw.`status` in (1,2,4) ) and biz_catalog=2";
    //$frozenBalance = pdo_fetch($frozenSql, [':workerid' => intval($bizWorker["id"])]);
    //$frozenBalance = round(floatval($frozenBalance['sum']), 2);
    $balance = round($income - $outgoing, 2);
    return array(
        "balance" => $balance,
        "income" => $income,
        "outgoing" => $outgoing,
        "salaryin" => $salaryin,
        "commissionin" => $commissionin,
        "activityin" => $activityin,
        "wxchargein" => $wxchargein,
        "withdrawout" => $withdrawout,
        "activityout" => $activityout,
        "frozenBalance" => $frozenBalance,
//        "frozenBalance"=> $frozenIn,
    );

}
function bizbase_workerStatistics($bizWorker)
{
    $sqlTemp = "";
    $sqlTemp .= " select sum(workTotal) as workTotal ";
    $sqlTemp .= "   ,sum(waitEnrollTotal) as waitEnrollTotal,sum(enrollTotal) as enrollTotal ";
    $sqlTemp .= "   ,sum(workingTotal) as workingTotal,sum(waitSettleTotal) as waitSettleTotal ";
    $sqlTemp .= "   ,sum(finishedTotal) as finishedTotal,sum(exceptTotal) as exceptTotal ";
    $sqlTemp .= "   ,sum(refuseTotal) as refuseTotal,sum(breakoffTotal) as breakoffTotal ";
    $sqlTemp .= "   ,sum(cancelTotal) as cancelTotal,sum(cancel2Total) as cancel2Total,sum(denypayTotal) as denypayTotal ";
    $sqlTemp .= "   ,sum(noStartWorkTotal) as noStartWorkTotal,sum(noFinishWorkTotal) as noFinishWorkTotal ";
    $unreadStatusMin = -8;
    $unreadStatusMax = 5;
    $unreadStatusPrefix = "unreadWKTotal";
    for ($iii = $unreadStatusMin; $iii <= $unreadStatusMax; $iii++) {
        $iiiExt = $iii < 0 ? "_" . abs($iii) : $iii;
        $alias = "{$unreadStatusPrefix}{$iiiExt}";
        $sqlTemp .= "   ,sum({$alias}) as {$alias} ";
    }
    $sqlTemp .= " from ( select sum(case when tdwk.id>0 then 1 else 0 end) as workTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`=1 then 1 else 0 end) as waitEnrollTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`>=2 then 1 else 0 end) as enrollTotal ";
    $sqlTemp .= "       ,sum(case when (tdwk.`status`=2 or tdwk.`status`=3) then 1 else 0 end) as workingTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`=4 then 1 else 0 end) as waitSettleTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`>=5 then 1 else 0 end) as finishedTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`<0 then 1 else 0 end) as exceptTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`=-1 then 1 else 0 end) as refuseTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`=-3 then 1 else 0 end) as breakoffTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`=-2 then 1 else 0 end) as cancelTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`=-4 then 1 else 0 end) as cancel2Total ";
    $sqlTemp .= "       ,sum(case when (tdwk.`status`=-5 or tdwk.`status`=-8) then 1 else 0 end) as denypayTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`=-6 then 1 else 0 end) as noStartWorkTotal ";
    $sqlTemp .= "       ,sum(case when tdwk.`status`=-7 then 1 else 0 end) as noFinishWorkTotal ";
    for ($iii = $unreadStatusMin; $iii <= $unreadStatusMax; $iii++) {
        $iiiExt = $iii < 0 ? "_" . abs($iii) : $iii;
        $alias = "{$unreadStatusPrefix}{$iiiExt}";
        $sqlTemp .= "  ,sum(case when (tdwk.`status`={$iii} and !FIND_IN_SET(tdwk.`status`, tdwk.worker_readed)) then 1 else 0 end) as {$alias} ";
    }
    $sqlTemp .= "      from biz_todowork tdwk ";
    $sqlTemp .= "      left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
    $sqlTemp .= "      where tdwk.biz_workerid=" . intval($bizWorker["id"]);
    $sqlTemp .= "      group by tdwk.biz_recruitid";
    $sqlTemp .= " ) as temp ";
    $totalInfo = pdo_fetch($sqlTemp, array());
    $backdata = array(
        "workTotal" => intval($totalInfo["workTotal"]),
        "work_erolledtotal" => intval($totalInfo["waitEnrollTotal"]) + intval($totalInfo["enrollTotal"]),
        "waitEnrollTotal" => intval($totalInfo["waitEnrollTotal"]),
        "enrollTotal" => intval($totalInfo["enrollTotal"]),
        "workingTotal" => intval($totalInfo["workingTotal"]),
        "waitSettleTotal" => intval($totalInfo["waitSettleTotal"]),
        "finishedTotal" => intval($totalInfo["finishedTotal"]),
        "exceptTotal" => intval($totalInfo["exceptTotal"]),
        "refuseTotal" => intval($totalInfo["refuseTotal"]),
        "breakoffTotal" => intval($totalInfo["breakoffTotal"]),
        "cancelTotal" => intval($totalInfo["cancelTotal"]),
        "cancel2Total" => intval($totalInfo["cancel2Total"]),
        "denypayTotal" => intval($totalInfo["denypayTotal"]),
        "noStartWorkTotal" => intval($totalInfo["noStartWorkTotal"]),
        "noFinishWorkTotal" => intval($totalInfo["noFinishWorkTotal"]),
        "othersTotal" => intval($totalInfo["noStartWorkTotal"]) + intval($totalInfo["noFinishWorkTotal"]),
        "exceptTotal2" => intval($totalInfo["refuseTotal"]) + intval($totalInfo["breakoffTotal"])
         + intval($totalInfo["cancelTotal"]) + intval($totalInfo["cancel2Total"]) + intval($totalInfo["denypayTotal"]),
    );
    $aliasALL = "{$unreadStatusPrefix}_ALL";
    $backdata[$aliasALL] = 0;
    $aliasOther = "{$unreadStatusPrefix}_Other";
    $backdata[$aliasOther] = 0;
    for ($iii = $unreadStatusMin; $iii < $unreadStatusMax; $iii++) {
        $iiiExt = $iii < 0 ? "_" . abs($iii) : $iii;
        $alias = "{$unreadStatusPrefix}{$iiiExt}";
        $backdata[$alias] = intval($totalInfo[$alias]);
        if ($iii < 0) {
            $backdata[$aliasALL] += intval($totalInfo[$alias]);
        }

        if ($iii == -6) {
            $backdata[$aliasOther] += intval($totalInfo[$alias]);
        }

        if ($iii == -7) {
            $backdata[$aliasOther] += intval($totalInfo[$alias]);
        }

    }
    $backdata["{$unreadStatusPrefix}_5"] = intval($backdata["{$unreadStatusPrefix}_5"]) + intval($backdata["{$unreadStatusPrefix}_8"]);
    return $backdata;
}
function bizbase_workerUndoList($bizWorker)
{
    $backdata = array();
    $backdata["notice_unreaded"] = intval(pdo_fetchcolumn("select count(*) from biz_pubic_notice bpn
        left join biz_basetrace bbt on bbt.deleted=0 and bbt.biz_catalog=1 and bbt.biz_id=bpn.id and bbt.biz_usertype=2 and bbt.biz_userid=" . intval($bizWorker["id"]) . "
        where bpn.deleted=0 and bpn.catalog=1
          and ifnull(bbt.id,0)<=0;"));
    return $backdata;
}
function bizbase_workerEntityHandle($fromSubSystem, $baseUser, $bizUser, $handleMode, $ajaxdata, $GPC)
{
    if (intval($baseUser["subsystem"]) == SUBSYS_LABOUR_MINA) {
        $bizWorker = $bizUser;
    }

    if (intval($baseUser["subsystem"]) == SUBSYS_CAPITAL_MINA) {
        $bizTrader = $bizUser;
    }

    if (intval($baseUser["subsystem"]) == SUBSYS_CAPITAL2_MINA) {
        $bizTrader2 = $bizUser;
    }

    switch ($handleMode) {
        case "idCardCheck":
            $trueName = isset($ajaxdata["trueName"]) ? $ajaxdata["trueName"] : $GPC["trueName"];
            $idCard = isset($ajaxdata["idCard"]) ? $ajaxdata["idCard"] : $GPC["idCard"];
            if (empty($bizWorker)) {
                throw new GeneralException("", "没有用户信息，请核查！");
            }

            require_once WEB_PHY_ROOT . "/base/wxsrv.php";
            txcloud_idcardCheck($trueName, $idCard);
            $sqlParam = array();
            $sqlParam[":realname_handletime"] = time();
            $sqlParam[":id"] = intval($bizWorker["id"]);
            $sqlParam[":true_name"] = $trueName;
            $sqlParam[":idcard"] = $idCard;
            $sqlParam[":realname_handle_remark"] = "[" . date("Y-m-d H:i:s", time()) . "] 实名认证 \n";
            $sqlTemp = "";
            $sqlTemp .= " update biz_worker set realname_handletime=:realname_handletime ";
            $sqlTemp .= " ,true_name=:true_name,idcard=:idcard ";
            $sqlTemp .= " ,realname_handle_remark=concat(:realname_handle_remark,ifnull(realname_handle_remark,'')) ";
            $sqlTemp .= " where id =:id;";
            $backdata = pdo_query3($sqlTemp, $sqlParam);
            return $backdata;
            break;
        case "fetchByPlater":
        case "fetchByTrader":
        case "fetchByTrader2":
        case "fetchByWorker":
            if (!empty($bizWorker)) {
                $workerId = $bizWorker["id"];
            } else {
                $workerId = isset($ajaxdata["workerId"]) ? $ajaxdata["workerId"] : $GPC["workerId"];
            }

            $sqlTemp = "select wk.*,bu.mobile as bu_mobile,bu.subsystem as subsystem,bu.wxapp_appid,bu.wxapp_openid,bu.wxmina_appid,bu.wxmina_openid";
            $sqlTemp .= " ,(select ifnull(avg(result_level),0) from biz_appraisal bapr where bapr.biz_catalog=2 and bapr.toerid=wk.id ) as worker_appraisal_avg ";
            $sqlTemp .= " from biz_worker wk";
            $sqlTemp .= " left join base_user  bu  on bu.id =wk.base_userid";
            $sqlTemp .= " where wk.id=:bizUserId limit 1;";
            $bizWorker = pdo_fetch($sqlTemp, array(":bizUserId" => $workerId));
            if (empty($bizWorker)) {
                throw new GeneralException("", "没有传递必要的workerId参数或没有对应的记录，请核查！");
            }

            $wokerInfo = array();
            $wokerInfo["id"] = $bizWorker["id"];
            $wokerInfo["workerId"] = $bizWorker["id"];
            $wokerInfo["profile_photo"] = $bizWorker["profile_photo"];
            $wokerInfo["regtime"] = date("Y-m-d", $bizWorker["createtime"]);
            $wokerInfo["true_name"] = $bizWorker["true_name"];
            $wokerInfo["realname_handled"] = $bizWorker["realname_handled"];
            $wokerInfo["nickname"] = $bizWorker["nickname"];
            $wokerInfo["blocked"] = intval($bizWorker["hanging"]) == 4 ? "1" : "0";
            $wokerInfo["blockedName"] = intval($wokerInfo["blocked"]) <= 0 ? "非黑名单" : "黑名单";
            $wokerInfo["memberRealed"] = empty(trim($bizWorker["idcard"])) ? false : true;
            $accountInfo = bizbase_workerAccountInfo($bizWorker);
            foreach ($accountInfo as $key => $value) {
                $wokerInfo["finance_" . $key] = $value;
            }

            $statistics = bizbase_workerStatistics($bizWorker);
            foreach ($statistics as $key => $value) {
                $wokerInfo["ss_" . $key] = $value;
            }

            $uodoList = bizbase_workerUndoList($bizWorker);
            foreach ($uodoList as $key => $value) {
                $wokerInfo["ss_" . $key] = $value;
            }

            $wokerInfo["mobile"] = $bizWorker["bu_mobile"];
            $wokerInfo["idcard"] = $bizWorker["idcard"];
            $wokerInfo["nation_name"] = $bizWorker["nation_name"];
            $wokerInfo["worker_appraisal_avg"] = round($bizWorker["worker_appraisal_avg"], 1);
            $wokerInfo["birthaddr"] = $bizWorker["birthaddr"];
            $wokerInfo["gender"] = (intval($bizWorker["gender"]) < 0 ? "" : (intval($bizWorker["gender"]) == 0 ? "男" : "女"));
            $wokerInfo["age"] = "";
            if (intval($bizWorker["birthday"]) > 0) {
                $birthdate = date("Ymd", $bizWorker["birthday"]);
                $datetime1 = date_create_from_format("Ymd", $birthdate);
                $datetime1 = new \DateTime(date("Y-m-d", date_timestamp_get($datetime1)));
                $datetime2 = new \DateTime(date("Y-m-d", time()));
                $interval = $datetime1->diff($datetime2);
                $wokerInfo["age"] = intval($interval->format('%Y'));
            }
            $wokerInfo["birthday"] = (intval($bizWorker["birthday"]) <= 0 ? "" : date("Y-m-d", $bizWorker["birthday"]));
            $wokerInfo["body_height"] = $bizWorker["body_height"];
            $wokerInfo["body_height"] = $bizWorker["body_height"];
            $wokerInfo["linker_phone"] = $bizWorker["linker_phone"];
            $wokerInfo["nowaddr"] = $bizWorker["nowaddr"];
            $wokerInfo["edulevel"] = $bizWorker["edulevel"];
            $wokerInfo["edulevel_name"] = $bizWorker["edulevel_name"];
            $wokerInfo["idcard_ppic"] = $bizWorker["idcard_ppic"]; //前端拼接头
            $wokerInfo["idcard_npic"] = $bizWorker["idcard_npic"]; //前端拼接头
            $wokerInfo["work_history"] = $bizWorker["work_history"];
            $wokerInfo["work_skills"] = $bizWorker["work_skills"];
            $wokerInfo["self_evaluation"] = $bizWorker["self_evaluation"];
            $wokerInfo["certificates"] = json_decode($bizWorker["certificates"], true);
            $breakInfo = pdo_fetchall("select catalog,count(*) as total from biz_worker_breaklaw where biz_workerid=" . intval($bizWorker["id"]) . " group by catalog");
            $wokerInfo["breakTotal0"] = 0;
            $wokerInfo["breakTotal1"] = 0;
            $wokerInfo["breakTotal2"] = 0;
            $wokerInfo["breakTotal3"] = 0;
            foreach ($breakInfo as $item) {
                $wokerInfo["breakTotal" . intval($item["catalog"])] = intval($item["total"]);
            }

            return $wokerInfo;
            break;
        case "blackhandle":
            $workerId = isset($ajaxdata["workerId"]) ? $ajaxdata["workerId"] : $GPC["workerId"];
            $sqlTemp = "select wk.*,bu.mobile as bu_mobile,bu.subsystem as subsystem,bu.wxapp_appid,bu.wxapp_openid,bu.wxmina_appid,bu.wxmina_openid";
            $sqlTemp .= " from biz_worker wk";
            $sqlTemp .= " left join base_user  bu  on bu.id =wk.base_userid";
            $sqlTemp .= " where wk.id=:bizUserId limit 1;";
            $bizWorker = pdo_fetch($sqlTemp, array(":bizUserId" => $workerId));
            if (empty($bizWorker)) {
                throw new GeneralException("", "没有传递必要的workerId参数或没有对应的记录，请核查！");
            }

            $reason = isset($ajaxdata["reason"]) ? $ajaxdata["reason"] : $GPC["reason"];
            $todo = isset($ajaxdata["todo"]) ? $ajaxdata["todo"] : $GPC["todo"];
            switch (trim($todo)) {
                case "set":
                    if (intval($bizWorker["hanging"]) >= 4) {
                        throw new GeneralException("", "已是黑名单状态了啊，请核查！");
                    }

                    $sqlTemp = "";
                    $sqlTemp .= " update biz_worker set updatetime=:nowtime,`hanging`=4,remark=concat(:remark,ifnull(remark,'')) where id=:id;";
                    $backdata = pdo_query($sqlTemp, array(
                        ":nowtime" => time(),
                        ":id" => intval($bizWorker["id"]),
                        ":remark" => "[" . date("Y-m-d H:i:s", time()) . "] 设置为黑名单 {$reason} \n"));
                    return $backdata;
                    break;
                case "reset":
                    if (intval($bizWorker["hanging"]) < 4) {
                        throw new GeneralException("", "当前处于非黑名单状态，请核查！");
                    }

                    $sqlTemp = "";
                    $sqlTemp .= " update biz_worker set updatetime=:nowtime,`hanging`=0,remark=concat(:remark,ifnull(remark,'')) where id=:id;";
                    $backdata = pdo_query($sqlTemp, array(
                        ":nowtime" => time(),
                        ":id" => intval($bizWorker["id"]),
                        ":remark" => "[" . date("Y-m-d H:i:s", time()) . "] 取消黑名单 {$reason} \n"));
                    return $backdata;
                    break;
                default:throw new GeneralException("", "不支持的todo");
            }
            break;
        case "wxRecharge":
            $minaCode = isset($ajaxdata["minaCode"]) ? $ajaxdata["minaCode"] : $GPC["minaCode"];
            if (empty(trim($minaCode))) {
                throw new GeneralException("", "没有传递必要的minaCode参数");
            }

            $money = isset($ajaxdata["money"]) ? $ajaxdata["money"] : $GPC["money"];
            $money = round(floatval($money), 2);
            if ($money <= 0) {
                throw new GeneralException("", "没有传递必要的money参数或小于等于0了");
            }

            $sqlParam = array();
            $sqlParam[":nowtime"] = time();
            $sqlParam[":biz_workerid"] = intval($bizWorker["id"]);
            $sqlParam[":type"] = 0; //收支类型：0-收入；1-支出；
            $sqlParam[":money"] = $money; //收入：0-次数支付；1-支付工单；
            $sqlParam[":biz_catalog"] = 3; //微信支付充值
            $sqlParam[":biz_id"] = 0;
            $sqlParam[":remark"] = "会员直接微信支付充值";
            $sqlTemp = "";
            $sqlTemp .= " insert into biz_worker_account set createtime=:nowtime";
            $sqlTemp .= "  ,biz_workerid=:biz_workerid, biz_roletype=0, biz_userid=:biz_workerid ";
            $sqlTemp .= "  ,type=:type, `money`=:money";
            $sqlTemp .= "  ,biz_catalog=:biz_catalog, biz_id=:biz_id";
            $sqlTemp .= "  ,`status`=0, remark=:remark;";
            $sqlTemp .= " update biz_worker_account set biz_idtag=concat('WXCGM',id,'EE',paytag) where id=LAST_INSERT_ID();";
            $sqlTemp .= " select * from biz_worker_account where id=LAST_INSERT_ID();";
            $dataset = pdo_query3($sqlTemp, $sqlParam);
            $bizInfo = $dataset[count($dataset) - 1][0];
            if (empty($bizInfo)) {
                throw new GeneralException("", "构建预支付订单异常");
            }

            $payBizCatalog = 4; //会员侧微信支付充值
            $payBizId = $bizInfo["id"];
            $payScene = "JSAPI";
            $prePayArgs = array(
                "payBackBizCatalog" => $payBizCatalog,
                "payBackBizId" => $payBizId,
                "payScene" => $payScene,
            );
            require_once WEB_PHY_ROOT . "/base/wxsrv.php";
            $resObj = bizwx_fetchMinaOpenidCore(SUBSYS_LABOUR_MINA);
            $wxmina_appid = $resObj["wxmina_appid"];
            $wxmina_openid = $resObj["openid"];
            $bizArgs = array(
                "minaCode" => $minaCode,
                "bizInfo" => $bizInfo,
                "wxmina_appid" => $wxmina_appid,
                "wxmina_openid" => $wxmina_openid,
            );
            //不会出现重复订单
            require_once WEB_PHY_ROOT . "/base/wxsrv.php";
            $prePayInfo = weixin_prepayBuildV3($prePayArgs, $bizArgs, function ($bizCatalog, $bizId, $bizArgs) {
                $bizInfo = $bizArgs["bizInfo"];
                $wxmina_appid = $bizArgs["wxmina_appid"];
                $wxmina_openid = $bizArgs["wxmina_openid"];
                //---------------------------------------
                $payTotal = round(floatval($bizInfo["money"]), 2);
                if ($payTotal <= 0) {
                    throw new GeneralException("", "购买金额竟然小于等于0");
                }

                $payTotal = $payTotal * 100; //转为分
                //---------------------------------------
                $sqlParam = array();
                $sqlParam[":id"] = intval($bizInfo["id"]);
                $sqlParam[":wxmina_appid"] = $wxmina_appid;
                $sqlParam[":wxmina_openid"] = $wxmina_openid;
                $sqlTemp = "  update biz_worker_account set";
                $sqlTemp .= "   wxmina_appid=:wxmina_appid,wxmina_openid=:wxmina_openid ";
                $sqlTemp .= " where id=:id; ";
                $dataset = pdo_query3($sqlTemp, $sqlParam);
                //---------------------------------------
                $prePayInfo = array();
                $prePayInfo["appid"] = $wxmina_appid;
                $prePayInfo["mchId"] = WeiXinPay_mchId;
                $prePayInfo["mch_paykeyV2"] = WeiXinPay_apiKey;
                $prePayInfo["mch_paykeyV3"] = WeiXinPay_apiKeyV3;
                $prePayInfo["out_trade_no"] = $bizInfo["biz_idtag"];
                $prePayInfo["total"] = "{$payTotal}";
                $prePayInfo["description"] = "会员微信支付充值";
                $prePayInfo["openid"] = $wxmina_openid;
                return $prePayInfo;
            });
            $prePayInfo = array_merge($prePayArgs, $prePayInfo);
            return array(
                "prePayInfo" => $prePayInfo,
            );
            break;
        case "fetchRecuritPoster":
            $recuritid = isset($ajaxdata["recuritid"]) ? $ajaxdata["recuritid"] : $GPC["recuritid"];
            if (intval($recuritid) <= 0) {
                throw new GeneralException("", "没有传递必要的recuritid参数或值为空");
            }

            $recuritInfo = pdo_fetch("select * from biz_trader_recruit where id=" . intval($recuritid));
            if (empty($recuritInfo)) {
                throw new GeneralException("", "招聘id没有对应的记录，请核查！");
            }

            $title = $recuritInfo["title"];
            //$title="一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十";
            if (mb_strwidth($title) > 20) {
                do {
                    $title = mb_substr($title, 0, mb_strlen($title) - 1);
                } while (mb_strwidth($title) > 17);
                $title .= "...";
            }
            //$recuritInfo["feeper"]=rand(111,888);//测试
            $salary = round($recuritInfo["feeper"], 2) . " 元/天";
            $sharer_fetchmoney = round($recuritInfo["sharer_fetchmoney"], 2) . " 元";
            $need_total = intval($recuritInfo["need_total"]) . " 人";
            $address = $recuritInfo["work_addr"];
            $address = mb_strlen($address) > 32 ? mb_substr($address, 0, 31) . "..." : $address;
            $poster = array();
            $poster["imgtype"] = "png";
            $poster["width"] = "750";
            $poster["height"] = "1624";
            // $posterCfg = bizbase_getPosterConfig();
            // $bgpic = trim($posterCfg["bgpic"]);
            $poster["bg"] = "/prjcenter/prjKLY/fileroot/poster/posterbg.jpg";
            $poster["data"] = array(
                array(
                    "type" => "text",
                    "left" => 114, //左对齐
                    "top" => "640", // 文本中可以加入强制换行的字符\n
                    "text" => "" . $title,
                    "size" => "36",
                    "color" => "#248a75",
                    "font" => "msyh", //某种ttf字体 放置到assets/font目录下
                ),
                array(
                    "type" => "text",
                    "left" => "255",
                    "top" => "737", // 文本中可以加入强制换行的字符\n
                    "text" => "" . $salary,
                    "size" => "22",
                    "color" => "#248a75",
                    "font" => "msyh", //某种ttf字体 放置到assets/font目录下
                ),
                array(
                    "type" => "text",
                    "left" => "255",
                    "top" => "792", // 文本中可以加入强制换行的字符\n
                    "text" => "" . $need_total,
                    "size" => "22",
                    "color" => "#248a75",
                    "font" => "msyh", //某种ttf字体 放置到assets/font目录下
                ),
                array(
                    "type" => "text",
                    "left" => "255",
                    "top" => "850", // 文本中可以加入强制换行的字符\n
                    "text" => "" . $address,
                    "size" => "22",
                    "width" => 22 * 17,
                    "color" => "#248a75",
                    "font" => "msyh", //某种ttf字体 放置到assets/font目录下
                ),
                array(
                    "type" => "qrmina",
                    "left" => "175",
                    "top" => "920",
                    "size" => "400",
                    "margin" => "0",
                    "logpath" => WEB_PHY_ROOT . "/prjcenter/prjKLY/fileroot/uploads/qr_log.png",
                ),
            );
            $saveSubPath = "share"; //海报存储的子目录 $bizCatalog=1 会员招聘信息分享 ,$bizid=招聘id
            $poster_imgurl = poster_build_pre(1, $recuritid, $bizWorker["id"], $poster, $saveSubPath, null,
                function ($bizCatalog, $bizid, $userid, $pdata) { //二维码
                    switch ($bizCatalog) {
                        default:
                            $qrminaSubPath = "qrmina_img";
                            $qrminaAppId = WeiXin111_AppID;
                            $qrminaAppSecret = WeiXin111_AppSecret;
                            $qrminaPagePath = "pages/index/index";
                            break;
                    }
                    return array(
                        "qrminaSubPath" => $qrminaSubPath,
                        "qrminaAppId" => $qrminaAppId,
                        "qrminaAppSecret" => $qrminaAppSecret,
                        "qrminaPagePath" => $qrminaPagePath,
                    );
                });
            return WEBAPI_IMG_HOSTURL . $poster_imgurl;
            break;
        default:
            throw new GeneralException("", "不支持的handleMode！");
    }
}
function bizbase_workerAboutQuery($fromSubSystem, $baseUser, $bizUser, $handleMode, $pageIndex, $pageSize, $ajaxdata, $GPC)
{
    if (intval($baseUser["subsystem"]) == SUBSYS_LABOUR_MINA) {
        $bizWorker = $bizUser;
    }

    if (intval($baseUser["subsystem"]) == SUBSYS_CAPITAL_MINA) {
        $bizTrader = $bizUser;
    }

    if (intval($baseUser["subsystem"]) == SUBSYS_CAPITAL2_MINA) {
        $bizTrader2 = $bizUser;
    }

    switch ($handleMode) {
        case "fetchall":
            $sqlParam = array();
            $query = isset($ajaxdata["query"]) ? $ajaxdata["query"] : $GPC["query"];
            $queryBreak = " and 1=1 ";
            if (empty($query) && !is_array($query)) { //验证一下query信息集
                $query = " and 1=1 ";
            } else {
                $queryNew = " and 1=1 ";
                foreach ($query as $fdName => $fdValue) {
                    if (empty($fdName) || empty($fdValue)) {
                        continue;
                    }

                    switch ($fdName) {
                        case "stoped":
                            switch (intval($fdValue)) {
                                case 1:
                                    $queryNew .= " and ( wk.hanging<=1 || ((wk.hanging=2 or wk.hanging=3) and wk.hanging_endtime<" . time() . " )) ";
                                    break;
                                case 2:
                                    $queryNew .= " and ( wk.hanging=4 || ((wk.hanging=2 or wk.hanging=3) and wk.hanging_endtime>=" . time() . " )) ";
                                    break;
                            }
                            break;
                        case "breakType":
                            if (intval($fdValue) > 0) {
                                $queryBreak .= " and catalog=" . (intval($fdValue) - 1);
                                $queryNew .= " and (select count(*) from biz_worker_breaklaw where biz_workerid=wk.id $queryBreak )>0 ";
                            }
                            break;
                        case "blocked":
                            if (intval($fdValue) > 0) {
                                $queryNew .= " and wk.blocked=" . (intval($fdValue) - 1);
                            }
                            break;
                        case "mobile":
                            $paramName = ":qy_mobile";
                            $queryNew .= " and (bu.mobile like concat('%',{$paramName},'%') ) ";
                            $sqlParam[$paramName] = $fdValue;
                            break;
                        case "memberName":
                            $paramName = ":qy_memberName";
                            $queryNew .= " and (wk.true_name like concat('%',{$paramName},'%') ) ";
                            $sqlParam[$paramName] = $fdValue;
                            break;
                        case "idcard":
                            $paramName = ":qy_idcard";
                            $queryNew .= " and (wk.idcard like concat('%',{$paramName},'%') ) ";
                            $sqlParam[$paramName] = $fdValue;
                            break;
                        case "edulevelName":
                            $paramName = ":qy_edulevelName";
                            $queryNew .= " and (wk.edulevel_name like concat('%',{$paramName},'%') ) ";
                            $sqlParam[$paramName] = $fdValue;
                            break;
                        case "regtime":
                            $paramName1 = ":qy_regtime1";
                            $paramName2 = ":qy_regtime2";
                            $queryNew .= " and (wk.createtime>= $paramName1 and wk.createtime<=$paramName2 ) ";
                            $sqlParam[$paramName1] = strtotime($fdValue);
                            $sqlParam[$paramName2] = strtotime($fdValue) + (24 * 3600);
                            break;
                    }
                }
                $query = $queryNew;
            }
            $orderby = isset($ajaxdata["orderby"]) ? $ajaxdata["orderby"] : $GPC["orderby"];
            switch (intval($orderby)) {
                case 1:
                    $orderby = " order by work_erolledtotal desc ";
                    break;
                case 2:
                    $orderby = " order by withdraw_total desc ";
                    break;
                case 3:
                    $orderby = " order by work_excepttotal desc ";
                    break;
                default:
                    $orderby = " order by wk.id desc ";
                    break;
            }
            //构建sql串
            $sqlBody = "";
            $sqlBody .= "  from biz_worker wk  ";
            $sqlBody .= " left join base_user  bu on bu.id =wk.base_userid";
            $sqlBody .= "  where wk.`deleted`=0  " . $query;
            //查询sql及统计sql
            $start = (intval($pageIndex) - 1) * $pageSize;
            $sqlFetch = " select wk.id as workerId,wk.* ";
            $sqlFetch .= " ,(select count(*) from biz_worker_breaklaw where biz_workerid=wk.id $queryBreak ) as break_total ";
            $sqlFetch .= " ,(select count(*) from biz_todowork where biz_workerid=wk.id and `status`>=1 ) as work_erolledtotal ";
            $sqlFetch .= " ,(select ifnull(sum(money),0) from biz_worker_account where deleted=0 and `status`=1 and biz_workerid=wk.id and type=1 and biz_catalog=0 ) as withdraw_total ";
            $sqlFetch .= " ,(select count(*) from biz_todowork where biz_workerid=wk.id and `status`<0 ) as work_excepttotal ";
            $sqlFetch .= " ,bu.mobile as bu_mobile ";
            $sqlFetch .= " {$sqlBody} {$orderby} limit {$start},{$pageSize} ";
            $pageData = pdo_fetchall($sqlFetch, $sqlParam);
            foreach ($pageData as &$data) { //数据转换/映射
                $accountInfo = bizbase_workerAccountInfo($data);
                foreach ($accountInfo as $key => $value) {
                    $data["finance_" . $key] = $value;
                }

                $statistics = bizbase_workerStatistics($data);
                foreach ($statistics as $key => $value) {
                    $data["" . $key] = $value;
                }

                $data["regtime"] = date("Y-m-d", $data["createtime"]);
                $data["birthday"] = (intval($data["birthday"]) <= 0 ? "" : date("Y-m-d", $data["birthday"]));
                $data["remark"] = trim(explode("\n", $data["remark"])[0]);
                $data["certificates"] = json_decode($data["certificates"], true);
            }
            $sqlSummary = " select count(*) as count " . $sqlBody;
            $sumData = pdo_fetch($sqlSummary, $sqlParam);
            return array(
                "pageData" => $pageData,
                "count" => intval($sumData["count"]),
            );

            break;
        case "fetchallSharer":
            $sqlParam = array();
            $query = isset($ajaxdata["query"]) ? $ajaxdata["query"] : $GPC["query"];
            $queryBreak = " and 1=1 ";
            if (empty($query) && !is_array($query)) { //验证一下query信息集
                $query = " and 1=1 ";
            } else {
                $queryNew = " and 1=1 ";
                foreach ($query as $fdName => $fdValue) {
                    if (empty($fdName) || empty($fdValue)) {
                        continue;
                    }

                    switch ($fdName) {
                        case "mobile":
                            $paramName = ":qy_mobile";
                            $queryNew .= " and (bu.mobile like concat('%',{$paramName},'%') ) ";
                            $sqlParam[$paramName] = $fdValue;
                            break;
                        case "memberName":
                            $paramName = ":qy_memberName";
                            $queryNew .= " and (wk.true_name like concat('%',{$paramName},'%') ) ";
                            $sqlParam[$paramName] = $fdValue;
                            break;
                        case "startDate":
                            $queryNew .= " and bwa.createtime>=" . strtotime(date("Y-m-d", strtotime($fdValue))) . " ";
                            break;
                        case "finishDate":
                            $queryNew .= " and bwa.createtime<=" . strtotime(date("Y-m-d", strtotime($fdValue))) . " ";
                            break;
                    }
                }
                $query = $queryNew;
            }
            $orderby = isset($ajaxdata["orderby"]) ? $ajaxdata["orderby"] : $GPC["orderby"];
            switch (intval($orderby)) {
                case 1:
                    $orderby = " order by money_total desc ";
                    break;
                default:
                    $orderby = " order by work_total desc ";
                    break;
            }
            //构建sql串
            $sqlBody = "";
            $sqlBody .= "  from  biz_worker_account bwa  ";
            $sqlBody .= "  inner join biz_worker wk on wk.id=bwa.biz_workerid  ";
            $sqlBody .= " left  join base_user  bu on bu.id=wk.base_userid ";
            $sqlBody .= "  where bwa.type=0 and bwa.`status`=1 and bwa.biz_catalog=1 and wk.`deleted`=0  " . $query;
            $sqlBody .= "  group by bwa.biz_workerid ";
            //查询sql及统计sql
            $start = (intval($pageIndex) - 1) * $pageSize;
            $sqlFetch = " select wk.id as workerId,wk.* ";
            $sqlFetch .= " ,bu.mobile as bu_mobile ";
            $sqlFetch .= " ,count(bwa.id) as work_total,sum(bwa.money) as money_total ";
            $sqlFetch .= " {$sqlBody} {$orderby} limit {$start},{$pageSize} ";
            $pageData = pdo_fetchall($sqlFetch, $sqlParam);
            foreach ($pageData as &$data) { //数据转换/映射
                $data["true_name"] = (!empty($data["true_name"])) ? $data["true_name"] : $data["nickname"];
                $data["birthday"] = (intval($data["birthday"]) <= 0 ? "" : date("Y-m-d", $data["birthday"]));
                $data["remark"] = trim(explode("\n", $data["remark"])[0]);
            }
            $sqlSummary = " select count(*) as count from ( select wk.id " . $sqlBody . " ) as temp ";
            $sumData = pdo_fetch($sqlSummary, $sqlParam);
            return array(
                "pageData" => $pageData,
                "count" => intval($sumData["count"]),
            );
            break;
        case "fetchallShareWorks":
            $sqlParam = array();
            $shareWorkerId = isset($ajaxdata["shareWorkerId"]) ? $ajaxdata["shareWorkerId"] : $GPC["shareWorkerId"];
            $query = isset($ajaxdata["query"]) ? $ajaxdata["query"] : $GPC["query"];
            $queryBreak = " and 1=1 ";
            if (empty($query) && !is_array($query)) { //验证一下query信息集
                $query = " and 1=1 ";
            } else {
                $queryNew = " and 1=1 ";
                foreach ($query as $fdName => $fdValue) {
                    if (empty($fdName) || empty($fdValue)) {
                        continue;
                    }

                    switch ($fdName) {
                        case "recuritTitle":
                            $paramName = ":qy_recuritTitle";
                            $queryNew .= " and (btr.title like concat('%',{$paramName},'%') ) ";
                            $sqlParam[$paramName] = $fdValue;
                            break;
                        case "startDate":
                            $queryNew .= " and bwa.createtime>=" . strtotime(date("Y-m-d", strtotime($fdValue))) . " ";
                            break;
                        case "finishDate":
                            $queryNew .= " and bwa.createtime<=" . strtotime(date("Y-m-d", strtotime($fdValue))) . " ";
                            break;
                    }
                }
                $query = $queryNew;
            }
            $query .= " and bwa.biz_workerid=" . intval($shareWorkerId) . " ";
            $orderby = isset($ajaxdata["orderby"]) ? $ajaxdata["orderby"] : $GPC["orderby"];
            switch (intval($orderby)) {
                case 1:
                    $orderby = " order by work_total desc ";
                    break;
                default:
                    $orderby = " order by money_total desc ";
                    break;
            }
            //构建sql串
            $sqlBody = "";
            $sqlBody .= "  from  biz_worker_account      bwa  ";
            //$sqlBody .= "  inner join biz_trader_account bta  on bta.id=bwa.biz_id  ";
            $sqlBody .= "  inner join biz_todowork       tdwk on tdwk.id=bwa.biz_id  ";
            $sqlBody .= "  left  join biz_trader_recruit btr  on btr.id=tdwk.biz_recruitid  ";
            $sqlBody .= "  left  join biz_trader         bt   on bt.id=btr.biz_traderid ";
            $sqlBody .= "  left  join base_user          btbu on btbu.id=bt.base_userid  ";
            $sqlBody .= "  where bwa.type=0 and bwa.`status`=1 and bwa.biz_catalog=1 and bwa.`deleted`=0  " . $query;
            $sqlBody .= "  group by tdwk.biz_recruitid ";
            //查询sql及统计sql
            $start = (intval($pageIndex) - 1) * $pageSize;
            $sqlFetch = " select btr.* ";
            $sqlFetch .= " ,bt.company_name,btbu.mobile as btbu_mobile ";
            $sqlFetch .= " ,count(bwa.id) as work_total,sum(bwa.money) as money_total ";
            $sqlFetch .= " {$sqlBody} {$orderby} limit {$start},{$pageSize} ";
            $pageData = pdo_fetchall($sqlFetch, $sqlParam);
            foreach ($pageData as &$data) { //数据转换/映射
                $data["remark"] = trim(explode("\n", $data["remark"])[0]);
            }
            $sqlSummary = " select count(*) as count from ( select bwa.id " . $sqlBody . " ) as temp ";
            $sumData = pdo_fetch($sqlSummary, $sqlParam);
            return array(
                "pageData" => $pageData,
                "count" => intval($sumData["count"]),
            );
            break;
        case "fetchallShareWorkers":
            $sqlParam = array();
            $shareWorkerId = isset($ajaxdata["shareWorkerId"]) ? $ajaxdata["shareWorkerId"] : $GPC["shareWorkerId"];
            $query = isset($ajaxdata["query"]) ? $ajaxdata["query"] : $GPC["query"];
            $queryBreak = " and 1=1 ";
            if (empty($query) && !is_array($query)) { //验证一下query信息集
                $query = " and 1=1 ";
            } else {
                $queryNew = " and 1=1 ";
                foreach ($query as $fdName => $fdValue) {
                    if (empty($fdName) || empty($fdValue)) {
                        continue;
                    }

                    switch ($fdName) {
                        case "recruitid":
                            $paramName = ":qy_recruitid";
                            $queryNew .= " and tdwk.biz_recruitid=" . intval($fdValue) . "  ";
                            $sqlParam[$paramName] = $fdValue;
                            break;
                        case "memberName":
                            $paramName = ":qy_memberName";
                            $queryNew .= " and (wk.true_name like concat('%',{$paramName},'%') ) ";
                            $sqlParam[$paramName] = $fdValue;
                            break;
                        case "startDate":
                            $queryNew .= " and bwa.createtime>=" . strtotime(date("Y-m-d", strtotime($fdValue))) . " ";
                            break;
                        case "finishDate":
                            $queryNew .= " and bwa.createtime<=" . strtotime(date("Y-m-d", strtotime($fdValue))) . " ";
                            break;
                    }
                }
                $query = $queryNew;
            }
            $query .= " and bwa.biz_workerid=" . intval($shareWorkerId) . " ";
            $orderby = isset($ajaxdata["orderby"]) ? $ajaxdata["orderby"] : $GPC["orderby"];
            switch (intval($orderby)) {
                case 1:
                    $orderby = " order by work_total desc ";
                    break;
                default:
                    $orderby = " order by money_total desc ";
                    break;
            }
            //构建sql串
            $sqlBody = "";
            $sqlBody .= "  from  biz_worker_account      bwa  ";
            //$sqlBody .= "  inner join biz_trader_account bta  on bta.id=bwa.biz_id  ";
            //$sqlBody .= "  inner join biz_todowork       tdwk on tdwk.id=bta.biz_id  ";
            $sqlBody .= "  inner join biz_todowork       tdwk on tdwk.id=bwa.biz_id  ";
            $sqlBody .= "  left  join biz_worker         wk   on wk.id=tdwk.biz_workerid  ";
            $sqlBody .= " left  join base_user          bu   on bu.id=wk.base_userid ";
            $sqlBody .= "  where bwa.type=0 and bwa.`status`=1 and bwa.biz_catalog=1 and bwa.`deleted`=0  " . $query;
            $sqlBody .= "  group by tdwk.biz_workerid ";
            //查询sql及统计sql
            $start = (intval($pageIndex) - 1) * $pageSize;
            $sqlFetch = " select wk.*,bwa.createtime as bwa_createtime ";
            $sqlFetch .= " ,bu.mobile as bu_mobile ";
            $sqlFetch .= " ,tdwk.id as tdwk_id ";
            $sqlFetch .= " ,count(bwa.id) as work_total,sum(bwa.money) as money_total ";
            $sqlFetch .= " {$sqlBody} {$orderby} limit {$start},{$pageSize} ";
            $pageData = pdo_fetchall($sqlFetch, $sqlParam);
            foreach ($pageData as &$data) { //数据转换/映射
                $data["true_name"] = (!empty($data["true_name"])) ? $data["true_name"] : $data["nickname"];
                $data["bwa_createtime"] = date("Y-m-d H:i:s", $data["bwa_createtime"]);
                $data["tdwk_sn"] = base_buildSNById("WK", $data["tdwk_id"]);
                $data["birthday"] = (intval($data["birthday"]) <= 0 ? "" : date("Y-m-d", $data["birthday"]));
                $data["remark"] = trim(explode("\n", $data["remark"])[0]);
            }
            $sqlSummary = " select count(*) as count,sum(work_total) as work_total,sum(money_total) as money_total from ( select bwa.id,count(bwa.id) as work_total,sum(bwa.money) as money_total " . $sqlBody . " ) as temp ";
            $sumData = pdo_fetch($sqlSummary, $sqlParam);
            return array(
                "pageData" => $pageData,
                "count" => intval($sumData["count"]),
                "money_total" => round($sumData["money_total"], 2),
                "work_total" => intval($sumData["work_total"]),
            );
            break;
        default:
            throw new GeneralException("", "不支持的handleMode！");
    }
}