package com.xzx.gc.user.controller;


import cn.hutool.core.bean.BeanUtil;
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.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.entity.OtherUserInfo;
import com.xzx.gc.entity.UserVehicleRel;
import com.xzx.gc.entity.VehicleInfo;
import com.xzx.gc.model.JsonResult;
import com.xzx.gc.model.admin.UserModel;
import com.xzx.gc.model.admin.VehicleModel;
import com.xzx.gc.user.dto.VehicleUpdateDto;
import com.xzx.gc.user.mapper.OtherUserMapper;
import com.xzx.gc.user.mapper.SysStorageMapper;
import com.xzx.gc.user.mapper.UserVehicleRelMapper;
import com.xzx.gc.user.mapper.VehicleInfoMapper;
import com.xzx.gc.user.service.*;
import com.xzx.gc.util.ConvertUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import tk.mybatis.mapper.entity.Example;

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

@Api(tags = "车辆管理")
@RestController
@Validated
public class VehicleController extends BaseController {


    @Autowired
    private VehicleInfoMapper vehicleInfoMapper;


    @Autowired
    private UserVehicleRelMapper userVehicleRelMapper;
    
    @Autowired
    private UserVehicleRelService userVehicleRelService;
    
    @Autowired
    private VehicleInfoService vehicleInfoService;

    @Autowired
    private OtherUserMapper otherUserMapper;

    @Autowired
    private UserService userService;

    @Autowired
    private OtherUserService otherUserService;
    @Autowired
    private CityPartnerService cityPartnerService;


    @ApiOperation( value = "分页查询车辆信息")
    @PostMapping("/vehicle/select")
    public Result<PageInfo<VehicleInfo>> find(HttpServletRequest request, @RequestBody SimplePage simplePage) {
        String partnerId = otherUserMapper.selectByPrimaryKey(getUserId(request)).getPartnerId();
        PageHelper.startPage(simplePage.getPageNo(),simplePage.getPageSize());
        List<VehicleInfo> select =  vehicleInfoMapper.findByPartnerId(partnerId);
        if(CollUtil.isNotEmpty(select)){
            for (VehicleInfo info : select) {
                //仓库信息
//                Integer storageId = info.getStorageId();
//                SysStorage sysStorage = sysStorageMapper.selectByPrimaryKey(storageId);
//                if(sysStorage!=null){
//                    info.setStorageName(sysStorage.getStorageName());
//                }

                //回收员信息
                UserVehicleRel userVehicleRel=new UserVehicleRel();
                userVehicleRel.setDelFlag(Convert.toShort(Constants.DEL_NOT_FLAG));
                userVehicleRel.setVehicleId(info.getId());
                List<UserVehicleRel> select1 = userVehicleRelMapper.select(userVehicleRel);
                if(CollUtil.isNotEmpty(select1)){
                    String userId = select1.get(0).getUserId();
                    OtherUserInfo otherUserInfo = otherUserMapper.selectByPrimaryKey(userId);
                    if(otherUserInfo!=null){
                        info.setUserName(otherUserInfo.getName());
                        info.setUserId(otherUserInfo.getUserId());
                    }

                }

            }
        }
        PageInfo<VehicleInfo> pageInfo=new PageInfo<>(select);
        return Result.success(pageInfo);
    }


