zm/tougao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

20201112

Browse Source
This commit is contained in:
wangjinlei
2021-03-11 15:46:35 +08:00
parent fc93cc5c9b
commit 22399fe204
2 changed files with 341 additions and 127 deletions
Download Patch File Download Diff File Expand all files Collapse all files

430
application/api/controller/Staff.php
View File

@@ -1,10 +1,14 @@
<?php <?php
namespace app\api\controller; namespace app\api\controller;
use think\Controller; use think\Controller;
use think\Db; use think\Db;
class Staff extends Controller{ class Staff extends Controller {
// const JURL = 'http://www.journal.com/master/Article/getJournalCites';
const JURL = 'http://journalapi.tmrjournals.com/public/index.php/master/Article/getJournalCites';
protected $article_obj = ''; protected $article_obj = '';
protected $user_obj = ''; protected $user_obj = '';
@@ -43,66 +47,71 @@ class Staff extends Controller{
$this->staff_to_journal_obj = Db::name('staff_to_journal'); $this->staff_to_journal_obj = Db::name('staff_to_journal');
} }
public function mytest(){
$url = self::JURL;
$param = [];
$param['issn'] = '2413-3973';
$res = json_decode(myPost($url,$param));
echo '<pre>';
var_dump($res->data->cites);
echo '</pre>';
die;
}
/** /**
* 添加工资level * 添加工资level
*/ */
public function addStaffLevel(){ public function addStaffLevel() {
$data = $this->request->post(); $data = $this->request->post();
$insert['title'] = $data['title']; $insert['title'] = $data['title'];
$insert['wages'] = $data['wages']; $insert['wages'] = $data['wages'];
$this->staff_level_obj->insert($insert); $this->staff_level_obj->insert($insert);
return jsonSuccess([]); return jsonSuccess([]);
} }
/** /**
* 删除工资level * 删除工资level
*/ */
public function delStaffLevel(){ public function delStaffLevel() {
$data = $this->request->post(); $data = $this->request->post();
$this->staff_level_obj->where('staff_level_id',$data['staff_level_id'])->update(['state'=>1]); $this->staff_level_obj->where('staff_level_id', $data['staff_level_id'])->update(['state' => 1]);
return jsonSuccess([]); return jsonSuccess([]);
} }
/** /**
* 编辑工资level * 编辑工资level
*/ */
public function editStaffLevel(){ public function editStaffLevel() {
$data = $this->request->post(); $data = $this->request->post();
$update['title'] = $data['title']; $update['title'] = $data['title'];
$update['wages'] = $data['wages']; $update['wages'] = $data['wages'];
$this->staff_level_obj->where('staff_level_id',$data['staff_level_id'])->update($update); $this->staff_level_obj->where('staff_level_id', $data['staff_level_id'])->update($update);
return jsonSuccess([]); return jsonSuccess([]);
} }
/** /**
* 获取工资levels * 获取工资levels
*/ */
public function getStaffLevels(){ public function getStaffLevels() {
$list = $this->staff_level_obj->where('state',0)->select(); $list = $this->staff_level_obj->where('state', 0)->select();
$re['levels'] = $list; $re['levels'] = $list;
return jsonSuccess($re); return jsonSuccess($re);
} }
/** /**
* 添加员工 * 添加员工
*/ */
public function addStaff(){ public function addStaff() {
$data = $this->request->post(); $data = $this->request->post();
// $data['staff_level_id'] = '3';
// $data['addition'] = '1';
// $data['addition_reason'] = '';
// $data['subtraction'] = '';
// $data['subtraction_reason'] = '';
// $data['name'] = '1';
// $data['phone'] = '1';
// $data['email'] = '1';
// $data['password'] = '1';
$insert['staff_level_id'] = $data['staff_level_id']; $insert['staff_level_id'] = $data['staff_level_id'];
$insert['name'] = $data['name']; $insert['name'] = $data['name'];
$insert['phone'] = $data['phone']; $insert['phone'] = $data['phone'];
$insert['email'] = $data['email']; $insert['email'] = $data['email'];
$insert['ident'] = $data['ident'];
$insert['bank'] = $data['bank'];
$insert['password'] = md5($data['password']); $insert['password'] = md5($data['password']);
$insert['add_price'] = $data['add_price']; $insert['add_price'] = $data['add_price'];
$insert['add_reason'] = $data['add_reason']; $insert['add_reason'] = $data['add_reason'];
@@ -111,16 +120,16 @@ class Staff extends Controller{
$this->staff_obj->insert($insert); $this->staff_obj->insert($insert);
return jsonSuccess([]); return jsonSuccess([]);
} }
/** /**
* 删除员工 * 删除员工
*/ */
public function delStaff() { public function delStaff() {
$data = $this->request->post(); $data = $this->request->post();
$this->staff_obj->where('staff_id',$data['staff_id'])->update(['state'=>1]); $this->staff_obj->where('staff_id', $data['staff_id'])->update(['state' => 1]);
return jsonSuccess([]); return jsonSuccess([]);
} }
/** /**
* 更新员工信息 * 更新员工信息
*/ */
@@ -130,148 +139,317 @@ class Staff extends Controller{
$update['name'] = $data['name']; $update['name'] = $data['name'];
$update['phone'] = $data['phone']; $update['phone'] = $data['phone'];
$update['email'] = $data['email']; $update['email'] = $data['email'];
$update['password'] = md5($data['password']); $update['ident'] = $data['ident'];
$update['bank'] = $data['bank'];
$update['add_price'] = $data['add_price']; $update['add_price'] = $data['add_price'];
$update['add_reason'] = $data['add_reason']; $update['add_reason'] = $data['add_reason'];
$update['sub_price'] = $data['sub_price']; $update['sub_price'] = $data['sub_price'];
$update['sub_reason'] = $data['sub_reason']; $update['sub_reason'] = $data['sub_reason'];
$this->staff_obj->where('staff_id',$data['staff_id'])->update($update); $this->staff_obj->where('staff_id', $data['staff_id'])->update($update);
return jsonSuccess([]); return jsonSuccess([]);
} }
/** /**
* 获取员工列表 * 获取员工列表
*/ */
public function getStaffs(){ public function getStaffs() {
$data = $this->request->post(); $data = $this->request->post();
$limit_start = ($data['pageIndex'] - 1) * $data['pageSize']; $limit_start = ($data['pageIndex'] - 1) * $data['pageSize'];
$list = $this->staff_obj->field('t_staff.*,t_staff_level.*') $list = $this->staff_obj->field('t_staff.*,t_staff_level.*')
->join('t_staff_level','t_staff_level.staff_level_id = t_staff.staff_level_id','left') ->join('t_staff_level', 't_staff_level.staff_level_id = t_staff.staff_level_id', 'left')
->where('t_staff.state',0) ->where('t_staff.state', 0)
->limit($limit_start,$data['pageSize']) ->order('staff_id')
->limit($limit_start, $data['pageSize'])
->select(); ->select();
$count = $this->staff_obj->where('state',0)->count(); $count = $this->staff_obj->where('state', 0)->count();
$re['staffs'] = $list; $re['staffs'] = $list;
$re['count'] = $count; $re['count'] = $count;
return jsonSuccess($re); return jsonSuccess($re);
} }
/**
* 获取全部员工
*/
public function getAllStaffs() {
$list = $this->staff_obj->where('state', 0)->select();
$re['staffs'] = $list;
return jsonSuccess($re);
}
/**
* 获取全部期刊
*/
public function getJournals() {
$list = $this->journal_obj
->field('t_journal.*,t_staff.name staff_name')
->join('t_staff', 't_journal.staff_id = t_staff.staff_id', 'left')
->where('t_journal.state', 0)
->select();
$re['journals'] = $list;
return jsonSuccess($re);
}
/**
* 更改期刊提成对接人与稿件数量与期刊基础工资
*/
public function editJournalStaff() {
$data = $this->request->post();
$this->journal_obj
->where('journal_id', $data['journal_id'])
->update(['staff_id' => $data['staff_id'], 'jour_num' => $data['jour_num'],'jour_price'=>$data['jour_price']]);
return jsonSuccess([]);
}
/**
* 获取员工实时工资(员工用)
*/
public function getStaffRealtime() {
$data = $this->request->post();
$res = $this->getTomonthPrice($data['name'], date('Ym'));
if ($res == 'error') {
return jsonError($res);
} else {
return jsonSuccess($res);
}
}
/**
* 核算月薪,记录进log(系统自动调用)
*/
public function pushStaffLog() {
$staff_list = $this->staff_obj->where('state', 0)->select();
// $where['state'] = 0;
$c_time = strtotime("-1 month", strtotime(date('Y-m') . '-26 00:00:00'));
$c_time1 = strtotime(date('Y-m' . '-25 23:59:59'));
$where['ctime'] = array(['>', $c_time], ['<=', $c_time1]);
foreach ($staff_list as $value) {
$base_price = $this->getBasePrice($value['name']);
$journals = $this->journal_obj->where('staff_id', $value['staff_id'])->select();
$journal_price = 0;
$cite_price = 0;
foreach ($journals as $v) {
$c_price = 0;
// $where['journal_id'] = $v['journal_id'];
$where['accept_sn'] = ['like',$v['abbr'].'%'];
$cache_articles = $this->article_obj->where($where)->select();
$c_gn = 0;
$c_gw = 0;
foreach ($cache_articles as $vv) {
$c_country = $this->article_author_obj->where('article_id', $vv['article_id'])->where('state', 0)->column('country');
$c_c = 'gn';
foreach ($c_country as $vvv) {
if ($vvv != 'China' && $vvv != '') {
$c_c = 'gw';
}
}
if ($c_c == 'gn') {
$c_gn++;
} else {
$c_gw++;
}
}
if ($c_gn - $v['jour_num'] >= 0) {
$c_price = ($c_gn - $v['jour_num']) * 100 + $c_gw * 200;
} else {
if (($c_gw - ($v['jour_num'] - $c_gn)) >= 0) {
$c_price = ($c_gn + $c_gw - $v['jour_num']) * 200;
} else {
$c_price = 0 - ($v['jour_num'] - $c_gn - $c_gw) * 50;
}
}
$journal_price += $c_price;
//获取cite提成
$jcites = json_decode(myPost(self::JURL,['issn'=>$v['issn']]));
$jcs = $jcites->data->cites;
$cite_price += count($jcs)*500;
}
//添加数据
$ccc = $this->staff_log_obj->where('staff_id',$value['staff_id'])->where('date', date('Ym'))->find();
if($ccc==null){
$insert['staff_id'] = $value['staff_id'];
$insert['date'] = date('Ym');
$insert['base_price'] = $base_price;
$insert['journal_price'] = $journal_price;
$insert['cite_price'] = $cite_price;
$this->staff_log_obj->insert($insert);
}
}
echo 'finshed';
}
/**
* 获取员工工资信息列表（管理员用）
*/
public function getAllStaff() {
// $data = $this->request->post();
$data['pageIndex'] = 1;
$data['pageSize'] = 100;
$data['date'] = '202103';
$limit_start = ($data['pageIndex'] - 1) * $data['pageSize'];
$staff_list = $this->staff_obj->where('state', 0)->limit($limit_start, $data['pageSize'])->select();
$count = $this->staff_obj->where('state', 0)->count();
foreach ($staff_list as $k => $v) {
$ca = $this->getTomonthPrice($v['name'], $data['date']);
$staff_list[$k]['pp'] = $ca;
}
$re['staffs'] = $staff_list;
$re['count'] = $count;
return jsonSuccess($re);
}
/** /**
* 获取全部期刊 * 修改工资详情
*/ */
public function getJournals(){ public function editStaffLog(){
$list = $this->journal_obj->where('state',0)->select();
$re['journals'] = $list;
return jsonSuccess($re);
}
/**
* 更改期刊提成对接人
*/
public function editJournalStaff(){
$data = $this->request->post(); $data = $this->request->post();
$this->journal_obj->where('journal_id',$data['journal_id'])->update(['staff_id'=>$data['staff_id']]); $update['add_price'] = $data['add_price'];
$update['add_reason'] = $data['add_reason'];
$update['sub_price'] = $data['sub_price'];
$update['sub_reason'] = $data['sub_reason'];
$this->staff_log_obj->where('staff_log_id',$data['staff_log_id'])->update($update);
return jsonSuccess([]); return jsonSuccess([]);
} }
/**
* 获取员工实时工资
*/
public function getStaffRealtime(){
$data = $this->request->post();
$staff_info = $this->staff_obj->where('name',$data['name'])->find();
$price = $this->getBasePrice($data['name']);
//获取实时期刊提成情况
$journals = $this->journal_obj->where('staff_id',$staff_info['staff_id'])->column('journal_id');
$where['journal'] = array('in',$journals);
if(date('d')>25){
$ch_time = strtotime(date('Y-m').'-26 00:00:00');
$where['ctime'] = array('>',$ch_time);
}else{
$c_time = strtotime("-1 month", strtotime(date('Y-m').'-26 00:00:00'));
$c_time1 = strtotime(date('Y-m'.'-25 23:59:59'));
$where['ctime'] = array(['>',$c_time],['<=',$c_time1]);
}
$where['state'] = 0;
$list = $this->article_obj->where($where)->select();
echo '<pre>';
var_dump($list);
echo '</pre>';
die;
$re['price'] = $price;
return jsonSuccess($re);
}
/**
* 核算月薪,记录进log(系统自动调用)
*/
public function pushStaffLog(){
}
/**
* 获取员工工资信息列表（管理员专用）
*/
public function getAllStaff($month = '0'){
if($month=='0'){//获取当月实时工资
}else{//获取其他月份工资log
}
}
/** /**
* 获取用户某月份工资详情 * 获取用户某月份工资详情
*/ */
public function getStaffLog(){ public function getStaffLog() {
$data = $this->request->post(); $data = $this->request->post();
$staff_info = $this->staff_obj->where('name',$data['name'])->find(); $staff_info = $this->staff_obj->where('name', $data['name'])->find();
$staff_log_obj = $this->staff_log_obj $staff_log_obj = $this->staff_log_obj
->where('staff_id',$staff_info['staff_id']) ->where('staff_id', $staff_info['staff_id'])
->where('date',$data['date']) ->where('date', $data['date'])
->where('state',0) ->where('state', 0)
->find(); ->find();
$re['staffLog'] = $staff_log_obj; $re['staffLog'] = $staff_log_obj;
return jsonSuccess($re); return jsonSuccess($re);
} }
/** /**
* 获取员工工资查询 * 检测员工查询
*/ */
public function checkStaffLogin(){ public function checkStaffLogin() {
$data = $this->request->post(); $data = $this->request->post();
$where['name'] = $data['name']; $where['name'] = $data['name'];
$where['password'] = md5($data['password']); $where['password'] = md5($data['password']);
$where['state'] = 0; $where['state'] = 0;
$res = $this->staff_obj->where($where)->find(); $res = $this->staff_obj->where($where)->find();
if($res){ if ($res) {
return jsonSuccess(['info'=>$res]); return jsonSuccess(['info' => $res]);
}else{ } else {
return jsonError('check error'); return jsonError('check error');
} }
} }
private function getBasePrice($name){ /**
$staff_info = $this->staff_obj->where('name',$name)->where('state',0)->find(); * 获取某月某员工工资
$level_info = $this->staff_level_obj->where('staff_level_id',$staff_info['staff_level_id'])->where('state',0)->find(); * @return type
//获取基本薪资 */
$price1 = $level_info['wages']+$staff_info['add_price']-$staff_info['sub_price']; private function getTomonthPrice($name, $date) {
$staff_info = $this->staff_obj->where('name', $name)->where('state',0)->find();
//获取稿件提成信息 $baseprice = $this->getBasePrice($name);
$price2 = 0;
if ($date != date('Ym')) {
//返回基础工资 $log_res = $this->staff_log_obj->where('staff_id', $staff_info['staff_id'])->where('date', $date)->where('state', 0)->find();
return $price1 +$price2; if ($log_res) {
$re['baseprice'] = $log_res['base_price'];
$re['journalprice'] = $log_res['journal_price'];
$re['citeprice'] = $log_res['cite_price'];
$re['add_price'] = $log_res['add_price'];
$re['sub_price'] = $log_res['sub_price'];
return $re;
} else {
return 'error';
}
}
//获取实时期刊提成情况
if (date('d') > 25) {
// $ch_time = strtotime(date('Y-m').'-26 00:00:00');
// $where['ctime'] = array('>',$ch_time);
//返回log数据
$log_res = $this->staff_log_obj->where('staff_id', $staff_info['staff_id'])->where('date', date('Ym'))->where('state', 0)->find();
if ($log_res) {
$re['staff_log_id'] = $log_res['staff_log_id'];
$re['baseprice'] = $log_res['base_price'];
$re['journalprice'] = $log_res['journal_price'];
$re['citeprice'] = $log_res['cite_price'];
$re['add_price'] = $log_res['add_price'];
$re['sub_price'] = $log_res['sub_price'];
return $re;
} else {
return 'error';
}
} else {
$c_time = strtotime("-1 month", strtotime(date('Y-m') . '-26 00:00:00'));
$c_time1 = strtotime(date('Y-m' . '-25 23:59:59'));
$where['ctime'] = array(['>', $c_time], ['<=', $c_time1]);
}
$journals = $this->journal_obj->where('staff_id', $staff_info['staff_id'])->select();
$journal_price = 0;
$cite_price = 0;
foreach ($journals as $v) {
$c_price = 0;
$where['accept_sn'] = ['like',$v['abbr'].'%'];
$cache_articles = $this->article_obj->where($where)->select();
$c_gn = 0;
$c_gw = 0;
foreach ($cache_articles as $vv) {
$c_country = $this->article_author_obj->where('article_id', $vv['article_id'])->where('state', 0)->column('country');
$c_c = 'gn';
foreach ($c_country as $vvv) {
if ($vvv != 'China' && $vvv != '') {
$c_c = 'gw';
}
}
if ($c_c == 'gn') {
$c_gn++;
} else {
$c_gw++;
}
}
if ($c_gn - $v['jour_num'] >= 0) {
$c_price = ($c_gn - $v['jour_num']) * 100 + $c_gw * 200;
} else {
if (($c_gw - ($v['jour_num'] - $c_gn)) >= 0) {
$c_price = ($c_gn + $c_gw - $v['jour_num']) * 200;
} else {
$c_price = 0 - ($v['jour_num'] - $c_gn - $c_gw) * 50;
}
}
$journal_price += $c_price;
//获取cite提成
$jcites = json_decode(myPost(self::JURL,['issn'=>$v['issn']]));
$jcs = $jcites->data->cites;
$cite_price += count($jcs)*500;
}
$re['staff_log_id'] = 0;
$re['baseprice'] = $baseprice;
$re['journalprice'] = $journal_price;
$re['citeprice'] = $cite_price;
$re['add_price'] = 0;
$re['sub_price'] = 0;
return $re;
} }
private function getBasePrice($name) {
$staff_info = $this->staff_obj->where('name', $name)->where('state', 0)->find();
// $level_info = $this->staff_level_obj->where('staff_level_id', $staff_info['staff_level_id'])->where('state', 0)->find();
$wag = $this->journal_obj->where('staff_id',$staff_info['staff_id'])->where('state',0)->sum('jour_price');
//获取基本薪资
$price1 = $wag + $staff_info['add_price'] - $staff_info['sub_price'];
//获取稿件提成信息
$price2 = 0;
//返回基础工资
return $price1 + $price2;
}
} }

38
application/common.php
View File

@@ -139,4 +139,40 @@ function jsonSuccess($data){
function jsonError($msg){ function jsonError($msg){
return json(['code'=>1,'msg'=>$msg]); return json(['code'=>1,'msg'=>$msg]);
} }
function myPost($url, $param=array()){
if(!is_array($param)){
throw new Exception("参数必须为array");
}
$httph =curl_init($url);
// curl_setopt($httph, CURLOPT_SSL_VERIFYPEER, 0);
// curl_setopt($httph, CURLOPT_SSL_VERIFYHOST, 1);
curl_setopt($httph,CURLOPT_RETURNTRANSFER,1);
curl_setopt($httph, CURLOPT_USERAGENT, "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.0)");
curl_setopt($httph, CURLOPT_POST, 1);//设置为POST方式
curl_setopt($httph, CURLOPT_POSTFIELDS, $param);
// curl_setopt($httph, CURLOPT_RETURNTRANSFER,0);
// curl_setopt($httph, CURLOPT_HEADER,1);
$rst=curl_exec($httph);
curl_close($httph);
return $rst;
}