优化扩展存储过程调用方法

collect-fees/collect-fees-service/src/main/java/com/tofly/fees/common/dbhelper/DbHelper.java

@@ -5,10 +5,12 @@ import com.tofly.fees.common.mapper.CommonMapper;
 import com.tofly.fees.common.model.CollectionData;
 import com.tofly.fees.common.model.DataSourceInfo;
 import com.tofly.fees.common.model.PageLink;
+import com.tofly.fees.common.model.ProcParamModel;
 import com.tofly.fees.common.util.SpringContextHolder;
 import org.springframework.context.annotation.DependsOn;
 
 import java.sql.*;
+import java.text.MessageFormat;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -313,12 +315,12 @@ public class DbHelper {
 //                }
 //                sb.append(")}");
 
-                if(!procurdeName.contains("map.")){
-                    procurdeName=procurdeName.replace("#{","#{map.");
+                if (!procurdeName.contains("map.")) {
+                    procurdeName = procurdeName.replace("#{", "#{map.");
                 }
-                if(procurdeName.contains("CURSOR")
-                        &&!procurdeName.contains("resultMap")){
-                    procurdeName=procurdeName.replace("CURSOR","CURSOR,resultMap=mapCus");
+                if (procurdeName.contains("CURSOR")
+                        && !procurdeName.contains("resultMap")) {
+                    procurdeName = procurdeName.replace("CURSOR", "CURSOR,resultMap=mapCus");
                 }
                 commonMapper.procedureCmd(procurdeName, objectHashMap);
                 return objectHashMap;
@@ -337,4 +339,44 @@ public class DbHelper {
         }
         return null;
     }
+
+
+    /**
+     * 执行存储过程
+     *
+     * @param procedureName 存储过程名称
+     * @param list          参数对象
+     * @return Map对象
+     */
+    public Map excuteProcedure(String procedureName, List<ProcParamModel> list) {
+        try {
+            Map<String, Object> objectHashMap = new HashMap<>();
+            StringBuilder sbProc = new StringBuilder();
+            sbProc.append(String.format("{call %s(", procedureName));
+            //判断是否有参数，有则进行赋值处理
+            if (list != null && list.size() > 0) {
+                sbProc.append("(");
+                String strJdbcType = "";
+                for (ProcParamModel paramModel : list) {
+                    objectHashMap.put(paramModel.getName(), paramModel.getValue());
+                    //判断是否为游标类型
+                    if (paramModel.getJdbcType().equals(JDBCType.REF_CURSOR)) {
+                        strJdbcType = "CURSOR,resultMap=mapCus";
+                    } else {
+                        strJdbcType = paramModel.getJdbcType().toString();
+                    }
+                    sbProc.append(MessageFormat.format("{0}map.{1},mode={2},jdbcType={3}},"
+                            , "#{", paramModel.getName(), paramModel.getMode(), strJdbcType));
+                }
+                //去掉最后的逗号
+                sbProc.delete(sbProc.length() - 1, sbProc.length());
+                sbProc.append(")");
+            }
+            sbProc.append(")}");
+            commonMapper.procedureCmd(sbProc.toString(), objectHashMap);
+            return objectHashMap;
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
 }

collect-fees/collect-fees-service/src/main/java/com/tofly/fees/common/model/ProcParamModel.java

@@ -0,0 +1,38 @@
+package com.tofly.fees.common.model;
+
+import lombok.Data;
+import org.apache.ibatis.mapping.ParameterMode;
+
+import java.sql.JDBCType;
+
+/**
+ * 存储过程参数实体类
+ *
+ * @author shudong
+ */
+@Data
+public class ProcParamModel {
+    /**
+     * 参数名
+     */
+    private String name;
+    /**
+     * 出入参类型
+     */
+    private ParameterMode mode;
+    /**
+     * 参数数据字段类型
+     */
+    private JDBCType jdbcType;
+    /**
+     * 参数对应的值
+     */
+    private Object value;
+
+    public ProcParamModel(String name, ParameterMode mode, JDBCType jdbcType, Object value) {
+        this.name = name;
+        this.mode = mode;
+        this.jdbcType = jdbcType;
+        this.value = value;
+    }
+}

collect-fees/collect-fees-service/src/main/java/com/tofly/fees/financialmgt/controller_easy/SfRecEasyController.java

@@ -1,5 +1,6 @@
 package com.tofly.fees.financialmgt.controller_easy;
 
+import cn.hutool.db.meta.JdbcType;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.tofly.common.core.entity.ResultRespone;
 import com.tofly.fees.common.BaseController;
@@ -7,6 +8,7 @@ import com.tofly.fees.common.dbhelper.DbHelper;
 import com.tofly.fees.common.enums.SysEnum;
 import com.tofly.fees.common.model.CollectionData;
 import com.tofly.fees.common.model.PageLink;
+import com.tofly.fees.common.model.ProcParamModel;
 import com.tofly.fees.common.util.DateUtils;
 import com.tofly.fees.common.util.XmlUtils;
 import io.swagger.annotations.Api;
@@ -14,6 +16,7 @@ import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
 import lombok.AllArgsConstructor;
 import org.apache.ibatis.io.Resources;
+import org.apache.ibatis.mapping.ParameterMode;
 import org.springframework.data.repository.query.Param;
 import org.springframework.format.annotation.DateTimeFormat;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -22,6 +25,8 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.io.InputStream;
+import java.sql.JDBCType;
+import java.sql.ParameterMetaData;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -39,46 +44,65 @@ import static com.tofly.fees.common.ControllerConstants.Mapper_Redis_Prix;
 @RestController
 @AllArgsConstructor
 @RequestMapping("/api/financialmgt/sfrec")
-@Api(tags="核算管理-欠费明细(含欠费变更)接口")
+@Api(tags = "核算管理-欠费明细(含欠费变更)接口")
 public class SfRecEasyController extends BaseController {
 
     /**
      * 分页查询
      *
-     * @param   分页对象
+     * @param 分页对象
      * @return
      */
     @GetMapping("/getListByCustomerNo")
     @ApiOperation(value = "[Easy]查询欠费不分页")
-    public ResultRespone getRecPage( @ApiParam(value = "用户编号")
-                                         @RequestParam(value = "customerNo", defaultValue = "") String customerNo
+    public ResultRespone getRecPage(@ApiParam(value = "用户编号")
+                                    @RequestParam(value = "customerNo", defaultValue = "") String customerNo
     ) throws Exception {
 
 
         DbHelper db = DbHelper.getDbHelper();
-        List<HashMap<String,Object>> lst=new ArrayList<>();
-        //参数
-        Map<String,Object> params = new HashMap<>();
-        params.put("V_YHBH",customerNo);
-        params.put("V_ISFFGX","0");
-        params.put("V_CUR",lst) ;
-        params.put("V_SFCG","0") ;
+        List<HashMap<String, Object>> lst = new ArrayList<>();
+//        //参数
+//        Map<String, Object> params = new HashMap<>();
+//        params.put("V_YHBH", customerNo);
+//        params.put("V_ISFFGX", "0");
+//        params.put("V_CUR", lst);
+//        params.put("V_SFCG", "0");
+//
+//        //这里要注意参数前面的map固定写法不然读取不了数据
+//        Map mp = db.procurdeCmd("{call PROC_CX_QFMX(" +
+//                "#{V_YHBH,mode=IN,jdbcType=VARCHAR}," +
+//                "#{V_ISFFGX,mode=IN,jdbcType=VARCHAR}," +
+//                "#{V_CUR,mode=OUT,jdbcType=CURSOR}," +
+//                "#{V_SFCG,mode=OUT,jdbcType=VARCHAR}" +
+//                ")}", params, SysEnum.MyBatis.getName());
 
-        //这里要注意参数前面的map固定写法不然读取不了数据
-        Map mp = db.procurdeCmd("{call PROC_CX_QFMX(" +
-                "#{V_YHBH,mode=IN,jdbcType=VARCHAR}," +
-                "#{V_ISFFGX,mode=IN,jdbcType=VARCHAR},"+
-                "#{V_CUR,mode=OUT,jdbcType=CURSOR},"+
-                "#{V_SFCG,mode=OUT,jdbcType=VARCHAR}"+
-                ")}",params, SysEnum.MyBatis.getName());
 
-         //存储过程返回的参数
-         ArrayList<Object> arr=(ArrayList<Object>)mp.get("V_CUR");
-         if(mp.get("V_SFCG").equals("0")) {
-             return ResultRespone.success(new CollectionData(arr, arr.size()));
-         }else {
-             return ResultRespone.success(new CollectionData(null,0));
-         }
+        //        //这里要注意参数前面的map固定写法不然读取不了数据
+//        Map mp = db.procurdeCmd("{call PROC_CX_QFMX }", params, SysEnum.MyBatis.getName());
+
+//        //存储过程返回的参数
+//        // ArrayList<Object> arr = (ArrayList<Object>) mp.get("V_CUR");
+//        if (mp.get("V_SFCG").equals("0")) {
+//            return ResultRespone.success(mp.get("V_CUR"));
+//            //return ResultRespone.success(new CollectionData(arr, arr.size()));
+//        } else {
+//            return ResultRespone.success(new CollectionData(null, 0));
+//        }
+
+        List<ProcParamModel> list = new ArrayList<>();
+        list.add(new ProcParamModel("V_YHBH", ParameterMode.IN, JDBCType.VARCHAR, customerNo));
+        list.add(new ProcParamModel("V_ISFFGX", ParameterMode.IN, JDBCType.VARCHAR, "0"));
+        list.add(new ProcParamModel("V_CUR", ParameterMode.OUT, JDBCType.REF_CURSOR, lst));
+        list.add(new ProcParamModel("V_SFCG", ParameterMode.OUT, JDBCType.VARCHAR, "0"));
+        Map map = db.excuteProcedure("PROC_CX_QFMX", list);
+
+        //存储过程返回的参数
+        if (map != null && map.get("V_SFCG").equals("0")) {
+            return ResultRespone.success(map.get("V_CUR"));
+        } else {
+            return ResultRespone.success(new CollectionData(null, 0));
+        }
     }
 
 }