多品牌使用

coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInfoDAO.java

@@ -182,10 +182,10 @@ public class LineInfoDAO {
         return lineMobile.stream().filter(o->StringUtils.isNotBlank(o.getMobile())).collect(Collectors.toMap(LineInfoDO::getId, LineInfoDO::getMobile, (k1, k2)-> k1));
     }
 
-    public Integer batchUpdateInvestmentManager( List<Long> lineIds, Integer status, String investmentManager){
+    public Integer batchUpdateInvestmentManager( List<Long> lineIds, Integer status, String investmentManager,Long regionId){
-        if(CollectionUtils.isEmpty(lineIds)|| status == null|| StringUtils.isBlank(investmentManager)){
+        if(CollectionUtils.isEmpty(lineIds)|| status == null|| StringUtils.isBlank(investmentManager) || regionId == null){
             return 0;
         }
-        return lineInfoMapper.batchUpdateInvestmentManager(lineIds, status, investmentManager);
+        return lineInfoMapper.batchUpdateInvestmentManager(lineIds, status, investmentManager,regionId);
     }
 }

coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInfoMapper.java

@@ -18,22 +18,26 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
     LineInfoDO getByPartnerId(@Param("partnerId") String partnerId);
 
     LineInfoDO getByLineId(@Param("lineId") Long lineId);
+
     List<LineInfoDO> getByLineIds(@Param("lineIds") List<Long> lineIds);
+
     /**
      * 查询招商经理待处理数据
+     *
      * @param investmentManagerUserId
      * @return
      */
-    List<LineInfoDO> listByInvestmentManager(@Param("investmentManagerUserId") String  investmentManagerUserId, @Param("codes") List<Integer> codes);
+    List<LineInfoDO> listByInvestmentManager(@Param("investmentManagerUserId") String investmentManagerUserId, @Param("codes") List<Integer> codes);
 
     /**
      * 面试官待处理
+     *
      * @param interviewId
      * @param interviewType
      * @param codes
      * @return
      */
-    List<LineInfoDO> listByInterview(@Param("interviewId") String  interviewId,
+    List<LineInfoDO> listByInterview(@Param("interviewId") String interviewId,
                                      @Param("interviewType") Integer interviewType,
                                      @Param("pendingInterviewStatusList") List<Integer> pendingInterviewStatusList,
                                      @Param("notPassingTheInterview") Integer notPassingTheInterview,
@@ -41,6 +45,7 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
 
     /**
      * 我的线索列表
+     *
      * @param lineListRequest
      * @return
      */
@@ -56,7 +61,8 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
 
 
     /**
-     *  公海线索列表
+     * 公海线索列表
+     *
      * @param publicLineListRequest
      * @return
      */
@@ -64,6 +70,7 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
 
     /**
      * 根据lineId判断是更新还是插入
+     *
      * @param lineInfoParam
      */
     void insertOrUpdate(@Param("param") LineInfoDO lineInfoParam);
@@ -73,6 +80,7 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
 
     /**
      * 待处理数据
+     *
      * @param userId
      * @return
      */
@@ -81,11 +89,11 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
     InvestmentCountDTO investmentData(@Param("userId") String userId);
 
 
-
+    Integer batchUpdateInterviewWorkflowStage(@Param("lineIds") List<Long> lineIds, @Param("workflowSubStage") Integer workflowSubStage, @Param("workflowSubStageStatus") Integer workflowSubStageStatus);
-    Integer batchUpdateInterviewWorkflowStage(@Param("lineIds") List<Long> lineIds, @Param("workflowSubStage")Integer workflowSubStage, @Param("workflowSubStageStatus")Integer workflowSubStageStatus);
 
     /**
      * 选址人员获取蓄水池状态的加盟商
+     *
      * @param request
      * @return
      */
@@ -100,6 +108,7 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
 
     /**
      * 获取线索手机号
+     *
      * @param lineIds
      * @return
      */
@@ -107,6 +116,7 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
 
     /**
      * 批量更新招商经理与线索状态
+     *
      * @param lineIds
      * @param status
      * @param investmentManager
@@ -114,5 +124,5 @@ public interface LineInfoMapper extends Mapper<LineInfoDO> {
      */
     Integer batchUpdateInvestmentManager(@Param("lineIds") List<Long> lineIds,
                                          @Param("status") Integer status,
-                                         @Param("investmentManager") String investmentManager);
+                                         @Param("investmentManager") String investmentManager, @Param("regionId") Long regionId);
 }

coolstore-partner-dao/src/main/resources/mapper/LineInfoMapper.xml

@@ -572,7 +572,7 @@
 
 
   <update id="batchUpdateInvestmentManager">
-    update xfsg_line_info set line_status = #{status} , investment_manager = #{investmentManager} where id in
+    update xfsg_line_info set line_status = #{status} , investment_manager = #{investmentManager} ,region_id = #{regionId} where id in
     <foreach collection="lineIds" item="lineId" open="(" separator="," close=")">
       #{lineId}
     </foreach>

coolstore-partner-model/src/main/java/com/cool/store/request/DistributionInvestmentRequest.java

@@ -16,4 +16,6 @@ public class DistributionInvestmentRequest {
 
     private List<Long> lineIds;
 
+    private Long regionId;
+
 }

coolstore-partner-service/src/main/java/com/cool/store/service/impl/LineServiceImpl.java

@@ -361,7 +361,7 @@ public class LineServiceImpl implements LineService {
             throw new ServiceException(ErrorCodeEnum.PARAMS_REQUIRED);
         }
         //批量更新线索
-        lineInfoDAO.batchUpdateInvestmentManager(request.getLineIds(),LineStatusEnum.PRIVATE_SEAS.getCode(), request.getInvestmentManagerId());
+        lineInfoDAO.batchUpdateInvestmentManager(request.getLineIds(),LineStatusEnum.PRIVATE_SEAS.getCode(), request.getInvestmentManagerId(),request.getRegionId());
         return Boolean.TRUE;
     }