package com.xzx.gc.user.service;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.StrUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.Result;
import com.xzx.gc.common.constant.CommonEnum;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.constant.UserEnum;
import com.xzx.gc.common.dto.gdmap.GdReverseGEODto;
import com.xzx.gc.common.exception.RestException;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.common.utils.gdmap.GdMapUtil;
import com.xzx.gc.entity.*;
import com.xzx.gc.model.admin.TargetUserModel;
import com.xzx.gc.model.order.FenceDto;
import com.xzx.gc.model.order.OrderInfoVo;
import com.xzx.gc.user.dto.*;
import com.xzx.gc.user.mapper.AddressMapper;
import com.xzx.gc.user.mapper.UserTargetInfoMapper;
import org.apache.commons.lang3.StringUtils;
import org.locationtech.spatial4j.context.SpatialContext;
import org.locationtech.spatial4j.distance.DistanceUtils;
import org.locationtech.spatial4j.shape.Rectangle;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import tk.mybatis.mapper.entity.Example;

import javax.servlet.http.HttpServletRequest;
import java.util.*;
import java.util.stream.Collectors;

@Service
@Transactional
public class UserTargetInfoService {

    @Autowired
    private UserTargetInfoMapper userTargetInfoMapper;

    @Autowired
    private AddressMapper addressMapper;

    @Autowired
    private UserService userService;

    @Autowired
    private BusinessUtil businessUtil;

    @Autowired
    private HttpServletRequest request;

    @Autowired
    private OtherUserService otherUserService;

    @Autowired
    private OrderService orderService;

    @Autowired
    private AddressService addressService;


    @Autowired
    private FenceService fenceService;

    @Autowired
    private AddressLevelService addressLevelService;
    @Autowired
    private PartnerGaodeService partnerGaodeService;

    public void add(UserTargetInfo userTargetInfo) {
        userTargetInfo.setCreateTime(DateUtil.now());
        userTargetInfo.setDelFlag(0);
        userTargetInfoMapper.insertSelective(userTargetInfo);
    }


    public UserTargetInfo findByMobileAndUserId(String mobile, String userId) {
        UserTargetInfo userTargetInfo = new UserTargetInfo();
        userTargetInfo.setMobile(mobile);
        userTargetInfo.setUserId(userId);
        UserTargetInfo userTargetInfo1 = userTargetInfoMapper.selectOne(userTargetInfo);
        return userTargetInfo1;
    }



    public List<UserTargetInfo> findByMobile(String mobile) {
        UserTargetInfo userTargetInfo = new UserTargetInfo();
        userTargetInfo.setMobile(mobile);
        List<UserTargetInfo> userTargetInfo1 = userTargetInfoMapper.select(userTargetInfo);
        if (!CollectionUtils.isEmpty(userTargetInfo1)) {
            List<UserTargetInfo> collect = userTargetInfo1.stream().sorted(Comparator.comparing(UserTargetInfo::getCreateTime).reversed()).collect(Collectors.toList());
            return collect;
        }
        return userTargetInfo1;
    }


