package com.ld.igds.drug.service;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.stereotype.Repository;
|
|
import com.bstek.bdf2.core.orm.jdbc.JdbcDao;
|
import com.bstek.dorado.data.provider.Page;
|
import com.ld.igds.models.Drug;
|
import com.ld.igds.models.DrugApply;
|
import com.ld.igds.models.DrugInout;
|
import com.ld.igds.models.DrugLog;
|
import com.ld.igds.util.ContextUtil;
|
|
/**
|
* 后期调整为Hibernate
|
* @author Andy
|
*
|
*/
|
@Repository
|
public class HDrugService extends JdbcDao {
|
|
public void pageDrug(Page<Drug> page, Map<String, Object> param)
|
throws Exception {
|
|
List<Object> args = new ArrayList<Object>();
|
|
args.add(ContextUtil.getCompanyId());
|
|
String sql = "select * from D_DRUG where company_id_ =? ";
|
|
if (null != param) {
|
String str = (String) param.get("name");
|
if (StringUtils.isNotEmpty(str)) {
|
sql += " and name_ like ?";
|
args.add("%" + str + "%");
|
}
|
}
|
sql += " order by name_ ";
|
|
this.pagingQuery(page, sql, args.toArray(), new DrugRowMapper());
|
}
|
|
public List<Drug> listDrug(String name) {
|
|
String sql = "select * from D_DRUG where company_id_ =? ";
|
|
List<Object> args = new ArrayList<Object>();
|
|
args.add(ContextUtil.getCompanyId());
|
|
if (StringUtils.isNotEmpty(name)) {
|
sql += " and name_ like ?";
|
args.add("%" + name + "%");
|
}
|
|
sql += " order by name_ ";
|
|
return this.getJdbcTemplate().query(sql, args.toArray(),
|
new DrugRowMapper());
|
}
|
|
public String delDrug(Drug data) {
|
|
if (null == data.getId()) {
|
return null;
|
}
|
|
String sql = " delete from D_DRUG where ID_ =?";
|
|
this.getJdbcTemplate().update(sql, new Object[] { data.getId() });
|
|
return null;
|
}
|
|
public String updateDrug(Drug data) {
|
data.setUpdateTime(new Date());
|
data.setUpdateUser(ContextUtil.getLoginUserCName());
|
if (null == data.getId()) {
|
return this.addDrug(data);
|
}
|
|
String sql = " update D_DRUG set name_=?," + "spec_=?," + "dosage_=?,"
|
+ "count_=?," + "update_User_=?," + "update_Time_=?,"
|
+ "remarks_=? where id_=?";
|
|
this.getJdbcTemplate().update(
|
sql,
|
new Object[] { data.getName(), data.getSpec(),
|
data.getDosage(), data.getCount(),
|
data.getUpdateUser(), data.getUpdateTime(),
|
data.getRemarks(), data.getId() });
|
|
return null;
|
}
|
|
private String addDrug(Drug data) {
|
data.setId(ContextUtil.getUUID());
|
data.setCompanyId(ContextUtil.getCompanyId());
|
|
String sql = " insert into D_DRUG(id_,company_ID_,name_,spec_,dosage_,count_,update_User_,update_Time_,remarks_) "
|
+ " values(?,?,?,?,?,?,?,?,?)";
|
|
this.getJdbcTemplate().update(
|
sql,
|
new Object[] { data.getId(), data.getCompanyId(),
|
data.getName(), data.getSpec(), data.getDosage(),
|
data.getCount(), data.getUpdateUser(),
|
data.getUpdateTime(), data.getRemarks() });
|
|
return null;
|
}
|
|
public void pageDrugInout(Page<DrugInout> page, Map<String, Object> param) {
|
List<Object> args = new ArrayList<Object>();
|
|
args.add(ContextUtil.getCompanyId());
|
|
String sql = "select * from D_DRUG_INOUT where company_id_ =? ";
|
|
if (null != param) {
|
String str = (String) param.get("name");
|
|
if (StringUtils.isNotEmpty(str)) {
|
sql += " and person_ like ?";
|
args.add("%" + str + "%");
|
}
|
|
str = (String) param.get("type");
|
if (StringUtils.isNotEmpty(str)) {
|
sql += " and type_ = ?";
|
args.add(str);
|
}
|
}
|
|
sql += " order by update_time_ desc ";
|
|
this.pagingQuery(page, sql, args.toArray(), new DrugInoutRowMapper());
|
}
|
|
public String delDrugInout(DrugInout data) {
|
|
if (null == data.getId()) {
|
return null;
|
}
|
|
String sql = " delete from D_DRUG_INOUT where ID_ =?";
|
|
this.getJdbcTemplate().update(sql, new Object[] { data.getId() });
|
|
return null;
|
}
|
|
public String updateDrugInout(DrugInout data) {
|
data.setUpdateTime(new Date());
|
data.setUpdateUser(ContextUtil.getLoginUserCName());
|
if (null == data.getId()) {
|
return this.addDrugInout(data);
|
}
|
|
String sql = " update D_DRUG_INOUT set DRUG_ID_=?," + "TIME_=?,"
|
+ "PERSON_=?," + "REASON_=?," + "COUNT_=?," + "TYPE_=?,"
|
+ "UPDATE_USER_=?,UPDATE_TIME_=?,REMARKS_=? where id_=?";
|
|
this.getJdbcTemplate()
|
.update(sql,
|
new Object[] { data.getDrugId(), data.getTime(),
|
data.getPerson(), data.getReason(),
|
data.getCount(), data.getType(),
|
data.getUpdateUser(), data.getUpdateTime(),
|
data.getRemarks(), data.getId() });
|
|
return null;
|
}
|
|
private String addDrugInout(DrugInout data) {
|
data.setId(ContextUtil.getUUID());
|
data.setCompanyId(ContextUtil.getCompanyId());
|
|
String sql = "insert into D_DRUG_INOUT(ID_,COMPANY_ID_,DRUG_ID_,TIME_,PERSON_,REASON_,COUNT_,TYPE_,UPDATE_USER_,UPDATE_TIME_,REMARKS_)"
|
+ " values(?,?,?,?,?,?,?,?,?,?,?)";
|
|
this.getJdbcTemplate().update(
|
sql,
|
new Object[] { data.getId(), data.getCompanyId(),
|
data.getDrugId(), data.getTime(), data.getPerson(),
|
data.getReason(), data.getCount(), data.getType(),
|
data.getUpdateUser(), data.getUpdateTime(),
|
data.getRemarks() });
|
return null;
|
}
|
|
public String delDrugLog(DrugLog data) {
|
if (null == data.getId()) {
|
return null;
|
}
|
|
String sql = " delete from D_DRUG_LOG where ID_ =?";
|
|
this.getJdbcTemplate().update(sql, new Object[] { data.getId() });
|
|
return null;
|
}
|
|
public String updateDrugLog(DrugLog data) {
|
data.setUpdateTime(new Date());
|
data.setUpdateUser(ContextUtil.getLoginUserCName());
|
if (null == data.getId()) {
|
return this.addDrugLog(data);
|
}
|
|
String sql = " update D_DRUG_LOG set DEPOT_ID_=?,"
|
+ "START_=?,"
|
+ "END_=?,"
|
+ "USER_=?,"
|
+ "UPDATE_USER_=?,UPDATE_TIME_=?,REMARKS_=?,DOSE_=? where ID_=?";
|
|
this.getJdbcTemplate().update(
|
sql,
|
new Object[] { data.getDepotId(), data.getStart(),
|
data.getEnd(), data.getUser(), data.getUpdateUser(),
|
data.getUpdateTime(), data.getRemarks(),
|
data.getDose(), data.getId() });
|
|
return null;
|
}
|
|
private String addDrugLog(DrugLog data) {
|
data.setId(ContextUtil.getUUID());
|
data.setCompanyId(ContextUtil.getCompanyId());
|
|
String sql = "insert into D_DRUG_LOG(ID_,COMPANY_ID_,DEPOT_ID_,START_,END_,USER_,UPDATE_USER_,UPDATE_TIME_,REMARKS_,DOSE_)"
|
+ " values(?,?,?,?,?,?,?,?,?,?)";
|
|
this.getJdbcTemplate()
|
.update(sql,
|
new Object[] { data.getId(), data.getCompanyId(),
|
data.getDepotId(), data.getStart(),
|
data.getEnd(), data.getUser(),
|
data.getUpdateUser(), data.getUpdateTime(),
|
data.getRemarks(), data.getDose() });
|
return null;
|
}
|
|
|
public void pageDrugLog(Page<DrugLog> page, Map<String, Object> param) {
|
List<Object> args = new ArrayList<Object>();
|
|
args.add(ContextUtil.getCompanyId());
|
|
String sql = "select * from D_DRUG_LOG where company_id_ =? ";
|
|
if (null != param) {
|
String str = (String) param.get("name");
|
if (StringUtils.isNotEmpty(str)) {
|
sql += " and user_ = ?";
|
args.add(str);
|
}
|
}
|
sql += " order by start_ desc ";
|
|
this.pagingQuery(page, sql, args.toArray(), new DrugLogRowMapper());
|
|
}
|
|
public String auditDrugApply(DrugApply data) {
|
|
if (null == data.getAuditUser()) {
|
data.setAuditUser(ContextUtil.getLoginUserCName());
|
}
|
if (null == data.getAuditTime()) {
|
data.setApplyTime(new Date());
|
}
|
|
if (data.getApplyUser().equals(data.getAuditUser())) {
|
return "系统：审核人和申请人不可为同一个人。";
|
}
|
|
return updateDrugApply(data);
|
|
}
|
|
public String updateDrugApply(DrugApply data) {
|
|
if (null == data.getApplyTime()) {
|
data.setAuditTime(new Date());
|
}
|
if (null == data.getApplyUser()) {
|
data.setApplyUser(ContextUtil.getLoginUserCName());
|
}
|
|
if (null == data.getId()) {
|
return this.addDrugApply(data);
|
}
|
|
String sql = " update D_DRUG_APPLY set " + "APPLY_TIME_=?,"
|
+ "APPLY_USER_=?," + "APPLY_REASON_=?," + "DRUG_NAME_=?,"
|
+ "COUNT_=?," + "AUDIT_TIME_=?," + "AUDIT_USER_=?,"
|
+ "AUDIT_REASON_=?," + "STATUS_=?," + "REMARKS_=? "
|
+ "where ID_=?";
|
|
this.getJdbcTemplate().update(
|
sql,
|
new Object[] { data.getApplyTime(), data.getApplyUser(),
|
data.getApplyReason(), data.getDrugName(),
|
data.getCount(), data.getAuditTime(),
|
data.getAuditUser(), data.getAuditReason(),
|
data.getStatus(), data.getRemarks(), data.getId() });
|
|
return null;
|
}
|
|
private String addDrugApply(DrugApply data) {
|
data.setId(ContextUtil.getUUID());
|
data.setCompanyId(ContextUtil.getCompanyId());
|
data.setStatus(DrugApply.STATUS_APPLY);
|
|
String sql = "INSERT INTO D_DRUG_APPLY(ID_,COMPANY_ID_,APPLY_TIME_,APPLY_USER_,APPLY_REASON_,DRUG_NAME_,COUNT_,AUDIT_TIME_,AUDIT_USER_,AUDIT_REASON_,"
|
+ "STATUS_,REMARKS_) values(?,?,?,?,?,?,?,?,?,?,?,?)";
|
|
this.getJdbcTemplate().update(
|
sql,
|
new Object[] { data.getId(), data.getCompanyId(),
|
data.getApplyTime(), data.getApplyUser(),
|
data.getApplyReason(), data.getDrugName(),
|
data.getCount(), data.getAuditTime(),
|
data.getAuditUser(), data.getAuditReason(),
|
data.getStatus(), data.getRemarks() });
|
|
return null;
|
}
|
|
public String delDrugApply(DrugApply data) {
|
|
if (null == data.getId()) {
|
return null;
|
}
|
|
String sql = " delete from D_DRUG_APPLY where ID_ =?";
|
|
this.getJdbcTemplate().update(sql, new Object[] { data.getId() });
|
|
return null;
|
}
|
|
public void pageDrugApply(Page<DrugApply> page, Map<String, Object> param) {
|
List<Object> args = new ArrayList<Object>();
|
|
args.add(ContextUtil.getCompanyId());
|
|
String sql = "select * from D_DRUG_APPLY where company_id_ =? ";
|
|
if (null != param) {
|
String str = (String) param.get("name");
|
if (StringUtils.isNotEmpty(str)) {
|
sql += " and APPLY_USER_ like ?";
|
args.add("%" + str + "%");
|
}
|
}
|
sql += " order by APPLY_TIME_ desc ";
|
|
this.pagingQuery(page, sql, args.toArray(), new DrugApplyRowMapper());
|
}
|
|
}
|
