admin/liche
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add-api-create_clues

Browse Source
This commit is contained in:
lccsw
2021-10-12 10:10:31 +08:00
parent 20297a42e6
commit 52a6d2880d
8 changed files with 237 additions and 245 deletions
Download Patch File Download Diff File Expand all files Collapse all files
admin/controllers/receiver/Customer.php
-32
View File
@@ -426,37 +426,5 @@ class Customer extends HD_Controller
return $id;
}
//更新晓致电话数据
public function get_update_xz()
{
$page = $this->input->get('page');
$size = $this->input->get('size');
$lk = $this->input->get('lk');
!$page && $page = 1;
!$size && $size = 10;
$where = [
'cf_title' => 'customer',
'cf_platform' => 'api',
'status' => 1
];
if ($lk) {
$rows = $this->receiver_xz_model->select($where, 'id desc', $page, $size, 'id,biz_id');
print_r($rows);
exit;
}
$total = $this->receiver_xz_model->count($where);
$rows = $this->receiver_xz_model->select($where, 'id desc', $page, $size, 'id,cf_id');
if ($rows) {
foreach ($rows as $key => $val) {
$row = $this->customers_model->get(['id' => $val['cf_id']], 'biz_id');
if ($row) {
$this->receiver_xz_model->update(['biz_id' => $row['biz_id']], ['id' => $val['id']]);
}
}
echo "total:{$total},剩余:" . ($total - $page * $size);
} else {
echo "finish";
}
}
}
api/controllers/wxapp/distribution/Home.php
+1
View File
@@ -66,6 +66,7 @@ class Home extends Wxapp
!$this->session['up_uid'] && $this->session['dealer'] && $menulist[] = ['title' => '我的团队', 'url' => '/pages/distribute/team/index', 'img' => $img_url . '/distribute/icon-tuandui.png'];
}
$this->session['manage'] && $menulist[] = ['title' => '分销管理', 'url' => '/pages/distribute/apply/index', 'img' => $img_url . '/distribute/icon-shenqing.png'];
$menulist[] = ['title' => '报备线索', 'url' => '/pages/distribute/clue/index', 'img' => $img_url . '/distribute/icon-sucai.png'];
$menulist[] = ['title' => '联系小狸', 'url' => '', 'img' => $img_url . '/distribute/icon-kefu.png'];
$data = array(
"title" => '分销',
api/controllers/wxapp/liche/Aptinfo.php
+1 -1
View File
@@ -131,8 +131,8 @@ class Aptinfo extends Wxapp{
$cms_json = json_decode($cms_row['jsondata'],true);
$cms_json['cfrom_id'] && $cf_id = $cms_json['cfrom_id'];
$brand_row = $this->auto_brand_model->get(['id'=>$cms_row['target_id']]);
$recommend_id && $cf_id = 8;
}
//$row = $this->clues_model->get(['cf_id'=>$cf_id,'cf_uid'=>$uid,'app_id'=>$this->app_id,'status'=>0]);
$row = $this->clues_model->get(['mobile'=>$this->session['mobile'],'app_id'=>$this->app_id]);
if($row){
$update = [
api/controllers/wxapp/liche/Clues.php
+190 -212
View File
@@ -17,236 +17,214 @@ class Clues extends Wxapp{
$this->check_status = array();//用户状态校验
$this->check_mobile = array();//需要手机号
$this->check_headimg =array();//授权微信信息
$this->load->model('receiver/receiver_clues_model');
$this->load->model('receiver/receiver_clue_oplogs_model');
$this->load->model('receiver/order/receiver_orders_model');
$this->load->model('auto/auto_brand_model');
}
protected function get(){
$id = $this->input_param('id');
$type = $this->input_param('type');
!strlen($type) && $type = 0;
$row = $this->orders_model->get(['id'=>$id,'mobile'=>$this->session['mobile']]);
$type_arr = $this->contracts_model->get_types();
if(!$row || !$type_arr[$type]){
throw new Exception('参数错误', API_CODE_INVILD_PARAM);
}
$contract = $this->contracts_model->get(['type'=>$type,'o_id'=>$id]);
$this->load->library('receiver/orders_entity');
$this->load->library('pdf');
list($h5_url,$title) = $this->orders_entity->get_contract_h5($id,$type,1);
list($pdf2img_url,$title) = $this->orders_entity->get_contract_h5($id,$type);
if(!$contract){
$add_data = [
'o_id' => $id,
'type' => $type,
'c_time' => time()
];
$con_id = $this->contracts_model->add($add_data);
if(!$con_id){
throw new Exception('创建合同失败', API_CODE_INVILD_PARAM);
}
$cid = create_contract_no(350200,$con_id,$type);
$this->contracts_model->update(['cid'=>$cid],['id'=>$con_id]);
//html转pdf
$save_path = 'data/contracts/'.date('Ymd');
$filename = $cid.'.pdf';
$c_res = $this->pdf->html2pdf($pdf2img_url,FCPATH.$save_path,$filename);
$update = [
'file' => $save_path.'/'.$filename,
'cid' => $cid
];
$this->contracts_model->update($update,['id'=>$con_id]);
if($id){
return $this->detail($id);
}else{
if(!$contract['status'] && date('Ymd')!=date('Ymd',$contract['c_time'])){ //更新合同文件日期
//html转pdf
@unlink(FCPATH.$contract['file']);
$save_path = 'data/contracts/'.date('Ymd');
$filename = $contract['cid'].'.pdf';
$c_res = $this->pdf->html2pdf($h5_url,FCPATH.$save_path,$filename);
$update = [
'file' => $save_path.'/'.$filename,
'c_time' => time()
return $this->lists();
}
}
protected function post(){
$cf_id = 8;
$name = $this->input_param('name');
$mobile = $this->input_param('mobile');
$brand_id = $this->input_param('brand_id');
$remark = $this->input_param('remark');
if(!$mobile||!$name||!$brand_id){
throw new Exception('参数错误', ERR_PARAMS_ERROR);
}
if(!mobile_valid($mobile)){
throw new Exception('手机号格式错误', ERR_PARAMS_ERROR);
}
$row = $this->receiver_clues_model->get(['app_id'=>$this->app_id,'mobile'=>$mobile,'cf_uid'=>$this->session['uid']]);
if($row){
throw new Exception('该手机号已报备', ERR_PARAMS_ERROR);
}
$add_data = [
'app_id' => $this->app_id,
'name' => $name,
'mobile' => $mobile,
'brand_id' => $brand_id,
'recommend_id' => $this->session['uid'],
'cf_uid' => $this->session['uid'],
'cf_id' => $cf_id,
'cf_platform' => 'wxapp',
'en_time' => date('Y-m-d H:i:s'),
'c_time' => time()
];
$res = $this->receiver_clues_model->add($add_data);
if(is_numeric($res)){
if($remark){ //添加日志
$this->load->library('receiver/clues_entity');
$this->clues_entity->add_log($res,$this->session['uid'],$this->session['nickname'],$remark);
}
throw new Exception('保存成功', API_CODE_SUCCESS);
}else{
throw new Exception('保存失败', ERR_PARAMS_ERROR);
}
}
protected function get_tabs(){
$uid = $this->session['uid'];
$recommend_id = [$uid];
$l_user = $this->app_user_model->select(['up_uid'=>$uid],'','','','id'); //下一级用户
if($l_user){
$l_user_ids = array_column($l_user,'id');
$recommend_id = array_merge($l_user_ids,$recommend_id);
}
$recommend_id_str = implode(',',$recommend_id);
$where = [
'app_id' => $this->app_id,
"recommend_id in ($recommend_id_str)" => null,
'status' => 0
];
$count = $this->receiver_clues_model->count($where);
$lists = [
['key' =>0 ,'name' => '全部','nums' => 0],
['key' =>1 ,'name' => '待确认','nums' => $count],
['key' =>2 ,'name' => '有效','nums' => 0],
['key' =>3 ,'name' => '无效','nums' => 0],
];
return $lists;
}
private function lists(){
$uid = $this->session['uid'];
$page = $this->input_param('page');
$size = $this->input_param('size');
$type = $this->input_param('type');
!$type && $type = 0;
!$page && $page = 1;
!$size && $size = 20;
$list = [];
$recommend_id = [$uid];
$l_user = $this->app_user_model->select(['up_uid'=>$uid],'','','','id'); //下一级用户
if($l_user){
$l_user_ids = array_column($l_user,'id');
$recommend_id = array_merge($l_user_ids,$recommend_id);
}
$recommend_id_str = implode(',',$recommend_id);
$where = [
'app_id' => $this->app_id,
"recommend_id in ($recommend_id_str)" => null
];
$total = $this->receiver_clues_model->count($where); //总数
if($type==1){ //待确认
$where["lc_receiver_orders.id is null"] = null;
$where["lc_receiver_clues.status !="] =3;
}elseif($type==2){ //有效
$where['lc_receiver_orders.id >'] = 0;
}elseif($type==3){
$where['lc_receiver_clues.status'] = 3;
}
$count = $this->receiver_clues_model->selectClues($where,'','','',1);
if($count){
$rows = $this->receiver_clues_model->selectClues($where,'id desc',$page,$size);
foreach($rows as $key=>$val){
if($val['cf_uid']==$uid){
$cfrom = '自带客';
}else{
$user = $this->app_user_model->get(['id'=>$val['recommend_id']],'nickname');
$cfrom = "团队带客({$user['nickname']})";
}
if($val['status']==3){ //无效
$status_cor = "#666";
$status_cn = '无效';
}elseif($val['o_id']){ //有效
$status_cor = "#f9394d";
$status_cn = '有效';
}else{ //待确认
$status_cor = "#f9394d";
$status_cn = '待确认';
}
$list[] = [
'id' => $val['id'],
'name' => $val['name'],
'mobile' => mobile_asterisk($val['mobile']),
'status' => [
'color' => $status_cor,
'text' => $status_cn
],
'cfrom' => $cfrom,
'c_time' => date('Y-m-d H:i:s',$val['c_time']),
];
$this->contracts_model->update($update,['id'=>$contract['id']]);
}
}
$data = [
'title' => $title,
'url' => $h5_url,
'img' => 'https://qs.haodian.cn/wechat_app/liche/mine/he-demo-2.jpg',
'list' => $list,
'total' => $count,
'all_total' => $total
];
return $data;
}
protected function post(){
$uid = $this->session['uid'];
$id = $this->input_param('id');
$type = $this->input_param('type');
$img = $this->input_param('img');
$row = $this->contracts_model->get(['type'=>$type,'o_id'=>$id]);
$order = $this->orders_model->get(['id'=>$id],'biz_id,ifentrust,pack_id,info_json');
if(!$row['file'] || !$img){
throw new Exception('参数错误', API_CODE_INVILD_PARAM);
}
$jsondata = json_decode($order['info_json'],true);
if($row['status']==1){
throw new Exception('已签名', API_CODE_INVILD_PARAM);
private function detail($id){
$row = $this->receiver_clues_model->get(['id'=>$id]);
if(!$row){
throw new Exception('数据不存在', ERR_PARAMS_ERROR);
}
//获取公司印章
if($type==1){
$company = $this->sys_company_model->get(["title like '%服务%'"=>null,'status'=>1],'img_seal,id');
$order = $this->receiver_orders_model->get(['clue_id'=>$row['id'],'status>='=>0]);
if($row['status']==3){ //无效
$status_cn = '无效';
}elseif($order){ //有效
$status_cn = '有效';
}else{ //待确认
$status_cn = '待确认';
}
$brand = $this->auto_brand_model->get(['id'=>$row['brand_id']],'name');
if($row['recommend_id']!=$this->session['uid']){
$user = $this->app_user_model->get(['id'=>$row['recommend_id']],'nickname');
$cfrom = "团队带客({$user['nickname']})";
}else{
$biz = $this->biz_model->get(['id'=>$order['biz_id']],'company_id');
$company = $this->sys_company_model->get(['id'=>$biz['company_id']],'img_seal,id');
$cfrom = '自带客';
}
$img_seal = $company['img_seal'] ? build_qiniu_image_url($company['img_seal']) : '';
if(!$img_seal){
throw new Exception('公司公章未上传', API_CODE_FAIL);
}
//pdf转图片
$pdf_url = http_host_com('api').'/'.$row['file'];
$this->load->library('pdf');
$pdf = new Pdf(); //正式
$imgs = $pdf->pdf2img($pdf_url);
if(!$imgs){
throw new Exception('签名失败,图片转换失败', API_CODE_INVILD_PARAM);
}
$redis = load_cache('redis');
$cache_key = "CONTRACT_{$id}_{$uid}_{$type}";
if($redis->get($cache_key)){
throw new Exception('请求太频繁,请刷新查看结果', API_CODE_INVILD_PARAM);
}
$redis->save($cache_key,1,60*1);
$this->load->library('receiver/sign_entity');
$sign_entity = new Sign_entity(['comp_img'=>$img_seal]);
switch($type){
case 0: //整车
$sign_img = array_pop($imgs);
$height = $order['ifentrust'] ? 480 : 380;
$jsondata['c_cardid'] && $height += 30;
$res = $sign_entity->merge($sign_img,$img,1070,$height,230);
if(!$res){
throw new Exception('签名失败', API_CODE_INVILD_PARAM);
}
$imgs[] = http_host_com('api').'/'.$res;
$imgs = $this->up_qiniu($imgs,$res);
$update = [
'imgs' => json_encode($imgs,JSON_UNESCAPED_UNICODE),
'sign_time' => date('Y-m-d H:i:s'),
'status' => 1
$mobile = mobile_asterisk($row['mobile']);
//获取日志
$logs = [];
$where = [
'clue_id' => $row['id']
];
$log_rows = $this->receiver_clue_oplogs_model->select($where,'id desc',1,20,'id,log,c_time');
if($log_rows){
foreach($log_rows as $key=>$val){
$logs[] = [
'id' => $val['id'],
'log' => $val['log'],
'c_time' => date('Y-m-d H:i:s',$val['c_time'])
];
$result = $this->contracts_model->update($update,['id'=>$row['id']]);
if($result){
$redis->delete($cache_key);
throw new Exception('签名成功', API_CODE_SUCCESS);
}else{
throw new Exception('签名失败', API_CODE_INVILD_PARAM);
}
break;
case 1: //协议
$sign_img = array_pop($imgs);
$package = $this->package_model->get(['id'=>$order['pack_id']],'srv_ids');
$srv_count = $package ? count(explode(',',$package['srv_ids'])) : 0;
$height = $order['ifentrust'] ? 1400 : 1280;
$jsondata['c_cardid'] && $height += 30;
$height += $srv_count*52;
$res = $sign_entity->merge($sign_img,$img,1050,$height,300);
if(!$res){
throw new Exception('签名失败', API_CODE_INVILD_PARAM);
}
$imgs[] = http_host_com('api').'/'.$res;
$imgs = $this->up_qiniu($imgs,$res);
$update = [
'imgs' => json_encode($imgs,JSON_UNESCAPED_UNICODE),
'sign_time' => date('Y-m-d H:i:s'),
'status' => 1
];
$result = $this->contracts_model->update($update,['id'=>$row['id']]);
if($result){
$this->load->library('receiver/orders_entity');
$this->orders_entity->sign_after_v2($id,$this->session);
$redis->delete($cache_key);
throw new Exception('签名成功', API_CODE_SUCCESS);
}else{
throw new Exception('签名失败', API_CODE_INVILD_PARAM);
}
break;
case 2: //确认信息
$sign_img = array_pop($imgs);
$height = $order['ifentrust'] ? 600 : 480;
$jsondata['c_cardid'] && $height += 30;
$res = $sign_entity->merge($sign_img,$img,1050,$height,300);
if(!$res){
throw new Exception('签名失败', API_CODE_INVILD_PARAM);
}
$imgs[] = http_host_com('api').'/'.$res;
$imgs = $this->up_qiniu($imgs,$res);
$update = [
'imgs' => json_encode($imgs,JSON_UNESCAPED_UNICODE),
'sign_time' => date('Y-m-d H:i:s'),
'status' => 1
];
$result = $this->contracts_model->update($update,['id'=>$row['id']]);
if($result){
$this->ckcars_model->update(['status'=>2],['o_id'=>$id]);
//生成支付订单
$this->load->library('receiver/orders_entity');
$this->orders_entity->check_finish_v2($id,$this->session);
$redis->delete($cache_key);
throw new Exception('签名成功', API_CODE_SUCCESS);
}else{
throw new Exception('签名失败', API_CODE_INVILD_PARAM);
}
break;
case 3: //车辆交接
$sign_img = array_pop($imgs);
$height = $order['ifentrust'] ? 1470 : 1350;
$res = $sign_entity->merge($sign_img,$img,1050,$height,350);
if(!$res){
throw new Exception('签名失败', API_CODE_INVILD_PARAM);
}
$imgs[] = http_host_com('api').'/'.$res;
$imgs = $this->up_qiniu($imgs,$res);
$update = [
'imgs' => json_encode($imgs,JSON_UNESCAPED_UNICODE),
'sign_time' => date('Y-m-d H:i:s'),
'status' => 1
];
$result = $this->contracts_model->update($update,['id'=>$row['id']]);
if($result){
$this->deliverys_model->update(['status'=>1],['o_id'=>$id]);
$redis->delete($cache_key);
throw new Exception('签名成功', API_CODE_SUCCESS);
}else{
throw new Exception('签名失败', API_CODE_INVILD_PARAM);
}
break;
default:
$redis->delete($cache_key);
throw new Exception('未知签名类型', API_CODE_INVILD_PARAM);
}
}
//图片上传七牛
private function up_qiniu($imgs,$file){
$this->load->library('qiniu');
//上传七牛并保存
foreach($imgs as $key=>$val){
$file_name = md5($val).'.jpg';
$result = $this->qiniu->fetch($val,$file_name);
if($result){
$imgs[$key] = $result['file'];
if (strpos($val, $file) !== false) {
@unlink(FCPATH.$file);
}
}
}
return $imgs;
//获取账单记录
$mlogs = [];
//$mlogs[] = [
// 'id' => 1,
// 'title' => '报备佣金',
// 'money' => '+500元',
// 'status' => '有效',
// 'c_time' => date('Y-m-d H:i:s')
//];
$data = [
'title' => "{$row['name']}·{$mobile}",
'brand' => $brand['name'],
'cfrom' => $cfrom,
'status' => $status_cn,
'c_time' => date('Y-m-d H:i:s',$row['c_time']),
'logs' => $logs,
'mlogs' => $mlogs
];
return $data;
}
}
api/controllers/wxapp/liche/Statistics.php
+13
View File
@@ -30,9 +30,15 @@ class Statistics extends Wxapp{
'lc_receiver_orders.status' => 6
];
$done = $this->clues_model->count_order($where);
$where = [
'lc_receiver_clues.recommend_id' => $uid,
'lc_receiver_orders.status>' => 0
];
$ispay = $this->clues_model->count_order($where);
$data = [
['name'=>'浏览','value'=>intval($brower['browse_num'])],
['name'=>'报名','value'=>$clues],
['name'=>'下定','value'=>$ispay],
['name'=>'成交','value'=>$done]
];
return $data;
@@ -61,10 +67,17 @@ class Statistics extends Wxapp{
'lc_receiver_orders.status' => 6
];
$done = $this->clues_model->count_order($where);
$where = [
'lc_receiver_clues.recommend_id' => $uid,
'lc_receiver_clues.brand_id' => $val['id'],
'lc_receiver_orders.status>' => 0
];
$ispay = $this->clues_model->count_order($where);
$commision = 0;
$list[] = [
'title' => $val['name'],
'enroll' => $enroll,
'ispay' => $ispay,
'done' => $done,
'commision' => number_format($done*500,2)
];
api/controllers/wxapp/licheb/Cusorder.php
+1
View File
@@ -185,6 +185,7 @@ class Cusorder extends Wxapp{
}
$data['money_json'] = json_encode($money_json,JSON_UNESCAPED_UNICODE);
$row['rid'] && $data['clue_id'] = $row['rid'];
$o_id = $this->orders_model->add($data);
if($o_id){
$sign_data = [
common/models/receiver/Receiver_clues_model.php
+30
View File
@@ -71,4 +71,34 @@ class Receiver_clues_model extends HD_Model
$this->db->limit($limit, $offset);
return $this->db->get()->result_array();
}
public function selectClues($where = array(), $order = '', $page = 0, $page_size = 20, $count = 0){
$this->db->from('lc_receiver_clues');
$this->db->join('lc_receiver_orders', 'lc_receiver_orders.clue_id = lc_receiver_clues.id and lc_receiver_orders.status>=0', 'left');
if ($where) {
$this->db->where($where);
}
if ($count) {
$this->db->distinct()->select('lc_receiver_clues.*');
return $this->db->count_all_results();
}else{
$this->db->select('lc_receiver_clues.*,lc_receiver_orders.id as o_id');
$this->db->group_by('lc_receiver_clues.id');
}
if ($order) {
$this->db->order_by($order);
}
if ($page) {
$offset = ($page - 1) * $page_size;
$limit = $page_size;
} else {
$offset = null;
$limit = null;
}
$this->db->limit($limit, $offset);
return $this->db->get()->result_array();
}
}
sql/receiver/order.sql
+1
View File
@@ -162,6 +162,7 @@ drop table if exists lc_receiver_orders;
create table lc_receiver_orders (
id int(10) unsigned not null auto_increment comment '自增id',
rid int(10) not null default '0' comment '客户池id',
clue_id int(10) not null default '0' comment '线索id',
sid varchar(32) not null comment '订单号',
name varchar(32) not null comment '客户姓名',
mobile varchar(11) not null comment '客户手机号码',