    public PageInfo<UserTargetInfo> find(UserTargetInfoFindDto userTargetInfoFindDto) {
        String userId = userTargetInfoFindDto.getUserId();
        List<UserTargetInfo> userTargetInfo1 = null;
        String loginUserId = request.getHeader("userId");
        String partnerId1 = otherUserService.findById(loginUserId).getPartnerId();
        userTargetInfoFindDto.setPartnerId(partnerId1);
        userTargetInfoFindDto.setLoginUserId(loginUserId);

        PageHelper.startPage(userTargetInfoFindDto.getPageNo(), userTargetInfoFindDto.getPageSize());
        userTargetInfo1 = userTargetInfoMapper.findPage(userTargetInfoFindDto);


        if (!CollectionUtils.isEmpty(userTargetInfo1)) {
            for (UserTargetInfo userTargetInfo : userTargetInfo1) {
                //如果是运营员 则不脱敏 否则若推广员或录入员是自己则不将手机号脱敏显示

                String realUserId = userTargetInfo.getRealUserId();
                String userId1 = userTargetInfo.getUserId();


                //已成交
                if (3 == userTargetInfo.getRegsterType()) {
                    UserInfo byMobile = userService.findByMobile(userTargetInfo.getMobile());
                    if (byMobile != null) {
                        //回收的累计重量
                        RecycleStatistic orderItemInfo = null;
                        orderItemInfo = orderService.findOrderItemInfo(byMobile.getUserId(), 1);

                        if (orderItemInfo != null) {
                            userTargetInfo.setSumWeight(businessUtil.changeWeight(orderItemInfo.getWeightAll()));
                            userTargetInfo.setSumWeightDouble(Convert.toDouble(businessUtil.changeWeight(orderItemInfo.getWeightAll())));
                        } else {
                            userTargetInfo.setSumWeight(Constants.WEIGHT_INIT.toString());
                        }

                        //上次成交的时间
                        List<OrderInfoVo> lastTimeBycreateUserId = orderService.findLastTimeBycreateUserId(byMobile.getUserId());
                        if (CollUtil.isNotEmpty(lastTimeBycreateUserId)) {
                            String completeTime = lastTimeBycreateUserId.get(0).getCompleteTime();
                            if (StrUtil.isNotBlank(completeTime)) {
                                String s = DateUtil.parseDate(completeTime).toString();
                                userTargetInfo.setLastTime(s);
                            }
                        }
                    } else {
                        userTargetInfo.setSumWeight(Constants.WEIGHT_INIT.toString());
                    }
                    //以下为了排序使用
                } else if (2 == userTargetInfo.getRegsterType()) {
                    userTargetInfo.setSumWeight("-1");
                    userTargetInfo.setSumWeightDouble(Convert.toDouble(-1));
                } else {
                    userTargetInfo.setSumWeight("-2");
                    userTargetInfo.setSumWeightDouble(Convert.toDouble(-2));
                }

                //判断当前用户是否自己推广
                String queryUserId = StrUtil.isNotBlank(realUserId) ? realUserId : userId1;
                if (loginUserId.equals(queryUserId)) {
                    userTargetInfo.setIsMe(true);
                } else {
                    OtherUserInfo otherUserInfo = otherUserService.findById(queryUserId);
                    if (otherUserInfo != null) {
                        userTargetInfo.setRealUserName(otherUserInfo.getName());
                    }
                    userTargetInfo.setIsMe(false);
                }


                if (!CommonEnum.运营员.getValue().equals(userTargetInfoFindDto.getUserType())) {

                    if (!loginUserId.equals(userId1) && !loginUserId.equals(realUserId)) {
                        String replace = businessUtil.changeMobile(userTargetInfo.getMobile());
                        userTargetInfo.setMobile(replace);
                    }
                }

            }

            if ("4".equals(userTargetInfoFindDto.getOrderType())) {
                userTargetInfo1 = userTargetInfo1.stream().sorted(Comparator.comparingDouble(UserTargetInfo::getSumWeightDouble).reversed()).collect(Collectors.toList());
                for (UserTargetInfo userTargetInfo : userTargetInfo1) {
                    if (userTargetInfo.getSumWeight().equals("-1") || userTargetInfo.getSumWeight().equals("-2")) {
                        userTargetInfo.setSumWeight(Constants.WEIGHT_INIT.toString());
                    }
                }
            }


            //置顶
            List<UserTargetInfo> list = new ArrayList<>();
            for (UserTargetInfo userTargetInfo : userTargetInfo1) {
                String topFlagUser = userTargetInfo.getTopFlagUser();
                if (StrUtil.isNotBlank(topFlagUser) && topFlagUser.equals(loginUserId)) {
                    list.add(userTargetInfo);
                }
            }
            if (CollUtil.isNotEmpty(list)) {
                for (UserTargetInfo userTargetInfo : userTargetInfo1) {
                    String topFlagUser = userTargetInfo.getTopFlagUser();
                    if (StrUtil.isBlank(topFlagUser) || !topFlagUser.equals(loginUserId)) {
                        userTargetInfo.setTopFlag(Convert.toShort(0));
                        list.add(userTargetInfo);
                    }
                }
                userTargetInfo1 = list;
            } else {
                for (UserTargetInfo userTargetInfo : userTargetInfo1) {
                    String topFlagUser = userTargetInfo.getTopFlagUser();
                    if (StrUtil.isBlank(topFlagUser) || !topFlagUser.equals(loginUserId)) {
                        userTargetInfo.setTopFlag(Convert.toShort(0));
                    }
                }
            }
        }


        PageInfo<UserTargetInfo> pageInfo = new PageInfo<>(userTargetInfo1);
        return pageInfo;
    }


