Commit 8c23baae authored by hujun's avatar hujun

绑定手机号修改

parent c124d813
......@@ -26,7 +26,7 @@ class CellPhone extends Basic
/**
* 绑定手机号
* 解绑之后有延迟
* 解绑之后有延迟(15s)
*
* @return \think\Response
* @throws \think\Exception
......@@ -37,9 +37,8 @@ class CellPhone extends Basic
public function bindAXB()
{
header('Access-Control-Allow-Origin:*');
$params = $this->request->param();
if (empty($params['phone_a']) || empty($params['phone_b'])) {
if (empty($this->params['phone_a']) || empty($this->params['phone_b'])) {
$this->code = 101;
$this->msg = 'phone_a or phone_b is null';
return $this->response(101, '参数错误,请联系运营人员!');
......@@ -54,7 +53,7 @@ class CellPhone extends Basic
//0不使用隐私号码 1阿里云 2容联云
if ($is_privacy == 0) {
$this->data = ['phone' => $phone_b];
$this->data = [ 'phone' => $phone_b ];
$m_report = new SecretReport();
$report_data['phone_no'] = $phone_a;
......@@ -67,7 +66,6 @@ class CellPhone extends Basic
return $this->response($this->code, $this->msg, $this->data);
}
$aliYunPhone = new AliYunPhone();
$bind = new BindingPhone();
$where['a.status'] = 1;
$where['a.phone_a'] = $phone_a;
......@@ -77,18 +75,11 @@ class CellPhone extends Basic
$phone_x = $bind->getPhoneX('b.phone_x', $where); //已经绑定的返回隐私号码
if (!empty($phone_x['phone_x'])) {
$this->data = ['phone' => $phone_x['phone_x']];
$this->data = [ 'phone' => $phone_x['phone_x'] ];
$this->msg = '已绑定,返回隐私号码。';
return $this->response($this->code, $this->msg, $this->data); //绑定过了,返回隐号
}
$phone_x = $aliYunPhone->getAliYunPhone($phone_a, $phone_b, $is_privacy); //获取未绑定隐号
if (empty($phone_x)) {
$this->code = 102;
$this->msg = '号码使用完,请联系运营人员。';
return $this->response($this->code, $this->msg, $this->data);
}
$day_num = $redis->get('s_day_num');
if (empty($day_num)) {
......@@ -105,32 +96,26 @@ class CellPhone extends Basic
if ($is_privacy == 1) {
/*阿里云*/
$result = PlsDemo::bindAxb($phone_a, $phone_b, $time, $record, $phone_x['phone_x']);
if ($result->Message == 'OK') {
$aliYunPhone->editStatus($phone_x, $phone_a, $phone_b, $record, $time, $result, '', $is_privacy); //记录绑定
$this->msg = '绑定成功。';
$this->data = ['phone' => $phone_x['phone_x']];
} else {
$phone_x_array[] = $phone_x['phone_x'];
//尝试5次绑定
for ($i = 1; $i < 5; $i++) {
$phone_x = $aliYunPhone->getAliYunPhone($phone_a, $phone_b, $is_privacy, $phone_x_array);
$result = PlsDemo::bindAxb($phone_a, $phone_b, $time, $record, $phone_x); //再尝试一下
if ($result->Message == 'OK') {
$aliYunPhone->editStatus($phone_x, $phone_a, $phone_b, $record, $time, $result, '', $is_privacy); //记录绑定
$this->msg = '绑定成功。';
$this->data = ['phone' => $phone_x['phone_x']];
break;
} else {
$phone_x_array[] = $phone_x; //记录绑定冲突号码,重新分配
}
try {
$result = PlsDemo::bindAxb($phone_a, $phone_b, $time, $record);
} catch (\Exception $e) {
return $this->response(101, '参数异常,无法呼叫,请联系运营人员!');
}
if ($result->Message != 'OK') {
if ($result->Code == 'OK') {
//记录绑定
$bind->recordBindPhone($result->SecretBindDTO->SecretNo, $phone_a, $phone_b, $record, $time, $result, '', $is_privacy);
$this->msg = '绑定成功。';
$this->data = [ 'phone' => $result->SecretBindDTO->SecretNo ];
} elseif ($result->Code == 'isv.NO_AVAILABLE_NUMBER') {
$this->code = 101;
$this->msg = '拨号失败,10秒再试,再无法拨号请联系请联系运营人员!';
}
$this->msg = '号码使用完,请联系运营人员。';
} else {
$this->code = 101;
$this->msg = '拨号失败,15秒再试,再无法拨号请联系请联系运营人员!';
}
} else {
/*容联云*/
......@@ -147,9 +132,10 @@ class CellPhone extends Basic
/*绑定成功*/
if ($result['statusCode'] == '000000') {
$aliYunPhone = new AliYunPhone();
$aliYunPhone->editStatus($phone_x, $phone_a, $phone_b, $record, $time, 0, $result['data']['mappingId'], $is_privacy); //记录绑定
$this->msg = 'Binding Rong success';
$this->data = ['phone' => $phone_x['phone_x']];
$this->data = [ 'phone' => $phone_x['phone_x'] ];
} else {
$this->code = 101;
$this->msg = '操作频繁,请10秒后再操作。';
......@@ -216,7 +202,7 @@ class CellPhone extends Basic
$redis = RedisExt::getRedis();
$is_privacy = $redis->get('s_is_privacy');
$is_privacy = $is_privacy != '0' ? $is_privacy : 0;
if ($is_privacy == 1) {
/*阿里云*/
$subsId = $phone->getSubsId($phone_x, $phone_a, $phone_b, 1, 'subsId');
......@@ -232,7 +218,7 @@ class CellPhone extends Basic
$this->code = 200;
$this->msg = '没有号码绑定关系,请忽略!。';
}
} else {
} elseif ($is_privacy == 2) {
/*容联云*/
$mappingId = $phone->getSubsId($phone_x, $phone_a, $phone_b, 1, 'mappingId');
$Rong = new RongDemo();
......@@ -250,8 +236,11 @@ class CellPhone extends Basic
$this->code = 101;
$this->msg = 'dont\'t have about phone_x info';
}
} else {
$this->code = 200;
$this->msg = '没有号码绑定关系,请忽略!。';
}
$this->params['phone_x'];
return $this->response($this->code, $this->msg);
}
......
......@@ -80,7 +80,7 @@ class PlsDemo
* @param string $phoneNoX 中间号码
* @return mixed|\SimpleXMLElement
*/
public static function bindAxb($phoneA, $phoneB, $time, $isRecordingEnabled=false, $phoneNoX = '17091955105') {
public static function bindAxb($phoneA, $phoneB, $time, $isRecordingEnabled=false, $phoneNoX = '') {
//组装请求对象-具体描述见控制台-文档部分内容
$request = new BindAxbRequest();
......
......@@ -88,18 +88,19 @@ class BindingPhone extends BaseModel
/**
* 获取phone_x
*
* @param $field
* @param $where
* @param string $field
* @param array $where
* @return array|false|\PDOStatement|string|\think\Model
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function getPhoneX($field, $where) {
public function getPhoneX($field = '', $where = []) {
return $this->alias('a')
->field($field)
->join('aliYun_phone b','a.aliYun_phone_id=b.id','left')
->where($where)
->order('a.id desc')
->find();
}
......@@ -137,4 +138,48 @@ class BindingPhone extends BaseModel
$this->update(['status' => 0, 'id' => $id]);
return ;
}
/**
* @param $phone_x
* @param $phone_a
* @param $phone_b
* @param $record
* @param $time
* @param $result
* @param string $mappingId
* @param int $type
* @return int|string
*/
/**
* @param $phone_x
* @param $phone_a
* @param $phone_b
* @param $record
* @param $time
* @param $result
* @param string $mappingId
* @param int $type
* @return int|string
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function recordBindPhone($phone_x, $phone_a, $phone_b,$record,$time,$result,$mappingId='',$type=1) {
$m_ali_phone = new AliYunPhone();
$phone_id = $m_ali_phone->field('id,bind_num')->where('phone_x', $phone_x)->find();
$phone_id['bind_num'] += 1;
$m_ali_phone->where('id',$phone_id['id'])->update(['bind_num'=>$phone_id['bind_num']]);
$insert_data['phone_a'] = $phone_a;
$insert_data['phone_b'] = $phone_b;
$insert_data['subsId'] = $result->SecretBindDTO->SubsId;
$insert_data['requestId'] = $result->RequestId;
$insert_data['mappingId'] = $mappingId;
$insert_data['record'] = $record;
$insert_data['aliYun_phone_id'] = $phone_id['id'];
$insert_data['expiry_date'] = $time;
$insert_data['type'] = $type;
$insert_data['status'] = 1;
return $this->insert($insert_data);
}
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment