新增数据同步方式及配置，当选择为sql时则为数据库直连同步，全局替换所有的同步方法，用户修改，离职，注销修改调整，文件上传去除同步推送上传

zhongrj

2022-08-22 3c607f075990d6d3238daa7db1c68eaae8126424

 src/main/java/org/springblade/modules/resource/controller/AttachController.java

@@ -34,6 +34,7 @@
import org.springblade.modules.resource.entity.Attach;
import org.springblade.modules.resource.service.IAttachService;
import org.springblade.modules.resource.vo.AttachVO;
import org.springblade.modules.system.service.MyAsyncService;
import org.springframework.web.bind.annotation.*;

import javax.validation.Valid;
@@ -52,7 +53,7 @@
public class AttachController extends BladeController {

   private final IAttachService attachService;

   private final MyAsyncService myAsyncService;
   /**
    * 详情
    */
@@ -84,8 +85,8 @@
   @GetMapping("/page")
   @ApiOperationSupport(order = 3)
   @ApiOperation(value = "分页", notes = "传入attach")
   public R<IPage<AttachVO>> page(AttachVO attach, Query query) {
      IPage<AttachVO> pages = attachService.selectAttachPage(Condition.getPage(query), attach);
   public R<IPage<AttachVO>> page(AttachVO attach, Query query,String deptid, String type,String cardid) {
      IPage<AttachVO> pages = attachService.selectAttachPage(Condition.getPage(query), attach,type,cardid);
      return R.data(pages);
   }

@@ -132,7 +133,8 @@
      list.forEach(id ->{
         //内网同步
         String s1 = "delete from blade_attach where id = " + "'" + id + "'";
         FtpUtil.sqlFileUpload(s1);
         //FtpUtil.sqlFileUpload(s1);
         myAsyncService.dataSync(s1);
      });
      return R.status(attachService.deleteLogic(Func.toLongList(ids)));
   }