    public void update(UserTargetInfo userTargetInfo) {
        userTargetInfoMapper.updateByPrimaryKeySelective(userTargetInfo);
    }


    public UserTargetInfoStatisticResDto statistic(UserTargetInfoStatisticDto userTargetInfoStatisticDto) {
        UserTargetInfoStatisticResDto userTargetInfoStatisticResDto = new UserTargetInfoStatisticResDto();
        Example example = new Example(UserTargetInfo.class);
        example.createCriteria().andEqualTo("userId", userTargetInfoStatisticDto.getUserId());
        List<UserTargetInfo> userTargetInfos = userTargetInfoMapper.selectByExample(example);
        if (!CollectionUtils.isEmpty(userTargetInfos)) {
            userTargetInfoStatisticResDto.setNoRegisters(userTargetInfos.stream().filter(x -> x.getRegsterType() == 1).count());
            userTargetInfoStatisticResDto.setNoOrders(userTargetInfos.stream().filter(x -> x.getRegsterType() == 2 && (x.getUserId() != null && x.getUserId().equals(userTargetInfoStatisticDto.getUserId()))).count());
            userTargetInfoStatisticResDto.setOrders(userTargetInfos.stream().filter(x -> x.getRegsterType() == 3 && (x.getRealUserId() != null && x.getRealUserId().equals(userTargetInfoStatisticDto.getUserId()))).count());
            userTargetInfoStatisticResDto.setSum(userTargetInfoStatisticResDto.getNoOrders() + userTargetInfoStatisticResDto.getOrders());
        }
        return userTargetInfoStatisticResDto;

    }


    public void acode(UserTargetInfo userTargetInfo) {
        List<UserTargetInfo> byMobile = findByMobile(userTargetInfo.getMobile());
        if (CollectionUtils.isEmpty(byMobile)) {
            userTargetInfo.setRegsterType(Convert.toInt(UserEnum.已注册.getValue()));
            userTargetInfo.setRealUserId(userTargetInfo.getUserId());
            add(userTargetInfo);
        } else {
            //如果存在的同手机号已经被人推广了，则不做处理。
            long count = byMobile.stream().filter(x -> x.getRealUserId() != null).count();
            if (count == 0) {
                UserTargetInfo userTargetInfo1 = new UserTargetInfo();
                userTargetInfo1.setRegsterType(Convert.toInt(UserEnum.已注册.getValue()));
                userTargetInfo1.setRealUserId(userTargetInfo.getUserId());
                Example example = new Example(UserTargetInfo.class);
                example.createCriteria().andEqualTo("mobile", userTargetInfo.getMobile());
                userTargetInfoMapper.updateByExampleSelective(userTargetInfo1, example);
            }
        }
    }


    public void updateTargetUserAddr(AddressInfo addressInfo) {
        UserInfo byId = userService.findById(addressInfo.getUserId());
        UserTargetInfo userTargetInfo1 = new UserTargetInfo();
        //赋值
        userTargetInfo1.setLatitude(addressInfo.getLatitude());
        userTargetInfo1.setLongitude(addressInfo.getLongitude());
        userTargetInfo1.setAddressArea(addressInfo.getAddressArea());
        userTargetInfo1.setDetailAddress(addressInfo.getDetailAddress());
        userTargetInfo1.setProvinceId(addressInfo.getProvinceId());
        userTargetInfo1.setCityId(addressInfo.getCityId());
        userTargetInfo1.setTownshipId(addressInfo.getTownshipId());

        Example example = new Example(UserTargetInfo.class);
        example.createCriteria().andEqualTo("mobile", byId.getMobilePhone());
        userTargetInfoMapper.updateByExampleSelective(userTargetInfo1, example);

    }


