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 + "的汇聚支付信息成功"); } }