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

zhongrj

2022-08-22 3c607f075990d6d3238daa7db1c68eaae8126424

 src/main/java/org/springblade/modules/seinspect/controller/SeinspectController.java

@@ -22,7 +22,7 @@
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.AllArgsConstructor;
import org.springblade.common.constant.FtpConstant;
import org.springblade.common.config.FtpConfig;
import org.springblade.common.utils.arg;
import org.springblade.core.boot.ctrl.BladeController;
import org.springblade.core.mp.support.Condition;
@@ -33,10 +33,12 @@
import org.springblade.modules.seinspect.entity.Seinspect;
import org.springblade.modules.seinspect.service.ISeinspectService;
import org.springblade.modules.seinspect.vo.SeinspectVO;
import org.springblade.modules.system.service.MyAsyncService;
import org.springframework.web.bind.annotation.*;

import javax.validation.Valid;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 *  控制器
@@ -51,6 +53,7 @@
public class SeinspectController extends BladeController {

   private final ISeinspectService seinspectService;
   private final MyAsyncService myAsyncService;

   /**
    * 详情
@@ -92,34 +95,34 @@
   @ApiOperationSupport(order = 4)
   @ApiOperation(value = "新增", notes = "传入seinspect")
   public R save(@Valid @RequestBody Seinspect seinspect) throws Exception {
      seinspectService.save(seinspect);
      String url = "";
      if (seinspect.getUrl()!=null&& !"".equals(seinspect.getUrl())){
         String[] split = seinspect.getUrl().split(",");
         for (int i = 0; i < split.length; i++) {
            String s = split[i].substring(26, split[i].length());
            url += FtpConstant.ip + s + ",";
      seinspect.setReviewtime(new Date());
      boolean save = seinspectService.save(seinspect);
      if (save) {
         String url = "";
         if (seinspect.getUrl() != null && !"".equals(seinspect.getUrl())) {
            String[] split = seinspect.getUrl().split(",");
            for (int i = 0; i < split.length; i++) {
               String s = split[i].substring(26, split[i].length());
               url += FtpConfig.ip + s + ",";
            }
            String substring = url.substring(0, url.length() - 1);
            seinspect.setUrl(substring);
         }
         String substring = url.substring(0, url.length() - 1);
         seinspect.setUrl(substring);
         //数据同步
         String s1 =
            "insert into sys_seinspect(id,reviewTime,content,result,url,examiner_dept_id,examiner_id,jurisdiction,security_id) " +
               "values(" + "'" + seinspect.getId() + "'" + "," +
               "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "'" + "," +
               "'" + seinspect.getContent() + "'" + "," +
               "'" + seinspect.getResult() + "'" + "," +
               "'" + seinspect.getUrl() + "'" + "," +
               "'" + seinspect.getExaminerDeptId() + "'" + "," +
               "'" + seinspect.getExaminerId() + "'" + "," +
               "'" + seinspect.getJurisdiction() + "'" + "," +
               "'" + seinspect.getSecurityId() + "'" + ")";
         //FtpUtil.sqlFileUpload(s1);
         myAsyncService.dataSync(s1);
      }
      //数据同步
      String s1 =
         "insert into sys_seinspect(id,realName,carid,sName,inspectman,deptName,reviewTime,insid,examination_type,url,jid,deptid,jurisdiction) " +
            "values(" + "'" + seinspect.getId() + "'" + "," +
            "'" + seinspect.getRealname() + "'" + "," +
            "'" + seinspect.getCarid() + "'" + "," +
            "'" + seinspect.getSname() + "'" + "," +
            "'" + seinspect.getInspectman() + "'" + "," +
            "'" + seinspect.getDeptname() + "'" + "," +
            "'" + seinspect.getReviewtime() + "'" + "," +
            "'" + seinspect.getInsid() + "'" + "," +
            "'" + seinspect.getExaminationType() + "'" + "," +
            "'" + seinspect.getUrl() + "'" + "," +
            "'" + seinspect.getJid() + "'" + "," +
            "'" + seinspect.getDeptid() + "'" + "," +
            "'" +seinspect.getJurisdiction() + "'" + ")";
      FtpUtil.sqlFileUpload(s1);
      return R.success("成功");
   }