过期积分数据

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/kylin/DataController.java

@@ -18,33 +18,41 @@ public class DataController {
     @Autowired
     private DataImpl data;
 
-    @PostMapping("fieldData")
-    @ApiOperation("场地数据迁移")
-    public ResponseDto<Boolean> fieldData() {
-        data.fieldData();
-        return ResponseDto.success();
-    }
-
-    @PostMapping("account")
-    @ApiOperation("演出关联用户id迁移")
-    public ResponseDto<Boolean> account() {
-        data.account();
-        return ResponseDto.success();
-    }
 
-    @PostMapping("sponsor")
-    @ApiOperation("主办方相关迁移")
-    public ResponseDto<Boolean> sponsor() {
-        data.sponsor();
+    @PostMapping("refreshScore")
+    @ApiOperation("过期历史积分")
+    public ResponseDto<Boolean> fieldData() {
+        data.refreshScore();
         return ResponseDto.success();
     }
 
-    @PostMapping("checkTicket")
-    @ApiOperation("验票账号相关迁移")
-    public ResponseDto<Boolean> checkTicket() {
-        data.checkTicket();
-        return ResponseDto.success();
-    }
+//    @PostMapping("fieldData")
+//    @ApiOperation("场地数据迁移")
+//    public ResponseDto<Boolean> fieldData() {
+//        data.fieldData();
+//        return ResponseDto.success();
+//    }
+//
+//    @PostMapping("account")
+//    @ApiOperation("演出关联用户id迁移")
+//    public ResponseDto<Boolean> account() {
+//        data.account();
+//        return ResponseDto.success();
+//    }
+//
+//    @PostMapping("sponsor")
+//    @ApiOperation("主办方相关迁移")
+//    public ResponseDto<Boolean> sponsor() {
+//        data.sponsor();
+//        return ResponseDto.success();
+//    }
+//
+//    @PostMapping("checkTicket")
+//    @ApiOperation("验票账号相关迁移")
+//    public ResponseDto<Boolean> checkTicket() {
+//        data.checkTicket();
+//        return ResponseDto.success();
+//    }
 
 //    @PostMapping("initScore")
 //    @ApiOperation("积分数据迁移")

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java

@@ -6,6 +6,7 @@ import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.*;
 import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.feign.stone.api.FeignStoneIntegralClient;
 import com.liquidnet.service.kylin.dto.param.PerformancePartnerVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.entity.KylinPerformanceRelations;
@@ -17,6 +18,9 @@ import com.liquidnet.service.slime.dto.vo.*;
 import com.liquidnet.service.slime.entity.*;
 import com.liquidnet.service.slime.mapper.*;
 import com.liquidnet.service.platform.utils.ObjectUtil;
+import com.liquidnet.service.stone.constant.StoneConstant;
+import com.liquidnet.service.stone.entity.StoneScoreLogs;
+import com.liquidnet.service.stone.mapper.StoneScoreLogsMapper;
 import com.mongodb.BasicDBObject;
 import com.mysql.cj.jdbc.result.ResultSetImpl;
 import lombok.extern.slf4j.Slf4j;
@@ -31,6 +35,7 @@ import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Service;
 import org.springframework.util.MultiValueMap;
 
+import java.math.BigDecimal;
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
@@ -66,9 +71,13 @@ public class DataImpl {
     DMTAuthorizationPermissionService dmtAuthorizationPermissionService;
     @Autowired
     DMTAuthorizationRecordsService dmtAuthorizationRecordsService;
+    @Autowired
+    StoneScoreLogsMapper stoneScoreLogsMapper;
+    @Autowired
+    FeignStoneIntegralClient feignStoneIntegralClient;
 
 
-//    private static final String SQL_URL = "jdbc:mysql://39.107.71.112:3308/test_ln_scene";
+    //    private static final String SQL_URL = "jdbc:mysql://39.107.71.112:3308/test_ln_scene";
 //    private static final String SQL_USER = "testmall";
 //    private static final String SQL_PWD = "zhengzai!mYT";
 //    private static final String PHP_DB = "testmall";
@@ -76,6 +85,7 @@ public class DataImpl {
     private static final String SQL_USER = "readonly";
     private static final String SQL_PWD = "ZWDsf8Fy";
     private static final String PHP_DB = "mall";
+
     //迁移场地和场地认领关系
     public void fieldData() {
         try {
@@ -236,7 +246,7 @@ public class DataImpl {
             String sql = "select merchant_id, mm.mobile,  kp.performances_id ,kps.audit_status\n" +
                     "from kylin_performances kp\n" +
                     "         inner join kylin_performance_relations kpr on kpr.performance_id = kp.performances_id\n" +
-                    "         inner join kylin_performance_status kps on kps.performance_id = kp.performances_id\n"+
+                    "         inner join kylin_performance_status kps on kps.performance_id = kp.performances_id\n" +
                     "         left join " + PHP_DB + ".merchants mm on mm.id = kpr.merchant_id";
             Connection connection = DriverManager.getConnection(SQL_URL, SQL_USER, SQL_PWD);
             //查询数据
@@ -267,11 +277,11 @@ public class DataImpl {
                 KylinPerformanceRelations kylinPerformanceRelations = KylinPerformanceRelations.getNew();
                 kylinPerformanceRelations.setMerchantId(uid);
                 kylinPerformanceRelationsMapper.update(kylinPerformanceRelations,
-                        Wrappers.lambdaUpdate(KylinPerformanceRelations.class).eq(KylinPerformanceRelations::getMerchantId, merchantId).eq(KylinPerformanceRelations::getPerformanceId,performancesId));
+                        Wrappers.lambdaUpdate(KylinPerformanceRelations.class).eq(KylinPerformanceRelations::getMerchantId, merchantId).eq(KylinPerformanceRelations::getPerformanceId, performancesId));
 
                 HashMap<String, Object> map = CollectionUtil.mapStringObject();
                 map.put("merchantId", uid);
-                map.put("auditStatus",auditStatus);
+                map.put("auditStatus", auditStatus);
                 //修改vo
                 Query voQuery = Query.query(Criteria.where("performancesId").is(performancesId));
                 BasicDBObject objectVo = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
@@ -607,4 +617,28 @@ public class DataImpl {
         mongoTemplate.upsert(query, update, SlimeAuthorizationPerformanceVo.class, SlimeAuthorizationPerformanceVo.class.getSimpleName());
         return vo;
     }
+
+
+    public boolean refreshScore() {
+        //获取需要跑积分的用户
+        List<StoneScoreLogs> logsList = stoneScoreLogsMapper.selectList(Wrappers.lambdaQuery(StoneScoreLogs.class)
+                .eq(StoneScoreLogs::getContent, "历史积分").eq(StoneScoreLogs::getUid,"544327").orderByDesc(StoneScoreLogs::getUid));
+        for (StoneScoreLogs logs : logsList) {
+            int restScore = getUserScoreRest(logs.getUid());
+            if(logs.getScore().compareTo(new BigDecimal(restScore))>0){
+                feignStoneIntegralClient.de2111(logs.getUid(), new BigDecimal(logs.getScore() + "").intValue(), "积分到期");
+            }
+        }
+        return true;
+    }
+
+    public Integer getUserScoreRest(String uid) {
+        String redisKey = StoneConstant.USER.concat(uid).concat(StoneConstant.SURPLUS_SCORE);
+        Object obj = redisDataSourceUtil.getRedisStoneUtil().get(redisKey);
+        if (obj == null) {
+            return 0;
+        } else {
+            return (Integer) obj;
+        }
+    }
 }