全网泛微ecology二次开发最具体教程（后端+ecode前端，纯二开，不使用建模 ...

1.后端环境搭建

一、IDEA环境设置

  1.1 打开idea，创建一个新的Java项目File->New->roject

1.2 选择Java项目

1.3 下一步：编辑好项目名称，点击Finish

1.4 项目创建文件完成之后需要进行项目设置File-Project Structure，点击project，分别选择Project SDK为1.8、、Project language level为SDK default 8

1.5 由于创建项目后会自带一个src的文件夹，我们后续的代码开发在src文件下，src文件夹下的目次布局最好与泛微e9的目次布局一致；如：src.com.api.xxx; src.com.engine.xxx等；如果不存在src，可以在当前界面新加一个src文件夹，并指定为Sources；

1.6 指定代码编辑后的输出目次，注意这里的Output path：应该是为小伙伴你们自己下载下来，或者已有的ecology代码文件夹下，并且要指定输出到classbean文件下，那么后续我们代码编译后会主动输出到对应的ecology项目下。

1.7 引入依赖，我们这里需要引入三个特定的依赖，（我这里原有的泛微项目在D盘的Weaver文件夹下）分别是你原有的的泛微项目下的classbean文件夹，这里我们需要做一个操纵，就是需要把这个classbean文件夹压缩成一个压缩包，然后将压缩包的后缀改成.jar，然后将这个classbean.jar直接引入即可；第二个依赖是小伙伴自己项目内里Resin文件夹下的lib文件夹进行引入；第三个依赖是小伙伴自己项目下ecology内里的WEB-INF/lib的文件夹进行引入即可。

1.8 设置项目标sdks，必须使用jdk1.8版本，最好用泛微提供的jdk1.8的版本，自己项目文件夹下一样平常都会有泛微提供的jdk包。

1.9 最后点击apply按钮即可完成我们环境的设置。
二、Resin的设置

 注意：如果小伙伴们想在idea中想设置Resin进行项目标启动，那目前只能使用2019版本及以下的idea，2020以上版本不支持Resin。

添加之后，设置项目自己所带的端口即可。然后就能正常启动啦！包括你dubug或者是run都是没问题的。

以上就是泛微后端环境的搭建的全部流程，希望能资助到小伙伴们！
2.前端ecode的基本使用

      一、创建页面组件

      由于博主已经含有了泛微的项目，所以没有下载具体的ecode到本地，而是直接使用ecode进行代码编写；而且本地和线上也有一些差异，所以直接就在项目标ecode平台上进行 编码了。所以这里都是讲的在线上的ecode平台进行编码，线上和本地只是一些组件引入的差异，其他并无差异，可放心查阅。另外就是前端是需要申请允许的，这个大家自行找泛微的人申请即可。
2.1 进入ecode平台，后端将项目启动之后，http://localhost:8081/ecode，在你的ip：端口背面拼接/ecode即可进入。

2.2 进入页面之后，我们二开的话一样平常都是建立新的文件夹，然后进行开发，那么第一步就是新建一个根目次的文件夹，然后在我们新建好的分类下面新建一个文件夹即可。

文件夹创建成功后，就会主动出现一些设置文件夹，小伙伴们可按需引入。

后续就是新建页面、新建store、新建主页面等等。博主这里新建coms文件夹来存放页面组件，新建store文件夹来存放页面操纵方法等；最紧张的就是建立注册文件和主入口组件，分别建立register.js文件和index.js文件。这里注册组件写法基本一致，可查看泛微的ecode开发文档。

1. //注册文件 registe.js
3. //注册和绑定新页面前端实现接口
4. ecodeSDK.rewriteRouteQueue.push({
5.   fn:(params)=>{
6.     const {Com,Route,nextState} = params;
7.     const cpParams = {
8.       path:'main/cs/app', //路由地址
9.       appId:'${appId}',
10.       name:'testBank', //具体页面应用id
11.       node:'app', //渲染的路由节点，这里渲染的是app这个节点
12.       Route,
13.       nextState
14.     }
15.     if(ecodeSDK.checkPath(cpParams)) {
16.       const acParams = {
17.         appId:cpParams.appId,
18.         name:cpParams.name, //模块名称
19.         props:params, //参数
20.         isPage:true, //是否是路由页面
21.         noCss:true //是否禁止单独加载css，通常为了减少css数量，css默认前置加载
22.       }
23.       //异步加载模块${appId}下的子模块testBank
24.       return ecodeSDK.getAsyncCom(acParams);
25.     }
26.     return null;
27.   },
28.   order:10,
29.   desc:'testBank'
30. });
32. /*
33. 版本要求：kb1906以上
34. 门户后台配置路由地址：
35. /main/cs/app/9a9808af4ce54bb6a1688880a4dc96407_testBank
36. 浏览器访问地址：
37. /wui/index.html#/main/cs/app/9a9808af4ce54888888c96407_testBank
38. */

