Bulk Data upload IN Cet app : ps

This commit is contained in:
VE10-Sanjeev 2023-01-07 14:27:17 +05:30
parent 0170fd35a1
commit 15406674cc
5 changed files with 164 additions and 13 deletions

View File

@ -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');

View File

@ -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';

View File

@ -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;

View File

@ -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;

View File

@ -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;
}