package com.xzx.gc.user.controller;

import cn.hutool.core.codec.Base64;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.Result;
import com.xzx.gc.common.annotations.valid.Insert;
import com.xzx.gc.common.annotations.valid.InsertExtend;
import com.xzx.gc.common.constant.CommonEnum;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.dto.SimplePage;
import com.xzx.gc.common.dto.log.OperationAppLog;
import com.xzx.gc.common.request.BaseController;
import com.xzx.gc.common.utils.MqUtil;
import com.xzx.gc.common.utils.RedisUtil;
import com.xzx.gc.entity.UserInfo;
import com.xzx.gc.entity.UserTargetInfo;
import com.xzx.gc.model.JsonResult;
import com.xzx.gc.model.admin.TargetUserModel;
import com.xzx.gc.model.user.UserInfoVo;
import com.xzx.gc.model.user.UserReq;
import com.xzx.gc.user.dto.*;
import com.xzx.gc.user.mapper.AddressMapper;
import com.xzx.gc.user.mapper.OtherUserMapper;
import com.xzx.gc.user.mapper.UserTargetInfoMapper;
import com.xzx.gc.user.service.UserService;
import com.xzx.gc.user.service.UserTargetInfoService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.Map;

@RestController
@Validated
@Slf4j
@Api(tags = "意向客户")
public class UserTargetInfoController extends BaseController {


    @Autowired
    private UserTargetInfoService userTargetInfoService;

    @Autowired
    private UserService userService;

    @Autowired
    private UserTargetInfoMapper userTargetInfoMapper;
    @Autowired
    private OtherUserMapper otherUserMapper;

    @Autowired
    private MqUtil mqUtil;



    @ApiOperation(value = "二维码扫描录入意向客户")
    @PostMapping("/targetInfo/acode")
    public Result acode(@Validated(value = {InsertExtend.class}) @RequestBody UserTargetInfoAddDto userTargetInfoAddDto,HttpServletRequest request) {

        Result result = new Result();
        if (org.apache.commons.lang3.StringUtils.isNotBlank(userTargetInfoAddDto.getNickName())) {
            if (!com.xzx.gc.common.utils.StringUtils.isBase64(userTargetInfoAddDto.getNickName())) {
                userTargetInfoAddDto.setNickName(Base64.encode(userTargetInfoAddDto.getNickName()));
            }
        }
        UserReq userReq = new UserReq();
        userReq.setMobilePhone(userTargetInfoAddDto.getMobile());
        List<UserInfoVo> list = userService.queryUserInfo(userReq);
        if (CollectionUtils.isEmpty(list)) {
            log.info("二维码扫描录入意向客户失败，该用户{}未注册", userReq.getMobilePhone());
        } else {
            UserTargetInfo userTargetInfo = new UserTargetInfo();
            BeanUtils.copyProperties(userTargetInfoAddDto, userTargetInfo);
            userTargetInfoService.acode(userTargetInfo);

//            String s = redisUtil.hget(Constants.REDIS_USER_KEY + "promoters:addr", userTargetInfoAddDto.getUserId());
//            if(StrUtil.isNotBlank(s)){
//                AddressDto addressDto = JSONUtil.toBean(s, AddressDto.class);
//                String lon = addressDto.getLongitude();
//                String lan= addressDto.getLatitude();
////                userTargetInfoService.updateTargetUserLon(userTargetInfoAddDto.getMobile(),lon,lan);
//            }
        }


        String mobilePhone = userService.findOtherByUserId(getUserId(request),0);
        OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
                .methodName(Constants.USER_MODUL_NAME).operateAction("二维码扫描录入意向客户-"+userTargetInfoAddDto.getMobile()).build();
        mqUtil.sendApp(build);

        return result;
    }

    @ApiOperation(value = "录入意向客户")
    @PostMapping("/targetInfo")
    public Result add(@Validated(value = {Insert.class}) @RequestBody UserTargetInfoAddDto userTargetInfoAddDto,HttpServletRequest request) {
        Result result = new Result();

        UserTargetInfo userTargetInfo = new UserTargetInfo();
        BeanUtils.copyProperties(userTargetInfoAddDto, userTargetInfo);

        //提交时用户已注册(不是通过该推广员注册的或自己注册的)---提示：提交失该用户已注册
        UserReq userReq = new UserReq();
        userReq.setMobilePhone(userTargetInfo.getMobile());
        List<UserInfoVo> list = userService.queryUserInfo(userReq);

        //判断该手机号是不是已录入
        List<UserTargetInfo> byMobile1 = userTargetInfoService.findByMobile(userTargetInfo.getMobile());
        if(CollUtil.isNotEmpty(byMobile1)){
            result.setCode(-1);
            result.setMsg("手机号码已重复录入");
            return result;
        }
        UserTargetInfo byMobile = userTargetInfoService.findByMobileAndUserId(userTargetInfo.getMobile(), userTargetInfo.getUserId());
        if (byMobile != null) {
            result.setCode(-1);
            result.setMsg("该用户您已录入");
        } else {
            if (!CollectionUtils.isEmpty(list)) {
                //自己注册的。
                result.setCode(-1);
                result.setMsg("提交失败，该用户已注册");
            } else {
                userTargetInfo.setRegsterType(1);
                userTargetInfoService.add(userTargetInfo);
            }
        }

        String mobilePhone = userService.findOtherByUserId(getUserId(request),0);
        OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
                .methodName(Constants.USER_MODUL_NAME).operateAction("录入意向客户-"+userTargetInfoAddDto.getMobile()).build();
        mqUtil.sendApp(build);


        return result;
    }



