20230105, huli mysql command_queue add import_id

指令入队节点/PushCommand.py

@@ -190,9 +190,9 @@ class DBCommand():
                     time_mns=diff.total_seconds()/60
                     queue_id=int(last_num+1+ time_mns*1)
 
-                SQL="insert into command_queue values('%s','%s',%d,%d,1,0,NULL,'%s',%d)"%(
+                SQL="insert into command_queue values('%s','%s',%d,%d,1,0,NULL,'%s',NULL, NULL)"%(
                     cmd.car_number,cmd.primary_key,cmd.unit_id,queue_id
-                    ,tf.MessageToString(cmd.entrance_measure_info,as_utf8=True),cmd.unit_id)
+                    ,tf.MessageToString(cmd.entrance_measure_info,as_utf8=True) )
                 cursor.execute(SQL)
                 #更新指令时间表，
                 dt=datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
@@ -278,7 +278,7 @@ class DBCommand():
                             time_mns=diff.total_seconds()/60
                             queue_id=int(last_num+1+ time_mns*1)
 
-                        SQL="insert into command_queue values('%s','%s',%d,%d,2,0,'%s','%s',NULL)"%(
+                        SQL="insert into command_queue values('%s','%s',%d,%d,2,0,'%s','%s',NULL, NULL)"%(
                             cmd.car_number,cmd.primary_key,unit_id,queue_id,tf.MessageToString(cmd.actually_space_info,as_utf8=True)
                             ,tf.MessageToString(cmd.actually_measure_info,as_utf8=True))
                         cursor.execute(SQL)