jzg/partner/src/main/java/com/jzg/controller/PartnerUserController.java

package com.jzg.controller;


import cn.hutool.extra.spring.SpringUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.jzg.commons.core.base.BaseController;
import com.jzg.commons.core.page.HttpResult;
import com.jzg.commons.entity.po.SysUserJzgInfo;
import com.jzg.commons.entity.vo.SysUserVo;
import com.jzg.entity.PartnerUser;
import com.jzg.entity.param.QueryVo;
import com.jzg.entity.param.UserGradeParam;
import com.jzg.service.PartnerUserService;
import com.jzg.utils.ContactQrCodeUtils;
import com.jzg.utils.TimedTaskUtils;
import com.jzg.utils.UpdateRatioUtils;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;
import java.util.Map;


/**
 * 合伙人
 */
@RestController
@RequestMapping("/partner")
@RequiredArgsConstructor
public class PartnerUserController extends BaseController {


    @Autowired
    private PartnerUserService partnerUserService;

    @PostMapping("commissionInitialization")
    public void commissionInitialization(@RequestBody List<String> infoId){
         partnerUserService.commissionInitialization(infoId);
    }

    @PostMapping("teamInvitation")
    public boolean teamInvitation(@RequestBody SysUserJzgInfo info) {
        return partnerUserService.teamInvitation(info);
    }

    @GetMapping("isTherePartner")
    public HttpResult isTherePartner(@RequestParam String userId, @RequestParam String systemCode) {
        return partnerUserService.isTherePartner(userId, systemCode);
    }

    @PostMapping("addPartnerRule")
    public HttpResult addPartnerRule(@RequestBody SysUserVo sysUserVo) {
        return partnerUserService.addPartnerRule(sysUserVo, sysUserVo.getGradeList(), getToken());
    }

    @GetMapping("partnerDetails")
    public HttpResult partnerDetails(@RequestParam String userId) {
        return partnerUserService.partnerDetails(userId);
    }

    @GetMapping("searchUserStudios")
    public PartnerUser searchUserStudios(@RequestParam String userId) {
        return partnerUserService.searchUserStudios(userId);
    }


    @GetMapping("enableDisable")
    public HttpResult enableDisable(@RequestParam("userId") String userId, @RequestParam("status") boolean status) {
        return partnerUserService.enableDisable(userId, status, getToken());
    }


    @PostMapping("/save")
    public HttpResult<String> add(@RequestBody PartnerUser partnerUser) {
        boolean exists = partnerUserService.exists(new LambdaQueryWrapper<>(PartnerUser.class).eq(PartnerUser::getUserId, partnerUser.getUserId())
                .eq(PartnerUser::getGrade, partnerUser.getGrade()));
        if (exists) {
            return HttpResult.error("已存在业务员身份");
        }
        return HttpResult.ok(partnerUserService.save(partnerUser) ? "添加成功" : "添加失败");
    }


    @PostMapping("/update")
    public HttpResult update(@RequestBody PartnerUser partnerUser) {
        return HttpResult.ok(partnerUserService.updateById(partnerUser) ? "修改成功" : "修改失败");
    }


    @PostMapping("/queryPage")
    public HttpResult queryPage(@RequestBody QueryVo queryVo) {
        return HttpResult.ok(partnerUserService.queryPage(queryVo));
    }

    /**
     * 用户关系查询
     *
     * @param id
     * @returns
     */
    @GetMapping("relationalQuery")
    public HttpResult relationalQuery(@RequestParam("id") String id) {
        return HttpResult.ok(partnerUserService.relationalQuery(id));
    }


    /**
     * 选择上级推荐人
     *
     * @param level
     * @return
     */
    @GetMapping("selectRecommender")
    public HttpResult selectRecommender(@RequestParam(value = "level", required = false) String level) {
        return HttpResult.ok(partnerUserService.selectRecommender(level));
    }


    /**
     * 验证是否满足升级条件
     *
     * @param userGradeParam
     * @return
     */
    @PostMapping("/verifyUpgradeConditions")
    public HttpResult verifyUpgradeConditions(@RequestBody UserGradeParam userGradeParam) {
        userGradeParam.setId(getUserId());
        return partnerUserService.verifyUpgradeConditions(userGradeParam);
    }


    /**
     * 提交合伙人变更申请
     *
     * @param userGradeParam
     * @return
     */
    @PostMapping("submitLiftingRecord")
    public HttpResult submitLiftingRecord(@RequestBody UserGradeParam userGradeParam) {
        userGradeParam.setId(getUserId());
        return partnerUserService.submitLiftingRecord(userGradeParam);
    }


    /**
     * 合伙人头像修改
     *
     * @param partnerUser
     * @return
     */
    @PostMapping("avatarUpdate")
    public HttpResult avatarUpdate(@RequestBody PartnerUser partnerUser) {
        partnerUser.setUserId(getUserId());
        return partnerUserService.avatarUpdate(partnerUser);
    }

    /**
     * 我的佣金比例
     *
     * @return
     */
    @GetMapping("commissionRate")
    public HttpResult commissionRate(@RequestParam("grade") String grade) {
        return partnerUserService.commissionRate(getUserId(), grade, getToken());
    }


    /**
     * 我的佣金比例
     *
     * @return
     */
    @GetMapping("myCommissionRate")
    public HttpResult myCommissionRate() {
        return partnerUserService.myCommissionRate(getUserId());
    }


    /**
     * 查询当前用户的身份
     *
     * @param userId
     * @return
     */
    @GetMapping("getUserGradeList")
    public HttpResult getUserGradeList(@RequestParam(value = "userId", required = false) String userId) {
        return HttpResult.ok(partnerUserService.getUserGradeList(userId, getToken()));
    }

    /**
     * 查询当前用户的身份
     *
     * @param userId
     * @return
     */
    @GetMapping("getUserGradeListMap")
    public HttpResult getUserGradeListMap() {
        return HttpResult.ok(partnerUserService.getUserGradeListMap(getUserId()));
    }

    /**
     * 新增用户身份， 为合伙人添加新的等级
     *
     * @author lipf
     * @date 2026/4/15 10:49
     */
    @PostMapping("addUserIdentity")
    public HttpResult<String> addUserIdentity(@RequestBody Map<String, Object> map) {
        return partnerUserService.addUserIdentity(map, getToken());
    }

    /**
     * 未降级完成任务
     *
     * @param grade
     * @return
     */
    @GetMapping("queryDowngradeTask")
    public HttpResult queryDowngradeTask(@RequestParam(value = "grade") String grade) {
        return partnerUserService.queryDowngradeTaskVo(grade, getUserId());
    }


    /**
     * 已降级完成任务
     *
     * @param grade
     * @return
     */
    @GetMapping("degradedTask")
    public HttpResult degradedTask(@RequestParam(value = "grade") String grade) {
        return partnerUserService.degradedTask(grade, getUserId());
    }


    /**
     * 已降级完成任务
     *
     * @return
     */
    @GetMapping("checkCommissionExpireTime")
    public void checkCommissionExpireTime() {
        SpringUtil.getBean(TimedTaskUtils.class).checkCommissionExpireTime();
    }


    /**
     * 联系客服
     *
     * @return
     */
    @GetMapping("contactCustomerService")
    public HttpResult contactCustomerService() {
        return HttpResult.ok(ContactQrCodeUtils.getContactQrCode());
    }


    /**
     * 联系客服
     * @return
     */
    @GetMapping("aaaaa")
    public void aaaaa() {
        SpringUtil.getBean(UpdateRatioUtils.class).before("2034905418911121408",5);
    }


}