XinYu_LZMES/.svn/pristine/71/71f1c9465fcb12f7ef4337925c698725765ed755.svn-base

package QCM.JHY01.JHY0103;

import java.sql.ResultSet;
import java.sql.Statement;
import java.util.HashMap;

import org.apache.ibatis.session.SqlSession;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;

import CoreFS.SA01.CoreIComponent;
import CoreFS.SA06.CoreReturnObject;
import QCM.COMMUNAL.VO.QcmJudgeOperateLog;

public class DeleteMaterialInfo extends CoreIComponent{
	
	CoreReturnObject cro = new CoreReturnObject();	
	SqlSession SqlSession = 
			QCM.COMMUNAL.SqlSessionBuilder.openSqlSession();
	QCM.COMMUNAL.OrderSqMapper mapper = SqlSession.getMapper(QCM.COMMUNAL.OrderSqMapper.class);
	/**
	 * 第三方认证，剔除子板功能 (目前作废已没有用当前按钮)
	 * @param materialInfo
	 * @return
	 * @throws Exception
	 */
	public CoreReturnObject delete2(String materialInfo,String materialNo,String userName) throws Exception {
		
		StringBuffer sqlucomm = new StringBuffer();
		
		String[] ja=materialInfo.split(",");
		String[] ja2=materialNo.split(",");
		
		String msInfo="";
		String inmaterialNo="";
		if (ja!=null && ja.length>0) {
			
			for (int i = 0; i < ja.length; i++) {
				String  sp = ja[i];
				String  sp2 = ja2[i];
				if ("".equals(msInfo)) {
					
					msInfo="'"+sp+"'";
					inmaterialNo="'"+sp2+"'";
				}else{
					msInfo=msInfo+"'"+sp+"'";
					inmaterialNo=inmaterialNo+"'"+sp2+"'";
				}
				
				if (i !=ja.length-1) {
					msInfo=msInfo+",";
					inmaterialNo=inmaterialNo+",";
				}
				
			}
		String sql = "insert into QCM_MAT_CERT_LOG "
					  +" (cert_no, material_no, design_key, psc, psc_desc, prod_code, prod_name, steel_code, steel_name, std_code, "
					  +"  std_name, delivery_state_code, delivery_state_desc, delivery_date, cut_type, heat_no, batch_no, inspection_lot,  "
					  +"  board_no, thick, width, length, mat_weight, pline_code, pline_name, approach, inceptcorpcode, buyercode, contract_no, " 
					  +"  create_name, create_time, vessel, send_flag_yth,LOG_NAME) "
					+" select cert_no, material_no, design_key, psc, psc_desc, prod_code, prod_name, steel_code, steel_name, std_code, "
					+"    std_name, delivery_state_code, delivery_state_desc, delivery_date, cut_type, heat_no, batch_no, inspection_lot,  "
					+"    board_no, thick, width, length, mat_weight, pline_code, pline_name, approach, inceptcorpcode, buyercode, contract_no,  "
					+"    create_name, create_time, vessel, send_flag_yth,'"+userName+"剔除子板' "
					+"    from qcm_mat_cert_d t where t.CERT_NO in ("+msInfo+") and t.MATERIAL_NO in("+inmaterialNo+")";
					 this.getDao("testDao").ExcuteNonQuery(sql.toString());
					
			sqlucomm.append("delete from QCM_MAT_CERT_D where CERT_NO in ("+msInfo+") and MATERIAL_NO in("+inmaterialNo+")");
			cro = this.getDao("testDao").ExcuteNonQuery(sqlucomm.toString());
			
		}
		
		return cro;
		
	}
	
