zm/nuttyreading-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改新增时，如选了默认地址，先清除当前默认地址

Browse Source
This commit is contained in:
wuchunlei
2024-05-14 17:53:46 +08:00
parent 4ccd2a670c
commit dd10365ca5
4 changed files with 24 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/com/peanut/common/utils/DataMigrationUtil.java
View File

@@ -1,6 +1,7 @@
package com.peanut.common.utils;
import cn.hutool.core.date.DateUtil;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
import java.math.BigDecimal;
@@ -38,7 +39,9 @@ public class DataMigrationUtil extends Thread {
Connection yljkconn = DriverManager.getConnection(
"jdbc:mysql://goldorchid.mysql.rds.aliyuncs.com:3309/everhealth?",
"yljkmaster", "Wu751019!@");
PreparedStatement statement = yljkconn.prepareStatement("select * from t_curriculum_catalogue where valid = 1 and poid in (select oid from t_curriculum_catalogue where valid = 1 and poid is null) and (courseFee like '%,%' or courseFee = '0' or poid = '00000000000000000000000000000070' )");
PreparedStatement statement = yljkconn.prepareStatement("select * from t_curriculum_catalogue where valid = 1" +
" and poid in (select oid from t_curriculum_catalogue where valid = 1 and poid is null) " +
"and (courseFee like '%,%' or courseFee = '0' or courseFee = '' or poid = '00000000000000000000000000000070' )");
ResultSet resultSet = statement.executeQuery();
List<Map> list = new ArrayList();
while(resultSet.next()){
@@ -135,7 +138,9 @@ public class DataMigrationUtil extends Thread {
halfFee = "0";
fee = "0";
}
if ("0".equals(resultSet.getString("courseFee"))){
if ("0".equals(resultSet.getString("courseFee"))
||("".equals(resultSet.getString("courseFee"))
&&!"00000000000000000000000000000070".equals(resultSet.getString("ppoid")))){
preparedStatement.setInt(1,0);
}else if ("00000000000000000000000000000070".equals(resultSet.getString("ppoid"))){
preparedStatement.setInt(1,2);
@@ -278,15 +283,16 @@ public class DataMigrationUtil extends Thread {
ResultSet resultSet = statement.executeQuery();
Map map = new HashMap();
while(resultSet.next()){
map.put("videoType",resultSet.getString("videoType"));
if (map.get("videoType").toString().equals("01")){
map.put("type","0");
map.put("video",resultSet.getString("videos"));
}else if (map.get("videoType").equals("02")){
if (StringUtils.isNotEmpty(resultSet.getString("videoId"))){
map.put("type","1");
map.put("video",resultSet.getString("videoId"));
}else if (StringUtils.isNotEmpty(resultSet.getString("videos"))){
map.put("type","0");
map.put("video",resultSet.getString("videos"));
}else if (StringUtils.isNotEmpty(resultSet.getString("voices"))){
map.put("type","2");
map.put("video",resultSet.getString("voices"));
}
map.put("createDate",resultSet.getString("createDate"));
if (map.size() > 0){
String[] tt = map.get("video").toString().split(",");
if (tt.length>0){
@@ -295,7 +301,7 @@ public class DataMigrationUtil extends Thread {
preparedStatement.setString(1,fzdslist.get(q-1).get("cccid").toString());
preparedStatement.setString(2,map.get("type").toString());
preparedStatement.setString(3,tt[r]);
preparedStatement.setString(4,map.get("createDate").toString());
preparedStatement.setString(4,resultSet.getString("createDate"));
preparedStatement.setString(5,r+1+"");
// 添加到批处理中
preparedStatement.addBatch();