切换分支备份

src/main/java/com/glxp/api/http/ErpBasicClient.java

@@ -153,6 +153,29 @@ public class ErpBasicClient {
         }
     }
 
+
+    /**
+     * 提交第三方产品信息
+     *
+     * @param postRelProductRequest
+     * @return
+     */
+    public BaseResponse<String> postRelProduct(PostRelProductRequest postRelProductRequest) {
+        ThrSystemEntity basicThirdSysEntity = basicThirdSysService.selectByThirdId("thirdId");
+        String url = basicThirdSysEntity.getThridUrl() + "/udiwms/erp/post/udiRel/product";
+        try {
+            String response = httpOkClient.uCloudPost(url, postRelProductRequest);
+            BaseResponse<String> listBaseResponse =
+                    JSONObject.parseObject(response, new TypeReference<BaseResponse<String>>() {
+                    });
+
+            return listBaseResponse;
+        } catch (Exception e) {
+            log.error("提交第三产品信息异常" + postRelProductRequest.getDatas().size(), e);
+            return ResultVOUtils.error(500, "连接第三方系统接口服务出错");
+        }
+    }
+
     //测试连通性
     public BaseResponse testConnection(ThrSystemEntity thrSystemEntity) {
         String response = httpOkClient.uCloudPost(thrSystemEntity.getThridUrl() + "/udiwms/erp/testLocal", "{}");

src/main/java/com/glxp/api/req/thrsys/PostRelProductRequest.java

@@ -0,0 +1,15 @@
+package com.glxp.api.req.thrsys;
+
+import com.glxp.api.res.basic.UdiRelevanceResponse;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class PostRelProductRequest {
+
+    private String uploadType;
+    private String thirdSys;
+    List<UdiRelevanceResponse> datas;
+
+}

src/main/java/com/glxp/api/service/thrsys/impl/ThrProductsServiceImpl.java

@@ -1,6 +1,12 @@
 package com.glxp.api.service.thrsys.impl;
 
 import cn.hutool.core.bean.BeanUtil;
+import com.glxp.api.req.basic.FilterUdiRelRequest;
+import com.glxp.api.req.thrsys.PostRelProductRequest;
+import com.glxp.api.service.basic.UdiRelevanceService;
+import com.glxp.api.util.BeanCopyUtils;
+import com.glxp.api.util.CustomUtil;
+import org.apache.regexp.RE;
 import org.springframework.beans.BeanUtils;
 import cn.hutool.core.bean.copier.CopyOptions;
 import cn.hutool.core.collection.CollUtil;
@@ -41,6 +47,7 @@ import javax.annotation.Resource;
 import java.util.Collections;
 import java.util.Date;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * <p>
@@ -313,18 +320,48 @@ public class ThrProductsServiceImpl extends ServiceImpl<ThrProductsDao, ThrProdu
 
     @Resource
     RedisUtil redisUtil;
+    @Resource
+    UdiRelevanceService udiRelevanceService;
 
     @Override
     public BaseResponse uploadThrProduct(ThrSystemDetailEntity thrSystemDetailEntity) {
         //上次修改时间
         String lastUploadTime = (String) redisUtil.get("THR_PI_UPLOAD_TIME");
+        String currentTime = DateUtil.formatTime(new Date());
         if (StrUtil.isEmpty(lastUploadTime)) {
-            //下载耗材字典最新维护数据
+            //获取耗材字典最新维护数据
-
+            FilterUdiRelRequest filterUdiRelRequest = new FilterUdiRelRequest();
-            //下载第三方产品信息
+            filterUdiRelRequest.setLastUpdateTime(lastUploadTime);
-
+            List<UdiRelevanceResponse> udiRelevanceResponses = udiRelevanceService.filterUdiJoinSup(filterUdiRelRequest);
-        }
+            if (CollUtil.isNotEmpty(udiRelevanceResponses)) {
-        return null;
+                List<UdiRelevanceResponse> filteredList = udiRelevanceResponses.stream()
+                        .filter(item ->
+                                {
+                                    if (StrUtil.isNotEmpty(item.getNameCode()) || StrUtil.isNotEmpty(item.getBasicPrductRemak8())) {
+                                        return true;
+                                    } else return false;
+                                }
+                        )
+                        .collect(Collectors.toList());
+
+                List<List<UdiRelevanceResponse>> splitList = CustomUtil.splitList(filteredList, 10);
+                for (List<UdiRelevanceResponse> temps : splitList) {
+                    PostRelProductRequest postRelProductRequest = new PostRelProductRequest();
+                    postRelProductRequest.setUploadType("1");
+                    postRelProductRequest.setThirdSys(thrSystemDetailEntity.getThirdSysFk());
+                    postRelProductRequest.setDatas(temps);
+                    //上传第三方产品信息
+                    BaseResponse baseResponse = erpBasicClient.postRelProduct(postRelProductRequest);
+                    if (baseResponse.getCode() != 20000) {
+                        return ResultVOUtils.error(500, "上传失败！" + baseResponse.getMessage());
+                    }
+                }
+                redisUtil.set("THR_PI_UPLOAD_TIME", currentTime);
+                return ResultVOUtils.success("上传成功");
+            }
+
+        }
+        return ResultVOUtils.error(500, "上传失败！");
     }
 
     /**

src/main/java/com/glxp/api/task/SyncThirdSysTask.java

@@ -126,6 +126,7 @@ public class SyncThirdSysTask implements SchedulingConfigurer {
                         downloadThrOrder(thrSystemDetailEntity);
                         break;
                     case ThirdSysConstant.PI_SUBMIT_URL:
+                        postRelProduct(thrSystemDetailEntity);
                         break;
                     default:
                         //其他接口暂不处理
@@ -271,25 +272,24 @@ public class SyncThirdSysTask implements SchedulingConfigurer {
         }
     }
 
-
     /**
-     * 上传第三方产品信息
+     * 上传已关联产品信息
      *
      * @param thrSystemDetailEntity
      */
