feat: 增加客户转移和释放公海数据保存

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/domain/dataobject/BlinkCustomerReleaseDO.java

@@ -0,0 +1,30 @@
+package com.wx.blink.backend.domain.dataobject;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.wx.blink.base.common.domain.BaseEntity;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Data
+@TableName("blink_customer_release")
+public class BlinkCustomerReleaseDO extends BaseEntity {
+
+    @Schema(description = "id")
+    @TableId(type = IdType.ASSIGN_UUID)
+    private String id;
+
+    @Schema(description = "客户id")
+    private String cusid;
+
+    @Schema(description = "释放原因")
+    private String reason;
+
+    @Schema(description = "归属区域")
+    private String belongRegion;
+
+    @Schema(description = "营销人员")
+    private String marketStaff;
+
+}

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/domain/dataobject/BlinkCustomerTransferDO.java

@@ -0,0 +1,35 @@
+package com.wx.blink.backend.domain.dataobject;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.wx.blink.base.common.domain.BaseEntity;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Data
+@TableName("blink_customer_transfer")
+public class BlinkCustomerTransferDO extends BaseEntity {
+
+    @Schema(description = "id")
+    @TableId(type = IdType.ASSIGN_UUID)
+    private String id;
+
+    @Schema(description = "客户id")
+    private String cusid;
+
+    @Schema(description = "转移至归属区域")
+    private String belongRegion;
+
+    @Schema(description = "转移至营销人员")
+    private String marketStaff;
+
+
+    @Schema(description = "原归属区域")
+    private String oldBelongRegion;
+
+    @Schema(description = "原营销人员")
+    private String oldMarketStaff;
+
+}

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/domain/dto/BlinkCustomerReleaseVO.java

@@ -14,4 +14,10 @@ public class BlinkCustomerReleaseVO implements Serializable {
     @Schema(description = "释放原因")
     private String reason;
 
+    @Schema(description = "归属区域")
+    private String belongRegion;
+
+    @Schema(description = "营销人员")
+    private String marketStaff;
+
 }

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/domain/dto/BlinkCustomerTransferVO.java

@@ -20,4 +20,11 @@ public class BlinkCustomerTransferVO implements Serializable {
     @Schema(description = "转移至营销人员")
     private String marketStaff;
 
+
+    @Schema(description = "原归属区域")
+    private String oldBelongRegion;
+
+    @Schema(description = "原营销人员")
+    private String oldMarketStaff;
+
 }

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/manager/BlinkCustomerReleaseImpl.java

@@ -0,0 +1,43 @@
+package com.wx.blink.backend.manager;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerReleaseDO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerReleaseVO;
+import com.wx.blink.backend.objectmapper.BlinkCustomerReleaseMapper;
+import com.wx.blink.backend.repository.BlinkCustomerReleaseRepository;
+import com.wx.blink.backend.service.IBlinkCustomerReleaseService;
+import com.wx.blink.base.common.util.BlinkEntityUtil;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+
+@Service
+public class BlinkCustomerReleaseImpl extends ServiceImpl<BlinkCustomerReleaseRepository, BlinkCustomerReleaseDO> implements IBlinkCustomerReleaseService {
+
+    @Resource
+    private BlinkCustomerReleaseRepository releaseRepository;
+    @Resource
+    private BlinkCustomerReleaseMapper releaseMapper;
+
+    @Override
+    public void addOrUpdate(BlinkCustomerReleaseVO vo) {
+        BlinkCustomerReleaseDO releaseDo = releaseMapper.customerReleaseVOtoDomain(vo);
+        if (releaseDo != null) {
+            //有id更新，没有则新增
+            if (releaseDo.getId() == null || releaseDo.getId() == "") {
+                //创建人赋值
+                BlinkEntityUtil.setCreateInfo(releaseDo);
+                this.save(releaseDo);
+            } else {
+                //更新人赋值
+                BlinkEntityUtil.setUpdatedInfo(releaseDo);
+                this.updateById(releaseDo);
+            }
+        }
+    }
+
+
+
+
+}

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/manager/BlinkCustomerServiceImpl.java

@@ -14,9 +14,7 @@ import com.wx.blink.backend.domain.qry.BlinkBizFileQry;
 import com.wx.blink.backend.objectmapper.BlinkCustomerMapper;
 import com.wx.blink.backend.repository.BlinkCustomerRepository;
 import com.wx.blink.backend.repository.BlinkProviderRepository;
-import com.wx.blink.backend.service.IBlinkCustomerSeniorService;
-import com.wx.blink.backend.service.IBlinkCustomerService;
-import com.wx.blink.backend.service.IBlinkProviderService;
+import com.wx.blink.backend.service.*;
 import com.wx.blink.base.common.domain.PageResult;
 import com.wx.blink.base.common.domain.ResponseDTO;
 import com.wx.blink.base.common.util.BlinkEntityUtil;
@@ -59,6 +57,10 @@ public class BlinkCustomerServiceImpl extends ServiceImpl<BlinkCustomerRepositor
     private IBlinkCustomerSeniorService seniorService;
     @Resource
     private BlinkProviderServiceImpl providerService;
