水量调度计划更新失败则删除相应指令工单

src/main/java/com/shkpr/service/aimodelpower/constants/LogFlagBusiType.java

@@ -147,6 +147,7 @@ public enum  LogFlagBusiType {
     BUSI_DB_WARN_REPORT_PUSH_REQ_LINK(174,"DB Warn Report Push Req Link"),
     BUSI_DB_WARN_TYPE_DICT_MGR(175,"DB Warn Type Dict Mgr"),
     BUSI_DB_WO_DISPATCH_PLAN(176,"DB WO Dispatch Info"),
+    BUSI_DB_WO_DISPATCH_CMD_INFO(177,"DB WO Dispatch Cmd Info"),
 
     BUSI_CHILD_DB_TAP_WATER(176,"DB TAP WATER Mgr"),
 

src/main/java/com/shkpr/service/aimodelpower/dbdao/mapper/WODispatchCmdInfoMapper.java

@@ -0,0 +1,12 @@
+package com.shkpr.service.aimodelpower.dbdao.mapper;
+
+import com.shkpr.service.aimodelpower.dbdao.providers.WODispatchCmdInfoSqlProvider;
+import org.apache.ibatis.annotations.DeleteProvider;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface WODispatchCmdInfoMapper {
+    @DeleteProvider(type = WODispatchCmdInfoSqlProvider.class, method = "deleteInIds")
+    int batchDeleteIn(@Param("ids") List<? extends Object> ids, @Param("extend") String extend);
+}

src/main/java/com/shkpr/service/aimodelpower/dbdao/providers/WODispatchCmdInfoSqlProvider.java

@@ -0,0 +1,43 @@
+package com.shkpr.service.aimodelpower.dbdao.providers;
+
+import com.shkpr.service.aimodelpower.dbdao.tables.WODispatchCmdInfoTable;
+
+public class WODispatchCmdInfoSqlProvider extends BaseSqlProvider implements WODispatchCmdInfoTable {
+    @Override
+    public String getRTableName() { return R_INFO.TABLE;}
+
+    @Override
+    public String getWTableName() {
+        return W_INFO.TABLE;
+    }
+
+    @Override
+    public String getRUniqueId() {
+        return R_INFO.UNIQUE_ID;
+    }
+
+    @Override
+    public String getWUniqueId() {
+        return W_INFO.UNIQUE_ID;
+    }
+
+    @Override
+    public String getSAllFiled() {
+        return R_INFO.ALL_FILED;
+    }
+
+    @Override
+    public String getRPrimaryKey() {
+        return R_INFO.PRIMARY_KEY;
+    }
+
+    @Override
+    public String getWPrimaryKey() {
+        return W_INFO.PRIMARY_KEY;
+    }
+
+    @Override
+    public boolean isWJsonForFiled(String filedName) {
+        return false;
+    }
+}

src/main/java/com/shkpr/service/aimodelpower/dbdao/services/WODispatchCmdInfoDBServiceImpl.java

@@ -0,0 +1,88 @@
+package com.shkpr.service.aimodelpower.dbdao.services;
+
+import com.global.base.log.LogLevelFlag;
+import com.global.base.log.LogPrintMgr;
+import com.shkpr.service.aimodelpower.commtools.CommTool;
+import com.shkpr.service.aimodelpower.constants.LogFlagBusiType;
+import com.shkpr.service.aimodelpower.dbdao.mapper.WODispatchCmdInfoMapper;
+import com.shkpr.service.aimodelpower.dbdao.services.intef.WODispatchCmdInfoDBService;
+import com.shkpr.service.aimodelpower.dbdao.tables.WODispatchCmdInfoTable;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class WODispatchCmdInfoDBServiceImpl implements WODispatchCmdInfoDBService,WODispatchCmdInfoTable{
+    private String mStrClassName = "";
+    private String mBusinessType = "";
+    private String logTag = "";
+    public WODispatchCmdInfoDBServiceImpl() {
+        mStrClassName = this.getClass().getSimpleName();
+        mBusinessType = LogFlagBusiType.BUSI_DB_WO_DISPATCH_CMD_INFO.toStrValue();
+        logTag = "Dispatch Cmd Info";
+    }
+
+    @SuppressWarnings("all")
+    @Autowired
+    WODispatchCmdInfoMapper woDispatchCmdInfoMapper;
+
+    @Override
+    public List<Map<String, Object>> listAllWiths(int limit, int offset, Map<String, Object> andWheres, Map<String, Object> orWheres, String orderBy, String extend) {
+        return null;
+    }
+
+    @Override
+    public List<Map<String, Object>> batchQueryIn(List<?> ids, String orderBy, String extend) {
+        return null;
+    }
+
+    @Override
+    public List<Map<String, Object>> batchQueryWiths(Map<String, Object> andWheres, Map<String, Object> orWheres, String orderBy, String extend) {
+        return null;
+    }
+
+    @Override
+    public int totalCounts(Map<String, Object> andWheres, Map<String, Object> orWheres) {
+        return 0;
+    }
+
+    @Override
+    public Map<String, Object> getOne(Object id) {
+        return null;
+    }
+
+    @Override
+    public int insertByMap(Map<String, Object> maps) {
+        return 0;
+    }
+
+    @Override
+    public int updateWiths(Map<String, Object> datas, Map<String, Object> andWheres) {
+        return 0;
+    }
+
+    @Override
+    public int delete(Object id) {
+        return 0;
+    }
+
+    @Override
+    public int batchDeleteIn(List<?> ids, String extend) {
+        int nCode = 0;
+        String strMsg = "Success";
+        try {
+            return woDispatchCmdInfoMapper.batchDeleteIn(ids, extend);
+        }catch (Exception e){
+            nCode = LogLevelFlag.LOG_ERROR.ordinal();
+            strMsg = e.getLocalizedMessage();
+            return -1;
+        }finally {
+            LogPrintMgr.getInstance().printLogMsg(LogLevelFlag.valueFromInt(nCode)
+                    , mBusinessType
+                    , mStrClassName
+                    , String.format("Batch Delete %s Lines:{lines=%d} from database, code:{%d} msg:{%s} ...", logTag, CommTool.listSize(ids), nCode, strMsg));
+        }
+    }
+}

src/main/java/com/shkpr/service/aimodelpower/dbdao/services/intef/WODispatchCmdInfoDBService.java

@@ -0,0 +1,4 @@
+package com.shkpr.service.aimodelpower.dbdao.services.intef;
+
+public interface WODispatchCmdInfoDBService extends BaseDBService{
+}

src/main/java/com/shkpr/service/aimodelpower/dbdao/tables/WODispatchCmdInfoTable.java

@@ -0,0 +1,22 @@
+package com.shkpr.service.aimodelpower.dbdao.tables;
+
+public interface WODispatchCmdInfoTable {
+    interface R_INFO{
+        String BASE_FILED = "*";
+        String TABLE = "v_k3_wws_dispatch_order_info";
+        String EVENT_LINK_ORDER = "v_k3_wws_dispatch_event_link_order";
+        String ORDER_TRRIGER_DATA = "v_k3_wws_dispatch_order_trigger_data";
+        String PRIMARY_KEY = "uid";
+        String ALL_FILED = "*";
+        String UNIQUE_ID = "uid";
+        String KIND = "kind";
+    }
+
+    interface W_INFO{
+        String ID = "id";
+        String TABLE = "k3_wws_dispatch_order_info";
+        String PRIMARY_KEY = "uid";
+        String UNIQUE_ID = "uid";
+        String KIND = "kind";
+    }
+}

src/main/java/com/shkpr/service/aimodelpower/dto/DispatchCmdTaskRsp.java

@@ -0,0 +1,15 @@
+package com.shkpr.service.aimodelpower.dto;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class DispatchCmdTaskRsp {
+    String code = "";
+    String uid = "";
+    long okTime = 0L;
+
+    public DispatchCmdTaskRsp() {
+    }
+}

src/main/java/com/shkpr/service/aimodelpower/dto/DispatchCmdTaskRspGroup.java

@@ -0,0 +1,7 @@
+package com.shkpr.service.aimodelpower.dto;
+
+public class DispatchCmdTaskRspGroup extends TRecordRes<DispatchCmdTaskRsp> {
+    public DispatchCmdTaskRspGroup() {
+        super();
+    }
+}