add delete expired cdr

lib/mapper/src/main/java/com/pudonghot/yo/mapper/CallDetailRecordMapper.java

@@ -30,4 +30,11 @@ public interface CallDetailRecordMapper extends BaseMapper<Integer, CallDetailRe
         @Param("tenantId") Integer tenantId,
         @Param("calledNumber") String calledNumber);
 
+
+    /**
+     * 删除过期记录
+     *
+     * @return delete row
+     */
+    int deleteExpired();
 }

lib/mapper/src/main/java/com/pudonghot/yo/mapper/CallDetailRecordMapper.xml

@@ -34,4 +34,12 @@
         ) t
     </select>
 
+    <delete id="deleteExpired">
+        delete from
+        <include refid="table" />
+        where
+        <![CDATA[
+            start_stamp < date(now() - interval 31 day)
+        ]]>
+    </delete>
 </mapper>

lib/mapper/src/test/java/com/pudonghot/yo/mapper/CallDetailRecordMapperTest.java

@@ -91,4 +91,9 @@ public class CallDetailRecordMapperTest {
         }
         // mapper.list(new Search().desc(CallDetailRecord.ID).limit(20));
     }
+
+    @Test
+    public void testDeleteExpired() {
+        mapper.deleteExpired();
+    }
 }

server/src/main/java/com/pudonghot/yo/campaign/service/impl/CallingListServiceImpl.java

@@ -14,6 +14,7 @@ import com.pudonghot.yo.mapper.PhoneAliasMapper;
 import com.pudonghot.yo.mapper.CallingListMapper;
 import com.pudonghot.yo.model.domain.CallingList;
 import com.pudonghot.yo.service.LeaderElectionService;
+import com.pudonghot.yo.mapper.CallDetailRecordMapper;
 import org.springframework.beans.factory.annotation.Value;
 import com.pudonghot.yo.mapper.CallingListHistoricalMapper;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -39,6 +40,8 @@ public class CallingListServiceImpl
     private LeaderElectionService leaderElectionService;
     @Autowired
     private PhoneAliasMapper phoneAliasMapper;
+    @Autowired
+    private CallDetailRecordMapper callDetailRecordMapper;
 
     @Value("${yo.campaign.calling-list-lock-expire.seconds:300}")
     private int expireLockDuration;
@@ -70,11 +73,22 @@ public class CallingListServiceImpl
         phoneAliasMapper.deleteOutdated();
     }
 
+    @Scheduled(cron = "${yo.call-detail-record.delete-expired-cron:1 1 0 * * *}")
+    public void deleteExpiredCDR() {
+        if (!leaderElectionService.isLeader()) {
+            log.info("Server is not leader, ignore delete expired CDR scheduler task.");
+            return;
+        }
+
+        log.info("Delete expired CDR.");
+        callDetailRecordMapper.deleteExpired();
+    }
+
     @Scheduled(cron = "${yo.campaign.calling-list.batch-cron:1 1 1 * * *}")
-    public void deleteCalled() {
+    public void callingListBatch() {
 
         if (!leaderElectionService.isLeader()) {
-            log.debug("Server is not leader, ignore campaign delete calling list scheduler task.");
+            log.debug("Server is not leader, ignore campaign calling list scheduler task.");
             return;
         }