drb/app/Jobs/ProcessDataJob.php

<?php

namespace App\Jobs;

use App\Model\DDEmployee;
use App\Model\Record;
use App\Service\U8DatabaseServerService;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Symfony\Component\Console\Output\ConsoleOutput;
use Symfony\Component\Console\Output\OutputInterface;

class ProcessDataJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $data;
    public $timeout = 30;

    public function __construct($data)
    {
        //record表
        $this->data = $data;
    }

    public function handle()
    {
        try {
            list($bool, $msg) = $this->syncApprovedRecords($this->data);
            if(! $bool) $this->finalDo($msg, $this->data);
        } catch (\Throwable $e) {
            $this->finalDo("异常：" . $e->getMessage());
            $this->delete();
        }
    }

    private function finalDo($msg, $record){
        Record::where('id', $record['id'])
            ->update(['result' => $msg]);
    }

    private function syncApprovedRecords($record)
    {
        try {
            $service = new U8DatabaseServerService(['zt_database' => $record['database']]);
            if ($service->error) return [false, $service->error];

            $time = date("Y-m-d H:i:s");
            $time1 = date("Y-m-d 00:00:00");

            if($record['del_time'] == 2){
                $type = $record['type'];
                $order_number = $record['order_number'];

                $system_name = "system";
                $name = DDEmployee::where('userid', $record['userid'])->value('name');
                if(! empty($name)) $system_name = $name;
                if($type == 1){
                    $service->db->table("PO_Pomain")
                        ->where("cPOID", $order_number)
                        ->update([
                            "cVerifier" => $system_name,
                            "iverifystateex"   => 1,
                            "cState" => 1,
                            "cAuditTime" => $time . ".000",
                            "cAuditDate" => $time1 . ".000",
                        ]);
                }elseif($type == 2){
                    $service->db->table("PU_AppVouch")
                        ->where("cCode", $order_number)
                        ->update([
                            "cVerifier" => $system_name,
                            "cAuditTime" => $time . ".000",
                            "cAuditDate" => $time1 . ".000",
                        ]);
                }else{
                    $service->db->table("AP_ApplyPayVouch")
                        ->where("cVouchID", $order_number)
                        ->update([
                            "cCheckMan" => $system_name,
                            "dverifysystime" => $time . ".000",
                            "dverifydate" => $time1 . ".000",
                        ]);
                }
            }

            // 更新本地数据
            Record::where("id", $record['id'])->update(['del_time' => 3]);

            $service->close();
        } catch (\Throwable $e) {
            return [false, $e->getMessage()];
        }

        return [true, ''];
    }

    protected function echoMessage(OutputInterface $output)
    {
        //输出消息
        $output->writeln(json_encode($this->data));
    }
}