Browse Source

add:指派任务

zoie 3 weeks ago
parent
commit
e8257086ce
5 changed files with 120 additions and 47 deletions
  1. 9 20
      conf/app.conf
  2. 51 0
      conf/app_prod.conf
  3. 10 8
      controllers/TaskData.go
  4. 44 18
      models/Task/Task.go
  5. 6 1
      models/Task/TaskData.go

+ 9 - 20
conf/app.conf

@@ -10,39 +10,28 @@ NatsServer_Url = "203.34.49.130:4222"
 
 # 存放sql临时文件目录
 Sql_Temp_Dir = "./temp/"
-
 # Redis
-Redis_address = "182.44.114.34:6379"
-Redis_password = "redis_F2tj7p"
+Redis_address = "203.34.49.130:4222"
+Redis_password = "redis_JJ56d5"
 Redis_dbNum = "2"
 
 # Mysql 本地
 Local_AliasName = "default"
-MysqlServer_UrlPort = "182.44.114.34:3306"
+MysqlServer_UrlPort = "203.34.49.130:3306"
 MysqlServer_Database = "coldverify"
-MysqlServer_Username = "root"
-MysqlServer_Password = "mysql_Ks7WAX"
+MysqlServer_Username = "coldverify"
+MysqlServer_Password = "Bd3d34yJ7aibiEi"
 MysqlServer_MaxIdleConnections = 100
 MysqlServer_MaxOpenConnections = 200
 
-# # Mysql 线上
+# Mysql 线上
 Server_AliasName = "server"
-MysqlServer2_UrlPort = "182.44.114.34:3306"
+MysqlServer2_UrlPort = "203.34.49.130:3306"
 MysqlServer2_Database = "coldverify"
-MysqlServer2_Username = "root"
-MysqlServer2_Password = "mysql_Ks7WAX"
+MysqlServer2_Username = "coldverify"
+MysqlServer2_Password = "Bd3d34yJ7aibiEi"
 MysqlServer2_MaxIdleConnections = 100
 MysqlServer2_MaxOpenConnections = 200
-
-# Mysql 1.0
-Verify1_AliasName = "Verify1"
-MysqlVerify_UrlPort = "182.44.114.34:3306"
-MysqlVerify_Database = "coldverify"
-MysqlVerify_Username = "root"
-MysqlVerify_Password = "mysql_Ks7WAX"
-MysqlVerify_MaxIdleConnections = 100
-MysqlVerify_MaxOpenConnections = 200
-
 # 静态资源
 Qiniu_AccessKey = "-8ezB_d-8-eUFTMvhOGbGzgeQRPeKQnaQ3DBcUxo"
 Qiniu_SecretKey = "KFhkYxTAJ2ZPN3ZS3euTsfWk8-C92rKgkhAMkDRN"

+ 51 - 0
conf/app_prod.conf

@@ -0,0 +1,51 @@
+appname = ColdVerify_local6400
+HTTPPort = 6400
+runmode = dev
+Graceful = true
+EnableDocs = true
+copyrequestbody = true
+
+# Nats
+NatsServer_Url = "203.34.49.130:4222"
+
+# 存放sql临时文件目录
+Sql_Temp_Dir = "./temp/"
+
+# Redis
+Redis_address = "182.44.114.34:6379"
+Redis_password = "redis_F2tj7p"
+Redis_dbNum = "2"
+
+# Mysql 本地
+Local_AliasName = "default"
+MysqlServer_UrlPort = "182.44.114.34:3306"
+MysqlServer_Database = "coldverify"
+MysqlServer_Username = "root"
+MysqlServer_Password = "mysql_Ks7WAX"
+MysqlServer_MaxIdleConnections = 100
+MysqlServer_MaxOpenConnections = 200
+
+# # Mysql 线上
+Server_AliasName = "server"
+MysqlServer2_UrlPort = "182.44.114.34:3306"
+MysqlServer2_Database = "coldverify"
+MysqlServer2_Username = "root"
+MysqlServer2_Password = "mysql_Ks7WAX"
+MysqlServer2_MaxIdleConnections = 100
+MysqlServer2_MaxOpenConnections = 200
+
+# Mysql 1.0
+Verify1_AliasName = "Verify1"
+MysqlVerify_UrlPort = "182.44.114.34:3306"
+MysqlVerify_Database = "coldverify"
+MysqlVerify_Username = "root"
+MysqlVerify_Password = "mysql_Ks7WAX"
+MysqlVerify_MaxIdleConnections = 100
+MysqlVerify_MaxOpenConnections = 200
+
+# 静态资源
+Qiniu_AccessKey = "-8ezB_d-8-eUFTMvhOGbGzgeQRPeKQnaQ3DBcUxo"
+Qiniu_SecretKey = "KFhkYxTAJ2ZPN3ZS3euTsfWk8-C92rKgkhAMkDRN"
+Qiniu_BUCKET = "bzdcoldverify"
+Oss = "https://bzdcoldverifyoss.baozhida.cn"
+

