合并分支 'dxy' 到 'qa'

src/main/java/com/sfa/job/consumer/feishu/EventCallbackLuzx.java

@@ -41,6 +41,9 @@ public class EventCallbackLuzx {
     private String encryptKeyP;
     @Value("${feishu.approval.scfy}")
     private String scfyCode;
+    @Value("${feishu.approval.xpss_cpdj}")
+    private String xpssCode;
+
     @Autowired
     private IEventCallbackService eventCallbackService;
     @Autowired
@@ -122,9 +125,15 @@ public class EventCallbackLuzx {
         EventCallBackDto eventCallBackDto = JSONObject.parseObject(decrypt, EventCallBackDto.class);
         EventCallBackDto.Event event = eventCallBackDto.getEvent();
         // 市场推广费用申请（审批实例CODE：258B4D93-96D4-49E4-B9E1-DA6AB45740B0）
-        if (Constants.FEISHU_APPROVAL_INSTANCE.equals(event.getType()) && scfyCode.equals(event.getApprovalCode())){
-            if (!event.getStatus().equals(PlanStatus.PENDING.name())){
-                eventCallbackService.planCP(event);
+//        if (Constants.FEISHU_APPROVAL_INSTANCE.equals(event.getType()) && scfyCode.equals(event.getApprovalCode())){
+//            if (!event.getStatus().equals(PlanStatus.PENDING.name())){
+//                eventCallbackService.planCP(event);
+//            }
+//        }
+        // 新品上市产品定价申请 （审批实例CODE: B4DBC1A9-D555-469D-AB69-4F353D8D2985）
+        if (Constants.FEISHU_APPROVAL_INSTANCE.equals(event.getType()) && xpssCode.equals(event.getApprovalCode())){
+            if (event.getStatus().equals(PlanStatus.APPROVED.name())){
+                eventCallbackService.getMinimumSellingPrice(event,xpssCode);
             }
         }
     }

src/main/java/com/sfa/job/domain/ls/LsDisStoreDaoImpl.java

@@ -37,8 +37,7 @@ public class LsDisStoreDaoImpl {
 //    秋林：1ZKO0CGs6nm9HuZWR6ucRiu4p9kM8f3i
     private void updateanhui(List<LsDisStore> lsDisStores,Long ldsId){
         for (LsDisStore lsDisStore : lsDisStores) {
-            String outlet = lsDisStore.getOutletName()+lsDisStore.getOutletAddress();
-            String s = HttpUtil.get("https://api.map.baidu.com/geocoding/v3/?address="+outlet+"&output=json&ak=OI4hMr7tEUoDBhSYxcrOGslnnBfZmD2b&city="+lsDisStore.getReCity());
+            String s = HttpUtil.get("https://api.map.baidu.com/geocoding/v3/?address="+lsDisStore.getOutletAddress()+"&output=json&ak=OI4hMr7tEUoDBhSYxcrOGslnnBfZmD2b");
             JSONObject bd = JSONObject.parseObject(s);
             Integer status = bd.getInteger("status");
             if (status.intValue() >= 300 && status.intValue() <= 399){
@@ -48,15 +47,21 @@ public class LsDisStoreDaoImpl {
             if (status.intValue() != 0){
                 continue;
             }
+
             JSONObject jo = bd.getJSONObject("result");
-            String analysLevel = jo.getString("level");
-            lsDisStore.setLat(analysLevel);
-            if (!analysLevel.equals("省") && !analysLevel.equals("城市")){
-                JSONObject location = jo.getJSONObject("location");
-                Float lng = location.getFloat("lng");
-                Float lat = location.getFloat("lat");
-                lsDisStore.setLng(lat+","+lng);
-            }
+            JSONObject location = jo.getJSONObject("location");
+            Float lng = location.getFloat("lng");
+            Float lat = location.getFloat("lat");
+            lsDisStore.setLng(lat+","+lng);
+//
+//            String analysLevel = jo.getString("level");
+//            lsDisStore.setLat(analysLevel);
+//            if (!analysLevel.equals("省") && !analysLevel.equals("城市")){
+//                JSONObject location = jo.getJSONObject("location");
+//                Float lng = location.getFloat("lng");
+//                Float lat = location.getFloat("lat");
+//                lsDisStore.setLng(lat+","+lng);
+//            }
         }
         lsDisStoreMapper.updateListO(lsDisStores);
         baiduAddressAnHui(ldsId);
@@ -76,8 +81,7 @@ public class LsDisStoreDaoImpl {
 //  黄总：8ptRbXOnQNX2TTqGVVYv5AUw3vJZ77gZ
     private void updateGuangzhou(List<LsDisStore> lsDisStores,Long ldsId){
         for (LsDisStore lsDisStore : lsDisStores) {
-            String outlet = lsDisStore.getOutletName()+lsDisStore.getOutletAddress();
-            String s = HttpUtil.get("https://api.map.baidu.com/geocoding/v3/?address="+outlet+"&output=json&ak=sJFYkogPGt8kI3xkkSPwQQ9T61b4GVQV&city="+lsDisStore.getReCity());
+            String s = HttpUtil.get("https://api.map.baidu.com/geocoding/v3/?address="+lsDisStore.getOutletAddress()+"&output=json&ak=sJFYkogPGt8kI3xkkSPwQQ9T61b4GVQV");
             JSONObject bd = JSONObject.parseObject(s);
             Integer status = bd.getInteger("status");
             if (status.intValue() >= 300 && status.intValue() <= 399){
@@ -88,14 +92,18 @@ public class LsDisStoreDaoImpl {
                 continue;
             }
             JSONObject jo = bd.getJSONObject("result");
-            String analysLevel = jo.getString("level");
-            lsDisStore.setLat(analysLevel);
-            if (!analysLevel.equals("省") && !analysLevel.equals("城市")){
-                JSONObject location = jo.getJSONObject("location");
-                Float lng = location.getFloat("lng");
-                Float lat = location.getFloat("lat");
-                lsDisStore.setLng(lat+","+lng);
-            }
+            JSONObject location = jo.getJSONObject("location");
+            Float lng = location.getFloat("lng");
+            Float lat = location.getFloat("lat");
+            lsDisStore.setLng(lat+","+lng);
+//            String analysLevel = jo.getString("level");
+//            lsDisStore.setLat(analysLevel);
+//            if (!analysLevel.equals("省") && !analysLevel.equals("城市")){
+//                JSONObject location = jo.getJSONObject("location");
+//                Float lng = location.getFloat("lng");
+//                Float lat = location.getFloat("lat");
+//                lsDisStore.setLng(lat+","+lng);
+//            }
         }
         lsDisStoreMapper.updateListT(lsDisStores);
         baiduAddressGuangzhou(ldsId);
@@ -115,8 +123,7 @@ public class LsDisStoreDaoImpl {
 //    本才：anjhOkUMuRyTb3DZO6dMGRUCY2l0vAql
     private void updateanhuisp(List<LsDisStore> lsDisStores,Long ldsId){
         for (LsDisStore lsDisStore : lsDisStores) {
-            String outlet = lsDisStore.getOutletName()+lsDisStore.getOutletAddress();
-            String s = HttpUtil.get("https://api.map.baidu.com/geocoding/v3/?address="+outlet+"&output=json&ak=anjhOkUMuRyTb3DZO6dMGRUCY2l0vAql&city="+lsDisStore.getReCity());
+            String s = HttpUtil.get("https://api.map.baidu.com/geocoding/v3/?address="+lsDisStore.getOutletAddress()+"&output=json&ak=anjhOkUMuRyTb3DZO6dMGRUCY2l0vAql");
             JSONObject bd = JSONObject.parseObject(s);
             Integer status = bd.getInteger("status");
             if (status.intValue() >= 300 && status.intValue() <= 399){
@@ -127,14 +134,19 @@ public class LsDisStoreDaoImpl {
                 continue;
             }
             JSONObject jo = bd.getJSONObject("result");
-            String analysLevel = jo.getString("level");
-            lsDisStore.setLat(analysLevel);
-            if (!analysLevel.equals("省") && !analysLevel.equals("城市")){
-                JSONObject location = jo.getJSONObject("location");
-                Float lng = location.getFloat("lng");
-                Float lat = location.getFloat("lat");
-                lsDisStore.setLng(lat+","+lng);
-            }
+            JSONObject location = jo.getJSONObject("location");
+            Float lng = location.getFloat("lng");
+            Float lat = location.getFloat("lat");
+            lsDisStore.setLng(lat+","+lng);
+
+//            String analysLevel = jo.getString("level");
+//            lsDisStore.setLat(analysLevel);
+//            if (!analysLevel.equals("省") && !analysLevel.equals("城市")){
+//                JSONObject location = jo.getJSONObject("location");
+//                Float lng = location.getFloat("lng");
+//                Float lat = location.getFloat("lat");
+//                lsDisStore.setLng(lat+","+lng);
+//            }
         }
         lsDisStoreMapper.updateListS(lsDisStores);
         baiduAddressAnHuisp(ldsId);
@@ -167,8 +179,12 @@ public class LsDisStoreDaoImpl {
             String formattedAddress = jo.getString("formatted_address");
 
             JSONObject ac = jo.getJSONObject("addressComponent");
+            String province = ac.getString("province");
+            String city = ac.getString("city");
             String district = ac.getString("district");
+            lsDisStore.setReProvince(province);
             lsDisStore.setReAddress(formattedAddress);
+            lsDisStore.setReCity(city);
             lsDisStore.setReArea(district);
         }
         lsDisStoreMapper.updateListNO(lsDisStores);
@@ -203,8 +219,12 @@ public class LsDisStoreDaoImpl {
             String formattedAddress = jo.getString("formatted_address");
 
             JSONObject ac = jo.getJSONObject("addressComponent");
+            String province = ac.getString("province");
+            String city = ac.getString("city");
             String district = ac.getString("district");
+            lsDisStore.setReProvince(province);
             lsDisStore.setReAddress(formattedAddress);
+            lsDisStore.setReCity(city);
             lsDisStore.setReArea(district);
         }
         lsDisStoreMapper.updateListNO(lsDisStores);
@@ -237,8 +257,12 @@ public class LsDisStoreDaoImpl {
             String formattedAddress = jo.getString("formatted_address");
 
             JSONObject ac = jo.getJSONObject("addressComponent");
+            String province = ac.getString("province");
+            String city = ac.getString("city");
             String district = ac.getString("district");
+            lsDisStore.setReProvince(province);
             lsDisStore.setReAddress(formattedAddress);
+            lsDisStore.setReCity(city);
             lsDisStore.setReArea(district);
         }
         lsDisStoreMapper.updateListNO(lsDisStores);
@@ -271,8 +295,12 @@ public class LsDisStoreDaoImpl {
             String formattedAddress = jo.getString("formatted_address");
 
             JSONObject ac = jo.getJSONObject("addressComponent");
+            String province = ac.getString("province");
+            String city = ac.getString("city");
             String district = ac.getString("district");
+            lsDisStore.setReProvince(province);
             lsDisStore.setReAddress(formattedAddress);
+            lsDisStore.setReCity(city);
             lsDisStore.setReArea(district);
         }
         lsDisStoreMapper.updateListNO(lsDisStores);
@@ -305,8 +333,12 @@ public class LsDisStoreDaoImpl {
             String formattedAddress = jo.getString("formatted_address");
 
             JSONObject ac = jo.getJSONObject("addressComponent");
+            String province = ac.getString("province");
+            String city = ac.getString("city");
             String district = ac.getString("district");
+            lsDisStore.setReProvince(province);
             lsDisStore.setReAddress(formattedAddress);
+            lsDisStore.setReCity(city);
             lsDisStore.setReArea(district);
         }
         lsDisStoreMapper.updateListNO(lsDisStores);
@@ -339,8 +371,12 @@ public class LsDisStoreDaoImpl {
             String formattedAddress = jo.getString("formatted_address");
 
             JSONObject ac = jo.getJSONObject("addressComponent");
+            String province = ac.getString("province");
+            String city = ac.getString("city");
             String district = ac.getString("district");
+            lsDisStore.setReProvince(province);
             lsDisStore.setReAddress(formattedAddress);
+            lsDisStore.setReCity(city);
             lsDisStore.setReArea(district);
         }
         lsDisStoreMapper.updateListNO(lsDisStores);

src/main/java/com/sfa/job/service/feishu/EventCallbackServiceImpl.java

 package com.sfa.job.service.feishu;
 
 import com.alibaba.fastjson2.JSONObject;
+import com.sfa.common.core.utils.DateUtils;
 import com.lark.oapi.service.corehr.v1.model.Offboarding;
 import com.lark.oapi.service.corehr.v2.model.*;
 import com.sfa.common.core.enums.promotion.PlanStatus;
-import com.sfa.common.core.utils.DateUtils;
 import com.sfa.common.core.utils.sdk.FeiShuUtil;
+import com.sfa.common.core.utils.sdk.FeiShuUtils;
 import com.sfa.job.domain.promotion.dao.IActivityPlanDao;
 import com.sfa.job.domain.system.dao.ISysDeptDao;
 import com.sfa.job.domain.system.dao.ISysEventLogDao;
@@ -14,6 +15,7 @@ import com.sfa.job.pojo.feishu.event.EventCallBackDto;
 import com.sfa.job.pojo.promotion.response.ActivityPlanApprovalDto;
 import com.sfa.job.pojo.response.SysEventLogDto;
 import com.sfa.job.service.system.IDeptAndUserService;
+import com.sfa.job.util.QinCeUtils;
 import com.sfa.job.util.T100Util;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
@@ -21,6 +23,9 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.Date;
+import java.math.BigDecimal;
+import java.util.HashMap;
+import java.util.Map;
 import java.util.Objects;
 
 /**
@@ -45,6 +50,9 @@ public class EventCallbackServiceImpl implements IEventCallbackService{
     private FeiShuUtil feiShuUtil;
     @Autowired
     private T100Util t100Util;
+    @Autowired
+    private QinCeUtils qinCeUtils;
+
 
     @Override
     public void planCP(EventCallBackDto.Event event) {
@@ -214,6 +222,93 @@ public class EventCallbackServiceImpl implements IEventCallbackService{
         deptAndUserService.userResigned(employeeNo);
     }
 
+
+    /**
+     * 获取最小销售价自动设置勤策最小单元售价
+     */
+    @Override
+    public void getMinimumSellingPrice(EventCallBackDto.Event event ,String approveTemplateCode) {
+        String fsInstanceId = event.getFsInstanceId();
+        String approvalInfo = feiShuUtil.getApprovalInfo(fsInstanceId);
+        log.info("开始处理审批单：{}",fsInstanceId);
+        log.info("审批单信息：{}",approvalInfo);
+        if (StringUtils.isBlank(approvalInfo)){
+            String errorMsg = "审批单" + fsInstanceId + "不存在，终止处理";
+            log.error("审批单不存在：{}",fsInstanceId);
+            // 调用封装的错误日志记录方法
+            recordErrorLog("FeiShu sync QinCe Price ", "FeiShu sync", "fsInstanceId：" + fsInstanceId, errorMsg);
+            return;
+        }
+
+        // 获取审批单字段ID
+        Map<String, Object> fieldIdMap = feiShuUtil.getApprovalFormValues(approvalInfo);
+        if (fieldIdMap.isEmpty()){
+            String errorMsg = "获取审批单字段ID失败，终止处理";
+            log.error("获取审批单字段ID失败：{}",approvalInfo);
+            // 调用封装的错误日志记录方法
+            recordErrorLog("FeiShu sync QinCe Price ", "FeiShu sync", "approvalInfo：" + approvalInfo, errorMsg);
+            return;
+        }
+
+        Object productSpec = fieldIdMap.get("productSpec");
+        String productName = (String)fieldIdMap.get("productName");
+        String productCode = (String)fieldIdMap.get("productCode");
+        Object productPrice = fieldIdMap.get("supplyPrice");
+
+
+        if (StringUtils.isBlank(productCode) || productSpec == null || productPrice == null) {
+            String errorMsg = String.format("审批单%s核心字段缺失：编码=%s, 箱规=%s, 供货价=%s",
+                    fsInstanceId, productCode, productSpec, productPrice);
+            log.error(errorMsg);
+            // 调用封装的错误日志记录方法
+            recordErrorLog("QinCe price sync", "QinCe price", "审批单ID：" + fsInstanceId, errorMsg);
+            return;
+        }
+
+        Integer productSpecValue = Integer.parseInt(productSpec.toString());
+        BigDecimal productPriceValue = new BigDecimal(productPrice.toString());
+        BigDecimal minSellingPrice = productPriceValue.multiply(new BigDecimal(productSpecValue));
+
+        log.info("审批单{}解析完成：产品名称={}, 编码={}, 箱规={}, 供货价={}, 最小售价={}", fsInstanceId, productName, productCode, productSpec, productPrice, minSellingPrice);
+
+        // 根据产品编码查询勤策的商品信息
+        try {
+            // 查询勤策商品完整JSON（包含所有原有字段：商品ID、第三方ID等）
+            com.alibaba.fastjson.JSONObject qinCeProductJson = qinCeUtils.queryProductInfo(productCode);
+            if (qinCeProductJson == null || qinCeProductJson.isEmpty()) {
+                 String errorMsg = "勤策未查询到产品编码为" + productCode + "的商品信息";
+                log.error(errorMsg);
+                recordErrorLog("QinCe price sync", "QinCe price", "产品编码：" + productCode, errorMsg);
+                return;
+            }
+            log.info("从勤策查询到的原始JSON：{}", qinCeProductJson.toJSONString());
+
+            // 校验勤策商品单位信息
+            if (qinCeProductJson.getJSONArray("prd_units") != null &&
+                    qinCeProductJson.getJSONArray("prd_units").size() <= 1) {
+                String message = String.format("检测到产品编码为 %s 的单位信息可能未进行转换", productCode);
+                FeiShuUtils.pustRoot(FeiShuUtil.syncpriceWebhook, message);
+            }
+
+            com.alibaba.fastjson.JSONObject updateJson = buildQinCeModifyParam(qinCeProductJson, minSellingPrice);
+
+            // 修改勤策商品信息
+            boolean isModified = qinCeUtils.modifyProductByFullJson(updateJson);
+            log.info("同步价格到勤策结果：产品编码={}，最小售价={}，同步成功={}",
+                    productCode, minSellingPrice, isModified);
+
+            // 日志记录
+            recordErrorLog("QinCe suggest price sync", "QinCe price",
+                    String.format("产品编码：%s，修改字段：prd_suggest_price，修改后值：%s", productCode, minSellingPrice),
+                    isModified ? "同步成功" : "同步失败");
+
+        } catch (Exception e) {
+            String errorMsg = "处理勤策商品信息异常：" + e.getMessage();
+            log.error("处理勤策商品信息时发生异常，产品编码：{}", productCode, e);
+            recordErrorLog("QinCe price sync error", "QinCe price", "产品编码：" + productCode, errorMsg);
+        }
+    }
+
     private void userAUT100(Employee emp){
         String departmentIdV2 = emp.getDepartmentIdV2();
         Department dept = feiShuUtil.getDepartmentCorehr(departmentIdV2);
@@ -284,4 +379,81 @@ public class EventCallbackServiceImpl implements IEventCallbackService{
         userJson.put("payload",payload);
         return t100Util.createOrUpdateUser(userJson);
     }
-}
+
+
+    private void recordErrorLog(String eventName, String eventGroup, String requestMsg, String responseMsg) {
+        try {
+            SysEventLogDto sysEventLogDto = new SysEventLogDto()
+                    .setEventName(eventName)
+                    .setEventGroup(eventGroup)
+                    .setRequestMsg(JSONObject.toJSONString(requestMsg))
+                    .setResponseMsg(responseMsg);
+            sysEventLogDao.insert(sysEventLogDto);
+        } catch (Exception e) {
+            // 日志记录失败时不影响主流程，仅打印错误
+            log.error("记录系统错误日志失败，事件名称：{}，请求信息：{}", eventName, requestMsg, e);
+        }
+    }
+
+    private com.alibaba.fastjson.JSONObject buildQinCeModifyParam(com.alibaba.fastjson.JSONObject qinCeProductJson, BigDecimal minSellingPrice) {
+        com.alibaba.fastjson.JSONObject modifyParam = new com.alibaba.fastjson.JSONObject();
+
+        // ========== 定义销售状态映射（文字↔数值） ==========
+        Map<String, String> saleStatusMap = new HashMap<>();
+        saleStatusMap.put("停售", "0");
+        saleStatusMap.put("在售", "1");
+        saleStatusMap.put("0", "停售");
+        saleStatusMap.put("1", "在售");
+
+        // ========== 顶级字段（严格匹配勤策接口示例字段名） ==========
+        // 核心标识字段
+        modifyParam.put("prd_id", StringUtils.defaultString(qinCeProductJson.getString("prd_id")));
+
+        // 排序/价格字段
+        modifyParam.put("prd_suggest_price", minSellingPrice == null ? BigDecimal.ZERO : minSellingPrice);
+
+        // 销售状态
+        String originalSaleStatus = qinCeProductJson.getString("prd_sale_status");
+        String standardSaleStatus = StringUtils.defaultString(originalSaleStatus);
+        // 转换为标准数值（0=停售，1=在售）
+        if (saleStatusMap.containsKey(standardSaleStatus)) {
+            standardSaleStatus = standardSaleStatus.matches("[01]") ? standardSaleStatus : saleStatusMap.get(standardSaleStatus);
+        }
+        modifyParam.put("prd_sale_status", standardSaleStatus);
+
+        // 标签值
+        String tagValues = String.join(",",
+                StringUtils.defaultString(qinCeProductJson.getString("with_tag_hot")),
+                StringUtils.defaultString(qinCeProductJson.getString("with_tag_gift")),
+                StringUtils.defaultString(qinCeProductJson.getString("with_tag_new")),
+                StringUtils.defaultString(qinCeProductJson.getString("with_tag_sale")),
+                StringUtils.defaultString(qinCeProductJson.getString("with_tag_ex1"))
+        ).replaceAll("^,|,$", "");
+        modifyParam.put("tag_values", tagValues);
+
+        modifyParam.put("prd_price", qinCeProductJson.getBigDecimal("prd_price") == null ? BigDecimal.ZERO : qinCeProductJson.getBigDecimal("prd_price"));
+
+        com.alibaba.fastjson.JSONArray units = new com.alibaba.fastjson.JSONArray();
+        com.alibaba.fastjson.JSONArray sourcePrdUnits = qinCeProductJson.getJSONArray("prd_units");
+        if (sourcePrdUnits != null && !sourcePrdUnits.isEmpty()) {
+            for (int i = 0; i < sourcePrdUnits.size(); i++) {
+                com.alibaba.fastjson.JSONObject sourceUnit = sourcePrdUnits.getJSONObject(i);
+                if (sourceUnit == null) continue;
+
+                com.alibaba.fastjson.JSONObject unit = new com.alibaba.fastjson.JSONObject();
+                // 单位字段严格映射为勤策要求的名称
+                unit.put("name", StringUtils.defaultString(sourceUnit.getString("prd_unit_name")));
+                unit.put("is_base", StringUtils.defaultString(sourceUnit.getString("prd_is_base")));
+                unit.put("ratio", sourceUnit.getBigDecimal("prd_ratio") == null ? 1.00000000 : sourceUnit.getBigDecimal("prd_ratio").doubleValue());
+                unit.put("bar_code", StringUtils.defaultString(sourceUnit.getString("prd_barcode")));
+                unit.put("weight", StringUtils.defaultString(sourceUnit.getString("prd_weight")));
+                unit.put("weight_unit", StringUtils.defaultString(sourceUnit.getString("prd_weight_unit")));
+
+                units.add(unit);
+            }
+        }
+        modifyParam.put("units", units);
+
+        return modifyParam;
+    }
+}
\ No newline at end of file

src/main/java/com/sfa/job/service/feishu/IEventCallbackService.java

@@ -19,4 +19,10 @@ public interface IEventCallbackService {
     void userUpdateByPersonId(String personId);
 
     void userResigned(String employmentId);
+
+    /**
+     * 自动获取最小销售价设置给勤策
+     * @param event
+     */
+    void getMinimumSellingPrice(EventCallBackDto.Event event , String approveTemplateCode);
 }

src/main/java/com/sfa/job/util/QinCeUtils.java

@@ -52,6 +52,11 @@ public class QinCeUtils {
     public static final String MODIFY_USER = "/api/employee/v3/modifyEmployee/";
 
 
+    // 商品信息查询
+    public static final String QUERY_PRODUCT_INFO = "/api/product/v1/queryProduct/";
+    // 商品价格更新
+    public static final String MODIFY_PRODUCT_PRICE = "/api/pd/v2/modifyProduct/";
+
 
     public String builderUrl(String sidepath, Map<String, Object> params) {
         String msgId = UUID.randomUUID().toString();
@@ -129,4 +134,66 @@ public class QinCeUtils {
         JSONObject jsonObject = postQC(url, params);
         return jsonObject.getJSONArray("response_data");
     }
+
+    /**
+     * 构建勤策商品查询参数（贴合官方queryProduct接口要求）
+     * @param productCode 产品编码（官方必传字段）
+     * @return 符合官方规范的查询参数
+     */
+    public Map<String, Object> queryProductOfficialParams(String productCode) {
+        Map<String, Object> params = new HashMap<>();
+        // 官方必传：产品编码（prd_code为勤策官方字段名）
+        params.put("prd_code", productCode);
+        return params;
+    }
+
+    /**
+     * 调用勤策官方查询商品接口（pd/v2/queryProduct）
+     * @param productCode 产品编码
+     * @return 商品信息JSON对象（返回第一条数据）
+     * @throws Exception 接口调用异常
+     */
+    public JSONObject queryProductInfo(String productCode) throws Exception {
+        Map<String, Object> params = queryProductOfficialParams(productCode);
+        String url = builderUrl(QUERY_PRODUCT_INFO, params);
+        log.info("调用勤策官方商品查询接口，URL：{}，参数：{}", url, params);
+
+        JSONObject result = postQC(url, params);
+        JSONArray dataArray = result.getJSONArray("response_data");
+        return CollectionUtils.isEmpty(dataArray) ? null : dataArray.getJSONObject(0);
+    }
+
+
+    public boolean modifyProductByFullJson(JSONObject fullProductJson)  {
+        //  空值校验
+        if (fullProductJson == null || fullProductJson.isEmpty()) {
+            log.error("勤策修改商品的JSON为空，无法调用接口");
+            return false;
+        }
+
+        try {
+            // 将JSONObject转为Map，满足builderUrl生成digest的要求（你原有逻辑依赖Map）
+            Map<String, Object> modifyParams = JSONObject.parseObject(fullProductJson.toJSONString(), Map.class);
+
+            // 复用你原有builderUrl方法生成接口地址（传入修改参数Map）
+            String url = builderUrl(MODIFY_PRODUCT_PRICE, modifyParams);
+            log.info("调用勤策商品修改接口，URL：{}，参数：{}", url, modifyParams);
+
+            // 复用你原有postQC方法（保持异常抛出逻辑一致）
+            JSONObject respObj = postQC(url, modifyParams);
+
+            // 解析返回结果（沿用你原有return_code校验逻辑）
+            String returnCode = respObj.getString("return_code");
+            if ("0".equals(returnCode)) {
+                log.info("勤策商品修改成功，修改字段：prd_suggest_price，商品编码：{}", fullProductJson.getString("prd_code"));
+                return true;
+            } else {
+                log.error("勤策商品修改失败，返回信息：{}", respObj);
+                return false;
+            }
+        } catch (Exception e) {
+            log.error("调用勤策修改商品接口异常，JSON：{}", fullProductJson.toJSONString(), e);
+            return false;
+        }
+    }
 }

src/main/java/com/sfa/job/xxljob/test/TestTask.java

@@ -25,13 +25,13 @@ public class TestTask {
 
     @XxlJob("ls_store_guangzhou")
     public void lsStoreGuangzhou() {
-        lsDisStoreDaoImpl.baiduAddressGuangzhou(500000L);
+        lsDisStoreDaoImpl.baiduAddressGuangzhou(40000L);
     }
 
 
     @XxlJob("ls_store_ahsp")
     public void lsStoreAnHuisp() {
-        lsDisStoreDaoImpl.baiduAddressAnHuisp(1000000L);
+        lsDisStoreDaoImpl.baiduAddressAnHuisp(80000L);
     }
 
     /**
@@ -43,26 +43,26 @@ public class TestTask {
     }
     @XxlJob("ls_store_n_xy")
     public void lsStoreNXY() {
-        lsDisStoreDaoImpl.lsStoreNXY(250000L);
+        lsDisStoreDaoImpl.lsStoreNXY(20000L);
     }
     @XxlJob("ls_store_n_gh")
     public void lsStoreNGH() {
-        lsDisStoreDaoImpl.lsStoreNGH(500000L);
+        lsDisStoreDaoImpl.lsStoreNGH(40000L);
     }
 
     @XxlJob("ls_store_n_hs")
     public void lsStoreNHS() {
-        lsDisStoreDaoImpl.lsStoreNHS(750000L);
+        lsDisStoreDaoImpl.lsStoreNHS(60000L);
     }
 
     @XxlJob("ls_store_n_dx")
     public void lsStoreNDX() {
-        lsDisStoreDaoImpl.lsStoreNDX(1000000L);
+        lsDisStoreDaoImpl.lsStoreNDX(80000L);
     }
 
-    @XxlJob("ls_store_n_ql")
-    public void lsStoreNQL() {
-        lsDisStoreDaoImpl.lsStoreNQL(1250000L);
-    }
+//    @XxlJob("ls_store_n_ql")
+//    public void lsStoreNQL() {
+//        lsDisStoreDaoImpl.lsStoreNQL(120000L);
+//    }
 
 }

src/main/resources/mapper/job/LsDisStoreMapper.xml

@@ -32,7 +32,7 @@
 <!--       修改 limit 数量-->
         <select id="selectBaseO" resultMap="LsDisStoreBase">
                 select lds_if,re_province,re_city,outlet_address,outlet_name
-                from ls_dis_store where lds_if &gt; #{lastId} and lds_if &lt;= 500000 and  re_area is null and lng is null   limit 1000;
+                from ls_dis_store where lds_if &gt; #{lastId} and lds_if &lt;= 40000 and lng is null limit 1000;
         </select>
 
 
@@ -45,7 +45,7 @@
 
         <select id="selectBaseT" resultMap="LsDisStoreBase">
                 select lds_if,re_province,re_city,outlet_address,outlet_name
-                from ls_dis_store where lds_if &gt; #{lastId} and lds_if &lt;= 1000000 and  re_area is null and lng is null   limit 1000;
+                from ls_dis_store where lds_if &gt; #{lastId} and lds_if &lt;= 80000 and lng is null   limit 1000;
         </select>
 
 
@@ -59,7 +59,7 @@
 
         <select id="selectBaseS" resultMap="LsDisStoreBase">
                 select lds_if,re_province,re_city,outlet_address,outlet_name
-                from ls_dis_store where lds_if &gt; #{lastId} and lds_if &lt;= 1537130 and  re_area is null and lng is null   limit 1000;
+                from ls_dis_store where lds_if &gt; #{lastId} and lds_if &lt;= 120000 and lng is null   limit 1000;
         </select>
 
 
@@ -74,37 +74,37 @@
 
     <select id="selectBaseLO" resultMap="LsDisStoreBase">
         select lds_if,lng
-        from ls_dis_store where lng is not null and re_area is null  limit 1000;
+        from ls_dis_store where lng is not null and re_city is null  and lds_if &gt; #{lastId} and lds_if &lt;= 20000 limit 1000;
     </select>
 
     <select id="selectBaseLT" resultMap="LsDisStoreBase">
         select lds_if,lng
-        from ls_dis_store where lng is not null and re_area is null and lds_if &gt; #{lastId} and lds_if &lt;= 500000 limit 1000;
+        from ls_dis_store where lng is not null and re_city is null and lds_if &gt; #{lastId} and lds_if &lt;= 40000 limit 1000;
     </select>
 
     <select id="selectBaseLS" resultMap="LsDisStoreBase">
         select lds_if,lng
-        from ls_dis_store where lng is not null and re_area is null and lds_if &gt; #{lastId} and lds_if &lt;= 750000 limit 1000;
+        from ls_dis_store where lng is not null and re_city is null and lds_if &gt; #{lastId} and lds_if &lt;= 60000 limit 1000;
     </select>
 
     <select id="selectBaseLF" resultMap="LsDisStoreBase">
         select lds_if,lng
-        from ls_dis_store where lng is not null and re_area is null and lds_if &gt; #{lastId} and lds_if &lt;= 1000000 limit 1000;
+        from ls_dis_store where lng is not null and re_city is null and lds_if &gt; #{lastId} and lds_if &lt;= 80000 limit 1000;
     </select>
 
     <select id="selectBaseLV" resultMap="LsDisStoreBase">
         select lds_if,lng
-        from ls_dis_store where lng is not null and re_area is null and lds_if &gt; #{lastId} and lds_if &lt;= 1250000 limit 1000;
+        from ls_dis_store where lng is not null and re_city is null and lds_if &gt; #{lastId} and lds_if &lt;= 120000 limit 1000;
     </select>
 
     <select id="selectBaseLX" resultMap="LsDisStoreBase">
         select lds_if,lng
-        from ls_dis_store where lng is not null and re_area is null and lds_if &gt; #{lastId} and lds_if &lt;= 1537130 limit 1000;
+        from ls_dis_store where lng is not null and re_city is null and lds_if &gt; #{lastId} and lds_if &lt;= 1537130 limit 1000;
     </select>
 
     <update id="updateListNO" parameterType="java.util.List">
         <foreach collection="lsDisStores" item="item" separator=";">
-            update ls_dis_store set re_address = #{item.reAddress},re_area = #{item.reArea} where lds_if = #{item.ldsIf}
+            update ls_dis_store set re_address = #{item.reAddress},re_area = #{item.reArea},re_province = #{item.reProvince},re_city = #{item.reCity} where lds_if = #{item.ldsIf}
         </foreach>
     </update>
 </mapper>