导数据

src/dashoo.cn/backend/api/business/oilsupplier/annualaudit/annualaudit.go

@@ -45,6 +45,7 @@ type OilAnnualAudit struct {
 	ModifiedOn       time.Time `xorm:"DATETIME"`
 	ModifiedUserId   int       `xorm:"INT(10)"`
 	ModifiedBy       string    `xorm:"VARCHAR(50)"`
+	OldId            int       `xorm:"INT(10)"`
 }
 
 type Suppliername struct {

src/dashoo.cn/backend/api/business/oilsupplier/suppliercert/oilsuppliercert.go

@@ -65,6 +65,7 @@ type OilSupplierCert struct {
 	ModifiedOn        time.Time `xorm:"DATETIME"`
 	ModifiedUserId    int       `xorm:"INT(10)"`
 	ModifiedBy        string    `xorm:"VARCHAR(50)"`
+	GfId              int       `xorm:"INT(11)"`
 }
 
 type OilSupplierVM struct {

src/dashoo.cn/backend/api/business/oilsupplier/suppliercertappend/oilsuppliercertappend.go

@@ -35,6 +35,7 @@ type OilSupplierCertAppend struct {
 	ModifiedOn     time.Time `xorm:"DATETIME"`
 	ModifiedUserId int       `xorm:"INT(10)"`
 	ModifiedBy     string    `xorm:"VARCHAR(50)"`
+	OldId          int       `xorm:"INT(10)"`
 }
 
 type OilSupplierCertAppendTodo struct {

src/dashoo.cn/backend/api/business/tmpzcgf/tmpzcgfSession.go

@@ -0,0 +1,157 @@
+package tmpzcgf
+
+import (
+	. "dashoo.cn/backend/api/mydb"
+	"github.com/go-xorm/xorm"
+)
+
+type TmpzcgtSession struct {
+	MySessionBase
+}
+
+func GetTmpzcgtService(session *xorm.Session) *TmpzcgtSession {
+	s := new(TmpzcgtSession)
+	s.Session = session
+	return s
+}
+
+func (s *TmpzcgtSession) InsertSupplier() 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,
+	SetupTime,
+	EMail,
+	BankCreditRating,
+	Mobile,
+	Telphone,
+	Fax,
+	CompanyTel,
+	QQ,
+	CompanyUrl,
+	Remark,
+	CreateBy
+) SELECT
+	企业名称 AS SupplierName,
+	级别 AS Grade,
+	经营方式 AS OperType,
+	国家 AS Country,
+	所代理制造商名称 AS MaunAgent,
+	施工队伍名称 AS ConstructTeam,
+	工商注册号 AS CommercialNo,
+	组织机构代码 AS OrganCode,
+	税务登记证国税编号 AS CountryTaxNo,
+	税务登记证地税编号 AS LocalTaxNo,
+	单位地址 AS Address,
+	邮编 AS ZipCode,
+	质量管理体系认证情况及认证机构 AS QualitySystemCert,
+	产品质量认证情况及认证机构 AS ProductQualityCert,
+	生产制造许可证获证情况及编号 AS MaunLicense,
+	企业资质证书编号 AS QualifCert,
+	企业资质证书级别 AS QualifCertLevel,
+	安全生产许可证 AS SafetyLicense,
+	技术服务类准入许可证 AS TechServiceLic,
+	外地企业进津备案通知书 AS TJInNotify,
+	行业特殊要求的认证证书 AS SpecIndustryCert,
+	法定代表人姓名 AS LegalPerson,
+	行业类别代码 AS CategoryCode,
+	行业类别名称 AS CategoryName,
+	注册资本 AS RegCapital,
+	币种 AS Currency,
+	联系人姓名 AS ContactName,
+	公司类型 AS CompanyType,
+	开户银行 AS DepositBank,
+	银行账号 AS BankAccount,
+	成立时间 AS SetupTime,
+	电子邮箱 AS EMail,
+	银行信用等级 AS BankCreditRating,
+	移动电话 AS Mobile,
+	固定电话 AS Telphone,
+	传真 AS Fax,
+	公司电话 AS CompanyTel,
+	QQ号码 AS QQ,
+	公司网址 AS CompanyUrl,
+	备注 AS Remark,
+	'导入' As CreateBy
+FROM 
+	tmp_zcgf WHERE ID IN (SELECT MAX(ID) FROM tmp_zcgf GROUP BY 企业名称);`
+	_,err := s.Session.Query(sql)
+	return err
+}
+
+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)
+	return err
+}
+
+func (s *TmpzcgtSession) UpdateSupplierTypeCodeAndInFlag() error {
+	sql1 := "update `OilSupplierCert` set SupplierTypeCode = '01' where SupplierTypeName='物资类'"
+	_,err := s.Session.Query(sql1)
+	if err != nil {
+		return err
+	}
+	sql2 := "UPDATE `OilSupplierCert` SET SupplierTypeCode = '02' WHERE SupplierTypeName='基建类'"
+	_,err = s.Session.Query(sql2)
+	if err != nil {
+		return err
+	}
+	sql3 := "UPDATE `OilSupplierCert` SET SupplierTypeCode = '03' WHERE SupplierTypeName='技术服务类'"
+	_,err = s.Session.Query(sql3)
+	if err != nil {
+		return err
+	}
+	sql4 := "UPDATE `OilSupplierCert` SET InFlag = '1' WHERE InFlag='准入'"
+	_,err = s.Session.Query(sql4)
+	if err != nil {
+		return err
+	}
+	sql5 := "UPDATE `OilSupplierCert` SET InFlag = '2' WHERE InFlag='暂停'"
+	_,err = s.Session.Query(sql5)
+	if err != nil {
+		return err
+	}
+	sql6 := "UPDATE `OilSupplierCert` SET InFlag = '3' WHERE InFlag='取消'"
+	_,err = s.Session.Query(sql6)
+	return err
+
+}
+
+func (s *TmpzcgtSession) InsterAnnual() error {
+	sql := "INSERT INTO OilAnnualAudit (SupplierTypeName, SupplierName, CreateOn, CreateBy, RecUnitId, ApplyTime, AccessCardNo, OldId) " +
+		"SELECT ( CASE 准入类别 WHEN '物资类' THEN '01' WHEN '基建类' THEN '02' WHEN '技术服务类' THEN '03' END ) SupplierTypeName, " +
+		"企业名称 AS SupplierName, 申请日期 AS CreateOn, 录入员 AS CreateBy, 推荐单位编码 AS RecUnitId, 年审日期 AS ApplyTime, 准入证号 AS AccessCardNo, id AS oldId " +
+		"FROM tmp_nianshen"
+
+	_,err := s.Session.Query(sql)
+	return err
+}

src/dashoo.cn/backend/api/controllers/tmpzcgf/tmpzcgf.go

@@ -0,0 +1,228 @@
+package tmpzcgf
+
+import (
+	"dashoo.cn/backend/api/business/oilsupplier/annualaudit"
+	"dashoo.cn/backend/api/business/oilsupplier/supplier"
+	"dashoo.cn/backend/api/business/oilsupplier/suppliercert"
+	"dashoo.cn/backend/api/business/oilsupplier/suppliercertappend"
+	"dashoo.cn/backend/api/business/tmpzcgf"
+	. "dashoo.cn/backend/api/controllers"
+	"dashoo.cn/utils"
+	"fmt"
+	"strconv"
+	"time"
+)
+
+type TmpzcgfController struct {
+	BaseController
+}
+
+// @Title 跟新OilSupplier
+// @Description get user by token
+// @Success 200 {object}
+// @router /insertsupplier [get]
+func (this *TmpzcgfController) InsertSupplier(){
+	t := time.Now()
+	session := utils.DBE.NewSession()
+	defer session.Close()
+	err := session.Begin()
+	svc := tmpzcgf.GetTmpzcgtService(session)
+	err = svc.InsertSupplier()
+	if err != nil {
+		session.Rollback()
+	}
+	err = session.Commit()
+	fmt.Println(err)
+	elapsed := time.Since(t)
+	fmt.Println(elapsed)
+}
+
+// @Title 跟新SupplierCert
+// @Description get user by token
+// @Success 200 {object}
+// @router /insertsuppliercert [get]
+func (this *TmpzcgfController) InsertSupplierCert(){
+	t := time.Now()
+	session := utils.DBE.NewSession()
+	defer session.Close()
+	err := session.Begin()
+	svc := tmpzcgf.GetTmpzcgtService(session)
+	err = svc.InsertSupplierCert()
+	if err != nil {
+		session.Rollback()
+	}
+	err = session.Commit()
+	fmt.Println(err)
+	elapsed := time.Since(t)
+	fmt.Println(elapsed)
+}
+
+// @Title 更新CertTypeAndInflag
+// @Description get user by token
+// @Success 200 {object}
+// @router /updatecerttypeandinflag [get]
+func (this *TmpzcgfController) UpdateCertTypeAndInflag(){
+	t := time.Now()
+	session := utils.DBE.NewSession()
+	defer session.Close()
+	err := session.Begin()
+	svc := tmpzcgf.GetTmpzcgtService(session)
+	err = svc.UpdateSupplierTypeCodeAndInFlag()
+	if err != nil {
+		session.Rollback()
+	}
+	err = session.Commit()
+	fmt.Println(err)
+	elapsed := time.Since(t)
+	fmt.Println(elapsed)
+}
+
+// @Title 跟新SupplierId
+// @Description get user by token
+// @Success 200 {object}
+// @router /updatesupplierid [get]
+func (this *TmpzcgfController) UpdateSupplierId(){
+	t := time.Now()
+	session := utils.DBE.NewSession()
+	defer session.Close()
+	err := session.Begin()
+	svc := tmpzcgf.GetTmpzcgtService(session)
+	var supp []supplier.OilSupplier
+	var certs  []suppliercert.OilSupplierCert
+	var  c  suppliercert.OilSupplierCert
+
+	svc.GetEntitysByWhere("OilSupplier", "CreateBy='导入'" ,&supp )
+	svc.GetEntitysByWhere("OilSupplierCert", "1=1", &certs)
+	for _,cert := range certs {
+		for _,sup := range supp {
+			if cert.OutsideFlog == sup.SupplierName {
+				fmt.Println(cert.OutsideFlog, sup.SupplierName)
+				col := []string{"SupplierId"}
+				c.SupplierId = sup.Id
+				where := "Id=" + strconv.Itoa(cert.Id)
+				err = svc.UpdateEntityBywheretbl("OilSupplierCert",c,col,where)
+				if err != nil {
+					session.Rollback()
+				}
+				break
+			}
+		}
+	}
+
+	err = session.Commit()
+	fmt.Println(err)
+	elapsed := time.Since(t)
+	fmt.Println(elapsed)
+}
+
+// @Title 导入年审
+// @Description get user by token
+// @Success 200 {object}
+// @router /insterannualaudit [get]
+func (this *TmpzcgfController) InsterAnnualAudit(){
+	t := time.Now()
+	session := utils.DBE.NewSession()
+	defer session.Close()
+	err := session.Begin()
+	svc := tmpzcgf.GetTmpzcgtService(session)
+	err = svc.InsterAnnual()
+	if err != nil {
+		session.Rollback()
+	}
+	err = session.Commit()
+	fmt.Println(err)
+	elapsed := time.Since(t)
+	fmt.Println(elapsed)
+}
+
+// @Title 跟新年审表的SupplierId CertId
+// @Description get user by token
+// @Success 200 {object}
+// @router /updateAnnualAudit [get]
+func (this *TmpzcgfController) UpdateAnnualAudit(){
+	t := time.Now()
+	session := utils.DBE.NewSession()
+	defer session.Close()
+	err := session.Begin()
+	svc := tmpzcgf.GetTmpzcgtService(session)
+	var annus []annualaudit.OilAnnualAudit
+	var certs  []suppliercert.OilSupplierCert
+	var  annual  annualaudit.OilAnnualAudit
+
+	svc.GetEntitysByWhere("OilAnnualAudit", "1=1" ,&annus )
+	svc.GetEntitysByWhere("OilSupplierCert", "CreateBy='导入'", &certs)
+	var aff int64
+	for _,annu := range annus {
+		for _,sup := range certs {
+			if annu.OldId == sup.GfId {
+				fmt.Println(annu.OldId, sup.GfId, sup.OutsideFlog)
+				col := []string{"SupplierId", "CerId"}
+				annual.SupplierId = sup.SupplierId
+				annual.CerId = sup.Id
+				//where := "Id=" + strconv.Itoa(annu.Id)
+				aff,err = svc.UpdateEntityByIdCols(annu.Id, &annual, col)
+				if err != nil {
+					session.Rollback()
+				}
+				break
+			}
+		}
+	}
+
+	err = session.Commit()
+	fmt.Println(err,aff)
+	elapsed := time.Since(t)
+	fmt.Println(elapsed)
+}
+
+// @Title 跟新 OilSupplierCertAppend 的 SupplierId  SupplierCertId
+// @Description get user by token
+// @Success 200 {object}
+// @router /updateOilSupplierCertAppend [get]
+func (this *TmpzcgfController) UpdateOilSupplierCertAppend(){
+	t := time.Now()
+	session := utils.DBE.NewSession()
+	defer session.Close()
+	err := session.Begin()
+	svc := tmpzcgf.GetTmpzcgtService(session)
+	var appendlist []suppliercertappend.OilSupplierCertAppend
+	var certlist  []suppliercert.OilSupplierCert
+	var  append  suppliercertappend.OilSupplierCertAppend
+	svc.GetEntities(&appendlist, "")
+	svc.GetEntities(&certlist, "CreateBy='导入'")
+
+	for _,annu := range appendlist {
+		for _,cert := range certlist {
+			if annu.OldId == cert.GfId && annu.AppendType == cert.SupplierTypeCode{
+				fmt.Println(annu.OldId, cert.GfId, cert.OutsideFlog, annu.AppendType, cert.SupplierTypeCode)
+				col := []string{"SupplierId", "SupplierCertId"}
+				append.SupplierId = cert.SupplierId
+				append.SupplierCertId = cert.Id
+				//where := "Id=" + strconv.Itoa(annu.Id)
+				_,err = svc.UpdateEntityByIdCols(annu.Id, &append, col)
+				if err != nil {
+					session.Rollback()
+				}
+				break
+			}
+		}
+	}
+
+	err = session.Commit()
+	fmt.Println(err)
+	elapsed := time.Since(t)
+	fmt.Println(elapsed)
+
+
+
+}
+
+
+
+
+
+
+
+
+
+

src/dashoo.cn/backend/api/routers/router.go

@@ -4,6 +4,7 @@
 package routers
 
 import (
+	"dashoo.cn/backend/api/controllers/tmpzcgf"
 	"dashoo.cn/backend/api/controllers"
 	"dashoo.cn/backend/api/controllers/bankapi"
 	"dashoo.cn/backend/api/controllers/casbin"
@@ -391,6 +392,12 @@ func init() {
 				&bankapi.ICBCController{},
 			),
 		),
+		//bankapi
+		beego.NSNamespace("/tmpzcgf",
+			beego.NSInclude(
+				&tmpzcgf.TmpzcgfController{},
+			),
+		),
 	)
 	beego.AddNamespace(ns)
 }

src/dashoo.cn/frontend_web/src/pages/system/tmpzcgf.vue

@@ -0,0 +1,99 @@
+<template>
+  <div>
+     <el-card class="box-card">
+      <div slot="header" style="height: 20px;">
+        <span style="float: left;">
+          <i class="icon icon-table2"></i>
+        </span>
+        <el-breadcrumb class="heading" style="float: left; margin-left: 5px">
+          <el-breadcrumb-item :to="{ path: '/' }">平台首页</el-breadcrumb-item>
+          <el-breadcrumb-item :to="{ path: '/system/users' }">收费管理</el-breadcrumb-item>
+        </el-breadcrumb>
+        <span style="float: right;">
+          <!--<el-button size="mini" type="primary" style="margin-left:10px; margin-top: -4px;" @click="opendatadialog(1,null,-1);resetForm('organizeform')">新增用户</el-button>-->
+        </span>
+      </div>
+       <el-button size="mini" type="primary" @click="insertsuppler" v-loading.fullscreen.lock="fullscreenLoading">导入OilSuppler</el-button>
+       <el-button size="mini" type="primary" @click="insertSupplerCert" v-loading.fullscreen.lock="fullscreenLoading">导入OilSupplerCert</el-button>
+       <el-button size="mini" type="primary" @click="updateSupplerCert" v-loading.fullscreen.lock="fullscreenLoading">更新SupplierTypeCodeAndInFlag</el-button>
+       <el-button size="mini" type="primary" @click="updateSupplerId" v-loading.fullscreen.lock="fullscreenLoading">更新Cert表的SupplierID</el-button>
+       <el-button size="mini" type="primary" @click="insterAnnualAudit" v-loading.fullscreen.lock="fullscreenLoading">导入年审表</el-button>
+       <el-button size="mini" type="primary" @click="updateAnnualAudit" v-loading.fullscreen.lock="fullscreenLoading">跟新年审表的SupplierId和CerId</el-button>
+       <el-button size="mini" type="primary" @click="updateOilSupplierCertAppend" v-loading.fullscreen.lock="fullscreenLoading">跟新OilSupplierCertAppend表的SupplierId和CerId</el-button>
+    </el-card>
+    <el-card class="box-card">
+    </el-card>
+  </div>
+</template>
+
+<script>
+  import {
+    mapGetters
+  } from 'vuex'
+  export default {
+    name: 'zcgf',
+
+    data () {
+      return {
+        fullscreenLoading: false
+
+      }
+    },
+    computed: mapGetters({
+      authUser: 'authUser'
+    }),
+    created () {
+    },
+    methods: {
+      insertsuppler () {
+        this.fullscreenLoading = true
+        this.$axios.get('tmpzcgf/insertsupplier')
+          .then(res => {
+            this.fullscreenLoading = false
+          })
+      },
+      insertSupplerCert () {
+        this.fullscreenLoading = true
+        this.$axios.get('tmpzcgf/insertsuppliercert')
+          .then(res => {
+            this.fullscreenLoading = false
+          })
+      },
+      updateSupplerCert () {
+        this.fullscreenLoading = true
+        this.$axios.get('tmpzcgf/updatecerttypeandinflag')
+          .then(res => {
+            this.fullscreenLoading = false
+          })
+      },
+      updateSupplerId () {
+        this.fullscreenLoading = true
+        this.$axios.get('tmpzcgf/updatesupplierid')
+          .then(res => {
+            this.fullscreenLoading = false
+          })
+      },
+      insterAnnualAudit () {
+        this.fullscreenLoading = true
+        this.$axios.get('tmpzcgf/insterannualaudit')
+          .then(res => {
+            this.fullscreenLoading = false
+          })
+      },
+      updateAnnualAudit () {
+        this.fullscreenLoading = true
+        this.$axios.get('tmpzcgf/updateAnnualAudit')
+          .then(res => {
+            this.fullscreenLoading = false
+          })
+      },
+      updateOilSupplierCertAppend () {
+        this.fullscreenLoading = true
+        this.$axios.get('tmpzcgf/updateOilSupplierCertAppend')
+          .then(res => {
+            this.fullscreenLoading = false
+          })
+      }
+    }
+  }
+</script>