全网泛微ecology二次开发最具体教程（后端+ecode前端，纯二开，不使用建模） - IT评测·应用市场-qidao123.com技术社区

//注册文件 registe.js
//注册和绑定新页面前端实现接口
ecodeSDK.rewriteRouteQueue.push({
fn:(params)=>{
const {Com,Route,nextState} = params;
const cpParams = {
path:'main/cs/app', //路由地址
appId:'${appId}',
name:'testBank', //具体页面应用id
node:'app', //渲染的路由节点，这里渲染的是app这个节点
Route,
nextState
}
if(ecodeSDK.checkPath(cpParams)) {
const acParams = {
appId:cpParams.appId,
name:cpParams.name, //模块名称
props:params, //参数
isPage:true, //是否是路由页面
noCss:true //是否禁止单独加载css，通常为了减少css数量，css默认前置加载
}
//异步加载模块${appId}下的子模块testBank
return ecodeSDK.getAsyncCom(acParams);
}
return null;
},
order:10,
desc:'testBank'
});
/*
版本要求：kb1906以上
门户后台配置路由地址：
/main/cs/app/9a9808af4ce54bb6a1688880a4dc96407_testBank
浏览器访问地址：
/wui/index.html#/main/cs/app/9a9808af4ce54888888c96407_testBank
*/

复制代码

//主入口页面组件 index.js
const { Provider } = mobxReact;
const TestTable = ecodeSDK.imp(TestTable);
const TestStore = ecodeSDK.imp(TestStore);
//实例化store，并通过provider注入所有组件中
const allTestBanks = {
testStore:new TestStore()
}
class testBankRoot extends React.Component {
render() {
return (
<Provider {...alltTestBanks}>
<TestTable {...this.props}/>
</Provider>
)
}
}
//发布模块
ecodeSDK.setCom('${appId}','testBank',testBankRoot);

复制代码

const { inject, observer } = mobxReact;
const { Button, Row, Col } = antd;
const { WeaTable, WeaInput, WeaDialog, WeaNewScroll, WeaSearchGroup, WeaInputSearch, WeaFormItem ,WeaError} = ecCom;
@inject("testStore") // 注入store
@observer // 观察状态的变化
class TestTable extends React.Component {
constructor(props){
super(props);
this.state = {
scrollHeight: 850, // 默认高度为850
};
}
componentDidMount() {
// 初始化时设置滚动条的高度
this.setScrollHeight();
// 监听窗口大小变化
window.addEventListener("resize", this.setScrollHeight);
}
componentWillUnmount() {
// 清理 resize 事件监听器
window.removeEventListener("resize", this.setScrollHeight);
}
setScrollHeight = () => {
const windowHeight = window.innerHeight;
const calculatedHeight = windowHeight - 60; // 你可以根据需要调整减去的值
this.setState({ scrollHeight: calculatedHeight });
};
render() {
const { testStore } = this.props;
const { scrollHeight } = this.state;
const columns = [
{ title: "测试1", dataIndex: "test1" },
{ title: "测试2", dataIndex: "test2" },
{
title: "操作",
dataIndex: "actions",
render: (text, record) => {
return (
<>
<Button type="primary" onClick={() => testStore.showModal(record)}>编辑</Button>
  
<Button onClick={() => testStore.deleteData(record.id)}>删除</Button>
</>
);
},
},
];
return (
<WeaNewScroll toTop height={scrollHeight}>
{/* 查询区域 */}
<WeaSearchGroup
showGroup
items={[
{
com: (
<WeaFormItem label="测试查询" labelCol={{ span: 3 }} wrapperCol={{ span: 6 }}>
<WeaInputSearch
value={testStore.searchTitle}
placeholder="请输入测试查询"
onSearch={(value) => {
testStore.searchTitle = value;
testStore.fetchData();
}}
/>
</WeaFormItem>
),
},
]}
/>
{/* 表格 */}
<WeaTable
dataSource={testStore.dataSource}
columns={columns}
loading={testStore.loading}
pagination={{
current: testStore.current,
pageSize: testStore.pageSize,
showSizeChanger: true,
total: testStore.total,
showTotal: (total) => `共${total} 条`,
onShowSizeChange(current, pageSize) {
testStore.current = current;
testStore.pageSize = pageSize;
testStore.fetchData();
},
onChange: (page) => {
testStore.current = page;
testStore.fetchData();
},
}}
/>
{/* 新增/编辑弹窗 */}
<WeaDialog
style={{ width: 400, height: 200 }}
title={testStore.formData.id ? "编辑测试" : "新增测试"}
visible={testStore.modalVisible}
onCancel={testStore.handleCancel}
>
<WeaNewScroll>
<div style={{ textAlign: "center" }}>
<WeaFormItem
label="测试"
labelCol={{ span: 4 }}
wrapperCol={{ span: 16 }}
viewAttr="3"
>
<WeaInput
viewAttr="3"
value={testStore.formData.test1}
onChange={(value) => testStore.updateFormData("test1", value)}
/>
</WeaFormItem>
</div>
</WeaNewScroll>
{/* 弹框底部按钮 */}
<div style={{ textAlign: "center", marginTop: 40 }}>
<Button key="cancel" onClick={testStore.handleCancel}>
取消
</Button>
<Button
key="submit"
type="primary"
onClick={() => testStore.handleSubmit(testStore.formData)} // 提交表单时校验
style={{ marginLeft: 8 }}
>
保存
</Button>
</div>
</WeaDialog>
</WeaNewScroll>
);
}
}
ecodeSDK.exp(TestTable);

