数据汇聚

src/main/java/com/sxtvs/open/api/odata/service/impl/WbYmAccountServiceImpl.java

@@ -8,8 +8,10 @@ import com.sxtvs.open.api.odata.entity.WbYmAccount;
 import com.sxtvs.open.api.odata.mapper.WbYmAccountMapper;
 import com.sxtvs.open.api.odata.service.IWbYmAccountService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sxtvs.open.api.odata.service.QrcodeLogServiceImpl;
 import com.sxtvs.open.api.youmei.service.YoumeiAccountServiceImpl;
 import jakarta.annotation.Resource;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
@@ -32,6 +34,9 @@ public class WbYmAccountServiceImpl extends ServiceImpl<WbYmAccountMapper, WbYmA
     @Resource
     private ObjectMapper objectMapper;
 
+    @Autowired
+    private QrcodeLogServiceImpl qrcodeLogService;
+
     public void upsert(String networkGroupId) throws JsonProcessingException {
         String accessToken = youmeiAccountService.getSxgdAccount().getAccessToken();
         String body = HttpUtil.createPost("https://api-open.51wyq.cn/dataapp/api/umei/fw/open/network_group/get_weibo_user_info")
@@ -47,5 +52,7 @@ public class WbYmAccountServiceImpl extends ServiceImpl<WbYmAccountMapper, WbYmA
         wbYmAccount.setUpdateTime(LocalDateTime.now());
         wbYmAccount.setCreateTime(LocalDateTime.now());
         saveOrUpdate(wbYmAccount);
+
+        qrcodeLogService.writeLog("微博",String.valueOf(wbYmAccount.getNetworkGroupId()),wbYmAccount.getNickName());
     }
 }