String sql1="INSERT INTO [wryk].[dbo].[DMSUPPLIER]" +
"(consignor_code,consignor_suppliercode,areaCode,Contact,express_money,fax_code,Mobile," +
"opcode,partnerType,postal_code,prefecture,refentseqno,remark,route," +
"supplier_address,supplier_code,supplier_name,supplier_short,Telephone)" +
"values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
DBHelper db=new DBHelper();
Connection conn=db.getConnection();
PreparedStatement ps=conn.prepareStatement(sql1);
final int batchSize=1000;
int count=0;
for(SupplierVO supps : suppVOs){
String suppPK=supps.getPk_supplier();
//货主代码(这里是默认值158 ,不为空
ps.setString(1,hzdm);
//货主对应的供应商编码
ps.setString(2,null);
//区县代码
String pk_areacl=supps.getPk_areacl();
String areacl="100000";
if(pk_areacl!=null&&pk_areacl.length()>0)
areacl=(String) bo.findColValue("bd_areacl", "code", "pk_areacl='"+pk_areacl+"'");
ps.setString(3,areacl);
//联系人
String pk_linkman=(String) bo.findColValue("bd_suplinkman", "pk_linkman", "pk_supplier='"+suppPK+"'");
String contact=null;
if(pk_linkman!=null&&!pk_linkman.equals(""))
contact=(String) bo.findColValue("bd_linkman", "name", "pk_linkman='"+pk_linkman+"'");
ps.setString(4,contact);
//订单加急费用
ps.setString(5,null);
//传真
ps.setString(6,supps.getFax1());
//移动电话
ps.setString(7,supps.getTel1());
//拼音码
ps.setString(8,supps.getMnecode());
//往来单位类型
ps.setString(9,"");
//邮编
ps.setString(10,supps.getAttributeValue("vpostcode_148")==null?"100000":String.valueOf(supps.getAttributeValue("vpostcode_148")));
//所属地
ps.setString(11,"");
//供应商对应的电子监管网入网序列号
ps.setString(12,"");
//备注
ps.setString(13,supps.getMemo());
//s送货线路
ps.setString(14,"");
//供应商地址
ps.setString(15,supps.getCorpaddress());
//供货方代码
ps.setString(16,supps.getCode());
//供货方名称
ps.setString(17,supps.getName());
//供货方简称
ps.setString(18,supps.getShortname());
//联系电话
ps.setString(19,supps.getTel1());
// //货主代码
// ps.setString(19,hzdm);
// if(++count % batchSize == 0){
// ps.executeBatch();
// }
int i=db.executeUpdate(sql1);
if(i<=0)
ExceptionUtils.wrappException(new BusinessException("本次数据插入有误,执行回滚"));
}
