Skip to content

Y
yd-backend
Commit aa37e4b2 by jianan
Options

AGMS的N22寿险数据统计

parent 12e12970
Showing with 153 additions and 11 deletions
yd-api/src/main/java/com/yd/api/agms/service/impl/AgmsDashboardServiceImpl.java
...@@ -6,9 +6,15 @@ import com.yd.api.agms.vo.dashboard.*; ...@@ -6,9 +6,15 @@ import com.yd.api.agms.vo.dashboard.*;
import com.yd.api.result.CommonResult; import com.yd.api.result.CommonResult;
import com.yd.dal.entity.agms.dashboard.StatisticsOpportunityInfo; import com.yd.dal.entity.agms.dashboard.StatisticsOpportunityInfo;
import com.yd.dal.entity.agms.dashboard.StatisticsPEPInfo; import com.yd.dal.entity.agms.dashboard.StatisticsPEPInfo;
import com.yd.dal.entity.customer.practitioner.PractitionerRankInfo;
import com.yd.dal.entity.meta.MdDropOptions; import com.yd.dal.entity.meta.MdDropOptions;
import com.yd.dal.service.agms.AgmsDashboardDALService; import com.yd.dal.service.agms.AgmsDashboardDALService;
import com.yd.dal.service.meta.MdDropOptionsDALService; import com.yd.dal.service.meta.MdDropOptionsDALService;
import com.yd.rmi.n22.salary.pojo.Achieve;
import com.yd.rmi.n22.salary.pojo.SearchStaffAchievementRequestBody;
import com.yd.rmi.n22.salary.pojo.SearchStaffAchievementResponseVO;
import com.yd.rmi.n22.salary.service.N22SalaryService;
import com.yd.util.CommonUtil;
import com.yd.util.config.ZHBErrorConfig; import com.yd.util.config.ZHBErrorConfig;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -16,7 +22,9 @@ import org.springframework.stereotype.Service; ...@@ -16,7 +22,9 @@ import org.springframework.stereotype.Service;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.text.DecimalFormat; import java.text.DecimalFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date;
import java.util.List; import java.util.List;
import java.util.stream.Collectors;
@Service("agmsDashboardService") @Service("agmsDashboardService")
public class AgmsDashboardServiceImpl implements AgmsDashboardService { public class AgmsDashboardServiceImpl implements AgmsDashboardService {
...@@ -25,6 +33,8 @@ public class AgmsDashboardServiceImpl implements AgmsDashboardService { ...@@ -25,6 +33,8 @@ public class AgmsDashboardServiceImpl implements AgmsDashboardService {
private AgmsDashboardDALService agmsDashboardDALService; private AgmsDashboardDALService agmsDashboardDALService;
@Autowired @Autowired
private MdDropOptionsDALService mdDropOptionsDALService; private MdDropOptionsDALService mdDropOptionsDALService;
@Autowired
private N22SalaryService n22SalaryService;
@Override @Override
public StatisticsPEPResponseVO statisticsPEP(StatisticsPEPRequestVO requestVO) { public StatisticsPEPResponseVO statisticsPEP(StatisticsPEPRequestVO requestVO) {
...@@ -92,39 +102,142 @@ public class AgmsDashboardServiceImpl implements AgmsDashboardService { ...@@ -92,39 +102,142 @@ public class AgmsDashboardServiceImpl implements AgmsDashboardService {
@Override @Override
public StatisticsSalesResponseVO statisticsSales(StatisticsSalesRequestVO requestVO) { public StatisticsSalesResponseVO statisticsSales(StatisticsSalesRequestVO requestVO) {
StatisticsSalesResponseVO responseVO = new StatisticsSalesResponseVO(); StatisticsSalesResponseVO responseVO = new StatisticsSalesResponseVO();
responseVO.setCommonResult(new CommonResult(true, ZHBErrorConfig.getErrorInfo("800000")));
String category = requestVO.getCategory(); String category = requestVO.getCategory();
String time = requestVO.getTime(); String time = requestVO.getTime();
String type = requestVO.getType(); String type = requestVO.getType();
category = Strings.isNullOrEmpty(category) ? "all" : category; category = Strings.isNullOrEmpty(category) ? "all" : category;
time = Strings.isNullOrEmpty(time) ? "m" : time; time = Strings.isNullOrEmpty(time) ? "m" : time;
type = Strings.isNullOrEmpty(type) ? "b" : type; type = Strings.isNullOrEmpty(type) ? "b" : type;
List<StatisticsSalesInfo> statisticsSalesInfos; List<StatisticsSalesInfo> statisticsSalesInfos = null;
if("life".equals(category)){//寿险 try {
statisticsSalesInfos = agmsDashboardDALService.statisticsSalesEG(type,time); if ("life".equals(category)) {//寿险
}else if("pc".equals(category)){//产险 // statisticsSalesInfos = agmsDashboardDALService.statisticsSalesEG(type, time);
statisticsSalesInfos = agmsDashboardDALService.statisticsSalesYD(type,time);
}else{ // 查询N22接口获取寿险数据
statisticsSalesInfos = getAll(type,time); statisticsSalesInfos = this.statisticsSalesN22(category, type, time);
} else if ("pc".equals(category)) {//产险
statisticsSalesInfos = agmsDashboardDALService.statisticsSalesYD(type, time);
} else {
statisticsSalesInfos = getAll(category, type, time);
}
} catch (Exception e) {
e.printStackTrace();
responseVO.setCommonResult(new CommonResult(false, e.getMessage()));
} }
responseVO.setStatisticsSalesInfos(statisticsSalesInfos); responseVO.setStatisticsSalesInfos(statisticsSalesInfos);
responseVO.setCommonResult(new CommonResult(true,ZHBErrorConfig.getErrorInfo("800000")));
return responseVO; return responseVO;
} }
private List<StatisticsSalesInfo> statisticsSalesN22(String category, String type, String time) throws Exception {
// 1.根据Agent_id当前经纪人的佣金明细
SearchStaffAchievementResponseVO searchStaffAchievementResponseVO = this.queryN22(category, type, time);
if (!"查询成功".equals(searchStaffAchievementResponseVO.getResponseHead().getMessage())){
throw new Exception( "N22寿险业绩统计查询错误");
}
List<Achieve> achieveList = searchStaffAchievementResponseVO.getResponseBody().getAchieveList();
// 2.筛选结果集
if ("life".equals(category)) {
if ("t".equals(type)) {
achieveList = achieveList.stream()
.filter((Achieve i) -> "寿险团队".equals(i.getRolegrouptype()))
.collect(Collectors.toList());
} else if ("b".equals(type)) {
achieveList = achieveList.stream()
.filter((Achieve i) -> "二级机构".equals(i.getRolegrouptype()))
.collect(Collectors.toList());
}
}
System.out.println("筛选后的数据");
System.out.println(achieveList);
// 3.组装返回报文
List<StatisticsSalesInfo> infoList = new ArrayList<>();
StatisticsSalesInfo info = null;
for (Achieve achieve : achieveList) {
info = new StatisticsSalesInfo();
info.setPieces(achieve.getSucNumber());
info.setFyp(Double.toString(achieve.getFYP()));
info.setFyc(Double.toString(achieve.getFYC()));
info.setTypeName(achieve.getDescription());
infoList.add(info);
}
// 3.计算件均保费
agmsDashboardDALService.getUnitPremium(infoList);
return infoList;
}
private SearchStaffAchievementResponseVO queryN22(String category, String type, String time) {
// 1.根据查询时间范围获取查询开始时间和结束时间
String startTime;
String endTime;
if ("d".equals(time)) {
endTime = startTime = CommonUtil.dateParseString(new Date(),"yyyy-MM-dd");
} else if ("w".equals(time)) {
startTime = CommonUtil.getWeekStart();
endTime = CommonUtil.getWeekEnd();
} else if ("m".equals(time)) {
startTime = CommonUtil.getBeginDayOfMonth();
endTime = CommonUtil.getEndDayOfMonth();
} else if ("q".equals(time)) {
startTime = CommonUtil.getStartOrEndDayOfQuarter(true);
endTime = CommonUtil.getStartOrEndDayOfQuarter(false);
} else {
startTime = CommonUtil.getBeginDayOfYear();
endTime = CommonUtil.getEndDayOfYear();
}
SearchStaffAchievementRequestBody searchStaffAchievementRequestBody = new SearchStaffAchievementRequestBody();
searchStaffAchievementRequestBody.setIssuedatestart(startTime);
searchStaffAchievementRequestBody.setIssuedateend(endTime);
searchStaffAchievementRequestBody.setPolicystatus("201");
if ("life".equals(category)) {
if ("b".equals(type)) {
searchStaffAchievementRequestBody.setSearchtype("3");
searchStaffAchievementRequestBody.setIsdown("0");
} else {
searchStaffAchievementRequestBody.setSearchtype("2");
searchStaffAchievementRequestBody.setIsdown("0");
}
} else if ("all".equals(category)) {
searchStaffAchievementRequestBody.setOrganization_id("HX6ZCQ");
searchStaffAchievementRequestBody.setSearchtype("3");
searchStaffAchievementRequestBody.setIsdown("1");
}
return n22SalaryService.searchStaffAchievement(searchStaffAchievementRequestBody);
}
/** /**
* dashBoard -- 寿险+产险销售统计 * dashBoard -- 寿险+产险销售统计
* @param type 类型 * @param type 类型
* @param time 时间 * @param time 时间
* @return 数据 * @return 数据
*/ */
private List<StatisticsSalesInfo> getAll(String type, String time) { private List<StatisticsSalesInfo> getAll(String category, String type, String time) throws Exception {
StatisticsSalesInfo statisticsSalesInfo = new StatisticsSalesInfo(); StatisticsSalesInfo statisticsSalesInfo = new StatisticsSalesInfo();
List<StatisticsSalesInfo> statisticsSalesInfos = new ArrayList<>(); List<StatisticsSalesInfo> statisticsSalesInfos = new ArrayList<>();
String unitPremium = "0"; String unitPremium = "0";
double fyp = 0D,fyc = 0D; double fyp = 0D,fyc = 0D;
Integer pieces = 0; Integer pieces = 0;
List<StatisticsSalesInfo> statisticsSalesInfosLife = agmsDashboardDALService.statisticsSalesEG(type,time); // List<StatisticsSalesInfo> statisticsSalesInfosLife = agmsDashboardDALService.statisticsSalesEG(type,time);
// 查询N22接口获取寿险数据
List<StatisticsSalesInfo> statisticsSalesInfosLife = this.statisticsSalesN22(category, type, time);
List<StatisticsSalesInfo> statisticsSalesInfosPC = agmsDashboardDALService.statisticsSalesYD(type,time); List<StatisticsSalesInfo> statisticsSalesInfosPC = agmsDashboardDALService.statisticsSalesYD(type,time);
statisticsSalesInfosLife.addAll(statisticsSalesInfosPC); statisticsSalesInfosLife.addAll(statisticsSalesInfosPC);
if(statisticsSalesInfosLife.size() > 0){ if(statisticsSalesInfosLife.size() > 0){
for(StatisticsSalesInfo item : statisticsSalesInfosLife){ for(StatisticsSalesInfo item : statisticsSalesInfosLife){
......
yd-api/src/main/java/com/yd/dal/service/agms/AgmsDashboardDALService.java
...@@ -20,4 +20,6 @@ public interface AgmsDashboardDALService { ...@@ -20,4 +20,6 @@ public interface AgmsDashboardDALService {
List<StatisticsSalesInfo> statisticsSalesEG(String type, String time); List<StatisticsSalesInfo> statisticsSalesEG(String type, String time);
List<PersonalOffLineFYC> offLineFYC(List<String> mobileNoList); List<PersonalOffLineFYC> offLineFYC(List<String> mobileNoList);
void getUnitPremium(List<StatisticsSalesInfo> statisticsSalesInfos);
} }
yd-api/src/main/java/com/yd/dal/service/agms/impl/AgmsDashboardDALServiceImpl.java
...@@ -101,7 +101,8 @@ public class AgmsDashboardDALServiceImpl implements AgmsDashboardDALService { ...@@ -101,7 +101,8 @@ public class AgmsDashboardDALServiceImpl implements AgmsDashboardDALService {
* 获取均件保费 * 获取均件保费
* @param statisticsSalesInfos * @param statisticsSalesInfos
*/ */
private void getUnitPremium(List<StatisticsSalesInfo> statisticsSalesInfos) { @Override
public void getUnitPremium(List<StatisticsSalesInfo> statisticsSalesInfos) {
if(statisticsSalesInfos != null && statisticsSalesInfos.size() > 0){ if(statisticsSalesInfos != null && statisticsSalesInfos.size() > 0){
String fyp; String fyp;
Integer pieces; Integer pieces;
......
yd-api/src/main/java/com/yd/rmi/n22/salary/pojo/Achieve.java
...@@ -8,6 +8,8 @@ public class Achieve { ...@@ -8,6 +8,8 @@ public class Achieve {
private String Description; private String Description;
private String Rolegrouptype;
private String SearchType; private String SearchType;
private Double FYC; private Double FYC;
......
yd-api/src/main/java/com/yd/util/CommonUtil.java
...@@ -1629,4 +1629,28 @@ public class CommonUtil { ...@@ -1629,4 +1629,28 @@ public class CommonUtil {
return dayBefore; return dayBefore;
} }
/**
* 获取本周的第一天
* @return String
* **/
public static String getWeekStart() {
Calendar cal = Calendar.getInstance();
cal.add(Calendar.WEEK_OF_MONTH, 0);
cal.set(Calendar.DAY_OF_WEEK, 2);
Date time = cal.getTime();
return new SimpleDateFormat("yyyy-MM-dd").format(time);
}
/**
* 获取本周的最后一天
* @return String
* **/
public static String getWeekEnd() {
Calendar cal = Calendar.getInstance();
cal.set(Calendar.DAY_OF_WEEK, cal.getActualMaximum(Calendar.DAY_OF_WEEK));
cal.add(Calendar.DAY_OF_WEEK, 1);
Date time = cal.getTime();
return new SimpleDateFormat("yyyy-MM-dd").format(time);
}
} }
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