From 605f8c50fdb0d8cf69bc32f79dbf33e7c16f2ba3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com>
Date: Fri, 22 Dec 2023 20:28:36 +0800
Subject: [PATCH] 'commit'

---
 .../Collect/Controller/CollectController.java | 24 +++++++++
 .../QingLong/Collect/Model/CollectModel.java  | 51 +++++++++++++++++++
 2 files changed, 75 insertions(+)

diff --git a/src/main/java/com/dsideal/QingLong/Collect/Controller/CollectController.java b/src/main/java/com/dsideal/QingLong/Collect/Controller/CollectController.java
index 805e7e4e..4cc0e077 100644
--- a/src/main/java/com/dsideal/QingLong/Collect/Controller/CollectController.java
+++ b/src/main/java/com/dsideal/QingLong/Collect/Controller/CollectController.java
@@ -544,4 +544,28 @@ public class CollectController extends Controller {
         Page<Record> list = cm.getBureauList(org_type_id, school_type_id, level_id, city_id, area_id, page, limit);
         renderJson(CommonUtil.renderJsonForLayUI(list));
     }
+
+    /**
+     * 功能：发布任务
+     *
+     * @param job_id
+     * @param deadline_time
+     * @param shiZhiSchool   市直属学校：1选中，0未选中
+     * @param shiZhiJiaoFu   市直属教辅单位：1选中，0未选中
+     * @param quXiaoJiaoYuJu 区县教育局：1选中，0未选中
+     * @param bureauIds      按单位选择的单位ids
+     */
+    @Before({POST.class})
+    @IsLoginInterface({})
+    @IsNumericInterface({"job_id", "shiZhiSchool", "shiZhiJiaoFu", "quXiaoJiaoYuJu"})
+    @EmptyInterface({"deadline_time"})
+    public void publishJob(int job_id, String deadline_time, int shiZhiSchool,
+                           int shiZhiJiaoFu, int quXiaoJiaoYuJu, String bureauIds) throws ParseException {
+
+        cm.publishJob(job_id, deadline_time, shiZhiSchool, shiZhiJiaoFu, quXiaoJiaoYuJu, bureauIds);
+        Map map = new HashMap();
+        map.put("success", true);
+        map.put("message", "保存成功!");
+        renderJson(map);
+    }
 }
\ No newline at end of file
diff --git a/src/main/java/com/dsideal/QingLong/Collect/Model/CollectModel.java b/src/main/java/com/dsideal/QingLong/Collect/Model/CollectModel.java
index 1c19ba5e..576f163e 100644
--- a/src/main/java/com/dsideal/QingLong/Collect/Model/CollectModel.java
+++ b/src/main/java/com/dsideal/QingLong/Collect/Model/CollectModel.java
@@ -969,4 +969,55 @@ public class CollectModel {
         Page<Record> pageRecord = Db.paginateByFullSql(page, limit, CommonUtil.getTotalSql(sql), sql);
         return pageRecord;
     }
+
+    /**
+     * 功能：发布任务
+     *
+     * @param job_id
+     * @param deadline_time
+     * @param shiZhiSchool   市直属学校：1选中，0未选中
+     * @param shiZhiJiaoFu   市直属教辅单位：1选中，0未选中
+     * @param quXiaoJiaoYuJu 区县教育局：1选中，0未选中
+     * @param bureauIds      按单位选择的单位ids
+     */
+    public void publishJob(int job_id, String deadline_time, int shiZhiSchool,
+                           int shiZhiJiaoFu, int quXiaoJiaoYuJu, String bureauIds) throws ParseException {
+        Set<String> bureauSet = new HashSet<>();
+        if (shiZhiSchool == 1) {
+            Page<Record> list = getBureauList(9, -1, 1, null, null, 1, 9999);
+            for (Record record : list.getList()) {
+                bureauSet.add(record.getStr("org_id"));
+            }
+        }
+        if (shiZhiJiaoFu == 1) {
+            Page<Record> list = getBureauList(5, -1, 1, null, null, 1, 9999);
+            for (Record record : list.getList()) {
+                bureauSet.add(record.getStr("org_id"));
+            }
+        }
+        if (quXiaoJiaoYuJu == 1) {
+            Page<Record> list = getBureauList(4, -1, 1, null, null, 1, 9999);
+            for (Record record : list.getList()) {
+                bureauSet.add(record.getStr("org_id"));
+            }
+        }
+        for (String s : bureauIds.split(",")) {
+            bureauSet.add(s);
+        }
+        //写主表
+        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+        Date date = dateFormat.parse(deadline_time);
+        String sql = "update t_collect_job set publish_time=now(),publish_state=1,deadline_time=? where job_id=?";
+        Db.update(sql, date, job_id);
+        //写任务分派表
+        List<Record> list = new ArrayList<>();
+        for (String s : bureauSet) {
+            Record record = new Record();
+            record.set("job_id", job_id);
+            record.set("bureau_id", s);
+            record.set("is_finish", 0);
+            list.add(record);
+        }
+        Db.batchSave("t_collect_job_bureau", list, 100);
+    }
 }
\ No newline at end of file