diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInfoDAO.java b/coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInfoDAO.java index e9d9b2b24..b767d48df 100644 --- a/coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInfoDAO.java +++ b/coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInfoDAO.java @@ -21,6 +21,7 @@ import com.google.common.collect.Maps; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.StringUtils; +import org.apache.ibatis.annotations.Param; import org.springframework.stereotype.Repository; import javax.annotation.Resource; @@ -180,4 +181,11 @@ public class LineInfoDAO { List lineMobile = lineInfoMapper.getLineMobile(lineIds); return lineMobile.stream().filter(o->StringUtils.isNotBlank(o.getMobile())).collect(Collectors.toMap(LineInfoDO::getId, LineInfoDO::getMobile, (k1, k2)-> k1)); } + + public Integer batchUpdateInvestmentManager( List lineIds, Integer status, String investmentManager){ + if(CollectionUtils.isEmpty(lineIds)|| status == null|| StringUtils.isBlank(investmentManager)){ + return 0; + } + return lineInfoMapper.batchUpdateInvestmentManager(lineIds, status, investmentManager); + } } diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInfoMapper.java b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInfoMapper.java index 8eeea8f33..fc5a4b865 100644 --- a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInfoMapper.java +++ b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInfoMapper.java @@ -104,4 +104,15 @@ public interface LineInfoMapper extends Mapper { * @return */ List getLineMobile(@Param("lineIds") List lineIds); + + /** + * 批量更新招商经理与线索状态 + * @param lineIds + * @param status + * @param investmentManager + * @return + */ + Integer batchUpdateInvestmentManager(@Param("lineIds") List lineIds, + @Param("status") Integer status, + @Param("investmentManager") String investmentManager); } \ No newline at end of file diff --git a/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml b/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml index 78e2772a9..10365d1aa 100644 --- a/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml +++ b/coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml @@ -567,4 +567,11 @@ + + update xfsg_line_info set line_status = #{status} and investment_manager = #{investmentManager} where id in + + #{lineId} + + + \ No newline at end of file diff --git a/coolstore-partner-model/src/main/java/com/cool/store/request/DistributionInvestmentRequest.java b/coolstore-partner-model/src/main/java/com/cool/store/request/DistributionInvestmentRequest.java new file mode 100644 index 000000000..45f47f12e --- /dev/null +++ b/coolstore-partner-model/src/main/java/com/cool/store/request/DistributionInvestmentRequest.java @@ -0,0 +1,19 @@ +package com.cool.store.request; + +import lombok.Data; + +import java.util.List; + +/** + * @Author suzhuhong + * @Date 2024/7/19 16:15 + * @Version 1.0 + */ +@Data +public class DistributionInvestmentRequest { + + private String investmentManagerId; + + private List lineIds; + +} diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/LineService.java b/coolstore-partner-service/src/main/java/com/cool/store/service/LineService.java index 4e02300dc..0011dd5ac 100644 --- a/coolstore-partner-service/src/main/java/com/cool/store/service/LineService.java +++ b/coolstore-partner-service/src/main/java/com/cool/store/service/LineService.java @@ -75,11 +75,11 @@ public interface LineService { /** * 将线索从未分配转为已分配 线索变为私海线索 - * @param changeInvestmentRequest + * @param distributionInvestmentRequest * @param userInfo * @return */ - Boolean distributionLine(ChangeInvestmentRequest changeInvestmentRequest,LoginUserInfo userInfo); + Boolean distributionLine(DistributionInvestmentRequest distributionInvestmentRequest,LoginUserInfo userInfo); /** * 线索的各节点情况 diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/LineServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/LineServiceImpl.java index 201f1664f..8eb225f4b 100644 --- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/LineServiceImpl.java +++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/LineServiceImpl.java @@ -335,21 +335,13 @@ public class LineServiceImpl implements LineService { } @Override - public Boolean distributionLine(ChangeInvestmentRequest changeInvestmentRequest, LoginUserInfo userInfo) { - log.info("changeJoinMode request={}",JSONObject.toJSONString(changeInvestmentRequest)); - if (changeInvestmentRequest.getLineId()==null||changeInvestmentRequest.getInvestmentManagerId()==null){ + public Boolean distributionLine(DistributionInvestmentRequest request, LoginUserInfo userInfo) { + log.info("changeJoinMode request={}",JSONObject.toJSONString(request)); + if (CollectionUtils.isEmpty(request.getLineIds())||request.getInvestmentManagerId()==null){ throw new ServiceException(ErrorCodeEnum.PARAMS_REQUIRED); } - //查询线索 - LineInfoDO lineInfo = lineInfoDAO.getLineInfo(changeInvestmentRequest.getLineId()); - if (lineInfo==null){ - throw new ServiceException(ErrorCodeEnum.LINE_ID_IS_NOT_EXIST); - } - lineInfo.setInvestmentManager(changeInvestmentRequest.getInvestmentManagerId()); - lineInfo.setLineStatus(LineStatusEnum.PRIVATE_SEAS.getCode()); - lineInfo.setUpdateTime(new Date()); - lineInfo.setUpdateUserId(userInfo.getUserId()); - lineInfoDAO.updateLineInfo(lineInfo); + //批量更新线索 + lineInfoDAO.batchUpdateInvestmentManager(request.getLineIds(),LineStatusEnum.PRIVATE_SEAS.getCode(), request.getInvestmentManagerId()); return Boolean.TRUE; } diff --git a/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/LineInfoController.java b/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/LineInfoController.java index 971491d52..f2bffd265 100644 --- a/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/LineInfoController.java +++ b/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/LineInfoController.java @@ -155,8 +155,8 @@ public class LineInfoController { @ApiOperation("将线索从未分配转为已分配") @PostMapping("/distributionLine") - public ResponseResult distributionLine(@RequestBody ChangeInvestmentRequest changeInvestmentRequest) { - return ResponseResult.success(lineService.distributionLine(changeInvestmentRequest,CurrentUserHolder.getUser())); + public ResponseResult distributionLine(@RequestBody DistributionInvestmentRequest distributionInvestmentRequest) { + return ResponseResult.success(lineService.distributionLine(distributionInvestmentRequest,CurrentUserHolder.getUser())); } @ApiOperation("跳过意向金")