股东大盘分红添加了版本号

kxs-user/kxs-user-api/src/main/java/com/kxs/user/api/model/KxsShdScore.java

@@ -64,7 +64,7 @@ public class KxsShdScore extends Model<KxsShdScore> implements Serializable {
      * 版本
      */
     @Schema(description = "版本")
-    private Integer version;
+    private Long version;
 
 
     /**

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/service/impl/KxsShdScoreServiceImpl.java

@@ -90,7 +90,8 @@ public class KxsShdScoreServiceImpl extends ServiceImpl<KxsShdScoreMapper, KxsSh
                 if (kxsUser != null){
                     //查询记录
                     KxsShdScore kxsShdScore = kxsShdScoreMapper.selectOne(Wrappers.<KxsShdScore>query().lambda().eq(KxsShdScore::getUserId, kxsUser.getId()).eq(KxsShdScore::getMonth, month));
-                    if (kxsShdScore == null){
+                    //版本号对比
+                    if (kxsShdScore == null || !kxsShdScore.getVersion().equals(integralStatDTO.getVersion())){
                         //记录不存在则构造数据
                         kxsShdScore = new KxsShdScore();
                         kxsShdScore.setCreateTime(now);
@@ -98,6 +99,7 @@ public class KxsShdScoreServiceImpl extends ServiceImpl<KxsShdScoreMapper, KxsSh
                         kxsShdScore.setUserId(Long.valueOf(kxsUser.getId()));
                         kxsShdScore.setUsername(kxsUser.getUsername());
                         kxsShdScore.setUserCode(kxsUser.getUserCode());
+                        kxsShdScore.setVersion(integralStatDTO.getVersion());//版本号
                         if (integralStatDTO.getTotalAmount().compareTo(ShdGradingEnum.LEVEL_FRIST.getTransactions()) >= 0){
                             kxsShdScore.setFirstScore(1);
                         }
@@ -126,6 +128,7 @@ public class KxsShdScoreServiceImpl extends ServiceImpl<KxsShdScoreMapper, KxsSh
                             kxsShdScore.setHighScore(kxsShdScore.getHighScore() + 1);
                         }
                         kxsShdScore.setUpdateTime(now);
+                        kxsShdScore.setVersion(integralStatDTO.getVersion());
                         kxsShdScoreMapper.updateById(kxsShdScore);
                     }
                 }