新增定时任务，获取标准焊缝数据接口数据

hongjli

2025-05-21 0f994c67ff258fb93aa85ae90200e3db2b5f97f4

新增定时任务，获取标准焊缝数据接口数据

 aps-modules/aps-job/src/main/java/com/aps/job/domain/ApsWeldSeamStandardJob.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,56 @@
package com.aps.job.domain;

import com.aps.common.core.annotation.Excel;
import com.aps.common.core.web.domain.BaseEntity;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.math.BigDecimal;

/**
 * ç„Šç¼æ ‡å‡†å¯¹è±¡ aps_weld_seam_standard_job
 * 
 * @author user
 * @date 2023-11-05
 */
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class ApsWeldSeamStandardJob extends BaseEntity
{
    private static final long serialVersionUID = 1L;

    /** ä¸»é”®ID */
    private Long id;

    /** æ–™å·ï¼ˆæŽ¥å£ä¸­å¯¹åº”plantCount或verId） */
    @Excel(name = "料号")
    private String itemCode;

    /** å›¾å· */
    @Excel(name = "图号")
    private String itemFigure;

    /** ç‰ˆæœ¬å· */
    @Excel(name = "版本号")
    private String itemFigureVersion;

    /** å•ä»¶ç„Šç¼æ•°ï¼ˆHup） */
    @Excel(name = "单件焊缝数（Hup）")
    private BigDecimal hupQty;

    /** å•ä»¶ç„Šç¼æ•°ï¼ˆLOD） */
    @Excel(name = "单件焊缝数（LOD）")
    private BigDecimal lodQty;

    /** ç„ŠæŽ¥å½¢å¼(hup\lod) */
    @Excel(name = "焊接形式")
    private String type;

    /** æ˜¯å¦åˆ é™¤(0否，1是) */
    private Integer delFlag;
} 

 aps-modules/aps-job/src/main/java/com/aps/job/mapper/ApsWeldSeamStandardJobMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,39 @@
package com.aps.job.mapper;

import com.aps.job.domain.ApsWeldSeamStandardJob;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

/**
 * ç„Šç¼æ ‡å‡†Job Mapper接口
 * 
 * @author user
 * @date 2023-11-05
 */
@Mapper
public interface ApsWeldSeamStandardJobMapper 
{
    /**
     * æŸ¥è¯¢ç„Šç¼æ ‡å‡†åˆ—表
     * 
     * @param apsWeldSeamStandardJob ç„Šç¼æ ‡å‡†
     * @return ç„Šç¼æ ‡å‡†é›†åˆ
     */
    public List<ApsWeldSeamStandardJob> selectApsWeldSeamStandardJobList(ApsWeldSeamStandardJob apsWeldSeamStandardJob);

    /**
     * åˆ é™¤æ‰€æœ‰ç„Šç¼æ ‡å‡†Job数据
     * 
     * @return ç»“æžœ
     */
    public int deleteAllApsWeldSeamStandardJob();
    
    /**
     * æ‰¹é‡æ–°å¢žç„Šç¼æ ‡å‡†Job
     * 
     * @param list ç„Šç¼æ ‡å‡†Job列表
     * @return ç»“æžœ
     */
    public int batchInsertApsWeldSeamStandardJob(List<ApsWeldSeamStandardJob> list);
} 

 aps-modules/aps-job/src/main/java/com/aps/job/mapper/ApsWeldSeamStandardMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,31 @@
package com.aps.job.mapper;

import com.aps.job.domain.ApsWeldSeamStandardJob;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

/**
 * ç„Šç¼æ ‡å‡†ä¸šåŠ¡è¡¨ Mapper接口
 * 
 * @author user
 * @date 2023-11-05
 */
@Mapper
public interface ApsWeldSeamStandardMapper
{
    /**
     * åˆ é™¤æ‰€æœ‰ç„Šç¼æ ‡å‡†æ•°æ®
     * 
     * @return ç»“æžœ
     */
    public int deleteAllApsWeldSeamStandard();
    
    /**
     * æ‰¹é‡æ–°å¢žç„Šç¼æ ‡å‡†
     * 
     * @param list ç„Šç¼æ ‡å‡†Job列表
     * @return ç»“æžœ
     */
    public int batchInsertApsWeldSeamStandard(List<ApsWeldSeamStandardJob> list);
} 

 aps-modules/aps-job/src/main/java/com/aps/job/service/IApsWeldSeamStandardJobService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,44 @@
