|
@@ -2,6 +2,7 @@
|
|
|
|
|
|
namespace Agent\Lib;
|
|
|
|
|
|
+set_time_limit(0);
|
|
|
use Dever;
|
|
|
|
|
|
class Import
|
|
@@ -46,16 +47,34 @@ class Import
|
|
|
}
|
|
|
|
|
|
public function get_api()
|
|
|
+ {
|
|
|
+ $host = 'https://cryl.yijiuguanfang.com/attachment/';
|
|
|
+
|
|
|
+ $state = 1;
|
|
|
+ while($state) {
|
|
|
+ $state = $this->get_data($host, $state);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ return 'ok';
|
|
|
+ }
|
|
|
+
|
|
|
+ public function get_data($host, $index = 0)
|
|
|
{
|
|
|
|
|
|
- $data = $this->db->fetchAll('select * from ims_ewei_shop_member where '.$this->get_yes_where().' order by id asc limit 10');
|
|
|
+ $index = $index - 1;
|
|
|
+ $limit = 1000;
|
|
|
+ $data = $this->db->fetchAll('select * from ims_ewei_shop_member where '.$this->get_yes_where().' order by id asc limit ' . $index . ', ' . $limit);
|
|
|
|
|
|
- print_r($data);die;
|
|
|
+ if (!$data) {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
|
|
|
foreach ($data as $k => $v) {
|
|
|
|
|
|
|
|
|
- $order = Dever::db('agent/order')->find($v['id']);
|
|
|
+ $order = Dever::db('agent/order')->find(array('id' => $v['id'], 'clear' => true));
|
|
|
if (!$order) {
|
|
|
$data = array();
|
|
|
$data['id'] = $v['id'];
|
|
@@ -90,25 +109,34 @@ class Import
|
|
|
if ($data['f_price'] <= 0) {
|
|
|
$data['f_price'] = $data['price'];
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
+ Dever::load('area/api')->upStatus($data['area'], 2);
|
|
|
+ $area_data = array('mid' => $v['id'], 'order_id' => $v['id'], 'role' => $data['role'], 'area' => $data['area']);
|
|
|
+ $area_data['type'] = 4;
|
|
|
+ $area_data['price'] = $data['f_price'];
|
|
|
+ Dever::db('agent/member_area')->insert($area_data);
|
|
|
}
|
|
|
$data['agent_cash'] = $data['f_price'];
|
|
|
|
|
|
- $data['sign'] = $v['contractsign'];
|
|
|
+ $data['sign'] = $v['contractsign'] ? $host . $v['contractsign'] : '';
|
|
|
$data['idcard'] = $v['idnumber'];
|
|
|
+ $data['idcard_front'] = $data['idcard_back'] = '';
|
|
|
if ($v['identity']) {
|
|
|
$identity = Dever::json_decode($v['identity']);
|
|
|
if (isset($identity[0])) {
|
|
|
- $data['idcard_front'] = $identity[0];
|
|
|
+ $data['idcard_front'] = $host . $identity[0];
|
|
|
}
|
|
|
if (isset($identity[1])) {
|
|
|
- $data['idcard_back'] = $identity[1];
|
|
|
+ $data['idcard_back'] = $host . $identity[1];
|
|
|
}
|
|
|
}
|
|
|
$data['company_name'] = $v['company'];
|
|
|
$data['address'] = $v['province'] . $v['city'] . $v['area'] . $v['street'];
|
|
|
|
|
|
$data['pay_type'] = 2;
|
|
|
- $data['pay_pic'] = $v['receipt'];
|
|
|
+ $receipt = Dever::json_decode($v['receipt']);
|
|
|
+ $data['pay_pic'] = $host . $receipt[0];
|
|
|
|
|
|
$data['status'] = $this->getStatus($v);
|
|
|
$data['audit_desc'] = $v['refuse'];
|
|
@@ -119,18 +147,36 @@ class Import
|
|
|
$data['goods_status'] = 1;
|
|
|
}
|
|
|
$data['pay_status'] = 2;
|
|
|
+ $data['import'] = $v['olduid'] > 0 ? 3 : 2;
|
|
|
|
|
|
$data['order_num'] = Dever::load('agent/lib/order')->getOrderId();
|
|
|
- $data['cdate'] = $v['createtime'];
|
|
|
+ $data['cdate'] = $v['agentapplytime'];
|
|
|
if ($data['status'] == 4) {
|
|
|
- $data['fdate'] = 1;
|
|
|
+ $data['fdate'] = $v['agenttime'];
|
|
|
}
|
|
|
+ $data['order_type'] = 1;
|
|
|
+ $data['company_pic'] = '';
|
|
|
$order_id = Dever::db('agent/order')->insert($data);
|
|
|
|
|
|
if ($order_id) {
|
|
|
|
|
|
+ if (!$v['preagenttime']) {
|
|
|
+ $v['preagenttime'] = $v['agenttime'];
|
|
|
+ }
|
|
|
if ($data['status'] == 2) {
|
|
|
+ $this->addProcess($order_id, 1, $v['preagenttime'], $data);
|
|
|
+ } elseif ($data['status'] == 3) {
|
|
|
+ $this->addProcess($order_id, 1, $v['preagenttime'], $data);
|
|
|
+ $this->addProcess($order_id, 2, $v['agenttime'], $data);
|
|
|
+ } elseif ($data['status'] == 4) {
|
|
|
+ $this->addProcess($order_id, 1, $v['preagenttime'], $data);
|
|
|
+ $this->addProcess($order_id, 2, $v['agenttime'], $data);
|
|
|
+ $this->addProcess($order_id, 3, $v['agenttime'], $data);
|
|
|
+ }
|
|
|
|
|
|
+
|
|
|
+ if ($data['sign']) {
|
|
|
+ $this->addAgreement($data);
|
|
|
}
|
|
|
|
|
|
$member = Dever::db('agent/member')->find($v['id']);
|
|
@@ -143,9 +189,12 @@ class Import
|
|
|
} else {
|
|
|
$data['status'] = 1;
|
|
|
}
|
|
|
+ $mc_member = $this->db->fetch('select * from ims_mc_members where uid = ' . $v['uid']);
|
|
|
$data['rdate'] = $v['agenttime'];
|
|
|
- $data['cash'] = $v['credit2'];
|
|
|
+ $data['cash'] = ($mc_member && $mc_member['credit2']) ? $mc_member['credit2'] : $v['credit2'];
|
|
|
$data['group_sell'] = $v['allcommission'];
|
|
|
+
|
|
|
+ Dever::load('invite/api')->setRelation($data['mid'], $data['parent_mid']);
|
|
|
if (!$member) {
|
|
|
Dever::db('agent/member')->insert($data);
|
|
|
} else {
|
|
@@ -155,7 +204,46 @@ class Import
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- print_r($data);die;
|
|
|
+ $index = $index + 1;
|
|
|
+ return $index * $limit;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ private function getRelation()
|
|
|
+ {
|
|
|
+ $data = $this->db->fetchAll('select * from ims_ewei_shop_commission_relation');
|
|
|
+ if ($data) {
|
|
|
+ foreach ($data as $k => $v) {
|
|
|
+ $where['uid'] = $v['pid'];
|
|
|
+ $where['to_uid'] = $v['id'];
|
|
|
+ $where['level'] = $v['level'];
|
|
|
+ $info = Dever::db('invite/relation')->one($where);
|
|
|
+ if (!$info) {
|
|
|
+ Dever::db('invite/relation')->insert($where);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ private function addAgreement($data)
|
|
|
+ {
|
|
|
+ Dever::load('agent/lib/agreement')->up($data);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ private function addProcess($order_id, $status, $time, $data)
|
|
|
+ {
|
|
|
+ $where['order_id'] = $order_id;
|
|
|
+ $where['status'] = $status;
|
|
|
+ $info = Dever::db('agent/order_process')->find($where);
|
|
|
+ if (!$info) {
|
|
|
+ if ($status == 3) {
|
|
|
+ $where['type'] = '1,2,3,5';
|
|
|
+ }
|
|
|
+ $where['cdate'] = $time;
|
|
|
+ Dever::db('agent/order_process')->insert($where);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
|
|
@@ -165,7 +253,7 @@ class Import
|
|
|
if ($data['issuingstate'] == 1 && $data['status'] == 1 && $data['prestatus'] == 1) {
|
|
|
return 4;
|
|
|
} elseif ($data['status'] == 1 && $data['prestatus'] == 1) {
|
|
|
- return 3;
|
|
|
+ return 4;
|
|
|
} elseif ($data['prestatus'] == 1) {
|
|
|
return 2;
|
|
|
} elseif ($data['restatus'] == 1) {
|