package com.xzx.gc.user.controller;


import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
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.log.OperationAppLog;
import com.xzx.gc.common.request.BaseController;
import com.xzx.gc.entity.AccountInfo;
import com.xzx.gc.model.JsonResult;
import com.xzx.gc.model.admin.*;
import com.xzx.gc.user.mapper.AccountMapper;
import com.xzx.gc.user.service.AccountService;
import com.xzx.gc.user.service.CityPartnerService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

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

@Api(tags = "账户信息")
@RestController
@Validated
public class AccountController extends BaseController {

    @Autowired
    private AccountMapper accountMapper;

    @Autowired
    private AccountService accountService;

    @Autowired
    private CityPartnerService cityPartnerService;


    @ApiOperation( value = "查询当前用户的账户信息")
    @PostMapping("/account/find")
    public Result<AccountInfo> find(HttpServletRequest request) {
        AccountInfo accountInfo1 = accountService.findByUserId(getUserId(request));
        if(accountInfo1==null){
            return  Result.error(-1,"账户不存在");
        }
        accountInfo1.setPayPassword(null);
        return Result.success(accountInfo1);
    }

    @PostMapping( "/admin/front/account/queryPartnerAccountLog.json")
    @ApiOperation(value="后台账户资金流转接口", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="approverStatus", value = "审核状态(1为待审核,2为已审核,3为审核不通过)", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "数量", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "type", value = "类型", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> queryPartnerAccountLog(@RequestBody PartnerAccountLogModel model){
        Map<String,Object> map = cityPartnerService.queryPartnerAccountLog(model);
        return JsonResult.success(map);
    }

    @PostMapping("/admin/front/account/queryUserAccountLog.json")
    @ApiOperation(value="账户管理优化", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="szType", value = "收支类型（空为全部，1：收2：支出）", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "数量", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "channelType", value = "操作渠道1：充值 2：提现 3：回收 4入库 5红包 6分享返利 7重量达标返利8额度申请 9 额度恢复 10 推广返利 11垫付合伙人", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "userName", value = "姓名手机号", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "roleType", value = "角色类型", required = true, dataType = "int")

    })
    public JsonResult<Map<String,Object>> queryUserAccountLog(@RequestBody AccountLogModel model){
        Map<String,Object> map = cityPartnerService.queryUserAccountLog(model);
        return JsonResult.success(map);
    }

    /**
     *
     * @param model
     * @return
     */
    @PostMapping("/admin/front/account/queryAccountMoney.json")
    @ApiOperation(value="账户余额", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "数量", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "isProhibit", value = "冻结状态", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "roleType", value = "角色Type", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "partnerId", value = "合伙人ID", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "userName", value = "姓名手机号", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> queryAccountMoney(@RequestBody AccountMoneyModel model){

        if(StrUtil.isBlank(model.getPartnerId())){
            List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
            if(CollUtil.isNotEmpty(partnerIds)){
                model.setPartnerId(partnerIds.get(0));
            }
        }
        List<UserModel> userIds = new ArrayList<>();
        List<String> allUserIds = new ArrayList<>();
        boolean isNull = false;
        if(StrUtil.isNotBlank(model.getPartnerId())){
            //查询合伙人所有打包站的Id
            if(null!=model.getRoleType()&&!"".equals(model.getRoleType())){
                if(model.getRoleType().equals(CommonEnum.普通用户.getValue())){
//                    List<String> townIds = service.queryTownIdsByPartnerId(partnerIds.get(0));
//                    model.setTownIds(townIds);
                    userIds = cityPartnerService.queryUserNormal(model);
                }else{
                    List<String> packageStationList = cityPartnerService.queryPackageIdList(model.getPartnerId());
                    userIds = cityPartnerService.queryOtherUserByPid(model.getPartnerId(),model,packageStationList);
                    if(null!=userIds&&userIds.size()>0){

                    }else{
                        isNull=true;
                    }
                }
            }else{
                List<String> packageStationList = cityPartnerService.queryPackageIdList(model.getPartnerId());
                userIds = cityPartnerService.queryOtherUserByPid(model.getPartnerId(),model,packageStationList);
                //查询合伙人区域列表
//                List<String> townIds = service.queryTownIdsByPartnerId(partnerIds.get(0));
//                model.setTownIds(townIds);
                List<UserModel> nomalUserIds = cityPartnerService.queryUserNormal(model);
                userIds.addAll(nomalUserIds);
            }

        }else{
            if(null!=model.getRoleType()&&!"".equals(model.getRoleType())){
                if(model.getRoleType().equals("1")){
                    userIds = cityPartnerService.queryUserNormal(model);
                    model.setUserFlag(1);
                }else{
                    userIds = cityPartnerService.queryOtherUserByPid(null,model,null);
                    if(null!=userIds&&userIds.size()>0){
                    }else{
                        isNull=true;
                    }
                }
            }else{
                if(null!=model.getUserName()&&!"".equals(model.getUserName())){
                    userIds = cityPartnerService.queryUserNormal(model);
                    List<UserModel> userIdsOth  = cityPartnerService.queryOtherUserByPid(null,model,null);
                    if(null!=userIdsOth&&userIdsOth.size()>0){
                        for (UserModel ou:userIdsOth) {
                            userIds.add(ou);
                        }
                    }
                }
            }
        }

        List<String> uid = new ArrayList<>();
        if(null!=userIds&&userIds.size()>0){
            for (UserModel mm:userIds) {
                uid.add(mm.getUserId());
            }
        }else{
            if(!isNull){
                if(model.getRoleType().equals("8")){
                    uid.add("0");
                }else{
                    uid = null;
                }
            }else{
                uid.add("0");
            }
        }

        model.setUserIds(uid);

        PageInfo<AccountMoneyModel> pageInfo = cityPartnerService.queryAccountByUserIds(model);
        Map<String,Object> map = new HashMap<>();
        map.put("data",pageInfo.getList());
        map.put("count",pageInfo.getTotal());
        map.put("code",0);
        return JsonResult.success(map);
    }

    @PostMapping( "/admin/front/account/updateAccountLimit.json")
    @ApiOperation(value="调整额度", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="accountId", value = "账户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "fixedLimit", value = "固定额度", required = true, dataType = "int")
    })
    public JsonResult<String> updateAccountLimit(@RequestBody AccountMoneyModel model,HttpServletRequest request){
        int num = cityPartnerService.updateAccountLimit(model);
        if(num>0){
            OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                    .methodName(Constants.ORDER_MODUL_NAME).operateAction("调整额度-"+model.getAccountId()).build();
            mqUtil.sendApp(build);
            return JsonResult.success("修改成功！");
        } else if (num == -1) {
            return JsonResult.failMessage("可用额度不足，调额失败！");
        }else if(num == -2){
            return JsonResult.failMessage("固定额度没有改变，调额失败！");

        }else {
            return JsonResult.failMessage("额度必须由合伙人修改，所以修改失败！");
        }
    }


    @PostMapping("/admin/front/account/updateAccountType.json")
    @ApiOperation(value="修改账户冻结状态", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="accountId", value = "账户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "isProhibit", value = "冻结状态 0：未冻结，1：冻结", required = true, dataType = "int")
    })
    public JsonResult<String> updateAccountType(@RequestBody AccountMoneyModel model,HttpServletRequest request){
        int num = cityPartnerService.updateAccountType(model);
        if(num>0){
            OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                    .methodName(Constants.ORDER_MODUL_NAME).operateAction("修改账户冻结状态-"+model.getAccountId()).build();
            mqUtil.sendApp(build);
            return JsonResult.success("修改成功");
        }else{
            return JsonResult.success("修改失败");
        }
    }

    @PostMapping( "/admin/front/account/queryAllType.json")
    @ApiOperation(value="类型返回", notes="test: 仅0有正确返回")
    public JsonResult<Map<String,Object>> queryAllType(@RequestBody RoleTypeModel model){
        List<Map<String,Object>> list = cityPartnerService.queryAllType(model);
        Map<String,Object> map = new HashMap<>();
        map.put("data",list);
        map.put("code",0);
        return JsonResult.success(map);
    }
}