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.StrUtil;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.constant.OrderEnum;
import com.xzx.gc.common.constant.SmsConstant;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.common.utils.IdUtils;
import com.xzx.gc.common.utils.StringUtils;
import com.xzx.gc.common.utils.ali.SmsUtil;
import com.xzx.gc.entity.*;
import com.xzx.gc.model.IdDTO;
import com.xzx.gc.model.system.ItemUserListDTO;
import com.xzx.gc.model.system.ItemUserListResDTO;
import com.xzx.gc.model.user.UserScrapStoreListParamDTO;
import com.xzx.gc.model.user.UserScrapSubscribeParamDTO;
import com.xzx.gc.user.mapper.OrderAppraiseInfoMapper;
import com.xzx.gc.user.mapper.OrderDetailMapper;
import com.xzx.gc.user.mapper.UserScrapStoreMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import tk.mybatis.mapper.entity.Example;

import java.util.*;
import java.util.stream.Collectors;

@Service
@Transactional
public class UserScrapStoreService {


    @Autowired
    private UserScrapStoreMapper userScrapStoreMapper;

    @Autowired
    private UserService userService;

    @Autowired
    private OrderAppraiseInfoMapper orderAppraiseInfoMapper;

    @Autowired
    private OrderService orderService;

    @Autowired
    private IdUtils idUtils;

    @Autowired
    private OrderDetailMapper orderDetailMapper;

    @Autowired
    private SysItemUserService sysItemUserService;

    @Autowired
    private SysEnvironmentalInfoService sysEnvironmentalInfoService;

    @Autowired
    private BusinessUtil businessUtil;

    @Autowired
    private AddressLevelService addressLevelService;

    public UserScrapStore findByMobile(String mobile) {
        UserScrapStore userScrapStore = new UserScrapStore();
        userScrapStore.setMobilePhone(mobile);
        userScrapStore.setDelFlag(Convert.toShort(Constants.DEL_NOT_FLAG));
        return userScrapStoreMapper.selectOne(userScrapStore);
    }

    public UserScrapStore findById(String id) {
        return userScrapStoreMapper.selectByPrimaryKey(id);
    }

    public void add(UserScrapStore userScrapStore) {
        userScrapStore.setDelFlag(Convert.toShort(Constants.DEL_NOT_FLAG));
        userScrapStore.setCreateTime(DateUtil.now());
        userScrapStoreMapper.insertSelective(userScrapStore);
    }

    public List<UserScrapStore> list(UserScrapStoreListParamDTO userScrapStoreListParamDTO) {
        List<UserScrapStore> list = userScrapStoreMapper.list(userScrapStoreListParamDTO);
        //关联了订单 一定会有部分数据 进行特殊处理
        long count = list.stream().filter(x -> StrUtil.isNotBlank(x.getId())).count();
        if (count > 0) {
            for (UserScrapStore userScrapStore : list) {
                //满意度
                Example example = new Example(OrderAppraiseInfo.class);
                Example.Criteria criteria = example.createCriteria();
                criteria.andEqualTo("delFlag", Convert.toShort(Constants.DEL_NOT_FLAG));
                criteria.andEqualTo("receiverId", userScrapStore.getId());
                List<OrderAppraiseInfo> orderAppraiseInfos = orderAppraiseInfoMapper.selectByExample(example);
                if (CollUtil.isNotEmpty(orderAppraiseInfos)) {
                    double sum = orderAppraiseInfos.stream().mapToDouble(x -> Convert.toDouble(x.getStar(), Convert.toDouble(Constants.SCORE_MAX))).sum();
                    userScrapStore.setSatisfaction(Convert.toInt(sum / (orderAppraiseInfos.size() * Constants.SCORE_MAX) * 100));
                }

                //区域名称
                AddressLevelInfo addressLevelInfo = addressLevelService.find(userScrapStore.getProvinceId(), userScrapStore.getCityId(), userScrapStore.getTownshipId());
                if(addressLevelInfo!=null){
                    userScrapStore.setTownshipName(addressLevelInfo.getLevel3Name());
                }
            }
            return list;
        }else {
            return new ArrayList<>();
        }
    }