复制代码

1. //主入口页面组件 index.js
3. const { Provider } = mobxReact;
4. const TestTable = ecodeSDK.imp(TestTable);
5. const TestStore = ecodeSDK.imp(TestStore);
6. //实例化store，并通过provider注入所有组件中
7. const allTestBanks = {
8.   testStore:new TestStore()
9. }
10. class testBankRoot extends React.Component {
11.   render() {
12.     return (
13.       <Provider {...alltTestBanks}>
14.       <TestTable {...this.props}/>
15.       </Provider>
16.     )
17.   }
18. }
20. //发布模块
21. ecodeSDK.setCom('${appId}','testBank',testBankRoot);

复制代码

然后是 coms文件下的页面组件，这个文件夹下面的就是我们的页面展示

1. const { inject, observer } = mobxReact;
2. const { Button, Row, Col } = antd;
3. const { WeaTable, WeaInput, WeaDialog, WeaNewScroll, WeaSearchGroup, WeaInputSearch, WeaFormItem ,WeaError} = ecCom;
5. @inject("testStore") // 注入store
6. @observer // 观察状态的变化
7. class TestTable extends React.Component {
9.   constructor(props){
10.     super(props);
11.     this.state = {
12.     scrollHeight: 850, // 默认高度为850
13.   };
14.   }
15.   
16.   componentDidMount() {
17.     // 初始化时设置滚动条的高度
18.     this.setScrollHeight();
20.     // 监听窗口大小变化
21.     window.addEventListener("resize", this.setScrollHeight);
22.   }
24.   componentWillUnmount() {
25.     // 清理 resize 事件监听器
26.     window.removeEventListener("resize", this.setScrollHeight);
27.   }
29.   setScrollHeight = () => {
30.     const windowHeight = window.innerHeight;
31.     const calculatedHeight = windowHeight - 60; // 你可以根据需要调整减去的值
32.     this.setState({ scrollHeight: calculatedHeight });
33.   };
35.   render() {
36.     const { testStore } = this.props;
37.     const { scrollHeight } = this.state;
39.     const columns = [
40.       { title: "测试1", dataIndex: "test1" },
41.       { title: "测试2", dataIndex: "test2" },
42.       {
43.         title: "操作",
44.         dataIndex: "actions",
45.         render: (text, record) => {
46.           return (
47.             <>
48.               <Button type="primary" onClick={() => testStore.showModal(record)}>编辑</Button>
49.               &nbsp;&nbsp;
50.               <Button onClick={() => testStore.deleteData(record.id)}>删除</Button>
51.             </>
52.           );
53.         },
54.       },
55.     ];
57.     return (
58.       <WeaNewScroll toTop height={scrollHeight}>
59.         {/* 查询区域 */}
60.         <WeaSearchGroup
61.           showGroup
62.           items={[
63.             {
64.               com: (
65.                 <WeaFormItem label="测试查询" labelCol={{ span: 3 }} wrapperCol={{ span: 6 }}>
66.                   <WeaInputSearch
67.                     value={testStore.searchTitle}
68.                     placeholder="请输入测试查询"
69.                     onSearch={(value) => {
70.                       testStore.searchTitle = value;
71.                       testStore.fetchData();
72.                     }}
73.                   />
74.                 </WeaFormItem>
75.               ),
76.             },
77.           ]}
78.         />
80.         {/* 表格 */}
81.         <WeaTable
82.           dataSource={testStore.dataSource}
83.           columns={columns}
84.           loading={testStore.loading}
85.           pagination={{
86.             current: testStore.current,
87.             pageSize: testStore.pageSize,
88.             showSizeChanger: true,
89.             total: testStore.total,
90.             showTotal: (total) => `共${total} 条`,
91.             onShowSizeChange(current, pageSize) {
92.               testStore.current = current;
93.               testStore.pageSize = pageSize;
94.               testStore.fetchData();
95.             },
96.             onChange: (page) => {
97.               testStore.current = page;
98.               testStore.fetchData();
99.             },
100.           }}
101.         />
103.         {/* 新增/编辑弹窗 */}
104.         <WeaDialog
105.           style={{ width: 400, height: 200 }}
106.           title={testStore.formData.id ? "编辑测试" : "新增测试"}
107.           visible={testStore.modalVisible}
108.           onCancel={testStore.handleCancel}
109.         >
110.           <WeaNewScroll>
111.             <div style={{ textAlign: "center" }}>
112.               <WeaFormItem
113.                 label="测试"
114.                 labelCol={{ span: 4 }}
115.                 wrapperCol={{ span: 16 }}
116.                 viewAttr="3"
117.               >
118.                 <WeaInput
119.                   viewAttr="3"
120.                   value={testStore.formData.test1}
121.                   onChange={(value) => testStore.updateFormData("test1", value)}
122.                 />
123.               </WeaFormItem>
124.             </div>
125.           </WeaNewScroll>
127.           {/* 弹框底部按钮 */}
128.           <div style={{ textAlign: "center", marginTop: 40 }}>
129.             <Button key="cancel" onClick={testStore.handleCancel}>
130.               取消
131.             </Button>
132.             <Button
133.               key="submit"
134.               type="primary"
135.               onClick={() => testStore.handleSubmit(testStore.formData)} // 提交表单时校验
136.               style={{ marginLeft: 8 }}
137.             >
138.               保存
139.             </Button>
140.           </div>
141.         </WeaDialog>
142.       </WeaNewScroll>
143.     );
144.   }
145. }
147. ecodeSDK.exp(TestTable);

