Import.php 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611
  1. <?php
  2. namespace Agent\Lib;
  3. set_time_limit(0);
  4. use Dever;
  5. class Import
  6. {
  7. # 图片存放地址
  8. private $img_host = 'https://cryl.yijiuguanfang.com/attachment/';
  9. public function __construct()
  10. {
  11. $this->db = Dever::db('agent/test:old');
  12. }
  13. # 获取已审核的条件
  14. private function get_yes_where()
  15. {
  16. //issuingstate=1 已发放权益
  17. return 'restatus = 0 and status = 1 and prestatus = 1 and isagent = 1';
  18. }
  19. # 获取审核失败的条件
  20. private function get_no_where()
  21. {
  22. //issuingstate=1 已发放权益
  23. return 'restatus = 1 and isagent = 1';
  24. }
  25. # 获取待审核的条件
  26. private function get_where()
  27. {
  28. //issuingstate=1 已发放权益
  29. return 'restatus = 0 and status = 0 and isagent = 1 and contractstatus = 1';
  30. }
  31. # 获取sql
  32. public function get_sql_api()
  33. {
  34. $table['已审核'] = 'select count(*) as num,mobile from ims_ewei_shop_member where '.$this->get_yes_where().' group by mobile order by num desc';
  35. $table['审核失败'] = 'select count(*) as num,mobile from ims_ewei_shop_member where '.$this->get_no_where().' group by mobile order by num desc';
  36. $table['待审核'] = 'select count(*) as num,mobile from ims_ewei_shop_member where '.$this->get_where().' group by mobile order by num desc';
  37. echo Dever::table($table);die;
  38. }
  39. public function get_api()
  40. {
  41. Dever::config('base')->hook = true;
  42. $host = 'https://cryl.yijiuguanfang.com/attachment/';
  43. $state = 1;
  44. while($state) {
  45. $state = $this->get_data($host, $state);
  46. }
  47. # 导入关联表
  48. //$this->getRelation();
  49. # 导入地区价格
  50. //$this->getAreaPrice();
  51. # 导入余额 不导入了
  52. //$this->getYue();
  53. return 'ok';
  54. }
  55. public function get_data($host, $index = 0)
  56. {
  57. # 获取已审核通过、权益已发放的用户
  58. $index = $index - 1;
  59. $limit = 1000;
  60. $data = $this->db->fetchAll('select * from ims_ewei_shop_member where status = 1 and prestatus = 1 and isagent = 1 order by id asc limit ' . $index . ', ' . $limit);
  61. if (!$data) {
  62. return false;
  63. }
  64. foreach ($data as $k => $v) {
  65. # 创建订单
  66. $order = Dever::db('agent/order')->find(array('id' => $v['id'], 'clear' => true));
  67. if (!$order) {
  68. $data = array();
  69. $data['id'] = $v['id'];
  70. $data['mobile'] = $v['mobile'];
  71. $data['name'] = $v['realname'];
  72. $data['avatar'] = $v['avatar'];
  73. $data['username'] = $v['nickname'];
  74. $data['mid'] = $v['id'];
  75. $data['parent_mid'] = $v['agentid'];
  76. $data['admin_desc'] = $v['content'];
  77. $data['parent_code'] = Dever::load("invite/api.code", $data['parent_mid']);
  78. $data['address'] = $v['province'] . $v['city'] . $v['area'] . $v['street'];
  79. $data['role'] = $this->getRole($v['agentlevel']);
  80. $data['area'] = '';
  81. if ($v['datavalue']) {
  82. list($data['area'], $new) = Dever::load('area/api')->up($v['province'], $v['city'], $v['area'], $v['street'], $v['datavalue'], $v['streetvalue']);
  83. # 记录日志
  84. if ($new) {
  85. $this->log($v['id'], 4, $data['address'], $new);
  86. }
  87. } else {
  88. if ($v['province'] && $v['city'] && $v['area'] && $v['street']) {
  89. list($data['area'], $new) = Dever::load('area/api')->upByName($v['province'], $v['city'], $v['area'], $v['street'], $v['streetvalue']);
  90. # 记录日志
  91. if (!$data['area']) {
  92. $this->log($v['id'], 5, $data['address'], $new);
  93. }
  94. }
  95. }
  96. if ($v['entertype'] == 1) {
  97. $data['type'] = 1;
  98. } else {
  99. $data['type'] = 2;
  100. }
  101. $data['price'] = $v['paymoney'];
  102. $data['f_price'] = $data['price'];
  103. $role = Dever::db('setting/role')->find($data['role']);
  104. if ($role['type'] == 1) {
  105. //$data['f_price'] = $role['price'];
  106. } elseif ($role['type'] == 2) {
  107. /*
  108. $data['f_price'] = Dever::load('area/api')->getPrice($role['area'], $data['area']);
  109. if ($data['f_price'] <= 0) {
  110. $data['f_price'] = $data['price'];
  111. }
  112. */
  113. # 区域要进行占用
  114. if ($data['area']) {
  115. Dever::load('area/api')->upStatus($data['area'], 2);
  116. $area_data = array('mid' => $v['id'], 'order_id' => $v['id'], 'role' => $data['role'], 'area' => $data['area']);
  117. $area_data['type'] = 4;
  118. $area_data['price'] = $data['f_price'];
  119. $area_data['cdate'] = $v['agentapplytime'];
  120. Dever::db('agent/member_area')->insert($area_data);
  121. }
  122. }
  123. $data['agent_cash'] = $data['f_price'];
  124. $data['sign'] = $v['contractsign'] ? $host . $v['contractsign'] : '';
  125. $data['idcard'] = $v['idnumber'];
  126. $data['idcard_front'] = $data['idcard_back'] = '';
  127. if ($v['identity']) {
  128. $identity = Dever::json_decode($v['identity']);
  129. if (isset($identity[0])) {
  130. $data['idcard_front'] = $host . $identity[0];
  131. }
  132. if (isset($identity[1])) {
  133. $data['idcard_back'] = $host . $identity[1];
  134. }
  135. }
  136. $data['company_name'] = $v['company'];
  137. $data['pay_type'] = 2;
  138. if ($v['receipt']) {
  139. $receipt = Dever::json_decode($v['receipt']);
  140. $data['pay_pic'] = array();
  141. foreach ($receipt as $v1) {
  142. $data['pay_pic'][] = $host . $v1;
  143. }
  144. $data['pay_pic'] = implode(',', $data['pay_pic']);
  145. }
  146. $data['status'] = $this->getStatus($v);
  147. $data['audit_desc'] = $v['refuse'];
  148. if ($v['issuingstate'] == 1) {
  149. $data['goods_status'] = 3;
  150. } else {
  151. $data['goods_status'] = 1;
  152. }
  153. $data['pay_status'] = 2;
  154. $data['import'] = $v['olduid'] > 0 ? 3 : 2;
  155. $data['order_num'] = Dever::load('agent/lib/order')->getOrderId();
  156. $data['cdate'] = $v['agentapplytime'];
  157. if ($data['status'] == 4) {
  158. $data['fdate'] = $v['agenttime'];
  159. }
  160. $data['order_type'] = 1;
  161. $data['company_pic'] = '';
  162. $order_id = Dever::db('agent/order')->insert($data);
  163. /*
  164. $order = Dever::db('agent/order')->find(array('id' => $v['id'], 'clear' => true));
  165. if (!$order) {
  166. $order_id = Dever::db('agent/order')->insert($data);
  167. } else {
  168. $order_id = $order['id'];
  169. }
  170. */
  171. if ($order_id) {
  172. if (!$v['preagenttime']) {
  173. $v['preagenttime'] = $v['agenttime'];
  174. }
  175. if ($data['status'] == 2) {
  176. $this->addProcess($order_id, 1, $v['preagenttime'], $data);
  177. } elseif ($data['status'] == 3) {
  178. $this->addProcess($order_id, 1, $v['preagenttime'], $data);
  179. $this->addProcess($order_id, 2, $v['agenttime'], $data);
  180. } elseif ($data['status'] == 4) {
  181. $this->addProcess($order_id, 1, $v['preagenttime'], $data);
  182. $this->addProcess($order_id, 2, $v['agenttime'], $data);
  183. $this->addProcess($order_id, 3, $v['agenttime'], $data);
  184. }
  185. if ($data['status'] == 4) {
  186. # 生成合同
  187. if ($data['sign']) {
  188. $this->addAgreement($data);
  189. }
  190. $member = Dever::db('agent/member')->find($v['id']);
  191. if ($data['status'] == 4) {
  192. $data['status'] = 2;
  193. } elseif ($data['status'] == 5) {
  194. $data['status'] = 1;
  195. $data['state'] = 2;
  196. } else {
  197. $data['status'] = 1;
  198. }
  199. $mc_member = $this->db->fetch('select * from ims_mc_members where uid = ' . $v['uid']);
  200. $data['rdate'] = $v['agenttime'];
  201. $data['cash'] = ($mc_member && $mc_member['credit2']) ? $mc_member['credit2'] : $v['credit2'];
  202. //$data['group_sell'] = $v['allcommission'];
  203. $data['old_agentdownnum'] = $v['agentdownnum'];
  204. $data['old_group_sell'] = $v['allcommission'];
  205. if (!$member) {
  206. Dever::db('agent/member')->insert($data);
  207. } else {
  208. $data['where_id'] = $member['id'];
  209. Dever::db('agent/member')->update($data);
  210. }
  211. if ($data['parent_mid']) {
  212. # 添加直推关系
  213. Dever::load('invite/lib/relation')->add($data['parent_mid'], $data['mid'], 1);
  214. # 为上级增加增加业绩
  215. Dever::load('bill/lib/sell')->up($data['parent_mid'], 1, $data['f_price'], $data['role'], $order_id, '邀请' . $data['name'] . '['.$data['mobile'].']新增直推业绩', 3, $data['cdate']);
  216. Dever::load('bill/lib/sell')->up($data['parent_mid'], 2, $data['f_price'], $data['role'], $order_id, '邀请' . $data['name'] . '['.$data['mobile'].']新增团队业绩', 3, $data['cdate']);
  217. }
  218. }
  219. echo $v['id'];
  220. echo "\r\n";
  221. }
  222. }
  223. }
  224. $index = $index + 1;
  225. return $index + $limit;
  226. }
  227. # 设置邀请关系 要跑完所有数据才能设置
  228. public function relation()
  229. {
  230. $data = Dever::db('invite/relation')->all(array('level' => 1));
  231. if ($data) {
  232. foreach ($data as $k => $v) {
  233. $order = Dever::db('agent/order')->find(array('id' => $v['to_uid'], 'status' => 4, 'clear' => true));
  234. if ($order) {
  235. $this->addRelation($v['to_uid'], $v['uid'], 2, $order);
  236. }
  237. echo $v['id'];
  238. echo "\r\n";
  239. }
  240. }
  241. }
  242. private function addRelation($cur, $parent, $level, $order)
  243. {
  244. $info = Dever::db('invite/relation')->one(array('to_uid' => $parent));
  245. if ($info) {
  246. $state = Dever::load('invite/lib/relation')->add($info['uid'], $cur, $level, $order);
  247. if ($state) {
  248. # 新增团队业绩
  249. Dever::load('bill/lib/sell')->up($info['uid'], 2, $order['f_price'], $order['role'], $order['id'], '邀请' . $order['name'] . '['.$order['mobile'].']新增团队业绩', 3, $order['cdate']);
  250. } else {
  251. return $this->addRelation($cur, $parent, $level, $order);
  252. }
  253. $level = $level + 1;
  254. return $this->addRelation($cur, $info['uid'], $level, $order);
  255. }
  256. }
  257. # 对业绩进行整理
  258. public function sell_api()
  259. {
  260. # 获取所有用户
  261. $data = Dever::db('agent/member')->select();
  262. if ($data) {
  263. foreach ($data as $k => $v) {
  264. $update = array();
  265. # 获取直推业绩
  266. $sell = Dever::db('bill/sell')->getNumByTimeOne(array('mid' => $v['id'], 'type' => 1, 'stype' => 3));
  267. if ($sell && $sell['num']) {
  268. $update['sell'] = $sell['num'];
  269. }
  270. # 获取团队业绩
  271. $sell = Dever::db('bill/sell')->getNumByTimeOne(array('mid' => $v['id'], 'type' => 2, 'stype' => 3));
  272. if ($sell && $sell['num']) {
  273. $update['group_sell'] = $sell['num'];
  274. if ($update['group_sell'] != $v['old_group_sell']) {
  275. # 记录日志
  276. $this->log($v['id'], 3, $v['old_group_sell'], $update['group_sell']);
  277. }
  278. }
  279. # 获取直推代理人数
  280. $num = Dever::load('invite/api')->getChildNum($v['id'], 1);
  281. if ($num != $v['old_agentdownnum']) {
  282. # 记录日志
  283. $this->log($v['id'], 2, $v['old_agentdownnum'], $num);
  284. }
  285. if ($update) {
  286. $update['where_id'] = $v['id'];
  287. Dever::db('agent/member')->update($update);
  288. }
  289. echo $v['id'];
  290. echo "\r\n";
  291. }
  292. }
  293. }
  294. # 导入日志记录
  295. public function log($mid, $type, $before, $after)
  296. {
  297. # 地区、直推代理人数、团队业绩
  298. $data['mid'] = $mid;
  299. $data['type'] = $type;
  300. $data['before'] = $before;
  301. $data['after'] = $after;
  302. Dever::db('agent/import_log')->insert($data);
  303. }
  304. # 验证直推代理人数是否正确 agentdownnum
  305. # 导入区域价格
  306. private function getAreaPrice()
  307. {
  308. $data = $this->db->fetchAll('select * from ims_ewei_shop_wang_city_other where deleted=0 and hide=0');
  309. if ($data) {
  310. foreach ($data as $k => $v) {
  311. $province = Dever::db('area/province')->one(array('name' => $v['province']));
  312. if ($province && $v['city']) {
  313. $city = Dever::db('area/city')->one(array('name' => $v['city'], 'province_id' => $province['id']));
  314. if ($city && $v['district']) {
  315. $county = Dever::db('area/county')->one(array('name' => $v['district'], 'city_id' => $city['id']));
  316. if ($county && $v['identity'] == 3) {
  317. # 区县
  318. Dever::db('area/county')->update(array('where_id' => $county['id'], 'price' => $v['money']));
  319. } elseif ($county && $v['street'] && $v['identity'] == 4) {
  320. # 街道
  321. if (strstr($v['street'], '燕郊')) {
  322. Dever::db('area/town')->update(array('where_id' => 131082450, 'price' => $v['money']));
  323. Dever::db('area/town')->update(array('where_id' => 131082109, 'price' => $v['money']));
  324. } else {
  325. $town = Dever::db('area/town')->one(array('name' => $v['street'], 'county_id' => $county['id']));
  326. if ($town) {
  327. Dever::db('area/town')->update(array('where_id' => $town['id'], 'price' => $v['money']));
  328. }
  329. }
  330. }
  331. }
  332. }
  333. }
  334. }
  335. }
  336. # 导入余额日志[不包括提现]
  337. private function getYue()
  338. {
  339. $data = $this->db->fetchAll('select * from mc_credits_record where credittype = "credit2" order by id asc');
  340. if ($data) {
  341. foreach ($data as $k => $v) {
  342. if ($v['credittype'] == 'credit2') {
  343. # 直推佣金
  344. $type = 1;
  345. } elseif ($v['credittype'] == 'credit3') {
  346. # 市场培训费
  347. $type = 2;
  348. } else {
  349. continue;
  350. }
  351. $remark = $v['remark'];
  352. if (strstr($remark, '提现')) {
  353. continue;
  354. }
  355. $info = Dever::db('bill/cash')->one(array('id' => $v['id'], 'clear' => true));
  356. if (!$info) {
  357. $update['id'] = $v['id'];
  358. $update['type'] = $type;
  359. if ($v['uid'] > 0) {
  360. $member = $this->db->fetch('select * from ims_ewei_shop_member where uid = ' . $v['uid'] . ' and isagent = 1 and status = 1 and prestatus = 1');
  361. if ($member) {
  362. $update['mid'] = $member['id'];
  363. }
  364. } elseif ($remark) {
  365. $temp = explode('OPENID: ', $remark);
  366. $temp = explode(' 剩余', $temp[1]);
  367. if (isset($temp[0]) && $temp[0]) {
  368. $member = $this->db->fetch('select * from ims_ewei_shop_member where openid = "' . $temp[0] . '" and isagent = 1 and status = 1 and prestatus = 1');
  369. if ($member) {
  370. $update['mid'] = $member['id'];
  371. }
  372. }
  373. }
  374. if (isset($update['mid']) && $update['mid'] > 0) {
  375. if (strstr($remark, '消费')) {
  376. $type = 12;
  377. }
  378. $update['cash'] = $v['num'];
  379. $update['yue'] = $v['presentcredit'];
  380. $update['status'] = 2;
  381. $update['audit'] = 2;
  382. $update['cdate'] = $update['operdate'] = $v['createtime'];
  383. $update['order_num'] = Dever::load('bill/lib/cash')->getOrderId();
  384. Dever::db('bill/cash')->insert($update);
  385. }
  386. }
  387. }
  388. }
  389. }
  390. # 获取提现
  391. private function getTixian()
  392. {
  393. $data = $this->db->fetchAll('select * from ims_ewei_shop_member_log where type > 0');
  394. if ($data) {
  395. foreach ($data as $k => $v) {
  396. $v['id'] = 50000 + $v['id'];
  397. $info = Dever::db('bill/cash')->one(array('id' => $v['id'], 'clear' => true));
  398. if (!$info) {
  399. $update['id'] = $v['id'];
  400. $update['type'] = 11;
  401. if ($v['uid'] > 0) {
  402. $member = $this->db->fetch('select * from ims_ewei_shop_member where uid = ' . $v['uid'] . ' and isagent = 1 and status = 1 and prestatus = 1');
  403. if ($member) {
  404. $update['mid'] = $member['id'];
  405. }
  406. } elseif ($remark) {
  407. $member = $this->db->fetch('select * from ims_ewei_shop_member where openid = "' . $v['openid'] . '" and isagent = 1 and status = 1 and prestatus = 1');
  408. if ($member) {
  409. $update['mid'] = $member['id'];
  410. }
  411. }
  412. if (isset($update['mid']) && $update['mid'] > 0) {
  413. $update['cash'] = $v['num'];
  414. $update['yue'] = $v['presentcredit'];
  415. $status = 1;
  416. $fstatus = -1;
  417. if ($v['status'] == 0 && $v['check'] == 0) {
  418. # 待审核
  419. $status = 1;
  420. } elseif ($v['status'] != -1 && $v['check'] == 1) {
  421. # 已审核
  422. $status = 2;
  423. } elseif ($v['status'] == 0 && $v['check'] == 1) {
  424. # 待发放
  425. $status = 2;
  426. $fstatus = 1;
  427. } elseif ($v['status'] == 1 && $v['check'] == 1) {
  428. # 已发放
  429. $status = 2;
  430. $fstatus = 2;
  431. } elseif ($v['check'] == -1) {
  432. # 已拒绝
  433. $status = 3;
  434. }
  435. $update['status'] = $status;
  436. $update['audit'] = $status;
  437. $update['cdate'] = $v['createtime'];
  438. $update['operdate'] = $v['checktime'];
  439. $update['order_num'] = Dever::load('bill/lib/cash')->getOrderId();
  440. $id = Dever::db('bill/cash')->insert($update);
  441. if ($id) {
  442. $tixian['order_num'] = Dever::load('bill/lib/tixian')->getOrderId();
  443. $tixian['id'] = $v['id'];
  444. $tixian['cash_id'] = $v['id'];
  445. $tixian['mid'] = $update['mid'];
  446. $tixian['ycash'] = $v['money'];
  447. $tixian['cash'] = $v['realmoney'];
  448. $tixian['yue'] = $v['deductionmoney'];
  449. $tixian['name'] = $v['realname'];
  450. $tixian['bank'] = $this->upBank($v['bankname']);
  451. $tixian['bankname'] = $v['bankopen'];
  452. $tixian['card'] = $v['bankcard'];
  453. $tixian['status'] = $fstatus;
  454. Dever::db('bill/tixian')->insert($tixian);
  455. }
  456. }
  457. }
  458. }
  459. }
  460. }
  461. # 导入关联表
  462. private function getRelation()
  463. {
  464. $data = $this->db->fetchAll('select * from ims_ewei_shop_commission_relation');
  465. if ($data) {
  466. foreach ($data as $k => $v) {
  467. $where['uid'] = $v['pid'];
  468. $where['to_uid'] = $v['id'];
  469. $where['level'] = $v['level'];
  470. $info = Dever::db('invite/relation')->one($where);
  471. if (!$info) {
  472. Dever::db('invite/relation')->insert($where);
  473. }
  474. }
  475. }
  476. }
  477. # 生成合同
  478. private function addAgreement($data)
  479. {
  480. Dever::load('agent/lib/agreement')->up($data);
  481. }
  482. # 更新进度
  483. private function addProcess($order_id, $status, $time, $data)
  484. {
  485. $where['order_id'] = $order_id;
  486. $where['status'] = $status;
  487. $info = Dever::db('agent/order_process')->find($where);
  488. if (!$info) {
  489. if ($status == 3) {
  490. $where['type'] = '1,2,3,5';
  491. }
  492. $where['cdate'] = $time;
  493. Dever::db('agent/order_process')->insert($where);
  494. }
  495. }
  496. # 状态对应
  497. private function getStatus($data)
  498. {
  499. # 完成权益发放issuingstate、财务审核status、初审prestatus的认为订单有效
  500. if ($data['issuingstate'] == 1 && $data['status'] == 1 && $data['prestatus'] == 1) {
  501. return 4;
  502. } elseif ($data['status'] == 1 && $data['prestatus'] == 1) {
  503. return 4;
  504. } elseif ($data['prestatus'] == 1) {
  505. return 2;
  506. } elseif ($data['restatus'] == 1) {
  507. # 审核失败
  508. return 5;
  509. } elseif ($data['trainersign'] && $data['contractsign']) {
  510. return 1;
  511. } else {
  512. return -2;
  513. }
  514. }
  515. # 代理商角色对应
  516. private function getRole($role)
  517. {
  518. # key是历史数据 value是最新数据
  519. $config = array
  520. (
  521. # 创服
  522. 5 => 5,
  523. # 创客
  524. 4 => 6,
  525. # 逍客
  526. 8 => 7,
  527. # 城市
  528. 1 => 2,
  529. # 区县
  530. 2 => 3,
  531. # 街道
  532. 3 => 4,
  533. # 炒菜机分享会员
  534. 6 => 8,
  535. # 热敏炉分享会员
  536. 7 => 9,
  537. );
  538. if (isset($config[$role]) && $config[$role]) {
  539. return $config[$role];
  540. }
  541. return 1;
  542. }
  543. }