    @ApiOperation( value = "修改车辆绑定信息")
    @PostMapping("/vehicle/update")
    public Result update(HttpServletRequest request, @RequestBody VehicleUpdateDto vehicleUpdateDto) {
        VehicleInfo vehicleInfo=new VehicleInfo();
        BeanUtil.copyProperties(vehicleUpdateDto,vehicleInfo);
        vehicleInfoMapper.updateByPrimaryKeySelective(vehicleInfo);

        //修改人与车辆的绑定
        UserVehicleRel userVehicleRel=new UserVehicleRel();
        userVehicleRel.setUserId(vehicleUpdateDto.getUserId());

        Example example=new Example(UserVehicleRel.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("vehicleId",vehicleUpdateDto.getId());
        userVehicleRelMapper.updateByExampleSelective(userVehicleRel,example);

        String mobilePhone = userService.findOtherByUserId(getUserId(request),0);
        OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
                .methodName(Constants.USER_MODUL_NAME).operateAction("修改车辆绑定信息-"+vehicleUpdateDto.getId()).build();
        mqUtil.sendApp(build);

        return Result.success(null);
    }

    @PostMapping( "/admin/front/vehicle/vehicleList.do")
    @ResponseBody
    @ApiOperation(value="运营管理-车辆管理", notes="test: 仅0有正确返回")
    public JsonResult<Map<String, Object>> vehicleList(@RequestBody VehicleModel model)
    {
        Map<String, Object> map =  vehicleInfoService.queryByVehicleInfoList(model.getVehicleNo(),model.getPage(),model.getLimit(),model.getPartnerId());
        return JsonResult.success(map);
    }


    @PostMapping( "/admin/front/vehicle/checkUserNameByPhone.json")
    @ResponseBody
    @ApiOperation(value="运营管理-车辆管理添加(校验回收员)", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "mobilePhone", value = "车辆编号", required = true, dataType = "String")
    })
    public JsonResult<Map<String, Object>> checkUserNameByPhone(@RequestBody UserModel model)
    {
        Map<String,Object> map = new HashMap<>();
        String userType = "2";
        OtherUserInfo userModel = otherUserService.findByMobileAndUserType(model.getMobilePhone(), userType);
        if(null!=userModel){
            map.put("code",0);
            map.put("msg","查询成功");
            map.put("userId",userModel.getUserId());
            map.put("mobilePhone",userModel.getMobilePhone());
            map.put("name",userModel.getName());
            map.put("nickName", Base64.decodeStr(userModel.getNickName()));
        }else{
            map.put("code",-1);
            map.put("msg","没有该手机号的回收员");
        }

        return JsonResult.success(map);
    }


    @PostMapping( "/admin/front/vehicle/queryAllOtherUserApiByName.json")
    @ApiOperation(value="运营管理-车辆管理添加(回收员列表)", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "userId", value = "用户Id", required = true, dataType = "String")
    })
    public JsonResult<List<Map<String, Object>>>  queryAllOtherUserByName(@RequestBody UserModel model) {
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        List<Map<String, Object>> otherUser = userVehicleRelMapper.queryCuserListByName(model.getUserId(),partnerIds);
        return JsonResult.success(otherUser);

    }


    @PostMapping( "/admin/front/vehicle/vehicleInfoadd.json")
    @ApiOperation(value="运营管理-车辆管理添加", notes="test: 仅0有正确返回")
    public JsonResult vehicleInfoadd(@RequestBody VehicleModel model, HttpServletRequest request)
    {
        Long aLong = vehicleInfoService.addVehicleInfo(model);

        OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                .methodName(Constants.USER_MODUL_NAME).operateAction("添加车辆-"+aLong).build();
        mqUtil.sendApp(build);

        return new JsonResult().success();
    }

    @PostMapping( "/admin/front/vehicle/editVehicleIn.json")
    @ApiOperation(value="运营管理-车辆管理编辑", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "id", value = "车辆管理Id", required = true, dataType = "Long"),
            @ApiImplicitParam(paramType="query", name = "relId", value = "车辆管理和用户关联ID", required = true, dataType = "Long"),
            @ApiImplicitParam(paramType="query", name = "userId", value = "用户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "weight", value = "重量", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "vehicleNo", value = "车辆编号", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "storageId", value = "仓库Id", required = true, dataType = "String")

    })
    public JsonResult<String> editVehicleIn(@RequestBody VehicleModel model, HttpServletRequest request) {
        String userId = model.getUserId();
        String relId = model.getRelId();
        VehicleInfo oldInfo = vehicleInfoService.queryById(model.getId());
        oldInfo.setWeight(model.getWeight());
        oldInfo.setVehicleNo(model.getVehicleNo());
        if(model.getStorageId()!=null){
            oldInfo.setStorageId(Integer.parseInt(model.getStorageId()));

        }else{
            return JsonResult.failMessage("保存失败,仓库Id为空！");
        }
        boolean success = vehicleInfoService.update(oldInfo);
        if (success) {
            UserVehicleRel rel = userVehicleRelService.queryById(Long.parseLong(relId));
            rel.setDelFlag((short)0);
            rel.setUserId(userId);
            userVehicleRelService.update(rel);

            OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                    .methodName(Constants.USER_MODUL_NAME).operateAction("车辆管理编辑-"+model.getId()).build();
            mqUtil.sendApp(build);

            return new JsonResult().success();
        } else {
            return JsonResult.failMessage("保存失败");
        }
    }

    @PostMapping("/admin/front/vehicle/delete.json")
    @ApiOperation(value="运营管理-车辆管理删除", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "query", name = "ids", value = "车辆Id,多个id用逗号分割", required = true, dataType = "String")
    })
    public JsonResult delete(@RequestBody VehicleModel model,HttpServletRequest request) {
        String ids = model.getIds();
        if (ids.endsWith(",")) {
            ids = StringUtils.substringBeforeLast(ids, ",");
        }
        List<Long> idList = ConvertUtil.str2longs(ids);
        vehicleInfoService.batchDelXzxUserVehicleInfo(idList);

        OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                .methodName(Constants.ORDER_MODUL_NAME).operateAction("车辆管理删除-"+model.getIds()).build();
        mqUtil.sendApp(build);
        return new JsonResult().success();
    }
}