黑名单同步接口

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.SecretHelper;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -263,4 +264,71 @@ 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("成功");
+
+    }
 }