    /**
     * 预约
     */
    public void subscribe(UserScrapSubscribeParamDTO scrapSubscribeParamDTO) {

        //废品站ID
        String id = scrapSubscribeParamDTO.getId();
        UserScrapStore byId = findById(id);
        UserInfo userInfo = userService.findById(scrapSubscribeParamDTO.getUserId());

        //新建个订单并完成状态
        OrderInfo orderInfo = new OrderInfo();
        String orderId = idUtils.generate("DD", 1);
        orderInfo.setOrderId(orderId);
        orderInfo.setAddress(byId.getDetailAddress());
        orderInfo.setOrderStatus(OrderEnum.完成.getValue());
        orderInfo.setOrderType(OrderEnum.废品站.getValue());
        orderInfo.setAddressArea(byId.getAddressArea());
        orderInfo.setCreateUserId(scrapSubscribeParamDTO.getUserId());
        orderInfo.setCreateTime(DateUtil.now());
        orderInfo.setRelaName(StringUtils.decode(userInfo.getNickName()));
        orderInfo.setRelaPhone(userInfo.getMobilePhone());
        orderInfo.setLatitude(userInfo.getLatitude());
        orderInfo.setLongitude(userInfo.getLongitude());
        orderInfo.setCreateType(Convert.toShort(1));
        orderInfo.setScrapId(id);
        orderService.add(orderInfo);

        OrderDetailInfo orderDetailInfo = new OrderDetailInfo();
        orderDetailInfo.setOrderId(orderId);
        orderDetailInfo.setCreateUserName(StringUtils.decode(userInfo.getNickName()));
        orderDetailInfo.setMobilePhone(userInfo.getMobilePhone());
        orderDetailInfo.setReceiverName(byId.getStoreName());
        orderDetailInfo.setReceiverPhone(byId.getMobilePhone());
        orderDetailInfo.setCompleteTime(DateUtil.now());
        orderDetailMapper.insertSelective(orderDetailInfo);

        //发送给废品站短信
        Map<String, Object> map = new HashMap<>();
        map.put("name", byId.getStoreName());
        String content = StrUtil.format("你好，{name}，收到送货上门订单，请注意查收。", map);
        SmsUtil.sendPoint(byId.getMobilePhone(), content);

    }


    /**
     * 显示废品站价格列表
     *
     * @param itemUserListDTO
     * @return
     */
    public List<ItemUserListResDTO> itemUserList(ItemUserListDTO itemUserListDTO) {
        List<ItemUserListResDTO> list = new ArrayList<>();
        UserScrapStore byId = findById(itemUserListDTO.getUserId());
        List<SysItemUser> byUserId = sysItemUserService.findByUserId(itemUserListDTO.getUserId());
        for (Iterator<SysItemUser> iterator = byUserId.iterator(); iterator.hasNext(); ) {
            SysItemUser next = iterator.next();
            SysEnvironmentalInfo byCityAndItemType = sysEnvironmentalInfoService.findByItemTypeAndAreaNotDel(next.getItemType(), Convert.toInt(byId.getTownshipId()));
            if (byCityAndItemType == null) {
                iterator.remove();
            } else {

                next.setPicture(byCityAndItemType.getPicture());
                next.setTitle(byCityAndItemType.getTitle());
                //平台价格
                next.setPrice(businessUtil.changeMoney(byCityAndItemType.getPrice()));

                //用父类分类包裹
                SysEnvironmentalInfo parent = sysEnvironmentalInfoService.findById(byCityAndItemType.getParentId());
                Long id = parent.getId();
                long count = list.stream().filter(x -> x.getId().equals(id)).count();
                if (count == 0) {
                    ItemUserListResDTO dto = new ItemUserListResDTO();
                    dto.setTitle(parent.getTitle());
                    dto.setId(id);
                    dto.setItemType(parent.getItemType());
                    List<SysItemUser> resList = new ArrayList<>();
                    resList.add(next);
                    dto.setList(resList);
                    list.add(dto);
                } else {
                    ItemUserListResDTO itemUserListResDTO = list.stream().filter(x -> x.getId().equals(id)).collect(Collectors.toList()).get(0);
                    List<SysItemUser> list1 = itemUserListResDTO.getList();
                    list1.add(next);
                }
            }
        }

        String filterOrder = itemUserListDTO.getFilterOrder();
        if (StrUtil.isNotBlank(filterOrder)) {
            for (ItemUserListResDTO itemUserListResDTO : list) {
                List<SysItemUser> list1 = itemUserListResDTO.getList();
                if (CollUtil.isNotEmpty(list1)) {
                    if ("1".equals(filterOrder)) {
                        CollUtil.sort(list1, (o1, o2) -> {
                            if (Convert.toBigDecimal(o1.getMaxPrice()).compareTo(Convert.toBigDecimal(o2.getMaxPrice())) > 0) {
                                return -1;
                            } else if (Convert.toBigDecimal(o1.getMaxPrice()).compareTo(Convert.toBigDecimal(o2.getMaxPrice())) == 0) {
                                return 0;
                            } else {
                                return 1;
                            }
                        });
                    } else {
                        CollUtil.sort(list1, (o1, o2) -> {
                            if (Convert.toBigDecimal(o1.getMaxPrice()).compareTo(Convert.toBigDecimal(o2.getMaxPrice())) > 0) {
                                return 1;
                            } else if (Convert.toBigDecimal(o1.getMaxPrice()).compareTo(Convert.toBigDecimal(o2.getMaxPrice())) == 0) {
                                return 0;
                            } else {
                                return -1;
                            }
                        });
                    }
                }
            }
        }

        return list;
    }

    public void update(UserScrapStore userScrapStore) {
        userScrapStoreMapper.updateByPrimaryKeySelective(userScrapStore);
    }

    public void deleteById(String id) {
        UserScrapStore userScrapStore = new UserScrapStore();
        userScrapStore.setId(id);
        userScrapStore.setDelFlag(Convert.toShort(Constants.DEL_FLAG));
        userScrapStoreMapper.updateByPrimaryKeySelective(userScrapStore);
        //删除报价
        sysItemUserService.deleteByUserId(id);
    }
}