|
@@ -1542,287 +1542,287 @@ class Synchronization extends Api
|
|
|
* @throws \think\exception\DbException
|
|
* @throws \think\exception\DbException
|
|
|
* @throws \think\exception\PDOException
|
|
* @throws \think\exception\PDOException
|
|
|
*/
|
|
*/
|
|
|
- public function minoMesProductData()
|
|
|
|
|
- {
|
|
|
|
|
- if ($this->request->isGet() === false) {
|
|
|
|
|
- $this->error('请求错误');
|
|
|
|
|
- }
|
|
|
|
|
- $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
- //工单数据查询
|
|
|
|
|
|
|
+// public function minoMesProductData()
|
|
|
|
|
+// {
|
|
|
|
|
+// if ($this->request->isGet() === false) {
|
|
|
|
|
+// $this->error('请求错误');
|
|
|
|
|
+// }
|
|
|
|
|
+// $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
+// //工单数据查询
|
|
|
|
|
+////
|
|
|
//
|
|
//
|
|
|
-
|
|
|
|
|
- $workOrderList = \db('设备_产量计酬')->where('sczl_rq', 'between', ['2024-09-01 00:00:00', '2024-09-30 00:00:00'])->column('DISTINCT(sczl_gdbh) as gdbh');
|
|
|
|
|
-
|
|
|
|
|
-// $workOrderData = $db5->name('工单_基本资料')->where('Gd_gdbh','in',$workOrderList)->select();
|
|
|
|
|
- $workOrderData = $db5->name('工单_基本资料')->where('Gd_gdbh', 'in', $workOrderList)->column('rtrim(Gd_gdbh) as gdbh');
|
|
|
|
|
-// $print = $process = [];
|
|
|
|
|
-// foreach ($workOrderData as $key=> $value){
|
|
|
|
|
-// unset($workOrderData[$key]['Uniqid']);
|
|
|
|
|
- //删除工单基本资料表中重复工单
|
|
|
|
|
-// $workOrderNum = \db('工单_基本资料')->where('Gd_gdbh',$value['Gd_gdbh'])->count();
|
|
|
|
|
-// if ($workOrderNum !== 0){
|
|
|
|
|
-// \db('工单_基本资料')->where('Gd_gdbh',$value['Gd_gdbh'])->delete();
|
|
|
|
|
-// }
|
|
|
|
|
- //查询工单印件表中印件数据
|
|
|
|
|
-
|
|
|
|
|
-// $printData = $db5->name('工单_印件资料')->where('Yj_Gdbh','in',$workOrderData)->select();
|
|
|
|
|
-// \db('工单_印件资料')->where('Yj_Gdbh','in',$workOrderData)->delete();
|
|
|
|
|
-// foreach ($printData as $kk=>$vv){
|
|
|
|
|
-// unset($printData[$kk]['Uniqid']);
|
|
|
|
|
-// array_push($print,$printData[$kk]);
|
|
|
|
|
- //删除工单印件表中重复数据
|
|
|
|
|
-// $printNum = \db('工单_印件资料')
|
|
|
|
|
-// ->where('Yj_Gdbh',$vv['Yj_Gdbh'])
|
|
|
|
|
-// ->where('yj_Yjno',$vv['yj_Yjno'])
|
|
|
|
|
-// ->count();
|
|
|
|
|
-// if ($printNum !== 0){
|
|
|
|
|
-// \db('工单_印件资料')
|
|
|
|
|
-// ->where('Yj_Gdbh',$vv['Yj_Gdbh'])
|
|
|
|
|
-// ->where('yj_Yjno',$vv['yj_Yjno'])
|
|
|
|
|
-// ->delete();
|
|
|
|
|
-// }
|
|
|
|
|
- //查询工单工艺资料表中数据
|
|
|
|
|
- \db('工单_工艺资料')
|
|
|
|
|
- ->where('Gy0_gdbh', 'in', $workOrderData)
|
|
|
|
|
- ->delete();
|
|
|
|
|
- $processData = $db5->name('工单_工艺资料')
|
|
|
|
|
- ->where('Gy0_gdbh', 'in', $workOrderData)
|
|
|
|
|
- ->select();
|
|
|
|
|
-// \db('工单_工艺资料')
|
|
|
|
|
-// ->where('Gy0_gdbh',$value['Gd_gdbh'])
|
|
|
|
|
-// ->delete();
|
|
|
|
|
- foreach ($processData as $k => $v) {
|
|
|
|
|
- unset($processData[$k]['UniqId']);
|
|
|
|
|
-// array_push($process,$processData[$k]);
|
|
|
|
|
|
|
+// $workOrderList = \db('设备_产量计酬')->where('sczl_rq', 'between', ['2024-09-01 00:00:00', '2024-09-30 00:00:00'])->column('DISTINCT(sczl_gdbh) as gdbh');
|
|
|
|
|
+//
|
|
|
|
|
+//// $workOrderData = $db5->name('工单_基本资料')->where('Gd_gdbh','in',$workOrderList)->select();
|
|
|
|
|
+// $workOrderData = $db5->name('工单_基本资料')->where('Gd_gdbh', 'in', $workOrderList)->column('rtrim(Gd_gdbh) as gdbh');
|
|
|
|
|
+//// $print = $process = [];
|
|
|
|
|
+//// foreach ($workOrderData as $key=> $value){
|
|
|
|
|
+//// unset($workOrderData[$key]['Uniqid']);
|
|
|
|
|
+// //删除工单基本资料表中重复工单
|
|
|
|
|
+//// $workOrderNum = \db('工单_基本资料')->where('Gd_gdbh',$value['Gd_gdbh'])->count();
|
|
|
|
|
+//// if ($workOrderNum !== 0){
|
|
|
|
|
+//// \db('工单_基本资料')->where('Gd_gdbh',$value['Gd_gdbh'])->delete();
|
|
|
|
|
+//// }
|
|
|
|
|
+// //查询工单印件表中印件数据
|
|
|
|
|
+//
|
|
|
|
|
+//// $printData = $db5->name('工单_印件资料')->where('Yj_Gdbh','in',$workOrderData)->select();
|
|
|
|
|
+//// \db('工单_印件资料')->where('Yj_Gdbh','in',$workOrderData)->delete();
|
|
|
|
|
+//// foreach ($printData as $kk=>$vv){
|
|
|
|
|
+//// unset($printData[$kk]['Uniqid']);
|
|
|
|
|
+//// array_push($print,$printData[$kk]);
|
|
|
|
|
+// //删除工单印件表中重复数据
|
|
|
|
|
+//// $printNum = \db('工单_印件资料')
|
|
|
|
|
+//// ->where('Yj_Gdbh',$vv['Yj_Gdbh'])
|
|
|
|
|
+//// ->where('yj_Yjno',$vv['yj_Yjno'])
|
|
|
|
|
+//// ->count();
|
|
|
|
|
+//// if ($printNum !== 0){
|
|
|
|
|
+//// \db('工单_印件资料')
|
|
|
|
|
+//// ->where('Yj_Gdbh',$vv['Yj_Gdbh'])
|
|
|
|
|
+//// ->where('yj_Yjno',$vv['yj_Yjno'])
|
|
|
|
|
+//// ->delete();
|
|
|
|
|
+//// }
|
|
|
|
|
+// //查询工单工艺资料表中数据
|
|
|
|
|
+// \db('工单_工艺资料')
|
|
|
|
|
+// ->where('Gy0_gdbh', 'in', $workOrderData)
|
|
|
|
|
+// ->delete();
|
|
|
|
|
+// $processData = $db5->name('工单_工艺资料')
|
|
|
|
|
+// ->where('Gy0_gdbh', 'in', $workOrderData)
|
|
|
|
|
+// ->select();
|
|
|
|
|
+//// \db('工单_工艺资料')
|
|
|
|
|
+//// ->where('Gy0_gdbh',$value['Gd_gdbh'])
|
|
|
|
|
+//// ->delete();
|
|
|
|
|
+// foreach ($processData as $k => $v) {
|
|
|
|
|
+// unset($processData[$k]['UniqId']);
|
|
|
|
|
+//// array_push($process,$processData[$k]);
|
|
|
|
|
+//// }
|
|
|
|
|
+//
|
|
|
|
|
+//// }
|
|
|
// }
|
|
// }
|
|
|
-
|
|
|
|
|
-// }
|
|
|
|
|
- }
|
|
|
|
|
-// halt($workOrderData);
|
|
|
|
|
-// $workSql = \db('工单_基本资料')->fetchSql(true)->insertAll($workOrderData);
|
|
|
|
|
-// $workRes = \db()->query($workSql);
|
|
|
|
|
-// die;
|
|
|
|
|
-// halt($printData);
|
|
|
|
|
-// $printSql = \db('工单_印件资料')->fetchSql(true)->insertAll($printData);
|
|
|
|
|
-// $printRes = \db()->query($printSql);
|
|
|
|
|
-// die;
|
|
|
|
|
-// halt($processData);
|
|
|
|
|
- $processSql = \db('工单_工艺资料')->fetchSql(true)->insertAll($processData);
|
|
|
|
|
- $processRes = \db()->query($processSql);
|
|
|
|
|
- die;
|
|
|
|
|
- if ($workRes !== false && $printRes !== false && $processRes !== false) {
|
|
|
|
|
- $this->success('成功');
|
|
|
|
|
- } else {
|
|
|
|
|
- $this->error('失败');
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
|
|
+//// halt($workOrderData);
|
|
|
|
|
+//// $workSql = \db('工单_基本资料')->fetchSql(true)->insertAll($workOrderData);
|
|
|
|
|
+//// $workRes = \db()->query($workSql);
|
|
|
|
|
+//// die;
|
|
|
|
|
+//// halt($printData);
|
|
|
|
|
+//// $printSql = \db('工单_印件资料')->fetchSql(true)->insertAll($printData);
|
|
|
|
|
+//// $printRes = \db()->query($printSql);
|
|
|
|
|
+//// die;
|
|
|
|
|
+//// halt($processData);
|
|
|
|
|
+// $processSql = \db('工单_工艺资料')->fetchSql(true)->insertAll($processData);
|
|
|
|
|
+// $processRes = \db()->query($processSql);
|
|
|
|
|
+//// die;
|
|
|
|
|
+// if ($workRes !== false && $printRes !== false && $processRes !== false) {
|
|
|
|
|
+// $this->success('成功');
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $this->error('失败');
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
|
|
|
|
|
|
|
|
//工单核检单同步
|
|
//工单核检单同步
|
|
|
- public function hejiandancopy()
|
|
|
|
|
- {
|
|
|
|
|
-// $param = $this->request->param();
|
|
|
|
|
- $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
- //查询本月工单核检单数据
|
|
|
|
|
- $list = $db5->name('db_qczl')
|
|
|
|
|
- ->where('sys_rq', '>=', '2024-11-21 00:00:00')
|
|
|
|
|
- ->select();
|
|
|
|
|
- $employeeList = \db('人事_基本资料')
|
|
|
|
|
- ->whereNotNull('mn_员工编号')
|
|
|
|
|
- ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
- foreach ($list as $key => $value) {
|
|
|
|
|
- for ($i = 1; $i < 14; $i++) {
|
|
|
|
|
- if ($value['fp_bh' . $i] !== '') {
|
|
|
|
|
- if (array_key_exists($value['fp_bh' . $i], $employeeList)) {
|
|
|
|
|
- $list[$key]['fp_bh' . $i] = $employeeList[$value['fp_bh' . $i]];
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- unset($list[$key]['UniqId']);
|
|
|
|
|
- }
|
|
|
|
|
- $sql = \db('db_qczl')->fetchSql(true)->insertAll($list);
|
|
|
|
|
- $res = \db()->query($sql);
|
|
|
|
|
- if ($res !== false) {
|
|
|
|
|
- $this->success('成功');
|
|
|
|
|
- } else {
|
|
|
|
|
- $this->error('失败');
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
|
|
+// public function hejiandancopy()
|
|
|
|
|
+// {
|
|
|
|
|
+//// $param = $this->request->param();
|
|
|
|
|
+// $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
+// //查询本月工单核检单数据
|
|
|
|
|
+// $list = $db5->name('db_qczl')
|
|
|
|
|
+// ->where('sys_rq', '>=', '2024-11-21 00:00:00')
|
|
|
|
|
+// ->select();
|
|
|
|
|
+// $employeeList = \db('人事_基本资料')
|
|
|
|
|
+// ->whereNotNull('mn_员工编号')
|
|
|
|
|
+// ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
+// foreach ($list as $key => $value) {
|
|
|
|
|
+// for ($i = 1; $i < 14; $i++) {
|
|
|
|
|
+// if ($value['fp_bh' . $i] !== '') {
|
|
|
|
|
+// if (array_key_exists($value['fp_bh' . $i], $employeeList)) {
|
|
|
|
|
+// $list[$key]['fp_bh' . $i] = $employeeList[$value['fp_bh' . $i]];
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
+// unset($list[$key]['UniqId']);
|
|
|
|
|
+// }
|
|
|
|
|
+// $sql = \db('db_qczl')->fetchSql(true)->insertAll($list);
|
|
|
|
|
+// $res = \db()->query($sql);
|
|
|
|
|
+// if ($res !== false) {
|
|
|
|
|
+// $this->success('成功');
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $this->error('失败');
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
|
|
|
|
|
|
|
|
//拆片工序数据同步
|
|
//拆片工序数据同步
|
|
|
- public function chaipianCopy()
|
|
|
|
|
- {
|
|
|
|
|
- if ($this->request->isGet() === false) {
|
|
|
|
|
- $this->error('请求错误');
|
|
|
|
|
- }
|
|
|
|
|
- $param = $this->request->param();
|
|
|
|
|
- if (!empty($param['end'])) {
|
|
|
|
|
- $where['sczl_rq'] = ['between', [$param['start'], $param['end']]];
|
|
|
|
|
- } else {
|
|
|
|
|
- $where['sczl_rq'] = ['>=', $param['start']];
|
|
|
|
|
- }
|
|
|
|
|
- $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
- $list = $db5->name('db_sczl')
|
|
|
|
|
- ->where($where)
|
|
|
|
|
- ->select();
|
|
|
|
|
- $employeeList = \db('人事_基本资料')
|
|
|
|
|
- ->whereNotNull('mn_员工编号')
|
|
|
|
|
- ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
- foreach ($list as $key => $value) {
|
|
|
|
|
- unset($list[$key]['UniqId']);
|
|
|
|
|
- if (array_key_exists($value['sczl_bh1'], $employeeList)) {
|
|
|
|
|
- $list[$key]['sczl_bh1'] = $employeeList[$value['sczl_bh1']];
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- $sql = \db('db_sczl')->fetchSql(true)->insertAll($list);
|
|
|
|
|
- $res = \db()->query($sql);
|
|
|
|
|
- if ($res !== false) {
|
|
|
|
|
- $this->success('成功');
|
|
|
|
|
- } else {
|
|
|
|
|
- $this->error('失败');
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
|
|
+// public function chaipianCopy()
|
|
|
|
|
+// {
|
|
|
|
|
+// if ($this->request->isGet() === false) {
|
|
|
|
|
+// $this->error('请求错误');
|
|
|
|
|
+// }
|
|
|
|
|
+// $param = $this->request->param();
|
|
|
|
|
+// if (!empty($param['end'])) {
|
|
|
|
|
+// $where['sczl_rq'] = ['between', [$param['start'], $param['end']]];
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $where['sczl_rq'] = ['>=', $param['start']];
|
|
|
|
|
+// }
|
|
|
|
|
+// $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
+// $list = $db5->name('db_sczl')
|
|
|
|
|
+// ->where($where)
|
|
|
|
|
+// ->select();
|
|
|
|
|
+// $employeeList = \db('人事_基本资料')
|
|
|
|
|
+// ->whereNotNull('mn_员工编号')
|
|
|
|
|
+// ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
+// foreach ($list as $key => $value) {
|
|
|
|
|
+// unset($list[$key]['UniqId']);
|
|
|
|
|
+// if (array_key_exists($value['sczl_bh1'], $employeeList)) {
|
|
|
|
|
+// $list[$key]['sczl_bh1'] = $employeeList[$value['sczl_bh1']];
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
+// $sql = \db('db_sczl')->fetchSql(true)->insertAll($list);
|
|
|
|
|
+// $res = \db()->query($sql);
|
|
|
|
|
+// if ($res !== false) {
|
|
|
|
|
+// $this->success('成功');
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $this->error('失败');
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
|
|
|
//手工检验报工数据同步
|
|
//手工检验报工数据同步
|
|
|
- public function shougongCopy()
|
|
|
|
|
- {
|
|
|
|
|
- if ($this->request->isGet() === false) {
|
|
|
|
|
- $this->error('请求错误');
|
|
|
|
|
- }
|
|
|
|
|
- $param = $this->request->param();
|
|
|
|
|
- if (!empty($param['end'])) {
|
|
|
|
|
- $where['sczl_rq'] = ['between', [$param['start'], $param['end']]];
|
|
|
|
|
- } else {
|
|
|
|
|
- $where['sczl_rq'] = ['>=', $param['start']];
|
|
|
|
|
- }
|
|
|
|
|
- $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
- $list = $db5->name('db_手工检验')
|
|
|
|
|
- ->where($where)
|
|
|
|
|
- ->select();
|
|
|
|
|
- $employeeList = \db('人事_基本资料')
|
|
|
|
|
- ->whereNotNull('mn_员工编号')
|
|
|
|
|
- ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
- foreach ($list as $key => $value) {
|
|
|
|
|
- for ($i = 0; $i < 13; $i++) {
|
|
|
|
|
- if ($value['sczl_bh' . $i] !== '') {
|
|
|
|
|
- if (array_key_exists($value['sczl_bh' . $i], $employeeList)) {
|
|
|
|
|
- $list[$key]['sczl_bh' . $i] = $employeeList[$value['sczl_bh' . $i]];
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- unset($list[$key]['UniqId']);
|
|
|
|
|
- }
|
|
|
|
|
- $sql = \db('db_手工检验')->fetchSql(true)->insertAll($list);
|
|
|
|
|
- $res = \db()->query($sql);
|
|
|
|
|
- if ($res !== false) {
|
|
|
|
|
- $this->success('成功');
|
|
|
|
|
- } else {
|
|
|
|
|
- $this->error('失败');
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
|
|
+// public function shougongCopy()
|
|
|
|
|
+// {
|
|
|
|
|
+// if ($this->request->isGet() === false) {
|
|
|
|
|
+// $this->error('请求错误');
|
|
|
|
|
+// }
|
|
|
|
|
+// $param = $this->request->param();
|
|
|
|
|
+// if (!empty($param['end'])) {
|
|
|
|
|
+// $where['sczl_rq'] = ['between', [$param['start'], $param['end']]];
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $where['sczl_rq'] = ['>=', $param['start']];
|
|
|
|
|
+// }
|
|
|
|
|
+// $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
+// $list = $db5->name('db_手工检验')
|
|
|
|
|
+// ->where($where)
|
|
|
|
|
+// ->select();
|
|
|
|
|
+// $employeeList = \db('人事_基本资料')
|
|
|
|
|
+// ->whereNotNull('mn_员工编号')
|
|
|
|
|
+// ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
+// foreach ($list as $key => $value) {
|
|
|
|
|
+// for ($i = 0; $i < 13; $i++) {
|
|
|
|
|
+// if ($value['sczl_bh' . $i] !== '') {
|
|
|
|
|
+// if (array_key_exists($value['sczl_bh' . $i], $employeeList)) {
|
|
|
|
|
+// $list[$key]['sczl_bh' . $i] = $employeeList[$value['sczl_bh' . $i]];
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
+// unset($list[$key]['UniqId']);
|
|
|
|
|
+// }
|
|
|
|
|
+// $sql = \db('db_手工检验')->fetchSql(true)->insertAll($list);
|
|
|
|
|
+// $res = \db()->query($sql);
|
|
|
|
|
+// if ($res !== false) {
|
|
|
|
|
+// $this->success('成功');
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $this->error('失败');
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
|
|
|
//包装计件数据同步
|
|
//包装计件数据同步
|
|
|
- public function baozhaungCopy()
|
|
|
|
|
- {
|
|
|
|
|
- if ($this->request->isGet() === false) {
|
|
|
|
|
- $this->error('请求错误');
|
|
|
|
|
- }
|
|
|
|
|
- $param = $this->request->param();
|
|
|
|
|
- if (!empty($param['end'])) {
|
|
|
|
|
- $where['sczl_rq'] = ['between', [$param['start'], $param['end']]];
|
|
|
|
|
- } else {
|
|
|
|
|
- $where['sczl_rq'] = ['>=', $param['start']];
|
|
|
|
|
- }
|
|
|
|
|
- $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
- $list = $db5->name('db_包装计件')
|
|
|
|
|
- ->where($where)
|
|
|
|
|
- ->select();
|
|
|
|
|
- $typeList = $db5->name('物料_存货编码')
|
|
|
|
|
- ->where('物料代码','like','10%')
|
|
|
|
|
- ->whereOr('物料代码','like','12%')
|
|
|
|
|
- ->whereOr('物料代码','like','14%')
|
|
|
|
|
- ->column('rtrim(规格) as 规格','rtrim(物料代码)');
|
|
|
|
|
- $cpdhList = $db5->name('工单_印件资料')
|
|
|
|
|
- ->where('Uniqid', '>', 18000)
|
|
|
|
|
- ->where('yj_cpdh', '<>', '') // 确保 yj_cpdh 不为空
|
|
|
|
|
- ->where('Yj_Gdbh','<>','')
|
|
|
|
|
- ->column('rtrim(yj_cpdh) AS cpdh, rtrim(yj_Yjno) AS yjno', 'CONCAT(rtrim(Yj_Gdbh), "-", rtrim(yj_Yjno))');
|
|
|
|
|
- $employeeList = \db('人事_基本资料')
|
|
|
|
|
- ->whereNotNull('mn_员工编号')
|
|
|
|
|
- ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
- foreach ($list as $key => $value) {
|
|
|
|
|
- for ($i = 1; $i < 7; $i++) {
|
|
|
|
|
- //循环判断工单编号是否为空,不为空判断物料规格是条盒或小盒,条盒核算参数取1000,小盒核算参数取2500,如果工单编号为空,核算参数为空
|
|
|
|
|
- if ($value['sczl_gdbh' . $i] !== '') {
|
|
|
|
|
- $yjno = (int)substr($value['sczl_yjGx'.$i],0,2);
|
|
|
|
|
- $liatKey = $value['sczl_gdbh' . $i].'-'.$yjno;
|
|
|
|
|
- if (array_key_exists($liatKey,$cpdhList) !== false){
|
|
|
|
|
- $cpdh = $cpdhList[$liatKey]['cpdh'];
|
|
|
|
|
- $guige = $typeList[$cpdh];
|
|
|
|
|
- if ($guige == '小盒'){
|
|
|
|
|
- $list[$key]['sczl_type'.$i] = '2500';
|
|
|
|
|
- }else{
|
|
|
|
|
- $list[$key]['sczl_type'.$i] = '1000';
|
|
|
|
|
- }
|
|
|
|
|
- }else{
|
|
|
|
|
- $list[$key]['sczl_type'.$i] = '1000';
|
|
|
|
|
- }
|
|
|
|
|
- }else{
|
|
|
|
|
- $list[$key]['sczl_type'.$i] = '';
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- }
|
|
|
|
|
- if (array_key_exists($value['sczl_bh'], $employeeList)) {
|
|
|
|
|
- $list[$key]['sczl_bh'] = $employeeList[$value['sczl_bh']];
|
|
|
|
|
- }
|
|
|
|
|
- unset($list[$key]['UniqId']);
|
|
|
|
|
- }
|
|
|
|
|
- $sql = \db('db_包装计件')->fetchSql(true)->insertAll($list);
|
|
|
|
|
- $res = \db()->query($sql);
|
|
|
|
|
- if ($res !== false) {
|
|
|
|
|
- $this->success('成功');
|
|
|
|
|
- } else {
|
|
|
|
|
- $this->error('失败');
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
|
|
+// public function baozhaungCopy()
|
|
|
|
|
+// {
|
|
|
|
|
+// if ($this->request->isGet() === false) {
|
|
|
|
|
+// $this->error('请求错误');
|
|
|
|
|
+// }
|
|
|
|
|
+// $param = $this->request->param();
|
|
|
|
|
+// if (!empty($param['end'])) {
|
|
|
|
|
+// $where['sczl_rq'] = ['between', [$param['start'], $param['end']]];
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $where['sczl_rq'] = ['>=', $param['start']];
|
|
|
|
|
+// }
|
|
|
|
|
+// $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
+// $list = $db5->name('db_包装计件')
|
|
|
|
|
+// ->where($where)
|
|
|
|
|
+// ->select();
|
|
|
|
|
+// $typeList = $db5->name('物料_存货编码')
|
|
|
|
|
+// ->where('物料代码','like','10%')
|
|
|
|
|
+// ->whereOr('物料代码','like','12%')
|
|
|
|
|
+// ->whereOr('物料代码','like','14%')
|
|
|
|
|
+// ->column('rtrim(规格) as 规格','rtrim(物料代码)');
|
|
|
|
|
+// $cpdhList = $db5->name('工单_印件资料')
|
|
|
|
|
+// ->where('Uniqid', '>', 18000)
|
|
|
|
|
+// ->where('yj_cpdh', '<>', '') // 确保 yj_cpdh 不为空
|
|
|
|
|
+// ->where('Yj_Gdbh','<>','')
|
|
|
|
|
+// ->column('rtrim(yj_cpdh) AS cpdh, rtrim(yj_Yjno) AS yjno', 'CONCAT(rtrim(Yj_Gdbh), "-", rtrim(yj_Yjno))');
|
|
|
|
|
+// $employeeList = \db('人事_基本资料')
|
|
|
|
|
+// ->whereNotNull('mn_员工编号')
|
|
|
|
|
+// ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
+// foreach ($list as $key => $value) {
|
|
|
|
|
+// for ($i = 1; $i < 7; $i++) {
|
|
|
|
|
+// //循环判断工单编号是否为空,不为空判断物料规格是条盒或小盒,条盒核算参数取1000,小盒核算参数取2500,如果工单编号为空,核算参数为空
|
|
|
|
|
+// if ($value['sczl_gdbh' . $i] !== '') {
|
|
|
|
|
+// $yjno = (int)substr($value['sczl_yjGx'.$i],0,2);
|
|
|
|
|
+// $liatKey = $value['sczl_gdbh' . $i].'-'.$yjno;
|
|
|
|
|
+// if (array_key_exists($liatKey,$cpdhList) !== false){
|
|
|
|
|
+// $cpdh = $cpdhList[$liatKey]['cpdh'];
|
|
|
|
|
+// $guige = $typeList[$cpdh];
|
|
|
|
|
+// if ($guige == '小盒'){
|
|
|
|
|
+// $list[$key]['sczl_type'.$i] = '2500';
|
|
|
|
|
+// }else{
|
|
|
|
|
+// $list[$key]['sczl_type'.$i] = '1000';
|
|
|
|
|
+// }
|
|
|
|
|
+// }else{
|
|
|
|
|
+// $list[$key]['sczl_type'.$i] = '1000';
|
|
|
|
|
+// }
|
|
|
|
|
+// }else{
|
|
|
|
|
+// $list[$key]['sczl_type'.$i] = '';
|
|
|
|
|
+// }
|
|
|
|
|
+//
|
|
|
|
|
+// }
|
|
|
|
|
+// if (array_key_exists($value['sczl_bh'], $employeeList)) {
|
|
|
|
|
+// $list[$key]['sczl_bh'] = $employeeList[$value['sczl_bh']];
|
|
|
|
|
+// }
|
|
|
|
|
+// unset($list[$key]['UniqId']);
|
|
|
|
|
+// }
|
|
|
|
|
+// $sql = \db('db_包装计件')->fetchSql(true)->insertAll($list);
|
|
|
|
|
+// $res = \db()->query($sql);
|
|
|
|
|
+// if ($res !== false) {
|
|
|
|
|
+// $this->success('成功');
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $this->error('失败');
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
|
|
|
//计时工资数据同步
|
|
//计时工资数据同步
|
|
|
- public function jishiCopy()
|
|
|
|
|
- {
|
|
|
|
|
- if ($this->request->isGet() === false) {
|
|
|
|
|
- $this->error('请求错误');
|
|
|
|
|
- }
|
|
|
|
|
- $param = $this->request->param();
|
|
|
|
|
- if (!empty($param['end'])) {
|
|
|
|
|
- $where['wgjs_rq'] = ['between', [$param['start'], $param['end']]];
|
|
|
|
|
- } else {
|
|
|
|
|
- $where['wgjs_rq'] = ['>=', $param['start']];
|
|
|
|
|
- }
|
|
|
|
|
- $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
- $list = $db5->name('db_wgjs')
|
|
|
|
|
- ->where($where)
|
|
|
|
|
- ->select();
|
|
|
|
|
- $employeeList = \db('人事_基本资料')
|
|
|
|
|
- ->whereNotNull('mn_员工编号')
|
|
|
|
|
- ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
- foreach ($list as $key => $value) {
|
|
|
|
|
- for ($i = 1; $i < 7; $i++) {
|
|
|
|
|
- if ($value['wgjs_bh' . $i] !== '') {
|
|
|
|
|
- if (array_key_exists($value['wgjs_bh' . $i], $employeeList)) {
|
|
|
|
|
- $list[$key]['wgjs_bh' . $i] = $employeeList[$value['wgjs_bh' . $i]];
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- unset($list[$key]['UniqId']);
|
|
|
|
|
- }
|
|
|
|
|
- $sql = \db('db_wgjs')->fetchSql(true)->insertAll($list);
|
|
|
|
|
- $res = \db()->query($sql);
|
|
|
|
|
- if ($res !== false) {
|
|
|
|
|
- $this->success('成功');
|
|
|
|
|
- } else {
|
|
|
|
|
- $this->error('失败');
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
|
|
+// public function jishiCopy()
|
|
|
|
|
+// {
|
|
|
|
|
+// if ($this->request->isGet() === false) {
|
|
|
|
|
+// $this->error('请求错误');
|
|
|
|
|
+// }
|
|
|
|
|
+// $param = $this->request->param();
|
|
|
|
|
+// if (!empty($param['end'])) {
|
|
|
|
|
+// $where['wgjs_rq'] = ['between', [$param['start'], $param['end']]];
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $where['wgjs_rq'] = ['>=', $param['start']];
|
|
|
|
|
+// }
|
|
|
|
|
+// $db5 = \db()->connect(config('database.db5'));
|
|
|
|
|
+// $list = $db5->name('db_wgjs')
|
|
|
|
|
+// ->where($where)
|
|
|
|
|
+// ->select();
|
|
|
|
|
+// $employeeList = \db('人事_基本资料')
|
|
|
|
|
+// ->whereNotNull('mn_员工编号')
|
|
|
|
|
+// ->column('员工编号', 'mn_员工编号');
|
|
|
|
|
+// foreach ($list as $key => $value) {
|
|
|
|
|
+// for ($i = 1; $i < 7; $i++) {
|
|
|
|
|
+// if ($value['wgjs_bh' . $i] !== '') {
|
|
|
|
|
+// if (array_key_exists($value['wgjs_bh' . $i], $employeeList)) {
|
|
|
|
|
+// $list[$key]['wgjs_bh' . $i] = $employeeList[$value['wgjs_bh' . $i]];
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
+// unset($list[$key]['UniqId']);
|
|
|
|
|
+// }
|
|
|
|
|
+// $sql = \db('db_wgjs')->fetchSql(true)->insertAll($list);
|
|
|
|
|
+// $res = \db()->query($sql);
|
|
|
|
|
+// if ($res !== false) {
|
|
|
|
|
+// $this->success('成功');
|
|
|
|
|
+// } else {
|
|
|
|
|
+// $this->error('失败');
|
|
|
|
|
+// }
|
|
|
|
|
+// }
|
|
|
|
|
|
|
|
}
|
|
}
|