-    private void submitThrProduct(ThrSystemDetailEntity thrSystemDetailEntity) {
+    private void postRelProduct(ThrSystemDetailEntity thrSystemDetailEntity) {
         //校验任务并更新redis数据执行标识
         if (verifyTask(thrSystemDetailEntity)) {
             getExecutor().submit(() -> {
-                log.info("开始下载第三方业务单据");
+                log.info("开始上传关联第三方产品信息");
                 try {
                     thrProductsService.uploadThrProduct(thrSystemDetailEntity);
                 } catch (Exception e) {
-                    log.error("下载第三方业务单据", e);
+                    log.error("开始上传关联第三方产品信息", e);
                 } finally {
                     updateTask(getTaskKey(thrSystemDetailEntity));
                 }
-                log.info("第三方业务单据下载完成");
+                log.info("开始上传关联第三方产品信息完成");
             });
         }
     }

src/main/resources/application-dev.yml

@@ -4,7 +4,7 @@ server:
 spring:
   datasource:
     driver-class-name: com.p6spy.engine.spy.P6SpyDriver
-    jdbc-url: jdbc:p6spy:mysql://127.0.0.1:3306/udi_wms_pt?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
+    jdbc-url: jdbc:p6spy:mysql://127.0.0.1:3306/udi_wms_ct?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
     username: root
     password: 123456
     hikari:

src/main/resources/mybatis/mapper/basic/UdiRelevanceDao.xml

@@ -334,7 +334,8 @@
                basic_products.categoryName,
                company_product_relevance.unitFk,
                basic_corp.erpId  as customerId,
-               basic_corp.name      companyName
+               basic_corp.name      companyName,
+               th.hsmc              hslbName
         FROM basic_udirel
                      inner JOIN basic_products
                 ON basic_products.uuid = basic_udirel.uuid
@@ -345,6 +346,7 @@
                      left join thr_products tp on tp.code = basic_udirel.mainId
                      left join basic_product_category_rel on basic_product_category_rel.relId = basic_udirel.id
                      left join basic_product_category on basic_product_category_rel.code = basic_product_category.code
+                     left join thr_hslb th on basic_products.basicPrductRemak8 = th.hsbm
         <where>
             <if test="ylqxzcrbarmc != '' and ylqxzcrbarmc != null">
                 AND basic_products.ylqxzcrbarmc LIKE concat('%', #{ylqxzcrbarmc}, '%')