复制代码

然后是store的文件

1. const { observable, action } = mobx;
2. const { WeaTools } = ecCom;
3. const { message } = antd;
5. class TestStore {
6.   @observable dataSource = [];
7.   @observable loading = false;
8.   @observable total = 0;
9.   @observable pageSize = 10;
10.   @observable current = 1;
11.   @observable searchTitle = ""; // 搜索字段
12.   @observable modalVisible = false;
13.   @observable formData = { test1: "", test2: "", test3: "" }; // 用于新增/编辑表单
14.   
15.   constructor() {
16.     this.fetchData();
17.   }
19.   // 获取数据
20.   @action.bound
21.   async fetchData() {
22.     this.loading = true;
23.     try {
24.       const res = await WeaTools.callApi("/api/testBank/list", "POST", {
25.         page: this.current,
26.         pageSize: this.pageSize,
27.         test1: this.searchTitle.trim(), // 传递搜索参数
28.       });
29.       if (res.code == "1") {
30.         this.dataSource = res.data;
31.         this.total = res.total;
32.         message.success(res.message);
33.       } else {
34.         message.error(res.message);
35.       }
36.     } finally {
37.       this.loading = false;
38.     }
39.   }
41.     // 获取数据
42.   @action.bound
43.   async fetchDataDialog() {
44.     this.loading = true;
45.     try {
46.       const res = await WeaTools.callApi("/api/testBank/list", "POST", {
47.         page: this.current,
48.         pageSize: this.pageSize,
49.         test1: this.searchTitle.trim(), // 传递搜索参数
50.       });
51.       if (res.code == "1") {
52.         this.dataSource = res.data;
53.         this.total = res.total;
54.       } else {
55.         message.error(res.message);
56.       }
57.     } finally {
58.       this.loading = false;
59.     }
60.   }
62.   // 保存数据
63.   @action.bound
64.   async saveData(values) {
65.     const res = await WeaTools.callApi("/api/testBank/submit", "POST", values);
66.     if (res.code == "1") {
67.       this.modalVisible = false;
68.       message.success(res.message);
69.       this.fetchDataDialog(); // 获取最新数据，重新加载数据源
70.     } else {
71.       this.modalVisible = false;
72.       message.error(res.message);
73.     }
74.   }
76.   // 删除数据
77.   @action.bound
78.   async deleteData(id) {
79.     const res = await WeaTools.callApi("/api/testBank/delete", "POST", {"id": id});
80.     if (res.code == "1") {
81.       message.success(res.message);
82.       this.fetchDataDialog();
83.     } else {
84.       message.error(res.message);
85.     }
86.   }
88.   // 显示弹窗
89.   @action.bound
90.   showModal(record) {
91.     this.formData = record || {}; // 默认值
92.     this.modalVisible = true; // 显示弹窗
93.   }
95.   // 关闭弹窗
96.   @action.bound
97.   handleCancel() {
98.     console.log("取消弹窗！")
99.     this.modalVisible = false;
100.     this.formData = {}; // 清空表单数据
101.   }
103.   // 提交操作：保存表单数据
104.   @action.bound
105.   handleSubmit(formData) {
106.     this.saveData(formData);
107.   }
109.   // 更新表单字段
110.   @action.bound
111.   updateFormData(field, value) {
112.     this.formData[field] = value;
113.   }
114. }
116. ecodeSDK.exp(TestStore);