+    @Resource
+    private IBlinkCustomerTransferService transferService;
+    @Resource
+    private IBlinkCustomerReleaseService releaseService;
 
     @Override
     public ResponseDTO<String> supportsCustomerCreate(BlinkCustomerCreateVO dto) {
@@ -288,12 +290,14 @@ public class BlinkCustomerServiceImpl extends ServiceImpl<BlinkCustomerRepositor
     @Override
     public ResponseDTO<String> customerTransfer(BlinkCustomerTransferVO vo) {
         customerRepository.customerTransfer(vo);
+        transferService.addOrUpdate(vo);
         return ResponseDTO.ok();
     }
 
     @Override
     public ResponseDTO<String> customerRelease(BlinkCustomerReleaseVO vo) {
         customerRepository.customerRelease(vo);
+        releaseService.addOrUpdate(vo);
         //记录
         String reason = "释放公海，释放原因：";
         if(vo.getReason()!=null) reason = reason+vo.getReason();

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/manager/BlinkCustomerTransferImpl.java

@@ -0,0 +1,44 @@
+package com.wx.blink.backend.manager;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerTransferDO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerTransferVO;
+import com.wx.blink.backend.objectmapper.BlinkCustomerTransferMapper;
+import com.wx.blink.backend.repository.BlinkCustomerTransferRepository;
+import com.wx.blink.backend.service.IBlinkCustomerTransferService;
+import com.wx.blink.base.common.util.BlinkEntityUtil;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+
+@Service
+public class BlinkCustomerTransferImpl extends ServiceImpl<BlinkCustomerTransferRepository, BlinkCustomerTransferDO> implements IBlinkCustomerTransferService {
+
+    @Resource
+    private BlinkCustomerTransferRepository transferRepository;
+    @Resource
+    private BlinkCustomerTransferMapper transferMapper;
+
+    @Override
+    public void addOrUpdate(BlinkCustomerTransferVO vo) {
+        BlinkCustomerTransferDO transferDo = transferMapper.customerTransferVOtoDomain(vo);
+        if (transferDo != null) {
+            //有id更新，没有则新增
+            if (transferDo.getId() == null || transferDo.getId() == "") {
+                //创建人赋值
+                BlinkEntityUtil.setCreateInfo(transferDo);
+                this.save(transferDo);
+            } else {
+                //更新人赋值
+                BlinkEntityUtil.setUpdatedInfo(transferDo);
+                this.updateById(transferDo);
+            }
+        }
+    }
+
+
+
+
+}

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/objectmapper/BlinkCustomerReleaseMapper.java

@@ -0,0 +1,24 @@
+package com.wx.blink.backend.objectmapper;
+
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerReleaseDO;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerTagDO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerReleaseVO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerTransferVO;
+import com.wx.blink.base.common.util.BlinkStringUtil;
+import org.mapstruct.Mapper;
+
+
+@Mapper(componentModel = "spring", imports = {BlinkStringUtil.class})
+public interface BlinkCustomerReleaseMapper {
+
+    /**
+     * 客户转移数据VO转do
+     *
+     * @param vo
+     * @return
+     */
+    BlinkCustomerReleaseDO customerReleaseVOtoDomain(BlinkCustomerReleaseVO vo);
+
+
+
+}

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/objectmapper/BlinkCustomerTransferMapper.java

@@ -0,0 +1,24 @@
+package com.wx.blink.backend.objectmapper;
+
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerTagDO;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerTransferDO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerTagVO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerTransferVO;
+import com.wx.blink.base.common.util.BlinkStringUtil;
+import org.mapstruct.Mapper;
+
+
+@Mapper(componentModel = "spring", imports = {BlinkStringUtil.class})
+public interface BlinkCustomerTransferMapper {
+
+    /**
+     * 客户转移数据VO转do
+     *
+     * @param vo
+     * @return
+     */
+    BlinkCustomerTransferDO customerTransferVOtoDomain(BlinkCustomerTransferVO vo);
+
+
+
+}

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/repository/BlinkCustomerReleaseRepository.java

@@ -0,0 +1,10 @@
+package com.wx.blink.backend.repository;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerReleaseDO;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerTagDO;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface BlinkCustomerReleaseRepository extends BaseMapper<BlinkCustomerReleaseDO> {
+}

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/repository/BlinkCustomerTransferRepository.java

@@ -0,0 +1,14 @@
+package com.wx.blink.backend.repository;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerTagDO;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerTransferDO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerTagVO;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@Mapper
+public interface BlinkCustomerTransferRepository extends BaseMapper<BlinkCustomerTransferDO> {
+}

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/service/IBlinkCustomerReleaseService.java

@@ -0,0 +1,19 @@
+package com.wx.blink.backend.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerReleaseDO;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerTransferDO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerReleaseVO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerTransferVO;
+
+public interface IBlinkCustomerReleaseService extends IService<BlinkCustomerReleaseDO> {
+
+
+
+    /**
+     * 保存或更新
+     *
+     * @return
+     */
+    void addOrUpdate(BlinkCustomerReleaseVO VO);
+}

bound-link-api/blink-backend/src/main/java/com/wx/blink/backend/service/IBlinkCustomerTransferService.java

@@ -0,0 +1,21 @@
+package com.wx.blink.backend.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.wx.blink.backend.domain.dataobject.BlinkCustomerTransferDO;
+import com.wx.blink.backend.domain.dataobject.BlinkTagPoolDO;
+import com.wx.blink.backend.domain.dto.BlinkCustomerTransferVO;
+import com.wx.blink.backend.domain.dto.BlinkTagPoolVO;
+import com.wx.blink.backend.domain.qry.BlinkTagPoolQry;
+import com.wx.blink.base.common.domain.PageResult;
+
+public interface IBlinkCustomerTransferService extends IService<BlinkCustomerTransferDO> {
+
+
+
+    /**
+     * 保存或更新
+     *
+     * @return
+     */
+    void addOrUpdate(BlinkCustomerTransferVO VO);
+}