/*
 *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions are met:
 *
 *  Redistributions of source code must retain the above copyright notice,
 *  this list of conditions and the following disclaimer.
 *  Redistributions in binary form must reproduce the above copyright
 *  notice, this list of conditions and the following disclaimer in the
 *  documentation and/or other materials provided with the distribution.
 *  Neither the name of the dreamlu.net developer nor the names of its
 *  contributors may be used to endorse or promote products derived from
 *  this software without specific prior written permission.
 *  Author: Chill 庄骞 (smallchill@163.com)
 */
package org.springblade.modules.place.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.logging.log4j.util.Strings;
import org.springblade.common.node.TreeStringNode;
import org.springblade.common.utils.IdUtils;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.modules.doorplateAddress.entity.DoorplateAddressEntity;
import org.springblade.modules.doorplateAddress.service.IDoorplateAddressService;
import org.springblade.modules.grid.service.IGridService;
import org.springblade.modules.place.entity.*;
import org.springblade.modules.place.excel.PlaceAndRelExcel;
import org.springblade.modules.place.excel.PlaceExcel;
import org.springblade.modules.place.service.IPlaceExtService;
import org.springblade.modules.place.service.IPlacePoiLabelService;
import org.springblade.modules.place.service.IPlaceRelService;
import org.springblade.modules.place.vo.PlaceVO;
import org.springblade.modules.place.mapper.PlaceMapper;
import org.springblade.modules.place.service.IPlaceService;
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springframework.transaction.annotation.Transactional;

import java.util.*;

/**
 * 场所表 服务实现类
 *
 * @author BladeX
 * @since 2023-10-28
 */
@Service
public class PlaceServiceImpl extends ServiceImpl<PlaceMapper, PlaceEntity> implements IPlaceService {
	@Autowired
	private IUserService userService;

	@Autowired
	private IPlacePoiLabelService placePoiLabelService;

	@Autowired
	private IPlaceExtService placeExtService;

	@Autowired
	private IPlaceRelService placeRelService;

	@Autowired
	private IDoorplateAddressService doorplateAddressService;

	@Autowired
	private IGridService gridService;

	/**
	 * 自定义列表查询
	 * @param page
	 * @param place
	 * @return
	 */
	@Override
	public IPage<PlaceVO> selectPlacePage(IPage<PlaceVO> page, PlaceVO place) {
		List<String> list = new ArrayList<>();
		if (null!=place.getRoleName() && !place.getRoleName().equals("")){
			if (place.getRoleName().equals("网格员")){
				// 查询对应的房屋地址code
				list = gridService.getAddressCodeListByUserId(AuthUtil.getUserId());
			}
		}
		place.setCreateUser(AuthUtil.getUserId());
		return page.setRecords(baseMapper.selectPlacePage(page, place,list));
	}

	/**
	 * 查询场所集合信息
	 * @param userId
	 * @return
	 */
	@Override
	public List<TreeStringNode> selectPlaceNodeList(Long userId) {
		return baseMapper.selectPlaceNodeList(userId.toString());
	}