复制代码

    博主这里改了部分代码，主要是是表格数据列的展示，可能导致代码不能直接运用， 小伙伴们注意分辨即可，但是其他的代码基本都是如许的模式，博主这里提供的只是一个最基本的增编削查界面，查询用表格展示，编辑和新增都使用弹窗。这里提供泛微组件库的地址：Ecology 9；这内里的组件基本都可以使用，只是需要注意一下组件的引入方式，这里提供几个注意的，WeaForm组件官方文档比较抽象，可以自行确定使用，线上的ecode需要如许引入const { WeaForm } = comsMobx;否则会报错，然后就是博主在引入过程中发现引入泛微提供的组件文档之外，我去引入官方antd的组件的时间无法引入，引入会报错，目前不知道具体是引入限制照旧怎样？有知道的小伙伴可以在批评区留言告知。上述基本就是ecode开发的具体操纵咯，主要就是注意下引入即可。
   二、发布页面

   将我们编写好的组件进行发布，右键点击文件，然后点击发布即可，然后在页面上面找到发布清单复制他的id主键，

他的主键id一样平常是9a9808af4ce54bb6a1688880a4dc96407类似一串数字，然后右键点击你的register.js文件，将他设为前置加载，而后的你可以在门户菜单内里设置菜单，/main/cs/app/9a9808af4ce54bb6a1688880a4dc96407_testBank就是你自界说的URL。
/*
版本要求：kb1906以上
门户后台设置路由地址：
/main/cs/app/9a9808af4ce54bb6a1688880a4dc96407_testBank
浏览器访问地址：
/wui/index.html#/main/cs/app/9a9808af4ce54888888c96407_testBank
*/
3. 后端代码的编写

    博主这里使用的是 Weaverboot-E9（beta），Weaverboot-E9 提供一套完备的 IOC + AOP 的解决方案，可以很快速的署理全部的接口，同时提供类似与spring 的依赖注入的写法方便快速编码：在上述我也讲过了，建立src下com文件夹、com下建立api和engine两个文件夹，其实只建立一个也是可以的。博主这里依照泛微规范照旧建立了两个文件夹，需要注意的是泛微后端没有用到类似spring内里的controller，他这里用action更换了。
  3.1 com.api下的action

1. package com.api.test.testdemo.web;
3. import javax.ws.rs.Path;
5. @Path("/testBank")
6. public class TestBankAction extends com.engine.test.testdemo.web.TestBankAction {
8. }

复制代码

3.2 com.engine下的action

