楼盘渠道相关

src/main/java/com/yunzhi/marketing/xlk/controller/BuildingChannelController.java

@@ -0,0 +1,140 @@
+package com.yunzhi.marketing.xlk.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.marketing.base.BaseController;
+import com.yunzhi.marketing.base.ResponseBean;
+import com.yunzhi.marketing.xlk.dto.BuildingChannelDTO;
+import com.yunzhi.marketing.xlk.entity.BuildingChannel;
+import com.yunzhi.marketing.xlk.service.IBuildingChannelService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * <p>
+    * 楼盘渠道表  前端控制器
+    * </p>
+ *
+ * @author jobob
+ * @since 2021-07-18
+ */
+@RestController
+@RequestMapping("/api")
+@Api(value = "楼盘渠道表", tags = "xlk-楼盘渠道表")
+public class BuildingChannelController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(BuildingChannelController.class);
+
+    @Autowired
+    public IBuildingChannelService iBuildingChannelService;
+
+
+    /**
+     * 保存对象
+     * @param buildingChannelDTO 实体对象
+     * @return
+     */
+    @ApiOperation(value = "admin-保存楼盘渠道接口", notes = "admin-保存楼盘渠道接口")
+    @RequestMapping(value="/admin/buildingChannel",method= RequestMethod.POST)
+    public ResponseBean buildingChannelAdd(@RequestHeader("authorization") String token,
+                                           @RequestBody BuildingChannelDTO buildingChannelDTO,
+                                           HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            Integer orgId = getOrgId(request);
+            List<BuildingChannel> buildingChannelList = new ArrayList<>();
+            List<String> channelIdList = buildingChannelDTO.getChannelIdList();
+            channelIdList.forEach(e -> {
+                BuildingChannel buildingChannel = new BuildingChannel();
+                BeanUtils.copyProperties(e,buildingChannel);
+                buildingChannel.setChannelId(e);
+                buildingChannel.setCreateDate(LocalDateTime.now());
+                buildingChannel.setOrgId(orgId);
+                buildingChannelList.add(buildingChannel);
+            });
+            if (iBuildingChannelService.saveBatch(buildingChannelList)){
+                responseBean.addSuccess("添加成功");
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("buildingChannelAdd -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 修改对象
+     *
+     * @return
+     */
+    @ApiOperation(value = "admin-修改楼盘渠道接口", notes = "admin-修改楼盘渠道接口")
+    @RequestMapping(value="/admin/buildingChannel",method= RequestMethod.PUT)
+    public ResponseBean buildingChannelUpdate(@RequestHeader("authorization") String token,
+                                              @RequestBody BuildingChannelDTO buildingChannelDTO,
+                                              HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            // 先把此楼盘的渠道全部删除
+            iBuildingChannelService.remove(new LambdaQueryWrapper<BuildingChannel>().eq(BuildingChannel::getBuildingId,buildingChannelDTO.getBuildingId()));
+
+            // 重新添加
+            Integer orgId = getOrgId(request);
+            List<BuildingChannel> buildingChannelList = new ArrayList<>();
+            List<String> channelIdList = buildingChannelDTO.getChannelIdList();
+            channelIdList.forEach(e -> {
+                BuildingChannel buildingChannel = new BuildingChannel();
+                BeanUtils.copyProperties(e,buildingChannel);
+                buildingChannel.setChannelId(e);
+                buildingChannel.setCreateDate(LocalDateTime.now());
+                buildingChannel.setOrgId(orgId);
+                buildingChannelList.add(buildingChannel);
+            });
+            if (iBuildingChannelService.saveBatch(buildingChannelList)){
+                responseBean.addSuccess("修改成功");
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("buildingChannelUpdate -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 根据id查询对象
+     * @param
+     */
+    @ApiOperation(value = "admin-获取楼盘渠道详情接口", notes = "admin-获取楼盘渠道详情接口")
+    @RequestMapping(value="/admin/buildingChannel/{buildingId}",method= RequestMethod.GET)
+    public ResponseBean buildingChannelGet(@PathVariable String buildingId){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            LambdaQueryWrapper<BuildingChannel> queryWrapper = new LambdaQueryWrapper<>();
+            queryWrapper.eq(BuildingChannel::getBuildingId,buildingId);
+            List<BuildingChannel> list = iBuildingChannelService.list(queryWrapper);
+            responseBean.addSuccess(list);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("buildingChannelDelete -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+}

src/main/java/com/yunzhi/marketing/xlk/dto/BuildingChannelDTO.java

@@ -0,0 +1,47 @@
+package com.yunzhi.marketing.xlk.dto;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * <p>
+ * 楼盘渠道表 
+ * </p>
+ *
+ * @author jobob
+ * @since 2021-07-18
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("xlk_building_channel")
+public class BuildingChannelDTO implements Serializable {
+
+    /**
+     * 楼盘id
+     */
+    private String buildingId;
+
+    /**
+     * 渠道id
+     */
+    private List<String> channelIdList;
+
+    /**
+     * 有效期
+     */
+    private Integer expirationDate;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+
+}

src/main/java/com/yunzhi/marketing/xlk/entity/BuildingChannel.java

@@ -0,0 +1,66 @@
+package com.yunzhi.marketing.xlk.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 楼盘渠道表 
+ * </p>
+ *
+ * @author jobob
+ * @since 2021-07-18
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("xlk_building_channel")
+public class BuildingChannel implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 楼盘渠道
+     */
+    @TableId(type = IdType.UUID)
+    private String buildingChannelId;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createDate;
+
+    /**
+     * 公司id
+     */
+    private Integer orgId;
+
+    /**
+     * 楼盘id
+     */
+    private String buildingId;
+
+    /**
+     * 渠道id
+     */
+    private String channelId;
+
+    /**
+     * 有效期
+     */
+    private Integer expirationDate;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+
+}

src/main/java/com/yunzhi/marketing/xlk/mapper/BuildingChannelMapper.java

@@ -0,0 +1,18 @@
+package com.yunzhi.marketing.xlk.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yunzhi.marketing.xlk.entity.BuildingChannel;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 楼盘渠道表  Mapper 接口
+ * </p>
+ *
+ * @author jobob
+ * @since 2021-07-18
+ */
+@Mapper
+public interface BuildingChannelMapper extends BaseMapper<BuildingChannel> {
+
+}

src/main/java/com/yunzhi/marketing/xlk/service/IBuildingChannelService.java

@@ -0,0 +1,16 @@
+package com.yunzhi.marketing.xlk.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.marketing.xlk.entity.BuildingChannel;
+
+/**
+ * <p>
+ * 楼盘渠道表  服务类
+ * </p>
+ *
+ * @author jobob
+ * @since 2021-07-18
+ */
+public interface IBuildingChannelService extends IService<BuildingChannel> {
+
+}

src/main/java/com/yunzhi/marketing/xlk/service/impl/BuildingChannelServiceImpl.java

@@ -0,0 +1,20 @@
+package com.yunzhi.marketing.xlk.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yunzhi.marketing.xlk.entity.BuildingChannel;
+import com.yunzhi.marketing.xlk.mapper.BuildingChannelMapper;
+import com.yunzhi.marketing.xlk.service.IBuildingChannelService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 楼盘渠道表  服务实现类
+ * </p>
+ *
+ * @author jobob
+ * @since 2021-07-18
+ */
+@Service
+public class BuildingChannelServiceImpl extends ServiceImpl<BuildingChannelMapper, BuildingChannel> implements IBuildingChannelService {
+
+}

src/main/resources/mapper/xlk/BuildingChannelMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yunzhi.marketing.xlk.mapper.BuildingChannelMapper">
+
+</mapper>