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

<?php
//
//namespace app\job;
//
////use think\Db;
////use think\Cache;
////use think\cache\driver\Redis;
//
//use think\Db;
//use think\Cache;
//use think\Log;
//use think\cache\driver\Redis;
//
//class InsertDataJob
//{
////    protected $data;
////
////    public function __construct($data)
////    {
////        $this->data = $data;
////    }
//
//    protected $data;
//    protected $taskData;
//
//    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 = [];
//        $options = [
//            'host'       => '127.0.0.1',
//            'port'       => 6379,
//            'password'   => '123456',
//            'select'     => 15,
//            'timeout'    => 0,
//            'expire'     => 0,
//            'persistent' => false,
//            'prefix'     => '',
//        ];
//        $redis = new Redis($options);
//
//        // 从任务数据中获取月份
//        $date = $this->taskData['date'] ?? '';
//        $taskId = $this->taskData['task_id'] ?? 0;
//        $taskIdentifier = md5('salary_calculation_' . $date);
//
//        try {
//            // 更新任务状态为执行中
//            if ($taskId) {
//                Db::name('queue_tasks')
//                    ->where('id', $taskId)
//                    ->update([
//                        'status' => 'processing',
//                        'start_time' => date('Y-m-d H:i:s'),
//                        'update_time' => date('Y-m-d H:i:s')
//                    ]);
//            }
//
//            // 原有的数据处理逻辑
//            $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);
////        }
//            if ($res !== false){
//                // 更新任务状态为成功
//                if ($taskId) {
//                    Db::name('queue_tasks')
//                        ->where('id', $taskId)
//                        ->update([
//                            'status' => 'success',
//                            'end_time' => date('Y-m-d H:i:s'),
//                            'result' => json_encode(['success' => true, 'message' => '工资计算完成']),
//                            'update_time' => date('Y-m-d H:i:s')
//                        ]);
//                }
//
//                // 清理缓存
//                $queueKey = 'salary_calculation';
//                Cache::store('redis')->handler()->del($queueKey);
//                $redis->rm($taskIdentifier);
//
//                Log::info('工资计算任务执行成功', ['date' => $date]);
//            } else {
//                throw new \Exception('数据插入失败');
//            }
//
//        } catch (\Exception $e) {
//            Log::error('工资计算任务执行失败: ' . $e->getMessage());
//
//            // 更新任务状态为失败
//            if ($taskId) {
//                Db::name('queue_tasks')
//                    ->where('id', $taskId)
//                    ->update([
//                        'status' => 'failed',
//                        'end_time' => date('Y-m-d H:i:s'),
//                        'error' => $e->getMessage(),
//                        'update_time' => date('Y-m-d H:i:s')
//                    ]);
//            }
//
//            $redis->rm($taskIdentifier);
//        }
//    }
//}


namespace app\job;

use think\Db;
use think\Log;
use app\service\SalaryCalculationService;

/**
 * 工资计算队列任务
 */
class InsertDataJob
{
    /**
     * 任务处理方法
     * @param \think\queue\Job $job 任务对象
     * @param mixed $data 任务数据
     */
    public function fire($job, $data)
    {
        // 确保数据是数组
        if (!is_array($data)) {
            $job->delete();
            return;
        }

        try {
            $taskId = isset($data['task_id']) ? (int)$data['task_id'] : 0;

            // 更新任务状态为执行中
            if ($taskId > 0) {
                $this->updateTaskStatus($taskId, 'processing', [
                    'start_time' => date('Y-m-d H:i:s'),
                    'retry_count' => $job->attempts()
                ]);
            }

            // 调用工资计算服务
            $service = new SalaryCalculationService();
            $result = $service->calculateSalary($data);

            if ($result['success']) {
                // 任务成功
                $job->delete();
                if ($taskId > 0) {
                    $this->updateTaskStatus($taskId, 'success', [
                        'end_time' => date('Y-m-d H:i:s'),
                        'result' => json_encode($result, JSON_UNESCAPED_UNICODE)
                    ]);
                }

            } else {
                // 任务失败
                if ($job->attempts() >= 3) {
                    $job->delete();
                    if ($taskId > 0) {
                        $this->updateTaskStatus($taskId, 'failed', [
                            'end_time' => date('Y-m-d H:i:s'),
                            'error' => $result['message'],
                            'retry_count' => $job->attempts()
                        ]);
                    }

                } else {
                    $delay = $this->getRetryDelay($job->attempts());
                    $job->release($delay);

                }
            }

        } catch (\Exception $e) {


            $taskId = isset($data['task_id']) ? (int)$data['task_id'] : 0;

            if ($job->attempts() >= 3) {
                $job->delete();
                if ($taskId > 0) {
                    $this->updateTaskStatus($taskId, 'error', [
                        'end_time' => date('Y-m-d H:i:s'),
                        'error' => $e->getMessage(),
                        'retry_count' => $job->attempts()
                    ]);
                }
            } else {
                $job->release(60); // 延迟60秒重试
            }
        }
    }

    /**
     * 更新任务状态
     */
    protected function updateTaskStatus(int $taskId, string $status, array $data = []): void
    {
        try {
            $updateData = array_merge(['status' => $status, 'update_time' => date('Y-m-d H:i:s')], $data);

            Db::name('queue_tasks')
                ->where('id', $taskId)
                ->update($updateData);

        } catch (\Exception $e) {
            Log::error('更新任务状态失败: ' . $e->getMessage());
        }
    }

    /**
     * 获取重试延迟时间
     */
    protected function getRetryDelay(int $attempts): int
    {
        $delays = [10, 30, 60]; // 10秒, 30秒, 1分钟
        return $delays[min($attempts - 1, count($delays) - 1)] ?? 60;
    }
}