package com.xzx.gc.order.service;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.StrUtil;
import com.xzx.gc.common.constant.CommonEnum;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.constant.OrderEnum;
import com.xzx.gc.common.constant.UserEnum;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.common.utils.DateUtils;
import com.xzx.gc.common.utils.LocationUtils;
import com.xzx.gc.common.utils.ali.SmsUtil;
import com.xzx.gc.entity.*;
import com.xzx.gc.model.admin.AccountLogModel;
import com.xzx.gc.model.admin.UserAccountModel;
import com.xzx.gc.model.user.UserRecommendListResDTO;
import com.xzx.gc.order.mapper.*;
import com.xzx.gc.util.DoubleUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import tk.mybatis.mapper.entity.Example;

import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

@Service
@Transactional
public class OtherUserService {

    public List<OtherUserInfo> findHomeUserForbidden() {
        OtherUserInfo otherUserInfo=new OtherUserInfo();
        otherUserInfo.setDelFlag(0);
        otherUserInfo.setOriginType(Convert.toShort(1));
        otherUserInfo.setIsProhibit(false);
        return  otherUserMapper.select(otherUserInfo);
    }

    @Async
    public void sendHomeSms(){
        //发送短信
        List<OtherUserInfo> homeUserForbidden = findHomeUserForbidden();
        for (OtherUserInfo otherUserInfo : homeUserForbidden) {
            SmsUtil.sendPoint(otherUserInfo.getMobilePhone(), "您有新的电器订单，请尽快处理。");
        }
    }

    @Autowired
    private OtherUserMapper otherUserMapper;

    @Autowired
    private BusinessUtil businessUtil;

    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private SysItemPriceMapper sysItemPriceMapper;

    @Autowired
    private OrderAppraiseInfoMapper orderAppraiseInfoMapper;

    @Autowired
    private AccountLogMapper accountLogMapper;

    @Autowired
    private AccountMapper accountMapper;



    public List<OtherUserInfo> findByMobile(String mobile) {
        OtherUserInfo otherUserInfo=new OtherUserInfo();
        otherUserInfo.setDelFlag(Constants.DEL_NOT_FLAG);
        otherUserInfo.setIsProhibit(false);
        otherUserInfo.setMobilePhone(mobile);
        return  otherUserMapper.select(otherUserInfo);
    }

    public List<OtherUserInfo> findByMobileForBidden(String mobile) {
        OtherUserInfo otherUserInfo=new OtherUserInfo();
        otherUserInfo.setDelFlag(Constants.DEL_NOT_FLAG);
        otherUserInfo.setMobilePhone(mobile);
        return  otherUserMapper.select(otherUserInfo);
    }


    public List<OtherUserInfo> findByMobileAndTypeForBidden(String mobile,String userType) {
        OtherUserInfo otherUserInfo=new OtherUserInfo();
        otherUserInfo.setDelFlag(Constants.DEL_NOT_FLAG);
        otherUserInfo.setMobilePhone(mobile);
        otherUserInfo.setUserType(userType);
        return  otherUserMapper.select(otherUserInfo);
    }

    /**
     * 转换成回收员
     * @param userId
     * @return
     */
    public OtherUserInfo turnReceiver(String userId){
        OtherUserInfo byId = findById(userId);
        String mobilePhone = byId.getMobilePhone();
        List<OtherUserInfo> byMobile = findByMobile(mobilePhone);
        if(CollUtil.isNotEmpty(byMobile)){
            List<OtherUserInfo> collect = byMobile.stream().filter(x -> x.getUserType().equals(CommonEnum.回收员.getValue())).collect(Collectors.toList());
            List<OtherUserInfo> collect2 = byMobile.stream().filter(x -> x.getUserType().equals(CommonEnum.入库员.getValue())).collect(Collectors.toList());
            if(CollUtil.isNotEmpty(collect)){
                return collect.get(0);
            }else if(CollUtil.isNotEmpty(collect2)){
                return collect2.get(0);
            }
        }
        return null;
    }