	/**
	 * 场所信息自定义新增/修改
	 * @param placeVO
	 * @return
	 */
	@Override
	@Transactional(rollbackFor = Exception.class)
	public Boolean addOrUpdate(PlaceVO placeVO) {
		boolean flag = false;
		placeVO.setUpdateUser(AuthUtil.getUserId());
		placeVO.setUpdateTime(new Date());
		// 查看是否包含houseCode,如果有，则更新
		if (!Strings.isBlank(placeVO.getHouseCode())){
			// 更新,先查询场所信息
			QueryWrapper<PlaceEntity> wrapper = new QueryWrapper<>();
			wrapper.eq("is_deleted",0).eq("house_code",placeVO.getHouseCode());
			PlaceEntity one = getOne(wrapper);
			placeVO.setId(one.getId());
			// 绑定用户信息
			bindUserHandle(placeVO);
			// 更新场所信息
			flag = updateById(placeVO);
			// 保存场所详情及任务信息
			savePlaceExtAndTaskInfo(placeVO);
			// 场所标签信息绑定(更新，调整）
			placeLabelBind(placeVO);
		}else {
			// 设置基础数据
			placeVO.setCreateUser(AuthUtil.getUserId());
			placeVO.setCreateTime(new Date());
			// 设置来源( 1：地址总表  2：国控采集)
			placeVO.setSource(2);
			// 并生成36位的houseCode
			placeVO.setHouseCode(IdUtils.getIdBy36());
			// 绑定用户信息
			bindUserHandle(placeVO);
			// 新增场所信息
			flag = save(placeVO);
			// 保存场所详情及任务信息
			savePlaceExtAndTaskInfo(placeVO);
			// 场所标签信息绑定
			placeLabelBind(placeVO);
		}
		// 位置绑定，通过定位去匹配所在网格
		// 返回结果
		return flag;
	}

	/**
	 * 场所标签信息绑定入库
	 * @param placeVO
	 */
	@Transactional(rollbackFor = Exception.class)
	public void placeLabelBind(PlaceVO placeVO) {
		// 先查询对于的场所是否已有标签信息
		// 查询对应已存在的从业人员
		QueryWrapper<PlacePoiLabel> wrapper = new QueryWrapper<>();
		wrapper.eq("place_id",placeVO.getId());
		List<PlacePoiLabel> oldList = placePoiLabelService.list(wrapper);
		if (oldList.size()>0){
			// 先将老的全部删除，然后批量插入
			QueryWrapper<PlacePoiLabel> queryWrapper = new QueryWrapper<>();
			queryWrapper.eq("place_id",placeVO.getId());
			boolean remove = placePoiLabelService.remove(queryWrapper);
			if (remove){
				// 批量新增
				savePlaceLabel(placeVO);
			}
		}else {
			savePlaceLabel(placeVO);
		}
	}

	/**
	 * 插入场所标签信息
	 * @param placeVO
	 */
	public void savePlaceLabel(PlaceVO placeVO) {
		// 批量新增
		List<String> labelList = Arrays.asList(placeVO.getLabel().split(","));
		// 遍历
		labelList.forEach(labelId -> {
			PlacePoiLabel placePoiLabel = new PlacePoiLabel();
			placePoiLabel.setPlaceId(placeVO.getId());
			placePoiLabel.setPoiCode(Integer.parseInt(labelId));
			placePoiLabelService.save(placePoiLabel);
		});
	}

	/**
	 * 场所负责人和用户绑定
	 * @param placeVO
	 */
	@Transactional(rollbackFor = Exception.class)
	public User bindUserHandle(PlaceVO placeVO) {
		User newUser = new User();
		if (null!=placeVO.getPhone() && !placeVO.getPhone().equals("")) {
			placeVO.setPrincipal(placeVO.getUsername());
			placeVO.setPrincipalPhone(placeVO.getPhone());
			//根据手机号查询库里的数据
			User userParams = new User();
			userParams.setPhone(placeVO.getPhone());
			User user = userService.getOne(Condition.getQueryWrapper(userParams));

			if (null!=user) {
				//如果用户存在，则该用户id绑定场所
				placeVO.setPrincipalUserId(user.getId());
				newUser = user;
				// 判断用户是否包含了居民角色,不包含则需更新
				if (!user.getRoleId().contains("1717429059648606209")){
					user.setRoleId(user.getRoleId() + ",1717429059648606209");
					//更新
					userService.updateById(user);
				}
			} else {
				//如果用户不存在，则新增一个用户
				newUser.setAccount(placeVO.getPhone());
				newUser.setPhone(placeVO.getPhone());
				newUser.setName(placeVO.getUsername());
				newUser.setRealName(placeVO.getUsername());
				// 社区群众部门
				newUser.setDeptId("1727979636479037441");
				// 目前暂定居民角色，
				newUser.setRoleId("1717429059648606209");
				//默认密码为 123456
				newUser.setPassword("123456");
				// 设置机构
				// 用户新增
				boolean submit = userService.submit(newUser);
				//绑定id
				placeVO.setPrincipalUserId(newUser.getId());
				//给人员打上场所负责人的标签
				baseMapper.saveUserLabel(newUser.getId(),1002);
			}
		}
		return newUser;
	}

