diff --git a/src/main/java/com/peanut/common/utils/DataMigrationUtil.java b/src/main/java/com/peanut/common/utils/DataMigrationUtil.java index 77684954..4fbbd793 100644 --- a/src/main/java/com/peanut/common/utils/DataMigrationUtil.java +++ b/src/main/java/com/peanut/common/utils/DataMigrationUtil.java @@ -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 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(); diff --git a/src/main/java/com/peanut/modules/common/controller/UserAddressController.java b/src/main/java/com/peanut/modules/common/controller/UserAddressController.java index 71609c04..d8d3016a 100644 --- a/src/main/java/com/peanut/modules/common/controller/UserAddressController.java +++ b/src/main/java/com/peanut/modules/common/controller/UserAddressController.java @@ -41,9 +41,8 @@ public class UserAddressController { */ @RequestMapping("/save") public R save(@RequestBody UserAddress userAddress) { - // 判断是否已经有默认的地址了 - if ((userAddressService.getUserDefaultAddressCount(userAddress.getUserId()) >= 1) && userAddress.getIsDefault() == 1) { - return R.error("已经存在默认地址"); + if (userAddress.getIsDefault()==1){ + userAddressService.clearUserDefaultAddress(userAddress.getUserId()); } if(userAddress.getRegionCode()==null||userAddress.getRegionCode().equals("")){ return R.error("地址异常添加失败!"); @@ -58,14 +57,8 @@ public class UserAddressController { @RequestMapping("/update") public R update(@RequestBody UserAddress userAddress) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper(); - wrapper.eq(UserAddress::getId,userAddress.getId()); - wrapper.eq(UserAddress::getIsDefault,1); - UserAddress ua = userAddressService.getOne(wrapper); - if (ua == null){ - if ((userAddressService.getUserDefaultAddressCount(userAddress.getUserId()) >= 1) && userAddress.getIsDefault() == 1) { - return R.error("已经存在默认地址"); - } + if (userAddress.getIsDefault()==1){ + userAddressService.clearUserDefaultAddress(userAddress.getUserId()); } String str = userAddress.getConsigneeName()+userAddress.getConsigneePhone()+userAddress.getDetailAddress(); if(str.contains("+")||str.contains("&")){ diff --git a/src/main/java/com/peanut/modules/common/service/UserAddressService.java b/src/main/java/com/peanut/modules/common/service/UserAddressService.java index a5a52c23..c97814c5 100644 --- a/src/main/java/com/peanut/modules/common/service/UserAddressService.java +++ b/src/main/java/com/peanut/modules/common/service/UserAddressService.java @@ -12,6 +12,6 @@ public interface UserAddressService extends IService { UserAddressVo getAddressName(UserAddressVo vo, String regionCode); - int getUserDefaultAddressCount(Integer userId); + boolean clearUserDefaultAddress(Integer userId); } \ No newline at end of file diff --git a/src/main/java/com/peanut/modules/common/service/impl/UserAddressServiceImpl.java b/src/main/java/com/peanut/modules/common/service/impl/UserAddressServiceImpl.java index 07f3ba8a..74ef5595 100644 --- a/src/main/java/com/peanut/modules/common/service/impl/UserAddressServiceImpl.java +++ b/src/main/java/com/peanut/modules/common/service/impl/UserAddressServiceImpl.java @@ -63,10 +63,12 @@ public class UserAddressServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.eq("user_id", userId); queryWrapper.eq("is_default", 1); - return this.count(queryWrapper); + UserAddress userAddress = this.getOne(queryWrapper); + userAddress.setIsDefault(0); + return this.updateById(userAddress); } } \ No newline at end of file