+ 10 - 8
controllers/TaskData.go

@@ -2138,6 +2138,7 @@ func (c *TaskDataController) CopyFromPositionAverageSN() {
 	}
 	var list []Task.TaskData_
 	ct := copyTime
+	CopyEndTime := ct
 	for i := 0; i < num; i++ {
 		if List1[i].T_time != List2[i].T_time {
 			c.Data["json"] = lib.JSONS{202, fmt.Sprintf("%s【%s】、%s【%s】时间不一致", List1[i].T_id, List1[i].T_time, List2[i].T_id, List2[i].T_time), nil}
@@ -2155,10 +2156,11 @@ func (c *TaskDataController) CopyFromPositionAverageSN() {
 			T_rh:   T_rh,
 			T_time: ct.Format("2006-01-02 15:04"),
 		})
+		CopyEndTime = ct
 		ct = ct.Add(time.Second * time.Duration(T_saveT))
 	}
 
-	//Task.DeleteTaskDataByTimeRange(Task_r.T_task_id, CopySN, CopyID, CopyTime, CopyEndTime)
+	Task.DeleteTaskDataByTimeRange(Task_r.T_task_id, CopySN, CopyID, CopyTime, CopyEndTime.Format("2006-01-02 15:04"))
 
 	go func(TaskDataList []Task.TaskData_, task_id string) {
 		for _, taskData := range TaskDataList {
@@ -6338,8 +6340,8 @@ func (c *TaskDataController) A风机布点总测点() {
 	c.Ctx.ResponseWriter.Header().Set("Cache-Control", "no-cache")
 	c.Ctx.ResponseWriter.Header().Set("Connection", "keep-alive")
 
-	一号风机测点 := c.GetString("1号风机测点")     //  v26nplogbwt1
-	二号风机测点 := c.GetString("2号风机测点")     //  v26nplogbwt1
+	一号风机测点 := c.GetString("1号风机测点")   //  v26nplogbwt1
+	二号风机测点 := c.GetString("2号风机测点")   //  v26nplogbwt1
 	一号风机回风口 := c.GetString("1号风机回风口") //  v26nplogbwt1
 	二号风机回风口 := c.GetString("2号风机回风口") //  v26nplogbwt1
 
@@ -6367,7 +6369,7 @@ func (c *TaskDataController) A库内除风机出风口回风口外总测点() {
 	c.Ctx.ResponseWriter.Header().Set("Cache-Control", "no-cache")
 	c.Ctx.ResponseWriter.Header().Set("Connection", "keep-alive")
 
-	库内所有测点 := c.GetString("库内所有测点")     //  v26nplogbwt1
+	库内所有测点 := c.GetString("库内所有测点")   //  v26nplogbwt1
 	风机布点总测点 := c.GetString("风机布点总测点") //  v26nplogbwt1
 
 	parts1 := strings.Split(库内所有测点, "|")
@@ -6398,9 +6400,9 @@ func (c *TaskDataController) A库内除风机出风口回风口特殊位置布
 	c.Ctx.ResponseWriter.Header().Set("Cache-Control", "no-cache")
 	c.Ctx.ResponseWriter.Header().Set("Connection", "keep-alive")
 
-	库内所有测点 := c.GetString("库内所有测点")                                           //  v26nplogbwt1
-	风机布点总测点 := c.GetString("风机布点总测点")                                       //  v26nplogbwt1
-	作业出入口总测点 := c.GetString("作业出入口总测点")                                   //  v26nplogbwt1
+	库内所有测点 := c.GetString("库内所有测点")                       //  v26nplogbwt1
+	风机布点总测点 := c.GetString("风机布点总测点")                     //  v26nplogbwt1
+	作业出入口总测点 := c.GetString("作业出入口总测点")                   //  v26nplogbwt1
 	照明灯除湿机风幕机等特殊区域测点 := c.GetString("照明灯、除湿机、风幕机等特殊区域测点") //  v26nplogbwt1
 
 	parts1 := strings.Split(strings.Trim(库内所有测点, "|"), "|")
@@ -6439,7 +6441,7 @@ func (c *TaskDataController) A车内除风机出风口回风口外总测点() {
 	c.Ctx.ResponseWriter.Header().Set("Cache-Control", "no-cache")
 	c.Ctx.ResponseWriter.Header().Set("Connection", "keep-alive")
 
-	车内所有测点 := c.GetString("车内所有测点")     //  v26nplogbwt1
+	车内所有测点 := c.GetString("车内所有测点")   //  v26nplogbwt1
 	风机布点总测点 := c.GetString("风机布点总测点") //  v26nplogbwt1
 
 	parts1 := strings.Split(车内所有测点, "|")

+ 44 - 18
models/Task/Task.go

@@ -20,22 +20,24 @@ type Task struct {
 	T_InfoCollection_id string `orm:"size(256);null"`       // 信息采集ID
 	T_InfoTemplate_id   string `orm:"size(256);null"`       // 信息采集模版ID
 
-	T_task_id              string `orm:"size(256);null"`     // 任务ID
-	T_uuid                 string `orm:"size(256);null"`     // 用户 UUID
-	T_name                 string `orm:"size(256);null"`     // 标题
-	T_VerifyTemplate_class string `orm:"size(256);null"`     // 模版id
-	T_VerifyTemplate_id    string `orm:"size(256);null"`     // 模版id
-	T_deadline             string `orm:"size(256);null"`     // 截止时间
-	T_scheme               string `orm:"size(256);null"`     // 实施方案 负责人UUID
-	T_collection           string `orm:"size(256);null"`     // 数据采集 负责人UUID
-	T_reporting            string `orm:"size(256);null"`     // 报告编写 负责人UUID
-	T_delivery             string `orm:"size(256);null"`     // 交付审核 负责人UUID
-	T_scheme_state         int    `orm:"size(2);default(0)"` // 实施方案 状态 0 未完成 1 已完成(客户通过) 2已退回(客户) 3已通过(负责人) 4已退回(负责人) 5已提交
-	T_collection_state     int    `orm:"size(2);default(0)"` // 数据采集 状态 0 未完成 1 数据来源已完成 2 处理中 3 已采集-无数据 4-数据编辑已完成(已提交) 5已通过(负责人) 6已退回(负责人)
-	T_reporting_state      int    `orm:"size(2);default(0)"` // 报告编写 状态 0 未完成 1 已完成(客户通过) 2已退回(客户) 3已通过(负责人) 4已退回(负责人) 5已提交
-	T_delivery_state       int    `orm:"size(2);default(0)"` // 交付审核 状态 0 未完成 1 已完成 2 处理中
-	T_marking_state        int    `orm:"size(2);default(0)"` // 验证标识 状态 0 未完成 1 已完成
-	T_record               string `orm:"type(text)"`         // 领导备注
+	T_task_id                string `orm:"size(256);null"`     // 任务ID
+	T_uuid                   string `orm:"size(256);null"`     // 用户 UUID
+	T_name                   string `orm:"size(256);null"`     // 标题
+	T_VerifyTemplate_class   string `orm:"size(256);null"`     // 模版id
+	T_VerifyTemplate_id      string `orm:"size(256);null"`     // 模版id
+	T_deadline               string `orm:"size(256);null"`     // 截止时间
+	T_scheme                 string `orm:"size(256);null"`     // 实施方案 负责人UUID
+	T_collection             string `orm:"size(256);null"`     // 数据采集 负责人UUID
+	T_reporting              string `orm:"size(256);null"`     // 报告编写 负责人UUID
+	T_delivery               string `orm:"size(256);null"`     // 交付审核 负责人UUID
+	T_scheme_state           int    `orm:"size(2);default(0)"` // 实施方案 状态 0 未完成 1 已完成(客户通过) 2已退回(客户) 3已通过(负责人) 4已退回(负责人) 5已提交
+	T_collection_state       int    `orm:"size(2);default(0)"` // 数据采集 状态 0 未完成 1 数据来源已完成 2 数据来源处理中 3 已采集-无数据 4-APP已提交 5已通过(负责人) 6已退回(负责人)
+	T_reporting_state        int    `orm:"size(2);default(0)"` // 报告编写 状态 0 未完成 1 已完成(客户通过) 2已退回(客户) 3已通过(负责人) 4已退回(负责人) 5已提交
+	T_delivery_state         int    `orm:"size(2);default(0)"` // 交付审核 状态 0 未完成 1 已完成 2 处理中
+	T_marking_state          int    `orm:"size(2);default(0)"` // 验证标识 状态 0 未完成 1 已完成
+	T_examining_report_state int    `orm:"size(2);default(0)"` // 检测报告 状态 0 未完成 1 已完成(客户通过) 2已退回(客户) 3已通过(负责人) 4已退回(负责人) 5已提交
+	T_original_record_state  int    `orm:"size(2);default(0)"` // 原始记录 状态 0 未完成 3 已通过(负责人) 4已退回(负责人) 5已提交
+	T_record                 string `orm:"type(text)"`         // 领导备注
 
 	T_VerifyDeviceDataStartTime string `orm:"size(256);null"` // 验证设备数据开始时间
 	T_VerifyDeviceDataEndTime   string `orm:"size(256);null"` // 验证设备数据开始时间
@@ -45,12 +47,17 @@ type Task struct {
 	T_doc1           string `orm:"type(text);null"` // 封面
 	T_pdf1           string `orm:"type(text);null"` // 验证方案
 	T_pdf1_watermark string `orm:"type(text);null"` // 验证方案 带水印
+	T_pdf1_signature string `orm:"type(text);null"` // 验证方案 带公章
 	T_doc2           string `orm:"type(text);null"` // 报告
 	T_pdf2           string `orm:"type(text);null"` // 验证报告
 	T_pdf2_watermark string `orm:"type(text);null"` // 验证报告 带水印
+	T_pdf2_signature string `orm:"type(text);null"` // 验证报告 带公章
 	T_doc3           string `orm:"type(text);null"` // 证书
 	T_pdf3           string `orm:"type(text);null"` // 证书
 	T_pdf4           string `orm:"type(text);null"` // 验证标识
+	T_pdf5           string `orm:"type(text);null"` // 检测报告
+	T_pdf5_watermark string `orm:"type(text);null"` // 检测报告 带水印
+	T_pdf6           string `orm:"type(text);null"` // 原始记录
 
 	T_Show  int `orm:"size(2);default(1)"`   // 0 隐藏   1 公开
 	T_Visit int `orm:"size(200);default(0)"` // 浏览量
@@ -112,8 +119,27 @@ type Task struct {
 	T_reporting_audit_record  string  `orm:"type(text);null"` // 验证报告审核记录
 	T_reporting_pass_time     string  `orm:"size(256);null"`  // 验证报告负责人通过时间
 
-	T_device_quantity int `orm:"size(20);default(0)"` //  终端数量 T_device_type=WZ 必填
-	T_cnas            int `orm:"size(20);default(0)"` //  cnas实验室
+	// 检测报告
+	T_examining_report_start_time    string  `orm:"size(256);null"`  // 检测报告开始时间 接收信息采集表的时间
+	T_examining_report_end_time      string  `orm:"size(256);null"`  // 检测报告结束时间 负责人审核通过前最后一次上传时间
+	T_examining_report_time_interval float64 `orm:"size(256);null"`  // 时间间隔 单位分钟
+	T_examining_report_signature     string  `orm:"type(text)"`      // 检测报告客户签字确认图片
+	T_examining_report_return_times  int     `orm:"size(256);null"`  // 检测报告退回次数
+	T_examining_report_audit_record  string  `orm:"type(text);null"` // 检测报告审核记录
+
+	// 原始记录
+	T_original_record_start_time    string  `orm:"size(256);null"`  // 原始记录开始时间 接收信息采集表的时间
+	T_original_record_end_time      string  `orm:"size(256);null"`  // 原始记录结束时间 负责人审核通过前最后一次上传时间
+	T_original_record_time_interval float64 `orm:"size(256);null"`  // 时间间隔 单位分钟
+	T_original_record_signature     string  `orm:"type(text)"`      // 原始记录客户签字确认图片
+	T_original_record_return_times  int     `orm:"size(256);null"`  // 原始记录退回次数
+	T_original_record_audit_record  string  `orm:"type(text);null"` // 原始记录审核记录
+
+	T_device_quantity int `orm:"size(20);default(0)"`  //  终端数量 T_device_type=WZ 必填
+	T_cnas            int `orm:"size(256);default(0)"` // 0-否 1-是
+
+	T_cover  int    `orm:"size(20);default(0)"` // 是否覆盖询问
+	T_backup string `orm:"size(256);null"`      // 历史数据记录
 
 	CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now_add 第一次保存时才设置时间
 	UpdateTime time.Time `orm:"column(update_time);type(timestamp);null;auto_now"`     //auto_now 每次 model 保存时都会对时间自动更新

+ 6 - 1
models/Task/TaskData.go

@@ -1210,7 +1210,12 @@ func DeleteTaskDataByTimeRange(T_task_id, sn string, id string, startTime, endTi
 		sqlStatement += " AND t_time >='" + startTime + "'"
 	}
 	if len(endTime) > 0 {
-		sqlStatement += " AND t_time <= '" + endTime + "'"
+		et, ok := lib.TimeStrToTime(endTime)
+		if ok {
+			ets := et.Format("2006-01-02 15:04") + ":59"
+			sqlStatement += " AND t_time <= '" + ets + "'"
+		}
+
 	}
 	o := orm.NewOrm()
 	exec, err := o.Raw(sqlStatement).Exec()