package com.aps.job.service;

import com.aps.job.domain.ApsWeldSeamStandardJob;

import java.util.List;

/**
 * ç„Šç¼æ ‡å‡†Job Service接口
 * 
 * @author user
 * @date 2023-11-05
 */
public interface IApsWeldSeamStandardJobService 
{
    /**
     * æŸ¥è¯¢ç„Šç¼æ ‡å‡†åˆ—表
     * 
     * @param apsWeldSeamStandardJob ç„Šç¼æ ‡å‡†
     * @return ç„Šç¼æ ‡å‡†é›†åˆ
     */
    public List<ApsWeldSeamStandardJob> selectApsWeldSeamStandardJobList(ApsWeldSeamStandardJob apsWeldSeamStandardJob);

    /**
     * åˆ é™¤æ‰€æœ‰ç„Šç¼æ ‡å‡†Job数据
     * 
     * @return ç»“æžœ
     */
    public int deleteAllApsWeldSeamStandardJob();
    
    /**
     * æ‰¹é‡æ–°å¢žç„Šç¼æ ‡å‡†Job
     * 
     * @param list ç„Šç¼æ ‡å‡†Job列表
     * @return ç»“æžœ
     */
    public int batchInsertApsWeldSeamStandardJob(List<ApsWeldSeamStandardJob> list);
    
    /**
     * åŒæ­¥ç‰©æ–™æ ‡å‡†ç„Šç¼æ•°æ®
     * 
     * @return ç»“æžœ
     */
    public boolean syncWeldSeamStandardData();
} 

 aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWeldSeamStandardJobServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,215 @@
package com.aps.job.service.impl;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.aps.common.core.utils.StringUtils;
import com.aps.common.security.utils.SecurityUtils;
import com.aps.job.domain.ApsWeldSeamStandardJob;
import com.aps.job.mapper.ApsWeldSeamStandardMapper;
import com.aps.job.mapper.ApsWeldSeamStandardJobMapper;
import com.aps.job.service.IApsWeldSeamStandardJobService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.client.RestTemplate;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicLong;

/**
 * ç„Šç¼æ ‡å‡†Job Service业务层处理
 * 
 * @author user
 * @date 2023-11-05
 */
@Slf4j
@Service
public class ApsWeldSeamStandardJobServiceImpl implements IApsWeldSeamStandardJobService 
{
    @Autowired
    private ApsWeldSeamStandardJobMapper apsWeldSeamStandardJobMapper;
    
    @Autowired
    private ApsWeldSeamStandardMapper apsWeldSeamStandardMapper;
    
    @Autowired
    private RestTemplate restTemplate;
    
    @Value("${pipingIntegrationplatform.apsWeldSeamStandard}")
    private String apsWeldSeamStandardUrl;

    /**
     * æŸ¥è¯¢ç„Šç¼æ ‡å‡†åˆ—表
     * 
     * @param apsWeldSeamStandardJob ç„Šç¼æ ‡å‡†
     * @return ç„Šç¼æ ‡å‡†é›†åˆ
     */
    @Override
    public List<ApsWeldSeamStandardJob> selectApsWeldSeamStandardJobList(ApsWeldSeamStandardJob apsWeldSeamStandardJob)
    {
        return apsWeldSeamStandardJobMapper.selectApsWeldSeamStandardJobList(apsWeldSeamStandardJob);
    }

    /**
     * åˆ é™¤æ‰€æœ‰ç„Šç¼æ ‡å‡†Job数据
     * 
     * @return ç»“æžœ
     */
    @Override
    public int deleteAllApsWeldSeamStandardJob()
    {
        return apsWeldSeamStandardJobMapper.deleteAllApsWeldSeamStandardJob();
    }
    
    /**
     * æ‰¹é‡æ–°å¢žç„Šç¼æ ‡å‡†Job
     * 
     * @param list ç„Šç¼æ ‡å‡†Job列表
     * @return ç»“æžœ
     */
    @Override
    public int batchInsertApsWeldSeamStandardJob(List<ApsWeldSeamStandardJob> list)
    {
        return apsWeldSeamStandardJobMapper.batchInsertApsWeldSeamStandardJob(list);
    }
    