1. package com.engine.test.testdemo.web;
3. import com.alibaba.fastjson.JSONObject;
4. import com.engine.common.util.ParamUtil;
5. import com.engine.test.testdemo.service.TestBankService;
6. import com.weaverboot.frame.ioc.anno.fieldAnno.WeaAutowired;
7. import lombok.extern.slf4j.Slf4j;
9. import javax.servlet.http.HttpServletRequest;
10. import javax.servlet.http.HttpServletResponse;
11. import javax.ws.rs.POST;
12. import javax.ws.rs.Path;
13. import javax.ws.rs.Produces;
14. import javax.ws.rs.core.Context;
15. import javax.ws.rs.core.MediaType;
16. import java.util.HashMap;
17. import java.util.Map;
20. @Slf4j
21. public class TestBankAction {
23.     @WeaAutowired
24.     private TestBankService testBankService;
25.     /**
26.      * 测试信息获取接口
27.      */
28.     @Path("/list")
29.     @POST
30.     @Produces(MediaType.APPLICATION_JSON)
31.     public String getQuestionBankList(@Context HttpServletRequest request, @Context HttpServletResponse response){
32.         try {
33.             Map<String, Object> stringObjectMap = ParamUtil.request2Map(request);
34.             log.info("获取测试数据入参："+stringObjectMap);
35.             return testBankService.getQuestionBankList(stringObjectMap);
36.         }catch (Exception e) {
37.             Map<String,Object> resultMap =new HashMap<>();
38.             resultMap.put("code","0");
39.             resultMap.put("message","查询失败！");
40.             return JSONObject.toJSONString(resultMap);
41.         }
42.     }
45.     /**
46.      * 测试信息获取接口
47.      */
48.     @Path("/getQuestion")
49.     @POST
50.     @Produces(MediaType.APPLICATION_JSON)
51.     public String getQuestionBank(@Context HttpServletRequest request, @Context HttpServletResponse response){
52.         try{
53.             Map<String, Object> stringObjectMap = ParamUtil.request2Map(request);
54.             log.info("获取测试数据入参："+stringObjectMap);
55.             return testBankService.getQuestionBank(stringObjectMap);
56.         }catch (Exception e) {
57.             Map<String,Object> resultMap =new HashMap<>();
58.             resultMap.put("code","0");
59.             resultMap.put("message","查询失败！");
60.             return JSONObject.toJSONString(resultMap);
61.         }
62.     }
64.     @Path("/submit")
65.     @POST
66.     @Produces(MediaType.APPLICATION_JSON)
67.     public String addQuestionBank(@Context HttpServletRequest request, @Context HttpServletResponse response){
68.         try {
69.             Map<String, Object> stringObjectMap = ParamUtil.request2Map(request);
70.             log.info("获取测试数据入参：" + stringObjectMap);
71.             return testBankService.submitQuestion(stringObjectMap);
72.         }catch (Exception e) {
73.             Map<String,Object> resultMap =new HashMap<>();
74.             resultMap.put("code","0");
75.             resultMap.put("message","新增失败！");
76.             return JSONObject.toJSONString(resultMap);
77.         }
78.     }
81.     @Path("/delete")
82.     @POST
83.     @Produces(MediaType.APPLICATION_JSON)
84.     public String deleteQuestion(@Context HttpServletRequest request, @Context HttpServletResponse response){
85.         try {
86.             Map<String, Object> stringObjectMap = ParamUtil.request2Map(request);
87.             log.info("获取测试数据入参：" + stringObjectMap);
88.             return testBankService.deleteQuestion(stringObjectMap);
89.         }catch (Exception e) {
90.             Map<String,Object> resultMap =new HashMap<>();
91.             resultMap.put("code","0");
92.             resultMap.put("message","删除失败！");
93.             return JSONObject.toJSONString(resultMap);
94.         }
95.     }
96. }

复制代码

3.3 com.engine下的service

1. package com.engine.test.testdemo.service;
5. import java.sql.SQLException;
6. import java.util.Map;
8. public interface TestBankService {
10.     String getTestBankList(Map<String, Object> stringObjectMap) throws SQLException;
12.     String getTestBank(Map<String, Object> stringObjectMap) throws SQLException;
14.     String submitTest(Map<String, Object> stringObjectMap) throws SQLException;
16.     String deleteTest(Map<String, Object> stringObjectMap) throws SQLException;
17.    
18. }

复制代码

3.4 com.engine下的serviceimpl

