szwlServer/src/main/java/com/szwl/controller/SyncOldProportionController.java

package com.szwl.controller;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.szwl.feign.bean.SyncOldFeign;
import com.szwl.model.bo.R;
import com.szwl.model.bo.ResponseModel;
import com.szwl.model.entity.TProportion;
import com.szwl.service.TProportionService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Objects;

@Slf4j
@Api(value = "/syncOldProportion", tags = {"同步旧系统的分销信息"})
@RestController
@RequestMapping("/syncOldProportion")
public class SyncOldProportionController {

    SyncOldFeign syncOldFeign;
    TProportionService proportionService;


    public SyncOldProportionController(SyncOldFeign syncOldFeign, TProportionService proportionService) {
        this.syncOldFeign = syncOldFeign;
        this.proportionService = proportionService;
    }


    @ApiOperation(value = "根据用户id同步分销信息")
    @PostMapping("/syncProportionByAdminId")
    public ResponseModel<?> syncProportionByAdminId(Long adminId) {
        if(adminId == null) {
            return R.fail("参数不能为空");
        }

        TProportion proportion = R.getDataIfSuccess(syncOldFeign.getProportionByAdminId(adminId));
        if (Objects.nonNull(proportion)) {
            proportionService.save(proportion);
        }
        return R.ok("同步用户" + adminId + "分销信息成功");
    }

}