DataSourceServiceImpl.java 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. package com.huimv.cattle.service.impl;
  2. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  3. import com.huimv.cattle.pojo.DataSource;
  4. import com.huimv.cattle.mapper.DataSourceMapper;
  5. import com.huimv.cattle.service.DataSourceService;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.huimv.common.utils.Result;
  8. import com.huimv.common.utils.ResultCode;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Service;
  11. import java.util.Map;
  12. /**
  13. * <p>
  14. * 服务实现类
  15. * </p>
  16. *
  17. * @author zn
  18. * @since 2022-12-15
  19. */
  20. @Service
  21. public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSource> implements DataSourceService {
  22. //默认牧场
  23. // private static final String DEFAULT_FARM_CODE = "330211";
  24. @Autowired
  25. private DataSourceMapper dataSourceMapper;
  26. @Override
  27. public Result getDataSource() {
  28. QueryWrapper<DataSource> totalQueryWrapper = new QueryWrapper();
  29. return new Result(ResultCode.SUCCESS, dataSourceMapper.selectOne(totalQueryWrapper));
  30. }
  31. @Override
  32. public Result setDataSouce(Map<String, String> paramsMap) {
  33. //
  34. String datasourceStatus = "0";
  35. if (paramsMap.get("datasourceStatus") != null) {
  36. datasourceStatus = paramsMap.get("datasourceStatus");
  37. }
  38. QueryWrapper<DataSource> totalQueryWrapper = new QueryWrapper();
  39. DataSource dataSource = dataSourceMapper.selectOne(totalQueryWrapper);
  40. if (dataSource == null) {
  41. dataSource = new DataSource();
  42. dataSource.setDsStatus(Integer.parseInt(datasourceStatus));
  43. dataSourceMapper.insert(dataSource);
  44. } else {
  45. dataSource.setDsStatus(Integer.parseInt(datasourceStatus));
  46. dataSourceMapper.updateById(dataSource);
  47. }
  48. return new Result(ResultCode.SUCCESS);
  49. }
  50. @Override
  51. public Integer getDataSourceStatus(Map<String, String> paramsMap) {
  52. QueryWrapper<DataSource> totalQueryWrapper = new QueryWrapper();
  53. DataSource dataSource = dataSourceMapper.selectOne(totalQueryWrapper);
  54. if (dataSource == null) {
  55. return 0;
  56. } else {
  57. return dataSource.getDsStatus();
  58. }
  59. }
  60. }