超期装备写入定时任务

jyzb-biz/src/main/java/com/junmp/jyzb/Repository/SupplierRepository.java

+package com.junmp.jyzb.Repository;
+
+import com.junmp.jyzb.entity.Supplier;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface SupplierRepository extends ElasticsearchRepository<Supplier, Long> {
+}

jyzb-biz/src/main/java/com/junmp/jyzb/mapper/InventorySummaryMapper.java

@@ -96,4 +96,10 @@ public interface InventorySummaryMapper  extends BaseMapper<InventorySummary> {
     void useViewOrgIdInLevel(@Param("sql") String sql,@Param("orgId") Long orgId);
 
     List<Long> selectOrgIds(@Param("orgId") Long orgId);
+
+    void setWarrantyInventoryAction();
+
+    void setDestoryGroupAction();
+
+    void setWarrantyGroupAction();
 }
\ No newline at end of file

jyzb-biz/src/main/java/com/junmp/jyzb/service/InventorySummaryService.java

@@ -48,4 +48,10 @@ public interface InventorySummaryService extends IService<InventorySummary> {
     PageResult<InventorySummary> GetEquipmentSummary(InventorySumReq req);
 
     List<InventorySummary> GetEquipmentSummaryDetail(InventorySumReq req);
+
+    void setWarrantyInventoryAction();
+
+    void setDestoryGroupAction();
+
+    void setWarrantyGroupAction();
 }

jyzb-biz/src/main/java/com/junmp/jyzb/service/PublicService.java

@@ -16,4 +16,6 @@ public interface PublicService {
     List<SimpleDictVo> getAllDictItem();
 
     boolean updateMessage(MessageReq req);
+
+
 }

jyzb-biz/src/main/java/com/junmp/jyzb/service/SupplierService.java

