hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

店铺，供应商同步到u8c客商

This commit is contained in:
sx 2024-08-13 09:38:32 +08:00
parent a8a6843f98
commit 834ab523b3
35 changed files with 2227 additions and 556 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
buildpackage/src/main/java/com/hzya/frame/plugin/lets/constant/OverallConstant.java
View File

@ -5,7 +5,6 @@ import java.util.Map;
/**
* lets全局静态参数配置
*
*/
public class OverallConstant {
@ -43,6 +42,13 @@ public class OverallConstant {
prodOverPublic.put("custdocSave", "/u8cloud/api/uapbd/custdoc/insert");//客商档案新增
prodOverPublic.put("custdocQuery", "/u8cloud/api/uapbd/custdoc/query");//客商档案查询
prodOverPublic.put("custdocUpdate", "/u8cloud/api/uapbd/custdoc/update");//客商档案修改
prodOverPublic.put("custdocAssign", "/u8cloud/api/uapbd/custdoc/assign");//客商档案分配
prodOverPublic.put("custmandocSave", "/u8cloud/api/uapbd/custmandoc/insert");//客商档案新增
prodOverPublic.put("bdcorpQuery", "/u8cloud/api/uapbd/bdcorp/query");//公司档案查询
}
@ -64,6 +70,8 @@ public class OverallConstant {
devOverAll.put("u8cApiNeedStackTraceCode", "Y");
devOverAll.put("u8cApiZdrCode", "15932295350");//单据制单人---测试环境：郑一凡
}
private static void loadProd() {

2
buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCubasdocDaoImpl.java
View File

@ -20,7 +20,7 @@ public class BdCubasdocDaoImpl extends MybatisGenericDao<BdCubasdocEntity, Strin
public BdCubasdocEntity queryBdCumandocEntity(BdCubasdocEntity bdCumandocEntity) throws Exception {
Assert.notNull(bdCumandocEntity, "BdCumandocEntity不可为空！");
Assert.notNull(bdCumandocEntity.getPk_cumandoc(), "供应商管理id不能为空！");
Assert.notNull(bdCumandocEntity.getPkCorp(), "公司id不能为空!");
Assert.notNull(bdCumandocEntity.getPk_corp(), "公司id不能为空!");
// Assert.notNull(bdCumandocEntity.getCustflag(), "客商属性不能为空!");
return query(bdCumandocEntity, "com.hzya.frame.plugin.lets.dao.impl.BdCubasdocDaoImpl.queryBdCumandocByPkCumandoc");

103
buildpackage/src/main/java/com/hzya/frame/plugin/lets/entity/BdCubasdocEntity.java
View File

@ -10,6 +10,10 @@ import com.hzya.frame.web.entity.BaseEntity;
*/
public class BdCubasdocEntity extends BaseEntity {
//客商基本档案主键(修改时必填,新增时禁止传入)
private String pk_cubasdoc;
private String accdefault;
private String billtemplet;
private String bp1;
@ -24,6 +28,7 @@ public class BdCubasdocEntity extends BaseEntity {
private String custname;
private Long custprop;
private String custshortname;
//是否
private String def1;
private String def10;
private String def11;
@ -67,12 +72,12 @@ public class BdCubasdocEntity extends BaseEntity {
private String phone1;
private String phone2;
private String phone3;
private String pkAreacl;
private String pkCorp;
private String pkCorp1;
private String pkCubasdoc;
private String pkCubasdoc1;
private String pkPricegroup;
private String pk_areacl;
private String pk_corp;
private String pk_corp1;
// private String pkcubasdoc;
private String pk_cubasdoc1;
private String pk_pricegroup;
private String registerfund;
private String saleaddr;
private String sealflag;
@ -119,6 +124,7 @@ public class BdCubasdocEntity extends BaseEntity {
this.end_createtime = end_createtime;
}
public String getCustflag() {
return custflag;
}
@ -571,6 +577,46 @@ public class BdCubasdocEntity extends BaseEntity {
return phone1;
}
public String getPk_areacl() {
return pk_areacl;
}
public void setPk_areacl(String pk_areacl) {
this.pk_areacl = pk_areacl;
}
public String getPk_corp() {
return pk_corp;
}
public void setPk_corp(String pk_corp) {
this.pk_corp = pk_corp;
}
public String getPk_corp1() {
return pk_corp1;
}
public void setPk_corp1(String pk_corp1) {
this.pk_corp1 = pk_corp1;
}
public String getPk_cubasdoc1() {
return pk_cubasdoc1;
}
public void setPk_cubasdoc1(String pk_cubasdoc1) {
this.pk_cubasdoc1 = pk_cubasdoc1;
}
public String getPk_pricegroup() {
return pk_pricegroup;
}
public void setPk_pricegroup(String pk_pricegroup) {
this.pk_pricegroup = pk_pricegroup;
}
public void setPhone1(String phone1) {
this.phone1 = phone1;
}
@ -591,53 +637,16 @@ public class BdCubasdocEntity extends BaseEntity {
this.phone3 = phone3;
}
public String getPkAreacl() {
return pkAreacl;
public String getPk_cubasdoc() {
return pk_cubasdoc;
}
public void setPkAreacl(String pkAreacl) {
this.pkAreacl = pkAreacl;
public void setPk_cubasdoc(String pk_cubasdoc) {
this.pk_cubasdoc = pk_cubasdoc;
}
public String getPkCorp() {
return pkCorp;
}
public void setPkCorp(String pkCorp) {
this.pkCorp = pkCorp;
}
public String getPkCorp1() {
return pkCorp1;
}
public void setPkCorp1(String pkCorp1) {
this.pkCorp1 = pkCorp1;
}
public String getPkCubasdoc() {
return pkCubasdoc;
}
public void setPkCubasdoc(String pkCubasdoc) {
this.pkCubasdoc = pkCubasdoc;
}
public String getPkCubasdoc1() {
return pkCubasdoc1;
}
public void setPkCubasdoc1(String pkCubasdoc1) {
this.pkCubasdoc1 = pkCubasdoc1;
}
public String getPkPricegroup() {
return pkPricegroup;
}
public void setPkPricegroup(String pkPricegroup) {
this.pkPricegroup = pkPricegroup;
}
public String getRegisterfund() {
return registerfund;

124
buildpackage/src/main/java/com/hzya/frame/plugin/lets/entity/BdCubasdocEntity.xml
View File

@ -60,12 +60,12 @@
<result property="phone1" column="phone1" jdbcType="VARCHAR"/>
<result property="phone2" column="phone2" jdbcType="VARCHAR"/>
<result property="phone3" column="phone3" jdbcType="VARCHAR"/>
<result property="pkAreacl" column="pk_areacl" jdbcType="VARCHAR"/>
<result property="pkCorp" column="pk_corp" jdbcType="VARCHAR"/>
<result property="pkCorp1" column="pk_corp1" jdbcType="VARCHAR"/>
<result property="pkCubasdoc" column="pk_cubasdoc" jdbcType="VARCHAR"/>
<result property="pkCubasdoc1" column="pk_cubasdoc1" jdbcType="VARCHAR"/>
<result property="pkPricegroup" column="pk_pricegroup" jdbcType="VARCHAR"/>
<result property="pkareacl" column="pk_areacl" jdbcType="VARCHAR"/>
<result property="pkcorp" column="pk_corp" jdbcType="VARCHAR"/>
<result property="pkcorp1" column="pk_corp1" jdbcType="VARCHAR"/>
<result property="pkcubasdoc" column="pk_cubasdoc" jdbcType="VARCHAR"/>
<result property="pkcubasdoc1" column="pk_cubasdoc1" jdbcType="VARCHAR"/>
<result property="pkpricegroup" column="pk_pricegroup" jdbcType="VARCHAR"/>
<result property="registerfund" column="registerfund" jdbcType="VARCHAR"/>
<result property="saleaddr" column="saleaddr" jdbcType="VARCHAR"/>
<result property="sealflag" column="sealflag" jdbcType="VARCHAR"/>
@ -212,12 +212,12 @@
<if test="phone1 != null and phone1 != ''"> and phone1 = #{phone1} </if>
<if test="phone2 != null and phone2 != ''"> and phone2 = #{phone2} </if>
<if test="phone3 != null and phone3 != ''"> and phone3 = #{phone3} </if>
<if test="pkAreacl != null and pkAreacl != ''"> and pk_areacl = #{pkAreacl} </if>
<if test="pkCorp != null and pkCorp != ''"> and pk_corp = #{pkCorp} </if>
<if test="pkCorp1 != null and pkCorp1 != ''"> and pk_corp1 = #{pkCorp1} </if>
<if test="pkCubasdoc != null and pkCubasdoc != ''"> and pk_cubasdoc = #{pkCubasdoc} </if>
<if test="pkCubasdoc1 != null and pkCubasdoc1 != ''"> and pk_cubasdoc1 = #{pkCubasdoc1} </if>
<if test="pkPricegroup != null and pkPricegroup != ''"> and pk_pricegroup = #{pkPricegroup} </if>
<if test="pkareacl != null and pkareacl != ''"> and pk_areacl = #{pkareacl} </if>
<if test="pkcorp != null and pkcorp != ''"> and pk_corp = #{pkcorp} </if>
<if test="pkcorp1 != null and pkcorp1 != ''"> and pk_corp1 = #{pkcorp1} </if>
<if test="pkcubasdoc != null and pkcubasdoc != ''"> and pk_cubasdoc = #{pkcubasdoc} </if>
<if test="pkcubasdoc1 != null and pkcubasdoc1 != ''"> and pk_cubasdoc1 = #{pkcubasdoc1} </if>
<if test="pkpricegroup != null and pkpricegroup != ''"> and pk_pricegroup = #{pkpricegroup} </if>
<if test="registerfund != null and registerfund != ''"> and registerfund = #{registerfund} </if>
<if test="saleaddr != null and saleaddr != ''"> and saleaddr = #{saleaddr} </if>
<if test="sealflag != null and sealflag != ''"> and sealflag = #{sealflag} </if>
@ -295,12 +295,12 @@
<if test="phone1 != null and phone1 != ''"> and phone1 = #{phone1} </if>
<if test="phone2 != null and phone2 != ''"> and phone2 = #{phone2} </if>
<if test="phone3 != null and phone3 != ''"> and phone3 = #{phone3} </if>
<if test="pkAreacl != null and pkAreacl != ''"> and pk_areacl = #{pkAreacl} </if>
<if test="pkCorp != null and pkCorp != ''"> and pk_corp = #{pkCorp} </if>
<if test="pkCorp1 != null and pkCorp1 != ''"> and pk_corp1 = #{pkCorp1} </if>
<if test="pkCubasdoc != null and pkCubasdoc != ''"> and pk_cubasdoc = #{pkCubasdoc} </if>
<if test="pkCubasdoc1 != null and pkCubasdoc1 != ''"> and pk_cubasdoc1 = #{pkCubasdoc1} </if>
<if test="pkPricegroup != null and pkPricegroup != ''"> and pk_pricegroup = #{pkPricegroup} </if>
<if test="pkareacl != null and pkareacl != ''"> and pk_areacl = #{pkareacl} </if>
<if test="pkcorp != null and pkcorp != ''"> and pk_corp = #{pkcorp} </if>
<if test="pkcorp1 != null and pkcorp1 != ''"> and pk_corp1 = #{pkcorp1} </if>
<if test="pkcubasdoc != null and pkcubasdoc != ''"> and pk_cubasdoc = #{pkcubasdoc} </if>
<if test="pkcubasdoc1 != null and pkcubasdoc1 != ''"> and pk_cubasdoc1 = #{pkcubasdoc1} </if>
<if test="pkpricegroup != null and pkpricegroup != ''"> and pk_pricegroup = #{pkpricegroup} </if>
<if test="registerfund != null and registerfund != ''"> and registerfund = #{registerfund} </if>
<if test="saleaddr != null and saleaddr != ''"> and saleaddr = #{saleaddr} </if>
<if test="sealflag != null and sealflag != ''"> and sealflag = #{sealflag} </if>
@ -377,12 +377,12 @@
<if test="phone1 != null and phone1 != ''"> and phone1 like concat('%',#{phone1},'%') </if>
<if test="phone2 != null and phone2 != ''"> and phone2 like concat('%',#{phone2},'%') </if>
<if test="phone3 != null and phone3 != ''"> and phone3 like concat('%',#{phone3},'%') </if>
<if test="pkAreacl != null and pkAreacl != ''"> and pk_areacl like concat('%',#{pkAreacl},'%') </if>
<if test="pkCorp != null and pkCorp != ''"> and pk_corp like concat('%',#{pkCorp},'%') </if>
<if test="pkCorp1 != null and pkCorp1 != ''"> and pk_corp1 like concat('%',#{pkCorp1},'%') </if>
<if test="pkCubasdoc != null and pkCubasdoc != ''"> and pk_cubasdoc like concat('%',#{pkCubasdoc},'%') </if>
<if test="pkCubasdoc1 != null and pkCubasdoc1 != ''"> and pk_cubasdoc1 like concat('%',#{pkCubasdoc1},'%') </if>
<if test="pkPricegroup != null and pkPricegroup != ''"> and pk_pricegroup like concat('%',#{pkPricegroup},'%') </if>
<if test="pkareacl != null and pkareacl != ''"> and pk_areacl like concat('%',#{pkareacl},'%') </if>
<if test="pkcorp != null and pkcorp != ''"> and pk_corp like concat('%',#{pkcorp},'%') </if>
<if test="pkcorp1 != null and pkcorp1 != ''"> and pk_corp1 like concat('%',#{pkcorp1},'%') </if>
<if test="pkcubasdoc != null and pkcubasdoc != ''"> and pk_cubasdoc like concat('%',#{pkcubasdoc},'%') </if>
<if test="pkcubasdoc1 != null and pkcubasdoc1 != ''"> and pk_cubasdoc1 like concat('%',#{pkcubasdoc1},'%') </if>
<if test="pkpricegroup != null and pkpricegroup != ''"> and pk_pricegroup like concat('%',#{pkpricegroup},'%') </if>
<if test="registerfund != null and registerfund != ''"> and registerfund like concat('%',#{registerfund},'%') </if>
<if test="saleaddr != null and saleaddr != ''"> and saleaddr like concat('%',#{saleaddr},'%') </if>
<if test="sealflag != null and sealflag != ''"> and sealflag like concat('%',#{sealflag},'%') </if>
@ -459,12 +459,12 @@
<if test="phone1 != null and phone1 != ''"> or phone1 = #{phone1} </if>
<if test="phone2 != null and phone2 != ''"> or phone2 = #{phone2} </if>
<if test="phone3 != null and phone3 != ''"> or phone3 = #{phone3} </if>
<if test="pkAreacl != null and pkAreacl != ''"> or pk_areacl = #{pkAreacl} </if>
<if test="pkCorp != null and pkCorp != ''"> or pk_corp = #{pkCorp} </if>
<if test="pkCorp1 != null and pkCorp1 != ''"> or pk_corp1 = #{pkCorp1} </if>
<if test="pkCubasdoc != null and pkCubasdoc != ''"> or pk_cubasdoc = #{pkCubasdoc} </if>
<if test="pkCubasdoc1 != null and pkCubasdoc1 != ''"> or pk_cubasdoc1 = #{pkCubasdoc1} </if>
<if test="pkPricegroup != null and pkPricegroup != ''"> or pk_pricegroup = #{pkPricegroup} </if>
<if test="pkareacl != null and pkareacl != ''"> or pk_areacl = #{pkareacl} </if>
<if test="pkcorp != null and pkcorp != ''"> or pk_corp = #{pkcorp} </if>
<if test="pkcorp1 != null and pkcorp1 != ''"> or pk_corp1 = #{pkcorp1} </if>
<if test="pkcubasdoc != null and pkcubasdoc != ''"> or pk_cubasdoc = #{pkcubasdoc} </if>
<if test="pkcubasdoc1 != null and pkcubasdoc1 != ''"> or pk_cubasdoc1 = #{pkcubasdoc1} </if>
<if test="pkpricegroup != null and pkpricegroup != ''"> or pk_pricegroup = #{pkpricegroup} </if>
<if test="registerfund != null and registerfund != ''"> or registerfund = #{registerfund} </if>
<if test="saleaddr != null and saleaddr != ''"> or saleaddr = #{saleaddr} </if>
<if test="sealflag != null and sealflag != ''"> or sealflag = #{sealflag} </if>
@ -479,7 +479,7 @@
</select>
<!--新增所有列-->
<!--<insert id="entity_insert" parameterType = "com.hzya.frame.plugin.lets.entity.BdCubasdocEntity" keyProperty="pkCubasdoc" useGeneratedKeys="true">-->
<!--<insert id="entity_insert" parameterType = "com.hzya.frame.plugin.lets.entity.BdCubasdocEntity" keyProperty="pkcubasdoc" useGeneratedKeys="true">-->
<!-- insert into bd_cubasdoc(-->
<!-- <trim suffix="" suffixOverrides=",">-->
<!-- <if test="accdefault != null and accdefault != ''"> accdefault , </if>-->
@ -539,12 +539,12 @@
<!-- <if test="phone1 != null and phone1 != ''"> phone1 , </if>-->
<!-- <if test="phone2 != null and phone2 != ''"> phone2 , </if>-->
<!-- <if test="phone3 != null and phone3 != ''"> phone3 , </if>-->
<!-- <if test="pkAreacl != null and pkAreacl != ''"> pk_areacl , </if>-->
<!-- <if test="pkCorp != null and pkCorp != ''"> pk_corp , </if>-->
<!-- <if test="pkCorp1 != null and pkCorp1 != ''"> pk_corp1 , </if>-->
<!-- <if test="pkCubasdoc != null and pkCubasdoc != ''"> pk_cubasdoc , </if>-->
<!-- <if test="pkCubasdoc1 != null and pkCubasdoc1 != ''"> pk_cubasdoc1 , </if>-->
<!-- <if test="pkPricegroup != null and pkPricegroup != ''"> pk_pricegroup , </if>-->
<!-- <if test="pkareacl != null and pkareacl != ''"> pk_areacl , </if>-->
<!-- <if test="pkcorp != null and pkcorp != ''"> pk_corp , </if>-->
<!-- <if test="pkcorp1 != null and pkcorp1 != ''"> pk_corp1 , </if>-->
<!-- <if test="pkcubasdoc != null and pkcubasdoc != ''"> pk_cubasdoc , </if>-->
<!-- <if test="pkcubasdoc1 != null and pkcubasdoc1 != ''"> pk_cubasdoc1 , </if>-->
<!-- <if test="pkpricegroup != null and pkpricegroup != ''"> pk_pricegroup , </if>-->
<!-- <if test="registerfund != null and registerfund != ''"> registerfund , </if>-->
<!-- <if test="saleaddr != null and saleaddr != ''"> saleaddr , </if>-->
<!-- <if test="sealflag != null and sealflag != ''"> sealflag , </if>-->
@ -615,12 +615,12 @@
<!-- <if test="phone1 != null and phone1 != ''"> #{phone1} ,</if>-->
<!-- <if test="phone2 != null and phone2 != ''"> #{phone2} ,</if>-->
<!-- <if test="phone3 != null and phone3 != ''"> #{phone3} ,</if>-->
<!-- <if test="pkAreacl != null and pkAreacl != ''"> #{pkAreacl} ,</if>-->
<!-- <if test="pkCorp != null and pkCorp != ''"> #{pkCorp} ,</if>-->
<!-- <if test="pkCorp1 != null and pkCorp1 != ''"> #{pkCorp1} ,</if>-->
<!-- <if test="pkCubasdoc != null and pkCubasdoc != ''"> #{pkCubasdoc} ,</if>-->
<!-- <if test="pkCubasdoc1 != null and pkCubasdoc1 != ''"> #{pkCubasdoc1} ,</if>-->
<!-- <if test="pkPricegroup != null and pkPricegroup != ''"> #{pkPricegroup} ,</if>-->
<!-- <if test="pkareacl != null and pkareacl != ''"> #{pkareacl} ,</if>-->
<!-- <if test="pkcorp != null and pkcorp != ''"> #{pkcorp} ,</if>-->
<!-- <if test="pkcorp1 != null and pkcorp1 != ''"> #{pkcorp1} ,</if>-->
<!-- <if test="pkcubasdoc != null and pkcubasdoc != ''"> #{pkcubasdoc} ,</if>-->
<!-- <if test="pkcubasdoc1 != null and pkcubasdoc1 != ''"> #{pkcubasdoc1} ,</if>-->
<!-- <if test="pkpricegroup != null and pkpricegroup != ''"> #{pkpricegroup} ,</if>-->
<!-- <if test="registerfund != null and registerfund != ''"> #{registerfund} ,</if>-->
<!-- <if test="saleaddr != null and saleaddr != ''"> #{saleaddr} ,</if>-->
<!-- <if test="sealflag != null and sealflag != ''"> #{sealflag} ,</if>-->
@ -635,19 +635,19 @@
<!-- ) -->
<!--</insert>-->
<!-- 批量新增 -->
<!--<insert id="entityInsertBatch" keyProperty="pkCubasdoc" useGeneratedKeys="true">-->
<!--<insert id="entityInsertBatch" keyProperty="pkcubasdoc" useGeneratedKeys="true">-->
<!-- insert into bd_cubasdoc(accdefault, billtemplet, bp1, bp2, bp3, conaddr, correspondunit, createtime, creator, creditmny, custcode, custname, custprop, custshortname, def1, def10, def11, def12, def13, def14, def15, def16, def17, def18, def19, def2, def20, def3, def4, def5, def6, def7, def8, def9, dr, drpnodeflag, ecotypesincevfive, email, engname, fax1, fax2, freecustflag, isconnflag, legalbody, linkman1, linkman2, linkman3, memo, mnecode, mobilephone1, mobilephone2, mobilephone3, modifier, modifytime, phone1, phone2, phone3, pk_areacl, pk_corp, pk_corp1, pk_cubasdoc1, pk_pricegroup, registerfund, saleaddr, sealflag, taxpayerid, trade, ts, url, zipcode, sts) -->
<!-- values-->
<!-- <foreach collection="entities" item="entity" separator=",">-->
<!-- (#{entity.accdefault},#{entity.billtemplet},#{entity.bp1},#{entity.bp2},#{entity.bp3},#{entity.conaddr},#{entity.correspondunit},#{entity.createtime},#{entity.creator},#{entity.creditmny},#{entity.custcode},#{entity.custname},#{entity.custprop},#{entity.custshortname},#{entity.def1},#{entity.def10},#{entity.def11},#{entity.def12},#{entity.def13},#{entity.def14},#{entity.def15},#{entity.def16},#{entity.def17},#{entity.def18},#{entity.def19},#{entity.def2},#{entity.def20},#{entity.def3},#{entity.def4},#{entity.def5},#{entity.def6},#{entity.def7},#{entity.def8},#{entity.def9},#{entity.dr},#{entity.drpnodeflag},#{entity.ecotypesincevfive},#{entity.email},#{entity.engname},#{entity.fax1},#{entity.fax2},#{entity.freecustflag},#{entity.isconnflag},#{entity.legalbody},#{entity.linkman1},#{entity.linkman2},#{entity.linkman3},#{entity.memo},#{entity.mnecode},#{entity.mobilephone1},#{entity.mobilephone2},#{entity.mobilephone3},#{entity.modifier},#{entity.modifytime},#{entity.phone1},#{entity.phone2},#{entity.phone3},#{entity.pkAreacl},#{entity.pkCorp},#{entity.pkCorp1},#{entity.pkCubasdoc1},#{entity.pkPricegroup},#{entity.registerfund},#{entity.saleaddr},#{entity.sealflag},#{entity.taxpayerid},#{entity.trade},#{entity.ts},#{entity.url},#{entity.zipcode}, 'Y')-->
<!-- (#{entity.accdefault},#{entity.billtemplet},#{entity.bp1},#{entity.bp2},#{entity.bp3},#{entity.conaddr},#{entity.correspondunit},#{entity.createtime},#{entity.creator},#{entity.creditmny},#{entity.custcode},#{entity.custname},#{entity.custprop},#{entity.custshortname},#{entity.def1},#{entity.def10},#{entity.def11},#{entity.def12},#{entity.def13},#{entity.def14},#{entity.def15},#{entity.def16},#{entity.def17},#{entity.def18},#{entity.def19},#{entity.def2},#{entity.def20},#{entity.def3},#{entity.def4},#{entity.def5},#{entity.def6},#{entity.def7},#{entity.def8},#{entity.def9},#{entity.dr},#{entity.drpnodeflag},#{entity.ecotypesincevfive},#{entity.email},#{entity.engname},#{entity.fax1},#{entity.fax2},#{entity.freecustflag},#{entity.isconnflag},#{entity.legalbody},#{entity.linkman1},#{entity.linkman2},#{entity.linkman3},#{entity.memo},#{entity.mnecode},#{entity.mobilephone1},#{entity.mobilephone2},#{entity.mobilephone3},#{entity.modifier},#{entity.modifytime},#{entity.phone1},#{entity.phone2},#{entity.phone3},#{entity.pkareacl},#{entity.pkcorp},#{entity.pkcorp1},#{entity.pkcubasdoc1},#{entity.pkpricegroup},#{entity.registerfund},#{entity.saleaddr},#{entity.sealflag},#{entity.taxpayerid},#{entity.trade},#{entity.ts},#{entity.url},#{entity.zipcode}, 'Y')-->
<!-- </foreach>-->
<!--</insert>-->
<!-- 批量新增或者修改-->
<!--<insert id="entityInsertOrUpdateBatch" keyProperty="pkCubasdoc" useGeneratedKeys="true">-->
<!--<insert id="entityInsertOrUpdateBatch" keyProperty="pkcubasdoc" useGeneratedKeys="true">-->
<!-- insert into bd_cubasdoc(accdefault, billtemplet, bp1, bp2, bp3, conaddr, correspondunit, createtime, creator, creditmny, custcode, custname, custprop, custshortname, def1, def10, def11, def12, def13, def14, def15, def16, def17, def18, def19, def2, def20, def3, def4, def5, def6, def7, def8, def9, dr, drpnodeflag, ecotypesincevfive, email, engname, fax1, fax2, freecustflag, isconnflag, legalbody, linkman1, linkman2, linkman3, memo, mnecode, mobilephone1, mobilephone2, mobilephone3, modifier, modifytime, phone1, phone2, phone3, pk_areacl, pk_corp, pk_corp1, pk_cubasdoc1, pk_pricegroup, registerfund, saleaddr, sealflag, taxpayerid, trade, ts, url, zipcode)-->
<!-- values-->
<!-- <foreach collection="entities" item="entity" separator=",">-->
<!-- (#{entity.accdefault},#{entity.billtemplet},#{entity.bp1},#{entity.bp2},#{entity.bp3},#{entity.conaddr},#{entity.correspondunit},#{entity.createtime},#{entity.creator},#{entity.creditmny},#{entity.custcode},#{entity.custname},#{entity.custprop},#{entity.custshortname},#{entity.def1},#{entity.def10},#{entity.def11},#{entity.def12},#{entity.def13},#{entity.def14},#{entity.def15},#{entity.def16},#{entity.def17},#{entity.def18},#{entity.def19},#{entity.def2},#{entity.def20},#{entity.def3},#{entity.def4},#{entity.def5},#{entity.def6},#{entity.def7},#{entity.def8},#{entity.def9},#{entity.dr},#{entity.drpnodeflag},#{entity.ecotypesincevfive},#{entity.email},#{entity.engname},#{entity.fax1},#{entity.fax2},#{entity.freecustflag},#{entity.isconnflag},#{entity.legalbody},#{entity.linkman1},#{entity.linkman2},#{entity.linkman3},#{entity.memo},#{entity.mnecode},#{entity.mobilephone1},#{entity.mobilephone2},#{entity.mobilephone3},#{entity.modifier},#{entity.modifytime},#{entity.phone1},#{entity.phone2},#{entity.phone3},#{entity.pkAreacl},#{entity.pkCorp},#{entity.pkCorp1},#{entity.pkCubasdoc1},#{entity.pkPricegroup},#{entity.registerfund},#{entity.saleaddr},#{entity.sealflag},#{entity.taxpayerid},#{entity.trade},#{entity.ts},#{entity.url},#{entity.zipcode})-->
<!-- (#{entity.accdefault},#{entity.billtemplet},#{entity.bp1},#{entity.bp2},#{entity.bp3},#{entity.conaddr},#{entity.correspondunit},#{entity.createtime},#{entity.creator},#{entity.creditmny},#{entity.custcode},#{entity.custname},#{entity.custprop},#{entity.custshortname},#{entity.def1},#{entity.def10},#{entity.def11},#{entity.def12},#{entity.def13},#{entity.def14},#{entity.def15},#{entity.def16},#{entity.def17},#{entity.def18},#{entity.def19},#{entity.def2},#{entity.def20},#{entity.def3},#{entity.def4},#{entity.def5},#{entity.def6},#{entity.def7},#{entity.def8},#{entity.def9},#{entity.dr},#{entity.drpnodeflag},#{entity.ecotypesincevfive},#{entity.email},#{entity.engname},#{entity.fax1},#{entity.fax2},#{entity.freecustflag},#{entity.isconnflag},#{entity.legalbody},#{entity.linkman1},#{entity.linkman2},#{entity.linkman3},#{entity.memo},#{entity.mnecode},#{entity.mobilephone1},#{entity.mobilephone2},#{entity.mobilephone3},#{entity.modifier},#{entity.modifytime},#{entity.phone1},#{entity.phone2},#{entity.phone3},#{entity.pkareacl},#{entity.pkcorp},#{entity.pkcorp1},#{entity.pkcubasdoc1},#{entity.pkpricegroup},#{entity.registerfund},#{entity.saleaddr},#{entity.sealflag},#{entity.taxpayerid},#{entity.trade},#{entity.ts},#{entity.url},#{entity.zipcode})-->
<!-- </foreach>-->
<!-- on duplicate key update-->
<!-- accdefault = values(accdefault),-->
@ -781,11 +781,11 @@
<!-- <if test="phone1 != null and phone1 != ''"> phone1 = #{phone1},</if>-->
<!-- <if test="phone2 != null and phone2 != ''"> phone2 = #{phone2},</if>-->
<!-- <if test="phone3 != null and phone3 != ''"> phone3 = #{phone3},</if>-->
<!-- <if test="pkAreacl != null and pkAreacl != ''"> pk_areacl = #{pkAreacl},</if>-->
<!-- <if test="pkCorp != null and pkCorp != ''"> pk_corp = #{pkCorp},</if>-->
<!-- <if test="pkCorp1 != null and pkCorp1 != ''"> pk_corp1 = #{pkCorp1},</if>-->
<!-- <if test="pkCubasdoc1 != null and pkCubasdoc1 != ''"> pk_cubasdoc1 = #{pkCubasdoc1},</if>-->
<!-- <if test="pkPricegroup != null and pkPricegroup != ''"> pk_pricegroup = #{pkPricegroup},</if>-->
<!-- <if test="pkareacl != null and pkareacl != ''"> pk_areacl = #{pkareacl},</if>-->
<!-- <if test="pkcorp != null and pkcorp != ''"> pk_corp = #{pkcorp},</if>-->
<!-- <if test="pkcorp1 != null and pkcorp1 != ''"> pk_corp1 = #{pkcorp1},</if>-->
<!-- <if test="pkcubasdoc1 != null and pkcubasdoc1 != ''"> pk_cubasdoc1 = #{pkcubasdoc1},</if>-->
<!-- <if test="pkpricegroup != null and pkpricegroup != ''"> pk_pricegroup = #{pkpricegroup},</if>-->
<!-- <if test="registerfund != null and registerfund != ''"> registerfund = #{registerfund},</if>-->
<!-- <if test="saleaddr != null and saleaddr != ''"> saleaddr = #{saleaddr},</if>-->
<!-- <if test="sealflag != null and sealflag != ''"> sealflag = #{sealflag},</if>-->
@ -795,12 +795,12 @@
<!-- <if test="url != null and url != ''"> url = #{url},</if>-->
<!-- <if test="zipcode != null and zipcode != ''"> zipcode = #{zipcode},</if>-->
<!--</trim>-->
<!--where pk_cubasdoc = #{pkCubasdoc}-->
<!--where pk_cubasdoc = #{pkcubasdoc}-->
<!--</update>-->
<!-- 逻辑删除 -->
<!--<update id="entity_logicDelete" parameterType = "com.hzya.frame.plugin.lets.entity.BdCubasdocEntity" >-->
<!--update bd_cubasdoc set sts= 'N'-->
<!--where pk_cubasdoc = #{pkCubasdoc}-->
<!--where pk_cubasdoc = #{pkcubasdoc}-->
<!--</update>-->
<!-- 多条件逻辑删除 -->
<!--<update id="entity_logicDelete_Multi_Condition" parameterType = "com.hzya.frame.plugin.lets.entity.BdCubasdocEntity" >-->
@ -863,12 +863,12 @@
<!-- <if test="phone1 != null and phone1 != ''"> and phone1 = #{phone1} </if>-->
<!-- <if test="phone2 != null and phone2 != ''"> and phone2 = #{phone2} </if>-->
<!-- <if test="phone3 != null and phone3 != ''"> and phone3 = #{phone3} </if>-->
<!-- <if test="pkAreacl != null and pkAreacl != ''"> and pk_areacl = #{pkAreacl} </if>-->
<!-- <if test="pkCorp != null and pkCorp != ''"> and pk_corp = #{pkCorp} </if>-->
<!-- <if test="pkCorp1 != null and pkCorp1 != ''"> and pk_corp1 = #{pkCorp1} </if>-->
<!-- <if test="pkCubasdoc != null and pkCubasdoc != ''"> and pk_cubasdoc = #{pkCubasdoc} </if>-->
<!-- <if test="pkCubasdoc1 != null and pkCubasdoc1 != ''"> and pk_cubasdoc1 = #{pkCubasdoc1} </if>-->
<!-- <if test="pkPricegroup != null and pkPricegroup != ''"> and pk_pricegroup = #{pkPricegroup} </if>-->
<!-- <if test="pkareacl != null and pkareacl != ''"> and pk_areacl = #{pkareacl} </if>-->
<!-- <if test="pkcorp != null and pkcorp != ''"> and pk_corp = #{pkcorp} </if>-->
<!-- <if test="pkcorp1 != null and pkcorp1 != ''"> and pk_corp1 = #{pkcorp1} </if>-->
<!-- <if test="pkcubasdoc != null and pkcubasdoc != ''"> and pk_cubasdoc = #{pkcubasdoc} </if>-->
<!-- <if test="pkcubasdoc1 != null and pkcubasdoc1 != ''"> and pk_cubasdoc1 = #{pkcubasdoc1} </if>-->
<!-- <if test="pkpricegroup != null and pkpricegroup != ''"> and pk_pricegroup = #{pkpricegroup} </if>-->
<!-- <if test="registerfund != null and registerfund != ''"> and registerfund = #{registerfund} </if>-->
<!-- <if test="saleaddr != null and saleaddr != ''"> and saleaddr = #{saleaddr} </if>-->
<!-- <if test="sealflag != null and sealflag != ''"> and sealflag = #{sealflag} </if>-->
@ -883,7 +883,7 @@
<!--通过主键删除-->
<!--<delete id="entity_delete">-->
<!-- delete from bd_cubasdoc where pk_cubasdoc = #{pkCubasdoc}-->
<!-- delete from bd_cubasdoc where pk_cubasdoc = #{pkcubasdoc}-->
<!--</delete>-->
<!-- 根据客商管理档案的基础档案主键，查询客商管理档案信息-->
@ -895,7 +895,7 @@
bca.dr = 0
and bc.dr = 0
and bca.pk_cumandoc = #{pk_cumandoc}
and bca.pk_corp = #{pkCorp}
and bca.pk_corp = #{pkcorp}
</select>
<!--sm_user根据pk查username-->
<select id="selectUserNameByPk" parameterType="String" resultType="String">

3
buildpackage/src/main/java/com/hzya/frame/plugin/lets/entity/BdCumandocEntity.java
View File

@ -31,6 +31,9 @@ public class BdCumandocEntity extends BaseEntity {
private String creditmoney;
private Long credlimitflag;
private String custflag;
// 客商名称
private String custname;
private Long custstate;
private String def1;
private String def10;

2
buildpackage/src/main/java/com/hzya/frame/plugin/lets/entity/BdJobbasfilEntity.xml
View File

@ -502,7 +502,7 @@ update bd_jobbasfil set sts= 'N' ,modify_time = #{modify_time},modify_user_id =
bcd0c.custcode shopCorrCustCode,
bcd0c.custname shopCorrCustName,
bj.def5,
bj.def6,--存货品牌
bj.def6,--存牌
bd.docname def6name,--存货品牌名称
bj.def7,--旺店通店铺主键
bd2.docname def7name,--旺店通店铺名称

46
buildpackage/src/main/java/com/hzya/frame/plugin/lets/ofs/entity/ShopEntity.java Normal file
View File

@ -0,0 +1,46 @@
package com.hzya.frame.plugin.lets.ofs.entity;
import com.hzya.frame.web.entity.BaseEntity;
import lombok.Data;
/**
* @Author
* @Date 2024/8/6 14:57
* @PackageName:com.hzya.frame.plugin.lets.ofs.entity
* @ClassName: ShopEntity
* @Description: OFS店铺实体类
*/
@Data
public class ShopEntity extends BaseEntity {
// 店铺业务编码
private String bizCode;
// 销售平台
private String platformCode;
// 店铺名称
private String name;
// 店主账号
private String ownerAccount;
// u8货主
private String u8CompanyCode;
// 运营类型
private String operationType;
// 业务
private String business;
// 客户分类编码
private String customerClassifyCode;
// 客户编码
private String customerCode;
// 客户管理类型编码
private String cmtCode;
// 品牌
private String brandCode;
// 组织
private String clientCode;
// 货主编码
private String companyCode;
private Integer status;
private String created_start;
private String created_end;
}

85
buildpackage/src/main/java/com/hzya/frame/plugin/lets/ofs/entity/ShopEntity.xml Normal file
View File

@ -0,0 +1,85 @@
<?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.hzya.frame.plugin.lets.ofs.entity.ShopEntity">
<resultMap id="BaseResultMap" type="com.hzya.frame.plugin.lets.ofs.entity.ShopEntity">
<id column="bizcode" property="bizCode" jdbcType="VARCHAR"/>
<result column="name" property="name" jdbcType="VARCHAR"/>
<result column="clientcode" property="clientCode" jdbcType="VARCHAR"/>
<result column="companycode" property="companyCode" jdbcType="VARCHAR"/>
<result column="ownernickname" property="ownerNickName" jdbcType="VARCHAR"/>
<result column="platformcode" property="platformCode" jdbcType="VARCHAR"/>
<result column="storeplatformid" property="storePlatformId" jdbcType="VARCHAR"/>
<result column="owneraccount" property="ownerAccount" jdbcType="VARCHAR"/>
<result column="ownername" property="ownerName" jdbcType="VARCHAR"/>
<result column="opendate" property="openDate" jdbcType="VARCHAR"/>
<result column="closedate" property="closeDate" jdbcType="VARCHAR"/>
<result column="address" property="address" jdbcType="VARCHAR"/>
<result column="country" property="country" jdbcType="VARCHAR"/>
<result column="state" property="state" jdbcType="VARCHAR"/>
<result column="city" property="city" jdbcType="VARCHAR"/>
<result column="district" property="district" jdbcType="VARCHAR"/>
<result column="attention_to" property="attentionTo" jdbcType="VARCHAR"/>
<result column="mobile" property="mobile" jdbcType="VARCHAR"/>
<result column="status" property="status" jdbcType="VARCHAR"/>
</resultMap>
<sql id="Base_Column_List">
biz_code
, name, client_code, company_code, owner_nick_name, platform_code, store_platform_id, owner_account, owner_name, open_date, close_date, address, country, state, city, district, attention_to, mobile, status
</sql>
<select id="selectByBizCode" resultMap="BaseResultMap" parameterType="java.lang.String">
select
<include refid="Base_Column_List"/>
from shop
where biz_code = #{bizCode,jdbcType=VARCHAR}
</select>
<select id="selectByClientCode" resultMap="BaseResultMap" parameterType="java.lang.String">
select
<include refid="Base_Column_List"/>
from shop
where client_code = #{clientCode,jdbcType=VARCHAR}
</select>
<select id="selectByCompanyCode" resultMap="BaseResultMap" parameterType="java.lang.String">
select
<include refid="Base_Column_List"/>
from shop
where company_code = #{companyCode,jdbcType=VARCHAR}
</select>
<select id="selectByOwnerNickName" resultMap="BaseResultMap" parameterType="java.lang.String">
select
<include refid="Base_Column_List"/>
from shop
where owner_nick_name = #{ownerNickName,jdbcType=VARCHAR}
</select>
<!-- 查询 采用==查询 -->
<select id="entity_list_base" resultMap="BaseResultMap"
parameterType="com.hzya.frame.plugin.lets.ofs.entity.ShopEntity">
select
<include refid="Base_Column_List"/>
from tocofs_saleout_detailed
<trim prefix="where" prefixOverrides="and">
<if test="bizcode != null">and biz_code = #{bizcode}</if>
<if test="name!= null">and name = #{name}</if>
<if test="clientcode!= null">and client_code = #{clientcode}</if>
<if test="companycode!= null">and company_code = #{companycode}</if>
<if test="ownernickname!= null">and owner_nick_name = #{ownernickname}</if>
<if test="platformcode!= null">and platform_code = #{platformcode}</if>
<if test="storeplatformid!= null">and store_platform_id = #{storeplatformid}</if>
<if test="owneraccount!= null">and owner_account = #{owneraccount}</if>
<if test="ownername!= null">and owner_name = #{ownername}</if>
<if test="opendate!= null">and open_date = #{opendate}</if>
<if test="closedate!= null">and close_date = #{closedate}</if>
<if test="address!= null">and address = #{address}</if>
<if test="country!= null">and country = #{country}</if>
<if test="state!= null">and state = #{state}</if>
<if test="city!= null">and city = #{city}</if>
<if test="district!= null">and district = #{district}</if>
<if test="attentionto!= null">and attention_to = #{attentionto}</if>
<if test="mobile!= null">and mobile = #{mobile}</if>
<if test="status!= null">and status = #{status}</if>
</trim>
</select>
</mapper>

38
buildpackage/src/main/java/com/hzya/frame/plugin/lets/ofs/entity/SupplierEntity.java Normal file
View File

@ -0,0 +1,38 @@
package com.hzya.frame.plugin.lets.ofs.entity;
import lombok.Data;
/**
* @Author
* @Date 2024/8/7 10:23
* @PackageName:com.hzya.frame.plugin.lets.ofs.entity
* @ClassName: SupplierEntity
* @Description: TODO
*/
@Data
public class SupplierEntity {
//业务编码
private String bizCode;
//供应商名称
private String name;
//组织
private String clientCode;
//货主编码
private String companyCode;
//地址
private String address;
//国家
private String country;
//省
private String state;
//市
private String city;
//区
private String district;
//联系人
private String attentionTo;
//手机号
private String mobile;
//状态
private String status;
}

288
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/CustdocAutoAllotPluginInitializer.java Normal file
View File

@ -0,0 +1,288 @@
package com.hzya.frame.plugin.lets.plugin.base;
import cn.hutool.core.lang.Assert;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.base.PluginBaseEntity;
import com.hzya.frame.plugin.lets.constant.OverallConstant;
import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant;
import com.hzya.frame.plugin.lets.entity.BdInvbasdocEntity;
import com.hzya.frame.plugin.lets.queryvo.CustDocAssginVo;
import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo;
import com.hzya.frame.plugin.lets.resultvo.CbdocResultVo;
import com.hzya.frame.plugin.lets.u8cdto.ReusltStrDto;
import com.hzya.frame.plugin.lets.util.PushDataByU8cUtil;
import com.hzya.frame.plugin.lets.util.SaveOrUpdateBusinessLogUtil;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.dao.IIntegrationTaskLivingDetailsDao;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.*;
import java.util.concurrent.locks.ReentrantLock;
/**
* @Author
* @Date 2024/8/12 13:57
* @PackageName:com.hzya.frame.plugin.lets.plugin.base
* @ClassName: CustdocAutoAllotPluginInitializer
* @Description: 客商档案自动分配
*/
public class CustdocAutoAllotPluginInitializer extends PluginBaseEntity {
Logger logger = LoggerFactory.getLogger(GoodsAutoAllotPluginInitializer.class);
private static final ReentrantLock LOCK = new ReentrantLock(true);
@Override
public void initialize() {
logger.info(getPluginLabel() + "執行初始化方法initialize()");
}
@Override
public void destroy() {
logger.info(getPluginLabel() + "執行銷毀方法destroy()");
}
@Override
public String getPluginId() {
return "com.hzya.frame.plugin.lets.plugin.base.GoodsAutoAllotPluginInitializer";
}
@Override
public String getPluginName() {
return "丽知：U8C->客商基本档案自动分配全公司";
}
@Override
public String getPluginLabel() {
return "丽知：U8C->客商基本档案自动分配全公司";
}
@Override
public String getPluginType() {
return "1";
}
@Autowired
private IIntegrationTaskLivingDetailsDao iIntegrationTaskLivingDetailsDao;
@Autowired
private PushDataByU8cUtil pushDataByU8cUtil;
@Autowired
private SaveOrUpdateBusinessLogUtil saveOrUpdateBusinessLogUtil;
@Override
public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
return null;
}
/**
* 默认推送
*/
public void start() {
try {
//查询要分配的客商
List<CustdocRequestVo> list = queryCustDoc();
//推送：自动分配
implement(list);
} catch (Exception e) {
logger.error("丽知：U8C->客商基本档案自动分配全公司,start()方法报错：", e);
}
}
/**
* 过滤成功日志
*
* @return
*/
public List<BdInvbasdocEntity> filter(List<BdInvbasdocEntity> bdInvbasdocEntityList) {
List<BdInvbasdocEntity> filterInvbasdocList = new ArrayList<>();
for (BdInvbasdocEntity bdInvbasdocEntity : bdInvbasdocEntityList) {
String rootAppPk = bdInvbasdocEntity.getPkInvbasdoc();
boolean isExis = true;
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setRootAppPk(rootAppPk);
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity);
if (integrationTaskLivingDetailsEntities == null || integrationTaskLivingDetailsEntities.size() == 0) {
isExis = false;
}
if (!isExis) {
filterInvbasdocList.add(bdInvbasdocEntity);
}
}
return filterInvbasdocList;
}
/**
* 查询客商基本档案
* @return
*/
private List<CustdocRequestVo> queryCustDoc() {
List<CustdocRequestVo> custdocRequestVos=null;
try {
String data = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocQuery"), "{}");
CbdocResultVo cbdocResultVo = JSONObject.parseObject(data, CbdocResultVo.class);
String datastring = cbdocResultVo.getData();
List list = JSONObject.parseObject(datastring, List.class);
custdocRequestVos = filterData(list);
} catch (Exception e) {
logger.error("丽知：U8C->客商基本档案自动分配全公司,查询客商基本档案失败", e);
}
return custdocRequestVos;
}
private List<CustdocRequestVo> filterData(List list) {
List<CustdocRequestVo> filterlist = new ArrayList<>();
for (Object o : list) {
//o转为
CustdocRequestVo requestVo = JSONObject.parseObject(JSONObject.toJSONString(o), CustdocRequestVo.class);
if("N".equals(requestVo.getParentvo().getDef10())){
filterlist.add(requestVo);
}
}
return filterlist;
}
/**
* U8C->客商基本档案自动分配全公司
*/
public void implement(List<CustdocRequestVo> list) {
//查询公司档案
try {
String corpresponse = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("bdcorpQuery"), "{}");
CbdocResultVo cbdocResultVo = JSONObject.parseObject(corpresponse, CbdocResultVo.class);
if(cbdocResultVo.getStatus()!="success"){
Assert.state(false, "查询公司档案失败");
}
} catch (Exception e) {
throw new RuntimeException(e);
}
for (CustdocRequestVo custdocRequestVo : list) {
String assginjsonString = "";
String pkCubasdoc = custdocRequestVo.getParentvo().getPk_cubasdoc();
String createtime = custdocRequestVo.getParentvo().getCreatetime();
try {
ArrayList<CustDocAssginVo> assginvolist = new ArrayList<>();
CustDocAssginVo custDocAssginVo = new CustDocAssginVo();
custDocAssginVo.setPk_cubasdoc(pkCubasdoc);
custDocAssginVo.setAssignallcorps("Y");
custDocAssginVo.setCustprop("2");
assginvolist.add(custDocAssginVo);
HashMap<String, List> map = new HashMap<>();
map.put("custbasvo", list);
assginjsonString = JSONObject.toJSONString(map);
String response = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocAssign"), assginjsonString);
System.out.println(response);
boolean isSuccess = false;
if (response != null && !"".equals(response)) {
ReusltStrDto reusltStrDto = JSON.parseObject(response, ReusltStrDto.class);
if ("success".equals(reusltStrDto.getStatus())) {
isSuccess = true;
//分配成功去更新状态
updateDoc(custdocRequestVo);
}
}
if (!isSuccess) {
Assert.state(false, "推送U8C--> U8C->客商基本档案自动分配全公司 失败 接口返回结果：{} 接口入参:{}", response, assginjsonString);
}
//成功
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setRootAppNewData(assginjsonString);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(response);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(createtime);
integrationTaskLivingDetailsEntity.setRootAppPk(pkCubasdoc);
integrationTaskLivingDetailsEntity.setRootAppBill(pkCubasdoc);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
} catch (Exception e) {
e.printStackTrace();
logger.error("U8C->客商基本档案自动分配全公司implement(List<BdInvbasdocEntity> filterInvbasdocList)方法失败");
//失败
String ErrMessage = e.getMessage();
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_N);
integrationTaskLivingDetailsEntity.setRootAppNewData(assginjsonString);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(createtime);
integrationTaskLivingDetailsEntity.setRootAppPk(pkCubasdoc);
integrationTaskLivingDetailsEntity.setRootAppBill(pkCubasdoc);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
}
}
}
private void updateDoc(CustdocRequestVo custdocRequestVo) {
//已分配
String pkCubasdoc = custdocRequestVo.getParentvo().getPk_cubasdoc();
String createtime = custdocRequestVo.getParentvo().getCreatetime();
custdocRequestVo.getParentvo().setDef10("Y");
ArrayList<CustdocRequestVo> requestVos = new ArrayList<>();
requestVos.add(custdocRequestVo);
HashMap<String, List> map = new HashMap<>();
map.put("custbasvo", requestVos);
String data = JSONObject.toJSONString(map);
try {
String response = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocUpdate"), data);
boolean isSuccess = false;
if (response != null && !"".equals(response)) {
ReusltStrDto reusltStrDto = JSON.parseObject(response, ReusltStrDto.class);
if ("success".equals(reusltStrDto.getStatus())) {
isSuccess = true;
}
}
if (!isSuccess) {
Assert.state(false, "推送U8C--> U8C->客商基本档案自动分配全公司 失败 接口返回结果：{} 接口入参:{}", response, data);
}
//成功
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setRootAppNewData(data);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(response);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(createtime);
integrationTaskLivingDetailsEntity.setRootAppPk(pkCubasdoc);
integrationTaskLivingDetailsEntity.setRootAppBill(pkCubasdoc);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
} catch (Exception e) {
//失败
logger.error("U8C->客商基本档案更新updateDoc(CustdocRequestVo custdocRequestVo)方法失败");
String ErrMessage = e.getMessage();
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_N);
integrationTaskLivingDetailsEntity.setRootAppNewData(data);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(createtime);
integrationTaskLivingDetailsEntity.setRootAppPk(pkCubasdoc);
integrationTaskLivingDetailsEntity.setRootAppBill(pkCubasdoc);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
}
}
}

255
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/CustmandocPluginInitializer.java Normal file
View File

@ -0,0 +1,255 @@
package com.hzya.frame.plugin.lets.plugin.base;
import cn.hutool.core.lang.Assert;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.base.PluginBaseEntity;
import com.hzya.frame.plugin.lets.constant.OverallConstant;
import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant;
import com.hzya.frame.plugin.lets.entity.BdCubasdocEntity;
import com.hzya.frame.plugin.lets.entity.BdCumandocEntity;
import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo;
import com.hzya.frame.plugin.lets.queryvo.CustmandocRequestVo;
import com.hzya.frame.plugin.lets.u8cdto.ReusltStrDto;
import com.hzya.frame.plugin.lets.util.PushDataByU8cUtil;
import com.hzya.frame.plugin.lets.util.SaveOrUpdateBusinessLogUtil;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.dao.IIntegrationTaskLivingDetailsDao;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.locks.ReentrantLock;
/**
* @Author
* @Date 2024/8/12 15:25
* @PackageName:com.hzya.frame.plugin.lets.plugin.base
* @ClassName: CustmandocPluginInitializer
* @Description: 客商管理档案
*/
public class CustmandocPluginInitializer extends PluginBaseEntity {
Logger logger = LoggerFactory.getLogger(GoodsClassPluginInitializer.class);
private static final ReentrantLock LOCK = new ReentrantLock(true);
@Override
public void initialize() {
logger.info(getPluginLabel() + "執行初始化方法initialize()");
}
@Override
public void destroy() {
logger.info(getPluginLabel() + "執行銷毀方法destroy()");
}
@Override
public String getPluginId() {
return "com.hzya.frame.plugin.lets.plugin.base.GoodsClassPluginInitializer";
}
@Override
public String getPluginName() {
return "丽知：OFS客商档案--->U8C客商管理档案";
}
@Override
public String getPluginLabel() {
return "丽知：U8C客商基本档案--->U8C客商管理档案";
}
@Override
public String getPluginType() {
return "1";
}
@Autowired
private PushDataByU8cUtil pushDataByU8cUtil;
@Autowired
private IIntegrationTaskLivingDetailsDao iIntegrationTaskLivingDetailsDao;
@Autowired
private SaveOrUpdateBusinessLogUtil saveOrUpdateBusinessLogUtil;
@Override
public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
return null;
}
/**
* 默认推送
*/
public void start() {
try {
//获取符合条件客商基本档案
List<CustdocRequestVo> custdocRequestVos = queryCustDoc();
implement(custdocRequestVos);
} catch (Exception e) {
logger.error("丽知：U8C客商基本档案 --->U8C客商管理档案 ,start()方法报错：", e);
}
}
/**
* 查询客商基本档案
* @return
*/
private List<CustdocRequestVo> queryCustDoc() {
List<CustdocRequestVo> custdocRequestVos=null;
try {
String data = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocQuery"), "{}");
List list = JSONObject.parseObject(data, List.class);
custdocRequestVos = filterData(list);
} catch (Exception e) {
logger.error("丽知：查询客商基本档案失败", e);
}
return custdocRequestVos;
}
private List<CustdocRequestVo> filterData(List list) {
List<CustdocRequestVo> filterlist = new ArrayList<>();
for (Object o : list) {
//o转为
CustdocRequestVo BdCubasdocEntity = JSONObject.parseObject(JSONObject.toJSONString(o), CustdocRequestVo.class);
if("N".equals(BdCubasdocEntity.getParentvo().getDef11())){
filterlist.add(BdCubasdocEntity);
}
}
return filterlist;
}
public void implement(List<CustdocRequestVo> list) {
for (CustdocRequestVo vo : list) {
String mandocjsonString = "";
//生成业务日期
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 定义日期格式
Date date = new Date(System.currentTimeMillis()); // 创建Date对象
String businessFormat = sdf.format(date); // 将Date对象格式化为字符串
BdCubasdocEntity parentvo = vo.getParentvo();
try {
parentvo.setPk_areacl("F");
CustmandocRequestVo custmandocRequestVo = new CustmandocRequestVo();
custmandocRequestVo.setParentvo(parentvo);
custmandocRequestVo.setAddrs(vo.getAddrs());
// custmandocRequestVo.setBanks(vo.getBanks());
BdCumandocEntity BdCumandocEntity = new BdCumandocEntity();
BdCumandocEntity.setCustflag("0");
BdCumandocEntity BdCumandocEntity1 = new BdCumandocEntity();
BdCumandocEntity1.setCustflag("4");
List<BdCumandocEntity> custmandocEntities = new ArrayList<>();
custmandocEntities.add(BdCumandocEntity);
custmandocEntities.add(BdCumandocEntity1);
custmandocRequestVo.setChildrenvo(custmandocEntities);
HashMap<String, Object> mandocparam = new HashMap<>();
mandocparam.put("billvo", custmandocRequestVo);
mandocjsonString = JSONObject.toJSONString(mandocparam);
String response = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custmandocSave"), mandocjsonString);
System.out.println(response);
boolean isSuccess = false;
if (response != null && !"".equals(response)) {
ReusltStrDto reusltStrDto = JSON.parseObject(response, ReusltStrDto.class);
if ("success".equals(reusltStrDto.getStatus())) {
isSuccess = true;
updateDoc(vo);
}
}
if (!isSuccess) {
Assert.state(false, "推送U8C-->丽知：U8C客商基本档案 --->U8C客商管理档案 失败 接口返回结果：{} 接口入参:{}", response, mandocjsonString);
}
//成功
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setRootAppNewData(mandocjsonString);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(response);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk(parentvo.getPk_cubasdoc());
integrationTaskLivingDetailsEntity.setRootAppBill(parentvo.getCustcode());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
} catch (Exception e) {
e.printStackTrace();
logger.error("丽知：U8C客商基本档案 --->U8C客商管理档案 ,implement()方法报错", e);
//失败
String ErrMessage = e.getMessage();
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_N);
integrationTaskLivingDetailsEntity.setRootAppNewData(mandocjsonString);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk(parentvo.getPk_areacl());
integrationTaskLivingDetailsEntity.setRootAppBill(parentvo.getCustcode());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
}
}
}
private void updateDoc(CustdocRequestVo custdocRequestVo) {
//已分配
String pkCubasdoc = custdocRequestVo.getParentvo().getPk_cubasdoc();
String createtime = custdocRequestVo.getParentvo().getCreatetime();
custdocRequestVo.getParentvo().setDef11("Y");
ArrayList<CustdocRequestVo> requestVos = new ArrayList<>();
requestVos.add(custdocRequestVo);
HashMap<String, List> map = new HashMap<>();
map.put("custbasvo", requestVos);
String data = JSONObject.toJSONString(map);
try {
String response = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocUpdate"), data);
boolean isSuccess = false;
if (response != null && !"".equals(response)) {
ReusltStrDto reusltStrDto = JSON.parseObject(response, ReusltStrDto.class);
if ("success".equals(reusltStrDto.getStatus())) {
isSuccess = true;
}
}
if (!isSuccess) {
Assert.state(false, "更新客商基本档案失败 接口返回结果：{} 接口入参:{}", response, data);
}
//成功
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setRootAppNewData(data);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(response);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(createtime);
integrationTaskLivingDetailsEntity.setRootAppPk(pkCubasdoc);
integrationTaskLivingDetailsEntity.setRootAppBill(pkCubasdoc);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
} catch (Exception e) {
//失败
logger.error("U8C->客商基本档案更新updateDoc(CustdocRequestVo custdocRequestVo)方法失败");
String ErrMessage = e.getMessage();
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_N);
integrationTaskLivingDetailsEntity.setRootAppNewData(data);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(createtime);
integrationTaskLivingDetailsEntity.setRootAppPk(pkCubasdoc);
integrationTaskLivingDetailsEntity.setRootAppBill(pkCubasdoc);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
}
}
}

1
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/GoodsAutoAllotPluginInitializer.java
View File

@ -100,6 +100,7 @@ public class GoodsAutoAllotPluginInitializer extends PluginBaseEntity {
bdInvbasdocEntity.setCreatetime_start_time(startTimeStr);
bdInvbasdocEntity.setCreatetime_end_time(endTimeStr);
bdInvbasdocEntity.setDataSourceCode(ProfilesActiveConstant.LETS_DATE_SOURCE);
List<BdInvbasdocEntity> bdInvbasdocEntityList = bdInvbasdocDao.query(bdInvbasdocEntity);
if (bdInvbasdocEntityList.size() == 0) {
return;

1
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/GoodsClassPluginInitializer.java
View File

@ -115,7 +115,6 @@ public class GoodsClassPluginInitializer extends PluginBaseEntity {
} catch (Exception e) {
logger.error("丽知：OFS货品档案分类--->U8C货品档案分类,start(String className)方法报错：", e);
}
}
/**

354
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/ShopPluginInitializer.java Normal file
View File

@ -0,0 +1,354 @@
package com.hzya.frame.plugin.lets.plugin.base;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.Assert;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.base.PluginBaseEntity;
import com.hzya.frame.plugin.lets.constant.OverallConstant;
import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant;
import com.hzya.frame.plugin.lets.entity.BdCubasdocEntity;
import com.hzya.frame.plugin.lets.ofs.entity.ShopEntity;
import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo;
import com.hzya.frame.plugin.lets.resultvo.CbdocResultVo;
import com.hzya.frame.plugin.lets.resultvo.ShopReturnMessageDto;
import com.hzya.frame.plugin.lets.util.PushDataByU8cUtil;
import com.hzya.frame.plugin.lets.util.SaveOrUpdateBusinessLogUtil;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.dao.IIntegrationTaskLivingDetailsDao;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity;
import com.hzya.frame.ttxofs.dto.InterfaceParamDto;
import com.hzya.frame.ttxofs.service.OfsUnifiedService;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.concurrent.locks.ReentrantLock;
/**
* @Author
* @Date 2024/8/6 14:36
* @PackageName:com.hzya.frame.plugin.lets.plugin.base
* @ClassName: ShopPluginInitializer
* @Description: 店铺->U8C客商档案
*/
public class ShopPluginInitializer extends PluginBaseEntity {
Logger logger = LoggerFactory.getLogger(GoodsClassPluginInitializer.class);
private static final ReentrantLock LOCK = new ReentrantLock(true);
@Override
public void initialize() {
logger.info(getPluginLabel() + "执行初始化方法initialize()");
}
@Override
public void destroy() {
logger.info(getPluginLabel() + "执行销毁方法destroy()");
}
@Override
public String getPluginId() {
return "ShopPluginInitializer";
}
@Override
public String getPluginName() {
return "丽知：OFS店铺档案--->U8C客商档案";
}
@Override
public String getPluginLabel() {
return "丽知：OFS店铺档案--->U8C客商档案";
}
@Override
public String getPluginType() {
return "1";
}
// @Autowired
// private IShopDao shopDao;
@Autowired
private SaveOrUpdateBusinessLogUtil saveOrUpdateBusinessLogUtil;
@Autowired
private IIntegrationTaskLivingDetailsDao iIntegrationTaskLivingDetailsDao;
@Autowired
private PushDataByU8cUtil pushDataByU8cUtil;
@Autowired
private OfsUnifiedService ofsUnifiedService;
@Override
public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
String param = String.valueOf(requestJson.get("param"));
if (requestJson != null && ProfilesActiveConstant.TYPE_DATE.equals(requestJson.get("type"))) {
if (param != null && !"".equals(param)) {
String[] split = param.split("/");
startImplement(split[0], split[1]);
}
} else if (requestJson != null && ProfilesActiveConstant.TYPE_VBILLCODE.equals(requestJson.get("type"))) {
if (param != null && !"".equals(param)) {
startImplement(param);
}
} else if (ProfilesActiveConstant.TYPE_DETAIL_ERROR.equals(requestJson.get("type"))) {
String integration_task_living_details_id = (String) requestJson.get("integration_task_living_details_id");
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = saveOrUpdateBusinessLogUtil.queryIntegrationTaskLivingDetailsEntity(integration_task_living_details_id);
startImplement(integrationTaskLivingDetailsEntity.getRootAppPk());
} else {
startImplement();
}
return null;
}
public void startImplement(String startDate, String endDate) {
try {
ShopEntity shopEntity = new ShopEntity();
shopEntity.setCreated_start(startDate);
shopEntity.setCreated_end(endDate);
InterfaceParamDto interfaceParamDto = new InterfaceParamDto();
interfaceParamDto.setApi("ofs.store.search");
interfaceParamDto.setData(JSON.toJSONString(shopEntity));
ShopReturnMessageDto unified = (ShopReturnMessageDto) ofsUnifiedService.unified(interfaceParamDto);
List<ShopEntity> data = unified.getData();
List<ShopEntity> shopEntities = filterShopEntity(data);
implement(shopEntities);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 默认推送
*/
public void startImplement() {
try {
//获取当前时间
Date currentDate = new Date();
Date startTime = DateUtil.offset(currentDate, DateField.MINUTE, -10);
Date endTime = DateUtil.offset(currentDate, DateField.MINUTE, -2);
String startTimeStr = DateUtil.format(startTime, "yyyy-MM-dd HH:mm:ss");
String endTimeStr = DateUtil.format(endTime, "yyyy-MM-dd HH:mm:ss");
ShopEntity shopEntity = new ShopEntity();
//TODO ofs查询店铺信息
shopEntity.setCreated_start(startTimeStr);
shopEntity.setCreated_end(endTimeStr);
// List<ShopEntity> query = shopDao.query(shopEntity);
List<ShopEntity> query = new ArrayList<>();
query.add(shopEntity);
//过滤数据
// List<ShopEntity> shopEntities = filterShopEntity(query);
//同步u8c
implement(query);
} catch (Exception e) {
logger.error("丽知：OFS货品档案分类--->U8C货品档案分类,startImplement()方法报错：", e);
}
}
/**
* 按编码名称
*/
public void startImplement(String code) {
Assert.notNull(code, "code不能为空");
try {
ShopEntity shopEntity = new ShopEntity();
shopEntity.setBizCode(code);
//TODO ofs查询店铺信息
// List<ShopEntity> query = shopDao.query(shopEntity);
List<ShopEntity> query = null;
//过滤数据
List<ShopEntity> shopEntities = filterShopEntity(query);
//执行
implement(shopEntities);
} catch (Exception e) {
logger.error("丽知：OFS店铺档案--->U8C客商档案,startImplement(String code)方法报错：", e);
}
}
@Transactional
public void implement(List<ShopEntity> shopEntityList) {
Assert.notNull(shopEntityList, "shopEntityList不能为空");
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date = new Date(System.currentTimeMillis());
String businessFormat = sdf.format(date);
for (ShopEntity shopEntity : shopEntityList) {
try {
BdCubasdocEntity parentvo = new BdCubasdocEntity();
CustdocRequestVo BdCubasdocEntity = new CustdocRequestVo();
//TODO 设置parentvo
parentvo.setCustname(shopEntity.getName());
parentvo.setCustshortname(shopEntity.getName());
parentvo.setCustcode(shopEntity.getCustomerCode());
//设置还未分配公司
parentvo.setDef10("N");
//设置还同步到管理档案
parentvo.setDef11("N");
// parentvo.setCustprop("0");
BdCubasdocEntity.setParentvo(parentvo);
//TODO 同步u8c
HashMap<String, Object> param = new HashMap<>();
param.put("cbdocvo", BdCubasdocEntity);
String jsonString = JSONObject.toJSONString(param);
String response = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocSave"), jsonString);
System.out.println(response);
if (response != null) {
CbdocResultVo cbdocResultVo = JSONObject.parseObject(response, CbdocResultVo.class);
String taskNumber = null;
boolean isSuccess = false;
if ("success".equals(cbdocResultVo.getStatus())) {
isSuccess = true;
taskNumber = cbdocResultVo.getTaskNumber();
String data = cbdocResultVo.getData();
// CustdocRequestVo BdCubasdocEntity1 = JSONObject.parseObject(data, CustdocRequestVo.class);
// List list = JSONObject.parseObject(data, List.class);
// Object o = list.get(0);
// CustdocRequestVo BdCubasdocEntity1 = JSONObject.parseObject(JSONObject.toJSONString(o), CustdocRequestVo.class);
//
// //分配给所有公司
// CustDocAssginVo custDocAssginVo = new CustDocAssginVo();
// custDocAssginVo.setAssignallcorps("Y");
// //分配给所有的公司
//// custDocAssginVo.setCustprop("0");
// //客户基本档案主键
// custDocAssginVo.setPk_cubasdoc(BdCubasdocEntity1.getParentvo().getPk_cubasdoc());
// //公司主键
//// custDocAssginVo.setPk_corp(BdCubasdocEntity1.getParentvo().getPk_corp());
// custDocAssginVo.setCustprop("2");
// HashMap<String, Object> assginHashMap = new HashMap<>();
// assginHashMap.put("custbasvo", custDocAssginVo);
// String assginjsonString = JSONObject.toJSONString(assginHashMap);
// String assignresponse = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocAssign"), assginjsonString);
// CbdocResultVo cbdocResultVo1 = JSONObject.parseObject(assignresponse, CbdocResultVo.class);
// if (!"success".equals(cbdocResultVo1.getStatus())) {
// isSuccess = false;
// }
//生成客商管理档案
//TODO 设置属性
//地区名称：丽知商城客商？
// parentvo.setPk_areacl("F");
//
// parentvo.setCustprop(BdCubasdocEntity1.getParentvo().getCustprop());
// CustmandocRequestVo custmandocRequestVo = new CustmandocRequestVo();
// custmandocRequestVo.setParentvo(parentvo);
// BdCumandocEntity BdCumandocEntity = new BdCumandocEntity();
// BdCumandocEntity.setCustflag("0");
// BdCumandocEntity BdCumandocEntity1 = new BdCumandocEntity();
// BdCumandocEntity1.setCustflag("4");
// List<BdCumandocEntity> custmandocEntities = new ArrayList<>();
// custmandocEntities.add(BdCumandocEntity);
// custmandocEntities.add(BdCumandocEntity1);
// custmandocRequestVo.setChildrenvo(custmandocEntities);
// HashMap<String, Object> mandocparam = new HashMap<>();
// mandocparam.put("billvo", custmandocRequestVo);
// String mandocjsonString = JSONObject.toJSONString(mandocparam);
// String mandocresponse = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custmandocSave"), mandocjsonString);
// CbdocResultVo mandoccbdocResultVo = JSONObject.parseObject(mandocresponse, CbdocResultVo.class);
// if (!"success".equals(mandoccbdocResultVo.getStatus())) {
// isSuccess = false;
// }
}
if (!isSuccess) {
Assert.state(false, "同步到U8C失败，原因：{} 接口入参:{} {}", JSON.toJSONString(cbdocResultVo), JSON.toJSONString(OverallConstant.getOverAllValue("custdocSave")), JSON.toJSONString(BdCubasdocEntity));
}
//TODO 根据返回结果记录日志
//成功
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setRootAppNewData(jsonString);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(JSON.toJSONString(cbdocResultVo));
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk(shopEntity.getBizCode());
integrationTaskLivingDetailsEntity.setRootAppBill(shopEntity.getName());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
//TODO 更新店铺状态
// CbdocResultVo cbdocResultVo1 = JSONObject.parseObject(response, CbdocResultVo.class);
// String errormsg = cbdocResultVo1.getErrormsg();
}
} catch (Exception e) {
e.printStackTrace();
String ErrMessage = e.getMessage();
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_N);
integrationTaskLivingDetailsEntity.setRootAppNewData(JSONObject.toJSONString(shopEntity));
integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk(shopEntity.getBizCode());
integrationTaskLivingDetailsEntity.setRootAppBill(shopEntity.getName());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
logger.error("丽知：OFS店铺档案--->U8C客商档案,implement()方法报错：", e);
}
}
}
public List<ShopEntity> filterShopEntity(List<ShopEntity> list) {
Assert.notNull(list, "不能为空！");
List<ShopEntity> shopEntityList = new ArrayList<>();
if (list != null && list.size() > 0) {
for (int i = 0; i < list.size(); i++) {
ShopEntity shopEntity = list.get(i);
if (shopEntity.getBizCode() != null && !"".equals(shopEntity.getBizCode().trim())) {
boolean isExis = true;
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setRootAppPk(shopEntity.getBizCode());
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y_H);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity);
if (integrationTaskLivingDetailsEntities == null || integrationTaskLivingDetailsEntities.size() == 0) {
isExis = false;
}
if (!isExis) {
shopEntityList.add(shopEntity);
}
}
}
}
return shopEntityList;
}
}

322
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/SupplierPluginInitializer.java Normal file
View File

@ -0,0 +1,322 @@
package com.hzya.frame.plugin.lets.plugin.base;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.Assert;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.base.PluginBaseEntity;
import com.hzya.frame.plugin.lets.constant.OverallConstant;
import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant;
import com.hzya.frame.plugin.lets.entity.BdCubasdocEntity;
import com.hzya.frame.plugin.lets.ofs.entity.ShopEntity;
import com.hzya.frame.plugin.lets.ofs.entity.SupplierEntity;
import com.hzya.frame.plugin.lets.queryvo.CustDocAssginVo;
import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo;
import com.hzya.frame.plugin.lets.queryvo.CustmandocRequestVo;
import com.hzya.frame.plugin.lets.resultvo.CbdocResultVo;
import com.hzya.frame.plugin.lets.util.PushDataByU8cUtil;
import com.hzya.frame.plugin.lets.util.SaveOrUpdateBusinessLogUtil;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.dao.IIntegrationTaskLivingDetailsDao;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.concurrent.locks.ReentrantLock;
/**
* @Author
* @Date 2024/8/6 14:36
* @PackageName:com.hzya.frame.plugin.lets.plugin.base
* @ClassName: ShopPluginInitializer
* @Description: 供应商档案->客商档案
*/
public class SupplierPluginInitializer extends PluginBaseEntity {
Logger logger = LoggerFactory.getLogger(GoodsClassPluginInitializer.class);
private static final ReentrantLock LOCK = new ReentrantLock(true);
@Override
public void initialize() {
logger.info(getPluginLabel() + "执行初始化方法initialize()");
}
@Override
public void destroy() {
logger.info(getPluginLabel() + "执行销毁方法destroy()");
}
@Override
public String getPluginId() {
return "ShopPluginInitializer";
}
@Override
public String getPluginName() {
return "丽知：OFS供应商档案--->U8C客商档案";
}
@Override
public String getPluginLabel() {
return "丽知：OFS供应商档案--->U8C客商档案";
}
@Override
public String getPluginType() {
return "1";
}
@Autowired
private SaveOrUpdateBusinessLogUtil saveOrUpdateBusinessLogUtil;
@Autowired
private IIntegrationTaskLivingDetailsDao iIntegrationTaskLivingDetailsDao;
@Autowired
private PushDataByU8cUtil pushDataByU8cUtil;
@Override
public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
String param = String.valueOf(requestJson.get("param"));
if (requestJson != null && ProfilesActiveConstant.TYPE_VBILLCODE.equals(requestJson.get("type"))) {
if (param != null && !"".equals(param)) {
startImplement(param);
}
} else if (ProfilesActiveConstant.TYPE_DETAIL_ERROR.equals(requestJson.get("type"))) {
String integration_task_living_details_id = (String) requestJson.get("integration_task_living_details_id");
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = saveOrUpdateBusinessLogUtil.queryIntegrationTaskLivingDetailsEntity(integration_task_living_details_id);
startImplement(integrationTaskLivingDetailsEntity.getRootAppPk());
} else {
startImplement();
}
return null;
}
/**
* 默认推送
*/
public void startImplement() {
try {
//获取当前时间
//获取当前时间
Date currentDate = new Date();
Date startTime = DateUtil.offset(currentDate, DateField.MINUTE, -10);
Date endTime = DateUtil.offset(currentDate, DateField.MINUTE, -2);
String startTimeStr = DateUtil.format(startTime, "yyyy-MM-dd HH:mm:ss");
String endTimeStr = DateUtil.format(endTime, "yyyy-MM-dd HH:mm:ss");
SupplierEntity supplierEntity = new SupplierEntity();
//TODO ofs查询店铺信息
// List<ShopEntity> query = shopDao.query(shopEntity);
List<SupplierEntity> query = null;
//过滤数据
List<SupplierEntity> supplierEntities = filterSupplierEntity(query);
implement(supplierEntities);
} catch (Exception e) {
logger.error("丽知：OFS供应商档案--->U8C客商档案,startImplement()方法报错：", e);
}
}
/**
* 按编码名称
*/
public void startImplement(String code) {
Assert.notNull(code, "code不能为空");
try {
ShopEntity shopEntity = new ShopEntity();
shopEntity.setBizCode(code);
//TODO ofs查询供应商信息
List<SupplierEntity> query = null;
//过滤数据
List<SupplierEntity> supplierEntities = filterSupplierEntity(query);
//执行
implement(supplierEntities);
} catch (Exception e) {
logger.error("丽知：OFS供应商档案--->U8C客商档案,startImplement(String code)方法报错：", e);
}
}
/**
* 按时间区间
*/
public void startImplement(String startTime, String endTime) {
try {
Date business_start = DateUtil.parse(startTime);
Date business_end = DateUtil.parse(endTime);
String start = DateUtil.format(business_start, "yyyy-MM-dd") + " 00:00:00";
String end = DateUtil.format(business_end, "yyyy-MM-dd") + " 23:59:59";
ShopEntity shopEntity = new ShopEntity();
shopEntity.setCreated_start(start);
shopEntity.setCreated_end(end);
//TODO ofs查询供应商信息
} catch (Exception e) {
logger.error("丽知：OFS供应商档案--->U8C客商档案,startImplement(String startTime, String endTime)方法报错：", e);
}
}
public void implement(List<SupplierEntity> shopEntityList) {
Assert.notNull(shopEntityList, "shopEntityList不能为空");
//业务时间
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date = new Date(System.currentTimeMillis());
String businessFormat = sdf.format(date);
for (SupplierEntity supplierEntity : shopEntityList) {
BdCubasdocEntity parentvo = new BdCubasdocEntity();
CustdocRequestVo BdCubasdocEntity = new CustdocRequestVo();
try {
//TODO 设置parentvo
// parentvo.setPk_areacl("");
parentvo.setCustname(supplierEntity.getName());
parentvo.setCustshortname(supplierEntity.getName());
parentvo.setCustcode(supplierEntity.getCompanyCode());
BdCubasdocEntity.setParentvo(parentvo);
//TODO 同步u8c
HashMap<String, Object> param = new HashMap<>();
param.put("cbdocvo", BdCubasdocEntity);
String jsonString = JSONObject.toJSONString(param);
String response = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocSave"), jsonString);
if (response != null) {
CbdocResultVo cbdocResultVo = JSONObject.parseObject(response, CbdocResultVo.class);
String taskNumber = null;
boolean isSuccess = false;
if ("success".equals(cbdocResultVo.getStatus())) {
isSuccess = true;
taskNumber = cbdocResultVo.getTaskNumber();
String data = cbdocResultVo.getData();
// CustdocRequestVo BdCubasdocEntity1 = JSONObject.parseObject(data, CustdocRequestVo.class);
List datalist = JSONObject.parseObject(data, List.class);
Object o = datalist.get(0);
CustdocRequestVo BdCubasdocEntity1 = JSONObject.parseObject(JSONObject.toJSONString(o), CustdocRequestVo.class);
CustDocAssginVo custDocAssginVo = new CustDocAssginVo();
custDocAssginVo.setAssignallcorps("Y");
//分配给所有公司
custDocAssginVo.setCustprop("2");
custDocAssginVo.setPk_cubasdoc(BdCubasdocEntity1.getParentvo().getPk_cubasdoc());
HashMap<String, Object> assginHashMap = new HashMap<>();
assginHashMap.put("custbasvo", custDocAssginVo);
String assginjsonString = JSONObject.toJSONString(assginHashMap);
String assignresponse = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocAssgin"), assginjsonString);
CbdocResultVo assginCbdocResultVo = JSONObject.parseObject(assignresponse, CbdocResultVo.class);
if (!"success".equals(assginCbdocResultVo.getStatus())) {
isSuccess = false;
}
//生成客商管理档案
//地区名称：丽知商城客商？
parentvo.setPk_areacl("F");
parentvo.setCustprop(BdCubasdocEntity1.getParentvo().getCustprop());
CustmandocRequestVo custmandocRequestVo = new CustmandocRequestVo();
custmandocRequestVo.setParentvo(parentvo);
// BdCumandocEntity BdCumandocEntity = new BdCumandocEntity();
// BdCumandocEntity.setCustflag("1");
//
// BdCumandocEntity BdCumandocEntity1 = new BdCumandocEntity();
// BdCumandocEntity.setCustflag(" ");
// ArrayList<BdCumandocEntity> list = new ArrayList<>();
// list.add(BdCumandocEntity);
// list.add(BdCumandocEntity1);
// custmandocRequestVo.setChildrenvo(list);
//TODO 设置属性
HashMap<String, Object> mandocparam = new HashMap<>();
mandocparam.put("billvo", custmandocRequestVo);
String mandocjsonString = JSONObject.toJSONString(mandocparam);
String mandocresponse = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custmandocSave"), mandocjsonString);
CbdocResultVo mandoccbdocResultVo = JSONObject.parseObject(mandocresponse, CbdocResultVo.class);
if (!"success".equals(mandoccbdocResultVo.getStatus())) {
isSuccess = false;
}
}
if (!isSuccess) {
Assert.state(false, "推送U8C，原因：{} 接口入参:{} {}", JSON.toJSONString(cbdocResultVo), JSON.toJSONString(OverallConstant.getOverAllValue("custdocSave")), JSON.toJSONString(BdCubasdocEntity));
}
//TODO 根据返回结果记录日志
//成功
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setRootAppNewData(jsonString);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(JSON.toJSONString(cbdocResultVo));
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk(supplierEntity.getBizCode());
integrationTaskLivingDetailsEntity.setRootAppBill(supplierEntity.getName());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
//TODO 更新供应商状态
}
} catch (Exception e) {
e.printStackTrace();
String ErrMessage = e.getMessage();
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_N);
integrationTaskLivingDetailsEntity.setRootAppNewData(JSONObject.toJSONString(BdCubasdocEntity));
integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk(supplierEntity.getBizCode());
integrationTaskLivingDetailsEntity.setRootAppBill(supplierEntity.getName());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
logger.error("丽知：OFS供应商档案--->U8C客商档案,implement()方法报错：", e);
}
}
}
//过滤数据
public List<SupplierEntity> filterSupplierEntity(List<SupplierEntity> list) {
Assert.notNull(list, "不能为空！");
List<SupplierEntity> supplierEntityList = new ArrayList<>();
if (list != null && list.size() > 0) {
for (int i = 0; i < list.size(); i++) {
SupplierEntity supplierEntity = list.get(i);
if (supplierEntity.getBizCode() != null && !"".equals(supplierEntity.getBizCode().trim())) {
boolean isExis = true;
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setRootAppPk(supplierEntity.getBizCode());
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y_H);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity);
if (integrationTaskLivingDetailsEntities == null || integrationTaskLivingDetailsEntities.size() == 0) {
isExis = false;
}
if (!isExis) {
supplierEntityList.add(supplierEntity);
}
}
}
}
return supplierEntityList;
}
}

2
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/sales/SoSaleOutPluginInitializerToC.java
View File

@ -523,7 +523,7 @@ public class SoSaleOutPluginInitializerToC extends PluginBaseEntity {
//客商管理档案：2024年8月5日 15:41:54 TOC店铺名称查询U8C客商档案，已经和妮姐确认
//2024年8月5日 15:49:49 先根据O店铺编码，得到店铺档案信息，取到名称，通过U8C接口查询出来
//目前O店铺信息查询接口还没有，等待开发，所以我这里先写所一个名字
BdCumandocEntity bdCumandocEntity = TocOrderBasicArchivesCacheUtil.stringBdCumandocEntityMap.get(bdCubasdocEntity.getPkCubasdoc() + bdCorpEntity.getPkCorp());
BdCumandocEntity bdCumandocEntity = TocOrderBasicArchivesCacheUtil.stringBdCumandocEntityMap.get(bdCubasdocEntity.getPk_cubasdoc() + bdCorpEntity.getPkCorp());
Assert.notNull(bdCumandocEntity, "无法匹配到客商档案 店铺名称：{}", "天猫intoyou旗舰店-自营");
//查找平台

2
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/sales/SoSaleReturnPluginInitializerToC.java
View File

@ -513,7 +513,7 @@ public class SoSaleReturnPluginInitializerToC extends PluginBaseEntity {
//客商管理档案：2024年8月5日 15:41:54 TOC店铺名称查询U8C客商档案，已经和妮姐确认
//2024年8月5日 15:49:49 先根据O店铺编码，得到店铺档案信息，取到名称，通过U8C接口查询出来
//目前O店铺信息查询接口还没有，等待开发，所以我这里先写所一个名字
BdCumandocEntity bdCumandocEntity = TocReturnBasicArchivesCacheUtil.stringBdCumandocEntityMap.get(bdCubasdocEntity.getPkCubasdoc() + bdCorpEntity.getPkCorp());
BdCumandocEntity bdCumandocEntity = TocReturnBasicArchivesCacheUtil.stringBdCumandocEntityMap.get(bdCubasdocEntity.getPk_cubasdoc() + bdCorpEntity.getPkCorp());
Assert.notNull(bdCumandocEntity, "无法匹配到客商档案 店铺名称：{}", "天猫intoyou旗舰店-自营");
//查找平台

32
buildpackage/src/main/java/com/hzya/frame/plugin/lets/queryvo/AddrVo.java Normal file
View File

@ -0,0 +1,32 @@
package com.hzya.frame.plugin.lets.queryvo;
import lombok.Data;
/**
* @Author
* @Date 2024/8/6 16:14
* @PackageName:com.hzya.frame.plugin.lets.plugin.base.vo
* @ClassName: addrs
* @Description: TODO
*/
@Data
public class AddrVo {
private String addrname;
;
private boolean defaddrflag;
;
private String linkman;
;
private String phone;
;
private String pk_address;
;
private String pk_areacl;
;
private String pk_cubasdoc;
;
private String pk_custaddr;
;
private String status;
}

50
buildpackage/src/main/java/com/hzya/frame/plugin/lets/queryvo/BankVo.java Normal file
View File

@ -0,0 +1,50 @@
package com.hzya.frame.plugin.lets.queryvo;
import lombok.Data;
/**
* @Author
* @Date 2024/8/6 16:14
* @PackageName:com.hzya.frame.plugin.lets.plugin.base.vo
* @ClassName: banks
* @Description: TODO
*/
@Data
public class BankVo {
private String accname;
private String accopendate;
private String account;
private String accountname;
private String accountproperty;
private String bankarea;
private String banktypename;
private String defflag;
private String memo;
private String pk_accbank;
private String pk_bankdoc;
private String pk_corp;
private String pk_cubasdoc;
private String pk_currtype;
private String pk_custbank;
private String status;
private String ts;
private String unitname;
}

18
buildpackage/src/main/java/com/hzya/frame/plugin/lets/queryvo/CustDocAssginVo.java Normal file
View File

@ -0,0 +1,18 @@
package com.hzya.frame.plugin.lets.queryvo;
import lombok.Data;
/**
* @Author
* @Date 2024/8/8 14:53
* @PackageName:com.hzya.frame.plugin.lets.plugin.base.vo
* @ClassName: CustDocAssginVo
* @Description: TODO
*/
@Data
public class CustDocAssginVo {
private String assignallcorps;
private String custprop;
private String pk_corp;
private String pk_cubasdoc;
}

22
buildpackage/src/main/java/com/hzya/frame/plugin/lets/queryvo/CustdocRequestVo.java Normal file
View File

@ -0,0 +1,22 @@
package com.hzya.frame.plugin.lets.queryvo;
import com.hzya.frame.plugin.lets.entity.BdCubasdocEntity;
import lombok.Data;
import java.util.List;
/**
* @Author
* @Date 2024/8/6 16:13
* @PackageName:com.hzya.frame.plugin.lets.ofsvo
* @ClassName: cbdocvo
* @Description:
*/
@Data
public class CustdocRequestVo {
private List<AddrVo> addrs;
private List<BankVo> banks;
// private BdCubasdocEntity parentvo;
private BdCubasdocEntity parentvo;
}

23
buildpackage/src/main/java/com/hzya/frame/plugin/lets/queryvo/CustmandocRequestVo.java Normal file
View File

@ -0,0 +1,23 @@
package com.hzya.frame.plugin.lets.queryvo;
import com.hzya.frame.plugin.lets.entity.BdCubasdocEntity;
import com.hzya.frame.plugin.lets.entity.BdCumandocEntity;
import lombok.Data;
import java.util.List;
/**
* @Author
* @Date 2024/8/8 15:17
* @PackageName:com.hzya.frame.plugin.lets.plugin.base.vo
* @ClassName: CustmandocRequestVo
* @Description: TODO
*/
@Data
public class CustmandocRequestVo {
private List<AddrVo> addrs;
private List<BankVo> custBanks;
private List<BdCumandocEntity> childrenvo;
private BdCubasdocEntity parentvo;
}

21
buildpackage/src/main/java/com/hzya/frame/plugin/lets/resultvo/CbdocResultVo.java Normal file
View File

@ -0,0 +1,21 @@
package com.hzya.frame.plugin.lets.resultvo;
import lombok.Data;
/**
* @Author
* @Date 2024/8/6 17:55
* @PackageName:com.hzya.frame.plugin.lets.plugin.base.vo
* @ClassName: ShopResultVo
* @Description: 客商档案返回结果
*/
@Data
public class CbdocResultVo {
private String status;
private String data;
private String taskNumber;
private String errormsg;
}

26
buildpackage/src/main/java/com/hzya/frame/plugin/lets/resultvo/ShopReturnMessageDto.java Normal file
View File

@ -0,0 +1,26 @@
package com.hzya.frame.plugin.lets.resultvo;
import com.hzya.frame.plugin.lets.ofs.entity.ShopEntity;
import com.hzya.frame.ttxofs.basics.ReturnMessageBasics;
import com.hzya.frame.ttxofs.dto.ofssaleorderoutsearch.HeaderDetailsDto;
import java.util.List;
/**
* @Author
* @Date 2024/8/8 17:42
* @PackageName:com.hzya.frame.plugin.lets.plugin.base.vo
* @ClassName: ShopReturnMessageDto
* @Description: TODO
*/
public class ShopReturnMessageDto extends ReturnMessageBasics {
private List<ShopEntity> data;
public List<ShopEntity> getData() {
return data;
}
public void setData(List<ShopEntity> data) {
this.data = data;
}
}

50
buildpackage/src/main/java/com/hzya/frame/plugin/lets/util/SaveOrUpdateBusinessLogUtil.java
View File

@ -1,6 +1,5 @@
package com.hzya.frame.plugin.lets.util;
import cn.hutool.core.lang.Assert;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.dao.IIntegrationTaskLivingDetailsDao;
@ -11,17 +10,13 @@ import org.springframework.stereotype.Component;
import java.util.List;
/**
* 保存或者更新业务日志
*
* @author liuyang
*/
//保存或者更新业务日志
@Component
public class SaveOrUpdateBusinessLogUtil {
@Autowired
private IIntegrationTaskLivingDetailsDao iIntegrationTaskLivingDetailsDao;
private static final Object insertOrUpdateLock = new Object();
/**
@ -34,41 +29,6 @@ public class SaveOrUpdateBusinessLogUtil {
Assert.notNull(integrationTaskLivingDetailsEntity.getRootAppPk(), "源系统单号不能为空");
Assert.notNull(integrationTaskLivingDetailsEntity.getPluginId(), "场景id不能为空");
// Thread thread = new Thread(new Runnable() {
// @Override
// public void run() {
// synchronized (insertOrUpdateLock) {
// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetails = null;
// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity1 = new IntegrationTaskLivingDetailsEntity();
// integrationTaskLivingDetailsEntity1.setRoot_app_pk(integrationTaskLivingDetailsEntity.getRoot_app_pk());
// integrationTaskLivingDetailsEntity1.setPlugin_id(integrationTaskLivingDetailsEntity.getPlugin_id());
// List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity1);
// if (integrationTaskLivingDetailsEntities != null && integrationTaskLivingDetailsEntities.size() > 0) {
// integrationTaskLivingDetails = integrationTaskLivingDetailsEntities.get(0);
// }
//
// if (integrationTaskLivingDetails != null) {
// //存在
// integrationTaskLivingDetailsEntity.setId(integrationTaskLivingDetails.getId());
// updateSuccessMessage(integrationTaskLivingDetailsEntity);
// iIntegrationTaskLivingDetailsDao.update("com.hzya.frame.sys.integrationtask.living.dao.impl.IntegrationTaskLivingDetailsDaoImpl.entity_updatebyid", integrationTaskLivingDetailsEntity);
// } else {
// //不存在
// Long uuid = UUIDLong.longUUID();
// integrationTaskLivingDetailsEntity.setId(String.valueOf(uuid));
// updateSuccessMessage(integrationTaskLivingDetailsEntity);
// iIntegrationTaskLivingDetailsDao.save(integrationTaskLivingDetailsEntity);
// }
// }
// }
// });
// thread.start();
// try {
// thread.join();
// } catch (Exception e) {
// e.printStackTrace();
// }
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetails = null;
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity1 = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity1.setRootAppPk(integrationTaskLivingDetailsEntity.getRootAppPk());
@ -82,14 +42,16 @@ public class SaveOrUpdateBusinessLogUtil {
synchronized (insertOrUpdateLock) {
integrationTaskLivingDetailsEntity.setId(integrationTaskLivingDetails.getId());
updateSuccessMessage(integrationTaskLivingDetailsEntity);
iIntegrationTaskLivingDetailsDao.update("com.hzya.frame.sys.integrationtask.living.dao.impl.IntegrationTaskLivingDetailsDaoImpl.entity_updatebyid", integrationTaskLivingDetailsEntity);
// iIntegrationTaskLivingDetailsDao.update("com.hzya.frame.sysnew.integtationTaskLivingDetails.dao.impl.IntegrationTaskLivingDetailsDaoImpl.entity_updatebyid", integrationTaskLivingDetailsEntity);
iIntegrationTaskLivingDetailsDao.update(integrationTaskLivingDetailsEntity);
}
} else {
//不存在
Long uuid = UUIDLong.longUUID();
integrationTaskLivingDetailsEntity.setId(String.valueOf(uuid));
updateSuccessMessage(integrationTaskLivingDetailsEntity);
iIntegrationTaskLivingDetailsDao.save(integrationTaskLivingDetailsEntity);
IntegrationTaskLivingDetailsEntity save = iIntegrationTaskLivingDetailsDao.save(integrationTaskLivingDetailsEntity);
System.out.println("save = " + save);
}
}

4
buildpackage/src/main/resources/application-local.yml
View File

@ -12,12 +12,14 @@ spring:
dynamic:
datasource:
master:
url: jdbc:mysql://hzya.ufyct.com:9014/businesscenter?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowLoadLocalInfile=false&autoReconnect=true&failOverReadOnly=false&connectTimeout=30000&socketTimeout=30000&autoReconnectForPools=true
url: jdbc:mysql://192.168.14.252:3306/businesscenter?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowLoadLocalInfile=false&autoReconnect=true&failOverReadOnly=false&connectTimeout=30000&socketTimeout=30000&autoReconnectForPools=true
username: root
password: 62e4295b615a30dbf3b8ee96f41c820b
driver-class-name: com.mysql.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
savefile:
# 文件保存路径
path: /Users/apple/Desktop/log/local
zt:
url: http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterface

5
buildpackage/src/main/resources/cfgHome/plugin/lets/spring/spring-sowow-plugin.xml
View File

@ -9,6 +9,11 @@
<bean name="goodsPluginInitializer" class="com.hzya.frame.plugin.lets.plugin.base.GoodsPluginInitializer"/>
<bean name="goodsAutoAllotPluginInitializer" class="com.hzya.frame.plugin.lets.plugin.base.GoodsAutoAllotPluginInitializer"/>
<bean name="goodsClassPluginInitializer" class="com.hzya.frame.plugin.lets.plugin.base.GoodsClassPluginInitializer"/>
<bean name="CustdocAutoAllotPluginInitializer" class="com.hzya.frame.plugin.lets.plugin.base.CustdocAutoAllotPluginInitializer"/>
<bean name="CustmandocPluginInitializer" class="com.hzya.frame.plugin.lets.plugin.base.CustmandocPluginInitializer"/>
<bean name="ShopPluginInitializer" class="com.hzya.frame.plugin.lets.plugin.base.ShopPluginInitializer"/>
<bean name="SupplierPluginInitializer" class="com.hzya.frame.plugin.lets.plugin.base.SupplierPluginInitializer"/>
<!--调拨-->
<bean name="transferPluginInitializer" class="com.hzya.frame.plugin.lets.plugin.transfer.TransferPluginInitializer"/>
<bean name="transferInPluginInitializer" class="com.hzya.frame.plugin.lets.plugin.transfer.TransferInPluginInitializer"/>

99
buildpackage/src/test/java/com/hzya/frame/plugin/lets/plugin/base/ShopTest.java Normal file
View File

@ -0,0 +1,99 @@
package com.hzya.frame.plugin.lets.plugin.base;
import com.hzya.frame.WebappApplication;
import com.hzya.frame.plugin.lets.entity.BdCubasdocEntity;
import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo;
import com.hzya.frame.plugin.lets.util.PushDataByU8cUtil;
import com.hzya.frame.ttxofs.service.OfsUnifiedService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.ArrayList;
/**
* @Author
* @Date 2024/8/8 9:09
* @PackageName:com.hzya.frame.plugin.lets.plugin.base
* @ClassName: ShopTest
* @Description: TODO
*/
@RunWith(SpringRunner.class)
@SpringBootTest(classes = WebappApplication.class)
public class ShopTest {
@Autowired
private ShopPluginInitializer shopPluginInitializer;
@Autowired
private OfsUnifiedService ofsUnifiedService;
@Autowired
private PushDataByU8cUtil pushDataByU8cUtil;
@Autowired
private CustmandocPluginInitializer custmandocPluginInitializer;
@Test
public void t00() {
// shopPluginInitializer.startImplement();
// ShopEntity shopEntity = new ShopEntity();
// shopEntity.setStatus(1);
// shopEntity.setClientCode("LETS");
// InterfaceParamDto interfaceParamDto = new InterfaceParamDto();
// interfaceParamDto.setApi("ofs.store.search");
// interfaceParamDto.setData(JSON.toJSONString(shopEntity));
// try {
// ShopReturnMessageDto unified = (ShopReturnMessageDto) ofsUnifiedService.unified(interfaceParamDto);
// System.out.println(unified);
// } catch (Exception e) {
// throw new RuntimeException(e);
// }
// ArrayList<ShopEntity> shopEntities = new ArrayList<>();
// ShopEntity shopEntity = new ShopEntity();
// shopEntity.setBizCode("intoyou-xhs");
// shopEntity.setName("小红书INTO YOU心慕与你旗舰店-自营1test1a1231");
// shopEntity.setCustomerCode("testcode11232411");
// shopEntities.add(shopEntity);
// shopPluginInitializer.implement(shopEntities);
// System.out.println("shopEntities = " + shopEntities);
// try {
// System.out.println("开始推送");
// //分配给所有公司
// CustDocAssginVo custDocAssginVo = new CustDocAssginVo();
// custDocAssginVo.setAssignallcorps("Y");
// //客户基本档案主键
// custDocAssginVo.setPk_cubasdoc("0001A210000000000PNV");
// //公司主键
// custDocAssginVo.setCustprop("2");
// HashMap<String, Object> assginHashMap = new HashMap<>();
// assginHashMap.put("custbasvo", custDocAssginVo);
// String assginjsonString = JSONObject.toJSONString(assginHashMap);
// String assignresponse = null;
// assignresponse = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocAssign"), assginjsonString);
// CbdocResultVo cbdocResultVo1 = JSONObject.parseObject(assignresponse, CbdocResultVo.class);
// System.out.println("cbdocResultVo1 = " + cbdocResultVo1);
// //{"custbasvo":[{"custprop":"2","pk_cubasdoc":"CU785@@@000001","assignallcorps":"Y"}]}
// } catch (Exception e) {
// throw new RuntimeException(e);
// }
//生成客商管理档案
BdCubasdocEntity parentvo = new BdCubasdocEntity();
parentvo.setCustname("测试客商管理档11223案");
parentvo.setCustshortname("测试客商管理档13121案");
parentvo.setCustcode("test34121a");
//地区名称：丽知商城客商？
parentvo.setPk_areacl("F");
parentvo.setPk_corp("0001");
CustdocRequestVo custdocRequestVo = new CustdocRequestVo();
custdocRequestVo.setParentvo(parentvo);
ArrayList<CustdocRequestVo> list = new ArrayList<>();
list.add(custdocRequestVo);
custmandocPluginInitializer.implement(list);
}
}

1
service/src/main/java/com/hzya/frame/sys/businessFile/controller/BusinessFileController.java
View File

@ -19,6 +19,7 @@ import org.springframework.web.servlet.ModelAndView;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;
import java.util.zip.ZipOutputStream;

4
service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/entity/IntegrationTaskLivingDetailsEntity.java
View File

@ -2,12 +2,15 @@ package com.hzya.frame.sysnew.integtationTaskLivingDetails.entity;
import java.util.Date;
import com.hzya.frame.web.entity.BaseEntity;
import lombok.Data;
/**
* 集成任务-实例详情(IntegrationTaskLivingDetails)实体类
*
* @author makejava
* @since 2024-05-15 14:06:41
*/
@Data
public class IntegrationTaskLivingDetailsEntity extends BaseEntity {
/** 集成任务-实例_id */
@ -85,7 +88,6 @@ public class IntegrationTaskLivingDetailsEntity extends BaseEntity {
public void setQueryCondition(String queryCondition) {
this.queryCondition = queryCondition;
}
public String getRootAppPk() {
return rootAppPk;
}