|
@@ -273,7 +273,7 @@ class Mail { |
|
@@ -273,7 +273,7 @@ class Mail { |
273
|
* @param $folder_id
|
273
|
* @param $folder_id
|
274
|
* @param $blacklist
|
274
|
* @param $blacklist
|
275
|
* @param $blackFolder
|
275
|
* @param $blackFolder
|
276
|
- * @param $db
|
276
|
+ * @param \Lib\DbPool $db
|
277
|
* @throws \Exception
|
277
|
* @throws \Exception
|
278
|
* @author:dc
|
278
|
* @author:dc
|
279
|
* @time 2023/8/2 15:35
|
279
|
* @time 2023/8/2 15:35
|
|
@@ -374,6 +374,14 @@ class Mail { |
|
@@ -374,6 +374,14 @@ class Mail { |
374
|
// 插入数据库
|
374
|
// 插入数据库
|
375
|
try {
|
375
|
try {
|
376
|
$id = $db->insert(listsSql::$table,$data);
|
376
|
$id = $db->insert(listsSql::$table,$data);
|
|
|
377
|
+ // 插入失败,尝试更新
|
|
|
378
|
+ if(!$id){
|
|
|
379
|
+ $db->update(listsSql::$table,$data,dbWhere([
|
|
|
380
|
+ 'email_id'=> $data['email_id'],
|
|
|
381
|
+ 'folder_id' => $data['folder_id'],
|
|
|
382
|
+ 'uid' => $data['uid']
|
|
|
383
|
+ ]));
|
|
|
384
|
+ }
|
377
|
if($id){
|
385
|
if($id){
|
378
|
// 同步body内容
|
386
|
// 同步body内容
|
379
|
redis()->rPush('sync_email_body', [
|
387
|
redis()->rPush('sync_email_body', [
|