|
|
@@ -754,3 +754,267 @@ func (s *TmpzcgtSession) UpdateOldCardNo() error {
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
+// 导入单个公司
|
|
|
+func (s *TmpzcgtSession) InsertOneSupplier(supplierName string) error {
|
|
|
+ sql := `INSERT INTO OilSupplier (
|
|
|
+ SupplierName,
|
|
|
+ Grade,
|
|
|
+ OperType,
|
|
|
+ Country,
|
|
|
+ MaunAgent,
|
|
|
+ ConstructTeam,
|
|
|
+ CommercialNo,
|
|
|
+ OrganCode,
|
|
|
+ CountryTaxNo,
|
|
|
+ LocalTaxNo,
|
|
|
+ Address,
|
|
|
+ ZipCode,
|
|
|
+ QualitySystemCert,
|
|
|
+ ProductQualityCert,
|
|
|
+ MaunLicense,
|
|
|
+ QualifCert,
|
|
|
+ QualifCertLevel,
|
|
|
+ SafetyLicense,
|
|
|
+ TechServiceLic,
|
|
|
+ TJInNotify,
|
|
|
+ SpecIndustryCert,
|
|
|
+ LegalPerson,
|
|
|
+ CategoryCode,
|
|
|
+ CategoryName,
|
|
|
+ RegCapital,
|
|
|
+ Currency,
|
|
|
+ ContactName,
|
|
|
+ CompanyType,
|
|
|
+ DepositBank,
|
|
|
+ BankAccount,
|
|
|
+ EMail,
|
|
|
+ BankCreditRating,
|
|
|
+ Mobile,
|
|
|
+ Telphone,
|
|
|
+ Fax,
|
|
|
+ CompanyTel,
|
|
|
+ QQ,
|
|
|
+ CompanyUrl,
|
|
|
+ Remark,
|
|
|
+ CreateBy,
|
|
|
+ SetupTime,
|
|
|
+ OilCertificateNo,
|
|
|
+ BusinessScope,
|
|
|
+ OldSupplierName
|
|
|
+) SELECT
|
|
|
+ max(企业名称) AS SupplierName,
|
|
|
+ max(级别) AS Grade,
|
|
|
+ max(经营方式) AS OperType,
|
|
|
+ max(国家) AS Country,
|
|
|
+ max(所代理制造商名称) AS MaunAgent,
|
|
|
+ max(施工队伍名称) AS ConstructTeam,
|
|
|
+ TRIM(max(工商注册号)) AS CommercialNo,
|
|
|
+ max(组织机构代码) AS OrganCode,
|
|
|
+ max(税务登记证国税编号) AS CountryTaxNo,
|
|
|
+ max(税务登记证地税编号) AS LocalTaxNo,
|
|
|
+ max(单位地址) AS Address,
|
|
|
+ max(邮编) AS ZipCode,
|
|
|
+ max(质量管理体系认证情况及认证机构) AS QualitySystemCert,
|
|
|
+ max(产品质量认证情况及认证机构) AS ProductQualityCert,
|
|
|
+ max(生产制造许可证获证情况及编号) AS MaunLicense,
|
|
|
+ max(企业资质证书编号) AS QualifCert,
|
|
|
+ max(企业资质证书级别) AS QualifCertLevel,
|
|
|
+ max(安全生产许可证) AS SafetyLicense,
|
|
|
+ max(技术服务类准入许可证) AS TechServiceLic,
|
|
|
+ max(外地企业进津备案通知书) AS TJInNotify,
|
|
|
+ max(行业特殊要求的认证证书) AS SpecIndustryCert,
|
|
|
+ max(法定代表人姓名) AS LegalPerson,
|
|
|
+ max(行业类别代码) AS CategoryCode,
|
|
|
+ max(行业类别名称) AS CategoryName,
|
|
|
+ max(注册资本) AS RegCapital,
|
|
|
+ max(币种) AS Currency,
|
|
|
+ max(联系人姓名) AS ContactName,
|
|
|
+ max(公司类型) AS CompanyType,
|
|
|
+ max(开户银行) AS DepositBank,
|
|
|
+ max(银行账号) AS BankAccount,
|
|
|
+ max(电子邮箱) AS EMail,
|
|
|
+ max(银行信用等级) AS BankCreditRating,
|
|
|
+ max(移动电话) AS Mobile,
|
|
|
+ max(固定电话) AS Telphone,
|
|
|
+ max(传真) AS Fax,
|
|
|
+ max(公司电话) AS CompanyTel,
|
|
|
+ max(QQ号码) AS QQ,
|
|
|
+ max(公司网址) AS CompanyUrl,
|
|
|
+ max(备注) AS Remark,
|
|
|
+ '导入' As CreateBy,
|
|
|
+ STR_TO_DATE(IF(max(成立时间)='', NULL, max(成立时间)),IF(LENGTH(max(成立时间))>8 or locate('-',max(成立时间)) >0, '%Y-%m-%d', '%Y%m%d')) AS SetupTime,
|
|
|
+ max(中石油供应商证书号) as OilCertificateNo,
|
|
|
+ max(推荐单位的推荐意见) as BusinessScope,
|
|
|
+ max(曾用名) AS OldSupplierName
|
|
|
+FROM
|
|
|
+ T_资格预审表 WHERE `
|
|
|
+ sql += "企业名称 = '" + supplierName + "'"
|
|
|
+ sql += " GROUP BY 企业名称;" //WHERE 准入标识 != '取消'
|
|
|
+ _, err := s.DBE.Query(sql)
|
|
|
+
|
|
|
+ s.DBE.Query(" UPDATE OilSupplier a SET a.OperType='贸易商' WHERE a.OperType IN ('3', '4') AND SupplierName = '" + supplierName + "'")
|
|
|
+ s.DBE.Query(" UPDATE OilSupplier a SET a.OperType='代理商' WHERE a.OperType = '2' AND SupplierName = '" + supplierName + "'")
|
|
|
+ s.DBE.Query(" UPDATE OilSupplier a SET a.OperType='制造商' WHERE a.OperType = '1' AND SupplierName = '" + supplierName + "'")
|
|
|
+ s.DBE.Query(" UPDATE OilSupplier a SET a.Grade='1' WHERE a.Grade = '一级' AND SupplierName = '" + supplierName + "'")
|
|
|
+ s.DBE.Query(" UPDATE OilSupplier a SET a.Grade='2' WHERE a.Grade = '二级' AND SupplierName = '" + supplierName + "'")
|
|
|
+
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) InsertOneSupplierCert(supplierName string) error {
|
|
|
+ s.DBE.Query("SET unique_checks=0;")
|
|
|
+ sql := "INSERT INTO OilSupplierCert (SupplierId,OutsideFlog, `Status` , Step, WorkerTotal, AccessCardNo,SupplierTypeName,InFlag,EffectStartTime,EffectEndTime,AddinTime,EffectTime,ApplyTime,Remark,CreateBy,GfID,RecUnitName,MgrUnit,RecDate,OldCardNo) " +
|
|
|
+ "SELECT -1 As SupplierId,企业名称 AS OutsideFlog,'8' As `Status`, 3 as Step, 1 as WorkerTotal, 准入证号 As AccessCardNo,准入类别 AS SupplierTypeName,准入标识 AS InFlag, STR_TO_DATE(IF(有效期起='', NULL, 有效期起),'%Y年%m月%d日') AS EffectStartTime, STR_TO_DATE(IF(有效期止='', NULL, 有效期止),'%Y年%m月%d日') AS EffectEndTime,审核日期 as AddinTime, 有效期起 as EffectTime, (SELECT 有效期至 FROM tmp_T_在册供方查询 tmpzc WHERE tmpzc.ID = a.ID) AS ApplyTime,备注 AS Remark,'导入' As CreateBy,ID,推荐单位名称 as RecUnitName,管理单位 as MgrUnit,推荐日期,曾用准入证号 as RecDate " +
|
|
|
+ "FROM T_资格预审表 a where 企业名称 = '" + supplierName + "'"
|
|
|
+ _, err := s.DBE.Query(sql)
|
|
|
+ s.DBE.Query("SET unique_checks=1;")
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) UpdateOneSupplierTypeCodeAndInFlag() error {
|
|
|
+ sql1 := "update `OilSupplierCert` set SupplierTypeCode = '01' where SupplierTypeName='物资类' and SupplierId = -1"
|
|
|
+ _, err := s.DBE.Query(sql1)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ sql2 := "UPDATE `OilSupplierCert` SET SupplierTypeCode = '02' WHERE SupplierTypeName='基建类' and SupplierId = -1"
|
|
|
+ _, err = s.DBE.Query(sql2)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ sql3 := "UPDATE `OilSupplierCert` SET SupplierTypeCode = '03' WHERE SupplierTypeName='服务类' and SupplierId = -1"
|
|
|
+ _, err = s.DBE.Query(sql3)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ sql31 := "UPDATE `OilSupplierCert` SET SupplierTypeCode = '03', SupplierTypeName='服务类' WHERE SupplierTypeName='技术服务类' and SupplierId = -1"
|
|
|
+ _, err = s.DBE.Query(sql31)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ sql4 := "UPDATE `OilSupplierCert` SET InFlag = '1' WHERE InFlag='准入' and SupplierId = -1"
|
|
|
+ _, err = s.DBE.Query(sql4)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ sql5 := "UPDATE `OilSupplierCert` SET InFlag = '2' WHERE InFlag='暂停' and SupplierId = -1"
|
|
|
+ _, err = s.DBE.Query(sql5)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ sql6 := "UPDATE `OilSupplierCert` SET InFlag = '3' WHERE InFlag='取消' and SupplierId = -1"
|
|
|
+ _, err = s.DBE.Query(sql6)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ sql7 := "UPDATE `OilSupplierCert` a,(select Id from `T_资格预审表` where 内部单位 = 1 ) b SET InStyle = '5' where b.Id = a.GfId and a.SupplierId = -1"
|
|
|
+ _, err = s.DBE.Query(sql7)
|
|
|
+
|
|
|
+ return err
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) UpdateOneSupplierCert() error {
|
|
|
+ sql := "UPDATE `OilSupplierCert` b SET b.SupplierId=IFNULL((SELECT a.Id FROM OilSupplier a WHERE a.SupplierName = b.OutsideFlog AND a.Id IS NOT NULL limit 1), 0) where b.SupplierId = -1"
|
|
|
+ _, err := s.DBE.Query(sql)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) UpdateOneSupplierMgrUnit(supplierName string) error {
|
|
|
+ sql := " update OilSupplier a set a.MgrUnit = (select MgrUnit from OilSupplierCert b where b.SupplierId = a.Id and b.SupplierTypeCode = '01') where a.SupplierName = '" + supplierName + "'"
|
|
|
+ _, err := s.DBE.Query(sql)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) InsertOneFileName(supplierName string) error {
|
|
|
+ sql := "INSERT INTO `OilSupplierFile` (SupplierId, SupplierCertSubId, FileUrl, Remark, NeedFileType, OtherRemark, SupplierTypeCode,CreateBy, FileExt, EffectDate, CreateOn, FileName) " +
|
|
|
+ "SELECT 0 AS SupplierId, 0 AS SupplierCertSubId, concat('/upfile/gfzl_2014/', f.ID_GF, '-' , f.类别编号, IFNULL(f.文件类型, ''), '|', f.类别, IFNULL(f.文件类型, '')) AS FileUrl, z.企业名称 AS Remark ,f.类别 AS NeedFileType, f.说明 AS OtherRemark, " +
|
|
|
+ "( CASE z.准入类别 WHEN '物资类' THEN '01' WHEN '基建类' THEN '02' WHEN '服务类' THEN '03' WHEN '技术服务类' THEN '03' else '000' END ) SupplierTypeCode, " +
|
|
|
+ "'导入' AS CreateBy, f.`文件类型` AS FileExt, str_to_date(f.`有效期至`, '%Y-%m-%d') AS EffectDate, str_to_date(f.`日期`, '%Y-%m-%d') AS CreateOn, concat(f.类别, IFNULL(f.文件类型, '')) AS FileName " +
|
|
|
+ "FROM `T_供方资料_V2014` f " +
|
|
|
+ "LEFT JOIN `T_资格预审表` z ON (f.ID_GF = z.ID) " +
|
|
|
+ "WHERE z.企业名称 = '" + supplierName + "'"
|
|
|
+ _, err := s.DBE.Query(sql)
|
|
|
+
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) UpdateOneSupplierFile() error {
|
|
|
+ sql := "update OilSupplierFile set SupplierTypeCode = '000',IsManuf = '0' where NeedFileType in ('银行开户许可证或基本存款账户信息','营业执照','诚信合规承诺书','国家企业信用信息公示系统截屏','税务登记证','组织机构代码证') and SupplierId = 0"
|
|
|
+ _, err := s.DBE.Query(sql)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) UpdateOneSupplierFileSId() error {
|
|
|
+ sql := "UPDATE `OilSupplierFile` b left join `OilSupplier` a ON (a.SupplierName = b.Remark AND a.Id IS NOT NULL) SET b.SupplierId = IFNULL(a.Id, 0) where b.SupplierId = 0"
|
|
|
+ _, err := s.DBE.Query(sql)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) InsertOneCertSub(id string) error {
|
|
|
+
|
|
|
+ sql := "INSERT INTO `OilSupplierCertSub` (" +
|
|
|
+ "OldId," +
|
|
|
+ "AppendStatus," +
|
|
|
+ "`Type`," +
|
|
|
+ "CreateBy," +
|
|
|
+ "Remark," +
|
|
|
+ "IsManufacturer," +
|
|
|
+ "GoodsLevel," +
|
|
|
+ "`Code`," +
|
|
|
+ "`Name`" +
|
|
|
+ ") " +
|
|
|
+ ` SELECT t.id AS OldId ,
|
|
|
+ '1' AS AppendStatus,
|
|
|
+ '1' AS Type,
|
|
|
+ '导入1' AS CreateBy,
|
|
|
+ t.备注 As Remark,
|
|
|
+ t.制造产品 AS IsManufacturer,
|
|
|
+ t.物资级别 AS GoodsLevel,
|
|
|
+ t.物资编码 AS code,
|
|
|
+ t.产品名称 AS name
|
|
|
+ FROM T_资格预审表_JRMX t
|
|
|
+ where t.id = `
|
|
|
+ sql += id
|
|
|
+ _, err := s.DBE.Query(sql)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) UpdateOneCertSub(cert suppliercert.OilSupplierCert) error {
|
|
|
+ var err error
|
|
|
+ sql := " UPDATE OilSupplierCertSub b SET b.SupplierId = '" + strconv.Itoa(cert.SupplierId) + "'," +
|
|
|
+ " b.SupplierCertId='"+ strconv.Itoa(cert.Id) + "',"+
|
|
|
+ " b.SupplierTypeCode='" + cert.SupplierTypeCode + "'" +
|
|
|
+ " where b.OldId = '" + strconv.Itoa(cert.GfId) + "'"
|
|
|
+ _, err = s.DBE.Query(sql)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) InsertOneOilPaymentInfo(id string) error {
|
|
|
+ sql := "INSERT INTO `OilPaymentInfo` ( " +
|
|
|
+ "ID_GF," +
|
|
|
+ "SupplierName," +
|
|
|
+ "PayDate," +
|
|
|
+ "Amount," +
|
|
|
+ "IsPay," +
|
|
|
+ " PayType," +
|
|
|
+ "Remark," +
|
|
|
+ "PayMode," +
|
|
|
+ "CreateBy" +
|
|
|
+ ")" +
|
|
|
+ "SELECT ID_GF, 企业名称 AS SupplierName ,IF(交费日期='', '1970-01-01', 交费日期) AS PayDate, IF(新准入='', 0, 新准入) AS Amount, '2' AS IsPay,'1' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM T_交费记录 WHERE 新准入 IS NOT NULL and 新准入<>'' and ID_GF = " + id +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName ,IF(交费日期='', '1970-01-01', 交费日期) AS PayDate, IF(换证='', 0, 换证) AS Amount , '2' AS IsPay, '4' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM T_交费记录 WHERE 换证 IS NOT NULL and 换证<>'' and ID_GF = " + id +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName ,IF(交费日期='', '1970-01-01', 交费日期) AS PayDate, IF(增项='', 0, 增项) AS Amount , '2' AS IsPay, '3' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM T_交费记录 WHERE 增项 IS NOT NULL and 增项<>'' and ID_GF = " + id +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName,IF(交费日期='', '1970-01-01', 交费日期) AS PayDate, IF(年审='', 0, 年审) AS Amount , '2' AS IsPay, '2' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM T_交费记录 WHERE 年审 IS NOT NULL and 年审<>'' and ID_GF = " + id +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName,IF(交费日期='', '1970-01-01', 交费日期) AS PayDate, IF(罚款='', 0, 罚款) AS Amount , '2' AS IsPay, '5' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM T_交费记录 WHERE 罚款 IS NOT NULL and 罚款<>'' and ID_GF = " + id +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName,IF(交费日期='', '1970-01-01', 交费日期) AS PayDate, IF(其它='', 0, 其它) AS Amount , '2' AS IsPay, '6' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM T_交费记录 WHERE 其它 IS NOT NULL and 其它<>'' and ID_GF = " + id
|
|
|
+
|
|
|
+ _, err := s.DBE.Query(sql)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|