From 15406674cc422841ccc0859f5316605c36688430 Mon Sep 17 00:00:00 2001 From: VE10-Sanjeev Date: Sat, 7 Jan 2023 14:27:17 +0530 Subject: [PATCH] Bulk Data upload IN Cet app : ps --- api/application/config/constants.php | 2 + api/application/config/routes.php | 4 + .../controllers/SMC_Credit_PD_Controller.php | 91 +++++++++++++++++-- .../controllers/Sales_PD_Controller.php | 78 +++++++++++++++- .../helpers/authorization_helper.php | 2 +- 5 files changed, 164 insertions(+), 13 deletions(-) diff --git a/api/application/config/constants.php b/api/application/config/constants.php index 800e1db4..bf978f8e 100644 --- a/api/application/config/constants.php +++ b/api/application/config/constants.php @@ -96,6 +96,8 @@ defined('ROUTE_LOGIN_V') OR define('ROUTE_LOGIN_V', 'generateSatelliteImg defined('ROUTE_LOGIN_U') OR define('ROUTE_LOGIN_U', 'generateOTP'); defined('ROUTE_LOGIN_T') OR define('ROUTE_LOGIN_T', 'verifyOTP'); defined('ROUTE_LOGIN_S') OR define('ROUTE_LOGIN_S', 'purge_pddata'); +defined('ROUTE_LOGIN_H') OR define('ROUTE_LOGIN_H', 'transferCreditPDToCETApp'); +defined('ROUTE_LOGIN_G') OR define('ROUTE_LOGIN_G', 'transferSalesPDToCETApp'); defined('ROUTE_LOGIN_F') OR define('ROUTE_LOGIN_F', 'previewDigiLockerDocs'); // defined('ROUTE_LOGIN_F') OR define('ROUTE_LOGIN_F', 'downloadDigiLockerDocs'); defined('ROUTE_LOGIN_E') OR define('ROUTE_LOGIN_E', 'getDigiLockerDocs'); diff --git a/api/application/config/routes.php b/api/application/config/routes.php index d80d4741..40f75386 100755 --- a/api/application/config/routes.php +++ b/api/application/config/routes.php @@ -421,3 +421,7 @@ $route['checkjsonPD']='Data_Dump_Controller/checkjsonPD'; $route['deleteS3Image']='Data_Dump_Controller/deleteS3Images'; $route['saveShortsVideo'] = 'PD_Controller/saveShortsVideo'; + +$route['transferSalesPDToCETApp'] = 'Sales_PD_Controller/transferSalesPDToCETApp'; +$route['transferCreditPDToCETApp'] = 'SMC_Credit_PD_Controller/transferCreditPDToCETApp'; + diff --git a/api/application/controllers/SMC_Credit_PD_Controller.php b/api/application/controllers/SMC_Credit_PD_Controller.php index 3c13051d..93c7ab78 100644 --- a/api/application/controllers/SMC_Credit_PD_Controller.php +++ b/api/application/controllers/SMC_Credit_PD_Controller.php @@ -269,9 +269,87 @@ class SMC_Credit_PD_Controller extends REST_Controller { } function uploadCreditPDDataToCETApp_get() { - log_message('ERROR', '#### upload SMC Credit PDData To CETApp Called'); - $this->load->helper('smc_creditpd'); $smc_credit_pd = $this->uri->segment(2); + if($smc_credit_pd){ + log_message('ERROR', '#### upload SMC-Credit PDData To CETApp Function Called'); + $response = $this->dataSynchronization($smc_credit_pd); + if($response){ + $data['dataStatus'] = true; + $data['status'] = REST_Controller::HTTP_OK; + $data['msg'] = 'Data Shared Successfully'; + $this->response($data,REST_Controller::HTTP_OK); + }else{ + $data['dataStatus'] = false; + $data['status'] = REST_Controller::HTTP_NO_CONTENT; + $data['msg'] = 'Something went wrong! Try Later'; + $this->response($data, REST_Controller::HTTP_OK); + } + }else{ + $msg = 'Can`t Upload ID Not Founded ! Try Later'; + $data['dataStatus'] = false; + $data['status'] = REST_Controller::HTTP_NO_CONTENT; + $data['msg'] = $msg; + log_message('ERROR', $msg); + $this->response($data, REST_Controller::HTTP_OK); + } + + } + public function transferCreditPDToCETApp_get() + { + $from_date = $this->get('from_date'); + $to_date = $this->get('to_date'); + if(($from_date != "" || $from_date != null) && ($to_date != "" || $to_date != null)){ + $newDate1 = date("Y-m-d", strtotime($from_date)); + $newDate2 = date("Y-m-d", strtotime($to_date)); + $smc_lender_id = ENVIRONMENT == 'production' ? 7 : 35; //SMC lender id MWISE in live and demo + $msg = " SMC-Credit PDData To CETApp Date Given Format => " . $from_date ." to ".$to_date; + // $where = 'DATE(PDTRIGGER.completed_on) BETWEEN ' ."'$newDate1'". ' AND ' ."'$newDate2'"; + $columns = array('PDTRIGGER.pd_id', 'PDTRIGGER.pd_status'); + $table = PDTRIGGER . ' as PDTRIGGER'; + + $where = '(SELECT + MAX(DATE(logmaster.createdon)) + FROM h_common_masters as logmaster + WHERE logmaster.new_value = "COMPLETED" AND PDTRIGGER.pd_id = logmaster.primary_key) + BETWEEN ' ."'$newDate1'". ' AND ' ."'$newDate2'"; + $where_arr = array('PDTRIGGER.fk_lender_id' => $smc_lender_id,'PDTRIGGER.pd_status' => COMPLETED, $where => null); + $details = $this->SMC_Credit_PD_Model->selectCustomRecords($columns, $where_arr, $table); + log_message('ERROR', $msg." Changed ".$newDate1." to ".$newDate2." Total Records => " . count($details)); + if(!empty($details)){ + $flag = 0; + for ($i = 0; $i < count($details); $i++) { + $smc_credit_pd = $details[$i]['pd_id']; + // echo $smc_credit_pd; + $result = $this->dataSynchronization($smc_credit_pd); + $flag = $result == true ? $flag+1 : $flag; + } + $data['dataStatus'] = true; + $data['status'] = REST_Controller::HTTP_OK; + $data['msg'] = $flag.' Data Shared Successfully'; + $this->response($data, REST_Controller::HTTP_OK); + }else{ + $msg = 'There is no data for Given Date ! Try Later'; + $data['dataStatus'] = false; + $data['status'] = REST_Controller::HTTP_NO_CONTENT; + $data['msg'] = $msg; + log_message('ERROR', $msg); + $this->response($data, REST_Controller::HTTP_OK); + } + + } + else { + $msg = 'Can`t Upload Date Not Founded ! Try Later'; + $data['dataStatus'] = false; + $data['status'] = REST_Controller::HTTP_NO_CONTENT; + $data['msg'] = $msg; + log_message('ERROR', $msg); + $this->response($data, REST_Controller::HTTP_OK); + } + + } + function dataSynchronization($smc_credit_pd) + { + $this->load->helper('smc_creditpd'); $mater_details = $this->PD_Model->getPDMasterDetails($smc_credit_pd); $pd_section_data = $this->SMC_Credit_PD_Model->getSMCTemplateForPD($smc_credit_pd,$mater_details[0]['fk_product_id'],null,null,'REPORT'); log_message('ERROR', '#### Credit PD ('.$smc_credit_pd.') There are ' . count($pd_section_data).' Forms '); @@ -308,7 +386,7 @@ class SMC_Credit_PD_Controller extends REST_Controller { $data_from_excel = $this->loadDataFromExcelBusiProcess($mater_details, $value['fk_form_id']); //print_r($data_from_excel);die(); // $view_data['pd_section_data'][$value['fk_form_id']] = $data_from_excel; - $CETAPP_creditPD_data[$value['form_name']] = json_decode($data_from_excel,true); + $CETAPP_creditPD_data[$value['form_name']] = $data_from_excel; $filter_form_id[$key] = $value['fk_form_id']; } } @@ -390,16 +468,15 @@ class SMC_Credit_PD_Controller extends REST_Controller { // echo $message; // }die(); - $data['dataStatus'] = true; - $data['status'] = REST_Controller::HTTP_OK; - $data['msg'] = 'Data Shared Successfully'; + return $result; }else{ log_message('ERROR', '#### Section Details pushed Images Details Not Pushed'); $data['dataStatus'] = false; $data['status'] = REST_Controller::HTTP_NO_CONTENT; $data['msg'] = 'Section Details pushed Images Details Not Pushed ! Try Later'; + $this->response($data, REST_Controller::HTTP_OK); } - $this->response($data, REST_Controller::HTTP_OK); + } else { log_message('ERROR', '#### There is No Data Found relevant Credit PDID '); $data['dataStatus'] = false; diff --git a/api/application/controllers/Sales_PD_Controller.php b/api/application/controllers/Sales_PD_Controller.php index bab5090a..b20229df 100644 --- a/api/application/controllers/Sales_PD_Controller.php +++ b/api/application/controllers/Sales_PD_Controller.php @@ -273,8 +273,79 @@ class Sales_PD_Controller extends REST_Controller { function uploadSalesPDDataToCETApp_get() { - log_message('ERROR','#### upload SalesPDData To CETApp Called'); $sales_pd_id = $this->uri->segment(2); + if($sales_pd_id){ + log_message('ERROR', '#### upload Sales PDData To CETApp Function Called'); + $response = $this->dataSynchronization($sales_pd_id); + if($response){ + $data['dataStatus'] = true; + $data['status'] = REST_Controller::HTTP_OK; + $data['msg'] = 'Data Shared Successfully'; + $this->response($data,REST_Controller::HTTP_OK); + }else{ + $data['dataStatus'] = false; + $data['status'] = REST_Controller::HTTP_NO_CONTENT; + $data['msg'] = 'Something went wrong! Try Later'; + $this->response($data, REST_Controller::HTTP_OK); + } + }else{ + $msg = 'Can`t Upload. ID Not Founded ! Try Later'; + $data['dataStatus'] = false; + $data['status'] = REST_Controller::HTTP_NO_CONTENT; + $data['msg'] = $msg; + log_message('ERROR', $msg); + $this->response($data, REST_Controller::HTTP_OK); + } + + } + public function transferSalesPDToCETApp_get() + { + $from_date = $this->get('from_date'); + $to_date = $this->get('to_date'); + if(($from_date != "" || $from_date != null) && ($to_date != "" || $to_date != null)){ + $newDate1 = date("Y-m-d", strtotime($from_date)); + $newDate2 = date("Y-m-d", strtotime($to_date)); + $msg = " SMC-Credit PDData Transfer To CETApp Date Given Format => " . $from_date ." to ".$to_date; + // $where = 'DATE(PDTRIGGER.completed_on) BETWEEN ' ."'$newDate1'". ' AND ' ."'$newDate2'"; + $columns = array('SALES_PD_DATA.sales_pd_id','SALES_PD_DATA.status', 'SALES_PD_DATA.completed_date'); + $table = SALES_PD_DATA . ' as SALES_PD_DATA'; + $where = 'DATE(SALES_PD_DATA.completed_date) + BETWEEN ' ."'$newDate1'". ' AND ' ."'$newDate2'"; + $where_arr = array('SALES_PD_DATA.status' => COMPLETED, $where => null); + $details = $this->Sales_PD_Model->selectCustomRecords($columns, $where_arr, $table); + log_message('ERROR', $msg." Changed ".$newDate1." to ".$newDate2." Total Records => " . count($details)); + if(!empty($details)){ + $flag = 0; + for ($i = 0; $i < count($details); $i++) { + $sales_pd_id = $details[$i]['sales_pd_id']; + // echo $sales_pd_id; + $result = $this->dataSynchronization($sales_pd_id); + $flag = ($result == true) ? $flag+1 : $flag; + } + $data['dataStatus'] = true; + $data['status'] = REST_Controller::HTTP_OK; + $data['msg'] = $flag.' Data Shared Successfully'; + $this->response($data, REST_Controller::HTTP_OK); + }else{ + $msg = 'There is no data for Given Date ! Try Later'; + $data['dataStatus'] = false; + $data['status'] = REST_Controller::HTTP_NO_CONTENT; + $data['msg'] = $msg; + log_message('ERROR', $msg); + $this->response($data, REST_Controller::HTTP_OK); + } + } + else { + $msg = 'Can`t Upload Date Not Founded ! Try Later'; + $data['dataStatus'] = false; + $data['status'] = REST_Controller::HTTP_NO_CONTENT; + $data['msg'] = $msg; + log_message('ERROR', $msg); + $this->response($data, REST_Controller::HTTP_OK); + } + } + function dataSynchronization($sales_pd_id) + { if(!empty($sales_pd_id)){ $columns = array('SALES_PD_DATA.*','ENTITY.short_name','PRODUCT.abbr','USERPROFILE.smc_emp_code'); $table = SALES_PD_DATA.' as SALES_PD_DATA'; @@ -343,10 +414,7 @@ class Sales_PD_Controller extends REST_Controller { $stt_fields['img'] = $satellite_image[0]['img']; cet_salespd::pushwithcetphotographapi($stt_fields,0); } - $data['dataStatus'] = true; - $data['status'] = REST_Controller::HTTP_OK; - $data['msg'] = 'Data Shared Successfully'; - $this->response($data,REST_Controller::HTTP_OK); + return $result; }else{ log_message('ERROR', '#### Section Details pushed Images Details Not Pushed'); $data['dataStatus'] = false; diff --git a/api/application/helpers/authorization_helper.php b/api/application/helpers/authorization_helper.php index 8ccfe153..977d3fab 100644 --- a/api/application/helpers/authorization_helper.php +++ b/api/application/helpers/authorization_helper.php @@ -72,7 +72,7 @@ class AUTHORIZATION } - if( $routingName == ROUTE_LOGIN_X || $routingName == ROUTE_LOGIN_Y || $routingName == ROUTE_LOGIN_Z || $routingName == ROUTE_LOGIN_W || $routingName == ROUTE_LOGIN_V || $routingName == ROUTE_LOGIN_A || $routingName == TURN_SERVER_API || $routingName == VIDEO_CHAT_ACCESS_KEY_API || $routingName ==SAVEROOMINFO_API || $routingName ==SAVESMCCREDITPDIMAGE_API || $routingName ==GETSMCPDIMGSECTIONDATA_API || $routingName == ROUTE_LOGIN_T || $routingName == ROUTE_LOGIN_U || $routingName == ROUTE_LOGIN_B || $routingName == ROUTE_LOGIN_C || $routingName == ROUTE_LOGIN_D || $routingName == ROUTE_LOGIN_E || $routingName == ROUTE_LOGIN_F || $routingName == ROUTE_LOGIN_S) + if( $routingName == ROUTE_LOGIN_X || $routingName == ROUTE_LOGIN_Y || $routingName == ROUTE_LOGIN_Z || $routingName == ROUTE_LOGIN_W || $routingName == ROUTE_LOGIN_V || $routingName == ROUTE_LOGIN_A || $routingName == TURN_SERVER_API || $routingName == VIDEO_CHAT_ACCESS_KEY_API || $routingName ==SAVEROOMINFO_API || $routingName ==SAVESMCCREDITPDIMAGE_API || $routingName ==GETSMCPDIMGSECTIONDATA_API || $routingName == ROUTE_LOGIN_T || $routingName == ROUTE_LOGIN_U || $routingName == ROUTE_LOGIN_B || $routingName == ROUTE_LOGIN_C || $routingName == ROUTE_LOGIN_D || $routingName == ROUTE_LOGIN_E || $routingName == ROUTE_LOGIN_F || $routingName == ROUTE_LOGIN_S || $routingName == ROUTE_LOGIN_G || $routingName == ROUTE_LOGIN_H) { return true; }