记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 0b6140cd authored by 张国柄's avatar 张国柄
Browse files
Options

opt;

parent fcdbdccd
Hide whitespace changes
Inline Side-by-side
Showing with 347 additions and 347 deletions
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/adam/PlatformDMController.java
View file @ 0b6140cd
package com.liquidnet.service.platform.controller.adam;
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import com.github.xiaoymin.knife4j.annotations.ApiSupport;
import com.liquidnet.common.exception.LiquidnetServiceException;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.platform.service.impl.adam.dm.processor.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
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.time.LocalDateTime;
import java.time.temporal.ChronoField;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.regex.Pattern;
@ApiSupport(order = 90062)
@Api(tags = "DM")
@Slf4j
@Validated
@RestController
@RequestMapping("dm")
public class PlatformDMController {
@Autowired
DMUserInformationProcessor dmUserInformationProcessor;
@Autowired
DMThirdPartsProcessor dmThirdPartsProcessor;
@Autowired
DMRealNameProcessor dmRealNameProcessor;
@Autowired
DMUserMemberProcessor dmUserMemberProcessor;
@Autowired
DMEntersProcessor dmEntersProcessor;
@Autowired
DMAddressesProcessor dmAddressesProcessor;
@Autowired
DMTracesInfoProcessor dmTracesInfoProcessor;
@Autowired
DMMemberOrderProcessor dmMemberOrderProcessor;
@Autowired
DMMemberCodeProcessor dmMemberCodeProcessor;
@Autowired
DMCollectionProcessor dmCollectionProcessor;
@ModelAttribute
public void accessExecuting(HttpServletRequest request) {
String alis = request.getHeader("alis");
LocalDateTime now = LocalDateTime.now();
int hour = now.get(ChronoField.HOUR_OF_DAY), minute = now.getMinute(), dom = now.get(ChronoField.DAY_OF_MONTH);;
String lns = "^(" + (dom % 10) + hour % (minute / 10 + 1) + "[A-Z]{2})" + minute / 10 + "[0-9]{1}$";
log.info("lns:{},alis:{}", lns, alis);
if (StringUtils.isEmpty(alis) || !Pattern.matches(lns, alis)) {
throw new LiquidnetServiceException("44444", "非法操作");
}
log.info("uri:[{}],Parameter:{}", request.getRequestURI(), request.getParameterMap());
}
@ApiOperationSupport(order = 1)
@ApiOperation(value = "T - user")
@ApiImplicitParams({
@ApiImplicitParam(type = "form", name = "dG", example = "220"),
})
@GetMapping(value = {"user"})
public ResponseDto<Object> dataMigrationForUser(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
log.info("===dG:{},incrDt:{},flg:{},flu:{}", dG, incrDt, flg, flu);
if (null != dG) {
ExecutorService exec = Executors.newFixedThreadPool(dG);
for (int i = 0; i < dG; i++) {
final int k = i;
exec.execute(() -> {
log.info("==================" + k);
dmUserInformationProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
});
try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
}
exec.shutdown();
} else {
dmUserInformationProcessor.dataProcessing(null, null, incrDt, flg, flu);
}
return ResponseDto.success(dG);
}
@ApiOperationSupport(order = 2)
@ApiOperation(value = "T - tpa")
@ApiImplicitParams({
@ApiImplicitParam(type = "form", name = "dG", example = "45"),
})
@GetMapping(value = {"tpa"})
public ResponseDto<Object> dataMigrationForTpa(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
if (null != dG) {
ExecutorService exec = Executors.newFixedThreadPool(dG);
for (int i = 0; i < dG; i++) {
final int k = i;
exec.execute(() -> {
log.info("==================" + k);
dmThirdPartsProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
});
try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
}
exec.shutdown();
} else {
dmThirdPartsProcessor.dataProcessing(null, null, incrDt, flg, flu);
}
return ResponseDto.success(dG);
}
@ApiOperationSupport(order = 3)
@ApiOperation(value = "T - real")
@ApiImplicitParams({
@ApiImplicitParam(type = "form", name = "dG", example = "2"),
})
@GetMapping(value = {"real"})
public ResponseDto<Object> dataMigrationForReal(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
if (null != dG) {
ExecutorService exec = Executors.newFixedThreadPool(dG);
for (int i = 0; i < dG; i++) {
final int k = i;
exec.execute(() -> {
log.info("==================" + k);
dmRealNameProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
});
try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
}
exec.shutdown();
} else {
dmRealNameProcessor.dataProcessing(null, null, incrDt, flg, flu);
}
return ResponseDto.success(dG);
}
@ApiOperationSupport(order = 4)
@ApiOperation(value = "T - collect")
@ApiImplicitParams({
@ApiImplicitParam(type = "form", name = "dG", example = "15"),
})
@GetMapping(value = {"collect"})
public ResponseDto<Object> dataMigrationForCollect(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
if (null != dG) {
ExecutorService exec = Executors.newFixedThreadPool(dG);
for (int i = 0; i < dG; i++) {
final int k = i;
exec.execute(() -> {
log.info("==================" + k);
dmCollectionProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
});
try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
}
exec.shutdown();
} else {
dmCollectionProcessor.dataProcessing(null, null, incrDt, flg, flu);
}
return ResponseDto.success(dG);
}
@ApiOperationSupport(order = 5)
@ApiOperation(value = "T - enters")
@ApiImplicitParams({
@ApiImplicitParam(type = "form", name = "dG", example = "93"),
})
@GetMapping(value = {"enters"})
public ResponseDto<Object> dataMigrationForEnters(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
if (null != dG) {
ExecutorService exec = Executors.newFixedThreadPool(dG);
for (int i = 0; i < dG; i++) {
final int k = i;
exec.execute(() -> {
log.info("==================" + k);
dmEntersProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
});
try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
}
exec.shutdown();
} else {
dmEntersProcessor.dataProcessing(null, null, incrDt, flg, flu);
}
return ResponseDto.success(dG);
}
@ApiOperationSupport(order = 6)
@ApiOperation(value = "T - addr")
@ApiImplicitParams({
@ApiImplicitParam(type = "form", name = "dG", example = "27"),
})
@GetMapping(value = {"addr"})
public ResponseDto<Object> dataMigrationForAddr(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
if (null != dG) {
ExecutorService exec = Executors.newFixedThreadPool(dG);
for (int i = 0; i < dG; i++) {
final int k = i;
exec.execute(() -> {
log.info("==================" + k);
dmAddressesProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
});
try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
}
exec.shutdown();
} else {
dmAddressesProcessor.dataProcessing(null, null, incrDt, flg, flu);
}
return ResponseDto.success(dG);
}
@ApiOperationSupport(order = 7)
@ApiOperation(value = "T - vip")
@ApiImplicitParams({
@ApiImplicitParam(type = "form", name = "dG", example = "2"),
})
@GetMapping(value = {"vip"})
public ResponseDto<Object> dataMigrationForVip(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
if (null != dG) {
ExecutorService exec = Executors.newFixedThreadPool(dG);
for (int i = 0; i < dG; i++) {
final int k = i;
exec.execute(() -> {
log.info("==================" + k);
dmUserMemberProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
});
try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
}
exec.shutdown();
} else {
dmUserMemberProcessor.dataProcessing(null, null, incrDt, flg, flu);
}
return ResponseDto.success(dG);
}
@ApiOperationSupport(order = 8)
@ApiOperation(value = "morder")
@GetMapping(value = {"morder"})
public ResponseDto<Object> dataMigrationForMOrder(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
dmMemberOrderProcessor.dataProcessing(null, null, incrDt, flg, flu);
return ResponseDto.success(dG);
}
@ApiOperationSupport(order = 9)
@ApiOperation(value = "mcode")
@GetMapping(value = {"mcode"})
public ResponseDto<Object> dataMigrationForMCode(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
dmMemberCodeProcessor.dataProcessing(null, null, incrDt, flg, flu);
return ResponseDto.success(dG);
}
@ApiOperationSupport(order = 10)
@ApiOperation(value = "traces")
@GetMapping(value = {"traces"})
public ResponseDto<Object> dataMigrationForTraces(@RequestParam(required = false) Integer dG,
@RequestParam(required = false) String incrDt,
@RequestParam(required = false) String flg,
@RequestParam(required = false) String flu
) {
dmTracesInfoProcessor.dataProcessing(null, null, incrDt, flg, flu);
return ResponseDto.success(dG);
}
}
//package com.liquidnet.service.platform.controller.adam;
//
//import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
//import com.github.xiaoymin.knife4j.annotations.ApiSupport;
//import com.liquidnet.common.exception.LiquidnetServiceException;
//import com.liquidnet.service.base.ResponseDto;
//import com.liquidnet.service.platform.service.impl.adam.dm.processor.*;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiImplicitParam;
//import io.swagger.annotations.ApiImplicitParams;
//import io.swagger.annotations.ApiOperation;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.commons.lang3.StringUtils;
//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.time.LocalDateTime;
//import java.time.temporal.ChronoField;
//import java.util.concurrent.ExecutorService;
//import java.util.concurrent.Executors;
//import java.util.regex.Pattern;
//
//@ApiSupport(order = 90062)
//@Api(tags = "DM")
//@Slf4j
//@Validated
//@RestController
//@RequestMapping("dm")
//public class PlatformDMController {
// @Autowired
// DMUserInformationProcessor dmUserInformationProcessor;
// @Autowired
// DMThirdPartsProcessor dmThirdPartsProcessor;
// @Autowired
// DMRealNameProcessor dmRealNameProcessor;
// @Autowired
// DMUserMemberProcessor dmUserMemberProcessor;
// @Autowired
// DMEntersProcessor dmEntersProcessor;
// @Autowired
// DMAddressesProcessor dmAddressesProcessor;
// @Autowired
// DMTracesInfoProcessor dmTracesInfoProcessor;
// @Autowired
// DMMemberOrderProcessor dmMemberOrderProcessor;
// @Autowired
// DMMemberCodeProcessor dmMemberCodeProcessor;
// @Autowired
// DMCollectionProcessor dmCollectionProcessor;
//
// @ModelAttribute
// public void accessExecuting(HttpServletRequest request) {
// String alis = request.getHeader("alis");
// LocalDateTime now = LocalDateTime.now();
// int hour = now.get(ChronoField.HOUR_OF_DAY), minute = now.getMinute(), dom = now.get(ChronoField.DAY_OF_MONTH);;
// String lns = "^(" + (dom % 10) + hour % (minute / 10 + 1) + "[A-Z]{2})" + minute / 10 + "[0-9]{1}$";
// log.info("lns:{},alis:{}", lns, alis);
// if (StringUtils.isEmpty(alis) || !Pattern.matches(lns, alis)) {
// throw new LiquidnetServiceException("44444", "非法操作");
// }
// log.info("uri:[{}],Parameter:{}", request.getRequestURI(), request.getParameterMap());
// }
//
// @ApiOperationSupport(order = 1)
// @ApiOperation(value = "T - user")
// @ApiImplicitParams({
// @ApiImplicitParam(type = "form", name = "dG", example = "220"),
// })
// @GetMapping(value = {"user"})
// public ResponseDto<Object> dataMigrationForUser(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// log.info("===dG:{},incrDt:{},flg:{},flu:{}", dG, incrDt, flg, flu);
// if (null != dG) {
// ExecutorService exec = Executors.newFixedThreadPool(dG);
// for (int i = 0; i < dG; i++) {
// final int k = i;
// exec.execute(() -> {
// log.info("==================" + k);
// dmUserInformationProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
// });
// try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
// }
// exec.shutdown();
// } else {
// dmUserInformationProcessor.dataProcessing(null, null, incrDt, flg, flu);
// }
// return ResponseDto.success(dG);
// }
//
// @ApiOperationSupport(order = 2)
// @ApiOperation(value = "T - tpa")
// @ApiImplicitParams({
// @ApiImplicitParam(type = "form", name = "dG", example = "45"),
// })
// @GetMapping(value = {"tpa"})
// public ResponseDto<Object> dataMigrationForTpa(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// if (null != dG) {
// ExecutorService exec = Executors.newFixedThreadPool(dG);
// for (int i = 0; i < dG; i++) {
// final int k = i;
// exec.execute(() -> {
// log.info("==================" + k);
// dmThirdPartsProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
// });
// try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
// }
// exec.shutdown();
// } else {
// dmThirdPartsProcessor.dataProcessing(null, null, incrDt, flg, flu);
// }
// return ResponseDto.success(dG);
// }
//
// @ApiOperationSupport(order = 3)
// @ApiOperation(value = "T - real")
// @ApiImplicitParams({
// @ApiImplicitParam(type = "form", name = "dG", example = "2"),
// })
// @GetMapping(value = {"real"})
// public ResponseDto<Object> dataMigrationForReal(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// if (null != dG) {
// ExecutorService exec = Executors.newFixedThreadPool(dG);
// for (int i = 0; i < dG; i++) {
// final int k = i;
// exec.execute(() -> {
// log.info("==================" + k);
// dmRealNameProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
// });
// try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
// }
// exec.shutdown();
// } else {
// dmRealNameProcessor.dataProcessing(null, null, incrDt, flg, flu);
// }
// return ResponseDto.success(dG);
// }
//
// @ApiOperationSupport(order = 4)
// @ApiOperation(value = "T - collect")
// @ApiImplicitParams({
// @ApiImplicitParam(type = "form", name = "dG", example = "15"),
// })
// @GetMapping(value = {"collect"})
// public ResponseDto<Object> dataMigrationForCollect(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// if (null != dG) {
// ExecutorService exec = Executors.newFixedThreadPool(dG);
// for (int i = 0; i < dG; i++) {
// final int k = i;
// exec.execute(() -> {
// log.info("==================" + k);
// dmCollectionProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
// });
// try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
// }
// exec.shutdown();
// } else {
// dmCollectionProcessor.dataProcessing(null, null, incrDt, flg, flu);
// }
// return ResponseDto.success(dG);
// }
//
// @ApiOperationSupport(order = 5)
// @ApiOperation(value = "T - enters")
// @ApiImplicitParams({
// @ApiImplicitParam(type = "form", name = "dG", example = "93"),
// })
// @GetMapping(value = {"enters"})
// public ResponseDto<Object> dataMigrationForEnters(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// if (null != dG) {
// ExecutorService exec = Executors.newFixedThreadPool(dG);
// for (int i = 0; i < dG; i++) {
// final int k = i;
// exec.execute(() -> {
// log.info("==================" + k);
// dmEntersProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
// });
// try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
// }
// exec.shutdown();
// } else {
// dmEntersProcessor.dataProcessing(null, null, incrDt, flg, flu);
// }
// return ResponseDto.success(dG);
// }
//
// @ApiOperationSupport(order = 6)
// @ApiOperation(value = "T - addr")
// @ApiImplicitParams({
// @ApiImplicitParam(type = "form", name = "dG", example = "27"),
// })
// @GetMapping(value = {"addr"})
// public ResponseDto<Object> dataMigrationForAddr(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// if (null != dG) {
// ExecutorService exec = Executors.newFixedThreadPool(dG);
// for (int i = 0; i < dG; i++) {
// final int k = i;
// exec.execute(() -> {
// log.info("==================" + k);
// dmAddressesProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
// });
// try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
// }
// exec.shutdown();
// } else {
// dmAddressesProcessor.dataProcessing(null, null, incrDt, flg, flu);
// }
// return ResponseDto.success(dG);
// }
//
// @ApiOperationSupport(order = 7)
// @ApiOperation(value = "T - vip")
// @ApiImplicitParams({
// @ApiImplicitParam(type = "form", name = "dG", example = "2"),
// })
// @GetMapping(value = {"vip"})
// public ResponseDto<Object> dataMigrationForVip(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// if (null != dG) {
// ExecutorService exec = Executors.newFixedThreadPool(dG);
// for (int i = 0; i < dG; i++) {
// final int k = i;
// exec.execute(() -> {
// log.info("==================" + k);
// dmUserMemberProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
// });
// try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
// }
// exec.shutdown();
// } else {
// dmUserMemberProcessor.dataProcessing(null, null, incrDt, flg, flu);
// }
// return ResponseDto.success(dG);
// }
//
// @ApiOperationSupport(order = 8)
// @ApiOperation(value = "morder")
// @GetMapping(value = {"morder"})
// public ResponseDto<Object> dataMigrationForMOrder(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// dmMemberOrderProcessor.dataProcessing(null, null, incrDt, flg, flu);
// return ResponseDto.success(dG);
// }
//
// @ApiOperationSupport(order = 9)
// @ApiOperation(value = "mcode")
// @GetMapping(value = {"mcode"})
// public ResponseDto<Object> dataMigrationForMCode(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// dmMemberCodeProcessor.dataProcessing(null, null, incrDt, flg, flu);
// return ResponseDto.success(dG);
// }
//
// @ApiOperationSupport(order = 10)
// @ApiOperation(value = "traces")
// @GetMapping(value = {"traces"})
// public ResponseDto<Object> dataMigrationForTraces(@RequestParam(required = false) Integer dG,
// @RequestParam(required = false) String incrDt,
// @RequestParam(required = false) String flg,
// @RequestParam(required = false) String flu
// ) {
// dmTracesInfoProcessor.dataProcessing(null, null, incrDt, flg, flu);
// return ResponseDto.success(dG);
// }
//}
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/kylin/DataController.java
View file @ 0b6140cd
package com.liquidnet.service.platform.controller.kylin;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.platform.service.impl.kylin.DataImpl;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@Api(tags = "数据迁移 (会重复)")
@RestController
@RequestMapping("data")
public class DataController {
@Autowired
private DataImpl data;
@PostMapping("performance")
@ApiOperation("演出数据迁移")
public ResponseDto<Boolean> performance() {
Boolean result = data.performance();
return ResponseDto.success(result);
}
@PostMapping("order")
@ApiOperation("订单数据迁移")
public ResponseDto<Boolean> order(String month) {
Boolean result = data.order(month);
return ResponseDto.success(result);
}
@PostMapping("roadShow")
@ApiOperation("巡演数据迁移")
public ResponseDto<Boolean> roadShow() {
Boolean result = data.roadShow();
return ResponseDto.success(result);
}
@PostMapping("childAccount")
@ApiOperation("验票子账号数据迁移")
public ResponseDto<Boolean> childAccount() {
Boolean result = data.childAccount();
return ResponseDto.success(result);
}
}
//package com.liquidnet.service.platform.controller.kylin;
//
//import com.liquidnet.service.base.ResponseDto;
//import com.liquidnet.service.platform.service.impl.kylin.DataImpl;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.PostMapping;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//
//@Api(tags = "数据迁移 (会重复)")
//@RestController
//@RequestMapping("data")
//public class DataController {
//
// @Autowired
// private DataImpl data;
//
// @PostMapping("performance")
// @ApiOperation("演出数据迁移")
// public ResponseDto<Boolean> performance() {
// Boolean result = data.performance();
// return ResponseDto.success(result);
// }
//
// @PostMapping("order")
// @ApiOperation("订单数据迁移")
// public ResponseDto<Boolean> order(String month) {
// Boolean result = data.order(month);
// return ResponseDto.success(result);
// }
//
// @PostMapping("roadShow")
// @ApiOperation("巡演数据迁移")
// public ResponseDto<Boolean> roadShow() {
// Boolean result = data.roadShow();
// return ResponseDto.success(result);
// }
//
// @PostMapping("childAccount")
// @ApiOperation("验票子账号数据迁移")
// public ResponseDto<Boolean> childAccount() {
// Boolean result = data.childAccount();
// return ResponseDto.success(result);
// }
//
//}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment