提交定时任务

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

@@ -3,6 +3,7 @@ package com.liquidnet.service.platform.service.impl.kylin;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.fasterxml.jackson.core.JsonProcessingException;
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.*;
 import com.liquidnet.service.adam.constant.AdamRedisConst;
@@ -21,6 +22,7 @@ import com.liquidnet.service.stone.vo.StoneUserVo;
 import com.liquidnet.service.sweet.constant.SweetConstant;
 import com.liquidnet.service.sweet.vo.SweetAppletUsersVo;
 import com.liquidnet.service.sweet.vo.SweetWechatUsersVo;
+import com.mysql.cj.jdbc.result.ResultSetImpl;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -34,6 +36,10 @@ 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;
+import java.sql.SQLException;
 import java.time.LocalDateTime;
 import java.util.Arrays;
 import java.util.HashMap;
@@ -185,7 +191,7 @@ public class DataImpl {
             //生成用户积分日志
             int isLog = stoneScoreLogsMapper.selectCount(Wrappers.lambdaQuery(StoneScoreLogs.class).eq(StoneScoreLogs::getUid, uid).eq(StoneScoreLogs::getContent, "历史积分"));
             if (isLog > 0) {
-                return  true;
+                return true;
 //                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
 //                    params.add("uid", uid);
 //                    params.add("score", (score >= 12000 ? 12000 : score) + "");
@@ -344,4 +350,41 @@ public class DataImpl {
         info.put("data", voList);
         return info;
     }
+
+
+    public void fieldData() {
+        try {
+            String countSql = "select count(1) from";
+            String sql = "select count(1) from";
+            Connection connection = DriverManager.getConnection("jdbc:mysql://39.106.122.201:3308/test_ln_scene", "testmall", "zhengzai!mYT");
+//            //查询行数
+//            PreparedStatement preparedStatementCount = connection.prepareStatement(countSql);
+//            ResultSetImpl count = (ResultSetImpl) preparedStatementCount.executeQuery();
+//            int totalCount = count.getInt(1);
+//            int totalRows = totalCount;
+//            count.close();
+            //查询数据
+            PreparedStatement preparedStatement = connection.prepareStatement(sql);
+            ResultSetImpl row = (ResultSetImpl) preparedStatement.executeQuery();
+            row.close();
+            preparedStatement.close();
+            //数据迁移
+            while (row.next()) {
+                //迁移省市县id
+                String url = "http://restapi.amap.com/v3/geocode/geo?key=389880a06e3f893ea46036f030c94700&s=rsv3&city=35&address=";
+                MultiValueMap<String, String> headers = CollectionUtil.linkedMultiValueMapStringString();
+                headers.add("Accept", "application/json;charset=UTF-8");
+//                HttpUtil.get()
+//                $data = $data['geocodes'][0];
+//                $country = $data['country'];
+//                $province = $data['province'];
+//                $city = $data['city'];
+//                $district = $data['district'];
+//                $location = $data['location'];
+
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
 }