From 82d497eb486b81cc5e83df9f3a36f1ba4740cbbe Mon Sep 17 00:00:00 2001
From: 许鹏程 <1821349743@qq.com>
Date: 星期三, 24 五月 2023 16:26:21 +0800
Subject: [PATCH] 协同办公个人已办列表添加分页

---
 src/main/java/com/product/administration/service/CooperatesService.java |  494 +++++++++++++++++++++++++++---------------------------
 1 files changed, 247 insertions(+), 247 deletions(-)

diff --git a/src/main/java/com/product/administration/service/CooperatesService.java b/src/main/java/com/product/administration/service/CooperatesService.java
index 806cf4f..ea7f0ed 100644
--- a/src/main/java/com/product/administration/service/CooperatesService.java
+++ b/src/main/java/com/product/administration/service/CooperatesService.java
@@ -38,24 +38,24 @@
 @Component
 @Service
 public class CooperatesService extends AbstractBaseService implements ICooperatesService {
-    @Autowired
-    public BaseDao baseDao;
-    @Autowired
-    public FlowCoordinationService flowCoordinationService;
-    @Autowired
-    PermissionService permissionService;
-    @Autowired
-    QueryFilterService queryFilterService;
-    @Autowired
-    @Qualifier("userOperService")
-    UserService userService;
+	@Autowired
+	public BaseDao baseDao;
+	@Autowired
+	public FlowCoordinationService flowCoordinationService;
+	@Autowired
+	PermissionService permissionService;
+	@Autowired
+	QueryFilterService queryFilterService;
+	@Autowired
+	@Qualifier("userOperService")
+	UserService userService;
 
-    /**
-     * @Date: 2020-03-23 18:10
-     * @Author: ZhouJie
-     * @Description: 鍗忓悓鍔炲叕鍒楄〃
-     */
-    public DataTableEntity getCooperateList(FieldSetEntity fs) throws BaseException {
+	/**
+	 * @Date: 2020-03-23 18:10
+	 * @Author: ZhouJie
+	 * @Description: 鍗忓悓鍔炲叕鍒楄〃
+	 */
+	public DataTableEntity getCooperateList(FieldSetEntity fs) throws BaseException {
 		String queryFilter = BaseUtil.ifNull(BaseUtil.ifNotNull(queryFilterService.getQueryFilter(fs), (value) -> value + " and "), "");
 
 		String filter = queryFilter + " created_by = ? ";
@@ -71,253 +71,253 @@
 		DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_OA_COOPERATES, filter, params.toArray(), null, CmnConst.CREATED_UTC_DATETIME + " DESC", fs.getInteger(CmnConst.PAGESIZE), fs.getInteger(CmnConst.CPAGE));
 		baseDao.loadPromptData(dt);
 		return dt;
-    }
+	}
 
-    /**
-     * @Date: 2020-03-23 17:52
-     * @Author: ZhouJie
-     * @Description: 鍗忓悓鍔炲叕璇︽儏
-     */
-    public String getCooperateInfo(FieldSetEntity fs) throws BaseException {
-        FieldSetEntity fse = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_COOPERATES, fs.getString(CmnConst.UUID), true);
-        DataTableEntity copsub = fse.getSubDataTable(CmnConst.PRODUCT_OA_COOPERATE_SUB);
-        baseDao.loadPromptData(copsub);
+	/**
+	 * @Date: 2020-03-23 17:52
+	 * @Author: ZhouJie
+	 * @Description: 鍗忓悓鍔炲叕璇︽儏
+	 */
+	public String getCooperateInfo(FieldSetEntity fs) throws BaseException {
+		FieldSetEntity fse = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_COOPERATES, fs.getString(CmnConst.UUID), true);
+		DataTableEntity copsub = fse.getSubDataTable(CmnConst.PRODUCT_OA_COOPERATE_SUB);
+		baseDao.loadPromptData(copsub);
 