	/**
	 * 第三方认证，撤销申报功能
	 * @param materialInfo
	 * @return
	 * @throws Exception
	 */
	public CoreReturnObject deleteMD(HashMap parmas) throws Exception {
		
		try {
			String sql = "insert into QCM_MAT_CERT_LOG "
					  +" (cert_no, material_no, design_key, psc, psc_desc, prod_code, prod_name, steel_code, steel_name, std_code, "
					  +"  std_name, delivery_state_code, delivery_state_desc, delivery_date, cut_type, heat_no, batch_no, inspection_lot,  "
					  +"  board_no, thick, width, length, mat_weight, pline_code, pline_name, approach, inceptcorpcode, buyercode, contract_no, " 
					  +"  create_name, create_time, vessel, send_flag_yth,LOG_NAME) "
					+" select cert_no, material_no, design_key, psc, psc_desc, prod_code, prod_name, steel_code, steel_name, std_code, "
					+"    std_name, delivery_state_code, delivery_state_desc, delivery_date, cut_type, heat_no, batch_no, inspection_lot,  "
					+"    board_no, thick, width, length, mat_weight, pline_code, pline_name, approach, inceptcorpcode, buyercode, contract_no,  "
					+"    create_name, create_time, vessel, send_flag_yth,'"+parmas.get("USER_NAME")+"撤销申报' "
					+"    from qcm_mat_cert_d t "
					+ " where t.CERT_NO = '"+parmas.get("CERT_NO")+"' "
					+ "  and t.MATERIAL_NO = '"+parmas.get("MATERIAL_NO")+"' "
					+ "  and t.BATCH_NO = '"+parmas.get("BATCH_NO")+"' ";
					 this.getDao("testDao").ExcuteNonQuery(sql.toString());
					
			String sqlucomm2="delete from QCM_MAT_CERT_D t where t.CERT_NO = '"+parmas.get("CERT_NO")+"' "
					+ "  and t.MATERIAL_NO = '"+parmas.get("MATERIAL_NO")+"' "
					+ "  and t.BATCH_NO = '"+parmas.get("BATCH_NO")+"' ";
			this.getDao("testDao").ExcuteNonQuery(sqlucomm2.toString());
		
		
			String CERTSql = "select count(*) COUNT_NUM from QCM_MAT_CERT_D t where t.CERT_NO = '"+parmas.get("CERT_NO")+"' ";
			ResultSet rs =this.getDao("testDao").ExceuteQueryForResultSet(CERTSql.toString());
			if(rs.next()){
				if(rs.getInt(1)<=0){
					String sqlucomm="delete from QCM_MAT_CERT_M t where t.CERT_NO = '"+parmas.get("CERT_NO")+"' ";
					this.getDao("testDao").ExcuteNonQuery(sqlucomm.toString());
				}
			}
			
			    String certInstCode = parmas.get("CERT_INST_CODE").toString();
				QcmJudgeOperateLog qjog = new QcmJudgeOperateLog();
				qjog.setOperate_name(parmas.get("USER_NAME")== null ?"":parmas.get("USER_NAME").toString());
				qjog.setBatchno(parmas.get("BATCH_NO") == null ?"":parmas.get("BATCH_NO").toString());	
				if(certInstCode.equals("IC011") || certInstCode.equals("IC012") || certInstCode.equals("IC013") || certInstCode.equals("IC014") || 
						  certInstCode.equals("IC015") || certInstCode.equals("IC016") || certInstCode.equals("IC017") || certInstCode.equals("IC018") || 
						  certInstCode.equals("IC019") || certInstCode.equals("IC020") || certInstCode.equals("IC021") || certInstCode.equals("IC022") || 
						  certInstCode.equals("IC023") || certInstCode.equals("IC024") || certInstCode.equals("IC026") ){
							
					 qjog.setOperate_type("第三方撤销");
				}else{
				     qjog.setOperate_type("船检撤销");
				}
				qjog.setParams(parmas.get("MATERIAL_NO") == null ?"":parmas.get("MATERIAL_NO").toString());
				String zb=parmas.get("BATCH_NO").toString().substring(0, 1);
				if(zb.equals("Z")){
					qjog.setProd_line("ZB1");
				}else if(zb.equals("H")){
					qjog.setProd_line("HB1");
				}
				
				mapper.insertQcmJudgeOperateLog(qjog);	 				 
				SqlSession.commit();
			rs.close();
			
			
		}catch (Exception e) {
				e.printStackTrace();
				SqlSession.rollback();
				cro.setV_errCode(-1);
				cro.setV_errMsg("撤销申报失败!子板"+parmas.get("MATERIAL_NO"));
				return cro;
				
			}finally {
				SqlSession.close();
			}
		return cro;
	}
	
	/**
	 * 第三方认证，申报确认
	 * @param materialInfo
	 * @return
	 * @throws Exception
	 */
	public CoreReturnObject updateM(String materialInfo) throws Exception {
		
		StringBuffer sqlucomm = new StringBuffer();
		
		String[] ja=materialInfo.split(",");
		
		String msInfo="";
		if (ja!=null && ja.length>0) {
			
			for (int i = 0; i < ja.length; i++) {
				String  sp = ja[i];
				if ("".equals(msInfo)) {
					
					msInfo="'"+sp+"'";
					
				}else{
					msInfo=msInfo+"'"+sp+"'";
				}
				
				if (i !=ja.length-1) {
					msInfo=msInfo+",";
				}
				
			}

			sqlucomm.append("update QCM_MAT_CERT_M set CERT_STATUS = '50' where CERT_NO in ("+msInfo+") ");
			
			cro = this.getDao("testDao").ExcuteNonQuery(sqlucomm.toString());
		}
		return cro;
	}
	
	/**
	 * 第三方见证撤销
	 * @param materialInfo
	 * @return
	 * @throws Exception
	 */
	public CoreReturnObject DoDelMatWitne(HashMap parmas) throws Exception {
		
		try {
			String sql1="delete from QCM_MAT_WITNE_D t where t.SPECIMEN_NO = '"+parmas.get("SPECIMEN_NO")+"'  ";
			this.getDao("testDao").ExcuteNonQuery(sql1.toString());
			
			String sql2="update QCM_JHY_SAMPLE_CONSIGN_D t set t.mat_witne = '' where t.specimen_no = '"+parmas.get("SPECIMEN_NO")+"'";
			this.getDao("testDao").ExcuteNonQuery(sql2.toString());
			
			
			QcmJudgeOperateLog qjog = new QcmJudgeOperateLog();
			qjog.setOperate_name(parmas.get("USER_NAME")== null ?"":parmas.get("USER_NAME").toString());
			qjog.setBatchno(parmas.get("BATCH_NO") == null ?"":parmas.get("BATCH_NO").toString());			
			qjog.setOperate_type("第三方撤销");
			qjog.setParams(parmas.get("MATERIAL_NO") == null ?"":parmas.get("MATERIAL_NO").toString());
            qjog.setProd_line(parmas.get("PLINE_CODE").toString());
            qjog.setMemo(parmas.get("SPECIMEN_NO").toString());
			mapper.insertQcmJudgeOperateLog(qjog);	 				 
			SqlSession.commit();
		}catch (Exception e) {
				e.printStackTrace();
				SqlSession.rollback();
				cro.setV_errCode(-1);
				cro.setV_errMsg("第三方见证撤销失败!");
				return cro;
			}finally {
				SqlSession.close();
			}
		return cro;
	}

}