加了一个同步黑名单的接口

hjzx-api/src/main/java/api/controller/patient/BlackListController.java

@@ -7,6 +7,7 @@ import api.entity.input.patient.AddBlackListInput;
 import api.service.call.IBlacklistService;
 import api.service.patient.IPatientLogService;
 import api.service.patient.IPatientService;
+import api.util.annotation.Anonymous;
 import api.util.enums.PhoneStatus;
 import api.util.helper.DateHelper;
 import api.util.helper.SecretHelper;
@@ -269,4 +270,72 @@ public class BlackListController extends BaseController {
         }
     }
 
+    @GetMapping("/syncdata")
+    @Anonymous
+    public AjaxResult syncdata(){
+        //同步p_blacklist的数据给call_blacklist
+        LambdaQueryWrapper<BlackList> qw = new LambdaQueryWrapper();
+        qw.eq(  BlackList::getIsDelete, 0);
+       List<BlackList> lists=  blacklistService.getList(qw);
+
+       for (BlackList item :lists){
+
+           //同步到通话记录的黑名单表
+           LambdaQueryWrapper<Blacklist> ex=new LambdaQueryWrapper<>();
+           String callnum=SecretHelper.AesDecrypt(item.getPhoneNumber());
+
+           if(StringHelper.isEmpty(callnum)){
+               continue;
+           }
+
+           ex.eq(Blacklist::getCallNumber, callnum);
+           if(!callblacklistService.exists(ex)){
+               Blacklist blacklist=new Blacklist();
+               blacklist.setCreateBy(item.getCreateUser());
+               blacklist.setCreateTime(new Date());
+               blacklist.setDelFlag("0");
+               if(item.getStarttime()==null && item.getEndtime()==null){
+                   blacklist.setBlackType(2L);
+               }
+               else {
+                   blacklist.setBlackType(1L);
+                   blacklist.setStartTime(item.getStarttime());
+                   blacklist.setEndTime(item.getEndtime());
+               }
+
+               blacklist.setCallNumber(callnum);
+
+               blacklist.setRemark(item.getReason());
+               callblacklistService.insert(blacklist);
+
+           }
+           else{
+
+               LambdaUpdateWrapper<Blacklist> updateWrapper=new LambdaUpdateWrapper<>();
+               updateWrapper.eq(Blacklist::getCallNumber,callnum);
+               updateWrapper.set(Blacklist::getStartTime,item.getStarttime());
+               updateWrapper.set(Blacklist::getEndTime,item.getEndtime());
+               updateWrapper.set(Blacklist::getRemark,item.getReason());
+               updateWrapper.set(Blacklist::getUpdateBy,item.getCreateUser());
+               updateWrapper.set(Blacklist::getUpdateTime,new Date());
+               updateWrapper.set(Blacklist::getDelFlag,0);
+
+
+               if(item.getStarttime()==null && item.getEndtime()==null){
+                   updateWrapper.set(Blacklist::getBlackType,2L);
+               }
+               else {
+                   updateWrapper.set(Blacklist::getBlackType,1L);
+               }
+               callblacklistService.updateBatch(updateWrapper);
+
+           }
+
+
+       }
+
+
+        return Success("成功");
+
+    }
 }