Import.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761
  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_data($host, $index = 0)
  62. {
  63. # 获取已审核通过、权益已发放的用户
  64. $index = $index - 1;
  65. $limit = 1000;
  66. $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);
  67. if (!$data) {
  68. return false;
  69. }
  70. foreach ($data as $k => $v) {
  71. # 创建订单
  72. $order = Dever::db('agent/order')->find(array('id' => $v['id'], 'clear' => true));
  73. if (1) {
  74. $update = false;
  75. if ($order) {
  76. $update = true;
  77. }
  78. $data = array();
  79. $data['id'] = $v['id'];
  80. $data['mobile'] = $v['mobile'];
  81. if (!$v['mobile']) {
  82. $v['mobile'] = '12345';
  83. }
  84. $data['name'] = $v['realname'];
  85. if (!$data['name']) {
  86. $data['name'] = 'boss';
  87. }
  88. $data['password'] = $v['pwd'];
  89. $data['avatar'] = $v['avatar'] ? $host . $v['avatar'] : '';
  90. $data['username'] = $v['nickname'];
  91. $data['mid'] = $v['id'];
  92. $data['parent_mid'] = $v['agentid'];
  93. $data['admin_desc'] = $v['content'];
  94. $data['parent_code'] = Dever::load("invite/api.code", $data['parent_mid']);
  95. $data['address'] = $v['province'] . $v['city'] . $v['area'] . $v['street'];
  96. $data['role'] = $this->getRole($v['agentlevel']);
  97. $role = Dever::db('setting/role')->find($data['role']);
  98. $data['area'] = '';
  99. if ($v['datavalue']) {
  100. $v['datavalue'] = trim(str_replace(" ", ',', $v['datavalue']));
  101. list($data['area'], $new) = Dever::load('area/api')->up($v['province'], $v['city'], $v['area'], $v['street'], $v['datavalue'], $v['streetvalue']);
  102. # 记录日志
  103. if ($new) {
  104. $this->log($v['id'], 4, $data['address'], $new, $update);
  105. }
  106. } else {
  107. if ($v['province'] && $v['city']) {
  108. list($data['area'], $new) = Dever::load('area/api')->upByName($v['province'], $v['city'], $v['area'], $v['street'], $v['streetvalue']);
  109. # 记录日志
  110. if ($data['area'] && strstr($data['area'], '-1')) {
  111. if ($this->state == 2) {
  112. $this->log($v['id'], 5, $data['address'], $new, $update);
  113. }
  114. if ($role['id'] == 5) {
  115. # 创服代理商无需记录
  116. $data['area'] = '';
  117. } else {
  118. $date = $v['agentapplytime'];
  119. if ($role['id'] == 6 && $date <= $this->date) {
  120. # 9月1日之前的创客无需导入
  121. $data['area'] = '';
  122. } else {
  123. if ($this->state == 1) {
  124. $this->log($v['id'], 5, $data['address'], $new, $update);
  125. }
  126. $data['area'] = '';
  127. }
  128. }
  129. }
  130. }
  131. }
  132. if ($v['entertype'] == 1) {
  133. $data['type'] = 1;
  134. } else {
  135. $data['type'] = 2;
  136. }
  137. $data['price'] = $v['paymoney'];
  138. $data['f_price'] = $data['price'];
  139. if ($data['price'] < 1 && $this->state == 2) {
  140. $this->log($v['id'], 6, $data['price'], $data['price'], $update);
  141. }
  142. if ($role['type'] == 1) {
  143. //$data['f_price'] = $role['price'];
  144. } elseif ($role['type'] == 2) {
  145. /*
  146. $data['f_price'] = Dever::load('area/api')->getPrice($role['area'], $data['area']);
  147. if ($data['f_price'] <= 0) {
  148. $data['f_price'] = $data['price'];
  149. }
  150. */
  151. # 区域要进行占用
  152. if ($data['area']) {
  153. Dever::load('area/api')->upStatus($data['area'], 2);
  154. $area_data = array('mid' => $v['id'], 'order_id' => $v['id'], 'role' => $data['role'], 'area' => $data['area']);
  155. $area_info = Dever::db('agent/member_area')->getOne($area_data);
  156. if (!$area_info) {
  157. $area_data['type'] = 4;
  158. $area_data['price'] = $data['f_price'];
  159. $area_data['cdate'] = $v['agentapplytime'];
  160. Dever::db('agent/member_area')->insert($area_data);
  161. }
  162. }
  163. }
  164. $data['agent_cash'] = $data['f_price'];
  165. $data['sign'] = $v['contractsign'] ? $host . $v['contractsign'] : '';
  166. $data['idcard'] = $v['idnumber'];
  167. $data['idcard_front'] = $data['idcard_back'] = '';
  168. if ($v['identity']) {
  169. $identity = Dever::json_decode($v['identity']);
  170. if (isset($identity[0])) {
  171. $data['idcard_front'] = $host . $identity[0];
  172. }
  173. if (isset($identity[1])) {
  174. $data['idcard_back'] = $host . $identity[1];
  175. }
  176. }
  177. $data['company_name'] = $v['company'];
  178. $data['pay_type'] = 2;
  179. if ($v['receipt']) {
  180. $receipt = Dever::json_decode($v['receipt']);
  181. $data['pay_pic'] = array();
  182. foreach ($receipt as $v1) {
  183. $data['pay_pic'][] = $host . $v1;
  184. }
  185. $data['pay_pic'] = implode(',', $data['pay_pic']);
  186. }
  187. $data['status'] = $this->getStatus($v);
  188. $data['audit_desc'] = $v['refuse'];
  189. if ($v['issuingstate'] == 1) {
  190. $data['goods_status'] = 3;
  191. } else {
  192. $data['goods_status'] = 1;
  193. }
  194. $data['pay_status'] = 2;
  195. $data['import'] = $v['olduid'] > 0 ? 3 : 2;
  196. $data['order_num'] = Dever::load('agent/lib/order')->getOrderId();
  197. $data['cdate'] = $v['agentapplytime'];
  198. if ($data['status'] == 4) {
  199. $data['fdate'] = $v['agenttime'];
  200. }
  201. $data['order_type'] = 1;
  202. $data['company_pic'] = '';
  203. if ($update) {
  204. $data['where_id'] = $order['id'];
  205. $order_id = Dever::db('agent/order')->update($data);
  206. } else {
  207. $order_id = Dever::db('agent/order')->insert($data);
  208. }
  209. if ($order_id) {
  210. if (!$v['preagenttime']) {
  211. $v['preagenttime'] = $v['agenttime'];
  212. }
  213. if (!$update) {
  214. if ($data['status'] == 2) {
  215. $this->addProcess($order_id, 1, $v['preagenttime'], $data);
  216. } elseif ($data['status'] == 3) {
  217. $this->addProcess($order_id, 1, $v['preagenttime'], $data);
  218. $this->addProcess($order_id, 2, $v['agenttime'], $data);
  219. } elseif ($data['status'] == 4) {
  220. $this->addProcess($order_id, 1, $v['preagenttime'], $data);
  221. $this->addProcess($order_id, 2, $v['agenttime'], $data);
  222. $this->addProcess($order_id, 3, $v['agenttime'], $data);
  223. }
  224. }
  225. if ($data['status'] == 4) {
  226. # 生成合同
  227. if (!$update && $data['sign']) {
  228. $data['sdate'] = $data['cdate'];
  229. $this->addAgreement($data);
  230. unset($data['sdate']);
  231. }
  232. $member = Dever::db('agent/member')->find($v['id']);
  233. if ($data['status'] == 4) {
  234. $data['status'] = 2;
  235. } elseif ($data['status'] == 5) {
  236. $data['status'] = 1;
  237. $data['state'] = 2;
  238. } else {
  239. $data['status'] = 1;
  240. }
  241. $mc_member = $this->db->fetch('select * from ims_mc_members where uid = ' . $v['uid']);
  242. $data['rdate'] = $v['agenttime'];
  243. $data['cash'] = ($mc_member && $mc_member['credit2']) ? $mc_member['credit2'] : $v['credit2'];
  244. $data['group_sell'] = $v['allcommission'];
  245. $data['old_agentdownnum'] = $v['agentdownnum'];
  246. $data['old_group_sell'] = $v['allcommission'];
  247. if (!$member) {
  248. Dever::db('agent/member')->insert($data);
  249. } else {
  250. $data['where_id'] = $member['id'];
  251. Dever::db('agent/member')->update($data);
  252. }
  253. if (!$update && $data['parent_mid']) {
  254. # 添加直推关系
  255. Dever::load('invite/lib/relation')->add($data['parent_mid'], $data['mid'], 1);
  256. # 为上级增加增加业绩
  257. Dever::load('bill/lib/sell')->up($data['parent_mid'], 1, $data['f_price'], $data['role'], $order_id, '邀请' . $data['name'] . '['.$data['mobile'].']新增直推业绩', 3, $data['cdate']);
  258. if ($this->state == 2) {
  259. Dever::load('bill/lib/sell')->up($data['parent_mid'], 2, $data['f_price'], $data['role'], $order_id, '邀请' . $data['name'] . '['.$data['mobile'].']新增团队业绩', 3, $data['cdate']);
  260. }
  261. }
  262. if ($this->state == 1) {
  263. if (!$update) {
  264. Dever::load('bill/lib/sell')->up($data['mid'], 2, $data['group_sell'], $data['role'], $order_id, '新增团队业绩', 3, time());
  265. }
  266. }
  267. }
  268. echo $v['id'];
  269. echo "\r\n";
  270. }
  271. }
  272. }
  273. $index = $index + 1;
  274. return $index + $limit;
  275. }
  276. # 设置邀请关系 要跑完所有数据才能设置
  277. public function relation_api()
  278. {
  279. Dever::config('base')->hook = true;
  280. $state = 1;
  281. while($state) {
  282. $state = $this->setRelation($state);
  283. }
  284. return 'ok';
  285. }
  286. private function setRelation($index)
  287. {
  288. # 获取已审核通过、权益已发放的用户
  289. $index = $index - 1;
  290. $limit = 1000;
  291. $data = Dever::db('invite/relation')->fetchAll('select * from {table} where level = 1 order by id desc limit ' . $index . ', ' . $limit);
  292. if (!$data) {
  293. return false;
  294. }
  295. //$data = Dever::db('invite/relation')->all(array('level' => 1));
  296. foreach ($data as $k => $v) {
  297. $check = Dever::db('invite/relation')->one(array('to_uid' => $v['to_uid'], 'level' => 2, 'clear' => true));
  298. if (!$check) {
  299. $order = Dever::db('agent/order')->find(array('id' => $v['to_uid'], 'status' => 4));
  300. if ($order) {
  301. $this->addRelation($v['to_uid'], $v['uid'], 2, $order);
  302. }
  303. }
  304. echo $v['id'];
  305. echo "\r\n";
  306. }
  307. $index = $index + 1;
  308. return $index + $limit;
  309. }
  310. private function addRelation($cur, $parent, $level, $order)
  311. {
  312. $info = Dever::db('invite/relation')->one(array('to_uid' => $parent));
  313. if ($info) {
  314. $state = Dever::load('invite/lib/relation')->add($info['uid'], $cur, $level, $order);
  315. if ($state) {
  316. # 新增团队业绩
  317. //Dever::load('bill/lib/sell')->up($info['uid'], 2, $order['f_price'], $order['role'], $order['id'], '邀请' . $order['name'] . '['.$order['mobile'].']新增团队业绩', 3, $order['cdate']);
  318. } else {
  319. return $this->addRelation($cur, $parent, $level, $order);
  320. }
  321. $level = $level + 1;
  322. return $this->addRelation($cur, $info['uid'], $level, $order);
  323. }
  324. }
  325. # 对业绩进行整理
  326. public function sell_api()
  327. {
  328. # 获取所有用户
  329. $data = Dever::db('agent/member')->select();
  330. if ($data) {
  331. foreach ($data as $k => $v) {
  332. $update = array();
  333. # 获取直推代理人数
  334. $num = Dever::load('invite/api')->getChildNum($v['id'], 1);
  335. if ($num != $v['old_agentdownnum']) {
  336. # 记录日志 无需记录 数据无误
  337. if ($this->state == 2) {
  338. $this->log($v['id'], 2, $v['old_agentdownnum'], $num);
  339. }
  340. }
  341. # 获取直推业绩
  342. $sell = Dever::db('bill/sell')->getNumByTimeOne(array('mid' => $v['id'], 'type' => 1, 'stype' => 3));
  343. if ($sell && $sell['num']) {
  344. $update['sell'] = $sell['num'];
  345. }
  346. # 获取团队业绩
  347. $sell = Dever::db('bill/sell')->getNumByTimeOne(array('mid' => $v['id'], 'type' => 2, 'stype' => 3));
  348. if ($sell && $sell['num']) {
  349. $update['group_sell'] = $sell['num'];
  350. if ($update['group_sell'] != $v['old_group_sell']) {
  351. # 记录日志 无需记录
  352. if ($this->state == 2) {
  353. $this->log($v['id'], 3, $v['old_group_sell'], $update['group_sell']);
  354. }
  355. }
  356. if ($v['level_id'] > 0) {
  357. $cur_level = Dever::db('setting/level')->find($v['level_id']);
  358. } else {
  359. $cur_level = array('id' => -1, 'name' => '普通', 'level' => 0, 'num' => 1, 'value' => '0');
  360. }
  361. $level = Dever::db('setting/level')->getOne(array('target' => ($update['group_sell']/10000)));
  362. if ($level && $level['level'] > $cur_level['level']) {
  363. $update['level_id'] = $level['id'];
  364. Dever::load('agent/lib/level_log')->up($v['id'], -1, $cur_level['id'], $level['id'], $update['group_sell'], $update['group_sell'], $num);
  365. }
  366. }
  367. if ($update) {
  368. $update['where_id'] = $v['id'];
  369. Dever::db('agent/member')->update($update);
  370. }
  371. echo $v['id'];
  372. echo "\r\n";
  373. }
  374. }
  375. }
  376. # 图片本地化
  377. public function local()
  378. {
  379. $data = Dever::db('agent/member')->select();
  380. # avatar sign idcard_front idcard_back pay_pic(多个) 9
  381. $key = 9;
  382. if ($data) {
  383. foreach ($data as $k => $v) {
  384. $update = array();
  385. $update['avatar'] = $this->upload($v['avatar']);
  386. $update['sign'] = $this->upload($v['sign']);
  387. $update['idcard_front'] = $this->upload($v['idcard_front']);
  388. $update['idcard_back'] = $this->upload($v['idcard_back']);
  389. $update['where_id'] = $v['id'];
  390. Dever::db('agent/member')->update($update);
  391. $order = Dever::db('agent/order')->find($v['id']);
  392. if ($order) {
  393. if ($order['pay_pic']) {
  394. $temp = explode(',', $order['pay_pic']);
  395. foreach ($temp as $k1 => $v1) {
  396. $temp[$k1] = $this->upload($v1);
  397. }
  398. $update['pay_pic'] = implode(',', $temp);
  399. }
  400. Dever::db('agent/order')->update($update);
  401. }
  402. }
  403. }
  404. }
  405. private function upload($file)
  406. {
  407. if ($file && strstr($file, 'http') && !strstr($file, '7.churenyiliao')) {
  408. return Dever::load('upload/save')->copy($file, 9);
  409. } else {
  410. return $file;
  411. }
  412. }
  413. # 导入日志记录
  414. public function log($mid, $type, $before, $after, $update = false)
  415. {
  416. # 地区、直推代理人数、团队业绩
  417. $data['mid'] = $mid;
  418. $data['type'] = $type;
  419. $data['before'] = $before;
  420. $data['after'] = $after;
  421. if ($type == 4) {
  422. $data['status'] = 2;
  423. }
  424. if ($update) {
  425. $info = Dever::db('agent/import_log')->find($data);
  426. if (!$info) {
  427. Dever::db('agent/import_log')->insert($data);
  428. }
  429. } else {
  430. Dever::db('agent/import_log')->insert($data);
  431. }
  432. }
  433. # 验证直推代理人数是否正确 agentdownnum
  434. # 导入区域价格
  435. private function getAreaPrice()
  436. {
  437. $data = $this->db->fetchAll('select * from ims_ewei_shop_wang_city_other where deleted=0 and hide=0');
  438. if ($data) {
  439. foreach ($data as $k => $v) {
  440. $province = Dever::db('area/province')->one(array('name' => $v['province']));
  441. if ($province && $v['city']) {
  442. $city = Dever::db('area/city')->one(array('name' => $v['city'], 'province_id' => $province['id']));
  443. if ($city && $v['district']) {
  444. $county = Dever::db('area/county')->one(array('name' => $v['district'], 'city_id' => $city['id']));
  445. if ($county && $v['identity'] == 3) {
  446. # 区县
  447. Dever::db('area/county')->update(array('where_id' => $county['id'], 'price' => $v['money']));
  448. } elseif ($county && $v['street'] && $v['identity'] == 4) {
  449. # 街道
  450. if (strstr($v['street'], '燕郊')) {
  451. Dever::db('area/town')->update(array('where_id' => 131082450, 'price' => $v['money']));
  452. Dever::db('area/town')->update(array('where_id' => 131082109, 'price' => $v['money']));
  453. } else {
  454. $town = Dever::db('area/town')->one(array('name' => $v['street'], 'county_id' => $county['id']));
  455. if ($town) {
  456. Dever::db('area/town')->update(array('where_id' => $town['id'], 'price' => $v['money']));
  457. }
  458. }
  459. }
  460. }
  461. }
  462. }
  463. }
  464. }
  465. # 导入余额日志[不包括提现]
  466. private function getYue()
  467. {
  468. $data = $this->db->fetchAll('select * from mc_credits_record where credittype = "credit2" order by id asc');
  469. if ($data) {
  470. foreach ($data as $k => $v) {
  471. if ($v['credittype'] == 'credit2') {
  472. # 直推佣金
  473. $type = 1;
  474. } elseif ($v['credittype'] == 'credit3') {
  475. # 市场培训费
  476. $type = 2;
  477. } else {
  478. continue;
  479. }
  480. $remark = $v['remark'];
  481. if (strstr($remark, '提现')) {
  482. continue;
  483. }
  484. $info = Dever::db('bill/cash')->one(array('id' => $v['id'], 'clear' => true));
  485. if (!$info) {
  486. $update['id'] = $v['id'];
  487. $update['type'] = $type;
  488. if ($v['uid'] > 0) {
  489. $member = $this->db->fetch('select * from ims_ewei_shop_member where uid = ' . $v['uid'] . ' and isagent = 1 and status = 1 and prestatus = 1');
  490. if ($member) {
  491. $update['mid'] = $member['id'];
  492. }
  493. } elseif ($remark) {
  494. $temp = explode('OPENID: ', $remark);
  495. $temp = explode(' 剩余', $temp[1]);
  496. if (isset($temp[0]) && $temp[0]) {
  497. $member = $this->db->fetch('select * from ims_ewei_shop_member where openid = "' . $temp[0] . '" and isagent = 1 and status = 1 and prestatus = 1');
  498. if ($member) {
  499. $update['mid'] = $member['id'];
  500. }
  501. }
  502. }
  503. if (isset($update['mid']) && $update['mid'] > 0) {
  504. if (strstr($remark, '消费')) {
  505. $type = 12;
  506. }
  507. $update['cash'] = $v['num'];
  508. $update['yue'] = $v['presentcredit'];
  509. $update['status'] = 2;
  510. $update['audit'] = 2;
  511. $update['cdate'] = $update['operdate'] = $v['createtime'];
  512. $update['order_num'] = Dever::load('bill/lib/cash')->getOrderId();
  513. Dever::db('bill/cash')->insert($update);
  514. }
  515. }
  516. }
  517. }
  518. }
  519. # 获取提现
  520. private function getTixian()
  521. {
  522. $data = $this->db->fetchAll('select * from ims_ewei_shop_member_log where type > 0');
  523. if ($data) {
  524. foreach ($data as $k => $v) {
  525. $v['id'] = 50000 + $v['id'];
  526. $info = Dever::db('bill/cash')->one(array('id' => $v['id'], 'clear' => true));
  527. if (!$info) {
  528. $update['id'] = $v['id'];
  529. $update['type'] = 11;
  530. if ($v['uid'] > 0) {
  531. $member = $this->db->fetch('select * from ims_ewei_shop_member where uid = ' . $v['uid'] . ' and isagent = 1 and status = 1 and prestatus = 1');
  532. if ($member) {
  533. $update['mid'] = $member['id'];
  534. }
  535. } elseif ($remark) {
  536. $member = $this->db->fetch('select * from ims_ewei_shop_member where openid = "' . $v['openid'] . '" and isagent = 1 and status = 1 and prestatus = 1');
  537. if ($member) {
  538. $update['mid'] = $member['id'];
  539. }
  540. }
  541. if (isset($update['mid']) && $update['mid'] > 0) {
  542. $update['cash'] = $v['num'];
  543. $update['yue'] = $v['presentcredit'];
  544. $status = 1;
  545. $fstatus = -1;
  546. if ($v['status'] == 0 && $v['check'] == 0) {
  547. # 待审核
  548. $status = 1;
  549. } elseif ($v['status'] != -1 && $v['check'] == 1) {
  550. # 已审核
  551. $status = 2;
  552. } elseif ($v['status'] == 0 && $v['check'] == 1) {
  553. # 待发放
  554. $status = 2;
  555. $fstatus = 1;
  556. } elseif ($v['status'] == 1 && $v['check'] == 1) {
  557. # 已发放
  558. $status = 2;
  559. $fstatus = 2;
  560. } elseif ($v['check'] == -1) {
  561. # 已拒绝
  562. $status = 3;
  563. }
  564. $update['status'] = $status;
  565. $update['audit'] = $status;
  566. $update['cdate'] = $v['createtime'];
  567. $update['operdate'] = $v['checktime'];
  568. $update['order_num'] = Dever::load('bill/lib/cash')->getOrderId();
  569. $id = Dever::db('bill/cash')->insert($update);
  570. if ($id) {
  571. $tixian['order_num'] = Dever::load('bill/lib/tixian')->getOrderId();
  572. $tixian['id'] = $v['id'];
  573. $tixian['cash_id'] = $v['id'];
  574. $tixian['mid'] = $update['mid'];
  575. $tixian['ycash'] = $v['money'];
  576. $tixian['cash'] = $v['realmoney'];
  577. $tixian['yue'] = $v['deductionmoney'];
  578. $tixian['name'] = $v['realname'];
  579. $tixian['bank'] = $this->upBank($v['bankname']);
  580. $tixian['bankname'] = $v['bankopen'];
  581. $tixian['card'] = $v['bankcard'];
  582. $tixian['status'] = $fstatus;
  583. Dever::db('bill/tixian')->insert($tixian);
  584. }
  585. }
  586. }
  587. }
  588. }
  589. }
  590. # 导入关联表
  591. private function getRelation()
  592. {
  593. $data = $this->db->fetchAll('select * from ims_ewei_shop_commission_relation');
  594. if ($data) {
  595. foreach ($data as $k => $v) {
  596. $where['uid'] = $v['pid'];
  597. $where['to_uid'] = $v['id'];
  598. $where['level'] = $v['level'];
  599. $info = Dever::db('invite/relation')->one($where);
  600. if (!$info) {
  601. Dever::db('invite/relation')->insert($where);
  602. }
  603. }
  604. }
  605. }
  606. # 生成合同
  607. private function addAgreement($data)
  608. {
  609. Dever::load('agent/lib/agreement')->up($data);
  610. }
  611. # 更新进度
  612. private function addProcess($order_id, $status, $time, $data)
  613. {
  614. $where['order_id'] = $order_id;
  615. $where['status'] = $status;
  616. $info = Dever::db('agent/order_process')->find($where);
  617. if (!$info) {
  618. if ($status == 3) {
  619. $where['type'] = '1,2,3,5';
  620. }
  621. $where['cdate'] = $time;
  622. Dever::db('agent/order_process')->insert($where);
  623. }
  624. }
  625. # 状态对应
  626. private function getStatus($data)
  627. {
  628. # 完成权益发放issuingstate、财务审核status、初审prestatus的认为订单有效
  629. if ($data['issuingstate'] == 1 && $data['status'] == 1 && $data['prestatus'] == 1) {
  630. return 4;
  631. } elseif ($data['status'] == 1 && $data['prestatus'] == 1) {
  632. return 4;
  633. } elseif ($data['prestatus'] == 1) {
  634. return 2;
  635. } elseif ($data['restatus'] == 1) {
  636. # 审核失败
  637. return 5;
  638. } elseif ($data['trainersign'] && $data['contractsign']) {
  639. return 1;
  640. } else {
  641. return -2;
  642. }
  643. }
  644. # 代理商角色对应
  645. private function getRole($role)
  646. {
  647. # key是历史数据 value是最新数据
  648. $config = array
  649. (
  650. # 创服
  651. 5 => 5,
  652. # 创客
  653. 4 => 6,
  654. # 逍客
  655. 8 => 7,
  656. # 城市
  657. 1 => 2,
  658. # 区县
  659. 2 => 3,
  660. # 街道
  661. 3 => 4,
  662. # 炒菜机分享会员
  663. 6 => 8,
  664. # 热敏炉分享会员
  665. 7 => 9,
  666. );
  667. if (isset($config[$role]) && $config[$role]) {
  668. return $config[$role];
  669. }
  670. return 1;
  671. }
  672. }