孙永军 преди 1 година
родител
ревизия
745963204a

+ 5 - 0
src/main/java/com/smcic/api/epg/controller/EpgController.java

@@ -71,4 +71,9 @@ public class EpgController {
         return keywordDisableConfigService.keywordConfigList(channelId, pageNum, pageSize);
     }
 
+    @PostMapping("update")
+    public void update(@RequestBody DisableDTO disableDTO){
+        epgDisableConfigService.update(disableDTO);
+    }
+
 }

+ 5 - 0
src/main/java/com/smcic/api/epg/controller/KeywordController.java

@@ -28,4 +28,9 @@ public class KeywordController {
         keywordDisableConfigService.disable(keywordDisableConfig);
     }
 
+    @PostMapping("update")
+    public void update(@RequestBody KeywordDisableConfig keywordDisableConfig){
+        keywordDisableConfigService.update(keywordDisableConfig);
+    }
+
 }

+ 5 - 0
src/main/java/com/smcic/api/epg/dto/DisableDTO.java

@@ -7,8 +7,13 @@ import java.time.LocalDateTime;
 
 @Data
 public class DisableDTO {
+
+    private Integer id;
+
     private Integer channelId;
 
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     private LocalDateTime startTime;
+
+    private Integer status = 1;
 }

+ 13 - 0
src/main/java/com/smcic/api/epg/service/impl/EpgDisableConfigService.java

@@ -52,4 +52,17 @@ public class EpgDisableConfigService extends ServiceImpl<EpgDisableConfigMapper,
         save(epgDisableConfig);
         programService.setCache(disableDTO.getChannelId());
     }
+
+    public void update(DisableDTO disableDTO){
+        EpgDisableConfig edc = getById(disableDTO.getId());
+
+        if(null == edc){
+            throw new APIException("不存在的数据记录");
+        }
+
+        edc.setStatus(1);
+
+        updateById(edc);
+
+    }
 }

+ 14 - 0
src/main/java/com/smcic/api/epg/service/impl/KeywordDisableConfigService.java

@@ -62,4 +62,18 @@ public class KeywordDisableConfigService extends ServiceImpl<KeywordDisableConfi
                 .ge(KeywordDisableConfig::getEndTime, startTime).le(KeywordDisableConfig::getStartTime, endTime)
                 .list().stream().map(KeywordDisableConfig::getProgram).distinct().collect(Collectors.toList());
     }
+
+    public void update(KeywordDisableConfig keywordDisableConfig){
+        KeywordDisableConfig kdc = getById(keywordDisableConfig.getId());
+
+        if (null == kdc) {
+            throw new APIException("不存在的配置");
+        }
+
+        kdc.setProgram(keywordDisableConfig.getProgram());
+        kdc.setStartTime(keywordDisableConfig.getStartTime());
+        kdc.setEndTime(keywordDisableConfig.getEndTime());
+        kdc.setStatus(keywordDisableConfig.getStatus());
+        updateById(keywordDisableConfig);
+    }
 }

+ 1 - 2
src/main/java/com/smcic/api/epg/service/impl/ProgramService.java

@@ -66,8 +66,7 @@ public class ProgramService extends ServiceImpl<ProgramMapper, Program> implemen
     }
 
     public List<Map<String, Object>> cacheEpg(Integer channelId) {
-        return getDisableProgramList(channelId);
-//        return (List<Map<String, Object>>)cache.get(channelId, key -> getDisableProgramList(channelId));
+        return (List<Map<String, Object>>)cache.get(channelId, key -> getDisableProgramList(channelId));
     }
 
     public void setCache(Integer channelId){