Core.php 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539
  1. <?php
  2. namespace Score\Lib;
  3. use Dever;
  4. class Core
  5. {
  6. /**
  7. * 增加日志 Dever::load('score/lib/core')->log($uid, $key, $name);
  8. *
  9. * @return mixed
  10. */
  11. public function log($uid, $action_key, $action_name, $callback = '', $score = false, $num = false, $type = false, $type_id = false)
  12. {
  13. if (strstr($action_key, '.')) {
  14. $temp = explode('.', $action_key);
  15. $action_key = $temp[0];
  16. $type = $temp[1];
  17. $type_id = $temp[2];
  18. }
  19. $action = Dever::db('score/action')->one(array('key' => $action_key));
  20. if (!$action) {
  21. $action = array();
  22. $action['id'] = Dever::db('score/action')->insert(array('key' => $action_key, 'name' => $action_name));
  23. }
  24. if (isset($action['id']) && $action['id'] > 0) {
  25. $insert = array();
  26. $parent_uid = 0;
  27. if (strstr($uid, '_')) {
  28. $temp = explode('_', $uid);
  29. $uid = $temp[1];
  30. $parent_uid = $temp[0];
  31. }
  32. $insert['uid'] = $uid;
  33. $insert['action_id'] = $action['id'];
  34. $insert['callback'] = $callback;
  35. if ($score > 0) {
  36. $insert['mscore'] = $score;
  37. }
  38. if ($num > 0) {
  39. $insert['num'] = $num;
  40. }
  41. if ($parent_uid > 0) {
  42. $insert['parent_uid'] = $parent_uid;
  43. }
  44. if ($type) {
  45. $insert['type'] = $type;
  46. }
  47. if ($type_id) {
  48. $insert['type_id'] = $type_id;
  49. }
  50. $insert['cron_type'] = 1;
  51. $log_id = Dever::db('score/action_log')->insert($insert);
  52. //Dever::load('score/lib/core.oper_commit?log_id='.$log_id);
  53. return;
  54. $sync = Dever::config('base', 'project')->score['sync'];
  55. if ($sync) {
  56. Dever::daemon('lib/core.oper?log_id='.$log_id, 'score');
  57. }
  58. //Dever::daemon('lib/core.oper?log_id='.$log_id, 'score');
  59. //Dever::load('score/lib/core.oper?log_id='.$log_id);
  60. }
  61. }
  62. # 获取积分列表
  63. public function getScore()
  64. {
  65. $data = Dever::db('score/config')->state();
  66. return $data;
  67. }
  68. # 获取某一个用户的积分
  69. public function getUserScore($uid, $config_id = false, $type = false, $type_id = false)
  70. {
  71. if ($config_id && $type && $type_id) {
  72. $where['config_id'] = $config_id;
  73. $where['type'] = $type;
  74. $where['type_id'] = $type_id;
  75. $where['state'] = 1;
  76. $child = Dever::db('score/config_child')->one($where);
  77. if ($child) {
  78. $where = array();
  79. $where['uid'] = $uid;
  80. $where['config_child_id'] = $child['id'];
  81. $score = Dever::db('score/user_child')->one($where);
  82. return array('name' => $child['name'], 'score' => $score['score'] ? $score['score'] : 0);
  83. }
  84. }
  85. if (!$config_id) {
  86. $config = Dever::db('score/config')->one(array('type' => 1));
  87. } else {
  88. $config = Dever::db('score/config')->one($config_id);
  89. }
  90. if ($config) {
  91. $where = array();
  92. $where['uid'] = $uid;
  93. $where['config_id'] = $config['id'];
  94. $score = Dever::db('score/user')->one($where);
  95. return array('name' => $config['name'], 'score' => $score['score'] ? $score['score'] : 0);
  96. }
  97. return false;
  98. }
  99. # 设置子积分
  100. public function setScoreChild($config_type, $config_id, $type, $type_id, $name)
  101. {
  102. $where['config_id'] = $config_id;
  103. $where['type'] = $type;
  104. $where['type_id'] = $type_id;
  105. $info = Dever::db('score/config_child')->one($where);
  106. if ($info && $config_type == 1) {
  107. $update['where_id'] = $info['id'];
  108. $update['state'] = 2;
  109. Dever::db('score/config_child')->update($update);
  110. } elseif ($config_type == 2) {
  111. if (!$name) {
  112. $config = Dever::db('score/config')->one($config_id);
  113. $name = $config['name'];
  114. }
  115. if ($info) {
  116. $update['where_id'] = $info['id'];
  117. $update['name'] = $name;
  118. $update['state'] = 1;
  119. Dever::db('score/config_child')->update($update);
  120. } else {
  121. $insert = $where;
  122. $insert['name'] = $name;
  123. Dever::db('score/config_child')->insert($insert);
  124. }
  125. }
  126. return true;
  127. }
  128. public function oper_api()
  129. {
  130. }
  131. public function oper_commit()
  132. {
  133. }
  134. /**
  135. * 根据用户行为,增加积分
  136. *
  137. * @return mixed
  138. */
  139. public function oper()
  140. {
  141. $log_id = Dever::input('log_id');
  142. $log = Dever::db('score/action_log')->one($log_id);
  143. $this->operAction($log);
  144. return $log;
  145. }
  146. private function rule($log, $info)
  147. {
  148. $config = Dever::db('score/config')->one($info['config_id']);
  149. if (!$config) {
  150. return;
  151. }
  152. if ($config && $config['state'] == 2) {
  153. return;
  154. }
  155. # 手动增加积分
  156. if (isset($log['mscore']) && $log['mscore'] > 0) {
  157. $info['num'] = $log['mscore'];
  158. }
  159. # 积分乘以倍数
  160. if (isset($log['num']) && $log['num'] > 0) {
  161. $info['num'] = $info['num'] * $log['num'];
  162. }
  163. if ($info['num'] == 0) {
  164. # 未加数据
  165. return $this->finish($log);
  166. }
  167. $uid = $log['uid'];
  168. $num = $info['num'];
  169. $this->user = 'score/user';
  170. $this->user_log = 'score/user_log';
  171. $info['config_child_id'] = false;
  172. # 验证是否有子积分设置
  173. if ($log['type'] && $log['type_id']) {
  174. $child = Dever::db('score/config_child')->one(array(
  175. 'config_id' => $info['config_id'], 'type' => $log['type'], 'type_id' => $log['type_id'], 'state' => 1));
  176. if ($child) {
  177. $this->user = 'score/user_child';
  178. $this->user_log = 'score/user_child_log';
  179. $info['config_child_id'] = $child['id'];
  180. }
  181. }
  182. if ($info['upper'] == 2 && $info['upper_limit'] >= 1) {
  183. $upper = $this->upper($uid, $info, $log);
  184. if (!$upper) {
  185. # 达到积分上限
  186. return $this->finish($log, 3, '0');
  187. }
  188. }
  189. # 完成
  190. $this->finish($log, 2, $num);
  191. $user_log = $this->add($uid, $num, $info, $log);
  192. if (!$user_log['id']) {
  193. return;
  194. }
  195. $user_log['type'] = $info['type'];
  196. $user_log['type_id'] = $info['type_id'];
  197. # 增加返利
  198. if ($info['rebate_type'] > 1) {
  199. $this->rebate($uid, $num, $info, $log);
  200. }
  201. if ($log['callback']) {
  202. Dever::load($log['callback'], $user_log);
  203. /*
  204. if (strstr($log['callback'], '?')) {
  205. Dever::load($log['callback'] . '&user_log_id=' . $user_log_id);
  206. } else {
  207. Dever::load($log['callback'], $user_log_id);
  208. }
  209. */
  210. } elseif ($config['callback_type'] > 1 && $config['callback_value']) {
  211. if ($config['callback_type'] == 2) {
  212. Dever::load($config['callback_value'], $user_log);
  213. } elseif ($config['callback_type'] == 3) {
  214. Dever::curl($config['callback_value'], $user_log, 'post');
  215. } elseif ($config['callback_type'] == 4) {
  216. $temp = explode('/', $config['callback_value']);
  217. $config['callback_value'] = str_replace($temp[0] . '/', '', $config['callback_value']);
  218. Dever::daemon($config['callback_value'] . '?log_id='.$user_log['id'], $temp[0]);
  219. }
  220. }
  221. }
  222. # 增加积分
  223. private function add($uid, $num, $info, $log, $rebate_uid = false)
  224. {
  225. $where = array();
  226. $where['uid'] = $uid;
  227. $where['config_id'] = $info['config_id'];
  228. if ($info['config_child_id']) {
  229. $where['config_child_id'] = $info['config_child_id'];
  230. }
  231. $user = Dever::db($this->user)->one($where);
  232. if (!$user) {
  233. $user = array();
  234. $user['id'] = Dever::db($this->user)->insert($where);
  235. $user['score'] = 0;
  236. }
  237. $update = array();
  238. $update['where_id'] = $user['id'];
  239. $update['score'] = $user['score'] + $num;
  240. $insert = $where;
  241. $insert['action_log_id'] = $log['id'];
  242. $insert['action_id'] = $info['action_id'];
  243. if ($rebate_uid) {
  244. $insert['rebate_uid'] = $rebate_uid;
  245. }
  246. $insert['status'] = 1;
  247. $insert['num'] = $num;
  248. $insert['total'] = $update['score'];
  249. $insert['cdate'] = time();
  250. $insert['id'] = Dever::db($this->user_log)->insert($insert);
  251. if ($user_log_id) {
  252. Dever::db($this->user)->update($update);
  253. # 提升等级
  254. $level_type = Dever::db('score/level_type')->state();
  255. if ($level_type) {
  256. foreach ($level_type as $k => $v) {
  257. $this->setLevel($uid, $v);
  258. }
  259. }
  260. }
  261. return $insert;
  262. }
  263. # 返利
  264. private function rebate($uid, $num, $info, $log)
  265. {
  266. if (!strstr($info['rebate_value'], ':')) {
  267. $info['rebate_value'] = '1:' . $info['rebate_value'];
  268. }
  269. $temp = explode(',', $info['rebate_value']);
  270. $invite = Dever::project('invite');
  271. $parent_uid = false;
  272. foreach ($temp as $k => $v) {
  273. $config = explode(':', $v);
  274. $value = $config[1];
  275. if ($info['rebate_type'] == 2) {
  276. # 百分比
  277. $value = round($num*($value/100), 2);
  278. }
  279. # 直属上级
  280. if ($config[0] == 1) {
  281. if ($log['parent_uid'] > 0) {
  282. $parent_uid = $log['parent_uid'];
  283. } elseif ($invite) {
  284. $parent_uid = Dever::load('invite/api')->getParent($uid, $config[0]);
  285. }
  286. if ($parent_uid > 0) {
  287. $this->add($parent_uid, $value, $info, $log, $uid);
  288. }
  289. } elseif ($invite) {
  290. # 上级的上级
  291. if ($parent_uid > 0) {
  292. $rebate_uid = $parent_uid;
  293. $level = $config[0]-1;
  294. } else {
  295. $rebate_uid = $uid;
  296. $level = $config[0];
  297. }
  298. $other_parent_uid = Dever::load('invite/api')->getParent($rebate_uid, $level);
  299. if ($other_parent_uid > 0) {
  300. $this->add($other_parent_uid, $value, $info, $log, $rebate_uid);
  301. }
  302. }
  303. }
  304. }
  305. # 迁移完成的数据
  306. private function finish($log, $score_type = 1, $score = 'no')
  307. {
  308. $id = $log['id'];
  309. if ($score_type == -1) {
  310. Dever::db('score/action_log')->update(array('where_id' => $id, 'cron_type' => 3));
  311. } else {
  312. unset($log['id']);
  313. $log['log_id'] = $id;
  314. $log['cron_type'] = 3;
  315. $log['score_type'] = $score_type;
  316. if ($score != 'no') {
  317. $log['score'] = $score;
  318. }
  319. Dever::db('score/action_log_finish')->insert($log);
  320. Dever::db('score/action_log')->delete($id);
  321. }
  322. return true;
  323. }
  324. # 设置上限限制
  325. private function upper($uid, $info, $log)
  326. {
  327. # 有上限限制
  328. $limit = $info['upper_limit'];
  329. # 获取用户最新一次积分变化日志
  330. $time = time();
  331. $where = array();
  332. if ($info['config_child_id']) {
  333. $where['config_child_id'] = $info['config_child_id'];
  334. }
  335. $where['config_id'] = $info['config_id'];
  336. $where['action_id'] = $info['action_id'];
  337. $where['uid'] = $uid;
  338. $where['status'] = 1;
  339. $user_log = Dever::db($this->user_log)->getNew($where);
  340. if ($user_log) {
  341. if ($info['upper_type'] == 1) {
  342. # 按天
  343. $where['start'] = Dever::maketime(date('Y-m-d 00:00:00', $time));
  344. //$where['end'] = $end;
  345. } elseif ($info['upper_type'] == 2) {
  346. # 按小时
  347. $where['start'] = $time - ($info['upper_time'] * 3600);
  348. //$where['end'] = $end;
  349. } elseif ($info['upper_type'] == 3) {
  350. # 永久
  351. } else {
  352. return true;
  353. }
  354. $user_log_num = Dever::db($this->user_log)->getNewTotal($where);
  355. if ($user_log_num >= $info['upper_limit']) {
  356. return false;
  357. }
  358. }
  359. return true;
  360. }
  361. private function operAction($log)
  362. {
  363. if ($log && $log['cron_type'] == 1) {
  364. Dever::db('score/action_log')->update(array('where_id' => $log['id'], 'cron_type' => 2));
  365. $where = array();
  366. $where['state'] = 1;
  367. $where['id'] = $log['action_id'];
  368. $action = Dever::db('score/action')->one($where);
  369. if ($action) {
  370. $rule = Dever::db('score/rule')->state(array('action_id' => $action['id']));
  371. if ($rule) {
  372. foreach ($rule as $k => $v) {
  373. $this->rule($log, $v);
  374. }
  375. }
  376. }
  377. }
  378. }
  379. /**
  380. * 根据积分日志和规则,增加积分,这是一个定时任务,可以设置每天凌晨启动
  381. *
  382. * @return mixed
  383. */
  384. public function cron()
  385. {
  386. $where['cron_type'] = 1;
  387. $log = Dever::db('score/action_log')->all($where);
  388. if ($log) {
  389. foreach ($log as $k => $v) {
  390. $this->operAction($v);
  391. }
  392. }
  393. }
  394. /**
  395. * 根据积分算等级,如果是自动升级,则直接升级,如果是手动升级,则将其标识置为可以升级状态。
  396. *
  397. * @return mixed
  398. */
  399. public function setLevel($uid, $level_type)
  400. {
  401. # 获取当前用户的等级
  402. $where['uid'] = $uid;
  403. $where['level_type_id'] = $level_type['id'];
  404. $user_level = Dever::db('score/user_level')->one($where);
  405. /*
  406. if ($user_level && $user_level['type'] == 2) {
  407. return;
  408. } else
  409. */
  410. $update = array();
  411. if ($user_level) {
  412. $config = Dever::db('score/level')->one($user_level['level_id']);
  413. $level = $config['level'] + 1;
  414. $method = 'update';
  415. $update['where_id'] = $user_level['id'];
  416. } else {
  417. $level = 1;
  418. $method = 'insert';
  419. }
  420. $config = Dever::db('score/level')->one(array('level' => $level, 'level_type_id' => $level_type['id'], 'state' => 1));
  421. if ($config) {
  422. # 是否能升级
  423. $yes = false;
  424. if ($config['total_type'] == 1 && $config['total'] > 0) {
  425. # 查看是否超过总数
  426. $total = Dever::db('score/user_level')->total(array('level_id' => $config['id']));
  427. if ($total >= $config['total']) {
  428. return $yes;
  429. }
  430. }
  431. $rule = Dever::array_decode($config['score']);
  432. if ($rule) {
  433. $user_score = Dever::db($this->user)->getScoreByConfig($where);
  434. if ($user_score) {
  435. foreach ($rule as $k => $v) {
  436. $score = $v['config'];
  437. $num = $v['num'];
  438. if (isset($user_score[$score]) && $user_score[$score]['score'] && $user_score[$score]['score'] >= $num) {
  439. $yes = $config['id'];
  440. # 是否清空积分 当type为自动并且score为2时
  441. if ($level_type['score'] == 2 && $level_type['type'] == 1) {
  442. $user_score_update['where_id'] = $user_score[$score]['id'];
  443. $user_score_update['score'] = $user_score[$score]['score'] - $num;
  444. Dever::db($this->user)->update($user_score_update);
  445. }
  446. } else {
  447. $yes = false;
  448. }
  449. }
  450. }
  451. }
  452. # 可以升级
  453. if ($yes) {
  454. if ($level_type['type'] == 2) {
  455. $update['next_level_id'] = $yes;
  456. $update['level_status'] = 1;
  457. } else {
  458. $update['level_id'] = $update['next_level_id'] = $yes;
  459. $update['level_status'] = 2;
  460. }
  461. $update['uid'] = $uid;
  462. $update['level_type_id'] = $level_type['id'];
  463. Dever::db('score/user_level')->$method($update);
  464. }
  465. }
  466. }
  467. }