MachineProductionReport.php 55 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. /**
  5. * 机台生产日报表维护接口
  6. */
  7. class MachineProductionReport extends Api
  8. {
  9. protected $noNeedLogin = ['*'];
  10. protected $noNeedRight = ['*'];
  11. /**
  12. * 首页
  13. *
  14. */
  15. public function index()
  16. {
  17. $this->success('请求成功');
  18. }
  19. /**
  20. * 获取机台生产日报表侧边栏
  21. * @ApiMethod (GET)
  22. */
  23. public function getTab()
  24. {
  25. //get请求
  26. if(!$this->request->isGet()){
  27. $this->error('请求方式错误');
  28. }
  29. $time = date('Y-m-d',time()-8640000);
  30. $sql = 'SELECT date, COUNT(*) as counts
  31. FROM (
  32. SELECT LEFT(sys_rq, 10) as date FROM db_sczl WHERE sys_rq > "'.$time.'"
  33. UNION ALL
  34. SELECT LEFT(sys_rq, 10) as date FROM 设备_产量计酬 WHERE sys_rq > "'.$time.'"
  35. ) AS t1
  36. GROUP BY date
  37. ORDER BY date DESC
  38. LIMIT 30';
  39. $rows = db()->query($sql);
  40. if(count($rows) < 30){
  41. $sql = 'SELECT date, COUNT(*) as counts
  42. FROM (
  43. SELECT LEFT(sys_rq, 10) as date FROM db_sczl WHERE sys_rq > "2023-11-01"
  44. UNION ALL
  45. SELECT LEFT(sys_rq, 10) as date FROM 设备_产量计酬 WHERE sys_rq > "2023-11-01"
  46. ) AS t1
  47. GROUP BY date
  48. ORDER BY date DESC
  49. LIMIT 30';
  50. $rows = db()->query($sql);
  51. }
  52. $sql = 'SELECT date, sys_id, COUNT(*) as count
  53. FROM (
  54. SELECT LEFT(sys_rq, 10) as date, rtrim(sys_id) as sys_id
  55. FROM db_sczl WHERE sys_rq >= "'.$rows[count($rows)-1]['date'].'"
  56. UNION ALL
  57. SELECT LEFT(sys_rq, 10) as date, rtrim(sys_id) as sys_id
  58. FROM 设备_产量计酬 WHERE sys_rq >= "'.$rows[count($rows)-1]['date'].'"
  59. ) AS t1
  60. GROUP BY date, sys_id
  61. ORDER BY date, sys_id';
  62. $data = db()->query($sql);
  63. $result = [];
  64. foreach ($data as $item) {
  65. $date = $item['date'];
  66. $sysId = $item['sys_id'];
  67. $count = $item['count'];
  68. // 如果结果数组中不存在该日期和系统ID的记录,则创建新记录
  69. if (!isset($result[$date][$sysId])) {
  70. if (substr($sysId,1,3)=='00-'){
  71. if (isset($result[$date])){
  72. $result[$date] = array_merge([$sysId=>0],$result[$date]);
  73. }else{
  74. $result[$date][$sysId] = 0;
  75. }
  76. }else{
  77. $result[$date][$sysId] = 0;
  78. }
  79. }
  80. // 将count累加到对应的记录中
  81. $result[$date][$sysId] += $count;
  82. }
  83. foreach($rows as $key=>$value){
  84. $rows[$key]['sys'] = $result[$value['date']];
  85. $rows[$key]['date'] = str_replace('-', '.', $rows[$key]['date']);
  86. }
  87. $this->success('成功',$rows);
  88. }
  89. /**
  90. * 通过工单获取机台生产日报表侧边栏
  91. * @ApiMethod (GET)
  92. */
  93. public function getTabByGdbh()
  94. {
  95. //get请求
  96. if(!$this->request->isGet()){
  97. $this->error('请求方式错误');
  98. }
  99. $date = date('Y-m-d',strtotime("-1 year"));
  100. $sql = 'SELECT t1.`sczl_gdbh`,t2.`yj_yjmc`
  101. FROM (
  102. SELECT DISTINCT `sczl_gdbh`, sczl_yjno FROM `db_sczl` where sys_rq >"'.$date.'"
  103. UNION
  104. SELECT DISTINCT `sczl_gdbh`, sczl_yjno FROM `设备_产量计酬` where sys_rq >"'.$date.'"
  105. ) AS t1
  106. JOIN `工单_印件资料` AS t2 ON t1.`sczl_gdbh` = t2.`Yj_Gdbh`
  107. WHERE t1.sczl_yjno = t2.yj_Yjno
  108. ORDER BY t1.`sczl_gdbh` DESC
  109. LIMIT 65';
  110. $rows = db()->query($sql);
  111. $sql = 'SELECT sczl_gdbh,rtrim(sys_id) as sys_id
  112. FROM (
  113. SELECT sczl_gdbh,rtrim(sys_id) as sys_id
  114. FROM db_sczl WHERE sczl_gdbh >= "'.$rows[count($rows)-1]['sczl_gdbh'].'"
  115. UNION ALL
  116. SELECT sczl_gdbh,rtrim(sys_id) as sys_id
  117. FROM 设备_产量计酬 WHERE sczl_gdbh >= "'.$rows[count($rows)-1]['sczl_gdbh'].'"
  118. ) AS t1
  119. ORDER BY sys_id';
  120. $arr = db()->query($sql);
  121. $brr = [];
  122. foreach($arr as $k=>$v){
  123. if(array_key_exists($v['sczl_gdbh'],$brr)){
  124. if(array_key_exists($v['sys_id'],$brr[$v['sczl_gdbh']])){
  125. $brr[$v['sczl_gdbh']][$v['sys_id']] += 1;
  126. }else{
  127. $brr[$v['sczl_gdbh']][$v['sys_id']] = 1;
  128. }
  129. }else{
  130. $brr[$v['sczl_gdbh']][$v['sys_id']] = 1;
  131. }
  132. }
  133. foreach($rows as $key=>$value){
  134. $rows[$key]['sys'] = $brr[$value['sczl_gdbh']];
  135. $rows[$key]['yj_yjmc'] = trim($value['yj_yjmc']);
  136. }
  137. $this->success('成功',$rows);
  138. }
  139. /**
  140. * 获取机台生产日报表列表
  141. * @ApiMethod (GET)
  142. * @param string $date 时间
  143. * @param string $sys_id 用户
  144. */
  145. public function getList()
  146. {
  147. //get请求
  148. if(!$this->request->isGet()){
  149. $this->error('请求方式错误');
  150. }
  151. $req = $this->request->param();
  152. if (!isset($req['date']) || empty($req['date'])) $this->error('参数缺失');
  153. $page = 1;
  154. $limit = 15;
  155. if (isset($req['page']) && !empty($req['page'])) $page = $req['page'];
  156. if (isset($req['limit']) && !empty($req['limit'])) $limit = $req['limit'];
  157. //获取total
  158. $sql = 'SELECT sum(count) AS count FROM (
  159. SELECT COUNT(*) AS count FROM `设备_产量计酬` ';
  160. $sql .= strpos($req['date'],'-') ? 'WHERE `sys_rq` LIKE "'.$req['date'].'%" ' : 'WHERE `sczl_gdbh` = "'.$req['date'].'" ';
  161. $sql .= isset($req['sys_id']) && !empty($req['sys_id']) ? 'AND `sys_id` LIKE "'.$req['sys_id'].'%" ' : '';
  162. $sql .= 'UNION ALL SELECT COUNT(*) AS count FROM `db_sczl`';
  163. $sql .= strpos($req['date'],'-') ? 'WHERE `sys_rq` LIKE "'.$req['date'].'%" ' : 'WHERE `sczl_gdbh` = "'.$req['date'].'" ';
  164. $sql .= isset($req['sys_id']) && !empty($req['sys_id']) ? 'AND `sys_id` LIKE "'.$req['sys_id'].'%" ' : '';
  165. $sql .= ') as t';
  166. $total = db()->query($sql)[0]['count'];
  167. if (cache('MachineProductReport-getList')){
  168. if(array_key_exists($req['date'].'-'.$req['sys_id'].'-'.$req['page'].'-'.$req['limit'] , cache('MachineProductReport-getList'))){
  169. $rows = cache('MachineProductReport-getList')[$req['date'].'-'.$req['sys_id'].'-'.$req['page'].'-'.$req['limit']];
  170. }else{
  171. //UNION 查询两表数据
  172. // db_sczl缺少数据 --> a.sczl_来料少数,
  173. // 设备_产量计酬缺少数据 --> a.拆片联拼系数, a.拆片条小盒系数,
  174. $sql = 'SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  175. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_zcfp, a.sczl_zccp,
  176. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  177. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  178. d.日定额, d.千件工价, d.补产标准, a.sczl_来料少数, NULL AS 拆片联拼系数, NULL AS 拆片条小盒系数,
  179. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId,e.yj_yjmc, "设备_产量计酬" AS table_type
  180. FROM `设备_产量计酬` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` JOIN `工单_印件资料` `e` ON `a`.`sczl_gdbh`=`e`.`Yj_Gdbh` AND `a`.`sczl_yjno`=`e`.`yj_Yjno`';
  181. $sql .= strpos($req['date'],'-') ? 'WHERE `a`.`sys_rq` LIKE "'.$req['date'].'%" ' : 'WHERE `a`.`sczl_gdbh` = "'.$req['date'].'" ';
  182. $sql .= isset($req['sys_id']) && !empty($req['sys_id']) ? 'AND `a`.`sys_id` = "'.$req['sys_id'].'" ' : '';
  183. $sql .= 'UNION ALL
  184. SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  185. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_fp as sczl_zcfp, a.sczl_cp as sczl_zccp,
  186. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  187. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  188. d.日定额, d.千件工价, d.补产标准, NULL AS sczl_来料少数, a.拆片联拼系数, a.拆片条小盒系数,
  189. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId,e.yj_yjmc, "db_sczl" AS table_type
  190. FROM `db_sczl` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` JOIN `工单_印件资料` `e` ON `a`.`sczl_gdbh`=`e`.`Yj_Gdbh` AND `a`.`sczl_yjno`=`e`.`yj_Yjno`';
  191. $sql .= strpos($req['date'],'-') ? 'WHERE `a`.`sys_rq` LIKE "'.$req['date'].'%" ' : 'WHERE `a`.`sczl_gdbh` = "'.$req['date'].'" ';
  192. $sql .= isset($req['sys_id']) && !empty($req['sys_id']) ? 'AND `a`.`sys_id` = "'.$req['sys_id'].'" ' : '';
  193. $sql .= 'ORDER BY sys_id ASC, sczl_num ASC LIMIT '.($page-1)*$limit.','.$limit;
  194. $rows = db()->query($sql);
  195. //设置缓存
  196. $cache = cache('MachineProductReport-getList');
  197. $cache[$req['date'].'-'.$req['sys_id'].'-'.$req['page'].'-'.$req['limit']] = $rows;
  198. cache('MachineProductReport-getList',$cache,3600);
  199. }
  200. }else{
  201. //UNION 查询两表数据
  202. // db_sczl缺少数据 --> a.sczl_来料少数,
  203. // 设备_产量计酬缺少数据 --> a.拆片联拼系数, a.拆片条小盒系数,
  204. $sql = 'SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  205. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_zcfp, a.sczl_zccp,
  206. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  207. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  208. d.日定额, d.千件工价, d.补产标准, a.sczl_来料少数, NULL AS 拆片联拼系数, NULL AS 拆片条小盒系数,
  209. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId,e.yj_yjmc, "设备_产量计酬" AS table_type
  210. FROM `设备_产量计酬` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` JOIN `工单_印件资料` `e` ON `a`.`sczl_gdbh`=`e`.`Yj_Gdbh` AND `a`.`sczl_yjno`=`e`.`yj_Yjno`';
  211. $sql .= strpos($req['date'],'-') ? 'WHERE `a`.`sys_rq` LIKE "'.$req['date'].'%" ' : 'WHERE `a`.`sczl_gdbh` = "'.$req['date'].'" ';
  212. $sql .= isset($req['sys_id']) && !empty($req['sys_id']) ? 'AND `a`.`sys_id` = "'.$req['sys_id'].'" ' : '';
  213. $sql .= 'UNION ALL
  214. SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  215. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_fp as sczl_zcfp, a.sczl_cp as sczl_zccp,
  216. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  217. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  218. d.日定额, d.千件工价, d.补产标准, NULL AS sczl_来料少数, a.拆片联拼系数, a.拆片条小盒系数,
  219. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId,e.yj_yjmc, "db_sczl" AS table_type
  220. FROM `db_sczl` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` JOIN `工单_印件资料` `e` ON `a`.`sczl_gdbh`=`e`.`Yj_Gdbh` AND `a`.`sczl_yjno`=`e`.`yj_Yjno`';
  221. $sql .= strpos($req['date'],'-') ? 'WHERE `a`.`sys_rq` LIKE "'.$req['date'].'%" ' : 'WHERE `a`.`sczl_gdbh` = "'.$req['date'].'" ';
  222. $sql .= isset($req['sys_id']) && !empty($req['sys_id']) ? 'AND `a`.`sys_id` = "'.$req['sys_id'].'" ' : '';
  223. $sql .= 'ORDER BY sys_id ASC, sczl_num ASC LIMIT '.($page-1)*$limit.','.$limit;
  224. $rows = db()->query($sql);
  225. //设置缓存
  226. $cache = [];
  227. $cache[$req['date'].'-'.$req['sys_id'].'-'.$req['page'].'-'.$req['limit']] = $rows;
  228. cache('MachineProductReport-getList',$cache,3600);
  229. }
  230. $gd = db('工单_基本资料')->cache(true,3600)->column('Gd_gdbh, 成品名称 as Gd_cpmc');
  231. $rs = db('人事_基本资料')->cache(true,3600)->column('员工编号, 员工姓名');
  232. foreach ($rows as $key=>$value){
  233. $rows[$key]['mod_rq'] = $value['mod_rq']=='1900-01-01 00:00:00' ? '' :$value['mod_rq'];
  234. // $rows[$key]['Gd_cpmc'] = array_key_exists($value['sczl_gdbh'],$gd) ? trim($gd[$value['sczl_gdbh']]) : '';
  235. $rows[$key]['Gd_cpmc'] = $value['yj_yjmc'];
  236. $rows[$key]['name1'] = array_key_exists($value['sczl_bh1'],$rs) ? trim($rs[$value['sczl_bh1']]) : '';
  237. for ($i=2;$i<=6;$i++){
  238. if ($value['sczl_bh'.$i]){
  239. if ($value['sczl_bh'.$i]==$value['sczl_bh1']){
  240. $rows[$key]['name'.$i] = $rows[$key]['name1'];
  241. }else{
  242. $rows[$key]['name'.$i] = array_key_exists($value['sczl_bh'.$i],$rs) ? trim($rs[$value['sczl_bh'.$i]]) : '';
  243. }
  244. }else{
  245. $rows[$key]['name'.$i] = '';
  246. }
  247. }
  248. $rows[$key]['jyno_gxmc'] = sprintf("%02d", $value['sczl_yjno']).'-'.sprintf("%02d", $value['sczl_gxh']).'-->'.trim($value['sczl_type']);
  249. $rows[$key]['sczl_num'] = $value['sczl_num'] == 0 ? '' : $value['sczl_num'];
  250. $rows[$key]['sczl_cl'] = $value['sczl_cl'] == 0 ? '' : floatval($value['sczl_cl']);
  251. $rows[$key]['sczl_ms'] = $value['sczl_ms'] == 0 ? 1 : floatval($value['sczl_ms']);
  252. $rows[$key]['sczl_zcfp'] = $value['sczl_zcfp'] == 0 ? '' : floatval($value['sczl_zcfp']);
  253. $rows[$key]['sczl_zccp'] = $value['sczl_zccp'] == 0 ? '' : floatval($value['sczl_zccp']);
  254. $rows[$key]['sczl_装版工时'] = $value['sczl_装版工时'] == 0 ? '' : floatval($value['sczl_装版工时']);
  255. $rows[$key]['sczl_保养工时'] = $value['sczl_保养工时'] == 0 ? '' : floatval($value['sczl_保养工时']);
  256. $rows[$key]['sczl_打样工时'] = $value['sczl_打样工时'] == 0 ? '' : floatval($value['sczl_打样工时']);
  257. $rows[$key]['sczl_异常停机工时'] = $value['sczl_异常停机工时'] == 0 ? '' : floatval($value['sczl_异常停机工时']);
  258. $rows[$key]['sczl_设备运行工时'] = $value['sczl_设备运行工时'] == 0 ? '' : floatval($value['sczl_设备运行工时']);
  259. $rows[$key]['sczl_工价系数'] = $value['sczl_工价系数'] == 0 ? '' : floatval($value['sczl_工价系数']);
  260. $rows[$key]['千件工价'] = $value['千件工价'] == 0 ? '' : floatval($value['千件工价']);
  261. $rows[$key]['sczl_来料少数'] = $value['sczl_来料少数'] == 0 ? '' : floatval($value['sczl_来料少数']);
  262. $rows[$key]['拆片联拼系数'] = $value['拆片联拼系数'] == 0 ? '' : floatval($value['拆片联拼系数']);
  263. $rows[$key]['拆片条小盒系数'] = $value['拆片条小盒系数'] == 0 ? '' : floatval($value['拆片条小盒系数']);
  264. unset($rows[$key]['sczl_yjno']);
  265. unset($rows[$key]['sczl_gxh']);
  266. unset($rows[$key]['sczl_type']);
  267. }
  268. $data = [
  269. 'total' => $total,
  270. 'rows' => $rows,
  271. ];
  272. $this->success('成功',$data);
  273. }
  274. /**
  275. * 定位
  276. * @ApiMethod (GET)
  277. * @param string $gdbh 工单编号
  278. * @param string $cpmc 产品名称
  279. * @param string $page 页码
  280. * @param string $limit 数量
  281. */
  282. public function locate()
  283. {
  284. //get请求
  285. if(!$this->request->isGet()){
  286. $this->error('请求方式错误');
  287. }
  288. $req = $this->request->param();
  289. $page = 1;
  290. $limit = 15;
  291. if (isset($req['page']) && !empty($req['page'])) $page = $req['page'];
  292. if (isset($req['limit']) && !empty($req['limit'])) $limit = $req['limit'];
  293. if (isset($req['gdbh']) && !empty($req['gdbh'])){
  294. //获取total
  295. $sql = 'SELECT sum(count) AS count FROM (
  296. SELECT COUNT(*) AS count FROM `设备_产量计酬` ';
  297. $sql .= 'WHERE `sczl_gdbh` LIKE "%'.$req['gdbh'].'%" ';
  298. $sql .= 'UNION ALL SELECT COUNT(*) AS count FROM `db_sczl`';
  299. $sql .= 'WHERE `sczl_gdbh` LIKE "%'.$req['gdbh'].'%" ';
  300. $sql .= ') as t';
  301. $total = db()->query($sql)[0]['count'];
  302. //判断缓存是否存在
  303. if (cache('MachineProductReport-getList')){
  304. if(array_key_exists($req['gdbh'].'-'.$req['page'].'-'.$req['limit'] , cache('MachineProductReport-getList'))){
  305. $rows = cache('MachineProductReport-getList')[$req['gdbh'].'-'.$req['page'].'-'.$req['limit']];
  306. }else{
  307. //a.拆片联拼系数, a.拆片条小盒系数,
  308. $sql = 'SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  309. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_zcfp, a.sczl_zccp,
  310. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  311. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  312. d.日定额, d.千件工价, d.补产标准, a.sczl_来料少数, NULL AS 拆片联拼系数, NULL AS 拆片条小盒系数,
  313. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "设备_产量计酬" AS table_type
  314. FROM `设备_产量计酬` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` ';
  315. $sql .= 'WHERE `a`.`sczl_gdbh` LIKE "%'.$req['gdbh'].'%" ';
  316. $sql .= 'UNION ALL
  317. SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  318. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_fp as sczl_zcfp, a.sczl_cp as sczl_zccp,
  319. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  320. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  321. d.日定额, d.千件工价, d.补产标准, NULL AS sczl_来料少数, a.拆片联拼系数, a.拆片条小盒系数,
  322. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "db_sczl" AS table_type
  323. FROM `db_sczl` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh`';
  324. $sql .= 'WHERE `a`.`sczl_gdbh` LIKE "%'.$req['gdbh'].'%" ';
  325. $sql .= 'ORDER BY sys_id ASC, sczl_num ASC LIMIT '.($page-1)*$limit.','.$limit;
  326. $rows = db()->query($sql);
  327. //设置缓存
  328. $cache = cache('MachineProductReport-getList');
  329. $cache[$req['gdbh'].'-'.$req['page'].'-'.$req['limit']] = $rows;
  330. cache('MachineProductReport-getList',$cache,3600);
  331. }
  332. }else{
  333. //a.拆片联拼系数, a.拆片条小盒系数,
  334. $sql = 'SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  335. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_zcfp, a.sczl_zccp,
  336. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  337. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  338. d.日定额, d.千件工价, d.补产标准, a.sczl_来料少数, NULL AS 拆片联拼系数, NULL AS 拆片条小盒系数,
  339. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "设备_产量计酬" AS table_type
  340. FROM `设备_产量计酬` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` ';
  341. $sql .= 'WHERE `a`.`sczl_gdbh` LIKE "%'.$req['gdbh'].'%" ';
  342. $sql .= 'UNION ALL
  343. SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  344. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_fp as sczl_zcfp, a.sczl_cp as sczl_zccp,
  345. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  346. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  347. d.日定额, d.千件工价, d.补产标准, NULL AS sczl_来料少数, a.拆片联拼系数, a.拆片条小盒系数,
  348. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "db_sczl" AS table_type
  349. FROM `db_sczl` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh`';
  350. $sql .= 'WHERE `a`.`sczl_gdbh` LIKE "%'.$req['gdbh'].'%" ';
  351. $sql .= 'ORDER BY sys_id ASC, sczl_num ASC LIMIT '.($page-1)*$limit.','.$limit;
  352. $rows = db()->query($sql);
  353. //设置缓存
  354. $cache = [];
  355. $cache[$req['gdbh'].'-'.$req['page'].'-'.$req['limit']] = $rows;
  356. cache('MachineProductReport-getList',$cache,3600);
  357. }
  358. }else{
  359. if (isset($req['cpmc']) && !empty($req['cpmc'])){
  360. //查询包括该名称的工单号
  361. $gd = db('工单_基本资料')
  362. ->where('Gd_cpmc', 'LIKE', '%'.$req['cpmc'].'%')
  363. ->column('Gd_gdbh');
  364. $in = "'" . implode("','", $gd) . "'";
  365. //获取total
  366. $sql = 'SELECT sum(count) AS count FROM (
  367. SELECT COUNT(*) AS count FROM `设备_产量计酬` ';
  368. $sql .= 'WHERE `sczl_gdbh` IN ('.$in.') ';
  369. $sql .= 'UNION ALL SELECT COUNT(*) AS count FROM `db_sczl`';
  370. $sql .= 'WHERE `sczl_gdbh` IN ('.$in.') ';
  371. $sql .= ') as t';
  372. $total = db()->query($sql)[0]['count'];
  373. //判断缓存是否存在
  374. if (cache('MachineProductReport-getList')){
  375. if(array_key_exists($req['cpmc'].'-'.$req['page'].'-'.$req['limit'] , cache('MachineProductReport-getList'))){
  376. $rows = cache('MachineProductReport-getList')[$req['cpmc'].'-'.$req['page'].'-'.$req['limit']];
  377. }else{
  378. $sql = 'SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  379. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_zcfp, a.sczl_zccp,
  380. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  381. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  382. d.日定额, d.千件工价, d.补产标准, a.sczl_来料少数, NULL AS 拆片联拼系数, NULL AS 拆片条小盒系数,
  383. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "设备_产量计酬" AS table_type
  384. FROM `设备_产量计酬` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` ';
  385. $sql .= 'WHERE `a`.`sczl_gdbh` IN ('.$in.') ';
  386. $sql .= 'UNION ALL
  387. SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  388. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_fp as sczl_zcfp, a.sczl_cp as sczl_zccp,
  389. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  390. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  391. d.日定额, d.千件工价, d.补产标准, NULL AS sczl_来料少数, a.拆片联拼系数, a.拆片条小盒系数,
  392. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "db_sczl" AS table_type
  393. FROM `db_sczl` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` ';
  394. $sql .= 'WHERE `a`.`sczl_gdbh` IN ('.$in.') ';
  395. $sql .= 'ORDER BY sys_id ASC, sczl_num ASC LIMIT '.($page-1)*$limit.','.$limit;
  396. $rows = db()->query($sql);
  397. //设置缓存
  398. $cache = cache('MachineProductReport-getList');
  399. $cache[$req['cpmc'].'-'.$req['page'].'-'.$req['limit']] = $rows;
  400. cache('MachineProductReport-getList',$cache,3600);
  401. }
  402. }else{
  403. $sql = 'SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  404. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_zcfp, a.sczl_zccp,
  405. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  406. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  407. d.日定额, d.千件工价, d.补产标准, a.sczl_来料少数, NULL AS 拆片联拼系数, NULL AS 拆片条小盒系数,
  408. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "设备_产量计酬" AS table_type
  409. FROM `设备_产量计酬` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` ';
  410. $sql .= 'WHERE `a`.`sczl_gdbh` IN ('.$in.') ';
  411. $sql .= 'UNION ALL
  412. SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  413. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_fp as sczl_zcfp, a.sczl_cp as sczl_zccp,
  414. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  415. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  416. d.日定额, d.千件工价, d.补产标准, NULL AS sczl_来料少数, a.拆片联拼系数, a.拆片条小盒系数,
  417. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "db_sczl" AS table_type
  418. FROM `db_sczl` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` ';
  419. $sql .= 'WHERE `a`.`sczl_gdbh` IN ('.$in.') ';
  420. $sql .= 'ORDER BY sys_id ASC, sczl_num ASC LIMIT '.($page-1)*$limit.','.$limit;
  421. $rows = db()->query($sql);
  422. //设置缓存
  423. $cache = [];
  424. $cache[$req['cpmc'].'-'.$req['page'].'-'.$req['limit']] = $rows;
  425. cache('MachineProductReport-getList',$cache,3600);
  426. }
  427. }else{
  428. $this->error('参数错误');
  429. }
  430. }
  431. $gd = db('工单_基本资料')->column('Gd_gdbh, 成品名称 as Gd_cpmc');
  432. $rs = db('人事_基本资料')->column('员工编号, 员工姓名');
  433. foreach ($rows as $key=>$value){
  434. $rows[$key]['mod_rq'] = $value['mod_rq']=='1900-01-01 00:00:00' ? '' :$value['mod_rq'];
  435. $rows[$key]['Gd_cpmc'] = array_key_exists($value['sczl_gdbh'],$gd) ? trim($gd[$value['sczl_gdbh']]) : '';
  436. $rows[$key]['name1'] = array_key_exists($value['sczl_bh1'],$rs) ? trim($rs[$value['sczl_bh1']]) : '';
  437. for ($i=2;$i<=6;$i++){
  438. if ($value['sczl_bh'.$i]){
  439. if ($value['sczl_bh'.$i]==$value['sczl_bh1']){
  440. $rows[$key]['name'.$i] = $rows[$key]['name1'];
  441. }else{
  442. $rows[$key]['name'.$i] = array_key_exists($value['sczl_bh'.$i],$rs) ? trim($rs[$value['sczl_bh'.$i]]) : '';
  443. }
  444. }else{
  445. $rows[$key]['name'.$i] = '';
  446. }
  447. }
  448. $rows[$key]['jyno_gxmc'] = sprintf("%02d", $value['sczl_yjno']).'-'.sprintf("%02d", $value['sczl_gxh']).'-->'.trim($value['sczl_type']);
  449. $rows[$key]['sczl_num'] = $value['sczl_num'] == 0 ? '' : $value['sczl_num'];
  450. $rows[$key]['sczl_cl'] = $value['sczl_cl'] == 0 ? '' : floatval($value['sczl_cl']);
  451. $rows[$key]['sczl_ms'] = $value['sczl_ms'] == 0 ? 1 : floatval($value['sczl_ms']);
  452. $rows[$key]['sczl_zcfp'] = $value['sczl_zcfp'] == 0 ? '' : floatval($value['sczl_zcfp']);
  453. $rows[$key]['sczl_zccp'] = $value['sczl_zccp'] == 0 ? '' : floatval($value['sczl_zccp']);
  454. $rows[$key]['sczl_装版工时'] = $value['sczl_装版工时'] == 0 ? '' : floatval($value['sczl_装版工时']);
  455. $rows[$key]['sczl_保养工时'] = $value['sczl_保养工时'] == 0 ? '' : floatval($value['sczl_保养工时']);
  456. $rows[$key]['sczl_打样工时'] = $value['sczl_打样工时'] == 0 ? '' : floatval($value['sczl_打样工时']);
  457. $rows[$key]['sczl_异常停机工时'] = $value['sczl_异常停机工时'] == 0 ? '' : floatval($value['sczl_异常停机工时']);
  458. $rows[$key]['sczl_设备运行工时'] = $value['sczl_设备运行工时'] == 0 ? '' : floatval($value['sczl_设备运行工时']);
  459. $rows[$key]['sczl_工价系数'] = $value['sczl_工价系数'] == 0 ? '' : floatval($value['sczl_工价系数']);
  460. $rows[$key]['千件工价'] = $value['千件工价'] == 0 ? '' : floatval($value['千件工价']);
  461. $rows[$key]['sczl_来料少数'] = $value['sczl_来料少数'] == 0 ? '' : floatval($value['sczl_来料少数']);
  462. $rows[$key]['拆片联拼系数'] = $value['拆片联拼系数'] == 0 ? '' : floatval($value['拆片联拼系数']);
  463. $rows[$key]['拆片条小盒系数'] = $value['拆片条小盒系数'] == 0 ? '' : floatval($value['拆片条小盒系数']);
  464. unset($rows[$key]['sczl_yjno']);
  465. unset($rows[$key]['sczl_gxh']);
  466. unset($rows[$key]['sczl_type']);
  467. }
  468. $data = [
  469. 'total' => $total,
  470. 'rows' => $rows,
  471. ];
  472. $this->success('成功',$data);
  473. }
  474. /**
  475. * 获取机台生产日报表信息
  476. * @ApiMethod (GET)
  477. * @param string $UniqId UniqId
  478. */
  479. public function getInfo()
  480. {
  481. //get请求
  482. if(!$this->request->isGet()){
  483. $this->error('请求方式错误');
  484. }
  485. $req = $this->request->param();
  486. if (isset($req['UniqId']) && !empty($req['UniqId'])){
  487. $UniqId = $req['UniqId'];
  488. }else{
  489. $this->error('参数错误');
  490. }
  491. $rows = db('db_sczl')->alias('a')
  492. ->field('a.sczl_gdbh, rtrim(j.成品名称) as Gd_cpmc,
  493. a.sczl_yjno, rtrim(y.yj_yjmc) as yj_yjmc,
  494. rtrim(a.sczl_gxmc) as sczl_gxmc, a.sczl_gxh, rtrim(a.sczl_type) as sczl_type,
  495. LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh, a.sczl_bzdh,
  496. a.sczl_ms, a.sczl_ls, a.sczl_cl, a.sczl_fp as sczl_zcfp,
  497. a.sczl_装版总工时, a.sczl_装版工时, a.sczl_保养工时, a.sczl_异常停机工时,
  498. a.sczl_打样总工时, a.sczl_打样工时, a.sczl_设备运行工时,
  499. a.拆片联拼系数, a.拆片条小盒系数,
  500. a.sczl_dedh, a.sczl_工价系数, a.sczl_计产系数,
  501. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5,
  502. a.sczl_bh6, a.sczl_bh7, a.sczl_bh8, a.sczl_bh9, a.sczl_bh10,
  503. a.sczl_rate1, a.sczl_rate2, a.sczl_rate3, a.sczl_rate4, a.sczl_rate5,
  504. a.sczl_rate6, a.sczl_rate7, a.sczl_rate8, a.sczl_rate9, a.sczl_rate10
  505. ')
  506. ->where('a.UniqId', $UniqId)
  507. ->where('a.sczl_yjno = y.yj_Yjno')
  508. ->join(['工单_基本资料'=>'j'],'a.sczl_gdbh = j.Gd_gdbh')
  509. ->join(['工单_印件资料'=>'y'],'a.sczl_gdbh = y.Yj_Gdbh')
  510. ->find();
  511. $rs = db('人事_基本资料')->column('员工编号, 员工姓名');
  512. for($i=1;$i<=10;$i++){
  513. if(trim($rows['sczl_bh'.$i])!=''){
  514. $rows['sczl_bh'.$i.'_name'] = array_key_exists($rows['sczl_bh'.$i],$rs) ? trim($rs[$rows['sczl_bh'.$i]]) : '';
  515. }else{
  516. $rows['sczl_bh'.$i.'_name'] = '';
  517. }
  518. }
  519. $this->success('成功',$rows);
  520. }
  521. /**
  522. * 获取工单名称
  523. * @ApiMethod (GET)
  524. * @param string $gdbh 工单编号
  525. */
  526. public function getGdmc()
  527. {
  528. //get请求
  529. if(!$this->request->isGet()){
  530. $this->error('请求方式错误');
  531. }
  532. $req = $this->request->param();
  533. if (isset($req['gdbh']) && !empty($req['gdbh'])){
  534. $gdbh = $req['gdbh'];
  535. }else{
  536. $this->error('参数错误');
  537. }
  538. $row = db('工单_基本资料')
  539. ->field('rtrim(成品名称) as Gd_cpmc')
  540. ->where('Gd_gdbh',$gdbh)
  541. ->find();
  542. $yjno= db('工单_工艺资料')
  543. ->where(['Gy0_gdbh'=>$gdbh])
  544. ->column('distinct Gy0_yjno');
  545. $row['yjno'] = $yjno;
  546. if (!$row) $this->error('查无此编号的工单, 请仔细检查后重新输入!');
  547. $this->success('成功',$row);
  548. }
  549. /**
  550. * 获取印件名称
  551. * @ApiMethod (GET)
  552. * @param string $gdbh 工单编号
  553. * @param string $yjno 印件号
  554. */
  555. public function getYjmc()
  556. {
  557. //get请求
  558. if(!$this->request->isGet()){
  559. $this->error('请求方式错误');
  560. }
  561. $req = $this->request->param();
  562. if (isset($req['gdbh']) && !empty($req['gdbh'])){
  563. $gdbh = $req['gdbh'];
  564. }else{
  565. $this->error('参数错误');
  566. }
  567. if (isset($req['yjno']) && !empty($req['yjno'])){
  568. $yjno = $req['yjno'];
  569. }else{
  570. $this->error('参数错误');
  571. }
  572. //获取印件名称
  573. $row = db('工单_印件资料')
  574. ->field('rtrim(yj_yjmc) as yj_yjmc,yj_ls as sczl_ls')
  575. ->where(['Yj_Gdbh'=>$gdbh,'yj_Yjno'=>$yjno])
  576. ->find();
  577. $gxmc = db('工单_工艺资料')
  578. ->field('Gy0_gxh as sczl_gxh, rtrim(Gy0_gxmc) as sczl_type, rtrim(Add_gxmc) as Add_gxmc, Gy0_ms as sczl_ms')
  579. ->where(['Gy0_gdbh'=>$gdbh,'Gy0_yjno'=>$yjno])
  580. ->find();
  581. if($gxmc['Add_gxmc'] != ''){
  582. $gxmc['sczl_gxmc'] = sprintf("%02d", $gxmc['sczl_gxh']).'-'.$gxmc['Add_gxmc'];
  583. }else{
  584. $gxmc['sczl_gxmc'] = sprintf("%02d", $gxmc['sczl_gxh']).'-'.$gxmc['sczl_type'];
  585. }
  586. $gxmc['sczl_ls'] = $row['sczl_ls'];
  587. unset($gxmc['Add_gxmc']);
  588. //获取拆片联拼系数
  589. $list = db('db_拆片系数')->where('ls',(int)$gxmc['sczl_ls'])->find();
  590. $gxmc['拆片联拼系数'] = $list['lpxs'];
  591. $gxmc['拆片条小盒系数'] = $list['txxs'];
  592. $row['gxmc'] = $gxmc;
  593. if (!$row) $this->error('印件编号不存在, 将恢复默认值, 请仔细确认数据准确性!');
  594. $this->success('成功',$row);
  595. }
  596. /**
  597. * 获取工序
  598. * @ApiMethod (GET)
  599. * @param string $gdbh 工单编号
  600. * @param string $yjno 印件号
  601. * @param string $keyword 关键词
  602. */
  603. public function getGx()
  604. {
  605. //get请求
  606. if(!$this->request->isGet()){
  607. $this->error('请求方式错误');
  608. }
  609. $req = $this->request->param();
  610. if (isset($req['gdbh']) && !empty($req['gdbh'])){
  611. $gdbh = $req['gdbh'];
  612. }else{
  613. $this->error('参数错误');
  614. }
  615. if (isset($req['yjno']) && !empty($req['yjno'])){
  616. $yjno = $req['yjno'];
  617. }else{
  618. $this->error('参数错误');
  619. }
  620. if (isset($req['keyword']) && !empty($req['keyword'])){
  621. $keyword = $req['keyword'];
  622. }else{
  623. $keyword = '';
  624. }
  625. $rows = db('工单_工艺资料')
  626. ->field('Gy0_gxh as sczl_gxh, rtrim(Gy0_gxmc) as sczl_type, rtrim(Add_gxmc) as Add_gxmc,Gy0_ls as sczl_ls, Gy0_ms as sczl_ms')
  627. ->where(['Gy0_gdbh'=>$gdbh,'Gy0_yjno'=>$yjno])
  628. ->where('Gy0_gxh|Gy0_gxmc|Add_gxmc','like','%'.$keyword.'%')
  629. ->select();
  630. foreach ($rows as $key=>$value) {
  631. if($value['Add_gxmc'] != ''){
  632. $rows[$key]['sczl_gxmc'] = sprintf("%02d", $value['sczl_gxh']).'-'.$value['Add_gxmc'];
  633. }else{
  634. $rows[$key]['sczl_gxmc'] = sprintf("%02d", $value['sczl_gxh']).'-'.$value['sczl_type'];
  635. }
  636. unset($rows[$key]['Add_gxmc']);
  637. }
  638. if (!$rows) $this->error('失败');
  639. $this->success('成功',$rows);
  640. }
  641. /**
  642. * 查询机台
  643. * @ApiMethod (GET)
  644. */
  645. public function getJtbh()
  646. {
  647. //get请求
  648. if(!$this->request->isGet()){
  649. $this->error('请求方式错误');
  650. }
  651. $req = $this->request->param();
  652. if (isset($req['sczl_type']) && !empty($req['sczl_type'])){
  653. $sczl_type = $req['sczl_type'];
  654. }else{
  655. $this->error('参数错误');
  656. }
  657. if (isset($req['key_word'])){
  658. $key_word = $req['key_word'];
  659. }else{
  660. $this->error('参数错误');
  661. }
  662. $rows = db('设备_基本资料')
  663. ->field('rtrim(设备编号) as jtbh, rtrim(设备名称) as 设备名称')
  664. ->where('设备编号|设备名称','like','%'.$key_word.'%')
  665. ->where('生产工序','like','%'.$sczl_type.'%')
  666. ->order('设备编号 asc')
  667. ->select();
  668. $this->success('成功',$rows);
  669. }
  670. /**
  671. * 检品机定额代号获取
  672. * @return void
  673. * @throws \think\db\exception\DataNotFoundException
  674. * @throws \think\db\exception\ModelNotFoundException
  675. * @throws \think\exception\DbException
  676. */
  677. public function JPgetDedh()
  678. {
  679. //get请求
  680. if(!$this->request->isGet()){
  681. $this->error('请求方式错误');
  682. }
  683. $req = $this->request->param();
  684. if (!isset($req['sczl_jtbh'])){
  685. $this->error('参数错误');
  686. }
  687. if(!empty($req['sczl_jtbh'])){
  688. $row = db('dic_lzde')
  689. ->field('sys_bh,Key_')
  690. ->where('适用机型',$req['sczl_jtbh'])
  691. ->find();
  692. $list = db('dic_lzde')
  693. ->field('sys_bh,rtrim(sys_mc) AS sys_mc')
  694. ->where('Parent',$row['Key_'])
  695. ->select();
  696. if (empty($list)){
  697. $this->success('成功',$row);
  698. }else{
  699. $this->success('成功',$list);
  700. }
  701. }
  702. }
  703. /**
  704. * 查询定额代号
  705. * @ApiMethod (GET)
  706. */
  707. public function getDedh()
  708. {
  709. //get请求
  710. if(!$this->request->isGet()){
  711. $this->error('请求方式错误');
  712. }
  713. $req = $this->request->param();
  714. if (!isset($req['sczl_jtbh'])){
  715. $this->error('参数错误');
  716. }
  717. if(!empty($req['sczl_jtbh'])){
  718. $row = db('dic_lzde')
  719. ->field('sys_bh,Key_,rtrim(sys_mc)')
  720. ->where('适用机型',$req['sczl_jtbh'])
  721. ->find();
  722. // $list = db('dic_lzde')
  723. // ->field('sys_bh')
  724. // ->where('Parent',$row['Key_'])
  725. // ->select();
  726. // if (empty($list)){
  727. $this->success('成功',$row);
  728. // }else{
  729. // $this->success('成功',$list);
  730. // }
  731. }
  732. $row = db('dic_lzde')
  733. ->field('Key_, sys_bh, rtrim(sys_mc) as sys_mc')
  734. ->where('sys_mc','人工作业计件定额')
  735. ->find();
  736. $rows = db('dic_lzde')
  737. ->field('Key_, sys_bh, rtrim(sys_mc) as sys_mc')
  738. ->where('Parent',$row['Key_'])
  739. ->order('sys_bh asc')
  740. ->select();
  741. foreach ($rows as $key=>$value){
  742. $bool = db('dic_lzde')
  743. ->field('Key_,sys_bh, rtrim(sys_mc) as sys_mc')
  744. ->where('Parent',$value['Key_'])
  745. ->order('sys_bh asc')
  746. ->select();
  747. if ($bool){
  748. foreach ($bool as $k=>$v){
  749. $bool1 = db('dic_lzde')
  750. ->field('sys_bh, rtrim(sys_mc) as sys_mc')
  751. ->where('Parent',$v['Key_'])
  752. ->order('sys_bh asc')
  753. ->select();
  754. if ($bool1){
  755. $bool[$k]['bh_mc'] = $bool1;
  756. }
  757. }
  758. $rows[$key]['bh_mc'] = $bool;
  759. }
  760. }
  761. $row['bh_mc'] = $rows;
  762. $this->success('成功',$row);
  763. }
  764. /**
  765. * 定额代号查询比例
  766. * @ApiMethod (GET)
  767. */
  768. public function dedhGetRate()
  769. {
  770. //get请求
  771. if(!$this->request->isGet()){
  772. $this->error('请求方式错误');
  773. }
  774. $req = $this->request->param();
  775. if (!(isset($req['dedh'])) || empty($req['dedh'])){
  776. $this->error('参数错误');
  777. }
  778. $row = db('dic_lzde')
  779. ->field('机长比例 as sczl_rate1, 副机比例 as sczl_rate2, 调墨比例 as sczl_rate3, 二手比例 as sczl_rate4, 飞达比例 as sczl_rate5,
  780. 辅助比例 as sczl_rate6, 放卷比例 as sczl_rate7, 分切1比例 as sczl_rate8, 分切2比例 as sczl_rate9, 检验比例 as sczl_rate10')
  781. ->where('sys_bh',$req['dedh'])
  782. ->find();
  783. $this->success('成功',$row);
  784. }
  785. /**
  786. * 新增
  787. * @ApiMethod (POST)
  788. * @param string
  789. */
  790. public function add()
  791. {
  792. if(!$this->request->isPost()){
  793. $this->error('请求方式错误');
  794. }
  795. $req = $this->request->param();
  796. $arr = [
  797. 'sys_id','sczl_gdbh','sczl_yjno',
  798. 'sczl_gxmc','sczl_gxh','sczl_type',
  799. 'sczl_rq','sczl_jtbh','sczl_bzdh',
  800. 'sczl_ms','sczl_ls','sczl_cl','sczl_fp',
  801. 'sczl_装版总工时','sczl_装版工时','sczl_保养工时','sczl_异常停机工时',
  802. 'sczl_打样总工时','sczl_打样工时','sczl_设备运行工时',
  803. '拆片联拼系数','拆片条小盒系数','sczl_dedh','sczl_工价系数','sczl_计产系数',
  804. 'sczl_bh1','sczl_bh2','sczl_bh3','sczl_bh4','sczl_bh5',
  805. 'sczl_bh6','sczl_bh7','sczl_bh8','sczl_bh9','sczl_bh10',
  806. 'sczl_rate1','sczl_rate2','sczl_rate3','sczl_rate4','sczl_rate5',
  807. 'sczl_rate6','sczl_rate7','sczl_rate8','sczl_rate9','sczl_rate10'
  808. ];
  809. $data = [];
  810. foreach ($arr as $key => $value){
  811. if (!(isset($req[$value]))){
  812. $this->error('参数错误',$value,$key+1);
  813. }
  814. $data[$value] = $req[$value];
  815. }
  816. $data['sys_rq'] = date('Y-m-d H:i:s');
  817. //查询UniqId
  818. $UniqId = db('db_sczl')->max('UniqId');
  819. $data['UniqId'] = $UniqId < 10000000 ? 10000000 : $UniqId + 1;
  820. //开启事务
  821. db()->startTrans();
  822. try{
  823. $sql = db('db_sczl')->fetchSql(true)->insert($data);
  824. $bool = db()->query($sql);
  825. // 提交事务
  826. db()->commit();
  827. cache('MachineProductReport-getList',null);
  828. } catch (\Exception $e) {
  829. // 回滚事务
  830. db()->rollback();
  831. $this->error($e->getMessage());
  832. }
  833. if($bool===false) $this->error('失败');
  834. $this->success('成功');
  835. }
  836. /**
  837. * 新增
  838. * @ApiMethod (POST)
  839. * @param string
  840. */
  841. public function edit()
  842. {
  843. if(!$this->request->isPost()){
  844. $this->error('请求方式错误');
  845. }
  846. $req = $this->request->param();
  847. $arr = [
  848. 'UniqId','sczl_gdbh','sczl_yjno',
  849. 'sczl_gxmc','sczl_gxh','sczl_type',
  850. 'sczl_rq','sczl_jtbh','sczl_bzdh',
  851. 'sczl_ms','sczl_ls','sczl_cl','sczl_fp',
  852. 'sczl_装版总工时','sczl_装版工时','sczl_保养工时','sczl_异常停机工时',
  853. 'sczl_打样总工时','sczl_打样工时','sczl_设备运行工时',
  854. '拆片联拼系数','拆片条小盒系数','sczl_dedh','sczl_工价系数','sczl_计产系数',
  855. 'sczl_bh1','sczl_bh2','sczl_bh3','sczl_bh4','sczl_bh5',
  856. 'sczl_bh6','sczl_bh7','sczl_bh8','sczl_bh9','sczl_bh10',
  857. 'sczl_rate1','sczl_rate2','sczl_rate3','sczl_rate4','sczl_rate5',
  858. 'sczl_rate6','sczl_rate7','sczl_rate8','sczl_rate9','sczl_rate10'
  859. ];
  860. $data = [];
  861. foreach ($arr as $key => $value){
  862. if (!(isset($req[$value]))){
  863. continue;
  864. }
  865. $data[$value] = $req[$value];
  866. }
  867. $data['mod_rq'] = date('Y-m-d H:i:s');
  868. //开启事务
  869. db()->startTrans();
  870. try{
  871. $sql = db('db_sczl')->where('UniqId',$req['UniqId'])->fetchSql(true)->update($data);
  872. $bool = db()->query($sql);
  873. // 提交事务
  874. db()->commit();
  875. cache('MachineProductReport-getList',null);
  876. } catch (\Exception $e) {
  877. // 回滚事务
  878. db()->rollback();
  879. $this->error($e->getMessage());
  880. }
  881. if($bool===false) $this->error('失败');
  882. $this->success('成功');
  883. }
  884. /**
  885. * 修改
  886. * @ApiMethod (POST)
  887. * @param string 'UniqId'
  888. */
  889. public function del()
  890. {
  891. if(!$this->request->isPost()){
  892. $this->error('请求方式错误');
  893. }
  894. $req = $this->request->param();
  895. if (!(isset($req['UniqId']) && trim($req['UniqId'])!='')){
  896. $this->error('参数错误','UniqId',100);
  897. }
  898. //开启事务
  899. db()->startTrans();
  900. try{
  901. $bool = db('db_sczl')->where('UniqId',$req['UniqId'])->delete();
  902. // 提交事务
  903. db()->commit();
  904. cache('MachineProductReport-getList',null);
  905. } catch (\Exception $e) {
  906. // 回滚事务
  907. db()->rollback();
  908. $this->error($e->getMessage());
  909. }
  910. if($bool===false) $this->error('失败');
  911. $this->success('成功');
  912. }
  913. /**
  914. * 工序汇总导出
  915. * @ApiMethod (GET)
  916. * @param string date
  917. * @param string sys_id
  918. * @param array fields
  919. */
  920. public function export(){
  921. if(!$this->request->isGet()){
  922. $this->error('请求方式错误');
  923. }
  924. $req = $this->request->param();
  925. $where = [];
  926. if (!isset($req['date']) || empty($req['date'])) $this->error('参数缺失');
  927. if (!(isset($req['fields']) && count($req['fields'])!=0)){
  928. $this->error('参数错误','fields',100);
  929. }
  930. $arr = [
  931. 'sczl_gdbh' =>['工单编号'],
  932. 'Gd_cpmc' =>['产品名称'],
  933. 'jyno_gxmc' =>['印件及工序'],
  934. 'sczl_rq' =>['生产日期'],
  935. 'sczl_jtbh' =>['机台'],
  936. 'sczl_bzdh' =>['班组'],
  937. 'sczl_num' =>['流程单'],
  938. 'sczl_cl' =>['车头产量'],
  939. 'sczl_ms' =>['色度数'],
  940. 'sczl_zcfp' =>['制程废'],
  941. 'sczl_zccp' =>['次品'],
  942. 'sczl_来料异常' =>['来料异常'],
  943. 'sczl_装版工时' =>['装版工时'],
  944. 'sczl_保养工时' =>['保养工时'],
  945. 'sczl_打样工时' =>['打样工时'],
  946. 'sczl_异常停机工时' =>['异常停机工时'],
  947. 'sczl_设备运行工时' =>['设备运行工时'],
  948. 'sczl_bh1' =>['组员编号1'],
  949. 'sczl_bh1_name' =>['组员姓名1'],
  950. 'sczl_bh2' =>['组员编号2'],
  951. 'sczl_bh2_name' =>['组员姓名2'],
  952. 'sczl_bh3' =>['组员编号3'],
  953. 'sczl_bh3_name' =>['组员姓名3'],
  954. 'sczl_bh4' =>['组员编号4'],
  955. 'sczl_bh4_name' =>['组员姓名4'],
  956. 'sczl_bh5' =>['组员编号5'],
  957. 'sczl_bh5_name' =>['组员姓名5'],
  958. 'sczl_bh6' =>['组员编号6'],
  959. 'sczl_bh6_name' =>['组员姓名6'],
  960. '拆片联拼系数' =>['拆片联拼系数'],
  961. '拆片条小盒系数' =>['拆片条小盒系数'],
  962. 'sczl_工价系数' =>['工价系数'],
  963. '日定额' =>['日定额'],
  964. '千件工价' =>['千件工价'],
  965. '补产标准' =>['补产标准'],
  966. ];
  967. $data[0] = [];
  968. foreach ($req['fields'] as $k=>$v){
  969. if(array_key_exists($v,$arr)){
  970. array_push($data[0],$arr[$v][0]);
  971. }
  972. }
  973. // UNION 查询两表数据
  974. // db_sczl缺少数据 --> a.sczl_来料少数,
  975. // 设备_产量计酬缺少数据 --> a.拆片联拼系数, a.拆片条小盒系数,
  976. $sql = 'SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  977. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_zcfp, a.sczl_zccp,
  978. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  979. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  980. d.日定额, d.千件工价, d.补产标准, a.sczl_来料少数 as sczl_来料异常, NULL AS 拆片联拼系数, NULL AS 拆片条小盒系数,
  981. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "设备_产量计酬" AS table_type
  982. FROM `设备_产量计酬` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh` ';
  983. $sql .= strpos($req['date'],'-') ? 'WHERE `a`.`sys_rq` LIKE "'.$req['date'].'%" ' : 'WHERE `a`.`sczl_gdbh` = "'.$req['date'].'" ';
  984. $sql .= isset($req['sys_id']) && !empty($req['sys_id']) ? 'AND `a`.`sys_id` LIKE "'.$req['sys_id'].'%" ' : '';
  985. $sql .= 'UNION ALL
  986. SELECT a.sczl_gdbh, a.sczl_yjno, a.sczl_gxh, a.sczl_type, LEFT(a.sczl_rq, 10) as sczl_rq, a.sczl_jtbh,
  987. a.sczl_bzdh, a.sczl_num, a.sczl_cl, a.sczl_ms, a.sczl_fp as sczl_zcfp, a.sczl_cp as sczl_zccp,
  988. a.sczl_装版工时, a.sczl_保养工时, a.sczl_打样工时, a.sczl_异常停机工时, a.sczl_设备运行工时,
  989. a.sczl_bh1, a.sczl_bh2, a.sczl_bh3, a.sczl_bh4, a.sczl_bh5, a.sczl_bh6, a.sczl_工价系数,
  990. d.日定额, d.千件工价, d.补产标准, NULL AS sczl_来料异常, a.拆片联拼系数, a.拆片条小盒系数,
  991. rtrim(a.sys_id) as sys_id, a.sys_rq, a.mod_rq, a.UniqId, "db_sczl" AS table_type
  992. FROM `db_sczl` `a` LEFT JOIN `dic_lzde` `d` ON `a`.`sczl_dedh`=`d`.`sys_bh`';
  993. $sql .= strpos($req['date'],'-') ? 'WHERE `a`.`sys_rq` LIKE "'.$req['date'].'%" ' : 'WHERE `a`.`sczl_gdbh` = "'.$req['date'].'" ';
  994. $sql .= isset($req['sys_id']) && !empty($req['sys_id']) ? 'AND `a`.`sys_id` LIKE "'.$req['sys_id'].'%" ' : '';
  995. $sql .= 'ORDER BY sys_id ASC, sczl_num ASC';
  996. $rows = db()->query($sql);
  997. $gd = db('工单_基本资料')->column('Gd_gdbh, 成品名称 as Gd_cpmc');
  998. $rs = db('人事_基本资料')->column('员工编号, 员工姓名');
  999. foreach ($rows as $key=>$value){
  1000. $subArray = [];
  1001. foreach ($arr as $k=>$v){
  1002. if($k=='sczl_来料异常' || $k=='拆片联拼系数' || $k=='拆片条小盒系数'){
  1003. $subArray[$k] = $value[$k] == null ? '' : floatval($value[$k]);
  1004. }else if($k=='Gd_cpmc'){
  1005. if(trim($value['sczl_gdbh']) != '' && array_key_exists($value['sczl_gdbh'],$gd)){
  1006. $subArray[$k] = trim($gd[$value['sczl_gdbh']]);
  1007. }else{
  1008. $subArray[$k] = '';
  1009. }
  1010. }else if($k=='sczl_bh1_name' || $k=='sczl_bh2_name' || $k=='sczl_bh3_name' || $k=='sczl_bh4_name' || $k=='sczl_bh5_name' || $k=='sczl_bh6_name'){
  1011. if(trim($value[substr($k,0,8)]) != '' && array_key_exists($value[substr($k,0,8)],$rs)){
  1012. $subArray[$k] = trim($rs[$value[substr($k,0,8)]]);
  1013. }else{
  1014. $subArray[$k] = '';
  1015. }
  1016. }else if($k=='sczl_num' || $k=='sczl_cl' || $k=='sczl_zcfp' || $k=='sczl_zccp' || $k=='sczl_装版工时' || $k=='sczl_保养工时' || $k=='sczl_打样工时' ||
  1017. $k=='sczl_异常停机工时' || $k=='sczl_设备运行工时' || $k=='拆片联拼系数' || $k=='拆片条小盒系数' || $k=='sczl_工价系数' || $k=='千件工价'){
  1018. $subArray[$k] = $value[$k] == 0 ? '' : floatval($value[$k]);
  1019. }else if($k=='sczl_ms'){
  1020. $subArray[$k] = $value[$k] == 0 ? 1 : floatval($value[$k]);
  1021. }else if($k=='jyno_gxmc'){
  1022. $subArray['jyno_gxmc'] = sprintf("%02d", $value['sczl_yjno']).'-'.sprintf("%02d", $value['sczl_gxh']).'-->'.trim($value['sczl_type']);
  1023. }else{
  1024. $subArray[$k] = $rows[$key][$k];
  1025. }
  1026. }
  1027. array_push($data,$subArray);
  1028. }
  1029. $this->success('成功',['file_name'=>$req['file_name'],'data'=>$data]);
  1030. }
  1031. }