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

zhongrj

2022-08-22 3c607f075990d6d3238daa7db1c68eaae8126424

 src/main/java/org/springblade/modules/accreditation/controller/AccreditationRecordsController.java

@@ -29,6 +29,7 @@
import org.springblade.modules.accreditation.entity.AccreditationRecords;
import org.springblade.modules.accreditation.service.AccreditationRecordsService;
import org.springblade.modules.accreditation.vo.AccreditationRecordsVo;
import org.springblade.modules.system.service.MyAsyncService;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource;
import org.springframework.web.bind.annotation.*;
@@ -56,7 +57,7 @@
   private final AccreditationRecordsService accreditationRecordsService;

   private final IUserService userService;

   private final MyAsyncService myAsyncService;

   /**
    * 自定义分页
@@ -70,13 +71,40 @@
   }

   /**
    * 新增
    * 新增（补证）
    * @param accreditationRecords 制证记录信息对象
    */
   @PostMapping("/save")
   @ApiOperation(value = "新增", notes = "传入accreditationRecords")
   public R save(@RequestBody AccreditationRecords accreditationRecords){
      return R.data(accreditationRecordsService.save(accreditationRecords));
      accreditationRecords.setCreateTime(new Date());
      accreditationRecords.setStatus(1);
      accreditationRecords.setAuditStatus(1);
      boolean save = accreditationRecordsService.save(accreditationRecords);

      //修改用户信息
      User user = new User();
      user.setId(accreditationRecords.getUserId());
      user.setUpdateTime(new Date());
      //修改为未制证状态
      user.setUserType(7);
      userService.updateById(user);
      //内网同步
      //内网新增
      String s = "insert into sys_accreditation_records(id,user_id,create_time,create_user,status,type,audit_status) " +
         "values(" + "'" + accreditationRecords.getId() + "'" + ","
         + "'" + accreditationRecords.getUserId() + "'" + ","
         + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(accreditationRecords.getCreateTime()) + "'" + ","
         + "'" + accreditationRecords.getCreateUser() +"'" + ","
         + "'" + accreditationRecords.getStatus() +"'" + ","
         + "'" + accreditationRecords.getType() +"'" + ","
         +"'" + accreditationRecords.getAuditStatus() + "'" + ");" +
      "update blade_user set user_type = " + "'" + user.getUserType() + "'" +
         ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "'" +
         " " + "where id = " + "'" + user.getId() + "'";
      //FtpUtil.sqlFileUpload(s);
      myAsyncService.dataSync(s);
      return R.data(save);
   }


@@ -86,9 +114,17 @@
    * @param accreditationRecords 制证记录信息对象
    */
   @PostMapping("/securityApply")
   @ApiOperation(value = "新增", notes = "传入accreditationRecords")
   public R securityApply(@RequestBody AccreditationRecordsVo accreditationRecords){
      return R.data(accreditationRecordsService.securityApply(accreditationRecords));
   }

   /**
    * 批量修改为已制证
    * @param accreditationRecords 制证记录信息对象
    */
   @PostMapping("/batchAccreditation")
   public R batchAccreditation(@RequestBody AccreditationRecordsVo accreditationRecords){
      return R.data(accreditationRecordsService.batchAccreditation(accreditationRecords));
   }


@@ -106,22 +142,35 @@
         //修改为未制证状态
         AccreditationRecords records = accreditationRecordsService.getById(accreditationRecords);
         User user = userService.getById(records.getUserId());
         user.setUserType(7);
         user.setUpdateTime(new Date());
         //更新
         userService.updateById(user);
         if(accreditationRecords.getType()==2) {
            user.setUserType(7);
            user.setUpdateTime(new Date());
            //更新
            userService.updateById(user);

         //内网同步
         String s =
            "update sys_accreditation_records set audit_status = " + accreditationRecords.getAuditStatus() + "" +
               ",audit_detail = " + accreditationRecords.getAuditDetail() + "" +
               ",audit_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(accreditationRecords.getAuditTime()) + "" +
               ",audit_user = " + accreditationRecords.getAuditUser() + " " +
               "where id = " + "'" + accreditationRecords.getId() + "';" +
            "update blade_user set user_type = " + user.getUserType() + "" +
               ",update_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "" +
               "where id = " + "'" + user.getId() + "'";
         FtpUtil.sqlFileUpload(s);
            //内网同步
            String s =
               "update sys_accreditation_records set audit_status = " + accreditationRecords.getAuditStatus() + "" +
                  ",audit_detail = " + accreditationRecords.getAuditDetail() + "" +
                  ",audit_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(accreditationRecords.getAuditTime()) + "" +
                  ",audit_user = " + accreditationRecords.getAuditUser() + " " +
                  "where id = " + "'" + accreditationRecords.getId() + "';" +
                  "update blade_user set user_type = " + user.getUserType() + "" +
                  ",update_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "" +
                  "where id = " + "'" + user.getId() + "'";
            //FtpUtil.sqlFileUpload(s);
            myAsyncService.dataSync(s);
         }else {
            //内网同步
            String s =
               "update sys_accreditation_records set audit_status = " + accreditationRecords.getAuditStatus() + "" +
                  ",audit_detail = " + accreditationRecords.getAuditDetail() + "" +
                  ",audit_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(accreditationRecords.getAuditTime()) + "" +
                  ",audit_user = " + accreditationRecords.getAuditUser() + " " +
                  "where id = " + "'" + accreditationRecords.getId() + "'";
            //FtpUtil.sqlFileUpload(s);
            myAsyncService.dataSync(s);
         }
      }else {
         //内网同步
         String s =
@@ -130,7 +179,8 @@
               ",audit_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(accreditationRecords.getAuditTime()) + "" +
               ",audit_user = " + accreditationRecords.getAuditUser() + " " +
               "where id = " + "'" + accreditationRecords.getId() + "'";
         FtpUtil.sqlFileUpload(s);
         //FtpUtil.sqlFileUpload(s);
         myAsyncService.dataSync(s);
      }
      //返回
      return R.status(b);
