package com.ld.igds.phone35.service.impl;
|
|
import com.bstek.bdf2.core.model.DefaultDept;
|
import com.bstek.bdf2.core.model.DefaultUser;
|
import com.bstek.bdf2.core.orm.hibernate.HibernateDao;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.inout.InoutConstant;
|
import com.ld.igds.models.*;
|
import com.ld.igds.phone35.param.Phone35InoutCommonParam;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.stereotype.Component;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 新版手机3.5，数据查询
|
* @author chen
|
*/
|
@Component
|
public class HPhoneServiceImpl extends HibernateDao {
|
|
/**
|
* 查询用户
|
* @param username
|
* @return
|
*/
|
public DefaultUser getUserByUsername(String username) {
|
String hql = " from " + DefaultUser.class.getName() + " where username =:username";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("username", username);
|
|
List<DefaultUser> list = this.query(hql, args);
|
if(list == null || list.isEmpty()){
|
return null;
|
}
|
return list.get(0);
|
}
|
|
/**
|
* 获取库区列表信息
|
* @param companyId
|
* @return
|
*/
|
public List<DefaultDept> listDept(String companyId) {
|
String hql = " from " + DefaultDept.class.getName() + " where companyId =:companyId and val =:val";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
//库区启用
|
args.put("val", Constant.YN_Y);
|
|
hql += " and parentId is not null";
|
hql += " order by id";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 获取仓库列表信息
|
* @param companyId
|
* @param deptId
|
* @return
|
*/
|
public List<Depot> listDepot(String companyId, String deptId) {
|
String hql = " from " + Depot.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(deptId)){
|
hql += " and deptId =:deptId";
|
args.put("deptId", deptId);
|
}
|
hql += " order by id";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询出入库信息，用于查询出入库记录、待值仓列表等
|
* @param param
|
* @return
|
*/
|
public List<InoutRecord> listInoutRecord(Phone35InoutCommonParam param) {
|
String hql = " from " + InoutRecord.class.getName() + " where companyId =:companyId"
|
+ " and recordStatus <>:recordStatus1 and recordStatus <>:recordStatus2";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", param.getCompanyId());
|
args.put("recordStatus1", InoutConstant.RECORD_STATUS_DEL);
|
args.put("recordStatus2", InoutConstant.RECORD_STATUS_ERROR);
|
|
if(StringUtils.isNotEmpty(param.getDeptId())){
|
hql += " and deptId =:deptId";
|
args.put("deptId", param.getDeptId());
|
}
|
if(StringUtils.isNotEmpty(param.getDeptId())){
|
hql += " and progress =:progress";
|
args.put("progress", param.getProgress());
|
}
|
if(StringUtils.isNotEmpty(param.getType())){
|
hql += " and type =:type";
|
args.put("type", param.getType());
|
}
|
if(null != param.getStartTime()){
|
hql += " and completeTime >:startTime";
|
args.put("startTime", param.getStartTime());
|
}
|
if(null != param.getEndTime()){
|
hql += " and completeTime <:endTime";
|
args.put("endTime", param.getEndTime());
|
}
|
if(StringUtils.isNotEmpty(param.getPlateNum())){
|
hql += " and plateNum =:plateNum";
|
args.put("plateNum", "%" + param.getPlateNum() + "%");
|
}
|
if(StringUtils.isNotEmpty(param.getType())){
|
hql += " and intelCard =:intelCard";
|
args.put("intelCard", param.getIntelCard());
|
}
|
hql += " order by registerTime";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 根据组织编码、库区编码、流水id查询出入库信息
|
* 用于判断当前数据是否在值仓流程
|
*
|
* @param companyId
|
* @param deptId
|
* @param id
|
* @return
|
*/
|
public InoutRecord getInoutRecord(String companyId, String deptId, String id, String intelCard) {
|
String hql = " from " + InoutRecord.class.getName() + " where" + " and recordStatus <>:recordStatus1 and recordStatus <>:recordStatus2";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
|
args.put("recordStatus1", InoutConstant.RECORD_STATUS_DEL);
|
args.put("recordStatus2", InoutConstant.RECORD_STATUS_ERROR);
|
|
if(StringUtils.isNotEmpty(companyId)){
|
hql += " and companyId =:companyId";
|
args.put("companyId", companyId);
|
}
|
if(StringUtils.isNotEmpty(deptId)){
|
hql += " and deptId =:deptId";
|
args.put("deptId", deptId);
|
}
|
if(StringUtils.isNotEmpty(id)){
|
hql += " and id =:id";
|
args.put("id", id);
|
}
|
if(StringUtils.isNotEmpty(intelCard)){
|
hql += " and intelCard =:intelCard";
|
args.put("intelCard", intelCard);
|
}
|
hql += " order by registerTime";
|
|
List<InoutRecord> list = this.query(hql, args);
|
if(null == list || list.isEmpty()){
|
return null;
|
}
|
return list.get(0);
|
}
|
|
/**
|
* 查询仓房信息数据----接口1103使用
|
* @param companyId
|
* @param deptId
|
* @return
|
*/
|
public List<Building> listBuilding(String companyId, String deptId) {
|
String hql = " from " + Building.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
if(StringUtils.isNotEmpty(deptId)){
|
hql += " and deptId =:deptId";
|
args.put("deptId", deptId);
|
}
|
|
hql += " order by id desc";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 根据仓房id获取仓房信息
|
* @param companyId
|
* @param id
|
* @return
|
*/
|
public Building getBuilding(String companyId, String id) {
|
if(StringUtils.isEmpty(id)){
|
return null;
|
}
|
String hql = " from " + Building.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
hql += " and id =:id";
|
args.put("id", id);
|
|
hql += " order by id desc";
|
|
List<Building> buildings = this.query(hql, args);
|
if(buildings == null || buildings.isEmpty()){
|
return null;
|
}
|
return buildings.get(0);
|
}
|
|
/**
|
* 查询文件信息数据----接口1112使用
|
* @param companyId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<FileInfo> listFiles(String companyId, Date startTime, Date endTime) {
|
String hql = " from " + FileInfo.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
if(null != startTime){
|
hql += " and createTime >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and createTime <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by createTime desc";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询质检数据----接口1201使用
|
* @param companyId
|
* @param depotId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<MQuality> listQuality(String companyId, String depotId, Date startTime, Date endTime) {
|
String hql = " from " + MQuality.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
if(null != startTime){
|
hql += " and time >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and time <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by time desc";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 询质检明细数据----接口1202使用
|
* @param checkId
|
* @return
|
*/
|
public List<CheckItem> listQualityDetail(String checkId) {
|
|
String hql = " from " + CheckItem.class.getName() + " where checkId =:checkId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("checkId", checkId);
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询倒仓信息数据----接口1309使用
|
* @param companyId
|
* @param depotId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<MStockChange> listStockChange(String companyId, String depotId, Date startTime, Date endTime) {
|
String hql = " from " + MStockChange.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
if(null != startTime){
|
hql += " and updateTime >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and updateTime <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by updateTime desc";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询损溢单数据----接口1311使用
|
* @param companyId
|
* @param depotId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<MLossOver> listLossOver(String companyId, String depotId, Date startTime, Date endTime) {
|
String hql = " from " + MLossOver.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
if(null != startTime){
|
hql += " and submitTime >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and submitTime <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by submitTime";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询粮食性质变更信息----接口1312使用
|
* @param companyId
|
* @param depotId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<InoutVarietyChange> listFoodVarietyChange(String companyId, String depotId, Date startTime, Date endTime) {
|
String hql = " from " + InoutVarietyChange.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
if(null != startTime){
|
hql += " and changeTime >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and changeTime <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by changeTime";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询温湿度信息----接口1401使用
|
* @param companyId
|
* @param depotId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<Grain> listGrain(String companyId, String depotId, Date startTime, Date endTime) {
|
String hql = " from " + Grain.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
if(null != startTime){
|
hql += " and receiveDate >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and receiveDate <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by receiveDate";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询粮情配置信息----接口1402使用
|
* @param companyId
|
* @param depotId
|
* @return
|
*/
|
public List<DepotConf> listDepotConf(String companyId, String depotId) {
|
String hql = " from " + DepotConf.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
hql += " order by depotId";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询通风信息----接口1403使用
|
* @param companyId
|
* @param depotId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<MAreationData> listAreationData(String companyId, String depotId, Date startTime, Date endTime) {
|
String hql = " from " + MAreationData.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
if(null != startTime){
|
hql += " and updateTime >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and updateTime <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by updateTime";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询熏蒸信息----接口1404使用
|
* @param companyId
|
* @param depotId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<DrugLog> listDrugLog(String companyId, String depotId, Date startTime, Date endTime) {
|
String hql = " from " + DrugLog.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
if(null != startTime){
|
hql += " and updateTime >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and updateTime <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by updateTime";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询虫害信息----接口1405使用
|
* @param companyId
|
* @param depotId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<Pest> listPest(String companyId, String depotId, Date startTime, Date endTime) {
|
String hql = " from " + Pest.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
if(null != startTime){
|
hql += " and receiveDate >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and receiveDate <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by receiveDate";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询虫害信息----接口1408使用
|
* @param companyId
|
* @param depotId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<Gas> listGas(String companyId, String depotId, Date startTime, Date endTime) {
|
String hql = " from " + Gas.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(depotId)){
|
hql += " and depotId =:depotId";
|
args.put("depotId", depotId);
|
}
|
|
if(null != startTime){
|
hql += " and receiveDate >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and receiveDate <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by receiveDate";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询轮换计划信息----接口1501使用
|
* @param companyId
|
* @param type
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<InoutPlan> listPlan(String companyId, String type, Date startTime, Date endTime) {
|
String hql = " from " + InoutPlan.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(StringUtils.isNotEmpty(type)){
|
hql += " and type =:type";
|
args.put("type", type);
|
}
|
|
if(null != startTime){
|
hql += " and createTime >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and createTime <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by createTime";
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询轮换明细计划信息----接口1502使用
|
* @param planId
|
* @return
|
*/
|
public List<InoutPlanDetail> getPlanDetail(String planId) {
|
|
String hql = " from " + InoutPlanDetail.class.getName() + " where planId =:planId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("planId", planId);
|
|
return this.query(hql, args);
|
}
|
|
/**
|
* 查询合同信息----接口1503使用
|
* @param companyId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<InoutContract> listContract(String companyId, Date startTime, Date endTime){
|
String hql = " from " + InoutContract.class.getName() + " where companyId =:companyId";
|
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("companyId", companyId);
|
|
if(null != startTime){
|
hql += " and createTime >:startTime";
|
args.put("startTime", startTime);
|
}
|
if(null != endTime){
|
hql += " and createTime <:endTime";
|
args.put("endTime", endTime);
|
}
|
|
hql += " order by createTime";
|
|
return this.query(hql, args);
|
}
|
}
|