复制代码

const { observable, action } = mobx;
const { WeaTools } = ecCom;
const { message } = antd;
class TestStore {
@observable dataSource = [];
@observable loading = false;
@observable total = 0;
@observable pageSize = 10;
@observable current = 1;
@observable searchTitle = ""; // 搜索字段
@observable modalVisible = false;
@observable formData = { test1: "", test2: "", test3: "" }; // 用于新增/编辑表单
constructor() {
this.fetchData();
}
// 获取数据
@action.bound
async fetchData() {
this.loading = true;
try {
const res = await WeaTools.callApi("/api/testBank/list", "POST", {
page: this.current,
pageSize: this.pageSize,
test1: this.searchTitle.trim(), // 传递搜索参数
});
if (res.code == "1") {
this.dataSource = res.data;
this.total = res.total;
message.success(res.message);
} else {
message.error(res.message);
}
} finally {
this.loading = false;
}
}
// 获取数据
@action.bound
async fetchDataDialog() {
this.loading = true;
try {
const res = await WeaTools.callApi("/api/testBank/list", "POST", {
page: this.current,
pageSize: this.pageSize,
test1: this.searchTitle.trim(), // 传递搜索参数
});
if (res.code == "1") {
this.dataSource = res.data;
this.total = res.total;
} else {
message.error(res.message);
}
} finally {
this.loading = false;
}
}
// 保存数据
@action.bound
async saveData(values) {
const res = await WeaTools.callApi("/api/testBank/submit", "POST", values);
if (res.code == "1") {
this.modalVisible = false;
message.success(res.message);
this.fetchDataDialog(); // 获取最新数据，重新加载数据源
} else {
this.modalVisible = false;
message.error(res.message);
}
}
// 删除数据
@action.bound
async deleteData(id) {
const res = await WeaTools.callApi("/api/testBank/delete", "POST", {"id": id});
if (res.code == "1") {
message.success(res.message);
this.fetchDataDialog();
} else {
message.error(res.message);
}
}
// 显示弹窗
@action.bound
showModal(record) {
this.formData = record || {}; // 默认值
this.modalVisible = true; // 显示弹窗
}
// 关闭弹窗
@action.bound
handleCancel() {
console.log("取消弹窗！")
this.modalVisible = false;
this.formData = {}; // 清空表单数据
}
// 提交操作：保存表单数据
@action.bound
handleSubmit(formData) {
this.saveData(formData);
}
// 更新表单字段
@action.bound
updateFormData(field, value) {
this.formData[field] = value;
}
}
ecodeSDK.exp(TestStore);

复制代码

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

复制代码