-        StringBuilder stringBuilder = new StringBuilder();
-        stringBuilder.append(" select ifnull(concat(tricode,'-',receiver) ,receiver) code,uuid,title,cooperate_uuid,grade,receiver as id,receiver,sender, ");
-        stringBuilder.append(" receiver_name,(select user_name FROM product_sys_users where user_id=receiver) label,sender_name,status, ");
-        stringBuilder.append(" tricode,opinion,handle_time,type,attachments from product_oa_cooperate_flow_node where cooperate_uuid=? ORDER BY tricode ");
-        DataTableEntity dt = baseDao.listTable(stringBuilder.toString(), new Object[]{fs.getString("uuid")});
-        JSONArray json = null;
-        if (dt != null && dt.getRows() > 0) {
-            DataTableEntity subData = baseDao.listTable(CmnConst.PRODUCT_OA_COOPERATE_FLOW_REPLY, BaseUtil.buildQuestionMarkFilter("parent_uuid", dt.getRows(), true), dt.getUuids());
-            baseDao.loadPromptData(subData);
-            Map<String, DataTableEntity> subMaps = new HashMap<>();
-            for (int i = 0; i < subData.getRows(); i++) {
-                FieldSetEntity ff = subData.getFieldSetEntity(i);
-                String parent_uuid = ff.getString("parent_uuid");
-                if (subMaps.get(parent_uuid) == null) {
-                    subMaps.put(parent_uuid, new DataTableEntity());
-                }
-                subMaps.get(parent_uuid).addFieldSetEntity(ff);
-            }
-            dt.getMeta().setTableName(new Object[]{"product_oa_cooperate_flow_node"});
-            DataTableEntity dd = dt.clones();
-            for (int i = 0; i < dt.getRows(); i++) {
-                String userId = dt.getString(i, "id");
-                String userAvatar = userService.getUserAvatar(userId);
-                if (!StringUtils.isEmpty(userAvatar)) {
-                    if (i == 0) {
-                        dt.setFieldValue(i, "avatar", userAvatar);
-                    }
-                    dd.setFieldValue(i, "avatar", userAvatar);
-                }
-                dd.getFieldSetEntity(i).addSubDataTable(subMaps.get(dt.getFieldSetEntity(i).getUUID()));
-            }
-            fse.addSubDataTable(dd);
-            json = BaseUtil.dataTableToTreeData(dt, "code", "tricode", null, false);
-        }
-        String sql = " select count(*) sum from product_oa_cooperate_flow_node where cooperate_uuid =?  and status =? ";
-        String sql1 = " select count(*) sum from product_oa_cooperate_flow_node where cooperate_uuid =? ";
-        String sql0 = " select count(*) sum from product_oa_cooperate_flow_node where cooperate_uuid =?  and (status =? or status is null) ";
-        FieldSetEntity fss = baseDao.getFieldSetEntityBySQL(sql1, new Object[]{fs.getString(CmnConst.UUID)}, true);
-        FieldSetEntity fs0 = baseDao.getFieldSetEntityBySQL(sql0, new Object[]{fs.getString(CmnConst.UUID), 0}, true);
-        FieldSetEntity fs1 = baseDao.getFieldSetEntityBySQL(sql, new Object[]{fs.getString(CmnConst.UUID), 1}, true);
-        FieldSetEntity fs2 = baseDao.getFieldSetEntityBySQL(sql, new Object[]{fs.getString(CmnConst.UUID), 2}, true);
-        if (fss.getInteger("sum") == null) {
-            fse.setValue("totals", 0);//娴佺▼鍏辨湁浜烘暟
-        } else {
-            fse.setValue("totals", fss.getInteger("sum") - 1);
-        }
-        if (fs0.getInteger("sum") == null) {
-            fse.setValue("uncollectd", 0);//鏈敹鏈姙浜烘暟
-        } else {
-            fse.setValue("uncollectd", fs0.getInteger("sum"));
-        }
-        if (fs1.getInteger("sum") == null) {
-            fse.setValue("received", 0);//宸叉敹鏈姙浜烘暟
-        } else {
-            fse.setValue("received", fs1.getInteger("sum"));
-        }
-        if (fs2.getInteger("sum") == null) {
-            fse.setValue("done", 0);//宸叉敹宸插姙浜烘暟
-        } else {
-            fse.setValue("done", fs2.getInteger("sum") - 1);
-        }
-        int a = fse.getInteger("totals") - fse.getInteger("uncollectd") - fse.getInteger("received") - fse.getInteger("done");
-        fse.setValue("not_yet", a);//鏈埌鐜妭浜烘暟
-        if (fse.getString("attachment") == null || "".equals(fse.getString("attachment"))) {
-            fse.setValue("attachment_number", 0);//闄勪欢鏁伴噺
-        } else {
-            int b = 0;
-            String str = fse.getString("attachment");
-            String[] array = str.split(",");
-            b = array.length;//瀛樺湪绗﹀彿鐨勪釜鏁�
-            fse.setValue("attachment_number", b);
-        }
-        if ("1".equals(fs.getString("countersign_type"))) {
-            fse.setValue("countersign_type", 1);
-        }
-        String emergency_degree = fse.getString("emergency_degree");
-        baseDao.loadPromptData(fse);
-        Map map = new HashMap();
-        map.put("document_process", json);
-        fse.setValue(CoreConst.API_RETURN_KEY_STATUS, fse.getString("status_save_value"));
+		StringBuilder stringBuilder = new StringBuilder();
+		stringBuilder.append(" select ifnull(concat(tricode,'-',receiver) ,receiver) code,uuid,title,cooperate_uuid,grade,receiver as id,receiver,sender, ");
+		stringBuilder.append(" receiver_name,(select user_name FROM product_sys_users where user_id=receiver) label,sender_name,status, ");
+		stringBuilder.append(" tricode,opinion,handle_time,type,attachments from product_oa_cooperate_flow_node where cooperate_uuid=? ORDER BY tricode ");
+		DataTableEntity dt = baseDao.listTable(stringBuilder.toString(), new Object[]{fs.getString("uuid")});
+		JSONArray json = null;
+		if (dt != null && dt.getRows() > 0) {
+			DataTableEntity subData = baseDao.listTable(CmnConst.PRODUCT_OA_COOPERATE_FLOW_REPLY, BaseUtil.buildQuestionMarkFilter("parent_uuid", dt.getRows(), true), dt.getUuids());
+			baseDao.loadPromptData(subData);
+			Map<String, DataTableEntity> subMaps = new HashMap<>();
+			for (int i = 0; i < subData.getRows(); i++) {
+				FieldSetEntity ff = subData.getFieldSetEntity(i);
+				String parent_uuid = ff.getString("parent_uuid");
+				if (subMaps.get(parent_uuid) == null) {
+					subMaps.put(parent_uuid, new DataTableEntity());
+				}
+				subMaps.get(parent_uuid).addFieldSetEntity(ff);
+			}
+			dt.getMeta().setTableName(new Object[]{"product_oa_cooperate_flow_node"});
+			DataTableEntity dd = dt.clones();
+			for (int i = 0; i < dt.getRows(); i++) {
+				String userId = dt.getString(i, "id");
+				String userAvatar = userService.getUserAvatar(userId);
+				if (!StringUtils.isEmpty(userAvatar)) {
+					if (i == 0) {
+						dt.setFieldValue(i, "avatar", userAvatar);
+					}
+					dd.setFieldValue(i, "avatar", userAvatar);
+				}
+				dd.getFieldSetEntity(i).addSubDataTable(subMaps.get(dt.getFieldSetEntity(i).getUUID()));
+			}
+			fse.addSubDataTable(dd);
+			json = BaseUtil.dataTableToTreeData(dt, "code", "tricode", null, false);
+		}
+		String sql = " select count(*) sum from product_oa_cooperate_flow_node where cooperate_uuid =?  and status =? ";
+		String sql1 = " select count(*) sum from product_oa_cooperate_flow_node where cooperate_uuid =? ";
+		String sql0 = " select count(*) sum from product_oa_cooperate_flow_node where cooperate_uuid =?  and (status =? or status is null) ";
+		FieldSetEntity fss = baseDao.getFieldSetEntityBySQL(sql1, new Object[]{fs.getString(CmnConst.UUID)}, true);
+		FieldSetEntity fs0 = baseDao.getFieldSetEntityBySQL(sql0, new Object[]{fs.getString(CmnConst.UUID), 0}, true);
+		FieldSetEntity fs1 = baseDao.getFieldSetEntityBySQL(sql, new Object[]{fs.getString(CmnConst.UUID), 1}, true);
+		FieldSetEntity fs2 = baseDao.getFieldSetEntityBySQL(sql, new Object[]{fs.getString(CmnConst.UUID), 2}, true);
+		if (fss.getInteger("sum") == null) {
+			fse.setValue("totals", 0);//娴佺▼鍏辨湁浜烘暟
+		} else {
+			fse.setValue("totals", fss.getInteger("sum") - 1);
+		}
+		if (fs0.getInteger("sum") == null) {
+			fse.setValue("uncollectd", 0);//鏈敹鏈姙浜烘暟
+		} else {
+			fse.setValue("uncollectd", fs0.getInteger("sum"));
+		}
+		if (fs1.getInteger("sum") == null) {
+			fse.setValue("received", 0);//宸叉敹鏈姙浜烘暟
+		} else {
+			fse.setValue("received", fs1.getInteger("sum"));
+		}
+		if (fs2.getInteger("sum") == null) {
+			fse.setValue("done", 0);//宸叉敹宸插姙浜烘暟
+		} else {
+			fse.setValue("done", fs2.getInteger("sum") - 1);
+		}
+		int a = fse.getInteger("totals") - fse.getInteger("uncollectd") - fse.getInteger("received") - fse.getInteger("done");
+		fse.setValue("not_yet", a);//鏈埌鐜妭浜烘暟
+		if (fse.getString("attachment") == null || "".equals(fse.getString("attachment"))) {
+			fse.setValue("attachment_number", 0);//闄勪欢鏁伴噺
+		} else {
+			int b = 0;
+			String str = fse.getString("attachment");
+			String[] array = str.split(",");
+			b = array.length;//瀛樺湪绗﹀彿鐨勪釜鏁�
+			fse.setValue("attachment_number", b);
+		}
+		if ("1".equals(fs.getString("countersign_type"))) {
+			fse.setValue("countersign_type", 1);
+		}
+		String emergency_degree = fse.getString("emergency_degree");
+		baseDao.loadPromptData(fse);
+		Map map = new HashMap();
+		map.put("document_process", json);
+		fse.setValue(CoreConst.API_RETURN_KEY_STATUS, fse.getString("status_save_value"));
 //        String s = String.copyValueOf(emergency_degree.toCharArray(), 0, emergency_degree.length());
