summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorwangwei <[email protected]>2019-04-25 10:26:44 +0800
committerwangwei <[email protected]>2019-04-25 10:26:44 +0800
commit6223c6661868db0c39b823725deb76d124fc6585 (patch)
tree61e7f3ac64a492c41aa2a929ddac713e77da04cb
parent0499fb845dff5c33723c31331ce887e2bdbae23a (diff)
修复 IP Spoofing定时任务配置相关表数据状态不同步
-rw-r--r--src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.java2
-rw-r--r--src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.xml14
-rw-r--r--src/main/java/com/nis/web/service/ScheduleService.java12
3 files changed, 25 insertions, 3 deletions
diff --git a/src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.java b/src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.java
index 75ffe3093..d6bec9bc9 100644
--- a/src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.java
+++ b/src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.java
@@ -18,6 +18,6 @@ public interface PxyObjSpoofingIpPoolDao extends CrudDao<PxyObjSpoofingIpPool>{
PxyObjSpoofingIpPool getPxyObjSpoofingIpPool(Long cfgId);
int insert(PxyObjSpoofingIpPool spoofingPool);
int update(PxyObjSpoofingIpPool spoofingPool);
-
+ int updateState(@Param("tableName")String tableName,@Param("compileId")int compileId,@Param("isValid")Integer isValid,@Param("editorId")Long editorId);
List<PxyObjSpoofingIpPool> findByPage(@Param("ids")String ids);
} \ No newline at end of file
diff --git a/src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.xml b/src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.xml
index da1d89aba..7507fd095 100644
--- a/src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.xml
+++ b/src/main/java/com/nis/web/dao/configuration/PxyObjSpoofingIpPoolDao.xml
@@ -307,6 +307,16 @@
left join request_info ri on r.request_id=ri.id
where r.CFG_ID in (${ids})
</select>
-
-
+
+ <update id="updateState">
+ update ${tableName}
+ <set>
+ is_valid = #{isValid} ,
+ is_audit = 1,
+ editor_id = #{editorId},
+ edit_time=now(),
+ </set>
+ where compile_id = #{compileId}
+ </update>
+
</mapper> \ No newline at end of file
diff --git a/src/main/java/com/nis/web/service/ScheduleService.java b/src/main/java/com/nis/web/service/ScheduleService.java
index 3ca0c9443..12d4c1a71 100644
--- a/src/main/java/com/nis/web/service/ScheduleService.java
+++ b/src/main/java/com/nis/web/service/ScheduleService.java
@@ -11,10 +11,13 @@ import org.springframework.transaction.annotation.Transactional;
import com.nis.domain.ScheduleCfg;
import com.nis.domain.ScheduleExceInfo;
import com.nis.domain.configuration.BaseCfg;
+import com.nis.domain.configuration.PxyObjSpoofingIpPool;
import com.nis.util.SchedulerTaskUtil;
import com.nis.util.ServiceConfigTemplateUtil;
import com.nis.web.dao.SchedulerDao;
import com.nis.web.dao.configuration.ConfigSynchronizationDao;
+import com.nis.web.dao.configuration.PxyObjSpoofingIpPoolDao;
+import com.nis.web.security.UserUtils;
@Service
public class ScheduleService extends BaseService{
@@ -22,6 +25,8 @@ public class ScheduleService extends BaseService{
private SchedulerDao dao ;
@Autowired
private ConfigSynchronizationDao configSynchronizationDao;
+ @Autowired
+ private PxyObjSpoofingIpPoolDao pxyObjSpoofingIpPoolDao;
@SuppressWarnings("rawtypes")
@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
@@ -53,6 +58,13 @@ public class ScheduleService extends BaseService{
if(isValid == 0) {
isIssueContent=0;
}
+ if(cfg.getServiceId().equals(518)){
+ try{
+ pxyObjSpoofingIpPoolDao.updateState("pxy_obj_spoofing_ip_pool",compileId-1,isValid,UserUtils.getUser().getId());
+ }catch(Exception e){
+ logger.info("更新 pxy_obj_spoofing_ip_pool 异常",e);
+ }
+ }
ServiceConfigTemplateUtil serviceTemplate = new ServiceConfigTemplateUtil();
List<Map<String,Object>> serviceList = serviceTemplate.getServiceListByServiceId(cfg.getServiceId());
//根据编译ID查询配置表中的配置信息