Browse Source

ctx用updateUser

yangwanyi 3 years ago
parent
commit
becca809e8

+ 2 - 1
src/main/java/com/persagy/transfer/service/IWdDbService.java

@@ -26,11 +26,12 @@ public interface IWdDbService {
      * @param valid            项目数据对象状态:1有效,0无效
      * @param updateTime       项目最后更新时间
      * @param classstrucrureid 万达设备分类ID
+     * @param updateUser 更新人
      * @author YangWanYi
      * @describe 万达设备信息对象数据同步
      * @date 2021/9/16 16:00
      */
-    void sycnHydomcAsset(JSONObject infosObj, String wdProjectId, HydomcAsset hydomcAsset, Integer valid, java.util.Date updateTime, String classstrucrureid);
+    void sycnHydomcAsset(JSONObject infosObj, String wdProjectId, HydomcAsset hydomcAsset, Integer valid, java.util.Date updateTime, String classstrucrureid, String updateUser);
 
     /**
      * @param wdfacilityRelList 筛选后的万达设备参数信息表与博锐尚格信息点的映射表数据

+ 1 - 1
src/main/java/com/persagy/transfer/service/impl/PersagyDbServiceImpl.java

@@ -113,7 +113,7 @@ public class PersagyDbServiceImpl implements IPersagyDbService {
             infosObj = JSONObject.parseObject(rwdObjectWd.getInfos());
             if (infosObj != null && !infosObj.isEmpty()) {
                 /*万达设备信息对象数据同步*/
-                this.wdDbService.sycnHydomcAsset(infosObj, wdprojRelPersagyproj.getWdProjectid(), hydomcAsset, rwdObjectWd.getValid(), rwdObjectWd.getUpdateTime(), wdclassRelPersagy.getClassstructureid());
+                this.wdDbService.sycnHydomcAsset(infosObj, wdprojRelPersagyproj.getWdProjectid(), hydomcAsset, rwdObjectWd.getValid(), rwdObjectWd.getUpdateTime(), wdclassRelPersagy.getClassstructureid(),rwdObjectWd.getUpdateUser());
                 /*万达设备参数信息数据同步*/
                 if (wdfacilityRelList == null) { // 循环万达项目ID与博锐尚格项目ID映射表数据时,wdfacility_rel_persagy只查询一次
                     wdfacilityRelList = this.listWdfacilityRelPersagy(wdclassRelPersagy.getWdClassCode(), wdclassRelPersagy.getClassstructureid());

+ 4 - 3
src/main/java/com/persagy/transfer/service/impl/WdDbServiceImpl.java

@@ -54,12 +54,13 @@ public class WdDbServiceImpl implements IWdDbService {
      * @param valid            项目数据对象状态:1有效,0无效
      * @param updateTime       项目最后更新时间
      * @param classstrucrureid 万达设备分类ID
+     * @param updateUser       更新人
      * @author YangWanYi
      * @describe 万达设备信息对象数据同步
      * @date 2021/9/16 16:00
      */
     @DS(value = SwitchConstant.DS_MASTER_2)
-    public void sycnHydomcAsset(JSONObject infosObj, String wdProjectId, HydomcAsset hydomcAsset, Integer valid, java.util.Date updateTime, String classstrucrureid) {
+    public void sycnHydomcAsset(JSONObject infosObj, String wdProjectId, HydomcAsset hydomcAsset, Integer valid, java.util.Date updateTime, String classstrucrureid, String updateUser) {
         log.debug("准备同步万达设备信息对象数据");
         // 根据万达设备信息表的主键查询数据是否存在
         hydomcAsset = this.getHydomcAssetByPKey(StringTool.object2String(infosObj.get(InfosKeyConstant.EQUIPMENT_CODE)));
@@ -98,7 +99,7 @@ public class WdDbServiceImpl implements IWdDbService {
             hydomcAsset.setDatastatus(valid == 0 ? SwitchConstant.IS_DELETE : SwitchConstant.IS_UPDATE); // 数据状态 update/delete 当数据状态为delete时,设备状态需改为报废
             hydomcAsset.setChangedate(updateTime); // 数据更新时间 增量字段
             // 新增一个ctx字段 变更人员的万信账号
-            hydomcAsset.setCtx("数据从哪儿来");
+            hydomcAsset.setCtx(updateUser);
             this.hydomcAssetMapper.insert(hydomcAsset);
         } else {
             UpdateWrapper<HydomcAsset> updateWrapper = new UpdateWrapper<>();
@@ -140,7 +141,7 @@ public class WdDbServiceImpl implements IWdDbService {
                 updateWrapper.set("siteid", wdProjectId); // 项目唯一id,可采用租赁系统广场id,同步后不可更改
                 updateWrapper.set("datastatus", SwitchConstant.IS_UPDATE); // 数据状态 update/delete 当数据状态为delete时,设备状态需改为报废
             }
-            updateWrapper.set("ctx", "数据从哪儿来"); // 新增一个ctx字段 变更人员的万信账号
+            updateWrapper.set("ctx", updateUser); // 新增一个ctx字段 变更人员的万信账号
             updateWrapper.set("changedate", updateTime); // 数据更新时间 增量字段
             this.hydomcAssetMapper.update(hydomcAsset, updateWrapper);
         }