    @ApiOperation(value = "编辑客户信息")
    @PostMapping("/targetInfo/update")
    public Result update(@Validated @RequestBody UserTargetInfoEditDto userTargetInfoEditDto,HttpServletRequest request) {
        Result result = new Result();


        UserTargetInfo userTargetInfo = new UserTargetInfo();
        BeanUtils.copyProperties(userTargetInfoEditDto, userTargetInfo);

        if(Convert.toShort(1).equals(userTargetInfoEditDto.getTopFlag())){
            userTargetInfo.setTopFlagUser(request.getHeader("userId"));
        }

        UserTargetInfo userTargetInfo1 = userTargetInfoMapper.selectByPrimaryKey(userTargetInfoEditDto.getId());

        if (userTargetInfoEditDto.getOldMobile().equals(userTargetInfoEditDto.getMobile())) {

            if (userTargetInfo1.getRegsterType() != 1) {
                userTargetInfo.setMobile(null);
            }
            userTargetInfoService.update(userTargetInfo);
        } else {

            UserReq userReq = new UserReq();
            userReq.setMobilePhone(userTargetInfo.getMobile());
            List<UserInfoVo> list = userService.queryUserInfo(userReq);
            UserTargetInfo byMobile = userTargetInfoService.findByMobileAndUserId(userTargetInfo.getMobile(), userTargetInfo1.getUserId());
            if (byMobile != null) {
                result.setCode(-1);
                result.setMsg("该用户您已录入");
            } else {
                if (!CollectionUtils.isEmpty(list)) {
                    //自己注册的。
                    result.setCode(-1);
                    result.setMsg("提交失败，该用户已注册");
                } else {
                    if (userTargetInfo1.getRegsterType() != 1) {
                        userTargetInfo.setMobile(null);
                    }
                    userTargetInfoService.update(userTargetInfo);
                }
            }


        }


        String mobilePhone = userService.findOtherByUserId(getUserId(request),0);
        OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
                .methodName(Constants.USER_MODUL_NAME).operateAction("编辑客户信息-"+userTargetInfoEditDto.getId()).build();
        mqUtil.sendApp(build);

        return result;
    }


    @ApiOperation(value = "我的客户")
    @PostMapping("/targetInfo/list")
    public Result<PageInfo<UserTargetInfo>> list(HttpServletRequest request,@RequestBody UserTargetInfoFindDto userTargetInfoFindDto) {
        Result result = new Result();
        PageInfo<UserTargetInfo> list = userTargetInfoService.find(userTargetInfoFindDto);
        result.setData(list);
        return result;

    }

    @ApiOperation(value = "我的客户地图")
    @PostMapping("/targetInfo/map")
    public Result<List<UserInfo>> map(HttpServletRequest request, @RequestBody UserTargetInfoMapDto  userTargetInfoMapDto) {
        Result result = new Result();
        List<UserInfo> list = userTargetInfoService.map(userTargetInfoMapDto);
        result.setData(list);
        return result;

    }


    @ApiOperation(value = "推荐搜索",notes = "extra传用户类型")
    @PostMapping("/targetInfo/recommend")
    public Result<PageInfo<UserTargetInfo>> recommend(@RequestBody SimplePage simplePage,HttpServletRequest request) {
        Result result = new Result();
        String partnerId = otherUserMapper.selectByPrimaryKey(getUserId(request)).getPartnerId();
        PageHelper.startPage(simplePage.getPageNo(),simplePage.getPageSize());

        //运营员身份推荐搜索 按时间推荐成交的所有用户   推广员则只推荐自己成交的
        String userId=null;
        if(CommonEnum.推广员.getValue().equals(simplePage.getExtra())){
            userId=getUserId(request);
        }
        List<UserTargetInfo> list = userTargetInfoService.findOrderUser(userId,partnerId);
        result.setData(list);
        return result;
    }



    @ApiOperation(value = "统计")
    @PostMapping("/targetInfo/statistic")
    public Result<UserTargetInfoStatisticResDto> statisticPost( @RequestBody  UserTargetInfoStatisticDto userTargetInfoStatisticDto) {
        Result result = new Result();
        UserTargetInfoStatisticResDto userTargetInfoStatisticResDto = userTargetInfoService.statistic(userTargetInfoStatisticDto);
        result.setData(userTargetInfoStatisticResDto);

        return result;

    }

    @PostMapping("/admin/queryListMap.json")
    @ResponseBody
    public JsonResult<Map<String, Object>> queryListMap(@RequestBody  TargetUserModel model){
        Map<String, Object> result = userTargetInfoService.queryListMap(model);
        return JsonResult.success(result);

    }

}