From 362c23e82c371ec7c76c93f01b193813812a7761 Mon Sep 17 00:00:00 2001 From: yuxueliang0813 <407010292@qq.com> Date: Thu, 14 Aug 2025 11:26:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=9A=E5=8A=A1=E8=AE=A4=E9=A2=86=E5=A2=9E?= =?UTF-8?q?=E5=8A=A0=E7=94=A8=E6=88=B7=E7=BB=84=E5=A4=84=E7=90=86=E9=80=BB?= =?UTF-8?q?=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../fi/plugin/task/UnclaimedNoticeTask.java | 20 +++++++++++++++++-- 1 file changed, 18 insertions(+), 2 deletions(-) diff --git a/main/java/shjh/jhzj7/fi/fi/plugin/task/UnclaimedNoticeTask.java b/main/java/shjh/jhzj7/fi/fi/plugin/task/UnclaimedNoticeTask.java index c92d709..eb036df 100644 --- a/main/java/shjh/jhzj7/fi/fi/plugin/task/UnclaimedNoticeTask.java +++ b/main/java/shjh/jhzj7/fi/fi/plugin/task/UnclaimedNoticeTask.java @@ -13,8 +13,6 @@ import kd.bos.servicehelper.BusinessDataServiceHelper; import kd.sdk.plugin.Plugin; import shjh.jhzj7.fi.fi.utils.JhzjUtils; -import java.text.ParseException; -import java.text.SimpleDateFormat; import java.time.LocalDate; import java.time.format.DateTimeFormatter; import java.util.ArrayList; @@ -29,6 +27,7 @@ import java.util.Map; public class UnclaimedNoticeTask extends AbstractTask implements Plugin { private static final String entityName = "cas_claimannounce";//认领中心-公告 + private static final String UGName = "fbd_usergroup";//用户组-t_fbd_usergroup //select * from t_cas_claimnoticebill where fbusinesstype='rec' and fclaimstatus='0' private static final Log logger = LogFactory.getLog(UnclaimedNoticeTask.class); @@ -52,6 +51,8 @@ public class UnclaimedNoticeTask extends AbstractTask implements Plugin { DynamicObjectCollection usercolls; Map> userBills = new HashMap<>();//缓存用户和认领单的关系 String userid; + String groupid; + DynamicObject groupinfo; List billlist; for(DynamicObject dio : colls){ dio = BusinessDataServiceHelper.loadSingle(dio.getLong("id"),entityName); @@ -66,6 +67,21 @@ public class UnclaimedNoticeTask extends AbstractTask implements Plugin { userBills.put(userid,billlist); } billlist.add(dio); + }else if("2".equals(userinfo.getString("claimtype"))){ + //认领类别 是用户组 fbd_usergroup 根据组内的人员进行消息发送 + groupid = userinfo.getString("claimtypeid"); + groupinfo = BusinessDataServiceHelper.loadSingle(Long.parseLong(groupid),UGName); + //获得组内所有用户 + DynamicObjectCollection ugss = groupinfo.getDynamicObjectCollection("entryentity"); + for (DynamicObject uguinfo : ugss) { + userid = uguinfo.getString("userfield.id"); + billlist = userBills.get(userid); + if(billlist == null){ + billlist = new ArrayList<>(); + userBills.put(userid,billlist); + } + billlist.add(dio); + } } } }