Commit 90081041 by songyinghui

feat: 好友关系判定

parent 0b72eae1
...@@ -401,10 +401,10 @@ public interface TabHaobanExternalClerkRelatedMapper { ...@@ -401,10 +401,10 @@ public interface TabHaobanExternalClerkRelatedMapper {
/** /**
* 查询会员与导购的好友关系 * 查询会员与导购的好友关系
* @param clerkId * @param staffId
* @param memberIds * @param memberIds
* @return * @return
*/ */
List<TabHaobanExternalClerkRelated> queryClerkMemberRelations(@Param("clerkId") String clerkId, @Param("memberIds") List<String> memberIds); List<TabHaobanExternalClerkRelated> queryClerkMemberRelations(@Param("staffId") String staffId, @Param("memberIds") List<String> memberIds);
} }
\ No newline at end of file
...@@ -96,6 +96,6 @@ public interface ExternalClerkRelatedService { ...@@ -96,6 +96,6 @@ public interface ExternalClerkRelatedService {
* @param memberIds * @param memberIds
* @return * @return
*/ */
List<TabHaobanExternalClerkRelated> queryClerkMemberRelations(String clerkId, List<String> memberIds); List<TabHaobanExternalClerkRelated> queryClerkMemberRelations(String staffId, List<String> memberIds);
} }
...@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; ...@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
import com.gic.api.base.commons.Page; import com.gic.api.base.commons.Page;
import com.gic.commons.util.UniqueIdUtils; import com.gic.commons.util.UniqueIdUtils;
import com.gic.haoban.common.utils.PageUtil; import com.gic.haoban.common.utils.PageUtil;
import com.gic.haoban.manage.api.dto.StaffClerkRelationDTO;
import com.gic.haoban.manage.service.dao.mapper.content.TabHaobanPotentialCustomerMapper; import com.gic.haoban.manage.service.dao.mapper.content.TabHaobanPotentialCustomerMapper;
import com.gic.haoban.manage.service.entity.TabHaobanExternalClerkRelated; import com.gic.haoban.manage.service.entity.TabHaobanExternalClerkRelated;
import com.gic.haoban.manage.service.entity.content.TabHaobanPotentialCustomer; import com.gic.haoban.manage.service.entity.content.TabHaobanPotentialCustomer;
...@@ -14,6 +15,7 @@ import com.gic.haoban.manage.service.pojo.qo.content.InteractRecordQO; ...@@ -14,6 +15,7 @@ import com.gic.haoban.manage.service.pojo.qo.content.InteractRecordQO;
import com.gic.haoban.manage.service.pojo.qo.content.PotentialCustomerQO; import com.gic.haoban.manage.service.pojo.qo.content.PotentialCustomerQO;
import com.gic.haoban.manage.service.service.ExternalClerkRelatedService; import com.gic.haoban.manage.service.service.ExternalClerkRelatedService;
import com.gic.haoban.manage.service.service.MemberQueryService; import com.gic.haoban.manage.service.service.MemberQueryService;
import com.gic.haoban.manage.service.service.StaffClerkRelationService;
import com.gic.haoban.manage.service.service.content.InteractRecordService; import com.gic.haoban.manage.service.service.content.InteractRecordService;
import com.gic.haoban.manage.service.service.content.PotentialCustomerService; import com.gic.haoban.manage.service.service.content.PotentialCustomerService;
import com.gic.haoban.manage.service.service.content.adaptor.PotentialCustomerNotifyBuilder; import com.gic.haoban.manage.service.service.content.adaptor.PotentialCustomerNotifyBuilder;
...@@ -56,6 +58,8 @@ public class PotentialCustomerServiceImpl implements PotentialCustomerService { ...@@ -56,6 +58,8 @@ public class PotentialCustomerServiceImpl implements PotentialCustomerService {
private ExternalClerkRelatedService externalClerkRelatedService; private ExternalClerkRelatedService externalClerkRelatedService;
@Autowired @Autowired
MemberQueryService memberQueryService; MemberQueryService memberQueryService;
@Autowired
StaffClerkRelationService staffClerkRelationService;
/** /**
...@@ -121,7 +125,11 @@ public class PotentialCustomerServiceImpl implements PotentialCustomerService { ...@@ -121,7 +125,11 @@ public class PotentialCustomerServiceImpl implements PotentialCustomerService {
log.info("按好友条件搜索 无须查询"); log.info("按好友条件搜索 无须查询");
return Collections.emptyMap(); return Collections.emptyMap();
} }
List<TabHaobanExternalClerkRelated> clerkRelateds = externalClerkRelatedService.queryClerkMemberRelations(clerkId, memberIds); StaffClerkRelationDTO staffClerkRelationDTO = staffClerkRelationService.getByClerkId(clerkId);
if (staffClerkRelationDTO == null) {
return Collections.emptyMap();
}
List<TabHaobanExternalClerkRelated> clerkRelateds = externalClerkRelatedService.queryClerkMemberRelations(staffClerkRelationDTO.getStaffId(), memberIds);
if (CollectionUtils.isEmpty(clerkRelateds)) { if (CollectionUtils.isEmpty(clerkRelateds)) {
log.info("查询导购与本批次会员不存在好友关系 clerkId:{}", clerkId); log.info("查询导购与本批次会员不存在好友关系 clerkId:{}", clerkId);
return Collections.emptyMap(); return Collections.emptyMap();
......
...@@ -504,20 +504,20 @@ public class ExternalClerkRelatedServiceImpl implements ExternalClerkRelatedServ ...@@ -504,20 +504,20 @@ public class ExternalClerkRelatedServiceImpl implements ExternalClerkRelatedServ
/*** /***
* 查询会员与导购的关系 * 查询会员与导购的关系
* @param clerkId * @param staffId
* @param memberIds * @param memberIds
* @return * @return
*/ */
@Override @Override
public List<TabHaobanExternalClerkRelated> queryClerkMemberRelations(String clerkId, List<String> memberIds) { public List<TabHaobanExternalClerkRelated> queryClerkMemberRelations(String staffId, List<String> memberIds) {
if (StringUtils.isBlank(clerkId)) { if (StringUtils.isBlank(staffId)) {
logger.info("查询导购与会员的关系,导购id不存在 {}", clerkId); logger.info("查询导购与会员的关系,staffId不存在 {}", staffId);
return Collections.emptyList(); return Collections.emptyList();
} }
if (CollectionUtils.isEmpty(memberIds)) { if (CollectionUtils.isEmpty(memberIds)) {
logger.info("查询导购与会员的关系,会员id数组为空 {}", clerkId); logger.info("查询导购与会员的关系,会员id数组为空 {}", staffId);
return Collections.emptyList(); return Collections.emptyList();
} }
return this.mapper.queryClerkMemberRelations(clerkId, memberIds); return this.mapper.queryClerkMemberRelations(staffId, memberIds);
} }
} }
...@@ -771,7 +771,7 @@ ...@@ -771,7 +771,7 @@
<select id="queryClerkMemberRelations" resultMap="BaseResultMap"> <select id="queryClerkMemberRelations" resultMap="BaseResultMap">
select <include refid="Base_Column_List"/> select <include refid="Base_Column_List"/>
from tab_haoban_external_clerk_related from tab_haoban_external_clerk_related
where clerk_id = #{clerkId} where staff_id = #{staffId}
and status_flag in (1, 3, 4) and status_flag in (1, 3, 4)
and member_id in and member_id in
<foreach collection="memberIds" item="memberId" open="(" close=")" separator=","> <foreach collection="memberIds" item="memberId" open="(" close=")" separator=",">
......
...@@ -61,7 +61,7 @@ public class MaterialReportServiceTest { ...@@ -61,7 +61,7 @@ public class MaterialReportServiceTest {
public void handlerMaterialWeekReportTest() { public void handlerMaterialWeekReportTest() {
System.setProperty("gic.module.name", "haoban-manage3-service"); System.setProperty("gic.module.name", "haoban-manage3-service");
materialReportService.handlerMaterialReport(eid, staffId, MaterialReportType.WEEK.getCode()); materialReportService.handlerMaterialReport(eid, staffId, MaterialReportType.WEEK.getCode());
materialReportService.handlerMaterialReport(eid, staffId, MaterialReportType.MONTH.getCode()); //materialReportService.handlerMaterialReport(eid, staffId, MaterialReportType.MONTH.getCode());
} }
@Test @Test
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment