package com.hb.proj.analysis.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.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.hb.proj.model.DiagramDiagnoseStandardPO; import com.hb.proj.model.DiagramDiagnoseStandardVO; import com.hb.proj.model.DiagramFeature; import com.hb.xframework.dao.core.SpringJdbcDAO; import com.hb.xframework.dao.util.PageModel; import com.hb.xframework.dao.util.UUIDHexGenerator; @Service public class DiagramDiagnoseService { @Autowired private SpringJdbcDAO dao; public PageModel query(Map args,int pageNo,int pageSize){ List sqlParams=new ArrayList(); StringBuilder sql=new StringBuilder(100); sql.append("select d.*,access_path "); sql.append(" from tzl_diagram_diagnose_standard d "); sql.append(" left join tsys_file_info f on d.file_id=f.file_id"); sql.append(" where d.del_if=false "); if(args!=null&&StringUtils.isNotBlank((String)args.get("conclusion"))) { sql.append(" and conclusion like ? "); sqlParams.add("%"+args.get("conclusion")+"%"); } sql.append(" order by create_time"); Object[] sqlArgs=sqlParams.size()>0?sqlParams.toArray():null; return dao.queryForPagedData(sql.toString(),pageNo, pageSize,DiagramDiagnoseStandardVO.class ,sqlArgs); } public String add(DiagramDiagnoseStandardPO diagnosePO) { UUIDHexGenerator uuid=UUIDHexGenerator.getInstance(); diagnosePO.setDiagnoseId(uuid.generate()); diagnosePO.setModifyTime(new Date()); diagnosePO.setDelIf(false); dao.insert(diagnosePO,"tzl_diagram_diagnose_standard"); return diagnosePO.getDiagnoseId(); } public boolean delete(String diagnoseId) { String sql="update tzl_diagram_diagnose_standard set del_if=true,modify_time=now() where diagnose_id=?"; dao.exeUpdate(sql,diagnoseId); return true; } public DiagramDiagnoseStandardVO get(String diagnoseId) { String sql=""" select d.*,f.access_path from tzl_diagram_diagnose_standard d left join tsys_file_info f on d.file_id=f.file_id and d.del_if=false where d.diagnose_id=? """; return dao.queryForPojo(sql,DiagramDiagnoseStandardVO.class,diagnoseId); } public DiagramDiagnoseStandardPO getPO(String diagnoseId) { String sql=""" select d.* from tzl_diagram_diagnose_standard d where d.diagnose_id=? """; return dao.queryForPojo(sql,DiagramDiagnoseStandardPO.class,diagnoseId); } public boolean update(DiagramDiagnoseStandardPO diagnosePO) { diagnosePO.setModifyTime(new Date()); diagnosePO.setDelIf(false); return dao.update(diagnosePO, "tzl_diagram_diagnose_standard", "diagnose_id")>0; } public String addDiagramFeature(DiagramFeature feature) { UUIDHexGenerator uuid=UUIDHexGenerator.getInstance(); feature.setFeatureId(uuid.generate()); feature.setModifyTime(new Date()); dao.insert(feature,"tzl_diagram_feature"); return feature.getFeatureId(); } public boolean updateDiagramFeature(DiagramFeature feature) { feature.setModifyTime(new Date()); return dao.update(feature, "tzl_diagram_feature", "feature_id")>0; } public DiagramFeature getDiagramFeatureByWell(String wellId) { return dao.queryForPojo("select * from tzl_diagram_feature where well_id=?", DiagramFeature.class, wellId); } }