1
0

UpdateDataStatistics.php 3.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798
  1. <?php
  2. namespace app\command;
  3. use think\console\Command;
  4. use think\console\input\Argument;
  5. use think\console\Input;
  6. use think\console\Output;
  7. use app\model\Talkskill;
  8. use app\model\TrainClass;
  9. use app\model\Employee;
  10. use app\model\Org;
  11. use app\model\MaterialCase;
  12. use app\model\CustomerClue;
  13. use app\model\TalkskillComment;
  14. use app\model\TrainDoneLog;
  15. use app\model\Company;
  16. use app\model\DataStatistics;
  17. use app\model\Building;
  18. use app\model\VrGroup;
  19. use app\model\Construction;
  20. use app\model\TalkskillChosen;
  21. use app\model\TalkskillSuccess;
  22. //数据统计管理
  23. class UpdateDataStatistics extends Command
  24. {
  25. protected function configure()
  26. {
  27. $this->setName('update_data_statistics')
  28. ->addArgument('root_id', Argument::OPTIONAL, "root_id")
  29. ->setDescription('update_data_statistics');
  30. }
  31. protected function execute(Input $input, Output $output)
  32. {
  33. //店面id
  34. $root_id = $input->getArgument('root_id');
  35. if ($root_id=='all') {
  36. $root_ids = Company::where('1=1')->column('root_id');
  37. foreach ($root_ids as $v) {
  38. $this->update($v);
  39. }
  40. $res = 'ok';
  41. }elseif($root_id){
  42. $res = $this->update($root_id);
  43. $res = !$res ? '参数错误' : 'ok';
  44. }else{
  45. $res = '无效参数';
  46. }
  47. $output->writeln($res);
  48. }
  49. private function update($root_id){
  50. //
  51. $company = Company::where('root_id',$root_id)->findOrEmpty();
  52. if($company->isEmpty()) return false;
  53. $where[] = ['root_id','=',$root_id];
  54. $info = DataStatistics::where($where)->findOrEmpty();
  55. if($info->isEmpty()) DataStatistics::insert(['root_id'=>$root_id]);
  56. $query = ['root_id','=',$root_id];
  57. //员工数量
  58. $data['emp_count'] = Employee::where([$query,['state','=','在职'],['uid','>',0]])->count();
  59. //员工管理员数量
  60. $data['emp_manage_count'] = Employee::where([$query,['state','=','在职'],['uid','>',0],['is_manager','=',1]])->count();
  61. //部门数量
  62. $data['org_count'] = Org::where([['path','like',$root_id.'-%']])->count();
  63. //运营数量
  64. $data['motion_count'] = Employee::where([$query,['state','=','在职'],['grant_id','>',0]])->count();
  65. //店面开通日期
  66. $data['root_date'] = strtotime($company->addtime);
  67. //案例数量
  68. $data['case_count'] = MaterialCase::where([$query,['del','=',0]])->count();
  69. //课程数量
  70. $data['course_count'] = TrainClass::where([$query,['del','=',0]])->count();
  71. //楼盘数量
  72. $data['building_count'] = Building::where([$query,['del','=',0]])->count();
  73. //话术数量
  74. $talk1 = TalkskillChosen::where([$query])->count();
  75. $talk2 = TalkskillSuccess::where([$query])->count();
  76. $talk3 = Talkskill::where([$query,['approve','=',1]])->count();
  77. $data['talkskill_count'] = $talk1 + $talk2 + $talk3;
  78. //Vr作品数量
  79. $group = VrGroup::where([$query,['status','=',2]])->column('size');
  80. $data['group_count'] = count($group);
  81. $data['use_count'] = $group ? array_sum($group) : 0;
  82. //设计师数量
  83. $org_ids = Org::where([['path','like',$root_id.'-%'],['org_type','=',2]])->column('id');
  84. $data['designer_count'] = Employee::where([$query,['state','=','在职'],['uid','>',0],['org_id','in',$org_ids]])->count();
  85. //在施工地数量
  86. $data['plant_count'] = Construction::where([$query,['status','=',1]])->count();
  87. DataStatistics::where('root_id',$root_id)->update($data);
  88. return true;
  89. }
  90. }