加入定时任务，启动时打固定点 ，并且加入工位数据缓存

yangys

2024-09-02 a33c33d48c2c16995130b825355b6883be4eb159

 collect/src/main/java/com/qianwen/mdc/collect/controller/MqttController.java

@@ -53,38 +53,11 @@
    public void testRec2() {
       //数据格式：{"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174是应用id
       //多条格式：{"174":[{"values":{"DeviceStatus":2},"ts":"1722478128278"},{"values":{"spindleSpeed":22},"ts":"1722478128281"}]}
       String payload = "{\"174\":[{\"values\":{\"DeviceStatus\":2,\"Output\":34},\"ts\":\"1721978780449\"}]}";
       String payload = "{\"174\":[{\"values\":{\"DeviceStatus\":2,\"Output\":34},\"ts\":\"1725247557768\"}]}";
       //payload = "{\"174\":[{\"values\":{\"Output\":11},\"ts\":\"1722478128278\"},{\"values\":{\"SpindleSpeed\":22},\"ts\":\"1722478128281\"}]}";
       recService.handle(payload);
    }
    @GetMapping("/rec")
    public void testRec() {
       ////数据格式：{"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174是应用id
       //多条格式：{"174":[{"values":{"output":11},"ts":"1722478128278"},{"values":{"spindleSpeed":22},"ts":"1722478128281"}]}
       String payload = "{\"174\":[{\"values\":{\"output\":12},\"ts\":\"1721978780449\"}]}";
    	
       JSONObject jsonObj = JSONObject.parseObject(payload);
      //数据格式：{"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174是应用id
      Set<String> keys = jsonObj.keySet();
      String appId = keys.toArray(new String[] {})[0];
      JSONArray dtArr = jsonObj.getJSONArray(appId);
      JSONObject data = dtArr.getJSONObject(0);
      long time = data.getLong("ts");
      String output = data.getJSONObject("values").getString("output");
       //AggrgateData ad = recService.fillFactoryData(payload);
    	
       List<String> fields = new ArrayList<>();
       List<String> values = new ArrayList<>();
       //long time = System.currentTimeMillis();
       fields.add("output");
       fields.add("factory_year");
       fields.add("factory_month");
       fields.add("factory_date");//INT64, INT64,factory_date INT64,factory_week
       values.add(output);
    	
    	
       //iotdbCfg.insertRecord("root.qa.myoutput_"+ad.getWorkstationId(), time, fields, values);
    }
    
    
    @GetMapping("/tpl")
    public Object tpl(String tplname) throws StatementExecutionException, IoTDBConnectionException {