youfeng

app/Jobs/ProcessDataJob.php

@@ -73,23 +73,6 @@ class ProcessDataJob implements ShouldQueue
         ]);
     }
 
-    public function failed(\Throwable $exception)
-    {
-        Log::error('ProcessDataJob 失败', [
-            'error' => $exception->getMessage(),
-            'data' => $this->data,
-        ]);
-
-        // 保底清理
-        try {
-            $service = new \App\Service\TPlusServerService();
-            $service->delTableKey($this->type);
-        } catch (\Throwable $e) {
-            Log::warning('清理 Redis Key 失败：' . $e->getMessage());
-        }
-    }
-
-
     protected function echoMessage(OutputInterface $output)
     {
         //输出消息

app/Service/TPlusServerService.php

@@ -817,6 +817,7 @@ class TPlusServerService extends Service
         $data['start_time'] = strtotime(date("Y-m-01",$data['start_timeStamp']));
         $data['end_time'] = strtotime(date("Y-m-01"),$data['end_timeStamp']);
         $data['operation_time'] = time();
+        $data['type'] = 5;
 
         list($status,$msg) = $this->limitingSendRequest($this->table_2);
         if(! $status) return [false, '业务员工资同步正在后台运行,请稍后'];
@@ -1047,6 +1048,7 @@ class TPlusServerService extends Service
         $data['start_time'] = $start;
         $data['end_time'] = $end;
         $data['operation_time'] = time();
+        $data['type'] = 6;
 
 //        list($status, $msg) = $this->synFreightFeeFromMine($data, $user);dd($status, $msg);
         list($status,$msg) = $this->limitingSendRequest($this->table_3);