设备管理-故障类型V1

op-modules/op-device/src/main/java/com/op/device/config/DynamicDatasource.java

@@ -0,0 +1,53 @@
+package com.op.device.config;
+
+import com.baomidou.dynamic.datasource.spring.boot.autoconfigure.DataSourceProperty;
+import com.op.common.core.domain.R;
+import com.op.common.datasource.creator.DynamicDatasourceCreator;
+import com.op.system.api.RemoteUserService;
+import com.op.system.api.domain.SysUser;
+
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 初始化动态数据源
+ *
+ * @ClassName: DynamicDatasource
+ * @Description: TODO
+ * @author shichangzhou
+ * @date 2023年4月19日 下午1:01:30
+ */
+@Component
+public class DynamicDatasource {
+
+    @Resource
+    private DynamicDatasourceCreator dynamicDatasourceCreator;
+    @Autowired
+    private RemoteUserService remoteUserService;
+
+    @PostConstruct
+    public void init() {
+        // 加载sf-cloud库的sys_datasource
+        SysUser sysUser = new SysUser();
+        sysUser.setUserId(1L);
+        R<List<Map<String, String>>> dateSources0 = remoteUserService.getPoolNameList(sysUser);
+        List<Map<String, String>> dateSources = dateSources0.getData();
+        for (Map<String, String> dateSource : dateSources) {
+            DataSourceProperty sdp = new DataSourceProperty();
+            sdp.setUrl(dateSource.get("url"));
+            sdp.setUsername(dateSource.get("userName"));
+            sdp.setPassword(dateSource.get("password"));
+            sdp.setDriverClassName(dateSource.get("driveClassName"));
+            sdp.setPoolName(dateSource.get("poolName"));// 这是数据源的key
+            sdp.setLazy(false);
+            dynamicDatasourceCreator.createDynamicDataSource(sdp);
+        }
+
+    }
+}

op-modules/op-device/src/main/java/com/op/device/controller/EquFaultTypeController.java

@@ -2,6 +2,7 @@ package com.op.device.controller;
 
 import java.util.List;
 import javax.servlet.http.HttpServletResponse;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -72,7 +73,7 @@ public class EquFaultTypeController extends BaseController {
     @Log(title = "故障类型维护", businessType = BusinessType.INSERT)
     @PostMapping
     public AjaxResult add(@RequestBody EquFaultType equFaultType) {
-		return toAjax(equFaultTypeService.insertEquFaultType(equFaultType));
+        return equFaultTypeService.insertEquFaultType(equFaultType);
     }
 
     /**

op-modules/op-device/src/main/java/com/op/device/mapper/EquFaultTypeMapper.java

@@ -44,7 +44,7 @@ public interface EquFaultTypeMapper {
 	public int updateEquFaultType(EquFaultType equFaultType);
 
 	/**
-	 * 删除故障类型维护
+	 * 删除故障类型维护-逻辑
 	 * 
 	 * @param faultId 故障类型维护主键
 	 * @return 结果
@@ -52,10 +52,16 @@ public interface EquFaultTypeMapper {
 	public int deleteEquFaultTypeByFaultId(String faultId);
 
 	/**
-	 * 批量删除故障类型维护
+	 * 批量删除故障类型维护-逻辑
 	 * 
 	 * @param faultIds 需要删除的数据主键集合
 	 * @return 结果
 	 */
 	public int deleteEquFaultTypeByFaultIds(String[] faultIds);
+
+	/**
+	 * 获取流水号
+	 * @return
+	 */
+    int selectSerialNumber();
 }

op-modules/op-device/src/main/java/com/op/device/service/IEquFaultTypeService.java

@@ -1,6 +1,8 @@
 package com.op.device.service;
 
 import java.util.List;
+
+import com.op.common.core.web.domain.AjaxResult;
 import com.op.device.domain.EquFaultType;
 
 /**
@@ -32,7 +34,7 @@ public interface IEquFaultTypeService {
 	 * @param equFaultType 故障类型维护
 	 * @return 结果
 	 */
-	public int insertEquFaultType(EquFaultType equFaultType);
+	public AjaxResult insertEquFaultType(EquFaultType equFaultType);
 
 	/**
 	 * 修改故障类型维护

op-modules/op-device/src/main/java/com/op/device/service/impl/EquCheckItemServiceImpl.java

@@ -4,13 +4,11 @@ import java.text.Format;
 import java.text.SimpleDateFormat;
 import java.util.List;
 
-import com.alibaba.nacos.shaded.org.checkerframework.checker.units.qual.A;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.op.common.core.context.SecurityContextHolder;
 import com.op.common.core.utils.DateUtils;
 import com.op.common.core.utils.uuid.IdUtils;
 import com.op.common.core.web.domain.AjaxResult;
-import com.op.common.log.annotation.Log;
 import com.op.device.domain.EquCheckItemDetail;
 import com.op.device.domain.EquItemEquipment;
 import com.op.device.domain.dto.EquCheckItemDTO;
@@ -313,6 +311,7 @@ public class EquCheckItemServiceImpl implements IEquCheckItemService {
      * @return
      */
     @Override
