//package com.cyksj.task;
//
//import cn.hutool.core.date.DateTime;
//import cn.hutool.core.date.DateUtil;
//import cn.hutool.core.util.StrUtil;
//import com.cyksj.common.constant.Constant;
//import com.cyksj.mapper.manage.CustomerServiceEveryMonthDetailMapper;
//import com.cyksj.mapper.manage.StatisticsCustomerServiceEveryMonthMapper;
//import com.cyksj.model.entity.CustomerServiceEveryMonthDetail;
//import com.cyksj.model.entity.CustomerServiceRenewOrderRecord;
//import com.cyksj.model.entity.RealGoodsOrderHandle;
//import com.cyksj.model.entity.StatisticsCustomerServiceEveryMonth;
//import com.ejlchina.searcher.BeanSearcher;
//import com.ejlchina.searcher.param.Operator;
//import com.ejlchina.searcher.util.MapUtils;
//import com.google.common.util.concurrent.AtomicDouble;
//import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Component;
//
//import java.math.BigDecimal;
//import java.util.List;
//import java.util.Map;
//import java.util.Optional;
//import java.util.stream.Collectors;
//
///*
// *项目名: netflix
// *文件名: OrderCustomerHandleScheduler
// *创建者: JavaZou
// *创建时间:2022/11/29 16:44
// */
//@Component
//@Slf4j
//@RequiredArgsConstructor
//public class OrderCustomerHandleScheduler {
//	private final CustomerServiceEveryMonthDetailMapper detailMapper;
//
//	private final StatisticsCustomerServiceEveryMonthMapper statisticsEveryMonthMapper;
//
//	private final BeanSearcher beanSearcher;
//
//	/**
//	 * 客服业绩数据统计
//	 */
//	@Scheduled(cron = "59 59 23 L * ?")
//	public void orderCustomerHandle() {
//		DateTime now = DateTime.now();
//		DateTime begin = DateUtil.beginOfMonth(now);
//		String statisticsDate = DateUtil.format(now, "yyyy-MM");
//		List<RealGoodsOrderHandle> realGoodsOrderHandles = beanSearcher.searchAll(RealGoodsOrderHandle.class, MapUtils.builder()
//				.field(RealGoodsOrderHandle::getStatus, Constant.noOrderAllStatus).op(Operator.NotIn)
//				.field(RealGoodsOrderHandle::getCreatedTime, begin, now).op(Operator.Between)
//				.build());
//		Map<String, List<RealGoodsOrderHandle>> before = realGoodsOrderHandles.stream().collect(Collectors.groupingBy(RealGoodsOrderHandle::getBeforeServiceName));
//		Map<String, List<RealGoodsOrderHandle>> after = realGoodsOrderHandles.stream().collect(Collectors.groupingBy(RealGoodsOrderHandle::getAfterServiceName));
//		StatisticsCustomerServiceEveryMonth statistics = new StatisticsCustomerServiceEveryMonth();
//		statistics.setStatisticsData(statisticsDate);
//		statisticsEveryMonthMapper.insert(statistics);
//		before.forEach((k, v) -> {
//			customerServiceRecord(k, v, 1, statistics.getId());
//		});
//		after.forEach((k, v) -> {
//			customerServiceRecord(k, v, 2, statistics.getId());
//		});
//		//续费业绩
//		List<CustomerServiceRenewOrderRecord> customerServiceRecords = beanSearcher.searchAll(CustomerServiceRenewOrderRecord.class, MapUtils.builder()
//				.field(RealGoodsOrderHandle::getCreatedTime, begin, now).op(Operator.Between)
//				.build());
//		Map<String, List<CustomerServiceRenewOrderRecord>> renews = customerServiceRecords.stream().collect(Collectors.groupingBy(CustomerServiceRenewOrderRecord::getCustomerService));
//		renews.forEach((k,v)->{
//			renewServiceOrderRecord(k, v, 3, statistics.getId());
//		});
//	}
//
//
//	public void customerServiceRecord(String serviceName, List<RealGoodsOrderHandle> handlers, Integer type, Long statisticsId) {
//		if (StrUtil.isNotBlank(serviceName)) {
//			CustomerServiceEveryMonthDetail record = new CustomerServiceEveryMonthDetail();
//			record.setType(type);
//			record.setCustomerServiceName(serviceName);
//			record.setStatisticsId(statisticsId);
//			AtomicDouble numOfOrder = new AtomicDouble(0);
//			handlers.forEach(handler -> {
//				if ("red_book".equals(handler.getLabelSource())) {
//					numOfOrder.addAndGet(1.5);
//					return;
//				}
//				numOfOrder.addAndGet(1);
//			});
//			record.setNumOfOrder(BigDecimal.valueOf(numOfOrder.doubleValue()));
//			Optional<BigDecimal> money = handlers.stream().map(RealGoodsOrderHandle::getMoney).reduce(BigDecimal::add);
//			record.setMoney(money.isPresent() ? money.get() : BigDecimal.ZERO);
//			detailMapper.insert(record);
//		}
//	}
//
//	public void renewServiceOrderRecord(String serviceName, List<CustomerServiceRenewOrderRecord> renewOrderRecords, Integer type, Long statisticsId) {
//		if (StrUtil.isNotBlank(serviceName)) {
//			CustomerServiceEveryMonthDetail record = new CustomerServiceEveryMonthDetail();
//			record.setType(type);
//			record.setCustomerServiceName(serviceName);
//			record.setStatisticsId(statisticsId);
//			record.setNumOfOrder(BigDecimal.valueOf(renewOrderRecords.size()));
//			record.setMoney(BigDecimal.ZERO);
//			detailMapper.insert(record);
//		}
//	}
//}