bug修复

fs-service/src/main/java/com/fs/course/service/impl/BalanceRollbackErrorServiceImpl.java

@@ -132,7 +132,7 @@ public class BalanceRollbackErrorServiceImpl extends ServiceImpl<BalanceRollback
                     BigDecimal newMoney = originalMoney.subtract(totalAmount);
                     redisCache.setCacheObject(companyMoneyKey, newMoney.toString());
 
-                } finally {
+                }finally {
                     lock1.unlock();
                 }
 
@@ -140,14 +140,13 @@ public class BalanceRollbackErrorServiceImpl extends ServiceImpl<BalanceRollback
                 for (BalanceRollbackError error : errorList) {
                     error.setStatus(1);
                 }
-
-                try {
-                    this.updateBatchById(errorList);
-                } catch(Exception  e){
-                    logger.error("批量更新余额异常数据异常公司id{},",companyId);
-                    logger.error("批量更新余额异常数据异常数据{},",errorList);
-                    throw new RuntimeException("批量更新余额异常数据异常",e);
+                boolean b = this.updateBatchById(errorList);
+                if (!b) {
+                    logger.error("批量更新余额异常表状态异常公司id{},",companyId);
+                    logger.error("批量更新余额异常表状态异常数据{},",errorList);
+                    throw new RuntimeException("批量更新余额异常表状态异常");
                 }
+
             } else {
                 logger.error("获取锁异常公司id{},",companyId);
                 logger.error("获取锁异常数据{},",errorList);

fs-service/src/main/java/com/fs/course/service/impl/FsUserCourseVideoServiceImpl.java

@@ -1635,7 +1635,7 @@ public class FsUserCourseVideoServiceImpl implements IFsUserCourseVideoService
                 try {
                     // 获取当前余额
                     String currentMoneyStr = redisCache.getCacheObject(companyMoneyKey);
-                    if (StringUtils.isNotEmpty(currentMoneyStr)) {
+                    if (StringUtils.isEmpty(currentMoneyStr)) {
                         throw new RuntimeException("回滚余额异常");
                     }