经销商审核保存地址

mp-admin/src/main/java/com/qs/mp/web/controller/api/channel/ChannelController.java

@@ -25,9 +25,12 @@ import com.qs.mp.common.enums.ChannelRoleEnum;
 import com.qs.mp.common.enums.ChannelVerifyStatusEnum;
 import com.qs.mp.common.enums.ErrorCodeEnum;
 import com.qs.mp.common.exception.ServiceException;
+import com.qs.mp.common.exception.base.BaseException;
 import com.qs.mp.common.utils.DateUtils;
 import com.qs.mp.system.service.ISysUserService;
+import com.qs.mp.user.domain.UserAddr;
 import com.qs.mp.user.domain.UserTicketOrder;
+import com.qs.mp.user.service.IUserAddrService;
 import com.qs.mp.user.service.IUserTicketOrderService;
 import com.qs.mp.utils.SecurityUtils;
 import com.qs.mp.web.controller.common.BaseApiController;
@@ -87,6 +90,9 @@ public class ChannelController extends BaseApiController {
 	@Autowired
 	private MapperFacade mapperFacade;
 
+	@Autowired
+	private IUserAddrService userAddrService;
+
 	/**
 	 * 获取我的下级渠道列表信息，支持翻页
 	 *
@@ -590,7 +596,7 @@ public class ChannelController extends BaseApiController {
 			}else {
 				channel.setCertifyStatus(ChannelCertifyStatusEnum.NOT_CERTIFIED);
 			}
-			channelService.updateById(channel);
+			channelService.siteVerify(channel);
 		} catch (Exception e) {
 			return AjaxResult.error("门店'" + channel.getName() + "'认证审核失败");
 		}

mp-service/src/main/java/com/qs/mp/channel/service/IChannelService.java

@@ -110,4 +110,10 @@ public interface IChannelService extends IService<Channel> {
     */
 	List<IndexVO> selectIndexSiteIncreaseList(Wrapper<Channel> wrapper);
 
+	/**
+	 * 审核通过的经销商
+	 * @param channel
+	 * @return
+	 */
+    boolean siteVerify(Channel channel);
 }

mp-service/src/main/java/com/qs/mp/channel/service/impl/ChannelServiceImpl.java

@@ -20,6 +20,8 @@ import com.qs.mp.system.domain.SysRole;
 import com.qs.mp.system.domain.SysUser;
 import com.qs.mp.system.service.ISysRoleService;
 import com.qs.mp.system.service.ISysUserService;
+import com.qs.mp.user.domain.UserAddr;
+import com.qs.mp.user.service.IUserAddrService;
 import com.qs.mp.utils.SecurityUtils;
 import java.util.List;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -54,6 +56,9 @@ public class ChannelServiceImpl extends ServiceImpl<ChannelMapper, Channel> impl
   @Autowired
   private ISysRoleService roleService;
 
+  @Autowired
+  private IUserAddrService userAddrService;
+
   @Override
   @Transactional
   public void saveChannel(Channel channel, ChannelRoleEnum channelRole) {
@@ -187,4 +192,32 @@ public class ChannelServiceImpl extends ServiceImpl<ChannelMapper, Channel> impl
 	 return getBaseMapper().selectIndexSiteIncreaseList(wrapper);
   }
 
+  @Override
+  @Transactional(rollbackFor = Exception.class)
+  public boolean siteVerify(Channel channel) {
+
+    // 更新经销商信息
+    channelService.updateById(channel);
+
+    // 设置保存地址信息
+    UserAddr userAddr = new UserAddr();
+    userAddr.setUserId(channel.getUserId());
+    userAddr.setReceiver(channel.getContact());
+    userAddr.setProvince(channel.getProvince());
+    userAddr.setProvinceId(channel.getProvinceId());
+    userAddr.setCity(channel.getCity());
+    userAddr.setCityId(channel.getCityId());
+    userAddr.setArea(channel.getArea());
+    userAddr.setAreaId(channel.getAreaId());
+    userAddr.setAddr(channel.getAddress());
+    userAddr.setMobile(channel.getMobile());
+    userAddr.setStatus(1);
+    int count = userAddrService.count(new LambdaQueryWrapper<UserAddr>().eq(UserAddr::getUserId, channel.getUserId()));
+    if (count == 0) {
+      userAddr.setCommonAddr(1);
+    }
+    userAddrService.save(userAddr);
+
+    return true;
+  }
 }

mp-service/src/main/java/com/qs/mp/user/domain/UserAddr.java

@@ -7,6 +7,9 @@ import com.baomidou.mybatisplus.annotation.TableName;
 import com.baomidou.mybatisplus.annotation.Version;
 import java.io.Serializable;
 import java.util.Date;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 /**
@@ -16,6 +19,7 @@ import lombok.Data;
  */
 @TableName("mp_user_addr")
 @Data
+@ApiModel("用户配送地址实体类")
 public class UserAddr implements Serializable {
 
   private static final long serialVersionUID = 1L;
@@ -23,96 +27,112 @@ public class UserAddr implements Serializable {
   /**
    * ID
    */
+  @ApiModelProperty("地址id,主键")
   @TableId(value = "addr_id" , type = IdType.AUTO)
   private Long addrId;
 
   /**
-   * 渠道ID
+   * 用户ID
    */
+  @ApiModelProperty("用户id")
   @TableField("user_id")
   private Long userId;
 
   /**
    * 收货人
    */
+  @ApiModelProperty("收货人")
   @TableField("receiver")
   private String receiver;
 
   /**
    * 省ID
    */
+  @ApiModelProperty("省id")
   @TableField("province_id")
   private Long provinceId;
 
   /**
    * 省
    */
+  @ApiModelProperty("省")
   @TableField("province")
   private String province;
 
   /**
    * 城市
    */
+  @ApiModelProperty("城市")
   @TableField("city")
   private String city;
 
   /**
    * 城市ID
    */
+  @ApiModelProperty("城市id")
   @TableField("city_id")
   private Long cityId;
 
   /**
    * 区
    */
+  @ApiModelProperty("区")
   @TableField("area")
   private String area;
 
   /**
    * 区ID
    */
+  @ApiModelProperty("区id")
   @TableField("area_id")
   private Long areaId;
 
   /**
    * 邮编
    */
+  @ApiModelProperty("邮编")
   @TableField("post_code")
   private String postCode;
 
   /**
    * 地址
    */
+  @ApiModelProperty("地址")
   @TableField("addr")
   private String addr;
 
   /**
    * 手机
    */
+  @ApiModelProperty("手机")
   @TableField("mobile")
   private String mobile;
 
   /**
    * 状态,1正常，0无效
    */
+  @ApiModelProperty("状态,1正常，0无效")
   @TableField("status")
   private Integer status;
 
   /**
    * 是否默认地址 1是
    */
+  @ApiModelProperty("是否默认地址 1是")
   @TableField("common_addr")
   private Integer commonAddr;
 
   /**
    * 建立时间
    */
+  @ApiModelProperty("建立时间")
   @TableField("create_time")
   private Date createTime;
 
   /**
    * 更新时间
    */
+  @ApiModelProperty("更新时间")
   @Version
   @TableField("update_time")
   private Date updateTime;