股東表插入、查詢

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/AppShareholderDetailBiz.java

@@ -6,6 +6,7 @@ import com.github.wxiaoqi.security.admin.entity.*;
 import com.github.wxiaoqi.security.admin.mapper.AppShareholderDetailMapper;
 import com.github.wxiaoqi.security.admin.vo.AppShareholderDetailVo;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.github.wxiaoqi.security.common.vo.PageDataVO;
@@ -181,14 +182,18 @@ public class AppShareholderDetailBiz extends BaseBiz<AppShareholderDetailMapper,
             int endIndex = i == (threadNums - 1) ? shareholderData.size() : (i + 1) * BORDER_NUM;
             List<String[]> subResultDate = shareholderData.subList(startIndex, endIndex);
             threadPoolTaskExecutor.execute(() -> {
-
-
+                wrapperData(subResultDate, discount, counter);
+                latch.countDown();
             });
-
+            try {
+                latch.await();
+            } catch (InterruptedException e) {
+                throw new BaseException("导入数据失败");
+            }
 
         }
 
-        return 1;
+        return appShareholderDetail.size();
     }
 
     /**