package cn.ksource.web.service.record; import java.util.List; import java.util.Map; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import cn.ksource.beans.GG_RECORD; import cn.ksource.beans.WORKFLOW_BASE; import cn.ksource.core.dao.BaseDao; import cn.ksource.core.dao.SqlParameter; import cn.ksource.core.util.DateUtil; import cn.ksource.core.util.StringUtil; @Service("recordService") public class RecordServiceImpl implements RecordService { @Autowired private BaseDao baseDao; /** * 保存处理记录 */ @Override public GG_RECORD addRecord(GG_RECORD record) { String flowId = record.getBusiness_id(); if(StringUtil.notEmpty(flowId)) { //通过流程编号,获取当前节点信息 WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById(); record.setNode_id(base.getCurrent_node_id()).setNode_name(base.getCurrent_node_name()); } record.setDeal_time(DateUtil.getCurrentDate14()); record = record.insert(); return record; } @Override public List queryRecord(String businessId) { String sql = "SELECT * FROM GG_RECORD WHERE BUSINESS_ID = :businessId ORDER BY DEAL_TIME DESC"; return baseDao.queryForList(sql,new SqlParameter("businessId",businessId)); } @Override public Map getRecordById(String recordId) { String sql = "SELECT * FROM GG_RECORD WHERE ID = :id"; return baseDao.queryForMap(sql,new SqlParameter("id",recordId)); } @Override public boolean deleteRecord(String recordId) { String deleteSql = "DELETE FROM GG_RECORD WHERE ID = :id"; baseDao.execute(deleteSql, new SqlParameter("id",recordId)); return true; } @Override public GG_RECORD insertOrUpdateRecord(GG_RECORD record) { String flowId = record.getBusiness_id(); if(StringUtil.notEmpty(flowId)) { //通过流程编号,获取当前节点信息 WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById(); record.setNode_id(base.getCurrent_node_id()).setNode_name(base.getCurrent_node_name()); } record.setDeal_time(DateUtil.getCurrentDate14()); record = record.insert(); return record; } }