fnvtk/cunkebao_v3
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码提交

Browse Source
This commit is contained in:
wong
2025-10-15 14:08:56 +08:00
parent f11bc7f686
commit d26e5a324d
1 changed files with 52 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

112
Server/application/api/controller/WechatFriendController.php
View File

@@ -75,21 +75,16 @@ class WechatFriendController extends BaseController
// 发送请求获取好友列表 // 发送请求获取好友列表
$result = requestCurl($this->baseUrl . 'api/WechatFriend/friendlistData', $params, 'POST', $header, 'json'); $result = requestCurl($this->baseUrl . 'api/WechatFriend/friendlistData', $params, 'POST', $header, 'json');
$response = handleApiResponse($result); $response = handleApiResponse($result);
// 保存数据到数据库 // 保存数据到数据库
if (is_array($response)) { if (is_array($response)) {
$isUpdate = false; $isUpdate = false;
$updated = $this->saveFriend($response); foreach ($response as $item) {
if($updated && $isDel == 0){
$isUpdate = true;
}
/*foreach ($response as $item) {
$updated = $this->saveFriend($item); $updated = $this->saveFriend($item);
if($updated && $isDel == 0){ if($updated && $isDel == 0){
$isUpdate = true; $isUpdate = true;
} }
}*/ }
} }
if ($isInner) { if ($isInner) {
@@ -112,61 +107,58 @@ class WechatFriendController extends BaseController
* @param array $item 微信好友数据 * @param array $item 微信好友数据
* @return bool 是否创建或更新了记录 * @return bool 是否创建或更新了记录
*/ */
private function saveFriend($data) private function saveFriend($item)
{ {
$sqlData = []; $data = [
foreach ($data as $item) { 'id' => $item['id'],
$sqlData[] = [ 'wechatAccountId' => $item['wechatAccountId'],
'id' => $item['id'], 'alias' => $item['alias'],
'wechatAccountId' => $item['wechatAccountId'], 'wechatId' => $item['wechatId'],
'alias' => $item['alias'], 'conRemark' => $item['conRemark'],
'wechatId' => $item['wechatId'], 'nickname' => $item['nickname'],
'conRemark' => $item['conRemark'], 'pyInitial' => $item['pyInitial'],
'nickname' => $item['nickname'], 'quanPin' => $item['quanPin'],
'pyInitial' => $item['pyInitial'], 'avatar' => $item['avatar'],
'quanPin' => $item['quanPin'], 'gender' => $item['gender'],
'avatar' => $item['avatar'], 'region' => $item['region'],
'gender' => $item['gender'], 'addFrom' => $item['addFrom'],
'region' => $item['region'], 'labels' => is_array($item['labels']) ? json_encode($item['labels']) : json_encode([]),
'addFrom' => $item['addFrom'], 'siteLabels' => json_encode([]),
'labels' => is_array($item['labels']) ? json_encode($item['labels']) : json_encode([]), 'signature' => $item['signature'],
'siteLabels' => json_encode([]), 'isDeleted' => $item['isDeleted'],
'signature' => $item['signature'], 'isPassed' => $item['isPassed'],
'isDeleted' => $item['isDeleted'], 'deleteTime' => !empty($item['isDeleted']) ? strtotime($item['deleteTime']) : 0,
'isPassed' => $item['isPassed'], 'accountId' => $item['accountId'],
'deleteTime' => !empty($item['isDeleted']) ? strtotime($item['deleteTime']) : 0, 'extendFields' => is_array($item['extendFields']) ? json_encode($item['extendFields']) : json_encode([]),
'accountId' => $item['accountId'], 'accountUserName' => $item['accountUserName'],
'extendFields' => is_array($item['extendFields']) ? json_encode($item['extendFields']) : json_encode([]), 'accountRealName' => $item['accountRealName'],
'accountUserName' => $item['accountUserName'], 'accountNickname' => $item['accountNickname'],
'accountRealName' => $item['accountRealName'], 'ownerAlias' => $item['ownerAlias'],
'accountNickname' => $item['accountNickname'], 'ownerWechatId' => $item['ownerWechatId'],
'ownerAlias' => $item['ownerAlias'], 'ownerNickname' => $item['ownerNickname'],
'ownerWechatId' => $item['ownerWechatId'], 'ownerAvatar' => $item['ownerAvatar'],
'ownerNickname' => $item['ownerNickname'], 'phone' => $item['phone'],
'ownerAvatar' => $item['ownerAvatar'], 'thirdParty' => is_array($item['thirdParty']) ? json_encode($item['thirdParty']) : json_encode([]),
'phone' => $item['phone'], 'groupId' => $item['groupId'],
'thirdParty' => is_array($item['thirdParty']) ? json_encode($item['thirdParty']) : json_encode([]), 'passTime' => !empty($item['isPassed']) && $item['passTime'] != '0001-01-01T00:00:00' ? strtotime($item['passTime']) : 0,
'groupId' => $item['groupId'], 'additionalPicture' => $item['additionalPicture'],
'passTime' => !empty($item['isPassed']) && $item['passTime'] != '0001-01-01T00:00:00' ? strtotime($item['passTime']) : 0, 'desc' => $item['desc'],
'additionalPicture' => $item['additionalPicture'], 'country' => $item['country'],
'desc' => $item['desc'], 'privince' => isset($item['privince']) ? $item['privince'] : '',
'country' => $item['country'], 'city' => isset($item['city']) ? $item['city'] : '',
'privince' => isset($item['privince']) ? $item['privince'] : '', 'createTime' => isset($item['createTime']) ? strtotime($item['createTime']) : 0,
'city' => isset($item['city']) ? $item['city'] : '', 'updateTime' => time()
'createTime' => isset($item['createTime']) ? strtotime($item['createTime']) : 0, ];
'updateTime' => time()
]; // 使用ID作为唯一性判断
} $friend = WechatFriendModel::where('id', $item['id'])->find();
$friend = new WechatFriendModel();
$friend->saveAll($sqlData);
if ($friend) { if ($friend) {
if ($friend->isUpdate()){ unset($data['siteLabels']);
return true; $friend->save($data);
}else{ return true;
return false; } else {
} WechatFriendModel::create($data);
}else{
return false; return false;
} }
} }