Import.php 41 KB

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