package com.changhong.autoform.mapper.data.impl;
|
|
|
import com.changhong.autoform.core.mapper.BaseMapper;
|
import com.changhong.autoform.entity.FormData;
|
import com.changhong.autoform.entity.SelectForm;
|
import com.changhong.autoform.entity.SubForm;
|
import com.changhong.autoform.entity.page.PageResult;
|
import com.changhong.autoform.entity.sql.Where;
|
import com.changhong.autoform.entity.sql.Where.Conditions;
|
import com.changhong.autoform.entity.sql.Where.JoinType;
|
import com.changhong.autoform.entity.sql.Where.Type;
|
import com.changhong.autoform.entity.sql.delete.Delete;
|
import com.changhong.autoform.entity.sql.insert.Insert;
|
import com.changhong.autoform.entity.sql.select.Select;
|
import com.changhong.autoform.entity.sql.select.SelectPage;
|
import com.changhong.autoform.entity.sql.update.Update;
|
import com.changhong.autoform.mapper.data.DataMapper;
|
import com.iemsoft.framework.cloud.core.tools.JSONTool;
|
import org.springframework.stereotype.Component;
|
import org.springframework.ui.ModelMap;
|
|
import java.util.*;
|
/**
|
*
|
* @author WangYT
|
*
|
*/
|
@Component("simpleDataMapper")
|
public class DataMapperImpl extends BaseMapper implements DataMapper{
|
|
public static final String COUNT_KEY = "COUNT(0)";
|
// public static final String TABLR_BILL_DATA = "epc_bill_data";
|
// public static final String EXPEND_SUB = "journey";
|
// public static final String[] TABLR_BILL_DATA_FIELD = {"bill_info"};
|
|
@Override
|
public int insertData(FormData formData) {
|
System.err.println(JSONTool.toJson(formData));
|
Insert insert = new Insert(formData.getFormName()
|
,new ModelMap("tenantID", formData.getTenantID())
|
.addAttribute("deleteFlg",0)
|
.addAttribute("PARENTDATAROWNUM", 0)
|
.addAttribute("CREATEUSER", formData.getUserName())
|
.addAllAttributes(formData.getData()));
|
//添加主表
|
int count = execute(insert);
|
//获取最后插入的id
|
Integer lastInsertId = insert.getId();
|
//添加从表
|
List<SubForm> subFormList = formData.getSubFormList();
|
if(null != subFormList && !subFormList.isEmpty()){
|
for (SubForm subForm : subFormList) {
|
List<Map<String,Object>> list = subForm.getData();
|
System.out.println("记录错误位置---61");
|
if(null !=list && !list.isEmpty()){
|
for (Map<String, Object> map : list) {
|
count+=execute(new Insert(subForm.getFormName()
|
,new ModelMap("deleteFlg",0)
|
.addAttribute("tenantID", formData.getTenantID())
|
.addAttribute("PARENTDATAROWNUM", lastInsertId)
|
.addAllAttributes(map)));
|
|
}
|
}
|
}
|
}
|
if(count >0)
|
return lastInsertId;
|
else return -1;
|
}
|
|
|
//删除（修改deleteflg状态为1）
|
@Override
|
public int deleteDate(FormData formData) {
|
List<String> dataIds = formData.getDataIds();
|
int count = 0;
|
count = execute(new Update(formData.getFormName()
|
, new ModelMap("deleteflg", "1")
|
, new Where( new Conditions("tenantID", Type.EQ, formData.getTenantID())
|
, new Conditions("dataRowNum", Type.IN, JoinType.AND, dataIds))));
|
List<SubForm> subFormList = formData.getSubFormList();
|
for (SubForm subForm : subFormList) {
|
count+=execute(new Update(subForm.getFormName()
|
, new ModelMap("deleteflg", "1")
|
, new Where(
|
new Conditions("PARENTDATAROWNUM", Type.IN, dataIds))));
|
}
|
return count;
|
}
|
|
//修改
|
@Override
|
public int updateDate(FormData formData) {
|
System.out.println("修改传入表单数据:"+JSONTool.toJson(formData));
|
//更新主表
|
int count = execute( new Update(formData.getFormName()
|
, formData.getData()
|
, new Where(new Conditions("dataRowNum", Type.EQ, formData.getDataRowNum()))));
|
//更新从表 先删再更
|
List<SubForm> subFormList = formData.getSubFormList();
|
for (SubForm subForm : subFormList) {
|
execute(new Delete(subForm.getFormName()
|
, new Where(
|
new Conditions("PARENTDATAROWNUM",Type.EQ,formData.getDataRowNum()))));
|
}
|
for (SubForm subForm : subFormList) {
|
List<Map<String,Object>> list = subForm.getData();
|
for (Map<String, Object> map : list) {
|
count++;
|
addSubForm(map, formData,subForm.getFormName());
|
}
|
}
|
return count ;
|
}
|
|
//子表单添加数据，用于重写
|
@Override
|
public int addSubForm(Map<String, Object> map,FormData formData,String formName){
|
Insert in = new Insert(formName
|
,new ModelMap("deleteFlg",0)
|
.addAttribute("tenantID", formData.getTenantID())
|
.addAttribute("PARENTDATAROWNUM",formData.getDataRowNum())
|
.addAllAttributes(map));
|
execute(in);
|
return in.getId();
|
}
|
|
//查询所有数据
|
@Override
|
public List<Map<String, Object>> selectAll(SelectForm selectForm) {
|
Map<String, Object> fields = selectForm.getFields();
|
fields.put("DATAROWNUM", "DATAROWNUM");
|
String screenCondition = selectForm.getScreenCondition();
|
Select select = null;
|
if(screenCondition!=null && !"".equals(screenCondition)){
|
select = new SelectPage(String.format(selectForm.getFormName())
|
, new Where(screenCondition,new Conditions("tenantID",Type.EQ,selectForm.getTenantID())
|
, new Conditions("deleteFlg", Type.EQ, JoinType.AND, 0)
|
)
|
, fields.keySet().toArray(new String[fields.size()])
|
, selectForm.getStartRow()
|
, selectForm.getEndRow());
|
}else{
|
select = new SelectPage(String.format(selectForm.getFormName())
|
, new Where(new Conditions("tenantID",Type.EQ,selectForm.getTenantID())
|
, new Conditions("deleteFlg", Type.EQ, JoinType.AND, 0))
|
, fields.keySet().toArray(new String[fields.size()])
|
, selectForm.getStartRow()
|
, selectForm.getEndRow());
|
}
|
select.setOrderName("DATAROWNUM");
|
return selectList(select, (index, key, rs, result)->{
|
if(key.equalsIgnoreCase("dataRowNum")){
|
result.put(Objects.toString(fields.get(key)), rs.getInt(index));
|
}else{
|
result.put(Objects.toString(fields.get(key)), rs.getString(index));
|
}
|
});
|
}
|
|
//查询分页数据
|
@Override
|
public PageResult<Map<String, Object>> selectPage(SelectForm selectForm) {//fenye
|
|
Object count;
|
// 上面为注释掉的方法
|
Map<String, Object> fields = selectForm.getFields();
|
fields.put(selectForm.getFormName()+".DATAROWNUM", "DATAROWNUM");
|
String screenCondition = selectForm.getScreenCondition();
|
Select select;
|
Where oneWhere, listWhere;
|
if(screenCondition!=null && !"".equals(screenCondition)) {
|
oneWhere = new Where(screenCondition,new Conditions(selectForm.getFormName()+".tenantID",Type.EQ,selectForm.getTenantID())
|
, new Conditions(selectForm.getFormName()+".deleteFlg", Type.EQ, JoinType.AND, 0));
|
listWhere = new Where(screenCondition,new Conditions(selectForm.getFormName()+".tenantID",Type.EQ,selectForm.getTenantID())
|
, new Conditions(selectForm.getFormName()+".deleteFlg", Type.EQ, JoinType.AND, 0));
|
}else{
|
oneWhere = new Where(new Conditions(selectForm.getFormName()+".tenantID",Type.EQ,selectForm.getTenantID())
|
, new Conditions(selectForm.getFormName()+".deleteFlg", Type.EQ, JoinType.AND, 0));
|
listWhere = new Where(new Conditions(selectForm.getFormName()+".tenantID",Type.EQ,selectForm.getTenantID())
|
, new Conditions(selectForm.getFormName()+".deleteFlg", Type.EQ, JoinType.AND, 0));
|
}
|
//查询总条数
|
count = selectOne(new Select(selectForm.getFormName()
|
, oneWhere
|
, new String[]{COUNT_KEY})).get(COUNT_KEY);
|
if(count == null || Long.parseLong(count.toString()) <= 0)
|
return new PageResult<>(new ArrayList<>(), 0L);
|
//业务数据查询实体
|
select = new SelectPage(String.format(selectForm.getFormName())
|
, listWhere
|
, fields.keySet().toArray(new String[fields.size()])
|
, selectForm.getStartRow()
|
, selectForm.getEndRow());
|
select.setOrderName(selectForm.getFormName()+".DATAROWNUM");
|
return new PageResult<>(
|
selectList(select, (index, key, rs, result)->{
|
if(key.equalsIgnoreCase("dataRowNum")){
|
result.put(Objects.toString(fields.get(key)), rs.getInt(index));
|
}else{
|
result.put(Objects.toString(fields.get(key)), rs.getString(index));
|
}
|
}), Long.parseLong(count.toString()));
|
}
|
|
//查询一条数据
|
@Override
|
public Map<String, Object> selectOne(SelectForm selectForm) {
|
//主表数据
|
Map<String, Object> fields = selectForm.getFields();
|
fields.put("DATAROWNUM", "DATAROWNUM");
|
fields.put("orderCode", "orderCode");
|
fields.put("orderStatus", "orderStatus");
|
fields.put("voucherCode", "voucherCode");
|
Set<String> fieldKey = fields.keySet();
|
Select select =new Select(String.format(selectForm.getFormName())
|
, new Where(new Conditions("deleteFlg",Type.EQ,0)
|
, new Conditions("tenantID",Type.EQ,JoinType.AND,selectForm.getTenantID())
|
, new Conditions("dataRowNum",Type.EQ,JoinType.AND,selectForm.getDataRowNum())
|
, new Conditions("PARENTDATAROWNUM",Type.EQ,JoinType.AND,0))
|
, fieldKey.toArray(new String[fieldKey.size()]));
|
Map<String, Object> formDataResult = selectOne(select,(index, key, rs, result)->{
|
if(key.equalsIgnoreCase("dataRowNum")){
|
result.put(key, rs.getInt(index));
|
}else{
|
String val = rs.getString(index);
|
if(null == val){
|
result.put(Objects.toString(fields.get(key)), "");
|
}else{
|
result.put(Objects.toString(fields.get(key)), val);
|
}
|
}
|
});
|
Map<Integer,List<Map<String,Object>>> subMap = new HashMap<>();
|
//从表数据
|
List<SubForm> subFormList = selectForm.getSubForm();
|
if(null!=subFormList&&!subFormList.isEmpty()){
|
for (SubForm subForm : subFormList) {
|
Map<String, Object> subFields = subForm.getFields();
|
subFields.put("DATAROWNUM", "DATAROWNUM");
|
Set<String> subFieldkey = subFields.keySet();
|
Select subSelect=new Select(subForm.getFormName()
|
, new Where(new Conditions("deleteFlg",Type.EQ,0)
|
, new Conditions("tenantID",Type.EQ,JoinType.AND,selectForm.getTenantID())
|
, new Conditions("PARENTDATAROWNUM",Type.EQ,JoinType.AND,subForm.getSubDataRowNum()))
|
, subFieldkey.toArray(new String[subFieldkey.size()]));
|
subMap.put(subForm.getFormDataNum(), selectList(subSelect,(index, key, rs, result)->{
|
if(key.equalsIgnoreCase("dataRowNum")){
|
result.put(key, rs.getInt(index));
|
// 注释详情带出票据信息
|
// String joury = subForm.getFormName().split("_")[subForm.getFormName().split("_").length -1];
|
//if have joury and orderCode
|
// if(EXPEND_SUB.equals(joury) && formDataResult != null
|
// && formDataResult.get("orderCode") != null && !"".equals(formDataResult.get("orderCode"))){
|
// Select billData = new Select(TABLR_BILL_DATA
|
// , new Where(new Conditions("j_id",Type.EQ,rs.getInt(index))
|
// , new Conditions("order_code",Type.EQ,JoinType.AND,formDataResult.get("orderCode")))
|
// , TABLR_BILL_DATA_FIELD);
|
// result.put("billData", selectList(billData));
|
// }
|
}else{
|
String val = rs.getString(index);
|
if(null == val){
|
result.put(Objects.toString(subFields.get(key)), "");
|
}else{
|
result.put(Objects.toString(subFields.get(key)), val);
|
}
|
}
|
}));
|
}
|
}
|
return new ModelMap("main", formDataResult).addAttribute("subs", subMap);
|
}
|
|
|
@Override
|
public String getUserName(SelectForm selectForm) {
|
Select select =new Select(String.format(selectForm.getFormName())
|
, new Where(new Conditions("deleteFlg",Type.EQ,0)
|
, new Conditions("tenantID",Type.EQ,JoinType.AND,selectForm.getTenantID())
|
, new Conditions("dataRowNum",Type.EQ,JoinType.AND,selectForm.getDataRowNum()))
|
,"CREATEUSER");
|
|
Map<String, Object> formDataResult = selectOne(select,(index, key, rs, result)->{
|
System.err.println(key);
|
System.err.println();
|
String userName = rs.getString(index);
|
if(key.equals("CREATEUSER"))
|
result.put("userName",userName);
|
});
|
return (String) formDataResult.get("userName");
|
}
|
|
}
|
