From 04b8eff075a04db23e6f908855699b4d2954588c Mon Sep 17 00:00:00 2001
From: yyt <306727702@qq.com>
Date: 星期四, 23 五月 2024 18:47:01 +0800
Subject: [PATCH] 380新产品,优化

---
 jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/controller/DaOpcuaConfigController.java |  112 ++++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 81 insertions(+), 31 deletions(-)

diff --git a/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/controller/DaOpcuaConfigController.java b/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/controller/DaOpcuaConfigController.java
index 0c74d37..b94f8f4 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/controller/DaOpcuaConfigController.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/controller/DaOpcuaConfigController.java
@@ -1,26 +1,40 @@
 package com.jcdm.main.da.opcuaconfig.controller;
 
+import java.util.List;
+import javax.servlet.http.HttpServletResponse;
+
+import com.jcdm.main.da.opcuaconfig.domain.DaOpcuaConfig;
+import com.jcdm.main.da.opcuaconfig.domain.NodeEntity;
+import com.jcdm.main.da.opcuaconfig.service.IDaOpcuaConfigService;
+import com.jcdm.main.da.paramCollection.domain.DaParamCollection;
+import com.jcdm.main.da.paramCollection.mapper.DaParamCollectionMapper;
+import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService;
+import com.jcdm.main.plcserver.sub.OPCUaSubscription;
+import com.kangaroohy.milo.model.ReadWriteEntity;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
 import com.jcdm.common.annotation.Log;
 import com.jcdm.common.core.controller.BaseController;
 import com.jcdm.common.core.domain.AjaxResult;
-import com.jcdm.common.core.page.TableDataInfo;
 import com.jcdm.common.enums.BusinessType;
 import com.jcdm.common.utils.poi.ExcelUtil;
-import com.jcdm.main.da.opcuaconfig.domain.DaOpcuaConfig;
-import com.jcdm.main.da.opcuaconfig.service.IDaOpcuaConfigService;
-import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.security.access.prepost.PreAuthorize;
-import org.springframework.web.bind.annotation.*;
+import com.jcdm.common.core.page.TableDataInfo;
 
-import javax.servlet.http.HttpServletResponse;
-import java.util.List;
+import static com.jcdm.main.plcserver.sub.OPCUaSubscription.miloService;
 
 /**
- * OPCUA鍙傛暟璁剧疆Controller
+ * 浜や簰淇″彿閰嶇疆Controller
  * 
  * @author yyt
- * @date 2023-12-22
+ * @date 2024-01-23
  */
 @RestController
 @RequestMapping("/da/opcuaconfig")
@@ -28,12 +42,10 @@
 {
     @Autowired
     private IDaOpcuaConfigService daOpcuaConfigService;
-
-    @Autowired
     private IDaParamCollectionService daParamCollectionService;
 
     /**
-     * 鏌ヨOPCUA鍙傛暟璁剧疆鍒楄〃
+     * 鏌ヨ浜や簰淇″彿閰嶇疆鍒楄〃
      */
     @PreAuthorize("@ss.hasPermi('da:opcuaconfig:list')")
     @GetMapping("/list")
@@ -44,28 +56,21 @@
         return getDataTable(list);
     }
 
-    @PreAuthorize("@ss.hasPermi('da:opcuaconfig:getconfig')")
-    @GetMapping("/getconfig")
-    public List<DaOpcuaConfig> getconfig(DaOpcuaConfig daOpcuaConfig)
-    {
-        return daOpcuaConfigService.selectDaOpcuaConfigList(daOpcuaConfig);
-    }
-
     /**
-     * 瀵煎嚭OPCUA鍙傛暟璁剧疆鍒楄〃
+     * 瀵煎嚭浜や簰淇″彿閰嶇疆鍒楄〃
      */
     @PreAuthorize("@ss.hasPermi('da:opcuaconfig:export')")
-    @Log(title = "OPCUA鍙傛暟璁剧疆", businessType = BusinessType.EXPORT)
+    @Log(title = "浜や簰淇″彿閰嶇疆", businessType = BusinessType.EXPORT)
     @PostMapping("/export")
     public void export(HttpServletResponse response, DaOpcuaConfig daOpcuaConfig)
     {
         List<DaOpcuaConfig> list = daOpcuaConfigService.selectDaOpcuaConfigList(daOpcuaConfig);
         ExcelUtil<DaOpcuaConfig> util = new ExcelUtil<DaOpcuaConfig>(DaOpcuaConfig.class);
-        util.exportExcel(response, list, "OPCUA鍙傛暟璁剧疆鏁版嵁");
+        util.exportExcel(response, list, "浜や簰淇″彿閰嶇疆鏁版嵁");
     }
 
     /**
-     * 鑾峰彇OPCUA鍙傛暟璁剧疆璇︾粏淇℃伅
+     * 鑾峰彇浜や簰淇″彿閰嶇疆璇︾粏淇℃伅
      */
     @PreAuthorize("@ss.hasPermi('da:opcuaconfig:query')")
     @GetMapping(value = "/{id}")
