| | <?php |
| | namespace app\admin\controller; |
| | use think\Db; |
| | use app\common\util\Collection as cjOper; |
| |
|
| | class Cj extends Base |
| | { |
| | var $_isall=0; |
| |
|
| | public function __construct() |
| | { |
| | parent::__construct(); |
| | } |
| |
|
| | |
| | public function index() |
| | { |
| | $param = input(); |
| | $param['page'] = intval($param['page']) <1 ? 1 : $param['page']; |
| | $param['limit'] = intval($param['limit']) <1 ? $this->_pagesize : $param['limit']; |
| | $where=[]; |
| |
|
| | $order='nodeid desc'; |
| | $res = model('Cj')->listData('cj_node',$where,$order,$param['page'],$param['limit']); |
| |
|
| | $this->assign('list',$res['list']); |
| | $this->assign('total',$res['total']); |
| | $this->assign('page',$res['page']); |
| | $this->assign('limit',$res['limit']); |
| |
|
| | $param['page'] = '{page}'; |
| | $param['limit'] = '{limit}'; |
| | $this->assign('param',$param); |
| | $this->assign('title',lang('admin/cj/title')); |
| |
|
| | return $this->fetch('admin@cj/index'); |
| | } |
| |
|
| |
|
| | public function info() |
| | { |
| | if (Request()->isPost()) { |
| | $param = input(); |
| | $data = $param['data']; |
| | $data['urlpage'] = (string)$param['urlpage'.$data['sourcetype']]; |
| | if(!empty($data['customize_config'])){ |
| | $customize_config = $data['customize_config']; |
| | unset($data['customize_config']); |
| | foreach ($customize_config['name'] as $k => $v) { |
| | if (empty($v) || empty($customize_config['name'][$k])) continue; |
| | $data['customize_config'][] = array('name'=>$customize_config['name'][$k], 'en_name'=>$customize_config['en_name'][$k], 'rule'=>$customize_config['rule'][$k], 'html_rule'=>$customize_config['html_rule'][$k]); |
| | } |
| | $data['customize_config'] = json_encode($data['customize_config'],JSON_FORCE_OBJECT); |
| | } |
| | $res = model('Cj')->saveData($data); |
| | if($res['code']>1){ |
| | return $this->error($res['msg']); |
| | } |
| | return $this->success($res['msg']); |
| | } |
| |
|
| | $id = input('id'); |
| | $where=[]; |
| | $where['nodeid'] = ['eq',$id]; |
| | $res = model('Cj')->infoData('cj_node',$where); |
| | if(!empty($res['info']['customize_config'])){ |
| | $res['info']['customize_config'] = json_decode($res['info']['customize_config'],true); |
| | } |
| | $this->assign('data',$res['info']); |
| | $this->assign('title',lang('admin/cj/title')); |
| | return $this->fetch('admin@cj/info'); |
| | } |
| |
|
| | public function program() |
| | { |
| | $param = input(); |
| | $where=[]; |
| | $where['nodeid'] = $param['id']; |
| | $res = model('Cj')->infoData('cj_node',$where); |
| | if($res['code']>1){ |
| | return $this->error($res['msg']); |
| | } |
| |
|
| | if (Request()->isPost()) { |
| | $program_config = []; |
| | foreach($param['model_field'] as $k=>$v){ |
| | if(!empty($param['node_field'][$k])){ |
| | $program_config['map'][$v] = $param['node_field'][$k]; |
| | $program_config['funcs'][$v] = $param['funcs'][$k]; |
| | } |
| | } |
| | $update=[]; |
| | $update['nodeid'] = $param['id']; |
| | $update['program_config'] = json_encode($program_config); |
| | $res = model('Cj')->saveData($update); |
| | if($res['code']>1){ |
| | return $this->error(lang('save_err')); |
| | } |
| | return $this->success(lang('save_ok')); |
| | } |
| |
|
| | $program_config = []; |
| | if(!empty($res['info']['program_config'])){ |
| | $program_config = json_decode($res['info']['program_config'],true); |
| | } |
| | $this->assign('program_config',$program_config); |
| |
|
| |
|
| | $node_field = array('title'=>lang('title'),'type'=>lang('type'), 'content'=>lang('content')); |
| | $customize_config = []; |
| | if(!empty($res['info']['customize_config'])){ |
| | $customize_config = json_decode($res['info']['customize_config'],true); |
| | } |
| |
|
| | if (is_array($customize_config)) foreach ($customize_config as $k=>$v) { |
| | if (empty($v['en_name']) || empty($v['name'])) continue; |
| | $node_field[$v['en_name']] = $v['name']; |
| | } |
| | $this->assign('node_field',$node_field); |
| |
|
| | $table = 'vod'; |
| | if($res['info']['mid'] =='2'){ |
| | $table='art'; |
| | } |
| | $column_list = Db::query('SHOW COLUMNS FROM '.config('database.prefix').$table); |
| | $this->assign('column_list',$column_list); |
| | $this->assign('param',$param); |
| | return $this->fetch('admin@cj/program'); |
| | } |
| |
|
| | public function col_all($param) |
| | { |
| | $this->_isall=1; |
| | $this->col_url($param); |
| | } |
| |
|
| |
|
| | |
| | public function col_url($param=[]) { |
| | if(empty($param)){ |
| | $param = input(); |
| | } |
| |
|
| | $where=[]; |
| | $where['nodeid'] = $param['id']; |
| | $res = model('Cj')->infoData('cj_node',$where); |
| | if($res['code']>1){ |
| | return $this->error($res['msg']); |
| | } |
| | $data = $res['info']; |
| | $collection = new cjOper(); |
| | $urls = $collection->url_list($data); |
| |
|
| | $total_page = count($urls); |
| | if (empty($total_page)){ |
| | return $this->error(lang('admin/cj/url_list_err')); |
| | } |
| |
|
| | $param['page'] = isset($param['page']) ? intval($param['page']) : 1; |
| |
|
| | $url_list = $urls[$param['page']-1]; |
| | $url = $collection->get_url_lists($url_list, $data); |
| |
|
| | $total = count($url); |
| | $re = 0; |
| | if (is_array($url) && !empty($url)) { |
| | foreach ($url as $v) { |
| | if (empty($v['url']) || empty($v['title'])) { |
| | $re++; |
| | continue; |
| | } |
| | $v['title'] = strip_tags($v['title']); |
| | $md5 = md5($v['url']); |
| | $where=[]; |
| | $where['md5'] = $md5; |
| | $history = model('Cj')->infoData('cj_history',$where); |
| | if($history['code']>1){ |
| | Db::name('cj_history')->insert(array('md5' => $md5)); |
| | Db::name('cj_content')->insert(array('nodeid'=>$param['id'], 'status'=>1, 'url'=>$v['url'], 'title'=>$v['title'])); |
| | } |
| | else { |
| | $re++; |
| | } |
| | } |
| | } |
| | if ($total_page <= $param['page']) { |
| | $time = time(); |
| | Db::name('cj_node')->where('nodeid',$param['id'])->update(array('lastdate' => $time)); |
| | } |
| | if($this->_isall==1){ |
| | mac_echo(lang('admin/cj/url_cj_complete')); |
| | $this->col_content($param); |
| | exit; |
| | } |
| | $this->assign('param',$param); |
| | $this->assign('url_list', $url_list); |
| | $this->assign('total_page', $total_page); |
| | $this->assign('re', $re); |
| | $this->assign('url', $url); |
| | $this->assign('page',$param['page']); |
| | $this->assign('total',$total); |
| | $this->assign('title',lang('admin/cj/url/title')); |
| | if($total_page > $param['page']){ |
| | mac_echo(lang('server_rest')); |
| | $param['page'] ++; |
| | $link = url('cj/col_url') . '?'. http_build_query($param); |
| | mac_jump( $link ,3); |
| | } |
| | else{ |
| | mac_echo(lang('admin/cj/url_cj_complete')); |
| | } |
| | return $this->fetch('admin@cj/col_url'); |
| | } |
| |
|
| | |
| | public function col_content($param=[]) { |
| | if(empty($param)){ |
| | $param = input(); |
| | } |
| |
|
| | $collection = new cjOper(); |
| | $page = isset($_GET['page']) ? intval($_GET['page']) : 1; |
| | $total = isset($_GET['total']) ? intval($_GET['total']) : 0; |
| |
|
| | $where=[]; |
| | $where['nodeid'] = $param['id']; |
| | $res = model('Cj')->infoData('cj_node',$where); |
| | if($res['code']>1){ |
| | return $this->error($res['msg']); |
| | } |
| | $data = $res['info']; |
| |
|
| | mac_echo('<style type="text/css">body{font-size:12px;color: #333333;line-height:21px;}span{font-weight:bold;color:#FF0000}</style>'); |
| |
|
| | if(empty($total)){ |
| | $total = Db::name('cj_content')->where('nodeid',$param['id'])->where('status',1)->count(); |
| | } |
| | $limit = 20; |
| | $total_page = ceil($total/$limit); |
| | mac_echo(lang('admin/cj/content/tip',[$total,$total_page,$limit,$page])); |
| |
|
| | $list = Db::name('cj_content')->where('nodeid',$param['id'])->where('status',1)->page($total_page-1,$limit)->select(); |
| |
|
| | $i = 0; |
| | $ids=[]; |
| | if(!empty($list) && is_array($list)){ |
| | foreach($list as $v){ |
| | $html = $collection->get_content($v['url'],$data); |
| | Db::name('cj_content')->where('id',$v['id'])->update(['status'=>2, 'data'=>json_encode($html)]); |
| | $ids[] = $v['id']; |
| | $i++; |
| |
|
| | mac_echo($v['url'].' '.'ok'); |
| | } |
| | } |
| | else{ |
| | mac_echo(lang('admin/cj/content_cj_complete')); |
| | exit; |
| | } |
| |
|
| | if($this->_isall==1){ |
| | mac_echo(lang('admin/cj/content_cj_complete')); |
| | $param['ids'] = implode(',',$ids); |
| | $param['limit'] = 999; |
| | $this->content_into($param); |
| | exit; |
| | } |
| |
|
| | if ($total_page > $page){ |
| | mac_echo(lang('server_rest')); |
| | $param['page'] ++; |
| | $link = url('cj/col_content') . '?'. http_build_query($param); |
| | mac_jump( $link ,3); |
| | } |
| | else{ |
| | $time = time(); |
| | Db::name('cj_node')->where('nodeid',$param['id'])->update(array('lastdate' => $time)); |
| | mac_echo(lang('admin/cj/cj_complete')); |
| | exit; |
| | } |
| | } |
| |
|
| |
|
| | public function publish() |
| | { |
| | $param = input(); |
| |
|
| | $param['page'] = intval($param['page']) <1 ? 1 : $param['page']; |
| | $param['limit'] = intval($param['limit']) <20 ? $this->_pagesize : $param['limit']; |
| | $where=[]; |
| | $where['nodeid'] = $param['id']; |
| | if(!empty($param['status'])){ |
| | $where['status'] = ['eq',$param['status']]; |
| | } |
| |
|
| | $order='id desc'; |
| | $res = model('Cj')->listData('cj_content',$where,$order,$param['page'],$param['limit']); |
| |
|
| | $this->assign('list',$res['list']); |
| | $this->assign('total',$res['total']); |
| | $this->assign('page',$res['page']); |
| | $this->assign('limit',$res['limit']); |
| |
|
| | $param['page'] = '{page}'; |
| | $param['limit'] = '{limit}'; |
| | $this->assign('param',$param); |
| | $this->assign('title',lang('admin/cj/publish/title')); |
| |
|
| | return $this->fetch('admin@cj/publish'); |
| | } |
| |
|
| | public function show() |
| | { |
| | $id = input('id'); |
| | $where=[]; |
| | $where['id'] = ['eq',$id]; |
| | $info = Db::name('cj_content')->where($where)->find(); |
| | if(!empty($info['data'])){ |
| | $info['data'] = @json_decode($info['data'],true); |
| | } |
| | $this->assign('info',$info); |
| | $this->assign('title',lang('admin/cj/title')); |
| | return $this->fetch('admin@cj/show'); |
| |
|
| | } |
| |
|
| | public function content_del() |
| | { |
| | $param = input(); |
| | $ids = $param['ids']; |
| | $all = $param['all']; |
| |
|
| | if(!empty($ids)){ |
| | $where=[]; |
| | $where['id'] = ['in',$ids]; |
| | if($all=='1'){ |
| | $where['id'] = ['gt',0]; |
| | } |
| | $urls = []; |
| | $list = Db::name('cj_content')->field('url')->where($where)->select(); |
| | foreach ($list as $k => $v) { |
| | $md5 = md5($v['url']); |
| | $urls[] = $md5; |
| | } |
| |
|
| | $where2=[]; |
| | $where2['md5'] = ['in',$md5]; |
| | Db::name('cj_history')->where($where2)->delete(); |
| |
|
| | $res = Db::name('cj_content')->where($where)->delete(); |
| | if($res===false){ |
| | return $this->error(lang('del_err').''.$this->getError()); |
| | } |
| | } |
| | return $this->success(lang('del_ok')); |
| | } |
| |
|
| | public function content_into($param=[]) |
| | { |
| | if(empty($param)){ |
| | $param = input(); |
| | } |
| |
|
| | $nodeid = $param['id']; |
| | $ids = $param['ids']; |
| | $all = $param['all']; |
| | $param['page'] = intval($param['page']) <1 ? 1 : $param['page']; |
| | $param['limit'] = intval($param['limit']) <20 ? $this->_pagesize : $param['limit']; |
| |
|
| | $where=[]; |
| | $where['nodeid'] = $param['id']; |
| | $res = model('Cj')->infoData('cj_node',$where); |
| | if($res['code']>1){ |
| | return $this->error($res['msg']); |
| | } |
| | $node = $res['info']; |
| | $where=[]; |
| | $where['nodeid'] = $nodeid; |
| | $where['status'] =['eq',2]; |
| | $where['id'] = ['in',$ids]; |
| | if($all=='1'){ |
| | $where['id'] = ['gt',0]; |
| | } |
| |
|
| | mac_echo('<style type="text/css">body{font-size:12px;color: #333333;line-height:21px;}span{font-weight:bold;color:#FF0000}</style>'); |
| | if(empty($param['total'])) { |
| | $param['total'] = Db::name('cj_content')->where($where)->count(); |
| | } |
| |
|
| | $list = Db::name('cj_content')->where($where)->page($param['page'],$param['limit'])->select(); |
| |
|
| | $total_page = ceil($param['total']/$param['limit']); |
| | mac_echo(lang('admin/cj/content_into/tip',[$param['total'],$total_page,$param['limit'],$param['page']])); |
| |
|
| | $program_config =[]; |
| | if(!empty($node['program_config'])){ |
| | $program_config = json_decode($node['program_config'],true); |
| | } |
| |
|
| | $inter = mac_interface_type(); |
| | $update_ids = []; |
| | foreach($list as $k=>$v){ |
| | $data=[]; |
| | $content_data = json_decode($v['data'],true); |
| | foreach ($program_config['map'] as $a=>$b) { |
| | if (isset($program_config['funcs'][$a]) && function_exists($program_config['funcs'][$a])) { |
| | $data['data'][$k][$a] = $program_config['funcs'][$a]($v['data'][$b]); |
| | } |
| | else { |
| | $data['data'][$k][$a] = $content_data[$b]; |
| | } |
| | if($b=='type' && !is_numeric($content_data[$b])) { |
| |
|
| | if($node['mid'] ==2 ) { |
| | $data['data'][$k][$a] = $inter['arttype'][$content_data[$b]]; |
| | } |
| | else{ |
| | $data['data'][$k][$a] = $inter['vodtype'][$content_data[$b]]; |
| | } |
| | } |
| | } |
| |
|
| |
|
| | if($node['mid'] == '2'){ |
| | $res = model('Collect')->art_data([],$data,0); |
| | } |
| | else{ |
| | $res = model('Collect')->vod_data([],$data,0); |
| | } |
| | if($res['code'] ==1){ |
| | $update_ids[] = $v['id']; |
| | } |
| | mac_echo($res['msg']); |
| | } |
| |
|
| | if(!empty($update_ids)){ |
| | $where=[]; |
| | $where['id'] = ['in',$update_ids]; |
| | $res = Db::name('cj_content')->where($where)->update(['status' => 3]); |
| | } |
| |
|
| | if($this->_isall==1){ |
| | mac_echo(lang('admin/cj/content_into/complete')); |
| | exit; |
| | } |
| |
|
| |
|
| | if ($total_page > $param['page']){ |
| | mac_echo(lang('server_rest')); |
| | $param['page'] ++; |
| | $link = url('cj/content_into') . '?'. http_build_query($param); |
| | mac_jump( $link ,3); |
| | } |
| | else{ |
| | mac_echo(lang('import_ok')); |
| | exit; |
| | } |
| | } |
| |
|
| |
|
| | |
| | public function show_url() |
| | { |
| | $param = input(); |
| | $data = $param['data']; |
| | $data['urlpage'] = (string)$param['urlpage'.$data['sourcetype']]; |
| | $collection = new cjOper(); |
| | $urls = $collection->url_list($data); |
| |
|
| | $this->assign('urls',$urls); |
| |
|
| | return $this->fetch('admin@cj/show_url'); |
| | } |
| |
|
| | public function del() |
| | { |
| | $param = input(); |
| | $ids = $param['ids']; |
| |
|
| | if(!empty($ids)){ |
| | $where=[]; |
| | $where['nodeid'] = ['in',$ids]; |
| | $res = model('Cj')->delData($where); |
| | if($res['code']>1){ |
| | return $this->error($res['msg']); |
| | } |
| | return $this->success($res['msg']); |
| | } |
| | return $this->error(lang('param_err')); |
| | } |
| |
|
| | public function export() |
| | { |
| | $param = input(); |
| |
|
| | $where=[]; |
| | $where['nodeid'] = $param['id']; |
| | $res = model('Cj')->infoData('cj_node',$where); |
| | if($res['code']>1){ |
| | return $this->error($res['msg']); |
| | } |
| | $node = $res['info']; |
| |
|
| | header("Content-type: application/octet-stream"); |
| | if(strpos($_SERVER['HTTP_USER_AGENT'], "MSIE")) { |
| | header("Content-Disposition: attachment; filename=mac_cj_" . urlencode($node['name']) . '.txt'); |
| | } |
| | else{ |
| | header("Content-Disposition: attachment; filename=mac_cj_" . $node['name'] . '.txt'); |
| | } |
| | echo base64_encode(json_encode($node)); |
| | } |
| |
|
| | public function import() |
| | { |
| | $file = $this->request->file('file'); |
| | $info = $file->rule('uniqid')->validate(['size' => 10240000, 'ext' => 'txt']); |
| | if ($info) { |
| | $data = json_decode(base64_decode(file_get_contents($info->getpathName())), true); |
| | @unlink($info->getpathName()); |
| | if($data){ |
| | unset($data['nodeid']); |
| | $res = model('Cj')->saveData($data); |
| | if($res['code']>1){ |
| | return $this->success($res['msg']); |
| | } |
| | return $this->success($res['msg']); |
| | } |
| | return $this->success(lang('import_err')); |
| | } |
| | else{ |
| | return $this->error($file->getError()); |
| | } |
| | } |
| | } |
| |
|