	/**
	 * 保存场所详情及任务信息
	 * @param placeVO
	 */
	@Transactional(rollbackFor = Exception.class)
	public void savePlaceExtAndTaskInfo(PlaceVO placeVO) {
		PlaceExtEntity placeExtEntity = new PlaceExtEntity();
		placeExtEntity.setPlaceId(placeVO.getId());
		// 判断是否已存在，已存在则不新增
		QueryWrapper<PlaceExtEntity> wrapper = new QueryWrapper<>();
		wrapper.eq("is_deleted",0)
			.eq("place_id",placeVO.getId());
		PlaceExtEntity one = placeExtService.getOne(wrapper);
		if (null == one) {
			placeExtEntity.setPlaceId(placeVO.getId());
			//新增
			placeExtService.savePlaceExt(placeExtEntity);
		}
	}

	/**
	 * 历史场所挂接处理-临时
	 * @param place
	 * @return
	 */
	@Override
	public Object historyPlaceHandle(PlaceVO place) {
		// 查询所有的场所（手机号不为空）
		List<PlaceVO> list = baseMapper.getPlaceNotNullPhone();
		// 遍历
		for (PlaceVO placeVO : list) {
			User user = bindUserHandle(placeVO);
			if (null!=user){
				placeVO.setPrincipalUserId(user.getId());
				//更新场所用户id绑定
				baseMapper.updatePlaceEntity(placeVO);
			}
		}
		return null;
	}

	/**
	 * 历史场所标签挂接处理-临时
	 * @param place
	 * @return
	 */
	@Override
	@Transactional
	public Object historyPlaceLabelHandle(PlaceVO place) {
		// 查询所有的场所
		List<PlaceVO> list = baseMapper.getAllHistoryPlace();
		// 遍历
		for (PlaceVO placeVO : list) {
			if (null!=placeVO.getLabel()){
				String[] split = placeVO.getLabel().split(",");
				for (String s : split) {
					PlacePoiLabel placePoiLabel = new PlacePoiLabel();
					placePoiLabel.setPlaceId(placeVO.getId());
					placePoiLabel.setPoiCode(Integer.parseInt(s));
					placePoiLabelService.save(placePoiLabel);
				}
			}
		}
		return null;
	}

	/**
	 * 场所表 自定义详情查询
	 * @param place
	 * @return
	 */
	@Override
	public PlaceVO getDetail(PlaceVO place) {
		// 查询场所信息
		PlaceVO placeVO = baseMapper.getDetail(place);
		if (null!= place.getAddressType() && place.getAddressType()==4){
			if (null != placeVO) {
				// 查询地址编码信息（社区派出所相关信息）
				DoorplateAddressEntity addressEntity = placeRelService.getDoorplateAddressEntity(placeVO);
				placeVO.setDoorplateAddressEntity(addressEntity);
				// 查询网格信息
				placeVO.setGrid(gridService.getGridDetailByParam(placeVO));
			}
		}else {
			if (null != placeVO) {
				if (null != placeVO.getHouseCode() && !placeVO.getHouseCode().equals("")) {
					place.setHouseCode(placeVO.getHouseCode());
				}
				// 查询门牌地址信息
				if (null != place.getHouseCode() && !place.getHouseCode().equals("")) {
					QueryWrapper<DoorplateAddressEntity> wrapper = new QueryWrapper<>();
					wrapper.eq("address_code", place.getHouseCode());
					List<DoorplateAddressEntity> list = doorplateAddressService.list(wrapper);
					if (list.size() > 0) {
						placeVO.setDoorplateAddressEntity(list.get(0));
					}
					// 查询网格数据
					placeVO.setGrid(gridService.getGridDetailByHouseCode(place.getHouseCode()));
				} else {
					// 通过定位点落面分析网格位置，反向推出社区派出所相关数据

				}
			}
		}
		// 返回
		return placeVO;
	}