@@ -75,10 +80,10 @@
     }
 
     /**
-     * 鏂板OPCUA鍙傛暟璁剧疆
+     * 鏂板浜や簰淇″彿閰嶇疆
      */
     @PreAuthorize("@ss.hasPermi('da:opcuaconfig:add')")
-    @Log(title = "OPCUA鍙傛暟璁剧疆", businessType = BusinessType.INSERT)
+    @Log(title = "浜や簰淇″彿閰嶇疆", businessType = BusinessType.INSERT)
     @PostMapping
     public AjaxResult add(@RequestBody DaOpcuaConfig daOpcuaConfig)
     {
@@ -86,10 +91,10 @@
     }
 
     /**
-     * 淇敼OPCUA鍙傛暟璁剧疆
+     * 淇敼浜や簰淇″彿閰嶇疆
      */
     @PreAuthorize("@ss.hasPermi('da:opcuaconfig:edit')")
-    @Log(title = "OPCUA鍙傛暟璁剧疆", businessType = BusinessType.UPDATE)
+    @Log(title = "浜や簰淇″彿閰嶇疆", businessType = BusinessType.UPDATE)
     @PutMapping
     public AjaxResult edit(@RequestBody DaOpcuaConfig daOpcuaConfig)
     {
@@ -97,13 +102,58 @@
     }
 
     /**
-     * 鍒犻櫎OPCUA鍙傛暟璁剧疆
+     * 鍒犻櫎浜や簰淇″彿閰嶇疆
      */
     @PreAuthorize("@ss.hasPermi('da:opcuaconfig:remove')")
-    @Log(title = "OPCUA鍙傛暟璁剧疆", businessType = BusinessType.DELETE)
+    @Log(title = "浜や簰淇″彿閰嶇疆", businessType = BusinessType.DELETE)
 	@DeleteMapping("/{ids}")
     public AjaxResult remove(@PathVariable Long[] ids)
     {
         return toAjax(daOpcuaConfigService.deleteDaOpcuaConfigByIds(ids));
     }
+
+    /**
+     * 鑾峰彇浜や簰淇″彿閰嶇疆璇︾粏淇℃伅
+     */
+    @PreAuthorize("@ss.hasPermi('da:opcuaconfig:query')")
+    @GetMapping(value = "/SNCode/{SNCode}/{locationCode}")
+    public AjaxResult setSNCode(@PathVariable("SNCode") String SNCode,@PathVariable("locationCode") String locationCode) {
+        ReadWriteEntity entity = new ReadWriteEntity("CFL4HX."+locationCode+".SNCode", SNCode);
+        Boolean out= true;
+        try {
+            miloService.writeToOpcUa(entity);//鍐橲N
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+        return toAjax(out);
+    }
+
+    /**
+     * 閰嶇摝鎵爜
+     */
+    @PreAuthorize("@ss.hasPermi('da:opcuaconfig:query')")
+    @GetMapping(value = "/barcode/{barcode}/{locationCode}")
+    public AjaxResult setBarcode(@PathVariable("barcode") String barcode,@PathVariable("locationCode") String locationCode) {
+        Boolean out= true;
+        try {
+            Object SNCodeObject = miloService.readFromOpcUa("CFL4HX."+locationCode+".Code1").getValue();
+            if (null == SNCodeObject){
+                SNCodeObject = miloService.readFromOpcUa("CFL4HX."+locationCode+ ".Code").getValue();
+            }
+            if (null != SNCodeObject){
+                String SNCode = SNCodeObject.toString();
+                //鎻掑叆鏁版嵁
+                DaParamCollection saveData = new DaParamCollection();
+                saveData.setSfcCode(SNCode);
+                saveData.setParamValue(barcode);
+                saveData.setLocationCode(locationCode);
+                saveData.setParamCode("XTM");
+                saveData.setParamName("鏇茶酱鐮�");
+                daParamCollectionService.insertDaParamCollection(saveData);
+            }
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+        return toAjax(out);
+    }
 }

--
Gitblit v1.9.3