产品工艺复制

application/api/controller/Product.php

@@ -354,11 +354,16 @@ class Product extends Api
         if (empty($params['from_code']) || empty($params['to_code'])) {
             $this->error('参数不能为空');
         }
+
         $where = [];
         if (isset($params['type']) && $params['type'] == 1) {
-            $where = ['Gy0_gxh' => ['>',20]];
+            $where = ['Gy0_gxh' => ['>', 20]];
         }
-        // 定义数据处理策略
+
+        $sys_id = $params['sys_id'];
+        $mod_rq = date('Y-m-d H:i:s', time());
+
+        // 定义数据处理策略（统一添加 Sys_id 和 Mod_rq 字段）
         $strategies = [
             'gy' => [
                 'flag' => 'is_copy_gy',
@@ -370,11 +375,13 @@ class Product extends Api
                         $this->error('工艺方案不能为空');
                     }
                 },
-                'data_mapper' => function ($item, $seq) use ($params) {
+                'data_mapper' => function ($item, $seq) use ($params, $sys_id, $mod_rq) {
                     return [
                         'Gy0_方案' => $params['to_pro'],
                         'Gy0_cpdh' => $params['to_code'],
-                        'UniqID' => $seq
+                        'UniqID' => $seq,
+                        'Sys_id' => $sys_id,  // 新增
+                        'Mod_rq' => $mod_rq   // 新增
                     ];
                 }
             ],
@@ -383,10 +390,12 @@ class Product extends Api
                 'table' => '产品_印件资料',
                 'source_field' => 'yj_cpdh',
                 'uniq_field' => 'UniqId',
-                'data_mapper' => function ($item, $seq) use ($params) {
+                'data_mapper' => function ($item, $seq) use ($params, $sys_id, $mod_rq) {
                     return [
                         'yj_cpdh' => $params['to_code'],
-                        'UniqId' => $seq
+                        'UniqId' => $seq,
+                        'sys_id' => $sys_id,  // 新增
+                        'mod_rq' => $mod_rq   // 新增
                     ];
                 }
             ],
@@ -395,10 +404,12 @@ class Product extends Api
                 'table' => '产品_印版资料',
                 'source_field' => 'YB_Cpdh',
                 'uniq_field' => 'UniqID',
-                'data_mapper' => function ($item, $seq) use ($params) {
+                'data_mapper' => function ($item, $seq) use ($params, $sys_id, $mod_rq) {
                     return [
                         'YB_Cpdh' => $params['to_code'],
-                        'UniqID' => $seq
+                        'UniqID' => $seq,
+                        'Sys_id' => $sys_id,  // 新增
+                        'Mod_rq' => $mod_rq   // 新增
                     ];
                 }
             ]
@@ -429,7 +440,7 @@ class Product extends Api
                 ->order("{$strategy['uniq_field']} desc")
                 ->value($strategy['uniq_field']) ?: 0;
 
-            // 处理数据
+            // 处理数据（自动覆盖原记录的 Sys_id 和 Mod_rq）
             $processedData = [];
             $currentSeq = 1;
             foreach ($data as $item) {
@@ -445,9 +456,9 @@ class Product extends Api
             // 事务处理
             db()->startTrans();
             try {
-//                db($strategy['table'])
-//                    ->where($strategy['source_field'], $params['to_code'])
-//                    ->delete();
+//              db($strategy['table'])
+//                 ->where($strategy['source_field'], $params['to_code'])
+//                 ->delete();
 
                 if (!db($strategy['table'])->insertAll($processedData)) {
                     throw new \Exception("Insert failed");