    public OtherUserInfo findByMobileAndUserType(String mobile, String userType) {
        OtherUserInfo otherUserInfo=new OtherUserInfo();
        otherUserInfo.setDelFlag(0);
        otherUserInfo.setIsProhibit(false);
        otherUserInfo.setUserType(userType);
        otherUserInfo.setMobilePhone(mobile);
        return  otherUserMapper.selectOne(otherUserInfo);
    }

    /**
     * 根据合伙人查找
     * @param partnerId
     * @return
     */
    public List<OtherUserInfo> findByPartnerId(String partnerId) {
        OtherUserInfo otherUserInfo=new OtherUserInfo();
        otherUserInfo.setDelFlag(0);
        otherUserInfo.setPartnerId(partnerId);
        return  otherUserMapper.select(otherUserInfo);
    }


    public OtherUserInfo findById(String userId) {
        return  otherUserMapper.selectByPrimaryKey(userId);
    }



    public void updateById(OtherUserInfo otherUserInfo){
        otherUserMapper.updateByPrimaryKeySelective(otherUserInfo);
    }

    public void deleteById(String userId){
        OtherUserInfo otherUserInfo=new OtherUserInfo();
        otherUserInfo.setUserId(userId);
        otherUserInfo.setDelFlag(Constants.DEL_FLAG);
        updateById(otherUserInfo);
    }



    /**
     * 获取回收员头部信息
     * @param otherUserInfo
     * @param createUserId  创建用户即普通用户
     * @return
     */
    public UserRecommendListResDTO getHeadInfo(OtherUserInfo otherUserInfo, String longitude, String latitude, String createUserId, SysEnvironmentalInfo sysEnvironmentalInfo){

        Long itemId = otherUserInfo.getItemId();
        String userId = otherUserInfo.getUserId();
        UserRecommendListResDTO resDTO=new UserRecommendListResDTO();
        BeanUtil.copyProperties(otherUserInfo,resDTO);
        resDTO.setType(UserEnum.回收员类型.getValue());
        if(StrUtil.isNotBlank(latitude)&&StrUtil.isNotBlank(longitude)) {
            //单位米
            double distance = LocationUtils.getDistance(Convert.toDouble(otherUserInfo.getLatitude(), Convert.toDouble(0)), Convert.toDouble(otherUserInfo.getLongitude(), Convert.toDouble(0)), Convert.toDouble(latitude), Convert.toDouble(longitude));
            //距离
            resDTO.setDistance(businessUtil.changeWeight(Convert.toStr(NumberUtil.div(distance,1000))));
        }
        //服务次数
        List<OrderInfo> serviceOrderList = orderMapper.findServiceOrderByUserIdAndStatus(userId, CollUtil.newArrayList(OrderEnum.待入库.getValue(),OrderEnum.完成.getValue(),OrderEnum.入库中.getValue()));
        resDTO.setServiceNum(serviceOrderList.size());
        //自己报价
        if(itemId!=null){
            Example example = new Example(SysItemPrice.class);
            Example.Criteria criteria = example.createCriteria();
            criteria.andEqualTo("itemId", itemId);
            criteria.andEqualTo("delFlag", Constants.DEL_NOT_FLAG);
            example.setOrderByClause("price desc");
            List<SysItemPrice> sysItemPrices = sysItemPriceMapper.selectByExample(example);
            if (CollUtil.isNotEmpty(sysItemPrices)) {
                BigDecimal price = CollUtil.getFirst(sysItemPrices).getPrice();
                resDTO.setSelfMoney(businessUtil.changeMoney(price));
            }
        }
        //平台报价
        if(sysEnvironmentalInfo!=null){
            resDTO.setPlatMoney(businessUtil.changeMoney(sysEnvironmentalInfo.getPrice()));
        }

        //预计时间 服务中多一个用户多1小时
        int fwzNum;
        List<OrderInfo> list = orderMapper.findListOrderReceiveTime(userId);
        if(CollUtil.isEmpty(list)){
            fwzNum= 0;
        }else {
            List<String> collect = list.stream().map(x -> x.getCreateUserId()).collect(Collectors.toList());
            if(StrUtil.isNotBlank(createUserId)) {
                int i = collect.indexOf(createUserId);
                i=i==-1?collect.size():i;
                fwzNum= i;
            }else {
                fwzNum= collect.size();
            }
        }

        DateTime dateTime;
        String hour = DateUtil.format(new Date(), DateUtils.DATE_FORMAT_H);
        //超过下午6点从明天上午8点开始预约
        if(Convert.toInt(hour)>=18){
            String format = DateUtil.format(DateUtil.offsetDay(new Date(), 1), DateUtils.DATE_FORMAT_YMD);
            format=format+" 08:00:00";
            dateTime = DateUtil.offsetHour(DateUtil.parse(format), fwzNum);
        }else{
            fwzNum=fwzNum==0?1:fwzNum;
            dateTime = DateUtil.offsetHour(new Date(), fwzNum);
        }
        resDTO.setScheduledTime(DateUtil.format(dateTime,DateUtils.DATE_FORMAT_HM));
        //排队人数
        resDTO.setQueueNum(fwzNum);
        //是否服务过
        if(StrUtil.isNotBlank(createUserId)) {
            long num = serviceOrderList.stream().filter(x->x.getCreateUserId().equals(createUserId)).count();
            if(num>0){
                resDTO.setServiceFlag(true);
            }
        }
        //是否高于平台
        if(Convert.toBigDecimal(resDTO.getSelfMoney(),Constants.MONEY_INIT).compareTo(Convert.toBigDecimal(resDTO.getPlatMoney(),Constants.MONEY_INIT))>0){
            resDTO.setHighThanPlatFlag(true);
        }

        //平均取货时间（分钟）=(所有单完成时间-接单时间)/单数
        long perMinuteOrder=0;
        for (OrderInfo orderInfo : serviceOrderList) {
            String completeTime = orderInfo.getCompleteTime();
            String receiveTime = orderInfo.getReceiveTime();
            if(StrUtil.isNotBlank(completeTime)&&StrUtil.isNotBlank(receiveTime)){
                perMinuteOrder += DateUtil.between(DateUtil.parseDateTime(receiveTime), DateUtil.parseDateTime(completeTime), DateUnit.MINUTE);
            }
        }

        if(CollUtil.isNotEmpty(serviceOrderList)) {
            resDTO.setPerMinuteOrder(perMinuteOrder / serviceOrderList.size());
        }else {
            resDTO.setPerMinuteOrder(0);
        }

        //满意度
        Example example=new Example(OrderAppraiseInfo.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("delFlag",Convert.toShort(Constants.DEL_NOT_FLAG));
        criteria.andEqualTo("receiverId",otherUserInfo.getUserId());
        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();
            resDTO.setSatisfaction(Convert.toInt(sum/(orderAppraiseInfos.size()*Constants.SCORE_MAX)*100));
        }

        return resDTO;
    }


