package com.xzx.gc.order.service;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import com.xzx.gc.common.Result;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.constant.OrderEnum;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.common.utils.JGPushUtil;
import com.xzx.gc.common.utils.RedisUtil;
import com.xzx.gc.common.utils.SecurityUtil;
import com.xzx.gc.common.utils.gdmap.GdMapUtil;
import com.xzx.gc.entity.CoreUser;
import com.xzx.gc.entity.Fence;
import com.xzx.gc.entity.OtherUserInfo;
import com.xzx.gc.entity.UserInfo;
import com.xzx.gc.model.admin.*;
import com.xzx.gc.order.mapper.*;
import com.xzx.gc.util.ChineseToSpell;
import com.xzx.gc.util.SessionUtil;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
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;

@Service
@Transactional
public class UserService {

    @Autowired
    private UserMapper userMapper;

    @Autowired
    private BusinessUtil businessUtil;

    @Autowired
    private OtherUserService otherUserService;

    @Autowired
    private HttpServletRequest request;

    @Autowired
    private AddressLevelService addressLevelService;

    @Autowired
    private FenceService fenceService;

    @Autowired
    private AddressService addressService;

    @Autowired
    private AddressMapper addressMapper;

    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private OrderDetailMapper orderDetailMapper;

    @Autowired
    private OrderItemInfoMapper orderItemInfoMapper;

    @Autowired
    private RedisUtil redisUtil;

    @Autowired
    private SessionUtil sessionUtil;

    @Autowired
    private JGPushUtil jgPushUtil;

    @Autowired
    private AccountMapper accountMapper;

    public UserInfo findByMobile(String mobilePhone){
        UserInfo userInfo = new UserInfo();
        userInfo.setMobilePhone(mobilePhone);
        userInfo.setDelFlag(Constants.DEL_NOT_FLAG);
        userInfo.setIsProhibit(false);
        UserInfo userInfo1 = userMapper.selectOne(userInfo);
        return userInfo1;
    }




    public UserInfo findById(String userId){
        return userMapper.selectByPrimaryKey(userId);
    }


    public List<UserInfo> findForBidden(){
        UserInfo userInfo = new UserInfo();
        userInfo.setDelFlag(Constants.DEL_NOT_FLAG);
        List<UserInfo> userInfo1 = userMapper.select(userInfo);
        return userInfo1;
    }