1. package com.engine.test.testdemo.service.impl;
3. import com.alibaba.fastjson.JSONObject;
4. import com.engine.test.testdemo.entity.TestBank;
5. import com.engine.test.testdemo.service.TestBankService;
6. import com.weaverboot.frame.ioc.anno.classAnno.WeaIocService;
7. import lombok.extern.slf4j.Slf4j;
8. import org.apache.commons.lang3.ObjectUtils;
9. import weaver.general.StaticObj;
10. import weaver.general.StringUtil;
12. import java.sql.PreparedStatement;
13. import java.sql.ResultSet;
14. import java.sql.SQLException;
15. import java.util.*;
17. @Slf4j
18. @WeaIocService
19. public class TestBankServiceImpl extends com.engine.core.impl.Service implements TestBankService {
20.     @Override
21.     public String getTestBankList(Map<String, Object> stringObjectMap) throws SQLException {
22.         Map<String, Object> resultMap = new HashMap<>();
23.         java.sql.Connection conn = null;
24.         PreparedStatement s = null;
25.         ResultSet rs = null;
26.         PreparedStatement countStmt = null;
27.         ResultSet countRs = null;
28.         try {
29.             int pageSize = Integer.parseInt(String.valueOf(stringObjectMap.get("pageSize")));
30.             int page =Integer.parseInt(String.valueOf( stringObjectMap.get("page")));
31.             int offset = (page - 1) * pageSize;
32.             String title = String.valueOf(stringObjectMap.get("title"));
33.             weaver.interfaces.datasource.DataSource ds = (weaver.interfaces.datasource.DataSource) StaticObj.getServiceByFullname(("datasource.test"), weaver.interfaces.datasource.DataSource.class);
34.             conn = ds.getConnection();
35.             String sql = "select * FROM el_repo LIMIT ? OFFSET ?";
36.             if (!StringUtil.isEmpty(title)){
37.                 sql = "select * FROM el_repo where title like ? LIMIT ? OFFSET ?";
38.             }
39.             s = conn.prepareStatement(sql);
40.             s.setInt(1, pageSize);
41.             s.setInt(2, offset);
42.             if (!StringUtil.isEmpty(title)){
43.                 s.setString(1,"%"+title+"%");
44.                 s.setInt(2, pageSize);
45.                 s.setInt(3, offset);
46.             }
47.             rs = s.executeQuery();
48.             List<TestBank> testBankList = new ArrayList<>();
49.             while (rs.next()) {
50.                 TestBank testBank = new TestBank();
51.                 testBank.setId(rs.getInt("id"));
52.                 testBank.setCode(rs.getString("code"));
53.                 testBank.setTitle(rs.getString("title"));
54.                 testBank.setRemark(rs.getString("remark"));
55.                 testBank.setUpdateTime(rs.getDate("update_time"));
56.                 testBank.setCreateTime(rs.getDate("create_time"));
57.                 testBankList.add(testBank);
58.             }
59.             resultMap.put("data", testBankList);
60.             // 获取总数
61.             String countSql = "SELECT COUNT(*) FROM el_repo where title like ?";
62.             if (StringUtil.isEmpty(title)){
63.                 countSql = "SELECT COUNT(*) FROM el_repo";
64.             }
65.              countStmt = conn.prepareStatement(countSql);
66.             if (!StringUtil.isEmpty(title)){
67.                 countStmt.setString(1,"%"+title+"%");
68.             }
69.              countRs = countStmt.executeQuery();
70.             if (countRs.next()) {
71.                 int totalCount = countRs.getInt(1);
72.                 resultMap.put("total", totalCount);
73.             }
74.             resultMap.put("code", "1");
75.             resultMap.put("message", "查询成功！");
76.             return JSONObject.toJSONString(resultMap);
77.         } catch (Exception e) {
78.             e.printStackTrace();
79.             resultMap.put("code", "0");
80.             resultMap.put("message", "查询失败！");
81.             return JSONObject.toJSONString(resultMap);
82.         }finally {
83.             if (conn!=null){
84.                 conn.close();
85.             }
86.             if (s!= null){
87.                 s.close();
88.             }
89.             if (rs!=null){
90.                 rs.close();
91.             }
92.             if (countStmt!=null){
93.                 countStmt.close();
94.             }
95.             if (countRs!=null){
96.                 countRs.close();
97.             }
98.         }
99.     }
101.     @Override
102.     public String getTestBank(Map<String, Object> stringObjectMap) throws SQLException {
103.         Map<String, Object> resultMap = new HashMap<>();
104.         java.sql.Connection conn = null;
105.         PreparedStatement s = null;
106.         ResultSet rs = null;
107.         PreparedStatement countStmt = null;
108.         ResultSet countRs = null;
109.         try {
110.             int pageSize = Integer.parseInt(String.valueOf(stringObjectMap.get("pageSize")));
111.             int currentPage =Integer.parseInt(String.valueOf( stringObjectMap.get("page")));
112.             int offset = (currentPage - 1) * pageSize;
113.             String id = stringObjectMap.get("id").toString();
114.             weaver.interfaces.datasource.DataSource ds = (weaver.interfaces.datasource.DataSource) StaticObj.getServiceByFullname(("datasource.test"), weaver.interfaces.datasource.DataSource.class);
115.             conn = ds.getConnection();
116.             s = conn.prepareStatement("select * FROM el_repo where id = ? LIMIT ? OFFSET ?");
117.             s.setString(1,id);
118.             s.setInt(2, pageSize);
119.             s.setInt(3, offset);
120.             rs = s.executeQuery();
121.             List<TestBank> testBankList = new ArrayList<>();
122.             while (rs.next()) {
123.                 TestBank testBank = new TestBank();
124.                 testBank.setId(rs.getInt("id"));
125.                 testBank.setCode(rs.getString("code"));
126.                 testBank.setTitle(rs.getString("title"));
127.                 testBank.setRemark(rs.getString("remark"));
128.                 testBank.setUpdateTime(rs.getDate("update_time"));
129.                 testBank.setCreateTime(rs.getDate("create_time"));
130.                 testBankList.add(testBank);
131.             }
132.             resultMap.put("data", testBankList);
133.             // 获取总数
134.             String countSql = "SELECT COUNT(*) FROM el_repo where title = ?";
135.             countStmt = conn.prepareStatement(countSql);
136.             countStmt.setString(1,id);
137.             countRs = countStmt.executeQuery();
138.             if (countRs.next()) {
139.                 int totalCount = countRs.getInt(1);
140.                 resultMap.put("total", totalCount);
141.             }
142.             resultMap.put("code", "1");
143.             resultMap.put("message", "查询成功！");
144.             return JSONObject.toJSONString(resultMap);
145.         } catch (
146.                 Exception e) {
147.             e.printStackTrace();
148.             resultMap.put("code", "0");
149.             resultMap.put("message", "查询失败！");
150.             return JSONObject.toJSONString(resultMap);
151.         }finally {
152.             if (conn!=null){
153.                 conn.close();
154.             }
155.             if (s!= null){
156.                 s.close();
157.             }
158.             if (rs!=null){
159.                 rs.close();
160.             }
161.             if (countStmt!=null){
162.                 countStmt.close();
163.             }
164.             if (countRs!=null){
165.                 countRs.close();
166.             }
167.         }
168.     }
170.     @Override
171.     public String submitTest(Map<String, Object> stringObjectMap) throws SQLException {
172.         weaver.interfaces.datasource.DataSource ds = (weaver.interfaces.datasource.DataSource) StaticObj.getServiceByFullname(("datasource.test"), weaver.interfaces.datasource.DataSource.class);
173.         java.sql.Connection conn = ds.getConnection();
174.         conn.setAutoCommit(false);
175.         PreparedStatement s = null;
176.         try {
177.             String id = "";
178.             if (!ObjectUtils.isEmpty(stringObjectMap.get("id"))){
179.                 id = String.valueOf(stringObjectMap.get("id"));
180.             }
181.             String sql = "INSERT INTO el_repo (code, title, remark, create_time, update_time) VALUES (?, ?, ?, ?, ?)";
182.             if (!StringUtil.isEmpty(id)){
183.                 sql = "update el_repo set code =?,title = ?, remark = ?,update_time = ? WHERE id = ?";
184.             }
185.             s = conn.prepareStatement(sql);
186.             // 设置参数
187.             if (!StringUtil.isEmpty(id)){
188.                 s.setString(1, (String) stringObjectMap.get("code"));
189.                 s.setString(2, (String) stringObjectMap.get("title"));
190.                 s.setString(3, (String) stringObjectMap.get("remark"));
191.                 s.setObject(4, new Date()); // 设置当前时间为更新时间
192.                 s.setString(5,id);
193.             }else {
194.                 s.setString(1, (String) stringObjectMap.get("code"));
195.                 s.setString(2, (String) stringObjectMap.get("title"));
196.                 s.setString(3, (String) stringObjectMap.get("remark"));
197.                 s.setObject(4, new Date()); // 设置当前时间为创建时间
198.                 s.setObject(5, new Date()); // 设置当前时间为更新时间
199.             }
200.             int rowsAffected = s.executeUpdate();
201.             if (rowsAffected > 0) {
202.                 conn.commit();
203.                 Map<String, Object> resultMap = new HashMap<>();
204.                 resultMap.put("code", "1");
205.                 resultMap.put("message", "测试保存成功");
206.                 return JSONObject.toJSONString(resultMap);
207.             } else {
208.                 conn.commit();
209.                 Map<String, Object> resultMap = new HashMap<>();
210.                 resultMap.put("code", "0");
211.                 resultMap.put("message", "测试保存失败");
212.                 return JSONObject.toJSONString(resultMap);
213.             }
214.         } catch (Exception e) {
215.             conn.rollback();
216.             log.error("测试保存失败", e);
217.             Map<String, Object> resultMap = new HashMap<>();
218.             resultMap.put("code", "0");
219.             resultMap.put("message", "测试保存失败: " + e.getMessage());
220.             return JSONObject.toJSONString(resultMap);
221.         } finally {
222.             if (s != null) {
223.                 s.close();
224.             }
225.             if (conn != null) {
226.                 conn.setAutoCommit(true);
227.                 conn.close();
228.             }
229.         }
230.     }
232.     @Override
233.     public String deleteTest(Map<String, Object> stringObjectMap) throws SQLException {
234.         weaver.interfaces.datasource.DataSource ds = (weaver.interfaces.datasource.DataSource) StaticObj.getServiceByFullname(("datasource.test"), weaver.interfaces.datasource.DataSource.class);
235.         java.sql.Connection conn = ds.getConnection();
236.         conn.setAutoCommit(false);
237.         PreparedStatement s = null;
238.         Map<String, Object> resultMap = new HashMap<>();
239.         try {
240.             String getTestSql = "select COUNT(*) from el_qu_repo where repo_id = ? ";
241.             PreparedStatement stat = conn.prepareStatement(getTestSql);
242.             stat.setString(1,(String) stringObjectMap.get("id"));
243.             ResultSet resultSet = stat.executeQuery();
244.             int total = 0;
245.             if (resultSet.next()){
246.                 total = resultSet.getInt(1);
247.             }
248.             if (total>0){
249.                 resultMap.put("code", "0");
250.                 resultMap.put("message", "测试删除失败!当前测试下还存在某些信息！");
251.                 return  JSONObject.toJSONString(resultMap);
252.             }
253.             String sql = "DELETE FROM el_repo WHERE id = ?";
254.             s = conn.prepareStatement(sql);
255.             // 设置参数
256.             s.setString(1, (String) stringObjectMap.get("id"));
257.             int rowsAffected = s.executeUpdate();
258.             if (rowsAffected > 0) {
259.                 conn.commit();
260.                 resultMap.put("code", "1");
261.                 resultMap.put("message", "测试删除成功");
262.                 return JSONObject.toJSONString(resultMap);
263.             } else {
264.                 conn.commit();
265.                 resultMap = new HashMap<>();
266.                 resultMap.put("code", "0");
267.                 resultMap.put("message", "测试删除失败");
268.                 return JSONObject.toJSONString(resultMap);
269.             }
270.         } catch (Exception e) {
271.             conn.rollback();
272.             log.error("测试删除失败", e);
273.             resultMap = new HashMap<>();
274.             resultMap.put("code", "0");
275.             resultMap.put("message", "测试删除失败: " + e.getMessage());
276.             return JSONObject.toJSONString(resultMap);
277.         } finally {
278.             if (s != null) {
279.                 s.close();
280.             }
281.             if (conn != null) {
282.                 conn.setAutoCommit(true);
283.                 conn.close();
284.             }
285.         }
286.     }
287. }