@@ -11,6 +11,9 @@ import com.junmp.v2.db.api.page.PageResult;
 import java.util.List;
 
 public interface SupplierService extends IService<Supplier> {
+
+    Object addEs();
+
     /**
      * 新增
      *

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/EquipmentSizeServiceImpl.java

@@ -141,6 +141,8 @@ public class EquipmentSizeServiceImpl extends ServiceImpl<EquipmentSizeMapper, E
         mqDto.setMessage("Adding sizeInfo");
         MQ.sendToExchange(exchangeName,"org",mqDto);
 
+        //添加es
+        sizeRepository.save(size);
         return sizeID+"||"+code;
     }
 
@@ -186,6 +188,8 @@ public class EquipmentSizeServiceImpl extends ServiceImpl<EquipmentSizeMapper, E
         mqDto.setMessage("Updating sizeInfo");
         MQ.sendToExchange(exchangeName,"org",mqDto);
 
+        //添加es
+        sizeRepository.save(size);
         return this.updateById(size);
     }
 

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/EquipmentTypeServiceImpl.java

@@ -151,12 +151,14 @@ public class EquipmentTypeServiceImpl extends ServiceImpl<EquipmentTypeMapper, E
             mqDto.setType(2);
             mqDto.setMessage("Adding typeInfo");
             MQ.sendToExchange(exchangeName,"org",mqDto);
-
+            //往es中添加数据
+            typeRepository.save(type);
             return  String.valueOf(newcode);
         } else {
             String msg="以下供应商不存在：" +String.join(",", chekResult);
             throw new JYZBAppException(EquipmentExceptionEnum.SUPPLIER_NOT_EXIST, msg);
         }
+
     }
 
 
@@ -256,6 +258,8 @@ public class EquipmentTypeServiceImpl extends ServiceImpl<EquipmentTypeMapper, E
             mqDto.setType(2);
             mqDto.setMessage("Updating typeInfo");
             MQ.sendToExchange(exchangeName,"org",mqDto);
+            //往es中添加数据
+            typeRepository.save(type);
             return this.updateById(type);
         } else {
             String msg="以下供应商不存在：" +String.join(",", chekResult);

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/InventorySummaryServiceImpl.java

@@ -176,6 +176,8 @@ public class InventorySummaryServiceImpl  extends ServiceImpl<InventorySummaryMa
         return inventorySummaryMapper.GetEquipmentSummaryDetail(req);
     }
 
+
+
     @Override
     public List<InventorySummary> getEquipmentInfoList(InventorySumReq req) {
         //当没有参数传递的时候默认查询全部，但是如果传递了条件，根据条件查询并且如果是根据id进行查询，则需要判断该id是否存在
@@ -517,4 +519,24 @@ public class InventorySummaryServiceImpl  extends ServiceImpl<InventorySummaryMa
 
         return wrapper;
     }
+    //执行过质保期装备存储过程
+    @Override
+    public void setWarrantyInventoryAction() {
+        inventorySummaryMapper.setWarrantyInventoryAction();
+        System.out.println("111 = " + 111);
+    }
+    //执行过质保期装备存储过程
+    @Override
+    public void setDestoryGroupAction() {
+        inventorySummaryMapper.setDestoryGroupAction();
+        System.out.println("111 = " + 222);
+
+    }
+    //执行过质保期装备存储过程
+    @Override
+    public void setWarrantyGroupAction() {
+        inventorySummaryMapper.setWarrantyGroupAction();
+        System.out.println("111 = " + 333);
+
+    }
 }

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/PubOrgServiceImpl.java

@@ -836,6 +836,8 @@ public class PubOrgServiceImpl extends ServiceImpl<PubOrgMapper, PubOrg>  implem
         pubOrg.setCreateTime(DateTimeUtil.getCurrentDateTime());
         pubOrg.setIsMap("0");
         save(pubOrg);
+        //添加es
+        pubOrgRepository.save(pubOrg);
         return pubOrg.getOrgId();
     }
 
@@ -848,6 +850,8 @@ public class PubOrgServiceImpl extends ServiceImpl<PubOrgMapper, PubOrg>  implem
 //        }
         PubOrg pubOrg = new PubOrg();
         BeanPlusUtil.copyProperties(req,pubOrg);
+        //添加es
+        pubOrgRepository.save(pubOrg);
         return updateById(pubOrg);
     }
 

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/SupplierServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.junmp.jyzb.Repository.SupplierRepository;
 import com.junmp.jyzb.api.bean.dto.FetchingDataDto.SupplierInfoDto;
 import com.junmp.jyzb.api.bean.dto.MQDto;
 import com.junmp.jyzb.api.bean.dto.SupplierDto;
@@ -42,6 +43,16 @@ public class SupplierServiceImpl extends ServiceImpl<SupplierMapper, Supplier> i
 
     @Resource
     private SupplierMapper supplierMapper;
+    
+    @Resource
+    private SupplierRepository supplierRepository;
+
+    @Override
+    public Object addEs() {
+        QuerySupplierReq req = new QuerySupplierReq();
+
+        return null;
+    }
 
     @Override
     public String AddSupplier(UpdateSupplierReq req) {

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/VieWarrantyGroupServiceImpl.java

@@ -36,7 +36,7 @@ public class VieWarrantyGroupServiceImpl extends ServiceImpl<VieWarrantyGroupMap
     private VieDestoryGroupServiceImpl VieDestoryGroupService;
     @Override
     public PageResult<WarrantyDataDto> WarrantyData(WarrantyReq req) {
-        if(req.getWarrantyType().equals(0)||req.getWarrantyType().equals(1))
+        if(req.getWarrantyType().equals("0")||req.getWarrantyType().equals("1"))
         {
             LambdaQueryWrapper<VieWarrantyGroup> wrapper = createWrapper(req);
             Page<VieWarrantyGroup> page = page(PageFactory.getDefaultPage(req.getPageNo(), req.getPageSize()), wrapper);

jyzb-biz/src/main/java/com/junmp/jyzb/task/DestoryGroupAction.java

+package com.junmp.jyzb.task;
+
+import com.junmp.jyzb.service.InventorySummaryService;
+import com.junmp.jyzb.service.PublicService;
+import com.junmp.v2.job.api.JobAction;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Slf4j
+@Component
+public class DestoryGroupAction implements JobAction {
+    @Resource
+    private InventorySummaryService inventorySummaryService;
+    @Override
+    public void action() {
+        inventorySummaryService.setDestoryGroupAction();
+    }
+}

jyzb-biz/src/main/java/com/junmp/jyzb/task/WarrantyGroupAction.java

+package com.junmp.jyzb.task;
+
+import com.junmp.jyzb.service.InventorySummaryService;
+import com.junmp.jyzb.service.PublicService;
+import com.junmp.v2.job.api.JobAction;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Slf4j
+@Component
+
+public class WarrantyGroupAction implements JobAction{
+    @Resource
+    private InventorySummaryService inventorySummaryService;
+    @Override
+    public void action() {
+        inventorySummaryService.setWarrantyGroupAction();
+    }
+}

jyzb-biz/src/main/java/com/junmp/jyzb/task/WarrantyInventoryAction.java

+package com.junmp.jyzb.task;
+
+import com.junmp.jyzb.service.InventorySummaryService;
+import com.junmp.jyzb.service.PublicService;
+import com.junmp.v2.job.api.JobAction;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Slf4j
+@Component
+
+public class WarrantyInventoryAction implements JobAction{
+
+    @Resource
+    private InventorySummaryService inventorySummaryService;
+    @Override
+    public void action() {
+        inventorySummaryService.setWarrantyInventoryAction();
+    }
+}

jyzb-biz/src/main/resources/mapper/InventorySummaryMapper.xml

@@ -87,7 +87,21 @@
                 END
         WHERE add_price IS NULL OR add_num IS NULL;
     </update>
+    <insert id="setWarrantyInventoryAction" statementType="CALLABLE">
 
+        {CALL Insert_into_base_warranty_inventory()}
+
+    </insert>
+    <insert id="setDestoryGroupAction" statementType="CALLABLE">
+
+        {CALL Insert_into_view_destory_group()}
+
+    </insert>
+    <insert id="setWarrantyGroupAction" statementType="CALLABLE">
+
+        {CALL Insert_into_view_warranty_group()}
+
+    </insert>
 
     <insert id="getSumByCabinet">
         INSERT INTO base_inventory_summary (id,org_id_int,org_name,type_id, type_name,size_id,size_name,location_id,location_name,

jyzb-boot/src/main/resources/application-prod.yml

@@ -32,7 +32,7 @@ knife4j:
 spring:
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver
-    url: jdbc:mysql://192.168.1.128:3306/db_jyzb?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT&nullCatalogMeansCurrent=true
+    url: jdbc:mysql://192.168.1.128:3306/db_jyzb_test?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT&nullCatalogMeansCurrent=true
     username: root
     password: 123456