TaskSystem/app/api/controller/CeshiController.php
2023-08-16 00:14:09 +08:00

67 lines
2.6 KiB
PHP
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

<?php
namespace app\api\controller;
use app\common\logic\finance\ShareProfit;
use app\common\logic\task\TaskLogic;
use app\common\model\Company;
use app\common\model\task\Task;
use app\common\model\task_scheduling_plan\TaskSchedulingPlan;
use think\facade\Log;
use app\job\TaskInformationJob;
class CeshiController extends BaseApiController
{
public array $notNeedLogin = ['index','ceshi'];
public function index()
{
$all=TaskSchedulingPlan::whereDay('start_time')->where('is_pay',0)->with(['template_info','scheduling'])->select()->toArray();
// halt($all);
foreach($all as $k=>$v){
queue(TaskInformationJob::class,$v);
}
halt(1);
//,'yesterday'
$all=TaskSchedulingPlan::whereDay('end_time')->where('is_pay',0)->with(['template_info','scheduling'])->select();
foreach($all as $k=>$data){
$task_id=explode(',',$data['task_id']);
$task_count=Task::where('id','in',$task_id)->field('director_uid')->with('director_info')->select();
if(empty($task_count)){
Log::error('任务结算失败任务id'.$task_id);
continue;
}
if(count($task_count)==count($task_id)){
$name_arr=[];
foreach ($task_count as $key => $value) {
$name_arr[$key]=$value['director_info']['nickname'];
}
$name=implode(',',$name_arr);
$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'];
(new ShareProfit())->first($arr);
}
}
halt(2);
}
public function ceshi(){
// $time=strtotime(date('Y-m-d',strtotime('+1 day')));
$time=strtotime(date('Y-m-d'));
$tiem_end=$time+86399;
$all=TaskSchedulingPlan::where('start_time','between',[$time,$tiem_end])->where('is_execute',0)->with(['template_info','scheduling','company'])->select()->toArray();
$company_id=0;
foreach($all as $k=>$v){
TaskLogic::CronAdd($v);
$company_id=$v['company_id'];
}
if($company_id!=0){
Company::where('id',$company_id)->inc('day_count')->update();
}
halt(TaskLogic::getError());
}
}