zl-opd-server/src/main/java/com/hb/proj/analysis/service/DiagramDiagnoseService.java

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<DiagramDiagnoseStandardVO> query(Map<String,Object> args,int pageNo,int pageSize){
		
		List<Object> sqlParams=new ArrayList<Object>();
		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);
	}
	
}