12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091 |
- package com.szwl.controller;
- import com.szwl.feign.bean.SyncOldFeign;
- import com.szwl.mapper.TCoinOrderMapper;
- import com.szwl.model.bo.R;
- import com.szwl.model.bo.ResponseModel;
- import com.szwl.model.entity.TCoinOrder;
- import com.szwl.service.TCoinOrderService;
- import io.swagger.annotations.Api;
- import io.swagger.annotations.ApiOperation;
- import lombok.extern.slf4j.Slf4j;
- import org.apache.commons.lang.StringUtils;
- import org.springframework.web.bind.annotation.PostMapping;
- import org.springframework.web.bind.annotation.RequestMapping;
- import org.springframework.web.bind.annotation.RestController;
- import javax.annotation.Resource;
- import java.util.List;
- @Slf4j
- @Api(value = "/syncCoinOrder", tags = {"同步旧系统的coinOrder数据"})
- @RestController
- @RequestMapping("/syncCoinOrder")
- public class SyncOldCoinOrderController {
- SyncOldFeign syncOldFeign;
- @Resource
- TCoinOrderMapper coinOrderMapper;
- TCoinOrderService coinOrderService;
- public SyncOldCoinOrderController(SyncOldFeign syncOldFeign, TCoinOrderService coinOrderService) {
- this.syncOldFeign = syncOldFeign;
- this.coinOrderService = coinOrderService;
- }
- // 真批量同步
- @ApiOperation(value = "同步海外某客户的某一设备某一时间段内的 coinOrder 订单")
- @PostMapping("/syncCoinOrderByCAT")
- public ResponseModel<?> syncCoinOrderByCAT(String adminId, String clientId, String startTime, String endTime) {
- if (adminId != null && StringUtils.isNotEmpty(clientId) && StringUtils.isNotEmpty(startTime) && StringUtils.isNotEmpty(endTime)) {
- long l = Long.parseLong(adminId);
- List<TCoinOrder> coinOrderList = R.getDataIfSuccess(syncOldFeign.getCoinOrderByACT(l, clientId, startTime, endTime));
- if (coinOrderList.size() == 0) {
- return R.fail("未查询到订单信息");
- }
- if (coinOrderList.size() > 10000) {
- return R.fail("数据量过大,请缩短时间范围");
- }
- // coinOrderService.saveBatch(coinOrderList);
- int i = coinOrderMapper.insertBatchSomeColumn(coinOrderList);
- return R.ok("批量插入 coinOrder " + i + "条记录");
- } else {
- return R.ok("参数不能为空");
- }
- }
- // 伪批量同步
- // @ApiOperation(value = "同步海外某客户的某一设备某一时间段内的 coinOrder 订单")
- // @PostMapping("/syncCoinOrderByCAT")
- // public ResponseModel<?> syncCoinOrderByCAT(String adminId, String clientId, String startTime, String endTime) {
- // if (StringUtils.isNotEmpty(adminId) && StringUtils.isNotEmpty(clientId) && StringUtils.isNotEmpty(startTime) && StringUtils.isNotEmpty(endTime)) {
- // long l = Long.parseLong(adminId);
- //
- // List<TCoinOrder> coinOrderList = R.getDataIfSuccess(syncOldFeign.getCoinOrderByACT(l, clientId, startTime, endTime));
- //
- //
- // if (coinOrderList.size()>1000) {
- // return R.fail("数据量过大,请缩短时间范围");
- // }
- //// coinOrderService.saveBatch(coinOrderList);
- //
- // for (TCoinOrder coinOrder : coinOrderList) {
- //// System.out.println("coinOrder》》" + coinOrder);
- // coinOrderService.save(coinOrder);
- // }
- //
- // return R.ok(adminId + "同步设备" + clientId + "从" + startTime + "至" + endTime + "的 coinOrder 信息成功");
- // } else {
- // return R.fail("参数不能为空");
- // }
- // }
- }
|