-        fse.setValue("emergency_degree_show_value", fse.getString("emergency_degree"));
-        fse.setValue("emergency_degree", emergency_degree);
-        return BaseUtil.success(fse, map);
-    }
+		fse.setValue("emergency_degree_show_value", fse.getString("emergency_degree"));
+		fse.setValue("emergency_degree", emergency_degree);
+		return BaseUtil.success(fse, map);
+	}
 
-    /**
-     * @Date: 2020-03-23 14:56
-     * @Author: ZhouJie
-     * @Description: 鏂板鍗忓悓鍔炲叕
-     */
-    @Transactional
-    public String addCooperate(FieldSetEntity fs) throws BaseException {
-        fs.setValue("created_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
-        fs.setValue("created_utc_datetime", new Date());
-        String uuid = baseDao.add(fs);
-        flowCoordinationService.saveCoordinationStartFlow(fs);
-        return uuid;
-    }
+	/**
+	 * @Date: 2020-03-23 14:56
+	 * @Author: ZhouJie
+	 * @Description: 鏂板鍗忓悓鍔炲叕
+	 */
+	@Transactional
+	public String addCooperate(FieldSetEntity fs) throws BaseException {
+		fs.setValue("created_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
+		fs.setValue("created_utc_datetime", new Date());
+		String uuid = baseDao.add(fs);
+		flowCoordinationService.saveCoordinationStartFlow(fs);
+		return uuid;
+	}
 
-    /**
-     * @Date: 2020-03-23 17:03
-     * @Author: ZhouJie
-     * @Description: 淇敼鍗忓悓鍔炲叕
-     */
-    @Transactional
-    public boolean updateCooperate(FieldSetEntity fs) throws BaseException {
-        fs.setValue("updated_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
-        fs.setValue("updated_utc_datetime", new Date());
-        fs.setValue("type", 0);
-        Boolean flag = baseDao.update(fs);
-        flowCoordinationService.saveCoordinationStartFlow(fs);
-        return flag;
-    }
+	/**
+	 * @Date: 2020-03-23 17:03
+	 * @Author: ZhouJie
+	 * @Description: 淇敼鍗忓悓鍔炲叕
+	 */
+	@Transactional
+	public boolean updateCooperate(FieldSetEntity fs) throws BaseException {
+		fs.setValue("updated_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
+		fs.setValue("updated_utc_datetime", new Date());
+		fs.setValue("type", 0);
+		Boolean flag = baseDao.update(fs);
+		flowCoordinationService.saveCoordinationStartFlow(fs);
+		return flag;
+	}
 
-    /**
-     * @Date: 2020-03-23 17:30
-     * @Author: ZhouJie
-     * @Description: 鍒犻櫎鍗忓悓鍔炲叕
-     */
-    @Transactional
-    public boolean deleteCooperate(FieldSetEntity fs) throws BaseException {
-        String uuid = fs.getUUID();
-        String[] uuids = uuid.split(",");
-        return baseDao.delete(CmnConst.PRODUCT_OA_COOPERATES, BaseUtil.buildQuestionMarkFilter(CmnConst.UUID, uuids.length, true), uuids);
-    }
+	/**
+	 * @Date: 2020-03-23 17:30
+	 * @Author: ZhouJie
+	 * @Description: 鍒犻櫎鍗忓悓鍔炲叕
+	 */
+	@Transactional
+	public boolean deleteCooperate(FieldSetEntity fs) throws BaseException {
+		String uuid = fs.getUUID();
+		String[] uuids = uuid.split(",");
+		return baseDao.delete(CmnConst.PRODUCT_OA_COOPERATES, BaseUtil.buildQuestionMarkFilter(CmnConst.UUID, uuids.length, true), uuids);
+	}
 
-    /**
-     * @Date: 2020-04-01 16:30
-     * @Author: ZhouJie
-     * @Description: 鍗忓悓鍔炲叕閫佸姙
-     */
-    public void sendCooperate(FieldSetEntity fs) throws BaseException {
-        DataTableEntity dt = fs.getSubDataTable("document_process");
-        if (dt != null && dt.getRows() > 0) {
-            for (int i = 0; i < dt.getRows(); i++) {
-                FieldSetEntity fss = dt.getFieldSetEntity(i);
-                if (fs.getString("flow_node_uuid") == null) {
-                    if (fss.getString("sender_name") == null) {
-                        fss.setValue("status", 2);
-                    }
-                }
-            }
-        }
-        if (fs.getUUID() == null) {
-            fs.setValue("created_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
-            fs.setValue("created_utc_datetime", new Date());
-            fs.setValue("start_time", new Date());//鍙戣捣鏃堕棿
-            baseDao.add(fs);
-        } else {
-            fs.setValue("updated_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
-            fs.setValue("updated_utc_datetime", new Date());
-            fs.setValue("start_time", new Date());//鍙戣捣鏃堕棿
-            if (fs.getInteger("type") == 4) {
-                baseDao.update(fs);
-            }
-        }
-        flowCoordinationService.saveCoordinationStartFlow(fs);
-    }
+	/**
+	 * @Date: 2020-04-01 16:30
+	 * @Author: ZhouJie
+	 * @Description: 鍗忓悓鍔炲叕閫佸姙
+	 */
+	public void sendCooperate(FieldSetEntity fs) throws BaseException {
+		DataTableEntity dt = fs.getSubDataTable("document_process");
+		if (dt != null && dt.getRows() > 0) {
+			for (int i = 0; i < dt.getRows(); i++) {
+				FieldSetEntity fss = dt.getFieldSetEntity(i);
+				if (fs.getString("flow_node_uuid") == null) {
+					if (fss.getString("sender_name") == null) {
+						fss.setValue("status", 2);
+					}
+				}
+			}
+		}
+		if (fs.getUUID() == null) {
+			fs.setValue("created_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
+			fs.setValue("created_utc_datetime", new Date());
+			fs.setValue("start_time", new Date());//鍙戣捣鏃堕棿
+			baseDao.add(fs);
+		} else {
+			fs.setValue("updated_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
+			fs.setValue("updated_utc_datetime", new Date());
+			fs.setValue("start_time", new Date());//鍙戣捣鏃堕棿
+			if (fs.getInteger("type") == 4) {
+				baseDao.update(fs);
+			}
+		}
+		flowCoordinationService.saveCoordinationStartFlow(fs);
+	}
 
-    /**
-     * @description: 鏆傚瓨寰呭姙
-     * @author: ZhouJie
-     * @date: 2021-05-26 16:53
-     */
-    public void saveTodo(FieldSetEntity fs) throws BaseException {
-        fs.setValue("status", 1);
-        baseDao.update(fs);
-    }
+	/**
+	 * @description: 鏆傚瓨寰呭姙
+	 * @author: ZhouJie
+	 * @date: 2021-05-26 16:53
+	 */
+	public void saveTodo(FieldSetEntity fs) throws BaseException {
+		fs.setValue("status", 1);
+		baseDao.update(fs);
+	}
 
-    /**
-     * @description: 鍗忓悓琛ュ厖姝f枃
-     * @author: ZhouJie
-     * @date: 2021-05-28 14:54
-     */
-    @Transactional
-    public String addSupplyText(FieldSetEntity fs) {
-        fs.setValue("cooperate_uuid", fs.getString("cooperate_uuid"));
-        fs.setValue("created_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
-        fs.setValue("created_utc_datetime", new Date());
-        return baseDao.add(fs);
-    }
+	/**
+	 * @description: 鍗忓悓琛ュ厖姝f枃
+	 * @author: ZhouJie
+	 * @date: 2021-05-28 14:54
+	 */
+	@Transactional
+	public String addSupplyText(FieldSetEntity fs) {
+		fs.setValue("cooperate_uuid", fs.getString("cooperate_uuid"));
+		fs.setValue("created_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
+		fs.setValue("created_utc_datetime", new Date());
+		return baseDao.add(fs);
+	}
 
-    /**
-     * @description: 鍗忓悓鍔炲叕鍌姙
-     * @author: ZhouJie
-     * @date: 2021-06-03 17:20
-     */
-    public void urging(FieldSetEntity fse) {
-        FieldSetEntity fs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_COOPERATES, fse.getString("cooperate_uuid"), false);
-        WebsocketMesssageServiceThread.getInstance().appendMessage(
-                fse.getString("receiver"),
-                "鍗忓悓銆�" + fs.getString("title") + "銆�" + fse.getString("content"),
-                "鍌姙:",
-                SpringMVCContextHolder.getCurrentUser().getUser_id(),
-                CoreConst.SYSTEM_MESSAGE_TYPE_DEALT + "",
-                CmnConst.PRODUCT_OA_COOPERATE_URL + "?" + CmnConst.UUID + "=" + fs.getString(CoreConst.UUID) + "&" + CmnConst.FIELD_COOPERATE_FLOW_NODE_UUID + "=" + fse.getUUID(),
-                CmnConst.PRODUCT_OA_COOPERATES,
-                fs.getUUID(),
-                fs.getInteger(CoreConst.CREATED_BY),
-                0,
-                0
-        );
-    }
+	/**
+	 * @description: 鍗忓悓鍔炲叕鍌姙
+	 * @author: ZhouJie
+	 * @date: 2021-06-03 17:20
+	 */
+	public void urging(FieldSetEntity fse) {
+		FieldSetEntity fs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_COOPERATES, fse.getString("cooperate_uuid"), false);
+		WebsocketMesssageServiceThread.getInstance().appendMessage(
+				fse.getString("receiver"),
+				"鍗忓悓銆�" + fs.getString("title") + "銆�" + fse.getString("content"),
+				"鍌姙:",
+				SpringMVCContextHolder.getCurrentUser().getUser_id(),
+				CoreConst.SYSTEM_MESSAGE_TYPE_DEALT + "",
+				CmnConst.PRODUCT_OA_COOPERATE_URL + "?" + CmnConst.UUID + "=" + fs.getString(CoreConst.UUID) + "&" + CmnConst.FIELD_COOPERATE_FLOW_NODE_UUID + "=" + fse.getUUID(),
+				CmnConst.PRODUCT_OA_COOPERATES,
+				fs.getUUID(),
+				fs.getInteger(CoreConst.CREATED_BY),
+				0,
+				0
+		);
+	}
 
-    /**
-     * @description: 娑堟伅鐘舵�佹敼涓衡�滃凡鏀舵湭鍔炩��
-     * @author: ZhouJie
-     * @date: 2021-06-11 11:00
-     */
-    public boolean modifyState(String node_uuid) {
-        String sql = " update product_oa_cooperate_flow_node set status=1 where status=0 and  uuid=?";
-        return baseDao.executeUpdate(sql, new Object[]{node_uuid});
-    }
+	/**
+	 * @description: 娑堟伅鐘舵�佹敼涓衡�滃凡鏀舵湭鍔炩��
+	 * @author: ZhouJie
+	 * @date: 2021-06-11 11:00
+	 */
+	public boolean modifyState(String node_uuid) {
+		String sql = " update product_oa_cooperate_flow_node set status=1 where status=0 and  uuid=?";
+		return baseDao.executeUpdate(sql, new Object[]{node_uuid});
+	}
 
-    /**
-     * @description: 娑堟伅澶勭悊鍒楄〃
-     * @author: ZhouJie
-     * @date: 2021-06-16 11:34
-     */
-    public DataTableEntity getNowUserList(FieldSetEntity fs) {
-        int user_id = SpringMVCContextHolder.getCurrentUser().getUser_id();
+	/**
+	 * @description: 娑堟伅澶勭悊鍒楄〃
+	 * @author: ZhouJie
+	 * @date: 2021-06-16 11:34
+	 */
+	public DataTableEntity getNowUserList(FieldSetEntity fs) {
+		int user_id = SpringMVCContextHolder.getCurrentUser().getUser_id();
 		String queryFilter = queryFilterService.getQueryFilter(fs);
-        StringBuffer str = new StringBuffer();
-        str.append(" select lc.*,lcn.uuid flow_node_uuid from product_oa_cooperate_flow_node lcn LEFT JOIN product_oa_COOPERATEs lc ");
-        str.append(" on lc.uuid=lcn.cooperate_uuid where lcn.receiver=? and lcn.status=? and sender_name is not null ");
+		StringBuffer str = new StringBuffer();
+		str.append(" select lc.*,lcn.uuid flow_node_uuid from product_oa_cooperate_flow_node lcn LEFT JOIN product_oa_cooperates lc ");
+		str.append(" on lc.uuid=lcn.cooperate_uuid where lcn.receiver=? and lcn.status=? and sender_name is not null ");
 		if (!StringUtils.isEmpty(queryFilter)) {
 			str.append(" and ").append(queryFilter);
 		}
-        DataTableEntity dt = baseDao.listTable(str.toString(), new Object[]{user_id, 2});
-		dt.getMeta().addAliasTable("product_oa_COOPERATEs", "lc");
+		DataTableEntity dt = baseDao.listTable(str.toString(), new Object[]{user_id, 2}, fs.getInteger(CmnConst.PAGESIZE), fs.getInteger(CmnConst.CPAGE));
+		dt.getMeta().addAliasTable("product_oa_cooperates", "lc");
 		dt.getMeta().addAliasTable("product_oa_cooperate_flow_node", "lcn");
-        baseDao.loadPromptData(dt);
-        return dt;
-    }
+		baseDao.loadPromptData(dt);
+		return dt;
+	}
 
 
 }

--
Gitblit v1.9.2