add lastupdatetimestamp update

Dapp-Learning-DAO · Jan 22, 2024 · 1011297 · 1011297
1 parent a549a1a
commit 1011297
Showing 1 changed file with 16 additions and 2 deletions.
diff --git a/src/main/java/com/dl/officialsite/redpacket/RedPacketService.java b/src/main/java/com/dl/officialsite/redpacket/RedPacketService.java
@@ -44,6 +44,8 @@ public class RedPacketService {
 
     public CloseableHttpClient httpClient = HttpClients.createDefault();
 
+    private String lastUpdateTimestamp= "";
+
    @Scheduled(cron =  "${jobs.redpacket.corn:0/10 * * * * ?}")
 
    public void updateRedpacketStatus() throws IOException {
@@ -60,13 +62,22 @@ public void updateRedpacketStatus() throws IOException {
                 JsonObject jsonObject = JsonParser.parseString(jsonResponse).getAsJsonObject();
                 JsonObject data = jsonObject.getAsJsonObject("data");
                 JsonArray redpacketsArray = data.getAsJsonArray("redpackets");
+                JsonArray lastupdatesArray = data.getAsJsonArray("lastupdates");
+                String lastTimestampFromGraph = lastupdatesArray.get(0).getAsString();
+                if(Objects.equals(lastTimestampFromGraph, lastUpdateTimestamp)){
+                    return;
+                } else {
+                    lastUpdateTimestamp = lastTimestampFromGraph;
+                }
+
+
                 List<RedPacket> redPacketList = redPacketRepository.findByStatusAndChainId(0, chainId);
 
                 for (int i = 0; i < redpacketsArray.size(); i++) {
                     // Access each element in the array
                     JsonObject redpacketObject = redpacketsArray.get(i).getAsJsonObject();
 
-                    log.info(redpacketObject.toString());
+                    //log.info(redpacketObject.toString());
                     Long id = redpacketObject.get("nonce").getAsLong();
                  //   String name = redpacketObject.get("name").getAsString();
                     for (int j = 0; j < redPacketList.size(); j++) {
@@ -138,7 +149,10 @@ private HttpEntity getHttpEntityFromChain(String chainId) throws IOException {
                 "      claimer" +
                 "     claimedValue " +
                 "    }" +
-                "  }" +
+
+                "  lastupdates ( orderBy : lastupdateTimestamp , orderDirection: desc) {\n" +
+                "    lastupdateTimestamp\n" +
+                "    }" +
                 "}\"";