Issues (364)

app/Jobs/DnaMatching.php (2 issues)

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
The trait Illuminate\Queue\SerializesModels requires some properties which are not provided by App\Jobs\DnaMatching: $collectionClass, $id, $relations, $class, $keyBy
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
The property person does not exist on App\Models\User. Did you mean person_id?
Loading history...
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