Skip to content

Y
yd-backend
Commit 57192da0 by jianan
Options

PEP得分查询bug修复及优化

parent 0f652e37
Showing with 112 additions and 50 deletions
yd-api/src/main/java/com/yd/api/practitioner/service/impl/ScheduleTrackServiceImpl.java
......@@ -6,6 +6,7 @@ import com.yd.api.result.CommonResult;
import com.yd.dal.entity.customer.AclPractitionerPotentialAssignedTrack;
import com.yd.dal.entity.marketing.MktLeadsAssignedTrack;
import com.yd.dal.entity.meta.MdDropOptions;
import com.yd.dal.entity.practitioner.PersonalPEPScore;
import com.yd.dal.entity.practitioner.PersonalSchedule;
import com.yd.dal.entity.practitioner.ScheduleTrack;
import com.yd.dal.mapper.marketing.ScheduleTrackMapper;
......@@ -215,22 +216,19 @@ public class ScheduleTrackServiceImpl implements ScheduleTrackService {
default:
break;
}
if (trackTime.equals(trackDate) || Integer.valueOf(1).equals(flag)) {
return true;
} else {
return false;
}
return trackTime.equals(trackDate) || Integer.valueOf(1).equals(flag);
}
@Override
public QueryPEPScoreResponseVO queryPEPScore(Long practitionerId) {
QueryPEPScoreResponseVO resp = new QueryPEPScoreResponseVO();
try {
// 获取本月第一天
Calendar cal = Calendar.getInstance();
cal.add(Calendar.MONTH,0);
cal.add(Calendar.MONTH, 0);
// 获取到本月起始日
int actualMinimum = cal.getActualMinimum(Calendar.DAY_OF_MONTH);
cal.set(cal.get(Calendar.YEAR), cal.get(Calendar.MONDAY), actualMinimum,00,00,00);
cal.set(cal.get(Calendar.YEAR), cal.get(Calendar.MONDAY), actualMinimum, 00, 00, 00);
// 获取本月起始日的年月日时分秒格式
Date monthOne = cal.getTime();
......@@ -244,7 +242,7 @@ public class ScheduleTrackServiceImpl implements ScheduleTrackService {
Date weekOne = cal.getTime();
// 根据团队长经纪人id查询团队每个成员本日，本周，本月得分以及本月FYC
List<Map<String, Object>> saleAndRecuit = scheduleTrackMapper.querySaleRecuitScoreFYC(practitionerId, monthOne, today);
List<PersonalPEPScore> saleAndRecuit = scheduleTrackMapper.querySaleRecuitScoreFYC(practitionerId, monthOne, today);
// 其他活动有长期固定，通过计算时间段内展示次数，算得总分
// 先获得每个人所有的其他活动
......@@ -255,41 +253,87 @@ public class ScheduleTrackServiceImpl implements ScheduleTrackService {
this.computeOtherScore(personalScheduleList, today, weekOne, monthOne);
// 最后合并营销增员和其他活动的分数
this.mergeScore(personalScheduleList, saleAndRecuit);
// 计算团队平均分
Map<String, Object> average = this.computeTeamAverageScore(saleAndRecuit, practitionerIdList.size());
resp.setPersonalList(saleAndRecuit);
System.out.println("看看结果集");
System.out.println(saleAndRecuit);
resp.setAverage(average);
resp.setCommonResult(new CommonResult(true, ZHBErrorConfig.getErrorInfo("800000")));
} catch (Exception e) {
e.printStackTrace();
resp.setCommonResult(new CommonResult(false, ZHBErrorConfig.getErrorInfo("800001")));
}
return resp;
}
private void mergeScore(List<PersonalSchedule> personalScheduleList, List<Map<String, Object>> saleAndRecuit) {
DecimalFormat df = new DecimalFormat("#.##%");
for (Map<String, Object> scoreMap:saleAndRecuit) {
private Map<String, Object> computeTeamAverageScore(List<PersonalPEPScore> saleAndRecuit, int teamSize) {
PersonalPEPScore personalScore = null;
Long dayScore = 0L;
Long weekScore = 0L;
Long monthScore = 0L;
BigDecimal FYC = new BigDecimal(0);
for (int i = 0; i < saleAndRecuit.size(); i++) {
personalScore = saleAndRecuit.get(i);
dayScore += personalScore.getDayScore();
weekScore += personalScore.getWeekScore();
monthScore += personalScore.getMonthScore();
FYC = FYC.add(personalScore.getFYC());
}
Double dayAverage = 0D;
Double weekAverage = 0D;
Double monthAverage = 0D;
// 平均分效
Double rate = 0D;
if (!CommonUtil.isNullOrZero(teamSize)){
dayAverage = BigDecimal.valueOf(dayScore)
.divide(BigDecimal.valueOf(teamSize),2, BigDecimal.ROUND_HALF_UP)
.doubleValue();
weekAverage = BigDecimal.valueOf(weekScore)
.divide(BigDecimal.valueOf(teamSize),2, BigDecimal.ROUND_HALF_UP)
.doubleValue();
monthAverage = BigDecimal.valueOf(monthScore)
.divide(BigDecimal.valueOf(teamSize),2, BigDecimal.ROUND_HALF_UP)
.doubleValue();
}
if (!CommonUtil.isNullOrZero(monthScore)){
rate = FYC.divide(BigDecimal.valueOf(monthScore), 2, BigDecimal.ROUND_HALF_UP)
.doubleValue();
}
for (PersonalSchedule perSchedule:personalScheduleList) {
Long curPractitionerId = perSchedule.getPractitionerId();
if (curPractitionerId.equals(scoreMap.get("practitionerId"))) {
Map<String, Long> otherMap = perSchedule.getOther();
Map<String, Object> average = new HashMap<>();
average.put("dayScore", dayAverage);
average.put("weekScore", weekAverage);
average.put("monthScore", monthAverage);
average.put("rate", rate);
Long dayScore = Long.parseLong(scoreMap.get("dayScore").toString()) + otherMap.get("dayScore");
Long weekScore = Long.parseLong(scoreMap.get("weekScore").toString()) + otherMap.get("weekScore");
Long monthScore = Long.parseLong(scoreMap.get("monthScore").toString()) + otherMap.get("monthScore");
return average;
}
scoreMap.put("dayScore", dayScore);
scoreMap.put("weekScore", weekScore);
scoreMap.put("monthScore", monthScore);
private void mergeScore(List<PersonalSchedule> personalScheduleList, List<PersonalPEPScore> saleAndRecuit) {
for (PersonalPEPScore socre : saleAndRecuit) {
for (PersonalSchedule schedule : personalScheduleList) {
Long curPractitionerId = schedule.getPractitionerId();
if (curPractitionerId.equals(socre.getPractitionerId())) {
Map<String, Long> otherMap = schedule.getOther();
}
Long dayScore = socre.getDayScore() + otherMap.get("dayScore");
Long weekScore = socre.getWeekScore() + otherMap.get("weekScore");
Long monthScore = socre.getMonthScore() + otherMap.get("monthScore");
socre.setDayScore(dayScore);
socre.setWeekScore(weekScore);
socre.setMonthScore(monthScore);
}
}
// 单人分效 scoreMap.get("monthScore").toString()
Double rate = BigDecimal.valueOf(Double.parseDouble(scoreMap.get("FYC").toString()))
.divide(BigDecimal.valueOf(Long.parseLong(scoreMap.get("monthScore").toString()) ), 2, BigDecimal.ROUND_HALF_UP)
Double rate = 0D;
if (!CommonUtil.isNullOrZero(socre.getMonthScore())){
// 单人分效
rate = socre.getFYC().divide(BigDecimal.valueOf(socre.getMonthScore()), 2, BigDecimal.ROUND_HALF_UP)
.doubleValue();
scoreMap.put("rate", df.format(rate));
}
socre.setRate(rate);
}
}
private void computeOtherScore(List<PersonalSchedule> personalScheduleList, Date today, Date weekOne, Date monthOne) {
......
yd-api/src/main/java/com/yd/api/practitioner/vo/sechedule/QueryPEPScoreResponseVO.java
package com.yd.api.practitioner.vo.sechedule;
import com.yd.api.result.CommonResult;
import com.yd.dal.entity.practitioner.PersonalPEPScore;
import lombok.Data;
import java.util.List;
......@@ -8,7 +9,7 @@ import java.util.Map;
@Data
public class QueryPEPScoreResponseVO {
private Map<String, String> average;
private List<Map<String, Object>> personalList;
private Map<String, Object> average;
private List<PersonalPEPScore> personalList;
private CommonResult commonResult;
}
yd-api/src/main/java/com/yd/dal/entity/practitioner/PersonalPEPScore.java 0 → 100644
package com.yd.dal.entity.practitioner;
import lombok.Data;
import java.math.BigDecimal;
@Data
public class PersonalPEPScore {
private Long practitionerId;
private String name;
private Long dayScore;
private Long weekScore;
private Long monthScore;
private BigDecimal FYC;
private Double rate;
}
yd-api/src/main/java/com/yd/dal/mapper/marketing/ScheduleTrackMapper.java
package com.yd.dal.mapper.marketing;
import com.yd.dal.entity.practitioner.PersonalPEPScore;
import com.yd.dal.entity.practitioner.PersonalSchedule;
import com.yd.dal.entity.practitioner.ScheduleTrack;
import org.apache.ibatis.annotations.Param;
......@@ -17,7 +18,7 @@ public interface ScheduleTrackMapper {
int checkTimePeriodConflict(@Param("taskTimeFrom")String taskTimeFrom, @Param("taskTimeEnd")String taskTimeEnd,
@Param("practitionerId")Long practitionerId);
List<Map<String, Object>> querySaleRecuitScoreFYC(@Param("practitionerId")Long practitionerId, @Param("firstDay")Date firstDay,
List<PersonalPEPScore> querySaleRecuitScoreFYC(@Param("practitionerId")Long practitionerId, @Param("firstDay")Date firstDay,
@Param("lastDay")Date lastDay);
List<Map<String, Object>> queryOtherScore(@Param("practitionerId")Long practitionerId);
......
yd-api/src/main/resources/mapper/marketing/ScheduleTrackMapper.xml
......@@ -87,23 +87,23 @@
</select>
<select id="querySaleRecuitScoreFYC" resultType="hashmap">
SELECT practitioner_id, dayScore, weekScore, monthScore, COALESCE(fyc,0) FYC
<select id="querySaleRecuitScoreFYC" resultType="com.yd.dal.entity.practitioner.PersonalPEPScore">
SELECT practitionerId, name, dayScore, weekScore, monthScore, COALESCE(fyc,0) FYC
FROM
(select practitioner_id,
sum(case when to_days(created_at) = to_days(now()) then COALESCE(track_score,0) else 0 end) dayScore,
sum(case when YEARWEEK(date_format(created_at,'%Y-%m-%d'),1) = YEARWEEK(now(),1) then COALESCE(track_score,0) else 0 end) weekScore,
sum(case when date_format(created_at,'%Y-%m')=date_format(now(),'%Y-%m') then COALESCE(track_score,0) else 0 end) monthScore
from ag_mkt_schedule_task_tracking
where is_active = 1
and practitioner_id in (SELECT id from ag_acl_practitioner
where subordinate_system_id =
(select subordinate_system_id from ag_acl_practitioner where id = #{practitionerId,jdbcType=BIGINT})
)
and md_drop_option_id not in (223,224,225,226,227)
and created_at between #{firstDay,jdbcType=TIMESTAMP}
and #{lastDay,jdbcType=TIMESTAMP}
group by practitioner_id
(select p.id practitionerId,
p.name,
sum(case when to_days(t.created_at) = to_days(now()) then COALESCE(t.track_score,0) else 0 end) dayScore,
sum(case when YEARWEEK(date_format(t.created_at,'%Y-%m-%d'),1) = YEARWEEK(now(),1) then COALESCE(t.track_score,0) else 0 end) weekScore,
sum(case when date_format(t.created_at,'%Y-%m')=date_format(now(),'%Y-%m') then COALESCE(t.track_score,0) else 0 end) monthScore
from ag_acl_practitioner p
left join (select practitioner_id, created_at, track_score
from ag_mkt_schedule_task_tracking where md_drop_option_id not in (223,224,225,226,227)
) t on p.id = t.practitioner_id
left join ag_acl_practitioner_subordinate_system s on s.id = p.subordinate_system_id
where s.owner_practitioner_id = #{practitionerId,jdbcType=BIGINT}
and s.is_active=1
and p.is_active=1
group by p.id
) s
LEFT JOIN
(select t.customer_id, sum(t.fyc_amount) fyc
......@@ -116,7 +116,8 @@
and #{lastDay,jdbcType=TIMESTAMP}
group by t.customer_id
) fyc
ON s.practitioner_id = fyc.customer_id
ON s.practitionerId = fyc.customer_id
ORDER BY dayScore desc, weekScore desc, monthScore desc
</select>
<select id="queryTeamAllPractitionerId" resultType="Long">
......
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