[task-1475] 基础数据维护

ibps-provider-root/modules/provider-platform/src/main/java/com/lc/ibps/platform/plan/job/BasicDataInitializationJob.java

@@ -20,25 +20,26 @@ public class BasicDataInitializationJob extends BaseJob2 {
 
     @Override
     public void executeJob(JobExecutionContext context) throws Exception {
-        //'Y' means just create one records.
+        //'Y' means just create one records.   注：所有字段均用大写
         // {"t_dyzzb", "", "N", "岗位职责配置列表"},
         String[][] tables = {
-                {"t_yjyaylpzb", "t_yjyaylpzzb", "Y", "应急预案演练配置表"},
-                {"t_gzxybmxzxqkjcjlpzb", "t_gzxybmxzxqkjcjlpzzb", "Y", "公正性与保密性检查项配置表"},
-                {"t_jyrykhpzb", "t_jyrykhpzzb", "N", "人员考核内容配置"},
-                {"t_ryjdpzb", "t_ryjdpzzb", "N", "人员监督配置表"},
-                {"t_mraqjcjlpzb", "t_mraqjcjlpzzb", "N", "每日安全检查记录配置表"},
-                {"t_myaqjcjlpzb", "t_myaqjcjlpzzb", "Y", "每月安全检查记录配置表"},
-                {"t_fhxdgzjlb", "t_fhxdgzxmpz,t_fhxdgzxmpzyw", "N", "防护消毒工作项目配置"},
-                {"t_sbysqkpzb", "t_sbysqkpzzx", "Y", "设备验收情况配置表"},
-                {"t_xzbgshzb", "t_xzbgsh", "Y", "校准报告审核配置项"},
-                {"t_fwxypspzb", "t_fwxypspzzb", "Y", "服务协议评审配置"},
-                {"t_mjgyskhnrpzb", "t_mjgyskhnrpzzb", "Y", "供应商评价、考核内容配置"},
-                {"t_hcxnyzjlb", "t_hcxnyzjlhcyqpzbzb", "Y", "耗材性能验证记录耗材要求配置表"},
-                {"t_snzkskbgpzb", "t_snzkskbgpzzb,t_snzkskbgpzzbskyy", "Y", "室内质控失控报告配置表"},
-                {"t_sjzphdjhylpzzb", "t_nlyztgz,t_sjzpzzfhsjbdf,t_ly", "Y", "室间质评活动计划一览配置表"},
-                {"t_yplxb", "t_yplxpzzb", "Y", "样品类型及保存期配置表"},
-                {"t_txyxpzb", "t_txyxpzzb", "Y", "体系运行记录配置内容"}};
+                {"t_yjyaylpzb", "t_yjyaylpzzb", "Y", "应急预案演练配置表", "PARENT_ID_" ,""},
+                {"t_gzxybmxzxqkjcjlpzb", "t_gzxybmxzxqkjcjlpzzb", "Y", "公正性与保密性检查项配置表" ,"PARENT_ID_" ,""},
+                {"t_jyrykhpzb", "t_jyrykhpzzb", "N", "人员考核内容配置" ,"PARENT_ID_" ,""},
+                {"t_ryjdpzb", "t_ryjdpzzb", "N", "人员监督配置表","PARENT_ID_" ,""},
+                {"t_mraqjcjlpzb", "t_mraqjcjlpzzb", "N", "每日安全检查记录配置表","PARENT_ID_" ,""},
+                {"t_myaqjcjlpzb", "t_myaqjcjlpzzb", "Y", "每月安全检查记录配置表","PARENT_ID_" ,""},
+                {"t_fhxdgzjlb", "t_fhxdgzxmpz,t_fhxdgzxmpzyw", "N", "防护消毒工作项目配置","PARENT_ID_" ,""},
+                {"t_sbysqkpzb", "t_sbysqkpzzx", "Y", "设备验收情况配置表","PARENT_ID_" ,""},
+                {"t_xzbgshzb", "t_xzbgsh", "Y", "校准报告审核配置项","PARENT_ID_" ,""},
+                {"t_fwxypspzzb", "t_fwxypspzb", "Y", "服务协议评审配置","WAI_JIAN_" ,"FEN_YUAN_"},
+                {"t_mjgyskhnrpzb", "t_mjgyskhnrpzzb", "Y", "供应商评价、考核内容配置","PARENT_ID_" ,""},
+                {"t_hcxnyzjlb", "t_hcxnyzjlhcyqpzbzb", "Y", "耗材性能验证记录耗材要求配置表","PARENT_ID_" ,""},
+                {"t_snzkskbgpzb", "t_snzkskbgpzzb,t_snzkskbgpzzbskyy", "Y", "室内质控失控报告配置表","PARENT_ID_" ,""},
+                {"t_sjzphdjhylpzzb", "t_nlyztgz,t_sjzpzzfhsjbdf,t_ly", "Y", "室间质评活动计划一览配置表","PARENT_ID_" ,""},
+                {"t_yplxpzzb", "t_yplxb", "Y", "样品类型及保存期配置表","PARENT_ID_" ,""},
+                {"t_txyxpzb", "t_txyxpzzb", "Y", "体系运行记录配置内容","PARENT_ID_", ""}
+        };
 
         //get admin position id.
         String sql1 = "SELECT positions_ FROM ibps_party_employee WHERE id_=1";
@@ -77,6 +78,9 @@ public class BasicDataInitializationJob extends BaseJob2 {
                 if (pVal.containsKey("DI_DIAN_")) {
                     pVal.put("DI_DIAN_", didian);
                 }
+                else if (pVal.containsKey(table[5])){
+                    pVal.put(table[5], didian);
+                }
                 if (pVal.containsKey("BIAN_ZHI_BU_MEN_")) {
                     pVal.put("BIAN_ZHI_BU_MEN_", deptId);
                 }
@@ -86,26 +90,27 @@ public class BasicDataInitializationJob extends BaseJob2 {
                 String[] sublist = table[1].split(",");
                 if (sublist.length>1){
                     for (String sub : sublist){
-                        executeSub(table[0],sub,posAdmin,pId,newPID,deptId,didian);
+                        executeSub(table[0],sub,posAdmin,pId,newPID,deptId,didian,table[4]);
                     }
                 }else {
-                    executeSub(table[0],table[1],posAdmin,pId,newPID,deptId,didian);
+                    executeSub(table[0],table[1],posAdmin,pId,newPID,deptId,didian,table[4]);
                 }
 
                 logger.error(String.format("Done: %s: table:%s dept:%s",table[3],table[0],deptName));
+
             }
         }
     }
 
