switch/application/job/FlowLog.php

<?php


namespace app\job;
use app\common\model\FlowLogs;
use think\queue\job;


class FlowLog
{
    public function fire(Job $job, $data) {

        list($ip, $port) = explode(':', $data['client_addr']);

        FlowLogs::create([
            'username'  =>  $data['username'],
            'ip'        =>  $ip,
            'bytes'     =>  $data['bytes'],
            'created_at'    => $data['time']
        ]);
    }
}