setName('addinvalidlog') ->setDescription('addinvalidlog'); } protected function execute(Input $input, Output $output) { $root_id = 1700; $orgids = orgSubIds($root_id); $list = CustomerVisitLog::where([['org_id','in',$orgids],['state','in',CustomerVisitLog::changeState('无效','chaos')]])->column('id,state,customer_id,employee_id,customer_employee_id,customer_org_id,org_id'); foreach($list as $key=>$val){ $cus = Customer::where('id',$val['customer_id'])->field('addtime,org_id,source_id')->find(); if(empty($cus)) continue; $org_id = !empty($val['customer_org_id']) ? $val['customer_org_id'] : $val['org_id']; $org_id = $org_id ? $org_id : $cus['org_id']; $add[]=[ 'customer_id' => $val['customer_id'], 'employee_id' => !empty($val['customer_employee_id']) ? $val['customer_employee_id'] : $val['employee_id'], 'org_id' => $org_id, 'root_id' => $root_id, 'cus_addtime' => $cus['addtime'], 'visitlog_id' => $val['id'], 'assigned_personnel' => '', 'source_id' => !empty($cus['source_id']) ? $cus['source_id'] : 0 ]; } $addlog = new CustomerInvalidLog; $addlog->saveAll($add); $output->writeln("添加无效记录处理完成"); } } ?>