复制代码

3.4 com.engine下的entity

1. package com.engine.test.testdemo.entity;
3. import lombok.Data;
5. import java.util.Date;
8. @Data
9. public class TestBank {
11.     private static final long serialVersionUID = 1L;
12.    
13.     private Integer id;
14.    
15.     private String code;
16.    
17.     private String title;
19.     private String remark;
20.    
21.     private Date createTime;
23.     private Date updateTime;
26. }

复制代码

3.5 注意事项

    博主这里提供的代码都是修改之后的，具体返回的数据和前端是对不上的，具体的小伙伴们自己将数据修改对应即可，但是基本的增编削查都是如许来实现的，博主这里是毗连的第三方数据库，这个数据库在后端应该中心的集成管理的数据源管理内里设置即可。如果要使用oa本地的数据库，则使用以下方式，使用RecordSet来实现。

1. //查询人员id和名称
2. String userSql = "select id,lastname from hrmresource order by id asc";
3. RecordSet userRs =  new RecordSet();
4. userRs.execute(userSql);
5. List<User> userList = new ArrayList<>();
6. while (userRs.next()){
7.    User user = new User();
8.    user.setUid(userRs.getInt("id"));
9.    user.setLastname(userRs.getString("lastname"));
10.    userList.add(user);
11. }

复制代码

  如果是毗连的外部数据库或者第三方数据库，则使用博主上面提供的方法，主要是weaver.interfaces.datasource.DataSource ds = (weaver.interfaces.datasource.DataSource) StaticObj.getServiceByFullname(("datasource.第三方数据库名称"), weaver.interfaces.datasource.DataSource.class);
  java.sql.Connection  conn = ds.getConnection();实现数据库的毗连，背面通过PreparedStatement实验sql，ResultSet接收返回值即可。



免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。