黑名单同步到callblacklist

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

@@ -1,8 +1,10 @@
 package api.controller.patient;
 
+import api.entity.database.call.Blacklist;
 import api.entity.database.patient.Patient;
 import api.entity.database.patient.PatientLog;
 import api.entity.input.patient.AddBlackListInput;
+import api.service.call.IBlacklistService;
 import api.service.patient.IPatientLogService;
 import api.service.patient.IPatientService;
 import api.util.enums.PhoneStatus;
@@ -39,7 +41,8 @@ public class BlackListController extends BaseController {
 
     @Autowired
     private IPatientService patientService;
-
+    @Autowired
+    private IBlacklistService callblacklistService;
     @ApiOperation("列表")
     @Log(title = "查询p_blacklist列表",businessType = BusinessType.QUERY)
     @GetMapping
@@ -117,6 +120,56 @@ public class BlackListController extends BaseController {
             wrapper.set(Patient::getPhoneStatus, PhoneStatus.BLACK.getValue());
           boolean paresult=  patientService.updateBatch(wrapper);
 
+            //同步到通话记录的黑名单表
+            LambdaQueryWrapper<Blacklist> ex=new LambdaQueryWrapper<>();
+            String callnum=SecretHelper.AesDecrypt(patient.getPhoneNumber());
+            ex.eq(Blacklist::getCallNumber,SecretHelper.AesDecrypt(patient.getPhoneNumber()));
+            if(!callblacklistService.exists(ex)){
+                Blacklist blacklist=new Blacklist();
+                blacklist.setCreateBy(CurrentUser().getUserName());
+                blacklist.setCreateTime(new Date());
+                blacklist.setDelFlag("0");
+                if(input.getStarttime()==null && input.getEndtime()==null){
+                    blacklist.setBlackType(2L);
+                }
+                else {
+                    blacklist.setBlackType(1L);
+                    blacklist.setStartTime(input.getStarttime());
+                    blacklist.setEndTime(input.getEndtime());
+                }
+
+                blacklist.setCallNumber(SecretHelper.AesDecrypt(patient.getPhoneNumber()));
+
+                blacklist.setRemark(input.getReason());
+                callblacklistService.insert(blacklist);
+
+            }
+            else{
+
+                LambdaUpdateWrapper<Blacklist> updateWrapper=new LambdaUpdateWrapper<>();
+                updateWrapper.eq(Blacklist::getCallNumber,callnum);
+                updateWrapper.set(Blacklist::getStartTime,input.getStarttime());
+                updateWrapper.set(Blacklist::getEndTime,input.getEndtime());
+                updateWrapper.set(Blacklist::getRemark,input.getReason());
+                updateWrapper.set(Blacklist::getUpdateBy,CurrentUser().getUserName());
+                updateWrapper.set(Blacklist::getUpdateTime,new Date());
+                updateWrapper.set(Blacklist::getDelFlag,0);
+
+
+                if(input.getStarttime()==null && input.getEndtime()==null){
+                    updateWrapper.set(Blacklist::getBlackType,2L);
+                }
+                else {
+                    updateWrapper.set(Blacklist::getBlackType,1L);
+                }
+                callblacklistService.updateBatch(updateWrapper);
+
+            }
+
+
+
+
+
             return Success("成功");
         } else {
             return Error("新增失败");
@@ -139,6 +192,23 @@ public class BlackListController extends BaseController {
 
         boolean result = blacklistService.updateBatch(qw);
         if (result) {
+            BlackList bl=blacklistService.getEntity(input.getBlackId());
+            String callnum= SecretHelper.AesDecrypt(  bl.getPhoneNumber());
+            LambdaUpdateWrapper<Blacklist> updateWrapper=new LambdaUpdateWrapper<>();
+            updateWrapper.eq(Blacklist::getCallNumber,callnum);
+            updateWrapper.set(Blacklist::getStartTime,input.getStarttime());
+            updateWrapper.set(Blacklist::getEndTime,input.getEndtime());
+            updateWrapper.set(Blacklist::getRemark,input.getReason());
+            updateWrapper.set(Blacklist::getUpdateBy,CurrentUser().getUserName());
+            updateWrapper.set(Blacklist::getUpdateTime,new Date());
+
+            if(input.getStarttime()==null && input.getEndtime()==null){
+                updateWrapper.set(Blacklist::getBlackType,2L);
+            }
+            else {
+                updateWrapper.set(Blacklist::getBlackType,1L);
+            }
+            callblacklistService.updateBatch(updateWrapper);
             return Success("成功");
         } else {
             return Error("修改失败");
@@ -155,6 +225,19 @@ public class BlackListController extends BaseController {
         lp.set(BlackList::getIsDelete, 1);
         boolean result = blacklistService.updateBatch(lp);
         if (result) {
+            for (Long id :ids){
+                BlackList bl=blacklistService.getEntity(id);
+                String callnum= SecretHelper.AesDecrypt(  bl.getPhoneNumber());
+
+                LambdaUpdateWrapper<Blacklist> lplp = new LambdaUpdateWrapper<>();
+                lplp.eq(Blacklist::getCallNumber,callnum);
+                lplp.set(Blacklist::getDelFlag,2L);
+                lplp.set(Blacklist::getDelTime,new Date());
+                lplp.set(Blacklist::getDelBy,CurrentUser().getUserName());
+                callblacklistService.updateBatch(lplp);
+            }
+
+
             //删除标签 存log记录
             LambdaQueryWrapper<BlackList> qw1 = new LambdaQueryWrapper<>();
             qw1.in(BlackList::getBlackId, ids).select(BlackList::getPatientId, BlackList::getPatientName);