WorkOrderVerification.php 47 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use \think\Request;
  5. use \think\Db;
  6. use \think\cache;
  7. /**
  8. * 工单核验单维护接口
  9. */
  10. class WorkOrderVerification extends Api
  11. {
  12. protected $noNeedLogin = ['*'];
  13. protected $noNeedRight = ['*'];
  14. /**
  15. * 首页
  16. *
  17. */
  18. public function index()
  19. {
  20. $this->success('请求成功');
  21. }
  22. /**
  23. * 获取工单核验单侧边栏
  24. * @ApiMethod (GET)
  25. */
  26. public function getTab()
  27. {
  28. //get请求
  29. if(!$this->request->isGet()){
  30. $this->error('请求方式错误');
  31. }
  32. if(!cache('WorkOrderVerification-getTable')){
  33. $time = date('Y-m-d',time()-8640000);
  34. $rows = db()->table('db_qczl')
  35. ->field('LEFT(sys_rq, 10) as date, COUNT(*) as counts')
  36. ->where('sys_rq','>=',$time)
  37. ->group('date')
  38. ->order('date desc')
  39. ->limit(30)
  40. ->select();
  41. $arr = db()->table('db_qczl')
  42. ->field('LEFT(sys_rq, 10) as date, rtrim(sys_id) as sys_id, COUNT(*) as count')
  43. ->where('sys_rq','>=',$rows[count($rows)-1]['date'])
  44. ->group('date, sys_id')
  45. ->select();
  46. foreach($rows as $key=>$value){
  47. $rows[$key]['sys'] = [];
  48. foreach($arr as $k=>$v){
  49. if($value['date'] == $v['date']){
  50. unset($v['date']);
  51. array_push($rows[$key]['sys'],$v);
  52. unset($arr[$k]);
  53. }
  54. }
  55. $rows[$key]['date'] = str_replace('-', '.', $rows[$key]['date']);
  56. }
  57. //设置缓存
  58. cache('WorkOrderVerification-getTable',$rows,3600);
  59. }else{
  60. $rows = cache('WorkOrderVerification-getTable');
  61. }
  62. $this->success('成功',$rows);
  63. }
  64. /**
  65. * 获取工单核验单侧边栏通过工单编号
  66. * @ApiMethod (GET)
  67. */
  68. public function getTabByGdbh()
  69. {
  70. //get请求
  71. if(!$this->request->isGet()){
  72. $this->error('请求方式错误');
  73. }
  74. $date = date('Y-m-d',strtotime("-1 year"));
  75. $rows = db()->table('db_qczl')->alias('d')
  76. ->field('d.qczl_gdbh, rtrim(y.Gd_cpmc) as Gd_cpmc')
  77. ->join('工单_基本资料 y','y.Gd_gdbh = d.qczl_gdbh','left')
  78. ->where('d.sys_rq','>=',$date)
  79. ->group('d.qczl_gdbh')
  80. ->order('d.qczl_gdbh desc')
  81. ->limit(65)
  82. ->select();
  83. $arr = db()->table('db_qczl')
  84. ->field('qczl_gdbh, rtrim(sys_id) as sys_id, COUNT(*) as count')
  85. ->where('qczl_gdbh','>=',$rows[count($rows)-1]['qczl_gdbh'])
  86. ->group('qczl_gdbh, sys_id')
  87. ->select();
  88. foreach($rows as $key=>$value){
  89. $rows[$key]['sys'] = [];
  90. foreach($arr as $k=>$v){
  91. if($value['qczl_gdbh'] == $v['qczl_gdbh']){
  92. unset($v['qczl_gdbh']);
  93. array_push($rows[$key]['sys'],$v);
  94. unset($arr[$k]);
  95. }
  96. }
  97. }
  98. $this->success('成功',$rows);
  99. }
  100. /**
  101. * 获取工单核验单列表
  102. * @ApiMethod (GET)
  103. * @param string $date 时间
  104. * @param string $sys_id 用户
  105. */
  106. public function getList()
  107. {
  108. //get请求
  109. if(!$this->request->isGet()){
  110. $this->error('请求方式错误');
  111. }
  112. $req = $this->request->param();
  113. $page = 1;
  114. $limit = 15;
  115. if (isset($req['page']) && !empty($req['page'])) $page = $req['page'];
  116. if (isset($req['limit']) && !empty($req['limit'])) $limit = $req['limit'];
  117. $where = [];
  118. if (isset($req['date']) && !empty($req['date'])){
  119. $where['sys_rq'] = ['LIKE',$req['date'].'%'];
  120. }
  121. if (isset($req['sys_id']) && !empty($req['sys_id'])) $where['sys_id'] = ['LIKE',$req['sys_id'].'%'];
  122. if (isset($req['order']) && !empty($req['order'])) $where['qczl_gdbh'] = $req['order'];
  123. if (isset($req['cpmc']) && !empty($req['cpmc'])){
  124. //查询工单表
  125. $gd = db('工单_基本资料')
  126. ->where('Gd_cpmc', 'LIKE', '%'.$req['cpmc'].'%')
  127. ->column('Gd_gdbh');
  128. $where['qczl_gdbh'] = ['in', $gd];
  129. }
  130. $rows = db()->table('db_qczl')
  131. ->field('qczl_gdbh, qczl_yjno, LEFT(qczl_rq, 10) as qczl_rq, qczl_num, rtrim(qczl_NumDesc) as qczl_NumDesc, qczl_fp,
  132. fp_lb1, fp_lb2, fp_lb3, fp_lb4, fp_lb5, fp_lb6, fp_lb7, fp_lb8, fp_lb9, fp_lb10, fp_lb11, fp_lb12, fp_lb13, fp_lb14, fp_lb15, fp_lb16, fp_lb17,
  133. fp_sl1, fp_sl2, fp_sl3, fp_sl4, fp_sl5, fp_sl6, fp_sl7, fp_sl8, fp_sl9, fp_sl10, fp_sl11, fp_sl12, fp_sl13, fp_sl14, fp_sl15, fp_sl16, fp_sl17,
  134. fp_bh1, fp_bh2, fp_bh3, fp_bh4, fp_bh5, fp_bh6, fp_bh7, fp_bh8, fp_bh9, fp_bh10, fp_bh11, fp_bh12, fp_bh13,
  135. rtrim(sys_id) as sys_id,UniqId')
  136. ->where($where)
  137. ->order('qczl_gdbh,qczl_yjno,qczl_num')
  138. ->page($page,$limit)
  139. ->select();
  140. $total = db()->table('db_qczl')->where($where)->count();
  141. $gd = db()->table('工单_基本资料')->column('Gd_gdbh, Gd_cpmc');
  142. foreach ($rows as $key=>$value){
  143. $rows[$key]['Gd_cpmc'] = array_key_exists($value['qczl_gdbh'],$gd) ? sprintf("%02d", $value['qczl_yjno']).'-'.trim($gd[$value['qczl_gdbh']]) : '';
  144. for ($i=1;$i<=17;$i++){
  145. if ($value['fp_sl'.$i]==0){
  146. $rows[$key]['sl_lb'.$i] = '';
  147. }else{
  148. $rows[$key]['sl_lb'.$i] = trim($value['fp_sl'.$i].'-->'.$value['fp_lb'.$i].'('.$value['fp_bh'.$i].')');
  149. }
  150. unset($rows[$key]['fp_sl'.$i]);
  151. unset($rows[$key]['fp_lb'.$i]);
  152. }
  153. }
  154. $data = [
  155. 'total' => $total,
  156. 'rows' => $rows,
  157. ];
  158. $this->success('成功',$data);
  159. }
  160. /**
  161. * 获取工单核验单信息
  162. * @ApiMethod (GET)
  163. * @param string $UniqId UniqId
  164. */
  165. public function getInfo()
  166. {
  167. //get请求
  168. if(!$this->request->isGet()){
  169. $this->error('请求方式错误');
  170. }
  171. $req = $this->request->param();
  172. if (isset($req['UniqId']) && !empty($req['UniqId'])){
  173. $UniqId = $req['UniqId'];
  174. }else{
  175. $this->error('参数错误');
  176. }
  177. $rows = db()->table('db_qczl')->alias('d')
  178. ->field('d.*, ')
  179. ->join('工单_基本资料 g', 'd.')
  180. ->where('d.UniqId',$UniqId)
  181. ->select();
  182. $this->success('成功',$rows);
  183. }
  184. /**
  185. * 获取单个工单核检单信息
  186. * @ApiMethod GET
  187. * @params string UniqId
  188. */
  189. public function getOneWorkOrder(){
  190. if (Request::instance()->isGet() == false){
  191. $this->error('非法请求');
  192. }
  193. $params = Request::instance()->param();
  194. if (!isset($params['UniqId']) || empty($params['UniqId'])){
  195. $this->error('参数错误');
  196. }
  197. $field = 'qczl_gdbh,qczl_Pygd,qczl_yjno,qczl_gxh,qczl_gxmc,qczl_type,qczl_rq,qczl_num,qczl_fp,
  198. qczl_NumDesc,qczl_NumDesc1,qczl_NumDesc2,qczl_NumDesc3,qczl_NumDesc4,qczl_NumDesc5,qczl_NumDesc6,qczl_NumDesc7,qczl_NumDesc8,
  199. fp_lb1,fp_lb2,fp_lb3,fp_lb4,fp_lb5,fp_lb6,fp_lb7,fp_lb8,fp_lb9,fp_lb10,fp_lb11,fp_lb12,fp_lb13,trim(fp_lb14) as fp_lb14,trim(fp_lb15) as fp_lb15,trim(fp_lb16) as fp_lb16,trim(fp_lb17) as fp_lb17,
  200. fp_sl1,fp_sl2,fp_sl3,fp_sl4,fp_sl5,fp_sl6,fp_sl7,fp_sl8,fp_sl9,fp_sl10,fp_sl11,fp_sl12,fp_sl13,fp_sl14,fp_sl15,fp_sl16,fp_sl17,
  201. fp_bh1,fp_bh2,fp_bh3,fp_bh4,fp_bh5,fp_bh6,fp_bh7,fp_bh8,fp_bh9,fp_bh10,fp_bh11,fp_bh12,fp_bh13,
  202. fp_bz1,fp_bz2,fp_bz3,fp_bz4,fp_bz5,fp_bz6,fp_bz7,fp_bz8,fp_bz9,fp_bz10,fp_bz11,fp_bz12,fp_bz13,
  203. fp_gxmc1,fp_gxmc2,fp_gxmc3,fp_gxmc4,fp_gxmc5,fp_gxmc6,fp_gxmc7,fp_gxmc8,fp_gxmc9,fp_gxmc10,fp_gxmc11,fp_gxmc12,fp_gxmc13,
  204. sys_id,rtrim(sys_rq) as sys_rq,UniqId';
  205. $list = db('db_qczl')->where('UniqId',$params['UniqId'])->field($field)->find();
  206. $list['fp_name1'] = '';
  207. if (!empty($list['fp_bh1'])){
  208. $list['fp_name1'] = db('人事_基本资料')->where('员工编号',$list['fp_bh1'])->value('rtrim(员工姓名)');
  209. }
  210. $list['fp_name2'] = '';
  211. if (!empty($list['fp_bh2'])){
  212. $list['fp_name2'] = db('人事_基本资料')->where('员工编号',$list['fp_bh2'])->value('rtrim(员工姓名)');
  213. }
  214. $list['fp_name3'] = '';
  215. if (!empty($list['fp_bh3'])){
  216. $list['fp_name3'] = db('人事_基本资料')->where('员工编号',$list['fp_bh3'])->value('rtrim(员工姓名)');
  217. }
  218. $list['fp_name4'] = '';
  219. if (!empty($list['fp_bh4'])){
  220. $list['fp_name4'] = db('人事_基本资料')->where('员工编号',$list['fp_bh4'])->value('rtrim(员工姓名)');
  221. }
  222. $list['fp_name5'] = '';
  223. if (!empty($list['fp_bh5'])){
  224. $list['fp_name5'] = db('人事_基本资料')->where('员工编号',$list['fp_bh5'])->value('rtrim(员工姓名)');
  225. }
  226. $list['fp_name6'] = '';
  227. if (!empty($list['fp_bh6'])){
  228. $list['fp_name6'] = db('人事_基本资料')->where('员工编号',$list['fp_bh6'])->value('rtrim(员工姓名)');
  229. }
  230. $list['fp_name7'] = '';
  231. if (!empty($list['fp_bh7'])){
  232. $list['fp_name7'] = db('人事_基本资料')->where('员工编号',$list['fp_bh7'])->value('rtrim(员工姓名)');
  233. }
  234. $list['fp_name8'] = '';
  235. if (!empty($list['fp_bh8'])){
  236. $list['fp_name8'] = db('人事_基本资料')->where('员工编号',$list['fp_bh8'])->value('rtrim(员工姓名)');
  237. }
  238. $list['fp_name9'] = '';
  239. if (!empty($list['fp_bh9'])){
  240. $list['fp_name9'] = db('人事_基本资料')->where('员工编号',$list['fp_bh9'])->value('rtrim(员工姓名)');
  241. }
  242. $list['fp_name10'] = '';
  243. if (!empty($list['fp_bh10'])){
  244. $list['fp_name10'] = db('人事_基本资料')->where('员工编号',$list['fp_bh10'])->value('rtrim(员工姓名)');
  245. }
  246. $list['fp_name11'] = '';
  247. if (!empty($list['fp_bh11'])){
  248. $list['fp_name11'] = db('人事_基本资料')->where('员工编号',$list['fp_bh11'])->value('rtrim(员工姓名)');
  249. }
  250. $list['fp_name12'] = '';
  251. if (!empty($list['fp_bh12'])){
  252. $list['fp_name12'] = db('人事_基本资料')->where('员工编号',$list['fp_bh12'])->value('rtrim(员工姓名)');
  253. }
  254. $list['fp_name13'] = '';
  255. if (!empty($list['fp_bh13'])){
  256. $list['fp_name13'] = db('人事_基本资料')->where('员工编号',$list['fp_bh13'])->value('rtrim(员工姓名)');
  257. }
  258. $max = db('设备_产量计酬')->where('sczl_gdbh',$list['qczl_gdbh'])->field('MAX(sczl_num) as sczl_num')->find();
  259. $list['total_liucheng'] = $max['sczl_num'];
  260. $this->success('请求成功',$list);
  261. }
  262. /**
  263. * 获取工单基本信息
  264. * @ApiMethod GET
  265. * @params string order
  266. */
  267. public function getOrderInfo(){
  268. if (Request::instance()->isGet() == false){
  269. $this->error('非法请求');
  270. }
  271. $params = Request::instance()->param();
  272. if (!isset($params['order']) || empty($params['order'])){
  273. $this->error('参数错误');
  274. }
  275. $list = db('工单_基本资料')->alias('a')
  276. ->join('工单_印件资料 b','a.Gd_gdbh = b.Yj_Gdbh','left')
  277. ->where('a.Gd_gdbh',$params['order'])
  278. // ->where('a.行号',1)
  279. ->field('a.Gd_cpmc,b.yj_Yjno,b.yj_yjmc')
  280. ->select();
  281. $this->success('请求成功',$list);
  282. }
  283. /**
  284. * 获取印件名称及工序
  285. * @ApiMethod GET
  286. * @params string order
  287. * @params string yj_no
  288. */
  289. public function getYjInfo(){
  290. if (Request::instance()->isGet() == false){
  291. $this->error('非法请求');
  292. }
  293. $params = Request::instance()->param();
  294. if (!isset($params['order']) || empty($params['order'])){
  295. $this->error('参数错误');
  296. }
  297. if (!isset($params['yj_no']) || empty($params['yj_no'])){
  298. $this->error('参数错误');
  299. }
  300. $where['Yj_Gdbh'] = $params['order'];
  301. $where['yj_Yjno'] = $params['yj_no'];
  302. $list = db('工单_印件资料')->where($where)->field('yj_yjmc')->find();
  303. $option['Gy0_gdbh'] = $params['order'];
  304. $option['Gy0_yjno'] = $params['yj_no'];
  305. $option['Gy0_gxmc|Add_gxmc'] = ['like','%'.'核检'.'%'];
  306. // $option['Gy0_site'] = '印后车间';
  307. // $option['Gy0_gxmc'] = array('not in',['包装','外发加工','废挑正','成品防护']);
  308. $gxList = db('工单_工艺资料')->where($option)->field('Gy0_gxh,rtrim(Gy0_gxmc) as Gy0_gxmc,rtrim(Add_gxmc) as Add_gxmc')->select();
  309. $max = db('设备_产量计酬')->where('sczl_gdbh',$params['order'])->where('sczl_yjno',$params['yj_no'])->field('MAX(sczl_num) as sczl_num')->value('sczl_num');
  310. $list['gx_data'] = $gxList;
  311. $list['max_num'] = $max;
  312. $this->success('请求成功',$list);
  313. }
  314. /**
  315. * 获取废品分类
  316. * @ApiMethod GET
  317. * @params string search
  318. */
  319. public function getWastInfo(){
  320. if (Request::instance()->isGet() == false){
  321. $this->error('非法请求');
  322. }
  323. $params = Request::instance()->param();
  324. $where['分类'] = '废品分类';
  325. if (!empty($params['search'])){
  326. $where['名称'] = array('like','%'.$params['search'].'%');
  327. }
  328. $data = db('erp_常用字典')->where($where)->order('次序 desc')->column('名称');
  329. // 分割字符串并合并相同项
  330. $resultArray = [];
  331. foreach ($data as $item) {
  332. $parts = explode('_', $item);
  333. // 使用第一个部分作为一级键,第二个部分作为二级键
  334. $firstKey = $parts[0];
  335. $secondKey = $parts[1];
  336. $thirdValue = $parts[2];
  337. $resultArray[$firstKey][$secondKey][] = $thirdValue;
  338. }
  339. // 对废品分类下的数组进行升序排序
  340. if (isset($resultArray['data']['废品分类'])) {
  341. foreach ($resultArray['data']['废品分类'] as &$category) {
  342. // 判断是关联数组(单凹等)还是索引数组(分切等)
  343. if (is_array($category) && !empty($category) && is_array(current($category))) {
  344. foreach ($category as &$subCategory) {
  345. ksort($subCategory);
  346. }
  347. } else {
  348. ksort($category);
  349. }
  350. }
  351. }
  352. $this->success('请求成功',$resultArray);
  353. }
  354. /**
  355. *获取工序及责任组长
  356. * @ApiMethod GET
  357. * @params string type
  358. * @params string order
  359. */
  360. public function getGxAndLeader(){
  361. if (Request::instance()->isGet() == false){
  362. $this->error('非法请求');
  363. }
  364. $params = Request::instance()->param();
  365. if (!isset($params['type']) || empty($params['type'])){
  366. $this->error('参数错误');
  367. }
  368. if (!isset($params['order']) || empty($params['order'])){
  369. $this->error('参数错误');
  370. }
  371. if (!isset($params['yjno']) || empty($params['yjno'])){
  372. $this->error('参数错误');
  373. }
  374. $type = trim($params['type']);
  375. $waste = db('erp_常用字典')->where('名称','like','%'.$type.'%')->find();
  376. if (empty($waste)){
  377. $this->error('未查询到废品分类');
  378. }
  379. $wasteType = explode('_',substr($waste['名称'],0,-1));
  380. $searchArr = explode('-',$wasteType[1]);
  381. $where['a.sczl_gdbh'] = $params['order'];
  382. $where['a.sczl_yjno'] = $params['yjno'];
  383. //模切和凹凸的废品类型相同
  384. if ($searchArr[1] === '模切凹凸'){
  385. $list = db('设备_产量计酬')->alias('a')
  386. ->join('人事_基本资料 b', 'a.sczl_bh1 = b.员工编号', 'left')
  387. ->where($where)
  388. ->where(function($query) {
  389. $query->where('a.sczl_type', 'like', '%模切%')
  390. ->whereOr('a.sczl_type', 'like', '%凹凸%');
  391. })
  392. ->field('distinct(a.sczl_gxmc),a.sczl_bzdh,a.sczl_jtbh,a.sczl_bh1,b.员工姓名 as name')
  393. ->select();
  394. }elseif ($searchArr[1] === '拆片'){
  395. $search = substr($searchArr[1],0,6);
  396. $where['a.sczl_type'] = array('like','%'.$search.'%');
  397. $list = db('db_sczl')->alias('a')
  398. ->join('人事_基本资料 b','a.sczl_bh1 = b.员工编号','left')
  399. ->where($where)
  400. ->field('distinct(a.sczl_gxmc),a.sczl_bzdh,a.sczl_jtbh,a.sczl_bh1,b.员工姓名 as name')
  401. ->select();
  402. }elseif($searchArr[1] === '检验'){
  403. $where['a.sczl_gxmc'] = ['like','%'.'检'.'%'];
  404. $list = db('设备_产量计酬')->alias('a')
  405. ->join('人事_基本资料 b','a.sczl_bh1 = b.员工编号','left')
  406. ->where($where)
  407. ->field('distinct(a.sczl_gxmc),a.sczl_bzdh,a.sczl_jtbh,a.sczl_bh1,b.员工姓名 as name')
  408. ->select();
  409. }else{
  410. $search = substr($searchArr[1],0,6);
  411. $where['a.sczl_type'] = array('like','%'.$search.'%');
  412. $list = db('设备_产量计酬')->alias('a')
  413. ->join('人事_基本资料 b','a.sczl_bh1 = b.员工编号','left')
  414. ->where($where)
  415. ->field('distinct(a.sczl_gxmc),a.sczl_bzdh,a.sczl_jtbh,a.sczl_bh1,b.员工姓名 as name')
  416. ->select();
  417. }
  418. $count = count($list);
  419. $list[$count]['sczl_gxmc'] = '99-外发加工';
  420. $list[$count]['sczl_bzdh'] = 'A班';
  421. $list[$count]['sczl_jtbh'] = '';
  422. $list[$count]['sczl_bh1'] = '000000';
  423. $list[$count]['name'] = '计时工';
  424. $this->success('请求成功',$list);
  425. }
  426. /**
  427. * 修改工单核检单
  428. * @ApiMethod POST
  429. * @params array data
  430. */
  431. public function edit(){
  432. if (Request::instance()->isPost() == false){
  433. $this->error('非法请求');
  434. }
  435. $params = Request::instance()->post();
  436. if (!isset($params['UniqId'])){
  437. $this->error('参数不能为空');
  438. }
  439. $id = $params['UniqId'];
  440. unset($params['UniqId']);
  441. $sql = db('db_qczl')->where('UniqId',$id)->fetchSql(true)->update($params);
  442. $res = Db::query($sql);
  443. if ($res !== 0){
  444. cache('WorkOrderVerification-getTable',null);
  445. $this->success('更新成功');
  446. }else{
  447. $this->error('更新失败');
  448. }
  449. }
  450. /**
  451. * 新增工单核检单
  452. * @ApiMethod POST
  453. * @params array data
  454. */
  455. public function add(){
  456. if (Request::instance()->isPost() == false){
  457. $this->error('非法请求');
  458. }
  459. $params = Request::instance()->post();
  460. $UniqId = db('db_qczl')->order('UniqId desc')->value('UniqId');
  461. if ($UniqId < 10000000){
  462. $UniqId = 10000000;
  463. }else{
  464. $UniqId = $UniqId + 1;
  465. }
  466. $params['UniqId'] = $UniqId;
  467. $params['sys_rq'] = date('Y-m-d H:i:s');
  468. $res = \db('db_qczl')->insert($params);
  469. if ($res !== false){
  470. cache('WorkOrderVerification-getTable',null);
  471. $this->success('新增成功');
  472. }else{
  473. $this->error('新增失败');
  474. }
  475. }
  476. /**
  477. * 工单核检废品分布
  478. * @ApiMethod GET
  479. * @params string order
  480. */
  481. public function wasteDistribution(){
  482. if (Request::instance()->isGet() == false){
  483. $this->error('非法请求');
  484. }
  485. $params = Request::instance()->param();
  486. if (!isset($params['order']) || empty($params['order'])){
  487. $this->error('参数错误');
  488. }
  489. if (!isset($params['yjno']) || empty($params['yjno'])){
  490. $this->error('参数错误');
  491. }
  492. $field = '
  493. rtrim(fp_lb1) as fp_lb1,rtrim(fp_lb2) as fp_lb2,rtrim(fp_lb3) as fp_lb3,rtrim(fp_lb4) as fp_lb4,rtrim(fp_lb5) as fp_lb5,rtrim(fp_lb6) as fp_lb6,rtrim(fp_lb7) as fp_lb7,
  494. rtrim(fp_lb8) as fp_lb8,rtrim(fp_lb9) as fp_lb9,rtrim(fp_lb10) as fp_lb10,rtrim(fp_lb11) as fp_lb11,rtrim(fp_lb12) as fp_lb12,rtrim(fp_lb13) as fp_lb13,
  495. fp_sl1,fp_sl2,fp_sl3,fp_sl4,fp_sl5,fp_sl6,fp_sl7,fp_sl8,fp_sl9,fp_sl10,fp_sl11,fp_sl12,fp_sl13,qczl_yjno
  496. ';
  497. // $data = db('db_qczl')->name('db_qczl')->where('qczl_gdbh',$params['order'])->field($field)->select();
  498. $data = db('db_qczl')->name('db_qczl')
  499. ->where('qczl_gdbh',$params['order'])
  500. ->where('qczl_yjno', $params['yjno'])
  501. ->field($field)->select();
  502. if (empty($data)){
  503. $this->error('暂无废品数据');
  504. }
  505. // 用于存储废品类别和对应废品数量的数组
  506. $categories = array();
  507. // 循环遍历原始数组
  508. foreach ($data as $item) {
  509. // 提取废品类别和对应废品数量
  510. foreach ($item as $key => $value) {
  511. if (strpos($key, "fp_lb") === 0) {
  512. $categoryKey = $key;
  513. $quantityKey = str_replace("fp_lb", "fp_sl", $key);
  514. $quantityValue = $item[$quantityKey];
  515. if (!isset($categories[$value])) {
  516. $categories[$value] = 0;
  517. }
  518. $categories[$value] += (int)$quantityValue;
  519. }
  520. }
  521. }
  522. ksort($categories);
  523. $wasteTotal = db('db_qczl')->where('qczl_gdbh',$params['order'])->sum('qczl_fp');
  524. if (empty($wasteTotal)){
  525. $wasteTotal = 0;
  526. }
  527. $where['a.Gd_gdbh'] = $params['order'];
  528. $where['a.行号'] = $params['yjno'];
  529. $gdInfo = db('工单_基本资料')->alias('a')
  530. ->join('工单_印件资料 b','a.Gd_gdbh = b.Yj_Gdbh','left')
  531. ->where($where)->field('a.Gd_gdbh,a.实际投料,b.yj_Yjno,b.yj_yjmc')->find();
  532. $gdInfo['yj_Yjno'] = $gdInfo['yj_Yjno'] > 10 ? $gdInfo['yj_Yjno']:'0'.$gdInfo['yj_Yjno'];
  533. $gdInfo['实际投料'] = (int)($gdInfo['实际投料'] * 10000);
  534. $gdInfo['wasteTotal'] = $wasteTotal;
  535. $finishNum = db('成品入仓')->where('jjcp_gdbh',$params['order'])->sum('jjcp_sl');
  536. $gdInfo['passRate'] = '';
  537. if (!empty($finishNum)){
  538. $gdInfo['passRate'] = number_format((int)$finishNum/$gdInfo['实际投料']*100,2).'%';
  539. }
  540. //左侧废品数据
  541. $wasteData = array();
  542. $i = 0;
  543. foreach ($categories as $key=>$value){
  544. if ($value != 0){
  545. $wasteData[$i]['type'] = $key;
  546. $wasteData[$i]['num'] = $value;
  547. $wasteData[$i]['lossesRate'] = number_format($value/$gdInfo['实际投料']*100,4).'%';
  548. $wasteData[$i]['wasteRate'] = number_format($value/$wasteTotal*100,2).'%';
  549. $i++;
  550. }
  551. }
  552. // 按首字母相同的键将值相加
  553. $newArray = array();
  554. foreach ($categories as $key => $value) {
  555. $firstLetter = strtoupper(substr($key, 0, 1)); // 获取首字母并转换为大写
  556. if (!isset($newArray[$firstLetter])) {
  557. $newArray[$firstLetter] = 0;
  558. }
  559. $newArray[$firstLetter] += $value;
  560. }
  561. // 去掉值为零的项
  562. $newArray = array_filter($newArray, function($value) {
  563. return $value !== 0;
  564. });
  565. //右侧废品数据
  566. $rightData = array();
  567. $i = 0;
  568. $name = array();
  569. foreach ($newArray as $key=>$value){
  570. $item = db('erp_常用字典')->where('名称','like','%'.$key.'%')->value('名称');
  571. $item = explode('_',substr($item,0,-1));
  572. $rightData[$i]['type'] = $item[1];
  573. $rightData[$i]['rate'] = number_format($value/$wasteTotal*100,0).'%';
  574. $name[$i] = $item[1];
  575. $i++;
  576. }
  577. $gdInfo['wasteData'] = $wasteData;
  578. $gdInfo['rightData'] = $rightData;
  579. $gdInfo['rightTitle'] = $name;
  580. $this->success('请求成功',$gdInfo);
  581. }
  582. /**
  583. * 获取工单工序状态
  584. * @ApiMethod GET
  585. * @params string order
  586. * 计划产量计算方式:上个工序计划产量-(基础损耗+损耗率*上个工序计划产量)*损耗系数*计损色数)
  587. * lastNum - (Gy0_Rate0 + Gy0_Rate1 * lastNum )* 损耗系数(Gy0_Rate3) * Gy0_Ms
  588. */
  589. public function getOrderDate(){
  590. if (Request::instance()->isGet() == false){
  591. $this->error('非法请求');
  592. }
  593. $params = Request::instance()->param();
  594. if (!isset($params['order']) || empty($params['order'])){
  595. $this->error('参数错误');
  596. }
  597. $where['a.Gy0_gdbh'] = $params['order'];
  598. $where['a.Gy0_sbbh'] = array('neq',' ');
  599. $productNum = db('工单_基本资料')->where('Gd_gdbh',$params['order'])->value('计划投料');
  600. $gyData = db('工单_工艺资料')->alias('a')
  601. ->join('设备_产量计酬 b','a.Gy0_gdbh = b.sczl_gdbh and a.Gy0_gxh = b.sczl_gxh','left')
  602. ->where($where)
  603. ->field('a.Gy0_yjno,a.Gy0_gxh,rtrim(a.Gy0_gxmc) as Gy0_gxmc,a.Gy0_sbbh,a.Gy0_Rate0,a.Gy0_Rate1,a.损耗系数 as Gy0_Rate3,a.Gy0_Ms,a.Gy0_SITE,a.Gy0_计划接货数,a.PD_WG,
  604. a.UniqId,sum(b.sczl_cl) as cl')
  605. ->group('a.Gy0_gxh')
  606. ->select();
  607. $lastNum = $productNum;
  608. $res = [];
  609. foreach ($gyData as $key=> $process) {
  610. $res[$key]['UniqId'] = $process['UniqId'];
  611. $res[$key]['Gy0_yjno'] = $process['Gy0_yjno'] > 10 ? $process['Gy0_yjno'] : '0'.$process['Gy0_yjno'];
  612. $res[$key]['Gy0_gxh'] = $process['Gy0_gxh'] > 10 ? $process['Gy0_gxh'] : '0'.$process['Gy0_gxh'];
  613. $res[$key]['Gy0_gxmc'] = $process['Gy0_gxmc'];
  614. $res[$key]['Gy0_sbbh'] = rtrim($process['Gy0_sbbh']);
  615. $res[$key]['PD_WG'] = $process['PD_WG'];
  616. $res[$key]['finish'] = empty($process['cl']) ? 0: (int)$process['cl'];
  617. // 计算工序计划产量
  618. if ($process["Gy0_gxh"] == "1") {
  619. // 第一道工序直接使用初始计划产量
  620. $Num = $lastNum;
  621. } else {
  622. $Gy0_Ms = $gyData[$key-1]['Gy0_Ms'];
  623. $Gy0_Rate0 = $gyData[$key-1]['Gy0_Rate0'];
  624. $Gy0_Rate1 = $gyData[$key-1]['Gy0_Rate1'];
  625. $Gy0_Rate3 = $gyData[$key-1]['Gy0_Rate3'];
  626. // 大于第一道工序,使用上一道工序的计划产量
  627. // 根据公式计算工序计划产量
  628. if ($Gy0_Ms != "0.00") {
  629. $Num = $lastNum - ($Gy0_Rate0 + $Gy0_Rate1 * $lastNum) * $Gy0_Rate3 * $Gy0_Ms;
  630. } else {
  631. $Num = $lastNum - ($Gy0_Rate0 + $Gy0_Rate1 * $lastNum) * $Gy0_Rate3;
  632. }
  633. }
  634. if (trim($process['Gy0_SITE']) == '检验车间'){
  635. $res[$key]['plan'] = (int)$process['Gy0_计划接货数'];
  636. }else{
  637. $res[$key]['plan'] = (int)round($Num);
  638. }
  639. $finish_rate = $res[$key]['finish']/$res[$key]['plan'];
  640. $res[$key]['finish_rate'] = '';
  641. if ($finish_rate != 0){
  642. $res[$key]['finish_rate'] = number_format($finish_rate*100,2).'%';
  643. }
  644. // 更新 $lastNum 为当前工序的计划产量
  645. $lastNum = $Num;
  646. }
  647. $this->success('请求成功',$res);
  648. }
  649. /**
  650. * 工单工序状态更正
  651. * @ApiMethod POST
  652. * @params string UniqId
  653. * @params string date
  654. */
  655. public function editOrderFinishDate(){
  656. if (Request::instance()->isPost() == false){
  657. $this->error('非法请求');
  658. }
  659. $params = Request::instance()->post();
  660. if (!isset($params['UniqId']) || !isset($params['date'])){
  661. $this->error('参数错误');
  662. }
  663. if (empty($params['UniqId'])){
  664. $this->error('参数不能为空');
  665. }
  666. if (empty($params['date'])){
  667. $params['date'] = '1900-01-01 00:00:00';
  668. }
  669. $res = db('工单_工艺资料')->where('UniqId',$params['UniqId'])->setField('PD_WG',$params['date']);
  670. if ($res != false){
  671. $this->success('更新成功');
  672. }else{
  673. $this->error('更新失败');
  674. }
  675. }
  676. /**
  677. * 工单工序生产进程菜单栏
  678. * @ApiMethod GET
  679. * @params string order
  680. */
  681. public function getOrderProcessLeft(){
  682. if (Request::instance()->isGet() == false){
  683. $this->error('非法请求');
  684. }
  685. $params = Request::instance()->param();
  686. if (!isset($params['order']) || empty($params['order'])){
  687. $this->error('参数错误');
  688. }
  689. if (!isset($params['yjno']) || empty($params['yjno'])){
  690. $this->error('参数错误');
  691. }
  692. $where['Gd_gdbh'] = $params['order'];
  693. // $where['行号'] = 1;
  694. //工单基本资料
  695. $info = db('工单_基本资料')->where($where)->field('rtrim(成品代号) as code,rtrim(成品名称) as name')->find();
  696. //工艺资料
  697. $option['Gy0_gdbh'] = $params['order'];
  698. $option['Gy0_yjno'] = $params['yjno'];
  699. $gyInfo = db('工单_工艺资料')
  700. ->where($option)
  701. ->where(function ($query) {
  702. $query->where('Gy0_sbbh', '<>', '')
  703. ->whereOr('Gy0_gxmc', '核检')
  704. ->whereOr('Gy0_gxmc', '抽检')
  705. ->whereOr('Gy0_gxmc', '成品防护');
  706. })
  707. ->field('Gy0_yjno,Gy0_gxh,rtrim(Gy0_gxmc) as Gy0_gxmc')
  708. ->select();
  709. foreach ($gyInfo as $key=>$value){
  710. $gyInfo[$key]['Gy0_yjno'] = $value['Gy0_yjno'] > 10 ? $value['Gy0_yjno'] : '0'.$value['Gy0_yjno'];
  711. $gyInfo[$key]['Gy0_gxh'] = $value['Gy0_gxh'] > 10 ? $value['Gy0_gxh'] : '0'.$value['Gy0_gxh'];
  712. }
  713. $res['Gd_info'] = $info;
  714. $res['Gy_info'] = $gyInfo;
  715. $this->success('请求成功',$res);
  716. }
  717. /**
  718. * 工单工序生产进程右侧
  719. * @ApiMethod GET
  720. * @params string order
  721. * @params string gxNo
  722. */
  723. public function getOrderProcessRight(){
  724. if (Request::instance()->isGet() == false){
  725. $this->error('非法请求');
  726. }
  727. $params = Request::instance()->param();
  728. if (!isset($params['order']) || empty($params['order'])){
  729. $this->error('参数错误');
  730. }
  731. if (!isset($params['yjno']) || empty($params['yjno'])){
  732. $this->error('参数错误');
  733. }
  734. if (!isset($params['gxNo']) || empty($params['gxNo'])){
  735. $this->error('参数错误');
  736. }
  737. $total = db('设备_产量计酬')->where('sczl_gdbh',$params['order'])->where('sczl_yjno',$params['yjno'])->order('sczl_num')->column('distinct(sczl_num)');
  738. $where['sczl_gxh'] = (int)$params['gxNo'];
  739. $where['sczl_gdbh'] = $params['order'];
  740. $where['sczl_yjno'] = $params['yjno'];
  741. //机器设备数据
  742. $process = db('设备_产量计酬')->where($where)->order('sczl_num')->column('distinct(sczl_num)');
  743. //手工数据
  744. $option['qczl_gdbh'] = $params['order'];
  745. $option['qczl_gxh'] = (int)$params['gxNo'];
  746. $option['qczl_yjno'] = $params['yjno'];
  747. $handProcess = db('db_qczl')->where($option)->field('qczl_num,qczl_NumDesc1,qczl_NumDesc2,qczl_NumDesc3,qczl_NumDesc4,qczl_NumDesc5,qczl_NumDesc6,qczl_NumDesc7,qczl_NumDesc8')->select();
  748. // 提取数据
  749. $result = array();
  750. foreach ($handProcess as $subArray) {
  751. $qczl_num = $subArray["qczl_num"];
  752. $result[] = $qczl_num;
  753. // 提取以qczl_NumDesc开头的键对应的值
  754. for ($i = 1; $i <= 8; $i++) {
  755. $key = "qczl_NumDesc" . $i;
  756. if ($subArray[$key] != 0){
  757. $result[] = $subArray[$key];
  758. }
  759. }
  760. }
  761. // 去重
  762. $result = array_unique($result);
  763. // 对结果进行排序
  764. sort($result);
  765. $res['total_process'] = $total;
  766. $res['process'] = $process;
  767. if (empty($process)){
  768. $res['process'] = $result;
  769. }
  770. $this->success('请求成功',$res);
  771. }
  772. /**
  773. * 核检废品日统计
  774. * @ApiMethod GET
  775. * @params date start_date
  776. * @params date end_date
  777. */
  778. public function getDaysWast()
  779. {
  780. if (Request::instance()->isGet() == false) {
  781. $this->error('非法请求');
  782. }
  783. $params = Request::instance()->param();
  784. if (!isset($params['start_date']) || empty($params['start_date'])) {
  785. $this->error('参数错误');
  786. }
  787. if (!isset($params['end_date']) || empty($params['end_date'])) {
  788. $this->error('参数错误');
  789. }
  790. $where['qczl_rq'] = array('between time', [$params['start_date'], $params['end_date']]);
  791. $field = '
  792. rtrim(fp_lb1) as fp_lb1,rtrim(fp_lb2) as fp_lb2,rtrim(fp_lb3) as fp_lb3,rtrim(fp_lb4) as fp_lb4,rtrim(fp_lb5) as fp_lb5,rtrim(fp_lb6) as fp_lb6,rtrim(fp_lb7) as fp_lb7,
  793. rtrim(fp_lb8) as fp_lb8,rtrim(fp_lb9) as fp_lb9,rtrim(fp_lb10) as fp_lb10,rtrim(fp_lb11) as fp_lb11,rtrim(fp_lb12) as fp_lb12,rtrim(fp_lb13) as fp_lb13,
  794. fp_sl1,fp_sl2,fp_sl3,fp_sl4,fp_sl5,fp_sl6,fp_sl7,fp_sl8,fp_sl9,fp_sl10,fp_sl11,fp_sl12,fp_sl13,
  795. fp_bh1,fp_bh2,fp_bh3,fp_bh4,fp_bh5,fp_bh6,fp_bh7,fp_bh8,fp_bh9,fp_bh10,fp_bh11,fp_bh12,fp_bh13,
  796. rtrim(fp_bz1) as fp_bz1, rtrim(fp_bz2) as fp_bz2, rtrim(fp_bz3) as fp_bz3, rtrim(fp_bz4) as fp_bz4, rtrim(fp_bz5) as fp_bz5, rtrim(fp_bz6) as fp_bz6, rtrim(fp_bz7) as fp_bz7,
  797. rtrim(fp_bz8) as fp_bz8, rtrim(fp_bz9) as fp_bz9, rtrim(fp_bz10) as fp_bz10, rtrim(fp_bz11) as fp_bz11, rtrim(fp_bz12) as fp_bz12, rtrim(fp_bz13) as fp_bz13,
  798. qczl_rq
  799. ';
  800. $resultArray = array();
  801. $key = 'getDaysWast'.$params['start_date'].'/'.$params['end_date'];
  802. $is_have_cache = Cache::has($key);
  803. if ($is_have_cache === false){
  804. $data = db('db_qczl')
  805. ->where($where)
  806. ->where(function ($query) {
  807. for ($i = 1; $i <= 13; $i++) {
  808. $query->whereOr("fp_lb$i", 'like', '%K%','AND',"fp_sl$i",'>',0);
  809. }
  810. })
  811. ->field($field)->select();
  812. $list = [];
  813. $j = 0;
  814. foreach ($data as $entry) {
  815. for ($i = 1; $i <= 13; $i++) {
  816. $labelKey = "fp_lb" . $i;
  817. $slKey = "fp_sl" . $i;
  818. $bhKey = "fp_bh" . $i;
  819. $bzKey = "fp_bz" . $i;
  820. if (!empty($entry[$labelKey])) {
  821. if ((substr($entry[$labelKey],0,3) == 'K02' || substr($entry[$labelKey],0,3) == 'K01') && $entry[$slKey] != '0'){
  822. $list[$j]['fp_lb'] = $entry[$labelKey];
  823. $list[$j]['fp_sl'] = $entry[$slKey];
  824. $list[$j]['fp_bh'] = $entry[$bhKey];
  825. $name = db('人事_基本资料')->where('员工编号',$entry[$bhKey])->value('rtrim(员工姓名)');
  826. $list[$j]['fp_name'] = empty($name) ? '计时工' : $name;
  827. $list[$j]['fp_bz'] = $entry[$bzKey];
  828. $list[$j]['qczl_rq'] = $entry['qczl_rq'];
  829. $j++;
  830. }
  831. }
  832. }
  833. }
  834. foreach ($list as $item) {
  835. $found = false;
  836. foreach ($resultArray as &$resultItem) {
  837. if ($item["fp_lb"] === $resultItem["fp_lb"] && $item["fp_bh"] === $resultItem["fp_bh"]) {
  838. $resultItem["fp_sl"] += (int)$item["fp_sl"];
  839. $found = true;
  840. break;
  841. }
  842. }
  843. if (!$found) {
  844. $resultArray[] = $item;
  845. }
  846. }
  847. // 使用usort进行排序
  848. usort($resultArray, function($a, $b) {
  849. // First, sort by fp_lb (K01/K02)
  850. $compareLb = strcmp($a['fp_lb'], $b['fp_lb']);
  851. if ($compareLb !== 0) {
  852. return $compareLb;
  853. }
  854. // If fp_lb is the same, prioritize B班 over A班
  855. $compareBz = strcmp($a['fp_bz'], $b['fp_bz']);
  856. if ($compareBz !== 0) {
  857. return (trim($a['fp_bz']) === 'B班') ? -1 : 1;
  858. }
  859. // If fp_bz is the same, sort by fp_bh
  860. $compareBh = strcmp($a['fp_bh'], $b['fp_bh']);
  861. return $compareBh;
  862. });
  863. Cache::set($key,$resultArray,86400);
  864. }else{
  865. $resultArray = Cache::get($key);
  866. }
  867. $this->success('请求成功',$resultArray);
  868. }
  869. /**
  870. * 月度核检废品责任人统计
  871. * @ApiMethod GET
  872. * @params string date
  873. */
  874. public function getMonthPeopleTotal(){
  875. if (Request::instance()->isGet() == false) {
  876. $this->error('非法请求');
  877. }
  878. $params = Request::instance()->param();
  879. if (!isset($params['date']) || empty($params['date'])) {
  880. $this->error('参数错误');
  881. }
  882. }
  883. /**
  884. * 工单质检废品统计
  885. * @ApiMethod GET
  886. * @params string order
  887. */
  888. public function getOrderWasteTotal(){
  889. if (Request::instance()->isGet() == false) {
  890. $this->error('非法请求');
  891. }
  892. $params = Request::instance()->param();
  893. if (!isset($params['order']) || empty($params['order'])) {
  894. $this->error('参数错误');
  895. }
  896. $field = '
  897. rtrim(a.fp_lb1) as fp_lb1,rtrim(a.fp_lb2) as fp_lb2,rtrim(a.fp_lb3) as fp_lb3,rtrim(a.fp_lb4) as fp_lb4,rtrim(a.fp_lb5) as fp_lb5,rtrim(a.fp_lb6) as fp_lb6,rtrim(a.fp_lb7) as fp_lb7,
  898. rtrim(a.fp_lb8) as fp_lb8,rtrim(a.fp_lb9) as fp_lb9,rtrim(a.fp_lb10) as fp_lb10,rtrim(a.fp_lb11) as fp_lb11,rtrim(a.fp_lb12) as fp_lb12,rtrim(a.fp_lb13) as fp_lb13,
  899. a.fp_sl1,a.fp_sl2,a.fp_sl3,a.fp_sl4,a.fp_sl5,a.fp_sl6,a.fp_sl7,a.fp_sl8,a.fp_sl9,a.fp_sl10,a.fp_sl11,a.fp_sl12,a.fp_sl13,
  900. a.fp_bh1,a.fp_bh2,a.fp_bh3,a.fp_bh4,a.fp_bh5,a.fp_bh6,a.fp_bh7,a.fp_bh8,a.fp_bh9,a.fp_bh10,a.fp_bh11,a.fp_bh12,a.fp_bh13,
  901. rtrim(a.fp_gxmc1) as fp_gxmc1, rtrim(a.fp_gxmc2) as fp_gxmc2, rtrim(a.fp_gxmc3) as fp_gxmc3, rtrim(a.fp_gxmc4) as fp_gxmc4, rtrim(a.fp_gxmc5) as fp_gxmc5, rtrim(a.fp_gxmc6) as fp_gxmc6,
  902. rtrim(a.fp_gxmc7) as fp_gxmc7,rtrim(a.fp_gxmc8) as fp_gxmc8, rtrim(a.fp_gxmc9) as fp_gxmc9, rtrim(a.fp_gxmc10) as fp_gxmc10, rtrim(a.fp_gxmc11) as fp_gxmc11, rtrim(a.fp_gxmc12) as fp_gxmc12,
  903. rtrim(a.fp_gxmc13) as fp_gxmc13,a.qczl_num,a.qczl_yjno,rtrim(b.成品代号) as product_code,rtrim(b.成品名称) as product_name,b.订单数量,rtrim(b.计量单位) as 计量单位,b.实际投料,b.交货日期,
  904. c.yj_ls,d.jjcp_sl,d.jjcp_sj
  905. ';
  906. $where['a.qczl_gdbh'] = $params['order'];
  907. $where['a.qczl_yjno'] = $params['yjno'];
  908. $data = db('db_qczl')->alias('a')
  909. ->join('工单_基本资料 b','a.qczl_gdbh = b.Gd_gdbh AND a.qczl_yjno = b.行号','left')
  910. ->join('工单_印件资料 c','a.qczl_gdbh = c.Yj_Gdbh AND a.qczl_yjno = c.yj_Yjno','left')
  911. ->join('成品入仓 d','a.qczl_gdbh = d.jjcp_gdbh AND a.qczl_yjno = d.jjcp_yjno','left')
  912. ->where($where)
  913. ->field($field)
  914. ->group('a.qczl_yjno,a.sys_rq')
  915. ->select();
  916. $list = [];
  917. $j = 0;
  918. foreach ($data as $entry) {
  919. for ($i = 1; $i <= 13; $i++) {
  920. $labelKey = "fp_lb" . $i;
  921. $slKey = "fp_sl" . $i;
  922. $bhKey = "fp_bh" . $i;
  923. $gxhKey = "fp_gxmc". $i;
  924. if (!empty($entry[$labelKey]) && $entry[$slKey] > 0) {
  925. $list[$j]['fp_lb'] = $entry[$labelKey];
  926. $list[$j]['fp_sl'] = $entry[$slKey];
  927. $list[$j]['fp_bh'] = $entry[$bhKey];
  928. $name = db('人事_基本资料')->where('员工编号',$entry[$bhKey])->value('rtrim(员工姓名)');
  929. $list[$j]['fp_name'] = $name;
  930. $list[$j]['fp_gxh'] = empty(substr($entry[$gxhKey],0,2)) ? "0" : substr($entry[$gxhKey],0,2);
  931. $list[$j]['qczl_num'] = $entry['qczl_num'];
  932. $list[$j]['qczl_yjno'] = $entry['qczl_yjno'];
  933. $list[$j]['product_code'] = $entry['product_code'];
  934. $list[$j]['product_name'] = $entry['product_name'];
  935. $list[$j]['订单数量'] = $entry['订单数量'];
  936. $list[$j]['计量单位'] = $entry['计量单位'];
  937. $list[$j]['交货日期'] = substr($entry['交货日期'],0,10);
  938. $list[$j]['yj_ls'] = $entry['yj_ls'];
  939. $list[$j]['jjcp_sl'] = $entry['jjcp_sl'];
  940. $list[$j]['jjcp_sj'] = substr($entry['jjcp_sj'],0,10);
  941. $j++;
  942. }
  943. }
  944. }
  945. $summedData = [];
  946. foreach ($list as $item) {
  947. $key = $item['qczl_num'] . $item['fp_lb'];
  948. if (!isset($summedData[$key])) {
  949. $summedData[$key] = $item;
  950. } else {
  951. $summedData[$key]['fp_sl'] += $item['fp_sl'];
  952. }
  953. }
  954. $fpGxhColumn = array_column($summedData, 'fp_gxh');
  955. $qczlNumColumn = array_column($summedData, 'qczl_num');
  956. $fpLbColumn = array_column($summedData, 'fp_lb');
  957. array_multisort($fpGxhColumn, SORT_ASC, $qczlNumColumn, SORT_ASC, $fpLbColumn, SORT_ASC, $summedData);
  958. $summedData = array_values($summedData);
  959. $summedData = mb_convert_encoding($summedData,'UTF-8','auto');
  960. $this->success('请求成功',$summedData);
  961. }
  962. /**
  963. * 工单核检单删除
  964. * @return void
  965. * @throws \think\Exception
  966. * @throws \think\exception\PDOException
  967. */
  968. public function del()
  969. {
  970. if ($this->request->isGet() === false){
  971. $this->error('请求错误');
  972. }
  973. $param = $this->request->param();
  974. if (empty($param['UniqId'])){
  975. $this->error('参数错误');
  976. }
  977. $res = \db('db_qczl')
  978. ->where('UniqId',$param['UniqId'])
  979. ->delete();
  980. if ($res !== false){
  981. $this->success('删除成功');
  982. }else{
  983. $this->error('产出失败');
  984. }
  985. }
  986. public function getJunkdata()
  987. {
  988. if ($this->request->isGet() === false){
  989. $this->error('请求错误');
  990. }
  991. $param = $this->request->param();
  992. if (empty($param)){
  993. $this->error('参数错误');
  994. }
  995. $sql = "SELECT
  996. a.jjcp_gdbh,
  997. a.jjcp_yjno,
  998. a.jjcp_sj,
  999. a.jjcp_sl,
  1000. a.成品名称,
  1001. b.fp_lb1,
  1002. b.fp_lb2,
  1003. b.fp_lb3,
  1004. b.fp_lb4,
  1005. b.fp_lb5,
  1006. b.fp_lb6,
  1007. b.fp_lb7,
  1008. b.fp_lb8,
  1009. b.fp_lb9,
  1010. b.fp_lb10,
  1011. b.fp_lb11,
  1012. b.fp_lb12,
  1013. b.fp_lb13,
  1014. b.fp_gxmc1,
  1015. b.fp_gxmc2,
  1016. b.fp_gxmc3,
  1017. b.fp_gxmc4,
  1018. b.fp_gxmc5,
  1019. b.fp_gxmc6,
  1020. b.fp_gxmc7,
  1021. b.fp_gxmc8,
  1022. b.fp_gxmc9,
  1023. b.fp_gxmc10,
  1024. b.fp_gxmc11,
  1025. b.fp_gxmc12,
  1026. b.fp_gxmc13,
  1027. b.fp_sl1,
  1028. b.fp_sl2,
  1029. b.fp_sl3,
  1030. b.fp_sl4,
  1031. b.fp_sl5,
  1032. b.fp_sl6,
  1033. b.fp_sl7,
  1034. b.fp_sl8,
  1035. b.fp_sl9,
  1036. b.fp_sl10,
  1037. b.fp_sl11,
  1038. b.fp_sl12,
  1039. b.fp_sl13,
  1040. sum(b.qczl_fp) as fp,
  1041. b.UniqId,
  1042. c.实际投料 * 10000
  1043. FROM
  1044. `成品入仓` `a`
  1045. LEFT JOIN db_qczl b ON a.jjcp_gdbh = b.qczl_gdbh AND a.jjcp_yjno = b.qczl_yjno
  1046. JOIN `工单_基本资料` c ON a.jjcp_gdbh = c.Gd_gdbh AND a.jjcp_yjno = c.`行号`
  1047. WHERE
  1048. (a.jjcp_sj LIKE '2024-07%'
  1049. OR a.jjcp_sj LIKE '2024-08%')
  1050. AND (b.qczl_fp <> null or b.qczl_fp > 0)
  1051. AND a.成品编码 like 'J0031%'
  1052. GROUP BY
  1053. b.UniqId";
  1054. $res = \db()->query($sql);
  1055. // halt($res);
  1056. $data = [];
  1057. foreach ($res as $key=>$value){
  1058. if (isset($data[$value['jjcp_gdbh']]) === false){
  1059. if (isset($data[$value['jjcp_gdbh']][$value['jjcp_yjno']]) === false){
  1060. $data[$value['jjcp_gdbh']][$value['jjcp_yjno']] = [];
  1061. }
  1062. }
  1063. if (isset($data[$value['jjcp_gdbh']][$value['jjcp_yjno']]['废品总数']) === false){
  1064. $data[$value['jjcp_gdbh']][$value['jjcp_yjno']]['废品总数'] = $value['fp'];
  1065. }else{
  1066. $data[$value['jjcp_gdbh']][$value['jjcp_yjno']]['废品总数'] += $value['fp'];
  1067. }
  1068. $data[$value['jjcp_gdbh']][$value['jjcp_yjno']]['实际投料'] = $value['c.实际投料 * 10000'];
  1069. for ($i=1;$i<14;$i++){
  1070. if ($value['fp_gxmc'.$i] !== ''){
  1071. if (isset($data[$value['jjcp_gdbh']][$value['jjcp_yjno']][$value['fp_lb'.$i]]) === false){
  1072. $data[$value['jjcp_gdbh']][$value['jjcp_yjno']][$value['fp_lb'.$i]] = $value['fp_sl'.$i];
  1073. }else{
  1074. $data[$value['jjcp_gdbh']][$value['jjcp_yjno']][$value['fp_lb'.$i]] += $value['fp_sl'.$i];
  1075. }
  1076. }
  1077. }
  1078. }
  1079. $list = [];
  1080. foreach ($data as $key=>$value){
  1081. foreach ($value as $k=>$v){
  1082. $i = 0;
  1083. foreach ($v as $kk=>$vv){
  1084. if ($kk !== '废品总数' && $kk !== '实际投料'){
  1085. $list[$key][$k][$i] = [
  1086. '类型' => $kk,
  1087. '数量' => $vv,
  1088. '废品占比' => number_format($vv/$v['废品总数']*100,4).'%',
  1089. '报损占比' => number_format($vv/$v['实际投料']*100,4).'%',
  1090. ];
  1091. $i++;
  1092. $result = [
  1093. '类型' => $kk,
  1094. '数量' => $vv,
  1095. '废品占比' => number_format($vv/$v['废品总数']*100,4).'%',
  1096. '报损占比' => number_format($vv/$v['实际投料']*100,4).'%',
  1097. '工单编号' => $key,
  1098. '印件号' => $k
  1099. ];
  1100. $sql = \db('废品报表')->fetchSql(true)->insert($result);
  1101. $reult = \db()->query($sql);
  1102. }
  1103. }
  1104. }
  1105. }
  1106. // $this->success('成功',$list);
  1107. }
  1108. }