src/Service/Loader/Legacy/StudentWriterService.php line 20

Open in your IDE?
  1. <?php
  3. namespace App\Service\Loader\Legacy;
  5. use App\CIC\Service\Legacy\Transformer\SinfoStudentTransformer;
  6. use App\Entity\School\Student\StudentProfile;
  7. use App\Service\CsscHelperService;
  8. use CIC\CSSC\SINFO;
  9. use CIC\DB\envLoader\db;
  10. use Doctrine\DBAL\Platforms\Keywords\DB2Keywords;
  11. use Doctrine\ORM\EntityManagerInterface;
  13. class StudentWriterService
  14. {
  15.     private EntityManagerInterface $em;
  16.     private db $db;
  17.     private SINFO $sinfo;
  18.     private SinfoStudentTransformer $transformer;
  20.     public function __construct()
  21.     {
  22. //        $this->em = $em;
  23. //        $this->db = $db;
  24. //        $this->sinfo=$cssc->getSinfo();
  25. //
  26. //        $this->transformer = $transformer;
  27.     }
  30.     function create(StudentProfile $student)
  31.     {
  32. //        $sinfo = $this->transformer->revert($student);
  33. //        //lets check if the student exists
  34. //        if(!$this->getStudentRow($student->getStudentNumber())) {
  35. //            $this->createLegacyRecord('SINFO',$sinfo);
  36. //            // $this->createLegacyRecord('SINFO_XTRA',['IDNUM'=>$student->getStudentNumber()]); //cic_cron handles this right now....
  37. //        }
  38.     }
  40.     function update(StudentProfile $student) {
  41.         //find record.
  42. //
  43. //        $sinfo = $this->transformer->revert($student);
  44. ////        updateLegacyRecord(string $table,array $data,string $where,array $criteria) {
  45. ////            return $this->db->update(
  46. ////                $table,
  47. ////                $data,
  48. ////                $where,
  49. ////                $criteria,
  50. ////            );
  51. //
  53.     }
  56.     function legacy_update(StudentProfile $student) {
  57. //        $this->sinfo->refresh($student->getStudentNumber());
  58. //        $sinfo=$this->getSinfo($student);
  59. //        $changes=$this->getChanges($student,$sinfo);
  60. //        $data=array_diff_assoc($changes,$sinfo);
  61. //        if(count($data) > 0) {
  62. //            $this->db->update('SINFO',$data,'IDNUM=?',$student->getStudentNumber());
  63. //            $this->sinfo->refresh($student->getStudentNumber());
  64. //        }
  66.     }
  68.     function legacy_create(StudentProfile $student) {
  69. //        $this->sinfo->refresh($student->getStudentNumber());
  70. //        $data=$this->getMap($student);
  71. //        $data['IDNUM']=$student->getStudentNumber();
  72. //        if(count($data) > 0) {
  73. //            $this->db->insert('SINFO',$data);
  74. //            $this->sinfo->refresh($student->getStudentNumber());
  75. //        }
  77.     }
  79.     function findByStudentNumber($idnum) {
  81.     }
  82.     function findByUuid($uuid) {
  84.     }
  86.     private function getSinfo(StudentProfile $student) {
  87.         //because cssc/sinfo does NOT have uuid lookup (yet) do it ourselves
  88.         $this->db->query(
  89.             "SELECT IDNUM from SINFO WHERE uuid=?",
  90.             [$student->getUuid()]
  91.         );
  92.         if($this->db->returned_rows>0){
  93.             //got a record
  94.             $result=$this->db->fetch_obj();
  95.             return $this->sinfo->get($result->IDNUM);
  96.         }
  97.         return $this->sinfo->get($student->getStudentNumber());
  98.     }
  100.     private function getChanges(StudentProfile $student, array $sinfo) {
  101.         $map=$this->getMap($student);
  102.         foreach($map as $key=>$value) {
  103.             $sinfo=$this->change($sinfo,$key,$value);
  104.         }
  105.         return $sinfo;
  106.     }
  108.     private function change($array,$key,$value) {
  109.         if(array_key_exists($key, $array)) {
  110.             if($array[$key]!=$value) {
  111.                 $array[$key]=$value;
  112.             }
  113.         }
  114.         return $array;
  115.     }
  118.     private function getMap(StudentProfile $student) {
  119.         $map=[
  120. //            'IDNUM'=>$student->getStudentNumber(),
  121.             'FIRSTN'=>$student->getGivenName(),
  122.             'LASTN'=>$student->getLastName(),
  123.             'DBIRTH'=>$student->getDateOfBirth()->format("Y-m-d"),
  124.             'MOTHER'=>implode(" ",[$student->getParent1()->getGivenName(),$student->getParent1()->getSurName()]),
  125.             'FATHER'=>implode(" ",[$student->getParent2()->getGivenName(),$student->getParent2()->getSurName()]),
  126.         ];
  127.         return $map;
  128.     }
  130.     /************************/
  131.     function getStudentRow($idnum) {
  132.         $q="SELECT * FROM SINFO WHERE IDNUM=?";
  133.         $this->db->query($q,[$idnum]);
  134.         if($this->db->returned_rows<1)
  135.             return;
  137.         /******************************/
  138.         $SINFO=$this->db->fetch_assoc();
  140.         $q="SELECT * FROM SINFO_XTRA WHERE IDNUM=?";
  141.         $this->db->query($q,[$idnum]);
  142.         $SINFO_XTRA=$this->db->fetch_assoc();
  144.         return [
  145.             'SINFO'=>$SINFO,
  146.             'SINFO_XTRA'=>$SINFO_XTRA,
  147.         ];
  148.     }
  150.     private function updateLegacyRecord(string $table,array $data,string $where,array $criteria) {
  151.         return $this->db->update(
  152.             $table,
  153.             $data,
  154.             $where,
  155.             $criteria,
  156.         );
  157.     }
  159.     private function createLegacyRecord(string $table,array $data) {
  160.         return $this->db->insert(
  161.             $table,
  162.             $data
  163.         );
  164.     }
  166. }