Core.php 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534
  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_commit_api()
  129. {
  130. }
  131. /**
  132. * 根据用户行为,增加积分
  133. *
  134. * @return mixed
  135. */
  136. public function oper_commit()
  137. {
  138. $log_id = Dever::input('log_id');
  139. $log = Dever::db('score/action_log')->one($log_id);
  140. $this->operAction($log);
  141. return $log;
  142. }
  143. private function rule($log, $info)
  144. {
  145. $config = Dever::db('score/config')->one($info['config_id']);
  146. if (!$config) {
  147. return;
  148. }
  149. if ($config && $config['state'] == 2) {
  150. return;
  151. }
  152. # 手动增加积分
  153. if (isset($log['mscore']) && $log['mscore'] > 0) {
  154. $info['num'] = $log['mscore'];
  155. }
  156. # 积分乘以倍数
  157. if (isset($log['num']) && $log['num'] > 0) {
  158. $info['num'] = $info['num'] * $log['num'];
  159. }
  160. if ($info['num'] == 0) {
  161. # 未加数据
  162. return $this->finish($log);
  163. }
  164. $uid = $log['uid'];
  165. $num = $info['num'];
  166. $this->user = 'score/user';
  167. $this->user_log = 'score/user_log';
  168. $info['config_child_id'] = false;
  169. # 验证是否有子积分设置
  170. if ($log['type'] && $log['type_id']) {
  171. $child = Dever::db('score/config_child')->one(array(
  172. 'config_id' => $info['config_id'], 'type' => $log['type'], 'type_id' => $log['type_id'], 'state' => 1));
  173. if ($child) {
  174. $this->user = 'score/user_child';
  175. $this->user_log = 'score/user_child_log';
  176. $info['config_child_id'] = $child['id'];
  177. }
  178. }
  179. if ($info['upper'] == 2 && $info['upper_limit'] >= 1) {
  180. $upper = $this->upper($uid, $info, $log);
  181. if (!$upper) {
  182. # 达到积分上限
  183. return $this->finish($log, 3, '0');
  184. }
  185. }
  186. # 完成
  187. $this->finish($log, 2, $num);
  188. $user_log = $this->add($uid, $num, $info, $log);
  189. if (!$user_log['id']) {
  190. return;
  191. }
  192. $user_log['type'] = $log['type'];
  193. $user_log['type_id'] = $log['type_id'];
  194. # 增加返利
  195. if ($info['rebate_type'] > 1) {
  196. $this->rebate($uid, $num, $info, $log);
  197. }
  198. if ($log['callback']) {
  199. Dever::load($log['callback'], $user_log);
  200. /*
  201. if (strstr($log['callback'], '?')) {
  202. Dever::load($log['callback'] . '&user_log_id=' . $user_log_id);
  203. } else {
  204. Dever::load($log['callback'], $user_log_id);
  205. }
  206. */
  207. } elseif ($config['callback_type'] > 1 && $config['callback_value']) {
  208. if ($config['callback_type'] == 2) {
  209. Dever::load($config['callback_value'], $user_log);
  210. } elseif ($config['callback_type'] == 3) {
  211. Dever::curl($config['callback_value'], $user_log, 'post');
  212. } elseif ($config['callback_type'] == 4) {
  213. $temp = explode('/', $config['callback_value']);
  214. $config['callback_value'] = str_replace($temp[0] . '/', '', $config['callback_value']);
  215. Dever::daemon($config['callback_value'] . '?log_id='.$user_log['id'], $temp[0]);
  216. }
  217. }
  218. }
  219. # 增加积分
  220. private function add($uid, $num, $info, $log, $rebate_uid = false)
  221. {
  222. $where = array();
  223. $where['uid'] = $uid;
  224. $where['config_id'] = $info['config_id'];
  225. if ($info['config_child_id']) {
  226. $where['config_child_id'] = $info['config_child_id'];
  227. }
  228. $user = Dever::db($this->user)->one($where);
  229. if (!$user) {
  230. $user = array();
  231. $user['id'] = Dever::db($this->user)->insert($where);
  232. $user['score'] = 0;
  233. }
  234. $update = array();
  235. $update['where_id'] = $user['id'];
  236. $update['score'] = $user['score'] + $num;
  237. $insert = $where;
  238. $insert['action_log_id'] = $log['id'];
  239. $insert['action_id'] = $info['action_id'];
  240. if ($rebate_uid) {
  241. $insert['rebate_uid'] = $rebate_uid;
  242. }
  243. $insert['status'] = 1;
  244. $insert['num'] = $num;
  245. $insert['total'] = $update['score'];
  246. $insert['cdate'] = time();
  247. $insert['id'] = Dever::db($this->user_log)->insert($insert);
  248. if ($insert['id']) {
  249. Dever::db($this->user)->update($update);
  250. # 提升等级
  251. $level_type = Dever::db('score/level_type')->state();
  252. if ($level_type) {
  253. foreach ($level_type as $k => $v) {
  254. $this->setLevel($uid, $v);
  255. }
  256. }
  257. }
  258. return $insert;
  259. }
  260. # 返利
  261. private function rebate($uid, $num, $info, $log)
  262. {
  263. if (!strstr($info['rebate_value'], ':')) {
  264. $info['rebate_value'] = '1:' . $info['rebate_value'];
  265. }
  266. $temp = explode(',', $info['rebate_value']);
  267. $invite = Dever::project('invite');
  268. $parent_uid = false;
  269. foreach ($temp as $k => $v) {
  270. $config = explode(':', $v);
  271. $value = $config[1];
  272. if ($info['rebate_type'] == 2) {
  273. # 百分比
  274. $value = round($num*($value/100), 2);
  275. }
  276. # 直属上级
  277. if ($config[0] == 1) {
  278. if ($log['parent_uid'] > 0) {
  279. $parent_uid = $log['parent_uid'];
  280. } elseif ($invite) {
  281. $parent_uid = Dever::load('invite/api')->getParent($uid, $config[0]);
  282. }
  283. if ($parent_uid > 0) {
  284. $this->add($parent_uid, $value, $info, $log, $uid);
  285. }
  286. } elseif ($invite) {
  287. # 上级的上级
  288. if ($parent_uid > 0) {
  289. $rebate_uid = $parent_uid;
  290. $level = $config[0]-1;
  291. } else {
  292. $rebate_uid = $uid;
  293. $level = $config[0];
  294. }
  295. $other_parent_uid = Dever::load('invite/api')->getParent($rebate_uid, $level);
  296. if ($other_parent_uid > 0) {
  297. $this->add($other_parent_uid, $value, $info, $log, $rebate_uid);
  298. }
  299. }
  300. }
  301. }
  302. # 迁移完成的数据
  303. private function finish($log, $score_type = 1, $score = 'no')
  304. {
  305. $id = $log['id'];
  306. if ($score_type == -1) {
  307. Dever::db('score/action_log')->update(array('where_id' => $id, 'cron_type' => 3));
  308. } else {
  309. unset($log['id']);
  310. $log['log_id'] = $id;
  311. $log['cron_type'] = 3;
  312. $log['score_type'] = $score_type;
  313. if ($score != 'no') {
  314. $log['score'] = $score;
  315. }
  316. Dever::db('score/action_log_finish')->insert($log);
  317. Dever::db('score/action_log')->delete($id);
  318. }
  319. return true;
  320. }
  321. # 设置上限限制
  322. private function upper($uid, $info, $log)
  323. {
  324. # 有上限限制
  325. $limit = $info['upper_limit'];
  326. # 获取用户最新一次积分变化日志
  327. $time = time();
  328. $where = array();
  329. if ($info['config_child_id']) {
  330. $where['config_child_id'] = $info['config_child_id'];
  331. }
  332. $where['config_id'] = $info['config_id'];
  333. $where['action_id'] = $info['action_id'];
  334. $where['uid'] = $uid;
  335. $where['status'] = 1;
  336. $user_log = Dever::db($this->user_log)->getNew($where);
  337. if ($user_log) {
  338. if ($info['upper_type'] == 1) {
  339. # 按天
  340. $where['start'] = Dever::maketime(date('Y-m-d 00:00:00', $time));
  341. //$where['end'] = $end;
  342. } elseif ($info['upper_type'] == 2) {
  343. # 按小时
  344. $where['start'] = $time - ($info['upper_time'] * 3600);
  345. //$where['end'] = $end;
  346. } elseif ($info['upper_type'] == 3) {
  347. # 永久
  348. } else {
  349. return true;
  350. }
  351. $user_log_num = Dever::db($this->user_log)->getNewTotal($where);
  352. if ($user_log_num >= $info['upper_limit']) {
  353. return false;
  354. }
  355. }
  356. return true;
  357. }
  358. private function operAction($log)
  359. {
  360. if ($log && $log['cron_type']) {
  361. Dever::db('score/action_log')->update(array('where_id' => $log['id'], 'cron_type' => 2));
  362. $where = array();
  363. $where['state'] = 1;
  364. $where['id'] = $log['action_id'];
  365. $action = Dever::db('score/action')->one($where);
  366. if ($action) {
  367. $rule = Dever::db('score/rule')->state(array('action_id' => $action['id']));
  368. if ($rule) {
  369. foreach ($rule as $k => $v) {
  370. $this->rule($log, $v);
  371. }
  372. }
  373. }
  374. }
  375. }
  376. /**
  377. * 根据积分日志和规则,增加积分,这是一个定时任务,可以设置每天凌晨启动
  378. *
  379. * @return mixed
  380. */
  381. public function cron()
  382. {
  383. $where['cron_type'] = 1;
  384. $log = Dever::db('score/action_log')->all($where);
  385. if ($log) {
  386. foreach ($log as $k => $v) {
  387. $this->operAction($v);
  388. }
  389. }
  390. }
  391. /**
  392. * 根据积分算等级,如果是自动升级,则直接升级,如果是手动升级,则将其标识置为可以升级状态。
  393. *
  394. * @return mixed
  395. */
  396. public function setLevel($uid, $level_type)
  397. {
  398. # 获取当前用户的等级
  399. $where['uid'] = $uid;
  400. $where['level_type_id'] = $level_type['id'];
  401. $user_level = Dever::db('score/user_level')->one($where);
  402. /*
  403. if ($user_level && $user_level['type'] == 2) {
  404. return;
  405. } else
  406. */
  407. $update = array();
  408. if ($user_level) {
  409. $config = Dever::db('score/level')->one($user_level['level_id']);
  410. $level = $config['level'] + 1;
  411. $method = 'update';
  412. $update['where_id'] = $user_level['id'];
  413. } else {
  414. $level = 1;
  415. $method = 'insert';
  416. }
  417. $config = Dever::db('score/level')->one(array('level' => $level, 'level_type_id' => $level_type['id'], 'state' => 1));
  418. if ($config) {
  419. # 是否能升级
  420. $yes = false;
  421. if ($config['total_type'] == 1 && $config['total'] > 0) {
  422. # 查看是否超过总数
  423. $total = Dever::db('score/user_level')->total(array('level_id' => $config['id']));
  424. if ($total >= $config['total']) {
  425. return $yes;
  426. }
  427. }
  428. $rule = Dever::array_decode($config['score']);
  429. if ($rule) {
  430. $user_score = Dever::db($this->user)->getScoreByConfig($where);
  431. if ($user_score) {
  432. foreach ($rule as $k => $v) {
  433. $score = $v['config'];
  434. $num = $v['num'];
  435. if (isset($user_score[$score]) && $user_score[$score]['score'] && $user_score[$score]['score'] >= $num) {
  436. $yes = $config['id'];
  437. # 是否清空积分 当type为自动并且score为2时
  438. if ($level_type['score'] == 2 && $level_type['type'] == 1) {
  439. $user_score_update['where_id'] = $user_score[$score]['id'];
  440. $user_score_update['score'] = $user_score[$score]['score'] - $num;
  441. Dever::db($this->user)->update($user_score_update);
  442. }
  443. } else {
  444. $yes = false;
  445. }
  446. }
  447. }
  448. }
  449. # 可以升级
  450. if ($yes) {
  451. if ($level_type['type'] == 2) {
  452. $update['next_level_id'] = $yes;
  453. $update['level_status'] = 1;
  454. } else {
  455. $update['level_id'] = $update['next_level_id'] = $yes;
  456. $update['level_status'] = 2;
  457. }
  458. $update['uid'] = $uid;
  459. $update['level_type_id'] = $level_type['id'];
  460. Dever::db('score/user_level')->$method($update);
  461. }
  462. }
  463. }
  464. }