1.数据源调整

tangzy

2021-07-27 d5347009480b97a146b7443df0285e98e9f57678

1.数据源调整

 src/main/java/org/springblade/common/config/BladeConfiguration.java

@@ -70,6 +70,7 @@
        secureRegistry.excludePathPatterns("/gun/**");
        secureRegistry.excludePathPatterns("/equipage/**");
        secureRegistry.excludePathPatterns("/blade-user/**");
        secureRegistry.excludePathPatterns("/trainingRegistration/**");
        return secureRegistry;
    }


 src/main/java/org/springblade/common/utils/arg.java

@@ -10,6 +10,11 @@
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;

public class arg {
    public static String url="http://47.49.21.216:80";
    public static String test01(String path,Object obj) throws Exception{
@@ -25,4 +30,31 @@
        System.out.println(str);
        return str;
    }
    public static String load(String urls,String query) throws Exception
    {
        URL restURL = new URL(urls);
        /*
         * 此处的urlConnection对象实际上是根据URL的请求协议(此处是http)生成的URLConnection类 的子类HttpURLConnection
         */
        HttpURLConnection conn = (HttpURLConnection) restURL.openConnection();
        //请求方式
        conn.setRequestMethod("POST");
        //设置是否从httpUrlConnection读入，默认情况下是true; httpUrlConnection.setDoInput(true);
        conn.setDoOutput(true);
        //allowUserInteraction 如果为 true，则在允许用户交互（例如弹出一个验证对话框）的上下文中对此 URL 进行检查。
        conn.setAllowUserInteraction(false);

        BufferedReader bReader = new BufferedReader(new InputStreamReader(conn.getInputStream()));

        String line,resultStr="";

        while(null != (line=bReader.readLine()))
        {
            resultStr +=line;
        }
        bReader.close();

        return resultStr;

    }
}

 src/main/java/org/springblade/modules/information/controller/InformationController.java

@@ -126,7 +126,8 @@
    @PostMapping("/update")
    @ApiOperationSupport(order = 5)
    @ApiOperation(value = "修改", notes = "传入information")
    public R update(@Valid @RequestBody Information information) {
    public R update(@Valid @RequestBody Information information) throws Exception {
        arg.test01(arg.url+"/information/update",information);
        return R.status(informationService.updateById(information));
    }

@@ -147,10 +148,11 @@
    @PostMapping("/remove")
    @ApiOperationSupport(order = 8)
    @ApiOperation(value = "删除", notes = "传入ids")
    public R remove(String creditcode) {
    public R remove(String creditcode) throws Exception {
        informationService.deleteIn(creditcode);
        informationService.deleteSh(creditcode);
        informationService.deleteMe(creditcode);
        arg.load(arg.url+"/information/remove",creditcode);
        return R.success("删除成功");
    }


 src/main/java/org/springblade/modules/member/controller/MemberController.java

@@ -89,7 +89,6 @@
    @ApiOperationSupport(order = 4)
    @ApiOperation(value = "新增", notes = "传入member")
    public R save(@Valid @RequestBody Member member) throws Exception {
        arg arg = new arg();
        arg.test01(arg.url+"/member/save",member);
        return R.status(memberService.save(member));
    }
@@ -100,7 +99,8 @@
    @PostMapping("/update")
    @ApiOperationSupport(order = 5)
    @ApiOperation(value = "修改", notes = "传入member")
    public R update(@Valid @RequestBody Member member) {
    public R update(@Valid @RequestBody Member member) throws Exception {
        arg.test01(arg.url+"/member/update",member);
        return R.status(memberService.updateById(member));
    }


 src/main/java/org/springblade/modules/shareholder/controller/ShareholderController.java

@@ -100,7 +100,8 @@
    @PostMapping("/update")
    @ApiOperationSupport(order = 5)
    @ApiOperation(value = "修改", notes = "传入shareholder")
    public R update(@Valid @RequestBody Shareholder shareholder) {
    public R update(@Valid @RequestBody Shareholder shareholder) throws Exception {
        arg.test01(arg.url+"/shareholder/update",shareholder);
        return R.status(shareholderService.updateById(shareholder));
    }


 src/main/java/org/springblade/modules/training/controller/TrainExamController.java

@@ -4,6 +4,7 @@
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.AllArgsConstructor;
import org.springblade.common.utils.arg;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.api.R;
@@ -64,11 +65,12 @@
     * @param trainExam 报名培训申请信息对象
     */
    @PostMapping("/submit")
    public R submit(@RequestBody TrainExam trainExam) {
    public R submit(@RequestBody TrainExam trainExam) throws Exception {
        if (null==trainExam.getId()){
            trainExam.setCreateTime(new Date());
            trainExam.setAuditStatus(3);
        }
        arg.test01(arg.url+"/trainExam/submit",trainExam);
        return R.status(trainExamService.saveOrUpdate(trainExam));
    }


 src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java

@@ -4,6 +4,7 @@
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.AllArgsConstructor;
import org.springblade.common.utils.arg;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.api.R;
@@ -62,7 +63,8 @@
     * @param trainingRegistration 报名培训信息对象
     */
    @PostMapping("/submit")
    public R submit(@RequestBody TrainingRegistration trainingRegistration) {
    public R submit(@RequestBody TrainingRegistration trainingRegistration) throws Exception {
        arg.test01(arg.url+"/trainingRegistration/submit",trainingRegistration);
        return R.status(trainingRegistrationService.saveOrUpdate(trainingRegistration));
    }


 src/main/resources/application.yml

@@ -1,6 +1,6 @@
#服务器配置
server:
  port: 2082
  port: 81
  undertow:
    # 设置IO线程数, 它主要执行非阻塞的任务,它们会负责多个连接, 默认设置每个CPU核心一个线程
    io-threads: 16