package com.szwl.controller; import com.szwl.feign.bean.PayFeign; import com.szwl.feign.bean.SyncOldFeign; import com.szwl.model.bo.R; import com.szwl.model.bo.ResponseModel; import com.szwl.model.entity.TOrder; import com.szwl.service.TOrderService; 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 java.text.SimpleDateFormat; import java.util.Date; import java.util.List; @Slf4j @Api(value = "/syncOrder", tags = {"同步旧系统的order数据"}) @RestController @RequestMapping("/syncOrder") public class SyncOrderController { PayFeign payFeign; TOrderService orderService; SyncOldFeign syncOldFeign; public SyncOrderController(PayFeign payFeign, TOrderService orderService, SyncOldFeign syncOldFeign) { this.payFeign = payFeign; this.orderService = orderService; this.syncOldFeign = syncOldFeign; } @ApiOperation(value = "同步国内某客户的某一设备某一时间段内的 order 订单") @PostMapping("/getOrderByCAT") public ResponseModel getOrderByCAT(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); // SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // Date start = sdf.parse(startTime); // Date end = sdf.parse(endTime); List orderList = R.getDataIfSuccess(syncOldFeign.getOrderByACT(l, clientId, startTime, endTime)); if (orderList.size()>1000) { return R.fail("数据量过大,请缩短时间范围"); } for (TOrder order : orderList) { // System.out.println("order》》" + order); payFeign.addOrder(order); } return R.ok(adminId + "同步设备" + clientId + "从" + startTime + "至" + endTime + "的 order 信息成功"); } else { return R.fail("参数不能为空"); } } }