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

店铺，供应商

This commit is contained in:
sx 2024-08-13 13:58:08 +08:00
parent 0f86bbf9da
commit eac2ca9b44
4 changed files with 38 additions and 76 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/CustdocAutoAllotPluginInitializer.java
View File

@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.base.PluginBaseEntity; import com.hzya.frame.base.PluginBaseEntity;
import com.hzya.frame.plugin.lets.constant.OverallConstant; import com.hzya.frame.plugin.lets.constant.OverallConstant;
import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant; import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant;
import com.hzya.frame.plugin.lets.entity.BdCorpEntity;
import com.hzya.frame.plugin.lets.entity.BdInvbasdocEntity; import com.hzya.frame.plugin.lets.entity.BdInvbasdocEntity;
import com.hzya.frame.plugin.lets.queryvo.CustDocAssginVo; import com.hzya.frame.plugin.lets.queryvo.CustDocAssginVo;
import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo; import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo;
@ -132,7 +133,10 @@ public class CustdocAutoAllotPluginInitializer extends PluginBaseEntity {
String data = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocQuery"), "{}"); String data = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocQuery"), "{}");
CbdocResultVo cbdocResultVo = JSONObject.parseObject(data, CbdocResultVo.class); CbdocResultVo cbdocResultVo = JSONObject.parseObject(data, CbdocResultVo.class);
String datastring = cbdocResultVo.getData(); String datastring = cbdocResultVo.getData();
List list = JSONObject.parseObject(datastring, List.class); Map map = JSONObject.parseObject(datastring, Map.class);
Object o = map.get("datas");
String jsonString = JSONObject.toJSONString(o);
List<CustdocRequestVo> list = JSONObject.parseArray(jsonString, CustdocRequestVo.class);
custdocRequestVos = filterData(list); custdocRequestVos = filterData(list);
} catch (Exception e) { } catch (Exception e) {
logger.error("丽知：U8C->客商基本档案自动分配全公司,查询客商基本档案失败", e); logger.error("丽知：U8C->客商基本档案自动分配全公司,查询客商基本档案失败", e);
@ -140,13 +144,10 @@ public class CustdocAutoAllotPluginInitializer extends PluginBaseEntity {
return custdocRequestVos; return custdocRequestVos;
} }
private List<CustdocRequestVo> filterData(List list) { private List<CustdocRequestVo> filterData(List<CustdocRequestVo> list) {
List<CustdocRequestVo> filterlist = new ArrayList<>(); List<CustdocRequestVo> filterlist = new ArrayList<>();
for (Object o : list) { for (CustdocRequestVo requestVo : list) {
//o转为 //o转为
CustdocRequestVo requestVo = JSONObject.parseObject(JSONObject.toJSONString(o), CustdocRequestVo.class);
if("N".equals(requestVo.getParentvo().getDef10())){ if("N".equals(requestVo.getParentvo().getDef10())){
filterlist.add(requestVo); filterlist.add(requestVo);
} }
@ -159,17 +160,22 @@ public class CustdocAutoAllotPluginInitializer extends PluginBaseEntity {
*/ */
public void implement(List<CustdocRequestVo> list) { public void implement(List<CustdocRequestVo> list) {
//查询公司档案 // //查询公司档案
try { // try {
String corpresponse = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("bdcorpQuery"), "{}"); // String corpresponse = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("bdcorpQuery"), "{}");
CbdocResultVo cbdocResultVo = JSONObject.parseObject(corpresponse, CbdocResultVo.class); // CbdocResultVo cbdocResultVo = JSONObject.parseObject(corpresponse, CbdocResultVo.class);
if(cbdocResultVo.getStatus()!="success"){ // if(cbdocResultVo.getStatus()!="success"){
Assert.state(false, "查询公司档案失败"); // Assert.state(false, "查询公司档案失败");
} // }
// String data = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("bdcorpQuery"), "{}");
} catch (Exception e) { // CbdocResultVo ResultVo = JSONObject.parseObject(data, CbdocResultVo.class);
throw new RuntimeException(e); // String datastring = ResultVo.getData();
} // Map map = JSONObject.parseObject(datastring, Map.class);
// Object o = map.get("datas");
// List<BdCorpEntity> bdCorpEntities = JSONObject.parseArray(JSON.toJSONString(o), BdCorpEntity.class);
// } catch (Exception e) {
// throw new RuntimeException(e);
// }
for (CustdocRequestVo custdocRequestVo : list) { for (CustdocRequestVo custdocRequestVo : list) {
String assginjsonString = ""; String assginjsonString = "";

18
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/CustmandocPluginInitializer.java
View File

@ -12,6 +12,7 @@ import com.hzya.frame.plugin.lets.entity.BdCumandocEntity;
import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo; import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo;
import com.hzya.frame.plugin.lets.queryvo.CustmandocRequestVo; import com.hzya.frame.plugin.lets.queryvo.CustmandocRequestVo;
import com.hzya.frame.plugin.lets.resultvo.CbdocResultVo;
import com.hzya.frame.plugin.lets.u8cdto.ReusltStrDto; import com.hzya.frame.plugin.lets.u8cdto.ReusltStrDto;
import com.hzya.frame.plugin.lets.util.PushDataByU8cUtil; import com.hzya.frame.plugin.lets.util.PushDataByU8cUtil;
import com.hzya.frame.plugin.lets.util.SaveOrUpdateBusinessLogUtil; import com.hzya.frame.plugin.lets.util.SaveOrUpdateBusinessLogUtil;
@ -103,8 +104,11 @@ public class CustmandocPluginInitializer extends PluginBaseEntity {
List<CustdocRequestVo> custdocRequestVos=null; List<CustdocRequestVo> custdocRequestVos=null;
try { try {
String data = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocQuery"), "{}"); String data = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("custdocQuery"), "{}");
CbdocResultVo cbdocResultVo = JSONObject.parseObject(data, CbdocResultVo.class);
List list = JSONObject.parseObject(data, List.class); String datastring = cbdocResultVo.getData();
Map map = JSONObject.parseObject(datastring, Map.class);
Object o = map.get("datas");
List<CustdocRequestVo> list = JSONObject.parseArray(JSON.toJSONString(o), CustdocRequestVo.class);
custdocRequestVos = filterData(list); custdocRequestVos = filterData(list);
} catch (Exception e) { } catch (Exception e) {
@ -113,13 +117,11 @@ public class CustmandocPluginInitializer extends PluginBaseEntity {
return custdocRequestVos; return custdocRequestVos;
} }
private List<CustdocRequestVo> filterData(List list) { private List<CustdocRequestVo> filterData(List<CustdocRequestVo> list) {
List<CustdocRequestVo> filterlist = new ArrayList<>(); List<CustdocRequestVo> filterlist = new ArrayList<>();
for (Object o : list) { for (CustdocRequestVo requestVo : list) {
//o转为 if("N".equals(requestVo.getParentvo().getDef11())){
CustdocRequestVo BdCubasdocEntity = JSONObject.parseObject(JSONObject.toJSONString(o), CustdocRequestVo.class); filterlist.add(requestVo);
if("N".equals(BdCubasdocEntity.getParentvo().getDef11())){
filterlist.add(BdCubasdocEntity);
} }
} }
return filterlist; return filterlist;

5
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/ShopPluginInitializer.java
View File

@ -209,7 +209,7 @@ public class ShopPluginInitializer extends PluginBaseEntity {
parentvo.setCustcode(shopEntity.getCustomerCode()); parentvo.setCustcode(shopEntity.getCustomerCode());
//设置还未分配公司 //设置还未分配公司
parentvo.setDef10("N"); parentvo.setDef10("N");
//设置还同步到管理档案 //设置还未同步到管理档案
parentvo.setDef11("N"); parentvo.setDef11("N");
// parentvo.setCustprop("0"); // parentvo.setCustprop("0");
BdCubasdocEntity.setParentvo(parentvo); BdCubasdocEntity.setParentvo(parentvo);
@ -249,8 +249,6 @@ public class ShopPluginInitializer extends PluginBaseEntity {
//TODO 更新店铺状态 //TODO 更新店铺状态
// CbdocResultVo cbdocResultVo1 = JSONObject.parseObject(response, CbdocResultVo.class); // CbdocResultVo cbdocResultVo1 = JSONObject.parseObject(response, CbdocResultVo.class);
// String errormsg = cbdocResultVo1.getErrormsg(); // String errormsg = cbdocResultVo1.getErrormsg();
} }
} catch (Exception e) { } catch (Exception e) {
@ -275,7 +273,6 @@ public class ShopPluginInitializer extends PluginBaseEntity {
public List<ShopEntity> filterShopEntity(List<ShopEntity> list) { public List<ShopEntity> filterShopEntity(List<ShopEntity> list) {
Assert.notNull(list, "不能为空！"); Assert.notNull(list, "不能为空！");
List<ShopEntity> shopEntityList = new ArrayList<>(); List<ShopEntity> shopEntityList = new ArrayList<>();
if (list != null && list.size() > 0) { if (list != null && list.size() > 0) {
for (int i = 0; i < list.size(); i++) { for (int i = 0; i < list.size(); i++) {

51
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/SupplierPluginInitializer.java
View File

@ -190,6 +190,10 @@ public class SupplierPluginInitializer extends PluginBaseEntity {
parentvo.setCustshortname(supplierEntity.getName()); parentvo.setCustshortname(supplierEntity.getName());
parentvo.setCustcode(supplierEntity.getCompanyCode()); parentvo.setCustcode(supplierEntity.getCompanyCode());
//设置还未分配公司
parentvo.setDef10("N");
//设置还未同步到管理档案
parentvo.setDef11("N");
BdCubasdocEntity.setParentvo(parentvo); BdCubasdocEntity.setParentvo(parentvo);
// 同步u8c // 同步u8c
HashMap<String, Object> param = new HashMap<>(); HashMap<String, Object> param = new HashMap<>();
@ -205,53 +209,6 @@ public class SupplierPluginInitializer extends PluginBaseEntity {
isSuccess = true; isSuccess = true;
taskNumber = cbdocResultVo.getTaskNumber(); taskNumber = cbdocResultVo.getTaskNumber();
String data = cbdocResultVo.getData(); 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);
// 设置属性
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) { if (!isSuccess) {
Assert.state(false, "推送U8C，原因：{} 接口入参:{} {}", JSON.toJSONString(cbdocResultVo), JSON.toJSONString(OverallConstant.getOverAllValue("custdocSave")), JSON.toJSONString(BdCubasdocEntity)); Assert.state(false, "推送U8C，原因：{} 接口入参:{} {}", JSON.toJSONString(cbdocResultVo), JSON.toJSONString(OverallConstant.getOverAllValue("custdocSave")), JSON.toJSONString(BdCubasdocEntity));