|
...
|
...
|
@@ -81,7 +81,7 @@ class SyncToEsCmd { |
|
|
|
pcntl_signal_dispatch();
|
|
|
|
|
|
|
|
// 是否超过来最大执行时间
|
|
|
|
if(time()-43200 > $this->startTime){
|
|
|
|
if(time()-3600 > $this->startTime){
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
...
|
...
|
@@ -434,7 +434,7 @@ class SyncToEsCmd { |
|
|
|
public function getPostid($email_id,$udate){
|
|
|
|
|
|
|
|
//每60秒验证一次
|
|
|
|
if(redis()->add('fob_bind_mail_times_check:'.$email_id,1,60)){
|
|
|
|
if(redis()->add('fob_bind_mail_times_check:'.$email_id,1,120)){
|
|
|
|
$lastpostid = $this->fob_db->throw()->value("select `post_id` from `e_mail_binds_log` where `source` = 2 and `email_id` = '{$email_id}' order by `id` desc limit 1");
|
|
|
|
// 如果找不到了
|
|
|
|
$thelast = $this->fob_db->throw()->first("select `id`,`post_id`,`source`,`email`,`email_id` from `e_mail_binds` where `source` = 2 and `email_id` = '{$email_id}' and `deleted_at` is null order by `id` desc limit 1");
|
...
|
...
|
|