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

package com.szwl.controller;

import com.szwl.feign.bean.SyncOldFeign;
import com.szwl.model.bo.R;
import com.szwl.model.bo.ResponseModel;
import com.szwl.model.entity.TJoinpayMch;
import com.szwl.service.TJoinpayMchService;
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 = "/syncOldJoinpayMch", tags = {"根据用户同步旧系统分销数据"})
@RestController
@RequestMapping("/syncOldJoinpayMch")
public class SyncOldJoinpayMchController {

    TJoinpayMchService joinpayMchService;
    SyncOldFeign syncOldFeign;

    public SyncOldJoinpayMchController(TJoinpayMchService joinpayMchService, SyncOldFeign syncOldFeign) {
        this.joinpayMchService = joinpayMchService;
        this.syncOldFeign = syncOldFeign;
    }

    @ApiOperation(value = "根据用户id同步汇聚支付信息")
    @PostMapping("/syncJoinpayMchByAdminId")
    public ResponseModel<?> syncJoinpayMchByAdminId(Long adminId) {
        if (adminId == null) {
            return R.fail("参数不能为空");
        }
        TJoinpayMch joinpayMch = R.getDataIfSuccess(syncOldFeign.getJoinpayMchByAdminId(adminId));
        if (Objects.nonNull(joinpayMch)) {
            joinpayMchService.save(joinpayMch);
        }
        return R.ok("同步用户" + adminId + "的汇聚支付信息成功");
    }
}