'commit'

src/main/java/com/dsideal/QingLong/Collect/Model/CollectModel.java

@@ -1224,17 +1224,13 @@ public class CollectModel {
                             if (fill_type_id == 2) statusCodeList.add(2120); //人员任务，市里发的，要求向下级单位转发的，还没有转发的
                             if (fill_type_id == 3) {
                                 statusCodeList.add(2130); //人员任务，市里发的，要求向本单位转发的，还没有转发的
-                                statusCodeList.add(2120);//人员任务，市里发的，要求向下级单位转发的，还没有转发的
+                                statusCodeList.add(2120); //人员任务，市里发的，要求向下级单位转发的，还没有转发的
                             }
                         }
                     }
                     if (publish_job_type_id == 2) {//县区
-                        //县区教育局
-                        if (orgTypeId == 1) {
-                            statusCodeList.add(2210);   //人员任务，县发起，需本单位填报，未填报
-                        } else
-                            //接收者：县区教辅单位，县区学校
-                            statusCodeList.add(2230);   //人员任务，县发起，需转发本单位，未转发
+                        //接收者：县区教育局,县区教辅单位，县区学校
+                        statusCodeList.add(2230);   //人员任务，县发起，需转发本单位，未转发
                     }
                     if (publish_job_type_id == 3) {//单位
                         statusCodeList.add(2310);  //2:人员任务，3：单位发的，1：填报任务，0：没填写
@@ -1976,44 +1972,41 @@ public class CollectModel {
         // 1:市 2：县区 3：单位
         int publish_job_type_id = getPublishJobTypeId(publish_role_id);
 
-        for (String s : targetSet) {
-            // 当前转发人是县区
-            if (publish_job_type_id == 2) {
-                Record record = new Record();
+        //下一个转发状态
+        int next_status_code = -1;
 
-                int next_status_code = -1;
-                //只有市里过来的任务，才能让县来转发 forward_job
-                //县里发的，用publish_job来解决
-                if (status_code == 1120) {  //1120 单位，市，需转发下级，未转发
-                    next_status_code = 1210;//1210 单位，县，填报，未填报
-                }
-                if (status_code == 2120) {  //2120 人员，市，需转发下级，未转发
-                    next_status_code = 2230;//2230 人员，县，需转发本级，未转发
-                }
-                if (status_code == 2130) {  //2130 人员，市，需转发本单位，未转发
-                    next_status_code = 2210;//2210 人员，县，填报，未填报
-                }
-                //有可能是转到本单位的人员，或者，转给下级的单位
-                record.set("job_id", job_id);
-                record.set("deadline_time", dateFormat.parse(deadline_time));
-                record.set("target_id", s);
-                record.set("bureau_id", bureau_id);
-                record.set("status_code", next_status_code);
-                list.add(record);
-            }
-            // 当前转发人是单位
-            if (publish_job_type_id == 3) {
-                //肯定是转发到人
-                Record record = new Record();
-                record.set("job_id", job_id);
-                record.set("target_id", s);
-                record.set("bureau_id", bureau_id);
-                record.set("status_code", 2310);//人员，单位，填报，待填
-                list.add(record);
+        for (String s : targetSet) {
+            switch (publish_job_type_id) {
+                case 1:
+                    //不会有发布角色是1的，因为市不需要转发
+                    break;
+                case 2:// 当前转发人是县区
+                    //有可能是转到本单位的人员，或者，转给下级的单位
+                    if (status_code == 1120) {  //1120 单位，市，需转发下级，未转发
+                        next_status_code = 1210;//1210 单位，县，填报，未填报
+                    }
+                    if (status_code == 2120) {  //2120 人员，市，需转发下级，未转发
+                        next_status_code = 2230;//2230 人员，县，需转发本级，未转发
+                    }
+                    if (status_code == 2130) {  //2130 人员，市，需转发本单位，未转发
+                        next_status_code = 2210;//2210 人员，县，填报，未填报
+                    }
+                    break;
+                // 当前转发人是单位
+                case 3:
+                    //肯定是转发到人
+                    next_status_code = 2310;
+                    break;
             }
+            Record record = new Record();
+            record.set("job_id", job_id);
+            record.set("deadline_time", dateFormat.parse(deadline_time));
+            record.set("target_id", s);
+            record.set("bureau_id", bureau_id);
+            record.set("status_code", next_status_code);
+            list.add(record);
         }
         Db.batchSave("t_collect_job_target", list, 500);
-
         //回写完成标志
         writeJobFinish(job_id, status_code, bureau_id, null);
     }