laravel-liberu /
genealogy
| 1 | <?php |
||
| 2 | |||
| 3 | namespace App\Jobs; |
||
| 4 | |||
| 5 | use App\Models\Dna; |
||
| 6 | use App\Models\DnaMatching as DM; |
||
| 7 | use App\Models\User; |
||
| 8 | use Illuminate\Bus\Queueable; |
||
| 9 | use Illuminate\Contracts\Queue\ShouldQueue; |
||
| 10 | use Illuminate\Foundation\Bus\Dispatchable; |
||
| 11 | use Illuminate\Queue\InteractsWithQueue; |
||
| 12 | use Illuminate\Queue\SerializesModels; |
||
| 13 | use Illuminate\Support\Facades\Log; |
||
| 14 | |||
| 15 | class DnaMatching implements ShouldQueue |
||
| 16 | { |
||
| 17 | use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; |
||
|
0 ignored issues
–
show
introduced
by
Loading history...
|
|||
| 18 | |||
| 19 | public int $timeout = 0; |
||
| 20 | public int $tries = 1; |
||
| 21 | |||
| 22 | /** |
||
| 23 | * Create a new job instance. |
||
| 24 | * |
||
| 25 | * @return void |
||
| 26 | */ |
||
| 27 | public function __construct(protected $current_user, protected $var_name, protected $file_name) |
||
| 28 | { |
||
| 29 | } |
||
| 30 | |||
| 31 | /** |
||
| 32 | * Execute the job. |
||
| 33 | * |
||
| 34 | * @return void |
||
| 35 | */ |
||
| 36 | public function handle() |
||
| 37 | { |
||
| 38 | $user = $this->current_user; |
||
| 39 | $dnas = Dna::where('variable_name', '!=', $this->var_name)->get(); |
||
| 40 | $mpath = app_path(); |
||
| 41 | |||
| 42 | foreach ($dnas as $dna) { |
||
| 43 | Log::info(json_encode($dna, JSON_THROW_ON_ERROR)); |
||
| 44 | Log::info(storage_path('/app/public/dna/output/shared_dna_'.$this->var_name.'_'.$dna->variable_name.'_'.$this->file_name.'_'.$dna->file_name)); |
||
| 45 | // system('/usr/bin/python3 /home/genealogia/public_html/dna.py ' . $this->var_name . ' ' . $dna->variable_name . ' ' . '/home/genealogia/public_html/storage/app/dna/'. $this->file_name . ' ' . '/home/genealogia/public_html/storage/app/dna/'. $dna->file_name); |
||
| 46 | // chdir('/home/familytree365/domains/api.familytree365.com/genealogy/app'); |
||
| 47 | chdir($mpath); |
||
| 48 | // exec('python dna.py '.$this->var_name.' '.$dna->variable_name.' '.$this->file_name.' '.$dna->file_name, $dna_output); |
||
| 49 | $result = exec('python3 dna.py '.$this->var_name.' '.$dna->variable_name.' '.$this->file_name.' '.$dna->file_name); |
||
| 50 | // $resultData = json_decode($result, true, 512, JSON_THROW_ON_ERROR); |
||
| 51 | $resultData = json_decode($result, true, 512, JSON_THROW_ON_ERROR); |
||
| 52 | // chmod(storage_path('/app/public/dna/output/shared_dna_'.$this->var_name.'_'.$dna->variable_name.'_'.$this->file_name.'_'.$dna->file_name), 0777); |
||
| 53 | |||
| 54 | $dm = new DM(); |
||
| 55 | $dm->user_id = $user->id; |
||
| 56 | $dm->match_id = $dna->user_id; |
||
| 57 | $match_name_user = User::with('person')->find($dna->user_id); |
||
| 58 | $match_name = $match_name_user->person->name; |
||
|
0 ignored issues
–
show
|
|||
| 59 | $dm->match_name = $match_name; |
||
| 60 | // $dm->image = 'shared_dna_'.$this->var_name.'_'.$dna->variable_name.'.png'; |
||
| 61 | // $dm->image = 'shared_dna_'.$this->var_name.'_'.$dna->variable_name.'_0p75cM_1100snps_GRCh37_HapMap2.png'; |
||
| 62 | $dm->image = env('APP_URL').'/storage/dna/output/shared_dna_'.$this->var_name.'_'. |
||
| 63 | $dna->variable_name.'_0p75cM_1100snps_GRCh37_HapMap2.png'; |
||
| 64 | // $dm->file1 = 'discordant_snps_'.$this->var_name.'_'.$dna->variable_name.'_GRCh37.csv'; |
||
| 65 | $dm->file1 = 'discordant_snps_'.$this->var_name.'_'.$dna->variable_name.'_GRCh37.csv'; |
||
| 66 | // $dm->file2 = 'shared_dna_one_chrom_'.$this->var_name.'_'.$dna->variable_name.'_GRCh37.csv'; |
||
| 67 | $dm->file2 = 'shared_dna_one_chrom_'.$this->var_name.'_'.$dna->variable_name.'_0p75cM_1100snps_GRCh37_HapMap2.csv'; |
||
| 68 | |||
| 69 | $dm->total_shared_cm = round($resultData['total_cms'], 2); |
||
| 70 | $dm->largest_cm_segment = round($resultData['largest_cm'], 2); |
||
| 71 | |||
| 72 | $dm->save(); |
||
| 73 | if ($dna->user_id !== $user->id) { |
||
| 74 | $dm2 = new DM(); |
||
| 75 | $dm2->user_id = $dna->user_id; |
||
| 76 | $dm2->match_id = $user->id; |
||
| 77 | $match_name_user = User::with('person')->find($dna->user_id); |
||
| 78 | $dm2->match_name = $match_name_user->person->name; |
||
| 79 | // $dm->image = 'shared_dna_'.$this->var_name.'_'.$dna->variable_name.'.png'; |
||
| 80 | // $dm->image = 'shared_dna_'.$this->var_name.'_'.$dna->variable_name.'_0p75cM_1100snps_GRCh37_HapMap2.png'; |
||
| 81 | $dm2->image = env('APP_URL').'/storage/dna/output/shared_dna_'.$this->var_name.'_'.$dna->variable_name.'_0p75cM_1100snps_GRCh37_HapMap2.png'; |
||
| 82 | // $dm->file1 = 'discordant_snps_'.$this->var_name.'_'.$dna->variable_name.'_GRCh37.csv'; |
||
| 83 | $dm2->file1 = 'discordant_snps_'.$this->var_name.'_'.$dna->variable_name.'_GRCh37.csv'; |
||
| 84 | // $dm->file2 = 'shared_dna_one_chrom_'.$this->var_name.'_'.$dna->variable_name.'_GRCh37.csv'; |
||
| 85 | $dm2->file2 = 'shared_dna_one_chrom_'.$this->var_name.'_'.$dna->variable_name.'_0p75cM_1100snps_GRCh37_HapMap2.csv'; |
||
| 86 | |||
| 87 | $dm2->total_shared_cm = round($resultData['total_cms'], 2); |
||
| 88 | $dm2->largest_cm_segment = round($resultData['largest_cm'], 2); |
||
| 89 | |||
| 90 | $dm2->save(); |
||
| 91 | } |
||
| 92 | // $data = readCSV(storage_path('app'.DIRECTORY_SEPARATOR.'dna'.DIRECTORY_SEPARATOR.'output'.DIRECTORY_SEPARATOR.$dm->file1), ','); |
||
| 93 | // array_shift($data); |
||
| 94 | // $data = writeCSV(storage_path('app'.DIRECTORY_SEPARATOR.'dna'.DIRECTORY_SEPARATOR.'output'.DIRECTORY_SEPARATOR.$dm->file1), $data); |
||
| 95 | |||
| 96 | // $data = readCSV(storage_path('app'.DIRECTORY_SEPARATOR.'dna'.DIRECTORY_SEPARATOR.'output'.DIRECTORY_SEPARATOR.$dm->file2), ','); |
||
| 97 | // array_shift($data); |
||
| 98 | |||
| 99 | // $temp_data = $data; |
||
| 100 | // array_shift($temp_data); |
||
| 101 | // array_shift($temp_data); |
||
| 102 | // $total_cms = 0; |
||
| 103 | // $largest_cm = 0; |
||
| 104 | // foreach ($temp_data as $line) { |
||
| 105 | // if ($line[4] >= $largest_cm) { |
||
| 106 | // $largest_cm = $line[4]; |
||
| 107 | // } |
||
| 108 | // $total_cms = $total_cms + $line[4]; |
||
| 109 | // } |
||
| 110 | // $dm->user_id = $user->id; |
||
| 111 | // $dm->total_shared_cm = $total_cms; |
||
| 112 | // $dm->largest_cm_segment = round($largest_cm, 2); |
||
| 113 | // $dm->save(); |
||
| 114 | |||
| 115 | // $data = writeCSV(storage_path('app'.DIRECTORY_SEPARATOR.'dna'.DIRECTORY_SEPARATOR.'output'.DIRECTORY_SEPARATOR.$dm->file2), $data); |
||
| 116 | } |
||
| 117 | } |
||
| 118 | } |
||
| 119 |