OrderSuperLoss.php 50 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use think\Cache;
  5. use \think\Request;
  6. use \think\Db;
  7. /**
  8. * 工单超节损核算接口
  9. */
  10. class OrderSuperLoss 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. if (Request::instance()->isGet() == false) {
  29. $this->error('非法请求');
  30. }
  31. $num = config('product_code_digit');
  32. $sql = "SELECT LEFT(a.jjcp_sj, 7) AS date,RTRIM(b.`编号`) AS 编号,RTRIM(b.`名称`) as 客户名称,COUNT(DISTINCT a.jjcp_gdbh) AS count
  33. FROM `成品入仓` a LEFT JOIN `物料_存货结构` b ON LEFT(a.`成品编码`, $num) = RTRIM(b.`编号`)
  34. WHERE LEFT(a.jjcp_sj, 7) >= LEFT(DATE_SUB(CURDATE(), INTERVAL 12 MONTH), 7) AND (a.jjcp_smb = '末 板' OR a.jjcp_smb = '末板') AND a.`成品编码` != ''
  35. GROUP BY LEFT(a.jjcp_sj, 7), RTRIM(b.`编号`) ORDER BY date DESC, 编号 ASC";
  36. $data = Db::query($sql);
  37. // 创建一个新数组来存储整理后的数据
  38. $organizedData = [];
  39. // 遍历原始数据
  40. foreach ($data as $entry) {
  41. $date = date('Ym',strtotime($entry['date']));
  42. // 检查日期是否在已整理数据中存在
  43. if (isset($organizedData[$date])) {
  44. // 如果日期存在,将数据追加到该日期下
  45. $organizedData[$date][] = [
  46. '客户名称' => $entry['客户名称'],
  47. '客户编号' => $entry['编号'],
  48. 'total' => $entry['count'],
  49. ];
  50. // 统计该日期下所有数据的总和
  51. $organizedData[$date]['total_count'] += $entry['count'];
  52. } else {
  53. // 如果日期不存在,创建新的日期项并添加数据
  54. $organizedData[$date] = [
  55. [
  56. '客户名称' => $entry['客户名称'],
  57. '客户编号' => $entry['编号'],
  58. 'total' => $entry['count'],
  59. ]
  60. ];
  61. // 初始化该日期的总和
  62. $organizedData[$date]['total_count'] = $entry['count'];
  63. }
  64. }
  65. // 将整理后的数据调整为以日期和相加的总和为索引的格式
  66. $finalData = [];
  67. foreach ($organizedData as $date => $entries) {
  68. $totalCount = $entries['total_count'];
  69. $index = $date . '-' . $totalCount;
  70. unset($entries['total_count']);
  71. $finalData[$index] = $entries;
  72. }
  73. $this->success('请求成功',$finalData);
  74. }
  75. /**
  76. * 获取超节损工单列表
  77. * @ApiMethod GET
  78. * @params string date
  79. * @params string code
  80. * 报废定额=(基础损耗+损耗率*计划产量)*损耗系数*计损色数(特定工序会有,如果无就不乘)
  81. * 允损比例=报废定额/计划产量
  82. * 目标合格率 = 100%-超节损工单中显示工序的允损比例之和
  83. * 节损奖 小盒0.02 大盒0.09
  84. *
  85. */
  86. public function getList(){
  87. if (Request::instance()->isGet() == false) {
  88. $this->error('非法请求');
  89. }
  90. $params = Request::instance()->param();
  91. $where = [];
  92. if (!empty($params['code'])) {
  93. if (!empty($params['search'])) {
  94. $this->error('参数错误');
  95. }
  96. }
  97. if (!empty($params['date'])) {
  98. if (!empty($params['search'])) {
  99. $this->error('参数错误');
  100. }
  101. $date_year = substr($params['date'],0,4);
  102. $date_mon = substr($params['date'],4);
  103. $date = $date_year.'-'.$date_mon;
  104. $where['a.jjcp_sj' ] = array('like',$date.'%');
  105. }
  106. if (!empty($params['search'])) {
  107. if (!empty($params['date']) || !empty($params['code'])) {
  108. $this->error('参数错误');
  109. }
  110. $where['a.成品名称|a.jjcp_gdbh'] = array('like','%'.$params['search'].'%');
  111. }
  112. $where['b.行号' ] = 1;
  113. $where['a.jjcp_smb' ] = array('IN', array('末 板', '末板'));
  114. $limit = $params['limit'];
  115. if (empty($limit)){
  116. $limit = 15;
  117. }
  118. $pages = $params['page'];
  119. if (empty($pages)){
  120. $pages = 1;
  121. }
  122. // $str = '';
  123. // if (empty($params['search'])){
  124. // $str = '/'.$date . '/' . $params['code'].'/'.$pages;
  125. // }
  126. // $is_have_cache = Cache::get('OrderSuperLoss/getList'.$str);
  127. $is_have_cache = false;
  128. $num = config('product_code_digit');
  129. if ($is_have_cache === false){
  130. if (!empty($params['code'])){
  131. $data = db('成品入仓')->alias('a')
  132. ->join('工单_基本资料 b', 'a.jjcp_gdbh = b.Gd_gdbh','left')
  133. ->join('工单_印件资料 c', 'a.jjcp_gdbh = c.Yj_Gdbh AND a.jjcp_cpdh = c.yj_Yjdh','left')
  134. ->join('物料_收发记录 d',' a.jjcp_gdbh = d.st_gdbh AND d.cpdh = a.jjcp_cpdh')
  135. ->where($where)
  136. ->where('d.仓库编号','Y101')
  137. ->whereRaw('LEFT(a.成品编码, ' . $num . ') = "' . $params['code'] . '"')
  138. ->field('DISTINCT(a.jjcp_gdbh) as Gd_gdbh,a.jjcp_yjno,rtrim(a.jjcp_cpdh) as 成品编码,rtrim(a.jjcp_cpmc) as 成品名称,a.jjcp_sj,a.jjcp_smb,b.计量单位,
  139. b.Gd_khdh, SUM(d.st_sl) as 实际投料 ,c.yj_Yjno, c.yj_ls,c.yj_ks')
  140. ->order('b.Gd_khdh,a.成品编码 asc,a.jjcp_yjno,d.st_rq desc')
  141. ->group('a.jjcp_gdbh,a.jjcp_yjno')
  142. ->page($pages)
  143. ->limit($limit)
  144. ->select();
  145. $total = db('成品入仓')->alias('a')
  146. ->join('工单_基本资料 b', 'a.jjcp_gdbh = b.Gd_gdbh','left')
  147. ->join('工单_印件资料 c', 'a.jjcp_gdbh = c.Yj_Gdbh','left')
  148. ->where($where)
  149. ->whereRaw('LEFT(a.成品编码, ' . $num . ') = "' . $params['code'] . '"')
  150. ->count();
  151. }else{
  152. $data = db('成品入仓')->alias('a')
  153. ->join('工单_基本资料 b', 'a.jjcp_gdbh = b.Gd_gdbh','left')
  154. ->join('工单_印件资料 c', 'a.jjcp_gdbh = c.Yj_Gdbh AND a.jjcp_cpdh = c.yj_Yjdh','left')
  155. ->join('物料_收发记录 d',' a.jjcp_gdbh = d.st_gdbh AND d.cpdh = a.jjcp_cpdh')
  156. ->where($where)
  157. ->where('d.仓库编号','Y101')
  158. ->field('DISTINCT(a.jjcp_gdbh) as Gd_gdbh,a.jjcp_yjno,rtrim(a.jjcp_cpdh) as 成品编码,rtrim(a.jjcp_cpmc) as 成品名称,a.jjcp_sj,a.jjcp_smb,b.计量单位,
  159. b.Gd_khdh, SUM(d.st_sl) as 实际投料,c.yj_Yjno, c.yj_ls,c.yj_ks')
  160. ->order('b.Gd_khdh,a.成品编码 asc,a.jjcp_yjno,d.st_rq desc')
  161. ->group('a.jjcp_gdbh,a.jjcp_yjno')
  162. ->page($pages)
  163. ->limit($limit)
  164. ->select();
  165. $total = db('成品入仓')->alias('a')
  166. ->join('工单_基本资料 b', 'a.jjcp_gdbh = b.Gd_gdbh','left')
  167. ->join('工单_印件资料 c', 'a.jjcp_gdbh = c.Yj_Gdbh','left')
  168. ->where($where)
  169. ->count();
  170. }
  171. foreach ($data as $key => $value){
  172. //查出成品数量及日期
  173. $cp_sql = "SELECT SUM(jjcp_sl) as cp_sl,MAX(jjcp_sj) as jjcp_sj FROM `成品入仓` WHERE jjcp_gdbh = '{$value['Gd_gdbh']}' AND jjcp_yjno = '{$value['jjcp_yjno']}' GROUP BY jjcp_gdbh,jjcp_yjno";
  174. $cp_data = Db::query($cp_sql);
  175. $data[$key]['warehousing_num'] = $cp_data[0]['cp_sl'];
  176. $data[$key]['warehousing_date'] = substr($cp_data[0]['jjcp_sj'],0,10);
  177. //查出进入超节损的工序,有上报产量的工序就进入超节损
  178. $gxh_sql = "SELECT sczl_gxh FROM
  179. (SELECT sczl_gxh FROM 设备_产量计酬 WHERE sczl_gdbh = '{$value['Gd_gdbh']}'
  180. UNION SELECT sczl_gxh FROM db_sczl WHERE sczl_gdbh = '{$value['Gd_gdbh']}') AS combined_result";
  181. $gxh_arr = Db::query($gxh_sql);
  182. $gxh_values = array_column($gxh_arr, 'sczl_gxh');
  183. $gy_data =db('工单_工艺资料')->where('Gy0_gdbh',$value['Gd_gdbh'])->where('Gy0_gxh','in',$gxh_values)->field('Gy0_gxmc,Gy0_计划接货数,Gy0_计划损耗')->select();
  184. $arr = [];
  185. $plan_loss = [];//工单计划损耗
  186. $machine_plan_loss = 0;//机检计划损耗
  187. foreach ($gy_data as $k=>$v){
  188. if ($v['Gy0_计划接货数'] > 0){
  189. $rate = round($v['Gy0_计划损耗'] / $v['Gy0_计划接货数'],5);
  190. }else{
  191. $rate = 0;
  192. }
  193. $arr[$k] = floor($rate * 10000) /10000;
  194. $plan_loss[$k] = $v['Gy0_计划损耗'];
  195. // if (strpos($v['Gy0_gxmc'],'机检') !== false){
  196. // $machine_plan_loss = $v['Gy0_计划损耗'];
  197. // }
  198. }
  199. if ((int)$value['yj_ls'] > 0){
  200. $value['实际投料'] = number_format(((int)$value['实际投料']/10000)*$value['yj_ls']*$value['yj_ks'],4);
  201. }else{
  202. $value['实际投料'] = number_format($value['实际投料']/10000,4);
  203. }
  204. $data[$key]['实际投料'] = $value['实际投料'];
  205. if ($value['实际投料'] >0 ){
  206. $target_rate = (1-array_sum($arr))*100;
  207. $data[$key]['target_rate'] =$target_rate.'%'; //目标合格率
  208. $real_rate = $cp_data[0]['cp_sl'] / ($value['实际投料'] * 10000) *100;
  209. $data[$key]['real_rate'] = number_format($real_rate,2) . '%';//实际合格率
  210. }else{
  211. $data[$key]['target_rate'] = ''; //目标合格率
  212. $data[$key]['real_rate'] = '';//实际合格率
  213. }
  214. //制程废品
  215. $zzfp_data =db('设备_产量计酬')->where('sczl_gdbh',$value['Gd_gdbh'])->field('SUM(sczl_zcfp) as sczl_zcfp')->select();
  216. $data[$key]['zcfp'] = $zzfp_data[0]['sczl_zcfp'] * $value['yj_ls'];//制程废品
  217. //废品合计
  218. $wasteTotal = db('db_qczl')->where('qczl_gdbh',$value['Gd_gdbh'])->sum('qczl_fp');
  219. if (empty($wasteTotal)){
  220. $wasteTotal = 0;
  221. }
  222. $data[$key]['废品合计'] = $wasteTotal + $data[$key]['zcfp'];//废品合计
  223. $data[$key]['工单无形损'] = (int)($value['实际投料'] *10000) - $cp_data[0]['cp_sl'] - $data[$key]['废品合计'];//工单无形损
  224. $out_sql = "SELECT 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,
  225. 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,
  226. 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,
  227. 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
  228. FROM db_qczl WHERE qczl_gdbh = '{$value['Gd_gdbh']}'";
  229. $waste_out = Db::query($out_sql);
  230. $list = []; //外发废数组
  231. $quality = [];//质检废数组
  232. $material = [];//材料废数组
  233. $change = [];//零头处理数组
  234. $machine = [];//机检废品数组
  235. $j = 0;
  236. $m = 0;
  237. $n = 0;
  238. $l = 0;
  239. $o = 0;
  240. foreach ($waste_out as $entry) {
  241. for ($i = 1; $i <= 13; $i++) {
  242. $labelKey = "fp_lb" . $i;
  243. $bhKey = "fp_bh" . $i;
  244. $gxmcKey = "fp_gxmc" . $i;
  245. $slKey = "fp_sl" . $i;
  246. if (!empty($entry[$labelKey])) {
  247. if (substr($entry[$gxmcKey],0,2) == '99'){
  248. $list[$j]= $entry[$slKey];
  249. $j++;
  250. }
  251. if (substr($entry[$labelKey],0,1) == 'L' ){
  252. $material[$n]= $entry[$slKey];
  253. $n++;
  254. }
  255. if (substr($entry[$labelKey],0,3) == 'M04' ){
  256. $change[$l]= $entry[$slKey];
  257. $l++;
  258. }
  259. }
  260. if (!empty($entry[$bhKey])) {
  261. if ($entry[$bhKey] != '000000' && $entry[$slKey] > 0){
  262. $quality[$m]= $entry[$slKey];
  263. $m++;
  264. }
  265. // if ($entry[$bhKey] != '000000' && substr($entry[$labelKey],0,3) == 'K01'){
  266. // $machine[$o]= $entry[$slKey];
  267. // $o++;
  268. // }
  269. }
  270. }
  271. }
  272. // $machine_waste = array_sum($machine);//机检废品
  273. // if ($data[$key]['Gd_gdbh'] == '2401746'){
  274. // halt($machine_waste);
  275. // }
  276. // $data[$key]['工单计划损耗'] = array_sum($plan_loss);//工单计划损耗
  277. // /**
  278. // * 奖惩系数及金额
  279. // * 奖惩金额 = 工单节损数 * 0.02(0.09)
  280. // * 工单节损数 = 工单计划损耗 - 废品总数 - 机检节损数
  281. // * 机检节损数 = 机检计划损耗 - 机检质检废品
  282. // */
  283. // $machine_loss = $machine_plan_loss - $machine_waste;
  284. // $order_loss = $data[$key]['工单计划损耗'] - $data[$key]['废品合计'] - $machine_loss;
  285. // if (strpos($data[$key]['成品名称'],'小盒')){
  286. // $moneyRate = 0.02;
  287. // }else{
  288. // $moneyRate = 0.09;
  289. // }
  290. // $reward = $order_loss * $moneyRate;
  291. $data[$key]['reward_rate'] = '1';
  292. // $data[$key]['reward_money'] = number_format($reward,2);
  293. $data[$key]['reward_money'] = '';
  294. $data[$key]['材料废'] = array_sum($material); //材料废
  295. $data[$key]['零头处理'] = array_sum($change); //零头处理
  296. $data[$key]['外发废'] = array_sum($list);//外发废
  297. $data[$key]['分摊废'] = '';//分摊废
  298. $data[$key]['工单质检废'] = array_sum($quality); //质检废
  299. }
  300. $res = [
  301. 'data'=>$data,
  302. 'total' => $total
  303. ];
  304. // if ($str != false){
  305. // Cache::set('OrderSuperLoss/getList'.$str,$res,3600);
  306. // }
  307. }else{
  308. // $res = Cache::get('OrderSuperLoss/getList'.$str);
  309. }
  310. $this->success('请求成功',$res);
  311. }
  312. /**
  313. * 获取工单超节损工艺
  314. * @ApiMethod GET
  315. * @params string order
  316. */
  317. public function getOrderSuperLossGy(){
  318. if (Request::instance()->isGet() == false) {
  319. $this->error('非法请求');
  320. }
  321. $params = Request::instance()->param();
  322. if (!isset($params['order']) || empty($params['order'])) {
  323. $this->error('参数错误');
  324. }
  325. $sql = "SELECT a.Gy0_gdbh,a.Gy0_yjno,a.Gy0_gxh,rtrim(a.Gy0_gxmc) as Gy0_gxmc,rtrim(a.Add_gxmc) as Add_gxmc,a.Gy0_ls,a.Gy0_Rate0,a.Gy0_Rate1,a.损耗系数,a.Gy0_ms,
  326. a.Gy0_计划接货数,a.Gy0_计划损耗,sum(b.sczl_cl) as total_cl,sum(b.sczl_zcfp) as total_fp,sum(c.sczl_cl) as cl,SUM(c.sczl_fp) as fp FROM `工单_工艺资料` a
  327. LEFT JOIN `设备_产量计酬` b ON a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_gxh = b.sczl_gxh
  328. LEFT JOIN `db_sczl` c ON a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_gxh = c.sczl_gxh
  329. WHERE a.Gy0_gdbh = '{$params['order']}' GROUP BY a.Gy0_gxh";
  330. $data = Db::query($sql);
  331. foreach ($data as $key=>$value){
  332. if (!empty($value['total_cl'])){
  333. $data[$key]['total_cl'] = $value['total_cl'] *$value['Gy0_ls'];
  334. }else{
  335. $data[$key]['total_cl'] =$value['cl'] *$value['Gy0_ls'];
  336. }
  337. if (!empty($value['total_fp'])){
  338. $data[$key]['total_fp'] = $value['total_fp'] *$value['Gy0_ls'];
  339. }else{
  340. $data[$key]['total_fp'] = $value['fp'] *$value['Gy0_ls'];
  341. }
  342. unset($data[$key]['cl']);
  343. unset($data[$key]['fp']);
  344. }
  345. $this->success('请求成功',$data);
  346. }
  347. /**
  348. * 工单超节损统计
  349. * @ApiMethod GET
  350. * @params string order
  351. * 节损奖 小盒0.02 大盒0.09
  352. */
  353. public function getOrderSuperLossCount(){
  354. if (Request::instance()->isGet() == false) {
  355. $this->error('非法请求');
  356. }
  357. $params = Request::instance()->param();
  358. if (!isset($params['order']) || empty($params['order'])) {
  359. $this->error('参数错误');
  360. }
  361. $order = $params['order'];
  362. $field = 'a.Gd_gdbh,rtrim(a.成品代号) as 成品代号,rtrim(a.成品名称) as 成品名称,rtrim(a.销售订单号) as 销售订单号,a.订单数量,c.yj_ls as ls,c.yj_ks as ks,SUM(b.st_sl) as 投料';
  363. $data =db('工单_基本资料')
  364. ->alias('a')
  365. ->join('物料_收发记录 b','a.Gd_gdbh = b.st_gdbh AND a.Gd_cpdh = b.cpdh')
  366. ->join('工单_印件资料 c','c.Yj_Gdbh = a.Gd_gdbh AND c.yj_Yjdh = a.Gd_cpdh')
  367. ->where('a.Gd_Gdbh',$order)
  368. ->where('a.行号',$params['yjno'])
  369. ->where('c.yj_Yjno',$params['yjno'])
  370. ->where('b.仓库编号','Y101')
  371. ->field($field)
  372. ->find();
  373. if ($data['ls'] == 0){
  374. $data['ls'] === 1;
  375. }
  376. if ($data['ks'] == 0){
  377. $data['ks'] === 1;
  378. }
  379. $data['实际投料'] = number_format($data['投料']*$data['ls']*$data['ks']/10000,4);
  380. //查出成品数量及日期
  381. $cp_sql = "SELECT SUM(jjcp_sl) as cp_sl,MAX(jjcp_sj) as jjcp_sj FROM `成品入仓` WHERE jjcp_gdbh = '{$order}' AND jjcp_yjno = '{$params['yjno']}' GROUP BY jjcp_gdbh,jjcp_yjno";
  382. $cp_data = Db::query($cp_sql);
  383. if (empty($cp_data)){
  384. $this->success('此工单未查询到成品入库信息,请核查该工单是否已进入超节损');
  385. }
  386. $data['warehousing_num'] = $cp_data[0]['cp_sl'];
  387. $data['warehousing_date'] = substr($cp_data[0]['jjcp_sj'],0,10);
  388. //查出进入超节损的工序,有上报产量的工序就进入超节损
  389. $gxh_sql = "SELECT sczl_gxh FROM
  390. (SELECT sczl_gxh FROM 设备_产量计酬 WHERE sczl_gdbh = '{$order}' AND sczl_yjno = '{$params['yjno']}'
  391. UNION SELECT sczl_gxh FROM db_sczl WHERE sczl_gdbh = '{$order}' AND sczl_yjno = '{$params['yjno']}') AS combined_result";
  392. $gxh_arr = Db::query($gxh_sql);
  393. // $gxh_arr = \db('工单_工艺资料')
  394. // ->where('Gy0_gdbh',$order)
  395. // ->where('Gy0_yjno',$params['yjno'])
  396. // ->field('Gy0_gxh as sczl_gxh')
  397. // ->select();
  398. $gxh_values = array_column($gxh_arr, 'sczl_gxh');
  399. foreach ($gxh_values as $k=>$v){
  400. if ((int)$v < 10){
  401. $gxh_values[$k] = '0'.$v;
  402. }
  403. }
  404. $gy_data =db('工单_工艺资料')
  405. ->alias('a')
  406. ->field([
  407. 'a.Gy0_yjno', 'a.Gy0_gxh', 'RTRIM(a.Gy0_gxmc) as Gy0_gxmc','RTRIM(a.Add_gxmc) as Add_gxmc','a.Gy0_ks', 'a.Gy0_ls', 'a.Gy0_计划接货数',
  408. 'a.Gy0_计划损耗', 'a.超节损承担比例','SUM(b.sczl_zcfp) as total_fp','SUM(b.sczl_cl) as total_cl','SUM(c.sczl_cl) as cl','SUM(c.sczl_fp) as fp',
  409. ])
  410. ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
  411. ->join('db_sczl c', 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh','left')
  412. ->where([
  413. 'a.Gy0_gdbh' => $order,
  414. 'a.Gy0_yjno' => $params['yjno'],
  415. 'a.Gy0_gxh' => ['in', $gxh_values]
  416. ])
  417. ->group('a.Gy0_yjno,a.Gy0_gxh')
  418. ->select();
  419. $arr = [];
  420. $plan_loss = [];//工单计划损耗
  421. foreach ($gy_data as $k=>$v){
  422. $rate = round($v['Gy0_计划损耗'] / $v['Gy0_计划接货数'],5);
  423. $arr[$k] = floor($rate * 10000) /10000;
  424. $plan_loss[$k] = $v['Gy0_计划损耗'];
  425. }
  426. $target_rate = (1-array_sum($arr))*100;
  427. $data['target_rate'] =$target_rate.'%'; //目标合格率
  428. $real_rate = $cp_data[0]['cp_sl'] / ($data['实际投料'] * 10000) *100;
  429. $data['real_rate'] = number_format($real_rate,2) . '%';//实际合格率
  430. //制程废品
  431. $zzfp_data =db('设备_产量计酬')->where('sczl_gdbh',$order)->where('sczl_yjno',$params['yjno'])->field('SUM(sczl_zcfp) as sczl_zcfp')->select();
  432. //联数
  433. $ls =db('工单_工艺资料')->where('Gy0_gdbh',$order)->field('Gy0_ls,Gy0_ks')->find();
  434. //制程废品*ls
  435. $data['zcfp'] = $zzfp_data[0]['sczl_zcfp'] * $ls['Gy0_ls'] * $ls['Gy0_ks'];
  436. //废品数量
  437. $wasteTotal = db('db_qczl')->where('qczl_gdbh',$order)->where('qczl_yjno',$params['yjno'])->sum('qczl_fp');
  438. if (empty($wasteTotal)){
  439. $wasteTotal = 0;
  440. }
  441. //废品合计
  442. $waste_total = $data['zcfp'] + $wasteTotal;
  443. //工单无形损
  444. $data['intangible_loss'] = (int)($data['实际投料'] *10000 - $cp_data[0]['cp_sl'] - $waste_total);
  445. $out_sql = "SELECT 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,
  446. 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,
  447. 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,
  448. 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,UniqId
  449. FROM db_qczl WHERE qczl_gdbh = '{$order}' AND qczl_yjno = '{$params['yjno']}'";
  450. $waste_out = Db::query($out_sql);
  451. $list = []; //外发废数组
  452. $quality = [];//质检废数组
  453. $material = [];//材料废数组
  454. $change = [];//零头处理数组
  455. $j = 0;
  456. $m = 0;
  457. $n = 0;
  458. $l = 0;
  459. foreach ($waste_out as $entry) {
  460. for ($i = 1; $i <= 13; $i++) {
  461. $labelKey = "fp_lb" . $i;
  462. $bhKey = "fp_bh" . $i;
  463. $gxmcKey = "fp_gxmc" . $i;
  464. $slKey = "fp_sl" . $i;
  465. if (!empty($entry[$labelKey])) {
  466. if (substr($entry[$labelKey],0,3) == 'M04'){
  467. $list[$j]= $entry[$slKey];
  468. $j++;
  469. }
  470. if (substr($entry[$labelKey],0,1) == 'L' ){
  471. $material[$n]= $entry[$slKey];
  472. $n++;
  473. }
  474. if (substr($entry[$labelKey],0,3) == 'M01' ){
  475. $change[$l]= $entry[$slKey];
  476. $l++;
  477. }
  478. }
  479. // if (!empty($entry[$bhKey])) {
  480. // if ($entry[$bhKey] != '000000' && $entry[$slKey] > 0){
  481. $quality[$m]= $entry[$slKey];
  482. $m++;
  483. // }
  484. // }
  485. }
  486. }
  487. $data['材料废'] = array_sum($material); //材料废
  488. $data['零头处理'] = array_sum($change); //零头处理
  489. $data['外发废'] = array_sum($list);//外发废
  490. $data['工单质检废'] = array_sum($quality);//质检废
  491. // $data['分摊废'] = '';//分摊废
  492. $plan_total =db('工单_工艺资料')->where(['Gy0_gdbh' => $order,'Gy0_yjno' => $params['yjno'], 'Gy0_gxh' => ['in', $gxh_values]])->value('SUM(Gy0_计划损耗 * Gy0_ls * Gy0_ks)');
  493. //单据列表最后统计
  494. $total = [];
  495. $total['plan_loss'] = 0;
  496. $total['total_fp'] = 0;
  497. $total['waste_quality'] = 0;
  498. $total['waste_intangible'] = 0;
  499. $total['reward'] = 0; //超节损奖励数组
  500. //按工序打印
  501. if ($params['type'] == 1){
  502. $total['total_waste'] = 0;
  503. $total['loss'] = 0;
  504. foreach ($gy_data as $k=>$item){
  505. $gy_data[$k]['Gy0_计划损耗'] = $item['Gy0_计划损耗']*$item['Gy0_ls']*$item['Gy0_ks'];
  506. $gy_data[$k]['waste_quality'] = 0;
  507. $gy_data[$k]['total_fp'] = $item['total_fp'] * $item['Gy0_ls'];
  508. $gy_data[$k]['total_cl'] = $item['total_cl'] * $item['Gy0_ls'];
  509. //无形损
  510. $gy_data[$k]['intangible_loss'] = round(number_format($gy_data[$k]['Gy0_计划损耗']/$plan_total,4) * $data['intangible_loss']);
  511. foreach ($waste_out as $entry) {
  512. for ($i = 1; $i <= 13; $i++) {
  513. $gxmcKey = "fp_gxmc" . $i;
  514. $slKey = "fp_sl" . $i;
  515. if ((int)substr($entry[$gxmcKey],0,2) == $item['Gy0_gxh']){
  516. $gy_data[$k]['waste_quality'] += $entry[$slKey];
  517. }
  518. }
  519. }
  520. //报废合计
  521. if ($gy_data[$k]['intangible_loss'] < 0){
  522. $gy_data[$k]['total_waste'] = $gy_data[$k]['waste_quality'] + $gy_data[$k]['total_fp'];
  523. }else{
  524. $gy_data[$k]['total_waste'] = $gy_data[$k]['waste_quality'] + $gy_data[$k]['intangible_loss'] + $gy_data[$k]['total_fp'];
  525. }
  526. //工序节损数
  527. $gy_data[$k]['loss'] = $item['Gy0_计划损耗']*$item['Gy0_ls']*$item['Gy0_ks'] - $gy_data[$k]['total_waste'];
  528. //占投料报废率
  529. $gy_data[$k]['loss_rate'] = number_format($gy_data[$k]['loss'] / $item['Gy0_计划接货数'],4) * 100 .'%';
  530. //工序目标报废率
  531. $target_loss_rate = floor($item['Gy0_计划损耗'] / $item['Gy0_计划接货数'] * 10000) / 10000;
  532. if ($target_loss_rate == 0){
  533. $target_loss_rate = round($item['Gy0_计划损耗'] / $item['Gy0_计划接货数'] * 10000) / 10000;
  534. }
  535. $gy_data[$k]['target_loss_rate'] = $target_loss_rate * 100 . '%';
  536. //工序实际报废率
  537. $gy_data[$k]['actual_loss_rate'] = number_format($gy_data[$k]['total_waste'] / $item['Gy0_计划接货数'],4) * 100 .'%';
  538. $gy_data[$k]['超节损承担比例'] = number_format($item['超节损承担比例'],4) * 100 .'%';
  539. //工序超节损金额
  540. if (strpos($data['成品名称'],'小盒')){
  541. $moneyRate = 0.02;
  542. }else{
  543. $moneyRate = 0.09;
  544. }
  545. if (strpos($item['Gy0_gxmc'],'机检') !== false){
  546. $gy_data[$k]['工序超节损金额'] = '0.000000';
  547. }else{
  548. $gy_data[$k]['工序超节损金额'] = number_format($gy_data[$k]['loss'] * $item['超节损承担比例'] * $moneyRate,4);
  549. }
  550. $total['plan_loss'] += $gy_data[$k]['Gy0_计划损耗'];
  551. $total['total_fp'] += $gy_data[$k]['total_fp'];
  552. $total['waste_quality'] += $gy_data[$k]['waste_quality'];
  553. $total['waste_intangible'] += $gy_data[$k]['intangible_loss'];
  554. $total['total_waste'] += $gy_data[$k]['total_waste'];
  555. $total['loss'] += $gy_data[$k]['loss'];
  556. $total['reward'] += floatval(str_replace(',', '', $gy_data[$k]['工序超节损金额']));
  557. }
  558. $total['reward'] = number_format($total['reward'],2);
  559. $data['gy_data'] = $gy_data;
  560. $data['total'] = $total;
  561. $this->success('请求成功',$data);
  562. }else{ //按班组打印
  563. //总产量数据
  564. $total_cl_data = \db('工单_工艺资料')->alias('a')
  565. ->field(['a.Gy0_yjno', 'a.Gy0_gxh','a.Gy0_ls', 'SUM(b.sczl_cl) as total_cl', 'SUM(c.sczl_cl) as cl'])
  566. ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
  567. ->join('db_sczl c', 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh','left')
  568. ->where([
  569. 'a.Gy0_gdbh' => $order,
  570. 'a.Gy0_yjno' => $params['yjno'],
  571. 'a.Gy0_gxh' => ['IN', $gxh_values],
  572. 'b.sczl_cl|c.sczl_cl' => ['>', 0]
  573. ])
  574. ->group('b.sczl_gxh')
  575. ->order('a.Gy0_gxh')
  576. ->select();
  577. //按班组分的产量数据
  578. $gy_data =db('工单_工艺资料')
  579. ->alias('a')
  580. ->field([
  581. 'a.Gy0_yjno', 'a.Gy0_gxh', 'a.Gy0_ls', 'a.Gy0_ks' ,'a.Gy0_计划损耗', 'a.超节损承担比例', 'b.sczl_gxmc',
  582. 'SUM(b.sczl_zcfp) as sczl_zcfp', 'SUM(b.sczl_cl) as total_cl',
  583. 'b.sczl_bh1', 'b.sczl_bh2', 'b.sczl_bh3', 'b.sczl_bh4', 'b.sczl_bh5', 'b.sczl_bh6',
  584. 'b.sczl_bh7', 'b.sczl_bh8', 'b.sczl_bh9', 'b.sczl_bh10',
  585. 'rtrim(c.sczl_gxmc) as gxmc', 'SUM(c.sczl_cl) as cl', 'SUM(c.sczl_fp) as fp', 'c.sczl_bh1 as sczl_bh'
  586. ])
  587. ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
  588. ->join('db_sczl c', 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh','left')
  589. ->where([
  590. 'a.Gy0_gdbh' => $order,
  591. 'a.Gy0_yjno' => $params['yjno'],
  592. 'a.Gy0_gxh' => ['in', $gxh_values],
  593. 'b.sczl_cl|c.sczl_cl' => ['>', 0]
  594. ])
  595. ->group('b.sczl_gxh, b.sczl_bh1, CASE WHEN b.sczl_bh2 = "000000" THEN "" ELSE b.sczl_bh2 END, b.sczl_bh3,
  596. b.sczl_bh4, b.sczl_bh5, b.sczl_bh6, b.sczl_bh7, b.sczl_bh8, b.sczl_bh9, c.sczl_bh1')
  597. ->order('a.Gy0_gxh asc, b.开工时间 asc, c.sczl_rq desc')
  598. ->select();
  599. foreach ($gy_data as $key=>$value){
  600. $gy_data[$key]['Gy0_yjno'] = $value['Gy0_yjno'] > 10 ? $value['Gy0_yjno'] : '0'.$value['Gy0_yjno'];
  601. //每道工序的产量(按班组分)
  602. $gy_data[$key]['total_cl'] = $value['total_cl'] * $value['Gy0_ls'];
  603. if (empty($value['total_cl'])){
  604. $gy_data[$key]['total_cl'] = $value['cl'] * $value['Gy0_ls'];
  605. }
  606. $value['Gy0_计划损耗'] = $value['Gy0_计划损耗']*$value['Gy0_ls']*$value['Gy0_ks'];
  607. //计算每道工序的计划损耗
  608. foreach ($total_cl_data as $k=>$v){
  609. //每道工序的总产量
  610. $cl = $v['total_cl'] * $v['Gy0_ls'];
  611. if (empty($cl)){
  612. $cl = $v['cl'] * $v['Gy0_ls'];
  613. }
  614. if ($value['Gy0_yjno'] == $v['Gy0_yjno'] && $value['Gy0_gxh'] == $v['Gy0_gxh']){
  615. $gy_data[$key]['计划损耗'] = round($gy_data[$key]['total_cl'] / $cl * $value['Gy0_计划损耗']);
  616. }
  617. }
  618. //每道工序的制程废品(按班组分)
  619. $gy_data[$key]['sczl_zcfp'] = $value['sczl_zcfp'] * $value['Gy0_ls'];
  620. if (empty($value['sczl_zcfp'])){
  621. $gy_data[$key]['sczl_zcfp'] = $value['fp'] * $value['Gy0_ls'];
  622. }
  623. //计算每道工序的质检废(按班组)
  624. $gy_data[$key]['sczl_gxmc'] = $value['sczl_gxmc'];
  625. if (empty($value['sczl_gxmc'])){
  626. $gy_data[$key]['sczl_gxmc'] = $value['gxmc'];
  627. }
  628. if (empty($value['sczl_bh1']) || is_null($value['sczl_bh1'])){
  629. $value['sczl_bh1'] = $value['sczl_bh'];
  630. }
  631. $gy_data[$key]['sczl_bh1'] = $value['sczl_bh1'];
  632. $gy_data[$key]['质检废'] = 0;
  633. foreach ($waste_out as $entry) {
  634. for ($i = 1; $i <= 13; $i++) {
  635. $gxmcKey = "fp_gxmc" . $i;
  636. $slKey = "fp_sl" . $i;
  637. $bhKey = "fp_bh" . $i;
  638. if ((int)substr($entry[$gxmcKey],0,2) == $value['Gy0_gxh'] && $entry[$bhKey] == $value['sczl_bh1']){
  639. $gy_data[$key]['质检废'] += $entry[$slKey];
  640. }
  641. }
  642. }
  643. //无形损分摊
  644. $gy_data[$key]['无形损分摊'] = round($gy_data[$key]['计划损耗'] / $plan_total * $data['intangible_loss']);
  645. //班组成员
  646. $nameArr = [];
  647. for ($j = 1; $j <= 10; $j++) {
  648. $bhKey = "sczl_bh" . $j;
  649. if (!empty($value[$bhKey])){
  650. $name = \db('人事_基本资料')->where('员工编号',$value[$bhKey])->value('rtrim(员工姓名)');
  651. array_push($nameArr,$name);
  652. }
  653. }
  654. $gy_data[$key]['member'] = implode(' ',$nameArr);
  655. unset($gy_data[$key]['Gy0_计划损耗']);
  656. unset($gy_data[$key]['gxmc']);
  657. unset($gy_data[$key]['cl']);
  658. unset($gy_data[$key]['fp']);
  659. unset($gy_data[$key]['sczl_bh']);
  660. }
  661. //重新计算多班组同组长的质检废,质检废 = 班组产量 / 总产量 * 质检废
  662. $totals = [];
  663. // foreach ($gy_data as $item) {
  664. // $sczl_bh1 = $item['sczl_bh1'];
  665. // $total_cl = $item['total_cl'];
  666. //
  667. // if (isset($totals[$sczl_bh1])) {
  668. // $totals[$sczl_bh1]['total'] += $total_cl;
  669. // } else {
  670. // $totals[$sczl_bh1] = ['total' => $total_cl, 'count' => 0];
  671. // }
  672. // $totals[$sczl_bh1]['count']++;
  673. // }
  674. $i = 0;
  675. foreach ($gy_data as &$item) {
  676. $sczl_bh1 = $item['sczl_bh1'];
  677. $total_cl = $item['total_cl'];
  678. // $item['total'] = $totals[$sczl_bh1]['total'];
  679. // if ($totals[$sczl_bh1]['count'] > 1) {
  680. // $item['质检废'] = round($total_cl / $totals[$sczl_bh1]['total'] * $item['质检废']);
  681. // }
  682. //节损数量
  683. if ($item['无形损分摊'] > 0){
  684. $total_waste = $item['质检废'] + $item['sczl_zcfp'] + $item['无形损分摊'];
  685. }else{
  686. $total_waste = $item['质检废'] + $item['sczl_zcfp'];
  687. }
  688. $gy_data[$i]['节损数量'] = $item['计划损耗'] - $total_waste;
  689. //节损奖
  690. if (strpos($data['成品名称'],'小盒')){
  691. $moneyRate = 0.02;
  692. }else{
  693. $moneyRate = 0.09;
  694. }
  695. if (strpos($item['sczl_gxmc'],'机检') !== false){
  696. $gy_data[$i]['节损奖'] = 0;
  697. }else{
  698. $gy_data[$i]['节损奖'] = number_format($gy_data[$i]['节损数量'] * $item['超节损承担比例'] * $moneyRate,4);
  699. }
  700. $gy_data[$i]['超节损承担比例'] = number_format($item['超节损承担比例'],4) * 100 .'%';
  701. $total['plan_loss'] += $item['计划损耗'];
  702. $total['total_fp'] += $item['sczl_zcfp'];
  703. $total['waste_quality'] += $item['质检废'];
  704. $total['waste_intangible'] += $item['无形损分摊'];
  705. $total['reward'] += floatval(str_replace(',', '', $gy_data[$i]['节损奖']));
  706. $i++;
  707. }
  708. $total['reward'] = number_format($total['reward'],2);
  709. $data['gy_data'] = $gy_data;
  710. $data['total'] = $total;
  711. $this->success('请求成功',$data);
  712. }
  713. }
  714. /**
  715. * 获取工单工艺
  716. * @ApiMethod GET
  717. * @params string order
  718. */
  719. public function getOrderGy(){
  720. if (Request::instance()->isGet() == false) {
  721. $this->error('非法请求');
  722. }
  723. $params = Request::instance()->param();
  724. if (!isset($params['order']) || empty($params['order'])) {
  725. $this->error('参数错误');
  726. }
  727. $order = $params['order'];
  728. $field = 'Gy0_yjno,Gy0_gxh,rtrim(Gy0_gxmc) as Gy0_gxmc,rtrim(Add_gxmc) as Add_gxmc,Gy0_rate0,Gy0_rate1,损耗系数,无形损承担比例 as loss_one,超节损承担比例 as loss_two,超节损核算单价 as loss_thr,UniqId';
  729. $data =db('工单_工艺资料')->where('Gy0_gdbh',$order)->field($field)->select();
  730. $this->success('请求成功',$data);
  731. }
  732. /**
  733. * 更新工单工艺
  734. * @ApiMethod POST
  735. * @params array data
  736. */
  737. public function updateOrderGy(){
  738. if (Request::instance()->isPost() == false) {
  739. $this->error('非法请求');
  740. }
  741. $params = Request::instance()->post();
  742. if (!isset($params) || !isset($params[0]['UniqId'])){
  743. $this->error('参数不能为空');
  744. }
  745. $i = 0;
  746. foreach ($params as $key=>$value){
  747. $data = [];
  748. $data['无形损承担比例'] = $value['loss_one'];
  749. $data['超节损承担比例'] = $value['loss_two'];
  750. $data['超节损核算单价'] = $value['loss_thr'];
  751. $sql =db('工单_工艺资料')->where('UniqId',$value['UniqId'])->fetchSql(true)->update($data);
  752. $res = Db::query($sql);
  753. if ($res !== false){
  754. $i++;
  755. }
  756. }
  757. if ($i !== 0){
  758. $this->success('更新成功');
  759. }else{
  760. $this->error('更新失败');
  761. }
  762. }
  763. /**
  764. * 获取工单印件考核资料
  765. * @ApiMethod GET
  766. * @params string order
  767. */
  768. public function getOrderYj(){
  769. if (Request::instance()->isGet() == false) {
  770. $this->error('非法请求');
  771. }
  772. $params = Request::instance()->request();
  773. if (!isset($params['order']) || empty($params['order'])) {
  774. $this->error('参数错误');
  775. }
  776. $data =db('工单_印件资料')->where('Yj_gdbh',$params['order'])->field('Yj_gdbh,rtrim(yj_Yjdh) as yj_Yjdh,yj_Yjno,rtrim(yj_yjmc) as yj_yjmc,质量考核')->find();
  777. $this->success('请求成功',$data);
  778. }
  779. /**
  780. * 更新工单印件考核资料
  781. * @ApiMethod POST
  782. * @params array data
  783. */
  784. public function updateOrderYj(){
  785. if (Request::instance()->isPost() == false) {
  786. $this->error('非法请求');
  787. }
  788. $params = Request::instance()->request();
  789. if (!isset($params['order'])){
  790. $this->error('参数不能为空');
  791. }
  792. if (!isset($params['yj_yjno'])){
  793. $this->error('参数不能为空');
  794. }
  795. if (!isset($params['examine'])){
  796. $this->error('参数不能为空');
  797. }
  798. $where['Yj_gdbh'] = $params['order'];
  799. $where['yj_Yjno'] = $params['yj_yjno'];
  800. $res =db('工单_印件资料')->where($where)->setField('质量考核',$params['examine']);
  801. if ($res !== false){
  802. $this->success('更新成功');
  803. }else{
  804. $this->error('更新失败');
  805. }
  806. }
  807. /**
  808. * 获取修正工单实际投料列表
  809. * @ApiMethod GET
  810. * @params string year
  811. * @params string month
  812. */
  813. public function getOrderFeedList(){
  814. if (Request::instance()->isGet() == false) {
  815. $this->error('非法请求');
  816. }
  817. $params = Request::instance()->request();
  818. if (empty($params['workorder']) || empty($params['yjno'])) {
  819. $this->error('参数错误');
  820. }
  821. // $search = $params['year'].'.'.$params['month'];
  822. $field = "a.Gd_gdbh,rtrim(c.yj_Yjdh) as yj_yjdh,c.yj_Yjno, c.yj_ks,c.yj_ls,rtrim(c.yj_zzdh) as yj_zzdh,
  823. rtrim(b.BOM_物料名称) as BOM_物料名称,rtrim(c.yj_tlgg) as yj_tlgg,rtrim(b.BOM_投料单位) as BOM_投料单位,
  824. a.订单数量,c.yj_平张投料, b.BOM_实际用量,d.st_sl as 实际投料,a.投料确认,d.Uniqid as UniqId";
  825. $data =db('工单_基本资料')->alias('a')
  826. ->join('工单_印件资料 c','a.Gd_gdbh = c.Yj_Gdbh ','left')
  827. ->join('工单_bom资料 b','c.Yj_Gdbh = b.BOM_工单编号 AND c.yj_zzdh = b.BOM_物料编码','left')
  828. ->join('物料_收发记录 d','a.Gd_gdbh = d.st_gdbh AND d.cpdh = c.yj_Yjdh')
  829. // ->where('a.投料确认','like','%'.$search.'%')
  830. ->where('a.Gd_gdbh',$params['workorder'])
  831. ->where('c.yj_Yjno',$params['yjno'])
  832. ->where('d.仓库编号','Y101')
  833. ->field($field)
  834. ->group('a.Gd_gdbh,d.Uniqid')
  835. ->order('b.BOM_投料单位,a.UniqId asc')
  836. ->select();
  837. if (empty($data)){
  838. $this->success('请求成功');
  839. }
  840. foreach ($data as $key=>$value){
  841. // if ($value['yj_ls'] > 0){
  842. // $value['实际投料'] = number_format(((int)$value['实际投料']/10000)*$value['yj_ls']*$value['yj_ks'],4);
  843. // }else{
  844. // $value['实际投料'] = number_format($value['实际投料']/10000,4);
  845. // }
  846. // $data[$key]['实际投料'] = $value['实际投料'];
  847. $len = stripos($value['yj_tlgg'],'/');
  848. if ($len){
  849. $name = substr($value['yj_tlgg'],0,$len);
  850. $len_two = stripos($value['yj_tlgg'],'(');
  851. if ($len_two){
  852. $name = substr($name,0,$len_two);
  853. }
  854. $data[$key]['yj_tlgg'] = $name;
  855. }
  856. $data[$key]['rate'] = '';
  857. }
  858. $this->success('请求成功',$data);
  859. }
  860. /**
  861. * 更新工单实际投料
  862. * @ApiMethod POST
  863. * @params int UniqId
  864. * @params string number
  865. */
  866. public function updateOrderFeed(){
  867. if (Request::instance()->isPost() == false) {
  868. $this->error('非法请求');
  869. }
  870. $params = Request::instance()->post();
  871. if (!isset($params[0]['UniqId']) || empty($params[0]['UniqId'])){
  872. $this->error('参数错误');
  873. }
  874. $i = 0;
  875. $list = \db('物料_收发记录')->where('Uniqid',$params['0']['UniqId'])->find();
  876. foreach ($params as $key=>$value){
  877. if (!empty($value['number'])){
  878. $tl_sql = \db('物料_收发记录')
  879. ->where('Uniqid',$value['UniqId'])
  880. ->fetchSql(true)
  881. ->update(['st_sl'=>$value['number']]);
  882. $tlRes = Db::query($tl_sql);
  883. if (!$tlRes){
  884. $i++;
  885. }
  886. }
  887. }
  888. $total_num = \db('物料_收发记录')
  889. ->alias('a')
  890. ->field('SUM(a.st_sl) as 投料数量,b.yj_ls,b.yj_ks')
  891. ->join('工单_印件资料 b','a.st_gdbh = b.Yj_Gdbh AND a.cpdh = b.yj_yjdh')
  892. ->where('a.st_gdbh',$list['st_gdbh'])
  893. ->where('a.cpdh',$list['cpdh'])
  894. ->where('a.仓库编号','Y101')
  895. ->find();
  896. $number = $total_num['投料数量']/10000*$total_num['yj_ls']*$total_num['yj_ks'];
  897. $res_sql = db('工单_基本资料')->where('Gd_gdbh',$list['st_gdbh'])->where('Gd_cpdh',$list['cpdh'])->fetchSql(true)->setField('实际投料',$number);
  898. $res = Db::query($res_sql);
  899. $data['yj_实际投料'] = $number;
  900. $yj_sql =db('工单_印件资料')->where('Yj_Gdbh',$list['st_gdbh'])->where('yj_Yjdh',$list['cpdh'])->fetchSql(true)->update($data);
  901. $yjRes = Db::query($yj_sql);
  902. // if ((int)$list['yj_ls'] !== 0 && (int)$list['yj_ks'] !== 0){
  903. // $tl_num = number_format(((float)$value['number']*10000)/((int)$list['yj_ks']*(int)$list['yj_ls']),4);
  904. // }else{
  905. // $tl_num = (float)$value['number']*10000;
  906. // }
  907. // $tl_num = (float)str_replace(',', '', $tl_num);
  908. if ($i != 0){
  909. $this->success('更新成功');
  910. }else{
  911. $this->error('更新失败');
  912. }
  913. }
  914. /**
  915. * 工单工序产量统计
  916. * @ApiMethod GET
  917. * @params string order
  918. */
  919. public function getOrderProcessCount(){
  920. if (Request::instance()->isGet() == false) {
  921. $this->error('非法请求');
  922. }
  923. $params = Request::instance()->request();
  924. if (empty($params['order']) || empty($params['order'])) {
  925. $this->error('参数错误');
  926. }
  927. $order = $params['order'];
  928. $sql = "SELECT a.Gy0_yjno,a.Gy0_gxh,rtrim(a.Gy0_gxmc) as Gy0_gxmc,rtrim(a.Add_gxmc) as Add_gxmc,a.Gy0_计划接货数, a.Gy0_ls,a.Gy0_sbbh,a.PD_WG,SUM(b.sczl_cl) as sczl_cl,
  929. SUM(b.sczl_zcfp) as sczl_zcfp,SUM(b.sczl_来料少数) as 来料异常,COUNT(DISTINCT b.sczl_num) as process_num,b.sczl_Pgcl,SUM(c.sczl_cl) as cl,b.sczl_rq
  930. FROM `工单_工艺资料` a
  931. LEFT JOIN `设备_产量计酬` b ON a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh
  932. LEFT JOIN db_sczl c ON a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh
  933. WHERE a.Gy0_gdbh = '{$order}' GROUP BY a.Gy0_yjno, a.Gy0_gxh ORDER BY a.Gy0_yjno, a.Gy0_gxh";
  934. $data = Db::query($sql);
  935. //手检数据
  936. $handData =db('db_手工检验')->where('sczl_gdbh',$order)->field('sum(sczl_cl) as cl,rtrim(sczl_yjgx) as sczl_gxh')->select();
  937. //包装及成品防护数据
  938. $sql = "SELECT sczl_gdbh1,sczl_gdbh2,sczl_gdbh3,sczl_gdbh4,sczl_gdbh5,sczl_gdbh6,rtrim(sczl_gxmc1) as sczl_gxmc1,rtrim(sczl_gxmc2) as sczl_gxmc2,
  939. rtrim(sczl_gxmc3) as sczl_gxmc3,rtrim(sczl_gxmc4) as sczl_gxmc4,rtrim(sczl_gxmc5) as sczl_gxmc5,rtrim(sczl_gxmc6) as sczl_gxmc6,
  940. sczl_cl1,sczl_cl2,sczl_cl3,sczl_cl4,sczl_cl5,sczl_cl6,sczl_PgCl1,sczl_PgCl2,sczl_PgCl3,sczl_PgCl4,sczl_PgCl5,sczl_PgCl6
  941. FROM `db_包装计件` WHERE `sczl_gdbh1` LIKE '%{$order}%' OR `sczl_gdbh2` LIKE '%{$order}%'
  942. OR `sczl_gdbh3` LIKE '%{$order}%' OR `sczl_gdbh4` LIKE '%{$order}%' OR `sczl_gdbh5` LIKE '%{$order}%' OR `sczl_gdbh6` LIKE '%{$order}%'";
  943. $package = Db::query($sql);
  944. $list = [];
  945. $j = 0;
  946. foreach ($package as $value){
  947. for ($i = 1; $i <= 6; $i++) {
  948. $gdbhlKey = "sczl_gdbh" . $i;
  949. $gxmcKey = "sczl_gxmc" . $i;
  950. $clKey = "sczl_cl" . $i;
  951. $pgclKey = "sczl_PgCl" . $i;
  952. if ($value[$gdbhlKey] == '2311743' && $value[$clKey] > 0) {
  953. $list[$j]['sczl_gdbh'] = $value[$gdbhlKey];
  954. $list[$j]['sczl_gxmc'] = $value[$gxmcKey];
  955. $list[$j]['sczl_cl'] = $value[$clKey];
  956. $list[$j]['sczl_PgCl'] = $value[$pgclKey];
  957. $j++;
  958. }
  959. }
  960. }
  961. // 创建一个关联数组,用于存储相同 sczl_gxmc 的值和对应的乘积之和
  962. $sumArray = [];
  963. foreach ($list as $item) {
  964. $key = $item['sczl_gxmc'];
  965. $cl = floatval($item['sczl_cl']);
  966. $pgCl = intval($item['sczl_PgCl']);
  967. $product = $cl * $pgCl;
  968. if (!isset($sumArray[$key])) {
  969. $sumArray[$key] = 0;
  970. }
  971. $sumArray[$key] += $product;
  972. }
  973. $handGxh = substr($handData[0]['sczl_gxh'],-2);
  974. foreach ($data as $key=>$item){
  975. $data[$key]['折算车头产量'] = $item['Gy0_计划接货数'];
  976. $data[$key]['Gy0_计划接货数'] = $item['Gy0_计划接货数']*$item['Gy0_ls'];
  977. $data[$key]['制程废品率'] = '';
  978. if ($item['sczl_zcfp'] > 0){
  979. $data[$key]['制程废品率'] = number_format($item['sczl_zcfp']/$item['sczl_cl']*100,4).'%';
  980. }
  981. if ($item['cl'] > 0){
  982. $data[$key]['sczl_cl'] = $item['cl'];
  983. }
  984. if ($item['sczl_Pgcl'] > 0){
  985. $data[$key]['sczl_cl'] = $item['sczl_cl'] * $item['sczl_Pgcl'];
  986. }
  987. if ($item['Gy0_gxh'] == (int)$handGxh){
  988. $data[$key]['sczl_cl'] = $handData[0]['cl'];
  989. }
  990. foreach ($sumArray as $k=>$v){
  991. if ($item['Gy0_gxmc'] == $k){
  992. $data[$key]['sczl_cl'] = $v;
  993. }
  994. }
  995. if (substr($item['PD_WG'],0,4) == '1900'){
  996. $data[$key]['PD_WG'] = '计划';
  997. }else{
  998. $data[$key]['PD_WG'] = '完工';
  999. }
  1000. }
  1001. $this->success('请求成功',$data);
  1002. }
  1003. }