	/**
	 * 场所数据到导入
	 * @param data
	 * @param isCovered
	 */
	@Override
	public void importPlace(List<PlaceExcel> data, Boolean isCovered) {
		for (PlaceExcel placeExcel : data) {
			// 判断是否存在，不存在则插入，否则不操作
			QueryWrapper<PlaceEntity> wrapper = new QueryWrapper<>();
			wrapper.eq("is_deleted",0)
				.eq("house_code",placeExcel.getHouseCode());
			PlaceEntity one = getOne(wrapper);
			if (null == one){
				Long userId = updateUser(placeExcel);
				// 插入场所
				PlaceEntity placeEntity = new PlaceEntity();
				placeEntity.setHouseCode(placeExcel.getHouseCode());
				placeEntity.setPrincipalUserId(userId);
				placeEntity.setPrincipal(placeExcel.getName());
				placeEntity.setPrincipalPhone(placeExcel.getPhoneNumber());
				placeEntity.setCreateTime(new Date());
				placeEntity.setCreateUser(AuthUtil.getUserId());
				placeEntity.setUpdateTime(new Date());
				placeEntity.setUpdateUser(AuthUtil.getUserId());
				//一个一个插入，防止同一个表中有相同的数据
				save(placeEntity);
			}
		}
	}

	/**
	 * 更新用户信息
	 * @param placeExcel
	 * @return
	 */
	public Long updateUser(PlaceExcel placeExcel) {
		if (!Strings.isBlank(placeExcel.getPhoneNumber()) &&
			!Strings.isBlank(placeExcel.getName())) {
			PlaceVO placeVO = new PlaceVO();
			placeVO.setPhone(placeExcel.getPhoneNumber());
			placeVO.setUsername(placeExcel.getName());
			// 更新场所负责人
			User user = bindUserHandle(placeVO);
			// 返回
			return user.getId();
		}
		return null;
	}

	/**
	 * 更新用户信息
	 * @param placeExcel
	 * @return
	 */
	public Long updateUser(PlaceAndRelExcel placeExcel) {
		if (!Strings.isBlank(placeExcel.getPhoneNumber()) &&
			!Strings.isBlank(placeExcel.getName())) {
			PlaceVO placeVO = new PlaceVO();
			placeVO.setPhone(placeExcel.getPhoneNumber());
			placeVO.setUsername(placeExcel.getName());
			// 更新场所负责人
			User user = bindUserHandle(placeVO);
			// 返回
			return user.getId();
		}
		return null;
	}

