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);
        // }
    }
}