批量会员导入

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

 package com.github.wxiaoqi.security.admin.biz;
 
-import com.github.wxiaoqi.security.admin.dto.BaseUserMemberExportDTO;
 import com.github.wxiaoqi.security.admin.dto.UserMemberDTO;
 import com.github.wxiaoqi.security.admin.entity.BaseUserMemberExport;
 import com.github.wxiaoqi.security.admin.mapper.BaseUserMemberExportMapper;
-import com.github.wxiaoqi.security.admin.mapper.BaseUserMemberMapper;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
-import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
-import com.github.wxiaoqi.security.common.util.excel.ExcelImport;
-import com.sun.org.apache.regexp.internal.RE;
-import com.xxfc.platform.vehicle.common.RestResponse;
+import com.github.wxiaoqi.security.common.exception.BaseException;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
-import org.springframework.web.multipart.MultipartFile;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -29,6 +24,7 @@ import java.util.stream.Collectors;
  * @data 2019/7/8 16:19
  */
 @Service
+@Slf4j
 public class BaseUserMemberExportBiz extends BaseBiz<BaseUserMemberExportMapper, BaseUserMemberExport> {
 
      @Autowired
@@ -43,7 +39,7 @@ public class BaseUserMemberExportBiz extends BaseBiz<BaseUserMemberExportMapper,
 
     @Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)
     @Async
-    public void importUserMember(List<String[]> userMemberData) throws Exception {
+    public void importUserMember(List<String[]> userMemberData){
         List<BaseUserMemberExport> baseUserMemberExports = new ArrayList<>();
 
         List<Integer> levels = userMemberData.stream().map(x -> x[1]).map(Integer::valueOf).collect(Collectors.toList());
@@ -62,7 +58,12 @@ public class BaseUserMemberExportBiz extends BaseBiz<BaseUserMemberExportMapper,
             userMemberDTO.setUserId(phoneAndUserIdMap.get(username));
             userMemberDTO.setDiscount(levelAndDisCountMap==null?0:(levelAndDisCountMap.get(memberLevel)==null?0:levelAndDisCountMap.get(memberLevel)));
             userMemberDTO.setTotalNumber(Integer.valueOf(totalNumber));
+            try {
                 baseUserMemberBiz.updUserMemberByUserId(userMemberDTO);
+            } catch (Exception e) {
+                log.error("会员更新错误：【{}】",e.getMessage());
+                throw new BaseException(e);
+            }
 
             BaseUserMemberExport memberExport = BaseUserMemberExport
                     .builder()

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/rest/UserMemberController.java

@@ -67,6 +67,7 @@ public class UserMemberController {
         if (userMemberData.size() < 1) {
             return ObjectRestResponse.createFailedResult(1001, "导入不能没数据！！！");
         }
-            return baseUserMemberExportBiz.importUserMember(userMemberData);
+        baseUserMemberExportBiz.importUserMember(userMemberData);
+        return  ObjectRestResponse.succ();
     }
 }