package com.xzx.gc.user.service;


import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.RandomUtil;
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.RedisKeyConstant;
import com.xzx.gc.common.constant.UserEnum;
import com.xzx.gc.common.utils.*;
import com.xzx.gc.entity.*;
import com.xzx.gc.model.user.UserGatherApplyListParam;
import com.xzx.gc.model.user.UserGatherAuditParam;
import com.xzx.gc.user.mapper.CoreUserMapper;
import com.xzx.gc.user.mapper.SysItemUserMapper;
import com.xzx.gc.user.mapper.UserGatherApplyMapper;
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 javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

@Service
@Transactional
public class UserGatherApplyService {


    @Autowired
    private UserGatherInfoService userGatherInfoService;

    @Autowired
    private IdUtils idUtils;

    @Autowired
    private UserService userService;

    @Autowired
    private AddressService addressService;

    @Autowired
    private UserGatherApplyMapper userGatherApplyMapper;
    
    @Autowired
    private AddressLevelService addressLevelService;

    @Autowired
    private AccountService accountService;

    @Autowired
    private HttpServletRequest request;

    @Autowired
    private RedisUtil redisUtil;

    @Autowired
    private TokenUtil tokenUtil;

    @Autowired
    private SysEnvironmentalInfoService sysEnvironmentalInfoService;

    @Autowired
    private OtherUserService otherUserService;

    @Autowired
    private UserRoleService userRoleService;

    @Autowired
    private PartnerTraceService partnerTraceService;

    @Autowired
    private PartnerGaodeService partnerGaodeService;

    @Autowired
    private UserScrapStoreService userScrapStoreService;

    @Autowired
    private SysItemUserMapper sysItemUserMapper;

    @Autowired
    private UserTargetInfoService userTargetInfoService;

    @Autowired
    private PartnerFenceService partnerFenceService;

    @Autowired
    private CoreUserMapper coreUserMapper;

