package com.xzx.gc.user.controller;


import cn.hutool.core.collection.CollUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.Result;
import com.xzx.gc.common.annotations.PassToken;
import com.xzx.gc.common.constant.CommonEnum;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.constant.UserEnum;
import com.xzx.gc.common.dto.log.OperationAppLog;
import com.xzx.gc.common.request.BaseController;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.common.utils.SpringUtil;
import com.xzx.gc.entity.OtherUserInfo;
import com.xzx.gc.entity.UserGatherApply;
import com.xzx.gc.entity.UserGatherInfo;
import com.xzx.gc.entity.UserScrapStore;
import com.xzx.gc.model.IdDTO;
import com.xzx.gc.model.user.UserGatherApplyListParam;
import com.xzx.gc.model.user.UserGatherAuditParam;
import com.xzx.gc.user.service.OtherUserService;
import com.xzx.gc.user.service.UserGatherApplyService;
import com.xzx.gc.user.service.UserGatherInfoService;
import com.xzx.gc.user.service.UserScrapStoreService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

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


@RestController
@Validated
@Slf4j
@Api(tags = "外驻人员申请审核管理")
public class UserGatherApplyController extends BaseController {


    @Autowired
    private UserGatherApplyService userGatherApplyService;

    @Autowired
    private BusinessUtil businessUtil;

    @Autowired
    private OtherUserService otherUserService;

    @Autowired
    private UserGatherInfoService userGatherInfoService;

    @Autowired
    private UserScrapStoreService userScrapStoreService;


    @PostMapping("/userGatherApply/apply")
    @ApiOperation(value = "外驻人员提交申请")
    @PassToken
    public Result userGatherApply(HttpServletRequest request, @RequestBody UserGatherApply userGatherApply) {
        String mobilePhone = userGatherApply.getMobilePhone();
        String code = userGatherApply.getCode();
        //1:集货员申请 2：回收员申请 3：废品店申请
        String type = userGatherApply.getType();

        boolean b = businessUtil.checkSmsCode(code, mobilePhone);

        if(!b){
            return Result.error("验证码不正确");
        }

        List<UserGatherApply> byMobile = userGatherApplyService.findByMobileAndType(mobilePhone,type);
        if(CollUtil.isNotEmpty(byMobile)){

            if(byMobile.stream().filter(x->x.getStatus().equals(CommonEnum.待审核.getValue())).count()>0){
                return Result.error("当前手机号正在审核中");
            }
        }

        //查询是否存在集货员、回收员、废品站等身份
        List<OtherUserInfo> byMobileForBidden = otherUserService.findByMobileForBidden(mobilePhone);
        if(CollUtil.isNotEmpty(byMobileForBidden)){
            return Result.error("当前手机号已被平台用户注册");
        }

        UserGatherInfo userGatherInfo = userGatherInfoService.findByMobileForBidden(mobilePhone);
        if (userGatherInfo != null) {
            return Result.error("当前手机号已被集货员注册");
        }

        UserScrapStore userScrapStore = userScrapStoreService.findByMobile(mobilePhone);
        if (userScrapStore != null) {
            return Result.error("当前手机号已被废品站注册");
        }

        userGatherApplyService.apply(userGatherApply);
        OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(userGatherApply.getMobilePhone())
                .methodName(Constants.USER_MODUL_NAME).operateAction("外驻人员提交申请-"+userGatherApply.getMobilePhone()).build();
        mqUtil.sendApp(build);
        return Result.success("申请成功，请重新登录");
    }

    @PostMapping(value = {"/userGatherApply/list","/admin/front/userGatherApply/list"})
    @ApiOperation(value = "外驻审核列表")
    public Result<PageInfo<UserGatherApply>> userGatherApplyList(HttpServletRequest request, @RequestBody UserGatherApplyListParam userGatherApplyListParam) {
        PageHelper.startPage(userGatherApplyListParam.getPageNo(),userGatherApplyListParam.getPageSize());
        boolean mobile = isMobile(request);
        if(mobile){
            userGatherApplyListParam.setClientType(CommonEnum.app.getValue());
        }
        List<UserGatherApply> list=userGatherApplyService.list(userGatherApplyListParam);
        return Result.success(new PageInfo<>(list));
    }

    @PostMapping(value = {"/userGatherApply/audit","/admin/front/userGatherApply/audit"})
    @ApiOperation(value = "外驻人员审核")
    public Result userGatherAudit(HttpServletRequest request, @RequestBody UserGatherAuditParam userGatherAuditParam) {

        //审核
        userGatherApplyService.audit(userGatherAuditParam);


        if(isMobile(request)){
            String mobilePhone = otherUserService.findById(getUserId(request)).getMobilePhone();
            OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
                    .methodName(Constants.USER_MODUL_NAME).operateAction("外驻人员审核-" + userGatherAuditParam.getId()).build();
            mqUtil.sendApp(build);
        }else {
            OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                    .methodName(Constants.USER_MODUL_NAME).operateAction("外驻人员审核-" + userGatherAuditParam.getId()).build();
            mqUtil.sendApp(build);
        }
        return Result.success();
    }


}