|
|
@@ -100,7 +100,7 @@ func (s *TmpzcgtSession) InsertSupplier() error {
|
|
|
'导入' As CreateBy
|
|
|
FROM
|
|
|
tmp_zcgf WHERE ID IN (SELECT MAX(ID) FROM tmp_zcgf GROUP BY 企业名称);`
|
|
|
- _,err := s.Session.Query(sql)
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
@@ -108,44 +108,44 @@ func (s *TmpzcgtSession) InsertSupplierCert() error {
|
|
|
sql := "INSERT INTO OilSupplierCert (SupplierId,OutsideFlog, `Status` ,AccessCardNo,SupplierTypeName,InFlag,EffectStartTime,EffectEndTime,ApplyTime,Remark,CreateBy,GfID) " +
|
|
|
"SELECT -1 As SupplierId,企业名称 AS OutsideFlog,'8' As `Status`,准入证号 As AccessCardNo,准入类别 AS SupplierTypeName,准入标识 AS InFlag,有效期起 AS EffectStartTime,有效期止 AS EffectEndTime,年审日期 AS ApplyTime,备注 AS Remark,'导入' As CreateBy,ID " +
|
|
|
"FROM tmp_zcgf;"
|
|
|
- _,err := s.Session.Query(sql)
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
func (s *TmpzcgtSession) UpdateSupplierCert() error {
|
|
|
sql := "UPDATE `OilSupplierCert` b SET b.SupplierId=(SELECT Id FROM OilSupplier a WHERE a.SupplierName = b.OutsideFlog)"
|
|
|
- _,err := s.Session.Query(sql)
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
func (s *TmpzcgtSession) UpdateSupplierTypeCodeAndInFlag() error {
|
|
|
sql1 := "update `OilSupplierCert` set SupplierTypeCode = '01' where SupplierTypeName='物资类'"
|
|
|
- _,err := s.Session.Query(sql1)
|
|
|
+ _, err := s.Session.Query(sql1)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
sql2 := "UPDATE `OilSupplierCert` SET SupplierTypeCode = '02' WHERE SupplierTypeName='基建类'"
|
|
|
- _,err = s.Session.Query(sql2)
|
|
|
+ _, err = s.Session.Query(sql2)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
sql3 := "UPDATE `OilSupplierCert` SET SupplierTypeCode = '03' WHERE SupplierTypeName='技术服务类'"
|
|
|
- _,err = s.Session.Query(sql3)
|
|
|
+ _, err = s.Session.Query(sql3)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
sql4 := "UPDATE `OilSupplierCert` SET InFlag = '1' WHERE InFlag='准入'"
|
|
|
- _,err = s.Session.Query(sql4)
|
|
|
+ _, err = s.Session.Query(sql4)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
sql5 := "UPDATE `OilSupplierCert` SET InFlag = '2' WHERE InFlag='暂停'"
|
|
|
- _,err = s.Session.Query(sql5)
|
|
|
+ _, err = s.Session.Query(sql5)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
sql6 := "UPDATE `OilSupplierCert` SET InFlag = '3' WHERE InFlag='取消'"
|
|
|
- _,err = s.Session.Query(sql6)
|
|
|
+ _, err = s.Session.Query(sql6)
|
|
|
return err
|
|
|
|
|
|
}
|
|
|
@@ -156,14 +156,14 @@ func (s *TmpzcgtSession) InsterAnnual() error {
|
|
|
"企业名称 AS SupplierName, 申请日期 AS CreateOn, 录入员 AS CreateBy, 推荐单位编码 AS RecUnitId, 年审日期 AS ApplyTime, 准入证号 AS AccessCardNo, id AS oldId " +
|
|
|
"FROM tmp_nianshen"
|
|
|
|
|
|
- _,err := s.Session.Query(sql)
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
func (s *TmpzcgtSession) InsertOilPaymentInfo() error {
|
|
|
sql := "INSERT INTO `OilPaymentInfo` ( " +
|
|
|
- "ID_GF," +
|
|
|
- "SupplierName," +
|
|
|
+ "ID_GF," +
|
|
|
+ "SupplierName," +
|
|
|
"PayDate," +
|
|
|
"Amount," +
|
|
|
"IsPay," +
|
|
|
@@ -171,72 +171,124 @@ func (s *TmpzcgtSession) InsertOilPaymentInfo() error {
|
|
|
"Remark," +
|
|
|
"PayMode," +
|
|
|
"CreateBy" +
|
|
|
- ")" +
|
|
|
- "SELECT ID_GF, 企业名称 AS SupplierName ,交费日期 AS PayDate, 新准入 AS Amount, '2' AS IsPay,'1' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 新准入 IS NOT NULL" +
|
|
|
- " UNION" +
|
|
|
- " SELECT ID_GF, 企业名称 AS SupplierName ,交费日期 AS PayDate, 换证 AS Amount , '2' AS IsPay, '4' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 换证 IS NOT NULL" +
|
|
|
- " UNION" +
|
|
|
- " SELECT ID_GF, 企业名称 AS SupplierName ,交费日期 AS PayDate, 增项 AS Amount , '2' AS IsPay, '3' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 增项 IS NOT NULL" +
|
|
|
- " UNION" +
|
|
|
- " SELECT ID_GF, 企业名称 AS SupplierName,交费日期 AS PayDate, 年审 AS Amount , '2' AS IsPay, '2' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 年审 IS NOT NULL" +
|
|
|
- " UNION" +
|
|
|
- " SELECT ID_GF, 企业名称 AS SupplierName,交费日期 AS PayDate, 罚款 AS Amount , '2' AS IsPay, '5' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 罚款 IS NOT NULL" +
|
|
|
- " UNION" +
|
|
|
- " SELECT ID_GF, 企业名称 AS SupplierName,交费日期 AS PayDate, 其它 AS Amount , '2' AS IsPay, '6' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 其它 IS NOT NULL"
|
|
|
-
|
|
|
- _,err := s.Session.Query(sql)
|
|
|
+ ")" +
|
|
|
+ "SELECT ID_GF, 企业名称 AS SupplierName ,交费日期 AS PayDate, 新准入 AS Amount, '2' AS IsPay,'1' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 新准入 IS NOT NULL" +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName ,交费日期 AS PayDate, 换证 AS Amount , '2' AS IsPay, '4' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 换证 IS NOT NULL" +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName ,交费日期 AS PayDate, 增项 AS Amount , '2' AS IsPay, '3' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 增项 IS NOT NULL" +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName,交费日期 AS PayDate, 年审 AS Amount , '2' AS IsPay, '2' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 年审 IS NOT NULL" +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName,交费日期 AS PayDate, 罚款 AS Amount , '2' AS IsPay, '5' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 罚款 IS NOT NULL" +
|
|
|
+ " UNION" +
|
|
|
+ " SELECT ID_GF, 企业名称 AS SupplierName,交费日期 AS PayDate, 其它 AS Amount , '2' AS IsPay, '6' AS PayType , 备注 AS Remark, 交款方式 AS PayMode,收款人 AS CreateBy FROM tmp_jiaofenjl WHERE 其它 IS NOT NULL"
|
|
|
+
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
func (s *TmpzcgtSession) UpdateOilPaymentInfo() error {
|
|
|
sql := "UPDATE OilPaymentInfo b SET b.SupplierId= (SELECT DISTINCT(a.SupplierId) FROM `OilSupplierCert` a WHERE a.GfId = b.ID_GF )"
|
|
|
- _,err := s.Session.Query(sql)
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
func (s *TmpzcgtSession) InsterBadRecord() error {
|
|
|
sql := "INSERT INTO BadRecord (" +
|
|
|
- "Bak1," +
|
|
|
+ "Bak1," +
|
|
|
"CreateOn, " +
|
|
|
"Record," +
|
|
|
"CompanyName, " +
|
|
|
"CompanyCode, " +
|
|
|
"CategoryName, " +
|
|
|
"CategoryCode " +
|
|
|
- ") " +
|
|
|
- "SELECT " +
|
|
|
- "gfid AS Bak1 , " +
|
|
|
+ ") " +
|
|
|
+ "SELECT " +
|
|
|
+ "gfid AS Bak1 , " +
|
|
|
"日期 AS CreateOn, " +
|
|
|
"内容 AS Record, " +
|
|
|
"'' AS CompanyName, " +
|
|
|
"'' AS CompanyCode, " +
|
|
|
"'' AS CategoryName, " +
|
|
|
"'' AS CategoryCode " +
|
|
|
- "FROM tmp_buliangjl WHERE 内容 IS NOT NULL"
|
|
|
- _,err := s.Session.Query(sql)
|
|
|
+ "FROM tmp_buliangjl WHERE 内容 IS NOT NULL"
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
func (s *TmpzcgtSession) UpdateBadRecord() error {
|
|
|
sql := "UPDATE BadRecord b SET " +
|
|
|
- "b.CompanyCode = (SELECT DISTINCT(a.SupplierId) FROM `OilSupplierCert` a WHERE a.GfId = b.Bak1 AND a.SupplierId IS NOT NULL)," +
|
|
|
- "b.CompanyName = (SELECT DISTINCT(a.OutsideFlog) FROM `OilSupplierCert` a WHERE a.GfId = b.Bak1 AND a.OutsideFlog IS NOT NULL) "
|
|
|
- _,err := s.Session.Query(sql)
|
|
|
+ "b.CompanyCode = (SELECT DISTINCT(a.SupplierId) FROM `OilSupplierCert` a WHERE a.GfId = b.Bak1 AND a.SupplierId IS NOT NULL)," +
|
|
|
+ "b.CompanyName = (SELECT DISTINCT(a.OutsideFlog) FROM `OilSupplierCert` a WHERE a.GfId = b.Bak1 AND a.OutsideFlog IS NOT NULL) "
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
func (s *TmpzcgtSession) UpdateOilAnnualAudit() error {
|
|
|
sql := "UPDATE OilAnnualAudit b SET b.SupplierId = (SELECT a.SupplierId FROM OilSupplierCert a WHERE a.GfId =b.OldId AND a.SupplierTypeCode = b.SupplierTypeName )," +
|
|
|
- "b.CerId = (SELECT a.Id FROM OilSupplierCert a WHERE a.GfId =b.OldId AND a.SupplierTypeCode = b.SupplierTypeName ),"+
|
|
|
- "b.AccessCardNo = (SELECT a.AccessCardNo FROM OilSupplierCert a WHERE a.GfId =b.OldId AND a.SupplierTypeCode = b.SupplierTypeName )"
|
|
|
- _,err := s.Session.Query(sql)
|
|
|
+ "b.CerId = (SELECT a.Id FROM OilSupplierCert a WHERE a.GfId =b.OldId AND a.SupplierTypeCode = b.SupplierTypeName )," +
|
|
|
+ "b.AccessCardNo = (SELECT a.AccessCardNo FROM OilSupplierCert a WHERE a.GfId =b.OldId AND a.SupplierTypeCode = b.SupplierTypeName )"
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
+func (s *TmpzcgtSession) InsertCertSub() error {
|
|
|
+ sql := "INSERT `OilSupplierCertSub` (" +
|
|
|
+ "OldId," +
|
|
|
+ "AppendStatus," +
|
|
|
+ "`Type`," +
|
|
|
+ "CreateBy," +
|
|
|
+ "Remark," +
|
|
|
+ "SupplierTypeCode," +
|
|
|
+ "`Code`," +
|
|
|
+ "`Name`" +
|
|
|
|
|
|
+ ")SELECT " +
|
|
|
+ "t.`ID` AS OldId , '1' AS AppendStatus, '1' AS `Type`, '导入1' AS CreateBy, t.企业名称 As Remark, " +
|
|
|
+ "(CASE t.`准入类别` WHEN '物资类' THEN '01' WHEN '基建类' THEN '02' WHEN '技术服务类' THEN '03' END) AS SupplierTypeCode," +
|
|
|
+ "REPLACE(SUBSTRING_INDEX (SUBSTRING_INDEX(SUBSTRING_INDEX(t.`准入范围`,';', b.help_topic_id + 1), ';', -1),' ' ,1),'BM','') AS `code`, " +
|
|
|
+ "SUBSTRING_INDEX(SUBSTRING_INDEX(SUBSTRING_INDEX(t.`准入范围`,';', b.help_topic_id + 1), ';', -1),' ' ,-1)AS `name` " +
|
|
|
+ "FROM tmp_zcgf t " +
|
|
|
+ "CROSS JOIN mysql.help_topic b " +
|
|
|
+ "ON b.help_topic_id < (LENGTH(t.`准入范围`) - LENGTH(REPLACE(t.`准入范围`, ';', '')) + 1) " +
|
|
|
+ "WHERE " +
|
|
|
+ "1=1 " +
|
|
|
+ "AND LENGTH( SUBSTRING_INDEX(SUBSTRING_INDEX(t.`准入范围`,';', b.help_topic_id + 1), ';', -1) ) > 0 " +
|
|
|
+ "ORDER BY t.ID "
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
+ return err
|
|
|
+}
|
|
|
|
|
|
+func (s *TmpzcgtSession) UpdateCertSub(where string) error {
|
|
|
+ sql := "UPDATE OilSupplierCertSub b SET b.SupplierId = (SELECT a.SupplierId FROM OilSupplierCert a WHERE a.GfId =b.OldId AND a.SupplierTypeCode = b.SupplierTypeCode )," +
|
|
|
+ "b.SupplierCertId = (SELECT a.Id FROM OilSupplierCert a WHERE a.GfId =b.OldId AND a.SupplierTypeCode = b.SupplierTypeCode ) " + where
|
|
|
+ _, err := s.Session.Query(sql)
|
|
|
+ return err
|
|
|
+}
|
|
|
|
|
|
+func (s *TmpzcgtSession) UpdateCertSub01classId(where string) error {
|
|
|
|
|
|
+ sql1 := "UPDATE OilSupplierCertSub_tmp b SET b.SubClassId = (SELECT a.Id FROM OilGoodsAptitudeClass a WHERE a.Code = b.Code ) " +
|
|
|
+ "WHERE b.SupplierTypeCode = '01'" + where
|
|
|
+ _, err := s.Session.Query(sql1)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) UpdateCertSub02classId(where string) error {
|
|
|
+ sql2 := "UPDATE OilSupplierCertSub_tmp b SET b.SubClassId = (SELECT a.Id FROM OilBasisBuild a WHERE a.Code = b.Code ) " +
|
|
|
+ "WHERE b.SupplierTypeCode = '02'" + where
|
|
|
+ _, err := s.Session.Query(sql2)
|
|
|
+ return err
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+func (s *TmpzcgtSession) UpdateCertSub03classId(where string) error {
|
|
|
+ sql3 := "UPDATE OilSupplierCertSub_tmp b SET b.SubClassId = (SELECT a.Id FROM OilBasisBuild a WHERE a.Code = b.Code ) " +
|
|
|
+ "WHERE b.SupplierTypeCode = '03'" + where
|
|
|
+ _, err := s.Session.Query(sql3)
|
|
|
+ return err
|
|
|
+}
|
|
|
|
|
|
|
|
|
|