物料同步日志

application/api/controller/Synchronization.php

@@ -796,7 +796,7 @@ class Synchronization extends Api
                 'sys_rq' => date('Y-m-d H:i:s', time()),
                 'mod_rq' => '1900-01-01 00:00:00',
                 'U8UID' => $value['U8_UID'],
-                'cpdh' => $value['产品编码']
+                'cpdh' => $value['产品编码'],
             ];
             $number = \db('物料_收发记录')
                 ->where('U8UID', $value['U8_UID'])
@@ -807,6 +807,17 @@ class Synchronization extends Api
                 if ($res === false) {
                     $i++;
                 } else {
+                    $logData = [
+                        'Gd_gdbh'      => $data['st_gdbh'], // 使用原始工单编号
+                        'ModifyUser'   => '系统同步',
+                        'ModifyTime'   => date('Y-m-d H:i:s'),
+                        'FieldName'    => $data['U8UID'],
+                        'OldValue'     => $data['st_sl'],
+                        'NewValue'     => $data['仓库编号'],
+                        'ModifySource' => '物料收发记录同步'
+                    ];
+                    $logSql = \db('系统操作日志表')->fetchSql(true)->insert($logData);
+                    $result = \db()->query($logSql);
                     $sqlString = $db3->name('U8_07物料领用')
                         ->where('UniqId', $value['UniqId'])
                         ->fetchSql(true)
@@ -817,6 +828,20 @@ class Synchronization extends Api
                     $db3->execute($sqlString);
                 }
             } else {
+                $oldData = \db('物料_收发记录')
+                    ->where('U8UID', $value['U8_UID'])
+                    ->select();
+                $changes = [];
+                foreach ($data as $field => $newValue) {
+                    $oldValue = $oldData[$field] ?? null;
+                    if ($oldValue != $newValue) {
+                        $changes[] = [
+                            'field' => $field,
+                            'old'   => $oldValue,
+                            'new'   => $newValue
+                        ];
+                    }
+                }
                 $sql = \db('物料_收发记录')
                     ->fetchSql(true)
                     ->where('U8UID', $value['U8_UID'])
@@ -825,6 +850,22 @@ class Synchronization extends Api
                 if ($res === false) {
                     $i++;
                 } else {
+                    if (!empty($changes)) {
+                        $logData = [];
+                        foreach ($changes as $change) {
+                            $logData[] = [
+                                'Gd_gdbh'      => $data['st_gdbh'], // 使用原始工单编号
+                                'ModifyUser'   => '系统同步',
+                                'ModifyTime'   => date('Y-m-d H:i:s'),
+                                'FieldName'    => $change['field'],
+                                'OldValue'     => $change['old'],
+                                'NewValue'     => $change['new'],
+                                'ModifySource' => '物料收发记录修改数据同步'
+                            ];
+                        }
+                        $logSql = \db('系统操作日志表')->fetchSql(true)->insertAll($logData);
+                        $result = \db()->query($logSql);
+                    }
                     $sqlString = $db3->name('U8_07物料领用')
                         ->where('UniqId', $value['UniqId'])
                         ->fetchSql(true)
@@ -1901,6 +1942,17 @@ class Synchronization extends Api
                 if ($res === false) {
                     $i++;
                 } else {
+                    $logData = [
+                        'Gd_gdbh'      => $data['st_gdbh'], // 使用原始工单编号
+                        'ModifyUser'   => '系统同步',
+                        'ModifyTime'   => date('Y-m-d H:i:s'),
+                        'FieldName'    => $data['U8UID'],
+                        'OldValue'     => $data['st_sl'],
+                        'NewValue'     => $data['仓库编号'],
+                        'ModifySource' => '物料收发记录同步'
+                    ];
+                    $logSql = \db('系统操作日志表')->fetchSql(true)->insert($logData);
+                    $result = \db()->query($logSql);
                     $sqlString = $db3->name('U8_07物料领用')
                         ->where('UniqId', $value['UniqId'])
                         ->fetchSql(true)
@@ -1911,6 +1963,20 @@ class Synchronization extends Api
                     $db3->execute($sqlString);
                 }
             } else {
+                $oldData = \db('物料_收发记录')
+                    ->where('U8UID', $value['U8_UID'])
+                    ->select();
+                $changes = [];
+                foreach ($data as $field => $newValue) {
+                    $oldValue = $oldData[$field] ?? null;
+                    if ($oldValue != $newValue) {
+                        $changes[] = [
+                            'field' => $field,
+                            'old'   => $oldValue,
+                            'new'   => $newValue
+                        ];
+                    }
+                }
                 $sql = \db('物料_收发记录')
                     ->fetchSql(true)
                     ->where('U8UID', $value['U8_UID'])
@@ -1919,6 +1985,22 @@ class Synchronization extends Api
                 if ($res === false) {
                     $i++;
                 } else {
+                    if (!empty($changes)) {
+                        $logData = [];
+                        foreach ($changes as $change) {
+                            $logData[] = [
+                                'Gd_gdbh'      => $data['st_gdbh'], // 使用原始工单编号
+                                'ModifyUser'   => '系统同步',
+                                'ModifyTime'   => date('Y-m-d H:i:s'),
+                                'FieldName'    => $change['field'],
+                                'OldValue'     => $change['old'],
+                                'NewValue'     => $change['new'],
+                                'ModifySource' => '物料收发记录修改数据同步'
+                            ];
+                        }
+                        $logSql = \db('系统操作日志表')->fetchSql(true)->insertAll($logData);
+                        $result = \db()->query($logSql);
+                    }
                     $sqlString = $db3->name('U8_07物料领用')
                         ->where('UniqId', $value['UniqId'])
                         ->fetchSql(true)