|
|
@@ -204,37 +204,37 @@ service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
}
|
|
|
//------------------------------------------------
|
|
|
//超时自动结算
|
|
|
- /*
|
|
|
+
|
|
|
myecho("处理内容:超时自动结算");
|
|
|
try {
|
|
|
- $pageIndex = 1;
|
|
|
- $pageSize = 30;
|
|
|
- $start = ($pageIndex - 1) * $pageSize;
|
|
|
- // $pageData=pdo_fetchall("select tdwk.*
|
|
|
- // from biz_todowork tdwk
|
|
|
- // left join biz_trader_recruit as btr on btr.id=tdwk.biz_recruitid
|
|
|
- // where tdwk.`status`=4 and tdwk.worked_finishtime<=:query_nowdate
|
|
|
- // limit {$start},{$pageSize}",array(
|
|
|
- // ":query_nowdate"=>time()-3600*48,
|
|
|
- // ));
|
|
|
- // foreach ($pageData as $data) {
|
|
|
- // $result = biz_flkForWork($data["id"], $data, function ($data) {
|
|
|
- // try{
|
|
|
- // $sqlParam=array();
|
|
|
- // $sqlParam[":nowtime"]=time();
|
|
|
- // $sqlParam[":workid"]=$data["id"];
|
|
|
- // $sqlParam[":status"]=-8;
|
|
|
- // $sqlParam[":remark"]="[".date("Y-m-d H:i:s",time())."] 自动处理为【超48时未结算】状态 \n";
|
|
|
- // $sqlTemp=" update biz_todowork set updatetime=:nowtime ";
|
|
|
- // $sqlTemp.=" ,`status`=:status, remark=concat(:remark,ifnull(remark,''))";
|
|
|
- // $sqlTemp.=" where id=:workid and `status`=4;";
|
|
|
- // $backdata=pdo_query3($sqlTemp,$sqlParam);
|
|
|
- // }catch(Throwable $e){
|
|
|
- // myecho("超时48小时未结算处理发生异常11：".$e->getMessage());
|
|
|
- // }
|
|
|
- // });
|
|
|
- // }
|
|
|
- $pageData = pdo_fetchall("select tdwk.*
|
|
|
+ $pageIndex = 1;
|
|
|
+ $pageSize = 30;
|
|
|
+ $start = ($pageIndex - 1) * $pageSize;
|
|
|
+ // $pageData=pdo_fetchall("select tdwk.*
|
|
|
+ // from biz_todowork tdwk
|
|
|
+ // left join biz_trader_recruit as btr on btr.id=tdwk.biz_recruitid
|
|
|
+ // where tdwk.`status`=4 and tdwk.worked_finishtime<=:query_nowdate
|
|
|
+ // limit {$start},{$pageSize}",array(
|
|
|
+ // ":query_nowdate"=>time()-3600*48,
|
|
|
+ // ));
|
|
|
+ // foreach ($pageData as $data) {
|
|
|
+ // $result = biz_flkForWork($data["id"], $data, function ($data) {
|
|
|
+ // try{
|
|
|
+ // $sqlParam=array();
|
|
|
+ // $sqlParam[":nowtime"]=time();
|
|
|
+ // $sqlParam[":workid"]=$data["id"];
|
|
|
+ // $sqlParam[":status"]=-8;
|
|
|
+ // $sqlParam[":remark"]="[".date("Y-m-d H:i:s",time())."] 自动处理为【超48时未结算】状态 \n";
|
|
|
+ // $sqlTemp=" update biz_todowork set updatetime=:nowtime ";
|
|
|
+ // $sqlTemp.=" ,`status`=:status, remark=concat(:remark,ifnull(remark,''))";
|
|
|
+ // $sqlTemp.=" where id=:workid and `status`=4;";
|
|
|
+ // $backdata=pdo_query3($sqlTemp,$sqlParam);
|
|
|
+ // }catch(Throwable $e){
|
|
|
+ // myecho("超时48小时未结算处理发生异常11：".$e->getMessage());
|
|
|
+ // }
|
|
|
+ // });
|
|
|
+ // }
|
|
|
+ $pageData = pdo_fetchall("select tdwk.*
|
|
|
,btr.biz_traderid, btr.feetotal as pay_feetotal
|
|
|
,btr.plat_fetchmoney,btr.sharer_fetchmoney,btr.salary as wker_salary
|
|
|
from biz_todowork tdwk
|
|
|
@@ -242,93 +242,93 @@ service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
where tdwk.`status`=4 and tdwk.worked_finishtime<=:query_nowdate
|
|
|
order by tdwk.id desc
|
|
|
limit {$start},{$pageSize}", array(
|
|
|
- ":query_nowdate" => time() - 3600 * 48,
|
|
|
- // ":query_nowdate"=>time()-3600*12,
|
|
|
- // ":query_nowdate"=>time(),
|
|
|
- ));
|
|
|
- foreach ($pageData as $data) {
|
|
|
- $result = biz_flkForWork($data["id"], $data, function ($data) {
|
|
|
- try {
|
|
|
- $platerMoney = round(floatval($data["plat_fetchmoney"]), 2);
|
|
|
- $sharerMoney = round(floatval($data["sharer_fetchmoney"]), 2);
|
|
|
- $workerMoney = round(floatval($data["wker_salary"]), 2);
|
|
|
- $bizUser = $data["bizUser"];
|
|
|
- $sqlParam = array();
|
|
|
- $sqlParam[":nowtime"] = time();
|
|
|
- $sqlParam[":nowtime2"] = "[" . date("Y-m-d H:i:s", time()) . "] 超时48小时自动结算";
|
|
|
- $sqlParam[":wkid"] = $data["id"];
|
|
|
- $sqlParam[":biz_roletype"] = 0;
|
|
|
- $sqlParam[":biz_userid"] = intval($bizUser["id"]);
|
|
|
- $sqlTemp = "";
|
|
|
+ ":query_nowdate" => time() - 3600 * 48,
|
|
|
+ // ":query_nowdate"=>time()-3600*12,
|
|
|
+ // ":query_nowdate"=>time(),
|
|
|
+ ));
|
|
|
+ foreach ($pageData as $data) {
|
|
|
+ $result = biz_flkForWork($data["id"], $data, function ($data) {
|
|
|
+ try {
|
|
|
+ $platerMoney = round(floatval($data["plat_fetchmoney"]), 2);
|
|
|
+ $sharerMoney = round(floatval($data["sharer_fetchmoney"]), 2);
|
|
|
+ $workerMoney = round(floatval($data["wker_salary"]), 2);
|
|
|
+ $bizUser = $data["bizUser"];
|
|
|
+ $sqlParam = array();
|
|
|
+ $sqlParam[":nowtime"] = time();
|
|
|
+ $sqlParam[":nowtime2"] = "[" . date("Y-m-d H:i:s", time()) . "] 超时48小时自动结算";
|
|
|
+ $sqlParam[":wkid"] = $data["id"];
|
|
|
+ $sqlParam[":biz_roletype"] = 0;
|
|
|
+ $sqlParam[":biz_userid"] = intval($bizUser["id"]);
|
|
|
+ $sqlTemp = "";
|
|
|
|
|
|
- //商家冻结费用解冻
|
|
|
- $sqlTemp .= " insert into biz_trader_account ( `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`,`biz_id`, remark )";
|
|
|
- $sqlTemp .= " select btr.biz_traderid, :nowtime , 0 , btr.feetotal, 1, 6 , tdwk.id, concat(:nowtime2,'工单结算时解冻工单费用\n') ";
|
|
|
- $sqlTemp .= " from biz_todowork tdwk";
|
|
|
- $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
- $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
+ //商家冻结费用解冻
|
|
|
+ $sqlTemp .= " insert into biz_trader_account ( `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`,`biz_id`, remark )";
|
|
|
+ $sqlTemp .= " select btr.biz_traderid, :nowtime , 0 , btr.feetotal, 1, 6 , tdwk.id, concat(:nowtime2,'工单结算时解冻工单费用\n') ";
|
|
|
+ $sqlTemp .= " from biz_todowork tdwk";
|
|
|
+ $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
+ $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
|
|
|
- //工单结算支出
|
|
|
- $sqlParam[":biz_catalog1"] = 6; //6-工单整体支出；
|
|
|
- $sqlTemp .= " insert into biz_trader_account ( `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`, `biz_id`, remark )";
|
|
|
- $sqlTemp .= " select btr.biz_traderid, :nowtime , 1 , btr.feetotal, 1, :biz_catalog1 , tdwk.id, concat(:nowtime2,'工单结算时支出工单费用\n') ";
|
|
|
- $sqlTemp .= " from biz_todowork tdwk";
|
|
|
- $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
- $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
+ //工单结算支出
|
|
|
+ $sqlParam[":biz_catalog1"] = 6; //6-工单整体支出；
|
|
|
+ $sqlTemp .= " insert into biz_trader_account ( `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`, `biz_id`, remark )";
|
|
|
+ $sqlTemp .= " select btr.biz_traderid, :nowtime , 1 , btr.feetotal, 1, :biz_catalog1 , tdwk.id, concat(:nowtime2,'工单结算时支出工单费用\n') ";
|
|
|
+ $sqlTemp .= " from biz_todowork tdwk";
|
|
|
+ $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
+ $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
|
|
|
- //------------------------------------
|
|
|
- $share_workerid = intval($data["share_workerid"]);
|
|
|
- if ($share_workerid > 0) {
|
|
|
- $platerMoney = $platerMoney - $sharerMoney;
|
|
|
- }
|
|
|
+ //------------------------------------
|
|
|
+ $share_workerid = intval($data["share_workerid"]);
|
|
|
+ if ($share_workerid > 0) {
|
|
|
+ $platerMoney = $platerMoney - $sharerMoney;
|
|
|
+ }
|
|
|
|
|
|
- $sqlParam[":platerMoney"] = $platerMoney; //平台分成
|
|
|
- $sqlTemp .= " insert into biz_trader_account ( deleted, `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`, `biz_id`, remark )";
|
|
|
- $sqlTemp .= " select 9, btr.biz_traderid , :nowtime , 1 , :platerMoney, 1, 1 , tdwk.id, concat(:nowtime2,'工单结算时平台分成\n') ";
|
|
|
- $sqlTemp .= " from biz_todowork tdwk";
|
|
|
- $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
- $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
+ $sqlParam[":platerMoney"] = $platerMoney; //平台分成
|
|
|
+ $sqlTemp .= " insert into biz_trader_account ( deleted, `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`, `biz_id`, remark )";
|
|
|
+ $sqlTemp .= " select 9, btr.biz_traderid , :nowtime , 1 , :platerMoney, 1, 1 , tdwk.id, concat(:nowtime2,'工单结算时平台分成\n') ";
|
|
|
+ $sqlTemp .= " from biz_todowork tdwk";
|
|
|
+ $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
+ $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
|
|
|
- if ($share_workerid > 0) { //分享佣金
|
|
|
- $sqlParam[":sharerMoney"] = $sharerMoney;
|
|
|
- $sqlParam[":share_workerid"] = $share_workerid;
|
|
|
- $sqlTemp .= " insert into biz_trader_account ( deleted, `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`, `biz_id`, remark )";
|
|
|
- $sqlTemp .= " select 9, btr.biz_traderid , :nowtime , 1 , :sharerMoney, 1, 2 , :wkid, concat(:nowtime2,'工单结算时佣金分成支出\n') ";
|
|
|
- $sqlTemp .= " from biz_todowork tdwk";
|
|
|
- $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
- $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
- $sqlTemp .= " insert into biz_worker_account ( `biz_workerid`, `createtime`,`type`, `money`, `status`, `biz_catalog`,`biz_id`, remark )";
|
|
|
- $sqlTemp .= " select :share_workerid , :nowtime , 0 , :sharerMoney, 1, 1 , :wkid, concat(:nowtime2,'工单结算时佣金分成收入\n') from dual where 1=1;";
|
|
|
- }
|
|
|
- $sqlParam[":workerMoney"] = $workerMoney; //工人工资
|
|
|
- $sqlParam[":doed_workerid"] = intval($data["biz_workerid"]);
|
|
|
- $sqlTemp .= " insert into biz_trader_account ( deleted, `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`, `biz_id`, remark )";
|
|
|
- $sqlTemp .= " select 9, btr.biz_traderid , :nowtime , 1 , :workerMoney, 1, 3 , :wkid, concat(:nowtime2,'工单结算时工资支出\n') ";
|
|
|
- $sqlTemp .= " from biz_todowork tdwk";
|
|
|
- $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
- $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
- $sqlTemp .= " insert into biz_worker_account ( `biz_workerid`, `createtime`,`type`, `money`, `status`, `biz_catalog`,`biz_id`, remark )";
|
|
|
- $sqlTemp .= " select :doed_workerid , :nowtime , 0 , :workerMoney, 1, 0 , :wkid, concat(:nowtime2,'工单结算时工资收入\n') from dual where 1=1;";
|
|
|
- //报名押金退还
|
|
|
- $sqlTemp .= " insert into biz_worker_account ( `biz_workerid`, `createtime`,`type`, `money`, `status`, `biz_catalog`,`biz_id`, remark )";
|
|
|
- $sqlTemp .= " select biz_workerid , :nowtime , 0 , enroll_premoney, 1, 7 , id, concat(:nowtime2,'工单结算时押金退还\n') ";
|
|
|
- $sqlTemp .= " from biz_todowork where id=:wkid;";
|
|
|
- //修正工单状态
|
|
|
- $sqlTemp .= " update biz_todowork set updatetime=:nowtime,`status`=5 ,`final_status` = 1"; //已结算
|
|
|
- $sqlTemp .= " ,settled_time=:nowtime,settled_mode=:biz_roletype,settled_userid=:biz_userid";
|
|
|
- $sqlTemp .= " ,remark=concat(:nowtime2,'工单自动结算\n',ifnull(remark,'')) where id=:wkid;";
|
|
|
- $dataset = pdo_query3($sqlTemp, $sqlParam);
|
|
|
- myecho($sqlTemp);
|
|
|
- return true;
|
|
|
- } catch (Throwable $e) {
|
|
|
- myecho("超时48小时自动结算处理发生异常：" . $e->getMessage());
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
+ if ($share_workerid > 0) { //分享佣金
|
|
|
+ $sqlParam[":sharerMoney"] = $sharerMoney;
|
|
|
+ $sqlParam[":share_workerid"] = $share_workerid;
|
|
|
+ $sqlTemp .= " insert into biz_trader_account ( deleted, `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`, `biz_id`, remark )";
|
|
|
+ $sqlTemp .= " select 9, btr.biz_traderid , :nowtime , 1 , :sharerMoney, 1, 2 , :wkid, concat(:nowtime2,'工单结算时佣金分成支出\n') ";
|
|
|
+ $sqlTemp .= " from biz_todowork tdwk";
|
|
|
+ $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
+ $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
+ $sqlTemp .= " insert into biz_worker_account ( `biz_workerid`, `createtime`,`type`, `money`, `status`, `biz_catalog`,`biz_id`, remark )";
|
|
|
+ $sqlTemp .= " select :share_workerid , :nowtime , 0 , :sharerMoney, 1, 1 , :wkid, concat(:nowtime2,'工单结算时佣金分成收入\n') from dual where 1=1;";
|
|
|
+ }
|
|
|
+ $sqlParam[":workerMoney"] = $workerMoney; //工人工资
|
|
|
+ $sqlParam[":doed_workerid"] = intval($data["biz_workerid"]);
|
|
|
+ $sqlTemp .= " insert into biz_trader_account ( deleted, `biz_traderid`, `createtime`,`type`, `money`, `status`, `biz_catalog`, `biz_id`, remark )";
|
|
|
+ $sqlTemp .= " select 9, btr.biz_traderid , :nowtime , 1 , :workerMoney, 1, 3 , :wkid, concat(:nowtime2,'工单结算时工资支出\n') ";
|
|
|
+ $sqlTemp .= " from biz_todowork tdwk";
|
|
|
+ $sqlTemp .= " left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid ";
|
|
|
+ $sqlTemp .= " where tdwk.id=:wkid;";
|
|
|
+ $sqlTemp .= " insert into biz_worker_account ( `biz_workerid`, `createtime`,`type`, `money`, `status`, `biz_catalog`,`biz_id`, remark )";
|
|
|
+ $sqlTemp .= " select :doed_workerid , :nowtime , 0 , :workerMoney, 1, 0 , :wkid, concat(:nowtime2,'工单结算时工资收入\n') from dual where 1=1;";
|
|
|
+ //报名押金退还
|
|
|
+ $sqlTemp .= " insert into biz_worker_account ( `biz_workerid`, `createtime`,`type`, `money`, `status`, `biz_catalog`,`biz_id`, remark )";
|
|
|
+ $sqlTemp .= " select biz_workerid , :nowtime , 0 , enroll_premoney, 1, 7 , id, concat(:nowtime2,'工单结算时押金退还\n') ";
|
|
|
+ $sqlTemp .= " from biz_todowork where id=:wkid;";
|
|
|
+ //修正工单状态
|
|
|
+ $sqlTemp .= " update biz_todowork set updatetime=:nowtime,`status`=5 ,`final_status` = 1"; //已结算
|
|
|
+ $sqlTemp .= " ,settled_time=:nowtime,settled_mode=:biz_roletype,settled_userid=:biz_userid";
|
|
|
+ $sqlTemp .= " ,remark=concat(:nowtime2,'工单自动结算\n',ifnull(remark,'')) where id=:wkid;";
|
|
|
+ $dataset = pdo_query3($sqlTemp, $sqlParam);
|
|
|
+ myecho($sqlTemp);
|
|
|
+ return true;
|
|
|
+ } catch (Throwable $e) {
|
|
|
+ myecho("超时48小时自动结算处理发生异常：" . $e->getMessage());
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
} catch (Throwable $e) {
|
|
|
- myecho("超时48小时未结算处理发生异常22：" . $e->getMessage());
|
|
|
+ myecho("超时48小时未结算处理发生异常22：" . $e->getMessage());
|
|
|
}
|
|
|
- */
|
|
|
+
|
|
|
//------------------------------------------------
|
|
|
//录用满员处理
|
|
|
myecho("处理内容:录用满员处理");
|
