131 lines
5.7 KiB
PHP
131 lines
5.7 KiB
PHP
<?php
|
||
|
||
namespace app\job;
|
||
|
||
use app\common\logic\finance\ShareProfit;
|
||
use app\common\model\task\Task;
|
||
use Symfony\Component\HttpClient\HttpClient;
|
||
use think\queue\Job;
|
||
use think\facade\Log;
|
||
use app\common\model\Company;
|
||
use app\common\model\informationg\UserInformationg;
|
||
|
||
/**
|
||
* 任务结算执行的具体逻辑
|
||
*/
|
||
class TaskInformationJob
|
||
{
|
||
|
||
public function fire(Job $job, $data)
|
||
{
|
||
// if ($job->attempts() > 1) {
|
||
// //通过这个方法可以检查这个任务已经重试了几次了
|
||
// }
|
||
$company = Company::where('id', $data['company_id'])->field('id,deposit,company_money,user_id,day_count,company_type,province,city,area,street,village,brigade')->find(); // 可能要判断预存金是否满足
|
||
$arr['status'] = 0;
|
||
//信息更新
|
||
if ($data['template_info']['type'] == 31) {
|
||
if ($data['template_info']['information_count'] < $data['template_info']['information_day_count']) {
|
||
Log::info('任务结算失败，信息更新未达到要求：' . json_encode($data));
|
||
return false;
|
||
}
|
||
$name = '小组队长';
|
||
} elseif
|
||
//交易金额
|
||
($data['template_info']['type'] == 33) {
|
||
$yesterday = date('Y-m-d', strtotime('-1 day', time()));
|
||
$parmas = [
|
||
"start_date" => $yesterday,
|
||
"end_date" => $yesterday
|
||
];
|
||
switch ($company['company_type']) {
|
||
case 18:
|
||
$parmas['brigade_id'] = $company['brigade'];
|
||
$parmas['village_code'] = $company['village'];
|
||
$parmas['street_code'] = $company['street'];
|
||
$parmas['district_code'] = $company['area'];
|
||
$parmas['city_code'] = $company['city'];
|
||
break;
|
||
case 17:
|
||
$parmas['village_code'] = $company['village'];
|
||
$parmas['street_code'] = $company['street'];
|
||
$parmas['district_code'] = $company['area'];
|
||
$parmas['city_code'] = $company['city'];
|
||
break;
|
||
case 16:
|
||
$parmas['street_code'] = $company['street'];
|
||
$parmas['district_code'] = $company['area'];
|
||
$parmas['city_code'] = $company['city'];
|
||
break;
|
||
case 15:
|
||
$parmas['district_code'] = $company['area'];
|
||
$parmas['city_code'] = $company['city'];
|
||
break;
|
||
case 14:
|
||
$parmas['city_code'] = $company['city'];
|
||
break;
|
||
default:
|
||
Log::error('任务结算失败，公司类型错误：' . $company['company_type']);
|
||
return false;
|
||
}
|
||
try {
|
||
$res = HttpClient::create()->request('GET', 'https://crmeb-test.shop.lihaink.cn/api/order/statistics', [
|
||
'query' => $parmas,
|
||
]);
|
||
$json = json_decode($res->getContent(), true);
|
||
$arr['total_price'] = 0;
|
||
$name = '片区交易';
|
||
if ($json['status'] == 200) {
|
||
$arr['total_price'] = $json['data']['total_price'];
|
||
//基础金额*(每日基户数*天数)//且户数小于公司总户数
|
||
$user_count = UserInformationg::where('company_id', $data['company_id'])->count();
|
||
$user_count_two = 5 * $company['day_count'];
|
||
if ($user_count_two > $user_count) {
|
||
$user_count_money = 58 * $user_count;
|
||
} else {
|
||
$user_count_money = 58 * $user_count_two;
|
||
}
|
||
if ($json['data']['total_price'] > $user_count_money) {
|
||
$arr['status'] = 1;
|
||
$name = '片区交易';
|
||
}
|
||
} else {
|
||
Log::error('获取订单金额失败：' . $json . '参数：' . json_encode($parmas));
|
||
}
|
||
} catch (\Exception $e) {
|
||
Log::error('获取订单金额失败：' . $e->getMessage() . '参数：' . json_encode($parmas));
|
||
return false;
|
||
}
|
||
} else {
|
||
$task_count = Task::where('id', $data['task_id'])->field('director_uid')->where('status', 3)->with('director_info')->find();
|
||
if (empty($task_count)) {
|
||
Log::error('列105 任务结算失败，task_count为空：' . json_encode($data));
|
||
return false;
|
||
}
|
||
$name = $task_count['director_info']['nickname'];
|
||
$arr['status'] = 1;
|
||
}
|
||
|
||
try {
|
||
$arr['money'] = $data['template_info']['money'];
|
||
$arr['company_id'] = $data['scheduling']['company_id'];
|
||
$arr['msg'] = '来自任务【' . $data['template_info']['title'] . '】,完成人：' . $name . ',的任务结算';
|
||
$arr['proportion_one'] = $data['template_info']['proportion_one'];
|
||
$arr['proportion_two'] = $data['template_info']['proportion_two'];
|
||
$arr['sn'] = $data['sn'];
|
||
$arr['id'] = $data['id'];
|
||
} catch (\Exception $e) {
|
||
Log::error('列122 任务结算失败：' . $e->getMessage() . json_encode($data));
|
||
return false;
|
||
}
|
||
(new ShareProfit())->first($arr, $company);
|
||
//如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法
|
||
$job->delete();
|
||
}
|
||
public function failed($data)
|
||
{
|
||
Log::error('任务结算失败' . $data);
|
||
// ...任务达到最大重试次数后，失败了
|
||
}
|
||
}
|