	/**
	 * 场所(商超)导入
	 * @param data
	 * @param isCovered
	 */
	@Override
	public void importAndRelPlace(List<PlaceAndRelExcel> data, Boolean isCovered) {
		for (PlaceAndRelExcel placeExcel : data) {
			// 判断是否存在，不存在则插入，否则不操作
			PlaceEntity one = baseMapper.getPlaceAndRelInfo(placeExcel);
			if (null == one){
				Long userId = updateUser(placeExcel);
				// 插入场所
				PlaceEntity placeEntity = new PlaceEntity();
				placeEntity.setPlaceName(placeExcel.getPlaceName());
				placeEntity.setLocaltion(placeExcel.getAddress());
				placeEntity.setPrincipalUserId(userId);
				placeEntity.setPrincipal(placeExcel.getName());
				placeEntity.setPrincipalPhone(placeExcel.getPhoneNumber());
				placeEntity.setPrincipalUserId(userId);
				placeEntity.setCreateTime(new Date());
				placeEntity.setCreateUser(AuthUtil.getUserId());
				placeEntity.setUpdateTime(new Date());
				placeEntity.setUpdateUser(AuthUtil.getUserId());
				//一个一个插入，防止同一个表中有相同的数据
				save(placeEntity);
				// 插入标签关系表
				savPlaceLabelBind(placeExcel,placeEntity);
				// 插入关联数据表
				PlaceRelEntity placeRelEntity = new PlaceRelEntity();
				placeRelEntity.setPlaceId(placeEntity.getId());
				placeRelEntity.setStreetName(placeExcel.getStreetName());
				placeRelEntity.setCommunityName(placeExcel.getCommunityName());
				placeRelEntity.setGridName(placeExcel.getGridName());
				placeRelEntity.setBuildingName(placeExcel.getBuildingName());
				placeRelEntity.setDoorplateNum(placeExcel.getDoorplateNum());
				placeRelEntity.setFloor(placeExcel.getFloor());
				placeRelEntity.setCreateTime(new Date());
				placeRelEntity.setCreateUser(AuthUtil.getUserId());
				placeRelEntity.setUpdateTime(new Date());
				placeRelEntity.setUpdateUser(AuthUtil.getUserId());
				// 新增
				placeRelService.save(placeRelEntity);
			}else {
				// 只更新商铺信息
				Long userId = updateUser(placeExcel);
				// 插入场所
				PlaceEntity placeEntity = new PlaceEntity();
				placeEntity.setId(one.getId());
				placeEntity.setPlaceName(placeExcel.getPlaceName());
				placeEntity.setLocaltion(placeExcel.getAddress());
				placeEntity.setPrincipalUserId(userId);
				placeEntity.setCreateTime(new Date());
				placeEntity.setCreateUser(AuthUtil.getUserId());
				placeEntity.setUpdateTime(new Date());
				placeEntity.setUpdateUser(AuthUtil.getUserId());
				//一个一个插入，防止同一个表中有相同的数据
				updateById(placeEntity);
			}
		}
	}

	/**
	 * 插入标签关系表
	 * @param placeExcel
	 */
	public void savPlaceLabelBind(PlaceAndRelExcel placeExcel,PlaceEntity placeEntity) {
		if (!Strings.isBlank(placeExcel.getLabelCode())){
			PlaceVO placeVO = new PlaceVO();
			placeVO.setId(placeEntity.getId());
			placeVO.setLabel(placeExcel.getLabelCode());
			// 插入标签
			placeLabelBind(placeVO);
		}
	}

	/**
	 * 场所数据处理-用户信息（场所负责人信息写入到场所表）
	 */
	@Override
	@Transactional(rollbackFor = Exception.class)
	public Object placeUserHandle() {
		// 查询出有用户id 的场所
		List<PlaceEntity> list = baseMapper.getHasUserIdPlaceList();
		// 遍历
		for (PlaceEntity placeEntity : list) {
			// 查询对应的用户信息
			User user = userService.getById(placeEntity.getPrincipalUserId());
			if (null!=user) {
				// 设置场所负责人，手机号
				if (null != user.getRealName() && !user.getRealName().equals("")) {
					placeEntity.setPrincipal(user.getRealName());
				}
				if (null != user.getPhone() && !user.getPhone().equals("")) {
					placeEntity.setPrincipalPhone(user.getPhone());
				}
				// 更新场所信息
				updateById(placeEntity);
			}
		}
		return null;
	}

	/**
	 * 自定义修改
	 * @param placeVO
	 * @return
	 */
	@Override
	@Transactional(rollbackFor = Exception.class)
	public boolean updatePlace(PlaceVO placeVO) {
		boolean flag = false;
		// 修改场所信息
		flag = updateById(placeVO);
		// 修改标签绑定信息

		// 返回
		return flag;
	}
}