package com.engine.test.testdemo.web;
import com.alibaba.fastjson.JSONObject;
import com.engine.common.util.ParamUtil;
import com.engine.test.testdemo.service.TestBankService;
import com.weaverboot.frame.ioc.anno.fieldAnno.WeaAutowired;
import lombok.extern.slf4j.Slf4j;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import java.util.HashMap;
import java.util.Map;
@Slf4j
public class TestBankAction {
@WeaAutowired
private TestBankService testBankService;
/**
* 测试信息获取接口
*/
@Path("/list")
@POST
@Produces(MediaType.APPLICATION_JSON)
public String getQuestionBankList(@Context HttpServletRequest request, @Context HttpServletResponse response){
try {
Map<String, Object> stringObjectMap = ParamUtil.request2Map(request);
log.info("获取测试数据入参："+stringObjectMap);
return testBankService.getQuestionBankList(stringObjectMap);
}catch (Exception e) {
Map<String,Object> resultMap =new HashMap<>();
resultMap.put("code","0");
resultMap.put("message","查询失败！");
return JSONObject.toJSONString(resultMap);
}
}
/**
* 测试信息获取接口
*/
@Path("/getQuestion")
@POST
@Produces(MediaType.APPLICATION_JSON)
public String getQuestionBank(@Context HttpServletRequest request, @Context HttpServletResponse response){
try{
Map<String, Object> stringObjectMap = ParamUtil.request2Map(request);
log.info("获取测试数据入参："+stringObjectMap);
return testBankService.getQuestionBank(stringObjectMap);
}catch (Exception e) {
Map<String,Object> resultMap =new HashMap<>();
resultMap.put("code","0");
resultMap.put("message","查询失败！");
return JSONObject.toJSONString(resultMap);
}
}
@Path("/submit")
@POST
@Produces(MediaType.APPLICATION_JSON)
public String addQuestionBank(@Context HttpServletRequest request, @Context HttpServletResponse response){
try {
Map<String, Object> stringObjectMap = ParamUtil.request2Map(request);
log.info("获取测试数据入参：" + stringObjectMap);
return testBankService.submitQuestion(stringObjectMap);
}catch (Exception e) {
Map<String,Object> resultMap =new HashMap<>();
resultMap.put("code","0");
resultMap.put("message","新增失败！");
return JSONObject.toJSONString(resultMap);
}
}
@Path("/delete")
@POST
@Produces(MediaType.APPLICATION_JSON)
public String deleteQuestion(@Context HttpServletRequest request, @Context HttpServletResponse response){
try {
Map<String, Object> stringObjectMap = ParamUtil.request2Map(request);
log.info("获取测试数据入参：" + stringObjectMap);
return testBankService.deleteQuestion(stringObjectMap);
}catch (Exception e) {
Map<String,Object> resultMap =new HashMap<>();
resultMap.put("code","0");
resultMap.put("message","删除失败！");
return JSONObject.toJSONString(resultMap);
}
}
}

复制代码

package com.engine.test.testdemo.service;
import java.sql.SQLException;
import java.util.Map;
public interface TestBankService {
String getTestBankList(Map<String, Object> stringObjectMap) throws SQLException;
String getTestBank(Map<String, Object> stringObjectMap) throws SQLException;
String submitTest(Map<String, Object> stringObjectMap) throws SQLException;
String deleteTest(Map<String, Object> stringObjectMap) throws SQLException;
}

复制代码

