记得上下班打卡 | git大法好,push需谨慎

Commit 035257aa authored by jiangxiulong's avatar jiangxiulong

Merge remote-tracking branch 'origin/dev_20211205' into dev_20211205

parents a98d28c3 af4d4646
...@@ -51,10 +51,6 @@ public class StoneServerImpl { ...@@ -51,10 +51,6 @@ public class StoneServerImpl {
@Autowired @Autowired
private MongoTemplate mongoTemplate; private MongoTemplate mongoTemplate;
@Autowired
AdamUserMapper userMapper;
@Autowired
KylinOrderTicketsMapper orderTicketsMapper;
@Autowired @Autowired
StoneScoreUserMapper stoneScoreUserMapper; StoneScoreUserMapper stoneScoreUserMapper;
@Autowired @Autowired
...@@ -63,18 +59,16 @@ public class StoneServerImpl { ...@@ -63,18 +59,16 @@ public class StoneServerImpl {
FeignStoneIntegralClient stoneIntegralClient; FeignStoneIntegralClient stoneIntegralClient;
private static final String SQL_URL = "jdbc:mysql://zhengzai.mysql.polardb.rds.aliyuncs.com:3306/ln_scene"; private static final String SQL_URL = "jdbc:mysql://zhengzai.mysql.polardb.rds.aliyuncs.com:3306/ln_scene";
private static final String SQL_USER = "java"; private static final String SQL_USER = "zhengzai";
private static final String SQL_PWD = "pOOs9Y3wj#2^"; private static final String SQL_PWD = "GDDHBJOEcJw!";
public boolean initScore(String uid) { public boolean initScore(String uid) {
try { try {
String sql = "select * from temp_score where uid = +uid"; String sql = "select * from temp_score where uid = " + uid;
Connection connection = DriverManager.getConnection(SQL_URL, SQL_USER, SQL_PWD); Connection connection = DriverManager.getConnection(SQL_URL, SQL_USER, SQL_PWD);
//查询数据 //查询数据
PreparedStatement preparedStatement = connection.prepareStatement(sql); PreparedStatement preparedStatement = connection.prepareStatement(sql);
ResultSetImpl row = (ResultSetImpl) preparedStatement.executeQuery(); ResultSetImpl row = (ResultSetImpl) preparedStatement.executeQuery();
row.close();
preparedStatement.close();
//数据迁移 //数据迁移
while (row.next()) { while (row.next()) {
int score = row.getInt("price_cost"); int score = row.getInt("price_cost");
...@@ -99,6 +93,8 @@ public class StoneServerImpl { ...@@ -99,6 +93,8 @@ public class StoneServerImpl {
} }
stoneIntegralClient.in2111(uid, score, "历史积分"); stoneIntegralClient.in2111(uid, score, "历史积分");
} }
row.close();
preparedStatement.close();
} catch (Exception e) { } catch (Exception e) {
log.info("异常 : {} ", e); log.info("异常 : {} ", e);
e.printStackTrace(); e.printStackTrace();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment