package com.panzhihua.service_community.service.impl;

import static java.util.Objects.isNull;
import static java.util.Objects.nonNull;
import static org.apache.commons.lang3.StringUtils.isNotBlank;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

import javax.annotation.Resource;
import javax.validation.constraints.NotNull;

import com.panzhihua.common.exceptions.ServiceException;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.dtos.community.rentingHouses.NearbyDTO;
import com.panzhihua.common.model.dtos.community.rentingHouses.PageRentingHouseRegisterDTO;
import com.panzhihua.common.model.dtos.community.rentingHouses.ReleaseOrCancelHouseDTO;
import com.panzhihua.common.model.dtos.community.rentingHouses.RentingHouseRegisterDTO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.rentingHouses.RentingHouseRegisterVO;
import com.panzhihua.common.utlis.Snowflake;
import com.panzhihua.service_community.dao.ComActVillageDAO;
import com.panzhihua.service_community.dao.RentingHourseContractConfigDao;
import com.panzhihua.service_community.dao.RentingHourseRegisterDao;
import com.panzhihua.service_community.entity.RentingHourseContractConfig;
import com.panzhihua.service_community.entity.RentingHourseFile;
import com.panzhihua.service_community.entity.RentingHourseRegister;
import com.panzhihua.service_community.model.dos.ComMngVillageDO;
import com.panzhihua.service_community.service.RentingHourseFileService;
import com.panzhihua.service_community.service.RentingHourseRegisterService;
import com.panzhihua.service_community.util.NearbyUtil;
import com.panzhihua.service_community.util.WxMaConfiguration;
import com.spatial4j.core.shape.Rectangle;

import cn.binarywang.wx.miniapp.api.WxMaQrcodeService;
import cn.hutool.core.codec.Base64;
import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.common.error.WxErrorException;

/**
 * 房屋租售-租赁房屋登记(RentingHourseRegister)表服务实现类
 *
 * @author makejava
 * @since 2021-11-23 10:49:08
 */
@Slf4j
@Service
public class RentingHourseRegisterServiceImpl extends ServiceImpl<RentingHourseRegisterDao, RentingHourseRegister> implements RentingHourseRegisterService {

    @Resource
    private ComActVillageDAO comActVillageDAO;
    @Resource
    private RentingHourseFileService rentingHourseFileService;
    @Resource
    private RentingHourseContractConfigDao rentingHourseContractConfigDao;
    @Resource
    private WxMaConfiguration wxMaConfiguration;

    @Value("${rentinghouse.min-app.jump-page}")
    private String minAppJumpPage;

    /**
     * 新增房源信息
     * @param registerDTO
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public R registerRentingHouse(RentingHouseRegisterDTO registerDTO) {
        checkDepositMoney(registerDTO);
        Long communityId = registerDTO.getCommunityId();
        Long userId = registerDTO.getUserId();
        RentingHourseRegister houseRegister = new RentingHourseRegister();
        BeanUtils.copyProperties(registerDTO, houseRegister);
        Date nowDate = new Date();
        houseRegister.setId(Snowflake.getId());
        houseRegister.setAuthStatus(RentingHourseRegister.AuthStatus.wrz);
        houseRegister.setStatus(RentingHourseRegister.Status.dfb);
        houseRegister.setDetailStatus(RentingHourseRegister.DetailStatus.drz);
        houseRegister.setInfoStatus(2);
        houseRegister.setCreateAt(nowDate);
        houseRegister.setUpdateAt(nowDate);
        try {
            WxMaQrcodeService qrCodeService = wxMaConfiguration.getMaService(registerDTO.getAreaCode()).getQrcodeService();
            byte[] bytes = qrCodeService.createWxaCodeUnlimitBytes("id=" + houseRegister.getId() + "&type=6",
                    minAppJumpPage, 30, true, null, false);
            String authCode = String.format("data:image/png;base64,%s", Base64.encode(bytes));
            houseRegister.setAuthCode(authCode);
        } catch (WxErrorException e) {
            log.error("生成房源认证码失败【{}】", e.getMessage());
            return R.fail("生成房源认证码失败，请稍后重试");
        }
        //街道id
        //小区id
        List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda()
                .eq(ComMngVillageDO::getCommunityId, communityId)
                .eq(ComMngVillageDO::getAlley, registerDTO.getAlley())
                .eq(ComMngVillageDO::getHouseNum, registerDTO.getHouseNum()));
        Long streetId = 0L;
        Long villageId = 0L;
        if (!villageList.isEmpty()) {
            ComMngVillageDO village = villageList.stream().sorted(Comparator.comparing(ComMngVillageDO::getCreateAt).reversed()).findFirst().get();
            streetId = village.getStreetId();
            villageId = village.getVillageId();
            houseRegister.setStreetId(streetId);
            houseRegister.setVillageId(villageId);
        }
        //房屋编号 streetId + communityId + villageId + timestamp
        String code = "" + streetId + communityId + villageId + nowDate.toInstant().getEpochSecond();
        houseRegister.setCode(code);
        int result = this.baseMapper.insert(houseRegister);
        if (result > 0) {
            //图片存储
            Long registerId = houseRegister.getId();
            List<RentingHourseFile> files = new ArrayList<>();
            List<String> housePictures = registerDTO.getHousePictures();
            if (!housePictures.isEmpty()) {
                housePictures.forEach(e -> {
                    if (StringUtils.isNotBlank(e)) {
                        RentingHourseFile file = new RentingHourseFile();
                        file.setId(Snowflake.getId());
                        file.setClassification(RentingHourseFile.Classification.fytp);
                        file.setRefId(registerId);
                        file.setType(RentingHourseFile.Type.picture);
                        file.setUrl(e);
                        file.setCreateBy(userId);
                        file.setCreateAt(nowDate);
                        files.add(file);
                    }
                });
            }
            List<String> propertyPictures = registerDTO.getPropertyPictures();
            if (!propertyPictures.isEmpty()) {
                propertyPictures.forEach(e -> {
                    if (StringUtils.isNotBlank(e)) {
                        RentingHourseFile file = new RentingHourseFile();
                        file.setId(Snowflake.getId());
                        file.setClassification(RentingHourseFile.Classification.cqtp);
                        file.setRefId(registerId);
                        file.setType(RentingHourseFile.Type.picture);
                        file.setUrl(e);
                        file.setCreateBy(userId);
                        file.setCreateAt(nowDate);
                        files.add(file);
                    }
                });
            }
            List<String> credentialsPictures = registerDTO.getCredentialsPictures();
            if (!credentialsPictures.isEmpty()) {
                credentialsPictures.forEach(e -> {
                    if (StringUtils.isNotBlank(e)) {
                        RentingHourseFile file = new RentingHourseFile();
                        file.setId(Snowflake.getId());
                        file.setClassification(RentingHourseFile.Classification.zjzq);
                        file.setRefId(registerId);
                        file.setType(RentingHourseFile.Type.picture);
                        file.setUrl(e);
                        file.setCreateBy(userId);
                        file.setCreateAt(nowDate);
                        files.add(file);
                    }
                });
            }
            rentingHourseFileService.saveBatch(files);
            return R.ok();
        }
        return R.fail("新增房源失败");
    }

    private void checkDepositMoney(RentingHouseRegisterDTO registerDTO) {
        BigDecimal dingMoney = registerDTO.getDingMoney();
        BigDecimal monthlyRentMoney = registerDTO.getMonthlyRentMoney();
        if (nonNull(dingMoney) && nonNull(monthlyRentMoney) && dingMoney.compareTo(monthlyRentMoney) == 1) {
            throw new ServiceException("500", "定金不能超过月租金");
        }
    }

    /**
     * 编辑房源信息
     * @param registerDTO
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public R updateRentingHouse(RentingHouseRegisterDTO registerDTO) {
        checkDepositMoney(registerDTO);
        Long id = registerDTO.getId();
        Long userId = registerDTO.getUserId();
        RentingHourseRegister houseRegister = this.baseMapper.selectById(id);
        if (isNull(houseRegister)) {
            return R.fail("房源不存在");
        }
        if (houseRegister.getStatus().intValue() == RentingHourseRegister.Status.czz ||
                houseRegister.getStatus().intValue() == RentingHourseRegister.Status.ytz) {
            return R.fail("出租中、结算中不可进行编辑操作");
        }
        if (houseRegister.getStatus().intValue() == RentingHourseRegister.Status.dcz) {
            return R.fail("编辑房源请先取消发布");
        }
        Date nowDate = new Date();
        BeanUtils.copyProperties(registerDTO, houseRegister);
        houseRegister.setUpdateAt(nowDate);
        String alley = registerDTO.getAlley();
        String houseNum = registerDTO.getHouseNum();
        boolean isChange = isNotBlank(alley) && isNotBlank(houseNum)
                && (!houseRegister.getAlley().equals(alley) || !houseRegister.getHouseNum().equals(houseNum));
        if (isChange) {
            List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda()
                    .eq(ComMngVillageDO::getCommunityId, registerDTO.getCommunityId())
                    .eq(ComMngVillageDO::getAlley, alley)
                    .eq(ComMngVillageDO::getHouseNum, houseNum));
            if (!villageList.isEmpty()) {
                ComMngVillageDO village = villageList.stream().sorted(Comparator.comparing(ComMngVillageDO::getCreateAt).reversed()).findFirst().get();
                houseRegister.setStreetId(village.getStreetId());
                houseRegister.setVillageId(village.getVillageId());
            }
        }
        int result = this.baseMapper.updateById(houseRegister);
        if (result > 0) {
            List<RentingHourseFile> files = new ArrayList<>();
            List<String> housePictures = registerDTO.getHousePictures();
            if (nonNull(housePictures) && !housePictures.isEmpty()) {
                rentingHourseFileService.remove(new QueryWrapper<RentingHourseFile>().lambda()
                        .eq(RentingHourseFile::getRefId, id)
                        .eq(RentingHourseFile::getClassification, RentingHourseFile.Classification.fytp)
                        .eq(RentingHourseFile::getType, RentingHourseFile.Type.picture));
                housePictures.forEach(e -> {
                    if (StringUtils.isNotBlank(e)) {
                        RentingHourseFile file = new RentingHourseFile();
                        file.setId(Snowflake.getId());
                        file.setClassification(RentingHourseFile.Classification.fytp);
                        file.setRefId(id);
                        file.setType(RentingHourseFile.Type.picture);
                        file.setUrl(e);
                        file.setCreateBy(userId);
                        file.setCreateAt(nowDate);
                        files.add(file);
                    }
                });
            }
            List<String> propertyPictures = registerDTO.getPropertyPictures();
            if (nonNull(propertyPictures) && !propertyPictures.isEmpty()) {
                rentingHourseFileService.remove(new QueryWrapper<RentingHourseFile>().lambda()
                        .eq(RentingHourseFile::getRefId, id)
                        .eq(RentingHourseFile::getClassification, RentingHourseFile.Classification.cqtp)
                        .eq(RentingHourseFile::getType, RentingHourseFile.Type.picture));
                propertyPictures.forEach(e -> {
                    if (StringUtils.isNotBlank(e)) {
                        RentingHourseFile file = new RentingHourseFile();
                        file.setId(Snowflake.getId());
                        file.setClassification(RentingHourseFile.Classification.cqtp);
                        file.setRefId(id);
                        file.setType(RentingHourseFile.Type.picture);
                        file.setUrl(e);
                        file.setCreateBy(userId);
                        file.setCreateAt(nowDate);
                        files.add(file);
                    }
                });
            }
            List<String> credentialsPictures = registerDTO.getCredentialsPictures();
            if (nonNull(credentialsPictures) && !credentialsPictures.isEmpty()) {
                rentingHourseFileService.remove(new QueryWrapper<RentingHourseFile>().lambda()
                        .eq(RentingHourseFile::getRefId, id)
                        .eq(RentingHourseFile::getClassification, RentingHourseFile.Classification.zjzq)
                        .eq(RentingHourseFile::getType, RentingHourseFile.Type.picture));
                credentialsPictures.forEach(e -> {
                    if (StringUtils.isNotBlank(e)) {
                        RentingHourseFile file = new RentingHourseFile();
                        file.setId(Snowflake.getId());
                        file.setClassification(RentingHourseFile.Classification.zjzq);
                        file.setRefId(id);
                        file.setType(RentingHourseFile.Type.picture);
                        file.setUrl(e);
                        file.setCreateBy(userId);
                        file.setCreateAt(nowDate);
                        files.add(file);
                    }
                });
            }
            rentingHourseFileService.saveBatch(files);
            return R.ok();
        }
        return R.fail("修改失败");
    }

    /**
     * 分页获取房源信息
     * @param pageRegisterDTO
     * @return
     */
    @Override
    public R pageRentingHouse(PageRentingHouseRegisterDTO pageRegisterDTO) {
        Page page = new Page<>();
        page.setCurrent(pageRegisterDTO.getPageNum());
        page.setSize(pageRegisterDTO.getPageSize());
        return R.ok(this.baseMapper.pageRentingHouse(page, pageRegisterDTO));
    }

    /**
     * 发布/取消发布 房源信
     * @param releaseOrCancelHouseDTO
     * @return
     */
    @Override
    public R releaseOrCancelHouse(ReleaseOrCancelHouseDTO releaseOrCancelHouseDTO) {
        RentingHourseRegister houseRegister = this.baseMapper.selectById(releaseOrCancelHouseDTO.getRegisterId());
        if (isNull(houseRegister)) {
            return R.fail("房源不存在");
        }
        Integer type = releaseOrCancelHouseDTO.getType();
        Integer status = houseRegister.getStatus();
        Integer authStatus = houseRegister.getAuthStatus();
        if (type.intValue() == 1) {
            //发布
            if (authStatus.intValue() == RentingHourseRegister.AuthStatus.wrz) {
                return R.fail("房源还未认证");
            }
            if (status.intValue() != RentingHourseRegister.Status.dfb) {
                return R.fail("已发布，请勿重复操作");
            }
            houseRegister.setStatus(RentingHourseRegister.Status.dcz);
            houseRegister.setDetailStatus(RentingHourseRegister.DetailStatus.dcz);
        } else {
            if (status.intValue() != RentingHourseRegister.Status.dcz) {
                return R.fail("暂不可取消发布");
            }
            //取消发布
            houseRegister.setStatus(RentingHourseRegister.Status.dfb);
            if (authStatus.intValue() == RentingHourseRegister.AuthStatus.yrz) {
                houseRegister.setDetailStatus(RentingHourseRegister.DetailStatus.dfb);
            } else {
                houseRegister.setDetailStatus(RentingHourseRegister.DetailStatus.drz);
            }
        }
        houseRegister.setUpdateAt(new Date());
        int result = this.baseMapper.updateById(houseRegister);
        if (result > 0) {
            return R.ok();
        }
        return R.fail("失败，请重试");
    }

    /**
     * 删除房源信息
     * @param registerId
     * @return
     */
    @Override
    public R deleteRentingHouse(Long registerId) {
        RentingHourseRegister houseRegister = this.baseMapper.selectById(registerId);
        if (isNull(houseRegister)) {
            return R.fail("房源不存在");
        }
        Integer status = houseRegister.getStatus();
        if (status.intValue() != RentingHourseRegister.Status.dfb) {
            return R.fail("已发布房源不支持删除");
        }
        rentingHourseFileService.remove(new QueryWrapper<RentingHourseFile>().lambda()
                .eq(RentingHourseFile::getRefId, registerId));
        int result = this.baseMapper.deleteById(registerId);
        if (result > 0) {
            return R.ok();
        }
        return R.fail("删除失败，请重试");
    }

    /**
     * 获取详情-房源信息
     * @param registerId
     * @return
     */
    @Override
    public R getRentingHouse(Long registerId) {
        RentingHourseRegister houseRegister = this.baseMapper.selectById(registerId);
        if (isNull(houseRegister)) {
            return R.fail("房源不存在");
        }
        RentingHouseRegisterVO registerVO = new RentingHouseRegisterVO();
        BeanUtils.copyProperties(houseRegister, registerVO);
        List<RentingHourseFile> files = rentingHourseFileService.list(new QueryWrapper<RentingHourseFile>().lambda()
                .eq(RentingHourseFile::getRefId, registerId)
                .eq(RentingHourseFile::getType, RentingHourseFile.Type.picture));
        if (!files.isEmpty()) {
            Map<Integer, List<RentingHourseFile>> fileGroupMap = files.stream()
                    .collect(Collectors.groupingBy(RentingHourseFile::getClassification));
            for (Map.Entry<Integer, List<RentingHourseFile>> entry : fileGroupMap.entrySet()) {
                List<String> urls = entry.getValue().stream().map(RentingHourseFile::getUrl).collect(Collectors.toList());
                switch (entry.getKey()) {
                    case RentingHourseFile.Classification.fytp:
                        registerVO.setHousePictures(urls);
                        registerVO.setUrl(urls.get(0));
                        break;
                    case RentingHourseFile.Classification.cqtp:
                        registerVO.setPropertyPictures(urls);
                        break;
                    case RentingHourseFile.Classification.zjzq:
                        registerVO.setCredentialsPictures(urls);
                    default:
                        break;
                }
            }
        }
        RentingHourseContractConfig contractConfig = rentingHourseContractConfigDao
                .selectOne(new QueryWrapper<RentingHourseContractConfig>()
                .lambda().eq(RentingHourseContractConfig::getName, "房屋委托代理合同"));
        if (nonNull(contractConfig)) {
            registerVO.setHouseAgencyContract(contractConfig.getValue());
        }
        return R.ok(registerVO);
    }