package com.engine.test.testdemo.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.engine.test.testdemo.entity.TestBank;
import com.engine.test.testdemo.service.TestBankService;
import com.weaverboot.frame.ioc.anno.classAnno.WeaIocService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import weaver.general.StaticObj;
import weaver.general.StringUtil;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.*;
@Slf4j
@WeaIocService
public class TestBankServiceImpl extends com.engine.core.impl.Service implements TestBankService {
@Override
public String getTestBankList(Map<String, Object> stringObjectMap) throws SQLException {
Map<String, Object> resultMap = new HashMap<>();
java.sql.Connection conn = null;
PreparedStatement s = null;
ResultSet rs = null;
PreparedStatement countStmt = null;
ResultSet countRs = null;
try {
int pageSize = Integer.parseInt(String.valueOf(stringObjectMap.get("pageSize")));
int page =Integer.parseInt(String.valueOf( stringObjectMap.get("page")));
int offset = (page - 1) * pageSize;
String title = String.valueOf(stringObjectMap.get("title"));
weaver.interfaces.datasource.DataSource ds = (weaver.interfaces.datasource.DataSource) StaticObj.getServiceByFullname(("datasource.test"), weaver.interfaces.datasource.DataSource.class);
conn = ds.getConnection();
String sql = "select * FROM el_repo LIMIT ? OFFSET ?";
if (!StringUtil.isEmpty(title)){
sql = "select * FROM el_repo where title like ? LIMIT ? OFFSET ?";
}
s = conn.prepareStatement(sql);
s.setInt(1, pageSize);
s.setInt(2, offset);
if (!StringUtil.isEmpty(title)){
s.setString(1,"%"+title+"%");
s.setInt(2, pageSize);
s.setInt(3, offset);
}
rs = s.executeQuery();
List<TestBank> testBankList = new ArrayList<>();
while (rs.next()) {
TestBank testBank = new TestBank();
testBank.setId(rs.getInt("id"));
testBank.setCode(rs.getString("code"));
testBank.setTitle(rs.getString("title"));
testBank.setRemark(rs.getString("remark"));
testBank.setUpdateTime(rs.getDate("update_time"));
testBank.setCreateTime(rs.getDate("create_time"));
testBankList.add(testBank);
}
resultMap.put("data", testBankList);
// 获取总数
String countSql = "SELECT COUNT(*) FROM el_repo where title like ?";
if (StringUtil.isEmpty(title)){
countSql = "SELECT COUNT(*) FROM el_repo";
}
countStmt = conn.prepareStatement(countSql);
if (!StringUtil.isEmpty(title)){
countStmt.setString(1,"%"+title+"%");
}
countRs = countStmt.executeQuery();
if (countRs.next()) {
int totalCount = countRs.getInt(1);
resultMap.put("total", totalCount);
}
resultMap.put("code", "1");
resultMap.put("message", "查询成功！");
return JSONObject.toJSONString(resultMap);
} catch (Exception e) {
e.printStackTrace();
resultMap.put("code", "0");
resultMap.put("message", "查询失败！");
return JSONObject.toJSONString(resultMap);
}finally {
if (conn!=null){
conn.close();
}
if (s!= null){
s.close();
}
if (rs!=null){
rs.close();
}
if (countStmt!=null){
countStmt.close();
}
if (countRs!=null){
countRs.close();
}
}
}
@Override
public String getTestBank(Map<String, Object> stringObjectMap) throws SQLException {
Map<String, Object> resultMap = new HashMap<>();
java.sql.Connection conn = null;
PreparedStatement s = null;
ResultSet rs = null;
PreparedStatement countStmt = null;
ResultSet countRs = null;
try {
int pageSize = Integer.parseInt(String.valueOf(stringObjectMap.get("pageSize")));
int currentPage =Integer.parseInt(String.valueOf( stringObjectMap.get("page")));
int offset = (currentPage - 1) * pageSize;
String id = stringObjectMap.get("id").toString();
weaver.interfaces.datasource.DataSource ds = (weaver.interfaces.datasource.DataSource) StaticObj.getServiceByFullname(("datasource.test"), weaver.interfaces.datasource.DataSource.class);
conn = ds.getConnection();
s = conn.prepareStatement("select * FROM el_repo where id = ? LIMIT ? OFFSET ?");
s.setString(1,id);
s.setInt(2, pageSize);
s.setInt(3, offset);
rs = s.executeQuery();
List<TestBank> testBankList = new ArrayList<>();
while (rs.next()) {
TestBank testBank = new TestBank();
testBank.setId(rs.getInt("id"));
testBank.setCode(rs.getString("code"));
testBank.setTitle(rs.getString("title"));
testBank.setRemark(rs.getString("remark"));
testBank.setUpdateTime(rs.getDate("update_time"));
testBank.setCreateTime(rs.getDate("create_time"));
testBankList.add(testBank);
}
resultMap.put("data", testBankList);
// 获取总数
String countSql = "SELECT COUNT(*) FROM el_repo where title = ?";
countStmt = conn.prepareStatement(countSql);
countStmt.setString(1,id);
countRs = countStmt.executeQuery();
if (countRs.next()) {
int totalCount = countRs.getInt(1);
resultMap.put("total", totalCount);
}
resultMap.put("code", "1");
resultMap.put("message", "查询成功！");
return JSONObject.toJSONString(resultMap);
} catch (
Exception e) {
e.printStackTrace();
resultMap.put("code", "0");
resultMap.put("message", "查询失败！");
return JSONObject.toJSONString(resultMap);
}finally {
if (conn!=null){
conn.close();
}
if (s!= null){
s.close();
}
if (rs!=null){
rs.close();
}
if (countStmt!=null){
countStmt.close();
}
if (countRs!=null){
countRs.close();
}
}
}
@Override
public String submitTest(Map<String, Object> stringObjectMap) throws SQLException {
weaver.interfaces.datasource.DataSource ds = (weaver.interfaces.datasource.DataSource) StaticObj.getServiceByFullname(("datasource.test"), weaver.interfaces.datasource.DataSource.class);
java.sql.Connection conn = ds.getConnection();
conn.setAutoCommit(false);
PreparedStatement s = null;
try {
String id = "";
if (!ObjectUtils.isEmpty(stringObjectMap.get("id"))){
id = String.valueOf(stringObjectMap.get("id"));
}
String sql = "INSERT INTO el_repo (code, title, remark, create_time, update_time) VALUES (?, ?, ?, ?, ?)";
if (!StringUtil.isEmpty(id)){
sql = "update el_repo set code =?,title = ?, remark = ?,update_time = ? WHERE id = ?";
}
s = conn.prepareStatement(sql);
// 设置参数
if (!StringUtil.isEmpty(id)){
s.setString(1, (String) stringObjectMap.get("code"));
s.setString(2, (String) stringObjectMap.get("title"));
s.setString(3, (String) stringObjectMap.get("remark"));
s.setObject(4, new Date()); // 设置当前时间为更新时间
s.setString(5,id);
}else {
s.setString(1, (String) stringObjectMap.get("code"));
s.setString(2, (String) stringObjectMap.get("title"));
s.setString(3, (String) stringObjectMap.get("remark"));
s.setObject(4, new Date()); // 设置当前时间为创建时间
s.setObject(5, new Date()); // 设置当前时间为更新时间
}
int rowsAffected = s.executeUpdate();
if (rowsAffected > 0) {
conn.commit();
Map<String, Object> resultMap = new HashMap<>();
resultMap.put("code", "1");
resultMap.put("message", "测试保存成功");
return JSONObject.toJSONString(resultMap);
} else {
conn.commit();
Map<String, Object> resultMap = new HashMap<>();
resultMap.put("code", "0");
resultMap.put("message", "测试保存失败");
return JSONObject.toJSONString(resultMap);
}
} catch (Exception e) {
conn.rollback();
log.error("测试保存失败", e);
Map<String, Object> resultMap = new HashMap<>();
resultMap.put("code", "0");
resultMap.put("message", "测试保存失败: " + e.getMessage());
return JSONObject.toJSONString(resultMap);
} finally {
if (s != null) {
s.close();
}
if (conn != null) {
conn.setAutoCommit(true);
conn.close();
}
}
}
@Override
public String deleteTest(Map<String, Object> stringObjectMap) throws SQLException {
weaver.interfaces.datasource.DataSource ds = (weaver.interfaces.datasource.DataSource) StaticObj.getServiceByFullname(("datasource.test"), weaver.interfaces.datasource.DataSource.class);
java.sql.Connection conn = ds.getConnection();
conn.setAutoCommit(false);
PreparedStatement s = null;
Map<String, Object> resultMap = new HashMap<>();
try {
String getTestSql = "select COUNT(*) from el_qu_repo where repo_id = ? ";
PreparedStatement stat = conn.prepareStatement(getTestSql);
stat.setString(1,(String) stringObjectMap.get("id"));
ResultSet resultSet = stat.executeQuery();
int total = 0;
if (resultSet.next()){
total = resultSet.getInt(1);
}
if (total>0){
resultMap.put("code", "0");
resultMap.put("message", "测试删除失败!当前测试下还存在某些信息！");
return JSONObject.toJSONString(resultMap);
}
String sql = "DELETE FROM el_repo WHERE id = ?";
s = conn.prepareStatement(sql);
// 设置参数
s.setString(1, (String) stringObjectMap.get("id"));
int rowsAffected = s.executeUpdate();
if (rowsAffected > 0) {
conn.commit();
resultMap.put("code", "1");
resultMap.put("message", "测试删除成功");
return JSONObject.toJSONString(resultMap);
} else {
conn.commit();
resultMap = new HashMap<>();
resultMap.put("code", "0");
resultMap.put("message", "测试删除失败");
return JSONObject.toJSONString(resultMap);
}
} catch (Exception e) {
conn.rollback();
log.error("测试删除失败", e);
resultMap = new HashMap<>();
resultMap.put("code", "0");
resultMap.put("message", "测试删除失败: " + e.getMessage());
return JSONObject.toJSONString(resultMap);
} finally {
if (s != null) {
s.close();
}
if (conn != null) {
conn.setAutoCommit(true);
conn.close();
}
}
}
}

复制代码

package com.engine.test.testdemo.entity;
import lombok.Data;
import java.util.Date;
@Data
public class TestBank {
private static final long serialVersionUID = 1L;
private Integer id;
private String code;
private String title;
private String remark;
private Date createTime;
private Date updateTime;
}

复制代码

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

复制代码