batchAdd

zhongzheng-admin/src/main/java/com/zhongzheng/controller/distribution/DistributionSellerController.java

@@ -85,4 +85,16 @@ public class DistributionSellerController extends BaseController {
 
 
 
+    /**
+     * 新增分销业务员
+     */
+    @ApiOperation("批量新增关联分销业务员")
+    @PreAuthorize("@ss.hasPermi('system:seller:add')")
+    @Log(title = "分销业务员", businessType = BusinessType.INSERT)
+    @PostMapping("/batchAdd")
+    public AjaxResult<Void> batchAdd(@RequestBody DistributionSellerAddBo bo) {
+        return toAjax(iDistributionSellerService.insertByAddBo(bo) ? 1 : 0);
+    }
+
+
 }

zhongzheng-framework/src/main/java/com/zhongzheng/framework/web/service/DistributionSellerServiceImpl.java

@@ -360,6 +360,34 @@ public class DistributionSellerServiceImpl extends ServiceImpl<DistributionSelle
         return this.save(inertData);
     }
 
+    @Override
+    public Boolean insertBatchByAddBo(DistributionSellerAddBo bo) {
+        for(Long userId:bo.getUserIds()){
+            User user = iUserService.getOne(new LambdaQueryWrapper<User>()
+                    .eq(User::getUserId,userId));
+            if(Validator.isEmpty(user.getIdCard())){
+                throw new CustomException(user.getUserId()+"没有身份证信息");
+            }
+            DistributionSeller sellerIdCard = getOne(new LambdaQueryWrapper<DistributionSeller>()
+                    .eq(DistributionSeller::getIdCard,EncryptHandler.encrypt(user.getIdCard())).last("limit 1"));
+            if(Validator.isNotEmpty(sellerIdCard)){
+                if(Validator.isEmpty(sellerIdCard.getUserId())){
+                    sellerIdCard.setUserId(user.getUserId());
+                    sellerIdCard.setUpdateTime(DateUtils.getNowTime());
+                    updateById(sellerIdCard);
+                }
+            }else{
+                DistributionSellerAddBo bo1 = new DistributionSellerAddBo();
+                bo1.setIdCard(user.getIdCard());
+                bo1.setTelphone(user.getTelphone());
+                bo1.setRealname(user.getRealname());
+                insertByAddBo(bo1);
+            }
+
+        }
+        return true;
+    }
+
     @Override
     public Boolean updateByEditBo(DistributionSellerEditBo bo) {
         DistributionSeller update = BeanUtil.toBean(bo, DistributionSeller.class);

zhongzheng-system/src/main/java/com/zhongzheng/modules/distribution/bo/DistributionSellerAddBo.java

@@ -5,7 +5,7 @@ import io.swagger.annotations.ApiModelProperty;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Data;
 import java.util.Date;
-
+import java.util.List;
 
 
 /**
@@ -60,4 +60,7 @@ public class DistributionSellerAddBo {
     /** 分享码 */
     @ApiModelProperty("分享码")
     private String shareCode;
+
+    @ApiModelProperty("批量用户ID")
+    private List<Long> userIds;
 }

zhongzheng-system/src/main/java/com/zhongzheng/modules/distribution/service/IDistributionSellerService.java

@@ -39,6 +39,8 @@ public interface IDistributionSellerService extends IService<DistributionSeller>
 	 */
 	Boolean insertByAddBo(DistributionSellerAddBo bo);
 
+	Boolean insertBatchByAddBo(DistributionSellerAddBo bo);
+
 	/**
 	 * 根据编辑业务对象修改分销业务员
 	 * @param bo 分销业务员编辑业务对象