control.php 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505
  1. <?php
  2. /**
  3. * 系统后台公共方法
  4. *
  5. * 包括系统后台父类
  6. *
  7. ***/
  8. defined('InShopNC') or exit('Access Invalid!');
  9. require_once(BASE_HELPER_PATH . '/mtopcard/mtopcard.php');
  10. require_once(BASE_HELPER_PATH . '/refill/RefillFactory.php');
  11. require_once(BASE_DATA_PATH . '/model/merchant.model.php');
  12. class SystemControl
  13. {
  14. const STATE_TEXT = ['使用中', '已禁用'];
  15. const THIRD_PRODUCT_TYPE = [
  16. mtopcard\ThirdOnlineProduct => '在线产品',
  17. mtopcard\ThirdElectricProduct => '电费产品',
  18. mtopcard\ThirdSMSProduct => '短信产品'
  19. ];
  20. const ADD_TYPE_TEXT = [
  21. merchantModel::type_mch_deposit => '商户预存', merchantModel::type_adm_deposit => '后台手动预存', merchantModel::type_adm_adjust => '后台手动调款',
  22. merchantModel::type_adm_finpos => '余额找平', merchantModel::type_mch_transfer => '平台转款', merchantModel::type_refund_back => '订单返销'
  23. ];
  24. /**
  25. * 管理员资料 name id group
  26. */
  27. protected $admin_info;
  28. /**
  29. * 权限内容
  30. */
  31. protected $permission;
  32. protected function __construct()
  33. {
  34. Language::read('common,layout');
  35. /**
  36. * 验证用户是否登录
  37. * $admin_info 管理员资料 name id
  38. */
  39. $this->admin_info = $this->systemLogin();
  40. if ($this->admin_info['id'] != 1){
  41. // 验证权限
  42. $this->checkPermission();
  43. }
  44. //转码 防止GBK下用ajax调用时传汉字数据出现乱码
  45. if (($_GET['branch']!='' || $_GET['op']=='ajax') && strtoupper(CHARSET) == 'GBK'){
  46. $_GET = Language::getGBK($_GET);
  47. }
  48. }
  49. /**
  50. * 取得当前管理员信息
  51. *
  52. * @param
  53. * @return 数组类型的返回结果
  54. */
  55. protected final function getAdminInfo(){
  56. return $this->admin_info;
  57. }
  58. /**
  59. * 系统后台登录验证
  60. *
  61. * @param
  62. * @return array 数组类型的返回结果
  63. */
  64. protected final function systemLogin(){
  65. //取得cookie内容,解密,和系统匹配
  66. $user = unserialize(decrypt(cookie('sys_key'),MD5_KEY));
  67. if (!key_exists('gid',(array)$user) || !isset($user['sp']) || (empty($user['name']) || empty($user['id']))){
  68. @header('Location: index.php?act=login&op=login');exit;
  69. }else {
  70. $this->systemSetKey($user);
  71. }
  72. return $user;
  73. }
  74. /**
  75. * 系统后台 会员登录后 将会员验证内容写入对应cookie中
  76. *
  77. * @param string $name 用户名
  78. * @param int $id 用户ID
  79. * @return bool 布尔类型的返回结果
  80. */
  81. protected final function systemSetKey($user){
  82. setNcCookie('sys_key',encrypt(serialize($user),MD5_KEY),3600,'',null);
  83. }
  84. /**
  85. * 验证当前管理员权限是否可以进行操作
  86. *
  87. * @param string $link_nav
  88. * @return
  89. */
  90. protected final function checkPermission($link_nav = null){
  91. if ($this->admin_info['sp'] == 1) return true;
  92. $act = $_GET['act']?$_GET['act']:$_POST['act'];
  93. $op = $_GET['op']?$_GET['op']:$_POST['op'];
  94. if (empty($this->permission)){
  95. $gadmin = Model('gadmin')->getby_gid($this->admin_info['gid']);
  96. $permission = decrypt($gadmin['limits'],MD5_KEY.md5($gadmin['gname']));
  97. $this->permission = $permission = explode('|',$permission);
  98. }else{
  99. $permission = $this->permission;
  100. }
  101. //显示隐藏小导航,成功与否都直接返回
  102. if (is_array($link_nav)){
  103. if (!in_array("{$link_nav['act']}.{$link_nav['op']}",$permission) && !in_array($link_nav['act'],$permission)){
  104. return false;
  105. }else{
  106. return true;
  107. }
  108. }
  109. //以下几项不需要验证
  110. $tmp = array('index','dashboard','login','common','cms_base');
  111. if (in_array($act,$tmp)) return true;
  112. if (in_array($act,$permission) || in_array("$act.$op",$permission)){
  113. return true;
  114. }else{
  115. $extlimit = array('ajax','export_step1');
  116. if (in_array($op,$extlimit) && (in_array($act,$permission) || strpos(serialize($permission),'"'.$act.'.'))){
  117. return true;
  118. }
  119. //带前缀的都通过
  120. foreach ($permission as $v) {
  121. if (!empty($v) && strpos("$act.$op",$v.'_') !== false) {
  122. return true;break;
  123. }
  124. }
  125. }
  126. showMessage(Language::get('nc_assign_right'),'','html','succ',0);
  127. }
  128. /**
  129. * 取得后台菜单
  130. *
  131. * @param string $permission
  132. * @return
  133. */
  134. protected final function getNav($permission = '',&$top_nav,&$left_nav,&$map_nav){
  135. $act = $_GET['act']?$_GET['act']:$_POST['act'];
  136. $op = $_GET['op']?$_GET['op']:$_POST['op'];
  137. if ($this->admin_info['sp'] != 1 && empty($this->permission)){
  138. $gadmin = Model('gadmin')->getby_gid($this->admin_info['gid']);
  139. $permission = decrypt($gadmin['limits'],MD5_KEY.md5($gadmin['gname']));
  140. $this->permission = $permission = explode('|',$permission);
  141. }
  142. Language::read('common');
  143. $lang = Language::getLangContent();
  144. $array = require(BASE_PATH.'/include/menu.php');
  145. $array = $this->parseMenu($array);
  146. //管理地图
  147. $map_nav = $array['left'];
  148. unset($map_nav[0]);
  149. $model_nav = "<li><a class=\"link actived\" id=\"nav__nav_\" href=\"javascript:;\" onclick=\"openItem('_args_');\"><span>_text_</span></a></li>\n";
  150. $top_nav = '';
  151. //顶部菜单
  152. foreach ($array['top'] as $k=>$v) {
  153. $v['nav'] = $v['args'];
  154. $top_nav .= str_ireplace(array('_args_','_text_','_nav_'),$v,$model_nav);
  155. }
  156. $top_nav = str_ireplace("\n<li><a class=\"link actived\"","\n<li><a class=\"link\"",$top_nav);
  157. //左侧菜单
  158. $model_nav = "
  159. <ul id=\"sort__nav_\">
  160. <li>
  161. <dl>
  162. <dd>
  163. <ol>
  164. list_body
  165. </ol>
  166. </dd>
  167. </dl>
  168. </li>
  169. </ul>\n";
  170. $left_nav = '';
  171. foreach ($array['left'] as $k=>$v) {
  172. $left_nav .= str_ireplace(array('_nav_'),array($v['nav']),$model_nav);
  173. $model_list = "<li nc_type='_pkey_'><a href=\"JavaScript:void(0);\" name=\"item__opact_\" id=\"item__opact_\" onclick=\"openItem('_args_');\">_text_</a></li>";
  174. $tmp_list = '';
  175. $current_parent = '';//当前父级key
  176. foreach ($v['list'] as $key=>$value) {
  177. $model_list_parent = '';
  178. $args = explode(',',$value['args']);
  179. if (!empty($value['parent'])){
  180. if (empty($current_parent) || $current_parent != $value['parent']){
  181. $model_list_parent = "<li nc_type='parentli' dataparam='{$value['parent']}'><dt>{$value['parenttext']}</dt><dd style='display:block;'></dd></li>";
  182. }
  183. $current_parent = $value['parent'];
  184. }
  185. $value['op'] = $args[0];
  186. $value['act'] = $args[1];
  187. //$tmp_list .= str_ireplace(array('_args_','_text_','_op_'),$value,$model_list);
  188. $tmp_list .= str_ireplace(['_args_','_text_','_opact_','_pkey_'],
  189. [$value['args'],$value['text'],$value['op'],$value['act'],$value['parent']],
  190. $model_list_parent.$model_list);
  191. }
  192. $left_nav = str_replace('list_body',$tmp_list,$left_nav);
  193. }
  194. }
  195. /**
  196. * 过滤掉无权查看的菜单
  197. *
  198. * @param array $menu
  199. * @return array
  200. */
  201. private final function parseMenu($menu = array()){
  202. if ($this->admin_info['sp'] == 1) return $menu;
  203. foreach ($menu['left'] as $k=>$v) {
  204. foreach ($v['list'] as $xk=>$xv) {
  205. $tmp = explode(',',$xv['args']);
  206. //以下几项不需要验证
  207. $except = array('index','dashboard','login','common');
  208. if (in_array($tmp[1],$except)) continue;
  209. if (!in_array($tmp[1],$this->permission) && !in_array($tmp[1].'.'.$tmp[0],$this->permission)){
  210. unset($menu['left'][$k]['list'][$xk]);
  211. }
  212. }
  213. if (empty($menu['left'][$k]['list'])) {
  214. unset($menu['top'][$k]);unset($menu['left'][$k]);
  215. }
  216. }
  217. return $menu;
  218. }
  219. /**
  220. * 取得顶部小导航
  221. *
  222. * @param array $links
  223. * @param 当前页 $actived
  224. */
  225. protected final function sublink($links = array(), $actived = '', $file='index.php'){
  226. $linkstr = '';
  227. foreach ($links as $k=>$v) {
  228. parse_str($v['url'],$array);
  229. if (!$this->checkPermission($array)) continue;
  230. $href = ($array['op'] == $actived ? null : "href=\"{$file}?{$v['url']}\"");
  231. $class = ($array['op'] == $actived ? "class=\"current\"" : null);
  232. $lang = L($v['lang']);
  233. $linkstr .= sprintf('<li><a %s %s><span>%s</span></a></li>',$href,$class,$lang);
  234. }
  235. return "<ul class=\"tab-base\">{$linkstr}</ul>";
  236. }
  237. /**
  238. * 记录系统日志
  239. *
  240. * @param $lang 日志语言包
  241. * @param $state 1成功0失败null不出现成功失败提示
  242. * @param $admin_name
  243. * @param $admin_id
  244. */
  245. protected final function log($lang = '', $state = 1, $admin_name = '', $admin_id = 0){
  246. if (!C('sys_log') || !is_string($lang)) return;
  247. if ($admin_name == ''){
  248. $admin = unserialize(decrypt(cookie('sys_key'),MD5_KEY));
  249. $admin_name = $admin['name'];
  250. $admin_id = $admin['id'];
  251. }
  252. $data = array();
  253. if (is_null($state)){
  254. $state = null;
  255. }else{
  256. // $state = $state ? L('nc_succ') : L('nc_fail');
  257. $state = $state ? '' : L('nc_fail');
  258. }
  259. $data['content'] = $lang.$state;
  260. $data['admin_name'] = $admin_name;
  261. $data['createtime'] = time();
  262. $data['admin_id'] = $admin_id;
  263. $data['ip'] = getIp();
  264. $data['url'] = $_REQUEST['act'].'&'.$_REQUEST['op'];
  265. return Model('admin_log')->insert($data);
  266. }
  267. /**
  268. * 添加到任务队列
  269. *
  270. * @param array $goods_array
  271. * @param boolean $ifdel 是否删除以原记录
  272. */
  273. protected function addcron($data = array(), $ifdel = false) {
  274. $model_cron = Model('cron');
  275. if (isset($data[0])) { // 批量插入
  276. $where = array();
  277. foreach ($data as $k => $v) {
  278. if (isset($v['content'])) {
  279. $data[$k]['content'] = serialize($v['content']);
  280. }
  281. // 删除原纪录条件
  282. if ($ifdel) {
  283. $where[] = '(type = ' . $data['type'] . ' and exeid = ' . $data['exeid'] . ')';
  284. }
  285. }
  286. // 删除原纪录
  287. if ($ifdel) {
  288. $model_cron->delCron(implode(',', $where));
  289. }
  290. $model_cron->addCronAll($data);
  291. } else { // 单条插入
  292. if (isset($data['content'])) {
  293. $data['content'] = serialize($data['content']);
  294. }
  295. // 删除原纪录
  296. if ($ifdel) {
  297. $model_cron->delCron(array('type' => $data['type'], 'exeid' => $data['exeid']));
  298. }
  299. $model_cron->addCron($data);
  300. }
  301. }
  302. protected function scard_type(int $card_type)
  303. {
  304. if ($card_type == 1) { //中石油
  305. return '中石油';
  306. } elseif ($card_type == 2) { //中石化
  307. return '中石化';
  308. } elseif ($card_type == 4) { //中国移动
  309. return '中国移动';
  310. } elseif ($card_type == 5) { //中国联通
  311. return '中国联通';
  312. } elseif ($card_type == 6) { //中国电信
  313. return '中国电信';
  314. } elseif ($card_type == 7) { //中国电信
  315. return '增值业务';
  316. } else {
  317. return 'unknown';
  318. }
  319. }
  320. protected function quality_format($quality,$card_type) {
  321. global $config;
  322. $text = [
  323. mtopcard\PetroChinaCard => $config['oil_quality_text'],
  324. mtopcard\SinopecCard => $config['oil_quality_text'],
  325. mtopcard\ChinaMobileCard => $config['phone_quality_text'],
  326. mtopcard\ChinaUnicomCard => $config['phone_quality_text'],
  327. mtopcard\ChinaTelecomCard => $config['phone_quality_text']
  328. ];
  329. return $text[$card_type][$quality] ?? $quality;
  330. }
  331. protected function elapse_time($seconds)
  332. {
  333. $minutes = intval($seconds / 60);
  334. $second = intval($seconds % 60);
  335. if ($minutes >= 60) {
  336. $minute = $minutes % 60;
  337. $hours = intval($minutes / 60);
  338. $result = "{$minute}m{$second}s";
  339. } elseif ($minutes > 0) {
  340. $result = "{$minutes}m{$second}s";
  341. } else {
  342. $result = "{$second}s";
  343. }
  344. if (isset($hours)) {
  345. $result = "{$hours}h{$minute}m";
  346. }
  347. return $result;
  348. }
  349. protected function check_fetch_order($order_ids): array
  350. {
  351. $mod = Model('fetch_order');
  352. $cond['order_id'] = ['in', $order_ids];
  353. $res = $mod->getFetchOrderList($cond);
  354. return array_column($res, 'order_id');
  355. }
  356. protected function merchants($condition = [])
  357. {
  358. $items = Model('')->table('merchant')->where($condition)->limit(1000)->order('company_name asc')->select();
  359. foreach ($items as &$item) {
  360. $item['pinyin'] = Pinyin::getPinyin(strtolower($item['company_name']));
  361. $item['alpha'] = substr($item['pinyin'],0,1);
  362. }
  363. $asc = function ($l,$r)
  364. {
  365. $lp = $l['pinyin'];
  366. $rp = $r['pinyin'];
  367. if(empty($lp) && empty($rp)) {
  368. $lo = $l['name'];
  369. $ro = $r['name'];
  370. return strcmp($lo,$ro);
  371. }
  372. else {
  373. return strcmp($lp,$rp);
  374. }
  375. };
  376. usort($items,$asc);
  377. return $items;
  378. }
  379. protected function providers($condition = [])
  380. {
  381. $items = Model('')->table('refill_provider,store')
  382. ->field('refill_provider.*,store.store_name')
  383. ->join('inner')
  384. ->on('store.store_id=refill_provider.store_id')
  385. ->where($condition)
  386. ->order('opened asc, name asc')
  387. ->limit(1000)
  388. ->select();
  389. foreach ($items as &$item) {
  390. $item['pinyin'] = Pinyin::getPinyin($item['store_name']);
  391. }
  392. $asc = function ($l,$r)
  393. {
  394. $lo = $l['opened'];
  395. $ro = $r['opened'];
  396. $lp = $l['pinyin'];
  397. $rp = $r['pinyin'];
  398. if($lo != $ro) {
  399. return $lo < $ro ? -1 : 1;
  400. }
  401. else {
  402. return strcmp($lp,$rp);
  403. }
  404. };
  405. usort($items,$asc);
  406. return $items;
  407. }
  408. protected function credit_save_money($money, $operatetype, $member_id, $bz = '')
  409. {
  410. $obj_member = Model('member');
  411. $member_id = intval($member_id);
  412. $member_info = $obj_member->getMemberInfo(['member_id' => $member_id], '*', true);
  413. $admininfo = $this->getAdminInfo();
  414. $bz = $bz == '' ? '管理员更改客户授信' : $bz;
  415. switch ($operatetype) {
  416. case 'add':
  417. $admin_act = "sys_add_money";
  418. $log_msg = "管理员【{$admininfo['name']}】操作会员{$member_id}余额:【{$member_info['member_name']}】,预存款【增加】,金额为{$money}。备注:{$bz}。";
  419. break;
  420. case 'del':
  421. $admin_act = "sys_del_money";
  422. $log_msg = "管理员【{$admininfo['name']}】操作会员{$member_id}余额:【{$member_info['member_name']}】,预存款【减少】,金额为{$money}。备注:{$bz}。";
  423. break;
  424. default:
  425. return [false, '调节类型错误'];
  426. }
  427. $model_pd = Model('predeposit');
  428. //调节预存款
  429. $data = [];
  430. $data['member_id'] = $member_info['member_id'];
  431. $data['member_name'] = $member_info['member_name'];
  432. $data['amount'] = $money;
  433. $data['order_sn'] = '';
  434. $data['admin_name'] = $admininfo['name'];
  435. $data['pdr_sn'] = '';
  436. $data['lg_desc'] = $bz;
  437. $isRefill = $model_pd->isRefill($data['member_id']);
  438. $model_pd->changePd($admin_act, $data,$isRefill);
  439. $this->log($log_msg, 1);
  440. return [true, 'success'];
  441. }
  442. protected function OrderDataFormat($order_list,$merchant_list)
  443. {
  444. foreach ($merchant_list as $value) {
  445. $merchants[$value['mchid']] = $value;
  446. }
  447. foreach ($order_list as $order_id => $order)
  448. {
  449. $order_list[$order_id]['card_type_text'] = $this->scard_type($order['card_type']);
  450. $order_list[$order_id]['mch_name'] = $merchants[$order['mchid']]['company_name'];
  451. if ($order['notify_time'] > 0) {
  452. $diff_time = $order['notify_time'] - $order['order_time'];
  453. } else {
  454. $diff_time = time() - $order['order_time'];
  455. }
  456. $order_list[$order_id]['diff_time_text'] = $this->elapse_time($diff_time);
  457. $order_list[$order_id]['diff_time'] = $diff_time;
  458. $order_list[$order_id]['quality_text'] = $this->quality_format($order['quality'],$order['card_type']);
  459. $order_list[$order_id]['org_quality_text'] = $this->quality_format($order['org_quality'],$order['card_type']);
  460. }
  461. return $order_list;
  462. }
  463. }