mes-sdai-server-api/application/job/InsertDataJob.php

<?php

namespace app\job;

use think\Db;
use think\Cache;
use think\cache\driver\Redis;

class InsertDataJob
{
    protected $data;

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

    public function handle()
    {
        $options = [
            'host'       => '127.0.0.1',
            'port'       => 6379,
            'password'   => '',
            'select'     => 15,
            'timeout'    => 0,
            'expire'     => 0,
            'persistent' => false,
            'prefix'     => '',
        ];
        $redis = new Redis($options);
        $taskIdentifier = md5(json_encode('date'));
        $handData = [];
        foreach ($this->data as $key=>$value){
            $handData[$key]['sczl_gdbh'] = $value['sczl_gdbh'];
            $handData[$key]['sczl_yjno'] = $value['sczl_yjno'];
            $handData[$key]['sczl_gxh'] = $value['sczl_gxh'];
            $handData[$key]['sczl_type'] = $value['sczl_type'];
            $handData[$key]['sczl_rq'] = $value['sczl_rq'];
            $handData[$key]['sczl_jtbh'] = $value['sczl_jtbh'];
            $handData[$key]['班组车头产量'] = $value['班组车头产量'];
            $handData[$key]['工价系数'] = $value['工价系数'];
            $handData[$key]['工序难度系数'] = $value['工序难度系数'];
            $handData[$key]['装版工时'] = $value['装版工时'];
            $handData[$key]['保养工时'] = $value['保养工时'];
            $handData[$key]['打样工时'] = $value['打样工时'];
            $handData[$key]['异常停机工时'] = $value['异常停机工时'];
            $handData[$key]['车头产量占用机时'] = $value['车头产量占用机时'];
            $handData[$key]['日定额'] = $value['日定额'];
            $handData[$key]['千件工价'] = $value['千件工价'];
            $handData[$key]['补产标准'] = $value['补产标准'];
            $handData[$key]['班组换算产量'] = $value['班组换算产量'];
            $handData[$key]['计时补差额工资'] = $value['计时补差额工资'];
            $handData[$key]['bh'] = $value['bh'];
            $handData[$key]['xm'] = $value['xm'];
            $handData[$key]['Rate'] = $value['Rate'];
            $handData[$key]['sczl_ms'] = $value['sczl_ms'];
            $handData[$key]['工时占比'] = $value['工时占比'];
            $handData[$key]['达标定额'] = $value['达标定额'];
            $handData[$key]['个人计件工资'] = $value['个人计件工资'];
            $handData[$key]['个人加班工资'] = $value['个人加班工资'];
            $handData[$key]['UniqID'] = $value['UniqID'];
            $handData[$key]['sys_ny'] = $value['sys_ny'];
            $handData[$key]['sys_rq'] = $value['sys_rq'];
            $handData[$key]['sys_id'] = $value['sys_id'];
            $handData[$key]['法定天数'] = $value['法定天数'];
        }
        $sql =Db::name('绩效工资汇总')->fetchSql(true)->insertAll($handData);
        $res = Db::query($sql);
        if ($res !== false){
            // 获取队列的键名
            $queueKey = 'default';
            // 删除队列
            Cache::store('redis')->handler()->del($queueKey);
            $redis->rm($taskIdentifier);
        }
    }
}