流程引擎-listhandler

smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/design/form/ModelFormHelper.java

@@ -284,6 +284,7 @@ public class ModelFormHelper {
         PageModel pageInfo = parsePageInfo(form.getContent());
         if (pageInfo == null) return "";
         ret.put("pageId", form.getEntityId());
+        ret.put("pageName", getPageName(form));
         ret.put("label", form.getTitle());
         ret.put("service", service);
         ret.put("module", ModelProjectCache.getInstance().getModule(form.getPrjId()));

smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/engine/dynPage/DynPageHelper.java

@@ -17,6 +17,7 @@ import cc.smtweb.framework.core.util.NumberUtil;
 import cc.smtweb.framework.core.util.PubUtil;
 import cc.smtweb.system.bpm.web.design.form.define.*;
 import org.apache.commons.lang3.StringUtils;
+import reactor.util.annotation.Nullable;
 
 import java.util.HashMap;
 import java.util.HashSet;
@@ -47,21 +48,9 @@ public class DynPageHelper {
         return bean.getData();
     }
 
-    /**
-     * 构建select fields from table
-     *
-     * @param dataSet
-     * @return
-     */
-    public static SqlNamedPara buildSelectSql(PageDataset dataSet, Map<String, Object> params) {
-        SqlNamedPara sqlNamedPara = buildWhereSql(dataSet, params);
-        buildSelectSql(dataSet, params, sqlNamedPara);
-        return sqlNamedPara;
-    }
-
-    public static void buildSelectSql(PageDataset dataSet, Map<String, Object> params, SqlNamedPara sqlNamedPara) {
+    private static void buildSelectSql(PageDataset dataSet, Map<String, Object> params, SqlNamedPara sqlNamedPara, IBuildSqlListener listener) {
         StringBuilder sql = new StringBuilder(512);
-        sql.append(buildSelFieldsSql(dataSet, sqlNamedPara));
+        sql.append(buildSelFieldsSql(dataSet, sqlNamedPara, listener));
         if (StringUtils.isNotEmpty(sqlNamedPara.sql)) {
             sql.append(" where ").append(sqlNamedPara.sql);
         }
@@ -79,11 +68,27 @@ public class DynPageHelper {
         sqlNamedPara.rows = MapUtil.readInt(params, SwConsts.PARAM_ROWS);
     }
 
+    /**
+     * 构建select fields from table
+     *
+     * @param dataSet
+     * @return
+     */
+    public static SqlNamedPara buildSelectSql(PageDataset dataSet, Map<String, Object> params) {
+        return buildSelectSqlEx(dataSet, params, null);
+    }
+
+    public static SqlNamedPara buildSelectSqlEx(PageDataset dataSet, Map<String, Object> params, IBuildSqlListener listener) {
+        SqlNamedPara sqlNamedPara = buildWhereSql(dataSet, params, listener);
+        buildSelectSql(dataSet, params, sqlNamedPara, listener);
+        return sqlNamedPara;
+    }
+
     //构建树型查询语句，插入parent_id=?
     public static SqlNamedPara buildTreeSelectSql(PageDataset dataSet, SwMap params, long parentId) {
         ModelTable table = ModelTableCache.getInstance().get(dataSet.masterTable);
         if (table == null) throw new SwException("没有找到指定的表：" + dataSet.masterTable);
-        SqlNamedPara sqlNamedPara = buildWhereSql(dataSet, params);
+        SqlNamedPara sqlNamedPara = buildWhereSql(dataSet, params, null);
         if (table.getType() == SwEnum.TableType.TYPE_TREE.value) {//是树型结构，才做处理
             ModelField field = table.findFieldByType(SwEnum.FieldType.PARENT_ID.value);
             if (field == null) throw new SwException("树型表（" + table.getName() + "）未定义上级id字段！");
@@ -96,7 +101,7 @@ public class DynPageHelper {
             sqlNamedPara.addParas("parent_id", parentId);
         }
 
-        buildSelectSql(dataSet, params, sqlNamedPara);
+        buildSelectSql(dataSet, params, sqlNamedPara, null);
         return sqlNamedPara;
     }
 
@@ -104,7 +109,7 @@ public class DynPageHelper {
     public static SqlNamedPara buildFilterSelectSql(PageDataset dataSet, SwMap params, String text) {
         ModelTable table = ModelTableCache.getInstance().get(dataSet.masterTable);
         if (table == null) throw new SwException("没有找到指定的表：" + dataSet.masterTable);
-        SqlNamedPara sqlNamedPara = buildWhereSql(dataSet, params);
+        SqlNamedPara sqlNamedPara = buildWhereSql(dataSet, params, null);
         if (StringUtils.isNotEmpty(text)) {//有文本信息
             StringBuilder sql = new StringBuilder(128);
             ModelField field = table.findFieldByType(SwEnum.FieldType.CODE.value);
@@ -127,7 +132,7 @@ public class DynPageHelper {
             }
         }
 
-        buildSelectSql(dataSet, params, sqlNamedPara);
+        buildSelectSql(dataSet, params, sqlNamedPara, null);
         return sqlNamedPara;
     }
 
@@ -139,7 +144,11 @@ public class DynPageHelper {
      * @return
      */
     public static SqlNamedPara buildSumSql(PageDataset dataSet, Map<String, Object> params) {
-        SqlNamedPara sqlNamedPara = buildSelectSql(dataSet, params);
+        return buildSumSqlEx(dataSet, params, null);
+    }
+
+    public static SqlNamedPara buildSumSqlEx(PageDataset dataSet, Map<String, Object> params, IBuildSqlListener listener) {
+        SqlNamedPara sqlNamedPara = buildSelectSqlEx(dataSet, params, listener);
         StringBuilder sql = new StringBuilder(256);
         sql.append("select count(1) " + TOTAL_KEY);
         for (PageDatasetField field : dataSet.fields) {
@@ -156,7 +165,7 @@ public class DynPageHelper {
         return sqlNamedPara;
     }
 
-    private static String buildSelFieldsSql(PageDataset dataSet, SqlNamedPara sqlNamedPara) {
+    private static String buildSelFieldsSql(PageDataset dataSet, SqlNamedPara sqlNamedPara, IBuildSqlListener listener) {
         StringBuilder sql = new StringBuilder(512);
         //主表
         ModelTable masterTable = ModelTableCache.getInstance().get(dataSet.masterTable);
@@ -175,6 +184,7 @@ public class DynPageHelper {
             }
             sql.setCharAt(sql.length() - 1, ' ');
             sql.append(" from ").append(masterTable.getSchemaTableName());
+            if (listener != null) listener.buildSelect(dataSet, sql);
             return sql.toString();
         } else {
             return dataSet.sql;
@@ -188,7 +198,7 @@ public class DynPageHelper {
      * @param params
      * @return
      */
-    public static SqlNamedPara buildWhereSql(PageDataset dataSet, Map<String, Object> params) {
+    private static SqlNamedPara buildWhereSql(PageDataset dataSet, Map<String, Object> params, IBuildSqlListener listener) {
         StringBuilder sql = new StringBuilder(512);
         SwMap args = new SwMap();
 
@@ -210,6 +220,7 @@ public class DynPageHelper {
         for (String s : setFixedFilter) {
             args.put(s, MapUtil.readString(params, s, ""));
         }
+        if (listener != null) listener.buildWhere(dataSet, sql, args);
         return new SqlNamedPara(sql.toString(), args);
     }
 

smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/engine/dynPage/DynPageListHandler.java

@@ -12,6 +12,7 @@ import cc.smtweb.framework.core.mvc.service.SqlPara;
 import cc.smtweb.system.bpm.web.design.form.define.PageDataset;
 
 import java.util.List;
+import java.util.Map;
 
 import static cc.smtweb.framework.core.common.SwConsts.TOTAL_KEY;
 
@@ -68,11 +69,24 @@ public class DynPageListHandler extends AbstractListHandler {
         return list;
     }
 
+
+    @Override
+    protected SqlNamedPara buildSumSqlPara() {
+        return DynPageHelper.buildSumSql(pageDataSet, filter);
+    }
+
     @Override
     public R getTotal() {
-        SqlNamedPara sqlPara = DynPageHelper.buildSumSql(pageDataSet, filter);
+        SqlNamedPara sqlParaSum = getCache(KEY_SQLPARA_SUM);
+        if (sqlParaSum == null) {
+            Map<String, Object> map = getCache(KEY_PARAMS);
+            if (map != null) params.putAll(map);
+            sqlParaSum = buildSumSqlPara();
+        }
+        if (sqlParaSum == null) return R.success();
+        setCache(KEY_SQLPARA_SUM, sqlParaSum);
 
-        SwMap mapFooter = DbEngine.getInstance().queryEntityN(sqlPara.sql, sqlPara.mapParas, SwMap.class);
+        SwMap mapFooter = DbEngine.getInstance().queryEntityN(sqlParaSum.sql, sqlParaSum.mapParas, SwMap.class);
 
         SwMap r = new SwMap();
         r.put("total", mapFooter.get(TOTAL_KEY));

smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/engine/dynPage/IBuildSqlListener.java

@@ -0,0 +1,17 @@
+package cc.smtweb.system.bpm.web.engine.dynPage;
+
+import cc.smtweb.framework.core.common.SwMap;
+import cc.smtweb.framework.core.mvc.service.SqlNamedPara;
+import cc.smtweb.system.bpm.web.design.form.define.PageDataset;
+
+/**
+ * Created by Akmm at 2022-08-29 12:24
+ * 动态构建sql时的监听
+ */
+public interface IBuildSqlListener {
+    default void buildWhere(PageDataset dataSet, StringBuilder sql, SwMap args) {
+    }
+
+    default void buildSelect(PageDataset dataSet, StringBuilder sql) {
+    }
+}

smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/engine/model/flow/listcard/single/FlowListHandler.java

@@ -0,0 +1,37 @@
+package cc.smtweb.system.bpm.web.engine.model.flow.listcard.single;
+
+import cc.smtweb.framework.core.common.SwMap;
+import cc.smtweb.framework.core.db.EntityHelper;
+import cc.smtweb.framework.core.mvc.service.SqlNamedPara;
+import cc.smtweb.framework.core.mvc.service.SqlPara;
+import cc.smtweb.system.bpm.web.design.form.define.PageDataset;
+import cc.smtweb.system.bpm.web.engine.dynPage.DynPageHelper;
+import cc.smtweb.system.bpm.web.engine.dynPage.DynPageListHandler;
+import cc.smtweb.system.bpm.web.engine.dynPage.IBuildSqlListener;
+import cc.smtweb.system.bpm.web.engine.flow.entity.ProcInst;
+
+/**
+ * Created by Akmm at 2022-08-29 11:41
+ */
+public class FlowListHandler extends DynPageListHandler {
+    static IBuildSqlListener sqlListener = new IBuildSqlListener(){
+        @Override
+        public void buildSelect(PageDataset dataSet, StringBuilder sql) {
+            sql.append("\ninner join " + EntityHelper.getSchemaTableName(ProcInst.ENTITY_NAME) + " on pri_id=" + dataSet.getModelTable().getIdField());
+        }
+    };
+
+    public FlowListHandler(long pageId, SwMap filter, PageDataset pageDataSet) {
+        super(pageId, filter, pageDataSet);
+    }
+
+    @Override
+    protected SqlPara buildSqlPara() {
+        return DynPageHelper.buildSelectSqlEx(pageDataSet, filter, sqlListener);
+    }
+
+    @Override
+    protected SqlNamedPara buildSumSqlPara() {
+        return DynPageHelper.buildSumSqlEx(pageDataSet, filter, sqlListener);
+    }
+}

smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/engine/model/flow/listcard/single/FlowSingleLoadHandler.java

@@ -69,13 +69,8 @@ public class FlowSingleLoadHandler<T extends DefaultEntity> extends LCSingleLoad
 
     @Override
     protected DynPageListHandler getListWorker(SwMap filter, PageDataset pageDataSet) {
-        return super.getListWorker(filter, pageDataSet);
-    }
-
-    @Override
-    public R list() {
-        DynRetBean bean = DynRetBean.createList(SwListData.EMPTY);
-
-        return R.success(bean);
+        FlowListHandler listHandler = new FlowListHandler(form.getId(), filter, pageDataSet);
+        listHandler.init(params, us);
+        return listHandler;
     }
 }