+    @DS("#header.poolName")
     public AjaxResult getEquipmentCodeListByItemCode(String itemCode) {
         List<String> equipmentCodeList = equItemEquipmentMapper.selectEquipmentCodeList(itemCode);
         return success(equipmentCodeList);

op-modules/op-device/src/main/java/com/op/device/service/impl/EquFaultTypeServiceImpl.java

@@ -1,12 +1,24 @@
 package com.op.device.service.impl;
 
 import java.util.List;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.op.common.core.context.SecurityContextHolder;
 import com.op.common.core.utils.DateUtils;
+import com.op.common.core.utils.uuid.IdUtils;
+import com.op.common.core.web.domain.AjaxResult;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.op.device.mapper.EquFaultTypeMapper;
 import com.op.device.domain.EquFaultType;
 import com.op.device.service.IEquFaultTypeService;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+import static com.op.common.core.web.domain.AjaxResult.error;
+import static com.op.common.core.web.domain.AjaxResult.success;
 
 /**
  * 故障类型维护Service业务层处理
@@ -26,6 +38,7 @@ public class EquFaultTypeServiceImpl implements IEquFaultTypeService {
      * @return 故障类型维护
      */
     @Override
+    @DS("#header.poolName")
     public EquFaultType selectEquFaultTypeByFaultId(String faultId) {
         return equFaultTypeMapper.selectEquFaultTypeByFaultId(faultId);
     }
@@ -37,6 +50,7 @@ public class EquFaultTypeServiceImpl implements IEquFaultTypeService {
      * @return 故障类型维护
      */
     @Override
+    @DS("#header.poolName")
     public List<EquFaultType> selectEquFaultTypeList(EquFaultType equFaultType) {
         return equFaultTypeMapper.selectEquFaultTypeList(equFaultType);
     }
@@ -48,9 +62,32 @@ public class EquFaultTypeServiceImpl implements IEquFaultTypeService {
      * @return 结果
      */
     @Override
-	public int insertEquFaultType(EquFaultType equFaultType) {
+    @DS("#header.poolName")
+    public AjaxResult insertEquFaultType(EquFaultType equFaultType) {
+
+        //获取当前所选工厂
+        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+        String key = "#header.poolName";
+        String str = request.getHeader(key.substring(8));
+        int index = str.indexOf("_");
+        String factory = str.substring(index + 1);
+
+        // 获取检查项流水号
+        String serialNum = String.format("%03d", equFaultTypeMapper.selectSerialNumber());
+
+        // 处理故障信息
+        equFaultType.setFaultId(IdUtils.fastSimpleUUID());
+        equFaultType.setFaultCode(DateUtils.dateTimeNow(DateUtils.YYYYMMDD) + serialNum);
+        equFaultType.setFactoryCode(factory);
+        equFaultType.setCreateBy(SecurityContextHolder.getUserName());
         equFaultType.setCreateTime(DateUtils.getNowDate());
-		return equFaultTypeMapper.insertEquFaultType(equFaultType);
+        equFaultType.setUpdateBy(SecurityContextHolder.getUserName());
+        equFaultType.setUpdateTime(DateUtils.getNowDate());
+
+        // 插入数据库
+        equFaultTypeMapper.insertEquFaultType(equFaultType);
+
+        return success();
     }
 
     /**
@@ -60,6 +97,7 @@ public class EquFaultTypeServiceImpl implements IEquFaultTypeService {
      * @return 结果
      */
     @Override
+    @DS("#header.poolName")
     public int updateEquFaultType(EquFaultType equFaultType) {
         equFaultType.setUpdateTime(DateUtils.getNowDate());
         return equFaultTypeMapper.updateEquFaultType(equFaultType);
@@ -72,6 +110,7 @@ public class EquFaultTypeServiceImpl implements IEquFaultTypeService {
      * @return 结果
      */
     @Override
+    @DS("#header.poolName")
     public int deleteEquFaultTypeByFaultIds(String[] faultIds) {
         return equFaultTypeMapper.deleteEquFaultTypeByFaultIds(faultIds);
     }
@@ -83,6 +122,7 @@ public class EquFaultTypeServiceImpl implements IEquFaultTypeService {
      * @return 结果
      */
     @Override
+    @DS("#header.poolName")
     public int deleteEquFaultTypeByFaultId(String faultId) {
         return equFaultTypeMapper.deleteEquFaultTypeByFaultId(faultId);
     }

op-modules/op-device/src/main/resources/mapper/device/EquFaultTypeMapper.xml

@@ -41,12 +41,19 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 			<if test="createTime != null "> and create_time = #{createTime}</if>
 			<if test="updateBy != null  and updateBy != ''"> and update_by = #{updateBy}</if>
 			<if test="updateTime != null "> and update_time = #{updateTime}</if>
+			and del_flag = '0'
 		</where>
 	</select>
 	
 	<select id="selectEquFaultTypeByFaultId" parameterType="String" resultMap="EquFaultTypeResult">
 		<include refid="selectEquFaultTypeVo"/>
-		where fault_id = #{faultId}
+		where fault_id = #{faultId} and del_flag = '0'
+	</select>
+
+    <select id="selectSerialNumber" resultType="java.lang.Integer">
+		SELECT COUNT(fault_id)+1 AS serialNum
+		FROM equ_fault_type
+		WHERE CONVERT(date, GETDATE()) = CONVERT(date,create_time) and del_flag = '0'
 	</select>
 
     <insert id="insertEquFaultType" parameterType="EquFaultType">
@@ -102,7 +109,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 			<if test="updateBy != null and updateBy != ''">update_by = #{updateBy},</if>
 			<if test="updateTime != null">update_time = #{updateTime},</if>
 		</trim>
-		where fault_id = #{faultId}
+		where fault_id = #{faultId} and del_flag = '0'
 	</update>
 
 	<delete id="deleteEquFaultTypeByFaultId" parameterType="String">