From 3d25adf592f750199b60c181737cc9a741c77bef Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B5=B5=E9=B9=8F?= Date: Mon, 20 Nov 2023 15:22:09 +0800 Subject: [PATCH] =?UTF-8?q?CT=E5=88=86=E9=94=80=E5=95=86=E7=B3=BB=E7=BB=9F?= =?UTF-8?q?=E7=9A=84=E6=8E=A5=E5=8F=A3=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ctmobilefirst/controllers/traindms.php | 164 ++++++++ .../ctmobilefirst/libraries/Des.php | 59 +++ .../ctmobilefirst/models/dms_model.php | 378 ++++++++++++++++++ 3 files changed, 601 insertions(+) create mode 100644 application/third_party/ctmobilefirst/controllers/traindms.php create mode 100644 application/third_party/ctmobilefirst/libraries/Des.php create mode 100644 application/third_party/ctmobilefirst/models/dms_model.php diff --git a/application/third_party/ctmobilefirst/controllers/traindms.php b/application/third_party/ctmobilefirst/controllers/traindms.php new file mode 100644 index 00000000..0d332969 --- /dev/null +++ b/application/third_party/ctmobilefirst/controllers/traindms.php @@ -0,0 +1,164 @@ +load->model("dms_model"); + } + + + /** + * @description: 接口总汇，根据接受数据，调用不同接口，返回数据 + * @return {*} + * @Date Changed: + */ + public function dmsCallback(){ + $back_json = file_get_contents('php://input'); + $dms_backdata = json_decode($back_json); + + if(!empty($dms_backdata)){ + //判断接口调用是否合法 + $TimeStamp = $dms_backdata->authentication->timeStamp; + $serviceName = $dms_backdata->authentication->serviceName; //每个接口都有自己名称 + $companyId = "haina"; + $key = "dms001"; + + $strSign = $TimeStamp.$serviceName.$companyId.$key; //加密前的令牌 + $Sign = md5($strSign); + $messageIdentity = $dms_backdata->authentication->messageIdentity; + $ResultNoticeResponse = new stdClass(); + if ($Sign == $messageIdentity){ + $ResultNoticeResponse->returnCode = 1; + $ResultNoticeResponse->returnMsg = "success"; + //这里正常处理各种接口调用 + if ($serviceName=="dms.login"){ //登录 + $username = $dms_backdata->loginInfo->username; + $password = $dms_backdata->loginInfo->password; + $ResultNoticeResponse->loginInfo = new stdClass(); + $LoginInfo = $this->dms_model->Login($username,$password); + if (empty($LoginInfo)){ + $ResultNoticeResponse->loginInfo->status = 0; //账号密码错误。 + $ResultNoticeResponse->loginInfo->dt_username = ''; + $ResultNoticeResponse->loginInfo->dt_payrule = ""; + $ResultNoticeResponse->loginInfo->dt_usertype = ""; + $ResultNoticeResponse->loginInfo->dt_HtId = ""; + $ResultNoticeResponse->loginInfo->dt_id = ""; + }else{ + $ResultNoticeResponse->loginInfo->status = 1; //账号密码是否正常。 + $ResultNoticeResponse->loginInfo->dt_username = $LoginInfo->dt_username; + $ResultNoticeResponse->loginInfo->dt_payrule = $LoginInfo->dt_payrule; + $ResultNoticeResponse->loginInfo->dt_usertype = $LoginInfo->dt_usertype; + $ResultNoticeResponse->loginInfo->dt_HtId = $LoginInfo->dt_HtId; + $ResultNoticeResponse->loginInfo->dt_id = $LoginInfo->dt_id; + } + + }else if($serviceName=="dms.dmlist"){ //分销商列表 + $arrKeyword = new stdClass(); + $arrKeyword = $dms_backdata->arrKeyword; + + $dmlist = $this->dms_model->get_DmList($arrKeyword); + $resultData = $dmlist["data"]; + $total = $dmlist["total"]; + $ResultNoticeResponse->dmlist = new stdClass(); + $ResultNoticeResponse->dmlist->data=$resultData; + $ResultNoticeResponse->dmlist->total = $total; + // "arrKeyword": { + // "s_username": "ssss", + // "s_ename": "vvv", + // "page": false, + // "per_page": 20 + // } + }else if($serviceName=="dms.getpayrule"){ //获取支付规则列表数据 + $getpayrule = $this->dms_model->get_payrule(); + $ResultNoticeResponse->getpayrule = $getpayrule; + }else if ($serviceName=="dms.addsave"){ //添加供应商操作 + $formData = new stdClass() ; + $formData = $dms_backdata->formInfo; + $rStatus = $this->dms_model->addsave($formData); + $ResultNoticeResponse->addsave = $rStatus; + }else if ($serviceName=="dms.getDmsDetail") { //修改分销商详细页 + $id = $dms_backdata->DmsDetail->dtid; + $dmsDetail = $this->dms_model->getDmsDetail($id); + $ResultNoticeResponse->DmsDetail = $dmsDetail; + }else if ($serviceName=="dms.editsave"){ //修改分销商保存 + + $formData = new stdClass() ; + $formData = $dms_backdata->formInfo; + $rStatus = $this->dms_model->editsave($formData); + $ResultNoticeResponse->editsave = $rStatus; + }else if ($serviceName=="dms.delete"){ //删除分销商 + $id = $dms_backdata->DmsDetail->dtid; + $rStatus = $this->dms_model->dmdDelete($id); + $ResultNoticeResponse->dmsdelete = $rStatus; + }else if ($serviceName == "dms.payrecord"){ //支付记录 + $arrKeyword = new stdClass(); + $arrKeyword = $dms_backdata->arrKeyword; + $payrecord = $this->dms_model->payrecord($arrKeyword); + $resultData = $payrecord["data"]; + $total = $payrecord["total"]; + $ResultNoticeResponse->payrecord = new stdClass(); + $ResultNoticeResponse->payrecord->data=$resultData; + $ResultNoticeResponse->payrecord->total = $total; + }else if ($serviceName=="dms.payrecord_addsave"){ //支付记录添加 + $formData = new stdClass() ; + $formData = $dms_backdata->formInfo; + $rStatus = $this->dms_model->payrecord_addsave($formData); + $ResultNoticeResponse->addsave = $rStatus; + }else if ($serviceName=="dms.payrecord_delete"){ //支付记录删除 + $id = $dms_backdata->payrecord->dp_id; + $htid = $dms_backdata->payrecord->dp_HtId; + $rStatus = $this->dms_model->payrecord_delete($id,$htid); + $ResultNoticeResponse->dmsdelete = $rStatus; + }else if ($serviceName=="dms.trainorder"){ //订单列表-火车 + $arrKeyword = new stdClass(); + $arrKeyword = $dms_backdata->arrKeyword; + $trainorder = $this->dms_model->trainorder($arrKeyword); + $resultData = $trainorder["data"]; + $total = $trainorder["total"]; + $ResultNoticeResponse->trainorder = new stdClass(); + $ResultNoticeResponse->trainorder->data=$resultData; + $ResultNoticeResponse->trainorder->total = $total; + }else if ($serviceName == "dms.dmslisteasy"){ //所有分销商数据，下拉框使用 + $getdmseasy = $this->dms_model->get_dmseasy(); + $ResultNoticeResponse->getpayrule = $getdmseasy; + }else if ($serviceName=="dms.getpaydetail"){ //获取某一个分销商的所有财务信息 + $id = $dms_backdata->htid; + $getpaydetail = $this->dms_model->get_paydetail($id); + $ResultNoticeResponse->getpaydetail = $getpaydetail; + } + + + }else{ + $ResultNoticeResponse->returnCode = 0; + $ResultNoticeResponse->returnMsg = "messageIdentity is error!"; + } + echo json_encode($ResultNoticeResponse); + + } + } + + /** + * @description: + * @return {*} + * @Date Changed: + */ + public function index() + { + + } + + + public function login (){ + + } + + public function addUser(){ + + } + +} + +/* End of file TrainDMS.php */ diff --git a/application/third_party/ctmobilefirst/libraries/Des.php b/application/third_party/ctmobilefirst/libraries/Des.php new file mode 100644 index 00000000..b2ea6b5f --- /dev/null +++ b/application/third_party/ctmobilefirst/libraries/Des.php @@ -0,0 +1,59 @@ +pkcs5_pad($string, $size); + $td = mcrypt_module_open('des', '', 'ecb', ''); + $iv = @mcrypt_create_iv(mcrypt_enc_get_iv_size($td), MCRYPT_RAND); + @mcrypt_generic_init($td, $key, $iv); + $data = mcrypt_generic($td, $string); + mcrypt_generic_deinit($td); + mcrypt_module_close($td); + $data = base64_encode($data); + return $data; + } + + function decrypt($string,$key) + { + $string = base64_decode($string); + $td = mcrypt_module_open('des', '', 'ecb', ''); + //使用MCRYPT_DES算法,cbc模式 + $iv = @mcrypt_create_iv(mcrypt_enc_get_iv_size($td), MCRYPT_RAND); + $ks = mcrypt_enc_get_key_size($td); + @mcrypt_generic_init($td, $key, $iv); + //初始处理 + $decrypted = mdecrypt_generic($td, $string); + //解密 + mcrypt_generic_deinit($td); + //结束 + mcrypt_module_close($td); + + $result = $this->pkcs5_unpad($decrypted); + //$result = mb_convert_encoding($result, 'UTF-8', 'GBK'); + return $result; + } + + function pkcs5_pad($text, $blocksize) + { + $pad = $blocksize - (strlen($text) % $blocksize); + return $text . str_repeat(chr($pad), $pad); + } + + function pkcs5_unpad($text) + { + $pad = ord($text{strlen($text) - 1}); + if ($pad > strlen($text)) { + return false; + } + if (strspn($text, chr($pad), strlen($text) - $pad) != $pad) { + return false; + } + return substr($text, 0, -1 * $pad); + } +} + +?> \ No newline at end of file diff --git a/application/third_party/ctmobilefirst/models/dms_model.php b/application/third_party/ctmobilefirst/models/dms_model.php new file mode 100644 index 00000000..e326f0f9 --- /dev/null +++ b/application/third_party/ctmobilefirst/models/dms_model.php @@ -0,0 +1,378 @@ +HT = $this->load->database('TOURMANAGER_LOCAL', TRUE); + $this->INFO = $this->load->database('INFORMATION_LOCAL', TRUE); + } + + /** + * @description: + * @return {*} + * @Date Changed: + */ + function Login($username,$password){ + $sql = "select top 1 dt_id,dt_username,dt_payrule,dt_usertype,dt_HtId from DMS_Distributor "; + $sql .= " where dt_status=1 and dt_username=? and dt_password=? "; + $query = $this->INFO->query($sql,array($username,$password)); + if ($query->num_rows() > 0) { + return $query->row(); + }else{ + return null; + } + } + + /** + * 订单列表 + */ + function trainorder($arrKeyword){ + $htid = $arrKeyword->htid ==false?-1:$arrKeyword->htid; + $page = $arrKeyword->page ==false?0:$arrKeyword->page; + $pagesize = $arrKeyword->per_page>0 ? $arrKeyword->per_page :20; + if ($page < 1) { + $page = 1; + } + + + $sql = " SELECT * from ( + select row_number() over (order by COLI_ApplyDate desc) as rownumber, COLI_SN,COLI_ID,COLI_ApplyDate,COLI_servicetype,COLI_State,COLI_sourcetype,COLI_GUT_SN + ,GUT_Title,GUT_FirstName,GUT_LastName + ,tb2.* + from BIZ_ConfirmLineInfo bci + inner join BIZ_Guest bg on bci.COLI_GUT_SN = bg.GUT_SN + outer apply ( select top 1 COLD_COLI_SN,FlightsNo,DepartureCity,ArrivalCity from BIZ_ConfirmLineDetail inner join BIZ_FlightsOrderInfo + on FOI_COLD_SN=COLD_SN where COLD_COLI_SN=bci.COLI_SN) tb2 + where COLI_State in(8,9,61,62) + AND COLI_servicetype='2' + and isnull(DeleteFlag,0)<>1 "; + + if ($htid == 32083 || $htid==32084){ + $sql .= " and COLI_sourcetype in(32083,32084) "; + }else { + $sql .= " and COLI_sourcetype ='".$htid."'"; + } + + $sql .= " )t "; + + + $sql2 = $sql." Where t.rownumber > ? And t.rownumber <= ?"; + + $begin = ($page - 1) * $pagesize; + $end = $begin + $pagesize; + $qurey = $this->HT->query($sql); + $count = $qurey->num_rows(); //总记录数 + + $qurey2 = $this->HT->query($sql2, array($begin, $end)); + //return 数据和总数 + return array('data' => $qurey2->result(), 'total' => $count); + } + + /** + * @description: + * @param {*} $arrKeyword + * @return {*} + * @Date Changed: + */ + function get_DmList($arrKeyword){ + $s_username = $arrKeyword->s_username ==false?"": trim($arrKeyword->s_username); + $s_ename = $arrKeyword->s_ename ==false?"": trim($arrKeyword->s_ename); + $page = $arrKeyword->page ==false?0:$arrKeyword->page; + $pagesize = $arrKeyword->per_page>0 ? $arrKeyword->per_page :20; + if ($page < 1) { + $page = 1; + } + + $sql = "SELECT * from ( + SELECT row_number() over (order by dt_id desc) as rownumber,dt_id,dt_username,dt_password,dt_HTid,dt_payrule,dt_usertype,isnull(dt_status,1) as dt_status + ,(select dpr_rule from dms_payrule where dpr_id = dt_payrule) as dpr_rule + ,(select syc2_CodeDiscribe FROM tourmanager.dbo.V_System_Code where SYC_Type=32 AND LGC_LGC=2 AND SYC_SN=dt_HtId) as dmsName + ,( select COUNT(*) as ordercount from tourmanager.dbo.BIZ_ConfirmLineInfo where COLI_sourcetype=dt_HtId + and COLI_State in(8,9,61,62) AND COLI_servicetype='2' + and isnull(DeleteFlag,0)<>1 ) as trainOrderCount + ,isnull((select SUM(dp_paymoney) from DMS_PayRecord where dp_HtId=dt_HtId and dp_status>0),0) as TrainPaySum + from DMS_Distributor + )t where 1=1 "; + if ($s_username!=""){ + $sql .= " and dt_username like '%".$s_username."%' "; + } + if ($s_ename!=""){ + $sql .= " and dmsName like '%".$s_ename."%' "; + } + $sql2 = $sql . " and t.rownumber > ? And t.rownumber <= ? order by dt_id desc"; + + $begin = ($page - 1) * $pagesize; + $end = $begin + $pagesize; + $qurey = $this->INFO->query($sql); + $count = $qurey->num_rows(); //总记录数 + + $qurey2 = $this->INFO->query($sql2, array($begin, $end)); + //return 数据和总数 + return array('data' => $qurey2->result(), 'total' => $count); + } + + /** + * 获取支付规则列表数据 + */ + function get_payrule(){ + $sql = "select * from dms_payrule "; + $query = $this->INFO->query($sql); + return $query->result(); + } + + function get_dmseasy(){ + $sql = " select * from DMS_Distributor where dt_usertype='distributor' + order by dt_username "; + $query = $this->INFO->query($sql); + return $query->result(); + } + + + /** + * 获取某一个分销商的所有财务信息 + */ + function get_paydetail($id){ + $sql = "select count(*) as oCount from BIZ_ConfirmLineInfo where COLI_State in(8,9,61,62) AND COLI_servicetype='2' and isnull(DeleteFlag,0)<>1 "; + if ($id == 32083 || $id==32084){ + $sql .= " and COLI_sourcetype in(32083,32084) "; + }else{ + $sql .= " and COLI_sourcetype ='".$id."' "; + } + $query = $this->HT->query($sql); + if ($query->num_rows()>0){ + $count = $query->row()->oCount; + }else{ + $count = 0; + } + + //付款规则 + $sql = "select top 1 dt_payrule from DMS_Distributor where dt_htid='".$id."'"; + $query = $this->INFO->query($sql); + if ($query->num_rows()>0){ + $rule = $query->row()->dt_payrule; + }else{ + $rule = 0; + } + + if ($rule == 1){ + $total = $count * 1; + }else if ($rule == 2 ){ + $total = $count * 2; + }else { + $total = 0; + } + + //已支付 + + $sql = "select isnull(SUM(dp_paymoney),0) as osum from DMS_PayRecord where dp_HtId= '".$id."'"; + $query = $this->INFO->query($sql); + if ($query->num_rows()>0){ + $sum = $query->row()->osum; + }else{ + $sum = 0; + } + + $result = new stdClass(); + $result->count = $count; + $result->total = $total; + $result->sum = round($sum,2); + + return $result; + } + + function addsave($formData){ + + $username = isset($formData->username)?$formData->username:""; + $password = isset($formData->password)?$formData->password:""; + $Htid = isset($formData->HtId)?$formData->HtId:0; + $payrule = isset($formData->payrule)?$formData->payrule:1; + $usertype = isset($formData->usertype)?$formData->usertype:""; + $result = new stdClass; + if ($usertype!=""){ //用户类型不为空才能进行添加 + //先判断htid是否重复，重复的话不允许添加.管理员不需要判断 + $sql = "select * from DMS_Distributor where dt_HtId=? and dt_usertype='distributor'"; + $query = $this->INFO->query($sql, array($Htid)); + if ($query->num_rows() > 0) { + $result->status = 0; + $result->msg = "翰特编码重复，不允许添加！"; + }else{ + $sql = "insert into DMS_Distributor (dt_username,dt_password,dt_HtId,dt_payrule,dt_usertype) values (?,?,?,?,?)"; + $query = $this->INFO->query($sql ,array($username,$password,$Htid,$payrule,$usertype)); + if ($query === true){ + $result->status = 1; + $result->msg = "数据添加成功！"; + }else{ + $result->status = 0; + $result->msg = "数据插入数据库失败，请联系管理员！"; + } + + } + + + }else{ + $result->status = 0; + $result->msg = "用户类型错误！"; + } + + return $result; + } + + /** + * 保存修改 + */ + function editsave($formData){ + $username = isset($formData->username)?$formData->username:""; + $password = isset($formData->password)?$formData->password:""; + $Htid = isset($formData->HtId)?$formData->HtId:0; + $payrule = isset($formData->payrule)?$formData->payrule:1; + $usertype = isset($formData->usertype)?$formData->usertype:""; + $id = isset($formData->id)?$formData->id:0; + $result = new stdClass; + if ($usertype!=""){ //用户类型不为空才能进行添加 + //先判断htid是否重复，重复的话不允许添加.管理员不需要判断 + $sql = "select * from DMS_Distributor where dt_HtId=? and dt_usertype='distributor' and dt_id<>?"; + $query = $this->INFO->query($sql, array($Htid,$id)); + if ($query->num_rows() > 0) { + $result->status = 0; + $result->msg = "翰特编码重复，不允许修改！"; + }else{ + $sql = "update DMS_Distributor set dt_username=?,dt_password=?,dt_HtId=?,dt_payrule=?,dt_usertype=? where dt_id = ?"; + $query = $this->INFO->query($sql ,array($username,$password,$Htid,$payrule,$usertype,$id)); + if ($query === true){ + $result->status = 1; + $result->msg = "数据修改成功！"; + }else{ + $result->status = 0; + $result->msg = "修改数据库失败，请联系管理员！"; + } + + } + + + }else{ + $result->status = 0; + $result->msg = "用户类型错误！"; + } + + return $result; + } + + + /** + * @description: 获取供应商详细信息 + * @param {*} $id + * @return {*} + * @Date Changed: + */ + function getDmsDetail($id){ + $sql = "select top 1 * from DMS_Distributor where dt_id = ? "; + $query = $this->INFO->query($sql ,array($id)); + return $query->result(); + + } + + /** + * @description: 删除分销商 + * @param {*} $id + * @return {*} + * @Date Changed: + */ + function dmdDelete($id){ + $sql = " delete from DMS_Distributor where dt_id = ? "; + $qurey = $this->INFO->query($sql ,array($id)); + $result = new stdClass; + if ($qurey){ + $result->status = 1; + $result->msg = "数据删除成功！"; + }else{ + $result->status = 0; + $result->msg = "数据删除失败，请联系管理员!"; + } + return $result; + } + + + function payRecord($arrKeyword){ + $htid = $arrKeyword->htid ==false?0:$arrKeyword->htid; + $page = $arrKeyword->page ==false?0:$arrKeyword->page; + $pagesize = $arrKeyword->per_page>0 ? $arrKeyword->per_page :20; + if ($page < 1) { + $page = 1; + } + + $sql = " SELECT * from ( + SELECT row_number() over (order by dp_id desc) as rownumber,* + ,(select syc2_CodeDiscribe FROM tourmanager.dbo.V_System_Code where SYC_Type=32 AND LGC_LGC=2 AND SYC_SN=dp_HtId) as dmsName + from DMS_PayRecord + where dp_HtId=? + )t "; + + + $sql2 = $sql." Where t.rownumber > ? And t.rownumber <= ?"; + + $begin = ($page - 1) * $pagesize; + $end = $begin + $pagesize; + $qurey = $this->INFO->query($sql,array($htid)); + $count = $qurey->num_rows(); //总记录数 + + $qurey2 = $this->INFO->query($sql2, array($htid,$begin, $end)); + //return 数据和总数 + return array('data' => $qurey2->result(), 'total' => $count); + + + } + + /** + * @description: + * @return {*} + * @Date Changed: + */ + function payrecord_addsave($formData){ + $paymoney = isset($formData->paymoney)?$formData->paymoney:0; + $currency = isset($formData->currency)?$formData->currency:"USD"; + $HtId = isset($formData->HtId)?$formData->HtId:0; + $paytype = isset($formData->paytype)?$formData->paytype:"Train"; + $filluser = isset($formData->filluser)?$formData->filluser:0; + $result = new stdClass; + if ($HtId!=0){ //必须有翰特ID才能进行添加 + + $sql = " insert into DMS_PayRecord (dp_HtId,dp_paymoney,dp_currency,dp_paytype,dp_addtime,dp_filluser,dp_status) values(?,?,?,?,GETDATE(),?,1)"; + $query = $this->INFO->query($sql ,array($HtId,$paymoney,$currency,$paytype,$filluser)); + if ($query === true){ + $result->status = 1; + $result->msg = "数据添加成功！"; + }else{ + $result->status = 0; + $result->msg = "数据插入数据库失败，请联系管理员！"; + } + + + + + }else{ + $result->status = 0; + $result->msg = "企业的翰特ID有错误！"; + } + + return $result; + } + + + function payrecord_delete($id,$htid){ + $sql = " update DMS_PayRecord set dp_status = 0 where dp_id=? and dp_HtId=? "; + $qurey = $this->INFO->query($sql ,array($id,$htid)); + $result = new stdClass; + if ($qurey){ + $result->status = 1; + $result->msg = "数据删除成功！"; + }else{ + $result->status = 0; + $result->msg = "数据删除失败，请联系管理员!"; + } + return $result; + } + +} \ No newline at end of file