    /**
     * åŒæ­¥ç‰©æ–™æ ‡å‡†ç„Šç¼æ•°æ®
     * 
     * @return ç»“æžœ
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean syncWeldSeamStandardData()
    {
        try {
            // ä½¿ç”¨POST方法调用接口
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.APPLICATION_JSON);
            
            // å‡†å¤‡è¯·æ±‚参数 - ä¼ é€’工厂代码字符串数组，设置为空数组
            String[] plantCodeArray = new String[0];
            
            // ç›´æŽ¥ä½¿ç”¨å­—符串数组作为请求体
            HttpEntity<String[]> requestEntity = new HttpEntity<>(plantCodeArray, headers);
            
            ResponseEntity<String> responseEntity = restTemplate.postForEntity(apsWeldSeamStandardUrl, requestEntity, String.class);
            if (!responseEntity.getStatusCode().is2xxSuccessful()) {
                log.error("获取物料标准焊缝数据失败");
                return false;
            }
            
            String responseBody = responseEntity.getBody();
            if (StringUtils.isEmpty(responseBody)) {
                return false;
            }
            
            JSONObject responseJson = JSON.parseObject(responseBody);
            
            // æ£€æŸ¥è¿”回码
            if (responseJson.getIntValue("code") != 0) {
                return false;
            }
            
            // èŽ·å–接口返回的数据
            JSONArray weldSeamList = responseJson.getJSONArray("ok");
            if (weldSeamList == null || weldSeamList.isEmpty()) {
                return false;
            }
            
            // è§£æžæ•°æ®å¹¶è½¬æ¢ä¸ºå®žä½“对象
            List<ApsWeldSeamStandardJob> jobList = new ArrayList<>();
            AtomicLong idCounter = new AtomicLong(System.currentTimeMillis()); // ä½¿ç”¨å½“前时间戳作为起始ID
            
            for (int i = 0; i < weldSeamList.size(); i++) {
                JSONObject item = weldSeamList.getJSONObject(i);
                
                // ä½¿ç”¨æ­£ç¡®çš„字段名称 plantCode
                String plantCode = item.getString("plantCode");
                
                // èŽ·å–UHP和LOD数量
                BigDecimal uhpCount = null;
                BigDecimal lodCount = null;
                
                try {
                    uhpCount = item.getBigDecimal("uhpCount");
                } catch (Exception e) {
                    // å¿½ç•¥å¼‚常
                }
                
                try {
                    lodCount = item.getBigDecimal("lodCount");
                } catch (Exception e) {
                    // å¿½ç•¥å¼‚常
                }
                
                // åˆ¤æ–­æ•°æ®æ˜¯å¦å®Œæ•´
                if (StringUtils.isEmpty(plantCode)) {
                    continue;
                }
                
                ApsWeldSeamStandardJob job = new ApsWeldSeamStandardJob();
                // ä¸ºid赋值，使用自增长整型
                job.setId(idCounter.incrementAndGet());
                job.setItemCode(plantCode);  // æ˜ å°„关系: plantCode -> itemCode
                job.setHupQty(uhpCount);     // æ˜ å°„关系: uhpCount -> hupQty
                job.setLodQty(lodCount);     // æ˜ å°„关系: lodCount -> lodQty
                job.setDelFlag(0);
                // ä¸å†è®¾ç½®createBy和createTime
                jobList.add(job);
            }
            
            if (jobList.isEmpty()) {
                return false;
            }
            
            // æ¸…空旧数据
            deleteAllApsWeldSeamStandardJob();
            
            // æ‰¹é‡æ’入新数据
            batchInsertApsWeldSeamStandardJob(jobList);
            
            // åŒæ­¥æ•°æ®åˆ°ä¸šåŠ¡è¡¨
            syncToBizTable(jobList);
            
            return true;
        } catch (Exception e) {
            log.error("同步物料标准焊缝数据异常", e);
            throw e;
        }
    }
    
    /**
     * åŒæ­¥æ•°æ®åˆ°ä¸šåŠ¡è¡¨
     * 
     * @param jobList ç„Šç¼æ ‡å‡†Job数据列表
     */
    private void syncToBizTable(List<ApsWeldSeamStandardJob> jobList) {
        try {
            // åˆ é™¤ä¸šåŠ¡è¡¨æ•°æ®ï¼ˆå…¨é‡è¦†ç›–）
            apsWeldSeamStandardMapper.deleteAllApsWeldSeamStandard();
            
            if (jobList == null || jobList.isEmpty()) {
                return;
            }
            
            // æ‰¹é‡æ’入数据到业务表
            apsWeldSeamStandardMapper.batchInsertApsWeldSeamStandard(jobList);
        } catch (Exception e) {
            log.error("同步物料标准焊缝数据到业务表异常", e);
            throw e;
        }
    }
} 

 aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java

