定时任务BUG修复
正在显示
4 个修改的文件
包含
19 行增加
和
7 行删除
... | @@ -98,12 +98,12 @@ public class DayDataSyncJob implements Job { | ... | @@ -98,12 +98,12 @@ public class DayDataSyncJob implements Job { |
98 | data.put("departId", departId); | 98 | data.put("departId", departId); |
99 | data.put("reportId", ReportConstant.view2119); | 99 | data.put("reportId", ReportConstant.view2119); |
100 | data.put("time",yesterday); | 100 | data.put("time",yesterday); |
101 | //reportDataService.insertOrUpdateReportData(departId, yesterday, data, ReportConstant.view2119); | 101 | reportDataService.insertOrUpdateReportData(departId, yesterday, data, ReportConstant.view2119); |
102 | log.info("========="+departId+"数据同步完成"+data); | 102 | // log.info("========="+departId+"数据同步完成"+data); |
103 | } | 103 | } |
104 | } | 104 | } |
105 | } | 105 | } |
106 | log.info("同步昨天的数据入报表完成"); | 106 | log.info("同步"+yesterday+"的数据入报表完成"); |
107 | }else { | 107 | }else { |
108 | log.info("没有需要同步数据的水厂"); | 108 | log.info("没有需要同步数据的水厂"); |
109 | } | 109 | } |
... | @@ -124,7 +124,11 @@ public class DayDataSyncJob implements Job { | ... | @@ -124,7 +124,11 @@ public class DayDataSyncJob implements Job { |
124 | Map<String, String> tagMap, Map<String, Object> dataMap) { | 124 | Map<String, String> tagMap, Map<String, Object> dataMap) { |
125 | if(tagMap.get(tagCode+"-"+departId)!=null){ | 125 | if(tagMap.get(tagCode+"-"+departId)!=null){ |
126 | if(dataMap.get(tagMap.get(tagCode+"-"+departId)) != null){ | 126 | if(dataMap.get(tagMap.get(tagCode+"-"+departId)) != null){ |
127 | data.put(itemCode, df.format(24*Double.parseDouble(dataMap.get(tagMap.get(tagCode+"-"+departId)).toString()))); | 127 | if("CSLL".equals(tagCode)||"JSLL".equals(tagCode)){ |
128 | data.put(itemCode, df.format(24*Double.parseDouble(dataMap.get(tagMap.get(tagCode+"-"+departId)).toString()))); | ||
129 | }else{ | ||
130 | data.put(itemCode, dataMap.get(tagMap.get(tagCode+"-"+departId)).toString()); | ||
131 | } | ||
128 | }else{ | 132 | }else{ |
129 | data.put(itemCode, ""); | 133 | data.put(itemCode, ""); |
130 | } | 134 | } | ... | ... |
... | @@ -66,11 +66,11 @@ public class NFDataSyncJob implements Job { | ... | @@ -66,11 +66,11 @@ public class NFDataSyncJob implements Job { |
66 | data.put("reportId", ReportConstant.view2119); | 66 | data.put("reportId", ReportConstant.view2119); |
67 | reportDataService.insertOrUpdateReportData(departId, time, data, ReportConstant.view2119); | 67 | reportDataService.insertOrUpdateReportData(departId, time, data, ReportConstant.view2119); |
68 | }else if("hyrb".equals(itemType)){ | 68 | }else if("hyrb".equals(itemType)){ |
69 | if(wsFields.indexOf(itemCode) > 0){ | 69 | if(wsFields.contains(itemCode)){ |
70 | data.put(itemCode+"HY", itemValue); | 70 | data.put(itemCode+"HY", itemValue); |
71 | data.put("reportId", ReportConstant.view9bff); | 71 | data.put("reportId", ReportConstant.view9bff); |
72 | reportDataService.insertOrUpdateReportData(departId, time, data, ReportConstant.view9bff); | 72 | reportDataService.insertOrUpdateReportData(departId, time, data, ReportConstant.view9bff); |
73 | }else if(gsFields.indexOf(itemCode) > 0){ | 73 | }else if(gsFields.contains(itemCode)){ |
74 | data.put(itemCode, itemValue); | 74 | data.put(itemCode, itemValue); |
75 | data.put("reportId", ReportConstant.view6643); | 75 | data.put("reportId", ReportConstant.view6643); |
76 | reportDataService.insertOrUpdateReportData(departId, time, data, ReportConstant.view6643); | 76 | reportDataService.insertOrUpdateReportData(departId, time, data, ReportConstant.view6643); | ... | ... |
... | @@ -203,11 +203,13 @@ public class SysRoleController { | ... | @@ -203,11 +203,13 @@ public class SysRoleController { |
203 | queryWrapper.notLike("role_code","admin"); | 203 | queryWrapper.notLike("role_code","admin"); |
204 | } | 204 | } |
205 | if(StringUtils.isNotEmpty(BaseContextHandler.getDeparts())){ | 205 | if(StringUtils.isNotEmpty(BaseContextHandler.getDeparts())){ |
206 | SysDepart sysDepart = sysDepartService.getById(BaseContextHandler.getDeparts()); | 206 | SysDepart sysDepart = sysDepartService.getById(BaseContextHandler.getRealDepartId()); |
207 | if(sysDepart!=null){ | 207 | if(sysDepart!=null){ |
208 | if(!"A01".equals(sysDepart.getOrgCode())){ | 208 | if(!"A01".equals(sysDepart.getOrgCode())){ |
209 | queryWrapper.notLike("role_type","group"); | 209 | queryWrapper.notLike("role_type","group"); |
210 | } | 210 | } |
211 | }else{ | ||
212 | queryWrapper.notLike("role_type","group"); | ||
211 | } | 213 | } |
212 | } | 214 | } |
213 | queryWrapper.orderByDesc("create_time"); | 215 | queryWrapper.orderByDesc("create_time"); | ... | ... |
... | @@ -72,6 +72,12 @@ public class SysFactoryInfoVO { | ... | @@ -72,6 +72,12 @@ public class SysFactoryInfoVO { |
72 | */ | 72 | */ |
73 | @ApiModelProperty(value = "水厂类型") | 73 | @ApiModelProperty(value = "水厂类型") |
74 | private String factoryType; | 74 | private String factoryType; |
75 | |||
76 | /** | ||
77 | * 星标厂区 | ||
78 | */ | ||
79 | @ApiModelProperty(value = "星标厂区") | ||
80 | private String factoryStar; | ||
75 | /** | 81 | /** |
76 | * 邮编 | 82 | * 邮编 |
77 | */ | 83 | */ | ... | ... |
-
请 注册 或 登录 后发表评论