-    private void executeSub(String parentTbl,String subTbl,String posAdmin,String pId,String newPID,String deptId,String didian) throws Exception {
-        String sql4 = String.format("SELECT c.* FROM %s p , %s c WHERE c.parent_id_ = p.id_ AND p.bian_zhi_ren_=1 " +
-                "AND p.bian_zhi_bu_men_='%s' AND c.parent_id_='%s'", parentTbl, subTbl, posAdmin, pId);
+    private void executeSub(String parentTbl,String subTbl,String posAdmin,String pId,String newPID,String deptId,String didian ,String foreignKey) throws Exception {
+        String sql4 = String.format("SELECT c.* FROM %s p , %s c WHERE c.%s = p.id_ AND p.bian_zhi_ren_=1 " +
+                "AND p.bian_zhi_bu_men_='%s' AND c.%s='%s'", parentTbl, subTbl, foreignKey, posAdmin, foreignKey , pId);
         List<Map<String, Object>> cList = (List<Map<String, Object>>) commonDao.query(sql4);
         if (Collections.isNotEmpty(cList)) {
             for (Map<String, Object> cVal1 : cList) {
                 Map<String, Object> cVal = this.transformUpperCase(cVal1);
                 cVal.put("ID_", UniqueIdUtil.getId());
-                cVal.put("PARENT_ID_", newPID);
+                cVal.put(foreignKey, newPID);
                 if (cVal.containsKey("DI_DIAN_")) {
                     cVal.put("DI_DIAN_", didian);
                 }