    public List<UserInfo> findForBiddenByTime(){
        Example example=new Example(UserInfo.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("delFlag",Constants.DEL_NOT_FLAG);
        criteria.andCondition("DATE_FORMAT(regist_time,'%Y-%m-%d')=date_sub(CURRENT_DATE(), interval 1 day)");
        List<UserInfo> userInfo1 = userMapper.selectByExample(example);
        return userInfo1;
    }

    public List<UserInfo> findHaveAddr(){
        return userMapper.findHaveAddr();
    }

    public List<UserInfo> findByIds(List<String> ids){
        if(CollUtil.isEmpty(ids)){
            return new ArrayList<>();
        }else {
            Example example = new Example(UserInfo.class);
            Example.Criteria criteria = example.createCriteria();
            criteria.andIn("userId", ids);
            criteria.andEqualTo("delFlag", Constants.DEL_NOT_FLAG);
            criteria.andEqualTo("isProhibit", Constants.DEL_NOT_FLAG);
            List<UserInfo> userInfos = userMapper.selectByExample(example);
            return userInfos;
        }
    }


    public void update(UserInfo userInfo){
        userMapper.updateByPrimaryKeySelective(userInfo);
    }


    public void updatePartnerId(String userId,String partnerId){
        UserInfo byId = findById(userId);
        if(StrUtil.isBlank(byId.getPartnerId())){
            UserInfo userInfo=new UserInfo();
            userInfo.setUserId(byId.getUserId());
            userInfo.setPartnerId(partnerId);
            update(userInfo);
        }else {
            userMapper.updatePartnerId(userId, partnerId);
        }
    }

    /**
     * 查询手机号码
     * @param userId
     * @param type    类型 0普通用户 1平台用户
     * @return
     */
    public String findOtherByUserId(String userId,int type){
        if (businessUtil.isApp(request.getHeader("clientType"))) {
            OtherUserInfo byId = otherUserService.findById(userId);
            if(byId!=null)return byId.getMobilePhone();
        }else{
            UserInfo byId = findById(userId);
            if(byId!=null)return byId.getMobilePhone();
        }
        return "未知";
    }

    public List<UserModel> queryUserByPhoneNormal(String phone, String normal){
        String nickName="";
        if(!StringUtils.isEmpty(phone)){
                nickName = com.xzx.gc.common.utils.StringUtils.decode(phone);
        }
        List<UserModel> userModel = userMapper.queryUserByUsertypeList(phone, "1", "0",normal,nickName);
        return userModel;
    }

    public UserModel insertUserInfo(OrderModel orderModel,  List<String> keys, String isNomal){
        String orderType = orderModel.getOrderType();
        UserModel userModel = new UserModel();
        Snowflake snowflake = IdUtil.getSnowflake(0, 3);
        String orderId= com.xzx.gc.util.DateUtil.generate("DD", 1);
        userModel.setOrderId(orderId);
        String townCode =addressLevelService.findByLevle3Name(orderModel.getTownshipId());
        String eleId1 = checkGaodeEleId(orderModel.getLongitude(),orderModel.getLatitude(),orderId,keys.get(0));
        Fence tEId = fenceService.findByGidForbidden(eleId1);
        if(null!=tEId){
            eleId1=tEId.getId().toString();
        }else{
            List<String> townList = fenceService.queryOrderTownListByArea(townCode,null);
            if(townList.size()>0){
                eleId1 = townList.get(0);
            }
        }

        userModel.setUserType("1");
        userModel.setMobilePhone(orderModel.getMobilePhone());
        if(!StringUtils.isEmpty(orderModel.getNickName())){
            userModel.setNickName(new String(Base64.encodeBase64(orderModel.getNickName().getBytes())));
        }
        if(isNomal.equals("0")){
            String salt = RandomUtil.randomString(16);
            String pass = SecurityUtil.encrypt(salt,"123456");
            userModel.setSalt(salt);
            userModel.setPassword(pass);
            userModel.setOrderNum(0);
            userModel.setDelFlag("0");
        }
        //添加地址
        String proviceId =addressLevelService.findIdByName("1",orderModel.getProvinceId());
        String cityId =addressLevelService.findIdByName("2",orderModel.getCityId());
        String townId =addressLevelService.findIdByName("3",orderModel.getTownshipId());

        if(null==proviceId){
            proviceId = orderModel.getProvinceId();
        }
        if(null==cityId){
            cityId = orderModel.getCityId();
        }
        if(null==townId){
            townId = orderModel.getTownshipId();
        }
        userModel.setProvince(ChineseToSpell.getPingYin(orderModel.getProvinceId()));
        userModel.setCity(ChineseToSpell.getPingYin(orderModel.getCityId()));

        userModel.setLongitude(orderModel.getLongitude());
        userModel.setLatitude(orderModel.getLatitude());
        //判断是否为第一次电话下单用户
        String userType = "1";
        UserModel oldUserModel = new UserModel();
        if(isNomal.equals("0")){

            oldUserModel =userMapper.queryUserByUsertype(orderModel.getMobilePhone(), userType,"0","3",null);
        }else{
            oldUserModel =userMapper.queryUserByUsertype(orderModel.getMobilePhone(), userType,"0",null,null);
        }
        if(oldUserModel != null){
            userModel.setRegistType(oldUserModel.getRegistType());
            userModel.setUserId(oldUserModel.getUserId());
            userMapper.updateUserInfo(userModel);
            //更改用户合伙人
            updatePartnerId(oldUserModel.getUserId(),oldUserModel.getPartnerId());

            //删除用户老地址
            addressService.deleteByUserId(oldUserModel.getUserId());
            if(null!=orderModel.getOrderId()&&!"".equals(orderModel.getOrderId())){

            }else{
                orderModel.setOrderId(orderId);
            }
            orderModel.setUserId(oldUserModel.getUserId());
            UserAddressModel userAddressModel = insertUserAddress(orderModel,oldUserModel.getUserId(),cityId,proviceId,townId);
            orderModel.setAddressId(userAddressModel.getAddressId());
            orderModel.setCreateUserId(userModel.getNickName());
            //添加订单，订单详情，订单物品表
            insertOrder(orderModel,eleId1);
            //发队列 和更新redis缓存
            sendOperationLog(orderModel);
//            String tag=Constants.GRAB_ORDER_TAG;
//            //极光推送发抢单
//            if(OrderEnum.家电回收.getValue().equals(orderType)){
//                tag=Constants.GRAB_ORDER_HOME_TAG;
//            }
//            jgPushUtil.pushNewOrder(tag,townId);

            //}
        }else{
            String userId= com.xzx.gc.util.DateUtil.generate("YH", 3);
            userModel.setUserId(userId);
            userModel.setPartnerId(orderModel.getPartnerId());
            if(userMapper.insertUserInfo(userModel)>0){
                //新建普通用户账号
                String id="ZH"+snowflake.nextIdStr();
                String value = "0";
                orderModel.setOrderId(orderId);
                String point = orderModel.getLongitude()+","+orderModel.getLatitude();
                //判断是否在围栏中
                boolean bool = false;
                if(null!=eleId1&&!"".equals(eleId1)){
                    bool = true;
                }else{
                    String  gid="";
                    for (String key:keys){
                        gid = checkElectricByLocations(orderId,key,point);
                        if(StrUtil.isNotBlank(gid)){
                            bool = true;
                            break;
                        }
                    }
                    if(!bool){
                        return  null;
                    }
                    //查询电子围栏Id
                    //eleId = dao.queryEleIdByGid(gid);
                }
                accountMapper.addCuserAccountRole(id, orderModel.getMobilePhone(), userId,value);
                UserAddressModel userAddressModel = insertUserAddress(orderModel,userId,cityId,proviceId,townId);
                orderModel.setUserId(userId);
                //添加订单，订单详情，订单物品表
                orderModel.setAddressId(userAddressModel.getAddressId());
                orderModel.setCreateUserId(userModel.getNickName());

                insertOrder(orderModel,eleId1);
                //发队列 和更新redis缓存
                sendOperationLog(orderModel);
                //极光推送发抢单
//                jgPushUtil.pushNewOrder(townId);
            }
        }

        return userModel;
    }


    private void sendOperationLog(OrderModel orderModel){
        OrderOperationLogModel operationLogModel = new OrderOperationLogModel();
        operationLogModel.setOrderId(orderModel.getOrderId());
        operationLogModel.setOperateContent("创建订单");
        operationLogModel.setOrderStatus("1");
        operationLogModel.setOrderSecondStatus("1");
        operationLogModel.setOperateTime(DateUtil.now());
        CoreUser user = sessionUtil.getCurrentUser();
        operationLogModel.setOperateUserId(String.valueOf(user.getId()));
        redisUtil.set("xzx:order:status:"+orderModel.getOrderId(),"0");
    }

    private void insertOrder(OrderModel orderModel,String townId){
        //String orderId=DateUtil.generate("DD", 1);
        //orderModel.setOrderId(orderId);
        orderModel.setReserveTime(orderModel.getReserveDay()+" "+orderModel.getReserveDate()+":00");
        orderModel.setCreateUserId(orderModel.getUserId());
        orderModel.setTownshipId(townId);
        orderModel.setOrderStatus("1");
        if(null!=orderModel.getStoreId()&&!"".equals(orderModel.getStoreId())){
            orderMapper.addOrderInfoApi(orderModel);

        }else{
            orderModel.setStoreId(null);
            orderMapper.addOrderInfoApi(orderModel);

        }

        orderDetailMapper.addOrderDetailApi(orderModel);
        if(!StringUtils.isEmpty(orderModel.getItemIds())){
            String itemIds = orderModel.getItemIds();
            String[] items = itemIds.split(",");
            List<OrderItemModel> list = new ArrayList<>();
            for (String itemType:items) {
                OrderItemModel itemModel = new OrderItemModel();
                itemModel.setOrderId(orderModel.getOrderId());
                itemModel.setItemType(itemType);
                list.add(itemModel);
            }
            orderItemInfoMapper.addOrderItem(list);
        }
    }

    /**
     * 添加地址表
     * @param orderModel
     * @param userId
     * @return
     */
    private UserAddressModel insertUserAddress(OrderModel orderModel,String userId,String cityId,String proviceId,String townId){
        //添加地址
        UserAddressModel addressModel = new UserAddressModel();
        addressModel.setAddressArea(orderModel.getAddressArea());
        addressModel.setMobilePhone(orderModel.getMobilePhone());
        addressModel.setCityId(cityId);
        addressModel.setProvinceId(proviceId);
        addressModel.setDetailAddress(orderModel.getDetailAddress());
        addressModel.setLatitude(orderModel.getLatitude());
        addressModel.setLongitude(orderModel.getLongitude());
        addressModel.setTownshipId(townId);
        addressModel.setUserId(userId);
        addressModel.setRelaPhone(orderModel.getMobilePhone());
        addressModel.setRelaName(orderModel.getNickName());
        addressMapper.insertUserAddress(addressModel);
        addressModel = addressMapper.queryUserAddressInfo(userId,orderModel.getMobilePhone());
        return addressModel;
    }

    private String checkElectricByLocations(String orderId,String keys,String point){
        Result inFence = GdMapUtil.isInFence(point + "," + DateUtil.currentSeconds(), GdMapUtil.getDiu(orderId),keys);
        if(inFence.getCode()==0) {
            //设置围栏id
            return inFence.getData().toString();
        }else {
            return null;
        }

    }


    public String checkGaodeEleId(String longitude,String latitude,String receiverId,String key){

        Result inFence = GdMapUtil.isInFence(longitude + "," + latitude + "," + cn.hutool.core.date.DateUtil.currentSeconds(), GdMapUtil.getDiu(receiverId),key);
        if(inFence.getCode()==0){
            return inFence.getData().toString();
        }
        return null;
    }
}