OrderSuperLoss.php 114 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use think\Cache;
  5. use think\Exception;
  6. use think\Log;
  7. use think\Queue;
  8. use \think\Request;
  9. use \think\Db;
  10. /**
  11. * 工单超节损核算接口
  12. */
  13. class OrderSuperLoss extends Api
  14. {
  15. protected $noNeedLogin = ['*'];
  16. protected $noNeedRight = ['*'];
  17. /**
  18. * 首页-已核查成品编号
  19. *
  20. */
  21. public function index()
  22. {
  23. $this->success('请求成功');
  24. }
  25. /**
  26. * 获取左侧菜单栏
  27. * @ApiMethod GET
  28. */
  29. public function getTab()
  30. {
  31. if (Request::instance()->isGet() == false) {
  32. $this->error('非法请求');
  33. }
  34. $sql = "SELECT
  35. DATE_FORMAT(a.jjcp_sj, '%Y-%m') AS date, -- Format the date for grouping
  36. RTRIM(b.`编号`) AS 编号,
  37. RTRIM(b.`名称`) AS 客户名称,
  38. COUNT(DISTINCT a.jjcp_gdbh) AS count
  39. FROM
  40. `成品入仓` a
  41. LEFT JOIN
  42. `物料_存货结构` b
  43. ON (CASE
  44. WHEN LEFT(a.`jjcp_cpdh`, 1) REGEXP '^[A-Za-z]' THEN LEFT(a.`jjcp_cpdh`, 5)
  45. ELSE LEFT(a.`jjcp_cpdh`, 4)
  46. END) = RTRIM(b.`编号`) -- Conditional join based on the first character
  47. WHERE
  48. a.jjcp_sj >= DATE_SUB(CURDATE(), INTERVAL 12 MONTH) -- Direct date comparison
  49. AND (a.jjcp_smb IN ('末 板', '末板')) -- Cleaner syntax for conditions
  50. AND a.`成品编码` != ''
  51. AND a.jjcp_sj >= '2025-01-01 00:00:00'
  52. GROUP BY
  53. DATE_FORMAT(a.jjcp_sj, '%Y-%m'), -- Group by formatted date
  54. RTRIM(b.`编号`)
  55. ORDER BY
  56. date DESC,
  57. 编号 ASC;";
  58. $data = Db::query($sql);
  59. // $data = \db('工单_质量考核汇总')
  60. // ->field([
  61. // 'sys_ny AS date',
  62. // 'CASE
  63. // WHEN 产品代号 REGEXP \'[A-Za-z]\' THEN LEFT(产品代号, 5)
  64. // ELSE LEFT(产品代号, 4)
  65. // END AS 编号',
  66. // '客户名称',
  67. // 'COUNT(DISTINCT Gy0_gdbh) AS count'
  68. // ])
  69. // ->group('编号, date')
  70. // ->order('date desc,编号')
  71. // ->select();
  72. // 创建一个新数组来存储整理后的数据
  73. $organizedData = [];
  74. // 遍历原始数据
  75. foreach ($data as $entry) {
  76. $date = date('Ym',strtotime($entry['date']));
  77. // 检查日期是否在已整理数据中存在
  78. if (isset($organizedData[$date])) {
  79. // 如果日期存在,将数据追加到该日期下
  80. $organizedData[$date][] = [
  81. '客户名称' => $entry['客户名称'],
  82. '客户编号' => $entry['编号'],
  83. 'total' => $entry['count'],
  84. ];
  85. // 统计该日期下所有数据的总和
  86. $organizedData[$date]['total_count'] += $entry['count'];
  87. } else {
  88. // 如果日期不存在,创建新的日期项并添加数据
  89. $organizedData[$date] = [
  90. [
  91. '客户名称' => $entry['客户名称'],
  92. '客户编号' => $entry['编号'],
  93. 'total' => $entry['count'],
  94. ]
  95. ];
  96. // 初始化该日期的总和
  97. $organizedData[$date]['total_count'] = $entry['count'];
  98. }
  99. }
  100. // 将整理后的数据调整为以日期和相加的总和为索引的格式
  101. $finalData = [];
  102. foreach ($organizedData as $date => $entries) {
  103. $totalCount = $entries['total_count'];
  104. $index = $date . '-' . $totalCount;
  105. unset($entries['total_count']);
  106. $finalData[$index] = $entries;
  107. }
  108. $this->success('请求成功',$finalData);
  109. }
  110. /**
  111. * 获取超节损工单列表
  112. * @ApiMethod GET
  113. * @params string date
  114. * @params string code
  115. * 报废定额=(基础损耗+损耗率*计划产量)*损耗系数*计损色数(特定工序会有,如果无就不乘)
  116. * 允损比例=报废定额/计划产量
  117. * 目标合格率 = 100%-超节损工单中显示工序的允损比例之和
  118. * 节损奖 小盒0.02 大盒0.09
  119. *
  120. */
  121. // public function getList(){
  122. // if (Request::instance()->isGet() == false) {
  123. // $this->error('非法请求');
  124. // }
  125. // $params = Request::instance()->param();
  126. // $where = [];
  127. // if (!empty($params['code'])) {
  128. // if (!empty($params['search'])) {
  129. // $this->error('参数错误');
  130. // }
  131. // }
  132. // if (!empty($params['date'])) {
  133. // if (!empty($params['search'])) {
  134. // $this->error('参数错误');
  135. // }
  136. // $date_year = substr($params['date'],0,4);
  137. // $date_mon = substr($params['date'],4);
  138. // $date = $date_year.'-'.$date_mon;
  139. // $where['a.jjcp_sj' ] = array('like',$date.'%');
  140. // }
  141. // if (!empty($params['search'])) {
  142. // if (!empty($params['date']) || !empty($params['code'])) {
  143. // $this->error('参数错误');
  144. // }
  145. // $where['a.jjcp_gdbh|a.成品名称|a.jjcp_cpmc'] = array('like','%'.$params['search'].'%');
  146. // }
  147. // $where['a.jjcp_smb' ] = array('IN', array('末 板', '末板'));
  148. // $limit = $params['limit'];
  149. // if (empty($limit)){
  150. // $limit = 15;
  151. // }
  152. // $pages = $params['page'];
  153. // if (empty($pages)){
  154. // $pages = 1;
  155. // }
  156. // $is_have_cache = false;
  157. // $num = config('product_code_digit');
  158. // if ($is_have_cache === false){
  159. // if (!empty($params['code'])){
  160. // $sql= db('物料_收发记录')
  161. // ->alias('d')
  162. // ->where('d.仓库编号', 'Y101')
  163. // ->whereOr('d.仓库编号', '101')
  164. // ->group('d.st_gdbh, d.cpdh')
  165. // ->field('d.st_gdbh, d.cpdh,d.st_rq, SUM(d.st_sl) as 实际投料,d.仓库编号')
  166. // ->buildSql();
  167. // $data = db('成品入仓')->alias('a')
  168. // ->join('工单_基本资料 b', 'a.jjcp_gdbh = b.Gd_gdbh', 'left')
  169. // ->join('工单_印件资料 c', 'a.jjcp_gdbh = c.Yj_Gdbh AND a.jjcp_cpdh = c.yj_Yjdh', 'left')
  170. // ->join([$sql => 'd'], 'a.jjcp_gdbh = d.st_gdbh AND a.jjcp_cpdh = d.cpdh', 'left')
  171. // ->where($where)
  172. // ->where(function($query) {
  173. // $query->where('d.仓库编号', '101')
  174. // ->whereOr('d.仓库编号', 'Y101');})
  175. // ->whereRaw('LEFT(a.成品编码, CASE WHEN a.成品编码 REGEXP "[a-zA-Z]" THEN 5 ELSE 4 END) = ?', [$params['code']])
  176. // ->field('a.jjcp_gdbh as Gd_gdbh, a.jjcp_yjno, rtrim(a.jjcp_cpdh) as 成品编码, rtrim(a.jjcp_cpmc) as 成品名称,
  177. // a.jjcp_sj, a.jjcp_smb, b.计量单位, b.Gd_khdh, d.实际投料, c.yj_Yjno, c.yj_ls, c.yj_ks, c.质量考核')
  178. // ->group('a.jjcp_gdbh, a.jjcp_yjno')
  179. // ->order('b.Gd_khdh, a.成品编码 asc, a.jjcp_yjno,d.st_rq desc')
  180. // ->page($pages)
  181. // ->limit($limit)
  182. // ->select();
  183. // $total = db('成品入仓')->alias('a')
  184. // ->join('工单_基本资料 b', 'a.jjcp_gdbh = b.Gd_gdbh','left')
  185. // ->join('工单_印件资料 c', 'a.jjcp_gdbh = c.Yj_Gdbh','left')
  186. // ->where($where)
  187. // ->whereRaw('LEFT(a.成品编码, CASE WHEN a.成品编码 REGEXP "[a-zA-Z]" THEN 5 ELSE 4 END) = ?', [$params['code']])
  188. // ->count();
  189. // }else{
  190. // $sql= db('物料_收发记录')
  191. // ->alias('d')
  192. // ->where('d.仓库编号', 'Y101')
  193. // ->whereOr('d.仓库编号', '101')
  194. // ->group('d.st_gdbh, d.cpdh')
  195. // ->field('d.st_gdbh, d.cpdh,d.st_rq, SUM(d.st_sl) as 实际投料,d.仓库编号')
  196. // ->buildSql();
  197. // $data = db('成品入仓')->alias('a')
  198. // ->join('工单_基本资料 b', 'a.jjcp_gdbh = b.Gd_gdbh', 'left')
  199. // ->join('工单_印件资料 c', 'a.jjcp_gdbh = c.Yj_Gdbh AND a.jjcp_cpdh = c.yj_Yjdh', 'left')
  200. // ->join([$sql => 'd'], 'a.jjcp_gdbh = d.st_gdbh AND a.jjcp_cpdh = d.cpdh', 'left')
  201. // ->where($where)
  202. // ->field('a.jjcp_gdbh as Gd_gdbh, a.jjcp_yjno, rtrim(a.jjcp_cpdh) as 成品编码, rtrim(a.jjcp_cpmc) as 成品名称,
  203. // a.jjcp_sj, a.jjcp_smb, b.计量单位, b.Gd_khdh, d.实际投料, c.yj_Yjno, c.yj_ls, c.yj_ks, c.质量考核')
  204. // ->group('a.jjcp_gdbh, a.jjcp_yjno')
  205. // ->order('b.Gd_khdh, a.成品编码 asc, a.jjcp_yjno, d.st_rq desc')
  206. // ->page($pages)
  207. // ->limit($limit)
  208. // ->select();
  209. // $total = db('成品入仓')->alias('a')
  210. // ->join('工单_基本资料 b', 'a.jjcp_gdbh = b.Gd_gdbh','left')
  211. // ->join('工单_印件资料 c', 'a.jjcp_gdbh = c.Yj_Gdbh','left')
  212. // ->where($where)
  213. // ->count();
  214. // }
  215. // foreach ($data as $key => $value){
  216. // //查出成品数量及日期
  217. // $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";
  218. // $cp_data = Db::query($cp_sql);
  219. // //入仓总数
  220. // $data[$key]['warehousing_num'] = $cp_data[0]['cp_sl'];
  221. // $data[$key]['warehousing_date'] = substr($cp_data[0]['jjcp_sj'],0,10);
  222. // //查出进入超节损的工序,有上报产量的工序就进入超节损
  223. // $gxh_sql = "SELECT sczl_gxh FROM
  224. // (SELECT sczl_gxh FROM 设备_产量计酬 WHERE sczl_gdbh = '{$value['Gd_gdbh']}' AND sczl_yjno = '{$value['jjcp_yjno']}'
  225. // UNION SELECT sczl_gxh FROM db_sczl WHERE sczl_gdbh = '{$value['Gd_gdbh']}' AND sczl_yjno = '{$value['jjcp_yjno']}') AS combined_result";
  226. // $gxh_arr = Db::query($gxh_sql);
  227. // $gxh_values = array_column($gxh_arr, 'sczl_gxh');
  228. // $gy_data =db('工单_工艺资料')
  229. // ->alias('a')
  230. // ->field([
  231. // '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_计划接货数',
  232. // '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',
  233. // ])
  234. // ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
  235. // ->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')
  236. // ->where([
  237. // 'a.Gy0_gdbh' => $value['Gd_gdbh'],
  238. // 'a.Gy0_yjno' =>$value['jjcp_yjno'],
  239. // 'a.Gy0_gxh' => ['in', $gxh_values]
  240. // ])
  241. // ->group('a.Gy0_yjno,a.Gy0_gxh')
  242. // ->select();
  243. // $arr = [];
  244. // $plan_loss = [];//工单计划损耗
  245. // $machine_plan_loss = 0;//机检计划损耗
  246. // foreach ($gy_data as $k=>$v){
  247. // if (strpos($v['Gy0_gxmc'],'检') === false){
  248. // if ($v['Gy0_计划接货数'] > 0){
  249. // $rate = round($v['Gy0_计划损耗'] / $v['Gy0_计划接货数'],5);
  250. // }else{
  251. // $rate = 0;
  252. // }
  253. // $arr[$k] = floor($rate * 10000) /10000;
  254. // $plan_loss[$k] = $v['Gy0_计划损耗']*$v['Gy0_ls']*$value['yj_ks'];
  255. // }
  256. // }
  257. // if ((int)$value['yj_ls'] > 0){
  258. // $value['实际投料'] = number_format(((int)$value['实际投料']/10000)*$value['yj_ls']*$value['yj_ks'],4);
  259. // }else{
  260. // $value['实际投料'] = number_format($value['实际投料']/10000,4);
  261. // }
  262. // $data[$key]['实际投料'] = $value['实际投料'];
  263. // if ($value['实际投料'] >0 ){
  264. // $target_rate = (1-array_sum($arr))*100;
  265. // $data[$key]['target_rate'] =$target_rate.'%'; //目标合格率
  266. // $real_rate = $cp_data[0]['cp_sl'] / ((float)str_replace(',', '', $value['实际投料']) * 10000) *100;
  267. // $data[$key]['real_rate'] = number_format($real_rate,2) . '%';//实际合格率
  268. // }else{
  269. // $data[$key]['target_rate'] = ''; //目标合格率
  270. // $data[$key]['real_rate'] = '';//实际合格率
  271. // }
  272. //
  273. // //制程废品
  274. // $zzfp_data =db('设备_产量计酬')->where('sczl_gdbh',$value['Gd_gdbh'])->where('sczl_yjno',$value['jjcp_yjno'])->value('SUM(sczl_zcfp) as sczl_zcfp');
  275. // $data[$key]['zcfp'] = $zzfp_data * $value['yj_ls'];//制程废品
  276. // //废品合计
  277. // $wasteTotal = db('db_qczl')->where('qczl_gdbh',$value['Gd_gdbh'])->where('qczl_yjno',$value['jjcp_yjno'])->sum('qczl_fp');
  278. // if (empty($wasteTotal)){
  279. // $wasteTotal = 0;
  280. // }
  281. // $data[$key]['废品合计'] = $wasteTotal + $data[$key]['zcfp'];//废品合计
  282. // $data[$key]['工单无形损'] = (int)((float)str_replace(',', '', $value['实际投料']) *10000) - $cp_data[0]['cp_sl'] - $data[$key]['废品合计'];//工单无形损
  283. // $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,
  284. // 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,
  285. // 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,
  286. // 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
  287. // FROM db_qczl WHERE qczl_gdbh = '{$value['Gd_gdbh']}' AND qczl_yjno = '{$value['jjcp_yjno']}'";
  288. // $waste_out = Db::query($out_sql);
  289. // $list = []; //外发废数组
  290. // $quality = [];//质检废数组
  291. // $material = [];//材料废数组
  292. // $change = [];//零头处理数组
  293. // $machine = [];//机检废品数组
  294. // $j = 0;
  295. // $m = 0;
  296. // $n = 0;
  297. // $l = 0;
  298. // $o = 0;
  299. // foreach ($waste_out as $entry) {
  300. // for ($i = 1; $i <= 13; $i++) {
  301. // $labelKey = "fp_lb" . $i;
  302. // $bhKey = "fp_bh" . $i;
  303. // $gxmcKey = "fp_gxmc" . $i;
  304. // $slKey = "fp_sl" . $i;
  305. // if (!empty($entry[$labelKey])) {
  306. // //外发加工废
  307. // if (substr($entry[$labelKey],0,3) == 'M04'){
  308. // $list[$j]= $entry[$slKey];
  309. // $j++;
  310. // }
  311. // //材料废
  312. // if (substr($entry[$labelKey],0,1) == 'L' ){
  313. // $material[$n]= $entry[$slKey];
  314. // $n++;
  315. // }
  316. // //零头处理
  317. // if (substr($entry[$labelKey],0,3) == 'M01' ){
  318. // $change[$l]= $entry[$slKey];
  319. // $l++;
  320. // }
  321. //
  322. // //机检废品
  323. // if (substr($entry[$labelKey],0,1) == 'K' ){
  324. // $machine[$o]= $entry[$slKey];
  325. // $o++;
  326. // }
  327. // }
  328. // $quality[$m]= $entry[$slKey];
  329. // $m++;
  330. // }
  331. // }
  332. // $machine_waste = array_sum($machine);//机检废品
  333. // if ($data[$key]['Gd_gdbh'] == '2401746'){
  334. // halt($machine_waste);
  335. // }
  336. // $data[$key]['工单计划损耗'] = array_sum($plan_loss);//工单计划损耗
  337. // /**
  338. // * 奖惩系数及金额
  339. // * 奖惩金额 = 工单节损数 * 0.02(0.09)
  340. // * 工单节损数 = 工单计划损耗 - 废品总数 - 机检节损数
  341. // * 机检节损数 = 机检计划损耗 - 机检质检废品
  342. // */
  343. // $machine_loss = $machine_plan_loss - $machine_waste;
  344. // $order_loss = $data[$key]['工单计划损耗'] - ($data[$key]['废品合计'] - array_sum($list) - array_sum($material)+$data[$key]['工单无形损'] - $machine_waste);
  345. // $guige = \db('物料_存货编码')
  346. // ->where('物料代码',$data[$key]['成品编码'])
  347. // ->value('rtrim(规格)');
  348. // //工序超节损金额
  349. // if ($guige === '小盒'){
  350. // $moneyRate = 0.02;
  351. // }else{
  352. // $moneyRate = 0.09;
  353. // }
  354. // $reward = $order_loss * $moneyRate;
  355. // $data[$key]['reward_rate'] = '1';
  356. // if ($data[$key]['质量考核'] === 0){
  357. // $data[$key]['reward_money'] = number_format($reward,2);
  358. // $data[$key]['考核'] = '是';
  359. // }else{
  360. // $data[$key]['reward_money'] = '';
  361. // $data[$key]['考核'] = '否';
  362. // }
  363. // $data[$key]['材料废'] = array_sum($material); //材料废
  364. // $data[$key]['零头处理'] = array_sum($change); //零头处理
  365. // $data[$key]['外发废'] = array_sum($list);//外发废
  366. // $data[$key]['分摊废'] = '';//分摊废
  367. // $data[$key]['工单质检废'] = array_sum($quality); //质检废
  368. // $data[$key]['机检废'] = $machine_waste;
  369. // }
  370. // $res = [
  371. // 'data'=>$data,
  372. // 'total' => $total
  373. // ];
  374. //
  375. // }
  376. // $this->success('请求成功',$res);
  377. // }
  378. /**
  379. * 获取工单超节损工艺
  380. * @ApiMethod GET
  381. * @params string order
  382. */
  383. public function getOrderSuperLossGy(){
  384. if (Request::instance()->isGet() == false) {
  385. $this->error('非法请求');
  386. }
  387. $params = Request::instance()->param();
  388. if (!isset($params['order']) || empty($params['order'])) {
  389. $this->error('参数错误');
  390. }
  391. if (!isset($params['yjno']) || empty($params['yjno'])) {
  392. $this->error('参数错误');
  393. }
  394. $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,
  395. a.Gy0_ls,a.Gy0_Rate0,a.Gy0_Rate1,a.损耗系数,a.Gy0_ms,a.Gy0_计划接货数*a.Gy0_ls as Gy0_计划接货数,
  396. a.Gy0_计划损耗*a.Gy0_ls as Gy0_计划损耗,sum(b.sczl_cl) as total_cl,sum(b.sczl_zcfp) as total_fp,
  397. sum(c.sczl_cl) as cl,SUM(c.sczl_fp) as fp,rtrim(a.印刷方式) as 印刷方式,rtrim(a.版距) as 版距
  398. FROM `工单_工艺资料` a
  399. LEFT JOIN `设备_产量计酬` b ON a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_gxh = b.sczl_gxh
  400. LEFT JOIN `db_sczl` c ON a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_gxh = c.sczl_gxh
  401. WHERE a.Gy0_gdbh = '{$params['order']}' AND a.Gy0_yjno = '{$params['yjno']}' GROUP BY a.Gy0_gxh";
  402. $data = Db::query($sql);
  403. foreach ($data as $key=>$value){
  404. if (!empty($value['total_cl'])){
  405. $data[$key]['total_cl'] = $value['total_cl'] *$value['Gy0_ls'];
  406. }else{
  407. $data[$key]['total_cl'] =$value['cl'] *$value['Gy0_ls'];
  408. }
  409. if (!empty($value['total_fp'])){
  410. $data[$key]['total_fp'] = $value['total_fp'] *$value['Gy0_ls'];
  411. }else{
  412. $data[$key]['total_fp'] = $value['fp'] *$value['Gy0_ls'];
  413. }
  414. if ($value['印刷方式'] === '卷对卷'){
  415. $data[$key]['total_cl'] = ceil($data[$key]['total_cl'] / $value['版距']*1000);
  416. $data[$key]['total_fp'] = ceil($data[$key]['total_fp'] / $value['版距']*1000);
  417. }
  418. unset($data[$key]['cl']);
  419. unset($data[$key]['fp']);
  420. }
  421. $this->success('请求成功',$data);
  422. }
  423. /**
  424. * 工单超节损统计
  425. * @ApiMethod GET
  426. * @params string order
  427. * 节损奖 小盒0.02 大盒0.09
  428. */
  429. public function getOrderSuperLossCount(){
  430. if (Request::instance()->isGet() == false) {
  431. $this->error('非法请求');
  432. }
  433. $params = Request::instance()->param();
  434. if (!isset($params['order']) || empty($params['order'])) {
  435. $this->error('参数错误');
  436. }
  437. $order = $params['order'];
  438. $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 投料';
  439. $data =db('工单_基本资料')
  440. ->alias('a')
  441. ->join('物料_收发记录 b','a.Gd_gdbh = b.st_gdbh AND a.Gd_cpdh = b.cpdh')
  442. ->join('工单_印件资料 c','c.Yj_Gdbh = a.Gd_gdbh AND c.yj_Yjdh = a.Gd_cpdh')
  443. ->where('a.Gd_Gdbh',$order)
  444. ->where('a.行号',$params['yjno'])
  445. ->where('c.yj_Yjno',$params['yjno'])
  446. ->where(function($query) {
  447. $query->where('b.仓库编号', '101')
  448. ->whereOr('b.仓库编号', 'Y101');})
  449. ->field($field)
  450. ->find();
  451. if ($data['ls'] == 0){
  452. $data['ls'] === 1;
  453. }
  454. if ($data['ks'] == 0){
  455. $data['ks'] === 1;
  456. }
  457. $data['实际投料'] = number_format($data['投料'] * $data['ls'] * $data['ks'] / 10000, 4, '.', '');
  458. if($data['实际投料'] == 0){
  459. $this->error('投料数据为 0,请点击超节损页面“修正工单投料”按钮进行修正');
  460. return;
  461. }
  462. //查出成品数量及日期
  463. $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";
  464. $cp_data = Db::query($cp_sql);
  465. if (empty($cp_data)){
  466. $this->success('此工单未查询到成品入库信息,请核查该工单是否已进入超节损');
  467. }
  468. $data['warehousing_num'] = $cp_data[0]['cp_sl'];
  469. $data['warehousing_date'] = substr($cp_data[0]['jjcp_sj'],0,10);
  470. //查出进入超节损的工序,有上报产量的工序就进入超节损
  471. $gxh_sql = "SELECT sczl_gxh FROM
  472. (SELECT sczl_gxh FROM 设备_产量计酬 WHERE sczl_gdbh = '{$order}' AND sczl_yjno = '{$params['yjno']}'
  473. UNION SELECT sczl_gxh FROM db_sczl WHERE sczl_gdbh = '{$order}' AND sczl_yjno = '{$params['yjno']}' AND sczl_gxmc like '%拆片%') AS combined_result";
  474. $gxh_arr = Db::query($gxh_sql);
  475. $gxh_values = array_column($gxh_arr, 'sczl_gxh');
  476. foreach ($gxh_values as $k=>$v){
  477. if ((int)$v < 10){
  478. $gxh_values[$k] = '0'.$v;
  479. }
  480. }
  481. $gy_data =db('工单_工艺资料')
  482. ->alias('a')
  483. ->field([
  484. '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_计划接货数*a.Gy0_ls as Gy0_计划接货数',
  485. 'a.Gy0_计划损耗', 'a.无形损承担比例','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',
  486. ])
  487. ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
  488. ->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')
  489. ->where([
  490. 'a.Gy0_gdbh' => $order,
  491. 'a.Gy0_yjno' => $params['yjno'],
  492. 'a.Gy0_gxh' => ['in', $gxh_values]
  493. ])
  494. ->group('a.Gy0_yjno,a.Gy0_gxh')
  495. ->select();
  496. $arr = [];
  497. $plan_loss = [];//工单计划损耗
  498. foreach ($gy_data as $k=>$v){
  499. $rate = round($v['Gy0_计划损耗'] / $v['Gy0_计划接货数'],5);
  500. $arr[$k] = floor($rate * 10000) /10000;
  501. $plan_loss[$k] = $v['Gy0_计划损耗'];
  502. }
  503. $target_rate = (1-array_sum($arr))*100;
  504. $data['target_rate'] =$target_rate.'%'; //目标合格率
  505. $real_rate = $cp_data[0]['cp_sl'] / ((float)$data['实际投料'] * 10000) *100;
  506. $data['real_rate'] = number_format($real_rate,2) . '%';//实际合格率
  507. //制程废品
  508. $zzfp_data =db('设备_产量计酬')->where('sczl_gdbh',$order)->where('sczl_yjno',$params['yjno'])->value('SUM(sczl_zcfp) as sczl_zcfp');
  509. //联数
  510. $ls =db('工单_工艺资料')->where('Gy0_gdbh',$order)->field('Gy0_ls,Gy0_ks')->find();
  511. //制程废品*ls
  512. $data['zcfp'] = $zzfp_data * $ls['Gy0_ls'] * $ls['Gy0_ks'];
  513. //废品数量
  514. $wasteTotal = db('db_qczl')->where('qczl_gdbh',$order)->where('qczl_yjno',$params['yjno'])->sum('qczl_fp');
  515. if (empty($wasteTotal)){
  516. $wasteTotal = 0;
  517. }
  518. //废品合计
  519. $waste_total = $data['zcfp'] + $wasteTotal;
  520. //工单无形损
  521. $data['intangible_loss'] = (int)((float)$data['实际投料'] *10000 - $cp_data[0]['cp_sl'] - $waste_total);
  522. $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,
  523. 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,
  524. 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,
  525. 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
  526. FROM db_qczl WHERE qczl_gdbh = '{$order}' AND qczl_yjno = '{$params['yjno']}'";
  527. $waste_out = Db::query($out_sql);
  528. $list = []; //外发废数组
  529. $quality = [];//质检废数组
  530. $material = [];//材料废数组
  531. $change = [];//零头处理数组
  532. $jijian = [];//机检数据
  533. $j = 0;
  534. $m = 0;
  535. $n = 0;
  536. $l = 0;
  537. $s = 0;
  538. foreach ($waste_out as $entry) {
  539. for ($i = 1; $i <= 13; $i++) {
  540. $labelKey = "fp_lb" . $i;
  541. $bhKey = "fp_bh" . $i;
  542. $gxmcKey = "fp_gxmc" . $i;
  543. $slKey = "fp_sl" . $i;
  544. if (!empty($entry[$labelKey])) {
  545. //外发废
  546. if (substr($entry[$labelKey],0,3) == 'M04'){
  547. $list[$j]= $entry[$slKey];
  548. $j++;
  549. }
  550. //材料废
  551. if (substr($entry[$labelKey],0,1) == 'L' ){
  552. $material[$n]= $entry[$slKey];
  553. $n++;
  554. }
  555. //零头处理
  556. if (substr($entry[$labelKey],0,3) == 'M01' ){
  557. $change[$l]= $entry[$slKey];
  558. $l++;
  559. }
  560. //机检数据
  561. if (substr($entry[$labelKey],0,1) == 'K' ){
  562. $jijian[$s]= $entry[$slKey];
  563. $s++;
  564. }
  565. }
  566. $quality[$m]= $entry[$slKey];
  567. $m++;
  568. }
  569. }
  570. $data['材料废'] = array_sum($material); //材料废
  571. $data['零头处理'] = array_sum($change); //零头处理
  572. $data['外发废'] = array_sum($list);//外发废
  573. $data['工单质检废'] = array_sum($quality);//质检废
  574. $data['机检废品'] = array_sum($jijian);
  575. $plan_total =db('工单_工艺资料')
  576. ->where(['Gy0_gdbh' => $order,'Gy0_yjno' => $params['yjno'], 'Gy0_gxh' => ['in', $gxh_values]])
  577. ->where('Gy0_gxmc','NOT LIKE','%检%')
  578. ->value('SUM(Gy0_计划损耗 * Gy0_ls * Gy0_ks)');
  579. if($plan_total == 0){
  580. $this->error('计划损耗数据为 0,请到工单资料管理页面修改工艺资料中选择正确的工序损耗');
  581. return;
  582. }
  583. //单据列表最后统计
  584. $total = [];
  585. $total['plan_loss'] = 0;
  586. $total['total_fp'] = 0;
  587. $total['waste_quality'] = 0;
  588. $total['waste_intangible'] = 0;
  589. $total['reward'] = 0; //超节损奖励数组
  590. //按工序打印
  591. if ($params['type'] == 1){
  592. $total['total_waste'] = 0;
  593. $total['loss'] = 0;
  594. foreach ($gy_data as $k=>$item){
  595. $gy_data[$k]['Gy0_计划损耗'] = $item['Gy0_计划损耗']*$item['Gy0_ls']*$item['Gy0_ks'];
  596. $gy_data[$k]['waste_quality'] = 0;
  597. $gy_data[$k]['total_fp'] = $item['total_fp'] * $item['Gy0_ls'];
  598. $gy_data[$k]['total_cl'] = $item['total_cl'] * $item['Gy0_ls'];
  599. //无形损
  600. if (floatval($item['无形损承担比例']) > 0){
  601. if (strpos($item['Gy0_gxmc'],'机检') === false){
  602. $gy_data[$k]['intangible_loss'] = round(number_format($gy_data[$k]['Gy0_计划损耗']/$plan_total,4) * $data['intangible_loss'] * floatval($item['无形损承担比例']));
  603. }else{
  604. $gy_data[$k]['intangible_loss'] = 0;
  605. }
  606. }else{
  607. if (strpos($item['Gy0_gxmc'],'机检') === false){
  608. $gy_data[$k]['intangible_loss'] = round(number_format($gy_data[$k]['Gy0_计划损耗']/$plan_total,4) * $data['intangible_loss']);
  609. }else{
  610. $gy_data[$k]['intangible_loss'] = 0;
  611. }
  612. }
  613. foreach ($waste_out as $entry) {
  614. for ($i = 1; $i <= 13; $i++) {
  615. $gxmcKey = "fp_gxmc" . $i;
  616. $slKey = "fp_sl" . $i;
  617. if (substr($entry[$gxmcKey],0,2) == $item['Gy0_gxh']){
  618. $gy_data[$k]['waste_quality'] += $entry[$slKey];
  619. }elseif (strpos($item['Gy0_gxmc'],'机检') !== false){
  620. $gy_data[$k]['waste_quality'] = $data['机检废品'];
  621. }
  622. }
  623. }
  624. //报废合计
  625. // if ($gy_data[$k]['intangible_loss'] < 0){
  626. // $gy_data[$k]['total_waste'] = $gy_data[$k]['waste_quality'] + $gy_data[$k]['total_fp'];
  627. // }else{
  628. $gy_data[$k]['total_waste'] = $gy_data[$k]['waste_quality'] + $gy_data[$k]['intangible_loss'] + $gy_data[$k]['total_fp'];
  629. // }
  630. //工序节损数
  631. $gy_data[$k]['loss'] = $item['Gy0_计划损耗']*$item['Gy0_ls']*$item['Gy0_ks'] - $gy_data[$k]['total_waste'];
  632. //占投料报废率
  633. $gy_data[$k]['loss_rate'] = number_format($gy_data[$k]['loss'] / $item['Gy0_计划接货数'],4) * 100 .'%';
  634. //工序目标报废率
  635. $target_loss_rate = floor($item['Gy0_计划损耗'] / $item['Gy0_计划接货数'] * 10000) / 10000;
  636. if ($target_loss_rate == 0){
  637. $target_loss_rate = round($item['Gy0_计划损耗'] / $item['Gy0_计划接货数'] * 10000) / 10000;
  638. }
  639. $gy_data[$k]['target_loss_rate'] = $target_loss_rate * 100 . '%';
  640. //工序实际报废率
  641. $gy_data[$k]['actual_loss_rate'] = number_format($gy_data[$k]['total_waste'] / ($data['实际投料']*10000),4) * 100 .'%';
  642. $gy_data[$k]['超节损承担比例'] = number_format($item['超节损承担比例'],4) * 100 .'%';
  643. $guige = \db('物料_存货编码')
  644. ->where('物料代码',$data['成品代号'])
  645. ->value('rtrim(规格)');
  646. //工序超节损金额
  647. if ($guige === '小盒'){
  648. $moneyRate = 0.02;
  649. }else{
  650. $moneyRate = 0.09;
  651. }
  652. if (strpos($item['Gy0_gxmc'],'机检') !== false){
  653. $gy_data[$k]['工序超节损金额'] = '0.000000';
  654. $gy_data[$k]['waste_quality'] = $data['机检废品'];
  655. }else{
  656. $gy_data[$k]['工序超节损金额'] = number_format($gy_data[$k]['loss'] * $item['超节损承担比例'] * $moneyRate,4);
  657. }
  658. $total['plan_loss'] += $gy_data[$k]['Gy0_计划损耗'];
  659. $total['total_fp'] += $gy_data[$k]['total_fp'];
  660. $total['waste_quality'] += $gy_data[$k]['waste_quality'];
  661. $total['waste_intangible'] += $gy_data[$k]['intangible_loss'];
  662. $total['total_waste'] += $gy_data[$k]['total_waste'];
  663. $total['loss'] += $gy_data[$k]['loss'];
  664. $total['reward'] += floatval(str_replace(',', '', $gy_data[$k]['工序超节损金额']));
  665. }
  666. $total['reward'] = number_format($total['reward'],2);
  667. $data['gy_data'] = $gy_data;
  668. $data['total'] = $total;
  669. $this->success('请求成功',$data);
  670. }else{ //按班组打印
  671. //总产量数据
  672. $total_cl_data = \db('工单_工艺资料')->alias('a')
  673. ->field(['a.Gy0_yjno', 'a.Gy0_gxh','a.Gy0_ls', 'SUM(b.sczl_cl) as total_cl', 'SUM(c.sczl_cl) as cl'])
  674. ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
  675. ->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')
  676. ->where([
  677. 'a.Gy0_gdbh' => $order,
  678. 'a.Gy0_yjno' => $params['yjno'],
  679. 'a.Gy0_gxh' => ['IN', $gxh_values],
  680. 'b.sczl_cl|c.sczl_cl' => ['>', 0]
  681. ])
  682. ->group('b.sczl_gxh')
  683. ->order('a.Gy0_gxh')
  684. ->select();
  685. //按班组分的产量数据
  686. $gy_data =db('工单_工艺资料')
  687. ->alias('a')
  688. ->field([
  689. 'a.Gy0_yjno', 'a.Gy0_gxh', 'a.Gy0_ls', 'a.Gy0_ks' ,'a.Gy0_计划损耗', 'a.超节损承担比例', 'b.sczl_gxmc',
  690. 'SUM(b.sczl_zcfp) as sczl_zcfp', 'SUM(b.sczl_cl) as total_cl',
  691. 'b.sczl_bh1', 'b.sczl_bh2', 'b.sczl_bh3', 'b.sczl_bh4', 'b.sczl_bh5', 'b.sczl_bh6',
  692. 'b.sczl_bh7', 'b.sczl_bh8', 'b.sczl_bh9', 'b.sczl_bh10',
  693. 'rtrim(c.sczl_gxmc) as gxmc', 'SUM(c.sczl_cl) as cl', 'SUM(c.sczl_fp) as fp', 'c.sczl_bh1 as sczl_bh'
  694. ])
  695. ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
  696. ->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')
  697. ->where([
  698. 'a.Gy0_gdbh' => $order,
  699. 'a.Gy0_yjno' => $params['yjno'],
  700. 'a.Gy0_gxh' => ['in', $gxh_values],
  701. 'b.sczl_cl|c.sczl_cl' => ['>', 0]
  702. ])
  703. ->group('b.sczl_gxh, b.sczl_bh1, CASE WHEN b.sczl_bh2 = "000000" THEN "" ELSE b.sczl_bh2 END, b.sczl_bh3,
  704. b.sczl_bh4, b.sczl_bh5, b.sczl_bh6, b.sczl_bh7, b.sczl_bh8, b.sczl_bh9, c.sczl_bh1')
  705. ->order('a.Gy0_gxh asc, b.开工时间 asc, c.sczl_rq desc')
  706. ->select();
  707. foreach ($gy_data as $key=>$value){
  708. $gy_data[$key]['Gy0_yjno'] = $value['Gy0_yjno'] > 10 ? $value['Gy0_yjno'] : '0'.$value['Gy0_yjno'];
  709. //每道工序的产量(按班组分)
  710. $gy_data[$key]['total_cl'] = $value['total_cl'] * $value['Gy0_ls'];
  711. if (empty($value['total_cl'])){
  712. $gy_data[$key]['total_cl'] = $value['cl'] * $value['Gy0_ls'];
  713. }
  714. $value['Gy0_计划损耗'] = $value['Gy0_计划损耗']*$value['Gy0_ls']*$value['Gy0_ks'];
  715. //计算每道工序的计划损耗
  716. foreach ($total_cl_data as $k=>$v){
  717. //每道工序的总产量
  718. $cl = $v['total_cl'] * $v['Gy0_ls'];
  719. if (empty($cl)){
  720. $cl = $v['cl'] * $v['Gy0_ls'];
  721. }
  722. if ($value['Gy0_yjno'] == $v['Gy0_yjno'] && $value['Gy0_gxh'] == $v['Gy0_gxh']){
  723. $gy_data[$key]['计划损耗'] = round($gy_data[$key]['total_cl'] / $cl * $value['Gy0_计划损耗']);
  724. }
  725. }
  726. //每道工序的制程废品(按班组分)
  727. $gy_data[$key]['sczl_zcfp'] = $value['sczl_zcfp'] * $value['Gy0_ls'];
  728. if (empty($value['sczl_zcfp'])){
  729. $gy_data[$key]['sczl_zcfp'] = $value['fp'] * $value['Gy0_ls'];
  730. }
  731. //计算每道工序的质检废(按班组)
  732. $gy_data[$key]['sczl_gxmc'] = $value['sczl_gxmc'];
  733. if (empty($value['sczl_gxmc'])){
  734. $gy_data[$key]['sczl_gxmc'] = $value['gxmc'];
  735. }
  736. if (empty($value['sczl_bh1']) || is_null($value['sczl_bh1'])){
  737. $value['sczl_bh1'] = $value['sczl_bh'];
  738. }
  739. $gy_data[$key]['sczl_bh1'] = $value['sczl_bh1'];
  740. $gy_data[$key]['质检废'] = 0;
  741. foreach ($waste_out as $entry) {
  742. for ($i = 1; $i <= 13; $i++) {
  743. $gxmcKey = "fp_gxmc" . $i;
  744. $slKey = "fp_sl" . $i;
  745. $bhKey = "fp_bh" . $i;
  746. if ((int)substr($entry[$gxmcKey],0,2) == $value['Gy0_gxh'] && $entry[$bhKey] == $value['sczl_bh1']){
  747. $gy_data[$key]['质检废'] += $entry[$slKey];
  748. }
  749. }
  750. }
  751. //无形损分摊
  752. if ($plan_total >0){
  753. $gy_data[$key]['无形损分摊'] = round($gy_data[$key]['计划损耗'] / $plan_total * $data['intangible_loss']);
  754. }else{
  755. $gy_data[$key]['无形损分摊'] = 0;
  756. }
  757. //班组成员
  758. $nameArr = [];
  759. for ($j = 1; $j <= 10; $j++) {
  760. $bhKey = "sczl_bh" . $j;
  761. if (!empty($value[$bhKey])){
  762. $name = \db('人事_基本资料')->where('员工编号',$value[$bhKey])->value('rtrim(员工姓名)');
  763. array_push($nameArr,$name);
  764. }
  765. }
  766. $gy_data[$key]['member'] = implode(' ',$nameArr);
  767. unset($gy_data[$key]['Gy0_计划损耗']);
  768. unset($gy_data[$key]['gxmc']);
  769. unset($gy_data[$key]['cl']);
  770. unset($gy_data[$key]['fp']);
  771. unset($gy_data[$key]['sczl_bh']);
  772. }
  773. $i = 0;
  774. foreach ($gy_data as &$item) {
  775. $sczl_bh1 = $item['sczl_bh1'];
  776. $total_cl = $item['total_cl'];
  777. // $item['total'] = $totals[$sczl_bh1]['total'];
  778. // if ($totals[$sczl_bh1]['count'] > 1) {
  779. // $item['质检废'] = round($total_cl / $totals[$sczl_bh1]['total'] * $item['质检废']);
  780. // }
  781. //节损数量
  782. if ($item['无形损分摊'] > 0){
  783. $total_waste = $item['质检废'] + $item['sczl_zcfp'] + $item['无形损分摊'];
  784. }else{
  785. $total_waste = $item['质检废'] + $item['sczl_zcfp'];
  786. }
  787. $gy_data[$i]['节损数量'] = $item['计划损耗'] - $total_waste;
  788. //节损奖
  789. $guige = \db('物料_存货编码')
  790. ->where('物料代码',$data['成品代号'])
  791. ->value('rtrim(规格)');
  792. //工序超节损金额
  793. if ($guige === '小盒'){
  794. $moneyRate = 0.02;
  795. }else{
  796. $moneyRate = 0.09;
  797. }
  798. if (strpos($item['sczl_gxmc'],'机检') !== false){
  799. $gy_data[$i]['节损奖'] = 0;
  800. }else{
  801. $gy_data[$i]['节损奖'] = number_format($gy_data[$i]['节损数量'] * $item['超节损承担比例'] * $moneyRate,4);
  802. }
  803. $gy_data[$i]['超节损承担比例'] = number_format($item['超节损承担比例'],4) * 100 .'%';
  804. $total['plan_loss'] += $item['计划损耗'];
  805. $total['total_fp'] += $item['sczl_zcfp'];
  806. $total['waste_quality'] += $item['质检废'];
  807. $total['waste_intangible'] += $item['无形损分摊'];
  808. $total['reward'] += floatval(str_replace(',', '', $gy_data[$i]['节损奖']));
  809. $i++;
  810. }
  811. $total['reward'] = number_format($total['reward'],2);
  812. $data['gy_data'] = $gy_data;
  813. $data['total'] = $total;
  814. $this->success('请求成功',$data);
  815. }
  816. }
  817. /**
  818. * 获取工单工艺
  819. * @ApiMethod GET
  820. * @params string order
  821. */
  822. public function getOrderGy(){
  823. if (Request::instance()->isGet() == false) {
  824. $this->error('非法请求');
  825. }
  826. $params = Request::instance()->param();
  827. if (!isset($params['order']) || empty($params['order'])) {
  828. $this->error('参数错误');
  829. }
  830. $order = $params['order'];
  831. $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';
  832. $data =db('工单_工艺资料')->where('Gy0_gdbh',$order)->where('Gy0_yjno',$params['yjno'])->field($field)->select();
  833. $this->success('请求成功',$data);
  834. }
  835. /**
  836. * 更新工单工艺
  837. * @ApiMethod POST
  838. * @params array data
  839. */
  840. public function updateOrderGy(){
  841. if (Request::instance()->isPost() == false) {
  842. $this->error('非法请求');
  843. }
  844. $params = Request::instance()->post();
  845. if (!isset($params) || !isset($params[0]['UniqId'])){
  846. $this->error('参数不能为空');
  847. }
  848. $i = 0;
  849. foreach ($params as $key=>$value){
  850. $data = [];
  851. $data['无形损承担比例'] = $value['loss_one'];
  852. $data['超节损承担比例'] = $value['loss_two'];
  853. $data['超节损核算单价'] = $value['loss_thr'];
  854. $sql =db('工单_工艺资料')->where('UniqId',$value['UniqId'])->fetchSql(true)->update($data);
  855. $res = Db::query($sql);
  856. if ($res !== false){
  857. $i++;
  858. }
  859. }
  860. if ($i !== 0){
  861. $this->success('更新成功');
  862. }else{
  863. $this->error('更新失败');
  864. }
  865. }
  866. /**
  867. * 获取工单印件考核资料
  868. * @ApiMethod GET
  869. * @params string order
  870. */
  871. public function getOrderYj(){
  872. if (Request::instance()->isGet() == false) {
  873. $this->error('非法请求');
  874. }
  875. $params = Request::instance()->request();
  876. if (!isset($params['order']) || empty($params['order'])) {
  877. $this->error('参数错误');
  878. }
  879. if (!isset($params['yjno']) || empty($params['yjno'])) {
  880. $this->error('参数错误');
  881. }
  882. $data =db('工单_印件资料')
  883. ->where('Yj_gdbh',$params['order'])
  884. ->where('Yj_Yjno', $params['yjno'])
  885. ->field('Yj_gdbh,rtrim(yj_Yjdh) as yj_Yjdh,yj_Yjno,rtrim(yj_yjmc) as yj_yjmc,质量考核')->find();
  886. $this->success('请求成功',$data);
  887. }
  888. /**
  889. * 更新工单印件考核资料
  890. * @ApiMethod POST
  891. * @params array data
  892. */
  893. public function updateOrderYj(){
  894. if ($this->request->isGet() === false){
  895. $this->error('请求错误');
  896. }
  897. $params = $this->request->get();
  898. if (!isset($params['order'])){
  899. $this->error('参数不能为空');
  900. }
  901. if (!isset($params['yj_yjno'])){
  902. $this->error('参数不能为空');
  903. }
  904. if (!isset($params['examine'])){
  905. $this->error('参数不能为空');
  906. }
  907. if ($params['examine'] === '参与'){
  908. $examine = 0;
  909. }else{
  910. $examine = 1;
  911. }
  912. $where['Yj_Gdbh'] = $params['order'];
  913. $where['yj_Yjno'] = $params['yj_yjno'];
  914. $sql =db('工单_印件资料')->where($where)->fetchSql(true)->update(['质量考核'=>$examine]);
  915. $res = \db()->query($sql);
  916. $returnData = $this->OneOrderSuperLoss($where['Yj_Gdbh'],$where['yj_Yjno']);
  917. db('工单_质量考核汇总')
  918. ->where('Gy0_gdbh',$where['Yj_Gdbh'])
  919. ->where('印件及工序',$where['yj_Yjno'])
  920. ->delete();
  921. $sql = db('工单_质量考核汇总')->fetchSql(true)->insertAll($returnData);
  922. $result = db()->query($sql);
  923. if($result===false) $this->error('失败');
  924. if ($res !== false){
  925. $this->success('更新成功');
  926. }else{
  927. $this->error('更新失败');
  928. }
  929. }
  930. /**
  931. * 获取修正工单实际投料列表
  932. * @ApiMethod GET
  933. * @params string year
  934. * @params string month
  935. */
  936. public function getOrderFeedList(){
  937. if (Request::instance()->isGet() == false) {
  938. $this->error('非法请求');
  939. }
  940. $params = Request::instance()->request();
  941. if (empty($params['workorder']) || empty($params['yjno'])) {
  942. $this->error('参数错误');
  943. }
  944. $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,
  945. rtrim(b.BOM_物料名称) as BOM_物料名称,rtrim(c.yj_tlgg) as yj_tlgg,rtrim(d.st_dw) as BOM_投料单位,
  946. a.订单数量,c.yj_平张投料, b.BOM_实际用量,d.st_sl as 实际投料,d.st_oldSl as 原投料,a.投料确认,
  947. d.Uniqid as UniqId,d.mod_number";
  948. $data =db('工单_基本资料')->alias('a')
  949. ->join('工单_印件资料 c','a.Gd_gdbh = c.Yj_Gdbh ','left')
  950. ->join('工单_bom资料 b','c.Yj_Gdbh = b.BOM_工单编号 AND c.yj_zzdh = b.BOM_物料编码','left')
  951. ->join('物料_收发记录 d','a.Gd_gdbh = d.st_gdbh AND d.cpdh = c.yj_Yjdh')
  952. ->where('a.Gd_gdbh',$params['workorder'])
  953. ->where('c.yj_Yjno',$params['yjno'])
  954. ->where(function($query) {
  955. $query->where('d.仓库编号', '101')
  956. ->whereOr('d.仓库编号', 'Y101');})
  957. ->field($field)
  958. ->group('a.Gd_gdbh,d.Uniqid')
  959. ->order('b.BOM_投料单位,a.UniqId asc')
  960. ->select();
  961. if (empty($data)){
  962. $this->success('请求成功');
  963. }
  964. foreach ($data as $key=>$value){
  965. $len = stripos($value['yj_tlgg'],'/');
  966. if ($len){
  967. $name = substr($value['yj_tlgg'],0,$len);
  968. $len_two = stripos($value['yj_tlgg'],'(');
  969. if ($len_two){
  970. $name = substr($name,0,$len_two);
  971. }
  972. $data[$key]['yj_tlgg'] = $name;
  973. }
  974. $data[$key]['rate'] = '';
  975. if (empty($value['原投料'])){
  976. $data[$key]['原投料'] = $value['实际投料'];
  977. }
  978. if ($value['mod_number'] === 0){
  979. $data[$key]['实际投料'] = '';
  980. }
  981. }
  982. $this->success('请求成功',$data);
  983. }
  984. /**
  985. * 更新工单实际投料
  986. * @ApiMethod POST
  987. * @params int UniqId
  988. * @params string number
  989. */
  990. public function updateOrderFeed(){
  991. if (Request::instance()->isPost() == false) {
  992. $this->error('非法请求');
  993. }
  994. $params = Request::instance()->post();
  995. if (!isset($params[0]['UniqId']) || empty($params[0]['UniqId'])){
  996. $this->error('参数错误');
  997. }
  998. $i = 0;
  999. $list = \db('物料_收发记录')->where('Uniqid',$params['0']['UniqId'])->find();
  1000. foreach ($params as $key=>$value){
  1001. $mod_num = \db('物料_收发记录')
  1002. ->where('Uniqid',$value['UniqId'])
  1003. ->value('mod_number');
  1004. $tl_sql = \db('物料_收发记录')
  1005. ->where('Uniqid',$value['UniqId'])
  1006. ->fetchSql(true)
  1007. ->update(['st_sl'=>$value['number'],'st_oldSl'=>$value['old_number'],'mod_number'=>$mod_num+1,'st_dw' => $value['dw']]);
  1008. $tlRes = Db::query($tl_sql);
  1009. if (!$tlRes){
  1010. $i++;
  1011. }
  1012. // $logData = [
  1013. // 'Gd_gdbh' => $list['st_gdbh'], // 使用原始工单编号
  1014. // 'ModifyUser' => $value['sys_id'],
  1015. // 'ModifyTime' => date('Y-m-d H:i:s'),
  1016. // 'FieldName' => 'st_sl',
  1017. // 'OldValue' => $value['old_number'],
  1018. // 'NewValue' => $value['number'],
  1019. // 'ModifySource' => '物料投料数修改'
  1020. // ];
  1021. // $logSql = \db('系统操作日志表')->fetchSql(true)->insert($logData);
  1022. // $result = \db()->query($logSql);
  1023. }
  1024. $total_num = \db('物料_收发记录')
  1025. ->alias('a')
  1026. ->field('SUM(a.st_sl) as 投料数量,b.yj_ls,b.yj_ks')
  1027. ->join('工单_印件资料 b','a.st_gdbh = b.Yj_Gdbh AND a.cpdh = b.yj_yjdh')
  1028. ->where('a.st_gdbh',$list['st_gdbh'])
  1029. ->where('a.cpdh',$list['cpdh'])
  1030. ->where(function($query) {
  1031. $query->where('a.仓库编号', '101')
  1032. ->whereOr('a.仓库编号', 'Y101');})
  1033. ->find();
  1034. $number = $total_num['投料数量']/10000*$total_num['yj_ls']*$total_num['yj_ks'];
  1035. $res_sql = db('工单_基本资料')->where('Gd_gdbh',$list['st_gdbh'])->where('Gd_cpdh',$list['cpdh'])->fetchSql(true)->setField('实际投料',$number);
  1036. $res = Db::query($res_sql);
  1037. $data['yj_实际投料'] = $number;
  1038. $yj_sql =db('工单_印件资料')->where('Yj_Gdbh',$list['st_gdbh'])->where('yj_Yjdh',$list['cpdh'])->fetchSql(true)->update($data);
  1039. $yjRes = Db::query($yj_sql);
  1040. $yjno = db('工单_印件资料')->where('Yj_Gdbh',$list['st_gdbh'])->where('yj_Yjdh',$list['cpdh'])->column('yj_Yjno')[0];
  1041. /**
  1042. * 重新计算工单超节损数据
  1043. **/
  1044. $result = $this->OneOrderSuperLoss($list['st_gdbh'],$yjno);
  1045. //先删除数据
  1046. \db('工单_质量考核汇总')
  1047. ->where('Gy0_gdbh',$list['st_gdbh'])
  1048. ->where('印件及工序',$yjno)
  1049. ->delete();
  1050. //插入新数据
  1051. $lossSql = \db('工单_质量考核汇总')->fetchSql(true)->insertAll($result);
  1052. $lossRes = \db()->query($lossSql);
  1053. if ($i != 0 && $lossRes !== false){
  1054. $this->success('更新成功');
  1055. }else{
  1056. $this->error('更新失败');
  1057. }
  1058. }
  1059. /**
  1060. * 工单工序产量统计
  1061. * @ApiMethod GET
  1062. * @params string order
  1063. */
  1064. public function getOrderProcessCount(){
  1065. if (Request::instance()->isGet() == false) {
  1066. $this->error('非法请求');
  1067. }
  1068. $params = Request::instance()->request();
  1069. if (empty($params['order']) || empty($params['order'])) {
  1070. $this->error('参数错误');
  1071. }
  1072. if (empty($params['yjno']) || empty($params['yjno'])) {
  1073. $this->error('参数错误');
  1074. }
  1075. $order = $params['order'];
  1076. $yjno = $params['yjno'];
  1077. $sql = "SELECT a.Gy0_yjno,a.Gy0_gxh,rtrim(a.Gy0_gxmc) as Gy0_gxmc,rtrim(a.Add_gxmc) as Add_gxmc,a.Gy0_计划接货数,
  1078. a.Gy0_ls,a.Gy0_sbbh,a.PD_WG,SUM(b.sczl_cl) as sczl_cl,SUM(b.sczl_zcfp) as sczl_zcfp,
  1079. SUM(b.sczl_来料少数) as 来料异常,COUNT(DISTINCT b.sczl_num) as process_num,b.sczl_Pgcl,
  1080. SUM(c.sczl_cl) as cl,b.sczl_rq,rtrim(a.印刷方式) as 印刷方式,rtrim(a.版距) as 版距
  1081. FROM `工单_工艺资料` a
  1082. LEFT JOIN `设备_产量计酬` b ON a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh
  1083. 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
  1084. WHERE a.Gy0_gdbh = '{$order}' and a.GY0_Yjno = '{$yjno}' GROUP BY a.Gy0_yjno, a.Gy0_gxh ORDER BY a.Gy0_yjno, a.Gy0_gxh";
  1085. $data = Db::query($sql);
  1086. //手检数据
  1087. $handData =db('db_手工检验')->where('sczl_gdbh',$order)->field('sum(sczl_cl) as cl,rtrim(sczl_yjgx) as sczl_gxh')->select();
  1088. //包装及成品防护数据
  1089. $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,
  1090. rtrim(sczl_gxmc3) as sczl_gxmc3,rtrim(sczl_gxmc4) as sczl_gxmc4,rtrim(sczl_gxmc5) as sczl_gxmc5,rtrim(sczl_gxmc6) as sczl_gxmc6,
  1091. sczl_cl1,sczl_cl2,sczl_cl3,sczl_cl4,sczl_cl5,sczl_cl6,sczl_PgCl1,sczl_PgCl2,sczl_PgCl3,sczl_PgCl4,sczl_PgCl5,sczl_PgCl6
  1092. FROM `db_包装计件` WHERE `sczl_gdbh1` LIKE '%{$order}%' OR `sczl_gdbh2` LIKE '%{$order}%'
  1093. OR `sczl_gdbh3` LIKE '%{$order}%' OR `sczl_gdbh4` LIKE '%{$order}%' OR `sczl_gdbh5` LIKE '%{$order}%' OR `sczl_gdbh6` LIKE '%{$order}%'";
  1094. $package = Db::query($sql);
  1095. $list = [];
  1096. $j = 0;
  1097. foreach ($package as $value){
  1098. for ($i = 1; $i <= 6; $i++) {
  1099. $gdbhlKey = "sczl_gdbh" . $i;
  1100. $gxmcKey = "sczl_gxmc" . $i;
  1101. $clKey = "sczl_cl" . $i;
  1102. $pgclKey = "sczl_PgCl" . $i;
  1103. if ($value[$gdbhlKey] == '2311743' && $value[$clKey] > 0) {
  1104. $list[$j]['sczl_gdbh'] = $value[$gdbhlKey];
  1105. $list[$j]['sczl_gxmc'] = $value[$gxmcKey];
  1106. $list[$j]['sczl_cl'] = $value[$clKey];
  1107. $list[$j]['sczl_PgCl'] = $value[$pgclKey];
  1108. $j++;
  1109. }
  1110. }
  1111. }
  1112. // 创建一个关联数组,用于存储相同 sczl_gxmc 的值和对应的乘积之和
  1113. $sumArray = [];
  1114. foreach ($list as $item) {
  1115. $key = $item['sczl_gxmc'];
  1116. $cl = floatval($item['sczl_cl']);
  1117. $pgCl = intval($item['sczl_PgCl']);
  1118. $product = $cl * $pgCl;
  1119. if (!isset($sumArray[$key])) {
  1120. $sumArray[$key] = 0;
  1121. }
  1122. $sumArray[$key] += $product;
  1123. }
  1124. $handGxh = substr($handData[0]['sczl_gxh'],-2);
  1125. foreach ($data as $key=>$item){
  1126. $data[$key]['折算车头产量'] = $item['Gy0_计划接货数'];
  1127. $data[$key]['Gy0_计划接货数'] = $item['Gy0_计划接货数']*$item['Gy0_ls'];
  1128. $data[$key]['制程废品率'] = '';
  1129. if ($item['sczl_zcfp'] > 0 && $item['sczl_cl']){
  1130. $data[$key]['制程废品率'] = number_format($item['sczl_zcfp']/$item['sczl_cl']*100,4).'%';
  1131. }
  1132. if ($item['cl'] > 0){
  1133. $data[$key]['sczl_cl'] = $item['cl'];
  1134. }
  1135. if ($item['sczl_Pgcl'] > 0){
  1136. $data[$key]['sczl_cl'] = $item['sczl_cl'] * $item['sczl_Pgcl'];
  1137. }
  1138. if ($item['Gy0_gxh'] == (int)$handGxh){
  1139. $data[$key]['sczl_cl'] = $handData[0]['cl'];
  1140. }
  1141. foreach ($sumArray as $k=>$v){
  1142. if ($item['Gy0_gxmc'] == $k){
  1143. $data[$key]['sczl_cl'] = $v;
  1144. }
  1145. }
  1146. if (substr($item['PD_WG'],0,4) == '1900'){
  1147. $data[$key]['PD_WG'] = '计划';
  1148. }else{
  1149. $data[$key]['PD_WG'] = '完工';
  1150. }
  1151. //印刷方式为卷对卷时候:上报产量/版距*1000
  1152. if ($item['印刷方式'] === '卷对卷'){
  1153. $data[$key]['sczl_cl'] = ceil($data[$key]['sczl_cl']/$item['版距']*1000);
  1154. $data[$key]['sczl_zcfp'] = ceil($data[$key]['sczl_zcfp']/$item['版距']*1000);
  1155. $data[$key]['来料异常'] = ceil($data[$key]['来料异常']/$item['版距']*1000);
  1156. }
  1157. }
  1158. $this->success('请求成功',$data);
  1159. }
  1160. /**
  1161. * 月份员工超节损数据汇总
  1162. * @return void
  1163. * @throws \think\db\exception\DataNotFoundException
  1164. * @throws \think\db\exception\ModelNotFoundException
  1165. * @throws \think\exception\DbException
  1166. */
  1167. public function EmployeeDataCollect()
  1168. {
  1169. if ($this->request->isPost() === false) {
  1170. $this->error('请求错误');
  1171. }
  1172. $params = $this->request->post();
  1173. if (empty($params)) {
  1174. $this->error('参数错误');
  1175. }
  1176. $date = date('Ym', strtotime($params['date']));
  1177. $list = \db('工单_质量考核汇总')
  1178. ->alias('a')
  1179. ->join('工单_印件资料 b', 'a.Gy0_gdbh = b.Yj_Gdbh AND a.印件及工序 = b.yj_Yjno')
  1180. ->join('成品入仓 c', 'a.Gy0_gdbh = c.jjcp_gdbh AND a.印件及工序 = c.jjcp_yjno')
  1181. ->where('a.sys_ny', $date)
  1182. ->where(function ($query) {
  1183. $query->where('b.质量考核', 0)
  1184. ->whereOr('b.质量考核', null);
  1185. })
  1186. ->where('c.jjcp_smb', 'like', '末%')
  1187. ->select();
  1188. $data = [];
  1189. foreach ($list as $item) {
  1190. $workshop = $item["车间名称"] ?? '';
  1191. for ($i = 1; $i <= 8; $i++) {
  1192. if (!empty($item["sczl_bh{$i}"]) && $item["sczl_bh{$i}"]!== ''){
  1193. $bh = $item["sczl_bh{$i}"] ?? '';
  1194. $xm = $item["Xm{$i}"] ?? '';
  1195. $rateValue = floatval($item["sczl_rate{$i}"]) ?? '';
  1196. // 关键优化:如果分配比例为 0 或空,默认为 1
  1197. $rate = (empty($rateValue) || (float)$rateValue == 0) ? 1 : (float)$rateValue;
  1198. if (!empty($bh) && $bh !== '') {
  1199. $je = round((float)$item["CjsJe"] * $rate, 4);
  1200. $data[] = [
  1201. "bh" => $bh,
  1202. "xm" => $xm,
  1203. "je" => (float)number_format($je, 4, '.', ''),
  1204. "cj" => $workshop
  1205. ];
  1206. }
  1207. }
  1208. }
  1209. }
  1210. $result = [];
  1211. foreach ($data as $item) {
  1212. $cj = $item['cj'];
  1213. $bh = $item['bh'];
  1214. $je = round($item['je'], 2); // 保留两位小数
  1215. if (!isset($result[$cj])) {
  1216. $result[$cj] = [];
  1217. }
  1218. if (isset($result[$cj][$bh])) {
  1219. $result[$cj][$bh]['je'] += (float)$je;
  1220. } else {
  1221. $result[$cj][$bh] = [
  1222. 'bh' => $bh,
  1223. 'xm' => $item['xm'],
  1224. 'je' => (float)$je,
  1225. 'cj' => $cj
  1226. ];
  1227. }
  1228. }
  1229. // 将每个车间的子数组转换为索引数组
  1230. foreach ($result as $cjName => &$items) {
  1231. $items = array_values($items);
  1232. }
  1233. $this->success('成功', $result);
  1234. }
  1235. /**
  1236. * 单条工单超节损计算
  1237. * @param $gdbh
  1238. * @param $yjno
  1239. * @return array
  1240. * @throws \think\db\exception\DataNotFoundException
  1241. * @throws \think\db\exception\ModelNotFoundException
  1242. * @throws \think\exception\DbException
  1243. */
  1244. public function OneOrderSuperLoss($gdbh,$yjno)
  1245. {
  1246. // $param = $this->request->param();
  1247. $param = [
  1248. 'gdbh' => $gdbh,
  1249. 'yjno' => $yjno
  1250. ];
  1251. //查询工单入仓数据
  1252. $workOrderData = \db('成品入仓')
  1253. ->where('jjcp_gdbh', $param['gdbh'])
  1254. ->where('jjcp_yjno', $param['yjno'])
  1255. ->where('jjcp_smb', '末 板')
  1256. ->find();
  1257. if (empty($workOrderData)) {
  1258. $this->error('工单' . $param['gdbh'] . '-' . $param['yjno'] . '未查询到末板入仓记录');
  1259. }
  1260. //入仓数量
  1261. $total_number = \db('成品入仓')
  1262. ->where('jjcp_gdbh', $param['gdbh'])
  1263. ->where('jjcp_yjno', $param['yjno'])
  1264. ->column('SUM(jjcp_sl)');
  1265. //查询工单资料、投料数据
  1266. $field = 'a.Gd_gdbh,rtrim(a.成品代号) as 成品代号,rtrim(a.成品名称) as 成品名称,
  1267. rtrim(a.销售订单号) as 销售订单号,a.订单数量,c.yj_ls as ls,c.yj_ks as ks,SUM(b.st_sl) as 投料,
  1268. b.st_dw,c.yj_zzmc,c.yj_tlgg,SUM(b.mod_number) as mod_num';
  1269. $data = db('工单_基本资料')
  1270. ->alias('a')
  1271. ->join('物料_收发记录 b', 'a.Gd_gdbh = b.st_gdbh AND a.Gd_cpdh = b.cpdh')
  1272. ->join('工单_印件资料 c', 'c.Yj_Gdbh = a.Gd_gdbh AND c.yj_Yjdh = a.Gd_cpdh')
  1273. ->where('a.Gd_Gdbh', $param['gdbh'])
  1274. ->where('c.yj_Yjno', $param['yjno'])
  1275. ->where(function ($query) {
  1276. $query->where('b.仓库编号', '101')
  1277. ->whereOr('b.仓库编号', 'Y101');
  1278. })
  1279. ->field($field)
  1280. ->find();
  1281. if ($data['投料'] == null){
  1282. return false;
  1283. }
  1284. if (!empty($data['yj_tlgg'])){
  1285. $number1 = (int)substr($data['yj_tlgg'],0,3);
  1286. $number2 = (int)substr($data['yj_tlgg'],4,3);
  1287. if ($number1 !== 0 && $number2 !== 0) {
  1288. preg_match('/(\d+)g/',$data['yj_zzmc'], $matches);
  1289. if ($data['st_dw'] === '吨'){
  1290. $data['投料'] = round(($data['投料']*1000*1000)/$matches[1]/($number1*$number2)*1000000);
  1291. $data['st_dw'] = '张';
  1292. }
  1293. }
  1294. }
  1295. //将开数、联数为0重新赋值
  1296. if ($data['ls'] == 0) {
  1297. $data['ls'] = 1;
  1298. }
  1299. if ($data['ks'] == 0) {
  1300. $data['ks'] = 1;
  1301. }
  1302. //计算工单实际投料
  1303. $data['实际投料'] = str_replace(',', '', number_format($data['投料'] * $data['ls'] * $data['ks'] / 10000, 4));
  1304. new WorkOrder();
  1305. (new WorkOrder)->PlannedProcessYield($param['gdbh'],$param['yjno'],0,$data['实际投料']*10000/$data['ls']);
  1306. //工单入仓数量
  1307. $data['warehousing_num'] = $total_number[0];
  1308. //截取工单末版的入仓时间
  1309. $data['warehousing_date'] = substr($workOrderData['jjcp_sj'], 0, 10);
  1310. //从设备产量计酬和sczl查出进入超节损的工序,有上报产量的工序就进入超节损
  1311. $gxh_sql = "SELECT sczl_gxh FROM
  1312. (SELECT sczl_gxh FROM 设备_产量计酬 WHERE sczl_gdbh = '{$workOrderData['jjcp_gdbh']}' AND sczl_yjno = '{$workOrderData['jjcp_yjno']}'
  1313. UNION SELECT sczl_gxh FROM db_sczl WHERE sczl_gdbh = '{$workOrderData['jjcp_gdbh']}' AND sczl_yjno = '{$workOrderData['jjcp_yjno']}') AS combined_result";
  1314. $gxh_arr = Db::query($gxh_sql);
  1315. if (empty($gxh_arr)) {
  1316. $this->error("工单".$workOrderData['jjcp_gdbh']."-".$workOrderData['jjcp_yjno']."未查询到报工信息,请核查该工单是否已进入超节损");
  1317. }
  1318. //整理查询处理的工序编号
  1319. $gxh_values = array_column($gxh_arr, 'sczl_gxh');
  1320. //将工序号小于10的编号前面加0
  1321. foreach ($gxh_values as $k => $v) {
  1322. if ((int)$v < 10) {
  1323. $gxh_values[$k] = '0' . $v;
  1324. }
  1325. }
  1326. $arr = [];
  1327. $plan_loss = [];//工单计划损耗
  1328. $target_rate = (1 - array_sum($arr)) * 100;
  1329. //目标合格率
  1330. $data['target_rate'] = $target_rate . '%';
  1331. //实际合格率
  1332. $real_rate = $total_number[0] / ($data['实际投料'] * 10000) * 100;
  1333. $data['real_rate'] = number_format($real_rate, 2) . '%';
  1334. //制程废品
  1335. $zzfp_data = db('设备_产量计酬')
  1336. ->where('sczl_gdbh', $workOrderData['jjcp_gdbh'])
  1337. ->where('sczl_yjno', $workOrderData['jjcp_yjno'])
  1338. ->field('SUM(sczl_zcfp) as sczl_zcfp')
  1339. ->select();
  1340. //制程废品*ls*ks
  1341. $data['zcfp'] = $zzfp_data[0]['sczl_zcfp'] * $data['ls'] * $data['ks'];
  1342. //废品数量
  1343. $wasteTotal = db('db_qczl')
  1344. ->where('qczl_gdbh', $workOrderData['jjcp_gdbh'])
  1345. ->where('qczl_yjno', $workOrderData['jjcp_yjno'])
  1346. ->sum('qczl_fp');
  1347. if (empty($wasteTotal)) {
  1348. $wasteTotal = 0;
  1349. }
  1350. //废品合计=制程废品+核检废品
  1351. $waste_total = $data['zcfp'] + $wasteTotal;
  1352. //工单无形损 = 实际投料-入仓数量-废品合计
  1353. $data['intangible_loss'] = (int)($data['实际投料'] * 10000 - $total_number[0] - $waste_total);
  1354. //查询核检单废品上报数据
  1355. $out_sql = "SELECT qczl_num,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,
  1356. 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,
  1357. 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,
  1358. 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,
  1359. 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
  1360. FROM db_qczl WHERE qczl_gdbh = '{$workOrderData['jjcp_gdbh']}' AND qczl_yjno = '{$workOrderData['jjcp_yjno']}'";
  1361. $waste_out = Db::query($out_sql);
  1362. $list = []; //外发废数组
  1363. $quality = [];//质检废数组
  1364. $material = [];//材料废数组
  1365. $change = [];//零头处理数组
  1366. $machine = [];//机检废品数组
  1367. $j = 0;
  1368. $m = 0;
  1369. $n = 0;
  1370. $l = 0;
  1371. $o = 0;
  1372. foreach ($waste_out as $entry) {
  1373. for ($i = 1; $i <= 13; $i++) {
  1374. $labelKey = "fp_lb" . $i;
  1375. $bhKey = "fp_bh" . $i;
  1376. $gxmcKey = "fp_gxmc" . $i;
  1377. $slKey = "fp_sl" . $i;
  1378. if (!empty($entry[$labelKey])) {
  1379. //外发加工废
  1380. if (substr($entry[$labelKey],0,3) == 'M04'){
  1381. $list[$j]= $entry[$slKey];
  1382. $j++;
  1383. }
  1384. //材料废
  1385. if (substr($entry[$labelKey],0,1) == 'L' ){
  1386. $material[$n]= $entry[$slKey];
  1387. $n++;
  1388. }
  1389. //零头处理
  1390. if (substr($entry[$labelKey],0,3) == 'M01' ){
  1391. $change[$l]= $entry[$slKey];
  1392. $l++;
  1393. }
  1394. //机检废品
  1395. if (substr($entry[$gxmcKey],0,2) == '01' ){
  1396. $machine[$o]= $entry[$slKey];
  1397. $o++;
  1398. }
  1399. }
  1400. $quality[$m]= $entry[$slKey];
  1401. $m++;
  1402. }
  1403. }
  1404. $data['材料废'] = array_sum($material); //材料废
  1405. $data['零头处理'] = array_sum($change); //零头处理
  1406. $data['外发废'] = array_sum($list);//外发废
  1407. $data['工单质检废'] = array_sum($quality);//质检废
  1408. $data['机检废'] = array_sum($machine);//机检废
  1409. //查询计划损耗
  1410. $plan_total = db('工单_工艺资料')
  1411. ->where(['Gy0_gdbh' => $workOrderData['jjcp_gdbh'], 'Gy0_yjno' => $workOrderData['jjcp_yjno'], 'Gy0_gxh' => ['in', $gxh_values]])
  1412. ->value('SUM(Gy0_计划损耗 * Gy0_ls * Gy0_ks)');
  1413. //单据列表最后统计/数据汇总
  1414. $total = [];
  1415. $total['plan_loss'] = 0;
  1416. $total['total_fp'] = 0;
  1417. $total['waste_quality'] = 0;
  1418. $total['waste_intangible'] = 0;
  1419. $total['reward'] = 0; //超节损奖励数组
  1420. //工单产量数据详情查询
  1421. $total_cl_data = \db('工单_工艺资料')->alias('a')
  1422. ->field(['a.Gy0_yjno', 'a.Gy0_gxh', 'rtrim(a.Gy0_gxmc) as gxmc', 'a.Gy0_ls', 'SUM(b.sczl_cl) as total_cl', 'SUM(c.sczl_cl) as cl','rtrim(a.印刷方式) as 印刷方式','rtrim(a.版距) as 版距'])
  1423. ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh', 'left')
  1424. ->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')
  1425. ->where([
  1426. 'a.Gy0_gdbh' => $workOrderData['jjcp_gdbh'],
  1427. 'a.Gy0_yjno' => $workOrderData['jjcp_yjno'],
  1428. 'a.Gy0_gxh' => ['IN', $gxh_values],
  1429. 'b.sczl_cl|c.sczl_cl' => ['>', 0],
  1430. ])
  1431. ->group('a.Gy0_gxh')
  1432. ->order('a.Gy0_gxh')
  1433. ->select();
  1434. //按班组分的产量数据
  1435. $gy_data = db('工单_工艺资料')
  1436. ->alias('a')
  1437. ->field([
  1438. 'a.Gy0_gdbh', 'a.Gy0_yjno', 'a.Gy0_gxh', 'a.Gy0_ls', 'a.Gy0_ks', 'a.Gy0_计划损耗', 'a.超节损承担比例',
  1439. 'CONCAT(`a`.`Gy0_gxmc`, "【", a.Add_gxmc,"】") AS sczl_gxmc', 'SUM(b.sczl_zcfp) as sczl_zcfp', 'SUM(b.sczl_cl) as total_cl',
  1440. 'b.sczl_bh1', 'b.sczl_bh2', 'b.sczl_bh3', 'b.sczl_bh4', 'b.sczl_bh5', 'b.sczl_bh6',
  1441. 'b.sczl_bh7', 'b.sczl_bh8', 'b.sczl_bh9', 'b.sczl_bh10', 'GROUP_CONCAT(DISTINCT b.sczl_num SEPARATOR ",") AS 流程单',
  1442. 'b.sczl_bzdh', 'b.sczl_rate1', 'b.sczl_rate2', 'b.sczl_rate3', 'b.sczl_rate4', 'b.sczl_rate5',
  1443. 'b.sczl_rate6', 'b.sczl_rate7', 'b.sczl_rate8', 'b.sczl_rate9', 'b.sczl_rate10',
  1444. 'rtrim(c.sczl_gxmc) as gxmc', 'SUM(c.sczl_cl) as cl', 'SUM(c.sczl_fp) as fp', 'c.sczl_bh1 as sczl_bh',
  1445. 'd.使用部门 as 使用部门', 'c.sczl_bzdh as bzdh', 'b.sczl_jtbh', 'a.损耗系数', 'a.Gy0_ms', 'a.Gy0_Rate0',
  1446. 'a.Gy0_Rate1', 'a.无形损承担比例', 'a.Gy0_计划接货数*a.Gy0_ls*a.Gy0_ks as 计划产量', 'e.Gd_客户代号', 'e.Gd_客户名称',
  1447. 'e.Gd_cpdh', 'e.Gd_cpmc', 'e.销售订单号', 'e.投料大箱', 'e.订单数量', 'e.计量单位', 'rtrim(a.Gy0_SITE) as Gy0_SITE',
  1448. 'rtrim(a.印刷方式) as 印刷方式','rtrim(a.版距) as 版距'
  1449. ])
  1450. ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh', 'left')
  1451. ->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')
  1452. ->join('设备_基本资料 d', 'd.设备编号 = b.sczl_jtbh', 'left')
  1453. ->join('工单_基本资料 e', 'a.Gy0_gdbh = e.Gd_gdbh AND a.Gy0_yjno = e.行号')
  1454. ->where([
  1455. 'a.Gy0_gdbh' => $workOrderData['jjcp_gdbh'],
  1456. 'a.Gy0_yjno' => $workOrderData['jjcp_yjno'],
  1457. 'a.Gy0_gxh' => ['in', $gxh_values],
  1458. 'b.sczl_cl|c.sczl_cl' => ['>', 0],
  1459. ])
  1460. ->group('a.Gy0_gxh,b.sczl_jtbh,b.sczl_bh1, CASE WHEN b.sczl_bh2 = "000000" THEN "" ELSE b.sczl_bh2 END, b.sczl_bh3,
  1461. b.sczl_bh4, b.sczl_bh5, b.sczl_bh6, b.sczl_bh7, b.sczl_bh8, b.sczl_bh9, c.sczl_bh1')
  1462. ->order('a.Gy0_gxh asc, b.开工时间 asc, c.sczl_rq desc')
  1463. ->select();
  1464. $sumBz = [];
  1465. foreach ($gy_data as $kk => $vv){
  1466. //每道工序的产量(按班组分)
  1467. $vv['total_cl'] = $vv['total_cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
  1468. if (empty($vv['total_cl'])) {
  1469. $vv['total_cl'] = $vv['cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
  1470. }
  1471. if (empty($vv['sczl_bh1'])){
  1472. $vv['sczl_bh1'] = $vv['sczl_bh'];
  1473. }
  1474. if (isset($sumBz[$vv['sczl_bh1'].'-'.$vv['Gy0_gxh']])){
  1475. $sumBz[$vv['sczl_bh1'].'-'.$vv['Gy0_gxh']] += $vv['total_cl'];
  1476. }else{
  1477. $sumBz[$vv['sczl_bh1'].'-'.$vv['Gy0_gxh']] = $vv['total_cl'];
  1478. }
  1479. }
  1480. foreach ($gy_data as $kk => $vv) {
  1481. $banju = $vv['版距']/1000;
  1482. if ($vv['印刷方式'] === '卷对卷'){
  1483. $vv['total_cl'] = $vv['total_cl']/$banju;
  1484. }
  1485. //每道工序的产量(按班组分)
  1486. $gy_data[$kk]['total_cl'] = (int)$vv['total_cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
  1487. if (empty($vv['total_cl'])) {
  1488. $gy_data[$kk]['total_cl'] = (int)$vv['cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
  1489. }
  1490. $gy_data[$kk]['Gy0_计划损耗'] = $vv['Gy0_计划损耗'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
  1491. $vv['Gy0_计划损耗'] = $vv['Gy0_计划损耗'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
  1492. //计算每道工序的计划损耗
  1493. foreach ($total_cl_data as $k => $v) {
  1494. //每道工序的总产量
  1495. $cl = $v['total_cl'] * $v['Gy0_ls'];
  1496. if (empty($cl)) {
  1497. $cl = $v['cl'] * $v['Gy0_ls'];
  1498. }
  1499. if ($vv['Gy0_yjno'] == $v['Gy0_yjno'] && $vv['Gy0_gxh'] == $v['Gy0_gxh']) {
  1500. $gy_data[$kk]['计划损耗'] = round($gy_data[$kk]['total_cl'] / $cl * $vv['Gy0_计划损耗']);
  1501. }
  1502. }
  1503. //每道工序的制程废品(按班组分)
  1504. $gy_data[$kk]['sczl_zcfp'] = $vv['sczl_zcfp'] * $vv['Gy0_ls'];
  1505. if (empty($vv['sczl_zcfp'])) {
  1506. $gy_data[$kk]['sczl_zcfp'] = $vv['fp'] * $vv['Gy0_ls'];
  1507. }
  1508. //计算每道工序的质检废(按班组)
  1509. $gy_data[$kk]['sczl_gxmc'] = $vv['sczl_gxmc'];
  1510. if (empty($vv['sczl_gxmc'])) {
  1511. $gy_data[$kk]['sczl_gxmc'] = $vv['gxmc'];
  1512. }
  1513. if (empty($vv['sczl_bh1']) || is_null($vv['sczl_bh1'])) {
  1514. $vv['sczl_bh1'] = $vv['sczl_bh'];
  1515. }
  1516. $gy_data[$kk]['sczl_bh1'] = $vv['sczl_bh1'];
  1517. $gy_data[$kk]['质检废'] = 0;
  1518. $gy_data[$kk]['zjfp'] = 0;
  1519. foreach ($waste_out as $entry) {
  1520. for ($i = 1; $i <= 13; $i++) {
  1521. $gxmcKey = "fp_gxmc" . $i;
  1522. $gxlbKey = "fp_lb" . $i;
  1523. $slKey = "fp_sl" . $i;
  1524. $bhKey = "fp_bh" . $i;
  1525. if ((int)substr($entry[$gxmcKey], 0, 2) == $vv['Gy0_gxh'] && $entry[$bhKey] == $vv['sczl_bh1']) {
  1526. $gy_data[$kk]['zjfp'] += $entry[$slKey];
  1527. }
  1528. }
  1529. }
  1530. $gy_data[$kk]['质检废'] = round($gy_data[$kk]['zjfp']*($gy_data[$kk]['total_cl']/$sumBz[$vv['sczl_bh1'].'-'.$vv['Gy0_gxh']]));
  1531. //无形损分摊
  1532. if ($plan_total > 0) {
  1533. $gy_data[$kk]['无形损分摊'] = round($gy_data[$kk]['计划损耗'] / $plan_total * $data['intangible_loss']);
  1534. } else {
  1535. $gy_data[$kk]['无形损分摊'] = 0;
  1536. }
  1537. //班组成员
  1538. for ($j = 1; $j <= 10; $j++) {
  1539. $bhKey = "sczl_bh" . $j;
  1540. if (!empty($vv[$bhKey])) {
  1541. $name = \db('人事_基本资料')->where('员工编号', $vv[$bhKey])->value('rtrim(员工姓名)');
  1542. $gy_data[$kk]['sczl_name' . $j] = $name;
  1543. } else {
  1544. $gy_data[$kk]['sczl_name' . $j] = '';
  1545. }
  1546. }
  1547. //工序产量
  1548. foreach ($total_cl_data as $k => $v) {
  1549. $banju1 = $v['版距']/1000;
  1550. if ($v['印刷方式'] === '卷对卷'){
  1551. $v['total_cl'] = $v['total_cl']/$banju1;
  1552. }
  1553. if ($v['Gy0_yjno'] === $vv['Gy0_yjno'] && $v['Gy0_gxh'] === $vv['Gy0_gxh']) {
  1554. if (strpos($v['gxmc'], '拆片') !== false) {
  1555. $gy_data[$kk]['工序产量'] = $v['cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
  1556. } else {
  1557. $gy_data[$kk]['工序产量'] = $v['total_cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
  1558. }
  1559. }
  1560. }
  1561. unset($gy_data[$kk]['gxmc']);
  1562. unset($gy_data[$kk]['cl']);
  1563. unset($gy_data[$kk]['fp']);
  1564. unset($gy_data[$kk]['sczl_bh']);
  1565. unset($gy_data[$kk]['bzdh']);
  1566. }
  1567. // halt($gy_data);
  1568. //计算超节损金额
  1569. foreach ($gy_data as $n => $item) {
  1570. //节损数量
  1571. if ($item['无形损分摊'] > 0) {
  1572. $total_waste = $item['质检废'] + $item['sczl_zcfp'] + $item['无形损分摊'];
  1573. } else {
  1574. $total_waste = $item['质检废'] + $item['sczl_zcfp'];
  1575. }
  1576. $gy_data[$n]['节损数量'] = $item['计划损耗'] - $total_waste;
  1577. //节损奖
  1578. $guige = \db('物料_存货编码')
  1579. ->where('物料代码',$data['成品代号'])
  1580. ->value('rtrim(规格)');
  1581. //工序超节损金额
  1582. if (strpos($guige,'小盒') !== false){
  1583. $moneyRate = 0.02;
  1584. }else{
  1585. $moneyRate = 0.09;
  1586. }
  1587. if (strpos($item['sczl_gxmc'], '机检') !== false) {
  1588. $gy_data[$n]['节损奖'] = 0;
  1589. } else {
  1590. $gy_data[$n]['节损奖'] = number_format($gy_data[$n]['节损数量'] * $item['超节损承担比例'] * $moneyRate, 4);
  1591. }
  1592. $gy_data[$n]['sys_ny'] = date('Ym', strtotime($workOrderData['jjcp_sj']));
  1593. $gy_data[$n]['超节损核算单价'] = $moneyRate;
  1594. $total['plan_loss'] += $item['计划损耗'];
  1595. $total['total_fp'] += $item['sczl_zcfp'];
  1596. $total['waste_quality'] += $item['质检废'];
  1597. $total['waste_intangible'] += $item['无形损分摊'];
  1598. $total['reward'] += floatval(str_replace(',', '', $gy_data[$n]['节损奖']));
  1599. }
  1600. // halt($gy_data);
  1601. //整合数据
  1602. $result = [];
  1603. foreach ($gy_data as $key => $value) {
  1604. $result[$key] = [
  1605. 'sys_ny' => $value['sys_ny'],
  1606. 'Gy0_gdbh' => $value['Gy0_gdbh'],
  1607. '印件及工序' => $value['Gy0_yjno'],
  1608. '工序' => $value['Gy0_gxh'],
  1609. '工序名称' => $value['sczl_gxmc'],
  1610. '联数' => $value['Gy0_ls'],
  1611. '基础损耗' => $value['Gy0_Rate0'],
  1612. '损耗率' => $value['Gy0_Rate1'],
  1613. '损耗系数' => $value['损耗系数'],
  1614. '计损色数' => $value['Gy0_ms'],
  1615. '计划产量' => $value['计划产量'],
  1616. '计划损耗' => $value['Gy0_计划损耗'],
  1617. '班组分摊计划损耗' => $value['计划损耗'],
  1618. '印件工序产量' => $value['工序产量'],
  1619. '班组产量' => $value['total_cl'],
  1620. '班组制程废品' => $value['sczl_zcfp'],
  1621. '工单质检废' => $data['工单质检废'],
  1622. '班组质检废品' => $value['zjfp'],
  1623. '班组分摊质检废品' => $value['质检废'],
  1624. '无班组废品' => 0,
  1625. '外发废' => $data['外发废'],
  1626. '材料废' => $data['材料废'],
  1627. '零头处理' => $data['零头处理'],
  1628. '分摊废' => 0,
  1629. '分摊废明细' => 0,
  1630. '印件无形损' => $data['intangible_loss'],
  1631. '班组分摊无形损' => $value['无形损分摊'],
  1632. 'CjsSl' => $value['节损数量'],
  1633. 'CjsJe' => str_replace(",", "", $value['节损奖']),
  1634. '无形损承担比例' => $value['无形损承担比例'],
  1635. '超节损承担比例' => $value['超节损承担比例'],
  1636. '超节损核算单价' => $value['超节损核算单价'],
  1637. 'sczl_jtbh' => $value['sczl_jtbh'],
  1638. 'sczl_bzdh' => $value['sczl_bzdh'],
  1639. 'sczl_bh1' => $value['sczl_bh1'],
  1640. 'sczl_bh2' => $value['sczl_bh2'],
  1641. 'sczl_bh3' => $value['sczl_bh3'],
  1642. 'sczl_bh4' => $value['sczl_bh4'],
  1643. 'sczl_bh5' => $value['sczl_bh5'],
  1644. 'sczl_bh6' => $value['sczl_bh6'],
  1645. 'sczl_bh7' => $value['sczl_bh7'],
  1646. 'sczl_bh8' => $value['sczl_bh8'],
  1647. 'Xm1' => $value['sczl_name1'],
  1648. 'Xm2' => $value['sczl_name2'],
  1649. 'Xm3' => $value['sczl_name3'],
  1650. 'Xm4' => $value['sczl_name4'],
  1651. 'Xm5' => $value['sczl_name5'],
  1652. 'Xm6' => $value['sczl_name6'],
  1653. 'Xm7' => $value['sczl_name7'],
  1654. 'Xm8' => $value['sczl_name8'],
  1655. 'sczl_rate1' => $value['sczl_rate1'],
  1656. 'sczl_rate2' => $value['sczl_rate2'],
  1657. 'sczl_rate3' => $value['sczl_rate3'],
  1658. 'sczl_rate4' => $value['sczl_rate4'],
  1659. 'sczl_rate5' => $value['sczl_rate5'],
  1660. 'sczl_rate6' => $value['sczl_rate6'],
  1661. 'sczl_rate7' => $value['sczl_rate7'],
  1662. 'sczl_rate8' => $value['sczl_rate8'],
  1663. '类型' => '',
  1664. '客户代号' => $value['Gd_客户代号'],
  1665. '客户名称' => $value['Gd_客户名称'],
  1666. '产品代号' => $value['Gd_cpdh'],
  1667. '产品名称' => $value['Gd_cpmc'],
  1668. '销售订单号' => $value['销售订单号'],
  1669. '订单数量' => $value['订单数量'],
  1670. '计量单位' => $value['计量单位'],
  1671. '实际投料' => $data['实际投料'],
  1672. '入仓数量' => $total_number[0],
  1673. '入仓日期' => $workOrderData['jjcp_sj'],
  1674. '大箱数' => $value['投料大箱'],
  1675. '废品合计' => $data['工单质检废'] + $data['zcfp'],
  1676. 'sys_id' => '',
  1677. 'sys_rq' => date('Y-m-d H:i:s', time()),
  1678. '车间名称' => $value['Gy0_SITE']
  1679. ];
  1680. }
  1681. return $result;
  1682. // halt($result);
  1683. // \db('工单_质量考核汇总')
  1684. // ->where('Gy0_gdbh', $param['gdbh'])
  1685. // ->where('印件及工序', $param['yjno'])
  1686. // ->delete();
  1687. // $sql = \db('工单_质量考核汇总')
  1688. // ->fetchSql(true)
  1689. // ->insertAll($result);
  1690. // $res = \db()->query($sql);
  1691. }
  1692. /**
  1693. * 超节损列表
  1694. * @return void
  1695. * @throws \think\db\exception\DataNotFoundException
  1696. * @throws \think\db\exception\ModelNotFoundException
  1697. * @throws \think\exception\DbException
  1698. */
  1699. public function getList()
  1700. {
  1701. if (!Request::instance()->isGet()) {
  1702. $this->error('非法请求');
  1703. }
  1704. $params = Request::instance()->param();
  1705. $where = [];
  1706. // 设置默认分页和限制
  1707. $limit = empty($params['limit']) ? 15 : intval($params['limit']);
  1708. $pages = empty($params['page']) ? 1 : intval($params['page']);
  1709. // 构建查询条件
  1710. if (!empty($params['code'])) {
  1711. // 根据产品代号是否含有字母确定匹配长度
  1712. $prefixLength = preg_match('/[A-Za-z]/', $params['code']) ? 5 : 4;
  1713. $where['a.jjcp_cpdh'] = ['LIKE', substr($params['code'], 0, $prefixLength) . '%'];
  1714. }
  1715. if (!empty($params['date'])) {
  1716. $year = substr($params['date'], 0, 4); // 取前4位作为年份
  1717. $month = substr($params['date'], 4, 2); // 取后2位作为月份
  1718. // 格式化为需要的值
  1719. $formattedDate = $year . '-' . $month;
  1720. $where['a.jjcp_sj'] = ['like',$formattedDate.'%'];
  1721. }
  1722. if (!empty($params['search'])) {
  1723. if (!empty($params['date']) || !empty($params['code'])) {
  1724. $this->error('参数错误');
  1725. }
  1726. $where['a.jjcp_gdbh|a.jjcp_cpdh|a.jjcp_cpmc'] = ['like', '%' . $params['search'] . '%'];
  1727. }
  1728. // 定义字段
  1729. $field = '
  1730. b.sys_ny,
  1731. a.jjcp_gdbh AS Gd_gdbh,
  1732. a.jjcp_yjno AS jjcp_yjno,
  1733. a.jjcp_yjno AS yj_Yjno,
  1734. c.yj_Yjdh as yjdh,
  1735. c.yj_ls AS yj_ls,
  1736. c.yj_cpdh AS 成品编码,
  1737. c.yj_yjmc AS 成品名称,
  1738. b.`实际投料`,
  1739. b.`计量单位`,
  1740. DATE(a.jjcp_sj) AS warehousing_date,
  1741. total_sl.warehousing_num,
  1742. SUM(DISTINCT b.`计划损耗`) AS `工单计划损耗`,
  1743. b.`废品合计`,
  1744. SUM(b.`CjsJe`) AS reward_money,
  1745. b.`印件无形损` AS 工单无形损,
  1746. b.`材料废`,
  1747. b.`零头处理`,
  1748. b.`外发废`,
  1749. SUM(b.`班组制程废品`) AS zcfp,
  1750. `工单质检废` AS 工单质检废,
  1751. c.质量考核,
  1752. c.工单类型
  1753. ';
  1754. // 子查询:计算所有记录的 jjcp_sl 总和(入仓数量)
  1755. $subQuery = \db('成品入仓')
  1756. ->alias('a_sub')
  1757. ->field('
  1758. a_sub.jjcp_gdbh AS Gd_gdbh_sub,
  1759. a_sub.jjcp_yjno AS jjcp_yjno_sub,
  1760. SUM(a_sub.jjcp_sl) AS warehousing_num
  1761. ')
  1762. ->group('a_sub.jjcp_gdbh, a_sub.jjcp_yjno')
  1763. ->buildSql();
  1764. $list = \db('成品入仓')
  1765. ->alias('a')
  1766. ->join('工单_质量考核汇总 b','a.jjcp_gdbh = b.Gy0_gdbh AND a.jjcp_yjno = b.印件及工序','left')
  1767. ->join('工单_印件资料 c','a.jjcp_gdbh = c.Yj_Gdbh AND a.jjcp_yjno = c.yj_Yjno')
  1768. ->join([$subQuery => 'total_sl'], 'a.jjcp_gdbh = total_sl.Gd_gdbh_sub AND a.jjcp_yjno = total_sl.jjcp_yjno_sub', 'left')
  1769. ->field($field)
  1770. ->where($where)
  1771. ->where('a.jjcp_smb','like','末%')
  1772. ->group('Gd_gdbh,jjcp_yjno')
  1773. ->order('warehousing_date DESC')
  1774. ->page($pages)
  1775. ->limit($limit)
  1776. ->select();
  1777. // 处理查询结果
  1778. foreach ($list as $key => $value) {
  1779. $status = \db('工单_印件资料')
  1780. ->where('Yj_Gdbh', $value['Gd_gdbh'])
  1781. ->where('yj_Yjno', $value['jjcp_yjno'])
  1782. ->value('质量考核');
  1783. $processDetail = \db('工单_工艺资料')
  1784. ->where('Gy0_gdbh', $value['Gd_gdbh'])
  1785. ->where('Gy0_yjno', $value['jjcp_yjno'])
  1786. ->field('CONCAT(rtrim(Gy0_gxmc),"[",rtrim(Add_gxmc),"]") as 工序名称,Gy0_ls as 联数')
  1787. ->select();
  1788. $number1 = $number2 = 1;
  1789. foreach ($processDetail as $k => $v) {
  1790. if (strpos($v['工序名称'],'分切') !== false) {
  1791. $number1 = $v['联数'];
  1792. }
  1793. if (strpos($v['工序名称'],'分切') === false && $v['联数'] > 1) {
  1794. $number2 = $v['联数'];
  1795. }
  1796. }
  1797. $Multiple = $number1/$number2;
  1798. if (is_int($Multiple) === false) {
  1799. $Multiple = 1;
  1800. }
  1801. $list[$key]['工单质检废'] = $value['废品合计'] - $value['zcfp'];
  1802. $list[$key]['质量考核'] = $status;
  1803. $list[$key]['考核'] = ($status == 1) ? '否' : '是';
  1804. if ($value['实际投料'] !== null){
  1805. $actualMaterial = $value['实际投料'] * 10000;
  1806. $list[$key]['target_rate'] = $this->calculateRate($actualMaterial, $value['工单计划损耗']);
  1807. $list[$key]['real_rate'] = $value['warehousing_num']/($value['实际投料']*10000)*100;
  1808. $list[$key]['real_rate'] = number_format($list[$key]['real_rate'], 2).'%';
  1809. }else{
  1810. $list[$key]['target_rate'] = null;
  1811. $list[$key]['real_rate'] = null;
  1812. }
  1813. $list[$key]['reward_rate'] = '1'; // or some logic if needed
  1814. }
  1815. if (!empty($list)) {
  1816. $this->success('成功', $list);
  1817. } else {
  1818. $this->error('未找到数据');
  1819. }
  1820. }
  1821. // 计算合格率
  1822. private function calculateRate($actual, $loss)
  1823. {
  1824. if ($actual == 0) {
  1825. return '0.00%'; // 防止除以零
  1826. }
  1827. $rate = ($actual - $loss) / $actual * 100;
  1828. return number_format($rate, 2) . '%';
  1829. }
  1830. /**
  1831. * 工序超节损
  1832. * @return void
  1833. * @throws \think\db\exception\DataNotFoundException
  1834. * @throws \think\db\exception\ModelNotFoundException
  1835. * @throws \think\exception\DbException
  1836. */
  1837. public function ProcessLoss()
  1838. {
  1839. if ($this->request->isGet() === false){
  1840. $this->error('请求错误');
  1841. }
  1842. $param = $this->request->param();
  1843. if (empty($param) || empty($param['order']) || empty($param['yjno'])){
  1844. $this->error('参数错误');
  1845. }
  1846. $where = ['Gy0_gdbh'=>$param['order'],'印件及工序'=>$param['yjno']];
  1847. //查询订单印件数据
  1848. $field = '
  1849. Gy0_gdbh AS Gd_gdbh,
  1850. `印件及工序` AS yjno,
  1851. `联数` AS ls,
  1852. `产品代号` AS `成品代号`,
  1853. `产品名称` AS `成品名称`,
  1854. `实际投料`,
  1855. `计量单位`,
  1856. DATE(`入仓日期`) AS warehousing_date,
  1857. `入仓数量` AS warehousing_num,
  1858. SUM(DISTINCT `计划损耗`) AS `计划损耗`,
  1859. `废品合计`,
  1860. `印件无形损` as intangible_loss,
  1861. `材料废`,
  1862. `零头处理`,
  1863. `外发废`,
  1864. SUM(`班组制程废品`) AS `zcfp`,
  1865. `工单质检废` AS `班组分摊质检废品`,
  1866. `订单数量`,
  1867. `销售订单号`
  1868. ';
  1869. $list = \db('工单_质量考核汇总')
  1870. ->field($field)
  1871. ->where($where)
  1872. ->group('Gy0_gdbh, `印件及工序`')
  1873. ->order('sys_rq DESC')
  1874. ->find();
  1875. $processDetail = \db('工单_工艺资料')
  1876. ->where('Gy0_gdbh', $param['order'])
  1877. ->where('Gy0_yjno', $param['yjno'])
  1878. ->field('CONCAT(rtrim(Gy0_gxmc),"[",rtrim(Add_gxmc),"]") as 工序名称,Gy0_ls as 联数')
  1879. ->select();
  1880. $status = \db('工单_印件资料')
  1881. ->where('Yj_Gdbh', $param['order'])
  1882. ->where('yj_Yjno', $param['yjno'])
  1883. ->value('质量考核');
  1884. // 添加到 $list 数组中
  1885. $list['质量考核'] = $status;
  1886. $list['考核'] = ($status == 1) ? '不参与考核' : '参与考核';
  1887. // $number1 = $number2 = 1;
  1888. // foreach ($processDetail as $k => $v) {
  1889. // if (strpos($v['工序名称'],'分切') !== false) {
  1890. // $number1 = $v['联数'];
  1891. // }
  1892. // if (strpos($v['工序名称'],'分切') === false && $v['联数'] > 1) {
  1893. // $number2 = $v['联数'];
  1894. // }
  1895. // }
  1896. // $Multiple = $number1/$number2;
  1897. // if (is_int($Multiple) === false) {
  1898. // $Multiple = 1;
  1899. // }
  1900. $list['实际投料'] = $list['实际投料']*10000;
  1901. //目标合格率
  1902. $list['target_rate'] = ($list['实际投料']-$list['计划损耗'])/$list['实际投料']*100;
  1903. $list['target_rate'] = number_format($list['target_rate'],2);
  1904. $list['target_rate'] = $list['target_rate'].'%';
  1905. //实际合格率
  1906. // $list['real_rate'] = $list['warehousing_num']/($list['实际投料']*$Multiple)*100;
  1907. $list['real_rate'] = $list['warehousing_num']/($list['实际投料'])*100;
  1908. $list['real_rate'] = number_format($list['real_rate'],2);
  1909. $list['real_rate'] = $list['real_rate'].'%';
  1910. //查询工序数据
  1911. $gy_field = '
  1912. `工序` AS Gy0_gxh,
  1913. `工序名称` AS Gy0_gxmc,
  1914. `印件及工序` AS Gy0_yjno,
  1915. `联数` AS Gy0_ls,
  1916. 计划损耗 AS Gy0_计划损耗,
  1917. `计划产量` AS Gy0_计划接货数,
  1918. SUM(`班组分摊无形损`) AS Gy0_无形损,
  1919. SUM(`CjsSl`) AS loss,
  1920. `印件工序产量` AS total_cl,
  1921. SUM(`班组制程废品`) AS total_fp,
  1922. SUM(`班组分摊质检废品`) AS waste_quality,
  1923. SUM(`CjsJe`) AS 工序超节损金额,
  1924. `无形损承担比例`,
  1925. `超节损承担比例`
  1926. ';
  1927. $gy_data = \db('工单_质量考核汇总')
  1928. ->field($gy_field)
  1929. ->where($where)
  1930. ->group('Gy0_gxh')
  1931. ->select();
  1932. foreach ($gy_data as $key=>$value){
  1933. if (strpos($value['Gy0_gxmc'],'分切') === false) {
  1934. $Multiple = 1;
  1935. }
  1936. //报废合计
  1937. $gy_data[$key]['total_waste'] = $value['Gy0_无形损'] + $value['total_fp'] + $value['waste_quality'];
  1938. //工序实际报废率
  1939. $gy_data[$key]['actual_loss_rate'] = ((number_format($gy_data[$key]['total_waste']/$list['实际投料'],4))*100).'%';
  1940. //工序目标报废率
  1941. $gy_data[$key]['target_loss_rate'] = ((number_format($value['Gy0_计划损耗']/$list['实际投料'],4))*100).'%';
  1942. //占投料报废率
  1943. $gy_data[$key]['loss_rate'] = ((number_format(($value['Gy0_计划损耗']-$gy_data[$key]['total_waste'])/$list['实际投料'],4))*100).'%';
  1944. }
  1945. $list['gy_data'] = $gy_data;
  1946. $total = [
  1947. 'total_waste' => 0,
  1948. 'total_zjfp' => 0,
  1949. 'total_fp' => 0,
  1950. 'plan_loss' => 0,
  1951. 'waste_intangible' => 0,
  1952. 'loss' => 0,
  1953. 'reward' => 0,
  1954. ];
  1955. foreach ($gy_data as $item){
  1956. $total['total_waste'] += $item['total_waste'];
  1957. $total['total_zjfp'] += $item['waste_quality'];
  1958. $total['total_fp'] += $item['total_fp'];
  1959. $total['plan_loss'] += $item['Gy0_计划损耗'];
  1960. $total['waste_intangible'] += $item['Gy0_无形损'];
  1961. $total['loss'] += $item['loss'];
  1962. $total['reward'] += $item['工序超节损金额'];
  1963. }
  1964. $total['reward'] = round($total['reward'],2);
  1965. //查询废品数量
  1966. $out_sql = "SELECT qczl_num,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,
  1967. 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,
  1968. 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,
  1969. 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
  1970. FROM db_qczl WHERE qczl_gdbh = '{$param['order']}' AND qczl_yjno = '{$param['yjno']}'";
  1971. $waste_out = Db::query($out_sql);
  1972. $machine = [];//机检废品数组
  1973. $o = 0;
  1974. foreach ($waste_out as $entry) {
  1975. for ($i = 1; $i <= 13; $i++) {
  1976. $labelKey = "fp_lb" . $i;
  1977. $slKey = "fp_sl" . $i;
  1978. if (!empty($entry[$labelKey])) {
  1979. //机检废品
  1980. if (substr($entry[$labelKey],0,1) == 'K' ){
  1981. $machine[$o]= $entry[$slKey];
  1982. $o++;
  1983. }
  1984. }
  1985. }
  1986. }
  1987. $list['机检废'] = array_sum($machine);//机检废
  1988. $list['total'] = $total;
  1989. $this->success('成功',$list);
  1990. }
  1991. //班组超节损数据
  1992. public function ClassLossData()
  1993. {
  1994. if ($this->request->isGet() === false){
  1995. $this->error('请求错误');
  1996. }
  1997. $param = $this->request->param();
  1998. if (empty($param) || empty($param['order']) || empty($param['yjno'])){
  1999. $this->error('参数错误');
  2000. }
  2001. $where = ['Gy0_gdbh'=>$param['order'],'印件及工序'=>$param['yjno']];
  2002. //查询订单印件数据
  2003. $field = '
  2004. Gy0_gdbh AS Gd_gdbh,
  2005. `印件及工序` AS yjno,
  2006. `联数` AS ls,
  2007. `产品代号` AS `成品代号`,
  2008. `产品名称` AS `成品名称`,
  2009. `实际投料`,
  2010. `计量单位`,
  2011. DATE(`入仓日期`) AS warehousing_date,
  2012. `入仓数量` AS warehousing_num,
  2013. SUM(DISTINCT `计划损耗`) AS `计划损耗`,
  2014. `废品合计`,
  2015. `印件无形损` as intangible_loss,
  2016. `材料废`,
  2017. `零头处理`,
  2018. `外发废`,
  2019. SUM(`班组制程废品`) AS `zcfp`,
  2020. `工单质检废` AS `班组分摊质检废品`,
  2021. `订单数量`,
  2022. `销售订单号`
  2023. ';
  2024. $list = \db('工单_质量考核汇总')
  2025. ->field($field)
  2026. ->where($where)
  2027. ->group('Gy0_gdbh, `印件及工序`')
  2028. ->order('sys_rq DESC')
  2029. ->find();
  2030. $processDetail = \db('工单_工艺资料')
  2031. ->where('Gy0_gdbh', $param['order'])
  2032. ->where('Gy0_yjno', $param['yjno'])
  2033. ->field('CONCAT(rtrim(Gy0_gxmc),"[",rtrim(Add_gxmc),"]") as 工序名称,Gy0_ls as 联数')
  2034. ->select();
  2035. $status = \db('工单_印件资料')
  2036. ->where('Yj_Gdbh', $param['order'])
  2037. ->where('yj_Yjno', $param['yjno'])
  2038. ->value('质量考核');
  2039. // 添加到 $list 数组中
  2040. $list['质量考核'] = $status;
  2041. $list['考核'] = ($status == 1) ? '不参与考核' : '参与考核';
  2042. // $number1 = $number2 = 1;
  2043. // foreach ($processDetail as $k => $v) {
  2044. // if (strpos($v['工序名称'],'分切') !== false) {
  2045. // $number1 = $v['联数'];
  2046. // }
  2047. // if (strpos($v['工序名称'],'分切') === false && $v['联数'] > 1) {
  2048. // $number2 = $v['联数'];
  2049. // }
  2050. // }
  2051. // $Multiple = $number1/$number2;
  2052. // if (is_int($Multiple) === false) {
  2053. // $Multiple = 1;
  2054. // }
  2055. $list['实际投料'] = $list['实际投料']*10000;
  2056. //目标合格率
  2057. $list['target_rate'] = ($list['实际投料']-$list['计划损耗'])/$list['实际投料']*100;
  2058. $list['target_rate'] = number_format($list['target_rate'],2);
  2059. $list['target_rate'] = $list['target_rate'].'%';
  2060. //实际合格率
  2061. // $list['real_rate'] = $list['warehousing_num']/($list['实际投料']*$Multiple)*100;
  2062. $list['real_rate'] = $list['warehousing_num']/($list['实际投料'])*100;
  2063. $list['real_rate'] = number_format($list['real_rate'],2);
  2064. $list['real_rate'] = $list['real_rate'].'%';
  2065. //班组数据
  2066. $gy_data = \db('工单_质量考核汇总')
  2067. ->where($where)
  2068. ->select();
  2069. $class_data = [];
  2070. foreach ($gy_data as $item){
  2071. $name = '';
  2072. for ($i=1;$i<9;$i++){
  2073. if ($item['Xm'.$i] !== ''){
  2074. $name = $name.' '.$item['Xm'.$i];
  2075. }
  2076. }
  2077. $data = [
  2078. 'member' => $name,
  2079. 'sczl_gxmc' => $item['工序名称'],
  2080. 'total_cl' => $item['班组产量'],
  2081. '计划损耗' => $item['班组分摊计划损耗'],
  2082. '无形损分摊' => $item['班组分摊无形损'],
  2083. '节损奖' => $item['CjsJe'],
  2084. '节损数量' => $item['CjsSl'],
  2085. 'sczl_zcfp' => $item['班组制程废品'],
  2086. '质检废' => $item['班组分摊质检废品'],
  2087. '超节损承担比例' => ($item['超节损承担比例']*100).'%',
  2088. ];
  2089. array_push($class_data,$data);
  2090. }
  2091. $list['gy_data'] = $class_data;
  2092. //工单节损数据
  2093. $total_field = '
  2094. SUM(`班组分摊质检废品`) as total_waste,
  2095. SUM(`班组质检废品`) as total_zjfp,
  2096. SUM(`班组制程废品`) as total_fp,
  2097. SUM(DISTINCT `计划损耗`) AS plan_loss,
  2098. `材料废`,
  2099. `印件无形损` as waste_intangible,
  2100. SUM(CjsSl) as loss,
  2101. SUM(CjsJe) as reward
  2102. ';
  2103. $total = \db('工单_质量考核汇总')
  2104. ->where($where)
  2105. ->field($total_field)
  2106. ->find();
  2107. //查询废品数量
  2108. $out_sql = "SELECT qczl_num,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,
  2109. 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,
  2110. 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,
  2111. 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
  2112. FROM db_qczl WHERE qczl_gdbh = '{$param['order']}' AND qczl_yjno = '{$param['yjno']}'";
  2113. $waste_out = Db::query($out_sql);
  2114. $machine = [];//机检废品数组
  2115. $o = 0;
  2116. foreach ($waste_out as $entry) {
  2117. for ($i = 1; $i <= 13; $i++) {
  2118. $labelKey = "fp_lb" . $i;
  2119. $slKey = "fp_sl" . $i;
  2120. if (!empty($entry[$labelKey])) {
  2121. //机检废品
  2122. if (substr($entry[$labelKey],0,1) == 'K' ){
  2123. $machine[$o]= $entry[$slKey];
  2124. $o++;
  2125. }
  2126. }
  2127. }
  2128. }
  2129. $list['机检废'] = array_sum($machine);//机检废
  2130. $list['total'] = $total;
  2131. $this->success('成功',$list);
  2132. }
  2133. /**
  2134. * 循环插入超节损数据
  2135. * @return void
  2136. * @throws \think\Exception
  2137. * @throws \think\db\exception\BindParamException
  2138. * @throws \think\db\exception\DataNotFoundException
  2139. * @throws \think\db\exception\ModelNotFoundException
  2140. * @throws \think\exception\DbException
  2141. * @throws \think\exception\PDOException
  2142. */
  2143. public function orderLossData()
  2144. {
  2145. $param = $this->request->param();
  2146. $where = [];
  2147. if (isset($param['gdbh']) && isset($param['yjno']) && !empty($param['gdbh']) && !empty($param['yjno'])){
  2148. $where['a.jjcp_gdbh'] = $param['gdbh'];
  2149. $where['a.jjcp_yjno'] = $param['yjno'];
  2150. }
  2151. if (isset($param['mouth'])){
  2152. $where['a.jjcp_sj'] = ['like',$param['mouth'].'%'];
  2153. }
  2154. $where['a.jjcp_smb'] = ['like','末%'];
  2155. $list = \db('成品入仓')
  2156. ->alias('a')
  2157. ->join('设备_产量计酬 b','a.jjcp_gdbh = b.sczl_gdbh AND a.jjcp_yjno = b.sczl_yjno')
  2158. ->join('物料_收发记录 c','a.jjcp_gdbh = c.st_gdbh AND a.jjcp_cpdh = c.cpdh')
  2159. ->where($where)
  2160. ->where(function ($query) {
  2161. $query->where('c.仓库编号', '101')
  2162. ->whereOr('c.仓库编号', 'Y101');
  2163. })
  2164. ->field('a.jjcp_gdbh,a.jjcp_yjno')
  2165. ->group('a.jjcp_gdbh,a.jjcp_yjno')
  2166. ->select();
  2167. $i = 0;
  2168. if (empty($list)) {
  2169. $this->error('未搜索到工单入仓数据');
  2170. }
  2171. foreach ($list as $item){
  2172. $jobData = [
  2173. 'gdbh' => $item['jjcp_gdbh'],
  2174. 'yjno' => $item['jjcp_yjno'],
  2175. 'created_at' => date('Y-m-d H:i:s'),
  2176. ];
  2177. $res = Queue::push('app\\job\\OrderSuperLossJob', $jobData, 'order_loss_calculation');
  2178. if (!$res) {
  2179. $i++;
  2180. }
  2181. }
  2182. if ($i === 0){
  2183. $this->success('任务已提交,共' . count($list) . '条');
  2184. }else{
  2185. $this->error('提交完成,失败' . $i . '条');
  2186. }
  2187. }
  2188. /**
  2189. * 创建投料数
  2190. * @return void
  2191. */
  2192. public function feedAdd()
  2193. {
  2194. // 1. 请求验证
  2195. if (!$this->request->isPost()) {
  2196. $this->error('请求错误');
  2197. }
  2198. $param = Request::instance()->post();
  2199. if (empty($param)) {
  2200. $this->error('参数错误');
  2201. }
  2202. // 2. 数据验证
  2203. $requiredFields = ['st_gdbh', 'st_sl', 'st_dw', 'sys_id', 'cpdh'];
  2204. foreach ($requiredFields as $field) {
  2205. if (!isset($param[$field]) || $param[$field] === '') {
  2206. $this->error("参数{$field}不能为空");
  2207. }
  2208. }
  2209. try {
  2210. // 3. 数据准备
  2211. $currentTime = date('Y-m-d H:i:s');
  2212. $currentDate = date('Y-m-d');
  2213. // 仓库编号逻辑
  2214. $cangku = preg_match('/[a-zA-Z]/', $param['st_gdbh']) ? 'Y101' : '101';
  2215. // 4. 主数据
  2216. $data = [
  2217. 'st_rq' => $currentDate,
  2218. 'st_jylb' => '生产领料',
  2219. 'st_gdbh' => $param['st_gdbh'],
  2220. 'st_wlbh' => $param['st_wlbh'],
  2221. 'st_sl' => $param['st_sl'],
  2222. 'st_dw' => $param['st_dw'],
  2223. 'sys_id' => $param['sys_id'],
  2224. 'sys_rq' => $currentTime,
  2225. 'cpdh' => $param['cpdh'],
  2226. ];
  2227. // 添加仓库编号(特殊处理)
  2228. $data['`仓库编号`'] = $cangku;
  2229. // 5. 日志数据
  2230. $logData = [
  2231. 'Gd_gdbh' => $param['st_gdbh'],
  2232. 'ModifyUser' => $param['sys_id'],
  2233. 'ModifyTime' => $currentTime,
  2234. 'FieldName' => 'st_sl',
  2235. 'NewValue' => $param['st_sl'],
  2236. 'ModifySource' => '新增物料投料数'
  2237. ];
  2238. // 6. 开启事务
  2239. Db::startTrans();
  2240. // 7. 插入日志
  2241. Db::name('系统操作日志表')->insert($logData);
  2242. // 8. 插入主记录 - 手动构建安全的SQL语句
  2243. $fields = array_keys($data);
  2244. $values = array_values($data);
  2245. // 构建字段名部分
  2246. $fieldList = implode(', ', array_map(function($field) {
  2247. return strpos($field, '`') === 0 ? $field : "`{$field}`";
  2248. }, $fields));
  2249. // 构建占位符
  2250. $placeholders = implode(', ', array_fill(0, count($values), '?'));
  2251. // 执行安全的参数化查询
  2252. $sql = "INSERT INTO `物料_收发记录` ({$fieldList}) VALUES ({$placeholders})";
  2253. $feedResult = Db::execute($sql, $values);
  2254. if ($feedResult === false) {
  2255. throw new Exception('新增物料记录失败');
  2256. }
  2257. // 9. 获取工单信息
  2258. $totalNum = Db::name('工单_印件资料')
  2259. ->field('yj_ls, yj_ks, yj_tlgg, yj_zzmc, yj_Yjno')
  2260. ->where('Yj_Gdbh', $param['st_gdbh'])
  2261. ->where('yj_Yjdh', $param['cpdh'])
  2262. ->find();
  2263. if (!$totalNum) {
  2264. throw new Exception('未找到对应的工单印件资料');
  2265. }
  2266. // 10. 计算投料数量
  2267. $num = $param['st_sl'];
  2268. if (!empty($totalNum['yj_tlgg'])) {
  2269. $dimensions = explode('*', $totalNum['yj_tlgg']);
  2270. $number1 = (int)($dimensions[0] ?? 0);
  2271. $number2 = (int)($dimensions[1] ?? 0);
  2272. preg_match('/(\d+)g/', $totalNum['yj_zzmc'], $matches);
  2273. $paperWeight = $matches[1] ?? 0;
  2274. if ($param['st_dw'] === '吨' && $paperWeight > 0 && $number1 > 0 && $number2 > 0) {
  2275. $num = round(($param['st_sl'] * 1000000) / $paperWeight / ($number1 * $number2) * 1000000);
  2276. }
  2277. }
  2278. // 11. 计算实际投料
  2279. $actualFeed = $num / 10000 * $totalNum['yj_ls'] * $totalNum['yj_ks'];
  2280. // 12. 更新工单基本资料 - 使用原生SQL处理中文字段
  2281. $updateBasicSql = "UPDATE `工单_基本资料` SET `实际投料` = ? WHERE `Gd_gdbh` = ? AND `Gd_cpdh` = ?";
  2282. $basicResult = Db::execute($updateBasicSql, [$actualFeed, $param['st_gdbh'], $param['cpdh']]);
  2283. if ($basicResult === false) {
  2284. throw new Exception('更新工单基本资料失败');
  2285. }
  2286. // 13. 更新工单印件资料 - 使用原生SQL
  2287. $updateYjSql = "UPDATE `工单_印件资料` SET `yj_实际投料` = ? WHERE `Yj_Gdbh` = ? AND `yj_cpdh` = ?";
  2288. $yjResult = Db::execute($updateYjSql, [$actualFeed, $param['st_gdbh'], $param['cpdh']]);
  2289. if ($yjResult === false) {
  2290. throw new Exception('更新工单印件资料失败');
  2291. }
  2292. $yjNo = $totalNum['yj_Yjno'];
  2293. // 14. 重新计算工单超节损数据
  2294. $resultAdd = $this->OneOrderSuperLoss($param['st_gdbh'], $yjNo);
  2295. // 15. 更新质量考核汇总 - 先删除
  2296. $deleteSql = "DELETE FROM `工单_质量考核汇总` WHERE `Gy0_gdbh` = ? AND `印件及工序` = ?";
  2297. Db::execute($deleteSql, [$param['st_gdbh'], $yjNo]);
  2298. // 16. 插入新的质量考核数据
  2299. if (!empty($resultAdd)) {
  2300. foreach ($resultAdd as $item) {
  2301. $fields = array_keys($item);
  2302. $values = array_values($item);
  2303. $fieldList = implode(', ', array_map(function($field) {
  2304. return strpos($field, '`') === 0 ? $field : "`{$field}`";
  2305. }, $fields));
  2306. $placeholders = implode(', ', array_fill(0, count($values), '?'));
  2307. $insertSql = "INSERT INTO `工单_质量考核汇总` ({$fieldList}) VALUES ({$placeholders})";
  2308. Db::execute($insertSql, $values);
  2309. }
  2310. }
  2311. // 17. 提交事务
  2312. Db::commit();
  2313. $this->success('新增成功');
  2314. } catch (Exception $e) {
  2315. // 18. 回滚事务
  2316. Db::rollback();
  2317. $this->error('操作失败: ' . $e->getMessage());
  2318. }
  2319. }
  2320. /**
  2321. * 获取物料信息
  2322. * @return void
  2323. * @throws \think\db\exception\DataNotFoundException
  2324. * @throws \think\db\exception\ModelNotFoundException
  2325. * @throws \think\exception\DbException
  2326. */
  2327. public function getFeedList()
  2328. {
  2329. if (Request::instance()->isGet() == false) {
  2330. $this->error('非法请求');
  2331. }
  2332. $params = Request::instance()->request();
  2333. if (empty($params['workorder']) || empty($params['yjno'])) {
  2334. $this->error('参数错误');
  2335. }
  2336. $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,
  2337. rtrim(b.BOM_物料名称) as BOM_物料名称,rtrim(c.yj_tlgg) as yj_tlgg,
  2338. a.订单数量,c.yj_平张投料, b.BOM_实际用量,a.投料确认";
  2339. $data =db('工单_基本资料')->alias('a')
  2340. ->join('工单_印件资料 c','a.Gd_gdbh = c.Yj_Gdbh ','left')
  2341. ->join('工单_bom资料 b','c.Yj_Gdbh = b.BOM_工单编号 AND c.yj_zzdh = b.BOM_物料编码','left')
  2342. ->where('a.Gd_gdbh',$params['workorder'])
  2343. ->where('c.yj_Yjno',$params['yjno'])
  2344. ->field($field)
  2345. ->group('a.Gd_gdbh')
  2346. ->order('b.BOM_投料单位,a.UniqId asc')
  2347. ->select();
  2348. if (empty($data)){
  2349. $this->success('请求成功');
  2350. }
  2351. foreach ($data as $key=>$value){
  2352. $len = stripos($value['yj_tlgg'],'/');
  2353. if ($len){
  2354. $name = substr($value['yj_tlgg'],0,$len);
  2355. $len_two = stripos($value['yj_tlgg'],'(');
  2356. if ($len_two){
  2357. $name = substr($name,0,$len_two);
  2358. }
  2359. $data[$key]['yj_tlgg'] = $name;
  2360. }
  2361. $data[$key]['rate'] = '';
  2362. }
  2363. $this->success('请求成功',$data);
  2364. }
  2365. /**
  2366. * 获取工单类型
  2367. * @return void
  2368. */
  2369. public function getWorkorderStatus()
  2370. {
  2371. if ($this->request->isGet() == false) {
  2372. $this->error('请求错误');
  2373. }
  2374. $param = $this->request->param();
  2375. if (empty($param['workorder']) || empty($param['yjno'])) {
  2376. $this->error('参数错误');
  2377. }
  2378. $data = \db('工单_印件资料')
  2379. ->where('Yj_Gdbh',$param['workorder'])
  2380. ->where('yj_Yjno',$param['yjno'])
  2381. ->field('Yj_gdbh,rtrim(yj_Yjdh) as yj_Yjdh,yj_Yjno,rtrim(yj_yjmc) as yj_yjmc,工单类型')
  2382. ->find();
  2383. $this->success('成功',$data);
  2384. }
  2385. /**
  2386. * 修改工单类型
  2387. * @return void
  2388. * @throws Exception
  2389. * @throws \think\db\exception\BindParamException
  2390. * @throws \think\exception\PDOException
  2391. */
  2392. public function updateWorkorderStatus()
  2393. {
  2394. if ($this->request->isGet() == false) {
  2395. $this->error('请求错误');
  2396. }
  2397. $param = $this->request->param();
  2398. if (empty($param['workorder']) || empty($param['yjno']) || empty($param['status'])) {
  2399. $this->error('参数错误');
  2400. }
  2401. $sql = \db('工单_印件资料')
  2402. ->where('Yj_Gdbh',$param['workorder'])
  2403. ->where('yj_Yjno',$param['yjno'])
  2404. ->fetchSql(true)
  2405. ->update(['工单类型'=>$param['status']]);
  2406. $result = db()->query($sql);
  2407. if ($result !== false) {
  2408. $this->success('修改成功');
  2409. }else{
  2410. $this->error('修改失败');
  2411. }
  2412. }
  2413. }