EmployeeDailySalary.php 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use \think\Request;
  5. use \think\Db;
  6. /**
  7. * 员工日工资查询接口
  8. */
  9. class EmployeeDailySalary extends Api
  10. {
  11. protected $noNeedLogin = ['*'];
  12. protected $noNeedRight = ['*'];
  13. /**
  14. * 首页
  15. *
  16. */
  17. public function index()
  18. {
  19. $this->success('请求成功');
  20. }
  21. /**
  22. * 员工日工资查询侧边栏
  23. * @ApiMethod (GET)
  24. */
  25. public function getTab()
  26. {
  27. //get请求
  28. if(!$this->request->isGet()){
  29. $this->error('请求方式错误');
  30. }
  31. // $rows = db()->table('绩效工资汇总')
  32. // ->whereTime('sczl_rq', '>=', strtotime('-15 months'))
  33. // ->group('sys_ny')
  34. // ->order('sys_ny desc')
  35. // ->limit(15)
  36. // ->column('sys_ny');
  37. $rows = db()->table('db_大废品')
  38. ->whereTime('sys_rq', '>=', strtotime('-15 months'))
  39. ->group("DATE_FORMAT(`sys_rq`, '%Y%m')")
  40. ->order('sys_rq desc')
  41. ->limit(15)
  42. ->column("DATE_FORMAT(`sys_rq`, '%Y%m')");
  43. $res=db()->table('绩效工资汇总')
  44. ->field('sys_ny,bh')
  45. ->group('sys_ny,bh')
  46. ->where(['sys_ny'=>['between',"$rows[14],$rows[0]"]])
  47. ->order('sys_ny desc')
  48. ->select();
  49. foreach($res as $v){
  50. $arr[$v['sys_ny'].'-'][]=$v['bh'];
  51. }
  52. $rs = db()->table('人事_基本资料')->column('员工编号,所在部门');
  53. foreach($arr as $k=>$v){
  54. foreach($v as $key=>$value){
  55. $data[$k][$key]=rtrim($rs[$value]);
  56. }
  57. $data[$k]=array_unique($data[$k]);
  58. usort($data[$k], function($a, $b) {
  59. $order = array(
  60. '胶印车间',
  61. '凹印车间',
  62. '丝印车间',
  63. '模切车间',
  64. '检验车间',
  65. '精品试验车间',
  66. '品保部',
  67. '人力资源部',
  68. '生产部',
  69. '营销部'
  70. );
  71. $a_index = array_search($a, $order);
  72. $b_index = array_search($b, $order);
  73. return $a_index - $b_index;
  74. });
  75. }
  76. $i=0;
  77. foreach($data as $k=>$v){
  78. $datas[$i]['label']=str_replace('-','',$k);
  79. foreach($v as $value){
  80. $datas[$i]['children'][]['label']=$value;
  81. }
  82. $i++;
  83. }
  84. $this->success('成功',$datas);
  85. }
  86. /**
  87. * 员工日工资查询上侧列表
  88. * @ApiMethod (GET)
  89. * @param string $date 年月
  90. * @param string $department 部门
  91. */
  92. public function getList()
  93. {
  94. //get请求
  95. if(!$this->request->isGet()){
  96. $this->error('请求方式错误');
  97. }
  98. $req = $this->request->param();
  99. $res=db()->table('绩效工资汇总')
  100. ->join('人事_基本资料','人事_基本资料.员工编号=绩效工资汇总.bh','LEFT')
  101. ->field('bh,rtrim(xm) as 员工姓名,LEFT(sczl_rq, 10) as sczl_rq,sum(个人计件工资) as 计件工资,
  102. sum(个人加班工资) as 加班工资,(sum(个人计件工资)+sum(个人加班工资)) as 日工资合计')
  103. ->group('绩效工资汇总.bh,LEFT(sczl_rq, 10)')
  104. ->where('sys_ny',$req['date'])
  105. ->where(['人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  106. ->select();
  107. if(!$res){
  108. $this->error('失败');
  109. }
  110. $year=substr($req['date'],0,4);
  111. $month=substr($req['date'],-2);
  112. if($month==12){
  113. $start_time=$year.'-12-01 00:00:00';
  114. $end_time=($year+1).'-01-01 00:00:00';
  115. }else{
  116. $start_time=$year.'-'.$month.'-01 00:00:00';
  117. $end_time=$year.'-'.($month+1).'-01 00:00:00';
  118. }
  119. $res1=db()->table('db_wgjs')
  120. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh1 as wgjs_bh,wgjs_js1 as wgjs_js')
  121. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh1','LEFT')
  122. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  123. ->select();
  124. $res2=db()->table('db_wgjs')
  125. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh2 as wgjs_bh,wgjs_js2 as wgjs_js')
  126. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh2','LEFT')
  127. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  128. ->select();
  129. $res3=db()->table('db_wgjs')
  130. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh3 as wgjs_bh,wgjs_js3 as wgjs_js')
  131. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh3','LEFT')
  132. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  133. ->select();
  134. $res4=db()->table('db_wgjs')
  135. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh4 as wgjs_bh,wgjs_js4 as wgjs_js')
  136. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh4','LEFT')
  137. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  138. ->select();
  139. $res5=db()->table('db_wgjs')
  140. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh5 as wgjs_bh,wgjs_js5 as wgjs_js')
  141. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh5','LEFT')
  142. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  143. ->select();
  144. $res6=db()->table('db_wgjs')
  145. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh6 as wgjs_bh,wgjs_js6 as wgjs_js')
  146. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh6','LEFT')
  147. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  148. ->select();
  149. $arr=array_merge($res1,$res2,$res3,$res4,$res5,$res6);
  150. foreach($arr as $v){
  151. if(isset($list[$v['wgjs_rq']][$v['wgjs_bh']])){
  152. $list[$v['wgjs_rq']][$v['wgjs_bh']]+=$v['wgjs_js'];
  153. }else{
  154. $list[$v['wgjs_rq']][$v['wgjs_bh']]=$v['wgjs_js'];
  155. }
  156. }
  157. foreach($res as &$v){
  158. if(isset($list[$v['sczl_rq']][$v['bh']])){
  159. $v['计时']=$list[$v['sczl_rq']][$v['bh']];
  160. }else{
  161. $v['计时']='';
  162. }
  163. $v['sczl_rq']=str_replace('-','.',$v['sczl_rq']);
  164. }
  165. $this->success('成功',$res);
  166. }
  167. /**
  168. * 员工日工资查询下侧列表
  169. * @ApiMethod (GET)
  170. * @param string $date 年月
  171. * @param string $code 员工编号
  172. */
  173. public function getAllList()
  174. {
  175. //get请求
  176. if(!$this->request->isGet()){
  177. $this->error('请求方式错误');
  178. }
  179. $req = $this->request->param();
  180. $res=db()->table('绩效工资汇总')
  181. ->field('LEFT(sczl_rq, 10) as sczl_rq,sczl_gdbh,rtrim(g.Gd_cpmc) as Gd_cpmc,sczl_yjno,sczl_gxh,sczl_type,
  182. sczl_jtbh,sum(班组车头产量) as 班组车头产量,sum(班组换算产量) as 班组换算产量,工序难度系数,sum(个人计件工资)
  183. as 个人计件工资,sum(个人加班工资) as 个人加班工资,sum(装版工时) as 装版工时,sum(保养工时) as 保养工时,
  184. sum(打样工时) as 打样工时,sum(异常停机工时) as 异常停机工时,sum(车头产量占用机时) as 车头产量占用机时,日定额,
  185. sum(达标定额) as 达标定额,千件工价,补产标准,bh,rtrim(xm) as xm,Rate')
  186. ->join('工单_基本资料 g','g.Gd_gdbh=绩效工资汇总.sczl_gdbh','LEFT')
  187. ->group('LEFT(sczl_rq, 10),sczl_gdbh')
  188. ->where(['sys_ny'=>$req['date'],'bh'=>$req['code']])
  189. ->select();
  190. if(!$res){
  191. $this->error('失败');
  192. }
  193. foreach($res as &$v){
  194. $v['sczl_rq']=str_replace('-','.',$v['sczl_rq']);
  195. if($v['sczl_yjno']>9){
  196. $sczl_yjno=$v['sczl_yjno'];
  197. }else{
  198. $sczl_yjno='0'.$v['sczl_yjno'];
  199. }
  200. unset($v['sczl_yjno']);
  201. if($v['sczl_gxh']>9){
  202. $sczl_gxh=$v['sczl_gxh'];
  203. }else{
  204. $sczl_gxh='0'.$v['sczl_gxh'];
  205. }
  206. unset($v['sczl_gxh']);
  207. $v['sczl_type']=$sczl_yjno.'-'.$sczl_gxh.'-->'.$v['sczl_type'];
  208. }
  209. $this->success('成功',$res);
  210. }
  211. /**
  212. * 员工日工资查询详情
  213. * @ApiMethod (GET)
  214. * @param string $date 日期
  215. * @param string $code 员工编号
  216. */
  217. public function getDetail()
  218. {
  219. //get请求
  220. if(!$this->request->isGet()){
  221. $this->error('请求方式错误');
  222. }
  223. $req = $this->request->param();
  224. $start_time=$req['date'].' 00:00:00';
  225. $end_time=$req['date'].' 23:59:59';
  226. $res=db()->table('绩效工资汇总')
  227. ->field('LEFT(sczl_rq, 10) as sczl_rq,sczl_gdbh,rtrim(g.Gd_cpmc) as Gd_cpmc,sczl_yjno,sczl_gxh,sczl_type,
  228. sczl_jtbh,sum(班组车头产量) as 班组车头产量,sum(班组换算产量) as 班组换算产量,工序难度系数,sum(个人计件工资)
  229. as 个人计件工资,sum(个人加班工资) as 个人加班工资,sum(装版工时) as 装版工时,sum(保养工时) as 保养工时,
  230. sum(打样工时) as 打样工时,sum(异常停机工时) as 异常停机工时,sum(车头产量占用机时) as 车头产量占用机时,日定额,
  231. sum(达标定额) as 达标定额,千件工价,补产标准,bh,rtrim(xm) as xm,Rate')
  232. ->join('工单_基本资料 g','g.Gd_gdbh=绩效工资汇总.sczl_gdbh','LEFT')
  233. ->group('LEFT(sczl_rq, 10),sczl_gdbh')
  234. ->where(['sczl_rq'=>['between',"$start_time,$end_time"],'bh'=>$req['code']])
  235. ->select();
  236. if(!$res){
  237. $this->error('失败');
  238. }
  239. foreach($res as &$v){
  240. $v['sczl_rq']=str_replace('-','.',$v['sczl_rq']);
  241. if($v['sczl_yjno']>9){
  242. $sczl_yjno=$v['sczl_yjno'];
  243. }else{
  244. $sczl_yjno='0'.$v['sczl_yjno'];
  245. }
  246. unset($v['sczl_yjno']);
  247. if($v['sczl_gxh']>9){
  248. $sczl_gxh=$v['sczl_gxh'];
  249. }else{
  250. $sczl_gxh='0'.$v['sczl_gxh'];
  251. }
  252. unset($v['sczl_gxh']);
  253. $v['sczl_type']=$sczl_yjno.'-'.$sczl_gxh.'-->'.$v['sczl_type'];
  254. }
  255. $this->success('成功',$res);
  256. }
  257. /**
  258. * 获取计件工计时单信息
  259. * @ApiMethod (GET)
  260. * @param string $UniqId UniqId
  261. */
  262. public function getInfo()
  263. {
  264. //get请求
  265. if(!$this->request->isGet()){
  266. $this->error('请求方式错误');
  267. }
  268. $req = $this->request->param();
  269. if (isset($req['UniqId']) && !empty($req['UniqId'])){
  270. $UniqId = $req['UniqId'];
  271. }else{
  272. $this->error('参数错误');
  273. }
  274. $rows = db()->table('db_wgjs')->alias('d')
  275. ->field('d.*, ')
  276. ->join('工单_基本资料 g', 'd.')
  277. ->where('d.UniqId',$UniqId)
  278. ->select();
  279. $this->success('成功',$rows);
  280. }
  281. /**
  282. * 定位
  283. * @ApiMethod GET
  284. */
  285. public function search(){
  286. //get请求
  287. if(!$this->request->isGet()){
  288. $this->error('请求方式错误');
  289. }
  290. $req = $this->request->param();
  291. $yg = db()->table('人事_基本资料')->where('员工姓名',$req['search'])->value('员工编号');
  292. if($yg){
  293. $req['search']=$yg;
  294. }
  295. $res=db()->table('绩效工资汇总')
  296. // ->join('人事_基本资料','人事_基本资料.员工编号=绩效工资汇总.bh','LEFT')
  297. ->field('bh,xm as 员工姓名,LEFT(sczl_rq, 10) as sczl_rq,sum(个人计件工资) as 计件工资,
  298. sum(个人加班工资) as 加班工资,(sum(个人计件工资)+sum(个人加班工资)) as 日工资合计')
  299. ->group('绩效工资汇总.bh,LEFT(sczl_rq, 10)')
  300. ->where('sys_ny',$req['date'])
  301. ->where('bh',$req['search'])
  302. // ->where('人事_基本资料.所在部门',$req['department'])
  303. ->select();
  304. if(!$res){
  305. $this->error('失败');
  306. }
  307. $year=substr($req['date'],0,4);
  308. $month=substr($req['date'],-2);
  309. if($month==12){
  310. $start_time=$year.'-12-01 00:00:00';
  311. $end_time=($year+1).'-01-01 00:00:00';
  312. }else{
  313. $start_time=$year.'-'.$month.'-01 00:00:00';
  314. $end_time=$year.'-'.($month+1).'-01 00:00:00';
  315. }
  316. $res1=db()->table('db_wgjs')
  317. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh1 as wgjs_bh,wgjs_js1 as wgjs_js')
  318. // ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh1','LEFT')
  319. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'wgjs_bh1'=>$req['search']])
  320. ->select();
  321. $res2=db()->table('db_wgjs')
  322. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh2 as wgjs_bh,wgjs_js2 as wgjs_js')
  323. // ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh2','LEFT')
  324. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'wgjs_bh2'=>$req['search']])
  325. ->select();
  326. $res3=db()->table('db_wgjs')
  327. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh3 as wgjs_bh,wgjs_js3 as wgjs_js')
  328. // ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh3','LEFT')
  329. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'wgjs_bh3'=>$req['search']])
  330. ->select();
  331. $res4=db()->table('db_wgjs')
  332. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh4 as wgjs_bh,wgjs_js4 as wgjs_js')
  333. // ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh4','LEFT')
  334. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'wgjs_bh4'=>$req['search']])
  335. ->select();
  336. $res5=db()->table('db_wgjs')
  337. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh5 as wgjs_bh,wgjs_js5 as wgjs_js')
  338. // ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh5','LEFT')
  339. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'wgjs_bh5'=>$req['search']])
  340. ->select();
  341. $res6=db()->table('db_wgjs')
  342. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh6 as wgjs_bh,wgjs_js6 as wgjs_js')
  343. // ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh6','LEFT')
  344. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'wgjs_bh6'=>$req['search']])
  345. ->select();
  346. $arr=array_merge($res1,$res2,$res3,$res4,$res5,$res6);
  347. foreach($arr as $v){
  348. if(isset($list[$v['wgjs_rq']][$v['wgjs_bh']])){
  349. $list[$v['wgjs_rq']][$v['wgjs_bh']]+=$v['wgjs_js'];
  350. }else{
  351. $list[$v['wgjs_rq']][$v['wgjs_bh']]=$v['wgjs_js'];
  352. }
  353. }
  354. foreach($res as &$v){
  355. $v['sczl_rq']=str_replace('-','.',$v['sczl_rq']);
  356. if(isset($list[$v['sczl_rq']][$v['bh']])){
  357. $v['计时']=$list[$v['sczl_rq']][$v['bh']];
  358. }else{
  359. $v['计时']='';
  360. }
  361. }
  362. $this->success('成功',$res);
  363. }
  364. /**
  365. * 员工计件明细
  366. * @ApiMethod (GET)
  367. * @param string $start_time
  368. * @param string $end_time
  369. * @param string $code 员工编号
  370. */
  371. public function getPieceDetail()
  372. {
  373. //get请求
  374. if(!$this->request->isGet()){
  375. $this->error('请求方式错误');
  376. }
  377. $req = $this->request->param();
  378. $req['start_time']=str_replace('.','-',$req['start_time']);
  379. $req['end_time']=str_replace('.','-',$req['end_time']);
  380. $start_time=$req['start_time'].' 00:00:00';
  381. $end_time=$req['end_time'].' 23:59:59';
  382. $res=db()->table('绩效工资汇总')
  383. ->field('LEFT(sczl_rq, 10) as sczl_rq,sczl_gdbh,rtrim(g.员工姓名) as 员工资料,sczl_yjno,sczl_gxh,sczl_type,
  384. sczl_jtbh,班组车头产量,保养工时,装版工时,打样工时,异常停机工时,补产标准,计时补差额工资 as 班组补产,日定额,达标定额,千件工价,
  385. 个人计件工资,个人加班工资,Rate as 个人比例')
  386. ->join('人事_基本资料 g','人事_基本资料.员工编号=绩效工资汇总.bh','LEFT')
  387. ->where(['sczl_rq'=>['between',"$start_time,$end_time"],'bh'=>$req['code']])
  388. ->select();
  389. if(!$res){
  390. $this->error('失败');
  391. }
  392. foreach($res as &$v){
  393. $v['sczl_rq']=str_replace('-','.',$v['sczl_rq']);
  394. if($v['sczl_yjno']>9){
  395. $sczl_yjno=$v['sczl_yjno'];
  396. }else{
  397. $sczl_yjno='0'.$v['sczl_yjno'];
  398. }
  399. unset($v['sczl_yjno']);
  400. if($v['sczl_gxh']>9){
  401. $sczl_gxh=$v['sczl_gxh'];
  402. }else{
  403. $sczl_gxh='0'.$v['sczl_gxh'];
  404. }
  405. unset($v['sczl_gxh']);
  406. $v['sczl_type']=$sczl_yjno.'-'.$sczl_gxh.'-->'.$v['sczl_type'];
  407. $v['班组补产']=$v['补产标准']*($v['保养工时']+$v['装版工时']+$v['打样工时']+$v['异常停机工时']);
  408. }
  409. $this->success('成功',$res);
  410. }
  411. /**
  412. * 每日工资统计
  413. * @ApiMethod (GET)
  414. * @param string $date 年月
  415. * @param string $department 部门
  416. */
  417. public function statistics()
  418. {
  419. //get请求
  420. if(!$this->request->isGet()){
  421. $this->error('请求方式错误');
  422. }
  423. $req = $this->request->param();
  424. $res=db()->table('绩效工资汇总')
  425. ->join('人事_基本资料','人事_基本资料.员工编号=绩效工资汇总.bh','LEFT')
  426. ->field('bh,rtrim(xm) as 员工姓名,LEFT(sczl_rq, 10) as sczl_rq,sum(个人计件工资) as 计件工资,
  427. sum(个人加班工资) as 加班工资')
  428. ->group('绩效工资汇总.bh,LEFT(sczl_rq, 10)')
  429. ->where('sys_ny',$req['date'])
  430. ->where(['人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  431. ->select();
  432. if(!$res){
  433. $this->error('失败');
  434. }
  435. $year=substr($req['date'],0,4);
  436. $month=substr($req['date'],-2);
  437. if($month==12){
  438. $start_time=$year.'-12-01 00:00:00';
  439. $end_time=($year+1).'-01-01 00:00:00';
  440. }else{
  441. $start_time=$year.'-'.$month.'-01 00:00:00';
  442. $end_time=$year.'-'.($month+1).'-01 00:00:00';
  443. }
  444. $res1=db()->table('db_wgjs')
  445. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh1 as wgjs_bh,wgjs_js1 as wgjs_js')
  446. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh1','LEFT')
  447. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  448. ->select();
  449. $res2=db()->table('db_wgjs')
  450. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh2 as wgjs_bh,wgjs_js2 as wgjs_js')
  451. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh2','LEFT')
  452. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  453. ->select();
  454. $res3=db()->table('db_wgjs')
  455. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh3 as wgjs_bh,wgjs_js3 as wgjs_js')
  456. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh3','LEFT')
  457. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  458. ->select();
  459. $res4=db()->table('db_wgjs')
  460. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh4 as wgjs_bh,wgjs_js4 as wgjs_js')
  461. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh4','LEFT')
  462. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  463. ->select();
  464. $res5=db()->table('db_wgjs')
  465. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh5 as wgjs_bh,wgjs_js5 as wgjs_js')
  466. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh5','LEFT')
  467. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  468. ->select();
  469. $res6=db()->table('db_wgjs')
  470. ->field('LEFT(wgjs_rq, 10) as wgjs_rq,wgjs_bh6 as wgjs_bh,wgjs_js6 as wgjs_js')
  471. ->join('人事_基本资料','人事_基本资料.员工编号=db_wgjs.wgjs_bh6','LEFT')
  472. ->where(['wgjs_rq'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
  473. ->select();
  474. $arr=array_merge($res1,$res2,$res3,$res4,$res5,$res6);
  475. foreach($arr as $v){
  476. if(isset($list[$v['wgjs_rq']][$v['wgjs_bh']])){
  477. $list[$v['wgjs_rq']][$v['wgjs_bh']]+=$v['wgjs_js'];
  478. }else{
  479. $list[$v['wgjs_rq']][$v['wgjs_bh']]=$v['wgjs_js'];
  480. }
  481. }
  482. foreach($res as &$v){
  483. if(isset($list[$v['sczl_rq']][$v['bh']])){
  484. $v['计时工资']=$list[$v['sczl_rq']][$v['bh']];
  485. }else{
  486. $v['计时工资']='';
  487. }
  488. $v['部门']=$req['department'];
  489. $v['sczl_rq']=str_replace('-','.',$v['sczl_rq']);
  490. }
  491. $this->success('成功',$res);
  492. }
  493. /**
  494. * 月度计时工资调整
  495. * @ApiMethod (GET)
  496. * @param string $date 年月
  497. * @param string $code 员工编号
  498. */
  499. public function wageAdjustment()
  500. {
  501. //get请求
  502. if(!$this->request->isGet()){
  503. $this->error('请求方式错误');
  504. }
  505. $req = $this->request->param();
  506. $res=db()->table('绩效加班工资月度修正')
  507. ->field('人事_基本资料.所在部门,bh,rtrim(xm) as xm,月计时时数,DATE_FORMAT(sczl_rq,"%Y.%m.%d") as sczl_rq,sczl_gdbh,sczl_yjno,sczl_gxh,
  508. 千件工价,Rate,sum(达标定额) as 达标定额,sum(个人计件工资) as 个人计件工资,sum(个人加班工资) as 个人加班工资,计时冲定额,sum(New_计件工资) as
  509. New_计件工资,sum(New_加班工资) as New_加班工资,调整量_合计')
  510. ->join('人事_基本资料','人事_基本资料.员工编号=绩效加班工资月度修正.bh','LEFT')
  511. ->group('LEFT(sczl_rq, 10),sczl_gdbh')
  512. ->where(['sys_ny'=>$req['date'],'bh'=>$req['code']])
  513. ->select();
  514. if(!$res){
  515. $this->error('失败');
  516. }
  517. foreach($res as &$v){
  518. if($v['sczl_yjno']>9){
  519. $sczl_yjno=$v['sczl_yjno'];
  520. }else{
  521. $sczl_yjno='0'.$v['sczl_yjno'];
  522. }
  523. unset($v['sczl_yjno']);
  524. if($v['sczl_gxh']>9){
  525. $sczl_gxh=$v['sczl_gxh'];
  526. }else{
  527. $sczl_gxh='0'.$v['sczl_gxh'];
  528. }
  529. unset($v['sczl_gxh']);
  530. $v['sczl_gdbh']=$v['sczl_gdbh'].'-'.$sczl_yjno.'-'.$sczl_gxh;
  531. $v['bh']=$v['bh'].' '.$v['xm'];
  532. unset($v['xm']);
  533. }
  534. $this->success('成功',$res);
  535. }
  536. }