@@ -153,25 +203,38 @@
         accreditationRecordsService.updateById(accreditationRecords);
         //审核通过
         if (accreditationRecords.getAuditStatus()==2){
            //修改为未制证状态
            AccreditationRecords records = accreditationRecordsService.getById(id);
            User user = userService.getById(records.getUserId());
            user.setUserType(7);
            user.setUpdateTime(new Date());
            //更新
            userService.updateById(user);
            if (accreditationRecords.getType()==2) {
               //修改为未制证状态
               AccreditationRecords records = accreditationRecordsService.getById(id);
               User user = userService.getById(records.getUserId());
               user.setUserType(7);
               user.setUpdateTime(new Date());
               //更新
               userService.updateById(user);

            //内网同步
            String s =
               "update sys_accreditation_records set audit_status = " + accreditationRecords.getAuditStatus() + "" +
                  ",audit_detail = " + accreditationRecords.getAuditDetail() + "" +
                  ",audit_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(accreditationRecords.getAuditTime()) + "" +
                  ",audit_user = " + accreditationRecords.getAuditUser() + " " +
                  "where id = " + "'" + accreditationRecords.getId() + "';" +
               "update blade_user set user_type = " + user.getUserType() + "" +
                  ",update_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "" +
                  "where id = " + "'" + user.getId() + "'";
            FtpUtil.sqlFileUpload(s);
               //内网同步
               String s =
                  "update sys_accreditation_records set audit_status = " + accreditationRecords.getAuditStatus() + "" +
                     ",audit_detail = " + accreditationRecords.getAuditDetail() + "" +
                     ",audit_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(accreditationRecords.getAuditTime()) + "" +
                     ",audit_user = " + accreditationRecords.getAuditUser() + " " +
                     "where id = " + "'" + accreditationRecords.getId() + "';" +
                     "update blade_user set user_type = " + user.getUserType() + "" +
                     ",update_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "" +
                     "where id = " + "'" + user.getId() + "'";
               //FtpUtil.sqlFileUpload(s);
               myAsyncService.dataSync(s);
            }else {
               //内网同步
               String s =
                  "update sys_accreditation_records set audit_status = " + accreditationRecords.getAuditStatus() + "" +
                     ",audit_detail = " + accreditationRecords.getAuditDetail() + "" +
                     ",audit_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(accreditationRecords.getAuditTime()) + "" +
                     ",audit_user = " + accreditationRecords.getAuditUser() + " " +
                     "where id = " + "'" + accreditationRecords.getId() + "'";
               //FtpUtil.sqlFileUpload(s);
               myAsyncService.dataSync(s);
            }
         }else {
            //内网同步
            String s =
@@ -180,7 +243,8 @@
                  ",audit_time = " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(accreditationRecords.getAuditTime()) + "" +
                  ",audit_user = " + accreditationRecords.getAuditUser() + " " +
                  "where id = " + "'" + accreditationRecords.getId() + "'";
            FtpUtil.sqlFileUpload(s);
            //FtpUtil.sqlFileUpload(s);
            myAsyncService.dataSync(s);
         }
      });
      //返回
@@ -239,7 +303,7 @@
   }

   /**
    * 导出保安员证信息
    * 导出保安员证信息（上岗证）
    */
   @GetMapping("export-security-paper")
   public void exportSecurityPaper(AccreditationRecordsVo accreditationRecords, HttpServletResponse response) throws IOException {