GrainLayerDataSynController.java 1.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. package com.chinaitop.depot.grainAPI.controller;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.chinaitop.depot.grainAPI.entity.TestDataLayer;
  4. import com.chinaitop.depot.grainAPI.service.TestDataLayerService;
  5. import org.apache.commons.lang3.StringUtils;
  6. import org.slf4j.Logger;
  7. import org.slf4j.LoggerFactory;
  8. import org.springframework.web.bind.annotation.PostMapping;
  9. import org.springframework.web.bind.annotation.RequestBody;
  10. import org.springframework.web.bind.annotation.RequestMapping;
  11. import org.springframework.web.bind.annotation.RestController;
  12. import javax.annotation.Resource;
  13. import java.util.List;
  14. /**
  15. * @author qingsong.han
  16. * @description: 测温数据子表库到云数据同步
  17. * @create 2021-11-03 13:52
  18. */
  19. @RestController
  20. @RequestMapping(value = "/testDataLayer")
  21. public class GrainLayerDataSynController {
  22. private final static Logger logger = LoggerFactory.getLogger(GrainLayerDataSynController.class);
  23. @Resource
  24. private TestDataLayerService testDataLayerService;
  25. @PostMapping("/housesToCouldTemperData")
  26. public void housesToCouldTemperData(@RequestBody String grainJson) {
  27. logger.info("testDataLayer: {}", grainJson);
  28. try {
  29. if (StringUtils.isNotBlank(grainJson)) {
  30. List<TestDataLayer> testDataLayer = JSONArray.parseArray(grainJson, TestDataLayer.class);
  31. testDataLayerService.saveBatch(testDataLayer);
  32. }
  33. } catch (Exception e) {
  34. logger.info("testDataLayerDataInfo保存失败: {}", grainJson);
  35. e.printStackTrace();
  36. }
  37. }
  38. }