SyncOldCoinOrderController.java 3.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  1. package com.szwl.controller;
  2. import com.szwl.feign.bean.SyncOldFeign;
  3. import com.szwl.mapper.TCoinOrderMapper;
  4. import com.szwl.model.bo.R;
  5. import com.szwl.model.bo.ResponseModel;
  6. import com.szwl.model.entity.TCoinOrder;
  7. import com.szwl.service.TCoinOrderService;
  8. import io.swagger.annotations.Api;
  9. import io.swagger.annotations.ApiOperation;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.apache.commons.lang.StringUtils;
  12. import org.springframework.web.bind.annotation.PostMapping;
  13. import org.springframework.web.bind.annotation.RequestMapping;
  14. import org.springframework.web.bind.annotation.RestController;
  15. import javax.annotation.Resource;
  16. import java.util.List;
  17. @Slf4j
  18. @Api(value = "/syncCoinOrder", tags = {"同步旧系统的coinOrder数据"})
  19. @RestController
  20. @RequestMapping("/syncCoinOrder")
  21. public class SyncOldCoinOrderController {
  22. SyncOldFeign syncOldFeign;
  23. @Resource
  24. TCoinOrderMapper coinOrderMapper;
  25. TCoinOrderService coinOrderService;
  26. public SyncOldCoinOrderController(SyncOldFeign syncOldFeign, TCoinOrderService coinOrderService) {
  27. this.syncOldFeign = syncOldFeign;
  28. this.coinOrderService = coinOrderService;
  29. }
  30. // 真批量同步
  31. @ApiOperation(value = "同步海外某客户的某一设备某一时间段内的 coinOrder 订单")
  32. @PostMapping("/syncCoinOrderByCAT")
  33. public ResponseModel<?> syncCoinOrderByCAT(String adminId, String clientId, String startTime, String endTime) {
  34. if (adminId != null && StringUtils.isNotEmpty(clientId) && StringUtils.isNotEmpty(startTime) && StringUtils.isNotEmpty(endTime)) {
  35. long l = Long.parseLong(adminId);
  36. List<TCoinOrder> coinOrderList = R.getDataIfSuccess(syncOldFeign.getCoinOrderByACT(l, clientId, startTime, endTime));
  37. if (coinOrderList.size() == 0) {
  38. return R.fail("未查询到订单信息");
  39. }
  40. if (coinOrderList.size() > 10000) {
  41. return R.fail("数据量过大,请缩短时间范围");
  42. }
  43. // coinOrderService.saveBatch(coinOrderList);
  44. int i = coinOrderMapper.insertBatchSomeColumn(coinOrderList);
  45. return R.ok("批量插入 coinOrder " + i + "条记录");
  46. } else {
  47. return R.ok("参数不能为空");
  48. }
  49. }
  50. // 伪批量同步
  51. // @ApiOperation(value = "同步海外某客户的某一设备某一时间段内的 coinOrder 订单")
  52. // @PostMapping("/syncCoinOrderByCAT")
  53. // public ResponseModel<?> syncCoinOrderByCAT(String adminId, String clientId, String startTime, String endTime) {
  54. // if (StringUtils.isNotEmpty(adminId) && StringUtils.isNotEmpty(clientId) && StringUtils.isNotEmpty(startTime) && StringUtils.isNotEmpty(endTime)) {
  55. // long l = Long.parseLong(adminId);
  56. //
  57. // List<TCoinOrder> coinOrderList = R.getDataIfSuccess(syncOldFeign.getCoinOrderByACT(l, clientId, startTime, endTime));
  58. //
  59. //
  60. // if (coinOrderList.size()>1000) {
  61. // return R.fail("数据量过大,请缩短时间范围");
  62. // }
  63. //// coinOrderService.saveBatch(coinOrderList);
  64. //
  65. // for (TCoinOrder coinOrder : coinOrderList) {
  66. //// System.out.println("coinOrder》》" + coinOrder);
  67. // coinOrderService.save(coinOrder);
  68. // }
  69. //
  70. // return R.ok(adminId + "同步设备" + clientId + "从" + startTime + "至" + endTime + "的 coinOrder 信息成功");
  71. // } else {
  72. // return R.fail("参数不能为空");
  73. // }
  74. // }
  75. }