Core.php 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247
  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. }
  78. $update = array();
  79. $update['where_id'] = $user['id'];
  80. $update['score'] = $user['score'] + $num;
  81. $insert['uid'] = $uid;
  82. $insert['config_id'] = $info['config_id'];
  83. $insert['action_id'] = $info['action_id'];
  84. $insert['status'] = 1;
  85. $insert['num'] = $num;
  86. $insert['total'] = $update['score'];
  87. $user_log_id = Dever::db('score/user_log')->insert($insert);
  88. Dever::db('score/user')->update($update);
  89. # 提升等级
  90. $this->setLevel($uid);
  91. if ($log['callback']) {
  92. if (strstr($log['callback'], '?')) {
  93. Dever::load($log['callback'] . '&user_log_id=' . $user_log_id);
  94. } else {
  95. Dever::load($log['callback'], $user_log_id);
  96. }
  97. }
  98. }
  99. private function upper($uid, $info)
  100. {
  101. # 有上限限制
  102. $limit = $info['upper_limit'];
  103. # 获取用户最新一次积分变化日志
  104. $time = time();
  105. $where = array();
  106. $where['config_id'] = $info['config_id'];
  107. $where['action_id'] = $info['action_id'];
  108. $where['uid'] = $uid;
  109. $where['status'] = 1;
  110. $user_log = Dever::db('score/user_log')->getNew($where);
  111. if ($user_log) {
  112. if ($info['upper_type'] == 1) {
  113. # 按天
  114. $where['start'] = Dever::maketime(date('Y-m-d 00:00:00', $time));
  115. //$where['end'] = $end;
  116. } elseif ($info['upper_type'] == 2) {
  117. # 按小时
  118. $where['start'] = $time - ($info['upper_time'] * 3600);
  119. //$where['end'] = $end;
  120. } elseif ($info['upper_type'] == 3) {
  121. # 永久
  122. } else {
  123. return true;
  124. }
  125. $user_log_num = Dever::db('score/user_log')->getNewTotal($where);
  126. if ($user_log_num >= $info['upper_limit']) {
  127. return false;
  128. }
  129. }
  130. return true;
  131. }
  132. private function operAction($log)
  133. {
  134. if ($log && $log['score_type'] == 1) {
  135. $where = array();
  136. $where['state'] = 1;
  137. $where['id'] = $log['action_id'];
  138. $action = Dever::db('score/action')->one($where);
  139. if ($action) {
  140. $rule = Dever::db('score/rule')->state(array('action_id' => $action['id']));
  141. if ($rule) {
  142. foreach ($rule as $k => $v) {
  143. $this->rule($log, $v);
  144. }
  145. }
  146. }
  147. }
  148. }
  149. /**
  150. * 根据积分日志和规则,增加积分,这是一个定时任务,暂时不开启了
  151. *
  152. * @return mixed
  153. */
  154. public function cron()
  155. {
  156. $where['score_type'] = 1;
  157. $log = Dever::db('score/action_log')->all($where);
  158. if ($log) {
  159. foreach ($log as $k => $v) {
  160. $this->operAction($v);
  161. }
  162. }
  163. }
  164. /**
  165. * 根据积分算等级
  166. *
  167. * @return mixed
  168. */
  169. public function setLevel($uid)
  170. {
  171. # 获取当前用户的等级
  172. $where['uid'] = $uid;
  173. $user_level = Dever::db('score/user_level')->one($where);
  174. if ($user_level && $user_level['type'] == 2) {
  175. return;
  176. } elseif ($user_level && $user_level['type'] == 1) {
  177. $config = Dever::db('score/level')->one($user_level['level_id']);
  178. $level = $config['level'] + 1;
  179. } else {
  180. $level = 1;
  181. }
  182. $config = Dever::db('score/level')->one(array('level' => $level, 'state' => 1));
  183. if ($config) {
  184. # 是否能升级
  185. $yes = false;
  186. $rule = Dever::array_decode($config['score']);
  187. if ($rule) {
  188. $user_score = Dever::db('score/user')->getScoreByConfig($where);
  189. if ($user_score) {
  190. foreach ($rule as $k => $v) {
  191. $score = $v['config'];
  192. $num = $v['num'];
  193. if (isset($user_score[$score]) && $user_score[$score]['score'] && $user_score[$score]['score'] >= $num) {
  194. $yes = $config['id'];
  195. } else {
  196. $yes = false;
  197. }
  198. }
  199. }
  200. }
  201. if ($yes) {
  202. # 可以升级
  203. if ($user_level) {
  204. Dever::db('score/user_level')->update(array('where_id' => $user_level['id'], 'level_id' => $yes));
  205. } else {
  206. Dever::db('score/user_level')->insert(array('uid' => $uid,'level_id' => $yes, 'type' => 1));
  207. }
  208. }
  209. }
  210. }
  211. }