    public UserGatherApply findByRelationId(String relationId){
        //可能申请多次
        Example example=new Example(UserGatherApply.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("relationId",relationId);
        example.setOrderByClause("create_time desc");
        List<UserGatherApply> userGatherApplies = userGatherApplyMapper.selectByExample(example);
        if(CollUtil.isNotEmpty(userGatherApplies)){
            return userGatherApplies.get(0);
        }
        return null;
    }

    public void apply(UserGatherApply userGatherApply) {

        //获取省市区
        AddressLevelInfo byAdcode = addressLevelService.findByLocation(userGatherApply.getLongitude(), userGatherApply.getLatitude());
        userGatherApply.setProvinceId(byAdcode.getLevel1Id());
        userGatherApply.setCityId(byAdcode.getLevel2Id());
        userGatherApply.setTownshipId(byAdcode.getLevel3Id());
        userGatherApply.setStatus(CommonEnum.待审核.getValue());

        //所属推广员ID
        Short applyOrigin = userGatherApply.getApplyOrigin();
        String createUserId = userGatherApply.getCreateUserId();

        /**
         * 设置推广人员
         */
        //小程序
        if(Convert.toShort(1).equals(applyOrigin)){
            if(StrUtil.isNotBlank(createUserId)){
                String mobilePhone = userService.findById(createUserId).getMobilePhone();
                List<UserTargetInfo> byMobile = userTargetInfoService.findByMobile(mobilePhone);
                if(CollUtil.isNotEmpty(byMobile)){
                    userGatherApply.setRelationUserId(byMobile.get(0).getRealUserId());
                }
            }
        }else {
            //安卓
            userGatherApply.setRelationUserId(createUserId);
        }

        add(userGatherApply);
    }



    /**
     * 审核集货员通过
     * @param userGatherApply
     */
    private String auditGather(UserGatherApply userGatherApply){
        //添加集货员表
        UserGatherInfo userGatherInfo=new UserGatherInfo();
        BeanUtil.copyProperties(userGatherApply,userGatherInfo);

        //查询是否有普通用户身份
        UserInfo byMobileForbidden = userService.findByMobileForbidden(userGatherApply.getMobilePhone());
        String userId;
        if(byMobileForbidden!=null){
            userId=byMobileForbidden.getUserId();
        }else {
            userId=idUtils.generate("YH",3);
        }
        userGatherInfo.setUserId(userId);
        userGatherInfo.setNickName(StringUtils.encode(userGatherInfo.getName()));
        UserGatherInfo byId = userGatherInfoService.findById(userId);
        if(byId==null) {
            userGatherInfoService.add(userGatherInfo);
        }else {
            userGatherInfo.setRegistTime(DateUtil.now());
            userGatherInfo.setDelFlag(Constants.DEL_NOT_FLAG);
            userGatherInfo.setIsProhibit(false);
            userGatherInfoService.updateById(userGatherInfo);
        }

        if(byMobileForbidden!=null){
            //更新用户类型
            byMobileForbidden.setUserType(CommonEnum.集货员.getValue());
            byMobileForbidden.setName(userGatherApply.getName());
            userService.updateById(byMobileForbidden);
            //将原所有地址设为非默认
            addressService.updateByUserIdSetNoDefault(userId);

            //删除缓存
            redisUtil.del(RedisKeyConstant.TOKEN+userId);

        }else {
            //复制到用户表
            UserInfo userInfo = new UserInfo();
            BeanUtil.copyProperties(userGatherInfo, userInfo);
            userService.add(userInfo);

            //添加账户
            AccountInfo accountInfo = accountService.init(userGatherApply.getMobilePhone(), userId);
            accountService.add(accountInfo);
        }

        //添加地址
        initAddAddress(userGatherApply,userId);


        //发送短信
//        SmsUtil.sendPoint(userGatherApply.getMobilePhone(), SmsConstant.GATHER_SUCCESS);

        return userId;
    }



    private void initAddAddress(UserGatherApply userGatherApply,String userId){
        AddressInfo addressInfo = new AddressInfo();
        BeanUtil.copyProperties(userGatherApply, addressInfo);
        addressInfo.setUserId(userId);
        addressInfo.setFlag(UserEnum.默认地址.getValue());
        addressInfo.setRelaPhone(userGatherApply.getMobilePhone());
        addressInfo.setRelaName(userGatherApply.getName());
        if(UserEnum.集货员类型.getValue().equals(userGatherApply.getType())) {
            //将address_area（定位地址） detail_address小区地址
            AddressLevelInfo addressLevelInfo = addressLevelService.find(userGatherApply.getProvinceId(), userGatherApply.getCityId(), userGatherApply.getTownshipId());
            if(addressLevelInfo!=null){
                addressInfo.setAddressArea(addressLevelInfo.getLevel1Name()+addressLevelInfo.getLevel2Name()+addressLevelInfo.getLevel3Name());
            }
            addressInfo.setDetailAddress(userGatherApply.getAddressArea());
            //小区名称
            addressInfo.setHouseName(userGatherApply.getDetailAddress());
        }
        addressService.add(addressInfo);
    }

    /**
     * 审核成为回收员
     * @param userGatherApply
     */
    private String auditOtherUser(UserGatherApply userGatherApply){
        String userId=idUtils.generate("USER",5);
        OtherUserInfo otherUserInfo=new OtherUserInfo();
        otherUserInfo.setUserId(userId);
        otherUserInfo.setMobilePhone(userGatherApply.getMobilePhone());
        String salt=RandomUtil.randomString(16);
//        String password=RandomUtil.randomNumbers(6);
        String password="123456";
        String encrypt = SecurityUtil.encrypt(salt, password);
        otherUserInfo.setPassword(encrypt);
        otherUserInfo.setSalt(salt);
        otherUserInfo.setName(userGatherApply.getName());
        otherUserInfo.setUserType(CommonEnum.回收员.getValue());

        //获取省市区
        otherUserInfo.setProvinceId(Convert.toInt(userGatherApply.getProvinceId()));
        otherUserInfo.setCityId(Convert.toInt(userGatherApply.getCityId()));
        otherUserInfo.setTownshipId(Convert.toInt(userGatherApply.getTownshipId()));

        //角色ID
        UserRole byCode = userRoleService.findByCode(CommonEnum.回收员.getValue());
        if(byCode!=null){
            otherUserInfo.setRoleIds(Convert.toStr(byCode.getId()));
        }
        otherUserInfo.setIsProhibit(false);
        otherUserInfo.setOriginType(Convert.toShort(1));

        //合伙人相关
//        PartnerGaode byTownId = partnerGaodeService.findByTownId(otherUserInfo.getTownshipId().toString());
//        if(byTownId!=null){
//            String partnerId = byTownId.getPartnerId();
//            String terimalId=partnerTraceService.createTerimainal(partnerId,OrderEnum.回收员订单轨迹.getValue(),userId);
//            String terimalDayId=partnerTraceService.createTerimainal(partnerId,OrderEnum.回收员全天轨迹.getValue(),userId);
//            otherUserInfo.setTerminalId(terimalId);
//            otherUserInfo.setTerminalDayId(terimalDayId);
//            otherUserInfo.setPartnerId(partnerId);
//            List<String> fences = partnerFenceService.findFences(partnerId);
//            if(CollUtil.isNotEmpty(fences)){
//                otherUserInfo.setTownId(CollUtil.join(fences,","));
//            }
//        }
        otherUserService.add(otherUserInfo);

        //新增账户
        AccountInfo accountInfo = accountService.init(userGatherApply.getMobilePhone(), userId);
        accountService.add(accountInfo);

        //发送短信
//        Map<String,String> map=new HashMap<>();
//        map.put("other_number",password);
//        SmsUtil.sendPointByTemplate(userGatherApply.getMobilePhone(),map,SmsConstant.OTHER_SUUCESS_TEMPLATE, 2);
        return userId;

    }

    /**
     * 审核成为废品站complaintFirstFlag
     * @param userGatherApply
     */
    private String auditScrapStore(UserGatherApply userGatherApply){
        UserScrapStore userScrapStore=new UserScrapStore();
        BeanUtil.copyProperties(userGatherApply,userScrapStore);
        String id=idUtils.generate("FP",6);
        userScrapStore.setId(id);
        userScrapStoreService.add(userScrapStore);

        //废品分类
        String itemTypes = userGatherApply.getItemTypes();
        if(StrUtil.isNotBlank(itemTypes)){
            List<SysEnvironmentalInfo> byIds = sysEnvironmentalInfoService.findByIds(itemTypes.split(","));
            List<SysItemUser> list=new ArrayList<>();
            for (SysEnvironmentalInfo byId : byIds) {
                SysItemUser sysItemUser=new SysItemUser();
                sysItemUser.setUserId(id);
                sysItemUser.setItemType(byId.getItemType());
                sysItemUser.setCreateTime(DateUtil.now());
                sysItemUser.setDelFlag(Constants.DEL_NOT_FLAG);
                list.add(sysItemUser);
            }
            if(CollUtil.isNotEmpty(list)) {
                sysItemUserMapper.insertList(list);
            }
        }

        //发送短信
//        SmsUtil.sendPoint(userGatherApply.getMobilePhone(), SmsConstant.SCRAP_SUCCESS);

        return id;


    }

    public void add(UserGatherApply userGatherApply){
        userGatherApply.setCreateTime(DateUtil.now());
        userGatherApplyMapper.insertSelective(userGatherApply);
    }

    public List<UserGatherApply> findByMobileAndType(String mobile,String type){
        UserGatherApply userGatherApply=new UserGatherApply();
        userGatherApply.setMobilePhone(mobile);
        userGatherApply.setType(type);
        return userGatherApplyMapper.select(userGatherApply);
    }

    public List<UserGatherApply> list(UserGatherApplyListParam userGatherApplyListParam) {
        Example example=new Example(UserGatherApply.class);
        Example.Criteria criteria = example.createCriteria();
        if(StrUtil.isNotBlank(userGatherApplyListParam.getStatus())){
            criteria.andEqualTo("status",userGatherApplyListParam.getStatus());
        }


        if(StrUtil.isNotBlank(userGatherApplyListParam.getFilterType())){
            criteria.andEqualTo("type",userGatherApplyListParam.getFilterType());
        }else {
            if(CommonEnum.app.getValue().equals(userGatherApplyListParam.getClientType())){
                criteria.andIn("type",CollUtil.newArrayList(UserEnum.回收员类型.getValue(),UserEnum.废品店类型.getValue()));
            }
        }

        if(StrUtil.isNotBlank(userGatherApplyListParam.getTownShipId())){
            criteria.andEqualTo("townshipId",userGatherApplyListParam.getTownShipId());
        }

        if(StrUtil.isNotBlank(userGatherApplyListParam.getRelationUserId())){
            criteria.andEqualTo("relationUserId",userGatherApplyListParam.getRelationUserId());
        }

        boolean createFlag=true;
        if(StrUtil.isNotBlank(userGatherApplyListParam.getExamineTimeStart())){
            createFlag=false;
            criteria.andCondition("DATE_FORMAT(examine_time,'%Y-%m-%d')>=DATE_FORMAT('"+userGatherApplyListParam.getExamineTimeStart()+"','%Y-%m-%d')");
        }

        if(StrUtil.isNotBlank(userGatherApplyListParam.getExamineTimeEnd())){
            createFlag=false;
            criteria.andCondition("DATE_FORMAT(examine_time,'%Y-%m-%d')<=DATE_FORMAT('"+userGatherApplyListParam.getExamineTimeEnd()+"','%Y-%m-%d')");
        }

        if(StrUtil.isNotBlank(userGatherApplyListParam.getCreateTimeStart())){
            criteria.andCondition("DATE_FORMAT(create_time,'%Y-%m-%d')>=DATE_FORMAT('"+userGatherApplyListParam.getCreateTimeStart()+"','%Y-%m-%d')");
        }

        if(StrUtil.isNotBlank(userGatherApplyListParam.getCreateTimeEnd())){
            criteria.andCondition("DATE_FORMAT(create_time,'%Y-%m-%d')<=DATE_FORMAT('"+userGatherApplyListParam.getCreateTimeEnd()+"','%Y-%m-%d')");
        }

        if(createFlag) {
            example.setOrderByClause("create_time desc");
        }else {
            example.setOrderByClause("examine_time desc");
        }
        List<UserGatherApply> userGatherApplies = userGatherApplyMapper.selectByExample(example);

        for (UserGatherApply userGatherApply : userGatherApplies) {
            String itemTypes = userGatherApply.getItemTypes();
            //分类
            if(StrUtil.isNotBlank(itemTypes)){
                String[] split = itemTypes.split(",");
                List<SysEnvironmentalInfo> byIds = sysEnvironmentalInfoService.findByIds(split);
                if(CollUtil.isNotEmpty(byIds)) {
                    userGatherApply.setItemTypeNames(byIds.stream().map(x->x.getTitle()).collect(Collectors.joining(",")));
                }
            }
            //所属区域名称
            if(StrUtil.isNotBlank(userGatherApply.getTownshipId())) {
                AddressLevelInfo addressLevelInfo = addressLevelService.find(userGatherApply.getProvinceId(), userGatherApply.getCityId(), userGatherApply.getTownshipId());
                if (addressLevelInfo != null) {
                    userGatherApply.setTownshipName(addressLevelInfo.getLevel3Name());
                }
            }

            //所属推广员名称
            if(StrUtil.isNotBlank(userGatherApply.getRelationUserId())){
                String name = otherUserService.findById(userGatherApply.getRelationUserId()).getName();
                userGatherApply.setRelationUserName(name);
            }

            //审核人名称
            //所属推广员名称
            if(StrUtil.isNotBlank(userGatherApply.getUpdateUserId())) {
                OtherUserInfo byId = otherUserService.findById(userGatherApply.getUpdateUserId());
                if(byId!=null){
                    userGatherApply.setUpdateUserName(byId.getName());
                }else {
                    CoreUser coreUser = coreUserMapper.selectByPrimaryKey(userGatherApply.getUpdateUserId());
                    if(coreUser!=null){
                        userGatherApply.setUpdateUserName(coreUser.getName());
                    }
                }
            }

            String mobilePhone = userGatherApply.getMobilePhone();
            UserGatherApply userGatherApply1=new UserGatherApply();
            userGatherApply1.setMobilePhone(mobilePhone);
            int i = userGatherApplyMapper.selectCount(userGatherApply1);
            if(i>1){
                userGatherApply.setIsApply(true);
            }else{
                userGatherApply.setIsApply(false);
            }
        }

        return userGatherApplies;

    }


    public UserGatherApply findById(Long id){
        return userGatherApplyMapper.selectByPrimaryKey(id);
    }

    public void audit(UserGatherAuditParam userGatherAuditParam) {
        Long id = userGatherAuditParam.getId();
        String status = userGatherAuditParam.getStatus();
        UserGatherApply userGatherApply=new UserGatherApply();
        BeanUtil.copyProperties(userGatherAuditParam,userGatherApply);

        //审核通过
        if(CommonEnum.已审核.getValue().equals(status)){
            UserGatherApply byId = findById(id);
            String type = byId.getType();

            if(UserEnum.回收员类型.getValue().equals(type)){
                String relationId=auditOtherUser(byId);
                userGatherApply.setRelationId(relationId);
            }else if(UserEnum.废品店类型.getValue().equals(type)){
                String relationId=auditScrapStore(byId);
                userGatherApply.setRelationId(relationId);
            }else if(UserEnum.集货员类型.getValue().equals(type)) {
                String relationId=auditGather(byId);
                userGatherApply.setRelationId(relationId);
            }
        }
        //更新审核状态
        userGatherApply.setExamineTime(DateUtil.now());
        userGatherApplyMapper.updateByPrimaryKeySelective(userGatherApply);
    }
}