    public void addOtherUserAccountLog(UserAccountModel accountModel, BigDecimal money, String payOrderId, String accountMoney){
        BigDecimal newAccountMoney= new BigDecimal(accountMoney).add(new BigDecimal(accountModel.getMoney()));
        accountMapper.updateUserAccount(accountModel.getAccountId(),DoubleUtil.roundTwo(newAccountMoney.toString()),accountModel.getOverdraftLimit());
        //写入日志
        AccountLogModel log = new AccountLogModel();
        log.setAccountId(accountModel.getAccountId());
        log.setChannelType("12");
        log.setCreateTime(cn.hutool.core.date.DateUtil.now());
        log.setCreateUserId(accountModel.getUserId());
        BigDecimal oldMoney = new BigDecimal(accountMoney);
        log.setNewFixedLimit(accountModel.getFixedLimit());
        log.setNewLimit(accountModel.getLimit()+"");
        log.setNewMoney(DoubleUtil.roundTwo(newAccountMoney.toString()));
        log.setOldFixedLimit(accountModel.getFixedLimit());
        log.setOldLimit(accountModel.getLimit()+"");
        log.setOldMoney(DoubleUtil.roundTwo(oldMoney.toString()));
        log.setOrderId(payOrderId);
        accountLogMapper.insertAccountLog(log);
    }



}