    @Override
    public R nearby(NearbyDTO nearbyDTO) {
        Rectangle rectangle =new NearbyUtil().getRectangle(nearbyDTO.getDistance(), Double.parseDouble(nearbyDTO.getLongitude()), Double.parseDouble(nearbyDTO.getLatitude()));
        return R.ok(this.baseMapper.nearby(rectangle.getMinX(),rectangle.getMaxX(),
                rectangle.getMinY(),rectangle.getMaxY(), nearbyDTO));
    }

    @Override
    public R pageRentingHouseApplet(PageRentingHouseRegisterDTO pageRegisterDTO) {
        Page page = new Page<>();
        page.setCurrent(pageRegisterDTO.getPageNum());
        page.setSize(pageRegisterDTO.getPageSize());
        return R.ok(this.baseMapper.pageRentingHouseApplet(page, pageRegisterDTO));
    }

    @Override
    public void updateAllHouseUnionAppCode(String areaCode) {
        List<RentingHourseRegister> list = this.baseMapper.selectList(null);
        if (!list.isEmpty()) {
            list.stream().forEach(houseRegister -> {
                try {
                    WxMaQrcodeService qrCodeService = wxMaConfiguration.getMaService(areaCode).getQrcodeService();
                    byte[] bytes = qrCodeService.createWxaCodeUnlimitBytes("id=" + houseRegister.getId() + "&type=6",
                            minAppJumpPage, 30, true, null, false);
                    String authCode = String.format("data:image/png;base64,%s", Base64.encode(bytes));
                    houseRegister.setAuthCode(authCode);
                } catch (WxErrorException e) {
                    log.error("生成房源认证码失败【{}】", e.getMessage());
                }
            });
            this.updateBatchById(list);
        }
    }
}