    public void updateTargetUserLon(String mobile, String lon, String lan) {
        UserTargetInfo userTargetInfo1 = new UserTargetInfo();
        userTargetInfo1.setLatitude(lan);
        userTargetInfo1.setLongitude(lon);
        Example example = new Example(UserTargetInfo.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("mobile", mobile);
        criteria.andIsNull("longitude");
        userTargetInfoMapper.updateByExampleSelective(userTargetInfo1, example);

    }

    /**
     * 查询当前推广员成交的用户
     *
     * @param userId
     * @return
     */

    public List<UserTargetInfo> findOrderUser(String userId, String partnerId) {
        return userTargetInfoMapper.recommend(userId, partnerId);
    }


    public List<UserInfo> map(UserTargetInfoMapDto userTargetInfoMapDto) {
        //判断当前用户所在的区域 和 当前所属合伙人的区域是否一致
        String userId = request.getHeader("userId");
        String partnerId1 = otherUserService.findById(userId).getPartnerId();
        GdReverseGEODto gdReverseGEODto = new GdReverseGEODto();
        gdReverseGEODto.setLocation(userTargetInfoMapDto.getLongitude() + "," + userTargetInfoMapDto.getLatitude());
        Result areaInfo = GdMapUtil.getAreaInfo(gdReverseGEODto, 0);
        if (areaInfo.getCode() == 0) {
            AddressInfo addressInfo1 = (AddressInfo) areaInfo.getData();
            AddressLevelInfo addressLevelInfo1 = addressLevelService.findByAdcode(addressInfo1.getAdcode());
            if (addressLevelInfo1 != null) {
                String level3Id = addressLevelInfo1.getLevel3Id();
                FenceDto fence = fenceService.getFence(level3Id, false, userTargetInfoMapDto.getLongitude(), userTargetInfoMapDto.getLatitude(), false);
                if(StrUtil.isBlank(fence.getFenceId())||!fence.getPartnerId().equals(partnerId1)){
                    throw new RestException(-1, "您已超出当前运营区域范围");
                }
            } else {
                throw new RestException(-1, "基础数据异常，未查询到当前区域：" + addressInfo1.getAdcode());
            }
        } else {
            throw new RestException(-1, "定位异常");
        }

        List<UserInfo> list = userService.findByDistance();
        List<UserInfo> resList = new ArrayList<>();
        if (CollUtil.isNotEmpty(list)) {
            //如果当前合伙人不是天心区 则将无合伙人的用户删除
            if (!Constants.DEFAULT_PARTNER_ID.equals(partnerId1)) {
                list.removeIf(x -> StrUtil.isBlank(x.getPartnerId()));
            }
            double lon = Convert.toDouble(userTargetInfoMapDto.getLongitude());
            double lat = Convert.toDouble(userTargetInfoMapDto.getLatitude());
            //单位千米
            double radius = 0.5;
            SpatialContext geo = SpatialContext.GEO;
            Rectangle rectangle = geo.getDistCalc().calcBoxByDistFromPt(geo.makePoint(lon, lat), radius * DistanceUtils.KM_TO_DEG, geo, null);
            //筛选附近0.5公里的
            for (Iterator<UserInfo> iterator = list.iterator(); iterator.hasNext(); ) {
                UserInfo userInfo = iterator.next();
                if(StrUtil.isNotBlank(userInfo.getLatitude())) {
                    double latitude = Convert.toDouble(userInfo.getLatitude(), Convert.toDouble(0));
                    double longitude = Convert.toDouble(userInfo.getLongitude(), Convert.toDouble(0));
                    if (NumberUtil.compare(latitude, rectangle.getMinY()) < 0) {
                        iterator.remove();
                    } else if (NumberUtil.compare(latitude, rectangle.getMaxY()) > 0) {
                        iterator.remove();
                    } else if (NumberUtil.compare(longitude, rectangle.getMinX()) < 0) {
                        iterator.remove();
                    } else if (NumberUtil.compare(longitude, rectangle.getMaxX()) > 0) {
                        iterator.remove();
                    }
                }
            }


            //进行分页
            int currentPageNo = userTargetInfoMapDto.getPageNo() - 1;

            while (true) {

                //是否结束循环
                boolean isOver = false;
                List<UserInfo> pageList = null;
                try {
                    pageList = new ArrayList<>(CollUtil.page(currentPageNo, userTargetInfoMapDto.getPageSize(), list));
                } catch (Exception e) {
                    return CollUtil.newArrayList();
                }

                //最后一页的数据
                if (pageList.size() < userTargetInfoMapDto.getPageSize()) {
                    isOver = true;
                }

                //筛选是属于当前合伙人的用户
                for (Iterator<UserInfo> iterator = pageList.iterator(); iterator.hasNext(); ) {
                    if (resList.size() == userTargetInfoMapDto.getPageSize()) {
                        isOver = true;
                        break;
                    }



                    UserInfo userInfo = iterator.next();

                    String partnerId = userInfo.getPartnerId();


                    if((Constants.DEFAULT_PARTNER_ID.equals(partnerId1)&&StrUtil.isBlank(partnerId))||partnerId.equals(partnerId1)){
                        resList.add(userInfo);
                    }else {
                        iterator.remove();
                    }
                }

                if (isOver) {
                    break;
                } else {
                    currentPageNo++;
                }

            }


            //设置用户状态
            for (UserInfo userInfo : resList) {
                int byCreateTime = orderService.findByCreateTime(userInfo.getUserId(), null, -1);
                if (byCreateTime > 0) {
                    userInfo.setRegsterType(Convert.toInt(UserEnum.已成交.getValue()));
                } else {
                    userInfo.setRegsterType(Convert.toInt(UserEnum.已注册.getValue()));
                }
            }
        }

        return resList;
    }


    public Map<String, Object> queryList(TargetUserModel model){
        if(!StringUtils.isEmpty(model.getRegsterType()) && model.getRegsterType().equals("2")){
            model.setRegsterType1("3");
        }
        Map<String, Object> m = new HashMap<>();
        PageHelper.startPage(model.getPage(),model.getLimit());
        List<TargetUserModel> list = userTargetInfoMapper.queryList(model);
        PageInfo<TargetUserModel> pageInfo=new PageInfo<>(list);
        m.put("data",list);
        m.put("count",pageInfo.getTotal());
        m.put("code", 0);
        return  m;
    }
    public Map<String, Object> queryListMap(TargetUserModel model){
        if(!StringUtils.isEmpty(model.getRegsterType()) && model.getRegsterType().equals("2")){
            model.setRegsterType1("3");
        }
        Map<String, Object> m = new HashMap<>();
        List<TargetUserModel> list = userTargetInfoMapper.queryList(model);
        List<TargetUserModel> userList = userTargetInfoMapper.queryUser();

        for(TargetUserModel tum : userList){
            if(StringUtils.isEmpty(tum.getOrderId())){
                tum.setRegsterType("2");
            }else{
                tum.setRegsterType("3");
            }
        }

        Map<String, TargetUserModel> mx = new HashMap<>();
        for(TargetUserModel tum : list){
            mx.put(tum.getMobile(), tum);
        }
        for (TargetUserModel tum : userList){
            mx.put(tum.getMobile(), tum);
        }

        Collection<TargetUserModel> valueCollection2 = mx.values();
        List<TargetUserModel> valueList= new ArrayList<TargetUserModel>(valueCollection2);//map转list

        m.put("data",valueList);
        m.put("count",valueList.size());
        m.put("regCount",userList.size());
        m.put("code", 0);
        return  m;
    }
}