长泰药品下载收费项目与物资字典修改

src/main/java/com/glxp/mipsdl/client/ctqyy/CtqyyClient.java

@@ -286,8 +286,24 @@ public class CtqyyClient extends CommonHttpClient {
                     products.setPrepnSpec(dict.getPHYSIC_SPEC());
                     products.setPrepnUnit(dict.getPHYSIC_UNIT());
                     products.setProductType(2);
+                    products.setId(IdUtil.getSnowflakeNextId());
+                    products.setThirdSysFk("thirdId1");
                     return products;
                 }).collect(Collectors.toList());
+                thrProductsDao.batchInsert(thrProductsEntityList);
+                thrProductsEntityList = thrProductsEntityList.stream()
+                        .collect(Collectors.groupingBy(ThrProductsEntity::getYbbm,
+                                LinkedHashMap::new,
+                                Collectors.collectingAndThen(Collectors.toList(), list -> list.get(0))))
+                        .values()
+                        .stream()
+                        .collect(Collectors.toList());
+            }
+
+            for (ThrProductsEntity entity : thrProductsEntityList) {
+                entity.setId(null);
+                entity.setRemark(entity.getCode());
+                entity.setCode(entity.getYbbm());
             }
             PageSimpleResponse<ThrProductsEntity> pageSimpleResponse = new PageSimpleResponse<>();
             pageSimpleResponse.setTotal(page.getTotal());
@@ -2263,6 +2279,7 @@ public class CtqyyClient extends CommonHttpClient {
         JSONObject dataJson = JSONObject.parseObject(jsonStr);
         ybClient.ybPost("3506A", dataJson);
     }
+
     /**
      * 获取交易类型集合
      *

src/main/java/com/glxp/mipsdl/dao/thrsys/ThrProductsDao.java

@@ -4,6 +4,11 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.glxp.mipsdl.entity.thrsys.ThrProductsEntity;
 import org.apache.ibatis.annotations.Mapper;
 
+import java.util.List;
+
 @Mapper
 public interface ThrProductsDao extends BaseMapper<ThrProductsEntity> {
+
+
+    boolean batchInsert(List<ThrProductsEntity> thrProducts);
 }

src/main/resources/mybatis/mapper/master/thrsys/ThrProductsDao.xml

@@ -39,9 +39,65 @@
     </resultMap>
     <sql id="Base_Column_List">
         <!--@mbg.generated-->
-    id, code, `name`, measname, spec, registerNo, manufactory, thirdSysFk, cplb, flbm,
-    qxlb, ybbm, sptm, tyshxydm, zczbhhzbapzbh, ylqxzcrbarmc, ylqxzcrbarywmc, cpms, updateTime,
-    supName, model, `standard`, qtbm, zczyxqz, remark, remark1, remark2, remark3, price,
-    `createUser`, createTime, updateUser
+        id,
+        code,
+        `name`,
+        measname,
+        spec,
+        registerNo,
+        manufactory,
+        thirdSysFk,
+        cplb,
+        flbm,
+        qxlb,
+        ybbm,
+        sptm,
+        tyshxydm,
+        zczbhhzbapzbh,
+        ylqxzcrbarmc,
+        ylqxzcrbarywmc,
+        cpms,
+        updateTime,
+        supName,
+        model,
+        `standard`,
+        qtbm,
+        zczyxqz,
+        remark,
+        remark1,
+        remark2,
+        remark3,
+        price,
+        `createUser`,
+        createTime,
+        updateUser
     </sql>
+    <insert id="batchInsert" parameterType="map">
+        <!--@mbg.generated-->
+        insert ignore into thr_products
+        (id, code, `name`, measname, spec, registerNo, manufactory, thirdSysFk, cplb, flbm,
+         qxlb, ybbm, sptm, tyshxydm, zczbhhzbapzbh, ylqxzcrbarmc, ylqxzcrbarywmc, cpms,
+         updateTime, supName, model, `standard`, qtbm, zczyxqz, remark, remark1, remark2,
+         remark3, price, `createUser`, createTime, updateUser, manufactoryCode, supCode,
+         `type`, prcitmcode, productType, prepnSpec, prepnUnit)
+        values
+        <foreach collection="list" item="item" separator=",">
+            (#{item.id,jdbcType=BIGINT}, #{item.code,jdbcType=VARCHAR}, #{item.name,jdbcType=VARCHAR},
+             #{item.measname,jdbcType=VARCHAR}, #{item.spec,jdbcType=VARCHAR}, #{item.registerNo,jdbcType=VARCHAR},
+             #{item.manufactory,jdbcType=VARCHAR}, #{item.thirdSysFk,jdbcType=VARCHAR}, #{item.cplb,jdbcType=VARCHAR},
+             #{item.flbm,jdbcType=VARCHAR}, #{item.qxlb,jdbcType=VARCHAR}, #{item.ybbm,jdbcType=VARCHAR},
+             #{item.sptm,jdbcType=VARCHAR}, #{item.tyshxydm,jdbcType=VARCHAR}, #{item.zczbhhzbapzbh,jdbcType=VARCHAR},
+             #{item.ylqxzcrbarmc,jdbcType=VARCHAR}, #{item.ylqxzcrbarywmc,jdbcType=VARCHAR},
+             #{item.cpms,jdbcType=LONGVARCHAR}, #{item.updateTime,jdbcType=TIMESTAMP}, #{item.supName,jdbcType=VARCHAR},
+             #{item.model,jdbcType=VARCHAR}, #{item.standard,jdbcType=VARCHAR}, #{item.qtbm,jdbcType=VARCHAR},
+             #{item.zczyxqz,jdbcType=VARCHAR}, #{item.remark,jdbcType=VARCHAR}, #{item.remark1,jdbcType=VARCHAR},
+             #{item.remark2,jdbcType=VARCHAR}, #{item.remark3,jdbcType=VARCHAR}, #{item.price,jdbcType=VARCHAR},
+             #{item.createUser,jdbcType=VARCHAR}, #{item.createTime,jdbcType=TIMESTAMP},
+             #{item.updateUser,jdbcType=VARCHAR},
+             #{item.manufactoryCode,jdbcType=VARCHAR}, #{item.supCode,jdbcType=VARCHAR}, #{item.type,jdbcType=TINYINT},
+             #{item.prcitmcode,jdbcType=VARCHAR}, #{item.productType,jdbcType=TINYINT},
+             #{item.prepnSpec,jdbcType=VARCHAR},
+             #{item.prepnUnit,jdbcType=VARCHAR})
+        </foreach>
+    </insert>
 </mapper>