提交galaxy系列表结构

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/utils/DataUtils.java

@@ -147,10 +147,12 @@ public class DataUtils {
         if(obj!=null){
             return (GalaxySeriesInfoBo) obj;
         }else {
-            GalaxySeriesInfoBo seriesInfoBo = mongoTemplate.findOne(Query.query(Criteria.where("seriesCode").is(seriesCode)), GalaxySeriesInfoBo.class, GalaxySeriesInfoBo.class.getSimpleName());
-            if (seriesInfoBo == null) {
+            GalaxySeriesInfoVo seriesInfoVo = mongoTemplate.findOne(Query.query(Criteria.where("seriesCode").is(seriesCode)), GalaxySeriesInfoVo.class, GalaxySeriesInfoVo.class.getSimpleName());
+            if (seriesInfoVo == null) {
                 return null;
             }
+            GalaxySeriesInfoBo seriesInfoBo = GalaxySeriesInfoBo.getNew();
+            BeanUtil.copy(seriesInfoVo,seriesInfoBo);
             redisUtil.set(GalaxyConstant.REDIS_KEY_GALAXY_SERIES.concat(routerType).concat(":") + seriesCode, seriesInfoBo);
             return seriesInfoBo;
         }
@@ -208,11 +210,22 @@ public class DataUtils {
 
         Query query = Query.query(Criteria.where("seriesCode").is(seriesInfoBo.getSeriesCode()));
         Update update = Update.fromDocument(Document.parse(JsonUtils.toJson(seriesInfoBo)));
-        update.set("seriesClaimStatus", seriesInfoBo.getSeriesClaimStatus());
+//        update.set("seriesClaimStatus", seriesInfoBo.getSeriesClaimStatus());
         String nowTimeStr = DateUtil.Formatter.yyyyMMddHHmmss.format(LocalDateTime.now());
         update.set("updatedAt",nowTimeStr);
         UpdateResult result = mongoTemplate.updateFirst(query,update, GalaxySeriesInfoVo.class,GalaxySeriesInfoVo.class.getSimpleName());
         log.info("updateSeriesClaimStatus result:{}",result.toString());
+
+        try{
+            queueUtil.sendMySqlRedis(
+                    SqlMapping.get("galaxy_series_info.updateSeriesIdAndStatus"),
+                    new Object[]{seriesInfoBo.getSeriesId(),seriesInfoBo.getSeriesClaimStatus(),nowTimeStr,seriesInfoBo.getSeriesCode()}
+                    , MQConst.GalaxyQueue.SQL_SERIES_INFO.getKey()
+            );
+        }catch(Exception e){
+            log.error(e.getMessage(),e);
+            log.error("#setNftTradeInfo error ==> MESSAGE:{}",e.getMessage());
+        }
     }
 
     public void setNftOrderBo(String routerType,String nftOrderPayId, GalaxyNftOrderBo nftOrderBo) {
@@ -267,7 +280,7 @@ public class DataUtils {
         update.set("nftId", nftOrderBo.getNftId());
         String nowTimeStr = DateUtil.Formatter.yyyyMMddHHmmss.format(LocalDateTime.now());
         update.set("updatedAt",nowTimeStr);
-        UpdateResult result = mongoTemplate.updateFirst(query,update, GalaxyNftOrderBo.class,GalaxyNftOrderBo.class.getSimpleName());
+        UpdateResult result = mongoTemplate.updateFirst(query,update, GalaxyNftOrderVo.class,GalaxyNftOrderVo.class.getSimpleName());
         log.info("updateNftOrderInfo result:{}",result.toString());
 
         try{
@@ -290,7 +303,7 @@ public class DataUtils {
         update.set("nftBuyTaskId", nftOrderBo.getNftBuyTaskId());
         String nowTimeStr = DateUtil.Formatter.yyyyMMddHHmmss.format(LocalDateTime.now());
         update.set("updatedAt",nowTimeStr);
-        UpdateResult result = mongoTemplate.updateFirst(query,update, GalaxyNftOrderBo.class,GalaxyNftOrderBo.class.getSimpleName());
+        UpdateResult result = mongoTemplate.updateFirst(query,update, GalaxyNftOrderVo.class,GalaxyNftOrderVo.class.getSimpleName());
         log.info("updateNftOrderInfo result:{}",result.toString());
 
         try{

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/sqlmap.properties

@@ -10,5 +10,6 @@ galaxy_nft_order_info.insert=insert into galaxy_nft_order_info (nft_order_pay_id
 galaxy_nft_trade_info.insert=insert into galaxy_nft_trade_info (nft_id, series_id, trade_hash, chain_timestamp, from_address, to_address,trade_price, trade_type, created_at, updated_at)values (?,?,?,?,?,?,?,?,?,?)
 
 #更新信息
+galaxy_series_info.updateSeriesIdAndStatus=update galaxy_series_info t set t.series_id = ?,t.series_claim_status = ? ,t.updated_at =? where t.series_code = ?
 galaxy_nft_order_info.updateNftId=update galaxy_nft_order_info t set t.nft_id = ? ,t.updated_at =? where t.nft_order_pay_id = ?
 galaxy_nft_order_info.updateNftBuyTaskId=update galaxy_nft_order_info t set t.nft_buy_task_id = ? ,t.updated_at =? where t.nft_order_pay_id = ?