@@ -44,6 +44,9 @@
    @Autowired
    private IApsMaterialManagementJobService apsMaterialManagementJobService;

    @Autowired
    private IApsWeldSeamStandardJobService apsWeldSeamStandardJobService;

    public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
    {
        System.out.println(StringUtils.format("执行多参方法： å­—符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
@@ -203,4 +206,11 @@
        remoteCoreService.setPlateSubPlansToRedis(SecurityConstants.INNER);
    }

    /**
     * åŒæ­¥ç‰©æ–™æ ‡å‡†ç„Šç¼æ•°æ®
     */
    public void syncWeldSeamStandardData() {
        apsWeldSeamStandardJobService.syncWeldSeamStandardData();
    }

}

 aps-modules/aps-job/src/main/resources/mapper/job/ApsWeldSeamStandardJobMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.aps.job.mapper.ApsWeldSeamStandardJobMapper">
    
    <resultMap type="com.aps.job.domain.ApsWeldSeamStandardJob" id="ApsWeldSeamStandardJobResult">
        <result property="id"    column="id"    />
        <result property="itemCode"    column="item_code"    />
        <result property="itemFigure"    column="item_figure"    />
        <result property="itemFigureVersion"    column="item_figure_version"    />
        <result property="hupQty"    column="hup_qty"    />
        <result property="lodQty"    column="lod_qty"    />
        <result property="type"    column="type"    />
        <result property="delFlag"    column="del_flag"    />
    </resultMap>

    <sql id="selectApsWeldSeamStandardJobVo">
        select id, item_code, item_figure, item_figure_version, hup_qty, lod_qty, type, del_flag from aps_weld_seam_standard_job
    </sql>

    <select id="selectApsWeldSeamStandardJobList" parameterType="com.aps.job.domain.ApsWeldSeamStandardJob" resultMap="ApsWeldSeamStandardJobResult">
        <include refid="selectApsWeldSeamStandardJobVo"/>
        <where>  
            <if test="itemCode != null  and itemCode != ''"> and item_code LIKE '%' || #{itemCode} || '%'</if>
            <if test="itemFigure != null  and itemFigure != ''"> and item_figure = #{itemFigure}</if>
            <if test="itemFigureVersion != null  and itemFigureVersion != ''"> and item_figure_version = #{itemFigureVersion}</if>
            <if test="hupQty != null "> and hup_qty = #{hupQty}</if>
            <if test="lodQty != null "> and lod_qty = #{lodQty}</if>
            <if test="type != null  and type != ''"> and type = #{type}</if>
            and del_flag = 0
        </where>
    </select>
    
    <delete id="deleteAllApsWeldSeamStandardJob">
        delete from aps_weld_seam_standard_job
    </delete>
    
    <insert id="batchInsertApsWeldSeamStandardJob" parameterType="java.util.List">
        insert into aps_weld_seam_standard_job(
        id,
        item_code, 
        item_figure,
        item_figure_version, 
        hup_qty, 
        lod_qty, 
        type, 
        del_flag)
        values
        <foreach collection="list" item="item" index="index" separator=",">
        (
            #{item.id},
            #{item.itemCode},
            #{item.itemFigure},
            #{item.itemFigureVersion},
            #{item.hupQty},
            #{item.lodQty},
            #{item.type},
            0
        )
        </foreach>
    </insert>
    
</mapper> 

 aps-modules/aps-job/src/main/resources/mapper/job/ApsWeldSeamStandardMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,35 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.aps.job.mapper.ApsWeldSeamStandardMapper">
    
    <delete id="deleteAllApsWeldSeamStandard">
        delete from aps_weld_seam_standard
    </delete>
    
    <insert id="batchInsertApsWeldSeamStandard" parameterType="java.util.List">
        insert into aps_weld_seam_standard(
        id,
        item_code, 
        item_figure, 
        item_figure_version, 
        hup_qty, 
        lod_qty, 
        type, 
        del_flag)
        values
        <foreach collection="list" item="item" index="index" separator=",">
        (
            #{item.id},
            #{item.itemCode},
            #{item.itemFigure},
            #{item.itemFigureVersion},
            #{item.hupQty},
            #{item.lodQty},
            #{item.type},
            0
        )
        </foreach>
    </insert>
</mapper>