|
|
@@ -1,28 +1,29 @@
|
|
|
<?php
|
|
|
define('ONLY_ONLY_ONLY', 'WWWSSS');
|
|
|
-require_once "../../../base/service_init.php";
|
|
|
+require_once dirname(__FILE__) . "/../../../base/service_init.php";
|
|
|
service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
/************************start********************************/
|
|
|
define('LOG_CATALOG', "KLY_AUTOTASK");
|
|
|
try {
|
|
|
+ //短信
|
|
|
try {
|
|
|
include_once WEB_PHY_ROOT . "/base/smslib.php";
|
|
|
$pageIndex = 1;
|
|
|
$pageSize = 30;
|
|
|
$start = ($pageIndex - 1) * $pageSize;
|
|
|
$pageData = pdo_fetchall("select bmq.*
|
|
|
- ,wkbu.mobile as wkbu_mobile,wker.true_name as wker_truename,wker.nickname as wker_nickname
|
|
|
- ,btbu.mobile as btbu_mobile,bter.company_name as bter_companyname
|
|
|
- ,btr.title as btr_title
|
|
|
- from biz_message_queue bmq
|
|
|
- left join biz_todowork tdwk on tdwk.id=bmq.biz_id
|
|
|
- left join biz_worker wker on wker.id=tdwk.biz_workerid
|
|
|
- left join base_user wkbu on wkbu.id=wker.base_userid
|
|
|
- left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid
|
|
|
- left join biz_trader bter on bter.id=btr.biz_traderid
|
|
|
- left join base_user btbu on btbu.id=bter.base_userid
|
|
|
- where bmq.`status`=0 and biz_catalog<=2
|
|
|
- limit {$start},{$pageSize}");
|
|
|
+ ,wkbu.mobile as wkbu_mobile,wker.true_name as wker_truename,wker.nickname as wker_nickname
|
|
|
+ ,btbu.mobile as btbu_mobile,bter.company_name as bter_companyname
|
|
|
+ ,btr.title as btr_title
|
|
|
+ from biz_message_queue bmq
|
|
|
+ left join biz_todowork tdwk on tdwk.id=bmq.biz_id
|
|
|
+ left join biz_worker wker on wker.id=tdwk.biz_workerid
|
|
|
+ left join base_user wkbu on wkbu.id=wker.base_userid
|
|
|
+ left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid
|
|
|
+ left join biz_trader bter on bter.id=btr.biz_traderid
|
|
|
+ left join base_user btbu on btbu.id=bter.base_userid
|
|
|
+ where bmq.`status`=0 and biz_catalog<=2
|
|
|
+ limit {$start},{$pageSize}");
|
|
|
foreach ($pageData as $data) {
|
|
|
try {
|
|
|
$smsSign = AliSMS_CODE_TMPSIGN;
|
|
|
@@ -64,33 +65,34 @@ service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
myecho("短信发送发生异常2211111：" . $e->getMessage());
|
|
|
}
|
|
|
//------------------------------------------------
|
|
|
+ //工单超时处理
|
|
|
try {
|
|
|
$pageIndex = 1;
|
|
|
$pageSize = 30;
|
|
|
$start = ($pageIndex - 1) * $pageSize;
|
|
|
$pageData = pdo_fetchall("select tdwk.*
|
|
|
- ,wkbu.mobile as wkbu_mobile,wker.true_name as wker_truename
|
|
|
- ,btbu.mobile as btbu_mobile,bter.company_name as bter_companyname
|
|
|
- ,btr.title as btr_title,btr.settle_catalog,btr.begin_datetime as btr_begin_datetime,btr.finish_datetime as btr_finish_datetime
|
|
|
- ,btr.begin_hour2 as btr_begin_hour2,btr.finish_hour2 as btr_finish_hour2
|
|
|
- from biz_todowork tdwk
|
|
|
- left join biz_worker wker on wker.id=tdwk.biz_workerid
|
|
|
- left join base_user wkbu on wkbu.id=wker.base_userid
|
|
|
- left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid
|
|
|
- left join biz_trader bter on bter.id=btr.biz_traderid
|
|
|
- left join base_user btbu on btbu.id=bter.base_userid
|
|
|
- where (tdwk.`status`=2 and ifnull(tdwk.todo_begindate,0)<=:nowtime111)
|
|
|
- or (tdwk.`status`=3 and (
|
|
|
- (btr.settle_catalog=0 and (
|
|
|
- (ifnull(btr.finish_datetime,0)>ifnull(btr.begin_datetime,0) and ifnull(btr.finish_datetime,0)<=:nowtime222))
|
|
|
- or
|
|
|
- (ifnull(btr.finish_datetime,0)<=ifnull(btr.begin_datetime,0) and ifnull(btr.begin_datetime,0)<=:nowtime222)
|
|
|
- )
|
|
|
- or
|
|
|
- (btr.settle_catalog>0 and ifnull(tdwk.todo_begindate,0)<=:nowtime222)
|
|
|
- )
|
|
|
- )
|
|
|
- limit {$start},{$pageSize}", array(
|
|
|
+ ,wkbu.mobile as wkbu_mobile,wker.true_name as wker_truename
|
|
|
+ ,btbu.mobile as btbu_mobile,bter.company_name as bter_companyname
|
|
|
+ ,btr.title as btr_title,btr.settle_catalog,btr.begin_datetime as btr_begin_datetime,btr.finish_datetime as btr_finish_datetime
|
|
|
+ ,btr.begin_hour2 as btr_begin_hour2,btr.finish_hour2 as btr_finish_hour2
|
|
|
+ from biz_todowork tdwk
|
|
|
+ left join biz_worker wker on wker.id=tdwk.biz_workerid
|
|
|
+ left join base_user wkbu on wkbu.id=wker.base_userid
|
|
|
+ left join biz_trader_recruit btr on btr.id=tdwk.biz_recruitid
|
|
|
+ left join biz_trader bter on bter.id=btr.biz_traderid
|
|
|
+ left join base_user btbu on btbu.id=bter.base_userid
|
|
|
+ where (tdwk.`status`=2 and ifnull(tdwk.todo_begindate,0)<=:nowtime111)
|
|
|
+ or (tdwk.`status`=3 and (
|
|
|
+ (btr.settle_catalog=0 and (
|
|
|
+ (ifnull(btr.finish_datetime,0)>ifnull(btr.begin_datetime,0) and ifnull(btr.finish_datetime,0)<=:nowtime222))
|
|
|
+ or
|
|
|
+ (ifnull(btr.finish_datetime,0)<=ifnull(btr.begin_datetime,0) and ifnull(btr.begin_datetime,0)<=:nowtime222)
|
|
|
+ )
|
|
|
+ or
|
|
|
+ (btr.settle_catalog>0 and ifnull(tdwk.todo_begindate,0)<=:nowtime222)
|
|
|
+ )
|
|
|
+ )
|
|
|
+ limit {$start},{$pageSize}", array(
|
|
|
":nowtime111" => time(), //time()-3600*25,
|
|
|
":nowtime222" => time(), //time()-3600*25,
|
|
|
));
|
|
|
@@ -122,17 +124,18 @@ service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
myecho("工单超时处理发生异常22：" . $e->getMessage());
|
|
|
}
|
|
|
//------------------------------------------------
|
|
|
+ //超时取消报名
|
|
|
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`=1
|
|
|
- and ((tdwk.todo_begindate+btr.begin_hour2)<=:query_nowdate)
|
|
|
- limit {$start},{$pageSize}", array(
|
|
|
-// ":query_nowdate"=>time()+3600*2,
|
|
|
+ from biz_todowork tdwk
|
|
|
+ left join biz_trader_recruit as btr on btr.id=tdwk.biz_recruitid
|
|
|
+ where tdwk.`status`=1
|
|
|
+ and ((tdwk.todo_begindate+btr.begin_hour2)<=:query_nowdate)
|
|
|
+ limit {$start},{$pageSize}", array(
|
|
|
+ // ":query_nowdate"=>time()+3600*2,
|
|
|
":query_nowdate" => time(),
|
|
|
));
|
|
|
foreach ($pageData as $data) {
|
|
|
@@ -163,11 +166,12 @@ service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
myecho("超时到时自动取消报名处理发生异常22：" . $e->getMessage());
|
|
|
}
|
|
|
//------------------------------------------------
|
|
|
+ //超时自动结算
|
|
|
try {
|
|
|
$pageIndex = 1;
|
|
|
$pageSize = 30;
|
|
|
$start = ($pageIndex - 1) * $pageSize;
|
|
|
-// $pageData=pdo_fetchall("select tdwk.*
|
|
|
+ // $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
|
|
|
@@ -192,15 +196,15 @@ service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
// });
|
|
|
// }
|
|
|
$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
|
|
|
- left join biz_trader_recruit as btr on btr.id=tdwk.biz_recruitid
|
|
|
- where tdwk.`status`=4 and tdwk.worked_finishtime<=:query_nowdate
|
|
|
- order by tdwk.id desc
|
|
|
- limit {$start},{$pageSize}", array(
|
|
|
+ ,btr.biz_traderid, btr.feetotal as pay_feetotal
|
|
|
+ ,btr.plat_fetchmoney,btr.sharer_fetchmoney,btr.salary as wker_salary
|
|
|
+ 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
|
|
|
+ order by tdwk.id desc
|
|
|
+ limit {$start},{$pageSize}", array(
|
|
|
":query_nowdate" => time() - 3600 * 48,
|
|
|
-// ":query_nowdate"=>time()-3600*12,
|
|
|
+ // ":query_nowdate"=>time()-3600*12,
|
|
|
// ":query_nowdate"=>time(),
|
|
|
));
|
|
|
foreach ($pageData as $data) {
|
|
|
@@ -285,6 +289,7 @@ service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
myecho("超时48小时未结算处理发生异常22：" . $e->getMessage());
|
|
|
}
|
|
|
//------------------------------------------------
|
|
|
+ //录用满员处理
|
|
|
try {
|
|
|
$pageIndex = 1;
|
|
|
$pageSize = 30;
|
|
|
@@ -327,6 +332,7 @@ service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
$sqlTemp .= " set @placeholder111=:biz_traderid;";
|
|
|
$sqlTemp .= " set @placeholder222=:remain_numtotal;";
|
|
|
$backdata = pdo_query3($sqlTemp, $sqlParam);
|
|
|
+ //$backdata = '123';//测试用
|
|
|
/**
|
|
|
* update wj 20220916
|
|
|
*/
|
|
|
@@ -335,17 +341,19 @@ service_init("KLY", "快来优通用任务 kly-autotask", 30, function () {
|
|
|
$todolistsql = "select id,biz_workerid,biz_recruitid,status from biz_todowork where status=1 and biz_recruitid=:brtid";
|
|
|
$todolist = pdo_fetchall($todolistsql, [':brtid' => $brtid]);
|
|
|
$reason = "招满自动返还";
|
|
|
- $sqlParams[":wkstatus"] = -1; //0-待提交；1-已报名待审核；2-已审核；-1-报名被驳回；3-工资/佣金已全部结算；-2-取消报名；-3-被违约 -4-被动取消'
|
|
|
- $sqlParams[":wkremark"] = "[" . date("Y-m-d H:i:s", time()) . "] 报名被拒绝（退还押金）：$reason \n";
|
|
|
+ $sqlParam2[":nowtime"] = time();
|
|
|
+ $sqlParam2[":wkstatus"] = -1; //0-待提交；1-已报名待审核；2-已审核；-1-报名被驳回；3-工资/佣金已全部结算；-2-取消报名；-3-被违约 -4-被动取消'
|
|
|
+ $sqlParam2[":wkremark"] = "[" . date("Y-m-d H:i:s", time()) . "] 报名被拒绝（退还押金）：$reason \n";
|
|
|
//返还押金对冲
|
|
|
foreach ($todolist as $key => $value) {
|
|
|
- $workid = $value['biz_workerid'];
|
|
|
- $sqlTemp .= " insert into biz_worker_account ( `biz_workerid`, `createtime`,`type`, `money`, `status`, `biz_catalog`,`biz_id`, remark )";
|
|
|
+ $workid = $value['id'];
|
|
|
+ $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, :wkremark ";
|
|
|
$sqlTemp .= " from biz_todowork where id=" . intval($workid) . ";";
|
|
|
$sqlTemp .= " update biz_todowork set updatetime=:nowtime,`status`=:wkstatus, remark=concat(:wkremark,ifnull(remark,'')) ";
|
|
|
$sqlTemp .= " where id=" . intval($workid) . ";";
|
|
|
- $dataset = pdo_query3($sqlTemp, $sqlParams);
|
|
|
+ $dataset = pdo_query3($sqlTemp, $sqlParam2);
|
|
|
+ exit;
|
|
|
}
|
|
|
return $backdata;
|
|
|
});
|
