|
@@ -0,0 +1,114 @@
|
|
|
+package com.onemap.apply.service.impl.jsc;
|
|
|
+
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.onemap.apply.domain.fzss.PzwjstdDTO;
|
|
|
+import com.onemap.apply.domain.jsc.TjscsqlDTO;
|
|
|
+import com.onemap.apply.mapper.jsc.JscMapper;
|
|
|
+import com.onemap.apply.mapper.jsc.TjscsqlMapper;
|
|
|
+import com.onemap.apply.service.jsc.JscService;
|
|
|
+import com.onemap.common.core.utils.StringUtils;
|
|
|
+import com.onemap.common.core.web.domain.RequestResult;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
+
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+
|
|
|
+/**
|
|
|
+ * @author lvhp
|
|
|
+ * * @date 2024/5/21
|
|
|
+ */
|
|
|
+@Service
|
|
|
+public class JscServiceImpl implements JscService {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private TjscsqlMapper tjscsqlMapper;
|
|
|
+ @Autowired
|
|
|
+ private JscMapper jscMapper;
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public RequestResult QueryOne(String jscType, String id, String beginTime, String endTime, String val0, String val1, String val2) {
|
|
|
+ if (StringUtils.isEmpty(jscType)) {
|
|
|
+ return RequestResult.error("jscType 参数未传递!");
|
|
|
+ }
|
|
|
+ if (StringUtils.isEmpty(id)) {
|
|
|
+ return RequestResult.error("id 参数未传递!");
|
|
|
+ }
|
|
|
+ QueryWrapper<TjscsqlDTO> wrapper = new QueryWrapper<TjscsqlDTO>();
|
|
|
+ wrapper.eq("jsc_type", jscType.trim());
|
|
|
+ TjscsqlDTO tjscsqlDto = tjscsqlMapper.selectOne(wrapper);
|
|
|
+ if (StringUtils.isNull(tjscsqlDto)) {
|
|
|
+ return RequestResult.error("jscType 参数传递有误!");
|
|
|
+ }
|
|
|
+ String jscSql = tjscsqlDto.getJscSql();
|
|
|
+ if (StringUtils.isEmpty(jscSql)) {
|
|
|
+ return RequestResult.error("参数配置有问题!");
|
|
|
+ }
|
|
|
+ Map<String, Object> queryMap = new HashMap<>();
|
|
|
+ queryMap.put("id", id);
|
|
|
+ if (StringUtils.isNotEmpty(beginTime)) {
|
|
|
+ queryMap.put("begin_time", beginTime);
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(endTime)) {
|
|
|
+ queryMap.put("end_time", endTime);
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(val0)) {
|
|
|
+ queryMap.put("val0", val0);
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(val1)) {
|
|
|
+ queryMap.put("val1", val1);
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(val2)) {
|
|
|
+ queryMap.put("val2", val2);
|
|
|
+ }
|
|
|
+ queryMap.put("jsc_sql", jscSql);
|
|
|
+ List<Map<String, Object>> list = jscMapper.getBeanListByEntity(queryMap);
|
|
|
+ if (list.size() != 1) {
|
|
|
+ return RequestResult.error("查询数据有误,请检查!");
|
|
|
+ }
|
|
|
+ return RequestResult.success(list.get(0));
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public RequestResult QueryList(String jscType, String id, String beginTime, String endTime, String val0, String val1, String val2) {
|
|
|
+ if (StringUtils.isEmpty(jscType)) {
|
|
|
+ return RequestResult.error("jscType 参数未传递!");
|
|
|
+ }
|
|
|
+ if (StringUtils.isEmpty(id)) {
|
|
|
+ return RequestResult.error("id 参数未传递!");
|
|
|
+ }
|
|
|
+ QueryWrapper<TjscsqlDTO> wrapper = new QueryWrapper<TjscsqlDTO>();
|
|
|
+ wrapper.eq("jsc_type", jscType.trim());
|
|
|
+ TjscsqlDTO tjscsqlDto = tjscsqlMapper.selectOne(wrapper);
|
|
|
+ if (StringUtils.isNull(tjscsqlDto)) {
|
|
|
+ return RequestResult.error("jscType 参数传递有误!");
|
|
|
+ }
|
|
|
+ String jscSql = tjscsqlDto.getJscSql();
|
|
|
+ if (StringUtils.isEmpty(jscSql)) {
|
|
|
+ return RequestResult.error("参数配置有问题!");
|
|
|
+ }
|
|
|
+ Map<String, Object> queryMap = new HashMap<>();
|
|
|
+ queryMap.put("id", id);
|
|
|
+ if (StringUtils.isNotEmpty(beginTime)) {
|
|
|
+ queryMap.put("begin_time", beginTime);
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(endTime)) {
|
|
|
+ queryMap.put("end_time", endTime);
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(val0)) {
|
|
|
+ queryMap.put("val0", val0);
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(val1)) {
|
|
|
+ queryMap.put("val1", val1);
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(val2)) {
|
|
|
+ queryMap.put("val2", val2);
|
|
|
+ }
|
|
|
+ queryMap.put("jsc_sql", jscSql);
|
|
|
+ List<Map<String, Object>> list = jscMapper.getBeanListByEntity(queryMap);
|
|
|
+ return RequestResult.success(list);
|
|
|
+ }
|
|
|
+
|
|
|
+}
|