Core.php 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249
  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)
  12. {
  13. $action = Dever::db('score/action')->one(array('key' => $action_key));
  14. if (!$action) {
  15. $action = array();
  16. $action['id'] = Dever::db('score/action')->insert(array('key' => $action_key, 'name' => $action_name));
  17. }
  18. if (isset($action['id']) && $action['id'] > 0) {
  19. $insert = array();
  20. $insert['uid'] = $uid;
  21. $insert['action_id'] = $action['id'];
  22. $insert['callback'] = $callback;
  23. if ($score > 0) {
  24. $insert['mscore'] = $score;
  25. }
  26. if ($num > 0) {
  27. $insert['num'] = $num;
  28. }
  29. $log_id = Dever::db('score/action_log')->insert($insert);
  30. Dever::daemon('lib/core.oper?log_id='.$log_id, 'score');
  31. //Dever::load('score/lib/core.oper?log_id='.$log_id);
  32. }
  33. }
  34. public function oper_api()
  35. {
  36. }
  37. /**
  38. * 根据用户行为,增加积分
  39. *
  40. * @return mixed
  41. */
  42. public function oper()
  43. {
  44. $log_id = Dever::input('log_id');
  45. $log = Dever::db('score/action_log')->one($log_id);
  46. $this->operAction($log);
  47. return $log;
  48. }
  49. private function rule($log, $info)
  50. {
  51. # 手动增加积分
  52. if (isset($log['mscore']) && $log['mscore'] > 0) {
  53. $info['num'] = $log['mscore'];
  54. }
  55. # 积分乘以倍数
  56. if (isset($log['num']) && $log['num'] > 0) {
  57. $info['num'] = $info['num'] * $log['num'];
  58. }
  59. if ($info['num'] == 0) {
  60. return;
  61. }
  62. $uid = $log['uid'];
  63. $user = Dever::db('score/user')->one(array('uid' => $uid, 'config_id' => $info['config_id']));
  64. if (!$user) {
  65. $user = array();
  66. $user['id'] = Dever::db('score/user')->insert(array('uid' => $uid, 'config_id' => $info['config_id'], 'score' => 0, 'no_score' => 0));
  67. $user['score'] = 0;
  68. }
  69. $num = $info['num'];
  70. if ($info['upper'] == 2 && $info['upper_limit'] >= 1) {
  71. $upper = $this->upper($uid, $info, $log);
  72. if (!$upper) {
  73. Dever::db('score/action_log')->update(array('where_id' => $log['id'], 'score_type' => 3, 'score' => '0'));
  74. return;
  75. }
  76. Dever::db('score/action_log')->update(array('where_id' => $log['id'], 'score_type' => 2, 'score' => $num));
  77. } else {
  78. Dever::db('score/action_log')->update(array('where_id' => $log['id'], 'score_type' => 2, 'score' => $num));
  79. }
  80. $update = array();
  81. $update['where_id'] = $user['id'];
  82. $update['score'] = $user['score'] + $num;
  83. $insert['uid'] = $uid;
  84. $insert['config_id'] = $info['config_id'];
  85. $insert['action_id'] = $info['action_id'];
  86. $insert['status'] = 1;
  87. $insert['num'] = $num;
  88. $insert['total'] = $update['score'];
  89. $user_log_id = Dever::db('score/user_log')->insert($insert);
  90. Dever::db('score/user')->update($update);
  91. # 提升等级
  92. $this->setLevel($uid);
  93. if ($log['callback']) {
  94. if (strstr($log['callback'], '?')) {
  95. Dever::load($log['callback'] . '&user_log_id=' . $user_log_id);
  96. } else {
  97. Dever::load($log['callback'], $user_log_id);
  98. }
  99. }
  100. }
  101. private function upper($uid, $info)
  102. {
  103. # 有上限限制
  104. $limit = $info['upper_limit'];
  105. # 获取用户最新一次积分变化日志
  106. $time = time();
  107. $where = array();
  108. $where['config_id'] = $info['config_id'];
  109. $where['action_id'] = $info['action_id'];
  110. $where['uid'] = $uid;
  111. $where['status'] = 1;
  112. $user_log = Dever::db('score/user_log')->getNew($where);
  113. if ($user_log) {
  114. if ($info['upper_type'] == 1) {
  115. # 按天
  116. $where['start'] = Dever::maketime(date('Y-m-d 00:00:00', $time));
  117. //$where['end'] = $end;
  118. } elseif ($info['upper_type'] == 2) {
  119. # 按小时
  120. $where['start'] = $time - ($info['upper_time'] * 3600);
  121. //$where['end'] = $end;
  122. } elseif ($info['upper_type'] == 3) {
  123. # 永久
  124. } else {
  125. return true;
  126. }
  127. $user_log_num = Dever::db('score/user_log')->getNewTotal($where);
  128. if ($user_log_num >= $info['upper_limit']) {
  129. return false;
  130. }
  131. }
  132. return true;
  133. }
  134. private function operAction($log)
  135. {
  136. if ($log && $log['score_type'] == 1) {
  137. $where = array();
  138. $where['state'] = 1;
  139. $where['id'] = $log['action_id'];
  140. $action = Dever::db('score/action')->one($where);
  141. if ($action) {
  142. $rule = Dever::db('score/rule')->state(array('action_id' => $action['id']));
  143. if ($rule) {
  144. foreach ($rule as $k => $v) {
  145. $this->rule($log, $v);
  146. }
  147. }
  148. }
  149. }
  150. }
  151. /**
  152. * 根据积分日志和规则,增加积分,这是一个定时任务,暂时不开启了
  153. *
  154. * @return mixed
  155. */
  156. public function cron()
  157. {
  158. $where['score_type'] = 1;
  159. $log = Dever::db('score/action_log')->all($where);
  160. if ($log) {
  161. foreach ($log as $k => $v) {
  162. $this->operAction($v);
  163. }
  164. }
  165. }
  166. /**
  167. * 根据积分算等级
  168. *
  169. * @return mixed
  170. */
  171. public function setLevel($uid)
  172. {
  173. # 获取当前用户的等级
  174. $where['uid'] = $uid;
  175. $user_level = Dever::db('score/user_level')->one($where);
  176. if ($user_level && $user_level['type'] == 2) {
  177. return;
  178. } elseif ($user_level && $user_level['type'] == 1) {
  179. $config = Dever::db('score/level')->one($user_level['level_id']);
  180. $level = $config['level'] + 1;
  181. } else {
  182. $level = 1;
  183. }
  184. $config = Dever::db('score/level')->one(array('level' => $level, 'state' => 1));
  185. if ($config) {
  186. # 是否能升级
  187. $yes = false;
  188. $rule = Dever::array_decode($config['score']);
  189. if ($rule) {
  190. $user_score = Dever::db('score/user')->getScoreByConfig($where);
  191. if ($user_score) {
  192. foreach ($rule as $k => $v) {
  193. $score = $v['config'];
  194. $num = $v['num'];
  195. if (isset($user_score[$score]) && $user_score[$score]['score'] && $user_score[$score]['score'] >= $num) {
  196. $yes = $config['id'];
  197. } else {
  198. $yes = false;
  199. }
  200. }
  201. }
  202. }
  203. if ($yes) {
  204. # 可以升级
  205. if ($user_level) {
  206. Dever::db('score/user_level')->update(array('where_id' => $user_level['id'], 'level_id' => $yes));
  207. } else {
  208. Dever::db('score/user_level')->insert(array('uid' => $uid,'level_id' => $yes, 'type' => 1));
  209. }
  210. }
  211. }
  212. }
  213. }