xky/app/Jobs/ProcessDataJob.php

<?php

namespace App\Jobs;

use App\Model\DDEmployee;
use App\Model\Record;
use App\Model\U8State;
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 {
            $LoginType = $record['login_type'];
            $database = $record['database'];

            $service = new U8DatabaseServerService(['zt_database' => $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'])->where('login_type', $LoginType)->value('name');
                if(! empty($name)) $system_name = $name;

                if($type == Record::type_one){
                    $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 == Record::type_two){
                    $service->db->table("PU_AppVouch")
                        ->where("cCode", $order_number)
                        ->update([
                            "cVerifier" => $system_name,
                            "cAuditTime" => $time . ".000",
                            "cAuditDate" => $time1 . ".000",
                        ]);
                }elseif($type == Record::type_three){
                    $service->db->table("RdRecord01")
                        ->where("cCode", $order_number)
                        ->update([
                            "cHandler" => $system_name,
                            "dnverifytime" => $time . ".000",
                            "dVeriDate" => $time1 . ".000",
                        ]);
                }elseif($type == Record::type_four){

                }elseif($type == Record::type_five){

                }

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

                // 更新状态为 通过状态
                U8State::updateOrCreate(
                    ['order_number' => $record['order_number'], 'login_type' => $record['login_type'], 'type' => $record['type']],
                    ['state' => U8State::state_one]
                );
            }

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

        return [true, ''];
    }

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