ReportingWork.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use \think\Request;
  5. use \think\Db;
  6. /**
  7. * 车间报工接口
  8. */
  9. class ReportingWork extends Api
  10. {
  11. protected $noNeedLogin = ['*'];
  12. protected $noNeedRight = ['*'];
  13. /**
  14. * 首页
  15. *
  16. */
  17. public function index()
  18. {
  19. $this->success('请求成功');
  20. }
  21. /**
  22. * 设置机台状态
  23. * @ApiMethod POST
  24. * @params
  25. */
  26. public function setMachineStatus(){
  27. if (Request::instance()->isPost() == false){
  28. $this->error('非法请求');
  29. }
  30. $params = Request::instance()->post();
  31. if (!isset($params['machine']) || empty($params['machine'])){
  32. $this->error('参数不能为空');
  33. }
  34. $machine = $params['machine'].'#';
  35. $data = [];
  36. // $lastData = \db('设备_产量采集')->where('设备编号',$machine)->order('UniqId desc')->find();
  37. $lastData = \db('设备_产量采集')
  38. // ->where('设备编号',$machine)
  39. ->order('UniqId desc')
  40. ->find();
  41. $id = $lastData['UniqId'] + 1;
  42. if (empty($params['order'])){
  43. unset($lastData['UniqId']);
  44. $data = $lastData;
  45. $data['当前状态'] = $params['status'];
  46. }else{
  47. $data['当前状态'] = $params['status'];
  48. $data['时间'] = date('Y-m-d H:i:s');
  49. $data['设备编号'] = $machine;
  50. $data['工单编号'] = $params['order'];
  51. $data['印件号'] = $params['yjno'];
  52. $data['工序号'] = (int)substr($params['gy_name'],0,2);
  53. $data['工序名称'] = $params['gy_name'];
  54. $data['当班产量'] = $params['production_now'];
  55. $data['累计产量'] = $params['production_all'];
  56. $class = explode(',',$params['class']);
  57. $where = [];
  58. $where['sczl_jtbh'] = $machine;
  59. for ($i=1;$i<=count($class);$i++){
  60. $where['sczl_bh'.$i] = $class[$i-1];
  61. }
  62. // $classData = \db('设备_班组资料')->where($where)->field('sczl_bzdh,UniqId')->find();
  63. $classData = \db('设备_班组资料')->where($where)->field('sczl_bzdh,UniqId')->find();
  64. $data['班组编号'] = $classData['sczl_bzdh'];
  65. $data['班组ID'] = $classData['UniqId'];
  66. // 获取当前时间
  67. $current_time = time();
  68. // 设置时间范围
  69. $start_time1 = strtotime(date('Y-m-d') . ' 08:30:00');
  70. $end_time1 = strtotime(date('Y-m-d') . ' 20:30:00');
  71. $end_time2 = strtotime(date('Y-m-d') . ' 24:00:00');
  72. $start_time3 = strtotime(date('Y-m-d', strtotime('+1 day')) . ' 08:30:00');
  73. // 判断当前时间属于哪个时间范围
  74. if ($current_time >= $start_time1 && $current_time <= $end_time1) {
  75. $data['开工时间'] = date('Y-m-d') . ' 08:30:00';
  76. } elseif ($current_time > $end_time1 && $current_time <= $end_time2) {
  77. $data['开工时间'] = date('Y-m-d') . ' 20:30:00';
  78. } elseif ($current_time > $end_time1 && $current_time <= $start_time3) {
  79. $data['开工时间'] = date('Y-m-d',strtotime('+1 day')) . ' 08:30:00';
  80. }
  81. $option['Gy0_gdbh'] = $params['order'];
  82. $option['Gy0_yjno'] = $params['yjno'];
  83. $option['Gy0_gxh'] = $data['工序号'];
  84. $data['任务ID'] = \db('工单_工艺资料')->where($option)->value('UniqId');
  85. }
  86. $data['UniqId'] = $id;
  87. // $sql = \db('设备_产量采集')->fetchSql(true)->insert($data);
  88. $sql = \db('设备_产量采集')->fetchSql(true)->insert($data);
  89. $res = Db::query($sql);
  90. if ($res === false){
  91. $this->error('设置失败');
  92. }else{
  93. $this->success('设置成功');
  94. }
  95. }
  96. /**
  97. * 设置工单工序完工
  98. * @ApiMethod POST
  99. * @params string order
  100. * @params string yjno
  101. * @params string gxh
  102. */
  103. public function setProcessStatus(){
  104. if (Request::instance()->isPost() == false){
  105. $this->error('非法请求');
  106. }
  107. $params = Request::instance()->post();
  108. if (!isset($params['order']) || empty($params['order'])){
  109. $this->error('参数不能为空');
  110. }
  111. if (!isset($params['yjno']) || empty($params['yjno'])){
  112. $this->error('参数不能为空');
  113. }
  114. if (!isset($params['gxh']) || empty($params['gxh'])){
  115. $this->error('参数不能为空');
  116. }
  117. $where['Gy0_gdbh'] = $params['order'];
  118. $where['Gy0_yjno'] = $params['yjno'];
  119. $where['Gy0_gxh'] = $params['gxh'];
  120. $date = date('Y-m-d H:i:s');
  121. $res = \db('工单_工艺资料')->where($where)->setField('PD_WG',$date);
  122. if ($res === false){
  123. $this->error('设置失败');
  124. }else{
  125. $this->success('设置成功');
  126. }
  127. }
  128. /**
  129. * 根据机台获取生产信息
  130. * @ApiMethod GET
  131. * @params string machine
  132. */
  133. public function getProduceInfo(){
  134. if (Request::instance()->isGet() == false) {
  135. $this->error('非法请求');
  136. }
  137. $params = Request::instance()->param();
  138. if (!isset($params['machine']) || empty($params['machine'])) {
  139. $this->error('参数错误');
  140. }
  141. $machine = $params['machine'].'#';
  142. $data = \db('设备_产量采集')->where('设备编号',$machine)->order('UniqId desc')->find();
  143. $list = [];
  144. $list['order'] = $data['工单编号'];
  145. $list['yjno'] = $data['印件号'];
  146. $name = \db('工单_基本资料')->where('Gd_Gdbh',$data['工单编号'])->value('成品名称');
  147. $list['product_name'] = rtrim($name);
  148. $where['Gy0_gdbh'] = $data['工单编号'];
  149. $where['Gy0_yjno'] = $data['印件号'];
  150. $where['Gy0_gxh'] = $data['工序号'];
  151. $gxmc = \db('工单_工艺资料')->where($where)->value('Gy0_gxmc');
  152. $list['gxmc'] = rtrim($gxmc);
  153. $this->success('请求成功',$list);
  154. }
  155. /**
  156. * 根据员工编号获取姓名
  157. * @ApiMethod GET
  158. * @params string code
  159. */
  160. public function getStaffName(){
  161. if (Request::instance()->isGet() == false) {
  162. $this->error('非法请求');
  163. }
  164. $params = Request::instance()->param();
  165. if (!isset($params['code']) || empty($params['code'])) {
  166. $this->error('参数错误');
  167. }
  168. $data = \db('人事_基本资料')->where('员工编号',$params['code'])->value('员工姓名');
  169. if (empty($data)){
  170. $data = \db('人事_基本资料')->where('pycode',$params['code'])->value('员工姓名');
  171. }
  172. $this->success('请求成功',rtrim($data));
  173. }
  174. /**
  175. * 根据员工编号获取姓名-优化
  176. * @ApiMethod GET
  177. * @params string code
  178. */
  179. public function getStaffNameTwo(){
  180. if (Request::instance()->isGet() == false) {
  181. $this->error('非法请求');
  182. }
  183. $params = Request::instance()->param();
  184. if (!isset($params['code']) || empty($params['code'])) {
  185. $this->error('参数错误');
  186. }
  187. $data = \db('人事_基本资料')->where('员工编号',$params['code'])->field('员工姓名')->select();
  188. if (empty($data)){
  189. $data = \db('人事_基本资料')->where('pycode',$params['code'])->field('rtrim(员工姓名) as 员工姓名')->select();
  190. }
  191. $num = count($data);
  192. $res['total'] = $num;
  193. $res['data'] = $data;
  194. $this->success('请求成功',$res);
  195. }
  196. /**
  197. * 提交巡查记录
  198. * @ApiMethod POST
  199. * @params
  200. */
  201. public function submitPatrolRecord(){
  202. if (Request::instance()->isPost() == false){
  203. $this->error('非法请求');
  204. }
  205. $params = Request::instance()->post();
  206. if (empty($params['machine']) || empty($params['type']) || empty($params['order'])) {
  207. $this->error('参数错误');
  208. }
  209. if (empty($params['yjno']) || empty($params['process']) || empty($params['no'])) {
  210. $this->error('参数错误');
  211. }
  212. $data = [];
  213. $data['类别'] = $params['type'];
  214. $data['工单编号'] = $params['order'];
  215. $data['印件号'] = $params['yjno'];
  216. $data['工序名称'] = '';
  217. $data['班组编号'] = '';
  218. $data['开工时间'] = '';
  219. $data['流程单号'] = $params['process'];
  220. $data['设备编号'] = $params['machine'].'#';
  221. $data['检验项目'] = '['.$params['no'].'/'.$params['name'].']';
  222. $data['检验备注'] = $params['remark'];
  223. $data['提交时间'] = date('Y-m-d H:i:s');
  224. $data['sys_rq'] = date('Y-m-d H:i:s');
  225. $produce = \db('设备_产量采集')->where('设备编号',$params['machine'].'#')->where('工单编号',$params['order'])->order('UniqId desc')->find();
  226. // $produce = \db('设备_产量采集')->where('设备编号',$params['machine'].'#')->where('工单编号',$params['order'])->order('UniqId desc')->find();
  227. if (!empty($produce)){
  228. $data['工序名称'] = $produce['工序名称'];
  229. $data['班组编号'] = rtrim($produce['班组编号']);
  230. $data['开工时间'] = $produce['开工时间'];
  231. }
  232. // $res = \db('制程检验_记录')->field('UniqId')->order('UniqId desc')->find();
  233. $res = \db('制程检验_记录')->field('UniqId')->order('UniqId desc')->find();
  234. if (empty($res['UniqId'])){
  235. $data['UniqId'] = 1;
  236. }else{
  237. $data['UniqId'] = $res['UniqId'] + 1;
  238. }
  239. // $sql = \db('制程检验_记录')->fetchSql(true)->insert($data);
  240. $sql = \db('制程检验_记录')->fetchSql(true)->insert($data);
  241. $result = Db::query($sql);
  242. if ($result === false){
  243. $this->error('提交失败');
  244. }else{
  245. $this->success('提交成功');
  246. }
  247. }
  248. /**
  249. * 获取报工单其他信息
  250. * @ApiMethod Get
  251. * @params string machine
  252. */
  253. public function getMachineReportInfo(){
  254. if (Request::instance()->isGet() == false) {
  255. $this->error('非法请求');
  256. }
  257. $params = Request::instance()->param();
  258. if (!isset($params['machine']) || empty($params['machine'])) {
  259. $this->error('参数错误');
  260. }
  261. $machine = $params['machine'].'#';
  262. $data = [];
  263. $produce = \db('设备_产量采集')->where('设备编号',$machine)->order('UniqId desc')->find();
  264. if (empty($produce)){
  265. $this->error('无此设备数据');
  266. }
  267. $data['order_info']['order'] = $produce['工单编号'];
  268. $data['order_info']['yjno'] = $produce['印件号'];
  269. $data['order_info']['gxh'] = $produce['工序号'];
  270. $data['order_info']['gxmc'] = $produce['工序名称'];
  271. // $data['order_info']['dedh'] = \db('dic_lzde')->where('适用机型',$machine)->value('sys_bh');
  272. $product = \db('工单_基本资料')->alias('a')
  273. ->join('工单_工艺资料 b','a.Gd_Gdbh = b.Gy0_gdbh','left')
  274. ->join('工单_印件资料 c','a.Gd_Gdbh = c.Yj_gdbh','left')
  275. ->field('a.成品名称,b.Gy0_gxmc,b.Gy0_ms,b.Gy0_ls,c.yj_yjmc')
  276. ->where('a.Gd_Gdbh',$produce['工单编号'])
  277. ->where('b.Gy0_yjno',$produce['印件号'])
  278. ->where('b.Gy0_gxh',$produce['工序号'])
  279. ->where('c.Yj_yjno',$produce['印件号'])
  280. ->select();
  281. if (empty($product)){
  282. $this->error('无此工单数据');
  283. }
  284. $data['order_info']['product_name'] = '';
  285. $data['order_info']['yj_name'] = '';
  286. $data['order_info']['gy_name'] = '';
  287. if (!empty($product)){
  288. $data['order_info']['product_name'] = rtrim($product[0]['成品名称']);
  289. $data['order_info']['yj_name'] = rtrim($product[0]['yj_yjmc']);
  290. $data['order_info']['gy_name'] = rtrim($product[0]['Gy0_gxmc']);
  291. $data['order_info']['Gy0_ms'] = rtrim($product[0]['Gy0_ms']);
  292. $data['order_info']['Gy0_ls'] = rtrim($product[0]['Gy0_ls']);
  293. }
  294. $dedh = \db('dic_lzde')->where('适用机型',$machine)->value('sys_bh');
  295. if (strpos($params['machine'],'JP') !== false){
  296. if (strpos($data['order_info']['product_name'],'小盒') !== false){
  297. $data['order_info']['dedh'] = $dedh.'001';
  298. }else{
  299. $data['order_info']['dedh'] = $dedh.'002';
  300. }
  301. }else{
  302. $data['order_info']['dedh'] = $dedh;
  303. }
  304. $class = \db('设备_班组资料')->where('UniqId',$produce['班组ID'])->find();
  305. for ($i=1;$i<11;$i++){
  306. $name = '';
  307. if (!empty($class['sczl_bh'.$i])){
  308. $name = \db('人事_基本资料')->where('员工编号',$class['sczl_bh'.$i])->value('员工姓名');
  309. }
  310. $class['sczl_name'.$i] = rtrim($name);
  311. }
  312. $data['class'] = $class;
  313. $where['st_gdbh'] = $produce['工单编号'];
  314. $machine = substr($machine,0,2);
  315. if ($machine == 'JY' || $machine == 'QZ'){
  316. $where['st_dpt'] = '胶印车间';
  317. }elseif ($machine == 'WY' || $machine == 'DW'){
  318. $where['st_dpt'] = '凹印车间';
  319. }elseif ($machine == 'SY' || $machine == 'PM'){
  320. $where['st_dpt'] = '丝印车间';
  321. }elseif ($machine == 'MQ' || $machine == 'TJ'){
  322. $where['st_dpt'] = '烫模车间';
  323. }elseif ($machine == 'JP'){
  324. $where['st_dpt'] = '检验车间';
  325. }
  326. $material = \db('物料_收发记录')
  327. ->alias('a')
  328. ->join('工单_bom资料 b', 'a.st_gdbh = b.BOM_工单编号 AND a.st_wlbh = b.BOM_物料编码','left')
  329. ->where($where)
  330. ->field('RTRIM(a.供方批次) as batch, rtrim(采购单号) as 采购单号, st_wlbh, MIN(a.Uniqid) AS Uniqid, rtrim(b.BOM_物料名称) as BOM_物料名称')
  331. ->group('batch')
  332. ->order('a.st_wlbh')
  333. ->select();
  334. $data['bom'] = $material;
  335. $this->success('请求成功',$data);
  336. }
  337. /**
  338. * 日产量上报
  339. * @ApiMethod POST
  340. * @params array data
  341. */
  342. public function submitDailyProduction(){
  343. if (Request::instance()->isPost() == false){
  344. $this->error('非法请求');
  345. }
  346. $params = Request::instance()->post();
  347. $time = date('Y-m-d 00:00:00',time()-86400);
  348. if ($params['sczl_sj2']<date('Y-m-d 08:30:00',time()) && $params['sczl_sj2']>date('Y-m-d 00:00:00')){
  349. $params['sczl_rq'] = $time;
  350. }
  351. $machine = $params['sczl_jtbh'].'#';
  352. $batchData = []; //批次追踪数据
  353. $batch = $params['bom'];
  354. $data = $params;//产量数据
  355. $data['sczl_type'] = $params['sczl_gxmc'];
  356. $data['sczl_前工序废'] = $params['last_fp'];
  357. $data['sczl_来料少数'] = $params['less_sl'];
  358. $data['sczl_装版总工时'] = $params['zb_time'];
  359. $data['sczl_打样总工时'] = $params['dy_time'];
  360. $data['sczl_设备运行工时'] = $params['run_time'];
  361. $data['sczl_jtbh'] = $machine;
  362. $data['码包'] = $params['code'];
  363. $data['主电表'] = $params['main_meter'];
  364. $data['辅电表'] = $params['auxiliary_meter'];
  365. unset($data['last_fp']);
  366. unset($data['less_sl']);
  367. unset($data['zb_time']);
  368. unset($data['dy_time']);
  369. unset($data['run_time']);
  370. unset($data['code']);
  371. unset($data['main_meter']);
  372. unset($data['auxiliary_meter']);
  373. unset($data['bom']);
  374. $start_time = \db('设备_产量采集')->where('设备编号',$machine)->order('UniqId desc')->find();
  375. if (!empty($start_time)){
  376. $data['开工时间'] = $start_time['开工时间'];
  377. }else{
  378. $data['开工时间'] = '';
  379. }
  380. $sys_id = \db('设备_基本资料')->where('设备编号',$machine)->value('sys_sbID');
  381. $data['sys_id'] = '['.$sys_id.'/'.$machine.']';
  382. $UniqId = \db('设备_产量计酬')->order('UniqId desc')->value('UniqId');
  383. if ($UniqId < 10000000){
  384. $data['UniqId'] = 10000000;
  385. }else{
  386. $data['UniqId'] = $UniqId + 1;
  387. }
  388. $data['sczl_Pgcl'] = 0;
  389. $data['sczl_oil'] = 0;
  390. $data['sczl_计产系数'] = 0;
  391. $data['sczl_工价系数'] = 0;
  392. $data['sczl_装版工时'] = 0;
  393. $data['sczl_保养工时'] = 0;
  394. $data['sczl_打样工时'] = 0;
  395. $data['sczl_异常停机工时'] = 0;
  396. $data['sczl_异常工时1'] = 0;
  397. $data['sczl_异常类型1'] = '';
  398. $data['sczl_废品率系数'] = '';
  399. $data['sczl_desc'] = '';
  400. $data['sczl_wgsj'] = '1900-01-01 00:00:00';
  401. $data['码开始行'] = 0;
  402. $data['码结束行'] = 0;
  403. $data['mod_rq'] = '1900-01-01 00:00:00';
  404. $data['sys_rq'] = date('Y-m-d H:i:s');
  405. if (!empty($batch)){
  406. $batchData = explode(',',$batch);
  407. $newData = [];
  408. $batchUniqId = \db('物料_批次跟踪')->order('UniqId desc')->value('UniqId');
  409. if ($batchUniqId < 10000000){
  410. $batchUniqId = 10000000;
  411. }
  412. foreach ($batchData as $key=>$item){
  413. $batchUniqId++;
  414. $val = explode('-',$item);
  415. $newData[$key]['wlbh'] = $val[0];
  416. $newData[$key]['wlBatch'] = $val[1];
  417. $newData[$key]['sczl_gdbh'] = $data['sczl_gdbh'];
  418. $newData[$key]['sczl_yjno'] = $data['sczl_yjno'];
  419. $newData[$key]['sczl_gxh'] = $data['sczl_gxh'];
  420. $newData[$key]['sczl_gxmc'] = $data['sczl_gxmc'];
  421. $newData[$key]['sczl_num'] = $data['sczl_num'];
  422. $newData[$key]['sys_id'] = $data['sys_id'];
  423. $newData[$key]['sys_rq'] = $data['sys_rq'];
  424. $newData[$key]['UniqID'] = $batchUniqId;
  425. }
  426. }
  427. $res = false;
  428. $batch_res = false;
  429. Db::startTrans();
  430. try {
  431. $sql = \db('设备_产量计酬')->fetchSql(true)->insert($data);
  432. $res = Db::query($sql);
  433. if (!empty($batch)){
  434. $batch_sql = \db('物料_批次跟踪')->fetchSql(true)->insertAll($newData);
  435. $batch_res = Db::query($batch_sql);
  436. }else{
  437. $batch_res = true;
  438. }
  439. Db::commit();
  440. cache('MachineProductReport-getList',null);
  441. }catch (\Exception $e){
  442. Db::rollback();
  443. }
  444. if ($res === false || $batch_res === false){
  445. $this->error('报工失败');
  446. }else{
  447. $this->success('报工成功');
  448. }
  449. }
  450. /**
  451. * 获取机台编号
  452. * @ApiMethod POST
  453. * @params string addr
  454. */
  455. public function getMachineMac(){
  456. if (Request::instance()->isGet() == false){
  457. $this->error('非法请求');
  458. }
  459. $params = Request::instance()->get();
  460. if (empty($params['addr'])){
  461. $this->error('参数不能为空');
  462. }
  463. $data = \db('设备_基本资料')->where('sys_sbID',$params['addr'])->field('设备编号,rtrim(使用部门) as 使用部门')->find();
  464. $this->success('请求成功',$data);
  465. }
  466. /**
  467. * 6获取拉料人员
  468. * @ApiMethod GET
  469. * @params department
  470. */
  471. public function getMaterialStrippingPeople(){
  472. if (Request::instance()->isGet() == false) {
  473. $this->error('非法请求');
  474. }
  475. $params = Request::instance()->param();
  476. $where = [];
  477. if (!isset($params['department']) || empty($params['department'])) {
  478. $this->error('参数错误');
  479. }if (!isset($params['search']) || !empty($params['search'])) {
  480. $where['员工编号|员工姓名'] = array('like','%'.$params['search'].'%');
  481. }
  482. $where['职称职务'] = '拉纸工';
  483. $where['在职状态'] = '在职';
  484. $where['U8在职'] = '在职';
  485. if ($params['department'] == 1){
  486. $where['所在部门'] = '生产部';
  487. }else{
  488. $where['所在部门'] = '检验车间';
  489. }
  490. $list[0]['员工编号'] = '000000';
  491. $list[0]['员工姓名'] = '自备';
  492. $data = \db('人事_基本资料')->where($where)->field('rtrim(员工编号) as 员工编号,rtrim(员工姓名) as 员工姓名')->order('班组代号 desc')->select();
  493. if (!empty($data)){
  494. foreach ($data as $item){
  495. array_push($list,$item);
  496. }
  497. }
  498. $this->success('请求成功',$list);
  499. }
  500. /**
  501. * 设置当前生产工单
  502. * @return void
  503. * @throws \think\Exception
  504. * @throws \think\db\exception\BindParamException
  505. * @throws \think\db\exception\DataNotFoundException
  506. * @throws \think\db\exception\ModelNotFoundException
  507. * @throws \think\exception\DbException
  508. * @throws \think\exception\PDOException
  509. */
  510. public function MachineWorkOrderEdit()
  511. {
  512. if (Request::instance()->isPost() === false) {
  513. $this->error('非法请求');
  514. }
  515. $params = Request::instance()->post();
  516. $list = \db('工单_基本资料')
  517. ->alias('a')
  518. ->field([
  519. 'RTRIM( b.Gy0_sj1 )' => 'sj1',
  520. 'RTRIM( b.Gy0_sj2 )' => 'sj2',
  521. 'RTRIM( b.UniqId )' => 'id'
  522. ])
  523. ->join('工单_工艺资料 b', 'a.Gd_gdbh = b.Gy0_gdbh')
  524. ->where([
  525. 'a.gd_statu' => '2-生产中',
  526. 'a.行号' => '1',
  527. 'b.Gy0_sbbh' => ['LIKE', '%' . $params['machine'] . '%'],
  528. 'b.PD_WG' => '1900-01-01 00:00:00',
  529. 'b.Gy0_sj1' => ['>', '1900-01-01 00:00:00'],
  530. ])
  531. ->where('b.Gy0_sj1', '<', '2099-01-01 00:00:00')
  532. ->group('a.Gd_gdbh,b.Gy0_yjno,b.Gy0_gxh')
  533. ->order('Gy0_sj1')
  534. ->select();
  535. $start = date('Y-m-d H:i:s', time());
  536. if ($start < date('Y-m-d H:15:00', time())) {
  537. $start = date('Y-m-d H:00:00', time());
  538. } elseif ($start > date('Y-m-d H:45:00', time())) {
  539. $start = date('Y-m-d H:00:00', time());
  540. } else {
  541. $start = date('Y-m-d H:30:00', time());
  542. }
  543. $data = $time = [];
  544. $i = 0;
  545. foreach ($list as $key => $value) {
  546. if ($value['id'] === $params['UniqId']) {
  547. $time = [
  548. 'Gy0_sj1' => $start,
  549. 'Gy0_sj2' => date('Y-m-d H:i:s', strtotime($start) + (strtotime($value['sj1']) - strtotime($value['sj2']))),
  550. 'id' => $value['id']
  551. ];
  552. unset($list[$key]);
  553. }
  554. }
  555. $arr = array_values($list);
  556. $data[0] = $time;
  557. foreach ($arr as $key => $value){
  558. $workTime = [
  559. 'Gy0_sj1' => $data[$key]['Gy0_sj2'],
  560. 'Gy0_sj2' => date('Y-m-d H:i:s', strtotime($data[$key]['Gy0_sj2']) + (strtotime($value['sj1']) - strtotime($value['sj2']))),
  561. 'id' => $value['id']
  562. ];
  563. array_push($data,$workTime);
  564. }
  565. foreach ($data as $key=>$value){
  566. unset($value['id']);
  567. $sql = \db('工单_工艺资料')
  568. ->where('UniqId',$data[$key]['id'])
  569. ->fetchSql(true)
  570. ->update($value);
  571. $res = \db()->query($sql);
  572. if ($res === false){
  573. $i++;
  574. }
  575. }
  576. if ($i !== 0){
  577. $this->error('失败');
  578. }else{
  579. $this->success('成功');
  580. }
  581. }
  582. /**
  583. * 检品机报工
  584. * @return void
  585. * @throws \think\db\exception\BindParamException
  586. * @throws \think\db\exception\DataNotFoundException
  587. * @throws \think\db\exception\ModelNotFoundException
  588. * @throws \think\exception\DbException
  589. * @throws \think\exception\PDOException
  590. */
  591. public function JpUploade()
  592. {
  593. if (Request::instance()->isPost() == false){
  594. $this->error('非法请求');
  595. }
  596. $params = Request::instance()->post();
  597. $time = date('Y-m-d 00:00:00',time()-86400);
  598. $data = $params;
  599. $data['sczl_装版总工时'] = $params['sczl_装版工时'];
  600. $data['sczl_sj1'] = '1900-01-01 00:00:00';
  601. $data['sczl_sj2'] = date('Y-m-d H:i:s',time());
  602. if ($data['sczl_sj2']<date('Y-m-d 08:30:00',time()) && $data['sczl_sj2']>date('Y-m-d 00:00:00')){
  603. $data['sczl_rq'] = $time;
  604. }
  605. $start_time = \db('设备_产量采集')->where('设备编号',$data['sczl_jtbh'])->order('UniqId desc')->find();
  606. if (!empty($start_time)){
  607. $data['开工时间'] = $start_time['开工时间'];
  608. }else{
  609. $data['开工时间'] = '1900-01-01 00:00:00';
  610. }
  611. $sys_id = \db('设备_基本资料')->where('设备编号',$data['sczl_jtbh'])->value('sys_sbID');
  612. $data['sys_id'] = '['.$sys_id.'/'.$data['sczl_jtbh'].']';
  613. $UniqId = \db('设备_产量计酬')->order('UniqId desc')->value('UniqId');
  614. $data['UniqId'] = $UniqId + 1;
  615. $data['sczl_ls'] = 1;
  616. $data['sczl_zcfp'] = 0;
  617. $data['sczl_zccp'] = 0;
  618. $data['sczl_前工序废'] = 0;
  619. $data['sczl_来料少数'] = 0;
  620. $data['sczl_ms'] = 0;
  621. $data['sczl_oil'] = 0;
  622. $data['sczl_计产系数'] = 0;
  623. $data['sczl_工价系数'] = 0;
  624. $data['sczl_保养工时'] = 0;
  625. $data['sczl_打样工时'] = 0;
  626. $data['sczl_异常停机工时'] = 0;
  627. $data['sczl_异常工时1'] = 0;
  628. $data['sczl_异常类型1'] = '';
  629. $data['sczl_desc'] = '';
  630. $data['sczl_wgsj'] = '1900-01-01 00:00:00';
  631. $data['码开始行'] = 0;
  632. $data['码结束行'] = 0;
  633. $data['码包'] = 0;
  634. $data['主电表'] = 0;
  635. $data['辅电表'] = 0;
  636. $data['mod_rq'] = '1900-01-01 00:00:00';
  637. $data['sys_rq'] = date('Y-m-d H:i:s');
  638. $sql = \db('设备_产量计酬')->fetchSql(true)->insert($data);
  639. $res = \db()->query($sql);
  640. if ($res === false){
  641. $this->error('添加失败');
  642. }else{
  643. $this->success('成功');
  644. }
  645. }
  646. //获取当前日期和时间
  647. public function getTime()
  648. {
  649. $data = [
  650. 'date' => date('Y-m-d',time()),
  651. 'hours' => date('Y-m-d H:i:s',time())
  652. ];
  653. $this->success('成功',$data);
  654. }
  655. }