Import.php 40 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069
  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. # 导入开关
  10. private $state = 1;
  11. public function __construct()
  12. {
  13. $this->db = Dever::db('agent/test:old');
  14. $this->state = Dever::input('state', 1);
  15. }
  16. # 获取已审核的条件
  17. private function get_yes_where()
  18. {
  19. //issuingstate=1 已发放权益
  20. return 'restatus = 0 and status = 1 and prestatus = 1 and isagent = 1';
  21. }
  22. # 获取审核失败的条件
  23. private function get_no_where()
  24. {
  25. //issuingstate=1 已发放权益
  26. return 'restatus = 1 and isagent = 1';
  27. }
  28. # 获取待审核的条件
  29. private function get_where()
  30. {
  31. //issuingstate=1 已发放权益
  32. return 'restatus = 0 and status = 0 and isagent = 1 and contractstatus = 1';
  33. }
  34. # 获取sql
  35. public function get_sql_api()
  36. {
  37. $table['已审核'] = 'select count(*) as num,mobile from ims_ewei_shop_member where '.$this->get_yes_where().' group by mobile order by num desc';
  38. $table['审核失败'] = 'select count(*) as num,mobile from ims_ewei_shop_member where '.$this->get_no_where().' group by mobile order by num desc';
  39. $table['待审核'] = 'select count(*) as num,mobile from ims_ewei_shop_member where '.$this->get_where().' group by mobile order by num desc';
  40. echo Dever::table($table);die;
  41. }
  42. public function get_api()
  43. {
  44. $this->date = Dever::maketime('2021-09-01 00:00:00');
  45. Dever::config('base')->hook = true;
  46. $host = 'https://cryl.yijiuguanfang.com/attachment/';
  47. $state = 1;
  48. while($state) {
  49. $state = $this->get_data($host, $state);
  50. }
  51. # 导入关联表
  52. $this->relation_api();
  53. # 导入业绩
  54. $this->sell_api();
  55. # 导入地区价格
  56. //$this->getAreaPrice();
  57. # 导入余额 不导入了
  58. //$this->getYue();
  59. return 'ok';
  60. }
  61. public function get_area_api()
  62. {
  63. $this->date = Dever::maketime('2021-09-01 00:00:00');
  64. Dever::config('base')->hook = true;
  65. $host = 'https://cryl.yijiuguanfang.com/attachment/';
  66. $state = 1;
  67. while($state) {
  68. $state = $this->get_area_act($host, $state);
  69. }
  70. return 'ok';
  71. }
  72. public function get_area_act($host, $index = 0)
  73. {
  74. # 获取已审核通过、权益已发放的用户
  75. $index = $index - 1;
  76. $limit = 1000;
  77. $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);
  78. if (!$data) {
  79. return false;
  80. }
  81. foreach ($data as $k => $v) {
  82. $data['address'] = $v['province'] . $v['city'] . $v['area'] . $v['street'];
  83. if ($v['datavalue']) {
  84. $v['datavalue'] = trim(str_replace(" ", ',', $v['datavalue']));
  85. $temp = explode(',', $v['datavalue']);
  86. if (isset($temp[0]) && $temp[0]) {
  87. $a['id'] = $temp[0];
  88. $a['clear'] = true;
  89. $info = Dever::db('area/province')->one($a);
  90. if (!$info) {
  91. $this->log($v['id'], 9, $data['address'], '省份编码错误:' . $temp[0]);
  92. continue;
  93. }
  94. }
  95. if (isset($temp[1]) && $temp[1]) {
  96. $a['id'] = $temp[1];
  97. $a['clear'] = true;
  98. $info = Dever::db('area/city')->one($a);
  99. if (!$info) {
  100. $this->log($v['id'], 9, $data['address'], '城市编码错误:' . $temp[1]);
  101. }
  102. }
  103. if (isset($temp[2]) && $temp[2]) {
  104. $a['id'] = $temp[2];
  105. $a['clear'] = true;
  106. $info = Dever::db('area/county')->one($a);
  107. if (!$info) {
  108. $this->log($v['id'], 9, $data['address'], '区县编码错误:' . $temp[2]);
  109. }
  110. }
  111. if (isset($v['streetvalue']) && $v['streetvalue']) {
  112. $a['id'] = $v['streetvalue'];
  113. $a['clear'] = true;
  114. $info = Dever::db('area/town')->one($a);
  115. if (!$info) {
  116. $this->log($v['id'], 9, $data['address'], '街道编码错误:' . $v['streetvalue']);
  117. }
  118. }
  119. } else {
  120. $this->log($v['id'], 9, $data['address'], '无区域编码');
  121. }
  122. }
  123. }
  124. public function get_data($host, $index = 0)
  125. {
  126. # 获取已审核通过、权益已发放的用户
  127. $index = $index - 1;
  128. $limit = 1000;
  129. $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);
  130. if (!$data) {
  131. return false;
  132. }
  133. foreach ($data as $k => $v) {
  134. # 创建订单
  135. $order = Dever::db('agent/order')->find(array('id' => $v['id'], 'clear' => true));
  136. if (1) {
  137. $update = false;
  138. if ($order) {
  139. $update = true;
  140. }
  141. $data = array();
  142. $data['id'] = $v['id'];
  143. $data['mobile'] = $v['mobile'];
  144. if (!$v['mobile']) {
  145. $v['mobile'] = '12345';
  146. }
  147. $data['name'] = $v['realname'];
  148. if (!$data['name']) {
  149. $data['name'] = 'boss';
  150. }
  151. if ($v['pwd']) {
  152. $data['old_pwd'] = $v['pwd'];
  153. $data['old_salt'] = $v['salt'];
  154. }
  155. if ($v['avatar'] && strstr($v['avatar'], 'http')) {
  156. $data['avatar'] = $v['avatar'];
  157. } elseif ($v['avatar']) {
  158. $data['avatar'] = $host . $v['avatar'];
  159. } else {
  160. $data['avatar'] = '';
  161. }
  162. $data['username'] = $v['nickname'];
  163. $data['mid'] = $v['id'];
  164. $data['parent_mid'] = $v['agentid'];
  165. $data['admin_desc'] = $v['content'];
  166. $data['parent_code'] = Dever::load("invite/api.code", $data['parent_mid']);
  167. $data['address'] = $v['province'] . $v['city'] . $v['area'] . $v['street'];
  168. $data['role'] = $this->getRole($v['agentlevel']);
  169. $role = Dever::db('setting/role')->find($data['role']);
  170. $data['area'] = '';
  171. if ($v['datavalue']) {
  172. $v['datavalue'] = trim(str_replace(" ", ',', $v['datavalue']));
  173. list($data['area'], $new) = Dever::load('area/api')->up($v['province'], $v['city'], $v['area'], $v['street'], $v['datavalue'], $v['streetvalue']);
  174. # 记录日志
  175. if ($new) {
  176. $this->log($v['id'], 4, $data['address'], $new, $update);
  177. }
  178. } else {
  179. if ($v['province'] && $v['city']) {
  180. list($data['area'], $new) = Dever::load('area/api')->upByName($v['province'], $v['city'], $v['area'], $v['street'], $v['streetvalue']);
  181. # 记录日志
  182. if ($data['area'] && strstr($data['area'], '-1')) {
  183. if ($this->state == 2) {
  184. $this->log($v['id'], 5, $data['address'], $new, $update);
  185. }
  186. if ($role['id'] == 5) {
  187. # 创服代理商无需记录
  188. $data['area'] = '';
  189. } else {
  190. $date = $v['agentapplytime'];
  191. if ($role['id'] == 6 && $date <= $this->date) {
  192. # 9月1日之前的创客无需导入
  193. $data['area'] = '';
  194. } else {
  195. if ($this->state == 1) {
  196. $this->log($v['id'], 5, $data['address'], $new, $update);
  197. }
  198. $data['area'] = '';
  199. }
  200. }
  201. }
  202. }
  203. }
  204. if ($v['entertype'] == 1) {
  205. $data['type'] = 1;
  206. } else {
  207. $data['type'] = 2;
  208. }
  209. $data['price'] = $v['paymoney'];
  210. $data['f_price'] = $data['price'];
  211. if ($data['price'] < 1 && $this->state == 2) {
  212. $this->log($v['id'], 6, $data['price'], $data['price'], $update);
  213. }
  214. if ($role['type'] == 1) {
  215. //$data['f_price'] = $role['price'];
  216. } elseif ($role['type'] == 2) {
  217. /*
  218. $data['f_price'] = Dever::load('area/api')->getPrice($role['area'], $data['area']);
  219. if ($data['f_price'] <= 0) {
  220. $data['f_price'] = $data['price'];
  221. }
  222. */
  223. # 区域要进行占用
  224. if ($data['area']) {
  225. Dever::load('area/api')->upStatus($data['area'], 2);
  226. $area_data = array('mid' => $v['id'], 'order_id' => $v['id'], 'role' => $data['role'], 'area' => $data['area']);
  227. $area_info = Dever::db('agent/member_area')->getOne($area_data);
  228. if (!$area_info) {
  229. $area_data['type'] = 4;
  230. $area_data['price'] = $data['f_price'];
  231. $area_data['cdate'] = $v['agentapplytime'];
  232. Dever::db('agent/member_area')->insert($area_data);
  233. }
  234. }
  235. }
  236. $data['agent_cash'] = $data['f_price'];
  237. $data['sign'] = $v['contractsign'] ? $host . $v['contractsign'] : '';
  238. $data['idcard'] = $v['idnumber'];
  239. $data['idcard_front'] = $data['idcard_back'] = '';
  240. if ($v['identity']) {
  241. $identity = Dever::json_decode($v['identity']);
  242. if (isset($identity[0])) {
  243. $data['idcard_front'] = $host . $identity[0];
  244. }
  245. if (isset($identity[1])) {
  246. $data['idcard_back'] = $host . $identity[1];
  247. }
  248. }
  249. $data['company_name'] = $v['company'];
  250. $data['pay_type'] = 2;
  251. if ($v['receipt']) {
  252. $receipt = Dever::json_decode($v['receipt']);
  253. $data['pay_pic'] = array();
  254. foreach ($receipt as $v1) {
  255. $data['pay_pic'][] = $host . $v1;
  256. }
  257. $data['pay_pic'] = implode(',', $data['pay_pic']);
  258. }
  259. $data['status'] = $this->getStatus($v);
  260. $data['audit_desc'] = $v['refuse'];
  261. if ($v['issuingstate'] == 1) {
  262. $data['goods_status'] = 3;
  263. } else {
  264. $data['goods_status'] = 1;
  265. }
  266. $data['pay_status'] = 2;
  267. $data['import'] = $v['olduid'] > 0 ? 3 : 2;
  268. $data['order_num'] = Dever::load('agent/lib/order')->getOrderId();
  269. $data['cdate'] = $v['agentapplytime'];
  270. if ($data['status'] == 4) {
  271. $data['fdate'] = $v['agenttime'];
  272. }
  273. $data['order_type'] = 1;
  274. $data['company_pic'] = '';
  275. if ($update) {
  276. $data['where_id'] = $order['id'];
  277. $order_id = Dever::db('agent/order')->update($data);
  278. } else {
  279. $order_id = Dever::db('agent/order')->insert($data);
  280. }
  281. if ($order_id) {
  282. if (!$v['preagenttime']) {
  283. $v['preagenttime'] = $v['agenttime'];
  284. }
  285. if (!$update) {
  286. if ($data['status'] == 2) {
  287. $this->addProcess($order_id, 1, $v['preagenttime'], $data);
  288. } elseif ($data['status'] == 3) {
  289. $this->addProcess($order_id, 1, $v['preagenttime'], $data);
  290. $this->addProcess($order_id, 2, $v['agenttime'], $data);
  291. } elseif ($data['status'] == 4) {
  292. $this->addProcess($order_id, 1, $v['preagenttime'], $data);
  293. $this->addProcess($order_id, 2, $v['agenttime'], $data);
  294. $this->addProcess($order_id, 3, $v['agenttime'], $data);
  295. }
  296. }
  297. if ($data['status'] == 4) {
  298. # 生成合同
  299. if (!$update && $data['sign']) {
  300. $data['sdate'] = $data['cdate'];
  301. $this->addAgreement($data);
  302. unset($data['sdate']);
  303. }
  304. $member = Dever::db('agent/member')->find($v['id']);
  305. if ($data['status'] == 4) {
  306. $data['status'] = 2;
  307. } elseif ($data['status'] == 5) {
  308. $data['status'] = 1;
  309. $data['state'] = 2;
  310. } else {
  311. $data['status'] = 1;
  312. }
  313. $mc_member = $this->db->fetch('select * from ims_mc_members where uid = ' . $v['uid']);
  314. $data['rdate'] = $v['agenttime'];
  315. //$data['cash'] = ($mc_member && $mc_member['credit2']) ? $mc_member['credit2'] : $v['credit2'];
  316. if ($this->state == 1) {
  317. $data['group_sell'] = $v['allcommission'];
  318. }
  319. $data['old_agentdownnum'] = $v['agentdownnum'];
  320. $data['old_group_sell'] = $v['allcommission'];
  321. if (!$member) {
  322. Dever::db('agent/member')->insert($data);
  323. } else {
  324. $data['where_id'] = $member['id'];
  325. Dever::db('agent/member')->update($data);
  326. }
  327. if (!$update && $data['parent_mid']) {
  328. # 添加直推关系
  329. Dever::load('invite/lib/relation')->add($data['parent_mid'], $data['mid'], 1);
  330. # 为上级增加增加业绩
  331. Dever::load('bill/lib/sell')->up($data['parent_mid'], 1, $data['f_price'], $data['role'], $order_id, '邀请' . $data['name'] . '['.$data['mobile'].']新增直推业绩', 3, $data['cdate']);
  332. if ($this->state == 2) {
  333. Dever::load('bill/lib/sell')->up($data['parent_mid'], 2, $data['f_price'], $data['role'], $order_id, '邀请' . $data['name'] . '['.$data['mobile'].']新增团队业绩', 3, $data['cdate']);
  334. }
  335. }
  336. if ($this->state == 1) {
  337. if (!$update) {
  338. Dever::load('bill/lib/sell')->up($data['mid'], 2, $data['group_sell'], $data['role'], $order_id, '新增团队业绩', 3, time());
  339. }
  340. }
  341. }
  342. echo $v['id'];
  343. echo "\r\n";
  344. }
  345. }
  346. }
  347. $index = $index + 1;
  348. return $index + $limit;
  349. }
  350. # 设置邀请关系 要跑完所有数据才能设置
  351. public function relation_api()
  352. {
  353. Dever::config('base')->hook = true;
  354. $state = 1;
  355. while($state) {
  356. $state = $this->setRelation($state);
  357. }
  358. return 'ok';
  359. }
  360. private function setRelation($index)
  361. {
  362. # 获取已审核通过、权益已发放的用户
  363. $index = $index - 1;
  364. $limit = 500;
  365. $data = Dever::db('invite/relation')->fetchAll('select * from {table} where level = 1 order by id desc limit ' . $index . ', ' . $limit);
  366. if (!$data) {
  367. return false;
  368. }
  369. //$data = Dever::db('invite/relation')->all(array('level' => 1));
  370. foreach ($data as $k => $v) {
  371. $check = Dever::db('invite/relation')->one(array('to_uid' => $v['to_uid'], 'level' => 2, 'clear' => true));
  372. if (!$check) {
  373. $order = Dever::db('agent/order')->find(array('id' => $v['to_uid'], 'status' => 4));
  374. if ($order) {
  375. $this->addRelation($v['to_uid'], $v['uid'], 2, $order);
  376. }
  377. }
  378. echo $v['id'];
  379. echo "\r\n";
  380. }
  381. $index = $index + 1;
  382. return $index + $limit;
  383. }
  384. private function addRelation($cur, $parent, $level, $order)
  385. {
  386. $info = Dever::db('invite/relation')->one(array('to_uid' => $parent));
  387. if ($info) {
  388. $state = Dever::load('invite/lib/relation')->add($info['uid'], $cur, $level, $order);
  389. if ($state) {
  390. # 新增团队业绩
  391. if ($this->state == 2) {
  392. Dever::load('bill/lib/sell')->up($info['uid'], 2, $order['f_price'], $order['role'], $order['id'], '邀请' . $order['name'] . '['.$order['mobile'].']新增团队业绩', 3, $order['cdate']);
  393. }
  394. } else {
  395. return $this->addRelation($cur, $parent, $level, $order);
  396. }
  397. $level = $level + 1;
  398. return $this->addRelation($cur, $info['uid'], $level, $order);
  399. }
  400. }
  401. # 对业绩进行整理
  402. public function sell_api()
  403. {
  404. # 获取所有用户
  405. $data = Dever::db('agent/member')->select();
  406. if ($data) {
  407. foreach ($data as $k => $v) {
  408. $update = array();
  409. # 获取直推代理人数
  410. $num = Dever::load('invite/api')->getChildNum($v['id'], 1);
  411. if ($num != $v['old_agentdownnum']) {
  412. # 记录日志 无需记录 数据无误
  413. if ($this->state == 2) {
  414. $this->log($v['id'], 2, $v['old_agentdownnum'], $num);
  415. }
  416. }
  417. # 获取直推业绩
  418. $sell = Dever::db('bill/sell')->getNumByTimeOne(array('mid' => $v['id'], 'type' => 1, 'stype' => 3));
  419. if ($sell && $sell['num']) {
  420. $update['sell'] = $sell['num'];
  421. }
  422. # 获取团队业绩
  423. $sell = Dever::db('bill/sell')->getNumByTimeOne(array('mid' => $v['id'], 'type' => 2, 'stype' => 3));
  424. if ($sell && $sell['num']) {
  425. $update['group_sell'] = $sell['num'];
  426. if ($update['group_sell'] != $v['old_group_sell']) {
  427. # 记录日志 无需记录
  428. if ($this->state == 2) {
  429. $this->log($v['id'], 3, $v['old_group_sell'], $update['group_sell']);
  430. }
  431. }
  432. if ($v['level_id'] > 0) {
  433. $cur_level = Dever::db('setting/level')->find($v['level_id']);
  434. } else {
  435. $cur_level = array('id' => -1, 'name' => '普通', 'level' => 0, 'num' => 1, 'value' => '0');
  436. }
  437. $level = Dever::db('setting/level')->getOne(array('target' => ($update['group_sell']/10000)));
  438. if ($level && $level['level'] > $cur_level['level']) {
  439. $update['level_id'] = $level['id'];
  440. Dever::load('agent/lib/level_log')->up($v['id'], -1, $cur_level['id'], $level['id'], $update['group_sell'], $update['group_sell'], $num);
  441. }
  442. }
  443. if ($update) {
  444. $update['where_id'] = $v['id'];
  445. Dever::db('agent/member')->update($update);
  446. }
  447. echo $v['id'];
  448. echo "\r\n";
  449. }
  450. }
  451. }
  452. # 图片本地化
  453. public function local_api()
  454. {
  455. $data = Dever::db('agent/member')->select();
  456. # avatar sign idcard_front idcard_back pay_pic(多个) 9
  457. $key = 9;
  458. if ($data) {
  459. foreach ($data as $k => $v) {
  460. if ($v['id'] >= 50000) {
  461. continue;
  462. }
  463. $update = array();
  464. if ($v['avatar']) {
  465. $update['avatar'] = $this->upload($v['avatar']);
  466. }
  467. if ($v['sign']) {
  468. $update['sign'] = $this->upload($v['sign']);
  469. }
  470. if ($v['idcard_front']) {
  471. $update['idcard_front'] = $this->upload($v['idcard_front']);
  472. }
  473. if ($v['idcard_back']) {
  474. $update['idcard_back'] = $this->upload($v['idcard_back']);
  475. }
  476. if ($update) {
  477. $update['where_id'] = $v['id'];
  478. Dever::db('agent/member')->update($update);
  479. $order = Dever::db('agent/order')->find($v['id']);
  480. if ($order) {
  481. if ($order['pay_pic']) {
  482. $temp = explode(',', $order['pay_pic']);
  483. foreach ($temp as $k1 => $v1) {
  484. $temp[$k1] = $this->upload($v1);
  485. }
  486. $update['pay_pic'] = implode(',', $temp);
  487. }
  488. if ($update) {
  489. Dever::db('agent/order')->update($update);
  490. }
  491. }
  492. }
  493. echo $v['id'];
  494. echo "\r\n";
  495. }
  496. }
  497. }
  498. private function upload($file)
  499. {
  500. if ($file && strstr($file, 'http') && !strstr($file, '7.churenyiliao')) {
  501. $data = Dever::load('upload/save')->copy($file, 9);
  502. if (isset($data['url'])) {
  503. return $data['url'];
  504. } else {
  505. return $file;
  506. }
  507. } else {
  508. return $file;
  509. }
  510. }
  511. # 同步pwd和salt
  512. public function pwd_api()
  513. {
  514. $data = Dever::db('agent/member')->select();
  515. if ($data) {
  516. foreach ($data as $k => $v) {
  517. $info = $this->db->fetch('select * from ims_ewei_shop_member where id =' . $v['id']);
  518. if (!$info) {
  519. continue;
  520. }
  521. if (!$info['pwd']) {
  522. continue;
  523. }
  524. $update = array();
  525. $update['old_pwd'] = $info['pwd'];
  526. $update['old_salt'] = $info['salt'];
  527. $update['where_id'] = $v['id'];
  528. Dever::db('agent/member')->update($update);
  529. echo $v['id'];
  530. echo "\r\n";
  531. }
  532. }
  533. }
  534. # 导入创客名额
  535. public function chuangke_api()
  536. {
  537. $data = Dever::db('agent/member')->select();
  538. $type = 3;
  539. $type_id = 1;
  540. $desc = '自动发放';
  541. if ($data) {
  542. foreach ($data as $k => $v) {
  543. $info = $this->db->fetch('select * from ims_ewei_shop_member where id =' . $v['id']);
  544. if (!$info) {
  545. continue;
  546. }
  547. if (!$info['direct_num']) {
  548. continue;
  549. }
  550. $direct_num = unserialize($info['direct_num']);
  551. if (isset($direct_num[4]) && $direct_num[4]) {
  552. $total = $direct_num[4];
  553. $prize = Dever::db('setting/prize')->find($type_id);
  554. $price = $prize['price'];
  555. $cash = $prize['price'] * $total;
  556. $name = $prize['name'];
  557. $w = array();
  558. $w['type'] = $type;
  559. $w['type_id'] = $type_id;
  560. $w['sku_id'] = -1;
  561. $w['mid'] = $v['id'];
  562. $state = Dever::db('agent/member_goods')->one($w);
  563. $w['total_num'] = $total;
  564. $w['cash'] = $cash;
  565. $w['price'] = $price;
  566. $w['name'] = $name;
  567. if (!$state) {
  568. $state = Dever::db('agent/member_goods')->insert($w);
  569. if ($state) {
  570. Dever::load('agent/lib/member_set')->log($w['mid'], '', $w['type'], $w['type_id'], $w['sku_id'], $total, 0, $w['total_num'], $name, $desc);
  571. }
  572. }
  573. $this->log($v['id'], 7, $total, $total, true);
  574. echo $v['id'];
  575. echo "\r\n";
  576. }
  577. }
  578. }
  579. }
  580. # 同步邀请码
  581. public function invite_code_api()
  582. {
  583. $data = Dever::db('agent/order')->select();
  584. if ($data) {
  585. foreach ($data as $k => $v) {
  586. if ($v['parent_mid'] && $v['parent_mid'] > 0) {
  587. $parent_code = Dever::load("invite/api.code", $v['parent_mid']);
  588. if ($parent_code) {
  589. $update = array();
  590. $update['parent_code'] = $parent_code;
  591. $update['where_id'] = $v['id'];
  592. Dever::db('agent/order')->update($update);
  593. echo $v['id'];
  594. echo "\r\n";
  595. }
  596. }
  597. }
  598. }
  599. }
  600. # 计算支付金额和角色是否能对应
  601. public function role_api()
  602. {
  603. $data = Dever::db('agent/order')->select();
  604. if ($data) {
  605. foreach ($data as $k => $v) {
  606. $role = Dever::db('setting/role')->find($v['role']);
  607. $price = 0;
  608. if ($role['type'] == 1) {
  609. $price = $role['price'];
  610. } elseif ($role['type'] == 2) {
  611. $price = Dever::load('area/api')->getPrice($role['area'], $v['area']);
  612. }
  613. if ($price > 0 && $price != $v['price']) {
  614. $this->log($v['mid'], 8, $v['price'], $price, true);
  615. }
  616. echo $v['id'];
  617. echo "\r\n";
  618. }
  619. }
  620. }
  621. # 导入日志记录
  622. public function log($mid, $type, $before, $after, $update = false)
  623. {
  624. # 地区、直推代理人数、团队业绩
  625. $data['mid'] = $mid;
  626. $data['type'] = $type;
  627. $data['before'] = $before;
  628. $data['after'] = $after;
  629. if ($type == 4 || $type == 7) {
  630. $data['status'] = 2;
  631. }
  632. if ($update) {
  633. $info = Dever::db('agent/import_log')->find($data);
  634. if (!$info) {
  635. Dever::db('agent/import_log')->insert($data);
  636. }
  637. } else {
  638. Dever::db('agent/import_log')->insert($data);
  639. }
  640. }
  641. public function get_cash_api()
  642. {
  643. # 获取已审核通过、权益已发放的用户
  644. /*
  645. # 团队业绩
  646. $data = $this->db->fetchAll('select a.*,b.credit3 as bcredit3 from ims_ewei_shop_member as a left join ims_mc_members as b on b.uid = a.uid where a.status = 1 and a.prestatus = 1 and a.isagent = 1 and (b.credit3 > 0 || a.credit3 > 0) order by a.id asc ');
  647. if (!$data) {
  648. return false;
  649. }
  650. foreach ($data as $k => $v) {
  651. if ($v['bcredit3'] > 0) {
  652. $num = $v['bcredit3'];
  653. } else {
  654. $num = $v['credit3'];
  655. }
  656. $this->cash_log($v['id'], 2, $num);
  657. echo $v['id'];
  658. echo "\r\n";
  659. }
  660. # 团队业绩
  661. $data = $this->db->fetchAll('select a.*,b.credit2 as bcredit2 from ims_ewei_shop_member as a left join ims_mc_members as b on b.uid = a.uid where a.status = 1 and a.prestatus = 1 and a.isagent = 1 and (b.credit2 > 0 || a.credit2 > 0) order by a.id asc ');
  662. if (!$data) {
  663. return false;
  664. }
  665. foreach ($data as $k => $v) {
  666. if ($v['bcredit2'] > 0) {
  667. $num = $v['bcredit2'];
  668. } else {
  669. $num = $v['credit2'];
  670. }
  671. $this->cash_log($v['id'], 1, $num);
  672. echo $v['id'];
  673. echo "\r\n";
  674. }
  675. */
  676. $data = Dever::db('agent/member')->getDataByArea(array('area' => '150000,150100'));
  677. if (!$data) {
  678. return false;
  679. }
  680. foreach ($data as $k => $v) {
  681. $num = Dever::db('agent/member')->total(array('parent_mid' => $v['id'], 'role' => 6));
  682. if ($num > 0) {
  683. $this->cash_log($v['id'], 3, $num);
  684. }
  685. echo $v['id'];
  686. echo "\r\n";
  687. }
  688. return 'ok';
  689. }
  690. public function cash_log($mid, $type, $num)
  691. {
  692. # 地区、直推代理人数、团队业绩
  693. $data['mid'] = $mid;
  694. $data['type'] = $type;
  695. $data['num'] = $num;
  696. $info = Dever::db('agent/import_cash_log')->find($data);
  697. if (!$info) {
  698. Dever::db('agent/import_cash_log')->insert($data);
  699. } else {
  700. $data['where_id'] = $info['id'];
  701. Dever::db('agent/import_cash_log')->update($data);
  702. }
  703. }
  704. # 验证直推代理人数是否正确 agentdownnum
  705. # 导入区域价格
  706. private function getAreaPrice()
  707. {
  708. $data = $this->db->fetchAll('select * from ims_ewei_shop_wang_city_other where deleted=0 and hide=0');
  709. if ($data) {
  710. foreach ($data as $k => $v) {
  711. $province = Dever::db('area/province')->one(array('name' => $v['province']));
  712. if ($province && $v['city']) {
  713. $city = Dever::db('area/city')->one(array('name' => $v['city'], 'province_id' => $province['id']));
  714. if ($city && $v['district']) {
  715. $county = Dever::db('area/county')->one(array('name' => $v['district'], 'city_id' => $city['id']));
  716. if ($county && $v['identity'] == 3) {
  717. # 区县
  718. Dever::db('area/county')->update(array('where_id' => $county['id'], 'price' => $v['money']));
  719. } elseif ($county && $v['street'] && $v['identity'] == 4) {
  720. # 街道
  721. if (strstr($v['street'], '燕郊')) {
  722. Dever::db('area/town')->update(array('where_id' => 131082450, 'price' => $v['money']));
  723. Dever::db('area/town')->update(array('where_id' => 131082109, 'price' => $v['money']));
  724. } else {
  725. $town = Dever::db('area/town')->one(array('name' => $v['street'], 'county_id' => $county['id']));
  726. if ($town) {
  727. Dever::db('area/town')->update(array('where_id' => $town['id'], 'price' => $v['money']));
  728. }
  729. }
  730. }
  731. }
  732. }
  733. }
  734. }
  735. }
  736. # 导入余额日志[不包括提现]
  737. private function getYue()
  738. {
  739. $data = $this->db->fetchAll('select * from mc_credits_record where credittype = "credit2" order by id asc');
  740. if ($data) {
  741. foreach ($data as $k => $v) {
  742. if ($v['credittype'] == 'credit2') {
  743. # 直推佣金
  744. $type = 1;
  745. } elseif ($v['credittype'] == 'credit3') {
  746. # 市场培训费
  747. $type = 2;
  748. } else {
  749. continue;
  750. }
  751. $remark = $v['remark'];
  752. if (strstr($remark, '提现')) {
  753. continue;
  754. }
  755. $info = Dever::db('bill/cash')->one(array('id' => $v['id'], 'clear' => true));
  756. if (!$info) {
  757. $update['id'] = $v['id'];
  758. $update['type'] = $type;
  759. if ($v['uid'] > 0) {
  760. $member = $this->db->fetch('select * from ims_ewei_shop_member where uid = ' . $v['uid'] . ' and isagent = 1 and status = 1 and prestatus = 1');
  761. if ($member) {
  762. $update['mid'] = $member['id'];
  763. }
  764. } elseif ($remark) {
  765. $temp = explode('OPENID: ', $remark);
  766. $temp = explode(' 剩余', $temp[1]);
  767. if (isset($temp[0]) && $temp[0]) {
  768. $member = $this->db->fetch('select * from ims_ewei_shop_member where openid = "' . $temp[0] . '" and isagent = 1 and status = 1 and prestatus = 1');
  769. if ($member) {
  770. $update['mid'] = $member['id'];
  771. }
  772. }
  773. }
  774. if (isset($update['mid']) && $update['mid'] > 0) {
  775. if (strstr($remark, '消费')) {
  776. $type = 12;
  777. }
  778. $update['cash'] = $v['num'];
  779. $update['yue'] = $v['presentcredit'];
  780. $update['status'] = 2;
  781. $update['audit'] = 2;
  782. $update['cdate'] = $update['operdate'] = $v['createtime'];
  783. $update['order_num'] = Dever::load('bill/lib/cash')->getOrderId();
  784. Dever::db('bill/cash')->insert($update);
  785. }
  786. }
  787. }
  788. }
  789. }
  790. # 获取提现
  791. private function getTixian()
  792. {
  793. $data = $this->db->fetchAll('select * from ims_ewei_shop_member_log where type > 0');
  794. if ($data) {
  795. foreach ($data as $k => $v) {
  796. $v['id'] = 50000 + $v['id'];
  797. $info = Dever::db('bill/cash')->one(array('id' => $v['id'], 'clear' => true));
  798. if (!$info) {
  799. $update['id'] = $v['id'];
  800. $update['type'] = 11;
  801. if ($v['uid'] > 0) {
  802. $member = $this->db->fetch('select * from ims_ewei_shop_member where uid = ' . $v['uid'] . ' and isagent = 1 and status = 1 and prestatus = 1');
  803. if ($member) {
  804. $update['mid'] = $member['id'];
  805. }
  806. } elseif ($remark) {
  807. $member = $this->db->fetch('select * from ims_ewei_shop_member where openid = "' . $v['openid'] . '" and isagent = 1 and status = 1 and prestatus = 1');
  808. if ($member) {
  809. $update['mid'] = $member['id'];
  810. }
  811. }
  812. if (isset($update['mid']) && $update['mid'] > 0) {
  813. $update['cash'] = $v['num'];
  814. $update['yue'] = $v['presentcredit'];
  815. $status = 1;
  816. $fstatus = -1;
  817. if ($v['status'] == 0 && $v['check'] == 0) {
  818. # 待审核
  819. $status = 1;
  820. } elseif ($v['status'] != -1 && $v['check'] == 1) {
  821. # 已审核
  822. $status = 2;
  823. } elseif ($v['status'] == 0 && $v['check'] == 1) {
  824. # 待发放
  825. $status = 2;
  826. $fstatus = 1;
  827. } elseif ($v['status'] == 1 && $v['check'] == 1) {
  828. # 已发放
  829. $status = 2;
  830. $fstatus = 2;
  831. } elseif ($v['check'] == -1) {
  832. # 已拒绝
  833. $status = 3;
  834. }
  835. $update['status'] = $status;
  836. $update['audit'] = $status;
  837. $update['cdate'] = $v['createtime'];
  838. $update['operdate'] = $v['checktime'];
  839. $update['order_num'] = Dever::load('bill/lib/cash')->getOrderId();
  840. $id = Dever::db('bill/cash')->insert($update);
  841. if ($id) {
  842. $tixian['order_num'] = Dever::load('bill/lib/tixian')->getOrderId();
  843. $tixian['id'] = $v['id'];
  844. $tixian['cash_id'] = $v['id'];
  845. $tixian['mid'] = $update['mid'];
  846. $tixian['ycash'] = $v['money'];
  847. $tixian['cash'] = $v['realmoney'];
  848. $tixian['yue'] = $v['deductionmoney'];
  849. $tixian['name'] = $v['realname'];
  850. $tixian['bank'] = $this->upBank($v['bankname']);
  851. $tixian['bankname'] = $v['bankopen'];
  852. $tixian['card'] = $v['bankcard'];
  853. $tixian['status'] = $fstatus;
  854. Dever::db('bill/tixian')->insert($tixian);
  855. }
  856. }
  857. }
  858. }
  859. }
  860. }
  861. # 导入关联表
  862. private function getRelation()
  863. {
  864. $data = $this->db->fetchAll('select * from ims_ewei_shop_commission_relation');
  865. if ($data) {
  866. foreach ($data as $k => $v) {
  867. $where['uid'] = $v['pid'];
  868. $where['to_uid'] = $v['id'];
  869. $where['level'] = $v['level'];
  870. $info = Dever::db('invite/relation')->one($where);
  871. if (!$info) {
  872. Dever::db('invite/relation')->insert($where);
  873. }
  874. }
  875. }
  876. }
  877. # 生成合同
  878. private function addAgreement($data)
  879. {
  880. Dever::load('agent/lib/agreement')->up($data);
  881. }
  882. # 更新进度
  883. private function addProcess($order_id, $status, $time, $data)
  884. {
  885. $where['order_id'] = $order_id;
  886. $where['status'] = $status;
  887. $info = Dever::db('agent/order_process')->find($where);
  888. if (!$info) {
  889. if ($status == 3) {
  890. $where['type'] = '1,2,3,5';
  891. }
  892. $where['cdate'] = $time;
  893. Dever::db('agent/order_process')->insert($where);
  894. }
  895. }
  896. # 状态对应
  897. private function getStatus($data)
  898. {
  899. # 完成权益发放issuingstate、财务审核status、初审prestatus的认为订单有效
  900. if ($data['issuingstate'] == 1 && $data['status'] == 1 && $data['prestatus'] == 1) {
  901. return 4;
  902. } elseif ($data['status'] == 1 && $data['prestatus'] == 1) {
  903. return 4;
  904. } elseif ($data['prestatus'] == 1) {
  905. return 2;
  906. } elseif ($data['restatus'] == 1) {
  907. # 审核失败
  908. return 5;
  909. } elseif ($data['trainersign'] && $data['contractsign']) {
  910. return 1;
  911. } else {
  912. return -2;
  913. }
  914. }
  915. # 代理商角色对应
  916. private function getRole($role)
  917. {
  918. # key是历史数据 value是最新数据
  919. $config = array
  920. (
  921. # 创服
  922. 5 => 5,
  923. # 创客
  924. 4 => 6,
  925. # 逍客
  926. 8 => 7,
  927. # 城市
  928. 1 => 2,
  929. # 区县
  930. 2 => 3,
  931. # 街道
  932. 3 => 4,
  933. # 炒菜机分享会员
  934. 6 => 8,
  935. # 热敏炉分享会员
  936. 7 => 9,
  937. );
  938. if (isset($config[$role]) && $config[$role]) {
  939. return $config[$role];
  940. }
  941. return 1;
  942. }
  943. }